动态锁定完成

src/main/java/cn/meteor/beyondclouds/modules/post/service/impl/PostServiceImpl.java

@@ -174,6 +174,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
         QueryWrapper queryWrapper = new QueryWrapper();
         QueryWrapper queryWrapper = new QueryWrapper();
         queryWrapper.eq("post_id", postId);
         queryWrapper.eq("post_id", postId);
         queryWrapper.eq("user_id", userId);
         queryWrapper.eq("user_id", userId);
+        queryWrapper.eq("status", 0);
         Post post = getOne(queryWrapper);
         Post post = getOne(queryWrapper);
         if (null == post) {
         if (null == post) {
             throw new PostServiceException(PostErrorCode.USER_POST_NOT_FOUND);
             throw new PostServiceException(PostErrorCode.USER_POST_NOT_FOUND);
@@ -209,6 +210,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
     public IPage<Post> getPostPage(Integer pageNumber, Integer pageSize, Integer type) {
     public IPage<Post> getPostPage(Integer pageNumber, Integer pageSize, Integer type) {
         IPage<Post> postPage = new Page<>(pageNumber, pageSize);
         IPage<Post> postPage = new Page<>(pageNumber, pageSize);
         QueryWrapper<Post> queryWrapper = new QueryWrapper();
         QueryWrapper<Post> queryWrapper = new QueryWrapper();
+        queryWrapper.eq("status", 0);
         queryWrapper.orderByDesc("create_time");
         queryWrapper.orderByDesc("create_time");
         if (null != type) {
         if (null != type) {
             queryWrapper.eq("type", type);
             queryWrapper.eq("type", type);
@@ -228,6 +230,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
     public IPage<Post> getUserPostPage(Integer pageNumber, Integer pageSize, String userId) {
     public IPage<Post> getUserPostPage(Integer pageNumber, Integer pageSize, String userId) {
         QueryWrapper queryWrapper = new QueryWrapper();
         QueryWrapper queryWrapper = new QueryWrapper();
         queryWrapper.eq("user_id", userId);
         queryWrapper.eq("user_id", userId);
+        queryWrapper.eq("status", 0);
         queryWrapper.orderByDesc("create_time");
         queryWrapper.orderByDesc("create_time");
 
 
         IPage<Post> postPage = new Page<>(pageNumber, pageSize);
         IPage<Post> postPage = new Page<>(pageNumber, pageSize);
@@ -281,6 +284,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
         if (!CollectionUtils.isEmpty(followedIds)) {
         if (!CollectionUtils.isEmpty(followedIds)) {
             QueryWrapper<Post> postQueryWrapper = new QueryWrapper<>();
             QueryWrapper<Post> postQueryWrapper = new QueryWrapper<>();
             postQueryWrapper.in("user_id", followedIds);
             postQueryWrapper.in("user_id", followedIds);
+            postQueryWrapper.eq("status", 0);
             postQueryWrapper.orderByDesc("create_time");
             postQueryWrapper.orderByDesc("create_time");
             return page(postPage, postQueryWrapper);
             return page(postPage, postQueryWrapper);
         } else {
         } else {
@@ -290,7 +294,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
 
 
     @Override
     @Override
     public PageDTO<PostDTO> getRecommendPosts(Integer page, Integer size) {
     public PageDTO<PostDTO> getRecommendPosts(Integer page, Integer size) {
-        IPage<Post> postPage = postMapper.selectRecommendPage(new Page<Post>(page, size));
+        IPage<Post> postPage = postMapper.selectRecommendPage(new Page<>(page, size));
         return toPageDTO(postPage);
         return toPageDTO(postPage);
     }
     }