BitpayX.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. <?php
  2. namespace App\Http\Controllers\Gateway;
  3. use Auth;
  4. use Illuminate\Http\JsonResponse;
  5. use Log;
  6. use Response;
  7. class BitpayX extends AbstractPayment
  8. {
  9. public function purchase($request): JsonResponse
  10. {
  11. $payment = $this->creatNewPayment(Auth::id(), $request->input('id'), $request->input('amount'));
  12. $data = [
  13. 'merchant_order_id' => $payment->trade_no,
  14. 'price_amount' => (float) $payment->amount,
  15. 'price_currency' => 'CNY',
  16. 'title' => '支付单号:'.$payment->trade_no,
  17. 'description' => sysConfig('subject_name') ?: sysConfig('website_name'),
  18. 'callback_url' => route('payment.notify', ['method' => 'bitpayx']),
  19. 'success_url' => route('invoice'),
  20. 'cancel_url' => route('invoice'),
  21. 'token' => $this->sign($this->prepareSignId($payment->trade_no)),
  22. ];
  23. if ($request->input('type') == 1) {
  24. $data['pay_currency'] = 'ALIPAY';
  25. } elseif ($request->input('type') == 3) {
  26. $data['pay_currency'] = 'WECHAT';
  27. }
  28. $result = $this->sendRequest($data);
  29. if ($result['status'] === 200 || $result['status'] === 201) {
  30. $result['payment_url'] .= '&lang=zh';
  31. $payment->update(['url' => $result['payment_url']]);
  32. return Response::json(['status' => 'success', 'url' => $result['payment_url'], 'message' => '创建订单成功!']);
  33. }
  34. Log::alert('【BitpayX】创建订单错误:'.var_export($result, true));
  35. return Response::json(['status' => 'fail', 'message' => '创建订单失败! 请联系管理员']);
  36. }
  37. private function sign($data)
  38. {
  39. return strtolower(md5(md5($data).sysConfig('bitpay_secret')));
  40. }
  41. private function prepareSignId($tradeNo): string
  42. {
  43. $data = [
  44. 'merchant_order_id' => $tradeNo,
  45. 'secret' => sysConfig('bitpay_secret'),
  46. 'type' => 'FIAT',
  47. ];
  48. ksort($data, SORT_STRING);
  49. return http_build_query($data);
  50. }
  51. private function sendRequest($data, $type = 'createOrder')
  52. {
  53. $bitpayGatewayUri = 'https://api.mugglepay.com/v1/';
  54. $headers = ['content-type: application/json', 'token: '.sysConfig('bitpay_secret')];
  55. $curl = curl_init();
  56. if ($type === 'createOrder') {
  57. $bitpayGatewayUri .= 'orders';
  58. curl_setopt($curl, CURLOPT_URL, $bitpayGatewayUri);
  59. curl_setopt($curl, CURLOPT_POST, 1);
  60. $data_string = json_encode($data);
  61. curl_setopt($curl, CURLOPT_POSTFIELDS, $data_string);
  62. } elseif ($type === 'query') {
  63. $bitpayGatewayUri .= 'orders/merchant_order_id/status?id='.$data['merchant_order_id'];
  64. curl_setopt($curl, CURLOPT_URL, $bitpayGatewayUri);
  65. curl_setopt($curl, CURLOPT_HTTPGET, 1);
  66. }
  67. curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
  68. curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
  69. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
  70. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
  71. $result = curl_exec($curl);
  72. curl_close($curl);
  73. return json_decode($result, true);
  74. }
  75. public function notify($request): void
  76. {
  77. $tradeNo = $request->input(['merchant_order_id']);
  78. // 准备待签名数据
  79. $str_to_sign = $this->prepareSignId($tradeNo);
  80. if ($request->input(['status']) === 'PAID' && $this->verify_bit($str_to_sign, $request->input(['token']))) {
  81. if ($this->paymentReceived($tradeNo)) {
  82. exit(json_encode(['status' => 200]));
  83. }
  84. } else {
  85. Log::error('【BitpayX】交易失败:'.var_export($request->all(), true));
  86. }
  87. exit(json_encode(['status' => 400]));
  88. }
  89. private function verify_bit($data, $signature)
  90. {
  91. $mySign = $this->sign($data);
  92. return $mySign === $signature;
  93. }
  94. }