// Package basic
// @Link  https://gitee.com/linngc/webos.gf
// @Copyright  Copyright (c) 2022 webos CLI
// @Author  linngc
// @License
package basic

import (
	"context"
	dao "gitee.com/linngc/center.gf/internal/gendao/dao/system/basic"
	do "gitee.com/linngc/center.gf/internal/gendao/do/system/basic"
	entity "gitee.com/linngc/center.gf/internal/gendao/entity/system/basic"
	"gitee.com/linngc/center.gf/internal/service/platform/system/basic"
	"github.com/gogf/gf/v2/database/gdb"
)

type (
	sSysJob struct{}
)

func (s *sSysJob) AllList(ctx context.Context) (entities []*entity.SysJob, err error) {
	dao.SysJob.Ctx(ctx).OrderAsc("tree_id").Scan(&entities)
	return
}
func (s *sSysJob) GetById(ctx context.Context, id int) (en *entity.SysJob, err error) {
	dao.SysJob.Ctx(ctx).Where(do.SysJob{Id: id}).Scan(&en)
	return
}
func (s *sSysJob) SaveOrUpdate(ctx context.Context, en *entity.SysJob) (err error) {
	return dao.SysJob.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
		if en.Id == 0 {
			//创建数据时，因为主键id为字增，排除主键id
			_, err = dao.SysJob.Ctx(ctx).Data(en).FieldsEx("id").Insert()
		} else {
			_, err = dao.SysJob.Ctx(ctx).Data(en).Update()
		}
		return err
	})
}

func (s *sSysJob) SaveOrUpdateBatch(ctx context.Context, entities []*entity.SysJob) (err error) {
	return dao.SysJob.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
		for _, en := range entities {
			if en.Id == 0 {
				//创建数据时，因为主键id为字增，排除主键id
				_, err = dao.SysJob.Ctx(ctx).Data(en).FieldsEx("id").Insert()
			} else {
				_, err = dao.SysJob.Ctx(ctx).Data(en).Update()
			}
		}
		return err
	})
}

func (s *sSysJob) Count(ctx context.Context) (count int, err error) {
	return dao.SysJob.Ctx(ctx).Count()
}

func (s *sSysJob) Delete(ctx context.Context, ids []int) (err error) {
	return dao.SysJob.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
		_, err = dao.SysJob.Ctx(ctx).WhereIn("Id", ids).Delete()
		return err
	})
}

func (s *sSysJob) DeleteAndSaveBatch(ctx context.Context, entities []*entity.SysJob) (err error) {
	return dao.SysJob.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
		dao.SysJob.Ctx(ctx).Data(entities).Delete()
		dao.SysJob.Ctx(ctx).Data(entities).Insert()
		return err
	})
}

func init() {
	basic.RegisterSysJob(NewSysJob())
}

func NewSysJob() *sSysJob {
	return &sSysJob{}
}