欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  php教程

PHP邮件收发,和编码问题。数据匹配

程序员文章站 2022-05-04 22:21:02
...

?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'; //incl

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 $t=0;
$users=array();
$mail=array();
$offset=($sum[0]-$n) //邮件循环
for ($i=$r;$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 $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)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 //判断是否是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 $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 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 if ($kid_birthdy[$j]>=0&&$kid_birthdy[$j] $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 if ($kid_birthdy[$j]>=0&&$kid_birthdy[$j] $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 $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

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


?>
这个类主要是为了读取邮件服务器中邮件的信息的,并对邮件信息进行处理,提取出邮件信息中的from,title ,content
并且提取出他们的编码格式,并对他们进行处理,同时from ,title 分别要和数据库中的信息去匹配,one_mail函数为只读取一封mail邮件的信息的,通过传参数i确定是读取第几封mail,并且返回mail 的 from ,title,content。在这个函数当中,主要是要判断当前的对象是否有parts属性,所以要进行判断,各个邮件发送邮件时候都有点差异的。编码的提取和解码
user_data函数主要是返回当前mail 参数中数据库中用户的信息,
insert_data函数,主要是把当前的当前的value 数据插入,value参数原为一个数组,后通过函数implode函数进行分解
,从而能对数据进行批插入。
reply_email函数为回复mai函数,这函数中主要的问题是要对发送过来的函数的编码进行提取,从而当回复时也用
它发送的编码方式,这样才不会出现编码的问题。
is_kid函数,为判断小孩是否是存在,和邮件信息时候相匹配
kid_message_count函数为孩子的大小排序的,如果当前孩子比较多的话,可以为它孩子进行大小排序。

执行这个类的话:
$file=fopen("mail.pid","a+");
if(flock($file,LOCK_EX+LOCK_NB)){
fwrite($file,date("Y-m-d H:i:s")."/tfile had locking/r/n");
$mail=new mail_data();
flock($file,LOCK_UN);
}else{
echo "程序运行中……";
}
fclose($file);

这个主要是通过文件锁flock来处理它进行单进程运行程序。

同时在整个类中,我也对当前的邮件信息数据进行了日志记载,和错误信息记录。