yhlxj/netflix-service/src/main/java/com/cyksj/service/user/impl/UserServiceImpl.java

package com.cyksj.service.user.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.task.GlobalThreadPoolTaskExecutor;
import com.cyksj.common.util.Codec;
import com.cyksj.common.util.Jsons;
import com.cyksj.common.util.StringUtil;
import com.cyksj.config.wxlogin.WxOpenPlatYHLXLoginConfig;
import com.cyksj.dto.UserSharedDto;
import com.cyksj.mapper.*;
import com.cyksj.mapper.channel.ChannelPopularizeMapper;
import com.cyksj.mapper.claudecode.ClaudeCodeUserPopularizeTrialTicketRecordMapper;
import com.cyksj.mapper.corp.*;
import com.cyksj.mapper.manage.coupon.CouponDistributePopularizeMapper;
import com.cyksj.mapper.manage.coupon.CouponRecommendMapper;
import com.cyksj.mapper.manage.cps.UserDistributePopularizeMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeSharedMapper;
import com.cyksj.mapper.market.task.UserBindDetailMapper;
import com.cyksj.mapper.mirrorshop.UserMirrorShopMapper;
import com.cyksj.mapper.station.CollegeStudentStationUserRelateMapper;
import com.cyksj.mapper.vip.VipUserMapper;
import com.cyksj.model.dto.*;
import com.cyksj.model.entity.*;
import com.cyksj.model.manage.views.GroupsRelationView;
import com.cyksj.model.request.LoginReq;
import com.cyksj.model.views.*;
import com.cyksj.redis.RedisService;
import com.cyksj.service.claude.ClaudeCodeService;
import com.cyksj.service.distribute.DistributeService;
import com.cyksj.service.distribute.equipment.EquipmentDistributeService;
import com.cyksj.service.exchange.ExchangeCodeService;
import com.cyksj.service.mange.coupon.CouponCommonService;
import com.cyksj.service.market.task.BindTaskService;
import com.cyksj.service.relation.GroupRelationFrontService;
import com.cyksj.service.shop.YhShopDistributeService;
import com.cyksj.service.sys.SysConfigService;
import com.cyksj.service.user.*;
import com.cyksj.service.wechat.WeChatService;
import com.ejlchina.searcher.BeanSearcher;
import com.ejlchina.searcher.param.Operator;
import com.ejlchina.searcher.util.MapUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;

