【探花交友】day05—圈子互动（下）

1. //分页查询评理列表
2. @GetMapping
3. public ResponseEntity findComments(@RequestParam(defaultValue = "1") Integer page,
4.                                 @RequestParam(defaultValue = "10") Integer pagesize,
5.                                    String movementId) {
6. PageResult pr = commentsService.findComments(movementId,page,pagesize);
7. return ResponseEntity.ok(pr);
8. }

1. //分页查询评理列表
2. public PageResult findComments(String movementId, Integer page, Integer pagesize) {
3. //1、调用API查询评论列表
4.     List<Comment> list = commentApi.findComments(movementId,CommentType.COMMENT,page,pagesize);
5. //2、判断list集合是否存在
6. if(CollUtil.isEmpty(list)) {
7. return new PageResult();
8.     }
9. //3、提取所有的用户id,调用UserInfoAPI查询用户详情
10.     List<Long> userIds = CollUtil.getFieldValues(list, "userId", Long.class);
11.     Map<Long, UserInfo> map = userInfoApi.findByIds(userIds, null);
12. //4、构造vo对象
13.     List<CommentVo> vos = new ArrayList<>();
14. for (Comment comment : list) {
15. UserInfo userInfo = map.get(comment.getUserId());
16. if(userInfo != null) {
17. CommentVo vo = CommentVo.init(userInfo, comment);
18.             vos.add(vo);
19.         }
20.     }
21. //5、构造返回值
22. return new PageResult(page,pagesize,0l,vos);
23. }

1. //分页查询
2. public List<Comment> findComments(String movementId, CommentType commentType, Integer page, Integer pagesize) {
3. //1、构造查询条件
4. Query query = Query.query(Criteria.where("publishId").is(new ObjectId(movementId)).and("commentType")
5.             .is(commentType.getType()))
6.             .skip((page -1) * pagesize)
7.             .limit(pagesize)
8.             .with(Sort.by(Sort.Order.desc("created")));
9. //2、查询并返回
10. return mongoTemplate.find(query,Comment.class);
11. }

1. @RestController
2. @RequestMapping("/comments")
3. public class CommentsController {
4. 
5. 
6. @Autowired
7. private CommentsService commentsService;
8. 
9. /**
10.      * 发布评论
11.      */
12. @PostMapping
13. public ResponseEntity saveComments(@RequestBody Map map) {
14. String movementId = (String )map.get("movementId");
15. String comment = (String)map.get("comment");
16.         commentsService.saveComments(movementId,comment);
17. return ResponseEntity.ok(null);
18.     }
19. }

1. @Service
2. @Slf4j
3. public class CommentsService {
4. 
5. @DubboReference
6. private CommentApi commentApi;
7. 
8. //发布评论
9. public void saveComments(String movementId, String comment) {
10. //1、获取操作用户id
11. Long userId = UserHolder.getUserId();
12. //2、构造Comment
13. Comment comment1 = new Comment();
14.         comment1.setPublishId(new ObjectId(movementId));
15.         comment1.setCommentType(CommentType.COMMENT.getType());
16.         comment1.setContent(comment);
17.         comment1.setUserId(userId);
18.         comment1.setCreated(System.currentTimeMillis());
19. //3、调用API保存评论
20. Integer commentCount = commentApi.save(comment1);
21.         log.info("commentCount = " + commentCount);
22.     }
23. }

1. //发布评论，并获取评论数量
2. public Integer save(Comment comment) {
3. //1、查询动态
4. Movement movement = mongoTemplate.findById(comment.getPublishId(), Movement.class);
5. //2、向comment对象设置被评论人属性
6. if(movement != null) {
7.         comment.setPublishUserId(movement.getUserId());
8.     }
9. //3、保存到数据库
10.     mongoTemplate.save(comment);
11. //4、更新动态表中的对应字段
12. Query query = Query.query(Criteria.where("id").is(comment.getPublishId()));
13. Update update = new Update();
14. if(comment.getCommentType() == CommentType.LIKE.getType()) {
15.         update.inc("likeCount",1);
16.     }else if (comment.getCommentType() == CommentType.COMMENT.getType()){
17.         update.inc("commentCount",1);
18.     }else {
19.         update.inc("loveCount",1);
20.     }
21. //设置更新参数
22. FindAndModifyOptions options = new FindAndModifyOptions();
23.     options.returnNew(true) ;//获取更新后的最新数据
24. Movement modify = mongoTemplate.findAndModify(query, update, options, Movement.class);
25. //5、获取最新的评论数量，并返回
26. return modify.statisCount(comment.getCommentType() );
27. }

1. @RunWith(SpringRunner.class)
2. @SpringBootTest(classes = AppServerApplication.class)
3. public class CommentApiTest {
4. 
5. @DubboReference
6. private CommentApi commentApi;
7. 
8. @Test
9. public void testSave() {
10. Comment comment = new Comment();
11.         comment.setCommentType(CommentType.COMMENT.getType());
12.         comment.setUserId(106l);
13.         comment.setCreated(System.currentTimeMillis());
14.         comment.setContent("测试评论");
15.         comment.setPublishId();
16.         commentApi.save(comment);
17.     }
18. }

