datatools/clueSync/jobutil.go

package main

import (
	"app.yhyue.com/moapp/jybase/mail"
	"app.yhyue.com/moapp/jybase/redis"
	"fmt"
	"github.com/tealeg/xlsx"
	"log"
	"math"
	"strings"
	"time"

	"github.com/gogf/gf/v2/util/gconv"

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

// 电销工单生成
func rderAcceptance() {
	sql := fmt.Sprintf(`select * from order_acceptance where is_clue=2 and  is_delete=1 order by propose_time  `)
	//sql := fmt.Sprintf(`select * from order_acceptance where is_clue=2 and  is_delete=1 and  id  = 333  order by propose_time  `)
	data := WorkOrder.SelectBySql(sql)
	if data != nil && len(*data) > 0 {
		for _, v := range *data {
			acceptance_no := gconv.String(v["acceptance_no"])
			childrenArr := WorkOrder.Find("order_acceptance_children", map[string]interface{}{
				"acceptance_no": acceptance_no,
			}, "", "", -1, -1)
			if childrenArr != nil && len(*childrenArr) > 0 {
				company := ""
				phone := ""
				demand := ""
				name := ""
				product := ""
				for _, v1 := range *childrenArr {
					if gconv.String(v1["field_name"]) == "公司名称" {
						company = gconv.String(v1["field_value"])
					}
					if gconv.String(v1["field_name"]) == "联系方式num" {
						phone = gconv.String(v1["field_value"])
					}
					if gconv.String(v1["field_name"]) == "客户姓名" {
						name = gconv.String(v1["field_value"])
					}
					if gconv.String(v1["field_name"]) == "客户需求" {
						demand = gconv.String(v1["field_value"])
					}
					if gconv.String(v1["field_name"]) == "咨询产品" {
						product = gconv.String(v1["field_value"])
					}
				}
				if !WorkDataHandle(company, phone, demand, name, product, v) {
					log.Println("工单创建失败")
				}
			}
		}
	}
}
func WorkDataHandle(company, phone, demand, name, product string, acceptanceData map[string]interface{}) bool {
	uId := ""
	query := map[string]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
		}
	}
	if uId == "" {
		log.Println("用户信息不存在")
		return false
	}
	cluename := company
	if cluename == "" {
		cluename = phone //没有线索名，手机号代替
	}
	ok, data, saleData, isNewScore := false, map[string]interface{}{}, []map[string]interface{}{}, false
	isGroup, isCommerce := GetCompanyType(cluename, uId)
	uCount, _ := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", ""), true //查当前线索是否已存在
	if uCount != nil && len(*uCount) > 0 {
		isUpdate := gconv.Int64((*uCount)["is_artificially_modified"])
		if isUpdate == 1 {
			cluename = ""
		}
		clueId := gconv.Int64((*uCount)["id"])
		positionId := gconv.Int64((*uCount)["position_id"])
		trailstatus := gconv.String((*uCount)["trailstatus"])
		IS_TRANSFER := gconv.Int64((*uCount)["IS_TRANSFER"])
		if IS_TRANSFER == 1 {
			//客成处理
			//客成
			//生成客成数据
			customerMap := TiDb.FindOne("dwd_f_csm_customer_info", map[string]interface{}{
				"clue_id": clueId,
			}, "position_id,name", "")
			if customerMap != nil && len(*customerMap) > 0 {
				//UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", company, name, gconv.String((*uCount)["name"]), phone, "", "", "", "", "", "", gconv.String((*uCount)["seat_number"]), "", gconv.Int64((*uCount)["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, false, demand)
				WorkUpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", cluename, name, gconv.String((*uCount)["name"]), phone, "", "", "", "", "", "", gconv.String((*uCount)["seat_number"]), "", gconv.Int64((*uCount)["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, false, demand)
				data = map[string]interface{}{
					"type":        "kc",
					"position_id": (*customerMap)["position_id"],
					"name":        (*customerMap)["name"],
				}
			} else {
				log.Println("查询不到客成数据", clueId, uId)
				return false
			}
			TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
				"clue_id":     clueId,
				"position_id": (*customerMap)["position_id"],
				"change_type": "加入任务车",
				"new_value":   "咨询客服转客成",
				"createtime":  time.Now().Format(date.Date_Full_Layout),
				"BCPCID":      common.GetRandom(32),
				"operator_id": -1,
			})
		} else {
			if positionId == 0 {
				//线索变更
				isNewScore = true
				ok, data, saleData = FindPosition(0, "", gconv.String(acceptanceData["creator_time"]))
				if !ok {
					log.Println(positionId, "用户查询失败")
					return false
				}
				WorkUpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", cluename, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
			} else {
				ok, data, saleData = FindPosition(positionId, trailstatus, gconv.String(acceptanceData["creator_time"]))
				if !ok {
					log.Println(positionId, "用户查询失败")
					return false
				}
				if gconv.Int64(data["position_id"]) == positionId {
					WorkUpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", cluename, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, false, demand)
				} else {
					WorkUpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", cluename, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
				}

			}
		}
	} else {
		//新增线索
		ok, data, _ = FindPosition(0, "", gconv.String(acceptanceData["creator_time"]))
		if !ok {
			return false
		}
		isNewScore = true
		SaveClue("", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", cluename, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, false, demand)
	}
	//工单生成
	ok1 := AddOrderWork(acceptanceData, data, product, phone, company, isNewScore)
	log.Println("工单创建", ok1, gconv.String(acceptanceData["acceptance_no"]))
	return true
}
func AddOrderWork(acceptanceData map[string]interface{}, userData map[string]interface{}, product, phone, company string, isNewScore bool) bool {
	time.Sleep(time.Second * 1)
	nowTime := time.Now().Format(date.Date_Full_Layout)
	work_order_no := fmt.Sprintf("GD%s%s", time.Now().Format(date.Date_yyyyMMdd), FindNumber("gd"))
	productArr := []string{}
	for _, v := range strings.Split(product, ",") {
		switch ProductMap[v] {
		case "dk":
			continue
		default:
			productArr = append(productArr, v)
		}
	}
	two_type := "dx"
	if gconv.String(userData["type"]) == "kc" {
		two_type = "kc"
	}
	personMap := GetPerson(gconv.String(userData["position_id"]))
	if personMap == nil || len(personMap) == 0 {
		return false
	}
	orderWorkMap := map[string]interface{}{
		"work_order_no":         work_order_no,
		"acceptance_no":         gconv.String(acceptanceData["acceptance_no"]),
		"type":                  strings.Join(productArr, ","),
		"status":                common.If(gconv.Int64(userData["orderStatus"]) == 0, 2, 1),
		"initiator_name":        gconv.String(acceptanceData["creator_name"]),
		"initiator_position_id": gconv.String(acceptanceData["initiator_position_id"]),
		"current_name":          common.If(gconv.Int64(userData["orderStatus"]) == 0, nil, userData["name"]),
		"current_position_id":   common.If(gconv.Int64(userData["orderStatus"]) == 0, nil, userData["position_id"]),
		"history_name":          common.If(gconv.Int64(userData["orderStatus"]) == 0, userData["name"], nil),
		"history_postion_id":    common.If(gconv.Int64(userData["orderStatus"]) == 0, userData["position_id"], nil),
		"is_delete":             1,
		"creator_name":          gconv.String(acceptanceData["creator_name"]),
		"creator_position_id":   gconv.String(acceptanceData["creator_position_id"]),
		"creator_time":          nowTime,
		"two_type":              two_type,
		"department_no":         gconv.String(personMap["deptId"]),
		"department_name":       gconv.String(personMap["deptName"]),
		"update_time":           common.If(gconv.Int64(userData["orderStatus"]) == 0, nowTime, nil),
	}
	ok3 := WorkOrder.Insert("order_work", orderWorkMap)
	if ok3 > 0 {
		status := 2
		if WorkOrder.Count("order_work", map[string]interface{}{
			"status":        1,
			"acceptance_no": gconv.String(acceptanceData["acceptance_no"]),
		}) > 0 {
			status = 1
		}
		WorkOrder.Update("order_acceptance", map[string]interface{}{
			"id": acceptanceData["id"],
		}, map[string]interface{}{
			"is_clue":   3,
			"status":    status,
			"over_time": common.If(status == 1, nil, nowTime),
		})
		//日志添加
		approvalRecordMap := map[string]interface{}{
			"work_order_no":       work_order_no,
			"status":              common.If(gconv.Int64(userData["orderStatus"]) == 0, 3, 1),
			"new_status":          common.If(gconv.Int64(userData["orderStatus"]) == 0, 2, nil),
			"handle_name":         userData["name"],
			"handle_position_id":  userData["position_id"],
			"handle_dept_id":      gconv.String(personMap["deptId"]),
			"handle_dept_name":    gconv.String(personMap["deptName"]),
			"creator_name":        gconv.String(acceptanceData["creator_name"]),
			"creator_position_id": gconv.String(acceptanceData["initiator_position_id"]),
			"is_delete":           1,
			"creator_time":        nowTime,
			"handle_time":         common.If(gconv.Int64(userData["orderStatus"]) == 0, nowTime, nil),
			"update_name":         common.If(gconv.Int64(userData["orderStatus"]) == 0, userData["name"], nil),
			"update_position_id":  common.If(gconv.Int64(userData["orderStatus"]) == 0, userData["position_id"], nil),
			"update_time":         common.If(gconv.Int64(userData["orderStatus"]) == 0, nowTime, nil),
		}
		WorkOrder.Insert("approval_record", approvalRecordMap)
		//工单分配记录添加
		if isNewScore {
			orderWorkAllocationRecord := map[string]interface{}{
				"person_name":       userData["name"],
				"position_id":       userData["position_id"],
				"dept_name":         personMap["deptName"],
				"dept_id":           personMap["deptId"],
				"work_order_no":     work_order_no,
				"create_time":       nowTime,
				"company_dept_numb": common.If(gconv.String(personMap["deptName"]) == "销售三部", 3, 1),
				"whee_time":         cfg.AllocationTime,
			}
			WorkOrder.Insert("order_work_allocation_record", orderWorkAllocationRecord)
		}
		WorkMail(personMap,
			strings.Join(productArr, ","),
			gconv.Int64(common.If(gconv.Int64(userData["orderStatus"]) == 0, 2, 1)),
			gconv.String(personMap["name"]),
			gconv.String(acceptanceData["creator_name"]),
			nowTime,
			work_order_no,
			phone,
			company)
		return true
	}
	return false
}

