zhangzengfei
2024-08-28 311f41bc841346935c95f58965c8d515f10584fc
添加调试日志
4个文件已修改
13 ■■■■■ 已修改文件
cache/cache.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
cache/shardmap/shardmap.go 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
compare/capture.go 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
compare/compare.go 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
cache/cache.go
@@ -124,6 +124,10 @@
        }
        wg.Wait()
        logger.Debug("抓拍档案库人员缓存完成用时:", time.Since(temptime))
        for k, v := range CaptureDbMap.Area {
            logger.Debugf("Cache area %s item len %d ", k, v.GetLen())
        }
    }
}
cache/shardmap/shardmap.go
@@ -4,6 +4,7 @@
import (
    "basic.com/pubsub/protomsg.git"
    "fmt"
    "sdkCompare/db"
    "sync"
    //"encoding/json"
@@ -93,6 +94,8 @@
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))
    for _, si := range s.shards {
        var tempsi shardItem = *si
compare/capture.go
@@ -1,6 +1,7 @@
package compare
import (
    "fmt"
    "sdkCompare/cache"
    "basic.com/pubsub/protomsg.git"
@@ -52,6 +53,7 @@
            continue
        }
        fmt.Printf("Walk area %s, cache len %d\n", key, val.GetLen())
        targets := val.Walk(DoSdkCompare, fFeature, baseScore)
        if len(targets) > 0 {
            // 比对结果去重, 同一个人到访过多个小区, 缓存数据内会有多条记录
compare/compare.go
@@ -30,6 +30,8 @@
        baseScore = 0
    }
    logger.Debugf("Compare args treeNodes %+v, is all %v, target %s, feature len %d", args.TreeNodes, args.IsCompareAll, args.CompareTarget, len(fFeature))
    var response protomsg.SdkCompareResult
    // 抓拍库比对
@@ -42,7 +44,7 @@
        response = capturePersonsCompere(args, fFeature, baseScore)
    }
    logger.Debugf("Compare Target %s result len %d", args.CompareTarget, len(response.CompareResult))
    logger.Debugf("Compare target %s result len %d", args.CompareTarget, len(response.CompareResult))
    if len(response.CompareResult) > 0 {
        logger.Debugf("Compare result %+v", response.CompareResult)