<?php

/**
 * @copyright © Melograno Ventures. All rights reserved.
 * @licence   See LICENCE.md for license details.
 */

namespace AmeliaBooking\Application\Services\Notification;

use AmeliaBooking\Application\Services\Helper\HelperService;
use AmeliaBooking\Application\Services\Placeholder\PlaceholderService;
use AmeliaBooking\Application\Services\QrCode\QrCodeApplicationService;
use AmeliaBooking\Application\Services\Settings\SettingsService;
use AmeliaBooking\Domain\Collection\Collection;
use AmeliaBooking\Domain\Entity\Entities;
use AmeliaBooking\Domain\Entity\Notification\Notification;
use AmeliaBooking\Domain\Entity\Notification\NotificationLog;
use AmeliaBooking\Domain\Entity\User\AbstractUser;
use AmeliaBooking\Domain\Entity\User\Customer;
use AmeliaBooking\Domain\Entity\User\Provider;
use AmeliaBooking\Domain\Services\DateTime\DateTimeService;
use AmeliaBooking\Domain\ValueObjects\String\BookingStatus;
use AmeliaBooking\Domain\ValueObjects\String\Email;
use AmeliaBooking\Domain\ValueObjects\String\NotificationStatus;
use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException;
use AmeliaBooking\Infrastructure\Repository\Notification\NotificationLogRepository;
use AmeliaBooking\Infrastructure\Repository\User\CustomerRepository;
use AmeliaBooking\Infrastructure\Repository\User\UserRepository;
use AmeliaBooking\Infrastructure\Services\Notification\MailgunService;
use AmeliaBooking\Infrastructure\Services\Notification\OutlookService;
use AmeliaBooking\Infrastructure\Services\Notification\PHPMailService;
use AmeliaBooking\Infrastructure\Services\Notification\SMTPService;
use AmeliaBooking\Infrastructure\WP\Integrations\ThriveAutomator\Apps\AmeliaBooking;
use Exception;
use InvalidArgumentException;
use Slim\Exception\ContainerException;
use Slim\Exception\ContainerValueNotFoundException;

/**
 * Class EmailNotificationService
 *
 * @package AmeliaBooking\Application\Services\Notification
 */