// 本级以及上级管理员查询
func GetPerson(positionId string) map[string]interface{} {
	person := map[string]interface{}{}
	positionArrMap := Base.SelectBySql(fmt.Sprintf(`select  a.phone,b.id,b.ent_id from  
                         base_user  a  
                             INNER JOIN   base_position  b     
                                 on     b.id=%s  and  b.user_id=a.id and   b.type=1`,
		positionId))
	if positionArrMap == nil || len(*positionArrMap) == 0 {
		return map[string]interface{}{}
	}
	phone := gconv.String((*positionArrMap)[0]["phone"])
	entId := gconv.String((*positionArrMap)[0]["ent_id"])
	entUserArrMap := Mysql.SelectBySql(fmt.Sprintf(`SELECT
	a.name as  name,a.mail as mail,b.dept_id as  deptId,a.phone ,c.name as deptName
FROM
	entniche_user a
	INNER JOIN entniche_department_user b ON a.ent_id =%s
	AND a.phone IN %s
	and  a.id=b.user_id
	inner  join  entniche_department c  on   b.dept_id=c.id
`, entId, fmt.Sprintf("(%s)", phone)))
	//商机管理员
	if entUserArrMap == nil || len(*entUserArrMap) == 0 {
		return map[string]interface{}{}
	}
	deptId := gconv.Int64((*entUserArrMap)[0]["deptId"])
	person = map[string]interface{}{
		"name":     gconv.String((*entUserArrMap)[0]["name"]),
		"mail":     gconv.String((*entUserArrMap)[0]["mail"]),
		"phone":    gconv.String((*entUserArrMap)[0]["phone"]),
		"deptId":   gconv.String((*entUserArrMap)[0]["deptId"]),
		"deptName": gconv.String((*entUserArrMap)[0]["deptName"]),
	}
	//本部门管理员查询
	depthMap := Mysql.SelectBySql(`SELECT
		c.name as name,c.mail as  mail
		FROM
			entniche_department_user a
			INNER JOIN entniche_user_role b ON a.dept_id = ? 
			AND a.user_id = b.user_id 
			AND b.role_id !=""
			INNER JOIN entniche_user c ON a.user_id = c.id`, deptId)
	if depthMap != nil && len(*depthMap) > 0 {
		person["deptPersonName"] = gconv.String((*depthMap)[0]["name"])
		person["deptPersonMail"] = gconv.String((*depthMap)[0]["mail"])
	}
	//商机管理员查询
	superiorDepthMap := Mysql.SelectBySql(`SELECT
	c.* 
FROM
	entniche_department d
	INNER JOIN entniche_department_user a ON d.id = ? 
	AND d.pid = a.dept_id
	INNER JOIN entniche_user_role b ON a.user_id = b.user_id 
	AND b.role_id !=""
	INNER JOIN entniche_user c ON a.user_id = c.id`, deptId)
	if superiorDepthMap != nil && len(*superiorDepthMap) > 0 {
		person["superiorDepthPersonName"] = gconv.String((*superiorDepthMap)[0]["name"])
		person["superiorDepthPersonMail"] = gconv.String((*superiorDepthMap)[0]["mail"])
	}
	return person
}

// 编号查询
func FindNumber(moudle string) string {
	today := time.Now().Format("2006-01-02")
	yesterday := time.Now().AddDate(0, 0, -1).Format("2006-01-02")
	key := fmt.Sprintf("%s_%s", today, moudle)
	yesterdayKey := fmt.Sprintf("%s_%s", yesterday, moudle)
	if ok, _ := redis.Exists("newother", yesterdayKey); ok {
		//删除之前数据
		redis.Del("newother", yesterdayKey)
	}
	count := redis.Incr("newother", key)
	log.Println("编号获取", moudle, fmt.Sprintf("%04d", count))
	return fmt.Sprintf("%04d", count)
}

