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
---
dbpersonApi.go | 46 ----------------------------------------------
1 files changed, 0 insertions(+), 46 deletions(-)
diff --git a/dbpersonApi.go b/dbpersonApi.go
index ae34cba..67eac00 100644
--- a/dbpersonApi.go
+++ b/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 {
--
Gitblit v1.8.0