From 7ff441cde857c41ae9908100de9c469ed5ab76be Mon Sep 17 00:00:00 2001
From: zc <zc>
Date: 星期一, 29 七月 2024 19:11:56 +0800
Subject: [PATCH] 视图sql

---
 src/main/java/com/zy/asrs/controller/OutController.java |   54 +++++++++++++++++++++++++++---------------------------
 1 files changed, 27 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 abfc36d..671d359 100644
--- a/src/main/java/com/zy/asrs/controller/OutController.java
+++ b/src/main/java/com/zy/asrs/controller/OutController.java
@@ -1,6 +1,5 @@
 package com.zy.asrs.controller;
 
-import com.alibaba.fastjson.JSON;
 import com.core.annotations.ManagerAuth;
 import com.core.common.BaseRes;
 import com.core.common.Cools;
@@ -8,18 +7,18 @@
 import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.LocDetl;
 import com.zy.asrs.entity.OrderDetl;
-import com.zy.asrs.entity.result.StoPreTab;
 import com.zy.asrs.service.*;
-import com.zy.common.model.DetlDto;
 import com.zy.common.model.LocDto;
 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 java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * Created by vincent on 2022/3/26
@@ -43,6 +42,14 @@
     @Autowired
     private BasDevpService basDevpService;
 
+
+    @PostMapping("/out/pakout/orderDetlIds/auth")
+    @ManagerAuth
+    public R pakoutOrderDetlIds(@RequestParam Long orderId) throws InterruptedException {
+        Thread.sleep(200);
+        return R.ok().add(orderDetlService.selectByOrderId(orderId).stream().map(OrderDetl::getId).distinct().collect(Collectors.toList()));
+    }
+
     @PostMapping("/out/pakout/preview/auth")
     @ManagerAuth
     public R pakoutPreview(@RequestBody List<Long> ids) {
@@ -50,27 +57,17 @@
             return R.parse(BaseRes.PARAM);
         }
         List<OrderDetl> orderDetls = orderDetlService.selectBatchIds(ids);
+        //鐢ㄦ埛纭鍑哄叆搴撻兘浠gno涓哄噯锛岄偅涔堜笉鑰冭檻鏁伴噺浜�
         List<LocDto> locDtos = new ArrayList<>();
-        for (OrderDetl orderDetl : orderDetls) {
-            double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D);
-            if (issued <= 0.0D) { continue; }
-            List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), null);
+        if (orderDetls != null && !orderDetls.isEmpty()) {
+            List<LocDetl> locDetls = locDetlService.queryStock(orderDetls.get(0).getSPgNO());
             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);
-                    List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103);
-                    locDto.setStaNos(staNos);
-                    locDtos.add(locDto);
-                    // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
-                    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);
+                LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetls.get(0).getOrderNo(),
+                        locDetl.getAnfme());
+                List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), 101);
+                locDto.setStaNos(staNos);
+                locDto.setZpallet(locDetl.getZpallet());
+                locDto.setSPgNO(orderDetls.get(0).getSPgNO());
                 locDtos.add(locDto);
             }
         }
@@ -83,22 +80,25 @@
         if (Cools.isEmpty(locDtos)) {
             return R.parse(BaseRes.PARAM);
         }
-        boolean refuse = true;
+        boolean lack = true;
         for (LocDto locDto : locDtos) {
             if (!locDto.isLack()) {
-                refuse = !refuse;
+                lack = false;
+                break;
             }
         }
-        if (refuse) {
+        if (lack) {
             return R.error("搴撳瓨涓嶈冻");
         }
 
-        Thread.sleep(500L);
+        Thread.sleep(1000L);
 
         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);

--
Gitblit v1.9.1