动态记录新增

clueSync/autoTask.go

@@ -103,7 +103,7 @@ func autoTask() {
 					"taskstatus": 0,
 					"tasksource": "超时未跟进自动加车",
 				}) {
-					AddChangeRecord(nil, clueId, position_id, "", "加入任务车", "超时未跟进自动加车", "", nowTime, -1)
+					AddChangeRecord(nil, clueId, position_id, "", "加入任务车", "超时未跟进自动加车", "", nowTime, "", -1)
 				}
 			}
 			return true
@@ -130,7 +130,7 @@ func autoTasks() {
 						"taskstatus": 0,
 						"tasksource": "即将到达下次跟进时间",
 					}) {
-						AddChangeRecord(nil, clueId, position_id, "", "加入任务车", "", "即将到达下次跟进时间", nowTime2, -1)
+						AddChangeRecord(nil, clueId, position_id, "", "加入任务车", "即将到达下次跟进时间", "", nowTime2, "", -1)
 					}
 				}
 			}
@@ -183,8 +183,8 @@ GROUP BY
 			if TiDb.ExecTx("退出线索", func(tx *sql.Tx) bool {
 				positionMap[positionId] = true
 				recordId := TiDb.UpdateOrDeleteBySqlByTx(tx, `UPDATE dwd_f_crm_clue_info SET is_assign=0,position_id=null,seatNumber=null,updatetime = ?,comeinsource_open=null,level_open=null,next_trail_time=null,is_task=null,tasktime=null,taskstatus=null,comeinsource_private=null,tasksource=null WHERE id = ?`, nowTime, clueId) //,start_trail_time=null,content=null
-				recordId2 := AddChangeRecord(tx, clueId, positionId, "", "退回公海", "所有人员私海已达上限", "", nowTime, -1)
-				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", "/", GetPositionName(seatNumber), nowTime, -1)
+				recordId2 := AddChangeRecord(tx, clueId, positionId, "", "退回公海", "所有人员私海已达上限", "", nowTime, "", -1)
+				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", "/", GetPositionName(seatNumber), nowTime, "", -1)
 				return recordId > -1 && recordId1 > -1 && recordId2 > -1
 			}) {
 				//发送消息，找wjh
@@ -221,10 +221,10 @@ func autoExitSea() {
 				// } else if is_assign == 0 {
 				// 	ok1 = TiDb.DeleteByTx(tx, "dwd_f_crm_open_sea", map[string]interface{}{"clue_id": clueId})
 				// }
-				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", GetPositionName(seatNumber), "/", nowTime, -1)
-				recordId2 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "流失", "空号停机", nowTime, -1)
-				recordId3 := AddChangeRecord(tx, clueId, positionId, "", "退出任务车", "空号停机自动从线索池删除", "", nowTime, -1)
-				recordId4 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "退出公海", "空号停机自动从线索池删除", "", nowTime, -1)
+				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", GetPositionName(seatNumber), "/", nowTime, "", -1)
+				recordId2 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "流失", "空号停机", nowTime, "", -1)
+				recordId3 := AddChangeRecord(tx, clueId, positionId, "", "退出任务车", "空号停机自动从线索池删除", "", nowTime, "", -1)
+				recordId4 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "退出公海", "空号停机自动从线索池删除", "", nowTime, "", -1)
 				return recordId > -1 && recordId1 > -1 && recordId2 > -1 && recordId3 > -1 && recordId4 > -1
 			}) {
 				log.Println("自动退出线索成功")
@@ -244,10 +244,10 @@ func autoExitSea() {
 			// is_assign := common.IntAll(v["is_assign"])
 			if TiDb.ExecTx("自动退海", func(tx *sql.Tx) bool {
 				recordId := TiDb.UpdateOrDeleteBySqlByTx(tx, `UPDATE dwd_f_crm_clue_info SET is_assign=0,position_id=null,seatNumber=null,updatetime = ?,comeintime_open = ?,comeinsource_open=?,level_open=4,next_trail_time=null,is_task=null,tasktime=null,taskstatus=null,comeinsource_private=null,tasksource=null WHERE id = ?`, nowTime, nowTime, common.If(trailstatus == "00", 8, 11), clueId) //,content=null,start_trail_time=null
-				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", "/", GetPositionName(seatNumber), nowTime, -1)
-				recordId2 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "流失", gconv.String(common.If(trailstatus == "00", "无意向客户", "拒绝客户")), nowTime, -1)
-				recordId3 := AddChangeRecord(tx, clueId, positionId, "", "退出任务车", gconv.String(common.If(trailstatus == "00", "无意向客户自动退回公海", "拒绝客户自动退回公海")), "", nowTime, -1)
-				recordId4 := AddChangeRecord(tx, clueId, positionId, "", "退回公海", gconv.String(common.If(trailstatus == "00", "无意向客户自动退回公海", "拒绝客户自动退回公海")), "", nowTime, -1)
+				recordId1 := AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", "/", GetPositionName(seatNumber), nowTime, "", -1)
+				recordId2 := AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "流失", gconv.String(common.If(trailstatus == "00", "无意向客户", "拒绝客户")), nowTime, "", -1)
+				recordId3 := AddChangeRecord(tx, clueId, positionId, "", "退出任务车", gconv.String(common.If(trailstatus == "00", "无意向客户自动退回公海", "拒绝客户自动退回公海")), "", nowTime, "", -1)
+				recordId4 := AddChangeRecord(tx, clueId, positionId, "", "退回公海", gconv.String(common.If(trailstatus == "00", "无意向客户自动退回公海", "拒绝客户自动退回公海")), "", nowTime, "", -1)
 				return recordId > -1 && recordId1 > -1 && recordId2 > -1 && recordId3 > -1 && recordId4 > -1
 			}) {
 				log.Println("自动退出私海成功")
@@ -311,18 +311,18 @@ func Thaw() {
 					"position_id": 0,
 					"seatNumber":  nil,
 				}) {
-					AddChangeRecord(nil, clueId, positionId, "position_id", "所属人变更", "/", nameMap[positionId], nowTime, -1)
+					AddChangeRecord(nil, clueId, positionId, "position_id", "所属人变更", "/", nameMap[positionId], nowTime, "", -1)
 				}
