Merge branch 'dev_screen_data_2.0' into dev_temp

epmet-module/data-report/data-report-client/src/main/java/com/epmet/evaluationindex/screen/dto/form/IndexScoreFormDTO.java

@@ -21,13 +21,15 @@ public class IndexScoreFormDTO implements Serializable {
     private String orgId;
     /**
      * 类型（组织：agency  网格：grid）
+     * 大屏接口此字段值为空
      */
-    @NotBlank(message = "数据类型不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class})
+    //@NotBlank(message = "数据类型不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class})
     private String orgType;
     /**
      * 月份Id eg：202009
+     * 大屏接口此字段值为空
      */
-    @NotBlank(message = "月份Id不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class})
+    //@NotBlank(message = "月份Id不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class})
     private String monthId;
     public interface AddUserInternalGroup {}
 

epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/IndexServiceImpl.java

@@ -2,6 +2,7 @@ package com.epmet.datareport.service.evaluationindex.screen.impl;
 
 import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.constant.DataSourceConstant;
 import com.epmet.datareport.dao.evaluationindex.screen.ScreenIndexDataMonthlyDao;
 import com.epmet.datareport.dao.evaluationindex.screen.ScreenIndexDataYearlyDao;
@@ -268,13 +269,17 @@ public class IndexServiceImpl implements IndexService {
     @Override
     public IndexScoreResultDTO indexScore(IndexScoreFormDTO formDTO) {
         //screen_index_data_monthly 根据组织id和月份获取月度指标得分
-        //1.根据组织或网格Id以及月份Id查询各项月度指数得分
+        //1.大屏接口 orgType和monthId字段不传值，默认查询上一个月数据
+        if(null==formDTO.getMonthId()||"".equals(formDTO.getMonthId())){
+            formDTO.setMonthId(DateUtils.getBeforeNMonth(1));
+        }
+        //2.根据组织或网格Id以及月份Id查询各项月度指数得分
         IndexScoreResultDTO resultDTO = screenIndexDataMonthlyDao.selectMonthData(formDTO);
         if (null == resultDTO) {
             return resultDTO;
         }
 
-        //2.将数据改成正确格式 四舍五入保留一位小数  权重转成百分比
+        //3.将数据改成正确格式 四舍五入保留一位小数  权重转成百分比
         NumberFormat nf = NumberFormat.getPercentInstance();
         nf.setMaximumFractionDigits(1);
 

epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenIndexDataMonthlyDao.xml

@@ -176,18 +176,20 @@
     <select id="selectMonthData" resultType="com.epmet.evaluationindex.screen.dto.result.IndexScoreResultDTO">
         SELECT
             index_total AS "total",
-            party_dev_ablity AS "party",
+            (party_dev_ablity * party_dev_weight) AS "party",
             party_dev_weight AS "partyDevAbilityWeight",
-            govern_ablity AS "govern",
+            (govern_ablity * govern_ablity_weight) AS "govern",
             govern_ablity_weight AS "governAbilityWeight",
-            service_ablity AS "service",
+            (service_ablity * service_ablity_weight) AS "service",
             service_ablity_weight AS "serviceAbilityWeight"
         FROM
             screen_index_data_monthly
         WHERE
             del_flag = '0'
         AND org_id = #{orgId}
+        <if test="orgType != null and orgType != '' ">
             AND org_type = #{orgType}
+        </if>
         AND month_id = #{monthId}
     </select>
 

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

@@ -52,7 +52,7 @@ public interface ScreenPartyUserRankDataDao extends BaseDao<ScreenPartyUserRankD
      * @author wangc
      * @date 2020.09.27 11:19
     */
-    Integer deleteBatchByCustomerIdAndDateId(@Param("customerId") String customerId,@Param("dateId") String dateId);
+    Integer deleteBatchByCustomerIdAndDateId(@Param("customerId") String customerId);
 
     /**
      * 9、党建引领|基层治理-居民（党员）积分排行榜

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/model/IndexExcelDataListener.java

@@ -316,7 +316,7 @@ public class IndexExcelDataListener extends AnalysisEventListener<IndexModel> {
             entity5.setCorrelation(data.getCorrelation());
             entity5.setLevel("5");
             entity5.setIndexCode(Pinyin4jUtil.getSpellPinYin(data.getLevel5Index(), false, 4));
-            entity.setValueType(data.getValueType());
+            entity5.setValueType(data.getValueType());
             indexDicMap.put(data.getLevel5Index(), entity5);
         }
     }

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

@@ -146,7 +146,7 @@ public class ScreenExtractServiceImpl implements ScreenExtractService {
         }catch (Exception e){
             log.error("先锋模范【extractExceptCommunityPioneerData】抽取到大屏失败，customerId为："+customerId+"dateId为："+dateId, e);
         }
-        //公众参与排行（注册人数、参与人数、话题数、议题数、项目数）screen_public_parti_total_data
+        //公众参与排行（注册人数、参与人数、话题数、议题数、项目数）screen_public_party_total_data
         try {
             publicPartiTotalDataExtractService.extractPublicPartiTotalData(customerId,dateId);
         }catch (Exception e){
@@ -156,9 +156,17 @@ public class ScreenExtractServiceImpl implements ScreenExtractService {
         ScreenCentralZoneDataFormDTO param = new ScreenCentralZoneDataFormDTO();
         param.setCustomerId(customerId);param.setDateId(dateId);
         //中央区 screen_user_total_data
+        try {
             screenCentralZoneDataAbsorptionService.centralZoneDataHub(param);
+        }catch (Exception e){
+            log.error("中央区抽取到大屏失败，customerId为："+customerId+"dateId为："+dateId, e);
+        }
         //基层治理- 难点赌点 screen_difficulty_data  |  screen_difficulty_img_data
+        try {
             screenGrassrootsGovernDataAbsorptionService.difficultyDataHub(param);
+        }catch (Exception e){
+            log.error("基层治理-难点赌点抽取到大屏失败，customerId为："+customerId+"dateId为："+dateId, e);
+        }
     }
 
     /**

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

@@ -122,7 +122,8 @@ public class ScreenGrassrootsGovernDataAbsorptionServiceImpl implements ScreenGr
         }
 
         //6.存入数据库
-        screenPartyUserRankDataService.dataClean(registeredUsers,param.getCustomerId(),dateId);
+        //不按照时间删除，每次插入之前将该客户下的所有历史数据清空
+        screenPartyUserRankDataService.dataClean(registeredUsers,param.getCustomerId());
     }
 
     /**

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

@@ -39,6 +39,6 @@ public interface ScreenPartyUserRankDataService extends BaseService<ScreenPartyU
      * @author wangc
      * @date 2020.09.27 09:44
     **/
-    void dataClean(List<ScreenPartyUserRankDataEntity> dataList,String customerId,String dateId);
+    void dataClean(List<ScreenPartyUserRankDataEntity> dataList,String customerId);
 
 }

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

@@ -55,11 +55,11 @@ public class ScreenPartyUserRankDataServiceImpl extends BaseServiceImpl<ScreenPa
      **/
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void dataClean(List<ScreenPartyUserRankDataEntity> dataList, String customerId, String dateId) {
+    public void dataClean(List<ScreenPartyUserRankDataEntity> dataList, String customerId) {
         if(!CollectionUtils.isEmpty(dataList)) {
             int affectedRows;
             do {
-                affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId, dateId);
+                affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId);
             } while (affectedRows > NumConstant.ZERO);
             baseDao.insertBatch(dataList);
         }

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

@@ -12,7 +12,6 @@
     <delete id="deleteBatchByCustomerIdAndDateId">
         delete from screen_party_user_rank_data
         where CUSTOMER_ID = #{customerId}
-        AND DATA_END_TIME = #{dateId}
         limit 1000;
     </delete>