| | |
|---|
| | | document_number_list = append(document_number_list, i.Id) |
|---|
| | | person := document_number_map[i.Id] |
|---|
| | | person.PersonType = i.PersonType |
|---|
| | | document_number_map[i.DocumentNumber] = person |
|---|
| | | document_number_map[i.Id] = person |
|---|
| | | } |
|---|
| | | //logger.Debugf("document_number_map %s last result %s", m.Task.Name, document_number_map) |
|---|
| | | records, err := queryEsLocation(db.GetEsClient(), m, document_number_list) |
|---|
| | |
|---|
| | | if err := json.NewDecoder(res.Body).Decode(&result); err != nil { |
|---|
| | | return nil, fmt.Errorf("error parsing response body: %s", err) |
|---|
| | | } |
|---|
| | | logger.Debugf("result--------------------------------------- %s", result) |
|---|
| | | //logger.Debugf("result--------------------------------------- %s", result) |
|---|
| | | // 解析聚合结果 |
|---|
| | | var records []*LocationRecord |
|---|
| | | if aggs, ok := result["aggregations"].(map[string]interface{}); ok { |
|---|
