Merge branch 'develop' into standalone_develop

app/services/api/v1/issues/batch_delete_service.rb

@@ -0,0 +1,38 @@
+class Api::V1::Issues::BatchDeleteService < ApplicationService
+  include ActiveModel::Model
+
+  attr_reader :project, :issues, :current_user
+
+  validates :project, :issues, :current_user, presence: true
+
+  def initialize(project, issues, current_user = nil)
+    @project = project 
+    @issues = issues.includes(:assigners)
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    try_lock("Api::V1::Issues::DeleteService:#{project.id}") # 开始写数据，加锁
+
+    delete_issues
+
+    project.incre_project_issue_cache_delete_count(@issues.size)
+
+    if Site.has_notice_menu?
+      @issues.each do |issue|
+        SendTemplateMessageJob.perform_later('IssueDeleted', current_user.id, @issue&.subject, @issue.assigners.pluck(:id), @issue.author_id) 
+      end
+    end
+
+    unlock("Api::V1::Issues::DeleteService:#{project.id}")
+
+    return true
+  end
+
+  private
+
+  def delete_issues
+    raise Error, "批量删除疑修失败！" unless @issues.destroy_all
+  end
+end

app/services/api/v1/issues/batch_update_service.rb

@@ -0,0 +1,33 @@
+class Api::V1::Issues::BatchUpdateService < ApplicationService
+  include ActiveModel::Model
+  include Api::V1::Issues::Concerns::Checkable 
+  include Api::V1::Issues::Concerns::Loadable 
+
+  attr_reader :project, :issues, :params, :current_user
+  attr_reader :status_id, :priority_id, :milestone_id
+  attr_reader :issue_tag_ids, :assigner_ids
+
+  validates :project, :issues, :current_user, presence: true
+
+  def initialize(project, issues, params, current_user = nil)
+    @project = project 
+    @issues = issues
+    @params = params
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    ActiveRecord::Base.transaction do 
+      @issues.each do |issue| 
+        if issue.issue_classify == "issue"
+          Api::V1::Issues::UpdateService.call(project, issue, params, current_user)
+        end
+      end
+
+      return true
+    end
+  end
+
+
+end

app/services/api/v1/issues/concerns/checkable.rb

@@ -0,0 +1,48 @@
+module Api::V1::Issues::Concerns::Checkable 
+
+  def check_issue_status(status_id)
+    raise ApplicationService::Error, "IssueStatus不存在！" unless IssueStatus.find_by_id(status_id).present?
+  end
+
+  def check_issue_priority(priority_id)
+    raise ApplicationService::Error, "IssuePriority不存在！" unless IssuePriority.find_by_id(priority_id).present? 
+  end
+
+  def check_milestone(milestone_id)
+    raise ApplicationService::Error, "Milestone不存在！" unless Version.find_by_id(milestone_id).present?
+  end
+
+  def check_issue_tags(issue_tag_ids)
+    raise ApplicationService::Error, "请输入正确的标记ID数组！" unless issue_tag_ids.is_a?(Array)
+    raise ApplicationService::Error, "最多可选择3个标记" if issue_tag_ids.size > 3
+    issue_tag_ids.each do |tid|
+      raise ApplicationService::Error, "请输入正确的标记ID！" unless IssueTag.exists?(id: tid)
+    end
+  end
+
+  def check_assigners(assigner_ids)
+    raise ApplicationService::Error, "请输入正确的负责人ID数组！" unless assigner_ids.is_a?(Array)
+    raise ApplicationService::Error, "最多可选择5个负责人" if assigner_ids.size > 5
+    assigner_ids.each do |aid|
+      raise ApplicationService::Error, "请输入正确的负责人ID！" unless User.exists?(id: aid)
+    end 
+  end
+
+  def check_attachments (attachment_ids)
+    raise ApplicationService::Error, "请输入正确的附件ID数组！" unless attachment_ids.is_a?(Array)
+    attachment_ids.each do |aid|
+      raise ApplicationService::Error, "请输入正确的附件ID！" unless Attachment.exists?(id: aid)
+    end 
+  end
+
+  def check_atme_receivers(receivers_login)
+    raise ApplicationService::Error, "请输入正确的用户标识数组！" unless receivers_login.is_a?(Array)
+    receivers_login.each do |rlogin|
+      raise ApplicationService::Error, "请输入正确的用户标识！" unless User.exists?(login: rlogin)
+    end 
+  end
+
+  def check_parent_journal(parent_id)
+    raise ApplicationService::Error, "ParentJournal不存在！" unless Journal.find_by_id(parent_id).present? 
+  end
+end

app/services/api/v1/issues/concerns/loadable.rb

