PHP email sending Tencent QQ enterprise email sending

PHP email sending Tencent QQ enterprise email sending single file version

code:https://github.com/harry-1012/PHP_Email_OneFile/tree/main

<?php
class Email
{   
   /**
   * @param Type reqData["title"] Mail subject 
   * @param Type reqData["content"] Mail content 
   * @param Type reqData["fromname"] Sender's name 
   * @param Type reqData["receiver"] Recipient's email 
   * @return boolean Returns true if sent successfully, false otherwise 
   */
    public function qqComMailSend($reqData = null)
    {
        if (empty($reqData)) {
            $reqData = $_REQUEST;
        }
        $mail = new Lib_Smtp();
        $PHPMailer = array(
            'host' => 'smtp.exmail.qq.com',//qq use smtp.qq.com，qq qiye use smtp.exmail.qq.com
            'username' => 'abc@abc.com',//Email login account 
            'password' => '123456',//Email login password, might also be an independent password, which is the authorization code when pop3/smtp is enabled 
            'port' => 465,//Default is 25, Tencent Cloud Server blocks port 25, so use 465 
            'ssl' => true,//Whether to enable SSL, if using 465, SSL must be enabled 
            'from' => 'abc@abc.com'//Sender 
        );
        $reqData["fromname"] = $reqData["fromname"]?$reqData["fromname"]:$PHPMailer["from"];
        $mail->setServer($PHPMailer["host"], $PHPMailer["username"], $PHPMailer["password"], $PHPMailer["port"], $PHPMailer["ssl"]); 
        $mail->setFrom($PHPMailer["from"]); //Sender's email 
        $mail->setFromName($reqData["fromname"]); //Sender's name 
        $mail->setReceiver($reqData["receiver"]); //Recipient's email 
        //$mail->addAttachment(""); //Attachment 
        $mail->setMail($reqData["title"], $reqData["content"]); //Title and content 
        return $mail->send();
    }
}

class Lib_Smtp
{
    /**
     * @var string Email transmission proxy username
     * @access private
     */
    private $_userName;

    /**
     * @var string Email transmission proxy password
     * @access private
     */
    private $_password;

    /**
     * @var string Email transmission proxy server address
     * @access private
     */
    private $_sendServer;

    /**
     * @var int Email transmission proxy server port
     * @access private
     */
    private $_port;

    /**
     * @var string Sender
     * @access protected
     */
    protected $_from;

    /**
     * @var string Sender's name
     * @access protected
     */
    protected $_from_name;

    /**
     * @var string Recipient
     * @access protected
     */
    protected $_to;

    /**
     * @var string CC
     * @access protected
     */
    protected $_cc;

    /**
     * @var string BCC
     * @access protected
     */
    protected $_bcc;

    /**
     * @var string Subject
     * @access protected
     */
    protected $_subject;

    /**
     * @var string Email body
     * @access protected
     */
    protected $_body;

    /**
     * @var string Attachment
     * @access protected
     */
    protected $_attachment;

    /**
     * @var reource Socket resource
     * @access protected
     */
    protected $_socket;

    /**
     * @var reource Whether it is a secure connection
     * @access protected
     */
    protected $_isSecurity;

    /**
     * @var string Error message
     * @access protected
     */
    protected $_errorMessage;

    protected $_debug = false;
    /*Output debug information*/
    private function debug($msg)
    {
        if ($this->_debug) {
            echo $msg, '<br>', "\n";
        }
    }
    public function setDebug($val = true)
    {
        $this->_debug = $val;
    }

    /**
     * Set the email transmission proxy, if it can be sent anonymously with the email server, only need to pass the proxy server address
     * @access public
     * @param string $server Proxy server IP or domain name
     * @param string $username Authentication account
     * @param string $password Authentication password
     * @param int $port Proxy server port, smtp default is port 25
     * @param boolean $isSecurity Whether the connection to the server is a secure connection, default is false
     * @return boolean
     */
    public function setServer($server, $username = "", $password = "", $port = 25, $isSecurity = false)
    {
        $this->_sendServer = $server;
        $this->_port = $port;
        $this->_isSecurity = $isSecurity;
        $this->_userName = empty($username) ? "" : base64_encode($username);
        $this->_password = empty($password) ? "" : base64_encode($password);
        return true;
    }

