PHP 利用Mail_MimeDecode类提取邮件信息示例

重点为one_mail函数。利用Mail_mimeDecode类从邮件中提取邮件头和邮件正文。
复制代码代码如下:
<？php
header（"content-type:text/html; charset=UTF-8"）;
/*
* record kid words and insert into database
* user by sending email to publication kid words
*
*/
include "POP3.php";
include "email_class.php";
include "Mail_mimeDecode.php";
//include "include/compatible.php";
include "include/extend_common.php";
//include "../../htdocs/include/extend_common.php";
define（"POST_FROM_EMAIL", 1）;
define（"DATABASE_CONNECTION_ERROR", 2）; //数据库连接失败错误
define（"EMAIL_CONNECTION_ERROR", 3）; //邮箱连接失败错误
define（"ACCOUNT_ERROR", 4）; //邮箱的账号错误
define（"SIGN_EMAIL_ERROR", 5）; //邮件标记删除错误
define（"DELELET_ERROR", 6）; //删除邮件错误
define（"INSERT_ERROR", 7）; //插入数据失败错误

class mail_data {

function mail_data（） {
include "config.php";
$mail_log = fopen（"mail_log.txt", "a+"）;
$conn = @ mysql_connect（$db_host, $db_user, $db_password）;
if （$conn） {
mysql_select_db（"t", $conn）;
mysql_query（"set names utf8"）;
$pop3 = new Net_POP3（）;
//判断连接是否成功
if （$pop3->connect（$host, 110）） {
//判断登入是否成功
if （$pop3->login（$user, $password） === true） {
$list = $pop3->_cmdList（）;
$sum = $pop3->_cmdStat（）;

//每次取多少邮件
$step = 2;
$r = 0;
//先对邮箱取$step邮件
for （$n = 0; $n < $sum[0]; $n += $step） {
$t = 0;
$users = array （）;
$mail = array （）;
$offset = （$sum[0] - $n） < $step ？ $sum[0] - $n : $step;
//邮件循环
for （$i = $r; $i < $n + $offset; $i++） {

//取得邮件信息
$user = $this->one_mail（$i, $pop3, $list, $mail_log）;
array_push（$mail, $user["from_mail"]）;
array_push（$users, $user）;
$r = $i +1;
}
//取得mail用户数据
$str = $this->uesr_data（$mail）;
$value = array （）;

//当前邮件数组循环，当前邮件用户的email，小孩名，童言
for （$m = 0; $m < count（$users）; $m++） {
$num = 0;
$mn = $m + $n;
//数据处理
$post_text = $users[$m]["conntent"];
if （！empty （$post_text）） {
$post_text = do_submit_text（$post_text）;
$post_text = mysql_real_escape_string（$post_text）;
$post_link_num = parsed_text_include_links（$post_text）;
$text = do_submit_text（$post_text）;
$post_text_undo = mysql_real_escape_string（$text）;
$post_text = mysql_real_escape_string（$post_text）;
$val = array （）;
$kid_num = $users[$m]["kid_nickname"];
if （is_numeric（$kid_num） && intval（$kid_num） <= 3 && intval（$kid_num） > 0） {
$kid_num = intval（$kid_num）;
$val = $this->kid_data（$users, $m, $kid_num, $post_text, $post_link_num, $post_text_undo）;
if （isset （$val）） {
$value["$t"] = $val;
$num = 1;
$t = $t +1;
}
} else {
//数据库中的数据
for （$x = 0; $x < count（$str）; $x++） {
//判断是否是from_mail的小孩
$val["$x"] = $this->is_kid（$users, $str, $m, $x, $post_text, $post_link_num, $post_text_undo）;
if （isset （$val["$x"]）） {
$value["$t"] = $val["$x"];
$num = 1;
$t = $t +1;
}
}
}

//判断是否成功与数据库中数据匹配到
if （$num == 0） {
$val = $this->kid_data（$users, $m, 1, $post_text, $post_link_num, $post_text_undo）;
if （isset （$val）） {
$value["$t"] = $val;
$num = 1;
$t = $t +1;
}
}
}
}
//对一段数据操作
$valu = implode（"）,（", $value）;
if （$valu ！= ""） {
$err_time = $this->insert_date（$valu）;
$this->kid_message_count（$value）;
}
}
fclose（$mail_log）;
/*
if（$pop3->disconnect（）==false）{
$this->_error（DELELET_ERROR）;
}
*/
} else {
echo "帐号或密码错误！";
$this->_error（ACCOUNT_ERROR）;
}
} else {
echo "连接失败...";
$this->_error（EMAIL_CONNECTION_ERROR）;

}
} else {
echo "数据库连接失败...";
$this->_error（DATABASE_CONNECTION_ERROR）;
}
}

/*
*read the $i email message
*@access public
*@param int $i mail id
*@param object $pop3 pop3 protocol object
*@return array mail from ,header,content
*/
function one_mail（$i, $pop3, $list, $mail_log） {
$stg = $pop3->getParsedHeaders（$list[$i]["msg_id"]）;
$from = imap_mime_header_decode（$stg["From"]）; //邮件的发送者
$string_from = "";
for （$j = 0; $j < count（$from）; $j++） {
$string_from = "$string_from" . $from[$j]->text;
}
preg_match（"/（[a-z0-9A-Z_]+）@（[a-z0-9A-Z/.]+）.（[a-z0-9A-Z]+）/", $string_from, $from_mail）;

$string = $pop3->getMsg（$list[$i]["msg_id"]）;
$body = new Mail_mimeDecode（$string）;

$sr = $body->decode（array （
"include_bodies" => true,
"decode_bodies" => false,
"decode_headers" => true
））;

if （property_exists（$sr, "parts"）） {
$mail_part = $sr->parts;
$mail_part = $mail_part[0];
} else {
$mail_part = $sr;
}

$mail_code = $mail_part->headers;
$mail_code = $mail_code["content-transfer-encoding"]; //编码格式
$mail_type = $mail_part->ctype_parameters;
$mail_type = $mail_type["charset"];
$mail_body = $mail_part->body; //正文内容

if （$mail_code == "base64"） { //判断编码格式
$text = base64_decode（"$mail_body"）;
$text = iconv（"$mail_type", "UTF-8", $text）;
} else {
$text = quoted_printable_decode（"$mail_body"）;
$text = iconv（"$mail_type", "UTF-8", $text）;
}

$mail_title = $sr->headers;
$mail_title = $mail_title["subject"];
$mail_title = imap_mime_header_decode（$mail_title）;

if （count（$mail_title）！= 0） {

$title = $mail_title[0]->text;
$t = $mail_title[0]->charset;

if （$t ！= "default"） {
$title = iconv（$t, "UTF-8", $title）;
} else {
$title = iconv（"gb2312", "UTF-8", $title）;
}
} else {
$title = 1;
}
//$pop3->_cmdDele（$list[$i]["msg_id"]）;
$pop3->deleteMsg（$list[$i]["msg_id"]）;
if （$pop3->deleteMsg（$list[$i]["msg_id"]） == false） {
$this->_error（SIGN_EMAIL_ERROR）;
}
//取得需要插入的用户email，小孩名，童言
$users["$i"] = array （
"from_mail" => "$from_mail[0]",
"kid_nickname" => "$title",
"conntent" => "$text",
"body_type" => "$mail_type"
）;
$log = $users["$i"];
array_unshift（$log, date（"Y-m-d H:i;s"））;
$log = serialize（$log）;
fwrite（$mail_log, $log . "/r/n"）;
return $users["$i"];
}

/**
*at database search $mail user"s information
*@access public
*@param string $mail all email
*@return array mail user"s information
*/
function uesr_data（$mail） {
$mails = implode（"","", $mail）;
$sql = "SELECT a.mail,a.user_name,a.user_nickname,b.kid_id, b.kid_name,b.kid_avatar ,b.kid_birthday
FROM `t_users` a, `t_users_kid` b
WHERE a.mail in （"$mails"） AND a.user_id=b.user_id";
$query = mysql_query（$sql） or die（mysql_error（））;
$str1 = array （）;

while （$arr = mysql_fetch_array（$query）） {
array_push（$str1, $arr）;
}
return $str1;
}
/*
*insert $value into database
*@access public
*@param string $value kid information
*@return void
*/
function insert_date（$value） {
$sql_insert = "INSERT INTO `t_posts`（kid_id,user_name,user_nickname,post_time,post_text,user_avatar,post_link_num,post_text_undo,post_from,add_time）
VALUES （$value）";
$num = mysql_query（$sql_insert） or die（mysql_error（））;

if （$num ！= 1） {
$this->_error（INSERT_ERROR）;
}
}
/*
*send email to $smtpemailto
*@access public
*@param string $mailtype mail_from type
*@param string $smtpemailto mail_from
*@param string $user_kid_name mail title
*@return void
*/
function reply_email（$mailtype, $smtpemailto, $user_kid_nickname） {
require "config.php";
$mailsubject = "您暂时还没有" . $user_kid_nickname . "宝宝";
$mailsubject = "=？UTF-8？B？" . base64_encode（$mailsubject） . "？=";
$mailbody = "请先添加宝宝";

if （$mailtype ！= "ISO-8859-1"） {
$mailbody = iconv（"utf-8", "$mailtype//ignore", $mailbody）;
}

$mail_type = "HTML";
$smtp = new smtp（$smtpserver, $smtpserverport, true, $smtpuser, $smtppass）;
$smtp->debug = FALSE;
$send_mail = $smtp->sendmail（$smtpemailto, $smtpusermail, $mailsubject, $mailbody, $mail_type, "", ""）;

if （$send_mail == false） {
return "send faile";
$send_mail = $smtp->sendmail（$smtpemailto, $smtpusermail, $mailsubject, $mailbody, $mail_type, "", ""）;
}
}
/*
*the kid"s age then publication kid words
*@access public
*@param int $kid_birthday kid birthday
*@return array kid year month day
*/

function get_kid_age_info（$kid_birthday） {
$cur_date = date（"Ymd"）;
$age = $cur_date - $kid_birthday;
if （$age < 0） {
return false;
}
$years = 0;
$months = 0;
$days = 0;
if （$age > 10000） {
$years = floor（$age / 10000）;
}

$age = $age % 10000;
$months = floor（$age / 100）;
if （$months > 12）
$months -= 88;
$days = $age % 100;
if （$days > $cur_date % 100） {
$days = $days - （100 - date（"d", strtotime（date（"Ym"） . "01"） - 24 * 3600））;
}
return array （
$years,
$months,
$days
）;
}
/**
*judge the $m message and the $x data
*@access public
*@param array $users mail information
*@param array $str user information
*@param int $m $users grade
*@param int $x $str grade
*@param string $post_text the mail text
*@return string information
*/
function is_kid（$users, $str, $m, $x, $post_text, $post_link_num, $post_text_undo） {

if （$users[$m]["from_mail"] == $str[$x]["mail"]） { //判断是否是from_mail的小孩

$kid_id = $str[$x]["kid_id"];
$user_name = $str[$x]["user_name"];
$user_nickname = $str[$x]["user_nickname"];
$kid_diff = $str[$x]["kid_birthday"];
$kid_name = $str[$x]["kid_name"];
$kid_diff = date（"Ymd", $kid_diff）;
$kid_birthdy = $this->get_kid_age_info（$kid_diff）;
//格式转换
for （$j = 0; $j < count（$kid_birthdy）; $j++） {
if （$kid_birthdy[$j] >= 0 && $kid_birthdy[$j] < 10） {
$kid_birthdy[$j] = "0" . "$kid_birthdy[$j]";
}
}
$post_time = $kid_birthdy[0] . $kid_birthdy[1] . $kid_birthdy[2];
$user_avatar = get_kid_avatar（$user_name, $kid_id）;
$kid_avatar = $user_avatar;
if （$users[$m]["kid_nickname"] == $kid_name） {
$kid_id = mysql_real_escape_string（"$kid_id"）;
$user_name = mysql_real_escape_string（"$user_name"）;
$post_time = mysql_real_escape_string（"$post_time"）;
$kid_avatar = mysql_real_escape_string（"$kid_avatar"）;
$from = POST_FROM_EMAIL;
$add_time = time（）;
$values = ""$kid_id","$user_name","$user_nickname","$post_time","$post_text","$kid_avatar","$post_link_num","$post_text_undo","$from","$add_time"";
return $values;
}
}
}
/**
*have the kid_num kid of users information
*@access public
*@param array $users the array（） of users
*@param int $m the m items of array
*@param int $kid_num the kid_num kid
*@return array kid information
*/
function user_kid（$users, $m, $kid_num） {
$m_mail = $users["$m"]["from_mail"];
$sql = "SELECT a.user_name,a.user_nickname,b.kid_id, b.kid_name,b.kid_avatar ,b.kid_birthday
FROM `t_users` a, `t_users_kid` b
WHERE a.mail="$m_mail" AND a.user_id=b.user_id ORDER BY b.kid_birthday ASC ";
$query = mysql_query（$sql） or die（mysql_error（））;
$str1 = array （）;
$kids = array （）;
$i = 0;
while （$arr = mysql_fetch_array（$query）） {
$str1[$i] = $arr;
$i = $i +1;
}
$kid_num = $kid_num -1;
if （$kid_num > （count（$str1） - 1）） {
return $num = 0;
} else {
return $str1["$kid_num"];
}

}
/**
*get the kid_num kid information
*@access public
*@param array $users the array（） of users
*@param int $m the m items of array
*@param int $kid_num the kid_num kid
*@param string $post_text the message of mail
*@param int $post_link_num count（link） of message body
*@return array $values the kid information
*/
function kid_data（$users, $m, $kid_num, $post_text, $post_link_num, $post_text_undo） {
$use_kid = $this->user_kid（$users, $m, $kid_num）;

if （$use_kid ！= 0） {
$kid_id = $use_kid["kid_id"];
$user_name = $use_kid["user_name"];
$user_nickname = $use_kid["user_nickname"];
$kid_diff = $use_kid["kid_birthday"];
$kid_diff = date（"Ymd", $kid_diff）;
$kid_birthdy = $this->get_kid_age_info（$kid_diff）;
//格式转换
for （$j = 0; $j < count（$kid_birthdy）; $j++） {
if （$kid_birthdy[$j] >= 0 && $kid_birthdy[$j] < 10） {
$kid_birthdy[$j] = "0" . "$kid_birthdy[$j]";
}
}
$post_time = $kid_birthdy[0] . $kid_birthdy[1] . $kid_birthdy[2];

$user_avatar = get_kid_avatar（$user_name, $kid_id）;
$kid_avatar = $user_avatar;
$add_time = time（）;
$from = POST_FROM_EMAIL;
$values = ""$kid_id","$user_name","$user_nickname","$post_time","$post_text","$kid_avatar","$post_link_num","$post_text_undo","$from","$add_time"";
return $values;
}
}
/**
*update data when have kid words
*@access public
*@param array $value the array（） of users
*@return void
*/
function kid_message_count（$value） {
$use_names = array （）;

for （$k = 0; $k < count（$value）; $k++） {
$k_name = explode（",", $value[$k]）;
$use_names[$k] = $k_name[1];
}
asort（$use_names）;
$sum_kid = count（$use_names）;
$s = 0;
if （count（$use_names） == 1） {
$d_users[0] = $use_names[0];
} else {

//第一个
if （$use_names[0] ！= $use_names[1]） {
$d_users[0] = $use_names[0];
} else {
$s_users[$s] = $use_names[0];
$s = $s +1;
}
//最后一个
if （$use_names[$sum_kid -1] ！= $use_names[$sum_kid -2]） {
$d_users[$sum_kid -1] = $use_names[$sum_kid -1];
} else {
$s_users[$s] = $use_names[$sum_kid -1];
$s = $s +1;
}

for （$k = 1; $k < count（$use_names） - 1; $k++） {

if （$use_names[$k] == $use_names[$k -1] || $use_names[$k] == $use_names[$k +1]） {
$s_users[$s] = $use_names[$k];
$s = $s +1;
} else {
$d_users[$k] = $use_names[$k];
}

}
}

if （isset （$d_users）） {
$names = implode（",", $d_users）;
$sql = "UPDATE `t_users` set post_num = post_num+1 WHERE `t_users`.user_name in （$names）";
$query = mysql_query（$sql） or die（mysql_error（））;
}

if （isset （$s_users）） {

for （$s = 0; $s < count（$s_users）; $s++） {
$name = $s_users[$s];
$sql = "UPDATE `t_users` set post_num = post_num+1 WHERE `t_users`.user_name = $name";
$query = mysql_query（$sql） or die（mysql_error（））;
}

}

}
/**
* point error
*@access private
*@param int error_num the error code
*@return void
*
*/
private function _error（$error_num） {
$error_log = fopen（"error_log.txt", "a+"）;
switch （$error_num） {
case 2 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tCould not connect database！/r/n"）;
break;
case 3 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tConnection Failure！/r/n"）;
break;
case 4 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tAccount number or password error！！/r/n"）;
break;
case 5 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tsign email failed！/r/n"）;
break;
case 6 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tdelete emails failed！/r/n"）;
break;
case 7 :
fwrite（$error_log, date（"Y-m-d H:i:s"） . "/t" . $error_num . "/tinsert data failed！/r/n"）;
break;
}
fclose（$error_log）;
}
}
？>