123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290 |
- package main
- import (
- "app.yhyue.com/moapp/jybase/mail"
- "database/sql"
- "encoding/json"
- "fmt"
- "log"
- "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 kcSync() {
- log.Println("客户成功系统移交定时任务开始")
- sql := `select * from dwd_f_userbase_order_info where (payable_money > 0 or (payable_money=0 and ( filter like "%分期付款补充权益%" or filter like "%原订单不支持开通多项权益%" or filter like "%权益码兑换%")))
- and data_spec!="dhy4" and order_status=1 and (refund_status!=1 or refund_status is null ) and vip_starttime<"2099-01-01"
- and vip_endtime > "` + time.Now().Format(date.Date_Full_Layout) + `" and autoUpdate > "` + cfg.LastkcTime + `" order by autoUpdate asc`
- //sql := `select * from dwd_f_userbase_order_info where order_code="152504013602" `
- data := TiDb.SelectBySql(sql)
- if data != nil && *data != nil && len(*data) > 0 {
- arr := []string{}
- for _, v := range *data {
- product_type := common.ObjToString(v["product_type"])
- vip_starttime := common.ObjToString(v["vip_starttime"])
- vip_endtime := common.ObjToString(v["vip_endtime"])
- order_change := gconv.Int64(v["order_change"])
- if (product_type == "大会员" || product_type == "企业商机管理") && ((order_change != 0) || (order_change == 0 && TimeStrcount(vip_starttime, vip_endtime) > 95)) {
- orderCode := gconv.String(v["order_code"])
- arr = append(arr, orderCode)
- status := kcJob(v)
- if status == 0 {
- break
- }
- }
- cfg.LastkcTime = common.ObjToString(v["autoUpdate"])
- }
- log.Println(strings.Join(arr, "`,`"))
- }
- common.WriteSysConfig(&cfg)
- log.Println("客户成功系统移交定时任务结束")
- }
- func kcJob(data map[string]interface{}) int {
- nowTime := time.Now().Format(date.Date_Full_Layout)
- uId, entId, clueId, saveMap, status := common.ObjToString(data["uid"]), fmt.Sprint(data["ent_id"]), int64(0), map[string]interface{}{}, 1
- clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
- orderCode := gconv.String(data["order_code"])
- saleDep, orderPositionId, salesperson := FindSaleRecord(orderCode)
- log.Println(data["order_code"], saleDep, orderPositionId, salesperson)
- if clueData == nil || len(*clueData) == 0 {
- if saleDep == "销售部" || saleDep == "市场部" {
- return 1
- }
- //创建线索
- //原始订单获取
- position_id := int64(0)
- orderData := Mysql.FindOne("dataexport_order", map[string]interface{}{
- "order_code": orderCode,
- }, "", "")
- if orderData == nil {
- log.Println("原始订单查询不到:", orderCode)
- }
- userId, cluename, phone := common.ObjToString((*orderData)["user_id"]), "", ""
- seatNumber := ""
- if saleDep == "客户成功组" {
- //新增线索
- position_id = 0
- } else if saleDep == "销售部" {
- log.Println("该订单数据销售部业绩,不会创建线索")
- return 0
- } else {
- position_id = orderPositionId
- //其他信息
- seatNumber = "0000"
- }
- cluename = common.ObjToString(data["company_name"])
- phone = common.ObjToString(data["user_phone"])
- if cluename == "" {
- cluename = phone
- }
- trailstatus := "08"
- isGroup, isCommerce := GetCompanyType(cluename, uId) //判断是否集团公司、工商库
- clueId = TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
- "userid": userId,
- "uid": uId,
- "is_assign": common.If(position_id > 0, 1, 0),
- "createtime": nowTime,
- "updatetime": nowTime,
- "cluename": cluename,
- "seatNumber": seatNumber,
- "position_id": position_id,
- "top_cluetype": "4",
- "sub_cluetype": "154",
- "trailstatus": trailstatus,
- "name": phone,
- "phone": phone,
- "is_task": 0,
- "taskstatus": 0,
- "company_nature": isGroup,
- "company_verification": isCommerce,
- "FREEZE_TIME": nowTime,
- "label": common.If(position_id > 0, 1, nil),
- })
- if clueId > 0 {
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(position_id > 0, position_id, -1),
- "change_type": "创建线索",
- "new_value": "系统自动创建",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- clueData = TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
- if clueData == nil || len(*clueData) == 0 {
- return 0
- }
- } else {
- return 1
- }
- }
- clueId = common.Int64All((*clueData)["id"])
- starttime := common.ObjToString(data["vip_starttime"])
- endtime := common.ObjToString(data["vip_endtime"])
- buy_subject := common.IntAll(data["buy_subject"])
- product_type := common.ObjToString(data["product_type"])
- data_spec := common.ObjToString(data["data_spec"])
- userName := common.ObjToString((*clueData)["name"])
- product, company_name := 0, common.ObjToString(data["company_name"])
- productMap := map[string]int{
- "dhy6": 1,
- "dhy7": 2,
- "dhy3": 4,
- "dhy1": 5,
- "dhy2": 6,
- "dhy5": 7,
- "企业商机管理": 8,
- }
- if buy_subject == 1 || buy_subject == 0 {
- entId = common.ObjToString(data["userid"])
- }
- if product_type == "企业商机管理" {
- product = productMap[product_type]
- powerData := TiDb.FindOne("dwd_f_data_equity_info", map[string]interface{}{"uid": uId, "product_type": "商机管理"}, "", "comeintime desc")
- if powerData != nil {
- starttime = common.ObjToString((*powerData)["starttime"])
- endtime = common.ObjToString((*powerData)["endtime"])
- } else {
- log.Println("客成移交权限未查到--", uId)
- return 0
- }
- } else {
- if data_spec == "dhy6" {
- product = 1
- filter := common.ObjToString(data["filter"])
- filterMap := map[string]interface{}{}
- json.Unmarshal([]byte(filter), &filterMap)
- if len(filterMap) > 0 {
- areaCount := common.IntAll(filterMap["areaCount"])
- if areaCount == 1 {
- product = 3
- }
- }
- } else {
- product = productMap[data_spec]
- }
- }
- //同一公司名称(以客户详情-组织机构-公司名称)下的线索需分配给同1人
- saveMap = map[string]interface{}{
- "clue_id": clueId,
- "transfertime": nowTime,
- "service_starttime": starttime,
- "service_endtime": endtime,
- "ent_id": entId,
- "is_task": 1,
- "tasktime": nowTime,
- "taskstatus": 0,
- "tasksource": "1",
- "is_admin": 1,
- "product_access": product,
- "buy_subject": buy_subject,
- "relationship_building_way": 1,
- "inventory_way": 1,
- "training_way": 1,
- "is_pre_sales_training": 0,
- "service_stage": 1,
- "company_name": company_name,
- }
- if TiDb.Count("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}) > 0 {
- csmdata := TiDb.FindOne("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, "", "")
- if csmdata != nil && len(*csmdata) > 0 {
- id := gconv.Int64((*csmdata)["id"])
- log.Println(1111111, id, orderCode)
- //'已移交销售,0移交客成 1移交销售',
- is_transfer := gconv.Int64((*csmdata)["is_transfer"])
- customerPositionId, customerName := cAutoDraw(0, orderPositionId, salesperson, saleDep, true, csmdata)
- log.Println("移交客成positionId", customerPositionId, customerName, saleDep, orderPositionId, salesperson, true)
- oldName := gconv.String((*csmdata)["name"])
- updateMap := map[string]interface{}{
- "is_transfer": 0,
- "is_renewal_protection": 0,
- "product_access": product,
- "buy_subject": buy_subject,
- "transfertime": nowTime,
- "service_starttime": starttime,
- "service_endtime": endtime,
- "ent_id": entId,
- "company_name": company_name,
- "name": customerName,
- "position_id": customerPositionId,
- }
- if is_transfer == 1 {
- //重新进去
- updateMap["relationship_building_way"] = 1
- updateMap["tasksource"] = "1"
- updateMap["inventory_way"] = 1
- updateMap["training_way"] = 1
- updateMap["is_pre_sales_training"] = 0
- updateMap["service_stage"] = 1
- updateMap["is_task"] = 1
- }
- TiDb.Update("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, updateMap)
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": customerPositionId,
- "change_type": "成交客户移交",
- "new_value": "移交至客户成功组",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- if customerPositionId > 0 && is_transfer == 1 {
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": customerPositionId,
- "change_field": "position_id",
- "change_type": "客户成功经理",
- "old_value": common.If(oldName != customerName, customerName, common.If(oldName == "", "/", oldName)),
- "new_value": customerName,
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": customerPositionId,
- "change_type": "加入任务车",
- "new_value": "未建联",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- }
- KcSend(orderCode, customerName)
- TiDb.Update("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{"is_transfer": 1, "updatetime": nowTime, "name": userName})
- }
- } else {
- entIds := common.IntAll(data["ent_id"])
- customerPositionId, customerName := cAutoDraw(entIds, orderPositionId, salesperson, saleDep, false, nil)
- log.Println("移交客成positionId", customerPositionId, customerName, saleDep, orderPositionId, salesperson, false)
- cId, ok, updateId1, updateId2, updateId3 := int64(0), false, int64(0), int64(0), int64(0)
- if TiDb.ExecTx("保存客户", func(tx *sql.Tx) bool {
- saveMap["position_id"] = customerPositionId
- saveMap["name"] = customerName
- cId = TiDb.InsertByTx(tx, "dwd_f_csm_customer_info", saveMap)
- ok = TiDb.UpdateByTx(tx, "dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, map[string]interface{}{"is_transfer": 1, "updatetime": nowTime, "name": userName})
- if customerPositionId > 0 {
- updateId1 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": customerPositionId,
- "change_type": "加入任务车",
- "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": customerPositionId,
- "change_field": "position_id",
- "change_type": "客户成功经理",
- "old_value": "/",
- "new_value": customerName,
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- }
- KcSend(orderCode, customerName)
- updateId2 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": customerPositionId,
- "change_type": "成交客户移交",
- "new_value": "移交至客户成功组",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- return cId > -1 && ok && updateId1 > -1 && updateId2 > -1 && updateId3 > -1
- }) {
- //TiDb.UpdateOrDeleteBySql(`update dwd_f_csm_customer_autodraw_record set count = count + 1 where name = ?`, name)
- log.Println("保存客户成功")
- } else {
- log.Println("保存客户失败!!!", clueId, cId, ok, updateId1, updateId2, updateId3, " 用户信息 ", customerName, customerPositionId, uId)
- }
- }
- return status
- }
- func cAutoDraw(entId int, orderPositionId int64, salesperson, saleDep string, isExist bool, csmdata *map[string]interface{}) (positionId int64, name string) {
- query := `SELECT name,position_id FROM dwd_d_crm_department_level_succbi WHERE bi_pcode = (SELECT bi_code FROM dwd_d_crm_department_level_succbi WHERE name = "客户成功部" and resign=0) and resign = 0 `
- data := TiDb.SelectBySql(query)
- if data == nil || len(*data) == 0 {
- return
- }
- //判断是否需要新增客成数据
- if isExist {
- //用户存在客成数据
- positionid := common.Int64All((*csmdata)["position_id"])
- if positionid != 0 {
- //以前没有,需要找一个新的
- for _, v := range *data {
- deptPositionId := gconv.Int64(v["position_id"])
- if deptPositionId == positionid {
- positionId = positionid
- name = common.ObjToString((*csmdata)["name"])
- return
- }
- }
- }
- //原始用户已离职 查看订单是否有合适的订单
- if saleDep == "客户成功组" {
- positionId = orderPositionId
- name = salesperson
- return
- }
- }
- //客成数据不存在的时候
- //查找企业有没有其他信息
- if entId > 0 {
- entdata := TiDb.Find("dwd_f_csm_customer_info", map[string]interface{}{"ent_id": entId}, "", "", -1, -1)
- if entdata != nil && len(*entdata) > 0 {
- for _, v := range *entdata {
- positionid := common.Int64All(v["position_id"])
- name = common.ObjToString(v["name"])
- for _, v := range *data {
- deptPositionId := gconv.Int64(v["position_id"])
- if deptPositionId == positionId {
- positionId = positionid
- name = common.ObjToString((*csmdata)["name"])
- return
- }
- }
- }
- }
- //原始用户已离职 或者没有查找相关企业客成信息 以订单信息为主
- if saleDep == "客户成功组" {
- positionId = orderPositionId
- name = salesperson
- }
- return
- //没有相同企业的客成信息
- } else {
- //没有人 分配给自己
- if saleDep == "客户成功组" {
- positionId = orderPositionId
- name = salesperson
- return
- }
- return
- }
- }
- func kcAuto() {
- log.Println("客户成功系统自动进入任务车定时任务开始")
- nowTime := time.Now().Format(date.Date_Full_Layout)
- sql := `select * from dwd_f_csm_customer_info where ((relationship_building_way != 1 and inventory_way = 1) or (inventory_way != 1 and training_way = 1)) and is_task = 0`
- data := TiDb.SelectBySql(sql)
- if data != nil && *data != nil && len(*data) > 0 {
- for _, v := range *data {
- relationship_building_way := common.IntAll(v["relationship_building_way"])
- inventory_way := common.IntAll(v["inventory_way"])
- training_way := common.IntAll(v["training_way"])
- positionId := common.Int64All(v["position_id"])
- clueId := common.Int64All(v["clue_id"])
- tasksource, tasksources := common.ObjToString(v["tasksource"]), ""
- taskstatus := common.IntAll(v["taskstatus"])
- if relationship_building_way != 1 && inventory_way == 1 {
- tasksources = "2"
- TiDb.Insert("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,
- })
- } else if inventory_way != 1 && training_way == 1 {
- tasksources = "3"
- TiDb.Insert("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,
- })
- }
- if taskstatus == 1 {
- tasksource = tasksources
- } else {
- if tasksource != "" {
- if !strings.Contains(tasksource, tasksources) {
- tasksource += "," + tasksources
- }
- } else {
- tasksource = tasksources
- }
- }
- TiDb.Update("dwd_f_csm_customer_info", map[string]interface{}{"clue_id": clueId}, map[string]interface{}{
- "tasksource": tasksource,
- "tasktime": nowTime,
- "is_task": 1,
- "taskstatus": 0,
- })
- }
- }
- log.Println("客户成功系统进入任务车定时任务结束")
- }
- func ordersClue() {
- log.Println("后台订单线索定时任务开始")
- lastOrderClueId := cfg.LastOrderClueId
- nowTime := time.Now().Format(date.Date_Full_Layout)
- sql := fmt.Sprintf(`select order_code,order_status,is_backstage_order,pay_money,saleDep,salesperson,user_phone,create_person,saleMoney,user_id,product_type,company_name,autoUpdate from dataexport_order where autoUpdate >= "%s" order by autoUpdate asc`, lastOrderClueId)
- 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"])
- pay_money := common.IntAll(v["pay_money"])
- orderCode := gconv.String(v["order_code"])
- saleDep, _, salesperson := FindSaleRecord(orderCode)
- user_phone := common.ObjToString(v["user_phone"])
- createperson := common.ObjToString(v["create_person"])
- userId, uId, cluename, seatNumber, positionId, trailstatus, clueId := common.ObjToString(v["user_id"]), "", "", "", int64(0), "", int64(0)
- product_type_str2 := `"大会员","企业商机管理","VIP订阅"`
- product_type := common.ObjToString(v["product_type"])
- if order_status == 1 && is_backstage_order == 1 && saleDep != "" && !strings.HasPrefix(user_phone, "9") && strings.Contains(product_type_str2, product_type) {
- //销售部
- query := map[string]interface{}{}
- source := ""
- if product_type == "企业商机管理" {
- query["phone"] = user_phone
- userInfo := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
- if userInfo != nil && len(*userInfo) > 0 {
- uId = common.ObjToString((*userInfo)["uid"])
- userId = common.ObjToString((*userInfo)["userid"])
- source = common.ObjToString((*userInfo)["source"])
- } else {
- log.Println("后台订单--未查询到 ", user_phone)
- break
- }
- } else {
- if !mongodb.IsObjectIdHex(userId) {
- userMapping := TiDb.FindOne("dwd_f_userbase_id_mapping", map[string]interface{}{"position_id": userId}, "", "")
- if userMapping != nil && len(*userMapping) > 0 {
- userId = common.ObjToString((*userMapping)["userid"])
- } else {
- log.Println("后台订单--未查询到 ", user_phone)
- break
- }
- }
- 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"])
- } else {
- log.Println("后台订单--未查询到 ", query, user_phone)
- break
- }
- }
- is_assign := 1
- mailContent := ""
- cluename = common.ObjToString(v["company_name"])
- mailContent = fmt.Sprintf("%s(%s)", cluename, user_phone)
- if cluename == "" {
- cluename = user_phone
- mailContent = user_phone
- }
- if pay_money > 0 {
- trailstatus = "08"
- } else {
- trailstatus = "01"
- }
- isGroup, isCommerce := GetCompanyType(cluename, uId) //判断是否集团公司、工商库
- clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"uid": uId}, "", "")
- if clueData == nil || len(*clueData) == 0 {
- log.Println("saleDep", saleDep)
- if saleDep == "销售部" {
- //撞单
- log.Println("销售部订单", saleDep)
- if strings.Contains(salesperson, ",") {
- log.Println("销售部撞单 ", salesperson)
- if salesperson == "" {
- salesperson = createperson
- }
- }
- log.Println("销售部订单salesperson", salesperson)
- saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"name": salesperson}, "", "")
- if saleData != nil {
- seatNumber = common.ObjToString((*saleData)["seat_number"])
- positionId = common.Int64All((*saleData)["position_id"])
- }
- if IsFreeze(source, pay_money, gconv.String(positionId), trailstatus) {
- //线索需要冻结
- is_assign = -3
- }
- clueId = TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
- "userid": userId,
- "uid": uId,
- "seatNumber": seatNumber,
- "position_id": positionId,
- "is_assign": is_assign,
- "comeintime": nowTime,
- "createtime": nowTime,
- "updatetime": nowTime,
- "cluename": cluename,
- "top_cluetype": "4",
- "sub_cluetype": "154",
- "trailstatus": trailstatus,
- "name": user_phone,
- "phone": user_phone,
- "comeinsource_private": 2,
- "is_task": 0,
- "taskstatus": 0,
- "company_nature": isGroup,
- "company_verification": isCommerce,
- "FREEZE_TIME": nowTime,
- })
- } else if saleDep == "市场部" {
- log.Println("市场部订单", saleDep)
- clueId = TiDb.Insert("dwd_f_crm_clue_info", map[string]interface{}{
- "userid": userId,
- "uid": uId,
- "is_assign": -2,
- "createtime": nowTime,
- "updatetime": nowTime,
- "cluename": cluename,
- "top_cluetype": "4",
- "sub_cluetype": "154",
- "trailstatus": trailstatus,
- "name": user_phone,
- "phone": user_phone,
- "is_task": 0,
- "taskstatus": 0,
- "company_nature": isGroup,
- "company_verification": isCommerce,
- "FREEZE_TIME": nowTime,
- })
- }
- if clueId > 0 {
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(positionId > 0, positionId, -1),
- "change_type": "创建线索",
- "new_value": "系统自动创建",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- if is_assign == -3 {
- //新增冻结记录
- TiDb.Insert("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,
- })
- //移交失败发送消息
- if IsFreeze(source, pay_money, gconv.String(positionId), trailstatus) {
- //发送邮件信息
- OrderCreateFail(positionId, mailContent)
- }
- }
- }
- }
- }
- cfg.LastOrderClueId = common.ObjToString(v["autoUpdate"])
- }
- }
- common.WriteSysConfig(&cfg)
- log.Println("后台订单线索定时任务结束")
- }
- func refundAuto() {
- log.Println("自动移交销售定时任务开始")
- findNowTime := time.Now().AddDate(0, 0, -db.ExpirationPeriod).Format(date.Date_Full_Layout)
- nowTime := time.Now().Format(date.Date_Full_Layout)
- mailData := map[string][]map[string]interface{}{}
- TiDb.SelectByBath(100, func(l *[]map[string]interface{}) bool {
- for _, v := range *l {
- saleId, cluename, company_nature, company_verification, uid, phone, userName := int64(0), "", 0, 0, "", "", ""
- clueId := common.Int64All(v["clue_id"])
- company_name := gconv.String(v["company_name"])
- name := common.ObjToString(v["name"])
- kcposition_id := common.Int64All(v["position_id"])
- isRenewalProtection := common.IntAll(v["is_renewal_protection"])
- clueData := TiDb.FindOne("dwd_f_crm_clue_info", map[string]interface{}{"id": clueId}, "name,phone,company_nature,company_verification,cluename,userid,position_id,uid", "")
- if clueData != nil && len(*clueData) > 0 {
- saleId = common.Int64All((*clueData)["position_id"])
- cluename = common.ObjToString((*clueData)["cluename"])
- userName = gconv.String((*clueData)["name"])
- company_nature = common.IntAll((*clueData)["company_nature"])
- company_verification = common.IntAll((*clueData)["company_verification"])
- uid = common.ObjToString((*clueData)["uid"])
- phone = common.ObjToString((*clueData)["phone"])
- }
- //查询即将到期数据
- if isRenewalProtection == 0 {
- orderData := TiDb.SelectBySql(`select * from dwd_f_userbase_order_info where uid=? and (product_type = "企业商机管理" or product_type = "大会员") and order_status = 1 and refund_status!=1 `, uid)
- if orderData != nil && len(*orderData) > 0 {
- endDate := time.Now().AddDate(0, 0, -db.ExpirationPeriod+1).Unix()
- startDate := time.Now().AddDate(0, 0, -db.ExpirationPeriod).Unix()
- vipEndDate, _ := time.Parse(time.DateTime, gconv.String((*orderData)[0]["vip_endtime"]))
- if vipEndDate.Unix() > startDate && vipEndDate.Unix() < endDate {
- //即将到期
- mailData[name] = append(mailData[name], map[string]interface{}{
- "company_name": company_name,
- "phone": phone,
- "userName": userName,
- "remrk": "1天后即将移交",
- "reason": "成交客户续费失败",
- })
- continue
- }
- }
- }
- isFull := FindUpperLimit(gconv.String(saleId), "", false)
- isAllRefund := false
- myOrders := TiDb.SelectBySql(`select refund_status from dwd_f_userbase_order_info where uid=? and (product_type = "企业商机管理" or product_type = "大会员") and order_status = 1 `, uid)
- if myOrders != nil {
- refundCount := 0
- for _, v := range *myOrders {
- if common.IntAll(v["refund_status"]) == 1 {
- refundCount++
- }
- }
- if len(*myOrders) > 0 && len(*myOrders) == refundCount {
- isAllRefund = true
- }
- }
- if isAllRefund {
- //全退款了
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,is_assign=0,trailstatus="01",position_id=null,seatNumber=null,updatetime=?,comeintime_open=?,comeinsource_open=1,level_open=3,next_trail_time=null,is_task=null,tasktime=null,taskstatus=null,comeinsource_private=null,tasksource=null,is_transfer=0 WHERE id = ?`, nowTime, nowTime, clueId)
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_type": "退回公海",
- "new_value": "成交客户申请退款",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_field": "trailstatus",
- "change_type": "基本信息变更",
- "old_value": "成交客户",
- "new_value": "商机线索",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_type": "客户成功经理",
- "change_field": "position_id",
- "old_value": name,
- "new_value": "/",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_type": "移交销售",
- "new_value": "成交客户申请退款",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- mailData[name] = append(mailData[name], map[string]interface{}{
- "company_name": company_name,
- "phone": phone,
- "userName": userName,
- "remrk": "已移交",
- "reason": "成交客户申请退款",
- })
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
- } else {
- order1 := TiDb.SelectBySql(`select id from dwd_f_userbase_order_info where uid=? and (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime > ? and order_status = 1 `, uid, findNowTime)
- if order1 == nil || len(*order1) == 0 {
- isOk := false
- order3 := TiDb.SelectBySql(`select vip_endtime from dwd_f_userbase_order_info where uid=? and (product_type = "企业商机管理" or product_type = "大会员") and vip_endtime < ? and order_status = 1 `, uid, findNowTime)
- if order3 != nil && len(*order3) > 0 {
- for _, vv := range *order3 {
- if isRenewalProtection == 1 {
- vip_endtime := common.ObjToString(vv["vip_endtime"])
- vip_endtimes, _ := time.ParseInLocation(date.Date_Full_Layout, vip_endtime, time.Local)
- //查询申请保护时间
- renewalTime := time.Now()
- timeData := TiDb.SelectBySql(`select max(createtime) as createtime from dwd_f_crm_clue_change_record where clue_id = ? and change_type="申请续费保护"`, clueId)
- if timeData != nil && len(*timeData) > 0 {
- if gconv.String(gconv.String((*timeData)[0]["createtime"])) != "" {
- renewalTime, _ = time.ParseInLocation(date.Date_Short_Layout, gconv.String((*timeData)[0]["createtime"]), time.Local)
- }
- }
- renewalInt := renewalTime.Unix()
- log.Println("申请保护期时间", clueId, renewalInt)
- log.Println("申请保护期时间222", time.Now().Unix()-vip_endtimes.Unix(), (db.HandoverCycle-1)*86400, (db.HandoverCycle)*86400)
- log.Println("申请保护期时间333", (db.HandoverCycle-1)*86400 < time.Now().Unix()-vip_endtimes.Unix(), time.Now().Unix()-vip_endtimes.Unix() < (db.HandoverCycle)*86400)
- //查看服务到期时间
- if renewalInt != 0 && renewalInt < db.CustomerTime {
- //三个月
- if time.Now().Unix()-vip_endtimes.Unix() < 3*30*86400 {
- isOk = true
- }
- } else if (db.HandoverCycle-2)*86400 < time.Now().Unix()-vip_endtimes.Unix() && time.Now().Unix()-vip_endtimes.Unix() < (db.HandoverCycle-1)*86400 {
- //提前一天提示
- mailData[name] = append(mailData[name], map[string]interface{}{
- "company_name": company_name,
- "phone": phone,
- "userName": userName,
- "remrk": "1天后即将移交",
- "reason": "成交客户续费失败",
- })
- } else if time.Now().Unix()-vip_endtimes.Unix() < db.HandoverCycle*86400 {
- isOk = true
- }
- }
- }
- }
- if !isOk {
- //全到期了
- if saleId > 0 {
- saleData := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": saleId, "resign": 0}, "", "")
- if saleData != nil && len(*saleData) > 0 {
- if FindUpperLimit(gconv.String(saleId), "", false) {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0,is_assign=-3,FREEZE_TIME=? WHERE id = ?`, nowTime, nowTime, nowTime, clueId)
- } else {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, nowTime, clueId)
- }
- } else {
- if company_nature == 0 && company_verification == 1 && cluename != "" {
- adata := TiDb.Find("dwd_f_crm_clue_info", map[string]interface{}{"cluename": cluename, "is_assign": 1}, "seatNumber,position_id", "", -1, -1)
- if adata != nil && len(*adata) > 0 {
- isOks := false
- for _, vv := range *adata {
- position_ids := common.Int64All(vv["position_id"])
- seatNumber := common.ObjToString(vv["seatNumber"])
- saleDatas := TiDb.FindOne("dwd_f_crm_personnel_management", map[string]interface{}{"position_id": position_ids, "resign": 0}, "", "")
- if saleDatas != nil && len(*saleDatas) > 0 {
- saleId = position_ids
- if isFull {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0,is_assign=-3,FREEZE_TIME=? WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, nowTime, clueId)
- } else {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
- }
- isOks = true
- break
- }
- }
- if !isOks {
- sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
- if sdata != nil && len(*sdata) > 0 {
- saleId = common.Int64All((*sdata)[0]["position_id"])
- seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
- if isFull {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0,is_assign=-3,FREEZE_TIME=? WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, nowTime, clueId)
- } else {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
- }
- }
- }
- }
- } else {
- sdata := TiDb.SelectBySql(`SELECT b.name,b.position_id,b.seat_number from dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id where a.bi_pcode = (SELECT bi_pcode from dwd_d_crm_department_level_succbi where position_id = ?) and b.role_id = 3`, saleId)
- if sdata != nil && len(*sdata) > 0 {
- saleId = common.Int64All((*sdata)[0]["position_id"])
- seatNumber := common.ObjToString((*sdata)[0]["seat_number"])
- if isFull {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0,is_assign=-3,FREEZE_TIME=? WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, nowTime, clueId)
- } else {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",position_id=?,seatNumber=?,is_task=1,tasktime=?,top_cluetype="532",sub_cluetype="537",taskstatus=0,tasksource="其他-成交客户续约失败",is_transfer=0 WHERE id = ?`, nowTime, saleId, seatNumber, nowTime, clueId)
- }
- }
- }
- }
- } else {
- if isFull {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",top_cluetype="532",sub_cluetype="537",is_transfer=0,is_assign=-3,FREEZE_TIME=? WHERE id = ?`, nowTime, nowTime, clueId)
- } else {
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_crm_clue_info SET is_unfollow=0,updatetime=?,trailstatus="01",top_cluetype="532",sub_cluetype="537",is_transfer=0 WHERE id = ?`, nowTime, clueId)
- }
- }
- if kcposition_id > 0 {
- mailData[name] = append(mailData[name], map[string]interface{}{
- "company_name": company_name,
- "phone": phone,
- "userName": userName,
- "remrk": "已移交",
- "reason": "成交客户续费失败",
- })
- }
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_type": "基本信息变更",
- "old_value": "成交客户",
- "change_field": "trailstatus",
- "new_value": "商机线索",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": saleId,
- "change_type": "加入任务车",
- "new_value": "线索自动分配-其他-成交客户续约失败",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": common.If(kcposition_id > 0, kcposition_id, -1),
- "change_type": "客户成功经理",
- "change_field": "position_id",
- "old_value": name,
- "new_value": "/",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": saleId,
- "change_type": "移交销售",
- "new_value": "成交客户续费失败,到期自动移交",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- TiDb.UpdateOrDeleteBySql(`UPDATE dwd_f_csm_customer_info SET is_transfer=1 WHERE clue_id = ?`, clueId)
- if isFull {
- //新增冻结记录
- TiDb.Insert("dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": saleId,
- "change_type": "线索冻结",
- "new_value": "销售人员私海已达上限",
- "createtime": nowTime,
- "BCPCID": common.GetRandom(32),
- "operator_id": -1,
- })
- //发送邮件
- mailContent := ""
- if cluename != "" {
- if phone != "" {
- if cluename == phone {
- mailContent = phone
- } else {
- mailContent = fmt.Sprintf("%s(%s)", cluename, phone)
- }
- } else {
- mailContent = cluename
- }
- } else {
- mailContent = phone
- }
- HandOverFail(saleId, mailContent)
- }
- }
- }
- }
- }
- return true
- }, `select ent_id,clue_id,position_id,name,is_renewal_protection,company_name from dwd_f_csm_customer_info where is_transfer = 0`)
- //}, `select ent_id,clue_id,position_id,name,is_renewal_protection,company_name from dwd_f_csm_customer_info where clue_id =1471384`)
- //移交电销提醒
- for i, v := range mailData {
- ExitKcSend(i, v)
- }
- log.Println("自动移交销售定时任务结束")
- }
- func refundAutoHistory() {
- data := TiDb.Find("dwd_f_crm_clue_autodraw_record", nil, "", "", -1, -1)
- if data != nil {
- for _, v := range *data {
- seatNumber := common.ObjToString(v["seatNumber"])
- adata := TiDb.Find("dwd_f_crm_personnel_management", map[string]interface{}{"seat_number": seatNumber}, "", "", -1, -1)
- if adata != nil {
- for _, vv := range *adata {
- if common.IntAll(vv["resign"]) == 0 {
- position_id := common.Int64All(vv["position_id"])
- TiDb.Update("dwd_f_crm_clue_autodraw_record", map[string]interface{}{"seatNumber": seatNumber}, map[string]interface{}{"position_id": position_id})
- break
- }
- }
- }
- }
- }
- }
- func IsFreeze(source string, pay_money int, positionId, trailstatus string) bool {
- log.Println(source, pay_money == 0, FindUpperLimit(gconv.String(
- positionId), "", false), trailstatus)
- if source == "0104" && pay_money == 0 && FindUpperLimit(gconv.String(
- positionId), "", false) {
- return true
- } else if source == "0104" && pay_money > 0 && trailstatus == "08" && FindUpperLimit(gconv.String(
- positionId), "", false) {
- return true
- }
- return false
- }
- func FindSaleRecord(orderCode string) (dept string, positionId int64, position string) {
- recordList := Mysql.SelectBySql("select * from order_sale_record where ordercode=? ORDER BY state ,money ", orderCode)
- if recordList != nil && len(*recordList) > 0 {
- saler_dept := gconv.String((*recordList)[0]["saler_dept"])
- if strings.Contains(saler_dept, "销售") {
- saler_dept = "销售部"
- } else if strings.Contains(saler_dept, "市场") {
- saler_dept = "市场部"
- } else if strings.Contains(saler_dept, "客户成功") {
- saler_dept = "客户成功组"
- } else {
- saler_dept = ""
- }
- return saler_dept, gconv.Int64((*recordList)[0]["saler_Id"]), gconv.String((*recordList)[0]["saler_name"])
- }
- return "", int64(0), ""
- }
- func kcClue(userId, uId, seatNumber, cluename, top_cluetype, sub_cluetype,
- name, phone, position, sourceCode, industry, follow_project_area,
- role, item, subname, topname, remark, demand, department, departments, saleName, source string,
- positionId int64, isGroup, isCommerce int,
- keywords []string) bool {
- clueId, uodateId1, uodateId2, uodateId3, uodateId4, uodateId5 := int64(0), int64(0), int64(0), int64(0), int64(0), int64(0)
- nowTime := time.Now().Format("2006-01-02 15:04:05")
- nowTimes := time.Unix(time.Now().Unix()+3600*12, 0).Format("2006-01-02 15:04:05")
- if TiDb.ExecTx("保存线索", func(tx *sql.Tx) bool {
- clueId = TiDb.InsertByTx(tx, "dwd_f_crm_clue_info", map[string]interface{}{
- "userid": userId,
- "uid": uId,
- "seatNumber": seatNumber,
- "position_id": positionId,
- "is_assign": common.If(positionId > 0, 1, 0),
- "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,
- "remark": remark,
- "customer_demand": demand,
- "FREEZE_TIME": nowTime,
- "label": 1,
- "labelChangeTime": time.Now().Format("2006-01-02"),
- })
- 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,
- })
- 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,
- })
- uodateId5 = TiDb.InsertByTx(tx, "dwd_f_crm_clue_change_record", map[string]interface{}{
- "clue_id": clueId,
- "position_id": positionId,
- "change_field": "sub_cluetype", //222
- "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
- }) {
- 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
- }
- return false
- }
- type OrderInfo struct {
- Id int64
- UserId string
- CompanyName string
- ProductType string
- OrderCode string
- PayMoney float64
- ReturnMoney float64
- UserPhone string
- StartEnd string
- DisKcName string
- UserName string
- SeriveList []string
- SaleName string
- }
- // 客成发送邮箱
- func KcSend(orderCode, personName string) {
- log.Println("客成发邮件", orderCode)
- bigmemberService := map[int64]string{}
- combo := map[int64]string{}
- Mysql.SelectByBath(1, func(l *[]map[string]interface{}) bool {
- bigmemberService[common.Int64All((*l)[0]["id"])] = common.ObjToString((*l)[0]["s_name"])
- return true
- }, `select id,s_name from jianyu.bigmember_service`)
- Mysql.SelectByBath(1, func(l *[]map[string]interface{}) bool {
- combo[common.Int64All((*l)[0]["id"])] = common.ObjToString((*l)[0]["s_name"])
- return true
- }, `select id,s_name from jianyu.bigmember_combo`)
- orderInfo := KcOrderFormat(orderCode, bigmemberService, combo)
- if orderInfo != nil {
- tableAppend := ""
- if len(orderInfo.SeriveList) > 0 {
- tableAppend = fmt.Sprintf(db.KeCheng.Mail.ServiceList, strings.Join(orderInfo.SeriveList, ","))
- }
- if orderInfo.ReturnMoney > 0 {
- tableAppend += fmt.Sprintf(db.KeCheng.Mail.ReturnMoney, orderInfo.ReturnMoney)
- }
- table := ""
- orderInfo.DisKcName = personName
- deptData := Mysql.SelectBySql("select b.mail from jianyu.entniche_department_user a inner join jianyu.entniche_user b on a.dept_id=? and a.user_id=b.id and b.name=? ", db.KeCheng.DeptId, personName)
- adminData := Mysql.SelectBySql(` select c.mail from entniche_department_user a INNER JOIN entniche_user_role b on a.dept_id=59005 and a.user_id = b.user_id and b.role_id=2 INNER JOIN entniche_user c on a.user_id=c.id`)
- table += fmt.Sprintf(db.KeCheng.Mail.Table, orderInfo.ProductType, orderInfo.CompanyName, orderInfo.UserPhone, orderInfo.UserName, orderInfo.OrderCode, orderInfo.PayMoney, orderInfo.StartEnd, orderInfo.DisKcName, orderInfo.SaleName, tableAppend)
- adminMailStr := ""
- if adminData != nil && len(*adminData) > 0 {
- adminMailStr = gconv.String((*adminData)[0]["mail"])
- }
- //发送邮件
- if personName == "" {
- if adminData != nil && len(*adminData) > 0 {
- //发送给管理员
- if adminMailStr != "" {
- gmail := &mail.GmailAuth{
- SmtpHost: db.Mail.SmtpHost,
- SmtpPort: db.Mail.SmtpPort,
- User: db.Mail.User,
- Pwd: db.Mail.Pwd,
- }
- status := mail.GSendMail_q("剑鱼标讯", adminMailStr, "", "", db.KeCheng.Title, fmt.Sprintf(db.KeCheng.Mail.Content, table), "", "", gmail)
- if status {
- log.Println("客成发邮件 send mail success", table, adminMailStr)
- }
- }
- }
- return
- }
- //当事人 管理员发送
- if deptData != nil && len(*deptData) > 0 {
- mailStr := gconv.String((*deptData)[0]["mail"])
- if mailStr != "" || adminMailStr != "" {
- gmail := &mail.GmailAuth{
- SmtpHost: db.Mail.SmtpHost,
- SmtpPort: db.Mail.SmtpPort,
- User: db.Mail.User,
- Pwd: db.Mail.Pwd,
- }
- status := true
- if mailStr == "" {
- status = mail.GSendMail_q("剑鱼标讯", adminMailStr, "", "", db.KeCheng.Title, fmt.Sprintf(db.KeCheng.Mail.Content, table), "", "", gmail)
- } else {
- status = mail.GSendMail_q("剑鱼标讯", mailStr, adminMailStr, "", db.KeCheng.Title, fmt.Sprintf(db.KeCheng.Mail.Content, table), "", "", gmail)
- }
- if status {
- log.Println("客成发邮件 send mail success", table, mailStr, adminMailStr)
- }
- }
- }
- }
- }
- func ExitKcSend(personName string, infoList []map[string]interface{}) {
- //退出客成 即将退出客成信息
- deptData := Mysql.SelectBySql("select b.mail from jianyu.entniche_department_user a inner join jianyu.entniche_user b on a.dept_id=? and a.user_id=b.id and b.name=? ", db.KeCheng.DeptId, personName)
- adminData := Mysql.SelectBySql(` select c.mail from entniche_department_user a INNER JOIN entniche_user_role b on a.dept_id=59005 and a.user_id = b.user_id and b.role_id=2 INNER JOIN entniche_user c on a.user_id=c.id`)
- if personName == "" {
- //没有客成人员
- adminMailStr := ""
- if adminData != nil && len(*adminData) > 0 {
- adminMailStr = gconv.String((*adminData)[0]["mail"])
- }
- if adminMailStr != "" {
- gmail := &mail.GmailAuth{
- SmtpHost: db.Mail.SmtpHost,
- SmtpPort: db.Mail.SmtpPort,
- User: db.Mail.User,
- Pwd: db.Mail.Pwd,
- }
- //正文拼接
- startStr := `<html lang="zh-CN"><head><meta charset="UTF-8"><meta name="viewport"content="width=device-width, initial-scale=1.0"><style>table{width:100%;border-collapse:collapse}th,td{border:1px solid#000;padding:8px;text-align:left}th{background-color:#f2f2f2}</style></head><body><p>以下客户已从或即将从客成系统退出,并移交销售跟进,请收悉,客户明细如下:</p><table><thead><tr><th>序号</th><th>公司名称</th><th>联系人</th><th>姓名</th><th>移交状态</th><th>移交销售原因</th></tr></thead><tbody>`
- for i, v := range infoList {
- startStr += fmt.Sprintf(`<tr><td>%d</td><td>%s</td><td>%s</td><td>%s</td><td>%s</td><td>%s</td></tr>`, i+1, gconv.String(v["company_name"]), gconv.String(v["phone"]), gconv.String(v["userName"]), gconv.String(v["remrk"]), gconv.String(v["reason"]))
- }
- endStr := `</tbody></table><p></body></html>`
- startStr += endStr
- status := mail.GSendMail_q("剑鱼标讯", adminMailStr, "", "", "客户退出客成系统通知", startStr, "", "", gmail)
- if status {
- log.Println("客成发邮件 send mail success", startStr, adminMailStr)
- }
- }
- return
- }
- if deptData != nil && len(*deptData) > 0 {
- mailStr := gconv.String((*deptData)[0]["mail"])
- adminMailStr := ""
- if adminData != nil && len(*adminData) > 0 {
- adminMailStr = gconv.String((*adminData)[0]["mail"])
- }
- if mailStr != "" || adminMailStr != "" {
- gmail := &mail.GmailAuth{
- SmtpHost: db.Mail.SmtpHost,
- SmtpPort: db.Mail.SmtpPort,
- User: db.Mail.User,
- Pwd: db.Mail.Pwd,
- }
- //正文拼接
- startStr := `<html lang="zh-CN"><head><meta charset="UTF-8"><meta name="viewport"content="width=device-width, initial-scale=1.0"><style>table{width:100%;border-collapse:collapse}th,td{border:1px solid#000;padding:8px;text-align:left}th{background-color:#f2f2f2}</style></head><body><p>以下客户已从或即将从客成系统退出,并移交销售跟进,请收悉,客户明细如下:</p><table><thead><tr><th>序号</th><th>公司名称</th><th>联系人</th><th>姓名</th><th>移交状态</th><th>移交销售原因</th></tr></thead><tbody>`
- for i, v := range infoList {
- startStr += fmt.Sprintf(`<tr><td>%d</td><td>%s</td><td>%s</td><td>%s</td><td>%s</td><td>%s</td></tr>`, i+1, gconv.String(v["company_name"]), gconv.String(v["phone"]), gconv.String(v["userName"]), gconv.String(v["remrk"]), gconv.String(v["reason"]))
- }
- endStr := `</tbody></table><p></body></html>`
- startStr += endStr
- status := true
- if mailStr == "" {
- status = mail.GSendMail_q("剑鱼标讯", adminMailStr, "", "", "客户退出客成系统通知", startStr, "", "", gmail)
- } else {
- status = mail.GSendMail_q("剑鱼标讯", mailStr, adminMailStr, "", "客户退出客成系统通知", startStr, "", "", gmail)
- }
- if status {
- log.Println("客成发邮件 send mail success", startStr, mailStr)
- }
- }
- }
- }
- func KcOrderFormat(orderCode string, bigmemberService, combo map[int64]string) *OrderInfo {
- orderData := Mysql.SelectBySql(`SELECT a.id,a.order_code,a.pay_money,a.user_phone,a.vip_starttime,a.vip_endtime,a.product_type,a.filter,a.user_id,a.ent_id,a.company_name,a.create_person,SUM(b.return_money) AS return_money
- FROM jianyu.dataexport_order a
- LEFT JOIN return_money_record b ON (a.order_code=b.order_code)
- WHERE a.order_code=? AND a.order_status=1 AND (a.product_type='大会员' OR a.product_type='大会员-子账号')
- GROUP BY a.id ORDER BY a.autoUpdate`, orderCode)
- data := &OrderInfo{}
- if orderData != nil && len(*orderData) > 0 {
- id := common.Int64All((*orderData)[0]["id"])
- user_phone := common.ObjToString((*orderData)[0]["user_phone"])
- user_id := common.ObjToString((*orderData)[0]["user_id"])
- product_type := common.ObjToString((*orderData)[0]["product_type"])
- serviceList := []string{}
- if filter := common.ObjToString((*orderData)[0]["filter"]); filter != "" {
- filterMap := map[string]interface{}{}
- json.Unmarshal([]byte(filter), &filterMap)
- if level := common.Int64All(filterMap["level"]); level == 5 {
- product_type += "自定义版"
- for _, serversId := range strings.Split(common.ObjToString(filterMap["serversId"]), ",") {
- if serviceName := bigmemberService[common.Int64All(serversId)]; serviceName != "" {
- serviceList = append(serviceList, serviceName)
- }
- }
- } else {
- product_type += combo[common.Int64All(filterMap["comboId"])]
- }
- }
- //联系人姓名
- sqlStr := `SELECT
- a.phone,
- b.NAME AS bname
- FROM
- dwd_f_userbase_contacts a
- INNER JOIN dwd_f_crm_clue_info b ON ( a.phone = ? AND a.baseinfo_id = b.uid )
- LEFT JOIN dwd_f_csm_customer_info c ON ( b.id = c.clue_id)`
- userName := ""
- if user_phone != "" {
- userData := TiDb.SelectBySql(sqlStr, user_phone)
- if userData != nil && len(*userData) > 0 {
- userName = gconv.String((*userData)[0]["bname"])
- }
- }
- data = &OrderInfo{
- Id: id,
- CompanyName: common.ObjToString((*orderData)[0]["company_name"]),
- UserId: user_id,
- ProductType: product_type,
- OrderCode: orderCode,
- PayMoney: common.Float64All((*orderData)[0]["pay_money"]) / 100,
- ReturnMoney: common.Float64All((*orderData)[0]["return_money"]) / 100,
- UserPhone: user_phone,
- StartEnd: fmt.Sprintf("%s--%s", strings.Split(common.ObjToString((*orderData)[0]["vip_starttime"]), " ")[0], strings.Split(common.ObjToString((*orderData)[0]["vip_endtime"]), " ")[0]),
- SeriveList: serviceList,
- SaleName: common.ObjToString((*orderData)[0]["create_person"]),
- UserName: userName,
- }
- }
- return data
- }
|