package plat

import (
	"context"

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

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

type taskLogService struct {
	*service.ContextService

	Dao *plat.PlatTaskLogDao
}

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

// 任务日志信息列表
func (s *taskLogService) GetList(req *model.SearchPlatTaskLogReq) (total int, TaskLogList []*model.PlatTaskLog, err error) {
	TaskLogModel := s.Dao.M

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

	err = TaskLogModel.Order("created_time DESC").Scan(&TaskLogList)
	return
}