classes/security/UserGroupDAO.inc.php

<?php

import('lib.pkp.classes.security.PKPUserGroupDAO');

class UserGroupDAO extends PKPUserGroupDAO {
   function UserGroupDAO() {
      parent::PKPUserGroupDAO();
   }

   function &getUserGroupsByStage($pressId, $stageId, $omitAuthors = false, $omitReviewers = false, $roleId = null) {
      $params = array((int) $pressId, (int) $stageId);
      if ($omitAuthors) $params[] = ROLE_ID_AUTHOR;
      if ($omitReviewers) $params[] = ROLE_ID_REVIEWER;
      if ($roleId) $params[] = $roleId;
      $result =& $this->retrieve(
         'SELECT  ug.*
         FROM  user_groups ug
            JOIN user_group_stage ugs ON (ug.user_group_id = ugs.user_group_id AND ug.context_id = ugs.press_id)
         WHERE ugs.press_id = ? AND
            ugs.stage_id = ?' .
            ($omitAuthors?' AND ug.role_id <> ?':'') .
            ($omitReviewers?' AND ug.role_id <> ?':'') .
            ($roleId?' AND ug.role_id = ?':'') .
         ' ORDER BY role_id ASC',
         $params
      );

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

   function getAssignedStagesByUserGroupId($pressId, $userGroupId) {
      $result =& $this->retrieve(
         'SELECT  stage_id
         FROM  user_group_stage
         WHERE press_id = ? AND
            user_group_id = ?',
         array((int) $pressId, (int) $userGroupId)
      );

      $returner = array();

      while (!$result->EOF) {
         $stageId = $result->Fields('stage_id');
         $returner[$stageId] = $this->getTranslationKeyFromId($stageId);
         $result->MoveNext();
      }

      return $returner;
   }

   function userGroupAssignedToStage($userGroupId, $stageId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM  user_group_stage
         WHERE user_group_id = ? AND
         stage_id = ?',
         array((int) $userGroupId, (int) $stageId)
      );

      $returner = isset($result->fields[0]) && $result->fields[0] > 0 ? true : false;

      $result->Close();
      unset($result);

      return $returner;
   }

   function assignGroupToStage($pressId, $userGroupId, $stageId) {
      return $this->update(
         'INSERT INTO user_group_stage (press_id, user_group_id, stage_id) VALUES (?, ?, ?)',
         array((int) $pressId, (int) $userGroupId, (int) $stageId)
      );
   }

   function removeGroupFromStage($pressId, $userGroupId, $stageId) {
      return $this->update(
         'DELETE FROM user_group_stage WHERE press_id = ? AND user_group_id = ? AND stage_id = ?',
         array((int) $pressId, (int) $userGroupId, (int) $stageId)
      );
   }

   function userAssignmentExists($pressId, $userId, $stageId) {
      $result =& $this->retrieve(
         'SELECT  COUNT(*)
         FROM  user_group_stage ugs,
            user_user_groups uug
         WHERE ugs.user_group_id = uug.user_group_id AND
            ugs.press_id = ? AND
            uug.user_id = ? AND
            ugs.stage_id = ?',
         array((int) $pressId, (int) $userId, (int) $stageId)
      );

      $returner = isset($result->fields[0]) && $result->fields[0] > 0 ? true : false;

      $result->Close();
      unset($result);

      return $returner;
   }


   //
   // Public helper methods
   //
   function getPathFromId($stageId) {
      static $stageMapping = array(
         WORKFLOW_STAGE_ID_SUBMISSION => WORKFLOW_STAGE_PATH_SUBMISSION,
         WORKFLOW_STAGE_ID_INTERNAL_REVIEW => WORKFLOW_STAGE_PATH_INTERNAL_REVIEW,
         WORKFLOW_STAGE_ID_EXTERNAL_REVIEW => WORKFLOW_STAGE_PATH_EXTERNAL_REVIEW,
         WORKFLOW_STAGE_ID_EDITING => WORKFLOW_STAGE_PATH_EDITING,
         WORKFLOW_STAGE_ID_PRODUCTION => WORKFLOW_STAGE_PATH_PRODUCTION
      );
      if (isset($stageMapping[$stageId])) {
         return $stageMapping[$stageId];
      } else {
         return null;
      }
   }

   function getIdFromPath($stagePath) {
      static $stageMapping = array(
         WORKFLOW_STAGE_PATH_SUBMISSION => WORKFLOW_STAGE_ID_SUBMISSION,
         WORKFLOW_STAGE_PATH_INTERNAL_REVIEW => WORKFLOW_STAGE_ID_INTERNAL_REVIEW,
         WORKFLOW_STAGE_PATH_EXTERNAL_REVIEW => WORKFLOW_STAGE_ID_EXTERNAL_REVIEW,
         WORKFLOW_STAGE_PATH_EDITING => WORKFLOW_STAGE_ID_EDITING,
         WORKFLOW_STAGE_PATH_PRODUCTION => WORKFLOW_STAGE_ID_PRODUCTION
      );
      if (isset($stageMapping[$stagePath])) {
         return $stageMapping[$stagePath];
      } else {
         return null;
      }
   }

   function getTranslationKeyFromId($stageId) {
      $stageMapping = $this->getWorkflowStageTranslationKeys();

      assert(isset($stageMapping[$stageId]));
      return $stageMapping[$stageId];
   }

   function getWorkflowStageTranslationKeys() {
      static $stageMapping = array(
         WORKFLOW_STAGE_ID_SUBMISSION => 'submission.submission',
         WORKFLOW_STAGE_ID_INTERNAL_REVIEW => 'workflow.review.internalReview',
         WORKFLOW_STAGE_ID_EXTERNAL_REVIEW => 'workflow.review.externalReview',
         WORKFLOW_STAGE_ID_EDITING => 'submission.editorial',
         WORKFLOW_STAGE_ID_PRODUCTION => 'submission.production'
      );

      return $stageMapping;
   }

   function getWorkflowStageKeysAndPaths() {
      $workflowStages = $this->getWorkflowStageTranslationKeys();
      $stageMapping = array();
      foreach ($workflowStages as $stageId => $translationKey) {
         $stageMapping[$stageId] = array(
            'id' => $stageId,
            'translationKey' => $translationKey,
            'path' => $this->getPathFromId($stageId)
         );
      }

      return $stageMapping;
   }
}

?>