kanbanworkflowstimelinescrumrubyroadmapproject-planningproject-managementopenprojectangularissue-trackerifcgantt-chartganttbug-trackerboardsbcf
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
117 lines
3.4 KiB
117 lines
3.4 KiB
#-- encoding: UTF-8
|
|
#-- copyright
|
|
# OpenProject is a project management system.
|
|
# Copyright (C) 2012-2017 the OpenProject Foundation (OPF)
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License version 3.
|
|
#
|
|
# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
|
|
# Copyright (C) 2006-2017 Jean-Philippe Lang
|
|
# Copyright (C) 2010-2013 the ChiliProject Team
|
|
#
|
|
# 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.
|
|
#
|
|
# See doc/COPYRIGHT.rdoc for more details.
|
|
#++
|
|
|
|
module ::Query::Sums
|
|
include ActionView::Helpers::NumberHelper
|
|
|
|
def next_in_same_group?(issue = cached_issue)
|
|
caching_issue issue do |issue|
|
|
!last_issue? &&
|
|
query.group_by_column.value(issue) == query.group_by_column.value(work_packages[issue_index + 1])
|
|
end
|
|
end
|
|
|
|
def last_issue?(issue = cached_issue)
|
|
caching_issue issue do |_issue|
|
|
issue_index == work_packages.size - 1
|
|
end
|
|
end
|
|
|
|
def issue_index(issue = cached_issue)
|
|
caching_issue issue do |issue|
|
|
work_packages.find_index(issue)
|
|
end
|
|
end
|
|
|
|
def grouped_sum_of_issue(column, issue = cached_issue)
|
|
grouped_sum_of column, group_for_issue(issue)
|
|
end
|
|
|
|
def grouped_sum_of(column, group)
|
|
sum_of column, group
|
|
end
|
|
|
|
def grouped_sums(column)
|
|
work_packages
|
|
.map { |wp| query.group_by_column.value(wp) }
|
|
.uniq
|
|
.inject({}) do |group_sums, current_group|
|
|
work_packages_in_current_group = work_packages.select { |wp| query.group_by_column.value(wp) == current_group }
|
|
# TODO: sum_of only works fast when passing an AR::Relation
|
|
group_sums.merge current_group => sum_of(column, work_packages_in_current_group)
|
|
end
|
|
end
|
|
|
|
def total_sum_of(column)
|
|
sum_of(column, work_packages)
|
|
end
|
|
|
|
def sum_of(column, collection)
|
|
return nil unless should_be_summed_up?(column)
|
|
|
|
sum = column.sum_of(collection)
|
|
|
|
crunch(sum)
|
|
end
|
|
|
|
def caching_issue(issue)
|
|
@cached_issue = issue unless @cached_issue == issue
|
|
block_given? ? yield(issue) : issue
|
|
end
|
|
|
|
def cached_issue
|
|
@cached_issue
|
|
end
|
|
|
|
def mapping_for(column)
|
|
if column.respond_to? :real_value
|
|
method(:number_to_currency)
|
|
else
|
|
# respond_to? :call, but do nothing
|
|
@nilproc ||= Proc.new { |val| val }
|
|
end
|
|
end
|
|
|
|
def crunch(num)
|
|
return num if num.nil? or num.integer?
|
|
Float(format '%.2f', num.to_f)
|
|
end
|
|
|
|
def group_for_issue(issue = @current_issue)
|
|
caching_issue issue do |issue|
|
|
work_packages.select do |is|
|
|
query.group_by_column.value(issue) == query.group_by_column.value(is)
|
|
end
|
|
end
|
|
end
|
|
|
|
def should_be_summed_up?(column)
|
|
column.summable? && Setting.work_package_list_summable_columns.include?(column.name.to_s)
|
|
end
|
|
end
|
|
|