java實(shí)現(xiàn)微信小程序退款

請(qǐng)仔細(xì)閱讀微信退款文檔 微信退款文檔

申請(qǐng)退款

退款需要有證書，參照：安全規(guī)范第三條 API證書

/**
     * @DESCRIPTION: 調(diào)用微信退款
     */
    public void payOrderRefund() {
        try {
            //查詢需要退款的金額
            double refundMoney = 0.0;

            if (驗(yàn)證退款金額,不驗(yàn)證也可以) {
                //封裝參數(shù)
                Map<String, String> data = this.createData(refundMoney);

                //MD5運(yùn)算生成簽名，這里是第一次簽名，用于調(diào)用統(tǒng)一下單接口
                //WeChat.KEY：微信支付的商戶密鑰，需要在微信后臺(tái)設(shè)置，包括后面用到的 KEY 都是這個(gè)值
                String mySign = this.sign(this.createLinkString(data), WeChat.KEY, "utf-8").toUpperCase();
                data.put("sign", mySign);
                log.info("退款 簽名：" + mySign);
                log.info("向微信服務(wù)器發(fā)送退款請(qǐng)求...");

                //支付結(jié)果通知的xml格式數(shù)據(jù)
                //退款的post請(qǐng)求方法需要有證書驗(yàn)證
                String xmlStr = httpUtils.postData(""https://api.mch.weixin.qq.com/secapi/pay/refund"", this.GetMapToXML(data));
                log.info("請(qǐng)求數(shù)據(jù)：" + xmlStr);

                Map notifyMap = this.doXMLParse(xmlStr);

                if (WeChat.SUCCESS.equals(notifyMap.get("return_code"))) {
                    if (WeChat.SUCCESS.equals(notifyMap.get("result_code"))) {
                        log.info("退款請(qǐng)求成功");
                    } else {
                        log.info("退款失敗！原因：" + notifyMap.get("err_code_des"));
                    }
                } else {
                    log.info("退款失敗！原因：" + notifyMap.get("return_msg"));
                }
            }
        } catch (Exception e) {
            log.info("退款異常：" + e.getMessage());
            e.printStackTrace();
        } 
    }

下面的工具方法可以和上面的放在一起也可以單獨(dú)寫一個(gè)工具類

封裝退款參數(shù)

//封裝退款請(qǐng)求需要的數(shù)據(jù)
    private Map<String, String> createData(OrderItemDto orderItemDto, double refundMoney) {

        Map<String, String> data = new HashMap<>();

        //隨機(jī)字符串
        String nonce_str = PayUtil.getRandomStringByLength(32);
        //商戶訂單號(hào)
        String out_trade_no = orderItemDto.getOrderNo();
        //商戶退款訂單號(hào)
        String out_refund_no = PayUtil.createOrderNoOrRefundNo(orderItemDto.getHotelId());
        //訂單總金額 微信支付提交的金額是不能帶小數(shù)點(diǎn)的，且是以分為單位,這邊需要轉(zhuǎn)成字符串類型，否則后面的簽名會(huì)失敗
        String total_fee = String.valueOf((int) (orderItemDto.getAmount() * 100));
        //退款總金額
        String refund_fee = String.valueOf((int) (refundMoney * 100));

        data.put("appid", appid);
        data.put("mch_id", WeChat.MCH_ID);
        data.put("nonce_str", nonce_str);
        data.put("sign_type", WeChat.SIGNTYPE);
        data.put("out_trade_no", out_trade_no);
        data.put("out_refund_no", out_refund_no);
        data.put("total_fee", total_fee);
        data.put("refund_fee", refund_fee);
        data.put("notify_url", WeChat.REFUND_NOTIFY_URL);
        data.put("refund_desc", WeChat.REFUND_DESC);

        return data;
    }

簽名

/**
     * 簽名字符串
     *
     * @param text          需要簽名的字符串
     * @param key           商戶平臺(tái)設(shè)置的密鑰
     * @param input_charset 編碼格式
     * @return 簽名結(jié)果
     */
    public static String sign(String text, String key, String input_charset) {
        text = text + "&key=" + key;
        return DigestUtils.md5Hex(getContentBytes(text, input_charset));
    }

轉(zhuǎn)換xml

public static String GetMapToXML(Map<String, String> param) {
        StringBuffer sb = new StringBuffer();
        sb.append("<xml>");
        for (Map.Entry<String, String> entry : param.entrySet()) {
            sb.append("<" + entry.getKey() + ">");
            sb.append(entry.getValue());
            sb.append("</" + entry.getKey() + ">");
        }
        sb.append("</xml>");
        return sb.toString();
    }

解析xml

/**
     * 解析xml,返回第一級(jí)元素鍵值對(duì)。如果第一級(jí)元素有子節(jié)點(diǎn)，則此節(jié)點(diǎn)的值是子節(jié)點(diǎn)的xml數(shù)據(jù)。
     *
     * @param strxml
     * @return
     * @throws IOException
     */
    public static Map doXMLParse(String strxml) throws Exception {
        if (stringUtils.isEmpty(strxml)) {
            return null;
        }
        Map m = new HashMap();
        InputStream in = String2Inputstream(strxml);
        SAXBuilder builder = new SAXBuilder();
        Document doc = builder.build(in);
        Element root = doc.getRootElement();
        List list = root.getChildren();
        Iterator it = list.iterator();
        while (it.hasNext()) {
            Element e = (Element) it.next();
            String k = e.getName();
            String v = "";
            List children = e.getChildren();
            if (children.isEmpty()) {
                v = e.getTextNormalize();
            } else {
                v = getChildrenText(children);
            }
            m.put(k, v);
        }
        //關(guān)閉流
        in.close();
        return m;
    }

排序并按規(guī)則拼接

/**
     * 把數(shù)組所有元素排序，并按照“參數(shù)=參數(shù)值”的模式用“&”字符拼接成字符串
     *
     * @param params 需要排序并參與字符拼接的參數(shù)組
     * @return 拼接后字符串
     */
    public static String createLinkString(Map<String, String> params) {
        List<String> keys = new ArrayList<>(params.keySet());
        Collections.sort(keys);
        String prestr = "";
        for (int i = 0; i < keys.size(); i++) {
            String key = keys.get(i);
            String value = params.get(key);
            if (i == keys.size() - 1) {
                // 拼接時(shí)，不包括最后一個(gè)&字符
                prestr = prestr + key + "=" + value;
            } else {
                prestr = prestr + key + "=" + value + "&";
            }
        }
        return prestr;
    }

http工具類

import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.ssl.SSLContexts;
import org.apache.http.util.EntityUtils;

import javax.net.ssl.SSLContext;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.KeyStore;

@Slf4j
public class httpUtils {

    // 連接超時(shí)時(shí)間，默認(rèn)10秒
    private static int socketTimeout = 10000;
    // 傳輸超時(shí)時(shí)間，默認(rèn)30秒
    private static int connectTimeout = 30000;
    // HTTP請(qǐng)求器
    private static CloseableHttpClient httpClient;
    // 請(qǐng)求器的配置
    private static RequestConfig requestConfig;

    /**
     * 加載證書
     */
    private static void initCert() throws Exception {
        // 證書密碼，默認(rèn)為商戶ID
        String key = "";
        // 商戶證書的路徑
        //public static final String CERT_PATH = "E:/workspace/apiclient_cert.p12"; //本地路徑
        String CERT_PATH = "/usr/local/dev/guns/cert/"; // 服務(wù)器路徑
        String path = CERT_PATH + "qcdr_cert.p12";

        InputStream instream = null;
        try {
            // 讀取本機(jī)存放的PKCS12證書文件
            instream = new FileInputStream(new File(path));

            /*ClassPathResource classPathResource = new ClassPathResource(path);
            //獲取文件流
            instream = classPathResource.getInputStream();
            instream = Thread.currentThread().getContextClassLoader().getResourceAsStream(path);*/
        } catch (Exception e) {
            log.error("商戶證書不正確-->>" + e);
        }
        try {
            // 指定讀取證書格式為PKCS12
            KeyStore keyStore = KeyStore.getInstance("PKCS12");
            // 指定PKCS12的密碼(商戶ID)
            keyStore.load(instream, key.toCharArray());

            SSLContext sslcontext = SSLContexts.custom().loadKeyMaterial(keyStore, key.toCharArray()).build();
            // 指定TLS版本
            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[]{"TLSv1"}, null, SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
            // 設(shè)置httpclient的SSLSocketFactory
            httpClient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
        } catch (Exception e) {
            log.error("商戶秘鑰不正確-->>" + e);
        } finally {
            instream.close();
        }
    }

    /**
     * 通過(guò)Https往API post xml數(shù)據(jù)
     *
     * @param url    退款地址
     * @param xmlObj 要提交的XML數(shù)據(jù)對(duì)象
     * @return
     */
    public static String postData(String url, String xmlObj) {
        // 加載證書
        try {
            initCert();
        } catch (Exception e) {
            e.printStackTrace();
        }
        String result = null;
        HttpPost httpPost = new HttpPost(url);
        // 得指明使用UTF-8編碼，否則到API服務(wù)器XML的中文不能被成功識(shí)別
        StringEntity postEntity = new StringEntity(xmlObj, "UTF-8");
        httpPost.addHeader("Content-Type", "text/xml");
        httpPost.setEntity(postEntity);
        // 根據(jù)默認(rèn)超時(shí)限制初始化requestConfig
        requestConfig = RequestConfig.custom()
                .setSocketTimeout(socketTimeout)
                .setConnectTimeout(connectTimeout)
                .build();
        // 設(shè)置請(qǐng)求器的配置
        httpPost.setConfig(requestConfig);
        try {
            HttpResponse response = null;
            try {
                response = httpClient.execute(httpPost);
            } catch (IOException e) {
                e.printStackTrace();
            }
            HttpEntity entity = response.getEntity();
            try {
                result = EntityUtils.toString(entity, "UTF-8");
            } catch (IOException e) {
                e.printStackTrace();
            }
        } finally {
            httpPost.abort();
        }
        return result;
    }

    /**
     * @param requestUrl    請(qǐng)求地址
     * @param requestMethod 請(qǐng)求方法
     * @param outputStr     參數(shù)
     */
    public static String httpRequest(String requestUrl, String requestMethod, String outputStr) {
        // 創(chuàng)建SSLContext
        StringBuffer buffer = null;
        try {
            URL url = new URL(requestUrl);
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            conn.setRequestMethod(requestMethod);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.connect();
            //往服務(wù)器端寫內(nèi)容
            if (null != outputStr) {
                OutputStream os = conn.getOutputStream();
                os.write(outputStr.getBytes("utf-8"));
                os.close();
            }
            // 讀取服務(wù)器端返回的內(nèi)容
            InputStream is = conn.getInputStream();
            InputStreamReader isr = new InputStreamReader(is, "utf-8");
            BufferedReader br = new BufferedReader(isr);
            buffer = new StringBuffer();
            String line = null;
            while ((line = br.readLine()) != null) {
                buffer.append(line);
            }
            br.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return buffer.toString();
    }
}

下面是小程序退款回調(diào)函數(shù)

退款回調(diào)函數(shù)

 /**
     * 微信退款回調(diào)函數(shù)
     */
    public void payOrderRefundCallback(HttpServletRequest request, HttpServletResponse response) {

        log.info("======================= 微信退款回調(diào)開始 =======================");
        String inputLine = "";
        String notityXml = "";
        StringBuffer buffer = new StringBuffer();
        buffer.append("<xml>");

        try {
            while ((inputLine = request.getReader().readLine()) != null) {
                notityXml += inputLine;
            }
            //關(guān)閉流
            request.getReader().close();
            log.info("退款  微信回調(diào)內(nèi)容信息：" + notityXml);

            //解析成Map
            Map map = this.doXMLParse(notityXml);

            //判斷 退款是否成功
            if ("SUCCESS".equals(map.get("return_code").toString())) {

                log.info("開始解密回調(diào)信息...");

                //解密返回的加密信息
                String passMap = AESUtil.decryptData(map.get("req_info").toString());

                log.info("解密成功!");
                //拿到解密信息
                map = this.doXMLParse(passMap);

                if ("SUCCESS".equals(map.get("refund_status"))) {

                    //退款回調(diào)成功，添加業(yè)務(wù)邏輯，可以修改訂退款成功

                    buffer.append("<return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg>");

                } else {
                    log.info("REFUNDCLOSE".equals(map.get("refund_status")) == true ? "退款關(guān)閉" : "退款異常");
                    buffer.append("<return_code><![CDATA[FAIL]]></return_code>");
                    buffer.append("<return_msg><![CDATA[退款異常]]></return_msg>");
                }

            } else {
                log.info("退款 微信回調(diào)返回失敗");
                buffer.append("<return_code><![CDATA[FAIL]]></return_code>");
                buffer.append("<return_msg><![CDATA[請(qǐng)求退款回調(diào)函數(shù)失敗]]></return_msg>");
            }

            buffer.append("</xml>");
            //給微信服務(wù)器返回 成功標(biāo)識(shí) 否則會(huì)一直詢問(wèn)是否回調(diào)成功
            PrintWriter writer = response.getWriter();
            writer.print(buffer.toString());

            log.info("退款回調(diào)通知微信的xml【" + buffer.toString() + "】");

        } catch (Exception e) {
            log.info("退款異常：" + e.getMessage());
            System.out.println(e);
            e.printStackTrace();
        }

        log.info("======================= 微信退款回調(diào)結(jié)束 =======================");
    }

解密回調(diào)字符串

import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;

public class AESUtil {
    /**
     * 密鑰算法
     */
    private static final String ALGORITHM = "AES";
    /**
     * 加解密算法/工作模式/填充方式
     */
    private static final String ALGORITHM_MODE_PADDING = "AES/ECB/PKCS5Padding";
    /**
     * 生成key
     */
    private static SecretKeySpec key = new SecretKeySpec(PayUtil.MD5Encode(WeChat.KEY, "UTF-8").toLowerCase().getBytes(), ALGORITHM);

    /**
     * AES加密
     *
     * @param data
     * @return
     * @throws Exception
     */
    public static String encryptData(String data) throws Exception {
        // 創(chuàng)建密碼器
        Cipher cipher = Cipher.getInstance(ALGORITHM_MODE_PADDING);
        // 初始化
        cipher.init(Cipher.ENCRYPT_MODE, key);
        return PayUtil.encode(cipher.doFinal(data.getBytes()));
    }

    /**
     * AES解密
     *
     * @param base64Data
     * @return
     * @throws Exception
     */
    public static String decryptData(String base64Data) throws Exception {
        Cipher cipher = Cipher.getInstance(ALGORITHM_MODE_PADDING);
        cipher.init(Cipher.DECRYPT_MODE, key);
        return new String(cipher.doFinal(PayUtil.decode(base64Data)));
    }
}

如果微信支付（退款）業(yè)務(wù)出現(xiàn)AES解密失敗（Illegal key size or default parameters）
請(qǐng)參照：AES解密失敗

至此整個(gè)微信小程序支付退款完成，如果有什么問(wèn)題歡迎指出

微信小程序 支付 詳細(xì)代碼地址：微信小程序支付