392 lines
11 KiB
Go
392 lines
11 KiB
Go
package iot
|
||
|
||
import (
|
||
"encoding/json"
|
||
"fmt"
|
||
|
||
"myschools.me/suguo/hikvision/iot/model"
|
||
)
|
||
|
||
/*
|
||
基础服务能力 > 设备管理 > 设备接入管理
|
||
*/
|
||
|
||
var (
|
||
access_base = "https://api2.hik-cloud.com/api/v1/open/basic/devices"
|
||
access_register = access_base + "/create"
|
||
access_delete = access_base + "/delete"
|
||
access_update = access_base + "/update"
|
||
access_detail = access_base + "/get"
|
||
access_list = access_base + "/list"
|
||
access_account = access_base + "/actions/deviceCount"
|
||
access_status = access_base + "https://api2.hik-cloud.com/api/v1/ezviz/devices/queryDeviceStatus"
|
||
access_reboot = access_base + "/actions/system/reboot"
|
||
|
||
// 设备校时配置
|
||
time_base = "https://api2.hik-cloud.com/api/v1/device/isapi/system/time"
|
||
time_ntpcfg = time_base + "/ntpServers"
|
||
time_ntpserver_cfg = time_base + "/ntpServers/config"
|
||
)
|
||
|
||
// 注册设备到对应分组内。
|
||
//
|
||
// 注册设备时首先会将设备添加到平台，然后异步同步设备通道。如果设备添加成功而同步设备通道失败，则可以先获取设备列表信息，再手动调用通道同步接口同步设备下的通道。\
|
||
func DeviceRegister(deviceserial, groupno, validatecode string) (*model.DeviceData, error) {
|
||
|
||
req := &struct {
|
||
DeviceSerial string `json:"deviceSerial"` //设备序列号
|
||
GroupNo string `json:"groupNo"` //组编号
|
||
ValidateCode string `json:"validateCode"` //验证码
|
||
}{
|
||
|
||
DeviceSerial: deviceserial,
|
||
GroupNo: groupno,
|
||
ValidateCode: validatecode,
|
||
}
|
||
|
||
resp, err := hikvisionRequest("POST", access_register, req)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceData `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 从某一分组内删除设备
|
||
func DeviceDelete(deviceSerial string) (*model.Hikvision, error) {
|
||
resp, err := hikvisionRequest("POST", fmt.Sprintf("%s?deviceSerial=%s", access_delete, deviceSerial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 该接口用于修改设备名称
|
||
func DeviceUpdate(deviceserial, devicename string) (*model.Hikvision, error) {
|
||
|
||
req := &struct {
|
||
DeviceSerial string `json:"deviceSerial"` //设备序列号
|
||
DeviceName string `json:"deviceName"` //设备名称
|
||
}{
|
||
DeviceSerial: deviceserial,
|
||
DeviceName: devicename,
|
||
}
|
||
|
||
resp, err := hikvisionRequest("POST", access_update, req)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 该接口用于根据设备序列号获取单个设备详细信息
|
||
func DeviceDetail(deviceSerial string) (*model.DeviceData, error) {
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("%s?deviceSerial=%s", access_detail, deviceSerial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceData `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 该接口用于查询某组下设备列表信息 ,组编号，页数，页行数
|
||
func DeviceList(groupno string, pageno, pagesize int) (*model.DeviceListData, error) {
|
||
url := fmt.Sprintf("%s?groupNo=%s&pageNo=%d&pageSize=%d", access_list, groupno, pageno, pagesize)
|
||
resp, err := hikvisionRequest("GET", url, nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceListData `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 该接口用于获取用户接入的设备总数
|
||
func DeviceNum() (*int, error) {
|
||
|
||
resp, err := hikvisionRequest("GET", access_account, nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data struct {
|
||
TotalCount int `json:"totalCount"`
|
||
} `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data.TotalCount, nil
|
||
}
|
||
|
||
// 该接口用于查询设备的状态信息，目前仅支持萤石设备 /*测试未通过*/
|
||
func DeviceStatus(deviceserial string) (*model.DeviceStatusData, error) {
|
||
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("%s?deviceSerial=%s", access_status, deviceserial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceStatusData `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 该接口用于重启设备，请谨慎操作
|
||
func DeviceReboot(deviceserial string) (*model.Hikvision, error) {
|
||
params := &struct {
|
||
DeviceSerial string `json:"deviceSerial"`
|
||
}{
|
||
DeviceSerial: deviceserial,
|
||
}
|
||
|
||
resp, err := hikvisionRequest("POST", access_reboot, params)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
/*
|
||
确权流程说明
|
||
设备接入政策进行了如下调整：
|
||
（1）设备首次激活，需要在规定的时间（72小时）内上线平台，否则，上线时需要走确权流程；
|
||
（2）设备重新注册平台，删除设备并重新添加设备超过规定时间（72小时）需要走确权流程；
|
||
|
||
什么时候需要进行确权
|
||
注册设备接口返回内容code=60058时，需要进行设备确权操作。
|
||
*/
|
||
|
||
// 下线确认 errcode:20002003 errmsg:离线失败
|
||
func DeviceOffline(deviceserial string) (*model.Hikvision, error) {
|
||
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("https://api2.hik-cloud.com/v1/carrier/wing/endpoint/confirm/right/offlineconfirm?deviceSerial=%s", deviceserial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 上线线确认
|
||
func DeviceOnline(deviceserial string) (*model.Hikvision, error) {
|
||
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("https://api2.hik-cloud.com/v1/carrier/wing/endpoint/confirm/right/onlineconfirm?deviceSerial=%s", deviceserial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 该接口用于获取设备当前校时配置
|
||
func DeviceGetTimeMode(deviceserial string) (*string, error) {
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("%s?deviceSerial=%s", time_base, deviceserial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data struct {
|
||
TimeMode string `json:"timeMode"`
|
||
} `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data.TimeMode, nil
|
||
}
|
||
|
||
// 该接口用于配置设备校时模式
|
||
func DeviceSetTimeMode(deviceSerial, timeMode string) (*model.Hikvision, error) {
|
||
|
||
req := &struct {
|
||
DeviceSerial string `json:"deviceSerial"`
|
||
TimeMode string `json:"timeMode"`
|
||
}{
|
||
DeviceSerial: deviceSerial,
|
||
TimeMode: timeMode,
|
||
}
|
||
|
||
resp, err := hikvisionRequest("POST", time_base, req)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 该接口用于获取设备当前NTP服务器配置
|
||
func DeviceGetNTPCfg(deviceserial string) (*model.DeviceSetNTPCfgServer, error) {
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("%s?deviceSerial=%s", time_ntpcfg, deviceserial), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceSetNTPCfgServer `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 该接口用于配置设备NTP服务器参数
|
||
func DeviceSetNTPCfg(deviceSerial string, ntpserver *model.DeviceSetNTPCfgServer) (*model.Hikvision, error) {
|
||
|
||
req := &struct {
|
||
DeviceSerial string `json:"deviceSerial"`
|
||
NtpServer model.DeviceSetNTPCfgServer `json:"ntpServer"`
|
||
}{
|
||
DeviceSerial: deviceSerial,
|
||
NtpServer: *ntpserver,
|
||
}
|
||
|
||
resp, err := hikvisionRequest("POST", time_ntpcfg, req)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
// 该接口用于获取设备指定NTP服务器配置
|
||
func DeviceGetNTPServerCfg(deviceserial string, ntpserverid int) (*model.DeviceSetNTPCfgServer, error) {
|
||
resp, err := hikvisionRequest("GET", fmt.Sprintf("%s?deviceSerial=%s&ntpServerId=%d", time_ntpserver_cfg, deviceserial, ntpserverid), nil)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result = &struct {
|
||
model.Hikvision
|
||
Data model.DeviceSetNTPCfgServer `json:"data"`
|
||
}{}
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return &result.Data, nil
|
||
}
|
||
|
||
// 该接口用于配置设备指定NTP服务器参数
|
||
func DeviceSetNTPServerCfg(req *model.DeviceSetNTPServerCfgReq) (*model.Hikvision, error) {
|
||
resp, err := hikvisionRequest("POST", time_ntpserver_cfg, req)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
var result *model.Hikvision
|
||
if err := json.Unmarshal(resp, &result); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
if result.Code != 200 {
|
||
return nil, fmt.Errorf("result errcode:%d errmsg:%s", result.Code, result.Message)
|
||
}
|
||
return result, nil
|
||
}
|