|
|
@@ -5,8 +5,8 @@ import (
|
|
|
"context"
|
|
|
"math"
|
|
|
"strconv"
|
|
|
- "time"
|
|
|
|
|
|
+ "dashoo.cn/opms_libary/myerrors"
|
|
|
"github.com/360EntSecGroup-Skylar/excelize"
|
|
|
"github.com/gogf/gf/errors/gerror"
|
|
|
"github.com/gogf/gf/frame/g"
|
|
|
@@ -57,139 +57,146 @@ func NewCustomerService(ctx context.Context) (svc *CustomerService, err error) {
|
|
|
return svc, nil
|
|
|
}
|
|
|
|
|
|
-//导出数据
|
|
|
-func (c *CustomerService) Derive(req *model.CustCustomerExport) (content *model.CustExport, err error) {
|
|
|
- var con model.CustExport
|
|
|
- total, data, err := c.GetList(&req.CustCustomerSearchReq)
|
|
|
+//创建客户
|
|
|
+func (c *CustomerService) Create(req *model.CustomerAddSeq) (insertId int64, err error) {
|
|
|
+ cusTomer := new(model.CustCustomer)
|
|
|
+ count, err := c.Dao.Where(g.Map{"cust_name": req.CustName}).Count()
|
|
|
if err != nil {
|
|
|
+ err = myerrors.New("Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
- f := excelize.NewFile()
|
|
|
- index := f.NewSheet("Sheet1")
|
|
|
- for index, item := range req.Columns {
|
|
|
- sheetPosition := service.Div(index+1) + "1"
|
|
|
- f.SetCellValue("Sheet1", sheetPosition, item)
|
|
|
- }
|
|
|
- if total > 0 {
|
|
|
-
|
|
|
- for ck, item := range data {
|
|
|
- for index, v := range req.Columns {
|
|
|
- // "CustCode":客户编码
|
|
|
- if v == "客户编码" {
|
|
|
- f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustCode)
|
|
|
- }
|
|
|
- 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.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)
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- f.SetActiveSheet(index)
|
|
|
-
|
|
|
- var buffer *bytes.Buffer
|
|
|
- buffer, _ = f.WriteToBuffer()
|
|
|
- con.Content = buffer.Bytes()
|
|
|
-
|
|
|
- return &con, err
|
|
|
-}
|
|
|
-
|
|
|
-//创建客户
|
|
|
-func (c *CustomerService) Create(req *model.Customer) (insertId int64, err error) {
|
|
|
- cusTomer := new(model.CustCustomer)
|
|
|
- g.Log().Info(err)
|
|
|
- Model := c.Dao.M
|
|
|
- record, err := Model.Where(g.Map{"cust_name": req.CustName}).One()
|
|
|
- g.Log().Info("recordE", record.IsEmpty())
|
|
|
- if err != nil || !record.IsEmpty() {
|
|
|
- err = gerror.New("该客户信息已存在,不可重复添加")
|
|
|
+ if count > 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "该客户信息已存在,不可重复添加")
|
|
|
return
|
|
|
}
|
|
|
- g.Log().Info("recordreq----", req.CustSource)
|
|
|
+
|
|
|
if err = gconv.Struct(req, cusTomer); err != nil {
|
|
|
return
|
|
|
}
|
|
|
service.SetCreatedInfo(cusTomer, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
- cusTomer.CustCode = strconv.Itoa(int(gtime.Timestamp()))
|
|
|
+ cusTomer.CustCode = "CT" + strconv.Itoa(int(gtime.Timestamp()))
|
|
|
cusTomer.CustStatus = "10"
|
|
|
- Roles := c.GetCxtUserRoles()
|
|
|
- roles := false
|
|
|
- for _, v := range Roles {
|
|
|
+
|
|
|
+ roles := c.GetCxtUserRoles()
|
|
|
+ isSales := false
|
|
|
+ for _, v := range roles {
|
|
|
if v == "Sales" { // 销售角色
|
|
|
- roles = true
|
|
|
+ isSales = true
|
|
|
}
|
|
|
}
|
|
|
// 销售角色
|
|
|
- if roles {
|
|
|
+ if isSales {
|
|
|
cusTomer.IsPublic = noPublic
|
|
|
cusTomer.SalesId = c.GetCxtUserId()
|
|
|
cusTomer.SalesName = c.GetCxtUserName()
|
|
|
- lastId, err := Model.InsertAndGetId(cusTomer)
|
|
|
- if err != nil && lastId > 0 {
|
|
|
- belongData := new(model.CustCustomerBelong)
|
|
|
- service.SetCreatedInfo(belongData, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
- belongData.CustId = int(lastId)
|
|
|
- belongData.SaleName = c.GetCxtUserName()
|
|
|
- belongData.OpnType = AllocaTion
|
|
|
- belongData.OpnPeople = c.GetCxtUserName()
|
|
|
- belongData.OpnDatetime = gtime.Now()
|
|
|
- _, err := c.BelongDao.InsertAndGetId(belongData)
|
|
|
+ insertId, err = c.Dao.InsertAndGetId(cusTomer)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ c.CreateContact(int(insertId))
|
|
|
+
|
|
|
+ } else {
|
|
|
+ cusTomer.IsPublic = isPublic
|
|
|
+ insertId, err = c.Dao.InsertAndGetId(cusTomer)
|
|
|
+ if err != nil {
|
|
|
+ err = gerror.New("创建失败")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+func (c *CustomerService) CreateContact(cust_id int) (err error) {
|
|
|
+
|
|
|
+ belongData := new(model.CustCustomerBelong)
|
|
|
+ service.SetCreatedInfo(belongData, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
+ belongData.CustId = cust_id
|
|
|
+ belongData.SaleName = c.GetCxtUserName()
|
|
|
+ belongData.OpnType = AllocaTion
|
|
|
+ belongData.OpnPeople = c.GetCxtUserName()
|
|
|
+ belongData.OpnDatetime = gtime.Now()
|
|
|
+ _, err = c.BelongDao.InsertAndGetId(belongData)
|
|
|
+ if err != nil {
|
|
|
+
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+//删除客户
|
|
|
+func (c *CustomerService) DeleteById(id int) error {
|
|
|
+ Model := c.Dao
|
|
|
+ ContactModel := c.ContactDao //联系人
|
|
|
+ BelongModel := c.BelongDao
|
|
|
+ //regionDetail := new(model.CustCustomer)
|
|
|
+ customerCount, err := Model.Where(c.Dao.Columns.Id, id).Count()
|
|
|
+ if err != nil {
|
|
|
+ return myerrors.New(" 删除客户 DeleteById Sql执行异常", err)
|
|
|
+ }
|
|
|
+ if customerCount == 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "客户信息不存在")
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ //删除客户表
|
|
|
+ _, 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 {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("创建失败")
|
|
|
+ return myerrors.New(" 删除客户 BelongModel Sql执行异常", err)
|
|
|
|
|
|
}
|
|
|
+ } else {
|
|
|
+ return myerrors.New(" 删除客户 ContactModel Sql执行异常", err)
|
|
|
+
|
|
|
}
|
|
|
+ } else {
|
|
|
|
|
|
+ return myerrors.New(" 删除客户 ColumnsModel Sql执行异常", err)
|
|
|
}
|
|
|
- cusTomer.IsPublic = isPublic
|
|
|
+ return nil
|
|
|
+}
|
|
|
|
|
|
- res, err := Model.Insert(cusTomer)
|
|
|
+//修改客户
|
|
|
+func (c *CustomerService) UpdateById(req *model.UpdateCustomer) (err error) {
|
|
|
+ db := c.Dao.M
|
|
|
+ count, err := db.Where(c.Dao.Columns.Id, req.Id).Count()
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("创建失败")
|
|
|
+ err = myerrors.New(" UpdateById Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if count == 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "用户信息不存在")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ countNums, err := db.Where(c.Dao.Columns.CustName+" = ", req.CustName).Where(c.Dao.Columns.Id+" not in (?)", req.Id).Count()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New(" Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if countNums > 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "客户名称已存在")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ CustomertData := new(model.CustomerAddSeq)
|
|
|
+ if err = gconv.Struct(req, CustomertData); err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ service.SetUpdatedInfo(CustomertData, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
+ _, err = db.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)
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("修改用户信息失败", err)
|
|
|
return
|
|
|
}
|
|
|
- insertId, _ = res.LastInsertId()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
//客户列表列表
|
|
|
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")
|
|
|
if req.TargetType == "" {
|
|
|
if !req.IsPublic {
|
|
|
|
|
|
@@ -213,7 +220,7 @@ func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int,
|
|
|
}
|
|
|
//客户级别
|
|
|
if req.CustLevel != "" {
|
|
|
- g.Log().Info("level", req.CustLevel)
|
|
|
+
|
|
|
Model = Model.Where(c.Dao.Columns.CustLevel, req.CustLevel)
|
|
|
}
|
|
|
//
|
|
|
@@ -222,15 +229,16 @@ func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int,
|
|
|
}
|
|
|
total, err = Model.Count()
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("获取总行数失败")
|
|
|
+ err = myerrors.New("获取总行数失败", err)
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
- if req.PageNum == 0 {
|
|
|
- req.PageNum = 1
|
|
|
- }
|
|
|
|
|
|
err = Model.Page(req.GetPage()).Order("id desc").Scan(&customerList)
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("获取列表失败", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
for _, v := range customerList {
|
|
|
times := gconv.String(v.CreatedTime)
|
|
|
v.FollowUpDate = gstr.SubStr(v.FollowUpDate, 0, 16)
|
|
|
@@ -239,76 +247,20 @@ func (c *CustomerService) GetList(req *model.CustCustomerSearchReq) (total int,
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//删除客户
|
|
|
-func (c *CustomerService) DeleteById(id int) error {
|
|
|
+//移入公海
|
|
|
+func (c *CustomerService) MoveToPubic(ids []int64) (err error) {
|
|
|
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)
|
|
|
+ columnsCount, err := Model.Fields(c.Dao.Columns.CreatedTime).Where(c.Dao.Columns.Id+" in (?) ", ids).Count()
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("没有要删除的数据")
|
|
|
- return err
|
|
|
- }
|
|
|
|
|
|
- //删除客户表
|
|
|
- _, 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
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-//修改客户
|
|
|
-func (c *CustomerService) UpdateById(req *model.UpdateCustomer) (err error) {
|
|
|
- db := c.Dao.M
|
|
|
- record, err := db.FindOne(c.Dao.Columns.Id, req.Id)
|
|
|
- if err != nil || record.IsEmpty() {
|
|
|
- err = gerror.New("该数据不存在")
|
|
|
- return err
|
|
|
- }
|
|
|
- CustomertData := new(model.Customer)
|
|
|
- if err = gconv.Struct(req, CustomertData); err != nil {
|
|
|
+ err = myerrors.New("MoveToPubic Sql 执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
- service.SetUpdatedInfo(CustomertData, c.GetCxtUserId(), c.GetCxtUserName())
|
|
|
- _, err = db.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)
|
|
|
-
|
|
|
- if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("修改用户信息失败")
|
|
|
+ if columnsCount == 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "没有要移除的数据")
|
|
|
return
|
|
|
}
|
|
|
- return
|
|
|
-}
|
|
|
|
|
|
-//移入公海
|
|
|
-func (c *CustomerService) MoveToPubic(ids []int64) error {
|
|
|
- Model := c.Dao.M
|
|
|
- //Cust := new(model.CustCustomer)
|
|
|
- list, err := Model.Fields(c.Dao.Columns.CreatedTime).Where(c.Dao.Columns.Id+" in (?) ", ids).All()
|
|
|
- if err != nil || list.Len() <= 0 {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("没有要移除的数据")
|
|
|
- return err
|
|
|
- }
|
|
|
_, err = Model.Data(g.Map{
|
|
|
"is_public": isPublic,
|
|
|
"sales_id": 0,
|
|
|
@@ -322,117 +274,107 @@ func (c *CustomerService) MoveToPubic(ids []int64) error {
|
|
|
}).Where(c.ContactDao.Columns.Id+" in (?)", ids).Update()
|
|
|
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("移入公海失败")
|
|
|
- return err
|
|
|
+ err = myerrors.New("MoveToPubic updateSql 执行异常", err)
|
|
|
+ return
|
|
|
}
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
//分配客户
|
|
|
-func (c *CustomerService) DistriCustomer(req *model.DistriCustomer) error {
|
|
|
+func (c *CustomerService) DistriCustomer(req *model.DistriCustomer) (err error) {
|
|
|
custModel := c.Dao
|
|
|
- rep, err := custModel.Where(cust.CustCustomer.Columns.Id+" in (?) ", req.Ids).Where(cust.CustCustomer.Columns.IsPublic, isPublic).All()
|
|
|
-
|
|
|
- g.Log().Info("fdasfsa", len(rep))
|
|
|
- if err != nil || len(rep) == 0 {
|
|
|
- err = gerror.New("该数据不存在")
|
|
|
- return err
|
|
|
+ customerData, err := custModel.Where(cust.CustCustomer.Columns.Id+" in (?) ", req.Ids).All()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("DistriCustomer Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(customerData) == 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "无可分配客户")
|
|
|
+ return
|
|
|
}
|
|
|
- //cust := new(model.CustCustomer)
|
|
|
var custMap = make(map[int]string)
|
|
|
- for _, v := range rep {
|
|
|
+ for _, v := range customerData {
|
|
|
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 = myerrors.NewMsgError(nil, "ID"+gconv.String(v)+"已被认领")
|
|
|
+ return
|
|
|
}
|
|
|
}
|
|
|
- err = c.updateCustomer(req.Ids, req.SalesId, req.SalesName)
|
|
|
- if err != nil {
|
|
|
- err = gerror.New("可配客户失败")
|
|
|
- return err
|
|
|
-
|
|
|
- }
|
|
|
+ c.updateCustomer(req.Ids, req.SalesId, req.SalesName)
|
|
|
+ //if err != nil {
|
|
|
+ // err = myerrors.New("DistriCustomer update Sql执行异常", err)
|
|
|
+ // return
|
|
|
+ //
|
|
|
+ //}
|
|
|
if req.Receive != "" {
|
|
|
req.Receive = Receive
|
|
|
} else {
|
|
|
req.Receive = AllocaTion
|
|
|
}
|
|
|
|
|
|
- err = c.Createbelong(rep, req)
|
|
|
- g.Log().Info("errr", req)
|
|
|
-
|
|
|
- if err != nil {
|
|
|
- err = gerror.New("分配客户失败")
|
|
|
- return err
|
|
|
- }
|
|
|
- return nil
|
|
|
+ c.Createbelong(customerData, req)
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
//客户详情
|
|
|
func (c *CustomerService) GetEntityById(ids []int64) (entityInfo []*model.CustList, err error) {
|
|
|
- Model := c.Dao.M //
|
|
|
- //FollowModel := c.FollowDao.M
|
|
|
-
|
|
|
+ Model := c.Dao //
|
|
|
err = Model.Where(cust.CustCustomer.Columns.Id+" in (?)", ids).Scan(&entityInfo)
|
|
|
+ if err != nil {
|
|
|
+ return nil, myerrors.New("获取用户数据失败", err)
|
|
|
+
|
|
|
+ }
|
|
|
for _, v := range entityInfo {
|
|
|
v.FollowUpDate = gstr.SubStr(v.FollowUpDate, 0, 16)
|
|
|
v.CreatedTime = gstr.SubStr(v.CreatedTime, 0, 16)
|
|
|
}
|
|
|
- if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- return nil, gerror.New("获取用户数据失败")
|
|
|
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+//获取客户名称
|
|
|
+func (c *CustomerService) GetCustNameIsExist(name string) (exist bool, err error) {
|
|
|
+ Model := c.Dao //
|
|
|
+ count, err := Model.Where(cust.CustCustomer.Columns.CustName, name).Count()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("获取用户名称是否存在 GetCustName Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ exist = false
|
|
|
+ if count > 0 {
|
|
|
+ exist = true
|
|
|
}
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
//客户摘要
|
|
|
func (c *CustomerService) CustAbstract(id int64) (followInfo *model.Follow, err error) {
|
|
|
- custModel := c.Dao.M //
|
|
|
- Model := c.FollowDao.M
|
|
|
-
|
|
|
+ custModel := c.Dao //
|
|
|
+ Model := c.FollowDao
|
|
|
count, err := Model.Where(c.FollowDao.Columns.CustId, id).Count()
|
|
|
- g.Log().Info("count", count)
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- gerror.New("获取用户数据失败")
|
|
|
- return
|
|
|
+ return nil, myerrors.New(" CustAbstract Sql执行异常", err)
|
|
|
}
|
|
|
-
|
|
|
followInfo = new(model.Follow)
|
|
|
followInfo.FollowCount = count
|
|
|
- //
|
|
|
- find, err := custModel.Fields(c.Dao.Columns.FollowUpDate).Where(c.Dao.Columns.Id, id).FindOne()
|
|
|
- g.Log().Info("find", find)
|
|
|
-
|
|
|
+ followTime, err := custModel.Fields(c.Dao.Columns.FollowUpDate, c.Dao.Columns.CreatedTime).FindOne(id)
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- gerror.New("获取用户数据失败")
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- findOne := find.Map()
|
|
|
- if findOne["follow_up_date"] == "" {
|
|
|
- followInfo.NotFollowDay = 0
|
|
|
+ err = myerrors.New("CustAbstract Sql执行错误", err)
|
|
|
return
|
|
|
}
|
|
|
- upDate := gconv.String(findOne["follow_up_date"])
|
|
|
- follow_up, err1 := time.Parse(TIME_LAYOUT, upDate)
|
|
|
now := gtime.Now()
|
|
|
- follow_next, err2 := time.Parse(TIME_LAYOUT, gconv.String(now))
|
|
|
- if err1 != nil || err2 != nil {
|
|
|
- followInfo.NotFollowDay = 0
|
|
|
- return
|
|
|
+ var hours float64
|
|
|
+ if followTime.FollowUpDate == nil {
|
|
|
+ poor := now.Sub(gtime.New(followTime.CreatedTime))
|
|
|
+ hours = float64(poor.Hours() / 24)
|
|
|
+ } else {
|
|
|
+ poor := now.Sub(gtime.New(followTime.FollowUpDate))
|
|
|
+ hours = float64(poor.Hours() / 24)
|
|
|
}
|
|
|
- poor := follow_next.Sub(follow_up)
|
|
|
- g.Log().Info("xxxxfdsaf", follow_up)
|
|
|
- hours := float64(poor.Hours() / 24)
|
|
|
if hours < 0 {
|
|
|
followInfo.NotFollowDay = 0
|
|
|
} else {
|
|
|
@@ -444,22 +386,22 @@ func (c *CustomerService) CustAbstract(id int64) (followInfo *model.Follow, err
|
|
|
//转移客户
|
|
|
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 || len(rep) == 0 {
|
|
|
- err = gerror.New("该数据不存在")
|
|
|
+ data, err := custModel.Fields("sales_id,sales_name,id").Where(cust.CustCustomer.Columns.Id+" in (?)", req.Ids).All()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("Sql执行异常", err)
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(data) == 0 {
|
|
|
+ err = myerrors.New("该数据不存在", err)
|
|
|
return
|
|
|
}
|
|
|
err = c.updateCustomer(req.Ids, req.SalesId, req.SalesName)
|
|
|
if err != nil {
|
|
|
- err = gerror.New("转移客户失败")
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
- err = c.Createbelong(rep, req)
|
|
|
-
|
|
|
- g.Log().Info("err", err)
|
|
|
+ err = c.Createbelong(data, req)
|
|
|
if err != nil {
|
|
|
- err = gerror.New("转移客户失败")
|
|
|
return
|
|
|
}
|
|
|
return
|
|
|
@@ -479,8 +421,7 @@ func (c *CustomerService) updateCustomer(ids []int64, salesId int64, salesName s
|
|
|
}).Where(cust.CustCustomer.Columns.Id+" in (?)", ids).Update()
|
|
|
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("变更失败")
|
|
|
+ err = myerrors.New("updateCustomer 变更Sql执行失败", err)
|
|
|
return err
|
|
|
}
|
|
|
return nil
|
|
|
@@ -488,10 +429,9 @@ func (c *CustomerService) updateCustomer(ids []int64, salesId int64, salesName s
|
|
|
|
|
|
//客户操作日志
|
|
|
func (c *CustomerService) OperationLog(ctx context.Context, ids []int64, req *model.AddCustomerDynameicsReq) (err error) {
|
|
|
- g.Log("fdasfsa", gconv.String(ctx))
|
|
|
cusDynameics := new(model.CustCustomerDynamics)
|
|
|
if err = gconv.Struct(req, cusDynameics); err != nil {
|
|
|
- g.Log().Info("error", err)
|
|
|
+ err = myerrors.NewMsgError(nil, "操作日志验证结构体失败")
|
|
|
return
|
|
|
}
|
|
|
Model := c.DynamicsDao.M
|
|
|
@@ -513,10 +453,13 @@ func (c *CustomerService) OperationLog(ctx context.Context, ids []int64, req *mo
|
|
|
contact["opn_content"] = req.OpnContent
|
|
|
maps = append(maps, contact)
|
|
|
}
|
|
|
- _, err = Model.Insert(maps)
|
|
|
+ lastId, err := Model.InsertAndGetId(maps)
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("创建失败")
|
|
|
+ err = myerrors.New("OperationLog Sql执行失败", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if lastId == 0 {
|
|
|
+ err = myerrors.New("客户操作日志失败", err)
|
|
|
return
|
|
|
}
|
|
|
return
|
|
|
@@ -524,11 +467,10 @@ func (c *CustomerService) OperationLog(ctx context.Context, ids []int64, req *mo
|
|
|
|
|
|
//客户动态
|
|
|
func (c *CustomerService) DynamicsList(req *model.CustomerDynameicsReq) (total int, result []interface{}, err error) {
|
|
|
- Model := c.DynamicsDao.M
|
|
|
- total, err = Model.Fields().Count()
|
|
|
+ Model := c.DynamicsDao
|
|
|
+ total, err = Model.Where("cust_id = ", req.CustId).Count()
|
|
|
if err != nil {
|
|
|
- g.Log().Error(err)
|
|
|
- err = gerror.New("获取总行数失败")
|
|
|
+ err = myerrors.New("DynamicsList Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
//if req.PageNum == 0 {
|
|
|
@@ -549,10 +491,7 @@ func (c *CustomerService) DynamicsList(req *model.CustomerDynameicsReq) (total i
|
|
|
})
|
|
|
|
|
|
}
|
|
|
-
|
|
|
- g.Log().Info("DynamicsList----", dynamicsList)
|
|
|
result = append(result, dynamicsList)
|
|
|
- g.Log().Info("Dy---", result)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
@@ -562,18 +501,23 @@ func (c *CustomerService) Mergecustomer(req *model.MergecustomerRep) (err error)
|
|
|
//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("该数据不存在")
|
|
|
+ customerCount, err := Model.Where(c.Dao.Columns.Id, req.Id).Count()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("Mergecustomer 合并客户 Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if customerCount == 0 {
|
|
|
+ err = myerrors.NewMsgError(nil, "该客户不存在")
|
|
|
return
|
|
|
}
|
|
|
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("合并联系人失败")
|
|
|
+ err = myerrors.New("Mergecustomer 合并联系人 Sql执行异常", err)
|
|
|
return
|
|
|
+
|
|
|
}
|
|
|
- CustomertData := new(model.Customer)
|
|
|
+ CustomertData := new(model.CustomerAddSeq)
|
|
|
if err = gconv.Struct(req, CustomertData); err != nil {
|
|
|
return
|
|
|
}
|
|
|
@@ -582,15 +526,19 @@ func (c *CustomerService) Mergecustomer(req *model.MergecustomerRep) (err error)
|
|
|
c.Dao.Columns.CreatedName, c.Dao.Columns.Id,
|
|
|
c.Dao.Columns.CustCode).WherePri(c.Dao.Columns.Id, req.Id).Update(CustomertData)
|
|
|
if err != nil {
|
|
|
- err = gerror.New("合并失败")
|
|
|
+ err = myerrors.New("Mergecustomer 合并客户 update Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
//删除被合并的客户信息
|
|
|
- Model.Where(c.Dao.Columns.Id+" in (?)", req.ChooseId).Delete()
|
|
|
+ _, err = Model.Where(c.Dao.Columns.Id+" in (?)", req.ChooseId).Delete()
|
|
|
+ if err != nil {
|
|
|
+ err = myerrors.New("Mergecustomer 删除被合并的客户信息 Sql执行异常", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
//删除 所选客户销售联系人
|
|
|
_, err = BelongDao.Where(c.BelongDao.Columns.CustId+" in (?)", req.ChooseId).WhereOr(c.BelongDao.Columns.CustId, req.Id).Delete()
|
|
|
if err != nil {
|
|
|
- err = gerror.New("合并失败")
|
|
|
+ err = myerrors.New("Mergecustomer 删除所选客户销售联系人 Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
@@ -601,26 +549,22 @@ func (c *CustomerService) Mergecustomer(req *model.MergecustomerRep) (err error)
|
|
|
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
|
|
|
- }
|
|
|
+ belongService.Create(req.AddCustomerBelong)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
//联系人(合并)
|
|
|
func (c *CustomerService) Createcontact(id int, Ids []int64, req *model.CustCustomerContactSeq) (err error) {
|
|
|
- ContactModel := c.ContactDao.M
|
|
|
+ ContactModel := c.ContactDao
|
|
|
_, err = ContactModel.Where(c.ContactDao.Columns.CustId+" in (?)", Ids).WhereOr(c.ContactDao.Columns.CustId, id).Delete()
|
|
|
if err != nil {
|
|
|
- err = gerror.New("合并联系人失败")
|
|
|
+ err = myerrors.New("Createcontact 合并删除联系人 Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
contactService := c.ContanctServer //new(CustomercontactService)
|
|
|
err = contactService.Create(req)
|
|
|
if err != nil {
|
|
|
- err = gerror.New("合并联系人失败")
|
|
|
+ err = myerrors.New("Createcontact 合并删除并创建联系人 Sql执行异常", err)
|
|
|
return
|
|
|
}
|
|
|
return
|
|
|
@@ -646,11 +590,82 @@ func (c *CustomerService) Createbelong(rep []*model.CustCustomer, req *model.Dis
|
|
|
belong.CreatedBy = c.GetCxtUserId()
|
|
|
belongData = append(belongData, belong)
|
|
|
}
|
|
|
- _, err = belongModel.Insert(belongData)
|
|
|
+ lastId, err := belongModel.InsertAndGetId(belongData)
|
|
|
g.Log().Info("belong", belongData)
|
|
|
if err != nil {
|
|
|
- err = gerror.New("插入失败")
|
|
|
+ err = myerrors.New("Createbelong Sql执行异常", err)
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if lastId == 0 {
|
|
|
+ err = myerrors.New("Createbelong 插入", err)
|
|
|
return err
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+//导出数据
|
|
|
+func (c *CustomerService) Export(req *model.CustCustomerExport) (content *model.CustExport, err error) {
|
|
|
+ var con model.CustExport
|
|
|
+ total, data, err := c.GetList(&req.CustCustomerSearchReq)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ f := excelize.NewFile()
|
|
|
+ index := f.NewSheet("Sheet1")
|
|
|
+ for index, item := range req.Columns {
|
|
|
+ sheetPosition := service.Div(index+1) + "1"
|
|
|
+ f.SetCellValue("Sheet1", sheetPosition, item)
|
|
|
+ }
|
|
|
+ if total > 0 {
|
|
|
+
|
|
|
+ for ck, item := range data {
|
|
|
+ for index, v := range req.Columns {
|
|
|
+ // "CustCode":客户编码
|
|
|
+ if v == "客户编码" {
|
|
|
+ f.SetCellValue("Sheet1", service.Div(index+1)+strconv.Itoa(ck+2), item.CustCode)
|
|
|
+ }
|
|
|
+ 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.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)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ f.SetActiveSheet(index)
|
|
|
+
|
|
|
+ var buffer *bytes.Buffer
|
|
|
+ buffer, _ = f.WriteToBuffer()
|
|
|
+ con.Content = buffer.Bytes()
|
|
|
+
|
|
|
+ return &con, err
|
|
|
+}
|