zhaoqingang
2025-02-10 bc37c44c45d08c2cb42822e08adf429f4bcffb51
测试 场景分析 bug
2个文件已修改
17 ■■■■ 已修改文件
models/locationAnalysis.go 15 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/task_results.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
models/locationAnalysis.go
@@ -393,6 +393,12 @@
                                                    },
                                                },
                                            },
                                            "pic_date": map[string]interface{}{ // 新增按 documentNumber 聚合
                                                "terms": map[string]interface{}{
                                                    "field": "picDate",
                                                    "size":  10000,
                                                },
                                            },
                                            "document_numbers": map[string]interface{}{ // 新增按 documentNumber 聚合
                                                "terms": map[string]interface{}{
                                                    "field": "documentNumber",
@@ -469,10 +475,15 @@
                                                persons = append(persons, docNumBucket.(map[string]interface{})["key"].(string))
                                            }
                                        }
                                        var PicDate string
                                        if docNumBuckets, ok := floorBucket.(map[string]interface{})["pic_data"].(map[string]interface{})["buckets"].([]interface{}); ok {
                                            for _, docNumBucket := range docNumBuckets {
                                                PicDate = docNumBucket.(map[string]interface{})["key"].(string)
                                            }
                                        }
                                        logger.Debugf("floor, persons--,appearCount------------------------------------- %s-- %s --", floor, persons, appearCount)
                                        record := &LocationRecord{
                                            //PicDate:        timestamp,
                                            PicDate:         PicDate,
                                            DocumentNumbers: persons,
                                            CommunityId:     communityId,
                                            Building:        building,
service/task_results.go
@@ -18,7 +18,7 @@
func SaveLocationTaskResults(results []*db.ModelTaskResults) error {
    for _, v := range results {
        err := db.NewModelTaskResultsSearch().SetTaskId(v.ModelTaskID).SetPicDate(v.PicDate).SetFirstLocation(v.Location).FirstOrCreate(v)
        err := db.NewModelTaskResultsSearch().SetTaskId(v.ModelTaskID).SetFirstLocation(v.Location).FirstOrCreate(v)
        if err != nil {
            logger.Errorf("save task result err:%v", err)
            return err