From a2c0678e8d34d1bd5afa26c6a2b34ec97b411777 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期三, 08 五月 2024 14:45:19 +0800
Subject: [PATCH] 新增删除人员缓存的处理
---
main.go | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/main.go b/main.go
index 52ccec1..67c5a08 100644
--- a/main.go
+++ b/main.go
@@ -92,13 +92,10 @@
var result []byte
if request.CompareType == facecompare.CompareType_Compare {
var compareArgInfo protomsg.CompareArgs
- var cacheChangeInfo protomsg.EsPersonCacheChange
if err = proto.Unmarshal(request.Payload, &compareArgInfo); err == nil {
timeStart := time.Now()
result = compare.GetComparePersonBaseInfo(compareArgInfo)
logger.Debug("鐢ㄦ椂锛�", time.Since(timeStart))
- } else if err = proto.Unmarshal(request.Payload, &cacheChangeInfo); err == nil {
- cache.UpdateCache(&cacheChangeInfo)
} else {
logger.Warn("CompareArgs or EsPersonCacheChange json unmarshal error")
continue
@@ -112,6 +109,10 @@
id := string(compareEvent.Payload)
cache.UpdateDbPersonsCacheById(id)
logger.Info("--------------鏇存柊浜哄憳缂撳瓨, id: ", id)
+ } else if compareEvent.EventType == protomsg.CompareEventType_DeleteCache { //搴撲腑鏂板鏇存柊缂撳瓨
+ id := string(compareEvent.Payload)
+ cache.DeleteDbPersonsCacheById(id)
+ logger.Info("--------------鍒犻櫎浜哄憳缂撳瓨, id: ", id)
}
} else {
logger.Warn("CompareEvent json unmarshal error")
--
Gitblit v1.8.0