From b7d562f09526fc5d1fddc3a692f47aeb3ac956f6 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期二, 28 四月 2026 04:09:14 +0800
Subject: [PATCH] #退库优化/自动跨巷道移库V1

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

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 16f1d50..33f885e 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -11,6 +11,8 @@
 import com.zy.asrs.entity.param.*;
 import com.zy.asrs.mapper.ReportQueryMapper;
 import com.zy.asrs.service.*;
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.asrs.task.handler.AutoEmptyOutHandler;
 import com.zy.common.model.DetlDto;
 import com.zy.common.web.BaseController;
 import lombok.extern.slf4j.Slf4j;
@@ -50,6 +52,8 @@
     private WaitPakinService waitPakinService;
     @Autowired
     private WrkDetlService wrkDetlService;
+    @Autowired
+    private AutoEmptyOutHandler autoEmptyOutHandler;
 
     @PostMapping("/order/matSync/default/v2")
 //    @AppAuth(memo = "鍟嗗搧淇℃伅鍚屾鎺ュ彛")
@@ -181,6 +185,23 @@
         return R.ok().add(openService.queryStock());
     }
 
+    @PostMapping("/task/autoEmptyOut/run/v1")
+    public synchronized R runAutoEmptyOut(@RequestHeader(required = false) String appkey,
+                                          @RequestParam(required = false) Integer crnNo,
+                                          @RequestParam(required = false) Integer max,
+                                          @RequestParam(required = false) Long userId,
+                                          HttpServletRequest request) {
+        // auth(appkey, null, request);
+        ReturnT<String> res = autoEmptyOutHandler.moveOldestInventory(crnNo, max, userId);
+        if (res == null) {
+            return R.error("鎵ц澶辫触").add(null);
+        }
+        if (res.isSuccess()) {
+            return R.ok().add(res);
+        }
+        return R.error(res.getMsg()).add(res);
+    }
+
     private void auth(String appkey, Object obj, HttpServletRequest request) {
         log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
         request.setAttribute("cache", obj);

--
Gitblit v1.9.1