Backup #2071

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\Repository\TaskRepositoryInterface;
use Infrastructure\Persistence\TaskCommentRepository;

class UpdateTaskStatusUseCase
{
    public function __construct(
        private TaskRepositoryInterface $taskRepository,
        private TaskCommentRepository $commentRepository
    ) {
    }

    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");
        }

        $oldStatus = $task->getStatus();

        match ($newStatus) {
            'in_progress' => $task->start(),
            'completed' => $task->complete(),
            'failed' => $task->fail(),
            'cancelled' => $task->cancel(),
            'pending' => $task->retry(),
            default => throw new \InvalidArgumentException("Invalid status: {$newStatus}"),
        };

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

        $comment = TaskComment::createStatusChange(
            $taskId,
            $updatedBy,
            $updatedByType,
            $oldStatus->label(),
            $task->getStatus()->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