微信小程序支付之V2支付

一、引入maven

<dependency>
    <groupId>com.github.binarywang</groupId>
    <artifactId>weixin-java-pay</artifactId>
    <version>3.3.4.B</version>
    <exclusions>
        <exclusion>
            <artifactId>qrcode-utils</artifactId>
            <groupId>com.github.binarywang</groupId>
        </exclusion>
    </exclusions>
</dependency>

<!--微信支付依赖-->
<dependency>
    <groupId>org.jdom</groupId>
    <artifactId>jdom</artifactId>
    <version>1.1</version>
    <scope>compile</scope>
</dependency>

二、调用

package com.dcqq.wechat;

import com.dcqq.common.core.controller.BaseController;
import com.dcqq.common.core.domain.R;
import com.dcqq.common.core.domain.entity.SysUser;
import com.dcqq.common.utils.ip.IpUtils;
import com.dcqq.common.utils.wx.HttpUtil;
import com.dcqq.common.utils.wx.PayCommonUtil;
import com.dcqq.common.utils.wx.WxPayConfig;
import com.dcqq.common.utils.wx.XMLUtil;
import com.dcqq.system.domain.TShopOrder;
import com.dcqq.system.domain.vo.PayVo;
import com.dcqq.system.service.ISysUserService;
import com.dcqq.system.service.ITShopOrderService;
import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.util.*;

/**
 * 微信支付管理Controller
 *
 * @author dcqq
 * @date 2024-01-04
 */
@RestController
@Api(tags = "微信支付管理")
@RequestMapping("/wechat/pay")
public class ApiPayController extends BaseController {

    @Autowired
    private ITShopOrderService shopOrderService;
    @Autowired
    private ISysUserService userService;

    /**
     * 调用统一下单接口，并组装生成支付所需参数对象.
     */
    @PostMapping("/tradeOrder")
    @ApiOperation("支付接口")
    public R tradeOrder(@RequestBody PayVo payVo,HttpServletRequest request) {
        TShopOrder order = shopOrderService.getByOrderNo(payVo.getOrderNo());
        if (payVo.getPayWay()==2) {//小程序支付
            Map<String, Object> map = wxPay(order, request);
            return R.ok(map);
        }
        return null;
    }

    /**
     * @Description: 小程序支付
     * @param request
     */
    private Map<String, Object> wxPay(TShopOrder order, HttpServletRequest request){
        SysUser user = userService.selectUserById(order.getSysUserId());
        String openid=user.getOpenId();
        Integer total=order.getOrderPrice().multiply(new BigDecimal("100")).intValue();
        try {
            request.setCharacterEncoding("UTF-8");
            //订单标题
            String title = "小程序微信支付";
            //时间戳
            String times = System.currentTimeMillis() + "";
            SortedMap<String, Object> packageParams = new TreeMap<String, Object>();
            packageParams.put("appid", WxPayConfig.appid);
            packageParams.put("mch_id", WxPayConfig.mch_id);
            packageParams.put("nonce_str", times);//时间戳
            packageParams.put("body", title);//支付主体
            packageParams.put("out_trade_no", order.getOrderNo());//订单编号
            packageParams.put("total_fee", total);//元转成分
            packageParams.put("attach","");
            packageParams.put("spbill_create_ip", IpUtils.getIpAddr(request));//这里之前加了ip，但是总是获取sign失败，原因不明，之后就注释掉了
            packageParams.put("notify_url", WxPayConfig.notify_url);//支付回调接口，用于支付成功后处理业务逻辑，小程序端支付success不能保证100%回调成功，建议采用后端异步回调处理方式，回调方法在最后
            packageParams.put("trade_type", WxPayConfig.tradeType);//这个api有，固定的
            packageParams.put("openid", openid);//openid
            //获取sign
            String sign = PayCommonUtil.createSign("UTF-8", packageParams, WxPayConfig.apiKey);//最后这个是自己设置的32位密钥
            packageParams.put("sign", sign);
            //转成XML
            String requestXML = PayCommonUtil.getRequestXml(packageParams);
            System.out.println(requestXML);
            //得到含有prepay_id的XML
            String resXml = HttpUtil.postData(WxPayConfig.pay_url, requestXML);
            System.out.println(resXml);
            //解析XML存入Map
            Map map = XMLUtil.doXMLParse(resXml);
            System.out.println(map);
            // String return_code = (String) map.get("return_code");
            //得到prepay_id
            String prepay_id = (String) map.get("prepay_id");
            SortedMap<String, Object> packageP = new TreeMap<String, Object>();
            //以下map的key必须和微信参数一致，请勿修改
            packageP.put("appId", WxPayConfig.appid);//！！！注意，这里是appId,上面是appid，真怀疑写这个东西的人。。。
            packageP.put("nonceStr", times);//时间戳
            packageP.put("package", "prepay_id=" + prepay_id);//必须把package写成 "prepay_id="+prepay_id这种形式
            packageP.put("signType", WxPayConfig.signType);//paySign加密
            packageP.put("timeStamp", (System.currentTimeMillis() / 1000) + "");
            //得到paySign
            String paySign = PayCommonUtil.createSign("UTF-8", packageP, WxPayConfig.apiKey);
            packageP.put("paySign", paySign);
            return packageP;
        }catch(Exception e){
            e.printStackTrace();
        }
        return null;
    }

