Merge branch 'feature/ppt_batch_refresh' into debug

services/data/edb_refresh.go

@@ -51,23 +51,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, ok := <-EdbRefreshHandling:
+			if !ok {
+				return
+			}
+			go EdbRefreshTask(item)
+		}
+	}
 }
 
 // EdbRefreshTask 指标刷新任务