fix

services/data/edb_refresh.go

@@ -6,6 +6,7 @@ import (
 	"eta/eta_api/utils"
 	"fmt"
 	"sync"
+	"time"
 )
 
 var (
@@ -51,23 +52,24 @@ func PushEdb2Refresh(item EdbQueueRefreshReq) {
 
 // HandleEdbRefreshQueue 排队刷新指标
 func HandleEdbRefreshQueue() {
-	//defer func() {
-	//	if err := recover(); err != nil {
-	//		tips := fmt.Sprintf("[HandleEdbRefreshQueue] panic: %v", err)
-	//		fmt.Println(tips)
-	//		utils.FileLog.Info(tips)
-	//	}
-	//}()
-	//fmt.Println("HandleEdbRefreshQueue start")
-	//
-	//for {
-	//	select {
-	//	case item := <-EdbRefreshHandling:
-	//		go EdbRefreshTask(item)
-	//	default:
-	//		continue
-	//	}
-	//}
+	defer func() {
+		if err := recover(); err != nil {
+			tips := fmt.Sprintf("[HandleEdbRefreshQueue] panic: %v", err)
+			fmt.Println(tips)
+			utils.FileLog.Info(tips)
+		}
+	}()
+	fmt.Println("HandleEdbRefreshQueue start")
+
+	for {
+		select {
+		case item := <-EdbRefreshHandling:
+			go EdbRefreshTask(item)
+		case <-time.After(time.Second * 2):
+			//fmt.Println("timeout")
+			continue
+		}
+	}
 }
 
 // EdbRefreshTask 指标刷新任务