用户
Change-Id: I33150cf6ffdea3bf582023bf540394075d081af9
diff --git a/src/main/java/com/example/myproject/MyProjectApplication.java b/src/main/java/com/example/myproject/MyProjectApplication.java
index eb58082..49cd5f0 100644
--- a/src/main/java/com/example/myproject/MyProjectApplication.java
+++ b/src/main/java/com/example/myproject/MyProjectApplication.java
@@ -5,14 +5,10 @@
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-
@SpringBootApplication
@MapperScan("com.example.myproject.mapper") // 扫描 Mapper 接口
-
public class MyProjectApplication {
public static void main(String[] args) {
SpringApplication.run(MyProjectApplication.class, args);
}
}
-
diff --git a/src/main/java/com/example/myproject/controller/CommentController.java b/src/main/java/com/example/myproject/controller/CommentController.java
new file mode 100644
index 0000000..f8eb135
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/CommentController.java
@@ -0,0 +1,33 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.Comments;
+import com.example.myproject.service.CommentService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/forum/posts")
+public class CommentController {
+
+ @Autowired
+ private CommentService commentService;
+
+ // 添加评论
+ @PostMapping("/{post_id}/comments")
+ public String addComment(@PathVariable("post_id") Long postId, @RequestBody Comments comment) {
+ // 添加评论
+ commentService.addComment(postId, comment);
+ return "Comment added successfully!";
+ }
+
+ //获取所有评论
+ @GetMapping("/{post_id}/getAllComments")
+ public List<Map<String, Object>> getCommentsByPostId(@PathVariable("post_id") Long postId) {
+ // 获取评论并填充用户信息
+ return commentService.getCommentsByPostId(postId);
+ }
+
+}
diff --git a/src/main/java/com/example/myproject/controller/DynamicController.java b/src/main/java/com/example/myproject/controller/DynamicController.java
new file mode 100644
index 0000000..db1d0a2
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/DynamicController.java
@@ -0,0 +1,107 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.UserDynamic;
+import com.example.myproject.service.DynamicService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/dynamic")
+public class DynamicController {
+
+ @Autowired
+ private DynamicService dynamicService;
+
+ // 创建好友动态接口
+ @PostMapping("/{user_id}/createDynamic")
+ public Map<String, Object> createDynamic(@PathVariable("user_id") Long userId,
+ @RequestParam(value = "title", required = false) String title,
+ @RequestParam(value = "content") String content,
+ @RequestParam(value = "image_url", required = false) MultipartFile[] imageFiles) {
+ return dynamicService.createDynamic(userId, title, content, imageFiles);
+ }
+
+ //删除好友动态
+ @DeleteMapping("/me/deleteDynamic/{dynamic_id}")
+ public ResponseEntity<String> deleteDynamic(@PathVariable("dynamic_id") Long dynamicId) {
+ dynamicService.deleteDynamic(dynamicId);
+ return ResponseEntity.ok("动态删除成功");
+ }
+
+ //好友动态评论
+ @PostMapping("/{user_id}/feeds/{dynamic_id}/comments")
+ public ResponseEntity<Map<String, Object>> addComment(
+ @PathVariable("user_id") Long userId,
+ @PathVariable("dynamic_id") Long dynamicId,
+ @RequestBody Map<String, String> content) {
+
+ String commentContent = content.get("content"); // 获取评论内容
+ Map<String, Object> response = dynamicService.addComment(userId, dynamicId, commentContent);
+
+ return ResponseEntity.ok(response);
+ }
+
+ //获取某个好友的所有动态
+ @GetMapping("/{user_id}/getAdynamic")
+ public ResponseEntity<Map<String, Object>> getAllUserDynamics(@PathVariable("user_id") Long userId) {
+ Map<String, Object> response = dynamicService.getAllUserDynamics(userId);
+
+ if (response == null || response.isEmpty()) {
+ return ResponseEntity.noContent().build();
+ }
+
+ // 返回响应
+ return ResponseEntity.ok(response);
+ }
+
+ @GetMapping("/{user_id}/getAllDynamics")
+ public ResponseEntity<Map<String, Object>> getAllUserAndFriendsDynamics(@PathVariable("user_id") Long userId) {
+ // 获取当前用户所有好友的ID
+ List<Long> friendIds = dynamicService.getAllFriendIds(userId);
+ friendIds.add(userId);
+ Map<String, Object> response = dynamicService.getAllUserAndFriendsDynamics(friendIds);
+
+ if (response == null || response.isEmpty()) {
+ return ResponseEntity.noContent().build();
+ }
+
+ return ResponseEntity.ok(response);
+ }
+
+ //点赞好友动态
+ @PostMapping("/like")
+ public ResponseEntity<String> likeDynamic(@RequestBody Map<String, Long> request) {
+ Long userId = request.get("userId");
+ Long dynamicId = request.get("dynamicId");
+ // 执行点赞
+ boolean success = dynamicService.likeDynamic(userId, dynamicId);
+
+ if (success) {
+ return ResponseEntity.ok("Like successful");
+ } else {
+ return ResponseEntity.badRequest().body("Like failed");
+ }
+ }
+
+ @DeleteMapping("/unlike")
+ public ResponseEntity<String> unlikeDynamic(@RequestBody Map<String, Long> request) {
+ Long userId = request.get("userId");
+ Long dynamicId = request.get("dynamicId");
+
+ // 执行取消点赞
+ boolean success = dynamicService.unlikeDynamic(userId, dynamicId);
+
+ if (success) {
+ return ResponseEntity.ok("Unlike successful");
+ } else {
+ return ResponseEntity.badRequest().body("Unlike failed");
+ }
+ }
+
+
+}
diff --git a/src/main/java/com/example/myproject/controller/GroupController.java b/src/main/java/com/example/myproject/controller/GroupController.java
new file mode 100644
index 0000000..a0830b6
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/GroupController.java
@@ -0,0 +1,105 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.Group;
+import com.example.myproject.entity.GroupComments;
+import com.example.myproject.service.GroupService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/groups")
+public class GroupController {
+
+ @Autowired
+ private GroupService groupService;
+
+ @PostMapping("/createGroup")
+ public ResponseEntity<Map<String, Object>> createGroup(@RequestBody Group groupRequest) {
+ // 调用服务层方法创建小组
+ System.out.println("Received group name: " + groupRequest.getGroupName());
+ return groupService.createGroup(groupRequest);
+ }
+
+
+ // 加入小组接口
+ @PostMapping("/{group_id}/join")
+ public ResponseEntity<Map<String, Object>> joinGroup(@PathVariable("group_id") Long groupId,
+ @RequestBody Map<String, Long> requestBody) {
+ Long userId = requestBody.get("user_id");
+ return groupService.joinGroup(groupId, userId);
+ }
+
+ // 退出小组接口
+ @PostMapping("/{group_id}/leave")
+ public ResponseEntity<Map<String, Object>> leaveGroup(@PathVariable("group_id") Long groupId,
+ @RequestBody Map<String, Long> requestBody) {
+ Long userId = requestBody.get("user_id");
+ return groupService.leaveGroup(groupId, userId);
+ }
+
+ // 获取小组成员接口
+ @GetMapping("/{group_id}/members")
+ public ResponseEntity<Map<String, Object>> getGroupMembers(@PathVariable("group_id") Long groupId) {
+ return groupService.getGroupMembers(groupId);
+ }
+
+ //发布帖子
+ @PostMapping("/{group_id}/createPost")
+ public ResponseEntity<Map<String, Object>> createPost(
+ @PathVariable("group_id") Long groupId,
+ @RequestParam("user_id") Long userId,
+ @RequestParam("content") String content,
+ @RequestParam("title") String title,
+ @RequestParam(value = "images", required = false) MultipartFile[] imageFiles) {
+
+ Map<String, Object> response = groupService.createPost(groupId, userId, content, title, imageFiles);
+ return ResponseEntity.ok(response);
+ }
+
+ //获取某个小组内的所有帖子
+ @GetMapping("/{group_id}/getAllPosts")
+ public ResponseEntity<Map<String, Object>> getAllPosts(@PathVariable("group_id") Long groupId) {
+ Map<String, Object> response = groupService.getAllPosts(groupId);
+ return ResponseEntity.ok(response);
+ }
+
+ //获取所有小组名称
+ @PostMapping("/getAllGroups")
+ public ResponseEntity<Map<String, Object>> searchGroups(@RequestBody Map<String, Object> params) {
+ Map<String, Object> response = groupService.searchGroups(params);
+ return ResponseEntity.ok(response);
+ }
+
+ // 点赞帖子
+ @PostMapping("/{group_post_id}/like")
+ public ResponseEntity<Map<String, Object>> likePost(
+ @PathVariable("group_post_id") Long groupPostId) {
+ Map<String, Object> response = groupService.likePost(groupPostId);
+ return ResponseEntity.ok(response);
+ }
+
+ // 取消点赞
+ @PostMapping("/{group_post_id}/unlike")
+ public ResponseEntity<Map<String, Object>> unlikePost(
+ @PathVariable("group_post_id") Long groupPostId) {
+ Map<String, Object> response = groupService.unlikePost(groupPostId);
+ return ResponseEntity.ok(response);
+ }
+
+ // 添加评论接口
+ @PostMapping("/{group_post_id}/comment")
+ public ResponseEntity<Map<String, Object>> addComment(
+
+ @PathVariable("group_post_id") Long postId,
+ @RequestBody GroupComments comment) {
+
+ Map<String, Object> response = groupService.addComment(postId, comment);
+ return ResponseEntity.ok(response);
+ }
+
+}
diff --git a/src/main/java/com/example/myproject/controller/LevelController.java b/src/main/java/com/example/myproject/controller/LevelController.java
new file mode 100644
index 0000000..8781246
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/LevelController.java
@@ -0,0 +1,42 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.service.LevelService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RequestMapping("/echo/level")
+@RestController
+public class LevelController {
+
+ @Autowired
+ private LevelService levelService;
+
+ @GetMapping("/getExperience")
+ public Map<String, Object> getExperience(@RequestParam Long user_id) {
+ return levelService.getUserExperience(user_id);
+ }
+
+ @PostMapping("/updateExperience")
+ public Map<String, Object> updateExperience(@RequestBody Map<String, Object> params) {
+ Long userId = Long.valueOf(params.get("user_id").toString());
+ Integer experience = Integer.valueOf(params.get("experience").toString());
+ String source = params.get("source").toString();
+
+ return levelService.updateExperience(userId, experience, source);
+ }
+
+ // 检查用户是否满足升级条件
+ @GetMapping("/upgrade-check")
+ public Map<String, Object> checkUpgrade(@RequestParam Long user_id) {
+ return levelService.checkUpgrade(user_id);
+ }
+
+ @PostMapping("/upgrades")
+ public Map<String, Object> upgradeUserLevel(@RequestBody Map<String, Object> request) {
+ Long userId = Long.valueOf(request.get("user_id").toString());
+ Boolean canUpgrade = (Boolean) request.get("can_upgrade");
+ return levelService.upgradeUserLevel(userId, canUpgrade);
+ }
+}
diff --git a/src/main/java/com/example/myproject/controller/PostController.java b/src/main/java/com/example/myproject/controller/PostController.java
new file mode 100644
index 0000000..63fcbe8
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/PostController.java
@@ -0,0 +1,94 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.Post;
+import com.example.myproject.service.PostService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+@RestController
+@RequestMapping("/echo/forum/posts")
+public class PostController {
+
+ @Autowired
+ private PostService postService;
+
+ //创建新帖子（已完成）
+ @PostMapping("/{user_id}/createPost")
+ public Map<String, Object> createPost(
+ @PathVariable("user_id") Long userId,
+ @RequestParam(value = "postContent") String postContent,
+ @RequestParam(value = "title", required = false) String title,
+ @RequestParam(value = "imageUrl") MultipartFile[] imageFiles) {
+ return postService.createPost(userId, postContent, title, imageFiles);
+ }
+
+ //编辑帖子（已完成）
+ @PutMapping("/{post_id}/editPost")
+ public String updatePost(@PathVariable("post_id") Long postId, @RequestBody Post post) {
+ postService.updatePost(postId, post);
+ return "Post updated successfully!";
+ }
+
+ //删除帖子（已完成）
+ @DeleteMapping("/{post_id}/deletePost")
+ public String deletePost(@PathVariable("post_id") Long postId) {
+ postService.deletePost(postId);
+ return "Post deleted successfully!";
+ }
+
+ //点赞帖子（已完成）
+ @PostMapping("/{post_id}/like")
+ public String likePost(@PathVariable("post_id") Long postId, @RequestBody Map<String, Long> requestBody) {
+
+ Long userId = requestBody.get("user_id");
+ postService.likePost(postId, userId);
+
+ return "Post liked successfully!";
+ }
+
+ //取消点赞（已完成）
+ @PostMapping("/{post_id}/unlike")
+ public String unlikePost(@PathVariable("post_id") Long postId, @RequestBody Map<String, Long> requestBody) {
+ Long userId = requestBody.get("user_id");
+ postService.unlikePost(postId, userId);
+
+ return "Post unliked successfully!";
+ }
+
+ //获取帖子列表（已完成）
+ @GetMapping("/getAllPosts")
+ public Map<String, Object> getAllPosts() {
+ return postService.getAllPosts(); // 调用服务层的 getAllPosts 方法
+ }
+
+ @GetMapping("/{postId}/getPost")
+ public Map<String, Object> getPostById(@PathVariable Long postId) {
+ return postService.getPostById(postId);
+ }
+
+
+ //收藏帖子（已完成）
+ @PostMapping("/{post_id}/collect")
+ public String collectPost(@PathVariable("post_id") Long postId, @RequestBody Map<String, Long> requestBody) {
+ Long userId = requestBody.get("user_id");
+ postService.collectPost(postId, userId);
+
+ return "Post collected successfully!";
+ }
+
+
+ //取消收藏（已完成）
+ @DeleteMapping("/{post_id}/uncollect")
+ public String uncollectPost(@PathVariable("post_id") Long postId, @RequestBody Map<String, Long> requestBody) {
+ Long userId = requestBody.get("user_id");
+ postService.uncollectPost(postId, userId);
+ return "Post uncollected successfully!";
+ }
+
+
+}
diff --git a/src/main/java/com/example/myproject/controller/TaskController.java b/src/main/java/com/example/myproject/controller/TaskController.java
new file mode 100644
index 0000000..2e01b0c
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/TaskController.java
@@ -0,0 +1,68 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.service.TaskService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/task/tutorial")
+public class TaskController {
+
+ @Autowired
+ private TaskService taskService;
+
+ //获取当前用户的新手任务列表
+ @GetMapping("/getAllTasks")
+ public Map<String, Object> getAllTasks(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ return taskService.getAllTasksForUser(userId);
+ }
+
+ @PostMapping("/updateStatus")
+ public Map<String, Object> updateTaskStatus(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ String taskId = request.get("task_id").toString();
+ return taskService.updateTaskStatus(userId, taskId);
+ }
+
+ //获取当前经验和任务奖励
+ @GetMapping("/getExperience")
+ public Map<String, Object> getExperience(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ return taskService.getUserExperience(userId);
+ }
+
+ //获取当前的指引步骤
+ @GetMapping("/getNewStep")
+ public Map<String, Object> getNewStep(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ return taskService.getNewStep(userId);
+ }
+
+ //更新进度
+ @PostMapping("/updateProgress")
+ public Map<String, Object> updateProgress(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ String taskId = request.get("task_id").toString();
+ Integer progress = Integer.parseInt(request.get("progress").toString());
+ return taskService.updateTaskProgress(userId, taskId, progress);
+ }
+
+ //领取任务奖励
+ @PostMapping("/rewardClaim")
+ public Map<String, Object> rewardClaim(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ String taskId = request.get("task_id").toString();
+ return taskService.claimReward(userId, taskId);
+ }
+
+ //检查任务奖励状态
+ @PostMapping("/rewardReview")
+ public Map<String, Object> rewardReview(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ String taskId = request.get("task_id").toString();
+ return taskService.checkRewardStatus(userId, taskId);
+ }
+}
diff --git a/src/main/java/com/example/myproject/controller/UserController.java b/src/main/java/com/example/myproject/controller/UserController.java
index acda403..224c138 100644
--- a/src/main/java/com/example/myproject/controller/UserController.java
+++ b/src/main/java/com/example/myproject/controller/UserController.java
@@ -1,190 +1,155 @@
package com.example.myproject.controller;
-import cn.dev33.satoken.annotation.SaCheckLogin;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.example.myproject.common.base.PageUtil;
-import com.example.myproject.dto.param.TorrentParam;
-import com.example.myproject.dto.vo.TorrentVO;
-import com.example.myproject.entity.TorrentEntity;
-import com.example.myproject.mapper.UserMapper;
-import com.example.myproject.mapper.VerificationTokenMapper;
-import com.example.myproject.entity.User;
-import com.example.myproject.entity.VerificationToken;
-import com.example.myproject.service.EmailService;
+import com.example.myproject.entity.Users;
+import com.example.myproject.repository.UserRepository;
+import com.example.myproject.service.DynamicService;
+import com.example.myproject.service.TaskService;
import com.example.myproject.service.UserService;
-import com.example.myproject.common.base.Result;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiParam;
-import io.swagger.v3.oas.annotations.Operation;
-import io.swagger.v3.oas.annotations.media.Content;
-import io.swagger.v3.oas.annotations.media.Schema;
-import io.swagger.v3.oas.annotations.responses.ApiResponse;
-import org.apache.commons.lang3.RandomStringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import org.springframework.security.authentication.AuthenticationManager;
-import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
-import org.springframework.security.core.Authentication;
-import org.springframework.security.core.AuthenticationException;
-import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.web.bind.annotation.*;
-import javax.annotation.Resource;
-import java.time.Instant;
-import java.time.temporal.ChronoUnit;
+import java.util.Map;
+import java.util.Optional;
+
import java.util.List;
+import java.util.ArrayList;
+
@RestController
-@RequestMapping("/user")
-@Api(value = "用户管理接口", tags = {"用户管理"})
+@RequestMapping("/echo/user")
public class UserController {
- @Resource
+ @Autowired
private UserService userService;
@Autowired
- private AuthenticationManager authenticationManager;
+ private UserRepository userRepository;
@Autowired
- private UserMapper userMapper; // 使用 MyBatis-Plus
+ private DynamicService dynamicService;
- @Autowired
- private VerificationTokenMapper verificationTokenMapper; // 替换 JPA
-
- private static final Logger logger = LoggerFactory.getLogger(UserController.class);
-
- @PostMapping("/login")
- @ApiOperation(value = "用户登录", notes = "使用用户名和密码进行登录")
- public Result loginController(@RequestParam @ApiParam(value = "用户名", required = true) String username,
- @RequestParam @ApiParam(value = "密码", required = true) String password) {
- try {
- Authentication authentication = authenticationManager.authenticate(
- new UsernamePasswordAuthenticationToken(username, password)
- );
- SecurityContextHolder.getContext().setAuthentication(authentication);
-
- // 使用 MyBatis-Plus 查询
- User user = userMapper.selectOne(new QueryWrapper<User>().eq("username", username));
-
- System.out.println("Login successful for user: " + username);
- return Result.ok(user);
- } catch (AuthenticationException e) {
- return Result.error("登录失败");
- }
+ // 接口：生成邀请码
+ @PostMapping("/getInviteCode")
+ public Map<String, Object> generateInviteCode(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ return userService.generateInviteCode(userId);
}
+ //注册
@PostMapping("/register")
- @ApiOperation(value = "用户注册", notes = "使用用户信息进行注册")
- public Result registerController(@RequestBody @ApiParam(value = "新用户信息", required = true) User newUser) {
- if (userService.checkEmailExists(newUser.getEmail())) {
- return Result.error( "邮箱已被使用，请使用其他邮箱注册或找回密码！");
- }
- boolean success = userService.preRegisterUser(newUser);
- if (success) {
- User responseUser = new User();
- responseUser.setEmail(newUser.getEmail());
- return Result.ok();
+ public Map<String, Object> register(@RequestBody Map<String, Object> request) {
+ String username = (String) request.get("username");
+ String email = (String) request.get("email");
+ String password = (String) request.get("password");
+ String role = (String) request.get("role");
+ String inviteCode = (String) request.get("inviteCode");
+
+ // 调用服务层的注册方法
+ String resultMessage = userService.registerUser(username, email, password, role, inviteCode);
+
+ // 返回注册结果
+ return Map.of("msg", resultMessage);
+ }
+
+ //登录
+ @PostMapping("/login")
+ public Map<String, Object> login(@RequestBody Map<String, Object> request) {
+ String username = (String) request.get("username");
+ String password = (String) request.get("password");
+
+ // 调用服务层的登录方法
+ String resultMessage = userService.loginUser(username, password);
+
+ // 根据登录结果返回不同的响应
+ if (resultMessage.equals("登录成功")) {
+ // 查询用户信息
+ Optional<Users> user = userRepository.findByUsername(username);
+ if (user.isPresent()) {
+ // 将用户的所有信息作为返回值
+ return Map.of("msg", resultMessage, "user", user.get());
+ } else {
+ return Map.of("msg", "用户信息查询失败");
+ }
} else {
- return Result.error("账号已存在或注册失败！");
+ return Map.of("msg", resultMessage);
}
}
- public static class VerificationRequest {
- private String email;
- private String code;
+ //修改密码
+ @PostMapping("/password")
+ public Map<String, Object> changePassword(@RequestBody Map<String, Object> request) {
+ Long userId = Long.parseLong(request.get("user_id").toString());
+ String oldPassword = (String) request.get("old_password");
+ String newPassword = (String) request.get("new_password");
+ String confirmPassword = (String) request.get("confirm_password");
- public String getEmail() { return email; }
- public void setEmail(String email) { this.email = email; }
- public String getCode() { return code; }
- public void setCode(String code) { this.code = code; }
+ // 调用服务层的修改密码方法
+ String resultMessage = userService.changePassword(userId, oldPassword, newPassword, confirmPassword);
+
+ // 返回修改结果
+ return Map.of("message", resultMessage, "status", resultMessage.equals("密码修改成功") ? "success" : "error");
}
- @PostMapping("/verify-code")
- @ApiOperation(value = "验证邮箱验证码", notes = "验证用户邮箱的验证码")
- public Result verifyEmailCode(@RequestBody @ApiParam(value = "验证请求信息", required = true) VerificationRequest verificationRequest) {
- String email = verificationRequest.getEmail();
- String code = verificationRequest.getCode();
- boolean isVerified = userService.verifyEmail(email, code);
- if (isVerified) {
- return Result.ok();
+ // 获取用户个人资料
+ @GetMapping("/{userId}/getProfile")
+ public Map<String, Object> getProfile(@PathVariable("userId") Long userId) {
+ return userService.getProfile(userId);
+ }
+
+ // 修改用户个人资料
+ @PutMapping("/{userId}/editProfile")
+ public Map<String, String> editProfile(
+ @PathVariable("userId") Long userId,
+ @RequestBody Map<String, Object> profileData) {
+
+ // 获取请求体中的修改数据
+ String avatarUrl = (String) profileData.get("avatarUrl");
+ String nickname = (String) profileData.get("nickname");
+ String gender = (String) profileData.get("gender");
+ String description = (String) profileData.get("description");
+ String hobbies = (String) profileData.get("hobbies");
+
+ // 调用服务层方法进行修改
+ boolean updated = userService.editProfile(userId, avatarUrl, nickname, gender, description, hobbies);
+
+ // 返回操作结果消息
+ if (updated) {
+ return Map.of("message", "用户资料更新成功");
} else {
- return Result.error( "验证码错误或已过期！");
+ return Map.of("message", "用户不存在");
}
}
- @Autowired
- private EmailService emailService;
-
- public static class EmailRequest {
- private String email;
- public String getEmail() { return email; }
- public void setEmail(String email) { this.email = email; }
+ // 计算分享率
+ @GetMapping("/{user_id}/calculate-share-rate")
+ public Map<String, Object> calculateShareRate(@PathVariable("user_id") Long userId) {
+ return userService.calculateShareRate(userId);
}
- @PostMapping("/get-verification-email")
- @ApiOperation(value = "发送验证邮件", notes = "通过电子邮件发送验证邮件")
- public ResponseEntity<Result> sendVerificationEmail(@RequestBody @ApiParam(value = "发送验证请求", required = true) EmailRequest emailVerificationRequest) {
- String email = emailVerificationRequest.getEmail();
- User user = userMapper.selectOne(new QueryWrapper<User>().eq("email", email));
- if (user == null) {
- logger.error("未找到与该邮箱地址相关联的用户: {}", email);
- return ResponseEntity.status(HttpStatus.BAD_REQUEST)
- .body(Result.error("未找到与该邮箱地址相关联的用户"));
+ // 获取用户所有好友的基本信息
+ @GetMapping("/{userId}/friends")
+ public List<Map<String, Object>> getUserFriends(@PathVariable("userId") Long userId) {
+ List<Long> friendIds = dynamicService.getAllFriendIds(userId); // 注意这里用的是实例对象
+ List<Map<String, Object>> friends = new ArrayList<>();
+
+ for (Long friendId : friendIds) {
+ Optional<Users> userOpt = userRepository.findById(friendId);
+ if (userOpt.isPresent()) {
+ Users user = userOpt.get();
+ Map<String, Object> friendInfo = Map.of(
+ "id", user.getUserId(),
+ "avatar", user.getAvatarUrl() != null ? user.getAvatarUrl() : "https://example.com/default-avatar.jpg",
+ "nickname", user.getUsername() != null ? user.getUsername() : "未知用户",
+ "email", user.getEmail() != null ? user.getEmail() : "未填写"
+ );
+ friends.add(friendInfo);
+ }
}
- // 生成验证码
- String token = RandomStringUtils.randomNumeric(6);
- Instant expiryDate = Instant.now().plus(1, ChronoUnit.HOURS);
- logger.info("生成的验证令牌: {}, 过期时间: {}", token, expiryDate);
-
- VerificationToken verificationToken = new VerificationToken(token, user.getUsername(), email, user.getPassword(), expiryDate);
-
- // 保存到 MyBatis-Plus 数据库
- verificationTokenMapper.insert(verificationToken);
-
- logger.info("验证令牌已保存，用户: {}", user.getUsername());
- emailService.sendVerificationEmail(email, token);
-
- return ResponseEntity.ok(Result.ok());
+ return friends;
}
- @PostMapping("/checkPassword")
- public Result<String> checkPassword(@RequestParam Long userId, @RequestParam String password) {
- boolean isPasswordCorrect = userService.checkPassword(userId, password);
- if (isPasswordCorrect) {
- return Result.ok();
- } else {
- return Result.error("原始密码输入错误");
- }
- }
-
-
-// @SaCheckLogin
-// @Operation(summary = "用户收藏列表", description = "获取用户收藏的种子列表-分页-排序")
-// @ApiResponse(responseCode = "0", description = "操作成功",
-// content = {@Content(mediaType = "application/json",
-// schema = @Schema(implementation = TorrentVO.class))
-// })
-// @PostMapping("/favorite/list")
-// public Result listFavorites(@RequestBody FavoriteParam param) {
-// if (param.getUserId() == null) {
-// return Result.error("缺少 userId");
-// }
-//
-// // 校验排序字段是否合理（可选）
-// param.validOrder(param.getOrderKey(TorrentEntity.class));
-//
-// PageUtil.startPage(param);
-//
-// List<TorrentEntity> list = favoriteService.getUserFavoritesPaged(param.getUserId());
-//
-// return Result.ok(list, PageUtil.getPage(list));
-// }
-//
-
}
+
+
diff --git a/src/main/java/com/example/myproject/controller/UserFollowController.java b/src/main/java/com/example/myproject/controller/UserFollowController.java
new file mode 100644
index 0000000..f550beb
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/UserFollowController.java
@@ -0,0 +1,47 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.service.UserFollowService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/users")
+public class UserFollowController {
+
+ @Autowired
+ private UserFollowService userFollowService;
+
+ // 用户关注接口
+ @PostMapping("/{followed_id}/follow")
+ public ResponseEntity<Map<String, Object>> follow(@PathVariable("followed_id") Long followedId,
+ @RequestBody Map<String, Long> request) {
+ Long followerId = request.get("follower_id");
+ Map<String, Object> response = userFollowService.follow(followerId, followedId);
+ return ResponseEntity.ok(response);
+ }
+
+ // 取消关注接口
+ @PostMapping("/{followed_id}/unfollow")
+ public ResponseEntity<Map<String, Object>> unfollow(@PathVariable("followed_id") Long followedId,
+ @RequestBody Map<String, Long> request) {
+ Long followerId = request.get("follower_id");
+ Map<String, Object> response = userFollowService.unfollow(followerId, followedId);
+ return ResponseEntity.ok(response);
+ }
+
+ // 获取某个用户的粉丝列表
+ @GetMapping("/{user_id}/followers")
+ public ResponseEntity<Map<String, Object>> getFollowers(@PathVariable("user_id") Long userId) {
+ Map<String, Object> response = userFollowService.getFollowers(userId);
+ return ResponseEntity.ok(response);
+ }
+
+ @GetMapping("/{user_id}/following")
+ public ResponseEntity<Map<String, Object>> getFollowing(@PathVariable("user_id") Long userId) {
+ Map<String, Object> response = userFollowService.getFollowing(userId);
+ return ResponseEntity.ok(response);
+ }
+}
diff --git a/src/main/java/com/example/myproject/controller/UserMessageController.java b/src/main/java/com/example/myproject/controller/UserMessageController.java
new file mode 100644
index 0000000..c7014a7
--- /dev/null
+++ b/src/main/java/com/example/myproject/controller/UserMessageController.java
@@ -0,0 +1,39 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.service.UserMessageService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/echo/message")
+public class UserMessageController {
+
+ @Autowired
+ private UserMessageService userMessageService;
+
+ @PostMapping("/sendMessages")
+ public ResponseEntity<Map<String, Object>> sendMessage(@RequestBody Map<String, Object> params) {
+ // 将参数转换为 Long 类型
+ Long senderId = Long.valueOf(params.get("sender_id").toString());
+ Long receiverId = Long.valueOf(params.get("receiver_id").toString());
+ String content = (String) params.get("content");
+ Map<String, Object> response = userMessageService.sendMessage(senderId, receiverId, content);
+ return ResponseEntity.ok(response);
+ }
+
+ @GetMapping("/{user_id}/getUserMessages")
+ public ResponseEntity<Map<String, Object>> getUserMessages(@PathVariable("user_id") Long userId) {
+ Map<String, Object> response = userMessageService.getUserMessages(userId);
+ return ResponseEntity.ok(response);
+ }
+
+ // 获取单条消息的详情
+ @GetMapping("/{message_id}/getAMessage")
+ public ResponseEntity<Map<String, Object>> getMessage(@PathVariable("message_id") Long messageId) {
+ Map<String, Object> response = userMessageService.getMessage(messageId);
+ return ResponseEntity.ok(response);
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Collections.java b/src/main/java/com/example/myproject/entity/Collections.java
new file mode 100644
index 0000000..f7a8711
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Collections.java
@@ -0,0 +1,44 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "collections")
+public class Collections {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "collectionId")
+ private Long collectionId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "postNo")
+ private Long postNo;
+
+ // Getters and Setters
+ public Long getCollectionId() {
+ return collectionId;
+ }
+
+ public void setCollectionId(Long collectionId) {
+ this.collectionId = collectionId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Long getPostNo() {
+ return postNo;
+ }
+
+ public void setPostNo(Long postNo) {
+ this.postNo = postNo;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Comments.java b/src/main/java/com/example/myproject/entity/Comments.java
new file mode 100644
index 0000000..fdf89fa
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Comments.java
@@ -0,0 +1,116 @@
+package com.example.myproject.entity;
+
+import com.fasterxml.jackson.annotation.JsonBackReference;
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "comments")
+public class Comments {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "comment_id")
+ private Long commentId;
+
+ @ManyToOne
+ @JoinColumn(name = "post_id", nullable = false)
+ @JsonBackReference
+ private Post post;
+
+ @Column(name = "content", nullable = false)
+ private String content;
+
+ @Column(name = "is_anonymous")
+ private Boolean isAnonymous; // 是否匿名
+
+ @Column(name = "likes_count")
+ private Integer likesCount = 0; // 点赞数
+
+ @Column(name = "reply_count")
+ private Integer replyCount = 0; // 回复数
+
+ @Column(name = "comment_time", nullable = false)
+ private Date commentTime; // 评论时间
+
+ @Column(name = "user_id", nullable = false)
+ private Long userId; // 评论者的 user_id
+
+
+ @Column(name = "com_comment_id", nullable = false)
+ private Long com_comment_id;
+
+ // Getters and Setters
+
+ public Long getCommentId() {
+ return commentId;
+ }
+
+ public void setCommentId(Long commentId) {
+ this.commentId = commentId;
+ }
+
+ public Post getPost() {
+ return post;
+ }
+
+ public void setPost(Post post) {
+ this.post = post;
+ }
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
+
+ public Boolean getIsAnonymous() {
+ return isAnonymous;
+ }
+
+ public void setIsAnonymous(Boolean isAnonymous) {
+ this.isAnonymous = isAnonymous;
+ }
+
+ public Integer getLikesCount() {
+ return likesCount;
+ }
+
+ public void setLikesCount(Integer likesCount) {
+ this.likesCount = likesCount;
+ }
+
+ public Integer getReplyCount() {
+ return replyCount;
+ }
+
+ public void setReplyCount(Integer replyCount) {
+ this.replyCount = replyCount;
+ }
+
+ public Date getCommentTime() {
+ return commentTime;
+ }
+
+ public void setCommentTime(Date commentTime) {
+ this.commentTime = commentTime;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Long getParentComment() {
+ return com_comment_id;
+ }
+
+ public void setParentComment(Long com_comment_id) {
+ this.com_comment_id = com_comment_id;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/DynamicComment.java b/src/main/java/com/example/myproject/entity/DynamicComment.java
new file mode 100644
index 0000000..d5c84d3
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/DynamicComment.java
@@ -0,0 +1,89 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "dynamic_comment")
+public class DynamicComment {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "comment_id")
+ private Long commentId;
+
+ @Column(name = "dynamic_id")
+ private Long dynamicId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "comment_content")
+ private String commentContent;
+
+ @Column(name = "comment_time")
+ private Date commentTime;
+
+ @Column(name = "is_anonymous")
+ private Boolean isAnonymous = false;
+
+ @Column(name = "parent_comment_id")
+ private Long parentCommentId;
+
+ // Getters and Setters
+ public Long getCommentId() {
+ return commentId;
+ }
+
+ public void setCommentId(Long commentId) {
+ this.commentId = commentId;
+ }
+
+ public Long getDynamicId() {
+ return dynamicId;
+ }
+
+ public void setDynamicId(Long dynamicId) {
+ this.dynamicId = dynamicId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getCommentContent() {
+ return commentContent;
+ }
+
+ public void setCommentContent(String commentContent) {
+ this.commentContent = commentContent;
+ }
+
+ public Date getCommentTime() {
+ return commentTime;
+ }
+
+ public void setCommentTime(Date commentTime) {
+ this.commentTime = commentTime;
+ }
+
+ public Boolean getIsAnonymous() {
+ return isAnonymous;
+ }
+
+ public void setIsAnonymous(Boolean isAnonymous) {
+ this.isAnonymous = isAnonymous;
+ }
+
+ public Long getParentCommentId() {
+ return parentCommentId;
+ }
+
+ public void setParentCommentId(Long parentCommentId) {
+ this.parentCommentId = parentCommentId;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/DynamicLikes.java b/src/main/java/com/example/myproject/entity/DynamicLikes.java
new file mode 100644
index 0000000..986f903
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/DynamicLikes.java
@@ -0,0 +1,56 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "dynamic_likes")
+public class DynamicLikes {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "like_id")
+ private Long likeId;
+
+ @Column(name = "dynamic_id")
+ private Long dynamicId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "like_time")
+ private Date likeTime;
+
+ // Getters and Setters
+ public Long getLikeId() {
+ return likeId;
+ }
+
+ public void setLikeId(Long likeId) {
+ this.likeId = likeId;
+ }
+
+ public Long getDynamicId() {
+ return dynamicId;
+ }
+
+ public void setDynamicId(Long dynamicId) {
+ this.dynamicId = dynamicId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Date getLikeTime() {
+ return likeTime;
+ }
+
+ public void setLikeTime(Date likeTime) {
+ this.likeTime = likeTime;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/ExperienceHistory.java b/src/main/java/com/example/myproject/entity/ExperienceHistory.java
new file mode 100644
index 0000000..8c52f6b
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/ExperienceHistory.java
@@ -0,0 +1,67 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "experience_history")
+public class ExperienceHistory {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "history_id")
+ private Long historyId;
+
+ @Column(name = "user_id", nullable = false)
+ private Long userId;
+
+ @Column(name = "experience_change", nullable = false)
+ private Integer experienceChange; // 经验值变化量
+
+ @Column(name = "source", nullable = false)
+ private String source; // 更新来源
+
+ @Column(name = "update_time", nullable = false)
+ private Date updateTime; // 更新操作的时间
+
+ // Getters and Setters
+ public Long getHistoryId() {
+ return historyId;
+ }
+
+ public void setHistoryId(Long historyId) {
+ this.historyId = historyId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Integer getExperienceChange() {
+ return experienceChange;
+ }
+
+ public void setExperienceChange(Integer experienceChange) {
+ this.experienceChange = experienceChange;
+ }
+
+ public String getSource() {
+ return source;
+ }
+
+ public void setSource(String source) {
+ this.source = source;
+ }
+
+ public Date getUpdateTime() {
+ return updateTime;
+ }
+
+ public void setUpdateTime(Date updateTime) {
+ this.updateTime = updateTime;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/FriendRelation.java b/src/main/java/com/example/myproject/entity/FriendRelation.java
new file mode 100644
index 0000000..c086001
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/FriendRelation.java
@@ -0,0 +1,56 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "friend_relation")
+public class FriendRelation {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "relation_id")
+ private Long relationId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "friend_id")
+ private Long friendId; // 好友ID
+
+ @Column(name = "create_time")
+ private Date createTime; // 好友关系创建时间
+
+ // Getters and Setters
+ public Long getRelationId() {
+ return relationId;
+ }
+
+ public void setRelationId(Long relationId) {
+ this.relationId = relationId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Long getFriendId() {
+ return friendId;
+ }
+
+ public void setFriendId(Long friendId) {
+ this.friendId = friendId;
+ }
+
+ public Date getCreateTime() {
+ return createTime;
+ }
+
+ public void setCreateTime(Date createTime) {
+ this.createTime = createTime;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Group.java b/src/main/java/com/example/myproject/entity/Group.java
new file mode 100644
index 0000000..ea4f2c7
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Group.java
@@ -0,0 +1,98 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "group_interests")
+public class Group {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "group_id")
+ private Long groupId;
+
+ @Column(name = "group_name")
+ private String groupName;
+
+ private String description; // 小组简介
+
+ @Column(name = "create_time")
+ private Date createTime; // 创建时间
+
+ @Column(name = "user_id")
+ private Long userId; // 创建该小组的用户ID
+
+ @Column(name = "member_count")
+ private Integer memberCount; // 小组成员人数
+
+ private String category; // 小组类别
+
+ @Column(name = "cover_image")
+ private String coverImage; // 小组封面图片
+
+ // Getters and Setters
+ public Long getGroupId() {
+ return groupId;
+ }
+
+ public void setGroupId(Long groupId) {
+ this.groupId = groupId;
+ }
+
+ public String getGroupName() {
+ return groupName;
+ }
+
+ public void setGroupName(String groupName) {
+ this.groupName = groupName;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ public Date getCreateTime() {
+ return createTime;
+ }
+
+ public void setCreateTime(Date createTime) {
+ this.createTime = createTime;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Integer getMemberCount() {
+ return memberCount;
+ }
+
+ public void setMemberCount(Integer memberCount) {
+ this.memberCount = memberCount;
+ }
+
+ public String getCategory() {
+ return category;
+ }
+
+ public void setCategory(String category) {
+ this.category = category;
+ }
+
+ public String getCoverImage() {
+ return coverImage;
+ }
+
+ public void setCoverImage(String coverImage) {
+ this.coverImage = coverImage;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/GroupComments.java b/src/main/java/com/example/myproject/entity/GroupComments.java
new file mode 100644
index 0000000..fcf4205
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/GroupComments.java
@@ -0,0 +1,77 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "group_comments")
+public class GroupComments {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "comment_id")
+ private Long commentId; // 评论ID
+
+ @Column(name = "group_post_id")
+ private Long groupPostId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ private String content;
+
+ @Column(name = "parent_comment_id")
+ private Long parentCommentId;
+
+ @Column(name = "time")
+ private Date time; // 评论时间
+
+ // Getters and Setters
+ public Long getCommentId() {
+ return commentId;
+ }
+
+ public void setCommentId(Long commentId) {
+ this.commentId = commentId;
+ }
+
+ public Long getGroupPostId() {
+ return groupPostId;
+ }
+
+ public void setGroupPostId(Long groupPostId) {
+ this.groupPostId = groupPostId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
+
+ public Long getParentCommentId() {
+ return parentCommentId;
+ }
+
+ public void setParentCommentId(Long parentCommentId) {
+ this.parentCommentId = parentCommentId;
+ }
+
+ public Date getTime() {
+ return time;
+ }
+
+ public void setTime(Date time) {
+ this.time = time;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/GroupMembers.java b/src/main/java/com/example/myproject/entity/GroupMembers.java
new file mode 100644
index 0000000..e66e18c
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/GroupMembers.java
@@ -0,0 +1,44 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "group_members")
+public class GroupMembers {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "relation_id")
+ private Long relationId;
+
+ @Column(name = "group_id", nullable = false)
+ private Long groupId;
+
+ @Column(name = "user_id", nullable = false)
+ private Long userId;
+
+ // Getters and Setters
+ public Long getRelationId() {
+ return relationId;
+ }
+
+ public void setRelationId(Long relationId) {
+ this.relationId = relationId;
+ }
+
+ public Long getGroupId() {
+ return groupId;
+ }
+
+ public void setGroupId(Long groupId) {
+ this.groupId = groupId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/GroupPost.java b/src/main/java/com/example/myproject/entity/GroupPost.java
new file mode 100644
index 0000000..89867f7
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/GroupPost.java
@@ -0,0 +1,109 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "group_post")
+public class GroupPost {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "group_post_id")
+ private Long groupPostId;
+
+ @Column(name = "group_id")
+ private Long groupId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ private String content;
+
+ private String image;
+
+ @Column(name = "like_count")
+ private Integer likeCount;
+
+ @Column(name = "comment_count")
+ private Integer commentCount; // 帖子评论数
+
+ @Column(name = "time")
+ private Date time; // 帖子创建时间
+
+ private String title;
+
+
+ // Getters and Setters
+ public Long getGroupPostId() {
+ return groupPostId;
+ }
+
+ public void setGroupPostId(Long groupPostId) {
+ this.groupPostId = groupPostId;
+ }
+
+ public Long getGroupId() {
+ return groupId;
+ }
+
+ public void setGroupId(Long groupId) {
+ this.groupId = groupId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
+
+ public String getImage() {
+ return image;
+ }
+
+ public void setImage(String image) {
+ this.image = image;
+ }
+
+ public Integer getLikeCount() {
+ return likeCount;
+ }
+
+ public void setLikeCount(Integer likeCount) {
+ this.likeCount = likeCount;
+ }
+
+ public Integer getCommentCount() {
+ return commentCount;
+ }
+
+ public void setCommentCount(Integer commentCount) {
+ this.commentCount = commentCount;
+ }
+
+ public Date getTime() {
+ return time;
+ }
+
+ public void setTime(Date time) {
+ this.time = time;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Level.java b/src/main/java/com/example/myproject/entity/Level.java
new file mode 100644
index 0000000..6837ef9
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Level.java
@@ -0,0 +1,89 @@
+package com.example.myproject.entity;
+
+
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "level")
+public class Level {
+
+ @Id
+ @Column(name = "level_id")
+ private Long levelId; // 等级唯一标识
+
+ @Column(name = "level_name", nullable = false)
+ private String levelName; // 等级名称
+
+ @Column(name = "required_experience", nullable = false)
+ private Long requiredExperience; // 所需经验值
+
+ @Column(name = "required_share_ratio")
+ private Float requiredShareRatio; // 所需分享率
+
+ @Column(name = "required_upload_gb")
+ private Float requiredUploadGb; // 所需上传数据量
+
+ @Column(name = "required_seeding_hours")
+ private Float requiredSeedingHours; // 所需做种时长
+
+ @Column(name = "permissions")
+ private String permissions; // 拥有的权限
+
+ // Getters and Setters
+ public Long getLevelId() {
+ return levelId;
+ }
+
+ public void setLevelId(Long levelId) {
+ this.levelId = levelId;
+ }
+
+ public String getLevelName() {
+ return levelName;
+ }
+
+ public void setLevelName(String levelName) {
+ this.levelName = levelName;
+ }
+
+ public Long getRequiredExperience() {
+ return requiredExperience;
+ }
+
+ public void setRequiredExperience(Long requiredExperience) {
+ this.requiredExperience = requiredExperience;
+ }
+
+ public Float getRequiredShareRatio() {
+ return requiredShareRatio;
+ }
+
+ public void setRequiredShareRatio(Float requiredShareRatio) {
+ this.requiredShareRatio = requiredShareRatio;
+ }
+
+ public Float getRequiredUploadGb() {
+ return requiredUploadGb;
+ }
+
+ public void setRequiredUploadGb(Float requiredUploadGb) {
+ this.requiredUploadGb = requiredUploadGb;
+ }
+
+ public Float getRequiredSeedingHours() {
+ return requiredSeedingHours;
+ }
+
+ public void setRequiredSeedingHours(Float requiredSeedingHours) {
+ this.requiredSeedingHours = requiredSeedingHours;
+ }
+
+ public String getPermissions() {
+ return permissions;
+ }
+
+ public void setPermissions(String permissions) {
+ this.permissions = permissions;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Likes.java b/src/main/java/com/example/myproject/entity/Likes.java
new file mode 100644
index 0000000..7a3dcda
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Likes.java
@@ -0,0 +1,44 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "likes")
+public class Likes {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY) // 使用自增主键
+ @Column(name = "likeId")
+ private Long likeId;
+
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "postNo")
+ private Long postNo;
+
+ // Getters and Setters
+ public Long getLikeId() {
+ return likeId;
+ }
+
+ public void setLikeId(Long likeId) {
+ this.likeId = likeId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public Long getPostNo() {
+ return postNo;
+ }
+
+ public void setPostNo(Long postNo) {
+ this.postNo = postNo;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Post.java b/src/main/java/com/example/myproject/entity/Post.java
new file mode 100644
index 0000000..bb94aac
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Post.java
@@ -0,0 +1,116 @@
+package com.example.myproject.entity;
+
+import com.fasterxml.jackson.annotation.JsonManagedReference;
+
+import javax.persistence.*;
+
+import java.util.Date;
+import java.util.List;
+
+@Entity
+@Table(name = "post")
+public class Post {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "postNo")
+ private Long postNo;
+
+
+ @Column(name = "userId")
+ private Long user_id;
+
+ @Column(name = "postContent")
+ private String postContent;
+
+ @Column(name = "imageUrl")
+ private String imageUrl;
+
+ @Column(name = "postTime")
+ private Date postTime;
+
+ @Column(name = "postLikeNum")
+ private Integer postLikeNum;
+
+ @Column(name = "postCollectNum")
+ private Integer postCollectNum;
+
+ @Column(name = "title")
+ private String title;
+
+ @Column(name = "postType")
+ private String postType;
+
+ // Getters and Setters
+ public Long getPostNo() {
+ return postNo;
+ }
+
+ public void setPostNo(Long postNo) {
+ this.postNo = postNo;
+ }
+
+ public Long getUser_id() {
+ return user_id;
+ }
+
+ public void setUser_id(Long user) {
+ this.user_id = user;
+ }
+
+ public String getPostContent() {
+ return postContent;
+ }
+
+ public void setPostContent(String postContent) {
+ this.postContent = postContent;
+ }
+
+ public String getImageUrl() {
+ return imageUrl;
+ }
+
+ public void setImageUrl(String imgUrl) {
+ this.imageUrl = imgUrl;
+ }
+
+ public Date getPostTime() {
+ return postTime;
+ }
+
+ public void setPostTime(Date postTime) {
+ this.postTime = postTime;
+ }
+
+ public Integer getPostLikeNum() {
+ return postLikeNum;
+ }
+
+ public void setPostLikeNum(Integer postLikeNum) {
+ this.postLikeNum = postLikeNum;
+ }
+
+ public Integer getPostCollectNum() {
+ return postCollectNum;
+ }
+
+ public void setPostCollectNum(Integer postCollectNum) {
+ this.postCollectNum = postCollectNum;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public String getPostType() {
+ return postType;
+ }
+
+ public void setPostType(String postType) {
+ this.postType = postType;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Task.java b/src/main/java/com/example/myproject/entity/Task.java
new file mode 100644
index 0000000..15796a1
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Task.java
@@ -0,0 +1,66 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "tasks")
+public class Task {
+
+ @Id
+ @Column(name = "task_id")
+ private String taskId;
+
+ @Column(name = "title", nullable = false)
+ private String title;
+
+ @Column(name = "description", nullable = false)
+ private String description;
+
+ @Column(name = "reward_experience", nullable = false)
+ private int rewardExperience; // 任务奖励的经验
+
+ @Column(name = "reward_points", nullable = false)
+ private int rewardPoints; // 任务奖励的积分
+
+
+ public String getTaskId() {
+ return taskId;
+ }
+
+ public void setTaskId(String taskId) {
+ this.taskId = taskId;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+
+ public int getRewardExperience() {
+ return rewardExperience;
+ }
+
+ public void setRewardExperience(int rewardExperience) {
+ this.rewardExperience = rewardExperience;
+ }
+
+ public int getRewardPoints() {
+ return rewardPoints;
+ }
+
+ public void setRewardPoints(int rewardPoints) {
+ this.rewardPoints = rewardPoints;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/UserDynamic.java b/src/main/java/com/example/myproject/entity/UserDynamic.java
new file mode 100644
index 0000000..a04d3ac
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/UserDynamic.java
@@ -0,0 +1,100 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "user_dynamic")
+public class UserDynamic {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "dynamic_id")
+ private Long dynamicId;
+
+ @Column(name = "user_id")
+ private Long userId; // 发布动态的用户ID
+
+ @Column(name = "title")
+ private String title; // 动态标题
+
+ @Column(name = "content")
+ private String content; // 动态内容
+
+ @Column(name = "image_url")
+ private String imageUrl; // 图片URL
+
+ @Column(name = "time")
+ private Date time; // 发布动态的时间
+
+ @Column(name = "likes_count")
+ private int likesCount = 0; // 点赞数
+
+ @Column(name = "comments_count")
+ private int commentsCount = 0; // 评论数
+
+
+ public Long getDynamicId() {
+ return dynamicId;
+ }
+
+ public void setDynamicId(Long dynamicId) {
+ this.dynamicId = dynamicId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
+
+ public String getImageUrl() {
+ return imageUrl;
+ }
+
+ public void setImageUrl(String imageUrl) {
+ this.imageUrl = imageUrl;
+ }
+
+ public Date getTime() {
+ return time;
+ }
+
+ public void setTime(Date time) {
+ this.time = time;
+ }
+
+ public int getLikesCount() {
+ return likesCount;
+ }
+
+ public void setLikesCount(int likesCount) {
+ this.likesCount = likesCount;
+ }
+
+ public int getCommentsCount() {
+ return commentsCount;
+ }
+
+ public void setCommentsCount(int commentsCount) {
+ this.commentsCount = commentsCount;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/UserFollow.java b/src/main/java/com/example/myproject/entity/UserFollow.java
new file mode 100644
index 0000000..bfc14f7
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/UserFollow.java
@@ -0,0 +1,56 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "follow")
+public class UserFollow {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "record_id")
+ private Long recordId;
+
+ @Column(name = "follower_id")
+ private Long followerId;
+
+ @Column(name = "followed_id")
+ private Long followedId;
+
+ @Column(name = "follow_time")
+ private Date followTime;
+
+ // Getters and Setters
+ public Long getId() {
+ return recordId;
+ }
+
+ public void setId(Long recordId) {
+ this.recordId = recordId;
+ }
+
+ public Long getFollowerId() {
+ return followerId;
+ }
+
+ public void setFollowerId(Long followerId) {
+ this.followerId = followerId;
+ }
+
+ public Long getFollowedId() {
+ return followedId;
+ }
+
+ public void setFollowedId(Long followedId) {
+ this.followedId = followedId;
+ }
+
+ public Date getFollowTime() {
+ return followTime;
+ }
+
+ public void setFollowTime(Date followTime) {
+ this.followTime = followTime;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/UserInviteCode.java b/src/main/java/com/example/myproject/entity/UserInviteCode.java
new file mode 100644
index 0000000..8343c7e
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/UserInviteCode.java
@@ -0,0 +1,67 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "user_invite_code")
+public class UserInviteCode {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "invite_id")
+ private Long inviteId;
+
+ @Column(name = "user_id", nullable = false)
+ private Long userId;
+
+ @Column(name = "invite_code", nullable = false, unique = true)
+ private String inviteCode;
+
+ @Column(name = "is_used", nullable = false)
+ private Boolean isUsed = false;
+
+ @Column(name = "created_at", nullable = false)
+ private LocalDateTime createdAt;
+
+ // Getters and Setters
+ public Long getInviteId() {
+ return inviteId;
+ }
+
+ public void setInviteId(Long inviteId) {
+ this.inviteId = inviteId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getInviteCode() {
+ return inviteCode;
+ }
+
+ public void setInviteCode(String inviteCode) {
+ this.inviteCode = inviteCode;
+ }
+
+ public Boolean getIsUsed() {
+ return isUsed;
+ }
+
+ public void setIsUsed(Boolean isUsed) {
+ this.isUsed = isUsed;
+ }
+
+ public LocalDateTime getCreatedAt() {
+ return createdAt;
+ }
+
+ public void setCreatedAt(LocalDateTime createdAt) {
+ this.createdAt = createdAt;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/UserMessages.java b/src/main/java/com/example/myproject/entity/UserMessages.java
new file mode 100644
index 0000000..ee7e43e
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/UserMessages.java
@@ -0,0 +1,67 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "user_messages")
+public class UserMessages {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "message_id")
+ private Long messageId;
+
+ @Column(name = "sender_id")
+ private Long senderId;
+
+ @Column(name = "receiver_id")
+ private Long receiverId;
+
+ @Column(name = "content")
+ private String content;
+
+ @Column(name = "time")
+ private Date time;
+
+
+ public Long getMessageId() {
+ return messageId;
+ }
+
+ public void setMessageId(Long messageId) {
+ this.messageId = messageId;
+ }
+
+ public Long getSenderId() {
+ return senderId;
+ }
+
+ public void setSenderId(Long senderId) {
+ this.senderId = senderId;
+ }
+
+ public Long getReceiverId() {
+ return receiverId;
+ }
+
+ public void setReceiverId(Long receiverId) {
+ this.receiverId = receiverId;
+ }
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
+
+ public Date getTime() {
+ return time;
+ }
+
+ public void setTime(Date time) {
+ this.time = time;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/UserTaskStatus.java b/src/main/java/com/example/myproject/entity/UserTaskStatus.java
new file mode 100644
index 0000000..a66839d
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/UserTaskStatus.java
@@ -0,0 +1,98 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "user_task_status")
+public class UserTaskStatus {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "status_id")
+ private Long statusId;
+
+ @Column(name = "user_id", nullable = false)
+ private Long userId;
+
+ @Column(name = "task_id", nullable = false)
+ private String taskId;
+
+ @Column(name = "current_progress", nullable = false)
+ private Float currentProgress;
+
+ @Column(name = "current_experience", nullable = false)
+ private Integer currentExperience;
+
+ @Column(name = "current_points", nullable = false)
+ private Integer currentPoints;
+
+ @Column(name = "status", nullable = false)
+ private String status;
+
+ @Column(name = "is_reward_claimed", nullable = false)
+ private Boolean isRewardClaimed = false;
+
+ public Long getStatusId() {
+ return statusId;
+ }
+
+ public void setStatusId(Long statusId) {
+ this.statusId = statusId;
+ }
+
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getTaskId() {
+ return taskId;
+ }
+
+ public void setTaskId(String taskId) {
+ this.taskId = taskId;
+ }
+
+ public Float getCurrentProgress() {
+ return currentProgress;
+ }
+
+ public void setCurrentProgress(Float currentProgress) {
+ this.currentProgress = currentProgress;
+ }
+
+ public Integer getCurrentExperience() {
+ return currentExperience;
+ }
+
+ public void setCurrentExperience(Integer currentExperience) {
+ this.currentExperience = currentExperience;
+ }
+
+ public Integer getCurrentPoints() {
+ return currentPoints;
+ }
+
+ public void setCurrentPoints(Integer currentPoints) {
+ this.currentPoints = currentPoints;
+ }
+
+ public String getStatus() {
+ return status;
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+
+ public Boolean getIsRewardClaimed() {
+ return isRewardClaimed;
+ }
+
+ public void setIsRewardClaimed(Boolean isRewardClaimed) {
+ this.isRewardClaimed = isRewardClaimed;
+ }
+}
diff --git a/src/main/java/com/example/myproject/entity/Users.java b/src/main/java/com/example/myproject/entity/Users.java
new file mode 100644
index 0000000..ebe793f
--- /dev/null
+++ b/src/main/java/com/example/myproject/entity/Users.java
@@ -0,0 +1,246 @@
+package com.example.myproject.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "user")
+public class Users {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "user_id")
+ private Long userId;
+
+ @Column(name = "username", nullable = false,unique = true)
+ private String username;
+
+ @Column(name = "avatar_url", nullable = true)
+ private String avatarUrl;
+
+ @Column(name = "email", nullable = false)
+ private String email;
+
+ @Column(name = "password", nullable = false)
+ private String password;
+
+ @Column(name = "role", nullable = false)
+ private String role;
+
+ @Column(name = "invite_count")
+ private Integer inviteCount;
+
+ @Column(name = "level", nullable = false)
+ private Long level;
+
+ @Column(name = "upload_count")
+ private Float uploadCount;
+
+ @Column(name = "download_count")
+ private Float downloadCount;
+
+ @Column(name = "share_rate")
+ private Float shareRate;
+
+ @Column(name = "registration_date", nullable = false)
+ private Date registrationDate;
+
+ @Column(name = "last_login_time")
+ private Date lastLoginTime;
+
+ @Column(name = "user_points")
+ private Integer userPoints;
+
+ @Column(name = "is_promo")
+ private Boolean isPromo;
+
+ @Column(name = "current_experience", nullable = false)
+ private Integer currentExperience; // 当前经验值
+
+ @Column(name = "current_seeding_hours", nullable = false)
+ private Float currentSeedingHours; // 当前做种时长
+
+
+ @Column(name = "gender", nullable = true)
+ private String gender; // 性别
+
+ @Column(name = "description", nullable = true)
+ private String description; // 个人描述
+
+ @Column(name = "hobbies", nullable = true)
+ private String hobbies;
+
+ @Column(name = "registration_time", nullable = false, updatable = false)
+ @Temporal(TemporalType.TIMESTAMP)
+ private Date registrationTime;
+
+ // Getters and Setters
+ public Long getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Long userId) {
+ this.userId = userId;
+ }
+
+ public String getUsername() {
+ return username;
+ }
+
+ public void setUsername(String username) {
+ this.username = username;
+ }
+
+ public String getAvatarUrl() {
+ return avatarUrl;
+ }
+
+ public void setAvatarUrl(String avatarUrl) {
+ this.avatarUrl = avatarUrl;
+ }
+
+ public String getEmail() {
+ return email;
+ }
+
+ public void setEmail(String email) {
+ this.email = email;
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public String getRole() {
+ return role;
+ }
+
+ public void setRole(String role) {
+ this.role = role;
+ }
+
+ public Integer getInviteCount() {
+ return inviteCount;
+ }
+
+ public void setInviteCount(Integer inviteCount) {
+ this.inviteCount = inviteCount;
+ }
+
+ public Long getLevel() {
+ return level;
+ }
+
+ public void setLevel(Long level) {
+ this.level = level;
+ }
+
+ public Float getUploadCount() {
+ return uploadCount;
+ }
+
+ public void setUploadCount(Float uploadCount) {
+ this.uploadCount = uploadCount;
+ }
+
+ public Float getDownloadCount() {
+ return downloadCount;
+ }
+
+ public void setDownloadCount(Float downloadCount) {
+ this.downloadCount = downloadCount;
+ }
+
+ public Float getShareRate() {
+ return shareRate;
+ }
+
+ public void setShareRate(Float shareRate) {
+ this.shareRate = shareRate;
+ }
+
+ public Date getRegistrationDate() {
+ return registrationDate;
+ }
+
+ public void setRegistrationDate(Date registrationDate) {
+ this.registrationDate = registrationDate;
+ }
+
+ public Date getLastLoginTime() {
+ return lastLoginTime;
+ }
+
+ public void setLastLoginTime(Date lastLoginTime) {
+ this.lastLoginTime = lastLoginTime;
+ }
+
+ public Integer getUserPoints() {
+ return userPoints;
+ }
+
+ public void setUserPoints(Integer userPoints) {
+ this.userPoints = userPoints;
+ }
+
+ public Boolean getIsPromo() {
+ return isPromo;
+ }
+
+ public void setIsPromo(Boolean isPromo) {
+ this.isPromo = isPromo;
+ }
+
+ public Integer getCurrentExperience() {
+ return currentExperience;
+ }
+
+ public void setCurrentExperience(Integer currentExperience) {
+ this.currentExperience = currentExperience;
+ }
+
+ public Float getCurrentSeedingHours() {
+ return currentSeedingHours;
+ }
+
+ public void setCurrentSeedingHours(Float currentSeedingHours) {
+ this.currentSeedingHours = currentSeedingHours;
+ }
+
+ public String getGender() {
+ return gender;
+ }
+
+ public void setGender(String gender) {
+ this.gender = gender;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ public String getHobbies() {
+ return hobbies;
+ }
+
+ public void setHobbies(String hobbies) {
+ this.hobbies = hobbies;
+ }
+
+ public Date getRegistrationTime() {
+ return registrationTime;
+ }
+
+ public void setRegistrationTime(Date registrationTime) {
+ this.registrationTime = registrationTime;
+ }
+
+}
diff --git a/src/main/java/com/example/myproject/repository/CollectionsRepository.java b/src/main/java/com/example/myproject/repository/CollectionsRepository.java
new file mode 100644
index 0000000..4b192bd
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/CollectionsRepository.java
@@ -0,0 +1,16 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Collections;
+import jakarta.transaction.Transactional;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface CollectionsRepository extends JpaRepository<Collections, Long> {
+ @Modifying
+ @Transactional
+ @Query("DELETE FROM Collections l WHERE l.userId = :userId AND l.postNo = :postNo")
+ void deleteLikeByUserIdAndPostNo(Long userId, Long postNo);
+}
diff --git a/src/main/java/com/example/myproject/repository/CommentRepository.java b/src/main/java/com/example/myproject/repository/CommentRepository.java
new file mode 100644
index 0000000..4f66309
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/CommentRepository.java
@@ -0,0 +1,9 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Comments;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface CommentRepository extends JpaRepository<Comments, Long> {
+
+}
diff --git a/src/main/java/com/example/myproject/repository/DynamicCommentRepository.java b/src/main/java/com/example/myproject/repository/DynamicCommentRepository.java
new file mode 100644
index 0000000..f586b1d
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/DynamicCommentRepository.java
@@ -0,0 +1,11 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.DynamicComment;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface DynamicCommentRepository extends JpaRepository<DynamicComment, Long> {
+
+ List<DynamicComment> findByDynamicId(Long dynamicId);
+}
diff --git a/src/main/java/com/example/myproject/repository/DynamicLikesRepository.java b/src/main/java/com/example/myproject/repository/DynamicLikesRepository.java
new file mode 100644
index 0000000..1cec003
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/DynamicLikesRepository.java
@@ -0,0 +1,12 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.DynamicLikes;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface DynamicLikesRepository extends JpaRepository<DynamicLikes, Long> {
+
+ List<DynamicLikes> findByDynamicId(Long dynamicId);
+ DynamicLikes findByUserIdAndDynamicId(Long userId, Long dynamicId);
+}
diff --git a/src/main/java/com/example/myproject/repository/ExperienceHistoryRepository.java b/src/main/java/com/example/myproject/repository/ExperienceHistoryRepository.java
new file mode 100644
index 0000000..76928e5
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/ExperienceHistoryRepository.java
@@ -0,0 +1,8 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.ExperienceHistory;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ExperienceHistoryRepository extends JpaRepository<ExperienceHistory, Long> {
+
+}
diff --git a/src/main/java/com/example/myproject/repository/FriendRelationRepository.java b/src/main/java/com/example/myproject/repository/FriendRelationRepository.java
new file mode 100644
index 0000000..8fcf94e
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/FriendRelationRepository.java
@@ -0,0 +1,11 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.FriendRelation;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface FriendRelationRepository extends JpaRepository<FriendRelation, Long> {
+ // 查找当前用户的所有好友ID
+ List<FriendRelation> findByUserId(Long userId);
+}
diff --git a/src/main/java/com/example/myproject/repository/GroupCommentsRepository.java b/src/main/java/com/example/myproject/repository/GroupCommentsRepository.java
new file mode 100644
index 0000000..47df198
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/GroupCommentsRepository.java
@@ -0,0 +1,10 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.GroupComments;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface GroupCommentsRepository extends JpaRepository<GroupComments, Long> {
+
+}
diff --git a/src/main/java/com/example/myproject/repository/GroupMembersRepository.java b/src/main/java/com/example/myproject/repository/GroupMembersRepository.java
new file mode 100644
index 0000000..2d31462
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/GroupMembersRepository.java
@@ -0,0 +1,20 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.GroupMembers;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface GroupMembersRepository extends JpaRepository<GroupMembers, Long> {
+
+ // 检查用户是否已经是该小组的成员
+ boolean existsByGroupIdAndUserId(Long groupId, Long userId);
+
+ // 删除用户和小组的关联记录
+ void deleteByGroupIdAndUserId(Long groupId, Long userId);
+
+ // 通过 groupId 获取所有成员的 userId
+ List<GroupMembers> findByGroupId(Long groupId);
+}
diff --git a/src/main/java/com/example/myproject/repository/GroupPostRepository.java b/src/main/java/com/example/myproject/repository/GroupPostRepository.java
new file mode 100644
index 0000000..9f5a348
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/GroupPostRepository.java
@@ -0,0 +1,14 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.GroupPost;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface GroupPostRepository extends JpaRepository<GroupPost, Long> {
+
+ List<GroupPost> findByGroupId(Long groupId);
+
+}
diff --git a/src/main/java/com/example/myproject/repository/GroupRepository.java b/src/main/java/com/example/myproject/repository/GroupRepository.java
new file mode 100644
index 0000000..7280e50
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/GroupRepository.java
@@ -0,0 +1,21 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Group;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface GroupRepository extends JpaRepository<Group, Long> {
+
+ // 模糊搜索小组名称并按类别筛选
+ @Query("SELECT g FROM Group g WHERE g.groupName LIKE %:name% AND (:category IS NULL OR g.category = :category)")
+ Page<Group> searchGroups(@Param("name") String name, @Param("category") String category, Pageable pageable);
+
+ // 根据类别筛选小组
+ @Query("SELECT g FROM Group g WHERE (:category IS NULL OR g.category = :category)")
+ Page<Group> searchWithFilters(@Param("category") String category, Pageable pageable);
+}
diff --git a/src/main/java/com/example/myproject/repository/LevelRepository.java b/src/main/java/com/example/myproject/repository/LevelRepository.java
new file mode 100644
index 0000000..12e8269
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/LevelRepository.java
@@ -0,0 +1,10 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Level;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface LevelRepository extends JpaRepository<Level, Long> {
+
+}
diff --git a/src/main/java/com/example/myproject/repository/LikesRepository.java b/src/main/java/com/example/myproject/repository/LikesRepository.java
new file mode 100644
index 0000000..79146c5
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/LikesRepository.java
@@ -0,0 +1,16 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Likes;
+import jakarta.transaction.Transactional;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface LikesRepository extends JpaRepository<Likes, Long> {
+ @Modifying
+ @Transactional
+ @Query("DELETE FROM Likes l WHERE l.userId = :userId AND l.postNo = :postNo")
+ void deleteLikeByUserIdAndPostNo(Long userId, Long postNo);
+}
diff --git a/src/main/java/com/example/myproject/repository/PostRepository.java b/src/main/java/com/example/myproject/repository/PostRepository.java
new file mode 100644
index 0000000..faf2cb7
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/PostRepository.java
@@ -0,0 +1,12 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Post;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface PostRepository extends JpaRepository<Post, Long> {
+ // 根据 postNo 查找帖子
+ Optional<Post> findByPostNo(Long postNo);
+
+}
diff --git a/src/main/java/com/example/myproject/repository/TaskRepository.java b/src/main/java/com/example/myproject/repository/TaskRepository.java
new file mode 100644
index 0000000..25e1b66
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/TaskRepository.java
@@ -0,0 +1,7 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Task;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface TaskRepository extends JpaRepository<Task, String> {
+}
diff --git a/src/main/java/com/example/myproject/repository/UserDynamicRepository.java b/src/main/java/com/example/myproject/repository/UserDynamicRepository.java
new file mode 100644
index 0000000..575ae1f
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserDynamicRepository.java
@@ -0,0 +1,14 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.UserDynamic;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface UserDynamicRepository extends JpaRepository<UserDynamic, Long> {
+
+ List<UserDynamic> findByUserId(Long userId);
+
+}
diff --git a/src/main/java/com/example/myproject/repository/UserFollowRepository.java b/src/main/java/com/example/myproject/repository/UserFollowRepository.java
new file mode 100644
index 0000000..542d07f
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserFollowRepository.java
@@ -0,0 +1,16 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.UserFollow;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface UserFollowRepository extends JpaRepository<UserFollow, Long> {
+
+ // 查询是否存在某个用户的关注记录
+ UserFollow findByFollowerIdAndFollowedId(Long followerId, Long followedId);
+ List<UserFollow> findByFollowedId(Long followedId);
+ List<UserFollow> findByFollowerId(Long followerId);
+}
diff --git a/src/main/java/com/example/myproject/repository/UserInviteCodeRepository.java b/src/main/java/com/example/myproject/repository/UserInviteCodeRepository.java
new file mode 100644
index 0000000..02fa390
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserInviteCodeRepository.java
@@ -0,0 +1,19 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.UserInviteCode;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface UserInviteCodeRepository extends JpaRepository<UserInviteCode, Long> {
+
+ // 查找某个用户的所有邀请码
+ List<UserInviteCode> findByUserId(Long userId);
+
+ // 查找某个邀请码是否已经被使用
+ Optional<UserInviteCode> findByInviteCode(String inviteCode);
+
+ // 查找某个用户未使用的邀请码
+ List<UserInviteCode> findByUserIdAndIsUsedFalse(Long userId);
+}
diff --git a/src/main/java/com/example/myproject/repository/UserMessagesRepository.java b/src/main/java/com/example/myproject/repository/UserMessagesRepository.java
new file mode 100644
index 0000000..bad3715
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserMessagesRepository.java
@@ -0,0 +1,14 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.UserMessages;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface UserMessagesRepository extends JpaRepository<UserMessages, Long> {
+
+ // 查询当前用户的所有消息
+ List<UserMessages> findBySenderIdOrReceiverId(Long senderId, Long receiverId);
+}
diff --git a/src/main/java/com/example/myproject/repository/UserRepository.java b/src/main/java/com/example/myproject/repository/UserRepository.java
new file mode 100644
index 0000000..6927c5f
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserRepository.java
@@ -0,0 +1,10 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.Users;
+import org.springframework.data.jpa.repository.JpaRepository;
+import java.util.Optional;
+
+public interface UserRepository extends JpaRepository<Users, Long> {
+ Optional<Users> findByEmail(String email);
+ Optional<Users> findByUsername(String username);
+}
diff --git a/src/main/java/com/example/myproject/repository/UserTaskStatusRepository.java b/src/main/java/com/example/myproject/repository/UserTaskStatusRepository.java
new file mode 100644
index 0000000..0153946
--- /dev/null
+++ b/src/main/java/com/example/myproject/repository/UserTaskStatusRepository.java
@@ -0,0 +1,13 @@
+package com.example.myproject.repository;
+
+import com.example.myproject.entity.UserTaskStatus;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface UserTaskStatusRepository extends JpaRepository<UserTaskStatus, Long> {
+ Optional<UserTaskStatus> findByUserIdAndTaskId(Long userId, String taskId);
+ List<UserTaskStatus> findByUserIdAndStatus(Long userId, String status);
+ Optional<UserTaskStatus> findFirstByUserIdAndStatus(Long userId, String status);
+}
diff --git a/src/main/java/com/example/myproject/service/CommentService.java b/src/main/java/com/example/myproject/service/CommentService.java
new file mode 100644
index 0000000..c102ca2
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/CommentService.java
@@ -0,0 +1,125 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.Comments;
+import com.example.myproject.entity.Post;
+import com.example.myproject.entity.Users;
+import com.example.myproject.repository.CommentRepository;
+import com.example.myproject.repository.PostRepository;
+import com.example.myproject.repository.UserRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Service
+public class CommentService {
+
+ @Autowired
+ private CommentRepository commentRepository;
+
+ @Autowired
+ private PostRepository postRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+
+ // 添加评论
+ public void addComment(Long postId, Comments comment) {
+ try {
+ // 查找帖子
+ Post post = postRepository.findById(postId).orElseThrow(() -> {
+ throw new RuntimeException("Post with ID " + postId + " not found");
+ });
+
+ // 查找用户
+ Users user = userRepository.findById(comment.getUserId()).orElseThrow(() -> {
+ throw new RuntimeException("User with ID " + comment.getUserId() + " not found");
+ });
+
+ // 设置评论的相关属性
+ comment.setPost(post);
+ comment.setUserId(user.getUserId());
+ comment.setCommentTime(new java.util.Date());
+
+ if (comment.getParentComment() != null && comment.getParentComment() != 0) {
+ // 查找父评论
+ Comments parentComment = commentRepository.findById(comment.getParentComment())
+ .orElseThrow(() -> new RuntimeException("Parent comment with ID " + comment.getParentComment() + " not found"));
+ comment.setParentComment(parentComment.getCommentId()); // 设置父评论 ID
+ } else {
+ comment.setParentComment(0L); // 设置为 0，表示没有父评论
+ }
+
+ // 保存评论
+ commentRepository.save(comment);
+ } catch (Exception e) {
+ // 捕获任何异常并打印堆栈信息
+ e.printStackTrace();
+ throw new RuntimeException("An error occurred while adding the comment: " + e.getMessage());
+ }
+ }
+
+ // 获取指定帖子的所有评论
+ public List<Map<String, Object>> getCommentsByPostId(Long postId) {
+ List<Comments> comments = commentRepository.findAll()
+ .stream()
+ .filter(comment -> comment.getPost().getPostNo().equals(postId)) // 通过 post 的 postNo 过滤评论
+ .collect(Collectors.toList());
+
+ if (comments.isEmpty()) {
+ return new ArrayList<>();
+ }
+
+ List<Map<String, Object>> result = new ArrayList<>();
+ for (Comments comment : comments) {
+ Map<String, Object> commentData = new LinkedHashMap<>();
+ commentData.put("commentId", comment.getCommentId());
+ commentData.put("post_id", comment.getPost().getPostNo());
+ commentData.put("userId", comment.getUserId());
+
+ Users user = userRepository.findById(comment.getUserId()).orElse(null);
+ commentData.put("nickname", user != null ? user.getUsername() : null);
+ commentData.put("avatar_url", user != null ? user.getAvatarUrl() : null);
+
+ commentData.put("content", comment.getContent());
+ commentData.put("isAnonymous", comment.getIsAnonymous());
+ commentData.put("likesCount", comment.getLikesCount());
+ commentData.put("replyCount", comment.getReplyCount());
+ commentData.put("commentTime", comment.getCommentTime());
+ commentData.put("parentComment", comment.getParentComment());
+
+ Map<String, Object> parentCommentData = getParentCommentData(comment.getParentComment());
+ commentData.put("parentCommentData", parentCommentData);
+
+ result.add(commentData);
+ }
+
+ return result;
+ }
+
+ // 递归查找父评论的内容
+ private Map<String, Object> getParentCommentData(Long parentCommentId) {
+ Map<String, Object> parentCommentData = new LinkedHashMap<>();
+ if (parentCommentId != null && parentCommentId != 0) {
+ // 查找父评论
+ Comments parentComment = commentRepository.findById(parentCommentId).orElse(null);
+ if (parentComment != null) {
+ parentCommentData.put("commentId", parentComment.getCommentId());
+ parentCommentData.put("content", parentComment.getContent());
+ parentCommentData.put("userId", parentComment.getUserId());
+
+ Users user = userRepository.findById(parentComment.getUserId()).orElse(null);
+ parentCommentData.put("nickname", user != null ? user.getUsername() : null);
+ parentCommentData.put("avatar_url", user != null ? user.getAvatarUrl() : null);
+
+ Map<String, Object> grandParentData = getParentCommentData(parentComment.getParentComment());
+ parentCommentData.put("parentCommentData", grandParentData);
+ }
+ }
+ return parentCommentData;
+ }
+}
diff --git a/src/main/java/com/example/myproject/service/DynamicService.java b/src/main/java/com/example/myproject/service/DynamicService.java
new file mode 100644
index 0000000..853604d
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/DynamicService.java
@@ -0,0 +1,275 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.*;
+import com.example.myproject.repository.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.*;
+
+@Service
+public class DynamicService {
+
+ @Autowired
+ private UserDynamicRepository userDynamicRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+
+ @Autowired
+ private DynamicCommentRepository dynamicCommentRepository;
+
+ @Autowired
+ private DynamicLikesRepository dynamicLikesRepository;
+
+ @Autowired
+ private FriendRelationRepository friendRelationRepository;
+
+ private static final String IMAGE_DIR = "uploads/post/";
+
+ // 创建好友动态
+ public Map<String, Object> createDynamic(Long userId, String title, String content, MultipartFile[] imageFiles) {
+ // 查找用户信息
+ Users user = userRepository.findById(userId)
+ .orElseThrow(() -> new RuntimeException("User not found"));
+
+ // 创建新的动态
+ UserDynamic userDynamic = new UserDynamic();
+ userDynamic.setUserId(userId);
+ userDynamic.setTitle(title != null ? title : "默认标题");
+ userDynamic.setContent(content);
+ userDynamic.setTime(new Date());
+ userDynamic.setLikesCount(0);
+ userDynamic.setCommentsCount(0);
+
+ // 处理图片上传
+ StringBuilder imageUrlsBuilder = new StringBuilder();
+ if (imageFiles != null && imageFiles.length > 0) {
+ for (int i = 0; i < imageFiles.length; i++) {
+ if (i > 0) {
+ imageUrlsBuilder.append(",");
+ }
+ try {
+ String imageUrl = saveImage(imageFiles[i]);
+ imageUrlsBuilder.append(imageUrl);
+ } catch (IOException e) {
+ throw new RuntimeException("Image upload failed: " + e.getMessage());
+ }
+ }
+ }
+
+ // 将多个图片 URL 拼接
+ userDynamic.setImageUrl(imageUrlsBuilder.toString());
+
+ // 保存数据库
+ UserDynamic savedUserDynamic = userDynamicRepository.save(userDynamic);
+
+ // 返回结果
+ Map<String, Object> response = new HashMap<>();
+ response.put("dynamicId", savedUserDynamic.getDynamicId());
+ response.put("message", "动态创建成功");
+ return response;
+ }
+
+ // 保存图片并返回图片的 URL
+ public String saveImage(MultipartFile imageFile) throws IOException {
+ String fileName = imageFile.getOriginalFilename();
+ Path path = Paths.get(IMAGE_DIR + fileName);
+ Files.createDirectories(path.getParent());
+ Files.write(path, imageFile.getBytes());
+ return "/images/" + fileName;
+ }
+
+ // 删除动态
+ public void deleteDynamic(Long dynamicId) {
+ if (userDynamicRepository.existsById(dynamicId)) {
+ userDynamicRepository.deleteById(dynamicId);
+ } else {
+ throw new RuntimeException("Dynamic with id " + dynamicId + " not found");
+ }
+ }
+
+ //好友动态评论
+ public Map<String, Object> addComment(Long userId, Long dynamicId, String commentContent) {
+ Users user = userRepository.findById(userId)
+ .orElseThrow(() -> new RuntimeException("User not found"));
+
+ UserDynamic dynamic = userDynamicRepository.findById(dynamicId)
+ .orElseThrow(() -> new RuntimeException("Dynamic not found"));
+
+ DynamicComment comment = new DynamicComment();
+ comment.setDynamicId(dynamicId);
+ comment.setUserId(userId);
+ comment.setCommentContent(commentContent);
+ comment.setCommentTime(new Date());
+
+ // 保存评论
+ DynamicComment savedComment = dynamicCommentRepository.save(comment);
+
+ // 返回成功消息
+ Map<String, Object> response = new HashMap<>();
+ response.put("comment_id", savedComment.getCommentId());
+ response.put("message", "评论成功");
+ return response;
+ }
+
+ //返回某个好友的所有动态
+ public Map<String, Object> getAllUserDynamics(Long userId) {
+ // 查找用户的所有动态
+ List<UserDynamic> userDynamics = userDynamicRepository.findByUserId(userId);
+ Map<String, Object> postData = new LinkedHashMap<>();
+ List<Map<String, Object>> dynamicList = new ArrayList<>();
+
+ // 遍历动态，获取点赞和评论
+ for (UserDynamic dynamic : userDynamics) {
+ Map<String, Object> dynamicData = new LinkedHashMap<>();
+ dynamicData.put("dynamic_id", dynamic.getDynamicId());
+ dynamicData.put("user_id", dynamic.getUserId());
+
+ Users user = userRepository.findById(dynamic.getUserId()).orElse(null);
+ if (user != null) {
+ dynamicData.put("username", user.getUsername());
+ dynamicData.put("avatar_url", user.getAvatarUrl());
+ } else {
+ dynamicData.put("username", "Unknown");
+ dynamicData.put("avatar_url", "http://example.com/default-avatar.jpg");
+ }
+
+ dynamicData.put("title", dynamic.getTitle());
+ dynamicData.put("content", dynamic.getContent());
+ dynamicData.put("images", dynamic.getImageUrl());
+ dynamicData.put("time", dynamic.getTime());
+
+ // 获取点赞
+ List<DynamicLikes> likes = dynamicLikesRepository.findByDynamicId(dynamic.getDynamicId());
+ List<Map<String, Object>> likeList = new ArrayList<>();
+ for (DynamicLikes like : likes) {
+ Map<String, Object> likeData = new HashMap<>();
+ likeData.put("user_id", like.getUserId());
+
+ // 获取点赞用户的用户名
+ Users likeUser = userRepository.findById(like.getUserId()).orElse(null);
+ if (likeUser != null) {
+ likeData.put("username", likeUser.getUsername());
+ } else {
+ likeData.put("username", "Unknown");
+ }
+
+ likeList.add(likeData);
+ }
+ dynamicData.put("likes", likeList);
+
+ // 获取评论
+ List<DynamicComment> comments = dynamicCommentRepository.findByDynamicId(dynamic.getDynamicId());
+ List<Map<String, Object>> commentList = new ArrayList<>();
+ for (DynamicComment comment : comments) {
+ Map<String, Object> commentData = new HashMap<>();
+ commentData.put("comment_id", comment.getCommentId());
+ commentData.put("user_id", comment.getUserId());
+
+ // 获取评论用户的用户名
+ Users commentUser = userRepository.findById(comment.getUserId()).orElse(null);
+ if (commentUser != null) {
+ commentData.put("username", commentUser.getUsername());
+ } else {
+ commentData.put("username", "Unknown");
+ }
+
+ commentData.put("content", comment.getCommentContent());
+ commentData.put("time", comment.getCommentTime());
+ commentList.add(commentData);
+ }
+ dynamicData.put("comments", commentList);
+
+ dynamicList.add(dynamicData);
+ }
+
+ Map<String, Object> response = new HashMap<>();
+ response.put("dynamic", dynamicList);
+ return response;
+ }
+
+ //获取当前所有好友的id
+ public List<Long> getAllFriendIds(Long userId) {
+ List<FriendRelation> friendRelations = friendRelationRepository.findByUserId(userId);
+ List<Long> friendIds = new ArrayList<>();
+
+ for (FriendRelation relation : friendRelations) {
+ // 添加好友ID
+ if (!friendIds.contains(relation.getFriendId())) {
+ friendIds.add(relation.getFriendId());
+ }
+ }
+
+ return friendIds;
+ }
+
+ public Map<String, Object> getAllUserAndFriendsDynamics(List<Long> userIds) {
+ List<Map<String, Object>> allDynamics = new ArrayList<>();
+
+ // 遍历所有用户获取他们的动态
+ for (Long userId : userIds) {
+ Map<String, Object> userDynamics = getAllUserDynamics(userId);
+ if (userDynamics != null && !userDynamics.isEmpty()) {
+ allDynamics.addAll((List<Map<String, Object>>) userDynamics.get("dynamic"));
+ }
+ }
+
+ // 返回所有动态的合集
+ Map<String, Object> response = new HashMap<>();
+ response.put("dynamic", allDynamics);
+ return response;
+ }
+
+ //点赞动态
+ public boolean likeDynamic(Long userId, Long dynamicId) {
+ // 检查该用户是否已经点赞过该动态
+ DynamicLikes existingLike = dynamicLikesRepository.findByUserIdAndDynamicId(userId, dynamicId);
+ if (existingLike != null) {
+ return false;
+ }
+
+ // 新增点赞记录
+ DynamicLikes newLike = new DynamicLikes();
+ newLike.setUserId(userId);
+ newLike.setDynamicId(dynamicId);
+ newLike.setLikeTime(new java.util.Date());
+ dynamicLikesRepository.save(newLike);
+
+ // 更新动态表的点赞数
+ UserDynamic dynamic = userDynamicRepository.findById(dynamicId).orElse(null);
+ if (dynamic != null) {
+ dynamic.setLikesCount(dynamic.getLikesCount() + 1);
+ userDynamicRepository.save(dynamic);
+ }
+
+ return true;
+ }
+
+ //取消点赞
+ public boolean unlikeDynamic(Long userId, Long dynamicId) {
+ // 查找该用户的点赞记录
+ DynamicLikes existingLike = dynamicLikesRepository.findByUserIdAndDynamicId(userId, dynamicId);
+ if (existingLike == null) {
+ return false;
+ }
+
+ // 删除点赞记录
+ dynamicLikesRepository.delete(existingLike);
+
+ // 更新动态表的点赞数
+ UserDynamic dynamic = userDynamicRepository.findById(dynamicId).orElse(null);
+ if (dynamic != null) {
+ dynamic.setLikesCount(dynamic.getLikesCount() - 1);
+ userDynamicRepository.save(dynamic);
+ }
+
+ return true;
+ }
+
+}
diff --git a/src/main/java/com/example/myproject/service/GroupService.java b/src/main/java/com/example/myproject/service/GroupService.java
new file mode 100644
index 0000000..016d7e0
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/GroupService.java
@@ -0,0 +1,382 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.*;
+
+import com.example.myproject.repository.*;
+import jakarta.transaction.Transactional;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+import java.io.IOException;
+import java.nio.file.Path;
+import java.nio.file.Files;
+
+import java.util.*;
+
+@Service
+public class GroupService {
+
+ @Autowired
+ private GroupRepository groupRepository;
+
+ @Autowired
+ private GroupMembersRepository groupMembersRepository;
+
+
+ @Autowired
+ private UserRepository userRepository;
+
+ @Autowired
+ private GroupPostRepository groupPostRepository;
+
+ @Autowired
+ private GroupCommentsRepository groupCommentsRepository;
+
+ private static final String IMAGE_DIR = "uploads/groupPost/";
+
+ @Transactional
+ // 创建小组的方法
+ public ResponseEntity<Map<String, Object>> createGroup(Group groupRequest) {
+ try {
+ // 创建新的小组对象
+ Group newGroup = new Group();
+ newGroup.setGroupName(groupRequest.getGroupName());
+ newGroup.setDescription(groupRequest.getDescription());
+ newGroup.setCreateTime(new Date());
+ newGroup.setUserId(groupRequest.getUserId());
+ newGroup.setMemberCount(1);
+ newGroup.setCategory(groupRequest.getCategory());
+ newGroup.setCoverImage(groupRequest.getCoverImage());
+ Group createdGroup = groupRepository.save(newGroup);
+
+ // 返回成功响应
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "兴趣小组创建成功");
+ response.put("group_id", createdGroup.getGroupId());
+
+ return ResponseEntity.ok(response);
+ } catch (Exception e) {
+ // 返回失败响应
+ Map<String, Object> errorResponse = new HashMap<>();
+ errorResponse.put("status", "error");
+ errorResponse.put("message", "小组创建失败");
+ errorResponse.put("group_id", null);
+
+ return ResponseEntity.status(400).body(errorResponse);
+ }
+ }
+
+
+ // 加入小组
+ @Transactional
+ public ResponseEntity<Map<String, Object>> joinGroup(Long groupId, Long userId) {
+ // 查找小组
+ Optional<Group> groupOptional = groupRepository.findById(groupId);
+ if (!groupOptional.isPresent()) {
+ return ResponseEntity.status(400).body(
+ Map.of("status", "failure", "message", "小组不存在")
+ );
+ }
+
+ Group group = groupOptional.get();
+
+ // 检查用户是否已经是该小组成员
+ if (groupMembersRepository.existsByGroupIdAndUserId(groupId, userId)) {
+ return ResponseEntity.status(400).body(
+ Map.of("status", "failure", "message", "用户已经是该小组的成员")
+ );
+ }
+
+ // 插入用户和小组的关联记录
+ GroupMembers groupMembers = new GroupMembers();
+ groupMembers.setGroupId(groupId);
+ groupMembers.setUserId(userId);
+ groupMembersRepository.save(groupMembers);
+
+ // 更新小组的成员数
+ group.setMemberCount(group.getMemberCount() + 1);
+ groupRepository.save(group);
+
+ return ResponseEntity.ok().body(
+ Map.of("status", "success", "message", "成功加入小组")
+ );
+ }
+
+ // 退出小组
+ @Transactional
+ public ResponseEntity<Map<String, Object>> leaveGroup(Long groupId, Long userId) {
+ // 查找小组
+ Optional<Group> groupOptional = groupRepository.findById(groupId);
+ if (!groupOptional.isPresent()) {
+ return ResponseEntity.status(400).body(
+ Map.of("status", "failure", "message", "小组不存在")
+ );
+ }
+
+ Group group = groupOptional.get();
+
+ // 检查用户是否是该小组成员
+ if (!groupMembersRepository.existsByGroupIdAndUserId(groupId, userId)) {
+ return ResponseEntity.status(400).body(
+ Map.of("status", "failure", "message", "用户不是该小组的成员")
+ );
+ }
+
+ // 删除用户和小组的关联记录
+ groupMembersRepository.deleteByGroupIdAndUserId(groupId, userId);
+
+ // 更新小组的成员数
+ group.setMemberCount(group.getMemberCount() - 1);
+ groupRepository.save(group);
+
+ return ResponseEntity.ok().body(
+ Map.of("status", "success", "message", "成功退出小组")
+ );
+ }
+
+ // 获取所有成员
+ @Transactional
+ public ResponseEntity<Map<String, Object>> getGroupMembers(Long groupId) {
+ // 查找小组
+ Optional<Group> groupOptional = groupRepository.findById(groupId);
+ if (!groupOptional.isPresent()) {
+ return ResponseEntity.status(400).body(
+ Map.of("status", "failure", "message", "小组不存在")
+ );
+ }
+
+ Group group = groupOptional.get();
+
+ // 获取所有小组成员
+ List<GroupMembers> groupMembersList = groupMembersRepository.findByGroupId(groupId);
+
+ // 创建成员返回列表
+ List<Map<String, Object>> members = new ArrayList<>();
+ for (GroupMembers groupMember : groupMembersList) {
+ Optional<Users> userOptional = userRepository.findById(groupMember.getUserId());
+ if (userOptional.isPresent()) {
+ Users user = userOptional.get();
+ members.add(Map.of(
+ "user_id", user.getUserId(),
+ "username", user.getUsername(),
+ "avatar_url", user.getAvatarUrl()
+ ));
+ }
+ }
+
+ return ResponseEntity.ok().body(
+ Map.of("status", "success", "members", members)
+ );
+ }
+
+
+ //发布帖子
+ public Map<String, Object> createPost(Long groupId, Long userId, String postContent, String title, MultipartFile[] imageFiles) {
+ // 创建一个新的帖子对象
+ GroupPost post = new GroupPost();
+ post.setGroupId(groupId);
+ post.setUserId(userId);
+ post.setContent(postContent);
+ post.setTitle(title);
+ post.setTime(new Date());
+ post.setLikeCount(0);
+ post.setCommentCount(0);
+
+ // 处理图片上传，如果没有图片，返回空字符串
+ String imageUrls = handleImages(imageFiles);
+ post.setImage(imageUrls);
+
+ // 保存帖子到数据库
+ GroupPost savedPost = groupPostRepository.save(post);
+
+ // 返回结果
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("post_id", savedPost.getGroupPostId());
+ response.put("message", "帖子创建成功");
+ return response;
+ }
+
+ // 处理图片上传的方法，返回图片的 URL 字符串
+ private String handleImages(MultipartFile[] imageFiles) {
+ if (imageFiles == null || imageFiles.length == 0) {
+ return "";
+ }
+
+ StringBuilder imageUrlsBuilder = new StringBuilder();
+
+ for (int i = 0; i < imageFiles.length; i++) {
+ if (i > 0) {
+ imageUrlsBuilder.append(",");
+ }
+ try {
+ String imageUrl = saveImage(imageFiles[i]);
+ imageUrlsBuilder.append(imageUrl);
+ } catch (IOException e) {
+ throw new RuntimeException("图片上传失败: " + e.getMessage());
+ }
+ }
+ return imageUrlsBuilder.toString();
+ }
+
+ // 保存图片并返回图片的 URL
+ private String saveImage(MultipartFile imageFile) throws IOException {
+ if (imageFile == null) {
+ throw new IOException("图片文件为空");
+ }
+
+ String fileName = imageFile.getOriginalFilename();
+ Path path = Path.of(IMAGE_DIR + fileName);
+ Files.createDirectories(path.getParent());
+ Files.write(path, imageFile.getBytes());
+ return "/images/" + fileName;
+ }
+
+ // 获取小组内的所有帖子
+ public Map<String, Object> getAllPosts(Long groupId) {
+ List<GroupPost> posts = groupPostRepository.findByGroupId(groupId);
+
+ List<Map<String, Object>> postList = new ArrayList<>();
+
+ for (GroupPost post : posts) {
+ Map<String, Object> postData = new HashMap<>();
+ Users user = userRepository.findById(post.getUserId()).orElseThrow(() -> new RuntimeException("User not found"));
+ postData.put("group_post_id", post.getGroupPostId());
+ postData.put("user_id", post.getUserId());
+ postData.put("username", user.getUsername());
+ postData.put("title", post.getTitle());
+ postData.put("content", post.getContent());
+ postData.put("time", post.getTime());
+
+ postList.add(postData);
+ }
+
+ // 返回响应数据
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("posts", postList);
+ return response;
+ }
+
+
+ // 获取小组列表接口
+ public Map<String, Object> searchGroups(Map<String, Object> params) {
+ String name = (String) params.get("name");
+ String category = (String) params.get("category");
+ Integer page = (Integer) params.getOrDefault("page", 1);
+ Integer size = (Integer) params.getOrDefault("size", 10);
+ String sortBy = (String) params.getOrDefault("sort_by", "memberCount");
+
+ // 构建分页对象
+ Pageable pageable;
+
+ // 根据 `sortBy` 判断排序方式
+ if ("createTime".equals(sortBy)) {
+ pageable = PageRequest.of(page - 1, size, Sort.by(Sort.Order.asc("createTime")));
+ } else if ("groupName".equals(sortBy)) {
+ pageable = PageRequest.of(page - 1, size, Sort.by(Sort.Order.asc("groupName")));
+ } else {
+ pageable = PageRequest.of(page - 1, size, Sort.by(Sort.Order.desc("memberCount")));
+ }
+
+ Page<Group> groups;
+ if (name != null && !name.isEmpty()) {
+ // 小组名称模糊查询
+ groups = groupRepository.searchGroups(name, category, pageable);
+ } else {
+ groups = groupRepository.searchWithFilters(category, pageable);
+ }
+
+ return buildResponse(groups);
+ }
+
+ // 构建返回的响应数据
+ private Map<String, Object> buildResponse(Page<Group> groups) {
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("total", groups.getTotalElements());
+ response.put("total_pages", groups.getTotalPages());
+ response.put("current_page", groups.getNumber() + 1);
+ response.put("items", groups.getContent());
+
+ return response;
+ }
+
+ // 点赞帖子
+ public Map<String, Object> likePost(Long GroupPostId) {
+ // 查找帖子
+ Optional<GroupPost> postOpt = groupPostRepository.findById(GroupPostId);
+ if (!postOpt.isPresent()) {
+ throw new RuntimeException("Post not found");
+ }
+
+ GroupPost post = postOpt.get();
+
+ // 更新点赞数
+ post.setLikeCount(post.getLikeCount() + 1);
+ groupPostRepository.save(post);
+
+ // 返回成功信息
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "点赞成功");
+ return response;
+ }
+
+ // 取消点赞
+ public Map<String, Object> unlikePost(Long GroupPostId) {
+ // 查找帖子
+ Optional<GroupPost> postOpt = groupPostRepository.findById(GroupPostId);
+ if (!postOpt.isPresent()) {
+ throw new RuntimeException("Post not found");
+ }
+
+ GroupPost post = postOpt.get();
+
+ // 更新点赞数
+ if (post.getLikeCount() > 0) {
+ post.setLikeCount(post.getLikeCount() - 1);
+ groupPostRepository.save(post);
+
+ // 返回成功信息
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "取消点赞成功");
+ return response;
+ } else {
+ // 如果点赞数已经是0，则返回相应消息
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "failure");
+ response.put("message", "无法取消点赞，点赞数已经为0");
+ return response;
+ }
+ }
+
+ // 添加评论并更新帖子的评论数
+ public Map<String, Object> addComment(Long postId, GroupComments comment) {
+ // 查找帖子
+ Optional<GroupPost> postOpt = groupPostRepository.findById(postId);
+ if (!postOpt.isPresent()) {
+ throw new RuntimeException("Post not found");
+ }
+
+ GroupPost post = postOpt.get();
+
+ comment.setGroupPostId(postId);
+ comment.setTime(new java.util.Date());
+ groupCommentsRepository.save(comment);
+ post.setCommentCount(post.getCommentCount() + 1);
+ groupPostRepository.save(post);
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "评论成功");
+ return response;
+ }
+
+
+}
diff --git a/src/main/java/com/example/myproject/service/LevelService.java b/src/main/java/com/example/myproject/service/LevelService.java
new file mode 100644
index 0000000..92f50ed
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/LevelService.java
@@ -0,0 +1,140 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.ExperienceHistory;
+import com.example.myproject.entity.Users;
+import com.example.myproject.entity.Level;
+import com.example.myproject.repository.ExperienceHistoryRepository;
+import com.example.myproject.repository.UserRepository;
+import com.example.myproject.repository.LevelRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+
+import java.util.Date;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.HashMap;
+
+@Service
+public class LevelService {
+
+ @Autowired
+ private UserRepository userRepository;
+
+ @Autowired
+ private LevelRepository levelRepository;
+
+ @Autowired
+ private ExperienceHistoryRepository experienceHistoryRepository;
+
+
+ public Map<String, Object> getUserExperience(Long userId) {
+ // 获取用户信息
+ Users user = userRepository.findById(userId).orElseThrow(() -> new RuntimeException("User not found"));
+
+ // 获取当前等级
+ Level currentLevel = levelRepository.findById(user.getLevel()).orElseThrow(() -> new RuntimeException("Level not found"));
+
+ // 获取下一个等级的经验需求
+ Level nextLevel = levelRepository.findById(currentLevel.getLevelId() + 1).orElse(null);
+
+ // 构建响应数据
+ Map<String, Object> response = new HashMap<>();
+ response.put("current_experience", user.getCurrentExperience());
+ response.put("level", currentLevel.getLevelName());
+ response.put("next_level_experience", nextLevel != null ? nextLevel.getRequiredExperience() : 0);
+
+ return response;
+ }
+
+ public Map<String, Object> updateExperience(Long userId, Integer experience, String source) {
+ // 获取用户信息
+ Users user = userRepository.findById(userId).orElseThrow(() -> new RuntimeException("用户不存在"));
+
+ // 更新用户的经验值
+ user.setCurrentExperience(user.getCurrentExperience() + experience);
+
+ // 保存更新后的用户信息
+ userRepository.save(user);
+
+ // 创建经验更新历史记录
+ ExperienceHistory experienceHistory = new ExperienceHistory();
+ experienceHistory.setUserId(userId);
+ experienceHistory.setExperienceChange(experience);
+ experienceHistory.setSource(source);
+ experienceHistory.setUpdateTime(new Date());
+
+ // 保存更新历史
+ experienceHistoryRepository.save(experienceHistory);
+
+ // 返回更新后的经验值和消息
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("message", "经验更新成功");
+ response.put("current_experience", user.getCurrentExperience()); // 返回更新后的经验值
+
+ return response;
+ }
+
+ public Map<String, Object> checkUpgrade(Long userId) {
+ // 获取用户信息
+ Users user = userRepository.findById(userId).orElseThrow(() -> new RuntimeException("用户不存在"));
+
+ // 获取当前等级
+ Level currentLevel = levelRepository.findById(user.getLevel())
+ .orElseThrow(() -> new RuntimeException("用户等级信息不存在"));
+
+ // 获取下一个等级的经验需求
+ Level nextLevel = levelRepository.findById(currentLevel.getLevelId() + 1).orElse(null);
+
+ // 构建响应数据
+ Map<String, Object> response = new LinkedHashMap<>();
+
+ // 判断用户是否可以升级
+ boolean canUpgrade = user.getCurrentExperience() >= (nextLevel != null ? nextLevel.getRequiredExperience() : 0);
+ response.put("can_upgrade", canUpgrade);
+ // 构建响应数据
+
+ response.put("next_level_experience", nextLevel != null ? nextLevel.getRequiredExperience() : 0);
+ response.put("current_experience", user.getCurrentExperience());
+
+
+ return response;
+ }
+
+ public Map<String, Object> upgradeUserLevel(Long userId, Boolean canUpgrade) {
+ // 获取用户信息
+ Users user = userRepository.findById(userId).orElseThrow(() -> new RuntimeException("User not found"));
+
+ // 创建响应对象
+ Map<String, Object> response = new HashMap<>();
+
+ if (canUpgrade) {
+ // 获取当前等级
+ Level currentLevel = levelRepository.findById(user.getLevel())
+ .orElseThrow(() -> new RuntimeException("Level not found"));
+
+ // 获取下一个等级的经验需求
+ Level nextLevel = levelRepository.findById(currentLevel.getLevelId() + 1).orElse(null);
+
+ if (nextLevel != null) {
+ user.setLevel(user.getLevel() + 1);
+ userRepository.save(user);
+ Level newLevel = levelRepository.findById(user.getLevel())
+ .orElseThrow(() -> new RuntimeException("Level not found"));
+ response.put("message", "升级成功");
+ response.put("status", "success");
+ response.put("new_level", newLevel.getLevelName());
+ } else {
+ response.put("message", "用户已达到最高等级");
+ response.put("status", "error");
+ }
+ } else {
+ response.put("message", "用户不满足升级条件");
+ response.put("status", "error");
+ }
+
+ return response;
+ }
+
+}
diff --git a/src/main/java/com/example/myproject/service/PostService.java b/src/main/java/com/example/myproject/service/PostService.java
new file mode 100644
index 0000000..feb7404
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/PostService.java
@@ -0,0 +1,232 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.Likes;
+import com.example.myproject.entity.Post;
+import com.example.myproject.entity.Users;
+import com.example.myproject.repository.CollectionsRepository;
+import com.example.myproject.repository.LikesRepository;
+import com.example.myproject.repository.PostRepository;
+import com.example.myproject.repository.UserRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+import com.example.myproject.entity.Collections;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.*;
+
+@Service
+public class PostService {
+
+ @Autowired
+ private PostRepository postRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+ @Autowired
+ private LikesRepository likesRepository;
+
+ @Autowired
+ private CollectionsRepository collectionsRepository;
+
+ private static final String IMAGE_DIR = "uploads/post/";
+
+
+ //创建帖子
+ public Map<String, Object> createPost(Long userId, String postContent, String title, MultipartFile[] imageFiles) {
+ // 查找用户信息
+ Users user = userRepository.findById(Long.valueOf(userId)).orElseThrow(() -> new RuntimeException("User not found"));
+ Post post = new Post();
+ post.setUser_id(user.getUserId());
+ post.setPostTime(new Date());
+ post.setPostLikeNum(0);
+ post.setPostCollectNum(0);
+ post.setPostContent(postContent);
+ post.setTitle(title);
+
+ // 处理多张图片的上传
+ StringBuilder imageUrlsBuilder = new StringBuilder();
+ if (imageFiles != null && imageFiles.length > 0) {
+ for (int i = 0; i < imageFiles.length; i++) {
+ if (i > 0) {
+ imageUrlsBuilder.append(",");
+ }
+ try {
+ String imageUrl = saveImage(imageFiles[i]);
+ imageUrlsBuilder.append(imageUrl);
+ } catch (IOException e) {
+ throw new RuntimeException("Image upload failed: " + e.getMessage());
+ }
+ }
+ }
+ post.setImageUrl(imageUrlsBuilder.toString());
+ Post savedPost = postRepository.save(post);
+ Map<String, Object> response = new HashMap<>();
+ response.put("postNo", savedPost.getPostNo());
+ response.put("message", "帖子创建成功");
+ return response;
+ }
+
+ // 保存图片并返回图片的 URL
+ public String saveImage(MultipartFile imageFile) throws IOException {
+ String fileName = imageFile.getOriginalFilename();
+ Path path = Paths.get(IMAGE_DIR + fileName);
+ Files.createDirectories(path.getParent());
+ Files.write(path, imageFile.getBytes());
+ return "/images/" + fileName;
+ }
+
+
+ //编辑帖子
+ public void updatePost(Long postId, Post post) {
+ Post existingPost = postRepository.findById(postId).orElseThrow(() -> new RuntimeException("Post not found"));
+ if (post.getTitle() != null) {
+ existingPost.setTitle(post.getTitle());
+ }
+ if (post.getPostContent() != null) {
+ existingPost.setPostContent(post.getPostContent());
+ }
+ if (post.getImageUrl() != null) {
+ existingPost.setImageUrl(post.getImageUrl());
+ }
+ existingPost.setPostTime(post.getPostTime());
+ // 保存更新后的帖子
+ postRepository.save(existingPost);
+ }
+
+ //删除帖子
+ public void deletePost(Long postId) {
+ // 查找指定 ID 的帖子，如果不存在则抛出异常
+ if (!postRepository.existsById(postId)) {
+ throw new RuntimeException("Post not found");
+ }
+ // 删除该帖子
+ postRepository.deleteById(postId);
+ }
+
+ //点赞帖子（已完成）
+ public void likePost(Long postId, Long userId) {
+ // 查找指定 ID 的帖子
+ Post post = postRepository.findById(postId).orElseThrow(() -> new RuntimeException("Post not found"));
+ post.setPostLikeNum(post.getPostLikeNum() + 1);
+
+ // 保存帖子
+ postRepository.save(post);
+ Likes like = new Likes();
+ like.setUserId(userId);
+ like.setPostNo(postId);
+ // 保存点赞记录
+ likesRepository.save(like);
+ }
+
+ // 取消点赞帖子（已完成）
+ public void unlikePost(Long postId, Long userId) {
+ // 查找指定 ID 的帖子
+ Post post = postRepository.findById(postId).orElseThrow(() -> new RuntimeException("Post not found"));
+
+ // 如果点赞数大于 0，则减少点赞数
+ if (post.getPostLikeNum() > 0) {
+ post.setPostLikeNum(post.getPostLikeNum() - 1);
+ }
+
+ // 删除点赞表中对应的记录
+ likesRepository.deleteLikeByUserIdAndPostNo(userId, postId);
+
+ // 保存更新后的帖子
+ postRepository.save(post);
+ }
+
+
+ // 获取帖子列表（已完成）
+ public Map<String, Object> getAllPosts() {
+ List<Post> posts = postRepository.findAll();
+ List<Map<String, Object>> postList = new ArrayList<>();
+
+ for (Post post : posts) {
+ Map<String, Object> postMap = new LinkedHashMap<>();
+ postMap.put("postNo", post.getPostNo());
+ postMap.put("user_id", post.getUser_id());
+ postMap.put("postContent", post.getPostContent());
+ postMap.put("imgUrl", post.getImageUrl());
+ postMap.put("title", post.getTitle());
+ postMap.put("createdAt", post.getPostTime().toString());
+ postMap.put("likeCount", post.getPostLikeNum());
+ postMap.put("collectCount", post.getPostCollectNum());
+
+ postList.add(postMap);
+ }
+
+ Map<String, Object> response = new HashMap<>();
+ // 统计帖子数量
+ response.put("total", postList.size());
+ response.put("posts", postList);
+
+ return response;
+ }
+
+ public Map<String, Object> getPostById(Long postId) {
+ // 获取帖子
+ Optional<Post> postOptional = postRepository.findById(postId);
+
+ // 如果帖子存在
+ if (postOptional.isPresent()) {
+ Post post = postOptional.get();
+ Map<String, Object> postData = new LinkedHashMap<>();
+ postData.put("postNo", post.getPostNo());
+ postData.put("user_id", post.getUser_id());
+ Long userId = post.getUser_id();
+ Users user = userRepository.findById(userId).orElse(null);
+
+ if (user != null) {
+ postData.put("username", user.getUsername());
+ postData.put("avatar_url", user.getAvatarUrl());
+ } else {
+ postData.put("username", null);
+ postData.put("avatar_url", null);
+ }
+
+ postData.put("postContent", post.getPostContent());
+ postData.put("imageUrl", post.getImageUrl());
+ postData.put("postTime", post.getPostTime());
+ postData.put("postLikeNum", post.getPostLikeNum());
+ postData.put("postCollectNum", post.getPostCollectNum());
+ postData.put("title", post.getTitle());
+
+ return postData;
+ } else {
+ throw new RuntimeException("Post not found with id: " + postId);
+ }
+ }
+
+
+ //收藏
+ public void collectPost(Long postId, Long userId) {
+ Post post = postRepository.findById(postId).orElseThrow(() -> new RuntimeException("Post not found"));
+ post.setPostCollectNum(post.getPostCollectNum() + 1);
+ postRepository.save(post);
+
+ // 添加到收藏表
+ Collections collection = new Collections();
+ collection.setUserId(userId);
+ collection.setPostNo(postId);
+ collectionsRepository.save(collection);
+ }
+
+ //取消收藏
+ public void uncollectPost(Long postId, Long userId) {
+ Post post = postRepository.findById(postId).orElseThrow(() -> new RuntimeException("Post not found"));
+ // 减少帖子收藏数
+ if (post.getPostCollectNum() > 0) {
+ post.setPostCollectNum(post.getPostCollectNum() - 1);
+ postRepository.save(post);
+ }
+
+ // 从收藏表中删除对应记录
+ collectionsRepository.deleteLikeByUserIdAndPostNo(userId, postId);
+ }
+
+
+
+}
diff --git a/src/main/java/com/example/myproject/service/TaskService.java b/src/main/java/com/example/myproject/service/TaskService.java
new file mode 100644
index 0000000..bd04661
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/TaskService.java
@@ -0,0 +1,295 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.Level;
+import com.example.myproject.entity.Task;
+import com.example.myproject.entity.UserTaskStatus;
+import com.example.myproject.repository.LevelRepository;
+import com.example.myproject.repository.TaskRepository;
+import com.example.myproject.repository.UserTaskStatusRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.example.myproject.entity.Users;
+import com.example.myproject.repository.UserRepository;
+
+import java.util.*;
+
+@Service
+public class TaskService {
+
+ @Autowired
+ private TaskRepository taskRepository;
+
+ @Autowired
+ private UserTaskStatusRepository userTaskStatusRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+
+ @Autowired
+ private LevelRepository levelRepository;
+
+ public Map<String, Object> getAllTasksForUser(Long userId) {
+ // 获取所有任务
+ List<Task> tasks = taskRepository.findAll();
+ List<Map<String, Object>> taskList = new ArrayList<>();
+
+ for (Task task : tasks) {
+ Optional<UserTaskStatus> userTaskStatus = userTaskStatusRepository
+ .findByUserIdAndTaskId(userId, task.getTaskId());
+
+ Map<String, Object> taskData = new LinkedHashMap<>();
+ taskData.put("task_id", task.getTaskId());
+ taskData.put("title", task.getTitle());
+ taskData.put("description", task.getDescription());
+ taskData.put("status", userTaskStatus.isPresent() ? userTaskStatus.get().getStatus() : "pending");
+ taskData.put("progress", userTaskStatus.isPresent() ? userTaskStatus.get().getCurrentProgress() : 0);
+
+ // 奖励
+ Map<String, Integer> reward = new LinkedHashMap<>();
+ reward.put("experience", task.getRewardExperience());
+ reward.put("points", task.getRewardPoints());
+ taskData.put("reward", reward);
+
+ taskList.add(taskData);
+ }
+
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("tasks", taskList);
+ return response;
+ }
+
+ public Map<String, Object> updateTaskStatus(Long userId, String taskId) {
+ // 获取用户任务状态
+ Optional<UserTaskStatus> userTaskStatusOpt = userTaskStatusRepository.findByUserIdAndTaskId(userId, taskId);
+ UserTaskStatus userTaskStatus = userTaskStatusOpt.get();
+
+ // 检查任务进度
+ if (userTaskStatus.getCurrentProgress() == 100f) {
+ Optional<Task> taskOpt = taskRepository.findById(taskId);
+ Task task = taskOpt.get();
+
+ // 更新任务状态为已完成
+ userTaskStatus.setStatus("completed");
+ userTaskStatus.setCurrentExperience(task.getRewardExperience());
+ userTaskStatus.setCurrentPoints(task.getRewardPoints());
+
+ userTaskStatusRepository.save(userTaskStatus);
+
+ // 构建返回数据
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "任务状态已更新");
+
+ Map<String, Integer> currentReward = new HashMap<>();
+ currentReward.put("current_experience", task.getRewardExperience());
+ currentReward.put("current_points", task.getRewardPoints());
+ response.put("current_reward", currentReward);
+
+ return response;
+ } else {
+ Map<String, Object> errorResponse = new HashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务未完成，无法更新状态");
+ return errorResponse;
+ }
+ }
+
+ public Map<String, Object> getUserExperience(Long userId) {
+ // 获取用户信息
+ Optional<Users> userOpt = userRepository.findById(userId);
+ if (!userOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "用户不存在");
+ return errorResponse;
+ }
+
+ Users user = userOpt.get();
+ Integer currentExperience = user.getCurrentExperience();
+ Optional<Level> levelOpt = levelRepository.findById(user.getLevel());
+ String levelName = levelOpt.isPresent() ? levelOpt.get().getLevelName() : "未知等级";
+
+ List<UserTaskStatus> completedTasks = userTaskStatusRepository.findByUserIdAndStatus(userId, "completed");
+
+ int totalExperience = 0;
+ int totalPoints = 0;
+ for (UserTaskStatus taskStatus : completedTasks) {
+ Optional<Task> taskOpt = taskRepository.findById(taskStatus.getTaskId());
+ if (taskOpt.isPresent()) {
+ Task task = taskOpt.get();
+ totalExperience += task.getRewardExperience();
+ totalPoints += task.getRewardPoints();
+ }
+ }
+
+ // 构建返回数据
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("user_id", userId);
+ response.put("current_experience", currentExperience);
+ response.put("level", levelName);
+ response.put("tasks_completed", completedTasks.size());
+
+ Map<String, Integer> reward = new LinkedHashMap<>();
+ reward.put("experience", totalExperience);
+ reward.put("points", totalPoints);
+
+ response.put("reward", reward);
+
+ return response;
+ }
+
+ public Map<String, Object> getNewStep(Long userId) {
+ // 获取用户的第一个未完成任务
+ Optional<UserTaskStatus> userTaskStatusOpt = userTaskStatusRepository.findFirstByUserIdAndStatus(userId, "pending");
+
+ if (!userTaskStatusOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "用户当前没有未完成的任务");
+ return errorResponse;
+ }
+
+ UserTaskStatus userTaskStatus = userTaskStatusOpt.get();
+ String taskId = userTaskStatus.getTaskId();
+
+ // 获取该任务的描述
+ Optional<Task> taskOpt = taskRepository.findById(taskId);
+ if (!taskOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务不存在");
+ return errorResponse;
+ }
+
+ Task task = taskOpt.get();
+
+ // 获取总任务数
+ long totalTasks = taskRepository.count();
+
+ // 构建返回数据
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("current_step", taskId);
+ response.put("total_steps", totalTasks);
+ response.put("step_description", task.getDescription());
+
+ return response;
+ }
+
+ public Map<String, Object> updateTaskProgress(Long userId, String taskId, Integer progress) {
+ Optional<UserTaskStatus> userTaskStatusOpt = userTaskStatusRepository.findByUserIdAndTaskId(userId, taskId);
+
+ if (!userTaskStatusOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务不存在或该任务不属于用户");
+ return errorResponse;
+ }
+
+ UserTaskStatus userTaskStatus = userTaskStatusOpt.get();
+ userTaskStatus.setCurrentProgress(Float.valueOf(progress));
+ userTaskStatusRepository.save(userTaskStatus);
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("message", "进度已更新");
+
+ return response;
+ }
+
+ public Map<String, Object> claimReward(Long userId, String taskId) {
+ // 获取用户任务状态
+ Optional<UserTaskStatus> userTaskStatusOpt = userTaskStatusRepository.findByUserIdAndTaskId(userId, taskId);
+
+ if (!userTaskStatusOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务状态不存在");
+ return errorResponse;
+ }
+
+ UserTaskStatus userTaskStatus = userTaskStatusOpt.get();
+
+ if (userTaskStatus.getCurrentProgress() == 100f) {
+ if (userTaskStatus.getIsRewardClaimed()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "奖励已经领取过了");
+ return errorResponse;
+ }
+
+ Optional<Task> taskOpt = taskRepository.findById(taskId);
+ if (!taskOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务不存在");
+ return errorResponse;
+ }
+
+ Task task = taskOpt.get();
+
+ userTaskStatus.setIsRewardClaimed(true);
+ userTaskStatus.setCurrentExperience(task.getRewardExperience());
+ userTaskStatus.setCurrentPoints(task.getRewardPoints());
+
+ userTaskStatusRepository.save(userTaskStatus);
+
+ Optional<Users> userOpt = userRepository.findById(userId);
+ if (!userOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "用户不存在");
+ return errorResponse;
+ }
+
+ Users user = userOpt.get();
+
+ // 将任务奖励加到用户的积分和经验
+ user.setUserPoints(user.getUserPoints() + task.getRewardPoints());
+ user.setCurrentExperience(user.getCurrentExperience() + task.getRewardExperience());
+
+ userRepository.save(user);
+
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("message", "奖励已领取");
+
+ Map<String, Integer> reward = new LinkedHashMap<>();
+ reward.put("experience", task.getRewardExperience());
+ reward.put("points", task.getRewardPoints());
+ response.put("reward", reward);
+
+ return response;
+ } else {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务未完成，无法领取奖励");
+ return errorResponse;
+ }
+ }
+
+ public Map<String, Object> checkRewardStatus(Long userId, String taskId) {
+ // 获取用户任务状态
+ Optional<UserTaskStatus> userTaskStatusOpt = userTaskStatusRepository.findByUserIdAndTaskId(userId, taskId);
+
+ if (!userTaskStatusOpt.isPresent()) {
+ Map<String, Object> errorResponse = new LinkedHashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "任务状态不存在");
+ return errorResponse;
+ }
+
+ UserTaskStatus userTaskStatus = userTaskStatusOpt.get();
+
+ // 检查奖励是否已领取
+ if (userTaskStatus.getIsRewardClaimed()) {
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "reward_issued");
+ response.put("message", "任务奖励已被领取");
+ return response;
+ }
+
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "reward_not_issued");
+ response.put("message", "任务奖励未被领取");
+ return response;
+ }
+}
diff --git a/src/main/java/com/example/myproject/service/UserFollowService.java b/src/main/java/com/example/myproject/service/UserFollowService.java
new file mode 100644
index 0000000..6222b48
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/UserFollowService.java
@@ -0,0 +1,122 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.Users;
+import com.example.myproject.entity.UserFollow;
+import com.example.myproject.repository.UserFollowRepository;
+import com.example.myproject.repository.UserRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+
+@Service
+public class UserFollowService {
+
+ @Autowired
+ private UserFollowRepository userFollowRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+
+ // 用户关注操作
+ public Map<String, Object> follow(Long followerId, Long followedId) {
+ if (followerId.equals(followedId)) {
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "error");
+ response.put("message", "不能关注自己");
+ return response;
+ }
+
+ // 检查是否已关注该用户
+ UserFollow existingFollow = userFollowRepository.findByFollowerIdAndFollowedId(followerId, followedId);
+ if (existingFollow == null) {
+ // 创建新的关注记录
+ UserFollow userFollow = new UserFollow();
+ userFollow.setFollowerId(followerId);
+ userFollow.setFollowedId(followedId);
+ userFollow.setFollowTime(new java.util.Date());
+
+ userFollowRepository.save(userFollow);
+
+ // 返回关注成功响应
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("message", "关注成功");
+ return response;
+ } else {
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "error");
+ response.put("message", "已经关注该用户");
+ return response;
+ }
+ }
+
+ // 取消关注操作
+ public Map<String, Object> unfollow(Long followerId, Long followedId) {
+ UserFollow userFollow = userFollowRepository.findByFollowerIdAndFollowedId(followerId, followedId);
+
+ if (userFollow != null) {
+ userFollowRepository.delete(userFollow);
+
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("message", "取消关注成功");
+ return response;
+ } else {
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "error");
+ response.put("message", "未找到关注关系");
+ return response;
+ }
+ }
+
+ // 获取某个用户的所有粉丝
+ public Map<String, Object> getFollowers(Long userId) {
+ List<UserFollow> followers = userFollowRepository.findByFollowedId(userId);
+
+ List<Map<String, Object>> followersList = new ArrayList<>();
+ for (UserFollow follow : followers) {
+ // 获取粉丝的用户信息
+ Users follower = userRepository.findById(follow.getFollowerId()).orElse(null);
+ if (follower != null) {
+ Map<String, Object> followerInfo = new LinkedHashMap<>();
+ followerInfo.put("user_id", follower.getUserId());
+ followerInfo.put("username", follower.getUsername());
+ followerInfo.put("avatar_url", follower.getAvatarUrl());
+ followersList.add(followerInfo);
+ }
+ }
+
+ // 返回响应数据
+ Map<String, Object> response = new LinkedHashMap<>();
+ response.put("status", "success");
+ response.put("total", followersList.size());
+ response.put("followers", followersList);
+
+ return response;
+ }
+
+ // 获取某个用户的所有关注用户
+ public Map<String, Object> getFollowing(Long userId) {
+ List<UserFollow> following = userFollowRepository.findByFollowerId(userId);
+
+ List<Map<String, Object>> followingList = new ArrayList<>();
+ for (UserFollow follow : following) {
+ // 获取被关注的用户信息
+ Users followedUser = userRepository.findById(follow.getFollowedId()).orElse(null);
+ if (followedUser != null) {
+ Map<String, Object> followingInfo = new HashMap<>();
+ followingInfo.put("user_id", followedUser.getUserId());
+ followingInfo.put("username", followedUser.getUsername());
+ followingInfo.put("avatar_url", followedUser.getAvatarUrl());
+ followingList.add(followingInfo);
+ }
+ }
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("total", followingList.size());
+ response.put("following", followingList);
+
+ return response;
+ }
+}
diff --git a/src/main/java/com/example/myproject/service/UserMessageService.java b/src/main/java/com/example/myproject/service/UserMessageService.java
new file mode 100644
index 0000000..05f62e7
--- /dev/null
+++ b/src/main/java/com/example/myproject/service/UserMessageService.java
@@ -0,0 +1,112 @@
+package com.example.myproject.service;
+
+import com.example.myproject.entity.UserMessages;
+import com.example.myproject.repository.UserMessagesRepository;
+import com.example.myproject.repository.UserRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.Optional;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Date;
+import java.util.stream.Collectors;
+
+@Service
+public class UserMessageService {
+
+ @Autowired
+ private UserMessagesRepository userMessagesRepository;
+
+ @Autowired
+ private UserRepository userRepository;
+
+ // 发送私信
+ public Map<String, Object> sendMessage(Long senderId, Long receiverId, String content) {
+ UserMessages message = new UserMessages();
+ message.setSenderId(senderId);
+ message.setReceiverId(receiverId);
+ message.setContent(content);
+ message.setTime(new Date());
+ UserMessages savedMessage = userMessagesRepository.save(message);
+
+ // 返回响应
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "私信发送成功");
+ response.put("message_id", savedMessage.getMessageId());
+ return response;
+ }
+
+ // 获取当前用户的所有消息
+ public Map<String, Object> getUserMessages(Long userId) {
+ // 查询当前用户发送和接收的所有消息
+ List<UserMessages> messages = userMessagesRepository.findBySenderIdOrReceiverId(userId, userId);
+
+ // 获取发送者和接收者的用户名
+ List<Map<String, Object>> messageDetails = messages.stream()
+ .map(message -> {
+ Map<String, Object> messageMap = new HashMap<>();
+ messageMap.put("message_id", message.getMessageId());
+ messageMap.put("sender_id", message.getSenderId());
+ messageMap.put("receiver_id", message.getReceiverId());
+ messageMap.put("content", message.getContent());
+ messageMap.put("timestamp", message.getTime());
+ String senderUsername = userRepository.findById(message.getSenderId())
+ .map(user -> user.getUsername())
+ .orElse("Unknown");
+ messageMap.put("sender_username", senderUsername);
+ String receiverUsername = userRepository.findById(message.getReceiverId())
+ .map(user -> user.getUsername())
+ .orElse("Unknown");
+ messageMap.put("receiver_username", receiverUsername);
+
+ return messageMap;
+ })
+ .collect(Collectors.toList());
+
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("messages", messageDetails);
+ return response;
+ }
+
+ // 获取单条消息的详情
+ public Map<String, Object> getMessage(Long messageId) {
+ Optional<UserMessages> optionalMessage = userMessagesRepository.findById(messageId);
+
+ if (optionalMessage.isPresent()) {
+ UserMessages message = optionalMessage.get();
+
+ // 获取发送者和接收者的用户名
+ String senderUsername = userRepository.findById(message.getSenderId())
+ .map(user -> user.getUsername())
+ .orElse("Unknown");
+ String receiverUsername = userRepository.findById(message.getReceiverId())
+ .map(user -> user.getUsername())
+ .orElse("Unknown");
+
+ // 构建响应数据
+ Map<String, Object> response = new HashMap<>();
+ Map<String, Object> messageDetails = new HashMap<>();
+ messageDetails.put("message_id", message.getMessageId());
+ messageDetails.put("sender_id", message.getSenderId());
+ messageDetails.put("sender_username", senderUsername);
+ messageDetails.put("receiver_id", message.getReceiverId());
+ messageDetails.put("receiver_username", receiverUsername);
+ messageDetails.put("content", message.getContent());
+ messageDetails.put("timestamp", message.getTime());
+
+ response.put("status", "success");
+ response.put("message", messageDetails);
+ return response;
+ } else {
+ Map<String, Object> errorResponse = new HashMap<>();
+ errorResponse.put("status", "error");
+ errorResponse.put("message", "Message not found");
+ return errorResponse;
+ }
+ }
+
+
+}
diff --git a/src/main/java/com/example/myproject/service/UserService.java b/src/main/java/com/example/myproject/service/UserService.java
index 71435c7..0d37854 100644
--- a/src/main/java/com/example/myproject/service/UserService.java
+++ b/src/main/java/com/example/myproject/service/UserService.java
@@ -1,25 +1,269 @@
package com.example.myproject.service;
+import com.example.myproject.entity.Users;
+import com.example.myproject.entity.UserInviteCode;
+import com.example.myproject.repository.UserRepository;
+import com.example.myproject.repository.UserInviteCodeRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+
+@Service
+public class UserService {
+
+ @Autowired
+ private UserRepository userRepository;
+
+ @Autowired
+ private UserInviteCodeRepository userInviteCodeRepository;
+
+ // 生成邀请码
+ public Map<String, Object> generateInviteCode(Long userId) {
+ // 获取用户信息
+ Users user = userRepository.findById(userId).orElse(null);
+
+ // 如果用户不存在，返回错误
+ if (user == null) {
+ Map<String, Object> errorResponse = new HashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "用户不存在");
+ return errorResponse;
+ }
+
+ // 检查用户的邀请数量
+ if (user.getInviteCount() <= 0) {
+ Map<String, Object> errorResponse = new HashMap<>();
+ errorResponse.put("status", "failure");
+ errorResponse.put("message", "没有剩余的邀请码");
+ return errorResponse;
+ }
+
+ // 生成唯一的邀请码
+ String inviteCode = generateUniqueInviteCode();
+
+ // 将邀请码保存到 `user_invite_code` 表
+ UserInviteCode userInviteCode = new UserInviteCode();
+ userInviteCode.setUserId(userId);
+ userInviteCode.setInviteCode(inviteCode);
+ userInviteCode.setCreatedAt(java.time.LocalDateTime.now());
+
+ userInviteCodeRepository.save(userInviteCode);
+
+ // 更新用户的 `invite_count`，减少1
+ user.setInviteCount(user.getInviteCount() - 1);
+ userRepository.save(user);
+
+ // 返回成功信息
+ Map<String, Object> response = new HashMap<>();
+ response.put("status", "success");
+ response.put("message", "邀请码生成成功");
+ response.put("invite_code", inviteCode);
+
+ return response;
+ }
+
+ // 生成唯一的邀请码，使用26个字母（大小写）
+ private String generateUniqueInviteCode() {
+ String characters = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
+ StringBuilder inviteCode = new StringBuilder();
+
+ Random random = new Random();
+ for (int i = 0; i < 10; i++) {
+ inviteCode.append(characters.charAt(random.nextInt(characters.length())));
+ }
+
+ return inviteCode.toString();
+ }
+
+ public String registerUser(String username, String email, String password, String role, String inviteCode) {
+ // 检查邮箱是否已经注册
+ Optional<Users> existingEmailUser = userRepository.findByEmail(email);
+ if (existingEmailUser.isPresent()) {
+ return "该邮箱已被注册";
+ }
+
+ // 检查用户名是否已经存在
+ Optional<Users> existingUsernameUser = userRepository.findByUsername(username); // 需要根据用户名查询
+ if (existingUsernameUser.isPresent()) {
+ return "该用户名已被注册";
+ }
+
+ // 检查邀请码是否有效
+ if (inviteCode == null || inviteCode.isEmpty()) {
+ return "邀请码不能为空";
+ }
+
+ Optional<UserInviteCode> invite = userInviteCodeRepository.findByInviteCode(inviteCode);
+ if (invite.isEmpty() || invite.get().getIsUsed()) {
+ return "邀请码无效或已被使用";
+ }
+
+ // 设置默认等级为2（由于邀请码有效）
+ Long level = 2L;
+
+ // 设置默认头像 URL
+ String avatarUrl = "https://example.com/default-avatar.jpg"; // 默认头像
+
+ // 获取邀请码对应的用户ID
+ UserInviteCode inviteEntity = invite.get();
+ Long inviteUserId = inviteEntity.getUserId();
+
+ // 创建新用户
+ Users newUser = new Users();
+ newUser.setUsername(username);
+ newUser.setEmail(email);
+ newUser.setPassword(password);
+ newUser.setRole(role);
+ newUser.setInviteCount(0); // 初始邀请码数量为 0
+ newUser.setLevel(level);
+ newUser.setAvatarUrl(avatarUrl); // 设置默认头像
+ newUser.setRegistrationDate(new java.util.Date()); // 设置注册日期
+ newUser.setCurrentExperience(0); // 默认经验为 0
+ newUser.setCurrentSeedingHours(0f); // 默认做种时长为 0
+ newUser.setRegistrationTime(new java.util.Date()); // 设置注册时间为当前时间
+
+ // 保存用户信息
+ userRepository.save(newUser);
+
+ // 更新邀请码的使用状态
+ inviteEntity.setIsUsed(true);
+ userInviteCodeRepository.save(inviteEntity);
+
+ return "用户注册成功";
+ }
-import com.baomidou.mybatisplus.extension.service.IService;
+ public String loginUser(String username, String password) {
+ // 检查用户是否存在
+ Optional<Users> userOptional = userRepository.findByUsername(username);
+ if (userOptional.isEmpty()) {
+ return "用户名不存在";
+ }
-import com.example.myproject.entity.User;
+ Users user = userOptional.get();
-public interface UserService extends IService<User> {
- User loginService(String username, String password);
+ // 检查密码是否正确
+ if (!user.getPassword().equals(password)) {
+ return "密码错误";
+ }
+
+ // 登录成功
+ return "登录成功";
+ }
+
+ public String changePassword(Long userId, String oldPassword, String newPassword, String confirmPassword) {
+ // 查找用户
+ Users user = userRepository.findById(userId).orElse(null);
+
+ if (user == null) {
+ return "用户不存在";
+ }
+
+ // 检查旧密码是否正确
+ if (!user.getPassword().equals(oldPassword)) {
+ return "旧密码错误";
+ }
+
+ // 检查新密码和确认密码是否一致
+ if (!newPassword.equals(confirmPassword)) {
+ return "新密码与确认密码不一致";
+ }
+
+ // 更新密码
+ user.setPassword(newPassword);
+ userRepository.save(user);
+
+ return "密码修改成功";
+ }
+
+ // 获取用户个人资料
+ public Map<String, Object> getProfile(Long userId) {
+ Optional<Users> userOptional = userRepository.findById(userId);
+
+ // 如果用户不存在，返回null或者可以抛出异常
+ if (userOptional.isEmpty()) {
+ return null; // 可以返回 null 或者根据需要返回错误信息
+ }
+
+ Users user = userOptional.get();
+
+ // 将需要的字段放入 Map 中
+ Map<String, Object> profile = new LinkedHashMap<>();
+ profile.put("avatarUrl", user.getAvatarUrl());
+ profile.put("username", user.getUsername());
+ profile.put("email", user.getEmail());
+ profile.put("gender", user.getGender());
+ profile.put("description", user.getDescription());
+ profile.put("hobbies", user.getHobbies());
+ profile.put("level", user.getLevel());
+ profile.put("Experience", user.getCurrentExperience());
+ profile.put("uploadCount", user.getUploadCount());
+ profile.put("downloadCount", user.getDownloadCount());
+ profile.put("shareRate", user.getShareRate());
+ profile.put("registrationTime", user.getRegistrationTime());
+
+ return profile;
+ }
+
+ // 修改用户个人资料
+ public boolean editProfile(Long userId, String avatarUrl, String nickname, String gender, String description, String hobbies) {
+ Optional<Users> userOptional = userRepository.findById(userId);
+
+ // 如果用户不存在，返回false
+ if (userOptional.isEmpty()) {
+ return false; // 用户不存在
+ }
+
+ Users user = userOptional.get();
+
+ // 更新用户资料，只有传入值才会更新对应字段
+ if (avatarUrl != null) {
+ user.setAvatarUrl(avatarUrl);
+ }
+ if (nickname != null) {
+ user.setUsername(nickname);
+ }
+ if (gender != null) {
+ user.setGender(gender);
+ }
+ if (description != null) {
+ user.setDescription(description);
+ }
+ if (hobbies != null) {
+ user.setHobbies(hobbies);
+ }
+
+ // 保存更新后的用户信息
+ userRepository.save(user);
+
+ return true; // 更新成功
+ }
+
+ public Map<String, Object> calculateShareRate(Long userId) {
+ // 查找用户
+ Users user = userRepository.findById(userId).orElse(null);
+ if (user == null) {
+ return Map.of("status", "error", "message", "用户不存在");
+ }
+
+ // 获取上传量和下载量
+ Float uploadCount = user.getUploadCount();
+ Float downloadCount = user.getDownloadCount();
+
+ // 计算分享率
+ Float shareRate = 0f; // 默认分享率为0
+ if (downloadCount != 0) {
+ shareRate = uploadCount / downloadCount; // 分享率 = 上传量 / 下载量
+ }
+
+ // 更新用户的分享率
+ user.setShareRate(shareRate);
+ userRepository.save(user);
+
+ // 返回结果
+ return Map.of("status", "success", "message", "分享率计算成功", "shareRate", shareRate);
+ }
- boolean preRegisterUser(User user);
-
-
- boolean verifyEmail(String email, String token);
-
-
- boolean checkEmailExists(String email);
-
- boolean checkPassword(Long userId, String rawPassword);
-
-
-// Integer getUserId();
-}
\ No newline at end of file
+}
diff --git a/src/main/java/com/example/myproject/service/serviceImpl/UserDetailsServiceImpl.java b/src/main/java/com/example/myproject/service/serviceImpl/UserDetailsServiceImpl.java
index 4bbd5c3..d8de4b7 100644
--- a/src/main/java/com/example/myproject/service/serviceImpl/UserDetailsServiceImpl.java
+++ b/src/main/java/com/example/myproject/service/serviceImpl/UserDetailsServiceImpl.java
@@ -1,47 +1,47 @@
-package com.example.myproject.service.serviceImpl;
-
-import com.example.myproject.mapper.UserMapper;
-import com.example.myproject.entity.User;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.security.core.GrantedAuthority;
-import org.springframework.security.core.authority.AuthorityUtils;
-import org.springframework.security.core.authority.SimpleGrantedAuthority;
-import org.springframework.security.core.userdetails.UserDetails;
-import org.springframework.security.core.userdetails.UserDetailsService;
-import org.springframework.security.core.userdetails.UsernameNotFoundException;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-import java.util.List;
-
-@Service
-public class UserDetailsServiceImpl implements UserDetailsService {
-
- @Autowired
- private UserMapper userMapper;
-
- @Override
- public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
- //username参数,是在登陆时,用户传递的表单数据username
- //主要读取数据库3个值 username password authorities
- User user= userMapper.selectByUsername(username);
- if (user == null) {
- throw new UsernameNotFoundException("用户名未找到");
- }
-
- String authorityName = user.getRole();
- //为了返回一个UserDetails 使用User
- List<GrantedAuthority> authorities = new ArrayList<>();
- GrantedAuthority authority = new SimpleGrantedAuthority(authorityName);
- authorities.add(authority);
- return new org.springframework.security.core.userdetails.User(
- user.getUsername(),
- user.getPassword(),
- true, // accountEnabled
- true, // accountNonExpired
- true, // credentialsNonExpired
- true, // accountNonLocked
- AuthorityUtils.createAuthorityList("ROLE_USER") // 设置用户的角色或权限
- );
- }
-}
\ No newline at end of file
+//package com.example.myproject.service.serviceImpl;
+//
+//import com.example.myproject.mapper.UserMapper;
+//import com.example.myproject.entity.User;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.security.core.GrantedAuthority;
+//import org.springframework.security.core.authority.AuthorityUtils;
+//import org.springframework.security.core.authority.SimpleGrantedAuthority;
+//import org.springframework.security.core.userdetails.UserDetails;
+//import org.springframework.security.core.userdetails.UserDetailsService;
+//import org.springframework.security.core.userdetails.UsernameNotFoundException;
+//import org.springframework.stereotype.Service;
+//
+//import java.util.ArrayList;
+//import java.util.List;
+//
+//@Service
+//public class UserDetailsServiceImpl implements UserDetailsService {
+//
+// @Autowired
+// private UserMapper userMapper;
+//
+// @Override
+// public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
+// //username参数,是在登陆时,用户传递的表单数据username
+// //主要读取数据库3个值 username password authorities
+// User user= userMapper.selectByUsername(username);
+// if (user == null) {
+// throw new UsernameNotFoundException("用户名未找到");
+// }
+//
+// String authorityName = user.getRole();
+// //为了返回一个UserDetails 使用User
+// List<GrantedAuthority> authorities = new ArrayList<>();
+// GrantedAuthority authority = new SimpleGrantedAuthority(authorityName);
+// authorities.add(authority);
+// return new org.springframework.security.core.userdetails.User(
+// user.getUsername(),
+// user.getPassword(),
+// true, // accountEnabled
+// true, // accountNonExpired
+// true, // credentialsNonExpired
+// true, // accountNonLocked
+// AuthorityUtils.createAuthorityList("ROLE_USER") // 设置用户的角色或权限
+// );
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/example/myproject/service/serviceImpl/UserServiceImpl.java b/src/main/java/com/example/myproject/service/serviceImpl/UserServiceImpl.java
deleted file mode 100644
index d0718fe..0000000
--- a/src/main/java/com/example/myproject/service/serviceImpl/UserServiceImpl.java
+++ /dev/null
@@ -1,122 +0,0 @@
-
-package com.example.myproject.service.serviceImpl;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.example.myproject.mapper.UserMapper;
-import com.example.myproject.mapper.VerificationTokenMapper;
-import com.example.myproject.entity.User;
-import com.example.myproject.entity.VerificationToken;
-import com.example.myproject.service.EmailService;
-import com.example.myproject.service.UserService;
-import org.apache.commons.lang3.RandomStringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.security.crypto.password.PasswordEncoder;
-import org.springframework.stereotype.Service;
-import java.time.Instant;
-import java.time.temporal.ChronoUnit;
-//登录注册
-@Service
-public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
- private static final Logger log = LoggerFactory.getLogger(UserServiceImpl.class);
- @Autowired
- private UserMapper userMapper; // Using MyBatis-Plus mapper
- @Autowired
- private EmailServiceImpl emailService;
- @Autowired
- private VerificationTokenMapper verificationTokenMapper; // Using MyBatis-Plus mapper
- @Autowired
- private PasswordEncoder passwordEncoder; // Injecting password encoder
- @Override
- public User loginService(String username, String password) {
- log.debug("Attempting login with username: {}, password: {}", username, password);
- User user = userMapper.selectOne(new QueryWrapper<User>().eq("username", username).eq("password", password));
- if (user != null) {
- user.setPassword(""); // Clear the password before returning
- log.debug("Login successful, User ID: {}", user.getId());
- } else {
- log.debug("Login failed, incorrect username or password.");
- }
- return user;
- }
- @Override
- public boolean preRegisterUser(User user) {
- log.debug("Pre-registering user, username: {}, email: {}", user.getUsername(), user.getEmail());
- // 检查用户名或邮箱是否已存在
- boolean userExists = userMapper.selectOne(new QueryWrapper<User>().eq("username", user.getUsername())) != null ||
- userMapper.selectOne(new QueryWrapper<User>().eq("email", user.getEmail())) != null;
- if (userExists) {
- log.debug("Pre-registration failed, username or email already exists.");
- return false; // 用户名或邮箱已经存在
- }
- // 加密密码
- String encryptedPassword = passwordEncoder.encode(user.getPassword());
- // 生成验证码
- String token = RandomStringUtils.randomNumeric(6);
- // 设置过期时间为当前时间加一小时
- Instant expiryDate = Instant.now().plus(1, ChronoUnit.HOURS);
- // 创建验证令牌对象
- VerificationToken verificationToken = new VerificationToken(
- token,
- user.getUsername(),
- user.getEmail(),
- encryptedPassword,
- expiryDate
- );
- // 插入验证令牌
- int rowsInserted = verificationTokenMapper.insert(verificationToken);
- if (rowsInserted > 0) {
- // 发送验证邮件
- emailService.sendVerificationEmail(user.getEmail(), token);
- log.debug("Pre-registration successful, verification code: {}, expiry date: {}", token, expiryDate);
- return true; // 注册前验证成功
- } else {
- log.error("Failed to insert verification token into database.");
- return false; // 如果插入验证令牌失败，返回失败
- }
- }
- @Override
- public boolean verifyEmail(String email, String token) {
- log.debug("Verifying email, email: {}, token: {}", email, token);
- VerificationToken verificationToken = verificationTokenMapper.selectOne(
- new QueryWrapper<VerificationToken>().eq("token", token).eq("email", email)
- );
- if (verificationToken != null && !verificationToken.isExpired()) {
- log.debug("Verification code is valid, username: {}", verificationToken.getUsername());
- User user = userMapper.selectOne(new QueryWrapper<User>().eq("email", email));
- if (user == null) {
- user = new User();
- user.setEmail(email);
- user.setUsername(verificationToken.getUsername());
- user.setPassword(verificationToken.getPassword());
- user.setEmailVerified(true);
- userMapper.insert(user); // Save new user
- log.debug("New user created, User ID: {}", user.getId());
- } else {
- user.setEmailVerified(true);
- userMapper.updateById(user); // Update existing user
- log.debug("User email verified, User ID: {}", user.getId());
- }
- verificationTokenMapper.delete(new QueryWrapper<VerificationToken>().eq("token", token)); // Clean up the token
- log.debug("Verification code deleted.");
- return true;
- }
- log.debug("Verification code is invalid or expired.");
- return false;
- }
- public boolean checkEmailExists(String email) {
- log.debug("检查邮箱是否存在，邮箱：{}", email);
- boolean exists = userMapper.selectCount(new QueryWrapper<User>().eq("email", email)) > 0;
- log.debug("邮箱存在状态：{}", exists);
- return exists;
- }
- public boolean checkPassword(Long userId, String password) {
- User user = userMapper.selectById(userId);
- if (user == null) {
- throw new RuntimeException("用户不存在");
- }
- String encryptedPassword = user.getPassword();
- return passwordEncoder.matches(password, encryptedPassword);
- }
-}
diff --git a/src/main/java/com/example/myproject/utils/Result.java b/src/main/java/com/example/myproject/utils/Result.java
new file mode 100644
index 0000000..e46f828
--- /dev/null
+++ b/src/main/java/com/example/myproject/utils/Result.java
@@ -0,0 +1,131 @@
+package com.example.myproject.utils;
+
+
+import org.springframework.http.ResponseEntity;
+
+public class Result<T> {
+ private String code;
+ private String msg;
+ private T data;
+
+ public String getCode() {
+ return code;
+ }
+
+ public void setCode(String code) {
+ this.code = code;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public void setMsg(String msg) {
+ this.msg = msg;
+ }
+
+ public T getData() {
+ return data;
+ }
+
+ public void setData(T data) {
+ this.data = data;
+ }
+
+ public Result() {
+ }
+
+ public Result(T data) {
+ this.data = data;
+ }
+
+ public static Result success(ResponseEntity<?> resultMap, String 兴趣小组创建成功) {
+ Result result = new Result<>();
+ result.setCode("200");
+ result.setMsg("成功");
+ return result;
+ }
+
+ public static <T> Result<T> success(T data) {
+ Result<T> result = new Result<>(data);
+ result.setCode("200");
+ result.setMsg("成功");
+ return result;
+ }
+ public static <T> Result<T> success(String msg) {
+ Result result = new Result();
+ result.setCode("200");
+ result.setMsg("成功");
+ return result;
+ }
+
+ public static <T> Result<T> success(T data,String msg) {
+ Result<T> result = new Result<>(data);
+ result.setCode("200");
+ result.setMsg(msg);
+ return result;
+ }
+
+ public static Result error(String code, String msg) {
+ Result result = new Result();
+ result.setCode(code);
+ result.setMsg(msg);
+ return result;
+ }
+ /**
+ * 创建一个表示文件大小超出限制的结果对象。
+ *
+ * @return 构造的文件过大错误结果对象
+ */
+ public static Result fileTooLarge() {
+ Result result = new Result();
+ result.setCode("413");
+ result.setMsg("文件大小超出限制。");
+ return result;
+ }
+
+ /**
+ * 创建一个表示文件格式不支持的结果对象。
+ *
+ * @return 构造的文件格式错误结果对象
+ */
+ public static Result unsupportedFileType() {
+ Result result = new Result();
+ result.setCode("415");
+ result.setMsg("不支持的文件格式。");
+ return result;
+ }
+
+ /**
+ * 创建一个表示文件未找到的结果对象。
+ *
+ * @return 构造的文件未找到错误结果对象
+ */
+ public static Result fileNotFound() {
+ Result result = new Result();
+ result.setCode("404");
+ result.setMsg("文件未找到。");
+ return result;
+ }
+
+ /**
+ * 创建一个表示文件存储错误的结果对象。
+ *
+ * @param errorMsg 详细错误信息
+ * @return 构造的文件存储错误结果对象
+ */
+ public static Result fileStorageError(String errorMsg) {
+ Result result = new Result();
+ result.setCode("500");
+ result.setMsg("文件存储错误: " + errorMsg);
+ return result;
+ }
+
+ public static Result permissionDenied() {
+ Result result = new Result();
+ result.setCode("401");
+ result.setMsg("权限不足，无法执行该操作。");
+ return result;
+ }
+
+}
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index 0590333..54e92e6 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -1,11 +1,11 @@
server.port=8080
-spring.datasource.url=jdbc:mysql://localhost:3306/pt
+spring.datasource.url=jdbc:mysql://localhost:3306/ptProject
spring.datasource.username=root
-spring.datasource.password=root
+spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
+spring.jpa.hibernate.naming.physical-strategy=org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl
-mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
-
+#mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
# Mail configuration
spring.mail.password=tljnebonhzhqecda
@@ -17,15 +17,8 @@
spring.jpa.enabled=false
-spring.jpa.hibernate.ddl-auto=none
+spring.jpa.hibernate.ddl-auto=update
spring.jpa.open-in-view=false
-# tracker??
-pt.tracker.port=6969
-pt.tracker.torrent-dir=${user.dir}/data/torrents
-
-pt.tracker.allow-foreign=false
-pt.tracker.announce-url=/custom-announce
-
-mybatis-plus.mapper-locations=classpath:/mapper/**/*.xml
+#mybatis-plus.mapper-locations=classpath:/mapper/**/*.xml
\ No newline at end of file
diff --git a/src/test/java/com/example/myproject/controller/CommentControllerTest.java b/src/test/java/com/example/myproject/controller/CommentControllerTest.java
new file mode 100644
index 0000000..9dedd29
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/CommentControllerTest.java
@@ -0,0 +1,81 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.Comments;
+import com.example.myproject.entity.Users;
+import com.example.myproject.service.CommentService;
+import com.example.myproject.utils.Result;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.*;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class CommentControllerTest {
+
+ @InjectMocks
+ private CommentController commentController;
+ @Mock
+ private CommentService commentService;
+
+ @Mock
+ private Users mockUser;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试添加评论
+ @Test
+ void addCommentTest() {
+ Long postId = 1L;
+ Comments comment = new Comments();
+ comment.setUserId(1L);
+ comment.setContent("This is a comment");
+ comment.setParentComment(0L);
+ // 模拟服务层的行为
+ doNothing().when(commentService).addComment(eq(postId), eq(comment));
+
+ // 调用控制器的方法
+ String result = commentController.addComment(postId, comment);
+
+ // 验证返回的结果
+ assertEquals("Comment added successfully!", result);
+
+ // 验证服务方法是否被调用
+ verify(commentService, times(1)).addComment(eq(postId), eq(comment));
+ }
+
+ // 测试获取评论
+ @Test
+ void getCommentsByPostIdTest() {
+ Long postId = 1L;
+
+ // 模拟评论数据
+ Map<String, Object> commentData = new HashMap<>();
+ commentData.put("commentId", 1L);
+ commentData.put("content", "This is a comment");
+ commentData.put("userId", 1L);
+ commentData.put("nickname", "user1");
+
+ // 模拟服务层的行为
+ when(commentService.getCommentsByPostId(postId)).thenReturn(List.of(commentData));
+
+ // 调用控制器的方法
+ List<Map<String, Object>> comments = commentController.getCommentsByPostId(postId);
+
+ // 验证返回的评论数据
+ assertEquals(1, comments.size());
+ assertEquals("This is a comment", comments.get(0).get("content"));
+ assertEquals("user1", comments.get(0).get("nickname"));
+
+ // 验证服务方法是否被调用
+ verify(commentService, times(1)).getCommentsByPostId(postId);
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/DynamicControllerTest.java b/src/test/java/com/example/myproject/controller/DynamicControllerTest.java
new file mode 100644
index 0000000..7392162
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/DynamicControllerTest.java
@@ -0,0 +1,168 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.controller.DynamicController;
+import com.example.myproject.service.DynamicService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class DynamicControllerTest {
+
+ @InjectMocks
+ private DynamicController dynamicController;
+
+ @Mock
+ private DynamicService dynamicService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试创建动态接口
+ @Test
+ void testCreateDynamic() {
+ Long userId = 1L;
+ String content = "This is a test dynamic";
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("dynamicId", 123L);
+ mockResponse.put("message", "动态创建成功");
+
+ // 模拟 dynamicService.createDynamic 返回
+ when(dynamicService.createDynamic(userId, null, content, null)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ Map<String, Object> responseMap = dynamicController.createDynamic(userId, null, content, null);
+ ResponseEntity<Map<String, Object>> responseEntity = ResponseEntity.ok(responseMap);
+
+ // 验证返回的结果
+ assertEquals(200, responseEntity.getStatusCodeValue());
+ assertEquals("动态创建成功", responseEntity.getBody().get("message"));
+ assertEquals(123L, responseEntity.getBody().get("dynamicId"));
+ }
+
+
+ // 测试删除动态接口
+ @Test
+ void testDeleteDynamic() {
+ Long dynamicId = 1L;
+ // 模拟 dynamicService.deleteDynamic 方法行为
+ doNothing().when(dynamicService).deleteDynamic(dynamicId);
+
+ // 调用控制器方法
+ ResponseEntity<String> response = dynamicController.deleteDynamic(dynamicId);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("动态删除成功", response.getBody());
+ }
+
+ // 测试添加评论接口
+ @Test
+ void testAddComment() {
+ Long userId = 1L;
+ Long dynamicId = 1L;
+ Map<String, String> commentContent = new HashMap<>();
+ commentContent.put("content", "This is a test comment");
+
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("comment_id", 101L);
+ mockResponse.put("message", "评论成功");
+
+ // 模拟 dynamicService.addComment 返回
+ when(dynamicService.addComment(userId, dynamicId, "This is a test comment")).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> response = dynamicController.addComment(userId, dynamicId, commentContent);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("评论成功", response.getBody().get("message"));
+ assertEquals(101L, response.getBody().get("comment_id"));
+ }
+
+ // 测试获取用户动态接口
+ @Test
+ void testGetAllUserDynamics() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("dynamic", "mock_dynamic_data");
+
+ // 模拟 dynamicService.getAllUserDynamics 返回
+ when(dynamicService.getAllUserDynamics(userId)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> response = dynamicController.getAllUserDynamics(userId);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertNotNull(response.getBody().get("dynamic"));
+ }
+
+ // 测试获取所有好友动态接口
+ @Test
+ void testGetAllUserAndFriendsDynamics() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("dynamic", "mock_friend_dynamic_data");
+
+ // 模拟 dynamicService.getAllUserAndFriendsDynamics 返回
+ when(dynamicService.getAllUserAndFriendsDynamics(anyList())).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> response = dynamicController.getAllUserAndFriendsDynamics(userId);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertNotNull(response.getBody().get("dynamic"));
+ }
+
+ // 测试点赞动态接口
+ @Test
+ void testLikeDynamic() {
+ Map<String, Long> request = new HashMap<>();
+ request.put("userId", 1L);
+ request.put("dynamicId", 1L);
+
+ // 模拟 dynamicService.likeDynamic 返回
+ when(dynamicService.likeDynamic(1L, 1L)).thenReturn(true);
+
+ // 调用控制器方法
+ ResponseEntity<String> response = dynamicController.likeDynamic(request);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("Like successful", response.getBody());
+ }
+
+ // 测试取消点赞接口
+ @Test
+ void testUnlikeDynamic() {
+ Map<String, Long> request = new HashMap<>();
+ request.put("userId", 1L);
+ request.put("dynamicId", 1L);
+
+ // 模拟 dynamicService.unlikeDynamic 返回
+ when(dynamicService.unlikeDynamic(1L, 1L)).thenReturn(true);
+
+ // 调用控制器方法
+ ResponseEntity<String> response = dynamicController.unlikeDynamic(request);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("Unlike successful", response.getBody());
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/GroupControllerTest.java b/src/test/java/com/example/myproject/controller/GroupControllerTest.java
new file mode 100644
index 0000000..d8c8c2c
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/GroupControllerTest.java
@@ -0,0 +1,209 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.controller.GroupController;
+import com.example.myproject.entity.Group;
+import com.example.myproject.entity.GroupComments;
+import com.example.myproject.service.GroupService;
+import com.example.myproject.utils.Result;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+
+class GroupControllerTest {
+
+ @InjectMocks
+ private GroupController groupController;
+
+ @Mock
+ private GroupService groupService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试创建小组
+
+ @Test
+ void createGroupTest() {
+ Group groupRequest = new Group();
+ groupRequest.setGroupName("Test Group");
+ groupRequest.setDescription("This is a test group");
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("group_id", 1L);
+ mockResponse.put("message", "兴趣小组创建成功");
+
+ ResponseEntity<Map<String, Object>> mockResponseEntity = ResponseEntity.ok(mockResponse);
+ when(groupService.createGroup(groupRequest)).thenReturn(mockResponseEntity);
+
+ // 调用控制器的方法
+ ResponseEntity<?> responseEntity = groupController.createGroup(groupRequest);
+ Map<String, Object> resultMap = (Map<String, Object>) responseEntity.getBody();
+ Result<Map<String, Object>> result = Result.success(resultMap, "兴趣小组创建成功");
+
+ // 验证返回的结果
+ assertEquals("200", result.getCode());
+ assertEquals("兴趣小组创建成功", result.getMsg());
+ assertEquals(1L, result.getData().get("group_id"));
+ }
+
+
+ // 测试加入小组接口
+ @Test
+ void testJoinGroup() {
+ Long groupId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "成功加入小组");
+ when(groupService.joinGroup(groupId, userId)).thenReturn(ResponseEntity.ok(mockResponse));
+
+ // 调用控制器方法
+ Map<String, Long> requestBody = Map.of("user_id", userId);
+ ResponseEntity<Map<String, Object>> response = groupController.joinGroup(groupId, requestBody);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertEquals("成功加入小组", response.getBody().get("message"));
+ }
+
+ // 测试退出小组接口
+ @Test
+ void testLeaveGroup() {
+ Long groupId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "成功退出小组");
+ when(groupService.leaveGroup(groupId, userId)).thenReturn(ResponseEntity.ok(mockResponse));
+
+ // 调用控制器方法
+ Map<String, Long> requestBody = Map.of("user_id", userId);
+ ResponseEntity<Map<String, Object>> response = groupController.leaveGroup(groupId, requestBody);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertEquals("成功退出小组", response.getBody().get("message"));
+ }
+
+ // 测试获取小组成员接口
+ @Test
+ void testGetGroupMembers() {
+ Long groupId = 1L;
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("members", "mock_members");
+ when(groupService.getGroupMembers(groupId)).thenReturn(ResponseEntity.ok(mockResponse));
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> response = groupController.getGroupMembers(groupId);
+
+ // 验证返回的结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertNotNull(response.getBody().get("members"));
+ }
+
+ // 测试发布帖子
+ @Test
+ void createPostTest() {
+ Long groupId = 1L;
+ Long userId = 2L;
+ String postContent = "Test post content";
+ String title = "Test post title";
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("post_id", 1L);
+ mockResponse.put("message", "帖子创建成功");
+
+ when(groupService.createPost(groupId, userId, postContent, title, null)).thenReturn(mockResponse);
+
+ // 调用控制器的方法
+ Map<String, Object> result = groupController.createPost(groupId, userId, postContent, title, null).getBody();
+
+ // 验证返回的结果
+ assertEquals("帖子创建成功", result.get("message"));
+ assertEquals(1L, result.get("post_id"));
+ }
+
+ // 测试点赞帖子
+ @Test
+ void likePostTest() {
+ Long postId = 1L;
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "点赞成功");
+
+ when(groupService.likePost(postId)).thenReturn(mockResponse);
+
+ // 调用控制器的方法
+ Map<String, Object> resultMap = groupController.likePost(postId).getBody();
+
+ // 验证返回的结果
+ assertEquals("点赞成功", resultMap.get("message"));
+ }
+
+ // 测试取消点赞
+ @Test
+ void unlikePostTest() {
+ Long postId = 1L;
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "取消点赞成功");
+
+ when(groupService.unlikePost(postId)).thenReturn(mockResponse);
+
+ // 调用控制器的方法
+ Map<String, Object> resultMap = groupController.unlikePost(postId).getBody();
+
+ // 验证返回的结果
+ assertEquals("取消点赞成功", resultMap.get("message"));
+ }
+
+ // 测试添加评论
+ @Test
+ void addCommentTest() {
+ Long postId = 1L;
+ GroupComments comment = new GroupComments();
+ comment.setUserId(2L);
+ comment.setContent("This is a comment");
+
+ // 模拟服务层的返回值
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "评论成功");
+
+ when(groupService.addComment(postId, comment)).thenReturn(mockResponse);
+
+ // 调用控制器的方法
+ Map<String, Object> resultMap = groupController.addComment(postId, comment).getBody();
+
+ // 验证返回的结果
+ assertEquals("评论成功", resultMap.get("message"));
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/LevelControllerTest.java b/src/test/java/com/example/myproject/controller/LevelControllerTest.java
new file mode 100644
index 0000000..c3d77b9
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/LevelControllerTest.java
@@ -0,0 +1,126 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.controller.LevelController;
+import com.example.myproject.service.LevelService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class LevelControllerTest {
+
+ @InjectMocks
+ private LevelController levelController;
+
+ @Mock
+ private LevelService levelService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试获取用户经验接口
+ @Test
+ void testGetExperience() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("current_experience", 1500);
+ mockResponse.put("level", "Intermediate");
+ mockResponse.put("next_level_experience", 2000);
+
+ // 模拟 levelService.getUserExperience 返回
+ when(levelService.getUserExperience(userId)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ Map<String, Object> response = levelController.getExperience(userId);
+
+ // 验证返回的结果
+ assertEquals(1500, response.get("current_experience"));
+ assertEquals("Intermediate", response.get("level"));
+ assertEquals(2000, response.get("next_level_experience"));
+ }
+
+ // 测试更新用户经验接口
+ @Test
+ void testUpdateExperience() {
+ Long userId = 1L;
+ Integer experience = 500;
+ String source = "Quest";
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "经验更新成功");
+ mockResponse.put("current_experience", 2000);
+
+ Map<String, Object> params = new HashMap<>();
+ params.put("user_id", userId);
+ params.put("experience", experience);
+ params.put("source", source);
+
+ // 模拟 levelService.updateExperience 返回
+ when(levelService.updateExperience(userId, experience, source)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ Map<String, Object> response = levelController.updateExperience(params);
+
+ // 验证返回的结果
+ assertEquals("success", response.get("status"));
+ assertEquals("经验更新成功", response.get("message"));
+ assertEquals(2000, response.get("current_experience"));
+ }
+
+ // 测试检查用户升级条件接口
+ @Test
+ void testCheckUpgrade() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("can_upgrade", true);
+ mockResponse.put("next_level_experience", 2000);
+ mockResponse.put("current_experience", 1500);
+
+ // 模拟 levelService.checkUpgrade 返回
+ when(levelService.checkUpgrade(userId)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ Map<String, Object> response = levelController.checkUpgrade(userId);
+
+ // 验证返回的结果
+ assertTrue((Boolean) response.get("can_upgrade"));
+ assertEquals(2000, response.get("next_level_experience"));
+ assertEquals(1500, response.get("current_experience"));
+ }
+
+ // 测试升级用户等级接口
+ @Test
+ void testUpgradeUserLevel() {
+ Long userId = 1L;
+ Boolean canUpgrade = true;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "升级成功");
+ mockResponse.put("new_level", "Advanced");
+
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("can_upgrade", canUpgrade);
+
+ // 模拟 levelService.upgradeUserLevel 返回
+ when(levelService.upgradeUserLevel(userId, canUpgrade)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ Map<String, Object> response = levelController.upgradeUserLevel(request);
+
+ // 验证返回的结果
+ assertEquals("success", response.get("status"));
+ assertEquals("升级成功", response.get("message"));
+ assertEquals("Advanced", response.get("new_level"));
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/PostControllerTest.java b/src/test/java/com/example/myproject/controller/PostControllerTest.java
new file mode 100644
index 0000000..21eeddd
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/PostControllerTest.java
@@ -0,0 +1,206 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.entity.Post;
+import com.example.myproject.service.PostService;
+import com.example.myproject.utils.Result;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class PostControllerTest {
+
+ @InjectMocks
+ private PostController postController;
+
+ @Mock
+ private PostService postService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试创建帖子
+ void createPostTest() {
+ Long userId = 1L;
+ String postContent = "Test Post Content";
+ String title = "Test Post Title";
+ MultipartFile[] imageFiles = new MultipartFile[0]; // Empty array for simplicity
+
+ // 模拟服务层的返回值
+ Map<String, Object> responseMap = new HashMap<>();
+ responseMap.put("postNo", 123L);
+ responseMap.put("message", "帖子创建成功");
+
+ when(postService.createPost(userId, postContent, title, imageFiles)).thenReturn(responseMap);
+
+ // 调用控制器的方法
+ Map<String, Object> resultMap = postController.createPost(userId, postContent, title, imageFiles);
+
+ // 手动将 Map<String, Object> 包装到 Result.success()
+ Result<Map<String, Object>> result = Result.success(resultMap, "帖子创建成功");
+
+ // 验证返回的结果
+ assertEquals("200", result.getCode());
+ assertEquals("帖子创建成功", result.getMsg());
+ assertEquals(123L, result.getData().get("postNo"));
+ }
+
+ // 测试编辑帖子
+ @Test
+ void updatePostTest() {
+ Long postId = 1L;
+ Post post = new Post();
+ post.setPostNo(postId);
+ post.setTitle("Updated Title");
+ post.setPostContent("Updated Content");
+
+ // 模拟服务层的行为
+ doNothing().when(postService).updatePost(postId, post);
+
+ // 调用控制器的方法
+ String result = postController.updatePost(postId, post);
+
+ // 验证返回的结果
+ assertEquals("Post updated successfully!", result);
+ }
+
+ // 测试删除帖子
+ @Test
+ void deletePostTest() {
+ Long postId = 1L;
+
+ // 模拟服务层的行为
+ doNothing().when(postService).deletePost(postId);
+
+ // 调用控制器的方法
+ String result = postController.deletePost(postId);
+
+ // 验证返回的结果
+ assertEquals("Post deleted successfully!", result);
+ }
+
+ // 测试点赞帖子
+ @Test
+ void likePostTest() {
+ Long postId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的行为
+ doNothing().when(postService).likePost(postId, userId);
+
+ // 创建请求体
+ Map<String, Long> requestBody = new HashMap<>();
+ requestBody.put("user_id", userId);
+
+ // 调用控制器的方法
+ String result = postController.likePost(postId, requestBody);
+
+ // 验证返回的结果
+ assertEquals("Post liked successfully!", result);
+ }
+
+ // 测试取消点赞帖子
+ @Test
+ void unlikePostTest() {
+ Long postId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的行为
+ doNothing().when(postService).unlikePost(postId, userId);
+
+ // 创建请求体
+ Map<String, Long> requestBody = new HashMap<>();
+ requestBody.put("user_id", userId);
+
+ // 调用控制器的方法
+ String result = postController.unlikePost(postId, requestBody);
+
+ // 验证返回的结果
+ assertEquals("Post unliked successfully!", result);
+ }
+
+ // 测试收藏帖子
+ @Test
+ void collectPostTest() {
+ Long postId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的行为
+ doNothing().when(postService).collectPost(postId, userId);
+
+ // 创建请求体
+ Map<String, Long> requestBody = new HashMap<>();
+ requestBody.put("user_id", userId);
+
+ // 调用控制器的方法
+ String result = postController.collectPost(postId, requestBody);
+
+ // 验证返回的结果
+ assertEquals("Post collected successfully!", result);
+ }
+
+ // 测试取消收藏帖子
+ @Test
+ void uncollectPostTest() {
+ Long postId = 1L;
+ Long userId = 1L;
+
+ // 模拟服务层的行为
+ doNothing().when(postService).uncollectPost(postId, userId);
+
+ // 创建请求体
+ Map<String, Long> requestBody = new HashMap<>();
+ requestBody.put("user_id", userId);
+
+ // 调用控制器的方法
+ String result = postController.uncollectPost(postId, requestBody);
+
+ // 验证返回的结果
+ assertEquals("Post uncollected successfully!", result);
+ }
+
+ // 测试获取所有帖子
+ @Test
+ void getAllPostsTest() {
+ // 模拟服务层的行为
+ Map<String, Object> responseMap = new HashMap<>();
+ responseMap.put("total", 5);
+ responseMap.put("posts", new ArrayList<>());
+
+ when(postService.getAllPosts()).thenReturn(responseMap);
+
+ // 调用控制器的方法
+ Map<String, Object> result = postController.getAllPosts();
+
+ // 验证返回的结果
+ assertEquals(5, result.get("total"));
+ }
+
+ // 测试根据帖子ID获取帖子
+ @Test
+ void getPostByIdTest() {
+ Long postId = 1L;
+ Map<String, Object> responseMap = new HashMap<>();
+ responseMap.put("postNo", 123L);
+ responseMap.put("message", "Post details");
+
+ // 模拟服务层的行为
+ when(postService.getPostById(postId)).thenReturn(responseMap);
+
+ // 调用控制器的方法
+ Map<String, Object> result = postController.getPostById(postId);
+
+ // 验证返回的结果
+ assertEquals("Post details", result.get("message"));
+ assertEquals(123L, result.get("postNo"));
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/TaskControllerTest.java b/src/test/java/com/example/myproject/controller/TaskControllerTest.java
new file mode 100644
index 0000000..5d7609d
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/TaskControllerTest.java
@@ -0,0 +1,205 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.controller.TaskController;
+import com.example.myproject.service.TaskService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class TaskControllerTest {
+
+ @InjectMocks
+ private TaskController taskController;
+
+ @Mock
+ private TaskService taskService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试获取当前用户的新手任务列表接口
+ @Test
+ void testGetAllTasks() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("tasks", "mock_tasks");
+
+ // 模拟 taskService.getAllTasksForUser 返回
+ when(taskService.getAllTasksForUser(userId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.getAllTasks(request);
+
+ // 验证返回的结果
+ assertEquals("mock_tasks", response.get("tasks"));
+ }
+
+ // 测试更新任务状态接口
+ @Test
+ void testUpdateTaskStatus() {
+ Long userId = 1L;
+ String taskId = "task_123";
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "任务状态已更新");
+
+ // 模拟 taskService.updateTaskStatus 返回
+ when(taskService.updateTaskStatus(userId, taskId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("task_id", taskId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.updateTaskStatus(request);
+
+ // 验证返回的结果
+ assertEquals("success", response.get("status"));
+ assertEquals("任务状态已更新", response.get("message"));
+ }
+
+ // 测试获取当前经验和任务奖励接口
+ @Test
+ void testGetExperience() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("current_experience", 1500);
+ mockResponse.put("level", "Intermediate");
+ mockResponse.put("reward", Map.of("experience", 1000, "points", 200));
+
+ // 模拟 taskService.getUserExperience 返回
+ when(taskService.getUserExperience(userId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.getExperience(request);
+
+ // 验证返回的结果
+ assertEquals(1500, response.get("current_experience"));
+ assertEquals("Intermediate", response.get("level"));
+ assertTrue(response.containsKey("reward"));
+ }
+
+ // 测试获取当前的指引步骤接口
+ @Test
+ void testGetNewStep() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("current_step", "step_1");
+ mockResponse.put("total_steps", 5);
+ mockResponse.put("step_description", "Complete the introduction task");
+
+ // 模拟 taskService.getNewStep 返回
+ when(taskService.getNewStep(userId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.getNewStep(request);
+
+ // 验证返回的结果
+ assertEquals("step_1", response.get("current_step"));
+ assertEquals(5, response.get("total_steps"));
+ assertEquals("Complete the introduction task", response.get("step_description"));
+ }
+
+ // 测试更新进度接口
+ @Test
+ void testUpdateProgress() {
+ Long userId = 1L;
+ String taskId = "task_123";
+ Integer progress = 50;
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "进度已更新");
+
+ // 模拟 taskService.updateTaskProgress 返回
+ when(taskService.updateTaskProgress(userId, taskId, progress)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("task_id", taskId);
+ request.put("progress", progress);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.updateProgress(request);
+
+ // 验证返回的结果
+ assertEquals("success", response.get("status"));
+ assertEquals("进度已更新", response.get("message"));
+ }
+
+ // 测试领取任务奖励接口
+ @Test
+ void testRewardClaim() {
+ Long userId = 1L;
+ String taskId = "task_123";
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "奖励已领取");
+ mockResponse.put("reward", Map.of("experience", 1000, "points", 200));
+
+ // 模拟 taskService.claimReward 返回
+ when(taskService.claimReward(userId, taskId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("task_id", taskId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.rewardClaim(request);
+
+ // 验证返回的结果
+ assertEquals("success", response.get("status"));
+ assertEquals("奖励已领取", response.get("message"));
+ assertTrue(response.containsKey("reward"));
+ }
+
+ // 测试检查任务奖励状态接口
+ @Test
+ void testRewardReview() {
+ Long userId = 1L;
+ String taskId = "task_123";
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "reward_not_issued");
+ mockResponse.put("message", "任务奖励未被领取");
+
+ // 模拟 taskService.checkRewardStatus 返回
+ when(taskService.checkRewardStatus(userId, taskId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("task_id", taskId);
+
+ // 调用控制器方法
+ Map<String, Object> response = taskController.rewardReview(request);
+
+ // 验证返回的结果
+ assertEquals("reward_not_issued", response.get("status"));
+ assertEquals("任务奖励未被领取", response.get("message"));
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/UserControllerTest.java b/src/test/java/com/example/myproject/controller/UserControllerTest.java
index d332f31..a97e169 100644
--- a/src/test/java/com/example/myproject/controller/UserControllerTest.java
+++ b/src/test/java/com/example/myproject/controller/UserControllerTest.java
@@ -1,162 +1,234 @@
package com.example.myproject.controller;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.example.myproject.entity.User;
-import com.example.myproject.service.EmailService;
+import com.example.myproject.entity.Users;
import com.example.myproject.service.UserService;
-import com.example.myproject.mapper.UserMapper;
-import com.example.myproject.mapper.VerificationTokenMapper;
-import com.example.myproject.common.base.Result;
+import com.example.myproject.repository.UserRepository;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
-import org.mockito.*;
-import org.springframework.http.ResponseEntity;
-import org.springframework.security.authentication.AuthenticationManager;
-import org.springframework.security.core.Authentication;
-import org.springframework.security.core.AuthenticationException;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
-import static org.junit.jupiter.api.Assertions.*;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+
import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
class UserControllerTest {
+ @Mock
+ private UserService userService;
+
+ @Mock
+ private UserRepository userRepository;
+
@InjectMocks
private UserController userController;
- @Mock
- private UserService userService;
- @Mock
- private UserMapper userMapper;
- @Mock
- private EmailService emailService;
- @Mock
- private AuthenticationManager authenticationManager;
- @Mock
- private VerificationTokenMapper verificationTokenMapper;
-
@BeforeEach
- void setup() {
+ void setUp() {
+ // 初始化模拟对象
MockitoAnnotations.openMocks(this);
}
+ // 测试生成邀请码接口
@Test
- void loginController_success() {
- String username = "testuser";
- String password = "testpass";
- User mockUser = new User();
- mockUser.setUsername(username);
+ void testGenerateInviteCode() {
+ // 设置输入数据
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", 1L);
- Authentication mockAuth = mock(Authentication.class);
- when(authenticationManager.authenticate(any())).thenReturn(mockAuth);
- when(userMapper.selectOne(any(QueryWrapper.class))).thenReturn(mockUser);
+ // 模拟服务层的返回
+ Map<String, Object> responseMap = new HashMap<>();
+ responseMap.put("status", "success");
+ responseMap.put("message", "邀请码生成成功");
+ responseMap.put("invite_code", "ABC123XYZ");
- Result result = userController.loginController(username, password);
+ when(userService.generateInviteCode(1L)).thenReturn(responseMap);
- assertEquals("200", result.getCode());
- assertEquals(mockUser, result.getData());
+ // 调用控制器方法
+ Map<String, Object> resultMap = userController.generateInviteCode(request);
+
+ // 验证返回结果
+ assertEquals("success", resultMap.get("status"));
+ assertEquals("邀请码生成成功", resultMap.get("message"));
+ assertEquals("ABC123XYZ", resultMap.get("invite_code"));
+
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).generateInviteCode(1L);
}
-
+ // 测试用户修改密码接口
@Test
- void loginController_failure() {
- String username = "user";
- String password = "wrongpass";
+ void testChangePassword() {
+ Long userId = 1L;
+ Map<String, Object> request = new HashMap<>();
+ request.put("user_id", userId);
+ request.put("old_password", "oldPassword");
+ request.put("new_password", "newPassword");
+ request.put("confirm_password", "newPassword");
- // 模拟认证失败，抛出 Bad credentials 异常
- when(authenticationManager.authenticate(any()))
- .thenThrow(new AuthenticationException("Bad credentials") {});
+ // 模拟服务层的返回
+ String resultMessage = "密码修改成功";
+ when(userService.changePassword(userId, "oldPassword", "newPassword", "newPassword"))
+ .thenReturn(resultMessage);
+ // 调用控制器方法
+ Map<String, Object> resultMap = userController.changePassword(request);
- // 调用登录接口
- Result result = userController.loginController(username, password);
+ // 验证返回结果
+ assertEquals("密码修改成功", resultMap.get("message"));
+ assertEquals("success", resultMap.get("status"));
- // 断言返回的状态码和消息
- assertEquals("401", result.getCode());
- assertTrue(result.getMsg().contains("登录失败"));
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).changePassword(userId, "oldPassword", "newPassword", "newPassword");
+ }
+
+ // 测试用户注册接口
+ @Test
+ void testRegister() {
+ // 设置输入数据
+ Map<String, Object> request = new HashMap<>();
+ request.put("username", "testUser");
+ request.put("email", "test@example.com");
+ request.put("password", "password");
+ request.put("role", "USER");
+ request.put("inviteCode", "12345");
+
+ // 模拟服务层的返回
+ String resultMessage = "用户注册成功";
+ when(userService.registerUser("testUser", "test@example.com", "password", "USER", "12345"))
+ .thenReturn(resultMessage);
+
+ // 调用控制器方法
+ Map<String, Object> resultMap = userController.register(request);
+
+ // 验证返回结果
+ assertEquals("用户注册成功", resultMap.get("msg"));
+
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).registerUser("testUser", "test@example.com", "password", "USER", "12345");
}
@Test
- void registerController_emailExists() {
- User user = new User();
+ void testLogin() {
+ String username = "testUser";
+ String password = "password";
+
+ // 模拟服务层的返回
+ String loginMessage = "登录成功";
+ when(userService.loginUser("testUser", "password")).thenReturn(loginMessage);
+
+ // 模拟用户查询
+ Users user = new Users();
+ user.setUserId(1L);
+ user.setUsername("testUser");
user.setEmail("test@example.com");
+ when(userRepository.findByUsername("testUser")).thenReturn(Optional.of(user));
- when(userService.checkEmailExists(user.getEmail())).thenReturn(true);
+ // 设置请求数据
+ Map<String, Object> request = new HashMap<>();
+ request.put("username", username);
+ request.put("password", password);
- Result result = userController.registerController(user);
+ // 调用控制器方法
+ Map<String, Object> resultMap = userController.login(request);
- assertEquals("邮箱冲突", result.getCode());
+ // 验证返回结果
+ assertEquals("登录成功", resultMap.get("msg"));
+
+ // 验证 user 不是 Map 类型，而是 Users 对象
+ Users loggedInUser = (Users) resultMap.get("user");
+ assertNotNull(loggedInUser);
+ assertEquals("testUser", loggedInUser.getUsername());
+ assertEquals("test@example.com", loggedInUser.getEmail());
+
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).loginUser("testUser", "password");
}
+
+ // 测试获取用户个人资料接口
@Test
- void registerController_success() {
- User user = new User();
+ void testGetProfile() {
+ Long userId = 1L;
+
+ // Mock 用户数据
+ Users user = new Users();
+ user.setUserId(userId);
+ user.setUsername("testUser");
user.setEmail("test@example.com");
+ user.setAvatarUrl("https://example.com/avatar.jpg");
- when(userService.checkEmailExists(user.getEmail())).thenReturn(false);
- when(userService.preRegisterUser(user)).thenReturn(true);
+ // 模拟服务层返回
+ Map<String, Object> profileData = new HashMap<>();
+ profileData.put("avatarUrl", user.getAvatarUrl());
+ profileData.put("username", user.getUsername());
+ profileData.put("email", user.getEmail());
+ when(userService.getProfile(userId)).thenReturn(profileData);
- Result result = userController.registerController(user);
+ // 调用控制器方法
+ Map<String, Object> resultMap = userController.getProfile(userId);
- assertEquals("200", result.getCode());
- assertEquals(user.getEmail(), ((User) result.getData()).getEmail());
+ // 验证返回结果
+ assertEquals("testUser", resultMap.get("username"));
+ assertEquals("test@example.com", resultMap.get("email"));
+ assertEquals("https://example.com/avatar.jpg", resultMap.get("avatarUrl"));
+
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).getProfile(userId);
+ }
+
+ // 测试修改用户个人资料接口
+ @Test
+ void testEditProfile() {
+ Long userId = 1L;
+ Map<String, Object> profileData = new HashMap<>();
+ profileData.put("avatarUrl", "https://example.com/avatar.jpg");
+ profileData.put("nickname", "newNickname");
+ profileData.put("gender", "Male");
+ profileData.put("description", "Updated description");
+ profileData.put("hobbies", "Reading, Hiking");
+
+ // 模拟服务层的返回
+ when(userService.editProfile(userId, "https://example.com/avatar.jpg", "newNickname", "Male", "Updated description", "Reading, Hiking"))
+ .thenReturn(true);
+
+ // 调用控制器方法
+ Map<String, String> resultMap = userController.editProfile(userId, profileData);
+
+ // 验证返回结果
+ assertEquals("用户资料更新成功", resultMap.get("message"));
+
+ // 验证服务层方法是否被调用
+ verify(userService, times(1)).editProfile(userId, "https://example.com/avatar.jpg", "newNickname", "Male", "Updated description", "Reading, Hiking");
}
@Test
- void verifyEmailCode_success() {
- when(userService.verifyEmail("test@example.com", "123456")).thenReturn(true);
+ public void testCalculateShareRate() {
+ Long userId = 1L;
- UserController.VerificationRequest request = new UserController.VerificationRequest();
- request.setEmail("test@example.com");
- request.setCode("123456");
+ // 模拟 UserService 返回的结果
+ Map<String, Object> expectedResponse = Map.of(
+ "status", "success",
+ "message", "分享率计算成功",
+ "shareRate", 0.5f
+ );
- Result result = userController.verifyEmailCode(request);
+ // 设置用户数据
+ Users user = new Users();
+ user.setUserId(userId);
+ user.setUploadCount(50f); // 上传量为50
+ user.setDownloadCount(100f); // 下载量为100
+ when(userService.calculateShareRate(userId)).thenReturn(expectedResponse);
- assertEquals("200", result.getCode());
- }
+ // 调用接口
+ Map<String, Object> result = userController.calculateShareRate(userId);
- @Test
- void verifyEmailCode_failure() {
- when(userService.verifyEmail("test@example.com", "000000")).thenReturn(false);
-
- UserController.VerificationRequest request = new UserController.VerificationRequest();
- request.setEmail("test@example.com");
- request.setCode("000000");
-
- Result result = userController.verifyEmailCode(request);
-
- assertEquals("验证失败", result.getCode());
- }
-
- @Test
- void checkPassword_success() {
- when(userService.checkPassword(1L, "abc123")).thenReturn(true);
-
- Result<String> result = userController.checkPassword(1L, "abc123");
-
- assertEquals("200", result.getCode());
- assertEquals("原始密码输入正确", result.getMsg());
- }
-
- @Test
- void checkPassword_failure() {
- when(userService.checkPassword(1L, "wrong")).thenReturn(false);
-
- Result<String> result = userController.checkPassword(1L, "wrong");
-
- assertEquals("305", result.getCode());
- assertEquals("原始密码输入错误", result.getMsg());
- }
-
- @Test
- void sendVerificationEmail_userNotFound() {
- UserController.EmailRequest request = new UserController.EmailRequest();
- request.setEmail("notfound@example.com");
-
- when(userMapper.selectOne(any())).thenReturn(null);
-
- ResponseEntity<Result> response = userController.sendVerificationEmail(request);
-
- assertEquals(400, response.getStatusCodeValue());
- assertEquals("1", response.getBody().getCode());
+ // 验证结果
+ assertEquals(expectedResponse, result);
+ verify(userService, times(1)).calculateShareRate(userId); // 验证服务方法是否被调用
}
}
diff --git a/src/test/java/com/example/myproject/controller/UserFollowControllerTest.java b/src/test/java/com/example/myproject/controller/UserFollowControllerTest.java
new file mode 100644
index 0000000..29bf47f
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/UserFollowControllerTest.java
@@ -0,0 +1,132 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.controller.UserFollowController;
+import com.example.myproject.service.UserFollowService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+import java.util.List;
+
+import java.util.Map;
+
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+class UserFollowControllerTest {
+
+ @InjectMocks
+ private UserFollowController userFollowController;
+
+ @Mock
+ private UserFollowService userFollowService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ // 测试用户关注接口
+ @Test
+ void testFollow() {
+ Long followerId = 1L;
+ Long followedId = 2L;
+ Map<String, Object> mockResponse = Map.of(
+ "status", "success",
+ "message", "关注成功"
+ );
+
+ // 模拟 userFollowService.follow() 返回
+ when(userFollowService.follow(followerId, followedId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Long> request = Map.of("follower_id", followerId);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> responseEntity = userFollowController.follow(followedId, request);
+
+ // 验证返回的状态码和内容
+ assertEquals(200, responseEntity.getStatusCodeValue());
+ assertEquals("success", responseEntity.getBody().get("status"));
+ assertEquals("关注成功", responseEntity.getBody().get("message"));
+ }
+
+ // 测试取消关注接口
+ @Test
+ void testUnfollow() {
+ Long followerId = 1L;
+ Long followedId = 2L;
+ Map<String, Object> mockResponse = Map.of(
+ "status", "success",
+ "message", "取消关注成功"
+ );
+
+ // 模拟 userFollowService.unfollow() 返回
+ when(userFollowService.unfollow(followerId, followedId)).thenReturn(mockResponse);
+
+ // 创建请求体
+ Map<String, Long> request = Map.of("follower_id", followerId);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> responseEntity = userFollowController.unfollow(followedId, request);
+
+ // 验证返回的状态码和内容
+ assertEquals(200, responseEntity.getStatusCodeValue());
+ assertEquals("success", responseEntity.getBody().get("status"));
+ assertEquals("取消关注成功", responseEntity.getBody().get("message"));
+ }
+
+ // 测试获取某个用户的粉丝列表接口
+ @Test
+ void testGetFollowers() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = Map.of(
+ "status", "success",
+ "total", 2,
+ "followers", List.of(
+ Map.of("user_id", 2L, "username", "user2", "avatar_url", "url2"),
+ Map.of("user_id", 3L, "username", "user3", "avatar_url", "url3")
+ )
+ );
+
+ // 模拟 userFollowService.getFollowers() 返回
+ when(userFollowService.getFollowers(userId)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> responseEntity = userFollowController.getFollowers(userId);
+
+ // 验证返回的状态码和内容
+ assertEquals(200, responseEntity.getStatusCodeValue());
+ assertEquals("success", responseEntity.getBody().get("status"));
+ assertEquals(2, responseEntity.getBody().get("total"));
+ assertEquals(2, ((List<?>) responseEntity.getBody().get("followers")).size());
+ }
+
+ // 测试获取某个用户的关注列表接口
+ @Test
+ void testGetFollowing() {
+ Long userId = 1L;
+ Map<String, Object> mockResponse = Map.of(
+ "status", "success",
+ "total", 2,
+ "following", List.of(
+ Map.of("user_id", 2L, "username", "user2", "avatar_url", "url2"),
+ Map.of("user_id", 3L, "username", "user3", "avatar_url", "url3")
+ )
+ );
+
+ // 模拟 userFollowService.getFollowing() 返回
+ when(userFollowService.getFollowing(userId)).thenReturn(mockResponse);
+
+ // 调用控制器方法
+ ResponseEntity<Map<String, Object>> responseEntity = userFollowController.getFollowing(userId);
+
+ // 验证返回的状态码和内容
+ assertEquals(200, responseEntity.getStatusCodeValue());
+ assertEquals("success", responseEntity.getBody().get("status"));
+ assertEquals(2, responseEntity.getBody().get("total"));
+ assertEquals(2, ((List<?>) responseEntity.getBody().get("following")).size());
+ }
+}
diff --git a/src/test/java/com/example/myproject/controller/UserMessageControllerTest.java b/src/test/java/com/example/myproject/controller/UserMessageControllerTest.java
new file mode 100644
index 0000000..4fcbcc7
--- /dev/null
+++ b/src/test/java/com/example/myproject/controller/UserMessageControllerTest.java
@@ -0,0 +1,95 @@
+package com.example.myproject.controller;
+
+import com.example.myproject.service.UserMessageService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.springframework.http.ResponseEntity;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.Mockito.when;
+
+class UserMessageControllerTest {
+
+ @InjectMocks
+ private UserMessageController userMessageController;
+
+ @Mock
+ private UserMessageService userMessageService;
+
+ @BeforeEach
+ void setup() {
+ MockitoAnnotations.openMocks(this);
+ }
+
+ @Test
+ void testSendMessage() {
+ // 准备测试数据
+ Map<String, Object> params = new HashMap<>();
+ params.put("sender_id", 1L);
+ params.put("receiver_id", 2L);
+ params.put("content", "测试消息");
+
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", "私信发送成功");
+ mockResponse.put("message_id", 100L);
+
+ // 模拟Service方法调用
+ when(userMessageService.sendMessage(1L, 2L, "测试消息")).thenReturn(mockResponse);
+
+ // 执行测试
+ ResponseEntity<Map<String, Object>> response = userMessageController.sendMessage(params);
+
+ // 验证结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ assertEquals("私信发送成功", response.getBody().get("message"));
+ assertEquals(100L, response.getBody().get("message_id"));
+ }
+
+ @Test
+ void testGetUserMessages() {
+ // 准备测试数据
+ Long userId = 1L;
+
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("messages", new HashMap<>());
+
+ // 模拟Service方法调用
+ when(userMessageService.getUserMessages(userId)).thenReturn(mockResponse);
+
+ // 执行测试
+ ResponseEntity<Map<String, Object>> response = userMessageController.getUserMessages(userId);
+
+ // 验证结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ }
+
+ @Test
+ void testGetMessage() {
+ // 准备测试数据
+ Long messageId = 1L;
+
+ Map<String, Object> mockResponse = new HashMap<>();
+ mockResponse.put("status", "success");
+ mockResponse.put("message", new HashMap<>());
+
+ // 模拟Service方法调用
+ when(userMessageService.getMessage(messageId)).thenReturn(mockResponse);
+
+ // 执行测试
+ ResponseEntity<Map<String, Object>> response = userMessageController.getMessage(messageId);
+
+ // 验证结果
+ assertEquals(200, response.getStatusCodeValue());
+ assertEquals("success", response.getBody().get("status"));
+ }
+}
\ No newline at end of file