PaymentController.php 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Http\Controllers\Gateway\BitpayX;
  5. use App\Http\Controllers\Gateway\CodePay;
  6. use App\Http\Controllers\Gateway\EPay;
  7. use App\Http\Controllers\Gateway\F2Fpay;
  8. use App\Http\Controllers\Gateway\Local;
  9. use App\Http\Controllers\Gateway\PayJs;
  10. use App\Http\Controllers\Gateway\PayPal;
  11. use App\Models\Coupon;
  12. use App\Models\Goods;
  13. use App\Models\Order;
  14. use App\Models\Payment;
  15. use App\Models\PaymentCallback;
  16. use Auth;
  17. use Illuminate\Http\JsonResponse;
  18. use Illuminate\Http\Request;
  19. use Log;
  20. use Response;
  21. /**
  22. * 支付控制器
  23. *
  24. * Class PaymentController
  25. *
  26. * @package App\Http\Controllers
  27. */
  28. class PaymentController extends Controller {
  29. private static $method;
  30. public static function notify(Request $request): int {
  31. self::$method = $request->input('method');
  32. Log::info(self::$method."回调接口[POST]:".self::$method.var_export($request->all(), true));
  33. self::getClient()->notify($request);
  34. return 0;
  35. }
  36. public static function getClient() {
  37. switch(self::$method){
  38. case 'credit':
  39. return new Local();
  40. case 'f2fpay':
  41. return new F2Fpay();
  42. case 'codepay':
  43. return new Codepay();
  44. case 'payjs':
  45. return new PayJs();
  46. case 'bitpayx':
  47. return new BitpayX();
  48. case 'paypal':
  49. return new PayPal();
  50. case 'epay':
  51. return new EPay();
  52. default:
  53. Log::error("未知支付:".self::$method);
  54. return false;
  55. }
  56. }
  57. public static function getStatus(Request $request): JsonResponse {
  58. $payment = Payment::whereTradeNo($request->input('trade_no'))->first();
  59. if($payment){
  60. if($payment->status == 1){
  61. return Response::json(['status' => 'success', 'message' => '支付成功']);
  62. }
  63. if($payment->status == -1){
  64. return Response::json(['status' => 'error', 'message' => '订单超时未支付,已自动关闭']);
  65. }
  66. return Response::json(['status' => 'fail', 'message' => '等待支付']);
  67. }
  68. return Response::json(['status' => 'error', 'message' => '未知订单']);
  69. }
  70. // 创建支付订单
  71. public function purchase(Request $request) {
  72. $goods_id = $request->input('goods_id');
  73. $coupon_sn = $request->input('coupon_sn');
  74. self::$method = $request->input('method');
  75. $credit = $request->input('amount');
  76. $pay_type = $request->input('pay_type');
  77. $amount = 0;
  78. $goods = Goods::find($goods_id);
  79. // 充值余额
  80. if($credit){
  81. if(!is_numeric($credit) || $credit <= 0){
  82. return Response::json(['status' => 'fail', 'message' => '充值余额不合规']);
  83. }
  84. $amount = $credit;
  85. // 购买服务
  86. }elseif($goods_id && self::$method){
  87. if(!$goods || !$goods->status){
  88. return Response::json(['status' => 'fail', 'message' => '订单创建失败:商品已下架']);
  89. }
  90. $amount = $goods->price;
  91. // 是否有生效的套餐
  92. $activePlan = Order::userActivePlan()->doesntExist();
  93. // 无生效套餐,禁止购买加油包
  94. if($goods->type == 1 && $activePlan){
  95. return Response::json(['status' => 'fail', 'message' => '购买加油包前,请先购买套餐']);
  96. }
  97. //非余额付款下,检查在线支付是否开启
  98. if(self::$method !== 'credit'){
  99. // 判断是否开启在线支付
  100. if(!sysConfig('is_onlinePay')){
  101. return Response::json(['status' => 'fail', 'message' => '订单创建失败:系统并未开启在线支付功能']);
  102. }
  103. // 判断是否存在同个商品的未支付订单
  104. if(Order::uid()->whereStatus(0)->exists()){
  105. return Response::json(['status' => 'fail', 'message' => '订单创建失败:尚有未支付的订单,请先去支付']);
  106. }
  107. }elseif(Auth::getUser()->credit < $amount){ // 验证账号余额是否充足
  108. return Response::json(['status' => 'fail', 'message' => '您的余额不足,请先充值']);
  109. }
  110. // 单个商品限购
  111. if($goods->limit_num){
  112. $count = Order::uid()->where('status', '>=', 0)->whereGoodsId($goods_id)->count();
  113. if($count >= $goods->limit_num){
  114. return Response::json([
  115. 'status' => 'fail',
  116. 'message' => '此商品限购'.$goods->limit_num.'次,您已购买'.$count.'次'
  117. ]);
  118. }
  119. }
  120. // 使用优惠券 TODO 代码整合至 CouponService
  121. if($coupon_sn){
  122. $coupon = Coupon::whereStatus(0)->whereIn('type', [1, 2])->whereSn($coupon_sn)->first();
  123. if(!$coupon){
  124. return Response::json(['status' => 'fail', 'message' => '订单创建失败:优惠券不存在']);
  125. }
  126. // 计算实际应支付总价
  127. $amount = $coupon->type == 2? $goods->price * $coupon->value / 100 : $goods->price - $coupon->value;
  128. $amount = $amount > 0? round($amount, 2) : 0; // 四舍五入保留2位小数,避免无法正常创建订单
  129. }
  130. // 价格异常判断
  131. if($amount < 0){
  132. return Response::json(['status' => 'fail', 'message' => '订单创建失败:订单总价异常']);
  133. }
  134. if($amount == 0 && self::$method !== 'credit'){
  135. return Response::json(['status' => 'fail', 'message' => '订单创建失败:订单总价为0,无需使用在线支付']);
  136. }
  137. }
  138. $orderSn = date('ymdHis').random_int(100000, 999999);
  139. // 生成订单
  140. $order = new Order();
  141. $order->order_sn = $orderSn;
  142. $order->user_id = Auth::id();
  143. $order->goods_id = $credit? 0 : $goods_id;
  144. $order->coupon_id = !empty($coupon)? $coupon->id : 0;
  145. $order->origin_amount = $credit?: $goods->price;
  146. $order->amount = $amount;
  147. $order->is_expire = 0;
  148. $order->pay_type = $pay_type;
  149. $order->pay_way = self::$method;
  150. $order->status = 0;
  151. $order->save();
  152. // 使用优惠券,减少可使用次数
  153. if(!empty($coupon)){
  154. if($coupon->usable_times > 0){
  155. Coupon::whereId($coupon->id)->decrement('usable_times', 1);
  156. }
  157. Helpers::addCouponLog('订单支付使用', $coupon->id, $goods_id, $order->id);
  158. }
  159. $request->merge(['id' => $order->id, 'type' => $pay_type, 'amount' => $amount]);
  160. // 生成支付单
  161. return self::getClient()->purchase($request);
  162. }
  163. public function close(Request $request): JsonResponse {
  164. $order = Order::find($request->input('id'));
  165. if($order){
  166. if(!$order->update(['status' => -1])){
  167. return Response::json(['status' => 'fail', 'message' => '关闭订单失败']);
  168. }
  169. }else{
  170. return Response::json(['status' => 'fail', 'message' => '未找到订单']);
  171. }
  172. return Response::json(['status' => 'success', 'message' => '关闭订单成功']);
  173. }
  174. // 支付单详情
  175. public function detail($trade_no) {
  176. $payment = Payment::uid()->with(['order', 'order.goods'])->whereTradeNo($trade_no)->firstOrFail();
  177. $view['payment'] = $payment;
  178. $goods = $payment->order->goods;
  179. $view['name'] = $goods? $goods->name : '余额充值';
  180. $view['days'] = $goods? $goods->days : 0;
  181. $view['pay_type'] = $payment->order->pay_type_label?: 0;
  182. $view['pay_type_icon'] = $payment->order->pay_type_icon;
  183. return view('user.payment', $view);
  184. }
  185. // 回调日志
  186. public function callbackList(Request $request) {
  187. $status = $request->input('status', 0);
  188. $query = PaymentCallback::query();
  189. if(isset($status)){
  190. $query->whereStatus($status);
  191. }
  192. $view['list'] = $query->latest()->paginate(10)->appends($request->except('page'));
  193. return view('admin.logs.callbackList', $view);
  194. }
  195. }