BitpayX.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. <?php
  2. namespace App\Http\Controllers\Gateway;
  3. use App\Models\Payment;
  4. use Auth;
  5. use GuzzleHttp\Client;
  6. use Illuminate\Http\JsonResponse;
  7. use Log;
  8. use Response;
  9. class BitpayX extends AbstractPayment
  10. {
  11. public function purchase($request): JsonResponse
  12. {
  13. $payment = $this->creatNewPayment(
  14. Auth::id(),
  15. $request->input('id'),
  16. $request->input('amount')
  17. );
  18. $data = [
  19. 'merchant_order_id' => $payment->trade_no,
  20. 'price_amount' => $payment->amount,
  21. 'price_currency' => 'CNY',
  22. 'title' => '支付单号:' . $payment->trade_no,
  23. 'description' => sysConfig('subject_name') ?: sysConfig(
  24. 'website_name'
  25. ),
  26. 'callback_url' => (sysConfig(
  27. 'website_callback_url'
  28. ) ?: sysConfig(
  29. 'website_url'
  30. )) . '/callback/notify?method=bitpayx',
  31. 'success_url' => sysConfig('website_url') . '/invoices',
  32. 'cancel_url' => sysConfig('website_url') . '/invoices',
  33. 'token' => $this->sign($payment->trade_no),
  34. ];
  35. $result = $this->sendRequest($data);
  36. if ($result['status'] === 200 || $result['status'] === 201) {
  37. $result['payment_url'] .= '&lang=zh';
  38. $payment->update(['url' => $result['payment_url']]);
  39. return Response::json(
  40. [
  41. 'status' => 'success',
  42. 'url' => $result['payment_url'],
  43. 'message' => '创建订单成功!',
  44. ]
  45. );
  46. }
  47. Log::error('创建订单错误:' . var_export($result, true));
  48. return Response::json(
  49. ['status' => 'fail', 'message' => '创建订单失败!' . $result['error']]
  50. );
  51. }
  52. private function sign($tradeNo): string
  53. {
  54. $data = [
  55. 'merchant_order_id' => $tradeNo,
  56. 'secret' => sysConfig('bitpay_secret'),
  57. 'type' => 'FIAT',
  58. ];
  59. return $this->aliStyleSign($data, sysConfig('bitpay_secret'));
  60. }
  61. private function sendRequest($data, $type = 'createOrder')
  62. {
  63. $client = new Client(
  64. [
  65. 'base_uri' => 'https://api.mugglepay.com/v1/',
  66. 'timeout' => 15,
  67. 'headers' => [
  68. 'token' => sysConfig('bitpay_secret'),
  69. 'content-type' => 'application/json',
  70. ],
  71. ]
  72. );
  73. if ($type === 'query') {
  74. $request = $client->get(
  75. 'orders/merchant_order_id/status?id=' . $data['merchant_order_id']
  76. );
  77. } else {// Create Order
  78. $request = $client->post('orders', ['body' => json_encode($data)]);
  79. }
  80. if ($request->getStatusCode() !== 200) {
  81. Log::error('BitPayX请求支付错误:' . var_export($request, true));
  82. }
  83. return json_decode($request->getBody(), true);
  84. }
  85. //Todo: Postman虚拟测试通过,需要真实数据参考验证
  86. public function notify($request): void
  87. {
  88. $tradeNo = $request->input(['merchant_order_id']);
  89. if ($request->input(['status']) === 'PAID' && hash_equals(
  90. $this->sign($tradeNo),
  91. $request->input(['token'])
  92. )) {
  93. $payment = Payment::whereTradeNo($tradeNo)->first();
  94. if ($payment) {
  95. $ret = $payment->order->update(['status' => 2]);
  96. if ($ret) {
  97. exit(json_encode(['status' => 200]));
  98. }
  99. }
  100. }
  101. exit(json_encode(['status' => 400]));
  102. }
  103. }