diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventM.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventM.java index a10d05f83..365f81560 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventM.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventM.java @@ -41,7 +41,7 @@ public class RStatEventM implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgM.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgM.java index 5ac02925b..1ecbfcf0e 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgM.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgM.java @@ -38,7 +38,7 @@ public class RStatEventOrgM implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgQ.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgQ.java index 85bf81fbf..44a727a94 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgQ.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgQ.java @@ -37,7 +37,7 @@ public class RStatEventOrgQ implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgY.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgY.java index f9c494706..69325f515 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgY.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventOrgY.java @@ -37,7 +37,7 @@ public class RStatEventOrgY implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventQ.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventQ.java index f6116e4d3..2f593e575 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventQ.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventQ.java @@ -41,7 +41,7 @@ public class RStatEventQ implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventVoltageM.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventVoltageM.java index 79b381403..f23a0d911 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventVoltageM.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventVoltageM.java @@ -44,7 +44,7 @@ public class RStatEventVoltageM implements Serializable { private String voltageType; @ApiModelProperty(value = "日均发生暂态监测点数") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventY.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventY.java index d41a0b0ab..8a253009a 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventY.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RStatEventY.java @@ -41,7 +41,7 @@ public class RStatEventY implements Serializable { private String eventType; @ApiModelProperty(value = "日均发生暂态监测点数(根据 发生暂态监测点数 取平均值)") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数(监测点暂态指标超标明细日表)") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatEventMVO.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatEventMVO.java index d2d530c1c..99ae40f75 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatEventMVO.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatEventMVO.java @@ -23,7 +23,7 @@ public class RStatEventMVO { private String eventName; @ApiModelProperty(value = "日均发生暂态监测点数") - private Integer eventMeasurementAverage; + private Float eventMeasurementAverage; @ApiModelProperty(value = "累计发生暂态监测点数") private Integer eventMeasurementAccrued; diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDetailServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDetailServiceImpl.java index 6d418ac47..e45ddeab0 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDetailServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDetailServiceImpl.java @@ -1,9 +1,11 @@ package com.njcn.event.service.majornetwork.Impl; import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.event.mapper.majornetwork.EventDetailMapper; import com.njcn.event.pojo.po.EventDetail; +import com.njcn.event.pojo.po.RmpEventDetailPO; import com.njcn.event.service.majornetwork.EventDetailService; -import com.njcn.influxdb.utils.AssembleSqlUtil; import com.njcn.influxdb.utils.InfluxDbUtils; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -23,7 +25,7 @@ import java.util.Objects; @Slf4j @Service @RequiredArgsConstructor -public class EventDetailServiceImpl implements EventDetailService { +public class EventDetailServiceImpl extends ServiceImpl implements EventDetailService { private final InfluxDbUtils influxDbUtils; diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventReportServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventReportServiceImpl.java index d16a23922..952559ded 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventReportServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventReportServiceImpl.java @@ -882,7 +882,7 @@ public class EventReportServiceImpl implements EventReportService { InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper(); List eventDetailList = influxDBResultMapper.toPOJO(monitorQuery, EventDetailNew.class); - Map> map = eventDetailList.stream().filter(x -> x.getWaveType()==1).collect(Collectors.groupingBy(s -> s.getTimeId().substring(0, 10))); + Map> map = eventDetailList.stream().filter(x -> x.getWaveType()=="1").collect(Collectors.groupingBy(s -> s.getTimeId().substring(0, 10))); Set keySet = map.keySet(); LocalDate parse1 = LocalDate.parse(startTime); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/RStatEventMServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/RStatEventMServiceImpl.java index c122b928b..9cd7d78da 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/RStatEventMServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/RStatEventMServiceImpl.java @@ -86,7 +86,7 @@ public class RStatEventMServiceImpl extends ServiceImpl