浏览代码

fix 奈飞同步更新装置获取错误

zoujiajian 1 年之前
父节点
当前提交
de2fe9f255

+ 14 - 8
netflix-service/src/main/java/com/cyksj/service/relation/impl/GroupRelationFrontServiceImpl.java

@@ -610,15 +610,16 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
 			if (type == null && linkType == null) {
 				throw BusinessRuntimeException.getInstance("系统异常");
 			}
-			String key = RedisService.key.NF_UPGRAD_USER_LIMIT_KEY.getNameFormat(DateUtil.hour(DateTime.now(), true), linkType, renewalView.getUserId());
-			if (!redisService.hasKey(key)) {
-				redisService.set(key, 1l, RedisService.key.NF_UPGRAD_USER_LIMIT_KEY.getTimeout());
-			} else {
-				Integer value = (Integer) redisService.get(key);
-				if (value >= 5) {
-					throw BusinessRuntimeException.getInstance("获取失败,请联系客服");
+			if (linkType != null) {
+				String key = RedisService.key.NF_UPGRAD_USER_LIMIT_KEY.getNameFormat(DateUtil.hour(DateTime.now(), true), linkType, renewalView.getUserId());
+				if (!redisService.hasKey(key)) {
+					redisService.set(key, 0l, RedisService.key.NF_UPGRAD_USER_LIMIT_KEY.getTimeout());
+				} else {
+					Integer value = (Integer) redisService.get(key);
+					if (value >= 5) {
+						throw BusinessRuntimeException.getInstance("获取奈飞同步更新装置过于频繁");
+					}
 				}
-				redisService.incr(key, 1L);
 			}
 		}
 		String code = commonMailService.getTicketMailCode(renewalView.getGoodsId(), account, renewalView.getRelateEmail(), renewalView.getGptEmailPwd(), renewalView.getCreatedTime(), type, loginReq.getLinkType(), false);
@@ -629,6 +630,11 @@ public class GroupRelationFrontServiceImpl implements GroupRelationFrontService
 		record.setGoodsId(renewalView.getGoodsId());
 		record.setSkuId(renewalView.getSkuId());
 		groupsRelationLoginCodeRecordMapper.insert(record);
+		//奈飞同步装置
+		if (renewalView.getGoodsId() == 1l && loginReq.getLinkType() != null) {
+			String key = RedisService.key.NF_UPGRAD_USER_LIMIT_KEY.getNameFormat(DateUtil.hour(DateTime.now(), true), loginReq.getLinkType(), renewalView.getUserId());
+			redisService.incr(key, 1L);
+		}
 		return code;
 	}