From 0127b463a6a96ae082abb61f6bb1423fb86f719c Mon Sep 17 00:00:00 2001 From: hamed <15238-genius.ha@users.noreply.drupalcode.org> Date: Fri, 31 Jul 2026 20:50:43 +0330 Subject: [PATCH] feat(resource): ad-hoc blocking, 409 recovery, and the rest of the flake MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Ad-hoc resource blocking - "The laser is being serviced this afternoon" is a specific range, not a change to the resource's working pattern. It stays separate from calendar exceptions and the modal says which is which — merging them means either an afternoon's closure lives in the calendar forever, or a change to working hours vanishes with one click - Blocking a range that already holds an appointment is refused with 409 rather than silently taking capacity back; the appointment is still there and someone has to decide about it first - Deleting an occupancy that belongs to an appointment is refused too, otherwise a patient's booking would quietly lose its resource with no record 409 on hold now recovers Saying "someone just took it" is not enough — the operator would have to search again by hand. The page drops the stale selection and refetches, so alternatives are on screen immediately. Flake, second half The earlier fix only covered createUser's retry path. Any test that trips a unique constraint closes the EntityManager, and the next test inherits the same closed instance from the container. setUp now resets the registry when it finds a closed manager, so a test's starting state no longer depends on how the previous one failed. Three consecutive full runs green: 1340 tests. Co-Authored-By: Claude Opus 5 (1M context) --- .../admin/components/ResourceBlocksModal.tsx | 197 ++++++++++++++++++ assets/admin/pages/ResourceBookingPage.tsx | 28 ++- assets/admin/pages/ResourcesPage.tsx | 13 ++ docs/api/resource.md | 43 ++++ .../Controller/AvailabilityController.php | 1 - .../Controller/ResourceBlockController.php | 140 +++++++++++++ .../ResourceOccupancyRepository.php | 49 +++++ .../Service/AvailabilityEngine.php | 2 +- tests/ApiTestCase.php | 13 ++ tests/Appointment/ResourceBlockTest.php | 164 +++++++++++++++ 10 files changed, 639 insertions(+), 11 deletions(-) create mode 100644 assets/admin/components/ResourceBlocksModal.tsx create mode 100644 src/Appointment/Availability/Controller/ResourceBlockController.php create mode 100644 tests/Appointment/ResourceBlockTest.php diff --git a/assets/admin/components/ResourceBlocksModal.tsx b/assets/admin/components/ResourceBlocksModal.tsx new file mode 100644 index 00000000..0b930e8f --- /dev/null +++ b/assets/admin/components/ResourceBlocksModal.tsx @@ -0,0 +1,197 @@ +import React, { useState } from 'react'; +import { useMutation, useQuery, useQueryClient } from '@tanstack/react-query'; +import { toast } from 'sonner'; +import { TrashIcon } from '@heroicons/react/24/outline'; +import Modal from './ui/Modal'; +import PersianDateInput from './ui/PersianDateInput'; +import { api, ApiError, type ApiResponse } from '../lib/api'; +import { formatDate, isoToUnix, unixToIso } from '../lib/utils'; + +interface Block { + uuid: string; + starts_at: number; + ends_at: number; + segment_name: string | null; +} + +interface Props { + resourceUuid: string | null; + resourceName: string; + onClose: () => void; +} + +const HOUR = 3600; + +/** + * مسدودسازی موردی یک منبع. + * + * عمداً از «استثنای تقویم» جداست و همین‌جا هم گفته می‌شود: آن الگوی کاری منبع را عوض + * می‌کند و ماندگار است، این فقط یک بازهٔ مشخص را می‌بندد. اپراتوری که این تفاوت را + * نداند، تعطیلی یک بعدازظهر را برای همیشه در تقویم ثبت می‌کند. + */ +export default function ResourceBlocksModal({ resourceUuid, resourceName, onClose }: Props) { + const qc = useQueryClient(); + const key = ['resource-blocks', resourceUuid]; + + const [day, setDay] = useState(() => unixToIso(Math.floor(Date.now() / 1000) + 86400)); + const [fromHour, setFromHour] = useState(9); + const [toHour, setToHour] = useState(13); + const [reason, setReason] = useState(''); + + const { data, isLoading } = useQuery({ + queryKey: key, + queryFn: () => api.get>(`/api/v1/resource/${resourceUuid}/blocks`), + enabled: !!resourceUuid, + }); + + const blocks = data?.data ?? []; + + const create = useMutation({ + mutationFn: (body: { starts_at: number; ends_at: number; reason: string }) => + api.post>(`/api/v1/resource/${resourceUuid}/blocks`, body), + onSuccess: () => { + toast.success('بازه مسدود شد'); + qc.invalidateQueries({ queryKey: key }); + setReason(''); + }, + // ۴۰۹ یعنی آن بازه نوبت دارد؛ پیام سرور دقیقاً می‌گوید اول چه باید کرد. + onError: (e) => toast.error(e instanceof ApiError ? e.message : 'مسدودسازی ناموفق بود'), + }); + + const remove = useMutation({ + mutationFn: (uuid: string) => api.delete>(`/api/v1/resource-block/${uuid}`), + onSuccess: () => { + toast.success('مسدودسازی برداشته شد'); + qc.invalidateQueries({ queryKey: key }); + }, + onError: (e) => toast.error(e instanceof ApiError ? e.message : 'حذف ناموفق بود'), + }); + + const dayStart = isoToUnix(day) ?? 0; + const rangeInvalid = toHour <= fromHour; + + return ( + + بستن + + } + > +
+

