diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/impl/GovProjectServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/impl/GovProjectServiceImpl.java index 087a4e9b17..5077b0af84 100644 --- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/impl/GovProjectServiceImpl.java +++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/impl/GovProjectServiceImpl.java @@ -557,11 +557,11 @@ public class GovProjectServiceImpl implements GovProjectService { List eventUser = projectDao.getEventList(projectIds); List topicUser = projectDao.getTopicUser(projectIds); - //5.封装数据 + //6.封装数据 //组织或网格id->组织或网格名称 Map map = new HashMap<>(); result.getList().forEach(re -> { - //所属组织 + //所属组织【议题来源网格】 if ("issue".equals(re.getOrigin())) { if (map.containsKey(re.getGridId())) { re.setOrgName(map.get(re.getGridId())); @@ -572,6 +572,7 @@ public class GovProjectServiceImpl implements GovProjectService { map.put(re.getGridId(), gridInfo.getGridName()); } } + //立项来源组织 } else if ("agency".equals(re.getOrigin())) { if (map.containsKey(re.getAgencyId())) { re.setOrgName(map.get(re.getAgencyId())); @@ -583,6 +584,7 @@ public class GovProjectServiceImpl implements GovProjectService { } } + //事件区分上报给网格或组织 } else if ("resi_event".equals(re.getOrigin())) { if (eventMap.containsKey(re.getOriginId())) { if ("grid".equals(eventMap.get(re.getOriginId()).getOrgType())) { @@ -613,13 +615,15 @@ public class GovProjectServiceImpl implements GovProjectService { List caId = new ArrayList<>(); list.forEach(ca -> { if (ca.getProjectId().equals(re.getProjectId())) { - caId.add(ca.getCategoryPids()); + //caId.add(ca.getCategoryPids()); + caId.add(ca.getCategoryCode()); } }); //一级分类名称、code集合 List caName = new ArrayList<>(); List caCode = new ArrayList<>(); - categoryList.forEach(ca -> caId.stream().filter(li -> ca.getId().equals(li)).forEach(s -> { + //categoryList.forEach(ca -> caId.stream().filter(li -> ca.getId().equals(li)).forEach(s -> { + categoryList.forEach(ca -> caId.stream().filter(li -> ca.getCategoryCode().equals(li)).forEach(s -> { caName.add(ca.getCategoryName()); caCode.add(ca.getCategoryCode()); }));