One Hat Cyber Team

Your IP: 216.73.216.19
Server IP: 178.33.27.10
Server: Linux cpanel.dev-unit.com 3.10.0-1160.108.1.el7.x86_64 #1 SMP Thu Jan 25 16:17:31 UTC 2024 x86_64
Server Software: Apache/2.4.57 (Unix) OpenSSL/1.0.2k-fips
PHP Version: 8.2.11
Buat File | Buat Folder
Dir : ~/home/id/hospital.dev-unit.com/app/Repositories/
View File Name : BedAssignRepository.php

<?php

namespace App\Repositories;

use App\Models\Bed;
use App\Models\BedAssign;
use App\Models\Doctor;
use App\Models\IpdPatientDepartment;
use App\Models\Notification;
use App\Models\Nurse;
use App\Models\PatientCase;
use App\Models\User;
use Arr;
use Exception;
use Illuminate\Support\Collection;
use Symfony\Component\HttpKernel\Exception\UnprocessableEntityHttpException;

/**
 * Class BedAssignRepository
 *
 * @version February 18, 2020, 6:49 am UTC
 */
class BedAssignRepository extends BaseRepository
{
    /**
     * @var array
     */
    protected $fieldSearchable = [
        'patient_id',
        'case_id',
        'assign_date',
    ];

    /**
     * Return searchable fields
     */
    public function getFieldsSearchable(): array
    {
        return $this->fieldSearchable;
    }

    /**
     * Configure the Model
     **/
    public function model()
    {
        return BedAssign::class;
    }

    public function getBeds()
    {
        /** @var Bed $beds */
        $beds = Bed::where('is_available', 1)->pluck('name', 'id')->toArray();
        natcasesort($beds);

        return $beds;
    }

    public function getCases(): array
    {
        $user = \Auth::user();
        if ($user->hasRole('Doctor')) {
            $cases = PatientCase::whereDoesntHave('bedAssign')->with('patient.user')->where(
                'doctor_id',
                '=',
                $user->owner_id
            )->where('status', '=', 1)->whereTenantId($user->tenant_id)->get();
        } else {
            $cases = PatientCase::whereDoesntHave('bedAssign')->with('patient.user')->where('status', '=', 1)->whereTenantId($user->tenant_id)->get();
        }

        $result = [];
        foreach ($cases as $case) {
            $result[$case->case_id] = $case->case_id.'  '.$case->patient->user->full_name;
        }
        ksort($result);

        return $result;
    }

    public function getIpdPatients($caseId): Collection
    {
        $patientCase = PatientCase::where('case_id', $caseId)->value('id');

        return IpdPatientDepartment::whereCaseId($patientCase)->pluck('ipd_number', 'id');
    }

    public function store($input)
    {
        try {
            $caseId = $input['case_id'];
            $patientId = PatientCase::whereCaseId($caseId)->first()->patient_id;
            $input['patient_id'] = $patientId;
            // $oldBed = BedAssign::with('bed','ipdPatient')->where('case_id',$caseId)->first();

            // if($oldBed){
            //     $oldBed->bed()->update(['is_available' => 1]);
            // }

            // $data = Arr::except($input,['_token','ipd_patient_list_url','isEdit','ipd_patient_id','birth_date']);

            // BedAssign::updateOrCreate(['case_id' => $caseId], $data);
            BedAssign::create($input);
            $bed = Bed::find($input['bed_id']);
            $bed->update(['is_available' => 0]);

            return true;
        } catch (Exception $e) {
            throw new UnprocessableEntityHttpException($e->getMessage());
        }
    }

    public function update($input, $bedAssign)
    {
        try {
            $patientAdmissionRepo = app(PatientAdmissionRepository::class);
            $caseId = $input['case_id'];
            $patientId = PatientCase::whereCaseId($caseId)->first()->patient_id;
            $input['patient_id'] = $patientId;
            $input['discharge_date'] = (! empty($input['discharge_date'])) ? $input['discharge_date'] : null;
            $oldBedCase = BedAssign::with('bed', 'ipdPatient')->where('case_id', $caseId)->first();

            if ($oldBedCase) {
                $oldBedCase->ipdPatient()->update(['bed_id' => $input['bed_id']]);
                $oldBedCase->bed()->update(['is_available' => 1]);
            }
            $bedAssign->update($input);

            if (isset($bedId)) {
                $patientAdmissionRepo->setBedUnAvailable($bedId);
            } elseif (isset($input['bed_id'])) {
                $patientAdmissionRepo->setBedUnAvailable($input['bed_id']);
            } else {
                $patientAdmissionRepo->setBedAvailable($input['bed_id']);
            }

            return true;
        } catch (Exception $e) {
            throw new UnprocessableEntityHttpException($e->getMessage());
        }
    }

    public function getPatientBeds($bedAssign)
    {
        /** @var Bed $beds */
        $beds = Bed::where('is_available', 1)->orWhere('id', $bedAssign->bed_id)->where(
            'is_available',
            0
        )->pluck('name', 'id')->toArray();
        natcasesort($beds);

        return $beds;
    }

    public function getPatientCases($bedAssign): array
    {
        /** @var PatientCase $cases */
        $cases = PatientCase::whereDoesntHave('bedAssign')->orWhere('case_id', $bedAssign->case_id)->get();

        $result = [];
        foreach ($cases as $case) {
            $result[$case->case_id] = $case->case_id.'  '.$case->patient->user->full_name;
        }
        ksort($result);

        return $result;
    }

    public function createNotification(array $input)
    {
        try {
            $patient = PatientCase::whereCaseId($input['case_id'])->first()->patient->user->full_name;
            $ownerType = [Doctor::class, Nurse::class];
            $userIds = User::whereIn('owner_type', $ownerType)->pluck('owner_type', 'id')->toArray();
            $adminUser = User::role('Admin')->first();
            $allUsers = $userIds + [$adminUser->id => Notification::NOTIFICATION_FOR[Notification::ADMIN]];
            $users = getAllNotificationUser($allUsers);

            foreach ($users as $id => $ownerType) {
                addNotification([
                    Notification::NOTIFICATION_TYPE['Bed Assign'],
                    $id,
                    Notification::NOTIFICATION_FOR[User::getOwnerType($ownerType)],
                    $patient.' has bed assigned.',
                ]);
            }
        } catch (Exception $e) {
            Notification::make()
                ->danger()
                ->title($e->getMessage())
                ->send();
        }
    }
}