TaskAssignmentRepository.php

• Pfad: src/Infrastructure/Persistence/TaskAssignmentRepository.php
• Namespace: Infrastructure\Persistence
• Zeilen: 139 | Größe: 4,237 Bytes
• Geändert: 2025-12-25 12:51:03 | Gescannt: 2025-12-31 10:22:15

Code Hygiene Score: 100

• Dependencies: 100 (25%)
• LOC: 100 (20%)
• Methods: 100 (20%)
• Secrets: 100 (15%)
• Classes: 100 (10%)
• Magic Numbers: 100 (10%)

Keine Issues gefunden.

Dependencies 4

• implements Domain\Repository\TaskAssignmentRepositoryInterface
• constructor PDO
• use Domain\Entity\TaskAssignment
• use Domain\Repository\TaskAssignmentRepositoryInterface

Klassen 1

• TaskAssignmentRepository class Zeile 12

Funktionen 8

• __construct() public Zeile 16
• find() public Zeile 21
• findByTaskId() public Zeile 30
• findByAssignee() public Zeile 45
• findActiveByAssignee() public Zeile 62
• save() public Zeile 79
• update() public Zeile 111
• delete() public Zeile 132

Verwendet von 5

• AssignTaskUseCase.php use
• AssignTaskUseCase.php constructor
• GetTasksUseCase.php constructor
• GetTasksUseCase.php use
• TaskServiceProvider.php use

Versionen 5

• v5 2025-12-25 12:51 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation
• v4 2025-12-25 10:32 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation
• v3 2025-12-25 10:32 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation
• v2 2025-12-23 08:04 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation
• v1 2025-12-22 10:11 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation

Code

<?php

declare(strict_types=1);

namespace Infrastructure\Persistence;

// @responsibility: Persistenz für Task-Zuweisungen (human, AI)

use Domain\Entity\TaskAssignment;
use Domain\Repository\TaskAssignmentRepositoryInterface;

class TaskAssignmentRepository implements TaskAssignmentRepositoryInterface
{
    private \PDO $pdo;

    public function __construct(\PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    public function find(int $id): ?TaskAssignment
    {
        $stmt = $this->pdo->prepare('SELECT * FROM task_assignments WHERE id = :id');
        $stmt->execute(['id' => $id]);
        $row = $stmt->fetch();

        return $row !== false ? TaskAssignment::fromArray($row) : null;
    }

    public function findByTaskId(int $taskId): array
    {
        $stmt = $this->pdo->prepare(
            'SELECT * FROM task_assignments WHERE task_id = :task_id ORDER BY assigned_at DESC'
        );
        $stmt->execute(['task_id' => $taskId]);

        $assignments = [];
        while ($row = $stmt->fetch()) {
            $assignments[] = TaskAssignment::fromArray($row);
        }

        return $assignments;
    }

    public function findByAssignee(string $assignee, int $limit = 50): array
    {
        $stmt = $this->pdo->prepare(
            'SELECT * FROM task_assignments WHERE assignee = :assignee ORDER BY assigned_at DESC LIMIT :limit'
        );
        $stmt->bindValue(':assignee', $assignee);
        $stmt->bindValue(':limit', $limit, \PDO::PARAM_INT);
        $stmt->execute();

        $assignments = [];
        while ($row = $stmt->fetch()) {
            $assignments[] = TaskAssignment::fromArray($row);
        }

        return $assignments;
    }

    public function findActiveByAssignee(string $assignee): array
    {
        $stmt = $this->pdo->prepare(
            "SELECT * FROM task_assignments
             WHERE assignee = :assignee AND status IN ('pending', 'accepted', 'in_progress')
             ORDER BY assigned_at DESC"
        );
        $stmt->execute(['assignee' => $assignee]);

        $assignments = [];
        while ($row = $stmt->fetch()) {
            $assignments[] = TaskAssignment::fromArray($row);
        }

        return $assignments;
    }

    public function save(TaskAssignment $assignment): int
    {
        $sql = 'INSERT INTO task_assignments (
            task_id, assignee, assignee_type, model_name,
            assigned_by, assigned_by_type, status,
            assigned_at, accepted_at, completed_at, notes
        ) VALUES (
            :task_id, :assignee, :assignee_type, :model_name,
            :assigned_by, :assigned_by_type, :status,
            :assigned_at, :accepted_at, :completed_at, :notes
        )';

        $stmt = $this->pdo->prepare($sql);
        $data = $assignment->toArray();

        $stmt->execute([
            'task_id' => $data['task_id'],
            'assignee' => $data['assignee'],
            'assignee_type' => $data['assignee_type'],
            'model_name' => $data['model_name'],
            'assigned_by' => $data['assigned_by'],
            'assigned_by_type' => $data['assigned_by_type'],
            'status' => $data['status'],
            'assigned_at' => $data['assigned_at'],
            'accepted_at' => $data['accepted_at'],
            'completed_at' => $data['completed_at'],
            'notes' => $data['notes'],
        ]);

        return (int) $this->pdo->lastInsertId();
    }

    public function update(TaskAssignment $assignment): bool
    {
        $sql = 'UPDATE task_assignments SET
            status = :status,
            accepted_at = :accepted_at,
            completed_at = :completed_at,
            notes = :notes
        WHERE id = :id';

        $stmt = $this->pdo->prepare($sql);
        $data = $assignment->toArray();

        return $stmt->execute([
            'id' => $data['id'],
            'status' => $data['status'],
            'accepted_at' => $data['accepted_at'],
            'completed_at' => $data['completed_at'],
            'notes' => $data['notes'],
        ]);
    }

    public function delete(int $id): bool
    {
        $stmt = $this->pdo->prepare('DELETE FROM task_assignments WHERE id = :id');

        return $stmt->execute(['id' => $id]);
    }
}