From 02f9af857c72559323ada1edd27a0af6be3c038b Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期六, 08 二月 2025 18:59:14 +0800
Subject: [PATCH] 测试 场景分析 bug
---
models/locationAnalysis.go | 28 +++++++++++++++-------------
1 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/models/locationAnalysis.go b/models/locationAnalysis.go
index de0e469..1bd1828 100644
--- a/models/locationAnalysis.go
+++ b/models/locationAnalysis.go
@@ -133,7 +133,7 @@
// 鏍规嵁閰嶇疆鐨勬椂闂存澶╂暟, 姣忓ぉ鐨勬椂闂磋寖鍥村唴锛� 閲嶇偣浜哄憳绫诲瀷鎴栬�呯壒瀹氭爣绛句汉鍛樺嚭鐜扮殑妤煎眰娆℃暟瓒呰繃闃堝��
results := make([]*db.ModelTaskResults, 0)
- var baseFilter, labelFilter, keyFilter, lastFilter []LocationPersonInfo
+ var baseFilter, labelFilter, keyFilter []LocationPersonInfo
var document_number_map = make(map[string]LocationPersonInfo)
var document_number_list []string
err := db.GetDB().Raw(`
@@ -186,13 +186,11 @@
}
logger.Debugf("task %s match label result %d", m.Task.Name, len(labelFilter))
+ document_number_list = []string{}
+ for _, i := range labelFilter {
+ document_number_list = append(document_number_list, i.Id)
+ }
}
-
- document_number_list = []string{}
- for _, i := range labelFilter {
- document_number_list = append(document_number_list, i.Id)
- }
-
if len(m.KeyTypes) > 0 {
//keyTypes := strings.Split(m.KeyPersonType, ",")
err := db.GetDB().Raw(`
@@ -214,7 +212,7 @@
}
logger.Debugf("task %s match key person result %d", m.Task.Name, len(keyFilter))
}
- logger.Debugf("task %s last result %d", m.Task.Name, len(lastFilter))
+ //logger.Debugf("task %s last result %d", m.Task.Name, len(lastFilter))
document_number_list = []string{}
for _, i := range keyFilter {
document_number_list = append(document_number_list, i.Id)
@@ -222,10 +220,12 @@
person.PersonType = i.PersonType
document_number_map[i.DocumentNumber] = person
}
+ logger.Debugf("document_number_list %s last result %s", m.Task.Name, document_number_list)
records, err := queryEsLocation(db.GetEsClient(), m, document_number_list)
if err != nil {
return err
}
+ logger.Debugf("records %s last result %s", m.Task.Name, records)
domains, err := domainToLocation(records)
if err != nil {
return err
@@ -346,8 +346,8 @@
filters = append(filters, map[string]interface{}{
"range": map[string]interface{}{
"picDate": map[string]interface{}{
- "gte": start.Format(time.RFC3339),
- "lte": end.Format(time.RFC3339),
+ "gte": start.Format("2006-01-02 15:04:05"),
+ "lte": end.Format("2006-01-02 15:04:05"),
},
},
})
@@ -448,17 +448,17 @@
if orgBuckets, ok := aggs["orgs"].(map[string]interface{})["buckets"].([]interface{}); ok {
for _, orgBucket := range orgBuckets {
orgId := orgBucket.(map[string]interface{})["key"].(string)
-
+ logger.Debugf("orgId--------------------------------------- %s", orgId)
// 瑙ｆ瀽鎸塩ommunityId鐨勮仛鍚堢粨鏋�
if communityBuckets, ok := orgBucket.(map[string]interface{})["community"].(map[string]interface{})["buckets"].([]interface{}); ok {
for _, communityBucket := range communityBuckets {
communityId := communityBucket.(map[string]interface{})["key"].(string)
-
+ logger.Debugf("communityId--------------------------------------- %s", communityId)
// 瑙ｆ瀽鎸塨uilding鐨勮仛鍚堢粨鏋�
if locationBuckets, ok := communityBucket.(map[string]interface{})["location"].(map[string]interface{})["buckets"].([]interface{}); ok {
for _, locationBucket := range locationBuckets {
building := locationBucket.(map[string]interface{})["key"].(string)
-
+ logger.Debugf("building--------------------------------------- %s", building)
// 瑙ｆ瀽鎸塮loor鐨勮仛鍚堢粨鏋�
if floorBuckets, ok := locationBucket.(map[string]interface{})["floor"].(map[string]interface{})["buckets"].([]interface{}); ok {
for _, floorBucket := range floorBuckets {
@@ -471,6 +471,8 @@
persons = append(persons, docNumBucket.(map[string]interface{})["key"].(string))
}
}
+
+ logger.Debugf("floor--------------------------------------- %s-- %s --", floor, appearCount)
record := &LocationRecord{
//PicDate: timestamp,
DocumentNumbers: persons,
--
Gitblit v1.8.0