bike-api/app/Http/Controllers/V1/CardRidingController.php

<?php


namespace App\Http\Controllers\V1;


use App\Http\Requests\CardRidingOrderRequest;
use App\Http\Requests\CardRidingRequest;
use App\Http\Requests\CardRidingsRequest;
use App\Jobs\CloseCardRidingOrderJob;
use App\Models\Auth;
use App\Models\CardRiding;
use App\Models\CardRidingOrder;
use App\Repositories\CardRidingOrderRepository;
use App\Repositories\CardRidingRepository;
use App\Repositories\CardRidingUserBagsRepository;
use App\Transformers\CardRidingOrdersTransformer;
use App\Transformers\CardRidingsTransformer;
use Carbon\Carbon;
use Dingo\Api\Http\Request;
use EasyWeChat\Factory;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use function EasyWeChat\Kernel\Support\generate_sign;

/**
 * 骑行卡营销活动
 * Class CardRidingController
 * @package App\Http\Controllers\V1
 */
class CardRidingController extends BaseController
{
    /**
     * 根据骑行用户区域id获取骑行卡列表
     *
     * */
    public function index(CardRidingsRequest $cardRidingsRequest, CardRidingRepository $cardRidingRepository)
    {
        try {
            $area_id = $cardRidingsRequest->get('area_id');
            $cards = $cardRidingRepository->byAreaIdGetCardRidings($area_id);
            return $this->response->collection($cards, CardRidingsTransformer::class);
        } catch (\Exception $exception) {
            return $this->exception($exception);
        }
    }

    /**
     * 根据骑行卡id 去购买骑行卡 下单
     *
     * @param CardRidingRequest $cardRidingRequest
     * */
    public function buyCardRiding(CardRidingRequest $cardRidingRequest, CardRidingRepository $cardRidingRepository, CardRidingOrderRepository $cardRidingOrderRepository, CardRidingUserBagsRepository $cardRidingUserBagsRepository)
    {
        try {
            $card_riding_id = $cardRidingRequest->get('card_riding_id');
            $user_id = $this->user->id;
            $area_id = $cardRidingRequest->get('area_id');

            if (empty($area_id)) return $this->errorNoValidation('请求错误');
            if (!$cardRidingRepository->isStatusOK($card_riding_id)) return $this->errorNoValidation('此骑行卡暂不售卖');
            if (!$cardRidingOrderRepository->isPayCallbackOk($user_id)) return $this->errorNoValidation('您已经购买过,请刷新后重试');
            if (!empty($cardRidingUserBagsRepository->isExist($user_id))) return $this->errorNoValidation('您已拥有骑行卡，请使用完毕后再购买');

            $cardRiding = $cardRidingRepository->byIdGetModel($card_riding_id);
            DB::beginTransaction();
            // 1.下单
            $discount = (bool)($cardRiding->is_discount) ? $cardRiding->discount : 1.00;
            $money = $cardRiding->price;

            switch (self::$SOURCE_TYPE ){
                case self::SOURCE_TYPE_WECHAT:
                    $source_type = CardRidingOrder::PAY_TYPE_WECHAT;
                    break;
                case self::SOURCE_TYPE_ALIPAY:
                    $source_type = CardRidingOrder::PAY_TYPE_ALIPAYMINI;
                    break;
            }

            $data = [
                'no' => CardRidingOrder::makeNo(self::$ORDER_TAG),
                'area_id' => $area_id,
                'user_id' => $user_id,
                'riding_card_id' => $card_riding_id,
                'money' => $money,
                'discount' => $discount,
                'pay_money' => bcmul($money, $discount, 2),
                'pay_type' => $source_type,
                'pay_status' => CardRidingOrder::PAY_STATUS_NO,
                'pay_time' => Carbon::now(),
                'merchant_id' => self::$MERCHANT_ID
            ];

            $cardRidingOrder = CardRidingOrder::create($data);

            $this->dispatch(new CloseCardRidingOrderJob($cardRidingOrder, Carbon::now()->addMinutes(30)));
            //发起支付


//            $username = $this->user->truename;
//            $auth = $this->user->auth;

            $user_id = $this->user->id;
            $userauth = userAuthinfo(self::$MERCHANT, $user_id);

            if ($userauth['code'] != 1) {
                return $this->errorNoValidation('用户信息有误');
            }

            switch (self::$SOURCE_TYPE) {
                case self::SOURCE_TYPE_WECHAT:
                    $payment = Factory::payment(wechat_pay_config(self::$MERCHANT)); // 微信支付
                    $result = $payment->order->unify([
                        'body' => "用户购买骑行卡-" . self::$MERCHANT['wxapp_name'],
                        'out_trade_no' => $cardRidingOrder->no,
                        'trade_type' => 'JSAPI',  // 必须为JSAPI
                        'openid' => $userauth['data']['credential'], // 这里的openid为付款人的openid
                        'total_fee' => wechat_fee($cardRidingOrder->pay_money), // 总价
                        'attach' => makeNoTag(CardRidingOrder::NO_TAG),
                    ]);

                    // 如果成功生成统一下单的订单，那么进行二次签名
                    if ('SUCCESS' === $result['return_code'] && 'SUCCESS' === $result['result_code']) {
                        // 二次签名的参数必须与下面相同
                        $params = [
                            'appId' => $userauth['data']['identifier'],
                            'timeStamp' => time(),
                            'nonceStr' => $result['nonce_str'],
                            'package' => 'prepay_id=' . $result['prepay_id'],
                            'signType' => 'MD5',
                        ];

                        // self::$MERCHANT['pay_key']为商户的key
                        $params['paySign'] = generate_sign($params, self::$MERCHANT['pay_key']);

                        $params['no'] = $cardRidingOrder->no;
                        DB::commit();
                        return $this->response->array($params);
                    }

                    break;
                case self::SOURCE_TYPE_ALIPAY:

                    $result = alipay_mini_pay(self::$MERCHANT, "用户购买骑行卡-" . self::$MERCHANT['wxapp_name'], $cardRidingOrder->no, $cardRidingOrder->pay_money, $userauth['data']['credential']);
                    if ($result['code'] != 1) {
                        return $this->errorNoValidation($result['msg']);
                    }
                    $response['tradeNo'] = $result['data']->tradeNo;  //获取支付宝订单号

                    DB::commit();
                    return $this->response->array($response);

                    break;
            }


            DB::rollBack();
            return $this->errorNoValidation('下单失败');
        } catch (\Exception $exception) {
            DB::rollBack();
            return $this->exception($exception);
        }
    }

