snowy-main/src/main/java/vip/xiaonuo/modular/blogarticlecomment/controller/BlogArticleCommentOutsideController.java

@@ -25,15 +25,27 @@
package vip.xiaonuo.modular.blogarticlecomment.controller;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Dict;
import cn.hutool.core.util.StrUtil;
import cn.hutool.extra.template.Template;
import cn.hutool.extra.template.TemplateConfig;
import cn.hutool.extra.template.TemplateEngine;
import cn.hutool.extra.template.TemplateUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import vip.xiaonuo.core.annotion.BusinessLog;
import vip.xiaonuo.core.consts.MyConstant;
import vip.xiaonuo.core.context.constant.ConstantContextHolder;
import vip.xiaonuo.core.email.MailSender;
import vip.xiaonuo.core.email.modular.model.SendMailParam;
import vip.xiaonuo.core.enums.LogAnnotionOpTypeEnum;
import vip.xiaonuo.core.exception.BlogException;
import vip.xiaonuo.core.pojo.response.ResponseData;
import vip.xiaonuo.core.pojo.response.SuccessResponseData;
import vip.xiaonuo.modular.blogarticle.entity.BlogArticle;
import vip.xiaonuo.modular.blogarticle.service.BlogArticleService;
import vip.xiaonuo.modular.blogarticlecomment.entity.BlogArticleComment;
import vip.xiaonuo.modular.blogarticlecomment.entity.BlogCommentVo;
@@ -58,29 +70,100 @@
    @Resource
    private BlogArticleService blogArticleService;


    @Resource
    private BlogArticleCommentService blogArticleCommentService;


    @Resource
    private MailSender mailSender;

    @PostMapping("/blogComment/add")
    @BusinessLog(title = "外部blog系统_blog留言/评论_增加", opType = LogAnnotionOpTypeEnum.ADD)
    public ResponseData add(@RequestBody @Validated(BlogArticleCommentAddDto.add.class) BlogArticleCommentAddDto addDto) {
        BlogArticle checkArticle = null;

        //自我认证
        if (MyConstant.myIds.contains(addDto.getVisitorNickName())) {
            if (StrUtil.isEmpty(addDto.getAuthCode()) || !addDto.getAuthCode().equals(ConstantContextHolder.getAuthCode())) {
                throw new BlogException("不要成为我,你就是真的自己");
            }
        }

        if (MyConstant.Yes.equals(addDto.getIsReceiveMail()) && StrUtil.isEmpty(addDto.getVisitorEmail())) {
            throw new BlogException("如果是想接收通知的话,你可能需要填上一个邮箱..");
        }

        if (addDto.getCommentType().equals(MyConstant.CommentType.type_2)) {
            if (addDto.getArticleId() == null) {
                throw new BlogException("评论类型为日志评论,日志id不能为空");
            }
            if (blogArticleService.getById(addDto.getId()) == null) {
            checkArticle = blogArticleService.getById(addDto.getArticleId());
            if (checkArticle == null) {
                throw new BlogException("查询不到相关日志");
            }

            if (checkArticle.getIsAllowedComment().equals(MyConstant.No)) {
                throw new BlogException("该日志评论已经关闭..");
            }
        }
        BlogArticleComment insert = new BlogArticleComment();
        BeanUtil.copyProperties(addDto, insert);
        insert.setIsCheck(MyConstant.No);
        insert.setIsCheck(MyConstant.Yes);
        insert.setIsEnable(MyConstant.Yes);
        insert.setIsReceiveCallback(addDto.getIsReceiveMail());

        blogArticleCommentService.save(insert);

        if (addDto.getReplyId() == null || addDto.getReplyId() == 0L) {
            //这里为根节点,预留通知我
            return new SuccessResponseData();
        }

        BlogArticleComment lastComment = blogArticleCommentService.getById(addDto.getReplyId());

        if (lastComment == null) {
            return new SuccessResponseData();
        }

        //前一个留言接收邮件回复(如果是给评论者自己的追加可以跳过)
        if (MyConstant.Yes.equals(lastComment.getIsReceiveCallback())
                && StrUtil.isNotEmpty(lastComment.getVisitorEmail())
//                && !lastComment.getVisitorNickName().equals(MyConstant.inleft)
//                && !lastComment.getVisitorEmail().equals(MyConstant.email)
                && !lastComment.getVisitorNickName().equals(addDto.getVisitorNickName())
                && !lastComment.getVisitorEmail().equals(addDto.getVisitorEmail())) {

            TemplateEngine engine = TemplateUtil.createEngine(new TemplateConfig("templates", TemplateConfig.ResourceMode.CLASSPATH));
            Template template = engine.getTemplate("emailReplyModel.ftl");

            String title = "碎碎念";
            String address;
            //跳转地址
            if (addDto.getCommentType().equals(MyConstant.CommentType.type_1)) {
                //留言板
                address = String.format(MyConstant.url_1, insert.getId());
            } else {
                //文章详情
                address = String.format(MyConstant.url_2, addDto.getArticleId(), insert.getId());
                title = checkArticle.getTitle();
            }

            Dict dict = Dict.create()
                    .set("lastGuest", lastComment.getVisitorNickName())
                    .set("commentContent", lastComment.getCommentContent())
                    .set("address", address)
                    .set("title", title)
                    .set("sender", addDto.getVisitorNickName())
                    .set("sendContent", addDto.getCommentContent());
            String result = template.render(dict);

            SendMailParam param = new SendMailParam();
            param.setContent(result);
            param.setTitle("先前您在 [inleft的小木屋] 的留言有了新的回复！\n");
            param.setTo(lastComment.getVisitorEmail());
            mailSender.sendMailHtml(param);
        }


        return new SuccessResponseData();
    }
@@ -99,15 +182,32 @@
        List<BlogArticleComment> commentList = blogArticleCommentService.lambdaQuery()
                .eq(queryDto.getArticleId() != null, BlogArticleComment::getArticleId, queryDto.getArticleId())
                .eq(BlogArticleComment::getCommentType, queryDto.getArticleId() == null ? MyConstant.CommentType.type_1 : MyConstant.CommentType.type_2)
                .eq(BlogArticleComment::getIsCheck, MyConstant.Yes)
                .eq(BlogArticleComment::getIsEnable, MyConstant.Yes)
                .eq(BlogArticleComment::getParentId,0)
                .eq(BlogArticleComment::getParentId, 0)
                .orderByDesc(BlogArticleComment::getCreateDate)
                .page(queryPage).getRecords();

        int limitCount = 2;
        List<BlogCommentVo> res = commentList.stream().map(e -> {
                    BlogCommentVo vo = new BlogCommentVo();
                    BeanUtil.copyProperties(e, vo);
                    vo.setIsHasNext(MyConstant.No);
                    List<BlogCommentVo> replyList = blogArticleCommentService.getReplyListById(e.getId(), limitCount);
                    vo.setReplyList(replyList);

                    if (e.getAuthStatus().equals(MyConstant.AuthStatus.privateCode)) {
                        vo.setCommentContent(MyConstant.privateComment);
                    }

                    if (CollUtil.isNotEmpty(replyList)
                            && blogArticleCommentService.lambdaQuery()
                            .eq(BlogArticleComment::getParentId, e.getId())
                            .eq(BlogArticleComment::getIsCheck, MyConstant.Yes)
                            .eq(BlogArticleComment::getIsEnable, MyConstant.Yes)
                            .count() > limitCount) {
                        vo.setIsHasNext(MyConstant.Yes);
                    }
                    return vo;
                }
        ).collect(Collectors.toList());
@@ -115,4 +215,47 @@
        queryPage.setRecords(res);
        return new SuccessResponseData(queryPage);
    }

    @GetMapping("/blogComment/queryBlogCommentSubList")
    @BusinessLog(title = "外部blog系统_blog留言/评论子列表_查询", opType = LogAnnotionOpTypeEnum.QUERY)
    public ResponseData queryBlogCommentSubList(BlogCommentQueryDto queryDto) {
        if (queryDto.getArticleId() != null && blogArticleCommentService.getById(queryDto.getCommentId()) == null) {
            throw new BlogException("查询不到相关评论");
        }


        List<BlogCommentVo> replyList = blogArticleCommentService.getReplyListById(queryDto.getCommentId(), null);
//        for (BlogCommentVo vo : replyList) {
//            vo.setIsHasNext(MyConstant.No);
//            if (vo.getAuthStatus().equals(MyConstant.AuthStatus.privateCode)) {
//                vo.setCommentContent(MyConstant.privateComment);
//            }
//        }

        return new SuccessResponseData(replyList);
    }

    //    @GetMapping("/blogComment/test")
    public ResponseData test() {


        TemplateEngine engine = TemplateUtil.createEngine(new TemplateConfig("templates", TemplateConfig.ResourceMode.CLASSPATH));
        Template template = engine.getTemplate("emailReplyModel.ftl");
        Dict dict = Dict.create()
                .set("lastGuest", "回复人")
                .set("commentContent", "评论内容")
                .set("address", "http://blog.inleft.com")
                .set("title", "回复标题")
                .set("sendTime", DateUtil.now())
                .set("sender", "发送人")
                .set("sendContent", "发送内容");
        String result = template.render(dict);

        SendMailParam param = new SendMailParam();
        param.setContent(result);
        param.setTitle("先前您在 [inleft的小木屋] 的留言有了新的回复！\n");
        param.setTo("1479853828@qq.com");
        mailSender.sendMailHtml(param);
        return new SuccessResponseData();
    }
}