From 7eb9b6f8c60a244e1a96597319c7b54963ba6612 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期二, 07 一月 2025 09:03:09 +0800
Subject: [PATCH] 优化MES库存同步逻辑及AGV告警字段

---
 src/main/java/com/zy/asrs/controller/OutController.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 53 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index 17c08a7..2a8ac8a 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -95,7 +95,53 @@
                 //issued = manLocDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
 
                 //鍏堟壘AGV鐨勫簱瀛橈紝濡傛灉杩斿洖鐨刬ssued澶т簬0锛屽垯鍘诲洓椤瑰簱鎵�
-                issued = agvLocDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
+                issued = agvLocDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime(),null);
+
+                //浠庡洓椤瑰簱鐨勫簱瀛橀噷闈㈡壘锛�
+                //issued = locDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
+
+                if (issued > 0) {
+                    LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued,orderDetl.getProcessSts());
+                    locDto.setLack(Boolean.TRUE);
+                    locDtoList.add(locDto);
+                }
+            }
+
+
+        }
+        return R.ok().add(locDtoList);
+
+    }
+
+    //鍑哄簱
+    @PostMapping("/bcp/out/pakout/preview/auth")
+    @ManagerAuth
+    public R bcpPakoutPreview(@RequestBody List<Long> ids) {
+
+        List<OrderDetl> orderDetlList = orderDetlService.selectBatchIds(ids);
+        //杩斿洖缁欏墠绔殑搴撲綅浠ュ強绔欑偣淇℃伅
+        List<LocDto> locDtoList = new ArrayList<>();
+
+        for (OrderDetl orderDetl : orderDetlList) {
+            double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D);
+            Order order = orderService.selectByNo(orderDetl.getOrderNo());
+            DocType docType = docTypeService.selectById(order.getDocType());
+            if("浜哄伐琛ヨ揣鍗�".equals(docType.getDocName())){
+                if (issued <= 0.0D) { continue; }
+                issued = locDetlService.queryStockAndSetLocDto1(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
+                if (issued > 0) {
+                    LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued,orderDetl.getProcessSts());
+                    locDto.setLack(Boolean.TRUE);
+                    locDtoList.add(locDto);
+                }
+            }else {
+                if (issued <= 0.0D) { continue; }
+
+                //浠庡钩搴撳鎵�
+                //issued = manLocDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
+
+                //鍏堟壘AGV鐨勫簱瀛橈紝濡傛灉杩斿洖鐨刬ssued澶т簬0锛屽垯鍘诲洓椤瑰簱鎵�
+                issued = agvLocDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime(),"bcp");
 
                 //浠庡洓椤瑰簱鐨勫簱瀛橀噷闈㈡壘锛�
                 //issued = locDetlService.queryStockAndSetLocDto(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),locDtoList,issued,orderDetl.getThreeCode(),orderDetl.getDeadTime());
@@ -119,6 +165,11 @@
     @Synchronized
     public synchronized R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException {
 
+        for (LocDto locDto : locDtos) {
+            if (locDto.getAnfme() == 0) {
+                return R.error(locDto.getMatnr()+"锛氬嚭搴撴暟閲忎负0");
+            }
+        }
         //鍒ゆ柇鏄惁鍙互鐢熸垚鍑哄簱宸ヤ綔妗�
         boolean lack = true;
         for (LocDto locDto : locDtos) {
@@ -234,7 +285,7 @@
                 continue;
             }
             //鍏堟壘AGV鐨勫簱瀛橈紝濡傛灉杩斿洖鐨刬ssued澶т簬0锛屽垯鍘诲洓椤瑰簱鎵�
-            issued = agvLocDetlService.queryStockAndSetLocDto(vo.getMatnr(),vo.getBatch(),JSON.toJSONString(vo.getOrderDtos()),locDtoList,issued, vo.getCsocode(), vo.getIsoseq());
+            issued = agvLocDetlService.queryStockAndSetLocDto(vo.getMatnr(),vo.getBatch(),JSON.toJSONString(vo.getOrderDtos()),locDtoList,issued, vo.getCsocode(), vo.getIsoseq(),null);
             //浠庡洓椤瑰簱鐨勫簱瀛橀噷闈㈡壘锛�
             issued = locDetlService.queryStockAndSetLocDto(vo.getMatnr(),vo.getBatch(),JSON.toJSONString(vo.getOrderDtos()),locDtoList,issued, vo.getCsocode(), vo.getIsoseq());
 

--
Gitblit v1.9.1