对办结率、办结效率的算法修改

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectParticipatedAgencyResultDTO.java

@@ -17,4 +17,6 @@ public class ProjectParticipatedAgencyResultDTO implements Serializable {
     private String agencyId;
 
     private int count;
+
+    private String projectId;
 }

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

@@ -23,6 +23,7 @@ import com.epmet.entity.evaluationindex.extract.FactOriginProjectLogDailyEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+
 import java.util.List;
 
 /**
@@ -125,7 +126,16 @@ public interface FactOriginProjectLogDailyDao extends BaseDao<FactOriginProjectL
 	 * @date 2020.10.15 11:20
 	*/
 	List<ProjectParticipatedAgencyResultDTO> selectAgencyWhistledCount(@Param("agencies") List<String> agencies, @Param("customerId") String customerId,@Param("dimId") String dimId);
-
+	/***
+	 * @Description 评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
+	 * @param agencies
+	 * @param customerId
+	 * @param dimId
+	 * @return java.util.List<com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO>
+	 * @author wangc
+	 * @date 2020.10.16 10:43
+	*/
+	List<ProjectParticipatedAgencyResultDTO> selectWhistledAgencyClosedProjectCount(@Param("agencies") List<String> agencies, @Param("customerId") String customerId,@Param("dimId") String dimId);
 	/***
 	 * @Description 查询机关办结次数
 	 * @param agencies
@@ -134,7 +144,24 @@ public interface FactOriginProjectLogDailyDao extends BaseDao<FactOriginProjectL
 	 * @date 2020.10.14 10:27
 	*/
 	List<ProjectParticipatedAgencyResultDTO> selectAgencyHandledProjectCount(@Param("agencies") List<String> agencies,@Param("customerId") String customerId,@Param("dimId") String dimId);
+	/**
+	 * @Description 查询评价周期内各级别机关办结的项目Id
+	 * @param customerId
+	 * @param dimId
+	 * @return java.util.List<com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO>
+	 * @author wangc
+	 * @date 2020.10.15 17:29
+	*/
+	List<ProjectParticipatedAgencyResultDTO> selectProjectIdHandledByAgency(@Param("customerId") String customerId,@Param("dimId") String dimId);
 
