From cc6dae7468506691bfb23ca81be5e14045771bce Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期三, 15 一月 2025 20:43:59 +0800
Subject: [PATCH] #  拍灯容器流动流程修改  发货确认功能开发 部分功能优化

---
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java |   30 ++++++------------------------
 1 files changed, 6 insertions(+), 24 deletions(-)

diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java
index 0d6e371..ab01799 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java
@@ -155,19 +155,6 @@
                 task.setTaskSts(TaskStsType.UPDATED_OUT.id);//200.搴撳瓨鏇存柊瀹屾垚
                 if (!taskService.updateById(task)) {
                     throw new CoolException("搴撳瓨鏇存柊澶辫触");
-                } else {
-                    //CacheSite 閲婃斁宸茶鍗犵敤鐨勯�氶亾 //fixme 鎾鍔熻兘瀹屾垚鍚庯紝闇�瑕佸皢杩欓噷娉ㄩ噴鎺�
-//                    List<TaskDetl> detls = taskDetlService.list(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getTaskId, task.getId()));
-//                    if (!Collections.isEmpty(detls)) {
-//                        List<Long> waveIds = detls.stream().map(TaskDetl::getWaveId).collect(Collectors.toList());
-//                        List<Order> orders = orderService.list(new LambdaQueryWrapper<Order>().in(Order::getWaveId, waveIds));
-//                        List<Long> orderIds = orders.stream().map(Order::getId).collect(Collectors.toList());
-//                        cacheSiteService.update(new LambdaUpdateWrapper<CacheSite>()
-//                                .in(CacheSite::getOrderId, orderIds)
-//                                .set(CacheSite::getSiteStatus, 0)
-//                                .set(CacheSite::getOrderId, null)
-//                                .set(CacheSite::getOrderNo, null));
-//                    }
                 }
             }
         } catch (Exception e) {
@@ -216,10 +203,9 @@
             if (!locDetlService.save(locDetl)) {
                 throw new CoolException("鎻掑叆搴撳瓨鏄庣粏澶辫触");
             }
-            //fixme 鏆傛椂鍏抽棴HOSTID,鍚庣画鎵撳紑鏈烘瀯ID
+
             //娣诲姞搴撳瓨鏄庣粏鎵╁睍瀛楁
-//            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()).eq(TaskDetlField::getHostId, hostId));
-            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()));
+            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()).eq(TaskDetlField::getHostId, hostId));
             for (TaskDetlField detlField : detlFields) {
                 LocDetlField locDetlField = new LocDetlField();
                 locDetlField.setDetlId(locDetl.getId());
@@ -232,10 +218,8 @@
                 }
             }
         }
-        //fixme 鏆傛椂鍏抽棴HOSTID,鍚庣画鎵撳紑鏈烘瀯ID
         //缁勬墭閫氱煡妗h浆鍘嗗彶妗�
-//        List<WaitPakin> waitPakins = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, task.getBarcode()).eq(WaitPakin::getHostId, hostId));
-        List<WaitPakin> waitPakins = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, task.getBarcode()));
+        List<WaitPakin> waitPakins = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, task.getBarcode()).eq(WaitPakin::getHostId, hostId));
         if (waitPakins.isEmpty()) {
             throw new CoolException("缁勬墭閫氱煡妗d笉瀛樺湪");
         }
@@ -342,8 +326,7 @@
     private void executeTask53(Task task) {
         Long hostId = task.getHostId();
         //fixme 灏嗕换鍔″綋鍓�
-//        Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()).eq(Loc::getHostId, hostId));
-        Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()));
+        Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()).eq(Loc::getHostId, hostId));
         if (loc == null) {
             throw new CoolException("搴撲綅涓嶅瓨鍦�");
         }
@@ -355,6 +338,7 @@
         loc.setLocStsId(LocStsType.F.val());
         loc.setUpdateTime(new Date());
         loc.setBarcode(task.getBarcode());
+
         if (!locService.updateById(loc)) {
             throw new CoolException("搴撲綅鐘舵�佹洿鏂板け璐�");
         }
@@ -385,9 +369,7 @@
             }
 
             //娣诲姞搴撳瓨鏄庣粏鎵╁睍瀛楁
-            //fixme 娉ㄩ噴
-//            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()).eq(TaskDetlField::getHostId, hostId));
-            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()));
+            List<TaskDetlField> detlFields = taskDetlFieldService.list(new LambdaQueryWrapper<TaskDetlField>().eq(TaskDetlField::getDetlId, taskDetl.getId()).eq(TaskDetlField::getHostId, hostId));
             for (TaskDetlField detlField : detlFields) {
                 LocDetlField locDetlField = new LocDetlField();
                 locDetlField.setDetlId(locDetl.getId());

--
Gitblit v1.9.1