class EmailNotificationService extends AbstractNotificationService
{
    /** @noinspection MoreThanThreeArgumentsInspection */
    /**
     * @param array        $appointmentArray
     * @param Notification $notification
     * @param bool         $logNotification
     * @param int|null     $bookingKey
     *
     * @throws \AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException
     * @throws ContainerValueNotFoundException
     * @throws QueryExecutionException
     * @throws Exception
     */
    public function sendNotification(
        $appointmentArray,
        $notification,
        $logNotification,
        $bookingKey = null,
        $allBookings = null,
        $invoice = []
    ) {
        /** @var NotificationLogRepository $notificationLogRepo */
        $notificationLogRepo = $this->container->get('domain.notificationLog.repository');

        /** @var UserRepository $userRepository */
        $userRepository = $this->container->get('domain.users.repository');

        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        /** @var PlaceholderService $placeholderService */
        $placeholderService = $this->container->get("application.placeholder.{$appointmentArray['type']}.service");

        /** @var SettingsService $settingsAS */
        $settingsAS = $this->container->get('application.settings.service');

        /** @var \AmeliaBooking\Domain\Services\Settings\SettingsService $settingsService */
        $settingsService = $this->container->get('domain.settings.service');

        /** @var HelperService $helperService */
        $helperService = $this->container->get('application.helper.service');

        $notificationSettings = $settingsService->getCategorySettings('notifications');

        if (!$notificationSettings['senderEmail'] || !$notificationSettings['senderName']) {
            return;
        }

        $isCustomerPackage = isset($appointmentArray['isForCustomer']) && $appointmentArray['isForCustomer'];
        $isBackend         = isset($appointmentArray['isBackend']) && $appointmentArray['isBackend'];

        /** @var AbstractUser $customer */
        $customer = (
            $appointmentArray['type'] !== Entities::PACKAGE &&
            $appointmentArray['type'] !== Entities::APPOINTMENTS &&
            $bookingKey !== null
        ) ? $userRepository->getById($appointmentArray['bookings'][$bookingKey]['customerId']) : null;

        if ($appointmentArray['type'] === Entities::PACKAGE || $appointmentArray['type'] === Entities::APPOINTMENTS) {
            $info = $isCustomerPackage || $appointmentArray['type'] === Entities::APPOINTMENTS
                ? json_encode($appointmentArray['customer']) : null;

            $userLanguage = null;
        } else {
            $info = $bookingKey !== null ? $appointmentArray['bookings'][$bookingKey]['info'] : null;

            $userLanguage = $customer ? $customer->getTranslations() : null;
        }

        if ($userLanguage) {
            $customerDefaultLanguage =
                $customer && $customer->getTranslations() ?
                json_decode($customer->getTranslations()->getValue(), true)['defaultLanguage'] :
                null;
        } else {
            $customerDefaultLanguage =
                ($isCustomerPackage && isset($appointmentArray['customer']['translations'])) ?
                json_decode($appointmentArray['customer']['translations'], true)['defaultLanguage'] :
                null;
        }

        // set customer email if WP user is connected and ameliaCustomer doesn't have email
        if ($customer && !!$customer->getExternalId() && !$customer->getEmail()->getValue()) {
            $wpUserEmail = get_userdata($customer->getExternalId()->getValue())->user_email;
            $customer->setEmail(new Email($wpUserEmail));
        }

        $translateNotification = true;

        $generalSettings = $settingsService->getCategorySettings('general');

        $locale = $customerDefaultLanguage ?: $helperService->getLocaleFromBooking($info);

        if (!in_array($locale, $generalSettings['usedLanguages'])) {
            $translateNotification = false;
        }

        $notificationSubject = $helperService->getBookingTranslation(
            $locale,
            $translateNotification && $notification->getTranslations() ? $notification->getTranslations()->getValue() : null,
            'subject'
        ) ?: $notification->getSubject()->getValue();

        $notificationContent = $helperService->getBookingTranslation(
            $locale,
            $translateNotification && $notification->getTranslations() ? $notification->getTranslations()->getValue() : null,
            'content'
        ) ?: $notification->getContent()->getValue();

        $data = $placeholderService->getPlaceholdersData(
            $appointmentArray,
            $bookingKey,
            'email',
            null,
            $allBookings,
            false,
            $notification->getName()->getValue()
        );

        $sendIcs        = $settingsService->getSetting('ics', 'sendIcsAttachment');
        $sendIcsPending = $settingsService->getSetting('ics', 'sendIcsAttachmentPending');

        $bookingStatus = $bookingKey !== null && isset($appointmentArray['bookings'][$bookingKey]['status'])
            ? $appointmentArray['bookings'][$bookingKey]['status']
            : $appointmentArray['status'];

        if (!empty($data['icsFiles'])) {
            $icsFiles = ($sendIcs && $bookingStatus === BookingStatus::APPROVED || $sendIcsPending && $bookingStatus === BookingStatus::PENDING)
                ? $data['icsFiles'][($isCustomerPackage || $bookingKey !== null) && !$isBackend ? 'translated' : 'original'] : [];
        }

        $subject = $placeholderService->applyPlaceholders($notificationSubject, $data);

        $body = $placeholderService->applyPlaceholders($notificationContent, $data);

        $users = $this->getUsersInfo(
            $notification->getSendTo()->getValue(),
            $appointmentArray,
            $bookingKey,
            $data
        );

        foreach ($users as $user) {
            if ($customer && $customer->getId()->getValue() === $user['id'] && $customer->getEmail() && !$user['email']) {
                $user['email'] = $customer->getEmail()->getValue();
            }

            try {
                if ($user['email']) {
                    $appointmentId = $appointmentArray['type'] === Entities::APPOINTMENT ?
                        $appointmentArray['id'] : (
                            $appointmentArray['type'] === Entities::APPOINTMENTS ?
                            $appointmentArray['recurring'][0]['appointment']['id'] : null
                        );

                    if (!empty($appointmentArray['isRetry'])) {
                        /** @var Collection $sentNotifications */
                        $sentNotifications = $notificationLogRepo->getSentNotificationsByUserAndEntity(
                            $user['id'],
                            'email',
                            $appointmentArray['type'] === Entities::APPOINTMENTS ?
                                Entities::APPOINTMENT : $appointmentArray['type'],
                            $appointmentArray['type'] === Entities::PACKAGE ?
                                $appointmentArray['packageCustomerId'] : $appointmentId
                        );

                        if ($sentNotifications->length()) {
                            continue;
                        }
                    }

                    if (!$isCustomerPackage && !empty($data['providersAppointments'][$user['id']])) {
                        $body = $placeholderService->applyPlaceholders(
                            $notificationContent,
                            array_merge(
                                $data,
                                ['cart_appointments_details' => $data['providersAppointments'][$user['id']]['cart_appointments_details']]
                            )
                        );
                    }

                    $reParsedData = !$isCustomerPackage ?
                        $placeholderService->reParseContentForProvider(
                            $appointmentArray,
                            $subject,
                            $body,
                            $user['id']
                        ) : [
                            'body'    => $body,
                            'subject' => $subject,
                        ];

                    $logNotificationId = null;

                    // allow user to manipulate emails via filter
                    $emailData = apply_filters(
                        'amelia_manipulate_email_data',
                        [
                            'email'       => $user['email'],
                            'subject'     => $reParsedData['subject'],
                            'body'        => $this->getParsedBody($reParsedData['body']),
                            'bcc'         => $settingsAS->getBccEmails(),
                            'attachments' => !empty($icsFiles) ? $icsFiles : [],
                            'data'        => [
                                'reservation' => $appointmentArray,
                                'bookingKey'  => $bookingKey,
                            ],
                        ]
                    );

                    $qrCodeItems = [];

                    if (
                        $notification->getName()->getValue() === 'customer_event_qr_code' && $bookingKey !== null
                    ) {
                        if (!empty($appointmentArray['bookings'][$bookingKey]['qrCodes'])) {
                            /** @var QrCodeApplicationService $qrApplicationService */
                            $qrApplicationService = $this->container->get('application.qrcode.service');

                            $qrCodeItems = $qrApplicationService->createQrCodeEventTickets(
                                $appointmentArray,
                                $appointmentArray['bookings'][$bookingKey]
                            );
                        }
                    }

                    if ($logNotification && $user['id']) {
                        $logNotificationId = $notificationLogRepo->add(
                            $notification,
                            $user['id'],
                            $appointmentId,
                            $appointmentArray['type'] === Entities::EVENT ? $appointmentArray['id'] : null,
                            $appointmentArray['type'] === Entities::PACKAGE ? $appointmentArray['packageCustomerId'] : null,
                            json_encode(
                                [
                                    'subject'  => $emailData['subject'],
                                    'body'     => $emailData['body'],
                                    'icsFiles' => $emailData['attachments'],
                                ]
                            )
                        );
                    }

                    if ($this->getSend() && empty($emailData['skipSending'])) {
                        $attachments = [];
                        if (!empty($emailData['attachments'])) {
                            $attachments = array_merge($attachments, $emailData['attachments']);
                        }
                        if (!empty($invoice)) {
                            $attachments = array_merge($attachments, [$invoice]);
                        }
                        if (!empty($qrCodeItems)) {
                            $attachments = array_merge($attachments, $qrCodeItems);
                        }

                        $mailService->send(
                            $emailData['email'],
                            $emailData['subject'],
                            $emailData['body'],
                            $emailData['bcc'],
                            $attachments
                        );
                    } elseif (empty($emailData['skipSending'])) {
                        $this->addPreparedNotificationData(
                            array_merge($emailData, ['logNotificationId' => $logNotificationId])
                        );
                    }

                    if ($logNotificationId) {
                        $notificationLogRepo->updateFieldById((int)$logNotificationId, 1, 'sent');
                    }
                }
            } catch (Exception $e) {
            }
        }
    }

