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
134
135
136
137
138
139
140
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月17日
 */
@Component("runCokingTraceModelGXJTask")
public class RunCokingTraceModelGXJTask 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 McsApi mcsApi;
 
    @Autowired
    private MdkApi mdkApi;
 
    private final static String process = TraceProcessTypeEnum.GXJ.getProcess();
 
    private final static String reportName = "干熄焦工序异常溯源";
 
    private final static String indType = "干熄焦工序异常溯源";
 
    private final static String SugObj = "GXJ";
 
    private String scheduleCode = "AnSteelCDQTrackImplv3"; //焦化干熄焦产蒸汽模型
    private final String finalResultStrKey = "finalResultStr";
    private final String resultListKey = "resultList";
 
    @Autowired
    private CokingTraceChartService cokingTraceChartService;
 
 
    @Override
    public void run(String params) {
        logger.info("RunCokingTraceModelGXJTask，参数为：{}", 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("RunCokingTraceModelGXJTask运行异常");
            ex.printStackTrace();
        }
        logger.info("RunCokingTraceModelGXJTask运行完成");
 
    }
 
}