zoujiajian vor 11 Monaten
Ursprung
Commit
3ed191c59e

+ 12 - 11
netflix-service/src/main/java/com/cyksj/service/gzh/factory/EventMsgService.java

@@ -445,19 +445,20 @@ public class EventMsgService implements GzhMsgService {
 						couponCommonService.sendCouponToUser(user.getId(), Constant.DISTRIBUTE_NANO_COUPON_ID, 0l, 0l, dsPopularizeId, CouponUser.Channel.manual);
 					}
 				}
+			}
 
-				if (isNano != null && isNano) {
-					if (redisService.setNx(RedisService.key.NANO_TY_DAY_CARD_KEY.getName() + user.getId(), user.getId(), RedisService.key.NANO_TY_DAY_CARD_KEY.getTimeout())) {
-						Integer receiveRecord = nanoUserTrialReceiveRecordMapper.selectCount(Wrappers.lambdaQuery(NanoUserTrialReceiveRecord.class).eq(NanoUserTrialReceiveRecord::getUserId, user.getId()));
-						if (receiveRecord > 0) {
-							return;
-						}
-						//发送nano 体验卡
-						Long relationId = groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID, 2);
-						recordReceiveNanoRecord(user.getId(), relationId);
-						//创建nano user
-						createNanoUser(user.getId(), relationId, goodsDonSkuMapper.selectById(Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID));
+			//新用户都送体验卡
+			if (isNano != null && isNano) {
+				if (redisService.setNx(RedisService.key.NANO_TY_DAY_CARD_KEY.getName() + user.getId(), user.getId(), RedisService.key.NANO_TY_DAY_CARD_KEY.getTimeout())) {
+					Integer receiveRecord = nanoUserTrialReceiveRecordMapper.selectCount(Wrappers.lambdaQuery(NanoUserTrialReceiveRecord.class).eq(NanoUserTrialReceiveRecord::getUserId, user.getId()));
+					if (receiveRecord > 0) {
+						return;
 					}
+					//发送nano 体验卡
+					Long relationId = groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID, 2);
+					recordReceiveNanoRecord(user.getId(), relationId);
+					//创建nano user
+					createNanoUser(user.getId(), relationId, goodsDonSkuMapper.selectById(Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID));
 				}
 			}
 		}

+ 12 - 11
netflix-service/src/main/java/com/cyksj/service/user/impl/UserServiceImpl.java

@@ -1007,18 +1007,19 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
 					}
 				}
 			}
-			if (isNano != null && isNano) {
-				if (redisService.setNx(RedisService.key.NANO_TY_DAY_CARD_KEY.getName() + user.getId(), user.getId(), RedisService.key.NANO_TY_DAY_CARD_KEY.getTimeout())) {
-					Integer receiveRecord = nanoUserTrialReceiveRecordMapper.selectCount(Wrappers.lambdaQuery(NanoUserTrialReceiveRecord.class).eq(NanoUserTrialReceiveRecord::getUserId, user.getId()));
-					if (receiveRecord > 0) {
-						return;
-					}
-					//发送nano 体验卡
-					Long relationId = groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID, 2);
-					recordReceiveNanoRecord(user.getId(), relationId);
-					//创建nano user
-					createNanoUser(user.getId(), relationId, goodsDonSkuMapper.selectById(Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID));
+		}
+		//新用户都发
+		if (isNano != null && isNano) {
+			if (redisService.setNx(RedisService.key.NANO_TY_DAY_CARD_KEY.getName() + user.getId(), user.getId(), RedisService.key.NANO_TY_DAY_CARD_KEY.getTimeout())) {
+				Integer receiveRecord = nanoUserTrialReceiveRecordMapper.selectCount(Wrappers.lambdaQuery(NanoUserTrialReceiveRecord.class).eq(NanoUserTrialReceiveRecord::getUserId, user.getId()));
+				if (receiveRecord > 0) {
+					return;
 				}
+				//发送nano 体验卡
+				Long relationId = groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID, 2);
+				recordReceiveNanoRecord(user.getId(), relationId);
+				//创建nano user
+				createNanoUser(user.getId(), relationId, goodsDonSkuMapper.selectById(Constant.DISTRIBUTE_NANO_TRIAL_SKU_ID));
 			}
 		}
 	}