From 501b641ba527cc8b811dc0a343bd59ec8bfd49a0 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期三, 30 七月 2025 15:06:57 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/nc/task/PlanOrderTask.java |   60 ++++++++++++++++++++++++++++++++++--------------------------
 1 files changed, 34 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/zy/nc/task/PlanOrderTask.java b/src/main/java/com/zy/nc/task/PlanOrderTask.java
index f874839..fcbb237 100644
--- a/src/main/java/com/zy/nc/task/PlanOrderTask.java
+++ b/src/main/java/com/zy/nc/task/PlanOrderTask.java
@@ -46,12 +46,19 @@
      */
     @Scheduled(cron = "0/3 * * * * ? ")
     public void execute1() {
-        List<String> ids = storeTypeService.listOwn();
-        List<String> Ids = nccSaleXsfhmxWmsService.selectXsfh(ids);
+        List<String> warehouseIds = storeTypeService.listOwn();
+        List<String> Ids = nccSaleXsfhmxWmsService.selectXsfh(warehouseIds);
         for (String id : Ids) {
-            List<NccSaleXsfhmxWms> wmsFlag = nccSaleXsfhmxWmsService.selectList(new EntityWrapper<NccSaleXsfhmxWms>().eq("vbillcode", id).ne("wms_flag", 1).eq("fstatusflag", 2).eq("hdr", 0).eq("bdr", 0));
+            List<NccSaleXsfhmxWms> wmsFlag = nccSaleXsfhmxWmsService.selectList(new EntityWrapper<NccSaleXsfhmxWms>()
+                    .eq("vbillcode", id)
+                    .ne("wms_flag", 1)
+                    .eq("fstatusflag", 2)
+                    .eq("hdr", 0)
+                    .eq("bdr", 0)
+                    .in("fhckbm",warehouseIds)
+            );
             if (wmsFlag == null || wmsFlag.isEmpty()) {
-                return;
+                continue;
             }
             ReturnT<String> returnT = planOrderHandler.start1(wmsFlag);
             if (!returnT.isSuccess()) {
@@ -84,7 +91,7 @@
         for (String string : strings) {
             List<NccScZkmxbWms> wmsFlag = nccScZkmxbWmsService.selectList(new EntityWrapper<NccScZkmxbWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("dr", 0).eq("bdr", 0));
             if (wmsFlag == null || wmsFlag.isEmpty()) {
-                return;
+                continue;
             }
             ReturnT<String> returnT = planOrderHandler.start2In(wmsFlag);
             if (!returnT.isSuccess()) {
@@ -99,18 +106,19 @@
     }
 
     /**
-     * 杞簱
+     * 杞簱-鍑哄簱
+     * 涓嶅悓姝ワ紝杞簱鍑哄簱鐢盬MS鐩存帴鍙戣捣
      *
      * @return
      */
-    @Scheduled(cron = "0/3 * * * * ? ")
+//    @Scheduled(cron = "0/3 * * * * ? ")
     public void execute2_2() {
         List<String> ids = storeTypeService.listOwn();
         List<String> strings = nccScZkmxbWmsService.selectZkOut(ids);
         for (String string : strings) {
             List<NccScZkmxbWms> wmsFlag = nccScZkmxbWmsService.selectList(new EntityWrapper<NccScZkmxbWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("dr", 0).eq("bdr", 0));
             if (wmsFlag == null || wmsFlag.isEmpty()) {
-                return;
+                continue;
             }
             ReturnT<String> returnT = planOrderHandler.start2Out(wmsFlag);
             if (!returnT.isSuccess()) {
@@ -135,7 +143,7 @@
         for (String string : strings) {
             List<NccCgCgdhdWms> wmsFlag = nccCgCgdhdWmsService.selectList(new EntityWrapper<NccCgCgdhdWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("hdr", 0).eq("bdr", 0));
             if (wmsFlag == null || wmsFlag.isEmpty()) {
-                return;
+                continue;
             }
             ReturnT<String> returnT = planOrderHandler.start3(wmsFlag);
             if (!returnT.isSuccess()) {
@@ -162,7 +170,7 @@
         for (String string : strings) {
             List<NccSaleDbddWms> wmsFlag = nccSaleDbddWmsService.selectList(new EntityWrapper<NccSaleDbddWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("dr", 0).eq("bdr", 0));
             if (wmsFlag == null || wmsFlag.isEmpty()) {
-                return;
+                continue;
             }
             ReturnT<String> returnT = planOrderHandler.start5(wmsFlag);
             if (!returnT.isSuccess()) {
@@ -183,20 +191,20 @@
      *
      * @return
      */
-    @Scheduled(cron = "0/3 * * * * ? ")
-    public void execute4() {
-        List<String> strings = nccCkPddWmsService.selectPdd();
-        for (String string : strings) {
-            List<NccCkPddWms> wmsFlag = nccCkPddWmsService.selectList(new EntityWrapper<NccCkPddWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("FBILLFLAG", 4).eq("hdr", 0).eq("bdr", 0));
-            ReturnT<String> returnT = planOrderHandler.start4(wmsFlag);
-            if (!returnT.isSuccess()) {
-                for (NccCkPddWms wms : wmsFlag) {
-                    wms.setWmsMemo(returnT.getMsg());
-                    wms.setWmsFlag(0);
-                    nccCkPddWmsService.updateById(wms);
-                }
-                log.error(returnT.getMsg());
-            }
-        }
-    }
+//    @Scheduled(cron = "0/3 * * * * ? ")
+//    public void execute4() {
+//        List<String> strings = nccCkPddWmsService.selectPdd();
+//        for (String string : strings) {
+//            List<NccCkPddWms> wmsFlag = nccCkPddWmsService.selectList(new EntityWrapper<NccCkPddWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("FBILLFLAG", 4).eq("hdr", 0).eq("bdr", 0));
+//            ReturnT<String> returnT = planOrderHandler.start4(wmsFlag);
+//            if (!returnT.isSuccess()) {
+//                for (NccCkPddWms wms : wmsFlag) {
+//                    wms.setWmsMemo(returnT.getMsg());
+//                    wms.setWmsFlag(0);
+//                    nccCkPddWmsService.updateById(wms);
+//                }
+//                log.error(returnT.getMsg());
+//            }
+//        }
+//    }
 }

--
Gitblit v1.9.1