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

暂降系统优化influxdb转mysql

Browse Source
This commit is contained in:
wurui
2023-03-31 10:28:39 +08:00
parent 8c3ae3ef2b
commit 6237a7b656
23 changed files with 1619 additions and 1686 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LogManageServiceImpl.java
View File

@@ -105,7 +105,7 @@ public class LogManageServiceImpl implements LogManageService {
if (!CollectionUtils.isEmpty(eventDetailData)) {
for (EventPushLogs pushLogs: eventPushLogs) {
for (EventDetail eventDetail: eventDetailData) {
if (pushLogs.getLineId().equals(eventDetail.getLineId()) && pushLogs.getTimeId().equals(eventDetail.getTimeId())) {
if (pushLogs.getLineId().equals(eventDetail.getLineId()) && pushLogs.getTimeId().equals(eventDetail.getStartTime())) {
EventLogVO event = logManageMapper.getEventLogData(pushLogs.getLineId());
if (Objects.isNull(event)) {
continue;
@@ -119,11 +119,11 @@ public class LogManageServiceImpl implements LogManageService {
eventLogVO.setLine(event.getLine());
eventLogVO.setSubstation(event.getSubstation());
eventLogVO.setPowerCompany(event.getPowerCompany());
Double e = eventDetail.getEventValue();
Double e = eventDetail.getFeatureAmplitude();
BigDecimal bd = new BigDecimal(e);
e= bd.setScale(2, BigDecimal.ROUND_DOWN).doubleValue();
eventLogVO.setEventValue(String.valueOf(e*100));
double i = eventDetail.getPersistTime() / 1000;
double i = eventDetail.getDuration() / 1000;
eventLogVO.setPersistTime(String.valueOf(i));
eventLogVO.setCreatTime(pushLogs.getCreateTime());
eventLogVO.setCreatTimed(pushLogs.getCreateTime());

2
pqs-event/event-api/src/main/java/com/njcn/event/pojo/param/TransientParam.java
View File

@@ -45,7 +45,7 @@ public class TransientParam extends DeviceInfoParam.BusinessParam {
private BigDecimal severityMin;
@ApiModelProperty("触发类型")
private List<Integer> waveType;
private List<String> waveType;
@ApiModelProperty("暂降原因")
private List<String> eventReason;

114
pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetail.java
View File

@@ -1,14 +1,17 @@
package com.njcn.event.pojo.po;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.datatype.jsr310.ser.InstantSerializer;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement;
import java.math.BigDecimal;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.concurrent.TimeUnit;
/**
* @author denghuajun
@@ -20,81 +23,90 @@ import java.time.Instant;
@Measurement(name = "pqs_eventdetail")
public class EventDetail {
@Column(name = "line_id")
private String lineId;
@Column(name = "line_id")
private String lineId;
@Column(name = "time")
@JsonSerialize(using = InstantSerializer.class)
private Instant timeId;
@Column(name = "time")
@ApiModelProperty(value = "开始时间")
@JsonSerialize(using = InstantSerializer.class)
private Instant startTime;
@Column(name = "event_describe")
private String eventDescribe;
@Column(name = "event_describe")
@ApiModelProperty(value = "事件描述")
private String eventDescribe;
@Column(name = "wave_type")
private Integer waveType;
@Column(name = "wave_type")
@ApiModelProperty(value = "统计类型")
private String eventType;
@Column(name = "persist_time")
private Double persistTime;
@Column(name = "persist_time")
@ApiModelProperty(value = "持续时间，单位秒")
private Double duration;
@Column(name = "event_value")
private Double eventValue;
@Column(name = "event_value")
@ApiModelProperty(value = "特征幅值")
private Double featureAmplitude;
@Column(name = "event_reason")
private String eventReason;
@Column(name = "event_reason")
@ApiModelProperty(value = "暂降原因（Event_Reason）")
private String advanceReason;
@Column(name = "event_type")
private String eventType;
@Column(name = "event_type")
@ApiModelProperty(value = "暂降类型（Event_Type）")
private String advanceType;
@Column(name = "eventass_index")
private String eventassIndex;
@Column(name = "eventass_index")
private String eventassIndex;
@Column(name = "dq_time")
private Integer dqTime;
@Column(name = "dq_time")
private Integer dqTime;
@Column(name = "deal_time")
private String dealTime;
@Column(name = "deal_time")
private String dealTime;
@Column(name = "deal_flag")
private Integer dealFlag;
@Column(name = "deal_flag")
private Integer dealFlag;
@Column(name = "num")
private Integer num;
@Column(name = "num")
private Integer num;
@Column(name = "file_flag")
private Integer fileFlag;
@Column(name = "file_flag")
private Integer fileFlag;
@Column(name = "first_time")
private String firstTime;
@Column(name = "first_time")
private String firstTime;
@Column(name = "first_type")
private String firstType;
@Column(name = "first_type")
private String firstType;
@Column(name = "first_ms")
private Integer firstMs;
@Column(name = "first_ms")
private Integer firstMs;
@Column(name = "wave_name")
private String waveName;
@Column(name = "wave_name")
@ApiModelProperty(value = "波形路径")
private String wavePath;
@Column(name = "energy")
private Double energy;
@Column(name = "energy")
private Double energy;
@Column(name = "severity")
private Double severity;
@Column(name = "severity")
private Double severity;
@Column(name = "sagsource")
private String sagSource;
@Column(name = "sagsource")
private String sagSource;
@Column(name = "create_time")
private String createTime;
@Column(name = "create_time")
private String createTime;
private String lineName;
private String lineName;
private BigDecimal lat;
private BigDecimal lat;
private BigDecimal lng;
private BigDecimal lng;
private String gdName;
private String gdName;
private String subName;
private String subName;
}

117
pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetailNew.java
View File

@@ -1,8 +1,8 @@
package com.njcn.event.pojo.po;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement;
import java.math.BigDecimal;
@@ -13,87 +13,98 @@ import java.math.BigDecimal;
*/
@Data
@Measurement(name = "pqs_eventdetail")
//@Measurement(name = "pqs_eventdetail")
public class EventDetailNew {
@Column(name = "line_id")
private String lineId;
@Column(name = "line_id")
private String lineId;
@Column(name = "time")
private String timeId;
@Column(name = "time")
@ApiModelProperty(value = "开始时间")
private String startTime;
@Column(name = "event_describe")
private String eventDescribe;
@Column(name = "event_describe")
@ApiModelProperty(value = "事件描述")
private String eventDescribe;
@Column(name = "wave_type")
private String waveType;
@Column(name = "wave_type")
@ApiModelProperty(value = "统计类型")
private String eventType;
@Column(name = "persist_time")
private Double persistTime;
@Column(name = "persist_time")
@ApiModelProperty(value = "持续时间，单位秒")
private Double duration;
@Column(name = "event_value")
private Double eventValue;
@Column(name = "event_value")
@ApiModelProperty(value = "特征幅值")
private Double featureAmplitude;
@Column(name = "event_reason")
private String eventReason;
@Column(name = "event_reason")
@ApiModelProperty(value = "暂降原因（Event_Reason）")
private String advanceReason;
@Column(name = "event_type")
private String eventType;
@Column(name = "event_type")
@ApiModelProperty(value = "暂降类型（Event_Type）")
private String advanceType;
@Column(name = "eventass_index")
private String eventassIndex;
@Column(name = "eventass_index")
private String eventassIndex;
@Column(name = "dq_time")
private Integer dqTime;
@Column(name = "dq_time")
private Integer dqTime;
@Column(name = "deal_time")
private String dealTime;
@Column(name = "deal_time")
private String dealTime;
@Column(name = "deal_flag")
private Integer dealFlag;
@Column(name = "deal_flag")
private Integer dealFlag;
@Column(name = "num")
private Integer num;
@Column(name = "num")
private Integer num;
@Column(name = "file_flag")
private Integer fileFlag;
@Column(name = "file_flag")
private Integer fileFlag;
@Column(name = "first_time")
private String firstTime;
@Column(name = "first_time")
private String firstTime;
@Column(name = "first_type")
private String firstType;
@Column(name = "first_type")
private String firstType;
@Column(name = "first_ms")
private Integer firstMs;
@Column(name = "first_ms")
private Integer firstMs;
@Column(name = "wave_name")
private String waveName;
@Column(name = "wave_name")
@ApiModelProperty(value = "波形路径")
private String wavePath;
@Column(name = "energy")
private Double energy;
@Column(name = "energy")
private Double energy;
@Column(name = "severity")
private Double severity;
@Column(name = "severity")
private Double severity;
@Column(name = "sagsource")
private String sagSource;
@Column(name = "sagsource")
private String sagSource;
@Column(name = "create_time")
private String createTime;
@Column(name = "create_time")
private String createTime;
private String lineName;
private String lineName;
private BigDecimal lat;
private BigDecimal lat;
private BigDecimal lng;
private BigDecimal lng;
private String gdName;
private String gdName;
private String subName;
private String subName;
private String ip;
private String ip;
private String scale;
private String scale;
@ApiModelProperty(value = "暂时事件ID")
private String eventId;
}

33
pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RmpEventDetailPO.java
View File

@@ -1,6 +1,5 @@
package com.njcn.event.pojo.po;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
@@ -10,15 +9,12 @@ import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.influxdb.annotation.Column;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.Date;
/**
* (RMpEventDetail)实体类
* (influxdb 转 mysql 专用)实体类
*
* @author yzh
* @since 2022-10-12 18:34:55
@@ -37,12 +33,20 @@ public class RmpEventDetailPO implements Serializable {
@ApiModelProperty(value = "监测点ID")
private String measurementPointId;
@ApiModelProperty(value = "事件类型")
@ApiModelProperty(value = "监测点ID(复制)")
@TableField("measurement_point_id")
private String lineId;
@ApiModelProperty(value = "统计类型")
private String eventType;
@ApiModelProperty(value = "暂降原因（字典表PQS_Dicdata）")
@TableField("Event_Reason")
private String eventReason;
@ApiModelProperty(value = "暂降原因（Event_Reason）")
@TableField("advance_reason")
private String advanceReason;
@ApiModelProperty(value = "暂降类型（Event_Type）")
@TableField("advance_type")
private String advanceType;
@ApiModelProperty(value = "事件关联分析表Guid")
private String eventassIndex;
@@ -82,7 +86,8 @@ public class RmpEventDetailPO implements Serializable {
@ApiModelProperty(value = "开始时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS",timezone = "GMT+8")
private Date startTime;
private String startTime;
@ApiModelProperty(value = "持续时间，单位秒")
private Double duration;
@@ -99,14 +104,10 @@ public class RmpEventDetailPO implements Serializable {
@ApiModelProperty(value = "波形路径")
private String wavePath;
@ApiModelProperty(value = "波形名称")
@TableField("wave_path")
private String waveName;
private String phasicType;
private Double transientValue;
private String createTime;
}

2
pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/WaveTypeVO.java
View File

@@ -130,7 +130,7 @@ public class WaveTypeVO{
private String eventDescribe;
@Column(name = "wave_type")
private Integer waveType;
private String waveType;
@Column(name = "persist_time")
private Double persistTime;

4
pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/AreaStatisticalController.java
View File

@@ -21,7 +21,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* 区域统计
* 区域概览
*
* @author : zhaojun
* @version : 1.0.0
@@ -30,7 +30,7 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
@RequestMapping("/areaStatistics")
@Api(tags = "区域统计")
@Api(tags = "区域概览")
@AllArgsConstructor
public class AreaStatisticalController extends BaseController {

2
pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java
View File

@@ -156,7 +156,7 @@ public class PqsEventDetailQuery extends QueryBuilder {
*/
public static BiFunction<DateTime, DateTime, List<EventDetail>> getBetweenTimeEventDetailList(List<EventDetail> eventDetailList) {
return (beginTime, endTime) -> eventDetailList.stream().filter(eventDetail -> {
Instant timeId = eventDetail.getTimeId();
Instant timeId = eventDetail.getStartTime();
return timeId.isAfter(beginTime.toInstant()) && timeId.isBefore(endTime.toInstant());
}).collect(Collectors.toList());
}

9
pqs-event/event-boot/src/main/java/com/njcn/event/service/distribution/Impl/PwEventCategoryDetailsServiceImpl.java
View File

@@ -341,10 +341,11 @@ public class PwEventCategoryDetailsServiceImpl implements PwEventCategoryDetails
eventFeatureAmplitudeCurve.setFeatureAmplitude(dto.getFeatureAmplitude());
eventFeatureAmplitudeCurve.setDuration(dto.getDuration());
Instant instant = dto.getStartTime().toInstant();
ZoneId zoneId = ZoneId.systemDefault();
eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.ofInstant(instant, zoneId));
// Instant instant = dto.getStartTime().toInstant();
// ZoneId zoneId = ZoneId.systemDefault();
//
// eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.ofInstant(instant, zoneId));
eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.parse( dto.getStartTime()));
return eventFeatureAmplitudeCurve;
})

2
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/EventDetailService.java
View File

@@ -37,5 +37,5 @@ public interface EventDetailService extends IService<RmpEventDetailPO> {
/**
* 根据监测点集合以及分页信息获取暂降事件
*/
List<EventDetail> getEventDetailLimit(List<String> lineIndexes, String startTime, String endTime, Integer pageSize, Integer pageNum, List<Integer> waveType);
List<EventDetail> getEventDetailLimit(List<String> lineIndexes, String startTime, String endTime, Integer pageSize, Integer pageNum, List<String> waveType);
}

106
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java
View File

@@ -1,6 +1,12 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.C;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.db.bo.BaseEntity;
import com.njcn.device.pq.api.GeneralDeviceInfoClient;
import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.device.pq.pojo.dto.GeneralDeviceDTO;
@@ -8,14 +14,18 @@ import com.njcn.device.pq.pojo.param.DeviceInfoParam;
import com.njcn.device.pq.pojo.vo.AreaLineInfoVO;
import com.njcn.event.influxdb.PqsEventDetailQuery;
import com.njcn.event.pojo.po.EventDetail;
import com.njcn.event.pojo.po.RStatEventY;
import com.njcn.event.pojo.po.RmpEventDetailPO;
import com.njcn.event.pojo.vo.AreaAnalysisVO;
import com.njcn.event.pojo.vo.VoltageToleranceCurveVO;
import com.njcn.event.pojo.vo.VoltageToleranceCurveVO.VoltageToleranceCurveDataList;
import com.njcn.event.service.majornetwork.AreaAnalysisService;
import com.njcn.event.service.majornetwork.EventDetailService;
import com.njcn.system.api.DicDataFeignClient;
import com.njcn.system.enums.DicDataTypeEnum;
import com.njcn.system.pojo.po.DictData;
import lombok.RequiredArgsConstructor;
import lombok.Value;
import org.influxdb.querybuilder.clauses.Clause;
import org.springframework.stereotype.Service;
@@ -45,7 +55,7 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
private final LineFeignClient lineFeignClient;
private final PqsEventDetailQuery pqsEventDetailQuery;
private final EventDetailService eventDetailService;
@Override
public AreaAnalysisVO getEventReason(DeviceInfoParam.BusinessParam deviceInfoParam) {
AreaAnalysisVO areaAnalysisVO = new AreaAnalysisVO();
@@ -55,7 +65,17 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData();
List<String> lineIds = getAllLineIdList(generalDeviceDTOList);
List<AreaAnalysisVO.Children> reasonList = assData(dicReasonList, lineIds, deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(), "event_reason");
//查询数据
// List<AreaAnalysisVO.Children> reasonList = assData(dicReasonList, lineIds, deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(), "event_reason");
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIds)
.in(RmpEventDetailPO::getAdvanceReason, dicReasonList.stream().map(DictData::getId).collect(Collectors.toList()))
.in(RmpEventDetailPO::getAdvanceType, dicTypeList.stream().map(DictData::getId).collect(Collectors.toList()))
.ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime, DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
.le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())))
);
List<AreaAnalysisVO.Children> reasonList = assDataPQ(info, dicReasonList);
//暂降类型特殊处理
DictData dictData = dicReasonList.stream().filter(item->"短路故障".equals(item.getName())).findFirst().get();
@@ -72,7 +92,8 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
stringListMap.put("相间故障",dicIdsXi);
stringListMap.put("未知",dicIdsOther);
List<AreaAnalysisVO.Children> typeList = assReason(stringListMap,lineIds,deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(),dictData.getId());
// List<AreaAnalysisVO.Children> typeList = assReason(stringListMap,lineIds,deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(),dictData.getId());
List<AreaAnalysisVO.Children> typeList = assReasonPQ(stringListMap, info, dictData.getId());
areaAnalysisVO.setReason(reasonList);
areaAnalysisVO.setType(typeList);
@@ -107,9 +128,17 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
getBaseLineAreaInfo.parallelStream().collect(Collectors.toConcurrentMap(AreaLineInfoVO::getLineId,
Function.identity()));
List<EventDetail> eventDetailList = pqsEventDetailQuery.selectList(Arrays.asList("time","line_id", "persist_time", "event_value"),
lineIdOr(lineIds), timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()),
endOfDay(deviceInfoParam.getSearchEndTime())));
// List<EventDetail> eventDetailList = pqsEventDetailQuery.selectList(Arrays.asList("time","line_id", "persist_time", "event_value"),
// lineIdOr(lineIds), timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()),
// endOfDay(deviceInfoParam.getSearchEndTime())));
//数据暂降查询
List<RmpEventDetailPO> infoPo = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIds)
.ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
.le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())))
);
List<EventDetail> eventDetailList= BeanUtil.copyToList(infoPo,EventDetail.class);
if (CollUtil.isEmpty(eventDetailList)) {
return VoltageToleranceCurveVO.empty();
}
@@ -120,9 +149,9 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
VoltageToleranceCurveDataList voltageToleranceCurve = new VoltageToleranceCurveDataList();
voltageToleranceCurve.setLineId(dto.getLineId());
voltageToleranceCurve.setPersistTime(dto.getPersistTime());
voltageToleranceCurve.setEventValue(dto.getEventValue());
voltageToleranceCurve.setTime(LocalDateTime.ofInstant(dto.getTimeId(), ZoneId.systemDefault()));
voltageToleranceCurve.setPersistTime(dto.getDuration());
voltageToleranceCurve.setEventValue(dto.getFeatureAmplitude());
voltageToleranceCurve.setTime(LocalDateTime.ofInstant(dto.getStartTime(), ZoneId.systemDefault()));
voltageToleranceCurve.setGdName(info.getGdName());
voltageToleranceCurve.setSubName(info.getSubName());
return voltageToleranceCurve;
@@ -143,6 +172,65 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
return generalDeviceDTOList.stream().flatMap(dto -> dto.getLineIndexes().stream()).collect(Collectors.toList());
}
private List<AreaAnalysisVO.Children> assDataPQ(List<RmpEventDetailPO> info,List<DictData> dicReasonList) {
List<AreaAnalysisVO.Children> reasonList = new ArrayList<>();
//根据暂降原因分组
Map<String, String> reasonMap = dicReasonList.stream().collect(Collectors.toMap(DictData::getId,DictData::getName));
//将数据进行分组
Map<String, Long> infoMap = info.stream().collect(Collectors.groupingBy(
x->{
return reasonMap.get(x.getAdvanceReason());
}, Collectors.counting()));
//排除不存在的字典数据集合
List<DictData> notDicData = dicReasonList.stream().filter(r -> !infoMap.containsKey(r.getName()))
.collect(Collectors.toList());
AreaAnalysisVO.Children allType ;
if(CollUtil.isNotEmpty(notDicData)){
for (DictData notDicDatum : notDicData) {
allType = new AreaAnalysisVO.Children();
allType.setName(notDicDatum.getName());
allType.setValue(0);
reasonList.add(allType);
}
}
Integer allCount = 0;
for (String s : infoMap.keySet()) {
allType = new AreaAnalysisVO.Children();
allType.setName(s);
int count = Math.toIntExact(infoMap.get(s));
allType.setValue(count);
allCount += count;
reasonList.add(allType);
}
AreaAnalysisVO.Children zj = new AreaAnalysisVO.Children();
zj.setName("总计");
zj.setValue(allCount);
reasonList.add(zj);
return reasonList;
}
private List<AreaAnalysisVO.Children> assReasonPQ(Map<String, List<String>> stringListMap, List<RmpEventDetailPO> info, String typeId){
List<AreaAnalysisVO.Children> reasonList = new ArrayList<>();
List<RmpEventDetailPO> reasons = info.stream().filter(x -> typeId.equals(x.getAdvanceReason())).collect(Collectors.toList());
Integer allCount = 0;
for (Map.Entry<String, List<String>> stringListEntry : stringListMap.entrySet()) {
List<String> value = stringListEntry.getValue();
Integer count = Math.toIntExact(reasons.stream().filter(x -> value.contains(x)).count());
AreaAnalysisVO.Children allType = new AreaAnalysisVO.Children();
allType.setName(stringListEntry.getKey());
allType.setValue(count);
allCount += count;
reasonList.add(allType);
}
AreaAnalysisVO.Children allType = new AreaAnalysisVO.Children();
allType.setName("总计");
allType.setValue(allCount);
reasonList.add(allType);
return reasonList;
}
private List<AreaAnalysisVO.Children> assData(List<DictData> dicList, List<String> lineIds, String startTime, String endTime, String type) {
List<AreaAnalysisVO.Children> reasonList = new ArrayList<>();

72
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java
View File

@@ -91,32 +91,7 @@ public class AreaInfoServiceImpl implements AreaInfoService {
}
}
//查询监测点未处理暂态事件
// StringBuilder lineIdsStr = InfluxDBCommUtils.assToInfluxParam(lineIds);
//
// String stringResult = "SELECT count(eventass_index) FROM " + Param.EVENT_DETAIL + Param.WHERE + "time >= '" + deviceInfoParam.getSearchBeginTime() + InfluxDBPublicParam.START_TIME + "' and " + "time <= '" + deviceInfoParam.getSearchEndTime() + InfluxDBPublicParam.END_TIME + "' and " + lineIdsStr + " and eventass_index = '' group by line_id" + InfluxDBPublicParam.TIME_ZONE;
// // 结果集
// QueryResult result = influxDbUtils.query(stringResult);
// if (!result.hasError()) {
// List<QueryResult.Series> list = result.getResults().get(0).getSeries();
//
// for (AreaLineInfoVO areaLineInfoVO : resList) {
// boolean flag = false;
// if(CollectionUtil.isNotEmpty(list)) {
// for (QueryResult.Series tem : list) {
// String lineId = tem.getTags().get("line_id");
// if (areaLineInfoVO.getLineId().equals(lineId)) {
// areaLineInfoVO.setNoDealCount(Double.valueOf(tem.getValues().get(0).get(1).toString()).intValue());
// flag = true;
// break;
// }
// }
// }
// if (!flag) {
// areaLineInfoVO.setNoDealCount(0);
// }
// }
// }
//组装成变电站
if (CollectionUtil.isNotEmpty(resList)) {
Map<String, List<AreaLineInfoVO>> map = resList.stream().collect(Collectors.groupingBy(AreaLineInfoVO::getSubId));
@@ -164,9 +139,9 @@ public class AreaInfoServiceImpl implements AreaInfoService {
//监测点id
eventDetailNew.setLineId(eventDetail.getMeasurementPointId());
//持续时间
eventDetailNew.setPersistTime(eventDetail.getDuration());
eventDetailNew.setDuration(eventDetail.getDuration());
//特征幅值
eventDetailNew.setEventValue(eventDetail.getFeatureAmplitude());
eventDetailNew.setFeatureAmplitude(eventDetail.getFeatureAmplitude());
if(lineMap.containsKey(eventDetail.getMeasurementPointId())){
AreaLineInfoVO areaLineInfoVO = lineMap.get(eventDetail.getMeasurementPointId());
eventDetailNew.setLineName(areaLineInfoVO.getLineName());
@@ -177,28 +152,6 @@ public class AreaInfoServiceImpl implements AreaInfoService {
}
// //查询监测点未处理暂态事件
// StringBuilder lineIdsStr = InfluxDBCommUtils.assToInfluxParam(lineIds);
//
// String stringResult = "SELECT * FROM " + Param.EVENT_DETAIL + Param.WHERE + lineIdsStr + "and eventass_index = '' order by time desc limit 100" + InfluxDBPublicParam.TIME_ZONE;
// // 结果集
// QueryResult result = influxDbUtils.query(stringResult);
// // 结果集映射到对象中
// InfluxDBResultMapperCn influxDBResultMapper = new InfluxDBResultMapperCn();
// resList = influxDBResultMapper.toPOJO(result, EventDetailNew.class);
// //对未处理暂降事件的监测点替换成中文名称
// if (CollectionUtil.isNotEmpty(resList)) {
// for (EventDetailNew eventDetail : resList) {
// for (AreaLineInfoVO tem : lineList) {
// if (eventDetail.getLineId().equals(tem.getLineId())) {
// eventDetail.setLineName(tem.getLineName());
// eventDetail.setLng(tem.getLng());
// eventDetail.setLat(tem.getLat());
// break;
// }
// }
// }
// }
}
return resList;
}
@@ -217,9 +170,9 @@ public class AreaInfoServiceImpl implements AreaInfoService {
//监测点id
eventDetailNew.setLineId(eventDetail.getMeasurementPointId());
//持续时间
eventDetailNew.setPersistTime(eventDetail.getDuration());
eventDetailNew.setDuration(eventDetail.getDuration());
//特征幅值
eventDetailNew.setEventValue(eventDetail.getFeatureAmplitude());
eventDetailNew.setFeatureAmplitude(eventDetail.getFeatureAmplitude());
if(CollectionUtil.isNotEmpty(lineList)){
resList = resList.stream().peek(item->{
item.setGdName(lineList.get(0).getGdName());
@@ -230,22 +183,7 @@ public class AreaInfoServiceImpl implements AreaInfoService {
}
}
// String stringResult = "SELECT * FROM " + Param.EVENT_DETAIL + Param.WHERE + "line_id = '"+id+"' and eventass_index = '' order by time desc limit 100" + InfluxDBPublicParam.TIME_ZONE;
// // 结果集
// QueryResult result = influxDbUtils.query(stringResult);
// // 结果集映射到对象中
// InfluxDBResultMapperCn influxDBResultMapper = new InfluxDBResultMapperCn();
// List<EventDetailNew> resList = influxDBResultMapper.toPOJO(result, EventDetailNew.class);
// List<AreaLineInfoVO> lineList = lineFeignClient.getBaseLineAreaInfo(Stream.of(id).collect(Collectors.toList())).getData();
// if(CollectionUtil.isNotEmpty(lineList)){
// resList = resList.stream().peek(item->{
// item.setGdName(lineList.get(0).getGdName());
// item.setSubName(lineList.get(0).getSubName());
// item.setLineName(lineList.get(0).getLineName());
// }).collect(Collectors.toList());
// }
return resList;
}

24
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java
View File

@@ -1,7 +1,10 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.common.pojo.enums.common.ServerEnum;
import com.njcn.device.pq.api.GeneralDeviceInfoClient;
import com.njcn.device.pq.api.LineFeignClient;
@@ -14,10 +17,12 @@ import com.njcn.event.influxdb.PqsOnlinerateQuery;
import com.njcn.event.mapper.majornetwork.PqDeviceMapper;
import com.njcn.event.pojo.po.PqDevice;
import com.njcn.event.pojo.po.PqsOnlinerate;
import com.njcn.event.pojo.po.RmpEventDetailPO;
import com.njcn.event.pojo.vo.*;
import com.njcn.event.pojo.vo.TerminalRunningStatisticsVO.TerminalRunningInfoVO;
import com.njcn.event.pojo.vo.TerminalRunningStatisticsVO.TerminalRunningVO;
import com.njcn.event.service.majornetwork.AreaLineService;
import com.njcn.event.service.majornetwork.EventDetailService;
import com.njcn.influxdb.param.InfluxDBPublicParam;
import com.njcn.influxdb.utils.InfluxDbUtils;
import com.njcn.system.pojo.enums.StatisticsEnum;
@@ -56,6 +61,8 @@ public class AreaLineServiceImpl implements AreaLineService {
private final PqsOnlinerateQuery pqsOnlinerateQuery;
private final PqDeviceMapper pqDeviceMapper;
private final EventDetailService eventDetailService;
@Override
public AreaLineVO getAreaLineVO(DeviceInfoParam deviceInfoParam) {
@@ -161,7 +168,14 @@ public class AreaLineServiceImpl implements AreaLineService {
// 获取暂降数据
if (lineIndexs.size() > 0) {
int tail = 0;
List<EventHeatDeatilVO> eventdetailList = getContion(deviceInfoParam, lineIndexs);
// List<EventHeatDeatilVO> eventdetailList = getContion(deviceInfoParam, lineIndexs);
//数据暂降查询
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIndexs)
.ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
.le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())))
);
List<EventHeatDeatilVO> eventdetailList= BeanUtil.copyToList(info,EventHeatDeatilVO.class);
if (eventdetailList.size() > 0) {
List<String> lineIds = eventdetailList.stream().map(EventHeatDeatilVO::getLineId).collect(Collectors.toList());
List<AreaLineInfoVO> areaAnalysisVOList = lineFeignClient.getBaseLineAreaInfo(lineIds).getData();
@@ -216,7 +230,13 @@ public class AreaLineServiceImpl implements AreaLineService {
if (lineIndexs.size() > 0) {
int tail = 0;
EventSeverityValueVO eventSeverityValueVO = new EventSeverityValueVO();
List<EventHeatDeatilVO> eventdetailList = getContion(deviceInfoParam, lineIndexs);
// List<EventHeatDeatilVO> eventdetailList = getContion(deviceInfoParam, lineIndexs);
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIndexs)
.ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
.le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())))
);
List<EventHeatDeatilVO> eventdetailList= BeanUtil.copyToList(info,EventHeatDeatilVO.class);
if (eventdetailList.size() > 0) {
for (int eventNum = 0; eventNum < eventdetailList.size(); eventNum++) {
tail += eventdetailList.get(eventNum).getCount();

32
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaStatisticalServiceImpl.java
View File

@@ -1,15 +1,19 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.device.pq.api.GeneralDeviceInfoClient;
import com.njcn.device.pq.pojo.dto.GeneralDeviceDTO;
import com.njcn.device.pq.pojo.param.DeviceInfoParam;
import com.njcn.event.influxdb.PqsEventDetailQuery;
import com.njcn.event.pojo.po.EventDetail;
import com.njcn.event.pojo.po.RmpEventDetailPO;
import com.njcn.event.pojo.vo.AreaCalculationVO;
import com.njcn.event.pojo.vo.AreaStatisticalVO;
import com.njcn.event.pojo.vo.AreaStatisticalVO.AreaStatisticsVO;
@@ -18,7 +22,11 @@ import com.njcn.event.pojo.vo.AreaStatisticalVO.VoltageStatisticsVO;
import com.njcn.event.pojo.vo.MonthCalculationVO;
import com.njcn.event.pojo.vo.VoltageLevelCalculationVO;
import com.njcn.event.service.majornetwork.AreaStatisticalService;
import com.njcn.event.service.majornetwork.EventDetailService;
import com.njcn.system.api.DicDataFeignClient;
import com.njcn.system.enums.DicDataEnum;
import com.njcn.system.pojo.enums.StatisticsEnum;
import com.njcn.system.pojo.po.DictData;
import lombok.RequiredArgsConstructor;
import org.influxdb.querybuilder.clauses.Clause;
import org.springframework.stereotype.Service;
@@ -47,6 +55,9 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService {
private final PqsEventDetailQuery pqsEventDetailQuery;
private final EventDetailService eventDetailService;
private final DicDataFeignClient dicDataFeignClient;
/**
* 获取暂降区域 电压等级 月份统计
*
@@ -55,6 +66,9 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService {
*/
@Override
public AreaStatisticalVO getAreaCalculation(DeviceInfoParam.BusinessParam deviceInfoParam) {
//获取录波字典信息
DictData data = dicDataFeignClient.getDicDataByCode(DicDataEnum.RECORDING_WAVE.getCode()).getData();
// 获取指定部门下的监测点集合
List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData();
if (CollUtil.isEmpty(generalDeviceDTOList)) {
@@ -65,10 +79,20 @@ public class AreaStatisticalServiceImpl implements AreaStatisticalService {
return AreaStatisticalVO.empty();
}
List<Clause> clauseList = new ArrayList<>(timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime())));
clauseList.add(ne("wave_type",5));
List<EventDetail> eventDetailList = pqsEventDetailQuery.selectList(Arrays.asList("line_id", "eventass_index"),
lineIdOr(lineIds),clauseList);
// List<Clause> clauseList = new ArrayList<>(timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime())));
// clauseList.add(ne("wave_type",5));
// List<EventDetail> cc = pqsEventDetailQuery.selectList(Arrays.asList("line_id", "eventass_index"),
// lineIdOr(lineIds),clauseList);
//数据暂降查询
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIds)
//todo 是否缺少录波
.eq(RmpEventDetailPO::getEventType, data.getId())
.ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
.le(StrUtil.isNotBlank(deviceInfoParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())))
);
List<EventDetail> eventDetailList = BeanUtil.copyToList(info,EventDetail.class);
if (CollUtil.isEmpty(eventDetailList)) {
return AreaStatisticalVO.empty();
}

