diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/GwMonitorPushServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/GwMonitorPushServiceImpl.java index 496469f3a..e986a5527 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/GwMonitorPushServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/GwMonitorPushServiceImpl.java @@ -77,10 +77,6 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { @Override public String pushMonitor(List ids) { - /*if (ids.size() > 100) { - throw new BusinessException("一次最多上送100条数据"); - }*/ - List pushResult = new ArrayList<>(); //电压等级 @@ -104,15 +100,13 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { // Map pointMap = pointDicList.stream().collect(Collectors.toMap(DictData::getId, Function.identity())); - DictData monitorStateDic = dicDataFeignClient.getDicDataByNameAndTypeName(DicDataTypeEnum.LINE_STATE.getName(), DicDataEnum.RUN.getName()).getData(); - LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); if(CollUtil.isEmpty(ids)){ - lambdaQueryWrapper.eq(Monitor::getMonitorState,monitorStateDic.getId()) + lambdaQueryWrapper .eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()).eq(Monitor::getIsUpToGrid,1); }else { - lambdaQueryWrapper.in(Monitor::getId, ids).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()); + lambdaQueryWrapper.in(Monitor::getId, ids).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()).eq(Monitor::getIsUpToGrid,1); } List monitorList = monitorService.list(lambdaQueryWrapper); if(CollUtil.isEmpty(monitorList)){ @@ -321,10 +315,10 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); if(CollUtil.isEmpty(ids)){ - lambdaQueryWrapper.eq(Monitor::getMonitorState,monitorStateDic.getId()) + lambdaQueryWrapper .eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()).eq(Monitor::getIsUpToGrid,1); }else { - lambdaQueryWrapper.in(Monitor::getId, ids).eq(Monitor::getMonitorState,monitorStateDic.getId()).eq(Monitor::getIsUpToGrid,1).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()); + lambdaQueryWrapper.in(Monitor::getId, ids).eq(Monitor::getIsUpToGrid,1).eq(Monitor::getStatus, DataStateEnum.ENABLE.getCode()); } List monitorList = monitorService.list(lambdaQueryWrapper); @@ -332,10 +326,7 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { throw new BusinessException("未查询到有效监测点!"); } - long noCount = monitorList.stream().filter(item-> !Objects.equals(item.getMonitorState(),monitorStateDic.getId()) || item.getIsUpToGrid() == 0).count(); - if(noCount>0){ - throw new BusinessException("当前监测点未投运或非上送国网监测点"); - } + List monitorIds = monitorList.stream().map(Monitor::getId).distinct().collect(Collectors.toList()); diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/MonitorSendServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/MonitorSendServiceImpl.java index 7fb6e79f1..7451bdd67 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/MonitorSendServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/gwPush/impl/MonitorSendServiceImpl.java @@ -101,18 +101,13 @@ public class MonitorSendServiceImpl implements MonitorSendService { } - //运行状态 - List lineState = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.LINE_STATE.getCode()).getData(); - List run = lineState.stream().filter(x -> DicDataEnum.RUN.getCode() - .equals(x.getCode())).collect(Collectors.toList()); //获取监测点信息 lambdaQueryWrapper.in(StrUtil.isNotBlank(param.getMonitorTag()),Monitor::getMonitorTag, param.getMonitorTag()) .eq(Monitor::getIsUpToGrid,1) - .eq(Monitor::getMonitorState,run.get(0).getId()) - .ne(param.getFiy(),Monitor::getIsUploadHead,1) + //.ne(param.getFiy(),Monitor::getIsUploadHead,1) .in(CollUtil.isNotEmpty(param.getIds()),Monitor::getId, param.getIds()); List monitorList = monitorService.list(lambdaQueryWrapper); diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/PqTypicalSourceCreatePOServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/PqTypicalSourceCreatePOServiceImpl.java index a3f7aa8b9..0e6197cdc 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/PqTypicalSourceCreatePOServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/PqTypicalSourceCreatePOServiceImpl.java @@ -156,9 +156,7 @@ public class PqTypicalSourceCreatePOServiceImpl extends ServiceImpl send = GwSendUtil.send(sendParam, GWSendEnum.TYPICAL_SOURCE); - log.info(Thread.currentThread().getName() + "获取返回体换流站指标统计明细数据接口响应结果:" + send + "结束----!"); List trIds = dtoList.stream().map(PqTypicalSourceCreateDTO::getId).distinct().collect(Collectors.toList()); returnInformation(1, trIds, send); });