| package com.g9.g9backend.controller; |
| |
| import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| import com.baomidou.mybatisplus.core.metadata.IPage; |
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| import com.g9.g9backend.pojo.*; |
| import com.g9.g9backend.pojo.DTO.*; |
| import com.g9.g9backend.pojo.Thread; |
| import com.g9.g9backend.service.*; |
| import org.slf4j.Logger; |
| import org.slf4j.LoggerFactory; |
| import org.springframework.http.HttpStatus; |
| import org.springframework.http.ResponseEntity; |
| import org.springframework.web.bind.annotation.*; |
| |
| import java.util.ArrayList; |
| import java.util.List; |
| |
| /** |
| * UserController 用户控制器类，处理与用户相关的请求 |
| * |
| * @author hcy |
| */ |
| @RestController |
| @RequestMapping("/user") |
| public class UserController { |
| |
| private final UserService userService; |
| |
| private final InvitationService invitationService; |
| |
| private final SubscriptionService subscriptionService; |
| |
| private final SearchHistoryService searchHistoryService; |
| |
| private final RewardService rewardService; |
| |
| private final UserCollectionService userCollectionService; |
| |
| private final UserUploadService userUploadService; |
| |
| private final UserPurchaseService userPurchaseService; |
| |
| private final ResourceService resourceService; |
| |
| private final ThreadService threadService; |
| |
| private final GameplayService gameplayService; |
| |
| private final ResourceVersionService resourceVersionService; |
| |
| private final GameVersionService gameVersionService; |
| |
| private final TorrentRecordService torrentRecordService; |
| |
| public UserController(UserService userService, InvitationService invitationService, SubscriptionService subscriptionService, SearchHistoryService searchHistoryService, RewardService rewardService, UserCollectionService userCollectionService, UserUploadService userUploadService, UserPurchaseService userPurchaseService, ResourceService resourceService, ThreadService threadService, GameplayService gameplayService, ResourceVersionService resourceVersionService, GameVersionService gameVersionService, TorrentRecordService torrentRecordService) { |
| this.userService = userService; |
| this.invitationService = invitationService; |
| this.subscriptionService = subscriptionService; |
| this.searchHistoryService = searchHistoryService; |
| this.rewardService = rewardService; |
| this.userCollectionService = userCollectionService; |
| this.userUploadService = userUploadService; |
| this.userPurchaseService = userPurchaseService; |
| this.resourceService = resourceService; |
| this.threadService = threadService; |
| this.gameplayService = gameplayService; |
| this.resourceVersionService = resourceVersionService; |
| this.gameVersionService = gameVersionService; |
| this.torrentRecordService = torrentRecordService; |
| } |
| |
| |
| private final Logger logger = LoggerFactory.getLogger(UserController.class); |
| |
| /** |
| * 用户注册 |
| * |
| * @param registerDTO 用户注册 |
| * @return 注册结果 |
| */ |
| @PostMapping("/register") |
| public ResponseEntity<String> register(@RequestBody RegisterDTO registerDTO) { |
| String username = registerDTO.getUsername(); |
| String password = registerDTO.getPassword(); |
| String invitationCode = registerDTO.getInvitationCode(); |
| logger.info("Register request received for account: {}", username); |
| |
| // 根据用户名查询该用户名是否已存在 |
| QueryWrapper<User> userQuery = new QueryWrapper<>(); |
| userQuery.eq("username", username); |
| User userCheck = userService.getOne(userQuery); |
| |
| if (userCheck != null) { |
| // 用户名重复 |
| logger.warn("Registration attempt failed. Account already exists: {}", username); |
| return ResponseEntity.status(412).body(""); |
| } |
| |
| // 查询邀请码是否存在 |
| QueryWrapper<Invitation> invitationQuery = new QueryWrapper<>(); |
| invitationQuery.eq("invitation_code", invitationCode); |
| Invitation invitation = invitationService.getOne(invitationQuery); |
| |
| if (invitation == null) { |
| // 邀请码不存在 |
| logger.info("The invitation code does not exist: {}", invitationCode); |
| return ResponseEntity.status(409).body(""); |
| } else if (invitation.getInviteeId() != 0) { |
| // 邀请码已被使用 |
| logger.info("The invitation code has been used: {}", invitationCode); |
| return ResponseEntity.status(410).body(""); |
| } |
| // 注册 |
| // 添加新用户 |
| User user = new User(); |
| user.setUsername(username); |
| user.setPassword(password); |
| userService.save(user); |
| |
| // 设置该邀请码已被使用 |
| User userGetId = userService.getOne(userQuery); |
| int newUserId = userGetId.getUserId(); |
| |
| UpdateWrapper<Invitation> invitationUpdate = new UpdateWrapper<>(); |
| invitationUpdate.eq("invitation_code", invitationCode).set("invitee_id", newUserId); |
| invitationService.update(invitationUpdate); |
| |
| // 生成五个邀请码并分配给新用户 |
| String[] invitationCodes = invitationService.generateInvitationCode(); |
| |
| for (String code : invitationCodes) { |
| Invitation newInvitation = new Invitation(); |
| newInvitation.setInvitationCode(code); |
| newInvitation.setUserId(newUserId); |
| invitationService.save(newInvitation); |
| } |
| |
| logger.info("User registered successfully: {}", username); |
| return ResponseEntity.ok(""); |
| } |
| |
| /** |
| * 用户登录 |
| * |
| * @param user 登录信息 |
| * @return 登录结果 |
| */ |
| @PostMapping("/login") |
| public ResponseEntity<String> login(@RequestBody User user) { |
| String username = user.getUsername(); |
| String password = user.getPassword(); |
| logger.info("Login attempt for account: {}", username); |
| |
| // 根据用户名查询该用户名是否已存在 |
| QueryWrapper<User> userQuery = new QueryWrapper<>(); |
| userQuery.eq("username", username); |
| User userCheck = userService.getOne(userQuery); |
| |
| if (userCheck == null) { |
| // 用户名不存在 |
| logger.warn("Login failed. User not found: {}", username); |
| return ResponseEntity.status(406).body(""); |
| } else { |
| if (userCheck.getPassword().equals(password)) { |
| return ResponseEntity.ok(""); |
| } else { |
| // 密码错误 |
| logger.warn("Login failed. Incorrect password for account: {}", username); |
| return ResponseEntity.status(408).body(""); |
| } |
| } |
| } |
| |
| /** |
| * 关注 |
| * |
| * @param subscription 关注信息 |
| * @return 关注结果 |
| */ |
| @PostMapping("/subscription") |
| public ResponseEntity<String> subscription(@RequestBody Subscription subscription) { |
| subscriptionService.save(subscription); |
| return ResponseEntity.ok(""); |
| } |
| |
| /** |
| * 注销账户 |
| * |
| * @param userId 用户id |
| * @param password 密码 |
| * @return 注销结果 |
| */ |
| @DeleteMapping |
| @ResponseStatus(HttpStatus.NO_CONTENT) |
| public ResponseEntity<String> userDelete(@RequestParam int userId, @RequestParam String password) { |
| logger.warn("Delete user with id: {}", userId); |
| // 根据用户id查询该用户 |
| QueryWrapper<User> userQuery = new QueryWrapper<>(); |
| userQuery.eq("user_id", userId); |
| User userCheck = userService.getOne(userQuery); |
| |
| if (userCheck.getPassword().equals(password)) { |
| // 注销账户（自动清除与该用户相关的记录，注意会回收分配给该用户的邀请码） |
| userService.remove(userQuery); |
| |
| return ResponseEntity.noContent().build(); |
| } else { |
| logger.warn("Delete failed. Incorrect password for account: {}", password); |
| return ResponseEntity.status(408).body(""); |
| } |
| } |
| |
| /** |
| * 删除用户搜索历史 |
| * |
| * @param searchHistoryId 搜索历史id |
| * @return 删除用户搜索历史结果 |
| */ |
| @DeleteMapping("/search") |
| @ResponseStatus(HttpStatus.NO_CONTENT) |
| public ResponseEntity<String> searchDelete(@RequestParam int searchHistoryId) { |
| searchHistoryService.removeById(searchHistoryId); |
| return ResponseEntity.noContent().build(); |
| } |
| |
| /** |
| * 取消关注 |
| * |
| * @param userId 被关注者id |
| * @param followerId 关注被人者id |
| * @return 取消关注结果 |
| */ |
| @DeleteMapping("/subscription") |
| @ResponseStatus(HttpStatus.NO_CONTENT) |
| public ResponseEntity<String> subscriptionDelete(@RequestParam int userId, @RequestParam int followerId) { |
| QueryWrapper<Subscription> subscriptionQuery = new QueryWrapper<>(); |
| subscriptionQuery.eq("user_id", userId).eq("follower_id", followerId); |
| subscriptionService.remove(subscriptionQuery); |
| return ResponseEntity.noContent().build(); |
| } |
| |
| |
| /** |
| * 获取用户ID |
| * |
| * @param username 用户名 |
| * @param password 密码 |
| * @return 获取邀请码结果 |
| */ |
| @GetMapping("/getId") |
| public ResponseEntity<Integer> getUserId(@RequestParam String username, @RequestParam String password) { |
| QueryWrapper<User> userQuery = new QueryWrapper<>(); |
| userQuery.eq("username", username).eq("password", password); |
| User user = userService.getOne(userQuery); |
| return ResponseEntity.ok(user.getUserId()); |
| } |
| |
| /** |
| * 获取邀请码 |
| * |
| * @param userId 用户id |
| * @return 获取邀请码结果 |
| */ |
| @GetMapping("/invitation-code") |
| public ResponseEntity<GetInvitationCodeDTO> getInvitationCode(@RequestParam int userId) { |
| QueryWrapper<Invitation> invitationQuery = new QueryWrapper<>(); |
| invitationQuery.eq("user_id", userId).eq("invitee_id", 0); // 获取未被使用过的分配给该用户的邀请码 |
| invitationQuery.select("invitation_code"); |
| List<Invitation> invitationList = invitationService.list(invitationQuery); |
| GetInvitationCodeDTO getInvitationCodeDTO = new GetInvitationCodeDTO(invitationList); |
| return ResponseEntity.ok(getInvitationCodeDTO); |
| } |
| |
| /** |
| * 获取用户信息 |
| * |
| * @param userId 用户id |
| * @return 获取用户信息结果 |
| */ |
| @GetMapping("/info") |
| public ResponseEntity<User> getUserInfo(@RequestParam int userId) { |
| User user = userService.getById(userId); |
| return ResponseEntity.ok(user); |
| } |
| |
| /** |
| * 获取用户悬赏 |
| * |
| * @param userId 用户id |
| * @param pageNumber 页数 |
| * @param rows 行数 |
| * @return 获取用户悬赏结果 |
| */ |
| @GetMapping("/reward") |
| public ResponseEntity<GetUserRewardDTO> getUserReward(@RequestParam int userId, @RequestParam int pageNumber, @RequestParam int rows) { |
| IPage<Reward> page = new Page<>(pageNumber, rows); |
| QueryWrapper<Reward> rewardQuery = new QueryWrapper<>(); |
| rewardQuery.eq("user_id", userId); |
| IPage<Reward> rewardPage = rewardService.page(page, rewardQuery); |
| List<Reward> rewardList = rewardPage.getRecords(); |
| long total = rewardPage.getTotal(); |
| long pages = rewardPage.getPages(); |
| long current = rewardPage.getCurrent(); |
| long size = rewardPage.getSize(); |
| |
| GetUserRewardDTO getUserRewardDTO = new GetUserRewardDTO(rewardList, total, pages, current, size); |
| return ResponseEntity.ok(getUserRewardDTO); |
| } |
| |
| /** |
| * 获取用户收藏资源 |
| * |
| * @param userId 用户id |
| * @param pageNumber 页数 |
| * @param rows 行数 |
| * @return 获取用户收藏结果 |
| */ |
| @GetMapping("/collection") |
| public ResponseEntity<GetUserResourceListDTO> getUserCollection(@RequestParam int userId, @RequestParam int pageNumber, @RequestParam int rows) { |
| IPage<UserCollection> page = new Page<>(pageNumber, rows); |
| QueryWrapper<UserCollection> userCollectionQuery = new QueryWrapper<>(); |
| userCollectionQuery.eq("user_id", userId); |
| IPage<UserCollection> userCollectionPage = userCollectionService.page(page, userCollectionQuery); |
| List<UserCollection> resourceList = userCollectionPage.getRecords(); |
| List<Resource> collectionList = new ArrayList<>(); |
| for (UserCollection userCollection : resourceList) { |
| Resource resource = resourceService.getById(userCollection.getResourceId()); |
| collectionList.add(resource); |
| } |
| long total = userCollectionPage.getTotal(); |
| long pages = userCollectionPage.getPages(); |
| long current = userCollectionPage.getCurrent(); |
| long size = userCollectionPage.getSize(); |
| |
| GetUserResourceListDTO getUserResourceListDTO = new GetUserResourceListDTO(collectionList, total, pages, current, size); |
| return ResponseEntity.ok(getUserResourceListDTO); |
| } |
| |
| /** |
| * 获取用户上传资源 |
| * |
| * @param userId 用户id |
| * @param pageNumber 页数 |
| * @param rows 行数 |
| * @return 获取用户上传资源结果 |
| */ |
| @GetMapping("/upload") |
| public ResponseEntity<GetUserResourceListDTO> getUserUpload(@RequestParam int userId, @RequestParam int pageNumber, @RequestParam int rows) { |
| IPage<UserUpload> page = new Page<>(pageNumber, rows); |
| QueryWrapper<UserUpload> userUploadQuery = new QueryWrapper<>(); |
| userUploadQuery.eq("user_id", userId); |
| IPage<UserUpload> userUploadPage = userUploadService.page(page, userUploadQuery); |
| List<UserUpload> resourceList = userUploadPage.getRecords(); |
| List<Resource> uploadList = new ArrayList<>(); |
| for (UserUpload userUpload : resourceList) { |
| Resource resource = resourceService.getById(userUpload.getResourceId()); |
| uploadList.add(resource); |
| } |
| long total = userUploadPage.getTotal(); |
| long pages = userUploadPage.getPages(); |
| long current = userUploadPage.getCurrent(); |
| long size = userUploadPage.getSize(); |
| |
| GetUserResourceListDTO getUserResourceListDTO = new GetUserResourceListDTO(uploadList, total, pages, current, size); |
| return ResponseEntity.ok(getUserResourceListDTO); |
| } |
| |
| /** |
| * 获取用户购买资源 |
| * |
| * @param userId 用户id |
| * @param pageNumber 页数 |
| * @param rows 行数 |
| * @return 获取用户购买资源结果 |
| */ |
| @GetMapping("/purchase") |
| public ResponseEntity<GetUserPurchaseDTO> getUserPurchase(@RequestParam int userId, @RequestParam int pageNumber, @RequestParam int rows) { |
| IPage<UserPurchase> page = new Page<>(pageNumber, rows); |
| QueryWrapper<UserPurchase> userPurchaseQuery = new QueryWrapper<>(); |
| userPurchaseQuery.eq("user_id", userId); |
| IPage<UserPurchase> userPurchasePage = userPurchaseService.page(page, userPurchaseQuery); |
| List<UserPurchase> resourceList = userPurchasePage.getRecords(); |
| List<Resource> purchaseList = new ArrayList<>(); |
| for (UserPurchase userPurchase : resourceList) { |
| Resource resource = resourceService.getById(userPurchase.getResourceId()); |
| purchaseList.add(resource); |
| } |
| List<Resource> resources = purchaseList; |
| List<List<Gameplay>> gameplays = new ArrayList<>(); |
| List<List<ResourceVersion>> resourceVersions = new ArrayList<>(); |
| List<List<List<GameVersion>>> gameVersion = new ArrayList<>(); |
| List<List<List<TorrentRecord>>> torrentRecord = new ArrayList<>(); |
| |
| for (Resource resource : purchaseList) { |
| int resourceId = resource.getResourceId(); |
| // 获取Gameplay列表 |
| List<Gameplay> gameplayList = gameplayService.list(new QueryWrapper<Gameplay>().eq("resource_id", resourceId)); |
| |
| // 获取ResourceVersion列表 |
| List<ResourceVersion> resourceVersionList = resourceVersionService.list(new QueryWrapper<ResourceVersion>().eq("resource_id", resourceId)); |
| |
| // 获取GameVersion二维列表 |
| List<List<GameVersion>> gameVersionLists = new ArrayList<>(); |
| for (ResourceVersion resourceVersion : resourceVersionList) { |
| List<GameVersion> gameVersionList = gameVersionService.list(new QueryWrapper<GameVersion>().eq("resource_version_id", resourceVersion.getResourceVersionId())); |
| gameVersionLists.add(gameVersionList); |
| } |
| |
| // 获取TorrentRecord二维列表 |
| List<List<TorrentRecord>> torrentRecordLists = new ArrayList<>(); |
| for (ResourceVersion resourceVersion : resourceVersionList) { |
| List<TorrentRecord> torrentRecordList = torrentRecordService.list(new QueryWrapper<TorrentRecord>().eq("resource_version_id", resourceVersion.getResourceVersionId())); |
| torrentRecordLists.add(torrentRecordList); |
| } |
| |
| gameplays.add(gameplayList); |
| resourceVersions.add(resourceVersionList); |
| gameVersion.add(gameVersionLists); |
| torrentRecord.add(torrentRecordLists); |
| } |
| long total = userPurchasePage.getTotal(); |
| long pages = userPurchasePage.getPages(); |
| long current = userPurchasePage.getCurrent(); |
| long size = userPurchasePage.getSize(); |
| |
| GetUserPurchaseDTO getUserPurchaseDTO = new GetUserPurchaseDTO(resources, gameplays, resourceVersions, gameVersion, torrentRecord, total, pages, current, size); |
| return ResponseEntity.ok(getUserPurchaseDTO); |
| } |
| |
| /** |
| * 获取用户搜索历史 |
| * |
| * @param userId 用户id |
| * @return 获取用户搜索历史结果 |
| */ |
| @GetMapping("/search") |
| public ResponseEntity<GetUserSearchHistoryDTO> getUserSearchHistory(@RequestParam int userId) { |
| QueryWrapper<SearchHistory> SearchHistoryQuery = new QueryWrapper<>(); |
| SearchHistoryQuery.eq("user_id", userId).orderByDesc("search_history_id").last("LIMIT 10"); |
| List<SearchHistory> searchHistoryList = searchHistoryService.list(SearchHistoryQuery); |
| |
| GetUserSearchHistoryDTO getUserSearchHistoryDTO = new GetUserSearchHistoryDTO(searchHistoryList); |
| return ResponseEntity.ok(getUserSearchHistoryDTO); |
| } |
| |
| /** |
| * 获取用户发布贴子 |
| * |
| * @param userId 用户id |
| * @param pageNumber 页数 |
| * @param rows 行数 |
| * @return 获取用户发布贴子结果 |
| */ |
| @GetMapping("/thread") |
| public ResponseEntity<GetUserThreadListDTO> getUserThread(@RequestParam int userId, @RequestParam int pageNumber, @RequestParam int rows) { |
| IPage<Thread> page = new Page<>(pageNumber, rows); |
| QueryWrapper<Thread> threadQuery = new QueryWrapper<>(); |
| threadQuery.eq("user_id", userId); |
| IPage<Thread> threadPage = threadService.page(page, threadQuery); |
| List<Thread> threadList = threadPage.getRecords(); |
| long total = threadPage.getTotal(); |
| long pages = threadPage.getPages(); |
| long current = threadPage.getCurrent(); |
| long size = threadPage.getSize(); |
| |
| GetUserThreadListDTO getUserThreadListDTO = new GetUserThreadListDTO(threadList, total, pages, current, size); |
| return ResponseEntity.ok(getUserThreadListDTO); |
| } |
| |
| /** |
| * 获取用户数据 |
| * |
| * @param userId 用户id |
| * @return 获取用户数据结果 |
| */ |
| @GetMapping("/data") |
| public ResponseEntity<GetUserDataDTO> getUserData(@RequestParam int userId) { |
| User user = userService.getById(userId); |
| int subscriberCount = user.getSubscriberCount(); |
| int uploadAmount = user.getUploadAmount(); |
| |
| QueryWrapper<UserUpload> UserUploadQuery = new QueryWrapper<>(); |
| UserUploadQuery.eq("user_id", userId); |
| List<UserUpload> UserUpload = userUploadService.list(UserUploadQuery); |
| int beDownloadedAmount = 0; // 上传资源被下载量 |
| float[] seedPercentageList = new float[4]; // 上传资源类型百分比，0-1区间的小数 |
| int resourcePackAmount = 0; |
| int modAmount = 0; |
| int modPackAmount = 0; |
| int mapAmount = 0; |
| for (UserUpload userUpload : UserUpload) { |
| Resource resource = resourceService.getById(userUpload.getResourceId()); |
| beDownloadedAmount += resource.getDownloads(); |
| switch (resource.getClassify()) { |
| case "resourcePack": |
| resourcePackAmount++; |
| break; |
| case "mod": |
| modAmount++; |
| break; |
| case "modPack": |
| modPackAmount++; |
| break; |
| case "map": |
| mapAmount++; |
| break; |
| } |
| } |
| int totalAmount = resourcePackAmount + modAmount + modPackAmount + mapAmount; |
| seedPercentageList[0] = (float) resourcePackAmount / totalAmount; |
| seedPercentageList[1] = (float) modAmount / totalAmount; |
| seedPercentageList[2] = (float) modPackAmount / totalAmount; |
| seedPercentageList[3] = (float) mapAmount / totalAmount; |
| |
| GetUserDataDTO getUserDataDTO = new GetUserDataDTO(subscriberCount, uploadAmount, beDownloadedAmount, seedPercentageList); |
| return ResponseEntity.ok(getUserDataDTO); |
| } |
| |
| /** |
| * 获取关注列表 |
| * |
| * @param userId 用户id |
| * @return 获取关注列表结果 |
| */ |
| @GetMapping("/subscriber") |
| public ResponseEntity<GetUserDTO> getUserSubscriber(@RequestParam int userId) { |
| QueryWrapper<Subscription> subscriptionQuery = new QueryWrapper<>(); |
| subscriptionQuery.eq("follower_id", userId); |
| List<Subscription> subscriptionList = subscriptionService.list(subscriptionQuery); |
| |
| List<User> subscriberList = new ArrayList<>(); |
| for (Subscription subscription : subscriptionList) { |
| User user = userService.getById(subscription.getUserId()); |
| subscriberList.add(user); |
| } |
| |
| GetUserDTO getUserDTO = new GetUserDTO(subscriberList); |
| return ResponseEntity.ok(getUserDTO); |
| } |
| |
| /** |
| * 获取粉丝列表 |
| * |
| * @param userId 用户id |
| * @return 获取粉丝列表结果 |
| */ |
| @GetMapping("/follower") |
| public ResponseEntity<GetUserDTO> getUserFollower(@RequestParam int userId) { |
| QueryWrapper<Subscription> subscriptionQuery = new QueryWrapper<>(); |
| subscriptionQuery.eq("user_id", userId); |
| List<Subscription> subscriptionList = subscriptionService.list(subscriptionQuery); |
| |
| List<User> subscriberList = new ArrayList<>(); |
| for (Subscription subscription : subscriptionList) { |
| User user = userService.getById(subscription.getUserId()); |
| subscriberList.add(user); |
| } |
| |
| GetUserDTO getUserDTO = new GetUserDTO(subscriberList); |
| return ResponseEntity.ok(getUserDTO); |
| } |
| |
| /** |
| * 修改用户签名 |
| * |
| * @param user 用户信息 |
| * @return 用户签名修改结果 |
| */ |
| @PutMapping("/signature") |
| public ResponseEntity<String> modifySignature(@RequestBody User user) { |
| UpdateWrapper<User> userUpdate = new UpdateWrapper<>(); |
| userUpdate.eq("user_id", user.getUserId()).set("signature", user.getSignature()); |
| userService.update(userUpdate); |
| |
| return ResponseEntity.ok(""); |
| } |
| |
| /** |
| * 修改用户密码 |
| * |
| * @param modifyPasswordDTO 用户信息 |
| * @return 用户密码修改结果 |
| */ |
| @PutMapping("/password") |
| public ResponseEntity<String> modifyPassword(@RequestBody ModifyPasswordDTO modifyPasswordDTO) { |
| // 检查密码是否正确 |
| QueryWrapper<User> userQuery = new QueryWrapper<>(); |
| userQuery.eq("user_id", modifyPasswordDTO.getUserId()); |
| User user = userService.getOne(userQuery); |
| if (user.getPassword().equals(modifyPasswordDTO.getPassword())) { |
| UpdateWrapper<User> userUpdate = new UpdateWrapper<>(); |
| userUpdate.eq("user_id", modifyPasswordDTO.getUserId()).set("password", modifyPasswordDTO.getNewPassword()); |
| userService.update(userUpdate); |
| return ResponseEntity.ok(""); |
| } else { |
| // 密码错误 |
| logger.warn("Modify failed. Incorrect password for userID: {}", modifyPasswordDTO.getUserId()); |
| return ResponseEntity.status(408).body(""); |
| } |
| } |
| |
| /** |
| * 修改用户头像 |
| * |
| * @param user 用户信息 |
| * @return 用户头像修改结果 |
| */ |
| @PutMapping("/avatar") |
| public ResponseEntity<String> modifyAvatar(@RequestBody User user) { |
| UpdateWrapper<User> userUpdate = new UpdateWrapper<>(); |
| userUpdate.eq("user_id", user.getUserId()).set("avatar", user.getAvatar()); |
| userService.update(userUpdate); |
| |
| return ResponseEntity.ok(""); |
| } |
| } |