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

---
 src/main/java/com/zy/asrs/entity/LocCache.java          |    1 +
 src/main/java/com/zy/asrs/entity/Mat.java               |    6 ++++++
 src/main/java/com/zy/asrs/controller/OutController.java |   35 +++++++++++++++++++++++------------
 3 files changed, 30 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index 6877bfc..945501c 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -88,7 +88,7 @@
 
         List<LocDto> locDtos = new ArrayList<>();
 
-        Set<String> exist = new HashSet<>();        
+        Set<String> exist = new HashSet<>();
 
         // 鑾峰彇璁㈠崟涓昏〃
         OrderPakout orderPakOut = orderPakOutService.selectByNo(orderDetlPakouts.get(0).getOrderNo());
@@ -117,6 +117,7 @@
                         List<String> collect = basStations.stream().map(BasStation::getDevNo).collect(Collectors.toList());
                         locDto.setAgvStaNos(collect);
                         locDto.setBrand(orderDetl.getBrand());
+                        locDto.setSuppCode(orderDetl.getSuppCode());
 
                         locDto.setStandby1(orderDetl.getStandby1());
                         locDto.setStandby2(orderDetl.getStandby2());
@@ -194,7 +195,7 @@
                         locDto.setBoxType2(orderDetl.getBoxType2());
                         locDto.setBoxType3(orderDetl.getBoxType3());
                         locDtos.add(locDto);
-                        
+
                         locDetlUsage.put(detlId, used + currentIssue);
                         // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
                         issued = issued - currentIssue;
@@ -361,8 +362,8 @@
         for (LocDto locDto : locDtos) {
             if (locDto.isLack()) { continue; }
             TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getAgvStaNo(), locDto);
-            if (TaskDto.has(taskDtos, taskDto)) {
-                TaskDto dto = TaskDto.find(taskDtos, taskDto);
+            if (TaskDto.hasAgv(taskDtos, taskDto)) {
+                TaskDto dto = TaskDto.findAgv(taskDtos, taskDto);
                 assert dto != null;
                 dto.getLocDtos().addAll(taskDto.getLocDtos());
             } else {
@@ -370,14 +371,24 @@
             }
         }
         // -----------------------------------------------------------------------------------------------
-        for (TaskDto taskDto : taskDtos) {
-//            BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
-            BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>()
-                    .in("loc_sts", Arrays.asList(LocStsType.LOC_STS_TYPE_O.type, LocStsType.LOC_STS_TYPE_O.type))
-                    .eq("dev_no", taskDto.getAgvStaNo()));
-            if (Objects.isNull(station)) { throw new CoolException("鏁版嵁閿欒锛岀珯鐐逛笉瀛樺湪鎴栧凡浣跨敤锛侊紒"); }
-            workService.agvStockOut(station, taskDto, getUserId());
-        }
+        Map<String, List<TaskDto>> listMap = taskDtos.stream().collect(Collectors.groupingBy(TaskDto::getLocNo));
+        listMap.keySet().forEach(locNo -> {
+            listMap.get(locNo).forEach(taskDto -> {
+                BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>()
+                        .in("loc_sts", Arrays.asList(LocStsType.LOC_STS_TYPE_O.type, LocStsType.LOC_STS_TYPE_O.type))
+                        .eq("dev_no", taskDto.getAgvStaNo()));
+                if (Objects.isNull(station)) { throw new CoolException("鏁版嵁閿欒锛岀珯鐐逛笉瀛樺湪鎴栧凡浣跨敤锛侊紒"); }
+                workService.agvStockOut(station, taskDto, getUserId());
+            });
+        });
+//        for (TaskDto taskDto : taskDtos) {
+////            BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
+//            BasStation station = basStationService.selectOne(new EntityWrapper<BasStation>()
+//                    .in("loc_sts", Arrays.asList(LocStsType.LOC_STS_TYPE_O.type, LocStsType.LOC_STS_TYPE_O.type))
+//                    .eq("dev_no", taskDto.getAgvStaNo()));
+//            if (Objects.isNull(station)) { throw new CoolException("鏁版嵁閿欒锛岀珯鐐逛笉瀛樺湪鎴栧凡浣跨敤锛侊紒"); }
+//            workService.agvStockOut(station, taskDto, getUserId());
+//        }
         return R.ok();
     }
 
diff --git a/src/main/java/com/zy/asrs/entity/LocCache.java b/src/main/java/com/zy/asrs/entity/LocCache.java
index 3309548..50a818a 100644
--- a/src/main/java/com/zy/asrs/entity/LocCache.java
+++ b/src/main/java/com/zy/asrs/entity/LocCache.java
@@ -35,6 +35,7 @@
      */
     @ApiModelProperty(value= "搴撲綅鍙�")
     @TableField("loc_no")
+//    @TableField(exist = false)  // 鏇存柊鏃跺拷鐣ヨ瀛楁
     private String locNo;
 
     /**
diff --git a/src/main/java/com/zy/asrs/entity/Mat.java b/src/main/java/com/zy/asrs/entity/Mat.java
index c8a2d7b..234d4b7 100644
--- a/src/main/java/com/zy/asrs/entity/Mat.java
+++ b/src/main/java/com/zy/asrs/entity/Mat.java
@@ -339,6 +339,12 @@
     @TableField("store_max_date")
     private Integer storeMaxDate;
 
+    /**
+     * 鍑哄簱浼樺厛绾�
+     */
+    @TableField("group_proty")
+    private Integer groupProty;
+
     public Mat() {}
 
     public Mat(String uuid,Long tagId,String matnr,String maktx,String name,String specs,String model,String color,String brand,String unit,Double price,String sku,Double units,String barcode,String origin,String manu,String manuDate,String itemNum,Double safeQty,Double weight,Double manLength,Double volume,String threeCode,String supp,String suppCode,Integer beBatch,String deadTime,Integer deadWarn,Integer source,Integer inspect,Integer danger,Integer status,Long createBy,Date createTime,Long updateBy,Date updateTime,String memo) {

--
Gitblit v1.9.1