123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250 |
- <?php
- namespace App\Components;
- use App\Http\Models\Goods;
- use App\Http\Models\GoodsLabel;
- use App\Http\Models\Order;
- use App\Http\Models\Payment;
- use App\Http\Models\SsNode;
- use App\Http\Models\SsNodeLabel;
- use App\Http\Models\User;
- use App\Http\Models\UserLabel;
- use App\Mail\sendUserInfo;
- use DB;
- use Exception;
- use Hash;
- use Illuminate\Http\Request;
- use Log;
- use Mail;
- use Response;
- trait Callback
- {
- protected static $systemConfig;
- function __construct()
- {
- self::$systemConfig = Helpers::systemConfig();
- }
- // 交易支付
- private function tradePaid($msg, $pay_type)
- {
- $pay_type_name = $pay_type == 1? '余额支付' : ($pay_type == 4? '支付宝国际' : ($pay_type == 5? '支付宝当面付' : ''));
- if($pay_type != 1){
- Log::info('【'.$pay_type_name.'】支付成功,开始处理回调订单');
- // 获取未完成状态的订单防止重复增加时间
- $payment = Payment::query()->with(['order', 'order.goods'])->where('status', 0)->where('order_sn', $msg['out_trade_no'])->first();
- if(!$payment){
- Log::info('【'.$pay_type_name.'】回调订单【'.$msg['out_trade_no'].'】不存在');
- return FALSE;
- }
- }else{
- Log::info('【'.$pay_type_name.'】订单处理');
- }
- // 处理订单
- DB::beginTransaction();
- try{
- if($pay_type != 1){
- // 如果支付单中没有用户信息则创建一个用户
- if(!$payment->user_id){
- $uid = Helpers::addUser('自动生成-'.$payment->order->email, Hash::make(makeRandStr()), 1, $payment->order->goods->days);
- if($uid){
- Order::query()->where('oid', $payment->oid)->update(['user_id' => $uid]);
- }
- }
- // 更新支付单
- $payment->pay_way = $pay_type == 4 || $pay_type == 5? 2 : 1; // 1-微信、2-支付宝
- $payment->status = 1;
- $payment->save();
- }
- // 更新订单
- $order = Order::query()->where('order_sn', $msg['out_trade_no'])->first();
- // 提取商品信息
- $goods = Goods::query()->where('id', $order->goods_id)->first();
- // 取出用户信息
- $user = User::query()->where('id', $order->user_id)->first();
- // 商品为流量或者套餐
- switch($goods->type){
- case 1:
- $order->status = 2;
- $order->save();
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, $user->transfer_enable+$goods->traffic*1048576, '[在线支付]加上用户购买的套餐流量');
- $user->increment('transfer_enable', $goods->traffic*1048576);
- break;
- case 2:
- $activePlan = Order::query()
- ->where('user_id', $order->user_id)
- ->with(['goods'])
- ->whereHas('goods', function($q){
- $q->where('type', 2);
- })
- ->where('is_expire', 0)
- ->where('status', 2)
- ->exists();
- // 2为开始生效,3为预支付
- $order->status = $activePlan? 3 : 2;
- $order->save();
- // 预支付不执行
- if(!$activePlan){
- // 如果买的是套餐,则先将之前购买的套餐都无效化,重置用户已用、可用流量为0
- Order::query()
- ->where('user_id', $order->user_id)
- ->with(['goods'])
- ->whereHas('goods', function($q){
- $q->where('type', '<=', 2);
- })
- ->where('is_expire', 0)
- ->where('status', 2)
- ->where('oid', '<>', $order->oid)
- ->update(['expire_at' => date('Y-m-d H:i:s'), 'is_expire' => 1]);
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, 0, '[在线支付]用户购买新套餐,先清空流量');
- User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
- $userTraffic = $goods->traffic*1048576;
- // 添加账号有效期
- $expireTime = date('Y-m-d', strtotime("+".$goods->days." days"));
- //账号下一个重置时间
- $nextResetTime = date('Y-m-d', strtotime("+".$goods->period." days"));
- if($nextResetTime >= $expireTime){
- $nextResetTime = NULL;
- }
- // 写入用户标签
- if($goods->label){
- // 删除用户所有标签
- UserLabel::query()->where('user_id', $order->user_id)->delete();
- //取出 商品默认标签 & 系统默认标签 去重
- $newUserLabels = array_values(array_unique(array_merge(GoodsLabel::query()->where('goods_id', $order->goods_id)->pluck('label_id')->toArray(), self::$systemConfig['initial_labels_for_user']? explode(',', self::$systemConfig['initial_labels_for_user']) : [])));
- // 生成标签
- foreach($newUserLabels as $vo){
- $obj = new UserLabel();
- $obj->user_id = $order->user_id;
- $obj->label_id = $vo;
- $obj->save();
- }
- }
- // 写入返利日志
- if($order->user->referral_uid){
- $this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount, $order->amount*self::$systemConfig['referral_percent']);
- // 邀请注册功能开启时,每成功邀请一名付费用户,返还邀请者邀请名额
- if(self::$systemConfig['is_invite_register']){
- User::query()->where('id', $order->user->referral_uid)->increment('invite_num', 1);
- }
- }
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, $userTraffic, '[在线支付]加上用户购买的套餐流量');
- User::query()->where('id', $order->user_id)->increment('invite_num', $goods->invite_num? : 0, ['transfer_enable' => $userTraffic, 'reset_time' => $nextResetTime, 'expire_time' => $expireTime, 'enable' => 1]);
- }else{
- //预支付订单先给上账号时间用于流量重置判断
- User::query()->where('id', $order->user_id)->update(['expire_time' => date('Y-m-d', strtotime("+".$goods->days." days", strtotime($user->expire_time)))]);
- }
- break;
- case 3:
- $order->status = 2;
- $order->save();
- $user->increment('balance', $goods->price*100);
- // 余额变动记录日志
- $this->addUserBalanceLog($order->user_id, $order->oid, $order->user->balance, $order->user->balance+$goods->price, $goods->price, '用户在线充值');
- break;
- default:
- Log::info('【处理订单】出现错误-未知套餐类型');
- }
- // 自动提号机:如果order的email值不为空
- if($order->email){
- $title = '自动发送账号信息';
- $content = [
- 'order_sn' => $order->order_sn,
- 'goods_name' => $order->goods->name,
- 'goods_traffic' => flowAutoShow($order->goods->traffic*1048576),
- 'port' => $order->user->port,
- 'passwd' => $order->user->passwd,
- 'method' => $order->user->method,
- //'protocol' => $order->user->protocol,
- //'protocol_param' => $order->user->protocol_param,
- //'obfs' => $order->user->obfs,
- //'obfs_param' => $order->user->obfs_param,
- 'created_at' => $order->created_at->toDateTimeString(),
- 'expire_at' => $order->expire_at
- ];
- // 获取可用节点列表
- $labels = UserLabel::query()->where('user_id', $order->user_id)->get()->pluck('label_id');
- $nodeIds = SsNodeLabel::query()->whereIn('label_id', $labels)->get()->pluck('node_id');
- $nodeList = SsNode::query()->whereIn('id', $nodeIds)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get()->toArray();
- $content['serverList'] = $nodeList;
- $logId = Helpers::addEmailLog($order->email, $title, json_encode($content));
- Mail::to($order->email)->send(new sendUserInfo($logId, $content));
- }
- DB::commit();
- Log::info('【'.$pay_type_name.'】处理成功');
- } catch(Exception $e){
- DB::rollBack();
- Log::info('【'.$pay_type_name.'】回调更新支付单和订单异常:'.$e->getMessage());
- }
- return FALSE;
- }
- private function activePrepaidOrder($oid)
- {
- // 取出预支付订单
- $prepaidOrder = Order::query()->where('oid', $oid)->first();
- //去除使用中的套餐和 流量包
- Order::query()->where('user_id', $prepaidOrder->user_id)->where('status', 2)->where('is_expire', 0)->update(['expire_at' => date('Y-m-d H:i:s'), 'is_expire' => 1]);
- //取出对应套餐信息
- $prepaidGood = Goods::query()->where('id', $prepaidOrder->goods_id)->first();
- //激活预支付套餐
- Order::query()->where('oid', $prepaidOrder->oid)->update(['expire_at' => date("Y-m-d H:i:s", strtotime("+".$prepaidGood->days." days")), 'status' => 2]);
- //取出用户信息
- $user = User::query()->where('id', $prepaidOrder->user_id)->first();
- $userTraffic = $prepaidGood->traffic*1048576;
- //拿出可能存在的其余套餐, 推算 最新的到期时间
- $expire_time = date('Y-m-d', strtotime("+".$prepaidGood->days." days"));
- $prepaidOrders = Order::query()->where('user_id', $prepaidOrder->user_id)->where('status', 3)->get();
- foreach($prepaidOrders as $paidOrder){
- //取出对应套餐信息
- $goods = Goods::query()->where('id', $paidOrder->goods_id)->first();
- $expire_time = date('Y-m-d', strtotime("+".$goods->days." days", strtotime($expire_time)));
- }
- //计算账号下一个重置时间
- $nextResetTime = date('Y-m-d', strtotime("+".$prepaidGood->period." days"));
- if($nextResetTime >= $expire_time){
- $nextResetTime = NULL;
- }
- // 用户默认标签
- $defaultLabels = self::$systemConfig['initial_labels_for_user']? explode(',', self::$systemConfig['initial_labels_for_user']) : [];
- //取出 商品默认标签 & 系统默认标签 去重
- $newUserLabels = array_values(array_unique(array_merge(GoodsLabel::query()->where('goods_id', $prepaidOrder->goods_id)->pluck('label_id')->toArray(), $defaultLabels)));
- // 生成标签
- foreach($newUserLabels as $vo){
- $obj = new UserLabel();
- $obj->user_id = $prepaidOrder->user_id;
- $obj->label_id = $vo;
- $obj->save();
- }
- Helpers::addUserTrafficModifyLog($prepaidOrder->user_id, $prepaidOrder->oid, $user->transfer_enable, $userTraffic, '[预支付订单激活]加上用户购买的套餐流量');
- User::query()->where('id', $prepaidOrder->user_id)->increment('invite_num', $prepaidOrder->invite_num? : 0, ['transfer_enable' => $userTraffic, 'expire_time' => $expire_time, 'reset_time' => $nextResetTime]);
- }
- public function show(Request $request)
- {
- exit('show');
- }
- }
|