|
|
@@ -19,7 +19,7 @@ import (
|
|
|
|
|
|
func kcSync() {
|
|
|
log.Println("客户成功系统移交定时任务开始")
|
|
|
- sql := `select * from dwd_f_userbase_order_info where pay_money > 0 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 payable_money > 0 and vip_endtime > "` + time.Now().Format(date.Date_Full_Layout) + `" and autoUpdate > "` + cfg.LastkcTime + `" order by autoUpdate asc`
|
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
|
@@ -54,7 +54,7 @@ func kcJob(data map[string]interface{}) int {
|
|
|
product_type := common.ObjToString(data["product_type"])
|
|
|
data_spec := common.ObjToString(data["data_spec"])
|
|
|
userName := common.ObjToString((*clueData)["name"])
|
|
|
- phone := common.ObjToString((*clueData)["phone"])
|
|
|
+ //phone := common.ObjToString((*clueData)["phone"])
|
|
|
product, company_name := 0, common.ObjToString(data["company_name"])
|
|
|
productMap := map[string]int{
|
|
|
"dhy6": 1,
|
|
|
@@ -70,12 +70,12 @@ func kcJob(data map[string]interface{}) int {
|
|
|
}
|
|
|
if product_type == "企业商机管理" {
|
|
|
product = productMap[product_type]
|
|
|
- powerData := TiDb.FindOne("dwd_f_data_equity_info", map[string]interface{}{"phone": phone, "product_type": "商机管理"}, "", "comeintime desc")
|
|
|
+ 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("客成移交权限未查到--", phone)
|
|
|
+ log.Println("客成移交权限未查到--", uId)
|
|
|
return 0
|
|
|
}
|
|
|
} else {
|
WH01243