diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/LineTargetServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/LineTargetServiceImpl.java index e8030ff..3335e1e 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/LineTargetServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/LineTargetServiceImpl.java @@ -97,7 +97,6 @@ public class LineTargetServiceImpl implements ILineTargetService { String path = csPagePOService.queryById(id).getPath(); InputStream inputStream = fileStorageUtil.getFileStream(path); List list = analysisJson(inputStream); - //influx的原始方法获取数据 if (CollectionUtil.isNotEmpty(list)){ list.forEach(item->{ String targetTag = item.getTargetId().stream().reduce((first, second) -> second).orElse("no last element"); @@ -147,6 +146,13 @@ public class LineTargetServiceImpl implements ILineTargetService { */ public StatisticalDataDTO getLineRtData(String lineId, String tableName, String columnName, String phasic, String dataType, String target) { StatisticalDataDTO statisticalDataDTO = commonService.getLineRtData(lineId,tableName,columnName,phasic,dataType); + if(Objects.isNull(statisticalDataDTO)){ + statisticalDataDTO = new StatisticalDataDTO(); + statisticalDataDTO.setLineId(lineId); + statisticalDataDTO.setPhaseType(phasic); + statisticalDataDTO.setValueType(dataType); + statisticalDataDTO.setValue(3.1415926); + } statisticalDataDTO.setStatisticalName(target); return statisticalDataDTO; }