正式-判重

udpfilterdup/src/config.json

@@ -17,7 +17,7 @@
     },
     "nextNode": [],
     "isMerger": false,
-    "threads": 5,
+    "threads": 1,
     "specialwords": "(重招|重新招标|勘察|设计|施工|监理|总承包|土石方|可研)",
     "specialtitle_1": "[0-9a-zA-Z一二三四五六七八九十零１２３４５６７８９](次|包|标段|标包|批)",
     "specialtitle_2": "项目（[0-9a-zA-Z一二三四五六七八九十零１２３４５６７８９]）",

udpfilterdup/src/main.go

@@ -104,14 +104,8 @@ func main() {
 
 //测试组人员使用
 func mainT() {
-
-	/*
-	761414
-	ObjectId("5da3f2c5a5cb26b9b79847fc")
-	ObjectId("5db2735ba5cb26b9b7c99c6f")
-	*/
-	//sid = "5da3f2c5a5cb26b9b79847f0"
-	//eid = "5db2735ba5cb26b9b7c99c6f"
+	//sid = "5da3f31aa5cb26b9b798d3aa"
+	//eid = "5da422fba5cb26b9b706984b"
 	mapinfo := map[string]interface{}{}
 	if sid == "" || eid == "" {
 		log.Println("sid,eid参数不能为空")
@@ -121,7 +115,7 @@ func mainT() {
 	mapinfo["lteid"] = eid
 	mapinfo["stop"] = "true"
 	task([]byte{}, mapinfo)
-	time.Sleep(30 * time.Second)
+	time.Sleep(10 * time.Second)
 }
 func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 	fmt.Println("接受的段数据")