+	/**
+	 * @Description 计算每个办结项目的总耗时
+	 * @param projectIds
+	 * @return java.util.List<com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO>
+	 * @author wangc
+	 * @date 2020.10.15 17:32
+	*/
+	List<ProjectParticipatedAgencyResultDTO> selectProjectCostTime(@Param("projectIds") List<String> projectIds);
 	/**
 	 * 网格项目响应度
 	 * @author zhaoqifeng

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

@@ -134,13 +134,17 @@ public class IndexCollCommunityServiceImpl implements IndexCollCommunityService
 			}));
 		}
 
-		//办结数
+
 		List<String> agencies = agencyList.stream().map(DimAgencyDTO :: getId).distinct().collect(Collectors.toList());
+		//办结数
 		Map<String, Integer> agencyHandleCount = factOriginProjectLogDailyService.getProjectHandledAgency(agencies,customerId,dimId.getMonthId(),"month");
-		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(agencies,customerId,dimId.getMonthId(),"month");
+		////评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
+		Map<String, Integer> whistledAgencyClosedProject = factOriginProjectLogDailyService.getWhistledAgencyClosedProjectCount(agencies,customerId,dimId.getMonthId(),"month");
+		//处理效率
+		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(customerId,dimId.getMonthId(),"month");
 		list.forEach(entity ->{
 			entity.setClosedProjectCount(agencyHandleCount.get(entity.getAgencyId()) == null? NumConstant.ZERO : agencyHandleCount.get(entity.getAgencyId()));
-			BigDecimal element = new BigDecimal(entity.getClosedProjectCount());
+			BigDecimal element = new BigDecimal(Optional.ofNullable(whistledAgencyClosedProject.get(entity.getAgencyId())).orElse(NumConstant.ZERO));
 			//分母，即机关参与过的项目数（去重）
 			//“评价周期内被吹哨且办结的项目数”/“评价周期内被吹哨的所有项目数”
 			Integer denominator = entity.getTransferedCount();

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

@@ -127,14 +127,17 @@ public class IndexCollDistrictServiceImpl implements IndexCollDistrictService {
 				}
 			}));
 		}
-		//办结数
+
 		List<String> agencies = agencyList.stream().map(DimAgencyDTO :: getId).distinct().collect(Collectors.toList());
+		//办结数
 		Map<String, Integer> agencyHandleCount = factOriginProjectLogDailyService.getProjectHandledAgency(agencies,customerId,dimId.getMonthId(),"month");
-
+		//评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
-		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(agencies,customerId,dimId.getMonthId(),"month");
+		Map<String, Integer> whistledAgencyClosedProject = factOriginProjectLogDailyService.getWhistledAgencyClosedProjectCount(agencies,customerId,dimId.getMonthId(),"month");
+		//处理效率
+		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(customerId,dimId.getMonthId(),"month");
 		list.forEach(entity ->{
 			entity.setClosedProjectCount(agencyHandleCount.get(entity.getAgencyId()) == null? NumConstant.ZERO : agencyHandleCount.get(entity.getAgencyId()));
-			BigDecimal element = new BigDecimal(entity.getClosedProjectCount());
+			BigDecimal element = new BigDecimal(Optional.ofNullable(whistledAgencyClosedProject.get(entity.getAgencyId())).orElse(NumConstant.ZERO));
 			//分母，即机关参与过的项目数（去重）
 			//“评价周期内被吹哨且办结的项目数”/“评价周期内被吹哨的所有项目数”
 			Integer denominator = entity.getTransferedCount();

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

@@ -125,14 +125,17 @@ public class IndexCollStreetServiceImpl implements IndexCollStreetService {
 				}
 			}));
 		}
-		//办结数
+
 		List<String> agencies = agencyList.stream().map(DimAgencyDTO :: getId).distinct().collect(Collectors.toList());
+		//办结数
 		Map<String, Integer> agencyHandleCount = factOriginProjectLogDailyService.getProjectHandledAgency(agencies,customerId,dimId.getMonthId(),"month");
-
+		////评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
-		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(agencies,customerId,dimId.getMonthId(),"month");
+		Map<String, Integer> whistledAgencyClosedProject = factOriginProjectLogDailyService.getWhistledAgencyClosedProjectCount(agencies,customerId,dimId.getMonthId(),"month");
+		//处理效率
+		Map<String,BigDecimal> efficiencyMap = factOriginProjectLogDailyService.getAgencyWorkPieceRatio(customerId,dimId.getMonthId(),"month");
 		list.forEach(entity ->{
 			entity.setClosedProjectCount(agencyHandleCount.get(entity.getAgencyId()) == null? NumConstant.ZERO : agencyHandleCount.get(entity.getAgencyId()));
-			BigDecimal element = new BigDecimal(entity.getClosedProjectCount());
+			BigDecimal element = new BigDecimal(Optional.ofNullable(whistledAgencyClosedProject.get(entity.getAgencyId())).orElse(NumConstant.ZERO));
 			//分母，吹哨次数
 			Integer denominator = entity.getTransferedCount();
 			if (null != denominator && denominator != NumConstant.ZERO) {

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

@@ -178,7 +178,7 @@ public interface FactOriginProjectLogDailyService extends BaseService<FactOrigin
     Map<String,Integer> getProjectHandledAgency(List<String> agencies, String customerId, String dimId,String dateType);
     
     /**
-     * @Description 查询机关单位经手的项目数，去重
+     * @Description 评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
      * @param agencies
      * @param dimId
      * @param dateType - 日期维度类型  month  date  week  quarter year
@@ -186,16 +186,16 @@ public interface FactOriginProjectLogDailyService extends BaseService<FactOrigin
      * @author wangc
      * @date 2020.09.23 10:06
     **/
