258 lines
9.7 KiB
Ruby
258 lines
9.7 KiB
Ruby
# Redmine plugin for Document Management System "Features"
|
|
#
|
|
# Copyright (C) 2011 Vít Jonáš <vit.jonas@gmail.com>
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License
|
|
# as published by the Free Software Foundation; either version 2
|
|
# of the License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
|
|
class DmsfFileRevision < ActiveRecord::Base
|
|
unloadable
|
|
belongs_to :file, :class_name => "DmsfFile", :foreign_key => "dmsf_file_id"
|
|
belongs_to :source_revision, :class_name => "DmsfFileRevision", :foreign_key => "source_dmsf_file_revision_id"
|
|
belongs_to :user
|
|
belongs_to :folder, :class_name => "DmsfFolder", :foreign_key => "dmsf_folder_id"
|
|
belongs_to :deleted_by_user, :class_name => "User", :foreign_key => "deleted_by_user_id"
|
|
belongs_to :project
|
|
has_many :access, :class_name => "DmsfFileRevisionAccess", :foreign_key => "dmsf_file_revision_id", :dependent => :destroy
|
|
has_many :dmsf_workflow_step_assignment, :dependent => :destroy
|
|
|
|
#Returns a list of revisions that are not deleted here, or deleted at parent level either
|
|
scope :visible, lambda {|*args| joins(:file).where(DmsfFile.visible_condition(args.shift || User.current, *args)).where("#{self.table_name}.deleted = :false", :false => false ).readonly(false) }
|
|
|
|
acts_as_customizable
|
|
|
|
acts_as_event :title => Proc.new {|o| "#{l(:label_dmsf_updated)}: #{o.file.dmsf_path_str}"},
|
|
:url => Proc.new {|o| {:controller => 'dmsf_files', :action => 'show', :id => o.file}},
|
|
:datetime => Proc.new {|o| o.updated_at },
|
|
:description => Proc.new {|o| o.comment },
|
|
:author => Proc.new {|o| o.user }
|
|
|
|
acts_as_activity_provider :type => "dmsf_files",
|
|
:timestamp => "#{DmsfFileRevision.table_name}.updated_at",
|
|
:author_key => "#{DmsfFileRevision.table_name}.user_id",
|
|
:permission => :view_dmsf_files,
|
|
:find_options => {:select => "#{DmsfFileRevision.table_name}.*",
|
|
:joins =>
|
|
"INNER JOIN #{DmsfFile.table_name} ON #{DmsfFileRevision.table_name}.dmsf_file_id = #{DmsfFile.table_name}.id " +
|
|
"INNER JOIN #{Project.table_name} ON #{DmsfFile.table_name}.project_id = #{Project.table_name}.id",
|
|
:conditions => ["#{DmsfFile.table_name}.deleted = :false", {:false => false}]
|
|
}
|
|
|
|
validates :title, :name, :presence => true
|
|
validates_format_of :name, :with => DmsfFolder.invalid_characters,
|
|
:message => l(:error_contains_invalid_character)
|
|
|
|
def self.remove_extension(filename)
|
|
filename[0, (filename.length - File.extname(filename).length)]
|
|
end
|
|
|
|
#TODO: check if better to move to dmsf_upload class
|
|
def self.filename_to_title(filename)
|
|
remove_extension(filename).gsub(/_+/, " ");
|
|
end
|
|
|
|
def delete(delete_all = false)
|
|
if self.file.locked_for_user?
|
|
errors[:base] << l(:error_file_is_locked)
|
|
return false
|
|
end
|
|
if !delete_all && self.file.revisions.length <= 1
|
|
errors[:base] << l(:error_at_least_one_revision_must_be_present)
|
|
return false
|
|
end
|
|
dependent = DmsfFileRevision.find(:all, :conditions =>
|
|
["source_dmsf_file_revision_id = :id and deleted = :deleted",
|
|
{:id => self.id, :deleted => false}])
|
|
dependent.each do |d|
|
|
d.source_revision = self.source_revision
|
|
d.save!
|
|
end
|
|
if Setting.plugin_redmine_dmsf["dmsf_really_delete_files"]
|
|
dependent = DmsfFileRevision.find(:all, :conditions =>
|
|
["disk_filename = :filename", {:filename => self.disk_filename}])
|
|
File.delete(self.disk_file) if dependent.length <= 1 && File.exist?(self.disk_file)
|
|
DmsfFileRevisionAccess.find(:all, :conditions => ["dmsf_file_revision_id = ?", self.id]).each {|a| a.destroy}
|
|
CustomValue.find(:all, :conditions => "customized_id = " + self.id.to_s).each do |v|
|
|
v.destroy
|
|
end
|
|
self.destroy
|
|
else
|
|
self.deleted = true
|
|
self.deleted_by_user = User.current
|
|
save
|
|
end
|
|
end
|
|
|
|
# In a static call, we find the first matched record on base object type and
|
|
# then run the access_grouped call against it
|
|
def self.access_grouped(revision_id)
|
|
DmsfFileRevision.find(revision_id).first.access_grouped
|
|
end
|
|
|
|
# Get grouped data from dmsf_file_revision_access about file interactions
|
|
# - 22-06-2012 - Rather than calling a static, we should use the access
|
|
# (has_many) to re-run a query - it makes more sense then executing
|
|
# custom SQL into a temporary object
|
|
#
|
|
def access_grouped
|
|
access.select("user_id, count(*) as count, min(created_at) as first_at, max(created_at) as last_at").group("user_id")
|
|
end
|
|
|
|
def version
|
|
"#{self.major_version}.#{self.minor_version}"
|
|
end
|
|
|
|
def disk_file
|
|
storage_base = "#{DmsfFile.storage_path}" #perhaps .dup?
|
|
unless project.nil?
|
|
project_base = project.identifier.gsub(/[^\w\.\-]/,'_')
|
|
storage_base << "/p_#{project_base}"
|
|
end
|
|
Dir.mkdir(storage_base) unless File.exists?(storage_base)
|
|
"#{storage_base}/#{self.disk_filename}"
|
|
end
|
|
|
|
def detect_content_type
|
|
content_type = self.mime_type
|
|
content_type = Redmine::MimeType.of(self.disk_filename) if content_type.blank?
|
|
content_type = "application/octet-stream" if content_type.blank?
|
|
content_type.to_s
|
|
end
|
|
|
|
#TODO: use standard clone method
|
|
def clone
|
|
new_revision = DmsfFileRevision.new
|
|
new_revision.file = self.file
|
|
new_revision.project = self.project
|
|
new_revision.disk_filename = self.disk_filename
|
|
new_revision.size = self.size
|
|
new_revision.mime_type = self.mime_type
|
|
new_revision.title = self.title
|
|
new_revision.description = self.description
|
|
new_revision.workflow = self.workflow
|
|
new_revision.major_version = self.major_version
|
|
new_revision.minor_version = self.minor_version
|
|
|
|
new_revision.source_revision = self
|
|
new_revision.user = User.current
|
|
|
|
new_revision.name = self.name
|
|
new_revision.folder = self.folder
|
|
|
|
new_revision.custom_values = self.custom_values.map(&:clone)
|
|
|
|
return new_revision
|
|
end
|
|
|
|
def workflow_str(name)
|
|
str = ''
|
|
if name && dmsf_workflow_id
|
|
wf = DmsfWorkflow.find_by_id(dmsf_workflow_id)
|
|
str = "#{wf.name} - " if wf
|
|
end
|
|
case workflow
|
|
when DmsfWorkflow::STATE_WAITING_FOR_APPROVAL
|
|
str + l(:title_waiting_for_approval)
|
|
when DmsfWorkflow::STATE_APPROVED
|
|
str + l(:title_approved)
|
|
when DmsfWorkflow::STATE_ASSIGNED
|
|
str + l(:title_assigned)
|
|
when DmsfWorkflow::STATE_REJECTED
|
|
str + l(:title_rejected)
|
|
else
|
|
str + l(:title_none)
|
|
end
|
|
end
|
|
|
|
def set_workflow(dmsf_workflow_id, commit)
|
|
self.dmsf_workflow_id = dmsf_workflow_id
|
|
if commit == 'start'
|
|
self.workflow = DmsfWorkflow::STATE_WAITING_FOR_APPROVAL
|
|
self.dmsf_workflow_started_by = User.current.id if User.current
|
|
self.dmsf_workflow_started_at = DateTime.now
|
|
else
|
|
self.workflow = DmsfWorkflow::STATE_ASSIGNED
|
|
self.dmsf_workflow_assigned_by = User.current.id if User.current
|
|
self.dmsf_workflow_assigned_at = DateTime.now
|
|
end
|
|
end
|
|
|
|
def assign_workflow(dmsf_workflow_id)
|
|
wf = DmsfWorkflow.find_by_id(dmsf_workflow_id)
|
|
wf.assign(self.id) if wf && self.id
|
|
end
|
|
|
|
def increase_version(version_to_increase, new_content)
|
|
if new_content
|
|
self.minor_version = case version_to_increase
|
|
when 2 then 0
|
|
else self.minor_version + 1
|
|
end
|
|
else
|
|
self.minor_version = case version_to_increase
|
|
when 1 then self.minor_version + 1
|
|
when 2 then 0
|
|
else self.minor_version
|
|
end
|
|
end
|
|
|
|
self.major_version = case version_to_increase
|
|
when 2 then self.major_version + 1
|
|
else self.major_version
|
|
end
|
|
end
|
|
|
|
def display_title
|
|
#if self.title.length > 35
|
|
# return self.title[0, 30] + "..."
|
|
#else
|
|
return self.title
|
|
#end
|
|
end
|
|
|
|
def new_storage_filename
|
|
raise DmsfAccessError, "File id is not set" unless self.file.id
|
|
filename = DmsfHelper.sanitize_filename(self.name)
|
|
timestamp = DateTime.now.strftime("%y%m%d%H%M%S")
|
|
while File.exist?(File.join(DmsfFile.storage_path, "#{timestamp}_#{self.file.id}_#{filename}"))
|
|
timestamp.succ!
|
|
end
|
|
"#{timestamp}_#{self.file.id}_#{filename}"
|
|
end
|
|
|
|
def copy_file_content(open_file)
|
|
File.open(self.disk_file, "wb") do |f|
|
|
while (buffer = open_file.read(8192))
|
|
f.write(buffer)
|
|
end
|
|
end
|
|
end
|
|
|
|
# Overrides Redmine::Acts::Customizable::InstanceMethods#available_custom_fields
|
|
def available_custom_fields
|
|
search_project = nil
|
|
if self.project.present?
|
|
search_project = self.project
|
|
elsif self.project_id.present?
|
|
search_project = Project.find(self.project_id)
|
|
end
|
|
if search_project
|
|
search_project.all_dmsf_custom_fields
|
|
else
|
|
DmsfFileRevisionCustomField.all
|
|
end
|
|
end
|
|
|
|
end
|