package proj

import (
	"context"
	projDao "dashoo.cn/micro/app/dao/proj"
	model "dashoo.cn/micro/app/model/proj"
	"dashoo.cn/micro/app/service"
	"github.com/gogf/gf/database/gdb"
)

type businessDynamicsService struct {
	*service.ContextService
	Dao *projDao.ProjBusinessDynamicsDao
}

func NewBusinessDynamicsService(ctx context.Context) (svc *businessDynamicsService, err error) {
	svc = new(businessDynamicsService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = projDao.NewProjBusinessDynamicsDao(svc.Tenant)
	return svc, nil
}

func (p *businessDynamicsService) GetList(busId int64) (businessList []*model.ProjBusinessDynamics, err error) {
	err = p.Dao.Where(p.Dao.Columns.BusId, busId).Order("id desc").Scan(&businessList)
	return
}

func (p *businessDynamicsService) GetEntityById(id int64) (business *model.ProjBusinessDynamics, err error) {
	err = p.Dao.Where(projDao.ProjBusinessDynamics.Columns.Id, id).Scan(&business)
	return
}

func (p *businessDynamicsService) Create(businessData *model.ProjBusinessDynamics, tenant string, tx *gdb.TX) (err error) {
	_, err = projDao.NewProjBusinessDao(tenant).TX(tx).Insert(businessData)
	return
}

func (p *businessDynamicsService) DeleteByIds(ids []int64) (err error) {
	_, err = p.Dao.WhereIn(projDao.ProjBusinessDynamics.Columns.Id, ids).Delete()
	return
}