**因工作需要，需要對接微信和支付寶掃碼支付功能。研究后發現微信的native支付第二種方式及支付寶支付當面付模式滿足業務需求,查了網上資料和自己對接官方文檔最終實現需求，現將實現過程及代碼做一簡單記錄。
微信native：
業務流程：
1.商戶后台生成訂單；
2.調用【統一下單接口】發送預支付請求，生成預支付訂單返回qrcodeURL並展示；
3.調用【訂單查詢接口】輪詢訂單狀態
4.根據返回查詢結果進行業務操作：
** 1. 支付成功。（記錄數據庫）
** 2. 支付不成功：
**** 1. 超時：記錄支付失敗（記錄數據庫）
**** 2. 未超時：繼續輪詢查詢接口
配置類PayConfigUtil：
//微信支付參數
public class PayConfigUtil {
public static final String APP_ID = "";//微信開發平台應用ID
public static final String MCH_ID = "";//商戶號(商戶號ID)
public static final String API_KEY = "";//API key(商戶號里面的)
public static final String NOTIFY_URL = "";//回調地址
public static final String UFDODER_URL = "https://api.mch.weixin.qq.com/pay/unifiedorder";//微信統一下單接口
public static final String SELECT_URL = "https://api.mch.weixin.qq.com/pay/orderquery";//查詢訂單接口
}
微信支付常用方法 PayCommonUtil：
/**
* 微信支付常用方法
*/
public class PayCommonUtil {
//private static org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger("mydebug");
static org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger("mydebug");
/**
* 是否簽名正確,規則是:按參數名稱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 = MD5Util.MD5Encode(sb.toString(), characterEncoding).toLowerCase();
String tenpaySign = ((String)packageParams.get("sign")).toLowerCase();
return tenpaySign.equals(mysign);
}
/**
* @author
* @date 2016-4-22
* @Description：sign簽名
* @param characterEncoding
* 編碼格式
* @param
*
* @return
*/
public static String createSign(String characterEncoding, SortedMap<Object, Object> packageParams, String API_KEY) {
StringBuilder sb = new StringBuilder();
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 (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
sb.append(k + "=" + v + "&");
}
}
sb.append("key=").append(API_KEY);
String sign = MD5Util.MD5Encode(sb.toString(), characterEncoding).toUpperCase();
return sign;
}
/**
* @author
* @date 2016-4-22
* @Description：將請求參數轉換為xml格式的string
* @param parameters
* 請求參數
* @return
*/
public static String getRequestXml(SortedMap<Object, Object> parameters) {
StringBuilder sb = new StringBuilder();
sb.append("<xml>");
Set es = parameters.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 ("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));
}
//發起訂購 返回二維碼url
public static String wxPay(String ip,String body,int order_price,String userId,String out_trade_no) throws Exception {
// 賬號信息
String appid = PayConfigUtil.APP_ID; // appid
String mch_id = PayConfigUtil.MCH_ID; // 商戶號
String key = PayConfigUtil.API_KEY; // key
String currTime = PayCommonUtil.getCurrTime();
String strTime = currTime.substring(8, currTime.length());
String strRandom = PayCommonUtil.buildRandom(4) + "";
String nonce_str = strTime + strRandom;
String device_info = userId;//設備id 可自定義為userID
String notify_url = PayConfigUtil.NOTIFY_URL;
String trade_type = "NATIVE"; //交易類型
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
packageParams.put("appid", appid);
packageParams.put("mch_id", mch_id);
packageParams.put("device_info", device_info);
packageParams.put("nonce_str", nonce_str);
packageParams.put("body", body);
packageParams.put("product_id", "joymusic_"+order_price);
packageParams.put("out_trade_no", out_trade_no);
packageParams.put("total_fee", String.valueOf(order_price));
packageParams.put("spbill_create_ip", ip);
packageParams.put("notify_url", notify_url);
packageParams.put("trade_type", trade_type);
//生成簽名
String sign = PayCommonUtil.createSign("UTF-8", packageParams,key);
packageParams.put("sign", sign);
String requestXML = PayCommonUtil.getRequestXml(packageParams);
String resXml = HttpUtil.postData(PayConfigUtil.UFDODER_URL, requestXML);
Map map = XMLUtil.doXMLParse(resXml);
return (String) map.get("code_url");
}
/**
* 查詢訂單
* @param orderFormName 訂單名稱 out_trade_no： 商戶訂單;transaction_id: 微信支付訂單
* @param orderId
* @return
* @throws Exception
*/
public static Map selectOrder(String orderFormName,String orderId) throws Exception {
// 賬號信息
String appid = PayConfigUtil.APP_ID; // appid
String mch_id = PayConfigUtil.MCH_ID; // 商戶號
String key = PayConfigUtil.API_KEY; // key
String currTime = PayCommonUtil.getCurrTime();
String strTime = currTime.substring(8, currTime.length());
String strRandom = PayCommonUtil.buildRandom(4) + "";
String nonce_str = strTime + strRandom;//隨機數
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
packageParams.put("appid", appid);
packageParams.put("mch_id", mch_id);
packageParams.put("nonce_str", nonce_str);
packageParams.put(orderFormName, orderId);
//生成簽名
String sign = PayCommonUtil.createSign("UTF-8", packageParams,key);
packageParams.put("sign", sign);
String requestXML = PayCommonUtil.getRequestXml(packageParams);
String resXml = HttpUtil.postData(PayConfigUtil.SELECT_URL, requestXML);
Map map = XMLUtil.doXMLParse(resXml);
return map;
}
/**
* 獲取當前時間 yyyyMMddHHmmss
*
* @return String
*/
public static String getCurrTime() {
Date now = new Date();
SimpleDateFormat outFormat = new SimpleDateFormat("yyyyMMddHHmmss");
return outFormat.format(now);
}
/**
* 支付回調方法
* @param request
* @param response
* @throws Exception
*/
public static HashMap<String,String> wxPayNotify(HttpServletRequest request, HttpServletResponse response) throws Exception {
//讀取參數
InputStream inputStream ;
StringBuilder sb = new StringBuilder();
inputStream = request.getInputStream();
String s ;
BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
while ((s = in.readLine()) != null){
sb.append(s);
}
in.close();
inputStream.close();
//解析xml成map
Map<String, String> m = new HashMap<String, String>();
m = XMLUtil.doXMLParse(sb.toString());
//過濾空 設置 TreeMap
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
Iterator it = m.keySet().iterator();
while (it.hasNext()) {
String parameter = (String) it.next();
String parameterValue = m.get(parameter);
String v = "";
if(null != parameterValue) v = parameterValue.trim();
packageParams.put(parameter, v);
}
// 賬號信息
String key = PayConfigUtil.API_KEY; // key
HashMap<String, String> resultMap = new HashMap<>();
//判斷簽名是否正確
if(PayCommonUtil.isTenpaySign("UTF-8", packageParams,key)) {
String resXml = "";
if("SUCCESS".equals((String) packageParams.get("result_code"))){
String mch_id = (String) packageParams.get("mch_id");
String openid = (String) packageParams.get("openid");//用戶標識
String device_info = (String) packageParams.get("device_info");//設備id
String is_subscribe = (String) packageParams.get("is_subscribe");//是否關注公眾號
String out_trade_no = (String) packageParams.get("out_trade_no");//商戶訂單號
String transaction_id = (String) packageParams.get("transaction_id");//微信支付訂單號
String total_fee = (String) packageParams.get("total_fee");//訂單金額
String cash_fee = (String) packageParams.get("cash_fee");//支付金額（分）
String time_end = (String) packageParams.get("time_end");//訂單完成時間
resultMap.put("result","SUCCESS");
resultMap.put("openid",openid);
resultMap.put("userId",device_info);
resultMap.put("myOrderNumber",out_trade_no);
resultMap.put("wxOderNumber",transaction_id);
resultMap.put("total_fee",total_fee);
resultMap.put("orderFee",cash_fee);
resultMap.put("orderTime",time_end);
//通知微信.異步確認成功.必寫.不然會一直通知后台.八次之后就認為交易失敗了.
resXml = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>"
+ "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";
//向微信服務器發送確認信息，若不發送，微信服務器會間隔不同的時間調用回調方法
BufferedOutputStream out = new BufferedOutputStream(response.getOutputStream());
out.write(resXml.getBytes());
out.flush();
out.close();
} else {
resultMap.put("result","FAIL");//支付失敗
logger.info("支付失敗,錯誤信息：" + packageParams.get("err_code"));
resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
+ "<return_msg><![CDATA[報文為空]]></return_msg>" + "</xml> ";
BufferedOutputStream out = new BufferedOutputStream(response.getOutputStream());
out.write(resXml.getBytes());
out.flush();
out.close();
}
} else{
resultMap.put("result","FAIL");//支付失敗
}
return resultMap;
}
}
其他工具類：
1. xml工具類：
public class XMLUtil {
/**
* 解析xml,返回第一級元素鍵值對。如果第一級元素有子節點，則此節點的值是子節點的xml數據。
* @param strxml
* @return
* @throws
* @throws IOException
*/
public static Map doXMLParse(String strxml) throws IOException, JDOMException {
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();
}
}
2. http支付請求工具類：
public class HttpUtil {
//private static final Log logger = LogFactory.getLog("org.apache.catalina.tribes.MESSAGES" );
static org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger("error");
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);
}
//發起post請求
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.info("Error connecting to " + urlStr + ": " + e.getMessage());
} finally {
try {
if (reader != null)
reader.close();
} catch (IOException e) {
}
}
return null;
}
}
3. md5加密：
/**
* md5加密
*/
public class MD5Util {
private final static char[] hexArray = "0123456789ABCDEF".toCharArray();
public static String byteArrToHex(byte... bytes) {
char[] hexChars = new char[bytes.length * 2];
for (int j = 0; j < bytes.length; j++) {
int v = bytes[j] & 0xFF;
hexChars[j * 2] = hexArray[v >>> 4];
hexChars[j * 2 + 1] = hexArray[v & 0x0F];
}
return new String(hexChars);
}
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 = byteArrToHex(md.digest(resultString.getBytes()));
else
resultString = byteArrToHex(md.digest(resultString.getBytes(charsetname)));
} catch (Exception exception) {
}
return resultString;
}
}
調用及實現：
//支付
String ip = "192.168.0.1";//發起支付ip
String body = "XX訂購";//訂單標題
String orderPrice = "1";//支付金額（分）
String userId = "test010101";//設備id 可當做用戶id
String out_trade_no = userId.substring(0,5)+"_"+ PayCommonUtil.getCurrTime() + PayCommonUtil.buildRandom(4);//商戶訂單id
//數據庫記錄發起訂購記錄（自定義）
setInitPay(ip, userId,orderPrice,body,"86",songId,platform,out_trade_no,payType);
//調用支付方法 獲取二維碼URL
String WXQRcode = PayCommonUtil.wxPay(ip, body, orderPrice, userId, out_trade_no);
//回調
因域名問題，支付回調接口地址配置不上！所以采用了輪詢訂單狀態查詢方法判斷訂單狀態
//查詢訂單
String isLast = request.getParameter("isLast");//最后一次
String out_trade_no = request.getParameter("outTrade");//商戶訂單id
String isKeep = "0";//繼續查詢 1 ，不繼續： 0
String orderResult = "1";//支付結果 ： 0 ：成功，1：未成功
Map orderSelectMap = null;
String payType = request.getParameter("payType");
orderSelectMap = PayCommonUtil.selectOrder("out_trade_no", out_trade_no);
String return_code = orderSelectMap.get("return_code").toString();
String result_code = orderSelectMap.get("result_code").toString();
String trade_state = orderSelectMap.get("trade_state").toString();
if ("SUCCESS".equals(return_code) && "SUCCESS".equals(result_code)){
String myOrderNumber = orderSelectMap.get("out_trade_no").toString();
//訂單狀態 ：0: 用戶支付中 1: 支付成功 2: 轉入退款 3:未支付 4:已關閉 5: 已撤銷 6:支付失敗
if ("SUCCESS".equals(trade_state)){//更新數據庫
updateInfoPay(userId,myOrderNumber,"1");
orderResult = "0";
}else if("USERPAYING".equals(trade_state) ||"NOTPAY".equals(trade_state)){//當返回未支付或者 正在支付中時
if ("1".equals(isLast)) {
updateInfoPay(userId,myOrderNumber,"3");
}else {
isKeep = "1";
}
}else if("REFUND".equals(trade_state)){
updateInfoPay(userId,myOrderNumber,"2");
}else if("CLOSED".equals(trade_state)){
updateInfoPay(userId,myOrderNumber,"4");
}else if("REVOKED".equals(trade_state)){
updateInfoPay(userId,myOrderNumber,"5");
}else if("PAYERROR".equals(trade_state)){
updateInfoPay(userId,myOrderNumber,"6");
}
}
JSONObject jsonStr = new JSONObject();
jsonStr.put("isKeep", isKeep);
jsonStr.put("result", orderResult);
//寫入流返回
out.print(jsonStr);
out.flush();
out.close();