package bhomedbapi
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"encoding/json"
|
"strconv"
|
)
|
|
type DbPersonApi struct {
|
|
}
|
|
func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
|
url := DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
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 := DATA_URL_PREFIX + "/dbperson/updateDbPerson"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
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) UpdateFace(id string,faceFeature string, pic string) (bool,interface{}) {
|
url := DATA_URL_PREFIX + "/dbperson/updateFace"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]interface{}{
|
"id": id,
|
"faceFeature": faceFeature,
|
"personPicUrl": pic,
|
}
|
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 := DATA_URL_PREFIX + "/dbperson/addDbPerson"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
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 := DATA_URL_PREFIX + "/dbperson/deleteDbPersonById"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramQuery := map[string]string {
|
"id": id,
|
}
|
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,paramQuery,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 := DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
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 := DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramQuery := map[string]string {
|
"tableId": tableId,
|
}
|
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,paramQuery,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 := DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
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 (tableId string) (total int64,err error) {
|
url := DATA_URL_PREFIX + "/dbperson/getPersonTotal"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]string{
|
"tableId": tableId,
|
}
|
body,err := client.DoGetRequest(url, paramBody,nil)
|
if err != nil {
|
return 0,err
|
}
|
|
var res Result
|
if err = json.Unmarshal(body, &res); err != nil {
|
return 0,err
|
}
|
|
return int64(res.Data.(float64)),nil
|
}
|
|
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))
|
client := NewClient(WithNodes(netNode))
|
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,&protomsg.Esinfo{
|
Id: ei.Id,
|
Tableid: ei.Tableid,
|
FaceFeature: ei.FaceFeature,
|
Enable: ei.Enable,
|
|
CarNo: ei.CarNo,
|
})
|
}
|
return persons,nil
|
}
|
|
func (api DbPersonApi) FindLikePersonIds (tableIds []string,inputValue string) (interface{},error) {
|
url := DATA_URL_PREFIX + "/dbperson/findLikePersonIds"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]interface{}{
|
"tableIds": tableIds,
|
"inputValue": inputValue,
|
}
|
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
|
}
|
return res.Data,nil
|
}
|
|
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))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]interface{}{
|
"tableIds": tableIds,
|
"faceFeature": faceFeature,
|
"personPicUrl": personPicUrl,
|
}
|
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) Move (personId string,tableIds []string) (bool,interface{}) {
|
url := DATA_URL_PREFIX + "/dbperson/move"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]interface{}{
|
"personId": personId,
|
"tableIds": tableIds,
|
}
|
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) Copy (personId string,tableIds []string) (bool,interface{}) {
|
url := DATA_URL_PREFIX + "/dbperson/copy"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
paramBody := map[string]interface{}{
|
"personId": personId,
|
"tableIds": tableIds,
|
}
|
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) MultiUploadCarNo(paramBody map[string]interface{}) bool {
|
url := DATA_URL_PREFIX + "/dbperson/multiUploadCarNo"
|
netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
|
client := NewClient(WithNodes(netNode))
|
body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
|
if err != nil {
|
logPrint("multiUploadCarNo err:", err)
|
return false
|
}
|
|
var res Result
|
if err = json.Unmarshal(body, &res); err != nil {
|
logPrint("unmarshal err:",err)
|
return false
|
}
|
return res.Success
|
}
|
