package base

import (
	"context"

	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"

	"dashoo.cn/micro/app/dao/base"
	model "dashoo.cn/micro/app/model/base"
	"dashoo.cn/micro/app/service"
)

type salesRegionService struct {
	*service.ContextService
	Dao    *base.BaseSalesRegionDao
	Detail *base.BaseSalesRegionDetailDao
}

func NewSalesRegionService(ctx context.Context) (svc *salesRegionService, err error) {
	svc = new(salesRegionService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = base.NewBaseSalesRegionDao(svc.Tenant)
	svc.Detail = base.NewBaseSalesRegionDetailDao(svc.Tenant)

	return svc, nil
}
func (p *salesRegionService) GetList(req *model.RegionSeq) (total int, RegionList []*model.BaseSalesRegion, err error) {

	regionModel := p.Dao.M
	//if req.KeyWords != "" {
	//	regionModel = regionModel.Where("prod_code", req.KeyWords)
	//
	//}
	total, err = regionModel.Count()
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取总行数失败")
		return
	}
	if req.PageNum == 0 {
		req.PageNum = 1
	}

	err = regionModel.Page(req.PageNum, req.PageSize).Order("id asc").Scan(&RegionList)
	return
}

//创建区域
func (p *salesRegionService) Create(req *model.AddBaseRegionReq) (err error) {
	Model := p.Detail.M
	detailData := new(model.BaseSalesRegionDetail)

	if err = gconv.Struct(req, detailData); err != nil {
		return
	}
	service.SetCreatedInfo(detailData, p.GetCxtUserId(), p.GetCxtUserName())

	detailData.RegionId = req.Id
	detailData.ProvinceCode = req.RegionCode
	service.SetCreatedInfo(detailData, p.GetCxtUserId(), p.GetCxtUserName())
	_, err = Model.Insert(detailData)
	if err != nil {
		return err
	}
	return nil

}

//获取区域列表
func (p *salesRegionService) GetRegion() (RegionList []*model.RegionRep) {
	regionModel := p.Dao.M
	err := regionModel.Order("id asc").Scan(&RegionList)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取数据失败")
		return
	}
	return
}