// 人员查询
func GetAllocation(proportion1, proportion3 float64, deptCount1, deptCount3 int64, administrators1, administrators3 map[string]interface{}) map[string]interface{} {
	log.Println("分配比例查询", cfg.AllocationTime, cfg.AllocationRatio, proportion1, proportion3, deptCount1, deptCount3)
	if deptCount1 == 0 {
		return administrators1
	}
	if deptCount3 == 0 {
		return administrators3
	}
	nowAllocationRatio := math.Round(gconv.Float64(deptCount1 / deptCount3))
	if cfg.AllocationRatio == 0 {
		//重新计算
		cfg.AllocationRatio = math.Round(proportion1 / proportion3)
		cfg.AllocationTime = time.Now().Format(date.Date_Full_Layout)
		common.WriteSysConfig(&cfg)
		log.Println("新增计算比例", cfg.AllocationRatio)
		return administrators1
	} else {
		if nowAllocationRatio == cfg.AllocationRatio {
			//重新计算
			cfg.AllocationRatio = math.Round(proportion1 / proportion3)
			cfg.AllocationTime = time.Now().Format(date.Date_Full_Layout)
			common.WriteSysConfig(&cfg)
			return administrators1
		}

	}
	if nowAllocationRatio > cfg.AllocationRatio {
		return administrators3
	} else {
		return administrators1
	}
	//达到比例也重新计算

}
func FindPosition(positionId int64, trailstatus, creatorTime string) (bool, map[string]interface{}, []map[string]interface{}) {
	allData := []map[string]interface{}{}
	//查询两个部门高级管理员
	//查询两个部门所有人员标识
	//电销三部
	userData1 := TiDb.SelectBySql(`SELECT
	a.position_id,
	a.name,
	b.seat_number,
	b.role_id,
	a.bi_pcode,
	a.dept_name
FROM
	dwd_d_crm_department_level_succbi a
	INNER JOIN dwd_f_crm_personnel_management b ON a.resign = 0 and b.resign = 0
	AND a.dept_name LIKE "销售一部%"
	AND a.position_id = b.position_id`)
	userData3 := TiDb.SelectBySql(`SELECT
	a.position_id,
	a.name,
	b.seat_number,
	b.role_id,
	a.bi_pcode,
	a.dept_name
FROM
	dwd_d_crm_department_level_succbi a
	INNER JOIN dwd_f_crm_personnel_management b ON a.resign = 0 and b.resign = 0
	AND a.resign = 0
	AND a.dept_name LIKE "%销售三部"
	AND a.position_id = b.position_id`)
	if userData3 == nil || len(*userData3) == 0 || userData1 == nil || len(*userData1) == 0 {
		return false, map[string]interface{}{}, allData
	}
	//一部管理员信息
	administrators1 := map[string]interface{}{}
	//三部管理员信息
	administrators3 := map[string]interface{}{}
	//返回当前人信息
	administrators := map[string]interface{}{}
	//电销一部
	deptNameMap1 := map[string]interface{}{}
	deptNameMap3 := map[string]interface{}{}
	proportion1 := float64(0)
	proportion3 := float64(0)
	for _, v := range *userData3 {
		v["type"] = 3
		id := gconv.Int64(v["position_id"])
		roleId := gconv.Int64(v["role_id"])
		if id == positionId {
			administrators = v
		}
		if roleId == 8 {
			v["orderStatus"] = 2
			administrators3 = v
		} else if roleId == 3 {
			proportion3 += 0.5
		} else {
			proportion3 += 1
		}
		deptNameMap3[gconv.String(v["bi_pcode"])] = true
		allData = append(allData, v)
	}
	for _, v := range *userData1 {
		v["type"] = 1
		id := gconv.Int64(v["position_id"])
		roleId := gconv.Int64(v["role_id"])
		if id == positionId {
			administrators = v
		}
		if roleId == 8 {
			v["orderStatus"] = 2
			administrators1 = v
		} else if roleId == 3 {
			proportion1 += 0.5
		} else {
			proportion1 += 1
		}
		deptNameMap1[gconv.String(v["bi_pcode"])] = true
		allData = append(allData, v)
	}
	if positionId != 0 {
		if administrators == nil || len(administrators) == 0 {
			return false, map[string]interface{}{}, allData
		}
		positiontype := gconv.Int64(administrators["type"])
		if trailstatus == "01" {
			switch positiontype {
			case 1:
				//找他上级
				administrators = administrators1
			case 3:
				//找他上级
				administrators = administrators3
			}
			return true, administrators, allData
		} else {
			return true, administrators, allData
		}
	}
	//按照比例分配选择一部还是三部
	//一部查询
	deptCount1 := CalculateProportion(1)
	//三部查询
	deptCount3 := CalculateProportion(3)
	return true, GetAllocation(proportion1, proportion3, deptCount1, deptCount3, administrators1, administrators3), allData
}

func CalculateProportion(deptNumb int64) int64 {
	data := WorkOrder.SelectBySql(`SELECT
	sum(1) as  count
FROM
	order_work_allocation_record  where   create_time >? and   company_dept_numb=? `, cfg.AllocationTime, deptNumb)
	count := int64(0)
	if data != nil && len(*data) > 0 {
		count = gconv.Int64((*data)[0]["count"])
	}
	return count
}

// 未支付订单 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))
	//sql := fmt.Sprintf(`select * from dataexport_order where id=260265`)
	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, ok2, _ := FormatData(v, "orders")
				if !ok1 {
					common.WriteSysConfig(&cfg)
					log.Println("线索卡点", "orders", v, selectTimeEnd, selectTimeStart)
				} else {
					if !ok2 {
						log.Println("用户分配已达上限", "orders", v, selectTimeEnd, selectTimeStart)
						common.WriteSysConfig(&cfg)
					}
				}
			}
			cfg.LastOrderId = common.IntAll(v["id"])
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("未支付订单定时任务结束")
}

func readClue() {
	log.Println("读表进线索定时任务开始")
	lastReadClueTime := cfg.LastReadClueTime
	sql := fmt.Sprintf(`select * from clue_info where updatetime > "%s" order by updatetime asc`, fmt.Sprint(lastReadClueTime))
	data := TiDb.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			ok1, ok2, _ := FormatData(v, "readClue")
			if !ok1 {
				common.WriteSysConfig(&cfg)
				log.Println("线索卡点", "readClue", v, lastReadClueTime)
			} else {
				if !ok2 {
					log.Println("用户分配已达上限", "readClue", v, lastReadClueTime)
					common.WriteSysConfig(&cfg)
				}
			}
			cfg.LastReadClueTime = common.ObjToString(v["updatetime"])
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("读表进线索定时任务结束")
}

// 新注册用户 5分钟一次
func users() {
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	//新用户注册后5分钟内进入线索 C
	log.Println("新注册用户定时任务开始", cfg.LastUserId)
	selectTimeEnd := cfg.LastUserId
	sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo   where createtime > "%s" and (s_platform != 'xcx' or    s_sourceid='jyzbw'    or  s_platform is  NULL)  and source = "0101" and status != 2  order by  createtime asc`, selectTimeEnd)
	//sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo   where id= 12617743`)
	data := TiDb.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for k, v := range *data {
			//判断用户是否有小程序切使用过剑鱼其他产品
			createtime := common.ObjToString(v["createtime"])
			changeCode := GetUserChannel(gconv.String(v["userid"]))
			if changeCode != "" {
				TiDb.Update("dwd_f_userbase_baseinfo", map[string]interface{}{
					"userid": gconv.String(v["userid"]),
				}, map[string]interface{}{
					"belong_to": changeCode,
				})
			}
			ok1, ok2, _ := FormatData(v, "users")
			if !ok1 {
				log.Println("线索卡点", "users", v, selectTimeEnd)
			} else {
				if !ok2 {
					log.Println("用户分配已达上限", "users", v, selectTimeEnd)
				}
			}
			if k == len(*data)-1 {
				cfg.LastUserId = createtime
			}
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("新注册用户定时任务结束", cfg.LastUserId)
	log.Println("小程序新注册用户定时任务结束", cfg.LastXcxUserId)
	selectXcxTimeEnd := cfg.LastXcxUserId
	xcxSql := fmt.Sprintf(`SELECT DISTINCT
	aa.mgo_id as  userId,
	cc.code as   industry ,
	aa.phone,
	IF
			( aa.phone_time IS NULL, aa.create_time, aa.phone_time ) as  time 
FROM
	debris_product.miniprogram_user aa
	INNER JOIN debris_product.miniprogram bb ON (
		aa.phone <> '' 
	AND
	IF
		( aa.phone_time IS NULL, aa.create_time, aa.phone_time ) > '%s' 
		AND aa.miniprogram_code = bb.CODE 
	)
	INNER JOIN debris_product.industry cc ON ( bb.industry_code = cc.CODE ) 
WHERE
	NOT EXISTS (
	SELECT
		1 
	FROM
		debris_product.miniprogram_user a
		INNER JOIN debris_product.miniprogram b ON (
			aa.unionid = a.unionid 
			AND aa.miniprogram_code = a.miniprogram_code 
			AND aa.id != a.id 
		AND
		IF
			( a.phone_time IS NULL, a.create_time, a.phone_time ) <= '%s' 
			AND a.miniprogram_code = b.CODE 
		)
	INNER JOIN debris_product.miniprogram_user c ON ( a.unionid = c.unionid AND b.CODE = c.miniprogram_code ))
	ORDER BY time
	`, selectXcxTimeEnd, selectXcxTimeEnd)
	xcxData := debrisProductMysql.SelectBySql(xcxSql)
	log.Println("11122", selectXcxTimeEnd, xcxData)
	if xcxData != nil && *xcxData != nil && len(*xcxData) > 0 {
		afList := []map[string]interface{}{}
		for k, v := range *xcxData {
			//判断用户是否有小程序切使用过剑鱼其他产品
			//判断uid
			uId := ""
			changeCode := GetUserChannel(gconv.String(v["userId"]))
			if changeCode != "" {
				TiDb.Update("dwd_f_userbase_baseinfo", map[string]interface{}{
					"userid": gconv.String(v["userId"]),
				}, map[string]interface{}{
					"belong_to": changeCode,
				})
			}
			for i := 0; i < 10; i++ {
				phone := common.ObjToString(v["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"])
					}
				}
				if uId == "" {
					time.Sleep(1 * time.Minute)
				} else {
					break
				}
			}
			updatetime := common.ObjToString(v["time"])
			if uId == "" {
				cfg.LastXcxUserId = updatetime
				continue
			}
			ok1, ok2, _ := FormatData(v, "xcxusers")
			/*if !ok3 {
				//首次使用"安防"小程序新注册用户
				afList = append(afList, v)
				cfg.LastXcxUserId = updatetime
				continue
			}*/
			if !ok1 {
				common.WriteSysConfig(&cfg)
				log.Println("小程序用户分配线索卡点", "xcxusers", v, selectXcxTimeEnd)
			} else {
				if !ok2 {
					log.Println("小程序用户分配已达上限", "xcxusers", v, selectXcxTimeEnd)
					common.WriteSysConfig(&cfg)
				}
			}

			if k == len(*xcxData)-1 {
				cfg.LastXcxUserId = updatetime
			}
		}
		if len(afList) > 0 {
			//发邮件给张文福
			AFEmail(afList)
		}
	}
	common.WriteSysConfig(&cfg)
	log.Println("小程序新注册用户定时任务结束", cfg.LastXcxUserId)
}

