From 8d08abc80c2e6d5ff3f123ac4493a806e9d7ca64 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Wed, 1 Sep 2021 15:12:11 +0800
Subject: [PATCH] =?UTF-8?q?screenProjectOrgDaily=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ScreenProjectOrgDailyServiceImpl.java     | 26 ++----
 .../extract/FactOriginProjectMainDailyDao.xml | 91 +++++++++----------
 .../screen/ScreenProjectOrgDailyDao.xml       |  2 +-
 3 files changed, 48 insertions(+), 71 deletions(-)

diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectOrgDailyServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectOrgDailyServiceImpl.java
index 3a37d17a40..9fbca67078 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectOrgDailyServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectOrgDailyServiceImpl.java
@@ -184,44 +184,30 @@ public class ScreenProjectOrgDailyServiceImpl extends BaseServiceImpl<ScreenProj
             log.warn(String.format(PingYinConstants.AGENCY_INFO_IS_ZERO,customerId));
             return;
         }
+        del(customerId, dateId);
         List<ProjectOrgDailyResultDTO> projectOrgDaily = baseDao.selectOrgProjectByAgency(agencyInfos, dateId);
         if (CollectionUtils.isEmpty(projectOrgDaily)){
             log.info(String.format(PingYinConstants.SELECT_GRID_INFO_BY_ORG_IS_NULL,customerId));
             return;
         }
         log.info(projectOrgDaily.toString());
-        List<ScreenProjectOrgDailyDTO> createProjects = disposeCreateProject(agencyInfos, dateId);
+        agencyInfos = disposeCreateProject(agencyInfos, dateId);
         agencyInfos.forEach(a -> {
             a.setDateId(dateId);
             projectOrgDaily.forEach(p -> {
                 if (a.getAreaCode().equals(p.getAreaCode())){
-                    a.setResolvedRatio(getRatio(p.getResolvedNum(),p.getProjectTotal()));
-                    a.setBadRatio(getRatio(p.getBadTotal(),p.getEvaluateTotal()));
-                    a.setGoodRatio(getRatio(p.getGoodTotal(),p.getEvaluateTotal()));
-                    a.setBadTotal(p.getBadTotal());
-                    a.setEvaluateTotal(p.getEvaluateTotal());
-                    a.setGoodTotal(p.getGoodTotal());
-                    a.setProjectTotal(p.getProjectTotal());
-                    a.setResolvedNum(p.getResolvedNum());
-                }
-            });
-        });
-        agencyInfos.forEach(a -> {
-            createProjects.forEach(p -> {
-                if (a.getOrgId().equals(p.getOrgId())){
                     a.setBadTotal(p.getBadTotal() + a.getBadTotal());
                     a.setEvaluateTotal(p.getEvaluateTotal() + a.getEvaluateTotal());
                     a.setGoodTotal(p.getGoodTotal() + a.getGoodTotal());
                     a.setProjectTotal(p.getProjectTotal() + a.getProjectTotal());
                     a.setResolvedNum(p.getResolvedNum() + a.getResolvedNum());
-                    a.setResolvedRatio(getRatio(a.getResolvedNum(),a.getProjectTotal()));
-                    a.setBadRatio(getRatio(a.getBadTotal(),a.getEvaluateTotal()));
-                    a.setGoodRatio(getRatio(a.getGoodTotal(),a.getEvaluateTotal()));
+                    a.setResolvedRatio(getRatio(p.getResolvedNum(),p.getProjectTotal()));
+                    a.setBadRatio(getRatio(p.getBadTotal(),p.getEvaluateTotal()));
+                    a.setGoodRatio(getRatio(p.getGoodTotal(),p.getEvaluateTotal()));
                 }
             });
         });
         log.info(agencyInfos.toString());
-        del(customerId, dateId);
         insert(agencyInfos,customerId,dateId);
     }
 
@@ -239,6 +225,7 @@ public class ScreenProjectOrgDailyServiceImpl extends BaseServiceImpl<ScreenProj
             log.warn(String.format(PingYinConstants.AGENCY_INFO_IS_ZERO,customerId));
             return;
         }
+        del(customerId, dateId);
         List<ProjectOrgDailyResultDTO> projectOrgDaily = baseDao.selectOrgProject(agencyInfos, dateId);
         if (CollectionUtils.isEmpty(projectOrgDaily)){
             log.info(String.format(PingYinConstants.SELECT_GRID_INFO_BY_ORG_IS_NULL,customerId));
@@ -278,7 +265,6 @@ public class ScreenProjectOrgDailyServiceImpl extends BaseServiceImpl<ScreenProj
             });
         });
         log.info(agencyInfos.toString());
-        del(customerId, dateId);
         insert(agencyInfos,customerId,dateId);
     }
 
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectMainDailyDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectMainDailyDao.xml
index fdf90af1f3..5558bfaa05 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectMainDailyDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectMainDailyDao.xml
@@ -623,66 +623,57 @@
 
     <!-- 组织查询项目总数 -->
     <select id="selectProjectTotalByOrg" resultType="com.epmet.dto.pingyin.result.ProjectTotalResultDTO">
