blackteay/ThinkAdmin
1
0
Fork 0
mirror of https://gitee.com/zoujingli/ThinkAdmin.git synced 2025-04-06 03:58:04 +08:00
Code Issues Projects Releases Wiki Activity

修改返利

Browse Source
This commit is contained in:
邹景立 2021-03-15 16:03:49 +08:00
parent b113a89eb6
commit 4aea1b91ce
4 changed files with 54 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
app/data/controller/api/auth/Balance.php
View File

@ -3,9 +3,6 @@
namespace app\data\controller\api\auth;
use app\data\controller\api\Auth;
use app\data\service\UserUpgradeService;
use app\data\service\UserService;
use think\admin\extend\CodeExtend;
/**
* 用户余额转账
@ -18,10 +15,10 @@ class Balance extends Auth
* 绑定数据表
* @var string
*/
private $table = 'DataUserBalanceTransfer';
private $table = 'DataUserBalance';
/**
* 获取用户转账记录
* 获取用户余额记录
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
@ -29,47 +26,8 @@ class Balance extends Auth
public function get()
{
$query = $this->_query($this->table);
$query->where(['uid|from' => $this->uuid, 'deleted' => 0]);
$result = $query->order('id desc')->page(true, false, false, 15);
if (count($result['list']) > 0) {
UserService::instance()->buildByUid($result['list'], 'uid', 'selfer');
UserService::instance()->buildByUid($result['list'], 'pid1', 'fromer');
}
$query->where(['uid' => $this->uuid, 'deleted' => 0]);
$result = $query->like('create_at#date')->order('id desc')->page(true, false, false, 15);
$this->success('获取数据成功', $result);
}
/**
* 创建余额转账申请
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function add()
{
$data = $this->_vali([
'from.value' => $this->uuid,
'code.value' => CodeExtend::uniqidDate(18, 'T'),
'uid.require' => '用户不能为空！',
'name.default' => '用户余额转账',
'amount.require' => '金额不能为空！',
]);
if ($data['uid'] == $this->uuid) {
$this->error('不能给自己转账！');
}
// 检测目标用户状态
$map = ['id' => $data['uid'], 'deleted' => 0];
$user = $this->app->db->name('DataUser')->where($map)->find();
if (empty($user)) $this->error('目标用户不存在！');
// 检测余额否有足够
[$total, $count] = UserUpgradeService::instance()->balance($this->uuid);
if ($data['amount'] > $total - $count) $this->error('可转账余额不足！');
// 写入余额转账记录
if ($this->app->db->name($this->table)->insert($data) !== false) {
UserUpgradeService::instance()->balance($data['uid']);
UserUpgradeService::instance()->balance($data['from']);
$this->success('余额转账成功！');
} else {
$this->error('余额转账失败！');
}
}
}

32
app/data/controller/api/auth/Rebate.php Normal file
View File

@ -0,0 +1,32 @@
<?php
namespace app\data\controller\api\auth;
use app\data\controller\api\Auth;
/**
* 用户返利管理
* Class Rebate
* @package app\data\controller\api\auth
*/
class Rebate extends Auth
{
/**
* 绑定数据表
* @var string
*/
private $table = 'DataUserRebate';
/**
* 获取用户返利记录
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function get()
{
$map = ['uid' => $this->uuid];
$query = $this->_query($this->table)->where($map);
$query->like('create_at#date')->order('id desc')->page(true, false, false, 15);
}
}

15
app/data/service/UserUpgradeService.php
View File

@ -21,16 +21,17 @@ class UserUpgradeService extends Service
*/
public function balance(int $uuid, array $nots = []): array
{
$total = $this->app->db->name('DataUserBalance')->where(['uid' => $uuid, 'deleted' => 0])->sum('amount');
$total += $this->app->db->name('DataUserBalanceTransfer')->where(['uid' => $uuid, 'deleted' => 0])->sum('amount');
$count = $this->app->db->name('DataUserBalanceTransfer')->where(['from' => $uuid, 'deleted' => 0])->sum('amount');
$total = abs($this->app->db->name('DataUserBalance')->where("uid='{$uuid}' and status=1 and amount>0 and deleted=0")->sum('amount'));
$count = abs($this->app->db->name('DataUserBalance')->where("uid='{$uuid}' and status=1 and amount<0 and deleted=0")->sum('amount'));
$locks = abs($this->app->db->name('DataUserBalance')->where("uid='{$uuid}' and status=0 and amount>0 and deleted=0")->sum('amount'));
if (empty($nots)) {
$count += $this->app->db->name('ShopOrder')->whereRaw("uid={$uuid} and status>1")->sum('payment_balance');
$this->app->db->name('DataUser')->where(['id' => $uuid])->update(['balance_total' => $total, 'balance_used' => $count]);
$this->app->db->name('DataUser')->where(['id' => $uuid])->update([
'balance_total' => $total, 'balance_used' => $count, 'balance_lock' => $locks,
]);
} else {
$count += $this->app->db->name('ShopOrder')->whereRaw("uid={$uuid} and status>1")->whereNotIn('order_no', $nots)->sum('payment_balance');
$count -= $this->app->db->name('DataUserBalance')->whereRaw("uid={$uuid}")->whereIn('code', $nots)->sum('amount');
}
return [$total, $count];
return [$total, $count, $locks];
}
/**

12
app/data/service/payment/BalancePyamentService.php
View File

@ -56,9 +56,17 @@ class BalancePyamentService extends PaymentService
// 创建支付行为
$this->createPaymentAction($orderNo, $paymentTitle, $paymentAmount);
// 扣减用户余额
[$total, $used] = UserUpgradeService::instance()->balance($order['uid'], [$orderNo]);
if ($paymentAmount > $total - $used) throw new Exception("可抵扣余额不足");
[$total, $count] = UserUpgradeService::instance()->balance($order['uid'], [$orderNo]);
if ($paymentAmount > $total - $count) throw new Exception("可抵扣余额不足");
$this->app->db->name('ShopOrder')->where(['order_no' => $orderNo])->update(['payment_balance' => $paymentAmount]);
// 扣除余额金额
data_save('DataUserBalance', [
'uid' => $order['uid'],
'code' => $order['order_no'],
'name' => "订单余额支付",
'remark' => "使用余额支付订单{$order['order_no']}金额{$paymentAmount}元",
'amount' => -$paymentAmount,
], 'code');
// 更新支付行为
$this->updatePaymentAction($orderNo, CodeExtend::uniqidDate(20), $paymentAmount, '账户余额支付');
// 刷新用户余额