db->table(self::TABLE)->eq('id', $task_link_id)->findOne(); } /** * Get the opposite task link (use the unique index task_has_links_unique) * * @access public * @param array $task_link * @return array */ public function getOppositeTaskLink(array $task_link) { $opposite_link_id = $this->link->getOppositeLinkId($task_link['link_id']); return $this->db->table(self::TABLE) ->eq('opposite_task_id', $task_link['task_id']) ->eq('task_id', $task_link['opposite_task_id']) ->eq('link_id', $opposite_link_id) ->findOne(); } /** * Get all links attached to a task * * @access public * @param integer $task_id Task id * @return array */ public function getAll($task_id) { return $this->db ->table(self::TABLE) ->columns( self::TABLE.'.id', self::TABLE.'.opposite_task_id AS task_id', Link::TABLE.'.label', Task::TABLE.'.title', Task::TABLE.'.is_active', Task::TABLE.'.project_id', Task::TABLE.'.time_spent AS task_time_spent', Task::TABLE.'.time_estimated AS task_time_estimated', Task::TABLE.'.owner_id AS task_assignee_id', User::TABLE.'.username AS task_assignee_username', User::TABLE.'.name AS task_assignee_name', Board::TABLE.'.title AS column_title' ) ->eq(self::TABLE.'.task_id', $task_id) ->join(Link::TABLE, 'id', 'link_id') ->join(Task::TABLE, 'id', 'opposite_task_id') ->join(Board::TABLE, 'id', 'column_id', Task::TABLE) ->join(User::TABLE, 'id', 'owner_id', Task::TABLE) ->orderBy(Link::TABLE.'.id ASC, '.Board::TABLE.'.position DESC, '.Task::TABLE.'.is_active DESC, '.Task::TABLE.'.position ASC, '.Task::TABLE.'.id', Table::SORT_ASC) ->findAll(); } /** * Get all links attached to a task grouped by label * * @access public * @param integer $task_id Task id * @return array */ public function getAllGroupedByLabel($task_id) { $links = $this->getAll($task_id); $result = array(); foreach ($links as $link) { if (! isset($result[$link['label']])) { $result[$link['label']] = array(); } $result[$link['label']][] = $link; } return $result; } /** * Create a new link * * @access public * @param integer $task_id Task id * @param integer $opposite_task_id Opposite task id * @param integer $link_id Link id * @return integer Task link id */ public function create($task_id, $opposite_task_id, $link_id) { $this->db->startTransaction(); // Get opposite link $opposite_link_id = $this->link->getOppositeLinkId($link_id); // Create the original task link $this->db->table(self::TABLE)->insert(array( 'task_id' => $task_id, 'opposite_task_id' => $opposite_task_id, 'link_id' => $link_id, )); $task_link_id = $this->db->getLastId(); // Create the opposite task link $this->db->table(self::TABLE)->insert(array( 'task_id' => $opposite_task_id, 'opposite_task_id' => $task_id, 'link_id' => $opposite_link_id, )); $this->db->closeTransaction(); return (int) $task_link_id; } /** * Update a task link * * @access public * @param integer $task_link_id Task link id * @param integer $task_id Task id * @param integer $opposite_task_id Opposite task id * @param integer $link_id Link id * @return boolean */ public function update($task_link_id, $task_id, $opposite_task_id, $link_id) { $this->db->startTransaction(); // Get original task link $task_link = $this->getById($task_link_id); // Find opposite task link $opposite_task_link = $this->getOppositeTaskLink($task_link); // Get opposite link $opposite_link_id = $this->link->getOppositeLinkId($link_id); // Update the original task link $rs1 = $this->db->table(self::TABLE)->eq('id', $task_link_id)->update(array( 'task_id' => $task_id, 'opposite_task_id' => $opposite_task_id, 'link_id' => $link_id, )); // Update the opposite link $rs2 = $this->db->table(self::TABLE)->eq('id', $opposite_task_link['id'])->update(array( 'task_id' => $opposite_task_id, 'opposite_task_id' => $task_id, 'link_id' => $opposite_link_id, )); $this->db->closeTransaction(); return $rs1 && $rs2; } /** * Remove a link between two tasks * * @access public * @param integer $task_link_id * @return boolean */ public function remove($task_link_id) { $this->db->startTransaction(); $link = $this->getById($task_link_id); $link_id = $this->link->getOppositeLinkId($link['link_id']); $this->db->table(self::TABLE)->eq('id', $task_link_id)->remove(); $this->db ->table(self::TABLE) ->eq('opposite_task_id', $link['task_id']) ->eq('task_id', $link['opposite_task_id']) ->eq('link_id', $link_id)->remove(); $this->db->closeTransaction(); return true; } /** * Common validation rules * * @access private * @return array */ private function commonValidationRules() { return array( new Validators\Required('task_id', t('Field required')), new Validators\Required('opposite_task_id', t('Field required')), new Validators\Required('link_id', t('Field required')), new Validators\NotEquals('opposite_task_id', 'task_id', t('A task cannot be linked to itself')), new Validators\Exists('opposite_task_id', t('This linked task id doesn\'t exists'), $this->db->getConnection(), Task::TABLE, 'id') ); } /** * Validate creation * * @access public * @param array $values Form values * @return array $valid, $errors [0] = Success or not, [1] = List of errors */ public function validateCreation(array $values) { $v = new Validator($values, $this->commonValidationRules()); return array( $v->execute(), $v->getErrors() ); } /** * Validate modification * * @access public * @param array $values Form values * @return array $valid, $errors [0] = Success or not, [1] = List of errors */ public function validateModification(array $values) { $rules = array( new Validators\Required('id', t('Field required')), ); $v = new Validator($values, array_merge($rules, $this->commonValidationRules())); return array( $v->execute(), $v->getErrors() ); } }