makefriends/dating
2
1
Fork 1
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Compare commits

base: makefriends:bd12c599b0d95b6a723c4b6803a4eae839cb6b61
Branches Tags
makefriends:master makefriends:fearure-Notice makefriends:feature-ccb makefriends:feature-admin makefriends:123321 makefriends:feature/contacts-update makefriends:feature-DataAnalysis makefriends:feature-init makefriends:feature/contacts-friends makefriends:feature-ip-location makefriends:feature-WebSocket makefriends:feature-KilLze makefriends:feature-PostFavorite makefriends:feature-Post makefriends:feature-PostLike makefriends:feature-Comment makefriends:dev makefriends:feature-Email makefriends:feature-userRegistry makefriends:main
..
compare: makefriends:fearure-Notice
Branches Tags
makefriends:fearure-Notice makefriends:feature-ccb makefriends:master makefriends:feature-admin makefriends:123321 makefriends:feature/contacts-update makefriends:feature-DataAnalysis makefriends:feature-init makefriends:feature/contacts-friends makefriends:feature-ip-location makefriends:feature-WebSocket makefriends:feature-KilLze makefriends:feature-PostFavorite makefriends:feature-Post makefriends:feature-PostLike makefriends:feature-Comment makefriends:dev makefriends:feature-Email makefriends:feature-userRegistry makefriends:main

1 Commits
bd12c599b0 ... fearure-No

Author SHA1 Message Date
lihaiyang
205f347d08 公告 2026-01-21 23:32:22 +08:00
43 changed files with 198 additions and 1336 deletions
Expand all files Collapse all files

43
pom.xml
View File

@@ -19,13 +19,6 @@
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.10</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
@@ -110,38 +103,6 @@
<version>0.2.8</version>
</dependency>
<!-- JWT 相关依赖 -->
<dependency>
<groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt-api</artifactId>
<version>0.11.5</version>
</dependency>
<dependency>
<groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt-impl</artifactId>
<version>0.11.5</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt-jackson</artifactId>
<version>0.11.5</version>
<scope>runtime</scope>
</dependency>
<!-- 阿里云短信服务SDK -->
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>dysmsapi20170525</artifactId>
<version>3.0.0</version>
</dependency>
<!-- Spring Mail 邮件发送 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
@@ -162,8 +123,8 @@
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>9</source>
<target>9</target>
<source>1.8</source>
<target>1.8</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>

16
src/main/java/com/bao/dating/common/Post.java
View File

@@ -1,16 +0,0 @@
package com.bao.dating.common;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 动态表
*/
@Data
public class Post {
private Long post_id; // 动态ID
private String content; // 动态内容
private Long user_id; // 发布人ID
private LocalDateTime created_at; // 创建时间
}

3
src/main/java/com/bao/dating/common/ResultCode.java
View File

