| | |
| | | document_number_list = []string{} |
| | | for _, i := range labelFilter { |
| | | document_number_list = append(document_number_list, i.Id) |
| | | document_number_list = append(document_number_list, i.Id) |
| | | } |
| | | } |
| | | if len(m.KeyTypes) > 0 { |
| | |
| | | person.PersonType = i.PersonType |
| | | document_number_map[i.DocumentNumber] = person |
| | | } |
| | | logger.Debugf("document_number_list %s last result %s", m.Task.Name, document_number_list) |
| | | records, err := queryEsLocation(db.GetEsClient(), m, document_number_list) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | logger.Debugf("records %s last result %s", m.Task.Name, records) |
| | | domains, err := domainToLocation(records) |
| | | if err != nil { |
| | | return err |
| | |
| | | filters = append(filters, map[string]interface{}{ |
| | | "range": map[string]interface{}{ |
| | | "picDate": map[string]interface{}{ |
| | | "gte": start.Format(time.RFC3339), |
| | | "lte": end.Format(time.RFC3339), |
| | | "gte": start.Format("2006-01-02 15:04:05"), |
| | | "lte": end.Format("2006-01-02 15:04:05"), |
| | | }, |
| | | }, |
| | | }) |