Merge branch '20250428-wyp-api' of Server/growth-manager into master

api-module/src/main/java/com/tzld/piaoquan/api/common/enums/ExceptionEnum.java

@@ -38,6 +38,12 @@ public enum ExceptionEnum {
     QW_PLAN_NOT_EXISTS(3003, "企微计划不存在"),
     GZH_ACCOUNT_NOT_EXISTS(3004, "公众号不存在"),
     GZH_ACCOUNT_NOT_AUTH(3005, "公众号未授权，无法使用平台发布"),
+
+    // api
+    API_TOKEN_ERROR(4000, "token无效"),
+    API_PAGE_PARAM_ERROR(4001, "请输入正确的分页参数"),
+    API_PAGE_SIZE_TOO_LARGE(4002, "每页获取数量不能超过500条"),
+    API_PAGE_URL_SIZE_TOO_LARGE(4002, "获取视频嵌入路径 每次最多3条"),
     ;
     private int code;
     private String msg;

api-module/src/main/java/com/tzld/piaoquan/api/controller/contentplatform/ContentPlatformApiController.java

@@ -0,0 +1,55 @@
+package com.tzld.piaoquan.api.controller.contentplatform;
+
+import com.tzld.piaoquan.api.annotation.JwtIgnore;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetContentPageParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetTokenParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetVideoPageUrlParam;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoIdTitleVO;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoPageUrlVO;
+import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformApiService;
+import com.tzld.piaoquan.growth.common.common.base.CommonResponse;
+import com.tzld.piaoquan.growth.common.utils.page.Page;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+@RestController
+@RequestMapping("/contentPlatform/api")
+public class ContentPlatformApiController {
+
+    @Autowired
+    ContentPlatformApiService apiService;
+
+    @ApiOperation(value = "获取token")
+    @PostMapping("/getToken")
+    @JwtIgnore
+    public CommonResponse<String> getToken(@RequestBody GetTokenParam param) {
+        return CommonResponse.success(apiService.getToken(param));
+    }
+
+    @ApiOperation(value = "分页获取内容库内容")
+    @PostMapping("/getContent")
+    @JwtIgnore
+    public CommonResponse<Page<VideoIdTitleVO>> getContent(HttpServletRequest request,
+                                                           @RequestBody GetContentPageParam param) {
+        String token = request.getHeader("token");
+        return CommonResponse.success(apiService.getContent(token, param));
+    }
+
+    @ApiOperation(value = "获取视频嵌入路径")
+    @PostMapping("/getVideoPageUrl")
+    @JwtIgnore
+    public CommonResponse<List<VideoPageUrlVO>> getVideoPageUrl(HttpServletRequest request,
+                                                                                      @RequestBody GetVideoPageUrlParam param) {
+        String token = request.getHeader("token");
+        return CommonResponse.success(apiService.getVideoPageUrl(token, param));
+    }
+
+
+}

api-module/src/main/java/com/tzld/piaoquan/api/dao/mapper/contentplatform/ext/ContentPlatformPlanMapperExt.java

@@ -61,5 +61,7 @@ public interface ContentPlatformPlanMapperExt {
 
     void updateVideoAggStatus(@Param("videoId") Long videoId, @Param("now") Long now);
 
-    List<ContentPlatformVideoAgg> getVideoAggList(List<String> dtList);
+    List<ContentPlatformVideoAgg> getVideoAggList(@Param("dtList") List<String> dtList);
+
+    List<ContentPlatformVideo> getVideoListByIds(@Param("videoIds") List<Long> videoIds);
 }

api-module/src/main/java/com/tzld/piaoquan/api/model/param/contentplatform/api/GetContentPageParam.java

@@ -0,0 +1,9 @@
+package com.tzld.piaoquan.api.model.param.contentplatform.api;
+
+import com.tzld.piaoquan.api.model.param.PageParam;
+import lombok.Data;
+
+@Data
+public class GetContentPageParam extends PageParam {
+
+}

api-module/src/main/java/com/tzld/piaoquan/api/model/param/contentplatform/api/GetTokenParam.java

@@ -0,0 +1,14 @@
+package com.tzld.piaoquan.api.model.param.contentplatform.api;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class GetTokenParam {
+
+    @ApiModelProperty(value = "telNum")
+    private String telNum;
+
+    @ApiModelProperty(value = "密码md5")
+    private String password;
+}

api-module/src/main/java/com/tzld/piaoquan/api/model/param/contentplatform/api/GetVideoPageUrlParam.java

@@ -0,0 +1,25 @@
+package com.tzld.piaoquan.api.model.param.contentplatform.api;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class GetVideoPageUrlParam {
+
+    @ApiModelProperty(value = "待嵌入视频列表")
+    private List<PlanItem> planList;
+
+    @Data
+    public static class PlanItem {
+        @ApiModelProperty(value = "id")
+        private String id;
+        @ApiModelProperty(value = "嵌入场景 0-自动回复 1-服务号定期推送")
+        private Integer type;
+        @ApiModelProperty(value = "公众号ghId")
+        private String ghId;
+        @ApiModelProperty(value = "videoIds")
+        private List<Long> videoIds;
+    }
+}

api-module/src/main/java/com/tzld/piaoquan/api/model/vo/contentplatform/api/VideoIdTitleVO.java

@@ -0,0 +1,13 @@
+package com.tzld.piaoquan.api.model.vo.contentplatform.api;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class VideoIdTitleVO {
+
+    @ApiModelProperty(value = "videoId")
+    private Long videoId;
+    @ApiModelProperty(value = "标题")
+    private String title;
+}

api-module/src/main/java/com/tzld/piaoquan/api/model/vo/contentplatform/api/VideoPageUrlVO.java

@@ -0,0 +1,30 @@
+package com.tzld.piaoquan.api.model.vo.contentplatform.api;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class VideoPageUrlVO {
+
+    @ApiModelProperty(value = "id")
+    private String id;
+
+    private int code = 0;
+    private String msg = "success";
+    private List<VideoPageUrlItem> data;
+
+    @Data
+    public static class VideoPageUrlItem {
+
+        @ApiModelProperty(value = "videoId")
+        private Long videoId;
+        @ApiModelProperty(value = "标题")
+        private String title;
+        @ApiModelProperty(value = "封面")
+        private String cover;
+        @ApiModelProperty(value = "嵌入小程序页面路径")
+        private String pageUrl;
+    }
+}

api-module/src/main/java/com/tzld/piaoquan/api/service/CgiReplyService.java

@@ -13,4 +13,5 @@ public interface CgiReplyService {
 
     List<CgiReplyBucketData> getCgiReplyBucketDataListByVideoId(Long videoId);
 
+    List<CgiReplyBucketData> getCgiReplyBucketDataListByGhIdVideoId(String ghId, List<Long> videoIds, String strategy);
 }

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

@@ -11,6 +11,8 @@ import java.util.List;
 public interface ContentPlatformAccountService {
     AccountLoginVO login(AccountLoginParam param);
 
+    ContentPlatformAccount getAccountByTelNum(String telNum);
+
     void sendMessageVerifyCode(AccountSendMessageParam param);
 
     Page<AccountVO> pageAccount(AccountListParam param);

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

@@ -0,0 +1,19 @@
+package com.tzld.piaoquan.api.service.contentplatform;
+
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetContentPageParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetTokenParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetVideoPageUrlParam;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoIdTitleVO;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoPageUrlVO;
+import com.tzld.piaoquan.growth.common.utils.page.Page;
+
+import java.util.List;
+
+public interface ContentPlatformApiService {
+
+    String getToken(GetTokenParam param);
+
+    Page<VideoIdTitleVO> getContent(String token, GetContentPageParam param);
+
+    List<VideoPageUrlVO> getVideoPageUrl(String token, GetVideoPageUrlParam param);
+}

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

@@ -38,4 +38,6 @@ public interface ContentPlatformCooperateAccountService {
     ContentPlatformGzhAccount getGzhAccount(String ghId);
 
     List<ContentPlatformGzhAccount> getAccountListByCreatorId(Long creatorId);
+
+    List<ContentPlatformGzhAccount> getAccountListByGhIds(List<String> ghIds, Long creatorId);
 }

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

@@ -71,4 +71,6 @@ public interface ContentPlatformPlanService {
     void gzhUpdateStagePublishStatus(Long id, Integer stagePublishStatus);
 
     String getGzhChannel(String ghId);
+
+    void saveQwPlanVideo(QwPlanSaveVideoParam videoParam, Long planId, Long loginAccountId);
 }

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

@@ -88,7 +88,8 @@ public class ContentPlatformAccountServiceImpl implements ContentPlatformAccount
         return result;
     }
 
-    private ContentPlatformAccount getAccountByTelNum(String telNum) {
+    @Override
+    public ContentPlatformAccount getAccountByTelNum(String telNum) {
         ContentPlatformAccountExample example = new ContentPlatformAccountExample();
         example.createCriteria().andTelNumEqualTo(telNum);
         List<ContentPlatformAccount> accountList = accountMapper.selectByExample(example);

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

@@ -0,0 +1,188 @@
+package com.tzld.piaoquan.api.service.contentplatform.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.tzld.piaoquan.api.common.enums.ExceptionEnum;
+import com.tzld.piaoquan.api.common.enums.contentplatform.AccountStatusEnum;
+import com.tzld.piaoquan.api.common.enums.contentplatform.PublishStageEnum;
+import com.tzld.piaoquan.api.common.exception.CommonException;
+import com.tzld.piaoquan.api.dao.mapper.contentplatform.ext.ContentPlatformPlanMapperExt;
+import com.tzld.piaoquan.api.model.config.LoginUserContext;
+import com.tzld.piaoquan.api.model.param.contentplatform.GzhPlanSaveParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.GzhPlanVideoContentItemParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.VideoContentListParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetContentPageParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetTokenParam;
+import com.tzld.piaoquan.api.model.param.contentplatform.api.GetVideoPageUrlParam;
+import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformAccount;
+import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformGzhAccount;
+import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformVideo;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoIdTitleVO;
+import com.tzld.piaoquan.api.model.vo.contentplatform.api.VideoPageUrlVO;
+import com.tzld.piaoquan.api.service.CgiReplyService;
+import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformAccountService;
+import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformApiService;
+import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformCooperateAccountService;
+import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformPlanService;
+import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
+import com.tzld.piaoquan.growth.common.utils.RedisUtils;
+import com.tzld.piaoquan.growth.common.utils.page.Page;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+public class ContentPlatformApiServiceImpl implements ContentPlatformApiService {
+
+    @Autowired
+    private ContentPlatformAccountService accountService;
+    @Autowired
+    private ContentPlatformPlanService planService;
+    @Autowired
+    private ContentPlatformPlanMapperExt planMapperExt;
+    @Autowired
+    private ContentPlatformCooperateAccountService gzhAccountService;
+    @Autowired
+    private CgiReplyService cgiReplyService;
+
+    @Autowired
+    private RedisUtils redisUtils;
+
+    @Value("${video.min.score:0.6}")
+    private Double videoMinScore;
+
+    @Override
+    public String getToken(GetTokenParam param) {
+        ContentPlatformAccount account = accountService.getAccountByTelNum(param.getTelNum());
+        if (Objects.isNull(account)) {
+            throw new CommonException(ExceptionEnum.ACCOUNT_NOT_EXISTS_WRONG);
+        }
+        if (account.getStatus() == AccountStatusEnum.FORBIDDEN.getVal()) {
+            throw new CommonException(ExceptionEnum.ACCOUNT_BANNED);
+        }
+        if (!account.getPassword().equals(param.getPassword())) {
+            throw new CommonException(ExceptionEnum.LOGIN_PASSWORD_WRONG);
+        }
+        String token = UUID.randomUUID().toString().replace("-", "");
+        saveTokenToRedis(account, token, 4 * 60 * 60L);
+        return token;
+    }
+
+    private void saveTokenToRedis(ContentPlatformAccount account, String token, Long expireTime) {
+        String tokenPrefix = "api.{token}";
+        String redisKey = tokenPrefix.replace("{token}", token);
+        redisUtils.setValueWithExpire(redisKey, JSON.toJSONString(account), expireTime);
+    }
+
+    @Override
+    public Page<VideoIdTitleVO> getContent(String token, GetContentPageParam param) {
+        checkToken(token);
+        if (Objects.isNull(param.getPageNum()) || Objects.isNull(param.getPageSize())
+                || param.getPageNum() <= 0 || param.getPageSize() <= 0) {
+            throw new CommonException(ExceptionEnum.API_PAGE_PARAM_ERROR);
+        }
+        if (param.getPageSize() > 500) {
+            throw new CommonException(ExceptionEnum.API_PAGE_SIZE_TOO_LARGE);
+        }
+        Page<VideoIdTitleVO> result = new Page<>(param.getPageNum(), param.getPageSize());
+        int offset = (param.getPageNum() - 1) * param.getPageSize();
+        String dt = planMapperExt.getVideoMaxDt();
+        VideoContentListParam listParam = new VideoContentListParam();
+        int count = planMapperExt.getVideoCount(listParam, dt, videoMinScore);
+        result.setTotalSize(count);
+        if (count == 0) {
+            return result;
+        }
+        List<ContentPlatformVideo> videoList = planMapperExt.getVideoList(listParam, dt, videoMinScore, offset, param.getPageSize());
+        List<VideoIdTitleVO> list = videoList.stream().map(video -> {
+            VideoIdTitleVO vo = new VideoIdTitleVO();
+            vo.setVideoId(video.getVideoId());
+            vo.setTitle(video.getTitle());
+            return vo;
+        }).collect(Collectors.toList());
+        result.setObjs(list);
+        return result;
+    }
+
+    private ContentPlatformAccount checkToken(String token) {
+        String tokenPrefix = "api.{token}";
+        String redisKey = tokenPrefix.replace("{token}", token);
+        String value = redisUtils.getString(redisKey);
+        if (StringUtils.isBlank(value)) {
+            throw new CommonException(ExceptionEnum.API_TOKEN_ERROR);
+        }
+        return JSON.parseObject(value, ContentPlatformAccount.class);
+    }
+
+    @Override
+    public List<VideoPageUrlVO> getVideoPageUrl(String token, GetVideoPageUrlParam param) {
+        ContentPlatformAccount account = checkToken(token);
+        if (CollectionUtils.isEmpty(param.getPlanList()) || param.getPlanList().size() > 3) {
+            throw new CommonException(ExceptionEnum.API_PAGE_URL_SIZE_TOO_LARGE);
+        }
+        List<VideoPageUrlVO> result = new ArrayList<>();
+        List<Long> videoIds = param.getPlanList().stream().flatMap(o -> o.getVideoIds().stream()).collect(Collectors.toList());
+        List<ContentPlatformVideo> videoList = planMapperExt.getVideoListByIds(videoIds);
+        Map<Long, ContentPlatformVideo> videoMap = videoList.stream().collect(Collectors.toMap(ContentPlatformVideo::getVideoId, video -> video));
+        List<String> ghIds = param.getPlanList().stream().map(GetVideoPageUrlParam.PlanItem::getGhId).collect(Collectors.toList());
+        List<ContentPlatformGzhAccount> gzhAccountList = gzhAccountService.getAccountListByGhIds(ghIds, account.getId());
+        Map<String, ContentPlatformGzhAccount> gzhAccountMap = gzhAccountList.stream()
+                .collect(Collectors.toMap(ContentPlatformGzhAccount::getGhId, gzhAccount -> gzhAccount));
+        LoginUserContext.setLoginUser(account);
+        for (GetVideoPageUrlParam.PlanItem item : param.getPlanList()) {
+            int code = 0;
+            String msg = "";
+            List<VideoPageUrlVO.VideoPageUrlItem> data = new ArrayList<>();
+            try {
+                GzhPlanSaveParam saveParam = new GzhPlanSaveParam();
+                saveParam.setPublishStage(PublishStageEnum.USER.getVal());
+                ContentPlatformGzhAccount gzhAccount = gzhAccountMap.get(item.getGhId());
+                if (Objects.isNull(gzhAccount)) {
+                    throw new CommonException(ExceptionEnum.GZH_ACCOUNT_NOT_EXISTS);
+                }
+                saveParam.setAccountId(gzhAccount.getId());
+                saveParam.setScene(0);
+                saveParam.setType(item.getType());
+                saveParam.setSelectVideoType(0);
+                List<GzhPlanVideoContentItemParam> videoItemList = new ArrayList<>();
+                for (Long videoId : item.getVideoIds()) {
+                    ContentPlatformVideo video = videoMap.get(videoId);
+                    GzhPlanVideoContentItemParam videoItem = new GzhPlanVideoContentItemParam();
+                    videoItem.setVideoId(video.getVideoId());
+                    videoItem.setTitle(video.getTitle());
+                    videoItem.setCover(video.getCover());
+                    videoItem.setVideo(video.getVideo());
+                    videoItemList.add(videoItem);
+                }
+                saveParam.setVideoList(videoItemList);
+                planService.gzhPlanSave(saveParam);
+                List<CgiReplyBucketData> replyBucketDataList = cgiReplyService.getCgiReplyBucketDataListByGhIdVideoId(
+                        gzhAccount.getGhId(), item.getVideoIds(), "manual");
+                for (CgiReplyBucketData cgiReplyBucketData : replyBucketDataList) {
+                    VideoPageUrlVO.VideoPageUrlItem vo = new VideoPageUrlVO.VideoPageUrlItem();
+                    vo.setVideoId(cgiReplyBucketData.getMiniVideoId());
+                    vo.setTitle(cgiReplyBucketData.getTitle());
+                    vo.setCover(cgiReplyBucketData.getCoverUrl());
+                    vo.setPageUrl(cgiReplyBucketData.getMiniPagePath());
+                    data.add(vo);
+                }
+            } catch (Exception e) {
+                code = -1;
+                msg = e.getMessage();
+            } finally {
+                VideoPageUrlVO response = new VideoPageUrlVO();
+                response.setId(item.getId());
+                response.setCode(code);
+                response.setMsg(msg);
+                response.setData(data);
+                result.add(response);
+            }
+        }
+        LoginUserContext.remove();
+        return result;
+    }
+}

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

@@ -180,6 +180,13 @@ public class ContentPlatformCooperateAccountServiceImpl implements ContentPlatfo
         return gzhAccountMapper.selectByExample(example);
     }
 
+    @Override
+    public List<ContentPlatformGzhAccount> getAccountListByGhIds(List<String> ghIds, Long creatorId) {
+        ContentPlatformGzhAccountExample example = new ContentPlatformGzhAccountExample();
+        example.createCriteria().andGhIdIn(ghIds).andCreateAccountIdEqualTo(creatorId);
+        return gzhAccountMapper.selectByExample(example);
+    }
+
     @Override
     public ContentPlatformGzhAccount getById(Long id) {
         return gzhAccountMapper.selectByPrimaryKey(id);

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

@@ -558,7 +558,8 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
         return buildQwPlanItemVOList(list);
     }
 
-    private void saveQwPlanVideo(QwPlanSaveVideoParam videoParam, Long planId, Long loginAccountId) {
+    @Override
+    public void saveQwPlanVideo(QwPlanSaveVideoParam videoParam, Long planId, Long loginAccountId) {
         ContentPlatformQwPlanVideo item = new ContentPlatformQwPlanVideo();
         item.setPlanId(planId);
         item.setVideoId(videoParam.getVideoId());
@@ -630,6 +631,9 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
                     .collect(Collectors.toMap(ContentPlatformGzhAccount::getGhId, Function.identity()));
             for (GhDetail ghDetail : ghDetailList) {
                 ContentPlatformGzhAccount gzhAccount = gzhAccountMap.get(ghDetail.getGhId());
+                if (Objects.isNull(gzhAccount)) {
+                    continue;
+                }
                 ContentPlatformGzhPlan gzhPlan = new ContentPlatformGzhPlan();
                 if (existsAccountIds.contains(gzhAccount.getId())) {
                     continue;
@@ -656,6 +660,9 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
                     continue;
                 }
                 List<Long> videoIds = JSONObject.parseArray(ghDetail.getVideoIds(), Long.class);
+                if (CollectionUtils.isEmpty(videoIds)) {
+                    continue;
+                }
                 Map<Long, VideoDetail> videoMap = messageAttachmentService.getVideoDetail(new HashSet<>(videoIds));
                 for (Map.Entry<Long, VideoDetail> entry : videoMap.entrySet()) {
                     Long videoId = entry.getKey();

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

@@ -106,4 +106,12 @@ public class CgiReplyServiceImpl implements CgiReplyService {
         example.createCriteria().andMiniVideoIdEqualTo(videoId).andIsDeleteEqualTo(0);
         return cgiReplyBucketDataMapper.selectByExample(example);
     }
+
+    @Override
+    public List<CgiReplyBucketData> getCgiReplyBucketDataListByGhIdVideoId(String ghId, List<Long> videoIds, String strategy) {
+        CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
+        example.createCriteria().andGhIdEqualTo(ghId).andMiniVideoIdIn(videoIds)
+                .andStrategyEqualTo(strategy).andIsDeleteEqualTo(0);
+        return cgiReplyBucketDataMapper.selectByExample(example);
+    }
 }

api-module/src/main/resources/mapper/contentplatform/ext/ContentPlatformPlanMapperExt.xml

@@ -237,4 +237,20 @@
         where video_id = #{videoId}
     </update>
 
+    <select id="getVideoListByIds"
+            resultType="com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformVideo">
+        SELECT t1.*
+        FROM content_platform_video t1
+        INNER JOIN (
+        SELECT video_id, MAX(dt) AS max_dt
+        FROM content_platform_video
+        WHERE video_id IN
+        <foreach collection="videoIds" item="item" open="(" close=")" separator=",">
+            #{item}
+        </foreach>
+        GROUP BY video_id
+        ) t2 ON t1.video_id = t2.video_id AND t1.dt = t2.max_dt
+        ORDER BY t1.dt DESC
+    </select>
+
 </mapper>