package com.vincent.rsf.openApi.controller;
|
|
import com.vincent.rsf.framework.common.R;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.openApi.entity.dto.CommonResponse;
|
import com.vincent.rsf.openApi.entity.params.ExMsgCallbackParams;
|
import com.vincent.rsf.openApi.entity.params.LocSiteParams;
|
import com.vincent.rsf.openApi.entity.params.LocationAllocateParams;
|
import com.vincent.rsf.openApi.entity.params.RcsPubTaskParams;
|
import com.vincent.rsf.openApi.entity.params.SyncRcsLocsParam;
|
import com.vincent.rsf.openApi.entity.params.TaskReportParams;
|
import com.vincent.rsf.openApi.service.WmsRcsService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Map;
|
import java.util.Objects;
|
|
@Slf4j
|
@RestController
|
@Api("RCS调度交互接口")
|
@RequestMapping("/rcs")
|
public class WmsRcsController {
|
|
@Autowired
|
private WmsRcsService wmsRcsService;
|
|
/**
|
* @author Ryan
|
* @date 2025/8/27
|
* @description: 任务下发
|
* @version 1.0
|
*/
|
@ApiOperation("调度任务下发")
|
@PostMapping("/pub/task")
|
public CommonResponse pubTasks(@RequestBody RcsPubTaskParams params) {
|
if (Objects.isNull(params)) {
|
throw new CoolException("参数不能为空！！");
|
}
|
return wmsRcsService.pubTasks(params);
|
}
|
|
/**
|
* @author Ryan
|
* @date 2025/8/27
|
* @description: 取消任务
|
* @version 1.0
|
*/
|
@ApiOperation("取消调度任务")
|
@PostMapping("/cancel/task")
|
public CommonResponse cancelTasks(@RequestBody Map<String, Object> params) {
|
return wmsRcsService.cancelTasks(params);
|
}
|
|
/**
|
* @author Ryan
|
* @date 2025/8/27
|
* @description: 任务回调，状态回写
|
* @version 1.0
|
*/
|
@ApiOperation("状态上报回调")
|
@PostMapping("/callback/event")
|
public CommonResponse callBackEvent(@RequestBody ExMsgCallbackParams params) {
|
return wmsRcsService.callBackEvent(params);
|
}
|
|
|
/**
|
* @author Ryan
|
* @date 2025/8/27
|
* @description: RCS库位信息同步
|
* @version 1.0
|
*/
|
@ApiOperation("RCS库位信息同步")
|
@PostMapping("/sync/locs")
|
public R syncLocsToWms(@RequestBody SyncRcsLocsParam params) {
|
if (Objects.isNull(params)) {
|
return R.error("参数不能为空！！");
|
}
|
return R.ok().add(wmsRcsService.syncLocs(params));
|
}
|
|
/**
|
* @author Ryan
|
* @date 2025/11/10
|
* @description: WMS 出库成功后，修改库位、站点状态
|
* @version 1.0
|
*/
|
@ApiOperation("RCS修改库位或站点状态")
|
@PostMapping("/modify/status")
|
public R modifyLocOrSite(@RequestBody LocSiteParams params) {
|
if (Objects.isNull(params)) {
|
return R.error("参数不能为空！！");
|
}
|
return wmsRcsService.modifyLocOrSite(params);
|
}
|
|
/**
|
* @author Ryan
|
* @date 2026/2/3
|
* @description: RCS回调接口
|
* @version 1.0
|
*/
|
@ApiOperation("RCS回调接口")
|
@PostMapping("/api/open/task/report")
|
public CommonResponse reportTask(@RequestBody TaskReportParams params) {
|
log.debug("RCS回调：{}", params);
|
if (Objects.isNull(params)) {
|
throw new CoolException("参数不能为空！！");
|
}
|
return wmsRcsService.reportTask(params);
|
}
|
|
/**
|
* @author Ryan
|
* @date 2026/2/6
|
* @description: 申请入库任务
|
* @version 1.0
|
*/
|
@ApiOperation("申请入库任务")
|
@PostMapping("/api/open/location/allocate")
|
public R allocateLocation(@RequestBody LocationAllocateParams params) {
|
log.info("申请入库任务，请求参数：{}", params);
|
if (Objects.isNull(params)) {
|
return R.error("参数不能为空！！");
|
}
|
if (Objects.isNull(params.getBarcode()) || params.getBarcode().isEmpty()) {
|
return R.error("料箱码不能为空！！");
|
}
|
if (Objects.isNull(params.getStaNo()) || params.getStaNo().isEmpty()) {
|
return R.error("入库站点不能为空！！");
|
}
|
if (Objects.isNull(params.getType())) {
|
params.setType(18);
|
}
|
return wmsRcsService.allocateLocation(params);
|
}
|
|
}
|
