移除到访小区的判断

zhangzengfei

2024-08-28 1eedcea2e1b3015a2cbaf0882340bddd4eb604b5

移除到访小区的判断

 cache/cache.go

@@ -68,8 +68,9 @@
    var dbpApi db.DbPersons
    total, e := dbpApi.GetPersonTotal("")

    var psApi db.PersonStatus
    accessAreas, _ := psApi.GetPersonAccessedAreas()
    // 暂时去掉到访小区过滤
    //var psApi db.PersonStatus
    //accessAreas, _ := psApi.GetPersonAccessedAreas()

    logger.Debugf("抓拍档案库共有%d条记录", total)
    if e == nil && total > 0 {
@@ -108,14 +109,14 @@
                        continue
                    }

                    for _, areaId := range accessAreas[value.Id] {
                        if _, ok := CaptureDbMap.Area[areaId]; !ok {
                            CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
                        }

                        CaptureDbMap.Area[areaId].Set(value.Id, value)
                        CaptureDbMap.Area[areaId].Settime()
                    //for _, areaId := range accessAreas[value.Id] {
                    if _, ok := CaptureDbMap.Area[areaId]; !ok {
                        CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
                    }

                    CaptureDbMap.Area[areaId].Set(value.Id, value)
                    CaptureDbMap.Area[areaId].Settime()
                    //}
                }

                CaptureDbMap.Unlock()

 cache/shardmap/shardmap.go

@@ -4,7 +4,6 @@

import (
    "basic.com/pubsub/protomsg.git"
    "fmt"
    "sdkCompare/db"
    "sync"
    //"encoding/json"
@@ -94,7 +93,7 @@
func (s *ShardMap) Walk(wf wfOp, sourceFea []float32, baseScore float32) (targets []*protomsg.SdkCompareEach) {
    var wg sync.WaitGroup
    var lock sync.Mutex
    fmt.Printf("Walk shards len %d\n", len(s.shards))
    //fmt.Printf("Walk shards len %d\n", len(s.shards))

    for _, si := range s.shards {
        var tempsi shardItem = *si