From 08915b05c42b2ba97a8bb0809aeb48802ae63b46 Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期五, 27 三月 2026 20:42:32 +0800
Subject: [PATCH] no message

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |  659 +++++++++++++++++++++++++++++++++--------------------------
 1 files changed, 371 insertions(+), 288 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
index 4078f98..7afbf9d 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -68,6 +68,8 @@
     private BasAreasService basAreasService;
     @Autowired
     private CommonService commonService;
+    @Autowired
+    private OrderPakoutService orderPakoutService;
 
     public ReturnT<String> start(WrkMast wrkMast) {
         // 4.鍏ュ簱瀹屾垚
@@ -152,9 +154,13 @@
                             locDetl = new LocDetl();
                             locDetl.sync(wrkDetl);
                             locDetl.setAreaId(locMast.getAreaId());
-                            locMast.setAreaName(locMast.getAreaName());
+                            locDetl.setAreaName(locMast.getAreaName());
                             locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
                             locDetl.setAnfme(wrkDetl.getAnfme()); // 鏁伴噺
+                            locDetl.setBoxType1(wrkDetl.getBoxType1());
+                            locDetl.setSuppCode(wrkDetl.getSuppCode());
+                            locDetl.setThreeCode(wrkDetl.getThreeCode());
+                            locDetl.setStandby1(wrkDetl.getSuppCode());
                             locDetl.setZpallet(wrkDetl.getZpallet()); // 鎵樼洏鏉$爜
                             locDetl.setModiTime(now);
                             locDetl.setAppeTime(now);
@@ -244,7 +250,11 @@
                             locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
                             locDetl.setAnfme(wrkDetl.getAnfme()); // 鏁伴噺
                             locDetl.setAreaId(locMast.getAreaId());
-                            locMast.setAreaName(locMast.getAreaName());
+                            locDetl.setAreaName(locMast.getAreaName());
+                            locDetl.setBoxType1(wrkDetl.getBoxType1());
+                            locDetl.setSuppCode(wrkDetl.getSuppCode());
+                            locDetl.setThreeCode(wrkDetl.getThreeCode());
+                            locDetl.setStandby1(wrkDetl.getSuppCode());
                             locDetl.setZpallet(wrkDetl.getZpallet()); // 鎵樼洏鏉$爜
                             locDetl.setModiTime(now);
                             locDetl.setAppeTime(now);
@@ -350,102 +360,83 @@
                             .selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                     if (wrkDetls54.isEmpty()) {
                         // exceptionHandle("骞舵澘鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌猴紱[workNo={0}]", wrkMast.getWrkNo());
-                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                        return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                                + wrkMast.getLocNo() + "]");
-                    }
-                    // 淇敼搴撳瓨鏄庣粏鏁伴噺锛屽鏃犲簱瀛橈紝鏇炬柊澧�
-                    for (WrkDetl wrkDetl : wrkDetls54) {
-                        LocDetl locDetl = locDetlService.selectItem(locMast.getLocNo(), wrkDetl.getMatnr(),
-                                wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(), wrkDetl.getStandby2(),
-                                wrkDetl.getStandby3(), wrkDetl.getBoxType1(), wrkDetl.getBoxType2(),
-                                wrkDetl.getBoxType3());
-                        if (null != locDetl) {
-                            if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr(),
-                                    wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                    wrkDetl.getStandby2(), wrkDetl.getStandby3(), wrkDetl.getBoxType1(),
-                                    wrkDetl.getBoxType2(), wrkDetl.getBoxType3())) {
-                                // exceptionHandle("骞舵澘鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[matnr={1}]",
-                                // wrkMast.getWrkNo(), wrkDetl.getMatnr());
-                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                                return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                                        + wrkMast.getLocNo() + "]");
-                            }
-                        } else {
-                            locDetl = new LocDetl();
-                            locDetl.sync(wrkDetl);
-                            locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
-                            locDetl.setAnfme(wrkDetl.getAnfme()); // 鏁伴噺
-                            locDetl.setAreaId(locMast.getAreaId());
-                            locMast.setAreaName(locMast.getAreaName());
-                            locDetl.setZpallet(wrkDetl.getZpallet()); // 鎵樼洏鏉$爜
-                            locDetl.setModiTime(now);
-                            locDetl.setAppeTime(now);
-                            if (!locDetlService.insert(locDetl)) {
-                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                                return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 鏂板搴撳瓨鏄庣粏澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                                        + wrkMast.getLocNo() + "]");
-                            }
-                        }
+//                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                        return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+//                                + wrkMast.getLocNo() + "]");
+                    } else {
+                        // 淇敼搴撳瓨鏄庣粏鏁伴噺锛屽鏃犲簱瀛橈紝鏇炬柊澧�
+                        for (WrkDetl wrkDetl : wrkDetls54) {
+                            LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>()
+                                    .eq("supp_code", wrkDetl.getSuppCode())
+                                    .eq("matnr", wrkDetl.getMatnr())
+                                    .eq("loc_no", locMast.getLocNo()));
 
+                            if (null != locDetl) {
+                                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
+                                OrderDetlPakin detlPakin = orderDetlPakinService.selectOne(new EntityWrapper<OrderDetlPakin>()
+//                                                .eq("three_code", wrkDetl.getThreeCode()) //TODO 骞舵澘鏃堕渶瑕佷慨鏀笲SCODE涓鸿鍗昩scode
+                                        .eq("supp_code", wrkDetl.getSuppCode())
+                                        .eq("matnr", wrkDetl.getMatnr())
+                                        .eq("order_no", wrkDetl.getOrderNo()));
+                                try {
+                                    if (!Cools.isEmpty(detlPakin)) {
+                                        double v = Math.round((wrkDetl.getAnfme() - locDetl.getAnfme()) * 10000) / 10000.0;
+                                        double v1 = Math.round((detlPakin.getQty() + v) * 10000) / 10000.0;
+                                        detlPakin.setQty(v1);
+                                        detlPakin.setWorkQty(v1);
+                                        detlPakin.setAdjustQty(wrkDetl.getAdjustQty());
+                                        detlPakin.setSplusQty(wrkDetl.getSplusQty());
+                                        if (!orderDetlPakinService.update(detlPakin, new EntityWrapper<OrderDetlPakin>()
+                                                .eq("matnr", detlPakin.getMatnr())
+                                                .eq("supp_code", detlPakin.getSuppCode())
+                                                .eq("order_no", detlPakin.getOrderNo()))) {
+                                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                                            return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo()
+                                                    + "],[locNo=" + wrkMast.getLocNo() + "]");
+                                        }
+                                    }
+                                } catch (Exception e) {
+                                    log.error(e.getMessage());
+                                }
 
-//                        OrderPakin orderPakin = orderPakinService.selectOne(new EntityWrapper<OrderPakin>().eq("order_no", pakin.getOrderNo()));
-//                        if (Objects.isNull(orderPakin)) {
-//                            throw new CoolException("鏁版嵁閿欒锛岃鍗曚俊鎭笉瀛樺湪锛侊紒");
-//                        }
-//
-//                        if (!orderPakin.getDocType().equals(0)) {
-//                            // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-//                            OrderDetlPakin orderDetlPakin = orderDetlPakinService.selectItem(pakin.getOrderNo(),
-//                                    pakin.getMatnr(), pakin.getBatch(), pakin.getBrand(), pakin.getStandby1(),
-//                                    pakin.getStandby2(), pakin.getStandby3(),
-//                                    pakin.getBoxType1(), pakin.getBoxType2(), pakin.getBoxType3());
-//                            if (orderDetlPakin == null) {
-//                                orderDetlPakin = orderDetlPakinService.selectItem(pakin.getOrderNo(), pakin.getMatnr(),
-//                                        pakin.getBatch(),
-//                                        pakin.getBrand(), pakin.getStandby1(), pakin.getStandby2(),
-//                                        pakin.getStandby3(),
-//                                        pakin.getBoxType1(), pakin.getBoxType2(), pakin.getBoxType3());
-//                            }
-//                            try {
-//                                if (!Cools.isEmpty(orderDetlPakin)) {
-//                                    if (!orderDetlPakinService.increaseQtyByOrderNo(pakin.getOrderNo(),
-//                                            pakin.getMatnr(),
-//                                            orderDetlPakin.getBatch(), pakin.getBrand(), pakin.getStandby1(),
-//                                            pakin.getStandby2(), pakin.getStandby3(),
-//                                            pakin.getBoxType1(), pakin.getBoxType2(), pakin.getBoxType3(),
-//                                            pakin.getAnfme())) {
-//                                        throw new CoolException("AGV鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo()
-//                                                + "],[locNo=" + wrkMast.getLocNo() + "]");
-//                                    }
-//                                }
-//                            } catch (Exception ignore) {
-//
-//                            }
-//                        }
+                                LocDetl detl = new LocDetl();
+                                detl.setAnfme(wrkDetl.getAnfme());
+                                detl.setStandby1(wrkDetl.getSuppCode());
+                                detl.setBoxType1(locDetl.getBoxType1());
+                                detl.setOrderNo(wrkDetl.getOrderNo());
 
-                        // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-                        OrderDetlPakin orderDetlPakin = orderDetlPakinService.selectItem(wrkDetl.getOrderNo(),
-                                wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                wrkDetl.getStandby2(), wrkDetl.getStandby3(), "1",
-                                wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
-                        try {
-                            if (!Cools.isEmpty(orderDetlPakin)) {
-                                if (!orderDetlPakinService.increaseQtyByOrderNo(wrkDetl.getOrderNo(),
-                                        wrkDetl.getMatnr(),
-                                        orderDetlPakin.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                        wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                                        "1", wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
-                                        wrkDetl.getAnfme())) {
+                                if (!locDetlService.update(detl, new EntityWrapper<LocDetl>()
+                                        .eq("loc_no", locMast.getLocNo())
+                                        .eq("matnr", wrkDetl.getMatnr())
+                                        .eq("supp_code", wrkDetl.getSuppCode()))) {
                                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                                    return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo()
-                                            + "],[locNo=" + wrkMast.getLocNo() + "]");
+                                    return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                                            + wrkMast.getLocNo() + "]");
+                                }
+
+                            } else {
+                                locDetl = new LocDetl();
+                                locDetl.sync(wrkDetl);
+                                locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
+                                locDetl.setAnfme(wrkDetl.getAnfme()); // 鏁伴噺
+                                locDetl.setAreaId(locMast.getAreaId());
+                                locDetl.setAreaName(locMast.getAreaName());
+                                locDetl.setBoxType1(wrkDetl.getBoxType1());
+                                locDetl.setSuppCode(wrkDetl.getSuppCode());
+                                locDetl.setThreeCode(wrkDetl.getThreeCode());
+                                locDetl.setStandby1(wrkDetl.getSuppCode());
+                                locDetl.setZpallet(wrkDetl.getZpallet()); // 鎵樼洏鏉$爜
+                                locDetl.setModiTime(now);
+                                locDetl.setAppeTime(now);
+                                if (!locDetlService.insert(locDetl)) {
+                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                                    return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 鏂板搴撳瓨鏄庣粏澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                                            + wrkMast.getLocNo() + "]");
                                 }
                             }
