hyperf 多条件批量修改的核心是拆解封装条件逻辑、复用查询构造器与策略模式，并通过协程、连接池、事务保障性能与一致性；需校验边界、处理空值、记录快照。
Hyperf 实现多条件判断的复杂业务数据批量修改，核心不是靠“一次写死多个 where”，而是把条件逻辑拆解、封装、可复用，并借助协程与数据库连接池提升吞吐。关键在于避免手写冗长 SQL 或硬编码 if-else 堆叠，而是用查询构造器 + 策略模式 + 事务控制来组织逻辑。
用 QueryBuilder 组合动态条件
Hyperf 的 Db::table() 支持链式调用，适合构建运行时决定的 where 条件。比如根据运营标签、时间范围、状态组合更新库存预警标记：
- 先初始化查询：$query = Db::table('orders');
- 按需追加条件：
if ($request->has('status')) $query->where('status', $request->input('status'));
if ($request->filled('created_after')) $query->where('created_at', '>=', $request->input('created_after'));
if (!empty($tags)) $query->whereIn('tag_id', $tags); - 最后执行更新：
$affected = $query->update(['is_high_risk' => 1]);
用 updateOrInsert 处理“存在则改、不存在则补”的场景
当批量操作涉及“查+改/插”二选一时，updateOrInsert 比手动 firstOrCreate + save 更高效。但要注意默认值问题——它不会自动读取数据库字段的 DEFAULT 定义：
- 显式补全必要字段：
Db::table('user_profiles')->updateOrInsert(
['user_id' => $uid],
[
'nickname' => $nick,
'status' => 1,
'updated_at' => now(),
'created_at' => now() // 即使是 INSERT 也得带上
]
); - 对 timestamp 或 enum 字段，不依赖 DB 默认值，统一在 PHP 层赋值，避免插入失败或字段为空。
用事务包裹跨表批量更新
涉及订单、库存、积分三张表联动更新时，必须用事务保证原子性。Hyperf 的协程事务支持 Db::transaction()，且不会阻塞其他协程：
- 把整个批量逻辑包进闭包：
Db::transaction(function () use ($orderIds, $newStatus) {
$orders = Db::table('orders')->whereIn('id', $orderIds)->get();
foreach ($orders as $order) {
Db::table('stocks')->where('sku', $order->sku)->decrement('quantity', $order->qty);
Db::table('points_log')->insert(['user_id' => $order->user_id, 'amount' => $order->point_bonus]);
}
Db::table('orders')->whereIn('id', $orderIds)->update(['status' => $newStatus]);
}); - 若某条子操作失败（如库存不足），整个事务回滚，无残留脏数据。
用协程并发处理独立批次
当要更新上万条记录，且每条更新逻辑彼此无关（比如给不同用户发通知状态），可用 Co::parallel() 分片并发：
- 把 ID 列表切分成每 200 条一组；
- 每个协程处理一个分片：
Co::parallel(array_map(function ($chunk) {
return function () use ($chunk) {
Db::table('notifications')->whereIn('id', $chunk)->update(['sent' => 1, 'sent_at' => now()]);
};
}, $chunks)); - 注意控制并发数（如最多 10 个协程），避免压垮数据库连接池。
不复杂但容易忽略：多条件批量更新真正难的不是语法，而是条件组合的边界校验、空值处理、以及更新前后的一致性快照。建议每次批量任务都记录影响行数和关键参数，方便出问题时回溯。
