merge: 合并feature-ip-location分支到feature/contacts-friends

完成用户信息修改，以及用户信息审核

pom.xml

@@ -71,6 +71,19 @@
             <version>3.12.0</version>
         </dependency>
 
+        <!-- OkHttp（用于调用API） -->
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.12.0</version>
+        </dependency>
+
+        <!-- AOP起步依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+
        <!--   阿里云相关依赖     -->
         <dependency>
             <groupId>com.aliyun.oss</groupId>
@@ -142,6 +155,12 @@
             <artifactId>spring-boot-starter-mail</artifactId>
         </dependency>
 
+        <!-- Redis 依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+
     </dependencies>
     <dependencyManagement>
         <dependencies>

src/main/java/com/bao/dating/DatingApplication.java

@@ -3,9 +3,11 @@ package com.bao.dating;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @MapperScan("com.bao.dating.mapper")
 @SpringBootApplication
+@EnableScheduling
 public class DatingApplication {
     public static void main(String[] args) {
         SpringApplication.run(DatingApplication.class, args);

src/main/java/com/bao/dating/aspect/RecordTimeAspect.java

@@ -0,0 +1,31 @@
+package com.bao.dating.aspect;
+
+import lombok.extern.slf4j.Slf4j;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.stereotype.Component;
+
+/**
+ *  记录方法运行耗时
+ *   @author KilLze
+ */
+@Slf4j
+@Aspect
+@Component
+public class RecordTimeAspect {
+    @Around("execution(* com.bao.dating.service.impl.*.*(..))")
+    public Object recordTime(ProceedingJoinPoint pjp) throws Throwable {
+        //1. 记录方法运行的开始时间
+        long begin = System.currentTimeMillis();
+
+        //2. 执行原始的方法
+        Object result = pjp.proceed();
+
+        //3. 记录方法运行的结束时间, 记录耗时
+        long end = System.currentTimeMillis();
+        log.info("方法 {} 执行耗时: {}ms", pjp.getSignature() ,end-begin);
+        return  result;
+    }
+
+}

src/main/java/com/bao/dating/common/ResultCode.java

@@ -1,14 +1,35 @@
 package com.bao.dating.common;
 
+/**
+ * 响应状态码枚举
+ * @author KilLze
+ */
 public enum ResultCode {
+    /** 成功 */
     SUCCESS(200, "成功"),
+    /** 请求已成功处理 */
     SUCCESS_REVIEW(201, "请求已成功处理"),
+    /** 删除成功 */
     SUCCESS_DELETE(204, "删除成功"),
+    /** 参数错误 */
     PARAM_ERROR(400, "参数错误"),
+    /** 未登录或 Token 失效 */
     UNAUTHORIZED(401, "未登录或 Token 失效"),
+    /** 无权限 */
     FORBIDDEN(403, "无权限"),
+    /** 数据不存在 */
     NOT_FOUND(404, "数据不存在"),
+    /** 验证码已发送 */
+    CODE_SENT(200, "验证码已发送"),
+    /** 验证码错误 */
+    CODE_ERROR(400, "验证码错误"),
+    /** 验证码已过期 */
+    CODE_EXPIRED(400, "验证码已过期"),
+    /** 验证码发送失败 */
+    CODE_SEND_FAIL(500, "验证码发送失败"),
+    /** 系统异常 */
     SYSTEM_ERROR(500, "系统异常"),
+    /** 操作失败 */
     FAIL(500, "操作失败");
 
     private final int code;

src/main/java/com/bao/dating/common/aliyun/AliOssUtil.java

@@ -4,16 +4,17 @@ import com.aliyun.oss.ClientException;
 import com.aliyun.oss.OSS;
 import com.aliyun.oss.OSSClientBuilder;
 import com.aliyun.oss.OSSException;
-import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;
 
 import java.io.ByteArrayInputStream;
-import java.time.LocalDate;
-import java.time.format.DateTimeFormatter;
 
+/**
+ * 阿里云OSS工具类
+ * @author KilLze
+ */
 @Data
 @Slf4j
 @Component

src/main/java/com/bao/dating/common/aliyun/SmsUtil.java

@@ -149,3 +149,4 @@ public class SmsUtil {
 
 
 
+

src/main/java/com/bao/dating/common/ip2location/Ip2LocationConfig.java

@@ -0,0 +1,14 @@
+package com.bao.dating.common.ip2location;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "ip2location.api")
+public class Ip2LocationConfig {
+    private String key;
+    private String url;
+    private int timeout;
+}

src/main/java/com/bao/dating/common/result/AliOssResult.java

@@ -0,0 +1,11 @@
+package com.bao.dating.common.result;
+
+/**
+ * 阿里云 OSS 文件上传结果
+ * @author KilLze
+ */
+public class AliOssResult {
+    public static final String IMAGE = "image";
+    public static final String VIDEO = "video";
+
+}

src/main/java/com/bao/dating/common/result/FileResult.java

@@ -0,0 +1,15 @@
+package com.bao.dating.common.result;
+
+/**
+ * 文件上传结果
+ * @author KilLze
+ */
+public class FileResult {
+    public static final String JPG = "jpg";
+    public static final String JPEG = "jpeg";
+    public static final String PNG = "png";
+    public static final String GIF = "gif";
+    public static final String MP4 = "mp4";
+    public static final String AVI = "avi";
+    public static final String MOV = "mov";
+}

src/main/java/com/bao/dating/common/result/GreenAuditResult.java

@@ -0,0 +1,11 @@
+package com.bao.dating.common.result;
+
+/**
+ * 阿里云敏感内容审核结果
+ * @author KilLze
+ */
+public class GreenAuditResult {
+    public static final String PASS = "pass";
+    public static final String REVIEW = "review";
+    public static final String BLOCK = "block";
+}

src/main/java/com/bao/dating/config/RedisConfig.java

@@ -0,0 +1,29 @@
+package com.bao.dating.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        
+        // 设置key的序列化器
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        
+        // 设置value的序列化器
+        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
+        
+        redisTemplate.afterPropertiesSet();
+        return redisTemplate;
+    }
+}

src/main/java/com/bao/dating/config/WebConfig.java

@@ -7,6 +7,10 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
+/**
+ * WebMvc配置类
+ * @author KilLze
+ */
 @Configuration
 public class WebConfig implements WebMvcConfigurer {
 
@@ -26,8 +30,10 @@ public class WebConfig implements WebMvcConfigurer {
                 // 忽略的接口
                 .excludePathPatterns(
                         "/user/login",
-                        "/user/userRegister"
+                        "/user/register",
+                        "/user/emailLogin",
+                        "/api/verification/send-email-code",
+                        "/ip/location"
                 );
     }
 }
-

src/main/java/com/bao/dating/context/UserContext.java

@@ -1,19 +1,19 @@
 package com.bao.dating.context;
 
 /**
- * 用户上下文类
+ * 用户上下文类，用于保存当前线程的用户ID
  * @author lenovo
  */
 public class UserContext {
 
-    private static final ThreadLocal<Long> userHolder = new ThreadLocal<>();
+    private static final ThreadLocal<Long> USER_HOLDER = new ThreadLocal<>();
 
     /**
      * 设置当前线程的用户ID
      * @param userId 用户ID
      */
     public static void setUserId(Long userId) {
-        userHolder.set(userId);
+        USER_HOLDER.set(userId);
     }
 
     /**
@@ -21,13 +21,13 @@ public class UserContext {
      * @return 当前用户ID，如果未设置则返回null
      */
     public static Long getUserId() {
-        return userHolder.get();
+        return USER_HOLDER.get();
     }
 
     /**
      * 清除当前线程的用户ID
      */
     public static void clear() {
-        userHolder.remove();
+        USER_HOLDER.remove();
     }
 }

src/main/java/com/bao/dating/controller/ContactsController.java

@@ -0,0 +1,45 @@
+package com.bao.dating.controller;
+
+import com.bao.dating.context.UserContext;
+import com.bao.dating.service.ContactsService;
+
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+public class ContactsController {
+    @Resource
+    private ContactsService contactsService;
+
+    /**
+     * 查询好友列表
+     * @return 响应结果
+     */
+    @GetMapping("/friends")
+    public Map<String, Object> getFriends() {
+
+        // 从UserContext获取当前用户ID
+        Long userId = UserContext.getUserId();
+        if (userId == null) {
+            Map<String, Object> error = new HashMap<>();
+            error.put("code", 401);
+            error.put("msg", "用户未授权");
+            return error;
+        }
+
+        // 查询好友列表
+        List<Map<String, Object>> friends = contactsService.getFriendsByUserId(userId);
+
+        // 构造响应
+        Map<String, Object> result = new HashMap<>();
+        result.put("code", 200);
+        result.put("msg", "查询成功");
+        result.put("data", friends);
+        return result;
+    }
+}

src/main/java/com/bao/dating/controller/FriendController.java

@@ -0,0 +1,122 @@
+package com.bao.dating.controller;
+
+import com.bao.dating.context.UserContext;
+import com.bao.dating.service.FriendRelationService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/friend-relation")
+public class FriendController {
+    @Autowired
+    private FriendRelationService friendRelationService;
+
+    /**
+     * 发送添加好友申请（写入数据库申请表）
+     * @param targetUserId 被申请人ID
+     * @param greeting 打招呼内容
+     * @return 操作结果
+     */
+    @PostMapping("/apply")
+    public Map<String, Object> sendFriendApply(
+            @RequestParam("targetUserId") Long targetUserId,
+            @RequestParam(value = "greeting", defaultValue = "你好，加个好友吧") String greeting) {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            Long applyUserId = UserContext.getUserId();
+            if (applyUserId == null) {
+                result.put("code", 401);
+                result.put("msg", "用户未登录");
+                return result;
+            }
+            friendRelationService.addFriendApply(applyUserId, targetUserId, greeting);
+            result.put("code", 200);
+            result.put("msg", "好友申请发送成功");
+        } catch (Exception e) {
+            result.put("code", 500);
+            result.put("msg", "发送失败：" + e.getMessage());
+        }
+        return result;
+    }
+
+    /**
+     * 同意好友申请
+     * @param applyUserId 申请人ID
+     * @param targetUserId 被申请人ID（当前登录用户）
+     * @param contactNickname 给申请人的备注名
+     * @return 操作结果
+     */
+    @PostMapping("/agree")
+    public Map<String, Object> agreeFriendApply(
+            @RequestParam("applyUserId") Long applyUserId,
+            @RequestParam("targetUserId") Long targetUserId,
+            @RequestParam(value = "contactNickname", required = false) String contactNickname) {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            // 1. 同意申请（更新申请状态+删除/标记）
+            friendRelationService.agreeFriendApply(applyUserId, targetUserId);
+            // 2. 保存好友关系到通讯录表
+            friendRelationService.addFriendRelation(targetUserId, applyUserId, contactNickname);
+            friendRelationService.addFriendRelation(applyUserId, targetUserId, null);
+            result.put("code", 200);
+            result.put("msg", "同意好友申请成功");
+        } catch (Exception e) {
+            result.put("code", 500);
+            result.put("msg", "同意失败：" + e.getMessage());
+        }
+        return result;
+    }
+
+    /**
+     * 查询待处理的好友申请
+     * @return 申请列表
+     */
+    @GetMapping("/apply/list")
+    public Map<String, Object> getApplyList() {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            Long targetUserId = UserContext.getUserId();
+            if (targetUserId == null) {
+                result.put("code", 401);
+                result.put("msg", "用户未登录");
+                return result;
+            }
+            List<Map<String, Object>> applyList = friendRelationService.getFriendApplyList(targetUserId);
+            result.put("code", 200);
+            result.put("msg", "查询成功");
+            result.put("data", applyList);
+        } catch (Exception e) {
+            result.put("code", 500);
+            result.put("msg", "查询失败：" + e.getMessage());
+        }
+        return result;
+    }
+
+    /**
+     * 测试查询联系人
+     * @return 联系人列表
+     */
+    @GetMapping("/list")
+    public Map<String, Object> getFriendRelationList() {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            Long userId = UserContext.getUserId();
+            if (userId == null) {
+                result.put("code", 401);
+                result.put("msg", "用户未登录");
+                return result;
+            }
+            result.put("code", 200);
+            result.put("msg", "查询成功");
+            result.put("data", friendRelationService.getFriendRelationList(userId));
+        } catch (Exception e) {
+            result.put("code", 500);
+            result.put("msg", "查询失败：" + e.getMessage());
+        }
+        return result;
+    }
+}

src/main/java/com/bao/dating/controller/IpLocationController.java

@@ -0,0 +1,37 @@
+package com.bao.dating.controller;
+
+import com.bao.dating.common.Result;
+import com.bao.dating.common.ResultCode;
+import com.bao.dating.pojo.vo.IpLocationVO;
+import com.bao.dating.service.Ip2LocationClientService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/ip")
+public class IpLocationController {
+    @Autowired
+    private Ip2LocationClientService ip2LocationClientService;
+    /**
+     * 前端访问接口，获取IP地址位置信息
+     * @param ip 可选参数，要查询的IP地址
+     * @return IP位置信息（JSON格式）
+     */
+    @GetMapping("/location")
+    public Result<?> getIpLocation(@RequestParam(required = false) String ip) {
+        if (ip.isEmpty()){
+            return Result.error(ResultCode.PARAM_ERROR);
+        }
+        try {
+            // 调用工具类获取API响应
+            IpLocationVO ipLocationVo = ip2LocationClientService.getIpLocation(ip);
+            return Result.success(ResultCode.SUCCESS,ipLocationVo);
+        } catch (Exception e) {
+            // 异常处理：返回错误信息（实际项目建议封装统一响应格式）
+            return Result.error(ResultCode.SYSTEM_ERROR,e.getMessage());
+        }
+    }
+}

