sczx_group/sczx_user
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加引荐人

Browse Source
This commit is contained in:
zhangli
2025-08-24 13:04:28 +08:00
parent 2f4128f133
commit 03fa3ef558
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/sczx/user/service/impl/UserServiceImpl.java
View File

@ -120,6 +120,23 @@ public class UserServiceImpl implements IUserService {
}
baseUserRepo.saveOrUpdate(newUserPO);
if(Objects.nonNull(wxMiniProgramRegRequest.getReferralUserId())){
LambdaQueryWrapper<BaseUserReferralPO> queryReferralWrapper = new LambdaQueryWrapper<>();
queryReferralWrapper.eq(BaseUserReferralPO::getUserId, baseUserPO.getId()).last( " limit 1");
BaseUserReferralPO baseUserReferralPO = baseUserReferralRepo.getOne(queryReferralWrapper);
if(Objects.isNull(baseUserReferralPO)){
baseUserReferralPO = new BaseUserReferralPO();
BaseUserPO referralUserPO = baseUserRepo.getById(wxMiniProgramRegRequest.getReferralUserId());
baseUserReferralPO.setUserId(baseUserPO.getId());
baseUserReferralPO.setUserPhoneNumber(phoneNumber);
baseUserReferralPO.setReferralUserId(wxMiniProgramRegRequest.getReferralUserId());
baseUserReferralPO.setReferralUserPhoneNumber(referralUserPO.getPhoneNumber());
//TODO-获取推荐奖励
//保存推荐信息
baseUserReferralRepo.save(baseUserReferralPO);
}
}
return getLoginResponse(openid,MiniProgramTypeEnum.WECHAT.getType());
}catch (Exception e){
log.error("微信小程序注册失败", e);