// 留资 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(db.Mgo.DbName).C("saleLeads").Find(&query).Sort("_id").Iter()
	thisData := map[string]interface{}{}
	filterArr := []string{"-pc", "-app", "-wx", "-h5"}
	sourceMap := map[string]string{}
	saleLeadsConfig := TiDb.Find("saleLeads_config", map[string]interface{}{
		"status": 0,
	}, "groupName", "", -1, -1)
	if saleLeadsConfig == nil || len(*saleLeadsConfig) == 0 {
		log.Println("线索卡点", "缺少留资分类名称", "saleLeads", thisData, lastId)
		return
	}
	sourceArr := []string{}
	for _, v := range *saleLeadsConfig {
		sourceArr = append(sourceArr, fmt.Sprintf(`department   LIKE '%%%s%%'`, gconv.String(v["groupName"])))
	}
	sql := fmt.Sprintf(`SELECT source,name FROM d_saleleads_code WHERE ( %s) AND is_delete = 1`, strings.Join(sourceArr, " or   "))
	saleSource := TiDb.SelectBySql(sql)
	if saleSource != nil && len(*saleSource) > 0 {
		for _, v := range *saleSource {
			source := common.ObjToString(v["source"])
			name := common.ObjToString(v["name"])
			for _, s := range filterArr {
				name = strings.ReplaceAll(name, s, "")
			}
			sourceMap[source] = name
		}
	}
	for {
		if !iter.Next(&thisData) {
			break
		}
		sourceCode := common.ObjToString(thisData["source"])
		if sourceCode == "" {
			log.Println("留资没有source", thisData)
			continue
		}
		//
		if sourceMap[sourceCode] != "" {
			continue
		}
		ok1, ok2, _ := FormatData(thisData, "saleLeads")
		if !ok1 {
			log.Println("线索卡点", "saleLeads", thisData, lastId)
		} else {
			if !ok2 {
				log.Println("用户分配已达上限", "saleLeads", thisData, lastId)
			}
		}
		cfg.LastId = mongodb.BsonIdToSId(thisData["_id"])
	}
	common.WriteSysConfig(&cfg)
	log.Println("用户留资定时任务结束")
}
func userbase() {
	log.Println("userbase定时任务开始")
	timeUnix := time.Now().Unix()
	selectTimeStart := time.Unix(timeUnix-1800, 0).Format("2006-01-02 15:04:05")
	selectTimeEnd := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05")
	sql := fmt.Sprintf(`SELECT
		a.phone,b.uid,a.baseinfo_id,b.l_registedate,a.createtime,b.id,b.userid,b.rsource
	FROM
		dwd_f_userbase_contacts a
	INNER JOIN dwd_f_userbase_baseinfo b ON
	    b.status= 1 
	    and  (b.s_platform != 'xcx' or  b.s_sourceid='jyzbw' or  b.s_platform is  NULL)
		AND a.phone = b.phone and a.baseinfo_id= b.uid and     b.source  ="0101"
  		and  a.phone  is  not   NULL  
		and   a.createtime   >="%s"
		and   a.createtime   <"%s"
		and  a.is_delete=1  
		ORDER BY    a.createtime `, selectTimeStart, 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"])
			changeCode := GetUserChannel(userId)
			if changeCode != "" {
				TiDb.Update("", map[string]interface{}{
					"userid": userId,
				}, map[string]interface{}{
					"belong_to": changeCode,
				})
			}
			registedate := common.ObjToString(v["l_registedate"])
			name := common.ObjToString(v["name"])
			nowTime := time.Now().Format(date.Date_Full_Layout)
			layout := "2006-01-02 15:04:05"
			createtime := gconv.String(v["createtime"])
			createtimeInt64, _ := time.Parse(layout, createtime)
			registedateInt64, _ := time.Parse(layout, registedate)
			count := TiDb.CountBySql("select count(1) as count from dwd_f_crm_clue_info where uid = ?", uId)
			if createtimeInt64.Unix()-registedateInt64.Unix() < int64(db.RegTimes)*86400 {
				if count == 0 {
					//注册少于7天、走新增
					data := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{
						"id": gconv.Int64(v["id"]),
					}, "", "")
					if data != nil && len(*data) > 0 {
						ok1, ok2, _ := FormatData(v, "users")
						if !ok1 {
							log.Println("线索卡点", "userbase uid", v, uId)
						} else {
							if !ok2 {
								log.Println("用户分配已达上限", "userbase uid", v, uId)
							}
						}
					}
				}
				continue
			}
			registedates, _ := time.Parse(date.Date_Full_Layout, registedate)
			log.Println("userbase uid 线索数量 ", count)
			log.Println("userbase uid 注册时间 ", registedates)
			if count == 0 {
				clueId := int64(0)
				sql := fmt.Sprintf(`select * from freeClubSign where mogUserId="%s" and sub_again_date > "%s" `, userId, selectTimeEnd)
				data := BiService.SelectBySql(sql)
				if len(*data) > 0 && userId != "" {
					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":      "670",
						"trailstatus":       "01",
						"name":              name,
						"phone":             phone,
						"comeintime_open":   nowTime,
						"comeinsource_open": 1,
						"FREEZE_TIME":       nowTime,
					})
				} else {
					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",
						"name":              name,
						"phone":             phone,
						"comeintime_open":   nowTime,
						"comeinsource_open": 1,
						"FREEZE_TIME":       nowTime,
					})
				}
				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定时任务结束")
}

