F2fpayController.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Components\Helpers;
  4. use App\Http\Controllers\Controller;
  5. use App\Http\Models\Goods;
  6. use App\Http\Models\GoodsLabel;
  7. use App\Http\Models\Order;
  8. use App\Http\Models\Payment;
  9. use App\Http\Models\SsNode;
  10. use App\Http\Models\SsNodeLabel;
  11. use App\Http\Models\User;
  12. use App\Http\Models\UserLabel;
  13. use App\Mail\sendUserInfo;
  14. use DB;
  15. use Hash;
  16. use Illuminate\Http\Request;
  17. use Log;
  18. use Mail;
  19. use Payment\Client\Query;
  20. use Payment\Common\PayException;
  21. /**
  22. * Class F2fpayController
  23. *
  24. * @author heron
  25. *
  26. * @package App\Http\Controllers\Api
  27. */
  28. class F2fpayController extends Controller
  29. {
  30. protected static $systemConfig;
  31. function __construct()
  32. {
  33. self::$systemConfig = Helpers::systemConfig();
  34. }
  35. // 接收GET请求
  36. public function index(Request $request)
  37. {
  38. \Log::info("【支付宝当面付】回调接口[GET]:" . var_export($request->all(), true) . '[' . getClientIp() . ']');
  39. exit("【支付宝当面付】接口正常");
  40. }
  41. // 接收POST请求
  42. public function store(Request $request)
  43. {
  44. \Log::info("【支付宝当面付】回调接口[POST]:" . var_export($request->all(), true));
  45. $result = "fail";
  46. try {
  47. $verify_result = Query::run('ali_charge', [
  48. 'use_sandbox' => false,
  49. "partner" => self::$systemConfig['f2fpay_app_id'],
  50. 'app_id' => self::$systemConfig['f2fpay_app_id'],
  51. 'sign_type' => 'RSA2',
  52. 'ali_public_key' => self::$systemConfig['f2fpay_public_key'],
  53. 'rsa_private_key' => self::$systemConfig['f2fpay_private_key'],
  54. 'notify_url' => self::$systemConfig['website_url'] . "/api/f2fpay", // 异步回调接口
  55. 'return_url' => self::$systemConfig['website_url'],
  56. 'return_raw' => false
  57. ], [
  58. 'out_trade_no' => $request->get('out_trade_no'),
  59. 'trade_no' => $request->get('trade_no'),
  60. ]);
  61. \Log::info("【支付宝当面付】回调验证查询:" . var_export($verify_result, true));
  62. } catch (PayException $e) {
  63. \Log::info("【支付宝当面付】回调验证查询出错:" . var_export($e->errorMessage(), true));
  64. exit($result);
  65. }
  66. if ($verify_result['is_success'] == 'T') { // 验证成功
  67. $result = "success";
  68. if ($_POST['trade_status'] == 'TRADE_FINISHED' || $_POST['trade_status'] == 'TRADE_SUCCESS') {
  69. // 商户订单号
  70. $data = [];
  71. $data['out_trade_no'] = $request->get('out_trade_no');
  72. // 支付宝交易号
  73. $data['trade_no'] = $request->get('trade_no');
  74. // 交易状态
  75. $data['trade_status'] = $request->get('trade_status');
  76. // 交易金额(这里是按照结算货币汇率的金额,和rmb_fee不相等)
  77. $data['total_amount'] = $request->get('total_amount');
  78. $this->tradePaid($data);
  79. } else {
  80. Log::info('支付宝当面付-POST:交易失败[' . getClientIp() . ']');
  81. }
  82. } else {
  83. Log::info('支付宝当面付-POST:验证失败[' . getClientIp() . ']');
  84. }
  85. // 返回验证结果
  86. exit($result);
  87. }
  88. // 交易支付
  89. private function tradePaid($msg)
  90. {
  91. Log::info('【支付宝当面付】回调交易支付');
  92. // 获取未完成状态的订单防止重复增加时间
  93. $payment = Payment::query()->with(['order', 'order.goods'])->where('status', 0)->where('order_sn', $msg['out_trade_no'])->first();
  94. if (!$payment) {
  95. Log::info('【支付宝当面付】回调订单不存在');
  96. return;
  97. }
  98. // 处理订单
  99. DB::beginTransaction();
  100. try {
  101. // 如果支付单中没有用户信息则创建一个用户
  102. if (!$payment->user_id) {
  103. // 生成一个可用端口
  104. $port = self::$systemConfig['is_rand_port'] ? Helpers::getRandPort() : Helpers::getOnlyPort();
  105. $user = new User();
  106. $user->username = '自动生成-' . $payment->order->email;
  107. $user->password = Hash::make(makeRandStr());
  108. $user->port = $port;
  109. $user->passwd = makeRandStr();
  110. $user->vmess_id = createGuid();
  111. $user->enable = 1;
  112. $user->method = Helpers::getDefaultMethod();
  113. $user->protocol = Helpers::getDefaultProtocol();
  114. $user->obfs = Helpers::getDefaultObfs();
  115. $user->usage = 1;
  116. $user->transfer_enable = 1; // 新创建的账号给1,防止定时任务执行时发现u + d >= transfer_enable被判为流量超限而封禁
  117. $user->enable_time = date('Y-m-d');
  118. $user->expire_time = date('Y-m-d', strtotime("+" . $payment->order->goods->days . " days"));
  119. $user->reg_ip = getClientIp();
  120. $user->referral_uid = 0;
  121. $user->traffic_reset_day = 0;
  122. $user->status = 1;
  123. $user->save();
  124. if ($user->id) {
  125. Order::query()->where('oid', $payment->oid)->update(['user_id' => $user->id]);
  126. }
  127. }
  128. // 更新支付单
  129. $payment->pay_way = 2; // 1-微信、2-支付宝
  130. $payment->status = 1;
  131. $payment->save();
  132. // 更新订单
  133. $order = Order::query()->with(['user'])->where('oid', $payment->oid)->first();
  134. $order->status = 2;
  135. $order->save();
  136. $goods = Goods::query()->where('id', $order->goods_id)->first();
  137. // 商品为流量或者套餐
  138. if ($goods->type <= 2) {
  139. // 如果买的是套餐,则先将之前购买的所有套餐置都无效,并扣掉之前所有套餐的流量,重置用户已用流量为0
  140. if ($goods->type == 2) {
  141. $existOrderList = Order::query()
  142. ->with(['goods'])
  143. ->whereHas('goods', function ($q) {
  144. $q->where('type', 2);
  145. })
  146. ->where('user_id', $order->user_id)
  147. ->where('oid', '<>', $order->oid)
  148. ->where('is_expire', 0)
  149. ->where('status', 2)
  150. ->get();
  151. foreach ($existOrderList as $vo) {
  152. Order::query()->where('oid', $vo->oid)->update(['is_expire' => 1]);
  153. // 先判断,防止手动扣减过流量的用户流量被扣成负数
  154. if ($order->user->transfer_enable - $vo->goods->traffic * 1048576 <= 0) {
  155. // 写入用户流量变动记录
  156. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, 0, 0, '[在线支付]用户购买套餐,先扣减之前套餐的流量(扣完)');
  157. User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
  158. } else {
  159. // 写入用户流量变动记录
  160. $user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
  161. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable - $vo->goods->traffic * 1048576), '[在线支付]用户购买套餐,先扣减之前套餐的流量(未扣完)');
  162. User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0]);
  163. User::query()->where('id', $order->user_id)->decrement('transfer_enable', $vo->goods->traffic * 1048576);
  164. }
  165. }
  166. }
  167. // 写入用户流量变动记录
  168. $user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
  169. Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable + $goods->traffic * 1048576), '[在线支付]用户购买商品,加上流量');
  170. // 把商品的流量加到账号上
  171. User::query()->where('id', $order->user_id)->increment('transfer_enable', $goods->traffic * 1048576);
  172. // 计算账号过期时间
  173. if ($order->user->expire_time < date('Y-m-d', strtotime("+" . $goods->days . " days"))) {
  174. $expireTime = date('Y-m-d', strtotime("+" . $goods->days . " days"));
  175. } else {
  176. $expireTime = $order->user->expire_time;
  177. }
  178. // 套餐就改流量重置日,流量包不改
  179. if ($goods->type == 2) {
  180. if (date('m') == 2 && date('d') == 29) {
  181. $traffic_reset_day = 28;
  182. } else {
  183. $traffic_reset_day = date('d') == 31 ? 30 : abs(date('d'));
  184. }
  185. User::query()->where('id', $order->user_id)->update(['traffic_reset_day' => $traffic_reset_day, 'expire_time' => $expireTime, 'enable' => 1]);
  186. } else {
  187. User::query()->where('id', $order->user_id)->update(['expire_time' => $expireTime, 'enable' => 1]);
  188. }
  189. // 写入用户标签
  190. if ($goods->label) {
  191. // 用户默认标签
  192. $defaultLabels = [];
  193. if (self::$systemConfig['initial_labels_for_user']) {
  194. $defaultLabels = explode(',', self::$systemConfig['initial_labels_for_user']);
  195. }
  196. // 取出现有的标签
  197. $userLabels = UserLabel::query()->where('user_id', $order->user_id)->pluck('label_id')->toArray();
  198. $goodsLabels = GoodsLabel::query()->where('goods_id', $order->goods_id)->pluck('label_id')->toArray();
  199. // 标签去重
  200. $newUserLabels = array_values(array_unique(array_merge($userLabels, $goodsLabels, $defaultLabels)));
  201. // 删除用户所有标签
  202. UserLabel::query()->where('user_id', $order->user_id)->delete();
  203. // 生成标签
  204. foreach ($newUserLabels as $vo) {
  205. $obj = new UserLabel();
  206. $obj->user_id = $order->user_id;
  207. $obj->label_id = $vo;
  208. $obj->save();
  209. }
  210. }
  211. // 写入返利日志
  212. if ($order->user->referral_uid) {
  213. $this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount, $order->amount * self::$systemConfig['referral_percent']);
  214. }
  215. // 取消重复返利
  216. User::query()->where('id', $order->user_id)->update(['referral_uid' => 0]);
  217. } elseif ($goods->type == 3) { // 商品为在线充值
  218. User::query()->where('id', $order->user_id)->increment('balance', $goods->price * 100);
  219. // 余额变动记录日志
  220. $this->addUserBalanceLog($order->user_id, $order->oid, $order->user->balance, $order->user->balance + $goods->price, $goods->price, '用户在线充值');
  221. }
  222. // 自动提号机:如果order的email值不为空
  223. if ($order->email) {
  224. $title = '自动发送账号信息';
  225. $content = [
  226. 'order_sn' => $order->order_sn,
  227. 'goods_name' => $order->goods->name,
  228. 'goods_traffic' => flowAutoShow($order->goods->traffic * 1048576),
  229. 'port' => $order->user->port,
  230. 'passwd' => $order->user->passwd,
  231. 'method' => $order->user->method,
  232. //'protocol' => $order->user->protocol,
  233. //'protocol_param' => $order->user->protocol_param,
  234. //'obfs' => $order->user->obfs,
  235. //'obfs_param' => $order->user->obfs_param,
  236. 'created_at' => $order->created_at->toDateTimeString(),
  237. 'expire_at' => $order->expire_at
  238. ];
  239. // 获取可用节点列表
  240. $labels = UserLabel::query()->where('user_id', $order->user_id)->get()->pluck('label_id');
  241. $nodeIds = SsNodeLabel::query()->whereIn('label_id', $labels)->get()->pluck('node_id');
  242. $nodeList = SsNode::query()->whereIn('id', $nodeIds)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get()->toArray();
  243. $content['serverList'] = $nodeList;
  244. $logId = Helpers::addEmailLog($order->email, $title, json_encode($content));
  245. Mail::to($order->email)->send(new sendUserInfo($logId, $content));
  246. }
  247. DB::commit();
  248. } catch (\Exception $e) {
  249. DB::rollBack();
  250. Log::info('【支付宝当面付】回调更新支付单和订单异常:' . $e->getMessage());
  251. }
  252. }
  253. public function show(Request $request)
  254. {
  255. exit('show');
  256. }
  257. }