function workflow_notify_workflow in Workflow 7

Same name and namespace in other branches

1. 7.2 workflow_notify/workflow_notify.module \workflow_notify_workflow()

Implements hook_workflow().

Parameters

$op: The current workflow operation: 'transition permitted', 'transition pre', or 'transition post'.

$old_state: The state ID of the current state.

$new_state: The state ID of the new state.

$node: The node whose workflow state is changing.

$force: The caller indicated that the transition should be forced. (bool). This is only available on the "pre" and "post" calls.

File

workflow_notify/workflow_notify.module, line 106

Notify roles for Workfllow state transitions.

Code

function workflow_notify_workflow($op, $old_state, $new_state, $node, $force = FALSE) {
  global $user;
  switch ($op) {

    // React to a transition after it's done.
    case 'transition post':

      // See if this is a state that we notify for.
      $notify = variable_get('workflow_notify_roles', array());
      if (isset($notify[$new_state])) {

        // List of content types.
        $node_types = node_type_get_names();

        // The name of the person making the change.
        $changer = format_username($user);
        $changer_mail = $user->mail;

        // Okay, we are notifying someone of this change.
        // So let's get the workflow object.
        $workflow = workflow_get_workflow_by_sid($new_state);

        // And all the states.
        $states = workflow_get_workflow_states_by_wid($workflow->wid);

        // Get the specific roles to notify.
        $notify = $notify[$new_state];

        // See if we want to notify the author too?
        $notify_author = in_array(-1, $notify);
        unset($notify[-1]);

        // There could be no roles set.
        if ($notify) {

          // Get all the user accounts in those roles.
          $query = "SELECT DISTINCT ur.uid " . "FROM {users_roles} ur " . "INNER JOIN {users} u ON u.uid = ur.uid " . "WHERE ur.rid IN (:rids) " . "AND u.status = 1 ";
          $users = db_query($query, array(
            ':rids' => $notify,
          ))
            ->fetchCol();
        }
        else {
          $users = array();
        }
        if ($notify_author) {
          $users[] = $node->uid;
        }

        // Load all the user entities, making sure there are no duplicates.
        $accounts = entity_load('user', array_unique($users, SORT_NUMERIC));

        // Call all modules that want to limit the list.
        $args = array(
          'users' => $accounts,
          'node' => $node,
          'state' => $new_state,
          'roles' => $notify,
          'workflow' => $workflow,
        );
        foreach (module_implements('workflow_notify') as $module) {
          $function = $module . '_workflow_notify';
          $function('users', $args);
        }

        // Retrieve the remaining list without duplicates.
        $accounts = $args['users'];
        $addr_list = array();

        // Just quit if there are no users.
        if (empty($accounts)) {
          watchdog('workflow_notify', 'No recipients - email skipped.', array(), WATCHDOG_DEBUG, l(t('view'), 'node/' . $node->nid));
          return;
        }
        foreach ($accounts as $uid => $account) {
          $addr_list[] = format_username($account) . '<' . $account->mail . '>';
        }
        $params = array(
          'clear' => TRUE,
          'sanitize' => FALSE,
          'data' => array(
            'node' => $node,
            'user' => $user,
          ),
          'filter' => variable_get('workflow_notify_filter_format_' . $workflow->wid, 'filtered_html'),
        );

        // Build the subject and body of the mail.
        // Token replacement occurs in hook_mail().
        // @TODO: Currently no translation occurs.
        $params['context']['subject'] = variable_get("workflow_notify_subject_{$new_state}", '[node:title] is now "[workflow:workflow-current-state-name]"');
        $params['context']['body'] = variable_get("workflow_notify_body_{$new_state}", '<a href="[node:url:absolute]">[node:title]</a> is now "@state".');
        switch (variable_get('workflow_notify_from_address_' . $workflow->wid, 'site')) {
          case 'site':
            $from = variable_get('site_mail', ini_get('sendmail_from'));
            break;
          case 'changer':
            $from = $user->mail;
            break;
        }

        // Send the email.
        drupal_mail('workflow_notify', 'workflow_notify', implode(',', $addr_list), language_default(), $params, $from);
      }
      return;
  }
}