From 2561f81f2c28480502f51775e618bceeb053644c Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期四, 06 十一月 2025 09:29:07 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jshdasrs' into jshdasrs

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  105 +++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 82 insertions(+), 23 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 77c261b..d51ef62 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -58,6 +58,10 @@
     private BasArmMastService basArmMastService;
     @Autowired
     private BasArmMastSignService basArmMastSignService;
+    @Autowired
+    private BasAgvMastService basAgvMastService;
+    @Autowired
+    private LocOwnerService locOwnerService;
 
     @Override
     @Transactional
@@ -68,6 +72,12 @@
         }
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE);
         Date now = new Date();
+        LocOwner locOwner = null;
+        if (!Cools.isEmpty(param.getOwnerId())) {
+            locOwner = locOwnerService.selectById(param.getOwnerId());
+        } else {
+            locOwner = locOwnerService.selectById(1);
+        }
         // 鍗曟嵁涓绘。
         order = new Order(
                 String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
@@ -75,12 +85,12 @@
                 DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
                 docType.getDocId(),    // 鍗曟嵁绫诲瀷
                 null,    // 椤圭洰缂栧彿
-                null,    //
+                param.getStandby1(),    //椤圭洰鍚嶇О 瀹㈡埛PO鍙�
                 null,    // 璋冩嫧椤圭洰缂栧彿
                 null,    // 鍒濆绁ㄦ嵁鍙�
                 null,    // 绁ㄦ嵁鍙�
-                null,    // 瀹㈡埛缂栧彿
-                null,    // 瀹㈡埛
+                locOwner.getOwnerUuid(),    // 瀹㈡埛缂栧彿
+                locOwner.getOwner(),    // 瀹㈡埛
                 null,    // 鑱旂郴鏂瑰紡
                 null,    // 鎿嶄綔浜哄憳
                 null,    // 鍚堣閲戦
@@ -136,6 +146,9 @@
             orderDetl.setStandby1(detlDto.getStandby1());
             orderDetl.setStandby2(detlDto.getStandby2());
             orderDetl.setStandby3(detlDto.getStandby3());
+            orderDetl.setBoxType1(detlDto.getBoxType1());
+            orderDetl.setBoxType2(detlDto.getBoxType2());
+            orderDetl.setBoxType3(detlDto.getBoxType3());
             orderDetl.setOrderId(order.getId());
             orderDetl.setOrderNo(order.getOrderNo());
             orderDetl.setCreateBy(9527L);
@@ -228,6 +241,12 @@
         }
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE);
         Date now = new Date();
+        LocOwner locOwner = null;
+        if (!Cools.isEmpty(param.getOwnerId())) {
+            locOwner = locOwnerService.selectById(param.getOwnerId());
+        } else {
+            locOwner = locOwnerService.selectById(1);
+        }
         // 鍗曟嵁涓绘。
         order = new Order(
                 String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
@@ -235,12 +254,12 @@
                 DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
                 docType.getDocId(),    // 鍗曟嵁绫诲瀷
                 null,    // 椤圭洰缂栧彿
-                null,    //
+                param.getStandby1(),    //椤圭洰鍚嶇О 瀹㈡埛PO鍙�
                 null,    // 璋冩嫧椤圭洰缂栧彿
                 null,    // 鍒濆绁ㄦ嵁鍙�
                 null,    // 绁ㄦ嵁鍙�
-                null,    // 瀹㈡埛缂栧彿
-                null,    // 瀹㈡埛
+                locOwner.getOwnerUuid(),    // 瀹㈡埛缂栧彿
+                locOwner.getOwner(),    // 瀹㈡埛
                 null,    // 鑱旂郴鏂瑰紡
                 null,    // 鎿嶄綔浜哄憳
                 null,    // 鍚堣閲戦
@@ -298,6 +317,9 @@
             orderDetl.setStandby1(detlDto.getStandby1());
             orderDetl.setStandby2(detlDto.getStandby2());
             orderDetl.setStandby3(detlDto.getStandby3());
+            orderDetl.setBoxType1(detlDto.getBoxType1());
+            orderDetl.setBoxType2(detlDto.getBoxType2());
+            orderDetl.setBoxType3(detlDto.getBoxType3());
             orderDetl.setOrderId(order.getId());
             orderDetl.setOrderNo(order.getOrderNo());
             orderDetl.setCreateBy(9527L);
@@ -620,7 +642,7 @@
         if (Cools.isEmpty(basArmMastOld)){
             basArmMastService.insert(basArmMast);
         } else {
-            throw new CoolException("鏈煡璇㈠埌鐩稿叧鏈烘鑷傛媶鐮佸灈浠诲姟锛侊紒锛�"+ JSON.toJSONString(param));
+            throw new CoolException("绛夊緟鍓嶈竟璐х墿鎶撳彇锛侊紒锛�"+ JSON.toJSONString(param));
         }
     }
 
