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.params.RcsPubTaskParams;
|
import com.vincent.rsf.openApi.entity.params.SyncRcsLocsParam;
|
import com.vincent.rsf.openApi.service.WmsRcsService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
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;
|
|
@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 R 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 R 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 R callBackEvent(@RequestBody Map<String, Object> 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));
|
}
|
|
|
}
|
