| | |
| | | person.PersonType = i.PersonType |
| | | document_number_map[i.DocumentNumber] = person |
| | | } |
| | | logger.Debugf("document_number_map %s last result %s", m.Task.Name, document_number_map) |
| | | //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 != nil { |
| | | return err |
| | |
| | | for _, record := range records { |
| | | tagTypes = []string{} |
| | | for _, personId := range record.DocumentNumbers { |
| | | logger.Debugf("document_number_map[personId] %s", document_number_map[personId]) |
| | | tagTypes = append(tagTypes, document_number_map[personId].PersonType) |
| | | lastAppearanceTime = document_number_map[personId].LastAppearanceTime |
| | | } |
| | |
| | | } |
| | | filters = append(filters, addrParams) |
| | | } |
| | | //var queryTimes []map[string]interface{} |
| | | var queryTimes []map[string]interface{} |
| | | for date := startTime; date.Before(nowTime); date = date.Add(24 * time.Hour) { |
| | | start := time.Date(date.Year(), date.Month(), date.Day(), locationModel.StartTime, 0, 0, 0, date.Location()) |
| | | end := time.Date(date.Year(), date.Month(), date.Day(), locationModel.EndTime, 0, 0, 0, date.Location()) |
| | | |
| | | //queryTimes = append(queryTimes, map[string]interface{}{ |
| | | // "range": map[string]interface{}{ |
| | | // "picDate": map[string]interface{}{ |
| | | // "gte": start.Format(time.DateTime), // "2006-01-02 15:04:05d" |
| | | // "lte": end.Format(time.DateTime), |
| | | // }, |
| | | // }, |
| | | //}) |
| | | |
| | | filters = append(filters, map[string]interface{}{ |
| | | queryTimes = append(queryTimes, map[string]interface{}{ |
| | | "range": map[string]interface{}{ |
| | | "picDate": map[string]interface{}{ |
| | | "gte": start.Format(time.DateTime), |
| | | "gte": start.Format(time.DateTime), // "2006-01-02 15:04:05d" |
| | | "lte": end.Format(time.DateTime), |
| | | }, |
| | | }, |
| | | }) |
| | | |
| | | //filters = append(filters, map[string]interface{}{ |
| | | // "range": map[string]interface{}{ |
| | | // "picDate": map[string]interface{}{ |
| | | // "gte": start.Format(time.DateTime), |
| | | // "lte": end.Format(time.DateTime), |
| | | // }, |
| | | // }, |
| | | //}) |
| | | } |
| | | //filters = append(filters, map[string]interface{}{ |
| | | // "bool": map[string]interface{}{ |
| | | // "filter": queryTimes, |
| | | // }, |
| | | //}) |
| | | filters = append(filters, map[string]interface{}{ |
| | | "bool": map[string]interface{}{ |
| | | "should": queryTimes, |
| | | }, |
| | | }) |
| | | //logger.Debugf("filters--------------------------------------- %s", filters) |
| | | query := map[string]interface{}{ |
| | | "query": map[string]interface{}{ |