| | |
| | | |
| | | 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 |
| | | } |
| | | } |