One Hat Cyber Team

View File Name : LiveConsultationRepository.php

<?php

namespace App\Repositories;

use App\Events\CreateGoogleEvent;
use App\Mail\NotifyMailLiveConsultation;
use App\Models\Doctor;
use App\Models\IpdPatientDepartment;
use App\Models\LiveConsultation;
use App\Models\Notification;
use App\Models\OpdPatientDepartment;
use App\Models\Patient;
use App\Models\User;
use App\Models\UserGoogleEventSchedule;
use App\Models\UserTenant;
use App\Models\UserZoomCredential;
use Carbon\Carbon;
use Exception;
use Illuminate\Contracts\Container\BindingResolutionException;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Mail;
use Symfony\Component\HttpKernel\Exception\UnprocessableEntityHttpException;

/**
 * Class LiveConsultationRepository
 */
class LiveConsultationRepository extends BaseRepository
{
    /**
     * @var array
     */
    protected $fieldSearchable = [
        'doctor_id',
        'patient_id',
        'consultation_title',
        'consultation_date',
        'consultation_duration_minutes',
        'type',
        'type_number',
        'description',
    ];

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

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

    public function getTypeNumber($input): Collection
    {
        if ($input['consultation_type'] == LiveConsultation::OPD) {
            return OpdPatientDepartment::where('patient_id', $input['patient_id'])->pluck('opd_number', 'id');
        }

        return IpdPatientDepartment::where('patient_id', $input['patient_id'])->pluck('ipd_number', 'id');
    }