func getRunOk() bool {
	currentTime, runOk := time.Now(), false
	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
		}
	}
	return runOk
}

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, sourceId int64) (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" && sourceCode != "bidCreditReportPreview" && sourceCode != "bidCreditReportFile" {
		pcode = "4"
		code = "154"
		level = "C"
		topname = "新增注册"
		subname = "新增注册用户"
	} else if item == "users" && (sourceCode == "bidCreditReportPreview" || sourceCode == "bidCreditReportFile") {
		pcode = "4"
		code = "767"
		level = "B"
		topname = "新增注册"
		subname = "信用报告引流用户"
	} else if item == "message" {
		pcode = "532"
		code = "477"
		level = "B"
		topname = "其他"
		subname = "机器人客服主动咨询"
	} else if item == "readClue" {
		level = "A"
		topname = "超级订阅临期用户"
		pcode = "614"
		if sourceId == 1 {
			code = "615"
			subname = "60天后到期"
		} else if sourceId == 2 {
			code = "616"
			subname = "45天后到期"
		} else if sourceId == 3 {
			code = "617"
			subname = "15天后到期"
		} else {
			code = "618"
			subname = "7天后到期"
		}
	} else if item == "allocation" {
		pcode = "532"
		code = "671"
		level = "D"
		pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": pcode}, "", "")
		if pcodeData != nil && len(*pcodeData) > 0 {
			topname = common.ObjToString((*pcodeData)["name"])
		}
		pcodeData = TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": code}, "", "")
		if pcodeData != nil && len(*pcodeData) > 0 {
			subname = common.ObjToString((*pcodeData)["name"])
		}
	} else if item == "rebind" {
		pcode = "532"
		code = "670"
		level = "D"
		pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": pcode}, "", "")
		if pcodeData != nil && len(*pcodeData) > 0 {

			topname = common.ObjToString((*pcodeData)["name"])

		}
		pcodeData = TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": code}, "", "")
		if pcodeData != nil && len(*pcodeData) > 0 {
			subname = common.ObjToString((*pcodeData)["name"])
		}
	} else if item == "invite" {
		codeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"code": 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"])
			}
		}
	} else if item == "tag" {
		pcodeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"name": gconv.String(data["topName"]), "level": 1}, "", "")
		if pcodeData != nil && len(*pcodeData) > 0 {
			pcode = common.ObjToString((*pcodeData)["code"])
			topname = common.ObjToString((*pcodeData)["name"])
			codeData := TiDb.FindOne("dwd_d_crm_cluetype_code", map[string]interface{}{"name": gconv.String(data["subName"]), "level": 2}, "", "")
			if codeData != nil && len(*codeData) > 0 {
				subname = common.ObjToString((*codeData)["name"])
				level = common.ObjToString((*codeData)["clue_level"])
				code = common.ObjToString((*codeData)["code"])
			}
		}
	} 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, cluename, phone string, isGroup, isCommerce int) (positionId int64, seatNumber, saleName string, saleData []map[string]interface{}, isOk, isFreeze bool, noticePositionId int64) {
	isOk = false
	isFreeze = false
	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.Find("dwd_f_crm_clue_info", map[string]interface{}{"cluename": cluename, "is_assign": 1}, "", "", -1, -1)
			cdata := TiDb.SelectBySql(`select  position_id,MAX(trail_time) as trail_time,max(last_ring_time) as last_ring_time,seatNumber,count(id) as count from   dwd_f_crm_clue_info where  cluename=? and  is_assign =1 GROUP BY  position_id `, cluename)
			if cdata != nil && len(*cdata) > 0 { //找到了公司有人在跟进
				isOk = true
				pdata := TiDb.SelectBySql(`select * from dwd_f_crm_personnel_management where seat_number is not null and seat_number != ""`)
				if pdata == nil {
					positionId = 0
					seatNumber = ""
					saleName = ""
					return
				}
				saleData = *pdata
				cdataNew := []map[string]interface{}{}
				if len(*cdata) > 1 {
					//可能有多个人跟进
					personMap := map[int64]bool{}
					upperLimitPersonMap := map[int64]bool{}
					upperLimitCdataNew := []map[string]interface{}{}
					upperLimitCount := 0
					isFull := false
					for _, m := range *cdata {
						positionid1 := gconv.Int64(m["position_id"])
						for _, v := range *pdata {
							resign := common.IntAll(v["resign"])
							assign_type := common.IntAll(v["assign_type"])
							role_id := common.IntAll(v["role_id"])
							if positionid1 == common.Int64All(v["position_id"]) {
								if resign == 0 && (assign_type == 1 || role_id == 8) {
									if !FindUpperLimit(gconv.String(positionid1), mode, true) {
										personMap[positionid1] = true
										m["saleName"] = common.ObjToString(v["name"])
										cdataNew = append(cdataNew, m)
									} else {
										upperLimitCount++
										upperLimitPersonMap[positionid1] = true
										m["saleName"] = common.ObjToString(v["name"])
										upperLimitCdataNew = append(upperLimitCdataNew, m)
									}
								}
							}
						}

					}
					if len(cdataNew) == 0 && len(upperLimitCdataNew) > 0 {
						//没有达上限的人数为0    全部都是达上限的
						personMap = upperLimitPersonMap
						cdataNew = upperLimitCdataNew
						isFull = true
					}
					//查询是否都有没有离职
					if len(personMap) != 0 && len(cdataNew) > 0 {
						layout := "2006-01-02 15:04:05"
						//有人没有离职
						data := map[string]interface{}{}
						trailTime := int64(0)
						for _, m := range cdataNew {
							currentTime := int64(0)
							if gconv.String(m["trail_time"]) == "" {
								continue
							}
							t, _ := time.Parse(layout, gconv.String(m["trail_time"]))
							currentTime = t.Unix()
							if currentTime > trailTime {
								trailTime = currentTime
								data = m
							}
						}
						if trailTime == 0 {
							//需要查看通话记录
							lastRingTime := int64(0)
							for _, m := range cdataNew {
								currentTime := int64(0)
								if gconv.String(m["last_ring_time"]) == "" {
									continue
								}
								t, _ := time.Parse(layout, gconv.String(m["last_ring_time"]))
								currentTime = t.Unix()
								if currentTime > lastRingTime {
									lastRingTime = currentTime
									data = m
								}
							}
							if lastRingTime != 0 {
								positionId = common.Int64All(data["position_id"])
								noticePositionId = positionId
								seatNumber = common.ObjToString(data["seatNumber"])
								saleName = common.ObjToString(data["saleName"])
								if isFull {
									isFreeze = true
									noticePositionId = positionId
									positionId = 0
									seatNumber = ""
									saleName = ""
								}
								return
							} else {
								count := 0
								//线索数量判断
								for i, v := range cdataNew {
									if i == 0 {
										count = gconv.Int(v["count"])
										data = v
									} else {
										if count < gconv.Int(v["count"]) {
											count = gconv.Int(v["count"])
											data = v
										}
									}
								}
								positionId = common.Int64All(data["position_id"])
								noticePositionId = positionId
								saleName = common.ObjToString(data["saleName"])
								seatNumber = common.ObjToString(data["seatNumber"])
								if isFull {
									isFreeze = true
									noticePositionId = positionId
									positionId = 0
									seatNumber = ""
									saleName = ""
								}
								return
							}
						} else {
							positionId = common.Int64All(data["position_id"])
							noticePositionId = positionId
							seatNumber = common.ObjToString(data["seatNumber"])
							saleName = common.ObjToString(data["saleName"])
							if isFull {
								isFreeze = true
								noticePositionId = positionId
								positionId = 0
								seatNumber = ""
								saleName = ""
							}
							return
						}
					}
				} else {
					//只有一人跟进
					//（1）该销售人员未离职，则继续分配给该销售人员（保持现状）；
					//该销售人员已离职，则随机分配
					positionId = common.Int64All((*cdata)[0]["position_id"])
					noticePositionId = positionId
					seatNumber = common.ObjToString((*cdata)[0]["seatNumber"])
					for _, v := range *pdata {
						resign := common.IntAll(v["resign"])
						assign_type := common.IntAll(v["assign_type"])
						role_id := common.IntAll(v["role_id"])
						if positionId == common.Int64All(v["position_id"]) {
							if resign == 0 && (assign_type == 1 || role_id == 8) {
								if FindUpperLimit(gconv.String(positionId), mode, true) {
									isFreeze = true
									positionId = 0
									seatNumber = ""
									saleName = ""
									break
								} else {
									saleName = common.ObjToString(v["name"])
									return
								}

							}
						}
					}
				}
			}
		}
	}
	positionId = 0
	seatNumber = ""
	saleName = ""
	query := `select * from dwd_f_crm_personnel_management where assign_type = 1 and`
	if mode == "A" {
		query += ` assign_level like "%A%"`
	} else if mode == "B" {
		query += ` assign_level like "%B%"`
	} else if mode == "D" {
		query += ` assign_level like "%D%"`
	} else if mode == "C" {
		query += ` assign_level like "%C%"`
	} else if mode == "S" {
		query += ` assign_level like "%S%"`
	} else if mode == "E" {
		query += ` assign_level like "%E%"`
	}
	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.Int64All(v["position_id"]) == common.Int64All(vv["position_id"]) {
						if common.IntAll(v["resign"]) == 0 {
							vv["status"] = 1
						} else {
							vv["status"] = 2
						}
						isOk = true
					}
				}
				if !isOk { //有新员工直接分给新员工
					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{}{
						"position_id": positionId,
						"clue_level":  mode,
						"count":       common.Int64All((*rData)["count"]),
					})
					break
				}
			}
			if positionId == 0 {
				res := int64(0)
				countres := 0
				for _, v := range *countData {
					if common.IntAll(v["status"]) == 1 {
						if FindUpperLimit(gconv.String(v["position_id"]), mode, false) {
							continue
						}
						if countres == 0 {
							res = common.Int64All(v["count"])
							positionId = common.Int64All(v["position_id"])
						} else {
							if common.Int64All(v["count"]) <= res {
								res = common.Int64All(v["count"])
								positionId = common.Int64All(v["position_id"])
							}
						}
						countres++
					}
				}
				log.Println(444, res)
			}
		} else {
			for _, kv := range *data {
				positionId1 := gconv.String(kv["position_id"])
				if !FindUpperLimit(positionId1, "", false) {
					positionId = common.Int64All(kv["position_id"])
					saleName = common.ObjToString(kv["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{}{
							"position_id": positionId,
							"clue_level":  mode,
							"count":       common.Int64All((*rData)["count"]),
						})
					} else {
						TiDb.Insert("dwd_f_crm_clue_autodraw_record", map[string]interface{}{
							"position_id": positionId,
							"clue_level":  mode,
							"count":       0,
						})
					}
					break
				}
			}
		}
		for _, v := range *data {
			if positionId == common.Int64All(v["position_id"]) {
				seatNumber = common.ObjToString(v["seat_number"])
				saleName = common.ObjToString(v["name"])
			}
		}
	}
	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": db.EntId, "user_id": userId}, "", "") //TODO ent_id
		if positionData != nil && len(*positionData) > 0 {
			positionId = common.Int64All((*positionData)["id"])
		}
	}
	return
}

