fix

api-module/src/main/java/com/tzld/piaoquan/api/dao/mapper/contentplatform/ext/ContentPlatformDataStatMapperExt.java

@@ -111,14 +111,20 @@ public interface ContentPlatformDataStatMapperExt {
 
     List<ContentPlatformQwDataStatReplyTotal> getQwTotalDatastatReplyScoreList(@Param("dt") String dt, @Param("channels") List<String> channels);
 
+    void deleteQwDatastat(@Param("dt") String dt);
+
     void deleteQwDatastatTotal(@Param("dt") String dt);
 
     void deleteQwDatastatReplyTotal(@Param("dt") String dt);
 
     void deleteQwDatastatSubChannel(@Param("dt") String dt);
 
+    void deleteGzhDatastat(@Param("dt") String dt);
+
     void deleteGzhDatastatTotal(@Param("dt") String dt);
 
+    void deleteFwhDatastat(@Param("dt") String dt);
+
     void deleteFwhDatastatTotal(@Param("dt") String dt);
 
     void deleteGzhVideoDatastat(@Param("dt") String dt);

api-module/src/main/java/com/tzld/piaoquan/api/job/ContentPlatformDatastatJob.java

@@ -69,10 +69,6 @@ public class ContentPlatformDatastatJob {
         if (StringUtils.hasText(param)) {
             dt = param;
         }
-        long count = getGzhDatastatCount(dt);
-        if (count > 0) {
-            return ReturnT.SUCCESS;
-        }
         Long now = System.currentTimeMillis();
         // 公众号自动回复数据统计
         String sql = String.format(
@@ -122,6 +118,7 @@ public class ContentPlatformDatastatJob {
                 saveList.add(item);
             }
             if (CollectionUtils.isNotEmpty(saveList)) {
+                dataStatMapperExt.deleteGzhDatastat(dt);
                 dataStatMapperExt.batchInsertGzhDatastat(saveList);
             }
         }
@@ -270,10 +267,6 @@ public class ContentPlatformDatastatJob {
         if (StringUtils.hasText(param)) {
             dt = param;
         }
-        long count = getFwhDatastatCount(dt);
-        if (count > 0) {
-            return ReturnT.SUCCESS;
-        }
         Long now = System.currentTimeMillis();
         // 公众号自动回复数据统计
         String sql = String.format(
@@ -323,6 +316,7 @@ public class ContentPlatformDatastatJob {
                 saveList.add(item);
             }
             if (CollectionUtils.isNotEmpty(saveList)) {
+                dataStatMapperExt.deleteFwhDatastat(dt);
                 dataStatMapperExt.batchInsertFwhDatastat(saveList);
             }
         }
@@ -537,6 +531,7 @@ public class ContentPlatformDatastatJob {
             }
         }
         if (CollectionUtils.isNotEmpty(saveList)) {
+            dataStatMapperExt.deleteQwDatastat(dt);
             dataStatMapperExt.batchInsertQwDatastat(saveList);
         }
         return ReturnT.SUCCESS;

api-module/src/main/resources/mapper/contentplatform/ext/ContentPlatformDataStatMapperExt.xml

@@ -317,6 +317,10 @@
         group by cpa.channel
     </select>
 
+    <delete id="deleteQwDatastat">
+        delete from content_platform_qw_datastat where date_str = #{dt}
+    </delete>
+
     <delete id="deleteQwDatastatTotal">
         delete from content_platform_qw_datastat_total where date_str = #{dt}
     </delete>
@@ -329,10 +333,18 @@
         delete from content_platform_qw_datastat_sub_channel where date_str = #{dt}
     </delete>
 
+    <delete id="deleteGzhDatastat">
+        delete from content_platform_gzh_datastat where date_str = #{dt}
+    </delete>
+
     <delete id="deleteGzhDatastatTotal">
         delete from content_platform_gzh_datastat_total where date_str = #{dt}
     </delete>
 
+    <delete id="deleteFwhDatastat">
+        delete from content_platform_fwh_datastat where date_str = #{dt}
+    </delete>
+
     <delete id="deleteFwhDatastatTotal">
         delete from content_platform_fwh_datastat_total where date_str = #{dt}
     </delete>