add DSL must not base documentNumber findAnalyzeCoordinatedMovementsInfos

sunty

2024-04-01 54cd528105b8ef861a793fb8e79c442ff6aa9735

add DSL must not base documentNumber findAnalyzeCoordinatedMovementsInfos

 EsApi.go

@@ -506,7 +506,7 @@
    return result
}

func findAnalyzeCoordinatedMovementsInfos(infos []acmInfo, beforeTime int, afterTime int, frequency int,
func findAnalyzeCoordinatedMovementsInfos(infos []acmInfo, docNumber string, beforeTime int, afterTime int, frequency int,
    indexName string, serverIp string, serverPort string) (map[string]interface{}, error) {
    //baseAddResultIds := make([]addResultIds, 0)
    targetAddResultIds := make([]addResultIds, 0)
@@ -539,6 +539,13 @@
                                    {
                                        "term": {
                                            "cameraId": "` + cInfo.cameraId + `"
                                        }
                                    }
                                ],            
                                "must_not": [
                                        {
                                        "term": {
                                                "documentNumber": "` + docNumber + `"
                                        }
                                    }
                                ]
@@ -701,7 +708,7 @@
        return nil, err
    }
    //fmt.Println(docResult)
    result, err := findAnalyzeCoordinatedMovementsInfos(docResult, beforeTime, afterTime, frequency, indexName, serverIp, serverPort)
    result, err := findAnalyzeCoordinatedMovementsInfos(docResult, docNumber, beforeTime, afterTime, frequency, indexName, serverIp, serverPort)
    if err != nil {
        return nil, err
    }
@@ -2431,6 +2438,11 @@
    return deleteRes, nil
}

//func GetCaptureDaysByDocumentNumber(docNumber string, comId string, indexName string, serverIp string, serverPort string){
//    url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_search"
//    queryDSL := ``
//}

// 按日期范围，服务器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"