修改匹配小程序

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/repository/longArticle/LongArticlesMatchVideoRepository.java

@@ -16,4 +16,6 @@ public interface LongArticlesMatchVideoRepository extends JpaRepository<LongArti
     List<LongArticlesMatchVideo> getByContentIdIn(List<String> contentIds);
 
     List<LongArticlesMatchVideo> getByContentId(String contentId);
+
+    List<LongArticlesMatchVideo> getByContentIdAndGhIdAndPublishFlag(String contentId, String ghId, Integer publishFlag);
 }

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/repository/longArticle/LongArticlesTextRepository.java

@@ -9,4 +9,6 @@ import java.util.List;
 @Repository
 public interface LongArticlesTextRepository extends JpaRepository<LongArticlesText, String> {
     List<LongArticlesText> getByContentIdIn(List<String> contentIds);
+
+    LongArticlesText getByContentId(String contentId);
 }

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/video/impl/MatchVideoServiceImpl.java

@@ -85,32 +85,40 @@ public class MatchVideoServiceImpl implements MatchVideoService {
             res.put("info", "params check error");
             return res;
         }
-        String traceId = String.format("search-%s-%s", UUID.randomUUID(), System.currentTimeMillis() / 1000);
-        LongArticlesMatchVideo longArticlesMatchVideo = new LongArticlesMatchVideo();
-        longArticlesMatchVideo.setTraceId(traceId);
-        longArticlesMatchVideo.setContentId(searchVideoParam.getArticleId());
-        longArticlesMatchVideo.setFlowPoolLevel(searchVideoParam.getFlowPoolLevelTag());
-        longArticlesMatchVideo.setGhId(searchVideoParam.getGhId());
-        longArticlesMatchVideo.setAccountName(searchVideoParam.getAccountName());
-        longArticlesMatchVideo.setUpdateTime(new Date());
-        longArticlesMatchVideo.setRequestTimestamp(System.currentTimeMillis() / 1000);
-        if (searchVideoParam.getPublishFlag() == null) {
-            longArticlesMatchVideo.setPublishFlag(1);
+        int publishFlag = 1;
+        if (searchVideoParam.getPublishFlag() != null) {
+            publishFlag = searchVideoParam.getPublishFlag();
+        }
+        String traceId;
+        List<LongArticlesMatchVideo> existLongArticlesMatchVideo =
+                longArticlesMatchVideoRepository.getByContentIdAndGhIdAndPublishFlag(searchVideoParam.getArticleId(),
+                        searchVideoParam.getAccountName(), publishFlag);
+        if (existLongArticlesMatchVideo == null) {
+            traceId = String.format("search-%s-%s", UUID.randomUUID(), System.currentTimeMillis() / 1000);
+            LongArticlesMatchVideo longArticlesMatchVideo = new LongArticlesMatchVideo();
+            longArticlesMatchVideo.setTraceId(traceId);
+            longArticlesMatchVideo.setContentId(searchVideoParam.getArticleId());
+            longArticlesMatchVideo.setFlowPoolLevel(searchVideoParam.getFlowPoolLevelTag());
+            longArticlesMatchVideo.setGhId(searchVideoParam.getGhId());
+            longArticlesMatchVideo.setAccountName(searchVideoParam.getAccountName());
+            longArticlesMatchVideo.setUpdateTime(new Date());
+            longArticlesMatchVideo.setRequestTimestamp(System.currentTimeMillis() / 1000);
+            longArticlesMatchVideo.setPublishFlag(publishFlag);
+            longArticlesMatchVideo.setVideoPoolTraceId(searchVideoParam.getVideoPoolTraceId());
+            longArticlesMatchVideoRepository.save(longArticlesMatchVideo);
         } else {
-            longArticlesMatchVideo.setPublishFlag(searchVideoParam.getPublishFlag());
+            traceId = existLongArticlesMatchVideo.get(0).getTraceId();
+        }
+        LongArticlesText longArticlesText1 = longArticlesTextRepository.getByContentId(searchVideoParam.getArticleId());
+        if (longArticlesText1 == null) {
+            LongArticlesText longArticlesText = new LongArticlesText();
+            longArticlesText.setContentId(searchVideoParam.getArticleId());
+            longArticlesText.setArticleTitle(searchVideoParam.getTitle());
+            longArticlesText.setArticleText(searchVideoParam.getContent());
+            longArticlesText.setKimiStatus(0);
+            longArticlesText.setSimilarityStatus(0);
+            longArticlesTextRepository.save(longArticlesText);
         }
-        longArticlesMatchVideo.setVideoPoolTraceId(searchVideoParam.getVideoPoolTraceId());
-        longArticlesMatchVideoRepository.save(longArticlesMatchVideo);
-
-
-        LongArticlesText longArticlesText = new LongArticlesText();
-        longArticlesText.setContentId(searchVideoParam.getArticleId());
-        longArticlesText.setArticleTitle(searchVideoParam.getTitle());
-        longArticlesText.setArticleText(searchVideoParam.getContent());
-        longArticlesText.setKimiStatus(0);
-        longArticlesText.setSimilarityStatus(0);
-        longArticlesTextRepository.save(longArticlesText);
-
         if (StringUtils.isNotEmpty(searchVideoParam.getChannelContentId())) {
             CrawlerProduceIdMap crawlerProduceIdMap = new CrawlerProduceIdMap();
             crawlerProduceIdMap.setChannelContentId(searchVideoParam.getChannelContentId());