备份

standardata/src/config.json

@@ -2,10 +2,10 @@
   "mgofrom": "192.168.3.207:27092",
   "mgofromsize":5,
   "mgofromdb":"qfw",
-  "mgoto": "192.168.3.205:27082,192.168.3.205:27083",
+  "mgoto": "192.168.3.207:27092",
   "mgotosize":5,
   "mgotodb":"mixdata",
-  "mgoent": "192.168.3.205:27082,192.168.3.205:27083",
+  "mgoent": "192.168.3.207:27092",
   "mgoentsize":5,
   "mgoentdb":"mixdata",
   "extractcoll":"bidding",
@@ -30,6 +30,8 @@
     }
   },
   "redis": "winner=127.0.0.1:6379,buyer=127.0.0.1:6379,agency=127.0.0.1:6379",
-  "username": "dataAnyWrite",
-  "password": "data@dataAnyWrite"
+  "username": "",
+  "password": "",
+  "username_bf": "dataAnyWrite",
+  "password_bf": "data@dataAnyWrite"
 }

standardata/src/standarwinner.go

@@ -69,6 +69,7 @@ func winnerStandarData(db string, query map[string]interface{}) {
 					data["mobilephone"] = timesMobilePhone
 					data["institute_type"] = "企业"
 					_id := MongoTo.Save(winnerent, data)
+					//有问题... ...
 					redis.PutRedis("winner", winnerbd, winner, _id.(primitive.ObjectID).Hex(), -1)
 					savetoerr = false
 				}
@@ -159,6 +160,7 @@ func historywinner(db, fromcoll string) {
 			if winner != "" && utf8.RuneCountInString(winner) > 4 {
 				winnerperson := qu.ObjToString(tmp["winnerperson"])
 				winnertel := qu.ObjToString(tmp["winnertel"])
+				//存在...更新
 				b, _ := redis.ExistRedis("winner", winnerbd, winner)
 				if b {
 					if winnerperson != "" || winnertel != "" {
@@ -285,7 +287,7 @@ func winMegerIndustry(id string, ps map[string]interface{}) map[string]interface
 	//contact
 	contact := tmp["contact"].(primitive.A)
 	contact = append(contact, ps)
-	//bid_contact
+	//bid_contact - 去重
 	bid_contacts, contacts := bid_contact(contact)
 	if len(bid_contacts) > 0 {
 		data["bid_contact"] = bid_contacts

standardata/src/task.go

@@ -10,6 +10,7 @@ import (
 )
 
 func task_standarData() {
+
 	mgofromdb := qu.ObjToString(sysconfig["mgofromdb"])
 	c := cron.New()
 	_ = c.AddFunc("0 30 4 * * *", func() {

standardata/src/util.go

@@ -869,7 +869,7 @@ func PCDScoreByDistrictSim(stype, t string, score float64, ps, cs, ds *map[strin
 	}
 }
 
-//bid_contact
+//bid_contact - 联系人+电话
 func bid_contact(tc primitive.A) ([]contactPersonPhone, []interface{}) {
 	contact_person_phone := make(map[string]uint32)
 	contact_person_phone_time := make(map[string]int64)

udp_city/src/config.json

@@ -15,6 +15,5 @@
       "stype":"hangye",
       "memo": "生kv招标分类"
     }
-
   ]
 }

udpdataclear/udpSensitiveWords/util/udpdata.go

@@ -155,7 +155,6 @@ func tremQuery(name string) bool {
 	}
 	return false
 }
-
 func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 	task <- struct{}{}
 	defer func() {
@@ -197,6 +196,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 		log.Println(string(data))
 	}
 }
+
 func handleData(datas []string) string {
 	dataslen := len(datas)
 	del := map[int]bool{}