    /**
     * @Description:微信支付回调
     * @return
     * @throws Exception
     */
    @RequestMapping(value="/wxNotify")
    public String wxNotify(HttpServletRequest request) {
        String result = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
        try {
            DataInputStream in = new DataInputStream(request.getInputStream());
            byte[] bytes = new byte[request.getContentLength()];
            in.readFully(bytes);
            in.close();
            String xml = new String(bytes);
            Map<String, String> map = XMLUtil.doXMLParse(xml);
            if (map != null && !map.isEmpty()) {
                System.out.println(map);
                System.out.println(map.get("attach"));
                if (map.get("return_code").equals("SUCCESS")) {
                    //String[] resultBody = map.get("attach").split(",");
                    String orderSn=map.get("out_trade_no");
                    /**更新订单信息*/
                    shopOrderService.payCallback(orderSn);
                    return WxPayNotifyResponse.success("处理成功!");
                }
            }
            return result.replace("SUCCESS", "FAIL").replace("OK", "返回数据错误");
        } catch (Exception e) {
            e.printStackTrace();
            return result.replace("SUCCESS", "FAIL").replace("OK", "本地服务器内部错误");
        }
    }
}

三、引入工具类，在公共文件下创建wx文件夹，把下面的代码全部放里面

package com.dcqq.common.utils.wx;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;
import java.net.URLConnection;

public class HttpUtil {
    //private static final Log logger = Logs.get();
    private final static int CONNECT_TIMEOUT = 5000; // in milliseconds
    private final static String DEFAULT_ENCODING = "UTF-8";

    public static String postData(String urlStr, String data){
        return postData(urlStr, data, null);
    }

    public static String postData(String urlStr, String data, String contentType){
        BufferedReader reader = null;
        try {
            URL url = new URL(urlStr);
            URLConnection conn = url.openConnection();
            conn.setDoOutput(true);
            conn.setConnectTimeout(CONNECT_TIMEOUT);
            conn.setReadTimeout(CONNECT_TIMEOUT);
            if(contentType != null)
                conn.setRequestProperty("content-type", contentType);
            OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream(), DEFAULT_ENCODING);
            if(data == null)
                data = "";
            writer.write(data);
            writer.flush();
            writer.close();

            reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), DEFAULT_ENCODING));
            StringBuilder sb = new StringBuilder();
            String line = null;
            while ((line = reader.readLine()) != null) {
                sb.append(line);
                sb.append("\r\n");
            }
            return sb.toString();
        } catch (IOException e) {
            //logger.error("Error connecting to " + urlStr + ": " + e.getMessage());
        } finally {
            try {
                if (reader != null)
                    reader.close();
            } catch (IOException e) {
            }
        }
        return null;
    }
}

