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

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

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);

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

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

@PostMapping
    public ResponseEntity fabudongtai(@RequestParam("imageContent") List imageContent,PostUpdateVo postUpdateVo){
        movementService.fabudongtai(imageContent,postUpdateVo,UserHolder.getUserId(),UserHolder.getMobile());
        return ResponseEntity.ok(null);
    }

public void fabudongtai(List 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);

@Override
    public 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 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);
        }
        //处理结束
    }

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

public ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo) {
        ResultList comments = commentApi.findComments(movementId, publicPageVo);
        List items = comments.getItems();


        //传入用户APi
        Map userInfoMap = userInfoApi.findUserByids(items.stream().map(comment -> comment.getUserId()).collect(Collectors.toList()));

        List 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 findUserByids(List collect);

ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo);

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

@Override
    public ResultList findComments(ObjectId movementId, PublicPageVo publicPageVo) {
        ResultList 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 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;
    }