@@ -0,0 +1,19 @@
+module Api::V1::Issues::Concerns::Loadable 
+
+  def load_assigners(assigner_ids)
+    @assigners = User.where(id: assigner_ids)
+  end
+
+  def load_issue_tags(issue_tag_ids)
+    @issue_tags = IssueTag.where(id: issue_tag_ids)
+  end
+
+  def load_attachments(attachment_ids)
+    @attachments = Attachment.where(id: attachment_ids)
+  end
+
+  def load_atme_receivers(receivers_login)
+    @atme_receivers = User.where(login: receivers_login)
+  end
+
+end

app/services/api/v1/issues/create_service.rb

@@ -0,0 +1,126 @@
+class Api::V1::Issues::CreateService < ApplicationService
+  include ActiveModel::Model
+  include Api::V1::Issues::Concerns::Checkable 
+  include Api::V1::Issues::Concerns::Loadable 
+
+  attr_reader :project, :current_user
+  attr_reader :status_id, :priority_id, :milestone_id, :branch_name, :start_date, :due_date, :subject, :description
+  attr_reader :issue_tag_ids, :assigner_ids, :attachment_ids, :receivers_login
+  attr_accessor :created_issue
+
+  validates :subject, presence: true
+  validates :status_id, :priority_id, presence: true
+  validates :project, :current_user, presence: true
+
+  def initialize(project, params, current_user = nil)
+    @project = project 
+    @current_user = current_user 
+    @status_id = params[:status_id]
+    @priority_id = params[:priority_id]
+    @milestone_id = params[:milestone_id]
+    @branch_name = params[:branch_name]
+    @start_date = params[:start_date]
+    @due_date = params[:due_date]
+    @subject = params[:subject]
+    @description = params[:description]
+    @issue_tag_ids = params[:issue_tag_ids]
+    @assigner_ids = params[:assigner_ids]
+    @attachment_ids = params[:attachment_ids]
+    @receivers_login = params[:receivers_login]
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    ActiveRecord::Base.transaction do 
+      check_issue_status(status_id)
+      check_issue_priority(priority_id)
+      check_milestone(milestone_id) if milestone_id.present?
+      check_issue_tags(issue_tag_ids) unless issue_tag_ids.blank?
+      check_assigners(assigner_ids) unless assigner_ids.blank?
+      check_attachments(attachment_ids) unless attachment_ids.blank?
+      check_atme_receivers(receivers_login) unless receivers_login.blank?
+      load_assigners(assigner_ids) unless assigner_ids.blank?
+      load_attachments(attachment_ids) unless attachment_ids.blank?
+      load_issue_tags(issue_tag_ids) unless issue_tag_ids.blank?
+      load_atme_receivers(receivers_login) unless receivers_login.blank?
+    
+      try_lock("Api::V1::Issues::CreateService:#{project.id}") # 开始写数据，加锁
+      @created_issue = Issue.new(issue_attributes)
+      build_author_participants
+      build_assigner_participants unless assigner_ids.blank?
+      build_atme_participants if @atme_receivers.present?
+      build_issue_journal_details 
+      build_issue_project_trends 
+      @created_issue.assigners = @assigners unless assigner_ids.blank?
+      @created_issue.attachments = @attachments unless attachment_ids.blank?
+      @created_issue.issue_tags = @issue_tags unless issue_tag_ids.blank?
+      
+      @created_issue.issue_tags_value = @issue_tags.order("id asc").pluck(:id).join(",") unless issue_tag_ids.blank?
+      @created_issue.save!
+      project.del_project_issue_cache_delete_count # 把缓存里存储项目删除issue的个数清除掉
+
+      # @信息发送
+      AtmeService.call(current_user, @atme_receivers, @created_issue) unless receivers_login.blank?
+
+      # 发消息
+      if Site.has_notice_menu?
+        SendTemplateMessageJob.perform_later('IssueAssigned', current_user.id, @issue&.id, assigner_ids) unless assigner_ids.blank?
+        SendTemplateMessageJob.perform_later('ProjectIssue', current_user.id, @issue&.id)
+      end
+ 
+      unlock("Api::V1::Issues::CreateService:#{project.id}") # 结束写数据，解锁
+    end
+    
+    return @created_issue
+  end
+
+  private 
+
+  def issue_attributes 
+    issue_attributes = {
+      subject: subject,
+      project_id: project.id,
+      author_id: current_user.id,
+      tracker_id: Tracker.first.id,
+      status_id: status_id, 
+      priority_id: priority_id,
+      project_issues_index: (project.get_last_project_issues_index + 1),
+      issue_type: "1",
+      issue_classify: "issue"
+    }
+
+    issue_attributes.merge!({description: description}) if description.present?
+    issue_attributes.merge!({fixed_version_id: milestone_id}) if milestone_id.present?
+    issue_attributes.merge!({start_date: start_date}) if start_date.present?
+    issue_attributes.merge!({due_date: due_date}) if due_date.present?
+    issue_attributes.merge!({branch_name: branch_name}) if branch_name.present?
+
+    issue_attributes
+  end
+
+  def build_author_participants 
+    @created_issue.issue_participants.new({participant_type: "authored", participant_id: current_user.id})
+  end
+
+  def build_assigner_participants
+    assigner_ids.each do |aid|
+      @created_issue.issue_participants.new({participant_type: "assigned", participant_id: aid})
+    end
+  end
+
+  def build_atme_participants
+    @atme_receivers.each do |receiver|
+      @created_issue.issue_participants.new({participant_type: "atme", participant_id: receiver.id})
+    end
+  end
+
+  def build_issue_project_trends
+    @created_issue.project_trends.new({user_id: current_user.id, project_id: @project.id, action_type: "create"})
+    @created_issue.project_trends.new({user_id: current_user.id, project_id: @project.id, action_type: ProjectTrend::CLOSE}) if status_id.to_i == 5
+  end
+
+  def build_issue_journal_details
+    journal = @created_issue.journals.new({user_id: current_user.id})
+    journal.journal_details.new({property: "issue", prop_key: 1, old_value: '', value: ''})
+  end 
+end

