package cust

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

//func NewCustomerDynamicsService(ctx context.Context) (svc *customerDynamicsService, err error) {
//	svc = new(customerDynamicsService)
//	if svc.ContextService, err = svc.Init(ctx); err != nil {
//		return nil, err
//	}
//	svc.Dao = cust.NewCustCustomerDynamicsDao(svc.Tenant)
//	return svc, nil
//}

//客户操作日志
func (c *customerDynamicsService) Create(req *model.AddCustomerDynameicsReq) (err error) {
	cusDynameics := new(model.CustCustomerDynamics)
	if err = gconv.Struct(req, cusDynameics); err != nil {
		g.Log().Info("error", err)
		return
	}
	Model := c.Dao.M
	service.SetCreatedInfo(cusDynameics, c.GetCxtUserId(), c.GetCxtUserName())
	_, err = Model.Insert(cusDynameics)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("创建失败")
		return
	}
	return
}

//日志详情
func (c *customerDynamicsService) GetEntityById(id int64) (dynamics *model.CustomerDynameicsRep, err error) {
	Model := c.Dao.M
	err = Model.Where(cust.CustCustomerDynamics.Columns.Id, id).Scan(&dynamics)
	if err != nil {
		g.Log().Error(err)
		return nil, gerror.New("获取用户数据失败")
	}
	return
}