From 3cdf9117668a91f2fefcda89eb4263d7fb2f4434 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 29 三月 2024 18:30:15 +0800
Subject: [PATCH] 精简代码

---
 cache/compare.go    |  237 +---------------------------------------------
 face/faceCompare.go |    5 
 main.go             |   27 -----
 3 files changed, 11 insertions(+), 258 deletions(-)

diff --git a/cache/compare.go b/cache/compare.go
index 9275cce..4d45b87 100644
--- a/cache/compare.go
+++ b/cache/compare.go
@@ -2,7 +2,6 @@
 
 import (
 	"encoding/base64"
-	"errors"
 	"flag"
 	"fmt"
 	"sdkCompare/face"
@@ -11,14 +10,10 @@
 	"sync"
 	"time"
 
-	"sdkCompare/cache/shardmap"
-	"sdkCompare/config"
-	"sdkCompare/util"
-
-	libEs "basic.com/pubsub/esutil.git"
 	"basic.com/pubsub/protomsg.git"
 	"basic.com/valib/logger.git"
 	"github.com/golang/protobuf/proto"
+	"sdkCompare/cache/shardmap"
 )
 
 var querynum = flag.Int("querynum", 3000, "the query number from database")
@@ -27,7 +22,6 @@
 var (
 	thresholdLimit     = float32(50)
 	captureTable       = "capturetable"
-	cartable           = "carTable_"
 	PRE_DBTABLE        = "dbTable_"
 	PRE_CAPTURE_SERVER = "captureServer_"
 )
@@ -39,138 +33,6 @@
 
 var Cmap *CmapItem
 var doOnce sync.Once
