Browse Source

feat:潜在客户

wangshan 1 year ago
parent
commit
2c1218c8ce
1 changed files with 7 additions and 0 deletions
  1. 7 0
      src/jfw/modules/bigmember/src/entity/analysisEntName.go

+ 7 - 0
src/jfw/modules/bigmember/src/entity/analysisEntName.go

@@ -122,11 +122,18 @@ func GetEntInfo(entName []string, p string) (entName_r []*EnterQYXYInfo) {
 				"$in": entName,
 				"$in": entName,
 			}
 			}
 		}
 		}
+		var isExist = map[string]bool{}
 		sess := db.Mgo_Ent.GetMgoConn()
 		sess := db.Mgo_Ent.GetMgoConn()
 		defer db.Mgo_Ent.DestoryMongoConn(sess)
 		defer db.Mgo_Ent.DestoryMongoConn(sess)
 		it := sess.DB(db.Mgo_Ent.DbName).C("qyxy_std").Find(query).Select(map[string]interface{}{"company_name": 1, "_id": 1, "company_area": 1, "company_city": 1}).Iter()
 		it := sess.DB(db.Mgo_Ent.DbName).C("qyxy_std").Find(query).Select(map[string]interface{}{"company_name": 1, "_id": 1, "company_area": 1, "company_city": 1}).Iter()
 		for m := make(map[string]interface{}); it.Next(&m); {
 		for m := make(map[string]interface{}); it.Next(&m); {
 			if m["company_name"] != nil && m["company_name"].(string) != "" {
 			if m["company_name"] != nil && m["company_name"].(string) != "" {
+				if p == "C" {
+					if isExist[qutil.ObjToString(m["company_name"])] {
+						continue
+					}
+					isExist[qutil.ObjToString(m["company_name"])] = true
+				}
 				entName_r = append(entName_r, &EnterQYXYInfo{
 				entName_r = append(entName_r, &EnterQYXYInfo{
 					Id:   m["_id"].(string),
 					Id:   m["_id"].(string),
 					Name: qutil.ObjToString(m["company_name"]),
 					Name: qutil.ObjToString(m["company_name"]),