修改定时 0晨-间隔4小时

udpfilterdup/src/config.json

@@ -2,7 +2,7 @@
     "udpport": ":11995",
     "dupdays": 5,
     "mongodb": {
-        "addr": "172.17.4.187:27083",
+        "addr": "192.168.3.207:27092",
         "pool": 5,
         "db": "qfw",
         "extract": "result_file_20200410",
@@ -34,7 +34,7 @@
     "isMerger": false,
     "isSort":true,
     "lowHeavy":false,
-    "timingTask":false,
+    "timingTask":true,
     "timingSpanDay": 3,
     "timingPubScope": 720,
     "specialwords": "(重招|重新招标|勘察|设计|施工|监理|总承包|土石方|可研)",

udpfilterdup/src/main.go

@@ -108,7 +108,7 @@ func init() {
 
 func main() {
 
-	//TestXiuFu()
+	//TestChuli()
 	//return
 
 	go checkMapJob()
@@ -149,9 +149,9 @@ func mainT() {
 		}
 		mapinfo["gtid"] = sid
 		mapinfo["lteid"] = eid
-		mapinfo["stop"] = "true"
+		//mapinfo["stop"] = "true"
 		task([]byte{}, mapinfo)
-		time.Sleep(10 * time.Second)
+		time.Sleep(99999 * time.Second)
 	}
 }
 func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
@@ -376,6 +376,7 @@ func task(data []byte, mapInfo map[string]interface{}) {
 
 	//任务完成，开始发送广播通知下面节点
 	if n > repeateN && mapInfo["stop"] == nil {
+		log.Println("判重任务完成发送udp")
 		for _, to := range nextNode {
 			sid, _ := mapInfo["gtid"].(string)
 			eid, _ := mapInfo["lteid"].(string)
@@ -662,29 +663,23 @@ func timedTaskDay() {
 	log.Println("部署定时任务")
 	c := cron.New()
 	c.AddFunc("0 0 1 * * ?", func() { movedata() })      //每天凌晨1点执行一次
-	c.AddFunc("0 0 2 * * ?", func() { timedTaskOnce() }) //每天凌晨2点执行一次
+	c.AddFunc("0 0 */4 * * ?", func() { timedTaskOnce() }) //每天凌晨2点执行一次
 	c.Start()
 	//timedTaskOnce()
 }
 func timedTaskOnce() {
 
 	log.Println("开始一次定时任务")
-
 	defer util.Catch()
-
+	//当前时间-8   -4 小时
 	now := time.Now()
-	preTime := time.Date(now.Year(), now.Month(), now.Day()-1, 0, 0, 0, 0, time.Local)
-	curTime := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, time.Local)
+	log.Println(now)
+	preTime := time.Date(now.Year(), now.Month(), now.Day(), now.Hour()-8, 0, 0, 0, time.Local)
+	curTime := time.Date(now.Year(), now.Month(), now.Day(), now.Hour()-4, 0, 0, 0, time.Local)
+	log.Println(preTime,curTime)
 	task_sid := util.BsonIdToSId(bson.NewObjectIdWithTime(preTime))
 	task_eid := util.BsonIdToSId(bson.NewObjectIdWithTime(curTime))
-
 	between_time := curTime.Unix() - (86400 * timingPubScope)
-
-	//task_sid = "5e9f18800000000000000000"
-	//task_eid = "5ea06a000000000000000000"
-	//between_time = int64(1525363200)
-
-
 	log.Println("id区间：",task_sid, task_eid,"时间：", between_time)
 	//区间id
 	q_start := map[string]interface{}{