package com.dcqq.common.utils.wx;
import org.apache.commons.lang3.StringUtils;

import javax.servlet.http.HttpServletRequest;

/**
 * @Description:
 * @Date: 2018/7/17
 * @Author: wcf
 */
public class IpUtils {
    /**
     * IpUtils工具类方法
     * 获取真实的ip地址
     * @param request
     * @return
     */
    public static String getIpAddr(HttpServletRequest request) {
        String ip = request.getHeader("X-Forwarded-For");
        if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){
            //多次反向代理后会有多个ip值，第一个ip才是真实ip
            int index = ip.indexOf(",");
            if(index != -1){
                return ip.substring(0,index);
            }else{
                return ip;
            }
        }
        ip = request.getHeader("X-Real-IP");
        if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){
            return ip;
        }
        return request.getRemoteAddr();
    }
}

package com.dcqq.common.utils.wx;

import java.security.MessageDigest;

public class MD5 {
    private static String byteArrayToHexString(byte b[]) {
        StringBuffer resultSb = new StringBuffer();
        for (int i = 0; i < b.length; i++)
            resultSb.append(byteToHexString(b[i]));

        return resultSb.toString();
    }

    private static String byteToHexString(byte b) {
        int n = b;
        if (n < 0)
            n += 256;
        int d1 = n / 16;
        int d2 = n % 16;
        return hexDigits[d1] + hexDigits[d2];
    }

    public static String MD5Encode(String origin, String charsetname) {
        String resultString = null;
        try {
            resultString = new String(origin);
            MessageDigest md = MessageDigest.getInstance("MD5");
            if (charsetname == null || "".equals(charsetname))
                resultString = byteArrayToHexString(md.digest(resultString
                        .getBytes()));
            else
                resultString = byteArrayToHexString(md.digest(resultString
                        .getBytes(charsetname)));
        } catch (Exception exception) {
        }
        return resultString;
    }

    private static final String hexDigits[] = { "0", "1", "2", "3", "4", "5",
            "6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };

}

package com.dcqq.common.utils.wx;

import java.text.SimpleDateFormat;
import java.util.*;

public class PayCommonUtil {
    /**
     * 是否签名正确,规则是:按参数名称a-z排序,遇到空值的参数不参加签名。
     * @return boolean
     */
    public static boolean isTenpaySign(String characterEncoding, SortedMap<Object, Object> packageParams, String API_KEY) {
        StringBuffer sb = new StringBuffer();
        Set es = packageParams.entrySet();
        Iterator it = es.iterator();
        while(it.hasNext()) {
            Map.Entry entry = (Map.Entry)it.next();
            String k = (String)entry.getKey();
            String v = (String)entry.getValue();
            if(!"sign".equals(k) && null != v && !"".equals(v)) {
                sb.append(k + "=" + v + "&");
            }
        }

        sb.append("key=" + API_KEY);

        //算出摘要
        String mysign = MD5.MD5Encode(sb.toString(), characterEncoding).toLowerCase();
        String tenpaySign = ((String)packageParams.get("sign")).toLowerCase();

        //System.out.println(tenpaySign + "    " + mysign);
        return tenpaySign.equals(mysign);
    }

    /**
     * @author
     * @Description：sign签名  https://pay.weixin.qq.com/wiki/doc/api/wxa/wxa_api.php?chapter=7_7&index=3
     * @param characterEncoding
     *            编码格式
     * @param parameters
     *            请求参数
     * @return
     */
    public static String createSign(String characterEncoding, SortedMap<String, Object> packageParams, String API_KEY) {
        StringBuffer sb = new StringBuffer();
        Set es = packageParams.entrySet();
        Iterator it = es.iterator();
        while (it.hasNext()) {
            Map.Entry entry = (Map.Entry) it.next();
            String k = entry.getKey().toString();
            String v = entry.getValue().toString();
            if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
                sb.append(k + "=" + v + "&");
            }
        }
        sb.append("key=" + API_KEY);
        System.out.println(sb.toString());
        String sign = MD5.MD5Encode(sb.toString(), characterEncoding).toUpperCase();
        return sign;
    }

