From 81efc7621ceb21f3529e540cf936814b8b03e2e5 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 04 十一月 2020 10:39:04 +0800
Subject: [PATCH] 摄像机新增或更新返回结果消息
---
dbtableApi.go | 109 +++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 94 insertions(+), 15 deletions(-)
diff --git a/dbtableApi.go b/dbtableApi.go
index 00b616a..30020d3 100644
--- a/dbtableApi.go
+++ b/dbtableApi.go
@@ -4,14 +4,29 @@
"basic.com/pubsub/protomsg.git"
"encoding/json"
"errors"
+ "strconv"
)
type DbTableApi struct {
-
+ Ip string
+ Port int
}
-func (dbt DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
+func (api DbTableApi) getBasicUrl() string {
+ if api.Ip == "" {
+ return BASIC_URL
+ }
+ if api.Ip == "" {
+ api.Ip = DEFAULT_IP
+ }
+ if api.Port == 0 {
+ api.Port = DEFAULT_PORT
+ }
+ return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
+
+func (api DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
client := NewClient()
body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
if err != nil {
@@ -26,8 +41,8 @@
return res.Success,res.Data
}
-func (dbt DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/queryDbTables/"+isSync
+func (api DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/queryDbTables/"+isSync
client := NewClient()
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
if err != nil {
@@ -42,8 +57,8 @@
return res.Success,res.Data
}
-func (dbt DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/updateDbTables"
+func (api DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/updateDbTables"
client := NewClient()
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
if err != nil {
@@ -58,8 +73,28 @@
return res.Success,res.Data
}
-func (dbt DbTableApi) DeleteById(id string) (bool,interface{}) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/deleteDBtablesById/"+id
+func (api DbTableApi) UpdateDbTableStatus(id string,enable int) (bool,interface{}) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/updateDbTableStatus"
+ client := NewClient()
+ paramBody := map[string]interface{}{
+ "id": id,
+ "enable": enable,
+ }
+ body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
+ if err != nil {
+ return false,nil
+ }
+
+ var res Result
+ if err = json.Unmarshal(body, &res); err != nil {
+ return false,nil
+ }
+
+ return res.Success,res.Data
+}
+
+func (api DbTableApi) DeleteById(id string) (bool,interface{}) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/deleteDBtablesById/"+id
client := NewClient()
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
if err != nil {
@@ -75,8 +110,8 @@
}
//鏍规嵁澶氫釜搴曞簱id鏌ヨ搴曞簱淇℃伅
-func (dbt DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
+func (api DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
client := NewClient()
paramBody := map[string]interface{}{
"ids": ids,
@@ -98,8 +133,8 @@
}
// 鏍规嵁tableid 鏌ヨtablename
-func (dbt DbTableApi) Dbtablename(tableId string) (tableName string,err error) {
- dts, e := dbt.DbtablesById([]string{tableId})
+func (api DbTableApi) Dbtablename(tableId string) (tableName string,err error) {
+ dts, e := api.DbtablesById([]string{tableId})
if e !=nil {
return "",e
}
@@ -109,8 +144,8 @@
return "",errors.New("table not found")
}
-func (dbt DbTableApi) FindAllDbTables() (dts []protomsg.Dbtable,err error) {
- url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/findAllDbTables"
+func (api DbTableApi) FindAllDbTables() (dts []protomsg.Dbtable,err error) {
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/findAllDbTables"
client := NewClient()
body,err := client.DoGetRequest(url, nil,nil)
if err != nil {
@@ -128,3 +163,47 @@
return dts,nil
}
+func (api DbTableApi) FindAllDbTablesByCurServer(isDelete string) (dts []protomsg.Dbtable,err error){
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/findAllDbTablesByCurServer"
+ client := NewClient()
+ paramQuery := map[string]string{
+ "isDelete":isDelete,
+ }
+ body,err := client.DoGetRequest(url, paramQuery,nil)
+ if err != nil {
+ return nil,err
+ }
+
+ var res Result
+ if err = json.Unmarshal(body, &res); err != nil {
+ return nil,err
+ }
+ dataBytes, _ := json.Marshal(res.Data)
+ if err = json.Unmarshal(dataBytes, &dts);err !=nil {
+ return nil,err
+ }
+ return dts,nil
+}
+
+func (api DbTableApi) FindAllLocalDbTables(isDelete string) (dts []protomsg.Dbtable,err error){
+ url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/findAllLocalDbTables"
+ client := NewClient()
+ paramQuery := map[string]string{
+ "isDelete":isDelete,
+ }
+ body,err := client.DoGetRequest(url, paramQuery,nil)
+ if err != nil {
+ return nil,err
+ }
+
+ var res Result
+ if err = json.Unmarshal(body, &res); err != nil {
+ return nil,err
+ }
+ dataBytes, _ := json.Marshal(res.Data)
+ if err = json.Unmarshal(dataBytes, &dts);err !=nil {
+ return nil,err
+ }
+ return dts,nil
+}
+
--
Gitblit v1.8.0