1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package com.iailab.module.ansteel.job.task;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.module.ansteel.coking.service.*;
import com.iailab.module.ansteel.common.constant.CommonConstant;
import com.iailab.module.ansteel.common.enums.TraceProcessTypeEnum;
import com.iailab.module.model.api.mcs.McsApi;
import com.iailab.module.model.api.mdk.MdkApi;
import com.iailab.module.model.api.mdk.dto.StScheduleRecordVO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
 
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Objects;
 
/**
 * 炼焦工序-异常溯源
 *
 * @author lirm
 * @Description
 * @createTime 2025年04月21日
 */
@Component("runCokingTraceModelLJTask")
public class RunCokingTraceModelLJTask implements ITask {
    private Logger logger = LoggerFactory.getLogger(getClass());
 
    @Autowired
    private CokingTraceReportService cokingTraceReportService;
 
    @Autowired
    private CokingTraceSuggestService cokingTraceSuggestService;
 
    @Autowired
    private CokingTraceDeviationService cokingTraceDeviationService;
 
    @Autowired
    private CokingAnalyIndService cokingAnalyIndService;
 
    @Autowired
    private CokingTraceIndService cokingTraceIndService;
 
    @Autowired
    private CokingTraceChartService cokingTraceChartService;
 
    @Autowired
    private McsApi mcsApi;
 
    private final static String process = TraceProcessTypeEnum.LJ.getProcess();
 
    private final static String reportName = "炼焦工序异常溯源";
 
    private final static String SugObj = "LJ";
 
    private final static String indType = "炼焦工序异常溯源";
 
    private String scheduleCode = "lianjiaoguankong"; //焦化炼焦管控模型
    private final String finalResultStrKey = "finalResultStr";
    private final String resultListKey = "resultList";
 
    @Override
    public void run(String params) {
        logger.info("RunCokingTraceModelLJTask，参数为：{}", params);
        try {
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.MILLISECOND, 0);
            calendar.set(Calendar.SECOND, 0);
            calendar.set(Calendar.MINUTE, 0);
 
            calendar.set(Calendar.HOUR_OF_DAY, 0);
            Date endDate = calendar.getTime();
            calendar.add(Calendar.DAY_OF_YEAR, -1);
            Date startDate = calendar.getTime();
            String clock = DateUtils.format(startDate);
 
            calendar.add(Calendar.DAY_OF_YEAR, 1);
            calendar.add(Calendar.MINUTE, -3);
            Date collectStartDate = calendar.getTime();
 
            // 查询模型结果
            List<StScheduleRecordVO> lastScheduleData = mcsApi.getLastScheduleData(scheduleCode, 1);
            if (CollectionUtils.isEmpty(lastScheduleData)) {
                logger.info("模型结果为空");
                return;
            }
            StScheduleRecordVO stScheduleRecordVO = lastScheduleData.get(0);
            if (stScheduleRecordVO == null) {
                logger.info("模型结果为空");
                return;
            }
            String jsonStr = stScheduleRecordVO.getResultData();
 
            JSONObject result = JSONObject.parseObject(jsonStr);
            if (Objects.isNull(result)) {
                logger.info("模型结果为空");
                return;
            }
 
            // 保存报告
            String analyDate = DateUtils.format(startDate);
            String analyContent = "炼焦异常";
            String relId = cokingTraceReportService.save(process, reportName, analyDate, clock, analyContent);
 
            // 保存一级分析指标
            cokingAnalyIndService.saveAnalyInd(relId, process, analyDate, analyContent);
 
            // 保存优化建议
            String suggest = result.getString(finalResultStrKey);
            cokingTraceSuggestService.saveTraceSuggest(relId, process, clock, suggest, SugObj);
 
            // 保存偏差值
            String jsonString = result.getString(resultListKey);
            cokingTraceDeviationService.saveTraceDeviation(relId, process, clock, jsonString, SugObj);
 
            // 保存溯源指标
            cokingTraceIndService.saveTraceInd(relId, indType, clock, collectStartDate, endDate);
 
            // 保存溯源折线图
            cokingTraceChartService.save(relId, clock, indType, startDate, endDate);
 
        } catch (Exception ex) {
            logger.error("RunCokingTraceModelLJTask运行异常");
            ex.printStackTrace();
        }
        logger.info("RunCokingTraceModelLJTask运行完成");
    }
}