-				AddChangeRecord(nil, clueId, positionId, "position_id", "线索解冻", "自动退回公海", "", nowTime, -1)
+				AddChangeRecord(nil, clueId, positionId, "position_id", "线索解冻", "自动退回公海", "", nowTime, "", -1)
 			} else {
 				if !FindUpperLimit(gconv.String(positionId), "", false) {
 					nowTime := time.Now().Format(date.Date_Full_Layout)
 					if TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{
 						"is_assign": 1,
 					}) {
-						AddChangeRecord(nil, clueId, positionId, "position_id", "所属人变更", nameMap[positionId], "/", nowTime, -1)
+						AddChangeRecord(nil, clueId, positionId, "position_id", "所属人变更", nameMap[positionId], "/", nowTime, "", -1)
 					}
-					AddChangeRecord(nil, clueId, positionId, "position_id", "线索解冻", "销售人员私海线索已释放", "", nowTime, -1)
+					AddChangeRecord(nil, clueId, positionId, "position_id", "线索解冻", "销售人员私海线索已释放", "", nowTime, "", -1)
 				}
 			}
 		}

clueSync/job.go

@@ -587,7 +587,7 @@ func WorkUpdateClue(data map[string]interface{}, saleData []map[string]interface
 	oldTaskTime = gconv.String(data["tasktime"])
 	is_task = common.IntAll(data["is_task"])
 	taskstatus = common.IntAll(data["taskstatus"])
-	BCPCID := common.GetRandom(32)
+	//BCPCID := common.GetRandom(32)
 	old_name := gconv.String(data["name"])
 	old_position := gconv.String(data["position"])
 	old_department := gconv.String(data["department"])
@@ -975,7 +975,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 	oldTaskTime = gconv.String(data["tasktime"])
 	is_task = common.IntAll(data["is_task"])
 	taskstatus = common.IntAll(data["taskstatus"])
-	BCPCID := common.GetRandom(32)
+	//BCPCID := common.GetRandom(32)
 	old_name := gconv.String(data["name"])
 	old_position := gconv.String(data["position"])
 	old_department := gconv.String(data["department"])
@@ -1291,7 +1291,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 						}
 					}
 				} else if !is_ok {
-					updateId5 = AddChangeRecord(tx, clueId, gconv.String(common.If(trailstatus == "00" || is_assign == 0 || is_assign == -1, positionId, common.Int64All(data["position_id"]))), "", "加入任务车",
+					updateId5 = AddChangeRecord(tx, clueId, gconv.Int64(common.If(trailstatus == "00" || is_assign == 0 || is_assign == -1, positionId, common.Int64All(data["position_id"]))), "", "加入任务车",
 						gconv.String(gconv.String(common.If(gconv.Int64(data["position_id"]) == 0, "线索自动分配", "线索来源自动更新"))+"-"+topname+"-"+subname), "", nowTime, "", -1)
 				}
 			}