-        SELECT
-        m.AGENCY_ID AS orgId,
-        IFNULL(COUNT(m.ID),0) AS projectTotal
-        FROM fact_origin_project_main_daily m
-        WHERE m.DEL_FLAG = 0
-        AND m.GRID_ID = ''
-        AND (
-            <foreach collection="orgIds" item="orgId" separator=" OR ">
-                m.AGENCY_ID = #{orgId}
-            </foreach>
-        )
-        <if test="dateId != null and dateId != '' ">
-            AND m.DATE_ID <![CDATA[ <= ]]>  #{dateId}
-        </if>
-        <if test="monthId != null and monthId != '' ">
-            AND m.MONTH_ID <![CDATA[ <= ]]> #{monthId}
-        </if>
-        GROUP BY m.AGENCY_ID
+        <foreach collection="orgIds" item="orgId" separator=" UNION ALL ">
+            SELECT
+                #{orgId} AS orgId,
+                IFNULL(COUNT(m.ID),0) AS projectTotal
+            FROM fact_origin_project_main_daily m
+            WHERE m.DEL_FLAG = 0
+                AND m.GRID_ID = ''
+                AND m.PIDS LIKE CONCAT('%',#{orgId},'%')
+                <if test="dateId != null and dateId != '' ">
+                    AND m.DATE_ID <![CDATA[ <= ]]>  #{dateId}
+                </if>
+                <if test="monthId != null and monthId != '' ">
+                    AND m.MONTH_ID <![CDATA[ <= ]]> #{monthId}
+                </if>
+        </foreach>
     </select>
 
     <!-- 组织查询已解决项目数 -->
     <select id="selectResolvedNumByOrg" resultType="com.epmet.dto.pingyin.result.ResolvedNumResultDTO">
-        SELECT
-            AGENCY_ID AS orgId,
-            IFNULL(COUNT(ID),0) AS resolvedNum
-        FROM fact_origin_project_main_daily
-        WHERE DEL_FLAG = 0
-          AND DATE_ID <![CDATA[ <= ]]> #{dateId}
-          AND PROJECT_STATUS = 'closed'
-          AND IS_RESOLVED = 'resolved'
-          AND (
-          <foreach collection="orgIds" item="orgId" separator=" OR ">
-              AGENCY_ID = #{orgId}
-          </foreach>
-          )
-          AND GRID_ID = ''
-        GROUP BY AGENCY_ID
+        <foreach collection="orgIds" item="orgId" separator=" UNION ALL ">
+            SELECT
+                #{orgId} AS orgId,
+                IFNULL(COUNT(ID),0) AS resolvedNum
+            FROM fact_origin_project_main_daily
+            WHERE DEL_FLAG = 0
+            AND DATE_ID <![CDATA[ <= ]]> #{dateId}
+            AND PIDS LIKE CONCAT('%',#{orgId},'%')
+            AND PROJECT_STATUS = 'closed'
+            AND IS_RESOLVED = 'resolved'
+            AND GRID_ID = ''
+        </foreach>
     </select>
 
     <!-- 组织 查询 满意度评价次数 -->
     <select id="selectEvaluateCountByOrg" resultType="com.epmet.dto.pingyin.result.EvaluateTotalResultDTO">
-        SELECT
-        ORG_ID,
-        IFNULL(COUNT(PROJECT_ID),0) AS evaluateCount
-        FROM fact_origin_project_log_daily
-        WHERE DEL_FLAG = 0
-        AND ORG_TYPE = 'agency'
-        AND DATE_ID <![CDATA[ <= ]]> #{dateId}
-        AND (
-            <foreach collection="orgIds" item="orgId" separator=" OR ">
-                org_id = #{orgId}
+        <foreach collection="orgIds" item="orgId" separator=" UNION ALL ">
+            SELECT
+                #{orgId} as orgId,
+                IFNULL(COUNT(PROJECT_ID),0) AS evaluateCount
+            FROM fact_origin_project_log_daily
+            WHERE DEL_FLAG = 0
+            AND ORG_TYPE = 'agency'
+            AND DATE_ID <![CDATA[ <= ]]> #{dateId}
+            AND PIDS LIKE CONCAT('%',#{orgId},'%')
+            AND IS_ACTIVE = 1
+            AND (
+            <foreach collection="activeCodes" item="code" separator=" OR ">
+                ACTION_CODE = #{code}
             </foreach>
-        )
-        AND IS_ACTIVE = 1
-        AND (
-        <foreach collection="activeCodes" item="code" separator=" OR ">
-            ACTION_CODE = #{code}
+            )
         </foreach>
-        )
-        GROUP BY ORG_ID
     </select>
 
     <!-- 组织查询本月新增项目数 -->
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectOrgDailyDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectOrgDailyDao.xml
index 0700977462..841526476b 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectOrgDailyDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectOrgDailyDao.xml
@@ -138,7 +138,7 @@
             FROM screen_project_grid_daily g
             LEFT JOIN screen_customer_grid cg ON cg.GRID_ID = g.GRID_ID
             WHERE g.DEL_FLAG = 0
-            AND cg.PARENT_AGENCY_ID  = #{a.orgId}
+            AND cg.ALL_PARENT_IDS LIKE CONCAT('%',#{a.orgId},'%')
             AND g.DATE_ID <![CDATA[ = ]]> #{dateId}
         </foreach>
     </select>