zhangmeng
2024-01-19 01dfd9dc8de7b19f9dfa4284722e01bbd5837801
dbpersonApi.go
@@ -2,319 +2,333 @@
import (
   "basic.com/pubsub/protomsg.git"
   json "github.com/json-iterator/go"
   jsoniter "github.com/json-iterator/go"
   "strconv"
)
type DbPersonApi struct {
}
func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) UpdateDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
func (api DbPersonApi) UpdateDbPerson(paramBody map[string]interface{}) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/updateDbPerson"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) UpdateFace(id string,faceFeature string, pic string) (bool,interface{}) {
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))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "id": id,
      "faceFeature": faceFeature,
      "id":           id,
      "faceFeature":  faceFeature,
      "personPicUrl": pic,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) AddDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
func (api DbPersonApi) AddDbPerson(paramBody map[string]interface{}) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/addDbPerson"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) DeleteDbPerson(id string) (bool,interface{}) {
func (api DbPersonApi) DeleteDbPerson(id string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deleteDbPersonById"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
   paramQuery := map[string]string{
      "id": id,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,paramQuery,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, nil, paramQuery, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) DeleteMoreDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
func (api DbPersonApi) DeleteMoreDbPerson(paramBody map[string]interface{}) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) DeletePersonsByTbId(tableId string) (bool,interface{}) {
func (api DbPersonApi) DeletePersonsByTbId(tableId string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
   paramQuery := map[string]string{
      "tableId": tableId,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,paramQuery,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, nil, paramQuery, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
//根据底库人员id查询人员信息详情
func (api DbPersonApi) Dbpersoninfosbyid (ids []string) (persons []protomsg.Dbperson,err error) {
func (api DbPersonApi) Dbpersoninfosbyid(ids []string) (persons []protomsg.Dbperson, err error) {
   url := DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   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)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return nil,err
      return nil, err
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return nil,err
      return nil, err
   }
   dataBytes, _ := json.Marshal(res.Data)
   if err = json.Unmarshal(dataBytes, &persons);err !=nil {
      return nil,err
   if err = json.Unmarshal(dataBytes, &persons); err != nil {
      return nil, err
   }
   return persons,nil
   return persons, nil
}
func (api DbPersonApi) GetPersonTotal (tableId string) (total int64,err error) {
func (api DbPersonApi) GetPersonTotal(tableId string) (total int64, err error) {
   url := DATA_URL_PREFIX + "/dbperson/getPersonTotal"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]string{
      "tableId": tableId,
   }
   body,err := client.DoGetRequest(url, paramBody,nil)
   body, err := client.DoGetRequest(url, paramBody, nil)
   if err != nil {
      return 0,err
      return 0, err
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return 0,err
      return 0, err
   }
   return int64(res.Data.(float64)),nil
   return int64(res.Data.(float64)), nil
}
func (api DbPersonApi) GetPersonsCompareCacheBase (from int,size int) (persons []*protomsg.Esinfo,err error) {
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))
   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)
   body, err := client.DoGetRequest(url, paramBody, nil)
   if err != nil {
      return nil,err
      return nil, err
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return nil,err
      return nil, err
   }
   dataBytes, _ := json.Marshal(res.Data)
   var arr []protomsg.Esinfo
   if err = json.Unmarshal(dataBytes, &arr);err !=nil {
      return nil,err
   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,
   for _, ei := range arr {
      persons = append(persons, &protomsg.Esinfo{
         Id:          ei.Id,
         Tableid:     ei.Tableid,
         FaceFeature: ei.FaceFeature,
         Enable: ei.Enable,
         Enable:      ei.Enable,
         CarNo: ei.CarNo,
      })
   }
   return persons,nil
   return persons, nil
}
func (api DbPersonApi) FindLikePersonIds (tableIds  []string,inputValue string) (interface{},error) {
func (api DbPersonApi) FindLikePersonIds(tableIds []string, inputValue string) (interface{}, error) {
   url := DATA_URL_PREFIX + "/dbperson/findLikePersonIds"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "tableIds": tableIds,
      "tableIds":   tableIds,
      "inputValue": inputValue,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return nil,err
      return nil, err
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return nil,err
      return nil, err
   }
   return res.Data,nil
   return res.Data, nil
}
func (api DbPersonApi) JoinDbTable (tableIds  []string,faceFeature string, personPicUrl string) (bool,interface{}) {
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))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{}{
      "tableIds": tableIds,
      "faceFeature": faceFeature,
      "tableIds":     tableIds,
      "faceFeature":  faceFeature,
      "personPicUrl": personPicUrl,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) Move (personId string,tableIds []string) (bool,interface{}) {
func (api DbPersonApi) Move(personId string, tableIds []string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/move"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   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)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api DbPersonApi) Copy (personId string,tableIds []string) (bool,interface{}) {
func (api DbPersonApi) Copy(personId string, tableIds []string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/dbperson/copy"
   netNode := getNetNode(url2Topic(Topic_CompTable_Service,url))
   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)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }
   return res.Success,res.Data
   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))
   netNode := getNetNode(url2Topic(Topic_CompTable_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   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)
      logPrint("unmarshal err:", err)
      return false
   }
   return res.Success
}
}