package service
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/logger.git"
|
"bytes"
|
"encoding/json"
|
"io/ioutil"
|
"net/http"
|
"time"
|
)
|
|
func inCameraTree(id, rtsp string, isGB bool) bool {
|
url := "http://127.0.0.1:7009/data/api-v/camera/show?id=" + id
|
if isGB {
|
url = "http://127.0.0.1:7009/data/api-v/gb28181/camera/show?cid=" + id
|
}
|
|
body, err := Get(url, nil)
|
if err != nil {
|
logger.Warn("[db]", err)
|
return false
|
}
|
|
var res Result
|
if err = json.Unmarshal(body, &res); err != nil {
|
logger.Warn("[db]", err)
|
return false
|
}
|
|
if !res.Success {
|
logger.Warn("[db]http response:", res)
|
return false
|
}
|
|
var camera protomsg.Camera
|
var bytes []byte
|
bytes, err = json.Marshal(res.Data)
|
if err != nil {
|
logger.Warn("[db]", err)
|
return false
|
}
|
|
err = json.Unmarshal(bytes, &camera)
|
if err != nil {
|
logger.Warn("[db]", err)
|
return false
|
}
|
|
return camera.Rtsp == rtsp
|
}
|
|
// hik 摄像机编码转rtsp
|
// 参数 {"cameraIndexCode":"3d3edde85d364a15906cf316a58ee69f"}
|
func rtspTranslation(cameraIndexCode string) (rtsp string) {
|
url := "http://192.168.122.101:20886/getHikRtsp"
|
param, _ := json.Marshal(map[string]string{"cameraIndexCode": cameraIndexCode})
|
|
logger.Debug("request hik api to get rtsp, camera index code:", cameraIndexCode)
|
|
body, err := Post(url, param)
|
if err != nil {
|
logger.Warn("convert rtsp failed:", err)
|
return
|
}
|
|
return string(body)
|
}
|
|
const (
|
token = "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjQ3NDUwMjU5MjMsInVzZXIiOiJ7XCJpZFwiOlwiZTZjY2QzNmQtNGYxNi00NmZjLTg4ZDUtMDczNjU4NjZkMjA1XCIsXCJwZXJtaXNzaW9uc1wiOltcInByb2R1Y3RNYW5nZTpwdWJsaXNoXCIsXCJjb2RlTWFuZ2U6dmlld1wiLFwiZGV2aWNlTWFuYWdlOmFkZFwiLFwiYWRtaW5NYW5hZ2VcIixcIm9yZGVyTWFuZ2VcIixcImRldmljZU1hbmFnZTp2aWV3XCIsXCJwcm9kdWN0TWFuZ2U6YWRkXCIsXCJhZG1pbk1hbmFnZTp2aWV3XCIsXCJjb2RlTWFuZ2U6YWRkXCIsXCJwcm9kdWN0TWFuZ2U6b2ZmU2FsZVwiLFwib3JkZXJNYW5nZTpjYW5jZWxcIixcInByb2R1Y3RDZW50ZXI6ZG93bmxvYWRcIixcInByb2R1Y3RDZW50ZXI6YnV5XCIsXCJwcm9kdWN0TWFuZ2U6dmlld1wiLFwiYXBpXCIsXCJob21lXCIsXCJvcmRlck1hbmdlOnBheVwiLFwiYWRtaW5NYW5hZ2U6YWRkXCIsXCJvcmRlck1hbmdlOmRvd25sb2FkXCIsXCJwcm9kdWN0Q2VudGVyXCIsXCJkZXZpY2VNYW5hZ2U6dW5iaW5kXCIsXCJvcmRlck1hbmdlOnZpZXdcIixcImFkbWluTWFuYWdlOmVkaXRcIixcImRldmljZU1hbmFnZVwiLFwidmlwTWFuYWdlOmFkZFwiLFwidmlwTWFuYWdlOnZpZXdcIixcInByb2R1Y3RDZW50ZXI6dmlld1wiLFwidmlwTWFuYWdlOmVkaXRcIixcInZpcE1hbmFnZVwiLFwicHJvZHVjdE1hbmdlOmVkaXRcIixcImNvZGVNYW5nZVwiLFwicHJvZHVjdE1hbmdlXCJdLFwidXNlcm5hbWVcIjpcImJhc2ljXCJ9In0.vwjAFkWuEyadRLvIOGK8LFE3MjpY3SQ7j6AlTXnQDG8"
|
)
|
|
type Result struct {
|
Code int `json:"code"`
|
Data interface{} `json:"data"`
|
Msg string `json:"msg"`
|
Success bool `json:"success"`
|
}
|
|
func Get(url string, parama []byte) (body []byte, err error) {
|
return request("GET", url, parama)
|
}
|
|
func Post(url string, parama []byte) (body []byte, err error) {
|
return request("POST", url, parama)
|
}
|
|
func request(method string, url string, parama []byte) (body []byte, err error) {
|
timeout := time.Duration(10 * time.Second)
|
client := http.Client{
|
Timeout: timeout,
|
}
|
request, err := http.NewRequest(method, url, bytes.NewBuffer(parama))
|
|
request.Header.Set("Content-type", "application/json")
|
request.Header.Add("Authorization", token)
|
|
if err != nil {
|
logger.Warn("build request fail !")
|
return nil, err
|
}
|
|
resp, err := client.Do(request)
|
if err != nil {
|
logger.Warn("request error: ", err)
|
return nil, err
|
}
|
|
defer resp.Body.Close()
|
|
body, err = ioutil.ReadAll(resp.Body)
|
if err != nil {
|
logger.Warn(err)
|
}
|
|
return body, nil
|
}
|
