package cust

import (
	"context"
	"fmt"

	"github.com/gogf/gf/errors/gerror"
	"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"
	//serviceLog "dashoo.cn/micro/app/service/cust"
)

type customercontactService struct {
	*service.ContextService
	Dao *cust.CustCustomerContactDao
}

func NewCustomerContactService(ctx context.Context) (svc *customercontactService, err error) {
	svc = new(customercontactService)

	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}

	svc.Dao = cust.NewCustCustomerContactDao(svc.Tenant)

	return svc, nil
}

//添加联系人
func (c *customercontactService) Create(req *model.CustCustomerContactSeq) (err error) {
	contact := new(model.CustCustomerContact)
	if err = gconv.Struct(req, contact); err != nil {
		g.Log().Info("error", err)
		return
	}
	service.SetCreatedInfo(contact, c.GetCxtUserId(), c.GetCxtUserName())
	Model := c.Dao.M
	res, err := Model.Insert(contact)
	if err != nil {
		return
	}

	InsertId, _ := res.LastInsertId()
	fmt.Println(InsertId)
	return
}

//修改联系人
func (c *customercontactService) UpdateById(req *model.UpdateCustCustomerContactSeq) (err error) {
	Model := c.Dao.M
	record, err := Model.FindOne("Id", req.Id)
	if err != nil || record.IsEmpty() {
		err = gerror.New("该数据不存在")
		return err
	}
	CustomertData := new(model.CustCustomerContact)
	if err = gconv.Struct(req, CustomertData); err != nil {
		return
	}
	service.SetUpdatedInfo(CustomertData, c.GetCxtUserId(), c.GetCxtUserName())
	_, err = Model.FieldsEx(c.Dao.Columns.CreatedTime, c.Dao.Columns.CreatedBy, c.Dao.Columns.CreatedName, c.Dao.Columns.CustId, c.Dao.Columns.Id).
		WherePri(c.Dao.Columns.Id, req.Id).Update(CustomertData)

	if err != nil {
		g.Log().Error(err)
		err = gerror.New("修改用户信息失败")
		return
	}
	return
}

//获取联系人信息
func (c *customercontactService) GetList(CustId int) (Info []*model.CustCustomerContactInfo, err error) {
	Model := c.Dao.M
	err = Model.Where(c.Dao.Columns.CustId, CustId).Where(c.Dao.Columns.DeletedTime + " is null").Scan(&Info)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取联系人信息失败")
		return
	}
	return
}

//删除联系人
func (c *customercontactService) DeleteById(id int) error {
	Model := c.Dao.M

	deleteTime := gtime.Now()
	// 删除客户联系人表
	_, err := Model.Data(g.Map{
		"deleted_time": deleteTime,
	}).Where(c.Dao.Columns.Id, id).Update()
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("删除数据失败")
		return err
	}
	return nil
}