    /**
     * @throws ContainerValueNotFoundException
     * @throws QueryExecutionException
     * @throws \AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException
     */
    public function sendUndeliveredNotifications()
    {
        /** @var UserRepository $userRepository */
        $userRepository = $this->container->get('domain.users.repository');

        /** @var NotificationLogRepository $notificationLogRepo */
        $notificationLogRepo = $this->container->get('domain.notificationLog.repository');

        /** @var Collection $undeliveredNotifications */
        $undeliveredNotifications = $notificationLogRepo->getUndeliveredNotifications('email');

        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        /** @var SettingsService $settingsAS */
        $settingsAS = $this->container->get('application.settings.service');

        /** @var NotificationLog $undeliveredNotification */
        foreach ($undeliveredNotifications->getItems() as $undeliveredNotification) {
            try {
                /** @var AbstractUser $user */
                $user = $userRepository->getById($undeliveredNotification->getUserId()->getValue());

                $data = json_decode($undeliveredNotification->getData()->getValue(), true);

                $mailService->send(
                    $user->getEmail()->getValue(),
                    $data['subject'],
                    $data['body'],
                    $settingsAS->getBccEmails(),
                    $data['icsFiles']
                );

                $notificationLogRepo->updateFieldById($undeliveredNotification->getId()->getValue(), 1, 'sent');
            } catch (\Exception $e) {
            }
        }
    }

