From 44522f08bff3abc3c34c77215eacd2cb3a484a0d Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期三, 29 四月 2026 14:07:51 +0800
Subject: [PATCH] 双伸出库优先筛选浅库位的任务进行出库,浅库位任务不足二十个则补上深库位出库的任务

---
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java |  126 +++++++++++++++++++++++++++++++----------
 1 files changed, 95 insertions(+), 31 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
index d98627e..9322455 100644
--- a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
@@ -76,6 +76,8 @@
     @Autowired
     private OrderDetlService orderDetlService;
     @Autowired
+    private OrderDetlPakoutService orderDetlPakoutService;
+    @Autowired
     private ConfigService configService;
     @Autowired
     private WcsController wcsController;
@@ -367,6 +369,7 @@
             wrkMast.setExitMk("N"); // 閫�鍑�
             wrkMast.setEmptyMk("N"); // 绌烘澘
             wrkMast.setLinkMis("N");
+            wrkMast.setPdcType("N");
             wrkMast.setBarcode(locMast.getBarcode());
             wrkMast.setTakeNone("0");  //0闈炶嚜鍔�
 
@@ -749,6 +752,7 @@
         wrkMast.setExitMk("N"); // 閫�鍑�
         wrkMast.setEmptyMk("N"); // 绌烘澘
         wrkMast.setLinkMis("N");
+        wrkMast.setPdcType("N");
         wrkMast.setBarcode(locMast.getBarcode());
         wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
         wrkMast.setAppeTime(now);
@@ -878,7 +882,7 @@
     public String emptyPlateIn(Integer devpNo, Long userId) {
         // 婧愮珯鐐圭姸鎬佹娴�
         BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);
-        // 妫�绱㈠簱浣�
+        // 妫�绱㈠簱浣嶏紱浜哄伐绌烘墭鐩樺叆搴撳浐瀹氫紶 staDescId=10锛屽疄闄呮壘浣嶈鍒欓泦涓湪 CommonService銆�
         LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);
         FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();
 
@@ -984,6 +988,7 @@
             wrkMast.setExitMk("N"); // 閫�鍑�
             wrkMast.setEmptyMk("Y"); // 绌烘澘
             wrkMast.setLinkMis("N");
+            wrkMast.setPdcType("N");
             wrkMast.setAppeUser(userId);
             wrkMast.setAppeTime(now);
             wrkMast.setModiUser(userId);
@@ -1046,6 +1051,7 @@
             wrkMast.setExitMk("N"); // 閫�鍑�
             wrkMast.setEmptyMk("Y"); // 绌烘澘
             wrkMast.setLinkMis("N");
+            wrkMast.setPdcType("N");
             wrkMast.setAppeUser(1L);
             wrkMast.setAppeTime(now);
             wrkMast.setModiUser(1L);
@@ -1530,38 +1536,39 @@
                     throw new CoolException("淇濆瓨鏁版嵁澶辫触");
                 }
             }
+            rollbackPakoutOrderWorkQty(wrkMast, wrkDetls, userId, now);
             for (WrkDetl wrkDetl : wrkDetls) {
-                if (!Cools.isEmpty(wrkDetl.getOrderNo())) {
-//                    if (!orderDetlService.decrease(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())) {
-//                        throw new CoolException("璁㈠崟鏁版嵁鍥炴粴澶辫触");
-//                    }
-                    OrderInAndOutUtil.decrease(Boolean.FALSE,wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(),wrkDetl.getBrand(),
-                            wrkDetl.getStandby1(),wrkDetl.getStandby2(),wrkDetl.getStandby3(),
-                            wrkDetl.getBoxType1(),wrkDetl.getBoxType2(),wrkDetl.getBoxType3(), wrkDetl.getAnfme());
-
-                    //淇敼璁㈠崟涓昏〃鐘舵��,娌℃湁浣滀笟鏁伴噺鏃舵墠鍙互淇敼
-                    boolean flag = true;
-//                    List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no",wrkDetl.getOrderNo()));
-                    Order order = OrderInAndOutUtil.selectByNo(Boolean.FALSE, wrkDetl.getOrderNo());
-                    List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(Boolean.FALSE, order.getId());
-                    for(OrderDetl orderDetl : orderDetls){
-                        if(orderDetl.getWorkQty() > 0){
-                            flag = false;
-                        }
-                    }
-                    if(flag){
-//                        Order order = orderService.selectOne(new EntityWrapper<Order>().eq("order_no",wrkDetl.getOrderNo()));
-                        if(!Cools.isEmpty(order) && order.getSettle()==2){
-                            order.setSettle(1L);
-                            order.setUpdateBy(userId);
-                            order.setUpdateTime(now);
-                        }
-//                        if(!orderService.update(order,new EntityWrapper<Order>().eq("order_no",wrkDetl.getOrderNo()))){
-//                            throw new CoolException("淇敼璁㈠崟鐘舵�佸け璐�");
+//                if (!Cools.isEmpty(wrkDetl.getOrderNo())) {
+////                    if (!orderDetlService.decrease(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())) {
+////                        throw new CoolException("璁㈠崟鏁版嵁鍥炴粴澶辫触");
+////                    }
+//                    OrderInAndOutUtil.decrease(Boolean.FALSE,wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(),wrkDetl.getBrand(),
+//                            wrkDetl.getStandby1(),wrkDetl.getStandby2(),wrkDetl.getStandby3(),
+//                            wrkDetl.getBoxType1(),wrkDetl.getBoxType2(),wrkDetl.getBoxType3(), wrkDetl.getAnfme());
+//
+//                    //淇敼璁㈠崟涓昏〃鐘舵��,娌℃湁浣滀笟鏁伴噺鏃舵墠鍙互淇敼
+//                    boolean flag = true;
+////                    List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no",wrkDetl.getOrderNo()));
+//                    Order order = OrderInAndOutUtil.selectByNo(Boolean.FALSE, wrkDetl.getOrderNo());
+//                    List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(Boolean.FALSE, order.getId());
+//                    for(OrderDetl orderDetl : orderDetls){
+//                        if(orderDetl.getWorkQty() > 0){
+//                            flag = false;
 //                        }
-                        OrderInAndOutUtil.updateOrder(Boolean.FALSE,order.getId(),order.getSettle(),userId);
-                    }
-                }
+//                    }
+//                    if(flag){
+////                        Order order = orderService.selectOne(new EntityWrapper<Order>().eq("order_no",wrkDetl.getOrderNo()));
+//                        if(!Cools.isEmpty(order) && order.getSettle()==2){
+//                            order.setSettle(1L);
+//                            order.setUpdateBy(userId);
+//                            order.setUpdateTime(now);
+//                        }
+////                        if(!orderService.update(order,new EntityWrapper<Order>().eq("order_no",wrkDetl.getOrderNo()))){
+////                            throw new CoolException("淇敼璁㈠崟鐘舵�佸け璐�");
+////                        }
+//                        OrderInAndOutUtil.updateOrder(Boolean.FALSE,order.getId(),order.getSettle(),userId);
+//                    }
+//                }
             }
 
         }
