240 lines
12 KiB
Ruby
240 lines
12 KiB
Ruby
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 |