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

controllers/fix.go

@@ -22,22 +22,22 @@ import (
 //
 //	// ### 2、再修复个人分类、删除不存在指标的分类
 //	// ### 2.1 数据加工
-//	//initFixSelfEdbClassify(utils.EdbClassifyTypeCalculate)
+//	initFixSelfEdbClassify(utils.EdbClassifyTypeCalculate)
 //	fmt.Println("《数据加工》修复个人分类、删除不存在指标的分类完成")
 //	//
 //	//// ### 2.2 衍生指标
-//	//initFixSelfEdbClassify(utils.EdbClassifyTypePredict)
+//	initFixSelfEdbClassify(utils.EdbClassifyTypePredict)
 //	fmt.Println("《衍生指标》修复个人分类、删除不存在指标的分类完成")
 //	//
 //
 //	// 开始图表数据了
 //
 //	// ### 3、修复图表分类完整路径
-//	//initFixChartClassifyPath()
+//	initFixChartClassifyPath()
 //	fmt.Println("修复图表分类完整路径完成")
 //
 //	// ### 4、修复图表分类完整路径
-//	//initFixSelfChartClassify()
+//	initFixSelfChartClassify()
 //	fmt.Println("修复个人分类、删除不存在图表的分类完成")
 //
 //	// ### 5、修复ES数据
@@ -703,6 +703,7 @@ func initEs() {
 	// 更新ES中的指标数据
 	data.AddOrEditAllEdbInfoToEs()
 	fmt.Println("更新ES中的指标数据完成")
+
 	// 更新es中的图表数据
 	data.AddAllChartInfo()
 	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