664
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventAnalysisServiceImpl.java
View File

@@ -1,6 +1,7 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -146,13 +147,14 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
@Override
public List<CoordsVO> getCoords(StatisticsParam statisticsParam) {
List<CoordsVO> result = new ArrayList<>();
// QueryResult query = MonitorQuery(statisticsParam);
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// List<EventDetail> info = influxDBResultMapper.toPOJO(query, EventDetail.class);
//查询监测点未处理暂态事件
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.ge(StringUtils.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime())))
.le(StringUtils.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime())))
);
@@ -388,8 +390,8 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
}
}
for (int i = 0; i < info.size(); i++) {
Double eventvalue = info.get(i).getEventValue();
double persisttime = info.get(i).getPersistTime();
Double eventvalue = info.get(i).getFeatureAmplitude();
double persisttime = info.get(i).getDuration();
if (eventvalue * 100 < 10) {
if (persisttime < 20) {
arr[4][0]++;
@@ -500,7 +502,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
//查询监测点未处理暂态事件
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.ge(StringUtils.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime())))
.le(StringUtils.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime())))
);
@@ -576,8 +578,8 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
}
}
for (int i = 0; i < info.size(); i++) {
Double eventvalue = info.get(i).getEventValue();
double persisttime = info.get(i).getPersistTime();
Double eventvalue = info.get(i).getFeatureAmplitude();
double persisttime = info.get(i).getDuration();
if (eventvalue * 100 < 1 && eventvalue * 100 >= 0) {
if (persisttime > 10 && persisttime <= 100) {
arr[16][0]++;
@@ -941,6 +943,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
} else {
builder2.append(startYear).append("-").append(startMonth + 1).append("-").append(startDays);
}
// query = MonitorQuery(new StatisticsParam(statisticsParam.getLineIndex(),builder1.toString(), builder2.toString(), statisticsParam.getFlag()));
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(query, EventDetail.class);
@@ -996,7 +999,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
);
Map<String, List<RmpEventDetailPO>> map = eventDetailList.stream().filter(x -> data.getId().equals(x.getEventType()))
.collect(Collectors.groupingBy(s -> DateUtil.format(s.getStartTime(), "yyyy-MM-dd")));
.collect(Collectors.groupingBy(s -> s.getStartTime().substring(0, 10)));
Set<String> keySet = map.keySet();
LocalDate parse1 = LocalDate.parse(startTime);
@@ -1049,46 +1052,59 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
List<EventDetail> list = new ArrayList<>();
List<ReasonsVO> reasonsVOS = new ArrayList<>();
List<TypesVO> typesVOS = new ArrayList<>();
List<EventDetail> info = new ArrayList<>();
QueryResult query = MonitorQuery(statisticsParam);
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
info = influxDBResultMapper.toPOJO(query, EventDetail.class);
// List<EventDetail> info = new ArrayList<>();
// QueryResult query = MonitorQuery(statisticsParam);
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// info = influxDBResultMapper.toPOJO(query, EventDetail.class);
//数据暂降查询
List<RmpEventDetailPO> info = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.ge(StringUtils.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime())))
.le(StringUtils.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime())))
);
HttpResult<List<DictData>> reason = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName());
HttpResult<List<DictData>> type = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName());
List<DictData> reasonData = reason.getData();
List<DictData> typeData = type.getData();
//获取暂降字典信息
DictData dataDto = dicDataFeignClient.getDicDataByCode(DicDataEnum.VOLTAGE_DIP.getCode()).getData();
HashMap<String, Integer> reasonMap = new HashMap<>();
HashMap<String, Integer> typeMap = new HashMap<>();
//添加detail
for (EventDetail detail : info) {
if (detail.getWaveType() == 1) {
for (RmpEventDetailPO detail : info) {
EventDetail details = null;
if (dataDto.getId() .equals(detail.getEventType())) {
for (DictData data : reasonData) {
reasonMap.put(data.getName(),0);
if (detail.getEventReason().equals(data.getId())) {
detail.setEventReason(data.getName());
if (detail.getAdvanceReason().equals(data.getId())) {
details=BeanUtil.copyProperties(detail,EventDetail.class);
details.setAdvanceReason(data.getName());
}
}
for (DictData data : typeData) {
typeMap.put(data.getName(),0);
if (detail.getEventType().equals(data.getId())) {
detail.setEventType(data.getName());
if (detail.getAdvanceType().equals(data.getId())) {
details=BeanUtil.copyProperties(detail,EventDetail.class);
detail.setAdvanceType(data.getName());
}
}
list.add(detail);
list.add(details);
}
}
//添加reason到map
for (EventDetail data : list) {
if (reasonMap.get(data.getEventReason()) != null) {
reasonMap.put(data.getEventReason(), reasonMap.get(data.getEventReason()) + 1);
if (reasonMap.get(data.getAdvanceReason()) != null) {
reasonMap.put(data.getAdvanceReason(), reasonMap.get(data.getAdvanceReason()) + 1);
}
}
//添加type到map
for (EventDetail data : list) {
if (typeMap.get(data.getEventType()) != null) {
typeMap.put(data.getEventType(), typeMap.get(data.getEventType()) + 1);
if (typeMap.get(data.getAdvanceType()) != null) {
typeMap.put(data.getAdvanceType(), typeMap.get(data.getAdvanceType()) + 1);
}
}
Set<String> reasonKeyset = reasonMap.keySet();
@@ -1116,14 +1132,21 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
public ProbabilityVO getProbabilityDistribution(StatisticsParam statisticsParam) {
ProbabilityVO result = new ProbabilityVO();
List<EventDetail> info = new ArrayList<>();
QueryResult query = MonitorQuery(statisticsParam);
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetail> info2 = influxDBResultMapper.toPOJO(query, EventDetail.class);
// QueryResult query = MonitorQuery(statisticsParam);
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// List<EventDetail> info2 = influxDBResultMapper.toPOJO(query, EventDetail.class);
//数据暂降查询
List<RmpEventDetailPO> infos = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.ge(StringUtils.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime())))
.le(StringUtils.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime())))
);
List<EventDetail> info2 = BeanUtil.copyToList(infos, EventDetail.class);
//总数
Integer count = 0;
for (EventDetail eventDetail : info2) {
//过滤掉大于0.9的数据
if (eventDetail.getEventValue() <= 0.9) {
if (eventDetail.getFeatureAmplitude() <= 0.9) {
count++;
info.add(eventDetail);
}
@@ -1152,53 +1175,53 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
subsectionMap.put("80~90", 0);
//求数量
for (EventDetail eventDetail : info) {
if (eventDetail.getEventValue() < 0.1) {
if (eventDetail.getFeatureAmplitude() < 0.1) {
countMap.put("<10", (countMap.get("<10") + 1));
}
if (eventDetail.getEventValue() < 0.2) {
if (eventDetail.getFeatureAmplitude() < 0.2) {
countMap.put("<20", (countMap.get("<20") + 1));
}
if (eventDetail.getEventValue() < 0.3) {
if (eventDetail.getFeatureAmplitude() < 0.3) {
countMap.put("<30", (countMap.get("<30") + 1));
}
if (eventDetail.getEventValue() < 0.4) {
if (eventDetail.getFeatureAmplitude() < 0.4) {
countMap.put("<40", (countMap.get("<40") + 1));
}
if (eventDetail.getEventValue() < 0.5) {
if (eventDetail.getFeatureAmplitude() < 0.5) {
countMap.put("<50", (countMap.get("<50") + 1));
}
if (eventDetail.getEventValue() < 0.6) {
if (eventDetail.getFeatureAmplitude() < 0.6) {
countMap.put("<60", (countMap.get("<60") + 1));
}
if (eventDetail.getEventValue() < 0.7) {
if (eventDetail.getFeatureAmplitude() < 0.7) {
countMap.put("<70", (countMap.get("<70") + 1));
}
if (eventDetail.getEventValue() < 0.8) {
if (eventDetail.getFeatureAmplitude() < 0.8) {
countMap.put("<80", (countMap.get("<80") + 1));
}
if (eventDetail.getEventValue() < 0.9) {
if (eventDetail.getFeatureAmplitude() < 0.9) {
countMap.put("<90", (countMap.get("<90") + 1));
}
}
//求每段数量
for (EventDetail eventDetail : info) {
if (eventDetail.getEventValue() < 0.1) {
if (eventDetail.getFeatureAmplitude() < 0.1) {
subsectionMap.put("0~10", (subsectionMap.get("0~10") + 1));
} else if (eventDetail.getEventValue() > 0.1 && eventDetail.getEventValue() < 0.2) {
} else if (eventDetail.getFeatureAmplitude() > 0.1 && eventDetail.getFeatureAmplitude() < 0.2) {
subsectionMap.put("10~20", (subsectionMap.get("10~20") + 1));
} else if (eventDetail.getEventValue() > 0.2 && eventDetail.getEventValue() < 0.3) {
} else if (eventDetail.getFeatureAmplitude() > 0.2 && eventDetail.getFeatureAmplitude() < 0.3) {
subsectionMap.put("20~30", (subsectionMap.get("20~30") + 1));
} else if (eventDetail.getEventValue() > 0.3 && eventDetail.getEventValue() < 0.4) {
} else if (eventDetail.getFeatureAmplitude() > 0.3 && eventDetail.getFeatureAmplitude() < 0.4) {
subsectionMap.put("30~40", (subsectionMap.get("30~40") + 1));
} else if (eventDetail.getEventValue() > 0.4 && eventDetail.getEventValue() < 0.5) {
} else if (eventDetail.getFeatureAmplitude() > 0.4 && eventDetail.getFeatureAmplitude() < 0.5) {
subsectionMap.put("40~50", (subsectionMap.get("40~50") + 1));
} else if (eventDetail.getEventValue() > 0.5 && eventDetail.getEventValue() < 0.6) {
} else if (eventDetail.getFeatureAmplitude() > 0.5 && eventDetail.getFeatureAmplitude() < 0.6) {
subsectionMap.put("50~60", (subsectionMap.get("50~60") + 1));
} else if (eventDetail.getEventValue() > 0.6 && eventDetail.getEventValue() < 0.7) {
} else if (eventDetail.getFeatureAmplitude() > 0.6 && eventDetail.getFeatureAmplitude() < 0.7) {
subsectionMap.put("60~70", (subsectionMap.get("60~70") + 1));
} else if (eventDetail.getEventValue() > 0.7 && eventDetail.getEventValue() < 0.8) {
} else if (eventDetail.getFeatureAmplitude() > 0.7 && eventDetail.getFeatureAmplitude() < 0.8) {
subsectionMap.put("70~80", (subsectionMap.get("70~80") + 1));
} else if (eventDetail.getEventValue() > 0.8 && eventDetail.getEventValue() < 0.9) {
} else if (eventDetail.getFeatureAmplitude() > 0.8 && eventDetail.getFeatureAmplitude() < 0.9) {
subsectionMap.put("80~90", (subsectionMap.get("80~90") + 1));
}
}
@@ -1276,7 +1299,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
timeMap.put("<180", 0);
//求不同时间段的总数
for (EventDetail eventDetail : info) {
Double persistTime = eventDetail.getPersistTime();
Double persistTime = eventDetail.getDuration();
if (persistTime / 1000 < 0.1) {
timeMap.put("<0.1", timeMap.get("<0.1") + 1);
} else if (persistTime / 1000 > 0.1 && persistTime / 1000 < 0.25) {
@@ -1337,7 +1360,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
//求sisttime
List<String> sisttime = new ArrayList<>();
for (EventDetail eventDetail : info) {
Double persistTime = eventDetail.getPersistTime();
Double persistTime = eventDetail.getDuration();
if (persistTime / 1000 < 0.1) {
timeMap2.put("<0.1", timeMap2.get("<0.1") + 1);
}
@@ -1415,7 +1438,7 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
// }
//查询监测点未处理暂态事件
List<RmpEventDetailPO> eventDetails = eventDetailService.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.eq(RmpEventDetailPO::getMeasurementPointId, statisticsParam.getLineIndex())
.ge(StringUtils.isNotBlank(statisticsParam.getStartTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(statisticsParam.getStartTime())))
.le(StringUtils.isNotBlank(statisticsParam.getEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(statisticsParam.getEndTime())))
);
@@ -1433,21 +1456,21 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
//监测点id
eventDetailNew.setLineId(eventDetail.getMeasurementPointId());
//持续时间
eventDetailNew.setPersistTime(eventDetail.getDuration());
eventDetailNew.setDuration(eventDetail.getDuration());
//特征幅值
eventDetailNew.setEventValue(eventDetail.getFeatureAmplitude());
eventDetailNew.setFeatureAmplitude(eventDetail.getFeatureAmplitude());
//波形路径
eventDetailNew.setWaveName(eventDetail.getWavePath());
eventDetailNew.setWavePath(eventDetail.getWavePath());
if(data.getId().equals(eventDetail.getEventType())){
if (reasonMap.containsKey(eventDetail.getEventReason())) {
if (reasonMap.containsKey(eventDetail.getAdvanceReason())) {
//暂降原因
DictData dictData = reasonMap.get(eventDetail.getEventReason());
eventDetailNew.setEventReason(dictData.getName());
DictData dictData = reasonMap.get(eventDetail.getAdvanceReason());
eventDetailNew.setAdvanceReason(dictData.getName());
}
if (typeMap.containsKey(eventDetail.getEventType())) {
if (typeMap.containsKey(eventDetail.getAdvanceType())) {
//事件类型
DictData dictData = typeMap.get(eventDetail.getEventType());
eventDetailNew.setEventType(dictData.getName());
DictData dictData = typeMap.get(eventDetail.getAdvanceType());
eventDetailNew.setAdvanceType(dictData.getName());
}
}
@@ -1466,244 +1489,295 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
@Override
public Page<WaveTypeVO> getMonitorEventAnalyseQuery(EventBaseParam eventBaseParam) {
//提前创建结果集合
List<WaveTypeVO> eventDetailList = new ArrayList<>();
//数据暂降查询
Page<RmpEventDetailPO> pageInfo = eventDetailService.page(new Page<>(eventBaseParam.getPageNum(), eventBaseParam.getPageSize()), new LambdaQueryWrapper<RmpEventDetailPO>()
.eq(RmpEventDetailPO::getMeasurementPointId, eventBaseParam.getLineId())
.ge(StringUtils.isNotBlank(eventBaseParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime())))
.le(StringUtils.isNotBlank(eventBaseParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime())))
//创建line_id集合,将入参line_id塞进去
List<String> lineIds = new ArrayList<>();
lineIds.add(eventBaseParam.getLineId());
//提前创建total
StringBuilder stringTotal = new StringBuilder();
//查询参数不为空,进行条件填充
if (ObjectUtil.isNotNull(eventBaseParam.getSearchValue())) {
//查询sql语句
StringBuilder stringResult = new StringBuilder(Param.SELECT).append(Param.EVENT_DETAIL).append(Param.WHERE).
append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ")
.append("line_id= '").append(eventBaseParam.getLineId()).append("'");
//套用公式(page-1)*pageSize
int i = (eventBaseParam.getPageNum() - 1) * eventBaseParam.getPageSize();
//拼接分页sql
stringResult.append("LIMIT ").append(eventBaseParam.getPageSize()).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
//查询sql语句总条数
stringTotal = new StringBuilder("SELECT COUNT(num) as aa FROM ").append(Param.EVENT_DETAIL).append(" WHERE ").append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ")
.append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ");
stringTotal.append("line_id= '").append(eventBaseParam.getLineId()).append("' tz('Asia/Shanghai')");
//结果集
QueryResult result = influxDbUtils.query(stringResult.toString());
//总条数
QueryResult resultTotal = influxDbUtils.query(stringTotal.toString());
//结果集映射到对象中
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
eventDetailList = influxDBResultMapper.toPOJO(result, WaveTypeVO.class);
//获取关于监测点发电站相关信息
HttpResult<List<AreaLineInfoVO>> baseLineAreaInfo = lineFeignClient.getBaseLineAreaInfo(lineIds);
System.out.println(baseLineAreaInfo);
//将返回的封装好的结果集进行还原成集合
List<AreaLineInfoVO> areaLineList = baseLineAreaInfo.getData();
//将监测点发电机相关信息copy到准备好的VO对象中
for (WaveTypeVO waveTypeVO : eventDetailList) {
if (waveTypeVO.getLineId() != null) {
for (AreaLineInfoVO lineInfoVO : areaLineList) {
if (waveTypeVO.getLineId().equals(lineInfoVO.getLineId())) {
waveTypeVO.setSubName(lineInfoVO.getSubName());
waveTypeVO.setLineId(lineInfoVO.getLineId());
waveTypeVO.setLineName(lineInfoVO.getLineName());
waveTypeVO.setGdId(lineInfoVO.getGdId());
waveTypeVO.setGdName(lineInfoVO.getGdName());
waveTypeVO.setVoltageId(lineInfoVO.getVoltageId());
waveTypeVO.setNoDealCount(lineInfoVO.getNoDealCount());
waveTypeVO.setCt1(lineInfoVO.getCt1());
waveTypeVO.setCt2(lineInfoVO.getCt2());
waveTypeVO.setPt1(lineInfoVO.getPt1());
waveTypeVO.setPt2(lineInfoVO.getPt2());
waveTypeVO.setRunFlag(lineInfoVO.getRunFlag());
waveTypeVO.setComFlag(lineInfoVO.getComFlag());
waveTypeVO.setIp(lineInfoVO.getIp());
waveTypeVO.setLat(lineInfoVO.getLat());
waveTypeVO.setLng(lineInfoVO.getLng());
waveTypeVO.setManufacturer(lineInfoVO.getManufacturer());
waveTypeVO.setVoltageScale(lineInfoVO.getVoltageScale());
}
}
} else {
//抛出异常,当前监测点id为空
throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
}
}
//使用字典表对暂态类型和暂态原因进行转换
HttpResult<List<DictData>> reason = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName());
HttpResult<List<DictData>> type = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName());
//获取字典数据暂态原因集合
List<DictData> eventReasonList = reason.getData();
//System.out.println(eventReasonList);
//获取字典数据暂态类型集合
List<DictData> eventTypeList = type.getData();
//System.out.println(eventTypeList);
//查询字典表替换事件原因与事件类型的字符串
for (WaveTypeVO eventDetail : eventDetailList) {
if (eventDetail.getEventReason() != null) {
for (DictData dictData : eventReasonList) {
//将字典数据id与VO中属性eventReason对应的字符串进行比较
if (eventDetail.getEventReason().equals(dictData.getId())) {
eventDetail.setEventReason(dictData.getName());
}
}
} else {
//抛出异常,当前暂态原因为空
throw new BusinessException(EventResponseEnum.EVENT_REASON_NOT_FOUND);
}
}
for (WaveTypeVO eventDetail : eventDetailList) {
if (eventDetail.getEventType() != null) {
for (DictData dictData : eventTypeList) {
//将字典数据id与VO中属性eventType对应的字符串进行比较
if (eventDetail.getEventType().equals(dictData.getId())) {
eventDetail.setEventType(dictData.getName());
}
}
} else {
//抛出异常,当前暂态类型为空
throw new BusinessException(EventResponseEnum.EVENT_TYPE_NOT_FOUND);
}
}
Page<WaveTypeVO> page = new Page<>();
page.setTotal(eventDetailList.size());
page.setRecords(eventDetailList);
page.setCurrent(eventBaseParam.getPageNum());
page.setSize(eventBaseParam.getPageSize());
return page;
} else {
StringBuilder stringResult = new StringBuilder(Param.SELECT).append(Param.EVENT_DETAIL).append(Param.WHERE).
append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ")
.append("line_id= '").append(eventBaseParam.getLineId()).append("'");
int i = (eventBaseParam.getPageNum() - 1) * eventBaseParam.getPageSize();
stringResult.append("LIMIT ").append(eventBaseParam.getPageSize()).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
//查询sql语句总条数
stringTotal = new StringBuilder("SELECT COUNT(num) as aa FROM ").append(Param.EVENT_DETAIL).append(" WHERE ").append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ")
.append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ");
stringTotal.append("line_id= '").append(eventBaseParam.getLineId()).append("' tz('Asia/Shanghai')");
//结果集
QueryResult result = influxDbUtils.query(stringResult.toString());
//总条数
QueryResult resultTotal = influxDbUtils.query(stringTotal.toString());
//结果集映射到对象中
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
eventDetailList = influxDBResultMapper.toPOJO(result, WaveTypeVO.class);
//获取关于监测点发电站相关信息
HttpResult<List<AreaLineInfoVO>> baseLineAreaInfo = lineFeignClient.getBaseLineAreaInfo(lineIds);
System.out.println(baseLineAreaInfo);
//将返回的封装好的结果集进行还原成集合
List<AreaLineInfoVO> areaLineList = baseLineAreaInfo.getData();
//将监测点发电机相关信息copy到准备好的VO对象中
for (WaveTypeVO waveTypeVO : eventDetailList) {
if (waveTypeVO.getLineId() != null) {
for (AreaLineInfoVO lineInfoVO : areaLineList) {
if (waveTypeVO.getLineId().equals(lineInfoVO.getLineId())) {
waveTypeVO.setSubName(lineInfoVO.getSubName());
waveTypeVO.setLineId(lineInfoVO.getLineId());
waveTypeVO.setLineName(lineInfoVO.getLineName());
waveTypeVO.setGdId(lineInfoVO.getGdId());
waveTypeVO.setGdName(lineInfoVO.getGdName());
waveTypeVO.setVoltageId(lineInfoVO.getVoltageId());
waveTypeVO.setNoDealCount(lineInfoVO.getNoDealCount());
waveTypeVO.setCt1(lineInfoVO.getCt1());
waveTypeVO.setCt2(lineInfoVO.getCt2());
waveTypeVO.setPt1(lineInfoVO.getPt1());
waveTypeVO.setPt2(lineInfoVO.getPt2());
waveTypeVO.setRunFlag(lineInfoVO.getRunFlag());
waveTypeVO.setComFlag(lineInfoVO.getComFlag());
waveTypeVO.setIp(lineInfoVO.getIp());
waveTypeVO.setLat(lineInfoVO.getLat());
waveTypeVO.setLng(lineInfoVO.getLng());
waveTypeVO.setManufacturer(lineInfoVO.getManufacturer());
waveTypeVO.setVoltageScale(lineInfoVO.getVoltageScale());
}
}
} else {
//抛出异常,当前监测点id为空
throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
}
}
//使用字典表对暂态类型和暂态原因进行转换
HttpResult<List<DictData>> reason = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName());
HttpResult<List<DictData>> type = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName());
//获取字典数据暂态原因集合
List<DictData> eventReasonList = reason.getData();
//System.out.println(eventReasonList);
//获取字典数据暂态类型集合
List<DictData> eventTypeList = type.getData();
//System.out.println(eventTypeList);
//查询字典表替换事件原因与事件类型的字符串
for (WaveTypeVO eventDetail : eventDetailList) {
if (eventDetail.getEventReason() != null) {
for (DictData dictData : eventReasonList) {
//将字典数据id与VO中属性eventReason对应的字符串进行比较
if (eventDetail.getEventReason().equals(dictData.getId())) {
eventDetail.setEventReason(dictData.getName());
break;
}
}
} else {
//抛出异常,当前暂态原因为空
throw new BusinessException(EventResponseEnum.EVENT_REASON_NOT_FOUND);
}
if (eventDetail.getEventType() != null) {
for (DictData dictData : eventTypeList) {
//将字典数据id与VO中属性eventType对应的字符串进行比较
if (eventDetail.getEventType().equals(dictData.getId())) {
eventDetail.setEventType(dictData.getName());
break;
}
}
} else {
//抛出异常,当前暂态类型为空
throw new BusinessException(EventResponseEnum.EVENT_TYPE_NOT_FOUND);
}
}
Page<WaveTypeVO> page = new Page<>();
long total = eventDetailList.size();
page.setTotal(total);
page.setRecords(eventDetailList);
page.setCurrent(eventBaseParam.getPageNum());
page.setSize(eventBaseParam.getPageSize());
return page;
);
//获取关于监测点发电站相关信息
List<AreaLineInfoVO> areaLineList = lineFeignClient.getBaseLineAreaInfo(Arrays.asList(eventBaseParam.getLineId())).getData();
if(CollectionUtil.isNotEmpty(areaLineList)){
throw new BusinessException(EventResponseEnum.NOT_FOUND);
}
List<WaveTypeVO> waveTypeVOS = new ArrayList<>();
List<RmpEventDetailPO> records = pageInfo.getRecords();
WaveTypeVO waveTypeVO;
//将监测点发电机相关信息copy到准备好的VO对象中
for (RmpEventDetailPO record : records) {
waveTypeVO=BeanUtil.copyProperties(record,WaveTypeVO.class);
if (waveTypeVO.getLineId() != null) {
for (AreaLineInfoVO lineInfoVO : areaLineList) {
if (waveTypeVO.getLineId().equals(lineInfoVO.getLineId())) {
waveTypeVO.setSubName(lineInfoVO.getSubName());
waveTypeVO.setLineId(lineInfoVO.getLineId());
waveTypeVO.setLineName(lineInfoVO.getLineName());
waveTypeVO.setGdId(lineInfoVO.getGdId());
waveTypeVO.setGdName(lineInfoVO.getGdName());
waveTypeVO.setVoltageId(lineInfoVO.getVoltageId());
waveTypeVO.setNoDealCount(lineInfoVO.getNoDealCount());
waveTypeVO.setCt1(lineInfoVO.getCt1());
waveTypeVO.setCt2(lineInfoVO.getCt2());
waveTypeVO.setPt1(lineInfoVO.getPt1());
waveTypeVO.setPt2(lineInfoVO.getPt2());
waveTypeVO.setRunFlag(lineInfoVO.getRunFlag());
waveTypeVO.setComFlag(lineInfoVO.getComFlag());
waveTypeVO.setIp(lineInfoVO.getIp());
waveTypeVO.setLat(lineInfoVO.getLat());
waveTypeVO.setLng(lineInfoVO.getLng());
waveTypeVO.setManufacturer(lineInfoVO.getManufacturer());
waveTypeVO.setVoltageScale(lineInfoVO.getVoltageScale());
waveTypeVOS.add(waveTypeVO);
}
}
} else {
//抛出异常,当前监测点id为空
throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
}
}
Page<WaveTypeVO> page=BeanUtil.copyProperties(pageInfo,Page.class);
page.setRecords(waveTypeVOS);
return page;
// //提前创建结果集合
// List<WaveTypeVO> eventDetailList = new ArrayList<>();
//
// //创建line_id集合,将入参line_id塞进去
// List<String> lineIds = new ArrayList<>();
// lineIds.add(eventBaseParam.getLineId());
//
// //提前创建total
// StringBuilder stringTotal = new StringBuilder();
//
//
// //查询参数不为空,进行条件填充
// if (ObjectUtil.isNotNull(eventBaseParam.getSearchValue())) {
// //查询sql语句
// StringBuilder stringResult = new StringBuilder(Param.SELECT).append(Param.EVENT_DETAIL).append(Param.WHERE).
// append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ")
// .append("line_id= '").append(eventBaseParam.getLineId()).append("'");
//
// //套用公式(page-1)*pageSize
// int i = (eventBaseParam.getPageNum() - 1) * eventBaseParam.getPageSize();
// //拼接分页sql
// stringResult.append("LIMIT ").append(eventBaseParam.getPageSize()).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
//
//
// //查询sql语句总条数
// stringTotal = new StringBuilder("SELECT COUNT(num) as aa FROM ").append(Param.EVENT_DETAIL).append(" WHERE ").append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ")
// .append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ");
// stringTotal.append("line_id= '").append(eventBaseParam.getLineId()).append("' tz('Asia/Shanghai')");
//
// //结果集
// QueryResult result = influxDbUtils.query(stringResult.toString());
// //总条数
// QueryResult resultTotal = influxDbUtils.query(stringTotal.toString());
//
// //结果集映射到对象中
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// eventDetailList = influxDBResultMapper.toPOJO(result, WaveTypeVO.class);
//
//
// //获取关于监测点发电站相关信息
// HttpResult<List<AreaLineInfoVO>> baseLineAreaInfo = lineFeignClient.getBaseLineAreaInfo(lineIds);
// System.out.println(baseLineAreaInfo);
// //将返回的封装好的结果集进行还原成集合
// List<AreaLineInfoVO> areaLineList = baseLineAreaInfo.getData();
//
//
// //将监测点发电机相关信息copy到准备好的VO对象中
// for (WaveTypeVO waveTypeVO : eventDetailList) {
// if (waveTypeVO.getLineId() != null) {
// for (AreaLineInfoVO lineInfoVO : areaLineList) {
// if (waveTypeVO.getLineId().equals(lineInfoVO.getLineId())) {
// waveTypeVO.setSubName(lineInfoVO.getSubName());
// waveTypeVO.setLineId(lineInfoVO.getLineId());
// waveTypeVO.setLineName(lineInfoVO.getLineName());
// waveTypeVO.setGdId(lineInfoVO.getGdId());
// waveTypeVO.setGdName(lineInfoVO.getGdName());
// waveTypeVO.setVoltageId(lineInfoVO.getVoltageId());
// waveTypeVO.setNoDealCount(lineInfoVO.getNoDealCount());
// waveTypeVO.setCt1(lineInfoVO.getCt1());
// waveTypeVO.setCt2(lineInfoVO.getCt2());
// waveTypeVO.setPt1(lineInfoVO.getPt1());
// waveTypeVO.setPt2(lineInfoVO.getPt2());
// waveTypeVO.setRunFlag(lineInfoVO.getRunFlag());
// waveTypeVO.setComFlag(lineInfoVO.getComFlag());
// waveTypeVO.setIp(lineInfoVO.getIp());
// waveTypeVO.setLat(lineInfoVO.getLat());
// waveTypeVO.setLng(lineInfoVO.getLng());
// waveTypeVO.setManufacturer(lineInfoVO.getManufacturer());
// waveTypeVO.setVoltageScale(lineInfoVO.getVoltageScale());
// }
// }
// } else {
// //抛出异常,当前监测点id为空
// throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
// }
// }
//
// //使用字典表对暂态类型和暂态原因进行转换
// HttpResult<List<DictData>> reason = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName());
// HttpResult<List<DictData>> type = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName());
// //获取字典数据暂态原因集合
// List<DictData> eventReasonList = reason.getData();
// //System.out.println(eventReasonList);
// //获取字典数据暂态类型集合
// List<DictData> eventTypeList = type.getData();
// //System.out.println(eventTypeList);
//
//
// //查询字典表替换事件原因与事件类型的字符串
// for (WaveTypeVO eventDetail : eventDetailList) {
// if (eventDetail.getEventReason() != null) {
// for (DictData dictData : eventReasonList) {
// //将字典数据id与VO中属性eventReason对应的字符串进行比较
// if (eventDetail.getEventReason().equals(dictData.getId())) {
// eventDetail.setEventReason(dictData.getName());
// }
// }
// } else {
// //抛出异常,当前暂态原因为空
// throw new BusinessException(EventResponseEnum.EVENT_REASON_NOT_FOUND);
// }
// }
//
// for (WaveTypeVO eventDetail : eventDetailList) {
// if (eventDetail.getEventType() != null) {
// for (DictData dictData : eventTypeList) {
// //将字典数据id与VO中属性eventType对应的字符串进行比较
// if (eventDetail.getEventType().equals(dictData.getId())) {
// eventDetail.setEventType(dictData.getName());
// }
// }
// } else {
// //抛出异常,当前暂态类型为空
// throw new BusinessException(EventResponseEnum.EVENT_TYPE_NOT_FOUND);
// }
// }
// Page<WaveTypeVO> page = new Page<>();
// page.setTotal(eventDetailList.size());
// page.setRecords(eventDetailList);
// page.setCurrent(eventBaseParam.getPageNum());
// page.setSize(eventBaseParam.getPageSize());
// return page;
//
//
// } else {
// StringBuilder stringResult = new StringBuilder(Param.SELECT).append(Param.EVENT_DETAIL).append(Param.WHERE).
// append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ")
// .append("line_id= '").append(eventBaseParam.getLineId()).append("'");
//
//
// int i = (eventBaseParam.getPageNum() - 1) * eventBaseParam.getPageSize();
//
// stringResult.append("LIMIT ").append(eventBaseParam.getPageSize()).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
//
// //查询sql语句总条数
// stringTotal = new StringBuilder("SELECT COUNT(num) as aa FROM ").append(Param.EVENT_DETAIL).append(" WHERE ").append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(eventBaseParam.getSearchBeginTime()))).append("' and ")
// .append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(eventBaseParam.getSearchEndTime()))).append("' and ");
// stringTotal.append("line_id= '").append(eventBaseParam.getLineId()).append("' tz('Asia/Shanghai')");
//
//
// //结果集
// QueryResult result = influxDbUtils.query(stringResult.toString());
// //总条数
// QueryResult resultTotal = influxDbUtils.query(stringTotal.toString());
//
// //结果集映射到对象中
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// eventDetailList = influxDBResultMapper.toPOJO(result, WaveTypeVO.class);
//
//
// //获取关于监测点发电站相关信息
// HttpResult<List<AreaLineInfoVO>> baseLineAreaInfo = lineFeignClient.getBaseLineAreaInfo(lineIds);
// System.out.println(baseLineAreaInfo);
// //将返回的封装好的结果集进行还原成集合
// List<AreaLineInfoVO> areaLineList = baseLineAreaInfo.getData();
//
//
// //将监测点发电机相关信息copy到准备好的VO对象中
// for (WaveTypeVO waveTypeVO : eventDetailList) {
// if (waveTypeVO.getLineId() != null) {
// for (AreaLineInfoVO lineInfoVO : areaLineList) {
// if (waveTypeVO.getLineId().equals(lineInfoVO.getLineId())) {
// waveTypeVO.setSubName(lineInfoVO.getSubName());
// waveTypeVO.setLineId(lineInfoVO.getLineId());
// waveTypeVO.setLineName(lineInfoVO.getLineName());
// waveTypeVO.setGdId(lineInfoVO.getGdId());
// waveTypeVO.setGdName(lineInfoVO.getGdName());
// waveTypeVO.setVoltageId(lineInfoVO.getVoltageId());
// waveTypeVO.setNoDealCount(lineInfoVO.getNoDealCount());
// waveTypeVO.setCt1(lineInfoVO.getCt1());
// waveTypeVO.setCt2(lineInfoVO.getCt2());
// waveTypeVO.setPt1(lineInfoVO.getPt1());
// waveTypeVO.setPt2(lineInfoVO.getPt2());
// waveTypeVO.setRunFlag(lineInfoVO.getRunFlag());
// waveTypeVO.setComFlag(lineInfoVO.getComFlag());
// waveTypeVO.setIp(lineInfoVO.getIp());
// waveTypeVO.setLat(lineInfoVO.getLat());
// waveTypeVO.setLng(lineInfoVO.getLng());
// waveTypeVO.setManufacturer(lineInfoVO.getManufacturer());
// waveTypeVO.setVoltageScale(lineInfoVO.getVoltageScale());
// }
// }
// } else {
// //抛出异常,当前监测点id为空
// throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
// }
// }
//
//
// //使用字典表对暂态类型和暂态原因进行转换
// HttpResult<List<DictData>> reason = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName());
// HttpResult<List<DictData>> type = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName());
// //获取字典数据暂态原因集合
// List<DictData> eventReasonList = reason.getData();
// //System.out.println(eventReasonList);
// //获取字典数据暂态类型集合
// List<DictData> eventTypeList = type.getData();
// //System.out.println(eventTypeList);
//
//
// //查询字典表替换事件原因与事件类型的字符串
// for (WaveTypeVO eventDetail : eventDetailList) {
// if (eventDetail.getEventReason() != null) {
// for (DictData dictData : eventReasonList) {
// //将字典数据id与VO中属性eventReason对应的字符串进行比较
// if (eventDetail.getEventReason().equals(dictData.getId())) {
// eventDetail.setEventReason(dictData.getName());
// break;
// }
// }
// } else {
// //抛出异常,当前暂态原因为空
// throw new BusinessException(EventResponseEnum.EVENT_REASON_NOT_FOUND);
// }
//
// if (eventDetail.getEventType() != null) {
// for (DictData dictData : eventTypeList) {
// //将字典数据id与VO中属性eventType对应的字符串进行比较
// if (eventDetail.getEventType().equals(dictData.getId())) {
// eventDetail.setEventType(dictData.getName());
// break;
// }
// }
// } else {
// //抛出异常,当前暂态类型为空
// throw new BusinessException(EventResponseEnum.EVENT_TYPE_NOT_FOUND);
// }
// }
//
//
// Page<WaveTypeVO> page = new Page<>();
// long total = eventDetailList.size();
// page.setTotal(total);
// page.setRecords(eventDetailList);
// page.setCurrent(eventBaseParam.getPageNum());
// page.setSize(eventBaseParam.getPageSize());
// return page;
// }
}
@@ -1782,11 +1856,11 @@ public class EventAnalysisServiceImpl implements EventAnalysisService {
//根据监测点id获取监测点详情
LineDetailDataVO lineDetailData = lineFeignClient.getLineDetailData(lineId.get(i)).getData();
EventDetail eventDetailByTime = eventDetailService.getEventDetailByTime(lineId.get(i), timeId.get(i));
if (Objects.isNull(lineDetailData.getIp()) && Objects.isNull(eventDetailByTime.getWaveName())) {
if (Objects.isNull(lineDetailData.getIp()) && Objects.isNull(eventDetailByTime.getWavePath())) {
throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
}
String ip = lineDetailData.getIp();
String waveName = eventDetailByTime.getWaveName();
String waveName = eventDetailByTime.getWavePath();
// TODO 1
File srcCFGFile = new File(generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + ".CFG");

105
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDetailServiceImpl.java
View File

@@ -1,6 +1,10 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.event.mapper.majornetwork.EventDetailMapper;
import com.njcn.event.pojo.po.EventDetail;
@@ -32,18 +36,26 @@ public class EventDetailServiceImpl extends ServiceImpl<EventDetailMapper, RmpEv
@Override
public List<EventDetail> getEventDetailData(String id, String startTime, String endTime) {
//组装sql语句
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(startTime))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(endTime))).append("' and ");
//sql语句
stringBuilder.append("line_id ='").append(id).append("'").append(" tz('Asia/Shanghai')");
//数据暂降查询
List<RmpEventDetailPO> info = this.list(new LambdaQueryWrapper<RmpEventDetailPO>()
.eq(RmpEventDetailPO::getMeasurementPointId, id)
.ge(StrUtil.isNotBlank(startTime), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(startTime)))
.le(StrUtil.isNotBlank(endTime), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(endTime)))
);
return BeanUtil.copyToList(info, EventDetail.class);
String sql = "select * from pqs_eventdetail where " + stringBuilder;
//获取暂降事件
QueryResult result = influxDbUtils.query(sql);
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(result, EventDetail.class);
return eventDetailList;
// //组装sql语句
// StringBuilder stringBuilder = new StringBuilder();
// stringBuilder.append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(startTime))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(endTime))).append("' and ");
// //sql语句
// stringBuilder.append("line_id ='").append(id).append("'").append(" tz('Asia/Shanghai')");
//
// String sql = "select * from pqs_eventdetail where " + stringBuilder;
// //获取暂降事件
// QueryResult result = influxDbUtils.query(sql);
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(result, EventDetail.class);
// return eventDetailList;
}
@Override
@@ -99,38 +111,47 @@ public class EventDetailServiceImpl extends ServiceImpl<EventDetailMapper, RmpEv
}
@Override
public List<EventDetail> getEventDetailLimit(List<String> lineIndexes, String startTime, String endTime, Integer pageSize, Integer pageNum, List<Integer> waveType) {
//组装sql语句
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(startTime))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(endTime))).append("' and (");
for (int i = 0; i < lineIndexes.size(); i++) {
if (lineIndexes.size() - i != 1) {
stringBuilder.append("line_id ='").append(lineIndexes.get(i)).append("' or ");
} else {
stringBuilder.append("line_id ='").append(lineIndexes.get(i)).append("' ");
}
}
stringBuilder.append(") and (");
for (int i = 0; i < waveType.size(); i++) {
if (waveType.size() - i != 1) {
stringBuilder.append("wave_type ='").append(waveType.get(i)).append("' or ");
} else {
stringBuilder.append("wave_type ='").append(waveType.get(i)).append("' ");
}
}
stringBuilder.append(") order by time desc");
int i = (pageNum - 1)*pageSize;
stringBuilder.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
//sql语句
String sql = "SELECT * FROM pqs_eventdetail WHERE " + stringBuilder;
System.out.println(sql);
//结果集
QueryResult result = influxDbUtils.query(sql);
//结果集映射到对象中
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(result, EventDetail.class);
public List<EventDetail> getEventDetailLimit(List<String> lineIndexes, String startTime, String endTime, Integer pageSize, Integer pageNum, List<String> waveType) {
return eventDetailList;
Page<RmpEventDetailPO> pageInfo = this.page(new Page<>(pageNum, pageSize), new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineIndexes)
.ge(StrUtil.isNotBlank(startTime), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(startTime)))
.le(StrUtil.isNotBlank(endTime), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(endTime)))
);
return BeanUtil.copyToList(pageInfo.getRecords(), EventDetail.class);
// //组装sql语句
// StringBuilder stringBuilder = new StringBuilder();
// stringBuilder.append("time >= '").append(DateUtil.beginOfDay(DateUtil.parse(startTime))).append("' and ").append("time <= '").append(DateUtil.endOfDay(DateUtil.parse(endTime))).append("' and (");
// for (int i = 0; i < lineIndexes.size(); i++) {
// if (lineIndexes.size() - i != 1) {
// stringBuilder.append("line_id ='").append(lineIndexes.get(i)).append("' or ");
// } else {
// stringBuilder.append("line_id ='").append(lineIndexes.get(i)).append("' ");
// }
// }
// stringBuilder.append(") and (");
// for (int i = 0; i < waveType.size(); i++) {
// if (waveType.size() - i != 1) {
// stringBuilder.append("wave_type ='").append(waveType.get(i)).append("' or ");
// } else {
// stringBuilder.append("wave_type ='").append(waveType.get(i)).append("' ");
// }
// }
// stringBuilder.append(") order by time desc");
// int i = (pageNum - 1)*pageSize;
// stringBuilder.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(i).append(" tz('Asia/Shanghai')");
// //sql语句
// String sql = "SELECT * FROM pqs_eventdetail WHERE " + stringBuilder;
// System.out.println(sql);
// //结果集
// QueryResult result = influxDbUtils.query(sql);
// //结果集映射到对象中
// InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
// List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(result, EventDetail.class);
//
// return eventDetailList;
}
}

4
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventDistributionStatisticsServiceImpl.java
View File

@@ -325,8 +325,8 @@ public class EventDistributionStatisticsServiceImpl implements EventDistribution
eventFeatureAmplitudeCurve.setFeatureAmplitude(dto.getFeatureAmplitude());
eventFeatureAmplitudeCurve.setDuration(dto.getDuration());
eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.ofInstant(dto.getStartTime().toInstant(), ZoneId.systemDefault()));
// eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.ofInstant(dto.getStartTime().toInstant(), ZoneId.systemDefault()));
eventFeatureAmplitudeCurve.setStartTime(LocalDateTime.parse( dto.getStartTime()));
return eventFeatureAmplitudeCurve;
})
//.sorted(VoltageToleranceCurveDataList.sortAscTime())

