package bhomedbapi
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
jsoniter "github.com/json-iterator/go"
|
"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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
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
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
if err = json.Unmarshal(body, &res); err != nil {
|
logPrint("unmarshal err:", err)
|
return false
|
}
|
return res.Success
|
}
|
