将删除动态优化为批量删除动态

动态图片存放在post/下的/yyyy/MM目录中

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

@@ -1,4 +1,4 @@
-package com.bao.dating.util;
+package com.bao.dating.common.aliyun;
 
 import com.aliyun.oss.ClientException;
 import com.aliyun.oss.OSS;
@@ -7,12 +7,17 @@ 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;
 
 @Data
-@AllArgsConstructor
 @Slf4j
+@Component
+@ConfigurationProperties(prefix = "aliyun.oss")
 public class AliOssUtil {
 
     private String endpoint;
@@ -27,7 +32,6 @@ public class AliOssUtil {
      * @return 完整的文件访问URL
      */
     public String upload(byte[] bytes, String objectName) {
-
         // 创建OSSClient实例。
         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
 

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

@@ -61,19 +61,24 @@ public class GreenImageScan {
 
             if (scanImageResponse.getStatusCode() == 200) {
 
-                List<ScanImageResponseBody.ScanImageResponseBodyDataResultsSubResults> subResults = scanImageResponse.body.data.results.get(0).getSubResults();
+                List<ScanImageResponseBody.ScanImageResponseBodyDataResults> results = scanImageResponse.body.data.results;
 
-                ListIterator<ScanImageResponseBody.ScanImageResponseBodyDataResultsSubResults> listIterator = subResults.listIterator();
+                // 遍历每一张图片的审核结果
-                while (listIterator.hasNext()) {
+                for (ScanImageResponseBody.ScanImageResponseBodyDataResults result : results) {
-                    ScanImageResponseBody.ScanImageResponseBodyDataResultsSubResults item = listIterator.next();
+                    List<ScanImageResponseBody.ScanImageResponseBodyDataResultsSubResults> subResults = result.getSubResults();
                     
-                    if (!item.suggestion.equals("pass")) {
+                    // 检查这张图片的所有子审核项
-                        resultMap.put("suggestion", item.suggestion);
+                    for (ScanImageResponseBody.ScanImageResponseBodyDataResultsSubResults subResult : subResults) {
-                        resultMap.put("label", item.label);
+                        // 如果有任何一项未通过审核，则整个审核不通过
-                        return resultMap;
+                        if (!subResult.suggestion.equals("pass")) {
+                            resultMap.put("suggestion", subResult.suggestion);
+                            resultMap.put("label", subResult.label);
+                            return resultMap;
+                        }
                     }
                 }
-                // 所有审核项都通过时，返回pass结果
+                
+                // 所有图片的所有审核项都通过时，返回pass结果
                 resultMap.put("suggestion", "pass");
                 resultMap.put("label", "normal");
                 return resultMap;

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

@@ -1,26 +0,0 @@
-package com.bao.dating.config;
-
-
-import com.bao.dating.properties.AliOssProperties;
-import com.bao.dating.util.AliOssUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * 配置类，用于创建AliOssUtil对象
- */
-@Configuration
-@Slf4j
-public class OssConfiguration {
-    @Bean
-    @ConditionalOnMissingBean
-    public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){
-        log.info("开始创建阿里云文件上传工具类对象：{}",aliOssProperties);
-        return new AliOssUtil(aliOssProperties.getEndpoint(),
-                aliOssProperties.getAccessKeyId(),
-                aliOssProperties.getAccessKeySecret(),
-                aliOssProperties.getBucketName());
-    }
-}

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

@@ -5,6 +5,7 @@ import com.bao.dating.common.Result;
 import com.bao.dating.common.ResultCode;
 import com.bao.dating.pojo.dto.PostRequestDTO;
 import com.bao.dating.pojo.entity.Post;
+import com.bao.dating.pojo.vo.PostEditVO;
 import com.bao.dating.service.PostService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -32,25 +33,49 @@ public class PostController {
 
     /**
      * 发布动态接口 - JSON格式请求
-     * @param postRequestDTO 动态信息
+     * @param postDTO 动态信息
+     * @param userId 用户ID
      * @return 发布的动态对象
      */
     @PostMapping(consumes = "application/json")
-    public Result<Post> createPostJson(@RequestBody PostRequestDTO postRequestDTO) {
+    public Result<Post> createPostJson(@RequestBody PostRequestDTO postDTO, @RequestParam Long userId) {
         // 调用 Service 层处理发布动态业务逻辑
-        Post result = postService.createPost(postRequestDTO);
+        Post result = postService.createPost(userId, postDTO);
         return Result.success(ResultCode.SUCCESS_REVIEW, "动态发布成功，等待审核。", result);
     }
 
     /**
-     * 删除动态
+     * 批量删除动态
      *
-     * @param postId 动态ID
+     * @param postIds 动态ID
      * @return 删除结果
      */
-    @DeleteMapping("/{postId}")
+    @DeleteMapping
-    public Result<String> deleteById(@PathVariable Integer postId){
+    public Result<String> deleteById(@RequestParam List<Long> postIds){
-        postService.deletePostById(postId);
+        postService.deletePostById(postIds);
         return Result.success(ResultCode.SUCCESS_DELETE, "动态删除成功", null);
     }
+
+    /**
+     * 根据ID查询动态接口
+     * @param postId 动态ID
+     * @return 动态对象
+     */
+    @GetMapping("/{postId}")
+    public Result<PostEditVO> getPostById(@PathVariable Long postId) {
+        PostEditVO postEditVO = postService.getPostForEdit(postId);
+        return Result.success(ResultCode.SUCCESS,"查询成功", postEditVO);
+    }
+    
+    /**
+     * 更新动态接口
+     * @param postId 动态ID
+     * @param postRequestDTO 动态信息
+     * @return 更新后的动态对象
+     */
+    @PutMapping("/{postId}")
+    public Result<PostEditVO> updatePost(@PathVariable Long postId, @RequestBody PostRequestDTO postRequestDTO) {
+        PostEditVO result = postService.updatePost(postId, postRequestDTO);
+        return Result.success(ResultCode.SUCCESS_REVIEW, "动态更新成功", result);
+    }
 }

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

@@ -2,24 +2,41 @@ package com.bao.dating.mapper;
 
 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 {
     /**
      * 插入动态
      *
-     * @param post 动态对象
+     * @param post
-     * @return 插入的行数
      */
-    int insert(Post post);
+    void insert(Post post);
 
     /**
      * 根据ID删除动态
      *
-     * @param postId 动态ID
+     * @param postIds 动态ID
-     * @return 删除的行数
      */
-    int deletePostById(Integer postId);
+    void deletePostByIds(@Param("postIds") List<Long> postIds);
+
+    /**
+     * 根据ID查询动态
+     *
+     * @param postId
+     * @return
+     */
+    Post selectById(@Param("postId") Long postId);
+
+    /**
+     * 根据ID更新动态
+     *
+     * @param post
+     * @return
+     */
+    void updateById(Post post);
 
     /**
      * 查询点赞数

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

@@ -1,14 +1,15 @@
 package com.bao.dating.pojo.dto;
 
 import lombok.Data;
-import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
+/**
+ * 动态数据传输对象
+ */
 @Data
 public class PostRequestDTO {
-    private Long userId;
     private String content;
+    private List<String> mediaOssKeys;
     private List<String> tags;
-    private List<String> mediaUrls;
 }

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

@@ -0,0 +1,19 @@
+package com.bao.dating.pojo.vo;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 修改内容查询返回数据
+ */
+@Data
+public class PostEditVO {
+    private Long postId;
+    private String content;
+    private List<String> mediaOssKeys;
+    private List<String> tags;
+    private Integer isPublic;
+    private LocalDateTime updatedAt;
+}

src/main/java/com/bao/dating/properties/AliOssProperties.java

@@ -1,15 +0,0 @@
-package com.bao.dating.properties;
-
-import lombok.Data;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.stereotype.Component;
-
-@Component
-@ConfigurationProperties(prefix = "aliyun.oss")
-@Data
-public class AliOssProperties {
-    private String endpoint;
-    private String accessKeyId;
-    private String accessKeySecret;
-    private String bucketName;
-}

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

@@ -2,6 +2,7 @@ package com.bao.dating.service;
 
 import com.bao.dating.pojo.dto.PostRequestDTO;
 import com.bao.dating.pojo.entity.Post;
+import com.bao.dating.pojo.vo.PostEditVO;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
@@ -16,15 +17,30 @@ public interface PostService {
 
     /**
      * 创建动态
-     * @param postRequestDTO 动态请求数据传输对象
+     * @param userId 用户ID
+     * @param postRequestDTO 动态数据传输对象
      * @return 创建的动态对象
      */
-    Post createPost(PostRequestDTO postRequestDTO);
+    Post createPost(Long userId, PostRequestDTO postRequestDTO);
 
     /**
      * 删除动态
-     * @param postId 动态ID
+     * @param postIds 动态ID
      * @return 删除的动态对象
      */
-    void deletePostById(Integer postId);
+    void deletePostById(List<Long> postIds);
+
+    /**
+     * 查询动态详情（用于编辑）
+     * @param postId 动态ID
+     */
+    PostEditVO getPostForEdit(Long postId);
+
+    /**
+     * 修改动态
+     * @param postId 动态ID
+     * @param postRequestDTO 修改的动态数据传输对象
+     * @return 修改后的动态对象
+     */
+    PostEditVO updatePost(Long postId, PostRequestDTO postRequestDTO);
 }

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

@@ -5,15 +5,20 @@ import com.bao.dating.common.aliyun.GreenTextScan;
 import com.bao.dating.mapper.PostMapper;
 import com.bao.dating.pojo.dto.PostRequestDTO;
 import com.bao.dating.pojo.entity.Post;
+import com.bao.dating.pojo.vo.PostEditVO;
 import com.bao.dating.service.PostService;
-import com.bao.dating.util.AliOssUtil;
+import com.bao.dating.common.aliyun.AliOssUtil;
 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;
@@ -53,8 +58,11 @@ public class PostServiceImpl implements PostService {
                     try {
                         // 根据文件扩展名判断文件类型
                         String fileType = FileUtil.getFileType(file.getOriginalFilename());
+                        // 创建目录
+                        String dir = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM"));
                         // 生成唯一文件名
-                        String fileName = UUID.randomUUID().toString() + "." + FileUtil.getFileExtension(file.getOriginalFilename());
+                        String newFileName = UUID.randomUUID().toString() + "." + FileUtil.getFileExtension(file.getOriginalFilename());
+                        String fileName = "post/" + dir + "/" + newFileName;
                         // 获取文件字节数据
                         byte[] fileBytes = file.getBytes();
                         // 根据文件类型处理
@@ -77,11 +85,23 @@ public class PostServiceImpl implements PostService {
     /**
      * 创建动态
      *
-     * @param postRequestDTO 动态请求数据传输对象
+     * @param userId 用户ID
+     * @param postRequestDTO 动态数据传输对象
      * @return 创建的动态对象
      */
     @Override
-    public Post createPost(PostRequestDTO postRequestDTO) {
+    public Post createPost(Long userId, PostRequestDTO postRequestDTO) {
+
+        // 创建动态对象
+        Post post = new Post();
+        post.setUserId(userId);
+        post.setContent(postRequestDTO.getContent());
+        post.setTags(postRequestDTO.getTags());
+        post.setMediaOssKeys(new ArrayList<>());
+        // 如果有传入的媒体链接，则使用它们
+        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
+            post.setMediaOssKeys(postRequestDTO.getMediaOssKeys());
+        }
 
         // 1. 文本内容审核
         Map textResult;
@@ -90,45 +110,45 @@ public class PostServiceImpl implements PostService {
         } catch (Exception e) {
             throw new RuntimeException("文本审核失败");
         }
-
+        // 文本审核结果
         String textSuggestion = (String) textResult.get("suggestion");
-        if ("block".equals(textSuggestion)) {
-            throw new RuntimeException("动态内容违规，禁止发布");
-        }
 
         // 2. 图片审核（如果有）
-        if (postRequestDTO.getMediaUrls() != null && !postRequestDTO.getMediaUrls().isEmpty()) {
+        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
             Map imageResult;
             try {
-                imageResult = greenImageScan.imageScan(postRequestDTO.getMediaUrls());
+                imageResult = greenImageScan.imageScan(postRequestDTO.getMediaOssKeys());
             } catch (Exception e) {
                 throw new RuntimeException(e);
             }
+            // 图片审核结果
+            String imageSuggestion = (String) imageResult.get("suggestion");
             
-            if ("block".equals(imageResult.get("suggestion"))) {
+            // 根据审核结果设置状态
-                throw new RuntimeException("图片内容违规，禁止发布");
+            if ("block".equals(textSuggestion) || "block".equals(imageSuggestion)) {
+                // 审核未通过，允许用户修改
+                post.setIsPublic(2);
+            } else if ("review".equals(textSuggestion) || "review".equals(imageSuggestion)) {
+                // 待审核，需人工审核
+                post.setIsPublic(1);
+            } else {
+                // 审核通过
+                post.setIsPublic(0);
+            }
+        } else {
+            // 只有文本内容的情况
+            if ("block".equals(textSuggestion)) {
+                // 审核未通过，允许用户修改
+                post.setIsPublic(2);
+            } else if ("review".equals(textSuggestion)) {
+                // 待审核，需人工审核
+                post.setIsPublic(1);
+            } else {
+                // 审核通过
+                post.setIsPublic(0);
             }
         }
         
-        Post post = new Post();
-        post.setUserId(Long.valueOf(postRequestDTO.getUserId()));
-        post.setContent(postRequestDTO.getContent());
-        post.setTags(postRequestDTO.getTags());
-        post.setMediaOssKeys(new ArrayList<>());
-        
-        // 如果有传入的媒体链接，则使用它们
-        if (postRequestDTO.getMediaUrls() != null && !postRequestDTO.getMediaUrls().isEmpty()) {
-            post.setMediaOssKeys(postRequestDTO.getMediaUrls());
-        }
-
-        // 4. 根据审核结果设置状态
-        if ("review".equals(textSuggestion)) {
-            // 待审核，需人工审核
-            post.setIsPublic(0);
-        } else {
-            // 审核通过
-            post.setIsPublic(1);
-        }
         post.setUpdatedAt(LocalDateTime.now());
         post.setCreatedAt(LocalDateTime.now());
 
@@ -140,11 +160,101 @@ public class PostServiceImpl implements PostService {
     /**
      * 删除动态
      *
-     * @param postId 动态ID
+     * @param postIds 动态ID
      * @return 删除的动态对象
      */
     @Override
-    public void deletePostById(Integer postId) {
+    @Transactional(rollbackFor = Exception.class)
-        postMapper.deletePostById(postId);
+    public void deletePostById(List<Long> postIds) {
+        // 批量删除动态
+        postMapper.deletePostByIds(postIds);
     }
+
+    @Override
+    public PostEditVO getPostForEdit(Long postId) {
+
+        Post post = postMapper.selectById(postId);
+        if (post == null) {
+            throw new RuntimeException("动态不存在");
+        }
+        PostEditVO postEditVO = new PostEditVO();
+        BeanUtils.copyProperties(post, postEditVO);
+        return postEditVO;
+    }
+
+    /**
+     * 修改动态
+     * @param postId 动态ID
+     * @param postRequestDTO 修改的动态数据传输对象
+     * @return
+     */
+    @Override
+    public PostEditVO updatePost(Long postId, PostRequestDTO postRequestDTO) {
+        // 查询动态
+        Post post = postMapper.selectById(postId);
+        if (post == null) {
+            throw new RuntimeException("动态不存在");
+        }
+        post.setContent(postRequestDTO.getContent());
+        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
+            post.setMediaOssKeys(postRequestDTO.getMediaOssKeys());
+        }
+
+        // 1. 文本内容审核
+        Map textResult;
+        try {
+            textResult = greenTextScan.greeTextScan(postRequestDTO.getContent());
+        } catch (Exception e) {
+            throw new RuntimeException("文本审核失败");
+        }
+        // 文本审核结果
+        String textSuggestion = (String) textResult.get("suggestion");
+
+        // 2. 图片审核（如果有）
+        if (postRequestDTO.getMediaOssKeys() != null && !postRequestDTO.getMediaOssKeys().isEmpty()) {
+            Map imageResult;
+            try {
+                imageResult = greenImageScan.imageScan(postRequestDTO.getMediaOssKeys());
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+            // 图片审核结果
+            String imageSuggestion = (String) imageResult.get("suggestion");
+
+            // 根据审核结果设置状态
+            if ("block".equals(textSuggestion) || "block".equals(imageSuggestion)) {
+                // 审核未通过，允许用户修改
+                post.setIsPublic(2);
+            } else if ("review".equals(textSuggestion) || "review".equals(imageSuggestion)) {
+                // 待审核，需人工审核
+                post.setIsPublic(1);
+            } else {
+                // 审核通过
+                post.setIsPublic(0);
+            }
+        } else {
+            // 只有文本内容的情况
+            if ("block".equals(textSuggestion)) {
+                // 审核未通过，允许用户修改
+                post.setIsPublic(2);
+            } else if ("review".equals(textSuggestion)) {
+                // 待审核，需人工审核
+                post.setIsPublic(1);
+            } else {
+                // 审核通过
+                post.setIsPublic(0);
+            }
+        }
+        post.setTags(postRequestDTO.getTags());
+        post.setUpdatedAt(LocalDateTime.now());
+
+        // 更新动态
+        postMapper.updateById(post);
+
+        // 返回动态详情
+        PostEditVO postEditVO = new PostEditVO();
+        BeanUtils.copyProperties(post, postEditVO);
+        return postEditVO;
+    }
+
 }

src/main/resources/application.yml

@@ -1,28 +0,0 @@
-server:
-  port: 8080
-
-spring:
-  datasource:
-    url: jdbc:mysql://110.42.41.177:3306/dating?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
-    username: root
-    password: JoyeeServe2025
-    driver-class-name: com.mysql.cj.jdbc.Driver
-
-# MyBatis 配置
-mybatis:
-  mapper-locations: classpath:mapper/*.xml
-  type-aliases-package: com.bao.dating.pojo
-  configuration:
-    map-underscore-to-camel-case: true
-    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
-
-# 阿里云 OSS 配置
-aliyun:
-  oss:
-    endpoint: oss-cn-beijing.aliyuncs.com
-    access-key-id: LTAI5tKo9TpWH1aW6JxWm1Gp
-    access-key-secret: LHk9DdHECKCwIdaIM9fkGgEuowt18W
-    bucket-name: heimato
-  accessKeyId: LTAI5t5vpcbCZwweNHEDDDaF
-  secret: bBHBAPiCqGyVBHUv07348wsHXkKqrk
-  scenes: antispam

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

@@ -29,9 +29,74 @@
     </insert>
 
     <!--动态删除-->
-    <delete id="deletePostById" parameterType="int">
+    <delete id="deletePostByIds">
-        DELETE FROM post WHERE post_id = #{postId}
+        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>
+
+    <!--动态查询-->
+    <resultMap id="PostResultMap" type="com.bao.dating.pojo.entity.Post">
+        <id property="postId" column="post_id"/>
+        <result property="userId" column="user_id"/>
+        <result property="content" column="content"/>
+        <result property="mediaOssKeys" column="media_oss_keys" typeHandler="com.bao.dating.handler.ListToVarcharTypeHandler"/>
+        <result property="tags" column="tags" typeHandler="com.bao.dating.handler.ListToVarcharTypeHandler"/>
+        <result property="location" column="location"/>
+        <result property="isPublic" column="is_public"/>
+        <result property="likeCount" column="like_count"/>
+        <result property="favoriteCount" column="favorite_count"/>
+        <result property="createdAt" column="created_at"/>
+        <result property="updatedAt" column="updated_at"/>
+    </resultMap>
+    <select id="selectById" resultMap="PostResultMap">
+        SELECT 
+          post_id,
+          user_id,
+          content,
+          media_oss_keys,
+          tags,
+          location,
+          is_public,
+          like_count,
+          favorite_count,
+          created_at,
+          updated_at
+        FROM post WHERE post_id = #{postId}
+    </select>
+
+    <!--动态更新-->
+    <update id="updateById">
+        UPDATE post
+        <set>
+            <if test="content != null">
+                content = #{content},
+            </if>
+            <if test="tags != null">
+                tags = #{tags, typeHandler=com.bao.dating.handler.ListToVarcharTypeHandler},
+            </if>
+            <if test="mediaOssKeys != null">
+                media_oss_keys =
+                #{mediaOssKeys, typeHandler=com.bao.dating.handler.ListToVarcharTypeHandler},
+            </if>
+            is_public = #{isPublic},
+            updated_at = #{updatedAt}
+        </set>
+        WHERE post_id = #{postId}
+    </update>
 
     <!--增加点赞数量-->
     <update id="increaseLikeCount">