交友项目【根据id查询单条动态发布评论查询评论列表】

目录

1：根据id查询单条动态

1.1：接口分析

1.2：流程分析

1.3：代码实现

2：发布评论

2.1：接口分析

2.2：流程分析

2.3：代码实现

3：查询评论列表

3.1：接口分析

3.2：流程分析

3.3：代码实现

1：根据id查询单条动态

1.1：接口分析

注意： 单条动态 和 查询评论列表 ，同时完成，app端才可以显示内容  

1.2：流程分析

根据id查询对应动态详情信息，接收到前端传来的id信息，到数据库中查询指定的数据，将数据处理封装返回前端，这个功能需要和该动态的所有评论一起实现才能在探花app上显示页面。

1.3：代码实现

接收请求的app服务端

app-server服务：controller层

    @GetMapping("/{id}")public ResponseEntity findmovement(@PathVariable("id") ObjectId id){MovementVo findmovement = movementService.findmovement(id);System.out.println(findmovement);return ResponseEntity.ok(findmovement);}

app-server服务：service层 

    public MovementVo findmovement(ObjectId id) {//处理评论Movement movement = movementApi.findmovement(id);UserInfo userInfo = userInfoApi.findUser(movement.getUserId());MovementVo movementVo = new MovementVo(movement.getId().toString(),userInfo.getId(),userInfo.getAvatar(),userInfo.getNickname(),userInfo.getGender(),Integer.valueOf(userInfo.getAge()),userInfo.getTags().split(","),movement.getTextContent(),movement.getMedias(),"500米",movement.getCreated().toString(),movement.getLikeCount(),movement.getCommentCount(),movement.getLoveCount(),0,0);return movementVo;}

接口模块：专门封装接口的模块

Movement findmovement(ObjectId id);

public UserInfo findUser(Long id);

db提供者服务：mysql

    @Overridepublic UserInfo findUser(Long id) {UserInfo userInfo = this.userInfoMapper.selectById(id);return userInfo;}

mongo提供者服务：mongo

    @Overridepublic Movement findmovement(ObjectId id) {Query query = new Query();query.addCriteria(Criteria.where("id").is(id));Movement one = mongoTemplate.findOne(query, Movement.class);return one;}

2：发布评论

2.1：接口分析

2.2：流程分析

接收到前端传入的发布动态参数，将图片信息上传到阿里云上面，将数据处理保存到数据库中。

2.3：代码实现

 接收请求的app服务端

app-server服务：controller层

    @PostMappingpublic ResponseEntity fabudongtai(@RequestParam("imageContent") List<MultipartFile> imageContent,PostUpdateVo postUpdateVo){movementService.fabudongtai(imageContent,postUpdateVo,UserHolder.getUserId(),UserHolder.getMobile());return ResponseEntity.ok(null);}

app-server服务：service层 

    public void fabudongtai(List<MultipartFile> imageContent, PostUpdateVo postUpdateVo, Long userId, String mobile) {for (MultipartFile multipartFile : imageContent) {String upload = ossTemplate.upload(multipartFile);System.out.println(upload);postUpdateVo.getImages().add(upload);}movementApi.fabudongtai(postUpdateVo,userId,mobile);}

接口模块：专门封装接口的模块

    void fabudongtai(PostUpdateVo postUpdateVo, Long userId, String mobile);

mongo提供者服务：mongo

   @Overridepublic void fabudongtai(PostUpdateVo postUpdateVo, Long userId, String mobile) {//保存动态到mongo动态表中Movement movement = new Movement();Long movement1 = idWorker.getNextId("movement");movement.setPid(movement1);movement.setUserId(userId);movement.setTextContent(postUpdateVo.getTextContent());movement.setMedias(postUpdateVo.getImages().toArray(new String[0]));movement.setState(0);movement.setLongitude(Double.valueOf(postUpdateVo.getLongitude()));movement.setLatitude(Double.valueOf(postUpdateVo.getLatitude()));movement.setLocationName(postUpdateVo.getLocation());movement.setCreated(new Date().getTime());//保存动态表Movement save = mongoTemplate.save(movement);//查询好友列表//构建条件Query query = new Query();Criteria criteria = Criteria.where("userId").is(userId);query.addCriteria(criteria);List<Friend> friends = mongoTemplate.find(query, Friend.class);//保存时间线数据for (Friend friend : friends) {MovementTimeline movementTimeline = new MovementTimeline(save.getCreated(),friend.getFriendId(),save.getId(),save.getUserId());mongoTemplate.save(movementTimeline);}//处理结束}

3：查询评论列表

3.1：接口分析

3.2：流程分析

通过动态id，到评论表中查找对应的所有评论

3.3：代码实现

 接收请求的app服务端

app-server服务：controller层

    @GetMappingpublic ResponseEntity findComments(@RequestParam("movementId") ObjectId movementId, PublicPageVo publicPageVo){System.out.println(movementId);ResultList comments = commentService.findComments(movementId, publicPageVo);return ResponseEntity.ok(comments);}

app-server服务：service层 

    public ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo) {ResultList comments = commentApi.findComments(movementId, publicPageVo);List<Comment> items = comments.getItems();//传入用户APiMap<Long, UserInfo> userInfoMap = userInfoApi.findUserByids(items.stream().map(comment -> comment.getUserId()).collect(Collectors.toList()));List<CommentVo> commentVoList = new ArrayList<>();//处理返回数据for (Comment comment : items) {UserInfo userInfo = userInfoMap.get(comment.getUserId());CommentVo commentVo = new CommentVo(comment.getId().toString(),userInfo.getAvatar(),userInfo.getNickname(),comment.getContent(),comment.getCreated().toString(), (int) comment.getLikeCount(),0);commentVoList.add(commentVo);}comments.setItems(commentVoList);return comments;}

接口模块：专门封装接口的模块

    Map<Long,UserInfo> findUserByids(List<Long> collect);

  ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo);

db提供者服务：mysql

    @Overridepublic Map<Long, UserInfo> findUserByids(List<Long> collect) {Map<Long,UserInfo> userInfoMap = new HashMap<>();//传入的是用户idfor (Long userid : collect) {UserInfo userInfo = userInfoMapper.selectById(userid);if (userInfo!=null){userInfoMap.put(userInfo.getId(),userInfo);}}return userInfoMap;}

mongo提供者服务：mongo

    @Overridepublic ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo) {ResultList<Comment> objectResultList = new ResultList<>();//拼凑条件Query query = new Query();//添加条件query.addCriteria(Criteria.where("publishId").is(movementId));long count = mongoTemplate.count(query, Comment.class);query.limit(publicPageVo.getPagesize().intValue()).skip((publicPageVo.getPage()-1)*publicPageVo.getPagesize()).with(Sort.by(Sort.Order.desc("created")));List<Comment> comments = mongoTemplate.find(query, Comment.class);objectResultList.setItems(comments);objectResultList.setCounts(Integer.valueOf(count+""));objectResultList.setPagesize(publicPageVo.getPagesize().intValue());objectResultList.setPage(publicPageVo.getPage().intValue());objectResultList.setPages((int) (count%publicPageVo.getPagesize() == 0 ? count/ publicPageVo.getPagesize():(count/ publicPageVo.getPagesize())+1));//返回处理的数据return objectResultList;}