Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

1.算法问题排查

Browse Source
This commit is contained in:
cdf
2024-10-12 13:37:45 +08:00
parent 04ae4f1fc1
commit 99b56bffac
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
View File

@@ -118,6 +118,13 @@ public class IntegrityServiceImpl extends MppServiceImpl<RStatIntegrityDMapper,
RStatIntegrityD integrityDpo = new RStatIntegrityD(); RStatIntegrityD integrityDpo = new RStatIntegrityD();
integrityDpo.setTimeId(LocalDateTimeUtil.parseDate(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN)); integrityDpo.setTimeId(LocalDateTimeUtil.parseDate(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN));
integrityDpo.setLineIndex(item.getPointId()); integrityDpo.setLineIndex(item.getPointId());
if(Objects.isNull(item.getInterval())){
System.out.println("遇到空指针异常+++++++++++++++++++++++++++++++++"+item);
System.out.println("遇到空指针异常+++++++++++++++++++++++++++++++++"+item);
System.out.println("遇到空指针异常+++++++++++++++++++++++++++++++++"+item);
System.out.println(item.getPointId());
}
integrityDpo.setDueTime(InfluxDBTableConstant.DAY_MINUTE / item.getInterval()); integrityDpo.setDueTime(InfluxDBTableConstant.DAY_MINUTE / item.getInterval());
integrityDpo.setRealTime(countList.stream() integrityDpo.setRealTime(countList.stream()
.filter(item2 -> Objects.equals(item.getPointId(), item2.getLineId())) .filter(item2 -> Objects.equals(item.getPointId(), item2.getLineId()))

3
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RUploadSubstationStatisticalDataDServiceImpl.java
View File

@@ -114,6 +114,7 @@ public class RUploadSubstationStatisticalDataDServiceImpl extends MppServiceImpl
rUploadSubstationStatisticalDataD.setUploadStatus(Integer.parseInt(UploadEnum.UPLOAD_STATUS_0.getCode())); rUploadSubstationStatisticalDataD.setUploadStatus(Integer.parseInt(UploadEnum.UPLOAD_STATUS_0.getCode()));
if(pmsRunStatisticMap.containsKey(k)){ if(pmsRunStatisticMap.containsKey(k)){
System.out.println("进入当前步骤++++++++++++++++++++");
String runMonitorIds = pmsRunStatisticMap.get(dept.getCode()).getRunMonitorIds(); String runMonitorIds = pmsRunStatisticMap.get(dept.getCode()).getRunMonitorIds();
if(StrUtil.isNotBlank(runMonitorIds)){ if(StrUtil.isNotBlank(runMonitorIds)){
ArrayList<String> list1 = CollectionUtil.toList(runMonitorIds.split(StrUtil.COMMA)); ArrayList<String> list1 = CollectionUtil.toList(runMonitorIds.split(StrUtil.COMMA));
@@ -123,7 +124,9 @@ public class RUploadSubstationStatisticalDataDServiceImpl extends MppServiceImpl
} }
}else{ }else{
//计算在线监测点数 //计算在线监测点数
System.out.println("临时测试---------------"+deptChildren.size());
List<LineDevGetDTO> l = deptChildren.get(k).get(0).getLineBaseList(); List<LineDevGetDTO> l = deptChildren.get(k).get(0).getLineBaseList();
if (CollUtil.isNotEmpty(l)){ if (CollUtil.isNotEmpty(l)){
l = l.stream().filter(o->Objects.equals(o.getIsUpToGrid(),1)).collect(Collectors.toList()); l = l.stream().filter(o->Objects.equals(o.getIsUpToGrid(),1)).collect(Collectors.toList());
rUploadSubstationStatisticalDataD.setOnlineMonitorNum(l.size()); rUploadSubstationStatisticalDataD.setOnlineMonitorNum(l.size());