    /**
     * @throws ContainerValueNotFoundException
     * @throws QueryExecutionException
     * @throws \AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException
     * @throws Exception
     */
    public function sendBirthdayGreetingNotifications()
    {
        /** @var Collection $notifications */
        $notifications = $this->getByNameAndType('customer_birthday_greeting', $this->type);
        /** @var NotificationLogRepository $notificationLogRepo */
        $notificationLogRepo = $this->container->get('domain.notificationLog.repository');

        $notificationsForSending = new Collection();

        foreach ($notifications->getItems() as $notification) {
            // Check if notification is enabled and it is time to send notification
            if (
                $notification->getStatus()->getValue() === NotificationStatus::ENABLED &&
                $notification->getTime() &&
                DateTimeService::getNowDateTimeObject() >=
                DateTimeService::getCustomDateTimeObject($notification->getTime()->getValue())
            ) {
                $notificationsForSending->addItem($notification);
            }
        }

        $customers = $notificationLogRepo->getBirthdayCustomers($this->type);

        $this->sendOtherNotifications($notifications, $customers->toArray());
    }


    /**
     * @param int $customerId
     * @param array $invoice
     *
     * @throws ContainerValueNotFoundException
     * @throws QueryExecutionException
     * @throws \AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException
     * @throws Exception
     */
    public function sendInvoiceNotification($customerId, $invoice)
    {
        /** @var Collection $notifications */
        $notifications = $this->getByNameAndType('customer_invoice', $this->type);

        /** @var CustomerRepository $customerRepository */
        $customerRepository = $this->container->get('domain.users.customers.repository');

        if ($customerId) {
            $customer = $customerRepository->getById($customerId);

            $this->sendOtherNotifications($notifications, [$customer->toArray()], [$invoice]);
        }
    }


