package plat

import (
	"context"

	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"

	"dashoo.cn/micro/app/dao/plat"
	model "dashoo.cn/micro/app/model/plat"
	"dashoo.cn/micro/app/service"
)

type taskCommentService struct {
	*service.ContextService

	Dao *plat.PlatTaskCommentDao
}

func NewTaskCommentService(ctx context.Context) (svc *taskCommentService, err error) {
	svc = new(taskCommentService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = plat.NewPlatTaskCommentDao(svc.Tenant)
	return svc, nil
}

// 任务评论信息列表
func (s *taskCommentService) GetList(req *model.SearchPlatTaskCommentReq) (total int, TaskCommentList []*model.PlatTaskComment, err error) {
	TaskCommentModel := s.Dao.M

	if req.TaskId != "" {
		TaskCommentModel = TaskCommentModel.Where("task_id", req.TaskId)
	}
	if req.Pid != "" {
		TaskCommentModel = TaskCommentModel.Where("pid", req.Pid)
	}
	total, err = TaskCommentModel.Count()
	if err != nil {
		g.Log().Error(err)
		err = myerrors.DbError("获取总行数失败。")
		return
	}

	err = TaskCommentModel.Order("created_time DESC").Scan(&TaskCommentList)
	return
}

// 添加信息
func (s *taskCommentService) Create(req *model.AddPlatTaskCommentReq) (err error) {
	platTaskComment := new(model.PlatTaskComment)
	if err = gconv.Struct(req, platTaskComment); err != nil {
		return
	}
	// 填充创建信息
	service.SetCreatedInfo(platTaskComment, s.GetCxtUserId(), s.GetCxtUserName())
	// 填充更新信息
	//service.SetUpdatedInfo(platTaskComment, s.GetCxtUserId(), s.GetCxtUserName())
	_, err = s.Dao.Insert(platTaskComment)
	if err != nil {
		return
	}

	return
}