Callback.php 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250
  1. <?php
  2. namespace App\Components;
  3. use App\Http\Models\Goods;
  4. use App\Http\Models\GoodsLabel;
  5. use App\Http\Models\Order;
  6. use App\Http\Models\Payment;
  7. use App\Http\Models\SsNode;
  8. use App\Http\Models\SsNodeLabel;
  9. use App\Http\Models\User;
  10. use App\Http\Models\UserLabel;
  11. use App\Mail\sendUserInfo;
  12. use DB;
  13. use Exception;
  14. use Hash;
  15. use Illuminate\Http\Request;
  16. use Log;
  17. use Mail;
  18. use Response;
  19. trait Callback
  20. {
  21. protected static $systemConfig;
  22. function __construct()
  23. {
  24. self::$systemConfig = Helpers::systemConfig();
  25. }
  26. // 交易支付
  27. private function tradePaid($msg, $pay_type)
  28. {
  29. $pay_type_name = $pay_type == 1? '余额支付' : ($pay_type == 4? '支付宝国际' : ($pay_type == 5? '支付宝当面付' : ''));
  30. if($pay_type != 1){
  31. Log::info('【'.$pay_type_name.'】支付成功,开始处理回调订单');
  32. // 获取未完成状态的订单防止重复增加时间
  33. $payment = Payment::query()->with(['order', 'order.goods'])->where('status', 0)->where('order_sn', $msg['out_trade_no'])->first();
  34. if(!$payment){
  35. Log::info('【'.$pay_type_name.'】回调订单【'.$msg['out_trade_no'].'】不存在');
  36. return FALSE;
  37. }
  38. }else{
  39. Log::info('【'.$pay_type_name.'】订单处理');
  40. }
  41. // 处理订单
  42. DB::beginTransaction();
  43. try{
  44. if($pay_type != 1){
  45. // 如果支付单中没有用户信息则创建一个用户
  46. if(!$payment->user_id){
  47. $uid = Helpers::addUser('自动生成-'.$payment->order->email, Hash::make(makeRandStr()), 1, $payment->order->goods->days);
  48. if($uid){
  49. Order::query()->where('oid', $payment->oid)->update(['user_id' => $uid]);
  50. }
  51. }
  52. // 更新支付单
  53. $payment->pay_way = $pay_type == 4 || $pay_type == 5? 2 : 1; // 1-微信、2-支付宝
  54. $payment->status = 1;
  55. $payment->save();
  56. }
  57. // 更新订单
  58. $order = Order::query()->where('order_sn', $msg['out_trade_no'])->first();
  59. // 提取商品信息
  60. $goods = Goods::query()->where('id', $order->goods_id)->first();
  61. // 取出用户信息
  62. $user = User::query()->where('id', $order->user_id)->first();
  63. // 商品为流量或者套餐
  64. switch($goods->type){
  65. case 1:
  66. $order->status = 2;
  67. $order->save();
  68. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, $user->transfer_enable+$goods->traffic*1048576, '[在线支付]加上用户购买的套餐流量');
  69. $user->increment('transfer_enable', $goods->traffic*1048576);
  70. break;
  71. case 2:
  72. $activePlan = Order::query()
  73. ->where('user_id', $order->user_id)
  74. ->with(['goods'])
  75. ->whereHas('goods', function($q){
  76. $q->where('type', 2);
  77. })
  78. ->where('is_expire', 0)
  79. ->where('status', 2)
  80. ->exists();
  81. // 2为开始生效,3为预支付
  82. $order->status = $activePlan? 3 : 2;
  83. $order->save();
  84. // 预支付不执行
  85. if(!$activePlan){
  86. // 如果买的是套餐,则先将之前购买的套餐都无效化,重置用户已用、可用流量为0
  87. Order::query()
  88. ->where('user_id', $order->user_id)
  89. ->with(['goods'])
  90. ->whereHas('goods', function($q){
  91. $q->where('type', '<=', 2);
  92. })
  93. ->where('is_expire', 0)
  94. ->where('status', 2)
  95. ->where('oid', '<>', $order->oid)
  96. ->update(['expire_at' => date('Y-m-d H:i:s'), 'is_expire' => 1]);
  97. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, 0, '[在线支付]用户购买新套餐,先清空流量');
  98. User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
  99. $userTraffic = $goods->traffic*1048576;
  100. // 添加账号有效期
  101. $expireTime = date('Y-m-d', strtotime("+".$goods->days." days"));
  102. //账号下一个重置时间
  103. $nextResetTime = date('Y-m-d', strtotime("+".$goods->period." days"));
  104. if($nextResetTime >= $expireTime){
  105. $nextResetTime = NULL;
  106. }
  107. // 写入用户标签
  108. if($goods->label){
  109. // 删除用户所有标签
  110. UserLabel::query()->where('user_id', $order->user_id)->delete();
  111. //取出 商品默认标签 & 系统默认标签 去重
  112. $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']) : [])));
  113. // 生成标签
  114. foreach($newUserLabels as $vo){
  115. $obj = new UserLabel();
  116. $obj->user_id = $order->user_id;
  117. $obj->label_id = $vo;
  118. $obj->save();
  119. }
  120. }
  121. // 写入返利日志
  122. if($order->user->referral_uid){
  123. $this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount, $order->amount*self::$systemConfig['referral_percent']);
  124. // 邀请注册功能开启时,每成功邀请一名付费用户,返还邀请者邀请名额
  125. if(self::$systemConfig['is_invite_register']){
  126. User::query()->where('id', $order->user->referral_uid)->increment('invite_num', 1);
  127. }
  128. }
  129. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, $userTraffic, '[在线支付]加上用户购买的套餐流量');
  130. 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]);
  131. }else{
  132. //预支付订单先给上账号时间用于流量重置判断
  133. User::query()->where('id', $order->user_id)->update(['expire_time' => date('Y-m-d', strtotime("+".$goods->days." days", strtotime($user->expire_time)))]);
  134. }
  135. break;
  136. case 3:
  137. $order->status = 2;
  138. $order->save();
  139. $user->increment('balance', $goods->price*100);
  140. // 余额变动记录日志
  141. $this->addUserBalanceLog($order->user_id, $order->oid, $order->user->balance, $order->user->balance+$goods->price, $goods->price, '用户在线充值');
  142. break;
  143. default:
  144. Log::info('【处理订单】出现错误-未知套餐类型');
  145. }
  146. // 自动提号机:如果order的email值不为空
  147. if($order->email){
  148. $title = '自动发送账号信息';
  149. $content = [
  150. 'order_sn' => $order->order_sn,
  151. 'goods_name' => $order->goods->name,
  152. 'goods_traffic' => flowAutoShow($order->goods->traffic*1048576),
  153. 'port' => $order->user->port,
  154. 'passwd' => $order->user->passwd,
  155. 'method' => $order->user->method,
  156. //'protocol' => $order->user->protocol,
  157. //'protocol_param' => $order->user->protocol_param,
  158. //'obfs' => $order->user->obfs,
  159. //'obfs_param' => $order->user->obfs_param,
  160. 'created_at' => $order->created_at->toDateTimeString(),
  161. 'expire_at' => $order->expire_at
  162. ];
  163. // 获取可用节点列表
  164. $labels = UserLabel::query()->where('user_id', $order->user_id)->get()->pluck('label_id');
  165. $nodeIds = SsNodeLabel::query()->whereIn('label_id', $labels)->get()->pluck('node_id');
  166. $nodeList = SsNode::query()->whereIn('id', $nodeIds)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get()->toArray();
  167. $content['serverList'] = $nodeList;
  168. $logId = Helpers::addEmailLog($order->email, $title, json_encode($content));
  169. Mail::to($order->email)->send(new sendUserInfo($logId, $content));
  170. }
  171. DB::commit();
  172. Log::info('【'.$pay_type_name.'】处理成功');
  173. } catch(Exception $e){
  174. DB::rollBack();
  175. Log::info('【'.$pay_type_name.'】回调更新支付单和订单异常:'.$e->getMessage());
  176. }
  177. return FALSE;
  178. }
  179. private function activePrepaidOrder($oid)
  180. {
  181. // 取出预支付订单
  182. $prepaidOrder = Order::query()->where('oid', $oid)->first();
  183. //去除使用中的套餐和 流量包
  184. 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]);
  185. //取出对应套餐信息
  186. $prepaidGood = Goods::query()->where('id', $prepaidOrder->goods_id)->first();
  187. //激活预支付套餐
  188. Order::query()->where('oid', $prepaidOrder->oid)->update(['expire_at' => date("Y-m-d H:i:s", strtotime("+".$prepaidGood->days." days")), 'status' => 2]);
  189. //取出用户信息
  190. $user = User::query()->where('id', $prepaidOrder->user_id)->first();
  191. $userTraffic = $prepaidGood->traffic*1048576;
  192. //拿出可能存在的其余套餐, 推算 最新的到期时间
  193. $expire_time = date('Y-m-d', strtotime("+".$prepaidGood->days." days"));
  194. $prepaidOrders = Order::query()->where('user_id', $prepaidOrder->user_id)->where('status', 3)->get();
  195. foreach($prepaidOrders as $paidOrder){
  196. //取出对应套餐信息
  197. $goods = Goods::query()->where('id', $paidOrder->goods_id)->first();
  198. $expire_time = date('Y-m-d', strtotime("+".$goods->days." days", strtotime($expire_time)));
  199. }
  200. //计算账号下一个重置时间
  201. $nextResetTime = date('Y-m-d', strtotime("+".$prepaidGood->period." days"));
  202. if($nextResetTime >= $expire_time){
  203. $nextResetTime = NULL;
  204. }
  205. // 用户默认标签
  206. $defaultLabels = self::$systemConfig['initial_labels_for_user']? explode(',', self::$systemConfig['initial_labels_for_user']) : [];
  207. //取出 商品默认标签 & 系统默认标签 去重
  208. $newUserLabels = array_values(array_unique(array_merge(GoodsLabel::query()->where('goods_id', $prepaidOrder->goods_id)->pluck('label_id')->toArray(), $defaultLabels)));
  209. // 生成标签
  210. foreach($newUserLabels as $vo){
  211. $obj = new UserLabel();
  212. $obj->user_id = $prepaidOrder->user_id;
  213. $obj->label_id = $vo;
  214. $obj->save();
  215. }
  216. Helpers::addUserTrafficModifyLog($prepaidOrder->user_id, $prepaidOrder->oid, $user->transfer_enable, $userTraffic, '[预支付订单激活]加上用户购买的套餐流量');
  217. User::query()->where('id', $prepaidOrder->user_id)->increment('invite_num', $prepaidOrder->invite_num? : 0, ['transfer_enable' => $userTraffic, 'expire_time' => $expire_time, 'reset_time' => $nextResetTime]);
  218. }
  219. public function show(Request $request)
  220. {
  221. exit('show');
  222. }
  223. }