| | |
| | | |
| | | @Override |
| | | public List<InfluxModelResultVO> queryModelResults(InfluxModelResultPOJO pojo, Date startTime, Date endTime) { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.set(Calendar.MILLISECOND, 0); |
| | | String start = startTime.toInstant().toString(); |
| | | |
| | | if (startTime.getTime() == endTime.getTime()) { |
| | |
| | | break; |
| | | case NORMALITEM: |
| | | case MERGEITEM: |
| | | List<DataValueVO> predictValue = new ArrayList<>(); |
| | | if (columnItem.getStartTime().getTime() == columnItem.getEndTime().getTime()) { |
| | | predictValue = mmItemResultService.getPredictValueLast(columnItem.getParamId(), columnItem.getStartTime(), 2); |
| | | } else { |
| | | predictValue = mmItemResultService.getPredictValue(columnItem.getParamId(), columnItem.getStartTime(), columnItem.getEndTime()); |
| | | } |
| | | List<DataValueVO> predictValue = mmItemResultService.getPredictValue(columnItem.getParamId(), columnItem.getStartTime(), columnItem.getEndTime()); |
| | | if (CollectionUtils.isEmpty(predictValue)) { |
| | | break; |
| | | } |
| | |
| | | Date dateTime = new Date(); |
| | | switch (ModelParamType.getEumByCode(columnItem.getParamType())) { |
| | | case DATAPOINT: |
| | | dateTime = calculateTime(originalTime, true, columnItem.getDataLength(), columnItem.getGranularity()); |
| | | break; |
| | | case PLAN: |
| | | dateTime = calculateTime(originalTime, true, columnItem.getDataLength() + 1, columnItem.getGranularity()); |
| | | break; |
| | |
| | | calendar.setTime(originalTime); |
| | | switch (ModelParamType.getEumByCode(columnItem.getParamType())) { |
| | | case DATAPOINT: |
| | | dateTime = calculateTime(originalTime, true, 1, columnItem.getGranularity()); |
| | | break; |
| | | case PLAN: |
| | | dateTime = calculateTime(originalTime, true, 1, columnItem.getGranularity()); |
| | | break; |
| | |
| | | break; |
| | | case NORMALITEM: |
| | | case MERGEITEM: |
| | | dateTime = calculateTime(originalTime, false, columnItem.getDataLength() + 1, columnItem.getGranularity()); |
| | | dateTime = calculateTime(originalTime, false, columnItem.getDataLength(), columnItem.getGranularity()); |
| | | break; |
| | | default: |
| | | break; |