From 97765a7c55a40c4492ac66e5da2cf811c5ab4166 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期五, 16 八月 2019 20:05:48 +0800
Subject: [PATCH] add dbperson and dbtable api

---
 dbpersonApi.go |  174 ++++++++++++++++++++++++++++++++++
 dbtableApi.go  |  111 ++++++++++++++++++++++
 2 files changed, 285 insertions(+), 0 deletions(-)

diff --git a/dbpersonApi.go b/dbpersonApi.go
new file mode 100644
index 0000000..af6c848
--- /dev/null
+++ b/dbpersonApi.go
@@ -0,0 +1,174 @@
+package dbapi
+
+import (
+	"basic.com/pubsub/protomsg.git"
+	"encoding/json"
+	"strconv"
+)
+
+type DbPersonApi struct {
+
+}
+
+func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
+	client := NewClient()
+	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 DbPersonApi) UpdateDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/updateDbPerson"
+	client := NewClient()
+	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 DbPersonApi) AddDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/addDbPerson"
+	client := NewClient()
+	body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,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 DbPersonApi) DeleteDbPerson(id string) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deleteDbPersonById/"+id
+	client := NewClient()
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,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 DbPersonApi) DeleteMoreDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
+	client := NewClient()
+	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 DbPersonApi) DeletePersonsByTbId(tableId string) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId/"+tableId
+	client := NewClient()
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,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
+}
+
+//鏍规嵁搴曞簱浜哄憳id鏌ヨ浜哄憳淇℃伅璇︽儏
+func (api DbPersonApi) Dbpersoninfosbyid (ids []string) (persons []protomsg.Dbperson,err error) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
+	client := NewClient()
+	paramBody := map[string]interface{}{
+		"ids": ids,
+	}
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,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, &persons);err !=nil {
+		return nil,err
+	}
+	return persons,nil
+}
+
+func (api DbPersonApi) GetPersonTotal () (total int64,err error) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/getPersonTotal"
+	client := NewClient()
+
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
+	if err != nil {
+		return 0,err
+	}
+
+	var res Result
+	if err = json.Unmarshal(body, &res); err != nil {
+		return 0,err
+	}
+
+	return res.Data.(int64),nil
+}
+
+func (api DbPersonApi) GetPersonsCompareCacheBase (from int,size int) (persons []*protomsg.Esinfo,err error) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
+	client := NewClient()
+	paramBody := map[string]string{
+		"from": strconv.Itoa(from),
+		"size": strconv.Itoa(size),
+	}
+	body,err := client.DoGetRequest(url, paramBody,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)
+	var arr []protomsg.Esinfo
+	if err = json.Unmarshal(dataBytes, &arr);err !=nil {
+		return nil,err
+	}
+	for _,ei :=range arr {
+		persons = append(persons,&ei)
+	}
+	return persons,nil
+}
\ No newline at end of file
diff --git a/dbtableApi.go b/dbtableApi.go
new file mode 100644
index 0000000..d620c22
--- /dev/null
+++ b/dbtableApi.go
@@ -0,0 +1,111 @@
+package dbapi
+
+import (
+	"basic.com/pubsub/protomsg.git"
+	"encoding/json"
+	"errors"
+)
+
+type DbTableApi struct {
+
+}
+
+func (dbt DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
+	client := NewClient()
+	body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,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 (dbt DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/queryDbTables/"+isSync
+	client := NewClient()
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,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 (dbt DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/updateDbTables"
+	client := NewClient()
+	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 (dbt DbTableApi) DeleteById(id string) (bool,interface{}) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/deleteDBtablesById/"+id
+	client := NewClient()
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,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
+}
+
+//鏍规嵁澶氫釜搴曞簱id鏌ヨ搴曞簱淇℃伅
+func (dbt DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
+	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
+	client := NewClient()
+	paramBody := map[string]interface{}{
+		"ids": ids,
+	}
+	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,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
+}
+
+// 鏍规嵁tableid 鏌ヨtablename
+func (dbt DbTableApi) Dbtablename(tableId string) (tableName string,err error) {
+	dts, e := dbt.DbtablesById([]string{tableId})
+	if e !=nil {
+		return "",e
+	}
+	if dts !=nil && len(dts) ==1 {
+		return dts[0].TableName,nil
+	}
+	return "",errors.New("table not found")
+}
+

--
Gitblit v1.8.0