Browse Source

fix:修改es的时候,修改完成后,里面刷新es

Roc 2 months ago
parent
commit
cc6b4c4391
2 changed files with 2 additions and 2 deletions
  1. 1 1
      services/elastic/chart.go
  2. 1 1
      services/elastic/edb_info.go

+ 1 - 1
services/elastic/chart.go

@@ -18,7 +18,7 @@ func AddOrEditChartInfoToEsData(indexName, docId string, item *data_manage.Chart
 	}()
 	client := utils.EsClient
 
-	resp, err := client.Index().Index(indexName).Id(docId).BodyJson(item).Do(context.Background())
+	resp, err := client.Index().Index(indexName).Id(docId).BodyJson(item).Refresh("true").Do(context.Background())
 	if err != nil {
 		fmt.Println("新增失败:", err.Error())
 		return err

+ 1 - 1
services/elastic/edb_info.go

@@ -18,7 +18,7 @@ func EsAddOrEditEdbInfoData(indexName, docId string, item *data_manage.EdbInfoEs
 	}()
 	client := utils.EsClient
 
-	resp, err := client.Index().Index(indexName).Id(docId).BodyJson(item).Do(context.Background())
+	resp, err := client.Index().Index(indexName).Id(docId).BodyJson(item).Refresh("true").Do(context.Background())
 	if err != nil {
 		fmt.Println("新增失败:", err.Error())
 		return err