    /**
     * @param Collection $notifications
     * @param array $customers
     * @param array $attachments
     *
     * @throws ContainerValueNotFoundException
     * @throws QueryExecutionException
     * @throws \AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException
     * @throws Exception
     */
    public function sendOtherNotifications($notifications, $customers, $attachments = [])
    {
        foreach ($notifications->getItems() as $notification) {
            // Check if notification is enabled and it is time to send notification
            if ($notification->getStatus()->getValue() === NotificationStatus::ENABLED) {
                /** @var NotificationLogRepository $notificationLogRepo */
                $notificationLogRepo = $this->container->get('domain.notificationLog.repository');

                /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
                $mailService = $this->container->get('infrastructure.mail.service');

                /** @var PlaceholderService $placeholderService */
                $placeholderService = $this->container->get('application.placeholder.appointment.service');

                /** @var SettingsService $settingsAS */
                $settingsAS = $this->container->get('application.settings.service');

                /** @var \AmeliaBooking\Domain\Services\Settings\SettingsService $settingsService */
                $settingsService = $this->container->get('domain.settings.service');

                $notificationSettings = $settingsService->getCategorySettings('notifications');

                if (!$notificationSettings['senderEmail'] || !$notificationSettings['senderName']) {
                    return;
                }

                $companyData = $placeholderService->getCompanyData();

                foreach ($customers as $customerArray) {
                    if ($customerArray['email']) {
                        $data = [
                            'customer_email'      => $customerArray['email'],
                            'customer_first_name' => $customerArray['firstName'],
                            'customer_last_name'  => $customerArray['lastName'],
                            'customer_full_name'  => $customerArray['firstName'] . ' ' . $customerArray['lastName'],
                            'customer_phone'      => $customerArray['phone']
                        ];

                        /** @noinspection AdditionOperationOnArraysInspection */
                        $data += $companyData;

                        $subject = $placeholderService->applyPlaceholders(
                            $notification->getSubject()->getValue(),
                            $data
                        );

                        $body = $placeholderService->applyPlaceholders(
                            $notification->getContent()->getValue(),
                            $data
                        );

                        try {
                            $mailService->send(
                                $data['customer_email'],
                                $subject,
                                $this->getParsedBody($body),
                                $settingsAS->getBccEmails(),
                                $attachments
                            );

                            $logNotificationId = $notificationLogRepo->add(
                                $notification,
                                $customerArray['id']
                            );

                            if ($logNotificationId) {
                                $notificationLogRepo->updateFieldById($logNotificationId, 1, 'sent');
                            }
                        } catch (Exception $e) {
                        }
                    }
                }
            }
        }
    }