@@ -8,8 +8,7 @@ public enum ResultCode {
UNAUTHORIZED(401, "未登录或 Token 失效"),
FORBIDDEN(403, "无权限"),
NOT_FOUND(404, "数据不存在"),
SYSTEM_ERROR(500, "系统异常"),
FAIL(500, "操作失败");
SYSTEM_ERROR(500, "系统异常");
private final int code;
private final String msg;

3
src/main/java/com/bao/dating/common/aliyun/AliOssUtil.java
View File

@@ -11,8 +11,6 @@ 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;
@Data
@Slf4j
@@ -32,6 +30,7 @@ public class AliOssUtil {
* @return 完整的文件访问URL
*/
public String upload(byte[] bytes, String objectName) {
// 创建OSSClient实例。
OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

151
src/main/java/com/bao/dating/common/aliyun/SmsUtil.java
View File

@@ -1,151 +0,0 @@
package com.bao.dating.common.aliyun;
import com.aliyun.dysmsapi20170525.Client;
import com.aliyun.dysmsapi20170525.models.SendSmsRequest;
import com.aliyun.dysmsapi20170525.models.SendSmsResponse;
import com.aliyun.teaopenapi.models.Config;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import java.util.Map;
/**
* 阿里云短信服务工具类
* @author KilLze
*/
@Data
@Slf4j
@Component
@ConfigurationProperties(prefix = "aliyun.sms")
public class SmsUtil {
/**
* 访问密钥ID
*/
private String accessKeyId;
/**
* 访问密钥Secret
*/
private String accessKeySecret;
/**
* 短信服务区域节点
*/
private String regionId = "cn-hangzhou";
/**
* 默认签名名称
*/
private String signName;
/**
* 默认模板代码
*/
private String templateCode;
/**
* 创建短信客户端
* @return Client对象
* @throws Exception 创建失败时抛出异常
*/
private Client createClient() throws Exception {
Config config = new Config()
.setAccessKeyId(accessKeyId)
.setAccessKeySecret(accessKeySecret)
.setEndpoint("dysmsapi.aliyuncs.com");
return new Client(config);
}
/**
* 发送短信
* @param phoneNumber 手机号码
* @param templateCode 模板代码（如果为空则使用默认模板代码）
* @param templateParam 模板参数（JSON格式字符串，如：{"code":"123456"}）
* @return 是否发送成功
*/
public boolean sendSms(String phoneNumber, String templateCode, String templateParam) {
try {
Client client = createClient();
SendSmsRequest sendSmsRequest = new SendSmsRequest()
.setPhoneNumbers(phoneNumber)
.setSignName(signName)
.setTemplateCode(templateCode != null ? templateCode : this.templateCode)
.setTemplateParam(templateParam);
SendSmsResponse response = client.sendSms(sendSmsRequest);
if ("OK".equals(response.getBody().getCode())) {
log.info("短信发送成功，手机号：{}，请求ID：{}", phoneNumber, response.getBody().getRequestId());
return true;
} else {
log.error("短信发送失败，手机号：{}，错误码：{}，错误信息：{}",
phoneNumber, response.getBody().getCode(), response.getBody().getMessage());
return false;
}
} catch (Exception e) {
log.error("发送短信异常，手机号：{}，异常信息：{}", phoneNumber, e.getMessage(), e);
return false;
}
}
/**
* 发送短信（使用默认模板代码）
* @param phoneNumber 手机号码
* @param templateParam 模板参数（JSON格式字符串）
* @return 是否发送成功
*/
public boolean sendSms(String phoneNumber, String templateParam) {
return sendSms(phoneNumber, null, templateParam);
}
/**
* 发送验证码短信
* @param phoneNumber 手机号码
* @param code 验证码
* @return 是否发送成功
*/
public boolean sendVerificationCode(String phoneNumber, String code) {
String templateParam = String.format("{\"code\":\"%s\"}", code);
return sendSms(phoneNumber, templateParam);
}
/**
* 发送验证码短信（使用指定模板代码）
* @param phoneNumber 手机号码
* @param code 验证码
* @param templateCode 模板代码
* @return 是否发送成功
*/
public boolean sendVerificationCode(String phoneNumber, String code, String templateCode) {
String templateParam = String.format("{\"code\":\"%s\"}", code);
return sendSms(phoneNumber, templateCode, templateParam);
}
/**
* 发送短信（使用Map参数）
* @param phoneNumber 手机号码
* @param templateCode 模板代码
* @param params 模板参数Map
* @return 是否发送成功
*/
public boolean sendSmsWithParams(String phoneNumber, String templateCode, Map<String, String> params) {
StringBuilder jsonBuilder = new StringBuilder("{");
boolean first = true;
for (Map.Entry<String, String> entry : params.entrySet()) {
if (!first) {
jsonBuilder.append(",");
}
jsonBuilder.append("\"").append(entry.getKey()).append("\":\"")
.append(entry.getValue()).append("\"");
first = false;
}
jsonBuilder.append("}");
return sendSms(phoneNumber, templateCode, jsonBuilder.toString());
}
}

31
src/main/java/com/bao/dating/config/WebConfig.java
View File

@@ -1,31 +0,0 @@
package com.bao.dating.config;
import com.bao.dating.interceptor.TokenInterceptor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@Configuration
public class WebConfig implements WebMvcConfigurer {
@Autowired
private TokenInterceptor tokenInterceptor;
/**
* 添加拦截器到Spring MVC配置中
* @param registry 拦截器注册中心
*/
@Override
public void addInterceptors(InterceptorRegistry registry) {
//注册自定义拦截器对象
registry.addInterceptor(tokenInterceptor)
// 拦截所有请求
.addPathPatterns("/**")
// 忽略的接口
.excludePathPatterns(
"/user/login"
);
}
}

33
src/main/java/com/bao/dating/context/UserContext.java
View File

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

52
src/main/java/com/bao/dating/controller/CommentController.java
View File

@@ -1,52 +0,0 @@
package com.bao.dating.controller;
import com.bao.dating.pojo.entity.Comments;
import com.bao.dating.common.Result;
import com.bao.dating.common.ResultCode;
import com.bao.dating.service.CommentsService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
@RestController
@RequestMapping("/comments")
@CrossOrigin
public class CommentController {
@Resource
private CommentsService commentsService;
/**
* 添加评论
* @param comment 评论对象（含content、userId、dynamicId）
*/
@PostMapping("/add")
public Result<String> addComment(@RequestBody Comments comment) {
boolean success = commentsService.addComment(comment);
return success ?
Result.success(ResultCode.SUCCESS, "评论成功") :
Result.error(ResultCode.FAIL, "评论失败");
}
/**
* 删除评论
* @param user_id 评论ID
*/
@DeleteMapping("/delete/{user_id}")
public Result<String> deleteComment(@PathVariable Long user_id) {
boolean success = commentsService.deleteComment(user_id);
return success ?
Result.success(ResultCode.SUCCESS, "删除成功") :
Result.error(ResultCode.FAIL, "删除失败");
}
/**
* 根据动态ID查询评论列表
* @param post_id 动态ID
*/
@GetMapping("/list/{post_id}")
public Result<List<Comments>> getCommentList(@PathVariable Long post_id) {
List<Comments> commentList = commentsService.getCommentByPostId(post_id);
return Result.success(ResultCode.SUCCESS, commentList);
}
}

39
src/main/java/com/bao/dating/controller/NoticeController.java Normal file
View File

@@ -0,0 +1,39 @@
package com.bao.dating.controller;
import com.bao.dating.pojo.entity.Notice;
import com.bao.dating.service.NoticeService;
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.RestController;
import java.util.List;
/**
* 公告控制器
*/
@RestController
@RequestMapping("/notice")
public class NoticeController {
@Autowired
private NoticeService noticeService;
/**
* 查询所有公告数据
* @return 公告列表
*/
@GetMapping("/list")
public List<Notice> getNoticeList() {
return noticeService.getNoticeList();
}
/**
* 判断是否有公告数据
* @return true=有数据 false=无数据
*/
@GetMapping("/hasData")
public boolean hasNoticeData() {
List<Notice> noticeList = noticeService.getNoticeList();
return !noticeList.isEmpty();
}
}

17
src/main/java/com/bao/dating/controller/PostController.java
View File

@@ -34,25 +34,26 @@ public class PostController {
/**
* 发布动态接口 - JSON格式请求
* @param postDTO 动态信息
* @param userId 用户ID
* @return 发布的动态对象
*/
@PostMapping(consumes = "application/json")
public Result<Post> createPostJson(@RequestBody PostRequestDTO postDTO) {
public Result<Post> createPostJson(@RequestBody PostRequestDTO postDTO, @RequestParam Long userId) {
// 调用 Service 层处理发布动态业务逻辑
Post result = postService.createPost(postDTO);
Post result = postService.createPost(userId, postDTO);
return Result.success(ResultCode.SUCCESS_REVIEW, "动态发布成功，等待审核。", result);
}
/**
* 批量删除动态
* 删除动态
*
* @param postIds 动态ID
* @param postId 动态ID
* @return 删除结果
*/
@DeleteMapping
public Result<String> deleteById(@RequestParam List<Long> postIds){
int deletedCount = postService.deletePostById(postIds);
return Result.success(ResultCode.SUCCESS_DELETE, deletedCount > 0 ? "成功删除" : "删除失败，该动态不存在", null);
@DeleteMapping("/{postId}")
public Result<String> deleteById(@PathVariable Long postId){
postService.deletePostById(postId);
return Result.success(ResultCode.SUCCESS_DELETE, "动态删除成功", null);
}
/**

27
src/main/java/com/bao/dating/controller/UserController.java
View File

@@ -1,27 +0,0 @@
package com.bao.dating.controller;
import com.bao.dating.common.Result;
import com.bao.dating.common.ResultCode;
import com.bao.dating.pojo.dto.UserLoginDTO;
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.*;
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
/**
* 登录
* @param userLoginDTO 登录参数
*/
@PostMapping("/login")
public Result<UserLoginVO> login(@RequestBody UserLoginDTO userLoginDTO) {
UserLoginVO userloginVO = userService.userLogin(userLoginDTO);
return Result.success(ResultCode.SUCCESS, "登录成功", userloginVO);
}
}

4
src/main/java/com/bao/dating/controller/text.java Normal file
View File

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

79
src/main/java/com/bao/dating/interceptor/TokenInterceptor.java
View File

@@ -1,79 +0,0 @@
package com.bao.dating.interceptor;
import javax.servlet.http.HttpServletRequest;
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;
import org.springframework.web.servlet.HandlerInterceptor;
/**
* HttpToken拦截器类
* 用于拦截请求并验证JWT token的有效性，同时从token中解析用户信息
*/
@Slf4j
@Component
public class TokenInterceptor implements HandlerInterceptor {
/**
* 在请求处理之前进行拦截
* 从请求头或URL参数中获取token，验证其有效性，并将用户ID保存到ThreadLocal中
* @param request HTTP请求对象
* @param response HTTP响应对象
* @param handler 处理器
* @return 验证通过返回true，否则返回false
* @throws Exception 异常
*/
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
//判断当前拦截到的是Controller的方法还是其他资源
if (!(handler instanceof HandlerMethod)) {
//当前拦截到的不是动态方法，直接放行
return true;
}
// 从 header 获取 token
String token = request.getHeader("token");
try {
log.info("jwt校验: {}", token);
// 验证 token 是否有效（包括是否过期）
if (!JwtUtil.validateToken(token)) {
log.error("Token 无效或已过期");
response.setStatus(401);
return false;
}
// 解析 token
String userId = JwtUtil.getSubjectFromToken(token);
log.info("用户: {}", userId);
// 保存 userId 到 ThreadLocal
UserContext.setUserId(Long.valueOf(userId));
return true;
} catch (Exception e) {
log.error("Token 校验失败: {}", e.getMessage());
response.setStatus(401);
return false;
}
}
/**
* 在请求完成之后执行清理工作
* 清除保存在ThreadLocal中的用户ID，防止内存泄漏
* @param request HTTP请求对象
* @param response HTTP响应对象
* @param handler 处理器
* @param ex 异常对象
* @throws Exception 异常
*/
@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
UserContext.clear();
}
}

21
src/main/java/com/bao/dating/mapper/CommentsMapper.java
View File

@@ -1,21 +0,0 @@
package com.bao.dating.mapper;
import com.bao.dating.pojo.entity.Comments;
import org.apache.ibatis.annotations.*;
import java.util.List;
public interface CommentsMapper {
// 添加评论
@Insert("INSERT INTO comments(content, user_id, post_id, created_at) VALUES(#{content}, #{user_id}, #{post_id}, #{created_at})")
int addComment(Comments comments);
// 删除评论
@Delete("DELETE FROM comments WHERE user_id = #{user_id}")
int deleteComments(@Param("user_id") Long user_id);
// 根据动态ID查询评论列表
@Select("SELECT * FROM comments WHERE post_id = #{post_id} ORDER BY created_at DESC")
List<Comments> getCommentsByPostId(@Param("post_id") Long post_id);
}

16
src/main/java/com/bao/dating/mapper/NoticeMapper.java Normal file
View File

@@ -0,0 +1,16 @@
package com.bao.dating.mapper;
import com.bao.dating.pojo.entity.Notice;
import java.util.List;
/**
* 公告Mapper接口
*/
public interface NoticeMapper {
/**
* 查询所有公告
* @return 公告列表
*/
List<Notice> selectNoticeList();
}

6
src/main/java/com/bao/dating/mapper/PostMapper.java
View File

@@ -4,8 +4,6 @@ import com.bao.dating.pojo.entity.Post;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface PostMapper {
/**
@@ -18,9 +16,9 @@ public interface PostMapper {
/**
* 根据ID删除动态
*
* @param postIds 动态ID
* @param postId 动态ID
*/
int deletePostByIds(@Param("postIds") List<Long> postIds);
void deletePostById(@Param("postId") Long postId);
/**
* 根据ID查询动态

16
src/main/java/com/bao/dating/mapper/UserMapper.java
View File

@@ -1,16 +0,0 @@
package com.bao.dating.mapper;
import com.bao.dating.pojo.entity.User;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UserMapper {
/**
* 根据用户名查询用户
*
* @param username 用户名
* @return 用户
*/
User getByUsername(String username);
}

3
src/main/java/com/bao/dating/pojo/dto/PostRequestDTO.java
View File

@@ -2,14 +2,13 @@ package com.bao.dating.pojo.dto;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 动态数据传输对象
*/
@Data
public class PostRequestDTO implements Serializable {
public class PostRequestDTO {
private String content;
private List<String> mediaOssKeys;
private List<String> tags;

14
src/main/java/com/bao/dating/pojo/dto/UserLoginDTO.java
View File

@@ -1,14 +0,0 @@
package com.bao.dating.pojo.dto;
import lombok.Data;
import java.io.Serializable;
/**
* 用户登录数据传输对象
*/
@Data
public class UserLoginDTO implements Serializable {
private String username;
private String password;
}

20
src/main/java/com/bao/dating/pojo/entity/Comments.java
View File

@@ -1,20 +0,0 @@
package com.bao.dating.pojo.entity;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
* 评论表
*/
@Data
public class Comments implements Serializable {
private Long comment_id; // 评论ID
private String content; // 评论内容
private Long user_id; // 评论人ID
private Long post_id; // 关联动态ID
private LocalDateTime created_at; // 评论时间
}

40
src/main/java/com/bao/dating/pojo/entity/Notice.java Normal file
View File

@@ -0,0 +1,40 @@
package com.bao.dating.pojo.entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.util.Date;
/**
* 公告实体类
*/
@Data
public class Notice {
/**
* 公告ID
*/
private Long noticeId;
/**
* 公告标题
*/
private String noticeTitle;
/**
* 公告内容
*/
private String noticeContent;
/**
* 状态（0正常 1关闭）
*/
private String noticeStatus;
/**
* 创建时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 更新时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
}

3
src/main/java/com/bao/dating/pojo/entity/Post.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.pojo.entity;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;
@@ -11,7 +10,7 @@ import java.util.List;
* @author KilLze
*/
@Data
public class Post implements Serializable {
public class Post {
private Long postId;

3
src/main/java/com/bao/dating/pojo/entity/PostFavorite.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.pojo.entity;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
@@ -10,7 +9,7 @@ import java.time.LocalDateTime;
* @author KilLze
*/
@Data
public class PostFavorite implements Serializable {
public class PostFavorite {
private Long favoriteId;

3
src/main/java/com/bao/dating/pojo/entity/PostLike.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.pojo.entity;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
@@ -10,7 +9,7 @@ import java.time.LocalDateTime;
* @author KilLze
*/
@Data
public class PostLike implements Serializable {
public class PostLike {
private Long likeId;
private Long userId;

7
src/main/java/com/bao/dating/pojo/entity/User.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.pojo.entity;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
@@ -11,7 +10,7 @@ import java.time.LocalDateTime;
* @author KilLze
*/
@Data
public class User implements Serializable {
public class User {
private Long userId;
@@ -38,8 +37,4 @@ public class User implements Serializable {
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String userEmail;
private String userPhone;
}

3
src/main/java/com/bao/dating/pojo/vo/PostEditVO.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.pojo.vo;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;
@@ -10,7 +9,7 @@ import java.util.List;
* 修改内容查询返回数据
*/
@Data
public class PostEditVO implements Serializable {
public class PostEditVO {
private Long postId;
private String content;
private List<String> mediaOssKeys;

14
src/main/java/com/bao/dating/pojo/vo/UserLoginVO.java
View File

@@ -1,14 +0,0 @@
package com.bao.dating.pojo.vo;
import lombok.Data;
import java.io.Serializable;
/**
* 登录返回数据
*/
@Data
public class UserLoginVO implements Serializable {
private Long userId;
private String nickname;
private String token;
}

20
src/main/java/com/bao/dating/service/CommentsService.java
View File

@@ -1,20 +0,0 @@
package com.bao.dating.service;
import com.bao.dating.pojo.entity.Comments;
import java.util.List;
public interface CommentsService{
// 添加评论
boolean addComment(Comments comments);
// 删除评论
boolean deleteComment(Long user_id);
// 根据动态ID查询评论
List<Comments> getCommentByPostId(Long post_id);
}

16
src/main/java/com/bao/dating/service/NoticeService.java Normal file
View File

@@ -0,0 +1,16 @@
package com.bao.dating.service;
import com.bao.dating.pojo.entity.Notice;
import java.util.List;
/**
* 公告服务接口
*/
public interface NoticeService {
/**
* 查询所有公告
* @return 公告列表
*/
List<Notice> getNoticeList();
}

10
src/main/java/com/bao/dating/service/PostService.java
View File

@@ -17,18 +17,20 @@ public interface PostService {
/**
* 创建动态
* @param userId 用户ID
* @param postRequestDTO 动态数据传输对象
* @return 创建的动态对象
*/
Post createPost(PostRequestDTO postRequestDTO);
Post createPost(Long userId, PostRequestDTO postRequestDTO);
/**
* 批量删除动态
* @param postIds 动态ID
* 删除动态
* @param postId 动态ID
* @return 删除的动态对象
*/
int deletePostById(List<Long> postIds);
void deletePostById(Long postId);
void deletePostById(Integer postId);
/**
* 查询动态详情（用于编辑）

13
src/main/java/com/bao/dating/service/UserService.java
View File

@@ -1,13 +0,0 @@
package com.bao.dating.service;
import com.bao.dating.pojo.dto.UserLoginDTO;
import com.bao.dating.pojo.vo.UserLoginVO;
public interface UserService {
/**
* 登录
* @param userLoginDTO 登录参数
* @return 登录结果
*/
UserLoginVO userLogin(UserLoginDTO userLoginDTO);
}

39
src/main/java/com/bao/dating/service/impl/CommentsServiceImpl.java
View File

@@ -1,39 +0,0 @@
package com.bao.dating.service.impl;
import com.bao.dating.pojo.entity.Comments;
import com.bao.dating.mapper.CommentsMapper;
import com.bao.dating.service.CommentsService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
@Service
public class CommentsServiceImpl implements CommentsService {
@Resource
private CommentsMapper commentsMapper;
@Override
public boolean addComment(Comments comments) {
// 设置创建时间
comments.setCreated_at(LocalDateTime.now());
return commentsMapper.addComment(comments) > 0;
}
@Override
public boolean deleteComment(Long user_id) {
return commentsMapper.deleteComments(user_id) > 0;
}
@Override
public List<Comments> getCommentByPostId(Long post_id) {
return commentsMapper.getCommentsByPostId(post_id);
}
}

18
src/main/java/com/bao/dating/service/impl/NoticeServiceImpl.java Normal file
View File

@@ -0,0 +1,18 @@
package com.bao.dating.service.impl;
import com.bao.dating.mapper.NoticeMapper;
import com.bao.dating.pojo.entity.Notice;
import com.bao.dating.service.NoticeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class NoticeServiceImpl implements NoticeService {
@Autowired
private NoticeMapper noticeMapper;
@Override
public List<Notice> getNoticeList() {
return noticeMapper.selectNoticeList();
}
}

62
src/main/java/com/bao/dating/service/impl/PostServiceImpl.java
View File

@@ -2,7 +2,6 @@ package com.bao.dating.service.impl;
import com.bao.dating.common.aliyun.GreenImageScan;
import com.bao.dating.common.aliyun.GreenTextScan;
import com.bao.dating.context.UserContext;
import com.bao.dating.mapper.PostMapper;
import com.bao.dating.pojo.dto.PostRequestDTO;
import com.bao.dating.pojo.entity.Post;
@@ -13,13 +12,10 @@ import com.bao.dating.util.FileUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
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;
@@ -59,11 +55,8 @@ public class PostServiceImpl implements PostService {
try {
// 根据文件扩展名判断文件类型
String fileType = FileUtil.getFileType(file.getOriginalFilename());
// 创建目录
String dir = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM"));
// 生成唯一文件名
String newFileName = UUID.randomUUID().toString() + "." + FileUtil.getFileExtension(file.getOriginalFilename());
String fileName = "post/" + dir + "/" + newFileName;
String fileName = UUID.randomUUID().toString() + "." + FileUtil.getFileExtension(file.getOriginalFilename());
// 获取文件字节数据
byte[] fileBytes = file.getBytes();
// 根据文件类型处理
@@ -86,15 +79,15 @@ public class PostServiceImpl implements PostService {
/**
* 创建动态
*
* @param userId 用户ID
* @param postRequestDTO 动态数据传输对象
* @return 创建的动态对象
*/
@Override
public Post createPost(PostRequestDTO postRequestDTO) {
public Post createPost(Long userId, PostRequestDTO postRequestDTO) {
// 创建动态对象
Post post = new Post();
Long userId = UserContext.getUserId();
post.setUserId(userId);
post.setContent(postRequestDTO.getContent());
post.setTags(postRequestDTO.getTags());
@@ -113,6 +106,9 @@ public class PostServiceImpl implements PostService {
}
String textSuggestion = (String) textResult.get("suggestion");
if ("block".equals(textSuggestion)) {
throw new RuntimeException("动态内容违规，禁止发布");
}
// 2. 图片审核（如果有）
if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
@@ -157,50 +153,29 @@ public class PostServiceImpl implements PostService {
return post;
}
@Override
public void deletePostById(Long postId) {
postMapper.deletePostById(postId);
}
/**
* 批量删除动态
* 删除动态
*
* @param postIds 动态ID
* @param postId 动态ID
* @return 删除的动态对象
*/
@Override
@Transactional(rollbackFor = Exception.class)
public int deletePostById(List<Long> postIds) {
// 判断用户权限
Long userId = UserContext.getUserId();
// 遍历所有要删除的帖子ID，验证权限
for (Long postId : postIds) {
Post post = postMapper.selectById(postId);
if (post == null) {
throw new RuntimeException("动态不存在");
}
// 验证用户权限
if (post.getUserId() == null || !post.getUserId().equals(userId)) {
throw new RuntimeException("无权限删除此动态");
}
}
// 批量删除动态
return postMapper.deletePostByIds(postIds);
public void deletePostById(Integer postId) {
postMapper.deletePostById(postId);
}
/**
* 查询动态详情（用于编辑）
*
* @param postId 动态ID
* @return
*/
@Override
public PostEditVO getPostForEdit(Long postId) {
Post post = postMapper.selectById(postId);
if (post == null) {
throw new RuntimeException("动态不存在");
}
// 判断用户权限
Long userId = UserContext.getUserId();
if (post.getUserId() == null || !post.getUserId().equals(userId)){
throw new RuntimeException("无权限查看此动态");
}
PostEditVO postEditVO = new PostEditVO();
BeanUtils.copyProperties(post, postEditVO);
return postEditVO;
@@ -219,11 +194,6 @@ public class PostServiceImpl implements PostService {
if (post == null) {
throw new RuntimeException("动态不存在");
}
// 判断用户权限
Long userId = UserContext.getUserId();
if (post.getUserId() == null || !post.getUserId().equals(userId)){
throw new RuntimeException("无权限修改此动态");
}
post.setContent(postRequestDTO.getContent());
if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
post.setMediaOssKeys(postRequestDTO.getMediaOssKeys());

48
src/main/java/com/bao/dating/service/impl/UserServiceImpl.java
View File

@@ -1,48 +0,0 @@
package com.bao.dating.service.impl;
import com.bao.dating.mapper.UserMapper;
import com.bao.dating.pojo.dto.UserLoginDTO;
import com.bao.dating.pojo.entity.User;
import com.bao.dating.pojo.vo.UserLoginVO;
import com.bao.dating.service.UserService;
import com.bao.dating.util.JwtUtil;
import com.bao.dating.util.MD5Util;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserServiceImpl implements UserService {
@Autowired
private UserMapper userMapper;
@Override
public UserLoginVO userLogin(UserLoginDTO userLoginDTO) {
// 参数校验
if (userLoginDTO == null || userLoginDTO.getUsername() == null || userLoginDTO.getPassword() == null) {
throw new RuntimeException("用户名或密码不能为空");
}
// 查询用户
User user = userMapper.getByUsername(userLoginDTO.getUsername());
if (user == null){
throw new RuntimeException("用户不存在");
}
// 密码校验
boolean match = MD5Util.verifyWithSalt(
userLoginDTO.getPassword(),
user.getSalt(),
user.getPasswordHash()
);
if (!match){
throw new RuntimeException("密码错误");
}
// 生成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;
}
}

178
src/main/java/com/bao/dating/util/EmailUtil.java
View File

@@ -1,178 +0,0 @@
package com.bao.dating.util;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Component;
import javax.mail.MessagingException;
import javax.mail.internet.MimeMessage;
import java.io.File;
/**
* 邮箱工具类
* 提供邮件发送功能（支持普通文本邮件和HTML邮件）
* @author KilLze
*/
@Slf4j
@Component
public class EmailUtil {
/**
* 邮件发送器（由Spring自动注入）
*/
private final JavaMailSender mailSender;
/**
* 发件人邮箱地址（从配置中读取）
*/
private final String from;
/**
* 构造函数，用于注入JavaMailSender和配置
* @param mailSender 邮件发送器
* @param from 发件人邮箱地址
*/
public EmailUtil(JavaMailSender mailSender, @Value("${spring.mail.username}") String from) {
this.mailSender = mailSender;
this.from = from;
}
/**
* 发送简单文本邮件
* @param to 收件人邮箱地址
* @param subject 邮件主题
* @param text 邮件内容
* @return 是否发送成功
*/
public boolean sendSimpleMail(String to, String subject, String text) {
try {
SimpleMailMessage message = new SimpleMailMessage();
message.setFrom(from);
message.setTo(to);
message.setSubject(subject);
message.setText(text);
mailSender.send(message);
log.info("简单邮件发送成功，收件人：{}，主题：{}", to, subject);
return true;
} catch (Exception e) {
log.error("简单邮件发送失败，收件人：{}，异常信息：{}", to, e.getMessage(), e);
return false;
}
}
/**
* 发送HTML格式邮件
* @param to 收件人邮箱地址
* @param subject 邮件主题
* @param htmlContent HTML内容
* @return 是否发送成功
*/
public boolean sendHtmlMail(String to, String subject, String htmlContent) {
try {
MimeMessage message = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(message, true, "UTF-8");
helper.setFrom(from);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(htmlContent, true);
mailSender.send(message);
log.info("HTML邮件发送成功，收件人：{}，主题：{}", to, subject);
return true;
} catch (MessagingException e) {
log.error("HTML邮件发送失败，收件人：{}，异常信息：{}", to, e.getMessage(), e);
return false;
}
}
/**
* 发送带附件的邮件
* @param to 收件人邮箱地址
* @param subject 邮件主题
* @param text 邮件内容
* @param attachmentPath 附件文件路径
* @param attachmentName 附件显示名称
* @return 是否发送成功
*/
public boolean sendMailWithAttachment(String to, String subject, String text,
String attachmentPath, String attachmentName) {
try {
MimeMessage message = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(message, true, "UTF-8");
helper.setFrom(from);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(text);
File file = new File(attachmentPath);
if (file.exists()) {
helper.addAttachment(attachmentName, file);
} else {
log.warn("附件文件不存在：{}", attachmentPath);
return false;
}
mailSender.send(message);
log.info("带附件邮件发送成功，收件人：{}，主题：{}，附件：{}", to, subject, attachmentName);
return true;
} catch (MessagingException e) {
log.error("带附件邮件发送失败，收件人：{}，异常信息：{}", to, e.getMessage(), e);
return false;
}
}
/**
* 发送验证码邮件
* @param to 收件人邮箱地址
* @param code 验证码
* @return 是否发送成功
*/
public boolean sendVerificationCode(String to, String code) {
String subject = "验证码";
String htmlContent = String.format(
"<html><body>" +
"<h2>您的验证码</h2>" +
"<p>验证码：<strong style='color: #1890ff; font-size: 24px;'>%s</strong></p>" +
"<p>验证码有效期为10分钟，请勿泄露给他人。</p>" +
"</body></html>", code);
return sendHtmlMail(to, subject, htmlContent);
}
/**
* 发送验证码邮件（自定义主题）
* @param to 收件人邮箱地址
* @param code 验证码
* @param subject 邮件主题
* @return 是否发送成功
*/
public boolean sendVerificationCode(String to, String code, String subject) {
String htmlContent = String.format(
"<html><body>" +
"<h2>您的验证码</h2>" +
"<p>验证码：<strong style='color: #1890ff; font-size: 24px;'>%s</strong></p>" +
"<p>验证码有效期为10分钟，请勿泄露给他人。</p>" +
"</body></html>", code);
return sendHtmlMail(to, subject, htmlContent);
}
/**
* 批量发送邮件
* @param toList 收件人邮箱地址数组
* @param subject 邮件主题
* @param text 邮件内容
* @return 成功发送的数量
*/
public int sendBatchMail(String[] toList, String subject, String text) {
int successCount = 0;
for (String to : toList) {
if (sendSimpleMail(to, subject, text)) {
successCount++;
}
}
log.info("批量邮件发送完成，总数：{}，成功：{}", toList.length, successCount);
return successCount;
}
}

204
src/main/java/com/bao/dating/util/JwtUtil.java
View File

@@ -1,204 +0,0 @@
package com.bao.dating.util;
import io.jsonwebtoken.Claims;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm;
import io.jsonwebtoken.security.Keys;
import javax.crypto.SecretKey;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
/**
* JWT工具类
* 提供JWT Token的生成、解析和验证功能
* @author KilLze
*/
public class JwtUtil {
/**
* 默认密钥（建议从配置文件读取）
*/
private static final String DEFAULT_SECRET = "dating-application-secret-key-for-jwt-token-generation-2025";
/**
* 默认过期时间（毫秒）- 7天
*/
private static final long DEFAULT_EXPIRATION = 7 * 24 * 60 * 60 * 1000L;
/**
* 生成JWT Token
* @param subject 主题（通常是用户ID或用户名）
* @return JWT Token字符串
*/
public static String generateToken(String subject) {
return generateToken(subject, DEFAULT_EXPIRATION);
}
/**
* 生成JWT Token（自定义过期时间）
* @param subject 主题（通常是用户ID或用户名）
* @param expiration 过期时间（毫秒）
* @return JWT Token字符串
*/
public static String generateToken(String subject, long expiration) {
return generateToken(subject, expiration, null);
}
/**
* 生成JWT Token（带自定义claims）
* @param subject 主题（通常是用户ID或用户名）
* @param expiration 过期时间（毫秒）
* @param claims 自定义claims
* @return JWT Token字符串
*/
public static String generateToken(String subject, long expiration, Map<String, Object> claims) {
Date now = new Date();
Date expiryDate = new Date(now.getTime() + expiration);
SecretKey key = getSecretKey();
if (claims == null) {
claims = new HashMap<>();
}
return Jwts.builder()
.setClaims(claims)
.setSubject(subject)
.setIssuedAt(now)
.setExpiration(expiryDate)
.signWith(key, SignatureAlgorithm.HS256)
.compact();
}
/**
* 生成JWT Token（使用自定义密钥）
* @param subject 主题
* @param expiration 过期时间（毫秒）
* @param secret 自定义密钥
* @return JWT Token字符串
*/
public static String generateTokenWithSecret(String subject, long expiration, String secret) {
Date now = new Date();
Date expiryDate = new Date(now.getTime() + expiration);
SecretKey key = getSecretKey(secret);
return Jwts.builder()
.setSubject(subject)
.setIssuedAt(now)
.setExpiration(expiryDate)
.signWith(key, SignatureAlgorithm.HS256)
.compact();
}
/**
* 从Token中获取Claims
* @param token JWT Token
* @return Claims对象
*/
public static Claims getClaimsFromToken(String token) {
return getClaimsFromToken(token, DEFAULT_SECRET);
}
/**
* 从Token中获取Claims（使用自定义密钥）
* @param token JWT Token
* @param secret 密钥
* @return Claims对象
*/
public static Claims getClaimsFromToken(String token, String secret) {
try {
SecretKey key = getSecretKey(secret);
return Jwts.parserBuilder()
.setSigningKey(key)
.build()
.parseClaimsJws(token)
.getBody();
} catch (Exception e) {
throw new RuntimeException("解析JWT Token失败", e);
}
}
/**
* 从Token中获取主题（通常是用户ID）
* @param token JWT Token
* @return 主题字符串
*/
public static String getSubjectFromToken(String token) {
Claims claims = getClaimsFromToken(token);
return claims.getSubject();
}
/**
* 验证Token是否有效
* @param token JWT Token
* @return 是否有效
*/
public static boolean validateToken(String token) {
return validateToken(token, DEFAULT_SECRET);
}
/**
* 验证Token是否有效（使用自定义密钥）
* @param token JWT Token
* @param secret 密钥
* @return 是否有效
*/
public static boolean validateToken(String token, String secret) {
try {
Claims claims = getClaimsFromToken(token, secret);
return !isTokenExpired(claims);
} catch (Exception e) {
return false;
}
}
/**
* 检查Token是否过期
* @param claims Claims对象
* @return 是否过期
*/
private static boolean isTokenExpired(Claims claims) {
Date expiration = claims.getExpiration();
return expiration.before(new Date());
}
/**
* 获取Token的过期时间
* @param token JWT Token
* @return 过期时间
*/
public static Date getExpirationDateFromToken(String token) {
Claims claims = getClaimsFromToken(token);
return claims.getExpiration();
}
/**
* 获取默认密钥的SecretKey对象
* @return SecretKey对象
*/
private static SecretKey getSecretKey() {
return getSecretKey(DEFAULT_SECRET);
}
/**
* 根据字符串密钥生成SecretKey对象
* @param secret 密钥字符串
* @return SecretKey对象
*/
private static SecretKey getSecretKey(String secret) {
// 确保密钥长度至少为256位（32字节）以支持HS256算法
byte[] keyBytes = secret.getBytes(StandardCharsets.UTF_8);
if (keyBytes.length < 32) {
// 如果密钥太短，进行填充
byte[] paddedKey = new byte[32];
System.arraycopy(keyBytes, 0, paddedKey, 0, Math.min(keyBytes.length, 32));
return Keys.hmacShaKeyFor(paddedKey);
}
return Keys.hmacShaKeyFor(keyBytes);
}
}

93
src/main/java/com/bao/dating/util/MD5Util.java
View File

@@ -1,93 +0,0 @@
package com.bao.dating.util;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
/**
* MD5工具类
* 提供MD5加密功能
* @author KilLze
*/
public class MD5Util {
/**
* 对字符串进行MD5加密
* @param input 待加密的字符串
* @return MD5加密后的32位小写字符串
*/
public static String encrypt(String input) {
if (input == null || input.isEmpty()) {
return null;
}
try {
MessageDigest md = MessageDigest.getInstance("MD5");
byte[] digest = md.digest(input.getBytes());
return bytesToHex(digest);
} catch (NoSuchAlgorithmException e) {
throw new RuntimeException("MD5算法不可用", e);
}
}
/**
* 对字符串进行MD5加密（带盐值）
* @param input 待加密的字符串
* @param salt 盐值
* @return MD5加密后的32位小写字符串
*/
public static String encryptWithSalt(String input, String salt) {
if (input == null || input.isEmpty()) {
return null;
}
if (salt == null) {
salt = "";
}
return encrypt(input + salt);
}
/**
* 验证字符串与MD5值是否匹配
* @param input 原始字符串
* @param md5Hash MD5哈希值
* @return 是否匹配
*/
public static boolean verify(String input, String md5Hash) {
if (input == null || md5Hash == null) {
return false;
}
return encrypt(input).equalsIgnoreCase(md5Hash);
}
/**
* 验证字符串与MD5值是否匹配（带盐值）
* @param input 原始字符串
* @param salt 盐值
* @param md5Hash MD5哈希值
* @return 是否匹配
*/
public static boolean verifyWithSalt(String input, String salt, String md5Hash) {
if (input == null || md5Hash == null) {
return false;
}
if (salt == null) {
salt = "";
}
return encryptWithSalt(input, salt).equalsIgnoreCase(md5Hash);
}
/**
* 将字节数组转换为十六进制字符串
* @param bytes 字节数组
* @return 十六进制字符串
*/
private static String bytesToHex(byte[] bytes) {
StringBuilder sb = new StringBuilder();
for (byte b : bytes) {
sb.append(String.format("%02x", b));
}
return sb.toString();
}
}

39
src/main/resources/application.yml
View File

@@ -7,38 +7,6 @@ spring:
username: root
password: JoyeeServe2025
driver-class-name: com.mysql.cj.jdbc.Driver
redis:
host: 127.0.0.1
port: 6379
password: ""
database: 0
timeout: 10000
# 连接池配置（lettuce是Spring Boot默认Redis客户端，性能更优）
lettuce:
pool:
max-active: 8 # 连接池最大连接数（默认8，可根据业务并发调整）
max-wait: -1 # 连接池最大阻塞等待时间（毫秒，-1表示无限制）
max-idle: 8 # 连接池最大空闲连接数（默认8）
min-idle: 1 # 连接池最小空闲连接数（默认0，建议设置1-4，提高连接复用率）
# 邮箱SMTP配置
mail:
host: smtp.163.com # QQ邮箱SMTP服务器地址
port: 465 # SMTP端口
username: 19271189822@163.com # 发件人邮箱
password: CAwXh39PXajy3fyH # 邮箱授权码
default-encoding: UTF-8
properties:
mail:
smtp:
auth: true
starttls:
enable: true
required: true
ssl:
enable: true # 使用587端口时设为false，使用465端口时设为true
connectiontimeout: 10000 # 连接超时时间（毫秒）
timeout: 10000 # 读取超时时间（毫秒）
writetimeout: 10000 # 写入超时时间（毫秒）
# MyBatis 配置
mybatis:
@@ -58,10 +26,3 @@ aliyun:
accessKeyId: LTAI5t5vpcbCZwweNHEDDDaF
secret: bBHBAPiCqGyVBHUv07348wsHXkKqrk
scenes: antispam
# 阿里云短信服务配置
sms:
access-key-id: LTAI5t5vpcbCZwweNHEDDDaF
access-key-secret: bBHBAPiCqGyVBHUv07348wsHXkKqrk
region-id: cn-hangzhou
sign-name: 速通互联验证码
template-code: 100001

20
src/main/resources/com/bao/dating/mapper/NoticeMapper.xml Normal file
View File

@@ -0,0 +1,20 @@
<?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.NoticeMapper">
<!-- 通用查询结果列 -->
<sql id="Notice_Column_List">
notice_id, notice_title, notice_content, notice_status, create_time, update_time
</sql>
<!-- 查询所有公告 -->
<select id="selectNoticeList" resultType="com.bao.dating.pojo.entity.Notice">
select
<include refid="Notice_Column_List"/>
from sys_notice
where notice_status = '0'
order by create_time desc
</select>
</mapper>

19
src/main/resources/com/bao/dating/mapper/PostMapper.xml
View File

@@ -29,23 +29,8 @@
</insert>
<!--动态删除-->
<delete id="deletePostByIds">
DELETE FROM post WHERE post_id IN
<foreach item="postId" index="index" collection="postIds" separator="," open="(" close=")">
#{postId}
</foreach>
</delete>
<!--删除收藏记录-->
<delete id="1">
DELETE FROM post_favorite WHERE post_id = #{postId}
</delete>
<!--删除点赞记录-->
<delete id="2">
DELETE FROM post_like WHERE post_id = #{postId}
</delete>
<!--动态评论删除-->
<delete id="3">
DELETE FROM comments WHERE post_id = #{postId}
<delete id="deletePostById">
DELETE FROM post WHERE post_id = #{postId}
</delete>
<!--动态查询-->

11
src/main/resources/com/bao/dating/mapper/UserMapper.xml
View File

@@ -1,11 +0,0 @@
<?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.UserMapper">
<select id="getByUsername" resultType="com.bao.dating.pojo.entity.User">
SELECT * FROM user WHERE user_name = #{userName}
</select>
</mapper>

77
src/test/java/com/bao/dating/util/EmailAndSmsTest.java
View File

@@ -1,77 +0,0 @@
package com.bao.dating.util;
import com.bao.dating.common.aliyun.SmsUtil;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.util.HashMap;
import java.util.Map;
/**
* 邮箱和短信发送测试类
* @author KilLze
*/
@SpringBootTest
public class EmailAndSmsTest {
@Autowired
private EmailUtil emailUtil;
@Autowired
private SmsUtil smsUtil;
/**
* 测试发送简单文本邮件
*/
@Test
public void testSendSimpleMail() {
String to = "n_1127@qq.com";
String subject = "测试邮件 - 简单文本";
String text = "这是一封测试邮件，用于测试简单文本邮件发送功能。\n\n如果您收到此邮件，说明邮件发送功能正常。";
boolean result = emailUtil.sendSimpleMail(to, subject, text);
System.out.println("简单邮件发送结果: " + (result ? "成功" : "失败"));
}
/**
* 测试发送HTML格式邮件
*/
@Test
public void testSendHtmlMail() {
String to = "n_1127@qq.com";
String subject = "测试邮件 - HTML格式";
String htmlContent = "<html><body>" +
"<h2 style='color: #1890ff;'>欢迎使用我们的服务</h2>" +
"<p>这是一封<strong>HTML格式</strong>的测试邮件。</p>" +
"<p>邮件内容支持：</p>" +
"<ul>" +
"<li>HTML标签</li>" +
"<li>样式设置</li>" +
"<li>富文本内容</li>" +
"</ul>" +
"<p style='color: #999;'>感谢您的使用！</p>" +
"</body></html>";
boolean result = emailUtil.sendHtmlMail(to, subject, htmlContent);
System.out.println("HTML邮件发送结果: " + (result ? "成功" : "失败"));
}
/**
* 测试发送验证码邮件
*/
@Test
public void testSendVerificationCodeEmail() {
String to = "n_1127@qq.com";
String code = "123456";
boolean result = emailUtil.sendVerificationCode(to, code);
System.out.println("验证码邮件发送结果: " + (result ? "成功" : "失败"));
System.out.println("验证码: " + code);
}
}