package dbapi
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"encoding/json"
|
"strconv"
|
)
|
|
type DbPersonApi struct {
|
Ip string
|
Port int
|
}
|
|
func (api DbPersonApi) getBasicUrl() string {
|
if api.Ip == "" {
|
return BASIC_URL
|
}
|
if api.Ip == "" {
|
api.Ip = DEFAULT_IP
|
}
|
if api.Port == 0 {
|
api.Port = DEFAULT_PORT
|
}
|
return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
|
}
|
|
func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
|
url := api.getBasicUrl() + 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 := api.getBasicUrl() + 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) UpdateFace(id string,faceFeature string, pic string) (bool,interface{}) {
|
url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/updateFace"
|
client := NewClient()
|
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 := api.getBasicUrl() + 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 := api.getBasicUrl() + 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 := api.getBasicUrl() + 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 := api.getBasicUrl() + 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 := api.getBasicUrl() + 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 (tableId string) (total int64,err error) {
|
url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/getPersonTotal"
|
client := NewClient()
|
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 := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/getPersonsCompareCacheBase"
|
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,&protomsg.Esinfo{
|
Id: ei.Id,
|
Tableid: ei.Tableid,
|
FaceFeature: ei.FaceFeature,
|
Enable: ei.Enable,
|
})
|
}
|
return persons,nil
|
}
|
|
func (api DbPersonApi) FindLikePersonIds (tableIds []string,inputValue string) (interface{},error) {
|
url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/findLikePersonIds"
|
client := NewClient()
|
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
|
}
|
