From 1c3012232d08c8eff3e5cca6d13959798516c466 Mon Sep 17 00:00:00 2001
From: jiang <jiang@bonus>
Date: Tue, 12 Nov 2024 11:13:31 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E6=88=B7=E7=99=BB=E5=BD=95=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../bonus/auth/service/SysLoginService.java    | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/bonus-auth/src/main/java/com/bonus/auth/service/SysLoginService.java b/bonus-auth/src/main/java/com/bonus/auth/service/SysLoginService.java
index a158b5d..4ba79d8 100644
--- a/bonus-auth/src/main/java/com/bonus/auth/service/SysLoginService.java
+++ b/bonus-auth/src/main/java/com/bonus/auth/service/SysLoginService.java
@@ -9,11 +9,13 @@ import com.bonus.common.core.constant.UserConstants;
 import com.bonus.common.core.domain.R;
 import com.bonus.common.core.exception.ServiceException;
 import com.bonus.common.core.utils.StringUtils;
+import com.bonus.common.core.utils.encryption.Sm4Utils;
 import com.bonus.common.core.web.domain.AjaxResult;
 import com.bonus.common.security.utils.SecurityUtils;
 import com.bonus.config.SystemConfig;
 import com.bonus.system.api.RemoteUserService;
 import com.bonus.system.api.domain.SysUser;
+import com.bonus.system.api.model.LoginUser;
 import com.hankcs.hanlp.HanLP;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -82,6 +84,21 @@ public class SysLoginService {
     public void register(RegisterBody registerBody) {
         long startTime = System.currentTimeMillis(); // 记录开始时间
         String result = convertAndAppend(registerBody.getNickName(), registerBody.getMobile());
+        int contactType = getContactType(registerBody.getMobile());
+
+        if (contactType == 0) {
+            R<LoginUser> userResult = remoteUserService.getUserInfoByEmail(Sm4Utils.encrypt(registerBody.getMobile()) , SecurityConstants.INNER);
+            if (userResult.getData() != null) {
+                throw new ServiceException("联系方式已经注册账号");
+            }
+        } else if (contactType == 1) {
+            R<LoginUser> userResult = remoteUserService.getUserInfoByPhone(Sm4Utils.encrypt(registerBody.getMobile()) , SecurityConstants.INNER);
+            if (userResult.getData() != null) {
+                throw new ServiceException("联系方式已经注册账号");
+            }
+        }else {
+            throw new ServiceException("请输入正确的联系方式");
+        }
         registerBody.setUsername(result);
         if (StringUtils.isAnyBlank(registerBody.getUsername(), registerBody.getPassword()) ||
                 registerBody.getUsername().length() < UserConstants.USERNAME_MIN_LENGTH ||
@@ -93,6 +110,7 @@ public class SysLoginService {
             passwordValidatorService.checkPhoneCaptcha(registerBody.getMobile(),registerBody.getVerificationCode());
         }
         AjaxResult ajaxResult = passwordValidatorService.validatePassword(registerBody.getUsername(), registerBody.getPassword());
+
         if (ajaxResult.isError()) {
             throw new ServiceException((String) ajaxResult.get("msg"));
         }