From 4691c6c2efe7fccc74c75eb01b91009791960259 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 17 五月 2024 22:59:32 +0800
Subject: [PATCH] 修复图片下载的bug

---
 controller/captureCtl.go |   67 +++++++++++++++++++++++++++++++--
 1 files changed, 62 insertions(+), 5 deletions(-)

diff --git a/controller/captureCtl.go b/controller/captureCtl.go
index 9501625..0f8bda9 100644
--- a/controller/captureCtl.go
+++ b/controller/captureCtl.go
@@ -38,15 +38,17 @@
 		return
 	}
 
-	// 濡傛灉寮�鍚簡涓嬬骇, 韬唤搴旇鏄秷鎭唬鐞�, 涓嶅啀杞彂鍒版湇鍔″櫒
 	face := req.FaceListObject.FaceObject[0]
+	logger.Debug("Receive new message, Id:%s Ip:%s faceId:%s, LeftTopX:%d, appearTime:%s", c.RemoteIP(), face.DeviceID, face.FaceID, face.LeftTopX, face.FaceAppearTime)
+
+	// 濡傛灉寮�鍚簡涓嬬骇, 韬唤搴旇鏄秷鎭唬鐞�, 涓嶅啀杞彂鍒版湇鍔″櫒
 	if config.ClientConf.Enable && config.ServeConf.Role == "agent" {
 		go a.Repository.VIIDMsgForward(&req)
 	} else if config.ServeConf.Role == "cascade" {
-		logger.Debug("Receive new message, Id:%s Ip:%s faceId:%s, LeftTopX:%d, appearTime:%s", c.RemoteIP(), face.DeviceID, face.FaceID, face.LeftTopX, face.FaceAppearTime)
-		go service.AddFaceCapture(&face)
-	} else {
-		logger.Debug("Receive new message, Id:%s Ip:%s faceId:%s, LeftTopX:%d, appearTime:%s", c.RemoteIP(), face.DeviceID, face.FaceID, face.LeftTopX, face.FaceAppearTime)
+		go service.AddFaceNotification(&face)
+	}
+
+	if config.ForwardConf.SyncServer != "" {
 		go a.Repository.FaceForward(req.FaceListObject.FaceObject)
 	}
 
@@ -63,3 +65,58 @@
 
 	c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
 }
+func (a CaptureController) VideoLabels(c *gin.Context) {
+	var req vo.RequestVideoLabelList
+	if err := c.BindJSON(&req); err != nil {
+		c.AbortWithStatus(http.StatusBadRequest)
+		return
+	}
+
+	if len(req.VideoLabelListObject.VideoLabelObject) == 0 {
+		c.AbortWithStatus(http.StatusBadRequest)
+		return
+	}
+
+	videoLabel := req.VideoLabelListObject.VideoLabelObject[0]
+	logger.Debug("Receive new message, Id:%s Ip:%s ", videoLabel.VideoLabelID, c.RemoteIP())
+
+	// 杞汉鑴告秷鎭�
+	var face vo.FaceObject
+	face.FaceID = videoLabel.VideoLabelID
+	face.InfoKind = 1
+	face.SourceID = videoLabel.VideoImageID
+	face.DeviceID = videoLabel.IVADeviceID
+	face.LocationMarkTime = videoLabel.CreateTimeAbs
+	face.FaceAppearTime = videoLabel.BehaviorAnalysisObject.BehaviorBeginTime
+	face.FaceDisAppearTime = videoLabel.BehaviorAnalysisObject.BehaviorEndTime
+
+	for idx, _ := range videoLabel.SubImageList.SubImageInfoObject {
+		videoLabel.SubImageList.SubImageInfoObject[idx].EventSort = 10
+	}
+
+	face.SubImageList.SubImageInfoObject = videoLabel.SubImageList.SubImageInfoObject
+
+	// 濡傛灉寮�鍚簡涓嬬骇, 韬唤搴旇鏄秷鎭唬鐞�, 涓嶅啀杞彂鍒版湇鍔″櫒
+	if config.ClientConf.Enable && config.ServeConf.Role == "agent" {
+		//go a.Repository.VIIDMsgForward(&req)
+	} else if config.ServeConf.Role == "cascade" {
+		go service.AddFaceNotification(&face)
+	}
+
+	if config.ForwardConf.SyncServer != "" {
+		go a.Repository.FaceForward([]vo.FaceObject{face})
+	}
+
+	// 璁惧淇濇椿
+	service.KeepDeviceAlive(videoLabel.IVADeviceID)
+
+	rspMsg := vo.ResponseStatus{
+		RequestURL:   c.FullPath(),
+		StatusCode:   vo.StatusSuccess,
+		StatusString: vo.StatusString[vo.StatusSuccess],
+		Id:           videoLabel.VideoLabelID,
+		LocalTime:    time.Now().Format("20060102150405"),
+	}
+
+	c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
+}

--
Gitblit v1.8.0