6
0
Fork 0
base
panliang 2022-09-21 11:32:24 +08:00
parent 80d4bc43c5
commit 5751de28b2
1 changed files with 12 additions and 10 deletions

View File

@ -67,17 +67,19 @@ class OrderProfitCommand extends Command
OrderProfit::whereIn('order_id', $orders->pluck('id'))->where('status', 0)->update(['status' => 4]); OrderProfit::whereIn('order_id', $orders->pluck('id'))->where('status', 0)->update(['status' => 4]);
// 获取 等待结算 的提成记录, 按照 user_id 分组 // 获取 等待结算 的提成记录, 按照 user_id 分组
$list = OrderProfit::where('status', 4)->whereIn('order_id', $orders->pluck('id'))->get()->groupBy('user_id'); OrderProfit::where('status', 4)->chunk(50, function ($list) use ($service) {
foreach($list as $id => $items) { $list = $list->groupBy('user_id');
try { foreach($list as $id => $items) {
DB::beginTransaction(); try {
$service->wechatTransfers($items); DB::beginTransaction();
DB::commit(); $service->wechatTransfers($items);
} catch (\Exception $e) { DB::commit();
DB::rollBack(); } catch (\Exception $e) {
$this->error($e->getMessage()); DB::rollBack();
$this->error($e->getMessage());
}
} }
} });
// 没有待付款的提成记录 // 没有待付款的提成记录
foreach($orders as $item) { foreach($orders as $item) {