app/services/api/v1/issues/delete_service.rb

@@ -0,0 +1,37 @@
+class Api::V1::Issues::DeleteService < ApplicationService
+  include ActiveModel::Model
+
+  attr_reader :project, :issue, :current_user
+
+  validates :project, :issue, :current_user, presence: true
+
+  def initialize(project, issue, current_user = nil)
+    @project = project 
+    @issue = issue
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    try_lock("Api::V1::Issues::DeleteService:#{project.id}") # 开始写数据，加锁
+
+    delete_issue
+
+    project.incre_project_issue_cache_delete_count
+
+    if Site.has_notice_menu?
+      SendTemplateMessageJob.perform_later('IssueDeleted', current_user.id, @issue&.subject, @issue.assigners.pluck(:id), @issue.author_id) 
+    end
+    
+    unlock("Api::V1::Issues::DeleteService:#{project.id}")
+
+    return true
+  end
+
+  private
+
+  def delete_issue
+    raise Error, "删除疑修失败！" unless issue.destroy!
+  end
+
+end

app/services/api/v1/issues/journals/children_list_service.rb

@@ -0,0 +1,42 @@
+class Api::V1::Issues::Journals::ChildrenListService < ApplicationService 
+
+  include ActiveModel::Model
+
+  attr_reader :issue, :journal, :keyword, :sort_by, :sort_direction
+  attr_accessor :queried_journals
+
+  validates :sort_by, inclusion: {in: Journal.column_names, message: '请输入正确的SortBy'}, allow_blank: true
+  validates :sort_direction, inclusion: {in: %w(asc desc), message: '请输入正确的SortDirection'}, allow_blank: true
+
+
+  def initialize(issue, journal, params, current_user=nil)
+    @issue = issue 
+    @journal = journal 
+    @keyword = params[:keyword]
+    @sort_by = params[:sort_by].present? ? params[:sort_by] : 'created_on'
+    @sort_direction = (params[:sort_direction].present? ? params[:sort_direction] : 'asc').downcase
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    begin
+      journal_query_data
+        
+      return @queried_journals
+    rescue 
+      raise Error, "服务器错误，请联系系统管理员！"
+      
+    end
+  end
+
+  private 
+  def journal_query_data
+    @queried_journals = journal.children_journals
+
+    @queried_journals = @queried_journals.ransack(notes_cont: keyword).result if keyword.present?
+    @queried_journals = @queried_journals.includes(:user, :attachments, :reply_journal)
+    @queried_journals = @queried_journals.reorder("journals.#{sort_by} #{sort_direction}").distinct
+
+    @queried_journals
+  end
+end

app/services/api/v1/issues/journals/create_service.rb