clueSync/jobutil.go

@@ -113,7 +113,7 @@ func WorkDataHandle(company, phone, demand, name, product string, acceptanceData
 				log.Println("查询不到客成数据", clueId, uId)
 				return false
 			}
-			AddChangeRecord(nil, clueId, gconv.Int64((*customerMap)["position_id"]), "", "加入任务车", "咨询客服转客成", "/", time.Now().Format(date.Date_Full_Layout), -1)
+			AddChangeRecord(nil, clueId, gconv.Int64((*customerMap)["position_id"]), "", "加入任务车", "咨询客服转客成", "/", time.Now().Format(date.Date_Full_Layout), "", -1)
 		} else {
 			//普通销售
 			if positionId == 0 && lockPositionId == 0 {
@@ -860,7 +860,7 @@ func userbase() {
 					})
 				}
 				if clueId > 0 {
-					AddChangeRecord(nil, clueId, -1, "", "创建线索", "系统自动创建", "/", nowTime, -1)
+					AddChangeRecord(nil, clueId, -1, "", "创建线索", "系统自动创建", "/", nowTime, "", -1)
 				}
 			}
 		}
@@ -1963,7 +1963,7 @@ func AddLockeStatusChange(tx *sql.Tx, clueId, positionId, oldLockStatus, lock_st
 	if clueName != "" {
 		_, clueList := FindRelatedData(clueName)
 		for _, v := range clueList {
-			AddChangeRecord(nil, clueId, positionId, "lock_status", "基本信息变更", gconv.String(CodeLock[lock_status]), gconv.String(common.If(lock_status == 0, CodeLock[lock_status], CodeLock[lock_status])), nowTime, -1)
+			AddChangeRecord(nil, v, positionId, "lock_status", "基本信息变更", gconv.String(CodeLock[lock_status]), gconv.String(common.If(lock_status == 0, CodeLock[lock_status], CodeLock[lock_status])), nowTime, "", -1)
 		}
 	}
 	return 1
@@ -1978,7 +1978,7 @@ func AddLockePersonChange(tx *sql.Tx, clueId, positionId int64, oldpersonName, p
 			log.Println(clueName, positionId, lockPositionId, "锁定人变更失败")
 		}
 		for _, v := range clueList {
-			AddChangeRecord(nil, v, positionId, "lock_position_id", "锁定人变更", personName, oldpersonName, nowTime, positionId)
+			AddChangeRecord(nil, v, positionId, "lock_position_id", "锁定人变更", personName, oldpersonName, nowTime, "", positionId)
 		}
 	}
 	return 1

clueSync/kc.go

