v2board/app/Http/Controllers/OrderController.php

400 lines
14 KiB
PHP
Raw Normal View History

2019-10-29 15:33:36 +08:00
<?php
namespace App\Http\Controllers;
use App\Http\Requests\OrderSave;
use App\Http\Controllers\Controller;
2020-01-01 23:40:14 +08:00
use Illuminate\Http\Request;
use Cache;
2019-12-27 01:59:15 +08:00
use Illuminate\Support\Facades\Log;
2020-01-01 23:40:14 +08:00
use Illuminate\Support\Facades\DB;
2019-10-29 15:33:36 +08:00
use App\Models\Order;
use App\Models\Plan;
use App\Models\User;
2020-01-01 17:55:16 +08:00
use App\Models\Coupon;
2019-10-29 15:33:36 +08:00
use App\Utils\Helper;
use Omnipay\Omnipay;
use Stripe\Stripe;
use Stripe\Source;
2019-12-27 01:50:26 +08:00
use Library\BitpayX;
2019-10-29 15:33:36 +08:00
class OrderController extends Controller
{
2020-01-11 13:36:52 +08:00
public function fetch(Request $request)
{
2019-10-29 15:33:36 +08:00
$order = Order::where('user_id', $request->session()->get('id'))
->orderBy('created_at', 'DESC')
->get();
$plan = Plan::get();
2020-01-11 13:36:52 +08:00
for ($i = 0; $i < count($order); $i++) {
for ($x = 0; $x < count($plan); $x++) {
2019-10-29 15:33:36 +08:00
if ($order[$i]['plan_id'] === $plan[$x]['id']) {
$order[$i]['plan'] = $plan[$x];
}
}
}
return response([
'data' => $order
]);
}
2020-01-11 13:36:52 +08:00
public function details(Request $request)
{
2019-10-29 15:33:36 +08:00
$order = Order::where('user_id', $request->session()->get('id'))
->where('trade_no', $request->input('trade_no'))
->first();
if (!$order) {
abort(500, '订单不存在');
}
$order['plan'] = Plan::find($order->plan_id);
2020-01-05 23:30:07 +08:00
$order['plan_transfer_hour'] = config('v2board.plan_transfer_hour', 12);
2019-10-29 15:33:36 +08:00
if (!$order['plan']) {
abort(500, '订阅不存在');
}
return response([
'data' => $order
]);
}
2020-01-02 00:05:54 +08:00
2020-01-11 13:36:52 +08:00
private function isExistNotPayOrderByUserId($userId)
{
2020-01-02 00:21:39 +08:00
$order = Order::where('status', 0)
2020-01-02 00:11:42 +08:00
->where('user_id', $userId)
2020-01-02 00:05:54 +08:00
->first();
2020-01-02 00:20:31 +08:00
if (!$order) {
return false;
}
return true;
2020-01-02 00:05:54 +08:00
}
2020-01-11 13:36:52 +08:00
public function save(OrderSave $request)
{
2020-01-02 00:11:42 +08:00
if ($this->isExistNotPayOrderByUserId($request->session()->get('id'))) {
2020-01-02 00:05:54 +08:00
abort(500, '存在未付款订单,请取消后再试');
}
2020-01-02 00:07:30 +08:00
2019-10-29 15:33:36 +08:00
$plan = Plan::find($request->input('plan_id'));
$user = User::find($request->session()->get('id'));
2020-01-11 13:36:52 +08:00
2019-10-29 15:33:36 +08:00
if (!$plan) {
abort(500, '该订阅不存在');
}
2020-01-11 13:36:52 +08:00
2019-10-29 15:33:36 +08:00
if (!($plan->show || $user->plan_id == $plan->id)) {
abort(500, '该订阅已售罄');
}
if (!$plan->show && !$plan->renew) {
abort(500, '该订阅无法续费,请更换其他订阅');
}
2019-11-25 18:56:00 +08:00
2019-12-31 15:58:53 +08:00
if ($plan[$request->input('cycle')] === NULL) {
2019-11-25 18:56:00 +08:00
abort(500, '该订阅周期无法进行购买,请选择其他周期');
}
2020-01-01 17:55:16 +08:00
if ($request->input('coupon_code')) {
$coupon = Coupon::where('code', $request->input('coupon_code'))->first();
if (!$coupon) {
abort(500, '优惠券无效');
}
2020-01-01 23:42:25 +08:00
if ($coupon->limit_use <= 0 && $coupon->limit_use !== NULL) {
2020-01-01 23:40:14 +08:00
abort(500, '优惠券已无可用次数');
}
2020-01-01 17:55:16 +08:00
if (time() < $coupon->started_at) {
abort(500, '优惠券还未到可用时间');
}
if (time() > $coupon->ended_at) {
abort(500, '优惠券已过期');
}
}
2020-01-11 13:36:52 +08:00
2020-01-01 23:40:14 +08:00
DB::beginTransaction();
2019-10-29 15:33:36 +08:00
$order = new Order();
$order->user_id = $request->session()->get('id');
$order->plan_id = $plan->id;
$order->cycle = $request->input('cycle');
$order->trade_no = Helper::guid();
$order->total_amount = $plan[$request->input('cycle')];
2020-01-01 17:55:16 +08:00
// renew and change subscribe process
2019-11-24 02:11:06 +08:00
if ($user->expired_at > time() && $order->plan_id !== $user->plan_id) {
$order->type = 3;
2019-11-24 23:59:13 +08:00
if (!(int)config('v2board.plan_is_update', 1)) abort(500, '目前不允许更改订阅,请联系管理员');
2019-11-24 02:11:06 +08:00
} else if ($user->expired_at > time() && $order->plan_id == $user->plan_id) {
$order->type = 2;
} else {
$order->type = 1;
}
2020-01-01 17:55:16 +08:00
// invite process
2019-10-29 15:33:36 +08:00
if ($user->invite_user_id) {
$order->invite_user_id = $user->invite_user_id;
2019-11-27 20:14:54 +08:00
$inviter = User::find($user->invite_user_id);
2019-11-27 20:15:53 +08:00
if ($inviter && $inviter->commission_rate) {
$order->commission_balance = $order->total_amount * ($inviter->commission_rate / 100);
} else {
$order->commission_balance = $order->total_amount * (config('v2board.invite_commission', 10) / 100);
2019-11-27 20:14:54 +08:00
}
2019-10-29 15:33:36 +08:00
}
2020-01-01 17:55:16 +08:00
// coupon process
if (isset($coupon)) {
switch ($coupon->type) {
2020-01-11 13:36:52 +08:00
case 1:
$order->discount_amount = $coupon->value;
2020-01-01 18:05:44 +08:00
break;
2020-01-11 13:36:52 +08:00
case 2:
$order->discount_amount = $order->total_amount * ($coupon->value / 100);
2020-01-01 18:05:44 +08:00
break;
2020-01-01 17:55:16 +08:00
}
2020-01-01 17:57:06 +08:00
$order->total_amount = $order->total_amount - $order->discount_amount;
2020-01-01 23:48:23 +08:00
if ($coupon->limit_use !== NULL) {
$coupon->limit_use = $coupon->limit_use - 1;
if (!$coupon->save()) {
DB::rollback();
abort(500, '优惠券使用失败');
}
}
2020-01-01 17:55:16 +08:00
}
// free process
if ($order->total_amount <= 0) {
2020-01-01 23:40:14 +08:00
$order->total_amount = 0;
2020-01-01 17:55:16 +08:00
$order->status = 1;
}
2020-01-01 23:40:14 +08:00
2019-10-29 15:33:36 +08:00
if (!$order->save()) {
2020-01-01 23:40:14 +08:00
DB::rollback();
2019-10-29 15:33:36 +08:00
abort(500, '订单创建失败');
}
2020-01-11 13:36:52 +08:00
2020-01-01 23:40:14 +08:00
DB::commit();
2019-10-29 15:33:36 +08:00
return response([
'data' => $order->trade_no
]);
}
2020-01-11 13:36:52 +08:00
public function checkout(Request $request)
{
2019-10-29 15:33:36 +08:00
$tradeNo = $request->input('trade_no');
$method = $request->input('method');
$order = Order::where('trade_no', $tradeNo)
->where('user_id', $request->session()->get('id'))
->where('status', 0)
->first();
if (!$order) {
2019-12-27 01:58:21 +08:00
abort(500, '订单不存在或已支付');
2019-10-29 15:33:36 +08:00
}
switch ($method) {
// return type => 0: QRCode / 1: URL
case 0:
// alipayF2F
if (!(int)config('v2board.alipay_enable')) {
abort(500, '支付方式不可用');
}
return response([
'type' => 0,
'data' => $this->alipayF2F($tradeNo, $order->total_amount)
]);
case 2:
// stripeAlipay
if (!(int)config('v2board.stripe_alipay_enable')) {
abort(500, '支付方式不可用');
}
return response([
'type' => 1,
'data' => $this->stripeAlipay($order)
]);
case 3:
// stripeWepay
if (!(int)config('v2board.stripe_wepay_enable')) {
abort(500, '支付方式不可用');
}
return response([
'type' => 0,
'data' => $this->stripeWepay($order)
]);
2019-12-27 01:50:26 +08:00
case 4:
// bitpayX
if (!(int)config('v2board.bitpayx_enable')) {
abort(500, '支付方式不可用');
}
return response([
'type' => 1,
'data' => $this->bitpayX($order)
]);
2019-10-29 15:33:36 +08:00
default:
abort(500, '支付方式不存在');
}
}
2020-01-11 13:36:52 +08:00
public function check(Request $request)
{
2019-10-29 15:33:36 +08:00
$tradeNo = $request->input('trade_no');
$order = Order::where('trade_no', $tradeNo)
->where('user_id', $request->session()->get('id'))
->first();
if (!$order) {
abort(500, '订单不存在');
}
return response([
'data' => $order->status
]);
}
2020-01-11 13:36:52 +08:00
public function getPaymentMethod()
{
2019-10-29 15:33:36 +08:00
$data = [];
if ((int)config('v2board.alipay_enable')) {
$alipayF2F = new \StdClass();
$alipayF2F->name = '支付宝';
$alipayF2F->method = 0;
$alipayF2F->icon = 'alipay';
array_push($data, $alipayF2F);
}
if ((int)config('v2board.stripe_alipay_enable')) {
$stripeAlipay = new \StdClass();
$stripeAlipay->name = '支付宝';
$stripeAlipay->method = 2;
$stripeAlipay->icon = 'alipay';
array_push($data, $stripeAlipay);
}
if ((int)config('v2board.stripe_wepay_enable')) {
$stripeWepay = new \StdClass();
$stripeWepay->name = '微信';
$stripeWepay->method = 3;
$stripeWepay->icon = 'wechat';
array_push($data, $stripeWepay);
}
2019-12-27 01:50:26 +08:00
if ((int)config('v2board.bitpayx_enable')) {
$bitpayX = new \StdClass();
$bitpayX->name = '虚拟货币';
$bitpayX->method = 4;
$bitpayX->icon = 'bitcoin';
array_push($data, $bitpayX);
}
2019-10-29 15:33:36 +08:00
return response([
'data' => $data
]);
}
2020-01-11 13:36:52 +08:00
public function cancel(Request $request)
{
2020-01-02 00:05:54 +08:00
if (empty($request->input('trade_no'))) {
abort(500, '参数有误');
}
$order = Order::where('trade_no', $request->input('trade_no'))
->where('user_id', $request->session()->get('id'))
->first();
if (!$order) {
abort(500, '订单不存在');
}
2020-01-02 00:21:39 +08:00
if ($order->status !== 0) {
2020-01-02 00:19:04 +08:00
abort(500, '只可以取消待支付订单');
}
2020-01-02 00:05:54 +08:00
$order->status = 2;
if (!$order->save()) {
abort(500, '取消失败');
}
return response([
'data' => true
]);
}
2020-01-11 13:36:52 +08:00
private function alipayF2F($tradeNo, $totalAmount)
{
2019-10-29 15:33:36 +08:00
$gateway = Omnipay::create('Alipay_AopF2F');
$gateway->setSignType('RSA2'); //RSA/RSA2
$gateway->setAppId(config('v2board.alipay_appid'));
$gateway->setPrivateKey(config('v2board.alipay_privkey')); // 可以是路径,也可以是密钥内容
$gateway->setAlipayPublicKey(config('v2board.alipay_pubkey')); // 可以是路径,也可以是密钥内容
2019-12-10 10:52:09 +08:00
$gateway->setNotifyUrl(url('/api/v1/guest/order/alipayNotify'));
2019-10-29 15:33:36 +08:00
$request = $gateway->purchase();
$request->setBizContent([
2020-01-11 13:36:52 +08:00
'subject' => config('v2board.app_name', 'V2Board') . ' - 订阅',
2019-10-29 15:33:36 +08:00
'out_trade_no' => $tradeNo,
'total_amount' => $totalAmount / 100
]);
/** @var \Omnipay\Alipay\Responses\AopTradePreCreateResponse $response */
$response = $request->send();
$result = $response->getAlipayResponse();
if ($result['code'] !== '10000') {
2020-01-11 13:36:52 +08:00
abort(500, $result['sub_msg']);
2019-10-29 15:33:36 +08:00
}
// 获取收款二维码内容
return $response->getQrCode();
}
2020-01-11 13:36:52 +08:00
private function stripeAlipay($order)
{
2019-10-29 15:33:36 +08:00
$exchange = Helper::exchange('CNY', 'HKD');
if (!$exchange) {
abort(500, '货币转换超时,请稍后再试');
}
Stripe::setApiKey(config('v2board.stripe_sk_live'));
$source = Source::create([
'amount' => floor($order->total_amount * $exchange),
'currency' => 'hkd',
'type' => 'alipay',
'redirect' => [
2019-12-21 00:01:11 +08:00
'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
2019-10-29 15:33:36 +08:00
]
]);
if (!$source['redirect']['url']) {
abort(500, '支付网关请求失败');
}
2020-01-11 13:36:52 +08:00
if (!Cache::put($source['id'], $order->trade_no)) {
2019-11-29 19:52:55 +08:00
abort(500, '订单创建失败');
2019-10-29 15:33:36 +08:00
}
2019-11-29 19:52:55 +08:00
Redis::expire($source['id'], 3600);
2019-10-29 15:33:36 +08:00
return $source['redirect']['url'];
}
2020-01-11 13:36:52 +08:00
private function stripeWepay($order)
{
2019-10-29 15:33:36 +08:00
$exchange = Helper::exchange('CNY', 'HKD');
if (!$exchange) {
abort(500, '货币转换超时,请稍后再试');
}
Stripe::setApiKey(config('v2board.stripe_sk_live'));
$source = Source::create([
'amount' => floor($order->total_amount * $exchange),
'currency' => 'hkd',
'type' => 'wechat',
'redirect' => [
2019-12-21 00:01:11 +08:00
'return_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
2019-10-29 15:33:36 +08:00
]
]);
if (!$source['wechat']['qr_code_url']) {
abort(500, '支付网关请求失败');
}
if (!Cache::put($source['id'], $order->trade_no)) {
2019-11-29 19:52:55 +08:00
abort(500, '订单创建失败');
2019-10-29 15:33:36 +08:00
}
2019-11-29 19:52:55 +08:00
Redis::expire($source['id'], 3600);
2019-10-29 15:33:36 +08:00
return $source['wechat']['qr_code_url'];
}
2019-12-27 01:50:26 +08:00
2020-01-11 13:36:52 +08:00
private function bitpayX($order)
{
2019-12-27 01:50:26 +08:00
$bitpayX = new BitpayX(config('v2board.bitpayx_appsecret'));
2020-01-11 13:36:52 +08:00
$params = [
'merchant_order_id' => 'V2Board_' . $order->trade_no,
'price_amount' => $order->total_amount / 100,
'price_currency' => 'CNY',
'title' => '支付单号:' . $order->trade_no,
'description' => '充值:' . $order->total_amount / 100 . ' 元',
'callback_url' => url('/api/v1/guest/order/bitpayXNotify'),
'success_url' => config('v2board.app_url', env('APP_URL')) . '/#/order',
'cancel_url' => config('v2board.app_url', env('APP_URL')) . '/#/order'
2019-12-27 01:50:26 +08:00
];
$strToSign = $bitpayX->prepareSignId($params['merchant_order_id']);
2020-01-11 13:36:52 +08:00
$params['token'] = $bitpayX->sign($strToSign);
2019-12-27 01:50:26 +08:00
$result = $bitpayX->mprequest($params);
Log::info('bitpayXSubmit: ' . json_encode($result));
return isset($result['payment_url']) ? $result['payment_url'] : false;
}
2019-10-29 15:33:36 +08:00
}