-                        } catch (Exception ignore) {
-
                         }
                     }
+
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
                         locMast.setLocSts("F");
@@ -462,20 +453,24 @@
                     }
 
                     String agvSta = null;
-                    if (wrkMast.getIoType() == TaskIOType.MERGE_IN.type) {
+                    if (wrkMast.getIoType().equals(TaskIOType.MERGE_IN.type)) {
                         agvSta = wrkMast.getPauseMk();
                     }
-                    // . 鍒犻櫎缂撳瓨绔欑偣鏄庣粏
-                    if (!Objects.isNull(agvSta)) {
-                        // 淇敼鐩爣绔欑偣淇℃伅
-                        BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>().eq("dev_no", agvSta));
-                        if (Objects.isNull(station)) {
-                            throw new CoolException("绔欑偣涓嶅瓨鍦�!!");
-                        }
-                        basStationDetlService.delete(new EntityWrapper<BasStationDetl>().eq("dev_no", station.getDevNo()));
-                        station.setLocSts(LocStsType.LOC_STS_TYPE_D.type);
-                        if (!basStationService.updateById(station)) {
-                            throw new CoolException("绔欑偣鐘舵�佹洿鏂板け璐ワ紒锛�");
+                    List<BasStationDetl> basStationDetls = basStationDetlService.selectList(new EntityWrapper<BasStationDetl>().eq("dev_no", agvSta));
+                    if (Objects.isNull(basStationDetls) || basStationDetls.isEmpty()) {
+                        // . 鍒犻櫎缂撳瓨绔欑偣鏄庣粏
+                        if (!Objects.isNull(agvSta)) {
+                            // 淇敼鐩爣绔欑偣淇℃伅
+                            BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>().eq("dev_no", agvSta));
+                            if (Objects.isNull(station)) {
+                                throw new CoolException("绔欑偣涓嶅瓨鍦�!!");
+                            }
+                            basStationDetlService.delete(new EntityWrapper<BasStationDetl>()
+                                    .eq("dev_no", station.getDevNo()));
+                            station.setLocSts(LocStsType.LOC_STS_TYPE_D.type);
+                            if (!basStationService.updateById(station)) {
+                                throw new CoolException("绔欑偣鐘舵�佹洿鏂板け璐ワ紒锛�");
+                            }
                         }
                     }
                     break;
@@ -484,34 +479,35 @@
                     // 鏍规嵁宸ヤ綔鍙凤紝鏌ヨ宸ヤ綔鏄庣粏妗�
                     List<WrkDetl> wrkDetls57 = wrkDetlService
                             .selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
-                    if (wrkDetls57.isEmpty()) {
+                    if (!wrkDetls57.isEmpty()) {
                         // exceptionHandle("鐩樼偣鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌猴紱[workNo={0}]", wrkMast.getWrkNo());
-                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                        return FAIL.setMsg("鐩樼偣鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                                + wrkMast.getLocNo() + "]");
-                    }
-                    for (WrkDetl wrkDetl : wrkDetls57) {
-                        if (!Cools.isEmpty(wrkDetl.getOrderNo())) {
-                            // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-                            CheckOrderDetl checkOrderDetl = checkOrderDetlService.selectById(wrkDetl.getOrderId());
-                            LocDetl locDetl = locDetlService.selectById(checkOrderDetl.getLocDetlId());
-                            BigDecimal oriAnfme = new BigDecimal(locDetl.getAnfme());
-                            locDetl.setAnfme(checkOrderDetl.getDiffQty()
-                                    .compareTo(BigDecimal.ZERO) == 0
-                                    || checkOrderDetl.getDiffQty()
-                                    .compareTo(BigDecimal.ZERO) > 0
-                                    ? oriAnfme.doubleValue()
-                                    : oriAnfme.add(checkOrderDetl.getDiffQty()).doubleValue());
-                            locDetl.setBookQty(oriAnfme);
-                            locDetl.setDiffQty(checkOrderDetl.getDiffQty());
-                            if (!locDetlService.updateById(locDetl)) {
-                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                                return FAIL.setMsg("鐩樼偣鍏ュ簱 ===>> 淇敼搴撳瓨宸紓鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                                        + wrkMast.getLocNo() + "]");
+                        for (WrkDetl wrkDetl : wrkDetls57) {
+                            if (!Cools.isEmpty(wrkDetl.getOrderNo())) {
+                                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
+                                CheckOrderDetl checkOrderDetl = checkOrderDetlService.selectById(wrkDetl.getOrderId());
+                                if (!Objects.isNull(checkOrderDetl)) {
+                                    LocDetl locDetl = locDetlService.selectById(checkOrderDetl.getLocDetlId());
+                                    if (!Objects.isNull(locDetl)) {
+                                        BigDecimal oriAnfme = new BigDecimal(locDetl.getAnfme());
+                                        locDetl.setAnfme(checkOrderDetl.getDiffQty()
+                                                .compareTo(BigDecimal.ZERO) == 0
+                                                || checkOrderDetl.getDiffQty()
+                                                .compareTo(BigDecimal.ZERO) > 0
+                                                ? oriAnfme.doubleValue()
+                                                : oriAnfme.add(checkOrderDetl.getDiffQty()).doubleValue());
+                                        locDetl.setBookQty(oriAnfme);
+                                        locDetl.setDiffQty(checkOrderDetl.getDiffQty());
+                                        if (!locDetlService.updateById(locDetl)) {
+                                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                                            return FAIL.setMsg("鐩樼偣鍏ュ簱 ===>> 淇敼搴撳瓨宸紓鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                                                    + wrkMast.getLocNo() + "]");
+                                        }
+                                    }
+                                }
                             }
-
                         }
                     }
+
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
                         locMast.setLocSts(wrkMast.getFullPlt().equals("Y") ? "F" : "D");
@@ -620,6 +616,7 @@
                         return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
                                 + wrkMast.getSourceLocNo() + "]");
                     }
+
                     for (WrkDetl wrkDetl : wrkDetls101) {
                         // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
                         OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(),
@@ -668,6 +665,10 @@
                         }
                     }
                     break;
+
+                case 104:
+
+                    break;
                 case 103:
 //                    List<WrkDetl> wrkDetls103 = wrkDetlService
 //                            .selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
@@ -677,7 +678,7 @@
 //                        return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
 //                                + wrkMast.getSourceLocNo() + "]");
 //                    }
-
+//
 //                    for (WrkDetl wrkDetl : wrkDetls103) {
 //                        // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
 //                        OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(),
@@ -819,14 +820,13 @@
      */
     @Transactional(rollbackFor = Exception.class)
     public ReturnT<String> agvDoOut(Task task) {
+        Date now = new Date();
         LocCache locMast = locCacheService
                 .selectOne(new EntityWrapper<LocCache>().eq("loc_no", task.getSourceLocNo()));
-        Date now = new Date();
-
+        if (Objects.isNull(locMast)) {
+            throw new RuntimeException("鏁版嵁閿欒锛氬簱浣嶄俊鎭笉鑳戒负绌猴紒锛�");
+        }
         if (task.getIoType().equals(101)) {
-            if (Objects.isNull(locMast)) {
-                throw new RuntimeException("鏁版嵁閿欒锛氬簱浣嶄俊鎭笉鑳戒负绌猴紒锛�");
-            }
             List<TaskDetl> wrkDetls101 = taskDetlService
                     .selectList(new EntityWrapper<TaskDetl>().eq("wrk_no", task.getWrkNo()));
             if (wrkDetls101.isEmpty()) {
@@ -834,6 +834,7 @@
                 return FAIL.setMsg(
                         "鍏ㄦ澘鍑哄簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + task.getWrkNo() + "],[locNo=" + task.getSourceLocNo() + "]");
             }
+
             BasStation devNo = basStationService
                     .selectOne(new EntityWrapper<BasStation>().eq("dev_no", task.getStaNo()));
             if (Objects.isNull(devNo)) {
@@ -847,31 +848,24 @@
             }
 
             for (TaskDetl wrkDetl : wrkDetls101) {
-                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(),
-                        wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                        wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                        wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
-                if (orderDetlPakout == null) {
-                    orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
-                            wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(), wrkDetl.getStandby2(),
-                            wrkDetl.getStandby3(),
-                            wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
-                }
-                try {
-                    if (!Cools.isEmpty(orderDetlPakout)) {
-                        if (!orderDetlPakoutService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
-                                orderDetlPakout.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
-                                wrkDetl.getAnfme())) {
-                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                            return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo() + "],[locNo="
-                                    + task.getSourceLocNo() + "]");
+                // 鏇存柊澶囪揣鍑哄簱鍗曞畬鎴愭暟閲�
+                OrderPakout orderPakout = orderPakoutService.selectOne(new EntityWrapper<OrderPakout>().eq("order_no", wrkDetl.getOrderNo()));
+                if (!Objects.isNull(orderPakout) && orderPakout.getDocType() == 5) {
+                    try {
+                        if (!Cools.isEmpty(orderPakout)) {
+                            if (!orderDetlPakoutService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
+                                    "1", wrkDetl.getBrand(), wrkDetl.getStandby1(),
+                                    wrkDetl.getStandby2(), wrkDetl.getStandby3(),
+                                    wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
+                                    wrkDetl.getAnfme())) {
+                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                                return FAIL.setMsg("澶囪揣鍑哄簱鍗� ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo() + "],[locNo="
+                                        + task.getSourceLocNo() + "]");
+                            }
                         }
+                    } catch (Exception ignore) {
+                        log.error(ignore.getMessage(), ignore);
                     }
-                } catch (Exception ignore) {
-
                 }
 
                 BasStationDetl stationDetl = new BasStationDetl();
@@ -882,6 +876,42 @@
                     throw new CoolException("绔欑偣鏄庣粏淇濆瓨澶辫触锛侊紒");
                 }
             }
+//            for (TaskDetl wrkDetl : wrkDetls101) {
+//                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
+//                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(),
+//                        wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
+//                        wrkDetl.getStandby2(), wrkDetl.getStandby3(),
+//                        wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
+//                if (orderDetlPakout == null) {
+//                    orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
+//                            wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(), wrkDetl.getStandby2(),
+//                            wrkDetl.getStandby3(),
+//                            wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
+//                }
+//                try {
+//                    if (!Cools.isEmpty(orderDetlPakout)) {
+//                        if (!orderDetlPakoutService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
+//                                orderDetlPakout.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
+//                                wrkDetl.getStandby2(), wrkDetl.getStandby3(),
+//                                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
+//                                wrkDetl.getAnfme())) {
+//                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                            return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo() + "],[locNo="
+//                                    + task.getSourceLocNo() + "]");
+//                        }
+//                    }
+//                } catch (Exception ignore) {
+//
+//                }
+//
+//                BasStationDetl stationDetl = new BasStationDetl();
+//                BeanUtils.copyProperties(wrkDetl, stationDetl);
+//                stationDetl.setDevNo(devNo.getDevNo())
+//                        .setOrderNo(wrkDetl.getOrderNo());
+//                if (!basStationDetlService.insert(stationDetl)) {
+//                    throw new CoolException("绔欑偣鏄庣粏淇濆瓨澶辫触锛侊紒");
+//                }
+//            }
             // 鍒犻櫎宸ヤ綔妗f簮搴撲綅鐨勫簱瀛樻槑缁�
             if (!locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no", task.getSourceLocNo()))) {
                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -889,12 +919,12 @@
                         "鍏ㄦ澘鍑哄簱 ===>> 鍒犻櫎搴撳瓨鏄庣粏澶辫触; [workNo=" + task.getWrkNo() + "],[locNo=" + task.getSourceLocNo() + "]");
             }
             // 淇敼婧愬簱浣嶇姸鎬� R ===>> O
-            if (locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type)) {
+            if (locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type) || locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_P.type)) {
                 locMast.setLocSts(LocStsType.LOC_STS_TYPE_O.type);
                 locMast.setBarcode("");
                 locMast.setModiTime(now);
                 locMast.setIoTime(now);
-                if (!locCacheService.updateById(locMast)) {
+                if (!locCacheService.update(locMast, new EntityWrapper<LocCache>().eq("loc_no", locMast.getLocNo()))) {
                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                     return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + task.getWrkNo() + "],[locNo="
                             + task.getSourceLocNo() + "]");
@@ -908,24 +938,19 @@
                 throw new CoolException("浠诲姟鐘舵�佷慨鏀瑰け璐ワ紒锛�");
             }
         } else if (task.getIoType().equals(110)) {
-            if (Objects.isNull(locMast)) {
-                throw new RuntimeException("鏁版嵁閿欒锛氬簱浣嶄俊鎭笉鑳戒负绌猴紒锛�");
-            }
             // 淇敼婧愬簱浣嶇姸鎬� R ===>> O
             if (locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type)) {
                 locMast.setLocSts(LocStsType.LOC_STS_TYPE_O.type);
                 locMast.setBarcode("");
                 locMast.setModiTime(now);
                 locMast.setIoTime(now);
-                if (!locCacheService.updateById(locMast)) {
+
+                if (!locCacheService.update(locMast, new EntityWrapper<LocCache>().eq("loc_no", locMast.getLocNo()))) {
                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                     return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + task.getWrkNo() + "],[locNo="
                             + task.getSourceLocNo() + "]");
                 }
-            } else {
-                throw new CoolException("褰撳墠搴撲綅鐘舵��" + locMast.getLocSts() + ", 鏃犳硶鎵ц鍑哄簱鎿嶄綔锛侊紒");
             }
