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