|
|
@@ -731,7 +731,7 @@ func isRunning() bool {
|
|
|
// 从数据库构建来源映射
|
|
|
func buildSourceMap(department string) map[string]map[string]interface{} {
|
|
|
sourceMap := map[string]map[string]interface{}{}
|
|
|
- saleSource := TiDb.SelectBySql(fmt.Sprintf(`SELECT source,name FROM d_saleleads_code WHERE department LIKE '%%%s%%' AND is_delete = 1`, department))
|
|
|
+ saleSource := TiDb.SelectBySql(fmt.Sprintf(`SELECT source,name,appoint_email FROM d_saleleads_code WHERE department LIKE '%%%s%%' AND is_delete = 1`, department))
|
|
|
if saleSource != nil {
|
|
|
for _, v := range *saleSource {
|
|
|
source := common.ObjToString(v["source"])
|
|
|
@@ -769,6 +769,7 @@ func processLeads(batch string, committeeTime int64, sourceMap map[string]map[st
|
|
|
dataArr := []map[string]interface{}{}
|
|
|
endtime := int64(0)
|
|
|
saleleadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"createtime": map[string]interface{}{"$gte": committeeTime}}, `{"phone":1,"createtime":1}`, nil, false, -1, -1)
|
|
|
+ //saleleadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"createtime": committeeTime}, `{"phone":1,"createtime":1}`, nil, false, -1, -1)
|
|
|
if ok && saleleadsData != nil {
|
|
|
data := FindBatchData(batch)
|
|
|
for _, v := range *saleleadsData {
|
WH01243