139 lines
4.4 KiB
PHP
139 lines
4.4 KiB
PHP
<?php
|
|
|
|
namespace App\Schedule;
|
|
|
|
use App\User\User;
|
|
use DateTimeImmutable;
|
|
use DateTimeZone;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class EloquentScheduleRepository implements ScheduleRepository
|
|
{
|
|
public function create(CreateScheduleDto $dto): Schedule
|
|
{
|
|
return DB::transaction(function () use ($dto): Schedule {
|
|
$model = ScheduleModel::create([
|
|
'user_id' => $dto->user->getId(),
|
|
'set_name' => $dto->setName,
|
|
'element_kind' => $dto->elementKind,
|
|
'start_date' => $dto->startDate->format('Y-m-d'),
|
|
'target_date' => $dto->targetDate->format('Y-m-d'),
|
|
]);
|
|
|
|
foreach ($dto->assignments as $assignmentDto) {
|
|
ScheduleAssignmentModel::create([
|
|
'schedule_id' => $model->id,
|
|
'element_name' => $assignmentDto->name,
|
|
'element_kind' => $assignmentDto->kind,
|
|
'element_path' => $assignmentDto->path,
|
|
'scheduled_date' => $assignmentDto->scheduledDate
|
|
->format('Y-m-d'),
|
|
'position' => $assignmentDto->position,
|
|
]);
|
|
}
|
|
|
|
return $this->toDomain($model, $dto->user);
|
|
});
|
|
}
|
|
|
|
public function findForUser(int $id, User $user): ?Schedule
|
|
{
|
|
$model = ScheduleModel::query()
|
|
->where('id', $id)
|
|
->where('user_id', $user->getId())
|
|
->first();
|
|
|
|
return $model === null ? null : $this->toDomain($model, $user);
|
|
}
|
|
|
|
public function findAllForUser(User $user): array
|
|
{
|
|
$models = ScheduleModel::query()
|
|
->where('user_id', $user->getId())
|
|
->orderByDesc('id')
|
|
->get();
|
|
$schedules = [];
|
|
|
|
foreach ($models as $model) {
|
|
$schedules[] = $this->toDomain($model, $user);
|
|
}
|
|
|
|
return $schedules;
|
|
}
|
|
|
|
public function findAssignmentsForUserOnDate(
|
|
User $user,
|
|
DateTimeImmutable $date,
|
|
): array {
|
|
$assignmentModels = ScheduleAssignmentModel::query()
|
|
->select('schedule_assignments.*')
|
|
->join(
|
|
'schedules',
|
|
'schedules.id',
|
|
'=',
|
|
'schedule_assignments.schedule_id',
|
|
)
|
|
->where('schedules.user_id', $user->getId())
|
|
->where('schedule_assignments.scheduled_date', $date->format(
|
|
'Y-m-d',
|
|
))
|
|
->with('schedule')
|
|
->orderByDesc('schedules.id')
|
|
->orderBy('schedule_assignments.position')
|
|
->orderBy('schedule_assignments.id')
|
|
->get();
|
|
$assignments = [];
|
|
|
|
foreach ($assignmentModels as $assignmentModel) {
|
|
$assignments[] = new AssignmentForDate(
|
|
scheduleId: $assignmentModel->schedule->id,
|
|
setName: $assignmentModel->schedule->set_name,
|
|
assignment: $this->assignmentToDomain($assignmentModel),
|
|
);
|
|
}
|
|
|
|
return $assignments;
|
|
}
|
|
|
|
private function toDomain(ScheduleModel $model, User $user): Schedule
|
|
{
|
|
$assignmentModels = ScheduleAssignmentModel::query()
|
|
->where('schedule_id', $model->id)
|
|
->orderBy('position')
|
|
->orderBy('id')
|
|
->get();
|
|
$assignments = [];
|
|
|
|
foreach ($assignmentModels as $assignmentModel) {
|
|
$assignments[] = $this->assignmentToDomain($assignmentModel);
|
|
}
|
|
|
|
return new Schedule(
|
|
id: $model->id,
|
|
user: $user,
|
|
setName: $model->set_name,
|
|
elementKind: $model->element_kind,
|
|
startDate: $this->date($model->start_date),
|
|
targetDate: $this->date($model->target_date),
|
|
assignments: $assignments,
|
|
);
|
|
}
|
|
|
|
private function assignmentToDomain(
|
|
ScheduleAssignmentModel $model,
|
|
): ScheduleAssignment {
|
|
return new ScheduleAssignment(
|
|
id: $model->id,
|
|
name: $model->element_name,
|
|
kind: $model->element_kind,
|
|
path: $model->element_path,
|
|
scheduledDate: $this->date($model->scheduled_date),
|
|
position: $model->position,
|
|
);
|
|
}
|
|
|
|
private function date(string $value): DateTimeImmutable
|
|
{
|
|
return new DateTimeImmutable($value, new DateTimeZone('UTC'));
|
|
}
|
|
}
|