22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 1 | package com.pt.controller; |
| 2 | |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 3 | import com.pt.constant.Constants; |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 4 | import com.pt.entity.User; |
22301102 | d526daa | 2025-06-07 10:53:27 +0800 | [diff] [blame] | 5 | import com.pt.service.InvitedCodeService; |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 6 | import com.pt.utils.JWTUtils; |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 7 | import org.springframework.beans.factory.annotation.Autowired; |
| 8 | import org.springframework.http.ResponseEntity; |
| 9 | import org.springframework.web.bind.annotation.*; |
| 10 | import com.pt.service.UserService; |
| 11 | |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 12 | import java.util.HashMap; |
| 13 | import java.util.Map; |
| 14 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 15 | @RestController |
| 16 | @RequestMapping("/api/user") |
| 17 | @CrossOrigin(origins = "*") |
| 18 | public class UserController { |
| 19 | |
| 20 | @Autowired |
| 21 | private UserService userService; |
22301102 | d526daa | 2025-06-07 10:53:27 +0800 | [diff] [blame] | 22 | private InvitedCodeService invitedCodeService; |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 23 | |
| 24 | @PostMapping("/register") |
yyyang | 502ab1d | 2025-06-03 16:40:59 +0800 | [diff] [blame] | 25 | public ResponseEntity<?> registerUser(@RequestBody Map<String, String> request) { |
| 26 | String username = request.get("username"); |
| 27 | String password = request.get("password"); |
| 28 | String email = request.get("email"); |
| 29 | |
| 30 | if (username == null || password == null || email == null) { |
| 31 | return ResponseEntity.badRequest().body("Missing required fields"); |
| 32 | } |
| 33 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 34 | User user = userService.findByUsername(username); |
| 35 | if (user != null) { |
| 36 | return ResponseEntity.badRequest().body("User already exists"); |
| 37 | } else { |
| 38 | User newUser = new User(); |
| 39 | |
22301102 | d526daa | 2025-06-07 10:53:27 +0800 | [diff] [blame] | 40 | if(request.get("invitedCode") != null) { |
| 41 | String invitedCode = request.get("invitedCode"); |
| 42 | if (!invitedCodeService.isCodeValid(invitedCode)) { |
| 43 | return ResponseEntity.badRequest().body("Invalid invited code"); |
| 44 | } |
| 45 | else { |
| 46 | newUser.setLevel(Constants.UserLevel.FRESH.getValue()); |
| 47 | newUser.setPoints(300); |
| 48 | } |
| 49 | } |
| 50 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 51 | String uid = String.valueOf(System.currentTimeMillis()); |
| 52 | newUser.setUid(uid); |
| 53 | newUser.setUsername(username); |
| 54 | newUser.setPassword(password); |
| 55 | newUser.setEmail(email); |
| 56 | userService.save(newUser); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 57 | |
| 58 | Map<String, Object> ans = new HashMap<>(); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 59 | ans.put("message", "User registered successfully"); |
yyyang | 502ab1d | 2025-06-03 16:40:59 +0800 | [diff] [blame] | 60 | ans.put("data", newUser); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 61 | |
| 62 | return ResponseEntity.ok().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 63 | } |
| 64 | } |
| 65 | |
| 66 | @PostMapping("/login") |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 67 | public ResponseEntity<?> loginUser(@RequestBody Map<String, String> request) { |
| 68 | String username = request.get("username"); |
| 69 | String password = request.get("password"); |
yyyang | 502ab1d | 2025-06-03 16:40:59 +0800 | [diff] [blame] | 70 | |
| 71 | if (username == null || password == null) { |
| 72 | return ResponseEntity.badRequest().body("Missing username or password"); |
| 73 | } |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 74 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 75 | User user = userService.findByUsernameAndPassword(username, password); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 76 | Map<String, Object> ans = new HashMap<>(); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 77 | if (user != null) { |
yyyang | 502ab1d | 2025-06-03 16:40:59 +0800 | [diff] [blame] | 78 | String token = JWTUtils.generateToken(username, Constants.UserRole.USER, Constants.DEFAULT_EXPIRE_TIME); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 79 | ans.put("message", "Login successful"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 80 | ans.put("data", token); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 81 | return ResponseEntity.ok().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 82 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 83 | ans.put("message", "Invalid username or password"); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 84 | return ResponseEntity.badRequest().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 85 | } |
| 86 | } |
| 87 | |
| 88 | @PostMapping("/update/username") |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 89 | public ResponseEntity<?> updateUsername(@RequestHeader("token") String token, |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 90 | @RequestBody Map<String, String> request) { |
| 91 | String oldUsername = request.get("username"); |
| 92 | String newUsername = request.get("newUsername"); |
| 93 | |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 94 | Map<String, Object> ans = new HashMap<>(); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 95 | if(!JWTUtils.checkToken(token, oldUsername, Constants.UserRole.USER)) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 96 | ans.put("message", "Invalid token"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 97 | return ResponseEntity.badRequest().body(ans); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 98 | } |
| 99 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 100 | User user = userService.findByUsername(oldUsername); |
| 101 | if (user != null) { |
| 102 | user.setUsername(newUsername); |
| 103 | userService.save(user); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 104 | ans.put("message", "Username updated successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 105 | return ResponseEntity.ok(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 106 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 107 | ans.put("message", "User not found"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 108 | return ResponseEntity.badRequest().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 109 | } |
| 110 | } |
| 111 | |
| 112 | @PostMapping("/update/password") |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 113 | public ResponseEntity<?> updatePassword(@RequestHeader("token") String token, |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 114 | @RequestBody Map<String, String> request |
| 115 | ) { |
| 116 | String username = request.get("username"); |
| 117 | String newPassword = request.get("newPassword"); |
| 118 | |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 119 | Map<String, Object> ans = new HashMap<>(); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 120 | if(!JWTUtils.checkToken(token, username, Constants.UserRole.USER)) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 121 | ans.put("message", "Invalid token"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 122 | return ResponseEntity.badRequest().body(ans); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 123 | } |
| 124 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 125 | User user = userService.findByUsername(username); |
| 126 | if (user != null) { |
| 127 | user.setPassword(newPassword); |
| 128 | userService.save(user); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 129 | ans.put("message", "Password updated successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 130 | return ResponseEntity.ok(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 131 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 132 | ans.put("message", "Invalid username or password"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 133 | return ResponseEntity.badRequest().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 134 | } |
| 135 | } |
| 136 | |
| 137 | @PostMapping("/update/email") |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 138 | public ResponseEntity<?> updateEmail(@RequestHeader("token") String token, |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 139 | @RequestBody Map<String, String> request) { |
| 140 | String username = request.get("username"); |
| 141 | String newEmail = request.get("newEmail"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 142 | |
| 143 | Map<String, Object> ans = new HashMap<>(); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 144 | if(!JWTUtils.checkToken(token, username, Constants.UserRole.USER)) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 145 | ans.put("message", "Invalid token"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 146 | return ResponseEntity.badRequest().body(ans); |
22301102 | 1019856 | 2025-05-17 16:27:12 +0800 | [diff] [blame] | 147 | } |
| 148 | |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 149 | User user = userService.findByUsername(username); |
| 150 | if (user != null) { |
| 151 | user.setEmail(newEmail); |
| 152 | userService.save(user); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 153 | ans.put("message", "Email updated successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 154 | return ResponseEntity.ok(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 155 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 156 | ans.put("message", "User not found"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 157 | return ResponseEntity.badRequest().body(ans); |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 158 | } |
| 159 | } |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 160 | |
| 161 | @DeleteMapping("/delete") |
| 162 | public ResponseEntity<?> deleteUser(@RequestHeader("token") String token, |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 163 | @RequestBody Map<String, String> request) { |
| 164 | String username = request.get("username"); |
| 165 | String targetUsername = request.get("targetUsername"); |
| 166 | |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 167 | Map<String, Object> ans = new HashMap<>(); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 168 | if(!JWTUtils.checkToken(token, username, Constants.UserRole.ADMIN)) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 169 | ans.put("message", "Invalid token"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 170 | return ResponseEntity.badRequest().body(ans); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 171 | } |
| 172 | |
| 173 | User user = userService.findByUsername(targetUsername); |
| 174 | if (user != null) { |
| 175 | userService.deleteById(user.getUid()); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 176 | ans.put("message", "User deleted successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 177 | return ResponseEntity.ok(ans); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 178 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 179 | ans.put("message", "User not found"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 180 | return ResponseEntity.badRequest().body(ans); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 181 | } |
| 182 | } |
| 183 | |
| 184 | @GetMapping("/list") |
| 185 | public ResponseEntity<?> listUsers(@RequestHeader("token") String token, |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 186 | @RequestBody Map<String, String> request) { |
| 187 | String username = request.get("username"); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 188 | if(!JWTUtils.checkToken(token, username, Constants.UserRole.ADMIN)) { |
| 189 | return ResponseEntity.badRequest().body("Invalid token"); |
| 190 | } |
| 191 | |
| 192 | Map<String, Object> ans = new HashMap<>(); |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 193 | ans.put("message", "User list retrieved successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 194 | ans.put("data", Map.of( |
| 195 | "amount", userService.listAll().size(), |
| 196 | "users", userService.listAll() |
| 197 | )); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 198 | return ResponseEntity.ok(ans); |
| 199 | } |
| 200 | |
| 201 | @GetMapping("/get/info") |
| 202 | public ResponseEntity<?> getUserInfo(@RequestHeader("token") String token, |
| 203 | @RequestParam("username") String username) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 204 | |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 205 | Map<String, Object> ans = new HashMap<>(); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 206 | if(!JWTUtils.checkToken(token, username, Constants.UserRole.USER)) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 207 | ans.put("message", "Invalid token"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 208 | return ResponseEntity.badRequest().body(ans); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 209 | } |
| 210 | |
| 211 | User user = userService.findByUsername(username); |
| 212 | if (user != null) { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 213 | ans.put("message", "User info retrieved successfully"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 214 | ans.put("data", user); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 215 | return ResponseEntity.ok(ans); |
| 216 | } else { |
22301102 | f69709e | 2025-06-08 14:10:02 +0800 | [diff] [blame] | 217 | ans.put("message", "User not found"); |
22301102 | aadb0ac | 2025-06-05 18:02:21 +0800 | [diff] [blame] | 218 | return ResponseEntity.badRequest().body(ans); |
22301102 | aa5adbc | 2025-05-18 17:51:55 +0800 | [diff] [blame] | 219 | } |
| 220 | } |
22301102 | e0c7c6e | 2025-05-17 11:08:45 +0800 | [diff] [blame] | 221 | } |