| | |
| | | } |
| | | Date predictTime = reqVO.getPredictTime(); |
| | | if (predictTime == null) { |
| | | MmItemOutputEntity output = mmItemOutputService.getOutPutById(reqVO.getOutIds().get(0)); |
| | | MmItemOutputEntity output = null; |
| | | for (String outId : outIds) { |
| | | output = mmItemOutputService.getOutPutById(outId); |
| | | if (output != null) { |
| | | break; |
| | | } |
| | | } |
| | | ItemVO predictItem = mmPredictItemService.getItemByIdFromCache(output.getItemid()); |
| | | if (predictItem.getLastTime() != null) { |
| | | predictTime = predictItem.getLastTime(); |
| | |
| | | void asyncWriteModelResults(List<InfluxModelResultPOJO> pointValues); |
| | | |
| | | List<InfluxModelResultVO> queryModelResults(InfluxModelResultPOJO pojo, Date startTime, Date endTime); |
| | | |
| | | Map<String,List<InfluxModelResultVO>> queryModelResultsByOutPutIds(InfluxModelResultByOutPutIdsPOJO pojo, Date startTime, Date endTime); |
| | | } |
| | |
| | | return outputMap.get(outputid); |
| | | } |
| | | MmItemOutputEntity entity = mmItemOutputDao.selectById(outputid); |
| | | if (entity != null) { |
| | | outputMap.put(outputid, entity); |
| | | return entity; |
| | | } |
| | | return outputMap.get(outputid); |
| | | } |
| | | } |