kiri-core/HttpServer/Abstracts/Callback.php

<?php
declare(strict_types=1);

namespace HttpServer\Abstracts;


use Exception;
use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\SMTP;
use Snowflake\Abstracts\Config;
use Snowflake\Error\Logger;
use Snowflake\Event;
use Snowflake\Exception\ConfigException;
use Snowflake\Snowflake;
use Swoole\Coroutine\Server;
use Swoole\Timer;


/**
 * Class Callback
 * @package HttpServer\Abstracts
 */
abstract class Callback extends HttpService
{


	/**
	 * @param $server
	 * @param $worker_id
	 * @param $message
	 * @throws Exception
	 */
	protected function clear($server, $worker_id, $message)
	{
		try {
			fire(Event::SYSTEM_RESOURCE_CLEAN);

			\logger()->insert();

			Snowflake::clearProcessId($server->worker_pid);

			$logger = Snowflake::app()->getLogger();
			$logger->write($this->_MESSAGE[$message] . $worker_id);
			$logger->clear();

			$this->eventNotify($message);
		} catch (\Throwable $exception) {
			$this->addError($exception);
		}
	}


	const EVENT_ERROR = 'WORKER:ERROR';
	const EVENT_STOP = 'WORKER:STOP';
	const EVENT_EXIT = 'WORKER:EXIT';


	private array $_MESSAGE = [
		self::EVENT_ERROR => 'The server error. at No.',
		self::EVENT_STOP  => 'The server stop. at No.',
		self::EVENT_EXIT  => 'The server exit. at No.',
	];

	/**
	 * @param $message
	 * @throws Exception
	 */
	private function eventNotify($message)
	{
		switch ($message) {
			case self::EVENT_ERROR:
				fire(Event::SERVER_WORKER_ERROR);
				break;
			case self::EVENT_EXIT:
				fire(Event::SERVER_WORKER_EXIT);
				break;
			case self::EVENT_STOP:
				fire(Event::SERVER_WORKER_STOP);
				break;
		}
	}


	/**
	 * @return PHPMailer
	 * @throws \PHPMailer\PHPMailer\Exception
	 * @throws ConfigException
	 */
	private function createEmail(): PHPMailer
	{
		$mail = new PHPMailer(true);
		$mail->SMTPDebug = SMTP::DEBUG_SERVER;                                                // Enable verbose debug output
		$mail->isSMTP();                                                                      // Send using SMTP
		$mail->Host = Config::get('email.host');                                              // Set the SMTP server to send through
		$mail->SMTPAuth = true;                                                               // Enable SMTP authentication
		$mail->Debugoutput = false;                                                           // Enable SMTP authentication
		$mail->CharSet = "UTF8";                                                              // Enable SMTP authentication
		$mail->Username = Config::get('email.username');                                      // SMTP username
		$mail->Password = Config::get('email.password');                                      // SMTP password
		$mail->SMTPSecure = PHPMailer::ENCRYPTION_SMTPS;                                      // Enable TLS encryption; `PHPMailer::ENCRYPTION_SMTPS` encouraged
		$mail->Port = Config::get('email.port');                                              // TCP port to connect to, use 465 for `PHPMailer::ENCRYPTION_SMTPS` above
		$mail->setFrom(Config::get('email.send.address'), Config::get('email.send.nickname'));
		return $mail;
	}


	/**
	 * @param $message
	 * @throws
	 */
	protected function system_mail($message)
	{
		try {
			if (!Config::get('email.enable', false, false)) {
				return;
			}
			$mail = $this->createEmail();
			$receives = Config::get('email.receive');
			if (empty($receives) || !is_array($receives)) {
				throw new Exception('接收人信息错误');
			}
			foreach ($receives as $receive) {
				$mail->addAddress($receive['address'], $receive['nickname']);                 // Add a recipient
			}
			$mail->isHTML(true);                                                                                            // Set email format to HTML
			$mail->Subject = 'service error';
			$mail->Body = $message;
			$mail->AltBody = $message;
			$mail->send();
		} catch (\Throwable $e) {
			$this->addError($e, 'email');
		}
	}

}