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

代码优化

Browse Source
This commit is contained in:
xy
2025-07-29 15:42:13 +08:00
parent 986c439644
commit d3294ccdbd
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -14,7 +14,9 @@ import com.njcn.common.utils.PubUtils;
import com.njcn.device.biz.commApi.CommTerminalGeneralClient; import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
import com.njcn.device.biz.pojo.dto.DeptGetBase; import com.njcn.device.biz.pojo.dto.DeptGetBase;
import com.njcn.device.biz.pojo.param.DeptGetLineParam; import com.njcn.device.biz.pojo.param.DeptGetLineParam;
import com.njcn.device.pq.api.DeptLineFeignClient;
import com.njcn.device.pq.api.LineFeignClient; import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.device.pq.pojo.po.DeptLine;
import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; import com.njcn.device.pq.pojo.vo.AreaLineInfoVO;
import com.njcn.event.pojo.vo.SendEventVO; import com.njcn.event.pojo.vo.SendEventVO;
import com.njcn.event.utils.EventUtil; import com.njcn.event.utils.EventUtil;
@@ -55,6 +57,7 @@ public class EventDetailServiceImpl extends ServiceImpl<EventDetailMapper, RmpEv
private final MqttPublisher publisher; private final MqttPublisher publisher;
private final CommTerminalGeneralClient commTerminalGeneralClient; private final CommTerminalGeneralClient commTerminalGeneralClient;
private final LineFeignClient lineFeignClient; private final LineFeignClient lineFeignClient;
private final DeptLineFeignClient deptLineFeignClient;
@Override @Override
@@ -181,12 +184,13 @@ public class EventDetailServiceImpl extends ServiceImpl<EventDetailMapper, RmpEv
} }
private void pushEvent(RmpEventDetailPO po) { private void pushEvent(RmpEventDetailPO po) {
//获取部门 //根据监测点获取部门
String deptIndex = RequestUtil.getDeptIndex(); DeptLine deptLine = deptLineFeignClient.getLineByLineIds(po.getMeasurementPointId()).getData();
String id = deptLine.getId();
Set<String> dept = new HashSet<>(); Set<String> dept = new HashSet<>();
dept.add(deptIndex); dept.add(id);
DeptGetLineParam deptGetLineParam = new DeptGetLineParam(); DeptGetLineParam deptGetLineParam = new DeptGetLineParam();
deptGetLineParam.setDeptId(deptIndex); deptGetLineParam.setDeptId(id);
List<DeptGetBase> deptList = commTerminalGeneralClient.getDeptChildrenByParent(deptGetLineParam).getData(); List<DeptGetBase> deptList = commTerminalGeneralClient.getDeptChildrenByParent(deptGetLineParam).getData();
if (CollectionUtil.isNotEmpty(deptList)) { if (CollectionUtil.isNotEmpty(deptList)) {
deptList.forEach(item->{ deptList.forEach(item->{