|  |  | 
 |  |  | 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 * * * * ? ") | 
 |  |  |     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={}]历史档处理失败", wrkMast.getWrkNo()); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  |