From a29aa2ea80eaaea6acff08068a04de47b69478a8 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期五, 19 七月 2024 10:05:19 +0800
Subject: [PATCH] 盘点出入库接口开发

---
 src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java |   26 +++++++++++++++-----------
 1 files changed, 15 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java b/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
index 923b229..cb769d5 100644
--- a/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
@@ -6,15 +6,15 @@
 import com.zy.asrs.service.WrkMastStaService;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.task.handler.OneLouHangJiaHandler;
-import com.zy.asrs.task.handler.RailwayPlatformHandler;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 /**
  * Created by Monkey D. Luffy on 2023.09.17
  * 寰愬伐姹変簯..............浠ヤ笅.............涓婇ザ姹熼摐.............閫�搴撴媶鐮佸灈
  */
+@Slf4j
 @Component
 public class OneLouHangJiaScheduler {
 
@@ -23,19 +23,23 @@
     @Autowired
     private WrkMastStaService wrkMastStaService;
 
-    @Scheduled(cron = "0/3 * * * * ? ")
+//    @Scheduled(cron = "0/3 * * * * ? ")
     private void execute(){//閫�搴撴媶鐮佸灈
 //        int[] staNos =new int[]{118,119};
         int[] staNos =new int[]{118};
         for (int staNo : staNos){
-            WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
-                    .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
-            if (!Cools.isEmpty(wrkMastSta)){
-                break;
-            }
-            ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
-            if (result.getCode()==200){
-                break;
+            try{
+                WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
+                        .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
+                if (!Cools.isEmpty(wrkMastSta)){
+                    break;
+                }
+                ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
+                if (result.getCode()==200){
+                    break;
+                }
+            }catch (Exception e){
+                log.error("閫�搴撴媶鐮佸灈"+staNo+"绔欑偣澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
             }
         }
     }

--
Gitblit v1.9.1