OrderController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Http\Requests\OrderSave;
  4. use Illuminate\Http\Request;
  5. use App\Http\Controllers\Controller;
  6. use Illuminate\Support\Facades\Redis;
  7. use Illuminate\Support\Facades\Log;
  8. use App\Models\Order;
  9. use App\Models\Plan;
  10. use App\Models\User;
  11. use App\Utils\Helper;
  12. use Omnipay\Omnipay;
  13. use Stripe\Stripe;
  14. use Stripe\Source;
  15. use Library\BitpayX;
  16. class OrderController extends Controller
  17. {
  18. public function fetch (Request $request) {
  19. $order = Order::where('user_id', $request->session()->get('id'))
  20. ->orderBy('created_at', 'DESC')
  21. ->get();
  22. $plan = Plan::get();
  23. for($i = 0; $i < count($order); $i++) {
  24. for($x = 0; $x < count($plan); $x++) {
  25. if ($order[$i]['plan_id'] === $plan[$x]['id']) {
  26. $order[$i]['plan'] = $plan[$x];
  27. }
  28. }
  29. }
  30. return response([
  31. 'data' => $order
  32. ]);
  33. }
  34. public function details (Request $request) {
  35. $order = Order::where('user_id', $request->session()->get('id'))
  36. ->where('trade_no', $request->input('trade_no'))
  37. ->first();
  38. if (!$order) {
  39. abort(500, '订单不存在');
  40. }
  41. $order['plan'] = Plan::find($order->plan_id);
  42. $order['update_fee'] = config('v2board.plan_update_fee', 0.5);
  43. if (!$order['plan']) {
  44. abort(500, '订阅不存在');
  45. }
  46. return response([
  47. 'data' => $order
  48. ]);
  49. }
  50. public function save (OrderSave $request) {
  51. $plan = Plan::find($request->input('plan_id'));
  52. $user = User::find($request->session()->get('id'));
  53. if (!$plan) {
  54. abort(500, '该订阅不存在');
  55. }
  56. if (!($plan->show || $user->plan_id == $plan->id)) {
  57. abort(500, '该订阅已售罄');
  58. }
  59. if (!$plan->show && !$plan->renew) {
  60. abort(500, '该订阅无法续费,请更换其他订阅');
  61. }
  62. if (!(int)$plan[$request->input('cycle')]) {
  63. abort(500, '该订阅周期无法进行购买,请选择其他周期');
  64. }
  65. $order = new Order();
  66. $order->user_id = $request->session()->get('id');
  67. $order->plan_id = $plan->id;
  68. $order->cycle = $request->input('cycle');
  69. $order->trade_no = Helper::guid();
  70. $order->total_amount = $plan[$request->input('cycle')];
  71. if ($user->expired_at > time() && $order->plan_id !== $user->plan_id) {
  72. $order->type = 3;
  73. if (!(int)config('v2board.plan_is_update', 1)) abort(500, '目前不允许更改订阅,请联系管理员');
  74. $order->total_amount = $order->total_amount + (ceil(($user->expired_at - time()) / 86400) * config('v2board.plan_update_fee', 0.5) * 100);
  75. } else if ($user->expired_at > time() && $order->plan_id == $user->plan_id) {
  76. $order->type = 2;
  77. } else {
  78. $order->type = 1;
  79. }
  80. if ($user->invite_user_id) {
  81. $order->invite_user_id = $user->invite_user_id;
  82. $inviter = User::find($user->invite_user_id);
  83. if ($inviter && $inviter->commission_rate) {
  84. $order->commission_balance = $order->total_amount * ($inviter->commission_rate / 100);
  85. } else {
  86. $order->commission_balance = $order->total_amount * (config('v2board.invite_commission', 10) / 100);
  87. }
  88. }
  89. if (!$order->save()) {
  90. abort(500, '订单创建失败');
  91. }
  92. return response([
  93. 'data' => $order->trade_no
  94. ]);
  95. }
  96. public function checkout (Request $request) {
  97. $tradeNo = $request->input('trade_no');
  98. $method = $request->input('method');
  99. $order = Order::where('trade_no', $tradeNo)
  100. ->where('user_id', $request->session()->get('id'))
  101. ->where('status', 0)
  102. ->first();
  103. if (!$order) {
  104. abort(500, '订单不存在或已支付');
  105. }
  106. switch ($method) {
  107. // return type => 0: QRCode / 1: URL
  108. case 0:
  109. // alipayF2F
  110. if (!(int)config('v2board.alipay_enable')) {
  111. abort(500, '支付方式不可用');
  112. }
  113. return response([
  114. 'type' => 0,
  115. 'data' => $this->alipayF2F($tradeNo, $order->total_amount)
  116. ]);
  117. case 2:
  118. // stripeAlipay
  119. if (!(int)config('v2board.stripe_alipay_enable')) {
  120. abort(500, '支付方式不可用');
  121. }
  122. return response([
  123. 'type' => 1,
  124. 'data' => $this->stripeAlipay($order)
  125. ]);
  126. case 3:
  127. // stripeWepay
  128. if (!(int)config('v2board.stripe_wepay_enable')) {
  129. abort(500, '支付方式不可用');
  130. }
  131. return response([
  132. 'type' => 0,
  133. 'data' => $this->stripeWepay($order)
  134. ]);
  135. case 4:
  136. // bitpayX
  137. if (!(int)config('v2board.bitpayx_enable')) {
  138. abort(500, '支付方式不可用');
  139. }
  140. return response([
  141. 'type' => 1,
  142. 'data' => $this->bitpayX($order)
  143. ]);
  144. default:
  145. abort(500, '支付方式不存在');
  146. }
  147. }
  148. public function check (Request $request) {
  149. $tradeNo = $request->input('trade_no');
  150. $order = Order::where('trade_no', $tradeNo)
  151. ->where('user_id', $request->session()->get('id'))
  152. ->first();
  153. if (!$order) {
  154. abort(500, '订单不存在');
  155. }
  156. return response([
  157. 'data' => $order->status
  158. ]);
  159. }
  160. public function getPaymentMethod () {
  161. $data = [];
  162. if ((int)config('v2board.alipay_enable')) {
  163. $alipayF2F = new \StdClass();
  164. $alipayF2F->name = '支付宝';
  165. $alipayF2F->method = 0;
  166. $alipayF2F->icon = 'alipay';
  167. array_push($data, $alipayF2F);
  168. }
  169. if ((int)config('v2board.stripe_alipay_enable')) {
  170. $stripeAlipay = new \StdClass();
  171. $stripeAlipay->name = '支付宝';
  172. $stripeAlipay->method = 2;
  173. $stripeAlipay->icon = 'alipay';
  174. array_push($data, $stripeAlipay);
  175. }
  176. if ((int)config('v2board.stripe_wepay_enable')) {
  177. $stripeWepay = new \StdClass();
  178. $stripeWepay->name = '微信';
  179. $stripeWepay->method = 3;
  180. $stripeWepay->icon = 'wechat';
  181. array_push($data, $stripeWepay);
  182. }
  183. if ((int)config('v2board.bitpayx_enable')) {
  184. $bitpayX = new \StdClass();
  185. $bitpayX->name = '虚拟货币';
  186. $bitpayX->method = 4;
  187. $bitpayX->icon = 'bitcoin';
  188. array_push($data, $bitpayX);
  189. }
  190. return response([
  191. 'data' => $data
  192. ]);
  193. }
  194. private function alipayF2F ($tradeNo, $totalAmount) {
  195. $gateway = Omnipay::create('Alipay_AopF2F');
  196. $gateway->setSignType('RSA2'); //RSA/RSA2
  197. $gateway->setAppId(config('v2board.alipay_appid'));
  198. $gateway->setPrivateKey(config('v2board.alipay_privkey')); // 可以是路径,也可以是密钥内容
  199. $gateway->setAlipayPublicKey(config('v2board.alipay_pubkey')); // 可以是路径,也可以是密钥内容
  200. $gateway->setNotifyUrl(url('/api/v1/guest/order/alipayNotify'));
  201. $request = $gateway->purchase();
  202. $request->setBizContent([
  203. 'subject' => config('v2board.app_name', 'V2Board') . ' - 订阅',
  204. 'out_trade_no' => $tradeNo,
  205. 'total_amount' => $totalAmount / 100
  206. ]);
  207. /** @var \Omnipay\Alipay\Responses\AopTradePreCreateResponse $response */
  208. $response = $request->send();
  209. $result = $response->getAlipayResponse();
  210. if ($result['code'] !== '10000') {
  211. abort(500, $result['sub_msg']);
  212. }
  213. // 获取收款二维码内容
  214. return $response->getQrCode();
  215. }
  216. private function stripeAlipay ($order) {
  217. $exchange = Helper::exchange('CNY', 'HKD');
  218. if (!$exchange) {
  219. abort(500, '货币转换超时,请稍后再试');
  220. }
  221. Stripe::setApiKey(config('v2board.stripe_sk_live'));
  222. $source = Source::create([
  223. 'amount' => floor($order->total_amount * $exchange),
  224. 'currency' => 'hkd',
  225. 'type' => 'alipay',
  226. 'redirect' => [
  227. 'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  228. ]
  229. ]);
  230. if (!$source['redirect']['url']) {
  231. abort(500, '支付网关请求失败');
  232. }
  233. if (!Redis::set($source['id'], $order->trade_no)) {
  234. abort(500, '订单创建失败');
  235. }
  236. Redis::expire($source['id'], 3600);
  237. return $source['redirect']['url'];
  238. }
  239. private function stripeWepay ($order) {
  240. $exchange = Helper::exchange('CNY', 'HKD');
  241. if (!$exchange) {
  242. abort(500, '货币转换超时,请稍后再试');
  243. }
  244. Stripe::setApiKey(config('v2board.stripe_sk_live'));
  245. $source = Source::create([
  246. 'amount' => floor($order->total_amount * $exchange),
  247. 'currency' => 'hkd',
  248. 'type' => 'wechat',
  249. 'redirect' => [
  250. 'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  251. ]
  252. ]);
  253. if (!$source['wechat']['qr_code_url']) {
  254. abort(500, '支付网关请求失败');
  255. }
  256. if (!Redis::set($source['id'], $order->trade_no)) {
  257. abort(500, '订单创建失败');
  258. }
  259. Redis::expire($source['id'], 3600);
  260. return $source['wechat']['qr_code_url'];
  261. }
  262. private function bitpayX ($order) {
  263. $bitpayX = new BitpayX(config('v2board.bitpayx_appsecret'));
  264. $params = [
  265. 'merchant_order_id' => 'V2Board_' . $order->trade_no,
  266. 'price_amount' => $order->total_amount / 100,
  267. 'price_currency' => 'CNY',
  268. 'title' => '支付单号:' . $order->trade_no,
  269. 'description' => '充值:' . $order->total_amount / 100 . ' 元',
  270. 'callback_url' => url('/api/v1/guest/order/bitpayXNotify'),
  271. 'success_url' => config('v2board.app_url', env('APP_URL')) . '/#/order',
  272. 'cancel_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  273. ];
  274. $strToSign = $bitpayX->prepareSignId($params['merchant_order_id']);
  275. $params['token'] = $bitpayX->sign($strToSign);
  276. $result = $bitpayX->mprequest($params);
  277. Log::info('bitpayXSubmit: ' . json_encode($result));
  278. return isset($result['payment_url']) ? $result['payment_url'] : false;
  279. }
  280. }