| | |
| | | } else { |
| | | log.info("没有匹配的TagNo=" + item.getTagNo()); |
| | | } |
| | | |
| | | log.info("TagNo=" + item.getTagNo() + ",value=" + value.toString()); |
| | | if (!PointDataTypeEnum.BOOLEAN.getCode().equals(item.getDataType())) { |
| | | BigDecimal coefficient = item.getUnittransfactor() == null ? BigDecimal.ONE : item.getUnittransfactor(); |
| | |
| | | } else if (PointDataTypeEnum.INT.getCode().equals(item.getDataType())) { |
| | | decValue = decValue.setScale(0, BigDecimal.ROUND_HALF_UP); |
| | | } |
| | | if (item.getMaxValue() != null && decValue.compareTo(item.getMaxValue()) > 0) { |
| | | decValue = item.getMaxValue(); |
| | | } else if (item.getMinValue() != null && decValue.compareTo(item.getMinValue()) < 0) { |
| | | decValue = item.getMinValue(); |
| | | } |
| | | data.put(item.getPointNo(), decValue); |
| | | } else { |
| | | data.put(item.getPointNo(), value); |
| | |
| | | |
| | | private String statusCode; |
| | | |
| | | private Integer adjustRate; |
| | | |
| | | private Map<String, Object> result; |
| | | } |
| | |
| | | } |
| | | if (!CollectionUtils.isEmpty(realDataMap)) { |
| | | Object curReal = realDataMap.get(DateUtils.format(predictTime, timeFormat)) == null ? |
| | | dataView.getRealData().get(dataView.getRealData().size() - 1) : realDataMap.get(DateUtils.format(predictTime, timeFormat)); |
| | | dataView.getRealData().get(dataView.getRealData().size() - 1)[1] : realDataMap.get(DateUtils.format(predictTime, timeFormat)); |
| | | // 当前值T0 + 当前预测值 20250409 |
| | | dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat, decimalPlaces, true, curReal)); |
| | | } else { |
| | |
| | | reqDTO.getDynamicDataLength(), reqDTO.getDynamicSettings()); |
| | | resp.setStatusCode(scheduleResult.getResultCode()); |
| | | resp.setResult(scheduleResult.getResult()); |
| | | resp.setAdjustRate(scheduleResult.getAdjustRate()); |
| | | stScheduleRecordService.create(scheduleResult); |
| | | stScheduleSchemeService.updateTime(scheduleResult.getSchemeId(), scheduleResult.getScheduleTime(), scheduleResult.getResultCode()); |
| | | log.info("调度计算结束: " + System.currentTimeMillis()); |
| | |
| | | Map<String, String> dynamicSettings) throws ModelInvokeException { |
| | | ScheduleResultVO scheduleResult = new ScheduleResultVO(); |
| | | StScheduleSchemeEntity scheduleScheme = stScheduleSchemeService.getByCode(schemeCode); |
| | | scheduleResult.setAdjustRate(scheduleScheme.getAdjustRate()); |
| | | StScheduleModelEntity scheduleModel = stScheduleModelService.get(scheduleScheme.getModelId()); |
| | | if (scheduleModel == null) { |
| | | throw new ModelInvokeException(MessageFormat.format("{0},modelId={1}", |
| | |
| | | */ |
| | | private Map<String, Object> result; |
| | | |
| | | /** |
| | | * 调整速率 |
| | | */ |
| | | private Integer adjustRate; |
| | | |
| | | } |
| | |
| | | t.status, |
| | | t.sort |
| | | from ( |
| | | select id,'alarm' type, t1.title, t1.content, t1.alarm_time `time`, t1.alarm_obj obj,0 status, 0 sort |
| | | select id,'alarm' type, t1.title, t1.content, t1.alarm_time `time`, t1.alarm_obj obj,0 status, 0 sort,t1.create_time |
| | | from t_mm_predict_alarm_message t1 |
| | | UNION |
| | | select id,'suggest' type, t2.title, t2.content, t2.schedule_time `time`, t2.schedule_obj obj,t2.status,t2.sort |
| | | select id,'suggest' type, t2.title, t2.content, t2.schedule_time `time`, t2.schedule_obj obj,t2.status,t2.sort,t2.create_time |
| | | from t_st_schedule_suggest t2 |
| | | ) t |
| | | <where> |
| | |
| | | </if> |
| | | |
| | | </where> |
| | | order by t.time desc, t.sort ASC |
| | | order by t.time desc, t.sort ASC,t.create_time |
| | | |
| | | </select> |
| | | </mapper> |