@@ -1617,6 +1624,63 @@
         }
     }
 
+    /**
+     * 鍑哄簱浠诲姟鍙栨秷鏃跺洖婊氬嚭搴撹鍗曟槑缁嗙殑浠诲姟鐢熸垚鏁伴噺銆�
+     *
+     * 寤惰繜鍑哄簱璁㈠崟涓細
+     * - work_qty 琛ㄧず宸茬粡鐢熸垚浠诲姟鐨勬暟閲忥紱
+     * - qty 琛ㄧず宸茬粡瀹屾垚鍑哄簱鐨勬暟閲忋��
+     *
+     * WCS 鍙栨秷鎴栨湰鍦板彇娑堜换鍔″悗锛屼换鍔′細琚Щ鍏ュ巻鍙叉。骞跺垹闄ゅ綋鍓嶅伐浣滄。銆�
+     * 濡傛灉涓嶅洖婊� work_qty锛屽悗缁悓涓�璁㈠崟鍐嶆涓嬪彂鏃剁郴缁熶細璇涓鸿繖浜涙槑缁嗕粛宸茬敓鎴愪换鍔°��
+     */
+    private void rollbackPakoutOrderWorkQty(WrkMast wrkMast, List<WrkDetl> wrkDetls, Long userId, Date now) {
+        if (wrkMast == null || Cools.isEmpty(wrkDetls)) {
+            return;
+        }
+        for (WrkDetl wrkDetl : wrkDetls) {
+            if (wrkDetl == null || Cools.isEmpty(wrkDetl.getOrderNo())) {
+                continue;
+            }
+            OrderDetlPakout orderDetl = findPakoutOrderDetlForRollback(wrkMast, wrkDetl);
+            if (orderDetl == null) {
+                continue;
+            }
+            double oldWorkQty = safeDouble(orderDetl.getWorkQty());
+            double rollbackQty = safeDouble(wrkDetl.getAnfme());
+            double completedQty = safeDouble(orderDetl.getQty());
+            double newWorkQty = Math.max(completedQty, oldWorkQty - rollbackQty);
+            orderDetl.setWorkQty(newWorkQty);
+            orderDetl.setUpdateBy(userId);
+            orderDetl.setUpdateTime(now);
+            if (!orderDetlPakoutService.updateById(orderDetl)) {
+                throw new CoolException("鍑哄簱浠诲姟鍙栨秷鍥炴粴璁㈠崟鏄庣粏浣滀笟鏁伴噺澶辫触锛�" + wrkDetl.getOrderNo());
+            }
+        }
+    }
+
+    private OrderDetlPakout findPakoutOrderDetlForRollback(WrkMast wrkMast, WrkDetl wrkDetl) {
+        String palletId = null;
+        if (wrkDetl != null && !Cools.isEmpty(wrkDetl.getZpallet())) {
+            palletId = wrkDetl.getZpallet();
+        } else if (wrkMast != null) {
+            palletId = wrkMast.getBarcode();
+        }
+        if (!Cools.isEmpty(palletId)) {
+            OrderDetlPakout orderDetl = orderDetlPakoutService.selectItemByOrderNoAndPallet(wrkDetl.getOrderNo(), palletId);
+            if (orderDetl != null) {
+                return orderDetl;
+            }
+        }
+        return orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(),
+                wrkDetl.getStandby1(), wrkDetl.getStandby2(), wrkDetl.getStandby3(),
+                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
+    }
+
+    private double safeDouble(Double value) {
+        return value == null ? 0.0D : value;
+    }
+
     @Override
     @Transactional
     public void pickWrkMast(String workNo, Long userId) {

--
Gitblit v1.9.1