Merge remote-tracking branch 'origin/feature/v1.5.2' into dev_v1.5.2_wh

# Conflicts:
#	clueSync/go.mod
#	clueSync/go.sum
#	clueSync/jobutil.go

clueSync/everything.go

@@ -335,40 +335,10 @@ func saveEverything(user_id, phone, item, sourceName, sourceCode string) bool {
 
 // 大客户线索-发邮件
 func bigCustomer() {
-	/*
-		2、线索来源:
-			(1)留资线索
-			   根据留资维表：tidb/Jianyu_subjectdb/d_saleleads_code
-			   根据维表中department字段包含“大客户”的所有source
-			   Source对应的中文名称用维表中的name，name要去掉"-pc","-app","-wx","-h5"
-			   查询sql如下：SELECT source,name FROM Jianyu_subjectdb.d_saleleads_code WHERE department LIKE '%大客户' AND is_delete = 1
-			(2)订单线索
-				①线上历史数据导出未支付订单
-				②线上历史数据导出已支付订单
-		3、线索处理逻辑
-			(1)线索每天保留最新的一条数据
-			(2)"具体来源", "数据需求" 这两个字段要将该用户当天作为线索进入大客户线索池的内容去重汇总，并用逗号分隔
-		4、导出明细
-			购买条数据：购买产品是“历史数据”，获取对应的购买条数
-			已支付订单信息：产品类型-有效期-金额
-			未支付订单信息：产品类型
-		5、发送邮件
-			(1)邮件主题：线索日期+大客户销售线索
-			(2)收件人：
-				"gaoxiang@jianyu360.com",
-				"sunzhenjie@jianyu360.com",
-				"fanzongdong@jianyu360.com",
-				"chenzhaobiao@jianyu360.com"
-			(3)发送内容
-				①当天有线索，邮件正文为：线索日期+数据详情请查看附件。附件名称同主题名称
-				②当天无线索，邮件正文为：线索日期+无数据。
-			(4)发送时间
-				每天一次，每天早上8：20
-	*/
 	log.Println("大客户线索定时任务开始")
 	dataArr := []map[string]interface{}{}
 	filterArr := []string{"-pc", "-app", "-wx", "-h5"}
-	sourceMap := map[string]string{}
+	sourceMap := map[string]string{} //根据留资维表：tidb/Jianyu_subjectdb/d_saleleads_code
 	saleSource := TiDb.SelectBySql(`SELECT source,name FROM d_saleleads_code WHERE department LIKE '%大客户%' AND is_delete = 1`)
 	if saleSource != nil && len(*saleSource) > 0 {
 		for _, v := range *saleSource {

clueSync/job.go

@@ -32,8 +32,8 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 		userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
 		if userInfo != nil && len(*userInfo) > 0 {
 			uId = common.ObjToString((*userInfo)["uid"])
-			source = common.ObjToString((*userInfo)["source"])
-			belong_to = common.ObjToString((*userInfo)["belong_to"])
+			source = common.ObjToString((*userInfo)["source"])       //用户来源
+			belong_to = common.ObjToString((*userInfo)["belong_to"]) //用户归属
 		}
 		cluename = common.ObjToString(data["company_name"])
 		phone = common.ObjToString(data["user_phone"])
@@ -98,7 +98,7 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 			log.Println("留资没有source", phone)
 			return true, true
 		}
-		remark = common.ObjToString(data["jyRemark"])
+		remark = common.ObjToString(data["jyRemark"]) //荟聚线索备注
 		keywordArr := data["keyword"]
 		if keywordArr != nil {
 			keyword = common.ObjArrToStringArr(data["keyword"].([]interface{}))
@@ -123,7 +123,7 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 				userId = common.ObjToString((*userInfo)["userid"])
 			}
 		} else {
-			if sourceCode == "report_retention" || sourceCode == "marketing_retention" {
+			if sourceCode == "report_retention" || sourceCode == "marketing_retention" { //荟聚线索来源，不是剑鱼用户，需要等待用户归集
 				log.Println("不是剑鱼用户留资,等待用户", phone)
 				return false, false
 			} else if remark != "" {
@@ -176,15 +176,15 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 		sourceId = common.Int64All(data["sourceId"])
 	}
 	if cluename == "" && item != "message" && item != "orders" && item != "readClue" {
-		cluename = phone
+		cluename = phone //没有线索名，手机号代替
 	}
-	isGroup, isCommerce := GetCompanyType(cluename) //判断是否集团公司、工商库
-	if source == "0104" || strings.HasPrefix(belong_to, "02") || source == "0102" || source == "0103" || phone == "" {
+	isGroup, isCommerce := GetCompanyType(cluename)                                                                    //判断是否集团公司、工商库
+	if source == "0104" || strings.HasPrefix(belong_to, "02") || source == "0102" || source == "0103" || phone == "" { //参照用户来源代码表
 		log.Println("线索分配失败，线索过滤！！", item, source, phone, userId)
 		saveHlyj(belong_to, item, phone, name, sourceName, cluename, position, nowTime, isGroup, isCommerce)
 		return true, false
 	}
-	if uId == "" {
+	if uId == "" { //没有进用户归集，等待进入，结束任务，放在下次继续执行
 		if isExists, _ := redis.Exists("bidx", "bidx_userId_"+userId); isExists {
 			redisInt := redis.GetInt("bidx", "bidx_userId_"+userId)
 			if redisInt > 4 {
@@ -216,11 +216,11 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 		}
 	}
 	top_cluetype, sub_cluetype, level, topname, subname = getClueType(item, data, sourceCode, sourceId) //查留资来源名字
-	if topname == "市场活动" && item == "saleLeads" {
+	if topname == "市场活动" && item == "saleLeads" {                                                       //市场活动的不要
 		log.Println("市场活动留资过滤 ", userId, phone)
 		return true, false
 	}
-	if strings.HasPrefix(belong_to, "03") {
+	if strings.HasPrefix(belong_to, "03") { //一切都好的不进
 		isOk := saveEverything(userId, phone, item, subname, sourceCode)
 		log.Println("渠道线索电销", userId, phone, item, subname, sourceCode)
 		if !isOk {
@@ -233,20 +233,20 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 		log.Println("线索分配失败，线索过滤top_cluetype！！", item, uId, phone, userId)
 		return true, true
 	}
-	position_id, seatNumber, saleName, saleData, pIsOk := autoDraw(level, cluename, phone, isGroup, isCommerce)
+	position_id, seatNumber, saleName, saleData, pIsOk := autoDraw(level, cluename, phone, isGroup, isCommerce) //查询当前分配次数最少的，如果当前线索有销售，此次找出的不会+1
 	log.Println("data -------", position_id, seatNumber, saleName)
 	if position_id > 0 && seatNumber != "" {
-		uCount, oks := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", ""), true
-		if uCount != nil && len(*uCount) > 0 {
+		uCount, oks := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", ""), true //查当前线索是否已存在
+		if uCount != nil && len(*uCount) > 0 {                                                               //已存在，走更新
 			batch_import := common.ObjToString((*uCount)["batch_import"])
-			if batch_import != "" && item == "users" {
+			if batch_import != "" && item == "users" { //有导入批次号还是新用户，不执行
 				return true, true
 			}
 			oks = UpdateClue(*uCount, saleData, item, userId, uId, top_cluetype, sub_cluetype, topname, subname, cluename, name, saleName, phone, position, department, departments, industry, follow_project_area, role, seatNumber, level, position_id, source, sourceCode, remark, keyword, belong_to, isGroup, isCommerce, pIsOk)
-		} else {
+		} else { //不存在走新增
 			oks = SaveClue(item, userId, uId, top_cluetype, sub_cluetype, topname, subname, cluename, name, saleName, phone, position, department, departments, industry, follow_project_area, role, seatNumber, position_id, source, sourceCode, remark, keyword, belong_to, isGroup, isCommerce)
-			if oks {
-				TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where seatNumber = ? and clue_level = ?`, seatNumber, level)
+			if oks { //新增成功，销售分配次数+1
+				TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where position_id = ? and clue_level = ?`, position_id, level)
 			}
 		}
 		if !oks {
@@ -388,9 +388,7 @@ func SaveClue(item, userId, uId, top_cluetype, sub_cluetype, topname, subname, c
 func UpdateClue(data map[string]interface{}, saleData []map[string]interface{}, item, userId, uId, top_cluetype, sub_cluetype, topname, subname, cluename, name, saleName, phone, position, department, departments, industry, follow_project_area, role, seatNumber, level string, positionId int64, source, sourceCode, remark string, keyword []string, belong_to string, isGroup, isCommerce int, pIsOk bool) bool {
 	nowTime := time.Now().Format("2006-01-02 15:04:05")
 	nowTimes := time.Unix(time.Now().Unix()+3600*12, 0).Format("2006-01-02 15:04:05")
-	//trailstatus = 无意向 为变更线索状态
-	//没有变更所属人查任务车，有车不变
-	trailstatus := common.ObjToString(data["trailstatus"])
+	trailstatus := common.ObjToString(data["trailstatus"]) //data都为原线索数据
 	trailstatusTime := common.ObjToString(data["trailstatus_time"])
 	var trailstatusTimes time.Time
 	if trailstatusTime != "" {
@@ -415,10 +413,10 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 	old_topname, old_subname := "", ""
 	is_transfer := common.IntAll(data["is_transfer"])
 	if taskstatus == 1 || is_task == 0 {
-		taskTime = common.ObjToString(common.If(item != "users", nowTime, nowTimes))
+		taskTime = common.ObjToString(common.If(item != "users", nowTime, nowTimes)) //任务时间，正常的是当前时间，新用户是当前时间+12个小时
 	} else {
 		if is_task == 1 {
-			if oldTaskTime != "" {
+			if oldTaskTime != "" { //以最新的任务时间为主
 				t1, err := time.Parse("2006-01-02 15:04:05", oldTaskTime)
 				if err == nil && time.Now().Before(t1) {
 					taskTime = nowTime
@@ -428,8 +426,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 			}
 		}
 	}
-	//加入任务车判断节假日
-	count, counts, t := 0, 0, time.Now()
+	count, counts, t := 0, 0, time.Now() //加入任务车判断节假日
 	for {
 		count++
 		currentTime := t.AddDate(0, 0, -count)
@@ -458,6 +455,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 			break
 		}
 	}
+	//两天之前不包含节假日，有没有跟进记录
 	recordCount := TiDb.CountBySql(`select count(1) from dwd_f_crm_trail_content where clue_id = ? and createtime > ?`, clueId, t.AddDate(0, 0, -count).Format(date.Date_Full_Layout))
 	//
 	clueUpdateData := map[string]interface{}{
@@ -472,14 +470,14 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 	}
 	old_remark := common.ObjToString(data["remark"])
 	if old_remark != "" {
-		remark = old_remark + ";" + remark
+		remark = old_remark + ";" + remark //备注不能替换，只能往上拼接
 	}
 	clueUpdateData["remark"] = remark
 	if cluename != "" {
-		clueUpdateData["cluename"] = cluename
+		clueUpdateData["cluename"] = cluename //新的线索名不为空才替换
 	}
 
-	if item != "orders" && item != "users" {
+	if item != "orders" && item != "users" { //新用户和订单之外的替换一下新的留资信息
 		if name != "" {
 			clueUpdateData["name"] = name
 		}
@@ -497,7 +495,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 		}
 		// clueUpdateData["industry"] = industry
 	}
-	if sourceCode == "app_xzcyh" {
+	if sourceCode == "app_xzcyh" { //这个留资单独处理一下
 		if departments != "" {
 			clueUpdateData["department"] = departments
 			department = departments
@@ -524,12 +522,12 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 			clueUpdateData["level_open"] = nil
 			clueUpdateData["clue_level"] = nil
 			for _, v := range saleData {
-				if common.ObjToString(data["seatNumber"]) == common.ObjToString(v["seat_number"]) {
+				if common.Int64All(data["position_id"]) == common.Int64All(v["position_id"]) {
 					oldsaleName = common.ObjToString(v["name"])
 				}
 			}
 		}
-	} else {
+	} else { //不属于上边情况就还是属于原来的销售，不更换销售
 		clueUpdateData["seatNumber"] = old_seatNumber
 		clueUpdateData["position_id"] = old_position_id
 		clueUpdateData["is_assign"] = 1
@@ -537,7 +535,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 		clueUpdateData["level_open"] = nil
 		clueUpdateData["clue_level"] = nil
 	}
-	if trailstatus != "08" && is_assign == 0 {
+	if trailstatus != "08" && is_assign == 0 { //在公海的成交客户
 		if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
 		} else {
 			clueUpdateData["trailstatus"] = "01"
@@ -913,7 +911,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 			})
 		}
 		if old_position_id == 0 {
-			TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where seatNumber = ? and clue_level = ?`, seatNumber, level)
+			TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where position_id = ? and clue_level = ?`, positionId, level)
 		}
 		return true
 	} else {

clueSync/jobutil.go

@@ -368,10 +368,10 @@ func getClueType(item string, data map[string]interface{}, sourceCode string, so
 // 获取自动分配的人
 func autoDraw(mode, cluename, phone string, isGroup, isCommerce int) (positionId int64, seatNumber, saleName string, saleData []map[string]interface{}, isOk bool) {
 	isOk = false
-	if TiDb.Count("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone, "is_assign": 1}) == 0 {
-		if isGroup == 0 && isCommerce == 1 && cluename != "" {
+	if TiDb.Count("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone, "is_assign": 1}) == 0 { //线索没销售进入，有销售走分配次数最少的逻辑
+		if isGroup == 0 && isCommerce == 1 && cluename != "" { //非集团在工商库线索名不为空
 			cdata := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"cluename": cluename, "is_assign": 1}, "", "")
-			if cdata != nil && len(*cdata) > 0 {
+			if cdata != nil && len(*cdata) > 0 { //找到了公司有人在跟进
 				isOk = true
 				positionId = common.Int64All((*cdata)["position_id"])
 				seatNumber = common.ObjToString((*cdata)["seatNumber"])
@@ -382,8 +382,8 @@ func autoDraw(mode, cluename, phone string, isGroup, isCommerce int) (positionId
 						saleData = *pdata
 						for _, v := range *pdata {
 							resign := common.IntAll(v["resign"])
-							if seatNumber == common.ObjToString(v["seat_number"]) {
-								if resign == 1 { //离职分配
+							if positionId == common.Int64All(v["position_id"]) {
+								if resign == 1 { //离职分配，找到的销售离职了，分给组员，没离职就给他
 									sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, positionId)
 									if sdata != nil && len(*sdata) > 0 {
 										positionId = common.Int64All((*sdata)[0]["position_id"])
@@ -425,7 +425,7 @@ func autoDraw(mode, cluename, phone string, isGroup, isCommerce int) (positionId
 			for _, v := range *data {
 				isOk := false //判断是否有新员工
 				for _, vv := range *countData {
-					if common.ObjToString(v["seat_number"]) == common.ObjToString(vv["seatNumber"]) {
+					if common.Int64All(v["position_id"]) == common.Int64All(vv["position_id"]) {
 						if common.IntAll(v["resign"]) == 0 {
 							vv["status"] = 1
 						} else {
@@ -435,32 +435,38 @@ func autoDraw(mode, cluename, phone string, isGroup, isCommerce int) (positionId
 					}
 				}
 				if !isOk { //有新员工直接分给新员工
-					seatNumber = common.ObjToString(v["seat_number"])
+					positionId = common.Int64All(v["position_id"])
 					saleName = common.ObjToString(v["name"])
+					log.Println("新员工, ", positionId, saleName)
 					rData := TiDb.FindOne("dwd_f_crm_clue_autodraw_record", map[string]interface{}{"clue_level": mode}, "", "count desc")
 					TiDb.Insert("dwd_f_crm_clue_autodraw_record", map[string]interface{}{
-						"seatNumber": seatNumber,
-						"clue_level": mode,
-						"count":      common.Int64All((*rData)["count"]),
+						"position_id": positionId,
+						"clue_level":  mode,
+						"count":       common.Int64All((*rData)["count"]),
 					})
 					break
 				}
 			}
-			if seatNumber == "" {
+			if positionId == 0 {
 				res := int64(0)
 				countres := 0
 				for _, v := range *countData {
 					if common.IntAll(v["status"]) == 1 {
 						if countres == 0 {
 							res = common.Int64All(v["count"])
-							seatNumber = common.ObjToString(v["seatNumber"])
+							positionId = common.Int64All(v["position_id"])
 						} else {
 							if common.Int64All(v["count"]) <= res {
+<<<<<<< HEAD
 								seatNumber1 := common.ObjToString(v["seatNumber"])
 								if !FindUpperLimit(seatNumber1, "seatNumber") {
 									res = common.Int64All(v["count"])
 									seatNumber = common.ObjToString(v["seatNumber"])
 								}
+=======
+								res = common.Int64All(v["count"])
+								positionId = common.Int64All(v["position_id"])
+>>>>>>> origin/feature/v1.5.2
 							}
 						}
 						countres++
@@ -468,26 +474,26 @@ func autoDraw(mode, cluename, phone string, isGroup, isCommerce int) (positionId
 				}
 			}
 		} else {
-			seatNumber = common.ObjToString((*data)[0]["seat_number"])
+			positionId = common.Int64All((*data)[0]["position_id"])
 			saleName = common.ObjToString((*data)[0]["name"])
 			rData := TiDb.FindOne("dwd_f_crm_clue_autodraw_record", map[string]interface{}{"clue_level": mode}, "", "count desc")
 			if rData != nil && len(*rData) > 0 {
 				TiDb.Insert("dwd_f_crm_clue_autodraw_record", map[string]interface{}{
-					"seatNumber": seatNumber,
-					"clue_level": mode,
-					"count":      common.Int64All((*rData)["count"]),
+					"position_id": positionId,
+					"clue_level":  mode,
+					"count":       common.Int64All((*rData)["count"]),
 				})
 			} else {
 				TiDb.Insert("dwd_f_crm_clue_autodraw_record", map[string]interface{}{
-					"seatNumber": seatNumber,
-					"clue_level": mode,
-					"count":      0,
+					"position_id": positionId,
+					"clue_level":  mode,
+					"count":       0,
 				})
 			}
 		}
 		for _, v := range *data {
-			if seatNumber == common.ObjToString(v["seat_number"]) {
-				positionId = common.Int64All(v["position_id"])
+			if positionId == common.Int64All(v["position_id"]) {
+				seatNumber = common.ObjToString(v["seat_number"])
 				saleName = common.ObjToString(v["name"])
 			}
 		}
@@ -520,6 +526,7 @@ func GetCompanyType(companyName string) (int, int) {
 	return isGroup, isCommerce
 }
 
+<<<<<<< HEAD
 // 查询是否达上限
 func FindUpperLimit(positionId string, dataType string) bool {
 	if positionId == "" {
@@ -531,4 +538,12 @@ func FindUpperLimit(positionId string, dataType string) bool {
 	} else {
 		return TiDb.CountBySql(`select count(1) from dwd_f_crm_clue_info where seatNumber=? and  is_assign and trailstatus != '08' `, positionId) >= 400
 	}
+=======
+func getSeatNumberPositionId(seatNumber string) (positionId int64) {
+	saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"seat_number": seatNumber}, "", "")
+	if saleData != nil && len(*saleData) > 0 {
+		positionId = common.Int64All((*saleData)["position_id"])
+	}
+	return
+>>>>>>> origin/feature/v1.5.2
 }

clueSync/kc.go

@@ -13,7 +13,6 @@ import (
 	"app.yhyue.com/moapp/jybase/date"
 	"app.yhyue.com/moapp/jybase/mongodb"
 	"app.yhyue.com/moapp/jybase/redis"
-	"github.com/tealeg/xlsx"
 )
 
 func kcSync() {
@@ -97,6 +96,7 @@ func kcJob(data map[string]interface{}) int {
 		//合力亿捷线索同步
 		customerData := TiDbData.FindOne("customer", map[string]interface{}{"phone": phone}, "", "")
 		if customerData != nil {
+			log.Println("移交客成查询到合力亿捷")
 			status999 := common.ObjToString((*customerData)["status999"])               //线索状态
 			source := common.ObjToString((*customerData)["source"])                     //销售来源
 			customerNeeds := common.ObjToString((*customerData)["customerNeeds"])       //客户需求
@@ -167,6 +167,7 @@ func kcJob(data map[string]interface{}) int {
 		//
 		entIds := common.IntAll(data["ent_id"])
 		positionId, name = cAutoDraw(entIds)
+		log.Println("移交客成positionId", positionId, name)
 		saveMap = map[string]interface{}{
 			"clue_id":                   clueId,
 			"transfertime":              nowTime,
@@ -594,727 +595,30 @@ func ordersClue() {
 	log.Println("后台订单线索定时任务结束")
 }
 
-func kcHistorySync() {
-	filePath := "./无线索的.xlsx"
-	// SE := qu.SimpleEncrypt{Key: "topJYBX2019"}
-	// log.Println(SE.DecodeString("QltHc2AmagsIUFwVV0dybyZpAwECX0YK"))
-	// return
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	// length := len(xlFile.Sheets[0].Rows)
-	//开辟除表头外的行数的数组内存
-	// resourceArr := make([]map[string]interface{}, length-1)
-	//遍历sheet
-	for k, sheet := range xlFile.Sheets {
-		if k > 0 {
-			break
-		}
-		//遍历每一行
-		for rowIndex, row := range sheet.Rows {
-			//跳过第一行表头信息
-			if rowIndex == 0 {
-				continue
-			}
-			nowTime := time.Now().Format(date.Date_Full_Layout)
-			relationship_building_way := row.Cells[1].Value
-			relationship_building_ways := 1
-			if relationship_building_way == "个人微信" {
-				relationship_building_ways = 2
-			} else if relationship_building_way == "企业微信" {
-				relationship_building_ways = 3
-			}
-			training_way := row.Cells[2].Value
-			training_ways := 1
-			if training_way == "发送使用资料" {
-				training_ways = 5
-			} else if training_way == "线上一对一" {
-				training_ways = 3
-			} else if training_way == "线下一对一" {
-				training_ways = 4
-			}
-			inventory_way := row.Cells[3].Value
-			inventory_ways := 1
-			if inventory_way == "电话盘点" {
-				inventory_ways = 3
-			} else if inventory_way == "微信盘点" {
-				inventory_ways = 2
-			}
-			service_stage := row.Cells[4].Value
-			service_stages := 1
-			if service_stage == "断约" {
-				service_stages = 2
-			} else if service_stage == "续约期" {
-				service_stages = 3
-			}
-			renewal_intention := row.Cells[5].Value
-			renewal_intentions := 1
-			if renewal_intention == "中" {
-				renewal_intentions = 2
-			} else if renewal_intention == "高" {
-				renewal_intentions = 3
-			}
-			positive_behavior_reminder := row.Cells[6].Value
-			positive_behavior_reminders := ""
-			if positive_behavior_reminder != "" {
-				positive_behavior_reminders = "1,3"
-			}
-			// negative_behavior_reminder := ""
-			name := row.Cells[13].Value
-			// phoneMap := map[string]string{
-			// "朱庆伟": "17600755377",
-			// "程涵":  "15538709520",
-			// "张铭铭": "18237530966",
-			// }
-
-			// company_name := row.Cells[10].Value
-			company_address := row.Cells[14].Value
-			company_website := row.Cells[15].Value
-			service_starttime := row.Cells[16].Value
-			service_endtime := row.Cells[17].Value
-
-			industry_status := row.Cells[21].Value
-			industry_statuss := 1
-			if industry_status == "非头部" {
-				industry_statuss = 2
-			}
-			target_customer_type := row.Cells[24].Value
-			main_sale_way := row.Cells[25].Value
-			main_get_info_way := row.Cells[26].Value
-			bid_sales_proportion := row.Cells[27].Value
-			continuous_use_judgment := row.Cells[29].Value
-			bid_sales_proportions := 1
-			continuous_use_judgments := 1
-			if bid_sales_proportion == "10%-19%" {
-				bid_sales_proportions = 2
-			} else if bid_sales_proportion == "20%-49%" {
-				bid_sales_proportions = 3
-			} else if bid_sales_proportion == "50%-69%" {
-				bid_sales_proportions = 4
-			} else if bid_sales_proportion == "70%及以上" {
-				bid_sales_proportions = 4
-			}
-			if strings.Contains(continuous_use_judgment, "预计可持续使用。需勤维护") {
-				continuous_use_judgments = 2
-			} else if strings.Contains(continuous_use_judgment, "需从功能层面提升客户粘性") {
-				continuous_use_judgments = 3
-			} else if strings.Contains(continuous_use_judgment, "需持续培育") {
-				continuous_use_judgments = 4
-			}
-			is_pre_sales_training := row.Cells[30].Value
-			is_pre_sales_trainings := 0
-			if is_pre_sales_training == "是" {
-				is_pre_sales_trainings = 1
-			}
-			shpx := row.Cells[31].Value
-			if shpx == "否" {
-				training_ways = 2
-			}
-			notes := row.Cells[32].Value
-			phone := strings.TrimSpace(row.Cells[11].Value)
-			log.Println("PHONE", phone, name, len(phone))
-			// if phone != "" && len(phone) == 11 && phoneMap[name] != "" {
-			positionId := 0
-			if name == "程涵" {
-				positionId = 2202735
-			} else if name == "张铭铭" {
-				positionId = 2202736
-			}
-			clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-			log.Println("clueData", clueData)
-			if clueData != nil {
-				clueId := common.Int64All((*clueData)["id"])
-				log.Println("线索存在", phone, clueId)
-				role := row.Cells[18].Value
-				business_scope := row.Cells[19].Value
-				industry := row.Cells[20].Value
-				salesperson_num := row.Cells[22].Value
-				salesperson_nums := 1
-				if salesperson_num == "10-19" {
-					salesperson_nums = 2
-				} else if salesperson_num == "20-49" {
-					salesperson_nums = 3
-				} else if salesperson_num == "50-99" {
-					salesperson_nums = 4
-				}
-				area := row.Cells[23].Value
-				areaArr := []string{}
-				for _, v := range strings.Split(area, ",") {
-					areaArr = append(areaArr, AreaCode[v])
-				}
-				follow_project_area := ""
-				if len(areaArr) > 0 {
-					follow_project_area = strings.Join(areaArr, ",")
-				}
-				customer_demand := row.Cells[28].Value
-				updatetime := row.Cells[36].Value
-				ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, map[string]interface{}{
-					"role":                role,
-					"business_scope":      business_scope,
-					"industry":            industry,
-					"follow_project_area": follow_project_area,
-					"customer_demand":     customer_demand,
-					"updatetime":          updatetime,
-					"is_transfer":         1,
-					"salesperson_num":     salesperson_nums,
-				})
-				if ok {
-					entId := "0"
-					buy_subject := 1
-					company_name := ""
-					product := 1
-					powerData := TiDb.FindOne("dwd_f_userbase_order_info", map[string]interface{}{"phone": phone}, "", "autoUpdate desc")
-					if powerData != nil {
-						buy_subject = common.IntAll((*powerData)["buy_subject"])
-						if buy_subject == 1 {
-							entId = common.ObjToString((*powerData)["userid"])
-						} else {
-							entId = fmt.Sprint((*powerData)["ent_id"])
-						}
-						company_name = common.ObjToString((*powerData)["company_name"])
-						product_type := common.ObjToString((*powerData)["product_type"])
-						data_spec := common.ObjToString((*powerData)["data_spec"])
-						productMap := map[string]int{
-							"dhy6":   1,
-							"dhy7":   2,
-							"dhy3":   4,
-							"dhy1":   5,
-							"dhy2":   6,
-							"dhy5":   7,
-							"企业商机管理": 8,
-						}
-						if product_type == "企业商机管理" {
-							product = productMap[product_type]
-						} else {
-							if data_spec == "dhy6" {
-								product = 1
-								filter := common.ObjToString((*powerData)["filter"])
-								filterMap := map[string]interface{}{}
-								json.Unmarshal([]byte(filter), &filterMap)
-								if len(filterMap) > 0 {
-									areaCount := common.IntAll(filterMap["areaCount"])
-									if areaCount == 1 {
-										product = 3
-									}
-								}
-							} else {
-								product = productMap[data_spec]
-							}
-						}
-					}
-					cid := TiDb.Insert("dwd_f_csm_customer_info", map[string]interface{}{
-						"clue_id":                    clueId,
-						"transfertime":               nowTime,
-						"position_id":                positionId,
-						"name":                       name,
-						"service_starttime":          service_starttime,
-						"service_endtime":            service_endtime,
-						"ent_id":                     entId,
-						"is_task":                    1,
-						"tasktime":                   nowTime,
-						"taskstatus":                 0,
-						"tasksource":                 "1",
-						"is_admin":                   1,
-						"product_access":             product,
-						"buy_subject":                buy_subject,
-						"relationship_building_way":  relationship_building_ways,
-						"inventory_way":              inventory_ways,
-						"training_way":               training_ways,
-						"is_pre_sales_training":      is_pre_sales_trainings,
-						"service_stage":              service_stages,
-						"company_name":               company_name,
-						"renewal_intention":          renewal_intentions,
-						"positive_behavior_reminder": positive_behavior_reminders,
-						"company_address":            company_address,
-						"company_website":            company_website,
-						"industry_status":            industry_statuss,
-						"target_customer_type":       target_customer_type,
-						"main_sale_way":              main_sale_way,
-						"main_get_info_way":          main_get_info_way,
-						// "bid_sales_proportion":    bid_sales_proportions,
-						// "continuous_use_judgment": continuous_use_judgments,
-						"notes": notes,
-					})
-					if cid > 0 {
-						log.Println("保存客户成功", phone)
-					} else {
-						log.Println("保存客户失败！！！", phone)
-					}
-				} else {
-					log.Println("线索修改失败！！！", phone)
-				}
-			} else {
-				role := row.Cells[18].Value
-				business_scope := row.Cells[19].Value
-				industry := row.Cells[20].Value
-				salesperson_num := row.Cells[22].Value
-				salesperson_nums := 1
-				if salesperson_num == "10-19" {
-					salesperson_nums = 2
-				} else if salesperson_num == "20-49" {
-					salesperson_nums = 3
-				} else if salesperson_num == "50-99" {
-					salesperson_nums = 4
-				}
-				area := row.Cells[23].Value
-				areaArr := []string{}
-				for _, v := range strings.Split(area, ",") {
-					areaArr = append(areaArr, AreaCode[v])
-				}
-				follow_project_area := ""
-				if len(areaArr) > 0 {
-					follow_project_area = strings.Join(areaArr, ",")
-				}
-				customer_demand := row.Cells[28].Value
-				entId := "0"
-				clueId := int64(0)
-				buy_subject := 1
-				company_name := ""
-				product := 1
-				powerData := TiDb.FindOne("dwd_f_userbase_order_info", map[string]interface{}{"phone": phone}, "", "autoUpdate desc")
-				if powerData != nil {
-					buy_subject = common.IntAll((*powerData)["buy_subject"])
-					if buy_subject == 1 {
-						entId = common.ObjToString((*powerData)["userid"])
-					} else {
-						entId = fmt.Sprint((*powerData)["ent_id"])
-					}
-					company_name = common.ObjToString((*powerData)["company_name"])
-					product_type := common.ObjToString((*powerData)["product_type"])
-					data_spec := common.ObjToString((*powerData)["data_spec"])
-					productMap := map[string]int{
-						"dhy6":   1,
-						"dhy7":   2,
-						"dhy3":   4,
-						"dhy1":   5,
-						"dhy2":   6,
-						"dhy5":   7,
-						"企业商机管理": 8,
-					}
-					if product_type == "企业商机管理" {
-						product = productMap[product_type]
-					} else {
-						if data_spec == "dhy6" {
-							product = 1
-							filter := common.ObjToString((*powerData)["filter"])
-							filterMap := map[string]interface{}{}
-							json.Unmarshal([]byte(filter), &filterMap)
-							if len(filterMap) > 0 {
-								areaCount := common.IntAll(filterMap["areaCount"])
-								if areaCount == 1 {
-									product = 3
-								}
-							}
-						} else {
-							product = productMap[data_spec]
-						}
-					}
-					//
-					uId := common.ObjToString((*powerData)["uid"])
-					userId := common.ObjToString((*powerData)["userid"])
-					pay_money := common.IntAll((*powerData)["pay_money"])
-					seatNumber, trailstatus := "", ""
-					salePositionId := int64(0)
-					cluename := common.ObjToString((*powerData)["company_name"])
-					salesperson := common.ObjToString((*powerData)["salesperson"])
-					if cluename == "" {
-						cluename = phone
-					}
-					if pay_money > 0 {
-						trailstatus = "08"
-					} else {
-						trailstatus = "01"
-					}
-					saleData := TiDb.FindOne("jy_salesperson_info", map[string]interface{}{"name": salesperson}, "", "")
-					if saleData != nil {
-						seatNumber = common.ObjToString((*saleData)["seat_number"])
-						salePositionId = common.Int64All((*saleData)["position_id"])
-					}
-					clueId = TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
-						"userid":               userId,
-						"uid":                  uId,
-						"seatNumber":           seatNumber,
-						"position_id":          salePositionId,
-						"is_assign":            1,
-						"comeintime":           nowTime,
-						"createtime":           nowTime,
-						"updatetime":           nowTime,
-						"cluename":             cluename,
-						"top_cluetype":         "4",
-						"sub_cluetype":         "154",
-						"trailstatus":          trailstatus,
-						"name":                 phone,
-						"phone":                phone,
-						"comeinsource_private": 2,
-						"is_task":              0,
-						"taskstatus":           1,
-						"role":                 role,
-						"business_scope":       business_scope,
-						"industry":             industry,
-						"follow_project_area":  follow_project_area,
-						"customer_demand":      customer_demand,
-						"is_transfer":          1,
-						"salesperson_num":      salesperson_nums,
-					})
-					//
-				}
-				TiDb.Insert("dwd_f_csm_customer_info", map[string]interface{}{
-					"clue_id":                    clueId,
-					"transfertime":               nowTime,
-					"position_id":                positionId,
-					"name":                       name,
-					"service_starttime":          service_starttime,
-					"service_endtime":            service_endtime,
-					"ent_id":                     entId,
-					"is_task":                    0,
-					"tasktime":                   nil,
-					"taskstatus":                 1,
-					"tasksource":                 nil,
-					"is_admin":                   1,
-					"product_access":             product,
-					"buy_subject":                buy_subject,
-					"relationship_building_way":  relationship_building_ways,
-					"inventory_way":              inventory_ways,
-					"training_way":               training_ways,
-					"is_pre_sales_training":      is_pre_sales_trainings,
-					"service_stage":              service_stages,
-					"company_name":               company_name,
-					"renewal_intention":          renewal_intentions,
-					"positive_behavior_reminder": positive_behavior_reminders,
-					"company_address":            company_address,
-					"company_website":            company_website,
-					"industry_status":            industry_statuss,
-					"target_customer_type":       target_customer_type,
-					"main_sale_way":              main_sale_way,
-					"main_get_info_way":          main_get_info_way,
-					"bid_sales_proportion":       bid_sales_proportions,
-					"continuous_use_judgment":    continuous_use_judgments,
-					"notes":                      notes,
-				})
-			}
-			// } else {
-			// 	log.Println("手机号有问题！！！", phone)
-			// 	row.AddCell().SetValue("手机号有问题！！！")
-			// }
-		}
-	}
-	// err := xlFile.Save("./222.xlsx")
-	// if err != nil {
-	// 	log.Println("xls error")
-	// }
-}
-
-func kcHistorySyncs() {
-	filePath := "./有线索的.xlsx"
-	// SE := qu.SimpleEncrypt{Key: "topJYBX2019"}
-	// log.Println(SE.DecodeString("QltHc2AmagsIUFwVV0dybyZpAwECX0YK"))
-	// return
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	// length := len(xlFile.Sheets[0].Rows)
-	//开辟除表头外的行数的数组内存
-	// resourceArr := make([]map[string]interface{}, length-1)
-	//遍历sheet
-	for k, sheet := range xlFile.Sheets {
-		if k > 0 {
-			break
-		}
-		//遍历每一行
-		for rowIndex, row := range sheet.Rows {
-			//跳过第一行表头信息
-			if rowIndex == 0 {
-				continue
-			}
-			bid_sales_proportion := row.Cells[2].Value
-			continuous_use_judgment := row.Cells[3].Value
-			phone := row.Cells[0].Value
-			bid_sales_proportions := 1
-			continuous_use_judgments := 1
-			if bid_sales_proportion == "10%-19%" {
-				bid_sales_proportions = 2
-			} else if bid_sales_proportion == "20%-49%" {
-				bid_sales_proportions = 3
-			} else if bid_sales_proportion == "50%-69%" {
-				bid_sales_proportions = 4
-			} else if bid_sales_proportion == "70%及以上" {
-				bid_sales_proportions = 4
-			}
-			if strings.Contains(continuous_use_judgment, "预计可持续使用。需勤维护") {
-				continuous_use_judgments = 2
-			} else if strings.Contains(continuous_use_judgment, "需从功能层面提升客户粘性") {
-				continuous_use_judgments = 3
-			} else if strings.Contains(continuous_use_judgment, "需持续培育") {
-				continuous_use_judgments = 4
-			}
-			if phone != "" {
-				clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-				if clueData != nil {
-					clueId := common.Int64All((*clueData)["id"])
-					log.Println("线索存在", phone, clueId)
-					salesperson_num := row.Cells[1].Value
-					salesperson_nums := 1
-					if salesperson_num == "10-19" {
-						salesperson_nums = 2
-					} else if salesperson_num == "20-49" {
-						salesperson_nums = 3
-					} else if salesperson_num == "50-99" {
-						salesperson_nums = 4
-					}
-					ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, map[string]interface{}{
-						"salesperson_num": salesperson_nums,
-					})
-					if ok {
-						oks := TiDb.Update("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
-							"bid_sales_proportion":    bid_sales_proportions,
-							"continuous_use_judgment": continuous_use_judgments,
-						})
-						if oks {
-							log.Println("修改客户成功", phone)
-						} else {
-							log.Println("修改客户失败！！！", phone)
-						}
-					} else {
-						log.Println("线索修改失败！！！", phone)
-					}
-				}
-			}
-		}
-	}
-}
-
-func kcVisitSync() {
-	filePath := "./222.xlsx"
-	// SE := qu.SimpleEncrypt{Key: "topJYBX2019"}
-	// log.Println(SE.DecodeString("QltHc2AmagsIUFwVV0dybyZpAwECX0YK"))
-	// return
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	// length := len(xlFile.Sheets[0].Rows)
-	//开辟除表头外的行数的数组内存
-	// resourceArr := make([]map[string]interface{}, length-1)
-	//遍历sheet
-	for k, sheet := range xlFile.Sheets {
-		if k == 1 {
-			//遍历每一行
-			for rowIndex, row := range sheet.Rows {
-				//跳过第一行表头信息
-				if rowIndex == 0 {
-					continue
-				}
-				tasksource := row.Cells[1].Value
-				tasksources := 1
-				if tasksource == "客户情况盘点" {
-					tasksources = 2
-				} else if tasksource == "未培训" {
-					tasksources = 3
-				} else if tasksource == "日常沟通" {
-					tasksources = 4
-				} else if tasksource == "续约沟通" {
-					tasksources = 5
-				} else if tasksource == "月度回访" {
-					tasksources = 6
-				} else if tasksource == "培训首周回访" {
-					tasksources = 7
-				} else if tasksource == "建联" {
-					tasksources = 1
-				}
-				phone := row.Cells[2].Value
-				trail_way := row.Cells[3].Value
-				trail_ways := 1
-				if trail_way == "电话沟通" {
-					trail_ways = 2
-				} else if trail_way == "线下面访" {
-					trail_ways = 3
-				} else if trail_way == "腾讯会议" {
-					trail_ways = 4
-				}
-				content := row.Cells[4].Value
-				name := row.Cells[5].Value
-				positionId := 0
-				if name == "程涵" {
-					positionId = 2202735
-				} else if name == "张铭铭" {
-					positionId = 2202736
-				} else {
-					positionId = -1
-				}
-				createtime := row.Cells[6].Value
-				clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-				if clueData != nil {
-					clueId := common.Int64All((*clueData)["id"])
-					TiDb.Insert("dwd_f_crm_trail_content", map[string]interface{}{
-						"clue_id":     clueId,
-						"position_id": positionId,
-						"operator_id": -1,
-						"content":     content,
-						"createtime":  createtime,
-						"tasksource":  tasksources,
-						"trail_way":   trail_ways,
-					})
-				} else {
-					row.AddCell().SetValue("没有线索")
-				}
-			}
-		} else if k == 2 {
-			//遍历每一行
-			for rowIndex, row := range sheet.Rows {
-				//跳过第一行表头信息
-				if rowIndex == 0 {
-					continue
-				}
-				phone := row.Cells[2].Value
-				contact_type := row.Cells[4].Value
-				clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-				if clueData != nil {
-					clueId := common.Int64All((*clueData)["id"])
-					TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{"contact_type": contact_type})
-				} else {
-					row.AddCell().SetValue("没有线索")
-				}
-			}
-		}
-	}
-	err := xlFile.Save("./333.xlsx")
-	if err != nil {
-		log.Println("xls error")
-	}
-}
-
 func refundAuto() {
 	log.Println("自动移交销售定时任务开始")
 	nowTime := time.Now().Format(date.Date_Full_Layout)
 	TiDb.SelectByBath(100, func(l *[]map[string]interface{}) bool {
 		for _, v := range *l {
-			saleId, cluename, company_nature, company_verification := int64(0), "", 0, 0
+			saleId, cluename, company_nature, company_verification, uid := int64(0), "", 0, 0, ""
 			clueId := common.Int64All(v["clue_id"])
 			name := common.ObjToString(v["name"])
 			kcposition_id := common.Int64All(v["position_id"])
 			isRenewalProtection := common.IntAll(v["is_renewal_protection"])
-			phone := ""
-
-			// if !mongodb.IsObjectIdHex(userId) {
-			clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, "company_nature,company_verification,cluename,userid,position_id,phone", "")
+			clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, "company_nature,company_verification,cluename,userid,position_id,uid", "")
 			if clueData != nil && len(*clueData) > 0 {
 				saleId = common.Int64All((*clueData)["position_id"])
-				// userId = common.ObjToString((*clueData)["userid"])
 				cluename = common.ObjToString((*clueData)["cluename"])
 				company_nature = common.IntAll((*clueData)["company_nature"])
 				company_verification = common.IntAll((*clueData)["company_verification"])
-				phone = common.ObjToString((*clueData)["phone"])
+				uid = common.ObjToString((*clueData)["uid"])
 			}
-			query1 := `select id from dataexport_order where (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime > "` + nowTime + `" and order_status = 1 and user_phone = "` + phone + `"`
-			query2 := `select id from dataexport_order where (product_type = "企业商机管理" or product_type = "大会员") and refund_status in (0,2) and order_status = 1 and user_phone = "` + phone + `"`
-			// userData := TiDb.SelectBySql("select position_id from dwd_f_userbase_id_mapping where userid = ? and ent_id = ?", userId, entId)
-			// if userData != nil && len(*userData) > 0 {
-			// 	positionId = common.Int64All((*userData)[0]["position_id"])
-			// 	query1 = `select id from dataexport_order where (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime > "` + nowTime + `" and order_status = 1 and user_id = "` + fmt.Sprint(positionId) + `"`
-			// 	query2 = `select id from dataexport_order where (product_type = "企业商机管理" or product_type = "大会员") and refund_status in (0,2) and order_status = 1 and user_id = "` + fmt.Sprint(positionId) + `"`
-			// }
-			// }
-			order1 := Mysql.SelectBySql(query1)
-			if order1 == nil || len(*order1) == 0 {
-				log.Println("query1 ", query1)
-				isOk := false
-				order3 := Mysql.SelectBySql(`select vip_endtime from dataexport_order where (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime < "` + nowTime + `" and order_status = 1 and user_phone = "` + phone + `"`)
-				if order3 != nil && len(*order3) > 0 {
-					for _, vv := range *order3 {
-						if isRenewalProtection == 1 {
-							vip_endtime := common.ObjToString(vv["vip_endtime"])
-							vip_endtimes, _ := time.ParseInLocation(date.Date_Full_Layout, vip_endtime, time.Local)
-							if time.Now().Unix()-vip_endtimes.Unix() < 30*86400 {
-								isOk = true
-							}
-						}
-					}
-				}
-				if !isOk {
-					//全到期了
-					if saleId > 0 {
-						saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": saleId, "resign": 0}, "", "")
-						if saleData != nil && len(*saleData) > 0 {
-							TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, nowTime, clueId)
-						} else {
-							if company_nature == 0 && company_verification == 1 && cluename != "" {
-								adata := TiDb.Find("dwd_f_crm_clue_info", map[string]interface{}{"cluename": cluename, "is_assign": 1}, "seatNumber,position_id", "", -1, -1)
-								if adata != nil && len(*adata) > 0 {
-									isOks := false
-									for _, vv := range *adata {
-										position_ids := common.Int64All(vv["position_id"])
-										seatNumber := common.ObjToString(vv["seatNumber"])
-										saleDatas := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": position_ids, "resign": 0}, "", "")
-										if saleDatas != nil && len(*saleDatas) > 0 {
-											saleId = position_ids
-											TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
-											isOks = true
-											break
-										}
-									}
-									if !isOks {
-										sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
-										if sdata != nil && len(*sdata) > 0 {
-											saleId = common.Int64All((*sdata)[0]["position_id"])
-											seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
-											TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
-										}
-									}
-								}
-							} else {
-								sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
-								if sdata != nil && len(*sdata) > 0 {
-									saleId = common.Int64All((*sdata)[0]["position_id"])
-									seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
-									TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
-								}
-							}
-						}
-					} else {
-						TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",top_cluetype="532",sub_cluetype="537",is_transfer=0 WHERE id = ?`, nowTime, clueId)
-					}
-					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-						"clue_id":      clueId,
-						"position_id":  common.If(kcposition_id > 0, kcposition_id, -1),
-						"change_type":  "基本信息变更",
-						"old_value":    "成交客户",
-						"change_field": "trailstatus",
-						"new_value":    "商机线索",
-						"createtime":   nowTime,
-						"BCPCID":       common.GetRandom(32),
-						"operator_id":  -1,
-					})
-					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-						"clue_id":     clueId,
-						"position_id": saleId,
-						"change_type": "加入任务车",
-						"new_value":   "线索自动分配-其他-成交客户续约失败",
-						"createtime":  nowTime,
-						"BCPCID":      common.GetRandom(32),
-						"operator_id": -1,
-					})
-					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-						"clue_id":      clueId,
-						"position_id":  common.If(kcposition_id > 0, kcposition_id, -1),
-						"change_type":  "客户成功经理",
-						"change_field": "position_id",
-						"old_value":    name,
-						"new_value":    "/",
-						"createtime":   nowTime,
-						"BCPCID":       common.GetRandom(32),
-						"operator_id":  -1,
-					})
-					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-						"clue_id":     clueId,
-						"position_id": saleId,
-						"change_type": "移交销售",
-						"new_value":   "成交客户续费失败，到期自动移交",
-						"createtime":  nowTime,
-						"BCPCID":      common.GetRandom(32),
-						"operator_id": -1,
-					})
-					TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
-				}
-			}
-			order2 := Mysql.SelectBySql(query2)
+			query1 := fmt.Sprintf(`select id from dwd_f_userbase_order_info where (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime > "%s" and order_status = 1 and pay_money > 0 and uid = "%s"`, nowTime, uid)
+			query2 := fmt.Sprintf(`select id from dwd_f_userbase_order_info where (product_type = "企业商机管理" or product_type = "大会员") and refund_status in (0,2) and order_status = 1 and pay_money > 0 and uid = "%s"`, uid)
+			log.Println("query1 ", query1)
+			log.Println("query2 ", query2)
+			order2 := TiDb.SelectBySql(query2)
 			if order2 == nil || len(*order2) == 0 {
-				log.Println("query2 ", query2)
 				//全退款了
 				TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET 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)
 				TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
@@ -1358,9 +662,132 @@ func refundAuto() {
 					"operator_id": -1,
 				})
 				TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
+			} else {
+				order1 := TiDb.SelectBySql(query1)
+				if order1 == nil || len(*order1) == 0 {
+					isOk := false
+					query3 := fmt.Sprintf(`select vip_endtime from dwd_f_userbase_order_info where (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime < "%s" and order_status = 1 and pay_money > 0 and uid = "%s"`, nowTime, uid)
+					log.Println("query3 ", query3)
+					order3 := TiDb.SelectBySql(query3)
+					if order3 != nil && len(*order3) > 0 {
+						for _, vv := range *order3 {
+							if isRenewalProtection == 1 {
+								vip_endtime := common.ObjToString(vv["vip_endtime"])
+								vip_endtimes, _ := time.ParseInLocation(date.Date_Full_Layout, vip_endtime, time.Local)
+								if time.Now().Unix()-vip_endtimes.Unix() < 3*30*86400 {
+									isOk = true
+								}
+							}
+						}
+					}
+					if !isOk {
+						//全到期了
+						if saleId > 0 {
+							saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": saleId, "resign": 0}, "", "")
+							if saleData != nil && len(*saleData) > 0 {
+								TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, nowTime, clueId)
+							} else {
+								if company_nature == 0 && company_verification == 1 && cluename != "" {
+									adata := TiDb.Find("dwd_f_crm_clue_info", map[string]interface{}{"cluename": cluename, "is_assign": 1}, "seatNumber,position_id", "", -1, -1)
+									if adata != nil && len(*adata) > 0 {
+										isOks := false
+										for _, vv := range *adata {
+											position_ids := common.Int64All(vv["position_id"])
+											seatNumber := common.ObjToString(vv["seatNumber"])
+											saleDatas := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": position_ids, "resign": 0}, "", "")
+											if saleDatas != nil && len(*saleDatas) > 0 {
+												saleId = position_ids
+												TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
+												isOks = true
+												break
+											}
+										}
+										if !isOks {
+											sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
+											if sdata != nil && len(*sdata) > 0 {
+												saleId = common.Int64All((*sdata)[0]["position_id"])
+												seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
+												TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
+											}
+										}
+									}
+								} else {
+									sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
+									if sdata != nil && len(*sdata) > 0 {
+										saleId = common.Int64All((*sdata)[0]["position_id"])
+										seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
+										TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
+									}
+								}
+							}
+						} else {
+							TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET updatetime=?,trailstatus="01",top_cluetype="532",sub_cluetype="537",is_transfer=0 WHERE id = ?`, nowTime, clueId)
+						}
+						TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
+							"clue_id":      clueId,
+							"position_id":  common.If(kcposition_id > 0, kcposition_id, -1),
+							"change_type":  "基本信息变更",
+							"old_value":    "成交客户",
+							"change_field": "trailstatus",
+							"new_value":    "商机线索",
+							"createtime":   nowTime,
+							"BCPCID":       common.GetRandom(32),
+							"operator_id":  -1,
+						})
+						TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
+							"clue_id":     clueId,
+							"position_id": saleId,
+							"change_type": "加入任务车",
+							"new_value":   "线索自动分配-其他-成交客户续约失败",
+							"createtime":  nowTime,
+							"BCPCID":      common.GetRandom(32),
+							"operator_id": -1,
+						})
+						TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
+							"clue_id":      clueId,
+							"position_id":  common.If(kcposition_id > 0, kcposition_id, -1),
+							"change_type":  "客户成功经理",
+							"change_field": "position_id",
+							"old_value":    name,
+							"new_value":    "/",
+							"createtime":   nowTime,
+							"BCPCID":       common.GetRandom(32),
+							"operator_id":  -1,
+						})
+						TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
+							"clue_id":     clueId,
+							"position_id": saleId,
+							"change_type": "移交销售",
+							"new_value":   "成交客户续费失败，到期自动移交",
+							"createtime":  nowTime,
+							"BCPCID":      common.GetRandom(32),
+							"operator_id": -1,
+						})
+						TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
+					}
+				}
 			}
 		}
 		return true
 	}, `select ent_id,clue_id,position_id,name,is_renewal_protection from dwd_f_csm_customer_info where is_transfer = 0`)
 	log.Println("自动移交销售定时任务结束")
 }
+
+func refundAutoHistory() {
+	data := TiDb.Find("dwd_f_crm_clue_autodraw_record", nil, "", "", -1, -1)
+	if data != nil {
+		for _, v := range *data {
+			seatNumber := common.ObjToString(v["seatNumber"])
+			adata := TiDb.Find("dwd_f_crm_personnel_management", map[string]interface{}{"seat_number": seatNumber}, "", "", -1, -1)
+			if adata != nil {
+				for _, vv := range *adata {
+					if common.IntAll(vv["resign"]) == 0 {
+						position_id := common.Int64All(vv["position_id"])
+						TiDb.Update("dwd_f_crm_clue_autodraw_record", map[string]interface{}{"seatNumber": seatNumber}, map[string]interface{}{"position_id": position_id})
+						break
+					}
+				}
+			}
+		}
+	}
+}

clueSync/main.go

@@ -128,14 +128,15 @@ func main() {
 			saleLeads()   //留资进线索
 		})
 		c.Start()
-		// 用户标签一天一次
+		// 一天一次
 		// tagAllSync()
 		d := cron.New()
 		d.AddFunc(cfg.CornExp4, func() {
-			tagAllSync()
+			tagAllSync() //用户标签
 		})
 		d.Start()
-		// 用户标签增量 5分钟一次
+		// 5分钟一次
+		go ordersClue() //后台订单进线索
 		e := cron.New()
 		e.AddFunc(cfg.CornExp5, func() {
 			go everythingSync() //渠道
@@ -155,13 +156,14 @@ func main() {
 		//自动进入任务车 1天一次
 		g := cron.New()
 		g.AddFunc(cfg.CornExp7, func() {
-			readClue() //读取中间表进线索
-			//refundAuto() //客成移交销售
-			autoTask()  //超时未跟进加入任务车
-			autoTasks() //按照下次跟进时间提前一天加入任务车
+			readClue()   //读取中间表进线索
+			refundAuto() //客成移交销售
+			autoTask()   //超时未跟进加入任务车
+			autoTasks()  //按照下次跟进时间提前一天加入任务车
 		})
 		g.Start()
 		select {}
 	} else {
+		refundAutoHistory()
 	}
 }

clueSync/subscribeAll.go

@@ -1,12 +1,9 @@
 package main
 
 import (
-	"regexp"
 	"strings"
 	"time"
 
-	"app.yhyue.com/moapp/jybase/date"
-
 	"log"
 
 	"app.yhyue.com/moapp/jybase/common"
@@ -179,133 +176,3 @@ func FormatSubscribeAllData(data map[string]interface{}) {
 		}
 	}
 }
-
-func eventSync() {
-	AppBuyPortraitReg := regexp.MustCompile("^/jyapp/big/page/unit_portrayal")
-	AppArticleReg := regexp.MustCompile("^/jyapp/article/(content|bdprivate|mailprivate)")
-	AppEntPortraitReg := regexp.MustCompile("^/jyapp/big/page/ent_portrait")
-	AppClientReg := regexp.MustCompile("^^/jyapp/big/page/client_portrayal")
-	TiDb.SelectByBath(1000, func(l *[]map[string]interface{}) bool {
-		for _, v := range *l {
-			url_ := common.ObjToString(v["url"])
-			id := common.Int64All(v["id"])
-			if AppBuyPortraitReg.MatchString(url_) {
-				url_ = strings.ReplaceAll(url_, "/jyapp/big/page", "/swordfish/page_big_pc")
-			} else if AppArticleReg.MatchString(url_) {
-				url_ = strings.ReplaceAll(url_, "/jyapp", "")
-			} else if AppEntPortraitReg.MatchString(url_) {
-				url_ = strings.ReplaceAll(url_, "/jyapp/big/page", "/swordfish/page_big_pc")
-			} else if AppClientReg.MatchString(url_) {
-				url_ = strings.ReplaceAll(url_, "/jyapp/big/page/client_portrayal?entName=", "/swordfish/page_big_pc/unit_portrayal/")
-			}
-			ok := TiDb.Update("dwd_f_userbase_event_info", map[string]interface{}{"id": id}, map[string]interface{}{"url": url_})
-			if ok {
-				log.Println("修改成功 ", id, url_)
-			} else {
-				log.Println("修改失败 ", id, url_)
-			}
-		}
-		return true
-	}, `SELECT * from dwd_f_userbase_event_info where platform = 1`)
-	log.Println("app刷行为信息链接结束")
-}
-
-func uidSync() {
-	phoneMap := map[string][]map[string]interface{}{}
-	data := TiDb.SelectBySql(`SELECT * FROM dwd_f_crm_clue_info WHERE phone IN (SELECT phone FROM dwd_f_crm_clue_info GROUP BY phone HAVING COUNT(1) > 1) ORDER BY comeintime asc`)
-	if data != nil && len(*data) > 0 {
-		for _, v := range *data {
-			phone := common.ObjToString(v["phone"])
-			id1 := common.Int64All(v["id"])
-			if phone != "" {
-				phoneMap[phone] = append(phoneMap[phone], v)
-			} else {
-				TiDb.Delete("dwd_f_crm_clue_info", map[string]interface{}{"id": id1})
-				TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id1})
-				TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id1})
-				TiDb.Delete("dwd_f_crm_clue_change_record", map[string]interface{}{"clue_id": id1})
-			}
-		}
-	}
-	log.Println(len(phoneMap))
-	for _, v := range phoneMap {
-		userid1 := common.ObjToString(v[0]["userid"])
-		id1 := common.Int64All(v[0]["id"])
-		id2 := common.Int64All(v[1]["id"])
-		if userid1 != "" {
-			TiDb.Delete("dwd_f_crm_clue_info", map[string]interface{}{"id": id2})
-			TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id2})
-			TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id2})
-			TiDb.Delete("dwd_f_crm_clue_change_record", map[string]interface{}{"clue_id": id2})
-			is_assign := common.IntAll(v[0]["is_assign"])
-			DelClue(is_assign, id1)
-		} else {
-			TiDb.Delete("dwd_f_crm_clue_info", map[string]interface{}{"id": id1})
-			TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id1})
-			TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id1})
-			TiDb.Delete("dwd_f_crm_clue_change_record", map[string]interface{}{"clue_id": id1})
-			is_assign := common.IntAll(v[1]["is_assign"])
-			DelClue(is_assign, id2)
-		}
-	}
-}
-
-func DelClue(is_assign int, id2 int64) {
-	if is_assign == 1 {
-		pd := TiDb.FindOne("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id2}, "", "")
-		if pd != nil && len(*pd) > 0 {
-			TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id2})
-		} else {
-			od := TiDb.FindOne("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id2}, "", "")
-			if od != nil && len(*od) > 0 {
-				TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": id2}, map[string]interface{}{"is_assign": 0})
-			} else {
-				TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": id2}, map[string]interface{}{"is_assign": 0})
-				TiDb.Insert("dwd_f_crm_open_sea", map[string]interface{}{
-					"clue_id":      id2,
-					"comeintime":   time.Now().Format(date.Date_Full_Layout),
-					"comeinsource": 2,
-				})
-			}
-		}
-	} else if is_assign == 0 {
-		od := TiDb.FindOne("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id2}, "", "")
-		if od != nil && len(*od) > 0 {
-			TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id2})
-		} else {
-			TiDb.Insert("dwd_f_crm_open_sea", map[string]interface{}{
-				"clue_id":      id2,
-				"comeintime":   time.Now().Format(date.Date_Full_Layout),
-				"comeinsource": 2,
-			})
-			TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id2})
-		}
-	} else if is_assign == -1 {
-		TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": id2})
-		TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": id2})
-	}
-}
-
-func privateClueSync() {
-	phoneMap := map[int64][]map[string]interface{}{}
-	data := TiDb.SelectBySql(`SELECT * FROM dwd_f_crm_private_sea WHERE clue_id IN (SELECT clue_id FROM dwd_f_crm_private_sea GROUP BY clue_id HAVING COUNT(1) > 1)`)
-	if data != nil && len(*data) > 0 {
-		for _, v := range *data {
-			clue_id := common.Int64All(v["clue_id"])
-			if clue_id > 0 {
-				phoneMap[clue_id] = append(phoneMap[clue_id], v)
-			}
-		}
-	}
-	log.Println(len(phoneMap))
-	for _, v := range phoneMap {
-		if len(v) > 1 {
-			clue_id1 := common.Int64All(v[1]["clue_id"])
-			// seatNumber1 := common.ObjToString(v[1]["seatNumber"])
-			id1 := common.Int64All(v[1]["id"])
-			if clue_id1 > 0 {
-				TiDb.Delete("dwd_f_crm_private_sea", map[string]interface{}{"id": id1})
-			}
-		}
-	}
-}

clueSync/trailContent.go

@@ -1,615 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"log"
-	"regexp"
-
-	"app.yhyue.com/moapp/jybase/mongodb"
-
-	"strings"
-	"time"
-
-	"app.yhyue.com/moapp/jybase/common"
-	"app.yhyue.com/moapp/jybase/date"
-	"github.com/tealeg/xlsx"
-)
-
-func trail() {
-	log.Println("合力亿捷跟进历史任务开始")
-	nameReg := regexp.MustCompile("【.*?】")
-	filePath := "./xlsx/跟进历史" + cfg.XlsxNum + ".xlsx"
-	log.Println("文件名 ", filePath)
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	length := len(xlFile.Sheets[0].Rows)
-	log.Println("获取行数 ", length)
-	//遍历sheet
-	for _, sheet := range xlFile.Sheets {
-		//遍历每一行
-		for rowIndex, row := range sheet.Rows {
-			//跳过第一行表头信息
-			if rowIndex == 0 {
-				continue
-			}
-			createtime := row.Cells[0].Value
-			name := row.Cells[1].Value
-			nexttype := row.Cells[2].Value
-			content := row.Cells[3].Value
-			phone := row.Cells[6].Value
-			positionId, clueId := getSale(name, phone)
-			log.Println("positionId,clueId ", positionId, clueId)
-			if clueId > 0 {
-				if nexttype == "无类型" {
-					TiDb.Insert("dwd_f_crm_trail_content", map[string]interface{}{
-						"clue_id":     clueId,
-						"position_id": positionId,
-						"createtime":  createtime,
-						"content":     content,
-						"operator_id": positionId,
-					})
-				} else {
-					old_value := strings.ReplaceAll(strings.ReplaceAll(nameReg.FindAllString(content, -1)[0], "【", ""), "】", "")
-					new_value := strings.ReplaceAll(strings.ReplaceAll(nameReg.FindAllString(content, -1)[1], "【", ""), "】", "")
-					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-						"clue_id":      clueId,
-						"position_id":  positionId,
-						"createtime":   createtime,
-						"change_field": common.If(nexttype == "所属人变更", "position_id", "trailstatus"),
-						"change_type":  common.If(nexttype == "所属人变更", nexttype, "基本信息变更"),
-						"old_value":    common.If(old_value == "销售线索", "商机线索", old_value),
-						"new_value":    common.If(new_value == "销售线索", "商机线索", new_value),
-						"operator_id":  positionId,
-					})
-				}
-			}
-		}
-	}
-}
-
-func getSale(name, phone string) (positionId, clueId int64) {
-	saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"name": name, "resign": 0}, "", "")
-	if saleData != nil && len(*saleData) > 0 {
-		positionId = common.Int64All((*saleData)["position_id"])
-	} else {
-		positionId = -1
-	}
-	if positionId == 0 {
-		positionId = -1
-	}
-	clueInfo := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-	if clueInfo != nil && len(*clueInfo) > 0 {
-		clueId = common.Int64All((*clueInfo)["id"])
-	}
-	return
-}
-
-func getSeatNumberPositionId(seatNumber string) (positionId int64) {
-	saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"seat_number": seatNumber}, "", "")
-	if saleData != nil && len(*saleData) > 0 {
-		positionId = common.Int64All((*saleData)["position_id"])
-	}
-	return
-}
-
-func getXlsx() {
-	filePath := "./code1.xlsx"
-	nowTime := time.Now().Format(date.Date_Full_Layout)
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	// length := len(xlFile.Sheets[0].Rows)
-	//开辟除表头外的行数的数组内存
-	// resourceArr := make([]map[string]interface{}, length-1)
-	//遍历sheet
-	for _, sheet := range xlFile.Sheets {
-		//遍历每一行
-		for rowIndex, row := range sheet.Rows {
-			//跳过第一行表头信息
-			if rowIndex == 0 {
-				continue
-			}
-			company := row.Cells[1].Value
-			name := row.Cells[2].Value
-			position := row.Cells[3].Value
-			phone := row.Cells[4].Value
-			if phone != "" {
-				data := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"phone": phone}, "", "")
-				if data != nil && len(*data) > 0 {
-					isAssign := common.IntAll((*data)["is_assign"])
-					clueId := common.Int64All((*data)["id"])
-					if isAssign == 1 {
-						//在私海
-						TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{
-							"is_assign":    1,
-							"comeintime":   nowTime,
-							"updatetime":   nowTime,
-							"top_cluetype": "377",
-							"sub_cluetype": "381",
-						})
-						TiDb.Update("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
-							"comeintime":   nowTime,
-							"comeinsource": 2,
-							"is_task":      1,
-							"task_time":    nowTime,
-							"tasktime":     nowTime,
-							"taskstatus":   0,
-							"tasksource":   "线索自动分配-批量导入-6月份获取拟建项目清单留资",
-						})
-					} else {
-						//在公海
-						positionId, seatNumber, _, _, _ := autoDraw("C", "", "", 0, 0)
-						TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"is_assign":    1,
-							"comeintime":   nowTime,
-							"updatetime":   nowTime,
-							"trailstatus":  "01",
-							"top_cluetype": "377",
-							"sub_cluetype": "381",
-						})
-						TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": clueId})
-						TiDb.Insert("dwd_f_crm_private_sea", map[string]interface{}{
-							"clue_id":      clueId,
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"comeintime":   nowTime,
-							"comeinsource": 2,
-							"is_task":      1,
-							"task_time":    nowTime,
-							"tasktime":     nowTime,
-							"taskstatus":   0,
-							"tasksource":   "线索自动分配-批量导入-6月份获取拟建项目清单留资",
-						})
-					}
-				} else {
-					//无线索
-					base := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{"phone": phone}, "", "")
-					if base != nil && len(*base) > 0 {
-						uId := common.ObjToString((*base)["uid"])
-						userId := common.ObjToString((*base)["userid"])
-						positionId, seatNumber, _, _, _ := autoDraw("C", "", "", 0, 0)
-						clueId := TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
-							"userid":       userId,
-							"uid":          uId,
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"is_assign":    1,
-							"comeintime":   nowTime,
-							"createtime":   nowTime,
-							"updatetime":   nowTime,
-							"cluename":     common.If(company != "", company, phone),
-							"top_cluetype": "377",
-							"sub_cluetype": "381",
-							"trailstatus":  "01",
-							"name":         name,
-							"phone":        phone,
-							"position":     position,
-						})
-						if clueId > -1 {
-							TiDb.Insert("dwd_f_crm_private_sea", map[string]interface{}{
-								"clue_id":      clueId,
-								"seatNumber":   seatNumber,
-								"position_id":  positionId,
-								"comeintime":   nowTime,
-								"comeinsource": 2,
-								"is_task":      1,
-								"task_time":    nowTime,
-								"tasktime":     "2023-06-12 10:00:00",
-								"taskstatus":   0,
-								"tasksource":   "线索自动分配-批量导入-6月份获取拟建项目清单留资",
-							})
-						}
-					}
-				}
-			}
-		}
-	}
-}
-
-func getXlsx2() {
-	filePath := "./code2.xlsx"
-	nowTime := time.Now().Format(date.Date_Full_Layout)
-	xlFile, _ := xlsx.OpenFile(filePath)
-	//获取行数
-	// length := len(xlFile.Sheets[0].Rows)
-	//开辟除表头外的行数的数组内存
-	// resourceArr := make([]map[string]interface{}, length-1)
-	//遍历sheet
-	for _, sheet := range xlFile.Sheets {
-		//遍历每一行
-		for rowIndex, row := range sheet.Rows {
-			//跳过第一行表头信息
-			if rowIndex == 0 {
-				continue
-			}
-			userId := row.Cells[0].Value
-			company := row.Cells[5].Value
-			name := row.Cells[1].Value
-			position := row.Cells[6].Value
-			phone := row.Cells[7].Value
-			positionId, seatNumber := int64(2047781), "8040"
-			if phone != "" {
-				data := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"userid": userId}, "", "")
-				if data != nil && len(*data) > 0 {
-					isAssign := common.IntAll((*data)["is_assign"])
-					clueId := common.Int64All((*data)["id"])
-					if isAssign != 1 {
-						//不在私海
-						TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"is_assign":    1,
-							"comeintime":   nowTime,
-							"updatetime":   nowTime,
-							"trailstatus":  "01",
-							"top_cluetype": "377",
-							"sub_cluetype": "382",
-						})
-						TiDb.Delete("dwd_f_crm_open_sea", map[string]interface{}{"clue_id": clueId})
-						TiDb.Insert("dwd_f_crm_private_sea", map[string]interface{}{
-							"clue_id":      clueId,
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"comeintime":   nowTime,
-							"comeinsource": 2,
-							"is_task":      1,
-							"task_time":    nowTime,
-							"tasktime":     nowTime,
-							"taskstatus":   0,
-							"tasksource":   "线索自动分配-批量导入-医械厂商线索",
-						})
-					}
-				} else {
-					//无线索
-					base := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{"userid": userId}, "", "")
-					if base != nil && len(*base) > 0 {
-						uId := common.ObjToString((*base)["uid"])
-						clueId := TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
-							"userid":       userId,
-							"uid":          uId,
-							"seatNumber":   seatNumber,
-							"position_id":  positionId,
-							"is_assign":    1,
-							"comeintime":   nowTime,
-							"createtime":   nowTime,
-							"updatetime":   nowTime,
-							"cluename":     common.If(company != "", company, phone),
-							"top_cluetype": "377",
-							"sub_cluetype": "382",
-							"trailstatus":  "01",
-							"name":         name,
-							"phone":        phone,
-							"position":     position,
-						})
-						if clueId > -1 {
-							TiDb.Insert("dwd_f_crm_private_sea", map[string]interface{}{
-								"clue_id":      clueId,
-								"seatNumber":   seatNumber,
-								"position_id":  positionId,
-								"comeintime":   nowTime,
-								"comeinsource": 2,
-								"is_task":      1,
-								"task_time":    nowTime,
-								"tasktime":     "2023-06-12 10:00:00",
-								"taskstatus":   0,
-								"tasksource":   "线索自动分配-批量导入-医械厂商线索",
-							})
-						}
-					}
-				}
-			}
-		}
-	}
-}
-
-func clueInfoSync() {
-	TiDb.SelectByBath(500, func(l *[]map[string]interface{}) bool {
-		for _, v := range *l {
-			id := common.Int64All(v["id"])
-			is_assign := common.IntAll(v["is_assign"])
-			comeintime := common.ObjToString(v["comeintime"])
-			comeintime_open := common.ObjToString(v["comeintime_open"])
-			trail_time, trail_times, next_trail_time := common.ObjToString(v["createtime"]), "", ""
-			tasktime := common.ObjToString(v["tasktime"])
-			task_time := common.ObjToString(v["task_time"])
-			is_task := common.IntAll(v["is_task"])
-			taskstatus := common.IntAll(v["taskstatus"])
-			comeinsource_private := common.IntAll(v["comeinsource_private"])
-			tasksource := common.ObjToString(v["tasksource"])
-			out_task_time := common.ObjToString(v["out_task_time"])
-			out_task_status := common.IntAll(v["out_task_status"])
-			comeinsource_open := common.IntAll(v["comeinsource_open"])
-			level_open := common.IntAll(v["level_open"])
-			clue_level := common.ObjToString(v["clue_level"])
-			var (
-				trail_time_s time.Time
-				comeintime_s time.Time
-			)
-			if trail_time != "" && comeintime != "" {
-				trail_time_s, _ = time.ParseInLocation(date.Date_Full_Layout, trail_time, time.Local)
-				comeintime_s, _ = time.ParseInLocation(date.Date_Full_Layout, comeintime, time.Local)
-				if trail_time_s.Unix() > comeintime_s.Unix() {
-					trail_times = trail_time
-					next_trail_time = common.ObjToString(v["next_time"])
-				}
-			}
-			updateData := map[string]interface{}{
-				"comeintime":      common.If(comeintime != "", comeintime, nil),
-				"comeintime_open": common.If(comeintime_open != "", comeintime_open, nil),
-			}
-			if is_assign == 1 {
-				updateData["trail_time"] = common.If(trail_times != "", trail_times, nil)
-				updateData["next_trail_time"] = common.If(next_trail_time != "", next_trail_time, nil)
-				updateData["is_task"] = is_task
-				updateData["tasktime"] = common.If(tasktime != "", tasktime, nil)
-				updateData["task_time"] = common.If(task_time != "", task_time, nil)
-				updateData["taskstatus"] = taskstatus
-				updateData["comeinsource_private"] = comeinsource_private
-				updateData["tasksource"] = tasksource
-				updateData["out_task_time"] = common.If(out_task_time != "", out_task_time, nil)
-				updateData["out_task_status"] = out_task_status
-			} else if is_assign == 0 {
-				updateData["comeinsource_open"] = comeinsource_open
-				updateData["level_open"] = level_open
-				updateData["clue_level"] = clue_level
-			}
-			ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": id}, updateData)
-			if ok {
-				log.Println("线索表同步成功 ", id)
-			} else {
-				log.Println("线索表同步失败！！！ ", id, updateData)
-			}
-		}
-		return true
-	}, `SELECT a.id,a.is_assign,c.comeintime,b.comeintime as comeintime_open,d.createtime,d.next_time,c.tasktime,c.task_time,c.is_task,c.taskstatus,c.comeinsource as comeinsource_private,c.tasksource,c.out_task_time,c.out_task_status,b.comeinsource as comeinsource_open,b.level as level_open,b.clue_level
- 			FROM dwd_f_crm_clue_info a 
-				LEFT JOIN dwd_f_crm_open_sea b ON b.clue_id=a.id 
-				LEFT JOIN dwd_f_crm_private_sea c ON c.clue_id=a.id 
-				LEFT JOIN dwd_f_crm_trail_content d ON d.clue_id=a.id and d.position_id=a.position_id`)
-}
-
-func app_xzcyh_sync() {
-	query := map[string]interface{}{"source": "app_xzcyh"}
-	session := Mgo.GetMgoConn()
-	defer func() {
-		Mgo.DestoryMongoConn(session)
-	}()
-	iter := session.DB(cfg.Mgo.DbName).C("saleLeads").Find(&query).Sort("_id").Iter()
-	thisData := map[string]interface{}{}
-	for {
-		if !iter.Next(&thisData) {
-			break
-		}
-		userId := common.ObjToString(thisData["userid"])
-		keyword := common.ObjArrToStringArr(thisData["keyword"].([]interface{}))
-		if !mongodb.IsObjectIdHex(userId) {
-			userMapping := TiDb.FindOne("dwd_f_userbase_id_mapping", map[string]interface{}{"position_id": userId}, "", "")
-			if userMapping != nil && len(*userMapping) > 0 {
-				userId = common.ObjToString((*userMapping)["userid"])
-			}
-		}
-		data := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"userid": userId}, "", "")
-		if data != nil && len(*data) > 0 {
-			business_scope := common.ObjToString((*data)["business_scope"])
-			clueUpdateData := map[string]interface{}{}
-			keywords := ""
-			if len(keyword) > 0 && keyword[0] != "" {
-				keywords = strings.Join(keyword, ",")
-				if business_scope != "" {
-					clueUpdateData["business_scope"] = business_scope + "," + keywords
-				} else {
-					clueUpdateData["business_scope"] = keywords
-				}
-				ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"userid": userId}, clueUpdateData)
-				if ok {
-					log.Println("主营业务修改成功", userId, keywords)
-				} else {
-					log.Println("主营业务修改失败！！！", userId, keywords)
-				}
-			}
-		}
-	}
-}
-
-func lzhSync() {
-	nowTime, count := time.Now().Format("2006-01-02 15:04:05"), 0
-	data := TiDbData.SelectBySql(`SELECT * FROM customer where owner in (2646,8050) and status999 in ("status0","status1","status2","status3")`)
-	if data != nil {
-		for _, v := range *data {
-			count++
-			owner := common.ObjToString(v["owner"])
-			positionId, seatNumber, trailstatus, uId, userId := int64(0), "", "", "", ""
-			if owner == "2646" {
-				positionId = 1205321180
-				seatNumber = "2646"
-			} else {
-				positionId = 1205321184
-				seatNumber = "8050"
-			}
-			phone := common.ObjToString(v["phone"])
-			status := common.ObjToString(v["status999"])
-			cluename := common.ObjToString(v["company"])
-			name := common.ObjToString(v["username"])
-			position := common.ObjToString(v["job"])
-			if status == "status0" {
-				trailstatus = "08"
-			} else if status == "status1" {
-				trailstatus = "07"
-			} else if status == "status2" {
-				trailstatus = "06"
-			} else {
-				trailstatus = "05"
-			}
-			cdata := TiDb.FindOne("dwd_f_userbase_contacts", map[string]interface{}{"phone": phone}, "", "")
-			if cdata != nil {
-				uId = common.ObjToString((*cdata)["baseinfo_id"])
-				cluedata := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
-				if cluedata != nil {
-					log.Println("第", count, "条已有线索", phone, uId)
-					seatNumbersss := common.ObjToString((*cluedata)["seatNumber"])
-					if seatNumbersss == "" {
-						TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, map[string]interface{}{
-							"seatNumber":           seatNumber,
-							"position_id":          positionId,
-							"is_assign":            1,
-							"comeintime":           nowTime,
-							"updatetime":           nowTime,
-							"trailstatus":          trailstatus,
-							"is_task":              1,
-							"task_time":            nowTime,
-							"tasktime":             nowTime,
-							"taskstatus":           0,
-							"comeinsource_private": 2,
-						})
-					}
-				} else {
-					udata := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{"uid": uId}, "", "")
-					if udata != nil {
-						userId = common.ObjToString((*udata)["userid"])
-						clueId := TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
-							"userid":               userId,
-							"uid":                  uId,
-							"seatNumber":           seatNumber,
-							"position_id":          positionId,
-							"is_assign":            1,
-							"comeintime":           nowTime,
-							"createtime":           nowTime,
-							"updatetime":           nowTime,
-							"cluename":             cluename,
-							"top_cluetype":         "4",
-							"sub_cluetype":         "154",
-							"trailstatus":          trailstatus,
-							"name":                 name,
-							"phone":                phone,
-							"position":             position,
-							"comeinsource_private": 2,
-							"is_task":              1,
-							"task_time":            nowTime,
-							"tasktime":             nowTime,
-							"taskstatus":           0,
-						})
-						if clueId > 0 {
-							log.Println("第", count, "条保存成功", phone, uId)
-						}
-					}
-				}
-			}
-
-		}
-	}
-}
-
-func piliangfenpeicuowu() {
-	data := TiDb.SelectBySql(`SELECT a.clue_id,a.old_value,b.position_id,b.seat_number FROM dwd_f_crm_clue_change_record a INNER JOIN dwd_f_crm_personnel_management b on b.name = a.old_value where a.position_id = 2222419 and a.createtime > "2024-02-26 00:00:00" and a.change_type = "所属人变更" and a.new_value != "/"`)
-	if data != nil && len(*data) > 0 {
-		for _, v := range *data {
-			clue_id := common.Int64All(v["clue_id"])
-			name := common.ObjToString(v["old_value"])
-			position_id := common.Int64All(v["position_id"])
-			seat_number := common.ObjToString(v["seat_number"])
-			ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clue_id}, map[string]interface{}{"position_id": position_id, "seatNumber": seat_number})
-			if ok {
-				log.Println("修改成功 ", clue_id, name)
-			} else {
-				log.Println("修改失败！！！ ", clue_id, name, position_id, seat_number)
-			}
-		}
-	}
-}
-
-func pilianggonghaicuowu() {
-	count := 0
-	data := TiDb.SelectBySql(`SELECT id FROM dwd_f_crm_clue_info WHERE comeintime_open >= "2024-03-04 16:46:16" and comeintime_open <= "2024-03-04 16:46:18"`)
-	if data != nil && len(*data) > 0 {
-		log.Println("LEN", len(*data))
-		for _, v := range *data {
-			count++
-			clue_id := common.Int64All(v["id"])
-			log.Println("COUNT ", count, clue_id)
-			sdata := TiDb.SelectBySql(`SELECT a.clue_id,a.old_value,a.new_value,b.position_id,b.seat_number,a.createtime FROM dwd_f_crm_clue_change_record a INNER JOIN dwd_f_crm_personnel_management b on b.name = a.new_value where a.clue_id = ` + fmt.Sprint(clue_id) + ` and a.change_type = "所属人变更" and a.new_value != "/" and a.new_value != "沈炳毅" ORDER BY a.createtime desc`)
-			if sdata != nil && len(*sdata) > 0 {
-				name := common.ObjToString((*sdata)[0]["new_value"])
-				position_id := common.Int64All((*sdata)[0]["position_id"])
-				seat_number := common.ObjToString((*sdata)[0]["seat_number"])
-				ok := TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clue_id}, map[string]interface{}{"position_id": position_id, "seatNumber": seat_number, "is_assign": 1})
-				if ok {
-					log.Println("修改成功 ", clue_id, name)
-				} else {
-					log.Println("修改失败！！！ ", clue_id, name, position_id, seat_number)
-				}
-			}
-		}
-	}
-}
-
-func userbase_error() {
-	log.Println("userbase_error定时任务开始")
-	sql := `SELECT dfub.uid,dfub.userid,dfub.phone,dfub.source FROM 
-	dwd_f_userbase_baseinfo dfub 
-	LEFT JOIN dwd_f_crm_clue_info dfci ON dfub.uid = dfci.uid 
-	LEFT JOIN dwd_f_userbase_contacts dfuc ON dfub.uid = dfuc.baseinfo_id 
-WHERE 
-	dfci.id IS NULL 
-	AND dfub.phone IS NOT NULL 
-	AND dfub.phone != "" 
-	AND dfub.belong_to NOT LIKE "02%" 
-	AND dfub.belong_to NOT LIKE "03%" 
-	AND dfub.status NOT IN (0,2) 
-	AND dfub.source NOT IN ("0102","0103","0104","0105")`
-	data := TiDb.SelectBySql(sql)
-	if data != nil && *data != nil && len(*data) > 0 {
-		for _, v := range *data {
-			phone := common.ObjToString(v["phone"])
-			uId := common.ObjToString(v["uid"])
-			userId := common.ObjToString(v["userid"])
-			nowTime := time.Now().Format(date.Date_Full_Layout)
-			source := common.ObjToString(v["source"])
-			if phone != "" {
-				contactsData := TiDb.SelectBySql("select * from dwd_f_userbase_contacts where phone = ? and is_delete = 1", phone)
-				if contactsData == nil || len(*contactsData) == 0 {
-					TiDb.Insert("dwd_f_userbase_contacts", map[string]interface{}{
-						"status":      1,
-						"is_delete":   1,
-						"createtime":  nowTime,
-						"updatetime":  nowTime,
-						"phone":       phone,
-						"baseinfo_id": uId,
-						"SOURCE":      source,
-					})
-				}
-				count := TiDb.CountBySql("select count(1) as count from dwd_f_crm_clue_info where uid = ?", uId)
-				log.Println("userbase uid 线索数量 ", count)
-				if count == 0 {
-					clueId := TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
-						"userid":            userId,
-						"uid":               uId,
-						"is_assign":         0,
-						"comeintime":        nowTime,
-						"createtime":        nowTime,
-						"updatetime":        nowTime,
-						"cluename":          phone,
-						"top_cluetype":      "532",
-						"sub_cluetype":      "475",
-						"trailstatus":       "01",
-						"phone":             phone,
-						"comeintime_open":   nowTime,
-						"comeinsource_open": 1,
-					})
-					if clueId > 0 {
-						TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
-							"clue_id":     clueId,
-							"position_id": -1,
-							"change_type": "创建线索",
-							"new_value":   "系统自动创建",
-							"createtime":  nowTime,
-							"BCPCID":      common.GetRandom(32),
-							"operator_id": -1,
-						})
-					}
-				}
-			}
-		}
-	}
-	log.Println("userbase_error定时任务结束")
-}