From 2025bc1fe84535219fd4bec24ad0985c5b482b78 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期三, 18 九月 2024 09:50:35 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java    |   12 +++++++-----
 src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java |   11 ++++++-----
 src/main/java/com/zy/asrs/controller/OrderDetlController.java    |    7 ++++++-
 3 files changed, 19 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OrderDetlController.java b/src/main/java/com/zy/asrs/controller/OrderDetlController.java
index 0e9b7ef..349450e 100644
--- a/src/main/java/com/zy/asrs/controller/OrderDetlController.java
+++ b/src/main/java/com/zy/asrs/controller/OrderDetlController.java
@@ -151,12 +151,15 @@
     }
 
     @RequestMapping(value = "/orderDetl/pakout/list/authV3")
+    @Synchronized
     @ManagerAuth
     public R pakoutList3(@RequestParam(defaultValue = "1")Integer curr,
                          @RequestParam(defaultValue = "10")Integer limit,
                          @RequestParam(required = false)String orderByField,
                          @RequestParam(required = false)String orderByType,
                          @RequestParam Map<String, Object> param){
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start();
         EntityWrapper<OrderDetl> wrapper = new EntityWrapper<>();
         excludeTrash(param);
         convertLike(param, wrapper);
@@ -170,12 +173,14 @@
                 docIds.add(pakin.getDocId());
             }
         }
-        wrapper.in("source",docIds);
+        wrapper.ne("source",19);
         Page<OrderDetl> page = orderDetlService.selectPage(new Page<>(curr, limit), wrapper);
         for (OrderDetl record : page.getRecords()) {
             Double sumAnfme = agvLocDetlService.getSumAnfme(record.getMatnr(), record.getThreeCode());
             record.setStock(sumAnfme == null ? 0 : sumAnfme);
         }
+        stopWatch.stop();
+        System.out.println(stopWatch.getTotalTimeSeconds());
         return R.ok(page);
     }
 
diff --git a/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java
index 1a97b91..7ac7ed3 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java
@@ -517,7 +517,10 @@
         if (ioType == 12 && locMast.getFloor() == 1 && floor != 4 && agvLocMast.getFloor() != 1) {
             List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
             for (AgvLocDetl agvLocDetl : agvLocDetls) {
-                OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("three_code", agvLocDetl.getThreeCode()).eq("matnr", agvLocDetl.getMatnr()).eq("order_no", "DB" + agvLocDetl.getOrderNo()));
+                OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("three_code", agvLocDetl.getThreeCode()).eq("matnr", agvLocDetl.getMatnr()).eq("source", 33));
+                if (Cools.isEmpty(orderDetl)) {
+                    throw new CoolException("褰撳墠鐗╂枡鐨勮皟鎷ㄥ崟涓嶅瓨鍦紒");
+                }
                 orderDetl.setQty(orderDetl.getQty() - agvLocDetl.getAnfme());
                 if (!orderDetlService.updateById(orderDetl)) {
                     throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
@@ -571,8 +574,6 @@
                 //鏇存柊鐩爣搴撲綅鏄庣粏 101.鍑哄簱 鍒犻櫎婧愬簱浣嶅簱瀛樻槑缁�
                 agvLocDetlService.delete(new EntityWrapper<AgvLocDetl>().eq("loc_no",agvWrkMast.getSourceLocNo()));
             }
-
-            agvWrkMast.setSourceLocNo("");
         }
 
         //鐢熸垚AGV宸ヤ綔鍘嗗彶妗� + 鐢熸垚AGV宸ヤ綔鏄庣粏鍘嗗彶妗�
@@ -595,9 +596,9 @@
             }
         }
         // 鏇存柊绔欑偣鐘舵��
-        agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O","",null);
+//        agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O","",null);
         // 鏇存柊婧愬簱浣嶇姸鎬�
-//        agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"O","",agvWrkMast.getWhsType().shortValue());
+        agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"O","",agvWrkMast.getWhsType().shortValue());
 
         //鍒犻櫎AGV宸ヤ綔鏄庣粏妗�
         agvWrkDetlService.delete(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",oldWrkNo));
diff --git a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
index 12b4c6d..b895aad 100644
--- a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
@@ -78,11 +78,6 @@
                 agvWrkMastLogService.save(agvWrkMast);
                 //鐢熸垚AGV宸ヤ綔鏄庣粏鍘嗗彶妗�
                 agvWrkDetlLogService.save(wrkNo);
-            } else {
-                if (!agvWrkMast.getSourceLocNo().substring(0,2).equals("DB")) {
-                    agvWrkMast.setSourceLocNo("");
-                }
-                agvWrkMastService.updateById(agvWrkMast);
             }
 
             switch (agvWrkMast.getIoType()){
@@ -235,6 +230,13 @@
                 //鍒犻櫎AGV宸ヤ綔鏄庣粏妗�
                 agvWrkDetlService.delete(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",wrkNo));
             }
+//            else {
+//                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"O","",agvWrkMast.getWhsType().shortValue());
+//                if (!agvWrkMast.getSourceLocNo().substring(0,2).equals("DB")) {
+//                    agvWrkMast.setSourceLocNo("");
+//                }
+//                agvWrkMastService.updateById(agvWrkMast);
+//            }
 
             if(!isJSON(orderNo)){
                 //妫�鏌ヨ鍗曟槸鍚﹀凡瀹屾垚

--
Gitblit v1.9.1