Backup #830

Dateiinhalt

<?php

declare(strict_types=1);

namespace UseCases\Task;

// @responsibility: Aktualisiert Task-Status mit Workflow-Validierung

use Domain\Entity\Task;
use Domain\Entity\TaskComment;
use Domain\ValueObject\TaskStatus;
use Infrastructure\Persistence\TaskCommentRepository;
use Infrastructure\Persistence\TaskRepository;

class UpdateTaskStatusUseCase
{
    private TaskRepository $taskRepository;
    private TaskCommentRepository $commentRepository;

    public function __construct(
        ?TaskRepository $taskRepository = null,
        ?TaskCommentRepository $commentRepository = null
    ) {
        $this->taskRepository = $taskRepository ?? new TaskRepository();
        $this->commentRepository = $commentRepository ?? new TaskCommentRepository();
    }

    public function execute(int $taskId, string $newStatus, string $updatedBy, string $updatedByType = 'human'): Task
    {
        $task = $this->taskRepository->find($taskId);
        if ($task === null) {
            throw new \InvalidArgumentException("Task {$taskId} not found");
        }

        $newStatusEnum = TaskStatus::from($newStatus);
        $oldStatus = $task->getStatus();

        if (!$oldStatus->canTransitionTo($newStatusEnum)) {
            throw new \InvalidArgumentException(
                "Cannot transition from {$oldStatus->value} to {$newStatus}"
            );
        }

        $task->setStatus($newStatusEnum);
        $this->taskRepository->update($task);

        $comment = TaskComment::createStatusChange(
            $taskId,
            $updatedBy,
            $updatedByType,
            $oldStatus->label(),
            $newStatusEnum->label()
        );
        $this->commentRepository->save($comment);

        return $task;
    }

    public function startTask(int $taskId, string $updatedBy, string $updatedByType = 'human'): Task
    {
        return $this->execute($taskId, 'in_progress', $updatedBy, $updatedByType);
    }

    public function completeTask(int $taskId, string $updatedBy, string $updatedByType = 'human'): Task
    {
        return $this->execute($taskId, 'completed', $updatedBy, $updatedByType);
    }

    public function failTask(int $taskId, string $updatedBy, string $updatedByType = 'human'): Task
    {
        return $this->execute($taskId, 'failed', $updatedBy, $updatedByType);
    }

    public function cancelTask(int $taskId, string $updatedBy, string $updatedByType = 'human'): Task
    {
        return $this->execute($taskId, 'cancelled', $updatedBy, $updatedByType);
    }
}

Vollständig herunterladen

Aktionen

Andere Versionen dieser Datei

← Zurück zur Übersicht