/**
 * @author chan
 * @date 2021/10/10 下午3:27
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
    private final DistributeService distributeService;

    private final EquipmentDistributeService equipDistributeService;

	private final ChannelPopularizeMapper channelPopularizeMapper;

	private final CouponCommonService couponCommonService;

	private final RedisService redisService;

	private final SysConfigService sysConfigService;

	private final UserBindDetailMapper userBindDetailMapper;

	private final UserDistributePopularizeMapper distributePopularizeMapper;

	private final UserMapper userMapper;

	private final PhoneCodeMapper phoneCodeMapper;

	private final WeChatService weChatService;

	private final BindTaskService bindTaskService;

	private final WxOpenPlatYHLXLoginConfig wxOpenPlatYHLXLoginConfig;

	private final GiftCardUserRecordMapper giftCardUserRecordMapper;

	private final ExchangeCodeService exchangeCodeService;

	private final GoodsDonSkuMapper goodsDonSkuMapper;

	private final GroupsRelationMapper groupsRelationMapper;

	private final BeanSearcher beanSearcher;

	private final UserBindRelationService userBindRelationService;

	private final YhShopDistributeService yhShopDistributeService;

	private final CorpUserMapper corpUserMapper;

	private final CorpUserTagMapper corpUserTagMapper;

	private final CorpFollowActiveCodeMapper corpFollowActiveCodeMapper;

	private final CorpCustomerAcquisitionLinkMapper corpCustomerAcquisitionLinkMapper;

	private final CorpWelcomeTemplateMapper corpWelcomeTemplateMapper;

	private final UserLoginRecordService userLoginRecordService;

	private final UserDistributeSharedMapper userDistributeSharedMapper;

	private final BadIntentionOpService badIntentionOpService;

	private final CollegeStudentStationUserRelateMapper collegeStudentStationUserRelateMapper;

	private final GroupRelationFrontService groupRelationFrontService;

	private final UserMirrorShopMapper userMirrorShopMapper;

	private final UserCertRecordMapper userCertRecordMapper;

	private final UserStudentCertRecordMapper userStudentCertRecordMapper;

	private final OrderDonMapper orderDonMapper;

	private final UserCommonService userCommonService;

	private final VipUserMapper vipUserMapper;

	private final CouponDistributePopularizeMapper couponDistributePopularizeMapper;

	private final UserDistributeMapper userDistributeMapper;

	private final ClaudeCodeService claudeCodeService;

	private final ClaudeCodeUserPopularizeTrialTicketRecordMapper claudeCodeUserPopularizeTrialTicketRecordMapper;

	private final CouponRecommendMapper couponRecommendMapper;

	private static final GlobalThreadPoolTaskExecutor TASK_POOL = GlobalThreadPoolTaskExecutor.getInstance();

	@Override
	public User saveAuth(GzhOAuth2UserInfo info, AuthRedirect re, User.RegisterEnv registerEnv) throws Exception {
		Long sharedId = re.getSharedId();
		Integer dsType = re.getDsType();
		Long pid = re.getPid();
		String dsCode = re.getDsCode();
		String callback = re.getCk();
		String callbackType = re.getCt();
		String customId = re.getCd();

		final String unionid = info.getUnionid();
		if (StrUtil.isEmpty(unionid)) {
			throw BusinessRuntimeException.getInstance("授权操作异常,请刷新页面");
		}

		User user = getSyncUser(info.getOpenid(), info.getUnionid(), null);

		user = Optional.ofNullable(user).orElseGet(() -> new User()
				.setUnionid(unionid));
		user.setCountry(info.getCountry())
				.setProvince(info.getProvince())
				.setCity(info.getCity());
		if (user.getSex() == null) {
			user.setSex(info.getSex());
		}
		if (StrUtil.isEmpty(user.getHeadimgurl())) {
			user.setHeadimgurl(info.getHeadimgurl());
		}
		if (StrUtil.isEmpty(user.getNickname())) {
			user.setNickname(info.getNickname());
		}
		user.setUnionid(unionid);
		user.setOpenId(info.getOpenid());
		Boolean isNewUser = false;
		if (user.getId() == null) {
			isNewUser = true;
			user.setPopularizeId(pid);
			user.setRegisterEnv(registerEnv.name());
			if (!redisService.setNx(RedisService.key.REPEAT_USER_KEY.getNameFormat(user.getUnionid()), user.getUnionid(), RedisService.key.REPEAT_USER_KEY.getTimeout())) {
				return this.getOne(Wrappers.lambdaQuery(User.class)
						.eq(User::getUnionid, unionid).last("limit 1"));
			}
			this.save(user);
			//缓存用户注册 回传信息
			if (StrUtil.isNotBlank(callback)) {
				OrderDonPostDataDto orderDonPostDataDto = new OrderDonPostDataDto().setCallback(callback)
						.setCallbackType(callbackType);
				redisService.set(RedisService.key.ORDER_DON_POST_DATA_USER_KEY.getName() + user.getId(), Jsons.toJson(orderDonPostDataDto));
			}
			//发放新用户福利
			final Long fUid = user.getId();
			TASK_POOL.execute(() -> {
//				try {
//					sendNewUserWelfare(fUid);
//				} catch (Exception e) {
//				}
				//去关联对应企业微信用户
				relateCorpUserAndSengWelfare(fUid, unionid);
			});
		} else {
			if (StrUtil.isEmpty(user.getRegisterEnv())) {
				user.setRegisterEnv(registerEnv.name());
			}
			this.updateById(user);
		}
		Long dsPopularizeId = null;
		if (StrUtil.isNotBlank(dsCode)) {
			UserSharedDto userSharedDto = getUserShredDtoByDsCode(dsCode);
			sharedId = userSharedDto.getSharedId();
			dsPopularizeId = userSharedDto.getDsPopularizeId();
		}
		if (sharedId != null && isNewUser) {
			if (dsType == null || dsType == 1) {
				distributeService.saveDistributionInvitation(sharedId, user.getId(), dsPopularizeId);
			}
		}
		//店铺注册用户 关联
		if (isNewUser && StrUtil.isNotBlank(customId)) {
			yhShopDistributeService.saveDistributionInvitation(customId, user.getId(), re.getCmt());
		}
		Long userId = user.getId();
		if (isNewUser && pid != null) {
			TASK_POOL.execute(() -> {
				sendFixedCustomerCoupon(pid, userId, unionid);
			});
		}
		//新旧用户都可实物分销
		if (sharedId != null && dsType != null && dsType == 2) {
			equipDistributeService.saveDistributionInvitation(sharedId, isNewUser, user.getId());
		}
		//查找渠道是否有设置了对应的claude code优惠码
		setClaudeCodePopularize(sharedId, dsPopularizeId, user);
		//每日活跃记录
		userLoginRecordService.saveUserLoginDayRecord(user.getId());
		//是否是大学生快递站进来的用户
		Integer cst = re.getCst();
		if (cst != null) {
			TASK_POOL.execute(() -> {
				handlerCollegeStudentUser(userId, cst);
			});
		}
		return user;
	}

	@Override
	public UserWhoami whoami(long userId, Boolean ccCode) {
		User user = this.getById(userId);
		Assert.notNull(user, "业务处理失败,请联系客服");
		UserWhoami userWhoami = new UserWhoami();
		if (StrUtil.isEmpty(user.getShowId())) {
			user.setShowId(userCommonService.getUserShowId(userId));
		}
		BeanUtil.copyProperties(user, userWhoami);

		UserBindDetail bindPhone = userBindDetailMapper.selectOne(Wrappers.lambdaQuery(UserBindDetail.class)
				.eq(StrUtil.isNotEmpty(user.getUnionid()), UserBindDetail::getUserId, userId)
				.eq(StrUtil.isNotBlank(user.getLoginPhone()), UserBindDetail::getPhoneUserId, userId)
				.eq(StrUtil.isNotEmpty(user.getEmail()), UserBindDetail::getEmailUserId, userId).last("limit 1"));
		//手机号
		if (bindPhone != null) {
			userWhoami.setBindPhone(bindPhone.getPhone());
			userWhoami.setBindEmail(bindPhone.getEmail());
		}
		Integer type = 3;
		if (StrUtil.isNotBlank(user.getLoginPhone())) {
			type = 1;
		} else if (StrUtil.isNotBlank(user.getEmail())) {
			type = 2;
		}
		userWhoami.setType(type);
		//是否加过企业微信
		String unionId = user.getUnionid();
		if (StrUtil.isEmpty(unionId)) {
			//获取绑定的微信用户id
			UserBindDetail bindDetail = userBindDetailMapper.selectOne(Wrappers.lambdaQuery(UserBindDetail.class)
					.and(qr -> qr.eq(UserBindDetail::getPhoneUserId, user.getId()).or().eq(UserBindDetail::getEmailUserId, user.getId()))
					.last("limit 1"));
			if (bindDetail != null && bindDetail.getUserId() != null) {
				User wxUser = userMapper.selectById(bindDetail.getUserId());
				if (wxUser != null) {
					unionId = wxUser.getUnionid();
				}
			}
		}
		if (StrUtil.isNotBlank(unionId)) {
			CorpUserFollowView corpUserFollowView = beanSearcher.searchFirst(CorpUserFollowView.class, MapUtils.builder()
					.field(CorpUserFollowView::getUnionId, unionId)
					.field(CorpUserFollowView::getStatus, 1).build());
			if (corpUserFollowView != null) {
				userWhoami.setIsJoinWx(true);
			}
		}
		//是否下过单
		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, user);
		Integer selectCount = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
				.in(OrderDon::getUserId, userIdList)
				.notIn(OrderDon::getStatus, Constant.noOrderStatus));
		userWhoami.setIsPay(selectCount > 0);
		if (ccCode != null) {
			Number number = beanSearcher.searchCount(GroupsRelationView.class, MapUtils.builder().field(GroupsRelationView::getUserId, userIdList).op(Operator.InList).field(GroupsRelationView::getSkuId, Constant.DISTRIBUTE_CLAUDE_CODE_TRIAL_SKU_ID).field(GroupsRelationView::getGoodsId, Constant.CLAUDE_CODE_GOODS_ID).build());
			userWhoami.setCcCode(number.intValue() > 0);
			Integer selectCount1 = claudeCodeUserPopularizeTrialTicketRecordMapper.selectCount(Wrappers.lambdaQuery(ClaudeCodeUserPopularizeTrialTicketRecord.class).in(ClaudeCodeUserPopularizeTrialTicketRecord::getUserId, userIdList));
			if (selectCount1 == 0) {
				ClaudeCodeUserPopularizeTrialTicketRecord record = new ClaudeCodeUserPopularizeTrialTicketRecord();
				record.setUserId(userId);
				claudeCodeUserPopularizeTrialTicketRecordMapper.insert(record);
			}
			userWhoami.setTc(selectCount1 == 0);
		}
		return userWhoami;
	}

    @Override
    public User getSyncUser(String openId, String unionId, WxSyncLog wxSyncLog) {
        User user;
        //迁移公众号之后同步授权后信息
        //是否是迁移用户
        if (wxSyncLog != null) {
            user = this.getOne(Wrappers.lambdaQuery(User.class)
                    .ne(User::getUnionid, unionId)
                    .eq(User::getOpenId, wxSyncLog.getOriOpenid()).last("limit 1"));
            if (user != null) {
                user.setOpenId(wxSyncLog.getNewOpenid());
            } else {
                // 查询用户是否存在
                user = Optional.ofNullable(
                        this.getOne(new LambdaQueryWrapper<User>().eq(User::getUnionid, unionId)
                                .orderByAsc(User::getId)
                                .last("limit 1")))
                        .orElseGet(() -> this.getOne(new LambdaQueryWrapper<User>().eq(User::getOpenId, openId)
                                .orderByAsc(User::getId)
                                .last("limit 1")));
            }
        } else {
            // 查询用户是否存在
            user = Optional.ofNullable(
                    this.getOne(new LambdaQueryWrapper<User>().eq(User::getUnionid, unionId)
                            .orderByAsc(User::getId)
                            .last("limit 1")))
                    .orElseGet(() -> this.getOne(new LambdaQueryWrapper<User>().eq(User::getOpenId, openId)
                            .orderByAsc(User::getId)
                            .last("limit 1")));
        }
        return user;
    }

	@Override
	public void sendFixedCustomerCoupon(Long popularizeId, Long userId, String unionId) {
		//若是百度渠道 添加固定客服 注册后直接发放优惠券
		ChannelPopularize channelPopularize = channelPopularizeMapper.selectById(popularizeId);
		if (channelPopularize != null && channelPopularize.getChannelId() == 34) {
//			SysConfig corpConfig = sysConfigService.getOne(Wrappers.lambdaQuery(SysConfig.class)
//					.eq(SysConfig::getSysKey, Constant.CORP_FIXED_CUSTOMER)
//					.last("limit 1"));
//			if (corpConfig != null) {
//				Optional.ofNullable(corpConfig.getSysValue()).ifPresent(value -> {
//					try {
//						if (StrUtil.isNotBlank(value)) {
//							List<String> followIds = Jsons.parseList(value, String.class);
//							//添加固定客服发放优惠券
//							CorpUserFollowView corpUserFollowView = beanSearcher.searchFirst(CorpUserFollowView.class, MapUtils.builder()
//									.field(CorpUserFollowView::getUnionId, unionId)
//									.field(CorpUserFollowView::getFollowId, followIds).op(Operator.InList).build());
//							if (corpUserFollowView != null) {
//								Constant.FIXED_CUSTOMER_COUPON_IDS.forEach(couponId -> couponCommonService.sendCouponToUser(userId, couponId, 0l, 0l, 0l, CouponUser.Channel.wxCorp));
//							}
//						}
//					} catch (Exception e) {
//					}
//				});
//
//			}
			SysConfig config = sysConfigService.getOne(Wrappers.lambdaQuery(SysConfig.class)
					.eq(SysConfig::getSysKey, Constant.BAIDU_POPULARIZE_COUPON_IDS).last("limit 1"));
			if (config != null) {
				String sysValue = config.getSysValue();
				if (StrUtil.isNotBlank(sysValue)) {
					try {
						List<Long> couponIds = Jsons.parseList(sysValue, Long.class);
						couponIds.forEach(couponId -> couponCommonService.sendCouponToUser(userId, couponId, 0l, 0l, popularizeId, CouponUser.Channel.manual));
					} catch (Exception e) {
						log.error("百度渠道优惠券解析错误");
					}
				}
			}
		}
	}


	@Override
	public List<Long> getRelationUserIdList(Long userId, User selectUser) {
		List<Long> userIds = new ArrayList<>();
		userIds.add(userId);
		UserBindDetail userBindDetail = userBindDetailMapper.selectOne(Wrappers.lambdaQuery(UserBindDetail.class)
				.eq(UserBindDetail::getUserId, userId).last("limit 1"));
		if (userBindDetail == null) {
			User user = Optional.ofNullable(selectUser).orElse(this.getById(userId));
			if (StrUtil.isEmpty(user.getOpenId()) && StrUtil.isNotEmpty(user.getLoginPhone())) {
				userBindDetail = userBindDetailMapper.selectOne(Wrappers.lambdaQuery(UserBindDetail.class)
						.eq(UserBindDetail::getPhone, user.getLoginPhone()).last("limit 1"));
				if (userBindDetail != null) {
					userIds.add(userBindDetail.getUserId());
				}
			}
		} else {
			if (StrUtil.isNotBlank(userBindDetail.getPhone())) {
				User otherUser = this.getOne(Wrappers.lambdaQuery(User.class)
						.eq(User::getLoginPhone, userBindDetail.getPhone()).last("limit 1"));
				if (otherUser != null) {
					userIds.add(otherUser.getId());
				}
			}
		}
		return userIds;
	}

	@Override
	public List<Long> getUserIdsByNickname(String nickname) {
		return userMapper.selectListByNickname(nickname);
	}

	@Override
	public String getUserMirrorShopId(Long userId) {
		Integer update = 0;
		String showId = null;
		while (update != 1) {
			showId = StringUtil.randomString(5);
			try {
				update = userMirrorShopMapper.update(null, Wrappers.lambdaUpdate(UserMirrorShop.class)
						.set(UserMirrorShop::getCustomId, showId)
						.eq(UserMirrorShop::getUserId, userId));
			} catch (DuplicateKeyException e) {
				update = 0;
			}
		}
		return showId;
	}

	@Override
	public Long getUserIdByShowId(String showId) {
		return userMapper.getUserIdByShowId(showId);
	}

	@Override
	public User webLogin(LoginReq loginReq, HttpServletRequest request) throws Exception {
		LambdaQueryWrapper<User> wrapper = Wrappers.lambdaQuery(User.class).last("limit 1");
		if (loginReq.getType() == null || loginReq.getType() < 1 || loginReq.getType() > 3) {
			throw BusinessRuntimeException.getInstance("系统异常,请刷新页面重新操作");
		}
		if (loginReq.getType() == 1) {
			if (StrUtil.hasEmpty(loginReq.getPhone(), loginReq.getCode())) {
				throw BusinessRuntimeException.getInstance("请输入对应信息");
			}
			DateTime now = DateTime.now();
			PhoneCode phoneCode = phoneCodeMapper.selectOne(Wrappers.lambdaQuery(PhoneCode.class).eq(PhoneCode::getPhone, loginReq.getPhone()).last("limit 1"));
			if (phoneCode == null || StrUtil.isEmpty(phoneCode.getCode())) {
				throw BusinessRuntimeException.getInstance("请重新获取手机验证码");
			}
			//3分钟失效
			Date updateTime = phoneCode.getUpdateTime();
			DateTime afterFiveMinutes = DateUtil.offsetMinute(updateTime, 3);
			if (now.isAfter(afterFiveMinutes)) {
				throw BusinessRuntimeException.getInstance("手机验证码已失效,请重新获取");
			}
			if (!StrUtil.equals(loginReq.getCode(), phoneCode.getCode())) {
				//是否是恶意用户
				badIntentionOpService.isBadOpLoginPhone(request, loginReq.getPhone());
				throw BusinessRuntimeException.getInstance("手机验证码错误,请重新输入");
			}
			wrapper.eq(User::getLoginPhone, loginReq.getPhone());
		}
		if (loginReq.getType() == 2) {
			if (StrUtil.isEmpty(loginReq.getEmail())) {
				throw BusinessRuntimeException.getInstance("邮箱不能为空");
			}
			String code = redisService.getStr(RedisService.key.EMAIL_CODE_KEY.getNameFormat(loginReq.getEmail()));
			if (StrUtil.isEmpty(code)) {
				throw BusinessRuntimeException.getInstance("邮箱验证码已失效,请重新获取");
			}
			if (!StrUtil.equals(loginReq.getCode(), code)) {
				throw BusinessRuntimeException.getInstance("邮箱验证码错误,请重新输入");
			}
			redisService.del(RedisService.key.EMAIL_CODE_KEY.getNameFormat(loginReq.getEmail()));
			wrapper.eq(User::getEmail, loginReq.getEmail());
		}
		if (loginReq.getType() == 3) {
			wrapper.eq(User::getEmail, loginReq.getEmail());
		}
		//保存用户信息
		User user = this.getOne(wrapper);
		String dsCode = loginReq.getDsCode();
		Long sharedId = loginReq.getSharedId();
		Long dsPopularizeId = null;
		Integer dsType = loginReq.getDsType();
		String customId = loginReq.getCustomId();
		Boolean isNewUser = false;
		if (StrUtil.isNotBlank(dsCode)) {
			UserSharedDto userSharedDto = getUserShredDtoByDsCode(dsCode);
			sharedId = userSharedDto.getSharedId();
			dsPopularizeId = userSharedDto.getDsPopularizeId();
		}
		if (user != null && loginReq.getType() == 3 && !user.getIsGoogle()) {
			user.setIsGoogle(true);
			this.updateById(user);
		}
		if (user == null) {
			user = new User();
			isNewUser = true;
			StringBuilder name = new StringBuilder();
			if (loginReq.getCmt() == 2) {
				name.append(Constant.DEFAULT_MIRROR_SHOP_USER_NAME);
			}else {
				name.append(Constant.DEFAULT_NAME);
			}
			if (loginReq.getPopularizeId() != null) {
				user.setPopularizeId(loginReq.getPopularizeId());
			}
			if (loginReq.getType() == 1) {
				user.setLoginPhone(loginReq.getPhone());
			}
			if (loginReq.getType() == 2 || loginReq.getType() == 3) {
				user.setEmail(loginReq.getEmail());
				name.append("@");
			}
			if (loginReq.getType() == 3) {
				user.setIsGoogle(true);
			}
			user.setNickname(String.format("%s%s", name.toString(), RandomUtil.randomString(6)));
			if (loginReq.getCmt() == 2) {
				user.setHeadimgurl(Constant.USER_MIRROR_SHOP_USER_DEFAULT_IMG);
			} else {
				//默认头像
				user.setHeadimgurl(Constant.DEFAULT_HEAD_IMG);
			}
			String registerEnv = loginReq.getRegisterEnv();
			user.setRegisterEnv(StrUtil.isEmpty(registerEnv) ? User.RegisterEnv.pc.name() : registerEnv);
			this.save(user);
			//新用户分销
			if (sharedId != null) {
				distributeService.saveDistributionInvitation(sharedId, user.getId(), dsPopularizeId);
			}
			//店铺注册用户 关联
			if (StrUtil.isNotBlank(customId)) {
				yhShopDistributeService.saveDistributionInvitation(customId, user.getId(), loginReq.getCmt());
			}
			//缓存用户注册 回传信息
			String callback = loginReq.getCallback();
			String callbackType = loginReq.getCallbackType();
			if (StrUtil.isNotBlank(callback)) {
				OrderDonPostDataDto orderDonPostDataDto = new OrderDonPostDataDto().setCallback(callback)
						.setCallbackType(callbackType);
				redisService.set(RedisService.key.ORDER_DON_POST_DATA_USER_KEY.getName() + user.getId(), Jsons.toJson(orderDonPostDataDto));
			}
			//发放新用户福利
			final Long fUid = user.getId();
//			TASK_POOL.execute(() -> {
//				try {
//					sendNewUserWelfare(fUid);
//				} catch (Exception e) {
//				}
//			});
			final String login_email = user.getEmail();
			final String login_phone = user.getLoginPhone();
			UserBindDetail bindDetail = userBindDetailMapper.selectOne(Wrappers.lambdaQuery(UserBindDetail.class)
					.and(ub -> ub.eq(StrUtil.isNotBlank(login_email), UserBindDetail::getEmail, login_email)
							.or().eq(StrUtil.isNotBlank(login_phone), UserBindDetail::getPhone, login_phone))
					.last("limit 1"));
			if (bindDetail != null) {
				if (StrUtil.isNotBlank(login_phone)) {
					bindDetail.setPhoneUserId(user.getId());
				}
				if (StrUtil.isNotBlank(login_email)) {
					bindDetail.setEmailUserId(user.getId());
				}
				userBindDetailMapper.updateById(bindDetail);
			}
		}
		if (StrUtil.isEmpty(user.getShowId())) {
			user.setShowId(userCommonService.getUserShowId(user.getId()));
		}
		//新旧用户都可实物分销
		if (sharedId != null && dsType != null && dsType == 2) {
			equipDistributeService.saveDistributionInvitation(sharedId, isNewUser, user.getId());
		}
		//查找渠道是否有设置了对应的claude code优惠码
		setClaudeCodePopularize(sharedId, dsPopularizeId, user);

		//每日活跃记录
		userLoginRecordService.saveUserLoginDayRecord(user.getId());
		return user;
	}

	@Override
	public String bindWxAccountRedirect(String code, String state) throws Exception {
		AuthToken token = weChatService.getAuthToken(code, wxOpenPlatYHLXLoginConfig.getAppId());
		//重定向
		// 根据openid 与 access_token 获取用户信息
		GzhOAuth2UserInfo userinfo = weChatService.getUserInfo(token.getAccessToken(), token.getOpenid());

		// 转跳参数
		String json = Codec.DoBase64.custom().setData(state).decodeAsText();
		AuthRedirect re = Jsons.parseObject(json, AuthRedirect.class);
		//保存用户信息
		User user = saveAuth(userinfo, re, User.RegisterEnv.pc);
		if (user == null) {
			throw BusinessRuntimeException.getInstance("系统错误,请重新授权");
		}
		String loginPhone = re.getLp();
		String loginEmail = re.getLe();

		if (StrUtil.isNotBlank(loginPhone)) {
			log.info("手机号phone:{}登录用户,微信扫描网页授权二维码进行用户信息绑定", loginPhone);
			try {
				bindTaskService.bindPhone(user, loginPhone, null);
			} catch (Exception e) {
				log.info(StringUtil.getErrorText(e));
			}
		}

		if (StrUtil.isNotBlank(loginEmail)) {
			log.info("邮箱email:{}登录用户,微信扫描网页授权二维码进行用户信息绑定", loginEmail);
			try {
				bindTaskService.bindEmail(user, loginEmail, null);
			} catch (Exception e) {
				log.info(StringUtil.getErrorText(e));
			}
		}
		return redisService.getStr(re.getMappingId().toString());
	}

	@Override
	@Transactional(rollbackFor = Throwable.class)
	public void receiveGiftCardByRc(Long userId, String code, Long relationId) {
		GiftCardUserRecord giftCardUserRecord = giftCardUserRecordMapper.selectOne(Wrappers.lambdaQuery(GiftCardUserRecord.class)
				.eq(GiftCardUserRecord::getRc, code).last("limit 1"));
		if (giftCardUserRecord == null) {
			throw BusinessRuntimeException.getInstance("好友赠送礼品卡不存在");
		}
		if (!giftCardUserRecord.getIsPay()) {
			throw BusinessRuntimeException.getInstance("无效礼品卡,好友未购买");
		}
		List<Long> relationUserIdList = userBindRelationService.getRelationUserIdList(userId, null);
		if (relationUserIdList.contains(giftCardUserRecord.getUserId())) {
			throw BusinessRuntimeException.getInstance("无法领取自己购买的礼品卡");
		}
		if (giftCardUserRecord.getToUserId() != 0 && !giftCardUserRecord.getToUserId().equals(userId)) {
			throw BusinessRuntimeException.getInstance("好友赠送礼品卡已被领取");
		}
		if (giftCardUserRecord.getToUserId().equals(userId)) {
			throw BusinessRuntimeException.getInstance("您已领取该礼品卡");
		}
		giftCardUserRecord.setToUserId(userId);
		int update = giftCardUserRecordMapper.update(null, Wrappers.lambdaUpdate(GiftCardUserRecord.class)
				.set(giftCardUserRecord.getGcType() != 1, GiftCardUserRecord::getIsUsed, true)
				.set(GiftCardUserRecord::getToUserId, userId)
				.set(GiftCardUserRecord::getIsSend, true)
				.set(GiftCardUserRecord::getReceivedTime, DateTime.now())
				.eq(GiftCardUserRecord::getId, giftCardUserRecord.getId())
				.eq(GiftCardUserRecord::getIsPay, true)
				.eq(GiftCardUserRecord::getToUserId, 0));
		if (update > 0) {
			//虚拟卡
			//直接发送 对应规格车票
			if (giftCardUserRecord.getGcType() != 1) {
				Long gcSkuId = giftCardUserRecord.getGcSkuId();
				log.info("用户userId:{}领取礼品卡id:{},开始发放虚拟车票skuId:{}", userId, giftCardUserRecord.getId(), gcSkuId);
				GoodsDonSku sku = goodsDonSkuMapper.selectById(gcSkuId);
				if (sku == null) {
					log.info("礼品卡id:{}虚拟车票skuId:{}不存在", giftCardUserRecord.getId(), gcSkuId);
					throw BusinessRuntimeException.getInstance("该礼品卡对应的虚拟卡不存在,请联系客服");
				}
				if (relationId != null) {
					GroupsRelation groupsRelation = groupsRelationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
							.in(GroupsRelation::getUserId, relationUserIdList)
							.eq(GroupsRelation::getId, relationId)
							.in(GroupsRelation::getStatus, List.of(GroupsRelation.Status.validity, GroupsRelation.Status.outside)).last("limit 1"));
					if (groupsRelation == null) {
						throw BusinessRuntimeException.getInstance("您选择的车票不存在");
					}
					Date expiryTime = groupsRelation.getExpiryTime();
					if (expiryTime == null) {
						throw BusinessRuntimeException.getInstance("请等您该类型下的车票配置账号后再增加对应时长");
					}
					if (sku.getDays() != null && sku.getDays() > 0) {
						expiryTime = DateUtil.offsetDay(expiryTime, sku.getDays());
					} else {
						expiryTime = DateUtil.offsetMonth(expiryTime, sku.getMonths());
					}
					log.info("userId:{}领取虚拟卡skuId:{},增加车票时长至:{}", userId, sku.getId(), expiryTime.toString());
					groupsRelation.setExpiryTime(expiryTime);
					groupsRelationMapper.updateById(groupsRelation);
					return;
				}
				//是否存在对应车票
				List<UserTicketView> ticketViews = beanSearcher.searchAll(UserTicketView.class, MapUtils.builder()
						.field(UserTicketView::getUserId, relationUserIdList).op(Operator.InList)
						.field(UserTicketView::getSkuId, giftCardUserRecord.getGcSkuId())
						.field(RenewalView::getStatus, List.of("validity", "outside")).op(Operator.InList)
						.orderBy(UserTicketView::getRelationId).asc()
						.build());
				if (CollUtil.isEmpty(ticketViews)) {
					GroupsRelation relationNoOrder = exchangeCodeService.getRelationNoOrder(sku, userId, null);
					giftCardUserRecordMapper.update(null, Wrappers.lambdaUpdate(GiftCardUserRecord.class)
							.set(GiftCardUserRecord::getRelationId, relationNoOrder.getId())
							.eq(GiftCardUserRecord::getId, giftCardUserRecord.getId()));
					log.info("用户未有该规格:{}车票,发送至用户userId:{}礼品卡虚拟车票结束", gcSkuId, userId);
					return;
				}
				if (ticketViews.size() > 1) {
					throw BusinessRuntimeException.getInstance("您有多张该类型的车票,请选择一张增加时长");
				}
				UserTicketView userTicketView = ticketViews.get(0);
				Date expiryTime = userTicketView.getExpiryTime();
				if (expiryTime == null) {
					throw BusinessRuntimeException.getInstance("请等您该类型下的车票配置账号后再增加对应时长");
				}
				if (sku.getDays() != null && sku.getDays() > 0) {
					expiryTime = DateUtil.offsetDay(expiryTime, sku.getDays());
				} else {
					expiryTime = DateUtil.offsetMonth(expiryTime, sku.getMonths());
				}
				groupsRelationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
						.set(GroupsRelation::getExpiryTime, expiryTime)
						.eq(GroupsRelation::getId, userTicketView.getRelationId()));
			}
		}
	}

	/**
	 * 发放新用户福利
	 */
	public void sendNewUserWelfare(Long userId) throws Exception {
		SysConfig newUserWelfareConfig = sysConfigService.getOne(Wrappers.lambdaQuery(SysConfig.class)
				.eq(SysConfig::getSysKey, Constant.NEW_USER_WELFARE_KEY).last("limit 1"));
		if (StrUtil.isEmpty(newUserWelfareConfig.getSysValue())) {
			return;
		}
		NewUserWelfareDto newUserWelfareDto = Jsons.parseObject(newUserWelfareConfig.getSysValue(), NewUserWelfareDto.class);
		if (newUserWelfareDto != null) {
			List<Long> couponIds = newUserWelfareDto.getCouponIds();
			couponIds.forEach(couponId -> couponCommonService.sendCouponToUser(userId, couponId, null, null, null, CouponUser.Channel.new_welfare));
		}
	}

	/**
	 * 关联企业微信用户 并发放福利
	 */
	private void relateCorpUserAndSengWelfare(Long fUid, String unionid) {
		CorpUser corpUser = corpUserMapper.selectOne(Wrappers.lambdaQuery(CorpUser.class)
				.eq(CorpUser::getUnionid, unionid).last("limit 1"));
		Long msgId = null;
		CouponUser.Channel channel = null;
		if (corpUser != null) {
			corpUser.setUserId(fUid);
			corpUserMapper.updateById(corpUser);
			//活码福利
			if (corpUser.getAcId() != null && corpUser.getAcId() > 0) {
				CorpFollowActiveCode corpFollowActiveCode = corpFollowActiveCodeMapper.selectById(corpUser.getAcId());
				if (corpFollowActiveCode != null) {
					msgId = corpFollowActiveCode.getMsgId();
					channel = CouponUser.Channel.corp_active_code;
				}
			}
			if (corpUser.getCustomerAcquisitionLinkId() != null && corpUser.getCustomerAcquisitionLinkId() > 0) {
				CorpCustomerAcquisitionLink corpCustomerAcquisitionLink = corpCustomerAcquisitionLinkMapper.selectById(corpUser.getCustomerAcquisitionLinkId());
				if (corpCustomerAcquisitionLink != null) {
					msgId = corpCustomerAcquisitionLink.getMsgId();
					channel = CouponUser.Channel.customer_link;
				}
			}
			if (msgId != null) {
				CorpWelcomeTemplate corpWelcomeTemplate = corpWelcomeTemplateMapper.selectById(msgId);
				if (corpWelcomeTemplate != null && StrUtil.isNotBlank(corpWelcomeTemplate.getCouponIds())) {
					final CouponUser.Channel fChannel = channel;
					try {
						List<Long> couponIds = Jsons.parseList(corpWelcomeTemplate.getCouponIds(), Long.class);
						couponIds.forEach(couponId -> couponCommonService.sendCouponToUser(fUid, couponId, 0l, 0l, 0l, fChannel));
					} catch (Exception e) {
					}
				}
			}

			//是否有对应获客链接的标签
			List<Long> tagIds = corpUserTagMapper.getTagIdByCorpUserId(corpUser.getId());
			if (CollUtil.isNotEmpty(tagIds)) {
				List<String> couponIdsStrList = corpCustomerAcquisitionLinkMapper.selectAcLinkCorpTemplateCouponIdsByTagIds(tagIds);
				if (CollUtil.isNotEmpty(couponIdsStrList)) {
					log.info("用户userId:{}存在获客链接标记的标签:{}", fUid, tagIds);
					couponIdsStrList.forEach(couponIdsStr -> {
						try {
							Jsons.parseList(couponIdsStr, Long.class).forEach(couponId -> couponCommonService.sendCouponToUser(fUid, couponId, 0l, 0l, 0l, CouponUser.Channel.customer_link));
						} catch (Exception e) {
						}
					});
				}
			}
		}
	}

	@Override
	public UserSharedDto getUserShredDtoByDsCode(String dsCode) {
		Long sharedId = 0l;
		Long dsPopularizeId = 0l;
		dsCode = dsCode.trim();
		User sharedUser = getOne(Wrappers.lambdaQuery(User.class)
				.eq(User::getShowId, dsCode).last("limit 1"));
		if (sharedUser != null) {
			sharedId = sharedUser.getId();
		} else {
			UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
					.eq(UserDistributePopularize::getCode, dsCode)
					.select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
			if (distributePopularize != null) {
				log.info("渠道sharedId:{}设置固定推广链接用户分销", distributePopularize.getUserId());
				sharedId = distributePopularize.getUserId();
				dsPopularizeId = distributePopularize.getId();
			}
		}
		UserSharedDto sharedDto = new UserSharedDto();
		sharedDto.setSharedId(sharedId);
		sharedDto.setDsPopularizeId(dsPopularizeId);
		return sharedDto;
	}

	@Override
	public Long getSharedIdByUserId(Long userId) {
		UserDistributeShared distributeShared = userDistributeSharedMapper.selectOne(Wrappers.lambdaQuery(UserDistributeShared.class)
				.eq(UserDistributeShared::getUserId, userId)
				.last("limit 1")
				.select(UserDistributeShared::getSharedId));
		if (distributeShared == null) {
			return 0l;
		}
		return distributeShared.getSharedId();
	}

	@Override
	public void bindUserDistributeShared(Long userId, String dsCode) {
		User user = userMapper.selectById(userId);
		if (StrUtil.equals(user.getShowId(), dsCode)) {
			return;
		}
		UserSharedDto userSharedDto = getUserShredDtoByDsCode(dsCode);
		Long sharedId = userSharedDto.getSharedId();
		Long dsPopularizeId = userSharedDto.getDsPopularizeId();
		//建立绑定关系
		log.info("建立用户userId:{}与sharedId:{}绑定关系", userId, sharedId);
		distributeService.saveDistributionInvitation(sharedId, user.getId(), dsPopularizeId);
	}

	@Override
	public void saveEpDistributeShared(Long userId, String dsCode) {
		if (StrUtil.isEmpty(dsCode)) {
			log.info("设备好友邀请userId：{}，code为空", userId);
			return;
		}
		User user = getById(userId);
		Date createdTime = user.getCreatedTime();
		String createDate = new DateTime(createdTime).toDateStr();
		Boolean isNewUser = false;
		if (StrUtil.equals(createDate, DateTime.now().toDateStr())) {
			isNewUser = true;
		}
		UserSharedDto userSharedDto = getUserShredDtoByDsCode(dsCode);
		if (userSharedDto != null) {
			log.info("实物好友分销邀请sharedId:{},被邀请用户id:{}", userSharedDto.getSharedId(), userId);
			equipDistributeService.saveDistributionInvitation(userSharedDto.getSharedId(), isNewUser, user.getId());
		}
	}

	@Override
	public UserCertInfoView getCertOverView(long userId) {
		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
		UserCertRecord record = userCertRecordMapper.selectOne(Wrappers.lambdaQuery(UserCertRecord.class)
				.in(UserCertRecord::getUserId, userIdList)
				.select(UserCertRecord::getName, UserCertRecord::getIdent)
				.last("limit 1"));
		if (record != null) {
			record.setIdent(StringUtil.enIndent(record.getIdent()));
			record.setName(StringUtil.enName(record.getName()));
		}
		UserStudentCertRecord userStudentCertRecord = userStudentCertRecordMapper.selectOne(Wrappers.lambdaQuery(UserStudentCertRecord.class)
				.in(UserStudentCertRecord::getUserId, userIdList)
				.select(UserStudentCertRecord::getSchool)
				.last("limit 1"));
		UserCertInfoView userCertInfoView = new UserCertInfoView();
		userCertInfoView.setIndent(record);
		userCertInfoView.setStudentCert(userStudentCertRecord);
		return userCertInfoView;
	}

	@Override
	public UserSyncInfoView getUserSyncInfo(long userId) {
		UserSyncInfoView syncInfoView = new UserSyncInfoView();
		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
		//是否是会员
		VipUser vipUser = vipUserMapper.selectOne(Wrappers.lambdaQuery(VipUser.class)
				.in(VipUser::getUserId, userIdList)
				.gt(VipUser::getExpiryTime, DateTime.now())
				.last("limit 1"));
		if (vipUser != null) {
			syncInfoView.setIsVip(Boolean.TRUE);
			syncInfoView.setVipStartTime(vipUser.getStartTime());
			syncInfoView.setVipExpiryTime(vipUser.getExpiryTime());
		}
		User user = userMapper.selectById(userId);
		syncInfoView.setGalaxyCoin(user.getGalaxyCoin());
		return syncInfoView;
	}

	/**
	 * 处理大学生快递站用户
	 */
	public void handlerCollegeStudentUser(Long userId, Integer cst) {
		try {
			CollegeStudentStationUserRelate cstRelate = new CollegeStudentStationUserRelate();
			cstRelate.setType(cst);
			cstRelate.setUserId(userId);
			collegeStudentStationUserRelateMapper.insert(cstRelate);

			//赠送1天的GPT镜像车票
			groupRelationFrontService.getCollegeStudentUserGptTicket(userId);
		} catch (DuplicateKeyException e) {
		}
	}

	/**
	 * 查找渠道是否有设置了对应的claude code优惠码
	 */
	public void setClaudeCodePopularize(Long sharedId, Long dsPopularizeId, User user) {
		//查找渠道是否有设置了对应的claude code优惠码
		if (sharedId != null) {
			UserDistribute userDistribute = userDistributeMapper.selectOne(Wrappers.lambdaQuery(UserDistribute.class).eq(UserDistribute::getUserId, sharedId).eq(UserDistribute::getDeleted, Boolean.TRUE).last("limit 1"));
			if (userDistribute != null) {
				if (dsPopularizeId == null) {
					return;
				}
				UserDistributePopularize userDistributePopularize = distributePopularizeMapper.selectById(dsPopularizeId);
				if (userDistributePopularize == null) {
					return;
				}
				//是否是cc推广
				if (StrUtil.isEmpty(userDistributePopularize.getOtherUrl()) || !"cc".equals(userDistributePopularize.getOtherUrl())) {
					return;
				}
				Integer selectCount = couponDistributePopularizeMapper.selectCount(Wrappers.lambdaQuery(CouponDistributePopularize.class).eq(CouponDistributePopularize::getDistributeId, userDistribute.getId()).eq(CouponDistributePopularize::getDeleted, Boolean.TRUE).eq(CouponDistributePopularize::getCouponId, Constant.DISTRIBUTE_CLAUDE_CODE_COUPON_ID));
				//是否设置claude cod优惠券
				if (selectCount > 0) {
					//设置了 直接发送优惠券
					couponCommonService.sendCouponToUser(user.getId(), Constant.DISTRIBUTE_CLAUDE_CODE_COUPON_ID, 0l, 0l, dsPopularizeId, CouponUser.Channel.manual);
					if (redisService.setNx(RedisService.key.CLAUDE_CODE_TY_DAY_CARD_KEY.getName() + user.getId(), user.getId(), RedisService.key.CLAUDE_CODE_TY_DAY_CARD_KEY.getTimeout())) {
						//存在Claude code车票不发送体验卡
						if (!claudeCodeService.checkClaudeCodeUser(user.getId())) {
							//发送claude code 体验卡
							groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_CLAUDE_CODE_TRIAL_SKU_ID, 1);
						}
					}
				} else {
					//该优惠券是否处于推荐中
					int isTj = couponRecommendMapper.checkPresentRecommendByCouponId(Constant.DISTRIBUTE_CLAUDE_CODE_NO_CODE_COUPON_ID);
					if (isTj != 0) {
						//发送无优惠码的 优惠券
						couponCommonService.sendCouponToUser(user.getId(), Constant.DISTRIBUTE_CLAUDE_CODE_NO_CODE_COUPON_ID, 0l, 0l, dsPopularizeId, CouponUser.Channel.manual);
					}
				}
			}
		}
	}
}