OrderController.php 14 KB

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