@@ -0,0 +1,75 @@
+class Api::V1::Issues::Journals::CreateService < ApplicationService
+  include ActiveModel::Model
+  include Api::V1::Issues::Concerns::Checkable 
+  include Api::V1::Issues::Concerns::Loadable 
+
+  attr_reader :issue, :current_user, :notes, :parent_id, :reply_id, :attachment_ids, :receivers_login
+  attr_accessor :created_journal, :atme_receivers
+
+  validates :notes, :issue, :current_user, presence: true
+
+  def initialize(issue, params, current_user=nil)
+    @issue = issue 
+    @notes = params[:notes]
+    @parent_id = params[:parent_id]
+    @reply_id = params[:reply_id]
+    @attachment_ids = params[:attachment_ids]
+    @receivers_login = params[:receivers_login]
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid?
+    raise Error, "请输入回复的评论ID" if parent_id.present? && !reply_id.present?
+    ActiveRecord::Base.transaction do 
+      check_parent_journal(parent_id) if parent_id.present? 
+      check_parent_journal(reply_id) if reply_id.present? 
+      check_attachments(attachment_ids) unless attachment_ids.nil?
+      check_atme_receivers(receivers_login) unless receivers_login.nil?
+      load_attachments(attachment_ids) unless attachment_ids.nil?
+      load_atme_receivers(receivers_login) unless receivers_login.nil?
+
+      try_lock("Api::V1::Issues::Journals::CreateService:#{@issue.id}")
+      @created_journal = @issue.journals.new(journal_attributes)
+
+      build_comment_participants 
+      build_atme_participants if @atme_receivers.present?
+      @created_journal.attachments = @attachments unless attachment_ids.blank?
+      
+      @created_journal.save!
+      @issue.save!
+
+      # @信息发送
+      AtmeService.call(current_user, @atme_receivers, @created_journal) unless receivers_login.blank?
+
+      unlock("Api::V1::Issues::Journals::CreateService:#{@issue.id}")
+
+      @created_journal
+    end
+  end 
+
+  private 
+
+  def journal_attributes 
+    journal_attributes = {
+      notes: notes,
+      user_id: current_user.id
+    }
+
+    journal_attributes.merge!({parent_id: parent_id}) if parent_id.present?
+    journal_attributes.merge!({reply_id: reply_id}) if reply_id.present?
+    
+    journal_attributes
+  end
+
+  def build_comment_participants
+    @issue.issue_participants.new({participant_type: "commented", participant_id: current_user.id}) unless @issue.issue_participants.exists?(participant_type: "commented", participant_id: current_user.id)
+  end
+
+  def build_atme_participants
+    @atme_receivers.each do |receiver|
+      next if @issue.issue_participants.exists?(participant_type: "atme", participant_id: receiver.id)
+      @issue.issue_participants.new({participant_type: "atme", participant_id: receiver.id})
+    end
+  end
+end

app/services/api/v1/issues/journals/list_service.rb

@@ -0,0 +1,52 @@
+class Api::V1::Issues::Journals::ListService < ApplicationService
+
+  include ActiveModel::Model
+
+  attr_reader :issue, :category, :keyword, :sort_by, :sort_direction
+  attr_accessor :queried_journals
+
+  validates :category, inclusion: {in: %w(all comment operate), message: "请输入正确的Category"}
+  validates :sort_by, inclusion: {in: Journal.column_names, message: '请输入正确的SortBy'}, allow_blank: true
+  validates :sort_direction, inclusion: {in: %w(asc desc), message: '请输入正确的SortDirection'}, allow_blank: true
+
+  def initialize(issue, params, current_user=nil)
+    @issue = issue
+    @keyword = params[:keyword]
+    @category = params[:category] || 'all'
+    @sort_by = params[:sort_by].present? ?  params[:sort_by] : 'created_on'
+    @sort_direction = (params[:sort_direction].present? ? params[:sort_direction] : 'asc').downcase
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    begin
+      journal_query_data
+      
+      @queried_journals
+    rescue 
+      raise Error, "服务器错误，请联系系统管理员！"
+    end
+  end
+
+  private 
+  def journal_query_data
+
+    @queried_journals = issue.journals
+
+    case category 
+    when 'comment'
+      @queried_journals = issue.comment_journals
+    when 'operate'
+      @queried_journals = issue.operate_journals
+    end
+
+    @queried_journals = @queried_journals.parent_journals
+
+    @queried_journals = @queried_journals.ransack(notes_cont: keyword).result if keyword.present?
+
+    @queried_journals = @queried_journals.includes(:journal_details, :user, :attachments, first_ten_children_journals: [:parent_journal, :reply_journal])
+    @queried_journals = @queried_journals.reorder("journals.#{sort_by} #{sort_direction}").distinct
+
+    @queried_journals
+  end
+end

app/services/api/v1/issues/journals/update_service.rb

@@ -0,0 +1,57 @@
+class Api::V1::Issues::Journals::UpdateService < ApplicationService 
+  include ActiveModel::Model
+  include Api::V1::Issues::Concerns::Checkable 
+  include Api::V1::Issues::Concerns::Loadable 
+
+  attr_reader :issue, :journal, :current_user, :notes, :attachment_ids, :receivers_login
+  attr_accessor :updated_journal, :atme_receivers
+
+  validates :notes, :issue, :journal, :current_user, presence: true
+
+  def initialize(issue, journal, params, current_user=nil)
+    @issue = issue
+    @journal = journal
+    @notes = params[:notes]
+    @attachment_ids = params[:attachment_ids]
+    @receivers_login = params[:receivers_login]
+    @current_user = current_user 
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid?
+    ActiveRecord::Base.transaction do 
+      check_attachments(attachment_ids) unless attachment_ids.nil?
+      check_atme_receivers(receivers_login) unless receivers_login.nil?
+      load_attachments(attachment_ids) unless attachment_ids.nil?
+      load_atme_receivers(receivers_login) unless receivers_login.nil?
+
+      try_lock("Api::V1::Issues::Journals::UpdateService:#{@issue.id}:#{@journal.id}")
+      @updated_journal = @journal
+      @updated_journal.notes = notes
+
+      build_atme_participants if @atme_receivers.present?
+
+      @updated_journal.attachments = @attachments unless attachment_ids.nil?
+      
+      @updated_journal.save!
+      @issue.save!
+
+      # @信息发送
+      AtmeService.call(current_user, @atme_receivers, @created_journal) unless receivers_login.blank?
+
+      unlock("Api::V1::Issues::Journals::UpdateService:#{@issue.id}:#{@journal.id}")
+
+      @updated_journal
+    end
+  end
+
+  private 
+
+  def build_atme_participants
+    @atme_receivers.each do |receiver|
+      next if @issue.issue_participants.exists?(participant_type: "atme", participant_id: receiver.id)
+      @issue.issue_participants.new({participant_type: "atme", participant_id: receiver.id})
+    end
+  end
+
+end

