Update UserAmount.php

This commit is contained in:
邹景立 2021-03-18 18:52:01 +08:00
parent bcc0f7156f
commit 3aeee0be2d

View File

@ -33,10 +33,10 @@ class UserAmount extends Command
try { try {
[$total, $count] = [$this->app->db->name('DataUser')->count(), 0]; [$total, $count] = [$this->app->db->name('DataUser')->count(), 0];
foreach ($this->app->db->name('DataUser')->field('id')->cursor() as $user) { foreach ($this->app->db->name('DataUser')->field('id')->cursor() as $user) {
$this->queue->message($total, ++$count, "正在计算用户 [{$user['id']}] 的余额返利"); $this->queue->message($total, ++$count, "正在计算用户 [{$user['id']}] 的余额返利");
UserRebateService::instance()->amount($user['id']); UserRebateService::instance()->amount($user['id']);
UserBalanceService::instance()->amount($user['id']); UserBalanceService::instance()->amount($user['id']);
$this->queue->message($total, $count, "完成计算用户 [{$user['id']}] 的余额返利", 1); $this->queue->message($total, $count, "完成计算用户 [{$user['id']}] 的余额返利", 1);
} }
} catch (\Exception $exception) { } catch (\Exception $exception) {
$this->queue->error($exception->getMessage()); $this->queue->error($exception->getMessage());