@@ -629,12 +651,42 @@
     public void taskArmCycleResult(TaskArmCycleResultParam param) {
         BasArm basArm = basArmService.selectOne(new EntityWrapper<BasArm>()
                 .eq("arm_no", param.getArm_no())
-                .eq("sta_no", Integer.parseInt(param.getStaNo()))
+                .eq("sorting_line", Integer.parseInt(param.getStaNo()))
                 .eq("status", 1)
         );
         if (Cools.isEmpty(basArm)){
             throw new CoolException("鏈烘鑷傞厤缃紓甯革紝鏌ヨ涓嶅埌鏈烘鑷傛暟鎹紒锛侊紒"+ JSON.toJSONString(param));
         }
+
+        try{
+            BasArmMastSign basArmMastSign = basArmMastSignService.selectOne(
+                    new EntityWrapper<BasArmMastSign>()
+                            .eq("matnr", param.getSku())
+                            .eq("order_no", param.getOrderNo())
+                            .eq("create_time", param.getBindingTags())
+            );
+            if (!Cools.isEmpty(basArmMastSign)){
+                basArmMastSign.setStatus(1);
+                basArmMastSignService.updateById(basArmMastSign);
+            }
+        } catch (Exception e){
+        }
+
+        BasArmMast basArmMastListError = basArmMastService.selectOne(
+                new EntityWrapper<BasArmMast>()
+                        .eq("sorting_line", basArm.getSortingLineSou())
+                        .eq("arm_no", param.getArm_no())
+                        .eq("status", 9)
+        );
+        if (!Cools.isEmpty(basArmMastListError)){
+            if (Integer.parseInt(param.getPick_num()) ==1){
+                basArmMastListError.setStatus(2);
+                basArmMastService.updateById(basArmMastListError);
+            }
+            return;
+        }
+
+
         BasArmMast basArmMast = basArmMastService.selectOne(
                 new EntityWrapper<BasArmMast>()
                         .eq("sorting_line", basArm.getSortingLineSou())
@@ -644,9 +696,13 @@
         if (Cools.isEmpty(basArmMast)){
             throw new CoolException("鏈煡璇㈠埌鐩稿叧鏈烘鑷傛媶鐮佸灈浠诲姟锛侊紒锛�"+ JSON.toJSONString(param));
         }
-
-        basArmMast.setStatus(2);
-        basArmMastService.updateById(basArmMast);
+        if (Integer.parseInt(param.getPick_num()) !=1){
+            basArmMast.setStatus(9);
+            basArmMastService.updateById(basArmMast);
+        } else {
+            basArmMast.setStatus(2);
+            basArmMastService.updateById(basArmMast);
+        }
     }
 
     @Override
@@ -677,7 +733,7 @@
     public void taskArmWorkOrderStatus(OrderArmEndParam param) {
         BasArm basArm = basArmService.selectOne(new EntityWrapper<BasArm>()
                 .eq("arm_no", param.getArm_no())
-                .eq("sta_no", Integer.parseInt(param.getStaNo()))
+                .eq("sorting_line", Integer.parseInt(param.getStaNo()))
                 .eq("status", 1)
         );
         if (Cools.isEmpty(basArm)){
@@ -697,20 +753,10 @@
     @Override
     @Transactional
     public boolean TaskArmWorkOrderSign(OrderArmEndParam param) {
-        BasArmMastSign basArmMastSign = basArmMastSignService.selectOne(
-                new EntityWrapper<BasArmMastSign>()
-                        .eq("matnr", param.getSku())
-                        .eq("order_no", param.getOrderNo())
-        );
-        if (Cools.isEmpty(basArmMastSign)){
-//            throw new CoolException("鏈煡璇㈠埌鐩稿叧鏈烘鑷傛媶鐮佸灈浠诲姟锛侊紒锛�"+ JSON.toJSONString(param));
-            return false;
-        }
         BasArmMastSign basArmMastSignNew = basArmMastSignService.selectOne(
                 new EntityWrapper<BasArmMastSign>()
-                        .eq("matnr", param.getSku())
                         .eq("order_no", param.getOrderNo())
-                        .eq("create_time", basArmMastSign.getCreateTime())
+                        .eq("create_time", param.getBindingTags())
                         .eq("status", 0)
         );
         if (Cools.isEmpty(basArmMastSignNew)){
@@ -719,4 +765,17 @@
         return true;
     }
 
+    @Override
+    @Transactional
+    public boolean TaskAgvReport(TaskAgvReportParam param) {
+        BasAgvMast basAgvMast = basAgvMastService.selectOne(new EntityWrapper<BasAgvMast>().eq("task_no", param.getTaskNo()));
+        if (Cools.isEmpty(basAgvMast)){
+            return false;
+        }
+        basAgvMast.setStatus(2);
+        basAgvMastService.updateById(basAgvMast);
+        return true;
+    }
+
+
 }

--
Gitblit v1.9.1