first

application/api/controller/HuiPay.php

@@ -0,0 +1,283 @@
+<?php
+
+namespace app\api\controller;
+
+use addons\epay\library\Service;
+use app\common\controller\Api;
+use app\utils\CurlUtil;
+use app\utils\Easywechat\MiniAppService;
+use app\utils\LogUtil;
+use app\utils\PayUtil;
+use think\Cache;
+use think\Db;
+use think\Exception;
+use think\Request;
+
+/**
+ * 通行证
+ */
+class HuiPay extends Api
+{
+    // 日志模块名称
+    const LOG_MODULE = 'HuiPay';
+    protected $noNeedLogin = ['vip_recharge', 'gold_recharge', 'pay', 'pay_notify'];
+    protected $noNeedRight = '*';
+    // h5 跳转小程序
+    const H5 = 'https://h5-min-pay-1gczed24bbbe3db8-1317709175.tcloudbaseapp.com/suning-pay.html';
+
+    public function _initialize()
+    {
+        parent::_initialize();
+    }
+
+    public function __construct(Request $request = null)
+    {
+        parent::__construct($request);
+        //日志统一写入
+        register_shutdown_function([new LogUtil, 'close']);
+        LogUtil::getInstance('Api/'); //设置日志存入通道
+    }
+
+
+    /**
+     * 会员充值 （跳转小程序充值）
+     * @return void
+     */
+    public function vip_recharge()
+    {
+        Db::startTrans();
+        try {
+            $rc_id = input('rc_id',0);
+            $pay_type = input('pay_type','wechat');
+            $uid = $this->auth->id;
+
+            if ($pay_type != 'wechat') {
+                throw new Exception('支付类型有误');
+            }
+
+            if(!$rc_id){
+                throw new Exception('请选择会员套餐');
+            }
+
+            //赋值money
+            $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find();
+            $money = $recharge_config['money'];
+
+            if($money <= 0) {
+                throw new Exception('支付金额必须大于0');
+            }
+            if($money > 10000){
+                throw new Exception('支付金额太大');
+            }
+
+            //会员等级冲突
+            //当前是会员，但是却要向下级续费，直接提示报错
+            //修改等级，向上立刻改，向下不允许
+            $wallet_info = model('wallet')->getWallet($this->auth->id);
+            if($wallet_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $wallet_info['vip_level']){
+                throw new Exception('当前会员没有过期，不能续费');
+            }
+
+            //创建订单
+            $data = [];
+            $data['status'] = 0;
+            $pay_no = createUniqueNo('V',$uid);
+            $data['pay_no'] = $pay_no;
+            $data['money'] = $money;
+            $data['payment_class'] = $pay_type;
+            $data['user_id'] = $uid;
+            $data['ext_info'] =  json_encode(['subject'=>'充值vip支付']);
+            $data['memo'] =  '充值会员支付';
+            $data['createtime'] = time();
+            //$data['payment'] = 'miniapp';
+            $data['payment'] = 'app';
+            $pay_order = Db::name('pay_order')->insertGetId($data);
+
+            //创建回调
+            $even_data = [];
+            $even_data['event'] = 'success';
+            $even_data['class'] = 'app\common\model\Recharge';
+            $even_data['method'] = 'vippaysucc';
+            $even_data['args'] = json_encode(['user_id'=>$uid,'days'=>$recharge_config['days'],'vip_level'=>$recharge_config['vip_level'],'gold_num'=>$recharge_config['gold_num'],'money'=>$money]);
+            $even_data['pay_no'] = $pay_no;
+            $pay_event = Db::name('pay_event')->insertGetId($even_data);
+
+            if (!$pay_order || !$pay_event){
+                throw new Exception('下单失败');
+            }
+
+            // h5跳转小程序支付链接
+            $url = self::H5."?order_no={$pay_no}";
+            Db::commit();
+            $this->success('success',[
+                'url' => $url
+            ]);
+        } catch (Exception $e) {
+            Db::rollback();
+            $this->error($e->getMessage());
+        }
+    }
+
+    /**
+     * 金币充值
+     * @return void
+     */
+    public function gold_recharge()
+    {
+        Db::startTrans();
+        try {
+            $rc_id     = input_post('rc_id',0);
+            $pay_type  = 'wechat';
+            $freemoney = input_post('freemoney', 0, 'intval');
+            $uid = $this->auth->id;
+
+            if(!$rc_id && !$freemoney){
+                throw new Exception('请选择或填写充值金额');
+            }
+            if (!in_array($pay_type,['wechat','alipay'])) {
+                throw new Exception('错误的支付类型');
+            }
+            //赋值money
+            if($rc_id){
+                $recharge_config = Db::name('paygold_config')->where('id',$rc_id)->find();
+                $money = $recharge_config ? $recharge_config['money']: 0;
+                $gold  = $recharge_config ? $recharge_config['gold'] : 0;
+                $first_gold     = $recharge_config ? $recharge_config['first_gold'] : 0;
+                $first_vipdays  = $recharge_config ? $recharge_config['first_vipdays'] : 0;
+                $vip_gold  = $recharge_config ? $recharge_config['vip_gold'] : 0;
+            }
+
+            //自由输入覆盖
+            if(!empty($freemoney)){
+                $rc_id = 0;
+                $money = floatval($freemoney);
+                $bili = config('site.money_to_gold') ?: 10;
+                $gold  = bcmul($money,$bili,0);
+                $first_gold = 0;
+                $first_vipdays = 0;
+                $vip_gold  = 0;
+            }
+            if($money <= 0) {
+                throw new Exception('支付金额必须大于0');
+            }
+            if($money > 10000){
+                throw new Exception('支付金额太大');
+            }
+            //查询是不是会员,若不是则不赠送金币
+            $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime');
+            if ($vip_endtime < time()) {
+                $vip_gold = 0;
+            }
+
+            //创建订单
+            $data = [];
+            $data['status'] = 0;
+            $pay_no = createUniqueNo('P',$uid);
+            $data['pay_no'] = $pay_no;
+            $data['money'] = $money;
+            $data['payment_class'] = $pay_type;
+            $data['user_id'] = $uid;
+            $data['ext_info'] =  json_encode(['subject'=>'充值金币支付']);
+            $data['memo'] =  '充值金币支付';
+            $data['createtime'] = time();
+            $data['payment'] = 'app';
+            $pay_order = Db::name('pay_order')->insertGetId($data);
+
+            //创建回调
+            $even_data = [];
+            $even_data['event'] = 'success';
+            $even_data['class'] = 'app\common\model\Recharge';
+            $even_data['method'] = 'goldpaysucc';
+            $even_data['args'] = json_encode(['user_id'=>$uid,'gold'=>$gold,'money'=>$money,'pg_id'=>$rc_id,'first_gold'=>$first_gold,'first_vipdays'=>$first_vipdays, 'intro_uid' => $this->auth->intro_uid, 'vip_gold' => $vip_gold]);
+            $even_data['pay_no'] = $pay_no;
+            $pay_event = Db::name('pay_event')->insertGetId($even_data);
+
+
+            if (!$pay_order || !$pay_event){
+                throw new Exception('下单失败');
+            }
+
+            // h5跳转小程序支付链接
+            $url = self::H5."?order_no={$pay_no}";
+            Db::commit();
+            $this->success('success',[
+                'url' => $url
+            ]);
+        } catch (Exception $e) {
+            Db::rollback();
+            $this->error($e->getMessage());
+        }
+    }
+
+    /**
+     * 汇付 支付
+     */
+    public function pay()
+    {
+        $params = \request()->post();
+        $order_no = $params['order_no'] ?? '';
+        if ($params['openid'] != 9696){
+            $wxInfo = Cache::get($params['openid'] ?? '');
+            $openid = $wxInfo['openid'] ?? '';
+        }else{
+            $openid = 'ol8qS68vKSgWJ3Unrgfyi3rkakcQ';
+        }
+
+        if (empty($order_no) || empty($openid)){
+            $this->error('支付超时，请重新下单支付');
+        }
+
+        // 获取下单信息
+        $order = Db::name('pay_order')->where('pay_no',$order_no)->find();
+        if (!$order){
+            $this->error('订单不存在，请重新下单支付');
+        }
+
+        $money = $order['money'];
+        $money = '0.01';// 测试支付
+
+        $pay = new PayUtil();
+        $notify_url = CurlUtil::getHttp('/api/hui_pay/pay_notify',false);
+        if (!$pay->jsPay($openid, $order_no, $money, $order['memo'] ?? '商品下单支付', $notify_url)){
+            $this->error($pay->getMessage());
+        }
+
+        $res = $pay->getData();
+        if (empty($res['data']['pay_info']) || !$pay_info = json_decode($res['data']['pay_info'],true)){
+            $this->error('支付信息有误');
+            // exit;
+            // 这里 不加 exit 编辑器可能会提示  $pay_info 有可能不存在的变量 是因为 fastadmin 自带 error 写法不规范导致的
+        }
+
+        $this->success('success', [
+            'pay_info' => $pay_info,// 这里编辑器可能会提示  有可能不存在的变量 是因为 fastadmin 自带 error 写法不规范导致的
+            'order_no' => $order_no
+        ]);
+    }
+
+    /**
+     * 支付回调
+     * @return void
+     */
+    public function pay_notify(Request $request)
+    {
+        $params = $request->param();
+
+        // 消息主体信息
+        $resp_data = json_decode(stripslashes(htmlspecialchars_decode($params['resp_data'] ?? '')),true);
+        unset($params['resp_data']);
+
+        LogUtil::info('支付回调参数', self::LOG_MODULE, __FUNCTION__,[
+            'params' => $params,
+            'resp_data' => $resp_data,
+        ]);
+
+        if (empty($params['resp_code']) || $params['resp_code'] != '00000000' || empty($resp_data)){
+            LogUtil::info('回调信息有误', self::LOG_MODULE, __FUNCTION__,"resp_code error");
+            $this->error('支付信息有误');
+        }
+
+
+        $this->success();
+    }
+}

application/utils/CurlUtil.php

@@ -2,6 +2,15 @@
 namespace app\utils;
 
 class CurlUtil{
+
+    public static function getHttp($url,$ssl = true){
+        $domain = $_SERVER['HTTP_HOST'];
+        $http = 'http://';
+        $ssl && $http = ((isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] == 'on') || (isset($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https')) ? 'https://' : 'http://';
+
+        return $http.$domain.$url;
+    }
+
     /**
      * 模拟http get请求
      * @param $url