From d51c66acbfdcadc5119ed5389e219c56dedec13f Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期五, 11 十月 2019 14:23:46 +0800
Subject: [PATCH] 增加更新所有下级平台资源的接口
---
gb28181Api.go | 52 ++++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 42 insertions(+), 10 deletions(-)
diff --git a/gb28181Api.go b/gb28181Api.go
index d9d6560..8a5241c 100644
--- a/gb28181Api.go
+++ b/gb28181Api.go
@@ -88,7 +88,7 @@
//GetDevicesByPageNO 鎸夐〉鑾峰彇涓嬬骇璁惧锛堝钩鍙版垨鎽勫儚鏈猴級鍒楄〃
//pageNo (鏁板瓧) 鎸囧畾鑾峰彇绗嚑椤碉紝绗竴娆′负1锛岃繑鍥炴�婚〉鏁帮紝鎬绘潯鏁扮瓑锛屽啀鏍规嵁杩欎簺淇℃伅鍘诲啀娆℃煡璇紝鐩村埌鍙栧畬鍏ㄩ儴
-func (api Gb28181Api) GetDevicesByPageNO(pageNo int) (DevicesInOnePage, bool) {
+func (api Gb28181Api) getDevicesByPageNO(pageNo int) (DevicesInOnePage, bool) {
url := BASIC_URL + DATA_URL_PREFIX + "/get_all_device/" + strconv.Itoa(pageNo)
client := NewClient()
@@ -115,7 +115,7 @@
//GetAllDevices 鑾峰彇鍏ㄩ儴涓嬬骇璁惧锛堝钩鍙版垨鎽勫儚鏈猴級淇℃伅鍒楄〃
func (api Gb28181Api) GetAllDevices() ([]DeviceInfo, bool) {
var deviceSlice []DeviceInfo
- devicesPerPage, flag := api.GetDevicesByPageNO(1)
+ devicesPerPage, flag := api.getDevicesByPageNO(1)
if !flag {
log.Println("GetDevicesByPageNO Error, deviceSlice is nil")
return deviceSlice, false
@@ -123,7 +123,7 @@
deviceSlice = devicesPerPage.Data
for i := 1; i < devicesPerPage.TotalPage; i++ {
- devicesPerPage, flag := api.GetDevicesByPageNO(i + 1)
+ devicesPerPage, flag := api.getDevicesByPageNO(i + 1)
if !flag {
log.Println("GetDevicesByPageNO Error,pageno:" + strconv.Itoa(i+1) + " ,deviceSlice is not completed")
return deviceSlice, false
@@ -139,7 +139,7 @@
//pageNo (鏁板瓧) 鎸囧畾鑾峰彇绗嚑椤碉紝绗竴娆′负1锛岃繑鍥炴�婚〉鏁帮紝鎬绘潯鏁扮瓑锛屽啀鏍规嵁杩欎簺淇℃伅鍘诲啀娆℃煡璇紝鐩村埌鍙栧畬鍏ㄩ儴
//srcType (瀛楃涓�) "all"-琛ㄧず鑾峰彇璁惧鐨勬墍鏈夎祫婧� "node"-鐖惰妭鐐逛笅鐨勭涓�绾ц祫婧�
//娉ㄦ剰锛氭牴鎹�"restype"瀛楁锛屽拷鐣ヨ祫婧愮粍锛屽彧淇濈暀閫氶亾璧勬簮------"restype"锛�(鏁板瓧)1-閫氶亾璧勬簮 2-璧勬簮缁�
-func (api Gb28181Api) GetCamsByDevAndPage(devID string, srcType string, pageNo int) (CamerasInOnePage, bool) {
+func (api Gb28181Api) getCamsByDevAndPage(devID string, srcType string, pageNo int) (CamerasInOnePage, bool) {
url := BASIC_URL + DATA_URL_PREFIX + "/get_all_channel/" + devID + "/" + srcType + "/" + strconv.Itoa(pageNo)
client := NewClient()
@@ -176,7 +176,7 @@
//devID (瀛楃涓�) 娉ㄥ唽鐨勮澶囩殑20浣峣d
func (api Gb28181Api) GetAllCamerasByDevID(devID string) ([]CameraInfo, bool) {
var cameraSlice []CameraInfo
- camerasPerPage, flag := api.GetCamsByDevAndPage(devID, "all", 1)
+ camerasPerPage, flag := api.getCamsByDevAndPage(devID, "all", 1)
if !flag {
log.Println("GetCamsByDevAndPage Error, deviceSlice is nil")
return cameraSlice, false
@@ -184,7 +184,7 @@
cameraSlice = camerasPerPage.Data
for i := 1; i < camerasPerPage.TotalPage; i++ {
- camerasPerPage, flag := api.GetCamsByDevAndPage(devID, "all", i+1)
+ camerasPerPage, flag := api.getCamsByDevAndPage(devID, "all", i+1)
if !flag {
log.Println("GetCamsByDevAndPage Error! devID:" + devID + ",type:all,pageno:" + strconv.Itoa(i+1) + " ,cameraSlice is not completed")
return cameraSlice, false
@@ -221,7 +221,7 @@
}
//GetAllCamerasByDomainUnit get all cameras by domainunit 鑾峰彇鎵�鏈夎鏀垮尯鍩熶笅鐨勮澶�
-func (api Gb28181Api) GetAllCamerasByDomainUnitAndPage(domainpubid string, pageNo int) (CamerasInOnePage, bool) {
+func (api Gb28181Api) getAllCamerasByDomainUnitAndPage(domainpubid string, pageNo int) (CamerasInOnePage, bool) {
url := BASIC_URL + DATA_URL_PREFIX + "/get_domainunit_channel/" + domainpubid + "/" + strconv.Itoa(pageNo)
client := NewClient()
@@ -248,7 +248,7 @@
//GetAllCamerasByDevID 鑾峰彇鎸囧畾琛屾斂鍖哄煙鐨勬憚鍍忔満鍒楄〃
func (api Gb28181Api) GetAllCamerasByDomainUnit(domainpubid string) ([]CameraInfo, bool) {
var cameraSlice []CameraInfo
- camerasPerPage, flag := api.GetAllCamerasByDomainUnitAndPage(domainpubid, 1)
+ camerasPerPage, flag := api.getAllCamerasByDomainUnitAndPage(domainpubid, 1)
if !flag {
log.Println("GetCamsByDevAndPage Error, deviceSlice is nil")
return cameraSlice, false
@@ -256,7 +256,7 @@
cameraSlice = camerasPerPage.Data
for i := 1; i < camerasPerPage.TotalPage; i++ {
- camerasPerPage, flag := api.GetAllCamerasByDomainUnitAndPage(domainpubid, i+1)
+ camerasPerPage, flag := api.getAllCamerasByDomainUnitAndPage(domainpubid, i+1)
if !flag {
log.Println("GetCamsByDevAndPage Error! devID:" + domainpubid + ",type:all,pageno:" + strconv.Itoa(i+1) + " ,cameraSlice is not completed")
return cameraSlice, false
@@ -404,6 +404,39 @@
return cameraSlice, true
}
+//updateResourceByID 鏇存柊涓嬬骇骞冲彴璧勬簮
+func (api Gb28181Api) updateResourceByID(devID string) bool {
+ url := BASIC_URL + "/vss/get_catalog/" + devID
+ client := NewClient()
+
+ body, err := client.DoGetRequest(url, nil, nil)
+ if err != nil {
+ log.Println("err:", err)
+ return false
+ }
+
+ var res GbResult
+ if err = json.Unmarshal(body, &res); err != nil {
+ log.Println("jsonErr:", err)
+ return false
+ }
+ if res.ErrCode != 0 {
+ log.Println("errcode: ", res.ErrCode, " errdesc: ", res.ErrDesc)
+ return false
+ }
+
+ return true
+}
+
+func (api Gb28181Api) UpdateAllResource() {
+ devices, b := api.GetAllDevices()
+ if b && len(devices) > 0 {
+ for _, device := range devices {
+ api.updateResourceByID(device.PublicID)
+ }
+ }
+}
+
//SetCameraPtz 2.3 PTZ浜戝彴鎺у埗
//"channelid": (瀛楃涓�) 閫氶亾20浣嶇紪鍙�
//"ptztype"锛� (瀛楃涓�) 鎺у埗绫诲瀷锛氫笂"up",涓�"down",宸�"left",鍙�"right",宸︿笂"leftup",宸︿笅"leftdown",鍙充笂"rightup",鍙充笅"rightdown",闀滃ご杩�"zoomin",闀滃ご杩�"zoomout",
@@ -419,7 +452,6 @@
return false
}
- //瑙ｆ瀽 CamerasInOnePage
var res GbResult
if err = json.Unmarshal(body, &res); err != nil {
log.Println("jsonErr:", err)
--
Gitblit v1.8.0