From 7125d7c2be53db25b8a11d42abc8730b36ef61bc Mon Sep 17 00:00:00 2001
From: yangyang
Date: 星期二, 15 七月 2025 13:23:30 +0800
Subject: [PATCH] 任务工作档生成播种明细

---
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java |   70 +++++++++++++++++++----------------
 1 files changed, 38 insertions(+), 32 deletions(-)

diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java
index 71af48e..8c4ccf6 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java
@@ -1021,9 +1021,10 @@
      * 鏍规嵁涓嶅悓搴撲綅绫诲瀷鐢熸垚鍑哄簱鎷h揣鍗曟垨CTU浠诲姟妗�
      *
      * @param dto
-     * @param wave
+     * @param
      */
-    private void outStockByArea(OrderOutMergeParamDto dto, Wave wave) {
+    @Transactional(rollbackFor = Exception.class)
+    public void outStockByArea(OrderOutMergeParamDto dto, Wave wave) {
         List<OrderOutMergeParam> params = dto.getList();
         if (params.isEmpty()) {
             throw new CoolException("鍙傛暟涓嶈兘涓虹┖");
@@ -1137,9 +1138,12 @@
                 }
 
                 String matUniqueKey = Utils.getMatUniqueKey(taskDetl.getMatnr(), taskDetl.getBatch(), taskDetl.getUniqueField());
-                WaveDetl waveDetl = waveDetlService.getOne(new LambdaQueryWrapper<WaveDetl>().eq(WaveDetl::getStockIndex, matUniqueKey).eq(WaveDetl::getWaveId, wave.getId()));
+                logger.error("Matnr------>{}", taskDetl.getMatnr());
+                WaveDetl waveDetl = waveDetlService.getOne(new LambdaQueryWrapper<WaveDetl>()
+                        .eq(WaveDetl::getStockIndex, matUniqueKey)
+                        .eq(WaveDetl::getWaveId, wave.getId()));
                 if (waveDetl == null) {
-                    throw new CoolException("娉㈡鏁版嵁涓嶅瓨鍦�");
+                    throw new CoolException("waveId:" + wave.getId()  + "鐗╂枡锛�" + taskDetl.getMatnr() + "娉㈡鏁版嵁涓嶅瓨鍦�");
                 }
                 waveDetl.setWorkQty(waveDetl.getWorkQty() + taskDetl.getAnfme());
                 waveDetl.setUpdateTime(new Date());
@@ -1153,28 +1157,30 @@
                 throw new CoolException("褰撳墠娉㈡璁㈠崟涓嶅瓨鍦紒锛�");
             }
 
-            List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
-                    .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel, task.getTargetSite()));
+//            List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
+//                    .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel, task.getTargetSite()));
+//
+//            if (cacheSites.isEmpty()) {
+//                throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�");
+//            }
+//
+//            if (cacheSites.size() < orders.size()) {
+//                throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�");
+//            }
 
-            if (cacheSites.isEmpty()) {
-                throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�");
-            }
-
-            if (cacheSites.size() < orders.size()) {
-                throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�");
-            }
-
-            for (int i = 0; i < orders.size(); i++) {
-                CacheSite cacheSite = cacheSites.get(i);
-                cacheSite.setOrderId(orders.get(i).getId());
-                cacheSite.setOrderNo(orders.get(i).getOrderNo());
-                cacheSite.setSiteStatus(CacheSiteStatusType.R.id);
-                cacheSite.setBarcode(loc.getBarcode());
-                cacheSite.setUpdateTime(new Date());
-                if (!cacheSiteService.updateById(cacheSite)) {
-                    throw new CoolException("缂撳瓨绔欐洿鏂板け璐�");
-                }
-            }
+//            for (int i = 0; i < orders.size(); i++) {
+//                CacheSite cacheSite = cacheSiteService.getOne(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderId, orders.get(i).getId()));
+//                if (Objects.isNull(cacheSite)) {
+//                    cacheSite.setOrderId(orders.get(i).getId());
+//                    cacheSite.setOrderNo(orders.get(i).getOrderNo());
+//                    cacheSite.setSiteStatus(CacheSiteStatusType.R.id);
+//                    cacheSite.setBarcode(loc.getBarcode());
+//                    cacheSite.setUpdateTime(new Date());
+//                    if (!cacheSiteService.updateById(cacheSite)) {
+//                        throw new CoolException("缂撳瓨绔欐洿鏂板け璐�");
+//                    }
+//                }
+//            }
 
             //搴撲綅F => R
             loc.setLocStsId(LocStsType.R.val());
@@ -1226,7 +1232,7 @@
     /**
      * @author Ryan
      * @date 2025/7/4
-     * @description: 鐢熼潰鎷h揣鏄庣粏
+     * @description: 鐢熸垚鎷h揣鏄庣粏
      * @version 1.0
      */
     @Transactional(rollbackFor = Exception.class)
@@ -1496,12 +1502,12 @@
                 continue;
             }
             OrderOutMergeDto outMergeParam = new OrderOutMergeDto();
-            outMergeParam.setAnfme(outLocDetl.getAnfme())
-                    .setLocNo(outLocDetl.getLocNo())
-                    .setLocDetlId(detl.getId())
-                    .setLocId(detl.getLocId())
-                    .setMatnr(outLocDetl.getMatnr())
-                    .setBatch(detl.getBatch());
+            outMergeParam.setAnfme(outLocDetl.getAnfme());
+            outMergeParam.setLocNo(outLocDetl.getLocNo());
+            outMergeParam.setLocDetlId(detl.getId());
+            outMergeParam.setLocId(detl.getLocId());
+            outMergeParam.setMatnr(outLocDetl.getMatnr());
+            outMergeParam.setBatch(detl.getBatch());
             orders.add(outMergeParam);
 
             //鏍规嵁搴撲綅ID鍒嗙粍

--
Gitblit v1.9.1