注册渠道获取

clueSync/jobutil.go

@@ -699,6 +699,31 @@ func saleLeads() {
 	log.Println("query :", query)
 	iter := session.DB(db.Mgo.DbName).C("saleLeads").Find(&query).Sort("_id").Iter()
 	thisData := map[string]interface{}{}
+	filterArr := []string{"-pc", "-app", "-wx", "-h5"}
+	sourceMap := map[string]string{}
+	saleLeadsConfig := TiDb.Find("saleLeads_config", map[string]interface{}{
+		"status": 0,
+	}, "groupName", "", -1, -1)
+	if saleLeadsConfig == nil || len(*saleLeadsConfig) == 0 {
+		log.Println("线索卡点", "缺少留资分类名称", "saleLeads", thisData, lastId)
+		return
+	}
+	sourceArr := []string{}
+	for _, v := range *saleLeadsConfig {
+		sourceArr = append(sourceArr, fmt.Sprintf(`department   LIKE '%%%s%%'`, gconv.String(v["groupName"])))
+	}
+	sql := fmt.Sprintf(`SELECT source,name FROM d_saleleads_code WHERE ( %s) AND is_delete = 1`, strings.Join(sourceArr, " or   "))
+	saleSource := TiDb.SelectBySql(sql)
+	if saleSource != nil && len(*saleSource) > 0 {
+		for _, v := range *saleSource {
+			source := common.ObjToString(v["source"])
+			name := common.ObjToString(v["name"])
+			for _, s := range filterArr {
+				name = strings.ReplaceAll(name, s, "")
+			}
+			sourceMap[source] = name
+		}
+	}
 	for {
 		if !iter.Next(&thisData) {
 			break
@@ -709,19 +734,6 @@ func saleLeads() {
 			continue
 		}
 		//
-		filterArr := []string{"-pc", "-app", "-wx", "-h5"}
-		sourceMap := map[string]string{}
-		saleSource := TiDb.SelectBySql(`SELECT source,name FROM d_saleleads_code WHERE (department LIKE '%大客户%' or department LIKE '%市场组%' or department LIKE '%咨询组%' or department LIKE '%运营部%') AND is_delete = 1`)
-		if saleSource != nil && len(*saleSource) > 0 {
-			for _, v := range *saleSource {
-				source := common.ObjToString(v["source"])
-				name := common.ObjToString(v["name"])
-				for _, s := range filterArr {
-					name = strings.ReplaceAll(name, s, "")
-				}
-				sourceMap[source] = name
-			}
-		}
 		if sourceMap[sourceCode] != "" {
 			continue
 		}