新增根据rootSourceId检查数据存在接口

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

@@ -35,4 +35,9 @@ public class CgiReplyController {
     public CommonResponse<VideoCharacteristicVO> getVideoCharacteristicByRootSourceId(@RequestParam String rootSourceId) {
         return CommonResponse.success(cgiReplyService.getVideoCharacteristicByRootSourceId(rootSourceId));
     }
+
+    @GetMapping("/checkExistRootSourceId")
+    public CommonResponse<Boolean> checkExistRootSourceId(@RequestParam String rootSourceId) {
+        return CommonResponse.success(cgiReplyService.checkExistRootSourceId(rootSourceId));
+    }
 }

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

@@ -25,4 +25,6 @@ public interface CgiReplyService {
     VideoCharacteristicVO getVideoCharacteristicByRootSourceId(String rootSourceId);
 
     MsgData bucketDataGenerate(bucketDataGenerateParam param);
+
+    Boolean checkExistRootSourceId(String rootSourceId);
 }

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

@@ -276,4 +276,18 @@ public class CgiReplyServiceImpl implements CgiReplyService {
         return coverUrl + coverSuffix;
     }
 
+    @Override
+    public Boolean checkExistRootSourceId(String rootSourceId) {
+        String redisKey = "check_exist_root_source_id_" + rootSourceId;
+        String value = redisUtils.get(redisKey);
+        if (StringUtils.isNotEmpty(value)) {
+            return Boolean.parseBoolean(value);
+        }
+        List<CgiReplyBucketData> list = getCgiReplyBucketDataListByRootSourceId(rootSourceId);
+        boolean exists = !CollectionUtils.isEmpty(list);
+        // 缓存1小时
+        redisUtils.set(redisKey, String.valueOf(exists), 60 * 60);
+        return exists;
+    }
+
 }