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.
		
		
		
		
		
			
		
			
				
					
					
						
							742 lines
						
					
					
						
							26 KiB
						
					
					
				
			
		
		
	
	
							742 lines
						
					
					
						
							26 KiB
						
					
					
				| # Redmine - project management software
 | |
| # Copyright (C) 2006-2013  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.
 | |
| 
 | |
| require 'SVG/Graph/Bar'
 | |
| require 'SVG/Graph/BarHorizontal'
 | |
| require 'digest/sha1'
 | |
| require 'redmine/scm/adapters/abstract_adapter'
 | |
| require 'tempfile'
 | |
| 
 | |
| class ChangesetNotFound < Exception; end
 | |
| class InvalidRevisionParam < Exception; end
 | |
| 
 | |
| class RepositoriesController < ApplicationController
 | |
|   include ApplicationHelper
 | |
|   menu_item :repository
 | |
|   menu_item :settings, :only => [:new, :create, :edit, :update, :destroy, :committers]
 | |
|   default_search_scope :changesets
 | |
| 
 | |
|   before_filter :find_project_by_project_id, :only => [:new, :create, :newrepo]
 | |
|   before_filter :find_repository, :only => [:edit, :update, :destroy, :committers]
 | |
|   before_filter :find_project_repository, :except => [:new, :create, :newcreate, :edit, :update, :destroy, :committers, :newrepo,:to_gitlab]
 | |
|   before_filter :find_changeset, :only => [:revision, :add_related_issue, :remove_related_issue]
 | |
|   before_filter :authorize , :except => [:newrepo,:newcreate,:fork, :to_gitlab]
 | |
|   accept_rss_auth :revisions
 | |
|   # hidden repositories filter // 隐藏代码过滤器
 | |
|   before_filter :check_hidden_repo, :only => [:show, :stats, :revisions, :revision, :diff ]
 | |
|   helper :repositories
 | |
|   include RepositoriesHelper
 | |
|   helper :project_score
 | |
|   #@root_path = RepositoriesHelper::ROOT_PATH
 | |
| 
 | |
| 
 | |
|   rescue_from Redmine::Scm::Adapters::CommandFailed, :with => :show_error_command_failed
 | |
|   def new
 | |
|     if @project.repositories.count == 0
 | |
|       scm = params[:repository_scm] || (Redmine::Scm::Base.all & Setting.enabled_scm).first
 | |
|       @repository = Repository.factory(scm)
 | |
|       @repository.is_default = @project.repository.nil?
 | |
|       @repository.project = @project
 | |
|       @course_tag = params[:course]
 | |
|       if @course_tag == 1
 | |
|         render :layout => 'base_courses'
 | |
|       else
 | |
|         render :layout => 'base_projects'
 | |
|       end
 | |
|     else
 | |
|       render_403
 | |
|     end
 | |
| 
 | |
|   end
 | |
| 
 | |
| 
 | |
|   def newrepo
 | |
|     scm = params[:repository_scm] || (Redmine::Scm::Base.all & Setting.enabled_scm).first
 | |
|     @repository = Repository.factory(scm)
 | |
|     @repository.is_default = @project.repository.nil?
 | |
|     @repository.project = @project
 | |
|     @course_tag = params[:course]
 | |
|     if @course_tag == 1
 | |
|       render :layout => 'base_courses'
 | |
|     else
 | |
|       render :layout => 'base_projects'
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def fork
 | |
|     @repository_url = params[:repository_url]
 | |
| 
 | |
|     # @repository.url
 | |
|     # system "htpasswd -mb "+@root_path+"user.passwd "+params[:repository][:identifier]+" "+@upasswd
 | |
|     # system "echo -e '"+params[:project_id]+"-"+params[:repository][:identifier]+"-write:"+
 | |
|     # " "+params[:repository][:identifier]+"'  >> "+@root_path+"group.passwd"
 | |
|     system "git clone --bare "+@repository_url
 | |
|     # system "mv "+@project_path+"/hooks/post-update{.sample,}"
 | |
|     # system "chmod a+x "+@project_path+"/hooks/post-update"
 | |
|     # system "."+@project_path+"/hooks/post-update"
 | |
|     # system "echo -e 'Allow from all \n Order Deny,Allow \n "+
 | |
|     # "<Limit PUT POST DELETE PROPPATCH MKCOL COPY MOVE LOCK UNLOCK> \n"+
 | |
