Jay
9 天以前 c350c9634dcc07db6a805d4cbc1bfea2677e61a1
提交 | 用户 | 时间
1c9291 1 package com.iailab.module.model.job.task;
L 2
3 import com.iailab.module.model.common.utils.DateUtils;
4 import com.iailab.module.model.mcs.sche.service.StScheduleRecordDetailService;
5 import com.iailab.module.model.mcs.sche.service.StScheduleRecordService;
6 import org.apache.commons.lang3.StringUtils;
7 import org.slf4j.Logger;
8 import org.slf4j.LoggerFactory;
9 import org.springframework.beans.factory.annotation.Autowired;
10 import org.springframework.stereotype.Component;
11
12 import java.util.Date;
13 import java.util.Map;
14
15 /**
16  * 清理调度记录表
17  *
18  * @author lirm
19  * @Description
20  * @createTime 2025年02月05日
21  */
22 @Component("cleanScheduleRecordTask")
23 public class CleanScheduleRecordTask implements ITask {
24     private Logger logger = LoggerFactory.getLogger(getClass());
25
26
27     @Autowired
28     private StScheduleRecordService stScheduleRecordService;
29
30     @Autowired
31     private StScheduleRecordDetailService stScheduleRecordDetailService;
32
33     @Override
34     public void run(String params) {
35         logger.info("CleanScheduleRecordTask定时任务正在执行,参数为:{}",params );
36         try {
37             int days = -40;
38             if (StringUtils.isNotBlank(params)) {
39                 days = Math.abs(Integer.parseInt(params)) * -1;
40             }
41             Map<String, Date> tMap = DateUtils.getIntervalDate(days);
42             stScheduleRecordService.cleanScheduleRecord(tMap);
43             stScheduleRecordDetailService.cleanScheduleRecordDetail(tMap);
44         } catch (Exception ex) {
45             logger.error("CleanScheduleRecordTask运行异常");
46             ex.printStackTrace();
47         }
48         logger.info("CleanScheduleRecordTask运行完成");
49     }
50 }