From c47395fe29493062a3f0bc2cf1d02a2946b20b88 Mon Sep 17 00:00:00 2001
From: zyh <zyh@123>
Date: 星期日, 04 一月 2026 08:41:35 +0800
Subject: [PATCH] 修改了判断空库位,查询语句的bug,和摄像头的连接

---
 src/main/java/com/zy/asrs/controller/OutController.java |  177 +++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 142 insertions(+), 35 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index e222a56..f17d01b 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -11,6 +11,7 @@
 import com.zy.common.model.LocDto;
 import com.zy.common.model.TaskDto;
 import com.zy.common.web.BaseController;
+import lombok.Synchronized;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -81,8 +82,8 @@
                 if (issued <= 0.0D) {
                     continue;
                 }
-                List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist,orderDetl.getMatnr(), orderDetl.getBatch(),
-                        orderDetl.getBrand(),orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3());
+                List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist, orderDetl.getMatnr(), orderDetl.getBatch(),
+                        orderDetl.getBrand(), orderDetl.getStandby1(), orderDetl.getStandby2(), orderDetl.getStandby3(), orderDetl.getBoxType1(), orderDetl.getBoxType2(), orderDetl.getBoxType3());
                 for (LocDetl locDetl : locDetls) {
                     if (issued > 0) {
                         LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
@@ -128,8 +129,8 @@
                     continue;
                 }
 
-                List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist,orderDetl.getMatnr(), orderDetl.getBatch(),
-                        orderDetl.getBrand(),orderPakOut.getDocType()==11?null:orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3());
+                List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist, orderDetl.getMatnr(), orderDetl.getBatch(),
+                        orderDetl.getBrand(), orderPakOut.getDocType() == 11 ? null : orderDetl.getStandby1(), orderDetl.getStandby2(), orderDetl.getStandby3(), orderDetl.getBoxType1(), orderDetl.getBoxType2(), orderDetl.getBoxType3());
                 for (LocDetl locDetl : locDetls) {
                     if (issued > 0) {
                         LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
@@ -172,15 +173,16 @@
         return R.ok().add(locDtos);
     }
 
+    @Synchronized
     @PostMapping("/out/pakout/auth")
     @ManagerAuth(memo = "璁㈠崟鍑哄簱")
-    public synchronized R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException {
+    public R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException {
         if (Cools.isEmpty(locDtos)) {
             return R.parse(BaseRes.PARAM);
         }
         List<LocDto> locDtoArrayList = new ArrayList<>();
-        for (LocDto locDto : locDtos){
-            if (locDto.getFrozen()!=1 && locDto.getFrozenLoc()!=1){
+        for (LocDto locDto : locDtos) {
+            if (locDto.getFrozen() != 1 && locDto.getFrozenLoc() != 1) {
                 locDtoArrayList.add(locDto);
             }
         }
@@ -204,7 +206,9 @@
         List<TaskDto> taskDtos = new ArrayList<>();
         // 鏍规嵁 锛堝簱浣� & 鍑哄簱绔欙級 鍒嗙粍锛� 鐞嗘兂鐘舵�侊細涓�缁勪负涓�娆″嚭搴撲换鍔�
         for (LocDto locDto : locDtos) {
-            if (locDto.isLack()) { continue; }
+            if (locDto.isLack()) {
+                continue;
+            }
             TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto);
             if (TaskDto.has(taskDtos, taskDto)) {
                 TaskDto dto = TaskDto.find(taskDtos, taskDto);
@@ -223,28 +227,35 @@
         //浼樺厛绾�
         int ioPri = 50;
         //宸蹭笅绌烘澘鍑哄簱浠诲姟鏁伴噺
-        int j=1;
+        int j = 1;
         // -----------------------------------------------------------------------------------------------
         for (TaskDto taskDto : taskDtos) {
             BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
-            workService.stockOut(staNo, taskDto, getUserId(),ioPri);
+            workService.stockOut(staNo, taskDto, getUserId(), ioPri);
             ioPri--;
             i++;
             //閰嶇洏鍑哄簱鍗曚娇鐢紝涓嬪彂闇�瑕佸嚭鐨勭┖鏉夸换鍔�
             if (orderPakout.getDocType() == 11) {
-                if (size<5&&i==size){
-                    for (;j<=orderPakout.getPayType();j++){
-                        String bar="";
-                        if(!Cools.isEmpty(orderPakout.getShipCode())&&orderPakout.getShipCode().equals("A01")){
-                            bar = "A01";
+                if (i == size) {
+                    for (; j <= orderPakout.getPayType(); j++) {
+                        LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", taskDto.getLocNo()));
+                        Integer locType = Integer.valueOf(locMast1.getLocType2());
+                        //閰嶇洏 鍑哄簱鍗曞嚭搴撳尯鍩熸椂Q-L4鏃�,鍑哄ぇ鎵樼洏绌烘澘
+                        if(orderPakout.getCstmrName().equals("Q-L4")){
+                            locType = 2;
                         }
-                        LocMast locMast = new  LocMast();
-                        if(Cools.isEmpty(bar)){
-                            locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
-                                    .eq("loc_sts", "D"));
-                        }else {
-                            locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
-                                    .eq("loc_sts", "D").like("barcode", bar));
+                        String bar = "";
+                        //鍏蜂綋寰呭畾
+//                        if(!Cools.isEmpty(orderPakout.getShipCode())&&orderPakout.getShipCode().equals("A01")){
+//                            bar = "A01";
+//                        }
+                        LocMast locMast = new LocMast();
+                        if (Cools.isEmpty(bar)) {
+                            locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                                    .eq("loc_sts", "D").eq("loc_type2", locType));
+                        } else {
+                            locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                                    .eq("loc_sts", "D").eq("loc_type2", locType).like("barcode", bar));
                         }
 
                         if (Cools.isEmpty(locMast)) {
@@ -253,23 +264,41 @@
                         String locNo = locMast.getLocNo();
                         EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
                         emptyPlateOutParam.setOutSite(303);
-                        emptyPlateOutParam.setLocNos(new ArrayList<String>(){{add(locNo);}});
-                        WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam,ioPri);
+                        emptyPlateOutParam.setLocNos(new ArrayList<String>() {{
+                            add(locNo);
+                        }});
+                        String agvSta = "";
+                        if (locMast.getLocType3() == 2) {
+                            agvSta = "Z-LZP26";
+                        }else if (locType == 2){
+
+                        }
+                        else {
+                            agvSta = orderPakout.getCstmrName();//agv鐩爣绔欑偣浣嶇疆
+                        }
+                        WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam, ioPri, agvSta);
                         ioPri--;
 
                     }
-                }else if(i == 5){
-                    String bar="";
-                    if(!Cools.isEmpty(orderPakout.getShipCode())&&orderPakout.getShipCode().equals("A01")){
+                } else if (i == 4) {
+                    LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", taskDto.getLocNo()));
+                    Integer locType = Integer.valueOf(locMast1.getLocType2());
+                    //閰嶇洏 鍑哄簱鍗曞嚭搴撳尯鍩熸椂Q-L4鏃�,鍑哄ぇ鎵樼洏绌烘澘
+                    if(orderPakout.getCstmrName().equals("Q-L4")){
+                        locType = 2;
+                    }
+
+                    String bar = "";
+                    if (!Cools.isEmpty(orderPakout.getShipCode()) && orderPakout.getShipCode().equals("A01")) {
                         bar = "A01";
                     }
                     LocMast locMast = null;
-                    if(Cools.isEmpty(bar)){
-                        locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
-                                .eq("loc_sts", "D"));
-                    }else {
-                        locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
-                                .eq("loc_sts", "D").like("barcode", bar));
+                    if (Cools.isEmpty(bar)) {
+                        locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                                .eq("loc_sts", "D").eq("loc_type2", locType));
+                    } else {
+                        locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                                .eq("loc_sts", "D").eq("loc_type2", locType).like("barcode", bar));
                     }
 
                     if (Cools.isEmpty(locMast)) {
@@ -278,13 +307,91 @@
                     String locNo = locMast.getLocNo();
                     EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
                     emptyPlateOutParam.setOutSite(303);
-                    emptyPlateOutParam.setLocNos(new ArrayList<String>(){{add(locNo);}});
-                    WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam,ioPri);
+                    emptyPlateOutParam.setLocNos(new ArrayList<String>() {{
+                        add(locNo);
+                    }});
+                    String agvSta = "";
+                    if (locMast.getLocType3() == 2) {
+
+                    } else {
+                        agvSta = orderPakout.getCstmrName();//agv鐩爣绔欑偣浣嶇疆
+                    }
+                    WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam, ioPri, agvSta);
                     ioPri--;
+                    j++;
                 }
             }
         }
         return R.ok();
     }
 
+    @PostMapping("/out/pakout/preview/auth1")
+    @ManagerAuth
+    public R pakoutPreview1(@RequestBody String orderNo) throws InterruptedException {
+        if (Cools.isEmpty(orderNo)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        List<OrderDetlPakout> orderDetlPakouts = orderDetlPakoutService.selectList(new EntityWrapper<OrderDetlPakout>().eq("order_no", orderNo));
+
+        if (orderDetlPakouts.size() == 0) {
+            return R.parse("璁㈠崟鏄庣粏涓虹┖");
+        }
+
+        List<LocDto> locDtos = new ArrayList<>();
+
+        Set<String> exist = new HashSet<>();
+
+        // 鑾峰彇璁㈠崟涓昏〃
+        OrderPakout orderPakOut = orderPakOutService.selectByNo(orderDetlPakouts.get(0).getOrderNo());
+
+        for (OrderDetlPakout orderDetl : orderDetlPakouts) {
+            double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getWorkQty()).orElse(0.0D);
+            if (issued <= 0.0D) {
+                continue;
+            }
+
+            List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist, orderDetl.getMatnr(), orderDetl.getBatch(),
+                    orderDetl.getBrand(), orderPakOut.getDocType() == 11 ? null : orderDetl.getStandby1(), orderDetl.getStandby2(), orderDetl.getStandby3(), orderDetl.getBoxType1(), orderDetl.getBoxType2(), orderDetl.getBoxType3());
+            for (LocDetl locDetl : locDetls) {
+                if (issued > 0) {
+                    LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
+                            issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
+                    LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo()));
+                    locDto.setFrozen(locDetl.getFrozen());
+                    locDto.setFrozenLoc(locMast.getFrozen());
+                    List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103);
+                    locDto.setStaNos(staNos);
+                    locDto.setBrand(orderDetl.getBrand());
+
+                    locDto.setStandby1(orderDetl.getStandby1());
+                    locDto.setStandby2(orderDetl.getStandby2());
+                    locDto.setStandby3(orderDetl.getStandby3());
+                    locDto.setBoxType1(orderDetl.getBoxType1());
+                    locDto.setBoxType2(orderDetl.getBoxType2());
+                    locDto.setBoxType3(orderDetl.getBoxType3());
+                    locDtos.add(locDto);
+                    exist.add(locDetl.getLocNo());
+                    // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
+                    issued = issued - locDetl.getAnfme();
+                } else {
+                    break;
+                }
+            }
+            if (issued > 0) {
+                LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
+                locDto.setBrand(orderDetl.getBrand());
+                locDto.setStandby1(orderDetl.getStandby1());
+                locDto.setStandby2(orderDetl.getStandby2());
+                locDto.setStandby3(orderDetl.getStandby3());
+                locDto.setBoxType1(orderDetl.getBoxType1());
+                locDto.setBoxType2(orderDetl.getBoxType2());
+                locDto.setBoxType3(orderDetl.getBoxType3());
+                locDto.setLack(Boolean.TRUE);
+                locDtos.add(locDto);
+            }
+        }
+        R pakout = pakout(locDtos);
+        return R.ok().add(pakout);
+    }
+
 }

--
Gitblit v1.9.1