    /**
     * Set the sender
     * @access public
     * @param string $from Sender's email address
     * @return boolean
     */
    public function setFrom($from)
    {
        $this->_from = $from;
        return true;
    }

    /**
     * Set sender's name
     * @access public
     * @param string $from Sender's email address
     * @return boolean
     */
    public function setFromName($fromName)
    {
        $this->_from_name = $fromName;
        return true;
    }
    

    /**
     * Set the recipient, multiple recipients, call multiple times.
     * @access public
     * @param string $to Recipient's email address
     * @return boolean
     */
    public function setReceiver($to)
    {
        if (isset($this->_to)) {
            if (is_string($this->_to)) {
                $this->_to = array($this->_to);
                $this->_to[] = $to;
                return true;
            } elseif (is_array($this->_to)) {
                $this->_to[] = $to;
                return true;
            } else {
                return false;
            }
        } else {
            $this->_to = $to;
            return true;
        }
    }

    /**
     * Set CC, multiple CC, call multiple times.
     * @access public
     * @param string $cc CC address
     * @return boolean
     */
    public function setCc($cc)
    {
        if (isset($this->_cc)) {
            if (is_string($this->_cc)) {
                $this->_cc = array($this->_cc);
                $this->_cc[] = $cc;
                return true;
            } elseif (is_array($this->_cc)) {
                $this->_cc[] = $cc;
                return true;
            } else {
                return false;
            }
        } else {
            $this->_cc = $cc;
            return true;
        }
    }

    /**
     * Set BCC, multiple BCC, call multiple times
     * @access public
     * @param string $bcc BCC address
     * @return boolean
     */
    public function setBcc($bcc)
    {
        if (isset($this->_bcc)) {
            if (is_string($this->_bcc)) {
                $this->_bcc = array($this->_bcc);
                $this->_bcc[] = $bcc;
                return true;
            } elseif (is_array($this->_bcc)) {
                $this->_bcc[] = $bcc;
                return true;
            } else {
                return false;
            }
        } else {
            $this->_bcc = $bcc;
            return true;
        }
    }

    /**
     * Set email attachments, multiple attachments, call multiple times
     * @access public
     * @param string $file File address
     * @return boolean
     */
    public function addAttachment($file)
    {
        if (!file_exists($file)) {
            $this->_errorMessage = "file " . $file . " does not exist.";
            return false;
        }
        if (isset($this->_attachment)) {
            if (is_string($this->_attachment)) {
                $this->_attachment = array($this->_attachment);
                $this->_attachment[] = $file;
                return true;
            } elseif (is_array($this->_attachment)) {
                $this->_attachment[] = $file;
                return true;
            } else {
                return false;
            }
        } else {
            $this->_attachment = $file;
            return true;
        }
    }

    /**
     * Set email information
     * @access public
     * @param string $body Email subject
     * @param string $subject Email body content, can be plain text or HTML text
     * @return boolean
     */
    public function setMail($subject, $body)
    {
        $this->_subject = $subject;
        $this->_body = base64_encode($body);
        return true;
    }

    /**
     * Send email
     * @access public
     * @return boolean
     */
    public function send()
    {
        $command = $this->getCommand();

        $this->_isSecurity ? $this->socketSecurity() : $this->socket();

        foreach ($command as $value) {
            $result = $this->_isSecurity ? $this->sendCommandSecurity($value[0], $value[1]) : $this->sendCommand($value[0], $value[1]);
            if ($result) {
                continue;
            } else {
                return false;
            }
        }

        //Actually, it's unnecessary to close here, after sending the smtp command: QUIT, the server closes the connection, and the local socket resource is automatically released
        $this->_isSecurity ? $this->closeSecutity() : $this->close();
        return true;
    }