app/services/api/v1/issues/list_service.rb

@@ -0,0 +1,91 @@
+class Api::V1::Issues::ListService < ApplicationService
+  include ActiveModel::Model
+
+  attr_reader :project, :category, :participant_category, :keyword, :author_id, :issue_tag_ids
+  attr_reader :milestone_id, :assigner_id, :status_id, :sort_by, :sort_direction, :current_user
+  attr_accessor :queried_issues, :total_issues_count, :closed_issues_count, :opened_issues_count
+
+  validates :category, inclusion: {in: %w(all opened closed), message: "请输入正确的Category"}
+  validates :participant_category, inclusion: {in: %w(all aboutme authoredme assignedme atme), message: "请输入正确的ParticipantCategory"}
+  validates :sort_by, inclusion: {in: ['issues.created_on', 'issues.updated_on', 'issue_priorities.position'], message: '请输入正确的SortBy'}, allow_blank: true
+  validates :sort_direction, inclusion: {in: %w(asc desc), message: '请输入正确的SortDirection'}, allow_blank: true
+  validates :current_user, presence: true
+
+  def initialize(project, params, current_user=nil)
+    @project = project
+    @category = params[:category] || 'all'
+    @participant_category = params[:participant_category] || 'all'
+    @keyword = params[:keyword]
+    @author_id = params[:author_id]
+    @issue_tag_ids = params[:issue_tag_ids].present? ? params[:issue_tag_ids].split(",") : []
+    @milestone_id = params[:milestone_id]
+    @assigner_id = params[:assigner_id]
+    @status_id = params[:status_id]
+    @sort_by = params[:sort_by].present? ?  params[:sort_by] : 'issues.updated_on'
+    @sort_direction = (params[:sort_direction].present? ? params[:sort_direction] : 'desc').downcase
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    # begin
+      issue_query_data
+
+      return {data: queried_issues, total_issues_count: @total_issues_count, closed_issues_count: @closed_issues_count, opened_issues_count: @opened_issues_count}
+    # rescue 
+    #   raise Error, "服务器错误，请联系系统管理员！"
+    # end
+  end
+
+  private 
+  def issue_query_data 
+    issues = @project.issues.issue_issue
+
+    case participant_category
+    when 'aboutme' # 关于我的
+      issues = issues.joins(:issue_participants).where(issue_participants: {participant_type: %w(authored assigned atme), participant_id: current_user&.id})
+    when 'authoredme' # 我创建的
+      issues = issues.joins(:issue_participants).where(issue_participants: {participant_type: 'authored', participant_id: current_user&.id})
+    when 'assignedme' # 我负责的
+      issues = issues.joins(:issue_participants).where(issue_participants: {participant_type: 'assigned', participant_id: current_user&.id})
+    when 'atme' # @我的
+      issues = issues.joins(:issue_participants).where(issue_participants: {participant_type: 'atme', participant_id: current_user&.id})
+    end
+
+    # author_id
+    issues = issues.where(author_id: author_id) if author_id.present?
+
+    # issue_tag_ids
+    issues = issues.ransack(issue_tags_value_cont: issue_tag_ids.sort!.join(",")).result unless issue_tag_ids.blank?
+    
+    # milestone_id
+    issues = issues.where(fixed_version_id: milestone_id) if milestone_id.present?
+
+    # assigner_id
+    issues = issues.joins(:assigners).where(users: {id: assigner_id}) if assigner_id.present?
+
+    # status_id
+    issues = issues.where(status_id: status_id) if status_id.present?
+
+    # keyword
+    issues = issues.ransack(subject_or_description_cont: keyword).result if keyword.present?
+
+    @total_issues_count = issues.distinct.size
+    @closed_issues_count = issues.closed.distinct.size 
+    @opened_issues_count = issues.opened.distinct.size
+
+    case category 
+    when 'closed'
+      issues = issues.closed
+    when 'opened'
+      issues = issues.opened
+    end
+
+    scope = issues.includes(:priority, :issue_status, :user, :show_assigners, :show_issue_tags, :version, :comment_journals)
+
+    scope = scope.reorder("#{sort_by} #{sort_direction}").distinct
+
+    @queried_issues = scope
+  end
+
+end

