From 2c77f012601b7788dc58b0c9fd99aad587983b0d Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 22 十月 2024 21:20:19 +0800
Subject: [PATCH] 完善楼层相关操作
---
repository/captureRepo.go | 48 ++++++++++++++++--------------------------------
1 files changed, 16 insertions(+), 32 deletions(-)
diff --git a/repository/captureRepo.go b/repository/captureRepo.go
index 73f0347..87ae032 100644
--- a/repository/captureRepo.go
+++ b/repository/captureRepo.go
@@ -51,7 +51,7 @@
bgImageStr = image.Data
}
} else if image.StoragePath != "" {
- imgData, err := util.ImageDownload(image.StoragePath, nil)
+ imgData, err := pkg.ImageDownload(image.StoragePath, nil)
if err != nil {
logger.Warn("Image download failure, %s", err.Error())
} else {
@@ -87,24 +87,24 @@
// 杞彂鍥惧儚
logger.Debug("Prepare forward image, deviceId:%s, bgImage len:%d, smImage len:%d server:%s", deviceId, len(bgImageBytes), len(faceImageBytes), config.ForwardConf.SyncServer)
if deviceId != "" && bgImageStr != "" && config.ForwardConf.SyncServer != "" {
- pd := c.PackPushDataV2(deviceId, faceId, face.FaceAppearTime, bgImageBytes, faceImageBytes)
- if pd == nil {
+ pushData := c.PackPushDataV2(deviceId, faceId, face.FaceAppearTime, bgImageBytes, faceImageBytes)
+ if pushData == nil {
return
}
// 澶勭悊姊帶濉啓鐨勬ゼ灞備俊鎭� 鏆傛椂浣跨敤otherFeature瀛楁
- if face.OtherFeature != "" && pd.CameraFloor == "" {
- pd.Direction, pd.CameraFloor, _ = pkg.RestoreFloor(face.OtherFeature)
+ if face.OtherFeature != "" && pushData.CameraFloor == "" {
+ pushData.Direction, pushData.CameraFloor, _ = pkg.RestoreFloor(face.OtherFeature)
}
- payload, err := json.Marshal(pd)
+ payload, err := json.Marshal(pushData)
if err != nil {
logger.Warn("Marshal error, %s", err.Error())
return
}
- if !util.SendData(payload, config.ForwardConf.SyncServer) {
- cacheItem, _ := json.Marshal(pd)
+ if !pkg.SendData(payload, config.ForwardConf.SyncServer) {
+ cacheItem, _ := json.Marshal(pushData)
c.CacheData(cacheItem, "basic")
logger.Warn("The data forwarding failed, adding to local cache.")
} else {
@@ -145,7 +145,7 @@
bgImageStr = image.Data
}
} else if image.StoragePath != "" {
- imgData, err := util.ImageDownload(image.StoragePath, nil)
+ imgData, err := pkg.ImageDownload(image.StoragePath, nil)
if err != nil {
logger.Warn("Image download failure, %s", err.Error())
} else {
@@ -188,7 +188,7 @@
return
}
- if !util.SendData(payload, config.ForwardConf.SyncServer) {
+ if !pkg.SendData(payload, config.ForwardConf.SyncServer) {
cacheItem, _ := json.Marshal(pd)
c.CacheData(cacheItem, "basic")
logger.Warn("The data forwarding failed, adding to local cache.")
@@ -218,16 +218,8 @@
floor = runState.Floor
for i := 0; i < config.NVCSConf.WaitRunTime; i++ {
- if runState = nvcs.FindMovePosition(faceAppearTime.Unix()+3, floor); runState.Floor != "" {
- switch runState.RunState {
- case nvcs.RunUp:
- runDir = "in"
- case nvcs.RunDown:
- runDir = "out"
- case nvcs.RunStop:
- runDir = ""
- }
-
+ if runState = nvcs.CurrentRunState(); runState.Floor != "" && runState.Floor != floor {
+ runDir = pkg.CheckDirection(floor, runState.Floor)
break
}
@@ -279,16 +271,8 @@
floor = runState.Floor
for i := 0; i < config.NVCSConf.WaitRunTime; i++ {
- if runState = nvcs.FindMovePosition(faceAppearTime.Unix()+3, floor); runState.Floor != "" {
- switch runState.RunState {
- case nvcs.RunUp:
- runDir = "in"
- case nvcs.RunDown:
- runDir = "out"
- case nvcs.RunStop:
- runDir = ""
- }
-
+ if runState = nvcs.CurrentRunState(); runState.Floor != "" && runState.Floor != floor {
+ runDir = pkg.CheckDirection(floor, runState.Floor)
break
}
@@ -296,7 +280,7 @@
}
for idx, _ := range msg.FaceListObject.FaceObject {
- msg.FaceListObject.FaceObject[idx].OtherFeature, _ = pkg.ParseFloor(runDir, floor)
+ msg.FaceListObject.FaceObject[idx].OtherFeature, _ = pkg.BuildFloorString(runDir, floor)
//if config.ClientConf.AddFloorToFaceId {
// msg.FaceListObject.FaceObject[idx].FaceID = pkg.GenerateFaceIdContainFloor(face.FaceID, devPos.Pos)
//}
@@ -350,7 +334,7 @@
logger.Debug("Pub record message %s, %s", deviceId, msgId)
body, _ := json.Marshal(&msg)
- _, err := util.HttpPost(config.ForwardConf.RecordServer, nil, body)
+ _, err := pkg.HttpPost(config.ForwardConf.RecordServer, nil, body)
if err != nil {
logger.Warn(err.Error())
}
--
Gitblit v1.8.0