liriming
2025-01-14 0809aa554fc906e73a383c34f88bb4153bb69b00
提交 | 用户 | 时间
b368e6 1 package com.iailab.module.model.api;
2
0a7d0f 3 import com.iailab.framework.common.pojo.PageResult;
b368e6 4 import com.iailab.framework.common.util.date.DateUtils;
8a74e9 5 import com.iailab.framework.common.util.object.ConvertUtils;
6 import com.iailab.module.data.api.plan.PlanItemApi;
7 import com.iailab.module.data.api.plan.dto.ApiPlanDataDTO;
b368e6 8 import com.iailab.module.data.api.point.DataPointApi;
9 import com.iailab.module.data.api.point.dto.ApiPointDTO;
10 import com.iailab.module.data.api.point.dto.ApiPointValueDTO;
11 import com.iailab.module.data.api.point.dto.ApiPointValueQueryDTO;
8a74e9 12 import com.iailab.module.data.common.ApiDataQueryDTO;
b368e6 13 import com.iailab.module.model.api.mcs.McsApi;
14 import com.iailab.module.model.api.mcs.dto.*;
22e321 15 import com.iailab.module.model.common.enums.DataTypeEnum;
401492 16 import com.iailab.module.model.enums.CommonConstant;
91343d 17 import com.iailab.module.model.common.enums.PreLineTypeEnum;
22e321 18 import com.iailab.module.model.influxdb.pojo.InfluxModelResultByOutPutIdsPOJO;
D 19 import com.iailab.module.model.influxdb.service.InfluxDBService;
20 import com.iailab.module.model.influxdb.vo.InfluxModelResultVO;
b368e6 21 import com.iailab.module.model.mcs.pre.entity.DmModuleEntity;
22 import com.iailab.module.model.mcs.pre.entity.MmItemOutputEntity;
c5fe30 23 import com.iailab.module.model.mcs.pre.entity.MmPredictAlarmMessageEntity;
b368e6 24 import com.iailab.module.model.mcs.pre.service.*;
22e321 25 import com.iailab.module.model.mcs.pre.vo.MmItemOutputRespVO;
c5fe30 26 import com.iailab.module.model.mcs.pre.vo.MmPredictAlarmMessageSaveReqVO;
22e321 27 import com.iailab.module.model.mcs.pre.vo.MmPredictItemRespVO;
055765 28 import com.iailab.module.model.mcs.sche.entity.StScheduleSuggestEntity;
4072bc 29 import com.iailab.module.model.mcs.sche.service.StScheduleSchemeService;
055765 30 import com.iailab.module.model.mcs.sche.service.StScheduleSuggestService;
19f359 31 import com.iailab.module.model.mcs.sche.vo.StScheduleSuggestSaveReqVO;
ead005 32 import com.iailab.module.model.mdk.vo.ItemVO;
730d19 33 import com.iailab.module.model.mpk.service.ChartParamService;
91343d 34 import com.iailab.module.model.mpk.service.ChartService;
b368e6 35 import lombok.extern.slf4j.Slf4j;
977edc 36 import org.apache.commons.lang3.StringUtils;
b368e6 37 import org.springframework.beans.factory.annotation.Autowired;
38 import org.springframework.util.CollectionUtils;
39 import org.springframework.validation.annotation.Validated;
40 import org.springframework.web.bind.annotation.RestController;
41
42 import java.math.BigDecimal;
43 import java.util.*;
22e321 44 import java.util.function.Function;
912419 45 import java.util.stream.Collectors;
22e321 46 import java.util.stream.Stream;
b368e6 47
48 /**
49  * @author PanZhibao
50  * @Description
51  * @createTime 2024年11月13日
52  */
53 @Slf4j
54 @RestController
55 @Validated
56 public class McsApiImpl implements McsApi {
57
58     @Autowired
6eeac9 59     private DataPointApi dataPointApi;
D 60
61     @Autowired
b368e6 62     private DmModuleService dmModuleService;
63
64     @Autowired
65     private MmPredictItemService mmPredictItemService;
66
67     @Autowired
68     private MmItemOutputService mmItemOutputService;
69
70     @Autowired
71     private MmItemResultService mmItemResultService;
72
73     @Autowired
74     private MmItemResultLastPointService mmItemResultLastPointService;
91343d 75
76     @Autowired
77     private MmItemResultJsonService mmItemResultJsonService;
78
79     @Autowired
80     private ChartService chartService;
c5fe30 81
82     @Autowired
83     private MmPredictAlarmMessageService mmPredictAlarmMessageService;
055765 84
85     @Autowired
86     private StScheduleSuggestService stScheduleSuggestService;
8a74e9 87
88     @Autowired
89     private PlanItemApi planItemApi;
9587d2 90
L 91     @Autowired
92     private MmPredictAlarmConfigService mmPredictAlarmConfigService;
3a6dfc 93
4072bc 94     @Autowired
L 95     private StScheduleSchemeService stScheduleSchemeService;
730d19 96
D 97     @Autowired
98     private ChartParamService chartParamService;
22e321 99
D 100     @Autowired
101     private InfluxDBService influxDBService;
6eeac9 102
b368e6 103     private int HOUR_MINS = 60;
104
105     @Override
106     public List<PredictItemTreeDTO> getPredictItemTree() {
107         List<PredictItemTreeDTO> result = new ArrayList<>();
108
109         List<DmModuleEntity> moduleList = dmModuleService.list(new HashMap<>());
110         if (CollectionUtils.isEmpty(moduleList)) {
111             return result;
112         }
113         moduleList.forEach(item -> {
114             PredictItemTreeDTO moduleOpt = new PredictItemTreeDTO();
115             moduleOpt.setId(item.getId());
116             moduleOpt.setLabel(item.getModulename());
117             List<PredictItemTreeDTO> children = new ArrayList<>();
a4891a 118             List<ItemVO> itemList = mmPredictItemService.getByModuleId(item.getId());
b368e6 119             itemList.forEach(item1 -> {
120                 PredictItemTreeDTO chd = new PredictItemTreeDTO();
a4891a 121                 chd.setLabel(item1.getItemName());
b368e6 122                 chd.setId(item1.getId());
a4891a 123                 List<PredictItemTreeDTO> chd1 = new ArrayList<>();
124                 List<MmItemOutputEntity> outList = mmItemOutputService.getByItemid(item1.getId());
125                 if (!CollectionUtils.isEmpty(outList)) {
126                     outList.forEach(out -> {
127                         PredictItemTreeDTO chd2 = new PredictItemTreeDTO();
128                         chd2.setId(out.getId());
f283ee 129                         chd2.setLabel(out.getResultName());
a4891a 130                         chd1.add(chd2);
131                     });
132                 }
133                 chd.setChildren(chd1);
b368e6 134                 children.add(chd);
135             });
136             moduleOpt.setChildren(children);
137             result.add(moduleOpt);
138         });
139         return result;
140     }
141
142     @Override
143     public PreDataBarLineRespVO getPreDataCharts(PreDataBarLineReqVO reqVO) {
144         PreDataBarLineRespVO result = new PreDataBarLineRespVO();
a4891a 145         List<String> outIds = reqVO.getOutIds();
b368e6 146         List<String> legends = new ArrayList<>();
147         List<PreDataViewRespDTO> dataViewList = new ArrayList<>();
9e844c 148         if (CollectionUtils.isEmpty(outIds)) {
b368e6 149             return result;
150         }
151         Date predictTime = reqVO.getPredictTime();
152         if (predictTime == null) {
9e844c 153             MmItemOutputEntity output = mmItemOutputService.getOutPutById(reqVO.getOutIds().get(0));
b82ba2 154             ItemVO predictItem = mmPredictItemService.getItemByIdFromCache(output.getItemid());
9e844c 155             if (predictItem.getLastTime() != null) {
156                 predictTime = predictItem.getLastTime();
157             } else {
158                 Calendar calendar = Calendar.getInstance();
159                 calendar.set(Calendar.MILLISECOND, 0);
160                 calendar.set(Calendar.SECOND, 0);
161                 predictTime = calendar.getTime();
162             }
b368e6 163         }
164         Date startTime = reqVO.getStartTime();
165         if (startTime == null) {
166             Calendar calendar = Calendar.getInstance();
167             calendar.setTime(predictTime);
168             calendar.add(Calendar.HOUR_OF_DAY, -1);
169             startTime = calendar.getTime();
170         }
171         Date endTime = reqVO.getEndTime();
172         if (endTime == null) {
173             Calendar calendar = Calendar.getInstance();
174             calendar.setTime(predictTime);
175             calendar.add(Calendar.HOUR_OF_DAY, 1);
176             endTime = calendar.getTime();
177         }
178
a4891a 179         for (int i = 0; i < outIds.size(); i++) {
b368e6 180             PreDataViewRespDTO viewDto = new PreDataViewRespDTO();
a4891a 181             String outId = outIds.get(i);
182             MmItemOutputEntity output = mmItemOutputService.getOutPutById(outId);
b368e6 183             if (output == null) {
9e844c 184                 continue;
b368e6 185             }
f283ee 186             legends.add(output.getResultName());
9e844c 187             viewDto.setItemId(output.getItemid());
188             viewDto.setOutId(outId);
189             viewDto.setResultstr(output.getResultstr());
f283ee 190             viewDto.setResultName(output.getResultName());
b368e6 191             viewDto.setRealData(getHisData(output.getPointid(), startTime, endTime));
977edc 192             viewDto.setPreDataN(mmItemResultService.getData(output.getId(), startTime, endTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
193             viewDto.setPreDataL(mmItemResultLastPointService.getData(output.getId(), startTime, endTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
b368e6 194
195             List<Double> values = new ArrayList<>();
196             if (!CollectionUtils.isEmpty(viewDto.getRealData())) {
197                 List<Double> hisValues = new ArrayList<>();
198                 viewDto.getRealData().forEach(item -> {
199                     values.add(Double.parseDouble(item[1].toString()));
200                     hisValues.add(Double.parseDouble(item[1].toString()));
201                 });
202                 viewDto.setHisMax(new BigDecimal(hisValues.stream().mapToDouble(Double::doubleValue).max().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
203                 viewDto.setHisMin(new BigDecimal(hisValues.stream().mapToDouble(Double::doubleValue).min().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
204                 viewDto.setHisAvg(new BigDecimal(hisValues.stream().mapToDouble(Double::doubleValue).average().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
205                 viewDto.setHisCumulant(new BigDecimal(hisValues.stream().mapToDouble(Double::doubleValue).sum())
206                         .divide(new BigDecimal(HOUR_MINS), 2, BigDecimal.ROUND_HALF_UP));
207             }
208             if (!CollectionUtils.isEmpty(viewDto.getPreDataN())) {
209                 viewDto.getPreDataN().forEach(item -> {
210                     values.add(Double.parseDouble(item[1].toString()));
211                 });
212             }
213             if (!CollectionUtils.isEmpty(viewDto.getPreDataL())) {
214                 List<Double> preValues = new ArrayList<>();
215                 viewDto.getPreDataL().forEach(item -> {
216                     values.add(Double.parseDouble(item[1].toString()));
217                     preValues.add(Double.parseDouble(item[1].toString()));
218                 });
219                 viewDto.setPreMax(new BigDecimal(preValues.stream().mapToDouble(Double::doubleValue).max().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
220                 viewDto.setPreMin(new BigDecimal(preValues.stream().mapToDouble(Double::doubleValue).min().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
221                 viewDto.setPreAvg(new BigDecimal(preValues.stream().mapToDouble(Double::doubleValue).average().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
222             }
223             if (!CollectionUtils.isEmpty(viewDto.getCurData())) {
224                 List<Double> preValues = new ArrayList<>();
225                 viewDto.getCurData().forEach(item -> {
226                     values.add(Double.parseDouble(item[1].toString()));
227                     preValues.add(Double.parseDouble(item[1].toString()));
228                 });
229                 viewDto.setPreCumulant(new BigDecimal(preValues.stream().mapToDouble(Double::doubleValue).sum())
230                         .divide(new BigDecimal(HOUR_MINS), 2, BigDecimal.ROUND_HALF_UP));
231             }
232             if (!CollectionUtils.isEmpty(viewDto.getAdjData())) {
233                 viewDto.getAdjData().forEach(item -> {
234                     values.add(Double.parseDouble(item[1].toString()));
235                 });
236             }
237             if (!CollectionUtils.isEmpty(values)) {
238                 viewDto.setMaxValue(new BigDecimal(values.stream().mapToDouble(Double::doubleValue).max().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
239                 viewDto.setMinValue(new BigDecimal(values.stream().mapToDouble(Double::doubleValue).min().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
240             }
241             dataViewList.add(viewDto);
242         }
243         result.setStartTime(startTime);
244         result.setEndTime(endTime);
245         result.setPredictTime(predictTime);
246         result.setCategories(DateUtils.getTimeScale(startTime, endTime, 60));
247         result.setLegend(legends);
248         result.setDataViewList(dataViewList);
249         return result;
250     }
251
ead005 252     @Override
253     public PreDataItemChartRespVO getPreDataItemChart(PreDataItemChartReqVO reqVO) {
254         PreDataItemChartRespVO result = new PreDataItemChartRespVO();
864b61 255         ItemVO predictItem = mmPredictItemService.getItemById(reqVO.getItemId());
ead005 256         if (predictItem == null) {
257             return result;
258         }
259         if (predictItem.getLastTime() == null) {
260             return result;
261         }
328ef4 262         result.setPredictTime(predictItem.getLastTime());
ead005 263         Date startTime = reqVO.getStartTime();
264         if (startTime == null) {
265             Calendar calendar = Calendar.getInstance();
266             calendar.setTime(predictItem.getLastTime());
e691b9 267             calendar.add(Calendar.SECOND, -1 * predictItem.getPredictLength() * predictItem.getGranularity());
ead005 268             startTime = calendar.getTime();
269         }
270         Date endTime = reqVO.getEndTime();
271         if (endTime == null) {
272             Calendar calendar = Calendar.getInstance();
273             calendar.setTime(predictItem.getLastTime());
e691b9 274             calendar.add(Calendar.SECOND, predictItem.getPredictLength() * predictItem.getGranularity());
ead005 275             endTime = calendar.getTime();
276         }
1f9784 277         if (endTime.getTime() <= startTime.getTime()) {
278             Calendar calendar = Calendar.getInstance();
279             calendar.setTime(startTime);
e691b9 280             calendar.add(Calendar.SECOND, predictItem.getPredictLength() * predictItem.getGranularity());
1f9784 281             endTime = calendar.getTime();
282         }
283
ead005 284         List<String> categories = DateUtils.getTimeScale(startTime, endTime, predictItem.getGranularity());
285         List<String> legend = new ArrayList<>();
286         LinkedHashMap<String, PreDataSampleViewRespDTO> viewMap = new LinkedHashMap<>();
287         List<MmItemOutputEntity> outs = mmItemOutputService.getByItemid(reqVO.getItemId());
288         if (CollectionUtils.isEmpty(outs)) {
289             return result;
290         }
291         for (MmItemOutputEntity out : outs) {
f283ee 292             legend.add(out.getResultName());
ead005 293             PreDataSampleViewRespDTO viewDto = new PreDataSampleViewRespDTO();
85b200 294             if (StringUtils.isNotBlank(out.getPointid())) {
D 295                 viewDto.setRealData(getHisData(out.getPointid(), startTime, endTime));
296             }
977edc 297             viewDto.setPreDataN(mmItemResultService.getData(out.getId(), startTime, endTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
f283ee 298             viewMap.put(out.getResultName(), viewDto);
ead005 299         }
300         result.setStartTime(startTime);
301         result.setEndTime(endTime);
302         result.setCategories(categories);
303         result.setLegend(legend);
304         result.setViewMap(viewMap);
305         return result;
306     }
307
328ef4 308     @Override
91343d 309     public PreDataSingleChartRespVO getPreDataSingleChart(PreDataSingleChartReqVO reqVO) {
310         PreDataSingleChartRespVO result = new PreDataSingleChartRespVO();
328ef4 311
91343d 312         Map<String, String> chartParams = chartService.getByChartCode(reqVO.getChartCode());
313         if (CollectionUtils.isEmpty(chartParams)) {
314             return result;
315         }
316         String itemCode = chartParams.get(CommonConstant.ITEM_CODE);
317         if (itemCode == null) {
318             return result;
319         }
320         String resultStr = chartParams.get(CommonConstant.RESULT_STR);
321         if (resultStr == null) {
322             return result;
323         }
bd9085 324         String resultIndex = chartParams.get(CommonConstant.RESULT_INDEX);
325
91343d 326         ItemVO predictItem = mmPredictItemService.getItemByItemNo(itemCode);
327         if (predictItem == null || predictItem.getLastTime() == null) {
328             return result;
329         }
977edc 330         String timeFormat = StringUtils.isBlank(reqVO.getTimeFormat()) ? DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND : reqVO.getTimeFormat();
331         PreLineTypeEnum lineType = chartParams.get(CommonConstant.LINE_TYPE) == null ? PreLineTypeEnum.TN : PreLineTypeEnum.getEumByCode(chartParams.get(CommonConstant.LINE_TYPE));
91343d 332         BigDecimal rangeH = chartParams.get(CommonConstant.RANGE_H) == null ? BigDecimal.ZERO : new BigDecimal(chartParams.get(CommonConstant.RANGE_H));
333         BigDecimal rangeL = chartParams.get(CommonConstant.RANGE_L) == null ? BigDecimal.ZERO : new BigDecimal(chartParams.get(CommonConstant.RANGE_L));
334         BigDecimal limitH = chartParams.get(CommonConstant.LIMIT_H) == null ? BigDecimal.ZERO : new BigDecimal(chartParams.get(CommonConstant.LIMIT_H));
335         BigDecimal limitL = chartParams.get(CommonConstant.LIMIT_L) == null ? BigDecimal.ZERO : new BigDecimal(chartParams.get(CommonConstant.LIMIT_L));
336         int lengthLeft = chartParams.get(CommonConstant.LENGTH_LEFT) == null ? predictItem.getPredictLength() : new BigDecimal(chartParams.get(CommonConstant.LENGTH_LEFT)).intValue();
337         int lengthRight = chartParams.get(CommonConstant.LENGTH_RIGHT) == null ? predictItem.getPredictLength() : new BigDecimal(chartParams.get(CommonConstant.LENGTH_RIGHT)).intValue();
8a74e9 338
339         Date[] timeArray = calResultTime(predictItem, reqVO.getStartTime(), reqVO.getEndTime(), lengthLeft, lengthRight);
340         Date predictTime = timeArray[0];
341         Date startTime = timeArray[1];
342         Date endTime = timeArray[2];
343
977edc 344         List<String> categories = DateUtils.getTimeScale(startTime, endTime, predictItem.getGranularity(), timeFormat);
91343d 345         List<String> legend = new ArrayList<>();
bdab69 346         MmItemOutputEntity outPut = mmItemOutputService.getByItemid(predictItem.getId(), resultStr, resultIndex);
91343d 347         PreDataViewRespDTO dataView = new PreDataViewRespDTO();
348         dataView.setItemId(predictItem.getId());
349         dataView.setItemName(predictItem.getItemName());
350         dataView.setResultstr(resultStr);
351         dataView.setRangeH(rangeH);
352         dataView.setRangeL(rangeL);
353         dataView.setLimitH(limitH);
354         dataView.setLimitL(limitL);
b6bfe8 355         if (StringUtils.isNotBlank(outPut.getPointid())) {
D 356             dataView.setRealData(getHisData(outPut.getPointid(), startTime, endTime, timeFormat));
357         } else {
358             dataView.setRealData(new ArrayList<>());
359         }
977edc 360         dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat));
91343d 361         switch (lineType) {
362             case TN:
977edc 363                 dataView.setPreDataN(mmItemResultService.getData(outPut.getId(), startTime, endTime, timeFormat));
91343d 364                 break;
365             case TL:
977edc 366                 dataView.setPreDataN(mmItemResultService.getData(outPut.getId(), predictTime, endTime, timeFormat));
367                 dataView.setPreDataL(mmItemResultLastPointService.getData(outPut.getId(), startTime, endTime, timeFormat));
91343d 368                 break;
369             default:
370                 break;
371         }
912419 372
373         if (!CollectionUtils.isEmpty(dataView.getCurData())) {
374             List<Double> curList = dataView.getCurData().stream().map(t -> {
375                 return new Double(t[1].toString());
376             }).collect(Collectors.toList());
377             dataView.setPreMax(new BigDecimal(curList.stream().mapToDouble(Double::doubleValue).max().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
378             dataView.setPreMin(new BigDecimal(curList.stream().mapToDouble(Double::doubleValue).min().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
379         }
380
9904da 381         String alarmObj = chartParams.get(CommonConstant.ALARM_OBJ);
382         if (StringUtils.isNotBlank(alarmObj)) {
383             List<AlarmMessageRespDTO> alarmList = ConvertUtils.sourceToTarget(mmPredictAlarmMessageService.getList(alarmObj, predictTime), AlarmMessageRespDTO.class);
8ccce9 384             dataView.setAlarmList(alarmList);
9904da 385         }
386
8a74e9 387         result.setPredictTime(predictTime);
91343d 388         result.setStartTime(startTime);
389         result.setEndTime(endTime);
390         result.setCategories(categories);
391         result.setLegend(legend);
392         result.setDataView(dataView);
8a74e9 393         return result;
394     }
395
396     @Override
d9fe8f 397     public Map<String, List<Object[]>> getPreDataCur(PreDataJsonReqVO reqVO) {
398         Map<String, List<Object[]>> result = new HashMap<>();
399         if (reqVO == null || reqVO.getPredictTime() == null || CollectionUtils.isEmpty(reqVO.getOutputIdList())) {
400             return result;
401         }
402         reqVO.getOutputIdList().forEach(outPutId -> {
403             result.put(outPutId, mmItemResultJsonService.getData(outPutId, reqVO.getPredictTime(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
404         });
405         return result;
406     }
407
408     @Override
8a74e9 409     public PlanDataSingleChartRespVO getPlanDataSingleChart(PreDataSingleChartReqVO reqVO) {
410         PlanDataSingleChartRespVO result = new PlanDataSingleChartRespVO();
411         Map<String, String> chartParams = chartService.getByChartCode(reqVO.getChartCode());
412         if (CollectionUtils.isEmpty(chartParams)) {
413             return result;
414         }
415         String itemCode = chartParams.get(CommonConstant.ITEM_CODE);
416         if (itemCode == null) {
417             return result;
418         }
419         String planItemStr = chartParams.get(CommonConstant.PLAN_ITEM_LIST);
420         if (planItemStr == null) {
421             return result;
422         }
423         List<String> planItemCodeList = Arrays.asList(planItemStr.split(","));
424
425         ItemVO predictItem = mmPredictItemService.getItemByItemNo(itemCode);
426         if (predictItem == null || predictItem.getLastTime() == null) {
427             return result;
428         }
429         String timeFormat = StringUtils.isBlank(reqVO.getTimeFormat()) ? DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND : reqVO.getTimeFormat();
430         int lengthLeft = chartParams.get(CommonConstant.LENGTH_LEFT) == null ? predictItem.getPredictLength() : new BigDecimal(chartParams.get(CommonConstant.LENGTH_LEFT)).intValue();
431         int lengthRight = chartParams.get(CommonConstant.LENGTH_RIGHT) == null ? predictItem.getPredictLength() : new BigDecimal(chartParams.get(CommonConstant.LENGTH_RIGHT)).intValue();
432         Date[] timeArray = calResultTime(predictItem, reqVO.getStartTime(), reqVO.getEndTime(), lengthLeft, lengthRight);
433         Date predictTime = timeArray[0];
434         Date startTime = timeArray[1];
435         Date endTime = timeArray[2];
436         List<String> categories = DateUtils.getTimeScale(startTime, endTime, predictItem.getGranularity(), timeFormat);
437         List<String> legend = new ArrayList<>();
438         LinkedHashMap<String, List<PlanDataRecordDTO>> record = new LinkedHashMap<>();
439         ApiDataQueryDTO queryDTO = new ApiDataQueryDTO();
440         queryDTO.setItemNos(planItemCodeList);
441         queryDTO.setStart(startTime);
442         queryDTO.setEnd(endTime);
443         LinkedHashMap<String, List<ApiPlanDataDTO>> planData = planItemApi.queryPlanItemRecordValue(queryDTO);
444         if (CollectionUtils.isEmpty(planData)) {
445             planData.forEach((key, value) -> {
446                 record.put(key, ConvertUtils.sourceToTarget(value, PlanDataRecordDTO.class));
447             });
448         }
449         result.setPredictTime(predictTime);
450         result.setStartTime(startTime);
451         result.setEndTime(endTime);
452         result.setCategories(categories);
453         result.setLegend(legend);
454         result.setRecord(record);
328ef4 455         return result;
456     }
457
b368e6 458     /**
459      * 获取真实值
460      *
461      * @param pointId
462      * @param startTime
463      * @param endTime
464      * @return
465      */
466     private List<Object[]> getHisData(String pointId, Date startTime, Date endTime) {
467         List<Object[]> result = new ArrayList<>();
468         ApiPointDTO pointDTO = dataPointApi.getInfoById(pointId);
469         ApiPointValueQueryDTO queryPointDto = new ApiPointValueQueryDTO();
470         queryPointDto.setPointNo(pointDTO.getPointNo());
471         queryPointDto.setStart(startTime);
472         queryPointDto.setEnd(endTime);
473         List<ApiPointValueDTO> valueDTOS = dataPointApi.queryPointHistoryValue(queryPointDto);
474         if (CollectionUtils.isEmpty(valueDTOS)) {
475             return result;
476         }
477         valueDTOS.forEach(item -> {
478             Object[] values = new Object[2];
214275 479             values[0] = DateUtils.format(item.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
480             values[1] = new BigDecimal(item.getV()).setScale(2, BigDecimal.ROUND_HALF_UP);
b368e6 481             result.add(values);
482         });
483         return result;
484     }
485
977edc 486     /**
487      * 获取真实值
488      *
489      * @param pointId
490      * @param startTime
491      * @param endTime
492      * @param timeFormat
493      * @return
494      */
495     private List<Object[]> getHisData(String pointId, Date startTime, Date endTime, String timeFormat) {
496         List<Object[]> result = new ArrayList<>();
497         ApiPointDTO pointDTO = dataPointApi.getInfoById(pointId);
498         ApiPointValueQueryDTO queryPointDto = new ApiPointValueQueryDTO();
499         queryPointDto.setPointNo(pointDTO.getPointNo());
500         queryPointDto.setStart(startTime);
501         queryPointDto.setEnd(endTime);
502         List<ApiPointValueDTO> valueDTOS = dataPointApi.queryPointHistoryValue(queryPointDto);
503         if (CollectionUtils.isEmpty(valueDTOS)) {
504             return result;
505         }
506         valueDTOS.forEach(item -> {
507             Object[] values = new Object[2];
508             values[0] = DateUtils.format(item.getT(), timeFormat);
509             values[1] = new BigDecimal(item.getV()).setScale(2, BigDecimal.ROUND_HALF_UP);
510             result.add(values);
511         });
512         return result;
513     }
514
c5fe30 515     /**
516      * 新增预警信息
517      *
518      * @param dto
519      * @return
520      */
b368e6 521     @Override
522     public Boolean createAlarmMessage(AlarmMessageRespDTO dto) {
c5fe30 523         try {
524             mmPredictAlarmMessageService.create(ConvertUtils.sourceToTarget(dto, MmPredictAlarmMessageSaveReqVO.class));
525             return true;
526         } catch (Exception e) {
527             return false;
528         }
b368e6 529     }
530
531     @Override
532     public List<AlarmMessageRespDTO> listAlarmMessage(Map<String, Object> params) {
533         return null;
534     }
535
536     @Override
9587d2 537     public List<AlarmConfigRespDTO> listAlarmConfig(Map<String, Object> params) {
L 538         return mmPredictAlarmConfigService.list(params);
539     }
540
541     @Override
c5fe30 542     public AlarmMessageRespDTO getLastAlarmMessage(String alarmObj) {
543         MmPredictAlarmMessageEntity entity = mmPredictAlarmMessageService.getLast(alarmObj);
544         return ConvertUtils.sourceToTarget(entity, AlarmMessageRespDTO.class);
545     }
546
547     @Override
b368e6 548     public Boolean createScheduleSuggest(ScheduleSuggestRespDTO dto) {
19f359 549         stScheduleSuggestService.create(ConvertUtils.sourceToTarget(dto, StScheduleSuggestSaveReqVO.class));
b368e6 550         return true;
551     }
552
553     @Override
4072bc 554     public List<ScheduleSuggestRespDTO> listScheduleSuggest(Map<String, Object> params) {
3a6dfc 555         return Collections.emptyList();
L 556     }
557
558     @Override
055765 559     public List<ScheduleSuggestRespDTO> getLastLimitScheduleSuggest(String scheduleObj, Integer limit) {
560         List<StScheduleSuggestEntity> list = stScheduleSuggestService.getList(scheduleObj, limit);
561         return ConvertUtils.sourceToTarget(list, ScheduleSuggestRespDTO.class);
b368e6 562     }
563
564     @Override
565     public Boolean modifyPredictModelSetting(List<PredictModelSettingReqDTO> dtos) {
566         return true;
567     }
568
569     @Override
570     public Boolean modifyScheduleModelSetting(List<ScheduleModelSettingReqDTO> dtos) {
571         return true;
572     }
8a74e9 573
4072bc 574     @Override
ed4107 575     public List<StScheduleSchemeDTO> listScheduleScheme(String triggerMethod, String triggerCondition) {
576         Map<String, Object> params = new HashMap<>();
577         params.put("triggerMethod", triggerMethod);
578         params.put("triggerCondition", triggerCondition);
4072bc 579         return stScheduleSchemeService.list(params);
6eeac9 580     }
8a74e9 581
730d19 582     @Override
D 583     public List<ChartParamDTO> getChartParamList(String chartCode) {
584         if (StringUtils.isBlank(chartCode)) {
585             return null;
586         }
587         return chartParamService.list(chartCode);
588     }
589
0a7d0f 590     @Override
591     public PageResult<StAlarmAndSuggestRespVO> getAlarmAndSuggestPage(StAlarmAndSuggestPageReqVO reqVO) {
592         return stScheduleSchemeService.getAlarmAndSuggestPage(reqVO);
593     }
594
22e321 595     @Override
D 596     public Map<String, Map<String, Double>> getPreDoubleData(PreDoubleDataReqVO reqVO) {
597         List<MmPredictItemRespVO> doubleItemOutPuts = mmPredictItemService.getDoubleOutPutsByItemNos(reqVO.getItemNos());
598
599         //<itemNo,<resultStr,double>>
600         Map<String, Map<String, Double>> result = new HashMap<>(reqVO.getItemNos().size());
601
602         for (MmPredictItemRespVO mmPredictItemRespVO : doubleItemOutPuts) {
603             List<String> outPutIds = mmPredictItemRespVO.getOutPuts().stream().map(MmItemOutputRespVO::getId).collect(Collectors.toList());
604             InfluxModelResultByOutPutIdsPOJO pojo = new InfluxModelResultByOutPutIdsPOJO();
605             pojo.setOutPutIds(outPutIds);
606             pojo.setType(DataTypeEnum.FLOAT.getCode());
607             Map<String, List<InfluxModelResultVO>> outPutIdDoubles = influxDBService.queryModelResultsByOutPutIds(pojo, mmPredictItemRespVO.getLastTime(), mmPredictItemRespVO.getLastTime());
608             Map<String, Double> outPutIdDouble = new HashMap<>(outPutIds.size());
609             for (MmItemOutputRespVO outPut : mmPredictItemRespVO.getOutPuts()) {
610                 String outPutId = outPut.getId();
611                 if (outPutIdDoubles.containsKey(outPutId)) {
612                     List<InfluxModelResultVO> influxModelResultVOS = outPutIdDoubles.get(outPutId);
613                     if (!CollectionUtils.isEmpty(influxModelResultVOS)) {
614                         outPutIdDouble.put(outPut.getResultstr(),Double.valueOf(influxModelResultVOS.get(0).getValue().toString()));
615                     }
616                 }
617             }
618             result.put(mmPredictItemRespVO.getItemno(),outPutIdDouble);
619         }
620         return result;
621     }
622
8a74e9 623     private Date[] calResultTime(ItemVO predictItem, Date startTimeReq, Date endTimeReq, int lengthLeft, int lengthRight) {
624         Date[] result = new Date[3];
625         Date predictTime = predictItem.getLastTime();
626         Date startTime = startTimeReq;
627         if (startTime == null) {
628             Calendar calendar = Calendar.getInstance();
629             calendar.setTime(predictItem.getLastTime());
630             calendar.add(Calendar.MINUTE, -1 * lengthLeft);
631             startTime = calendar.getTime();
632         }
633         Date endTime = endTimeReq;
634         if (endTime == null) {
635             Calendar calendar = Calendar.getInstance();
636             calendar.setTime(predictItem.getLastTime());
637             calendar.add(Calendar.MINUTE, lengthRight);
638             endTime = calendar.getTime();
639         }
640         if (endTime.getTime() <= startTime.getTime()) {
641             Calendar calendar = Calendar.getInstance();
642             calendar.setTime(startTime);
643             calendar.add(Calendar.MINUTE, lengthRight);
644             endTime = calendar.getTime();
645         }
646         result[0] = predictTime;
647         result[1] = startTime;
648         result[2] = endTime;
649         return result;
650     }
b368e6 651 }