微信支付开发-支付工厂AppApi查账代码

一、JSAPI支付产品、APP支付产品、小程序支付产品流程图

二、工厂父类抽象类代码开发

<?php
/**
 * 微信父类抽象类
 * User: 龙哥·三年风水
 * Date: 2024/9/19
 * Time: 11:33
 */
namespace Payment\WechatPay;
abstract class WechatPaymentHandle
{
    /**
     * 下单
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:36
     * @ return mixed
     */
    protected abstract function pay();

    /**
     * 查询
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:39
     * @ return mixed
     */
    protected abstract function transac();

    /**
     * 退款
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:42
     * @ return mixed
     */
    protected abstract function refunds();
}

三、工厂通道选择类代码开发

<?php
/**
 * 微信支付工厂通道选择类
 * User: 龙哥·三年风水
 * Date: 2024/9/19
 * Time: 11:47
 */
namespace Payment\WechatPay;
use app\BaseError;
use Payment\WechatPay\impl\AppApi;
use Payment\WechatPay\impl\Applet;
use Payment\WechatPay\impl\H5Api;
use Payment\WechatPay\impl\JsApi;
use Payment\WechatPay\impl\NativeApi;

class WechatPaymentFactory
{
    protected static $instance = null;//缓存实例
    protected $merchantId = null;// 商户号
    protected $merchantSerialNumber = null;// 商户API证书序列号
    protected $appid = null;// 公众号ID
    protected $merchantPrivateKey = null;// 商户私钥
    protected $channelType = 0;//通道类型

    /**
     * 初始化资源
     */

    public function __construct($type){
        $this->merchantId = config('pay.wechat.merchant_id');
        $this->appid = config('pay.wechat.app_id');
        $this->merchantSerialNumber = config('pay.wechat.merchant_serial_number');
        $file = file_get_contents('./wechatpay/apiclient_key.pem');
        $this->merchantPrivateKey = openssl_get_privatekey($file);// 读取商户秘钥
        self::$instance = null;
        $this->channelType = $type;
    }


    /**
     * 通道选择
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 14:34
     * @ param $url
     * @ param $data
     * @ return null|JsApi
     */

    public function sendWechatPaymentHandle($url,$data){
        switch ((int)$this->channelType){
            case 1:
                $data['appid'] = $this->appid;
                $data['mchid'] = $this->merchantId;
                $authorization = $this->getSign($url,$data);
                self::$instance = new JsApi($url,$authorization,$data);
                break;
            case 2:
                $data['appid'] = $this->appid;
                $data['mchid'] = $this->merchantId;
                $authorization = $this->getSign($url,$data);
                self::$instance = new AppApi($url,$authorization,$data);
                break;
            case 3:
                $data['appid'] = $this->appid;
                $data['mchid'] = $this->merchantId;
                $authorization = $this->getSign($url,$data);
                self::$instance = new H5Api($url,$authorization,$data);
                break;
            case 4:
                $data['appid'] = $this->appid;
                $data['mchid'] = $this->merchantId;
                $authorization = $this->getSign($url,$data);
                self::$instance = new NativeApi($url,$authorization,$data);
                break;
            case 5:
                $data['appid'] = $this->appid;
                $data['mchid'] = $this->merchantId;
                $authorization = $this->getSign($url,$data);
                self::$instance = new Applet($url,$authorization,$data);
                break;
            default:
                self::$instance = null;
                throw new BaseError("未设置任何通道",50000,200);
                break;
        }
        return self::$instance;
    }

    /**
     * 生成签名
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 14:01
     * @ param $url
     * @ param $data
     * @ return string
     */

    protected function getSign($url,$data){
        $timestamp = time();
        $nonce = alnum(12).date('YmdHis', $timestamp) . rand(1000, 9999);
        $url_parts = parse_url($url);
        $canonical_url = ($url_parts['path'] . (!empty($url_parts['query']) ? "?${url_parts['query']}" : ""));
        $data = json_encode($data);
        $message = 'POST' . "\n" .
            $canonical_url . "\n" .
            $timestamp . "\n" .
            $nonce . "\n" .
            $data . "\n";
        openssl_sign($message, $signature, $this->merchantPrivateKey, "sha256WithRSAEncryption");
        $sign = base64_encode($signature);
        $schema = 'WECHATPAY2-SHA256-RSA2048';
        $token = sprintf('mchid="%s",nonce_str="%s",timestamp="%d",serial_no="%s",signature="%s"',  $this->merchantId, $nonce, $timestamp, $this->merchantSerialNumber, $sign);
        return "Authorization: " . $schema . " " . $token;
    }

