DedeBIZ
/
DedeV6
Observar 2
Favorito 0
Fork 0
Código Pull requests 0 Versões 31 Atividade
Ver código fonte

群友提交修复php高版本会员邮箱验证，请审核

tags/6.1.9
xushubieli 3 anos atrás
pai
f5aa182d15
commit
a2c042128f
1 arquivos alterados com 122 adições e 104 exclusões
Visão unificada
Opções de diferenças
Mostrar estatísticas Baixar arquivo de patch Baixar arquivo de diferenças
  1. +122
    -104
      src/system/libraries/mail.class.php

+ 122
- 104
src/system/libraries/mail.class.php Ver arquivo

@@ -11,86 +11,81 @@ if (!defined('DEDEINC')) exit('dedebiz');
*/ */
class smtp class smtp
{ {
//公有变量
var $smtp_port;
var $time_out;
var $host_name;
var $log_file;
var $relay_host;
var $debug;
var $auth;
var $user;
var $pass;
//私有变量
var $sock;
//析构函数
function smtp($relay_host = "", $smtp_port = 25, $auth = FALSE, $user, $pass)
public $debug;
protected $smtp_port, $time_out, $host_name, $log_file, $relay_host, $auth, $user, $pass, $sock;
//构造函数
public function __construct($relay_host = "", $smtp_port = 25, $auth = FALSE, $user = "", $pass = "")
{ {
$this->debug = FALSE;
$this->smtp_port = $smtp_port;
$this->debug = FALSE;
$this->smtp_port = $smtp_port;
$this->relay_host = $relay_host; $this->relay_host = $relay_host;
//is used in fsockopen()
$this->time_out = 30;
$this->auth = $auth; //auth
$this->user = $user;
$this->pass = $pass;
//is used in HELO command
$this->host_name = "localhost";
$this->log_file = "";
$this->sock = FALSE;
$this->time_out = 30;
$this->auth = $auth;
$this->user = $user;
$this->pass = $pass;
$this->host_name = "localhost";
$this->log_file = "";
$this->sock = FALSE;
} }
/** /**
* 邮件主函数 * 邮件主函数
* *
* @access public * @access public
* @param string $to 发送到的email
* @param string $webname 站点名称
* @param string $from 来自
* @param string $subject 主题
* @param string $body 邮件内容
* @param string $mailtype 邮件类型
* @param string $to 发送到的email
* @param string $webname 站点名称
* @param string $from 来自
* @param string $subject 主题
* @param string $body 邮件内容
* @param string $mailtype 邮件类型
* @return string * @return string
*/ */
function sendmail($to, $webname, $from, $subject = "", $body = "", $mailtype, $cc = "", $bcc = "", $additional_headers = "")
function sendmail($to, $webname, $from, $subject = "", $body = "", $mailtype = "TXT", $cc = "", $bcc = "", $additional_headers = "")
{ {
$mail_from = $this->get_address($this->strip_comment($from)); $mail_from = $this->get_address($this->strip_comment($from));
$body = preg_replace("/(^|(\r\n))(\.)/", "\1.\3", $body);
$header = "MIME-Version:1.0\r\n";
if ($mailtype == "HTML") {
$body = preg_replace("/(^|(\r\n))(\.)/", "\1.\3", $body);
$header = "MIME-Version:1.0\r\n";
if ($mailtype == "HTML")
{
$header .= "Content-Type:text/html\r\n"; $header .= "Content-Type:text/html\r\n";
} }
if ($cc != "") {
$header .= "Cc: ".$cc."\r\n";
if ($cc != "")
{
$header .= "Cc: " . $cc . "\r\n";
} }
$header .= "From: $webname<".$from.">\r\n";
$subject = "=?".$GLOBALS['cfg_soft_lang']."?B?".base64_encode($subject)."?=";
$header .= "Subject: ".$subject."\r\n";
$header .= $additional_headers;
$header .= "Date: ".date("r")."\r\n";
$header .= "X-Mailer:By Redhat (PHP/".phpversion().")\r\n";
$header .= "From: $webname<" . $from . ">\r\n";
$subject = "=?" . $GLOBALS['cfg_soft_lang'] . "?B?" . base64_encode($subject) . "?=";
$header .= "Subject: " . $subject . "\r\n";
$header .= $additional_headers;
$header .= "Date: " . date("r") . "\r\n";
$header .= "X-Mailer:By Redhat (PHP/" . phpversion() . ")\r\n";
list($msec, $sec) = explode(" ", microtime()); list($msec, $sec) = explode(" ", microtime());
$header .= "Message-ID: <".date("YmdHis", $sec).".".($msec * 1000000).".".$mail_from.">\r\n";
$TO = explode(",", $this->strip_comment($to));
if ($cc != "") {
$header .= "Message-ID: <" . date("YmdHis", $sec) . "." . ($msec * 1000000) . "." . $mail_from . ">\r\n";
$TO = explode(",", $this->strip_comment($to));
if ($cc != "")
{
$TO = array_merge($TO, explode(",", $this->strip_comment($cc))); $TO = array_merge($TO, explode(",", $this->strip_comment($cc)));
} }
if ($bcc != "") {
if ($bcc != "")
{
$TO = array_merge($TO, explode(",", $this->strip_comment($bcc))); $TO = array_merge($TO, explode(",", $this->strip_comment($bcc)));
} }
$sent = TRUE; $sent = TRUE;
foreach ($TO as $rcpt_to) {
$headerto = "To: ".$rcpt_to."\r\n";
$headerall = $header.$headerto;
$rcpt_to = $this->get_address($rcpt_to);
if (!$this->smtp_sockopen($rcpt_to)) {
$this->log_write("Error: Cannot send email to ".$rcpt_to."\n");
foreach ($TO as $rcpt_to)
{
$headerto = "To: " . $rcpt_to . "\r\n";
$headerall = $header . $headerto;
$rcpt_to = $this->get_address($rcpt_to);
if (!$this->smtp_sockopen($rcpt_to))
{
$this->log_write("Error: Cannot send email to " . $rcpt_to . "\n");
$sent = FALSE; $sent = FALSE;
continue; continue;
} }
if ($this->smtp_send($this->host_name, $mail_from, $rcpt_to, $headerall, $body)) {
$this->log_write("E-mail has been sent to <".$rcpt_to.">\n");
if ($this->smtp_send($this->host_name, $mail_from, $rcpt_to, $headerall, $body))
{
$this->log_write("E-mail has been sent to <" . $rcpt_to . ">\n");
} else { } else {
$this->log_write("Error: Cannot send email to <".$rcpt_to.">\n");
$this->log_write("Error: Cannot send email to <" . $rcpt_to . ">\n");
$sent = FALSE; $sent = FALSE;
} }
fclose($this->sock); fclose($this->sock);
@@ -102,52 +97,64 @@ class smtp
* SMTP发送 * SMTP发送
* *
* @access public * @access public
* @param string $helo 发送HELO
* @param string $from 来自
* @param string $to 到
* @param string $header 头部信息
* @param string $body 内容主体
* @param string $helo 发送HELO
* @param string $from 来自
* @param string $to 到
* @param string $header 头部信息
* @param string $body 内容主体
* @return string * @return string
*/ */
function smtp_send($helo, $from, $to, $header, $body = "") function smtp_send($helo, $from, $to, $header, $body = "")
{ {
if (!$this->smtp_putcmd("HELO", $helo)) {
if (!$this->smtp_putcmd("HELO", $helo))
{
return $this->smtp_error("sending HELO command"); return $this->smtp_error("sending HELO command");
} }
if ($this->auth) {
if (!$this->smtp_putcmd("AUTH LOGIN")) {
if ($this->auth)
{
if (!$this->smtp_putcmd("AUTH LOGIN"))
{
return $this->smtp_error("sending AUTH LOGIN command"); return $this->smtp_error("sending AUTH LOGIN command");
} }
if (!$this->smtp_putcmd("", base64_encode($this->user))) {
if (!$this->smtp_putcmd("", base64_encode($this->user)))
{
return $this->smtp_error("sending HELO command"); return $this->smtp_error("sending HELO command");
} }
if (!$this->smtp_putcmd("", base64_encode($this->pass))) {
if (!$this->smtp_putcmd("", base64_encode($this->pass)))
{
return $this->smtp_error("sending HELO command"); return $this->smtp_error("sending HELO command");
} }
} }
if (!$this->smtp_putcmd("MAIL", "FROM:<".$from.">")) {
if (!$this->smtp_putcmd("MAIL", "FROM:<" . $from . ">"))
{
return $this->smtp_error("sending MAIL FROM command"); return $this->smtp_error("sending MAIL FROM command");
} }
if (!$this->smtp_putcmd("RCPT", "TO:<".$to.">")) {
if (!$this->smtp_putcmd("RCPT", "TO:<" . $to . ">"))
{
return $this->smtp_error("sending RCPT TO command"); return $this->smtp_error("sending RCPT TO command");
} }
if (!$this->smtp_putcmd("DATA")) {
if (!$this->smtp_putcmd("DATA"))
{
return $this->smtp_error("sending DATA command"); return $this->smtp_error("sending DATA command");
} }
if (!$this->smtp_message($header, $body)) {
if (!$this->smtp_message($header, $body))
{
return $this->smtp_error("sending message"); return $this->smtp_error("sending message");
} }
if (!$this->smtp_eom()) {
if (!$this->smtp_eom())
{
return $this->smtp_error("sending <CR><LF>.<CR><LF> [EOM]"); return $this->smtp_error("sending <CR><LF>.<CR><LF> [EOM]");
} }
if (!$this->smtp_putcmd("QUIT")) {
if (!$this->smtp_putcmd("QUIT"))
{
return $this->smtp_error("sending QUIT command"); return $this->smtp_error("sending QUIT command");
} }
return TRUE; return TRUE;
} }
function smtp_sockopen($address) function smtp_sockopen($address)
{ {
if ($this->relay_host == "") {
if ($this->relay_host == "")
{
return $this->smtp_sockopen_mx($address); return $this->smtp_sockopen_mx($address);
} else { } else {
return $this->smtp_sockopen_relay(); return $this->smtp_sockopen_relay();
@@ -155,41 +162,45 @@ class smtp
} }
function smtp_sockopen_relay() function smtp_sockopen_relay()
{ {
$this->log_write("Trying to ".$this->relay_host.":".$this->smtp_port."\n");
$this->log_write("Trying to " . $this->relay_host . ":" . $this->smtp_port . "\n");
$this->sock = @fsockopen($this->relay_host, $this->smtp_port, $errno, $errstr, $this->time_out); $this->sock = @fsockopen($this->relay_host, $this->smtp_port, $errno, $errstr, $this->time_out);
if (!($this->sock && $this->smtp_ok())) {
$this->log_write("Error: Cannot connenct to relay host ".$this->relay_host."\n");
$this->log_write("Error: ".$errstr." (".$errno.")\n");
if (!($this->sock && $this->smtp_ok()))
{
$this->log_write("Error: Cannot connenct to relay host " . $this->relay_host . "\n");
$this->log_write("Error: " . $errstr . " (" . $errno . ")\n");
return FALSE; return FALSE;
} }
$this->log_write("Connected to relay host ".$this->relay_host."\n");
$this->log_write("Connected to relay host " . $this->relay_host . "\n");
return TRUE;; return TRUE;;
} }
function smtp_sockopen_mx($address) function smtp_sockopen_mx($address)
{ {
$domain = preg_replace("/^.+@([^@]+)$/i", "\1", $address); $domain = preg_replace("/^.+@([^@]+)$/i", "\1", $address);
if (!@getmxrr($domain, $MXHOSTS)) {
$this->log_write("Error: Cannot resolve MX \"".$domain."\"\n");
if (!@getmxrr($domain, $MXHOSTS))
{
$this->log_write("Error: Cannot resolve MX \"" . $domain . "\"\n");
return FALSE; return FALSE;
} }
foreach ($MXHOSTS as $host) {
$this->log_write("Trying to ".$host.":".$this->smtp_port."\n");
foreach ($MXHOSTS as $host)
{
$this->log_write("Trying to " . $host . ":" . $this->smtp_port . "\n");
$this->sock = @fsockopen($host, $this->smtp_port, $errno, $errstr, $this->time_out); $this->sock = @fsockopen($host, $this->smtp_port, $errno, $errstr, $this->time_out);
if (!($this->sock && $this->smtp_ok())) {
$this->log_write("Warning: Cannot connect to mx host ".$host."\n");
$this->log_write("Error: ".$errstr." (".$errno.")\n");
if (!($this->sock && $this->smtp_ok()))
{
$this->log_write("Warning: Cannot connect to mx host " . $host . "\n");
$this->log_write("Error: " . $errstr . " (" . $errno . ")\n");
continue; continue;
} }
$this->log_write("Connected to mx host ".$host."\n");
$this->log_write("Connected to mx host " . $host . "\n");
return TRUE; return TRUE;
} }
$this->log_write("Error: Cannot connect to any mx hosts (".implode(", ", $MXHOSTS).")\n");
$this->log_write("Error: Cannot connect to any mx hosts (" . implode(", ", $MXHOSTS) . ")\n");
return FALSE; return FALSE;
} }
function smtp_message($header, $body) function smtp_message($header, $body)
{ {
fputs($this->sock, $header."\r\n".$body);
$this->smtp_debug("> ".str_replace("\r\n", "\n"."> ", $header."\n> ".$body."\n> "));
fputs($this->sock, $header . "\r\n" . $body);
$this->smtp_debug("> " . str_replace("\r\n", "\n" . "> ", $header . "\n> " . $body . "\n> "));
return TRUE; return TRUE;
} }
function smtp_eom() function smtp_eom()
@@ -201,42 +212,47 @@ class smtp
function smtp_ok() function smtp_ok()
{ {
$response = str_replace("\r\n", "", fgets($this->sock, 512)); $response = str_replace("\r\n", "", fgets($this->sock, 512));
$this->smtp_debug($response."\n");
if (!preg_match("#^[23]#", $response)) {
$this->smtp_debug($response . "\n");
if (!preg_match("#^[23]#", $response))
{
fputs($this->sock, "QUIT\r\n"); fputs($this->sock, "QUIT\r\n");
fgets($this->sock, 512); fgets($this->sock, 512);
$this->log_write("Error: Remote host returned \"".$response."\"\n");
$this->log_write("Error: Remote host returned \"" . $response . "\"\n");
return FALSE; return FALSE;
} }
return TRUE; return TRUE;
} }
function smtp_putcmd($cmd, $arg = "") function smtp_putcmd($cmd, $arg = "")
{ {
if ($arg != "") {
if ($cmd == "") {
if ($arg != "")
{
if ($cmd == "")
{
$cmd = $arg; $cmd = $arg;
} else { } else {
$cmd = $cmd." ".$arg;
$cmd = $cmd . " " . $arg;
} }
} }
fputs($this->sock, $cmd."\r\n");
$this->smtp_debug("> ".$cmd."\n");
fputs($this->sock, $cmd . "\r\n");
$this->smtp_debug("> " . $cmd . "\n");
return $this->smtp_ok(); return $this->smtp_ok();
} }
function smtp_error($string) function smtp_error($string)
{ {
$this->log_write("Error: Error occurred while ".$string.".\n");
$this->log_write("Error: Error occurred while " . $string . ".\n");
return FALSE; return FALSE;
} }
function log_write($message) function log_write($message)
{ {
$this->smtp_debug($message); $this->smtp_debug($message);
if ($this->log_file == "") {
if ($this->log_file == "")
{
return TRUE; return TRUE;
} }
$message = date("M d H:i:s ").get_current_user()."[".getmypid()."]: ".$message;
if (!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, "a"))) {
$this->smtp_debug("Warning: Cannot open log file \"".$this->log_file."\"\n");
$message = date("M d H:i:s ") . get_current_user() . "[" . getmypid() . "]: " . $message;
if (!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, "a")))
{
$this->smtp_debug("Warning: Cannot open log file \"" . $this->log_file . "\"\n");
return FALSE;; return FALSE;;
} }
flock($fp, LOCK_EX); flock($fp, LOCK_EX);
@@ -247,7 +263,8 @@ class smtp
function strip_comment($address) function strip_comment($address)
{ {
$comment = "#\([^()]*\)#"; $comment = "#\([^()]*\)#";
while (preg_match($comment, $address)) {
while (preg_match($comment, $address))
{
$address = preg_replace($comment, "", $address); $address = preg_replace($comment, "", $address);
} }
return $address; return $address;
@@ -260,7 +277,8 @@ class smtp
} }
function smtp_debug($message) function smtp_debug($message)
{ {
if ($this->debug) {
if ($this->debug)
{
echo $message; echo $message;
} }
} }

Escrever Pré-visualização
Carregando…
Cancelar
Salvar