mirror of
https://github.com/espocrm/espocrm.git
synced 2026-06-28 23:16:03 +00:00
397 lines
13 KiB
PHP
397 lines
13 KiB
PHP
<?php
|
|
/************************************************************************
|
|
* This file is part of EspoCRM.
|
|
*
|
|
* EspoCRM - Open Source CRM application.
|
|
* Copyright (C) 2014-2018 Yuri Kuznetsov, Taras Machyshyn, Oleksiy Avramenko
|
|
* Website: http://www.espocrm.com
|
|
*
|
|
* EspoCRM is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* EspoCRM is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with EspoCRM. If not, see http://www.gnu.org/licenses/.
|
|
*
|
|
* The interactive user interfaces in modified source and object code versions
|
|
* of this program must display Appropriate Legal Notices, as required under
|
|
* Section 5 of the GNU General Public License version 3.
|
|
*
|
|
* In accordance with Section 7(b) of the GNU General Public License version 3,
|
|
* these Appropriate Legal Notices must retain the display of the "EspoCRM" word.
|
|
************************************************************************/
|
|
|
|
namespace Espo\Core\Mail;
|
|
|
|
use \Espo\Entities\Email;
|
|
|
|
use \Zend\Mime\Message as MimeMessage;
|
|
use \Zend\Mime\Part as MimePart;
|
|
use \Zend\Mime\Mime as Mime;
|
|
|
|
use \Zend\Mail\Message;
|
|
use \Zend\Mail\Transport\Smtp as SmtpTransport;
|
|
use \Zend\Mail\Transport\SmtpOptions;
|
|
|
|
use \Espo\Core\Exceptions\Error;
|
|
|
|
class Sender
|
|
{
|
|
protected $config;
|
|
|
|
protected $entityManager;
|
|
|
|
protected $transport;
|
|
|
|
protected $isGlobal = false;
|
|
|
|
protected $params = array();
|
|
|
|
public function __construct($config, $entityManager)
|
|
{
|
|
$this->config = $config;
|
|
$this->entityManager = $entityManager;
|
|
$this->useGlobal();
|
|
}
|
|
|
|
protected function getConfig()
|
|
{
|
|
return $this->config;
|
|
}
|
|
|
|
protected function getEntityManager()
|
|
{
|
|
return $this->entityManager;
|
|
}
|
|
|
|
public function resetParams()
|
|
{
|
|
$this->params = array();
|
|
return $this;
|
|
}
|
|
|
|
public function setParams(array $params = array())
|
|
{
|
|
$this->params = array_merge($this->params, $params);
|
|
return $this;
|
|
}
|
|
|
|
public function useSmtp(array $params = array())
|
|
{
|
|
$this->isGlobal = false;
|
|
$this->params = $params;
|
|
|
|
$this->transport = new SmtpTransport();
|
|
|
|
$config = $this->config;
|
|
|
|
$localHostName = $config->get('smtpLocalHostName', gethostname());
|
|
|
|
$opts = array(
|
|
'name' => $localHostName,
|
|
'host' => $params['server'],
|
|
'port' => $params['port'],
|
|
'connection_config' => array()
|
|
);
|
|
if ($params['auth']) {
|
|
if (!empty($params['smtpAuthMechanism'])) {
|
|
$opts['connection_class'] = $params['smtpAuthMechanism'];
|
|
} else {
|
|
$opts['connection_class'] = 'login';
|
|
}
|
|
$opts['connection_config']['username'] = $params['username'];
|
|
$opts['connection_config']['password'] = $params['password'];
|
|
}
|
|
if ($params['security']) {
|
|
$opts['connection_config']['ssl'] = strtolower($params['security']);
|
|
}
|
|
|
|
if (array_key_exists('fromName', $params)) {
|
|
$this->params['fromName'] = $params['fromName'];
|
|
}
|
|
if (array_key_exists('fromAddress', $params)) {
|
|
$this->params['fromAddress'] = $params['fromAddress'];
|
|
}
|
|
|
|
$options = new SmtpOptions($opts);
|
|
$this->transport->setOptions($options);
|
|
|
|
return $this;
|
|
}
|
|
|
|
public function useGlobal()
|
|
{
|
|
$this->params = array();
|
|
if ($this->isGlobal) {
|
|
return $this;
|
|
}
|
|
|
|
$this->transport = new SmtpTransport();
|
|
|
|
$config = $this->config;
|
|
|
|
$localHostName = $config->get('smtpLocalHostName', gethostname());
|
|
|
|
$opts = array(
|
|
'name' => $localHostName,
|
|
'host' => $config->get('smtpServer'),
|
|
'port' => $config->get('smtpPort'),
|
|
'connection_config' => array()
|
|
);
|
|
if ($config->get('smtpAuth')) {
|
|
$opts['connection_class'] = $config->get('smtpAuthMechanism', 'login');
|
|
$opts['connection_config']['username'] = $config->get('smtpUsername');
|
|
$opts['connection_config']['password'] = $config->get('smtpPassword');
|
|
}
|
|
if ($config->get('smtpSecurity')) {
|
|
$opts['connection_config']['ssl'] = strtolower($config->get('smtpSecurity'));
|
|
}
|
|
|
|
$options = new SmtpOptions($opts);
|
|
$this->transport->setOptions($options);
|
|
|
|
$this->isGlobal = true;
|
|
|
|
return $this;
|
|
}
|
|
|
|
public function send(Email $email, $params = array(), &$message = null, $attachmentList = [])
|
|
{
|
|
if (!$message) {
|
|
$message = new Message();
|
|
}
|
|
$config = $this->config;
|
|
$params = $this->params + $params;
|
|
|
|
if ($email->get('from')) {
|
|
$fromName = null;
|
|
if (!empty($params['fromName'])) {
|
|
$fromName = $params['fromName'];
|
|
} else {
|
|
$fromName = $config->get('outboundEmailFromName');
|
|
}
|
|
$message->addFrom(trim($email->get('from')), $fromName);
|
|
} else {
|
|
if (!empty($params['fromAddress'])) {
|
|
$fromAddress = $params['fromAddress'];
|
|
} else {
|
|
if (!$config->get('outboundEmailFromAddress')) {
|
|
throw new Error('outboundEmailFromAddress is not specified in config.');
|
|
}
|
|
$fromAddress = $config->get('outboundEmailFromAddress');
|
|
}
|
|
|
|
if (!empty($params['fromName'])) {
|
|
$fromName = $params['fromName'];
|
|
} else {
|
|
$fromName = $config->get('outboundEmailFromName');
|
|
}
|
|
|
|
$message->addFrom($fromAddress, $fromName);
|
|
}
|
|
|
|
if (!$email->get('from')) {
|
|
$email->set('from', $fromAddress);
|
|
}
|
|
|
|
$sender = new \Zend\Mail\Header\Sender();
|
|
$sender->setAddress($email->get('from'));
|
|
$message->getHeaders()->addHeader($sender);
|
|
|
|
if (!empty($params['replyToAddress'])) {
|
|
$replyToName = null;
|
|
if (!empty($params['replyToName'])) {
|
|
$replyToName = $params['replyToName'];
|
|
}
|
|
$message->setReplyTo($params['replyToAddress'], $replyToName);
|
|
}
|
|
|
|
$value = $email->get('to');
|
|
if ($value) {
|
|
$arr = explode(';', $value);
|
|
if (is_array($arr)) {
|
|
foreach ($arr as $address) {
|
|
$message->addTo(trim($address));
|
|
}
|
|
}
|
|
}
|
|
|
|
$value = $email->get('cc');
|
|
if ($value) {
|
|
$arr = explode(';', $value);
|
|
if (is_array($arr)) {
|
|
foreach ($arr as $address) {
|
|
$message->addCC(trim($address));
|
|
}
|
|
}
|
|
}
|
|
|
|
$value = $email->get('bcc');
|
|
if ($value) {
|
|
$arr = explode(';', $value);
|
|
if (is_array($arr)) {
|
|
foreach ($arr as $address) {
|
|
$message->addBCC(trim($address));
|
|
}
|
|
}
|
|
}
|
|
|
|
$value = $email->get('replyTo');
|
|
if ($value) {
|
|
$arr = explode(';', $value);
|
|
if (is_array($arr)) {
|
|
foreach ($arr as $address) {
|
|
$message->addReplyTo(trim($address));
|
|
}
|
|
}
|
|
}
|
|
|
|
$attachmentPartList = array();
|
|
$attachmentCollection = $email->get('attachments');
|
|
$attachmentInlineCollection = $email->getInlineAttachments();
|
|
|
|
foreach ($attachmentList as $attachment) {
|
|
$attachmentCollection[] = $attachment;
|
|
}
|
|
|
|
if (!empty($attachmentCollection)) {
|
|
foreach ($attachmentCollection as $a) {
|
|
$fileName = $this->getEntityManager()->getRepository('Attachment')->getFilePath($a);
|
|
$attachment = new MimePart(file_get_contents($fileName));
|
|
$attachment->disposition = Mime::DISPOSITION_ATTACHMENT;
|
|
$attachment->encoding = Mime::ENCODING_BASE64;
|
|
$attachment->filename ='=?utf-8?B?' . base64_encode($a->get('name')) . '?=';
|
|
if ($a->get('type')) {
|
|
$attachment->type = $a->get('type');
|
|
}
|
|
$attachmentPartList[] = $attachment;
|
|
}
|
|
}
|
|
|
|
if (!empty($attachmentInlineCollection)) {
|
|
foreach ($attachmentInlineCollection as $a) {
|
|
$fileName = $this->getEntityManager()->getRepository('Attachment')->getFilePath($a);
|
|
$attachment = new MimePart(file_get_contents($fileName));
|
|
$attachment->disposition = Mime::DISPOSITION_INLINE;
|
|
$attachment->encoding = Mime::ENCODING_BASE64;
|
|
$attachment->id = $a->id;
|
|
if ($a->get('type')) {
|
|
$attachment->type = $a->get('type');
|
|
}
|
|
$attachmentPartList[] = $attachment;
|
|
}
|
|
}
|
|
|
|
|
|
$message->setSubject($email->get('name'));
|
|
|
|
$body = new MimeMessage();
|
|
|
|
$textPart = new MimePart($email->getBodyPlainForSending());
|
|
$textPart->type = 'text/plain';
|
|
$textPart->encoding = Mime::ENCODING_QUOTEDPRINTABLE;
|
|
$textPart->charset = 'utf-8';
|
|
|
|
if ($email->get('isHtml')) {
|
|
$htmlPart = new MimePart($email->getBodyForSending());
|
|
$htmlPart->encoding = Mime::ENCODING_QUOTEDPRINTABLE;
|
|
$htmlPart->type = 'text/html';
|
|
$htmlPart->charset = 'utf-8';
|
|
}
|
|
|
|
if (!empty($attachmentPartList)) {
|
|
$messageType = 'multipart/related';
|
|
if ($email->get('isHtml')) {
|
|
$content = new MimeMessage();
|
|
$content->addPart($textPart);
|
|
$content->addPart($htmlPart);
|
|
|
|
$messageType = 'multipart/mixed';
|
|
|
|
$contentPart = new MimePart($content->generateMessage());
|
|
$contentPart->type = "multipart/alternative;\n boundary=\"" . $content->getMime()->boundary() . '"';
|
|
|
|
$body->addPart($contentPart);
|
|
} else {
|
|
$body->addPart($textPart);
|
|
}
|
|
|
|
foreach ($attachmentPartList as $attachmentPart) {
|
|
$body->addPart($attachmentPart);
|
|
}
|
|
|
|
} else {
|
|
if ($email->get('isHtml')) {
|
|
$body->setParts(array($textPart, $htmlPart));
|
|
$messageType = 'multipart/alternative';
|
|
} else {
|
|
$body = $email->getBodyPlainForSending();
|
|
$messageType = 'text/plain';
|
|
}
|
|
}
|
|
|
|
$message->setBody($body);
|
|
|
|
if ($messageType == 'text/plain') {
|
|
if ($message->getHeaders()->has('content-type')) {
|
|
$message->getHeaders()->removeHeader('content-type');
|
|
}
|
|
$message->getHeaders()->addHeaderLine('Content-Type', 'text/plain; charset=UTF-8');
|
|
} else {
|
|
if (!$message->getHeaders()->has('content-type')) {
|
|
$contentTypeHeader = new \Zend\Mail\Header\ContentType();
|
|
$message->getHeaders()->addHeader($contentTypeHeader);
|
|
}
|
|
$message->getHeaders()->get('content-type')->setType($messageType);
|
|
}
|
|
|
|
$message->setEncoding('UTF-8');
|
|
|
|
try {
|
|
$messageId = $email->get('messageId');
|
|
if (empty($messageId) || !is_string($messageId) || strlen($messageId) < 4 || strpos($messageId, 'dummy:') === 0) {
|
|
$messageId = $this->generateMessageId($email);
|
|
$email->set('messageId', '<' . $messageId . '>');
|
|
} else {
|
|
$messageId = substr($messageId, 1, strlen($messageId) - 2);
|
|
}
|
|
|
|
$messageIdHeader = new \Zend\Mail\Header\MessageId();
|
|
$messageIdHeader->setId($messageId);
|
|
$message->getHeaders()->addHeader($messageIdHeader);
|
|
|
|
$this->transport->send($message);
|
|
|
|
$email->set('status', 'Sent');
|
|
$email->set('dateSent', date("Y-m-d H:i:s"));
|
|
} catch (\Exception $e) {
|
|
throw new Error($e->getMessage(), 500);
|
|
}
|
|
|
|
$this->useGlobal();
|
|
}
|
|
|
|
static public function generateMessageId(Email $email)
|
|
{
|
|
$rand = mt_rand(1000, 9999);
|
|
|
|
if ($email->get('parentType') && $email->get('parentId')) {
|
|
$messageId = '' . $email->get('parentType') .'/' . $email->get('parentId') . '/' . time() . '/' . $rand . '@espo';
|
|
} else {
|
|
$messageId = '' . md5($email->get('name')) . '/' . time() . '/' . $rand . '@espo';
|
|
}
|
|
if ($email->get('isSystem')) {
|
|
$messageId .= '-system';
|
|
}
|
|
|
|
return $messageId;
|
|
}
|
|
}
|
|
|