溯源入口改为发布记录

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/model/entity/longArticle/ArticlePoolPromotionSource.java

@@ -35,6 +35,8 @@ public class ArticlePoolPromotionSource implements Serializable {
     private Integer status;
     @Column(name = "deleted")
     private Integer deleted;
+    @Column(name = "publish_timestamp")
+    private Long publishTimestamp;
     @Column(name = "create_timestamp")
     private Long createTimestamp;
     @Column(name = "update_timestamp")

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

@@ -265,12 +265,12 @@ public class ArticleService {
             if (Objects.isNull(publishAccount)) {
                 continue;
             }
-            List<PublishContent> publishContentList = aigcBaseMapper.getNearestPublishContent(publishAccount.getId(), now, null);
-            PublishContent publishContent = findPublishContent(publishContentList, task.getTitle(), now);
+            List<PublishContent> publishContentList = aigcBaseMapper.getNearestPublishContent(publishAccount.getId(), task.getPublishTimestamp(), 100);
+            PublishContent publishContent = findPublishContent(publishContentList, task.getTitle(), task.getPublishTimestamp());
             if (Objects.isNull(publishContent)) {
                 continue;
             }
-            RootPublishContentVO source = getRootPublishContent(task.getChannelContentId(), null, null, null, 0);
+            RootPublishContentVO source = getRootPublishContent(publishContent.getCrawlerChannelContentId(), null, publishContent.getId(), null, 0);
             // 更新
             if (StringUtils.hasText(source.getRootProduceContentId())) {
                 task.setStatus(ArticlePoolPromotionSourceStatusEnum.FINISH.getCode());