PHP遍历邮箱获取邮件内容

$emails = array(
array('account' => 'haodai1688@163.com', 'pwd' => '*', 'server' => 'imap.163.com'),
array('account' => 'haodaiwan@163.com', 'pwd' => '*', 'server' => 'imap.163.com'),
array('account' => 'asmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'bsmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'csmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'dsmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'esmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'fsmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'jsmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'hsmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'ismschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'ksmschina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'sms_test@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'smstestchina@yeah.net', 'pwd' => '*', 'server' => 'imap.yeah.net'),
array('account' => 'vesxza@163.com', 'pwd' => '*', 'server' => 'imap.163.com'),
array('account' => 'mm663305@163.com', 'pwd' => '*', 'server' => 'imap.163.com'),
array('account' => '14828@163.com', 'pwd' => '*', 'server' => 'imap.163.com'),
array('account' => '15850060264@163.com', 'pwd' => '*', 'server' => 'imap.163.com')
);
//读取发件箱的所有邮件
foreach ($emails as $key => $value) {
$imap_stream = imap_open('{' . $value['server'] . ':993/imap/ssl}&XfJT0ZAB-', $value['account'], $value['pwd']);
$msg_num = imap_num_msg($imap_stream);  //已发送的邮件的数量
while ($msg_num > 0) {
$data = array();
$headers = imap_headerinfo($imap_stream, $msg_num);
/* 邮件主题内容 */
$subject = imap_mime_header_decode($headers->subject);
$data['subject_text'] = mysql_real_escape_string($subject[0]->text);
/* 发件人的地址 */
$data['fromaddress'] = mysql_real_escape_string($headers->fromaddress);
/* 收件人的地址 */
$data['toaddress'] = mysql_real_escape_string($headers->toaddress);
/* 发送邮件的时间 */
$data['totime'] = date('Y-m-d H:i:s', strtotime($headers->MailDate));
/* 邮件正文的内容,todo:需要完善编码判断,以及附件的读取判断 */
$data['msg'] = mysql_real_escape_string(base64_decode(imap_fetchbody($imap_stream, $msg_num, 1)));
/* 邮件的header头内容 */
$data['header'] = mysql_real_escape_string(imap_fetchbody($imap_stream, 1, 0));
/* 邮件的body区域的内容 */
$data['body'] = mysql_real_escape_string(imap_body($imap_stream, $msg_num));
/* 提取电话号码 */
if (preg_match_all('/\d{4,}/', $data['subject_text'], $matches, PREG_PATTERN_ORDER)) {
$data['phone'] = implode(',', $matches[0]);
} else {
preg_match_all('/\d{4,}/', $data['msg'], $matches, PREG_PATTERN_ORDER);
$data['phone'] = implode(',', $matches[0]);
}
$msg_num--;
addContent($data);
}
imap_close($imap_stream);
echo $value['account'] . '---完成', PHP_EOL;
}
//写入数据到mysql的过程
function addContent($data) {
static $mysql_conn = '';
if (!is_resource($mysql_conn)) {
$mysql_conn = mysql_connect('127.0.0.1', 'root', 'root');
mysql_select_db("remail", $mysql_conn);
mysql_query('SET NAMES UTF8');
}
$sql = 'INSERT INTO mail_detail(subject,from_address,to_address,to_time,msg,header,body,phone) values (\'' . $data['subject_text'] . '\',\'' .
$data['fromaddress'] . '\',\'' . $data['toaddress'] . '\',\'' . $data['totime'] . '\',\'' . $data['msg'] . '\',\'' .
$data['header'] . '\',\'' . $data['body'] . '\',\'' . $data['phone'] . '\');';
mysql_query($sql);
}