Browse Source

Merge remote-tracking branch 'origin/eta/2.3'

Roc 3 months ago
parent
commit
71080bc5e4
2 changed files with 34 additions and 27 deletions
  1. 33 26
      controllers/fix.go
  2. 1 1
      utils/elastic.go

+ 33 - 26
controllers/fix.go

@@ -15,31 +15,36 @@ import (
 // @Description: 数据修复
 // @author: Roc
 // @datetime 2024-12-02 09:29:56
-func init() {
-	// ### 1、先修复指标分类完整路径
-	//initFixEdbClassifyPath()
-
-	// ### 2、再修复个人分类、删除不存在指标的分类
-	// ### 2.1 数据加工
-	//initFixSelfEdbClassify(utils.EdbClassifyTypeCalculate)
-	//
-	//// ### 2.2 衍生指标
-	//initFixSelfEdbClassify(utils.EdbClassifyTypePredict)
-	//
-
-	// 开始图表数据了
-
-	// ### 3、修复图表分类完整路径
-	//initFixChartClassifyPath()
-
-	// ### 4、修复图表分类完整路径
-	//initFixSelfChartClassify()
-
-	// ### 5、修复ES数据
-	//initEs()
-
-	//fmt.Println("修复完成")
-}
+//func init() {
+//	// ### 1、先修复指标分类完整路径
+//	initFixEdbClassifyPath()
+//	fmt.Println("修复指标分类完整路径完成")
+//
+//	// ### 2、再修复个人分类、删除不存在指标的分类
+//	// ### 2.1 数据加工
+//	//initFixSelfEdbClassify(utils.EdbClassifyTypeCalculate)
+//	fmt.Println("《数据加工》修复个人分类、删除不存在指标的分类完成")
+//	//
+//	//// ### 2.2 衍生指标
+//	//initFixSelfEdbClassify(utils.EdbClassifyTypePredict)
+//	fmt.Println("《衍生指标》修复个人分类、删除不存在指标的分类完成")
+//	//
+//
+//	// 开始图表数据了
+//
+//	// ### 3、修复图表分类完整路径
+//	//initFixChartClassifyPath()
+//	fmt.Println("修复图表分类完整路径完成")
+//
+//	// ### 4、修复图表分类完整路径
+//	//initFixSelfChartClassify()
+//	fmt.Println("修复个人分类、删除不存在图表的分类完成")
+//
+//	// ### 5、修复ES数据
+//	initEs()
+//
+//	fmt.Println("修复完成")
+//}
 
 // initFixEdbClassifyPath
 // @Description: 修复分类完整路径
@@ -696,9 +701,11 @@ func updateChartPath(item *data_manage.ChartClassifyItems, classifyNamePath, cla
 // @datetime 2024-11-29 16:18:02
 func initEs() {
 	// 更新ES中的指标数据
-	//data.AddOrEditAllEdbInfoToEs()
+	data.AddOrEditAllEdbInfoToEs()
+	fmt.Println("更新ES中的指标数据完成")
 	// 更新es中的图表数据
 	data.AddAllChartInfo()
+	fmt.Println("更新ES中的图表数据完成")
 
 	fmt.Println("全部es数据修复完成")
 }

+ 1 - 1
utils/elastic.go

@@ -21,7 +21,7 @@ func initEs() {
 		elastic.SetSniff(false),
 	}
 	if logInfo != nil {
-		clientOptionFuncList = append(clientOptionFuncList, elastic.SetTraceLog(logInfo))
+		clientOptionFuncList = append(clientOptionFuncList, elastic.SetErrorLog(logInfo))
 	}
 
 	client, err := elastic.NewClient(