本文介绍在 magento 1.9 中通过 cron 任务精准触发单次邮件发送的实践方案，解决因订单集合重复遍历导致的同一客户收到多封重复邮件的问题，并提供安全、可维护的代码实现。
本文介绍在 magento 1.9 中通过 cron 任务精准触发单次邮件发送的实践方案，解决因订单集合重复遍历导致的同一客户收到多封重复邮件的问题，并提供安全、可维护的代码实现。
在 Magento 1.9 的自定义模块中，常通过定时 Cron 任务检测“订单完成 15–20 分钟内”的订单并发送售后提醒邮件。但原始实现中直接遍历 sales/order_item_collection 并对每个订单项调用邮件发送逻辑，极易引发重复发送——尤其当一个订单含多个商品（即多条 order_item 记录）时，foreach 会为同一订单 ID 触发多次邮件。
更可靠的做法是：确保每个订单仅触发一次邮件，且避免跨订单重复执行。以下为优化后的核心逻辑：
public function customcrontask()
{
$now = time();
// 定义时间窗口：15–20 分钟前（即 900–1200 秒前）
$toTime = $now - 900; // 15 分钟前
$fromTime = $now - 1200; // 20 分钟前（注意：M1 时间过滤 'from' <= created_at <= 'to'）
$to = date('Y-m-d H:i:s', $toTime);
$from = date('Y-m-d H:i:s', $fromTime);
// 关键改进：基于 sales/order_collection 过滤，而非 order_item
// 避免因 item 多对一导致的重复触发
$orders = Mage::getResourceModel('sales/order_collection')
->addAttributeToSelect('entity_id')
->addAttributeToSelect('increment_id')
->addAttributeToSelect('customer_email')
->addAttributeToFilter('status', 'complete') // 确保只处理已完成订单
->addAttributeToFilter('created_at', array('from' => $from, 'to' => $to))
->setPageSize(1) // 严格限制最多处理 1 个订单，防并发冲突
->setCurPage(1)
->load();
if ($orders->count() > 0) {
$order = $orders->getFirstItem();
$customerId = $order->getCustomerId();
$customerEmail = $order->getCustomerEmail();
$incrementId = $order->getIncrementId();
// 构建邮件变量
$vars = array(
'order_id' => $incrementId,
'customer_name' => $order->getCustomerName(),
);
$template = 'your_custom_email_template'; // 替换为实际模板标识
$sender = array('name' => 'Your Store', 'email' => 'no-reply@yoursite.com');
try {
Mage::getModel('core/email_template')
->sendTransactional($template, $sender, $customerEmail, null, $vars, Mage::app()->getStore()->getId());
// 【重要】记录已处理状态（推荐写入自定义日志表或使用 order comment 标记）
$order->addStatusHistoryComment("Auto-sent post-completion email at " . date('Y-m-d H:i:s'))
->setIsCustomerNotified(true)
->save();
} catch (Exception $e) {
Mage::logException($e);
}
}
}✅ 关键优化点说明：
- 改用 sales/order_collection：直接按订单维度筛选，彻底规避 order_item 多行引发的重复；
- 添加 status = 'complete' 过滤：确保仅处理真正完成的订单，防止状态未同步导致误发；
- setPageSize(1) + getFirstItem()：强制单次任务最多处理一个订单，既防重复又利于后续扩展幂等控制；
- 写入订单备注（addStatusHistoryComment）：作为业务侧“已发送”标记，便于排查与审计；
- 异常捕获与日志记录：保障 Cron 崩溃不中断后续调度，同时留存错误线索。
⚠️ 注意事项：
- 若需支持多订单批量发送（如每日汇总），应引入独立的状态字段（如 email_sent_at）并配合数据库 UPDATE ... WHERE email_sent_at IS NULL 实现原子更新；
- 生产环境务必启用 Cron 锁机制（如 cron_lock 表），防止同一任务被多个进程并发执行；
- 邮件模板需在后台启用并配置正确，否则 sendTransactional() 将静默失败。
通过以上重构，您将获得稳定、可追溯、符合 Magento 最佳实践的延迟邮件通知能力。