|     # "Require group "+params[:project_id]+"-"+params[:repository][:identifier]+"-write  \n "+
 | |
|     # "</Limit> \n ' >>"+
 | |
|     # @project_path+"/.htaccess"
 | |
|     flash[:notice] = l(:label_notice_fork_successed)
 | |
|     @repositories = @project.repositories
 | |
|     render :action => 'show', :layout => 'base_projects'
 | |
|   end
 | |
| 
 | |
| 
 | |
|   HOOK_TEMPLATE = %Q{#!/bin/sh
 | |
| exec sh -c '
 | |
| function update()
 | |
| {
 | |
|         CMD_PATH=`dirname $0`;
 | |
|         cd $CMD_PATH;
 | |
|         PY_PATH=$PWD/../../git_refresh_changes.py;
 | |
|         [[ -s "$PY_PATH"   ]] && $(which python) $PY_PATH $PWD;
 | |
|         cd -;
 | |
| }
 | |
| git update-server-info
 | |
| update
 | |
| '
 | |
|   }
 | |
| 
 | |
|   def create
 | |
|     attrs = pickup_extra_info
 | |
|     @repository = Repository.factory('Git')
 | |
|     @repository.safe_attributes = params[:repository]
 | |
|     if attrs[:attrs_extra].keys.any?
 | |
|       @repository.merge_extra_info(attrs[:attrs_extra])
 | |
|     end
 | |
|     @repository.project = @project
 | |
|     @repository.type = 'Repository::Gitlab'
 | |
|     @repository.url = @repository.identifier
 | |
|     if request.post? && @repository.save
 | |
|       s = Trustie::Gitlab::Sync.new
 | |
|       s.create_project(@project, @repository)
 | |
|       redirect_to settings_project_url(@project, :tab => 'repositories')
 | |
|     else
 | |
|       redirect_to settings_project_url(@project, :tab => 'repositories',:repository_error_message=>@repository.errors.full_messages)
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def edit
 | |
|   end
 | |
| 
 | |
|   def update
 | |
|     attrs = pickup_extra_info
 | |
|     @repository.safe_attributes = attrs[:attrs]
 | |
|     if attrs[:attrs_extra].keys.any?
 | |
|       @repository.merge_extra_info(attrs[:attrs_extra])
 | |
|     end
 | |
|     @repository.project = @project
 | |
|     if request.put? && @repository.save
 | |
|       redirect_to settings_project_url(@project, :tab => 'repositories')
 | |
|     else
 | |
|       render :action => 'edit'
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def pickup_extra_info
 | |
|     p       = {}
 | |
|     p_extra = {}
 | |
|     params[:repository].each do |k, v|
 | |
|       if k =~ /^extra_/
 | |
|         p_extra[k] = v
 | |
|       else
 | |
|         p[k] = v
 | |
|       end
 | |
|     end
 | |
|     {:attrs => p, :attrs_extra => p_extra}
 | |
|   end
 | |
|   private :pickup_extra_info
 | |
| 
 | |
|   def committers
 | |
|     @committers = @repository.committers
 | |
|     @users = @project.users
 | |
|     additional_user_ids = @committers.collect(&:last).collect(&:to_i) - @users.collect(&:id)
 | |
|     @users += User.find_all_by_id(additional_user_ids) unless additional_user_ids.empty?
 | |
|     @users.compact!
 | |
|     @users.sort!
 | |
|     if request.post? && params[:committers].is_a?(Hash)
 | |
|       # Build a hash with repository usernames as keys and corresponding user ids as values
 | |
|       @repository.committer_ids = params[:committers].values.inject({}) {|h, c| h[c.first] = c.last; h}
 | |
|       flash[:notice] = l(:notice_successful_update)
 | |
|       respond_to do |format|
 | |
|         format.html{
 | |
|           render :layout => "base_projects"
 | |
|         }
 | |
|       end
 | |
|     elsif request.get?
 | |
|       respond_to do |format|
 | |
|         format.html{
 | |
|           render :layout => "base_projects"
 | |
|         }
 | |
|       end
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def destroy
 | |
|     DestroyRepositoryTask.new.destroy(User.current.id, @repository.id)
 | |
|     @repository.hidden = true
 | |
|     @repository.save
 | |
|     redirect_to settings_project_url(@project, :tab => 'repositories')
 | |
|   end
 | |
| 
 | |
|   def to_gitlab
 | |