    /**
     * @author
     * @Description：将请求参数转换为xml格式的string
     * @param parameters
     *            请求参数
     * @return
     */
    public static String getRequestXml(SortedMap<String, Object> parameters) {
        StringBuffer sb = new StringBuffer();
        sb.append("<xml>");
        Set es = parameters.entrySet();
        Iterator it = es.iterator();
        while (it.hasNext()) {
            Map.Entry entry = (Map.Entry) it.next();
            String k = entry.getKey().toString();
            String v = entry.getValue().toString();
            if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k) || "sign".equalsIgnoreCase(k)) {
                sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");
            } else {
                sb.append("<" + k + ">" + v + "</" + k + ">");
            }
        }
        sb.append("</xml>");
        return sb.toString();
    }

    /**
     * 取出一个指定长度大小的随机正整数.
     *
     * @param length
     *            int 设定所取出随机数的长度。length小于11
     * @return int 返回生成的随机数。
     */
    public static int buildRandom(int length) {
        int num = 1;
        double random = Math.random();
        if (random < 0.1) {
            random = random + 0.1;
        }
        for (int i = 0; i < length; i++) {
            num = num * 10;
        }
        return (int) ((random * num));
    }

    /**
     * 获取当前时间 yyyyMMddHHmmss
     *
     * @return String
     */
    public static String getCurrTime() {
        Date now = new Date();
        SimpleDateFormat outFormat = new SimpleDateFormat("yyyyMMddHHmmss");
        String s = outFormat.format(now);
        return s;
    }
}

package com.dcqq.common.utils.wx;

/**
 * @Description:
 * @Date: 2018/7/17
 * @Author: wcf
 */
public class WxPayConfig {
    //小程序appid
    public static final String appid = "wxaf1111111111111111111";
    //微信支付的商户id
    public static final String mch_id = "55555555";
    //微信支付的商户密钥
    public static final String key = "A5223241994ASDr222222222";
    //支付成功后的服务器回调url
    public static final String notify_url = "http://com.ss/wechat/pay/wxNotify";
    //签名方式
    public static final String signType = "MD5";
    //交易类型
    public static final String tradeType = "JSAPI";
    //api-key
    public static final String apiKey = "A5223241994ASDr222222222";
    //微信统一下单接口地址 https://api.mch.weixin.qq.com/pay/unifiedorder
    public static final String pay_url = "https://api.mch.weixin.qq.com/pay/unifiedorder";
}

package com.dcqq.common.utils.wx;

import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

public class XMLUtil {
    public static Map doXMLParse(String strxml) throws JDOMException, IOException {
        strxml = strxml.replaceFirst("encoding=\".*\"", "encoding=\"UTF-8\"");

        if(null == strxml || "".equals(strxml)) {
            return null;
        }

        Map m = new HashMap();

        InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));
        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 = XMLUtil.getChildrenText(children);
            }

            m.put(k, v);
        }

        //关闭流
        in.close();

        return m;
    }

    /**
     * 获取子结点的xml
     * @param children
     * @return String
     */
    public static String getChildrenText(List children) {
        StringBuffer sb = new StringBuffer();
        if(!children.isEmpty()) {
            Iterator it = children.iterator();
            while(it.hasNext()) {
                Element e = (Element) it.next();
                String name = e.getName();
                String value = e.getTextNormalize();
                List list = e.getChildren();
                sb.append("<" + name + ">");
                if(!list.isEmpty()) {
                    sb.append(XMLUtil.getChildrenText(list));
                }
                sb.append(value);
                sb.append("</" + name + ">");
            }
        }

        return sb.toString();
    }
}