Microservice/govern
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码调整

Browse Source
This commit is contained in:
xuyang
2023-06-09 08:48:00 +08:00
parent 0b88a7a747
commit 5058931d4f
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/LineTargetServiceImpl.java
View File

@@ -97,7 +97,6 @@ public class LineTargetServiceImpl implements ILineTargetService {
String path = csPagePOService.queryById(id).getPath();
InputStream inputStream = fileStorageUtil.getFileStream(path);
List<ElementsVO> 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;
}