From 183e39f1cd59c80bf56ecdf159319d811b9dbc52 Mon Sep 17 00:00:00 2001 From: 疯狂的狮子Li <15040126243@163.com> Date: 星期三, 29 十一月 2023 15:27:46 +0800 Subject: [PATCH] update 优化 删除无用注解 --- ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java | 21 +++++++++++++++++---- 1 files changed, 17 insertions(+), 4 deletions(-) diff --git a/ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java b/ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java index 187ea2a..d0d7931 100644 --- a/ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java +++ b/ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java @@ -16,11 +16,14 @@ import org.dromara.common.core.domain.model.RegisterBody; import org.dromara.common.core.domain.model.SocialLoginBody; import org.dromara.common.core.utils.*; +import org.dromara.common.encrypt.annotation.ApiEncrypt; import org.dromara.common.json.utils.JsonUtils; +import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.common.social.config.properties.SocialLoginConfigProperties; import org.dromara.common.social.config.properties.SocialProperties; import org.dromara.common.social.utils.SocialUtils; import org.dromara.common.tenant.helper.TenantHelper; +import org.dromara.common.websocket.utils.WebSocketUtils; import org.dromara.system.domain.SysClient; import org.dromara.system.domain.bo.SysTenantBo; import org.dromara.system.domain.vo.SysTenantVo; @@ -39,6 +42,8 @@ import java.net.URL; import java.util.List; +import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; /** * 璁よ瘉 @@ -47,7 +52,6 @@ */ @Slf4j @SaIgnore -@Validated @RequiredArgsConstructor @RestController @RequestMapping("/auth") @@ -60,6 +64,7 @@ private final ISysTenantService tenantService; private final ISysSocialService socialUserService; private final ISysClientService clientService; + private final ScheduledExecutorService scheduledExecutorService; /** @@ -68,8 +73,9 @@ * @param body 鐧诲綍淇℃伅 * @return 缁撴灉 */ + @ApiEncrypt @PostMapping("/login") - public R<LoginVo> login(@Validated @RequestBody String body) { + public R<LoginVo> login(@RequestBody String body) { LoginBody loginBody = JsonUtils.parseObject(body, LoginBody.class); ValidatorUtils.validate(loginBody); // 鎺堟潈绫诲瀷鍜屽鎴风id @@ -86,7 +92,13 @@ // 鏍¢獙绉熸埛 loginService.checkTenant(loginBody.getTenantId()); // 鐧诲綍 - return R.ok(IAuthStrategy.login(body, client, grantType)); + LoginVo loginVo = IAuthStrategy.login(body, client, grantType); + + Long userId = LoginHelper.getUserId(); + scheduledExecutorService.schedule(() -> { + WebSocketUtils.sendMessage(userId, "娆㈣繋鐧诲綍RuoYi-Vue-Plus鍚庡彴绠$悊绯荤粺"); + }, 3, TimeUnit.SECONDS); + return R.ok(loginVo); } /** @@ -152,6 +164,7 @@ /** * 鐢ㄦ埛娉ㄥ唽 */ + @ApiEncrypt @PostMapping("/register") public R<Void> register(@Validated @RequestBody RegisterBody user) { if (!configService.selectRegisterEnabled(user.getTenantId())) { @@ -181,7 +194,7 @@ } // 鏍规嵁鍩熷悕杩涜绛涢�� List<TenantListVo> list = StreamUtils.filter(voList, vo -> - StringUtils.equals(vo.getDomain(), host)); + StringUtils.equals(vo.getDomain(), host)); // 杩斿洖瀵硅薄 LoginTenantVo vo = new LoginTenantVo(); vo.setVoList(CollUtil.isNotEmpty(list) ? list : voList); -- Gitblit v1.9.3