|
|
|
package article
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"github.com/samber/lo"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/pkg/xerr"
|
|
|
|
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/api/internal/svc"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/api/internal/types"
|
|
|
|
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
|
|
)
|
|
|
|
|
|
|
|
type SystemUpdateArticleLogic struct {
|
|
|
|
logx.Logger
|
|
|
|
ctx context.Context
|
|
|
|
svcCtx *svc.ServiceContext
|
|
|
|
}
|
|
|
|
|
|
|
|
func NewSystemUpdateArticleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SystemUpdateArticleLogic {
|
|
|
|
return &SystemUpdateArticleLogic{
|
|
|
|
Logger: logx.WithContext(ctx),
|
|
|
|
ctx: ctx,
|
|
|
|
svcCtx: svcCtx,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (l *SystemUpdateArticleLogic) SystemUpdateArticle(req *types.SystemArticleUpdateRequest) (resp *types.SystemArticleUpdateResponse, err error) {
|
|
|
|
var conn = l.svcCtx.DefaultDBConn()
|
|
|
|
article, err := l.svcCtx.ArticleRepository.FindOne(l.ctx, conn, req.Id)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerr.NewErrMsgErr("帖子不存在", err)
|
|
|
|
}
|
|
|
|
//TODO 获取图片的尺寸大小
|
|
|
|
images := []domain.Image{}
|
|
|
|
for _, val := range req.Images {
|
|
|
|
images = append(images, domain.Image{
|
|
|
|
Url: val,
|
|
|
|
Width: 0,
|
|
|
|
Height: 0,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
article.Title = req.Title
|
|
|
|
article.Version = article.Version + 1
|
|
|
|
article.Images = images
|
|
|
|
article.WhoRead = req.WhoRead
|
|
|
|
article.WhoReview = req.WhoReview
|
|
|
|
article.TargetUser = domain.ArticleTarget(req.TargetUser)
|
|
|
|
article.Location = domain.Location{
|
|
|
|
Longitude: req.Location.Longitude,
|
|
|
|
Latitude: req.Location.Latitude,
|
|
|
|
Descript: req.Location.Descript,
|
|
|
|
}
|
|
|
|
//文章内容
|
|
|
|
articleSections := []domain.ArticleSection{}
|
|
|
|
lo.ForEach(req.Section, func(item types.ArticleSection, index int) {
|
|
|
|
articleSections = append(articleSections, domain.ArticleSection{
|
|
|
|
Id: item.Id,
|
|
|
|
CompanyId: article.CompanyId,
|
|
|
|
Version: article.Version,
|
|
|
|
ArticleId: article.Id,
|
|
|
|
Content: item.Content,
|
|
|
|
SortBy: index + 1,
|
|
|
|
})
|
|
|
|
})
|
|
|
|
//设置内容概要
|
|
|
|
if len(req.Section) > 0 {
|
|
|
|
// 截取内容 30个字
|
|
|
|
runeNumber := 0 //字数
|
|
|
|
stringIndex := 0 //字符串长度
|
|
|
|
for i := range req.Section[0].Content {
|
|
|
|
if runeNumber > 30 {
|
|
|
|
break
|
|
|
|
}
|
|
|
|
runeNumber += 1
|
|
|
|
stringIndex = i
|
|
|
|
}
|
|
|
|
article.Summary = req.Section[0].Content[0:stringIndex]
|
|
|
|
}
|
|
|
|
err = transaction.UseTrans(l.ctx, conn.DB(), func(ctx context.Context, c transaction.Conn) error {
|
|
|
|
_, err = l.svcCtx.ArticleRepository.Update(l.ctx, conn, article)
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("保存文章失败", err)
|
|
|
|
}
|
|
|
|
//文章内容
|
|
|
|
updateSectionIds := []int64{}
|
|
|
|
for _, item := range articleSections {
|
|
|
|
if item.Id > 0 {
|
|
|
|
section, err := l.svcCtx.ArticleSectionRepository.FindOne(ctx, c, item.Id)
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("获取文章段落内容失败", err)
|
|
|
|
}
|
|
|
|
section.Content = item.Content
|
|
|
|
section.ArticleId = item.ArticleId
|
|
|
|
section.Version = item.Version
|
|
|
|
section.SortBy = item.SortBy
|
|
|
|
section.CompanyId = item.CompanyId
|
|
|
|
_, err = l.svcCtx.ArticleSectionRepository.Update(ctx, c, section)
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("保存文章段落内容失败", err)
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
_, err = l.svcCtx.ArticleSectionRepository.Insert(ctx, c, &item)
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("保存文章段落内容失败", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
updateSectionIds = append(updateSectionIds, item.Id)
|
|
|
|
}
|
|
|
|
if len(updateSectionIds) > 0 {
|
|
|
|
err = l.svcCtx.ArticleSectionRepository.DeleteBy(ctx, c, domain.NewQueryOptions().WithKV("articleId", article.Id).WithKV("notIds", updateSectionIds))
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("保存文章内容失败", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//备份数据
|
|
|
|
backup := article.MakeBackup(article.Author, articleSections)
|
|
|
|
backup.Action = "编辑"
|
|
|
|
_, err = l.svcCtx.ArticleBackupRepository.Insert(ctx, c, backup)
|
|
|
|
if err != nil {
|
|
|
|
return xerr.NewErrMsgErr("保存文章内容失败", err)
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}, true)
|
|
|
|
return
|
|
|
|
} |
...
|
...
|
|