func GetCompanyType(companyName string, uId string) (int, int) {
	isGroup, isCommerce := 0, 0
	uCount := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
	if uCount != nil && len(*uCount) > 0 {
		isUpdate := gconv.Int64((*uCount)["is_artificially_modified"])
		if isUpdate == 1 {
			companyName = gconv.String((*uCount)["cluename"])
		}
		if companyName == "" {
			companyName = gconv.String((*uCount)["cluename"])
		}
	}
	if companyName == "" {
		return isGroup, isCommerce
	}
	//是否是集团
	if c := TiDb.CountBySql(`select count(1) from group_company_name where company_name=?`, companyName); c > 0 {
		isGroup = 1
	}
	//是否在工商库
	if companyName != "" {
		if c := MgoQyxy.Count("qyxy_std", map[string]interface{}{"company_name": companyName, "company_type": map[string]interface{}{"$ne": "个体工商户"}}); c > 0 {
			isCommerce = 1
		}
	}
	return isGroup, isCommerce
}

// 查询是否达上限
func FindUpperLimit(positionId string, level string, isAdd bool) bool {
	if positionId == "" {
		return false
	}
	isFull := TiDb.CountBySql(`select count(1) from dwd_f_crm_clue_info where position_id=? and is_assign=1   and is_transfer != 1  `, positionId) >= db.AllocationCap
	if isFull && isAdd && level != "" {
		TiDb.UpdateOrDeleteBySql(`update dwd_f_crm_clue_autodraw_record set count = count + 1 where position_id = ? and clue_level = ?`, positionId, level)
	}
	return isFull
}
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 rebind() {
	log.Println("重新关注用户处理开始")
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	rebindTimeEnd := cfg.RebindTime
	sql := fmt.Sprintf(`select * from freeClubSign where sub_again_date > "%s" order by  sub_again_date asc`, rebindTimeEnd)
	data := BiService.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			rebindTimeEnd = common.ObjToString(v["sub_again_date"])
			registedates, _ := time.Parse(date.Date_Full_Layout, gconv.String(v["register_time"]))
			if time.Now().Unix()-registedates.Unix() > int64(db.RegTimes)*86400 {
				ok1, ok2, _ := FormatData(v, "rebind")
				if !ok1 {
					log.Println("线索卡点", "allocation", v, rebindTimeEnd)
				} else {
					if !ok2 {
						log.Println("用户分配已达上限", "allocation", v, rebindTimeEnd)
					}
				}
			}
		}
		cfg.RebindTime = rebindTimeEnd
		common.WriteSysConfig(&cfg)
	}
	log.Println("重新关注用户处理结束")
}

// 活跃用户处理
func activeUsers() {
	log.Println("活跃用户处理开始")
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	//活跃用户查询
	activeTimeEnd := cfg.ActiveTime
	sql := fmt.Sprintf(`select * from freeClubSign where act_again_date > "%s" order by  act_again_date asc`, activeTimeEnd)
	data := BiService.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			activeTimeEnd = common.ObjToString(v["act_again_date"])
			ok1, ok2, _ := FormatData(v, "allocation")
			log.Println(v, "allocation", ok1, ok2)
			if !ok1 {
				log.Println("线索卡点", "allocation", v, activeTimeEnd)
			} else {
				if !ok2 {
					log.Println("用户分配已达上限", "allocation", v, activeTimeEnd)
				}
			}
		}
		cfg.ActiveTime = activeTimeEnd
		common.WriteSysConfig(&cfg)
	}
	log.Println("活跃用户处理结束")
}

