如何实现Cron任务在邮件发送完成后停止并次日重启？

这个场景我之前也遇到过——批量任务跑完后Cron还在空跑，既浪费资源又没必要。结合你的需求，我给你几个实用的方案，从简单到灵活都有：

方案1：用控制文件实现启停（最简单） #

核心思路是用一个文件作为"开关"：脚本执行前先检查开关是否存在，存在就直接退出；当所有邮件发完时创建这个开关文件，再用一个每日Cron任务在凌晨删除开关，让任务次日重新启动。

步骤1：修改邮件发送脚本 #

<?php
// 连接数据库（这里假设你已经有$conn连接）
// ...

// 定义开关文件路径（选一个脚本有读写权限的目录）
$stopSwitch = '/var/run/stop_email_batch';

// 先检查是否需要停止执行
if (file_exists($stopSwitch)) {
    exit; // 直接退出，不做任何操作
}

// 获取上次记录的last_id，处理初始为NULL的情况
$lastIdQuery = mysqli_query($conn, "SELECT `id` FROM `last_id` LIMIT 1");
$lastIdRow = mysqli_fetch_assoc($lastIdQuery);
$last_id = $lastIdRow['id'] ?? 0; // 如果是NULL，就从id=0开始

// 安全查询下一批订阅者（用预处理防止SQL注入！）
$stmt = mysqli_prepare($conn, "SELECT * FROM `subscribers` WHERE `id` > ? LIMIT 200");
mysqli_stmt_bind_param($stmt, "i", $last_id);
mysqli_stmt_execute($stmt);
$result = mysqli_stmt_get_result($stmt);
$subscribers = mysqli_fetch_all($result, MYSQLI_ASSOC);

if (empty($subscribers)) {
    // 没有更多订阅者了：创建停止开关 + 重置last_id
    file_put_contents($stopSwitch, '');
    mysqli_query($conn, "UPDATE `last_id` SET `id` = NULL");
    exit;
}

// 执行发送邮件的逻辑
// ...（你的邮件发送代码）

// 更新last_id为当前批次的最后一个ID
$lastSubscriber = end($subscribers);
$new_last_id = $lastSubscriber['id'];
mysqli_query($conn, "UPDATE `last_id` SET `id` = " . intval($new_last_id));
?>

步骤2：添加每日重置的Cron任务 #

登录服务器，运行crontab -e添加以下任务（每天凌晨0点删除开关文件）：

0 0 * * * rm -f /var/run/stop_email_batch

方案2：用数据库状态字段控制（更灵活） #

如果不想依赖文件系统，可以扩展你的last_id表，增加一个状态字段来标记任务是否完成，再用每日Cron重置状态。

步骤1：修改数据库表 #

先给last_id表新增一个状态字段：

ALTER TABLE `last_id` ADD COLUMN `is_completed` BOOLEAN NOT NULL DEFAULT 0;

步骤2：修改邮件发送脚本 #

<?php
// 连接数据库
// ...

// 检查任务是否已完成
$statusQuery = mysqli_query($conn, "SELECT `id`, `is_completed` FROM `last_id` LIMIT 1");
$statusRow = mysqli_fetch_assoc($statusQuery);
$last_id = $statusRow['id'] ?? 0;
$isCompleted = $statusRow['is_completed'];

if ($isCompleted) {
    exit; // 任务已完成，直接退出
}

// 查询下一批订阅者（同样用预处理防注入）
$stmt = mysqli_prepare($conn, "SELECT * FROM `subscribers` WHERE `id` > ? LIMIT 200");
mysqli_stmt_bind_param($stmt, "i", $last_id);
mysqli_stmt_execute($stmt);
$result = mysqli_stmt_get_result($stmt);
$subscribers = mysqli_fetch_all($result, MYSQLI_ASSOC);

if (empty($subscribers)) {
    // 标记任务为完成，同时重置last_id
    mysqli_query($conn, "UPDATE `last_id` SET `is_completed` = 1, `id` = NULL");
    exit;
}

// 发送邮件逻辑
// ...

// 更新last_id
$new_last_id = end($subscribers)['id'];
mysqli_query($conn, "UPDATE `last_id` SET `id` = " . intval($new_last_id));
?>

步骤3：添加每日重置状态的Cron任务 #

运行crontab -e添加以下任务（每天凌晨0点重置状态）：

0 0 * * * mysql -u 你的数据库用户名 -p'你的数据库密码' 你的数据库名 -e "UPDATE last_id SET is_completed = 0, id = NULL;"

重要注意事项 #

• SQL注入防护：一定要用预处理语句（像上面代码那样），不要直接把变量拼进SQL里，避免被攻击。
• 权限问题：脚本需要有读写开关文件的权限（方案1），或者Cron任务需要有执行MySQL命令的权限（方案2）。
• 初始状态处理：第一次执行时last_id是NULL，一定要处理成0，否则WHERE id > NULL会返回空结果，导致任务直接标记完成。

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