fix: es写入清理缓存

services/elastic/elastic.go

@@ -73,7 +73,7 @@ func EsAddOrEditEdbInfoData(indexName, docId string, item *data_manage.EdbInfoLi
 	}()
 	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
@@ -925,7 +925,7 @@ func EsDeleteEdbInfoData(indexName, docId string) (err error) {
 	}()
 	client := utils.EsClient
 
-	resp, err := client.Delete().Index(indexName).Id(docId).Do(context.Background())
+	resp, err := client.Delete().Index(indexName).Id(docId).Refresh(`true`).Do(context.Background())
 	fmt.Println(resp)
 	if err != nil {
 		return
@@ -1054,7 +1054,7 @@ func EsAddOrEditChartInfoData(indexName, docId string, item *data_manage.ChartIn
 	}()
 	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
@@ -1078,7 +1078,7 @@ func EsDeleteDataV2(indexName, docId string) (err error) {
 	}()
 	client := utils.EsClient
 
-	resp, err := client.Delete().Index(indexName).Id(docId).Do(context.Background())
+	resp, err := client.Delete().Index(indexName).Id(docId).Refresh("true").Do(context.Background())
 	fmt.Println(resp)
 	if err != nil {
 		return
@@ -1303,7 +1303,7 @@ func EsAddOrEditDataInterface(indexName, docId string, item interface{}) (err er
 	}()
 	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
@@ -1751,7 +1751,7 @@ func EsAddOrEditExcelInfoData(indexName, docId string, item *excel.ExcelInfo) (e
 	}()
 	client := utils.EsClient
 
-	resp, e := client.Index().Index(indexName).Id(docId).BodyJson(item).Do(context.Background())
+	resp, e := client.Index().Index(indexName).Id(docId).BodyJson(item).Refresh("true").Do(context.Background())
 	if e != nil {
 		err = fmt.Errorf("resp err, %v", e)
 		return
@@ -1930,7 +1930,7 @@ func EsAddOrEditDataSourceIndex(indexName, docId string, item *dataSourceModel.S
 	}()
 	client := utils.EsClient
 
-	resp, e := client.Index().Index(indexName).Id(docId).BodyJson(item).Do(context.Background())
+	resp, e := client.Index().Index(indexName).Id(docId).BodyJson(item).Refresh("true").Do(context.Background())
 	if e != nil {
 		err = fmt.Errorf("resp err, %v", e)
 		return