根据rootSourceId获取视频特征

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

@@ -131,7 +131,7 @@ public class CgiReplyServiceImpl implements CgiReplyService {
     @Override
     public List<CgiReplyBucketData> getCgiReplyBucketDataListByRootSourceId(String rootSourceId) {
         CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
-        example.createCriteria().andRootSourceIdEqualTo(rootSourceId).andIsDeleteEqualTo(0);
+        example.createCriteria().andRootSourceIdEqualTo(rootSourceId);
         return cgiReplyBucketDataMapper.selectByExample(example);
     }
 
@@ -142,8 +142,14 @@ public class CgiReplyServiceImpl implements CgiReplyService {
         if (StringUtils.isNotEmpty(value)) {
             return JSONObject.parseObject(value, VideoCharacteristicVO.class);
         }
+        String blackListKey = "auto_reply_video_detail_black_list_" + rootSourceId;
+        String blackListValue = redisUtils.get(blackListKey);
+        if (StringUtils.isNotEmpty(blackListValue)) {
+            throw new CommonException(ExceptionEnum.CGI_REPLY_BUCKET_DATA_NOT_FOUND);
+        }
         List<CgiReplyBucketData> list = getCgiReplyBucketDataListByRootSourceId(rootSourceId);
         if (CollectionUtils.isEmpty(list)) {
+            redisUtils.set(blackListKey, "1", 60 * 60);
             throw new CommonException(ExceptionEnum.CGI_REPLY_BUCKET_DATA_NOT_FOUND);
         }
         list.sort(Comparator.comparing(CgiReplyBucketData::getCreateTime).reversed());

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

@@ -7,6 +7,7 @@ import com.tzld.piaoquan.api.common.enums.ReplyStrategyServiceEnum;
 import com.tzld.piaoquan.api.component.TouLiuHttpClient;
 import com.tzld.piaoquan.api.dao.mapper.AlgGhAutoreplyVideoRankDataMapper;
 import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformGzhPlanVideo;
+import com.tzld.piaoquan.api.model.vo.VideoCharacteristicVO;
 import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformPlanService;
 import com.tzld.piaoquan.growth.common.common.enums.StrategyStatusEnum;
 import com.tzld.piaoquan.growth.common.dao.mapper.CgiReplyBucketDataMapper;
@@ -18,6 +19,7 @@ import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
 import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketDataExample;
 import com.tzld.piaoquan.api.service.strategy.ReplyStrategyService;
 import com.tzld.piaoquan.growth.common.utils.MessageUtil;
+import com.tzld.piaoquan.growth.common.utils.RedisUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -76,6 +78,9 @@ public class BuckStrategyV1 implements ReplyStrategyService {
     @Autowired
     private ContentPlatformPlanService contentPlatformPlanService;
 
+    @Autowired
+    private RedisUtils redisUtils;
+
     @Override
     public ReplyBucketData getResult(BucketDataParam bucketDataParam) {
         // 0 获取策略key
@@ -256,6 +261,14 @@ public class BuckStrategyV1 implements ReplyStrategyService {
             // 入库
             for (CgiReplyBucketData cgiReplyBucketData : collect) {
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
+                String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
+                VideoCharacteristicVO vo = new VideoCharacteristicVO();
+                vo.setGhId(cgiReplyBucketData.getGhId());
+                vo.setName(bucketDataParam.getAccountName());
+                vo.setVideoId(cgiReplyBucketData.getMiniVideoId());
+                vo.setTitle(cgiReplyBucketData.getTitle());
+                vo.setCover(cgiReplyBucketData.getCoverUrl());
+                redisUtils.set(redisKey, JSONObject.toJSONString(vo), 3L * 24 * 60 * 60);
             }
         }
     }

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

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 
 import com.tzld.piaoquan.api.common.enums.ReplyStrategyServiceEnum;
 import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformGzhPlanVideo;
+import com.tzld.piaoquan.api.model.vo.VideoCharacteristicVO;
 import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformPlanService;
 import com.tzld.piaoquan.growth.common.common.enums.StrategyStatusEnum;
 import com.tzld.piaoquan.api.component.TouLiuHttpClient;
@@ -17,6 +18,7 @@ import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
 import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketDataExample;
 import com.tzld.piaoquan.api.service.strategy.ReplyStrategyService;
 import com.tzld.piaoquan.growth.common.utils.MessageUtil;
+import com.tzld.piaoquan.growth.common.utils.RedisUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -66,6 +68,9 @@ public class ThirdPartyPushMessageStrategyV1 implements ReplyStrategyService {
     @Autowired
     private ContentPlatformPlanService contentPlatformPlanService;
 
+    @Autowired
+    private RedisUtils redisUtils;
+
     @Override
     public ReplyBucketData getResult(BucketDataParam bucketDataParam) {
         log.info("ThirdPartyPushMessageStrategyV1 start");
@@ -161,6 +166,14 @@ public class ThirdPartyPushMessageStrategyV1 implements ReplyStrategyService {
             // 入库
             for (CgiReplyBucketData cgiReplyBucketData : collect) {
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
+                String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
+                VideoCharacteristicVO vo = new VideoCharacteristicVO();
+                vo.setGhId(cgiReplyBucketData.getGhId());
+                vo.setName(bucketDataParam.getAccountName());
+                vo.setVideoId(cgiReplyBucketData.getMiniVideoId());
+                vo.setTitle(cgiReplyBucketData.getTitle());
+                vo.setCover(cgiReplyBucketData.getCoverUrl());
+                redisUtils.set(redisKey, JSONObject.toJSONString(vo), 3L * 24 * 60 * 60);
             }
         }
     }

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

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.tzld.piaoquan.api.common.enums.ReplyStrategyServiceEnum;
 import com.tzld.piaoquan.api.component.TouLiuHttpClient;
 import com.tzld.piaoquan.api.dao.mapper.AlgGhAutoreplyVideoRankDataMapper;
+import com.tzld.piaoquan.api.model.vo.VideoCharacteristicVO;
 import com.tzld.piaoquan.growth.common.common.enums.StrategyStatusEnum;
 import com.tzld.piaoquan.growth.common.dao.mapper.CgiReplyBucketDataMapper;
 import com.tzld.piaoquan.api.model.bo.*;
@@ -14,6 +15,7 @@ import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
 import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketDataExample;
 import com.tzld.piaoquan.api.service.strategy.ReplyStrategyService;
 import com.tzld.piaoquan.growth.common.utils.MessageUtil;
+import com.tzld.piaoquan.growth.common.utils.RedisUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -60,6 +62,9 @@ public class WeComPushMessageStrategyV1 implements ReplyStrategyService {
     @Autowired
     private TouLiuHttpClient touLiuHttpClient;
 
+    @Autowired
+    private RedisUtils redisUtils;
+
     @Override
     public ReplyBucketData getResult(BucketDataParam bucketDataParam) {
         log.info("ThirdPartyPushMessageStrategyV1 start");
@@ -155,6 +160,14 @@ public class WeComPushMessageStrategyV1 implements ReplyStrategyService {
             // 入库
             for (CgiReplyBucketData cgiReplyBucketData : collect) {
                 cgiReplyBucketDataMapper.insertSelective(cgiReplyBucketData);
+                String redisKey = "auto_reply_video_detail_" + cgiReplyBucketData.getRootSourceId();
+                VideoCharacteristicVO vo = new VideoCharacteristicVO();
+                vo.setGhId(cgiReplyBucketData.getGhId());
+                vo.setName(bucketDataParam.getAccountName());
+                vo.setVideoId(cgiReplyBucketData.getMiniVideoId());
+                vo.setTitle(cgiReplyBucketData.getTitle());
+                vo.setCover(cgiReplyBucketData.getCoverUrl());
+                redisUtils.set(redisKey, JSONObject.toJSONString(vo), 3L * 24 * 60 * 60);
             }
         }
     }