    /**
     *销毁资源
     */

    public function __destruct(){
        $this->merchantId = null;
        $this->appid = null;
        $this->merchantSerialNumber = null;
        $this->merchantPrivateKey = null;
        self::$instance = null;
    }
}

四、AppApi支付产品查账代码开发

<?php
/**
 * App支付方式
 * User: 龙哥·三年风水
 * Date: 2024/9/20
 * Time: 10:55
 */
namespace Payment\WechatPay\impl;
use Payment\WechatPay\WechatPaymentHandle;
use app\BaseError;
class AppApi extends WechatPaymentHandle
{
    protected $url = ''; //访问路径
    protected $header = ''; //头文件
    protected $data = []; //数据组

    /**
     * 初始化
     * @ param $url
     * @ param $header
     * @ param $data
     */

    public function __construct($url,$header,$data){
        $this->url = $url;
        $this->header = $header;
        $this->data = $data;
    }

    /**
     * 下单
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:36
     * @ return mixed
     */
    public function pay()
    {
        $res = http_post($this->url, $this->header, $this->data);
        $arr = json_decode($res, true);
        if(isset($arr['code'])) {
            $error['code'] = $arr['code'];
            $error['message'] = $arr['message'];
            $error['timestamp'] = time();
            $error['ip'] = get_client_ip();
            file_put_contents('app_pay.txt', json_encode($error) . PHP_EOL, FILE_APPEND);
            throw new BaseError($arr['message'], 50000, 200);
        }
        return $arr;
    }

    /**
     * 查询
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:39
     * @ return mixed
     */
    public function transac()
    {
        $res = http_gets($this->url, $this->header);
        $arr = json_decode($res, true);
        if(isset($arr['code'])) {
            $error['code'] = $arr['code'];
            $error['message'] = $arr['message'];
            $error['timestamp'] = time();
            $error['ip'] = get_client_ip();
            file_put_contents('js_pay.txt', json_encode($error) . PHP_EOL, FILE_APPEND);
            throw new BaseError($arr['message'], 50000, 200);
        }
        return $arr;
    }

    /**
     * 退款
     * User: 龙哥·三年风水
     * Date: 2024/9/19
     * Time: 11:42
     * @ return mixed
     */
    public function refunds()
    {
        $res = http_post($this->url, $this->header, $this->data);
        $arr = json_decode($res, true);
        if(isset($arr['code'])) {
            $error['code'] = $arr['code'];
            $error['message'] = $arr['message'];
            $error['timestamp'] = time();
            $error['ip'] = get_client_ip();
            file_put_contents('app_pay.txt', json_encode($error) . PHP_EOL, FILE_APPEND);
            throw new BaseError($arr['message'], 50000, 200);
        }
        return $arr;
    }

    /**
     *
     */

    public function __destruct(){
        $this->url = '';
        $this->header = '';
        $this->data = [];
    }
}

五、微信支付订单号查询订单测试调用

public function index(){
        //定义参数
        $transaction_id = '支付时返回微信订单号';
        // 初始化通道
        $wechatPaymentFactory = new WechatPaymentFactory(2);
        // 选择实例
        $wechatPaymentHandle = $wechatPaymentFactory->sendWechatPaymentHandle("https://api.mch.weixin.qq.com/v3/pay/transactions/id/{$transaction_id}",'');
        $res = $wechatPaymentHandle->pay();
        var_dump($res);
}

六、商户订单号查询订单测试调用

public function index(){
        //定义参数
        $out_trade_no = '支付时系统创建的支付单号';
        // 初始化通道
        $wechatPaymentFactory = new WechatPaymentFactory(2);
        // 选择实例
        $wechatPaymentHandle = $wechatPaymentFactory->sendWechatPaymentHandle("https://api.mch.weixin.qq.com/v3/pay/transactions/out-trade-no/{$out_trade_no}",'');
        $res = $wechatPaymentHandle->pay();
        var_dump($res);
}