From c6a9333ccafbfac3bd5c04d7c5b6195dff35d0a3 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期一, 22 七月 2019 15:29:04 +0800 Subject: [PATCH] local and gb28181 camera update snapshot --- controllers/camera.go | 3 ++- service/CamraUpdatesnashot.go | 49 +++++++++++++++++++++++++++++++++++++++++-------- controllers/initForData.go | 1 + 3 files changed, 44 insertions(+), 9 deletions(-) diff --git a/controllers/camera.go b/controllers/camera.go index 9956bc1..c0272b9 100644 --- a/controllers/camera.go +++ b/controllers/camera.go @@ -266,7 +266,8 @@ // @Router /data/api-v/camera/updateSnapshotUrl/{cid} [get] func(cc CameraController) UpdateSnapshotUrl(c *gin.Context){ cid := c.Param("cid") - filename, err := service.UpdateSnapshotUrl(cid) + //filename, err := service.UpdateSnapshotUrl(cid) + filename, err := service.UpdateCapture(cid) if err != nil { util.ResponseFormat(c, code.ComError, "鏇存柊澶辫触") return diff --git a/controllers/initForData.go b/controllers/initForData.go index cce730b..30af460 100644 --- a/controllers/initForData.go +++ b/controllers/initForData.go @@ -1,6 +1,7 @@ package controllers import ( + "basic.com/dbapi.git" "fmt" "github.com/gin-gonic/gin" "strings" diff --git a/service/CamraUpdatesnashot.go b/service/CamraUpdatesnashot.go index 233447d..4027daf 100644 --- a/service/CamraUpdatesnashot.go +++ b/service/CamraUpdatesnashot.go @@ -1,25 +1,26 @@ package service import ( - "flag" - "fmt" - "os" - "os/exec" - "strconv" - "time" - "webserver/extend/config" - "bytes" "encoding/json" "errors" + "flag" + "fmt" "gocv.io/x/gocv" "io" "log" "mime/multipart" "net/http" + "os" + "os/exec" "path/filepath" + "strconv" + "time" + "webserver/extend/config" + "webserver/extend/esutil" "basic.com/dbapi.git" + "basic.com/valib/capture.git" ) func PostFormBufferData(uri string, filepath string, fileName string) (maps map[string]interface{}, err0 error) { @@ -143,3 +144,35 @@ } return filename, nil } + +//璋冪敤缁熶竴鎺ュ彛锛屽埛鏂板簳鍥撅紙闆嗘垚鍥芥爣搴曞浘鍒锋柊锛� +func UpdateCapture(cid string) (fileName string,err error){ + var cameraApi dbapi.CameraApi + camera, err := cameraApi.GetCameraById(cid) + if err !=nil{ + return "",errors.New("camera not exist") + } + + m := capture.Rtsp + if camera.Type == 1{//鍥芥爣鎽勫儚鏈� + m = capture.GB28181 + } + b,err := capture.Capture("./runtime/libcffmpeg.so",m,camera.Rtsp,capture.JPEGFileExt,1280,720,10) + if err == nil{ + var weedfsUri = "http://"+config.WeedFs.Ip+":"+strconv.Itoa(config.WeedFs.UploadPort)+"/submit" + resp, err := esutil.PostFormBufferData(weedfsUri, camera.Name+".jpg", "file", b) + if err != nil { + return "",err + } else { + fileurl := resp["fileUrl"].(string) // 鏂囦欢璺緞 + filename := filepath.Base(fileurl) + ok := cameraApi.UpdateSnapshotUrl(cid, filename) + if !ok { + return "", errors.New("update camera's snapshot fail") + } + return filename, nil + } + }else{ + return "",err + } +} -- Gitblit v1.8.0