Обновление атрибута в обратном вызове Rails 3 - PullRequest
1 голос
/ 27 мая 2011

Исходя из этого вопроса , я потратил день на то, чтобы добавить совокупную сумму текущих продаж в мою таблицу продаж. Это немного сложно (для меня), потому что я хочу промежуточный итог для продаж, где isbn_id одинаков, и, в этом наборе, записи, где channel_id одинаков - ранжирован по invoice_date. Это все, чтобы я мог рассчитать роялти по конкретному диапазону проданных единиц.

Вот мой нерабочий код обратного вызова в модели Sale:

before_save :runningtotal

private

def runningtotal
  @sale = Sale.order("invoice_date ASC")
  @lastbal = @sale.find_all_by_isbn_id(@isbn).group_by(&:channel)
  #that sucessfully gets all sales ranked by date ascending, then groups them by channel, just for the current isbn.
  @lastbal.each do |channel, sale|
    sale.each_with_index do |sale, i|
      previous_sale = sale[i-1] unless i==0
      next unless previous_sale
      @total_quantity = previous_sale.quantity + :quantity
      write_attribute(:total_quantity,@total_quantity)
    end
  end 
end  

Это примерно как написать обратный вызов - только в модели? Это просто волшебно работает перед сохранением новой продажи?

Мой основной вопрос: как я могу обновить атрибут «total_quantity», чтобы он стал суммой «количества» для текущей записи и «total_quantity» для предыдущей записи по дате в обратном вызове before_save, в рамках ограничений находки для isbn_id и channel_id?

Вот результат поиска:

ruby-1.9.2-p180 :025 > @lastbal = @sale.find_all_by_isbn_id(@isbn).group_by(&:channel) 
=> {#<Channel id: 4, isbn_id: nil, channel_name: "Gratis", created_at: "2011-05-26 11:08:22", updated_at: "2011-05-26 11:08:22">=>[#<Sale id: 26, isbn_id: 2, quantity: 10000, value: 40000, currency: "", total_quantity: nil, created_at: "2011-05-26 11:11:30", updated_at: "2011-05-26 11:11:30", customer: "6", retail_price: nil, discount: nil, channel_id: 4, invoice_date: "2011-05-18", rule_id: nil, trenche: nil>], #<Channel id: 1, isbn_id: nil, channel_name: "Home", created_at: "2011-05-16 19:47:27", updated_at: "2011-05-16 19:47:27">=>[#<Sale id: 22, isbn_id: 2, quantity: 1000, value: 5193, currency: "", total_quantity: nil, created_at: "2011-05-25 19:46:03", updated_at: "2011-05-25 19:46:03", customer: "a", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2011-05-11", rule_id: nil, trenche: nil>, #<Sale id: 24, isbn_id: 2, quantity: 1000, value: 4394, currency: "", total_quantity: nil, created_at: "2011-05-26 09:48:16", updated_at: "2011-05-26 09:48:16", customer: "g", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2011-05-10", rule_id: nil, trenche: nil>, #<Sale id: 25, isbn_id: 2, quantity: 1000, value: 4394, currency: "", total_quantity: nil, created_at: "2011-05-26 10:02:38", updated_at: "2011-05-26 10:02:38", customer: "g", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2011-05-05", rule_id: nil, trenche: nil>, #<Sale id: 21, isbn_id: 2, quantity: 1000, value: 5193, currency: "", total_quantity: nil, created_at: "2011-05-25 14:12:45", updated_at: "2011-05-25 14:12:45", customer: "a", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2010-10-15", rule_id: nil, trenche: nil>, #<Sale id: 13, isbn_id: 2, quantity: 50, value: 159, currency: "", total_quantity: nil, created_at: "2011-05-25 12:33:09", updated_at: "2011-05-25 12:33:09", customer: "a", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2010-01-01", rule_id: nil, trenche: nil>, #<Sale id: 14, isbn_id: 2, quantity: 25, value: 129, currency: "", total_quantity: nil, created_at: "2011-05-25 12:33:23", updated_at: "2011-05-25 12:33:23", customer: "", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2010-01-01", rule_id: nil, trenche: nil>, #<Sale id: 12, isbn_id: 2, quantity: 100, value: 415, currency: "", total_quantity: nil, created_at: "2011-05-25 12:32:50", updated_at: "2011-05-25 15:13:21", customer: "a", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2001-10-01", rule_id: nil, trenche: nil>, #<Sale id: 11, isbn_id: 2, quantity: 500, value: 2197, currency: "", total_quantity: nil, created_at: "2011-05-25 12:32:24", updated_at: "2011-05-25 15:11:20", customer: "a", retail_price: nil, discount: nil, channel_id: 1, invoice_date: "2000-10-01", rule_id: nil, trenche: nil>], #<Channel id: 2, isbn_id: nil, channel_name: "Export", created_at: "2011-05-16 19:47:35", updated_at: "2011-05-16 19:47:35">=>[#<Sale id: 23, isbn_id: 2, quantity: 2000, value: 5000, currency: "", total_quantity: nil, created_at: "2011-05-26 09:16:15", updated_at: "2011-05-26 09:16:15", customer: "v", retail_price: nil, discount: nil, channel_id: 2, invoice_date: "2011-05-02", rule_id: nil, trenche: nil>, #<Sale id: 17, isbn_id: 2, quantity: 242, value: 657, currency: "", total_quantity: nil, created_at: "2011-05-25 12:34:24", updated_at: "2011-05-25 12:34:24", customer: "b ", retail_price: nil, discount: nil, channel_id: 2, invoice_date: "2010-10-15", rule_id: nil, trenche: nil>, #<Sale id: 18, isbn_id: 2, quantity: 54, value: 194, currency: "", total_quantity: nil, created_at: "2011-05-25 12:34:44", updated_at: "2011-05-25 12:34:44", customer: "b ", retail_price: nil, discount: nil, channel_id: 2, invoice_date: "2010-10-15", rule_id: nil, trenche: nil>, #<Sale id: 15, isbn_id: 2, quantity: 135, value: 377, currency: "", total_quantity: nil, created_at: "2011-05-25 12:33:48", updated_at: "2011-05-25 12:33:48", customer: "b ", retail_price: nil, discount: nil, channel_id: 2, invoice_date: "2010-09-15", rule_id: nil, trenche: nil>, #<Sale id: 16, isbn_id: 2, quantity: 433, value: 830, currency: "", total_quantity: nil, created_at: "2011-05-25 12:34:06", updated_at: "2011-05-25 12:34:06", customer: "b ", retail_price: nil, discount: nil, channel_id: 2, invoice_date: "2010-09-15", rule_id: nil, trenche: nil>]} 

Вот столбцы в моей модели Sale:

#  id             :integer         not null, primary key
#  isbn_id        :integer
#  quantity       :integer
#  value          :integer
#  currency       :string(255)
#  total_quantity :integer
#  created_at     :datetime
#  updated_at     :datetime
#  customer       :string(255)
#  retail_price   :integer
#  discount       :decimal(, )
#  channel_id     :integer
#  invoice_date   :date
#  rule_id        :integer

Большое спасибо заранее.

ОБНОВЛЕНИЕ: окончательное решение.

Действительно не уверен, что это считается «отдачей сообществу», так как это комично, а не СУХОЙ, полный путов, которые я использовал, чтобы выяснить все ошибки, и плохо отформатированных для загрузки, но, черт возьми, я нуб и, по крайней мере, я могу вернуться сюда и посмеяться над собой через несколько лет, когда я знаю, что я делаю. Итак, вот мое окончательное решение, в Sale.rb. Бедная чучела модели. Я сделаю рефакторинг этого, однажды.

before_save :runningtotal
after_commit :refresh

private
  def runningtotal
    # get the latest sale that matches the new sale's isbn and channel id, then rank by invoice date descending, and get the first record:
    lastsale = Sale.where(:isbn_id => self.isbn_id).where(:channel_id => self.channel_id).order("invoice_date DESC").first 
    allsales = Sale.where(:isbn_id => self.isbn_id).where(:channel_id => self.channel_id).order("invoice_date DESC")
    # set the total_quantity field in the new sales record to its quantity + the last sale's total.             
        if allsales.maximum(:invoice_date).nil? 
          puts "runningtotal thinks the max of invoice date in the allsales relation is nil"
          puts "and runningtotal is setting total_quantity on the new sale to be #{self.quantity + (lastsale.try(:total_quantity) || 0)}"
          self.total_quantity = self.quantity + (lastsale.try(:total_quantity) || 0)
          else    
            if self.invoice_date < allsales.maximum(:invoice_date)
            puts "the runningtotal method has been skipped because runningtotal thinks the current invoice date is less than the highest invoice date in the allsales relation"
            else 
              puts "this is a normal entry so runningtotal has set the total quantity to be #{self.quantity + (lastsale.try(:total_quantity) || 0) }"
              self.total_quantity = self.quantity + (lastsale.try(:total_quantity) || 0)     
            end
        end
  end

  def refresh
     allsales = Sale.where(:isbn_id => self.isbn_id).where(:channel_id => self.channel_id).order("invoice_date ASC")
       #if the runningtotal callback hasn't run, the total quantity will be nil, and nil triggers this after_commit callback 
       if total_quantity.nil?
         puts "running refresh callback"
         puts "here's a sample parameter pass: id: #{id} quantity: #{quantity} date: #{invoice_date} "
         puts "allsales class is #{allsales.class}"
         # if the new sale that's being saved has a date that's before any previous sale... 
            puts "before the if, refresh thinks that the earliest invoice date is #{allsales.minimum(:invoice_date)} and that invoice date is #{invoice_date}"
            if invoice_date <= allsales.minimum(:invoice_date)
              puts "date earlier than existing sales dates"
              puts "refresh thinks that the earliest invoice date is #{allsales.minimum(:invoice_date)} and that invoice date is #{invoice_date}"
              #... then set its total_quantity to the sale quantity... 

                update_attribute(:total_quantity, quantity)
                puts "total_qty updated with qty"
                # ... and update all subsequent records' total_quantity (skipping the before_save callback which would trigger an infinite loop).
                  allsales.each_with_index do |sale, i|
                    previous_sale = allsales[i-1] unless i==0
                    next unless previous_sale 
                     puts "getting qty out of arel when date earlier than others: #{previous_sale.quantity}"
                     puts "this is adding #{quantity} to #{previous_sale.quantity } which is #{quantity + previous_sale.total_quantity }" 
                 Sale.skip_callback(:save, :before, :runningtotal )
                    sale.update_attribute(:total_quantity, (sale.quantity + previous_sale.total_quantity ))
                 Sale.set_callback(:save, :before, :runningtotal)
                 end
            else
              # if the invoice date is within the min and max range of the previous sales...                
                # ... update all previous and subsequent records' total_quantity (skipping the before_save callback which would trigger an infinite loop).
                  allsales.each_with_index do |sale, i|                 
                    previous_sale = allsales[i-1] unless i==0
                    next unless previous_sale 
                    puts "getting qty out of arel within existing date range: #{previous_sale.quantity}"
                    puts "this is adding #{quantity} to #{previous_sale.quantity } which is #{quantity + previous_sale.total_quantity }" 
                Sale.skip_callback(:save, :before, :runningtotal )
                    sale.update_attribute(:total_quantity, (sale.quantity + previous_sale.total_quantity )) 
                Sale.set_callback(:save, :before, :runningtotal )
                  end
        end 
      end 
  end

1 Ответ

1 голос
/ 27 мая 2011

Да, использование before_save в модели будет запускаться при каждом сохранении, новом или обновленном. Таким образом, в расчетах необходимо следить за тем, чтобы текущая (новая) запись еще не существовала. ;) Возможно, вы захотите использовать before_save, :on => :create, чтобы ограничить его действием создания.

