|
@@ -140,6 +140,28 @@ func saleLeads() {
|
|
|
if !iter.Next(&thisData) {
|
|
|
break
|
|
|
}
|
|
|
+ sourceCode := common.ObjToString(thisData["source"])
|
|
|
+ if sourceCode == "" {
|
|
|
+ log.Println("留资没有source", phone)
|
|
|
+ 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 '%市场组%') 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
|
|
|
+ }
|
|
|
ok1, ok2 := FormatData(thisData, "saleLeads")
|
|
|
if !ok1 {
|
|
|
common.WriteSysConfig(&cfg)
|