From cc9d7e2dfad7c634e8ce69d02ce5fc4065e809e4 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期日, 25 四月 2021 11:34:47 +0800
Subject: [PATCH] 使用bhsgo by lichao
---
dbtableApi.go | 30 ------------------------------
1 files changed, 0 insertions(+), 30 deletions(-)
diff --git a/dbtableApi.go b/dbtableApi.go
index 9c41639..ba6b8c9 100644
--- a/dbtableApi.go
+++ b/dbtableApi.go
@@ -13,9 +13,6 @@
func (api DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
url := DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return false,nil
- }
client := NewClient(WithNodes(netNode))
body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
if err != nil {
@@ -33,9 +30,6 @@
func (api DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
url := DATA_URL_PREFIX + "/dbtable/queryDbTables"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return false,nil
- }
client := NewClient(WithNodes(netNode))
paramQuery:= map[string]string {
"isSync":isSync,
@@ -56,9 +50,6 @@
func (api DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
url := DATA_URL_PREFIX + "/dbtable/updateDbTables"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return false,nil
- }
client := NewClient(WithNodes(netNode))
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
if err != nil {
@@ -76,9 +67,6 @@
func (api DbTableApi) UpdateDbTableStatus(id string,enable int) (bool,interface{}) {
url := DATA_URL_PREFIX + "/dbtable/updateDbTableStatus"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return false,nil
- }
client := NewClient(WithNodes(netNode))
paramBody := map[string]interface{}{
"id": id,
@@ -100,9 +88,6 @@
func (api DbTableApi) DeleteById(id string) (bool,interface{}) {
url := DATA_URL_PREFIX + "/dbtable/deleteDBtablesById"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return false,nil
- }
client := NewClient(WithNodes(netNode))
paramQuery := map[string]string {
"id": id,
@@ -124,9 +109,6 @@
func (api DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
url := DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return nil,errors.New("compTable-service proc not found")
- }
client := NewClient(WithNodes(netNode))
paramBody := map[string]interface{}{
"ids": ids,
@@ -162,9 +144,6 @@
func (api DbTableApi) FindAllDbTables() (dts []protomsg.Dbtable,err error) {
url := DATA_URL_PREFIX + "/dbtable/findAllDbTables"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return nil,errors.New("compTable-service proc not found")
- }
client := NewClient(WithNodes(netNode))
body,err := client.DoGetRequest(url, nil,nil)
if err != nil {
@@ -185,9 +164,6 @@
func (api DbTableApi) FindAllDbTablesByCurServer(isDelete string) (dts []protomsg.Dbtable,err error){
url := DATA_URL_PREFIX + "/dbtable/findAllDbTablesByCurServer"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return nil,errors.New("compTable-service proc not found")
- }
client := NewClient(WithNodes(netNode))
paramQuery := map[string]string{
"isDelete":isDelete,
@@ -211,9 +187,6 @@
func (api DbTableApi) FindAllDbTablesByType(isDelete string, typ string) (dts []protomsg.Dbtable,err error){
url := DATA_URL_PREFIX + "/dbtable/findAllDbTablesByCurServer"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return nil,errors.New("compTable-service proc not found")
- }
client := NewClient(WithNodes(netNode))
paramQuery := map[string]string{
"isDelete":isDelete,
@@ -238,9 +211,6 @@
func (api DbTableApi) FindAllLocalDbTables(isDelete string) (dts []protomsg.Dbtable,err error){
url := DATA_URL_PREFIX + "/dbtable/findAllLocalDbTables"
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
- if netNode == nil {
- return nil,errors.New("compTable-service proc not found")
- }
client := NewClient(WithNodes(netNode))
paramQuery := map[string]string{
"isDelete":isDelete,
--
Gitblit v1.8.0