opms_backend/opms_parent/app/service/plat/plat_task_progress.go

package plat

import (
	"context"
	"dashoo.cn/micro/app/dao/plat"
	model "dashoo.cn/micro/app/model/plat"
	"dashoo.cn/micro/app/service"
	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"
)

type taskProgressService struct {
	*service.ContextService

	Dao *plat.PlatTaskProgressDao
}

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

// 任务进展信息列表
func (s *taskProgressService) GetList(req *model.SearchPlatTaskProgressReq) (total int, taskProgressList []*model.PlatTaskProgress, err error) {
	taskProgressModel := s.Dao.M

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

	err = taskProgressModel.Order("created_time DESC").Scan(&taskProgressList)
	return
}

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

	// 流程日志
	err = CreateTaskLog(nil, s, req.TaskId, s.GetCxtUserId(), s.GetCxtUserName(), "添加进展", "任务进展更新", "")

	return
}