feat(pricing): date-ranged price lists and immutable appointment invoices

Section 12 and the fifth closing rule: changing a price never changes an
already-booked appointment.

The pricing chain already existed and worked. Two things were missing. Tariff only
carries a year, so a rate change starting in Mehr could not be expressed — PriceList
now takes an explicit date range and Tariff remains the layer beneath it. And an
appointment stored a single number, so after a price change or a discount nobody
could say what those 2,400,000 rials were made of.

Price resolution walks four layers per service and takes the first hit: branch
override, then the covering price list, then the yearly tariff, then the service's own
price. The last one is the guarantee that a date no list covers still returns a price
rather than zero or an exception. breakdown.sources reports which layer answered, so a
surprising number can be traced instead of guessed at.

Two calculation decisions worth stating. Tax is computed on the patient's share, not
the gross — a patient does not pay tax on the portion the insurer covers. And a
discount larger than the amount floors the total at zero rather than going negative,
because a negative balance would mean the clinic owes the patient money, which nothing
downstream is built to mean.

A branch-specific list deliberately does not count as overlapping a general one; it
takes precedence instead. Treating them as a conflict would have made per-branch
exceptions impossible to express. Lists have no effect until activated, so drafting
next quarter's prices cannot disturb today's.

PriceSnapshot has no setters and a unique key on appointment_id: a snapshot that can
be edited is not a snapshot, and two invoices for one appointment would be two truths.
Corrections are a new row plus voiding the old one. Invoices are written during
confirm with the prices of that moment — computing later would let a rate change
between booking and invoicing produce a different number, which is exactly what rule
five forbids.

12 tests. The one that matters is
testBookedAppointmentKeepsItsOriginalInvoiceAfterAPriceChange: book, double the
service price, watch quote return the new number while the appointment's invoice
returns the old one. Without it rule five is only a claim.

