|
@@ -1,8 +1,10 @@
|
|
package com.ruoyi.ams.xuankuang.service;
|
|
package com.ruoyi.ams.xuankuang.service;
|
|
|
|
|
|
|
|
+import cn.hutool.core.collection.CollectionUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
|
|
+import com.google.common.collect.Lists;
|
|
import com.ruoyi.ams.asn.domain.WmsDocAsnDetails;
|
|
import com.ruoyi.ams.asn.domain.WmsDocAsnDetails;
|
|
import com.ruoyi.ams.asn.domain.WmsDocAsnHeader;
|
|
import com.ruoyi.ams.asn.domain.WmsDocAsnHeader;
|
|
import com.ruoyi.ams.asn.service.IWmsDocAsnDetailsService;
|
|
import com.ruoyi.ams.asn.service.IWmsDocAsnDetailsService;
|
|
@@ -64,6 +66,11 @@ public class WcsTaskSubService {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
+ public AjaxResult addWcsTask(String locationFrom, String locationTo
|
|
|
|
+ , String asnNo, String palletNo, String wcsNo) {
|
|
|
|
+ return addWcsTask(IdWorker.getIdStr(), locationFrom, locationTo, asnNo, palletNo, wcsNo, 10L, "立体库入库任务", StringUtils.EMPTY);
|
|
|
|
+ }
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 新增wcsTask,兼容老的四向车立体库任务
|
|
* 新增wcsTask,兼容老的四向车立体库任务
|
|
* @param locationFrom
|
|
* @param locationFrom
|
|
@@ -73,11 +80,16 @@ public class WcsTaskSubService {
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
public AjaxResult addWcsTask(String locationFrom, String locationTo
|
|
public AjaxResult addWcsTask(String locationFrom, String locationTo
|
|
- , String asnNo, String palletNo, String wcsNo) {
|
|
|
|
- return addWcsTask(IdWorker.getIdStr(), locationFrom, locationTo, asnNo, palletNo, wcsNo, 10L, "立体库入库任务");
|
|
|
|
|
|
+ , String asnNo, String palletNo, String wcsNo, String taskType) {
|
|
|
|
+ return addWcsTask(IdWorker.getIdStr(), locationFrom, locationTo, asnNo, palletNo, wcsNo, 10L, "立体库入库任务", taskType);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
+
|
|
|
|
+ public AjaxResult addWcsTask(String taskNo, String locationFrom, String locationTo
|
|
|
|
+ , String asnNo, String palletNo, Long state, String remake) {
|
|
|
|
+ return addWcsTask(taskNo, locationFrom, locationTo, asnNo, palletNo, StringUtils.EMPTY, state, remake, StringUtils.EMPTY);
|
|
|
|
+ }
|
|
/**
|
|
/**
|
|
* 增加wcsTask,桶装入库的时候封装用
|
|
* 增加wcsTask,桶装入库的时候封装用
|
|
* @param taskNo
|
|
* @param taskNo
|
|
@@ -89,15 +101,16 @@ public class WcsTaskSubService {
|
|
* @param remake
|
|
* @param remake
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
|
|
+
|
|
public AjaxResult addWcsTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsTask(String taskNo, String locationFrom, String locationTo
|
|
- , String asnNo, String palletNo, Long state, String remake) {
|
|
|
|
- return addWcsTask(taskNo, locationFrom, locationTo, asnNo, palletNo, StringUtils.EMPTY, state, remake);
|
|
|
|
|
|
+ , String asnNo, String palletNo, Long state, String remake, String taskType) {
|
|
|
|
+ return addWcsTask(taskNo, locationFrom, locationTo, asnNo, palletNo, StringUtils.EMPTY, state, remake, taskType);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public AjaxResult addWcsTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsTask(String taskNo, String locationFrom, String locationTo
|
|
- , String asnNo, String palletNo, String wcsNo, Long state, String remake) {
|
|
|
|
|
|
+ , String asnNo, String palletNo, String wcsNo, Long state, String remake, String taskType) {
|
|
|
|
|
|
BaseLocationInfo baseLocationInfoFrom = iBaseLocationInfoService.selectBaseLocationInfoByIdOrNo(locationFrom, 1l);
|
|
BaseLocationInfo baseLocationInfoFrom = iBaseLocationInfoService.selectBaseLocationInfoByIdOrNo(locationFrom, 1l);
|
|
BaseLocationInfo baseLocationInfoTo = iBaseLocationInfoService.selectBaseLocationInfoByIdOrNo(locationTo, 1l);
|
|
BaseLocationInfo baseLocationInfoTo = iBaseLocationInfoService.selectBaseLocationInfoByIdOrNo(locationTo, 1l);
|
|
@@ -119,6 +132,7 @@ public class WcsTaskSubService {
|
|
wcsTask.setExt2(palletNo);
|
|
wcsTask.setExt2(palletNo);
|
|
wcsTask.setExt3(wcsNo);
|
|
wcsTask.setExt3(wcsNo);
|
|
wcsTask.setRemark(remake);
|
|
wcsTask.setRemark(remake);
|
|
|
|
+ wcsTask.setExt8(taskType);
|
|
if (iWcsTaskService.insertWcsTask(wcsTask) > 0) {
|
|
if (iWcsTaskService.insertWcsTask(wcsTask) > 0) {
|
|
iBaseLocationInfoService.lockLocationStockStatus(Long.valueOf(wcsTask.getLocationFrom())
|
|
iBaseLocationInfoService.lockLocationStockStatus(Long.valueOf(wcsTask.getLocationFrom())
|
|
, Long.valueOf(wcsTask.getLocationTo())
|
|
, Long.valueOf(wcsTask.getLocationTo())
|
|
@@ -168,19 +182,24 @@ public class WcsTaskSubService {
|
|
|
|
|
|
|
|
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
- , String orderNo, String palletNo, String wcsNo, Long state, String remark) {
|
|
|
|
- return addWcsTask(taskNo, locationFrom, locationTo, orderNo, palletNo, wcsNo, state, remark);
|
|
|
|
|
|
+ , String orderNo, String palletNo, String wcsNo, Long state, String remark, String taskType) {
|
|
|
|
+ return addWcsTask(taskNo, locationFrom, locationTo, orderNo, palletNo, wcsNo, state, remark, taskType);
|
|
}
|
|
}
|
|
|
|
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
- , String orderNo, String wcsNo, Long state, String remark) {
|
|
|
|
- return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, StringUtils.EMPTY, wcsNo, state, remark);
|
|
|
|
|
|
+ , String orderNo, String palletNo, String wcsNo, Long state, String remark) {
|
|
|
|
+ return addWcsTask(taskNo, locationFrom, locationTo, orderNo, palletNo, wcsNo, state, remark, StringUtils.EMPTY);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
, String orderNo, String palletNo, String remark) {
|
|
, String orderNo, String palletNo, String remark) {
|
|
- return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, palletNo, StringUtils.EMPTY, 10L, remark);
|
|
|
|
|
|
+ return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, palletNo, remark, StringUtils.EMPTY);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
|
|
+ , String orderNo, String palletNo, String remark, String taskType) {
|
|
|
|
+ return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, palletNo, StringUtils.EMPTY, 10L, remark, taskType);
|
|
}
|
|
}
|
|
|
|
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
@@ -190,7 +209,7 @@ public class WcsTaskSubService {
|
|
|
|
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
public AjaxResult addWcsOutTask(String taskNo, String locationFrom, String locationTo
|
|
, String orderNo) {
|
|
, String orderNo) {
|
|
- return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, StringUtils.EMPTY, 10L, "立体库出库任务");
|
|
|
|
|
|
+ return addWcsOutTask(taskNo, locationFrom, locationTo, orderNo, StringUtils.EMPTY, StringUtils.EMPTY, 10L, "立体库出库任务", StringUtils.EMPTY);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -283,7 +302,8 @@ public class WcsTaskSubService {
|
|
// 修改出库单收货数量
|
|
// 修改出库单收货数量
|
|
completeTheCallbackOut(wcsTask);
|
|
completeTheCallbackOut(wcsTask);
|
|
}//空托任务反馈和移库反馈
|
|
}//空托任务反馈和移库反馈
|
|
- else if (wcsTask.getExt1().equals("") && !wcsTask.getExt3().equals("")) {
|
|
|
|
|
|
+ else if (CollectionUtil.contains(
|
|
|
|
+ Lists.newArrayList(Constant.TaskType.EMPTY_PALLET, Constant.TaskType.MOVE_INV), wcsTask.getExt8())) {
|
|
invLotLocIdService.adjLocationIsEmpty(wcsTask.getLocationFrom(), Constant.WAREHOUSE_ID, "Wcs");
|
|
invLotLocIdService.adjLocationIsEmpty(wcsTask.getLocationFrom(), Constant.WAREHOUSE_ID, "Wcs");
|
|
}//agv出库完成后反馈回调取货完成
|
|
}//agv出库完成后反馈回调取货完成
|
|
else if (wcsTask.getExt5() != null) {
|
|
else if (wcsTask.getExt5() != null) {
|