socialforge/app/helpers/user_score_helper.rb

# encoding: utf-8
#
# 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.

module UserScoreHelper
  def calculate_collaboration_count(user)
    issue_c = 0
    issues = Issue.where('author_id = ?', user.id)
    issues.each do |issue|
      issue_c = issue_c + issue.journals.where("user_id <> ?", user.id).count
    end
    issue_c = issue_c + Journal.where("user_id = ?", user.id).count
    ############################
    memos = Memo.where('author_id = ? AND parent_id IS NOT NULL', user.id)
    
    memos.each do |m|
      if Memo.find(m.parent_id).author.id != user.id
        issue_c = issue_c + 1
      else
        issue_c = issue_c - 1
      end
    end
    
    
    pmemos = Memo.where('author_id = ? AND parent_id IS NULL', user.id)
    pmemos.each do |pm|
      issue_c = issue_c + pm.replies_count
    end
    ############################
    
    issue_c = issue_c + JournalsForMessage.where('user_id = ? AND reply_id IS NOT NULL AND reply_id <> ?', user.id, user.id).count + JournalsForMessage.where('reply_id = ? AND user_id <> ?', user.id, user.id).count
    
    
    
    return issue_c
  end

  def calculate_influence_count(user)
    watcher_count = Watcher.where("watchable_type = 'principal' AND watchable_id = ?", user.id).count
  end




  def calculate_skill_count(user)
    
    praise_count_l0 = 0
    praise_count_l1 = 0
    praise_count_l2 = 0
    tread_count_l0 = 0
    tread_count_l1 = 0
    tread_count_l2 = 0
    issues = Issue.where('author_id = ?', user.id)   
    issues.each do |i|
      pts = PraiseTread.where('praise_tread_object_id = ?', i.id)
      pts.each do |p|
        templevel = calculate_level(User.find(p.user_id))

        if templevel.to_i == 0
          if p.praise_or_tread == 1
            praise_count_l0 = praise_count_l0 + 1
          else
            tread_count_l0 = tread_count_l0 + 1            
          end
        end
        if templevel.to_i == 1
          if p.praise_or_tread == 1
            praise_count_l1 = praise_count_l1 + 1
          else
            tread_count_l1 = tread_count_l1 + 1
          end
        end
        if templevel.to_i == 2
          if p.praise_or_tread == 1
            praise_count_l2 = praise_count_l2 + 1
          else
            tread_count_l2 + tread_count_l2 + 1
          end
        end
      end
    end



    
    bids = Bid.where('author_id = ?', user.id)
    bids.each do |b|
      ptcs = PraiseTread.where('praise_tread_object_id = ?', b.id)
      ptcs.each do |p|
        templevel = calculate_level(User.find(p.user_id))

        if templevel.to_i == 0
          if p.praise_or_tread == 1
            praise_count_l0 = praise_count_l0 + 1
          else
            tread_count_l0 = tread_count_l0 + 1            
          end
        end
        if templevel.to_i == 1
          if p.praise_or_tread == 1
            praise_count_l1 = praise_count_l1 + 1
          else
            tread_count_l1 = tread_count_l1 + 1
          end
        end
        if templevel.to_i == 2
          if p.praise_or_tread == 1
            praise_count_l2 = praise_count_l2 + 1
          else
            tread_count_l2 + tread_count_l2 + 1
          end
        end
      end
    end
    
    contests = Contest.where('author_id = ?', user.id)
    contests.each do |c|
      ptcs = PraiseTread.where('praise_tread_object_id = ?', c.id)
      ptcs.each do |p|
        templevel = calculate_level(User.find(p.user_id))

        if templevel.to_i == 0
          if p.praise_or_tread == 1
            praise_count_l0 = praise_count_l0 + 1
          else
            tread_count_l0 = tread_count_l0 + 1            
          end
        end
        if templevel.to_i == 1
          if p.praise_or_tread == 1
            praise_count_l1 = praise_count_l1 + 1
          else
            tread_count_l1 = tread_count_l1 + 1
          end
        end
        if templevel.to_i == 2
          if p.praise_or_tread == 1
            praise_count_l2 = praise_count_l2 + 1
          else
            tread_count_l2 + tread_count_l2 + 1
          end
        end 
      end     
    end
    
    
    
