From 5dc8a9f9aba3310fd21cad9509635bb7ec2f007f Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期四, 12 十二月 2024 13:29:06 +0800 Subject: [PATCH] Generating... --- src/main/java/com/zy/asrs/task/WorkLogScheduler.java | 26 +++++++++++++++++++------- 1 files changed, 19 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java b/src/main/java/com/zy/asrs/task/WorkLogScheduler.java index ac0033c..c1fbf1e 100644 --- a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java +++ b/src/main/java/com/zy/asrs/task/WorkLogScheduler.java @@ -1,28 +1,40 @@ package com.zy.asrs.task; +import com.zy.asrs.entity.WrkMast; +import com.zy.asrs.service.WrkMastService; +import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.WorkLogHandler; -import com.zy.system.entity.Config; -import com.zy.system.service.ConfigService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import java.util.List; + /** * Created by vincent on 2020/7/7 */ +@Slf4j @Component public class WorkLogScheduler { @Autowired private WorkLogHandler workLogHandler; @Autowired - private ConfigService configService; + private WrkMastService wrkMastService; - @Scheduled(cron = "0/3 * * * * ? ") + //@Scheduled(cron = "0/1 * * * * ? ") + @Scheduled(fixedDelay = 60000) private void execute(){ - ReturnT<Config> result = workLogHandler.start(); - if (!result.isSuccess()) { - configService.insert(result.getContent()); + List<WrkMast> wrkMasts = wrkMastService.selectToBeHistoryData(); + if (wrkMasts.isEmpty()) { + return; + } + for (WrkMast wrkMast : wrkMasts) { + ReturnT<String> result = workLogHandler.start(wrkMast); + if (!result.isSuccess()) { + log.error("宸ヤ綔妗workNo={}]鍘嗗彶妗e鐞嗗け璐�", wrkMast.getWrkNo()); + } } } -- Gitblit v1.9.1