Browse Source

增加aigc刷新

xueyiming 3 months ago
parent
commit
0d9680ad4d

+ 66 - 2
offline-module/src/main/java/com/tzld/piaoquan/offline/job/AutoReplyVideoDataJob.java

@@ -32,8 +32,67 @@ import java.util.stream.Collectors;
 @Component
 public class AutoReplyVideoDataJob {
 
+    private static final List<String> auditGhIds = new ArrayList<String>() {{
+        add("gh_b63b9dde3f4b");
+        add("gh_330ef0db846d");
+        add("gh_330ef0db846d");
+        add("gh_e2318164f869");
+        add("gh_620af8e24fb9");
+        add("gh_620af8e24fb9");
+        add("gh_133c36b99b14");
+        add("gh_133c36b99b14");
+        add("gh_5ac72e2b9130");
+        add("gh_ef8ade0fad92");
+        add("gh_1e03b6de22bf");
+        add("gh_5538fe297e59");
+        add("gh_8c6fffcbaac1");
+        add("gh_8c6fffcbaac1");
+        add("gh_d0e830b7547e");
+        add("gh_fb234f4e32a5");
+        add("gh_84c5d01a61e7");
+        add("gh_87c4b8ae885e");
+        add("gh_29d8a63d5e5e");
+        add("gh_b144210318e5");
+        add("gh_b144210318e5");
+        add("gh_1f9bf4cfa788");
+        add("gh_4f47d12bbe04");
+        add("gh_8c6af276df98");
+        add("gh_1f16bc6ac60d");
+        add("gh_4920bc4c5720");
+        add("gh_5177a8c57917");
+        add("gh_5177a8c57917");
+        add("gh_5e3e6cd5e35c");
+        add("gh_5e3e6cd5e35c");
+        add("gh_d2c72bcc05c9");
+        add("gh_d2c72bcc05c9");
+        add("gh_5f2400da935c");
+        add("gh_5f2400da935c");
+        add("gh_669555ebea28");
+        add("gh_28ce883486c3");
+        add("gh_28ce883486c3");
+        add("gh_7057ef30222b");
+        add("gh_7057ef30222b");
+        add("gh_b0048adc0b46");
+        add("gh_6e61a2d5db85");
+        add("gh_01cd19465b39");
+        add("gh_01cd19465b39");
+        add("gh_126c99b39cea");
+        add("gh_4a1174e36ceb");
+        add("gh_f81c27eb8c48");
+        add("gh_f81c27eb8c48");
+        add("gh_3170dc15e246");
+        add("gh_1ccfb5620605");
+        add("gh_315be76a746d");
+        add("gh_4f47d12bbe04");
+        add("gh_4f47d12bbe04");
+        add("gh_4f47d12bbe04");
+    }};
+
     private static final String VIDEO_DETAIL_URL = "https://longvideoapi.piaoquantv.com/longvideoapi/openapi/video/batchSelectVideoInfo";
 
+    private static final String REFRESH_GZH_URL = "http://aigc-api.cybertogether.net/aigc/publish/api/refreshGzhAutoReplyMsgData";
+
+
     @Autowired
     private CgiReplyBucketDataMapper cgiReplyBucketDataMapper;
 
@@ -85,11 +144,11 @@ public class AutoReplyVideoDataJob {
             CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
             example.createCriteria().andMiniVideoIdEqualTo(videoId).andIsDeleteEqualTo(0);
             List<CgiReplyBucketData> cgiReplyBucketDataList = cgiReplyBucketDataMapper.selectByExample(example);
-            List<String> ghIds = cgiReplyBucketDataList.stream().map(CgiReplyBucketData::getGhId).collect(Collectors.toList());
+            List<String> ghIds = new ArrayList<>();
             List<String> manualGhIds = new ArrayList<>();
             for (CgiReplyBucketData cgiReplyBucketData : cgiReplyBucketDataList) {
+                String ghId = cgiReplyBucketData.getGhId();
                 if (Objects.equals(cgiReplyBucketData.getStrategy(), "manual")) {
-                    String ghId = cgiReplyBucketData.getGhId();
                     GhDetailExample ghDetailExample = new GhDetailExample();
                     ghDetailExample.createCriteria().andGhIdEqualTo(ghId).andTypeEqualTo(GhTypeEnum.THIRD_PARTY_GH.type);
                     List<GhDetail> ghDetails = ghDetailMapper.selectByExample(ghDetailExample);
@@ -101,6 +160,11 @@ public class AutoReplyVideoDataJob {
                     }
                     manualGhIds.add(cgiReplyBucketData.getGhId());
                 }
+                ghIds.add(cgiReplyBucketData.getGhId());
+                if (auditGhIds.contains(ghId)) {
+                    String url = REFRESH_GZH_URL + "?ghId=" + cgiReplyBucketData.getGhId();
+                    String res = httpPoolClient.get(url);
+                }
             }
             String msg = String.format("审核不通过的视频id:%s \n 配置了该视频的ghId列表:%s \n 保底视频更新为策略视频的ghId列表:%s",
                     videoId, ghIds, manualGhIds);