From 797fce4ad48f7b70dc08766068b64f35ee9d4775 Mon Sep 17 00:00:00 2001
From: zc <zc>
Date: 星期五, 01 十一月 2024 14:31:18 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/xgmFlasrs2' into xgmFlasrs2

---
 src/main/java/com/zy/third/erp/task/ERPOutHedTBScheduler.java |    2 ++
 src/main/java/com/zy/common/config/ThreadPoolConfig.java      |    1 +
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java   |   28 ++++++++++++++++++++++++----
 src/main/resources/application.yml                            |    2 +-
 4 files changed, 28 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index be5810c..ce9114e 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -214,6 +214,24 @@
 
         // 鑾峰彇鍗曟嵁
         Order order = orderService.selectByNo(orderNo);
+        if (order == null) {
+            int i = 30;
+            while (i >= 0) {
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+                order = orderService.selectByNo(orderNo);
+                if (order != null) {
+                    break;
+                }
+                i--;
+            }
+        }
+        if (order == null) {
+            return R.parse("鍗曟嵁涓嶅瓨鍦細" + orderNo);
+        }
         // 鑾峰彇鍗曟嵁鏄庣粏
         List<OrderDetl> orderDetlList = orderDetlService.selectByOrderId(order.getId());
 
@@ -287,6 +305,8 @@
         }
         return R.ok("鍑哄簱鎴愬姛");
     }
+
+
 
     @Override
     @Transactional
@@ -679,12 +699,12 @@
     @Override
     @Transactional
     public void syncMat(MatSyncParam param) {
-        if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <=0 ) {
+        if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <= 0) {
             throw new CoolException("鍟嗗搧鏁版嵁涓虹┖");
         }
 
-        for(MatSyncParam.MatParam matParam : param.getMatDetails()){
-            if(Cools.isEmpty(matParam.getMatnr())){
+        for (MatSyncParam.MatParam matParam : param.getMatDetails()) {
+            if (Cools.isEmpty(matParam.getMatnr())) {
                 throw new CoolException("鍟嗗搧缂栫爜涓嶈兘涓虹┖");
             }
 
@@ -777,7 +797,7 @@
                 }
             } else {
                 mat.sync(param);
-                if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
+                if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr", matParam.getMatnr()))) {
                     throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳");
                 }
             }
diff --git a/src/main/java/com/zy/common/config/ThreadPoolConfig.java b/src/main/java/com/zy/common/config/ThreadPoolConfig.java
index 1b21b47..7ae1132 100644
--- a/src/main/java/com/zy/common/config/ThreadPoolConfig.java
+++ b/src/main/java/com/zy/common/config/ThreadPoolConfig.java
@@ -33,4 +33,5 @@
         return executor;
     }
 
+
 }
diff --git a/src/main/java/com/zy/third/erp/task/ERPOutHedTBScheduler.java b/src/main/java/com/zy/third/erp/task/ERPOutHedTBScheduler.java
index e77f1fb..84fdaa0 100644
--- a/src/main/java/com/zy/third/erp/task/ERPOutHedTBScheduler.java
+++ b/src/main/java/com/zy/third/erp/task/ERPOutHedTBScheduler.java
@@ -7,6 +7,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
@@ -36,6 +37,7 @@
 
     //@Transactional(rollbackFor = Throwable.class)
     @Scheduled(cron = "${erp.refreshtime}")
+    @Async("orderThreadPool")
     public void OutHedTBScheduler() {
         //log.info("OutHedTBScheduler寮�濮嬩簡");
         if (!erpEnabled) return;
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 9912f44..41805fa 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -106,7 +106,7 @@
   enabled: true
   #enabled: false
   #鏌ョ湅ERP涓棿琛ㄩ棿闅�
-  refreshtime: 0 0/1 * * * ?
+  refreshtime: 0/5 * * * * ?
   db:
     driver_class_name: com.microsoft.sqlserver.jdbc.SQLServerDriver
     url: jdbc:sqlserver://192.168.1.147:1800;databasename=XDLinkLK

--
Gitblit v1.9.1