src/main/java/com/bao/dating/controller/PostController.java

@@ -13,6 +13,11 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
+/**
+ * 动态接口
+ *
+ * @author KilLze
+ */
 @RestController
 @RequestMapping("/posts")
 public class PostController {
@@ -28,7 +33,7 @@ public class PostController {
     @PostMapping(value = "/upload", consumes = "multipart/form-data")
     public Result<List<String>> uploadMedia(@RequestParam("files") MultipartFile[] files) {
         List<String> fileUrls = postService.uploadMedia(files);
-        return Result.success(ResultCode.SUCCESS_REVIEW, "文件上传成功", fileUrls);
+        return Result.success(ResultCode.SUCCESS, "文件上传成功", fileUrls);
     }
 
     /**
@@ -36,11 +41,11 @@ public class PostController {
      * @param postDTO 动态信息
      * @return 发布的动态对象
      */
-    @PostMapping(consumes = "application/json")
+    @PostMapping( "/createPost")
     public Result<Post> createPostJson(@RequestBody PostRequestDTO postDTO) {
         // 调用 Service 层处理发布动态业务逻辑
         Post result = postService.createPost(postDTO);
-        return Result.success(ResultCode.SUCCESS_REVIEW, "动态发布成功，等待审核。", result);
+        return Result.success(ResultCode.SUCCESS, "动态发布成功，等待审核。", result);
     }
 
     /**
@@ -49,8 +54,8 @@ public class PostController {
      * @param postIds 动态ID
      * @return 删除结果
      */
-    @DeleteMapping
-    public Result<String> deleteById(@RequestParam List<Long> postIds){
+    @PostMapping("/deletePost")
+    public Result<String> deleteById(@RequestBody List<Long> postIds){
         int deletedCount = postService.deletePostById(postIds);
         return Result.success(ResultCode.SUCCESS_DELETE, deletedCount > 0 ? "成功删除" : "删除失败，该动态不存在", null);
     }
@@ -60,7 +65,7 @@ public class PostController {
      * @param postId 动态ID
      * @return 动态对象
      */
-    @GetMapping("/{postId}")
+    @PostMapping("/{postId}")
     public Result<PostEditVO> getPostById(@PathVariable Long postId) {
         PostEditVO postEditVO = postService.getPostForEdit(postId);
         return Result.success(ResultCode.SUCCESS,"查询成功", postEditVO);
@@ -72,9 +77,9 @@ public class PostController {
      * @param postRequestDTO 动态信息
      * @return 更新后的动态对象
      */
-    @PutMapping("/{postId}")
+    @PostMapping("/{postId}/updatePost")
     public Result<PostEditVO> updatePost(@PathVariable Long postId, @RequestBody PostRequestDTO postRequestDTO) {
         PostEditVO result = postService.updatePost(postId, postRequestDTO);
-        return Result.success(ResultCode.SUCCESS_REVIEW, "动态更新成功", result);
+        return Result.success(ResultCode.SUCCESS, "动态更新成功", result);
     }
 }

src/main/java/com/bao/dating/controller/PostFavoriteController.java

@@ -3,10 +3,8 @@ package com.bao.dating.controller;
 import com.bao.dating.common.Result;
 import com.bao.dating.common.ResultCode;
 import com.bao.dating.pojo.entity.Post;
-import com.bao.dating.pojo.entity.PostFavorite;
 import com.bao.dating.pojo.entity.User;
 import com.bao.dating.service.PostFavoriteService;
-import com.bao.dating.service.PostService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -18,6 +16,13 @@ import java.util.Map;
 public class PostFavoriteController {
     @Autowired
     private PostFavoriteService postFavoriteService;
+
+    /**
+     * 收藏
+     * @param postId 动态ID
+     * @param user 当前登录用户对象
+     * @return 结果
+     */
     @PostMapping("/{post_id}/favorites")
     public Result<Map<String,Long>> addPostFavorite(@PathVariable("post_id")Long postId, User user){
         if (user == null){
@@ -26,6 +31,13 @@ public class PostFavoriteController {
         Long userId = user.getUserId();
         return postFavoriteService.postFavorite(userId,postId);
     }
+
+    /**
+     * 取消收藏
+     * @param postId 动态id
+     * @param user 登录用户
+     * @return 结果
+     */
     @DeleteMapping("/{post_id}/favorites")
     public Result<?> deletePostFavorite(@PathVariable("post_id")Long postId, User user){
         if (user == null){
@@ -34,11 +46,21 @@ public class PostFavoriteController {
         Long userId = user.getUserId();
         return postFavoriteService.deletePostFavorite(userId, postId);
     }
-    @GetMapping("/{user_id}/favorites")
-    public Result<List<Post>> getFavorites(@PathVariable("user_id")Long postId){
-        if (postId == null){
+
+    /**
+     * 展示所有收藏
+     * @param user 当前登录用户
+     * @return 结果
+     */
+    @GetMapping("/showFavorites")
+    public Result<List<Post>> showPostFavorites(@RequestBody User user){
+        //校验参数
+        if (user == null){
             return Result.error(ResultCode.PARAM_ERROR);
         }
-        return postFavoriteService.getAllFavoritePost(postId);
+        Long userId = user.getUserId();
+        List<Post> posts = postFavoriteService.selectAllFavorites(userId);
+        return Result.success(ResultCode.SUCCESS,posts);
     }
+
 }

src/main/java/com/bao/dating/controller/UserController.java

@@ -2,12 +2,22 @@ package com.bao.dating.controller;
 
 import com.bao.dating.common.Result;
 import com.bao.dating.common.ResultCode;
+import com.bao.dating.context.UserContext;
+import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
 import com.bao.dating.pojo.dto.UserLoginDTO;
+import com.bao.dating.pojo.vo.UserInfoVO;
 import com.bao.dating.pojo.vo.UserLoginVO;
 import com.bao.dating.service.UserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
+
+/**
+ * 用户接口
+ *
+ * @author KilLze
+ */
 @RestController
 @RequestMapping("/user")
 public class UserController {
@@ -26,23 +36,86 @@ public class UserController {
     }
 
     /**
-     * 用户注册
-     * @param userAccount 用户名称
-     * @param userPassword 用户密码
-     * @return 用户id
+     * 获取用户信息
+     * @return 用户信息
      */
-    @PostMapping("/userRegister")
-    public Result userRegister(String userAccount, String userPassword){
-        long result = userService.userRegister(userAccount, userPassword);
-        if (result == -1){
-            return Result.error(ResultCode.SYSTEM_ERROR);
+    @GetMapping("/info")
+    public Result<UserInfoVO> getUserInfo() {
+        Long userId = UserContext.getUserId();
+        UserInfoVO userInfoVO = userService.getUserInfo(userId);
+        return Result.success(ResultCode.SUCCESS, "获取用户信息成功", userInfoVO);
     }
-        if (result==-2){
+
+    /**
+     * 上传头像接口
+     * @param file 头像文件
+     * @return 上传后的文件URL列表
+     */
+    @PostMapping(value = "/info/uploadAvatar", consumes = "multipart/form-data")
+    public Result<String> uploadAvatar(@RequestParam("file") MultipartFile file) {
+        String fileUrl = userService.uploadAvatar(file);
+        return Result.success(ResultCode.SUCCESS, "头像上传成功", fileUrl);
+    }
+
+    /**
+     * 上传背景接口
+     * @param file 背景文件
+     * @return 上传后的文件URL列表
+     */
+    @PostMapping(value = "/info/uploadBackground", consumes = "multipart/form-data")
+    public Result<String> uploadBackground(@RequestParam("file") MultipartFile file) {
+        String fileUrl = userService.uploadBackground(file);
+        return Result.success(ResultCode.SUCCESS, "背景上传成功", fileUrl);
+    }
+
+    /**
+     * 更新用户信息
+     * @param userInfoUpdateDTO 用户信息更新参数
+     * @return 更新后的用户信息
+     */
+    @PostMapping("/info/update")
+    public Result<UserInfoVO> userInfoUpdate(@RequestBody UserInfoUpdateDTO userInfoUpdateDTO) {
+        Long userId = UserContext.getUserId();
+        userInfoUpdateDTO.setUserId(userId);
+        UserInfoVO userInfoVO =userService.updateUserInfo(userInfoUpdateDTO);
+        return Result.success(ResultCode.SUCCESS, "用户信息更新成功", userInfoVO);
+    }
+
+    /**
+     * 用户注册
+     * @param userName 用户名称
+     * @param userPassword 用户密码
+     * @return 返回
+     */
+    @PostMapping("/register")
+    public Result<?> userRegister(@RequestParam String userName , @RequestParam String userPassword){
+        //校验参数是否为空
+        if (userName.isEmpty() || userPassword.isEmpty()){
             return Result.error(ResultCode.PARAM_ERROR);
         }
-        if (result == -3){
-            return Result.error(ResultCode.FAIL,"用户名称相同");
+        if (!userService.registerUser(userName,userPassword)){
+            return Result.error(ResultCode.FAIL);
         }
-        return Result.success(ResultCode.SUCCESS,"注册成功",result);
+        return Result.success(ResultCode.SUCCESS,"用户注册成功",null);
     }
+
+    /**
+     * 通过邮箱登录
+     * @param email 邮箱
+     * @param code 验证码
+     * @return 用户信息
+     */
+    @PostMapping("/emailLogin")
+    public Result<UserLoginVO> emailLogin(@RequestParam String email , @RequestParam String code){
+        //校验参数是否为空
+        if (email.isEmpty() || code.isEmpty()){
+            return Result.error(ResultCode.PARAM_ERROR);
+        }
+        UserLoginVO userLoginVO = userService.emailLogin(email, code);
+        if (userLoginVO == null){
+            return Result.error(ResultCode.FAIL,"请先注册用户或添加邮箱");
+        }
+        return Result.success(ResultCode.SUCCESS,"用户登录成功",userLoginVO);
+    }
+
 }

src/main/java/com/bao/dating/controller/VerificationCodeController.java

@@ -0,0 +1,90 @@
+package com.bao.dating.controller;
+
+import com.bao.dating.common.Result;
+import com.bao.dating.common.ResultCode;
+import com.bao.dating.service.VerificationCodeService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 验证码控制器
+ * @author KilLze
+ */
+@Slf4j
+@RestController
+@RequestMapping("/api/verification")
+public class VerificationCodeController {
+
+    @Autowired
+    private VerificationCodeService verificationCodeService;
+
+    /**
+     * 发送邮箱验证码
+     * @param email 邮箱地址
+     * @return 结果
+     */
+    @PostMapping("/send-email-code")
+    public Result<String> sendEmailCode(@RequestParam String email) {
+        // 参数校验
+        if (!StringUtils.hasText(email)) {
+            return Result.error(ResultCode.PARAM_ERROR, "邮箱地址不能为空");
+        }
+        
+        // 简单的邮箱格式校验
+        if (!isValidEmail(email)) {
+            return Result.error(ResultCode.PARAM_ERROR, "邮箱格式不正确");
+        }
+        
+        // 发送验证码
+        boolean success = verificationCodeService.sendEmailCode(email);
+        
+        if (success) {
+            return Result.success(ResultCode.CODE_SENT, "验证码已发送到您的邮箱，请查收");
+        } else {
+            return Result.error(ResultCode.CODE_SEND_FAIL, "验证码发送失败，请稍后重试");
+        }
+    }
+
+    /**
+     * 验证邮箱验证码
+     * @param email 邮箱地址
+     * @param code 验证码
+     * @return 结果
+     */
+    @PostMapping("/verify-email-code")
+    public Result<String> verifyEmailCode(@RequestParam String email, @RequestParam String code) {
+        // 参数校验
+        if (!StringUtils.hasText(email)) {
+            return Result.error(ResultCode.PARAM_ERROR, "邮箱地址不能为空");
+        }
+        
+        if (!StringUtils.hasText(code)) {
+            return Result.error(ResultCode.PARAM_ERROR, "验证码不能为空");
+        }
+        
+        // 验证验证码
+        boolean success = verificationCodeService.verifyEmailCode(email, code);
+        
+        if (success) {
+            return Result.success(ResultCode.SUCCESS, "验证码验证成功");
+        } else {
+            return Result.error(ResultCode.CODE_ERROR, "验证码错误或已过期");
+        }
+    }
+
+    /**
+     * 简单的邮箱格式校验
+     * @param email 邮箱地址
+     * @return 是否有效
+     */
+    private boolean isValidEmail(String email) {
+        if (email == null || email.trim().isEmpty()) {
+            return false;
+        }
+        // 简单的邮箱格式校验：包含@和.
+        return email.contains("@") && email.contains(".") && email.length() > 5;
+    }
+}
+

src/main/java/com/bao/dating/controller/text.java

@@ -0,0 +1,4 @@
+package com.bao.dating.controller;
+
+public class text {
+}

src/main/java/com/bao/dating/handler/GlobalExceptionHandler.java

@@ -0,0 +1,109 @@
+package com.bao.dating.handler;
+
+import com.bao.dating.common.Result;
+import com.bao.dating.common.ResultCode;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.dao.DuplicateKeyException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.converter.HttpMessageNotReadableException;
+import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.MissingServletRequestParameterException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
+import org.springframework.web.servlet.NoHandlerFoundException;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * 全局异常处理器
+ * 统一处理控制器层抛出的异常
+ * @author KilLze
+ */
+@Slf4j
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+
+    /**
+     * 处理参数验证失败异常
+     */
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public Result<String> handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
+        log.error("参数验证失败: {}", e.getMessage());
+        return Result.error(ResultCode.PARAM_ERROR, e.getBindingResult().getFieldError().getDefaultMessage());
+    }
+
+    /**
+     * 处理请求参数缺失异常
+     */
+    @ExceptionHandler(MissingServletRequestParameterException.class)
+    public Result<String> handleMissingServletRequestParameterException(MissingServletRequestParameterException e) {
+        log.error("请求参数缺失: 参数名={}, 参数类型={}", e.getParameterName(), e.getParameterType());
+        return Result.error(ResultCode.PARAM_ERROR, "缺少必需的请求参数: " + e.getParameterName());
+    }
+
+    /**
+     * 处理请求参数类型不匹配异常
+     */
+    @ExceptionHandler(MethodArgumentTypeMismatchException.class)
+    public Result<String> handleMethodArgumentTypeMismatchException(MethodArgumentTypeMismatchException e) {
+        log.error("请求参数类型不匹配: {}", e.getMessage());
+        return Result.error(ResultCode.PARAM_ERROR, "请求参数类型错误: " + e.getName());
+    }
+
+    /**
+     * 处理请求体缺失或格式错误异常
+     */
+    @ExceptionHandler(HttpMessageNotReadableException.class)
+    public Result<String> handleHttpMessageNotReadableException(HttpMessageNotReadableException e) {
+        log.error("请求体格式错误: {}", e.getMessage());
+        return Result.error(ResultCode.PARAM_ERROR, "请求体格式错误或缺失");
+    }
+
+    /**
+     * 处理不支持的HTTP请求方法异常
+     */
+    @ExceptionHandler(HttpRequestMethodNotSupportedException.class)
+    public Result<String> handleHttpRequestMethodNotSupportedException(HttpRequestMethodNotSupportedException e) {
+        log.error("不支持的HTTP请求方法: {}", e.getMethod());
+        return Result.error(ResultCode.PARAM_ERROR, "不支持的请求方法: " + e.getMethod());
+    }
+
+    /**
+     * 处理404异常
+     */
+    @ExceptionHandler(NoHandlerFoundException.class)
+    public Result<String> handleNoHandlerFoundException(HttpServletRequest request, NoHandlerFoundException e) {
+        log.error("请求的接口不存在: {} {}", request.getMethod(), request.getRequestURI());
+        return Result.error(ResultCode.NOT_FOUND, "请求的接口不存在");
+    }
+
+    /**
+     * 处理数据库唯一约束违反异常
+     */
+    @ExceptionHandler(DuplicateKeyException.class)
+    public Result<String> handleDuplicateKeyException(DuplicateKeyException e) {
+        log.error("数据库唯一约束违反: {}", e.getMessage());
+        return Result.error(ResultCode.FAIL, "数据已存在，操作失败");
+    }
+
+    /**
+     * 处理运行时异常
+     */
+    @ExceptionHandler(RuntimeException.class)
+    public Result<String> handleRuntimeException(RuntimeException e) {
+        log.error("运行时异常: ", e);
+        return Result.error(ResultCode.SYSTEM_ERROR, e.getMessage());
+    }
+
+    /**
+     * 处理通用异常
+     */
+    @ExceptionHandler(Exception.class)
+    public Result<String> handleException(HttpServletRequest request, Exception e) {
+        log.error("系统异常 [{} {}]: ", request.getMethod(), request.getRequestURI(), e);
+        return Result.error(ResultCode.SYSTEM_ERROR, "系统内部错误");
+    }
+}

src/main/java/com/bao/dating/handler/ListToJsonTypeHandler.java

@@ -0,0 +1,69 @@
+package com.bao.dating.handler;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.ibatis.type.JdbcType;
+import org.apache.ibatis.type.MappedJdbcTypes;
+import org.apache.ibatis.type.MappedTypes;
+import org.apache.ibatis.type.TypeHandler;
+
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.List;
+
+
+/**
+ * List类型转换成JSON类型
+ * @author KilLze
+ */
+@MappedJdbcTypes(JdbcType.VARCHAR)
+@MappedTypes(List.class)
+public class ListToJsonTypeHandler implements TypeHandler<List<String>> {
+
+    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
+
+    @Override
+    public void setParameter(PreparedStatement ps, int i, List<String> parameter, JdbcType jdbcType) throws SQLException {
+        if (parameter == null || parameter.isEmpty()) {
+            ps.setNull(i, java.sql.Types.VARCHAR); // 或者 Types.JSON 如果数据库支持
+            return;
+        }
+        try {
+            String json = OBJECT_MAPPER.writeValueAsString(parameter);
+            ps.setString(i, json);
+        } catch (JsonProcessingException e) {
+            throw new SQLException("Error converting list to JSON", e);
+        }
+    }
+
+    @Override
+    public List<String> getResult(ResultSet rs, String columnName) throws SQLException {
+        String json = rs.getString(columnName);
+        return convertJsonToList(json);
+    }
+
+    @Override
+    public List<String> getResult(ResultSet rs, int columnIndex) throws SQLException {
+        String json = rs.getString(columnIndex);
+        return convertJsonToList(json);
+    }
+
+    @Override
+    public List<String> getResult(java.sql.CallableStatement cs, int columnIndex) throws SQLException {
+        String json = cs.getString(columnIndex);
+        return convertJsonToList(json);
+    }
+
+    private List<String> convertJsonToList(String json) throws SQLException {
+        if (json == null || json.isEmpty()) {
+            return null;
+        }
+        try {
+            return OBJECT_MAPPER.readValue(json, new TypeReference<List<String>>() {});
+        } catch (JsonProcessingException e) {
+            throw new SQLException("Error converting JSON to list", e);
+        }
+    }
+}

src/main/java/com/bao/dating/handler/ListToVarcharTypeHandler.java

@@ -6,10 +6,7 @@ import org.apache.ibatis.type.MappedJdbcTypes;
 import org.apache.ibatis.type.MappedTypes;
 import org.apache.ibatis.type.TypeHandler;
 
-import java.sql.CallableStatement;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
+import java.sql.*;
 import java.util.Arrays;
 import java.util.List;
 
@@ -22,6 +19,11 @@ import java.util.List;
 public class ListToVarcharTypeHandler implements TypeHandler<List<String>> {
     @Override
     public void setParameter(PreparedStatement preparedStatement, int i, List<String> strings, JdbcType jdbcType) throws SQLException {
+        // 允许 null
+        if (strings == null || strings.isEmpty()) {
+            preparedStatement.setNull(i, Types.VARCHAR);
+            return;
+        }
         // 遍历List类型的入参，拼装为String类型，使用Statement对象插入数据库
         StringBuffer sb = new StringBuffer();
         for (int j = 0; j < strings.size(); j++) {

src/main/java/com/bao/dating/interceptor/TokenInterceptor.java

@@ -5,7 +5,6 @@ import javax.servlet.http.HttpServletResponse;
 
 import com.bao.dating.context.UserContext;
 import com.bao.dating.util.JwtUtil;
-import io.jsonwebtoken.Claims;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.springframework.web.method.HandlerMethod;
@@ -14,6 +13,7 @@ import org.springframework.web.servlet.HandlerInterceptor;
 /**
  * HttpToken拦截器类
  * 用于拦截请求并验证JWT token的有效性，同时从token中解析用户信息
+ * @author KilLze
  */
 @Slf4j
 @Component
@@ -43,7 +43,7 @@ public class TokenInterceptor implements HandlerInterceptor {
             
             // 验证 token 是否有效（包括是否过期）
             if (!JwtUtil.validateToken(token)) {
-                log.error("Token 无效或已过期");
+                log.error("Token无效或已过期");
                 response.setStatus(401);
                 return false;
             }

src/main/java/com/bao/dating/mapper/ContactMapper.java

@@ -0,0 +1,20 @@
+package com.bao.dating.mapper;
+
+import com.bao.dating.pojo.entity.Contacts;
+import com.bao.dating.pojo.entity.User;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface ContactMapper {
+    /**
+     * 根据用户ID查询好友列表（仅正常状态、非黑名单的好友）
+     * @param userId 当前用户ID
+     * @return 好友列表（包含联系人+用户基础信息）
+     */
+    List<Map<String, Object>> selectFriendsByUserId(@Param("userId") Long userId);
+
+}

src/main/java/com/bao/dating/mapper/FriendRelationMapper.java

@@ -0,0 +1,61 @@
+package com.bao.dating.mapper;
+
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FriendRelationMapper {
+    /**
+     * 插入好友申请
+     * @param params 申请参数（匹配friend_apply表字段）
+     */
+    void insertFriendApply(Map<String, Object> params);
+
+    /**
+     * 根据申请人ID和被申请人ID查询好友申请
+     * @param applyUserId 申请人ID
+     * @param targetUserId 被申请人ID
+     * @return 好友申请记录
+     */
+    Map<String, Object> selectFriendApplyByUsers(@Param("applyUserId") Long applyUserId, @Param("targetUserId") Long targetUserId);
+
+    /**
+     * 更新好友申请状态
+     * @param params 更新参数
+     */
+    void updateFriendApplyStatus(Map<String, Object> params);
+
+    /**
+     * 删除好友申请（可选）
+     * @param params 删除条件
+     */
+    void deleteFriendApply(Map<String, Object> params);
+
+    /**
+     * 查询待处理的好友申请
+     * @param targetUserId 被申请人ID
+     * @return 申请列表
+     */
+    List<Map<String, Object>> selectFriendApplyList(@Param("targetUserId") Long targetUserId);
+
+    /**
+     * 插入联系人记录
+     * @param params 插入参数（匹配contacts表字段）
+     */
+    void insertFriendRelation(Map<String, Object> params);
+
+    /**
+     * 根据用户ID查询联系人列表
+     * @param userId 用户ID
+     * @return 联系人列表
+     */
+    List<Map<String, Object>> selectFriendRelationListByUserId(@Param("userId") Long userId);
+
+    /**
+     * 删除过期的好友申请
+     * @param days 过期天数
+     * @return 删除的记录数
+     */
+    int deleteExpiredFriendApply(@Param("days") Integer days);
+}

src/main/java/com/bao/dating/mapper/PostFavoriteMapper.java

@@ -11,7 +11,10 @@ import java.util.List;
 public interface PostFavoriteMapper {
     //查询当前已收藏所有用户
     List<Long> selectUserIDByPostID(@Param("postId") Long postId);
+    //添加收藏
     int addPostFavorite(PostFavorite postFavorite);
+    //删除收藏
     int deletePostFavorite(@Param("postId") Long postId);
-    List<Post> getAllPost(@Param("userId") Long userId);
+    //查询用户所有收藏
+    List<Post> showAllFavorites(@Param("userid")Long userid);
 }

src/main/java/com/bao/dating/mapper/PostMapper.java

@@ -6,12 +6,17 @@ import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
+/**
+ * 动态Mapper
+ *
+ * @author KilLze lanyangyang-yzx
+ */
 @Mapper
 public interface PostMapper {
     /**
      * 插入动态
      *
-     * @param post
+     * @param post 动态
      */
     void insert(Post post);
 
@@ -20,29 +25,49 @@ public interface PostMapper {
      *
      * @param postIds 动态ID
      */
-    int deletePostByIds(@Param("postIds") List<Long> postIds);
+    int deletePostByIds(List<Long> postIds);
+    
+    /**
+     * 根据动态ID删除收藏记录
+     *
+     * @param postId 动态ID
+     */
+    int deletePostFavoriteByPostId(Long postId);
+    
+    /**
+     * 根据动态ID删除点赞记录
+     *
+     * @param postId 动态ID
+     */
+    int deletePostLikeByPostId(Long postId);
+    
+    /**
+     * 根据动态ID删除评论记录
+     *
+     * @param postId 动态ID
+     */
+    int deleteCommentsByPostId(Long postId);
 
     /**
      * 根据ID查询动态
      *
-     * @param postId
-     * @return
+     * @param postId 动态ID
+     * @return 动态
      */
-    Post selectById(@Param("postId") Long postId);
+    Post selectById(Long postId);
 
     /**
      * 根据ID更新动态
      *
-     * @param post
-     * @return
+     * @param post 动态
      */
     void updateById(Post post);
 
     /**
      * 查询点赞数
      *
-     * @param postId
-     * @return
+     * @param postId 动态ID
+     * @return 点赞数
      */
     int selectLikeCount(Long postId);
 
@@ -72,8 +97,8 @@ public interface PostMapper {
     /**
      * 查询点赞数
      *
-     * @param postId
-     * @return
+     * @param postId 动态ID
+     * @return 点赞数
      */
     int selectFavoriteCount(Long postId);
 

src/main/java/com/bao/dating/mapper/UserMapper.java

@@ -1,8 +1,14 @@
 package com.bao.dating.mapper;
 
+import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
 import com.bao.dating.pojo.entity.User;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
+/**
+ * 用户Mapper
+ * @author KilLze
+ */
 @Mapper
 public interface UserMapper {
 
@@ -14,11 +20,38 @@ public interface UserMapper {
      */
     User getByUsername(String username);
 
+    /**
+     * 根据用户id查询用户信息
+     *
+     * @param userid 用户id
+     * @return 用户
+     */
+    User selectByUserId(Long userid);
+
+    /**
+     * 更新用户信息
+     * @param userInfoUpdateDTO 用户信息更新参数
+     */
+    void updateUserInfoByUserId(UserInfoUpdateDTO userInfoUpdateDTO);
+
     /**
      * 添加用户
      * @param user 用户对象
      * @return 受影响行数
      */
-    Long insertUser(User user);
-    long getMaxUserId();
+    int saveUser(User user);
+
+    /**
+     * 查询最大用户id
+     * @return 用户id
+     */
+    Long selectMaxId();
+
+    /**
+     * 根据邮箱查询用户
+     * @param email 用户邮箱
+     * @return 用户信息
+     */
+    User selectByUserEmailUser(@Param("userEmail") String email);
+
 }

src/main/java/com/bao/dating/pojo/dto/PostRequestDTO.java

@@ -7,9 +7,10 @@ import java.util.List;
 
 /**
  * 动态数据传输对象
+ * @author KilLze
  */
 @Data
-public class PostRequestDTO implements Serializable {
+public class PostRequestDTO implements Serializable{
     private String content;
     private List<String> mediaOssKeys;
     private List<String> tags;

src/main/java/com/bao/dating/pojo/dto/UserInfoUpdateDTO.java

@@ -0,0 +1,25 @@
+package com.bao.dating.pojo.dto;
+
+import lombok.Data;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 用户信息更新数据传输对象
+ * @author KilLze
+ */
+@Data
+public class UserInfoUpdateDTO {
+    private Long userId;
+    private String userName;
+    private String nickname;
+    private String avatarUrl;
+    private String backgroundUrl;
+    private Integer gender;
+    private LocalDate birthday;
+    private List<String> hobbies;
+    private String signature;
+    private LocalDateTime updatedAt;
+}

src/main/java/com/bao/dating/pojo/dto/UserLoginDTO.java

@@ -6,6 +6,7 @@ import java.io.Serializable;
 
 /**
  * 用户登录数据传输对象
+ * @author KilLze
  */
 @Data
 public class UserLoginDTO implements Serializable {

src/main/java/com/bao/dating/pojo/entity/Contacts.java

@@ -0,0 +1,24 @@
+package com.bao.dating.pojo.entity;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.Date;
+import java.util.List;
+
+@Data
+public class Contacts {
+    private Long contactId;         // 通讯录记录ID
+    private Long userId;            // 当前用户ID
+    private Long contactUserId;     // 联系人用户ID
+    private String contactNickname; // 联系人备注名
+    private String contactAvatar;   // 联系人头像缓存
+    private Integer relationType;   // 关系类型（1普通好友/2特别关注/3黑名单/4陌生人）
+    private Date addTime;           // 添加时间
+    private Date lastChatTime;      // 最后聊天时间
+    private Integer contactStatus;  // 联系人状态（1正常/2已删除/3已拉黑）
+    private String contactRemark;   // 备注信息
+    private List<String> tags;      // 标签（JSON数组）
+    private Date createdAt;         // 创建时间
+    private Date updatedAt;         // 更新时间
+}

src/main/java/com/bao/dating/pojo/entity/FriendApply.java

@@ -0,0 +1,60 @@
+package com.bao.dating.pojo.entity;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 好友申请实体类
+ * @author KilLze
+ */
+@Data
+public class FriendApply {
+    /**
+     * 申请ID，主键
+     * 对应字段：apply_id
+     */
+    private Long applyId;
+
+    /**
+     * 申请人ID（对应user表user_id）
+     * 对应字段：apply_user_id
+     */
+    private Long applyUserId;
+
+    /**
+     * 被申请人ID（对应user表user_id）
+     * 对应字段：target_user_id
+     */
+    private Long targetUserId;
+
+    /**
+     * 打招呼内容
+     * 对应字段：greeting
+     */
+    private String greeting;
+
+    /**
+     * 申请时间
+     * 对应字段：apply_time
+     */
+    private Date applyTime;
+
+    /**
+     * 申请状态：0-待处理，1-已同意，2-已拒绝
+     * 对应字段：apply_status
+     */
+    private Byte applyStatus;
+
+    /**
+     * 创建时间
+     * 对应字段：created_at
+     */
+    private Date createdAt;
+
+    /**
+     * 更新时间
+     * 对应字段：updated_at
+     */
+    private Date updatedAt;
+}

src/main/java/com/bao/dating/pojo/entity/User.java

@@ -5,6 +5,7 @@ import lombok.Data;
 import java.io.Serializable;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * 用户表
@@ -31,7 +32,7 @@ public class User implements Serializable {
 
     private LocalDate birthday;
 
-    private String hobbies;
+    private List<String> hobbies;
 
     private String signature;
 

src/main/java/com/bao/dating/pojo/vo/IpLocationVO.java

@@ -0,0 +1,30 @@
+package com.bao.dating.pojo.vo;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class IpLocationVO {
+    // 国家
+    @JsonProperty("country_name")
+    private String countryName;
+    // 省份/地区
+    @JsonProperty("region_name")
+    private String regionName;
+    // 城市
+    @JsonProperty("city_name")
+    private String cityName;
+    // 纬度
+    private String latitude;
+    // 经度
+    private String longitude;
+    // ISP运营商
+    @JsonProperty("isp")
+    private String isp;
+}

src/main/java/com/bao/dating/pojo/vo/PostEditVO.java

@@ -8,6 +8,7 @@ import java.util.List;
 
 /**
  * 修改内容查询返回数据
+ * @author KilLze
  */
 @Data
 public class PostEditVO implements Serializable {

src/main/java/com/bao/dating/pojo/vo/UserInfoVO.java

@@ -0,0 +1,27 @@
+package com.bao.dating.pojo.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 用户信息VO
+ * @author KilLze
+ */
+@Data
+public class UserInfoVO implements Serializable {
+    private Long userId;
+    private String userName;
+    private String nickname;
+    private String avatarUrl;
+    private String backgroundUrl;
+    private Integer gender;
+    private LocalDate birthday;
+    private List<String> hobbies;
+    private String signature;
+    private LocalDateTime updatedAt;
+    private LocalDateTime createdAt;
+}

src/main/java/com/bao/dating/pojo/vo/UserLoginVO.java

@@ -5,6 +5,7 @@ import java.io.Serializable;
 
 /**
  * 登录返回数据
+ * @author KilLze
  */
 @Data
 public class UserLoginVO implements Serializable {

src/main/java/com/bao/dating/service/ContactsService.java

@@ -0,0 +1,20 @@
+package com.bao.dating.service;
+
+
+import com.bao.dating.pojo.entity.User;
+
+import java.util.List;
+import java.util.Map;
+
+public interface ContactsService {
+    /**
+     * 根据用户ID查询好友列表
+     * @param userId 用户ID
+     * @return 好友列表
+     */
+    List<Map<String, Object>> getFriendsByUserId(Long userId);
+
+
+
+}
+

src/main/java/com/bao/dating/service/FriendRelationService.java

@@ -0,0 +1,43 @@
+package com.bao.dating.service;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FriendRelationService {
+    /**
+     * 新增好友申请
+     * @param applyUserId 申请人ID
+     * @param targetUserId 被申请人ID
+     * @param greeting 打招呼内容
+     */
+    void addFriendApply(Long applyUserId, Long targetUserId, String greeting);
+
+    /**
+     * 同意好友申请（更新状态/删除记录）
+     * @param applyUserId 申请人ID
+     * @param targetUserId 被申请人ID
+     */
+    void agreeFriendApply(Long applyUserId, Long targetUserId);
+
+    /**
+     * 查询待处理的好友申请
+     * @param targetUserId 被申请人ID
+     * @return 申请列表
+     */
+    List<Map<String, Object>> getFriendApplyList(Long targetUserId);
+
+    /**
+     * 添加好友到通讯录表
+     * @param userId 当前用户ID
+     * @param contactUserId 联系人ID
+     * @param contactNickname 备注名
+     */
+    void addFriendRelation(Long userId, Long contactUserId, String contactNickname);
+
+    /**
+     * 查询用户的联系人列表
+     * @param userId 当前用户ID
+     * @return 联系人列表
+     */
+    List<Map<String, Object>> getFriendRelationList(Long userId);
+}

src/main/java/com/bao/dating/service/Ip2LocationClientService.java

@@ -0,0 +1,7 @@
+package com.bao.dating.service;
+
+import com.bao.dating.pojo.vo.IpLocationVO;
+
+public interface Ip2LocationClientService {
+    IpLocationVO getIpLocation(String ip)throws Exception;
+}

src/main/java/com/bao/dating/service/PostFavoriteService.java

@@ -9,5 +9,5 @@ import java.util.Map;
 public interface PostFavoriteService {
     Result<Map<String,Long>> postFavorite(Long userid,Long postId);
     Result<?> deletePostFavorite(Long userid,Long postId);
-    Result<List<Post>> getAllFavoritePost(Long userId);
+    List<Post> selectAllFavorites(Long userid);
 }

src/main/java/com/bao/dating/service/PostService.java

@@ -7,6 +7,10 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
+/**
+ * 动态服务
+ * @author bao KilLze lanyangyang-yzx yang
+ */
 public interface PostService {
     /**
      * 上传媒体文件
@@ -33,6 +37,7 @@ public interface PostService {
     /**
      * 查询动态详情（用于编辑）
      * @param postId 动态ID
+     * @return 动态详情
      */
     PostEditVO getPostForEdit(Long postId);
 

src/main/java/com/bao/dating/service/UserService.java

@@ -1,8 +1,16 @@
 package com.bao.dating.service;
 
+import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
 import com.bao.dating.pojo.dto.UserLoginDTO;
+import com.bao.dating.pojo.entity.User;
+import com.bao.dating.pojo.vo.UserInfoVO;
 import com.bao.dating.pojo.vo.UserLoginVO;
+import org.springframework.web.multipart.MultipartFile;
 
+/**
+ * 用户服务接口
+ * @author KilLze
+ */
 public interface UserService {
     /**
      * 登录
@@ -10,5 +18,47 @@ public interface UserService {
      * @return 登录结果
      */
     UserLoginVO userLogin(UserLoginDTO userLoginDTO);
-    long userRegister(String userAccount, String userPassword);
+
+    /**
+     * 查询个人信息
+     * @param userId 动态ID
+     * @return 个人信息
+     */
+    UserInfoVO getUserInfo(Long userId);
+
+    /**
+     * 上传头像
+     * @param file 头像文件
+     * @return 上传后的文件URL列表
+     */
+    String uploadAvatar(MultipartFile file);
+
+    /**
+     * 上传背景
+     * @param file 背景文件
+     * @return 上传后的文件URL列表
+     */
+    String uploadBackground(MultipartFile file);
+
+    /**
+     * 更新用户信息
+     * @param userInfoUpdateDTO 用户信息
+     * @return 更新后的用户信息
+     */
+    UserInfoVO updateUserInfo(UserInfoUpdateDTO userInfoUpdateDTO);
+
+    /**
+     * 用户注册
+     * @param userName 用户民称
+     * @return 用户信息
+     */
+    Boolean registerUser(String userName,String userPassword);
+
+    /**
+     * 邮箱登录
+     * @param email 邮箱
+     * @param code 验证码
+     * @return
+     */
+    UserLoginVO emailLogin(String email , String code);
 }

src/main/java/com/bao/dating/service/VerificationCodeService.java

@@ -0,0 +1,31 @@
+package com.bao.dating.service;
+
+/**
+ * 验证码服务接口
+ * @author KilLze
+ */
+public interface VerificationCodeService {
+    
+    /**
+     * 发送邮箱验证码
+     * @param email 邮箱地址
+     * @return 是否发送成功
+     */
+    boolean sendEmailCode(String email);
+    
+    /**
+     * 验证邮箱验证码
+     * @param email 邮箱地址
+     * @param code 验证码
+     * @return 是否验证成功
+     */
+    boolean verifyEmailCode(String email, String code);
+    
+    /**
+     * 生成验证码
+     * @param length 验证码长度（默认6位）
+     * @return 验证码字符串
+     */
+    String generateCode(int length);
+}
+

src/main/java/com/bao/dating/service/impl/ContactServiceImpl.java

@@ -0,0 +1,22 @@
+package com.bao.dating.service.impl;
+
+import com.bao.dating.mapper.ContactMapper;
+import com.bao.dating.service.ContactsService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class ContactServiceImpl implements ContactsService {
+    @Autowired
+    private ContactMapper contactMapper;
+
+    @Override
+    public List<Map<String, Object>> getFriendsByUserId(Long userId) {
+        // 直接调用Mapper查询，无额外封装
+        return contactMapper.selectFriendsByUserId(userId);
+    }
+}

src/main/java/com/bao/dating/service/impl/FriendRelationServiceImpl.java

@@ -0,0 +1,81 @@
+package com.bao.dating.service.impl;
+
+import com.bao.dating.mapper.FriendRelationMapper;
+import com.bao.dating.service.FriendRelationService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class FriendRelationServiceImpl implements FriendRelationService {
+
+    @Autowired
+    private FriendRelationMapper friendRelationMapper;
+
+    /**
+     * 新增好友申请（写入数据库）
+     */
+    @Override
+    public void addFriendApply(Long applyUserId, Long targetUserId, String greeting) {
+        // 检查是否已存在待处理的申请
+        Map<String, Object> existingApply = friendRelationMapper.selectFriendApplyByUsers(applyUserId, targetUserId);
+        if (existingApply != null) {
+            throw new RuntimeException("好友申请已存在，请勿重复发送");
+        }
+        
+        Map<String, Object> params = new HashMap<>();
+        params.put("apply_user_id", applyUserId);
+        params.put("target_user_id", targetUserId);
+        params.put("greeting", greeting);
+        friendRelationMapper.insertFriendApply(params);
+    }
+
+    /**
+     * 同意好友申请（更新状态为已同意，也可直接删除）
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void agreeFriendApply(Long applyUserId, Long targetUserId) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("apply_user_id", applyUserId);
+        params.put("target_user_id", targetUserId);
+        params.put("apply_status", 1); // 1-已同意
+        friendRelationMapper.updateFriendApplyStatus(params);
+        // 也可选择直接删除申请记录：friendRelationMapper.deleteFriendApply(params);
+    }
+
+    /**
+     * 查询待处理的好友申请
+     */
+    @Override
+    public List<Map<String, Object>> getFriendApplyList(Long targetUserId) {
+        return friendRelationMapper.selectFriendApplyList(targetUserId);
+    }
+
+    /**
+     * 添加好友到通讯录表（严格匹配contacts表字段）
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void addFriendRelation(Long userId, Long contactUserId, String contactNickname) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("user_id", userId);
+        params.put("contact_user_id", contactUserId);
+        params.put("contact_nickname", contactNickname);
+        params.put("relation_type", 1); // 1-普通好友
+        params.put("contact_status", 1); // 1-正常
+        friendRelationMapper.insertFriendRelation(params);
+    }
+
+    /**
+     * 查询用户的联系人列表
+     */
+    @Override
+    public List<Map<String, Object>> getFriendRelationList(Long userId) {
+        return friendRelationMapper.selectFriendRelationListByUserId(userId);
+    }
+}

src/main/java/com/bao/dating/service/impl/Ip2LocationClientServiceImpl.java

@@ -0,0 +1,67 @@
+package com.bao.dating.service.impl;
+
+import com.bao.dating.common.ip2location.Ip2LocationConfig;
+import com.bao.dating.pojo.vo.IpLocationVO;
+import com.bao.dating.service.Ip2LocationClientService;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+import java.net.URI;
+
+@Service
+public class Ip2LocationClientServiceImpl implements Ip2LocationClientService {
+    @Autowired
+    private Ip2LocationConfig ip2LocationConfig;
+
+    // Jackson的ObjectMapper，用于JSON解析
+    private final ObjectMapper objectMapper = new ObjectMapper();
+
+    /**
+     * 调用API并只返回核心位置信息
+     * @param ip 要查询的IP地址
+     * @return 精简的位置信息实体类
+     * @throws Exception 异常
+     */
+    @Override
+    public IpLocationVO getIpLocation(String ip) throws Exception {
+        // 1. 构建请求URL
+        URIBuilder uriBuilder = new URIBuilder(ip2LocationConfig.getUrl());
+        uriBuilder.addParameter("key", ip2LocationConfig.getKey());
+        if (ip != null && !ip.trim().isEmpty()) {
+            uriBuilder.addParameter("ip", ip);
+        }
+        URI uri = uriBuilder.build();
+
+        // 2. 配置超时时间（逻辑和之前一致）
+        RequestConfig requestConfig = RequestConfig.custom()
+                .setConnectTimeout(ip2LocationConfig.getTimeout())
+                .setSocketTimeout(ip2LocationConfig.getTimeout())
+                .build();
+
+        // 3. 发送请求并解析响应
+        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
+            HttpGet httpGet = new HttpGet(uri);
+            httpGet.setConfig(requestConfig);
+
+            try (CloseableHttpResponse response = httpClient.execute(httpGet)) {
+                if (response.getStatusLine().getStatusCode() == 200) {
+                    String jsonStr = EntityUtils.toString(response.getEntity(), "UTF-8");
+                    // 核心：将完整JSON解析为只包含位置信息的VO类
+                    return objectMapper.readValue(jsonStr, IpLocationVO.class);
+                } else {
+                    throw new RuntimeException("调用API失败，状态码：" + response.getStatusLine().getStatusCode());
+                }
+            }
+        }
+    }
+
+}

src/main/java/com/bao/dating/service/impl/PostFavoriteServiceImpl.java

@@ -60,9 +60,17 @@ public class PostFavoriteServiceImpl implements PostFavoriteService {
         return null;
     }
 
+    /**
+     * 展示所有收藏
+     * @param userid 用户id
+     * @return 查询到的结果
+     */
+
     @Override
-    public Result<List<Post>> getAllFavoritePost(Long userId) {
-        List<Post> result = postFavoriteMapper.getAllPost(userId);
-        return Result.success(ResultCode.SUCCESS,"查询成功",result);
+    public List<Post> selectAllFavorites(Long userid) {
+        if (userid == null){
+            return null;
+        }
+        return postFavoriteMapper.showAllFavorites(userid);
     }
 }

src/main/java/com/bao/dating/service/impl/PostServiceImpl.java

@@ -2,6 +2,7 @@ package com.bao.dating.service.impl;
 
 import com.bao.dating.common.aliyun.GreenImageScan;
 import com.bao.dating.common.aliyun.GreenTextScan;
+import com.bao.dating.common.result.GreenAuditResult;
 import com.bao.dating.context.UserContext;
 import com.bao.dating.mapper.PostMapper;
 import com.bao.dating.pojo.dto.PostRequestDTO;
@@ -20,15 +21,12 @@ import java.io.IOException;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
+import java.util.*;
 
 /**
  * 动态服务实现类
  *
- * @author KilLze
+ * @author KilLze yang
  */
 @Service
 public class PostServiceImpl implements PostService {
@@ -52,32 +50,53 @@ public class PostServiceImpl implements PostService {
      */
     @Override
     public List<String> uploadMedia(MultipartFile[] files) {
+        // 如果没有文件，则返回空列表
+        if (files == null || files.length == 0) {
+            return Collections.emptyList();
+        }
+        // 创建媒体文件列表
         List<String> mediaUrls = new ArrayList<>();
-        if (files != null && files.length > 0) {
+
             for (MultipartFile file : files) {
-                if (!file.isEmpty()) {
-                    try {
-                        // 根据文件扩展名判断文件类型
-                        String fileType = FileUtil.getFileType(file.getOriginalFilename());
+                // 跳过空文件
+                if (file == null || file.isEmpty()) {
+                    continue;
+                }
+                // 获取文件名并跳过空文件
+                String originalFilename = file.getOriginalFilename();
+                if (originalFilename == null) {
+                    continue;
+                }
+                // 校验文件类型
+                String fileType = FileUtil.getFileType(originalFilename);
+                if (!"image".equals(fileType) && !"video".equals(fileType)) {
+                    throw new RuntimeException("不支持的文件类型：" + originalFilename);
+                }
+
                 // 创建目录
                 String dir = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM"));
+                // 获取文件扩展名
+                String extension = FileUtil.getFileExtension(originalFilename);
                 // 生成唯一文件名
-                        String newFileName = UUID.randomUUID().toString() + "." + FileUtil.getFileExtension(file.getOriginalFilename());
-                        String fileName = "post/" + dir + "/" + newFileName;
+                String newFileName = UUID.randomUUID().toString().replace("-", "") + "." + extension;
+                // 获取用户ID
+                Long userId = UserContext.getUserId();
+                // 创建文件名
+                String fileName = "post/" + userId + "/" + dir + "/" + newFileName;
+
+                    try {
                         // 获取文件字节数据
                         byte[] fileBytes = file.getBytes();
-                        // 根据文件类型处理
-                        String ossUrl = "";
-                        if ("image".equals(fileType) || "video".equals(fileType)) {
                         // 上传图片或视频
-                            ossUrl = ossUtil.upload(fileBytes, fileName);
+                        String ossUrl = ossUtil.upload(fileBytes, fileName);
+                        if (ossUrl == null || ossUrl.isEmpty()) {
+                            throw new RuntimeException("文件上传失败：" + originalFilename);
                         }
                         // 添加上传后的 URL
                         mediaUrls.add(ossUrl);
                     } catch (IOException e) {
-                        e.printStackTrace();
-                    }
-                }
+                        // 统一异常处理
+                        throw new RuntimeException("上传媒体文件失败：" + originalFilename, e);
                     }
                 }
         return mediaUrls;
@@ -126,10 +145,10 @@ public class PostServiceImpl implements PostService {
             String imageSuggestion = (String) imageResult.get("suggestion");
 
             // 根据审核结果设置状态
-            if ("block".equals(textSuggestion) || "block".equals(imageSuggestion)) {
+            if (GreenAuditResult.BLOCK.equals(textSuggestion) || GreenAuditResult.BLOCK.equals(imageSuggestion)) {
                 // 审核未通过，允许用户修改
                 post.setIsPublic(2);
-            } else if ("review".equals(textSuggestion) || "review".equals(imageSuggestion)) {
+            } else if (GreenAuditResult.REVIEW.equals(textSuggestion) || GreenAuditResult.REVIEW.equals(imageSuggestion)) {
                 // 待审核，需人工审核
                 post.setIsPublic(1);
             } else {
@@ -138,10 +157,10 @@ public class PostServiceImpl implements PostService {
             }
         } else {
             // 只有文本内容的情况
-            if ("block".equals(textSuggestion)) {
+            if (GreenAuditResult.BLOCK.equals(textSuggestion)) {
                 // 审核未通过，允许用户修改
                 post.setIsPublic(2);
-            } else if ("review".equals(textSuggestion)) {
+            } else if (GreenAuditResult.REVIEW.equals(textSuggestion)) {
                 // 待审核，需人工审核
                 post.setIsPublic(1);
             } else {
@@ -169,7 +188,7 @@ public class PostServiceImpl implements PostService {
         // 判断用户权限
         Long userId = UserContext.getUserId();
 
-        // 遍历所有要删除的帖子ID，验证权限
+        // 遍历所有要删除的帖子ID，验证权限并删除相关记录
         for (Long postId : postIds) {
             Post post = postMapper.selectById(postId);
             if (post == null) {
@@ -179,6 +198,12 @@ public class PostServiceImpl implements PostService {
             if (post.getUserId() == null || !post.getUserId().equals(userId)) {
                 throw new RuntimeException("无权限删除此动态");
             }
+            // 删除相关的收藏记录
+            postMapper.deletePostFavoriteByPostId(postId);
+            // 删除相关的点赞记录
+            postMapper.deletePostLikeByPostId(postId);
+            // 删除相关的评论记录
+            postMapper.deleteCommentsByPostId(postId);
         }
         // 批量删除动态
         return postMapper.deletePostByIds(postIds);
@@ -188,7 +213,7 @@ public class PostServiceImpl implements PostService {
      * 查询动态详情（用于编辑）
      *
      * @param postId 动态ID
-     * @return
+     * @return 动态详情
      */
     @Override
     public PostEditVO getPostForEdit(Long postId) {
@@ -210,7 +235,7 @@ public class PostServiceImpl implements PostService {
      * 修改动态
      * @param postId 动态ID
      * @param postRequestDTO 修改的动态数据传输对象
-     * @return
+     * @return 修改的动态对象
      */
     @Override
     public PostEditVO updatePost(Long postId, PostRequestDTO postRequestDTO) {
@@ -225,9 +250,8 @@ public class PostServiceImpl implements PostService {
             throw new RuntimeException("无权限修改此动态");
         }
         post.setContent(postRequestDTO.getContent());
-        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
+        // 如果请求中的mediaOssKeys不为null（即使是空列表），则更新为新值
         post.setMediaOssKeys(postRequestDTO.getMediaOssKeys());
-        }
 
         // 1. 文本内容审核
         Map textResult;
@@ -239,11 +263,11 @@ public class PostServiceImpl implements PostService {
         // 文本审核结果
         String textSuggestion = (String) textResult.get("suggestion");
 
-        // 2. 图片审核（如果有）
-        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
+        // 2. 图片审核（如果有媒体文件）
+        if (post.getMediaOssKeys() != null && !post.getMediaOssKeys().isEmpty()) {
             Map imageResult;
             try {
-                imageResult = greenImageScan.imageScan(postRequestDTO.getMediaOssKeys());
+                imageResult = greenImageScan.imageScan(post.getMediaOssKeys());
             } catch (Exception e) {
                 throw new RuntimeException(e);
             }
@@ -251,10 +275,10 @@ public class PostServiceImpl implements PostService {
             String imageSuggestion = (String) imageResult.get("suggestion");
 
             // 根据审核结果设置状态
-            if ("block".equals(textSuggestion) || "block".equals(imageSuggestion)) {
+            if (GreenAuditResult.BLOCK.equals(textSuggestion) || GreenAuditResult.BLOCK.equals(imageSuggestion)) {
                 // 审核未通过，允许用户修改
                 post.setIsPublic(2);
-            } else if ("review".equals(textSuggestion) || "review".equals(imageSuggestion)) {
+            } else if (GreenAuditResult.REVIEW.equals(textSuggestion) || GreenAuditResult.REVIEW.equals(imageSuggestion)) {
                 // 待审核，需人工审核
                 post.setIsPublic(1);
             } else {
@@ -263,10 +287,10 @@ public class PostServiceImpl implements PostService {
             }
         } else {
             // 只有文本内容的情况
-            if ("block".equals(textSuggestion)) {
+            if (GreenAuditResult.BLOCK.equals(textSuggestion)) {
                 // 审核未通过，允许用户修改
                 post.setIsPublic(2);
-            } else if ("review".equals(textSuggestion)) {
+            } else if (GreenAuditResult.REVIEW.equals(textSuggestion)) {
                 // 待审核，需人工审核
                 post.setIsPublic(1);
             } else {

src/main/java/com/bao/dating/service/impl/UserServiceImpl.java

@@ -1,23 +1,65 @@
 package com.bao.dating.service.impl;
 
+import com.bao.dating.common.Result;
+import com.bao.dating.common.ResultCode;
+import com.bao.dating.common.aliyun.AliOssUtil;
+import com.bao.dating.common.aliyun.GreenImageScan;
+import com.bao.dating.common.aliyun.GreenTextScan;
+import com.bao.dating.common.result.AliOssResult;
+import com.bao.dating.common.result.GreenAuditResult;
+import com.bao.dating.context.UserContext;
 import com.bao.dating.mapper.UserMapper;
+import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
 import com.bao.dating.pojo.dto.UserLoginDTO;
 import com.bao.dating.pojo.entity.User;
+import com.bao.dating.pojo.vo.UserInfoVO;
 import com.bao.dating.pojo.vo.UserLoginVO;
 import com.bao.dating.service.UserService;
+import com.bao.dating.service.VerificationCodeService;
+import com.bao.dating.util.FileUtil;
 import com.bao.dating.util.JwtUtil;
 import com.bao.dating.util.MD5Util;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
 
+/**
+ * 用户服务实现类
+ *
+ * @author KilLze
+ */
 @Service
 public class UserServiceImpl implements UserService {
 
+    @Autowired
+    private AliOssUtil ossUtil;
+
+    @Autowired
+    private GreenTextScan greenTextScan;
+
+    @Autowired
+    private GreenImageScan greenImageScan;
+
     @Autowired
     private UserMapper userMapper;
 
+    @Autowired
+    private VerificationCodeService verificationCodeService;
+
+    /**
+     * 用户登录
+     *
+     * @param userLoginDTO 登录参数
+     * @return 登录信息
+     */
     @Override
     public UserLoginVO userLogin(UserLoginDTO userLoginDTO) {
         // 参数校验
@@ -26,7 +68,7 @@ public class UserServiceImpl implements UserService {
         }
         // 查询用户
         User user = userMapper.getByUsername(userLoginDTO.getUsername());
-        if (user == null){
+        if (user == null) {
             throw new RuntimeException("用户不存在");
         }
         // 密码校验
@@ -35,7 +77,7 @@ public class UserServiceImpl implements UserService {
                 user.getSalt(),
                 user.getPasswordHash()
         );
-        if (!match){
+        if (!match) {
             throw new RuntimeException("密码错误");
         }
         // 生成token
@@ -49,36 +91,249 @@ public class UserServiceImpl implements UserService {
     }
 
     /**
-     * 用户注册
-     * @param userAccount 账户名称
-     * @param userPassword 密码
-     * @return 用户id
+     * 获取用户信息
+     *
+     * @param userId 用户ID
+     * @return 用户信息
      */
     @Override
-    public long userRegister(String userAccount, String userPassword) {
-        //验证非空
-        if (userAccount.isEmpty() ||userPassword.isEmpty()){
-            return -2;
+    public UserInfoVO getUserInfo(Long userId) {
+        User user = userMapper.selectByUserId(userId);
+        if (user == null) {
+            throw new RuntimeException("用户不存在");
         }
-        //校验账户不能重复
-        User resultUser = userMapper.getByUsername(userAccount);
-        if (resultUser!=null){
-            return -3;
+        UserInfoVO userInfoVO = new UserInfoVO();
+        BeanUtils.copyProperties(user, userInfoVO);
+        return userInfoVO;
     }
-        //对密码进行加密
-        String encryptPassword = MD5Util.encryptWithSalt(userPassword, "yujian");
-        long maxUserId = userMapper.getMaxUserId();
-        User user = new User();
-        user.setUserId(maxUserId+1);
-        user.setUserName(userAccount);
-        user.setSalt("yujian");
-        user.setPasswordHash(encryptPassword);
-        user.setCreatedAt(LocalDateTime.now());
-        user.setUpdatedAt(LocalDateTime.now());
-        Long result = userMapper.insertUser(user);
-        if (result < 0){
-            return -1;
+
+    /**
+     * 上传头像接口
+     *
+     * @param file 头像文件
+     * @return 上传后的文件URL
+     */
+    @Override
+    public String uploadAvatar(MultipartFile file) {
+        // 参数校验
+        if (file == null || file.isEmpty()) {
+            throw new RuntimeException("图片不存在");
         }
-        return user.getUserId();
+
+        String originalFilename = file.getOriginalFilename();
+        if (originalFilename == null) {
+            throw new RuntimeException("文件名非法");
+        }
+
+        String fileType = FileUtil.getFileType(originalFilename);
+        if (!AliOssResult.IMAGE.equals(fileType)) {
+            throw new RuntimeException("仅支持图片上传");
+        }
+
+        //生成 OSS 路径
+        String extension = FileUtil.getFileExtension(originalFilename);
+        String fileName = UUID.randomUUID().toString().replace("-", "") + "." + extension;
+        Long userId = UserContext.getUserId();
+        String objectKey = "user/" + userId + "/avatar/" + fileName;
+
+        try {
+            byte[] fileBytes = file.getBytes();
+            String ossUrl = ossUtil.upload(fileBytes, objectKey);
+
+            if (ossUrl == null || ossUrl.isEmpty()) {
+                throw new RuntimeException("图片上传失败");
+            }
+
+            return ossUrl;
+
+        } catch (Exception e) {
+            throw new RuntimeException("上传图片失败", e);
+        }
+    }
+
+    /**
+     * 上传背景图片
+     *
+     * @param file 背景图片文件
+     * @return 上传后的文件URL
+     */
+    @Override
+    public String uploadBackground(MultipartFile file) {
+        // 参数校验
+        if (file == null || file.isEmpty()) {
+            throw new RuntimeException("图片不存在");
+        }
+
+        String originalFilename = file.getOriginalFilename();
+        if (originalFilename == null) {
+            throw new RuntimeException("文件名非法");
+        }
+
+        String fileType = FileUtil.getFileType(originalFilename);
+        if (!AliOssResult.IMAGE.equals(fileType)) {
+            throw new RuntimeException("仅支持图片上传");
+        }
+
+        //生成 OSS 路径
+        String extension = FileUtil.getFileExtension(originalFilename);
+        String fileName = UUID.randomUUID().toString().replace("-", "") + "." + extension;
+        Long userId = UserContext.getUserId();
+        String objectKey = "user/" + userId + "/background/" + fileName;
+
+        try {
+            byte[] fileBytes = file.getBytes();
+            String ossUrl = ossUtil.upload(fileBytes, objectKey);
+
+            if (ossUrl == null || ossUrl.isEmpty()) {
+                throw new RuntimeException("图片上传失败");
+            }
+
+            return ossUrl;
+
+        } catch (Exception e) {
+            throw new RuntimeException("上传图片失败", e);
+        }
+    }
+
+    /**
+     * 更新用户信息
+     *
+     * @param userInfoUpdateDTO 用户信息更新参数
+     */
+    @Override
+    public UserInfoVO updateUserInfo(UserInfoUpdateDTO userInfoUpdateDTO) {
+        Long userId = userInfoUpdateDTO.getUserId();
+        User user = userMapper.selectByUserId(userId);
+        if (user == null) {
+            throw new RuntimeException("用户不存在");
+        }
+
+        // 将需要审核的内容合并成一个文本，用于减少调用次数
+        StringBuilder textBuilder = new StringBuilder();
+
+        if (userInfoUpdateDTO.getNickname() != null && !userInfoUpdateDTO.getNickname().isEmpty()) {
+            textBuilder.append(userInfoUpdateDTO.getNickname()).append(" ");
+        }
+        if (userInfoUpdateDTO.getHobbies() != null && !userInfoUpdateDTO.getHobbies().isEmpty()) {
+            // 将爱好列表转换为字符串，用空格分隔
+            String hobbiesStr = String.join(" ", userInfoUpdateDTO.getHobbies());
+            textBuilder.append(hobbiesStr).append(" ");
+        }
+        if (userInfoUpdateDTO.getSignature() != null && !userInfoUpdateDTO.getSignature().isEmpty()) {
+            textBuilder.append(userInfoUpdateDTO.getSignature()).append(" ");
+        }
+        // 文本审核
+        if (textBuilder.length() > 0) {
+            Map textResult;
+            try {
+                textResult = greenTextScan.greeTextScan(textBuilder.toString());
+            } catch (Exception e) {
+                throw new RuntimeException("用户信息文本审核失败");
+            }
+
+            String suggestion = (String) textResult.get("suggestion");
+
+            if (GreenAuditResult.BLOCK.equals(suggestion)) {
+                throw new RuntimeException("用户信息包含违规内容，修改失败");
+            }
+            if (GreenAuditResult.REVIEW.equals(suggestion)) {
+                throw new RuntimeException("用户信息需要人工审核，暂无法修改");
+            }
+        }
+
+        // 图片审核
+        List<String> imageKeys = new ArrayList<>();
+        if (userInfoUpdateDTO.getAvatarUrl() != null && !userInfoUpdateDTO.getAvatarUrl().isEmpty()) {
+            imageKeys.add(userInfoUpdateDTO.getAvatarUrl());
+        }
+        if (userInfoUpdateDTO.getBackgroundUrl() != null && !userInfoUpdateDTO.getBackgroundUrl().isEmpty()) {
+            imageKeys.add(userInfoUpdateDTO.getBackgroundUrl());
+        }
+        if (!imageKeys.isEmpty()) {
+            Map imageResult;
+            try {
+                imageResult = greenImageScan.imageScan(imageKeys);
+            } catch (Exception e) {
+                throw new RuntimeException("用户图片审核失败");
+            }
+
+            String suggestion = (String) imageResult.get("suggestion");
+
+            if (GreenAuditResult.BLOCK.equals(suggestion)) {
+                throw new RuntimeException("头像或背景图不合规，修改失败");
+            }
+            if (GreenAuditResult.REVIEW.equals(suggestion)) {
+                throw new RuntimeException("头像或背景图需要人工审核，暂无法修改");
+            }
+        }
+        // 默认昵称兜底
+        if (userInfoUpdateDTO.getNickname() == null || userInfoUpdateDTO.getNickname().trim().isEmpty()) {
+            userInfoUpdateDTO.setNickname(user.getUserName());
+        }
+        userInfoUpdateDTO.setUpdatedAt(LocalDateTime.now());
+
+        // 更新数据库
+        userMapper.updateUserInfoByUserId(userInfoUpdateDTO);
+
+        // 封装返回结果
+        User updatedUser = userMapper.selectByUserId(userInfoUpdateDTO.getUserId());
+        UserInfoVO userInfoVO = new UserInfoVO();
+        BeanUtils.copyProperties(updatedUser, userInfoVO);
+        return userInfoVO;
+    }
+
+    /**
+     * 查询用户
+     * @param userName 用户民称
+     * @return
+     */
+    @Override
+    public Boolean registerUser(String userName,String userPassword) {
+        //校验参数是否为空
+        if (userName.isEmpty() || userPassword.isEmpty()){
+            return false;
+        }
+        //产看数据库是否存在已注册用户
+        User user = userMapper.getByUsername(userName);
+        if (user != null){
+            return false;
+        }
+        //将用户数据存入苏数据库
+        String salt = "lyy123";
+        String passwordHash = MD5Util.encryptWithSalt(userPassword, salt);
+        //查询最大用户id
+        Long maxId = userMapper.selectMaxId();
+        User saveUser = new User();
+        saveUser.setUserId(maxId+1);
+        saveUser.setUserName(userName);
+        saveUser.setPasswordHash(passwordHash);
+        saveUser.setSalt(salt);
+        saveUser.setUpdatedAt(LocalDateTime.now());
+        saveUser.setCreatedAt(LocalDateTime.now());
+        int count = userMapper.saveUser(saveUser);
+        return count > 0;
+    }
+
+    /**
+     * 邮箱登录
+     * @param email 邮箱
+     * @param code 验证码
+     * @return 脱敏用户信息
+     */
+    @Override
+    public UserLoginVO emailLogin(String email, String code) {
+        User user = userMapper.selectByUserEmailUser(email);
+        if (user == null)
+            return null;
+        boolean flag = verificationCodeService.verifyEmailCode(email, code);
+        if (!flag)
+            return null;
+        // 生成token
+        String token = JwtUtil.generateToken(String.valueOf(user.getUserId()));
+        UserLoginVO userLoginVO = new UserLoginVO();
+        userLoginVO.setUserId(user.getUserId());
+        userLoginVO.setNickname(user.getNickname());
+        userLoginVO.setToken(token);
+        return userLoginVO;
     }
 }

src/main/java/com/bao/dating/service/impl/VerificationCodeServiceImpl.java

@@ -0,0 +1,122 @@
+package com.bao.dating.service.impl;
+
+import com.bao.dating.service.VerificationCodeService;
+import com.bao.dating.util.EmailUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.Random;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 验证码服务实现类
+ * @author KilLze
+ */
+@Slf4j
+@Service
+public class VerificationCodeServiceImpl implements VerificationCodeService {
+
+    @Autowired
+    private EmailUtil emailUtil;
+
+    @Autowired
+    private StringRedisTemplate redisTemplate;
+
+    /**
+     * Redis中验证码的key前缀
+     */
+    private static final String CODE_KEY_PREFIX = "email:code:";
+
+    /**
+     * 验证码过期时间（分钟）
+     */
+    private static final long CODE_EXPIRE_MINUTES = 10;
+
+    /**
+     * 验证码长度
+     */
+    private static final int CODE_LENGTH = 6;
+
+    /**
+     * 发送邮箱验证码
+     * @param email 邮箱地址
+     * @return 是否发送成功
+     */
+    @Override
+    public boolean sendEmailCode(String email) {
+        try {
+            // 生成验证码
+            String code = generateCode(CODE_LENGTH);
+            
+            // 存储到Redis，设置过期时间
+            String key = CODE_KEY_PREFIX + email;
+            redisTemplate.opsForValue().set(key, code, CODE_EXPIRE_MINUTES, TimeUnit.MINUTES);
+            
+            // 发送邮件
+            boolean sendResult = emailUtil.sendVerificationCode(email, code);
+            
+            if (sendResult) {
+                log.info("邮箱验证码发送成功，邮箱：{}，验证码：{}", email, code);
+                return true;
+            } else {
+                // 如果发送失败，删除Redis中的验证码
+                redisTemplate.delete(key);
+                log.error("邮箱验证码发送失败，邮箱：{}", email);
+                return false;
+            }
+        } catch (Exception e) {
+            log.error("发送邮箱验证码异常，邮箱：{}，异常信息：{}", email, e.getMessage(), e);
+            return false;
+        }
+    }
+
+    /**
+     * 验证邮箱验证码
+     * @param email 邮箱地址
+     * @param code 验证码
+     * @return 是否验证成功
+     */
+    @Override
+    public boolean verifyEmailCode(String email, String code) {
+        try {
+            String key = CODE_KEY_PREFIX + email;
+            String storedCode = redisTemplate.opsForValue().get(key);
+            
+            if (storedCode == null) {
+                log.warn("验证码不存在或已过期，邮箱：{}", email);
+                return false;
+            }
+            
+            if (storedCode.equals(code)) {
+                // 验证成功后，删除验证码（防止重复使用）
+                redisTemplate.delete(key);
+                log.info("邮箱验证码验证成功，邮箱：{}", email);
+                return true;
+            } else {
+                log.warn("邮箱验证码错误，邮箱：{}，输入的验证码：{}，正确的验证码：{}", email, code, storedCode);
+                return false;
+            }
+        } catch (Exception e) {
+            log.error("验证邮箱验证码异常，邮箱：{}，异常信息：{}", email, e.getMessage(), e);
+            return false;
+        }
+    }
+
+    /**
+     * 生成验证码
+     * @param length 验证码长度
+     * @return 验证码字符串
+     */
+    @Override
+    public String generateCode(int length) {
+        Random random = new Random();
+        StringBuilder code = new StringBuilder();
+        for (int i = 0; i < length; i++) {
+            code.append(random.nextInt(10)); // 生成0-9的随机数字
+        }
+        return code.toString();
+    }
+}
+

src/main/java/com/bao/dating/task/FriendApplyCleanupTask.java

@@ -0,0 +1,36 @@
+package com.bao.dating.task;
+
+import com.bao.dating.mapper.FriendRelationMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * 好友申请清理定时任务
+ * 定时清理数据库中超过7天未处理的好友申请
+ * @author KilLze
+ */
+@Slf4j
+@Component
+public class FriendApplyCleanupTask {
+
+    @Autowired
+    private FriendRelationMapper friendRelationMapper;
+
+    /**
+     * 定时清理过期的好友申请
+     * 每1分钟执行一次，清理创建时间超过7天的未处理申请
+     */
+    @Scheduled(fixedRate = 60000) // 每1分钟执行一次
+    public void cleanupExpiredFriendApply() {
+        log.info("开始执行好友申请清理任务");
+        try {
+            // 删除创建时间超过7天的未处理申请（apply_status = 0）
+            int deletedCount = friendRelationMapper.deleteExpiredFriendApply(7);
+            log.info("好友申请清理任务执行完成，删除了 {} 条过期记录", deletedCount);
+        } catch (Exception e) {
+            log.error("好友申请清理任务执行失败", e);
+        }
+    }
+}

src/main/java/com/bao/dating/util/EmailUtil.java

@@ -84,6 +84,7 @@ public class EmailUtil {
         } catch (MessagingException e) {
             log.error("HTML邮件发送失败，收件人：{}，异常信息：{}", to, e.getMessage(), e);
             return false;
+
         }
     }
 
@@ -173,6 +174,7 @@ public class EmailUtil {
         }
         log.info("批量邮件发送完成，总数：{}，成功：{}", toList.length, successCount);
         return successCount;
+
     }
 }
 

src/main/java/com/bao/dating/util/FileUtil.java

@@ -1,5 +1,7 @@
 package com.bao.dating.util;
 
+import com.bao.dating.common.result.FileResult;
+
 /**
  * 文件工具类
  * @author KilLze
@@ -13,9 +15,9 @@ public class FileUtil {
     public static String getFileType(String fileUrl) {
         String extension = getFileExtension(fileUrl);
 
-        if (extension.equals("jpg") || extension.equals("jpeg") || extension.equals("png") || extension.equals("gif")) {
+        if (FileResult.JPG.equals(extension) || FileResult.JPEG.equals(extension) || FileResult.PNG.equals(extension) || FileResult.GIF.equals(extension)) {
             return "image";
-        } else if (extension.equals("mp4") || extension.equals("avi") || extension.equals("mov")) {
+        } else if (FileResult.MP4.equals(extension) || FileResult.AVI.equals(extension) || FileResult.MOV.equals(extension)) {
             return "video";
         }
         return "unknown";

src/main/resources/application.yml

@@ -8,8 +8,8 @@ spring:
     password: JoyeeServe2025
     driver-class-name: com.mysql.cj.jdbc.Driver
   redis:
-    host: 127.0.0.1
-    port: 6379
+    host: 110.42.41.177
+    port: 6389
     password: ""
     database: 0
     timeout: 10000
@@ -39,7 +39,6 @@ spring:
           connectiontimeout: 10000  # 连接超时时间（毫秒）
           timeout: 10000  # 读取超时时间（毫秒）
           writetimeout: 10000  # 写入超时时间（毫秒）
-
 # MyBatis 配置
 mybatis:
   mapper-locations: classpath:mapper/*.xml
@@ -65,3 +64,11 @@ aliyun:
     region-id: cn-hangzhou
     sign-name: 速通互联验证码
     template-code: 100001
+
+# ip2location.io 相关配置
+ip2location:
+  api:
+    key: 95F4AB991174E296AFD5AD0EF927B2ED  # ip2location.io API密钥
+    url: https://api.ip2location.io/
+    timeout: 5000  # 请求超时时间（毫秒）
+

src/main/resources/com/bao/dating/mapper/ContactMapper.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.bao.dating.mapper.ContactMapper">
+    <select id="selectFriendsByUserId" resultType="java.util.Map">
+        SELECT c.contact_id,
+               c.user_id,
+               c.contact_user_id,
+               c.contact_nickname,
+               c.relation_type,
+               c.add_time,
+               u.user_name,
+               u.nickname,
+               u.avatar_url,
+               u.signature
+        FROM contacts c
+                 LEFT JOIN user u ON c.contact_user_id = u.user_id
+        WHERE c.user_id = #{userId}
+          AND c.contact_status = 1 -- 正常状态
+          AND c.relation_type != 3  -- 排除黑名单
+          AND c.user_id != c.contact_user_id -- 排除自己
+    </select>
+</mapper>
+

src/main/resources/com/bao/dating/mapper/FriendRelationMapper.xml

@@ -0,0 +1,130 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.bao.dating.mapper.FriendRelationMapper">
+    <!-- 插入好友申请 -->
+    <insert id="insertFriendApply" parameterType="java.util.Map">
+        INSERT INTO friend_apply (
+            apply_user_id,
+            target_user_id,
+            greeting,
+            apply_time,
+            apply_status,
+            created_at,
+            updated_at
+        ) VALUES (
+                     #{apply_user_id},
+                     #{target_user_id},
+                     #{greeting},
+                     NOW(),
+                     0,
+                     NOW(),
+                     NOW()
+                 )
+    </insert>
+
+    <!-- 更新好友申请状态 -->
+    <update id="updateFriendApplyStatus" parameterType="java.util.Map">
+        UPDATE friend_apply
+        SET apply_status = #{apply_status},
+            updated_at = NOW()
+        WHERE apply_user_id = #{apply_user_id}
+          AND target_user_id = #{target_user_id}
+          AND apply_status = 0
+    </update>
+
+    <!-- 删除好友申请（可选） -->
+    <delete id="deleteFriendApply" parameterType="java.util.Map">
+        DELETE FROM friend_apply
+        WHERE apply_user_id = #{apply_user_id}
+          AND target_user_id = #{target_user_id}
+    </delete>
+
+    <!-- 根据申请人ID和被申请人ID查询好友申请 -->
+    <select id="selectFriendApplyByUsers" parameterType="java.util.Map" resultType="java.util.Map">
+        SELECT
+            apply_id,
+            apply_user_id,
+            target_user_id,
+            greeting,
+            apply_time,
+            apply_status,
+            created_at,
+            updated_at
+        FROM friend_apply
+        WHERE apply_user_id = #{applyUserId}
+          AND target_user_id = #{targetUserId}
+          AND apply_status = 0
+    </select>
+
+    <!-- 查询待处理的好友申请 -->
+    <select id="selectFriendApplyList" parameterType="java.lang.Long" resultType="java.util.Map">
+        SELECT
+            apply_id,
+            apply_user_id,
+            target_user_id,
+            greeting,
+            apply_time,
+            apply_status,
+            created_at,
+            updated_at
+        FROM friend_apply
+        WHERE target_user_id = #{targetUserId}
+          AND apply_status = 0
+        ORDER BY apply_time DESC
+    </select>
+
+    <!-- 插入联系人记录（方法名同步修改，字段名不变） -->
+    <insert id="insertFriendRelation" parameterType="java.util.Map">
+        INSERT INTO contacts (
+            user_id,
+            contact_user_id,
+            contact_nickname,
+            relation_type,
+            contact_status,
+            add_time,
+            created_at,
+            updated_at
+        ) VALUES (
+                     #{user_id},
+                     #{contact_user_id},
+                     #{contact_nickname},
+                     #{relation_type},
+                     #{contact_status},
+                     NOW(),
+                     NOW(),
+                     NOW()
+                 )
+    </insert>
+
+    <!-- 查询联系人列表（方法名同步修改，字段名不变） -->
+    <select id="selectFriendRelationListByUserId" parameterType="java.lang.Long" resultType="java.util.Map">
+        SELECT
+            contact_id,
+            user_id,
+            contact_user_id,
+            contact_nickname,
+            contact_avatar,
+            relation_type,
+            add_time,
+            last_chat_time,
+            contact_status,
+            contact_remark,
+            tags,
+            created_at,
+            updated_at
+        FROM contacts
+        WHERE user_id = #{userId}
+          AND contact_status = 1
+        ORDER BY add_time DESC
+    </select>
+
+    <!-- 删除过期的好友申请 -->
+    <delete id="deleteExpiredFriendApply" parameterType="java.lang.Integer">
+        DELETE FROM friend_apply
+        WHERE apply_status = 0
+          AND created_at &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
+
+</mapper>

src/main/resources/com/bao/dating/mapper/PostFavoriteMapper.xml

@@ -14,8 +14,8 @@
     <select id="selectUserIDByPostID" resultType="java.lang.Long">
         SELECT user_id FROM post_favorite WHERE post_id = #{postId}
     </select>
-    <!--查询用户收藏的所有动态-->
-    <select id="getAllPost" resultType="com.bao.dating.pojo.entity.Post">
-        select * from post where post_id in (select post_id from post_favorite where user_id=#{userId})
+    <!-- 查询所有收藏动态 -->
+    <select id="showAllFavorites" resultType="com.bao.dating.pojo.entity.Post">
+        SELECT * FROM post WHERE post_id IN (SELECT post_id FROM post_favorite WHERE user_id = #{userid})
     </select>
 </mapper>

src/main/resources/com/bao/dating/mapper/PostMapper.xml

@@ -36,15 +36,15 @@
         </foreach>
     </delete>
     <!--删除收藏记录-->
-    <delete id="1">
+    <delete id="deletePostFavoriteByPostId">
         DELETE FROM post_favorite WHERE post_id = #{postId}
     </delete>
     <!--删除点赞记录-->
-    <delete id="2">
+    <delete id="deletePostLikeByPostId">
         DELETE FROM post_like WHERE post_id = #{postId}
     </delete>
     <!--动态评论删除-->
-    <delete id="3">
+    <delete id="deleteCommentsByPostId">
         DELETE FROM comments WHERE post_id = #{postId}
     </delete>
 
@@ -82,10 +82,10 @@
     <update id="updateById">
         UPDATE post
         <set>
-            <if test="content != null">
+            <if test="content != null and content != '' ">
                 content = #{content},
             </if>
-            <if test="tags != null">
+            <if test="tags != null and tags != '' ">
                 tags = #{tags, typeHandler=com.bao.dating.handler.ListToVarcharTypeHandler},
             </if>
             <if test="mediaOssKeys != null">

src/main/resources/com/bao/dating/mapper/UserMapper.xml

@@ -3,15 +3,91 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 
 <mapper namespace="com.bao.dating.mapper.UserMapper">
-    <insert id="insertUser" useGeneratedKeys="true" parameterType="com.bao.dating.pojo.entity.User">
-        insert into user(user_id,user_name,salt,password_hash,created_at,updated_at) values (#{userId},#{userName},#{salt},#{passwordHash},#{createdAt},#{updatedAt})
+    <!-- 向数据库中添加用户 -->
+    <insert id="saveUser">
+        insert into user(user_id,user_name,password_hash,salt,created_at,updated_at) values (#{userId},#{userName},#{passwordHash},#{salt},#{createdAt},#{updatedAt})
     </insert>
 
+    <!--根据用户名查询用户-->
     <select id="getByUsername" resultType="com.bao.dating.pojo.entity.User">
-        SELECT * FROM user WHERE user_name = #{userName}
-    </select>
-    <select id="getMaxUserId" resultType="java.lang.Long">
-        SELECT IFNULL(MAX(user_id), 0) AS max_id FROM user;
+        SELECT
+            user_id,
+            user_name,
+            password_hash,
+            salt,
+            nickname
+        FROM user WHERE user_name = #{userName}
     </select>
 
+    <!--根据用户id查询用户信息-->
+    <resultMap id="UserResultMap" type="com.bao.dating.pojo.entity.User">
+        <id property="userId" column="user_id"/>
+        <result property="userName" column="user_name"/>
+        <result property="nickname" column="nickname"/>
+        <result property="avatarUrl" column="avatar_url"/>
+        <result property="backgroundUrl" column="background_url"/>
+        <result property="gender" column="gender"/>
+        <result property="birthday" column="birthday"/>
+        <result property="hobbies" column="hobbies" typeHandler="com.bao.dating.handler.ListToJsonTypeHandler"/>
+        <result property="signature" column="signature"/>
+        <result property="createdAt" column="created_at"/>
+        <result property="updatedAt" column="updated_at"/>
+    </resultMap>
+    <select id="selectByUserId" resultMap="UserResultMap">
+        SELECT
+            user_id,
+            user_name,
+            nickname,
+            avatar_url,
+            background_url,
+            gender,
+            birthday,
+            hobbies,
+            signature,
+            created_at,
+            updated_at
+            FROM user WHERE user_id = #{userId}
+    </select>
+
+    <!-- 查询最大用户id -->
+    <select id="selectMaxId" resultType="java.lang.Long">
+        SELECT MAX(user_id) FROM user
+    </select>
+
+    <!-- 根据邮箱查询用户信息 -->
+    <select id="selectByUserEmailUser" resultType="com.bao.dating.pojo.entity.User">
+        select * from user where user_email = #{userEmail}
+    </select>
+
+    <!--根据ID更新动态-->
+    <update id="updateUserInfoByUserId">
+        UPDATE user
+        <set>
+            <if test="nickname != null">
+                nickname = #{nickname},
+            </if>
+            <if test="avatarUrl != null">
+                avatar_url = #{avatarUrl},
+            </if>
+            <if test="backgroundUrl != null">
+                background_url = #{backgroundUrl},
+            </if>
+            <if test="gender != null">
+                gender = #{gender},
+            </if>
+            <if test="birthday != null">
+                birthday = #{birthday},
+            </if>
+            <if test="hobbies != null">
+                hobbies = #{hobbies, typeHandler=com.bao.dating.handler.ListToJsonTypeHandler},
+            </if>
+            <if test="signature != null">
+                signature = #{signature},
+            </if>
+            updated_at = #{updatedAt}
+        </set>
+        WHERE user_id = #{userId}
+    </update>
+
+
 </mapper>

src/test/java/com/bao/dating/common/aliyun/OssUploadTest.java

@@ -0,0 +1,304 @@
+package com.bao.dating.common.aliyun;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.UUID;
+
+/**
+ * OSS图片上传测试类
+ * @author KilLze
+ */
+@SpringBootTest
+public class OssUploadTest {
+
+    @Autowired
+    private AliOssUtil aliOssUtil;
+
+    /**
+     * 测试上传本地图片文件
+     */
+    @Test
+    public void testUploadLocalImage() {
+        try {
+            // 本地图片文件路径（请修改为实际存在的图片路径）
+            String localImagePath = "D:/image/image.jpg"; // 请修改为实际路径
+            
+            File imageFile = new File(localImagePath);
+            if (!imageFile.exists()) {
+                System.out.println("图片文件不存在: " + localImagePath);
+                System.out.println("请修改localImagePath为实际存在的图片路径");
+                return;
+            }
+
+            // 读取文件字节
+            byte[] imageBytes = Files.readAllBytes(Paths.get(localImagePath));
+            
+            // 生成OSS对象名称（使用时间戳和UUID确保唯一性）
+            String objectName = generateObjectName("test", "jpg");
+            
+            // 上传到OSS
+            String fileUrl = aliOssUtil.upload(imageBytes, objectName);
+            
+            System.out.println("========== 本地图片上传测试 ==========");
+            System.out.println("本地文件路径: " + localImagePath);
+            System.out.println("文件大小: " + imageBytes.length + " 字节");
+            System.out.println("OSS对象名称: " + objectName);
+            System.out.println("文件访问URL: " + fileUrl);
+            System.out.println("上传结果: 成功");
+            System.out.println("=====================================");
+            
+        } catch (IOException e) {
+            System.out.println("上传失败: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 测试从网络URL下载图片并上传到OSS
+     */
+    @Test
+    public void testUploadImageFromUrl() {
+        try {
+            // 网络图片URL（请修改为实际的图片URL）
+            String imageUrl = "https://example.com/image.jpg"; // 请修改为实际URL
+            
+            System.out.println("========== 网络图片上传测试 ==========");
+            System.out.println("开始下载图片: " + imageUrl);
+            
+            // 从URL下载图片
+            URL url = new URL(imageUrl);
+            try (InputStream inputStream = url.openStream()) {
+                byte[] imageBytes = readAllBytes(inputStream);
+                
+                // 从URL中提取文件扩展名
+                String extension = getFileExtensionFromUrl(imageUrl);
+                if (extension.isEmpty()) {
+                    extension = "jpg"; // 默认扩展名
+                }
+                
+                // 生成OSS对象名称
+                String objectName = generateObjectName("download", extension);
+                
+                // 上传到OSS
+                String fileUrl = aliOssUtil.upload(imageBytes, objectName);
+                
+                System.out.println("图片下载成功");
+                System.out.println("文件大小: " + imageBytes.length + " 字节");
+                System.out.println("OSS对象名称: " + objectName);
+                System.out.println("文件访问URL: " + fileUrl);
+                System.out.println("上传结果: 成功");
+            }
+            
+            System.out.println("=====================================");
+            
+        } catch (Exception e) {
+            System.out.println("上传失败: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 测试上传不同格式的图片
+     */
+    @Test
+    public void testUploadDifferentImageFormats() {
+        String[] imagePaths = {
+            "D:/test/image1.jpg",   // 请修改为实际路径
+            "D:/test/image2.png",   // 请修改为实际路径
+            "D:/test/image3.gif"    // 请修改为实际路径
+        };
+        
+        System.out.println("========== 多格式图片上传测试 ==========");
+        
+        for (String imagePath : imagePaths) {
+            try {
+                File imageFile = new File(imagePath);
+                if (!imageFile.exists()) {
+                    System.out.println("跳过不存在的文件: " + imagePath);
+                    continue;
+                }
+                
+                // 读取文件
+                byte[] imageBytes = Files.readAllBytes(Paths.get(imagePath));
+                
+                // 获取文件扩展名
+                String extension = getFileExtension(imagePath);
+                
+                // 生成OSS对象名称
+                String objectName = generateObjectName("format-test", extension);
+                
+                // 上传
+                String fileUrl = aliOssUtil.upload(imageBytes, objectName);
+                
+                System.out.println("\n文件: " + imagePath);
+                System.out.println("格式: " + extension);
+                System.out.println("大小: " + imageBytes.length + " 字节");
+                System.out.println("URL: " + fileUrl);
+                System.out.println("状态: 成功");
+                
+            } catch (Exception e) {
+                System.out.println("\n文件: " + imagePath);
+                System.out.println("状态: 失败 - " + e.getMessage());
+            }
+        }
+        
+        System.out.println("\n=====================================");
+    }
+
+    /**
+     * 测试上传图片到指定目录
+     */
+    @Test
+    public void testUploadImageToDirectory() {
+        try {
+            // 本地图片文件路径
+            String localImagePath = "D:/test/image.jpg"; // 请修改为实际路径
+            
+            File imageFile = new File(localImagePath);
+            if (!imageFile.exists()) {
+                System.out.println("图片文件不存在: " + localImagePath);
+                return;
+            }
+            
+            // 读取文件
+            byte[] imageBytes = Files.readAllBytes(Paths.get(localImagePath));
+            
+            // 上传到指定目录（例如：images/2025/12/24/xxx.jpg）
+            String directory = "images/" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd"));
+            String fileName = UUID.randomUUID().toString() + ".jpg";
+            String objectName = directory + "/" + fileName;
+            
+            // 上传
+            String fileUrl = aliOssUtil.upload(imageBytes, objectName);
+            
+            System.out.println("========== 目录上传测试 ==========");
+            System.out.println("目录: " + directory);
+            System.out.println("文件名: " + fileName);
+            System.out.println("完整路径: " + objectName);
+            System.out.println("文件访问URL: " + fileUrl);
+            System.out.println("上传结果: 成功");
+            System.out.println("=================================");
+            
+        } catch (Exception e) {
+            System.out.println("上传失败: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 测试使用FileInputStream上传
+     */
+    @Test
+    public void testUploadWithFileInputStream() {
+        try {
+            // 本地图片文件路径
+            String localImagePath = "D:/test/image.jpg"; // 请修改为实际路径
+            
+            File imageFile = new File(localImagePath);
+            if (!imageFile.exists()) {
+                System.out.println("图片文件不存在: " + localImagePath);
+                return;
+            }
+            
+            // 使用FileInputStream读取文件
+            try (FileInputStream fis = new FileInputStream(imageFile)) {
+                byte[] imageBytes = new byte[(int) imageFile.length()];
+                fis.read(imageBytes);
+                
+                // 生成OSS对象名称
+                String objectName = generateObjectName("stream", "jpg");
+                
+                // 上传
+                String fileUrl = aliOssUtil.upload(imageBytes, objectName);
+                
+                System.out.println("========== FileInputStream上传测试 ==========");
+                System.out.println("文件路径: " + localImagePath);
+                System.out.println("文件大小: " + imageBytes.length + " 字节");
+                System.out.println("OSS对象名称: " + objectName);
+                System.out.println("文件访问URL: " + fileUrl);
+                System.out.println("上传结果: 成功");
+                System.out.println("===========================================");
+            }
+            
+        } catch (Exception e) {
+            System.out.println("上传失败: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 生成OSS对象名称
+     * @param prefix 前缀
+     * @param extension 文件扩展名
+     * @return 对象名称
+     */
+    private String generateObjectName(String prefix, String extension) {
+        // 格式: prefix/yyyyMMdd/HHmmss-uuid.extension
+        String dateTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd/HHmmss"));
+        String uuid = UUID.randomUUID().toString().substring(0, 8);
+        return String.format("%s/%s-%s.%s", prefix, dateTime, uuid, extension);
+    }
+
+    /**
+     * 从文件路径获取扩展名
+     * @param filePath 文件路径
+     * @return 扩展名
+     */
+    private String getFileExtension(String filePath) {
+        int lastDot = filePath.lastIndexOf('.');
+        if (lastDot > 0 && lastDot < filePath.length() - 1) {
+            return filePath.substring(lastDot + 1).toLowerCase();
+        }
+        return "jpg"; // 默认扩展名
+    }
+
+    /**
+     * 从URL获取文件扩展名
+     * @param url URL地址
+     * @return 扩展名
+     */
+    private String getFileExtensionFromUrl(String url) {
+        try {
+            // 移除查询参数
+            String path = url.split("\\?")[0];
+            int lastDot = path.lastIndexOf('.');
+            int lastSlash = path.lastIndexOf('/');
+            
+            if (lastDot > lastSlash && lastDot < path.length() - 1) {
+                return path.substring(lastDot + 1).toLowerCase();
+            }
+        } catch (Exception e) {
+            // 忽略异常
+        }
+        return "jpg"; // 默认扩展名
+    }
+
+    /**
+     * 从InputStream读取所有字节（兼容方法）
+     * @param inputStream 输入流
+     * @return 字节数组
+     * @throws IOException IO异常
+     */
+    private byte[] readAllBytes(InputStream inputStream) throws IOException {
+        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+        byte[] data = new byte[8192]; // 8KB缓冲区
+        int nRead;
+        while ((nRead = inputStream.read(data, 0, data.length)) != -1) {
+            buffer.write(data, 0, nRead);
+        }
+        return buffer.toByteArray();
+    }
+}
+

src/test/java/com/bao/dating/service/VerificationCodeServiceTest.java

@@ -0,0 +1,91 @@
+package com.bao.dating.service;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * 验证码服务测试类
+ * @author KilLze
+ */
+@SpringBootTest
+public class VerificationCodeServiceTest {
+
+    @Autowired
+    private VerificationCodeService verificationCodeService;
+
+    /**
+     * 测试发送邮箱验证码
+     */
+    @Test
+    public void testSendEmailCode() {
+        String email = "test@example.com"; // 请修改为实际邮箱地址
+        
+        System.out.println("========== 发送邮箱验证码测试 ==========");
+        System.out.println("邮箱地址: " + email);
+        
+        boolean result = verificationCodeService.sendEmailCode(email);
+        
+        System.out.println("发送结果: " + (result ? "成功" : "失败"));
+        System.out.println("=====================================");
+    }
+
+    /**
+     * 测试验证邮箱验证码
+     */
+    @Test
+    public void testVerifyEmailCode() {
+        String email = "test@example.com"; // 请修改为实际邮箱地址
+        String code = "123456"; // 请修改为实际收到的验证码
+        
+        System.out.println("========== 验证邮箱验证码测试 ==========");
+        System.out.println("邮箱地址: " + email);
+        System.out.println("验证码: " + code);
+        
+        boolean result = verificationCodeService.verifyEmailCode(email, code);
+        
+        System.out.println("验证结果: " + (result ? "成功" : "失败"));
+        System.out.println("=====================================");
+    }
+
+    /**
+     * 测试完整流程：发送验证码 -> 验证验证码
+     */
+    @Test
+    public void testCompleteFlow() {
+        String email = "test@example.com"; // 请修改为实际邮箱地址
+        
+        System.out.println("========== 完整流程测试 ==========");
+        System.out.println("邮箱地址: " + email);
+        
+        // 1. 发送验证码
+        System.out.println("\n1. 发送验证码...");
+        boolean sendResult = verificationCodeService.sendEmailCode(email);
+        System.out.println("发送结果: " + (sendResult ? "成功" : "失败"));
+        
+        if (sendResult) {
+            // 2. 等待用户输入验证码（这里模拟，实际应该从控制台或API获取）
+            System.out.println("\n2. 请查看邮箱获取验证码，然后手动测试验证功能");
+            System.out.println("   使用 testVerifyEmailCode() 方法进行验证");
+        }
+        
+        System.out.println("\n=====================================");
+    }
+
+    /**
+     * 测试生成验证码
+     */
+    @Test
+    public void testGenerateCode() {
+        System.out.println("========== 生成验证码测试 ==========");
+        
+        // 测试不同长度的验证码
+        for (int length = 4; length <= 8; length++) {
+            String code = verificationCodeService.generateCode(length);
+            System.out.println(length + "位验证码: " + code);
+        }
+        
+        System.out.println("=====================================");
+    }
+}
+

src/test/java/com/bao/dating/util/EmailAndSmsTest.java

@@ -75,3 +75,4 @@ public class EmailAndSmsTest {
 
 
 
+