ThinkPHP微信自动退款功能实现-无缝对接微信支付自动退款流程

在ThinkPHP框架中实现微信自动退款功能，通常涉及调用微信支付的退款API。以下是一个基本的实现步骤和示例代码，帮助你理解如何在ThinkPHP中集成微信自动退款功能。

前提条件

微信支付商户账号：确保你已经有微信支付的商户账号，并获取到相关的密钥信息（如商户号、API密钥等）。
SSL证书：微信退款接口需要使用SSL证书进行双向认证。
ThinkPHP环境：确保你的开发环境已经搭建好ThinkPHP框架。

实现步骤

加载微信支付SDK或自己封装请求：
- 你可以选择使用现有的微信支付SDK，或者自己封装HTTP请求来调用微信API。
准备退款参数：
- 包括商户订单号、退款金额、退款原因等。
调用微信退款API：
- 使用准备好的参数和证书，调用微信支付的退款接口。
处理响应：
- 根据微信返回的响应结果，处理退款成功或失败的情况。

示例代码

以下是一个简单的示例代码，展示如何在ThinkPHP中调用微信退款API：

<?php
namespace app\controller;

use think\facade\Log;

class WeChatRefund
{
    private $mch_id; // 商户号
    private $app_id; // 公众账号ID
    private $key;    // API密钥
    private $cert_path; // 证书路径
    private $key_path;  // 私钥路径

    public function __construct()
    {
        $this->mch_id = 'your_mch_id';
        $this->app_id = 'your_app_id';
        $this->key = 'your_api_key';
        $this->cert_path = '/path/to/your/apiclient_cert.pem';
        $this->key_path = '/path/to/your/apiclient_key.pem';
    }

    public function refund($out_trade_no, $refund_fee, $reason = '')
    {
        $url = 'https://api.mch.weixin.qq.com/secapi/pay/refund';

        $data = [
            'appid' => $this->app_id,
            'mch_id' => $this->mch_id,
            'nonce_str' => md5(uniqid()),
            'out_trade_no' => $out_trade_no,
            'out_refund_no' => md5($out_trade_no . time()), // 商户退款单号
            'total_fee' => 100, // 原订单金额（分），需与实际订单一致
            'refund_fee' => $refund_fee, // 退款金额（分）
            'refund_desc' => $reason, // 退款原因
            'notify_url' => 'https://yourdomain.com/wechat/refund_notify', // 退款结果通知url
        ];

        $data['sign'] = $this->makeSign($data);

        $xml = $this->arrayToXml($data);

        $response = $this->postXmlSSLCurl($xml, $url);

        // 处理响应
        $result = $this->xmlToArray($response);
        if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
            Log::write('Refund successful: ' . json_encode($result));
            return true;
        } else {
            Log::write('Refund failed: ' . json_encode($result));
            return false;
        }
    }

    private function makeSign($data)
    {
        // 签名生成逻辑
        ksort($data);
        $string = urldecode(http_build_query($data)) . '&key=' . $this->key;
        return strtoupper(md5($string));
    }

    private function arrayToXml($arr)
    {
        // 数组转XML
        $xml = "<xml>";
        foreach ($arr as $key => $val) {
            $xml .= "<$key><![CDATA[$val]]></$key>";
        }
        $xml .= "</xml>";
        return $xml;
    }

    private function xmlToArray($xml)
    {
        // XML转数组
        libxml_disable_entity_loader(true);
        return json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
    }

    private function postXmlSSLCurl($xml, $url, $timeout = 30)
    {
        // 使用cURL发送POST请求，支持SSL证书
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_SSLCERT, $this->cert_path);
        curl_setopt($ch, CURLOPT_SSLKEY, $this->key_path);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
        $data = curl_exec($ch);
        if ($data) {
            curl_close($ch);
            return $data;
        } else {
            $error = curl_errno($ch) . ':' . curl_error($ch);
            curl_close($ch);
            throw new \Exception('Curl error: ' . $error);
        }
    }
}