网格员巡查 适应 数据融合调整

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

@@ -39,11 +39,21 @@ public class StatsStaffPatrolRecordDailyDTO implements Serializable {
      */
 	private String id;
 
+    /**
+     * 来源类型 external:外部，internal:内部
+     */
+	private String sourceType;
+
     /**
      * 客户Id
      */
 	private String customerId;
 
+	/**
+     * 来源客户Id
+     */
+	private String sourceCustomerId;
+
     /**
      * 统计日期 关联日期dim表
      */

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>