OrderController.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430
  1. <?php
  2. namespace App\Http\Controllers\User;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\User\OrderSave;
  5. use Illuminate\Http\Request;
  6. use Illuminate\Support\Facades\Cache;
  7. use Illuminate\Support\Facades\Log;
  8. use Illuminate\Support\Facades\DB;
  9. use App\Models\Order;
  10. use App\Models\Plan;
  11. use App\Models\User;
  12. use App\Models\Coupon;
  13. use App\Utils\Helper;
  14. use Omnipay\Omnipay;
  15. use Stripe\Stripe;
  16. use Stripe\Source;
  17. use Library\BitpayX;
  18. use Library\PayTaro;
  19. class OrderController extends Controller
  20. {
  21. public function fetch(Request $request)
  22. {
  23. $model = Order::where('user_id', $request->session()->get('id'))
  24. ->orderBy('created_at', 'DESC');
  25. if ($request->input('status') !== null) {
  26. $model->where('status', $request->input('status'));
  27. }
  28. $order = $model->get();
  29. $plan = Plan::get();
  30. for ($i = 0; $i < count($order); $i++) {
  31. for ($x = 0; $x < count($plan); $x++) {
  32. if ($order[$i]['plan_id'] === $plan[$x]['id']) {
  33. $order[$i]['plan'] = $plan[$x];
  34. }
  35. }
  36. }
  37. return response([
  38. 'data' => $order
  39. ]);
  40. }
  41. public function details(Request $request)
  42. {
  43. $order = Order::where('user_id', $request->session()->get('id'))
  44. ->where('trade_no', $request->input('trade_no'))
  45. ->first();
  46. if (!$order) {
  47. abort(500, '订单不存在');
  48. }
  49. $order['plan'] = Plan::find($order->plan_id);
  50. $order['plan_transfer_hour'] = config('v2board.plan_transfer_hour', 12);
  51. $order['try_out_plan_id'] = (int)config('v2board.try_out_plan_id');
  52. if (!$order['plan']) {
  53. abort(500, '订阅不存在');
  54. }
  55. return response([
  56. 'data' => $order
  57. ]);
  58. }
  59. private function isExistNotPayOrderByUserId($userId)
  60. {
  61. $order = Order::where('status', 0)
  62. ->where('user_id', $userId)
  63. ->first();
  64. if (!$order) {
  65. return false;
  66. }
  67. return true;
  68. }
  69. public function save(OrderSave $request)
  70. {
  71. if ($this->isExistNotPayOrderByUserId($request->session()->get('id'))) {
  72. abort(500, '存在未付款订单,请取消后再试');
  73. }
  74. $plan = Plan::find($request->input('plan_id'));
  75. $user = User::find($request->session()->get('id'));
  76. if (!$plan) {
  77. abort(500, '该订阅不存在');
  78. }
  79. if (!($plan->show || $user->plan_id == $plan->id)) {
  80. abort(500, '该订阅已售罄');
  81. }
  82. if (!$plan->show && !$plan->renew) {
  83. abort(500, '该订阅无法续费,请更换其他订阅');
  84. }
  85. if ($plan[$request->input('cycle')] === NULL) {
  86. abort(500, '该订阅周期无法进行购买,请选择其他周期');
  87. }
  88. if ($request->input('coupon_code')) {
  89. $coupon = Coupon::where('code', $request->input('coupon_code'))->first();
  90. if (!$coupon) {
  91. abort(500, '优惠券无效');
  92. }
  93. if ($coupon->limit_use <= 0 && $coupon->limit_use !== NULL) {
  94. abort(500, '优惠券已无可用次数');
  95. }
  96. if (time() < $coupon->started_at) {
  97. abort(500, '优惠券还未到可用时间');
  98. }
  99. if (time() > $coupon->ended_at) {
  100. abort(500, '优惠券已过期');
  101. }
  102. }
  103. DB::beginTransaction();
  104. $order = new Order();
  105. $order->user_id = $request->session()->get('id');
  106. $order->plan_id = $plan->id;
  107. $order->cycle = $request->input('cycle');
  108. $order->trade_no = Helper::guid();
  109. $order->total_amount = $plan[$request->input('cycle')];
  110. // renew and change subscribe process
  111. if ($user->expired_at > time() && $order->plan_id !== $user->plan_id) {
  112. $order->type = 3;
  113. if (!(int)config('v2board.plan_change_enable', 1)) abort(500, '目前不允许更改订阅,请联系管理员');
  114. } else if ($user->expired_at > time() && $order->plan_id == $user->plan_id) {
  115. $order->type = 2;
  116. } else {
  117. $order->type = 1;
  118. }
  119. // coupon process
  120. if (isset($coupon)) {
  121. switch ($coupon->type) {
  122. case 1:
  123. $order->discount_amount = $coupon->value;
  124. break;
  125. case 2:
  126. $order->discount_amount = $order->total_amount * ($coupon->value / 100);
  127. break;
  128. }
  129. $order->total_amount = $order->total_amount - $order->discount_amount;
  130. if ($coupon->limit_use !== NULL) {
  131. $coupon->limit_use = $coupon->limit_use - 1;
  132. if (!$coupon->save()) {
  133. DB::rollback();
  134. abort(500, '优惠券使用失败');
  135. }
  136. }
  137. }
  138. // free process
  139. if ($order->total_amount <= 0) {
  140. $order->total_amount = 0;
  141. $order->status = 1;
  142. }
  143. // invite process
  144. if ($user->invite_user_id && $order->total_amount > 0) {
  145. $order->invite_user_id = $user->invite_user_id;
  146. $inviter = User::find($user->invite_user_id);
  147. if ($inviter && $inviter->commission_rate) {
  148. $order->commission_balance = $order->total_amount * ($inviter->commission_rate / 100);
  149. } else {
  150. $order->commission_balance = $order->total_amount * (config('v2board.invite_commission', 10) / 100);
  151. }
  152. }
  153. if (!$order->save()) {
  154. DB::rollback();
  155. abort(500, '订单创建失败');
  156. }
  157. DB::commit();
  158. return response([
  159. 'data' => $order->trade_no
  160. ]);
  161. }
  162. public function checkout(Request $request)
  163. {
  164. $tradeNo = $request->input('trade_no');
  165. $method = $request->input('method');
  166. $order = Order::where('trade_no', $tradeNo)
  167. ->where('user_id', $request->session()->get('id'))
  168. ->where('status', 0)
  169. ->first();
  170. if (!$order) {
  171. abort(500, '订单不存在或已支付');
  172. }
  173. switch ($method) {
  174. // return type => 0: QRCode / 1: URL
  175. case 0:
  176. // alipayF2F
  177. if (!(int)config('v2board.alipay_enable')) {
  178. abort(500, '支付方式不可用');
  179. }
  180. return response([
  181. 'type' => 0,
  182. 'data' => $this->alipayF2F($tradeNo, $order->total_amount)
  183. ]);
  184. case 2:
  185. // stripeAlipay
  186. if (!(int)config('v2board.stripe_alipay_enable')) {
  187. abort(500, '支付方式不可用');
  188. }
  189. return response([
  190. 'type' => 1,
  191. 'data' => $this->stripeAlipay($order)
  192. ]);
  193. case 3:
  194. // stripeWepay
  195. if (!(int)config('v2board.stripe_wepay_enable')) {
  196. abort(500, '支付方式不可用');
  197. }
  198. return response([
  199. 'type' => 0,
  200. 'data' => $this->stripeWepay($order)
  201. ]);
  202. case 4:
  203. // bitpayX
  204. if (!(int)config('v2board.bitpayx_enable')) {
  205. abort(500, '支付方式不可用');
  206. }
  207. return response([
  208. 'type' => 1,
  209. 'data' => $this->bitpayX($order)
  210. ]);
  211. case 5:
  212. if (!(int)config('v2board.paytaro_enable')) {
  213. abort(500, '支付方式不可用');
  214. }
  215. return response([
  216. 'type' => 1,
  217. 'data' => $this->payTaro($order)
  218. ]);
  219. default:
  220. abort(500, '支付方式不存在');
  221. }
  222. }
  223. public function check(Request $request)
  224. {
  225. $tradeNo = $request->input('trade_no');
  226. $order = Order::where('trade_no', $tradeNo)
  227. ->where('user_id', $request->session()->get('id'))
  228. ->first();
  229. if (!$order) {
  230. abort(500, '订单不存在');
  231. }
  232. return response([
  233. 'data' => $order->status
  234. ]);
  235. }
  236. public function getPaymentMethod()
  237. {
  238. $data = [];
  239. if ((int)config('v2board.alipay_enable')) {
  240. $alipayF2F = new \StdClass();
  241. $alipayF2F->name = '支付宝';
  242. $alipayF2F->method = 0;
  243. $alipayF2F->icon = 'alipay';
  244. array_push($data, $alipayF2F);
  245. }
  246. if ((int)config('v2board.stripe_alipay_enable')) {
  247. $stripeAlipay = new \StdClass();
  248. $stripeAlipay->name = '支付宝';
  249. $stripeAlipay->method = 2;
  250. $stripeAlipay->icon = 'alipay';
  251. array_push($data, $stripeAlipay);
  252. }
  253. if ((int)config('v2board.stripe_wepay_enable')) {
  254. $stripeWepay = new \StdClass();
  255. $stripeWepay->name = '微信';
  256. $stripeWepay->method = 3;
  257. $stripeWepay->icon = 'wechat';
  258. array_push($data, $stripeWepay);
  259. }
  260. if ((int)config('v2board.bitpayx_enable')) {
  261. $bitpayX = new \StdClass();
  262. $bitpayX->name = '聚合支付';
  263. $bitpayX->method = 4;
  264. $bitpayX->icon = 'wallet';
  265. array_push($data, $bitpayX);
  266. }
  267. if ((int)config('v2board.paytaro_enable')) {
  268. $obj = new \StdClass();
  269. $obj->name = '聚合支付';
  270. $obj->method = 5;
  271. $obj->icon = 'wallet';
  272. array_push($data, $obj);
  273. }
  274. return response([
  275. 'data' => $data
  276. ]);
  277. }
  278. public function cancel(Request $request)
  279. {
  280. if (empty($request->input('trade_no'))) {
  281. abort(500, '参数有误');
  282. }
  283. $order = Order::where('trade_no', $request->input('trade_no'))
  284. ->where('user_id', $request->session()->get('id'))
  285. ->first();
  286. if (!$order) {
  287. abort(500, '订单不存在');
  288. }
  289. if ($order->status !== 0) {
  290. abort(500, '只可以取消待支付订单');
  291. }
  292. $order->status = 2;
  293. if (!$order->save()) {
  294. abort(500, '取消失败');
  295. }
  296. return response([
  297. 'data' => true
  298. ]);
  299. }
  300. private function alipayF2F($tradeNo, $totalAmount)
  301. {
  302. $gateway = Omnipay::create('Alipay_AopF2F');
  303. $gateway->setSignType('RSA2'); //RSA/RSA2
  304. $gateway->setAppId(config('v2board.alipay_appid'));
  305. $gateway->setPrivateKey(config('v2board.alipay_privkey')); // 可以是路径,也可以是密钥内容
  306. $gateway->setAlipayPublicKey(config('v2board.alipay_pubkey')); // 可以是路径,也可以是密钥内容
  307. $gateway->setNotifyUrl(url('/api/v1/guest/order/alipayNotify'));
  308. $request = $gateway->purchase();
  309. $request->setBizContent([
  310. 'subject' => config('v2board.app_name', 'V2Board') . ' - 订阅',
  311. 'out_trade_no' => $tradeNo,
  312. 'total_amount' => $totalAmount / 100
  313. ]);
  314. /** @var \Omnipay\Alipay\Responses\AopTradePreCreateResponse $response */
  315. $response = $request->send();
  316. $result = $response->getAlipayResponse();
  317. if ($result['code'] !== '10000') {
  318. abort(500, $result['sub_msg']);
  319. }
  320. // 获取收款二维码内容
  321. return $response->getQrCode();
  322. }
  323. private function stripeAlipay($order)
  324. {
  325. $exchange = Helper::exchange('CNY', 'HKD');
  326. if (!$exchange) {
  327. abort(500, '货币转换超时,请稍后再试');
  328. }
  329. Stripe::setApiKey(config('v2board.stripe_sk_live'));
  330. $source = Source::create([
  331. 'amount' => floor($order->total_amount * $exchange),
  332. 'currency' => 'hkd',
  333. 'type' => 'alipay',
  334. 'redirect' => [
  335. 'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  336. ]
  337. ]);
  338. if (!$source['redirect']['url']) {
  339. abort(500, '支付网关请求失败');
  340. }
  341. if (!Cache::put($source['id'], $order->trade_no, 3600)) {
  342. abort(500, '订单创建失败');
  343. }
  344. return $source['redirect']['url'];
  345. }
  346. private function stripeWepay($order)
  347. {
  348. $exchange = Helper::exchange('CNY', 'HKD');
  349. if (!$exchange) {
  350. abort(500, '货币转换超时,请稍后再试');
  351. }
  352. Stripe::setApiKey(config('v2board.stripe_sk_live'));
  353. $source = Source::create([
  354. 'amount' => floor($order->total_amount * $exchange),
  355. 'currency' => 'hkd',
  356. 'type' => 'wechat',
  357. 'redirect' => [
  358. 'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  359. ]
  360. ]);
  361. if (!$source['wechat']['qr_code_url']) {
  362. abort(500, '支付网关请求失败');
  363. }
  364. if (!Cache::put($source['id'], $order->trade_no, 3600)) {
  365. abort(500, '订单创建失败');
  366. }
  367. return $source['wechat']['qr_code_url'];
  368. }
  369. private function bitpayX($order)
  370. {
  371. $bitpayX = new BitpayX(config('v2board.bitpayx_appsecret'));
  372. $params = [
  373. 'merchant_order_id' => $order->trade_no,
  374. 'price_amount' => $order->total_amount / 100,
  375. 'price_currency' => 'CNY',
  376. 'title' => '支付单号:' . $order->trade_no,
  377. 'description' => '充值:' . $order->total_amount / 100 . ' 元',
  378. 'callback_url' => url('/api/v1/guest/order/bitpayXNotify'),
  379. 'success_url' => config('v2board.app_url', env('APP_URL')) . '/#/order',
  380. 'cancel_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  381. ];
  382. $strToSign = $bitpayX->prepareSignId($params['merchant_order_id']);
  383. $params['token'] = $bitpayX->sign($strToSign);
  384. $result = $bitpayX->mprequest($params);
  385. Log::info('bitpayXSubmit: ' . json_encode($result));
  386. return isset($result['payment_url']) ? $result['payment_url'] : false;
  387. }
  388. private function payTaro($order)
  389. {
  390. $payTaro = new PayTaro(config('v2board.paytaro_app_id'), config('v2board.paytaro_app_secret'));
  391. $result = $payTaro->pay([
  392. 'app_id' => config('v2board.paytaro_app_id'),
  393. 'out_trade_no' => $order->trade_no,
  394. 'total_amount' => $order->total_amount,
  395. 'notify_url' => url('/api/v1/guest/order/payTaroNotify'),
  396. 'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
  397. ]);
  398. return $result;
  399. }
  400. }