#    case level
#      when 0 skill_score = praise_count - 0.5 * tread_count
#      when 1 skill_score = 2 * praise_count - 1.5 * tread_count
#      when 2 skill_socre = 3 * praise_count - 2.5 * tread_count
#      when 3 skill_socre = 4 * praise_count - 3.5 * tread_count
#      when 4 skill_socre = 5 * praise_count - 4.5 * tread_count
#    end

    skill_score = 2 * praise_count_l0.to_f + 3 * praise_count_l1.to_f + 4 * praise_count_l2.to_f
                  - 1 * tread_count_l0.to_f - 1.5 * tread_count_l1.to_f - 2 * tread_count_l2.to_f
    
    tread_user_count = PraiseTread.where('praise_or_tread = ? AND user_id = ?', 0, user.id).count
    
    skill_score = skill_score.to_f - tread_user_count.to_f







    return skill_score
    
    
    
  end
  
  def calculate_level(user)
    commit_count = user.changesets.count
    max_praise_num = 0
    
    
    issues = Issue.where('author_id = ?', user.id)   
    issues.each do |i|
      ptcs = PraiseTreadCache.where('object_id = ?', i.id)
      ptcs.each do |p|
        if p.praise_num.to_i > max_praise_num.to_i
          max_praise_num = p.praise_num
        end
      end
    end
    
    bids = Bid.where('author_id = ?', user.id)
    bids.each do |b|
      ptcs = PraiseTreadCache.where('object_id = ?', b.id)
      ptcs.each do |p|
        if p.praise_num.to_i > max_praise_num.to_i
          max_praise_num = p.praise_num
        end
      end
    end
    
    contests = Contest.where('author_id = ?', user.id)
    contests.each do |c|
      ptcs = PraiseTreadCache.where('object_id = ?', c.id)
      ptcs.each do |p|
        if p.praise_num.to_i > max_praise_num.to_i
          max_praise_num = p.praise_num
        end
      end     
    end
    
    
    best_answer_num = 0
    
    isManager = 0
    members = Member.where('user_id = ?', user.id)
    members.each do |m|
      @membership = m.memberships.all(:conditions => Project.visible_condition(User.current))
      @membership.each do |membership|
        #拥有编辑项目权限的可操作该项目
        if m.allowed_to?(:is_manager, membership.project, :global => false)
          isManager = 1
        end
      end


    end
    
    level = 0
    
    if max_praise_num > 4
      level = 1
    end
    if commit_count > 0 and commit_count < 101
      level = 1
    end  
    if commit_count > 100 or isManager == 1
      level = 2
    end
    
    return level
    
  end

  def calculate_activity_count(user)
    # commit_count = user.changesets.count
    # issue_details_count = 0
    # issues = Issue.where('assigned_to_id = ?', user.id)
    # issues.each do |issue|
    # change_count = issue.journals.where("prop_key = ?", "done_ratio").count
    # issue_details_count = change_count + issue_details_count
    # end
    # file_count = user.file_commit.count
    # issue_count = Issue.where('author_id = ?', user.id).count
    #f = user.user_score.file
    #i = user.user_score.issue
    #f_max = UserScore.find_max_file
    #f_min = UserScore.find_min_file
    #i_max = UserScore.find_max_issue
    #i_min = UserScore.find_min_issue
    #score = 100 * ((f - f_min)/(f_max - f_min) + (i - i_min)/(i_max - i_min))
  end

  def calculate_file(user)
    file_count = user.file_commit.count
    issue_count = Issue.where('author_id = ?', user.id).count
    return (file_count + issue_count)
  end

  def calculate_issue(user)
    commit_count = user.changesets.count
     
    issue_details_count = 0
    issues = Issue.where('assigned_to_id = ?', user.id)
    
    change_count = 0
    issues.each do |issue|
      js = issue.journals
      js.each do |j|
        change_count = change_count + j.details.where("prop_key = ?", "done_ratio").count
      end
    
      
      issue_details_count = change_count + issue_details_count
    end
    
    return (commit_count + issue_details_count)
    
  end


  def calculate_attachments(user)
    attachments = Attachment.where("container_type IS NOT NULL AND container_type <> 'Issue' AND author_id = ?", user.id).count

    return attachments
    
  end
  
  def calculate_user_score(user)
    collaboration = calculate_collaboration_count(user)
    influence = calculate_influence_count(user)
    skill = calculate_skill_count(user)
    activity = calculate_activity_count(user)
    file = calculate_file(user)
    issue = calculate_issue(user)
    level = calculate_level(user)
    #user.user_score << UserScore.new(:collaboration => collaboration, :influence => influence, :skill => skill,
    #                                 :activity => activity, :file => file, :issue => issue, :level => level)
    UserScore.new(:collaboration => collaboration, :influence => influence, :skill => skill,
                                     :activity => activity, :file => file, :issue => issue, :level => level)
  end
  
  def update_user_score(user)
    collaboration = calculate_collaboration_count(user)
    influence = calculate_influence_count(user)
    skill = calculate_skill_count(user)
    file = calculate_file(user)
    issue = calculate_issue(user)

    ##activity = calculate_activity_count(user)
    
    level = calculate_level(user)
    user.user_score.update_attributes(:collaboration => collaboration, :influence => influence, :skill => skill,
                                      :activity => activity, :file => file, :issue => issue, :level => level)
  end

  #====================================================================================================
  def get_option_number(user,type,project_id=nil)
    if project_id.nil?
      option_number = OptionNumber.where("user_id = '#{user.id}' and score_type = '#{type}'");
    else
      option_number = OptionNumber.where("user_id = '#{user.id}' and score_type = '#{type}' and project_id = '#{project_id}'");
    end

     result = nil
     if option_number.nil? || option_number.count == 0
       result = OptionNumber.new
       result.user_id = user.id
       result.memo = 0
       result.messages_for_issues = 0
       result.issues_status = 0
       result.replay_for_message = 0
       result.replay_for_memo = 0
       result.follow = 0
       result.tread = 0
       result.praise_by_one = 0
       result.praise_by_two = 0
       result.praise_by_three = 0
       result.tread_by_one = 0
       result.tread_by_two = 0
       result.tread_by_three = 0
       result.changeset = 0
       result.document = 0
       result.attachment = 0
       result.issue_done_ratio = 0
       result.post_issue = 0
       result.total_score = 0
       result.score_type  =type
       unless project_id.nil?
          result.project_id = project_id
       end
     else
       result = option_number.first
     end
     result
  end

  #更新分数
  def update_score(option_number)
    option_number.total_score = collaboration(option_number) + influence(option_number) + skill(option_number) + active(option_number)
    option_number.save
  end

  #协同得分
  def collaboration(option_number)
    option_number.memo * 2 + option_number.messages_for_issues + option_number.issues_status + option_number.replay_for_message + option_number.replay_for_memo
  end
  #影响力得分
  def influence(option_number)
    option_number.follow * 2
  end
  #技术得分
  def skill(option_number)
     option_number.praise_by_one * 4  + option_number.praise_by_two * 6 + option_number.praise_by_three * 8 - option_number.tread * 2 - option_number.tread_by_one * 2 - option_number.tread_by_two * 4 - option_number.tread_by_three * 6
  end
  #项目贡献得分
  def active(option_number)
    option_number.changeset * 4 + option_number.document * 4 + option_number.attachment * 4 + option_number.issue_done_ratio * 2 + option_number.post_issue * 4
  end

  #更新发帖数
  def update_memo_number(user,type)
    option_number = get_option_number(user,type)
    option_number.memo = Message.includes(:author).where("parent_id IS NULL and author_id = '#{user.id}'").all.count +  Memo.includes(:author).where("parent_id IS NULL and author_id = '#{user.id}'").all.count
    update_score(option_number)
  end

  #发帖数
  def memo_num(user,project=nil)
    if project.nil?
      Message.includes(:author).joins(:board).where("#{Message.table_name}.parent_id IS NULL and #{Message.table_name}.author_id = '#{user.id}' and #{Board.table_name}.project_id != -1").all.count
    else
      Message.includes(:author).joins(:board).where("#{Message.table_name}.parent_id IS NULL and #{Message.table_name}.author_id = '#{user.id}' and #{Board.table_name}.project_id = #{project.id}").all.count
    end

  end

  #更新对缺陷留言数
  def update_messges_for_issue(user,type)
    option_number = get_option_number(user,type)
    option_number.messages_for_issues = Journal.includes(:user).where("user_id = '#{user.id}' and notes != '' and notes is not null").all.count
    update_score(option_number)
  end

  def messges_for_issue_num(user,project=nil)
    if project.nil?
      Journal.includes(:user).where("user_id = '#{user.id}' and notes != '' and notes is not null").all.count
    else
      Journal.includes(:user).joins(:issue).where("#{Journal.table_name}.user_id = '#{user.id}' and #{Issue.table_name}.project_id = '#{project.id}' and #{Journal.table_name}.notes != '' and #{Journal.table_name}.notes is not null").all.count
    end
  end

  #更新更改缺陷状态状态次数
  def update_issues_status(user,type)
    option_number = get_option_number(user,type)
    option_number.issues_status = Journal.joins(:details, :user).where("#{JournalDetail.table_name}.prop_key = 'status_id' and #{User.table_name}.id = '#{user.id}'").count
    update_score(option_number)
  end

  def issues_status_num(user,project=nil)
    if project.nil?
      Journal.joins(:details, :user).where("#{JournalDetail.table_name}.prop_key = 'status_id' and #{User.table_name}.id = '#{user.id}'").count
    else
      Journal.joins(:issue,:details,:user).where("#{Issue.table_name}.project_id = '#{project.id}' and #{JournalDetail.table_name}.prop_key = 'status_id' and #{User.table_name}.id = '#{user.id}'").count
    end

  end

  #更新对留言的回复数量
  def update_replay_for_message(user,type)
    option_number = get_option_number(user,type)
    option_number.replay_for_message = JournalsForMessage.includes(:user).where("m_parent_id IS NOT NULL and user_id = #{user.id}").count
    update_score(option_number)
  end

  def replay_for_message_num(user)
      JournalsForMessage.includes(:user).where("m_parent_id IS NOT NULL and user_id = #{user.id}").count
  end

  #更新对帖子的回复数量
  def update_replay_for_memo(user,type)
    option_number = get_option_number(user,type)
    option_number.replay_for_memo = Message.includes(:author).where("parent_id IS NOT NULL and author_id = #{user.id}").all.count #+ Memo.includes(:author).where("parent_id IS NOT NULL and author_id = #{user.id}").all.count
    update_score(option_number)
  end

  def replay_for_memo_num(user,project=nil)
    if project.nil?
      Message.includes(:author).where("parent_id IS NOT NULL and author_id = #{user.id}").all.count
    else
      Message.includes(:author).joins(:board).where("#{Message.table_name}.parent_id IS NOT NULL and #{Message.table_name}.author_id = '#{user.id}' and #{Board.table_name}.project_id = #{project.id}").all.count
    end
  end

  #更新被关注的人数
  def update_follow(user,type)
    option_number = get_option_number(user,type)
    option_number.follow = Watcher.includes(:watchable).where("watchable_type = 'Principal' and watchable_id = '#{user.id}'").count
    update_score(option_number)
  end

  def follow_num(user)
    Watcher.includes(:watchable).where("watchable_type = 'Principal' and watchable_id = '#{user.id}'").count
  end

  #更新帖子踩各项数量
  def update_tread(user,type)
    option_number = get_option_number(user,type)
    option_number.tread = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0 and user_id = '#{user.id}'").all.count
    pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0").all
    result = []
    result1 = []
    result2 = []
    pts.each do |pt|
      obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
      if obj.nil?
        next
      end
      target_user = obj.author
      level = UserLevels.get_level(pt.user)#pt.user.get_level
      project = pt.project
      if level == 1 && target_user.id = user.id
        result << pt
      elsif level == 2 &&  target_user.id = user.id
        result1 << pt
      elsif level == 3 && target_user.id = user.id
        result2 << pt
      end
    end
    option_number.tread_by_one = result.count
    option_number.tread_by_two = result1.count
    option_number.tread_by_three = result2.count
    update_score(option_number)
  end

  def tread_num(user,project=nil)
    if project.nil?
      result0 = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0 and user_id = '#{user.id}'").all.count
      pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0").all
      result = []
      result1 = []
      result2 = []
      pts.each do |pt|
        obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
        if obj.nil?
          next
        end
        target_user = obj.author
        level = UserLevels.get_level(pt.user)#pt.user.get_level
        project = pt.project
        if level == 1 && target_user.id = user.id
          result << pt
        elsif level == 2 &&  target_user.id = user.id
          result1 << pt
        elsif level == 3 && target_user.id = user.id
          result2 << pt
        end
      end
      [:tread=>result0,:tead_by_one => result.count,:tread_by_two => result1.count,:tread_by_three =>result2.count]
    else
      result0 = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0 and user_id = '#{user.id}'").all.count
      pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 0").all
      result = []
      result1 = []
      result2 = []
      pts.each do |pt|
        obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
        if obj.nil?
          next
        end
        if !(pt.praise_tread_object_type == "Issue" && obj.project.id == project.id) && !(pt.praise_tread_object_type == "Message" && obj.board.project.id == project.id)
          next
        end
        target_user = obj.author
        level = UserLevels.get_level(pt.user)#pt.user.get_level
        project = pt.project
        if level == 1 && target_user.id = user.id
          result << pt
        elsif level == 2 &&  target_user.id = user.id
          result1 << pt
        elsif level == 3 && target_user.id = user.id
          result2 << pt
        end
      end
      [:tread=>result0,:tead_by_one => result.count,:tread_by_two => result1.count,:tread_by_three =>result2.count]
    end

  end

  #更新帖子顶数量
  def update_praise(user,type)
    option_number = get_option_number(user,type)
    pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 1").all
    result = []
    result1 = []
    result2 = []
    pts.each do |pt|
      obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
      if obj.nil?
        next
      end
      target_user = obj.author
      level = UserLevels.get_level(pt.user)#pt.user.get_level
      project = pt.project
      if level == 1 && target_user.id = user.id
        result << pt
      elsif level == 2 &&  target_user.id = user.id
        result1 << pt
      elsif level == 3 && target_user.id = user.id
        result2 << pt
      end
    end
    option_number.praise_by_one = result.count
    option_number.praise_by_two = result1.count
    option_number.praise_by_three = result2.count
    update_score(option_number)
  end

  def praise_num(user,project=nil)
    if project.nil?
      pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 1").all
      result = []
      result1 = []
      result2 = []
      pts.each do |pt|
        obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
        if obj.nil?
          next
        end
        if !(pt.praise_tread_object_type == "Issue" && obj.project.id == project.id) && !(pt.praise_tread_object_type == "Message" && obj.board.project.id == project.id)
          next
        end
        target_user = obj.author
        level = UserLevels.get_level(pt.user)#pt.user.get_level
        project = pt.project
        if level == 1 && target_user.id = user.id
          result << pt
        elsif level == 2 &&  target_user.id = user.id
          result1 << pt
        elsif level == 3 && target_user.id = user.id
          result2 << pt
        end
      end
      [:praise_by_one => result.count,:praise_by_two => result1.count,:praise_by_three => result2.count]
    else
      pts = PraiseTread.where("praise_tread_object_type = 'Issue' || praise_tread_object_type = 'Message' and praise_or_tread = 1").all
      result = []
      result1 = []
      result2 = []
      pts.each do |pt|
        obj = PraiseTread.find_object_by_type_and_id(pt.praise_tread_object_type, pt.praise_tread_object_id)
        if obj.nil?
          next
        end
        target_user = obj.author
        level = UserLevels.get_level(pt.user)#pt.user.get_level
        project = pt.project
        if level == 1 && target_user.id = user.id
          result << pt
        elsif level == 2 &&  target_user.id = user.id
          result1 << pt
        elsif level == 3 && target_user.id = user.id
          result2 << pt
        end
      end
      [:praise_by_one => result.count,:praise_by_two => result1.count,:praise_by_three => result2.count]
    end

  end

  #更新提交代码次数
  def update_changeset(user,type)
    option_number = get_option_number(user,type)
    option_number.changeset = Changeset.includes(:user).where("user_id = '#{user.id}'").all.count
    update_score(option_number)
  end

  def changeset_num(user,project=nil)
    if project.nil?
      Changeset.includes(:user).where("user_id = '#{user.id}'").all.count
    else
      Changeset.includes(:user).joins(:repository).where("#{Changeset.table_name}.user_id = '#{user.id}' and #{Repository.table_name}.project_id = #{project.id}").all.count
    end

  end

  #更新文档提交次数
  def update_document(user,type)
    option_number = get_option_number(user,type)
    option_number.document =  Document.includes(:user).where("user_id = '#{user.id}'").all.count
    update_score(option_number)
  end

  def document_num(user,project=nil?)
    if project.nil?
      Document.includes(:user).where("user_id = '#{user.id}'").all.count
    else
      Document.includes(:user,:project).where("user_id = '#{user.id}' and project_id = '#{project.id}'").all.count
    end

  end

  #更新附件提交数量
  def update_attachment(user,type)
    option_number = get_option_number(user,type)
    option_number.attachment =  Attachment.includes(:author).where("author_id = '#{user.id}'").all.count
    update_score(option_number)
  end
  #===================here to continue============================
  def attachment_num(user,project=nil)
    if project.nil?
      Attachment.includes(:author).where("author_id = '#{user.id}'").all.count
    else
      Attachment.includes(:author,:container).where("author_id = '#{user.id}' and container_type = 'Project' and container_id = #{project.id}").all.count
    end

  end

  #更新缺陷完成度次数
  def update_issue_done_ratio(user,type)
    option_number = get_option_number(user,type)
    option_number.issue_done_ratio =  Journal.joins(:details, :user).where("#{JournalDetail.table_name}.prop_key = 'done_ratio' and #{User.table_name}.id = '#{user.id}'").count
    update_score(option_number)
  end

  def issue_done_ratio_num(user,project)
    Journal.joins(:details, :user).where("#{JournalDetail.table_name}.prop_key = 'done_ratio' and #{User.table_name}.id = '#{user.id}'").count
  end

  #更新发布缺陷次数
  def update_post_issue(user,type)
    option_number = get_option_number(user,type)
    option_number.post_issue =  Issue.includes(:author).where("author_id = '#{user.id}'").all.count
    update_score(option_number)
  end

  def post_issue_num(user,project=nil)
    Issue.includes(:author).where("author_id = '#{user.id}'").all.count
  end
end