Symfony中满足条件时自动发送邮件失败问题求助

问题背景 #

在Symfony框架中尝试实现当条件满足时自动发送邮件，先后在CandidatureController的index方法和postUpdate实体事件监听器中编写逻辑，但均未正常运行。不确定是实现方法、条件判断逻辑问题，还是需要使用Messenger组件。

原控制器代码 #

class CandidatureController extends AbstractController
{
    #[Route('/candidature', name: 'app_candidature', methods: ['GET', 'POST'])]
    public function index(EntityManagerInterface $entityManager, ManagerRegistry $doctrine, Request $request, MailerInterface $mailer): Response
    {
        if ($this->getUser()->getIsApproved() == false or $this->getUser()->isIsVerified() == false) {
            throw $this->createAccessDeniedException('not approved');
        }
        $candidature = new Candidature();

        $candidatRepo = $doctrine->getRepository(ProfileCandidat::class,); // access to the repository of ProfileCandidat
        $candidatNom = $candidatRepo->findOneBy([
            'email_adress' => $this->getUser()->getEmail()
        ]);

        $annonce = $entityManager->getRepository(Annonce::class)->findOneBy([
            'id' => $request->get('id')
        ]);


        //dd($candidatNom->getNom()); // display the name of the specific ProfileCandidat with the id

        $candidature->setNom($candidatNom->getNom());    // set the name of the ProfileCandidat in the Candidature
        $candidature->setPrenom($candidatNom->getPrenom()); // set the lastname of the ProfileCandidat in the Candidature
        $candidature->setCv($candidatNom->getCV()); // set the cv of the ProfileCandidat in the Candidature
        $candidature->setAnnonce($annonce); // set the annonce_id in the Candidature

        $entityManager->persist($candidature);
        $entityManager->flush();

        if ($candidature->getIsVerified() == true) {
            $email = (new Email())
                ->from('trtconseilexample@gmail.com')
                ->to($annonce->getEmail())
                ->subject('Vous avez un nouveau candidat !')
                ->text("{$candidature->getNom()} {$candidature->getPrenom()} a postulé à votre annonce, vous trouverez son CV en pièce jointe !")
                ->attachFromPath("public/uploads/images/{$candidature->getCv()}");
            ;
            $mailer->send($email);
        }

        return $this->redirectToRoute('app_annonce_index', [], Response::HTTP_SEE_OTHER);
    }

}

原事件监听器代码 #

class MailEvent
{
// the entity listener methods receive two arguments:
// the entity instance and the lifecycle event
public function postUpdate(Candidature $candidature, Annonce 
$annonce, MailerInterface $mailer, LifecycleEventArgs $event): void
{
    $change = $event->getEntityChangeSet();

    if ($change instanceof Candidature and $candidature->getIsVerified()) {
        $email = (new Email())
            ->from('trtconseilexample@gmail.com')
            ->to($annonce->getEmail())
            ->subject('Vous avez un nouveau candidat !')
            ->text("{$candidature->getNom()} {$candidature->getPrenom()} a postulé à votre annonce, vous trouverez son CV en pièce jointe !")
            ->attachFromPath("public/uploads/images/{$candidature->getCv()}");
        ;
        $mailer->send($email);
    }
}

问题分析 #

控制器代码核心问题 #

1. 条件判断逻辑错误：新创建的Candidature实体，isVerified属性默认值为false，导致if ($candidature->getIsVerified() == true)永远不会触发邮件发送。
2. 潜在空指针风险：$candidatNom和$annonce查询结果可能为null，未做判空处理会导致后续方法调用报错。
3. 文件路径不规范：硬编码相对路径public/uploads/images/，建议使用Symfony内置参数拼接绝对路径。
4. 依赖冗余：同时注入EntityManagerInterface和ManagerRegistry，只需保留其中一个即可。

事件监听器核心问题 #

1. 方法参数错误：实体生命周期监听器的postUpdate方法仅支持两个参数（实体实例+LifecycleEventArgs），直接注入Annonce和MailerInterface会导致监听器无法触发。
2. 变更集判断错误：$event->getEntityChangeSet()返回的是字段变更数组，$change instanceof Candidature永远为false，条件不成立。
3. 关联对象获取错误：应从$candidature的关联属性中获取Annonce，而非直接注入。

正确实现方案 #

方案一：修正控制器逻辑（适用于验证Candidature时发送邮件） #

如果需求是当Candidature被标记为已验证时发送邮件，逻辑应放在审核操作中：

class CandidatureController extends AbstractController
{
    #[Route('/candidature/{id}/verify', name: 'app_candidature_verify', methods: ['POST'])]
    public function verify(Candidature $candidature, MailerInterface $mailer, EntityManagerInterface $entityManager): Response
    {
        if (!$this->isGranted('ROLE_ADMIN')) {
            throw $this->createAccessDeniedException();
        }

        $candidature->setIsVerified(true);
        $entityManager->flush();

        $annonce = $candidature->getAnnonce();
        if (!$annonce) {
            return $this->redirectToRoute('app_candidature_index');
        }

        $email = (new Email())
            ->from('trtconseilexample@gmail.com')
            ->to($annonce->getEmail())
            ->subject('Vous avez un nouveau candidat !')
            ->text("{$candidature->getNom()} {$candidature->getPrenom()} a postulé à votre annonce, vous trouverez son CV en pièce jointe !")
            ->attachFromPath($this->getParameter('kernel.project_dir') . '/public/uploads/images/' . $candidature->getCv());

        $mailer->send($email);

        return $this->redirectToRoute('app_candidature_index');
    }
}

方案二：修正实体事件监听器（自动监听状态变更） #

1. 注册监听器：在config/services.yaml中添加配置

services:
    App\EventListener\MailEvent:
        tags:
            - { name: doctrine.orm.entity_listener, entity: App\Entity\Candidature, event: postUpdate }

2. 修正监听器代码

namespace App\EventListener;

use App\Entity\Candidature;
use Doctrine\ORM\Event\LifecycleEventArgs;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Mime\Email;

class MailEvent
{
    private $mailer;

