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
141
142
143
144
145
146
147
148
149
150
151
package com.iailab.module.ansteel.job.task;
 
import com.iailab.module.model.api.mcs.McsApi;
import com.iailab.module.model.api.mcs.dto.ScheduleSuggestRespDTO;
import com.iailab.module.model.api.mdk.MdkApi;
import com.iailab.module.model.api.mdk.dto.MdkScheduleReqDTO;
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
import org.apache.commons.lang3.StringUtils;
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.Map;
 
/**
 * 执行调度方案定时任务
 */
@Component("runScheduleModuleTask")
public class RunScheduleModuleTask implements ITask {
    private Logger logger = LoggerFactory.getLogger(getClass());
    private String GasCode = "AnSteelGasSchedule"; //日平衡
    private String LdgCode = "AnSteelldgstrategy"; //转炉实时调度
    private String CogCode = "AnSteelcogstrategy"; //焦炉实时调度
    private String BfgCode = "AnSteelbfgstrategy"; //高炉实时调度
 
    @Autowired
    private MdkApi mdkApi;
    @Autowired
    private McsApi mcsApi;
 
 
    @Override
    public void run(String params) {
        logger.info("runScheduleModuleTask定时任务正在执行，参数为：{}", params);
        try {
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.SECOND, 0);
            calendar.set(Calendar.MILLISECOND, 0);
 
            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
            dto.setScheduleTime(calendar.getTime());
            dto.setScheduleCode(params);
            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
            logger.info("调度方案结果开始下发");
            if (mdkApi.scheduleModelOut(mdkScheduleRespDTO)) {
                logger.info("调度方案结果下发成功");
            } else {
                logger.error("调度方案结果下发失败");
            }
 
 
            //日平衡调度建议保存
            Object time8 =  mdkScheduleRespDTO.getResult().get("Time8");
            Object time16 = mdkScheduleRespDTO.getResult().get("Time16");
            Object time24 =  mdkScheduleRespDTO.getResult().get("Time24");
            if (GasCode.equals(params)) {
                if(time8!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(time8.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + time8 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                }
                if(time16!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(time16.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + time16 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                }
                if(time24!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(time24.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + time24 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                }
            }
            //转炉实时调度建议保存
            Object LDG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (LdgCode.equals(params) && LDG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("转炉实时调度建议");
                suggestDto.setContent(LDG.toString());
                suggestDto.setScheduleObj("LDG");
                suggestDto.setScheduleTime(dto.getScheduleTime());
                suggestDto.setCreateTime(calendar.getTime());
                if (mcsApi.createScheduleSuggest(suggestDto)) {
                    logger.info("转炉实时调度建议{" + LDG + "}保存成功");
                } else {
                    logger.error("转炉实时调度建议保存失败");
                }
            }
            //焦炉实时调度建议保存
            Object COG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (CogCode.equals(params) && COG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("焦炉实时调度建议");
                suggestDto.setContent(COG.toString());
                suggestDto.setScheduleObj("COG");
                suggestDto.setScheduleTime(dto.getScheduleTime());
                suggestDto.setCreateTime(calendar.getTime());
                if (mcsApi.createScheduleSuggest(suggestDto)) {
                    logger.info("焦炉实时调度建议{" + COG + "}保存成功");
                } else {
                    logger.error("焦炉实时调度建议保存失败");
                }
            }
            //高炉实时调度建议保存
            Object BFG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (BfgCode.equals(params) && BFG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("高炉实时调度建议");
                suggestDto.setContent(BFG.toString());
                suggestDto.setScheduleObj("BFG");
                suggestDto.setScheduleTime(dto.getScheduleTime());
                suggestDto.setCreateTime(calendar.getTime());
                if (mcsApi.createScheduleSuggest(suggestDto)) {
                    logger.info("高炉实时调度建议{" + BFG + "}保存成功");
                } else {
                    logger.error("高炉实时调度建议保存失败");
                }
            }
        } catch (Exception ex) {
            logger.error("runScheduleModuleTask运行异常");
            ex.printStackTrace();
        }
        logger.info("runScheduleModuleTask运行完成");
    }
}