修改：活动视频、直播数据详情数据接口

src/main/java/com/afanticar/afantiopenapi/controller/FawOpenController.java

@@ -145,7 +145,7 @@ public class FawOpenController extends BaseController {
     @ApiOperation(value = "抖音活动视频数据信息", notes = "抖音活动视频数据", produces = "application/json")
     @PostMapping("/activity/douyin/aweme/list")
     public BaseResponse<BasePageVO<HongqiActivityAwemeVO>> getDouyinActivityAwemeData(@RequestBody @Validated FawActivityDTO dto) {
-        BaseResponse check = baseService.baseLimit(dataType, limit, limitPeriod);
+        BaseResponse check = baseService.pageApiLimit(dataType, limit, limitPeriod);
         if (check != null) {
             return check;
         }
@@ -159,7 +159,7 @@ public class FawOpenController extends BaseController {
     @ApiOperation(value = "抖音活动直播数据信息", notes = "抖音活动直播数据", produces = "application/json")
     @PostMapping("/activity/douyin/live/list")
     public BaseResponse<BasePageVO<HongqiActivityLiveVO>> getDouyinActivityLiveData(@RequestBody @Validated FawActivityDTO dto) {
-        BaseResponse check = baseService.baseLimit(dataType, limit, limitPeriod);
+        BaseResponse check = baseService.pageApiLimit(dataType, limit, limitPeriod);
         if (check != null) {
             return check;
         }
@@ -173,7 +173,7 @@ public class FawOpenController extends BaseController {
     @ApiOperation(value = "快手活动视频数据信息", notes = "快手活动视频数据", produces = "application/json")
     @PostMapping("/activity/kuaishou/aweme/list")
     public BaseResponse<BasePageVO<HongqiActivityAwemeVO>> getKuaishouActivityAwemeData(@RequestBody @Validated FawActivityDTO dto) {
-        BaseResponse check = baseService.baseLimit(dataType, limit, limitPeriod);
+        BaseResponse check = baseService.pageApiLimit(dataType, limit, limitPeriod);
         if (check != null) {
             return check;
         }
@@ -187,7 +187,7 @@ public class FawOpenController extends BaseController {
     @ApiOperation(value = "快手活动直播数据信息", notes = "快手活动直播数据", produces = "application/json")
     @PostMapping("/activity/kuaishou/live/list")
     public BaseResponse<BasePageVO<HongqiActivityLiveVO>> getKuaishouActivityLiveData(@RequestBody @Validated FawActivityDTO dto) {
-        BaseResponse check = baseService.baseLimit(dataType, limit, limitPeriod);
+        BaseResponse check = baseService.pageApiLimit(dataType, limit, limitPeriod);
         if (check != null) {
             return check;
         }

src/main/java/com/afanticar/afantiopenapi/service/BaseService.java

@@ -42,11 +42,26 @@ public class BaseService {
         String header = "token";
         String fawKey = String.format("%s:%s:limit", dataType, header);
         RRateLimiter rateLimiter = redissonClient.getRateLimiter(fawKey);
-        rateLimiter.trySetRate(RateType.OVERALL, limit,limitPeriod, RateIntervalUnit.SECONDS);
+        rateLimiter.trySetRate(RateType.OVERALL, limit, limitPeriod, RateIntervalUnit.SECONDS);
         if (!rateLimiter.tryAcquire(1, waiting, TimeUnit.MILLISECONDS)) {
             return BaseController.error("10010", "您的请求太过频繁，请稍后再试！");
         }
         return null;
     }
 
+    public BaseResponse pageApiLimit(String dataType, Integer limit, Integer limitPeriod) {
+        try {
+            Thread.sleep(5000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+//        String header = "token";
+//        String fawKey = String.format("%s:%s:limit", dataType, header);
+//        RRateLimiter rateLimiter = redissonClient.getRateLimiter(fawKey);
+//        rateLimiter.trySetRate(RateType.OVERALL, limit, limitPeriod, RateIntervalUnit.SECONDS);
+//        if (!rateLimiter.tryAcquire(1, waiting, TimeUnit.MILLISECONDS)) {
+//            return BaseController.error("10010", "您的请求太过频繁，请稍后再试！");
+//        }
+        return null;
+    }
 }