431 lines
15 KiB
PHP
431 lines
15 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Data\UnifiedPatientData;
|
|
use App\Models\Department;
|
|
use App\Models\DepartmentPatientOperation;
|
|
use App\Models\MedicalHistorySnapshot;
|
|
use App\Models\MetrikaResult;
|
|
use App\Models\MisMedicalHistory;
|
|
use App\Models\MisStationarBranch;
|
|
use App\Models\Report;
|
|
use App\Models\User;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Support\Collection;
|
|
|
|
class SnapshotService
|
|
{
|
|
public function __construct(
|
|
protected UnifiedPatientService $unifiedPatientService,
|
|
protected PatientService $patientService,
|
|
protected DateRangeService $dateRangeService,
|
|
) {}
|
|
|
|
/**
|
|
* Создать снапшоты пациентов для отчета
|
|
*/
|
|
public function createPatientSnapshots(Report $report, User $user, array $dates, $fillableAuto = false): void
|
|
{
|
|
$department = Department::query()->where('department_id', $report->rf_department_id)->first() ?? $user->department;
|
|
$branchId = $department
|
|
? $this->getBranchId($department->rf_mis_department_id)
|
|
: null;
|
|
|
|
if (!$department || !$branchId) {
|
|
return;
|
|
}
|
|
|
|
MedicalHistorySnapshot::query()
|
|
->where('rf_report_id', $report->report_id)
|
|
->delete();
|
|
|
|
[$startDate, $endDate] = $this->parseDates($dates);
|
|
$dateRange = $this->dateRangeService->getNormalizedDateRange($user, $startDate, $endDate);
|
|
$metrics = [];
|
|
|
|
$planPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'plan',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
!$fillableAuto,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'plan', $planPatients);
|
|
$metrics[4] = $planPatients->count();
|
|
|
|
$emergencyPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'emergency',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
!$fillableAuto,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'emergency', $emergencyPatients);
|
|
$metrics[12] = $emergencyPatients->count();
|
|
|
|
$dischargedPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'outcome-discharged',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
null,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'discharged', $dischargedPatients);
|
|
$metrics[15] = $dischargedPatients->count();
|
|
|
|
$transferredPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'outcome-transferred',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
null,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'transferred', $transferredPatients);
|
|
$metrics[13] = $transferredPatients->count();
|
|
|
|
$deceasedPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'outcome-deceased',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
null,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'deceased', $deceasedPatients);
|
|
|
|
$recipientPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'recipient',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
null,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'recipient', $recipientPatients);
|
|
|
|
$currentPatients = $this->unifiedPatientService->getLivePatientsByStatus(
|
|
$department,
|
|
$user,
|
|
'current',
|
|
$dateRange,
|
|
$branchId,
|
|
false,
|
|
null,
|
|
$fillableAuto
|
|
);
|
|
$this->createSnapshotsForType($report, 'current', $currentPatients);
|
|
|
|
$planSurgeryCount = $this->patientService->getSurgicalPatients(
|
|
'plan',
|
|
$branchId,
|
|
$dateRange,
|
|
true
|
|
);
|
|
$emergencySurgeryCount = $this->patientService->getSurgicalPatients(
|
|
'emergency',
|
|
$branchId,
|
|
$dateRange,
|
|
true
|
|
);
|
|
|
|
$this->saveMetrics($report, $metrics);
|
|
}
|
|
|
|
/**
|
|
* Сохранить метрики в базу
|
|
*/
|
|
private function saveMetrics(Report $report, array $metrics): void
|
|
{
|
|
foreach ($metrics as $metrikaItemId => $value) {
|
|
MetrikaResult::updateOrCreate(
|
|
[
|
|
'rf_report_id' => $report->report_id,
|
|
'rf_metrika_item_id' => $metrikaItemId,
|
|
],
|
|
[
|
|
'value' => $value,
|
|
]
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Получить статистику из снапшотов
|
|
*/
|
|
public function getStatisticsFromSnapshots(array $reportIds): array
|
|
{
|
|
return [
|
|
'plan' => $this->getCountFromSnapshots('plan', $reportIds),
|
|
'emergency' => $this->getCountFromSnapshots('emergency', $reportIds),
|
|
'outcome' => $this->getCountFromSnapshots('outcome', $reportIds),
|
|
'deceased' => $this->getCountFromSnapshots('deceased', $reportIds),
|
|
'discharged' => $this->getCountFromSnapshots('discharged', $reportIds),
|
|
'transferred' => $this->getCountFromSnapshots('transferred', $reportIds),
|
|
'recipient' => $this->getCountFromSnapshots('recipient', $reportIds),
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Получить пациентов из снапшотов по типу
|
|
*/
|
|
public function getPatientsFromSnapshots(
|
|
string $type,
|
|
array $reportIds,
|
|
?int $branchId = null,
|
|
bool $onlyIds = false,
|
|
bool $markRecipients = false,
|
|
?array $recipientReportIds = null
|
|
): Collection {
|
|
$snapshots = MedicalHistorySnapshot::query()
|
|
->whereIn('rf_report_id', $reportIds)
|
|
->where('patient_type', $type)
|
|
->get()
|
|
->unique(fn (MedicalHistorySnapshot $snapshot) => $snapshot->patient_uid ?: ($snapshot->rf_medicalhistory_id ? "mis:{$snapshot->rf_medicalhistory_id}" : "snapshot:{$snapshot->medical_history_snapshot_id}"))
|
|
->values();
|
|
|
|
if ($snapshots->isEmpty()) {
|
|
return collect();
|
|
}
|
|
|
|
$recipientIds = [];
|
|
if ($markRecipients) {
|
|
$recipientReportIds ??= $reportIds;
|
|
$recipientIds = MedicalHistorySnapshot::query()
|
|
->whereIn('rf_report_id', $recipientReportIds)
|
|
->where('patient_type', 'recipient')
|
|
->get()
|
|
->map(fn (MedicalHistorySnapshot $snapshot) => UnifiedPatientData::fromSnapshot($snapshot)->id)
|
|
->unique()
|
|
->values()
|
|
->all();
|
|
}
|
|
|
|
$operationsByHistoryId = $this->getOperationsByMedicalHistoryId($snapshots);
|
|
$operationsByDepartmentPatientId = $this->getOperationsByDepartmentPatientId($snapshots);
|
|
|
|
$patients = $snapshots->map(function (MedicalHistorySnapshot $snapshot) use ($recipientIds, $operationsByHistoryId, $operationsByDepartmentPatientId) {
|
|
$patientId = $snapshot->rf_department_patient_id
|
|
? "manual:{$snapshot->rf_department_patient_id}"
|
|
: ($snapshot->patient_uid ?: "mis:{$snapshot->rf_medicalhistory_id}");
|
|
|
|
$misOperations = $snapshot->rf_medicalhistory_id
|
|
? ($operationsByHistoryId[$snapshot->rf_medicalhistory_id] ?? [])
|
|
: [];
|
|
$manualOperations = $snapshot->rf_department_patient_id
|
|
? ($operationsByDepartmentPatientId[$snapshot->rf_department_patient_id] ?? [])
|
|
: [];
|
|
$operations = collect($misOperations)
|
|
->merge($manualOperations)
|
|
->unique(fn (array $operation) => ($operation['code'] ?? '') . '|' . ($operation['name'] ?? ''))
|
|
->values()
|
|
->all();
|
|
|
|
return UnifiedPatientData::fromSnapshot(
|
|
$snapshot,
|
|
in_array($patientId, $recipientIds, true),
|
|
$operations
|
|
);
|
|
})->sortByDesc(fn (UnifiedPatientData $patient) => $patient->admittedAt ?? '')->values();
|
|
|
|
if ($onlyIds) {
|
|
return $patients->pluck('id');
|
|
}
|
|
|
|
return $patients;
|
|
}
|
|
|
|
public function getPatientsFromOneDayCurrentSnapshots(
|
|
string $type,
|
|
array $reportIds,
|
|
bool $onlyIds = false,
|
|
?array $recipientReportIds = null
|
|
): Collection {
|
|
$snapshots = MedicalHistorySnapshot::query()
|
|
->whereIn('rf_report_id', $reportIds)
|
|
->where('patient_type', 'current')
|
|
->get();
|
|
|
|
if ($snapshots->isEmpty()) {
|
|
return $this->getPatientsFromSnapshots(
|
|
$type,
|
|
$reportIds,
|
|
null,
|
|
$onlyIds,
|
|
true,
|
|
$recipientReportIds
|
|
);
|
|
}
|
|
|
|
$recipientReportIds ??= $reportIds;
|
|
$recipientIds = MedicalHistorySnapshot::query()
|
|
->whereIn('rf_report_id', $recipientReportIds)
|
|
->where('patient_type', 'recipient')
|
|
->get()
|
|
->map(fn (MedicalHistorySnapshot $snapshot) => UnifiedPatientData::fromSnapshot($snapshot)->id)
|
|
->unique()
|
|
->values()
|
|
->all();
|
|
|
|
$operationsByHistoryId = $this->getOperationsByMedicalHistoryId($snapshots);
|
|
$operationsByDepartmentPatientId = $this->getOperationsByDepartmentPatientId($snapshots);
|
|
|
|
$patients = $snapshots
|
|
->filter(fn (MedicalHistorySnapshot $snapshot) => $snapshot->patient_kind === $type)
|
|
->unique(fn (MedicalHistorySnapshot $snapshot) => $snapshot->patient_uid ?: ($snapshot->rf_medicalhistory_id ? "mis:{$snapshot->rf_medicalhistory_id}" : "snapshot:{$snapshot->medical_history_snapshot_id}"))
|
|
->map(function (MedicalHistorySnapshot $snapshot) use ($recipientIds, $operationsByHistoryId, $operationsByDepartmentPatientId) {
|
|
$misOperations = $snapshot->rf_medicalhistory_id
|
|
? ($operationsByHistoryId[$snapshot->rf_medicalhistory_id] ?? [])
|
|
: [];
|
|
$manualOperations = $snapshot->rf_department_patient_id
|
|
? ($operationsByDepartmentPatientId[$snapshot->rf_department_patient_id] ?? [])
|
|
: [];
|
|
$operations = collect($misOperations)
|
|
->merge($manualOperations)
|
|
->unique(fn (array $operation) => ($operation['code'] ?? '') . '|' . ($operation['name'] ?? ''))
|
|
->values()
|
|
->all();
|
|
|
|
$patient = UnifiedPatientData::fromSnapshot(
|
|
$snapshot,
|
|
false,
|
|
$operations
|
|
);
|
|
$patient->isRecipientToday = in_array($patient->id, $recipientIds, true);
|
|
|
|
return $patient;
|
|
})
|
|
->sortByDesc(fn (UnifiedPatientData $patient) => $patient->admittedAt ?? '')
|
|
->values();
|
|
|
|
if ($onlyIds) {
|
|
return $patients->pluck('id');
|
|
}
|
|
|
|
return $patients;
|
|
}
|
|
|
|
/**
|
|
* Получить количество пациентов из снапшотов
|
|
*/
|
|
private function getCountFromSnapshots(string $type, array $reportIds): int
|
|
{
|
|
$query = MedicalHistorySnapshot::whereIn('rf_report_id', $reportIds);
|
|
|
|
if ($type === 'outcome') {
|
|
$query->whereIn('patient_type', ['discharged', 'deceased']);
|
|
} else {
|
|
$query->where('patient_type', $type);
|
|
}
|
|
|
|
return $query->get()
|
|
->map(fn (MedicalHistorySnapshot $snapshot) => $snapshot->patient_uid ?: ($snapshot->rf_medicalhistory_id ? "mis:{$snapshot->rf_medicalhistory_id}" : "snapshot:{$snapshot->medical_history_snapshot_id}"))
|
|
->unique()
|
|
->count();
|
|
}
|
|
|
|
/**
|
|
* Создать снапшоты для определенного типа пациентов
|
|
*/
|
|
private function createSnapshotsForType(Report $report, string $type, Collection $patients): void
|
|
{
|
|
foreach ($patients as $patient) {
|
|
if (!$patient instanceof UnifiedPatientData) {
|
|
continue;
|
|
}
|
|
|
|
MedicalHistorySnapshot::updateOrCreate(
|
|
[
|
|
'rf_report_id' => $report->report_id,
|
|
'patient_uid' => $patient->patientUid,
|
|
'patient_type' => $type,
|
|
],
|
|
[
|
|
'rf_report_id' => $report->report_id,
|
|
'patient_type' => $type,
|
|
...$patient->toSnapshotPayload($type),
|
|
]
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Получить ID отделения
|
|
*/
|
|
private function getBranchId(int $misDepartmentId): ?int
|
|
{
|
|
return MisStationarBranch::where('rf_DepartmentID', $misDepartmentId)
|
|
->value('StationarBranchID');
|
|
}
|
|
|
|
/**
|
|
* Разобрать даты
|
|
*/
|
|
private function parseDates(array $dates): array
|
|
{
|
|
return [
|
|
Carbon::createFromTimestampMs($dates[0])->setTimezone('Asia/Yakutsk'),
|
|
Carbon::createFromTimestampMs($dates[1])->setTimezone('Asia/Yakutsk'),
|
|
];
|
|
}
|
|
|
|
private function getOperationsByMedicalHistoryId(Collection $snapshots): array
|
|
{
|
|
$historyIds = $snapshots->pluck('rf_medicalhistory_id')->filter()->unique()->values();
|
|
|
|
if ($historyIds->isEmpty()) {
|
|
return [];
|
|
}
|
|
|
|
return MisMedicalHistory::query()
|
|
->whereIn('MedicalHistoryID', $historyIds)
|
|
->with(['surgicalOperations.serviceMedical'])
|
|
->get()
|
|
->mapWithKeys(function (MisMedicalHistory $history) {
|
|
return [
|
|
$history->MedicalHistoryID => $history->surgicalOperations->map(fn ($operation) => [
|
|
'code' => $operation->serviceMedical?->ServiceMedicalCode,
|
|
'name' => $operation->serviceMedical?->ServiceMedicalName,
|
|
])->values()->all()
|
|
];
|
|
})
|
|
->all();
|
|
}
|
|
|
|
private function getOperationsByDepartmentPatientId(Collection $snapshots): array
|
|
{
|
|
$departmentPatientIds = $snapshots->pluck('rf_department_patient_id')->filter()->unique()->values();
|
|
|
|
if ($departmentPatientIds->isEmpty()) {
|
|
return [];
|
|
}
|
|
|
|
return DepartmentPatientOperation::query()
|
|
->whereIn('rf_department_patient_id', $departmentPatientIds)
|
|
->with('serviceMedical')
|
|
->get()
|
|
->groupBy('rf_department_patient_id')
|
|
->map(fn (Collection $operations) => $operations->map(fn (DepartmentPatientOperation $operation) => [
|
|
'code' => $operation->serviceMedical?->ServiceMedicalCode ?? $operation->service_code,
|
|
'name' => $operation->serviceMedical?->ServiceMedicalName ?? $operation->service_name,
|
|
])->values()->all())
|
|
->all();
|
|
}
|
|
}
|