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

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,12 @@ 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数据修复完成")
 }

services/data/data_approve/approve.go

@@ -1099,7 +1099,6 @@ func CheckOpenApprove(dataType int) (opening bool, err error) {
 
 	// 查看审批节点
 	if flowItem.DataApproveFlowId > 0 {
-
 		nodeOb := new(dataApproveModel.DataApproveNode)
 		nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ? `, dataApproveModel.DataApproveNodeCols.DataApproveFlowId, dataApproveModel.DataApproveNodeCols.CurrVersion)
 		nodePars := make([]interface{}, 0)

services/data/data_approve/approve_flow.go

@@ -84,6 +84,9 @@ func SaveDataApproveFlow(flow *request.DataApproveFlowSaveReq) (ok bool, msg str
 
 		biFlowNodeItems := make([]*DataApprove.DataApproveNode, 0)
 		for _, node := range flow.Nodes {
+			if node.Users == nil || len(node.Users) == 0 {
+				continue
+			}
 			flowNode := new(DataApprove.DataApproveNode)
 			flowNode.ApproveType = node.ApproveType
 			flowNode.CurrVersion = flowInfo.CurrVersion

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(