Merge remote-tracking branch 'origin/master'
| | |
| | | break; |
| | | case NORMALITEM: |
| | | case MERGEITEM: |
| | | MmItemOutputEntity outPut = mmItemOutputService.getOutPutById(columnItem.getParamId()); |
| | | List<DataValueVO> predictValue = mmItemResultService.getPredictValue(outPut.getId(), columnItem.getStartTime(), columnItem.getEndTime()); |
| | | // MmItemOutputEntity outPut = mmItemOutputService.getOutPutById(columnItem.getParamId()); |
| | | List<DataValueVO> predictValue = mmItemResultService.getPredictValue(columnItem.getParamId(), columnItem.getStartTime(), columnItem.getEndTime()); |
| | | if (CollectionUtils.isEmpty(predictValue)) { |
| | | break; |
| | | } |
| | |
| | | break; |
| | | } |
| | | // 避免生产环境日志过多,分级打印 |
| | | log.debug("数据获取,columnItem:" + columnItem + ",dataList" + dataList); |
| | | log.info("数据获取,columnItem:" + columnItem + ",dataListLength" + dataList.size()); |
| | | log.debug("数据获取,columnItem:" + columnItem + ",dataList:" + dataList); |
| | | log.info("数据获取,columnItem:" + columnItem + ",dataListLength:" + dataList.size()); |
| | | return dataList; |
| | | } |
| | | } |
| | |
| | | case MERGEITEM: |
| | | // 预测值 |
| | | oneMin = PredGranularityEnum.MIN1.getCode() * 1000L; |
| | | start = start - (start % oneMin) + oneMin; |
| | | end = end - (end % oneMin) + oneMin; |
| | | mins = ((end - start) / oneMin); |
| | | start = start - (start % oneMin); |
| | | end = end - (end % oneMin); |
| | | mins = ((end - start) / oneMin) + 1; |
| | | break; |
| | | case DATAPOINT: |
| | | // 测点值 |