-
             BasStation devNo = basStationService
                     .selectOne(new EntityWrapper<BasStation>().eq("dev_no", task.getStaNo()));
             if (Objects.isNull(devNo)) {
@@ -948,75 +973,122 @@
                 return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + task.getWrkNo() + "],[locNo="
                         + task.getSourceLocNo() + "]");
             }
-            for (TaskDetl wrkDetl : wrkDetls103) {
-                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.
-                        selectOne(new EntityWrapper<OrderDetlPakout>()
-                                .eq("matnr", wrkDetl.getMatnr())
-                                .eq("supp_code", wrkDetl.getSuppCode())
-                                .eq("order_no", wrkDetl.getOrderNo()));
-                try {
-                    if (!Cools.isEmpty(orderDetlPakout)) {
-                        if (!orderDetlPakoutService.increaseQtyByOrderNo(wrkDetl.getOrderNo(),
-                                wrkDetl.getMatnr(),
-                                orderDetlPakout.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
-                                wrkDetl.getAnfme())) {
-                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                            return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo()
-                                    + "],[locNo=" + task.getSourceLocNo() + "]");
-                        }
-                    }
-                    //TODO 淇敼绔欑偣鐘舵�侀绾︾洰鏍囧簱浣�,浠ュ強绔欑偣搴撲綅淇℃伅
-                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>()
-                            .eq("matnr", wrkDetl.getMatnr())
-                            .eq("supp_code", wrkDetl.getSuppCode())
-                            .eq("loc_no", task.getSourceLocNo()));
-                    if (Objects.isNull(locDetl) ) {
-                        throw new CoolException("搴撳瓨鏁版嵁閿欒锛岃鑱旂郴绠$悊鍛橈紒锛�");
-                    }
-                    Double sulp = Math.round((locDetl.getAnfme() - wrkDetl.getAnfme()) * 10000) / 10000.0;
-                    locDetl.setAnfme(sulp);
-                    if (!locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo())
-                            .eq("matnr", locDetl.getMatnr())
-                            .eq("supp_code", locDetl.getSuppCode()))) {
-                        return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo()
-                                + "],[locNo=" + task.getSourceLocNo() + "]");
-                    }
-                } catch (Exception ignore) {
-                    log.error(ignore.getMessage());
-                }
-            }
+//            for (TaskDetl wrkDetl : wrkDetls103) {
+//                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
+//                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.
+//                        selectOne(new EntityWrapper<OrderDetlPakout>()
+//                                .eq("matnr", wrkDetl.getMatnr())
+//                                .eq("supp_code", wrkDetl.getSuppCode())
+//                                .eq("order_no", wrkDetl.getOrderNo()));
+//                try {
+//                    if (!Cools.isEmpty(orderDetlPakout)) {
+//                        if (!orderDetlPakoutService.increaseQtyByOrderNo(wrkDetl.getOrderNo(),
+//                                wrkDetl.getMatnr(),
+//                                orderDetlPakout.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
+//                                wrkDetl.getStandby2(), wrkDetl.getStandby3(),
+//                                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
+//                                wrkDetl.getAnfme())) {
+//                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                            return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo()
+//                                    + "],[locNo=" + task.getSourceLocNo() + "]");
+//                        }
+//                    }
+//                    //TODO 淇敼绔欑偣鐘舵�侀绾︾洰鏍囧簱浣�,浠ュ強绔欑偣搴撲綅淇℃伅
+//                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>()
+//                            .eq("matnr", wrkDetl.getMatnr())
+//                            .eq("supp_code", wrkDetl.getSuppCode())
+//                            .eq("loc_no", task.getSourceLocNo()));
+//                    if (Objects.isNull(locDetl) ) {
+//                        throw new CoolException("搴撳瓨鏁版嵁閿欒锛岃鑱旂郴绠$悊鍛橈紒锛�");
+//                    }
+//                    Double sulp = Math.round((locDetl.getAnfme() - wrkDetl.getAnfme()) * 10000) / 10000.0;
+//                    locDetl.setAnfme(sulp);
+//                    if (!locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo())
+//                            .eq("matnr", locDetl.getMatnr())
+//                            .eq("supp_code", locDetl.getSuppCode()))) {
+//                        return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + task.getWrkNo()
+//                                + "],[locNo=" + task.getSourceLocNo() + "]");
+//                    }
+//                } catch (Exception ignore) {
+//                    log.error(ignore.getMessage());
+//                }
+//            }
+
+//            if (locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_P.type) || locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type)) {
+//                locMast.setLocSts(LocStsType.LOC_STS_TYPE_S.type);
+//                locMast.setBarcode("");
+//                locMast.setModiTime(now);
+//                locMast.setIoTime(now);
+//                if (!locCacheService.updateById(locMast)) {
+//                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                    return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + task.getWrkNo() + "],[locNo="
+//                            + task.getSourceLocNo() + "]");
+//                }
+//            } else {
+//                throw new CoolException("褰撳墠搴撲綅鐘舵��" + locMast.getLocSts() + ", 鏃犳硶鎵ц鍑哄簱鎿嶄綔锛侊紒");
+//            }
+//
+//            BasStation basStation = basStationService.selectOne(new EntityWrapper<BasStation>().eq("dev_no", task.getStaNo()));
+//            // 淇敼婧愬簱浣嶇姸鎬� R ===>> O
+//            if (basStation.getLocSts().equals(LocStsType.LOC_STS_TYPE_F.type) || basStation.getLocSts().equals(LocStsType.LOC_STS_TYPE_P.type)) {
+//                basStation.setLocSts(LocStsType.LOC_STS_TYPE_R.type);
+//                basStation.setBarcode("");
+//                basStation.setModiTime(now);
+//                basStation.setIoTime(now);
+//                if (!basStationService.updateById(basStation)) {
+//                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                    return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + task.getWrkNo() + "],[locNo="
+//                            + task.getSourceLocNo() + "]");
+//                }
+//            } else {
+//                throw new CoolException("褰撳墠搴撲綅鐘舵��" + basStation.getLocSts() + ", 鏃犳硶鎵ц鍑哄簱鎿嶄綔锛侊紒");
+//            }
+//            Task task1 = new Task();
 //            int workNo = commonService.getWorkNo(0);