// 安博会邮件
/*func ABHEmail(source string, data []map[string]interface{}) {
	fileName, detailName, email, dir := "", "", "", ""
	var err error
	switch source {
	case "user":
		xlsxArr := []string{"姓名", "联系方式", "邮箱", "公司名称", "咨询需求", "销售线索来源", "具体来源", "留资时间"}
		batch := FindBatch("abh")
		fileName, detailName = "安博会用户注册销售线索 "+time.Now().Format(date.Date_Short_Layout)+"-"+batch, ""
		xf := xlsx.NewFile()
		style := xlsx.NewStyle()
		style.Font.Size = 12
		style.Font.Bold = true
		style.Alignment.Vertical = "center"
		style.Alignment.Horizontal = "center"
		detailName = "今日新增安博会销售线索，请查收附件，及时跟进。"
		sh, _ := xf.AddSheet("线索数据")
		row1 := sh.AddRow()
		for _, x := range xlsxArr {
			cell := row1.AddCell()
			cell.SetString(x)
			cell.SetStyle(style)
		}
		for _, v := range data {
			row := sh.AddRow()
			row.AddCell().SetString(common.ObjToString(v["name"]))
			row.AddCell().SetString(common.ObjToString(v["phone"]))
			row.AddCell().SetString(common.ObjToString(v["email"]))
			row.AddCell().SetString(common.ObjToString(v["company_name"]))
			row.AddCell().SetString("")
			row.AddCell().SetString("")
			row.AddCell().SetString("安博会用户注册")
			row.AddCell().SetString(gconv.Time(gconv.Int64(v["createtime"])).Format(date.Date_Full_Layout))
			//增加客户需求
		}
		dir = "./xlsx/abh/" + fileName + ".xlsx"
		err = xf.Save(dir)
	case "saleLeads":
		xlsxArr := []string{"用户昵称", "姓名", "公司名称", "职位", "联系人电话", "购买条数", "用户邮箱", "已支付订单信息", "未支付订单类型", "销售线索来源", "具体来源", "数据需求"}
		batch := FindBatch("abh")
		fileName, detailName = time.Now().Format(date.Date_Short_Layout)+"-"+batch+"安博会电销销售线索", ""
		xf := xlsx.NewFile()
		style := xlsx.NewStyle()
		style.Font.Size = 12
		style.Font.Bold = true
		style.Alignment.Vertical = "center"
		style.Alignment.Horizontal = "center"
		detailName = "今日新增安博会销售线索，请查收附件，及时跟进。"
		sh, _ := xf.AddSheet("线索数据")
		row1 := sh.AddRow()
		for _, x := range xlsxArr {
			cell := row1.AddCell()
			cell.SetString(x)
			cell.SetStyle(style)
		}
		filterArr := []string{"-pc", "-app", "-wx", "-h5"}
		sourceMap := map[string]string{} //根据留资维表：tidb/Jianyu_subjectdb/d_saleleads_code
		saleSource := TiDb.SelectBySql(`SELECT source,name FROM d_saleleads_code WHERE   is_delete = 1`)
		if saleSource != nil && len(*saleSource) > 0 {
			for _, v := range *saleSource {
				source := common.ObjToString(v["source"])
				name := common.ObjToString(v["name"])
				for _, s := range filterArr {
					name = strings.ReplaceAll(name, s, "")
				}
				sourceMap[source] = name
			}
		}
		for _, v := range data {
			sources := common.ObjToString(v["source"])
			interest := common.ObjToString(v["interest"])
			row := sh.AddRow()
			row.AddCell().SetString(common.ObjToString(v["usernickname"]))
			row.AddCell().SetString(common.ObjToString(v["name"]))
			row.AddCell().SetString(common.ObjToString(v["company"]))
			row.AddCell().SetString(common.ObjToString(v["position"]))
			row.AddCell().SetString(common.ObjToString(v["phone"]))
			row.AddCell().SetValue(0)
			row.AddCell().SetString(common.ObjToString(v["email"]))
			row.AddCell().SetString("")
			row.AddCell().SetString("")
			row.AddCell().SetString(sourceMap[sources])
			row.AddCell().SetString(interest)
			row.AddCell().SetString(common.ObjToString(v["data_requirement"]))
			//增加客户需求
		}
		dir = "./xlsx/abh/" + fileName + ".xlsx"
		err = xf.Save(dir)
	case "big":
		xlsxArr := []string{"用户昵称", "姓名", "公司名称", "职位", "联系人电话", "购买条数", "用户邮箱", "已支付订单信息", "未支付订单类型", "销售线索来源", "具体来源", "数据需求"}
		batch := FindBatch("abh")
		fileName, detailName = time.Now().Format(date.Date_Short_Layout)+"-"+batch+"安博会大客户销售线索", ""
		xf := xlsx.NewFile()
		style := xlsx.NewStyle()
		style.Font.Size = 12
		style.Font.Bold = true
		style.Alignment.Vertical = "center"
		style.Alignment.Horizontal = "center"
		detailName = "今日新增安博会销售线索，请查收附件，及时跟进。"
		sh, _ := xf.AddSheet("线索数据")
		row1 := sh.AddRow()
		for _, x := range xlsxArr {
			cell := row1.AddCell()
			cell.SetString(x)
			cell.SetStyle(style)
		}
		for _, v := range data {
			row := sh.AddRow()
			row.AddCell().SetString(common.ObjToString(v["usernickname"]))
			row.AddCell().SetString(common.ObjToString(v["username"]))
			row.AddCell().SetString(common.ObjToString(v["company"]))
			row.AddCell().SetString(common.ObjToString(v["job"]))
			row.AddCell().SetString(common.ObjToString(v["phone"]))
			row.AddCell().SetValue(common.IntAll(v["data_count"]))
			row.AddCell().SetString(common.ObjToString(v["email"]))
			row.AddCell().SetString(common.ObjToString(v["payorderinfo"]))
			row.AddCell().SetString(common.ObjToString(v["unpayorderinfo"]))
			row.AddCell().SetString(common.ObjToString(v["source"]))
			row.AddCell().SetString(common.ObjToString(v["interest"]))
			row.AddCell().SetString(common.ObjToString(v["data_requirement"]))
			//增加客户需求
		}
		dir = "./xlsx/abh/" + fileName + ".xlsx"
		err = xf.Save(dir)
	case "advisory":
		xlsxArr := []string{"姓名", "联系方式", "邮箱", "公司名称", "咨询需求", "销售线索来源", "具体来源", "留资时间"}
		//排序：首先按照“联系方式”排序，即同1个用户的留资放在一起，其次按照留资时间正序排序。
		batch := FindBatch("abh")
		fileName, detailName = "安博会咨询服务销售线索 "+time.Now().Format(date.Date_Short_Layout)+"-"+batch, ""
		xf := xlsx.NewFile()
		style := xlsx.NewStyle()
		style.Font.Size = 12
		style.Font.Bold = true
		style.Alignment.Vertical = "center"
		style.Alignment.Horizontal = "center"
		detailName = "今日新增安博会销售线索，请查收附件，及时跟进。"
		sh, _ := xf.AddSheet("线索数据")
		row1 := sh.AddRow()
		for _, x := range xlsxArr {
			cell := row1.AddCell()
			cell.SetString(x)
			cell.SetStyle(style)
		}
		for _, v := range data {
			row := sh.AddRow()
			row.AddCell().SetString(common.ObjToString(v["username"]))
			row.AddCell().SetString(common.ObjToString(v["phone"]))
			row.AddCell().SetString(common.ObjToString(v["email"]))
			row.AddCell().SetString(common.ObjToString(v["company"]))
			row.AddCell().SetString(common.ObjToString(v["data_requirement"]))
			row.AddCell().SetString(common.ObjToString(v["source"]))
			row.AddCell().SetString(common.ObjToString(v["interest"]))
			row.AddCell().SetString(gconv.Time(gconv.Int64(v["createtime"])).Format(date.Date_Full_Layout))
		}
		dir = "./xlsx/abh/" + fileName + ".xlsx"
		err = xf.Save(dir)
	case "market":
		xlsxArr := []string{"姓名", "联系人电话", "公司名称", "职位", "部门", "销售线索来源", "留资时间"}
		batch := FindBatch("abh")
		fileName, detailName = "安博会商务合作销售线索 "+time.Now().Format(date.Date_Short_Layout)+"-"+batch, ""
		xf := xlsx.NewFile()
		style := xlsx.NewStyle()
		style.Font.Size = 12
		style.Font.Bold = true
		style.Alignment.Vertical = "center"
		style.Alignment.Horizontal = "center"
		detailName = "今日新增安博会销售线索，请查收附件，及时跟进。"
		sh, _ := xf.AddSheet("线索数据")
		row1 := sh.AddRow()
		for _, x := range xlsxArr {
			cell := row1.AddCell()
			cell.SetString(x)
			cell.SetStyle(style)
		}
		for _, v := range data {
			row := sh.AddRow()
			row.AddCell().SetString(common.ObjToString(v["username"]))
			row.AddCell().SetString(common.ObjToString(v["phone"]))
			row.AddCell().SetString(common.ObjToString(v["company"]))
			row.AddCell().SetString(common.ObjToString(v["job"]))
			row.AddCell().SetString(common.ObjToString(v["branch"]))
			row.AddCell().SetString(common.ObjToString(v["source"]))
			row.AddCell().SetString(gconv.Time(gconv.Int64(v["createtime"])).Format(date.Date_Full_Layout))
			//增加客户需求
		}
		dir = "./xlsx/abh/" + fileName + ".xlsx"
		err = xf.Save(dir)
	}
	email = db.AbhEmail
	if err != nil {
		log.Println("xls error", err, dir)
	} else {
		gmail := &mail.GmailAuth{
			SmtpHost: "smtp.exmail.qq.com",
			SmtpPort: 465,
			User:     "public03@topnet.net.cn",
			Pwd:      "ue9Rg9Sf4CVtdm5a",
		}
		status := mail.GSendMail_q("剑鱼标讯", email, "", "", fileName, detailName, dir, fileName+".xlsx", gmail)
		if status {
			log.Println("send mail success", fileName, email)
		}
	}
}*/

