PaymentController.php 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Yzy;
  4. use App\Http\Models\Coupon;
  5. use App\Http\Models\Goods;
  6. use App\Http\Models\Order;
  7. use App\Http\Models\Payment;
  8. use App\Http\Models\PaymentCallback;
  9. use Illuminate\Http\Request;
  10. use Response;
  11. use Redirect;
  12. use Log;
  13. use DB;
  14. class PaymentController extends Controller
  15. {
  16. protected static $config;
  17. function __construct()
  18. {
  19. self::$config = $this->systemConfig();
  20. }
  21. // 创建支付单
  22. public function create(Request $request)
  23. {
  24. $goods_id = intval($request->get('goods_id'));
  25. $coupon_sn = $request->get('coupon_sn');
  26. $user = $request->session()->get('user');
  27. $goods = Goods::query()->where('id', $goods_id)->where('status', 1)->first();
  28. if (!$goods) {
  29. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:商品或服务已下架']);
  30. }
  31. // 判断是否开启有赞云支付
  32. if (!self::$config['is_youzan']) {
  33. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:系统并未开启在线支付功能']);
  34. }
  35. // 判断是否存在同个商品的未支付订单
  36. $existsOrder = Order::query()->where('goods_id', $goods_id)->where('status', 0)->where('user_id', $user['id'])->first();
  37. if ($existsOrder) {
  38. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:尚有未支付的订单,请先去支付']);
  39. }
  40. // 限购控制
  41. $strategy = self::$config['goods_purchase_limit_strategy'];
  42. if ($strategy == 'all' || ($strategy == 'free' && $goods->price == 0)) {
  43. // 判断是否已经购买过该商品
  44. $none_expire_good_exist = Order::query()->where('user_id', $user['id'])->where('goods_id', $goods_id)->where('is_expire', 0)->exists();
  45. if ($none_expire_good_exist) {
  46. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:商品不可重复购买']);
  47. }
  48. }
  49. // 使用优惠券
  50. if ($coupon_sn) {
  51. $coupon = Coupon::query()->where('sn', $coupon_sn)->whereIn('type', [1, 2])->where('is_del', 0)->where('status', 0)->first();
  52. if (!$coupon) {
  53. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:优惠券不存在']);
  54. }
  55. // 计算实际应支付总价
  56. $amount = $coupon->type == 2 ? $goods->price * $coupon->discount / 10 : $goods->price - $coupon->amount;
  57. $amount = $amount > 0 ? $amount : 0;
  58. } else {
  59. $amount = $goods->price;
  60. }
  61. // 如果最后总价格为0,则不允许创建支付单
  62. if ($amount <= 0) {
  63. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:合计价格为0,无需使用在线支付']);
  64. }
  65. DB::beginTransaction();
  66. try {
  67. $user = $request->session()->get('user');
  68. $orderSn = date('ymdHis') . mt_rand(100000, 999999);
  69. $sn = makeRandStr(12);
  70. // 生成订单
  71. $order = new Order();
  72. $order->order_sn = $orderSn;
  73. $order->user_id = $user['id'];
  74. $order->goods_id = $goods_id;
  75. $order->coupon_id = !empty($coupon) ? $coupon->id : 0;
  76. $order->origin_amount = $goods->price;
  77. $order->amount = $amount;
  78. $order->expire_at = date("Y-m-d H:i:s", strtotime("+" . $goods->days . " days"));
  79. $order->is_expire = 0;
  80. $order->pay_way = 2;
  81. $order->status = 0;
  82. $order->save();
  83. // 生成支付单
  84. $yzy = new Yzy();
  85. $result = $yzy->createQrCode($goods->name, $amount * 100, $orderSn);
  86. if (isset($result['error_response'])) {
  87. Log::error('【有赞云】创建二维码失败:' . $result['error_response']['msg']);
  88. throw new \Exception($result['error_response']['msg']);
  89. }
  90. $payment = new Payment();
  91. $payment->sn = $sn;
  92. $payment->user_id = $user['id'];
  93. $payment->oid = $order->oid;
  94. $payment->order_sn = $orderSn;
  95. $payment->pay_way = 1;
  96. $payment->amount = $amount;
  97. $payment->qr_id = $result['response']['qr_id'];
  98. $payment->qr_url = $result['response']['qr_url'];
  99. $payment->qr_code = $result['response']['qr_code'];
  100. $payment->qr_local_url = $this->base64ImageSaver($result['response']['qr_code']);
  101. $payment->status = 0;
  102. $payment->save();
  103. DB::commit();
  104. return Response::json(['status' => 'success', 'data' => $sn, 'message' => '创建支付单成功']);
  105. } catch (\Exception $e) {
  106. DB::rollBack();
  107. Log::error('创建支付订单失败:' . $e->getMessage());
  108. return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败:' . $e->getMessage()]);
  109. }
  110. }
  111. // 支付单详情
  112. public function detail(Request $request, $sn)
  113. {
  114. if (empty($sn)) {
  115. return Redirect::to('user/goodsList');
  116. }
  117. $user = $request->session()->get('user');
  118. $payment = Payment::query()->with(['order', 'order.goods'])->where('sn', $sn)->where('user_id', $user['id'])->first();
  119. if (!$payment) {
  120. return Redirect::to('user/goodsList');
  121. }
  122. $order = Order::query()->where('oid', $payment->oid)->first();
  123. if (!$order) {
  124. $request->session()->flash('errorMsg', '订单不存在');
  125. return Response::view('payment/' . $sn);
  126. }
  127. $view['payment'] = $payment;
  128. $view['website_analytics'] = self::$config['website_analytics'];
  129. $view['website_customer_service'] = self::$config['website_customer_service'];
  130. return Response::view('payment/detail', $view);
  131. }
  132. // 获取订单支付状态
  133. public function getStatus(Request $request)
  134. {
  135. $sn = $request->get('sn');
  136. if (empty($sn)) {
  137. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请求失败']);
  138. }
  139. $user = $request->session()->get('user');
  140. $payment = Payment::query()->where('sn', $sn)->where('user_id', $user['id'])->first();
  141. if (!$payment) {
  142. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败']);
  143. }
  144. if ($payment->status) {
  145. return Response::json(['status' => 'success', 'data' => '', 'message' => '支付成功']);
  146. } else if ($payment->status < 0) {
  147. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败']);
  148. } else {
  149. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等待支付']);
  150. }
  151. }
  152. // 有赞云回调日志
  153. public function callbackList(Request $request)
  154. {
  155. $status = $request->get('status', 0);
  156. $query = PaymentCallback::query();
  157. if ($status) {
  158. $query->where('status', $status);
  159. }
  160. $view['list'] = $query->orderBy('id', 'desc')->paginate(10);
  161. return Response::view('payment/callbackList', $view);
  162. }
  163. }