| | |
| | | } else { |
| | | dataView.setRealData(new ArrayList<>()); |
| | | } |
| | | dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat, 3)); |
| | | |
| | | Map<String, Object> realDataMap = new HashMap<>(); |
| | | dataView.getRealData().forEach(item -> { |
| | | realDataMap.put(item[0].toString(), item[1]); |
| | | }); |
| | | Object curReal = realDataMap.get(DateUtils.format(predictTime, timeFormat)) == null ? dataView.getPreDataL().get(dataView.getPreDataL().size() - 1) : realDataMap.get(DateUtils.format(predictTime, timeFormat)); |
| | | |
| | | // 当前值T0 + 当前预测值 20250409 |
| | | dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat, 3, true, curReal)); |
| | | // 调整预测值 |
| | | dataView.setAdjData(stAdjustResultService.getData(outPut.getId(),predictTime,timeFormat)); |
| | | dataView.setLineType(lineType.getCode()); |
| | |
| | | |
| | | List<Object[]> getData(String outputId, Date predictTime, String timeFormat, int scale); |
| | | |
| | | List<Object[]> getData(String outputId, Date predictTime, String timeFormat, int scale, Boolean isT1, Object curReal); |
| | | |
| | | double[] getSimpleData(String outputId, Date predictTime, int predictLength); |
| | | |
| | | void insert(List<MmItemResultJsonEntity> resultJsonList); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public List<Object[]> getData(String outputId, Date predictTime, String timeFormat, int scale, Boolean isT1, Object curReal) { |
| | | List<Object[]> result = new ArrayList<>(); |
| | | QueryWrapper<MmItemResultJsonEntity> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("outputid", outputId) |
| | | .eq("predicttime", DateUtils.format(predictTime,timeFormat)); |
| | | MmItemResultJsonEntity data = baseDao.selectOne(wrapper); |
| | | if (data == null || StringUtils.isBlank(data.getJsonvalue())) { |
| | | return result; |
| | | } |
| | | List<Double> valueList = JSONArray.parseArray(data.getJsonvalue(), Double.class); |
| | | if (CollectionUtils.isEmpty(valueList)) { |
| | | return result; |
| | | } |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.setTime(predictTime); |
| | | if (isT1) { |
| | | Object[] v0 = new Object[2]; |
| | | v0[0] = DateUtils.format(calendar.getTime(), timeFormat); |
| | | v0[1] = curReal; |
| | | result.add(v0); |
| | | calendar.add(Calendar.MINUTE, 1); |
| | | } |
| | | |
| | | valueList.forEach(value -> { |
| | | Object[] dv = {DateUtils.format(calendar.getTime(), timeFormat), new BigDecimal(value).setScale(scale, BigDecimal.ROUND_HALF_UP)}; |
| | | calendar.add(Calendar.MINUTE, 1); |
| | | result.add(dv); |
| | | }); |
| | | return result; |
| | | } |
| | | |
| | | @Override |
| | | public double[] getSimpleData(String outputId, Date predictTime, int predictLength) { |
| | | double[] result = new double[predictLength]; |
| | | QueryWrapper<MmItemResultJsonEntity> wrapper = new QueryWrapper<>(); |