datatools/clueSync/job.go

package main

import (
	"database/sql"
	"encoding/json"
	"fmt"
	"log"
	"net/url"
	"strings"
	"time"

	"app.yhyue.com/moapp/jybase/date"

	"app.yhyue.com/moapp/jybase/redis"

	"app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/mongodb"
)

// 未支付订单 30分钟一次
func orders() {
	//一个小时未支付进入线索 A
	log.Println("未支付订单定时任务开始")
	lastOrderId := cfg.LastOrderId
	selectTimeStart := time.Unix(time.Now().Unix()-7200, 0).Format(date.Date_Full_Layout)
	selectTimeEnd := time.Unix(time.Now().Unix()-3600, 0).Format(date.Date_Full_Layout)
	sql := fmt.Sprintf(`select * from dataexport_order where create_time <= "%s" and create_time >= "%s" and id > %s`, selectTimeEnd, selectTimeStart, fmt.Sprint(lastOrderId))
	data := Mysql.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			order_status := common.IntAll(v["order_status"])
			is_backstage_order := common.IntAll(v["is_backstage_order"])
			product_type_str1 := `"大会员","VIP订阅","数据流量包","历史数据"`
			product_type := common.ObjToString(v["product_type"])
			if order_status == 0 && is_backstage_order == 0 && strings.Contains(product_type_str1, product_type) {
				ok1, _ := FormatData(v, "orders")
				if !ok1 {
					common.WriteSysConfig(&cfg)
					break
				}
			}
			cfg.LastOrderId = common.IntAll(v["id"])
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("未支付订单定时任务结束")
}

// 新注册用户 5分钟一次
func users() {
	//判断节假日
	currentTime, runOk := time.Now(), false
	// if currentTime.Weekday() == time.Sunday || currentTime.Weekday() == time.Saturday {
	if currentTime.Weekday() == time.Sunday {
		isok := false
		for k, v := range DateMap {
			if currentTime.Format(date.Date_Short_Layout) == k && v == 2 {
				isok = true
			}
		}
		if isok {
			runOk = true
		}
	} else {
		isok := true
		for k, v := range DateMap {
			if currentTime.Format(date.Date_Short_Layout) == k && v == 1 {
				isok = false
			}
		}
		if isok {
			runOk = true
		}
	}
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	} /*else {
		if currentTime.Hour() == 17 && currentTime.Minute() > 30 {
			log.Println("不是工作日，任务暂停")
			return
		}
	}*/
	//新用户注册后5分钟内进入线索 C
	log.Println("新注册用户定时任务开始")
	selectTimeEnd := cfg.LastUserId
	sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and source = 1`, selectTimeEnd)
	data := TiDb.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for k, v := range *data {
			createtime := common.ObjToString(v["createtime"])
			FormatData(v, "users")
			if k == len(*data)-1 {
				cfg.LastUserId = createtime
			}
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("新注册用户定时任务结束")
}

func userbase() {
	log.Println("userbase定时任务开始")
	selectTimeEnd := time.Unix(time.Now().Unix()-1800, 0).Format("2006-01-02 15:04:05")
	sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where updatetime > "%s" and source > 0`, selectTimeEnd)
	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"])
			registedate := common.ObjToString(v["l_registedate"])
			name := common.ObjToString(v["name"])
			nowTime := time.Now().Format(date.Date_Full_Layout)
			source := common.IntAll(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 {
					contactsData2 := TiDb.SelectBySql("select * from dwd_f_userbase_contacts where baseinfo_id = ? and is_delete = 1", uId)
					if contactsData2 != nil && len(*contactsData2) > 0 {
						log.Println("userbase uid不为空 新增通讯录", uId)
						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,
						})
					} else {
						registedates, _ := time.Parse(date.Date_Full_Layout, registedate)
						count := TiDb.CountBySql("select count(1) as count from dwd_f_crm_clue_info where uid = ?", uId)
						log.Println("userbase uid 线索数量 ", count)
						log.Println("userbase uid 注册时间 ", registedates)
						if time.Now().Unix()-registedates.Unix() > int64(cfg.RegTimes)*86400 {
							if count == 0 {
								// TiDb.Insert("dwd_f_crm_open_sea", map[string]interface{}{
								// 	"clue_id":      clueId,
								// 	"comeintime":   nowTime,
								// 	"comeinsource": 2,
								// })
								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":      "474",
									"sub_cluetype":      "475",
									"trailstatus":       "01",
									"name":              name,
									"phone":             phone,
									"comeintime_open":   nowTime,
									"comeinsource_open": 1,
								})
								if clueId > 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,
									})
									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,
									})
								}
							} else {
								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,
								})
							}
						} else {
							if count == 0 {
								FormatData(v, "users")
							} else {
								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,
								})
							}
						}
					}
				}
			}
		}
	}
	log.Println("userbase定时任务结束")
}

