|
@@ -371,7 +371,6 @@ func bigCustomer() {
|
|
|
saleleadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"createtime": map[string]interface{}{"$gte": bigSaleTime}}, `{"phone":1,"createtime":1}`, nil, false, -1, -1)
|
|
|
if ok && saleleadsData != nil && len(*saleleadsData) > 0 {
|
|
|
for _, v := range *saleleadsData {
|
|
|
- log.Println("444", v)
|
|
|
sources := common.ObjToString(v["source"])
|
|
|
userid := common.ObjToString(v["userid"])
|
|
|
uid := ""
|
|
@@ -407,7 +406,6 @@ func bigCustomer() {
|
|
|
data_requirement := common.ObjToString(v["data_requirement"])
|
|
|
belongTo, usernickname := "大客户", ""
|
|
|
userData := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{"uid": uid}, "", "")
|
|
|
- log.Println("555", uid, userData)
|
|
|
if userData != nil {
|
|
|
usernickname = common.ObjToString((*userData)["nickname"])
|
|
|
bt := common.ObjToString((*userData)["belong_to"])
|
|
@@ -415,10 +413,8 @@ func bigCustomer() {
|
|
|
continue
|
|
|
}
|
|
|
}
|
|
|
- log.Println("333", userData)
|
|
|
s_sourceid := common.ObjToString((*userData)["s_sourceid"])
|
|
|
if s_sourceid == db.Sourceid {
|
|
|
- log.Println("abhList", data, 2222)
|
|
|
//安博会数据
|
|
|
abhList = append(abhList, map[string]interface{}{
|
|
|
"createTime": nowTime,
|
|
@@ -562,7 +558,6 @@ func bigCustomer() {
|
|
|
}
|
|
|
cfg.BigOrderTime = bigOrderTime
|
|
|
}
|
|
|
- log.Println("abhList", abhList, 11111)
|
|
|
if len(abhList) > 0 {
|
|
|
ABHEmail("big", abhList)
|
|
|
}
|