Story#105855968 - send invoices to directo

app/models/bank_transaction.rb

@@ -2,7 +2,6 @@ class BankTransaction < ActiveRecord::Base
   include Versions
   belongs_to :bank_statement
   has_one :account_activity
-  has_many :directo_records, as: :item, class_name: 'Directo'# Deprecated
 
   scope :unbinded, lambda {
     where('id NOT IN (SELECT bank_transaction_id FROM account_activities where bank_transaction_id IS NOT NULL)')

app/models/directo.rb

@@ -53,7 +53,7 @@ class Directo < ActiveRecord::Base
   def self.dump_result_to_db mappers, xml
     Nokogiri::XML(xml).css("Result").each do |res|
       obj = mappers[res.attributes["docid"].value.to_i]
-      obj.directo_records.create!(response: res.as_json.to_h)
+      obj.directo_records.create!(response: res.as_json.to_h, invoice_number: obj.number)
       obj.update_columns(in_directo: true)
       Rails.logger.info("[DIRECTO] Invoice #{res.attributes["docid"].value} was pushed and return is #{res.as_json.to_h.inspect}")
     end
@@ -61,13 +61,24 @@ class Directo < ActiveRecord::Base
 
 
   def self.send_monthly_invoices
-    I18n.locale = :et
+    I18n.locale    = :et
     month          = Time.now - 1.month
     invoices_until = month.end_of_month
     date_format    = "%Y-%m-%d"
+    invoice_counter= Counter.new
+
+    min_directo    = Setting.invoice_number_min.presence.try(:to_i)
+    max_directo    = Setting.directo_monthly_number_max.presence.try(:to_i)
+    last_directo   = [Setting.directo_monthly_number_last.presence.try(:to_i), min_directo].compact.max || 0
+    if max_directo && max_directo <= last_directo
+      raise "Directo counter is out of period"
+    end
 
     Registrar.find_each do |registrar|
-      next unless registrar.cash_account
+      unless registrar.cash_account
+        Rails.logger.info("[DIRECTO] Monthly invoice for registrar #{registrar.id} has been skipped as it doesn't has cash_account")
+        next
+      end
       counter = Counter.new(1)
       items   = {}
       registrar_activities = AccountActivity.where(account_id: registrar.account_ids).where("created_at BETWEEN ? AND ?",month.beginning_of_month, month.end_of_month)
@@ -75,7 +86,10 @@ class Directo < ActiveRecord::Base
       # adding domains items
       registrar_activities.where(activity_type: [AccountActivity::CREATE, AccountActivity::RENEW]).each do |activity|
         pricelist    = load_activity_pricelist(activity)
-        next unless pricelist
+        unless pricelist
+          Rails.logger.error("[DIRECTO] Skipping activity #{activity.id} as pricelist not found")
+          next
+        end
 
         pricelist.years_amount.times do |i|
           year = i+1
@@ -104,9 +118,12 @@ class Directo < ActiveRecord::Base
 
       # generating XML
       if items.any?
+        directo_next = last_directo + 1
+        invoice_counter.next
+
         builder = Nokogiri::XML::Builder.new(encoding: "UTF-8") do |xml|
           xml.invoices{
-            xml.invoice("Number"      =>"13980",
+            xml.invoice("Number"      =>directo_next,
                         "InvoiceDate" =>invoices_until.strftime(date_format),
                         "PaymentTerm" =>"E",
                         "CustomerCode"=>registrar.directo_handle,
@@ -120,12 +137,23 @@ class Directo < ActiveRecord::Base
             }
           }
         end
-        puts builder.to_xml
+
+        data = builder.to_xml.gsub("\n",'')
+        response = RestClient::Request.execute(url: ENV['directo_invoice_url'], method: :post, payload: {put: "1", what: "invoice", xmldata: data}, verify_ssl: false).to_s
+        Setting.directo_monthly_number_last = directo_next
+        Nokogiri::XML(response).css("Result").each do |res|
+          Directo.create!(response: res.as_json.to_h, invoice_number: directo_next)
+          Rails.logger.info("[DIRECTO] Invoice #{res.attributes["docid"].value} was pushed and return is #{res.as_json.to_h.inspect}")
+        end
+      else
+        Rails.logger.info("[DIRECTO] Registrar #{registrar.id} has nothing to be sent to Directo")
       end
 
     end
+    STDOUT << "#{Time.zone.now.utc} - Directo invoices sending finished. #{invoice_counter.now} are sent\n"
   end
 
+
   def self.load_activity_pricelist activity
     @pricelists ||= {}
     return @pricelists[activity.log_pricelist_id] if @pricelists.has_key?(activity.log_pricelist_id)

app/views/admin/settings/index.haml

@@ -69,6 +69,9 @@
         %tbody
           = render 'setting_row', var: :invoice_number_min
           = render 'setting_row', var: :invoice_number_max
+          = render 'setting_row', var: :directo_monthly_number_min
+          = render 'setting_row', var: :directo_monthly_number_max
+          = render 'setting_row', var: :directo_monthly_number_last
           = render 'setting_row', var: :days_to_keep_invoices_active
           = render 'setting_row', var: :days_to_keep_overdue_invoices_active
           = render 'setting_row', var: :minimum_deposit