|     @project = Project.find(params[:project_id])
 | |
|     @repository = Repository.find(params[:id])
 | |
|     s = Trustie::Gitlab::Sync.new
 | |
|     s.sync_project(@project, path: params[:repo_name], import_url: @repository.url)
 | |
|     @repository.type = 'Repository::Gitlab'
 | |
|     @repository.save
 | |
|     redirect_to :controller => 'repositories', :action => 'show', :id => @project.id, to: 'gitlab'
 | |
|   end
 | |
| 
 | |
|   def show
 | |
|     ## TODO: the below will move to filter, done.
 | |
|     if !User.current.member_of?(@project)
 | |
|       if @project.hidden_repo
 | |
|         render_403
 | |
|         return -1
 | |
|       end
 | |
|     end
 | |
| 
 | |
|     # unless @repository.gitlab?
 | |
|     #   # redirect_to to_gitlab_project_repository_path(@project, @repository)
 | |
|     #   render :to_gitlab
 | |
|     #   return
 | |
|     # end
 | |
| 
 | |
|     #if( !User.current.member_of?(@project) || @project.hidden_repo)
 | |
|     @repository.fetch_changesets if Setting.autofetch_changesets? && @path.empty?
 | |
| 
 | |
|     # :name, :path, :kind, :size, :lastrev, :changeset
 | |
|     @entries = @repository.entries(@path, @rev)
 | |
|     # @trees = g.trees(project, @path)
 | |
|     @changeset = @repository.find_changeset_by_name(@rev)
 | |
|     #@project_path_cut = RepositoriesHelper::PROJECT_PATH_CUT
 | |
|     #@ip               = RepositoriesHelper::REPO_IP_ADDRESS
 | |
| 
 | |
|     if request.xhr?
 | |
|       @entries ? render(:partial => 'dir_list_content') : render(:nothing => true)
 | |
|     else
 | |
|       #Modified by young
 | |
|       #  (show_error_not_found; return) unless @entries
 | |
|       g = Gitlab.client
 | |
|       count = 0
 | |
|       (0..100).each do |page|
 | |
|         if g.commits(@project.gpid,:page => page).count == 0
 | |
|           break
 | |
|         else
 | |
|           count = count + g.commits(@project.gpid,:page => page).count
 | |
|         end
 | |
|       end
 | |
|       @changesets = g.commits(@project.gpid)
 | |
|       # @changesets = @repository.latest_changesets(@path, @rev)
 | |
|       # @changesets_count = @repository.latest_changesets(@path, @rev).count
 | |
|       @changesets_all_count = count
 | |
|       @changesets_latest_coimmit = @changesets[0]
 | |
|       @properties = @repository.properties(@path, @rev)
 | |
|       @repositories = @project.repositories
 | |
|       @course_tag = params[:course]
 | |
|       project_path_cut = RepositoriesHelper::PROJECT_PATH_CUT
 | |
|       ip = RepositoriesHelper::REPO_IP_ADDRESS
 | |
|       gitlab_address = Redmine::Configuration['gitlab_address']
 | |
|       if @repository.type.to_s == "Repository::Gitlab"
 | |
|         @repos_url = gitlab_address.to_s+"/"+@project.owner.to_s+"/"+@repository.identifier+"."+"git"
 | |
|       else
 | |
|         @repos_url = "http://"+@repository.login.to_s+"_"+@repository.identifier.to_s+"@"+ip.to_s + @repository.url.slice(project_path_cut, @repository.url.length).to_s
 | |
|       end
 | |
|       if @course_tag == 1
 | |
|         render :action => 'show', :layout => 'base_courses'
 | |
|       else
 | |
|         render :action => 'show', :layout => 'base_projects'
 | |
|       end
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   alias_method :browse, :show
 | |
| 
 | |
|   def changes
 | |
|     @entry = @repository.entry(@path, @rev)
 | |
|     (show_error_not_found; return) unless @entry
 | |
|     g = Gitlab.client
 | |
|     @commits = g.commits(@project.gpid, page:params[:pamge])
 | |
|     @commit = g.commit(@project.gpid,@rev)
 | |
|     # @changesets = g.get ("/projects/#{@project.gpid}/repository/commits?#{@rev}")
 | |
|     #@changesets = @repository.latest_changesets(@path, @rev, Setting.repository_log_display_limit.to_i)
 | |
|     @properties = @repository.properties(@path, @rev)
 | |
