游记评论

/**
 * 游记评论
 */
@Setter
@Getter
@Document("travel_comment")
public class TravelComment implements Serializable {
    public static final int TRAVLE_COMMENT_TYPE_COMMENT = 0; //普通评论
    public static final int TRAVLE_COMMENT_TYPE = 1; //评论的评论
    @Id
    private String id;  //id
    private Long travelId;  //游记id
    private String travelTitle; //游记标题
    private Long userId;    //用户id
    private String nickname; //用户名
    private String city;
    private Integer level;
    private String headImgUrl;   // 用户头像
    private Integer type; //评论类别
    private Date createTime; //创建时间
    private String content;  //评论内容
    private TravelComment refComment;  //关联的评论
}

/**
 * 游记评论 Repository
 */
public interface TravelCommentRepository extends MongoRepository<TravelComment, String> {
}

public interface TravelCommentService {
    
}

@Slf4j
@Service
public class TravelCommentServiceImpl implements TravelCommentService {

    private final TravelCommentRepository travelCommentRepository;
    private final MongoTemplate mongoTemplate;

    public TravelCommentServiceImpl(TravelCommentRepository travelCommentRepository, MongoTemplate mongoTemplate) {
        this.travelCommentRepository = travelCommentRepository;
        this.mongoTemplate = mongoTemplate;
    }
}

@RestController
@RequestMapping("/travels/comments")
public class TravelCommentController {

    private final TravelCommentService travelCommentService;

    public TravelCommentController(TravelCommentService travelCommentService) {
        this.travelCommentService = travelCommentService;
    }
}

/**
 * 获取游记的评论
 * @param travelId 游记ID
 * @return 所有评论
 */
List<TravelComment> findList(Long travelId);

/**
 * 获取游记的评论
 *
 * @param travelId 游记ID
 * @return 所有评论
 */
@Override
public List<TravelComment> findList(Long travelId) {
    Query query = new Query()
            .with(Sort.by(Sort.Direction.DESC, "createTime"))
            .addCriteria(Criteria.where("travelId").is(travelId));
    List<TravelComment> travelComments = mongoTemplate.find(query, TravelComment.class);
    for (TravelComment travelComment : travelComments) {
        TravelComment refComment = travelComment.getRefComment();
        if (refComment != null && refComment.getId() != null) {
            Optional<TravelComment> refCommentOptional = travelCommentRepository.findById(refComment.getId());
            travelComment.setRefComment(refCommentOptional.orElse(null));
        }
    }
    return travelComments;
}

@GetMapping("/query")
public R<List<TravelComment>> findList(Long travelId) {
    return R.ok(travelCommentService.findList(travelId));
}

/**
 * 保存游记评论
 * @param comment 评论信息
 */
void save(TravelComment comment);

/**
 * 保存游记评论
 *
 * @param comment 评论信息
 */
@Override
public void save(TravelComment comment) {
    // 获取当前登陆用户
    LoginUser loginUser = AuthenticationUtil.getLoginUser();
    if (loginUser == null) {
        log.error("[游记评论模块] 获取登陆用户信息错误");
        throw new BizException("获取登陆用户信息错误");
    }
    comment.setUserId(loginUser.getId());
    comment.setNickname(loginUser.getNickname());
    comment.setCity(loginUser.getCity());
    comment.setLevel(loginUser.getLevel());
    comment.setHeadImgUrl(loginUser.getHeadImgUrl());
    comment.setCreateTime(new Date());
    if (comment.getRefComment() != null && StringUtils.hasLength(comment.getRefComment().getId())) {
        // 评论的评论
        comment.setType(TravelComment.TRAVLE_COMMENT_TYPE);
    } else {
        // 普通评论
        comment.setType(TravelComment.TRAVLE_COMMENT_TYPE_COMMENT);
    }
    travelCommentRepository.save(comment);
}

@RequireLogin
@PostMapping("/save")
public R<?> queryComment(TravelComment comment) {
    travelCommentService.save(comment);
    return R.ok();
}