youxiangjie/application/api/controller/Recharge.php

<?php
namespace app\api\controller;

use app\api\model\RechargeModel;
use app\api\model\UsersModel;
use app\common\controller\Api;
use app\common\lib\WxPay;

/**
 * 充值接口
 */
class Recharge extends Api
{
    protected $noNeedLogin = '*';

    /**
     * 充值页面
     *
     * @ApiTitle    (充值页面)
     * @ApiSummary  (充值页面)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/recharge/rechargePage)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     */
    public function rechargePage()
    {
        $userId = $this->request->post('user_id');
        if (!$userId) {
            $this->result('参数错误', [], 100);
        }
        if (!UsersModel::checkUserExist($userId)) {
            $this->result('用户不存在', [], 100);
        }
        $user = UsersModel::get($userId);
        $this->result('ok', ['quota' => $user->vip_discount_quota], 200);
    }
    /**
     * 话费充值
     *
     * @ApiTitle    (话费充值)
     * @ApiSummary  (话费充值)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/recharge/recharge)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="price", type="int", required=true, description="充值面额")
     * @ApiParams   (name="tel", type="string", required=true, description="充值手机号")
     * @ApiParams   (name="pay_type", type="int", required=true, description="支付方式 1-微信 2-支付宝")
     */
    public function recharge()
    {
        $userId = $this->request->post('user_id');
        $price = $this->request->post('price');
        $tel = $this->request->post('tel');
        $payType = $this->request->post('pay_type');

        if (!$userId || !$price || !$tel || !$payType) {
            $this->result('参数错误', [], 100);
        }
        $user = UsersModel::get($userId);
        if (!$user) {
            $this->result('用户不存在', [], 100);
        }
        if ($user->user_level == 1) {
            $this->result('您还不是VIP用户，不能进行充值', [], 100);
        }

        // 检测手机号是否可以充值
        $url = 'http://op.juhe.cn/ofpay/mobile/telcheck?phoneno='.$tel.'&cardnum='.$price.'&key=f5ff49671fede25118a6b01131ff88a4';
        $res = $this->sendRequest($url);
        if ($res['error_code'] != 0) {
            $this->result('充值错误，请检查手机号码是否正确', [], 100);
        }

        $final_fee = $price * 0.88;
        // 生成充值订单
        $out_trade_no = createOutTradeNo();
        $orderInfo = array(
            'uid' => $userId,
            'tel' => $tel,
            'price' => $price,
            'create_time' => date('Y-m-d H:i:s', time()),
            'pay_type' => $payType,
            'out_trade_no' => $out_trade_no,
            'final_fee' => $final_fee
        );
        $add = RechargeModel::create($orderInfo);
        if ($add) {
            if ($payType == 1) {
                $notify_url = config('site.httpurl').'/api/recharge/recharge_wx_notify';
                $payObj = new WxPay();
                $getPrePayInfo = $payObj->getPrePayOrder('话费充值', $out_trade_no, ($final_fee * 100), $notify_url);
                $getPayInfo = $payObj->getOrder($getPrePayInfo['prepay_id']);
                $this->result('订单创建成功', $getPayInfo, 200);
            }
            if ($payType == 2) {
                $this->result('订单创建成功', [], 200);
            }
        } else {
            $this->result('订单创建失败', [], 200);
        }
    }
    /**
     * 1
     * @ApiInternal
     */
    public function sendRequest($url)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        $output = curl_exec($ch);
        curl_close($ch);
        return json_decode($output, true);
    }
    /**
     * 话费充值微信支付异步回调
     * @ApiInternal
     */
    public function recharge_wx_notify()
    {

    }
}