|     @changeset = @repository.find_changeset_by_name(@rev)
 | |
|     render :layout => 'base_projects'
 | |
|   end
 | |
| 
 | |
|   def revisions
 | |
|     @changeset_count = @repository.changesets.count
 | |
|     @changeset_pages = Paginator.new @changeset_count,
 | |
|                                      per_page_option,
 | |
|                                      params['page']
 | |
|     @changesets = @repository.changesets.
 | |
|         limit(@changeset_pages.per_page).
 | |
|         offset(@changeset_pages.offset).
 | |
|         includes(:user, :repository, :parents).
 | |
|         all
 | |
| 
 | |
|     respond_to do |format|
 | |
|       format.html { render :layout => 'base_projects' }
 | |
|       format.atom { render_feed(@changesets, :title => "#{@project.name}: #{l(:label_revision_plural)}") }
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def raw
 | |
|     entry_and_raw(true)
 | |
|   end
 | |
| 
 | |
|   def entry
 | |
|     entry_and_raw(false)
 | |
|     render :layout => 'base_projects'
 | |
|   end
 | |
| 
 | |
|   def entry_and_raw(is_raw)
 | |
|     @entry = @repository.entry(@path, @rev)
 | |
|     (show_error_not_found; return) unless @entry
 | |
| 
 | |
|     # If the entry is a dir, show the browser
 | |
|     (show; return) if @entry.is_dir?
 | |
| 
 | |
|     @content = @repository.cat(@path, @rev)
 | |
|     (show_error_not_found; return) unless @content
 | |
|     if is_raw ||
 | |
|         (@content.size && @content.size > Setting.file_max_size_displayed.to_i.kilobyte) ||
 | |
|         ! is_entry_text_data?(@content, @path)
 | |
|       # Force the download
 | |
|       send_opt = { :filename => filename_for_content_disposition(@path.split('/').last) }
 | |
|       send_type = Redmine::MimeType.of(@path)
 | |
|       send_opt[:type] = send_type.to_s if send_type
 | |
|       send_opt[:disposition] = (Redmine::MimeType.is_type?('image', @path) && !is_raw ? 'inline' : 'attachment')
 | |
|       send_data @content, send_opt
 | |
|     else
 | |
|       # Prevent empty lines when displaying a file with Windows style eol
 | |
|       # TODO: UTF-16
 | |
|       # Is this needs? AttachmentsController reads file simply.
 | |
|       @content.gsub!("\r\n", "\n")
 | |
|       @changeset = @repository.find_changeset_by_name(@rev)
 | |
|     end
 | |
|   end
 | |
|   private :entry_and_raw
 | |
| 
 | |
|   def is_entry_text_data?(ent, path)
 | |
|     # UTF-16 contains "\x00".
 | |
|     # It is very strict that file contains less than 30% of ascii symbols
 | |
|     # in non Western Europe.
 | |
|     return true if Redmine::MimeType.is_type?('text', path)
 | |
|     # Ruby 1.8.6 has a bug of integer divisions.
 | |
|     # http://apidock.com/ruby/v1_8_6_287/String/is_binary_data%3F
 | |
|     return false if ent.is_binary_data?
 | |
|     true
 | |
|   end
 | |
|   private :is_entry_text_data?
 | |
| 
 | |
|   def annotate
 | |
|     @entry = @repository.entry(@path, @rev)
 | |
|     (show_error_not_found; return) unless @entry
 | |
| 
 | |
|     @annotate = @repository.scm.annotate(@path, @rev)
 | |
|     if @annotate.nil? || @annotate.empty?
 | |
|       (render_error l(:error_scm_annotate); return)
 | |
|     end
 | |
|     ann_buf_size = 0
 | |
|     @annotate.lines.each do |buf|
 | |
|       ann_buf_size += buf.size
 | |
|     end
 | |
|     if ann_buf_size > Setting.file_max_size_displayed.to_i.kilobyte
 | |
|       (render_error l(:error_scm_annotate_big_text_file); return)
 | |
|     end
 | |
|     @changeset = @repository.find_changeset_by_name(@rev)
 | |
|   end
 | |
| 
 | |
|   def revision
 | |
|     respond_to do |format|
 | |
|       format.html{render :layout => 'base_projects'}
 | |
|       format.js {render :layout => false}
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   # Adds a related issue to a changeset
 | |
|   # POST /projects/:project_id/repository/(:repository_id/)revisions/:rev/issues
 | |