    /**
     * @throws BindingResolutionException
     */
    public function store(array $input): bool
    {
        /** @var ZoomRepository $zoomRepo */
        $zoomRepo = App::makeWith(ZoomRepository::class, ['createdBy' => getLoggedInUserId()]);

        try {
            $input['created_by'] = getLoggedInUserId();
            $input['consultation_date'];
            $zoom = $zoomRepo->createZoomMeeting($input);
            $input['password'] = $zoom['password'];
            $input['meeting_id'] = $zoom['id'];
            $input['meta'] = $zoom;

            $input['status'] = $input['status'] ?? 0;
            $input['time_zone'] = $input['time_zone'] ?? '';

            $zoomModel = LiveConsultation::create($input);

            $userId = UserTenant::whereTenantId(getLoggedInUser()->tenant_id)->value('user_id');
            $hospitalDefaultAdmin = User::whereId($userId)->first();

            if (! empty($hospitalDefaultAdmin)) {

                $hospitalDefaultAdminEmail = $hospitalDefaultAdmin->email;
                $doctor = Doctor::whereId($input['doctor_id'])->first();
                $patient = Patient::whereId($input['patient_id'])->first();

                $mailData = [
                    'consultation_title' => $input['consultation_title'],
                    'consultation_date' => $input['consultation_date'],
                    'consultation_duration_time' => $input['consultation_duration_minutes'],
                    'created_by' => getLoggedInUser()->full_name,
                    'created_for' => $doctor->user->full_name,
                    'patient_name' => $patient->user->full_name,
                    'doctor_name' => $doctor->user->full_name,
                    'patient_type' => $input['type'] == 0 ? 'OPD' : 'IPD',
                    'doctor_department' => $doctor->department->title,
                ];

                $mailData['zoom_redirect_url'] = $input['meta']['start_url'];

                Mail::to($doctor->user->email)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));

                $mailData['zoom_redirect_url'] = $input['meta']['join_url'];

                Mail::to($hospitalDefaultAdminEmail)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));

                Mail::to($patient->user->email)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));
            }

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

    public function edit(array $input, LiveConsultation $liveConsultation): bool
    {
        /** @var ZoomRepository $zoomRepo */
        $zoomRepo = App::make(ZoomRepository::class, ['createdBy' => $liveConsultation->created_by]);

        try {

            DB::beginTransaction();

            if ($input['platform_type'] == LiveConsultation::GOOGLE_MEET) {
                $newConsultationDateTime = \Carbon\Carbon::parse($input['consultation_date']);
                $oldConsultationDateTime = \Carbon\Carbon::parse($liveConsultation->consultation_date);

                if ($newConsultationDateTime->ne($oldConsultationDateTime) || $input['consultation_duration_minutes'] != $liveConsultation->consultation_duration_minutes) {
                    $oldGoogleMeetingData = UserGoogleEventSchedule::where(['user_id' => getLoggedInUserId(), 'google_live_consultation_id' => $liveConsultation->id])->first();

                    $oldGoogleMeetingData->delete();
                    $liveConsultation->delete();

                    $this->googleMeetStore($input);
                } else {
                    $input['created_by'] = getLoggedInUserId();
                    $input['created_by'] = $liveConsultation->created_by != getLoggedInUserId() ? $liveConsultation->created_by : getLoggedInUserId();
                    $startTime = $input['consultation_date'];
                    $input['consultation_date'] = Carbon::parse($startTime)->format('Y-m-d H:i:s');
                    $liveConsultation->update($input);
                }
            } else {
                $zoomSessionUpdate = $zoomRepo->updateZoomMeeting($input, $liveConsultation);
                $input['created_by'] = getLoggedInUserId();
                $input['created_by'] = $liveConsultation->created_by != getLoggedInUserId() ? $liveConsultation->created_by : getLoggedInUserId();
                $startTime = $input['consultation_date'];
                $input['consultation_date'] = Carbon::parse($startTime)->format('Y-m-d H:i:s');

                $zoomModel = $liveConsultation->update($input);
            }

            DB::commit();

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

    /**
     * @return mixed
     */
    public function createUserZoom(array $input)
    {
        try {
            UserZoomCredential::updateOrCreate([
                'user_id' => getLoggedInUserId(),
            ], [
                'user_id' => getLoggedInUserId(),
                'zoom_api_key' => $input['zoom_api_key'],
                'zoom_api_secret' => $input['zoom_api_secret'],
            ]);

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

    public function createNotification(array $input = [])
    {
        try {
            $patient = Patient::with('patientUser')->where('id', $input['patient_id'])->first();
            $doctor = Doctor::with('doctorUser')->where('id', $input['doctor_id'])->first();
            $userIds = [
                $doctor->user_id => Notification::NOTIFICATION_FOR[Notification::DOCTOR],
                $patient->user_id => Notification::NOTIFICATION_FOR[Notification::PATIENT],
            ];

            $adminUser = User::role('Admin')->first();
            $allUsers = $userIds + [$adminUser->id => Notification::NOTIFICATION_FOR[Notification::ADMIN]];
            $users = getAllNotificationUser($allUsers);

            foreach ($users as $key => $notification) {
                if ($notification == Notification::NOTIFICATION_FOR[Notification::PATIENT]) {
                    $title = $patient->patientUser->full_name.' your live consultation has been created by '.$doctor->doctorUser->full_name.'.';
                } else {
                    $title = $patient->patientUser->full_name.' live consultation has been booked.';
                }
                addNotification([
                    Notification::NOTIFICATION_TYPE['Live Consultation'],
                    $key,
                    $notification,
                    $title,
                ]);
            }
        } catch (Exception $e) {
            throw new UnprocessableEntityHttpException($e->getMessage());
        }
    }

    public function filter($status)
    {
        if ($status == 'all') {
            return LiveConsultation::where(
                'patient_id',
                getLoggedInUser()->owner_id
            )->with('patient', 'doctor', 'user')->orderBy('id', 'desc')->get();
        } elseif ($status == 'awaited') {
            return LiveConsultation::where(
                'status',
                LiveConsultation::STATUS_AWAITED
            )
                ->where('patient_id', getLoggedInUser()->owner_id)
                ->orderBy('id', 'desc')
                ->get();
        } elseif ($status == 'cancelled') {
            return LiveConsultation::with('patient', 'doctor', 'user')->where(
                'status',
                LiveConsultation::STATUS_CANCELLED
            )->where('patient_id', getLoggedInUser()->owner_id)->orderBy('id', 'desc')->get();
        } elseif ($status == 'finished') {
            return LiveConsultation::with('patient', 'doctor', 'user')->where(
                'status',
                LiveConsultation::STATUS_FINISHED
            )->where('patient_id', getLoggedInUser()->owner_id)->orderBy('id', 'desc')->get();
        } else {
            return false;
        }
    }

    public function googleMeetStore($input)
    {
        try {
            $input['created_by'] = getLoggedInUserId();
            $startTime = $input['consultation_date'];
            $input['consultation_date'] = Carbon::parse($startTime)->format('Y-m-d H:i:s');
            $input['password'] = '123456';
            $input['status'] = $input['status'] ?? 0;
            $input['meeting_id'] = $input['meeting_id'] ?? '';
            $input['time_zone'] = $input['meeting_id'] ?? '';

            $liveConsultation = LiveConsultation::create($input);
            CreateGoogleEvent::dispatch($liveConsultation->id);

            $userId = UserTenant::whereTenantId(getLoggedInUser()->tenant_id)->value('user_id');
            $hospitalDefaultAdmin = User::whereId($userId)->first();

            if (! empty($hospitalDefaultAdmin)) {

                $hospitalDefaultAdminEmail = $hospitalDefaultAdmin->email;
                $doctor = Doctor::whereId($input['doctor_id'])->first();
                $patient = Patient::whereId($input['patient_id'])->first();

                $googleUserEventSchedule = UserGoogleEventSchedule::where('user_id', $liveConsultation->user->id)->where('google_live_consultation_id', $liveConsultation->id)->first();

                if (($liveConsultation->platform_type == LiveConsultation::GOOGLE_MEET) && ! empty($googleUserEventSchedule->google_meet_link)) {
                    $data['google_meet_link'] = $googleUserEventSchedule->google_meet_link;
                } else {
                    $data['google_meet_link'] = '';
                }

                $mailData = [
                    'consultation_title' => $input['consultation_title'],
                    'consultation_date' => $input['consultation_date'],
                    'consultation_duration_time' => $input['consultation_duration_minutes'],
                    'created_by' => getLoggedInUser()->full_name,
                    'created_for' => $doctor->user->full_name,
                    'patient_name' => $patient->user->full_name,
                    'doctor_name' => $doctor->user->full_name,
                    'patient_type' => $input['type'] == 0 ? 'OPD' : 'IPD',
                    'doctor_department' => $doctor->department->title,
                ];

                $mailData['google_meet_link'] = $data['google_meet_link'];

                Mail::to($doctor->user->email)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));

                Mail::to($hospitalDefaultAdminEmail)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));

                Mail::to($patient->user->email)
                    ->send(new NotifyMailLiveConsultation(
                        'emails.live_consultation_created_mail',
                        __('messages.new_change.consultancy_create'),
                        $mailData
                    ));
            }

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