From 6f10f72b074455ba473f82a20b76fa20452a4114 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期四, 09 五月 2024 09:53:07 +0800
Subject: [PATCH] add AnalyzeCoordinatedMovements 同行目标按照档案编号分组
---
EsApi.go | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index c293036..c33e153 100644
--- a/EsApi.go
+++ b/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
}
--
Gitblit v1.8.0