From 394c40d8bb29b8e40fc7978ea638f1592b03d617 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期四, 08 九月 2022 16:42:46 +0800
Subject: [PATCH] 修复目录订阅的状态异常
---
src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java | 115 +++++++++++++++++++++------------------------------------
1 files changed, 43 insertions(+), 72 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java
index d628d57..0052fd3 100644
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java
@@ -1,5 +1,6 @@
package com.genersoft.iot.vmp.vmanager.user;
+import com.genersoft.iot.vmp.conf.exception.ControllerException;
import com.genersoft.iot.vmp.conf.security.SecurityUtils;
import com.genersoft.iot.vmp.conf.security.dto.LoginUser;
import com.genersoft.iot.vmp.service.IRoleService;
@@ -7,6 +8,7 @@
import com.genersoft.iot.vmp.storager.dao.dto.Role;
import com.genersoft.iot.vmp.storager.dao.dto.User;
import com.genersoft.iot.vmp.utils.DateUtil;
+import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
import com.genersoft.iot.vmp.vmanager.bean.WVPResult;
import com.github.pagehelper.PageInfo;
@@ -18,6 +20,7 @@
import org.springframework.http.ResponseEntity;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.util.DigestUtils;
+import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
@@ -40,28 +43,21 @@
private IRoleService roleService;
@GetMapping("/login")
+ @PostMapping("/login")
@Operation(summary = "鐧诲綍")
@Parameter(name = "username", description = "鐢ㄦ埛鍚�", required = true)
@Parameter(name = "password", description = "瀵嗙爜锛�32浣峬d5鍔犲瘑锛�", required = true)
- public WVPResult<LoginUser> login(@RequestParam String username, @RequestParam String password){
+ public LoginUser login(@RequestParam String username, @RequestParam String password){
LoginUser user = null;
- WVPResult<LoginUser> result = new WVPResult<>();
try {
user = SecurityUtils.login(username, password, authenticationManager);
} catch (AuthenticationException e) {
- e.printStackTrace();
- result.setCode(-1);
- result.setMsg("fail");
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), e.getMessage());
}
- if (user != null) {
- result.setCode(0);
- result.setMsg("success");
- result.setData(user);
- }else {
- result.setCode(-1);
- result.setMsg("fail");
+ if (user == null) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "鐢ㄦ埛鍚嶆垨瀵嗙爜閿欒");
}
- return result;
+ return user;
}
@PostMapping("/changePassword")
@@ -69,27 +65,27 @@
@Parameter(name = "username", description = "鐢ㄦ埛鍚�", required = true)
@Parameter(name = "oldpassword", description = "鏃у瘑鐮侊紙宸瞞d5鍔犲瘑鐨勫瘑鐮侊級", required = true)
@Parameter(name = "password", description = "鏂板瘑鐮侊紙鏈猰d5鍔犲瘑鐨勫瘑鐮侊級", required = true)
- public String changePassword(@RequestParam String oldPassword, @RequestParam String password){
+ public void changePassword(@RequestParam String oldPassword, @RequestParam String password){
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
LoginUser userInfo = SecurityUtils.getUserInfo();
if (userInfo== null) {
- return "fail";
+ throw new ControllerException(ErrorCode.ERROR100);
}
String username = userInfo.getUsername();
LoginUser user = null;
try {
user = SecurityUtils.login(username, oldPassword, authenticationManager);
- if (user != null) {
- int userId = SecurityUtils.getUserId();
- boolean result = userService.changePassword(userId, DigestUtils.md5DigestAsHex(password.getBytes()));
- if (result) {
- return "success";
- }
+ if (user == null) {
+ throw new ControllerException(ErrorCode.ERROR100);
+ }
+ int userId = SecurityUtils.getUserId();
+ boolean result = userService.changePassword(userId, DigestUtils.md5DigestAsHex(password.getBytes()));
+ if (!result) {
+ throw new ControllerException(ErrorCode.ERROR100);
}
} catch (AuthenticationException e) {
- e.printStackTrace();
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), e.getMessage());
}
- return "fail";
}
@@ -98,22 +94,17 @@
@Parameter(name = "username", description = "鐢ㄦ埛鍚�", required = true)
@Parameter(name = "password", description = "瀵嗙爜锛堟湭md5鍔犲瘑鐨勫瘑鐮侊級", required = true)
@Parameter(name = "roleId", description = "瑙掕壊ID", required = true)
- public ResponseEntity<WVPResult<Integer>> add(@RequestParam String username,
+ public void add(@RequestParam String username,
@RequestParam String password,
@RequestParam Integer roleId){
- WVPResult<Integer> result = new WVPResult<>();
- if (StringUtils.isEmpty(username) || StringUtils.isEmpty(password) || roleId == null) {
- result.setCode(-1);
- result.setMsg("鍙傛暟涓嶅彲涓虹┖");
- return new ResponseEntity<>(null, HttpStatus.BAD_REQUEST);
+ if (ObjectUtils.isEmpty(username) || ObjectUtils.isEmpty(password) || roleId == null) {
+ throw new ControllerException(ErrorCode.ERROR400.getCode(), "鍙傛暟涓嶅彲涓虹┖");
}
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
int currenRoleId = SecurityUtils.getUserInfo().getRole().getId();
if (currenRoleId != 1) {
// 鍙敤瑙掕壊id涓�1鎵嶅彲浠ュ垹闄ゅ拰娣诲姞鐢ㄦ埛
- result.setCode(-1);
- result.setMsg("鐢ㄦ埛鏃犳潈闄�");
- return new ResponseEntity<>(result, HttpStatus.FORBIDDEN);
+ throw new ControllerException(ErrorCode.ERROR400.getCode(), "鐢ㄦ埛鏃犳潈闄�");
}
User user = new User();
user.setUsername(username);
@@ -123,53 +114,38 @@
Role role = roleService.getRoleById(roleId);
if (role == null) {
- result.setCode(-1);
- result.setMsg("roleId is not found");
- // 瑙掕壊涓嶅瓨鍦�
- return new ResponseEntity<>(result, HttpStatus.OK);
+ throw new ControllerException(ErrorCode.ERROR400.getCode(), "瑙掕壊涓嶅瓨鍦�");
}
user.setRole(role);
user.setCreateTime(DateUtil.getNow());
user.setUpdateTime(DateUtil.getNow());
int addResult = userService.addUser(user);
-
-
- result.setCode(addResult > 0 ? 0 : -1);
- result.setMsg(addResult > 0 ? "success" : "fail");
- result.setData(addResult);
- return new ResponseEntity<>(result, HttpStatus.OK);
+ if (addResult <= 0) {
+ throw new ControllerException(ErrorCode.ERROR100);
+ }
}
@DeleteMapping("/鍒犻櫎鐢ㄦ埛")
@Operation(summary = "鍋滄瑙嗛鍥炴斁")
@Parameter(name = "id", description = "鐢ㄦ埛Id", required = true)
- public ResponseEntity<WVPResult<String>> delete(@RequestParam Integer id){
+ public void delete(@RequestParam Integer id){
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
int currenRoleId = SecurityUtils.getUserInfo().getRole().getId();
- WVPResult<String> result = new WVPResult<>();
if (currenRoleId != 1) {
// 鍙敤瑙掕壊id涓�0鎵嶅彲浠ュ垹闄ゅ拰娣诲姞鐢ㄦ埛
- result.setCode(-1);
- result.setMsg("鐢ㄦ埛鏃犳潈闄�");
- return new ResponseEntity<>(result, HttpStatus.FORBIDDEN);
+ throw new ControllerException(ErrorCode.ERROR400.getCode(), "鐢ㄦ埛鏃犳潈闄�");
}
int deleteResult = userService.deleteUser(id);
-
- result.setCode(deleteResult>0? 0 : -1);
- result.setMsg(deleteResult>0? "success" : "fail");
- return new ResponseEntity<>(result, HttpStatus.OK);
+ if (deleteResult <= 0) {
+ throw new ControllerException(ErrorCode.ERROR100);
+ }
}
@GetMapping("/all")
@Operation(summary = "鏌ヨ鐢ㄦ埛")
- public ResponseEntity<WVPResult<List<User>>> all(){
+ public List<User> all(){
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
- List<User> allUsers = userService.getAllUsers();
- WVPResult<List<User>> result = new WVPResult<>();
- result.setCode(0);
- result.setMsg("success");
- result.setData(allUsers);
- return new ResponseEntity<>(result, HttpStatus.OK);
+ return userService.getAllUsers();
}
/**
@@ -191,21 +167,18 @@
@Operation(summary = "淇敼pushkey")
@Parameter(name = "userId", description = "鐢ㄦ埛Id", required = true)
@Parameter(name = "pushKey", description = "鏂扮殑pushKey", required = true)
- public ResponseEntity<WVPResult<String>> changePushKey(@RequestParam Integer userId,@RequestParam String pushKey) {
+ public void changePushKey(@RequestParam Integer userId,@RequestParam String pushKey) {
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
int currenRoleId = SecurityUtils.getUserInfo().getRole().getId();
WVPResult<String> result = new WVPResult<>();
if (currenRoleId != 1) {
// 鍙敤瑙掕壊id涓�0鎵嶅彲浠ュ垹闄ゅ拰娣诲姞鐢ㄦ埛
- result.setCode(-1);
- result.setMsg("鐢ㄦ埛鏃犳潈闄�");
- return new ResponseEntity<>(result, HttpStatus.FORBIDDEN);
+ throw new ControllerException(ErrorCode.ERROR400.getCode(), "鐢ㄦ埛鏃犳潈闄�");
}
int resetPushKeyResult = userService.changePushKey(userId,pushKey);
-
- result.setCode(resetPushKeyResult > 0 ? 0 : -1);
- result.setMsg(resetPushKeyResult > 0 ? "success" : "fail");
- return new ResponseEntity<>(result, HttpStatus.OK);
+ if (resetPushKeyResult <= 0) {
+ throw new ControllerException(ErrorCode.ERROR100);
+ }
}
@PostMapping("/changePasswordForAdmin")
@@ -213,20 +186,18 @@
@Parameter(name = "adminId", description = "绠＄悊鍛榠d", required = true)
@Parameter(name = "userId", description = "鐢ㄦ埛id", required = true)
@Parameter(name = "password", description = "鏂板瘑鐮侊紙鏈猰d5鍔犲瘑鐨勫瘑鐮侊級", required = true)
- public String changePasswordForAdmin(@RequestParam int userId, @RequestParam String password) {
+ public void changePasswordForAdmin(@RequestParam int userId, @RequestParam String password) {
// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id
LoginUser userInfo = SecurityUtils.getUserInfo();
if (userInfo == null) {
- return "fail";
+ throw new ControllerException(ErrorCode.ERROR100);
}
Role role = userInfo.getRole();
if (role != null && role.getId() == 1) {
boolean result = userService.changePassword(userId, DigestUtils.md5DigestAsHex(password.getBytes()));
- if (result) {
- return "success";
+ if (!result) {
+ throw new ControllerException(ErrorCode.ERROR100);
}
}
-
- return "fail";
}
}
--
Gitblit v1.8.0