// 安防邮件
func AFEmail(data []map[string]interface{}) {
	xlsxArr := []string{"姓名", "联系方式", "邮箱", "公司名称", "咨询需求", "销售线索来源", "具体来源", "留资时间"}
	batch := FindBatch("af")
	fileName, detailName := "安防销售线索 "+time.Now().Format(date.Date_Short_Layout)+"-"+batch, ""
	xf := xlsx.NewFile()
	style := xlsx.NewStyle()
	style.Font.Size = 12
	style.Font.Bold = true
	style.Alignment.Vertical = "center"
	style.Alignment.Horizontal = "center"
	detailName = "今日新增安防销售线索，请查收附件，及时跟进。"
	sh, _ := xf.AddSheet("线索数据")
	row1 := sh.AddRow()
	for _, x := range xlsxArr {
		cell := row1.AddCell()
		cell.SetString(x)
		cell.SetStyle(style)
	}
	for _, v := range data {
		row := sh.AddRow()
		row.AddCell().SetString(common.ObjToString(v["name"]))
		row.AddCell().SetString(common.ObjToString(v["phone"]))
		row.AddCell().SetString(common.ObjToString(v["email"]))
		row.AddCell().SetString(common.ObjToString(v["company_name"]))
		row.AddCell().SetString("")
		row.AddCell().SetString("")
		row.AddCell().SetString("首次使用安防新注册")
		row.AddCell().SetString(gconv.String(v["time"]))
		//增加客户需求
	}
	email := db.AfEmail
	dir := "./xlsx/af/" + fileName + ".xlsx"
	err := xf.Save(dir)
	if err != nil {
		log.Println("xls error", err, dir)
	} else {
		gmail := &mail.GmailAuth{
			SmtpHost: db.Mail.SmtpHost,
			SmtpPort: db.Mail.SmtpPort,
			User:     db.Mail.User,
			Pwd:      db.Mail.Pwd,
		}
		status := mail.GSendMail_q("剑鱼标讯", email, "", "", fileName, detailName, dir, "", gmail)
		if status {
			log.Println("send mail success", fileName, email)
		}

	}
}

func populateAdvisoryData(sh *xlsx.Sheet, data []map[string]interface{}) error {
	for _, v := range data {
		row := sh.AddRow()
		row.AddCell().SetString(common.ObjToString(v["username"]))
		row.AddCell().SetString(common.ObjToString(v["phone"]))
		row.AddCell().SetString(common.ObjToString(v["email"]))
		row.AddCell().SetString(common.ObjToString(v["company"]))
		row.AddCell().SetString(common.ObjToString(v["data_requirement"]))
		row.AddCell().SetString(common.ObjToString(v["source"]))
		row.AddCell().SetString(common.ObjToString(v["interest"]))
		row.AddCell().SetString(gconv.Time(gconv.Int64(v["createtime"])).Format(date.Date_Full_Layout))
	}
	return nil
}

// 邀请用户处理
func inviteUser() {
	log.Println("邀请用户处理开始")
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	rebindTimeEnd := cfg.InviteTime
	sql := fmt.Sprintf(`select * from user_statistics where createTime > "%s" order by  createTime asc`, rebindTimeEnd)
	//sql := fmt.Sprintf(`select * from user_statistics where createTime = "%s" order by  createTime asc`, rebindTimeEnd)
	data := BiService.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			rebindTimeEnd = common.ObjToString(v["createTime"])
			event := gconv.Int64(v["event"])
			switch event {
			case 1:
				v["sourceCode"] = "736"
			case 2:
				v["sourceCode"] = "737"
			case 3:
				v["sourceCode"] = "738"
			}
			v["user_id"] = gconv.String(v["userId"])
			ok1, ok2, _ := FormatData(v, "invite")
			if !ok1 {
				log.Println("线索卡点", "invite", v, rebindTimeEnd)
			} else {
				if !ok2 {
					log.Println("用户分配已达上限", "invite", v, rebindTimeEnd)
				}
			}
		}
		cfg.InviteTime = rebindTimeEnd
		common.WriteSysConfig(&cfg)
	}
	log.Println("邀请用户处理结束")
}

// 开年活动
func nextYearActivity() {
	log.Println("开年活动处理开始")
	//判断节假日
	runOk := getRunOk()
	if !runOk {
		log.Println("不是工作日，任务暂停")
		return
	}
	activityTimeEnd := cfg.ActivityTime
	sql := fmt.Sprintf(`SELECT
							 a.*
							FROM
								jyactivities.lottery_user_account a  
								INNER JOIN  jyactivities.lottery_prize_info b  on     a.create_time > "%s"  and  a.prize_id=b.id
								INNER JOIN  jyactivities.prize_base_info c  on   c.name like "%s"  and b.pb_id=c.id
							ORDER BY
								a.create_time ASC
`, activityTimeEnd, "%超级订阅%")
	data := Mysql.SelectBySql(sql)
	if data != nil && *data != nil && len(*data) > 0 {
		for _, v := range *data {
			activityTimeEnd = common.ObjToString(v["create_time"])
			v["sourceCode"] = gconv.Int64(v["active_id"])
			v["user_id"] = gconv.String(v["mgo_user_id"])
			ok1, ok2, _ := FormatData(v, "activity")
			if !ok1 {
				log.Println("线索卡点", "activity", v, activityTimeEnd)
			} else {
				if !ok2 {
					log.Println("开年活动分配已达上限", "activity", v, activityTimeEnd)
				}
			}
		}
		cfg.ActivityTime = activityTimeEnd
		common.WriteSysConfig(&cfg)
	}
	log.Println("开年活动处理结束")
}

// 获取用户渠道信息
func GetUserChannel(userId string) string {
	if userId == "" {
		return ""
	}
	codeArr := []string{}
	if len(UserChannel) > 0 {
		for i := range UserChannel {
			codeArr = append(codeArr, fmt.Sprintf(`"%s"`, i))
		}
	}
	//查找注册日志表
	sql := fmt.Sprintf(`select  channel_code   from   user_source     where  user_id  ="%s"  and   channel_code  in   (%s)   ORDER BY   create_time  desc   limit   1  `, userId, strings.Join(codeArr, ","))
	courceData := ThirdParty.SelectBySql(sql)
	if courceData != nil && len(*courceData) > 0 {
		channelCode := gconv.String((*courceData)[0]["channel_code"])
		data, exit := UserChannel[channelCode]
		if exit {
			return gconv.String(data["clueCode"])
		}
	}
	return ""
}