复制代码 代码如下:

<?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);
}
}
?>