123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630 |
- # Redmine - project management software
- # Copyright (C) 2006-2017 Jean-Philippe Lang
- #
- # 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 IssueQuery < Query
-
- self.queried_class = Issue
- self.view_permission = :view_issues
-
- self.available_columns = [
- QueryColumn.new(:id, :sortable => "#{Issue.table_name}.id", :default_order => 'desc', :caption => '#', :frozen => true),
- QueryColumn.new(:project, :sortable => "#{Project.table_name}.name", :groupable => true),
- QueryColumn.new(:tracker, :sortable => "#{Tracker.table_name}.position", :groupable => true),
- QueryColumn.new(:parent, :sortable => ["#{Issue.table_name}.root_id", "#{Issue.table_name}.lft ASC"], :default_order => 'desc', :caption => :field_parent_issue),
- QueryColumn.new(:status, :sortable => "#{IssueStatus.table_name}.position", :groupable => true),
- QueryColumn.new(:priority, :sortable => "#{IssuePriority.table_name}.position", :default_order => 'desc', :groupable => true),
- QueryColumn.new(:subject, :sortable => "#{Issue.table_name}.subject"),
- QueryColumn.new(:author, :sortable => lambda {User.fields_for_order_statement("authors")}, :groupable => true),
- QueryColumn.new(:assigned_to, :sortable => lambda {User.fields_for_order_statement}, :groupable => true),
- TimestampQueryColumn.new(:updated_on, :sortable => "#{Issue.table_name}.updated_on", :default_order => 'desc', :groupable => true),
- QueryColumn.new(:category, :sortable => "#{IssueCategory.table_name}.name", :groupable => true),
- QueryColumn.new(:fixed_version, :sortable => lambda {Version.fields_for_order_statement}, :groupable => true),
- QueryColumn.new(:start_date, :sortable => "#{Issue.table_name}.start_date", :groupable => true),
- QueryColumn.new(:due_date, :sortable => "#{Issue.table_name}.due_date", :groupable => true),
- QueryColumn.new(:estimated_hours, :sortable => "#{Issue.table_name}.estimated_hours", :totalable => true),
- QueryColumn.new(:total_estimated_hours,
- :sortable => "COALESCE((SELECT SUM(estimated_hours) FROM #{Issue.table_name} subtasks" +
- " WHERE subtasks.root_id = #{Issue.table_name}.root_id AND subtasks.lft >= #{Issue.table_name}.lft AND subtasks.rgt <= #{Issue.table_name}.rgt), 0)",
- :default_order => 'desc'),
- QueryColumn.new(:done_ratio, :sortable => "#{Issue.table_name}.done_ratio", :groupable => true),
- TimestampQueryColumn.new(:created_on, :sortable => "#{Issue.table_name}.created_on", :default_order => 'desc', :groupable => true),
- TimestampQueryColumn.new(:closed_on, :sortable => "#{Issue.table_name}.closed_on", :default_order => 'desc', :groupable => true),
- QueryColumn.new(:last_updated_by, :sortable => lambda {User.fields_for_order_statement("last_journal_user")}),
- QueryColumn.new(:relations, :caption => :label_related_issues),
- QueryColumn.new(:attachments, :caption => :label_attachment_plural),
- QueryColumn.new(:description, :inline => false),
- QueryColumn.new(:last_notes, :caption => :label_last_notes, :inline => false)
- ]
-
- def initialize(attributes=nil, *args)
- super attributes
- self.filters ||= { 'status_id' => {:operator => "o", :values => [""]} }
- end
-
- def draw_relations
- r = options[:draw_relations]
- r.nil? || r == '1'
- end
-
- def draw_relations=(arg)
- options[:draw_relations] = (arg == '0' ? '0' : nil)
- end
-
- def draw_progress_line
- r = options[:draw_progress_line]
- r == '1'
- end
-
- def draw_progress_line=(arg)
- options[:draw_progress_line] = (arg == '1' ? '1' : nil)
- end
-
- def build_from_params(params, defaults={})
- super
- self.draw_relations = params[:draw_relations] || (params[:query] && params[:query][:draw_relations]) || options[:draw_relations]
- self.draw_progress_line = params[:draw_progress_line] || (params[:query] && params[:query][:draw_progress_line]) || options[:draw_progress_line]
- self
- end
-
- def initialize_available_filters
- add_available_filter "status_id",
- :type => :list_status, :values => lambda { issue_statuses_values }
-
- add_available_filter("project_id",
- :type => :list, :values => lambda { project_values }
- ) if project.nil?
-
- add_available_filter "tracker_id",
- :type => :list, :values => trackers.collect{|s| [s.name, s.id.to_s] }
-
- add_available_filter "priority_id",
- :type => :list, :values => IssuePriority.all.collect{|s| [s.name, s.id.to_s] }
-
- add_available_filter("author_id",
- :type => :list, :values => lambda { author_values }
- )
-
- add_available_filter("assigned_to_id",
- :type => :list_optional, :values => lambda { assigned_to_values }
- )
-
- add_available_filter("member_of_group",
- :type => :list_optional, :values => lambda { Group.givable.visible.collect {|g| [g.name, g.id.to_s] } }
- )
-
- add_available_filter("assigned_to_role",
- :type => :list_optional, :values => lambda { Role.givable.collect {|r| [r.name, r.id.to_s] } }
- )
-
- add_available_filter "fixed_version_id",
- :type => :list_optional, :values => lambda { fixed_version_values }
-
- add_available_filter "fixed_version.due_date",
- :type => :date,
- :name => l(:label_attribute_of_fixed_version, :name => l(:field_effective_date))
-
- add_available_filter "fixed_version.status",
- :type => :list,
- :name => l(:label_attribute_of_fixed_version, :name => l(:field_status)),
- :values => Version::VERSION_STATUSES.map{|s| [l("version_status_#{s}"), s] }
-
- add_available_filter "category_id",
- :type => :list_optional,
- :values => lambda { project.issue_categories.collect{|s| [s.name, s.id.to_s] } } if project
-
- add_available_filter "subject", :type => :text
- add_available_filter "description", :type => :text
- add_available_filter "created_on", :type => :date_past
- add_available_filter "updated_on", :type => :date_past
- add_available_filter "closed_on", :type => :date_past
- add_available_filter "start_date", :type => :date
- add_available_filter "due_date", :type => :date
- add_available_filter "estimated_hours", :type => :float
- add_available_filter "done_ratio", :type => :integer
-
- if User.current.allowed_to?(:set_issues_private, nil, :global => true) ||
- User.current.allowed_to?(:set_own_issues_private, nil, :global => true)
- add_available_filter "is_private",
- :type => :list,
- :values => [[l(:general_text_yes), "1"], [l(:general_text_no), "0"]]
- end
-
- add_available_filter "attachment",
- :type => :text, :name => l(:label_attachment)
-
- if User.current.logged?
- add_available_filter "watcher_id",
- :type => :list, :values => lambda { watcher_values }
- end
-
- add_available_filter("updated_by",
- :type => :list, :values => lambda { author_values }
- )
-
- add_available_filter("last_updated_by",
- :type => :list, :values => lambda { author_values }
- )
-
- if project && !project.leaf?
- add_available_filter "subproject_id",
- :type => :list_subprojects,
- :values => lambda { subproject_values }
- end
-
- add_available_filter("project.status",
- :type => :list,
- :name => l(:label_attribute_of_project, :name => l(:field_status)),
- :values => lambda { project_statuses_values }
- ) if project.nil? || !project.leaf?
-
- add_custom_fields_filters(issue_custom_fields)
- add_associations_custom_fields_filters :project, :author, :assigned_to, :fixed_version
-
- IssueRelation::TYPES.each do |relation_type, options|
- add_available_filter relation_type, :type => :relation, :label => options[:name], :values => lambda {all_projects_values}
- end
- add_available_filter "parent_id", :type => :tree, :label => :field_parent_issue
- add_available_filter "child_id", :type => :tree, :label => :label_subtask_plural
-
- add_available_filter "issue_id", :type => :integer, :label => :label_issue
-
- Tracker.disabled_core_fields(trackers).each {|field|
- delete_available_filter field
- }
- end
-
- def available_columns
- return @available_columns if @available_columns
- @available_columns = self.class.available_columns.dup
- @available_columns += issue_custom_fields.visible.collect {|cf| QueryCustomFieldColumn.new(cf) }
-
- if User.current.allowed_to?(:view_time_entries, project, :global => true)
- # insert the columns after total_estimated_hours or at the end
- index = @available_columns.find_index {|column| column.name == :total_estimated_hours}
- index = (index ? index + 1 : -1)
-
- subselect = "SELECT SUM(hours) FROM #{TimeEntry.table_name}" +
- " JOIN #{Project.table_name} ON #{Project.table_name}.id = #{TimeEntry.table_name}.project_id" +
- " WHERE (#{TimeEntry.visible_condition(User.current)}) AND #{TimeEntry.table_name}.issue_id = #{Issue.table_name}.id"
-
- @available_columns.insert index, QueryColumn.new(:spent_hours,
- :sortable => "COALESCE((#{subselect}), 0)",
- :default_order => 'desc',
- :caption => :label_spent_time,
- :totalable => true
- )
-
- subselect = "SELECT SUM(hours) FROM #{TimeEntry.table_name}" +
- " JOIN #{Project.table_name} ON #{Project.table_name}.id = #{TimeEntry.table_name}.project_id" +
- " JOIN #{Issue.table_name} subtasks ON subtasks.id = #{TimeEntry.table_name}.issue_id" +
- " WHERE (#{TimeEntry.visible_condition(User.current)})" +
- " AND subtasks.root_id = #{Issue.table_name}.root_id AND subtasks.lft >= #{Issue.table_name}.lft AND subtasks.rgt <= #{Issue.table_name}.rgt"
-
- @available_columns.insert index+1, QueryColumn.new(:total_spent_hours,
- :sortable => "COALESCE((#{subselect}), 0)",
- :default_order => 'desc',
- :caption => :label_total_spent_time
- )
- end
-
- if User.current.allowed_to?(:set_issues_private, nil, :global => true) ||
- User.current.allowed_to?(:set_own_issues_private, nil, :global => true)
- @available_columns << QueryColumn.new(:is_private, :sortable => "#{Issue.table_name}.is_private", :groupable => true)
- end
-
- disabled_fields = Tracker.disabled_core_fields(trackers).map {|field| field.sub(/_id$/, '')}
- @available_columns.reject! {|column|
- disabled_fields.include?(column.name.to_s)
- }
-
- @available_columns
- end
-
- def default_columns_names
- @default_columns_names ||= begin
- default_columns = Setting.issue_list_default_columns.map(&:to_sym)
-
- project.present? ? default_columns : [:project] | default_columns
- end
- end
-
- def default_totalable_names
- Setting.issue_list_default_totals.map(&:to_sym)
- end
-
- def default_sort_criteria
- [['id', 'desc']]
- end
-
- def base_scope
- Issue.visible.joins(:status, :project).where(statement)
- end
-
- # Returns the issue count
- def issue_count
- base_scope.count
- rescue ::ActiveRecord::StatementInvalid => e
- raise StatementInvalid.new(e.message)
- end
-
- # Returns sum of all the issue's estimated_hours
- def total_for_estimated_hours(scope)
- map_total(scope.sum(:estimated_hours)) {|t| t.to_f.round(2)}
- end
-
- # Returns sum of all the issue's time entries hours
- def total_for_spent_hours(scope)
- total = scope.joins(:time_entries).
- where(TimeEntry.visible_condition(User.current)).
- sum("#{TimeEntry.table_name}.hours")
-
- map_total(total) {|t| t.to_f.round(2)}
- end
-
- # Returns the issues
- # Valid options are :order, :offset, :limit, :include, :conditions
- def issues(options={})
- order_option = [group_by_sort_order, (options[:order] || sort_clause)].flatten.reject(&:blank?)
-
- scope = Issue.visible.
- joins(:status, :project).
- preload(:priority).
- where(statement).
- includes(([:status, :project] + (options[:include] || [])).uniq).
- where(options[:conditions]).
- order(order_option).
- joins(joins_for_order_statement(order_option.join(','))).
- limit(options[:limit]).
- offset(options[:offset])
-
- scope = scope.preload([:tracker, :author, :assigned_to, :fixed_version, :category, :attachments] & columns.map(&:name))
- if has_custom_field_column?
- scope = scope.preload(:custom_values)
- end
-
- issues = scope.to_a
-
- if has_column?(:spent_hours)
- Issue.load_visible_spent_hours(issues)
- end
- if has_column?(:total_spent_hours)
- Issue.load_visible_total_spent_hours(issues)
- end
- if has_column?(:last_updated_by)
- Issue.load_visible_last_updated_by(issues)
- end
- if has_column?(:relations)
- Issue.load_visible_relations(issues)
- end
- if has_column?(:last_notes)
- Issue.load_visible_last_notes(issues)
- end
- issues
- rescue ::ActiveRecord::StatementInvalid => e
- raise StatementInvalid.new(e.message)
- end
-
- # Returns the issues ids
- def issue_ids(options={})
- order_option = [group_by_sort_order, (options[:order] || sort_clause)].flatten.reject(&:blank?)
-
- Issue.visible.
- joins(:status, :project).
- where(statement).
- includes(([:status, :project] + (options[:include] || [])).uniq).
- references(([:status, :project] + (options[:include] || [])).uniq).
- where(options[:conditions]).
- order(order_option).
- joins(joins_for_order_statement(order_option.join(','))).
- limit(options[:limit]).
- offset(options[:offset]).
- pluck(:id)
- rescue ::ActiveRecord::StatementInvalid => e
- raise StatementInvalid.new(e.message)
- end
-
- # Returns the journals
- # Valid options are :order, :offset, :limit
- def journals(options={})
- Journal.visible.
- joins(:issue => [:project, :status]).
- where(statement).
- order(options[:order]).
- limit(options[:limit]).
- offset(options[:offset]).
- preload(:details, :user, {:issue => [:project, :author, :tracker, :status]}).
- to_a
- rescue ::ActiveRecord::StatementInvalid => e
- raise StatementInvalid.new(e.message)
- end
-
- # Returns the versions
- # Valid options are :conditions
- def versions(options={})
- Version.visible.
- where(project_statement).
- where(options[:conditions]).
- includes(:project).
- references(:project).
- to_a
- rescue ::ActiveRecord::StatementInvalid => e
- raise StatementInvalid.new(e.message)
- end
-
- def sql_for_updated_by_field(field, operator, value)
- neg = (operator == '!' ? 'NOT' : '')
- subquery = "SELECT 1 FROM #{Journal.table_name}" +
- " WHERE #{Journal.table_name}.journalized_type='Issue' AND #{Journal.table_name}.journalized_id=#{Issue.table_name}.id" +
- " AND (#{sql_for_field field, '=', value, Journal.table_name, 'user_id'})" +
- " AND (#{Journal.visible_notes_condition(User.current, :skip_pre_condition => true)})"
-
- "#{neg} EXISTS (#{subquery})"
- end
-
- def sql_for_last_updated_by_field(field, operator, value)
- neg = (operator == '!' ? 'NOT' : '')
- subquery = "SELECT 1 FROM #{Journal.table_name} sj" +
- " WHERE sj.journalized_type='Issue' AND sj.journalized_id=#{Issue.table_name}.id AND (#{sql_for_field field, '=', value, 'sj', 'user_id'})" +
- " AND sj.id = (SELECT MAX(#{Journal.table_name}.id) FROM #{Journal.table_name}" +
- " WHERE #{Journal.table_name}.journalized_type='Issue' AND #{Journal.table_name}.journalized_id=#{Issue.table_name}.id" +
- " AND (#{Journal.visible_notes_condition(User.current, :skip_pre_condition => true)}))"
-
- "#{neg} EXISTS (#{subquery})"
- end
-
- def sql_for_watcher_id_field(field, operator, value)
- db_table = Watcher.table_name
-
- me, others = value.partition { |id| ['0', User.current.id.to_s].include?(id) }
- sql = if others.any?
- "SELECT #{Issue.table_name}.id FROM #{Issue.table_name} " +
- "INNER JOIN #{db_table} ON #{Issue.table_name}.id = #{db_table}.watchable_id AND #{db_table}.watchable_type = 'Issue' " +
- "LEFT OUTER JOIN #{Project.table_name} ON #{Project.table_name}.id = #{Issue.table_name}.project_id " +
- "WHERE (" +
- sql_for_field(field, '=', me, db_table, 'user_id') +
- ') OR (' +
- Project.allowed_to_condition(User.current, :view_issue_watchers) +
- ' AND ' +
- sql_for_field(field, '=', others, db_table, 'user_id') +
- ')'
- else
- "SELECT #{db_table}.watchable_id FROM #{db_table} " +
- "WHERE #{db_table}.watchable_type='Issue' AND " +
- sql_for_field(field, '=', me, db_table, 'user_id')
- end
-
- "#{Issue.table_name}.id #{ operator == '=' ? 'IN' : 'NOT IN' } (#{sql})"
- end
-
- def sql_for_member_of_group_field(field, operator, value)
- if operator == '*' # Any group
- groups = Group.givable
- operator = '=' # Override the operator since we want to find by assigned_to
- elsif operator == "!*"
- groups = Group.givable
- operator = '!' # Override the operator since we want to find by assigned_to
- else
- groups = Group.where(:id => value).to_a
- end
- groups ||= []
-
- members_of_groups = groups.inject([]) {|user_ids, group|
- user_ids + group.user_ids + [group.id]
- }.uniq.compact.sort.collect(&:to_s)
-
- '(' + sql_for_field("assigned_to_id", operator, members_of_groups, Issue.table_name, "assigned_to_id", false) + ')'
- end
-
- def sql_for_assigned_to_role_field(field, operator, value)
- case operator
- when "*", "!*" # Member / Not member
- sw = operator == "!*" ? 'NOT' : ''
- nl = operator == "!*" ? "#{Issue.table_name}.assigned_to_id IS NULL OR" : ''
- "(#{nl} #{Issue.table_name}.assigned_to_id #{sw} IN (SELECT DISTINCT #{Member.table_name}.user_id FROM #{Member.table_name}" +
- " WHERE #{Member.table_name}.project_id = #{Issue.table_name}.project_id))"
- when "=", "!"
- role_cond = value.any? ?
- "#{MemberRole.table_name}.role_id IN (" + value.collect{|val| "'#{self.class.connection.quote_string(val)}'"}.join(",") + ")" :
- "1=0"
-
- sw = operator == "!" ? 'NOT' : ''
- nl = operator == "!" ? "#{Issue.table_name}.assigned_to_id IS NULL OR" : ''
- "(#{nl} #{Issue.table_name}.assigned_to_id #{sw} IN (SELECT DISTINCT #{Member.table_name}.user_id FROM #{Member.table_name}, #{MemberRole.table_name}" +
- " WHERE #{Member.table_name}.project_id = #{Issue.table_name}.project_id AND #{Member.table_name}.id = #{MemberRole.table_name}.member_id AND #{role_cond}))"
- end
- end
-
- def sql_for_fixed_version_status_field(field, operator, value)
- where = sql_for_field(field, operator, value, Version.table_name, "status")
- version_ids = versions(:conditions => [where]).map(&:id)
-
- nl = operator == "!" ? "#{Issue.table_name}.fixed_version_id IS NULL OR" : ''
- "(#{nl} #{sql_for_field("fixed_version_id", "=", version_ids, Issue.table_name, "fixed_version_id")})"
- end
-
- def sql_for_fixed_version_due_date_field(field, operator, value)
- where = sql_for_field(field, operator, value, Version.table_name, "effective_date")
- version_ids = versions(:conditions => [where]).map(&:id)
-
- nl = operator == "!*" ? "#{Issue.table_name}.fixed_version_id IS NULL OR" : ''
- "(#{nl} #{sql_for_field("fixed_version_id", "=", version_ids, Issue.table_name, "fixed_version_id")})"
- end
-
- def sql_for_is_private_field(field, operator, value)
- op = (operator == "=" ? 'IN' : 'NOT IN')
- va = value.map {|v| v == '0' ? self.class.connection.quoted_false : self.class.connection.quoted_true}.uniq.join(',')
-
- "#{Issue.table_name}.is_private #{op} (#{va})"
- end
-
- def sql_for_attachment_field(field, operator, value)
- case operator
- when "*", "!*"
- e = (operator == "*" ? "EXISTS" : "NOT EXISTS")
- "#{e} (SELECT 1 FROM #{Attachment.table_name} a WHERE a.container_type = 'Issue' AND a.container_id = #{Issue.table_name}.id)"
- when "~", "!~"
- c = sql_contains("a.filename", value.first)
- e = (operator == "~" ? "EXISTS" : "NOT EXISTS")
- "#{e} (SELECT 1 FROM #{Attachment.table_name} a WHERE a.container_type = 'Issue' AND a.container_id = #{Issue.table_name}.id AND #{c})"
- end
- end
-
- def sql_for_parent_id_field(field, operator, value)
- case operator
- when "="
- "#{Issue.table_name}.parent_id = #{value.first.to_i}"
- when "~"
- root_id, lft, rgt = Issue.where(:id => value.first.to_i).pluck(:root_id, :lft, :rgt).first
- if root_id && lft && rgt
- "#{Issue.table_name}.root_id = #{root_id} AND #{Issue.table_name}.lft > #{lft} AND #{Issue.table_name}.rgt < #{rgt}"
- else
- "1=0"
- end
- when "!*"
- "#{Issue.table_name}.parent_id IS NULL"
- when "*"
- "#{Issue.table_name}.parent_id IS NOT NULL"
- end
- end
-
- def sql_for_child_id_field(field, operator, value)
- case operator
- when "="
- parent_id = Issue.where(:id => value.first.to_i).pluck(:parent_id).first
- if parent_id
- "#{Issue.table_name}.id = #{parent_id}"
- else
- "1=0"
- end
- when "~"
- root_id, lft, rgt = Issue.where(:id => value.first.to_i).pluck(:root_id, :lft, :rgt).first
- if root_id && lft && rgt
- "#{Issue.table_name}.root_id = #{root_id} AND #{Issue.table_name}.lft < #{lft} AND #{Issue.table_name}.rgt > #{rgt}"
- else
- "1=0"
- end
- when "!*"
- "#{Issue.table_name}.rgt - #{Issue.table_name}.lft = 1"
- when "*"
- "#{Issue.table_name}.rgt - #{Issue.table_name}.lft > 1"
- end
- end
-
- def sql_for_updated_on_field(field, operator, value)
- case operator
- when "!*"
- "#{Issue.table_name}.updated_on = #{Issue.table_name}.created_on"
- when "*"
- "#{Issue.table_name}.updated_on > #{Issue.table_name}.created_on"
- else
- sql_for_field("updated_on", operator, value, Issue.table_name, "updated_on")
- end
- end
-
- def sql_for_issue_id_field(field, operator, value)
- if operator == "="
- # accepts a comma separated list of ids
- ids = value.first.to_s.scan(/\d+/).map(&:to_i)
- if ids.present?
- "#{Issue.table_name}.id IN (#{ids.join(",")})"
- else
- "1=0"
- end
- else
- sql_for_field("id", operator, value, Issue.table_name, "id")
- end
- end
-
- def sql_for_relations(field, operator, value, options={})
- relation_options = IssueRelation::TYPES[field]
- return relation_options unless relation_options
-
- relation_type = field
- join_column, target_join_column = "issue_from_id", "issue_to_id"
- if relation_options[:reverse] || options[:reverse]
- relation_type = relation_options[:reverse] || relation_type
- join_column, target_join_column = target_join_column, join_column
- end
-
- sql = case operator
- when "*", "!*"
- op = (operator == "*" ? 'IN' : 'NOT IN')
- "#{Issue.table_name}.id #{op} (SELECT DISTINCT #{IssueRelation.table_name}.#{join_column} FROM #{IssueRelation.table_name} WHERE #{IssueRelation.table_name}.relation_type = '#{self.class.connection.quote_string(relation_type)}')"
- when "=", "!"
- op = (operator == "=" ? 'IN' : 'NOT IN')
- "#{Issue.table_name}.id #{op} (SELECT DISTINCT #{IssueRelation.table_name}.#{join_column} FROM #{IssueRelation.table_name} WHERE #{IssueRelation.table_name}.relation_type = '#{self.class.connection.quote_string(relation_type)}' AND #{IssueRelation.table_name}.#{target_join_column} = #{value.first.to_i})"
- when "=p", "=!p", "!p"
- op = (operator == "!p" ? 'NOT IN' : 'IN')
- comp = (operator == "=!p" ? '<>' : '=')
- "#{Issue.table_name}.id #{op} (SELECT DISTINCT #{IssueRelation.table_name}.#{join_column} FROM #{IssueRelation.table_name}, #{Issue.table_name} relissues WHERE #{IssueRelation.table_name}.relation_type = '#{self.class.connection.quote_string(relation_type)}' AND #{IssueRelation.table_name}.#{target_join_column} = relissues.id AND relissues.project_id #{comp} #{value.first.to_i})"
- when "*o", "!o"
- op = (operator == "!o" ? 'NOT IN' : 'IN')
- "#{Issue.table_name}.id #{op} (SELECT DISTINCT #{IssueRelation.table_name}.#{join_column} FROM #{IssueRelation.table_name}, #{Issue.table_name} relissues WHERE #{IssueRelation.table_name}.relation_type = '#{self.class.connection.quote_string(relation_type)}' AND #{IssueRelation.table_name}.#{target_join_column} = relissues.id AND relissues.status_id IN (SELECT id FROM #{IssueStatus.table_name} WHERE is_closed=#{self.class.connection.quoted_false}))"
- end
-
- if relation_options[:sym] == field && !options[:reverse]
- sqls = [sql, sql_for_relations(field, operator, value, :reverse => true)]
- sql = sqls.join(["!", "!*", "!p", '!o'].include?(operator) ? " AND " : " OR ")
- end
- "(#{sql})"
- end
-
- def sql_for_project_status_field(field, operator, value, options={})
- sql_for_field(field, operator, value, Project.table_name, "status")
- end
-
- def find_assigned_to_id_filter_values(values)
- Principal.visible.where(:id => values).map {|p| [p.name, p.id.to_s]}
- end
- alias :find_author_id_filter_values :find_assigned_to_id_filter_values
-
- IssueRelation::TYPES.each_key do |relation_type|
- alias_method "sql_for_#{relation_type}_field".to_sym, :sql_for_relations
- end
-
- def joins_for_order_statement(order_options)
- joins = [super]
-
- if order_options
- if order_options.include?('authors')
- joins << "LEFT OUTER JOIN #{User.table_name} authors ON authors.id = #{queried_table_name}.author_id"
- end
- if order_options.include?('users')
- joins << "LEFT OUTER JOIN #{User.table_name} ON #{User.table_name}.id = #{queried_table_name}.assigned_to_id"
- end
- if order_options.include?('last_journal_user')
- joins << "LEFT OUTER JOIN #{Journal.table_name} ON #{Journal.table_name}.id = (SELECT MAX(#{Journal.table_name}.id) FROM #{Journal.table_name}" +
- " WHERE #{Journal.table_name}.journalized_type='Issue' AND #{Journal.table_name}.journalized_id=#{Issue.table_name}.id AND #{Journal.visible_notes_condition(User.current, :skip_pre_condition => true)})" +
- " LEFT OUTER JOIN #{User.table_name} last_journal_user ON last_journal_user.id = #{Journal.table_name}.user_id";
- end
- if order_options.include?('versions')
- joins << "LEFT OUTER JOIN #{Version.table_name} ON #{Version.table_name}.id = #{queried_table_name}.fixed_version_id"
- end
- if order_options.include?('issue_categories')
- joins << "LEFT OUTER JOIN #{IssueCategory.table_name} ON #{IssueCategory.table_name}.id = #{queried_table_name}.category_id"
- end
- if order_options.include?('trackers')
- joins << "LEFT OUTER JOIN #{Tracker.table_name} ON #{Tracker.table_name}.id = #{queried_table_name}.tracker_id"
- end
- if order_options.include?('enumerations')
- joins << "LEFT OUTER JOIN #{IssuePriority.table_name} ON #{IssuePriority.table_name}.id = #{queried_table_name}.priority_id"
- end
- end
-
- joins.any? ? joins.join(' ') : nil
- end
- end
|