|   def add_related_issue
 | |
|     @issue = @changeset.find_referenced_issue_by_id(params[:issue_id])
 | |
|     if @issue && (!@issue.visible? || @changeset.issues.include?(@issue))
 | |
|       @issue = nil
 | |
|     end
 | |
| 
 | |
|     if @issue
 | |
|       @changeset.issues << @issue
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   # Removes a related issue from a changeset
 | |
|   # DELETE /projects/:project_id/repository/(:repository_id/)revisions/:rev/issues/:issue_id
 | |
|   def remove_related_issue
 | |
|     @issue = Issue.visible.find_by_id(params[:issue_id])
 | |
|     if @issue
 | |
|       @changeset.issues.delete(@issue)
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def diff
 | |
|     if params[:format] == 'diff'
 | |
|       @diff = @repository.diff(@path, @rev, @rev_to)
 | |
|       (show_error_not_found; return) unless @diff
 | |
|       filename = "changeset_r#{@rev}"
 | |
|       filename << "_r#{@rev_to}" if @rev_to
 | |
|       send_data @diff.join, :filename => "#{filename}.diff",
 | |
|                 :type => 'text/x-patch',
 | |
|                 :disposition => 'attachment'
 | |
|     else
 | |
|       @diff_type = params[:type] || User.current.pref[:diff_type] || 'inline'
 | |
|       @diff_type = 'inline' unless %w(inline sbs).include?(@diff_type)
 | |
| 
 | |
|       # Save diff type as user preference
 | |
|       if User.current.logged? && @diff_type != User.current.pref[:diff_type]
 | |
|         User.current.pref[:diff_type] = @diff_type
 | |
|         User.current.preference.save
 | |
|       end
 | |
|       @cache_key = "repositories/diff/#{@repository.id}/" +
 | |
|           Digest::MD5.hexdigest("#{@path}-#{@rev}-#{@rev_to}-#{@diff_type}-#{current_language}")
 | |
|       unless read_fragment(@cache_key)
 | |
|         @diff = @repository.diff(@path, @rev, @rev_to)
 | |
|         unless @diff
 | |
|           show_error_not_found
 | |
|           return
 | |
|         end
 | |
|       end
 | |
| 
 | |
|       @changeset = @repository.find_changeset_by_name(@rev)
 | |
|       @changeset_to = @rev_to ? @repository.find_changeset_by_name(@rev_to) : nil
 | |
|       @diff_format_revisions = @repository.diff_format_revisions(@changeset, @changeset_to)
 | |
|     end
 | |
|     render :layout => 'base_projects'
 | |
|   end
 | |
| 
 | |
|   def stats
 | |
|     @project_id = params[:id]
 | |
|     @repository_id = @repository.identifier
 | |
|     # 提交次数统计
 | |
|     @status_commit_count = Changeset.count(:conditions => ["#{Changeset.table_name}.repository_id = ?", @repository.id])
 | |
|     render :layout => 'base_projects'
 | |
|   end
 | |
| 
 | |
|   def graph
 | |
|     data = nil
 | |
|     case params[:graph]
 | |
|       when "commits_per_month"
 | |
|         data = graph_commits_per_month(@repository)
 | |
|       when "commits_per_author"
 | |
|         data = graph_commits_per_author(@repository)
 | |
|       when "author_commits_per_month"
 | |
|         data = graph_author_commits_per_month(@repository)
 | |
|       when "author_commits_six_month"
 | |
|         data = author_commits_six_month(@repository)
 | |
|       when "author_code_six_months"
 | |
|         data = author_code_six_month(@repository)
 | |
|     end
 | |
|     if data
 | |
|       headers["Content-Type"] = "image/svg+xml"
 | |
|       send_data(data, :type => "image/svg+xml", :disposition => "inline")
 | |
|     else
 | |
|       render_404
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   private
 | |
| 
 | |
|   def find_repository
 | |
|     @repository = Repository.find(params[:id])
 | |
|     @project = @repository.project
 | |
|   rescue ActiveRecord::RecordNotFound
 | |
|     render_404
 | |
|   end
 | |
| 
 | |
|   REV_PARAM_RE = %r{\A[a-f0-9]*\Z}i
 | |
| 
 | |
|   def find_project_repository
 | |
|     @project = Project.find(params[:id])
 | |
|     if params[:repository_id].present?
 | |