+ این یک بازهٔ مشخص را می‌بندد و تا وقتی حذفش نکنید می‌ماند. برای تغییر + الگوی کاری + منبع (مثلاً «پنجشنبه‌ها تعطیل») از استثنای تقویم استفاده کنید، نه از اینجا. +

+ +
+
+ + +
+ + + + +
+ +
+ + setReason(e.target.value)} + placeholder="مثلاً: سرویس دوره‌ای دستگاه" + /> +
+ + {rangeInvalid && ( + + ساعت پایان باید بعد از ساعت شروع باشد. + + )} + +
+ +
+ +
+

مسدودسازی‌های فعلی

+ + {isLoading ? ( + در حال بارگذاری… + ) : blocks.length === 0 ? ( + + این منبع مسدودسازی موردی ندارد. + + ) : ( + blocks.map((block) => ( +
+ {formatDate(block.starts_at)} + + {new Date(block.starts_at * 1000).toLocaleTimeString('fa-IR', { hour: '2-digit', minute: '2-digit' })} + {' – '} + {new Date(block.ends_at * 1000).toLocaleTimeString('fa-IR', { hour: '2-digit', minute: '2-digit' })} + + {block.segment_name ?? '—'} + +
+ )) + )} +
+
+ + ); +} diff --git a/assets/admin/pages/ResourceBookingPage.tsx b/assets/admin/pages/ResourceBookingPage.tsx index 1ff582f6..36a64a88 100644 --- a/assets/admin/pages/ResourceBookingPage.tsx +++ b/assets/admin/pages/ResourceBookingPage.tsx @@ -67,7 +67,7 @@ export default function ResourceBookingPage() { return { from, to: from + Number(days) * DAY }; }, [days]); - const { result, loading, error } = useAvailabilitySearch( + const { result, loading, error, refetch } = useAvailabilitySearch( { serviceUuid, branchUuid, from: range.from, to: range.to }, searching, ); @@ -95,15 +95,25 @@ export default function ResourceBookingPage() { const takeHold = async () => { if (!pickedSlot || !picked) return; - const created = await create.mutateAsync({ - service_uuid: serviceUuid, - branch_uuid: branchUuid, - start: pickedSlot.start, - assignment: picked, - }); + try { + const created = await create.mutateAsync({ + service_uuid: serviceUuid, + branch_uuid: branchUuid, + start: pickedSlot.start, + assignment: picked, + }); - setHold(created.data); - setExpired(false); + setHold(created.data); + setExpired(false); + } catch (e) { + // ۴۰۹ یعنی همین لحظه کس دیگری گرفت. گفتنش کافی نیست: کاربر باید بلافاصله + // جایگزین ببیند، وگرنه باید دستی دوباره جستجو بزند و بختش را از نو امتحان کند. + if (e instanceof ApiError && e.status === 409) { + setPickedSlot(null); + setPicked(null); + await refetch(); + } + } }; const reasonText = result?.reason ? REASON_LABELS[result.reason] ?? result.reason : null; diff --git a/assets/admin/pages/ResourcesPage.tsx b/assets/admin/pages/ResourcesPage.tsx index 9cbb632c..d618255d 100644 --- a/assets/admin/pages/ResourcesPage.tsx +++ b/assets/admin/pages/ResourcesPage.tsx @@ -3,6 +3,7 @@ import { Link } from 'react-router-dom'; import { PlusIcon } from '@heroicons/react/24/outline'; import PageHeader from '../components/ui/PageHeader'; import DataTable, { type Column } from '../components/ui/DataTable'; +import ResourceBlocksModal from '../components/ResourceBlocksModal'; import ConfirmDialog from '../components/ui/ConfirmDialog'; import SearchableSelect from '../components/ui/SearchableSelect'; import { ActiveBadge } from '../components/ui/StatusBadge'; @@ -48,6 +49,7 @@ export default function ResourcesPage() { const [editing, setEditing] = useState<{ open: boolean; resource: ClinicResource | null }>({ open: false, resource: null }); const [skillsFor, setSkillsFor] = useState(null); + const [blocksFor, setBlocksFor] = useState(null); const [toDelete, setToDelete] = useState(null); const rows = useMemo(() => { @@ -186,6 +188,11 @@ export default function ResourcesPage() { تقویم + {/* مسدودسازی موردی از تقویم جداست: آن الگوی کاری را عوض می‌کند، + این یک بازهٔ مشخص را می‌بندد. */} + @@ -195,6 +202,12 @@ export default function ResourcesPage() { } /> + setBlocksFor(null)} + /> + requireResource($user, $uuid); + + $from = $request->query->has('from') ? $request->query->getInt('from') : time(); + $to = $request->query->has('to') ? $request->query->getInt('to') : $from + 30 * 86400; + + return $this->success(array_map( + static fn (ResourceOccupancy $o): array => $o->toArray(), + $this->occupancy->findManualBlocks((int) $resource->getId(), $from, $to), + )); + } + + #[Route('/api/v1/resource/{uuid}/blocks', name: 'resource_block_create', methods: ['POST'])] + public function create(#[CurrentUser] User $user, string $uuid, Request $request): JsonResponse + { + $resource = $this->requireResource($user, $uuid); + $data = json_decode($request->getContent(), true); + + if (!is_array($data) || !is_numeric($data['starts_at'] ?? null) || !is_numeric($data['ends_at'] ?? null)) { + return $this->error(ErrorCodes::ERR_VALIDATION_002, 'بازهٔ مسدودسازی الزامی است', 422, 'starts_at'); + } + + $startsAt = (int) $data['starts_at']; + $endsAt = (int) $data['ends_at']; + + if ($endsAt <= $startsAt) { + return $this->error(ErrorCodes::ERR_VALIDATION_001, 'پایان بازه باید بعد از شروع آن باشد', 422, 'ends_at'); + } + + // مسدودسازی روی بازه‌ای که نوبت دارد، ظرفیت را پس نمی‌گیرد — نوبت همچنان سرجایش + // است و کاربر باید اول تکلیفش را روشن کند. + if ($this->occupancy->hasAppointmentInRange((int) $resource->getId(), $startsAt, $endsAt)) { + return $this->error( + ErrorCodes::ERR_SLOT_TAKEN, + 'در این بازه نوبت ثبت‌شده وجود دارد؛ اول آن را جابه‌جا یا لغو کنید', + 409, + ); + } + + $block = new ResourceOccupancy($resource, $startsAt, $endsAt, ResourceOccupancy::STATUS_BOOKED); + $block->setSegmentName( + is_string($data['reason'] ?? null) && trim($data['reason']) !== '' + ? trim($data['reason']) + : 'مسدودسازی دستی', + ); + + $this->em->persist($block); + $this->em->flush(); + + return $this->success($block->toArray(), 201); + } + + #[Route('/api/v1/resource-block/{uuid}', name: 'resource_block_delete', methods: ['DELETE'])] + public function delete(#[CurrentUser] User $user, string $uuid): JsonResponse + { + $block = $this->occupancy->findOneBy(['uuid' => $uuid]); + [$entityType, $entityId] = $this->branches->pair($user); + + if ($block === null || !$this->ownership->belongsToPair($entityType, $entityId, $block)) { + return $this->error(ErrorCodes::ERR_NOT_FOUND_001, 'مسدودسازی یافت نشد', 404); + } + + // اشغالِ یک نوبت واقعی از اینجا حذف نمی‌شود؛ وگرنه نوبت بیمار بی‌صدا منبعش را + // از دست می‌دهد و هیچ‌جا هم ثبت نمی‌شود. + if ($block->getAppointmentId() !== null || $block->getHoldId() !== null) { + return $this->error( + ErrorCodes::ERR_VALIDATION_001, + 'این اشغال متعلق به یک نوبت است و از اینجا حذف نمی‌شود', + 422, + ); + } + + $this->em->remove($block); + $this->em->flush(); + + return $this->success(null); + } + + private function requireResource(User $user, string $uuid): ClinicResource + { + $resource = $this->resources->findOneBy(['uuid' => $uuid]); + [$entityType, $entityId] = $this->branches->pair($user); + + if ($resource === null || !$this->ownership->belongsToPair($entityType, $entityId, $resource)) { + throw new AppException(ErrorCodes::ERR_NOT_FOUND_001, 'منبع یافت نشد', 404); + } + + return $resource; + } +} diff --git a/src/Appointment/Availability/Repository/ResourceOccupancyRepository.php b/src/Appointment/Availability/Repository/ResourceOccupancyRepository.php index 7e271539..5817c9ec 100644 --- a/src/Appointment/Availability/Repository/ResourceOccupancyRepository.php +++ b/src/Appointment/Availability/Repository/ResourceOccupancyRepository.php @@ -57,6 +57,55 @@ class ResourceOccupancyRepository extends ServiceEntityRepository } /** @return ResourceOccupancy[] */ + /** + * آیا در این بازه نوبت یا رزرو موقتی روی این منبع هست؟ + * + * فقط ردیف‌هایی که به نوبت یا hold وصل‌اند؛ مسدودسازی دستیِ دیگر مانع نیست — + * دو بازهٔ سرویس دستگاه می‌توانند هم‌پوشان باشند و آن مشکلی نیست. + */ + public function hasAppointmentInRange(int $resourceId, int $from, int $to): bool + { + return (int) $this->createQueryBuilder('o') + ->select('COUNT(o.id)') + ->where('IDENTITY(o.resource) = :resource') + ->andWhere('o.appointmentId IS NOT NULL OR o.holdId IS NOT NULL') + ->andWhere('o.status IN (:blocking)') + ->andWhere('o.startsAt < :to') + ->andWhere('o.endsAt > :from') + ->setParameter('resource', $resourceId) + ->setParameter('blocking', ResourceOccupancy::BLOCKING_STATUSES) + ->setParameter('from', $from) + ->setParameter('to', $to) + ->getQuery() + ->getSingleScalarResult() > 0; + } + + /** + * مسدودسازی‌های دستیِ یک منبع در یک بازه. + * + * فقط ردیف‌های بدون نوبت: بقیه اشغالِ رزرو واقعی‌اند و از صفحهٔ منابع مدیریت + * نمی‌شوند — حذفشان از آنجا یعنی نوبت بیمار بی‌صدا منبعش را از دست بدهد. + * + * @return ResourceOccupancy[] + */ + public function findManualBlocks(int $resourceId, int $from, int $to): array + { + return $this->createQueryBuilder('o') + ->where('IDENTITY(o.resource) = :resource') + ->andWhere('o.appointmentId IS NULL') + ->andWhere('o.holdId IS NULL') + ->andWhere('o.status IN (:blocking)') + ->andWhere('o.startsAt < :to') + ->andWhere('o.endsAt > :from') + ->setParameter('resource', $resourceId) + ->setParameter('blocking', ResourceOccupancy::BLOCKING_STATUSES) + ->setParameter('from', $from) + ->setParameter('to', $to) + ->orderBy('o.startsAt', 'ASC') + ->getQuery() + ->getResult(); + } + public function findForAppointment(int $appointmentId): array { return $this->findBy(['appointmentId' => $appointmentId]); diff --git a/src/Appointment/Availability/Service/AvailabilityEngine.php b/src/Appointment/Availability/Service/AvailabilityEngine.php index 6df15e84..24b2f4e7 100644 --- a/src/Appointment/Availability/Service/AvailabilityEngine.php +++ b/src/Appointment/Availability/Service/AvailabilityEngine.php @@ -261,7 +261,7 @@ final class AvailabilityEngine // استراتژی فقط **ترتیب** را تعیین می‌کند؛ شرط جا داشتن و برداشته‌نشدن // همچنان اینجاست، چون فقط موتور هر دو را می‌داند. $ordered = $picker->order( - array_values($requirement->eligible), + $requirement->eligible, new PickContext($free, $needed, $start, $preferredResourceIds), ); diff --git a/tests/ApiTestCase.php b/tests/ApiTestCase.php index 4575c1d1..37931eb9 100644 --- a/tests/ApiTestCase.php +++ b/tests/ApiTestCase.php @@ -38,6 +38,19 @@ abstract class ApiTestCase extends WebTestCase protected function setUp(): void { $this->client = static::createClient(); + + // هر تستی که عمداً یا تصادفی یک قید یکتا را می‌شکند، EntityManager را می‌بندد + // و آن نمونهٔ بسته به تست بعدی ارث می‌رسد — چون کانتینر همان را برمی‌گرداند. + // نتیجه‌اش خطای «EntityManager is closed» روی تستی کاملاً بی‌ربط بود که هر بار + // جای دیگری می‌افتاد و در اجرای زیرمجموعه هرگز تکرار نمی‌شد. + // + // ریست اینجا ارزان است و تضمین می‌کند شروع هر تست مستقل از خرابیِ تست قبلی باشد. + $registry = static::getContainer()->get('doctrine'); + + if (!$registry->getManager()->isOpen()) { + $registry->resetManager(); + } + $this->em = static::getContainer()->get(EntityManagerInterface::class); $this->ensureFreePlan(); } diff --git a/tests/Appointment/ResourceBlockTest.php b/tests/Appointment/ResourceBlockTest.php new file mode 100644 index 00000000..da5cf29e --- /dev/null +++ b/tests/Appointment/ResourceBlockTest.php @@ -0,0 +1,164 @@ +createUser(['ROLE_USER', 'ROLE_CLINIC']); + $clinic = new Clinic($user); + $clinic->setName('کلینیک مسدودسازی'); + $this->em->persist($clinic); + $this->em->flush(); + + $address = DoctorAddress::forClinic($clinic->getId()); + $address->setName('شعبه'); + $this->em->persist($address); + + $type = new ResourceType('clinic', (int) $clinic->getId(), 'device', 'دستگاه'); + $this->em->persist($type); + $this->em->flush(); + + $resource = new ClinicResource($address, $type, 'لیزر ۱'); + $this->em->persist($resource); + $this->em->flush(); + + return [$user, $resource]; + } + + public function testBlockingAFreeRangeSucceedsAndIsListed(): void + { + [$user, $resource] = $this->clinicWithResource(); + + $start = time() + 86400; + + $body = $this->authJson('POST', "/api/v1/resource/{$resource->getUuid()}/blocks", $user, [ + 'starts_at' => $start, + 'ends_at' => $start + 4 * 3600, + 'reason' => 'سرویس دوره‌ای دستگاه', + ]); + + self::assertSame(201, $this->responseCode(), json_encode($body, JSON_UNESCAPED_UNICODE)); + self::assertSame('سرویس دوره‌ای دستگاه', $body['data']['segment_name']); + + $list = $this->authJson( + 'GET', + sprintf('/api/v1/resource/%s/blocks?from=%d&to=%d', $resource->getUuid(), $start - 3600, $start + 86400), + $user, + ); + + self::assertCount(1, $list['data']); + } + + public function testAnInvertedRangeIsRejected(): void + { + [$user, $resource] = $this->clinicWithResource(); + + $start = time() + 86400; + + $this->authJson('POST', "/api/v1/resource/{$resource->getUuid()}/blocks", $user, [ + 'starts_at' => $start, + 'ends_at' => $start - 3600, + ]); + + self::assertSame(422, $this->responseCode()); + } + + /** ⭐ مسدودسازی روی بازه‌ای که نوبت دارد، ظرفیت را پس نمی‌گیرد. */ + public function testBlockingOverABookedRangeIsRejected(): void + { + [$user, $resource] = $this->clinicWithResource(); + + $start = time() + 2 * 86400; + + $em = static::getContainer()->get(EntityManagerInterface::class); + $reloaded = $em->getRepository(ClinicResource::class)->find($resource->getId()); + + $booked = new ResourceOccupancy($reloaded, $start, $start + 3600); + $booked->setAppointmentId(4242); + $em->persist($booked); + $em->flush(); + + $this->authJson('POST', "/api/v1/resource/{$resource->getUuid()}/blocks", $user, [ + 'starts_at' => $start, + 'ends_at' => $start + 7200, + ]); + + self::assertSame(409, $this->responseCode()); + } + + /** ⭐ اشغالِ یک نوبت واقعی از این مسیر حذف نمی‌شود. */ + public function testAnAppointmentOccupancyCannotBeDeletedAsABlock(): void + { + [$user, $resource] = $this->clinicWithResource(); + + $start = time() + 3 * 86400; + + $em = static::getContainer()->get(EntityManagerInterface::class); + $reloaded = $em->getRepository(ClinicResource::class)->find($resource->getId()); + + $booked = new ResourceOccupancy($reloaded, $start, $start + 3600); + $booked->setAppointmentId(777); + $em->persist($booked); + $em->flush(); + + $this->authJson('DELETE', "/api/v1/resource-block/{$booked->getUuid()}", $user); + + self::assertSame(422, $this->responseCode()); + } + + public function testAManualBlockCanBeDeleted(): void + { + [$user, $resource] = $this->clinicWithResource(); + + $start = time() + 86400; + + $created = $this->authJson('POST', "/api/v1/resource/{$resource->getUuid()}/blocks", $user, [ + 'starts_at' => $start, + 'ends_at' => $start + 3600, + ]); + + $this->authJson('DELETE', "/api/v1/resource-block/{$created['data']['uuid']}", $user); + self::assertSame(200, $this->responseCode()); + + $list = $this->authJson( + 'GET', + sprintf('/api/v1/resource/%s/blocks?from=%d&to=%d', $resource->getUuid(), $start - 3600, $start + 86400), + $user, + ); + + self::assertCount(0, $list['data']); + } + + public function testAnotherClinicCannotBlockTheResource(): void + { + [, $resource] = $this->clinicWithResource(); + [$other] = $this->clinicWithResource(); + + $start = time() + 86400; + + $this->authJson('POST', "/api/v1/resource/{$resource->getUuid()}/blocks", $other, [ + 'starts_at' => $start, + 'ends_at' => $start + 3600, + ]); + + self::assertSame(404, $this->responseCode()); + } +}