diff --git a/consumer/src/main/java/cn/lili/event/impl/MemberExecute.java b/consumer/src/main/java/cn/lili/event/impl/MemberExecute.java index 838a097e1..426c5817d 100644 --- a/consumer/src/main/java/cn/lili/event/impl/MemberExecute.java +++ b/consumer/src/main/java/cn/lili/event/impl/MemberExecute.java @@ -49,6 +49,10 @@ public class MemberExecute implements MemberLoginEvent, MemberConnectLoginEvent SourceEnum sourceEnum = SourceEnum.getSourceEnum(authUser.getSource(), authUser.getType()); connectService.loginBindUser(member.getId(), authUser.getUuid(), sourceEnum.name()); } + //保存手机号,判断用户是否存手机号,如果不存在则保存手机号 + if (StrUtil.isNotBlank(authUser.getPhone())&&StrUtil.isBlank(member.getMobile())) { + memberService.changeMobile(member.getId(),member.getMobile()); + } } } diff --git a/framework/src/main/java/cn/lili/modules/member/service/MemberService.java b/framework/src/main/java/cn/lili/modules/member/service/MemberService.java index 430bb1d67..7b7776464 100644 --- a/framework/src/main/java/cn/lili/modules/member/service/MemberService.java +++ b/framework/src/main/java/cn/lili/modules/member/service/MemberService.java @@ -147,6 +147,14 @@ public interface MemberService extends IService { */ boolean changeMobile(String mobile); + /** + * 修改用户手机号 + * @param memberId 会员ID + * @param mobile 手机号 + * @return + */ + boolean changeMobile(String memberId,String mobile); + /** * 通过手机号修改密码 diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java index 3407253e7..21f19deee 100644 --- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java @@ -431,6 +431,15 @@ public class MemberServiceImpl extends ServiceImpl impleme return this.update(lambdaUpdateWrapper); } + @Override + public boolean changeMobile(String memberId, String mobile) { + //修改会员手机号 + LambdaUpdateWrapper lambdaUpdateWrapper = Wrappers.lambdaUpdate(); + lambdaUpdateWrapper.eq(Member::getId, memberId); + lambdaUpdateWrapper.set(Member::getMobile, mobile); + return this.update(lambdaUpdateWrapper); + } + @Override public boolean resetByMobile(String uuid, String password) { String phone = cache.get(CachePrefix.FIND_MOBILE + uuid).toString();