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-11 18:28:45 +08:00
parent 2173fed1c6
commit 161da9e1ff
9 changed files with 91 additions and 78 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/data/command/UserUpgrade.php
View File

@ -2,7 +2,7 @@
namespace app\data\command;
use app\data\service\UserService;
use app\data\service\UpgradeService;
use think\admin\Command;
use think\admin\Exception;
use think\console\Input;
@ -33,7 +33,7 @@ class UserUpgrade extends Command
[$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']}] 的等级");
UserService::instance()->syncLevel($user['id']);
UpgradeService::instance()->syncLevel($user['id']);
$this->queue->message($total, $count, "完成计算用户 [{$user['id']}] 的等级", 1);
}
} catch (\Exception $exception) {

2
app/data/controller/ShopOrder.php
View File

@ -86,7 +86,7 @@ class ShopOrder extends Controller
{
UserService::instance()->buildByUid($data);
UserService::instance()->buildByUid($data, 'puid1', 'fromer');
OrderService::instance()->buildOrderData($data);
OrderService::instance()->buildData($data);
foreach ($data as &$vo) $vo['payment_name'] = PaymentService::name($vo['payment_type']);
}

2
app/data/controller/ShopOrderSend.php
View File

@ -66,7 +66,7 @@ class ShopOrderSend extends Controller
*/
protected function _index_page_filter(array &$data)
{
OrderService::instance()->buildOrderData($data, false);
OrderService::instance()->buildData($data, false);
$orders = array_unique(array_column($data, 'order_no'));
$orderList = $this->app->db->name('ShopOrder')->whereIn('order_no', $orders)->column('*', 'order_no');
foreach ($data as &$vo) $vo['order'] = $orderList[$vo['order_no']] ?? [];

2
app/data/controller/api/auth/Order.php
View File

@ -40,7 +40,7 @@ class Order extends Auth
$map = ['uid' => $this->uuid, 'deleted' => 0];
$query = $this->_query('ShopOrder')->in('status')->equal('order_no');
$result = $query->where($map)->order('id desc')->page(true, false, false, 20);
if (count($result['list']) > 0) OrderService::instance()->buildOrderData($result['list']);
if (count($result['list']) > 0) OrderService::instance()->buildData($result['list']);
$this->success('获取订单数据成功！', $result);
}

2
app/data/service/OrderService.php
View File

@ -45,7 +45,7 @@ class OrderService extends Service
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function buildOrderData(array &$data = [], $fromer = true): array
public function buildData(array &$data = [], $fromer = true): array
{
// 关联发货信息
$nobs = array_unique(array_column($data, 'order_no'));

2
app/data/service/PaymentService.php
View File

@ -8,9 +8,9 @@ use app\data\service\payment\EmptyPaymentService;
use app\data\service\payment\JoinpayPaymentService;
use app\data\service\payment\VoucherPaymentService;
use app\data\service\payment\WechatPaymentService;
use think\admin\Exception;
use think\App;
use think\Container;
use think\admin\Exception;
/**
* 支付基础服务

10
app/data/service/RebateCurrentService.php
View File

@ -2,8 +2,8 @@
namespace app\data\service;
use think\admin\Service;
use think\admin\Exception;
use think\admin\Service;
/**
* 实时返利服务
@ -128,7 +128,7 @@ class RebateCurrentService extends Service
'uid' => $this->from1['id'], 'name' => $name, 'amount' => $amount, 'order_amount' => $this->order['amount_total'],
]));
// 更新用户奖利金额
UserService::instance()->syncLevel($this->from1['id']);
UpgradeService::instance()->syncLevel($this->from1['id']);
}
return true;
}
@ -160,7 +160,7 @@ class RebateCurrentService extends Service
'uid' => $this->from1['id'], 'name' => $name, 'amount' => $amount, 'order_amount' => $this->order['amount_total'],
]));
// 更新用户奖利金额
UserService::instance()->syncLevel($this->from1['id']);
UpgradeService::instance()->syncLevel($this->from1['id']);
}
return true;
}
@ -185,7 +185,7 @@ class RebateCurrentService extends Service
'uid' => $this->from1['id'], 'name' => $name, 'amount' => $amount, 'order_amount' => $this->order['amount_total'],
]));
// 更新用户奖利金额
UserService::instance()->syncLevel($this->from1['id']);
UpgradeService::instance()->syncLevel($this->from1['id']);
}
return true;
}
@ -209,7 +209,7 @@ class RebateCurrentService extends Service
'uid' => $this->from2['id'], 'name' => $name, 'amount' => $amount, 'order_amount' => $this->order['amount_total'],
]));
// 更新代理奖利金额
UserService::instance()->syncLevel($this->from2['id']);
UpgradeService::instance()->syncLevel($this->from2['id']);
}
return true;
}

79
app/data/service/UpgradeService.php Normal file
View File

@ -0,0 +1,79 @@
<?php
namespace app\data\service;
use think\admin\Service;
/**
* 用户等级升级服务
* Class UpgradeService
* @package app\data\service
*/
class UpgradeService extends Service
{
/**
* 同步计算用户级别
* @param integer $uid 指定用户UID
* @param boolean $parent 同步计算上级
* @return boolean
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function syncLevel(int $uid, bool $parent = true): bool
{
$user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
if (empty($user)) return true;
[$vipName, $vipNumber] = ['普通用户', 0];
// 统计历史数据
$teamsDirect = $this->app->db->name('DataUser')->where(['pid1' => $uid])->count();
$teamsIndirect = $this->app->db->name('DataUser')->where(['pid2' => $uid])->count();
$teamsUsers = $this->app->db->name('DataUser')->where(['pid1|pid2' => $uid])->count();
$orderAmount = $this->app->db->name('ShopOrder')->where("uid={$uid} and status>=4")->sum('amount_total');
// 计算用户级别
foreach ($this->app->db->name('DataUserUpgrade')->where(['status' => 1])->order('number desc')->cursor() as $item) {
$l1 = empty($item['goods_vip_status']) || $user['buy_vip_entry'] > 0;
$l2 = empty($item['teams_users_status']) || $item['teams_users_number'] <= $teamsUsers;
$l3 = empty($item['order_amount_status']) || $item['order_amount_number'] <= $orderAmount;
$l4 = empty($item['teams_direct_status']) || $item['teams_direct_number'] <= $teamsDirect;
$l5 = empty($item['teams_indirect_status']) || $item['teams_indirect_number'] <= $teamsIndirect;
if (
($item['upgrade_type'] == 0 && ($l1 || $l2 || $l3 || $l4 || $l5)) /* 满足任何条件可以等级 */
||
($item['upgrade_type'] == 1 && ($l1 && $l2 && $l3 && $l4 && $l5)) /* 满足所有条件可以等级 */
) {
[$vipName, $vipNumber] = [$item['name'], $item['number']];
break;
}
}
// 购买商品升级
$query = $this->app->db->name('ShopOrderItem')->alias('b')->join('shop_order a', 'b.order_no=a.order_no');
$tmpNumber = $query->whereRaw("a.uid={$uid} and a.payment_status=1 and a.status>=4 and b.vip_entry=1")->max('b.vip_number');
if ($tmpNumber > $vipNumber) {
$map = ['status' => 1, 'number' => $tmpNumber];
$upgrade = $this->app->db->name('DataUserUpgrade')->where($map)->find();
if (!empty($upgrade)) [$vipName, $vipNumber] = [$upgrade['name'], $upgrade['number']];
}
// 统计订单金额
$orderAmountTotal = $this->app->db->name('ShopOrder')->whereRaw("uid={$uid} and status>=4")->sum('amount_goods');
$teamsAmountDirect = $this->app->db->name('ShopOrder')->whereRaw("puid1={$uid} and status>=4")->sum('amount_goods');
$teamsAmountIndirect = $this->app->db->name('ShopOrder')->whereRaw("puid2={$uid} and status>=4")->sum('amount_goods');
// 更新用户数据
$data = [
'vip_name' => $vipName,
'vip_number' => $vipNumber,
'teams_users_total' => $teamsUsers,
'teams_users_direct' => $teamsDirect,
'teams_users_indirect' => $teamsIndirect,
'teams_amount_total' => $teamsAmountDirect + $teamsAmountIndirect,
'teams_amount_direct' => $teamsAmountDirect,
'teams_amount_indirect' => $teamsAmountIndirect,
'order_amount_total' => $orderAmountTotal,
];
if ($data['vip_number'] !== $user['vip_number']) {
$data['vip_datetime'] = date('Y-m-d H:i:s');
}
$this->app->db->name('DataUser')->where(['id' => $uid])->update($data);
return ($parent && $user['pid2'] > 0) ? $this->syncLevel($user['pid2'], false) : true;
}
}