    public function __construct(MailerInterface $mailer)
    {
        $this->mailer = $mailer;
    }

    public function postUpdate(Candidature $candidature, LifecycleEventArgs $event): void
    {
        $entityManager = $event->getEntityManager();
        $changeSet = $entityManager->getUnitOfWork()->getEntityChangeSet($candidature);

        // 检查isVerified是否从false变为true
        if (!isset($changeSet['isVerified']) || $changeSet['isVerified'][0] !== false || $changeSet['isVerified'][1] !== true) {
            return;
        }

        $annonce = $candidature->getAnnonce();
        if (!$annonce) {
            return;
        }

        $projectDir = $entityManager->getConfiguration()->getContainer()->getParameter('kernel.project_dir');
        $email = (new Email())
            ->from('trtconseilexample@gmail.com')
            ->to($annonce->getEmail())
            ->subject('Vous avez un nouveau candidat !')
            ->text("{$candidature->getNom()} {$candidature->getPrenom()} a postulé à votre annonce, vous trouverez son CV en pièce jointe !")
            ->attachFromPath($projectDir . '/public/uploads/images/' . $candidature->getCv());

        $this->mailer->send($email);
    }
}

方案三：使用Messenger组件异步发送邮件（推荐） #

避免邮件发送阻塞请求，用异步队列处理：

1. 创建消息类

namespace App\Message;

class SendCandidatureNotificationEmail
{
    private $candidatureId;

    public function __construct(int $candidatureId)
    {
        $this->candidatureId = $candidatureId;
    }

    public function getCandidatureId(): int
    {
        return $this->candidatureId;
    }
}

2. 创建消息处理器

namespace App\MessageHandler;

use App\Entity\Candidature;
use App\Message\SendCandidatureNotificationEmail;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
use Symfony\Component\Mime\Email;

#[AsMessageHandler]
class SendCandidatureNotificationEmailHandler
{
    private $entityManager;
    private $mailer;

    public function __construct(EntityManagerInterface $entityManager, MailerInterface $mailer)
    {
        $this->entityManager = $entityManager;
        $this->mailer = $mailer;
    }

    public function __invoke(SendCandidatureNotificationEmail $message)
    {
        $candidature = $this->entityManager->getRepository(Candidature::class)->find($message->getCandidatureId());
        if (!$candidature || !$candidature->getIsVerified()) {
            return;
        }

        $annonce = $candidature->getAnnonce();
        if (!$annonce) {
            return;
        }

        $projectDir = $this->entityManager->getConfiguration()->getContainer()->getParameter('kernel.project_dir');
        $email = (new Email())
            ->from('trtconseilexample@gmail.com')
            ->to($annonce->getEmail())
            ->subject('Vous avez un nouveau candidat !')
            ->text("{$candidature->getNom()} {$candidature->getPrenom()} a postulé à votre annonce, vous trouverez son CV en pièce jointe !")
            ->attachFromPath($projectDir . '/public/uploads/images/' . $candidature->getCv());

        $this->mailer->send($email);
    }
}

3. 触发异步消息
   在控制器验证方法中添加：

use Symfony\Component\Messenger\MessageBusInterface;
use App\Message\SendCandidatureNotificationEmail;

public function verify(Candidature $candidature, EntityManagerInterface $entityManager, MessageBusInterface $bus): Response
{
    $candidature->setIsVerified(true);
    $entityManager->flush();

    $bus->dispatch(new SendCandidatureNotificationEmail($candidature->getId()));

    return $this->redirectToRoute('app_candidature_index');
}

内容的提问来源于stack exchange，提问作者Epson184