summaryrefslogtreecommitdiff
path: root/app/Model/TaskLinkModel.php
diff options
context:
space:
mode:
Diffstat (limited to 'app/Model/TaskLinkModel.php')
-rw-r--r--app/Model/TaskLinkModel.php265
1 files changed, 265 insertions, 0 deletions
diff --git a/app/Model/TaskLinkModel.php b/app/Model/TaskLinkModel.php
new file mode 100644
index 00000000..45225e35
--- /dev/null
+++ b/app/Model/TaskLinkModel.php
@@ -0,0 +1,265 @@
+<?php
+
+namespace Kanboard\Model;
+
+use Kanboard\Core\Base;
+use Kanboard\Event\TaskLinkEvent;
+
+/**
+ * TaskLink model
+ *
+ * @package Kanboard\Model
+ * @author Olivier Maridat
+ * @author Frederic Guillot
+ */
+class TaskLinkModel extends Base
+{
+ /**
+ * SQL table name
+ *
+ * @var string
+ */
+ const TABLE = 'task_has_links';
+
+ /**
+ * Events
+ *
+ * @var string
+ */
+ const EVENT_CREATE_UPDATE = 'tasklink.create_update';
+
+ /**
+ * Get a task link
+ *
+ * @access public
+ * @param integer $task_link_id Task link id
+ * @return array
+ */
+ public function getById($task_link_id)
+ {
+ return $this->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->linkModel->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',
+ LinkModel::TABLE.'.label',
+ TaskModel::TABLE.'.title',
+ TaskModel::TABLE.'.is_active',
+ TaskModel::TABLE.'.project_id',
+ TaskModel::TABLE.'.column_id',
+ TaskModel::TABLE.'.color_id',
+ TaskModel::TABLE.'.time_spent AS task_time_spent',
+ TaskModel::TABLE.'.time_estimated AS task_time_estimated',
+ TaskModel::TABLE.'.owner_id AS task_assignee_id',
+ UserModel::TABLE.'.username AS task_assignee_username',
+ UserModel::TABLE.'.name AS task_assignee_name',
+ ColumnModel::TABLE.'.title AS column_title',
+ ProjectModel::TABLE.'.name AS project_name'
+ )
+ ->eq(self::TABLE.'.task_id', $task_id)
+ ->join(LinkModel::TABLE, 'id', 'link_id')
+ ->join(TaskModel::TABLE, 'id', 'opposite_task_id')
+ ->join(ColumnModel::TABLE, 'id', 'column_id', TaskModel::TABLE)
+ ->join(UserModel::TABLE, 'id', 'owner_id', TaskModel::TABLE)
+ ->join(ProjectModel::TABLE, 'id', 'project_id', TaskModel::TABLE)
+ ->asc(LinkModel::TABLE.'.id')
+ ->desc(ColumnModel::TABLE.'.position')
+ ->desc(TaskModel::TABLE.'.is_active')
+ ->asc(TaskModel::TABLE.'.position')
+ ->asc(TaskModel::TABLE.'.id')
+ ->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;
+ }
+
+ /**
+ * Publish events
+ *
+ * @access private
+ * @param array $events
+ */
+ private function fireEvents(array $events)
+ {
+ foreach ($events as $event) {
+ $event['project_id'] = $this->taskFinderModel->getProjectId($event['task_id']);
+ $this->container['dispatcher']->dispatch(self::EVENT_CREATE_UPDATE, new TaskLinkEvent($event));
+ }
+ }
+
+ /**
+ * 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)
+ {
+ $events = array();
+ $this->db->startTransaction();
+
+ // Get opposite link
+ $opposite_link_id = $this->linkModel->getOppositeLinkId($link_id);
+
+ $values = array(
+ 'task_id' => $task_id,
+ 'opposite_task_id' => $opposite_task_id,
+ 'link_id' => $link_id,
+ );
+
+ // Create the original task link
+ $this->db->table(self::TABLE)->insert($values);
+ $task_link_id = $this->db->getLastId();
+ $events[] = $values;
+
+ // Create the opposite task link
+ $values = array(
+ 'task_id' => $opposite_task_id,
+ 'opposite_task_id' => $task_id,
+ 'link_id' => $opposite_link_id,
+ );
+
+ $this->db->table(self::TABLE)->insert($values);
+ $events[] = $values;
+
+ $this->db->closeTransaction();
+
+ $this->fireEvents($events);
+
+ 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)
+ {
+ $events = array();
+ $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->linkModel->getOppositeLinkId($link_id);
+
+ // Update the original task link
+ $values = array(
+ 'task_id' => $task_id,
+ 'opposite_task_id' => $opposite_task_id,
+ 'link_id' => $link_id,
+ );
+
+ $rs1 = $this->db->table(self::TABLE)->eq('id', $task_link_id)->update($values);
+ $events[] = $values;
+
+ // Update the opposite link
+ $values = array(
+ 'task_id' => $opposite_task_id,
+ 'opposite_task_id' => $task_id,
+ 'link_id' => $opposite_link_id,
+ );
+
+ $rs2 = $this->db->table(self::TABLE)->eq('id', $opposite_task_link['id'])->update($values);
+ $events[] = $values;
+
+ $this->db->closeTransaction();
+
+ if ($rs1 && $rs2) {
+ $this->fireEvents($events);
+ return true;
+ }
+
+ return false;
+ }
+
+ /**
+ * 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->linkModel->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;
+ }
+}
generated by cgit v1.2.3 (git 2.46.0) at 2024-11-23 01:05:28 +0000