video cover

api-module/src/main/java/com/tzld/piaoquan/api/remote/AigcApiService.java

@@ -191,4 +191,13 @@ public class AigcApiService {
             log.error("closePublishPlan error", e);
         }
     }
+
+    public void refreshGzhAutoReplyMsgData(String ghId) {
+        String url = aigcApiHost + "/publish/api/refreshGzhAutoReplyMsgData?ghId=" + ghId;
+        try {
+            httpPoolClient.get(url);
+        } catch (Exception e) {
+            log.error("refreshGzhAutoReplyMsgData error", e);
+        }
+    }
 }

api-module/src/main/java/com/tzld/piaoquan/api/service/contentplatform/impl/ContentPlatformPlanServiceImpl.java

@@ -21,6 +21,7 @@ import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformCooperateAcc
 import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformPlanService;
 import com.tzld.piaoquan.growth.common.common.enums.GhTypeEnum;
 import com.tzld.piaoquan.growth.common.common.enums.StrategyStatusEnum;
+import com.tzld.piaoquan.growth.common.dao.mapper.ext.CgiReplyBucketDataMapperExt;
 import com.tzld.piaoquan.growth.common.model.bo.VideoDetail;
 import com.tzld.piaoquan.growth.common.model.po.GhDetail;
 import com.tzld.piaoquan.growth.common.service.MessageAttachmentService;
@@ -49,6 +50,8 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
     @Autowired
     private ContentPlatformQwPlanVideoMapper qwPlanVideoMapper;
     @Autowired
+    private CgiReplyBucketDataMapperExt cgiReplyBucketDataMapperExt;
+    @Autowired
     private ContentPlatformCooperateAccountService cooperateAccountService;
     @Autowired
     private GhDetailService ghDetailService;
@@ -135,8 +138,12 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
         // 更新gh_detail
         List<Long> videoIds = param.getVideoList().stream().map(VideoContentItemVO::getVideoId).collect(Collectors.toList());
         updateGhDetail(account, videoIds);
+        // 更新cgi_reply_bucket_data
+        updateCgiReplyBucketData(account.getGhId(), param.getVideoList());
         // 调用aigc创建发布计划
         String externalId = aigcApiService.createPublishPlan(account.getExternalId(), account.getName());
+        // 调用aigc重新拉取视频
+        aigcApiService.refreshGzhAutoReplyMsgData(account.getGhId());
         if (Objects.isNull(param.getId())) {
             gzhPlan.setExternalId(externalId);
             gzhPlan.setCreateAccountId(loginAccount.getId());
@@ -150,6 +157,16 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
         saveGzhPlanVideo(param, videoIds, gzhPlan.getId(), loginAccount.getId());
     }
 
+    private void updateCgiReplyBucketData(String ghId, List<VideoContentItemVO> videoList) {
+        for (VideoContentItemVO video : videoList) {
+            if (video.getTitleIsEdit() == 0 && video.getCoverIsEdit() == 0) {
+                continue;
+            }
+            cgiReplyBucketDataMapperExt.updateBucketDataTitleCoverByGhId(ghId, video.getVideoId(),
+                    video.getTitle(), video.getCover());
+        }
+    }
+
     private void saveGzhPlanVideo(GzhPlanSaveParam param, List<Long> videoIds, Long id, Long loginAccountId) {
         List<ContentPlatformGzhPlanVideo> existsVideo = getGzhVideoByPlanId(id);
         List<Long> existsVideoIds = existsVideo.stream().map(ContentPlatformGzhPlanVideo::getVideoId).collect(Collectors.toList());
@@ -250,7 +267,8 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
             item.setTitle(video.getTitle());
             VideoDetail detail = coverMap.get(video.getVideoId());
             if (Objects.nonNull(detail)) {
-                item.setCover(detail.getCover());
+                String cover = detail.getCover().substring(0, detail.getCover().indexOf("/watermark"));
+                item.setCover(cover);
             }
             item.setVideo(video.getVideo());
             item.setScore(video.getScore());

common-module/src/main/java/com/tzld/piaoquan/growth/common/dao/mapper/ext/CgiReplyBucketDataMapperExt.java

@@ -0,0 +1,13 @@
+package com.tzld.piaoquan.growth.common.dao.mapper.ext;
+
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface CgiReplyBucketDataMapperExt {
+    void updateBucketDataTitleCoverByGhId(@Param("ghId") String ghId,
+                                          @Param("videoId") Long videoId,
+                                          @Param("title") String title,
+                                          @Param("cover") String cover);
+}

common-module/src/main/resources/mapper/ext/CgiReplyBucketDataMapperExt.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.tzld.piaoquan.growth.common.dao.mapper.ext.CgiReplyBucketDataMapperExt">
+
+  <update id="updateBucketDataTitleCoverByGhId">
+      update cgi_reply_bucket_data
+      set title = #{title},
+          cover = #{cover}
+      where gh_id = #{ghId}
+        and mini_video_id = #{videoId}
+        and is_delete = 0
+  </update>
+
+</mapper>