opms_backend/opms_parent/app/handler/cust/customer.go

package cust

import (
	"context"
	"dashoo.cn/micro/app/model/contract"
	"encoding/base64"

	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gvalid"

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

type CustomerHeader struct{}

var isPublic, noPublic = "10", "20" // 公海,非公海
var noCustomer = true               // 区分公海列表 和 客户列表 true  公海

// Swagger:Customer 客户 客户列表
func (c *CustomerHeader) GetList(ctx context.Context, req *model.CustCustomerSearchReq, rsp *comm_def.CommonMsg) error {
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	total, list, err := customerServer.GetList(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil

}

// Swagger:Customer 客户 公海列表
func (c *CustomerHeader) PublicGetList(ctx context.Context, req *model.CustCustomerSearchReq, rsp *comm_def.CommonMsg) error {
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {

		return err
	}

	req.IsPublic = noCustomer

	total, list, err := customerServer.GetList(req)
	if err != nil {

		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil

}

// Swagger:Customer 客户 创建客户
func (c *CustomerHeader) Create(ctx context.Context, req *model.CustomerAddSeq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {

		return err

	}
	id, err := s.Create(req)
	if err != nil {

		return err
	}
	s.CreateDynamics("创建客户", req, id)
	rsp.Data = g.Map{"lastId": id}
	return nil
}

// Swagger:Customer 客户 修改客户
func (c *CustomerHeader) UpdateById(ctx context.Context, req *model.UpdateCustomer, rsp *comm_def.CommonMsg) error {
	s, err := server.NewCustomerService(ctx)
	if err != nil {

		return err
	}
	err = s.UpdateById(req)
	if err != nil {

		return err
	}
	s.CreateDynamics("编辑客户", req, req.Id)
	return nil
}

// Swagger:Customer 客户 客户详情
func (c *CustomerHeader) GetEntityById(ctx context.Context, req *comm_def.IdsReq, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 {
		return myerrors.ValidError("参数有误")
	}
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {

		return err
	}
	list, err := customerServer.GetEntityById(req.Ids)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list}
	return nil
}

// Swagger:Customer 客户 删除客户
func (c *CustomerHeader) DeleteById(ctx context.Context, req *model.DelCustomer, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 {
		return myerrors.ValidError("参数有误")
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.DeleteByIds(req.Ids)
	if err != nil {
		return err
	}
	//删除客户
	s.CreateDynamics("删除客户", req, req.Ids...)
	return nil
}

// Swagger:Customer 客户 判断客户名称是否存在
func (c *CustomerHeader) GetCustNameIsExist(ctx context.Context, req *model.IsExistsCustName, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	exist, err := customerServer.GetCustNameIsExist(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": exist}
	return nil
}

// Swagger:Customer 客户 转移客户
func (c *CustomerHeader) TransCustomer(ctx context.Context, req *model.AssignCustomerReq, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 || req.SalesId == 0 {
		return myerrors.ValidError("参数有误")
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.TransCustomerRequest(ctx, req)
	if err != nil {
		return err
	}
	return nil
}

// Swagger:Customer 客户 分配、领取客户
func (c *CustomerHeader) AssignCustomer(ctx context.Context, req *model.AssignCustomerReq, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 || req.SalesId == 0 {
		return myerrors.ValidError("参数有误")
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.AssignCustomer(ctx, req)
	if err != nil {
		return err
	}
	return nil

}

// Swagger:Customer 客户 移入公海
func (c *CustomerHeader) MoveToPubic(ctx context.Context, req *model.MoveToPubicRep, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 {
		return myerrors.ValidError("参数有误")
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.MoveToPublicRequest(ctx, req)
	if err != nil {

		return err
	}
	return nil
}

// Swagger:Customer 客户 客户动态
func (c *CustomerHeader) GetDynamicsList(ctx context.Context, req *model.CustomerDynameicsReq, rsp *comm_def.CommonMsg) error {
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	total, list, err := customerServer.GetDynamicsList(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}

// Swagger:Customer 客户 合并客户
func (c *CustomerHeader) MergeCustomer(ctx context.Context, req *model.MergeCustomerRep, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.MergeCustomer(req)
	if err != nil {
		return err
	}

	s.CreateDynamics("合并客户", req, req.Id)
	return nil
}

// Swagger:Customer 客户 客户摘要
func (c *CustomerHeader) GetCustAbstract(ctx context.Context, req *comm_def.IdReq, rsp *comm_def.CommonMsg) error {
	if req.Id == 0 {
		return myerrors.ValidError("参数有误")
	}
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	list, err := customerServer.CustAbstract(req.Id)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list}
	return nil
}

// Swagger:Customer 客户 导出
func (c *CustomerHeader) Export(ctx context.Context, req *model.CustCustomerExport, rsp *comm_def.CommonMsg) error {
	customerServer, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	} //Export
	buffer, err := customerServer.Export(ctx, req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": buffer}
	return nil
}

// Swagger:Customer 客户 系统管理员转移客户(不走审批)
func (c *CustomerHeader) SysAdminTransCustomer(ctx context.Context, req *model.AssignCustomerReq, rsp *comm_def.CommonMsg) error {
	if len(req.Ids) == 0 || req.SalesId == 0 {
		return myerrors.ValidError("参数有误")
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {
		return err
	}
	err = s.SysAdminTransCustomer(ctx, req)
	if err != nil {
		return err
	}
	return nil
}

// Swagger:Customer 导入客户 模板
func (c *CustomerHeader) ExcelTemplate(ctx context.Context, req *struct{}, rsp *comm_def.CommonMsg) error {
	//g.Log().Infof("TeQuestionDocDetail.ExcelTemplate request %#v ", *req)
	f, err := server.ExcelTemplate()
	if err != nil {
		return err
	}
	buf, err := f.WriteToBuffer()
	if err != nil {
		return err
	}
	rsp.Data = base64.StdEncoding.EncodeToString(buf.Bytes())
	return nil
}

// Swagger:Customer 客户 导入客户并创建联系人
func (c *CustomerHeader) Import(ctx context.Context, req *contract.ExcelImportReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	s, err := server.NewCustomerService(ctx)
	if err != nil {

		return err

	}
	err, failedCount, failedData := s.Import(ctx, req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"failedCount": failedCount, "failedData": failedData}
	return nil
}