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
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 org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
import java.util.Calendar;
import java.util.Date;
import java.util.Objects;
 
/**
 * 化产工序异常溯源
 *
 * @author lirm
 * @Description
 * @createTime 2025年04月22日
 */
@Component("runCokingTraceModelHCTask")
public class RunCokingTraceModelHCTask 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;
 
    @Autowired
    private MdkApi mdkApi;
 
    private final static String process = TraceProcessTypeEnum.HC.getProcess();
 
    private final static String reportName = "化产工序异常溯源";
 
    private final static String SugObj = "HC";
 
    private final static String indType = "化产工序异常溯源";
 
    private final static String row = "chemProdRow";
 
    private final static String total = "chemProdTotal";
 
    private static final String jsonStr = "{\n" +
            "\"result\":{\n" +
            "\"chemProdHomePage\":[1782.7,0.8]," +
            "\"chemProdElec\":[794680.52]," +
            "\"chemProdIndex\":[16.3,2.57,0.017,0.745,658731.5]," +
            "\"chemProdRow0\":[[0.0,42.3],[5.0,1342.5],[10.0,122.5]]," +
            "\"chemProdRow1\":[[0.0,42.3],[7.0,12.5],[9.0,17.45]]," +
            "\"chemProdRow2\":[[0.0,42.3],[12.0,23.5],[35.0,54.33]]," +
            "\"chemProdSteam\":[46.3]," +
            "\"chemProdTotal\":\"蒸汽消耗量异常，经模型计算，原因和调整建议如下：电捕绝缘箱温度异常，当前值190，建议调整电捕绝缘箱温度至区间[80,110], 蒸氨塔塔顶温度异常，当前值190，建议调整蒸氨塔塔顶温度至区间[101,103]\"," +
            "\"chemProdHomeIndexInfo\":\"化产蒸汽消耗量异常\""+
            " }" +
            "}";
 
    @Override
    public void run(String params) {
        logger.info("RunCokingTraceModelHCTask，参数为：{}", 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);
 
            // 调用模型
            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));
 
            if (Objects.isNull(result)) {
                logger.info("模型结果为空");
                return;
            }
 
            // 保存报告
            String analyDate = DateUtils.format(startDate);
            String analyContent = clock + " " + result.getString("chemProdHomeIndexInfo");
            String relId = cokingTraceReportService.save(process, reportName, analyDate, clock, analyContent);
 
            // 保存一级分析指标
            cokingAnalyIndService.saveAnalyInd(relId, process, analyDate, analyContent);
 
            // 保存优化建议
            cokingTraceSuggestService.saveTraceSuggest(relId, process, clock, total, SugObj);
 
            // 保存偏差值
            cokingTraceDeviationService.saveTraceDeviation(relId, process, clock, result, CommonConstant.COKE_INDEX_CHARTCODE, row, SugObj);
 
            // 保存溯源指标
            cokingTraceIndService.saveTraceInd(relId, indType, clock);
 
            // 保存溯源折线图
            cokingTraceChartService.save(relId, clock, indType, startDate, endDate);
 
        } catch (Exception ex) {
            logger.error("RunCokingTraceModelHCTask运行异常");
            ex.printStackTrace();
        }
        logger.info("RunCokingTraceModelHCTask运行完成");
    }
}