app/services/api/v1/issues/milestones/detail_issues_service.rb

@@ -0,0 +1,65 @@
+class Api::V1::Issues::Milestones::DetailIssuesService < ApplicationService 
+  include ActiveModel::Model
+
+  attr_reader :project, :category, :author_id, :assigner_id, :issue_tag_ids, :sort_by, :sort_direction, :current_user
+  attr_accessor :queried_issues, :total_issues_count, :closed_issues_count, :opened_issues_count
+
+  validates :category, inclusion: {in: %w(all opened closed), message: "请输入正确的Category"}
+  validates :sort_by, inclusion: {in: ['issues.created_on', 'issues.updated_on', 'issue_priorities.position'], message: '请输入正确的SortBy'}, allow_blank: true
+  validates :sort_direction, inclusion: {in: %w(asc desc), message: '请输入正确的SortDirection'}, allow_blank: true
+  validates :current_user, presence: true
+
+  def initialize(project, milestone, params, current_user=nil)
+    @project = project 
+    @milestone = milestone
+    @category = params[:category] || 'all'
+    @author_id = params[:author_id]
+    @assigner_id = params[:assigner_id]
+    @issue_tag_ids = params[:issue_tag_ids].present? ? params[:issue_tag_ids].split(",") : []
+    @sort_by = params[:sort_by].present? ?  params[:sort_by] : 'issues.updated_on'
+    @sort_direction = (params[:sort_direction].present? ? params[:sort_direction] : 'desc').downcase
+    @current_user = current_user
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    begin
+      issue_query_data 
+
+      return {data: queried_issues, total_issues_count: @total_issues_count, closed_issues_count: @closed_issues_count, opened_issues_count: @opened_issues_count}
+    rescue
+      raise Error, "服务器错误，请联系系统管理员！"
+    end
+  end
+
+  private 
+  def issue_query_data
+    issues = @milestone.issues.issue_issue
+
+    # author_id 
+    issues = issues.where(author_id: author_id) if author_id.present? 
+
+    # assigner_id 
+    issues = issues.joins(:assigners).where(users: {id: assigner_id}).or(issues.joins(:assigners).where(assigned_to_id: assigner_id)) if assigner_id.present? 
+
+    issues = issues.ransack(issue_tags_value_cont: issue_tag_ids.sort!.join(",")).result unless issue_tag_ids.blank?
+
+    @total_issues_count = issues.distinct.size
+    @closed_issues_count = issues.closed.distinct.size 
+    @opened_issues_count = issues.opened.distinct.size
+
+    case category 
+    when 'closed'
+      issues = issues.closed 
+    when 'opened'
+      issues = issues.opened
+    end
+
+    scope = issues.includes(:priority, :issue_status, :user, :show_assigners, :version, :show_issue_tags, :comment_journals).references(:assigners)
+
+    scope = scope.reorder("#{sort_by} #{sort_direction}").distinct
+
+    @queried_issues = scope
+  end
+
+end

app/services/api/v1/issues/update_service.rb

