classes/user/UserStageAssignmentDAO.inc.php

<?php

import('classes.user.UserDAO');

class UserStageAssignmentDAO extends UserDAO {
   function UserStageAssignmentDAO() {
      parent::UserDAO();
   }

   function getUsersNotAssignedToStageInUserGroup($submissionId, $stageId, $userGroupId) {
      $result =& $this->retrieve(
         'SELECT  u.*
         FROM  users u
            LEFT JOIN user_user_groups uug ON (u.user_id = uug.user_id)
            LEFT JOIN stage_assignments s ON (s.user_id = uug.user_id AND s.user_group_id = uug.user_group_id AND s.submission_id = ?)
            JOIN user_group_stage ugs ON (uug.user_group_id = ugs.user_group_id AND ugs.stage_id = ?)
         WHERE uug.user_group_id = ? AND
            s.user_group_id IS NULL',
         array((int) $submissionId, (int) $stageId, (int) $userGroupId));

      $returner = new DAOResultFactory($result, $this, '_returnUserFromRowWithData');
      return $returner;
   }

   function getUsersBySubmissionAndStageId($submissionId, $stageId = null, $userGroupId = null, $roleId = null, $userId = null) {
      return $this->_getUsersByIds($submissionId, $stageId, $userGroupId, $userId, $roleId);
   }

   function deleteAssignment($assignmentId) {
      return $this->update('DELETE FROM stage_assignments WHERE stage_assignment_id = ?', $assignmentId);
   }


   //
   // Private helper method
   //
   function _getUsersByIds($submissionId, $stageId = null, $userGroupId = null, $userId = null, $roleId = null) {
      $params = array((int) $submissionId);
      if (isset($stageId)) $params[] = (int) $stageId;
      if (isset($userGroupId)) $params[] = (int) $userGroupId;
      if (isset($userId)) $params[] = (int) $userId;
      if (isset($roleId)) $params[] = (int) $roleId;

      $result =& $this->retrieve(
         'SELECT u.*
         FROM stage_assignments sa
         INNER JOIN user_group_stage ugs ON (sa.user_group_id = ugs.user_group_id)
         INNER JOIN users u ON (u.user_id = sa.user_id) ' .
         (isset($roleId) ? 'INNER JOIN user_groups ug ON (ug.user_group_id = sa.user_group_id) ' : '') .
         'WHERE submission_id = ?' .
         (isset($stageId) ? ' AND ugs.stage_id = ?' : '') .
         (isset($userGroupId) ? ' AND sa.user_group_id = ?':'') .
         (isset($userId)?' AND u.user_id = ? ' : '') .
         (isset($roleId)?' AND ug.role_id = ?' : ''),
         $params);

      $returner = null;
      // This is a little obscure.
      // 4 params and 1 search results, means calling context was seeking an individual user.
      if ($result->RecordCount() == 1 && count($params) == 4) {
         // If all parameters were specified, then seeking only one assignment.
         $returner =& $this->_returnUserFromRowWithData($result->GetRowAssoc(false));
      } elseif ($result) {
         $returner = new DAOResultFactory($result, $this, '_returnUserFromRowWithData');
      }
      return $returner;
   }
}

?>