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 3f903d943..71a49b303 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 @@ -27,6 +27,8 @@ import com.njcn.system.enums.DicDataEnum; import com.njcn.system.enums.DicDataTypeEnum; import com.njcn.system.pojo.po.DictData; import com.njcn.system.pojo.po.SysDicTreePO; +import com.njcn.user.api.DeptFeignClient; +import com.njcn.user.pojo.po.Dept; import com.njcn.web.enums.GWSendEnum; import com.njcn.web.factory.PageFactory; import com.njcn.web.pojo.param.BaseParam; @@ -60,6 +62,8 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { private final DicDataFeignClient dicDataFeignClient; + private final DeptFeignClient deptFeignClient; + private final DictTreeFeignClient dictTreeFeignClient; private final StatationStatMapper statationStatMapper; @@ -73,9 +77,9 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { @Override public String pushMonitor(List ids) { - if (ids.size() > 100) { + /*if (ids.size() > 100) { throw new BusinessException("一次最多上送100条数据"); - } + }*/ List pushResult = new ArrayList<>(); @@ -139,12 +143,19 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { Map mapTerminal = pmsTerminalList.stream().collect(Collectors.toMap(PmsTerminal::getId,Function.identity())); Map mapBus = GeneratrixWireList.stream().collect(Collectors.toMap(GeneratrixWire::getId,Function.identity())); + + //获取母线中台信息 List pmsMidLedgers = pmsMidLedgerMapper.selectList(new LambdaQueryWrapper() - .in(PmsMidLedger::getId, mapBus.keySet()) + .in(PmsMidLedger::getId, GeneratrixWireList.stream().map(GeneratrixWire::getMidBusId).distinct().collect(Collectors.toList())) ); Map mapMidLedger = pmsMidLedgers.stream().collect(Collectors.toMap(PmsMidLedger::getId,Function.identity())); + //单位处理 + List deptList = deptFeignClient.getAllDept().getData(); + Map deptMap = deptList.stream().collect(Collectors.toMap(Dept::getCode,Function.identity())); + Map deptIdMap = deptList.stream().collect(Collectors.toMap(Dept::getId,Function.identity())); + for (Monitor item : monitorList) { PushMonitorDTO pushMonitorDTO = new PushMonitorDTO(); @@ -152,7 +163,7 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { pushMonitorDTO.setMonitorId(item.getMonitorId()); pushMonitorDTO.setMonitorName(item.getName()); pushMonitorDTO.setTerminalCode(item.getTerminalId()); - pushMonitorDTO.setCityId(item.getOrgId()); + pushMonitorDTO.setCityId(deptIdMap.get(deptMap.get(item.getOrgId()).getPid()).getCode()); pushMonitorDTO.setIsMajorNet("1"); pushMonitorDTO.setProvinceId("13B9B47F1E483324E05338297A0A0595"); @@ -225,9 +236,9 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { }*/ - /*if (StrUtil.isNotBlank(item.getOperationId())) { - pushMonitorDTO.setMaintOrg(item.getOperationId()); - }*/ + if (StrUtil.isNotBlank(item.getOrgName())) { + pushMonitorDTO.setMaintOrg(item.getOrgName()); + } if (Objects.nonNull(item.getStatisticalInterval())) { pushMonitorDTO.setStatisticalInterval(item.getStatisticalInterval().toString()); } @@ -292,9 +303,9 @@ public class GwMonitorPushServiceImpl implements GwMonitorPushService { @Override public String pushMonitorOverLimit(List ids) { - if (ids.size() > 100) { + /* if (ids.size() > 100) { throw new BusinessException("一次最多上送100条数据"); - } + }*/ List pushResult = new ArrayList<>();