录像回放

app/security/controller/rewindController.go

@@ -0,0 +1,28 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	edgeService "iot_manager_service/app/security/edge_service"
+	"iot_manager_service/util/common"
+	"net/http"
+)
+
+// TODO: 未记录日志
+var Rewind = new(rewindCtl)
+
+type rewindCtl struct{}
+
+func (c rewindCtl) RewindText(ctx *gin.Context) {
+	streamId := ctx.Query("streamId")
+	date := ctx.Query("date")
+	edgeService := edgeService.ForRewindService{}
+	operate, err := edgeService.GetRewindText(streamId, date)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+	}
+	if operate == "" {
+		ctx.JSON(http.StatusOK, nil)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Success, operate))
+}

app/security/edge_service/forRewindService.go

@@ -0,0 +1,51 @@
+package edge_service
+
+import (
+	"fmt"
+	"io/ioutil"
+	"iot_manager_service/config"
+	"net/http"
+	"net/url"
+)
+
+// Rewind 回放记录
+type ForRewindService struct {
+}
+
+// getRewindApi 公用请求接口
+func (f *ForRewindService) getRewindApi(url string) (string, error) {
+	fmt.Printf("url = %v", url)
+	method := "GET"
+
+	client := &http.Client{}
+	req, err := http.NewRequest(method, url, nil)
+
+	if err != nil {
+		fmt.Println(err)
+		return "", nil
+	}
+	res, err := client.Do(req)
+	if err != nil {
+		fmt.Println(err)
+		return "", nil
+	}
+	defer res.Body.Close()
+
+	body, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		fmt.Println(err)
+		return "", nil
+	}
+	fmt.Println(string(body))
+	return string(body), err
+}
+
+func (f *ForRewindService) GetRewindText(streamId string, date string) (string, error) {
+	//fmt.Printf("streamId = %v", streamId)
+	cfg := config.Instance()
+	api := cfg.Foreign.SecurityRewindUrl + "/list/%v/%v"
+	url2 := fmt.Sprintf(api, (streamId), url.QueryEscape(date))
+	//fmt.Printf("url2 = %v", url2)
+	//return "", nil
+	return f.getRewindApi(url2)
+}

app/security/model/security.go

@@ -6,12 +6,13 @@ type CameraLiveDetail struct {
 }
 
 type CameraLive struct {
-	Id             int    `json:"id"`
-	DeviceName     string `json:"deviceName"`
-	DeviceSn       string `json:"deviceSn"`
-	PoleGroupName  string `json:"poleGroupName"`
-	MonitorAddress string `json:"monitorAddress"`
-	StreamId       string `json:"streamId"`
-	RunState       string `json:"runState"`
-	CameraType     int    `json:"cameraType"`
+	Id               int    `json:"id"`
+	DeviceName       string `json:"deviceName"`
+	DeviceSn         string `json:"deviceSn"`
+	PoleGroupName    string `json:"poleGroupName"`
+	MonitorAddress   string `json:"monitorAddress"`
+	StreamId         string `json:"streamId"`
+	RunState         string `json:"runState"`
+	CameraType       int    `json:"cameraType"`
+	LampPoleLocation string `json:"lampPoleLocation"`
 }

app/security/service/securityService.go

@@ -28,14 +28,15 @@ func (s *securityService) GetCameraLiveList(tenantId int) ([]model.CameraLiveDet
 				poleGroupName = cameraDevice.DeviceName + "在线"
 			}
 			cameraList = append(cameraList, model.CameraLive{
-				Id:             cameraDevice.ID,
-				DeviceName:     cameraDevice.DeviceName,
-				DeviceSn:       cameraDevice.DeviceSN,
-				PoleGroupName:  poleGroupName,
-				MonitorAddress: cameraDevice.MonitorAddress,
-				StreamId:       cameraDevice.StreamId,
-				RunState:       state,
-				CameraType:     cameraDevice.CameraType,
+				Id:               cameraDevice.ID,
+				DeviceName:       cameraDevice.DeviceName,
+				DeviceSn:         cameraDevice.DeviceSN,
+				PoleGroupName:    poleGroupName,
+				MonitorAddress:   cameraDevice.MonitorAddress,
+				StreamId:         cameraDevice.StreamId,
+				RunState:         state,
+				CameraType:       cameraDevice.CameraType,
+				LampPoleLocation: cameraDevice.LampPoleLocation,
 			})
 		}
 		rsp = append(rsp, model.CameraLiveDetail{

config/config.go

@@ -76,5 +76,6 @@ type minio struct {
 }
 
 type foreign struct {
-	IotEdgeUrl string `yaml:"iot_edge_url"`
+	IotEdgeUrl        string `yaml:"iot_edge_url"`
+	SecurityRewindUrl string `yaml:"security_rewind_url"`
 }

config/config.yaml

@@ -36,4 +36,5 @@ minio:
 
 #接口
 foreign:
-  iot_edge_url: "http://106.52.134.22:8880"
+  iot_edge_url: "http://106.52.134.22:8880"
+  security_rewind_url: "http://106.52.134.22:9099"

router/router.go

@@ -466,6 +466,12 @@ func InitRouter(engine *gin.Engine) {
 			securityMultiscreenGroup.GET("cameraList", security.Security.GetCameraLiveList)
 			securityMultiscreenGroup.POST("submit", security.Multiscreen.Submit)
 		}
+
+		securityRewindGroup := securityGroup.Group("/rewind")
+		{
+			securityRewindGroup.GET("getCameraLiveList", security.Security.GetCameraLiveList)
+			securityRewindGroup.POST("rewind-text", security.Rewind.RewindText)
+		}
 	}
 
 	// 媒体素材