package article

import (
	"context"
	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/api/internal/logic/core"
	"sort"

	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/api/internal/svc"
	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/api/internal/types"
	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/pkg/xerr"

	"github.com/zeromicro/go-zero/core/logx"
)

type MiniGetArticleLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewMiniGetArticleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *MiniGetArticleLogic {
	return &MiniGetArticleLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

// 小程序端展示文章内容
func (l *MiniGetArticleLogic) MiniGetArticle(req *types.MiniArticleGetRequest) (resp *types.MiniArticleGetResponse, err error) {
	// 获取文章内容
	var conn = l.svcCtx.DefaultDBConn()
	companyInfo, err := l.svcCtx.CompanyRepository.FindOne(l.ctx, conn, req.CompanyId)
	if err != nil {
		return nil, xerr.NewErrMsgErr("读取公司数据失败", err)
	}
	articleInfo, err := l.svcCtx.ArticleRepository.FindOne(l.ctx, conn, req.Id)
	if err != nil {
		return nil, xerr.NewErrMsgErr("读取文章内容失败", err)
	}
	if articleInfo.CompanyId != req.CompanyId {
		return nil, xerr.NewErrMsg("没有查看权限")
	}
	// 检查文章的可查看人
	if ok := articleInfo.WhoCanRead(int64(req.UserId)); !ok {
		return nil, xerr.NewErrMsg("没有查看权限")
	}
	if articleInfo.Show == domain.ArticleShowDisable {
		// 文章内容不显示
		// resp = &types.MiniArticleGetResponse{
		// 	Id:    articleInfo.Id,
		// 	Title: articleInfo.Title,
		// 	Show:  int(domain.ArticleShowDisable),
		// }
		// return resp, nil
		return nil, xerr.NewErrMsg("没有查看权限")
	}

	queryOption := domain.NewQueryOptions().
		WithFindOnly().
		MustWithKV("articleId", articleInfo.Id)

	_, sectionList, err := l.svcCtx.ArticleSectionRepository.Find(l.ctx, conn, queryOption)
	if err != nil {
		return nil, xerr.NewErrMsgErr("读取文章内容失败", err)
	}

	//获取作者信息
	author, _ := l.svcCtx.UserRepository.FindOne(l.ctx, conn, int64(articleInfo.AuthorId))

	var meLoveFlag int
	if req.UserId > 0 {
		// 获取我对文章的点赞标识
		queryOption = domain.NewQueryOptions().
			WithCountOnly().
			MustWithKV("articleId", articleInfo.Id).
			MustWithKV("commentId", 0).
			MustWithKV("userId", req.UserId)
		cnt, _, _ := l.svcCtx.UserLoveFlagRepository.Find(l.ctx, conn, queryOption)
		if cnt > 0 {
			meLoveFlag = 1
		}
	}
	tags := []string{}
	if len(articleInfo.Tags) > 0 {
		queryOption := domain.NewQueryOptions().WithFindOnly().MustWithKV("ids", articleInfo.Tags)
		_, tagList, _ := l.svcCtx.ArticleTagRepository.Find(l.ctx, conn, req.CompanyId, queryOption)
		for _, val := range tagList {
			tags = append(tags, val.Name)
		}
	}
	// 查询我是否已关注文章的作者

	follow, _ := l.svcCtx.UserFollowRepository.FindOneUserFollowing(l.ctx, conn, int64(req.UserId), articleInfo.AuthorId)

	queryOption = domain.NewQueryOptions().WithCountOnly().WithOffsetLimit(1, 1).WithKV("articleId", articleInfo.Id)
	backupCount, _, _ := l.svcCtx.ArticleBackupRepository.Find(l.ctx, conn, queryOption)

	sortBy := domain.SortArticleSection(sectionList)
	sort.Sort(sortBy)
	articleSection := []types.ArticleSection{}

	for _, val := range sortBy {

		paragraphTemplate := core.NewTypesParagraph(val.ParagraphTemplate)
		paragraphTemplate.Images = val.Images
		paragraphTemplate.Text = val.Content
		articleSection = append(articleSection, types.ArticleSection{
			Id:                val.Id,
			Content:           val.Content,
			SortBy:            val.SortBy,
			TotalComment:      val.TotalComment,
			Images:            val.Images,
			ParagraphTemplate: core.NewTypesParagraph(val.ParagraphTemplate),
			ParagraphType:     val.ParagraphType,
		})
	}
	resp = &types.MiniArticleGetResponse{
		Id:       articleInfo.Id,
		Title:    articleInfo.Title,
		AuthorId: articleInfo.AuthorId,
		Author: types.ArticleAuthor{
			Id:       articleInfo.Author.Id,
			Name:     "",
			Avatar:   "",
			Position: "",
			Company:  companyInfo.Name,
		},
		CreatedAt:   articleInfo.CreatedAt,
		Section:     articleSection,
		Images:      []string{},
		Attachments: NewTypesAttachments(articleInfo.Attachments),
		WhoRead:     articleInfo.WhoRead,
		WhoReview:   articleInfo.WhoReview,
		Location: types.Location{
			Longitude: articleInfo.Location.Longitude,
			Latitude:  articleInfo.Location.Latitude,
			Descript:  articleInfo.Location.Descript,
		},
		CountLove:    articleInfo.CountLove,
		CountComment: articleInfo.CountComment,
		CountRead:    articleInfo.CountRead,
		Show:         int(articleInfo.Show),
		Edit:         0,
		MeLoveFlag:   meLoveFlag,
		MeFollowFlag: 0,
		Tags:         tags,
		MatchUrl:     map[string]string{},
		Videos:       []types.Video{},
		Cover:        articleInfo.GetCover(),
	}
	if backupCount > 1 {
		resp.Edit = 1
	}
	if author != nil {
		resp.Author = types.ArticleAuthor{
			Id:       articleInfo.Author.Id,
			Name:     author.Name,
			Avatar:   author.Avatar,
			Position: author.Position,
			Company:  companyInfo.Name,
		}
	}
	for k, v := range articleInfo.MatchUrl {
		resp.MatchUrl[k] = v
	}
	for _, val := range articleInfo.Images {
		resp.Images = append(resp.Images, val.Url)
	}

	for _, val := range articleInfo.Videos {
		resp.Videos = append(resp.Videos, types.Video{
			Url:    val.Url,
			Cover:  val.Cover,
			Width:  val.Width,
			Height: val.Height,
		})
	}

	if follow != nil {
		resp.MeFollowFlag = 1
	}
	if resp.AuthorId == int64(req.UserId) {
		// 作者本人在查看
		resp.MeFollowFlag = 1
	}
	return
}