From c9d011ae46f73cc87c4d6addd7d9d24d6c53bec0 Mon Sep 17 00:00:00 2001
From: zyh <zyh@123>
Date: 星期一, 30 三月 2026 09:55:38 +0800
Subject: [PATCH] 修复入库任务还未生成时下发出库任务会同步进行的问题

---
 src/main/java/com/zy/asrs/controller/MobileController.java |   39 ++++++++++++++++++++++++++-------------
 1 files changed, 26 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java
index 06df109..7085b61 100644
--- a/src/main/java/com/zy/asrs/controller/MobileController.java
+++ b/src/main/java/com/zy/asrs/controller/MobileController.java
@@ -12,6 +12,7 @@
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.*;
 import com.zy.asrs.entity.result.MobileAdjustResult;
+import com.zy.asrs.mapper.CanFinMapper;
 import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.service.impl.OrderDetlPakinServiceImpl;
@@ -65,6 +66,8 @@
     private ManLocDetlMapper manLocDetlMapper;
     @Autowired
     private WrkDetlLogService wrkDetlLogService;
+    @Autowired
+    private CanFinMapper canFinMapper;
 
     @Resource
     private StaDescService staDescService;
@@ -277,7 +280,13 @@
     @RequestMapping("/comb/auth")
     @ManagerAuth(memo = "缁勬墭")
     public R comb(@RequestBody CombParam combParam){
-        mobileService.comb(combParam, getUserId());
+
+        if (combParam.getUserId() != null && !combParam.getUserId().equals(null)){
+            mobileService.comb(combParam, combParam.getUserId());
+        }else {
+            mobileService.comb(combParam, getUserId());
+        }
+
         return R.ok("缁勬墭鎴愬姛");
     }
 
@@ -557,9 +566,11 @@
      */
     // pda鍛煎彨绌烘枡妗嗗嚭搴�
     @PostMapping("/callEmptyBinOutBound")
-    @ManagerAuth(memo = "pda鍛煎彨绌烘枡妗嗗嚭搴�")
+    // @ManagerAuth(memo = "pda鍛煎彨绌烘枡妗嗗嚭搴�")
     public synchronized R callEmptyBinOutBound(@RequestParam(required = false) String locNo
-            , @RequestParam(required = false) String size) {
+            , @RequestParam(required = false) String size
+            , @RequestParam(required = false) String palletFormat
+            , @RequestParam(required = false) String agvTaskNo) {
         if (Cools.isEmpty(locNo) || Cools.isEmpty(size)) {
             return R.error("绔欑偣鎴栬�呭ぇ灏忎笉鑳戒负绌�");
         }
@@ -567,7 +578,7 @@
         if (wrkMast != null) {
             return R.error("璇ョ珯鐐�="+locNo+"宸茬粡鏈夌┖鏉垮嚭搴撲换鍔★紝涓轰簡涓嶅牭濉炲爢鍨涙満鎺ラ┏绔欑偣锛岀姝笅鍙戝涓┖鏉垮嚭搴撲换鍔�");
         }
-        return mobileService.callEmptyBinOutBound(locNo,size,getUserId());
+        return mobileService.callEmptyBinOutBound(locNo, size, palletFormat, agvTaskNo, 9995L);
     }
 
     /**
@@ -623,11 +634,17 @@
                 .setAppeTime(date)
                 .setModiUser(9945L)
                 .setModiTime(date);
-        if (!taskService.insert(task)) {
+        if (taskService.insert(task)) {
+            Date now = new Date();
+            CanFin canFin = new CanFin();
+            canFin.setAgvType("agv-in");
+            canFin.setInNo(TaskNo);
+            canFin.setApplyTime(now);
+            canFinMapper.insert(canFin);
+        }else{
             throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
         }
-
-        return r;
+        return R.error("涓嬪彂澶辫触");
     }
 
     @RequestMapping("/orderIn")
@@ -644,9 +661,7 @@
                         break;
                     }
                 }
-                if (boo) {
-                    settle.remove(orderPakin);
-                }else {
+                if (!boo) {
                     list.add(orderPakin.getOrderNo());
                 }
             }else {
@@ -670,9 +685,7 @@
                         break;
                     }
                 }
-                if (boo) {
-                    settle.remove(orderPakout);
-                }else {
+                if (!boo) {
                     list.add(orderPakout.getOrderNo());
                 }
             }else {

--
Gitblit v1.9.1