youxiangjie/application/api/controller/Queue.php

<?php
namespace app\api\controller;

use alipay\aop\AopClient;
use alipay\aop\request\AlipayTradeAppPayRequest;
use app\admin\model\BuyVipLogModel;
use app\api\model\QueueModel;
use app\api\model\UsersModel;
use app\common\controller\Api;
use app\common\lib\WxPay;
use think\Db;
use function GuzzleHttp\Psr7\str;

/**
 * 排队接口
 */
class Queue extends Api
{
    protected $noNeedLogin = '*';
    /**
     * 排队页面
     *
     * @ApiTitle    (排队页面)
     * @ApiSummary  (排队页面顶部提示信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/queuePage)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     */
    public function queuePage()
    {
        $userId = $this->request->post('user_id');
        if (!$userId) {
            $this->result('参数错误', [], 200);
        }
        $user = UsersModel::where('user_id', $userId)->find();
        if (!$user) {
            $this->result('用户不存在', [], 200);
        }
        // 获得的次数
        $getNum = $user->get_queue_num;
        // 基础次数
        $baseNum = Db::name('queue_set')->where('level', $user->user_level)->value('num');
        // 可用的基础次数
        $canUseBaseNum = $baseNum - $user->queue_num_today;
        // 总可用次数
        $total = $getNum + $canUseBaseNum;
        $this->result('ok', [
            'tip' => '尊敬的VIP会员，你还可排队'.$total.'次，排队时间（09:00-22:00），其中推荐用户获得'.$getNum.'次，VIP会员奖励'.$canUseBaseNum.'次'
        ], 200);
    }
    /**
     * 排队
     *
     * @ApiTitle    (排队)
     * @ApiSummary  (排队)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/queue)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="pay_type", type="int", required=true, description="支付方式：1-余额 2-微信 3-支付宝")
     */
    public function queue()
    {
        $userId = $this->request->post('user_id');
        $payType = $this->request->post('pay_type'); // 1-余额 2-微信 3-支付宝
        $amount = 0.01;
        $income = 2;

        if (!$userId || !$payType) {
            $this->result('参数错误', [], 100);
        }

        $user = UsersModel::get($userId);

        if (!$user) {
            $this->result('用户不存在', [], 100);
        }

        if ($user->user_level == 1) {
            $this->result('您还不是VIP用户，不能进行排队哦', [], 100);
        }

        // 查询所有的可排队次数是否已经用完
        // 情况一：获得次数有、基础次数有，可排队
        // 情况二：获得次数有、基础次数无，不存在该种情况
        // 情况三：获得次数无、基础次数有，可排队
        // 情况四：都无，不可排队
        $canQueueNum = Db::name('queue_set')->where('level', $user->user_level)->value('num');
        if ($user->queue_num_today == $canQueueNum) {
            $this->result('您的可用排队次数不足', [], 100);
        }

        $nowTime = time();
        $startTime = strtotime(date('Y-m-d').' 09:00:00');
        $endTime = strtotime(date('Y-m-d').' 22:00:00');

        if ($startTime < $nowTime && $nowTime < $endTime) {

            $nowHour = date("Y-m-d H:00:00", time());
            $nextHour = date("Y-m-d H:00:00", strtotime("+1 hour"));

            // 是否在本时间段内排过队
            $hasOnLine = QueueModel::where(['uid' => $userId, 'pay_status' => 1])
                ->whereTime('time', 'between', [$nowHour, $nextHour])
                ->find();

            if (!empty($hasOnLine)) {
                $this->result('您当前已排过队', [], 100);
            }

            // 进入队列时的时间
            $joinQueueTime = date('Y-m-d H:i:s', time());//halt($joinQueueTime);
            // 当前时间段排队人数
            $lineNum = QueueModel::whereTime('time', 'between', [$nowHour, $joinQueueTime])->where('pay_status',1)->count();
            $trade = createOutTradeNo();
            $lineInfo = array(
                'uid'      => $userId,
                'trade'    => $trade,
                'amount'   => $amount,
                'line_num' => $lineNum,
                'income'   => $income,
                'time'     => date('Y-m-d H:i:s', time()),
                'pay_type' => $payType
            );
            Db::startTrans();
            $insert = QueueModel::insert($lineInfo);
            if ($insert) {
                Db::commit();
                // 余额支付
                if ($payType == 1) {
                    $this->result('订单创建成功', ['out_trade_no' => $trade, 'fee' => $amount], 200);
                }
                // 微信支付
                if ($payType == 2) {
                    $payObj = new WxPay();
                    $notifyUrl = config('site.httpurl').'/api/queue/wx_notify_url';
                    $getPrePayInfo = $payObj->getPrePayOrder('优享街排队', $trade, ($amount * 100), $notifyUrl);
                    if ($getPrePayInfo) {
                        $getPayInfo = $payObj->getOrder($getPrePayInfo['prepay_id']);
                        if ($getPayInfo) {
                            $this->result('订单创建成功', $getPayInfo, 200);
                        } else {
                            $this->result('支付错误，请稍后再试', [], 100);
                        }
                    } else {
                        $this->result('支付错误，请稍后再试', [], 100);
                    }
                }
                // 支付宝支付
                if ($payType == 3) {
                    $notify_url2 = config('site.httpurl').'/api/queue/alipay_notify_url';
                    $aop = new AopClient;
                    $aop->gatewayUrl = "https://openapi.alipay.com/gateway.do";
                    $aop->appId = config('alipay.app_id');
                    $aop->rsaPrivateKey = config('alipay.private_key');
                    $aop->format = "json";
                    $aop->charset = "utf-8";
                    $aop->signType = "RSA2";
                    $aop->alipayrsaPublicKey = config('alipay.public_key');
                    //实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
                    $request = new AlipayTradeAppPayRequest();

                    // 订单标题
                    $subject = '优享街排队';
                    // 订单详情
                    $body = '优享街排队';

                    // SDK已经封装掉了公共参数，这里只需要传入业务参数
                    $bizcontent = json_encode([
                        'body' => $body,
                        'subject' => $subject,
                        'out_trade_no' => $trade,
                        'timeout_express' => '90m',
                        'total_amount' => $amount,
                        'product_code' => 'QUICK_MSECURITY_PAY'
                    ]);

                    $request->setNotifyUrl($notify_url2);
                    $request->setBizContent($bizcontent);
                    // 这里和普通的接口调用不同，使用的是sdkExecute
                    $response = $aop->sdkExecute($request);
                    // 注意：这里不需要使用htmlspecialchars进行转义，直接返回即可
                    // return $response;
                    $this->result('订单发起成功', ['payInfoString' => $response], 200);
                }
            } else {
                Db::rollback();
                $this->result('服务器繁忙', [], 100);
            }
        } else {
            $this->result('今日排队活动已经结束了哦', [], 100);
        }
    }
    /**
     * 排队余额支付
     *
     * @ApiTitle    (排队余额支付)
     * @ApiSummary  (排队余额支付)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/balancePayQueue)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="fee", type="decimal", required=true, description="排队接口返回的支付金额fee字段的值")
     * @ApiParams   (name="out_trade_no", type="string", required=true, description="排队接口返回的支付订单编号out_trade_no字段的值")
     * @ApiParams   (name="pay_password", type="string", required=true, description="用户支付密码")
     */
    public function balancePayQueue()
    {
        $userId = $this->request->post('user_id');
        $fee = $this->request->post('fee');
        $trade = $this->request->post('out_trade_no');
        $payPwd = $this->request->post('pay_password');

        if (!$userId || !$fee || !$trade || !$payPwd) {
            $this->result('参数错误', [], 100);
        }

        $user = UsersModel::get($userId);

        // 用户是否存在
        if (!$user) {
            $this->result('用户不存在', [], 100);
        }
        // 订单是否存在
        $order = QueueModel::where('trade', $trade)->find();
        if (!$order) {
            $this->result('订单不存在', [], 100);
        }
        if ($fee <= 0) {
            $this->result('请输入正确的支付金额', [], 100);
        }
        // 余额是否满足本次扣费金额
        if ($user->user_money < $fee) {
            $this->result('账户余额不足', [], 100);
        }
        // 是否设置支付密码
        if (empty($user->user_paypwd)) {
            $this->result('请先设置支付密码', [], 100);
        }
        // 支付密码是否正确
        if ($user->user_paypwd != $payPwd) {
            $this->result('支付密码错误', [], 100);
        }

        Db::startTrans();
        // 扣除账户余额
        $dec = UsersModel::where('user_id', $userId)->setDec('user_money', $fee);
        // 增加排队收入
        $amount = 2;
        $inc = UsersModel::where('user_id', $userId)->setInc('user_money', $amount);
        // 更新支付状态和支付时间
        $updatePayStatus = QueueModel::where('trade', $trade)
            ->update(['pay_status' => 1, 'pay_time' => date('Y-m-d H:i:s', time())]);

        // 获得的次数是否够用
        if ($user->get_queue_num < 1) {
            // 不够用，使用基础次数
            $decBaseNum = UsersModel::where('user_id', $userId)->setInc('queue_num_today', 1);
            if ($dec && $inc && $updatePayStatus && $decBaseNum) {
                Db::commit();
                $this->result('排队成功', [], 200);
            } else {
                Db::rollback();
                $this->result('支付失败，稍后再试', [], 100);
            }
        } else {
            // 获得次数够用，直接减少一次次数
            $decGetNum = UsersModel::where('user_id', $userId)->setDec('get_queue_num', 1);
            if ($dec && $inc && $updatePayStatus && $decGetNum) {
                Db::commit();
                $this->result('排队成功', [], 200);
            } else {
                Db::rollback();
                $this->result('支付失败，稍后再试', [], 100);
            }
        }
    }
    /**
     * 排队微信支付异步回调处理
     * @ApiInternal
     */
    public function wx_notify_url()
    {
        //获取返回的xml格式数据
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式
        $result = json_decode($jsonXml, true);

        if ($result) {
            //如果成功返回
            if ($result['return_code'] == 'SUCCESS') {
                if ($result['result_code'] == 'SUCCESS') {
                    // sign 值校验
                    // 校验时不包含返回的 sign 字段，需踢除 sign 字段
                    foreach($result as $k => $v) {
                        if ($k == 'sign') {
                            $sign = $result[$k];
                            unset($result[$k]);
                        };
                    }
                    //按字典排序
                    ksort($result);
                    //转为 url 键值对
                    $signTemp = http_build_query($result);
                    //md5处理，$key 为微信商户平台的 api 安全密钥
                    $key = 'b3ae6bbf3cc4fa017eb169ae219e2c27';
                    $signTemp = md5($signTemp.'&key='.$key);
                    //转大写得最终 sign 值
                    $resultSign = strtoupper($signTemp);
                    //如果sign值正确
                    if ($sign === $resultSign) {
                        $order = QueueModel::where('trade', $result['out_trade_no'])->find();
                        $user = UsersModel::where('user_id', $order->uid)->find();
                        if ($order) {
                            // 增加排队收入
                            $amount = 2;
                            $inc = UsersModel::where('user_id', $user->user_id)->setInc('user_money', $amount);
                            // 更新支付状态和支付时间
                            $updatePayStatus = QueueModel::where('trade', $result['out_trade_no'])
                                ->update(['pay_status' => 1, 'pay_time' => date('Y-m-d H:i:s', time())]);
                            // 获得的次数是否够用
                            if ($user->get_queue_num < 1) {
                                // 不够用，使用基础次数
                                $decBaseNum = UsersModel::where('user_id', $user->user_id)->setInc('queue_num_today', 1);
                                if ($inc && $updatePayStatus && $decBaseNum) {
                                    $successArray = array(
                                        'return_code' => 'SUCCESS',
                                        'return_msg'  => 'OK'
                                    );
                                    return $this->arrayToXml($successArray);
                                }
                            } else {
                                // 获得次数够用，直接减少一次次数
                                $decGetNum = UsersModel::where('user_id', $user->user_id)->setDec('get_queue_num', 1);
                                if ($inc && $updatePayStatus && $decGetNum) {
                                    $successArray = array(
                                        'return_code' => 'SUCCESS',
                                        'return_msg'  => 'OK'
                                    );
                                    return $this->arrayToXml($successArray);
                                }
                            }
                        }
                    }
                } else {
                    return false;
                }
            } else {
                return false;
            }
        }
    }
    /**
     * 数组转xml
     * @ApiInternal
     */
    public function arrayToXml($arr)
    {
        $xml = "<xml>";
        foreach ($arr as $key=>$val)
        {
            if (is_numeric($val))
            {
                $xml.="<".$key.">".$val."</".$key.">";
            }
            else
                $xml.="<".$key."><![CDATA[".$val."]]></".$key.">";
        }
        $xml.="</xml>";
        return $xml;
    }
    /**
     * 排队支付支付宝回调
     * @ApiInternal
     */
    public function alipay_notify_url()
    {
        $params = $this->request->post();
        if (!empty($params) && $params['trade_status'] == 'TRADE_SUCCESS') {
            // 验证签名
            $aop = new AopClient();
            $aop->alipayrsaPublicKey = config('alipay.public_key');
            // 此处反转义参数中的字符，否则验签不通过
            $params['fund_bill_list'] = htmlspecialchars_decode($params['fund_bill_list']);
            $checkSign = $aop->rsaCheckV1($params, null, 'RSA2');
            if ($checkSign) {
                // 是不是向此商户号付款
                if ($params['app_id'] == config('alipay.app_id')) {
                    // 查询订单是否存在
                    $order = QueueModel::where('trade', $params['out_trade_no'])->find();
                    $user = UsersModel::where('user_id', $order->uid)->find();
                    if ($order) {
                        // 增加排队收入
                        $amount = 2;
                        $inc = UsersModel::where('user_id', $user->user_id)->setInc('user_money', $amount);
                        // 更新支付状态和支付时间
                        $updatePayStatus = QueueModel::where('trade', $params['out_trade_no'])
                            ->update(['pay_status' => 1, 'pay_time' => date('Y-m-d H:i:s', time())]);
                        // 获得的次数是否够用
                        if ($user->get_queue_num < 1) {
                            // 不够用，使用基础次数
                            $decBaseNum = UsersModel::where('user_id', $user->user_id)->setInc('queue_num_today', 1);
                            if ($inc && $updatePayStatus && $decBaseNum) {
                                echo 'success';
                            }
                        } else {
                            // 获得次数够用，直接减少一次次数
                            $decGetNum = UsersModel::where('user_id', $user->user_id)->setDec('get_queue_num', 1);
                            if ($inc && $updatePayStatus && $decGetNum) {
                                echo 'success';
                            }
                        }
                    }
                }
            }
        }
    }
    /**
     * 已成功排队的记录
     *
     * @ApiTitle    (获取已成功排队列表)
     * @ApiSummary  (此接口返回的是成功支付的排队订单，均是已完成订单，已排好顺序)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/getQueueList)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     */
    public function getQueueList()
    {
        $userId = $this->request->post('user_id');
        if (!$userId) {
            $this->result('参数错误', [], 100);
        }
        if (!UsersModel::checkUserExist($userId)) {
            $this->result('用户不存在', [], 100);
        }
        $myList = QueueModel::where(['uid' => $userId, 'pay_status' => 1])
            ->field('id,trade,time,pay_time')
            ->order('id desc')
            ->select();
        $this->result('ok', $myList, 200);
    }
    /**
     * 查看当前排队记录详情
     *
     * @ApiTitle    (查看当前排队记录详情)
     * @ApiSummary  (查看当前排队记录详情)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/lookQueueDetail)
     * @ApiParams   (name="id", type="int", required=true, description="【获取已成功排队列表】接口中返回的id字段的值")
     */
    public function lookQueueDetail()
    {
        $id = $this->request->post('id');
        if (!$id) {
            $this->result('参数错误', [], 100);
        }
        $queueOrder = QueueModel::field('trade,line_num')->find($id);
        //$nowTime = date('Y-m-d H:i:s', time());
        //$nextTime = date("Y-m-d H:00:00", strtotime("+1 hour"));
        //$mistake = strtotime($nextTime) - strtotime($nowTime);
        //$hour=floor((strtotime($nextTime)-strtotime($nowTime))%86400/3600);
        //$minute=floor((strtotime($nextTime)-strtotime($nowTime))%86400/60);
        //$second=floor((strtotime($nextTime)-strtotime($nowTime))%86400%60);
        //halt($second);
        if (!empty($queueOrder)) {
            $this->result('ok', $queueOrder, 200);
        } else {
            $this->result('记录不存在', [], 100);
        }
    }
    /**
     * 排队记录
     *
     * @ApiTitle    (获取排队记录)
     * @ApiSummary  (获取排队记录)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/queue/getQueueRecord)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="type", type="int", required=true, description="获取类型 1-获取消费记录 2-获取收益记录")
     */
    public function getQueueRecord()
    {
        $userId = $this->request->post('user_id');
        $type = $this->request->post('type'); // 1-消费记录 2-收益记录

        if (!$userId || !$type) {
            $this->result('参数错误', [], 100);
        }
        if (!UsersModel::checkUserExist($userId)) {
            $this->result('用户不存在', [], 100);
        }

        if ($type == 1) {
            $record = QueueModel::where(['uid' => $userId, 'pay_status' => 1])
                ->field('amount,pay_type,time')
                ->order('id desc')
                ->select();
            $this->result('ok', $record, 200);
        }
        if ($type == 2) {
            $record = QueueModel::where(['uid' => $userId, 'pay_status' => 1])
                ->field('income,time')
                ->order('id desc')
                ->select();
            $this->result('ok', $record, 200);
        }
    }
}