| | |
| | | |
| | | 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; |
| | |
| | | @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(); |
| | | } |
| | |
| | | .orderByDesc(BlogArticleComment::getCreateDate) |
| | | .page(queryPage).getRecords(); |
| | | |
| | | int limitCount = 5; |
| | | String privateComment = "******"; |
| | | int limitCount = 2; |
| | | List<BlogCommentVo> res = commentList.stream().map(e -> { |
| | | BlogCommentVo vo = new BlogCommentVo(); |
| | | BeanUtil.copyProperties(e, vo); |
| | |
| | | vo.setReplyList(replyList); |
| | | |
| | | if (e.getAuthStatus().equals(MyConstant.AuthStatus.privateCode)) { |
| | | vo.setCommentContent(privateComment); |
| | | vo.setCommentContent(MyConstant.privateComment); |
| | | } |
| | | |
| | | if (CollUtil.isNotEmpty(replyList) |
| | |
| | | throw new BlogException("查询不到相关评论"); |
| | | } |
| | | |
| | | String privateComment = "(悄悄话已隐藏)******"; |
| | | |
| | | 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(privateComment); |
| | | } |
| | | } |
| | | // 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(); |
| | | } |
| | | } |