PHP IMAP邮件提取与WordPress自定义文章类型集成教程

class Email_reader {
    public $conn; // IMAP服务器连接句柄
    private $inbox; // 存储收件箱邮件数组
    private $msg_cnt; // 邮件总数

    // 邮件服务器配置
    private $server = 'myserver.com';
    private $user   = 'your_email@myserver.com'; // 请替换为实际邮箱地址
    private $pass   = 'YOUR_PASSWORD'; // 请替换为实际邮箱密码
    private $port   = 993; // IMAP端口，通常为993（SSL）或143（非SSL）

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

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

    // 建立IMAP服务器连接
    function connect() {
        // {server/notls} 用于不使用TLS连接，根据服务器配置调整
        // 对于SSL连接，通常是 '{server:port/imap/ssl/novalidate-cert}'
        $this->conn = imap_open('{'.$this->server.':'.$this->port.'/imap/ssl}', $this->user, $this->pass);
        if (!$this->conn) {
            die('IMAP connection failed: ' . imap_last_error());
        }
    }

    // 将邮件移动到指定文件夹
    function move($msg_index, $folder='INBOX.Processed') {
        imap_mail_move($this->conn, $msg_index, $folder);
        imap_expunge($this->conn); // 清理已标记为删除的邮件
        $this->inbox(); // 重新读取收件箱
    }

    // 获取特定索引的邮件
    function get($msg_index=NULL) {
        if (count($this->inbox) <= 0) {
            return array();
        } elseif ( ! is_null($msg_index) && isset($this->inbox[$msg_index])) {
            return $this->inbox[$msg_index];
        }
        return $this->inbox[0]; // 默认返回第一封邮件
    }

    // 读取收件箱所有邮件的概览信息
    function inbox() {
        $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;
    }

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

// 示例：注册自定义文章类型
function register_email_cpt() {
    $labels = array(
        'name'          => _x( '邮件收件箱', 'Post Type General Name', 'textdomain' ),
        'singular_name' => _x( '邮件', 'Post Type Singular Name', 'textdomain' ),
        // ... 其他标签
    );
    $args = array(
        'label'                 => _x( '邮件收件箱', 'Post Type Label', 'textdomain' ),
        'labels'                => $labels,
        'public'                => true,
        'publicly_queryable'    => true,
        'show_ui'               => true,
        'show_in_menu'          => true,
        'query_var'             => true,
        'rewrite'               => array( 'slug' => 'email-inbox' ),
        'capability_type'       => 'post',
        'has_archive'           => true,
        'hierarchical'          => false,
        'menu_position'         => 5,
        'supports'              => array( 'title', 'editor', 'author', 'thumbnail', 'excerpt', 'comments' ),
        'show_in_rest'          => true, // 启用Gutenberg编辑器
    );
    register_post_type( 'faqpress_email', $args ); // 确保这里的 'faqpress_email' 与后续代码一致
}
add_action( 'init', 'register_email_cpt' );

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

// 获取邮件总数
$total_emails = $emails->total_msg();

// 循环处理每一封邮件
for ($j = 1; $j <= $total_emails; $j++) {
    $mail = $emails->get($j); // 获取当前邮件的详细信息

    // 准备用于wp_insert_post的数组
    $post_array = array(
        'post_content'  => wp_kses_post($mail['body']), // 邮件正文，建议进行内容清理
        'post_title'    => sanitize_text_field($mail['header']->subject), // 邮件主题，建议进行清理
        'post_type'     => 'faqpress_email', // 你的自定义文章类型名称
        '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)) {
        error_log('Error inserting email post: ' . $post_id->get_error_message());
    } else {
        // 邮件成功插入后，可以选择将其移动到服务器上的“已处理”文件夹
        // $emails->move($j, 'INBOX.Processed');
        echo "Email '{$mail['header']->subject}' imported as post ID: {$post_id}<br>";
    }
}

// 关闭IMAP连接
$emails->close();