@@ -0,0 +1,240 @@
+class Api::V1::Issues::UpdateService < ApplicationService
+  include ActiveModel::Model 
+  include Api::V1::Issues::Concerns::Checkable 
+  include Api::V1::Issues::Concerns::Loadable 
+
+  attr_reader :project, :issue, :current_user
+  attr_reader :status_id, :priority_id, :milestone_id, :branch_name, :start_date, :due_date, :subject, :description
+  attr_reader :issue_tag_ids, :assigner_ids, :attachment_ids, :receivers_login
+  attr_accessor :add_assigner_ids, :previous_issue_changes, :updated_issue, :atme_receivers
+
+  validates :project, :issue, :current_user, presence: true
+
+  def initialize(project, issue, params, current_user = nil) 
+    @project = project 
+    @issue = issue
+    @current_user = current_user
+    @status_id = params[:status_id]
+    @priority_id = params[:priority_id]
+    @milestone_id = params[:milestone_id]
+    @branch_name = params[:branch_name]
+    @start_date = params[:start_date]
+    @due_date = params[:due_date]
+    @subject = params[:subject]
+    @description = params[:description]
+    @issue_tag_ids = params[:issue_tag_ids]
+    @assigner_ids = params[:assigner_ids]
+    @attachment_ids = params[:attachment_ids]
+    @receivers_login = params[:receivers_login]
+    @add_assigner_ids = []
+    @previous_issue_changes = {}
+  end
+
+  def call 
+    raise Error, errors.full_messages.join(", ") unless valid? 
+    ActiveRecord::Base.transaction do 
+      check_issue_status(status_id) if status_id.present?
+      check_issue_priority(priority_id) if priority_id.present?
+      check_milestone(milestone_id) if milestone_id.present?
+      check_issue_tags(issue_tag_ids) unless issue_tag_ids.nil?
+      check_assigners(assigner_ids) unless assigner_ids.nil?
+      check_attachments(attachment_ids) unless attachment_ids.nil?
+      check_atme_receivers(receivers_login) unless receivers_login.nil?
+      load_assigners(assigner_ids)
+      load_attachments(attachment_ids)
+      load_issue_tags(issue_tag_ids)
+      load_atme_receivers(receivers_login) unless receivers_login.nil?
+
+      try_lock("Api::V1::Issues::UpdateService:#{project.id}:#{issue.id}")
+      @updated_issue = @issue
+      issue_load_attributes
+      build_assigner_issue_journal_details unless assigner_ids.nil?# 操作记录
+      build_attachment_issue_journal_details unless attachment_ids.nil?
+      build_issue_tag_issue_journal_details unless issue_tag_ids.nil?
+      build_issue_project_trends if status_id.present? # 开关时间记录
+      build_assigner_participants unless assigner_ids.nil? # 负责人
+      build_edit_participants 
+      build_atme_participants if @atme_receivers.present?
+      @updated_issue.assigners = @assigners || User.none unless assigner_ids.nil?
+      @updated_issue.attachments = @attachments || Attachment.none unless attachment_ids.nil?
+      @updated_issue.issue_tags_relates.destroy_all & @updated_issue.issue_tags = @issue_tags || IssueTag.none unless issue_tag_ids.nil?
+      @updated_issue.issue_tags_value = @issue_tags.order("id asc").pluck(:id).join(",") unless issue_tag_ids.nil?
+
+      @updated_issue.updated_on = Time.now
+      @updated_issue.save!
+
+      build_after_issue_journal_details if @updated_issue.previous_changes.present? # 操作记录
+      build_previous_issue_changes
+
+      # @信息发送
+      AtmeService.call(current_user, @atme_receivers, @issue) unless receivers_login.blank?
+      # 消息发送
+      if Site.has_notice_menu?
+        SendTemplateMessageJob.perform_later('IssueChanged', current_user.id, @issue&.id, previous_issue_changes) unless previous_issue_changes.blank?
+        SendTemplateMessageJob.perform_later('IssueAssigned', current_user.id, @issue&.id, add_assigner_ids) unless add_assigner_ids.blank?
+      end
+
+      unlock("Api::V1::Issues::UpdateService:#{project.id}:#{issue.id}")
+
+      return @updated_issue
+    end
+  end
+ 
+  private
+
+  def issue_load_attributes 
+    @updated_issue.status_id = status_id if status_id.present?
+    @updated_issue.priority_id = priority_id if priority_id.present?
+    @updated_issue.fixed_version_id = milestone_id unless milestone_id.nil? 
+    @updated_issue.branch_name = branch_name unless branch_name.nil?
+    @updated_issue.start_date = start_date unless start_date.nil? 
+    @updated_issue.due_date = due_date unless due_date.nil? 
+    @updated_issue.subject = subject if subject.present? 
+    @updated_issue.description = description unless description.nil?
+  end
+
+  def build_assigner_participants
+    if assigner_ids.blank? 
+      @updated_issue.issue_participants.where(participant_type: "assigned").each(&:destroy!)
+    else
+      @updated_issue.issue_participants.where(participant_type: "assigned").where.not(participant_id: assigner_ids).each(&:destroy!)
+      assigner_ids.each do |aid|
+        next if @updated_issue.issue_participants.exists?(participant_type: "assigned", participant_id: aid)
+        @updated_issue.issue_participants.new({participant_type: "assigned", participant_id: aid})
+        @add_assigner_ids << aid
+      end
+    end
+  end
+
+  def build_edit_participants 
+    @updated_issue.issue_participants.new({participant_type: "edited", participant_id: current_user.id}) unless @updated_issue.issue_participants.exists?(participant_type: "edited", participant_id: current_user.id)
+  end
+
+  def build_atme_participants
+    @atme_receivers.each do |receiver|
+      next if @updated_issue.issue_participants.exists?(participant_type: "atme", participant_id: receiver.id)
+      @updated_issue.issue_participants.new({participant_type: "atme", participant_id: receiver.id})
+    end
+  end
+
+  def build_previous_issue_changes
+    @previous_issue_changes = @updated_issue.previous_changes.except("updated_on", "created_on")
+    if @updated_issue.previous_changes["start_date"].present? 
+      @previous_issue_changes.merge!(start_date: [@updated_issue.previous_changes["start_date"][0].to_s,  @updated_issue.previous_changes["start_date"][1].to_s])
+    end
+    if @updated_issue.previous_changes["due_date"].present? 
+      @previous_issue_changes.merge!(due_date: [@updated_issue.previous_changes["due_date"][0].to_s,  @updated_issue.previous_changes["due_date"][1].to_s])
+    end
+  end
+
+  def build_issue_project_trends
+    if @updated_issue.previous_changes["status_id"].present? && @updated_issue.previous_changes["status_id"][1] == 5
+      @updated_issue.project_trends.new({user_id: current_user.id, project_id: @project.id, action_type: ProjectTrend::CLOSE})
+    end
+    if @updated_issue.previous_changes["status_id"].present? && @updated_issue.previous_changes["status_id"][0] == 5
+      @updated_issue.project_trends.where(action_type: ProjectTrend::CLOSE).each(&:destroy!)
+    end
+  end
+
+  def build_after_issue_journal_details
+    begin
+      # 更改标题
+      if @updated_issue.previous_changes["subject"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "subject", old_value: @updated_issue.previous_changes["subject"][0], value: @updated_issue.previous_changes["subject"][1]})
+      end
+
+      # 更改描述
+      if @updated_issue.previous_changes["description"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "description", old_value: @updated_issue.previous_changes["description"][0], value: @updated_issue.previous_changes["description"][1]})
+      end
+
+      # 修改状态
+      if @updated_issue.previous_changes["status_id"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "status_id", old_value: @updated_issue.previous_changes["status_id"][0], value: @updated_issue.previous_changes["status_id"][1]})
+      end
+
+      # 修改优先级
+      if @updated_issue.previous_changes["priority_id"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "priority_id", old_value: @updated_issue.previous_changes["priority_id"][0], value: @updated_issue.previous_changes["priority_id"][1]})
+      end
+
+      # 修改里程碑
+      if @updated_issue.previous_changes["fixed_version_id"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "fixed_version_id", old_value: @updated_issue.previous_changes["fixed_version_id"][0], value: @updated_issue.previous_changes["fixed_version_id"][1]})
+      end
+
+      # 更改分支
+      if @updated_issue.previous_changes["branch_name"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "branch_name", old_value: @updated_issue.previous_changes["branch_name"][0], value: @updated_issue.previous_changes["branch_name"][1]})
+      end
+
+      # 更改开始时间
+      if @updated_issue.previous_changes["start_date"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "start_date", old_value: @updated_issue.previous_changes["start_date"][0], value: @updated_issue.previous_changes["start_date"][1]})
+      end
+
+      # 更改结束时间
+      if @updated_issue.previous_changes["due_date"].present?
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attr", prop_key: "due_date", old_value: @updated_issue.previous_changes["due_date"][0], value: @updated_issue.previous_changes["due_date"][1]})
+      end
+    rescue
+      raise Error, "创建操作记录失败!"
+    end
+  end
+
+  def build_assigner_issue_journal_details
+    begin
+      # 更改负责人
+      new_assigner_ids = @assigner_ids
+      new_assigner_ids = [] if @assigner_ids.nil?
+      now_assigner_ids = @updated_issue.assigners.pluck(:id)
+      if !(now_assigner_ids & assigner_ids).empty? || !(now_assigner_ids.empty? && new_assigner_ids.empty?)
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "assigner", prop_key: "#{new_assigner_ids.size}", old_value: now_assigner_ids.join(","), value: new_assigner_ids.join(",")})
+      end
+
+    rescue
+      raise Error, "创建操作记录失败!"
+    end
+  end
+
+  def build_issue_tag_issue_journal_details
+    begin
+      # 更改标记
+      new_issue_tag_ids = @issue_tag_ids
+      new_issue_tag_ids = [] if @issue_tag_ids.nil?
+      now_issue_tag_ids = @updated_issue.issue_tags.pluck(:id)
+      if !(now_issue_tag_ids & new_issue_tag_ids).empty? || !(now_issue_tag_ids.empty? && new_issue_tag_ids.empty?)
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "issue_tag", prop_key: "#{new_issue_tag_ids.size}", old_value: now_issue_tag_ids.join(","), value: new_issue_tag_ids.join(",")})
+      end
+    rescue
+      raise Error, "创建操作记录失败!"
+    end
+  end
+
+
+  def build_attachment_issue_journal_details
+    begin
+      # 更改附件
+      new_attachment_ids = @attachment_ids
+      new_attachment_ids = [] if @attachment_ids.nil?
+      now_attachment_ids = @updated_issue.attachments.pluck(:id)
+      if !(now_attachment_ids & new_attachment_ids).empty? || !(now_attachment_ids.empty? && new_attachment_ids.empty?)
+        journal = @updated_issue.journals.create!({user_id: current_user.id})
+        journal.journal_details.create!({property: "attachment", prop_key: "#{new_attachment_ids.size}", old_value: now_attachment_ids.join(","), value: new_attachment_ids.join(",")})
+      end
+    rescue
+      raise Error, "创建操作记录失败!"
+    end
+  end
+ 
+end