取出打印+完善测试使用

udpfilterdup/src/config.json

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

udpfilterdup/src/datamap.go

@@ -101,7 +101,6 @@ func NewDatamap(days int, lastid string) *datamap {
 				now1 = pt_time
 			}
 			if qutil.Float64All(now1-pt_time) < datelimit {
-				log.Println(tmp)
 				info := NewInfo(tmp)
 				dkey := qutil.FormatDateWithObj(&pt, qutil.Date_yyyyMMdd)
 				k := fmt.Sprintf("%s_%s_%s", dkey, info.subtype, info.area)

udpfilterdup/src/main.go

@@ -124,20 +124,27 @@ func mainT() {
 		ObjectId("5db2735ba5cb26b9b7c99c6f")
 	*/
 	log.Println("测试开始")
-	sid = "5da3f2c5a5cb26b9b79847fc"
-	eid = "5db2735ba5cb26b9b7c99c6f"
+	if TimingTask {
+		go timedTaskDay()
+		time.Sleep(99999 * time.Hour)
+	}else {
+		//sid = "5da3f2c5a5cb26b9b79847fc"
+		//eid = "5db2735ba5cb26b9b7c99c6f"
+		log.Println(sid,"---",eid)
+		mapinfo := map[string]interface{}{}
+		if sid == "" || eid == "" {
+			log.Println("sid,eid参数不能为空")
+			os.Exit(0)
+		}
+		mapinfo["gtid"] = sid
+		mapinfo["lteid"] = eid
+		mapinfo["stop"] = "true"
+		task([]byte{}, mapinfo)
+		time.Sleep(10 * time.Second)
+	}
+
 
 
-	mapinfo := map[string]interface{}{}
-	if sid == "" || eid == "" {
-		log.Println("sid,eid参数不能为空")
-		os.Exit(0)
-	}
-	mapinfo["gtid"] = sid
-	mapinfo["lteid"] = eid
-	mapinfo["stop"] = "true"
-	task([]byte{}, mapinfo)
-	time.Sleep(10 * time.Second)
 }
 func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 	fmt.Println("接受的段数据")