WordPress中基于PHP IMAP实现邮件内容自动导入自定义文章类型

class Email_reader {

    // imap server connection
    public $conn;

    // inbox storage and inbox message count
    private $inbox;
    private $msg_cnt;

    // email login credentials
    private $server = 'myserver.com'; // 您的IMAP服务器地址
    private $user   = 'your_email@myserver.com'; // 您的邮箱地址
    private $pass   = 'YOUR_PASSWORD'; // 您的邮箱密码
    private $port   = 993; // IMAP端口，通常是993（SSL）或143

    /**
     * 构造函数：连接到服务器并读取收件箱邮件
     */
    function __construct() {
        $this->connect();
        $this->inbox();
    }

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

    /**
     * 打开服务器连接
     * 注意：imap_open 函数的参数需要根据您的IMAP服务器配置进行调整。
     * 示例中的 '{'.$this->server.'/notls}' 适用于某些特定服务器（如Dreamhost），
     * 您可能需要改为 '{'.$this->server.':'.$this->port.'/imap/ssl/novalidate-cert}' 等。
     */
    function connect() {
        // 建议根据实际服务器配置调整连接字符串
        $connection_string = '{'.$this->server.':'.$this->port.'/imap/ssl/novalidate-cert}INBOX'; 
        // 原始示例：$this->conn = imap_open('{'.$this->server.'/notls}', $this->user, $this->pass);
        $this->conn = imap_open($connection_string, $this->user, $this->pass);

        if (!$this->conn) {
            throw new Exception('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 邮件索引 (1 = 第一封邮件, 2 = 第二封邮件, 等)
     * @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开始
            return $this->inbox[$msg_index - 1];
        }

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

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

    /**
     * 读取收件箱邮件并存储到 $inbox 属性
     */
    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;
    }
}

// 实例化 Email_reader 类以开始读取邮件
try {
    $emails = new Email_reader;
} catch (Exception $e) {
    error_log($e->getMessage()); // 记录错误日志
    die('邮件读取器初始化失败。');
}

// 示例：查看读取到的邮件对象
// var_dump($emails);

// 确保在WordPress环境中运行此代码，例如在主题的functions.php或自定义插件中
if ( ! function_exists('wp_insert_post') ) {
    // 如果不在WordPress环境中，需要手动加载WordPress核心
    require_once( $_SERVER['DOCUMENT_ROOT'] . '/wp-load.php' );
}

// 假设 $emails 对象已由 Email_reader 类实例化并读取了邮件
// $emails = new Email_reader; // 如果 $emails 对象尚未实例化，请取消注释此行

$total_messages = $emails->total_msg(); 

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

    // 检查邮件是否已存在，避免重复导入
    // 可以通过邮件的唯一标识符（如Msgno）进行检查
    $existing_posts = get_posts(array(
        'post_type'  => 'faqpress_email', // 您的自定义文章类型slug
        'meta_key'   => 'ticket_id',
        'meta_value' => $mail['header']->Msgno,
        'posts_per_page' => 1,
        'fields'     => 'ids',
    ));

    if ( ! empty($existing_posts) ) {
        // 邮件已存在，跳过导入
        continue;
    }

    // 准备要插入的文章数据
    $post_array = array( 
        'post_content'  => wp_kses_post($mail['body']), // 过滤HTML内容，防止XSS攻击
        'post_title'    => sanitize_text_field($mail['header']->subject), // 清理标题
        'post_type'     => 'faqpress_email', // 替换为您的自定义文章类型 slug
        'post_status'   => 'publish', // 发布状态
        'meta_input'    => array(
            'from_address'  => sanitize_email($mail['header']->fromaddress), // 发件人地址
            'email_date'    => date('Y-m-d H:i:s', strtotime($mail['header']->Date)), // 邮件日期，格式化
            'ticket_id'     => intval($mail['header']->Msgno), // 邮件的唯一消息编号
            // 您可以根据需要添加更多自定义字段
        ),
    );

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

    if ( is_wp_error($post_id) ) {
        error_log('导入邮件失败: ' . $post_id->get_error_message());
    } else {
        // 邮件导入成功后，可以选择将其移动到已处理文件夹
        // $emails->move($j, 'INBOX.Processed'); 
        // error_log('邮件导入成功，文章ID: ' . $post_id . '，邮件主题: ' . $post_array['post_title']);
    }
}

// 完成所有操作后关闭IMAP连接
$emails->close();