From 87d66c61fc5047fb5708d609f4a5f1f868cd646c Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期四, 10 七月 2025 18:04:30 +0800
Subject: [PATCH] no message
---
zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/WaveManagentController.java | 4 +
zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/WaveSeed.java | 3
zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/param/WaveSeedReviewParam.java | 2
zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java | 136 ++++++++++++++++++----------------
zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java | 20 +++--
zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaveSeedServiceImpl.java | 18 +---
6 files changed, 98 insertions(+), 85 deletions(-)
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java
index 7d7c5e2..953a736 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java
@@ -117,26 +117,30 @@
throw new CoolException("褰撳墠绔欑偣涓嶅瓨鍦紒锛�");
}
- List<WaveSeed> waveSeed = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getSiteNo, request.get("tagCode").toString()));
+ WaveSeed waveSeed = waveSeedService.getOne(new LambdaQueryWrapper<WaveSeed>()
+ .eq(WaveSeed::getExceStatus, 1)
+ .eq(WaveSeed::getSiteNo, request.get("tagCode").toString()));
if (Objects.isNull(waveSeed)) {
throw new CoolException("鎾澧欏湴鏍囨湭缁戝畾锛侊紒");
}
- List<Long> taskIds = waveSeed.stream().map(WaveSeed::getTaskId).collect(Collectors.toList());
-
// 鏍规嵁鎾绔欑偣淇℃伅鏉＄爜锛屾煡浠诲姟
- List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, taskIds));
- if (tasks.isEmpty()) {
+ Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getId, waveSeed.getTaskId()));
+ if (Objects.isNull(task)) {
throw new CoolException("褰撳墠绔欑偣浠诲姟涓嶅瓨鍦紒锛�");
}
- List<String> taskNos = tasks.stream().map(Task::getTaskNo).collect(Collectors.toList());
-
Map<String, Object> param = new HashMap<>();
- param.put("taskNo", taskNos);
+ param.put("taskNo", task.getTaskNo());
param.put("siteNo", cacheSite.getSiteNo());
+ param.put("weedId", waveSeed.getId());
param.put("orderNo",cacheSite.getOrderNo());
+ waveSeed.setExceStatus(0);
+ if (!waveSeedService.updateById(waveSeed)) {
+ throw new CoolException("鎾鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+ }
+
return wcsApiService.slapLightLogic(param);
}
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/WaveManagentController.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/WaveManagentController.java
index c56ed38..6d62137 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/WaveManagentController.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/WaveManagentController.java
@@ -114,6 +114,10 @@
if (Objects.isNull(reviewParam.getWaveSeedId())) {
return R.error("鎾鏄庣粏鏍囪瘑涓嶈兘涓虹┖锛侊紒");
}
+// if (Objects.isNull(reviewParam.getSiteNo())) {
+// return R.error("鎾绔欑偣涓嶈兘涓虹┖锛侊紒");
+// }
+
return waveManagentService.reviewSeeds(reviewParam);
}
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
index acc93e4..f33da51 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
@@ -33,6 +33,7 @@
import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;
+import java.util.stream.DoubleStream;
@Slf4j
@Service
@@ -79,20 +80,20 @@
*/
@Override
@Transactional(rollbackFor = Exception.class)
- public R containerArrivedNotify(ContainerArrivedParam arrivedParam, String taskType, Long hostId){
+ public R containerArrivedNotify(ContainerArrivedParam arrivedParam, String taskType, Long hostId) {
Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, arrivedParam.getContainerCode()));
if (task == null) {
return R.error("浠诲姟涓嶅瓨鍦紒锛�");
}
- log.info("瀹瑰櫒鍒拌揪鎺ユ敹锛屼换鍔″彿锛歿}锛屽綋鍓嶇姸鎬侊細{}锛屼笂鎶ョ姸鎬侊細{}, 鎺ユ敹鍙傛暟锛歿}",task.getTaskNo(),task.getTaskSts$(),TaskStsType.WCS_CONTAINER_RECEIVE.desc, JSONObject.toJSONString(arrivedParam));
+ log.info("瀹瑰櫒鍒拌揪鎺ユ敹锛屼换鍔″彿锛歿}锛屽綋鍓嶇姸鎬侊細{}锛屼笂鎶ョ姸鎬侊細{}, 鎺ユ敹鍙傛暟锛歿}", task.getTaskNo(), task.getTaskSts$(), TaskStsType.WCS_CONTAINER_RECEIVE.desc, JSONObject.toJSONString(arrivedParam));
- taskType = task.getTaskType() > 100 ? "outStock":"inStock";
+ taskType = task.getTaskType() > 100 ? "outStock" : "inStock";
if (taskType.equals("inStock")) {
if (task.getTaskSts() == 198) {
return R.error("鎾涓紒锛�");
}
- if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_IN.id ) {
+ if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_IN.id) {
//DONE 鏍规嵁ESS杩斿洖鐨勫鍣ㄧ紪鐮佷慨鏀逛换鍔℃。涓殑杈撻�佺嚎璧峰浣嶇疆鑺傜偣锛屽強浠诲姟妗ｅ鍣ㄥ埌杈剧姸鎬�
taskService.update(new LambdaUpdateWrapper<Task>()
.set(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)
@@ -100,26 +101,26 @@
.set(Task::getOriginSite, arrivedParam.getSlotCode())
.eq(Task::getBarcode, arrivedParam.getContainerCode()));
} else {
- log.warn("{}娌℃湁涓嬪彂浠诲姟",task.getTaskNo());
- R.error(task.getTaskNo()+"娌℃湁涓嬪彂浠诲姟");
+ log.warn("{}娌℃湁涓嬪彂浠诲姟", task.getTaskNo());
+ R.error(task.getTaskNo() + "娌℃湁涓嬪彂浠诲姟");
}
} else {
if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_ARRIVED.id
- || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id ) {
+ || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
// 鍒拌揪鎷ｉ�変綅锛屾帶鍒舵挱绉嶅浜伅
CacheSite cacheSite = cacheSiteService.getOne(new LambdaQueryWrapper<CacheSite>()
.eq(CacheSite::getChannel, task.getTargetSite())
- .isNull(CacheSite::getOrderId).orderByAsc(CacheSite::getId),false);
+ .isNull(CacheSite::getOrderId).orderByAsc(CacheSite::getId), false);
// List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
// .eq(CacheSite::getBarcode, task.getBarcode()));
- if(Objects.isNull(cacheSite)) {
- log.error("鏉＄爜锛歿}锛屾湭鎵惧埌鎾澧欎寒鐏�",task.getBarcode());
- throw new CoolException("鏈壘鍒版挱绉嶅");
- }
+ if (Objects.isNull(cacheSite)) {
+ log.error("鏉＄爜锛歿}锛屾湭鎵惧埌鎾澧欎寒鐏�", task.getBarcode());
+ throw new CoolException("鏈壘鍒版挱绉嶅");
+ }
// 鑾峰彇浠诲姟鏄庣粏鏁伴噺
List<TaskDetl> taskDetlByTaskId = taskDetlService.getTaskDetlByTaskId(task.getId());
- int sum = (int)taskDetlByTaskId.stream().mapToDouble(TaskDetl::getAnfme).sum();
+ int sum = (int) taskDetlByTaskId.stream().mapToDouble(TaskDetl::getAnfme).sum();
SlapLightControlParam slapLightControlParam = new SlapLightControlParam();
slapLightControlParam
.setControllerCode(cacheSite.getMemo())
@@ -129,12 +130,12 @@
.setMode("LIGHT")
.setDisplay(sum + "");
// 鍙戣捣浜伅璇锋眰
- log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅浜伅涓嬪彂",task.getTaskNo(), JSONObject.toJSONString(slapLightControlParam));
+ log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅浜伅涓嬪彂", task.getTaskNo(), JSONObject.toJSONString(slapLightControlParam));
CommonReponse response = HttpEssUtils.post("鍒拌揪鎷ｉ�変綅锛屾挱绉嶅浜伅", HttpEssUtils.PLT_SEND_COMMAND, slapLightControlParam);
if (response.getCode().equals(0)) {
- log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅{}浜伅鎴愬姛",task.getTaskNo(),cacheSite.getSiteNo());
+ log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅{}浜伅鎴愬姛", task.getTaskNo(), cacheSite.getSiteNo());
} else {
- log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅{}浜伅澶辫触",task.getTaskNo(),cacheSite.getSiteNo());
+ log.info("浠诲姟{}鍒拌揪鎷ｉ�変綅锛屾挱绉嶅{}浜伅澶辫触", task.getTaskNo(), cacheSite.getSiteNo());
}
boolean update = taskService.update(new LambdaUpdateWrapper<Task>()
@@ -144,16 +145,16 @@
if (!update) {
throw new CoolException("瀹瑰櫒鍒拌揪浠诲姟鏇存柊澶辫触锛侊紒");
}
- } else if(task.getTaskSts().equals(TaskStsType.UPDATED_OUT.id)) {
+ } else if (task.getTaskSts().equals(TaskStsType.UPDATED_OUT.id)) {
ConveyorStarParam conveyorStarParam = new ConveyorStarParam();
conveyorStarParam.setSlotCode(task.getOriginSite())
.setContainerCode(task.getBarcode())
.setDirection("200");
// 鍑哄簱瀹屾垚锛屾竻闄よ緭閫佺嚎鏉＄爜锛屽彇涓嬬瀛�
- CommonReponse response = HttpEssUtils.post("娓呴櫎杈撻�佺嚎鏉＄爜", HttpEssUtils.CONVEYOR_START, conveyorStarParam);
- if (response.getCode().equals(200)) {
- log.info("{}鍑哄簱瀹屾垚锛屾竻闄}杈撻�佺嚎鏉＄爜{}鎴愬姛",task.getTaskNo(),task.getOriginSite(),task.getBarcode());
- }
+ CommonReponse response = HttpEssUtils.post("娓呴櫎杈撻�佺嚎鏉＄爜", HttpEssUtils.CONVEYOR_START, conveyorStarParam);
+ if (response.getCode().equals(200)) {
+ log.info("{}鍑哄簱瀹屾垚锛屾竻闄}杈撻�佺嚎鏉＄爜{}鎴愬姛", task.getTaskNo(), task.getOriginSite(), task.getBarcode());
+ }
}
}
@@ -175,17 +176,17 @@
.eq(Task::getTaskNo, callbackParam.getTaskCode()));
if (!Collections.isEmpty(list)) {
list.forEach(task -> {
- log.info("瀹瑰櫒鎵ц鐘舵�佷笂鎶ワ紝浠诲姟鍙凤細{}锛屽綋鍓嶇姸鎬侊細{}锛屼笂鎶ョ姸鎬侊細{}",task.getTaskNo(),task.getTaskSts$(),callbackParam.getEventType());
+ log.info("瀹瑰櫒鎵ц鐘舵�佷笂鎶ワ紝浠诲姟鍙凤細{}锛屽綋鍓嶇姸鎬侊細{}锛屼笂鎶ョ姸鎬侊細{}", task.getTaskNo(), task.getTaskSts$(), callbackParam.getEventType());
if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_ALLOCATED.event)) {
return;
}
// ESS鍙兘閰嶇疆涓�涓姸鎬佷笂鎶ユ帴鍙ｏ紝鏍规嵁浠诲姟鍙峰垽鏂槸鍏ュ簱浠诲姟鎴栧嚭搴撲换鍔�
- String taskType = task.getTaskType() > 100 ? "outStock":"inStock";
+ String taskType = task.getTaskType() > 100 ? "outStock" : "inStock";
TaskStsType taskStsType = null;
if (taskType.equals("inStock")) { //鍏ュ簱浠诲姟
if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
// if (task.getTaskSts() == TaskStsType.WCS_CONVEYOR_START.id) {
- taskStsType = TaskStsType.WCS_TOTE_LOAD;
+ taskStsType = TaskStsType.WCS_TOTE_LOAD;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_LOAD.desc + "浠诲姟";
// log.error(errMsg);
@@ -193,7 +194,7 @@
// }
} else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
// if (task.getTaskSts() == TaskStsType.WCS_TOTE_LOAD.id) {
- taskStsType = TaskStsType.WCS_TOTE_UNLOAD;
+ taskStsType = TaskStsType.WCS_TOTE_UNLOAD;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_UNLOAD.desc + "浠诲姟";
// log.error(errMsg);
@@ -201,7 +202,7 @@
// }
} else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //TODO 闇�纭涓婃姤浠诲姟涓紝浠诲姟瀹屾垚鏄摢涓簨浠讹紝鐩墠鏆傚畾task浜嬩欢
// if (task.getTaskSts() == TaskStsType.WCS_TOTE_UNLOAD.id) {
- taskStsType = TaskStsType.WCS_PUTAWAY_SUCESS;
+ taskStsType = TaskStsType.WCS_PUTAWAY_SUCESS;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_PUTAWAY_SUCESS.desc + "浠诲姟";
// log.error(errMsg);
@@ -225,7 +226,7 @@
} else { //鍑哄簱浠诲姟
if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
// if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT.id ) {
- taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD;
+ taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.desc + "浠诲姟";
// log.error(errMsg);
@@ -233,7 +234,7 @@
// }
} else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
// if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.id) {
- taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD;
+ taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.desc + "浠诲姟";
// log.error(errMsg);
@@ -241,8 +242,8 @@
// }
} else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //涓婃姤瀹屾垚鐘舵��
// if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
- //鍑哄簱浠诲姟瀹屾垚锛屼慨鏀圭姸鎬佷负瀹瑰櫒鍒拌揪锛屽畾鏃朵换鍔＄敓鎴愭挱绉嶆尝娆�
- taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
+ //鍑哄簱浠诲姟瀹屾垚锛屼慨鏀圭姸鎬佷负瀹瑰櫒鍒拌揪锛屽畾鏃朵换鍔＄敓鎴愭挱绉嶆尝娆�
+ taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
// } else {
// String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.desc + "浠诲姟";
// log.error(errMsg);
@@ -279,11 +280,11 @@
*/
@Override
@Transactional(rollbackFor = Exception.class)
- public synchronized R containerConveryor(String code) throws Exception{
+ public synchronized R containerConveryor(String code) throws Exception {
Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, code));
if (Objects.isNull(task)) {
throw new CoolException("瀹瑰櫒鐮佷换鍔′笉瀛樺湪锛侊紒");
- }
+ }
try {
ConveyorStarParam conveyorStarParam = new ConveyorStarParam();
conveyorStarParam.setSlotCode(task.getOriginSite())
@@ -323,7 +324,7 @@
}
}
} catch (Exception ex) {
- log.error("UNK", ex);
+ log.error("UNK", ex);
}
return R.ok();
}
@@ -348,39 +349,46 @@
@Override
@Transactional(rollbackFor = Exception.class)
public R slapLightLogic(Map<String, Object> request) {
- List<String> taskNos = (List<String>)request.get("taskNo");
+ String taskNo = request.get("taskNo").toString();
String orderNo = request.get("orderNo").toString();
String siteNo = Objects.isNull(request.get("siteNo")) ? null : request.get("siteNo").toString();
List<CacheSite> performs = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
if (Objects.isNull(performs.stream().findFirst().get().getPlatformId())) {
throw new CoolException("璇锋墦鍗版槑缁嗭紝骞剁粦瀹氱洰鏍囬泦璐у尯");
}
-
//* 1. 鍒ゆ柇褰撳墠瀹瑰櫒鏄惁杩樻湁鐗╂枡鏈嫞锛屾湭鎷ｅ畬闂伅锛屾嫞瀹岄�氱煡瀹瑰櫒娴佸姩锛屽苟鐏伅
SlapLightControlParam slapParam = new SlapLightControlParam();
MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
- taskNos.forEach(taskNo -> {
- //鍒ゆ柇褰撳墠浠诲姟鏄惁杩樻湁鐗╂枡鏈嫞
- if (!checked(orderNo, taskNo)) {
- log.info("鏈畬鎴愰棯鐏姹傚湴鍧�锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
- //璋冪敤涓夋柟鎺ュ彛,闂伅涓嶅仛鎿嶄綔
- // 璁剧疆璇锋眰鍙傛暟
- throw new CoolException("褰撳墠浠诲姟鏈畬鎴愶紝涓嶈兘鎵ц姝ゆ搷浣滐紒锛�");
+ //鍒ゆ柇褰撳墠浠诲姟鏄惁杩樻湁鐗╂枡鏈嫞
+ if (!checked(orderNo, taskNo)) {
+ log.info("鏈畬鎴愰棯鐏姹傚湴鍧�锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
+ //璋冪敤涓夋柟鎺ュ彛,闂伅涓嶅仛鎿嶄綔
+ // 璁剧疆璇锋眰鍙傛暟
+// throw new CoolException("褰撳墠浠诲姟鏈畬鎴愶紝涓嶈兘鎵ц姝ゆ搷浣滐紒锛�");
// params.add("params", JSONObject.toJSONString(slapParam));
- } else {
- //璋冪敤涓夋柟鎺ュ彛,鐏伅閫氱煡瀹瑰櫒娴佸姩锛� 浼犵伃鐏弬鏁�
- //todo 鍒ゆ柇褰撳墠璁㈠崟鏄惁瀹屾垚锛屽畬鎴愮伃鐏紝鏈畬鎴愪繚鎸佹嫞璐х姸鎬佷寒鐏�
- Order one = orderService.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNo, orderNo));
- if (Objects.isNull(one)) {
- throw new CoolException("褰撳墠璁㈠崟鏄庣粏涓嶅瓨鍦紒锛�");
- }
+ } else {
+ //璋冪敤涓夋柟鎺ュ彛,鐏伅閫氱煡瀹瑰櫒娴佸姩锛� 浼犵伃鐏弬鏁�
+ //todo 鍒ゆ柇褰撳墠璁㈠崟鏄惁瀹屾垚锛屽畬鎴愮伃鐏紝鏈畬鎴愪繚鎸佹嫞璐х姸鎬佷寒鐏�
+ Order one = orderService.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNo, orderNo));
+ if (Objects.isNull(one)) {
+ throw new CoolException("褰撳墠璁㈠崟鏄庣粏涓嶅瓨鍦紒锛�");
+ }
// //鑾峰彇鎾宸插畬鎴愮殑璁㈠崟鏄庣粏
// List<OrderDetl> detlList = orderDetls.stream().filter(detl -> {
// return detl.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val;
// }).collect(Collectors.toList());
- //鍒ゆ柇鏁伴噺鏄惁涓庤鍗曟槑缁嗙殑闇�姹傞噺鐩稿悓锛岀浉鍚屽垯璁㈠崟瀹屾垚
+ //鍒ゆ柇鏁伴噺鏄惁涓庤鍗曟槑缁嗙殑闇�姹傞噺鐩稿悓锛岀浉鍚屽垯璁㈠崟瀹屾垚
+
+ List<WaveSeed> seeds = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderNo, orderNo));
+ if (Objects.isNull(seeds)) {
+ throw new CoolException("鏁版嵁閿欒锛氭挱绉嶆暟鎹笉瀛樺湪锛侊紒");
+ }
+
+ Double tolAnfme = seeds.stream().mapToDouble(WaveSeed::getAnfme).sum();
+ Double toDouble = seeds.stream().mapToDouble(WaveSeed::getWorkQty).sum();
+ if (toDouble.compareTo(tolAnfme) >= 0) {
//鎾瀹屾垚锛岄噴鏀剧粦瀹氱珯鐐�
List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
.eq(!Objects.isNull(siteNo), CacheSite::getSiteNo, siteNo)
@@ -399,21 +407,21 @@
}
}
}
- params.add("params", JSONObject.toJSONString(slapParam));
- log.info("瀹屾垚鐏伅璇锋眰鍦板潃锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
}
+ params.add("params", JSONObject.toJSONString(slapParam));
+ log.info("瀹屾垚鐏伅璇锋眰鍦板潃锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
+ }
- Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getTaskNo, request.get("taskNo")));
- if (Objects.isNull(task)) {
- throw new CoolException("浠诲姟涓嶅瓨鍦紒锛�");
- }
- try {
- containerConveryor(task.getBarcode());
- } catch (Exception e) {
- log.error("鎵ц寮傚父:UNK", e);
- throw new CoolException(e.getMessage());
- }
- });
+ Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getTaskNo, request.get("taskNo")));
+ if (Objects.isNull(task)) {
+ throw new CoolException("浠诲姟涓嶅瓨鍦紒锛�");
+ }
+ try {
+ containerConveryor(task.getBarcode());
+ } catch (Exception e) {
+ log.error("鎵ц寮傚父:UNK", e);
+ throw new CoolException(e.getMessage());
+ }
return R.ok();
}
@@ -449,7 +457,7 @@
//鍒ゆ柇浠诲姟闇�姹傛�婚噺鏄惁绛夋挱绉嶆�绘暟閲�
if (taskNum == seedNum) {
return true;
- } else {
+ } else {
return false;
}
}
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/WaveSeed.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/WaveSeed.java
index 0b8b916..585cb6a 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/WaveSeed.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/WaveSeed.java
@@ -110,6 +110,9 @@
@ApiModelProperty(value= "宸ヤ綔鏁伴噺")
private Double workQty;
+ @ApiModelProperty("鎵ц鐘舵��")
+ private Integer exceStatus;
+
/**
* 鍟嗗搧缂栧彿
*/
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/param/WaveSeedReviewParam.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/param/WaveSeedReviewParam.java
index 76beb68..1828eb5 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/param/WaveSeedReviewParam.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/param/WaveSeedReviewParam.java
@@ -9,4 +9,6 @@
private Double reviewNum;
+ private String siteNo;
+
}
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaveSeedServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaveSeedServiceImpl.java
index c8e9190..24de776 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaveSeedServiceImpl.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaveSeedServiceImpl.java
@@ -60,7 +60,8 @@
throw new CoolException("鎾鏁版嵁涓嶅瓨鍦�");
}
- List<CacheSite> sites = cacheSiteMapper.selectList(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, waveSeed.getOrderNo()));
+ List<CacheSite> sites = cacheSiteMapper.selectList(new LambdaQueryWrapper<CacheSite>()
+ .eq(CacheSite::getOrderNo, waveSeed.getOrderNo()));
if (sites.isEmpty()) {
throw new CoolException("褰撳墠璁㈠崟鏈粦瀹氭挱绉嶅簱浣嶏紝璇蜂娇鐢≒DA->鍦版爣缁戝畾,鍔熻兘缁戝畾鍚庡啀鎿嶄綔锛侊紒");
}
@@ -69,7 +70,9 @@
if (stock - param.getReviewNum() < 0) {
throw new CoolException("鎾鏁伴噺宸叉弧");
}
- waveSeed.setWorkQty(waveSeed.getWorkQty() + param.getReviewNum());
+ //璁剧疆鐘舵�佷负鎵ц涓�
+ waveSeed.setWorkQty(waveSeed.getWorkQty() + param.getReviewNum())
+ .setExceStatus(1);
TaskDetl taskDetl = taskDetlMapper.getOne(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getId, waveSeed.getTaskDetlId()));
if (Objects.isNull(taskDetl)) {
@@ -110,17 +113,6 @@
.set(Order::getPickStatus, OrderPickStatus.ORDER_PICK_STATUS_DONE.val))) {
throw new CoolException("鍘熷璁㈠崟涓诲崟鎷ｈ揣鐘舵�佹洿鏂板け璐ワ紒锛�");
}
- try {
- Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getId, waveSeed.getTaskId()));
- if (Objects.isNull(task)) {
- throw new CoolException("鏁版嵁閿欒锛� 浠诲姟鍗曟嵁涓嶅瓨鍦紒锛�");
- }
- wcsApiService.containerConveryor(task.getBarcode());
- } catch (Exception e) {
- log.error("鎵ц寮傚父:UNK", e);
- throw new CoolException(e.getMessage());
- }
-
} else {
if (!orderMapper.update(new LambdaUpdateWrapper<Order>()
.eq(Order::getOrderNo, orderDetl.getOrderNo())
--
Gitblit v1.9.1