package proj

import (
	"context"
	"github.com/gogf/gf/util/gconv"

	projDao "dashoo.cn/micro/app/dao/proj"
	model "dashoo.cn/micro/app/model/proj"
	"dashoo.cn/micro/app/service"
)

type businessFileService struct {
	*service.ContextService
	Dao *projDao.ProjBusinessFileDao
}

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

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

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

func (p *businessFileService) Create(req *model.ProjBusinessFileReq) (err error) {
	businessData := new(model.ProjBusinessFile)
	if err = gconv.Struct(req, businessData); err != nil {
		return
	}
	service.SetCreatedInfo(businessData, p.GetCxtUserId(), p.GetCxtUserName())
	_, err = p.Dao.Insert(businessData)
	return
}

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