EPay.php 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  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 Illuminate\Http\Request;
  8. use Response;
  9. class EPay extends AbstractPayment
  10. {
  11. public function purchase(Request $request): JsonResponse
  12. {
  13. $payment = $this->creatNewPayment(
  14. Auth::id(),
  15. $request->input('id'),
  16. $request->input('amount')
  17. );
  18. switch ($request->input('type')) {
  19. case 2:
  20. $type = 'qqpay';
  21. break;
  22. case 3:
  23. $type = 'wxpay';
  24. break;
  25. case 1:
  26. default:
  27. $type = 'alipay';
  28. break;
  29. }
  30. $data = [
  31. 'pid' => sysConfig('epay_mch_id'),
  32. 'type' => $type,
  33. 'notify_url' => (sysConfig('website_callback_url') ?: sysConfig(
  34. 'website_url'
  35. )) . '/callback/notify?method=epay',
  36. 'return_url' => sysConfig('website_url') . '/invoices',
  37. 'out_trade_no' => $payment->trade_no,
  38. 'name' => sysConfig('subject_name') ?: sysConfig(
  39. 'website_name'
  40. ),
  41. 'money' => $payment->amount,
  42. 'sign_type' => 'MD5',
  43. ];
  44. $data['sign'] = $this->aliStyleSign($data, sysConfig('epay_key'));
  45. $url = sysConfig('epay_url') . 'submit.php?' . http_build_query($data);
  46. $payment->update(['url' => $url]);
  47. return Response::json(
  48. ['status' => 'success', 'url' => $url, 'message' => '创建订单成功!']
  49. );
  50. }
  51. public function notify(Request $request): void
  52. {
  53. if ($request->input('trade_status') === 'TRADE_SUCCESS'
  54. && $this->verify(
  55. $request->except('method'),
  56. sysConfig('epay_key'),
  57. $request->input('sign')
  58. )) {
  59. $payment = Payment::whereTradeNo($request->input('out_trade_no'))
  60. ->first();
  61. if ($payment) {
  62. $ret = $payment->order->update(['status' => 2]);
  63. if ($ret) {
  64. exit('SUCCESS');
  65. }
  66. }
  67. }
  68. exit('FAIL');
  69. }
  70. public function queryInfo(): JsonResponse
  71. {
  72. $request = (new Client())->get(
  73. sysConfig('epay_url') . 'api.php',
  74. [
  75. 'query' => [
  76. 'act' => 'query',
  77. 'pid' => sysConfig('epay_mch_id'),
  78. 'key' => sysConfig('epay_key'),
  79. ],
  80. ]
  81. );
  82. if ($request->getStatusCode() == 200) {
  83. return Response::json(
  84. [
  85. 'status' => 'success',
  86. 'data' => json_decode($request->getBody(), true),
  87. ]
  88. );
  89. }
  90. return Response::json(
  91. ['status' => 'fail', 'message' => '获取失败!请检查配置信息']
  92. );
  93. }
  94. }