diff --git a/app/czg/app/controller/OrderController.php b/app/czg/app/controller/OrderController.php index 8f0bc3c..3cb302c 100644 --- a/app/czg/app/controller/OrderController.php +++ b/app/czg/app/controller/OrderController.php @@ -17,7 +17,7 @@ use think\facade\Db; class OrderController extends BaseController { -// protected array $noNeedLogin = ["payOrders"]; + protected array $noNeedLogin = ["*"]; protected array $noNeedPermission = []; @@ -36,7 +36,6 @@ class OrderController extends BaseController { $params = request()->get(); - $userInfo = $this->auth->getUser(); debounce('insertCourseOrders'.$userInfo['user_id']); Log::info('生成商品订单信息接口入参为: {}', $params); diff --git a/app/czg/app/controller/Wuyou.php b/app/czg/app/controller/Wuyou.php index 3fa0723..679bc08 100644 --- a/app/czg/app/controller/Wuyou.php +++ b/app/czg/app/controller/Wuyou.php @@ -2,19 +2,16 @@ namespace app\czg\app\controller; -use app\api\model\Orders; use app\api\model\TbUserBlacklist; -use app\api\validate\WuyouValidate; use app\common\controller\BaseController; -use app\common\controller\Frontend; use app\common\library\DatabaseRoute; -use app\CoroutineContext; use app\exception\SysException; use app\utils\RedisUtils; use app\utils\WuYouPayUtils; use ba\Random; +use Orders; +use support\Log; use think\facade\Db; -use think\facade\Log; use Throwable; class Wuyou extends BaseController @@ -23,9 +20,8 @@ class Wuyou extends BaseController protected array $noNeedPermission = []; - public function queryOrder() + public function queryOrder($orderId) { - $orderId = $this->request->param('orderId'); $userId = $this->getUserId(); $order = DatabaseRoute::getDb('orders', $userId)->where([ 'orders_id' => $orderId diff --git a/app/czg/app/model/Orders.php b/app/czg/app/model/Orders.php index 7d83250..b3e3ba5 100644 --- a/app/czg/app/model/Orders.php +++ b/app/czg/app/model/Orders.php @@ -1,15 +1,15 @@ where([ -// 'user_id' => $order['user_id'] -// ])->find(); + self::insertOrders($order); + + // 用户信息及上级信息 + $userInfo = DatabaseRoute::getDb('tb_user', $order['user_id'])->where([ + 'user_id' => $order['user_id'] + ])->find(); -// $byUser = TbUser::getByUserIdOrInviterCode($userInfo['inviter_user_id'], $userInfo['inviter_code']); + $byUser = TbUser::getByUserIdOrInviterCode($userInfo['inviter_user_id'], $userInfo['inviter_code']); // 记录上级用户奖励信息 -// Log::info("上级用户: ".json_encode($byUser)); -// if ($byUser) { -// $inviteAchievement = DatabaseRoute::getAllDbData('invite_achievement', function ($query) use ($byUser, $userInfo) { -// return $query->where([ -// 'target_user_id' => $userInfo['user_id'] -// ]); -// })->find(); -// if ($inviteAchievement) { -// Log::info("修改邀请统计"); -// DatabaseRoute::getDb('invite_achievement', $byUser['user_id'], true)->where([ -// 'user_id' => $inviteAchievement['user_id'], -// 'id' => $inviteAchievement['id'] -// ])->update([ -// 'count' => $inviteAchievement['count'] + 1, -// 'update_time' => getNormalDate() -// ]); -// }else{ -// Log::info("新增邀请统计"); -// DatabaseRoute::getDb('invite_achievement', $byUser['user_id'], true)->insert([ -// 'state' => 0, -// 'count' => 1, -// 'create_time' => getNormalDate(), -// 'target_user_id' => $userInfo['user_id'], -// 'user_id' => $byUser['user_id'] -// ]); -// } + Log::info("上级用户: ".json_encode($byUser)); + if ($byUser) { + $inviteAchievement = DatabaseRoute::getAllDbData('invite_achievement', function ($query) use ($byUser, $userInfo) { + return $query->where([ + 'target_user_id' => $userInfo['user_id'] + ]); + })->find(); + if ($inviteAchievement) { + Log::info("修改邀请统计"); + DatabaseRoute::getDb('invite_achievement', $byUser['user_id'], true)->where([ + 'user_id' => $inviteAchievement['user_id'], + 'id' => $inviteAchievement['id'] + ])->update([ + 'count' => $inviteAchievement['count'] + 1, + 'update_time' => getNormalDate() + ]); + }else{ + Log::info("新增邀请统计"); + DatabaseRoute::getDb('invite_achievement', $byUser['user_id'], true)->insert([ + 'state' => 0, + 'count' => 1, + 'create_time' => getNormalDate(), + 'target_user_id' => $userInfo['user_id'], + 'user_id' => $byUser['user_id'] + ]); + } // // // // TODO 异步领取奖励 -//// pushQueue(ActivitiesQueue::class, [ -//// 'userInfo' => $userInfo, -//// 'sourceUser' => $byUser -//// ], 1); -// DatabaseRoute::transactionXa(function () use ($userInfo, $byUser, $userId) { -// self::activities($userInfo, $byUser); -// }); -// } +// pushQueue(ActivitiesQueue::class, [ +// 'userInfo' => $userInfo, +// 'sourceUser' => $byUser +// ], 1); + DatabaseRoute::transactionXa(function () use ($userInfo, $byUser, $userId) { + self::activities($userInfo, $byUser); + }); + } // 推广奖励发放 -// if ($userInfo['inviter_code'] || !$byUser || $byUser['user_id'] == 1) { -// $sysUser = SysUser::GetByQrcode($userInfo['qd_code']); -// if ($sysUser) { -// $rateMoney = $sysUser['qd_rate']; -// SysUser::updateSysMoney($sysUser['user_id'], $rateMoney, 1); -// -// DatabaseRoute::getDb('sys_user_money_details', $sysUser['user_id'], true)->insert([ -// 'sys_user_id' => $sysUser['user_id'], -// 'user_id' => $sysUser['user_id'], -// 'type' => 1, -// 'money' => $rateMoney, -// 'create_time' => getNormalDate(), -// 'state' => 2, -// 'classify' => 10, -// 'title' => "[渠道用户]用户名称:{$userInfo['user_name']}", -// 'money_type' => 1, -// 'content' => '总佣金'.$rateMoney.',到账佣金'.$rateMoney -// ]); -// } -// } + if ($userInfo['inviter_code'] || !$byUser || $byUser['user_id'] == 1) { + $sysUser = SysUser::GetByQrcode($userInfo['qd_code']); + if ($sysUser) { + $rateMoney = $sysUser['qd_rate']; + SysUser::updateSysMoney($sysUser['user_id'], $rateMoney, 1); + + DatabaseRoute::getDb('sys_user_money_details', $sysUser['user_id'], true)->insert([ + 'sys_user_id' => $sysUser['user_id'], + 'user_id' => $sysUser['user_id'], + 'type' => 1, + 'money' => $rateMoney, + 'create_time' => getNormalDate(), + 'state' => 2, + 'classify' => 10, + 'title' => "[渠道用户]用户名称:{$userInfo['user_name']}", + 'money_type' => 1, + 'content' => '总佣金'.$rateMoney.',到账佣金'.$rateMoney + ]); + } + } // 增加剧集支付次数 -// self::incrWeekPayCount($order['course_id']); + self::incrWeekPayCount($order['course_id']); } diff --git a/config/route.php b/config/route.php index a004849..0984b69 100644 --- a/config/route.php +++ b/config/route.php @@ -14,7 +14,7 @@ use Webman\Route; - +Route::any('/czg/app/wuyou/queryOrder/{orderId}', [app\czg\app\controller\Wuyou::class, 'queryOrder']);