    /**
     * @param Customer $customer
     * @param string   $locale
     *
     * @return void
     *
     * @throws ContainerValueNotFoundException
     * @throws ContainerException
     * @throws InvalidArgumentException
     * @throws QueryExecutionException
     * @throws Exception
     */
    public function sendRecoveryEmail($customer, $locale, $cabinetType)
    {
        /** @var Collection $notifications */
        $notifications = $cabinetType === 'customer' ?
            $this->getByNameAndType('customer_account_recovery', 'email') :
            $this->getByNameAndType('provider_panel_recovery', 'email');


        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        /** @var PlaceholderService $placeholderService */
        $placeholderService = $this->container->get('application.placeholder.appointment.service');

        /** @var HelperService $helperService */
        $helperService = $this->container->get('application.helper.service');

        /** @var \AmeliaBooking\Domain\Services\Settings\SettingsService $settingsService */
        $settingsService = $this->container->get('domain.settings.service');

        $notificationSettings = $settingsService->getCategorySettings('notifications');

        if (!$notificationSettings['senderEmail'] || !$notificationSettings['senderName']) {
            return;
        }

        foreach ($notifications->getItems() as $notification) {
            if ($notification->getStatus()->getValue() === NotificationStatus::ENABLED) {
                $data = [
                    'customer_email'      => $customer->getEmail()->getValue(),
                    'customer_first_name' => $customer->getFirstName()->getValue(),
                    'customer_last_name'  => $customer->getLastName()->getValue(),
                    'customer_full_name'  =>
                    $customer->getFirstName()->getValue() . ' ' . $customer->getLastName()->getValue(),
                    'customer_phone'      => $customer->getPhone() ? $customer->getPhone()->getValue() : '',
                    'customer_panel_url'  => $cabinetType === 'customer' ? $helperService->getCustomerCabinetUrl(
                        $customer->getEmail()->getValue(),
                        'email',
                        null,
                        null,
                        $locale,
                        true
                    ) : $helperService->getProviderCabinetUrl(
                        $customer->getEmail()->getValue(),
                        'email',
                        null,
                        null,
                        true
                    )
                ];

                /** @noinspection AdditionOperationOnArraysInspection */
                $data += $placeholderService->getCompanyData();

                if ($cabinetType === 'provider') {
                    $data = array_combine(
                        array_map(
                            function ($key) {
                                return str_replace('customer', 'employee', $key);
                            },
                            array_keys($data)
                        ),
                        $data
                    );
                }

                $notificationContent = $notification->getContent()->getValue();
                $notificationSubject = $notification->getSubject()->getValue();

                $customerDefaultLanguage =
                    $cabinetType === 'customer' && $customer->getTranslations() ?
                    json_decode($customer->getTranslations()->getValue(), true)['defaultLanguage'] :
                    null;

                if (!empty($customerDefaultLanguage)) {
                    $notificationSubject = $helperService->getBookingTranslation(
                        $customerDefaultLanguage,
                        $notification->getTranslations() ? $notification->getTranslations()->getValue() : null,
                        'subject'
                    ) ?: $notification->getSubject()->getValue();

                    $notificationContent = $helperService->getBookingTranslation(
                        $customerDefaultLanguage,
                        $notification->getTranslations() ? $notification->getTranslations()->getValue() : null,
                        'content'
                    ) ?: $notification->getContent()->getValue();
                }

                $body = $placeholderService->applyPlaceholders(
                    $notificationContent,
                    $data
                );

                $subject = $placeholderService->applyPlaceholders(
                    $notificationSubject,
                    $data
                );

                try {
                    $mailService->send(
                        $cabinetType === 'customer' ?
                            $data['customer_email'] :
                            $data['employee_email'],
                        $subject,
                        $this->getParsedBody($body)
                    );
                } catch (Exception $e) {
                }
            }
        }
    }

    /**
     * @param Provider $provider
     *
     * @param $plainPassword
     * @return void
     *
     * @throws QueryExecutionException
     */
    public function sendEmployeePanelAccess($provider, $plainPassword)
    {
        /** @var Collection $notifications */
        $notifications = $this->getByNameAndType('provider_panel_access', 'email');

        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        /** @var PlaceholderService $placeholderService */
        $placeholderService = $this->container->get('application.placeholder.appointment.service');

        /** @var \AmeliaBooking\Domain\Services\Settings\SettingsService $settingsService */
        $settingsService = $this->container->get('domain.settings.service');

        $notificationSettings = $settingsService->getCategorySettings('notifications');

        if (!$notificationSettings['senderEmail'] || !$notificationSettings['senderName']) {
            return;
        }

        foreach ($notifications->getItems() as $notification) {
            if ($notification->getStatus()->getValue() === NotificationStatus::ENABLED) {
                $data = [
                    'employee_email'      => $provider['email'],
                    'employee_first_name' => $provider['firstName'],
                    'employee_last_name'  => $provider['lastName'],
                    'employee_full_name'  =>
                    $provider['firstName'] . ' ' . $provider['lastName'],
                    'employee_phone'      => $provider['phone'],
                    'employee_password'   => $plainPassword,
                    'employee_panel_url'  => trim(
                        $this->container->get('domain.settings.service')->getSetting('roles', 'providerCabinet')['pageUrl']
                    )
                ];

                /** @noinspection AdditionOperationOnArraysInspection */
                $data += $placeholderService->getCompanyData();

                $subject = $placeholderService->applyPlaceholders(
                    $notification->getSubject()->getValue(),
                    $data
                );

                $body = $placeholderService->applyPlaceholders(
                    $notification->getContent()->getValue(),
                    $data
                );

                try {
                    $mailService->send($data['employee_email'], $subject, $this->getParsedBody($body), []);
                } catch (Exception $e) {
                }
            }
        }
    }

