|
|
@@ -36,10 +36,12 @@ func (this *SaleClueService) Add(ctx context.Context) int64 {
|
|
|
args := []interface{}{}
|
|
|
argsTask := []interface{}{}
|
|
|
argsTaskTeam := []interface{}{}
|
|
|
+ // userIds, positionIds := "", ""
|
|
|
//判断处理方式
|
|
|
//转办
|
|
|
if this.Types == 2 {
|
|
|
transferArr := []int64{}
|
|
|
+ baseUserIdArr := []int64{}
|
|
|
for _, v := range this.User {
|
|
|
i_entuserid := v
|
|
|
resp, err := cm.UserCenterRpc.IdentityByEntUserId(ctx, &pb.IdentityReq{
|
|
|
@@ -47,20 +49,25 @@ func (this *SaleClueService) Add(ctx context.Context) int64 {
|
|
|
})
|
|
|
if err != nil {
|
|
|
log.Println("获取用户职位id信息出错", i_entuserid, "的信息出错", err)
|
|
|
- return 0
|
|
|
+ return -1
|
|
|
} else if resp == nil {
|
|
|
log.Println("entuser用户", i_entuserid, "没有找到职位信息")
|
|
|
- return 0
|
|
|
+ return -1
|
|
|
}
|
|
|
transferArr = append(transferArr, resp.PositionId)
|
|
|
+ baseUserIdArr = append(baseUserIdArr, resp.UserId)
|
|
|
+ //查询mgo
|
|
|
}
|
|
|
+ // &User{
|
|
|
+ // baseUserIds
|
|
|
+ // }
|
|
|
//线索
|
|
|
args = append(args, this.PositionId, this.EntId, this.EntUserId, this.ClueName, this.CluesSource, this.Summary, this.EmployInfoId, 0, nowtime, this.CreateName)
|
|
|
//任务
|
|
|
argsTask = append(argsTask, this.EntId, this.ClueName+"的跟进任务", 1, this.PositionId, 1, nowtime, 1, qu.If(this.FollowUpTime == 0, nil, nextFollowTime))
|
|
|
|
|
|
- if !Save(ctx, args, argsTask, argsTaskTeam, this.PositionId, this.CreateName, transferArr) {
|
|
|
- return 0
|
|
|
+ if !Save(ctx, args, argsTask, argsTaskTeam, this.EmployInfoId, 0, this.PositionId, this.CreateName, transferArr) {
|
|
|
+ return -1
|
|
|
}
|
|
|
} else if this.Types == 1 {
|
|
|
//线索
|
|
|
@@ -70,11 +77,11 @@ func (this *SaleClueService) Add(ctx context.Context) int64 {
|
|
|
//任务团队
|
|
|
argsTaskTeam = append(argsTaskTeam, this.PositionId, this.EntUserId, this.CreateName, 1, nowtime)
|
|
|
//存库
|
|
|
- if !Save(ctx, args, argsTask, argsTaskTeam, this.PositionId, this.CreateName, []int64{}) {
|
|
|
- return 0
|
|
|
+ if !Save(ctx, args, argsTask, argsTaskTeam, this.EmployInfoId, 0, this.PositionId, this.CreateName, []int64{}) {
|
|
|
+ return -1
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+ // StationMailPush
|
|
|
return 1
|
|
|
}
|
|
|
|
|
|
@@ -96,9 +103,9 @@ func TaskAdd(tx *sql.Tx, args, taskTeamArgs []interface{}, transferArr []int64,
|
|
|
teamId, transferId := int64(0), int64(0)
|
|
|
if len(taskTeamArgs) > 0 {
|
|
|
//自办
|
|
|
- taskTeamFields := []string{"position_id", "ent_user_id", "name", "role", "create_time", "task_id"}
|
|
|
+ // taskTeamFields := []string{"position_id", "ent_user_id", "name", "role", "create_time", "task_id"}
|
|
|
taskTeamArgs = append(taskTeamArgs, id)
|
|
|
- _, teamId = cm.CrmMysql.InsertBatchByTx(tx, entity.TASK_TEAM, taskTeamFields, taskTeamArgs)
|
|
|
+ // _, teamId = cm.CrmMysql.InsertBatchByTx(tx, entity.TASK_TEAM, taskTeamFields, taskTeamArgs)
|
|
|
} else if len(transferArr) > 0 {
|
|
|
//转办
|
|
|
taskTransferFields := []string{"transfer_id", "responsible_id", "create_time", "task_id"}
|
|
|
@@ -116,7 +123,7 @@ func TaskAdd(tx *sql.Tx, args, taskTeamArgs []interface{}, transferArr []int64,
|
|
|
}
|
|
|
|
|
|
//Save 存库
|
|
|
-func Save(ctx context.Context, argsClue, argsTask, argsTaskTeam []interface{}, positionId int64, createName string, transferArr []int64) bool {
|
|
|
+func Save(ctx context.Context, argsClue, argsTask, argsTaskTeam []interface{}, employ_info_id, employ_custom_id, positionId int64, createName string, transferArr []int64) bool {
|
|
|
//存库
|
|
|
return cm.CrmMysql.ExecTx("创建线索", func(tx *sql.Tx) bool {
|
|
|
//插入线索
|
|
|
@@ -125,12 +132,14 @@ func Save(ctx context.Context, argsClue, argsTask, argsTaskTeam []interface{}, p
|
|
|
argsTask = append(argsTask, clueId)
|
|
|
//任务车存储
|
|
|
taskId := TaskAdd(tx, argsTask, argsTaskTeam, transferArr, positionId)
|
|
|
+ //是否创建销售线索
|
|
|
+ ok1 := EmployUpdate(tx, employ_info_id, employ_custom_id, positionId, "is_create_clue")
|
|
|
//操作台帐
|
|
|
- ok := SaveLedger(ctx, positionId, clueId, taskId, "创建销售线索", fmt.Sprintf("%s创建了销售线索", createName), createName)
|
|
|
- if clueId > 0 && taskId > 0 && ok {
|
|
|
+ ok2 := SaveLedger(ctx, positionId, clueId, taskId, "创建销售线索", fmt.Sprintf("%s创建了销售线索", createName), createName)
|
|
|
+ if clueId > 0 && taskId > 0 && ok1 && ok2 {
|
|
|
return true
|
|
|
}
|
|
|
- log.Println("save clue err: ", clueId, taskId, ok)
|
|
|
+ log.Println("save clue err: ", clueId, taskId, ok1, ok2)
|
|
|
return false
|
|
|
})
|
|
|
}
|