-            task.setIoType(task.getIoType() - 50);
-            task.setLocNo(task.getSourceLocNo());
-            task.setWrkSts(TaskStatusType.AGV_IN_START.type);
-
-            if (!taskService.update(task, new EntityWrapper<Task>().eq("wrk_no", task.getWrkNo()))) {
-                throw new CoolException("浠诲姟鎷h揣瀹屾垚鐘舵�佹洿鏂板け璐ワ紒锛�");
-            }
-
-            // 淇敼婧愬簱浣嶇姸鎬� R ===>> O
-            if (locMast.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type)) {
-                locMast.setLocSts(LocStsType.LOC_STS_TYPE_S.type);
-                locMast.setBarcode("");
-                locMast.setModiTime(now);
-                locMast.setIoTime(now);
-                if (!locCacheService.updateById(locMast)) {
-                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                    return FAIL.setMsg("鎷f枡鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + task.getWrkNo() + "],[locNo="
-                            + task.getSourceLocNo() + "]");
-                }
-            } else {
-                throw new CoolException("褰撳墠搴撲綅鐘舵��" + locMast.getLocSts() + ", 鏃犳硶鎵ц鍑哄簱鎿嶄綔锛侊紒");
-            }
+//            task1.setWrkNo(workNo);
+//            task1.setIoType(task.getIoType() - 50);
+//            task1.setLocNo(task.getSourceLocNo());
+//            task1.setIsNewIn("M1");
+//            task1.setSourceStaNo(task.getStaNo());
+//            task1.setWrkSts(TaskStatusType.AGV_IN_START.type);
+//
+//            if (!taskService.insert(task1)) {
+//                throw new CoolException("鎷h揣鍏ュ簱浠诲姟鐢熸垚澶辫触锛侊紒");
+//            }
+//
+//            List<TaskDetl> taskDetls = taskDetlService.selectList(new EntityWrapper<TaskDetl>().eq("wrk_no", task.getWrkNo()));
+//            taskDetls.forEach(detl -> {
+//                detl.setWrkNo(task1.getWrkNo());
+//                if (!taskDetlService.update(detl, new EntityWrapper<TaskDetl>().eq("wrk_no", detl.getWrkNo()))) {
+//                    throw new CoolException("浠诲姟鏄庣粏淇敼澶辫触锛侊紒");
+//                }
+//            });
+//            task.setWrkSts(TaskStatusType.AGV_INVENTORY_UPDATED_OUT.type);
+//            if (!taskService.updateById(task)) {
+//                throw new CoolException("浠诲姟鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+//            }
         }
         return SUCCESS;
     }
 
     @Transactional(rollbackFor = Exception.class)
     public ReturnT<String> agvDoIn(Task wrkMast) {
+        if (wrkMast.getIsNewIn().equals("XM1")) {
+            wrkMast.setWrkSts(TaskStatusType.AGV_INVENTORY_UPDATED_IN.type);
+            wrkMast.setModiTime(new Date());
+            if (!taskService.updateById(wrkMast)) {
+                throw new CoolException("浠诲姟鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+            }
+            return SUCCESS;
+        }
+        if (wrkMast.getTaskType().equals("agv_back")) {
+            wrkMast.setWrkSts(TaskStatusType.AGV_INVENTORY_UPDATED_IN.type);
+            wrkMast.setModiTime(new Date());
+            if (!taskService.updateById(wrkMast)) {
+                throw new CoolException("浠诲姟鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+            }
+            return SUCCESS;
+        }
         LocCache locCache = locCacheService.selectOne(new EntityWrapper<LocCache>().eq("loc_no", wrkMast.getLocNo()));
         if (!Objects.isNull(wrkMast.getSourceStaNo())) {
             BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>()
@@ -1028,8 +1100,10 @@
                 }
                 station.setBarcode("");
                 if (!basStationService.updateById(station)) {
-                    basStationDetlService.delete(new EntityWrapper<BasStationDetl>().eq("dev_no", station.getDevNo()));
+                    throw new CoolException("绔欑偣鐘舵�佷慨鏀瑰け璐ワ紒锛�");
                 }
+
+                basStationDetlService.delete(new EntityWrapper<BasStationDetl>().eq("dev_no", station.getDevNo()));
             }
         }
 
@@ -1110,7 +1184,8 @@
             locCache.setBarcode(wrkMast.getBarcode());
             locCache.setModiTime(new Date());
             locCache.setIoTime(new Date());
-            if (!locCacheService.updateById(locCache)) {
+
+            if (!locCacheService.update(locCache, new EntityWrapper<LocCache>().eq("loc_no", locCache.getLocNo()))) {
                 throw new CoolException("搴撲綅鐘舵�佷慨鏀瑰け璐ワ紒");
             }
             wrkMast.setWrkSts(TaskStatusType.AGV_INVENTORY_UPDATED_IN.type);
@@ -1137,81 +1212,89 @@
             // 鏍规嵁宸ヤ綔鍙凤紝鏌ヨ宸ヤ綔鏄庣粏妗�
             List<TaskDetl> wrkDetls53 = taskDetlService
                     .selectList(new EntityWrapper<TaskDetl>().eq("wrk_no", wrkMast.getWrkNo()));
-            if (wrkDetls53.isEmpty()) {
-                // exceptionHandle("鎷f枡鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌猴紱[workNo={0}]", wrkMast.getWrkNo());
-                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                        + wrkMast.getLocNo() + "]");
-            }
+
             for (TaskDetl wrkDetl : wrkDetls53) {
-                LocDetl locDetl = locDetlService.selectItem(locCache.getLocNo(), wrkDetl.getMatnr(),
-                        wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(), wrkDetl.getStandby2(),
-                        wrkDetl.getStandby3(), wrkDetl.getBoxType1(), wrkDetl.getBoxType2(),
-                        wrkDetl.getBoxType3());
+                LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>()
+                        .eq("supp_code", wrkDetl.getSuppCode())
+                        .eq("matnr", wrkDetl.getMatnr())
+                        .eq("loc_no", wrkMast.getLocNo()));
+
                 if (null != locDetl) {
-                    if (!locDetlService.updateAnfme(locDetl.getAnfme() - wrkDetl.getAnfme(), locCache.getLocNo(),
-                            wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                            wrkDetl.getStandby2(), wrkDetl.getStandby3(), wrkDetl.getBoxType1(),
-                            wrkDetl.getBoxType2(), wrkDetl.getBoxType3())) {
-                        // exceptionHandle("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[locNo={1}]",
-                        // wrkMast.getWrkNo(), wrkMast.getLocNo());
+                    Double v = Math.round((locDetl.getAnfme() - wrkDetl.getAnfme()) * 10000) / 10000.0;
+                    locDetl.setBoxType1(wrkDetl.getBoxType1());
+                    locDetl.setOrderNo(wrkDetl.getOrderNo());
+                    locDetl.setStandby1(wrkDetl.getSuppCode());
+                    locDetl.setAnfme(v);
+
+                    if (v.compareTo(0.0) == 0) {
+                        if (!locDetlService.delete(new EntityWrapper<LocDetl>()
+                                .eq("supp_code", wrkDetl.getSuppCode())
+                                .eq("matnr", wrkDetl.getMatnr())
+                                .eq("loc_no", wrkMast.getLocNo()))) {
+                            return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                                    + wrkMast.getLocNo() + "]");
+                        }
+                    } else {
+                        if (!locDetlService.update(locDetl, new EntityWrapper<LocDetl>()
+                                .eq("supp_code", wrkDetl.getSuppCode())
+                                .eq("matnr", wrkDetl.getMatnr())
+                                .eq("loc_no", wrkMast.getLocNo()))) {
+                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                            return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                                    + wrkMast.getLocNo() + "]");
+                        }
+                    }
+                }
+
+                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
+                OrderDetlPakout orderDetlPakout = orderDetlPakoutService
+                        .selectOne(new EntityWrapper<OrderDetlPakout>()
+                                .eq("order_no", wrkDetl.getOrderNo())
+                                .eq("supp_code", wrkDetl.getSuppCode())
+                                .eq("matnr", wrkDetl.getMatnr()));
+
+                if (!Cools.isEmpty(orderDetlPakout)) {
+                    double v = Math.round((orderDetlPakout.getQty() + wrkDetl.getAnfme()) * 10000) / 10000.0;
+                    orderDetlPakout.setQty(v);
+
+                    if (!orderDetlPakoutService.update(orderDetlPakout, new EntityWrapper<OrderDetlPakout>()
+                            .eq("order_no", wrkDetl.getOrderNo())
+                            .eq("supp_code", wrkDetl.getSuppCode())
+                            .eq("matnr", wrkDetl.getMatnr()))) {
                         TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                         return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
                                 + wrkMast.getLocNo() + "]");
                     }
                 }
-
-                // 鏇存柊璁㈠崟瀹屾垚鏁伴噺
-                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(),
-                        wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getBrand(),
-                        wrkDetl.getStandby1(), wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                        wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
-                if (orderDetlPakout == null) {
-                    orderDetlPakout = orderDetlPakoutService.selectItem(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),
-                            wrkDetl.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                            wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                            wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3());
-                }
-                try {
-                    if (!Cools.isEmpty(orderDetlPakout)) {
-                        if (!orderDetlPakinService.increaseQtyByOrderNo(wrkDetl.getOrderNo(),
-                                wrkDetl.getMatnr(),
-                                orderDetlPakout.getBatch(), wrkDetl.getBrand(), wrkDetl.getStandby1(),
-                                wrkDetl.getStandby2(), wrkDetl.getStandby3(),
-                                wrkDetl.getBoxType1(), wrkDetl.getBoxType2(), wrkDetl.getBoxType3(),
-                                wrkDetl.getAnfme())) {
-                            // exceptionHandle("鎷f枡鍏ュ簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触锛沎workNo={0}],[locNo={1}]",
-                            // wrkMast.getWrkNo(), wrkMast.getLocNo());
-                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                            return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触; [workNo=" + wrkMast.getWrkNo()
-                                    + "],[locNo=" + wrkMast.getLocNo() + "]");
-                        }
-                    }
-                } catch (Exception ignore) {
-                }
-
             }
             Date now = new Date();