1220 tests / 3551 assertions. phpstan back at its 14-error baseline. Frozen slot
contract green.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
This commit is contained in:
hamed
2026-07-31 09:42:21 +03:30
co-authored by Claude Opus 5
parent cd12fabe14
commit 34b07421bd
17 changed files with 1765 additions and 66 deletions
@@ -9,6 +9,9 @@ use App\Appointment\Booking\Service\HoldService;
use App\Appointment\Entity\Appointment;
use App\Auth\Repository\UserRepository;
use App\Doctor\Repository\DoctorRepository;
use App\Pricing\Entity\PriceSnapshot;
use App\Pricing\Service\PriceSnapshotService;
use App\Pricing\Service\PricingEngine;
use App\Appointment\Plan\Service\AppointmentPlanBuilder;
use App\Auth\Entity\User;
use App\Branch\Service\BranchResolver;
@@ -44,6 +47,8 @@ class BookingController extends BaseController
private readonly ClinicResourceRepository $resources,
private readonly DoctorRepository $doctors,
private readonly UserRepository $users,
private readonly PricingEngine $pricing,
private readonly PriceSnapshotService $snapshots,
private readonly BranchResolver $branches,
private readonly TenantOwnershipChecker $ownership,
private readonly EntityManagerInterface $em,
@@ -143,8 +148,14 @@ class BookingController extends BaseController
$this->booking->confirm($hold, $appointment);
// فاکتور همین‌جا و با قیمت‌های همین لحظه ثبت می‌شود. اگر بعداً محاسبه می‌شد،
// تغییر تعرفه بین ثبت و صدور فاکتور، عدد دیگری می‌داد — دقیقاً چیزی که قانون
// پنجم مستند ممنوع کرده است.
$snapshot = $this->recordPrice($user, $hold, $appointment, $data);
return $this->success([
'appointment_uuid' => $appointment->getUuid(),
'price_snapshot' => $snapshot->toArray(),
'starts_at' => $hold->getStartsAt(),
'ends_at' => $hold->getEndsAt(),
'assignment' => $hold->getPayload()['assignment'] ?? [],
@@ -188,6 +199,40 @@ class BookingController extends BaseController
]);
}
/**
* فاکتور تفکیک‌شده. اگر سرویس پیدا نشد (نوبت ویزیت ساده)، فاکتور با همان
* `visit_price_rials` موجود ساخته می‌شود؛ خالی گذاشتنش یعنی گزارش مالی یک ردیف
* کم دارد.
*
* @param array<string, mixed> $data
*/
private function recordPrice(User $user, AppointmentHold $hold, Appointment $appointment, array $data): PriceSnapshot
{
if (!is_string($data['service_uuid'] ?? null) || !is_string($data['branch_uuid'] ?? null)) {
return $this->snapshots->recordFlatVisit($appointment, (int) $appointment->getVisitPriceRials());
}
$service = $this->requireItem($user, $data['service_uuid']);
$address = $this->branches->resolve($user, $data['branch_uuid']);
$items = [];
foreach (($data['item_uuids'] ?? []) as $itemUuid) {
if (is_string($itemUuid)) {
$items[] = $this->requireItem($user, $itemUuid);
}
}
$quote = $this->pricing->quote(
$service,
$items,
$address,
$hold->getStartsAt(),
is_array($data['policy'] ?? null) ? $data['policy'] : [],
);
return $this->snapshots->record($appointment, $quote);
}
/**
* هر نیازمندی باید در `assignment` منبع داشته باشد. بدون این، رزرو موقت
* می‌توانست نصفِ منابع لازم را بگیرد و بقیه هنگام حضور بیمار کم بیاید.
@@ -0,0 +1,264 @@
<?php
namespace App\Pricing\Controller;
use App\Appointment\Entity\Appointment;
use App\Auth\Entity\User;
use App\Branch\Service\BranchResolver;
use App\ClinicService\Entity\ServiceItem;
use App\ClinicService\Repository\ServiceItemRepository;
use App\Pricing\Entity\PriceList;
use App\Pricing\Entity\PriceListItem;
use App\Pricing\Repository\PriceListItemRepository;
use App\Pricing\Repository\PriceListRepository;
use App\Pricing\Repository\PriceSnapshotRepository;
use App\Pricing\Service\PricingEngine;
use App\Shared\Constant\ErrorCodes;
use App\Shared\Controller\BaseController;
use App\Shared\Exception\AppException;
use App\Shared\Tenant\TenantOwnershipChecker;
use Doctrine\ORM\EntityManagerInterface;
use OpenApi\Attributes as OA;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Routing\Attribute\Route;
use Symfony\Component\Security\Http\Attribute\CurrentUser;
use Symfony\Component\Security\Http\Attribute\IsGranted;
#[OA\Tag(name: 'Pricing')]
#[IsGranted('IS_AUTHENTICATED_FULLY')]
class PricingController extends BaseController
{
public function __construct(
private readonly PriceListRepository $lists,
private readonly PriceListItemRepository $listItems,
private readonly PriceSnapshotRepository $snapshots,
private readonly ServiceItemRepository $items,
private readonly PricingEngine $engine,
private readonly BranchResolver $branches,
private readonly TenantOwnershipChecker $ownership,
private readonly EntityManagerInterface $em,
) {}
#[Route('/api/v1/price-lists', name: 'price_list_index', methods: ['GET'])]
public function index(#[CurrentUser] User $user): JsonResponse
{
[$entityType, $entityId] = $this->branches->pair($user);
return $this->success(array_map(
static fn (PriceList $l): array => $l->toArray(),
$this->lists->findForPair($entityType, $entityId),
));
}
#[Route('/api/v1/price-lists', name: 'price_list_create', methods: ['POST'])]
public function create(#[CurrentUser] User $user, Request $request): JsonResponse
{
$data = json_decode($request->getContent(), true);
if (!is_array($data) || !is_string($data['name'] ?? null) || trim($data['name']) === '') {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'نام لیست قیمت الزامی است', 422, 'name');
}
if (!is_numeric($data['starts_at'] ?? null) || !is_numeric($data['ends_at'] ?? null)) {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'بازهٔ تاریخ الزامی است', 422, 'starts_at');
}
[$entityType, $entityId] = $this->branches->pair($user);
try {
$list = new PriceList($entityType, $entityId, trim($data['name']), (int) $data['starts_at'], (int) $data['ends_at']);
} catch (\InvalidArgumentException) {
return $this->error(ErrorCodes::ERR_VALIDATION_001, 'پایان بازه باید بعد از شروع آن باشد', 422, 'ends_at');
}
if (is_string($data['address_uuid'] ?? null)) {
$list->setAddress($this->branches->resolve($user, $data['address_uuid']));
}
$this->em->persist($list);
$this->em->flush();
return $this->success($list->toArray(), 201);
}
#[Route('/api/v1/price-list/{uuid}', name: 'price_list_show', methods: ['GET'])]
public function show(#[CurrentUser] User $user, string $uuid): JsonResponse
{
return $this->success($this->requireList($user, $uuid)->toArray());
}
#[Route('/api/v1/price-list/{uuid}', name: 'price_list_update', methods: ['PATCH'])]
public function update(#[CurrentUser] User $user, string $uuid, Request $request): JsonResponse
{
$data = json_decode($request->getContent(), true);
$list = $this->requireList($user, $uuid);
if (!is_array($data)) {
return $this->error(ErrorCodes::ERR_VALIDATION_001, 'بدنهٔ درخواست نامعتبر است', 422);
}
if (is_string($data['name'] ?? null) && trim($data['name']) !== '') {
$list->setName(trim($data['name']));
}
if (array_key_exists('active', $data)) {
$list->setActive((bool) $data['active']);
}
$this->em->flush();
return $this->success($list->toArray());
}
#[Route('/api/v1/price-list/{uuid}', name: 'price_list_delete', methods: ['DELETE'])]
public function delete(#[CurrentUser] User $user, string $uuid): JsonResponse
{
$this->em->remove($this->requireList($user, $uuid));
$this->em->flush();
return $this->success(null);
}
#[Route('/api/v1/price-list/{uuid}/items', name: 'price_list_items_replace', methods: ['PUT'])]
public function replaceItems(#[CurrentUser] User $user, string $uuid, Request $request): JsonResponse
{
$data = json_decode($request->getContent(), true);
if (!is_array($data) || !is_array($data['items'] ?? null)) {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'فیلد items الزامی است', 422, 'items');
}
$list = $this->requireList($user, $uuid);
$resolved = [];
foreach ($data['items'] as $row) {
if (!is_array($row) || !is_string($row['service_uuid'] ?? null) || !is_numeric($row['price_rials'] ?? null)) {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'service_uuid و price_rials الزامی‌اند', 422, 'items');
}
if ((int) $row['price_rials'] < 0) {
return $this->error(ErrorCodes::ERR_VALIDATION_001, 'قیمت نمی‌تواند منفی باشد', 422, 'price_rials');
}
$resolved[] = [$this->requireItem($user, $row['service_uuid']), (int) $row['price_rials']];
}
$this->listItems->deleteForList($list);
$list->getItems()->clear();
foreach ($resolved as [$service, $price]) {
$item = new PriceListItem($list, $service, $price);
$this->em->persist($item);
$list->getItems()->add($item);
}
$list->touch();
$this->em->flush();
return $this->success($list->toArray());
}
/**
* فعال‌سازی با بررسی تداخل: دو لیستِ فعالِ هم‌پوشان یعنی یک تاریخ دو قیمت دارد و
* هیچ‌کس نمی‌تواند بگوید کدام درست است.
*/
#[Route('/api/v1/price-list/{uuid}/activate', name: 'price_list_activate', methods: ['POST'])]
public function activate(#[CurrentUser] User $user, string $uuid): JsonResponse
{
$list = $this->requireList($user, $uuid);
$conflicts = $this->lists->findOverlapping($list);
if ($conflicts !== []) {
return $this->error(
ErrorCodes::ERR_VALIDATION_001,
sprintf('بازهٔ این لیست با «%s» هم‌پوشانی دارد', $conflicts[0]->getName()),
422,
'starts_at',
);
}
$list->setActive(true);
$this->em->flush();
return $this->success($list->toArray());
}
#[Route('/api/v1/pricing/quote', name: 'pricing_quote', methods: ['POST'])]
public function quote(#[CurrentUser] User $user, Request $request): JsonResponse
{
$data = json_decode($request->getContent(), true);
if (!is_array($data) || !is_string($data['service_uuid'] ?? null)) {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'فیلد service_uuid الزامی است', 422, 'service_uuid');
}
if (!is_string($data['branch_uuid'] ?? null)) {
return $this->error(ErrorCodes::ERR_VALIDATION_002, 'فیلد branch_uuid الزامی است', 422, 'branch_uuid');
}
$service = $this->requireItem($user, $data['service_uuid']);
$address = $this->branches->resolve($user, $data['branch_uuid']);
$items = [];
foreach (($data['item_uuids'] ?? []) as $itemUuid) {
if (is_string($itemUuid)) {
$items[] = $this->requireItem($user, $itemUuid);
}
}
$at = is_numeric($data['at'] ?? null) ? (int) $data['at'] : time();
$policy = is_array($data['policy'] ?? null) ? $data['policy'] : [];
return $this->success($this->engine->quote($service, $items, $address, $at, $policy)->toArray());
}
/**
* فاکتور تفکیک‌شدهٔ نوبت — همان اعدادِ لحظهٔ ثبت، حتی اگر قیمت‌ها بعداً عوض شده باشند.
*/
#[Route('/api/v1/appointment/{uuid}/price-snapshot', name: 'appointment_price_snapshot', methods: ['GET'])]
public function snapshot(#[CurrentUser] User $user, string $uuid): JsonResponse
{
$appointment = $this->em->getRepository(Appointment::class)->findOneBy(['uuid' => $uuid]);
[$entityType, $entityId] = $this->branches->pair($user);
if ($appointment === null || !$this->ownership->belongsToPair($entityType, $entityId, $appointment)) {
return $this->error(ErrorCodes::ERR_NOT_FOUND_001, 'نوبت یافت نشد', 404);
}
$snapshot = $this->snapshots->findForAppointment($appointment);
if ($snapshot === null) {
return $this->error(ErrorCodes::ERR_NOT_FOUND_001, 'برای این نوبت فاکتوری ثبت نشده است', 404);
}
return $this->success($snapshot->toArray());
}
private function requireList(User $user, string $uuid): PriceList
{
$list = $this->lists->findByUuid($uuid);
[$entityType, $entityId] = $this->branches->pair($user);
if ($list === null || !$this->ownership->belongsToPair($entityType, $entityId, $list)) {
throw new AppException(ErrorCodes::ERR_NOT_FOUND_001, 'لیست قیمت یافت نشد', 404);
}
return $list;
}
private function requireItem(User $user, string $uuid): ServiceItem
{
$item = $this->items->findByUuid($uuid);
[$entityType, $entityId] = $this->branches->pair($user);
if ($item === null
|| $item->getSection()->getEntityType() !== $entityType
|| $item->getSection()->getEntityId() !== $entityId
) {
throw new AppException(ErrorCodes::ERR_NOT_FOUND_001, 'سرویس یافت نشد', 404);
}
return $item;
}
}
+125
View File
@@ -0,0 +1,125 @@
<?php
namespace App\Pricing\Entity;
use App\Doctor\Entity\DoctorAddress;
use App\Pricing\Repository\PriceListRepository;
use App\Shared\Tenant\TenantOwnedTrait;
use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;
use Symfony\Component\Uid\Uuid;
/**
* لیست قیمت با **بازهٔ تاریخ** — بند ۱۲ مستند.
*
* `Tariff` موجود فقط «سال» دارد، پس تغییر تعرفه از اول مهر قابل بیان نیست. این جدول
* بازهٔ دقیق می‌گیرد و `Tariff` به‌عنوان لایهٔ پشتیبان سرِ جایش می‌ماند.
*
* `address` تهی‌پذیر است: `null` یعنی «همهٔ شعبه‌های این محیط». قیمت اختصاصی یک شعبه
* از {@see \App\ClinicService\Entity\ServiceBranchOverride} می‌آید که بر این مقدم است.
*/
#[ORM\Entity(repositoryClass: PriceListRepository::class)]
#[ORM\Table(name: 'price_lists')]
#[ORM\Index(columns: ['entity_type', 'entity_id', 'active'], name: 'idx_price_list_tenant')]
#[ORM\Index(columns: ['starts_at', 'ends_at'], name: 'idx_price_list_range')]
class PriceList
{
use TenantOwnedTrait;
#[ORM\Id]
#[ORM\GeneratedValue]
#[ORM\Column(type: 'integer')]
private ?int $id = null;
#[ORM\Column(type: 'string', length: 36, unique: true)]
private string $uuid;
#[ORM\ManyToOne(targetEntity: DoctorAddress::class)]
#[ORM\JoinColumn(name: 'address_id', referencedColumnName: 'id', nullable: true, onDelete: 'CASCADE')]
private ?DoctorAddress $address = null;
#[ORM\Column(type: 'string', length: 150)]
private string $name;
#[ORM\Column(name: 'starts_at', type: 'integer')]
private int $startsAt;
#[ORM\Column(name: 'ends_at', type: 'integer')]
private int $endsAt;
/** تا فعال نشده هیچ اثری ندارد؛ ساختنِ پیش‌نویس نباید قیمت امروز را عوض کند. */
#[ORM\Column(type: 'boolean', options: ['default' => false])]
private bool $active = false;
#[ORM\Column(name: 'created_at', type: 'integer')]
private int $createdAt;
#[ORM\Column(name: 'updated_at', type: 'integer')]
private int $updatedAt;
/** @var Collection<int, PriceListItem> */
#[ORM\OneToMany(targetEntity: PriceListItem::class, mappedBy: 'priceList', cascade: ['persist', 'remove'], orphanRemoval: true)]
private Collection $items;
public function __construct(string $entityType, int $entityId, string $name, int $startsAt, int $endsAt)
{
if ($endsAt <= $startsAt) {
throw new \InvalidArgumentException('Price list end must be after its start.');
}
$this->uuid = Uuid::v4()->toRfc4122();
$this->name = $name;
$this->startsAt = $startsAt;
$this->endsAt = $endsAt;
$this->createdAt = time();
$this->updatedAt = time();
$this->items = new ArrayCollection();
$this->assignTenantPair($entityType, $entityId);
}
public function getId(): ?int { return $this->id; }
public function getUuid(): string { return $this->uuid; }
public function getAddress(): ?DoctorAddress { return $this->address; }
public function getName(): string { return $this->name; }
public function getStartsAt(): int { return $this->startsAt; }
public function getEndsAt(): int { return $this->endsAt; }
public function isActive(): bool { return $this->active; }
/** @return Collection<int, PriceListItem> */
public function getItems(): Collection { return $this->items; }
public function setAddress(?DoctorAddress $v): self { $this->address = $v; $this->touch(); return $this; }
public function setName(string $v): self { $this->name = $v; $this->touch(); return $this; }
public function setActive(bool $v): self { $this->active = $v; $this->touch(); return $this; }
public function covers(int $at): bool
{
return $this->active && $at >= $this->startsAt && $at < $this->endsAt;
}
public function overlaps(int $startsAt, int $endsAt): bool
{
return $startsAt < $this->endsAt && $endsAt > $this->startsAt;
}
public function touch(): void { $this->updatedAt = time(); }
public function toArray(): array
{
return [
'uuid' => $this->uuid,
'name' => $this->name,
'address_uuid' => $this->address?->getUuid(),
'address_name' => $this->address?->getName(),
'starts_at' => $this->startsAt,
'ends_at' => $this->endsAt,
'active' => $this->active,
'items' => array_map(
static fn (PriceListItem $i): array => $i->toArray(),
$this->items->toArray(),
),
];
}
}
+58
View File
@@ -0,0 +1,58 @@
<?php
namespace App\Pricing\Entity;
use App\ClinicService\Entity\ServiceItem;
use App\Pricing\Repository\PriceListItemRepository;
use Doctrine\ORM\Mapping as ORM;
/**
* قیمت یک سرویس در یک لیست قیمت. فرزند aggregate با ریشهٔ {@see PriceList} که خودش
* جفت محیط دارد؛ uuid از request نمی‌گیرد.
*/
#[ORM\Entity(repositoryClass: PriceListItemRepository::class)]
#[ORM\Table(name: 'price_list_items')]
#[ORM\UniqueConstraint(name: 'uniq_price_list_service', columns: ['price_list_id', 'service_item_id'])]
class PriceListItem
{
#[ORM\Id]
#[ORM\GeneratedValue]
#[ORM\Column(type: 'integer')]
private ?int $id = null;
#[ORM\ManyToOne(targetEntity: PriceList::class, inversedBy: 'items')]
#[ORM\JoinColumn(name: 'price_list_id', referencedColumnName: 'id', nullable: false, onDelete: 'CASCADE')]
private PriceList $priceList;
#[ORM\ManyToOne(targetEntity: ServiceItem::class)]
#[ORM\JoinColumn(name: 'service_item_id', referencedColumnName: 'id', nullable: false, onDelete: 'CASCADE')]
private ServiceItem $serviceItem;
#[ORM\Column(name: 'price_rials', type: 'bigint')]
private int $priceRials;
public function __construct(PriceList $priceList, ServiceItem $serviceItem, int $priceRials)
{
if ($priceRials < 0) {
throw new \InvalidArgumentException('Price cannot be negative.');
}
$this->priceList = $priceList;
$this->serviceItem = $serviceItem;
$this->priceRials = $priceRials;
}
public function getId(): ?int { return $this->id; }
public function getPriceList(): PriceList { return $this->priceList; }
public function getServiceItem(): ServiceItem { return $this->serviceItem; }
public function getPriceRials(): int { return (int) $this->priceRials; }
public function toArray(): array
{
return [
'service_uuid' => $this->serviceItem->getUuid(),
'service_name' => $this->serviceItem->getName(),
'price_rials' => $this->getPriceRials(),
];
}
}
+129
View File
@@ -0,0 +1,129 @@
<?php
namespace App\Pricing\Entity;
use App\Appointment\Entity\Appointment;
use App\Pricing\Repository\PriceSnapshotRepository;
use App\Shared\Tenant\TenantOwnedTrait;
use Doctrine\ORM\Mapping as ORM;
use Symfony\Component\Uid\Uuid;
/**
* فاکتور تفکیک‌شدهٔ **لحظهٔ ثبت** نوبت.
*
* قانون پنجم مستند: «تغییر قیمت هرگز نوبت‌های ثبت‌شده را عوض نمی‌کند.» امروز روی نوبت
* فقط یک عدد (`visit_price_rials`) هست، پس بعد از تغییر تعرفه یا تخفیف نمی‌شود گفت آن
* ۲٬۴۰۰٬۰۰۰ ریال از چه تشکیل شده بود.
*
* هیچ ستونی از این جدول بعد از ساخت تغییر نمی‌کند و عمداً هیچ setter ای ندارد:
* snapshot ای که ویرایش شود دیگر snapshot نیست. اصلاح قیمت با ردیف تازه و ابطال
* قبلی انجام می‌شود، نه با بازنویسی.
*/
#[ORM\Entity(repositoryClass: PriceSnapshotRepository::class)]
#[ORM\Table(name: 'price_snapshots')]
#[ORM\UniqueConstraint(name: 'uniq_snapshot_appointment', columns: ['appointment_id'])]
#[ORM\Index(columns: ['entity_type', 'entity_id'], name: 'idx_snapshot_tenant')]
class PriceSnapshot
{
use TenantOwnedTrait;
#[ORM\Id]
#[ORM\GeneratedValue]
#[ORM\Column(type: 'integer')]
private ?int $id = null;
#[ORM\Column(type: 'string', length: 36, unique: true)]
private string $uuid;
#[ORM\ManyToOne(targetEntity: Appointment::class)]
#[ORM\JoinColumn(name: 'appointment_id', referencedColumnName: 'id', nullable: false, onDelete: 'CASCADE')]
private Appointment $appointment;
#[ORM\Column(name: 'base_rials', type: 'bigint')]
private int $baseRials;
#[ORM\Column(name: 'items_rials', type: 'bigint')]
private int $itemsRials;
#[ORM\Column(name: 'discount_rials', type: 'bigint')]
private int $discountRials;
#[ORM\Column(name: 'insurance_base_rials', type: 'bigint')]
private int $insuranceBaseRials;
#[ORM\Column(name: 'insurance_supplementary_rials', type: 'bigint')]
private int $insuranceSupplementaryRials;
#[ORM\Column(name: 'tax_rials', type: 'bigint')]
private int $taxRials;
#[ORM\Column(name: 'final_rials', type: 'bigint')]
private int $finalRials;
#[ORM\Column(name: 'deposit_rials', type: 'bigint')]
private int $depositRials;
/** ریز تخفیف‌ها و مأخذشان — «۲۰٪ تخفیف» بدون نام، سه ماه بعد قابل توضیح نیست. */
#[ORM\Column(type: 'json', nullable: true)]
private ?array $breakdown = null;
#[ORM\Column(name: 'computed_at', type: 'integer')]
private int $computedAt;
/** @param array<string, mixed> $breakdown */
public function __construct(
Appointment $appointment,
string $entityType,
int $entityId,
int $baseRials,
int $itemsRials,
int $discountRials,
int $insuranceBaseRials,
int $insuranceSupplementaryRials,
int $taxRials,
int $finalRials,
int $depositRials,
array $breakdown = [],
?int $computedAt = null,
) {
$this->uuid = Uuid::v4()->toRfc4122();
$this->appointment = $appointment;
$this->baseRials = $baseRials;
$this->itemsRials = $itemsRials;
$this->discountRials = $discountRials;
$this->insuranceBaseRials = $insuranceBaseRials;
$this->insuranceSupplementaryRials = $insuranceSupplementaryRials;
$this->taxRials = $taxRials;
$this->finalRials = $finalRials;
$this->depositRials = $depositRials;
$this->breakdown = $breakdown === [] ? null : $breakdown;
$this->computedAt = $computedAt ?? time();
$this->assignTenantPair($entityType, $entityId);
}
public function getId(): ?int { return $this->id; }
public function getUuid(): string { return $this->uuid; }
public function getAppointment(): Appointment { return $this->appointment; }
public function getFinalRials(): int { return (int) $this->finalRials; }
public function getDepositRials(): int { return (int) $this->depositRials; }
public function getComputedAt(): int { return $this->computedAt; }
public function toArray(): array
{
return [
'uuid' => $this->uuid,
'appointment_uuid' => $this->appointment->getUuid(),
'base_rials' => (int) $this->baseRials,
'items_rials' => (int) $this->itemsRials,
'discount_rials' => (int) $this->discountRials,
'insurance_base_rials' => (int) $this->insuranceBaseRials,
'insurance_supplementary_rials' => (int) $this->insuranceSupplementaryRials,
'tax_rials' => (int) $this->taxRials,
'final_rials' => (int) $this->finalRials,
'deposit_rials' => (int) $this->depositRials,
'breakdown' => $this->breakdown ?? [],
'computed_at' => $this->computedAt,
];
}
}
@@ -0,0 +1,59 @@
<?php
namespace App\Pricing\Repository;
use App\ClinicService\Entity\ServiceItem;
use App\Pricing\Entity\PriceList;
use App\Pricing\Entity\PriceListItem;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;
/**
* @extends ServiceEntityRepository<PriceListItem>
*/
class PriceListItemRepository extends ServiceEntityRepository
{
public function __construct(ManagerRegistry $registry)
{
parent::__construct($registry, PriceListItem::class);
}
public function deleteForList(PriceList $list): int
{
return (int) $this->createQueryBuilder('i')
->delete()
->where('i.priceList = :list')
->setParameter('list', $list)
->getQuery()
->execute();
}
/**
* قیمت چند سرویس در یک لیست — یک کوئری، نه یکی per سرویس.
*
* @param ServiceItem[] $services
* @return array<int, int> شناسهٔ سرویس => قیمت
*/
public function priceMap(PriceList $list, array $services): array
{
if ($services === []) {
return [];
}
$rows = $this->createQueryBuilder('i')
->select('IDENTITY(i.serviceItem) AS service_id, i.priceRials AS price')
->where('i.priceList = :list')
->andWhere('i.serviceItem IN (:services)')
->setParameter('list', $list)
->setParameter('services', $services)
->getQuery()
->getArrayResult();
$map = [];
foreach ($rows as $row) {
$map[(int) $row['service_id']] = (int) $row['price'];
}
return $map;
}
}
@@ -0,0 +1,102 @@
<?php
namespace App\Pricing\Repository;
use App\Doctor\Entity\DoctorAddress;
use App\Pricing\Entity\PriceList;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;
/**
* @extends ServiceEntityRepository<PriceList>
*/
class PriceListRepository extends ServiceEntityRepository
{
public function __construct(ManagerRegistry $registry)
{
parent::__construct($registry, PriceList::class);
}
public function findByUuid(string $uuid): ?PriceList
{
return $this->findOneBy(['uuid' => $uuid]);
}
/** @return PriceList[] */
public function findForPair(string $entityType, int $entityId): array
{
return $this->createQueryBuilder('p')
->where('p.entityType = :type')
->andWhere('p.entityId = :id')
->setParameter('type', $entityType)
->setParameter('id', $entityId)
->orderBy('p.startsAt', 'DESC')
->getQuery()
->getResult();
}
/**
* لیست قیمتِ حاکم بر یک لحظه.
*
* لیستِ مخصوصِ همان شعبه بر لیست عمومیِ محیط مقدم است — وگرنه تعریف استثنا برای
* یک شعبه هیچ اثری نداشت.
*/
public function findCovering(string $entityType, int $entityId, ?DoctorAddress $address, int $at): ?PriceList
{
$rows = $this->createQueryBuilder('p')
->where('p.entityType = :type')
->andWhere('p.entityId = :id')
->andWhere('p.active = true')
->andWhere('p.startsAt <= :at')
->andWhere('p.endsAt > :at')
->setParameter('type', $entityType)
->setParameter('id', $entityId)
->setParameter('at', $at)
->getQuery()
->getResult();
$general = null;
foreach ($rows as $list) {
if ($address !== null && $list->getAddress()?->getId() === $address->getId()) {
return $list;
}
if ($list->getAddress() === null) {
$general = $list;
}
}
return $general;
}
/**
* لیست‌های فعالِ هم‌پوشان با یک بازه — برای جلوگیری از دو قیمتِ هم‌زمان.
*
* @return PriceList[]
*/
public function findOverlapping(PriceList $candidate): array
{
$qb = $this->createQueryBuilder('p')
->where('p.entityType = :type')
->andWhere('p.entityId = :id')
->andWhere('p.active = true')
->andWhere('p.startsAt < :ends')
->andWhere('p.endsAt > :starts')
->setParameter('type', $candidate->getEntityType())
->setParameter('id', $candidate->getEntityId())
->setParameter('starts', $candidate->getStartsAt())
->setParameter('ends', $candidate->getEndsAt());
if ($candidate->getId() !== null) {
$qb->andWhere('p.id != :self')->setParameter('self', $candidate->getId());
}
// فقط لیست‌هایی که دامنهٔ یکسانی دارند با هم تداخل دارند: لیست عمومی و لیست
// یک شعبه عمداً کنار هم زندگی می‌کنند و اولویت دارند، نه تداخل.
return array_values(array_filter(
$qb->getQuery()->getResult(),
static fn (PriceList $other): bool => $other->getAddress()?->getId() === $candidate->getAddress()?->getId(),
));
}
}
@@ -0,0 +1,24 @@
<?php
namespace App\Pricing\Repository;
use App\Appointment\Entity\Appointment;
use App\Pricing\Entity\PriceSnapshot;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;
/**
* @extends ServiceEntityRepository<PriceSnapshot>
*/
class PriceSnapshotRepository extends ServiceEntityRepository
{
public function __construct(ManagerRegistry $registry)
{
parent::__construct($registry, PriceSnapshot::class);
}
public function findForAppointment(Appointment $appointment): ?PriceSnapshot
{
return $this->findOneBy(['appointment' => $appointment]);
}
}
@@ -0,0 +1,77 @@
<?php
namespace App\Pricing\Service;
use App\Appointment\Entity\Appointment;
use App\Pricing\Entity\PriceSnapshot;
use App\Pricing\Repository\PriceSnapshotRepository;
use App\Pricing\ValueObject\PriceQuote;
use Doctrine\ORM\EntityManagerInterface;
/**
* ثبت فاکتور تفکیک‌شده روی نوبت.
*
* idempotent است: نوبتی که از قبل snapshot دارد، دومی نمی‌گیرد. کلید یکتای
* `appointment_id` هم همین را در سطح دیتابیس تضمین می‌کند — دو فاکتور برای یک نوبت
* یعنی دو حقیقت.
*/
final class PriceSnapshotService
{
public function __construct(
private readonly PriceSnapshotRepository $snapshots,
private readonly EntityManagerInterface $em,
) {}
public function record(Appointment $appointment, PriceQuote $quote, ?int $now = null): PriceSnapshot
{
$existing = $this->snapshots->findForAppointment($appointment);
if ($existing !== null) {
return $existing;
}
$snapshot = new PriceSnapshot(
$appointment,
$appointment->getEntityType(),
$appointment->getEntityId(),
$quote->baseRials,
$quote->itemsRials,
$quote->discountRials,
$quote->insuranceBaseRials,
$quote->insuranceSupplementaryRials,
$quote->taxRials,
$quote->finalRials,
$quote->depositRials,
$quote->breakdown(),
$now,
);
$this->em->persist($snapshot);
$this->em->flush();
return $snapshot;
}
/**
* نوبتِ بدون سرویس (ویزیت سادهٔ حالت اسلاتی) هم باید فاکتور داشته باشد؛ خالی
* گذاشتنش یعنی گزارش مالی یک ردیف کم دارد.
*/
public function recordFlatVisit(Appointment $appointment, int $priceRials, ?int $now = null): PriceSnapshot
{
return $this->record(
$appointment,
new PriceQuote(
baseRials: $priceRials,
itemsRials: 0,
discountRials: 0,
insuranceBaseRials: 0,
insuranceSupplementaryRials: 0,
taxRials: 0,
finalRials: $priceRials,
depositRials: 0,
sources: ['visit' => 'appointment_visit_price'],
),
$now,
);
}
}
+218
View File
@@ -0,0 +1,218 @@
<?php
namespace App\Pricing\Service;
use App\ClinicService\Entity\ServiceItem;
use App\ClinicService\Repository\ServiceBranchOverrideRepository;
use App\ClinicService\Repository\TariffRepository;
use App\Doctor\Entity\DoctorAddress;
use App\Pricing\Repository\PriceListItemRepository;
use App\Pricing\Repository\PriceListRepository;
use App\Pricing\ValueObject\PriceQuote;
use App\Representation\Service\JalaliDateService;
/**
* زنجیرهٔ قیمت‌گذاری بند ۱۲ مستند.
*
* ```
* قیمت پایه → + آیتم‌ها → − تخفیف → − بیمهٔ پایه → − تکمیلی → + مالیات → بیعانه
* ```
*
* ## زنجیرهٔ منبع قیمت
*
* برای هر سرویس، اولین چیزی که پیدا شود برنده است:
*
* ۱. override شعبه ({@see \App\ClinicService\Entity\ServiceBranchOverride}) — تسک ۰۴
* ۲. لیست قیمتِ حاکم بر آن تاریخ — همین تسک
* ۳. `Tariff` سال — لایهٔ موجود
* ۴. `ServiceItem::priceRials` — همیشه هست
*
* مرحلهٔ چهارم ضامن است که **هرگز صفر یا خطا** برنگردد: تاریخی که هیچ لیستی نمی‌پوشاند
* باید قیمت بدهد، نه استثنا.
*/
final class PricingEngine
{
public function __construct(
private readonly PriceListRepository $priceLists,
private readonly PriceListItemRepository $priceListItems,
private readonly ServiceBranchOverrideRepository $overrides,
private readonly TariffRepository $tariffs,
private readonly JalaliDateService $jalali,
) {}
/**
* @param ServiceItem[] $items آیتم‌های انتخاب‌شده (بدون خودِ سرویس)
* @param array{
* discount_percent?: float, discount_rials?: int, discount_label?: string,
* max_total_discount_percent?: float,
* insurance_base_percent?: float, insurance_supplementary_percent?: float,
* tax_percent?: float, deposit_percent?: float, deposit_rials?: int
* } $policy
*/
public function quote(
ServiceItem $service,
array $items,
DoctorAddress $address,
int $at,
array $policy = [],
): PriceQuote {
$entityType = $address->tenantEntityType();
$entityId = $address->tenantEntityId();
$list = $this->priceLists->findCovering($entityType, $entityId, $address, $at);
$sources = [];
$base = $this->priceFor($service, $address, $list, $at, $sources);
$itemsTotal = 0;
foreach ($items as $item) {
$itemsTotal += $this->priceFor($item, $address, $list, $at, $sources);
}
$subtotal = $base + $itemsTotal;
// ── تخفیف ─────────────────────────────────────────────────────────────
[$discount, $discounts] = $this->discountFor($subtotal, $policy);
// تخفیف بیشتر از مبلغ، مبلغ را **صفر** می‌کند نه منفی: بدهی منفی یعنی کلینیک
// به بیمار پول بدهکار شود، که هیچ‌جای این جریان معنا ندارد.
$discount = min($discount, $subtotal);
$afterDiscount = $subtotal - $discount;
// ── بیمه ──────────────────────────────────────────────────────────────
$insuranceBase = $this->percentOf($afterDiscount, $policy['insurance_base_percent'] ?? 0.0);
$insuranceBase = min($insuranceBase, $afterDiscount);
$remaining = $afterDiscount - $insuranceBase;
$supplementary = min($this->percentOf($remaining, $policy['insurance_supplementary_percent'] ?? 0.0), $remaining);
$patientShare = $remaining - $supplementary;
// ── مالیات ────────────────────────────────────────────────────────────
// روی سهم بیمار حساب می‌شود، نه روی کل: بیمار مالیاتِ سهمی که بیمه می‌دهد را
// نمی‌پردازد.
$tax = $this->percentOf($patientShare, $policy['tax_percent'] ?? 0.0);
$final = $patientShare + $tax;
// ── بیعانه ────────────────────────────────────────────────────────────
$deposit = isset($policy['deposit_rials'])
? (int) $policy['deposit_rials']
: $this->percentOf($final, $policy['deposit_percent'] ?? 0.0);
$deposit = max(0, min($deposit, $final));
return new PriceQuote(
baseRials: $base,
itemsRials: $itemsTotal,
discountRials: $discount,
insuranceBaseRials: $insuranceBase,
insuranceSupplementaryRials: $supplementary,
taxRials: $tax,
finalRials: $final,
depositRials: $deposit,
discounts: $discounts,
sources: $sources,
);
}
/**
* @param array<string, string> $sources
*/
private function priceFor(
ServiceItem $service,
DoctorAddress $address,
?\App\Pricing\Entity\PriceList $list,
int $at,
array &$sources,
): int {
$override = $this->overrides->mapForAddress([(int) $service->getId()], $address)[(int) $service->getId()] ?? null;
if ($override?->getPriceRials() !== null) {
$sources[$service->getUuid()] = 'branch_override';
return $override->getPriceRials();
}
if ($list !== null) {
$price = $this->priceListItems->priceMap($list, [$service])[(int) $service->getId()] ?? null;
if ($price !== null) {
$sources[$service->getUuid()] = 'price_list';
return $price;
}
}
$tariff = $this->tariffs->findForServiceYear((int) $service->getId(), $this->jalali->jalaliYear($at));
if ($tariff !== null) {
$sources[$service->getUuid()] = 'tariff';
return (int) $tariff->getPriceRials();
}
$sources[$service->getUuid()] = 'service_item';
return $service->getPriceRials();
}
/**
* @param array<string, mixed> $policy
* @return array{0: int, 1: list<array<string, mixed>>}
*/
private function discountFor(int $subtotal, array $policy): array
{
$discounts = [];
$total = 0;
if (($policy['discount_percent'] ?? 0.0) > 0) {
$amount = $this->percentOf($subtotal, (float) $policy['discount_percent']);
$total += $amount;
$discounts[] = [
'label' => $policy['discount_label'] ?? 'تخفیف درصدی',
'percent' => $policy['discount_percent'],
'rials' => $amount,
];
}
if (($policy['discount_rials'] ?? 0) > 0) {
$amount = (int) $policy['discount_rials'];
$total += $amount;
$discounts[] = [
'label' => $policy['discount_label'] ?? 'تخفیف مبلغی',
'rials' => $amount,
];
}
// سقف جمع تخفیف‌ها per محیط: چند تخفیفِ جداگانه که هرکدام منطقی‌اند، با هم
// می‌توانند مبلغ را بی‌معنا کنند.
$cap = $policy['max_total_discount_percent'] ?? null;
if ($cap !== null && $cap >= 0) {
$maxAllowed = $this->percentOf($subtotal, (float) $cap);
if ($total > $maxAllowed) {
$discounts[] = [
'label' => sprintf('سقف تخفیف %s٪ اعمال شد', $cap),
'rials' => $maxAllowed - $total,
];
$total = $maxAllowed;
}
}
return [$total, $discounts];
}
/** ریال واحد صحیح است؛ گرد کردن به پایین از اضافه‌گرفتن جلوگیری می‌کند. */
private function percentOf(int $amount, float $percent): int
{
if ($percent <= 0) {
return 0;
}
return (int) floor($amount * $percent / 100);
}
}
+46
View File
@@ -0,0 +1,46 @@
<?php
namespace App\Pricing\ValueObject;
/**
* نتیجهٔ زنجیرهٔ قیمت‌گذاری، پیش از اینکه جایی ذخیره شود.
*
* همان اعدادی که `PriceSnapshot` نگه می‌دارد — عمداً یک شکل، تا «قیمتی که به کاربر
* نشان دادیم» و «قیمتی که ثبت کردیم» نتوانند واگرا شوند.
*/
final readonly class PriceQuote
{
/** @param list<array<string, mixed>> $discounts */
public function __construct(
public int $baseRials,
public int $itemsRials,
public int $discountRials,
public int $insuranceBaseRials,
public int $insuranceSupplementaryRials,
public int $taxRials,
public int $finalRials,
public int $depositRials,
public array $discounts = [],
public array $sources = [],
) {}
public function breakdown(): array
{
return ['discounts' => $this->discounts, 'sources' => $this->sources];
}
public function toArray(): array
{
return [
'base_rials' => $this->baseRials,
'items_rials' => $this->itemsRials,
'discount_rials' => $this->discountRials,
'insurance_base_rials' => $this->insuranceBaseRials,
'insurance_supplementary_rials' => $this->insuranceSupplementaryRials,
'tax_rials' => $this->taxRials,
'final_rials' => $this->finalRials,
'deposit_rials' => $this->depositRials,
'breakdown' => $this->breakdown(),
];
}
}
+1
View File
@@ -109,6 +109,7 @@ final class GlobalTables
\App\ClinicService\Entity\ServiceItemConsumable::class => \App\ClinicService\Entity\ServiceItem::class,
\App\ClinicService\Entity\Tariff::class => \App\ClinicService\Entity\ServiceItem::class,
\App\ClinicService\Entity\ItemGroupMember::class => \App\ClinicService\Entity\ItemGroup::class,
\App\Pricing\Entity\PriceListItem::class => \App\Pricing\Entity\PriceList::class,
\App\Billing\Entity\ClaimItem::class => \App\Billing\Entity\Claim::class,
\App\Billing\Entity\ClaimStatusLog::class => \App\Billing\Entity\Claim::class,