-
-// 璁$畻姣忔鏌ヨ鐨勬暟鎹噺鏉℃暟
-func Querynum(totalnum int) int {
-	qn := totalnum / *threadnum //qn=6551
-	if *querynum < qn {         //
-
-		return *querynum
-	}
-	return qn
-}
-
-// 澧為噺鏌ヨ
-func IncreVideoPersonsCache(lastT time.Time, targetType string) {
-	ticker := time.NewTicker(time.Minute * 3)
-	for {
-		select {
-		case <-ticker.C:
-			curTime := time.Now()
-			Incrementquery(lastT, curTime, targetType)
-			lastT = curTime
-		}
-	}
-}
-
-func Incrementquery(last time.Time, cur time.Time, targetType string) {
-	laststring := last.Format("2006-01-02 15:04:05")
-	curstring := cur.Format("2006-01-02 15:04:05")
-	alarmIp := config.EsCompServerInfo.ESIP
-	alarmPort := config.EsCompServerInfo.ESPort
-	indexName := config.EsInfo.EsIndex.AiOcean.IndexName
-
-	serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
-	if e != nil {
-		return
-	}
-
-	shardStr, e := getShards(serverIp, alarmIp, alarmPort)
-	if e != nil {
-		return
-	}
-
-	// 璋冪敤澧為噺鐨勬帴鍙�
-	captures, err := libEs.GetPeriodInfos(serverIp, alarmPort, laststring, curstring, indexName, shardStr, targetType)
-	if err != nil {
-		logger.Error(err)
-		return
-	}
-	for _, ei := range captures {
-		if ei.EsInfo.AnalyServerId != "" {
-			cKey := PRE_CAPTURE_SERVER + ei.EsInfo.AnalyServerId
-			ei.EsInfo.Tableid = captureTable
-
-			if _, ok := Cmap.Cam[cKey]; !ok {
-				Cmap.Cam[cKey] = shardmap.New(uint8(*threadnum))
-			}
-
-			Cmap.Cam[cKey].Set(ei.EsInfo.Id, ei.EsInfo)
-		}
-	}
-}
-
-func getShards(serverIp string, alarmIp string, alarmPort string) (string, error) {
-	infos, e := libEs.GetShardsByIndex(alarmIp, alarmPort, config.EsInfo.EsIndex.AiOcean.IndexName)
-	if e != nil || infos == nil {
-		logger.Error("get es primary ips err")
-		return "", errors.New("get es primary ips err")
-	}
-
-	var shards []string
-	for _, shard := range infos {
-		if (shard.ShardIp == serverIp || shard.ShardIp == "127.0.0.1") && shard.ShardRole == "primary" && shard.ShardState == "STARTED" {
-			shards = append(shards, strconv.Itoa(shard.ShardNum))
-		}
-	}
-	if len(shards) == 0 {
-		return "", errors.New("current shards is empty")
-	}
-	return strings.Join(shards, ","), nil
-}
-
-// 1. 鎷垮埌鎬婚噺锛� 璁$畻姣忎釜绾跨▼鐨勬煡璇㈤噺
-// 2. 鍒嗙嚎绋嬫煡璇�
-func Init(indexName string, targetType string) error {
-	alarmIp := config.EsCompServerInfo.ESIP
-	alarmPort := config.EsCompServerInfo.ESPort
-
-	doOnce.Do(func() {
-		flag.Parse()
-
-		Cmap = &CmapItem{
-			Cam: make(map[string]*shardmap.ShardMap),
-		}
-	})
-
-	serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
-	if e != nil {
-		return e
-	}
-
-	shardStr, e := getShards(serverIp, alarmIp, alarmPort)
-	if e != nil {
-		return e
-	}
-	// 杩欓噷闇�瑕佹彁渚涙�婚噺鐨勬帴鍙�
-	estotalnum := libEs.GetTotal(serverIp, alarmPort, indexName, shardStr, targetType)
-	*querynum = Querynum(estotalnum)
-	temptime := time.Now()
-
-	captures, err := libEs.GetOceanFeatures(serverIp, alarmPort, 1000, indexName, shardStr, targetType)
-	if err != nil {
-		logger.Error("libEs.GetOceanFeatures err:", err)
-		return err
-	}
-	logger.Debug("len(captures):", len(captures))
-	Cmap.Lock()
-	for _, ei := range captures {
-		if ei.EsInfo.AnalyServerId != "" {
-			cKey := PRE_CAPTURE_SERVER + ei.EsInfo.AnalyServerId
-			ei.EsInfo.Tableid = captureTable
-			if _, ok := Cmap.Cam[cKey]; !ok {
-				Cmap.Cam[cKey] = shardmap.New(uint8(*threadnum))
-			}
-
-			Cmap.Cam[cKey].Set(ei.EsInfo.Id, ei.EsInfo)
-		}
-	}
-
-	Cmap.Unlock()
-
-	logger.Debug(indexName, "缂撳瓨瀹屾垚鐢ㄦ椂:", time.Since(temptime))
-	return nil
-}
 
 func ReInitDbTablePersonsCache() {
 	Cmap.Lock()
@@ -447,87 +309,15 @@
 			}
 		} else { //web璇锋眰锛屾瘮瀵规寚瀹氱殑鎶撴媿搴撴垨鑰呭簳搴�
 			for _, tid := range compareArgs.TableIds {
-				if tid == captureTable { //姣斿鎶撴媿搴�
-					tStart := time.Now()
-					serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
-					if e != nil {
-						logger.Error("util.GetLocalIP err:", e)
-						continue
-					}
-					alarmPort := config.EsCompServerInfo.ESPort
+				shardins, ok := Cmap.Cam[tid]
+				if !ok {
+					logger.Error("get shard error by tableId:", tid)
+					continue
+				}
 
-					scopeIds := libEs.GetAllLocalVideopersonsId(compareArgs, config.EsInfo.EsIndex.AiOcean.IndexName, serverIp, alarmPort, compareArgs.AlarmLevel)
-					logger.Debug("libEs.GetAllLocalVideopersonsId len(scopeIds):", len(scopeIds), " 鑰楁椂锛�", time.Since(tStart))
-					if scopeIds != nil {
-						tCompStart := time.Now()
-						if compareArgs.AnalyServerId != "" { //鎸囧畾server
-							for cKey, cacheMap := range Cmap.Cam {
-								if cKey == PRE_CAPTURE_SERVER+compareArgs.AnalyServerId {
-									for _, sId := range scopeIds {
-										obj, ok := cacheMap.Get(sId)
-										if ok {
-											eInfo, ok := obj.(*protomsg.Esinfo)
-											if !ok {
-												continue
-											}
-											sec := DoSdkCompare(compareArgs.FaceFeature, eInfo.FaceFeature)
-											if sec >= baseScore {
-												scResult.CompareResult = append(scResult.CompareResult, &protomsg.SdkCompareEach{
-													Id:           eInfo.Id,
-													CompareScore: sec,
-													Tableid:      eInfo.Tableid,
-												})
-											}
-										}
-									}
-								}
-							}
-						} else { //绠$悊骞冲彴璇锋眰姣斿鎵�鏈夋姄鎷�,涓嶆寚瀹歴erver
-							for cKey, cacheMap := range Cmap.Cam {
-								if len(compareArgs.ServerIds) > 0 {
-									for _, termDevId := range compareArgs.ServerIds {
-										if cKey == PRE_CAPTURE_SERVER+termDevId || !strings.HasPrefix(cKey, PRE_CAPTURE_SERVER) {
-											targets := cacheMap.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
-											if len(targets) > 0 {
-												scResult.CompareResult = append(scResult.CompareResult, targets...)
-											}
-										}
-									}
-								} else {
-									if strings.HasPrefix(cKey, PRE_CAPTURE_SERVER) {
-										for _, sId := range scopeIds {
-											if obj, ok := cacheMap.Get(sId); ok {
-												eInfo, ok := obj.(*protomsg.Esinfo)
-												if !ok {
-													continue
-												}
-												sec := DoSdkCompare(compareArgs.FaceFeature, eInfo.FaceFeature)
-												if sec >= baseScore {
-													scResult.CompareResult = append(scResult.CompareResult, &protomsg.SdkCompareEach{
-														Id:           eInfo.Id,
-														CompareScore: sec,
-														Tableid:      eInfo.Tableid,
-													})
-												}
-											}
-										}
-									}
-								}
-							}
-						}
-						logger.Debug("鏍规嵁scopeIds姣斿鑰楁椂锛�", time.Since(tCompStart))
-					}
-				} else {
-					shardins, ok := Cmap.Cam[tid]
-					if !ok {
-						logger.Error("get shard error by tableId:", tid)
-						continue
-					}
-
-					targets := shardins.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
-					if len(targets) > 0 {
-						scResult.CompareResult = append(scResult.CompareResult, targets...)
-					}
+				targets := shardins.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
+				if len(targets) > 0 {
+					scResult.CompareResult = append(scResult.CompareResult, targets...)
 				}
 			}
 		}
@@ -550,15 +340,6 @@
 		logger.Error("DoSdkCompare err:", err)
 		return -1
 	}
