zoujiajian 2 gadi atpakaļ
vecāks
revīzija
8f0ce1d596

+ 1 - 0
netflix-service/src/main/java/com/cyksj/redis/RedisService.java

@@ -839,6 +839,7 @@ public class RedisService {
         MIDJOURNEY_USER("midjourney:user:", "midjourney user", 60 * 60 * 2L),
         MIDJOURNEY_ACCOUNT("midjourney:account:", "midjourney account", 60 * 60 * 48L),
         APPLY_MONEY_DAY_LIMIT_KEY("apply_money_day_limit_key:%s:%s:%s", "每日提现次数限制", 60 * 60 * 24L),
+        NETFLIX_UPDATE_LIMIT_TIME("netflix_update_limit_time", "奈飞同步更新", 30l),
         NETFLIX_SET_LIMIT_TIME("netflix_set_limit_time", "奈飞设置限制", 30l),
         MIDJOURNEY_CAR_TASK("midjourney:car:task","midjourney car 任务数", 48 * 60 * 60L),
         SYS_CONFIG_CACHE_KEY("sys_config_cache_key:", "系统配置缓存key", 60 * 60 * 23L),

+ 5 - 0
netflix-service/src/main/java/com/cyksj/service/relation/impl/GroupsRelationNetflixServiceImpl.java

@@ -131,6 +131,10 @@ public class GroupsRelationNetflixServiceImpl implements GroupsRelationNetflixSe
 
 	@Override
 	public Boolean confirmUpdate(String nfUrl) {
+		String key = RedisService.key.NETFLIX_UPDATE_LIMIT_TIME.getName();
+		if (!redisService.setNx(key, 1L, 30L)) {
+			throw BusinessRuntimeException.getInstance("系统繁忙,请稍后点击..");
+		}
 		JSONObject params = new JSONObject();
 		params.putOpt("url", nfUrl);
 		//确认更新点击
@@ -143,6 +147,7 @@ public class GroupsRelationNetflixServiceImpl implements GroupsRelationNetflixSe
 					.setReadTimeout(30000)
 					.execute();
 			JSONObject resp = Jsons.parseObject(execute.body(), JSONObject.class);
+			redisService.del(key);
 			return resp.getBool("success");
 		} catch (Exception e) {
 		}