芝麻web文件管理V1.00
编辑当前文件:/home2/sdektunc/dzilamdebravo1821.gob.mx/plugins/workflow/notification/notification.php
* @license GNU General Public License version 2 or later; see LICENSE.txt */ defined('_JEXEC') or die; use Joomla\CMS\Application\CMSApplicationInterface; use Joomla\CMS\Component\ComponentHelper; use Joomla\CMS\Event\Workflow\WorkflowTransitionEvent; use Joomla\CMS\Factory; use Joomla\CMS\Form\Form; use Joomla\CMS\Language\LanguageFactoryInterface; use Joomla\CMS\Language\Text; use Joomla\CMS\Plugin\CMSPlugin; use Joomla\CMS\User\UserFactoryInterface; use Joomla\CMS\Workflow\WorkflowPluginTrait; use Joomla\CMS\Workflow\WorkflowServiceInterface; use Joomla\Event\EventInterface; use Joomla\Event\SubscriberInterface; use Joomla\Utilities\ArrayHelper; /** * Workflow Notification Plugin * * @since 4.0.0 */ class PlgWorkflowNotification extends CMSPlugin implements SubscriberInterface { use WorkflowPluginTrait; /** * Load the language file on instantiation. * * @var boolean * @since 4.0.0 */ protected $autoloadLanguage = true; /** * Loads the CMS Application for direct access * * @var CMSApplicationInterface * @since 4.0.0 */ protected $app; /** * Database object. * * @var JDatabaseDriver * @since 3.9.0 */ protected $db; /** * Returns an array of events this subscriber will listen to. * * @return array * * @since 4.0.0 */ public static function getSubscribedEvents(): array { return [ 'onContentPrepareForm' => 'onContentPrepareForm', 'onWorkflowAfterTransition' => 'onWorkflowAfterTransition', ]; } /** * The form event. * * @param Form $form The form * @param stdClass $data The data * * @return boolean * * @since 4.0.0 */ public function onContentPrepareForm(EventInterface $event) { $form = $event->getArgument('0'); $data = $event->getArgument('1'); $context = $form->getName(); // Extend the transition form if ($context === 'com_workflow.transition') { $this->enhanceWorkflowTransitionForm($form, $data); } return true; } /** * Send a Notification to defined users a transition is performed * * @param string $context The context for the content passed to the plugin. * @param array $pks A list of primary key ids of the content that has changed stage. * @param object $data Object containing data about the transition * * @return boolean * * @since 4.0.0 */ public function onWorkflowAfterTransition(WorkflowTransitionEvent $event) { $context = $event->getArgument('extension'); $extensionName = $event->getArgument('extensionName'); $transition = $event->getArgument('transition'); $pks = $event->getArgument('pks'); if (!$this->isSupported($context)) { return; } $component = $this->app->bootComponent($extensionName); // Check if send-mail is active if (empty($transition->options['notification_send_mail'])) { return; } // ID of the items whose state has changed. $pks = ArrayHelper::toInteger($pks); if (empty($pks)) { return; } // Get UserIds of Receivers $userIds = $this->getUsersFromGroup($transition); // The active user $user = $this->app->getIdentity(); // Prepare Language for messages $defaultLanguage = ComponentHelper::getParams('com_languages')->get('administrator'); $debug = $this->app->get('debug_lang'); $modelName = $component->getModelName($context); $model = $component->getMVCFactory()->createModel($modelName, $this->app->getName(), ['ignore_request' => true]); // Don't send the notification to the active user $key = array_search($user->id, $userIds); if (is_int($key)) { unset($userIds[$key]); } // Remove users with locked input box from the list of receivers if (!empty($userIds)) { $userIds = $this->removeLocked($userIds); } // If there are no receivers, stop here if (empty($userIds)) { return; } // Get the model for private messages $model_message = $this->app->bootComponent('com_messages') ->getMVCFactory()->createModel('Message', 'Administrator'); // Get the title of the stage $model_stage = $this->app->bootComponent('com_workflow') ->getMVCFactory()->createModel('Stage', 'Administrator'); $toStage = $model_stage->getItem($transition->to_stage_id)->title; $hasGetItem = method_exists($model, 'getItem'); $container = Factory::getContainer(); foreach ($pks as $pk) { // Get the title of the item which has changed $title = ''; if ($hasGetItem) { $title = $model->getItem($pk)->title; } // Send Email to receivers foreach ($userIds as $user_id) { $receiver = $container->get(UserFactoryInterface::class)->loadUserById($user_id); if ($receiver->authorise('core.manage', 'com_message')) { // Load language for messaging $lang = $container->get(LanguageFactoryInterface::class) ->createLanguage($user->getParam('admin_language', $defaultLanguage), $debug); $lang->load('plg_workflow_notification'); $messageText = sprintf($lang->_('PLG_WORKFLOW_NOTIFICATION_ON_TRANSITION_MSG'), $title, $user->name, $lang->_($toStage)); if (!empty($transition->options['notification_text'])) { $messageText .= '
' . htmlspecialchars($lang->_($transition->options['notification_text'])); } $message = [ 'id' => 0, 'user_id_to' => $receiver->id, 'subject' => sprintf($lang->_('PLG_WORKFLOW_NOTIFICATION_ON_TRANSITION_SUBJECT'), $modelName), 'message' => $messageText, ]; $model_message->save($message); } } } $this->app->enqueueMessage(Text::_('PLG_WORKFLOW_NOTIFICATION_SENT'), 'message'); } /** * Get user_ids of receivers * * @param object $data Object containing data about the transition * * @return array $userIds The receivers * * @since 4.0.0 */ private function getUsersFromGroup($data): array { $users = []; // Single userIds if (!empty($data->options['notification_receivers'])) { $users = ArrayHelper::toInteger($data->options['notification_receivers']); } // Usergroups $groups = []; if (!empty($data->options['notification_groups'])) { $groups = ArrayHelper::toInteger($data->options['notification_groups']); } $users2 = []; if (!empty($groups)) { // UserIds from usergroups $model = Factory::getApplication()->bootComponent('com_users') ->getMVCFactory()->createModel('Users', 'Administrator', ['ignore_request' => true]); $model->setState('list.select', 'id'); $model->setState('filter.groups', $groups); $model->setState('filter.state', 0); // Ids from usergroups $groupUsers = $model->getItems(); $users2 = ArrayHelper::getColumn($groupUsers, 'id'); } // Merge userIds from individual entries and userIDs from groups return array_unique(array_merge($users, $users2)); } /** * Check if the current plugin should execute workflow related activities * * @param string $context * * @return boolean * * @since 4.0.0 */ protected function isSupported($context) { if (!$this->checkAllowedAndForbiddenlist($context)) { return false; } $parts = explode('.', $context); // We need at least the extension + view for loading the table fields if (count($parts) < 2) { return false; } $component = $this->app->bootComponent($parts[0]); if (!$component instanceof WorkflowServiceInterface || !$component->isWorkflowActive($context)) { return false; } return true; } /** * Remove receivers who have locked their message inputbox * * @param array $userIds The userIds which must be checked * * @return array users with active message input box * * @since 4.0.0 */ private function removeLocked(array $userIds): array { if (empty($userIds)) { return []; } // Check for locked inboxes would be better to have _cdf settings in the user_object or a filter in users model $query = $this->db->getQuery(true); $query->select($this->db->quoteName('user_id')) ->from($this->db->quoteName('#__messages_cfg')) ->whereIn($this->db->quoteName('user_id'), $userIds) ->where($this->db->quoteName('cfg_name') . ' = ' . $this->db->quote('locked')) ->where($this->db->quoteName('cfg_value') . ' = 1'); $locked = $this->db->setQuery($query)->loadColumn(); return array_diff($userIds, $locked); } }