    /**
     * @param string $body
     */
    private function replaceStyledTags($body)
    {
        return preg_replace_callback(
            '#<p([^>]*)>(.*?)</p>#is',
            function ($matches) {
                $attrs = $matches[1];

                $content = $matches[2];

                if (preg_match('/style\s*=\s*["\'][^"\']*(text-align:\s*(center|right))[^"\']*["\']/i', $attrs)) {
                    return "<div$attrs>$content</div>";
                }

                return $matches[0];
            },
            $body
        );
    }

    /**
     * @param string $body
     *
     * @return string
     */
    public function getParsedBody($body)
    {
        /** @var \AmeliaBooking\Domain\Services\Settings\SettingsService $settingsService */
        $settingsService = $this->container->get('domain.settings.service');

        $body = str_replace(
            [
                'class="ql-size-small"',
                'class="ql-size-large"',
                'class="ql-size-huge"',
                'class="ql-font-serif"',
                'class="ql-font-monospace"',
                'class="ql-direction-rtl"',
                'class="ql-align-center"',
                'class="ql-align-justify"',
                'class="ql-align-right"',
                'class="ql-size-small ql-font-monospace"',
                'class="ql-size-large ql-font-monospace"',
                'class="ql-size-huge ql-font-monospace"',
                'class="ql-font-monospace ql-size-small"',
                'class="ql-font-monospace ql-size-large"',
                'class="ql-font-monospace ql-size-huge"',
                'class="ql-size-small ql-font-serif"',
                'class="ql-size-large ql-font-serif"',
                'class="ql-size-huge ql-font-serif"',
                'class="ql-font-serif ql-size-small"',
                'class="ql-font-serif ql-size-large"',
                'class="ql-font-serif ql-size-huge"',
                'class="ql-align-justify ql-direction-rtl"',
                'class="ql-align-center ql-direction-rtl"',
                'class="ql-align-right ql-direction-rtl"',
                'class="ql-direction-rtl ql-align-justify"',
                'class="ql-direction-rtl ql-align-center"',
                'class="ql-direction-rtl ql-align-right"'
            ],
            [
                'style="font-size: 0.75em;"',
                'style="font-size: 1.5em;"',
                'style="font-size: 2.5em;"',
                'style="font-family: Georgia, Times New Roman, serif;"',
                'style="font-family: Monaco, Courier New, monospace;"',
                'style="direction: rtl; text-align: inherit;"',
                'style="text-align: center;"',
                'style="text-align: justify;"',
                'style="text-align: right;"',
                'style="font-size: 0.75em; font-family: Monaco, Courier New, monospace;"',
                'style="font-size: 1.5em; font-family: Monaco, Courier New, monospace;"',
                'style="font-size: 2.5em; font-family: Monaco, Courier New, monospace;"',
                'style="font-family: Monaco, Courier New, monospace; font-size: 0.75em;"',
                'style="font-family: Monaco, Courier New, monospace; font-size: 1.5em;"',
                'style="font-family: Monaco, Courier New, monospace; font-size: 2.5em;"',
                'style="font-size: 0.75em; font-family: Georgia, Times New Roman, serif;"',
                'style="font-size: 1.5em; font-family: Georgia, Times New Roman, serif;"',
                'style="font-size: 2.5em; font-family: Georgia, Times New Roman, serif;"',
                'style="font-family: Georgia, Times New Roman, serif; font-size: 0.75em;"',
                'style="font-family: Georgia, Times New Roman, serif; font-size: 1.5em;"',
                'style="font-family: Georgia, Times New Roman, serif; font-size: 2.5em;"',
                'style="text-align: justify; direction: rtl;"',
                'style="text-align: center; direction: rtl;"',
                'style="text-align: right; direction: rtl;"',
                'style="direction: rtl; text-align: justify;"',
                'style="direction: rtl; text-align: center;"',
                'style="direction: rtl; text-align: right;"'
            ],
            $body
        );

        // Remove only formatting newlines/tabs between block-level tags
        // This preserves intentional spaces between inline elements like <span> text </span>
        // phpcs:ignore
        $body = preg_replace(
            '/(<\/(p|div|h[1-6]|ul|ol|li|table|tr|td|th|blockquote)>)\s+(<(p|div|h[1-6]|ul|ol|li|table|tr|td|th|blockquote)[^>]*>)/i',
            '$1$3',
            $body
        );

        // fix for 2 x style attribute on same html tag
        $splitBodyByTags = explode('<', $body);

        foreach ($splitBodyByTags as $k => $v) {
            if (substr_count($v, "style") === 2) {
                $splitBodyByTags[$k] = str_replace(';" style="', '; ', $v);
            }
        }

        $body = implode('<', $splitBodyByTags);

        $breakReplacement = $settingsService->getSetting('notifications', 'breakReplacement');

        // First, handle empty paragraphs (created by double Enter in WYSIWYG)
        // Convert </p><p><br></p><p> sequences to preserve blank lines
        $body = preg_replace('/<\/p><p><br\s*\/?><\/p><p>/i', '</p>###EMPTY_PARA###<p>', $body);

        $replaceSource = [
            '</p><p>',
            '<p>',
            '</p>'
        ];

        $replaceTarget = [
            '<br>',
            '',
            ''
        ];

        $body = str_replace(
            $replaceSource,
            $replaceTarget,
            $this->replaceStyledTags($body)
        );

        // Now convert the empty paragraph placeholders to double line break for blank line
        $body = str_replace('###EMPTY_PARA###', '<br><br>', $body);

        return $breakReplacement === '' || $breakReplacement === '<br>' ?
            $body :
            str_replace('<p><br></p>', $breakReplacement, $body);
    }