    /**
     * Return error message
     * @return string
     */
    public function error()
    {
        if (!isset($this->_errorMessage)) {
            $this->_errorMessage = "";
        }
        return $this->_errorMessage;
    }

    /**
     * Return mail command
     * @access protected
     * @return array
     */
    protected function getCommand()
    {
        $separator = "----=_Part_" . md5($this->_from . time()) . uniqid(); //Separator

        $command = array(
            array("HELO sendmail\r\n", 250)
        );
        if (!empty($this->_userName)) {
            $command[] = array("AUTH LOGIN\r\n", 334);
            $command[] = array($this->_userName . "\r\n", 334);
            $command[] = array($this->_password . "\r\n", 235);
        }

        //Set sender
        $command[] = array("MAIL FROM: <" . $this->_from . ">\r\n", 250);
        $fromname_command = "";
        if(!empty($this->_from_name)){
            $fromname_command = " =?utf-8?B?". base64_encode($this->_from_name)."?= ";
        }
        $header = "FROM:".$fromname_command." <" . $this->_from . ">\r\n";

        //Set recipient
        if (is_array($this->_to)) {
            $count = count($this->_to);
            for ($i = 0; $i < $count; $i++) {
                $command[] = array("RCPT TO: <" . $this->_to[$i] . ">\r\n", 250);
                if ($i == 0) {
                    $header .= "TO: <" . $this->_to[$i] . ">";
                } elseif ($i + 1 == $count) {
                    $header .= ",<" . $this->_to[$i] . ">\r\n";
                } else {
                    $header .= ",<" . $this->_to[$i] . ">";
                }
            }
        } else {
            $command[] = array("RCPT TO: <" . $this->_to . ">\r\n", 250);
            $header .= "TO: <" . $this->_to . ">\r\n";
        }

        //Set cc
        if (isset($this->_cc)) {
            if (is_array($this->_cc)) {
                $count = count($this->_cc);
                for ($i = 0; $i < $count; $i++) {
                    $command[] = array("RCPT TO: <" . $this->_cc[$i] . ">\r\n", 250);
                    if ($i == 0) {
                        $header .= "CC: <" . $this->_cc[$i] . ">";
                    } elseif ($i + 1 == $count) {
                        $header .= ",<" . $this->_cc[$i] . ">\r\n";
                    } else {
                        $header .= ",<" . $this->_cc[$i] . ">";
                    }
                }
            } else {
                $command[] = array("RCPT TO: <" . $this->_cc . ">\r\n", 250);
                $header .= "CC: <" . $this->_cc . ">\r\n";
            }
        }

        //Set bcc
        if (isset($this->_bcc)) {
            if (is_array($this->_bcc)) {
                $count = count($this->_bcc);
                for ($i = 0; $i < $count; $i++) {
                    $command[] = array("RCPT TO: <" . $this->_bcc[$i] . ">\r\n", 250);
                    if ($i == 0) {
                        $header .= "BCC: <" . $this->_bcc[$i] . ">";
                    } elseif ($i + 1 == $count) {
                        $header .= ",<" . $this->_bcc[$i] . ">\r\n";
                    } else {
                        $header .= ",<" . $this->_bcc[$i] . ">";
                    }
                }
            } else {
                $command[] = array("RCPT TO: <" . $this->_bcc . ">\r\n", 250);
                $header .= "BCC: <" . $this->_bcc . ">\r\n";
            }
        }

        //Subject
        $header .= "Subject: " . $this->_subject . "\r\n";
        if (isset($this->_attachment)) {
            //Mail header with attachments needs to be declared like this
            $header .= "Content-Type: multipart/mixed;\r\n";
        } elseif (false) {
            //For emails containing image resources
            $header .= "Content-Type: multipart/related;\r\n";
        } else {
            //For HTML or plain text emails
            $header .= "Content-Type: multipart/alternative;\r\n";
        }

        //Mail header separator
        $header .= "\t" . 'boundary="' . $separator . '"';
        $header .= "\r\nMIME-Version: 1.0\r\n";
        $header .= "\r\n--" . $separator . "\r\n";
        $header .= "Content-Type:text/html; charset=utf-8\r\n";
        $header .= "Content-Transfer-Encoding: base64\r\n\r\n";
        $header .= $this->_body . "\r\n";
        $header .= "--" . $separator . "\r\n";

        //Add attachments
        if (isset($this->_attachment) && !empty($this->_attachment)) {
            if (is_array($this->_attachment)) {
                $count = count($this->_attachment);
                for ($i = 0; $i < $count; $i++) {
                    $header .= "\r\n--" . $separator . "\r\n";
                    $header .= "Content-Type: " . $this->getMIMEType($this->_attachment[$i]) . '; name="' . basename($this->_attachment[$i]) . '"' . "\r\n";
                    $header .= "Content-Transfer-Encoding: base64\r\n";
                    $header .= 'Content-Disposition: attachment; filename="' . basename($this->_attachment[$i]) . '"' . "\r\n";
                    $header .= "\r\n";
                    $header .= $this->readFile($this->_attachment[$i]);
                    $header .= "\r\n--" . $separator . "\r\n";
                }
            } else {
                $header .= "\r\n--" . $separator . "\r\n";
                $header .= "Content-Type: " . $this->getMIMEType($this->_attachment) . '; name="' . basename($this->_attachment) . '"' . "\r\n";
                $header .= "Content-Transfer-Encoding: base64\r\n";
                $header .= 'Content-Disposition: attachment; filename="' . basename($this->_attachment) . '"' . "\r\n";
                $header .= "\r\n";
                $header .= $this->readFile($this->_attachment);
                $header .= "\r\n--" . $separator . "\r\n";
            }
        }

        //End email data sending
        $header .= "\r\n.\r\n";


        $command[] = array("DATA\r\n", 354);
        $command[] = array($header, 250);
        $command[] = array("QUIT\r\n", 221);

        return $command;
    }

