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
}