Laravel定时任务幂等性可通过四种方法实现：一、数据库唯一约束配合INSERT IGNORE或ON DUPLICATE KEY UPDATE；二、状态标记+SELECT FOR UPDATE事务校验；三、Redis分布式锁前置守卫；四、任务执行记录表UPSERT校验事务。
如果Laravel定时任务在重复触发时产生重复数据或状态冲突，则可能是由于任务缺乏幂等性保障。事务本身不直接提供幂等性，但可配合唯一约束、状态标记与数据库锁等机制，在事务边界内确保关键操作的原子性与一致性。以下是实现定时任务幂等执行的多种方法：
一、使用数据库唯一约束配合INSERT IGNORE或ON DUPLICATE KEY UPDATE
该方法利用数据库层面的唯一索引强制拦截重复插入，事务仅包裹写入逻辑，失败时自动回滚，避免部分写入。适用于需生成唯一记录（如日志、快照、统计条目）的场景。
1、在目标数据表中添加业务唯一索引，例如联合索引 (`task_name`, `exec_date`) 或基于任务标识的哈希字段 `task_signature`。
2、在Artisan命令或调度闭包中开启事务：DB::transaction(function () { ... });
3、执行带冲突处理的插入：DB::insert('INSERT INTO task_logs (task_name, exec_date, status) VALUES (?, ?, ?) ON DUPLICATE KEY UPDATE status = VALUES(status)', [$name, $date, 'processed']);
二、采用“状态标记+SELECT FOR UPDATE”事务校验
该方法先查询任务当前是否已执行，若未执行则加行锁并更新状态，整个过程在事务中完成，防止并发重复执行。适用于需严格控制单次运行结果的状态型任务。
1、为任务记录表添加状态字段 `status ENUM('pending', 'running', 'completed', 'failed') DEFAULT 'pending' 及唯一任务标识字段 `task_key`。
2、在调度逻辑中执行带锁查询与条件更新：DB::transaction(function () use ($taskKey) { $row = DB::table('task_locks')->where('task_key', $taskKey)->where('status', 'pending')->lockForUpdate()->first(); if (!$row) { return; } DB::table('task_locks')->where('id', $row->id)->update(['status' => 'running', 'started_at' => now()]); });
3、任务主体执行完毕后，再次事务内更新最终状态为 'completed' 或 'failed'。
三、使用Redis分布式锁作为事务外前置守卫
该方法不依赖数据库事务，而是借助Redis原子操作（如SETNX）抢占执行权，成功获取锁才进入后续数据库事务。适合高并发、多服务器部署下避免竞态，且将幂等判断前置到最外层。
1、在调度任务开始前生成确定性锁键，例如 "schedule:{$taskName}:".date('Y-m-d')。
2、调用 Redis::set($lockKey, $value, 'EX', 3600, 'NX') 获取锁；若返回null，说明已被占用，直接退出。
3、获取锁成功后，立即开启数据库事务执行核心逻辑，并在事务提交后异步释放锁（或依赖过期自动清理）。
四、基于任务执行记录表的UPSERT校验事务
该方法显式维护一张任务执行登记表，每次运行前尝试插入带时间戳的执行记录，依靠唯一约束拒绝重复，再根据插入结果决定是否执行主逻辑。所有操作均包裹于同一事务中，保证登记与执行的一致性。
1、创建执行记录表，含复合唯一键 (`task_name`, `run_date`)，字段包括 id, task_name, run_date, started_at, finished_at, status。
2、事务内执行插入并捕获唯一冲突异常：try { DB::table('task_runs')->insert(['task_name' => $name, 'run_date' => $date, 'started_at' => now(), 'status' => 'started']); } catch (\Illuminate\Database\QueryException $e) { if ($e->getCode() === '23000') { return; } throw $e; }
3、插入成功后继续执行业务逻辑，并在结束时更新该记录的 finished_at 和 status 字段。
