Jelajahi Sumber

set rootSourceId

wangyunpeng 1 Minggu lalu
induk
melakukan
21795860d8

+ 1 - 0
api-module/src/main/java/com/tzld/piaoquan/api/service/strategy/impl/BuckStrategyV1.java

@@ -314,6 +314,7 @@ public class BuckStrategyV1 implements ReplyStrategyService {
                             cgiReplyBucketData.getMiniPagePath(), cgiReplyBucketData.getTitle(), cgiReplyBucketData.getCoverUrl());
                 }
                 cgiReplyBucketData.setMiniPagePath(pageUrl);
+                cgiReplyBucketData.setRootSourceId(MessageUtil.getRootSourceId(cgiReplyBucketData.getMiniPagePath()));
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
                 String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
                 VideoCharacteristicVO vo = new VideoCharacteristicVO();

+ 1 - 0
api-module/src/main/java/com/tzld/piaoquan/api/service/strategy/impl/ThirdPartyPushMessageStrategyV1.java

@@ -228,6 +228,7 @@ public class ThirdPartyPushMessageStrategyV1 implements ReplyStrategyService {
                             pageUrl, cgiReplyBucketData.getTitle(), cgiReplyBucketData.getCoverUrl());
                     cgiReplyBucketData.setMiniPagePath(pageUrl);
                 }
+                cgiReplyBucketData.setRootSourceId(MessageUtil.getRootSourceId(cgiReplyBucketData.getMiniPagePath()));
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
                 String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
                 VideoCharacteristicVO vo = new VideoCharacteristicVO();

+ 1 - 0
api-module/src/main/java/com/tzld/piaoquan/api/service/strategy/impl/WeComPushMessageStrategyV1.java

@@ -182,6 +182,7 @@ public class WeComPushMessageStrategyV1 implements ReplyStrategyService {
                 String pageUrl = videoMultiService.setVideoMultiTitleCoverPagePath(cgiReplyBucketData.getMiniVideoId(),
                         cgiReplyBucketData.getMiniPagePath(), cgiReplyBucketData.getTitle(), cgiReplyBucketData.getCoverUrl());
                 cgiReplyBucketData.setMiniPagePath(pageUrl);
+                cgiReplyBucketData.setRootSourceId(MessageUtil.getRootSourceId(cgiReplyBucketData.getMiniPagePath()));
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
                 String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
                 VideoCharacteristicVO vo = new VideoCharacteristicVO();

+ 15 - 0
api-module/src/test/java/com/tzld/piaoquan/api/GhDetailTest.java

@@ -2,6 +2,7 @@ package com.tzld.piaoquan.api;
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.tzld.piaoquan.api.component.AigcApiService;
 import com.tzld.piaoquan.api.component.ManagerApiService;
 import com.tzld.piaoquan.api.dao.mapper.GhDetailExtMapper;
 import com.tzld.piaoquan.api.model.po.GhDetailExt;
@@ -18,6 +19,7 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 @SpringBootTest(classes = GrowthServerApplication.class)
 @Slf4j
@@ -31,6 +33,8 @@ public class GhDetailTest {
     CgiReplyBucketDataMapper cgiReplyBucketDataMapper;
     @Autowired
     CgiReplyBucketDataMapperExt cgiReplyBucketDataMapperExt;
+    @Autowired
+    AigcApiService aigcApiService;
 
     @Test
     public void testGhDetailExtId() {
@@ -103,4 +107,15 @@ public class GhDetailTest {
         }
     }
 
+    @Test
+    public void refreshGzhAutoReplyMsgData() {
+        CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
+        example.createCriteria().andIsDeleteEqualTo(0);
+        List<CgiReplyBucketData> list = cgiReplyBucketDataMapper.selectByExample(example);
+        List<String> ghIds = list.stream().map(CgiReplyBucketData::getGhId).distinct().collect(Collectors.toList());
+        for (String ghId : ghIds) {
+            aigcApiService.refreshGzhAutoReplyMsgData(ghId);
+        }
+    }
+
 }

+ 4 - 0
common-module/src/main/java/com/tzld/piaoquan/growth/common/utils/MessageUtil.java

@@ -38,4 +38,8 @@ public class MessageUtil {
         return String.format(defaultName, DateUtil.getDayDateString("MMdd"), remark);
     }
 
+    public static void main(String[] args) {
+        String url = "pages/category?jumpPage=pages%2Fuser-videos%3FfromGzh%3D1%26rootShareId%3D450ba747-3375-4cf3-a908-1b2772e181a7%26id%3D13889690%26shareId%3D450ba747-3375-4cf3-a908-1b2772e181a7%26rootSourceId%3Ddaitou_tencentgzh_20251212_13889690_f7221c51%26shareTitleId%3D14889690%26shareImageId%3D87473466%26shareImageUrl%3Dhttps%253A%252F%252Frescdn.yishihui.com%252Flongvideo%252Fpic%252F44a75a67b65244ef80a8dca6341584fc1765518383424";
+        System.out.println(getRootSourceId(url));
+    }
 }