-            // 淇敼搴撲綅鐘舵�� Q ====>> F
-            if (locCache.getLocSts().equals("Q")) {
-                locCache.setLocSts("F");
-                locCache.setBarcode(wrkMast.getBarcode());
-                locCache.setIoTime(now);
-                locCache.setModiTime(now);
-                if (!locCacheService.updateById(locCache)) {
-                    // exceptionHandle("鎷f枡鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐ワ紱[workNo={0}],[locNo={1}]",
-                    // wrkMast.getWrkNo(), wrkMast.getLocNo());
-                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                    return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
-                            + wrkMast.getLocNo() + "]");
+            List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>()
+                    .eq("loc_no", locCache.getLocNo()));
+            if (Objects.isNull(locDetls) || locDetls.isEmpty()) {
+                locCache.setLocSts("D");
+            } else {
+                Double sum = locDetls.stream().mapToDouble(LocDetl::getAnfme).sum();
+                if (sum.compareTo(0.0) == 0) {
+                    locCache.setLocSts("D");
+                } else {
+                    // 淇敼搴撲綅鐘舵�� Q ====>> F
+                    locCache.setLocSts("F");
                 }
             }
-
+            locCache.setBarcode(wrkMast.getBarcode());
+            locCache.setIoTime(now);
+            locCache.setModiTime(now);
+            if (!locCacheService.update(locCache, new EntityWrapper<LocCache>().eq("loc_no", locCache.getLocNo()))) {
+                // exceptionHandle("鎷f枡鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐ワ紱[workNo={0}],[locNo={1}]",
+                // wrkMast.getWrkNo(), wrkMast.getLocNo());
+                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                return FAIL.setMsg("鎷f枡鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo="
+                        + wrkMast.getLocNo() + "]");
+            }
             // 淇敼宸ヤ綔涓绘。鐘舵��
             wrkMast.setWrkSts(TaskStatusType.AGV_INVENTORY_UPDATED_IN.type);
             wrkMast.setModiTime(now);
             if (!taskService.updateById(wrkMast)) {
-                // exceptionHandle("鏇存柊鍏ュ簱瀹屾垚鐘舵�佸け璐�;[workNo={0}]", wrkMast.getWrkNo());
                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 return FAIL
                         .setMsg("鏇存柊鍏ュ簱瀹屾垚鐘舵�佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");

--
Gitblit v1.9.1