|
|
@@ -24,17 +24,19 @@ const TIME_LAYOUT = "2006-01-02 15:04:05"
|
|
|
|
|
|
type CustomerService struct {
|
|
|
*service.ContextService
|
|
|
- Dao *cust.CustCustomerDao
|
|
|
- BelongDao *cust.CustCustomerBelongDao
|
|
|
- DynamicsDao *cust.CustCustomerDynamicsDao
|
|
|
- ContactDao *cust.CustCustomerContactDao
|
|
|
- FollowDao *platdao.PlatFollowupDao
|
|
|
+ Dao *cust.CustCustomerDao
|
|
|
+ BelongDao *cust.CustCustomerBelongDao
|
|
|
+ DynamicsDao *cust.CustCustomerDynamicsDao
|
|
|
+ ContactDao *cust.CustCustomerContactDao
|
|
|
+ FollowDao *platdao.PlatFollowupDao
|
|
|
+ BelongServer *CustomerbelongService
|
|
|
+ ContanctServer *CustomercontactService
|
|
|
}
|
|
|
|
|
|
-var isPublic, noPublic = "10", "20" // 公海,非公海
|
|
|
-var isTransfer int8 = 1 //转移
|
|
|
-var isAllocation int8 = 2 //分配 Allocation
|
|
|
-var OperaTion, AllocaTion, Receive = "20", "10", "30"
|
|
|
+var isPublic, noPublic = "10", "20" // 公海,非公海
|
|
|
+var isTransfer int8 = 1 //转移
|
|
|
+var isAllocation int8 = 2 //分配 Allocation
|
|
|
+var OperaTion, AllocaTion, Receive, Merge = "20", "10", "30", "40" // 10分配20转移30领取40合并
|
|
|
|
|
|
type OpnType struct {
|
|
|
OperaTion string
|
|
|
@@ -50,13 +52,14 @@ func NewCustomerService(ctx context.Context) (svc *CustomerService, err error) {
|
|
|
svc.DynamicsDao = cust.NewCustCustomerDynamicsDao(svc.Tenant)
|
|
|
svc.ContactDao = cust.NewCustCustomerContactDao(svc.Tenant)
|
|
|
svc.FollowDao = platdao.NewPlatFollowupDao(svc.Tenant)
|
|
|
+ svc.BelongServer, _ = NewCustomerBelongService(ctx)
|
|
|
+ svc.ContanctServer, _ = NewCustomerContactService(ctx)
|
|
|
return svc, nil
|
|
|
}
|
|
|
|
|
|
//导出数据
|
|
|
func (c *CustomerService) Derive(req *model.CustCustomerExport) (content *model.CustExport, err error) {
|
|
|
var con model.CustExport
|
|
|
- req.CustCustomerSearchReq.TargetType = "11"
|
|
|
total, data, err := c.GetList(&req.CustCustomerSearchReq)
|
|
|
if err != nil {
|
|
|
return
|
|
|
@@ -71,18 +74,42 @@ func (c *CustomerService) Derive(req *model.CustCustomerExport) (content *model.
|
|
|
|
|
|
for ck, item := range data {
|
|
|
for index, v := range req.Columns {
|
|
|
- if v == "经销商编码" {
|
|
|
+ // "CustCode":客户编码
|
|
|
+ if v == "客户编码" {
|
|
|
f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustCode)
|
|
|
}
|
|
|
- if v == "经销商名称" {
|
|
|
+ if v == "客户名称" {
|
|
|
f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustName)
|
|
|
}
|
|
|
if v == "助记名" {
|
|
|
f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.AbbrName)
|
|
|
}
|
|
|
- //if v == "所在地区" {
|
|
|
- // f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.)
|
|
|
- //}
|
|
|
+ if v == "助记名" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.AbbrName)
|
|
|
+ }
|
|
|
+ if v == "所在地区" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustLocation)
|
|
|
+ }
|
|
|
+ if v == "客户行业" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustIndustry)
|
|
|
+ }
|
|
|
+ if v == "客户级别" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustLevel)
|
|
|
+ }
|
|
|
+ if v == "客户状态" {
|
|
|
+ var CustStatus string
|
|
|
+ CustStatus = "正常"
|
|
|
+ if item.CustStatus != "10" {
|
|
|
+ CustStatus = "异常"
|
|
|
+ }
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), CustStatus)
|
|
|
+ }
|
|
|
+ if v == "最后跟进时间" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.FollowUpDate)
|
|
|
+ }
|
|
|
+ if v == "创建时间" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CreatedTime)
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
}
|
|
|
@@ -108,82 +135,43 @@ func (c *CustomerService) Create(req *model.Customer) (insertId int64, err error
|
|
|
err = gerror.New("该客户信息已存在,不可重复添加")
|
|
|
return
|
|
|
}
|
|
|
- //OpnPeopleId int ` json:"opnPeopleId"` // 操作人ID
|
|
|
- //OpnPeople string ` json:"opnPeople"` // 操作人
|
|
|
- //OpnDate *gtime.Time ` json:"opnDate"` // 操作日期
|
|
|
- //OpnType string ` json:"opnType"` // 操作类型
|
|
|
- //OpnContent string ` json:"opnContent"` // 操作内容
|
|
|
|
|
|
- //c.OperationLog()
|
|
|
if err = gconv.Struct(req, cusTomer); err != nil {
|
|
|
return
|
|
|
}
|
|
|
- g.Log().Info("部门ID", c.CxtUser.DeptId)
|
|
|
service.SetCreatedInfo(cusTomer, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
cusTomer.CustCode = strconv.Itoa(int(gtime.Timestamp()))
|
|
|
+
|
|
|
cusTomer.IsPublic = isPublic
|
|
|
cusTomer.CustStatus = "10"
|
|
|
- //if c.CxtUser.DeptId == 2 {
|
|
|
- // cusTomer.IsPublic = noPublic // 非公海用户
|
|
|
- // cusTomer.DeptId = c.GetCxtUserDeptId() // 部门id
|
|
|
- // cusTomer.DeptId = c.GetCxtUserDeptId() // 部门名称
|
|
|
- // cusTomer.SalesId = c.GetCxtUserId() // 销售id
|
|
|
- // cusTomer.SalesName = c.GetCxtUserName() // 销售名称
|
|
|
- //}
|
|
|
res, err := Model.Insert(cusTomer)
|
|
|
if err != nil {
|
|
|
g.Log().Error(err)
|
|
|
err = gerror.New("创建失败")
|
|
|
return
|
|
|
}
|
|
|
- //
|
|
|
|
|
|
- insertId, _ = res.LastInsertId()
|
|
|
+ /**
|
|
|
+ CustomerbelongService := new(CustomerbelongService)
|
|
|
+ err = CustomerbelongService.Create(req)
|
|
|
+ */
|
|
|
|
|
|
- //销售人员创建条件成立 同步belong 表
|
|
|
- //custBelong := new(model.AddCustomerBelong)
|
|
|
- //custBelong.CustId = int(insertId)
|
|
|
- //custBelong.SaleName = "xxx"
|
|
|
- //custBelong.OpnPeople = "xxxx"
|
|
|
- //custBelong.OpnDatetime = gtime.Now()
|
|
|
- //err = c.CreateBelong()
|
|
|
+ insertId, _ = res.LastInsertId()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//销售人员创建 直接认领客户
|
|
|
-func (c *CustomerService) CreateBelong(req *model.AddCustomerBelong) (err error) {
|
|
|
- cusTomerBelong := new(model.CustCustomerBelong)
|
|
|
- if err = gconv.Struct(req, cusTomerBelong); err != nil {
|
|
|
- g.Log().Info("error", err)
|
|
|
- return
|
|
|
- }
|
|
|
- service.SetCreatedInfo(cusTomerBelong, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
-
|
|
|
- cusTomerBelong.OpnType = isPublic
|
|
|
- cusTomerBelong.OpnDatetime = gtime.Now()
|
|
|
- service.SetCreatedInfo(cusTomerBelong, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
- _, err = c.BelongDao.Insert(cusTomerBelong)
|
|
|
- if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("创建失败")
|
|
|
- return
|
|
|
- }
|
|
|
- return nil
|
|
|
-
|
|
|
-}
|
|
|
-
|
|
|
//客户列表列表
|
|
|
func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int, customerList []*model.CustList, err error) {
|
|
|
|
|
|
g.Log().Info("serverS", req)
|
|
|
Model := c.Dao.M
|
|
|
- Model = Model.Where(c.Dao.Columns.DeletedTime + " is null")
|
|
|
+ //Model = Model.Where(c.Dao.Columns.DeletedTime + " is null")
|
|
|
if req.TargetType == "" {
|
|
|
if !req.IsPublic {
|
|
|
- g.Log().Info("ISPUblic", "xxxxxx")
|
|
|
+
|
|
|
Model = Model.Where(c.Dao.Columns.SalesId, c.CxtUser.Id).Where(c.Dao.Columns.IsPublic, noPublic)
|
|
|
} else {
|
|
|
- g.Log().Info("serverS", req)
|
|
|
+
|
|
|
Model = Model.Where(c.Dao.Columns.IsPublic, isPublic)
|
|
|
}
|
|
|
}
|
|
|
@@ -217,7 +205,8 @@ func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int,
|
|
|
if req.PageNum == 0 {
|
|
|
req.PageNum = 1
|
|
|
}
|
|
|
- err = Model.Page(req.PageNum, req.PageSize).Order("id desc").Scan(&customerList)
|
|
|
+
|
|
|
+ err = Model.Page(req.GetPage()).Order("id desc").Scan(&customerList)
|
|
|
for _, v := range customerList {
|
|
|
times := gconv.String(v.CreatedTime)
|
|
|
v.FollowUpDate = gstr.SubStr(v.FollowUpDate, 0, 16)
|
|
|
@@ -228,9 +217,9 @@ func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int,
|
|
|
|
|
|
//删除客户
|
|
|
func (c *CustomerService) DeleteById(id int) error {
|
|
|
-
|
|
|
- Model := c.Dao.M
|
|
|
+ Model := c.Dao
|
|
|
ContactModel := c.ContactDao //联系人
|
|
|
+ BelongModel := c.BelongDao
|
|
|
regionDetail := new(model.CustCustomer)
|
|
|
err := Model.Where(c.Dao.Columns.Id, id).Scan(®ionDetail)
|
|
|
//g.Log().Info("DeleteByIds", one)
|
|
|
@@ -239,17 +228,22 @@ func (c *CustomerService) DeleteById(id int) error {
|
|
|
err = gerror.New("没有要删除的数据")
|
|
|
return err
|
|
|
}
|
|
|
- deleteTime := gtime.Now()
|
|
|
- //删除客户表
|
|
|
- _, err = Model.Data(g.Map{
|
|
|
- "deleted_time": deleteTime,
|
|
|
- }).Where(c.Dao.Columns.Id, id).Update()
|
|
|
- // 删除客户联系人表
|
|
|
- _, err = ContactModel.Data(g.Map{
|
|
|
- "deleted_time": deleteTime,
|
|
|
- }).Where(c.ContactDao.Columns.CustId, id).Update()
|
|
|
|
|
|
- if err != nil {
|
|
|
+ //删除客户表
|
|
|
+ _, err = Model.Where(c.Dao.Columns.Id, id).Delete()
|
|
|
+ if err == nil {
|
|
|
+ _, err = ContactModel.Where(c.ContactDao.Columns.CustId, id).Delete()
|
|
|
+ if err == nil {
|
|
|
+ _, err = BelongModel.Where(c.BelongDao.Columns.CustId, id).Delete()
|
|
|
+ if err != nil {
|
|
|
+ err = gerror.New("删除数据失败")
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ err = gerror.New("删除数据失败")
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
g.Log().Error(err)
|
|
|
err = gerror.New("删除数据失败")
|
|
|
return err
|
|
|
@@ -313,29 +307,42 @@ func (c *CustomerService) MoveToPubic(ids []int64) error {
|
|
|
|
|
|
//分配客户
|
|
|
func (c *CustomerService) DistriCustomer(req *model.DistriCustomer) error {
|
|
|
- custModel := c.Dao.M
|
|
|
+ custModel := c.Dao
|
|
|
rep, err := custModel.Where(cust.CustCustomer.Columns.Id+" in (?) ", req.Ids).Where(cust.CustCustomer.Columns.IsPublic, isPublic).All()
|
|
|
- if err != nil {
|
|
|
+
|
|
|
+ g.Log().Info("fdasfsa", len(rep))
|
|
|
+ if err != nil || len(rep) == 0 {
|
|
|
err = gerror.New("该数据不存在")
|
|
|
return err
|
|
|
}
|
|
|
+ //cust := new(model.CustCustomer)
|
|
|
+ var custMap = make(map[int]string)
|
|
|
+ for _, v := range rep {
|
|
|
+ custMap[v.Id] = v.SalesName
|
|
|
+ }
|
|
|
+ g.Log().Info("fadfadsfaf", custMap)
|
|
|
+ for _, v := range req.Ids {
|
|
|
+ g.Log().Info("req.Ids", v)
|
|
|
+ if custMap[gconv.Int(v)] != "" {
|
|
|
+ err = gerror.New("ID" + gconv.String(v) + "已被认领")
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
err = c.updateCustomer(req.Ids, req.SalesId, req.SalesName)
|
|
|
if err != nil {
|
|
|
err = gerror.New("可配客户失败")
|
|
|
return err
|
|
|
|
|
|
}
|
|
|
- var maps = make(map[string]string)
|
|
|
- maps["remark"] = req.Remark
|
|
|
if req.Receive != "" {
|
|
|
- maps["opn_type"] = AllocaTion
|
|
|
+ req.Receive = Receive
|
|
|
} else {
|
|
|
- maps["opn_type"] = Receive
|
|
|
+ req.Receive = AllocaTion
|
|
|
}
|
|
|
- maps["sale_name"] = req.SalesName
|
|
|
- maps["opn_people"] = c.GetCxtUserName()
|
|
|
- //maps["created_by"] = c.GetCxtUserId()
|
|
|
- err = c.belongInsters(rep.List(), maps)
|
|
|
+
|
|
|
+ err = c.Createbelong(rep, req)
|
|
|
+ g.Log().Info("errr", req)
|
|
|
+
|
|
|
if err != nil {
|
|
|
err = gerror.New("分配客户失败")
|
|
|
return err
|
|
|
@@ -356,6 +363,7 @@ func (c *CustomerService) GetEntityById(ids []int64) (entityInfo []*model.CustLi
|
|
|
if err != nil {
|
|
|
g.Log().Error(err)
|
|
|
return nil, gerror.New("获取用户数据失败")
|
|
|
+
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
@@ -369,7 +377,8 @@ func (c *CustomerService) CustAbstract(id int64) (followInfo *model.Follow, err
|
|
|
g.Log().Info("count", count)
|
|
|
if err != nil {
|
|
|
g.Log().Error(err)
|
|
|
- return nil, gerror.New("获取用户数据失败")
|
|
|
+ gerror.New("获取用户数据失败")
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
followInfo = new(model.Follow)
|
|
|
@@ -380,7 +389,8 @@ func (c *CustomerService) CustAbstract(id int64) (followInfo *model.Follow, err
|
|
|
|
|
|
if err != nil {
|
|
|
g.Log().Error(err)
|
|
|
- return nil, gerror.New("获取用户数据失败")
|
|
|
+ gerror.New("获取用户数据失败")
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
findOne := find.Map()
|
|
|
@@ -408,25 +418,22 @@ func (c *CustomerService) CustAbstract(id int64) (followInfo *model.Follow, err
|
|
|
}
|
|
|
|
|
|
//转移客户
|
|
|
-func (c *CustomerService) UpdateBytransfer(req *model.CustSalesReq) (entityInfo []*model.CustCustomer, err error) {
|
|
|
- custModel := c.Dao.M
|
|
|
+func (c *CustomerService) UpdateBytransfer(req *model.DistriCustomer) (err error) {
|
|
|
+ custModel := c.Dao
|
|
|
rep, err := custModel.Fields("sales_id,sales_name,id").Where(cust.CustCustomer.Columns.Id+" in (?)", req.Ids).All()
|
|
|
- if err != nil || rep.IsEmpty() {
|
|
|
+ if err != nil || len(rep) == 0 {
|
|
|
err = gerror.New("该数据不存在")
|
|
|
return
|
|
|
}
|
|
|
- err = c.updateCustomer(req.Ids, req.SalesIds, req.SalesName)
|
|
|
+ err = c.updateCustomer(req.Ids, req.SalesId, req.SalesName)
|
|
|
if err != nil {
|
|
|
err = gerror.New("转移客户失败")
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- var maps = make(map[string]string)
|
|
|
- maps["remark"] = req.Remark
|
|
|
- maps["opn_type"] = OperaTion
|
|
|
- maps["sale_name"] = req.SalesName
|
|
|
+ err = c.Createbelong(rep, req)
|
|
|
|
|
|
- err = c.belongInsters(rep.List(), maps)
|
|
|
+ g.Log().Info("err", err)
|
|
|
if err != nil {
|
|
|
err = gerror.New("转移客户失败")
|
|
|
return
|
|
|
@@ -528,17 +535,20 @@ func (c *CustomerService) DynamicsList(req *model.CustomerDynameicsReq) (total i
|
|
|
//合并客户
|
|
|
func (c *CustomerService) Mergecustomer(req *model.MergecustomerRep) (err error) {
|
|
|
Model := c.Dao.M
|
|
|
- ContactModel := c.ContactDao.M
|
|
|
- BelongDao := c.BelongDao.M
|
|
|
+ //ContactModel := c.ContactDao.M
|
|
|
+ BelongDao := c.BelongDao
|
|
|
//当前目标客户是否存在
|
|
|
FindOne, err := Model.Where(c.Dao.Columns.DeletedTime+" is null").Where(c.Dao.Columns.Id, req.Id).FindOne()
|
|
|
if err != nil || FindOne.IsEmpty() {
|
|
|
err = gerror.New("该数据不存在")
|
|
|
return
|
|
|
}
|
|
|
- //所选客户联系人信息
|
|
|
- List, err := ContactModel.Where(c.ContactDao.Columns.CustId+" in (?)", req.ChooseId).All()
|
|
|
- g.Log().Info("list", List.List())
|
|
|
+ ContactModel := c.ContactDao
|
|
|
+ _, err = ContactModel.Where(c.ContactDao.Columns.CustId+" in (?)", req.ChooseId).WhereOr(c.ContactDao.Columns.CustId, req.Id).Delete()
|
|
|
+ if err != nil {
|
|
|
+ err = gerror.New("合并联系人失败")
|
|
|
+ return
|
|
|
+ }
|
|
|
CustomertData := new(model.Customer)
|
|
|
if err = gconv.Struct(req, CustomertData); err != nil {
|
|
|
return
|
|
|
@@ -546,112 +556,77 @@ func (c *CustomerService) Mergecustomer(req *model.MergecustomerRep) (err error)
|
|
|
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.Id,
|
|
|
- c.Dao.Columns.CustCode,
|
|
|
- c.Dao.Columns.SalesName,
|
|
|
- c.Dao.Columns.SalesId).WherePri(c.Dao.Columns.Id, req.Id).Update(CustomertData)
|
|
|
+ c.Dao.Columns.CustCode).WherePri(c.Dao.Columns.Id, req.Id).Update(CustomertData)
|
|
|
if err != nil {
|
|
|
err = gerror.New("合并失败")
|
|
|
return
|
|
|
}
|
|
|
- Model.Data(g.Map{"deleted_time": gtime.Now()}).Where(c.ContactDao.Columns.Id+" in (?)", req.ChooseId).Update()
|
|
|
- if err != nil || List.Len() > 0 {
|
|
|
- err = c.contactInster(req.Id, req.ChooseId, List.List())
|
|
|
- if err != nil {
|
|
|
- err = gerror.New("合并失败")
|
|
|
- return
|
|
|
- }
|
|
|
+ //删除被合并的客户信息
|
|
|
+ Model.Where(c.Dao.Columns.Id+" in (?)", req.ChooseId).Delete()
|
|
|
+ //删除 所选客户销售联系人
|
|
|
+ _, err = BelongDao.Where(c.BelongDao.Columns.CustId+" in (?)", req.ChooseId).WhereOr(c.BelongDao.Columns.CustId, req.Id).Delete()
|
|
|
+ if err != nil {
|
|
|
+ err = gerror.New("合并失败")
|
|
|
+ return
|
|
|
}
|
|
|
- ////所选客户销售联系人信息
|
|
|
- BelongList, err := BelongDao.Where(c.BelongDao.Columns.CustId+" in (?)", req.ChooseId).All()
|
|
|
- if err != nil || BelongList.Len() > 0 {
|
|
|
- err = c.belongInster(req.Id, req.ChooseId, req.Customer.SalesName)
|
|
|
- if err != nil {
|
|
|
- err = gerror.New("合并失败")
|
|
|
- return
|
|
|
- }
|
|
|
+
|
|
|
+ //插入一条合并成功的归属记录
|
|
|
+ belongService := c.BelongServer //
|
|
|
+ req.AddCustomerBelong.CustId = req.Id
|
|
|
+ req.AddCustomerBelong.OpnType = Merge
|
|
|
+ req.AddCustomerBelong.OpnPeople = c.GetCxtUserName()
|
|
|
+ req.AddCustomerBelong.OpnDatetime = gtime.Now()
|
|
|
+ req.AddCustomerBelong.SaleName = req.SalesName
|
|
|
+ err = belongService.Create(req.AddCustomerBelong)
|
|
|
+ if err != nil {
|
|
|
+ err = gerror.New("合并失败")
|
|
|
+ return
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//联系人
|
|
|
-func (c *CustomerService) contactInster(id int, Ids []int64, list []map[string]interface{}) (err error) {
|
|
|
+//联系人（合并）
|
|
|
+func (c *CustomerService) Createcontact(id int, Ids []int64, req *model.CustCustomerContactSeq) (err error) {
|
|
|
ContactModel := c.ContactDao.M
|
|
|
- ContactModel.Data(g.Map{"deleted_time": gtime.Now()}).Where(c.ContactDao.Columns.CustId+" in (?)", Ids).Update()
|
|
|
- maps := []map[string]interface{}{}
|
|
|
- for _, v := range list {
|
|
|
- contact := map[string]interface{}{}
|
|
|
- contact["cust_id"] = id
|
|
|
- contact["cuct_name"] = v["cuct_name"]
|
|
|
- contact["cuct_gender"] = v["cuct_gender"]
|
|
|
- contact["postion"] = v["postion"]
|
|
|
- contact["telephone"] = v["telephone"]
|
|
|
- contact["wechat"] = v["wechat"]
|
|
|
- contact["email"] = v["email"]
|
|
|
- contact["policy"] = v["policy"]
|
|
|
- contact["remark"] = v["remark"]
|
|
|
- contact["created_by"] = v["created_by"]
|
|
|
- contact["created_name"] = v["created_name"]
|
|
|
- contact["created_time"] = v["created_time"]
|
|
|
- maps = append(maps, contact)
|
|
|
- }
|
|
|
- _, err = ContactModel.Insert(maps)
|
|
|
+ _, err = ContactModel.Where(c.ContactDao.Columns.CustId+" in (?)", Ids).WhereOr(c.ContactDao.Columns.CustId, id).Delete()
|
|
|
if err != nil {
|
|
|
- err = gerror.New("操作失败")
|
|
|
- g.Log().Info("contactInster", err)
|
|
|
+ err = gerror.New("合并联系人失败")
|
|
|
return
|
|
|
-
|
|
|
}
|
|
|
-
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-//销售
|
|
|
-func (c *CustomerService) belongInster(Id int, BelongIds []int64, SaleName string) (err error) {
|
|
|
- BelongDao := c.BelongDao.M
|
|
|
- BelongDao.Data(g.Map{"deleted_time": gtime.Now()}).Where(c.BelongDao.Columns.CustId+" in (?)", BelongIds).Update()
|
|
|
- BelongData := new(model.CustCustomerBelong)
|
|
|
- BelongData.CustId = Id
|
|
|
- service.SetCreatedInfo(BelongData, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
- BelongData.SaleName = SaleName
|
|
|
- BelongData.OpnType = AllocaTion
|
|
|
- BelongData.OrigSaleName = ""
|
|
|
- BelongData.OpnPeople = "admin"
|
|
|
- BelongData.OpnDatetime = gtime.Now()
|
|
|
- _, err = BelongDao.Insert(BelongData)
|
|
|
+ contactService := c.ContanctServer //new(CustomercontactService)
|
|
|
+ err = contactService.Create(req)
|
|
|
if err != nil {
|
|
|
- g.Log().Info("BeloongInster", err)
|
|
|
- err = gerror.New("操作失败")
|
|
|
+ err = gerror.New("合并联系人失败")
|
|
|
return
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//批量插入客户归属记录表
|
|
|
-func (c *CustomerService) belongInsters(rep []map[string]interface{}, parameter map[string]string) (err error) {
|
|
|
- belongModel := c.BelongDao.M
|
|
|
- maps := []map[string]interface{}{}
|
|
|
+//批量插入客户归属记录表//parameter map[string]string
|
|
|
+func (c *CustomerService) Createbelong(rep []*model.CustCustomer, req *model.DistriCustomer) (err error) {
|
|
|
+ belongModel := c.BelongDao
|
|
|
+ var belongData []*model.CustCustomerBelong
|
|
|
date_time := gtime.Now()
|
|
|
+ userName := c.GetCxtUserName()
|
|
|
for _, v := range rep {
|
|
|
- orig_sale_name := v["sales_name"]
|
|
|
- belong := map[string]interface{}{}
|
|
|
- belong["cust_id"] = v["id"].(int)
|
|
|
- belong["sale_name"] = parameter["sale_name"]
|
|
|
- belong["orig_sale_name"] = orig_sale_name
|
|
|
- belong["opn_type"] = parameter["opn_type"]
|
|
|
- belong["opn_people"] = parameter["opn_people"]
|
|
|
- belong["opn_datetime"] = date_time
|
|
|
- belong["created_by"] = c.GetCxtUserId()
|
|
|
- belong["remark"] = parameter["remark"]
|
|
|
- belong["created_name"] = c.GetCxtUserName()
|
|
|
- belong["created_time"] = date_time
|
|
|
- belong["opn_datetime"] = date_time
|
|
|
- maps = append(maps, belong)
|
|
|
- }
|
|
|
- _, err = belongModel.Insert(maps)
|
|
|
+ orig_sale_name := v.SalesName
|
|
|
+ belong := new(model.CustCustomerBelong) //map[string]interface{}{}
|
|
|
+ belong.CustId = v.Id
|
|
|
+ belong.SaleName = req.SalesName
|
|
|
+ belong.OrigSaleName = orig_sale_name
|
|
|
+ belong.OpnType = req.Receive
|
|
|
+ belong.OpnPeople = userName
|
|
|
+ belong.CreatedName = userName
|
|
|
+ belong.OpnDatetime = date_time
|
|
|
+ belong.Remark = req.Remark
|
|
|
+ belong.CreatedBy = c.GetCxtUserId()
|
|
|
+ belongData = append(belongData, belong)
|
|
|
+ }
|
|
|
+ _, err = belongModel.Insert(belongData)
|
|
|
+ g.Log().Info("belong", belongData)
|
|
|
if err != nil {
|
|
|
err = gerror.New("插入失败")
|
|
|
return err
|
|
|
}
|
|
|
-
|
|
|
return
|
|
|
}
|
wangxingcheng