From 44e60ad34936374153468bce802d2f2f52feb983 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 17 十月 2022 15:45:48 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/OutController.java |   21 +++++++++++++++++----
 1 files changed, 17 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java
index b625d86..0eda27d 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -8,13 +8,12 @@
 import com.zy.asrs.service.*;
 import com.zy.common.model.LocDto;
 import com.zy.common.model.OrderDto;
+import com.zy.common.model.OrderMergeVo;
 import com.zy.common.model.TaskDto;
 import com.zy.common.web.BaseController;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -88,6 +87,7 @@
 
     @PostMapping("/out/pakout/auth")
     @ManagerAuth(memo = "璁㈠崟鍑哄簱")
+    @Transactional
     public synchronized R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException {
         if (Cools.isEmpty(locDtos)) {
             return R.parse(BaseRes.PARAM);
@@ -149,11 +149,24 @@
             }
         }
         // -----------------------------------------------------------------------------------------------
+        List<String> excludeLocNos = taskDtos.stream().map(TaskDto::getLocNo).distinct().collect(Collectors.toList());
         for (TaskDto taskDto : taskDtos) {
             BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
             workService.stockOut(staNo, taskDto, getUserId());
+            locMastService.breakUp(taskDto.getLocNo(), excludeLocNos);
         }
         return R.ok();
     }
 
+
+    /**
+     * 鍚堝苟璁㈠崟姹囨�婚瑙�
+     */
+    @RequestMapping(value = "/order/merge/preview/auth")
+    @ManagerAuth
+    public R mergePreview(@RequestParam(value = "orderIds[]") List<Long> orderIds){
+        OrderMergeVo merge = orderService.mergePreview(orderIds);
+        return R.ok().add(merge);
+    }
+
 }

--
Gitblit v1.9.1