-    Map<String,Integer> getCountOfDealingAgency(List<String> agencies, String customerId,String dimId,String dateType);
+    Map<String,Integer> getWhistledAgencyClosedProjectCount(List<String> agencies, String customerId,String dimId,String dateType);
 
     /**
      * @Description 计算机关办结项目效率
-     * @param agencies
+     * @param customerId
      * @return
      * @author wangc
      * @date 2020.09.21 02:16
     **/
-    Map<String, BigDecimal> getAgencyWorkPieceRatio(List<String> agencies, String customerId,String dimId,String dateType);
+    Map<String, BigDecimal> getAgencyWorkPieceRatio( String customerId,String dimId,String dateType);
 
     /**
      * 网格项目响应度

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

@@ -38,6 +38,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
+import javax.naming.LinkLoopException;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.*;
@@ -183,7 +184,7 @@ public class FactOriginProjectLogDailyServiceImpl extends BaseServiceImpl<FactOr
 
 
     /**
-     * @Description 查询机关单位经手的项目数，去重
+     * @Description 评价周期内被吹哨且被办结(无论是哪一级办结)的项目数
      * @param agencies
      * @param dimId
      * @param dateType - 日期维度类型  month  date  week  quarter year
@@ -192,9 +193,9 @@ public class FactOriginProjectLogDailyServiceImpl extends BaseServiceImpl<FactOr
      * @date 2020.09.23 10:06
      **/
     @Override
-    public Map<String, Integer> getCountOfDealingAgency(List<String> agencies, String customerId,String dimId, String dateType) {
+    public Map<String, Integer> getWhistledAgencyClosedProjectCount(List<String> agencies, String customerId,String dimId, String dateType) {
         Map<String,Integer> result = new HashMap<>();
-        List<ProjectParticipatedAgencyResultDTO> projectAgencyCount = baseDao.selectProjectParticipatedAgency(agencies,customerId,dimId);
+        List<ProjectParticipatedAgencyResultDTO> projectAgencyCount = baseDao.selectWhistledAgencyClosedProjectCount(agencies,customerId,dimId);
         if(!CollectionUtils.isEmpty(projectAgencyCount)){
            result = projectAgencyCount.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getAgencyId,ProjectParticipatedAgencyResultDTO::getCount));
         }
@@ -203,48 +204,63 @@ public class FactOriginProjectLogDailyServiceImpl extends BaseServiceImpl<FactOr
 
     /**
      * @Description 计算机关办结项目效率
-     * @param agencies
+     * @param
      * @return
      * @author wangc
      * @date 2020.09.21 02:16
      **/
     @Override
