Merge remote-tracking branch 'remotes/origin/dev_grid_member_statistics' into dev_gridmember_fusion

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

@@ -98,7 +98,7 @@
             and del_flag = 0
         </where>
         group by member.staff_id, member.grid_id
-        order by ${sort} desc
+        order by ${sort} desc, convert(member.staff_name using gbk) asc, member.GRID_ID asc
     </select>
 
     <select id="getGridMemberIssueProjectStats"

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/user/result/StatsStaffPatrolRecordDailyDTO.java

@@ -49,6 +49,11 @@ public class StatsStaffPatrolRecordDailyDTO implements Serializable {
      */
 	private String customerId;
 
+	/**
+     * 来源客户Id
+     */
+	private String sourceCustomerId;
+
     /**
      * 数据来源客户Id
      */

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/user/StatsStaffPatrolRecordDailyDao.java

@@ -35,7 +35,23 @@ import java.util.List;
 @Mapper
 public interface StatsStaffPatrolRecordDailyDao extends BaseDao<StatsStaffPatrolRecordDailyEntity> {
 
+    /**
+     * desc: 请描述类的业务用途
+     *
+     * @param insertList
+     * @return java.lang.Integer
+     * @author LiuJanJun
+     * @date 2021/7/9 1:57 下午
+     */
     Integer insertBatch(@Param("list") List<StatsStaffPatrolRecordDailyDTO> insertList);
 
-    int delete(StaffPatrolStatsFormDTO formDTO);
+    /**
+     * desc: 删除内部数据
+     *
+     * @param formDTO
+     * @return int
+     * @author LiuJanJun
+     * @date 2021/7/9 2:03 下午
+     */
+    int deleteInternal(StaffPatrolStatsFormDTO formDTO);
 }

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

@@ -227,6 +227,9 @@ public class BizDataStatsServiceImpl implements BizDataStatsService {
             record.setPatrolTotal(NumConstant.ZERO);
             record.setLatestPatrolStatus("end");
             record.setReportProjectCount(NumConstant.ZERO);
+
+            record.setSourceType("internal");
+            record.setSourceCustomerId(record.getCustomerId());
             //最后巡查时间
             record.setLatestPatrolTime(null);
             if (recordDailyDTO != null) {

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/user/impl/StatsStaffPatrolServiceImpl.java

@@ -32,7 +32,7 @@ public class StatsStaffPatrolServiceImpl implements StatsStaffPatrolService {
 
     @Override
     public Integer delAndInsertBatch(StaffPatrolStatsFormDTO formDTO, List<StatsStaffPatrolRecordDailyDTO> insertList) {
-        int delete = statsStaffPatrolRecordDailyDao.delete(formDTO);
+        int delete = statsStaffPatrolRecordDailyDao.deleteInternal(formDTO);
         log.debug("delAndInsertBatch delete:{},param:{}", delete, JSON.toJSONString(formDTO));
         return statsStaffPatrolRecordDailyDao.insertBatch(insertList);
     }

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/user/StatsStaffPatrolRecordDailyDao.xml

@@ -6,7 +6,9 @@
          insert into stats_staff_patrol_record_daily
         (
             ID,
+            SOURCE_TYPE,
             CUSTOMER_ID,
+            SOURCE_CUSTOMER_ID,
             DATE_ID,
             WEEK_ID,
             MONTH_ID,
@@ -31,7 +33,9 @@
         <foreach collection="list" item="item" separator=",">
             (
             (SELECT REPLACE(UUID(), '-', '') AS id),
+            #{item.sourceType},
             #{item.customerId},
+            #{item.sourceCustomerId},
             #{item.dateId},
             #{item.weekId},
             #{item.monthId},
@@ -54,11 +58,16 @@
             now()
             )
         </foreach>
+        ON DUPLICATE KEY UPDATE
+            PATROL_TOTAL = values(PATROL_TOTAL),
+            TOTAL_TIME = values(TOTAL_TIME),
+            UPDATED_BY = VALUES(UPDATED_BY)
     </insert>
-    <delete id="delete">
+    <delete id="deleteInternal">
         DELETE FROM stats_staff_patrol_record_daily
         WHERE CUSTOMER_ID = #{customerId}
         AND DATE_ID = #{dateId}
+        AND SOURCE_TYPE = 'internal'
         <if test="gridId != null and gridId != ''">
             AND GRID_ID = #{gridId}
         </if>