    /**
     * Send command
     * @access protected
     * @param string $command SMTP command sent to the server
     * @param int $code Expected response code from the server
     * @return boolean
     */
    protected function sendCommand($command, $code)
    {
        //debug('Send command:' . $command . ',expected code:' . $code );
        //Send command to the server
        try {
            if (socket_write($this->_socket, $command, strlen($command))) {

                //When the email content is sent in multiple parts, there is no $code, and the server does not return
                if (empty($code)) {
                    return true;
                }

                //Read server response
                $data = trim(socket_read($this->_socket, 1024));
                //debug( 'response:' . $data);

                if ($data) {
                    $pattern = "/^" . $code . "/";
                    if (preg_match($pattern, $data)) {
                        return true;
                    } else {
                        $this->_errorMessage = "Error:" . $data . "|**| command:";
                        return false;
                    }
                } else {
                    $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
                    return false;
                }
            } else {
                $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
                return false;
            }
        } catch (Exception $e) {
            $this->_errorMessage = "Error:" . $e->getMessage();
        }
    }

    /**
     * Send command
     * @access protected
     * @param string $command SMTP command sent to the server
     * @param int $code Expected response code from the server
     * @return boolean
     */
    protected function sendCommandSecurity($command, $code)
    {
        try {
            fputs($this->_socket, $command);
            $data = trim(fgets($this->_socket, 1024));
            if ($data) {
                $pattern = "/^" . $code . "/";
                if (preg_match($pattern, $data)) {
                    return true;
                } else {
                    $this->_errorMessage = "Error:" . $data . "|**| command:";
                    return false;
                }
            } else {
                $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
                return false;
            }
        } catch (Exception $e) {
            $this->_errorMessage = "Error:" . $e->getMessage();
        }
    }

