Java开发微信Navicat支付完整版

Java开发微信Navicat支付完整版

一：准备工作

2：去微信商户平台注册一个商户号，用于收款

4：支付结果异步通知（需要重点注意）

注意：请先详细查看官方文档按步骤开发，一切以官方文档为主 微信Navicat支付官方文档

5：测试的时候一定要使用内网穿透软件，否则回调时会报错

二：开发代码

WeChatPayConfig：

public class WeChatPayConfig {

private String APPID = "";

//商户号KEY

private String KEY = "";

//商户号ID

private String MCHID = "";

//支付完成后微信回调地址，需要外网能访问要是域名，不能是127.0.0.1跟localhost

private String NOTIFY_URL = "";

}

WeChatPayServcie：

public interface WeChatPayServcie {

//微信支付下单

public Map getWxpayUrl(Map sourceMap);

//订单查询

public String orderQuery(String out_trade_no);

}

@Service

public class WeChatPayServiceImpl implements WeChatPayServcie {

/**

* 微信支付请求

* @param sourceMap

* @return

*/

public Map getWxpayUrl(Map sourceMap) {

SortedMap signParams = new TreeMap();

String nonce_str = UUID.randomUUID().toString().trim().replaceAll("-", "");

signParams.put("appid", PayConfig.APPID);

signParams.put("mch_id",PayConfig.MCHID);

signParams.put("nonce_str",sourceMap.get("nonce_str"));

signParams.put("product_id",sourceMap.get("prod_id"));

signParams.put("body",sourceMap.get("body"));

signParams.put("out_trade_no",sourceMap.get("out_trade_no"));

signParams.put("total_fee",sourceMap.get("total_fee"));

signParams.put("spbill_create_ip", WxUtil.getIp());

signParams.put("notify_url",PayConfig.NOTYFLY_URL);

signParams.put("trade_type","NATIVE");

String sign = WxUtil.createSign(signParams,PayConfig.KEY);

signParams.put("sign",sign);

String xmlPackage = WxUtil.parseMapXML(signParams);

Map resultMap = new HashMap();

try {

String result = HttpUtil.post("https://api.mch.weixin.qq.com/pay/unifiedorder",xmlPackage);

resultMap = WxUtil.parseXmlMap(result);

} catch (Exception e) {

e.printStackTrace();

}

String returnCode = (String) resultMap.get("return_code");

String returnMsg = (String) resultMap.get("return_msg");

if (returnCode.equalsIgnoreCase("FAIL")) {

throw new RuntimeException(returnMsg);

}

String result_code = (String) resultMap.get("result_code");

if (result_code.equalsIgnoreCase("FAIL")) {

throw new RuntimeException(resultMap.get("err_code_des"));

}

String code_url = (String) resultMap.get("code_url");

Map map = new HashMap<>();

map.put("code_url",code_url);

map.put("out_trade_no",sourceMap.get("out_trade_no"));

return map;

}

/**

* 微信支付订单查询

* @param out_trade_no

* @return

*/

public String orderQuery(String out_trade_no) {

String nonce_str = UUID.randomUUID().toString().trim().replaceAll("-", "");

SortedMap signParams = new TreeMap<>();

signParams.put("appid", payConfig.getWeChatPorpetties().getAppId());

signParams.put("mch_id",payConfig.getWeChatPorpetties().getMchId());

signParams.put("out_trade_no",out_trade_no);

signParams.put("nonce_str",nonce_str);

String sign = WxUtil.createSign(signParams,payConfig.getWeChatPorpetties().getApiKey());

signParams.put("sign",sign);

String xmlPackage = WxUtil.parseMapXML(signParams);

Map resultMap = new HashMap();

try {

String result = HttpUtil.post("https://api.mch.weixin.qq.com/pay/orderquery",xmlPackage);

resultMap = WxUtil.parseXmlMap(result);

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException("渠道网络异常");

}

String returnCode = (String) resultMap.get("return_code");

String returnMsg = (String) resultMap.get("return_msg");

if (returnCode.equalsIgnoreCase(PayContants.FAIL)) {

throw new RuntimeException(returnMsg);

}

String result_code = (String) resultMap.get("result_code");

if (result_code.equalsIgnoreCase(PayContants.FAIL)) {

throw new RuntimeException(resultMap.get("err_code_des"));

}

String trade_state = (String) resultMap.get("trade_state");

return trade_state;

}

}