|       @repository = @project.repositories.find_by_identifier_param(params[:repository_id])
 | |
|     else
 | |
|       # 多版本库,如果一个版本库为空则去下一个
 | |
|       rep_count = @project.repositories.count
 | |
|       if @project.repository.nil?
 | |
|         for i in 0..rep_count
 | |
|           unless @project.repositories[i].nil?
 | |
|             @repository = @project.repositories[i]
 | |
|             break
 | |
|           end
 | |
|         end
 | |
|       else
 | |
|         @repository = @project.repository
 | |
|       end
 | |
|     end
 | |
|     (render_404; return false) unless @repository
 | |
|     @path = params[:path].is_a?(Array) ? params[:path].join('/') : params[:path].to_s
 | |
|     @rev = params[:rev].blank? ? @repository.default_branch : params[:rev].to_s.strip
 | |
|     @rev_to = params[:rev_to]
 | |
| 
 | |
|     unless @rev.to_s.match(REV_PARAM_RE) && @rev_to.to_s.match(REV_PARAM_RE)
 | |
|       if @repository.branches.blank?
 | |
|         raise InvalidRevisionParam
 | |
|       end
 | |
|     end
 | |
|   rescue ActiveRecord::RecordNotFound
 | |
|     render_404
 | |
|   rescue InvalidRevisionParam
 | |
|     show_error_not_found
 | |
|   end
 | |
| 
 | |
|   def find_changeset
 | |
|     if @rev.present?
 | |
|       @changeset = @repository.find_changeset_by_name(@rev)
 | |
|     end
 | |
|     show_error_not_found unless @changeset
 | |
|   end
 | |
| 
 | |
|   def show_error_not_found
 | |
|     render_error :message => l(:error_scm_not_found), :status => 404
 | |
|   end
 | |
| 
 | |
|   def show_error_forbidden
 | |
|     render_error :status => 403
 | |
|   end
 | |
| 
 | |
|   # Handler for Redmine::Scm::Adapters::CommandFailed exception
 | |
|   def show_error_command_failed(exception)
 | |
|     render_error l(:error_scm_command_failed, exception.message)
 | |
|   end
 | |
| 
 | |
|   def graph_commits_per_month(repository)
 | |
|     @date_to = Date.today
 | |
|     @date_from = @date_to << 11
 | |
|     @date_from = Date.civil(@date_from.year, @date_from.month, 1)
 | |
|     commits_by_day = Changeset.count(
 | |
|         :all, :group => :commit_date,
 | |
|         :conditions => ["repository_id = ? AND commit_date BETWEEN ? AND ?", repository.id, @date_from, @date_to])
 | |
|     commits_by_month = [0] * 12
 | |
|     commits_by_day.each {|c| commits_by_month[(@date_to.month - c.first.to_date.month) % 12] += c.last }
 | |
| 
 | |
|     changes_by_day = Change.count(
 | |
|         :all, :group => :commit_date, :include => :changeset,
 | |
|         :conditions => ["#{Changeset.table_name}.repository_id = ? AND #{Changeset.table_name}.commit_date BETWEEN ? AND ?", repository.id, @date_from, @date_to])
 | |
|     changes_by_month = [0] * 12
 | |
|     changes_by_day.each {|c| changes_by_month[(@date_to.month - c.first.to_date.month) % 12] += c.last }
 | |
| 
 | |
|     fields = []
 | |
|     12.times {|m| fields << month_name(((Date.today.month - 1 - m) % 12) + 1)}
 | |
| 
 | |
|     graph = SVG::Graph::Bar.new(
 | |
|         :height => 300,
 | |
|         :width => 600,
 | |
|         :fields => fields.reverse,
 | |
|         :stack => :side,
 | |
|         :scale_integers => true,
 | |
|         :step_x_labels => 2,
 | |
|         :show_data_values => true,
 | |
|         :graph_title => l(:label_commits_per_month),
 | |
|         :show_graph_title => true
 | |
|     )
 | |
| 
 | |
|     # 具状图
 | |
|     graph.add_data(
 | |
|         :data => commits_by_month[0..11].reverse,
 | |
|         :title => l(:label_revision_plural)
 | |
|     )
 | |
| 
 | |
|     graph.add_data(
 | |
|         :data => changes_by_month[0..11].reverse,
 | |
|         :title => l(:label_change_plural)
 | |
|     )
 | |
| 
 | |
|     graph.burn
 | |
|   end
 | |
