使用bhsgo by lichao

liuxiaolong

2021-04-25 cc9d7e2dfad7c634e8ce69d02ce5fc4065e809e4

 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,