vr-shopxo-plugin/shopxo/extend/payment/HupijiaoWxPay.php

<?php

namespace payment;

use think\facade\Db;
use app\service\PayLogService;

/**
 * 虎皮椒微信支付
 */
class HupijiaoWxPay {
    //插件配置参数
    private $config;

    public function __construct($params = []) {
        $this->config = $params;
    }

    /**
     * 配置信息
     */
    public function Config() {
        // 基础信息
        $base = [
            'name' => '虎皮椒微信支付',
            'version' => '1.0.1',
            'apply_version' => '不限',
            'apply_terminal' => ['pc','h5','weixin'],// 适用终端 默认全部 ['pc', 'h5', 'app', 'alipay', 'weixin', 'baidu']
            'desc' => '个人微信支付接口，无需提现，100%资金安全，官方清算，金额无限制，支持各种网站系统。是个人收款的最佳解决方案。<a href="https://admin.xunhupay.com/sign-in.html" target="_blank">立即申请</a>',  // 插件描述（支持html）
            'author' => '迅虎网络',  // 开发者
            'author_url' => 'https://www.wpweixin.net/',  // 开发者主页
        ];

        // 配置信息
        $element = [
            [
                'element' => 'input',
                'type' => 'text',
                'default' => '',
                'name' => 'app_id',
                'placeholder' => 'AppID',
                'title' => 'AppID',
                'is_required' => 0,
                'message' => '请填写虎皮椒分配的AppID',
            ],
            [
                'element' => 'input',
                'type' => 'text',
                'default' => '',
                'name' => 'app_secret',
                'placeholder' => 'AppSecret',
                'title' => 'AppSecret',
                'is_required' => 0,
                'message' => '请填写虎皮椒分配的AppSecret',
            ],
            [
                'element' => 'input',
                'type' => 'text',
                'default' => 'https://api.xunhupay.com/payment/do.html',
                'name' => 'gateway_url',
                'placeholder' => '网关地址',
                'title' => '网关地址',
                'is_required' => 0,
                'message' => '请填写虎皮椒支付网关地址',
            ]
        ];

        return [
            'base' => $base,
            'element' => $element,
        ];
    }


    /**
     * 支付入口
     */
    public function Pay($params = []) {
        // 参数
        if (empty($params)) {
            return DataReturn('参数不能为空', -1);
        }

        // 配置信息
        if (empty($this->config)) {
            return DataReturn('支付缺少配置', -1);
        }
        $parameter=$this->GetPayParams($params);

        // 支付请求记录
        PayLogService::PayLogRequestRecord($params['order_no'], ['request_params'=>$parameter]);

        $response=$this->HttpRequest($this->config['gateway_url'],$parameter);
        $response=json_decode($response,true);
        if(isset($response['errcode'])&&$response['errcode']==0){
            return DataReturn('success', 0, $response['url']);
        }
        return DataReturn($response['errmsg'], -1);
    }

    /**
     * 支付回调处理
     */
    public function Respond($params = []) {
        //支付异步回调
        if(isset($_POST['hash'])){
            file_put_contents(dirname(__FILE__).'/log.txt',json_encode($_POST)."\r\n",FILE_APPEND);
            $respose=$_POST;
            $this->checkRespose($respose);
            return DataReturn('支付成功', 0, $this->ReturnData($respose));
        }
        //查询订单支付状态
        if(isset($_GET['order_no'])){
            $order_no=$_GET['order_no'];
            $payData=Db::name('PayLog')->where('log_no',$order_no)->order('id desc')->find();
            if(!$payData){
                return DataReturn('订单暂无支付信息！', -100);
            }
            $data=[
                'trade_no'=>$payData['trade_no'],
                'buyer_user'=>$payData['buyer_user'],
                'out_trade_no'=>$order_no,
                'subject'=>$payData['subject'],
                'pay_price'=>$payData['pay_price'],
            ];
            return DataReturn('支付成功', 0,$data);
        }
        //同步-因同步不携带验签参数，所以需要ajax查询订单是否支付
        return DataReturn('处理异常错误', -100);
    }

    /**
     * 退款处理
     */
    public function Refund($params = []){
        return DataReturn('该支付方式暂未提供退款接口', -1);
    }

    /**
     * 返回数据统一格式
     */
    private function ReturnData($data) {
        // 返回数据固定基础参数
        $data['trade_no']       = $data['transaction_id'];  // 支付平台 - 订单号
        $data['buyer_user']     = $data['appid'];           // 支付平台 - 用户
        $data['out_trade_no']   = $data['trade_order_id'];  // 本系统发起支付的 - 订单号
        $data['subject']        = $data['plugins'];         // 本系统发起支付的 - 商品名称
        $data['pay_price']      = $data['total_fee'];       // 本系统发起支付的 - 总价
        return $data;
    }

    /**
     * 查询
     */

    /**
     * 获取支付参数
     */
    private function GetPayParams($params = []){
        $data = [
            'version' => '1.1',
            'appid' => $this->config['app_id'],
            'trade_order_id'=> $params['order_no'],
            'payment' => 'wechat',
            'total_fee' => round($params['total_price'],2),
            'title' => $params['name'].'-订单号:'.$params['order_no'],
            'time' => time(),
            'notify_url'=> $params['notify_url'],
            'return_url'=> $params['call_back_url'].'?order_no='.$params['order_no'],
            'nonce_str' => md5(time()),
            'plugins'=>$params['name']
        ];
        $data['hash']=$this->GenerateHash($data);
        return $data;
    }

    /**
     * 生成hash
     */
    private function GenerateHash($data=[]){
        if(array_key_exists('hash',$data)){
            unset($data['hash']);
        }
        ksort($data);
        $string=$this->FormatUrlParams($data).$this->config['app_secret'];
        return md5($string);
    }

    /**
     * 格式化参数
     */
    private function FormatUrlParams($data=[]){
        $buff = "";
        foreach ($data as $k => $v) {
            if ($k != "hash" && $v !== "" && !is_array($v)) {
                $buff .= $k . "=" . $v . "&";
            }
        }
        $buff = trim($buff, "&");
        return $buff;
    }

    /**
     * http请求
     */
    private function HttpRequest($url, $data = '',$headers = []) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS , $data);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        $output = curl_exec($ch);
        $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);    // 获取响应状态码
        $error = curl_error($ch);
        curl_close($ch);
        if ($http_code != 200) {
            exit("error:{$error}");
        }
        return $output;
    }

    /**
     * 校验参数
     */
    private function CheckRespose($data){
        if($data['status']!='OD'){
            exit($data['status']);
        }
        //校验签名
        if(!$this->CheckHash($data)){
            exit('签名校验失败');
        }
    }

    /**
     * 校验签名
     */
    private function CheckHash($data){
        $hish=$this->GenerateHash($data);
        if($hish==$data['hash']){
            return true;
        }
        return false;
    }

}

?>