1. /**
2.  * 点赞
3.  */
4. @GetMapping("/{id}/like")
5. public ResponseEntity like(@PathVariable("id") String movementId) {
6. Integer likeCount = commentsService.likeComment(movementId);
7. return ResponseEntity.ok(likeCount);
8. }
9. 
10. /**
11.  * 取消点赞
12.  */
13. @GetMapping("/{id}/dislike")
14. public ResponseEntity dislike(@PathVariable("id") String movementId) {
15. Integer likeCount = commentsService.dislikeComment(movementId);
16. return ResponseEntity.ok(likeCount);
17. }

1. //动态点赞
2. public Integer likeComment(String movementId) {
3. //1、调用API查询用户是否已点赞
4. Boolean hasComment = commentApi.hasComment(movementId,UserHolder.getUserId(),CommentType.LIKE);
5. //2、如果已经点赞，抛出异常
6. if(hasComment) {
7. throw  new BusinessException(ErrorResult.likeError());
8.     }
9. //3、调用API保存数据到Mongodb
10. Comment comment = new Comment();
11.     comment.setPublishId(new ObjectId(movementId));
12.     comment.setCommentType(CommentType.LIKE.getType());
13.     comment.setUserId(UserHolder.getUserId());
14.     comment.setCreated(System.currentTimeMillis());
15. Integer count = commentApi.save(comment);
16. //4、拼接redis的key，将用户的点赞状态存入redis
17. String key = Constants.MOVEMENTS_INTERACT_KEY + movementId;
18. String hashKey = Constants.MOVEMENT_LIKE_HASHKEY + UserHolder.getUserId();
19.     redisTemplate.opsForHash().put(key,hashKey,"1");
20. return count;
21. }
22. 
23. 
24. //取消点赞
25. public Integer dislikeComment(String movementId) {
26. //1、调用API查询用户是否已点赞
27. Boolean hasComment = commentApi.hasComment(movementId,UserHolder.getUserId(),CommentType.LIKE);
28. //2、如果未点赞，抛出异常
29. if(!hasComment) {
30. throw new BusinessException(ErrorResult.disLikeError());
31.     }
32. //3、调用API，删除数据，返回点赞数量
33. Comment comment = new Comment();
34.     comment.setPublishId(new ObjectId(movementId));
35.     comment.setCommentType(CommentType.LIKE.getType());
36.     comment.setUserId(UserHolder.getUserId());
37. Integer count = commentApi.delete(comment);
38. //4、拼接redis的key，删除点赞状态
39. String key = Constants.MOVEMENTS_INTERACT_KEY + movementId;
40. String hashKey = Constants.MOVEMENT_LIKE_HASHKEY + UserHolder.getUserId();
41.     redisTemplate.opsForHash().delete(key,hashKey);
42. return count;
43. }

1. //判断comment数据是否存在
2. public Boolean hasComment(String movementId, Long userId, CommentType commentType) {
3. Criteria criteria = Criteria.where("userId").is(userId)
4.             .and("publishId").is(new ObjectId(movementId))
5.             .and("commentType").is(commentType.getType());
6. Query query = Query.query(criteria);
7. return mongoTemplate.exists(query,Comment.class); //判断数据是否存在
8. }

1. //删除
2. public Integer delete(Comment comment) {
3. //1、删除Comment表数据
4. Criteria criteria = Criteria.where("userId").is(comment.getUserId())
5.             .and("publishId").is(comment.getPublishId())
6.             .and("commentType").is(comment.getCommentType());
7. Query query = Query.query(criteria);
8.     mongoTemplate.remove(query,Comment.class);
9. //2、修改动态表中的总数量
10. Query movementQuery = Query.query(Criteria.where("id").is(comment.getPublishId()));
11. Update update = new Update();
12. if(comment.getCommentType() == CommentType.LIKE.getType()) {
13.         update.inc("likeCount",-1);
14.     }else if (comment.getCommentType() == CommentType.COMMENT.getType()){
15.         update.inc("commentCount",-1);
16.     }else {
17.         update.inc("loveCount",-1);
18.     }
19. //设置更新参数
20. FindAndModifyOptions options = new FindAndModifyOptions();
21.     options.returnNew(true) ;//获取更新后的最新数据
22. Movement modify = mongoTemplate.findAndModify(movementQuery, update, options, Movement.class);
23. //5、获取最新的评论数量，并返回
24. return modify.statisCount(comment.getCommentType() );
25. }

1. /**
2.  * 喜欢
3.  */
4. @GetMapping("/{id}/love")
5. public ResponseEntity love(@PathVariable("id") String movementId) {
6. Integer likeCount = commentsService.loveComment(movementId);
7. return ResponseEntity.ok(likeCount);
8. }
9. 
10. /**
11.  * 取消喜欢
12.  */
13. @GetMapping("/{id}/unlove")
14. public ResponseEntity unlove(@PathVariable("id") String movementId) {
15. Integer likeCount = commentsService.disloveComment(movementId);
16. return ResponseEntity.ok(likeCount);
17. }

1. /**
2.  * 喜欢
3.  */
4. @GetMapping("/{id}/love")
5. public ResponseEntity love(@PathVariable("id") String movementId) {
6. Integer likeCount = commentsService.loveComment(movementId);
7. return ResponseEntity.ok(likeCount);
8. }
9. 
10. /**
11.  * 取消喜欢
12.  */
13. @GetMapping("/{id}/unlove")
14. public ResponseEntity unlove(@PathVariable("id") String movementId) {
15. Integer likeCount = commentsService.disloveComment(movementId);
16. return ResponseEntity.ok(likeCount);
17. }