add: applied join project

This commit is contained in:
2021-06-09 16:53:09 +08:00
parent d4b8b3e24f
commit 5489ea9fbc
32 changed files with 1497 additions and 132 deletions

View File

@@ -0,0 +1,61 @@
class Projects::AcceptJoinService < ApplicationService
attr_accessor :applied_project, :owner
attr_reader :user, :project
def initialize(user, applied_project)
@user = user
@project = applied_project.project
@applied_project = applied_project
end
def call
Rails.logger.info("###### Project accept_join_service begin ######")
ActiveRecord::Base.transaction do
validate!
update_apply
operate_project_member
send_apply_message
end
Rails.logger.info("##### Project accept_join_service end ######")
return @applied_project
end
private
def permission
case @applied_project.role
when 'manager'
'admin'
when 'developer'
'write'
when 'reporter'
'read'
else
'read'
end
end
def validate!
raise Error, '该申请已经被接受' if @applied_project.accepted?
raise Error, '该申请不存在' unless @applied_project.present?
raise Error, '未拥有接受申请权限' unless is_permit_operator
end
def is_permit_operator
return @user.admin? || @project.manager?(@user)
end
def update_apply
@applied_project.update!(status: 'accepted')
end
def operate_project_member
Projects::AddMemberInteractor.call(@project.owner, @project, @user, permission)
end
def send_apply_message
SendJoinProjectAppliedMessageJob.perform_now(@applied_project, @user, 'successed')
end
end

View File

@@ -9,26 +9,25 @@ class Projects::ApplyJoinService < ApplicationService
end
def call
validate!
# 项目报告人员直接加入项目
if params[:role] == 'reporter'
# Projects::JoinService.call(project, user, role: 'reporter')
return project
end
# if params[:role] == 'reporter'
# # Projects::JoinService.call(project, user, role: 'reporter')
# return project
# end
ActiveRecord::Base.transaction do
validate!
apply = user.applied_projects.create!(project: project, role: role_value)
apply
# apply.forge_activities.find_or_create_by!(user: user, project: project)
apply.forge_activities.find_or_create_by!(user: user, project: project)
notify_project_manager!(apply)
# notify_project_manager!(apply)
end
# notify_project_owner
ApplyJoinProjectNotifyJob.perform_later(user.id, project.id, role_value)
# ApplyJoinProjectNotifyJob.perform_later(user.id, project.id, role_value)
project
end
private
@@ -43,7 +42,8 @@ class Projects::ApplyJoinService < ApplicationService
when 'manager' then 3
when 'developer' then 4
when 'reporter' then 5
else raise Error, '角色无效'
else
5
end
end
@@ -74,12 +74,18 @@ class Projects::ApplyJoinService < ApplicationService
def validate!
# params check
raise Error, '邀请码不能为空' if params[:code].blank?
raise Error, '角色不能为空' if params[:role].blank?
raise Error, '角色无效' unless %w(manager developer reporter).include?(params[:role])
raise Error, '请输入6位项目邀请码' unless valid_invite_code( params[:code])
# logical check
raise Error, '邀请码无效' if project.blank?
raise Error, '您已在该项目中' if project.member?(user)
raise Error, '您已经提交过申请' if user.applied_projects.pending.exists?(project: project)
raise Error, '您已是项目成员' if project.member?(user)
raise Error, '您已经提交过申请' if user.applied_projects.common.exists?(project: project)
end
def valid_invite_code(str)
if (str =~ /^[A-Za-z0-9]{6}+$/)
return true
end
return false
end
end

View File

@@ -0,0 +1,39 @@
class Projects::RefuseJoinService < ApplicationService
attr_accessor :applied_project, :owner
attr_reader :user, :project
def initialize(user, applied_project)
@user = user
@project = applied_project.project
@applied_project = applied_project
end
def call
Rails.logger.info("###### Project refuse_join_service begin ######")
validate!
update_apply
send_apply_message
Rails.logger.info("###### Project refuse_join_service end ######")
return @applied_project
end
private
def validate!
raise Error, '该申请已被拒绝' if @applied_project.refused?
raise Error, '该申请不存在' unless @applied_project.present?
raise Error, '未拥有接受申请权限' unless is_permit_operator
end
def is_permit_operator
return @user.admin? || @project.manager?(@user)
end
def update_apply
@applied_project.update!(status: 'refused')
end
def send_apply_message
SendJoinProjectAppliedMessageJob.perform_now(@applied_project, @user, 'failure')
end
end