package cust

import (
	"context"

	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gconv"

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

type CustomerbelongService struct {
	*service.ContextService
	Dao *cust.CustCustomerBelongDao
}

func NewCustomerBelongService(ctx context.Context) (svc *CustomerbelongService, err error) {
	svc = new(CustomerbelongService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = cust.NewCustCustomerBelongDao(svc.Tenant)
	return svc, nil
}

//GetList 获取客户归属信息
func (s *CustomerbelongService) GetList(req *model.ReqCustomerBelongReq) (total int, Info []*model.CustomerBelongInfo, err error) {
	err = s.Dao.Where("cust_id = ", req.CustId).Order(" created_time desc ").Scan(&Info)
	if err != nil {
		g.Log().Error(err)
		return
	}
	total, err = s.Dao.Where("cust_id = ", req.CustId).Count()
	if err != nil {
		g.Log().Error(err)
		err = myerrors.DbError("获取总行数失败。")
		return
	}
	return
}

//Create 插入归属销售
func (s *CustomerbelongService) Create(req *model.CustomerBelongAddSeq) (err error) {

	cusTomerBelong := new(model.CustCustomerBelong)
	if err = gconv.Struct(req, cusTomerBelong); err != nil {
		g.Log().Error(err)
		return
	}
	cusTomerBelong.OpnDatetime = gtime.Now()
	cusTomerBelong.StartDate = gtime.Now()
	service.SetCreatedInfo(cusTomerBelong, s.GetCxtUserId(), s.GetCxtUserName())
	_, err = s.Dao.Insert(cusTomerBelong)
	if err != nil {
		g.Log().Error(err)
		return
	}
	return nil
}

//