lywsvip/codefever
1
0
Fork 0
mirror of https://github.com/PGYER/codefever.git synced 2026-05-07 05:57:30 +08:00
Code Issues Packages Projects Releases Wiki Activity
Files
49473b851148c559ad3ec4f0673e617a15c74436
codefever/application/event_handlers/UserNotificationHandler.php

373 lines
16 KiB
PHP
Executable File
Raw Blame History

<?php
namespace service\EventHandler;
use service\Event\Event;
use service\Constant\EventType;
use service\Utility\MessageGenerator;
use service\AccessControl\UserAccessController;
use service\Utility\Helper;
use service\MessageService\Email\EmailSender;
class UserNotificationHandler extends EventHandler {
protected $ListenedEventList = [
EventType::MERGE_REQUEST_CREATE,
EventType::MERGE_REQUEST_CLOSE,
EventType::MERGE_REQUEST_MERGE,
EventType::MERGE_REQUEST_REVIEWER_CREATE,
EventType::MERGE_REQUEST_REVIEWER_REVIEW
];
protected $messageTemplate = [
LANG_CN => [
EventType::MERGE_REQUEST_CREATE => [
'mailTitle' => '{{$user@users:u_name}} 打开了和并请求',
'mailBody' => '{{$user@users:u_name}} 打开了和并请求: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_CLOSE => [
'mailTitle' => '{{$user@users:u_name}} 关闭了和并请求',
'mailBody' => '{{$user@users:u_name}} 关闭了和并请求: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_MERGE => [
'mailTitle' => '{{$user@users:u_name}} 合并了和并请求',
'mailBody' => '{{$user@users:u_name}} 合并了和并请求: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_REVIEWER_CREATE => [
'mailTitle' => '和并请求评审',
'mailBody' => '{{$user@users:u_name}} 指定你为和并请求 {{$data->rKey@repositories:r_name}}!{{$data->id}} 的评审员',
],
EventType::MERGE_REQUEST_REVIEWER_REVIEW => [
'mailTitle' => '和并请求评审',
'mailBody' => '{{$user@users:u_name}} 通过了和并请求 {{$data->rKey@repositories:r_name}}!{{$data->id}} 的评审',
]
],
LANG_EN => [
EventType::MERGE_REQUEST_CREATE => [
'mailTitle' => '{{$user@users:u_name}} Open Merge Request',
'mailBody' => '{{$user@users:u_name}} Open Merge Request: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_CLOSE => [
'mailTitle' => '{{$user@users:u_name}} Close Merge Request',
'mailBody' => '{{$user@users:u_name}} Close Merge Request: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_MERGE => [
'mailTitle' => '{{$user@users:u_name}} Merge The Merge Request',
'mailBody' => '{{$user@users:u_name}} Merge The Merge Request: {{$data->sourceGKey@groups:g_name}}/{{$data->sourceRKey@repositories:r_name}}/{{$data->sourceBranch}} -> {{$data->gKey@groups:g_name}}/{{$data->rKey@repositories:r_name}}/{{$data->targetBranch}}',
],
EventType::MERGE_REQUEST_REVIEWER_CREATE => [
'mailTitle' => 'Merge Request Review',
'mailBody' => '{{$user@users:u_name}} Designates You As A Reviewer For Merge Request {{$data->rKey@repositories:r_name}}!{{$data->id}}',
],
EventType::MERGE_REQUEST_REVIEWER_REVIEW => [
'mailTitle' => 'Merge Request Review',
'mailBody' => '{{$user@users:u_name}} Passed Review Of Merge Request {{$data->rKey@repositories:r_name}}!{{$data->id}}',
]
]
];
protected $messageFieldData = [
EventType::MERGE_REQUEST_CREATE => [
'cueOption' => ['members'],
'internalData' => [
'user' => '{{$user@users:u_name}}',
'group' => '{{$data->gKey@groups:g_name}}',
'repository' => '{{$data->rKey@repositories:r_name}}',
'sourceRepository' => '{{$data->sourceRKey@repositories:r_name}}',
'sourceBranch' => '{{$data->sourceBranch}}',
'targetBranch' => '{{$data->targetBranch}}',
'number' => '{{$data->id}}',
'title' => '{{$data->mrKey@merge_requests:mr_title}}',
'description' => '{{$data->mrKey@merge_requests:mr_description}}',
'created' => '{{$data->mrKey@merge_requests:mr_created}}'
]
],
EventType::MERGE_REQUEST_CLOSE => [
'cueOption' => ['members'],
'internalData' => [
'user' => '{{$user@users:u_name}}',
'group' => '{{$data->gKey@groups:g_name}}',
'repository' => '{{$data->rKey@repositories:r_name}}',
'sourceRepository' => '{{$data->sourceRKey@repositories:r_name}}',
'sourceBranch' => '{{$data->sourceBranch}}',
'targetBranch' => '{{$data->targetBranch}}',
'number' => '{{$data->id}}',
'title' => '{{$data->mrKey@merge_requests:mr_title}}',
'description' => '{{$data->mrKey@merge_requests:mr_description}}',
'closed' => '{{$data->mrKey@merge_requests:mr_close_time}}'
]
],
EventType::MERGE_REQUEST_MERGE => [
'cueOption' => ['members'],
'internalData' => [
'user' => '{{$user@users:u_name}}',
'group' => '{{$data->gKey@groups:g_name}}',
'repository' => '{{$data->rKey@repositories:r_name}}',
'sourceRepository' => '{{$data->sourceRKey@repositories:r_name}}',
'sourceBranch' => '{{$data->sourceBranch}}',
'targetBranch' => '{{$data->targetBranch}}',
'number' => '{{$data->id}}',
'title' => '{{$data->mrKey@merge_requests:mr_title}}',
'description' => '{{$data->mrKey@merge_requests:mr_description}}',
'merged' => '{{$data->mrKey@merge_requests:mr_merge_time}}'
]
],
EventType::MERGE_REQUEST_REVIEWER_CREATE => [
'cueOption' => ['reviewer'],
'internalData' => [
'user' => '{{$user@users:u_name}}',
'reviewer' => '{{$data->reviewer@users:u_name}}',
'group' => '{{$data->gKey@groups:g_name}}',
'repository' => '{{$data->rKey@repositories:r_name}}',
'number' => '{{$data->id}}',
'title' => '{{$data->mrKey@merge_requests:mr_title}}',
'created' => '{{$data->mrrKey@merge_request_reviewers:mrr_created}}'
]
],
EventType::MERGE_REQUEST_REVIEWER_REVIEW => [
'cueOption' => ['members'],
'internalData' => [
'user' => '{{$user@users:u_name}}',
'reviewer' => '{{$data->reviewer@users:u_name}}',
'group' => '{{$data->gKey@groups:g_name}}',
'repository' => '{{$data->rKey@repositories:r_name}}',
'number' => '{{$data->id}}',
'title' => '{{$data->mrKey@merge_requests:mr_title}}'
]
]
];
public function capture(Event $event)
{
$eventType = $event->type;
if (!in_array($eventType, $this->ListenedEventList)) {
return FAlSE;
}
$notifyMessageSet = array_merge($this->messageTemplate[$event->language][$eventType], $this->messageFieldData[$eventType]);
$affectedUsers = $this->getAffectedUsers($event, $notifyMessageSet['cueOption']);
$messageData = $this->composeMessageData($event, $notifyMessageSet);
if (is_array($affectedUsers) && count($affectedUsers)) {
// $this->sendMail($event, $messageData, $affectedUsers);
$this->addWebSiteMessage($event, $messageData, $affectedUsers);
// $this->sendSms($event, $messageData, $affectedUsers, $projectInfo['p_key']);
// $this->sendWXMessage($event, $messageData, $affectedUsers, $projectInfo['p_key'], $messageData['i_no'], $projectInfo['p_name'], $messageData['i_status_text']);
// $this->addBrowserNotification($event, $messageData, $affectedUsers, $projectInfo['p_key']);
}
}
public function getAffectedUsers(Event $event, array $cueOption)
{
if (count($cueOption) == 0) {
return FALSE;
}
$affectedUsers = MessageGenerator::fetchUserList($cueOption, $event);
$affectedUsers = $this->filterOtherRule($affectedUsers, $event);
$affectedUsers = $this->filterProjectNotificationSetting($affectedUsers, $event);
$affectedUsers = $this->filterUserNotificationSetting($affectedUsers, $event);
return $affectedUsers;
}
// 根据用户对组或仓库的通知设置过滤
protected function filterProjectNotificationSetting(array $affectedUsers, Event $event)
{
$this->CI->load->model('Notification_model', 'notificationModel');
$result = [];
foreach ($affectedUsers as $user) {
// check group
if ($this->CI->notificationModel->isNotificationRefusedExists(
$user['u_key'],
NOTIFICATION_REFUSE_GROUP,
$event->data->gKey)) {
continue;
}
// check repository
if ($this->CI->notificationModel->isNotificationRefusedExists(
$user['u_key'],
NOTIFICATION_REFUSE_REPOSITORY,
$event->data->rKey)) {
continue;
}
array_push($result, $user);
}
return $result;
}
protected function filterOtherRule(array $affectedUsers, Event $event)
{
$result = [];
if ($event->type == EventType::MERGE_REQUEST_REVIEWER_REVIEW) {
foreach ($affectedUsers as $user) {
if ($user['role'] > UserAccessController::ROLE_DEVELOPER) {
array_push($result, $user);
}
}
} else if (in_array($event->type, [
EventType::MERGE_REQUEST_CREATE,
EventType::MERGE_REQUEST_CLOSE,
EventType::MERGE_REQUEST_MERGE
])) {
if ($event->type == EventType::MERGE_REQUEST_CREATE && $event->data->reviewers) {
$affectedUsers = [];
}
foreach ($affectedUsers as $user) {
if ($user['role'] > UserAccessController::ROLE_REPORTER) {
array_push($result, $user);
}
}
} else if ($event->type == EventType::MERGE_REQUEST_REVIEWER_CREATE) {
$result = $affectedUsers;
}
return $result;
}
// 根据用户设置过滤 u_notification_status 字段
protected function filterUserNotificationSetting(array $affectedUsers, Event $event)
{
$result = [
'email' => [],
'internal' => []
];
foreach ($affectedUsers as $user) {
// check merge request event type
if (in_array($event->type, [
EventType::MERGE_REQUEST_CREATE,
EventType::MERGE_REQUEST_CLOSE,
EventType::MERGE_REQUEST_MERGE,
EventType::MERGE_REQUEST_REVIEWER_CREATE,
EventType::MERGE_REQUEST_REVIEWER_REVIEW
])) {
if (($user['u_notification_status'] >> (NOTIFICATION_STATUS_MR - 1) & 1) === 1) {
continue;
}
} else if (false) {
// other event type
}
array_push($result['internal'], $user);
// check email notification status
if (($user['u_notification_status'] >> (NOTIFICATION_STATUS_EMAIL - 1) & 1) === 0) {
array_push($result['email'], $user['u_email']);
}
}
return $result;
}
protected function composeMessageData(Event $event, array $messageSet)
{
if (!$messageSet) {
return FALSE;
}
if (isset($messageSet['cueOption'])) {
unset($messageSet['cueOption']);
}
$messageSet['internalData'] = $this->toInternalData($messageSet['internalData']);
$delimiter = Helper::getDelimiter() . Helper::getDelimiter();
$template = implode($delimiter, array_values($messageSet));
$tmpData = MessageGenerator::getMessageData($template, $event);
$messageData = explode($delimiter, $tmpData);
$messageData = array_combine(array_keys($messageSet), $messageData);
$messageData['internalData'] = $this->parseInternalData($messageData['internalData']);
return $messageData;
}
protected function toInternalData(array $data)
{
if (!$data) {
return FALSE;
}
$result = [];
$delimiter = Helper::getDelimiter();
foreach ($data as $key => $val) {
$result[] = $key . $delimiter . $val;
}
$result = implode("\n", $result);
return $result;
}
protected function parseInternalData(string $message)
{
if (!$message) {
return FALSE;
}
$data = [];
$delimiter = Helper::getDelimiter();
$keyValueStrs = explode("\n", $message);
foreach ($keyValueStrs as $keyValueStr) {
$keyValue = explode($delimiter, $keyValueStr);
if (count($keyValue) == 2) {
$data[$keyValue[0]] = $keyValue[1];
}
}
return $data;
}
protected function addWebSiteMessage(Event $event, array $messageData, array $affectedUsers)
{
if (!isset($affectedUsers['internal']) || count($messageData) == 0) {
return FALSE;
}
$this->CI->load->model('Notification_model', 'notificationModel');
$users = $affectedUsers['internal'];
foreach ($users as $user) {
$this->CI->notificationModel->addNotification($user['u_key'], $event->type, json_encode($messageData['internalData'], TRUE), NOTIFY_FOR_USER, $event->data->gKey, $event->data->rKey);
}
return TRUE;
}
public function sendMail(Event $event, array $messageData, array $affectedUsers)
{
if (!isset($affectedUsers['email']) || count($messageData) == 0) {
return FALSE;
}
$host = 'https://codefever.pgyer.com/';
$emails = $affectedUsers['email'];
if (in_array($event->type, [
EventType::MERGE_REQUEST_CREATE,
EventType::MERGE_REQUEST_CLOSE,
EventType::MERGE_REQUEST_MERGE,
EventType::MERGE_REQUEST_REVIEWER_CREATE,
EventType::MERGE_REQUEST_REVIEWER_REVIEW
])) {
$messageData['url'] = $host . $messageData['internalData']['group'] . '/' . $messageData['internalData']['repository'] . '/mergerequests/' . $messageData['internalData']['number'];
}
$body = $this->CI->load->view('mail/user_notification', $messageData, TRUE);
foreach($emails as $email) {
EmailSender::send(
$email,
$messageData['mailTitle'],
$body
);
}
}
}
Reference in New Issue View Git Blame Copy Permalink