WeChatPayController：

/**

* 微信支付接口

*/

@Controller

public class WxPayController {

@Autowired

WeChatPayServcie weChatPayServcie;

/**

* 微信支付下单

* payID可以不用传自己生成32位以内的随机数就好，要保证不重复

* totalFee金额一定要做判断，判断这笔支付金额与数据库是否一致

*/

@RequestMapping("pay")

@ResponseBody

public Map toWxpay(HttpServletRequest httpRequest,String payId, String totalFee, String body){

System.out.println("开始微信支付...");

Map map = new HashMap<>();

String nonce_str = UUID.randomUUID().toString().trim().replaceAll("-", "");

//生成一笔支付记录

//拼接支付参数

Map paramMap = new HashMap<>();

paramMap.put("nonce_str", nonce_str);

paramMap.put("prod_id", payId);

paramMap.put("body", body);

paramMap.put("total_fee", totalFee);

paramMap.put("out_trade_no", payId);

//发送支付请求并获取返回参数与二维码，用于支付与调用查询接口

Map returnMap = weChatPayServcie.getWxpayUrl(paramMap);

httpRequest.setAttribute("out_trade_no", payId);

httpRequest.setAttribute("total_fee", totalFee);

//code_url就是二维码URL，可以把这个URL放到草料二维码中生成微信二维码

httpRequest.setAttribute("code_url", returnMap.get("code_url"));

map.put("out_trade_no", payId);

map.put("total_fee", String.valueOf(bigDecimal));

map.put("code_url", returnMap.get("code_url"));

return map;

}

/**

* 查询微信订单

* ot_trade_no是支付

*/

@RequestMapping("query")

@ResponseBody

public Root orderQuery(String out_trade_no){

return weixinPayServcie.orderQuery(queryCallbackForm.getOut_trade_no());

}

/**

* 微信支付回调，这个地址就是Config中的NOTYFLY_URL

*/

@RequestMapping("callback")

public void notify_url(HttpServletRequest request, HttpServletResponse response) throws DocumentException, ServletException, IOException,Throwable {

System.out.print("微信支付回调获取数据开始...");

String inputLine;

String notityXml = "";

try {

while ((inputLine = request.getReader().readLine()) != null) {

notityXml += inputLine;

}

request.getReader().close();

} catch (Exception e) {

WxUtil.sendXmlMessage(request,response, PayContants.FAIL);

throw new RuntimeException("回调数据xml获取失败！");

}

if(StringUtils.isEmpty(notityXml)){

WxUtil.sendXmlMessage(request,response, PayContants.FAIL);

throw new RuntimeException("回调数据xml为空！");

}

Map resultMap = XMLParse.parseXmlMap(notityXml);

String returnCode = (String) resultMap.get("return_code");

String returnMsg = (String) resultMap.get("return_msg");

if (returnCode.equalsIgnoreCase(PayContants.FAIL)) {

WxUtil.sendXmlMessage(request,response, PayContants.FAIL);

throw new RuntimeException(returnMsg);

}

String resultCode = (String) resultMap.get("result_code");

if (resultCode.equalsIgnoreCase(PayContants.FAIL)) {

WxUtil.sendXmlMessage(request,response, PayContants.FAIL);

throw new RuntimeException(resultMap.get("err_code_des"));

}

SortedMap paramMap = new TreeMap<>();

paramMap.put("appid",resultMap.get("appid"));

paramMap.put("mch_id",resultMap.get("mch_id"));

paramMap.put("nonce_str",resultMap.get("nonce_str"));

paramMap.put("body",resultMap.get("body"));

paramMap.put("openid", resultMap.get("openid"));

paramMap.put("is_subscribe",resultMap.get("is_subscribe"));

paramMap.put("trade_type",resultMap.get("trade_type"));

paramMap.put("bank_type",resultMap.get("bank_type"));

paramMap.put("total_fee",resultMap.get("total_fee"));

paramMap.put("fee_type",resultMap.get("fee_type"));

paramMap.put("cash_fee",resultMap.get("cash_fee"));

paramMap.put("transaction_id",resultMap.get("transaction_id"));

paramMap.put("out_trade_no",resultMap.get("out_trade_no"));

paramMap.put("time_end",resultMap.get("time_end"));

paramMap.put("return_code",resultMap.get("return_code"));

paramMap.put("return_msg",resultMap.get("return_msg"));

paramMap.put("result_code",resultMap.get("result_code"));

String out_trade_no = (String) resultMap.get("out_trade_no");

String sign = SignUtil.createSign(paramMap,WxPayConfig.KEY);

String mySign =(String) resultMap.get("sign");

//回调一定要验证签名以防数据被篡改

if(sign.equals(mySign)){

System.out.println("回调签名验证成功！");

//修改业务逻辑，将那笔支付状态改为已支付

}

WxUtil.sendXmlMessage(request,response, PayContants.SUCCESS);

}else{

WxUtil.shttp://endXmlMessage(request,response, PayContants.FAIL);

throw new RuntimeException("签名不一致！");

}

}

}

