datatools/clueSync/autoTask.go

package main

import (
	"database/sql"
	"log"
	"time"

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

func autoTask() {
	log.Println("超时未跟进定时任务开始")
	t := time.Now()
	nowTime := time.Now().Format(date.Date_Full_Layout)
	statusMap := map[string]int{
		"07": 2, //待签署客户
		"06": 2, //高意向客户
		"05": 3, //意向客户
		"04": 7, //潜在客户
	}
	//判断节假日
	for status, statusInt := range statusMap {
		count, counts := 0, 0
		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 >= statusInt {
				break
			}
		}
		statusMap[status] = count
	}
	log.Println(statusMap)
	for trailstatus, _ := range map[string]string{
		"07": "", //待签署客户
		"06": "", //高意向客户
		"05": "", //意向客户
		"04": "", //潜在客户
	} {
		sql := `SELECT a.clue_id,a.position_id,a.seatNumber,a.out_task_status FROM dwd_f_crm_private_sea a 
				LEFT JOIN dwd_f_crm_clue_info b ON a.clue_id=b.id 
				WHERE b.trailstatus =?`
		argsSelect := []interface{}{trailstatus}
		intime := ""
		sql += " AND a.comeintime <?"
		// nt := nexttime.(time.Time)
		nt := t.AddDate(0, 0, -statusMap[trailstatus])
		intime = nt.Format(date.Date_Full_Layout)
		argsSelect = append(argsSelect, intime)
		//
		TiDb.SelectByBath(100, func(l *[]map[string]interface{}) bool {
			for _, v := range *l {
				clueId := common.Int64All(v["clue_id"])
				position_id := common.Int64All(v["position_id"])
				out_task_status := common.IntAll(v["out_task_status"])
				args2 := []interface{}{clueId}
				//获取跟进内容
				// sql1 := `select COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id =?;`
				sql2 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id = ? and position_id = ?`
				if intime != "" {
					sql2 += ` and createtime > ?`
					args2 = append(args2, position_id)
					args2 = append(args2, intime)
				}
				//保留未跟进线索
				// if c1, c2 := TiDb.CountBySql(sql1, clueId), TiDb.CountBySql(sql2, args2...); (c1 != 0 && c2 > 0) || out_task_status == 1 {
				// 	log.Println("不满足线索过滤", clueId)
				// 	continue
				// }
				log.Println("intime ", clueId, intime, sql2)
				if c2 := TiDb.CountBySql(sql2, args2...); c2 > 0 || out_task_status == 1 {
					log.Println("不满足线索过滤", clueId)
					continue
				}
				if TiDb.Update("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
					"is_task":    1,
					"task_time":  nowTime,
					"tasktime":   time.Now().Format(date.Date_Short_Layout) + " 10:00:00",
					"taskstatus": 0,
					"tasksource": "超时未跟进自动加车",
				}) {
					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
						"clue_id":     clueId,
						"position_id": position_id,
						"change_type": "加入任务车",
						"new_value":   "超时未跟进自动加车",
						"createtime":  nowTime,
						"BCPCID":      common.GetRandom(32),
						"operator_id": -1,
					})
				}
			}
			return true
		}, sql, argsSelect...)
	}
	log.Println("超时未跟进定时任务结束")
}

func autoTasks() {
	log.Println("按照跟进时间提前一天进入任务车定时任务开始")
	nowTime2 := time.Now().Format(date.Date_Full_Layout)
	nextTime := time.Now().AddDate(0, 0, 1).Format(date.Date_Full_Layout)
	TiDb.SelectByBath(100, func(l *[]map[string]interface{}) bool {
		for _, v := range *l {
			clueId := common.Int64All(v["clue_id"])
			position_id := common.Int64All(v["position_id"])
			out_task_status := common.IntAll(v["out_task_status"])
			if out_task_status != 1 {
				if TiDb.Update("dwd_f_crm_private_sea", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
					"is_task":    1,
					"task_time":  nowTime2,
					"tasktime":   nowTime2,
					"taskstatus": 0,
					"tasksource": "即将到达下次跟进时间",
				}) {
					TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
						"clue_id":     clueId,
						"position_id": position_id,
						"change_type": "加入任务车",
						"new_value":   "即将到达下次跟进时间",
						"createtime":  nowTime2,
						"BCPCID":      common.GetRandom(32),
						"operator_id": -1,
					})
				}
			}
		}
		return true
	}, `SELECT a.clue_id,a.position_id,a.seatNumber,a.out_task_status FROM dwd_f_crm_private_sea a 
				LEFT JOIN dwd_f_crm_clue_info b ON a.clue_id=b.id 
				LEFT JOIN dwd_f_crm_trail_content c ON c.clue_id=b.id 
				WHERE c.next_time >= "`+nowTime2+`" and c.next_time <= "`+nextTime+`"`)
	log.Println("按照跟进时间提前一天进入任务车定时任务结束")
}

func autoExitSea() {
	log.Println("自动退海任务开始")
	data := TiDb.SelectBySql(`select * from dwd_f_crm_clue_info where trailstatus = "02" and (is_assign = 1 or is_assign = 0)`)
	if data != nil && len(*data) > 0 {
		for _, v := range *data {
			clueId := common.Int64All(v["id"])
			positionId := common.Int64All(v["position_id"])
			seatNumber := common.ObjToString(v["seatNumber"])
			nowTime := time.Now().Format(date.Date_Full_Layout)
			is_assign := common.IntAll(v["is_assign"])
			if TiDb.ExecTx("退出线索", func(tx *sql.Tx) bool {
				recordId := TiDb.UpdateOrDeleteBySqlByTx(tx, `UPDATE dwd_f_crm_clue_info SET is_assign = -1,position_id = null,seatNumber = null WHERE id = ?`, clueId)
				ok1 := true
				if is_assign == 1 {
					ok1 = TiDb.DeleteByTx(tx, "dwd_f_crm_private_sea", map[string]interface{}{"clue_id": clueId})
				}
				recordId1 := 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":    GetPositionName(seatNumber),
					"new_value":    "/",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				recordId2 := 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,
				})
				recordId3 := 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,
				})
				recordId4 := 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,
				})
				log.Println(ok1, recordId, recordId1, recordId2, recordId3, recordId4)
				return ok1 && recordId > -1 && recordId1 > -1 && recordId2 > -1 && recordId3 > -1 && recordId4 > -1
			}) {
				log.Println("自动退出线索成功")
			} else {
				log.Println("自动退出线索失败")
			}
		}
	}
	datas := TiDb.Find("dwd_f_crm_clue_info", map[string]interface{}{"trailstatus": "00", "is_assign": 1}, "", "", -1, -1)
	if datas != nil && len(*datas) > 0 {
		for _, v := range *datas {
			clueId := common.Int64All(v["id"])
			positionId := common.Int64All(v["position_id"])
			seatNumber := common.ObjToString(v["seatNumber"])
			nowTime := time.Now().Format(date.Date_Full_Layout)
			is_assign := common.IntAll(v["is_assign"])
			if TiDb.ExecTx("自动退海", func(tx *sql.Tx) bool {
				recordId := TiDb.UpdateOrDeleteBySqlByTx(tx, `UPDATE dwd_f_crm_clue_info SET is_assign = 0,position_id = null,seatNumber = null  WHERE id = ?`, clueId)
				ok1 := true
				if is_assign == 1 {
					ok1 = TiDb.DeleteByTx(tx, "dwd_f_crm_private_sea", map[string]interface{}{"clue_id": clueId})
				}
				recordId1 := 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":    GetPositionName(seatNumber),
					"new_value":    "/",
					"createtime":   nowTime,
					"BCPCID":       common.GetRandom(32),
					"operator_id":  -1,
				})
				recordId2 := 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,
				})
				recordId3 := 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,
				})
				recordId4 := 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,
				})
				recordId5 := TiDb.InsertByTx(tx, "dwd_f_crm_open_sea", map[string]interface{}{
					"clue_id":      clueId,
					"comeintime":   nowTime,
					"comeinsource": 2,
				})
				return ok1 && recordId > -1 && recordId1 > -1 && recordId2 > -1 && recordId3 > -1 && recordId4 > -1 && recordId5 > -1
			}) {
				log.Println("自动退出私海成功")
			} else {
				log.Println("自动退出私海失败")
			}
		}
	}
	log.Println("自动退海任务结束")
}

func GetPositionName(seatNumber string) string {
	data := TiDb.SelectBySql(`select name from jy_salesperson_info where status = 0 and position != 0 and seatNumber = ? limit 1`, seatNumber)
	if data != nil && len(*data) > 0 {
		return common.ObjToString((*data)[0]["name"])
	}
	return ""
}