| 
 | |
|   def graph_commits_per_author(repository)
 | |
|     commits_by_author = Changeset.count(:all, :group => :committer, :conditions => ["repository_id = ?", repository.id])
 | |
|     commits_by_author = commits_by_author.to_a.sort! {|x, y| x.last <=> y.last}.last(25)
 | |
| 
 | |
|     changes_by_author = Change.count(:all, :group => :committer, :include => :changeset, :conditions => ["#{Changeset.table_name}.repository_id = ?", repository.id])
 | |
|     h = changes_by_author.inject({}) {|o, i| o[i.first] = i.last; o}
 | |
| 
 | |
|     fields = commits_by_author.collect {|r| r.first}
 | |
|     commits_data = commits_by_author.collect {|r| r.last}
 | |
|     changes_data = commits_by_author.collect {|r| h[r.first] || 0}
 | |
| 
 | |
|     fields = fields + [""]*(10 - fields.length) if fields.length<10
 | |
|     commits_data = commits_data + [0]*(10 - commits_data.length) if commits_data.length<10
 | |
|     changes_data = changes_data + [0]*(10 - changes_data.length) if changes_data.length<10
 | |
| 
 | |
|     # Remove email adress in usernames
 | |
|     fields = fields.collect {|c| c.gsub(%r{<.+@.+>}, '') }
 | |
| 
 | |
|     graph = SVG::Graph::BarHorizontal.new(
 | |
|         :height => 400,
 | |
|         :width => 600,
 | |
|         :fields => fields,
 | |
|         :stack => :side,
 | |
|         :scale_integers => true,
 | |
|         :show_data_values => true,
 | |
|         :rotate_y_labels => false,
 | |
|         :graph_title => l(:label_commits_per_author),
 | |
|         :show_graph_title => true
 | |
|     )
 | |
|     graph.add_data(
 | |
|         :data => commits_data,
 | |
|         :title => l(:label_revision_plural)
 | |
|     )
 | |
|     graph.add_data(
 | |
|         :data => changes_data,
 | |
|         :title => l(:label_change_plural)
 | |
|     )
 | |
|     graph.burn
 | |
|   end
 | |
| 
 | |
|   # 用户最近一年的提交次数
 | |
|   def graph_author_commits_per_month(repository)
 | |
|     @date_to = Date.today
 | |
|     @date_from = @date_to << 12
 | |
|     @date_from = Date.civil(@date_from.year, @date_from.month,  @date_from.day)
 | |
|     commits_by_author = Changeset.count(:all, :group => :committer,
 | |
|                                         :conditions => ["#{Changeset.table_name}.repository_id = ? AND #{Changeset.table_name}.commit_date BETWEEN ? AND ?", repository.id, @date_from, @date_to])
 | |
|     commits_by_author = commits_by_author.to_a.sort! {|x, y| x.last <=> y.last}.last(25)
 | |
| 
 | |
|     fields = commits_by_author.collect {|r| r.first}
 | |
|     commits_data = commits_by_author.collect {|r| r.last}
 | |
| 
 | |
|     fields = fields + [""]*(10 - fields.length) if fields.length<10
 | |
|     commits_data = commits_data + [0]*(10 - commits_data.length) if commits_data.length<10
 | |
| 
 | |
|     # Remove email adress in usernames
 | |
|     fields = fields.collect {|c| c.gsub(%r{<.+@.+>}, '') }
 | |
| 
 | |
|     graph = SVG::Graph::BarHorizontal.new(
 | |
|         :height => 400,
 | |
|         :width => 600,
 | |
|         :fields => fields,
 | |
|         :stack => :side,
 | |
|         :scale_integers => true,
 | |
|         :show_data_values => true,
 | |
|         :rotate_y_labels => false,
 | |
|         :graph_title => l(:label_author_commits_year),
 | |
|         :show_graph_title => true,
 | |
|         :no_css => true
 | |
|     )
 | |
|     graph.add_data(
 | |
|         :data => commits_data,
 | |
|         :title => l(:label_revision_commit_count)
 | |
|     )
 | |
|     graph.burn
 | |
|   end
 | |
| 
 | |
|   # 用户最近六个月的提交次数
 | |
|   def author_commits_six_month(repository)
 | |
|     @date_to = Date.today
 | |
|     @date_from = @date_to << 6
 | |
|     @date_from = Date.civil(@date_from.year, @date_from.month, @date_from.day)
 | |
