| | |
| | | |
| | | 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.RcsPubTaskParams; |
| | | import com.vincent.rsf.openApi.entity.params.SyncRcsLocsParam; |
| | | import com.vincent.rsf.openApi.service.WmsRcsService; |
| | |
| | | */ |
| | | @ApiOperation("调度任务下发") |
| | | @PostMapping("/pub/task") |
| | | public R pubTasks(@RequestBody RcsPubTaskParams params) { |
| | | public CommonResponse pubTasks(@RequestBody RcsPubTaskParams params) { |
| | | if (Objects.isNull(params)) { |
| | | throw new CoolException("参数不能为空!!"); |
| | | } |
| | |
| | | */ |
| | | @ApiOperation("取消调度任务") |
| | | @PostMapping("/cancel/task") |
| | | public R cancelTasks(@RequestBody Map<String, Object> params) { |
| | | public CommonResponse cancelTasks(@RequestBody Map<String, Object> params) { |
| | | return wmsRcsService.cancelTasks(params); |
| | | } |
| | | |
| | |
| | | */ |
| | | @ApiOperation("状态上报回调") |
| | | @PostMapping("/callback/event") |
| | | public R callBackEvent(@RequestBody ExMsgCallbackParams params) { |
| | | public CommonResponse callBackEvent(@RequestBody ExMsgCallbackParams params) { |
| | | return wmsRcsService.callBackEvent(params); |
| | | } |
| | | |
| | |
| | | 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); |
| | | } |
| | | |
| | | |
| | | } |