mirror of
https://github.com/LaCasemate/fab-manager.git
synced 2024-12-01 12:24:28 +01:00
30 lines
1.4 KiB
Ruby
30 lines
1.4 KiB
Ruby
class InsertCustomAggregations < ActiveRecord::Migration
|
|
def change
|
|
# available reservations hours for machines
|
|
machine = StatisticIndex.find_by_es_type_key('machine')
|
|
machine_hours = StatisticType.find_by(key: 'hour', statistic_index_id: machine.id)
|
|
|
|
available_hours = StatisticCustomAggregation.new({
|
|
statistic_type_id: machine_hours.id,
|
|
es_index: 'fablab',
|
|
es_type: 'availabilities',
|
|
field: 'available_hours',
|
|
query: '{"size":0, "aggregations":{"%{aggs_name}":{"sum":{"field":"hours_duration"}}}, "query":{"bool":{"must":[{"range":{"start_at":{"gte":"%{start_date}", "lte":"%{end_date}"}}}, {"match":{"available_type":"machines"}}]}}}'
|
|
})
|
|
available_hours.save!
|
|
|
|
# available training tickets
|
|
training = StatisticIndex.find_by_es_type_key('training')
|
|
training_bookings = StatisticType.find_by(key: 'booking', statistic_index_id: training.id)
|
|
|
|
available_tickets = StatisticCustomAggregation.new({
|
|
statistic_type_id: training_bookings.id,
|
|
es_index: 'fablab',
|
|
es_type: 'availabilities',
|
|
field: 'available_tickets',
|
|
query: '{"size":0, "aggregations":{"%{aggs_name}":{"sum":{"field":"nb_total_places"}}}, "query":{"bool":{"must":[{"range":{"start_at":{"gte":"%{start_date}", "lte":"%{end_date}"}}}, {"match":{"available_type":"training"}}]}}}'
|
|
})
|
|
available_tickets.save!
|
|
end
|
|
end
|