芝麻web文件管理V1.00

编辑当前文件:/home/pulsehostuk9/www/cloud.pulsehost.co.uk/modules/Calendar/Cron.php

<?php
/**
 * This code is licensed under AGPLv3 license or Afterlogic Software License
 * if commercial version of the product was purchased.
 * For full statements of the licenses see LICENSE-AFTERLOGIC and LICENSE-AGPL3 files.
 */

namespace Aurora\Modules\Calendar;

require_once \dirname(__file__) . "/../../system/autoload.php";
\Aurora\System\Api::Init();

class Reminder
{
    private $oUsersManager;

private $oCalendarManager;

private $oMailManager;

private $oAccountsManager;

private $oCalendarModule;

/**
     * @var array
     */
    private $aUsers;

/**
     * @var string
     */
    private $sCurRunFilePath;

public function __construct()
    {
        $this->aUsers = array();
        $this->sCurRunFilePath = \Aurora\System\Api::DataPath() . '/reminder-run';

$oMailModule =  \Aurora\Modules\Mail\Module::getInstance();
        $this->oCalendarModule = \Aurora\Modules\Calendar\Module::getInstance();

$this->oUsersManager = \Aurora\Modules\Core\Module::getInstance()->getUsersManager() ;
        $this->oCalendarManager = $this->oCalendarModule->getManager();
        $this->oMailManager = $oMailModule->getMailManager();
        $this->oAccountsManager = $oMailModule->getAccountsManager();
    }

public static function NewInstance()
    {
        return new self();
    }

/**
     * @param string $sKey
     * @param \Aurora\Modules\Core\Models\User $oUser = null
     * @param array $aParams = null
     * @param int $iMinutes
     *
     * @return string
     */
    private function i18n($sKey, $oUser = null, $aParams = null, $iMinutes = null)
    {
        return $this->oCalendarModule->I18N($sKey, $aParams, $iMinutes, $oUser->UUID);
    }

/**
     * @param string $sLogin
     *
     * @return \Aurora\Modules\Core\Models\User
     */
    private function &getUser($sLogin)
    {
        $mResult = null;

if (!isset($this->aUsers[$sLogin])) {
            $this->aUsers[$sLogin] = $this->oUsersManager->getUserByPublicId($sLogin);
        }

$mResult = &$this->aUsers[$sLogin];

if (is_array($this->aUsers[$sLogin]) && 30 < count($this->aUsers[$sLogin])) {
            $this->aUsers = array_slice($this->aUsers, -30);
        }

return $mResult;
    }

/**
     * @param \Aurora\Modules\Core\Models\User $oUser
     * @param string $sEventName
     * @param string $sDateStr
     * @param string $sCalendarName
     * @param string $sEventText
     * @param string $sCalendarColor
     *
     * @return string
     */
    private function createBodyHtml($oUser, $sEventName, $sDateStr, $sCalendarName, $sEventText, $sCalendarColor)
    {
        $sEventText = nl2br($sEventText);

return sprintf(
            '
			<div style="padding: 10px; font-size: 12px; text-align: center; word-wrap: break-word;">
				<div style="border: 4px solid %s; padding: 15px; width: 370px;">
					<h2 style="margin: 5px; font-size: 18px; line-height: 1.4;">%s</h2>
					<span>%s%s</span><br/>
					<span>%s: %s</span><br/><br/>
					<span>%s</span><br/>
				</div>
				<p style="color:#667766; width: 400px; font-size: 10px;">%s</p>
			</div>',
            $sCalendarColor,
            $sEventName,
            ucfirst($this->i18n('EVENT_BEGIN', $oUser)),
            $sDateStr,
            $this->i18n('CALENDAR', $oUser),
            $sCalendarName,
            $sEventText,
            $this->i18n('EMAIL_EXPLANATION', $oUser, array(
                'EMAIL' => '<a href="mailto:' . $oUser->PublicId . '">' . $oUser->PublicId . '</a>',
                'CALENDAR_NAME' => $sCalendarName
            ))
        );
    }

/**
     * @param \Aurora\Modules\Core\Models\User $oUser
     * @param string $sEventName
     * @param string $sDateStr
     * @param string $sCalendarName
     * @param string $sEventText
     *
     * @return string
     */
    private function createBodyText($oUser, $sEventName, $sDateStr, $sCalendarName, $sEventText)
    {
        return sprintf(
            "%s\r\n\r\n%s%s\r\n\r\n%s: %s %s\r\n\r\n%s",
            $sEventName,
            ucfirst($this->i18n('EVENT_BEGIN', $oUser)),
            $sDateStr,
            $this->i18n('CALENDAR', $oUser),
            $sCalendarName,
            $sEventText,
            $this->i18n('EMAIL_EXPLANATION', $oUser, array(
                'EMAIL' => '<a href="mailto:' . $oUser->PublicId . '">' . $oUser->PublicId . '</a>',
                'CALENDAR_NAME' => $sCalendarName
            ))
        );
    }

/**
     * @param \Aurora\Modules\Core\Models\User $oUser
     * @param string $sSubject
     * @param string $mHtml = null
     * @param string $mText = null
     *
     * @return \MailSo\Mime\Message
     */
    private function createMessage($oUser, $sSubject, $mHtml = null, $mText = null)
    {
        $oMessage = \MailSo\Mime\Message::NewInstance();
        $oMessage->RegenerateMessageId();

//		$sXMailer = \Aurora\System\Api::GetValue('webmail.xmailer-value', '');
        //		if (0 < strlen($sXMailer))
        //		{
        //			$oMessage->SetXMailer($sXMailer);
        //		}

$oMessage
            ->SetFrom(\MailSo\Mime\Email::NewInstance($oUser->PublicId))
            ->SetSubject($sSubject)
        ;

$oToEmails = \MailSo\Mime\EmailCollection::NewInstance($oUser->PublicId);
        if ($oToEmails && $oToEmails->Count()) {
            $oMessage->SetTo($oToEmails);
        }

if ($mHtml !== null) {
            $oMessage->AddText($mHtml, true);
        }

if ($mText !== null) {
            $oMessage->AddText($mText, false);
        }

return $oMessage;
    }

/**
     *
     * @param \Aurora\Modules\Core\Models\User $oUser
     * @param string $sSubject
     * @param string $sEventName
     * @param string $sDate
     * @param string $sCalendarName
     * @param string $sEventText
     * @param string $sCalendarColor
     *
     * @return bool
     */
    private function sendMessage($oUser, $sSubject, $sEventName, $sDate, $sCalendarName, $sEventText, $sCalendarColor)
    {
        $oMessage = $this->createMessage(
            $oUser,
            $sSubject,
            $this->createBodyHtml($oUser, $sEventName, $sDate, $sCalendarName, $sEventText, $sCalendarColor),
            $this->createBodyText($oUser, $sEventName, $sDate, $sCalendarName, $sEventText)
        );

try {
            $oAccount = $this->oAccountsManager->getAccountUsedToAuthorize($oUser->PublicId);
            if (!$oAccount instanceof \Aurora\Modules\Mail\Models\MailAccount) {
                return false;
            }
            return $this->oMailManager->sendMessage($oAccount, $oMessage);
        } catch (\Exception $oException) {
            \Aurora\System\Api::Log('MessageSend Exception', \Aurora\System\Enums\LogLevel::Error, 'cron-');
            \Aurora\System\Api::LogException($oException, \Aurora\System\Enums\LogLevel::Error, 'cron-');
        }

return false;
    }

private function getSubject($oUser, $sEventStart, $iEventStartTS, $sEventName, $sDate, $iNowTS, $bAllDay = false)
    {
        $sSubject = '';

if ($bAllDay) {
            $oEventStart = new \DateTime("@$iEventStartTS", new \DateTimeZone('UTC'));
            $oEventStart->setTimezone(new \DateTimeZone($oUser->DefaultTimeZone ?: 'UTC'));
            $iEventStartTS = $oEventStart->getTimestamp() - $oEventStart->getOffset();
        }

$iMinutes = round(($iEventStartTS - $iNowTS) / 60);

if ($iMinutes > 0 && $iMinutes < 60) {
            $sSubject = $this->i18n('SUBJECT_MINUTES_PLURAL', $oUser, array(
                'EVENT_NAME' => $sEventName,
                'DATE' => date('G:i', strtotime($sEventStart)),
                'COUNT' => $iMinutes
            ), $iMinutes);
        } elseif ($iMinutes >= 60 && $iMinutes < 1440) {
            $sSubject = $this->i18n('SUBJECT_HOURS_PLURAL', $oUser, array(
                'EVENT_NAME' => $sEventName,
                'DATE' => date('G:i', strtotime($sEventStart)),
                'COUNT' => round($iMinutes / 60)
            ), round($iMinutes / 60));
        } elseif ($iMinutes >= 1440 && $iMinutes < 10080) {
            $sSubject = $this->i18n('SUBJECT_DAYS_PLURAL', $oUser, array(
                'EVENT_NAME' => $sEventName,
                'DATE' => $sDate,
                'COUNT' => round($iMinutes / 1440)
            ), round($iMinutes / 1440));
        } elseif ($iMinutes >= 10080) {
            $sSubject = $this->i18n('SUBJECT_WEEKS_PLURAL', $oUser, array(
                'EVENT_NAME' => $sEventName,
                'DATE' => $sDate,
                'COUNT' => round($iMinutes / 10080)
            ), round($iMinutes / 10080));
        } else {
            $sSubject = $this->i18n('SUBJECT', $oUser, array(
                'EVENT_NAME' => $sEventName,
                'DATE' => $sDate
            ));
        }

return $sSubject;
    }

private function getDateTimeFormat($oUser)
    {
        $sDateFormat = 'm/d/Y';
        $sTimeFormat = 'h:i A';

if ($oUser->DateFormat === \Aurora\System\Enums\DateFormat::DDMMYYYY) {
            $sDateFormat = 'd/m/Y';
        } elseif ($oUser->DateFormat === \Aurora\System\Enums\DateFormat::MMDDYYYY) {
            $sDateFormat = 'm/d/Y';
        } elseif ($oUser->DateFormat === \Aurora\System\Enums\DateFormat::DD_MONTH_YYYY) {
            $sDateFormat = 'd m Y';
        } elseif ($oUser->DateFormat === \Aurora\System\Enums\DateFormat::MMDDYY) {
            $sDateFormat = 'm/d/y';
        } elseif ($oUser->DateFormat === \Aurora\System\Enums\DateFormat::DDMMYY) {
            $sDateFormat = 'd/m/Y';
        }

if ($oUser->TimeFormat == \Aurora\System\Enums\TimeFormat::F24) {
            $sTimeFormat = 'H:i';
        }

return $sDateFormat . ' ' . $sTimeFormat;
    }

public function GetReminders($iStart, $iEnd)
    {
        $aReminders = $this->oCalendarManager->getReminders($iStart, $iEnd);
        $aEvents = array();

if ($aReminders && is_array($aReminders) && count($aReminders) > 0) {
            foreach ($aReminders as $aReminder) {
                $oUser = $this->getUser($aReminder['user']);

$sCalendarUri = $aReminder['calendaruri'];
                $sEventId = $aReminder['eventid'];
                $iStartTime = $aReminder['starttime'];
                $iReminderTime = $aReminder['time'];

$aEventData = [];
                if ($oUser) {
                    $aEventData['data'] = $this->oCalendarManager->getEvent($oUser->PublicId, $sCalendarUri, $sEventId);

$dt = new \DateTime();
                    $dt->setTimestamp($iStartTime);
                    $oDefaultTimeZone = new \DateTimeZone($oUser->DefaultTimeZone ?: 'UTC');
                    $dt->setTimezone($oDefaultTimeZone);

if (is_array($aEventData['data'])) {
                        $CurrentEvent = null;
                        foreach ($aEventData['data'] as $key => $aEvent) {
                            if (is_int($key)) {
                                if (empty($CurrentEvent)) {
                                    $CurrentEvent = $aEvent;
                                } elseif (isset($aEvent['excluded']) && $this->EventHasReminder($aEvent, $iReminderTime)) {
                                    $CurrentEvent = $aEvent;
                                }
                                unset($aEventData['data'][$key]);
                            }
                        }
                        if (!empty($CurrentEvent)) {
                            $aEventData['data'][0] = $CurrentEvent;
                        }
                    }
                    $aEventData['time'] = $dt->format($this->getDateTimeFormat($oUser));
                }

if (count($aEventData) > 0) {
                    $aEvents[$aReminder['user']][$sCalendarUri][$sEventId] = $aEventData;
                }
            }
        }

return $aEvents;
    }

public function DeleteOutdatedReminders($iTime)
    {
        $this->oCalendarManager->deleteOutdatedReminders($iTime);
    }

public function EventHasReminder($aEvent, $iReminderTime)
    {
        foreach ($aEvent['alarms'] as $iAlarm) {
            if ($aEvent['startTS'] - $iAlarm * 60 === (int) $iReminderTime) {
                return true;
            }
        }
        return false;
    }

public function Execute()
    {
        \Aurora\System\Api::Log('---------- Start cron script', \Aurora\System\Enums\LogLevel::Full, 'cron-');

$oTimeZoneUTC = new \DateTimeZone('UTC');
        $oNowDT_UTC = new \DateTimeImmutable('now', $oTimeZoneUTC);
        $iNowTS = $oNowDT_UTC->getTimestamp();

$oStartDT_UTC = clone $oNowDT_UTC;
        $oStartDT_UTC = $oStartDT_UTC->sub(new \DateInterval('PT30M'));

if (file_exists($this->sCurRunFilePath)) {
            $handle = fopen($this->sCurRunFilePath, 'r');
            $sCurRunFileTS = fread($handle, 10);
            if (!empty($sCurRunFileTS) && is_numeric($sCurRunFileTS)) {
                $oStartDT_UTC = new \DateTimeImmutable("@$sCurRunFileTS");
            }
        }

$iStartTS = $oStartDT_UTC->getTimestamp();

if ($iNowTS >= $iStartTS) {
            \Aurora\System\Api::Log('Start time: ' . $oStartDT_UTC->format('r'), \Aurora\System\Enums\LogLevel::Full, 'cron-');
            \Aurora\System\Api::Log('End time: ' . $oNowDT_UTC->format('r'), \Aurora\System\Enums\LogLevel::Full, 'cron-');

$aEvents = $this->GetReminders($iStartTS, $iNowTS);

foreach ($aEvents as $sEmail => $aUserCalendars) {
                foreach ($aUserCalendars as $sCalendarUri => $aUserEvents) {
                    foreach ($aUserEvents as $aUserEvent) {
                        $aSubEvents = $aUserEvent['data'];

if (isset($aSubEvents, $aSubEvents['vcal'])) {
                            $vCal = $aSubEvents['vcal'];
                            foreach ($aSubEvents as $mKey => $aEvent) {
                                if ($mKey !== 'vcal') {
                                    $oUser = $this->getUser($sEmail);
                                    $oCalendar = $this->oCalendarManager->getCalendar($oUser->PublicId, $sCalendarUri);

if ($oCalendar && $oCalendar->Id === $aEvent['calendarId']) {
                                        $sEventCalendarId = $aEvent['calendarId'];
                                        $sEventId = $aEvent['uid'];
                                        $sEventStart = $aEvent['start'];
                                        $iEventStartTS = $aEvent['startTS'];
                                        $sEventName = $aEvent['subject'];
                                        $sEventText = $aEvent['description'];
                                        $bAllDay = $aEvent['allDay'];
                                        $sDate = $aUserEvent['time'];

if (isset($vCal->getBaseComponent('VEVENT')->RRULE) && $iEventStartTS < $iNowTS) { // the correct date for repeatable events
                                            $aBaseEvents = $vCal->getBaseComponents('VEVENT');
                                            if (isset($aBaseEvents[0])) {
                                                $oEventStartDT = \Aurora\Modules\Calendar\Classes\Helper::getNextRepeat($oNowDT_UTC, $aBaseEvents[0]);
                                                if ($oEventStartDT) {
                                                    $sEventStart = $oEventStartDT->format('Y-m-d H:i:s');
                                                    if ($bAllDay) {
                                                        $sDate = $oEventStartDT->format('d m Y');
                                                    } else {
                                                        $sDate = $oEventStartDT->format('d m Y H:i');
                                                    }
                                                    $iEventStartTS = $oEventStartDT->getTimestamp();
                                                }
                                            }
                                        }

$sSubject = $this->getSubject($oUser, $sEventStart, $iEventStartTS, $sEventName, $sDate, $iNowTS, $bAllDay);

$aUsers = [
                                            $oUser->Id => $oUser
                                        ];

// TODO: get users to whom the calendar is shared

// $aCalendarUsers = $this->oCalendarManager->getCalendarUsers($oUser->PublicId, $oCalendar);
                                        // if (0 < count($aCalendarUsers)) {
                                        //     foreach ($aCalendarUsers as $aCalendarUser) {
                                        //         $oCalendarUser = $this->getUser($aCalendarUser['email']);
                                        //         if ($oCalendarUser) {
                                        //             $aUsers[$oCalendarUser->Id] = $oCalendarUser;
                                        //         }
                                        //     }
                                        // }

foreach ($aUsers as $oUserItem) {
                                            $bIsMessageSent = false;
                                            $oEvent = $this->oCalendarManager->getEvent($sEmail, $sEventCalendarId, $sEventId);
                                            if ($oEvent) {
                                                \Aurora\System\Api::Log('Send reminder - calendar: \'' . $sEventCalendarId . '\',  event: \'' . $sEventName . '\' started on \'' . $sDate . '\' to \'' . $oUserItem->PublicId . '\'', \Aurora\System\Enums\LogLevel::Full, 'cron-');
                                                $bIsMessageSent = $this->sendMessage($oUserItem, $sSubject, $sEventName, $sDate, $oCalendar->DisplayName, $sEventText, $oCalendar->Color);

$aArgs = array(
                                                    array(
                                                        "Email" => $sEmail,
                                                        "Debug" => false,
                                                        "Data" => array(
                                                            array(
                                                                "Type" => $aEvent['type'] === 'VTODO' ? 'task' : 'event',
                                                                "From" => "",
                                                                "To" => $sEmail,
                                                                "Subject" => $sSubject,
                                                                "EventId" => $sEventId,
                                                                "CalendarId" => $sEventCalendarId
                                                            )
                                                        )
                                                    )
                                                );

$bResult = false;

$this->oCalendarModule->broadcastEvent(
                                                    'SendNotification',
                                                    $aArgs,
                                                    $bResult
                                                );
                                            } else {
                                                \Aurora\System\Api::Log('Event not found - User: ' . $sEmail . ', Calendar: ' . $sCalendarUri . ' , Event: ' . $sEventId, \Aurora\System\Enums\LogLevel::Full, 'cron-');
                                            }
                                            if ($bIsMessageSent) {
                                                $sEventUrl = (substr(strtolower($sEventId), -4) !== '.ics') ? $sEventId . '.ics' : $sEventId;
                                                $this->oCalendarManager->updateReminder($oUserItem->PublicId, $sEventCalendarId, $sEventUrl, $vCal->serialize());
                                            } else {
                                                \Aurora\System\Api::Log('Send reminder for event: FAILED!', \Aurora\System\Enums\LogLevel::Full, 'cron-');
                                            }
                                        }
                                    } else {
                                        \Aurora\System\Api::Log('Calendar ' . $sCalendarUri . ' not found for user \'' . $oUser->PublicId . '\'', \Aurora\System\Enums\LogLevel::Full, 'cron-');
                                    }
                                }
                            }
                        }
                    }
                }
            }

$this->DeleteOutdatedReminders($iStartTS);
            file_put_contents($this->sCurRunFilePath, $iNowTS);
        }

\Aurora\System\Api::Log('---------- End cron script', \Aurora\System\Enums\LogLevel::Full, 'cron-');
    }
}

$iTimer = microtime(true);

Reminder::NewInstance()->Execute();

\Aurora\System\Api::Log('Cron execution time: ' . (microtime(true) - $iTimer) . ' sec.', \Aurora\System\Enums\LogLevel::Full, 'cron-');