Merge branch 'dev_project_statis'

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/govorg/CustomerStaffAgencyDao.java

@@ -22,6 +22,7 @@ import com.epmet.dataaggre.dto.govorg.CustomerAgencyDTO;
 import com.epmet.dataaggre.dto.govorg.CustomerGridDTO;
 import com.epmet.dataaggre.dto.govorg.CustomerStaffAgencyDTO;
 import com.epmet.dataaggre.dto.govorg.OrgDTO;
+import com.epmet.dataaggre.dto.govorg.result.StaffOrgRelationResultDTO;
 import com.epmet.dataaggre.entity.govorg.CustomerStaffAgencyEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -71,4 +72,6 @@ public interface CustomerStaffAgencyDao extends BaseDao<CustomerStaffAgencyEntit
      */
     List<OrgDTO> selectSubAgency(@Param("agencyId") String agencyId, @Param("userId") String userId);
 
+    List<StaffOrgRelationResultDTO> getStaffList(@Param("orgId") String orgId, @Param("orgType") String orgType);
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/govorg/CustomerStaffGridDao.java

@@ -56,4 +56,6 @@ public interface CustomerStaffGridDao extends BaseDao<CustomerStaffGridEntity> {
      * @Date 2021/8/20 14:37
      */
     List<OrgDTO> selectGridList(@Param("agencyId") String agencyId, @Param("userId") String userId);
+
+    List<GridStaffResultDTO> getGridStaffByAgency(@Param("agencyId") String agencyId);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/govproject/ProjectDao.java

@@ -130,4 +130,6 @@ public interface ProjectDao extends BaseDao<ProjectEntity> {
     List<OrgCountDTO> getGridClosedProjectCount(OrgStatisticsFormDTO formDTO);
     List<OrgCountDTO> getMemberProjectCount(OrgStatisticsFormDTO formDTO);
     List<OrgCountDTO> getMemberClosedProjectCount(OrgStatisticsFormDTO formDTO);
+    List<OrgCountDTO> getAgencyProjectCount(OrgStatisticsFormDTO formDTO);
+    List<OrgCountDTO> getAgencyClosedProjectCount(OrgStatisticsFormDTO formDTO);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java

@@ -605,6 +605,9 @@ public class EpmetUserServiceImpl implements EpmetUserService {
         queryWrapper.eq(CustomerStaffEntity::getUserId,staffId)
         .eq(CustomerStaffEntity::getDelFlag,NumConstant.ZERO_STR);
         CustomerStaffEntity staffEntity = customerStaffDao.selectOne(queryWrapper);
+        if (null == staffEntity) {
+            return null;
+        }
         CustomerStaffResultDTO result = ConvertUtils.sourceToTarget(staffEntity, CustomerStaffResultDTO.class);
 
         //查询工作人员所属组织信息

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govorg/impl/GovOrgServiceImpl.java

@@ -3,6 +3,7 @@ package com.epmet.dataaggre.service.govorg.impl;
 import cn.afterturn.easypoi.excel.ExcelExportUtil;
 import cn.afterturn.easypoi.excel.entity.ExportParams;
 import cn.afterturn.easypoi.excel.entity.enmus.ExcelType;
+import cn.hutool.core.bean.BeanUtil;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.dingtalk.api.request.OapiRobotSendRequest;
@@ -24,17 +25,17 @@ import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
 import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
 import com.epmet.commons.tools.redis.common.bean.AgencyInfoCache;
 import com.epmet.commons.tools.redis.common.bean.BuildingInfoCache;
+import com.epmet.commons.tools.redis.common.bean.CustomerStaffInfoCache;
 import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
-import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.commons.tools.utils.HttpClientManager;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dataaggre.constant.DataSourceConstant;
 import com.epmet.dataaggre.constant.OrgConstant;
 import com.epmet.dataaggre.dao.govorg.*;
-import com.epmet.dataaggre.dto.datastats.result.SubAgencyProjectResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.form.ResisByPolicyRulesFormDTO;
+import com.epmet.dataaggre.dto.epmetuser.result.CustomerStaffResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.ListStaffResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.StaffRoleListResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.StaffSelectResDTO;
@@ -66,6 +67,7 @@ import org.apache.commons.fileupload.disk.DiskFileItemFactory;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.entity.ContentType;
 import org.apache.poi.ss.usermodel.Workbook;
+import org.jetbrains.annotations.Nullable;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.commons.CommonsMultipartFile;
@@ -75,6 +77,7 @@ import javax.servlet.ServletOutputStream;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.io.OutputStream;
+import java.text.Collator;
 import java.text.NumberFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -1153,17 +1156,12 @@ public class GovOrgServiceImpl implements GovOrgService {
     public PageData<OrgProjectDetailResultDTO> orgProjectDetailList(TokenDto tokenDto, OrgStatisticsFormDTO formDTO) {
         List<OrgProjectDetailResultDTO> resultList = new ArrayList<>();
         if (StringUtils.isBlank(formDTO.getAgencyId())) {
-            CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
+            CustomerStaffInfoCacheResult staffInfo = getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
             if (null == staffInfo) {
                 throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取用户信息失败", "获取用户信息失败");
             }
             formDTO.setAgencyId(staffInfo.getAgencyId());
         }
-        if (StringUtils.isEmpty(formDTO.getStartDate()) && StringUtils.isEmpty(formDTO.getEndDate())) {
-            //当前日期前一天
-            String dateId = DateUtils.format(DateUtils.addDateDays(new Date(), NumConstant.ONE_NEG), DateUtils.DATE_PATTERN_YYYYMMDD);
-            formDTO.setEndDate(dateId);
-        }
         CustomerAgencyEntity agencyEntity = customerAgencyDao.selectById(formDTO.getAgencyId());
         if (null == agencyEntity) {
             return new PageData<>(Collections.emptyList(), NumConstant.ZERO);
@@ -1184,7 +1182,7 @@ public class GovOrgServiceImpl implements GovOrgService {
                 //统计网格关闭项目数
                 Map<String, Integer> closedMap = govProjectService.getGridClosedProjectMap(formDTO);
                 //网格员统计
-                Map<String, Integer> memberMap = dataStatsService.getMemberMap(formDTO.getAgencyId());
+                Map<String, Long> memberMap = getMemberMap(tokenDto.getCustomerId(), formDTO.getAgencyId());
                 resultList = gridList.stream().map(grid -> {
                     OrgProjectDetailResultDTO dto = new OrgProjectDetailResultDTO();
                     dto.setOrgId(grid.getId());
@@ -1197,9 +1195,11 @@ public class GovOrgServiceImpl implements GovOrgService {
                         dto.setClosedCount(closedMap.get(grid.getId()));
                     }
                     if (memberMap.containsKey(grid.getId())) {
-                        dto.setMemberCount(memberMap.get(grid.getId()));
+                        dto.setMemberCount(Math.toIntExact(memberMap.get(grid.getId())));
-                        dto.setProjectAve(dto.getProjectCount()/memberMap.get(grid.getId()));
+                        if (NumConstant.ZERO != dto.getMemberCount()) {
-                        dto.setClosedAve(dto.getClosedCount()/memberMap.get(grid.getId()));
+                            dto.setProjectAve(dto.getProjectCount() / dto.getMemberCount());
+                            dto.setClosedAve(dto.getClosedCount() / dto.getMemberCount());
+                        }
                     }
                     return dto;
                 }).collect(Collectors.toList());
@@ -1221,7 +1221,10 @@ public class GovOrgServiceImpl implements GovOrgService {
             //拼装数据
             if (CollectionUtils.isNotEmpty(agencyList)) {
                 //项目相关统计
-                Map<String, SubAgencyProjectResultDTO> projectMap = dataStatsService.getAgencyProjectTotal(formDTO);
+                //统计项目数
+                Map<String, Integer> projectMap = govProjectService.getAgencyProjectMap(formDTO);
+                //统计关闭项目数
+                Map<String, Integer> closedMap = govProjectService.getAgencyClosedProjectMap(formDTO);
                 //网格员统计
                 Map<String, Integer> memberMap = epmetUserService.getMemberCount(tokenDto.getCustomerId());
 
@@ -1230,12 +1233,12 @@ public class GovOrgServiceImpl implements GovOrgService {
                     dto.setOrgId(agency.getId());
                     dto.setOrgType(OrgConstant.AGENCY);
                     dto.setOrgName(agency.getOrganizationName());
-                    if (projectMap.containsKey(agency.getId())) {
-                        dto.setProjectCount(projectMap.get(agency.getId()).getProjectTotal());
-                        dto.setClosedCount(projectMap.get(agency.getId()).getClosedProjectTotal());
-                    }
                     //获取当前组织的所有下级组织ID（包含本级）
                     List<String> agencyIds = customerAgencyDao.getSubAgencyList(agency.getId());
+                    int projectCount = agencyIds.stream().filter(projectMap::containsKey).mapToInt(projectMap::get).sum();
+                    int closedCount = agencyIds.stream().filter(closedMap::containsKey).mapToInt(closedMap::get).sum();
+                    dto.setProjectCount(projectCount);
+                    dto.setClosedCount(closedCount);
                     //将下级组织网格员数加起来
                     int memberCount = agencyIds.stream().filter(memberMap::containsKey).mapToInt(memberMap::get).sum();
                     dto.setMemberCount(memberCount);
@@ -1268,30 +1271,25 @@ public class GovOrgServiceImpl implements GovOrgService {
     @Override
     public PageData<MemberProjectInfoResultDTO> memberProjectInfoList(TokenDto tokenDto, OrgStatisticsFormDTO formDTO) {
         formDTO.setCustomerId(tokenDto.getCustomerId());
-        PageData<MemberProjectInfoResultDTO> result;
         if (StringUtils.isBlank(formDTO.getOrgId())) {
-            CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
+            CustomerStaffInfoCacheResult staffInfo = getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
             if (null == staffInfo) {
                 throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取用户信息失败", "获取用户信息失败");
             }
             formDTO.setOrgId(staffInfo.getAgencyId());
             formDTO.setOrgType(OrgConstant.AGENCY);
         }
-        if (StringUtils.isEmpty(formDTO.getStartDate()) && StringUtils.isEmpty(formDTO.getEndDate())) {
+        PageData<MemberProjectInfoResultDTO> result = getGridMemberList(formDTO);
-            //当前日期前一天
+        //if (OrgConstant.AGENCY.contains(formDTO.getOrgType())) {
-            String dateId = DateUtils.format(DateUtils.addDateDays(new Date(), NumConstant.ONE_NEG), DateUtils.DATE_PATTERN_YYYYMMDD);
+        //    //获取当前组织的所有下级组织ID（包含本级）
-            formDTO.setEndDate(dateId);
+        //    //List<String> agencyIds = customerAgencyDao.getSubAgencyList(formDTO.getOrgId());
-        }
+        //    //formDTO.setAgencyList(agencyIds);
-        if (OrgConstant.AGENCY.contains(formDTO.getOrgType())) {
+        //    //获取组织下的网格员
-            //获取当前组织的所有下级组织ID（包含本级）
+        //    result =  epmetUserService.getMemberList(formDTO);
-            List<String> agencyIds = customerAgencyDao.getSubAgencyList(formDTO.getOrgId());
+        //} else {
-            formDTO.setAgencyList(agencyIds);
+        //    //获取网格下的网格员
-            //获取组织下的网格员
+        //    result = dataStatsService.getMemberList(formDTO);
-            result =  epmetUserService.getMemberList(formDTO);
+        //}
-        } else {
-            //获取网格下的网格员
-            result = dataStatsService.getMemberList(formDTO);
-        }
         if (CollectionUtils.isNotEmpty(result.getList())) {
             //统计项目数
             Map<String, Integer> projectMap = govProjectService.getMemberProjectMap(formDTO);
@@ -1319,4 +1317,105 @@ public class GovOrgServiceImpl implements GovOrgService {
         }
         return result;
     }
+
+    private PageData<MemberProjectInfoResultDTO> getGridMemberList(OrgStatisticsFormDTO formDTO) {
+        List<MemberProjectInfoResultDTO> list = new ArrayList<>();
+        List<StaffOrgRelationResultDTO> staffList = customerStaffAgencyDao.getStaffList(formDTO.getOrgId(), formDTO.getOrgType());
+        if (OrgConstant.AGENCY.equals(formDTO.getOrgType())) {
+            for (StaffOrgRelationResultDTO staff : staffList) {
+                CustomerStaffInfoCacheResult staffInfo = getStaffInfo(formDTO.getCustomerId(), staff.getStaffId());
+                if (null != staffInfo) {
+                    if(staffInfo.getRoleMap().containsKey("grid_member")) {
+                        MemberProjectInfoResultDTO dto = new MemberProjectInfoResultDTO();
+                        dto.setStaffId(staff.getStaffId());
+                        dto.setStaffName(staffInfo.getRealName());
+                        dto.setOrgId(staff.getOrgId());
+                        AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(staff.getOrgId());
+                        if (null != agencyInfo) {
+                            dto.setOrgName(agencyInfo.getOrganizationName());
+                        }
+                        list.add(dto);
+                    }
+                }
+            }
+        } else {
+            for (StaffOrgRelationResultDTO staff : staffList) {
+                CustomerStaffInfoCacheResult staffInfo = getStaffInfo(formDTO.getCustomerId(), staff.getStaffId());
+                if (null != staffInfo) {
+                    if(staffInfo.getRoleMap().containsKey("grid_member")) {
+                        MemberProjectInfoResultDTO dto = new MemberProjectInfoResultDTO();
+                        dto.setStaffId(staff.getStaffId());
+                        dto.setStaffName(staffInfo.getRealName());
+                        dto.setOrgId(staff.getOrgId());
+                        GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(staff.getOrgId());
+                        if (null != gridInfo) {
+                            dto.setOrgName(gridInfo.getGridName());
+                        }
+                        list.add(dto);
+                    }
+                }
+            }
+        }
+        int num = (formDTO.getPageNo() - NumConstant.ONE) * formDTO.getPageSize();
+        PageInfo<MemberProjectInfoResultDTO> pageInfo = new PageInfo<>(list);
+        list = list.stream().sorted((o1, o2) ->
+                Collator.getInstance(Locale.SIMPLIFIED_CHINESE)
+                        .compare(o1.getStaffName(),o2.getStaffName())).collect(Collectors.toList());
+        list = list.stream().skip(num).limit(formDTO.getPageSize()).collect(Collectors.toList());
+        return new PageData<>(list, pageInfo.getTotal());
+
+    }
+
+    private Map<String, Long> getMemberMap(String customerId, String agencyId) {
+        List<GridStaffResultDTO> list = customerStaffGridDao.getGridStaffByAgency(agencyId);
+        if (CollectionUtils.isEmpty(list)) {
+            return Collections.emptyMap();
+        }
+        list = list.stream().filter(item -> {
+            CustomerStaffInfoCacheResult staffInfo = getStaffInfo(customerId, item.getStaffId());
+            if (null != staffInfo) {
+                if (staffInfo.getRoleMap().containsKey("grid_member")) {
+                    return true;
+                }
+            }
+            return false;
+        }).collect(Collectors.toList());
+
+        return list.stream().collect(Collectors.groupingBy(GridStaffResultDTO::getGridId, Collectors.counting()));
+    }
+
+
+    private CustomerStaffInfoCacheResult getStaffInfo(String customerId, String staffId) {
+        if (StringUtils.isBlank(customerId) || StringUtils.isBlank(staffId)){
+            log.warn("getStaffInfo param is blank,customerId:{},staffId:{}",customerId,staffId);
+            return null;
+        }
+        String key = RedisKeys.getCustomerStaffInfoKey(customerId, staffId);
+        Map<String, Object> roleMap = redisUtils.hGetAll(key);
+        if (!org.springframework.util.CollectionUtils.isEmpty(roleMap)) {
+            return ConvertUtils.mapToEntity(roleMap, CustomerStaffInfoCacheResult.class);
+        }
+
+        CustomerStaffInfoCache resultData = reloadStaffCache(staffId, key);
+        if (resultData == null) {
+            return null;
+        }
+
+        return ConvertUtils.sourceToTarget(resultData, CustomerStaffInfoCacheResult.class);
+    }
+
+    @Nullable
+    private CustomerStaffInfoCache reloadStaffCache(String staffId, String key) {
+        CustomerStaffResultDTO staffResult = epmetUserService.getStaffInfo(staffId);
+        if (staffResult == null) {
+            log.warn("getStaffInfo staff is null,staffId:{}", staffId);
+            return null;
+        }
+        CustomerStaffInfoCache resultData =ConvertUtils.sourceToTarget(staffResult, CustomerStaffInfoCache.class);
+
+        Map<String, Object> map = BeanUtil.beanToMap(resultData, false, true);
+        redisUtils.hMSet(key, map);
+        return resultData;
+    }
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/GovProjectService.java

@@ -153,4 +153,20 @@ public interface GovProjectService {
 	 * @Date 2022/7/28 9:29
 	 */
 	Map<String, Integer> getMemberClosedProjectMap(OrgStatisticsFormDTO formDTO);
+	/**
+	 * 组织上报项目数
+	 * @Param formDTO
+	 * @Return {@link Map< String, Integer>}
+	 * @Author zhaoqifeng
+	 * @Date 2022/7/28 9:29
+	 */
+	Map<String, Integer> getAgencyProjectMap(OrgStatisticsFormDTO formDTO);
+	/**
+	 * 组织关闭项目数
+	 * @Param formDTO
+	 * @Return {@link Map< String, Integer>}
+	 * @Author zhaoqifeng
+	 * @Date 2022/7/28 9:29
+	 */
+	Map<String, Integer> getAgencyClosedProjectMap(OrgStatisticsFormDTO formDTO);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/govproject/impl/GovProjectServiceImpl.java

@@ -721,6 +721,42 @@ public class GovProjectServiceImpl implements GovProjectService {
 		return list.stream().collect(Collectors.toMap(OrgCountDTO::getOrgId, OrgCountDTO::getCount, (o1, o2) -> o1));
 	}
 
+	/**
+	 * 组织上报项目数
+	 *
+	 * @param formDTO
+	 * @Param formDTO
+	 * @Return {@link Map< String, Integer>}
+	 * @Author zhaoqifeng
+	 * @Date 2022/7/28 9:29
+	 */
+	@Override
+	public Map<String, Integer> getAgencyProjectMap(OrgStatisticsFormDTO formDTO) {
+		List<OrgCountDTO> list = projectDao.getAgencyProjectCount(formDTO);
+		if (CollectionUtils.isEmpty(list)) {
+			return Collections.emptyMap();
+		}
+		return list.stream().collect(Collectors.toMap(OrgCountDTO::getOrgId, OrgCountDTO::getCount, (o1, o2) -> o1));
+	}
+
+	/**
+	 * 组织关闭项目数
+	 *
+	 * @param formDTO
+	 * @Param formDTO
+	 * @Return {@link Map< String, Integer>}
+	 * @Author zhaoqifeng
+	 * @Date 2022/7/28 9:29
+	 */
+	@Override
+	public Map<String, Integer> getAgencyClosedProjectMap(OrgStatisticsFormDTO formDTO) {
+		List<OrgCountDTO> list = projectDao.getAgencyClosedProjectCount(formDTO);
+		if (CollectionUtils.isEmpty(list)) {
+			return Collections.emptyMap();
+		}
+		return list.stream().collect(Collectors.toMap(OrgCountDTO::getOrgId, OrgCountDTO::getCount, (o1, o2) -> o1));
+	}
+
 	/**
 	 * 构造事件查询
 	 * @param customerId

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml

@@ -124,4 +124,39 @@
                 ca.ID
         ORDER BY ca.CREATED_TIME ASC
     </select>
+    <select id="getStaffList" resultType="com.epmet.dataaggre.dto.govorg.result.StaffOrgRelationResultDTO">
+        <choose>
+            <when test="orgType != null and orgType == 'dept' ">
+                SELECT
+                    DEPARTMENT_ID AS "orgId",
+                    user_id AS "staffId"
+                FROM
+                    customer_staff_department
+                WHERE
+                    del_flag = '0'
+                AND department_id = #{orgId}
+            </when>
+            <when test="orgType != null and orgType == 'grid' ">
+                SELECT
+                    GRID_ID AS "orgId",
+                    user_id AS "staffId"
+                FROM
+                    customer_staff_grid
+                WHERE
+                    del_flag = '0'
+                AND grid_id = #{orgId}
+            </when>
+            <otherwise>
+                SELECT
+                    csa.AGENCY_ID AS "orgId",
+                    csa.user_id AS "staffId"
+                FROM
+                    customer_staff_agency csa
+                INNER JOIN customer_agency ca ON csa.AGENCY_ID = ca.ID AND ca.del_flag = '0'
+                WHERE
+                    csa.del_flag = '0'
+                AND (ca.ID = #{orgId} OR ca.PIDS LIKE CONCAT('%', #{orgId}, '%'))
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffGridDao.xml

@@ -55,4 +55,17 @@
                 cg.ID
         ORDER BY cg.CREATED_TIME ASC
     </select>
+    <select id="getGridStaffByAgency" resultType="com.epmet.dataaggre.dto.govorg.result.GridStaffResultDTO">
+        SELECT
+            GRID_ID,
+            USER_ID AS staffId
+        FROM
+            customer_staff_grid a
+            INNER JOIN customer_grid b ON a.GRID_ID = b.ID
+            AND b.DEL_FLAG = '0'
+        WHERE
+            a.DEL_FLAG = '0'
+            AND b.PID = #{agencyId}
+
+    </select>
 </mapper>

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govproject/ProjectDao.xml

@@ -501,5 +501,42 @@
         GROUP BY
             STAFF_ID
     </select>
+    <select id="getAgencyProjectCount" resultType="com.epmet.dataaggre.dto.govorg.result.OrgCountDTO">
+        SELECT
+            AGENCY_ID AS "orgId",
+            COUNT( ID ) AS "count"
+        FROM
+            project
+        WHERE
+            DEL_FLAG = '0'
+            AND (AGENCY_ID = #{agencyId} OR ORG_ID_PATH LIKE CONCAT('%', #{agencyId}, '%'))
+            <if test="null != startDate and '' != startDate">
+                AND DATE_FORMAT(CREATED_TIME,"%Y%m%d") <![CDATA[ >= ]]> #{startDate}
+            </if>
+            <if test="null != endDate and '' != endDate">
+                AND DATE_FORMAT(CREATED_TIME,"%Y%m%d") <![CDATA[ <= ]]> #{endDate}
+            </if>
+        GROUP BY
+            AGENCY_ID
+    </select>
+    <select id="getAgencyClosedProjectCount" resultType="com.epmet.dataaggre.dto.govorg.result.OrgCountDTO">
+        SELECT
+            AGENCY_ID AS "orgId",
+            COUNT( ID ) AS "count"
+        FROM
+            project_process
+        WHERE
+            DEL_FLAG = '0'
+            AND (AGENCY_ID = #{agencyId} OR ORG_ID_PATH LIKE CONCAT('%', #{agencyId}, '%'))
+            AND OPERATION = 'close'
+            <if test="null != startDate and '' != startDate">
+                AND DATE_FORMAT(CREATED_TIME,"%Y%m%d") <![CDATA[ >= ]]> #{startDate}
+            </if>
+            <if test="null != endDate and '' != endDate">
+                AND DATE_FORMAT(CREATED_TIME,"%Y%m%d") <![CDATA[ <= ]]> #{endDate}
+            </if>
+        GROUP BY
+            AGENCY_ID
+    </select>
 
 </mapper>