WxUtil：

package com.ys.commons.utils.pay;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.net.InetAddress;

import java.net.UnknownHostException;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

//微信工具类

public class WxUtil {

//获取当前IP

public static String getIp() {

try {

String spbill_create_ip = InetAddress.getLocalHost().getHostAddress();

return spbill_create_ip;

} catch (UnknownHostException var2) {

var2.printStackTrace();

return "获取IP失败...";

}

}

//输出xml格式

public static void sendXmlMessage(HttpServletRequest request, HttpServletResponse response, String content) {

try {

String contentXml = "<![CDATA[" + content + "]]>";

OutputStream os = response.getOutputStream();

BufferedWriter resBr = new BufferedWriter(new OutputStreamWriter(os));

resBr.write(contentXml);

resBr.flush();

resBr.close();

} catch (IOException var6) {

var6.printStackTrace();

}

}

//生成sign签名

public static String createSign(SortedMap packageParams, String KEY) {

StringBuffer sb = new StringBuffer();

Set> es = packageParams.entrySet();

Iterator it = es.iterator();

while(it.hasNext()) {

Entry entry = (Entry)it.next();

String k = (String)entry.getKey();

String v = (String)entry.getValue();

if(null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {

sb.append(k + "=" + v + "&");

}

}

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

String sign = MD5Util.MD5Encode(sb.toString(), "UTF-8").toUpperCase();

return sign;

}

//将map转为xml

public static String parseMapXML(SortedMap map) {

String xmlResult = "";

StringBuffer sb = new StringBuffer();

sb.append("");

Iterator var3 = map.keySet().iterator();

while(var3.hasNext()) {

String key = (String)var3.next();

String value = "<![CDATA[" + map.get(key) + "]]>";

sb.append("<" + key + ">" + value + "" + key + ">");

System.out.println();

}

sb.append("");

xmlResult = sb.toString();

return xmlResult;

}

//将xml转为map

public static Map parseXmlMap(String xml) throws DocumentException {

Document document = DocumentHelper.parseText(xml);

Element root = document.getRootElement();

List elementList = root.elements();

Map map = new HashMap();

Iterator var5 = elementList.iterator();

while(var5.hasNext()) {

Element e = (Element)var5.next();

map.put(e.getName(), e.getText());

}

return map;

}

}

发送请求需要推荐一个非常好用的工具，里面各种常用的工具都封装好了hutool，如果想直接复制代码使用也需要引入此工具的maven库

注意：此工具只支持JDK 1.7以上至此代码已经完成，有意见建议的都可以留言，后续会更新最完整最新版的PayPal支付，同时有需要的也可以看看博主的支付宝PC支付

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。