ADD: Class SendMailSmtpClass

Перенесем данный класс в ядро, для последующей работы.

https://github.com/LibArea/libarea/issues/21
This commit is contained in:
Evg 2022-10-19 12:39:17 +03:00
parent c933aa2f03
commit 96af68f207
4 changed files with 283 additions and 3 deletions

View file

@ -0,0 +1,13 @@
<?php
declare(strict_types=1);
namespace App\Exception;
class AutorizationException extends \Exception
{
public static function Smtp(string $value): self
{
return new self("Send (smtp) error: `{$value}`.");
}
}

View file

@ -1,6 +1,7 @@
<?php
use App\Models\User\{SettingModel, UserModel};
use App\Exception\AutorizationException;
class SendEmail
{
@ -56,7 +57,7 @@ class SendEmail
{
if (config('integration.smtp')) {
$mailSMTP = new \SmtpMail\SendMailSmtpClass(config('integration.smtp_user'), config('integration.smtp_pass'), 'ssl://' . config('integration.smtp_host'), config('integration.smtp_port'), "UTF-8");
$mailSMTP = new SendMailSmtpClass(config('integration.smtp_user'), config('integration.smtp_pass'), 'ssl://' . config('integration.smtp_host'), config('integration.smtp_port'), "UTF-8");
$from = array(
config('meta.name'), // Имя отправителя
@ -68,7 +69,7 @@ class SendEmail
if ($result === true) {
echo "Done";
} else {
echo "Error: " . $result;
throw AutorizationException::Smtp("Error - " . $result);
}
} else {
$mail = new \Phphleb\Muller\StandardMail(false);

View file

@ -0,0 +1,267 @@
<?php
/**
* https://github.com/Ipatov/SendMailSmtpClass
* @author Ipatov Evgeniy <admin@vk-book.ru>
* @version 1.2
*/
use App\Exception\AutorizationException;
class SendMailSmtpClass {
/**
*
* @var string $smtp_username - логин
* @var string $smtp_password - пароль
* @var string $smtp_host - хост
* @var array $smtp_from - от кого
* @var integer $smtp_port - порт
* @var string $smtp_charset - кодировка
* @var string $boundary - разделитель содержимого письма(для отправки файлов)
* @var bool $addFile - содержит письмо файл или нет
* @var string $multipart - заголовки для письма с файлами
* @var array $arrayCC - массив получателей копии письма
* @var array $arrayBCC - массив получателей скрытой копии письма
*
*/
public $smtp_username;
public $smtp_password;
public $smtp_host;
public $smtp_from;
public $smtp_port;
public $smtp_charset;
public $boundary;
public $addFile = false;
public $multipart;
public $arrayCC;
public $arrayBCC;
public function __construct($smtp_username, $smtp_password, $smtp_host, $smtp_port = 25, $smtp_charset = "utf-8") {
$this->smtp_username = $smtp_username;
$this->smtp_password = $smtp_password;
$this->smtp_host = $smtp_host;
$this->smtp_port = $smtp_port;
$this->smtp_charset = $smtp_charset;
// разделитель файлов
$this->boundary = "--".md5(uniqid(time()));
$this->multipart = "";
}
/**
* Отправка письма
*
* @param string $mailTo - получатель письма
* @param string $subject - тема письма
* @param string $message - тело письма
* @param array $smtp_from - отправитель. Массив с именем и e-mail
*
* @return bool|string В случаи отправки вернет true, иначе текст ошибки
*
*/
function send($mailTo, $subject, $message, $smtp_from) {
// подготовка содержимого письма к отправке
$contentMail = $this->getContentMail($subject, $message, $smtp_from, $mailTo);
try {
if(!$socket = @fsockopen($this->smtp_host, $this->smtp_port, $errorNumber, $errorDescription, 30)){
throw AutorizationException::Smtp($errorNumber.".".$errorDescription);
}
if (!$this->_parseServer($socket, "220")){
throw AutorizationException::Smtp('Connection error');
}
$server_name = $_SERVER["SERVER_NAME"];
fputs($socket, "EHLO $server_name\r\n");
if(!$this->_parseServer($socket, "250")){
// если сервер не ответил на EHLO, то отправляем HELO
fputs($socket, "HELO $server_name\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: HELO');
}
}
fputs($socket, "AUTH LOGIN\r\n");
if (!$this->_parseServer($socket, "334")) {
fclose($socket);
throw AutorizationException::Smtp('Autorization error');
}
fputs($socket, base64_encode($this->smtp_username) . "\r\n");
if (!$this->_parseServer($socket, "334")) {
fclose($socket);
throw AutorizationException::Smtp('Autorization error');
}
fputs($socket, base64_encode($this->smtp_password) . "\r\n");
if (!$this->_parseServer($socket, "235")) {
fclose($socket);
throw AutorizationException::Smtp('Autorization error');
}
fputs($socket, "MAIL FROM: <".$smtp_from[1].">\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: MAIL FROM');
}
$mailTo = str_replace(" ", "", $mailTo);
$emails_to_array = explode(',', $mailTo);
foreach($emails_to_array as $email) {
fputs($socket, "RCPT TO: <{$email}>\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: RCPT TO');
}
}
// если есть кому отправить копию
if(!empty($this->arrayCC)){
foreach($this->arrayCC as $emailCC) {
fputs($socket, "RCPT TO: <{$emailCC}>\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: RCPT TO');
}
}
}
// если есть кому отправить скрытую копию
if(!empty($this->arrayBCC)){
foreach($this->arrayBCC as $emailBCC) {
fputs($socket, "RCPT TO: <{$emailBCC}>\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: RCPT TO');
}
}
}
fputs($socket, "DATA\r\n");
if (!$this->_parseServer($socket, "354")) {
fclose($socket);
throw AutorizationException::Smtp('Error of command sending: DATA');
}
fputs($socket, $contentMail."\r\n.\r\n");
if (!$this->_parseServer($socket, "250")) {
fclose($socket);
throw AutorizationException::Smtp("E-mail didn't sent");
}
fputs($socket, "QUIT\r\n");
fclose($socket);
} catch (Exception $e) {
return $e->getMessage();
}
return true;
}
// добавление файла в письмо
public function addFile($path){
$file = @fopen($path, "rb");
if(!$file) {
throw AutorizationException::Smtp("File `{$path}` didn't open");
}
$data = fread($file, filesize( $path ) );
fclose($file);
$filename = basename($path);
$multipart = "\r\n--{$this->boundary}\r\n";
$multipart .= "Content-Type: application/octet-stream; name=\"$filename\"\r\n";
$multipart .= "Content-Transfer-Encoding: base64\r\n";
$multipart .= "Content-Disposition: attachment; filename=\"$filename\"\r\n";
$multipart .= "\r\n";
$multipart .= chunk_split(base64_encode($data));
$this->multipart .= $multipart;
$this->addFile = true;
}
// парсинг ответа сервера
private function _parseServer($socket, $response) {
$responseServer = $response;
while (@substr($responseServer, 3, 1) != ' ') {
if (!($responseServer = fgets($socket, 256))) {
return false;
}
}
if (!(substr($responseServer, 0, 3) == $response)) {
return false;
}
return true;
}
// подготовка содержимого письма
private function getContentMail($subject, $message, $smtp_from, $mailTo){
// если кодировка windows-1251, то перекодируем тему
if( strtolower($this->smtp_charset) == "windows-1251" ){
$subject = iconv('utf-8', 'windows-1251', $subject);
}
$contentMail = "Date: " . date("D, d M Y H:i:s") . " UT\r\n";
$contentMail .= 'Subject: =?' . $this->smtp_charset . '?B?' . base64_encode($subject) . "=?=\r\n";
// заголовок письма
$headers = "MIME-Version: 1.0\r\n";
// кодировка письма
if($this->addFile){
// если есть файлы
$headers .= "Content-Type: multipart/mixed; boundary=\"{$this->boundary}\"\r\n";
}else{
$headers .= "Content-type: text/html; charset={$this->smtp_charset}\r\n";
}
// $headers .= "From: {$smtp_from[0]} <{$smtp_from[1]}>\r\n"; // от кого письмо
$headers .= 'From: ' . '=?UTF-8?B?' . base64_encode($smtp_from[0]) . '?= ' . '<' . $smtp_from[1] . '>' . "\n";
$headers .= "To: ".$mailTo."\r\n"; // кому
// если есть кому отправить копию
if(!empty($this->arrayCC)){
foreach($this->arrayCC as $emailCC) {
$headers.= "Cc: ".$emailCC."\r\n"; // кому копию
}
}
// если есть кому отправить копию
if(!empty($this->arrayBCC)){
foreach($this->arrayBCC as $emailBCC) {
$headers.= "Bcc: ".$emailBCC."\r\n"; // кому копию
}
}
$contentMail .= $headers . "\r\n";
if($this->addFile){
// если есть файлы
$multipart = "--{$this->boundary}\r\n";
$multipart .= "Content-Type: text/html; charset=utf-8\r\n";
$multipart .= "Content-Transfer-Encoding: base64\r\n";
$multipart .= "\r\n";
$multipart .= chunk_split(base64_encode($message));
// файлы
$multipart .= $this->multipart;
$multipart .= "\r\n--{$this->boundary}--\r\n";
$contentMail .= $multipart;
}else{
$contentMail .= $message . "\r\n";
}
// если кодировка windows-1251, то все письмо перекодируем
if( strtolower($this->smtp_charset) == "windows-1251" ){
$contentMail = iconv('utf-8', 'windows-1251', $contentMail);
}
return $contentMail;
}
// добавлении получателя копии
public function toCopy($email){
$this->arrayCC[] = $email;
}
// добавлении получателя скрытой копии
public function toHideCopy($email){
$this->arrayBCC[] = $email;
}
}

View file

@ -32,7 +32,6 @@
"phphleb/debugpan": "1.*",
"phphleb/radjax": "dev-master",
"phphleb/muller": "dev-main",
"ipatov/smtp-mail": "dev-master",
"cocur/slugify": "^4.1",
"taufik-nurrohman/parsedown-extra-plugin": "dev-main",
"donatj/phpuseragentparser": "dev-master",