66
app/data/service/UserService.php
View File

@ -209,72 +209,6 @@ class UserService extends Service
}
}
/**
* 同步计算用户级别
* @param integer $uid 指定用户UID
* @param boolean $parent 同步计算上级
* @return boolean
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function syncLevel(int $uid, bool $parent = true): bool
{
$user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
if (empty($user)) return true;
[$vipName, $vipNumber] = ['普通用户', 0];
// 统计历史数据
$teamsDirect = $this->app->db->name('DataUser')->where(['pid1' => $uid])->count();
$teamsIndirect = $this->app->db->name('DataUser')->where(['pid2' => $uid])->count();
$teamsUsers = $this->app->db->name('DataUser')->where(['pid1|pid2' => $uid])->count();
$orderAmount = $this->app->db->name('ShopOrder')->where("uid={$uid} and status>=4")->sum('amount_total');
// 计算用户级别
foreach ($this->app->db->name('DataUserUpgrade')->where(['status' => 1])->order('number desc')->cursor() as $item) {
$l1 = empty($item['goods_vip_status']) || $user['buy_vip_entry'] > 0;
$l2 = empty($item['teams_users_status']) || $item['teams_users_number'] <= $teamsUsers;
$l3 = empty($item['order_amount_status']) || $item['order_amount_number'] <= $orderAmount;
$l4 = empty($item['teams_direct_status']) || $item['teams_direct_number'] <= $teamsDirect;
$l5 = empty($item['teams_indirect_status']) || $item['teams_indirect_number'] <= $teamsIndirect;
if (
($item['upgrade_type'] == 0 && ($l1 || $l2 || $l3 || $l4 || $l5)) /* 满足任何条件可以等级 */
||
($item['upgrade_type'] == 1 && ($l1 && $l2 && $l3 && $l4 && $l5)) /* 满足所有条件可以等级 */
) {
[$vipName, $vipNumber] = [$item['name'], $item['number']];
break;
}
}
// 购买商品升级
$query = $this->app->db->name('ShopOrderItem')->alias('b')->join('shop_order a', 'b.order_no=a.order_no');
$tmpNumber = $query->whereRaw("a.uid={$uid} and a.payment_status=1 and a.status>=4 and b.vip_entry=1")->max('b.vip_number');
if ($tmpNumber > $vipNumber) {
$map = ['status' => 1, 'number' => $tmpNumber];
$upgrade = $this->app->db->name('DataUserUpgrade')->where($map)->find();
if (!empty($upgrade)) [$vipName, $vipNumber] = [$upgrade['name'], $upgrade['number']];
}
// 统计订单金额
$orderAmountTotal = $this->app->db->name('ShopOrder')->whereRaw("uid={$uid} and status>=4")->sum('amount_goods');
$teamsAmountDirect = $this->app->db->name('ShopOrder')->whereRaw("puid1={$uid} and status>=4")->sum('amount_goods');
$teamsAmountIndirect = $this->app->db->name('ShopOrder')->whereRaw("puid2={$uid} and status>=4")->sum('amount_goods');
// 更新用户数据
$data = [
'vip_name' => $vipName,
'vip_number' => $vipNumber,
'teams_users_total' => $teamsUsers,
'teams_users_direct' => $teamsDirect,
'teams_users_indirect' => $teamsIndirect,
'teams_amount_total' => $teamsAmountDirect + $teamsAmountIndirect,
'teams_amount_direct' => $teamsAmountDirect,
'teams_amount_indirect' => $teamsAmountIndirect,
'order_amount_total' => $orderAmountTotal,
];
if ($data['vip_number'] !== $user['vip_number']) {
$data['vip_datetime'] = date('Y-m-d H:i:s');
}
$this->app->db->name('DataUser')->where(['id' => $uid])->update($data);
return ($parent && $user['pid2'] > 0) ? $this->syncLevel($user['pid2'], false) : true;
}
/**
* 获取令牌的认证值
* @return string