|
<?php |
|
|
|
namespace Kanboard\Model; |
|
|
|
use PicoDb\Database; |
|
use Kanboard\Core\Base; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class SubtaskModel extends Base |
|
{ |
|
|
|
|
|
|
|
|
|
|
|
const TABLE = 'subtasks'; |
|
|
|
|
|
|
|
|
|
|
|
|
|
const STATUS_TODO = 0; |
|
const STATUS_INPROGRESS = 1; |
|
const STATUS_DONE = 2; |
|
|
|
|
|
|
|
|
|
|
|
|
|
const EVENT_UPDATE = 'subtask.update'; |
|
const EVENT_CREATE = 'subtask.create'; |
|
const EVENT_DELETE = 'subtask.delete'; |
|
const EVENT_CREATE_UPDATE = 'subtask.create_update'; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getProjectId($subtaskId) |
|
{ |
|
return $this->db |
|
->table(self::TABLE) |
|
->eq(self::TABLE.'.id', $subtaskId) |
|
->join(TaskModel::TABLE, 'id', 'task_id') |
|
->findOneColumn(TaskModel::TABLE . '.project_id') ?: 0; |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getStatusList() |
|
{ |
|
return array( |
|
self::STATUS_TODO => 'Todo', |
|
self::STATUS_INPROGRESS => 'In progress', |
|
self::STATUS_DONE => 'Done', |
|
); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getQuery() |
|
{ |
|
return $this->db |
|
->table(self::TABLE) |
|
->columns( |
|
self::TABLE.'.*', |
|
UserModel::TABLE.'.username', |
|
UserModel::TABLE.'.name' |
|
) |
|
->subquery($this->subtaskTimeTrackingModel->getTimerQuery($this->userSession->getId()), 'timer_start_date') |
|
->join(UserModel::TABLE, 'id', 'user_id') |
|
->asc(self::TABLE.'.position'); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function countByAssigneeAndTaskStatus($userId) |
|
{ |
|
$query = $this->db->table(self::TABLE) |
|
->eq('user_id', $userId) |
|
->eq(TaskModel::TABLE.'.is_active', TaskModel::STATUS_OPEN) |
|
->join(Taskmodel::TABLE, 'id', 'task_id'); |
|
|
|
$this->hook->reference('model:subtask:count:query', $query); |
|
|
|
return $query->count(); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getAll($taskId) |
|
{ |
|
return $this->subtaskListFormatter |
|
->withQuery($this->getQuery()->eq('task_id', $taskId)) |
|
->format(); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getAllByTaskIds(array $taskIds) |
|
{ |
|
if (empty($taskIds)) { |
|
return array(); |
|
} |
|
|
|
return $this->subtaskListFormatter |
|
->withQuery($this->getQuery()->in('task_id', $taskIds)) |
|
->format(); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getAllByTaskIdsAndAssignee(array $taskIds, $userId) |
|
{ |
|
if (empty($taskIds)) { |
|
return array(); |
|
} |
|
|
|
return $this->subtaskListFormatter |
|
->withQuery($this->getQuery()->in('task_id', $taskIds)->eq(self::TABLE.'.user_id', $userId)) |
|
->format(); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getById($subtaskId) |
|
{ |
|
return $this->db->table(self::TABLE)->eq('id', $subtaskId)->findOne(); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getByIdWithDetails($subtaskId) |
|
{ |
|
$subtasks = $this->subtaskListFormatter |
|
->withQuery($this->getQuery()->eq(self::TABLE.'.id', $subtaskId)) |
|
->format(); |
|
|
|
if (! empty($subtasks)) { |
|
return $subtasks[0]; |
|
} |
|
|
|
return null; |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getLastPosition($taskId) |
|
{ |
|
return (int) $this->db |
|
->table(self::TABLE) |
|
->eq('task_id', $taskId) |
|
->desc('position') |
|
->findOneColumn('position'); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function create(array $values) |
|
{ |
|
$this->prepareCreation($values); |
|
$subtaskId = $this->db->table(self::TABLE)->persist($values); |
|
|
|
if ($subtaskId !== false) { |
|
$this->subtaskTimeTrackingModel->updateTaskTimeTracking($values['task_id']); |
|
$this->queueManager->push($this->subtaskEventJob->withParams( |
|
$subtaskId, |
|
array(self::EVENT_CREATE_UPDATE, self::EVENT_CREATE) |
|
)); |
|
} |
|
|
|
return $subtaskId; |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function update(array $values, $fireEvent = true) |
|
{ |
|
$this->prepare($values); |
|
$updates = $values; |
|
unset($updates['id']); |
|
$result = $this->db->table(self::TABLE)->eq('id', $values['id'])->save($updates); |
|
|
|
if ($result) { |
|
$subtask = $this->getById($values['id']); |
|
$this->subtaskTimeTrackingModel->updateTaskTimeTracking($subtask['task_id']); |
|
|
|
if ($fireEvent) { |
|
$this->queueManager->push($this->subtaskEventJob->withParams( |
|
$subtask['id'], |
|
array(self::EVENT_CREATE_UPDATE, self::EVENT_UPDATE), |
|
$values |
|
)); |
|
} |
|
} |
|
|
|
return $result; |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function remove($subtaskId) |
|
{ |
|
$this->subtaskEventJob->execute($subtaskId, array(self::EVENT_DELETE)); |
|
|
|
$subtask = $this->getById($subtaskId); |
|
$result = $this->db->table(self::TABLE)->eq('id', $subtaskId)->remove(); |
|
|
|
$this->subtaskTimeTrackingModel->updateTaskTimeTracking($subtask['task_id']); |
|
|
|
return $result; |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function duplicate($srcTaskId, $dstTaskId) |
|
{ |
|
return $this->db->transaction(function (Database $db) use ($srcTaskId, $dstTaskId) { |
|
|
|
$subtasks = $db->table(SubtaskModel::TABLE) |
|
->columns('title', 'time_estimated', 'position','user_id') |
|
->eq('task_id', $srcTaskId) |
|
->asc('position') |
|
->findAll(); |
|
|
|
foreach ($subtasks as &$subtask) { |
|
$subtask['task_id'] = $dstTaskId; |
|
|
|
if (! $db->table(SubtaskModel::TABLE)->save($subtask)) { |
|
return false; |
|
} |
|
} |
|
}); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
protected function prepare(array &$values) |
|
{ |
|
$this->helper->model->removeFields($values, array('another_subtask')); |
|
$this->helper->model->resetFields($values, array('time_estimated', 'time_spent')); |
|
$this->hook->reference('model:subtask:modification:prepare', $values); |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
protected function prepareCreation(array &$values) |
|
{ |
|
$this->prepare($values); |
|
|
|
$values['position'] = $this->getLastPosition($values['task_id']) + 1; |
|
$values['status'] = isset($values['status']) ? $values['status'] : self::STATUS_TODO; |
|
$values['time_estimated'] = isset($values['time_estimated']) ? $values['time_estimated'] : 0; |
|
$values['time_spent'] = isset($values['time_spent']) ? $values['time_spent'] : 0; |
|
$values['user_id'] = isset($values['user_id']) ? $values['user_id'] : 0; |
|
$this->hook->reference('model:subtask:creation:prepare', $values); |
|
} |
|
} |
|
|