使用bhsgo by lichao

liuxiaolong

2021-04-25 cc9d7e2dfad7c634e8ce69d02ce5fc4065e809e4

 dbpersonApi.go

@@ -3,7 +3,6 @@
import (
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "errors"
   "strconv"
)

@@ -14,9 +13,6 @@
func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
   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 {
@@ -34,9 +30,6 @@
func (api DbPersonApi) UpdateDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/updateDbPerson"
   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 {
@@ -54,9 +47,6 @@
func (api DbPersonApi) UpdateFace(id string,faceFeature string, pic string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/updateFace"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "id": id,
@@ -79,9 +69,6 @@
func (api DbPersonApi) AddDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/addDbPerson"
   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 {
@@ -99,9 +86,6 @@
func (api DbPersonApi) DeleteDbPerson(id string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deleteDbPersonById"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
      "id": id,
@@ -122,9 +106,6 @@
func (api DbPersonApi) DeleteMoreDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
   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 {
@@ -142,9 +123,6 @@
func (api DbPersonApi) DeletePersonsByTbId(tableId string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
      "tableId": tableId,
@@ -166,9 +144,6 @@
func (api DbPersonApi) Dbpersoninfosbyid (ids []string) (persons []protomsg.Dbperson,err error) {
   url := DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
   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,
@@ -192,9 +167,6 @@
func (api DbPersonApi) GetPersonTotal (tableId string) (total int64,err error) {
   url := DATA_URL_PREFIX + "/dbperson/getPersonTotal"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return -1,errors.New("compTable-service proc not found")
   }
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]string{
      "tableId": tableId,
@@ -215,9 +187,6 @@
func (api DbPersonApi) GetPersonsCompareCacheBase (from int,size int) (persons []*protomsg.Esinfo,err error) {
   url := DATA_URL_PREFIX + "/dbperson/getPersonsCompareCacheBase"
   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]string{
      "from": strconv.Itoa(from),
@@ -254,9 +223,6 @@
func (api DbPersonApi) FindLikePersonIds (tableIds  []string,inputValue string) (interface{},error) {
   url := DATA_URL_PREFIX + "/dbperson/findLikePersonIds"
   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{}{
      "tableIds": tableIds,
@@ -277,9 +243,6 @@
func (api DbPersonApi) JoinDbTable (tableIds  []string,faceFeature string, personPicUrl string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/joinDbTable"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "tableIds": tableIds,
@@ -301,9 +264,6 @@
func (api DbPersonApi) Move (personId string,tableIds []string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/move"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "personId": personId,
@@ -324,9 +284,6 @@
func (api DbPersonApi) Copy (personId string,tableIds []string) (bool,interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/copy"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false,nil
   }
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "personId": personId,
@@ -347,9 +304,6 @@
func (api DbPersonApi) MultiUploadCarNo(paramBody map[string]interface{}) bool {
   url := DATA_URL_PREFIX + "/dbperson/multiUploadCarNo"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   if netNode == nil {
      return false
   }
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   if err != nil {