116 lines
4.3 KiB
Ruby
116 lines
4.3 KiB
Ruby
# encoding: utf-8
|
|
class Supplier < ActiveRecord::Base
|
|
has_many :articles, -> { where(:type => nil).includes(:article_category).order('article_categories.name', 'articles.name') }
|
|
has_many :stock_articles, -> { includes(:article_category).order('article_categories.name', 'articles.name') }
|
|
has_many :orders
|
|
has_many :deliveries
|
|
has_many :invoices
|
|
belongs_to :shared_supplier # for the sharedLists-App
|
|
|
|
include ActiveModel::MassAssignmentSecurity
|
|
attr_accessible :name, :address, :phone, :phone2, :fax, :email, :url, :contact_person, :customer_number,
|
|
:delivery_days, :order_howto, :note, :shared_supplier_id, :min_order_quantity, :shared_sync_method
|
|
|
|
validates :name, :presence => true, :length => { :in => 4..30 }
|
|
validates :phone, :presence => true, :length => { :in => 8..25 }
|
|
validates :address, :presence => true, :length => { :in => 8..50 }
|
|
validates_length_of :order_howto, :note, maximum: 250
|
|
validate :valid_shared_sync_method
|
|
validate :uniqueness_of_name
|
|
|
|
scope :undeleted, -> { where(deleted_at: nil) }
|
|
|
|
# sync all articles with the external database
|
|
# returns an array with articles(and prices), which should be updated (to use in a form)
|
|
# also returns an array with outlisted_articles, which should be deleted
|
|
# also returns an array with new articles, which should be added (depending on shared_sync_method)
|
|
def sync_all
|
|
updated_articles = Array.new
|
|
outlisted_articles = Array.new
|
|
new_articles = Array.new
|
|
for article in articles.undeleted
|
|
# try to find the associated shared_article
|
|
shared_article = article.shared_article(self)
|
|
|
|
if shared_article # article will be updated
|
|
|
|
unequal_attributes = article.shared_article_changed?(self)
|
|
unless unequal_attributes.blank? # skip if shared_article has not been changed
|
|
|
|
# try to convert different units
|
|
new_price, new_unit_quantity = article.convert_units
|
|
if new_price && new_unit_quantity
|
|
article.price = new_price
|
|
article.unit_quantity = new_unit_quantity
|
|
else
|
|
article.price = shared_article.price
|
|
article.unit_quantity = shared_article.unit_quantity
|
|
article.unit = shared_article.unit
|
|
end
|
|
# update other attributes
|
|
article.attributes = {
|
|
:name => shared_article.name,
|
|
:manufacturer => shared_article.manufacturer,
|
|
:origin => shared_article.origin,
|
|
:shared_updated_on => shared_article.updated_on,
|
|
:tax => shared_article.tax,
|
|
:deposit => shared_article.deposit,
|
|
:note => shared_article.note
|
|
}
|
|
updated_articles << [article, unequal_attributes]
|
|
end
|
|
# Articles with no order number can be used to put non-shared articles
|
|
# in a shared supplier, with sync keeping them.
|
|
elsif not article.order_number.blank?
|
|
# article isn't in external database anymore
|
|
outlisted_articles << article
|
|
end
|
|
end
|
|
# Find any new articles, unless the import is manual
|
|
unless shared_sync_method == 'import'
|
|
for shared_article in shared_supplier.shared_articles
|
|
unless articles.undeleted.find_by_order_number(shared_article.number)
|
|
new_articles << shared_article.build_new_article(self)
|
|
end
|
|
end
|
|
end
|
|
return [updated_articles, outlisted_articles, new_articles]
|
|
end
|
|
|
|
# default value
|
|
def shared_sync_method
|
|
return unless shared_supplier
|
|
self[:shared_sync_method] || 'import'
|
|
end
|
|
|
|
def deleted?
|
|
deleted_at.present?
|
|
end
|
|
|
|
def mark_as_deleted
|
|
transaction do
|
|
update_column :deleted_at, Time.now
|
|
articles.each(&:mark_as_deleted)
|
|
end
|
|
end
|
|
|
|
protected
|
|
|
|
# make sure the shared_sync_method is allowed for the shared supplier
|
|
def valid_shared_sync_method
|
|
if shared_supplier && !shared_supplier.shared_sync_methods.include?(shared_sync_method)
|
|
errors.add :name, :included
|
|
end
|
|
end
|
|
|
|
# Make sure, the name is uniq, add usefull message if uniq group is already deleted
|
|
def uniqueness_of_name
|
|
supplier = Supplier.where(name: name)
|
|
supplier = supplier.where.not(id: self.id) unless new_record?
|
|
if supplier.exists?
|
|
message = supplier.first.deleted? ? :taken_with_deleted : :taken
|
|
errors.add :name, message
|
|
end
|
|
end
|
|
end
|
|
|