@@ -115,7 +115,7 @@ func kcJob(data map[string]interface{}) int {
 			"label":                common.If(position_id > 0, 1, nil),
 		})
 		if clueId > 0 {
-			AddChangeRecord(nil, clueId, gconv.Int64(common.If(position_id > 0, position_id, -1)), "", "创建线索", "系统自动创建", "", nowTime, -1)
+			AddChangeRecord(nil, clueId, gconv.Int64(common.If(position_id > 0, position_id, -1)), "", "创建线索", "系统自动创建", "", nowTime, "", -1)
 			clueData = TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
 			if clueData == nil || len(*clueData) == 0 {
 				return 0
@@ -226,10 +226,10 @@ func kcJob(data map[string]interface{}) int {
 				updateMap["is_task"] = 1
 			}
 			TiDb.Update("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, updateMap)
-			AddChangeRecord(nil, clueId, customerPositionId, "", "成交客户移交", "移交至客户成功组", "", nowTime, -1)
+			AddChangeRecord(nil, clueId, customerPositionId, "", "成交客户移交", "移交至客户成功组", "", nowTime, "", -1)
 			if customerPositionId > 0 && (is_transfer == 1 || customerPositionId != gconv.Int64((*csmdata)["position_id"])) {
-				AddChangeRecord(nil, clueId, customerPositionId, "position_id", "客户成功经理", customerName, gconv.String(common.If(oldName != customerName, oldName, common.If(oldName == "", "/", oldName))), nowTime, -1)
-				AddChangeRecord(nil, clueId, customerPositionId, "", "加入任务车", "未建联", "", nowTime, -1)
+				AddChangeRecord(nil, clueId, customerPositionId, "position_id", "客户成功经理", customerName, gconv.String(common.If(oldName != customerName, oldName, common.If(oldName == "", "/", oldName))), nowTime, "", -1)
+				AddChangeRecord(nil, clueId, customerPositionId, "", "加入任务车", "未建联", "", nowTime, "", -1)
 			}
 			if is_transfer == 1 || customerPositionId != gconv.Int64((*csmdata)["position_id"]) {
 				if customerName == db.KeCheng.Admin {
@@ -252,11 +252,11 @@ func kcJob(data map[string]interface{}) int {
 			cId = TiDb.InsertByTx(tx, "dwd_f_csm_customer_info", saveMap)
 			ok = TiDb.UpdateByTx(tx, "dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{"is_transfer": 1, "updatetime": nowTime, "name": userName})
 			if customerPositionId > 0 {
-				updateId1 = AddChangeRecord(tx, clueId, customerPositionId, "", "加入任务车", "未建联", "", nowTime, -1)
-				updateId3 = AddChangeRecord(tx, clueId, customerPositionId, "position_id", "客户成功经理", "/", customerName, nowTime, -1)
+				updateId1 = AddChangeRecord(tx, clueId, customerPositionId, "", "加入任务车", "未建联", "", nowTime, "", -1)
+				updateId3 = AddChangeRecord(tx, clueId, customerPositionId, "position_id", "客户成功经理", "/", customerName, nowTime, "", -1)
 			}
 			KcSend(orderCode, customerName)
-			updateId2 := AddChangeRecord(tx, clueId, customerPositionId, "", "成交客户移交", "移交至客户成功组", "", nowTime, -1)
+			updateId2 := AddChangeRecord(tx, clueId, customerPositionId, "", "成交客户移交", "移交至客户成功组", "", nowTime, "", -1)
 			return cId > -1 && ok && updateId1 > -1 && updateId2 > -1 && updateId3 > -1
 		}) {
 			//TiDb.UpdateOrDeleteBySql(`update dwd_f_csm_customer_autodraw_record set count = count + 1 where name = ?`, name)
@@ -412,11 +412,11 @@ func kcAuto() {
 			taskstatus := common.IntAll(v["taskstatus"])
 			if relationship_building_way != 1 && inventory_way == 1 {
 				tasksources = "2"
-				AddChangeRecord(nil, clueId, positionId, "", "加入任务车", "未盘点", "", "", -1)
+				AddChangeRecord(nil, clueId, positionId, "", "加入任务车", "未盘点", "", "", "", -1)
 
 			} else if inventory_way != 1 && training_way == 1 {
 				tasksources = "3"
-				AddChangeRecord(nil, clueId, positionId, "position_id", "加入任务车", "未培训", "", nowTime, -1)
+				AddChangeRecord(nil, clueId, positionId, "position_id", "加入任务车", "未培训", "", nowTime, "", -1)
 			}
 			if taskstatus == 1 {
 				tasksource = tasksources
@@ -573,10 +573,10 @@ func ordersClue() {
 						})
 					}
 					if clueId > 0 {
-						AddChangeRecord(tx, clueId, gconv.Int64(common.If(positionId > 0, positionId, -1)), "", "创建线索", "系统自动创建", "", nowTime, -1)
+						AddChangeRecord(nil, clueId, gconv.Int64(common.If(positionId > 0, positionId, -1)), "", "创建线索", "系统自动创建", "", nowTime, "", -1)
 						if is_assign == -3 {
 							//新增冻结记录
-							AddChangeRecord(tx, clueId, positionId, "", "线索冻结", "销售人员私海已达上限", "", nowTime, -1)
+							AddChangeRecord(nil, clueId, positionId, "", "线索冻结", "销售人员私海已达上限", "", nowTime, "", -1)
 
 							//移交失败发送消息
 							if IsFreeze(source, pay_money, gconv.String(positionId), trailstatus) {
@@ -666,10 +666,10 @@ func refundAuto() {
 			if isAllRefund {
 				//全退款了
 				TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,is_assign=0,trailstatus="01",position_id=null,seatNumber=null,updatetime=?,comeintime_open=?,comeinsource_open=1,level_open=3,next_trail_time=null,is_task=null,tasktime=null,taskstatus=null,comeinsource_private=null,tasksource=null,is_transfer=0 WHERE id = ?`, nowTime, nowTime, clueId)
-				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "", "退回公海", "成交客户申请退款", "", nowTime, -1)
-				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "trailstatus", "基本信息变更", "商机线索", "成交客户", nowTime, -1)
-				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "position_id", "客户成功经理", "/", name, nowTime, -1)
-				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "", "移交销售", "成交客户申请退款", "", nowTime, -1)
+				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "", "退回公海", "成交客户申请退款", "", nowTime, "", -1)
+				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "trailstatus", "基本信息变更", "商机线索", "成交客户", nowTime, "", -1)
+				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "position_id", "客户成功经理", "/", name, nowTime, "", -1)
+				AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "", "移交销售", "成交客户申请退款", "", nowTime, "", -1)
 				mailData[name] = append(mailData[name], map[string]interface{}{
 					"company_name": company_name,
 					"phone":        phone,
@@ -803,14 +803,14 @@ func refundAuto() {
 								"cluename":     cluename,
 							})
 						}
-						AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "trailstatus", "基本信息变更", "商机线索", "", nowTime, -1)
-						AddChangeRecord(nil, clueId, saleId, "trailstatus", "加入任务车", "线索自动分配-其他-成交客户续约失败", "", nowTime, -1)
-						AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "position_id", "客户成功经理", "/", name, nowTime, -1)
-						AddChangeRecord(nil, clueId, saleId, "", "移交销售", "成交客户续费失败，到期自动移交", "", nowTime, -1)
+						AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "trailstatus", "基本信息变更", "商机线索", "", nowTime, "", -1)
+						AddChangeRecord(nil, clueId, saleId, "trailstatus", "加入任务车", "线索自动分配-其他-成交客户续约失败", "", nowTime, "", -1)
+						AddChangeRecord(nil, clueId, gconv.Int64(common.If(kcposition_id > 0, kcposition_id, -1)), "position_id", "客户成功经理", "/", name, nowTime, "", -1)
+						AddChangeRecord(nil, clueId, saleId, "", "移交销售", "成交客户续费失败，到期自动移交", "", nowTime, "", -1)
 						TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
 						if isFull {
 							//新增冻结记录
-							AddChangeRecord(nil, clueId, 线索冻结, "trailstatus", "线索冻结", "销售人员私海已达上限", "", nowTime, -1)
+							AddChangeRecord(nil, clueId, saleId, "trailstatus", "线索冻结", "销售人员私海已达上限", "", nowTime, "", -1)
 							//发送邮件
 							mailContent := ""
 							if cluename != "" {
@@ -1310,11 +1310,11 @@ func kcClue(userId, uId, seatNumber, cluename, top_cluetype, sub_cluetype,
 			"labelChangeTime":      time.Now().Format("2006-01-02"),
 		})
 
-		uodateId1 = AddChangeRecord(tx, clueId, positionId, "", "创建线索", "系统自动创建", "", nowTime, -1)
-		uodateId2 = AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", saleName, "/", nowTime, -1)
-		uodateId3 = AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "新增", "商机线索", nowTime, -1)
-		uodateId4 = AddChangeRecord(tx, clueId, positionId, "top_cluetype", "基本信息变更", topname, "/", nowTime, -1)
-		uodateId5 = AddChangeRecord(tx, clueId, positionId, "sub_cluetype", "基本信息变更", subname, "/", nowTime, -1)
+		uodateId1 = AddChangeRecord(tx, clueId, positionId, "", "创建线索", "系统自动创建", "", nowTime, "", -1)
+		uodateId2 = AddChangeRecord(tx, clueId, positionId, "position_id", "所属人变更", saleName, "/", nowTime, "", -1)
+		uodateId3 = AddChangeRecord(tx, clueId, positionId, "trailstatus", "基本信息变更", "新增", "商机线索", nowTime, "", -1)
+		uodateId4 = AddChangeRecord(tx, clueId, positionId, "top_cluetype", "基本信息变更", topname, "/", nowTime, "", -1)
+		uodateId5 = AddChangeRecord(tx, clueId, positionId, "sub_cluetype", "基本信息变更", subname, "/", nowTime, "", -1)
 		return clueId > -1 && uodateId1 > -1 && uodateId2 > -1 && uodateId3 > -1 && uodateId4 > -1 && uodateId5 > -1
 	}) {
 		log.Println("线索分配成功")