From ce4a6c80a379cd46acd59c8aff9212ad8d399825 Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期三, 12 六月 2024 13:53:22 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   76 ++++++++++++++++++++++++++++++++++++++
 src/main/java/com/zy/asrs/controller/OutController.java        |    8 ---
 src/main/java/com/zy/asrs/service/AgvWorkService.java          |    5 ++
 3 files changed, 82 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index 4eb5846..8628b88 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -205,14 +205,8 @@
         generateTaskDto(locDtos,taskDtos,agvTaskDtos);
 
         //鐢熸垚AGV鍑哄簱浠诲姟
-        agvWorkService.stockOutWrkMast(agvTaskDtos, getUserId());
+        agvWorkService.processOut(agvTaskDtos, getUserId());
 
-        // 鐢熸垚鍑哄簱浠诲姟
-        taskDtos.stream().map(TaskDto::getLocNo).distinct().collect(Collectors.toList());
-        for (TaskDto taskDto : taskDtos) {
-            BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
-            workService.stockOut(staNo, taskDto, getUserId());
-        }
         return R.ok();
     }
 
diff --git a/src/main/java/com/zy/asrs/service/AgvWorkService.java b/src/main/java/com/zy/asrs/service/AgvWorkService.java
index 8e8493e..190b1df 100644
--- a/src/main/java/com/zy/asrs/service/AgvWorkService.java
+++ b/src/main/java/com/zy/asrs/service/AgvWorkService.java
@@ -22,6 +22,11 @@
     void stockOutWrkMast(List<TaskDto> agvTaskDtos, Long userId);
 
     /*
+    鐢熸垚鍑哄簱浠诲姟
+     */
+    void processOut(List<TaskDto> agvTaskDtos, Long userId);
+
+    /*
     鐢熸垚鎷f枡鍏ュ簱浠诲姟
      */
     void pickIn(List<AgvWrkMast> agvWrkMastList);
diff --git a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
index 86ab33d..8d6e68a 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -186,6 +186,80 @@
         });
     }
 
+    /*
+    鍔犲伐鍑哄簱
+     */
+    @Transactional
+    public void processOut(List<TaskDto> agvTaskDtos, Long userId) {
+        Date now = new Date();
+
+        agvTaskDtos.forEach(taskDto -> {
+
+            List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectByTaskDto(taskDto);
+
+            //AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", taskDto.getLocNo()));
+
+            //宸ヤ綔妗f墍闇�鍙傛暟
+
+            long wrkSts = 21L;
+            String sourceLocNo = taskDto.getLocNo();
+            String targetLocNo = taskDto.getAgvStaNo();
+            //String barcode = agvLocDetls.get(0).getSuppCode();
+            String containerCode = taskDto.getLocDtos().get(0).getContainerCode();
+
+
+            //鍒ゆ柇鏄惁鍏ㄦ澘鍑哄簱
+            int ioType = 107;
+            //鐢熸垚宸ヤ綔妗�
+            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,containerCode,now,userId,Short.valueOf(containerCode.substring(0,2)));
+            //鐢熸垚宸ヤ綔妗f槑缁�
+            taskDto.getLocDtos().forEach(locDto -> {
+                if (!BaseController.isJSON(locDto.getOrderNo())) {
+                    //鏄庣粏妗f墍闇�鍙傛暟
+                    createWrkDetlReWrite(locDto.getMatnr(),
+                            wrkMast.getWrkNo(),
+                            locDto.getOrderNo(),
+                            locDto.getBatch(),
+                            locDto.getAnfme(),
+                            locDto.getContainerCode(),
+                            now,
+                            userId,
+                            locDto.getCsocode(),
+                            locDto.getIsoseq(),
+                            locDto.getProcessSts());
+                }else {
+                    List<OrderDto> orderDtoList = JSON.parseArray(locDto.getOrderNo(), OrderDto.class);
+                    orderDtoList.forEach(orderDto -> {
+                        //鏄庣粏妗f墍闇�鍙傛暟
+                        createWrkDetlReWrite(locDto.getMatnr(),
+                                wrkMast.getWrkNo(),
+                                orderDto.getOrderNo(),
+                                locDto.getBatch(),
+                                orderDto.getAnfme(),
+                                locDto.getContainerCode(),
+                                now,
+                                userId,
+                                locDto.getCsocode(),
+                                locDto.getIsoseq(),
+                                locDto.getProcessSts());
+                    });
+                }
+
+                //淇敼璁㈠崟淇℃伅
+                modifyOrderDetl(locDto, userId);
+            });
+//            //淇敼璁㈠崟淇℃伅
+//            modifyOrderDetl(taskDto.getLocDtos().get(0), userId);
+            //鏇存柊婧愮珯鐐逛俊鎭�
+            String locSts = "R";
+            updateAgvLocMast(agvLocMastService.selectById(sourceLocNo),locSts);
+            //鏇存柊鐩爣绔欑偣鐘舵��
+            //locSts = ioType == 101 ? "S" : "Q";
+            updateAgvBasDevp(agvBasDevpService.selectById(targetLocNo),"S");
+
+        });
+    }
+
     //鎷f枡鍏ュ簱
     @Transactional
     public void pickIn(List<AgvWrkMast> agvWrkMastList){
@@ -365,6 +439,8 @@
             locType = 4;
         } else if (containerType == 20 && agvBasDevp.getFloor() == 3) {
             locType = 2;
+        } else if (containerType == 30) {
+            locType = 3;
         } else {
             locType = agvBasDevp.getLocType1();
         }

--
Gitblit v1.9.1