From a49cdaa669f18d92e8fef5d84da536c0465670db Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期三, 17 十二月 2025 21:21:07 +0800
Subject: [PATCH] 1.新增组托入库生成AGV搬运任务,执行AGV搬运任务时判断堆垛机接驳站点是否有空料架,有的话需要进行搬离(没有出库任务的情况下) 2.完善配盘出库单agv目标地点,可能是区域也可能是站点 Q为区域;Z为站点 3.完善立库入库找规则方法

---
 src/main/java/com/zy/asrs/controller/OutController.java |  210 +++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 183 insertions(+), 27 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index 4be0c77..5a603ab 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -1,15 +1,13 @@
 package com.zy.asrs.controller;
 
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.annotations.ManagerAuth;
 import com.core.common.BaseRes;
 import com.core.common.Cools;
 import com.core.common.R;
-import com.zy.asrs.entity.BasDevp;
-import com.zy.asrs.entity.LocDetl;
-import com.zy.asrs.entity.OrderDetl;
-import com.zy.asrs.entity.OrderDetlPakout;
+import com.zy.asrs.entity.*;
+import com.zy.asrs.entity.param.EmptyPlateOutParam;
 import com.zy.asrs.service.*;
-import com.zy.asrs.utils.OrderInAndOutUtil;
 import com.zy.common.model.LocDto;
 import com.zy.common.model.TaskDto;
 import com.zy.common.web.BaseController;
@@ -19,6 +17,7 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.annotation.Resource;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -46,6 +45,9 @@
     @Autowired
     private BasDevpService basDevpService;
 
+    @Resource
+    private OrderPakoutService orderPakOutService;
+
 
     @PostMapping("/out/pakout/orderDetlIds/auth")
     @ManagerAuth
@@ -62,33 +64,109 @@
         }
         List<OrderDetlPakout> orderDetlPakouts = orderDetlPakoutService.selectBatchIds(ids);
 
+        if (orderDetlPakouts.size() == 0) {
+            return R.parse("璁㈠崟鏄庣粏涓虹┖");
+        }
+
         List<LocDto> locDtos = new ArrayList<>();
 
         Set<String> exist = new HashSet<>();
 
-        for (OrderDetlPakout orderDetl : orderDetlPakouts) {
-            double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getWorkQty()).orElse(0.0D);
-            if (issued <= 0.0D) { continue; }
-            List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), null, exist);
-            for (LocDetl locDetl : locDetls) {
+        // 鑾峰彇璁㈠崟涓昏〃
+        OrderPakout orderPakOut = orderPakOutService.selectByNo(orderDetlPakouts.get(0).getOrderNo());
+        // 鐩樼偣鍗曞嚭搴�
+        if (orderPakOut.getDocType() == 8) {
+            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(),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(), 107);
+                        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.setStaNos(staNos);
+                        locDtos.add(locDto);
+                        // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
+                        issued = issued - locDetl.getAnfme();
+                    } else {
+                        break;
+                    }
+                }
                 if (issued > 0) {
-                    LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
-                            issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
-                    locDto.setFrozen(locDetl.getFrozen());
-                    List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103);
-                    locDto.setStaNos(staNos);
+                    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);
-                    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.setLack(Boolean.TRUE);
-                locDtos.add(locDto);
+        } else {
+            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);
+                }
             }
         }
         return R.ok().add(locDtos);
@@ -102,13 +180,13 @@
         }
         List<LocDto> locDtoArrayList = new ArrayList<>();
         for (LocDto locDto : locDtos){
-            if (locDto.getFrozen()!=1){
+            if (locDto.getFrozen()!=1 && locDto.getFrozenLoc()!=1){
                 locDtoArrayList.add(locDto);
             }
         }
         locDtos = locDtoArrayList;
         if (Cools.isEmpty(locDtos)) {
-            return R.parse(BaseRes.PARAM);
+            return R.parse("搴撳瓨/搴撲綅琚喕缁擄紝璇峰鐞嗗悗鍑哄簱锛侊紒锛�");
         }
         boolean lack = true;
         for (LocDto locDto : locDtos) {
@@ -136,10 +214,88 @@
                 taskDtos.add(taskDto);
             }
         }
+        OrderPakout orderPakout = orderPakOutService.selectByNo(locDtos.get(0).getOrderNo());
+
+        //閰嶇洏鍑哄簱鍗曠敤锛� i=5鏃舵垨鑰呭嚭搴撳埌鏈�鍚庢椂涓嬪彂绌烘澘鍑哄簱浠诲姟
+        int i = 0;
+        //闇�瑕佸嚭搴撶殑鎵樼洏鏁伴噺
+        int size = taskDtos.size();
+        //浼樺厛绾�
+        int ioPri = 50;
+        //宸蹭笅绌烘澘鍑哄簱浠诲姟鏁伴噺
+        int j=1;
         // -----------------------------------------------------------------------------------------------
         for (TaskDto taskDto : taskDtos) {
             BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
-            workService.stockOut(staNo, taskDto, getUserId());
+            workService.stockOut(staNo, taskDto, getUserId(),ioPri);
+            ioPri--;
+            i++;
+            //閰嶇洏鍑哄簱鍗曚娇鐢紝涓嬪彂闇�瑕佸嚭鐨勭┖鏉夸换鍔�
+            if (orderPakout.getDocType() == 11) {
+                if (i==size){
+                    for (;j<=orderPakout.getPayType();j++){
+                        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"));
+                        }else {
+                            locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
+                                    .eq("loc_sts", "D").like("barcode", bar));
+                        }
+
+                        if (Cools.isEmpty(locMast)) {
+                            return R.error("搴撳瓨娌℃湁绌烘澘");
+                        }
+                        String locNo = locMast.getLocNo();
+                        EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
+                        emptyPlateOutParam.setOutSite(303);
+                        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--;
+
+                    }
+                }else if(i == 4){
+                    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(locMast)) {
+                        return R.error("搴撳瓨娌℃湁绌烘澘");
+                    }
+                    String locNo = locMast.getLocNo();
+                    EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
+                    emptyPlateOutParam.setOutSite(303);
+                    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--;
+                }
+            }
         }
         return R.ok();
     }

--
Gitblit v1.9.1