    /**
     * Read file
     * @access protected
     * @param string $file file address
     * @return mixed
     */
    protected function readFile($file)
    {
        if ($fp = fopen($file, "rb", 0)) {
            $content = "";
            while (!feof($fp)) {
                //Read binary file, fread is different from fgets, fread reads a fixed number of bytes each time
                $content .= chunk_split(base64_encode(fread($fp, 1024))); //read 1024 bytes at a time
            }
            fclose($fp);
            return $content;
        } else {
            $this->_errorMessage = "Error:cannot read file:" . $file;
            return false;
        }
    }

    /**
     * Get the MIME type of the file
     * @access protected
     * @param string $file file address
     * @return mixed
     */
    protected function getMIMEType($file)
    {
        if (file_exists($file)) {
            $mime_types = array(
                "pdf" => "application/pdf",
                "exe" => "application/octet-stream",
                "zip" => "application/zip",
                "docx" => "application/msword",
                "xls" => "application/vnd.ms-excel",
                "ppt" => "application/vnd.ms-powerpoint",
                "gif" => "image/gif",
                "png" => "image/png",
                "jpeg" => "image/jpg",
                "jpg" => "image/jpg",
                "mp3" => "audio/mpeg",
                "wav" => "audio/x-wav",
                "mpeg" => "video/mpeg",
                "mpg" => "video/mpeg",
                "mpe" => "video/mpeg",
                "mov" => "video/quicktime",
                "avi" => "video/x-msvideo",
                "3gp" => "video/3gpp",
                "css" => "text/css",
                "jsc" => "application/javascript",
                "js" => "application/javascript",
                "php" => "text/html",
                "htm" => "text/html",
                "html" => "text/html",
                "txt" => "text/plain",
                "text" => "text/plain",
                "log" => "text/plain",
                "xml" => "text/xml",
                "xsl" => "text/xml",
                "wmv" => "video/x-ms-wmv"
            );
            $fileExt = strtolower(pathinfo($file, PATHINFO_EXTENSION));
            return isset($mime_types[$fileExt]) ? $mime_types[$fileExt] : "application/octet-stream";
        } else {
            return false;
        }
    }

    /**
     * Create socket
     * @access private
     * @return boolean
     */
    private function socket()
    {
        if (!function_exists("socket_create")) {
            $this->_errorMessage = "Error:extension socket not found";
            return false;
        }

        $this->_socket = socket_create(AF_INET, SOCK_STREAM, getprotobyname('tcp'));

        if (!$this->_socket) {
            $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
            return false;
        }

        socket_set_block($this->_socket);

        if (!socket_connect($this->_socket, $this->_sendServer, $this->_port)) {
            $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
            return false;
        }

        socket_read($this->_socket, 1024);

        return true;
    }

    /**
     * Create secure socket
     * @access private
     * @return boolean
     */
    private function socketSecurity()
    {
        if (!function_exists("fsockopen")) {
            $this->_errorMessage = "Error:extension fsockopen not found";
            return false;
        }

        $target = ($this->_isSecurity ? "ssl://" : "") . $this->_sendServer;

        $this->_socket = fsockopen($target, $this->_port, $errno, $errstr, 10);

        if (!$this->_socket) {
            $this->_errorMessage = "Error:" . $errstr;
            return false;
        }

        stream_set_blocking($this->_socket, true);

        $response = fgets($this->_socket, 512);

        if (substr($response, 0, 3) != 220) {
            $this->_errorMessage = "Error:connection failed!";
            return false;
        }

        return true;
    }

    /**
     * Close socket
     * @access private
     * @return boolean
     */
    private function close()
    {
        if (!isset($this->_socket) || empty($this->_socket)) {
            return true;
        }

        socket_close($this->_socket);
        return true;
    }

    /**
     * Close secure socket
     * @access private
     * @return boolean
     */
    private function closeSecutity()
    {
        if (!isset($this->_socket) || empty($this->_socket)) {
            return true;
        }

        fclose($this->_socket);
        return true;
    }
}