add AnalyzeCoordinatedMovements 同行目标按照档案编号分组

sunty

2024-05-09 6f10f72b074455ba473f82a20b76fa20452a4114

add AnalyzeCoordinatedMovements 同行目标按照档案编号分组

 EsApi.go

@@ -636,6 +636,7 @@
            }
        }
    }

    rdbaseIds := removeDuplicates(baseIds)
    rdtargetIds := removeDuplicates(targetIds)
    baseInfos, err := GetInfosByIds(rdbaseIds, indexName, serverIp, serverPort)
@@ -646,9 +647,21 @@
    if err != nil {
        return nil, err
    }
    docNumberMap := make(map[string][]interface{})
    for _, tinfo := range targetInfos {
        docNumber := tinfo["documentNumber"].(string)
        docNumberMap[docNumber] = append(docNumberMap[docNumber], tinfo)
    }
    targetRecordInfos := make([]map[string]interface{}, 0)
    for docNumber, infos := range docNumberMap {
        ifs := make(map[string]interface{})
        ifs["documentNumber"] = docNumber
        ifs["recordInfos"] = infos
        targetRecordInfos = append(targetRecordInfos, ifs)
    }
    result := make(map[string]interface{})
    result["baseRecordInfo"] = baseInfos
    result["targetRecordInfo"] = targetInfos
    result["targetRecordInfo"] = targetRecordInfos
    return result, nil
}