package proj

import (
	"context"
	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"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 businessDynamicsService struct {
	*service.ContextService
	Dao *projDao.ProjBusinessDao
}

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.NewProjBusinessDao(svc.Tenant)
	return svc, nil
}

func (p *businessDynamicsService) GetList(req *model.ProjBusinessSearchReq) (total int, businessList []*model.ProjBusiness, err error) {
	db := p.Dao.M
	if req.NboName != "" {
		db = db.WhereLike(p.Dao.Columns.NboName, "%"+req.NboName+"%")
	}
	if req.CustName != "" {
		db = db.WhereLike(p.Dao.Columns.CustName, "%"+req.CustName+"%")
	}
	if req.SaleName != "" {
		db = db.WhereLike(p.Dao.Columns.SaleName, "%"+req.SaleName+"%")
	}
	if req.NboType != "" {
		db = db.Where(p.Dao.Columns.NboType, req.NboType)
	}
	total, err = db.Count()
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取总行数失败")
		return
	}

	err = db.Page(req.GetPage()).Order("id desc").Scan(&businessList)
	return
}

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

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

func (p *businessDynamicsService) UpdateById(req *model.UpdateProjBusinessReq) (err error) {
	db := p.Dao.M
	record, err := db.Count("Id", req.Id)
	if err != nil || record == 0 {
		err = gerror.New("该数据不存在")
		return err
	}
	businessData := new(model.ProjBusiness)
	if err = gconv.Struct(req, businessData); err != nil {
		return
	}
	service.SetUpdatedInfo(businessData, p.GetCxtUserId(), p.GetCxtUserName())
	_, err = db.FieldsEx(service.UpdateFieldEx).WherePri(projDao.ProjBusinessDynamics.Columns.Id, req.Id).Update(businessData)
	return
}

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