定时任务

src/main/java/com/huiju/estateagents/job/CustomerStatisticTimeJob.java

@@ -50,7 +50,7 @@ public class CustomerStatisticTimeJob extends BaseController {
      *
      * 开启定时任务，每天23:50执行
      */
-    @Scheduled(cron = "* 50 23 * * ?")
+    @Scheduled(cron = "00 50 23 * * ?")
     private void configureTasks() {
         LocalDateTime nowDate = LocalDateTime.now();
     

src/main/java/com/huiju/estateagents/statistic/mapper/TaCustomerStatisticDailyMapper.java

@@ -52,4 +52,6 @@ public interface TaCustomerStatisticDailyMapper extends BaseMapper<TaCustomerSta
 	 * @return
 	 */
 	List<TaCustomerStatisticDaily> getDailyList(@Param("customerType") String customerType,@Param("orgId")  Integer orgId,@Param("nowDate")  LocalDateTime nowDate,@Param("beforeDate")  LocalDateTime beforeDate);
+	
+	int deleteNowDate(@Param("nowDate") LocalDateTime nowDate,@Param("customerType") String customerType);
 }

src/main/java/com/huiju/estateagents/statistic/service/impl/TaCustomerStatisticDailyServiceImpl.java

@@ -98,6 +98,9 @@ public class TaCustomerStatisticDailyServiceImpl extends ServiceImpl<TaCustomerS
 	 * @param customerType
 	 */
 	private void statisticDailySaveBatch(List<TaCustomerStatisticDaily> list, LocalDateTime nowDate, String customerType) {
+		//先删除当天数据在添加防止有脏数据
+		customerStatisticDailyMapper.deleteNowDate(nowDate,customerType);
+		
 		list.forEach(e -> {
 			e.setCreateDate(nowDate);
 			e.setCustomerType(customerType);

src/main/resources/mapper/statistic/TaCustomerStatisticDailyMapper.xml

@@ -2,6 +2,12 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.huiju.estateagents.statistic.mapper.TaCustomerStatisticDailyMapper">
 
+    <delete id="deleteNowDate">
+        delete from ta_customer_statistic_daily
+        where customer_type = #{customerType}
+        AND date_format( create_date, '%Y-%m-%d' ) = date_format( #{nowDate}, '%Y-%m-%d' )
+    </delete>
+
     <select id="getFollowUpData" resultType="com.huiju.estateagents.statistic.entity.TaCustomerStatisticDaily">
         SELECT
             org_id,