diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java index 8202d5f..056f4a8 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java @@ -441,8 +441,9 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl csLinePOS = csLinePOService.findByNdid(csEquipmentDeliveryPo.getNdid()); - if(!csLinePOS.isEmpty() && csLinePOS.get(0)!=null){ - deviceManagerVo.setTime(csLinePOService.findByNdid(csEquipmentDeliveryPo.getNdid()).get(0).getCreateTime()); + if(!csLinePOS.isEmpty()){ + Optional earliest = csLinePOS.stream().min(Comparator.comparing(CsLinePO::getCreateTime)); + deviceManagerVo.setTime(earliest.map(CsLinePO::getCreateTime).orElse(null)); } } } diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java index fa2ab05..1629e27 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java @@ -667,19 +667,19 @@ public class DataServiceImpl implements IDataService { BeanUtils.copyProperties(vo1,vo); RealTimeDataVo phaseA = v.stream().filter(s->Objects.equals(s.getPhase(),"A") || Objects.equals(s.getPhase(),"AB")).findFirst().orElse(null); if (Objects.nonNull(phaseA)) { - vo.setValueA(phaseA.getAvgValue()); + vo.setValueA(Objects.isNull(phaseA.getAvgValue()) ? 3.14159 : phaseA.getAvgValue()); } RealTimeDataVo phaseB = v.stream().filter(s->Objects.equals(s.getPhase(),"B") || Objects.equals(s.getPhase(),"BC")).findFirst().orElse(null); if (Objects.nonNull(phaseB)) { - vo.setValueB(phaseB.getAvgValue()); + vo.setValueB(Objects.isNull(phaseB.getAvgValue()) ? 3.14159 : phaseB.getAvgValue()); } RealTimeDataVo phaseC = v.stream().filter(s->Objects.equals(s.getPhase(),"C") || Objects.equals(s.getPhase(),"CA")).findFirst().orElse(null); if (Objects.nonNull(phaseC)) { - vo.setValueC(phaseC.getAvgValue()); + vo.setValueC(Objects.isNull(phaseC.getAvgValue()) ? 3.14159 : phaseC.getAvgValue()); } RealTimeDataVo phaseM = v.stream().filter(s->Objects.equals(s.getPhase(),"M")).findFirst().orElse(null); if (Objects.nonNull(phaseM)) { - vo.setValueM(phaseM.getAvgValue()); + vo.setValueM(Objects.isNull(phaseM.getAvgValue()) ? 3.14159 : phaseM.getAvgValue()); } vo.setPhase("/"); vo.setAvgValue(null);