增加删除回调消息定时任务

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/XxlJobService.java

@@ -328,6 +328,7 @@ public class XxlJobService {
         }
         return ReturnT.SUCCESS;
     }
+
     @XxlJob("delPushMessageCallbackJob")
     public ReturnT<String> delPushMessageCallbackJob(String param) {
         Calendar calendar = Calendar.getInstance();
@@ -351,8 +352,8 @@ public class XxlJobService {
 
             PushMessageCallbackExample example = new PushMessageCallbackExample();
             example.createCriteria().andCreateTimeBetween(startTime, endTime);
-            long mySqlCount = pushMessageCallbackMapper.countByExample(example);
-            if (mySqlCount == 0) {
+            long mysqlCount = pushMessageCallbackMapper.countByExample(example);
+            if (mysqlCount == 0) {
                 break;
             }
             String pt = DateUtils.getDateString(startTime.getTime());
@@ -363,8 +364,8 @@ public class XxlJobService {
                 return ReturnT.FAIL;
             }
             Long hiveCount = recordList.get(0).getBigint(0);
-            if (Math.abs(mySqlCount - hiveCount) > 500) {
-                LarkRobotUtil.sendMessage("数量异常" + pt);
+            if (Math.abs(mysqlCount - hiveCount) > 0) {
+                LarkRobotUtil.sendMessage("数量异常" + pt + "\n mysql数量：" + mysqlCount + "\n hive数量：" + hiveCount);
                 return ReturnT.FAIL;
             }
             pushMessageCallbackMapper.deleteByExample(example);