diff --git a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserMemberMapper.java b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserMemberMapper.java index e9df72b..328a645 100644 --- a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserMemberMapper.java +++ b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserMemberMapper.java @@ -81,5 +81,5 @@ public interface WxUserMemberMapper { List selectWxUserMemberIdList(); - + List selectWxUserMemberByMobile(@Param("mobile") String mobile); } diff --git a/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml b/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml index 8dc63b0..0b6db33 100644 --- a/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml +++ b/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml @@ -291,5 +291,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" SELECT id FROM `wx_user_member` + + \ No newline at end of file diff --git a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java index 0cf04e6..2d9223a 100644 --- a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java +++ b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java @@ -24,6 +24,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; +import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -110,6 +111,12 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService { logger.error("获取用户手机号码失败: {}", wxCode2PhoneRet.getErrmsg()); throw new ServiceException("获取用户手机号码失败"); } + + // 查询号码是否存在 + List wxUserMembers = wxUserMemberMapper.selectWxUserMemberByMobile(wxCode2PhoneRet.getPhoneInfo().getPhoneNumber()); + if (wxUserMembers.size() > 0) { + throw new ServiceException("手机号码已注册!"); + } wxUserMemberMapper.upgradeMember(wxCode2PhoneRet.getPhoneInfo().getPhoneNumber(), SecurityUtils.getLoginUser().getWxUserMember().getId().intValue()); return wxCode2PhoneRet.getPhoneInfo().getPhoneNumber(); }