// 留资 5分钟一次
func saleLeads() {
	//判断节假日
	currentTime, runOk := time.Now(), false
	// if currentTime.Weekday() == time.Sunday || currentTime.Weekday() == time.Saturday {
	if currentTime.Weekday() == time.Sunday {
		isok := false
		for k, v := range DateMap {
			if currentTime.Format(date.Date_Short_Layout) == k && v == 2 {
				isok = true
			}
		}
		if isok {
			runOk = true
		}
	} else {
		isok := true
		for k, v := range DateMap {
			if currentTime.Format(date.Date_Short_Layout) == k && v == 1 {
				isok = false
			}
		}
		if isok {
			runOk = true
		}
	}
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	} /*else {
		if currentTime.Hour() == 17 && currentTime.Minute() > 30 {
			log.Println("不是工作日，任务暂停")
			return
		}
	}*/
	//留资后5分钟内进入线索
	//分为免费留资和付费留资 付费B 免费C
	log.Println("用户留资定时任务开始")
	session := Mgo.GetMgoConn()
	lastId := cfg.LastId
	defer func() {
		Mgo.DestoryMongoConn(session)
	}()
	query := map[string]interface{}{}
	if lastId != "" {
		query["_id"] = map[string]interface{}{"$gt": mongodb.StringTOBsonId(lastId)}
	}
	// query["_id"] = map[string]interface{}{"$gt": mongodb.StringTOBsonId("63f6049a4c172a1fd44ed3c8")}
	log.Println("query :", query)

	iter := session.DB(cfg.Mgo.DbName).C("saleLeads").Find(&query).Sort("_id").Iter()
	thisData := map[string]interface{}{}

	for {
		if !iter.Next(&thisData) {
			break
		}
		ok1, _ := FormatData(thisData, "saleLeads")
		if !ok1 {
			common.WriteSysConfig(&cfg)
			break
		}
		cfg.LastId = mongodb.BsonIdToSId(thisData["_id"])
		// FormatData(thisData, "saleLeads")
	}
	common.WriteSysConfig(&cfg)
	log.Println("用户留资定时任务结束")
}

