add DeleteByDocumentNumber

sunty

2024-03-27 aed591b550b73250a06c07889705ef7b697ae443

add DeleteByDocumentNumber

 EsApi.go

@@ -2400,6 +2400,38 @@
}

// 按日期范围，服务器Id删除数据
func DeleteByDocumentNumber(docNumber []string, serverIp string, serverPort string, indexName string) (total int, err error) {

    url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
    docNumbers := strings.Replace(strings.Trim(fmt.Sprint(docNumber), "[]"), " ", "\",\"", -1)
    deleteJson := `{
    "query":{
        "bool":{
            "filter":[
            {
                "terms":{
                    "documentNumber":["` + docNumbers + `"]
                }
            }
            ]
        }
    }
}    `
    fmt.Println(url)
    fmt.Println(deleteJson)
    return
    buf, err := EsReq("POST", url, []byte(deleteJson))
    if err != nil {
        return -1, errors.New("请求失败")
    }
    deleteRes, err := SourceDeleted(buf)
    if err != nil {
        return -1, errors.New("解码失败")
    }
    return deleteRes, nil
}

// 按日期范围，服务器Id删除数据
func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (total int, err error) {
    url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
    deleteJson := `{