Merge remote-tracking branch 'origin/develop' into develop

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/datastats/DatsStatsDao.xml

@@ -769,32 +769,39 @@
 
     <select id="selectGirdMemberPatrol" resultType="com.epmet.dataaggre.dto.epmetuser.result.GridMemberPatrolListResultDTO">
         SELECT
-            staff_id staffId,
-            staff_name staffName,
-            date_id dateId,
+            a.staff_id staffId,
+            a.staff_name staffName,
+            a.date_id dateId,
             IFNULL(
                 SUM(
-                    issue_to_project_count + closed_issue_count + project_response_count + project_transfer_count + project_closed_count
-                )
-            , 0)eventCount
+                    a.issue_to_project_count + a.closed_issue_count + a.project_response_count + a.project_transfer_count + a.project_closed_count
+                ),
+                0
+            ) eventCount
+        FROM
+            fact_grid_member_statistics_daily a
+        INNER JOIN (
+            SELECT
+                staff_id,
+                MAX(date_id) date_id
             FROM
                 fact_grid_member_statistics_daily
-        WHERE
-            del_flag = '0'
+            WHERE del_flag = '0'
             AND pids LIKE concat('%', #{agencyId}, '%')
-        AND date_id = (
-            SELECT MAX(date_id)
-            FROM fact_grid_member_statistics_daily
-            WHERE
-                del_flag = '0'
             <if test="dimType!= null and dimType == 'month' ">
                 AND month_id = #{dimId}
             </if>
             <if test="dimType!= null and dimType == 'year' ">
                 AND year_id = #{dimId}
             </if>
-        )
-        GROUP BY staff_id
+            GROUP BY STAFF_ID
+        ) b ON a.STAFF_ID = b.STAFF_ID AND a.date_id = b.date_id
+
+        WHERE
+            a.del_flag = '0'
+        AND a.pids LIKE concat('%', #{agencyId}, '%')
+        GROUP BY a.staff_id
+        ORDER BY a.date_id DESC
     </select>
 
     <select id="regUserList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetuser/StaffPatrolRecordDao.xml

@@ -124,7 +124,7 @@
     <select id="gridMemberPatrol" resultType="com.epmet.dataaggre.dto.epmetuser.result.StaffListResultDTO">
         SELECT
             staff_id staffId,
-            IFNULL(SUM(patrol_total), 0) reportProjectCount,
+            IFNULL(SUM(report_project_count), 0) reportProjectCount,
             IFNULL(SUM(total_time), 0) timeNum
         FROM
             stats_staff_patrol_record_daily

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ClosedProjectTotalResultDTO.java

@@ -0,0 +1,31 @@
+package com.epmet.dto.project.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/11/4 9:12 上午
+ * @DESC
+ */
+@Data
+public class ClosedProjectTotalResultDTO implements Serializable {
+
+    private static final long serialVersionUID = -3683494871244065806L;
+
+    /**
+     * 组织ID
+     */
+    private String orgId;
+
+    /**
+     * 分类code
+     */
+    private String categoryCode;
+
+    /**
+     * 结案的项目数
+     */
+    private Integer closedProjectTotal = 0;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screen/ScreenProjectCategoryGridDailyDTO.java

@@ -120,4 +120,6 @@ public class ScreenProjectCategoryGridDailyDTO implements Serializable {
      */
 	private Boolean status = false;
 
+	private Integer closedProjectTotal = 0;
+
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screen/result/CategoryProjectResultDTO.java

@@ -42,6 +42,11 @@ public class CategoryProjectResultDTO implements Serializable {
      */
     private Integer projectTotal;
 
+    /**
+     * 结案数
+     */
+    private Integer closedProjectTotal;
+
     /**
      * 分类级别
      */

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/extract/FactOriginProjectCategoryDailyDao.java

@@ -42,7 +42,7 @@ public interface FactOriginProjectCategoryDailyDao extends BaseDao<FactOriginPro
      * @description 计算当前客户下，各个网格内，各项目分类下项目数量
      * @Date 2021/3/23 9:58
      **/
-    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryGridDailyDTO(@Param("customerId") String customerId,@Param("subCount")Integer subCount);
+    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryGridDailyDTO(@Param("customerId") String customerId,@Param("subCount")Integer subCount,@Param("projectType")String projectType);
 
     /**
      * @Description  查询客户下，组织直接立项的，各项目分类下的项目数量【筛选组织创建的项目，fact_origin_project_main_daily表gridId为空】
@@ -50,7 +50,8 @@ public interface FactOriginProjectCategoryDailyDao extends BaseDao<FactOriginPro
      * @author zxc
      * @date 2021/4/13 下午4:36
      */
-    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(@Param("orgIds")List<String> orgIds,@Param("customerId") String customerId,@Param("subCount") Integer subCount);
+    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(@Param("orgIds")List<String> orgIds,@Param("customerId") String customerId,
+                                                                           @Param("subCount") Integer subCount,@Param("projectType")String projectType);
 
     int deleteByProjectIds(@Param("list") List<String> list);
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenProjectCategoryOrgDailyDao.java

@@ -18,6 +18,7 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.project.result.ClosedProjectTotalResultDTO;
 import com.epmet.dto.screen.result.CategoryProjectResultDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectCategoryOrgDailyEntity;
 import com.sun.org.apache.xpath.internal.operations.Bool;
@@ -106,4 +107,15 @@ public interface ScreenProjectCategoryOrgDailyDao extends BaseDao<ScreenProjectC
 	 * @date 2021/8/16 10:36 上午
 	 */
 	List<CategoryProjectResultDTO> selectSelfAgencyCategory(@Param("dateId") String dateId,@Param("orgIds")List<String> orgIds);
+
+	/**
+	 * @Description  查询父客户 存在 分类的结案项目数
+	 * @param customerIds
+	 * @param dateId
+	 * @author zxc
+	 * @date 2021/11/4 9:26 上午
+	 */
+	List<ClosedProjectTotalResultDTO> selectClosedProjectTotal(@Param("customerIds")List<String> customerIds, @Param("dateId") String dateId,
+															   @Param("status")Boolean status);
+
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/evaluationindex/screen/ScreenProjectCategoryGridDailyEntity.java

@@ -74,4 +74,9 @@ public class ScreenProjectCategoryGridDailyEntity extends BaseEpmetEntity {
 	 * 分类等级1、2....
 	 */
 	private Integer level;
+
+	/**
+	 * 分类下所有结案的项目
+	 */
+	private Integer closedProjectTotal;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/evaluationindex/screen/ScreenProjectCategoryOrgDailyEntity.java

@@ -82,6 +82,11 @@ public class ScreenProjectCategoryOrgDailyEntity extends BaseEpmetEntity {
      */
 	private Integer projectTotal;
 
+	/**
+	 * 分类下所有结案项目数
+	 */
+	private Integer closedProjectTotal;
+
 	/**
 	 * 分类等级1、2....
 	 */

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/FactOriginProjectCategoryDailyService.java

@@ -54,5 +54,5 @@ public interface FactOriginProjectCategoryDailyService extends BaseService<FactO
      * @author zxc
      * @date 2021/4/13 下午4:36
      */
-    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(List<String> orgIds,String customerId,Integer subCount);
+    List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(List<String> orgIds,String customerId,Integer subCount,String projectType);
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginProjectCategoryDailyServiceImpl.java

@@ -138,7 +138,11 @@ public class FactOriginProjectCategoryDailyServiceImpl extends BaseServiceImpl<F
      **/
     @Override
     public List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryGridDailyDTO(String customerId) {
-        List<ScreenProjectCategoryGridDailyDTO> list=baseDao.selectListProjectCategoryGridDailyDTO(customerId,getSubCount(customerId));
+        List<ScreenProjectCategoryGridDailyDTO> list=baseDao.selectListProjectCategoryGridDailyDTO(customerId,getSubCount(customerId),"all");
+        List<ScreenProjectCategoryGridDailyDTO> closedList = baseDao.selectListProjectCategoryGridDailyDTO(customerId,getSubCount(customerId),"closed");
+        if (!CollectionUtils.isEmpty(closedList)){
+            list.forEach(l -> closedList.stream().filter(c -> l.getGridId().equals(c.getGridId()) && l.getCategoryCode().equals(c.getCategoryCode())).forEach(c -> l.setClosedProjectTotal(c.getClosedProjectTotal())));
+        }
         return list;
     }
 
@@ -157,10 +161,10 @@ public class FactOriginProjectCategoryDailyServiceImpl extends BaseServiceImpl<F
      * @date 2021/4/13 下午4:36
      */
     @Override
-    public List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(List<String> orgIds,String customerId,Integer subCount) {
+    public List<ScreenProjectCategoryGridDailyDTO> selectListProjectCategoryByOrg(List<String> orgIds,String customerId,Integer subCount,String projectType) {
         if (!CollectionUtils.isEmpty(orgIds)){
             return new ArrayList<>();
         }
-        return baseDao.selectListProjectCategoryByOrg(orgIds,customerId,subCount);
+        return baseDao.selectListProjectCategoryByOrg(orgIds,customerId,subCount,projectType);
     }
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java

@@ -32,6 +32,7 @@ import com.epmet.constant.ScreenConstant;
 import com.epmet.dao.evaluationindex.screen.ScreenProjectCategoryGridDailyDao;
 import com.epmet.dao.evaluationindex.screen.ScreenProjectCategoryOrgDailyDao;
 import com.epmet.dto.extract.result.CustomerAgencyInfoResultDTO;
+import com.epmet.dto.project.result.ClosedProjectTotalResultDTO;
 import com.epmet.dto.screen.ScreenCustomerGridDTO;
 import com.epmet.dto.screen.ScreenProjectCategoryGridDailyDTO;
 import com.epmet.dto.screen.ScreenProjectCategoryOrgDailyDTO;
@@ -264,6 +265,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                         categoryProjectGrid.forEach(grid -> {
                             if (agency.getOrgId().equals(grid.getOrgId()) && agency.getCategoryCode().equals(grid.getCategoryCode())){
                                 agency.setProjectTotal(agency.getProjectTotal() + grid.getProjectTotal());
+                                agency.setClosedProjectTotal(agency.getClosedProjectTotal() + grid.getClosedProjectTotal());
                                 grid.setStatus(true);
                             }
                         });
@@ -280,7 +282,11 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
         // 组织项目分类 项目数
         List<CustomerAgencyInfoResultDTO> levelAgencyInfo = groupByLevel.get(level);
         if (!CollectionUtils.isEmpty(levelAgencyInfo)){
-            List<ScreenProjectCategoryGridDailyDTO> screenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds,customerId,NumConstant.FOUR);
+            List<ScreenProjectCategoryGridDailyDTO> screenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds,customerId,NumConstant.FOUR,"all");
+            List<ScreenProjectCategoryGridDailyDTO> closedScreenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds,customerId,NumConstant.FOUR,"closed");
+            if (!CollectionUtils.isEmpty(closedScreenProjectCategory)){
+                screenProjectCategory.forEach(l -> closedScreenProjectCategory.stream().filter(c -> l.getGridId().equals(c.getGridId()) && l.getCategoryCode().equals(c.getCategoryCode())).forEach(c -> l.setClosedProjectTotal(c.getClosedProjectTotal())));
+            }
             if (!CollectionUtils.isEmpty(result)){
                 if (!CollectionUtils.isEmpty(screenProjectCategory)){
                     result.forEach(r -> {
@@ -288,6 +294,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                             if (r.getOrgId().equals(pc.getOrgId()) && r.getCategoryCode().equals(pc.getCategoryCode())){
                                 pc.setStatus(true);
                                 r.setProjectTotal(r.getProjectTotal() + pc.getProjectTotal());
+                                r.setClosedProjectTotal(r.getClosedProjectTotal() + pc.getClosedProjectTotal());
                             }
                         });
                     });
@@ -390,6 +397,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                             // 组织ID 和 分类标签code一样时，项目数累加
                             if (agency.getOrgId().equals(grid.getOrgId()) && agency.getCategoryCode().equals(grid.getCategoryCode())){
                                 agency.setProjectTotal(agency.getProjectTotal() + grid.getProjectTotal());
+                                agency.setClosedProjectTotal(agency.getClosedProjectTotal() + grid.getClosedProjectTotal());
                                 grid.setStatus(true);
                             }
                         });
@@ -417,13 +425,23 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                 // 父客户存在的分类
                 List<CategoryProjectResultDTO> categoryProjectExists = baseDao.selectOrgCategoryMoreCustomerInfo(customerIds, dateId, level, customerId);
                 log.info("父客户存在的分类{}"+ JSON.toJSONString(categoryProjectExists));
+                // 父客户存在的分类 已结案的项目数
+                List<ClosedProjectTotalResultDTO> closedProjectTotalExist = baseDao.selectClosedProjectTotal(customerIds, dateId, true);
                 // 父客户不存在的分类
                 List<CategoryProjectResultDTO> categoryProjectNotExists = baseDao.selectOrgCategoryMoreCustomerInfoNotExists(customerIds, dateId, level, customerId);
                 log.info("父客户不存在的分类{}"+ JSON.toJSONString(categoryProjectNotExists));
+                // 父客户 不存在 的分类 已结案的项目数
+                List<ClosedProjectTotalResultDTO> closedProjectTotalNotExist = baseDao.selectClosedProjectTotal(customerIds, dateId, false);
                 if (!CollectionUtils.isEmpty(categoryProjectExists)){
+                    if (!CollectionUtils.isEmpty(closedProjectTotalExist)){
+                        categoryProjectExists.forEach(l -> closedProjectTotalExist.stream().filter(c -> l.getOrgId().equals(c.getOrgId()) && l.getCategoryCode().equals(c.getCategoryCode())).forEach(c -> l.setClosedProjectTotal(c.getClosedProjectTotal())));
+                    }
                     sonCustomerList.addAll(categoryProjectExists);
                 }
                 if (!CollectionUtils.isEmpty(categoryProjectNotExists)){
+                    if (!CollectionUtils.isEmpty(closedProjectTotalNotExist)){
+                        categoryProjectNotExists.forEach(l -> closedProjectTotalNotExist.stream().filter(c -> l.getOrgId().equals(c.getOrgId()) && l.getCategoryCode().equals(c.getCategoryCode())).forEach(c -> l.setClosedProjectTotal(c.getClosedProjectTotal())));
+                    }
                     sonCustomerList.addAll(categoryProjectNotExists);
                 }
                 if (!CollectionUtils.isEmpty(sonCustomerList)){
@@ -443,6 +461,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                         categoryProjectExists.forEach(c -> {
                             if (f.getCategoryCode().equals(c.getCategoryCode())){
                                 f.setProjectTotal(f.getProjectTotal() + c.getProjectTotal());
+                                f.setClosedProjectTotal(f.getClosedProjectTotal() + c.getClosedProjectTotal());
                                 c.setStatus(true);
                             }
                         });
@@ -481,6 +500,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                             e.setCategoryCode(code);
                             e.setOrgId(entity.getAgencyId());
                             e.setProjectTotal(CollectionUtils.isEmpty(list2) ? NumConstant.ZERO : list2.stream().collect(Collectors.summingInt(CategoryProjectResultDTO::getProjectTotal)));
+                            e.setClosedProjectTotal(CollectionUtils.isEmpty(list2) ? NumConstant.ZERO : list2.stream().collect(Collectors.summingInt(CategoryProjectResultDTO::getClosedProjectTotal)));
                             e.setPid(entity.getPid());
                             e.setPids(StringUtils.isEmpty(entity.getPids()) ? NumConstant.ZERO_STR : entity.getPids());
                             // 因为根据categoryCode分组，所以level都一样，取第一条的
@@ -496,7 +516,11 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
         List<CustomerAgencyInfoResultDTO> levelAgencyInfo = groupByLevel.get(level);
         if (!CollectionUtils.isEmpty(levelAgencyInfo)) {
             // 查询客户下，组织直接立项的，各项目分类下的项目数量【筛选组织创建的项目，fact_origin_project_main_daily表gridId为空】
-            List<ScreenProjectCategoryGridDailyDTO> screenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds, customerId,NumConstant.TWO);
+            List<ScreenProjectCategoryGridDailyDTO> screenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds, customerId,NumConstant.TWO,"all");
+            List<ScreenProjectCategoryGridDailyDTO> closedScreenProjectCategory = factOriginProjectCategoryDailyService.selectListProjectCategoryByOrg(orgIds, customerId,NumConstant.TWO,"closed");
+            if (!CollectionUtils.isEmpty(closedScreenProjectCategory)){
+                screenProjectCategory.forEach(l -> closedScreenProjectCategory.stream().filter(c -> l.getGridId().equals(c.getGridId()) && l.getCategoryCode().equals(c.getCategoryCode())).forEach(c -> l.setClosedProjectTotal(c.getClosedProjectTotal())));
+            }
             log.info("直接立项的统计:"+screenProjectCategory);
             if (!CollectionUtils.isEmpty(result)) {
                 if (!CollectionUtils.isEmpty(screenProjectCategory)) {
@@ -505,6 +529,7 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                             if (r.getOrgId().equals(pc.getOrgId()) && r.getCategoryCode().equals(pc.getCategoryCode())) {
                                 pc.setStatus(true);
                                 r.setProjectTotal(r.getProjectTotal() + pc.getProjectTotal());
+                                r.setClosedProjectTotal(r.getClosedProjectTotal() + pc.getClosedProjectTotal());
                             }
                         });
                     });

epmet-module/data-statistical/data-statistical-server/src/main/resources/db/migration/V0.0.25__add_closedProjectTotal.sql

@@ -0,0 +1,2 @@
+alter table screen_project_category_grid_daily add COLUMN CLOSED_PROJECT_TOTAL int(11) NOT NULL DEFAULT 0 comment '该分类下所有结案的项目数' AFTER PROJECT_TOTAL;
+alter table screen_project_category_org_daily add COLUMN CLOSED_PROJECT_TOTAL int(11) NOT NULL DEFAULT 0 comment '该分类下所有结案的项目数' AFTER PROJECT_TOTAL;

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectCategoryDailyDao.xml

@@ -36,13 +36,21 @@
                 p.GRID_ID,
                 p.AGENCY_ID AS PID,
                 P.PIDS,
+                <if test='projectType == "closed" '>
+                    count(1) AS closedProjectTotal
+                </if>
+                <if test='projectType == "all" '>
                     count(1)as projectTotal
+                </if>
             FROM
                 fact_origin_project_category_daily c
                 LEFT JOIN fact_origin_project_main_daily p ON ( c.PROJECT_Id = p.id and p.del_flag='0' AND p.GRID_ID != '')
             WHERE
                 c.DEL_FLAG = '0'
                 AND c.CUSTOMER_ID = #{customerId}
+                <if test='projectType == "closed" '>
+                    AND p.PROJECT_STATUS = 'closed'
+                </if>
                 AND c.`LEVEL` = '2'
                 AND p.GRID_ID != ''
             GROUP BY
@@ -60,13 +68,21 @@
                 p.GRID_ID,
                 p.AGENCY_ID AS PID,
                 P.PIDS,
+                <if test='projectType == "closed" '>
+                    count(distinct c.project_id) AS closedProjectTotal
+                </if>
+                <if test='projectType == "all" '>
                     count(distinct c.project_id)as projectTotal
+                </if>
             FROM
                 fact_origin_project_category_daily c
                 LEFT JOIN fact_origin_project_main_daily p ON ( c.PROJECT_Id = p.id and p.del_flag='0' AND p.GRID_ID != '')
             WHERE
                 c.DEL_FLAG = '0'
                 AND p.GRID_ID != ''
+                <if test='projectType == "closed" '>
+                    AND p.PROJECT_STATUS = 'closed'
+                </if>
                 AND c.CUSTOMER_ID = #{customerId}
             GROUP BY
                 c.CUSTOMER_ID,
@@ -87,7 +103,12 @@
             p.AGENCY_ID AS orgId,
             p.PID AS PID,
             P.PIDS,
+            <if test='projectType == "all" '>
                 COUNT(DISTINCT p.ID) AS projectTotal
+            </if>
+            <if test='projectType == "closed" '>
+                COUNT(DISTINCT p.ID) AS closedProjectTotal
+            </if>
         FROM fact_origin_project_main_daily p
         LEFT JOIN fact_origin_project_category_daily c ON ( c.PROJECT_Id = p.id AND p.del_flag='0' AND p.GRID_ID = '')
         WHERE c.DEL_FLAG = '0'
@@ -99,6 +120,9 @@
             )
           AND c.`LEVEL` = '2'
           AND p.GRID_ID = ''
+          <if test='projectType == "closed" '>
+              AND p.PROJECT_STATUS = 'closed'
+          </if>
         GROUP BY c.CUSTOMER_ID, c.CATEGORY_CODE, c.`LEVEL`, p.AGENCY_ID, p.PID, P.PIDS
         UNION ALL
         SELECT
@@ -109,7 +133,12 @@
             p.AGENCY_ID AS orgId,
             p.PID AS PID,
             P.PIDS,
-            COUNT(distinct p.ID) AS projectTotal
+            <if test='projectType == "all" '>
+                COUNT(DISTINCT p.ID) AS projectTotal
+            </if>
+            <if test='projectType == "closed" '>
+                COUNT(DISTINCT p.ID) AS closedProjectTotal
+            </if>
         FROM fact_origin_project_main_daily p
         LEFT JOIN fact_origin_project_category_daily c ON ( c.PROJECT_Id = p.id AND p.del_flag='0' AND p.GRID_ID = '')
         WHERE c.DEL_FLAG = '0'
@@ -120,6 +149,9 @@
               </foreach>
           )
          AND p.GRID_ID = ''
