融合-初版-

udpfusion/src/config.json

@@ -3,7 +3,7 @@
   "mongodb": {
     "addrName": "192.168.3.207:27092",
     "dbName": "zhengkun",
-    "collName": "zk_data",
+    "collName": "fusion_test",
     "pool": 10,
     "site": {
       "dbname": "zhengkun",

udpfusion/src/main.go

@@ -208,6 +208,9 @@ func startTask(data []byte, mapInfo map[string]interface{}) {
 	log.Println("********************分割线********************")
 	log.Println("********************分割线********************")
 	log.Println("开始处理新增分组... ...")
+
+
+
 	start := int(time.Now().Unix())
 
 	//多线程 - 处理数据

udpfusion/src/weightValueMethod.go

@@ -304,6 +304,42 @@ func dealWithContractTypeScore(tmp map[string]interface{}) int {
 		score = score+4
 	}
 
+	//projectcode agency area city contractname bidamount budget  signaturedate
+	projectcode := qu.ObjToString(tmp["projectcode"])
+	if tmp["projectcode"]!=nil && projectcode !="" {
+		score = score+2
+	}
+	agency := qu.ObjToString(tmp["agency"])
+	if tmp["agency"]!=nil && agency !="" {
+		score = score+2
+	}
+	area := qu.ObjToString(tmp["area"])
+	if tmp["area"]!=nil && area !="" {
+		score = score+2
+	}
+	city := qu.ObjToString(tmp["city"])
+	if tmp["city"]!=nil && city !="" {
+		score = score+2
+	}
+	contractname := qu.ObjToString(tmp["contractname"])
+	if tmp["contractname"]!=nil && contractname !="" {
+		score = score+2
+	}
+	budget := qu.Float64All(tmp["budget"])
+	if tmp["budget"]!=nil && budget !=0.0 {
+		score = score+2
+	}
+	bidamount := qu.Float64All(tmp["bidamount"])
+	if tmp["bidamount"]!=nil && bidamount !=0.0 {
+		score = score+2
+	}
+	signaturedate := qu.Int64All(tmp["signaturedate"])
+	if tmp["signaturedate"]!=nil && signaturedate !=0 {
+		score = score+2
+	}
+
+
+
 	score = score+dealWithLowScoreData(tmp)