SubEditorsDAO.inc.php

<?php
 
class SubEditorsDAO extends DAO {
 
   function insertEditor($contextId, $assocId, $userId, $assocType) {
      return $this->update(
         'INSERT INTO subeditor_submission_group
            (context_id, assoc_id, user_id, assoc_type)
            VALUES
            (?, ?, ?, ?)',
         array(
            (int) $contextId,
            (int) $assocId,
            (int) $userId,
            (int) $assocType,
         )
      );
   }
 
   function deleteEditor($contextId, $assocId, $userId, $assocType) {
      $this->update(
         'DELETE FROM subeditor_submission_group WHERE context_id = ? AND section_id = ? AND user_id = ? AND assoc_type = ?',
         array(
            (int) $contextId,
            (int) $assocId,
            (int) $userId,
            (int) $assocType,
         )
      );
   }
 
   function getBySubmissionGroupId($assocId, $assocType, $contextId) {
      $userDao = DAORegistry::getDAO('UserDAO'); /* @var $userDao UserDAO */
      $params = array((int) $contextId, (int) $assocId, (int) $assocType);
      $params = array_merge($userDao->getFetchParameters(), $params);
      $result = $this->retrieve(
         'SELECT  u.user_id,
         ' . $userDao->getFetchColumns() . '
         FROM  subeditor_submission_group e
            JOIN users u ON (e.user_id = u.user_id)
            ' . $userDao->getFetchJoins() . '
         WHERE e.context_id = ? AND
            e.assoc_id = ? AND e.assoc_type = ?
         ' . $userDao->getOrderBy(),
         $params
      );
 
      $users = array();
      while (!$result->EOF) {
         $row = $result->GetRowAssoc(false);
         $user = $userDao->getById($row['user_id']);
         $users[$user->getId()] = $user;
         $result->MoveNext();
      }
 
      $result->Close();
      return $users;
   }
 
   function deleteBySubmissionGroupId($assocId, $assocType, $contextId = null) {
      $params = array((int) $assocId, (int) $assocType);
      if ($contextId) $params[] = (int) $contextId;
      $this->update(
         'DELETE FROM subeditor_submission_group WHERE assoc_id = ? AND assoc_type = ?' .
         ($contextId?' AND context_id = ?':''),
         $params
      );
   }
 
   function deleteByUserId($userId, $contextId  = null, $assocId = null, $assocType = null) {
      $params = array((int) $userId);
      if ($contextId) $params[] = (int) $contextId;
      if ($assocId) $params[] = (int) $assocId;
      if ($assocType) $params[] = (int) $assocType;
 
      $this->update(
         'DELETE FROM subeditor_submission_group WHERE user_id = ?' .
         ($contextId?' AND context_id = ?':'') .
         ($assocId?' AND assoc_id = ?':'') . 
         ($assocType?' AND assoc_type = ?':''),
         $params
      );
   }
 
   function editorExists($contextId, $assocId, $userId, $assocType) {
      $result = $this->retrieve(
         'SELECT COUNT(*) FROM subeditor_submission_group WHERE context_id = ? AND section_id = ? AND user_id = ? AND assoc_id = ?',
         array((int) $contextId, (int) $assocId, (int) $userId, (int) $assocType)
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;
 
      $result->Close();
      return $returner;
   }
}