From 03dd61f514f3df982fb2c4cdf97ebe45c23269dd Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrjt@163.com>
Date: Wed, 13 Jul 2022 15:03:17 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E4=B8=8A=E6=8A=A5=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../screen/ScreenProjectDataDao.xml           | 27 ++++++++++++-------
 .../impl/BaseDisputeProcessServiceImpl.java   |  2 +-
 2 files changed, 19 insertions(+), 10 deletions(-)

diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectDataDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectDataDao.xml
index f132877210..a52fb831b7 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectDataDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectDataDao.xml
@@ -241,7 +241,16 @@
                 screen_project_process spp
             WHERE
                 ( spp.CUSTOMER_ID = '2fe0065f70ca0e23ce4c26fca5f1d933' OR spp.CUSTOMER_ID = '44876154d10d7cb7affd92000f84f833' OR spp.CUSTOMER_ID = '46c55cb862d6d5e6d05d2ab61a1cc07e' )
-                AND OPERATION = 'closed_case' UNION ALL
+                AND OPERATION = 'closed_case'
+                <if test='null != customerId and "" != customerId'>
+                    AND spp.CUSTOMER_ID = #{customerId}
+                </if>
+                <if test='null != projectIds and projectIds.size()>0'>
+                    <foreach collection="projectIds" item="projectId" open="AND (" separator=" OR " close=" )">
+                       spp.PROJECT_ID = #{projectId}
+                    </foreach>
+                </if>
+            UNION ALL
             SELECT
                 spp.CUSTOMER_ID,
                 PROJECT_ID,
@@ -253,15 +262,15 @@
             WHERE
                 ( spp.CUSTOMER_ID != '2fe0065f70ca0e23ce4c26fca5f1d933' AND spp.CUSTOMER_ID != '44876154d10d7cb7affd92000f84f833' AND spp.CUSTOMER_ID != '46c55cb862d6d5e6d05d2ab61a1cc07e' )
                 AND OPERATION = 'close'
+                <if test='null != customerId and "" != customerId'>
+                    AND spp.CUSTOMER_ID = #{customerId}
+                </if>
+                <if test='null != projectIds and projectIds.size()>0'>
+                    <foreach collection="projectIds" item="projectId" open="AND (" separator=" OR " close=" )">
+                       spp.PROJECT_ID = #{projectId}
+                    </foreach>
+                </if>
             ) b ON a.PROJECT_ID = b.PROJECT_ID
-            <if test='null != customerId and "" != customerId'>
-                AND b.CUSTOMER_ID = #{customerId}
-            </if>
-            <if test='null != projectIds and projectIds.size()>0'>
-                <foreach collection="projectIds" item="projectId" open="AND (" separator=" OR " close=" )">
-                   b.PROJECT_ID = #{projectId}
-                </foreach>
-            </if>
             LEFT JOIN screen_customer_agency c ON b.HANDLER_ID = c.AGENCY_ID
             WHERE a.DEL_FLAG = '0'
             AND a.CATEGORY_CODE IS NOT NULL
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/BaseDisputeProcessServiceImpl.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/BaseDisputeProcessServiceImpl.java
index 81ca02745e..2d80688ddc 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/BaseDisputeProcessServiceImpl.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/BaseDisputeProcessServiceImpl.java
@@ -83,7 +83,7 @@ public class BaseDisputeProcessServiceImpl extends BaseServiceImpl<BaseDisputePr
         List<EventInfoResultDTO> list = result.getData();
         saveEvent(formDTO, deptMap, userMap, list);
         //分批次循环
-        while (CollectionUtils.isNotEmpty(list)) {
+        while (CollectionUtils.isNotEmpty(list) && list.size() == formDTO.getPageSize()) {
             formDTO.setPageNo(formDTO.getPageNo() + NumConstant.ONE);
             result = dataStatisticalOpenFeignClient.getEventInfo(formDTO);
             list = result.getData();