diff --git a/app/data/command/UserBalance.php b/app/data/command/UserAmount.php similarity index 71% rename from app/data/command/UserBalance.php rename to app/data/command/UserAmount.php index 0631bc542..55a9e24c7 100644 --- a/app/data/command/UserBalance.php +++ b/app/data/command/UserAmount.php @@ -3,23 +3,23 @@ namespace app\data\command; use app\data\service\UserBalanceService; -use app\data\service\UserUpgradeService; +use app\data\service\UserRebateService; use think\admin\Command; use think\admin\Exception; use think\console\Input; use think\console\Output; /** - * 用户余额重算处理 + * 用户余额及返利重算处理 * Class UserBalance * @package app\data\command */ -class UserBalance extends Command +class UserAmount extends Command { protected function configure() { - $this->setName('xdata:UserBalance'); - $this->setDescription('批量重新计算用户余额'); + $this->setName('xdata:UserAmount'); + $this->setDescription('批量重新计算余额返利'); } /** @@ -33,9 +33,10 @@ class UserBalance extends Command try { [$total, $count] = [$this->app->db->name('DataUser')->count(), 0]; 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']); UserBalanceService::instance()->amount($user['id']); - $this->queue->message($total, $count, "完成计算用户 [{$user['id']}] 的余额", 1); + $this->queue->message($total, $count, "完成计算用户 [{$user['id']}] 的余额和返利", 1); } } catch (\Exception $exception) { $this->queue->error($exception->getMessage()); diff --git a/app/data/controller/User.php b/app/data/controller/User.php index 6a2ce2f68..9ff2ad35c 100644 --- a/app/data/controller/User.php +++ b/app/data/controller/User.php @@ -38,9 +38,6 @@ class User extends Controller /** * 数据列表处理 * @param array $data - * @throws \think\db\exception\DataNotFoundException - * @throws \think\db\exception\DbException - * @throws \think\db\exception\ModelNotFoundException */ protected function _page_filter(array &$data) { @@ -48,6 +45,16 @@ class User extends Controller UserAdminService::instance()->buildByUid($data, 'pid1', 'from'); } + + /** + * 重新计算用户余额返利 + * @auth true + */ + public function sync() + { + $this->_queue('重新计算用户余额返利', 'xdata:UserAmount'); + } + /** * 修改用户状态 * @auth true diff --git a/app/data/sys.php b/app/data/sys.php index 397791bab..0c894ee74 100644 --- a/app/data/sys.php +++ b/app/data/sys.php @@ -1,7 +1,7 @@ request->isCli()) { Console::starting(function (Console $console) { $console->addCommand(OrderClear::class); - $console->addCommand(UserBalance::class); + $console->addCommand(UserAmount::class); $console->addCommand(UserUpgrade::class); $console->addCommand(UserTransfer::class); }); diff --git a/app/data/view/user/index.html b/app/data/view/user/index.html index a2b62ddc1..37a307e55 100644 --- a/app/data/view/user/index.html +++ b/app/data/view/user/index.html @@ -1,5 +1,11 @@ {extend name="../../admin/view/main"} +{block name="button"} + + + +{/block} + {block name="content"}