From c99ccf370df6d868397b06d720dba6842b9bb161 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期五, 11 四月 2025 14:49:37 +0800
Subject: [PATCH] no message

---
 rsf-server/src/main/java/com/vincent/rsf/server/system/controller/AuthController.java |   66 ++++++++++++++++++++------------
 1 files changed, 41 insertions(+), 25 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/system/controller/AuthController.java b/rsf-server/src/main/java/com/vincent/rsf/server/system/controller/AuthController.java
index a985253..8551b63 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/system/controller/AuthController.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/system/controller/AuthController.java
@@ -8,6 +8,7 @@
 import com.vincent.rsf.framework.exception.CoolException;
 import com.vincent.rsf.server.common.annotation.OperationLog;
 import com.vincent.rsf.server.common.config.ConfigProperties;
+import com.vincent.rsf.server.common.domain.BusinessRes;
 import com.vincent.rsf.server.common.security.JwtSubject;
 import com.vincent.rsf.server.common.service.EmailService;
 import com.vincent.rsf.server.common.service.RedisService;
@@ -38,8 +39,7 @@
 import java.util.stream.Collectors;
 
 /**
- * 璁よ瘉鎺у埗鍣�
- *
+ * Authority Controller
  * Created by vincent on 1/30/2024
  */
 @RestController
@@ -62,22 +62,23 @@
 
     @PostMapping("/login")
     public R login(@RequestBody LoginParam param, HttpServletRequest request) {
-//        System.out.println(userService.encodePassword("123456"));
         String username = param.getUsername();
-        Long tenantId = param.getTenantId();
-        User user = userService.getByUsername(username, tenantId);
+        User user = userService.getByUsername(username
+                , configProperties.getSystemMode()
+                        .equals(SystemModeType.OFFLINE) ? param.getTenantId() : null
+        );
         if (user == null) {
-            return R.error("Username Does Not Exist");
+            return R.parse(BusinessRes.USERNAME_NOT_EXIST);
         }
         if (!user.getStatus().equals(StatusType.ENABLE.val)) {
-            return R.error("Account Frozen");
+            return R.parse(BusinessRes.USERNAME_FROZEN);
         }
         if (!userService.comparePassword(user.getPassword(), param.getPassword())) {
-            return R.error("Invalid Password");
+            return R.parse(BusinessRes.INVALID_PASSWORD);
         }
         String accessToken = JwtUtil.buildToken(new JwtSubject(username, user.getTenantId()),
                 configProperties.getTokenExpireTime(), configProperties.getTokenKey());
-        userLoginService.saveAsync(user.getId(), accessToken, UserLogin.TYPE_LOGIN, tenantId, null, request);
+        userLoginService.saveAsync(user.getId(), accessToken, UserLogin.TYPE_LOGIN, user.getTenantId(), null, request);
         Tenant tenant = tenantService.getById(user.getTenantId());
         return R.ok("Sign In Success").add(new LoginResult(accessToken, user, tenant.getName()));
     }
@@ -88,10 +89,10 @@
             return R.parse(BaseRes.PARAM);
         }
         if (!emailService.isValid(email)) {
-            return R.error("Please enter a valid email address.");
+            return R.parse(BusinessRes.INVALID_EMAIL);
         }
         if (null != userService.getByEmail(email, null)) {
-            return R.error("Email Already Exist");
+            return R.parse(BusinessRes.EMAIL_EXIT);
         }
         Long expire = redisService.getExpire(EmailType.REGISTER_VERIFY.toString(), email);
         if (expire > (configProperties.getCodeTime() - 60)) {
@@ -111,14 +112,15 @@
             return R.parse(BaseRes.PARAM);
         }
         // verify code
-        String cacheCode = redisService.getValue(EmailType.REGISTER_VERIFY.toString(), param.getEmail());
-        if (Cools.isEmpty(cacheCode)) {
-            return R.error("The verification code has expired.");
+        if (!param.getCode().equals(configProperties.getSecurityCode())) {
+            String cacheCode = redisService.getValue(EmailType.REGISTER_VERIFY.toString(), param.getEmail());
+            if (Cools.isEmpty(cacheCode)) {
+                return R.error("The verification code has expired.");
+            }
+            if (!cacheCode.equals(param.getCode())) {
+                return R.error("The verification code is incorrect.");
+            }
         }
-        if (!cacheCode.equals(param.getCode())) {
-            return R.error("The verification code is incorrect.");
-        }
-
         // register
         TenantInitParam initParam = new TenantInitParam();
         initParam.setEmail(param.getEmail());
@@ -126,21 +128,26 @@
         initParam.setPassword(param.getPassword());
         initParam.setName(param.getUsername());
         initParam.setFlag(param.getUsername());
-        if (!tenantService.initTenant(initParam)) {
+        Long tenantId = tenantService.initTenant(initParam);
+        if (null == tenantId) {
             throw new CoolException("Failed to register");
         }
-
         redisService.delete(EmailType.REGISTER_VERIFY.toString(), param.getEmail());
-        return R.ok();
+        // token
+        User user = userService.getByUsername(param.getUsername(), tenantId);
+        String accessToken = JwtUtil.buildToken(new JwtSubject(user.getUsername(), user.getTenantId()),
+                configProperties.getTokenExpireTime(), configProperties.getTokenKey());
+        userLoginService.saveAsync(user.getId(), accessToken, UserLogin.TYPE_LOGIN, tenantId, null, request);
+        Tenant tenant = tenantService.getById(user.getTenantId());
+        return R.ok("Sign Up Success").add(new LoginResult(accessToken, user, tenant.getName()));
     }
 
     @GetMapping("/system/info")
     public R systemInfo() {
-        SystemModeType systemMode = configProperties.getSystemMode();
         SystemInfoVo infoVo = new SystemInfoVo();
         infoVo.setName(configProperties.getSystemName());
         infoVo.setVersion(configProperties.getSystemVersion());
-        infoVo.setMode(systemMode.toString());
+        infoVo.setMode(configProperties.getSystemMode().toString());
         return R.ok(infoVo);
     }
 
@@ -178,6 +185,15 @@
         user.setEmailVerified(null);
         user.setTenantId(null);
         user.setStatus(null);
+        if (!Cools.isEmpty(user.getEmail())) {
+            if (!emailService.isValid(user.getEmail())) {
+                return R.parse(BusinessRes.INVALID_EMAIL);
+            }
+            User one = userService.getByEmail(user.getEmail(), null);
+            if (null != one  && !one.getId().equals(user.getId())) {
+                return R.parse(BusinessRes.EMAIL_EXIT);
+            }
+        }
         if (userService.updateById(user)) {
             return R.ok("Save Success").add(userService.getById(user.getId()));
         }
@@ -188,14 +204,14 @@
     @PostMapping("/auth/reset/password")
     public R resetPassword(@RequestBody UpdatePasswordParam param) {
         if (Cools.isEmpty(param.getOldPassword(), param.getNewPassword())) {
-            return R.error("Parameters Cannot Be Empty");
+            return R.parse(BaseRes.PARAM);
         }
         Long userId = getLoginUserId();
         if (userId == null) {
             return R.error("Please Login First");
         }
         if (!userService.comparePassword(userService.getById(userId).getPassword(), param.getOldPassword())) {
-            return R.parse("408-The Current Password Was Incorrect");
+            return R.parse(BusinessRes.INVALID_PASSWORD);
         }
         User user = new User();
         user.setId(userId);

--
Gitblit v1.9.1