334 lines
8.2 KiB
PHP
Executable File
334 lines
8.2 KiB
PHP
Executable File
<?php
|
||
|
||
|
||
if (!defined('IN_ECS'))
|
||
{
|
||
die('Hacking attempt');
|
||
}
|
||
|
||
define('SMTP_STATUS_NOT_CONNECTED', 1, true);
|
||
define('SMTP_STATUS_CONNECTED', 2, true);
|
||
|
||
class smtp
|
||
{
|
||
var $connection;
|
||
var $recipients;
|
||
var $headers;
|
||
var $timeout;
|
||
var $errors;
|
||
var $status;
|
||
var $body;
|
||
var $from;
|
||
var $host;
|
||
var $port;
|
||
var $helo;
|
||
var $auth;
|
||
var $user;
|
||
var $pass;
|
||
|
||
/**
|
||
* 参数为一个数组
|
||
* host SMTP 服务器的主机 默认：localhost
|
||
* port SMTP 服务器的端口 默认：25
|
||
* helo 发送HELO命令的名称 默认：localhost
|
||
* user SMTP 服务器的用户名 默认：空值
|
||
* pass SMTP 服务器的登陆密码 默认：空值
|
||
* timeout 连接超时的时间 默认：5
|
||
* @return bool
|
||
*/
|
||
function smtp($params = array())
|
||
{
|
||
if (!defined('CRLF'))
|
||
{
|
||
define('CRLF', "\r\n", true);
|
||
}
|
||
|
||
$this->timeout = 10;
|
||
$this->status = SMTP_STATUS_NOT_CONNECTED;
|
||
$this->host = 'localhost';
|
||
$this->port = 25;
|
||
$this->auth = false;
|
||
$this->user = '';
|
||
$this->pass = '';
|
||
$this->errors = array();
|
||
|
||
foreach ($params AS $key => $value)
|
||
{
|
||
$this->$key = $value;
|
||
}
|
||
|
||
$this->helo = $this->host;
|
||
|
||
// 如果没有设置用户名则不验证
|
||
$this->auth = ('' == $this->user) ? false : true;
|
||
}
|
||
|
||
function connect($params = array())
|
||
{
|
||
if (!isset($this->status))
|
||
{
|
||
$obj = new smtp($params);
|
||
|
||
if ($obj->connect())
|
||
{
|
||
$obj->status = SMTP_STATUS_CONNECTED;
|
||
}
|
||
|
||
return $obj;
|
||
}
|
||
else
|
||
{
|
||
if (!empty($GLOBALS['_CFG']['smtp_ssl']))
|
||
{
|
||
$this->host = "ssl://" . $this->host;
|
||
}
|
||
$this->connection = @fsockopen($this->host, $this->port, $errno, $errstr, $this->timeout);
|
||
|
||
if ($this->connection === false)
|
||
{
|
||
$this->errors[] = 'Access is denied.';
|
||
|
||
return false;
|
||
}
|
||
|
||
@socket_set_timeout($this->connection, 0, 250000);
|
||
|
||
$greeting = $this->get_data();
|
||
|
||
if (is_resource($this->connection))
|
||
{
|
||
$this->status = 2;
|
||
|
||
return $this->auth ? $this->ehlo() : $this->helo();
|
||
}
|
||
else
|
||
{
|
||
log_write($errstr, __FILE__, __LINE__);
|
||
$this->errors[] = 'Failed to connect to server: ' . $errstr;
|
||
|
||
return false;
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 参数为数组
|
||
* recipients 接收人的数组
|
||
* from 发件人的地址，也将作为回复地址
|
||
* headers 头部信息的数组
|
||
* body 邮件的主体
|
||
*/
|
||
|
||
function send($params = array())
|
||
{
|
||
foreach ($params AS $key => $value)
|
||
{
|
||
$this->$key = $value;
|
||
}
|
||
|
||
if ($this->is_connected())
|
||
{
|
||
// 服务器是否需要验证
|
||
if ($this->auth)
|
||
{
|
||
if (!$this->auth())
|
||
{
|
||
return false;
|
||
}
|
||
}
|
||
|
||
$this->mail($this->from);
|
||
|
||
if (is_array($this->recipients))
|
||
{
|
||
foreach ($this->recipients AS $value)
|
||
{
|
||
$this->rcpt($value);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
$this->rcpt($this->recipients);
|
||
}
|
||
|
||
if (!$this->data())
|
||
{
|
||
return false;
|
||
}
|
||
|
||
$headers = str_replace(CRLF . '.', CRLF . '..', trim(implode(CRLF, $this->headers)));
|
||
$body = str_replace(CRLF . '.', CRLF . '..', $this->body);
|
||
$body = substr($body, 0, 1) == '.' ? '.' . $body : $body;
|
||
|
||
$this->send_data($headers);
|
||
$this->send_data('');
|
||
$this->send_data($body);
|
||
$this->send_data('.');
|
||
|
||
return (substr($this->get_data(), 0, 3) === '250');
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = 'Not connected!';
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function helo()
|
||
{
|
||
if (is_resource($this->connection)
|
||
AND $this->send_data('HELO ' . $this->helo)
|
||
AND substr($error = $this->get_data(), 0, 3) === '250' )
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = 'HELO command failed, output: ' . trim(substr($error, 3));
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function ehlo()
|
||
{
|
||
if (is_resource($this->connection)
|
||
AND $this->send_data('EHLO ' . $this->helo)
|
||
AND substr($error = $this->get_data(), 0, 3) === '250' )
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = 'EHLO command failed, output: ' . trim(substr($error, 3));
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function auth()
|
||
{
|
||
if (is_resource($this->connection)
|
||
AND $this->send_data('AUTH LOGIN')
|
||
AND substr($error = $this->get_data(), 0, 3) === '334'
|
||
AND $this->send_data(base64_encode($this->user)) // Send username
|
||
AND substr($error = $this->get_data(),0,3) === '334'
|
||
AND $this->send_data(base64_encode($this->pass)) // Send password
|
||
AND substr($error = $this->get_data(),0,3) === '235' )
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = 'AUTH command failed: ' . trim(substr($error, 3));
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function mail($from)
|
||
{
|
||
if ($this->is_connected()
|
||
AND $this->send_data('MAIL FROM:<' . $from . '>')
|
||
AND substr($this->get_data(), 0, 2) === '250' )
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function rcpt($to)
|
||
{
|
||
if ($this->is_connected()
|
||
AND $this->send_data('RCPT TO:<' . $to . '>')
|
||
AND substr($error = $this->get_data(), 0, 2) === '25')
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = trim(substr($error, 3));
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function data()
|
||
{
|
||
if ($this->is_connected()
|
||
AND $this->send_data('DATA')
|
||
AND substr($error = $this->get_data(), 0, 3) === '354' )
|
||
{
|
||
return true;
|
||
}
|
||
else
|
||
{
|
||
$this->errors[] = trim(substr($error, 3));
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function is_connected()
|
||
{
|
||
return (is_resource($this->connection) AND ($this->status === SMTP_STATUS_CONNECTED));
|
||
}
|
||
|
||
function send_data($data)
|
||
{
|
||
if (is_resource($this->connection))
|
||
{
|
||
return fwrite($this->connection, $data . CRLF, strlen($data) + 2);
|
||
}
|
||
else
|
||
{
|
||
return false;
|
||
}
|
||
}
|
||
|
||
function get_data()
|
||
{
|
||
$return = '';
|
||
$line = '';
|
||
|
||
if (is_resource($this->connection))
|
||
{
|
||
while (strpos($return, CRLF) === false OR $line{3} !== ' ')
|
||
{
|
||
$line = fgets($this->connection, 512);
|
||
$return .= $line;
|
||
}
|
||
|
||
return trim($return);
|
||
}
|
||
else
|
||
{
|
||
return '';
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获得最后一个错误信息
|
||
*
|
||
* @access public
|
||
* @return string
|
||
*/
|
||
function error_msg()
|
||
{
|
||
if (!empty($this->errors))
|
||
{
|
||
$len = count($this->errors) - 1;
|
||
return $this->errors[$len];
|
||
}
|
||
else
|
||
{
|
||
return '';
|
||
}
|
||
}
|
||
}
|
||
|
||
?>
|