diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/DeptLineFeignClient.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/DeptLineFeignClient.java index 4480e7173..e9bf94126 100644 --- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/DeptLineFeignClient.java +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/DeptLineFeignClient.java @@ -7,7 +7,6 @@ import com.njcn.device.pq.pojo.po.DeptLine; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestParam; - import java.util.List; import java.util.Map; @@ -19,7 +18,10 @@ import java.util.Map; @FeignClient(value = ServerInfo.DEVICE,path = "/deptLine",fallbackFactory = DeptLineFeignClientFallbackFactory.class,contextId = "deptLine") public interface DeptLineFeignClient { @PostMapping("/getLineByDeptId") - HttpResult> getLineByDeptId(String id); + HttpResult> getLineByDeptId(@RequestParam("id")String id); + + @PostMapping("/getLineByDeptIdAndNewStation") + HttpResult> getLineByDeptIdAndNewStation(@RequestParam("id")String id,@RequestParam("type")String type); @PostMapping("/selectDeptBindLines") HttpResult selectDeptBindLines(@RequestParam("ids") List ids); diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/fallback/DeptLineFeignClientFallbackFactory.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/fallback/DeptLineFeignClientFallbackFactory.java index 9e2679cc6..5bd202030 100644 --- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/fallback/DeptLineFeignClientFallbackFactory.java +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/api/fallback/DeptLineFeignClientFallbackFactory.java @@ -39,6 +39,12 @@ public class DeptLineFeignClientFallbackFactory implements FallbackFactory> getLineByDeptIdAndNewStation(String id, String type) { + log.error("{}异常,降级处理,异常为:{}", "根据部门id获取绑定的监测点且再根据NewStation进行过滤", throwable.toString()); + throw new BusinessException(finalExceptionEnum); + } + @Override public HttpResult selectDeptBindLines(List ids) { log.error("{}异常,降级处理,异常为:{}", "部门Ids集合查询是否绑定", throwable.toString()); diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/DeptLineController.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/DeptLineController.java index a602b9cb5..c37dec7d1 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/DeptLineController.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/DeptLineController.java @@ -112,6 +112,15 @@ public class DeptLineController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); } + @OperateInfo(info = LogEnum.SYSTEM_COMMON) + @PostMapping("/getLineByDeptIdAndNewStation") + @ApiOperation("根据部门id获取绑定的监测点且再根据NewStation进行过滤") + public HttpResult> getLineByDeptIdAndNewStation(@RequestParam("id") String id,@RequestParam("type")String type) { + String methodDescribe = getMethodDescribe("getLineByDeptIdAndNewStation"); + List list = deptLineService.getLineByDeptIdAndNewStation(id,type); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); + } + @OperateInfo(info = LogEnum.SYSTEM_COMMON) @PostMapping("/getLineDetailByDeptId") @ApiOperation("部门Id获取绑定监测点详情") diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/DeptLineMapper.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/DeptLineMapper.java index 83be88ac3..8a3156746 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/DeptLineMapper.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/DeptLineMapper.java @@ -82,4 +82,6 @@ public interface DeptLineMapper extends BaseMapper { List selectSubStationList(@Param("param") SubstationParam substationParam); + + List getLineByDeptIdAndNewStation(@Param("id") String id,@Param("stationType") String stationType); } diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/DeptLineMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/DeptLineMapper.xml index 13bf15d54..9c6c73e30 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/DeptLineMapper.xml +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/DeptLineMapper.xml @@ -194,4 +194,10 @@ + + diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/DeptLineService.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/DeptLineService.java index 2bd783503..401632dab 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/DeptLineService.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/DeptLineService.java @@ -67,7 +67,13 @@ public interface DeptLineService extends IService { */ List getLineByDeptId(String id); - + /** + * 功能描述: 根据部门id获取绑定的监测点且再根据NewStation进行过滤 + * @param id,type + * @author guofeihu + * @date 2024/8/19 + */ + List getLineByDeptIdAndNewStation(String id,String type); /** * @Description: 根据部门id获取所有子集部门所包含的部门信息 diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DeptLineServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DeptLineServiceImpl.java index d29d679fa..d837147a7 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DeptLineServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DeptLineServiceImpl.java @@ -12,6 +12,7 @@ import com.njcn.device.pq.mapper.LineMapper; import com.njcn.device.pq.pojo.po.DeptLine; import com.njcn.device.pq.pojo.vo.LineDeviceStateVO; import com.njcn.device.pq.service.DeptLineService; +import com.njcn.event.pojo.constant.Param; import com.njcn.user.api.DeptFeignClient; import com.njcn.user.pojo.dto.DeptDTO; import com.njcn.web.pojo.param.DeptLineParam; @@ -88,6 +89,13 @@ public class DeptLineServiceImpl extends ServiceImpl i return this.lambdaQuery().in(DeptLine::getId, id).list().stream().map(DeptLine::getLineId).distinct().collect(Collectors.toList()); } + @Override + public List getLineByDeptIdAndNewStation(String id, String type) { + if("1".equals(type)) type = Param.WINDFARM; + if("2".equals(type)) type = Param.PHOTOVOLTAICPOWER; + return this.baseMapper.getLineByDeptIdAndNewStation(id,type); + } + @Override public List getLineNodeByDeptId(String id) { List deptInfos = deptFeignClient.getDeptDescendantIndexes(id, WebUtil.filterDeptType()).getData(); diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineServiceImpl.java index b044163fc..9cda65b62 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineServiceImpl.java @@ -501,9 +501,11 @@ public class LineServiceImpl extends ServiceImpl implements Li List data = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.DEV_VOLTAGE_STAND.getCode()).getData(); Map dicMap = data.stream().collect(Collectors.toMap(DictData::getId, DictData::getValue)); LineDTO lineDTO = this.baseMapper.selectLineDetail(id); - if(dicMap.containsKey(lineDTO.getVoltageLevel())){ - lineDTO.setVoltageLevel(dicMap.get(lineDTO.getVoltageLevel())); - return lineDTO; + if(lineDTO != null){ + if(dicMap.containsKey(lineDTO.getVoltageLevel())){ + lineDTO.setVoltageLevel(dicMap.get(lineDTO.getVoltageLevel())); + return lineDTO; + } } return null; } diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/constant/Param.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/constant/Param.java index e30f4164c..54b9595ec 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/constant/Param.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/constant/Param.java @@ -27,6 +27,14 @@ public interface Param { String BEGIN =" 00:00:00"; String END =" 23:59:59"; - + //以下四个固定ID用于某些业务判断 + //字典(sys_dict_data):电压暂升的ID + String UPPEREVENT = "c5ce588cb76fba90c4519ab250c962d0"; + //字典(sys_dict_data):电升暂升的ID + String LOWEREVENT = "c37861896dafab0883321e1d508caa51"; + //字典(sys_dict_data):光伏电站的ID + String PHOTOVOLTAICPOWER = "45615057cb88650ffc4779b0629bac7e"; + //字典(sys_dict_data):风电场的ID + String WINDFARM = "f9145acb79cbf136b9ee89fd38d72583"; } diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/param/VoltageRideThroughQueryParam.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/param/VoltageRideThroughQueryParam.java new file mode 100644 index 000000000..d5696333a --- /dev/null +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/param/VoltageRideThroughQueryParam.java @@ -0,0 +1,28 @@ +package com.njcn.event.pojo.param; + +import com.njcn.web.pojo.param.BaseParam; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import javax.validation.constraints.NotBlank; +import java.util.List; + +/** + * 高低电压穿越统计查询实体类 + * @author guofeihu + * @since 2024-08-15 + */ +@Data +public class VoltageRideThroughQueryParam extends BaseParam { + + @ApiModelProperty("区域ID") + @NotBlank(message = "区域ID不能为空") + private String areaId; + + @ApiModelProperty("1:风电场,2:光伏电厂") + @NotBlank(message = "新能源场站不能为空") + private String type; + + @ApiModelProperty("监测点集合(用于后端使用)") + private List lineIds; + +} diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/EventNewStationVo.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/EventNewStationVo.java new file mode 100644 index 000000000..de01a7e5b --- /dev/null +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/EventNewStationVo.java @@ -0,0 +1,39 @@ +package com.njcn.event.pojo.vo; + +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * 高低电压穿越统计 暂降事件列表实体类 + * @author guofeihu + * @since 2024-08-15 + */ +@Data +public class EventNewStationVo implements Serializable { + + @ApiModelProperty(value = "事件ID") + private String eventId; + + @ApiModelProperty(value = "监测点ID") + private String lineId; + + @ApiModelProperty(value = "电站名称") + private String newStationName; + + @ApiModelProperty(value = "开始时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS") + private LocalDateTime startTime; + + @ApiModelProperty(value = "特征幅值") + private Double featureAmplitude; + + @ApiModelProperty(value = "暂降原因") + private String advanceReason; + + @ApiModelProperty(value = "暂降严重度") + private Double severity; + +} diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/VoltageRideThroughVo.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/VoltageRideThroughVo.java new file mode 100644 index 000000000..2dd811258 --- /dev/null +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/VoltageRideThroughVo.java @@ -0,0 +1,34 @@ +package com.njcn.event.pojo.vo; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import java.io.Serializable; +import java.math.BigDecimal; + +/** + * 高低电压穿越统计 地图实体类 + * @author: guofeihu + * @date: 2024-08-15 + */ +@Data +public class VoltageRideThroughVo implements Serializable { + + @ApiModelProperty("地区ID") + private String id; + + @ApiModelProperty("地区名称") + private String name; + + @ApiModelProperty("中心点经度") + private BigDecimal lng; + + @ApiModelProperty("中心点纬度") + private BigDecimal lat; + + @ApiModelProperty("低压次数") + private String lowPressure; + + @ApiModelProperty("高压次数") + private String highPressure; + +} diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/VoltageRideThroughEventController.java b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/VoltageRideThroughEventController.java new file mode 100644 index 000000000..e77c569d8 --- /dev/null +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/controller/majornetwork/VoltageRideThroughEventController.java @@ -0,0 +1,60 @@ +package com.njcn.event.controller.majornetwork; + +import com.njcn.common.pojo.annotation.OperateInfo; +import com.njcn.common.pojo.constant.OperateType; +import com.njcn.common.pojo.enums.common.LogEnum; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.common.utils.HttpResultUtil; +import com.njcn.common.utils.LogUtil; +import com.njcn.event.pojo.param.VoltageRideThroughQueryParam; +import com.njcn.event.pojo.vo.EventNewStationVo; +import com.njcn.event.pojo.vo.VoltageRideThroughVo; +import com.njcn.event.service.majornetwork.VoltageRideThroughEventService; +import com.njcn.web.controller.BaseController; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import java.util.List; + +/** + *

+ * 高低电压穿越统计 前端控制器 + *

+ * @author guofeihu + * @since 2024-08-14 + */ +@Api(tags = "高低电压穿越统计") +@Slf4j +@RestController +@RequestMapping("/voltageRideThrough") +@RequiredArgsConstructor +public class VoltageRideThroughEventController extends BaseController { + + private final VoltageRideThroughEventService voltageRideThroughEventService; + + @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.QUERY) + @PostMapping("/view") + @ApiOperation("查询高低电压穿越视图") + public HttpResult> voltageRideThroughView(@RequestBody @Validated VoltageRideThroughQueryParam voltageRideThroughQueryParam) { + String methodDescribe = getMethodDescribe("voltageRideThroughView"); + LogUtil.njcnDebug(log, "{},查询对象为:{}", methodDescribe, voltageRideThroughQueryParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, voltageRideThroughEventService.voltageRideThroughView(voltageRideThroughQueryParam), methodDescribe); + } + + @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.QUERY) + @PostMapping("/eventQueryPage") + @ApiOperation("高低电压穿越暂态事件分页") + public HttpResult> voltageRideThroughEventQueryPage(@RequestBody @Validated VoltageRideThroughQueryParam voltageRideThroughQueryParam) { + String methodDescribe = getMethodDescribe("voltageRideThroughEventQueryPage"); + LogUtil.njcnDebug(log, "{},查询对象为:{}", methodDescribe, voltageRideThroughQueryParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, voltageRideThroughEventService.voltageRideThroughEventQueryPage(voltageRideThroughQueryParam), methodDescribe); + } + +} diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/VoltageRideThroughEventServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/VoltageRideThroughEventServiceImpl.java new file mode 100644 index 000000000..491d45619 --- /dev/null +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/VoltageRideThroughEventServiceImpl.java @@ -0,0 +1,136 @@ +package com.njcn.event.service.majornetwork.Impl; + +import cn.hutool.core.bean.BeanUtil; +import com.njcn.device.biz.commApi.CommLineClient; +import com.njcn.device.biz.pojo.dto.LineDTO; +import com.njcn.device.pq.api.DeptLineFeignClient; +import com.njcn.device.pq.api.LineFeignClient; +import com.njcn.device.pq.api.NewStationClient; +import com.njcn.device.pq.pojo.po.NewStation; +import com.njcn.device.pq.pojo.vo.LineDetailDataVO; +import com.njcn.event.pojo.constant.Param; +import com.njcn.event.pojo.param.VoltageRideThroughQueryParam; +import com.njcn.event.pojo.po.EventDetail; +import com.njcn.event.pojo.vo.EventNewStationVo; +import com.njcn.event.pojo.vo.VoltageRideThroughVo; +import com.njcn.event.service.majornetwork.EventDetailService; +import com.njcn.event.service.majornetwork.VoltageRideThroughEventService; +import com.njcn.system.api.AreaFeignClient; +import com.njcn.system.pojo.po.Area; +import com.njcn.user.api.DeptFeignClient; +import com.njcn.user.pojo.dto.DeptDTO; +import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; +import java.util.stream.Collectors; + +/** + *

+ * 高低电压穿越统计 服务类实现类 + *

+ * @author guofeihu + * @since 2024-08-14 + */ +@Service +@AllArgsConstructor +@Slf4j +public class VoltageRideThroughEventServiceImpl implements VoltageRideThroughEventService { + + private final AreaFeignClient areaFeignClient; + + private final DeptFeignClient deptFeignClient; + + private final DeptLineFeignClient deptLineFeignClient; + + private final CommLineClient commLineClient; + + private final LineFeignClient lineFeignClient; + + private final EventDetailService eventDetailService; + + private final NewStationClient newStationClient; + + @Override + public List voltageRideThroughView(VoltageRideThroughQueryParam voltageRideThroughQueryParam) { + List voltageRideThroughVos = new ArrayList<>(); + //根据当前选择的部门ID获取其下的子部门集合 + List deptDTOS = deptFeignClient.getDepSonDetailByDeptId(voltageRideThroughQueryParam.getAreaId()).getData(); + for(DeptDTO deptDTO : deptDTOS){ + //子部门信息 + VoltageRideThroughVo voltageRideThroughVo = new VoltageRideThroughVo(); + //赋值子部门名称及ID + BeanUtils.copyProperties(deptDTO,voltageRideThroughVo); + //根据子部门的area获取经纬度 + Area area = areaFeignClient.selectIdArea(deptDTO.getArea()).getData(); + if(area != null){ + voltageRideThroughVo.setLat(area.getLat()); + voltageRideThroughVo.setLng(area.getLng()); + } + //开始计算每个地区高低压穿越次数 + //获取当前部门下所有的监测点(当然也会根据选择的新能源场站类型进行过滤) + List lineIds = deptLineFeignClient.getLineByDeptIdAndNewStation(deptDTO.getId(),voltageRideThroughQueryParam.getType()).getData(); + for(String lineId : lineIds){ + //监测点信息 + LineDTO lineDTO = commLineClient.getLineDetail(lineId).getData(); + if(lineDTO == null){ + continue; + } + //监测点绑定的暂降事件 + List eventDetails = eventDetailService.getEventDetailData(lineId,voltageRideThroughQueryParam.getSearchBeginTime()+Param.BEGIN,voltageRideThroughQueryParam.getSearchEndTime()+Param.END); + //取出事件类型为:暂升 + List upperEventDetails = eventDetails.stream().filter(e -> e.getEventType().equals(Param.UPPEREVENT)).collect(Collectors.toList()); + //取出事件类型为:暂降 + List lowerEventDetails = eventDetails.stream().filter(e -> e.getEventType().equals(Param.LOWEREVENT)).collect(Collectors.toList()); + //当前监测点为:光伏电站 + if(Param.PHOTOVOLTAICPOWER.equals(lineDTO.getStationType())){ + //计算 光伏电站 暂升次数 + for(EventDetail eventDetail : upperEventDetails){ + + } + //计算 光伏电站 暂降次数 + for(EventDetail eventDetail : lowerEventDetails){ + + } + } + //当前监测点为:风电场 + if(Param.WINDFARM.equals(lineDTO.getStationType())){ + //计算 风电场 暂升次数 + for(EventDetail eventDetail : upperEventDetails){ + + } + //计算 风电场 暂降次数 + for(EventDetail eventDetail : lowerEventDetails){ + + } + } + } + voltageRideThroughVos.add(voltageRideThroughVo); + } + return voltageRideThroughVos; + } + + @Override + public List voltageRideThroughEventQueryPage(VoltageRideThroughQueryParam voltageRideThroughQueryParam) { + List eventNewStationVos = new ArrayList<>(); + List lineIds = new ArrayList<>(); + //获取当前选择的部门下所有的监测点(当然也会根据选择的新能源场站类型进行过滤) + lineIds.addAll(deptLineFeignClient.getLineByDeptIdAndNewStation(voltageRideThroughQueryParam.getAreaId(),voltageRideThroughQueryParam.getType()).getData()); + if(!lineIds.isEmpty()){ + //根据监测点获取监测点下所有的事件集合 + eventNewStationVos = BeanUtil.copyToList(eventDetailService.getEventDetail(lineIds,voltageRideThroughQueryParam.getSearchBeginTime()+Param.BEGIN,voltageRideThroughQueryParam.getSearchEndTime()+Param.END,null), EventNewStationVo.class); + //特殊处理事件集合中新能源场站名称 + for(EventNewStationVo eventNewStationVo : eventNewStationVos){ + List lineDetailDataVOS = lineFeignClient.getLineDetailList(Arrays.asList(eventNewStationVo.getLineId())).getData(); + if(!lineDetailDataVOS.isEmpty()){ + NewStation newStation = newStationClient.selectById(lineDetailDataVOS.get(0).getNewStationId()).getData(); + eventNewStationVo.setNewStationName(newStation.getName()); + } + } + } + return eventNewStationVos; + } +} diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/VoltageRideThroughEventService.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/VoltageRideThroughEventService.java new file mode 100644 index 000000000..5cc20378f --- /dev/null +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/VoltageRideThroughEventService.java @@ -0,0 +1,32 @@ +package com.njcn.event.service.majornetwork; + +import com.njcn.event.pojo.param.VoltageRideThroughQueryParam; +import com.njcn.event.pojo.vo.EventNewStationVo; +import com.njcn.event.pojo.vo.VoltageRideThroughVo; +import java.util.List; + +/** + *

+ * 高低电压穿越统计 服务类 + *

+ * @author guofeihu + * @since 2024-08-14 + */ +public interface VoltageRideThroughEventService { + + + /*** + * 查询高低电压穿越视图 + * @param voltageRideThroughQueryParam + * @return List + */ + List voltageRideThroughView(VoltageRideThroughQueryParam voltageRideThroughQueryParam); + + /*** + * 高低电压穿越暂态事件分页 + * @param voltageRideThroughQueryParam + * @return Page + */ + List voltageRideThroughEventQueryPage(VoltageRideThroughQueryParam voltageRideThroughQueryParam); + +}