Однако, если я понимаю ваше английское изложение проблемы, ваш код довольно запутанный. Я даже не вижу, где находится @isbn, это может быть опасно ...

Нужно ли обновлять итоги по другим объектам, таким как isbn и канал? Обычно лучше просто рассчитать это по мере необходимости, чем пытаться кэшировать общее количество в каждой записи.

в обратном вызове, self является текущей (новой?) Записью, поэтому используйте ее для ссылки на новые значения.

  @sale = Sale.order("invoice_date ASC")
  @lastbal = @sale.find_all_by_isbn_id(@isbn).group_by(&:channel)

можно заменить этим, я думаю:

 @lastbal = Sale.order("invoice_date ASC").where(:isbn_id => self.isbn_id).group_by(&:channel)

Я предполагаю, что @isbn на самом деле isbn новой записи.

Оттуда я не уверен, что вы собираетесь обновить только новую запись или старую ... Если вы хотите обновить текущую запись, просто установите атрибут и закройте обратный вызов, и он будет сохранено, когда остальное сохранено: self.total_quantity = previous_sale.quantity + self.quantity

Если вы намереваетесь обновить и другие объекты, мы должны обновить эти объекты и сохранить их. Я не вижу, чтобы это происходило здесь, в вашем коде.

Ваш код проходит через несколько циклов, возможно, несколько раз нажимая write_attribute ... это не имеет смысла.

Если вы имеете в виду, что хотите найти последнюю запись, которая соответствует текущему isbn и каналу для обновления новой записи, я бы сделал следующее:

def runningtotal
  lastsale = Sale.where(:isbn_id => self.isbn_id).
                  where(:channel_id => self.channel_id).
                  order("invoice_date DESC").first 
             # that should be the latest sale that matches 
             # the current isbn and channel
  self.total_quantity = self.quantity + (lastsale.try(:total_quantity) || 0) 
      # watch out for nil if no previous record exists ^
end  

`

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...