    /**
     * 下单 没支付
     * */
    public function changeCardRidingOrderStatus(CardRidingOrderRequest $request)
    {
        try {
            $card_riding_order_no = $request->get('no');
            $card_riding_order = CardRidingOrder::where('no', $card_riding_order_no)->first();
            if (empty($card_riding_order)) return $this->errorNoValidation('订单不存在');

            $card_riding_order->status = CardRidingOrder::STATUS_NO;
            $card_riding_order->save();
            return $this->success();
        } catch (\Exception $exception) {
            return $this->exception($exception);
        }
    }

    /**
     * 用户骑行卡
     * */
    public function userCardRiding(Request $request, CardRidingUserBagsRepository $cardRidingUserBagsRepository, CardRidingRepository $cardRidingRepository)
    {
        $user_id = $this->user->id;
        $area_id = $request->get('area_id', $this->user->register_area_id);
        $userCard = $cardRidingUserBagsRepository->isExist($user_id);
        $is_card_begin = $cardRidingRepository->byAreaIdIsExists($area_id);
        if (empty($userCard)) {
            return $this->response->array(['user_card' => [], 'is_card_begin' => $is_card_begin]);
        }
        $userCard = $userCard->toArray();
        return $this->response->array(['user_card' => $userCard, 'is_card_begin' => $is_card_begin]);

    }

    /**
     * 用户购买骑行卡历史订单
     * */
    public function CardRidingOrderHistory(CardRidingOrderRepository $cardRidingOrderRepository)
    {
        $user_id = $this->user->id;

        $cardOrders = $cardRidingOrderRepository->getAllByUserId($user_id);

        return $this->response->paginator($cardOrders, CardRidingOrdersTransformer::class);
    }

}