发布内容查找根内容id 增加定时任务

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

@@ -19,6 +19,7 @@ import com.tzld.longarticle.recommend.server.model.entity.crawler.LongArticlesVi
 import com.tzld.longarticle.recommend.server.model.entity.longArticle.GetOffVideoArticle;
 import com.tzld.longarticle.recommend.server.model.entity.longArticle.LongArticlesMatchVideo;
 import com.tzld.longarticle.recommend.server.model.entity.longArticle.LongArticlesReadRate;
+import com.tzld.longarticle.recommend.server.model.param.ArticleFindSourceParam;
 import com.tzld.longarticle.recommend.server.repository.crawler.GetOffVideoCrawlerRepository;
 import com.tzld.longarticle.recommend.server.repository.crawler.LongArticlesRootSourceIdRepository;
 import com.tzld.longarticle.recommend.server.repository.crawler.LongArticlesVideoRepository;
@@ -26,6 +27,7 @@ import com.tzld.longarticle.recommend.server.repository.longArticle.GetOffVideoA
 import com.tzld.longarticle.recommend.server.repository.longArticle.LongArticlesMatchVideoRepository;
 import com.tzld.longarticle.recommend.server.repository.longArticle.LongArticlesReadRateRepository;
 import com.tzld.longarticle.recommend.server.repository.model.PushMessageCallbackExample;
+import com.tzld.longarticle.recommend.server.service.recommend.ArticleService;
 import com.tzld.longarticle.recommend.server.util.DateUtils;
 import com.tzld.longarticle.recommend.server.util.LarkRobotUtil;
 import com.tzld.longarticle.recommend.server.util.feishu.FeishuMessageSender;
@@ -69,6 +71,8 @@ public class XxlJobService {
     private LongArticlesRootSourceIdRepository longArticlesRootSourceIdRepository;
     @Autowired
     private PushMessageCallbackMapper pushMessageCallbackMapper;
+    @Autowired
+    private ArticleService articleService;
 
     @ApolloJsonValue("${touliu.account.ghIds:[\"gh_93e00e187787\", \"gh_ac43e43b253b\", \"gh_68e7fdc09fe4\",\"gh_77f36c109fb1\", \"gh_b181786a6c8c\", \"gh_1ee2e1b39ccf\"]}")
     private List<String> touliuAccountGhIds;
@@ -327,4 +331,12 @@ public class XxlJobService {
         }
         return ReturnT.SUCCESS;
     }
+
+    @XxlJob("syncArticleRootPublishId")
+    public ReturnT<String> syncArticleRootPublishId(String param) {
+        ArticleFindSourceParam findSourceParam = new ArticleFindSourceParam();
+        findSourceParam.setDateStr(param);
+        articleService.findSource(findSourceParam);
+        return ReturnT.SUCCESS;
+    }
 }

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

@@ -61,12 +61,16 @@ public class ArticleService {
             new ThreadPoolExecutor.AbortPolicy());
 
     public void findSource(ArticleFindSourceParam param) {
+        if (StringUtils.hasText(param.getWxSn())) {
+            syncAigcIdByWxSn(param.getWxSn());
+            return;
+        }
+        long minUpdateTimestamp;
         if (StringUtils.hasText(param.getDateStr())) {
-            long minUpdateTimestamp = DateUtils.dateStrToTimestamp(param.getDateStr(), "yyyyMMdd") - 86400 * 7;
+            minUpdateTimestamp = DateUtils.dateStrToTimestamp(param.getDateStr(), "yyyyMMdd") - 86400 * 7;
         } else {
-            long minUpdateTimestamp = DateUtils.getTodayStart() - 86400 * 7;
+            minUpdateTimestamp = DateUtils.getTodayStart() - 86400 * 7;
         }
-        long minUpdateTimestamp = 1704081913L;
         while (true) {
             List<Article> articleList = crawlerBaseMapper.getWaitingFindArticle(minUpdateTimestamp);
             if (CollectionUtils.isEmpty(articleList)) {

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

@@ -38,4 +38,9 @@ public class XxlJobController {
     public void alertPushMessageJob(String dateStr) {
         service.alertPushMessageJob(dateStr);
     }
+
+    @GetMapping("/syncArticleRootPublishId")
+    public void syncArticleRootPublishId(String dateStr) {
+        service.syncArticleRootPublishId(dateStr);
+    }
 }