84
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/EventReportServiceImpl.java
View File

@@ -46,8 +46,8 @@ public class EventReportServiceImpl implements EventReportService {
}
}
for (int i = 0; i < info.size(); i++) {
Double eventvalue = info.get(i).getEventValue();
double persisttime = info.get(i).getPersistTime();
Double eventvalue = info.get(i).getFeatureAmplitude();
double persisttime = info.get(i).getDuration();
if (eventvalue * 100 < 10) {
if (persisttime < 20) {
arr[4][0]++;
@@ -158,8 +158,8 @@ public class EventReportServiceImpl implements EventReportService {
}
}
for (int i = 0; i < info.size(); i++) {
Double eventvalue = info.get(i).getEventValue();
double persisttime = info.get(i).getPersistTime();
Double eventvalue = info.get(i).getFeatureAmplitude();
double persisttime = info.get(i).getDuration();
if (eventvalue * 100 < 1) {
if (persisttime < 20 && persisttime >= 10) {
arr[2][0]++;
@@ -220,8 +220,8 @@ public class EventReportServiceImpl implements EventReportService {
}
}
for (int i = 0; i < info.size(); i++) {
Double eventvalue = info.get(i).getEventValue();
double persisttime = info.get(i).getPersistTime();
Double eventvalue = info.get(i).getFeatureAmplitude();
double persisttime = info.get(i).getDuration();
if (eventvalue * 100 < 1 && eventvalue * 100 >= 0) {
if (persisttime > 10 && persisttime <= 100) {
arr[16][0]++;
@@ -559,7 +559,7 @@ public class EventReportServiceImpl implements EventReportService {
Integer count = 0;
for (EventDetail eventDetail : info2) {
//过滤掉大于0.9的数据
if (eventDetail.getEventValue() <= 0.9) {
if (eventDetail.getFeatureAmplitude() <= 0.9) {
count++;
info.add(eventDetail);
}
@@ -588,53 +588,53 @@ public class EventReportServiceImpl implements EventReportService {
subsectionMap.put("80~90", 0);
//求数量
for (EventDetail eventDetail : info) {
if (eventDetail.getEventValue() < 0.1) {
if (eventDetail.getFeatureAmplitude() < 0.1) {
countMap.put("<10", (countMap.get("<10") + 1));
}
if (eventDetail.getEventValue() < 0.2) {
if (eventDetail.getFeatureAmplitude() < 0.2) {
countMap.put("<20", (countMap.get("<20") + 1));
}
if (eventDetail.getEventValue() < 0.3) {
if (eventDetail.getFeatureAmplitude() < 0.3) {
countMap.put("<30", (countMap.get("<30") + 1));
}
if (eventDetail.getEventValue() < 0.4) {
if (eventDetail.getFeatureAmplitude() < 0.4) {
countMap.put("<40", (countMap.get("<40") + 1));
}
if (eventDetail.getEventValue() < 0.5) {
if (eventDetail.getFeatureAmplitude() < 0.5) {
countMap.put("<50", (countMap.get("<50") + 1));
}
if (eventDetail.getEventValue() < 0.6) {
if (eventDetail.getFeatureAmplitude() < 0.6) {
countMap.put("<60", (countMap.get("<60") + 1));
}
if (eventDetail.getEventValue() < 0.7) {
if (eventDetail.getFeatureAmplitude() < 0.7) {
countMap.put("<70", (countMap.get("<70") + 1));
}
if (eventDetail.getEventValue() < 0.8) {
if (eventDetail.getFeatureAmplitude() < 0.8) {
countMap.put("<80", (countMap.get("<80") + 1));
}
if (eventDetail.getEventValue() < 0.9) {
if (eventDetail.getFeatureAmplitude() < 0.9) {
countMap.put("<90", (countMap.get("<90") + 1));
}
}
//求每段数量
for (EventDetail eventDetail : info) {
if (eventDetail.getEventValue() < 0.1) {
if (eventDetail.getFeatureAmplitude() < 0.1) {
subsectionMap.put("0~10", (subsectionMap.get("0~10") + 1));
} else if (eventDetail.getEventValue() > 0.1 && eventDetail.getEventValue() < 0.2) {
} else if (eventDetail.getFeatureAmplitude() > 0.1 && eventDetail.getFeatureAmplitude() < 0.2) {
subsectionMap.put("10~20", (subsectionMap.get("10~20") + 1));
} else if (eventDetail.getEventValue() > 0.2 && eventDetail.getEventValue() < 0.3) {
} else if (eventDetail.getFeatureAmplitude() > 0.2 && eventDetail.getFeatureAmplitude() < 0.3) {
subsectionMap.put("20~30", (subsectionMap.get("20~30") + 1));
} else if (eventDetail.getEventValue() > 0.3 && eventDetail.getEventValue() < 0.4) {
} else if (eventDetail.getFeatureAmplitude() > 0.3 && eventDetail.getFeatureAmplitude() < 0.4) {
subsectionMap.put("30~40", (subsectionMap.get("30~40") + 1));
} else if (eventDetail.getEventValue() > 0.4 && eventDetail.getEventValue() < 0.5) {
} else if (eventDetail.getFeatureAmplitude() > 0.4 && eventDetail.getFeatureAmplitude() < 0.5) {
subsectionMap.put("40~50", (subsectionMap.get("40~50") + 1));
} else if (eventDetail.getEventValue() > 0.5 && eventDetail.getEventValue() < 0.6) {
} else if (eventDetail.getFeatureAmplitude() > 0.5 && eventDetail.getFeatureAmplitude() < 0.6) {
subsectionMap.put("50~60", (subsectionMap.get("50~60") + 1));
} else if (eventDetail.getEventValue() > 0.6 && eventDetail.getEventValue() < 0.7) {
} else if (eventDetail.getFeatureAmplitude() > 0.6 && eventDetail.getFeatureAmplitude() < 0.7) {
subsectionMap.put("60~70", (subsectionMap.get("60~70") + 1));
} else if (eventDetail.getEventValue() > 0.7 && eventDetail.getEventValue() < 0.8) {
} else if (eventDetail.getFeatureAmplitude() > 0.7 && eventDetail.getFeatureAmplitude() < 0.8) {
subsectionMap.put("70~80", (subsectionMap.get("70~80") + 1));
} else if (eventDetail.getEventValue() > 0.8 && eventDetail.getEventValue() < 0.9) {
} else if (eventDetail.getFeatureAmplitude() > 0.8 && eventDetail.getFeatureAmplitude() < 0.9) {
subsectionMap.put("80~90", (subsectionMap.get("80~90") + 1));
}
}
@@ -712,7 +712,7 @@ public class EventReportServiceImpl implements EventReportService {
timeMap.put("<180", 0);
//求不同时间段的总数
for (EventDetail eventDetail : info) {
Double persistTime = eventDetail.getPersistTime();
Double persistTime = eventDetail.getDuration();
if (persistTime / 1000 < 0.1) {
timeMap.put("<0.1", timeMap.get("<0.1") + 1);
} else if (persistTime / 1000 > 0.1 && persistTime / 1000 < 0.25) {
@@ -773,7 +773,7 @@ public class EventReportServiceImpl implements EventReportService {
//求sisttime
List<String> sisttime = new ArrayList<>();
for (EventDetail eventDetail : info) {
Double persistTime = eventDetail.getPersistTime();
Double persistTime = eventDetail.getDuration();
if (persistTime / 1000 < 0.1) {
timeMap2.put("<0.1", timeMap2.get("<0.1") + 1);
}
@@ -850,7 +850,7 @@ public class EventReportServiceImpl implements EventReportService {
query = MonitorQuery(new StatisticsParam(statisticsParam.getLineIndex(),builder1.toString(), builder2.toString(), statisticsParam.getFlag()));
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(query, EventDetail.class);
long count = eventDetailList.stream().filter(x -> x.getWaveType() == 1).count();
long count = eventDetailList.stream().filter(x -> x.getEventType() == "1").count();
if (startMonth < 10) {
list.add(new TimeVO(null, null,"", "0" + startMonth.toString(), count+"", startYear.toString(), startYear.toString()+"-"+"0"+startMonth.toString()));
} else {
@@ -869,7 +869,7 @@ public class EventReportServiceImpl implements EventReportService {
query = MonitorQuery(new StatisticsParam(statisticsParam.getLineIndex(),builder1.toString(), builder2.toString(), statisticsParam.getFlag()));
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetail> eventDetailList = influxDBResultMapper.toPOJO(query, EventDetail.class);
long count1 = eventDetailList.stream().filter(x -> x.getWaveType() == 1).count();
long count1 = eventDetailList.stream().filter(x -> x.getEventType() == "1").count();
if (startMonth < 10) {
list.add(new TimeVO(null, null,"", "0" + startMonth.toString(), count1+"", startYear.toString(), startYear.toString()+"-"+"0"+startMonth.toString()));
} else {
@@ -882,7 +882,7 @@ public class EventReportServiceImpl implements EventReportService {
InfluxDBResultMapper influxDBResultMapper = new InfluxDBResultMapper();
List<EventDetailNew> eventDetailList = influxDBResultMapper.toPOJO(monitorQuery, EventDetailNew.class);
Map<String, List<EventDetailNew>> map = eventDetailList.stream().filter(x -> x.getWaveType()=="1").collect(Collectors.groupingBy(s -> s.getTimeId().substring(0, 10)));
Map<String, List<EventDetailNew>> map = eventDetailList.stream().filter(x -> x.getEventType()=="1").collect(Collectors.groupingBy(s -> s.getStartTime().substring(0, 10)));
Set<String> keySet = map.keySet();
LocalDate parse1 = LocalDate.parse(startTime);
@@ -938,13 +938,13 @@ public class EventReportServiceImpl implements EventReportService {
//添加detail
for (EventDetail detail : info) {
for (DictData data : reasonData) {
if (detail.getEventReason().equals(data.getId())) {
detail.setEventReason(data.getName());
if (detail.getAdvanceReason().equals(data.getId())) {
detail.setAdvanceReason(data.getName());
}
}
for (DictData data : typeData) {
if (detail.getEventType().equals(data.getId())) {
detail.setEventType(data.getName());
if (detail.getAdvanceType().equals(data.getId())) {
detail.setAdvanceType(data.getName());
}
}
}
@@ -964,14 +964,14 @@ public class EventReportServiceImpl implements EventReportService {
for (EventDetail detail : info) {
for (DictData data : reasonData) {
reasonMap.put(data.getName(),0);
if (detail.getEventReason().equals(data.getId())) {
detail.setEventReason(data.getName());
if (detail.getAdvanceReason().equals(data.getId())) {
detail.setAdvanceReason(data.getName());
}
}
for (DictData data : typeData) {
typeMap.put(data.getName(),0);
if (detail.getEventType().equals(data.getId())) {
detail.setEventType(data.getName());
if (detail.getAdvanceType().equals(data.getId())) {
detail.setAdvanceType(data.getName());
}
}
list.add(detail);
@@ -979,14 +979,14 @@ public class EventReportServiceImpl implements EventReportService {
//添加reason到map
for (EventDetail data : list) {
if (reasonMap.get(data.getEventReason()) != null) {
reasonMap.put(data.getEventReason(), reasonMap.get(data.getEventReason()) + 1);
if (reasonMap.get(data.getAdvanceReason()) != null) {
reasonMap.put(data.getAdvanceReason(), reasonMap.get(data.getAdvanceReason()) + 1);
}
}
//添加type到map
for (EventDetail data : list) {
if (typeMap.get(data.getEventType()) != null) {
typeMap.put(data.getEventType(), typeMap.get(data.getEventType()) + 1);
if (typeMap.get(data.getAdvanceType()) != null) {
typeMap.put(data.getAdvanceType(), typeMap.get(data.getAdvanceType()) + 1);
}
}
Set<String> reasonKeyset = reasonMap.keySet();

1768
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/ReportServiceImpl.java
View File

File diff suppressed because it is too large Load Diff

134
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java
View File

@@ -1,8 +1,10 @@
package com.njcn.event.service.majornetwork.Impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.njcn.common.config.GeneralInfo;
import com.njcn.common.pojo.enums.common.ServerEnum;
@@ -43,6 +45,7 @@ import com.njcn.system.api.DicDataFeignClient;
import com.njcn.system.enums.DicDataTypeEnum;
import com.njcn.system.pojo.po.DictData;
import lombok.AllArgsConstructor;
import org.apache.commons.lang.StringUtils;
import org.influxdb.dto.QueryResult;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
@@ -126,41 +129,41 @@ public class TransientServiceImpl implements TransientService {
TransientVO transientVO = new TransientVO();
transientVO.setId(eventDetail.getLineId());
transientVO.setNumber(i++);
transientVO.setWaveName(eventDetail.getWaveName());
Instant timeId = eventDetail.getTimeId();
transientVO.setWaveName(eventDetail.getWavePath());
Instant timeId = eventDetail.getStartTime();
ZoneId zoneId = ZoneId.systemDefault();
LocalDateTime localDateTime = LocalDateTime.ofInstant(timeId, zoneId);
DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
String format = dateTimeFormatter.format(localDateTime);
transientVO.setTime(format);
switch (eventDetail.getWaveType()) {
case 0:
switch (eventDetail.getEventType()) {
case 0+"":
transientVO.setTrigType("扰动");
break;
case 1:
case 1+"":
transientVO.setTrigType("暂降");
break;
case 2:
case 2+"":
transientVO.setTrigType("暂升");
break;
case 3:
case 3+"":
transientVO.setTrigType("中断");
break;
case 4:
case 4+"":
transientVO.setTrigType("其他");
break;
case 5:
case 5+"":
transientVO.setTrigType("录波");
break;
}
Double eventValue = new BigDecimal(eventDetail.getEventValue()).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();
Double eventValue = new BigDecimal(eventDetail.getFeatureAmplitude()).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();
transientVO.setEventValue(new BigDecimal(eventValue * 100).setScale(0, BigDecimal.ROUND_HALF_UP).doubleValue());
transientVO.setEventValues(100 - transientVO.getEventValue());
transientVO.setPersistTime((Float.parseFloat(eventDetail.getPersistTime().toString())) / 1000);
transientVO.setPersistTime((Float.parseFloat(eventDetail.getDuration().toString())) / 1000);
transientVO.setYZD(getYZD(Float.parseFloat(eventDetail.getPersistTime().toString()),
Float.parseFloat(eventDetail.getEventValue().toString()))
transientVO.setYZD(getYZD(Float.parseFloat(eventDetail.getDuration().toString()),
Float.parseFloat(eventDetail.getFeatureAmplitude().toString()))
);
transientVOS.add(transientVO);
}
@@ -297,17 +300,30 @@ public class TransientServiceImpl implements TransientService {
if (!CollectionUtils.isEmpty(generalDeviceDTOList)) {
//获取按终端分类的监测点索引集合
List<String> lineList = generalDeviceDTOList.stream().flatMap(dto -> dto.getLineIndexes().stream()).collect(Collectors.toList());
if(CollUtil.isNotEmpty(lineList)){
Page<RmpEventDetailPO> pageInfo = eventDetailService.page(new Page<>(transientParam.getPageNum(), transientParam.getPageSize()), new LambdaQueryWrapper<RmpEventDetailPO>()
.in(RmpEventDetailPO::getMeasurementPointId, lineList)
.ge(StringUtils.isNotBlank(transientParam.getSearchBeginTime()), RmpEventDetailPO::getStartTime,DateUtil.beginOfDay(DateUtil.parse(transientParam.getSearchBeginTime())))
.le(StringUtils.isNotBlank(transientParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(transientParam.getSearchEndTime())))
if (!CollectionUtils.isEmpty(lineList)) {
StringBuilder stringBuilder = InfluxDBCommUtils.assToInfluxParam(lineList);
//influxDB查询待分页数据总量
Long total = getTransientDetail(stringBuilder, transientParam);
page.setTotal(total);
//分页总页数
int pages = (int) Math.ceil(transientParam.getPageNum() * 1.0 / transientParam.getPageSize());
page.setPages(pages);
//influxDB分页查询
List<EventDetailNew> eventDetailData = getTransientDetailLimit(lineList, transientParam);
//暂态幅值最小值
.ge(Objects.nonNull(transientParam.getEventValueMin()),RmpEventDetailPO::getFeatureAmplitude, transientParam.getEventValueMin())
.le(Objects.nonNull(transientParam.getEventValueMax()),RmpEventDetailPO::getFeatureAmplitude, transientParam.getEventValueMax())
//持续时间最小值
.ge(Objects.nonNull(transientParam.getPersistMin()),RmpEventDetailPO::getDuration, transientParam.getPersistMin())
.le(Objects.nonNull(transientParam.getPersistMax()),RmpEventDetailPO::getDuration, transientParam.getPersistMax())
//严重度最小值
.ge(Objects.nonNull(transientParam.getSeverityMin()),RmpEventDetailPO::getSeverity, transientParam.getSeverityMin())
.le(Objects.nonNull(transientParam.getSeverityMax()),RmpEventDetailPO::getSeverity, transientParam.getSeverityMax())
//波形文件
.eq(Objects.nonNull(transientParam.getFileFlag()),RmpEventDetailPO::getFileFlag, transientParam.getFileFlag())
//事件
.in(CollUtil.isNotEmpty(transientParam.getWaveType()),RmpEventDetailPO::getEventType, transientParam.getWaveType())
.in(CollUtil.isNotEmpty(transientParam.getEventReason()),RmpEventDetailPO::getAdvanceReason, transientParam.getEventReason())
.in(CollUtil.isNotEmpty(transientParam.getEventType()),RmpEventDetailPO::getAdvanceType, transientParam.getEventType())
);
List<EventDetailNew> eventDetailData=BeanUtil.copyToList(pageInfo.getRecords(),EventDetailNew.class);
page= BeanUtil.copyProperties(pageInfo,Page.class);
if (CollUtil.isNotEmpty(eventDetailData)) {
List<String> lineIds = eventDetailData.stream().map(EventDetailNew::getLineId).collect(Collectors.toList());
@@ -333,15 +349,15 @@ public class TransientServiceImpl implements TransientService {
}
for (DictData dictData : reasonList) {
if (eventDetail.getEventReason().equals(dictData.getId())) {
eventDetail.setEventReason(dictData.getName());
if (eventDetail.getAdvanceReason().equals(dictData.getId())) {
eventDetail.setAdvanceReason(dictData.getName());
break;
}
}
for (DictData dictData : typeList) {
if (eventDetail.getEventType().equals(dictData.getId())) {
eventDetail.setEventType(dictData.getName());
if (eventDetail.getAdvanceType().equals(dictData.getId())) {
eventDetail.setAdvanceType(dictData.getName());
break;
}
}
@@ -354,6 +370,68 @@ public class TransientServiceImpl implements TransientService {
}
// if (!CollectionUtils.isEmpty(lineList)) {
// StringBuilder stringBuilder = InfluxDBCommUtils.assToInfluxParam(lineList);
// //influxDB查询待分页数据总量
// Long total = getTransientDetail(stringBuilder, transientParam);
// page.setTotal(total);
// //分页总页数
// int pages = (int) Math.ceil(transientParam.getPageNum() * 1.0 / transientParam.getPageSize());
// page.setPages(pages);
// //influxDB分页查询
// List<EventDetailNew> eventDetailData = getTransientDetailLimit(lineList, transientParam);
//
// if (CollUtil.isNotEmpty(eventDetailData)) {
// List<String> lineIds = eventDetailData.stream().map(EventDetailNew::getLineId).collect(Collectors.toList());
// lineIds = lineIds.stream().distinct().collect(Collectors.toList());
//
// List<AreaLineInfoVO> r = lineFeignClient.getBaseLineAreaInfo(lineIds).getData();
// List<DictData> reasonList = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName()).getData();
// List<DictData> typeList = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName()).getData();
//
//
// for (EventDetailNew eventDetail : eventDetailData) {
// for (AreaLineInfoVO areaLineInfoVO : r) {
// if (eventDetail.getLineId().equals(areaLineInfoVO.getLineId())) {
// eventDetail.setLineId(areaLineInfoVO.getLineId());
// eventDetail.setLineName(areaLineInfoVO.getLineName());
// eventDetail.setGdName(areaLineInfoVO.getGdName());
// eventDetail.setSubName(areaLineInfoVO.getSubName());
// eventDetail.setIp(areaLineInfoVO.getIp());
// eventDetail.setScale(areaLineInfoVO.getVoltageScale());
// eventDetail.setIp(areaLineInfoVO.getIp());
// break;
// }
// }
//
// for (DictData dictData : reasonList) {
// if (eventDetail.getEventReason().equals(dictData.getId())) {
// eventDetail.setEventReason(dictData.getName());
// break;
// }
// }
//
// for (DictData dictData : typeList) {
// if (eventDetail.getEventType().equals(dictData.getId())) {
// eventDetail.setEventType(dictData.getName());
// break;
// }
// }
// }
//
//
// //当前页数据
// page.setRecords(eventDetailData);
// }
//
// }
}
return page;
}
@@ -476,7 +554,7 @@ public class TransientServiceImpl implements TransientService {
LineDetailDataVO lineDetailData = lineFeignClient.getLineDetailData(lineId.get(i)).getData();
EventDetail eventDetailByTime = eventDetailService.getEventDetailByTime(lineId.get(i), timeId.get(i));
String ip = lineDetailData.getIp();
String waveName = eventDetailByTime.getWaveName();
String waveName = eventDetailByTime.getWavePath();
if (StrUtil.isBlank(ip) && StrUtil.isBlank(waveName)) {
throw new BusinessException(EventResponseEnum.EVENT_NOT_FOUND);
}

2
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/HistoryResultServiceImpl.java
View File

@@ -78,7 +78,7 @@ public class HistoryResultServiceImpl implements HistoryResultService {
List<EventDetailVO> eventDetailVOList = new ArrayList<>();
if (!eventDetailList.isEmpty()) {
for (EventDetail eventdetail : eventDetailList) {
Instant now = eventdetail.getTimeId();
Instant now = eventdetail.getStartTime();
Long time = now.toEpochMilli();
String timeText = format.format(time);
EventDetailVO eventDetailVO = new EventDetailVO();

10
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java
View File

@@ -673,10 +673,10 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
private List<PublicDTO> getLineDate(List<String> line, String startTime, String endTime, String type) {
List<PublicDTO> result = new ArrayList<>();
String quota = "";
if (Objects.equals(type, DicDataEnum.XBDY_ENUM.getCode())) {
quota = "harmonic_v";
} else if (Objects.equals(type, DicDataEnum.XBDL_ENUM.getCode())) {
quota = "harmonic_i";
if (Objects.equals(type, DicDataEnum.V_HARMONIC.getCode())) {
quota = ",harmonic_v";
} else if (Objects.equals(type, DicDataEnum.I_ALL.getCode())) {
quota = ",harmonic_i";
}
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append(Param.TIME).append(" >= '").append(startTime).append(Param.START_TIME).append("' and ").append(Param.TIME).append(" <= '").append(endTime).append(Param.END_TIME).append("' and (");
@@ -688,7 +688,7 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
}
}
stringBuilder.append(" group by line_id order by time desc limit 1 tz('Asia/Shanghai')");
String sql = "SELECT line_id," + quota + " FROM harmonic_pollution where " + stringBuilder;
String sql = "SELECT line_id" + quota + " FROM harmonic_pollution where " + stringBuilder;
QueryResult sqlResult = influxDbUtils.query(sql);
List<QueryResult.Series> list = sqlResult.getResults().get(0).getSeries();
if (!CollectionUtils.isEmpty(list)) {

9
pqs-system/system-api/src/main/java/com/njcn/system/enums/DicDataEnum.java
View File

@@ -24,6 +24,12 @@ public enum DicDataEnum {
FXDL_ENUM("负序电流", "FXDL"),
JXBDY_ENUM("间谐波电压", "JXBDY"),
/**
* 污区图统计类型
*/
I_ALL("谐波电流", "I_All"),
V_HARMONIC("谐波电压", "V_Harmonic"),
/**
* 监测点类型
@@ -49,6 +55,9 @@ public enum DicDataEnum {
VOLTAGE_DIP("电压暂降", "Voltage_Dip"),
VOLTAGE_RISE("电压暂升", "Voltage_Rise"),
SHORT_INTERRUPTIONS("短时中断", "Short_Interruptions"),
DISTURBANCE("扰动", "Disturbance"),
OTHER("其他", "Other"),
RECORDING_WAVE("录波", "Recording_Wave"),
/**
* 数据类型