    /**
     * @param string $to
     *
     * @throws \AmeliaPHPMailer\PHPMailer\Exception
     */
    public function sendSmsBalanceLowEmail($to)
    {
        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        $subject = 'Low SMS Balance Alert';

        $body = '
            Dear valuable customer,<br><br>
            Your SMS balance is running low. To continue seamless messaging services, please top up your balance promptly.
             <ol type="I">
                  <li>Log in to your account.</li>
                  <li>Go to the "Notifications" and in "SMS Notification" section go to “Recharge Balance”</li>
             </ol>
            Need assistance? Contact our <a href="https://store.Melograno Ventures.com/?ameliaGleap=1">support team</a>.<br><br>
            Thank you for your attention.<br><br>
            Best regards,<br>
            Team Amelia
            ';

        $mailService->send($to, $subject, $body);
    }

    /**
     * @return void
     * @throws QueryExecutionException
     */
    public function sendPreparedNotifications()
    {
        /** @var PHPMailService|SMTPService|MailgunService|OutlookService $mailService */
        $mailService = $this->container->get('infrastructure.mail.service');

        /** @var NotificationLogRepository $notificationLogRepo */
        $notificationLogRepo = $this->container->get('domain.notificationLog.repository');

        foreach ($this->getPreparedNotificationData() as $item) {
            try {
                $mailService->send(
                    $item['email'],
                    $item['subject'],
                    $item['body'],
                    $item['bcc'],
                    $item['attachments']
                );
            } catch (\Exception $e) {
                if ($item['id']) {
                    $notificationLogRepo->updateFieldById((int)$item['id'], 0, 'sent');
                }
            }
        }
    }
}