Jelajahi Sumber

召回过滤去除白名单限制

wangyunpeng 3 bulan lalu
induk
melakukan
2a33eefa26

+ 5 - 6
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/recommend/recall/RecallService.java

@@ -32,6 +32,7 @@ import com.tzld.longarticle.recommend.server.model.param.TitleHisCacheParam;
 import com.tzld.longarticle.recommend.server.remote.aigc.AIGCWaitingPublishContentService;
 import com.tzld.longarticle.recommend.server.repository.aigc.CrawlerMetaArticleRepository;
 import com.tzld.longarticle.recommend.server.repository.aigc.PublishContentRepository;
+import com.tzld.longarticle.recommend.server.repository.aigc.PublishPlanRepository;
 import com.tzld.longarticle.recommend.server.repository.crawler.AccountAvgInfoRepository;
 import com.tzld.longarticle.recommend.server.repository.crawler.AccountCorrelationRepository;
 import com.tzld.longarticle.recommend.server.repository.crawler.ArticleDetailInfoRepository;
@@ -110,6 +111,8 @@ public class RecallService implements ApplicationContextAware {
     LongArticleTitleAuditRepository titleAuditRepository;
     @Autowired
     AigcBaseMapper aigcBaseMapper;
+    @Autowired
+    PublishPlanRepository publishPlanRepository;
 
     private final Map<String, RecallStrategy> strategyMap = new HashMap<>();
     private ApplicationContext applicationContext;
@@ -121,8 +124,6 @@ public class RecallService implements ApplicationContextAware {
     private Boolean contentHisFeishuEnable;
     @Value("${morning.noon.fission.rate:0.64}")
     private double morningNoonFissionRate;
-    @ApolloJsonValue("${whiteAccountList:[]}")
-    private List<String> whiteAccountList;
 
 
     @PostConstruct
@@ -193,12 +194,10 @@ public class RecallService implements ApplicationContextAware {
         long t2 = System.currentTimeMillis();
         CostMonitor.logCost("Recall", "GetAllContents", t2 - t1);
         ContentCountMonitor.logCount("Recall", "GetAllContents", Objects.isNull(content) ? 0 : content.size());
-        if (whiteAccountList.contains(param.getAccountName())) {
 //            // 临时过滤文章视频不匹配content
 //            filterNotMatchContent(content);
-            // 过滤仅保留审核通过content
-            filterAuditPassContent(content);
-        }
+        // 过滤仅保留审核通过content
+        filterAuditPassContent(content);
         ContentCountMonitor.logCount("Recall", "Filter", Objects.isNull(content) ? 0 : content.size());
         if (CollectionUtils.isEmpty(content)) {
             FeishuMessageSender.sendWebHookMessage(FeishuRobotIdEnum.RECOMMEND.getRobotId(),