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

终端异常统计优化

Browse Source
This commit is contained in:
zhuxinyu
2023-03-30 09:38:47 +08:00
parent e3f85b6779
commit 346530b0a0
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/OperationContrController.java
View File

@@ -146,7 +146,7 @@ public class OperationContrController extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/getDailyDeviceAbnormalStatistics") @PostMapping("/getDailyDeviceAbnormalStatistics")
@ApiOperation("获取终端异常统计") @ApiOperation("获取终端异常统计")
@ApiImplicitParam(name = "conditionBusinessParam", value = "实体", required = true) @ApiImplicitParam(name = "param", value = "实体", required = true)
public HttpResult<Page<TopMsgPO>> dailyDeviceAbnormalStatistics(@RequestBody PqsParam param) { public HttpResult<Page<TopMsgPO>> dailyDeviceAbnormalStatistics(@RequestBody PqsParam param) {
String methodDescribe = getMethodDescribe("dailyDeviceAbnormalStatistics"); String methodDescribe = getMethodDescribe("dailyDeviceAbnormalStatistics");
Page<TopMsgPO> result = lineService.dailyDeviceAbnormalStatistics(param); Page<TopMsgPO> result = lineService.dailyDeviceAbnormalStatistics(param);

4
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/device/DeviceAbnormaStatisticsServiceImpl.java
View File

@@ -38,7 +38,7 @@ public class DeviceAbnormaStatisticsServiceImpl implements DeviceAbnormalStatist
// 获取监测点告警 // 获取监测点告警
List<AlarmPO> lineAlarms = deviceAbnormaStatisticsMapper.getAlarmByLines( List<AlarmPO> lineAlarms = deviceAbnormaStatisticsMapper.getAlarmByLines(
DateUtil.beginOfDay(DateUtil.parse(param.getBeginTime())), DateUtil.beginOfDay(DateUtil.parse(param.getBeginTime())),
DateUtil.beginOfDay(DateUtil.parse(param.getEndTime()))); DateUtil.endOfDay(DateUtil.parse(param.getEndTime())));
if (CollectionUtil.isNotEmpty(lineAlarms)){ if (CollectionUtil.isNotEmpty(lineAlarms)){
// 根据装置分组 // 根据装置分组
devLineMap = lineAlarms.stream().collect(Collectors.groupingBy(AlarmPO::getDeviceId)); devLineMap = lineAlarms.stream().collect(Collectors.groupingBy(AlarmPO::getDeviceId));
@@ -46,7 +46,7 @@ public class DeviceAbnormaStatisticsServiceImpl implements DeviceAbnormalStatist
// 获取设备流量 // 获取设备流量
List<AlarmPO> deviceAlarms = deviceAbnormaStatisticsMapper.getAlarmByDevice( List<AlarmPO> deviceAlarms = deviceAbnormaStatisticsMapper.getAlarmByDevice(
DateUtil.beginOfDay(DateUtil.parse(param.getBeginTime())), DateUtil.beginOfDay(DateUtil.parse(param.getBeginTime())),
DateUtil.beginOfDay(DateUtil.parse(param.getEndTime()))); DateUtil.endOfDay(DateUtil.parse(param.getEndTime())));
List<String> devs = deviceAlarms.stream().map(AlarmPO::getId).collect(Collectors.toList()); List<String> devs = deviceAlarms.stream().map(AlarmPO::getId).collect(Collectors.toList());
// 获取通信中断信息 // 获取通信中断信息
List<TopMsgPO> comMsgs = getCommunicate(devs, param.getBeginTime(), param.getEndTime()); List<TopMsgPO> comMsgs = getCommunicate(devs, param.getBeginTime(), param.getEndTime());