|     commits_by_author = Changeset.count(:all, :group => :committer,
 | |
|                                         :conditions => ["#{Changeset.table_name}.repository_id = ? AND #{Changeset.table_name}.commit_date BETWEEN ? AND ?", repository.id, @date_from, @date_to])
 | |
|     commits_by_author = commits_by_author.to_a.sort! {|x, y| x.last <=> y.last}.last(25)
 | |
| 
 | |
|     fields = commits_by_author.collect {|r| r.first}
 | |
|     commits_data = commits_by_author.collect {|r| r.last}
 | |
| 
 | |
|     fields = fields + [""]*(10 - fields.length) if fields.length<10
 | |
|     commits_data = commits_data + [0]*(10 - commits_data.length) if commits_data.length<10
 | |
| 
 | |
|     # Remove email adress in usernames
 | |
|     fields = fields.collect {|c| c.gsub(%r{<.+@.+>}, '') }
 | |
| 
 | |
|     graph = SVG::Graph::BarHorizontal.new(
 | |
|         :height => 400,
 | |
|         :width => 600,
 | |
|         :fields => fields,
 | |
|         :stack => :side,
 | |
|         :scale_integers => true,
 | |
|         :show_data_values => true,
 | |
|         :rotate_y_labels => false,
 | |
|         :graph_title => l(:label_author_commits_six_month),
 | |
|         :show_graph_title => true
 | |
|     )
 | |
|     graph.add_data(
 | |
|         :data => commits_data,
 | |
|         :title => l(:label_revision_commit_count)
 | |
|     )
 | |
|     graph.burn
 | |
|   end
 | |
| 
 | |
|   # 最近六个月代码量统计
 | |
|   def author_code_six_month(repository)
 | |
|     @date_to = Date.today
 | |
|     @date_from = @date_to << 6
 | |
|     @date_from = Date.civil(@date_from.year, @date_from.month, @date_from.day)
 | |
|     commits_by_author = Changeset.count(:group => :committer, :conditions => ["#{Changeset.table_name}.repository_id = ? AND #{Changeset.table_name}.commit_date BETWEEN ? AND ?", repository.id, @date_from, @date_to])
 | |
|     commits_by_author = commits_by_author.to_a.sort! {|x, y| x.last <=> y.last}.last(40)
 | |
|     all_author = []
 | |
|     commits_by_author.each do |cba|
 | |
|       all_author << cba.first
 | |
|     end
 | |
|     # all_author = all_author.collect {|c| c.gsub(%r{/ /<.+@.+>}, '') }
 | |
|     all_author = all_author.collect {|c| c.split.first }
 | |
|     commits_by_author = repository.commits(all_author, "#{@date_from}", "#{@date_to}", repository.id == 150 ? "szzh" : 'master')
 | |
| 
 | |
|     fields = commits_by_author.collect {|r| r.first}
 | |
|     commits_data = commits_by_author.collect {|r| r.last}
 | |
| 
 | |
|     fields = fields + [""]*(10 - fields.length) if fields.length<10
 | |
|     commits_data = commits_data + [0]*(10 - commits_data.length) if commits_data.length<10
 | |
| 
 | |
|     # Remove email adress in usernames
 | |
|     fields = fields.collect {|c| c.gsub(%r{<.+@.+>}, '') }
 | |
| 
 | |
|     graph = SVG::Graph::BarHorizontal.new(
 | |
|         :height => 400,
 | |
|         :width => 600,
 | |
|         :fields => fields,
 | |
|         :stack => :side,
 | |
|         :scale_integers => true,
 | |
|         :show_data_values => true,
 | |
|         :rotate_y_labels => false,
 | |
|         :graph_title => l(:label_author_code_six_month),
 | |
|         :show_graph_title => true
 | |
|     )
 | |
|     graph.add_data(
 | |
|         :data => commits_data,
 | |
|         :title => l(:lable_revision_code_count)
 | |
|     )
 | |
|     graph.burn
 | |
|   end
 | |
| 
 | |
| 
 | |
|   def check_hidden_repo
 | |
|     project = Project.find(params[:id])
 | |
|     if !User.current.member_of?(project)
 | |
|       if project.hidden_repo
 | |
|         #render_403
 | |
|       end
 | |
|     end
 | |
|   rescue ActiveRecord::RecordNotFound
 | |
|     render_404
 | |
|   end
 | |
| end
 |