Symfony 怎么把IMAP邮件头转数组

<?php

// 假设这些配置来自你的Symfony参数或环境变量
$hostname = '{imap.example.com:993/imap/ssl/novalidate-cert}INBOX';
$username = 'your_email@example.com';
$password = 'your_password';

$inbox = imap_open($hostname, $username, $password) or die('无法连接到邮箱: ' . imap_last_error());

// 获取最新的邮件ID，或者指定一个邮件ID
$emails = imap_search($inbox, 'ALL');
$lastEmailId = end($emails); // 假设我们处理最新一封邮件

if ($lastEmailId) {
    // 获取邮件头信息，它返回一个stdClass对象
    $headerInfo = imap_headerinfo($inbox, $lastEmailId);

    // 将stdClass对象转换为数组
    $headerArray = [];
    foreach ($headerInfo as $key => $value) {
        // imap_headerinfo返回的对象中，有些字段本身就是对象数组（如from, to, cc, bcc, reply_to）
        // 对于这些字段，我们需要进一步处理，否则直接转换为数组
        if (is_array($value) && !empty($value) && is_object($value[0])) {
            $processedValue = [];
            foreach ($value as $item) {
                // 常见的联系人信息对象有 personal, mailbox, host
                $processedValue[] = [
                    'personal' => isset($item->personal) ? (string) imap_utf8($item->personal) : null,
                    'mailbox' => isset($item->mailbox) ? (string) $item->mailbox : null,
                    'host' => isset($item->host) ? (string) $item->host : null,
                ];
            }
            $headerArray[$key] = $processedValue;
        } elseif (is_string($value)) {
            // 对主题等可能包含非ASCII字符的字符串进行UTF-8解码
            if (in_array($key, ['subject', 'fromaddress', 'toaddress', 'ccaddress', 'bccaddress', 'reply_toaddress'])) {
                $headerArray[$key] = imap_utf8($value);
            } else {
                $headerArray[$key] = $value;
            }
        } else {
            $headerArray[$key] = $value;
        }
    }

    // 邮件日期通常需要额外处理成DateTime对象
    if (isset($headerArray['date'])) {
        try {
            $headerArray['parsed_date'] = new \DateTime($headerArray['date']);
        } catch (\Exception $e) {
            $headerArray['parsed_date'] = null; // 日期解析失败
        }
    }

    // 打印转换后的数组
    // echo '<pre class="brush:php;toolbar:false">';
    // print_r($headerArray);
    // echo '

imap_utf8

$obj->property

ImapProcessor

<?php

// src/Service/MailboxService.php
namespace App\Service;

use DateTime;
use Exception;

class MailboxService
{
    private string $hostname;
    private string $username;
    private string $password;
    private $inbox = null; // IMAP resource

    public function __construct(string $hostname, string $username, string $password)
    {
        $this->hostname = $hostname;
        $this->username = $username;
        $this->password = $password;
    }

    private function connect(): void
    {
        if ($this->inbox === null) {
            $this->inbox = imap_open($this->hostname, $this->username, $this->password);
            if (!$this->inbox) {
                throw new Exception('无法连接到邮箱: ' . imap_last_error());
            }
        }
    }

    private function disconnect(): void
    {
        if ($this->inbox !== null) {
            imap_close($this->inbox);
            $this->inbox = null;
        }
    }

    /**
     * 获取指定邮件ID的邮件头信息并转换为数组
     * @param int $messageId
     * @return array|null
     * @throws Exception
     */
    public function getMailHeadersAsArray(int $messageId): ?array
    {
        $this->connect(); // 确保连接已建立

        $headerInfo = imap_headerinfo($this->inbox, $messageId);
        if (!$headerInfo) {
            return null; // 邮件ID无效或获取失败
        }

        $headerArray = [];
        foreach ($headerInfo as $key => $value) {
            if (is_array($value) && !empty($value) && is_object($value[0])) {
                $processedValue = [];
                foreach ($value as $item) {
                    $processedValue[] = [
                        'personal' => isset($item->personal) ? (string) imap_utf8($item->personal) : null,
                        'mailbox' => isset($item->mailbox) ? (string) $item->mailbox : null,
                        'host' => isset($item->host) ? (string) $item->host : null,
                    ];
                }
                $headerArray[$key] = $processedValue;
            } elseif (is_string($value)) {
                if (in_array($key, ['subject', 'fromaddress', 'toaddress', 'ccaddress', 'bccaddress', 'reply_toaddress'])) {
                    $headerArray[$key] = imap_utf8($value);
                } else {
                    $headerArray[$key] = $value;
                }
            } else {
                $headerArray[$key] = $value;
            }
        }

        if (isset($headerArray['date'])) {
            try {
                $headerArray['parsed_date'] = new DateTime($headerArray['date']);
            } catch (Exception $e) {
                $headerArray['parsed_date'] = null;
            }
        }

        $this->disconnect(); // 操作完成后关闭连接
        return $headerArray;
    }

    /**
     * 获取所有邮件的ID列表
     * @return array
     * @throws Exception
     */
    public function getAllMailIds(): array
    {
        $this->connect();
        $emails = imap_search($this->inbox, 'ALL');
        $this->disconnect();
        return $emails ?: [];
    }

    // 你可以在这里添加更多方法，比如获取邮件体、附件等
}

config/services.yaml

config/packages/parameters.yaml

# config/services.yaml
services:
    App\Service\MailboxService:
        arguments:
            $hostname: '%env(IMAP_HOSTNAME)%'
            $username: '%env(IMAP_USERNAME)%'
            $password: '%env(IMAP_PASSWORD)%'

<?php
// src/Controller/MailController.php
namespace App\Controller;

use App\Service\MailboxService;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;

class MailController extends AbstractController
{
    #[Route('/mail/{id}', name: 'app_mail_show')]
    public function show(int $id, MailboxService $mailboxService): Response
    {
        try {
            $headers = $mailboxService->getMailHeadersAsArray($id);

            if (!$headers) {
                throw $this->createNotFoundException('邮件未找到或无法获取。');
            }

            // 现在你可以将 $headers 传递给Twig模板，或者作为JSON响应返回
            return $this->json($headers);

        } catch (\Exception $e) {
            return new Response('处理邮件时发生错误: ' . $e->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
        }
    }

    #[Route('/mails', name: 'app_mails_list')]
    public function list(MailboxService $mailboxService): Response
    {
        try {
            $mailIds = $mailboxService->getAllMailIds();
            $allHeaders = [];
            foreach ($mailIds as $id) {
                // 这里为了演示，每次都获取完整的头，实际应用中可能需要分页或只获取部分关键信息
                $allHeaders[] = $mailboxService->getMailHeadersAsArray($id);
            }
            return $this->json($allHeaders);
        } catch (\Exception $e) {
            return new Response('获取邮件列表时发生错误: ' . $e->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
        }
    }
}