classes/stageAssignment/StageAssignmentDAO.inc.php

<?php

import('classes.stageAssignment.StageAssignment');

class StageAssignmentDAO extends DAO {
   function StageAssignmentDAO() {
      parent::DAO();
   }

   function getById($stageAssignmentId) {
      $result =& $this->retrieve(
         $this->getBaseQueryForAssignmentSelection()
         . 'WHERE stage_assignment_id = ?',
         (int) $stageAssignmentId
      );
      return $this->_fromRow($result->GetRowAssoc(false));
   }

   function getBySubmissionAndStageId($submissionId, $stageId = null, $userGroupId = null, $userId = null) {
      return $this->_getByIds($submissionId, $stageId, $userGroupId, $userId);
   }

   function getBySubmissionAndRoleId($submissionId, $roleId, $stageId = null, $userId = null) {
      return $this->_getByIds($submissionId, $stageId, null, $userId, $roleId);
   }

   function getByUserId($userId) {
      return $this->_getByIds(null, null, null, $userId);
   }

   function getEditorsAssignedToStage($submissionId, $stageId) {
      $pressManagerAssignmentFactory = $this->getBySubmissionAndRoleId($submissionId, ROLE_ID_PRESS_MANAGER, $stageId);
      $seriesEditorAssignmentFactory = $this->getBySubmissionAndRoleId($submissionId, ROLE_ID_SERIES_EDITOR, $stageId);
      return array_merge($pressManagerAssignmentFactory->toArray(), $seriesEditorAssignmentFactory->toArray());
   }

   function editorAssignedToStage($submissionId, $stageId = null) {
      $params = array((int) $submissionId, ROLE_ID_PRESS_MANAGER, ROLE_ID_SERIES_EDITOR);
      if ($stageId) $params[] = (int) $stageId;
      $result =& $this->retrieve(
         'SELECT  COUNT(*)
         FROM  stage_assignments sa
            JOIN user_groups ug ON (sa.user_group_id = ug.user_group_id)
            JOIN user_group_stage ugs ON (ug.user_group_id = ugs.user_group_id)
         WHERE sa.submission_id = ? AND
            ug.role_id IN (?, ?)' .
            ($stageId?' AND ugs.stage_id = ?':''),
         $params
      );
      $returner = isset($result->fields[0]) && $result->fields[0] > 0 ? true : false;

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

      return $returner;
   }

   function build($submissionId, $userGroupId, $userId) {

      // If one exists, fetch and return.
      $stageAssignment =& $this->getBySubmissionAndStageId($submissionId, null, $userGroupId, $userId);
      if (!$stageAssignment->wasEmpty()) return $stageAssignment;

      // Otherwise, build one.
      unset($stageAssignment);
      $stageAssignment = $this->newDataObject();
      $stageAssignment->setSubmissionId($submissionId);
      $stageAssignment->setUserGroupId($userGroupId);
      $stageAssignment->setUserId($userId);
      $this->insertObject($stageAssignment);
      $stageAssignment->setId($this->getInsertStageAssignmentId());
      return $stageAssignment;
   }

   function newDataObject() {
      return new StageAssignment();
   }

   function _fromRow(&$row) {
      $stageAssignment = $this->newDataObject();

      $stageAssignment->setId($row['stage_assignment_id']);
      $stageAssignment->setSubmissionId($row['submission_id']);
      $stageAssignment->setUserId($row['user_id']);
      $stageAssignment->setUserGroupId($row['user_group_id']);
      $stageAssignment->setDateAssigned($row['date_assigned']);
      $stageAssignment->setStageId($row['stage_id']);

      return $stageAssignment;
   }

   function insertObject(&$stageAssignment) {
      return $this->update(
         sprintf(
            'INSERT INTO stage_assignments
               (submission_id, user_group_id, user_id, date_assigned)
            VALUES
               (?, ?, ?, %s)',
            $this->datetimeToDB(Core::getCurrentDate())
         ),
         array(
            $stageAssignment->getSubmissionId(),
            $this->nullOrInt($stageAssignment->getUserGroupId()),
            $this->nullOrInt($stageAssignment->getUserId())
         )
      );
   }

   function deleteObject($stageAssignment) {
      return $this->deleteByAll(
         $stageAssignment->getSubmissionId(),
         $stageAssignment->getUserGroupId(),
         $stageAssignment->getUserId()
      );
   }

   function deleteByAll($submissionId, $userGroupId, $userId) {
      return $this->update(
         'DELETE FROM stage_assignments
         WHERE submission_id = ?
            AND user_group_id = ?
            AND user_id = ?',
         array((int) $submissionId, (int) $userGroupId, (int) $userId)
      );
   }

   function getInsertStageAssignmentId() {
      return $this->getInsertId('stage_assignments', 'stage_assignment_id');
   }

   function _getByIds($submissionId = null, $stageId = null, $userGroupId = null, $userId = null, $roleId = null, $single = false) {
      $conditions = array();
      $params = array();
      if (isset($submissionId)) {
         $conditions[] = 'sa.submission_id = ?';
         $params[] = (int) $submissionId;
      }
      if (isset($stageId)) {
         $conditions[] = 'ugs.stage_id = ?';
         $params[] = (int) $stageId;
      }
      if (isset($userGroupId)) {
         $conditions[] = 'sa.user_group_id = ?';
         $params[] = (int) $userGroupId;
      }
      if (isset($userId)) {
         $conditions[] = 'sa.user_id = ?';
         $params[] = (int) $userId;
      }

      if (isset($roleId)) {
         $conditions[] = 'ug.role_id = ?';
         $params[] = (int) $roleId;
      }

      $result =& $this->retrieve(
         $this->getBaseQueryForAssignmentSelection() .
         (isset($roleId)?' LEFT JOIN user_groups ug ON sa.user_group_id = ug.user_group_id ':'') .
         'WHERE ' . (implode(' AND ', $conditions)),
         $params
      );

      $returner = null;
      if ( $single ) {
            // all four parameters must be specified for a single record to be returned
            if (!$submissionId && !$stageId && !$userGroupId && !$userId) return false;
            // no matches were found.
            if ($result->RecordCount() == 0) return false;
            $returner =& $this->_fromRow($result->GetRowAssoc(false));
            $result->Close();
      } else {
         // In any other case, return a list of all assignments
         $returner = new DAOResultFactory($result, $this, '_fromRow');
      }
      return $returner;
   }

   function getBaseQueryForAssignmentSelection() {
      return 'SELECT ugs.stage_id AS stage_id, sa.* FROM stage_assignments sa
         JOIN user_group_stage ugs ON sa.user_group_id = ugs.user_group_id ';
   }
}

?>