预处理备份...已调试完毕

src/jy/extract/extractudp.go

@@ -345,7 +345,6 @@ func ExtractByUdpPre(n_sid, n_eid string, f_sid, f_eid string) {
 	count1 := ext.TaskInfo.FDB.Count("bidding_nomal", query1)
 	count2 := ext.TaskInfo.FDB.Count("bidding_file", query2)
 	log.Debug("待抽取数量：", count1+count2)
-	return
 	list1, _ := ext.TaskInfo.FDB.Find("zktest_bidding_nomal", query1, nil, Fields, false, -1, -1)
 	list2, _ := ext.TaskInfo.FDB.Find("zktest_bidding_file", query2, nil, Fields, false, -1, -1)
 	new_list := append(*list1, *list2...)

src/jy/extract/extractudp_task.go

@@ -24,7 +24,7 @@ func GetExtractUdpTaskInfo() {
 				n_sid, f_sid := s_nomal["sid"], s_file["sid"]
 				n_eid, f_eid := e_nomal["eid"], e_file["eid"]
 				ju.TaskUdpList = ju.TaskUdpList[l:]
-				log.Debug("合并段落...", n_sid, "~", f_sid, "~", n_eid, "~", f_eid)
+				log.Debug("合并段落...", n_sid, "~", n_eid, "~", f_sid, "~", f_eid)
 				ExtractByUdpPre(n_sid, n_eid, f_sid, f_eid)
 			} else {
 				nomal := ju.TaskUdpList[0]["nomal"]
@@ -35,7 +35,7 @@ func GetExtractUdpTaskInfo() {
 			ju.IsGetask = false
 			getasklock.Unlock()
 		} else {
-			time.Sleep(10 * time.Second)
+			time.Sleep(3 * time.Second)
 		}
 	}
 }