PaymentController.php 7.7 KB

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