wxz 2 years ago
parent
commit
252c81d0ec
  1. 7
      epmet-module/resi-partymember/resi-partymember-server/pom.xml
  2. 31
      epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/LingShanPartyOrgServiceImpl.java
  3. 9
      epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/LingShanScreenServiceImpl.java

7
epmet-module/resi-partymember/resi-partymember-server/pom.xml

@ -12,6 +12,13 @@
<packaging>jar</packaging> <packaging>jar</packaging>
<dependencies> <dependencies>
<dependency>
<groupId>com.epmet</groupId>
<artifactId>epmet-heart-client</artifactId>
<version>
2.0.0
</version>
</dependency>
<dependency> <dependency>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>resi-partymember-client</artifactId> <artifactId>resi-partymember-client</artifactId>

31
epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/LingShanPartyOrgServiceImpl.java

@ -25,10 +25,8 @@ import com.epmet.resi.partymember.dto.partyOrg.result.LingShanScreenPartyObjectB
import com.epmet.resi.partymember.enums.LingShanPartyObjEnums; import com.epmet.resi.partymember.enums.LingShanPartyObjEnums;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.LinkedList; import java.util.*;
import java.util.List;
import java.util.Map;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -49,7 +47,15 @@ public class LingShanPartyOrgServiceImpl implements LingShanPartyOrgService, Res
ArrayList<LingShanPartyOrgAndOtherObjQtyRstDTO> tl = new ArrayList<>(); ArrayList<LingShanPartyOrgAndOtherObjQtyRstDTO> tl = new ArrayList<>();
// 1.党组织 // 1.党组织
AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); AgencyInfoCache agencyInfo = null;
try {
agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId);
} catch (
Exception e) {
logger.error("【灵山大屏-党对象数量查询】组织未找到:" + agencyId);
return convertPartyObjsMap2DTO(null);
}
String orgIdPath = PidUtils.convertPid2OrgIdPath(agencyInfo.getId(), agencyInfo.getPids()); String orgIdPath = PidUtils.convertPid2OrgIdPath(agencyInfo.getId(), agencyInfo.getPids());
String level = agencyInfo.getLevel(); String level = agencyInfo.getLevel();
@ -103,6 +109,20 @@ public class LingShanPartyOrgServiceImpl implements LingShanPartyOrgService, Res
// 4.检查缺项(党委, 支部, 党群服务中心, 党群服务站, 联建单位几项都要有,没有数据则显示0。党代表工作室目前还没开发,开发了也要有) // 4.检查缺项(党委, 支部, 党群服务中心, 党群服务站, 联建单位几项都要有,没有数据则显示0。党代表工作室目前还没开发,开发了也要有)
Map<String, LingShanPartyOrgAndOtherObjQtyRstDTO> map = tl.stream().collect(Collectors.toMap(LingShanPartyOrgAndOtherObjQtyRstDTO::getName, Function.identity())); Map<String, LingShanPartyOrgAndOtherObjQtyRstDTO> map = tl.stream().collect(Collectors.toMap(LingShanPartyOrgAndOtherObjQtyRstDTO::getName, Function.identity()));
return convertPartyObjsMap2DTO(map);
}
/**
* @Description: 看看哪个缺了补上
* @param map:
* @Return java.util.List
* @Author: wangxianzhang
* @Date: 2023/5/23 3:43 PM
*/
public List convertPartyObjsMap2DTO(Map<String, LingShanPartyOrgAndOtherObjQtyRstDTO> map) {
if (map == null) {
map = new HashMap<>();
}
LinkedList rl = new LinkedList<LingShanPartyOrgAndOtherObjQtyRstDTO>(); LinkedList rl = new LinkedList<LingShanPartyOrgAndOtherObjQtyRstDTO>();
LingShanPartyOrgAndOtherObjQtyRstDTO dw = map.get("党委"); LingShanPartyOrgAndOtherObjQtyRstDTO dw = map.get("党委");
rl.add(dw != null ? dw : new LingShanPartyOrgAndOtherObjQtyRstDTO(LingShanPartyObjEnums.DW.getCode(), "党委", 0)); rl.add(dw != null ? dw : new LingShanPartyOrgAndOtherObjQtyRstDTO(LingShanPartyObjEnums.DW.getCode(), "党委", 0));
@ -118,7 +138,6 @@ public class LingShanPartyOrgServiceImpl implements LingShanPartyOrgService, Res
LingShanPartyOrgAndOtherObjQtyRstDTO ljdz = map.get("联建单位"); LingShanPartyOrgAndOtherObjQtyRstDTO ljdz = map.get("联建单位");
rl.add(ljdz != null ? ljdz : new LingShanPartyOrgAndOtherObjQtyRstDTO(LingShanPartyObjEnums.PARTY_UNIT.getCode(), "联建单位", 0)); rl.add(ljdz != null ? ljdz : new LingShanPartyOrgAndOtherObjQtyRstDTO(LingShanPartyObjEnums.PARTY_UNIT.getCode(), "联建单位", 0));
return rl; return rl;
} }

9
epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/LingShanScreenServiceImpl.java

@ -62,7 +62,14 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD
@Override @Override
public List<LingShanScreenPartyOrgCategoryResultDTO> listPartyOrgCategoryAndQuantity(String agencyId) { public List<LingShanScreenPartyOrgCategoryResultDTO> listPartyOrgCategoryAndQuantity(String agencyId) {
AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); AgencyInfoCache agencyInfo = null;
try {
agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId);
} catch (Exception e) {
logger.error("【灵山大屏-党对象数量查询】组织未找到:" + agencyId);
return new ArrayList<>();
}
if (agencyInfo == null) { if (agencyInfo == null) {
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询当前组织信息失败,agencyId:" + agencyId, "查询当前组织信息失败"); throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询当前组织信息失败,agencyId:" + agencyId, "查询当前组织信息失败");
} }

Loading…
Cancel
Save