【灵山大屏】1.新增：根据组织id查询党员数接口

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/controller/LingShanScreenController.java

@@ -105,4 +105,16 @@ public class LingShanScreenController {
         return new Result<List<LingShanScreenPartyActQtyStatsResultDTO>>().ok(l);
     }
 
+    /**
+     * @description: 大屏地图-党员数
+     * @param agencyId:
+     * @return
+     * @author: WangXianZhang
+     * @date: 2023/4/17 1:54 PM
+     */
+    @GetMapping("partymemberQty")
+    public Result<Integer> getPartymemberQtyOfOrg(@RequestParam("agencyId") String agencyId) {
+        return new Result<Integer>().ok(lingShanScreenService.getPartymemberQtyOfOrg(agencyId));
+    }
+
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/LingShanScreenService.java

@@ -56,4 +56,13 @@ public interface LingShanScreenService {
      * @date: 2023/4/14 7:27 PM
      */
     List<LingShanScreenPartyActQtyStatsResultDTO> actQtyOfPartyOrgStats(String agencyId, Date holdTimeStart, Date holdTimeEnd);
+
+    /**
+     * @description: 大屏地图-党员数
+     * @param agencyId:
+     * @return
+     * @author: WangXianZhang
+     * @date: 2023/4/17 1:55 PM
+     */
+    Integer getPartymemberQtyOfOrg(String agencyId);
 }

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

@@ -305,4 +305,19 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD
 
         return rl;
     }
+
+    @Override
+    public Integer getPartymemberQtyOfOrg(String agencyId) {
+        AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId);
+        if (agencyInfo == null) {
+            logger.error("getPartymemberQtyOfOrg查询组织信息失败agencyId:{}", agencyId);
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询当前组织信息失败，agencyId:" + agencyId, "查询当前组织信息失败");
+        }
+
+        LambdaQueryWrapper<IcPartyMemberEntity> query = new LambdaQueryWrapper<>();
+        query.likeRight(IcPartyMemberEntity::getAgencyPids, PidUtils.convertPid2OrgIdPath(agencyId, agencyInfo.getPids()))
+                .or()
+                .eq(IcPartyMemberEntity::getAgencyId, agencyId);
+        return icPartyMemberDao.selectCount(query);
+    }
 }