323 lines
12 KiB
PHP
323 lines
12 KiB
PHP
<?php
|
|
|
|
namespace app\admin\controller;
|
|
|
|
use app\admin\model\MoneyLogHistory;
|
|
use app\admin\model\User;
|
|
use app\admin\model\UserMoneyLog;
|
|
use app\common\controller\Backend;
|
|
use app\admin\model\Bank;
|
|
use think\exception\ValidateException;
|
|
use think\facade\Db;
|
|
use think\facade\Request;
|
|
use Throwable;
|
|
|
|
class Dashboard extends Backend
|
|
{
|
|
/**
|
|
* @var object
|
|
* @phpstan-var Bank
|
|
*/
|
|
protected object $bank;
|
|
public function initialize(): void
|
|
{
|
|
parent::initialize();
|
|
$this->bank = new Bank();
|
|
}
|
|
|
|
public function index(): void
|
|
{
|
|
$rawStart = request()->param('start/s');
|
|
$start = $rawStart ? strtotime($rawStart) : strtotime('today');
|
|
$rawEnd = request()->param('end/s');
|
|
$end = $rawEnd ? strtotime("$rawEnd +1 day") : strtotime('tomorrow');
|
|
if ($start > $end) {
|
|
list($start, $end) = [$end, $start];
|
|
}
|
|
$bankList = Bank::field([
|
|
'id', 'bank_name', 'bank_account', 'current_balance', 'safe_alert', 'label_color', 'weigh',
|
|
// 子查询：入款总额
|
|
"(SELECT SUM(money/100) FROM ba_user_money_log WHERE bank_id = ba_bank.id AND type in (1,3) and create_time BETWEEN {$start} AND {$end}) AS total_fund_in",
|
|
// 子查询：出款总额
|
|
"(SELECT SUM(money/100) FROM ba_user_money_log WHERE bank_id = ba_bank.id AND type in (2,4) and create_time BETWEEN {$start} AND {$end}) AS total_fund_out",
|
|
// 子查询：入款次数
|
|
"(SELECT COUNT(*) FROM ba_user_money_log WHERE bank_id = ba_bank.id AND type in (1,3) and create_time BETWEEN {$start} AND {$end}) AS count_fund_in",
|
|
// 子查询：出款次数
|
|
"(SELECT COUNT(*) FROM ba_user_money_log WHERE bank_id = ba_bank.id AND type in (2,4) and create_time BETWEEN {$start} AND {$end}) AS count_fund_out",
|
|
])
|
|
->where('status', 1)
|
|
->order('weigh', 'desc')
|
|
->order('id', 'desc')
|
|
->select()
|
|
->toArray();
|
|
|
|
foreach ($bankList as &$bank) {
|
|
$bank['total_fund_in'] = (float)$bank['total_fund_in'];
|
|
$bank['total_fund_out'] = (float)$bank['total_fund_out'];
|
|
$bank['count_fund_in'] = (int)$bank['count_fund_in'];
|
|
$bank['count_fund_out'] = (int)$bank['count_fund_out'];
|
|
}
|
|
unset($bank);
|
|
$customer = Db::name('user_money_log')->field([
|
|
// 1. 总进款 (type = 1)
|
|
'ROUND(SUM(CASE WHEN type = 1 THEN money/100 ELSE 0 END), 2) AS total_deposit',
|
|
// 2. 总出款 (type = 2)
|
|
'ROUND(SUM(CASE WHEN type = 2 THEN money/100 ELSE 0 END), 2) AS total_withdraw',
|
|
// 3. 总进款次数 (type = 1 的记录总数)
|
|
'COUNT(CASE WHEN type = 1 THEN 1 END) AS count_deposit',
|
|
// 4. 总出款次数 (type = 2 的记录总数)
|
|
'COUNT(CASE WHEN type = 2 THEN 1 END) AS count_withdraw',
|
|
// 5. 活跃玩家数 (去重计算有多少个不同的 user_id 产生了流水)
|
|
'COUNT(DISTINCT user_id) AS active_player',
|
|
//6. 首次充值
|
|
'COUNT(CASE WHEN label = 1 THEN 1 END) AS first_deposit',
|
|
'ROUND(SUM(CASE WHEN label = 2 THEN money/100 ELSE 0 END), 2) AS unclaim_amount',
|
|
'COUNT(CASE WHEN label = 2 THEN 1 END) AS unclaim_receipt',
|
|
])
|
|
->whereBetweenTime('create_time', $start, $end)
|
|
->whereNull('created_by')
|
|
->find();
|
|
$customerData = [
|
|
'total_deposit' => (float)($customer['total_deposit'] ?? 0),
|
|
'total_withdraw' => (float)($customer['total_withdraw'] ?? 0),
|
|
'count_deposit' => (int)($customer['count_deposit'] ?? 0),
|
|
'count_withdraw' => (int)($customer['count_withdraw'] ?? 0),
|
|
'active_player' => (int)($customer['active_player'] ?? 0),
|
|
'first_deposit' => (int)($customer['first_deposit'] ?? 0),
|
|
'unclaim_amount' => (float)($customer['unclaim_amount'] ?? 0),
|
|
'unclaim_receipt' => (int)($customer['unclaim_receipt'] ?? 0),
|
|
];
|
|
$limit = request()->param('limit/d') ?? 15;
|
|
$bindFields = [
|
|
'user' => ['jk_username'],
|
|
'bank' => ['bank_name'],
|
|
'admin' => ['id', 'username'],
|
|
];
|
|
$transaction = UserMoneyLog::withJoin($bindFields, 'left')
|
|
->with([
|
|
'scoreLog' => function($query) {
|
|
$query->field(['money_log_id', 'game_type', 'score']);
|
|
}
|
|
])
|
|
->whereBetweenTime('user_money_log.create_time', $start, $end)
|
|
->order('id', 'desc')
|
|
->paginate($limit);
|
|
$transactionList = $transaction->items();
|
|
foreach ($transactionList as &$item) {
|
|
$item['user_name'] = $item['user']['jk_username'] ?? '';
|
|
$item['bank_name'] = $item['bank']['bank_name'] ?? '';
|
|
$item['created_by'] = $item['admin']['username'] ?? 'WEBHOOK';
|
|
unset($item['user'], $item['bank'], $item['admin']);
|
|
}
|
|
unset($item);
|
|
$transactionTotal = Db::name('user_money_log')->field([
|
|
// 1. 总进款 (type = 1)
|
|
'ROUND(SUM(CASE WHEN type = 1 THEN money/100 ELSE 0 END), 2) AS total_fund_in',
|
|
// 2. 总出款 (type = 2)
|
|
'ROUND(SUM(CASE WHEN type = 2 THEN money/100 ELSE 0 END), 2) AS total_fund_out',
|
|
])
|
|
->whereBetweenTime('create_time', $start, $end)
|
|
->find();
|
|
$this->success('', [
|
|
'bank' => $bankList,
|
|
'customer' => $customerData,
|
|
'transaction'=> [
|
|
'list' => $transactionList,
|
|
'count' => $transaction->total(),
|
|
'current_page' => $transaction->currentPage(),
|
|
'last_page' => $transaction->lastPage(),
|
|
'total_deposit' => (float)($transactionTotal['total_fund_in'] ?? 0),
|
|
'total_withdraw' => (float)($transactionTotal['total_fund_out'] ?? 0),
|
|
],
|
|
]);
|
|
}
|
|
|
|
public function bankTransact(): void
|
|
{
|
|
$data = $this->request->post();
|
|
if (!$data) {
|
|
$this->error(__('Parameter %s can not be empty', ['']));
|
|
}
|
|
|
|
$money = isset($data['money']) ? (int)$data['money'] : 0;
|
|
$bankFromId = isset($data['bank_from']) ? (int)$data['bank_from'] : 0;
|
|
$bankToId = isset($data['bank_to']) ? (int)$data['bank_to'] : 0;
|
|
if ($money <= 0) {
|
|
$this->error(__('转账金额必须大于 0'));
|
|
}
|
|
if ($bankFromId === $bankToId) {
|
|
$this->error(__('转出银行和转入银行不能相同'));
|
|
}
|
|
$adminId = $this->auth->getInfo()['id'] ?? null;
|
|
\think\facade\Db::startTrans();
|
|
try {
|
|
$bankFrom = Bank::where('id', $bankFromId)->where('status', 1)->lock(true)->find();
|
|
if (!$bankFrom) {
|
|
throw new ValidateException('转出银行账户不存在或已被禁用');
|
|
}
|
|
if ($bankFrom->current_balance < $money) {
|
|
throw new ValidateException("转出银行【{$bankFrom->bank_name}】余额不足");
|
|
}
|
|
|
|
$bankTo = Bank::where('id', $bankToId)->where('status', 1)->lock(true)->find();
|
|
if (!$bankTo) {
|
|
throw new ValidateException('转入银行账户不存在或已被禁用');
|
|
}
|
|
|
|
// 5. 更新转出银行账户余额
|
|
$bankFrom->current_balance -= $money;
|
|
$bankFrom->save();
|
|
|
|
$logFrom = new UserMoneyLog();
|
|
$logFrom->save([
|
|
'user_id' => 0,
|
|
'money' => -$money,
|
|
'before' => $bankFrom->current_balance + $money,
|
|
'after' => $bankFrom->current_balance,
|
|
'type' => 4,
|
|
'bank_id' => $bankFromId,
|
|
'created_by' => $adminId,
|
|
'memo' => $data['remark'],
|
|
'category' => 2,
|
|
'create_time' => time()
|
|
]);
|
|
|
|
$bankTo->current_balance += $money;
|
|
$bankTo->save();
|
|
|
|
$logTo = new UserMoneyLog();
|
|
$logTo->save([
|
|
'user_id' => 0,
|
|
'money' => $money,
|
|
'before' => $bankTo->current_balance - $money,
|
|
'after' => $bankTo->current_balance,
|
|
'type' => 3,
|
|
'bank_id' => $bankToId,
|
|
'created_by' => $adminId,
|
|
'memo' => $data['remark'],
|
|
'category' => 2,
|
|
'create_time' => time()
|
|
]);
|
|
|
|
\think\facade\Db::commit();
|
|
$isCommitSuccess = true;
|
|
} catch (ValidateException $e) {
|
|
\think\facade\Db::rollback();
|
|
$this->error($e->getMessage());
|
|
} catch (Throwable $e) {
|
|
\think\facade\Db::rollback();
|
|
trace($e->getMessage(), 'error');
|
|
$this->error(__('No rows were added'));
|
|
}
|
|
if ($isCommitSuccess) {
|
|
$this->success(__('Added successfully'));
|
|
}
|
|
}
|
|
|
|
public function newTransact(): void
|
|
{
|
|
if ($this->request->isPost()) {
|
|
$data = $this->request->post();
|
|
if (!$data) {
|
|
$this->error(__('Parameter %s can not be empty', ['']));
|
|
}
|
|
$result = false;
|
|
$data = $this->excludeFields($data);
|
|
|
|
if ($data['type'] == 2) {
|
|
$data['money'] = -$data['money'];
|
|
}
|
|
$user_id = User::where('jk_username', $data['user_name'])->value('id');
|
|
if (!$user_id) {
|
|
$this->error(__("The user can't find it", ['']));
|
|
}
|
|
$data['user_id'] = $user_id;
|
|
$userMoneyLog = new UserMoneyLog();
|
|
$userMoneyLog->startTrans();
|
|
try {
|
|
$data['created_by'] = $this->auth->getInfo()['id'];
|
|
$result = $userMoneyLog->save($data);
|
|
$userMoneyLog->commit();
|
|
} catch (Throwable $e) {
|
|
$userMoneyLog->rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
if ($result !== false) {
|
|
$this->success(__('Added successfully'));
|
|
} else {
|
|
$this->error(__('No rows were added'));
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
public function logHistory($id): void
|
|
{
|
|
$bindFields = [
|
|
'admin' => ['id','username'],
|
|
];
|
|
$history = MoneyLogHistory::withJoin($bindFields, 'left')
|
|
->where('money_log_id', $id)
|
|
->select();
|
|
if (!empty($history)) {
|
|
foreach ($history as &$item) {
|
|
$item['admin_name'] = $item['admin']['username'] ?? '';
|
|
unset($item['admin']);
|
|
}
|
|
unset($item);
|
|
}
|
|
$this->success('', $history);
|
|
}
|
|
|
|
public function editTransact(): void
|
|
{
|
|
$userMoneyLog = new UserMoneyLog();
|
|
$pk = $userMoneyLog->getPk();
|
|
$id = $this->request->param($pk);
|
|
$row = $userMoneyLog->find($id);
|
|
if (!$row) {
|
|
$this->error(__('Record not found'));
|
|
}
|
|
|
|
if ($this->request->isPost()) {
|
|
$data = $this->request->post();
|
|
if (!$data) {
|
|
$this->error(__('Parameter %s can not be empty', ['']));
|
|
}
|
|
|
|
$result = false;
|
|
$userMoneyLog->startTrans();
|
|
try {
|
|
$result = $row->save($data);
|
|
$userMoneyLog->commit();
|
|
} catch (Throwable $e) {
|
|
$userMoneyLog->rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
if ($result !== false) {
|
|
$this->success(__('Update successful'));
|
|
} else {
|
|
$this->error(__('No rows updated'));
|
|
}
|
|
return;
|
|
}
|
|
$this->success('', [
|
|
'row' => $row
|
|
]);
|
|
}
|
|
|
|
public function delTransact($id): void
|
|
{
|
|
$result = false;
|
|
try {
|
|
$result = Db::table('ba_user_money_log')->delete($id);
|
|
} catch (Throwable $e) {
|
|
$this->error(__('%d records and files have been deleted', [1]) . $e->getMessage());
|
|
}
|
|
if ($result) {
|
|
$this->success(__('%d records and files have been deleted', [1]));
|
|
} else {
|
|
$this->error(__('No rows were deleted'));
|
|
}
|
|
}
|
|
} |