package base

import (
	"context"

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

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

type distributorService struct {
	*service.ContextService

	Dao *base.BaseDistributorDao
}

func NewDistributorService(ctx context.Context) (svc *distributorService, err error) {
	svc = new(distributorService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = base.NewBaseDistributorDao(svc.Tenant)
	return svc, nil
}

//经销商信息列表 distributorList []*model.BaseDistributorRonp
func (d *distributorService) GetList(req *model.BaseDistributorSearchReq) (total int, distributorList []*model.DistributorRonp, err error) {
	distributorModel := d.Dao.M
	if req.DistCode != "" {
		distributorModel = distributorModel.Where("u.dist_code", req.DistCode)
	}
	if req.DistName != "" {
		distributorModel = distributorModel.Where("dist_name like ?", "%"+req.DistName+"%")
	}
	if req.BelongSale != "" {
		distributorModel = distributorModel.Where("belong_sale like ?", "%"+req.BelongSale+"%")
	}
	if req.ProvinceId != 0 {
		distributorModel = distributorModel.Where("province_id ", req.ProvinceId)
	}
	g.Log().Info("搜索条件", req.BelongSale)
	total, err = distributorModel.Count()
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取总行数失败")
		return
	}
	if req.PageNum == 0 {
		req.PageNum = 1
	}
	err = distributorModel.Page(req.PageNum, req.PageSize).Order("id desc").Scan(&distributorList)
	g.Log().Info("返回列表", distributorList)
	return
}