-    public Map<String, BigDecimal> getAgencyWorkPieceRatio(List<String> agencies, String customerId,String dimId, String dateType) {
+    public Map<String, BigDecimal> getAgencyWorkPieceRatio(String customerId,String dimId, String dateType) {
-        //网格、部门的办结系数
+        //计算方法 : 评价周期内办结项目的平均处理时长的倒数
-        List<OrgResponseTimeResultDTO> gridDeptResponse = projectOrgPeriodDailyDao.selectSubOrgResponseCoefficient(customerId, dimId, dateType);
+
-        //机关的办结系数
+
-        List<OrgResponseTimeResultDTO> agencyResponse = projectOrgPeriodDailyDao.selectAgencyResponseCoefficient(customerId, dimId, dateType);
+        //1.评价周期内结案了的项目
-        Map<String,BigDecimal> consumingMap = new HashMap<>();
+        List<ProjectParticipatedAgencyResultDTO> projectsHandledByAgency = baseDao.selectProjectIdHandledByAgency(customerId,dimId);
-        Map<String,BigDecimal> timeMap = new HashMap<>();
-        if(!CollectionUtils.isEmpty(agencyResponse)){
-            agencyResponse.forEach(response -> {
-                consumingMap.put(response.getAgencyId(),response.getResponseTime());
-                //注意，这里取的是去重后的项目次数，例如一个部门被项目流转了多次，项目数只算一次
-                //如果需要改成不去重，只需response.getProjectTotal()
-                timeMap.put(response.getAgencyId(),response.getDistinctProjectTotal());
-            });
-        }
-        if(!CollectionUtils.isEmpty(gridDeptResponse)){
-           gridDeptResponse.forEach(response -> {
-               if(null != consumingMap.get(response.getAgencyId())){
-                   consumingMap.put(response.getAgencyId(),consumingMap.get(response.getAgencyId()).add(response.getResponseTime()));
-                   timeMap.put(response.getAgencyId(),timeMap.get(response.getAgencyId()).add(response.getDistinctProjectTotal()));
-               }else{
-                   consumingMap.put(response.getAgencyId(),response.getResponseTime());
-                   timeMap.put(response.getAgencyId(),response.getDistinctProjectTotal());
-               }
-           });
-        }
-        //效率map
         Map<String,BigDecimal> efficiencyMap = new HashMap<>();
-        if(!CollectionUtils.isEmpty(consumingMap)) {
+        if(!CollectionUtils.isEmpty(projectsHandledByAgency)){
-            consumingMap.keySet().forEach(agencyId -> {
+            Map<String,List<String>> agencyProjectsMap = new HashMap<>();
-                efficiencyMap.put(agencyId, consumingMap.get(agencyId).divide(timeMap.get(agencyId), NumConstant.SIX, RoundingMode.HALF_UP));
+
+            projectsHandledByAgency.forEach(o -> {
+                String agencyId = o.getAgencyId();
+                String projectId = o.getProjectId();
+                if(CollectionUtils.isEmpty(agencyProjectsMap.get(agencyId))){
+                    List<String> projectUnit = new LinkedList<>();
+                    projectUnit.add(projectId);
+                    agencyProjectsMap.put(agencyId,projectUnit);
+                }else{
+                    agencyProjectsMap.get(agencyId).add(projectId);
+                }
+            });
+
+            List<String> projects = new LinkedList<>();
+            agencyProjectsMap.forEach((key,value) -> {projects.addAll(value);});
+            //2.结案项目的总耗时
+            List<ProjectParticipatedAgencyResultDTO> costTimes = baseDao.selectProjectCostTime(projects);
+
+            Map<String,Integer> projectCostTime = costTimes.stream().collect(Collectors.toMap(ProjectParticipatedAgencyResultDTO::getProjectId,ProjectParticipatedAgencyResultDTO::getCount));
+            agencyProjectsMap.forEach((k,v) -> {
+                //k -> agencyId    v  ->   projects
+                int total = NumConstant.ZERO;
+                if(!CollectionUtils.isEmpty(v)){
+                    for(String p : v){
+                        Integer cost = projectCostTime.get(p);
+                        total = total + (null == cost ? NumConstant.ZERO : cost);
+                    }
+                    //每个机关的项目平均耗时
+                    BigDecimal avgCost = new BigDecimal(total).divide(new BigDecimal(v.size()),4, BigDecimal.ROUND_HALF_UP);
+
+                    efficiencyMap.put(k,BigDecimal.ONE.divide(avgCost,4, BigDecimal.ROUND_HALF_UP));
+
+                }else{
+                    efficiencyMap.put(k,BigDecimal.ZERO);
+                }
             });
         }
+
         return efficiencyMap;
     }
 
+
     @Override
     public List<OrgStatisticsResultDTO> getGridResponse(String customerId, String monthId) {
         return baseDao.selectGridResponse(customerId, monthId);

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

@@ -180,6 +180,29 @@
         </if>
         GROUP BY AGENCY_ID
     </select>
+    <!-- 评价周期内被吹哨且被办结(无论是哪一级办结)的项目数  -->
+    <select id="selectWhistledAgencyClosedProjectCount" resultType="com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO">
+        SELECT
+        log.AGENCY_ID,
+        COUNT(DISTINCT log.PROJECT_ID) AS count
+        FROM
+        fact_origin_project_log_daily log
+        LEFT JOIN fact_origin_project_main_daily project ON log.PROJECT_ID = project.ID AND project.DEL_FLAG = '0' AND project.CUSTOMER_ID = #{customerId}
+        WHERE log.DEL_FLAG = '0'
+        AND project.PROJECT_STATUS LIKE 'close%'
+        AND log.CUSTOMER_ID = #{customerId}
+        AND log.IS_ACTIVE = '0'
+
+        <if test='null != dimId and "" != dimId.trim()'>
+            AND log.MONTH_ID = #{dimId}
+        </if>
+        <if test="agencies != null and agencies.size() > 0">
+            <foreach collection="agencies" item="agencyId" open="AND (" close=" )" separator=" OR ">
+                log.AGENCY_ID = #{agencyId}
+            </foreach>
+        </if>
+        GROUP BY log.AGENCY_ID
+    </select>
     <!-- 查询机关办结次数 -->
     <select id="selectAgencyHandledProjectCount" resultType="com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO">
         	SELECT
@@ -201,6 +224,60 @@
                 </if>
                 GROUP BY SUBSTRING_INDEX(main.FINISH_ORG_IDS,':',1)
     </select>
+    <!-- 查询评价周期内各级别机关办结的项目Id -->
+    <select id="selectProjectIdHandledByAgency" resultType="com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO">
+            SELECT
+					ID AS projectId,
+					SUBSTRING_INDEX(FINISH_ORG_IDS,':',1) AS agencyId
+			FROM
+					fact_origin_project_main_daily
+			WHERE
+					DEL_FLAG = '0'
+			AND ID IN (
+
+					    SELECT DISTINCT PROJECT_ID FROM fact_origin_project_log_daily
+					WHERE DEL_FLAG = '0' AND CUSTOMER_ID = #{customerId}
+					AND ACTION_CODE = 'close'
+					<if test='null != dimId and "" != dimId'>
+                        AND MONTH_ID = #{dimId}
+                    </if>
+					 )
+					ORDER BY agencyId
+    </select>
+    <!-- 计算每个办结项目的总耗时 -->
+    <select id="selectProjectCostTime" resultType="com.epmet.dto.extract.result.ProjectParticipatedAgencyResultDTO">
+        SELECT
+            DISTINCT
+            log1.PROJECT_ID,
+            IF(
+                TIMESTAMPDIFF( DAY, log2.createdDate, DATE_FORMAT( log1.DATE_ID, '%Y-%m-%d' ) ) = 0,
+                1,
+                TIMESTAMPDIFF( DAY, log2.createdDate, DATE_FORMAT( log1.DATE_ID, '%Y-%m-%d' ) )
+            ) * 8 * 60 AS count
+        FROM
+            fact_origin_project_log_daily log1
+            LEFT JOIN (
+        SELECT
+            ID ,
+            DATE_FORMAT( DATE_ID, '%Y-%m-%d' ) AS createdDate
+        FROM
+            fact_origin_project_main_daily
+        WHERE
+            DEL_FLAG = '0'
+        <foreach collection="projectIds" item="projectId" open="AND ( " separator=" OR " close=" ) ">
+            ID = #{projectId}
+         </foreach>
+            AND PROJECT_STATUS = 'closed'
+
+            ) log2 ON log1.PROJECT_ID = log2.ID
+        WHERE
+            log1.DEL_FLAG = '0'
+        <foreach collection="projectIds" item="projectId" open="AND ( " separator=" OR " close=" ) ">
+            log1.PROJECT_ID = #{projectId}
+        </foreach>
+            AND log1.IS_ACTIVE = '1'
+            AND log1.ACTION_CODE = 'close'
+    </select>
 
     <select id="selectGridResponse" resultType="com.epmet.dto.extract.result.OrgStatisticsResultDTO">
         SELECT a.ORG_ID,