func FormatData(data map[string]interface{}, item string) (bool, bool) {
	userId, uId, positionId, source, cluename, phone, sourceCode, keyword := common.ObjToString(data["user_id"]), "", "", 0, "", "", "", []string{}
	role, industry, department, departments, position, name, top_cluetype, sub_cluetype, follow_project_area, level := "", "", "", "", "", "", "", "", "", ""
	query, topname, subname, belong_to, sourceName := map[string]interface{}{}, "", "", "01", ""
	nowTime := time.Now().Format("2006-01-02 15:04:05")
	if item == "orders" {
		if !mongodb.IsObjectIdHex(userId) {
			positionId = 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"])
			}
		}
		query["userid"] = userId
		userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
		if userInfo != nil && len(*userInfo) > 0 {
			uId = common.ObjToString((*userInfo)["uid"])
			source = common.IntAll((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
		}
		//cluename --> company_name
		cluename = common.ObjToString(data["company_name"])
		phone = common.ObjToString(data["user_phone"])
	} else if item == "message" {
		userMapping := TiDb.FindOne("dwd_f_userbase_id_mapping", map[string]interface{}{"base_user_id": common.Int64All(data["own_id"])}, "", "")
		if userMapping != nil && len(*userMapping) > 0 {
			userId = common.ObjToString((*userMapping)["userid"])
			positionId = fmt.Sprint((*userMapping)["position_id"])
		}
		query["userid"] = userId
		userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
		if userInfo != nil && len(*userInfo) > 0 {
			uId = common.ObjToString((*userInfo)["uid"])
			source = common.IntAll((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
			// cluename = common.ObjToString((*userInfo)["company_name"])
			phone = common.ObjToString((*userInfo)["phone"])
		}
	} else if item == "users" {
		userId = mongodb.BsonIdToSId(data["userid"])
		//新用户没有uid、source要等5分钟
		cluename = common.ObjToString(data["company_name"])
		phone = common.ObjToString(data["phone"])
		if phone != "" {
			contactsData := TiDb.SelectBySql("select * from dwd_f_userbase_contacts where phone = ? and is_delete = 1", phone)
			if contactsData != nil && len(*contactsData) > 0 {
				if common.ObjToString((*contactsData)[0]["baseinfo_id"]) != "" {
					uId = common.ObjToString((*contactsData)[0]["baseinfo_id"])
					query["uid"] = uId
				} else {
					query["userid"] = userId
				}
			} else {
				query["userid"] = userId
			}
			userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
			if userInfo != nil && len(*userInfo) > 0 {
				uId = common.ObjToString((*userInfo)["uid"])
				source = common.IntAll((*userInfo)["source"])
				belong_to = common.ObjToString((*userInfo)["belong_to"])
				// userId = common.ObjToString((*userInfo)["userid"])
			}
		}
	} else if item == "saleLeads" {
		userId = common.ObjToString(data["userid"])
		if !mongodb.IsObjectIdHex(userId) {
			positionId = 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"])
			}
		}

		cluename = common.ObjToString(data["company"])
		phone = common.ObjToString(data["phone"])
		role = common.ObjToString(data["companyType"])
		industry = common.ObjToString(data["industry"])
		department = common.ObjToString(data["branch"])
		departments = common.ObjToString(data["department"])
		position = common.ObjToString(data["position"])
		name = common.ObjToString(data["name"])
		sourceCode = common.ObjToString(data["source"])
		keywordArr := data["keyword"]
		if keywordArr != nil {
			keyword = common.ObjArrToStringArr(data["keyword"].([]interface{}))
		}
		contactsData := TiDb.SelectBySql("select * from dwd_f_userbase_contacts where phone = ? and is_delete = 1", phone)
		if contactsData != nil && len(*contactsData) > 0 {
			if common.ObjToString((*contactsData)[0]["baseinfo_id"]) != "" {
				uId = common.ObjToString((*contactsData)[0]["baseinfo_id"])
				query["uid"] = uId
			} else {
				query["userid"] = userId
			}
		} else {
			query["userid"] = userId
		}
		userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
		if userInfo != nil && len(*userInfo) > 0 {
			uId = common.ObjToString((*userInfo)["uid"])
			source = common.IntAll((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
			userId = common.ObjToString((*userInfo)["userid"])
		}
	} else if item == "eventReg" {
		userId = common.ObjToString(data["userid"])
		cluename = common.ObjToString(data["company"])
		phone = common.ObjToString(data["sign_phone"])
		role = common.ObjToString(data["company_type"])
		department = common.ObjToString(data["branch"])
		position = common.ObjToString(data["position"])
		name = common.ObjToString(data["sign_name"])
		sourceCode = common.ObjToString(data["source_code"])
		sourceName = common.ObjToString(data["source_name"])
		contactsData := TiDb.SelectBySql("select * from dwd_f_userbase_contacts where phone = ? and is_delete = 1", phone)
		if contactsData != nil && len(*contactsData) > 0 {
			if common.ObjToString((*contactsData)[0]["baseinfo_id"]) != "" {
				uId = common.ObjToString((*contactsData)[0]["baseinfo_id"])
				query["uid"] = uId
			} else {
				query["userid"] = userId
			}
		} else {
			query["userid"] = userId
		}
		userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
		if userInfo != nil && len(*userInfo) > 0 {
			uId = common.ObjToString((*userInfo)["uid"])
			source = common.IntAll((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
			userId = common.ObjToString((*userInfo)["userid"])
		}
		if role == "集成商" || role == "设计院" {
			role = "其他-" + role
		}
	}
	//线索名称为空用手机号代替
	if cluename == "" && item != "message" {
		cluename = phone
	}
	//域外用户和内部用户和没有手机号，不存线索
	if source == 2 || strings.HasPrefix(belong_to, "02") || source == 6 || source == 11 || phone == "" {
		log.Println("线索分配失败，线索过滤！！", item, source, phone, userId)
		if strings.HasPrefix(belong_to, "02") && item == "eventReg" {
			saveMap := map[string]interface{}{
				"unique_id":      phone,
				"phone":          phone,
				"username":       name,
				"source":         sourceName,
				"status999":      "status5",
				"company":        cluename,
				"job":            position,
				"belongTo":       "市场部",
				"createTime":     nowTime,
				"lastUpdateTime": nowTime,
			}
			token := getToken()
			updateData := map[string]interface{}{
				"dbType":       "0001",
				"customerList": []map[string]interface{}{saveMap},
			}
			dataByte, _ := json.Marshal(&updateData)
			url := `https://a1.7x24cc.com/commonInte?flag=1007&account=N000000029739&accessToken=` + token + `&json=` + url.QueryEscape(string(dataByte))
			bs, err := doGet(url)
			if err != nil {
				log.Println("调用接口失败")
			} else {
				resMap := common.StringToMap(string(bs))
				if resMap["success"] != nil && resMap["success"].(bool) {
					TiDbData.Insert("customer", saveMap)
				} else {
					log.Println("新增线索失败")
				}
			}
		}
		return true, false
	}
	if uId == "" {
		if isExists, _ := redis.Exists("bidx", "bidx_userId_"+userId); isExists {
			redisInt := redis.GetInt("bidx", "bidx_userId_"+userId)
			if redisInt > 4 {
				log.Println("线索分配失败，线索缺少信息，任务已执行超过1次", item, userId, phone)
				return true, true
			} else {
				redis.Incr("bidx", "bidx_userId_"+userId)
			}
		} else {
			redis.Put("bidx", "bidx_userId_"+userId, 1, 3600)
		}
		log.Println("线索分配失败，线索缺少信息", item, phone, userId)
		return false, false
	}
	//不是留资的要查一遍留资
	if item == "orders" {
		qid := positionId
		if qid == "" {
			qid = userId
		}
		saleLeadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"userid": qid}, map[string]interface{}{"_id": -1}, nil, false, 0, 1)
		if ok && saleLeadsData != nil && len(*saleLeadsData) > 0 {
			sdata := (*saleLeadsData)[0]
			role = common.ObjToString(sdata["companyType"])
			industry = common.ObjToString(sdata["industry"])
			department = common.ObjToString(sdata["branch"])
			departments = common.ObjToString(sdata["department"])
			position = common.ObjToString(sdata["position"])
			name = common.ObjToString(sdata["name"])
		}
	}

	//top_cluetype
	top_cluetype, sub_cluetype, level, topname, subname = getClueType(item, data, sourceCode)
	//
	if topname == "市场活动" && item == "saleLeads" {
		log.Println("市场活动留资过滤 ", userId, phone)
		return true, false
	}
	if strings.HasPrefix(belong_to, "03") {
		isOk := saveEverything(userId, phone, item, subname, sourceCode)
		log.Println("渠道线索电销", userId, phone, item, subname, sourceCode)
		if !isOk {
			return true, false
		}
	}
	//
	//follow_project_area --> follow_project_monitor
	follow_project_area = getAreaCode(userId)
	//seatNumber position_id
	log.Println("data +++", top_cluetype, sub_cluetype, level, follow_project_area)
	if top_cluetype == "" || sub_cluetype == "" || level == "" {
		log.Println("线索分配失败，线索过滤top_cluetype！！", item, uId, phone, userId)
		return true, true
	}
	position_id, seatNumber, saleName, saleData := autoDraw(level)
	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 {
			batch_import := common.ObjToString((*uCount)["batch_import"])
			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, position_id, source, sourceCode, keyword, belong_to)
		} 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, keyword, belong_to)
		}
		if oks {
			TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where seatNumber = ? and clue_level = ?`, seatNumber, level)
		} else {
			log.Println("线索分配失败!!", item, position_id, seatNumber, uId, userId, phone)
			return false, false
		}
	}
	return true, true
}

func SaveClue(item, userId, uId, top_cluetype, sub_cluetype, topname, subname, cluename, name, saleName, phone, position, department, departments, industry, follow_project_area, role, seatNumber string, positionId int64, source int, sourceCode string, keyword []string, belong_to string) 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")
	//
	if strings.HasPrefix(belong_to, "03") {
		return false
	}
	//
	clueId, uodateId1, uodateId2, uodateId3, uodateId4, uodateId5, uodateId6 := int64(0), int64(0), int64(0), int64(0), int64(0), int64(0), int64(0)
	// BCPCID := common.GetRandom(32)
	if TiDb.ExecTx("保存线索", func(tx *sql.Tx) bool {
		keywords := ""
		if sourceCode == "app_xzcyh" {
			if len(keyword) > 0 && keyword[0] != "" {
				keywords = strings.Join(keyword, ",")
			}
		}
		if cluename == "" {
			cluename = phone
		}
		//线索
		clueId = TiDb.InsertByTx(tx, "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":         top_cluetype,
			"sub_cluetype":         sub_cluetype,
			"trailstatus":          "01",
			"name":                 name,
			"phone":                phone,
			"position":             position,
			"department":           common.If(sourceCode == "app_xzcyh", departments, department),
			"industry":             industry,
			"follow_project_area":  follow_project_area,
			"role":                 role,
			"comeinsource_private": 2,
			"is_task":              1,
			"task_time":            nowTime,
			"tasktime":             common.If(item == "users", nowTimes, nowTime),
			"taskstatus":           0,
			"tasksource":           "线索自动分配" + "-" + topname + "-" + subname,
			"business_scope":       common.If(sourceCode == "app_xzcyh", keywords, nil),
		})
		//变更记录
		uodateId1 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":     clueId,
			"position_id": positionId,
			"change_type": "创建线索",
			"new_value":   "系统自动创建",
			"createtime":  nowTime,
			"BCPCID":      common.GetRandom(32),
			"operator_id": -1,
		})
		uodateId2 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":      clueId,
			"position_id":  positionId,
			"change_field": "position_id",
			"change_type":  "所属人变更",
			"old_value":    "/",
			"new_value":    saleName,
			"createtime":   nowTime,
			"BCPCID":       common.GetRandom(32),
			"operator_id":  -1,
		})
		uodateId3 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":      clueId,
			"position_id":  positionId,
			"change_field": "trailstatus",
			"change_type":  "基本信息变更",
			"old_value":    "商机线索",
			"new_value":    "新增",
			"createtime":   nowTime,
			"BCPCID":       common.GetRandom(32),
			"operator_id":  -1,
		})
		uodateId4 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":     clueId,
			"position_id": positionId,
			"change_type": "加入任务车",
			"new_value":   "线索自动分配" + "-" + topname + "-" + subname,
			"createtime":  nowTime,
			"BCPCID":      common.GetRandom(32),
			"operator_id": -1,
		})
		uodateId5 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":      clueId,
			"position_id":  positionId,
			"change_field": "top_cluetype",
			"change_type":  "基本信息变更",
			"old_value":    "/",
			"new_value":    topname,
			"createtime":   nowTime,
			"BCPCID":       common.GetRandom(32),
			"operator_id":  -1,
		})
		uodateId6 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
			"clue_id":      clueId,
			"position_id":  positionId,
			"change_field": "sub_cluetype",
			"change_type":  "基本信息变更",
			"old_value":    "/",
			"new_value":    subname,
			"createtime":   nowTime,
			"BCPCID":       common.GetRandom(32),
			"operator_id":  -1,
		})
		return clueId > -1 && uodateId1 > -1 && uodateId2 > -1 && uodateId3 > -1 && uodateId4 > -1 && uodateId5 > -1 && uodateId6 > -1
	}) {
		log.Println("线索分配成功")
		if TiDb.Count("dwd_f_userbase_contacts", map[string]interface{}{"phone": phone}) == 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,
			})
		}
		return true
	} else {
		log.Println("线索分配失败！！！", clueId, uodateId1, uodateId2, uodateId3, uodateId4, uodateId5, uodateId6, " 用户信息 ", item, position, seatNumber, uId, userId, phone)
		return false
	}
}

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 string, positionId int64, source int, sourceCode string, keyword []string, belong_to string) 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"])
	trailstatusTime := common.ObjToString(data["trailstatus_time"])
	var trailstatusTimes time.Time
	if trailstatusTime != "" {
		trailstatusTimes, _ = time.ParseInLocation(date.Date_Full_Layout, trailstatusTime, time.Local)
	}
	clueId := common.Int64All(data["id"])
	is_assign := common.IntAll(data["is_assign"])
	oldsaleName, oldTaskTime, taskTime, is_task, taskstatus := "", "", "", 0, 0
	old_position_id, old_seatNumber := common.Int64All(data["position_id"]), common.ObjToString(data["seatNumber"])
	oldTaskTime = common.ObjToString(data["tasktime"])
	is_task = common.IntAll(data["is_task"])
	taskstatus = common.IntAll(data["taskstatus"])
	BCPCID := common.GetRandom(32)
	old_name := common.ObjToString(data["name"])
	old_position := common.ObjToString(data["position"])
	old_department := common.ObjToString(data["department"])
	old_follow_project_area := common.ObjToString(data["follow_project_area"])
	old_role := common.ObjToString(data["role"])
	old_cluename := common.ObjToString(data["cluename"])
	old_top_cluetype := common.ObjToString(data["top_cluetype"])
	old_sub_cluetype := common.ObjToString(data["sub_cluetype"])
	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))
	} else {
		if is_task == 1 {
			if oldTaskTime != "" {
				t1, err := time.Parse("2006-01-02 15:04:05", oldTaskTime)
				if err == nil && time.Now().Before(t1) {
					taskTime = nowTime
				} else {
					taskTime = oldTaskTime
				}
			}
		}
	}
	//加入任务车判断节假日
	count, counts, t := 0, 0, time.Now()
	for {
		count++
		currentTime := t.AddDate(0, 0, -count)
		if currentTime.Weekday() == time.Sunday || currentTime.Weekday() == time.Saturday {
			isok := false
			for k, v := range DateMap {
				if currentTime.Format(date.Date_Short_Layout) == k && v == 2 {
					isok = true
				}
			}
			if isok {
				counts++
			}
		} else {
			isok := true
			for k, v := range DateMap {
				if currentTime.Format(date.Date_Short_Layout) == k && v == 1 {
					isok = false
				}
			}
			if isok {
				counts++
			}
		}
		if counts >= 2 {
			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{}{
		"updatetime":           nowTime,
		"top_cluetype":         top_cluetype,
		"sub_cluetype":         sub_cluetype,
		"userid":               userId,
		"comeinsource_private": 2,
		"tasksource":           "线索来源自动更新" + "-" + topname + "-" + subname,
	}
	if cluename != "" {
		clueUpdateData["cluename"] = cluename
	}
	if item != "orders" && item != "users" {
		if name != "" {
			clueUpdateData["name"] = name
		}
		if position != "" {
			clueUpdateData["position"] = position
		}
		if department != "" {
			clueUpdateData["department"] = department
		}
		if follow_project_area != "" {
			clueUpdateData["follow_project_area"] = follow_project_area
		}
		if role != "" {
			clueUpdateData["role"] = role
		}
		// clueUpdateData["industry"] = industry
	}
	if sourceCode == "app_xzcyh" {
		if departments != "" {
			clueUpdateData["department"] = departments
			department = departments
		}
		business_scope := common.ObjToString(data["business_scope"])
		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
			}
		}
	}
	if trailstatus == "00" || old_position_id == 0 || is_assign != 1 {
		if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
		} else {
			clueUpdateData["seatNumber"] = seatNumber
			clueUpdateData["position_id"] = positionId
			clueUpdateData["comeintime"] = nowTime
			clueUpdateData["is_assign"] = 1
			clueUpdateData["comeinsource_open"] = nil
			clueUpdateData["level_open"] = nil
			clueUpdateData["clue_level"] = nil
			for _, v := range saleData {
				if common.ObjToString(data["seatNumber"]) == common.ObjToString(v["seatNumber"]) {
					oldsaleName = common.ObjToString(v["name"])
				}
			}
		}
	} else {
		clueUpdateData["seatNumber"] = old_seatNumber
		clueUpdateData["position_id"] = old_position_id
		clueUpdateData["is_assign"] = 1
		clueUpdateData["comeinsource_open"] = nil
		clueUpdateData["level_open"] = nil
		clueUpdateData["clue_level"] = nil
	}
	if trailstatus != "08" && is_assign == 0 {
		if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
		} else {
			clueUpdateData["trailstatus"] = "01"
			clueUpdateData["trailstatus_time"] = nowTime
		}
	}
	is_ok := false
	if (trailstatus != "08" && recordCount <= 0) || is_assign == 0 {
		if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
		} else {
			if item == "eventReg" {
				eData := TiDb.Find("dwd_f_crm_clue_change_record", map[string]interface{}{"clue_id": clueId, "change_type": "加入任务车"}, "", "", -1, -1)
				if eData != nil && len(*eData) > 0 {
					for _, e := range *eData {
						new_value := common.ObjToString(e["new_value"])
						if strings.Contains(new_value, subname) {
							is_ok = true
						}
					}
				}
				if !is_ok {
					if old_sub_cluetype != sub_cluetype || is_assign == 0 {
						if taskTime == "" {
							taskTime = nowTime
						}
						clueUpdateData["task_time"] = nowTime
						clueUpdateData["tasktime"] = taskTime
						clueUpdateData["taskstatus"] = 0
					}
					if is_transfer != 1 {
						clueUpdateData["is_task"] = 1
					}
				}
			} else {
				if old_sub_cluetype != sub_cluetype || is_assign == 0 {
					if taskTime == "" {
						taskTime = nowTime
					}
					clueUpdateData["task_time"] = nowTime
					clueUpdateData["tasktime"] = taskTime
					clueUpdateData["taskstatus"] = 0
				}
				if is_transfer != 1 {
					clueUpdateData["is_task"] = 1
				}
			}
		}
	}
	ok, updateId14 := true, true
	updateId1, updateId2, updateId3, updateId4, updateId5 := int64(0), int64(0), int64(0), int64(0), int64(0)
	updateId6, updateId7, updateId8, updateId9, updateId10 := int64(0), int64(0), int64(0), int64(0), int64(0)
	updateId11, updateId12, updateId13 := int64(0), int64(0), int64(0)
	if TiDb.ExecTx("更新线索", func(tx *sql.Tx) bool {
		//线索
		ok = TiDb.UpdateByTx(tx, "dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, clueUpdateData)
		//变更记录
		if (trailstatus == "00" || old_position_id == 0) && is_assign == 1 {
			if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
			} else if old_position_id == 0 {
				updateId1 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "position_id",
					"change_type":  "所属人变更",
					"old_value":    common.If(oldsaleName != "", oldsaleName, "/"),
					"new_value":    common.If(saleName != "", saleName, "/"),
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				updateId3 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "trailstatus",
					"change_type":  "基本信息变更",
					"old_value":    CodeTrail[trailstatus],
					"new_value":    "新增",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
			} else {
				updateId1 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "position_id",
					"change_type":  "所属人变更",
					"old_value":    common.If(oldsaleName != "", oldsaleName, "/"),
					"new_value":    common.If(saleName != "", saleName, "/"),
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				updateId2 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.Int64All(data["position_id"]),
					"change_field": "trailstatus",
					"change_type":  "基本信息变更",
					"old_value":    "无意向客户",
					"new_value":    "流失",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				updateId3 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "trailstatus",
					"change_type":  "基本信息变更",
					"old_value":    "商机线索",
					"new_value":    "新增",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				updateId4 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "trailstatus",
					"change_type":  "基本信息变更",
					"old_value":    "无意向客户",
					"new_value":    "商机线索",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
			}
		} else if trailstatus != "08" && is_assign == 0 {
			if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
			} else {
				updateId1 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "position_id",
					"change_type":  "所属人变更",
					"old_value":    common.If(oldsaleName != "", oldsaleName, "/"),
					"new_value":    common.If(saleName != "", saleName, "/"),
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				if trailstatus != "01" {
					updateId4 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
						"clue_id":      clueId,
						"position_id":  positionId,
						"change_field": "trailstatus",
						"change_type":  "基本信息变更",
						"old_value":    CodeTrail[trailstatus],
						"new_value":    "商机线索",
						"createtime":   nowTime,
						"BCPCID":       common.GetRandom(32),
						"operator_id":  -1,
					})
				}
				updateId3 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  positionId,
					"change_field": "trailstatus",
					"change_type":  "基本信息变更",
					"old_value":    "商机线索",
					"new_value":    "新增",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
			}
		}
		if (trailstatus != "08" && recordCount <= 0) || is_assign == 0 {
			if trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400 {
			} else {
				if old_sub_cluetype != sub_cluetype && !is_ok {
					if is_transfer != 1 {
						updateId5 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
							"clue_id":     clueId,
							"position_id": common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"])),
							"change_type": "加入任务车",
							"new_value":   "线索来源自动更新" + "-" + topname + "-" + subname,
							"createtime":  nowTime,
							"BCPCID":      common.GetRandom(32),
							"operator_id": -1,
						})
					} else {
						cdata := TiDb.FindOne("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, "", "")
						if cdata != nil && len(*cdata) > 0 {
							kcpositionId := common.Int64All((*cdata)["position_id"])
							tasksource := common.ObjToString((*cdata)["tasksource"])
							taskstatus := common.IntAll((*cdata)["taskstatus"])
							updateId5 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
								"clue_id":     clueId,
								"position_id": kcpositionId,
								"change_type": "加入任务车",
								"new_value":   "线上主动留资",
								"createtime":  nowTime,
								"BCPCID":      common.GetRandom(32),
								"operator_id": -1,
							})
							if taskstatus == 1 {
								tasksource = "10"
							} else {
								if tasksource != "" && !strings.Contains(tasksource, "10") {
									if !strings.Contains(tasksource, "10") {
										tasksource += ",10"
									}
								} else {
									tasksource = "10"
								}
							}
							updateId14 = TiDb.UpdateByTx(tx, "dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
								"tasksource": tasksource,
								"tasktime":   nowTime,
								"is_task":    1,
								"taskstatus": 0,
							})
						}
					}
				}
			}
		}
		if old_top_cluetype != "" {
			pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": old_top_cluetype}, "", "")
			if pcodeData != nil && len(*pcodeData) > 0 {
				old_topname = common.ObjToString((*pcodeData)["name"])
			}
		}
		if old_sub_cluetype != "" {
			pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": old_sub_cluetype}, "", "")
			if pcodeData != nil && len(*pcodeData) > 0 {
				old_subname = common.ObjToString((*pcodeData)["name"])
			}
		}
		if item != "orders" {
			if old_name != name && name != "" {
				updateId6 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "name",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_name != "", old_name, "/"),
					"new_value":    common.If(name != "", name, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
			if old_position != position && position != "" {
				updateId7 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "position",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_position != "", old_position, "/"),
					"new_value":    common.If(position != "", position, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
			if old_department != department && department != "" {
				updateId8 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "department",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_department != "", old_department, "/"),
					"new_value":    common.If(department != "", department, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
			if old_role != role && role != "" {
				updateId9 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "role",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_role != "", old_role, "/"),
					"new_value":    common.If(role != "", role, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
			if old_follow_project_area != follow_project_area && follow_project_area != "" {
				old_area, old_area_arr := "", []string{}
				new_area, new_area_arr := "", []string{}
				for _, v := range strings.Split(old_follow_project_area, ",") {
					old_area_arr = append(old_area_arr, CodeArea[v])
				}
				for _, v := range strings.Split(follow_project_area, ",") {
					new_area_arr = append(new_area_arr, CodeArea[v])
				}
				old_area = strings.Join(old_area_arr, ",")
				new_area = strings.Join(new_area_arr, ",")
				updateId10 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "follow_project_area",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_area != "", old_area, "/"),
					"new_value":    common.If(new_area != "", new_area, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
			if old_cluename != cluename && cluename != "" {
				updateId11 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
					"clue_id":      clueId,
					"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
					"change_field": "cluename",
					"change_type":  "基本信息变更",
					"old_value":    common.If(old_cluename != "", old_cluename, "/"),
					"new_value":    common.If(cluename != "", cluename, "/"),
					"createtime":   nowTime,
					"BCPCID":       BCPCID,
					"operator_id":  -1,
				})
			}
		}
		if old_top_cluetype != top_cluetype {
			updateId12 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
				"clue_id":      clueId,
				"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
				"change_field": "top_cluetype",
				"change_type":  "基本信息变更",
				"old_value":    common.If(old_topname != "", old_topname, "/"),
				"new_value":    common.If(topname != "", topname, "/"),
				"createtime":   nowTime,
				"BCPCID":       BCPCID,
				"operator_id":  -1,
			})
		}
		if old_sub_cluetype != sub_cluetype {
			updateId13 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
				"clue_id":      clueId,
				"position_id":  common.If(trailstatus == "00" && trailstatusTime != "" && time.Now().Unix()-trailstatusTimes.Unix() < 86400, -1, common.If(trailstatus == "00" || is_assign == 0, positionId, common.Int64All(data["position_id"]))),
				"change_field": "sub_cluetype",
				"change_type":  "基本信息变更",
				"old_value":    common.If(old_subname != "", old_subname, "/"),
				"new_value":    common.If(subname != "", subname, "/"),
				"createtime":   nowTime,
				"BCPCID":       BCPCID,
				"operator_id":  -1,
			})
		}
		return ok && updateId1 > -1 && updateId2 > -1 && updateId3 > -1 && updateId4 > -1 && updateId5 > -1 && updateId6 > -1 && updateId7 > -1 && updateId8 > -1 && updateId9 > -1 && updateId10 > -1 && updateId11 > -1 && updateId12 > -1 && updateId13 > -1 && updateId14
	}) {
		log.Println("线索更新成功")
		if TiDb.Count("dwd_f_userbase_contacts", map[string]interface{}{"phone": phone}) == 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,
			})
		}
		return true
	} else {
		log.Println("线索更新失败！！！", ok, updateId1, updateId2, updateId3, updateId4, updateId5, updateId6, updateId7, updateId8, updateId9, updateId10, updateId11, updateId12, updateId13, updateId14, " 用户信息 ", item, position, seatNumber, uId, userId, phone)
		return false
	}
}

func getAreaCode(userId string) (code string) {
	followData := Base.Find("follow_project_monitor", map[string]interface{}{"s_userid": userId}, "", "", -1, -1)
	sidArr := []string{}
	if followData != nil && len(*followData) > 0 {
		for _, v := range *followData {
			infoId := common.ObjToString(v["s_id"])
			sidArr = append(sidArr, infoId)
		}
	}
	if len(sidArr) > 0 {
		query := `{"query": {"bool": {"must": [{"terms": {"_id": ["%s"]}}],"must_not": [],"should": []}}}`
		query = fmt.Sprintf(query, strings.Join(sidArr, `","`))
		biddingData := Es.Get("bidding", "bidding", query)
		if biddingData != nil && len(*biddingData) > 0 {
			codeMap := map[string]string{}
			codeArr := []string{}
			for _, v := range *biddingData {
				area := common.ObjToString(v["area"])
				address := common.ObjToString(v["city"])
				if address == "" {
					address = area
				}
				codeMap[address] = AreaCode[address]
			}
			if len(codeMap) > 0 {
				for _, v := range codeMap {
					codeArr = append(codeArr, v)
				}
			}
			if len(codeArr) > 0 {
				code = strings.Join(codeArr, ",")
			}
		}
	}
	log.Println("code ", code)
	return
}

func getClueType(item string, data map[string]interface{}, sourceCode string) (pcode, code, level, topname, subname string) {
	if item == "orders" {
		productType := common.ObjToString(data["product_type"])
		pcode = "1"
		level = "A"
		topname = "提交订单未支付"
		if productType == "VIP订阅" {
			code = "6"
			subname = "超级订阅"
		} else if productType == "大会员" {
			code = "7"
			subname = "大会员"
		} else if productType == "数据流量包" {
			code = "8"
			subname = "数据流量包"
		} else if productType == "历史数据" {
			code = "9"
			subname = "数据自助导出"
		}
	} else if item == "users" {
		pcode = "4"
		code = "154"
		level = "C"
		topname = "新增注册"
		subname = "新增注册用户"
	} else if item == "message" {
		pcode = "532"
		code = "477"
		level = "B"
		topname = "其他"
		subname = "机器人客服主动咨询"
	} else {
		if sourceCode != "" {
			codeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"source": sourceCode}, "", "")
			if codeData != nil && len(*codeData) > 0 {
				pcode = common.ObjToString((*codeData)["pcode"])
				code = common.ObjToString((*codeData)["code"])
				level = common.ObjToString((*codeData)["clue_level"])
				subname = common.ObjToString((*codeData)["name"])
				pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": pcode}, "", "")
				if pcodeData != nil && len(*pcodeData) > 0 {
					topname = common.ObjToString((*pcodeData)["name"])
				}
			}
		}
	}
	return
}

// 获取自动分配的人
func autoDraw(mode string) (positionId int64, seatNumber, saleName string, saleData []map[string]interface{}) {
	query := `select * from jy_salesperson_info where`
	if mode == "A" || mode == "B" {
		query += ` is_complete = 1`
	} else {
		query += ` is_complete = 1 or is_complete = 0`
	}
	data := TiDb.SelectBySql(query)
	if data != nil && len(*data) > 0 {
		saleData = *data
		sql := "select * from dwd_f_crm_clue_autodraw_record where clue_level = ?"
		countData := TiDb.SelectBySql(sql, mode)
		if countData != nil && len(*countData) > 0 {
			for _, v := range *data {
				//判断是否有新员工
				isOk := false
				for _, vv := range *countData {
					if common.ObjToString(v["seatNumber"]) == common.ObjToString(vv["seatNumber"]) {
						if common.IntAll(v["status"]) == 0 {
							vv["status"] = 1
						} else {
							vv["status"] = 2
						}
						isOk = true
					}
				}
				//有新员工直接分给新员工
				if !isOk {
					seatNumber = common.ObjToString(v["seatNumber"])
					saleName = common.ObjToString(v["name"])
					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"]),
					})
					break
				}
			}
			if seatNumber == "" {
				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"])
						} else {
							if common.Int64All(v["count"]) <= res {
								res = common.Int64All(v["count"])
								seatNumber = common.ObjToString(v["seatNumber"])
							}
						}
						countres++
					}
					// if k == 0 {
					// 	res = common.Int64All(v["count"])
					// 	seatNumber = common.ObjToString(v["seatNumber"])
					// } else {
					// 	if common.Int64All(v["count"]) <= res {
					// 		res = common.Int64All(v["count"])
					// 		seatNumber = common.ObjToString(v["seatNumber"])
					// 	}
					// }
				}
			}
		} else {
			seatNumber = common.ObjToString((*data)[0]["seatNumber"])
			saleName = common.ObjToString((*data)[0]["name"])
			rData := TiDb.FindOne("dwd_f_crm_clue_autodraw_record", map[string]interface{}{"clue_level": mode}, "", "count asc")
			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"]),
				})
			} else {
				TiDb.Insert("dwd_f_crm_clue_autodraw_record", map[string]interface{}{
					"seatNumber": seatNumber,
					"clue_level": mode,
					"count":      0,
				})
			}
		}
		for _, v := range *data {
			if seatNumber == common.ObjToString(v["seatNumber"]) {
				positionId = getPositionId(common.ObjToString(v["phone"]))
				saleName = common.ObjToString(v["name"])
			}
		}
		// if positionId > 0 {
		// 	TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where seatNumber = ? and clue_level = ?`, seatNumber, mode)
		// }
	}
	return
}

func getPositionId(phone string) (positionId int64) {
	userData, ok := Mgo.FindOne("user", map[string]interface{}{"s_phone": phone})
	if ok && userData != nil && len(*userData) > 0 {
		userId := common.Int64All((*userData)["base_user_id"])
		positionData := Base.FindOne("base_position", map[string]interface{}{"type": 1, "ent_id": 25917, "user_id": userId}, "", "") //TODO ent_id
		if positionData != nil && len(*positionData) > 0 {
			positionId = common.Int64All((*positionData)["id"])
		}
	}
	return
}