+         <if test='projectType == "closed" '>
+            AND p.PROJECT_STATUS = 'closed'
+         </if>
         GROUP BY c.CUSTOMER_ID, left(c.CATEGORY_CODE, #{subCount}), c.`LEVEL`, p.PID, p.AGENCY_ID, P.PIDS
     </select>
 </mapper>

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectCategoryGridDailyDao.xml

@@ -20,6 +20,7 @@
             sg.CUSTOMER_ID AS categoryOriginCustomerId,
             sg.CATEGORY_CODE,
             SUM(sg.PROJECT_TOTAL) AS projectTotal,
+            SUM(sg.CLOSED_PROJECT_TOTAL) AS closedProjectTotal,
             sg.level,
             sg.DATE_ID,
             sca.`LEVEL` AS orgType

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectCategoryOrgDailyDao.xml

@@ -32,6 +32,7 @@
             sa.CATEGORY_ORIGIN_CUSTOMER_ID,
             sa.CATEGORY_CODE,
             SUM(sa.PROJECT_TOTAL) AS projectTotal,
+            SUM(sa.CLOSED_PROJECT_TOTAL) AS closedProjectTotal,
             sa.level,
             sa.DATE_ID,
             sca.`LEVEL` AS orgType
@@ -182,4 +183,36 @@
         GROUP BY categoryCode,od.ORG_ID
     </select>
 
+    <!-- 查询分类的结案项目数 -->
+    <select id="selectClosedProjectTotal" resultType="com.epmet.dto.project.result.ClosedProjectTotalResultDTO">
+        <foreach collection="customerIds" item="customerId" separator=" UNION ALL ">
+            SELECT
+            (SELECT AGENCY_ID FROM screen_customer_agency WHERE DEL_FLAG = 0 AND CUSTOMER_ID = #{customerId} AND PID = '0') AS orgId,
+            <if test="status == true">
+                cd.EPMET_CATEGORY_CODE AS categoryCode,
+            </if>
+            <if test="status == false">
+                pd.CATEGORY_CODE AS categoryCode
+            </if>
+            count(pd.project_id) AS closedProjectTotal
+            FROM screen_project_data pd
+            LEFT JOIN customer_project_category_dict cd ON (cd.CATEGORY_CODE = pd.CATEGORY_CODE AND cd.CUSTOMER_ID = #{customerId})
+            LEFT JOIN screen_customer_grid scg ON scg.GRID_ID = pd.ORG_ID
+            WHERE 1=1
+            AND pd.DEL_FLAG = '0'
+            AND pd.CUSTOMER_ID = #{customerId}
+            <if test="status == true">
+                AND cd.EPMET_CATEGORY_CODE IS NOT NULL
+            </if>
+            <if test="status == false">
+                AND (cd.EPMET_CATEGORY_CODE IS NULL OR cd.EPMET_CATEGORY_CODE = '')
+            </if>
+            AND cd.EPMET_CATEGORY_CODE != ''
+            AND pd.PROJECT_STATUS_CODE = 'closed'
+            AND pd.ALL_PARENT_IDS LIKE CONCAT('%',(SELECT AGENCY_ID FROM screen_customer_agency WHERE DEL_FLAG = 0 AND CUSTOMER_ID = #{customerId} AND PID = '0'),'%')
+            AND DATE_FORMAT(pd.project_create_time,'%Y%m%d') <![CDATA[ <= ]]> #{dateId}
+            GROUP BY categoryCode
+        </foreach>
+    </select>
+
 </mapper>