将IMAP邮件导入WordPress自定义文章类型教程

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   = 'PASSWORD'; // 你的邮箱密码
    private $port   = 993; // IMAP端口，通常是993（SSL）或143

    // connect to the server and get the inbox emails
    function __construct() {
        $this->connect();
        $this->inbox();
    }

    // close the server connection
    function close() {
        $this->inbox = array();
        $this->msg_cnt = 0;
        if ($this->conn) {
            imap_close($this->conn);
        }
    }

    // open the server connection
    function connect() {
        // 根据你的服务器配置调整连接字符串
        // 例如：'{myserver.com:993/imap/ssl/novalidate-cert}'
        $this->conn = imap_open('{'.$this->server.':'.$this->port.'/imap/ssl}', $this->user, $this->pass);
        if (!$this->conn) {
            die('Cannot connect to IMAP: ' . imap_last_error());
        }
    }

    // move the message to a new folder
    function move($msg_index, $folder='INBOX.Processed') {
        if ($this->conn) {
            imap_mail_move($this->conn, $msg_index, $folder);
            imap_expunge($this->conn); // 永久删除被移动的邮件
            $this->inbox(); // 重新读取收件箱
        }
    }

    // get a specific message (1 = first email, 2 = second email, etc.)
    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];
    }

    // read the inbox
    function inbox() {
        if (!$this->conn) {
            $this->msg_cnt = 0;
            $this->inbox = array();
            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;
    }

    // get total message count
    function total_msg() {
        return $this->msg_cnt;
    }
}

// 实例化邮件阅读器并获取邮件
$emails = new Email_reader;

// 确保Email_reader类已实例化并获取了邮件
// $emails = new Email_reader; // 如果上面没有实例化，这里需要

$total = $emails->total_msg();

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

    // 检查邮件是否有效，避免空数据插入
    if (empty($mail) || empty($mail['header']->subject)) {
        continue;
    }

    // 准备要插入WordPress的文章数据
    $post_array = array(
        'post_content'  => $mail['body'], // 邮件正文作为文章内容
        'post_title'    => $mail['header']->subject, // 邮件主题作为文章标题
        'post_type'     => 'faqpress_email', // 你的自定义文章类型 slug
        'post_status'   => 'publish', // 设置文章状态为发布
        'meta_input'    => array( // 自定义字段（post meta）
            'from_address' => $mail['header']->fromaddress, // 发件人地址
            'email_date'   => $mail['header']->Date,       // 邮件日期
            'message_id'   => $mail['header']->message_id, // 邮件的唯一ID
            'ticket_id'    => $mail['header']->Msgno,      // 邮件在IMAP服务器中的编号
        ),
    );

    // 插入文章到WordPress数据库
    $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');
        // 可选：记录日志或进行其他操作
        // error_log('Email imported successfully with ID: ' . $post_id);
    }
}

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