|
@@ -371,7 +371,7 @@ func (jy *RepairRule) RepairDelete() {
|
|
|
client := JyEs.GetEsConn()
|
|
|
defer JyEs.DestoryEsConn(client)
|
|
|
|
|
|
- _, err := client.Delete().Index(EsIndex).Type(EsType).Id(id).Refresh("true").Do(context.TODO())
|
|
|
+ _, err := client.Delete().Index(EsIndex).Id(id).Refresh("true").Do(context.TODO())
|
|
|
if err != nil {
|
|
|
log.Println("delete es err:", err)
|
|
|
}
|
|
@@ -1118,7 +1118,7 @@ func ModifyData1(tmp map[string]interface{}, user map[string]interface{}) (err m
|
|
|
//删除es
|
|
|
client := JyEs.GetEsConn()
|
|
|
defer JyEs.DestoryEsConn(client)
|
|
|
- _, err1 := client.Delete().Index(EsIndex).Type(EsType).Id(id).Refresh("true").Do(context.TODO())
|
|
|
+ _, err1 := client.Delete().Index(EsIndex).Id(id).Refresh("true").Do(context.TODO())
|
|
|
if err1 != nil {
|
|
|
log.Println("delete es err:", err1)
|
|
|
}
|