PHP IMAP邮件提取与WordPress自定义文章类型整合指南

<?php

/**
 * Email_reader 类用于连接IMAP服务器，读取和管理邮件。
 */
class Email_reader {

    public $conn; // IMAP 服务器连接资源
    private $inbox; // 存储邮件列表
    private $msg_cnt; // 邮件总数

    // IMAP 登录凭据和服务器设置
    private $server = 'myserver.com'; // IMAP 服务器地址
    private $user   = 'your_email@example.com'; // 邮箱用户名
    private $pass   = 'YOUR_PASSWORD'; // 邮箱密码
    private $port   = 993; // IMAP 端口，通常为 993 (SSL) 或 143 (非SSL)

    /**
     * 构造函数：建立连接并读取收件箱。
     */
    function __construct() {
        $this->connect();
        $this->inbox();
    }

    /**
     * 关闭IMAP服务器连接。
     */
    function close() {
        $this->inbox = array();
        $this->msg_cnt = 0;
        if ($this->conn) {
            imap_close($this->conn);
        }
    }

    /**
     * 建立IMAP服务器连接。
     * 请根据您的服务器配置调整 imap_open 函数的参数。
     * 示例中使用了 '/notls'，您可能需要 '/ssl' 或其他选项。
     */
    function connect() {
        // 示例：连接到使用SSL的IMAP服务器
        // $this->conn = imap_open('{'.$this->server.':'.$this->port.'/ssl/novalidate-cert}', $this->user, $this->pass);
        // 示例：连接到不使用TLS/SSL的IMAP服务器
        $this->conn = imap_open('{'.$this->server.'/notls}', $this->user, $this->pass);

        if (!$this->conn) {
            die('无法连接到IMAP服务器: ' . imap_last_error());
        }
    }

    /**
     * 将指定邮件移动到另一个文件夹。
     *
     * @param int $msg_index 邮件索引。
     * @param string $folder 目标文件夹名称，例如 'INBOX.Processed'。
     */
    function move($msg_index, $folder='INBOX.Processed') {
        if ($this->conn) {
            imap_mail_move($this->conn, $msg_index, $folder);
            imap_expunge($this->conn); // 永久删除标记为删除的邮件
            $this->inbox(); // 重新读取收件箱
        }
    }

    /**
     * 获取指定索引的邮件内容。
     *
     * @param int|null $msg_index 邮件索引，如果为null则返回第一封邮件。
     * @return array 邮件数据数组，如果找不到则返回空数组。
     */
    function get($msg_index=NULL) {
        if (count($this->inbox) <= 0) {
            return array();
        }
        elseif ( ! is_null($msg_index) && isset($this->inbox[$msg_index - 1])) { // 数组索引从0开始，邮件索引从1开始
            return $this->inbox[$msg_index - 1];
        }

        return $this->inbox[0]; // 默认返回第一封邮件
    }

    /**
     * 读取收件箱中的所有邮件，并存储其头信息、正文和结构。
     */
    function inbox() {
        if (!$this->conn) {
            return;
        }

        $this->msg_cnt = imap_num_msg($this->conn);
        $in = array();
        for($i = 1; $i <= $this->msg_cnt; $i++) {
            $in[] = array(
                'index'     => $i,
                'header'    => imap_headerinfo($this->conn, $i),
                'body'      => imap_body($this->conn, $i),
                'structure' => imap_fetchstructure($this->conn, $i)
            );
        }
        $this->inbox = $in;
    }

    /**
     * 获取邮件总数。
     * @return int 邮件总数。
     */
    public function total_msg() {
        return $this->msg_cnt;
    }
}

// 实例化邮件读取器
$emails = new Email_reader();

<?php
// 确保在WordPress环境中运行，例如通过插件或主题功能文件
// 并且 Email_reader 类已定义并实例化为 $emails

if (class_exists('Email_reader') && isset($emails) && $emails->conn) {
    $total_emails = $emails->total_msg();

    for ($j = 1; $j <= $total_emails; $j++) {
        $mail = $emails->get($j);

        if (!empty($mail)) {
            // 构建文章数据数组
            $post_array = array(
                'post_content'  => wp_kses_post($mail['body']), // 邮件正文，使用wp_kses_post进行内容清理
                'post_title'    => sanitize_text_field($mail['header']->subject), // 邮件主题，使用sanitize_text_field进行清理
                'post_type'     => 'faqpress_email', // 替换为您的自定义文章类型 slug
                'post_status'   => 'publish', // 设置文章状态为发布
                'meta_input'    => array(
                    'from_address' => sanitize_email($mail['header']->fromaddress), // 发件人地址
                    'email_date'   => sanitize_text_field($mail['header']->Date),   // 邮件日期
                    'ticket_id'    => sanitize_text_field($mail['header']->Msgno), // 邮件消息ID，可用作唯一标识
                ),
            );

            // 插入文章
            $post_id = wp_insert_post($post_array);

            if (!is_wp_error($post_id) && $post_id !== 0) {
                echo "成功将邮件 '{$post_array['post_title']}' 插入为文章 ID: {$post_id}<br>";
                // 邮件处理成功后，可以选择将其移动到已处理文件夹
                // $emails->move($j, 'INBOX.Processed');
            } else {
                echo "插入邮件 '{$post_array['post_title']}' 失败: " . $post_id->get_error_message() . "<br>";
            }
        }
    }

    // 处理完毕后关闭IMAP连接
    $emails->close();
} else {
    echo "Email_reader 类未实例化或IMAP连接失败。<br>";
}
?>