check 需求匹配报警

core/src/main/java/com/tzld/videoVector/job/ChannelDemandMatchCheckJob.java

@@ -34,26 +34,26 @@ public class ChannelDemandMatchCheckJob {
      */
     @XxlJob("checkChannelDemandMatchDataJob")
     public ReturnT<String> checkChannelDemandMatchDataJob(String param) {
-        String today = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
-        log.info("开始检查 channel_demand_match_result 表当日数据, dt={}", today);
+        String dt = LocalDate.now().minusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+        log.info("开始检查 channel_demand_match_result 表当日数据, dt={}", dt);
 
         try {
             ChannelDemandMatchResultExample example = new ChannelDemandMatchResultExample();
-            example.createCriteria().andDtEqualTo(today);
+            example.createCriteria().andDtEqualTo(dt);
             long count = resultMapper.countByExample(example);
 
-            log.info("channel_demand_match_result 表当日数据量, dt={}, count={}", today, count);
+            log.info("channel_demand_match_result 表当日数据量, dt={}, count={}", dt, count);
 
             if (count == 0) {
                 String alertMsg = String.format(
-                        "【渠道需求匹配告警】channel_demand_match_result 表当日(%s)暂无数据，请检查 channelDemandMatchJob 执行状态。", today);
+                        "【渠道需求匹配告警】channel_demand_match_result 表当日(%s)暂无数据，请检查 channelDemandMatchJob 执行状态。", dt);
                 FeishuMessageSender.sendWebHookMessage(FEISHU_ROBOT_ID, alertMsg);
-                log.warn("channel_demand_match_result 表当日无数据，已发送飞书报警, dt={}", today);
+                log.warn("channel_demand_match_result 表当日无数据，已发送飞书报警, dt={}", dt);
             } else if (count < 100000) {
                 String alertMsg = String.format(
-                        "【渠道需求匹配告警】channel_demand_match_result 表当日(%s)数据量不足，当前仅 %d 条（阈值 100000），请关注。", today, count);
+                        "【渠道需求匹配告警】channel_demand_match_result 表当日(%s)数据量不足，当前仅 %d 条（阈值 100000），请关注。", dt, count);
                 FeishuMessageSender.sendWebHookMessage(FEISHU_ROBOT_ID, alertMsg);
-                log.warn("channel_demand_match_result 表当日数据量不足，已发送飞书报警, dt={}, count={}", today, count);
+                log.warn("channel_demand_match_result 表当日数据量不足，已发送飞书报警, dt={}, count={}", dt, count);
             }
 
             return ReturnT.SUCCESS;