-	//if len(co_d) != 2560 {
-	//	logger.Error("target fea.len !=2560")
-	//	return -1
-	//}
-	//
-	//if len(ci) != 2560 {
-	//	logger.Error("source fea.len !=2560")
-	//	return -1
-	//}
 	sec := face.DecCompare(ci, co_d)
 	//logger.Debug("姣斿寰楀垎涓猴細", sec)
 
diff --git a/face/faceCompare.go b/face/faceCompare.go
index b4b139c..373027d 100644
--- a/face/faceCompare.go
+++ b/face/faceCompare.go
@@ -1,7 +1,6 @@
 package face
 
 import (
-	"fmt"
 	"unsafe"
 )
 
@@ -69,7 +68,7 @@
 	if len(ffeat1) != len(ffeat2) {
 		return 0
 	}
-	fmt.Println("len:", len(ffeat1), len(feat2))
+	//fmt.Println("len:", len(ffeat1), len(feat2))
 	//fmt.Println("ffeat1:", ffeat1, "ffeat2:", ffeat2, "len:", len(ffeat1), len(feat2))
 	// normalize
 	var score float32
@@ -83,7 +82,7 @@
 	if score < 0.0001 {
 		score = 0.0001
 	}
-	fmt.Println("score:", score)
+	//fmt.Println("score:", score)
 	return score
 }
 
diff --git a/main.go b/main.go
index e120069..7ea4ffb 100644
--- a/main.go
+++ b/main.go
@@ -60,33 +60,6 @@
 	cache.InitDbTablePersons()
 	serveUrl = serveUrl + strconv.Itoa(config.DbPersonCompInfo.ServePort)
 
-	//if procName == "dbCompare" {
-	//	if err := cache.ConnectDB(); err != nil {
-	//		logger.Error(err.Error())
-	//		return
-	//	}
-	//
-	//	cache.InitDbTablePersons()
-	//	if !cache.InitCompare() {
-	//		logger.Debug("init SDKFace return false,panic")
-	//		return
-	//	}
-	//	serveUrl = serveUrl + strconv.Itoa(config.DbPersonCompInfo.ServePort)
-	//} else {
-	//	if err := cache.Init(config.EsInfo.EsIndex.AiOcean.IndexName, targetType1); err != nil {
-	//		logger.Info("init capture cache err:", err)
-	//		return
-	//	}
-	//
-	//	if !cache.InitCompare() {
-	//		logger.Debug("init SDKFace return false,panic")
-	//		return
-	//	}
-	//
-	//	go cache.IncreVideoPersonsCache(time.Now(), targetType1)
-	//	serveUrl = serveUrl + strconv.Itoa(config.EsCompServerInfo.ServePort)
-	//}
-
 	logger.Debugf("%s serve url:%s", procName, serveUrl)
 
 	Recv(serveUrl)

--
Gitblit v1.8.0