datatools/clueSync/job.go

package main

import (
	"database/sql"
	"fmt"
	"log"
	"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() {
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	//新用户注册后5分钟内进入线索 C
	log.Println("新注册用户定时任务开始")
	selectTimeEnd := cfg.LastUserId
	sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and source = "0101" and status != 2`, 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("新注册用户定时任务结束")
}

// 留资 5分钟一次
func saleLeads() {
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		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)}
	}
	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"])
	}
	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"]), "", "", "", "", "", "", []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.ObjToString((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
		}
		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.ObjToString((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
			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.ObjToString((*userInfo)["source"])
				belong_to = common.ObjToString((*userInfo)["belong_to"])
			}
		}
	} 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.ObjToString((*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.ObjToString((*userInfo)["source"])
			belong_to = common.ObjToString((*userInfo)["belong_to"])
			userId = common.ObjToString((*userInfo)["userid"])
		}
		if role == "集成商" || role == "设计院" {
			role = "其他-" + role
		}
	}
	if cluename == "" && item != "message" && item != "orders" {
		cluename = 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 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, 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 = getAreaCode(userId) //关注项目区域
	log.Println("data +++", top_cluetype, sub_cluetype, level, follow_project_area, isGroup, isCommerce)
	if top_cluetype == "" || sub_cluetype == "" || level == "" {
		log.Println("线索分配失败，线索过滤top_cluetype！！", item, uId, phone, userId)
		return true, true
	}
	position_id, seatNumber, saleName, saleData, pIsOk := autoDraw(level, cluename, isGroup, isCommerce)
	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, isGroup, isCommerce, pIsOk)
		} 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, 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 {
			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, sourceCode string, keyword []string, belong_to string, isGroup, isCommerce int) 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")
	clueId, uodateId1, uodateId2, uodateId3, uodateId4, uodateId5, uodateId6 := int64(0), int64(0), int64(0), int64(0), int64(0), int64(0), int64(0)
	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),
			"company_nature":       isGroup,
			"company_verification": isCommerce,
		})
		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, sourceCode 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"])
	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,
		"company_nature":       isGroup,
		"company_verification": isCommerce,
	}
	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 || pIsOk {
		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["seat_number"]) {
					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 || pIsOk) && 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
	}
}