微信支付
之前搞了下支付寶微信掃碼支付，突然又讓搞app支付，大神直接甩個賬號，讓自己搞，還得一點一點扒拉。在此記一下，以后用到了方便找。service得接口，是支付寶和微信支付公用的，有的參數(shù)有點多，單一用的話多余的可以去掉。本篇主要是微信的支付，支付寶的會在另一篇里去寫。不多說了，上代碼。
主要部分為service實現(xiàn)層。
掃碼支付
/**
* 服務端當面付，掃碼支付，返回二維碼字符串（有前端工具生成二維碼）
* @param orderId 訂單id
* @param totalCost 費用
* @param body 對一筆交易的具體描述信息。如果是多種商品，請將商品描述字符串累加傳給body。
* @param subject 商品的標題/交易標題/訂單標題/訂單關鍵字等。（必填）
*/
public InvokeResult commitPay(String orderId, float totalCost, String body,String desc) ；
@Override
public InvokeResult commitPay(String orderId, float totalCost, String body,String desc) {
String cost =String.valueOf(totalCost*100);
cost = cost.substring(0,cost.indexOf("."));
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
packageParams.put("appid", SxlinkWecharConstants.SXLink_APP_ID);
packageParams.put("mch_id", SxlinkWecharConstants.MCH_ID);
packageParams.put("nonce_str", PayCommonUtil.generateNonceStr());
packageParams.put("body", desc);//商品描述
packageParams.put("out_trade_no", orderId); //商品訂單
packageParams.put("total_fee", cost); //費用 單位為分
packageParams.put("spbill_create_ip", PayCommonUtil.getHostIP()); //終端IP
packageParams.put("notify_url", SxlinkWecharConstants.NOTIFY_URL);
packageParams.put("trade_type", SxlinkWecharConstants.TRADE_TYPE);
String sign = PayCommonUtil.createSign("UTF-8", packageParams,SxlinkWecharConstants.API_KEY); //獲取簽名
packageParams.put("sign", sign);
String requestXML = PayCommonUtil.getRequestXml(packageParams);//將請求參數(shù)轉換成String類型
String resXml = HttpUtil.postData(SxlinkWecharConstants.UNIFIEDORDER_URL_SUFFIX, requestXML); //解析請求之后的xml參數(shù)并且轉換成String類型
Map map = null;
try {
map = XMLUtil.doXMLParse(resXml);
} catch (Exception e) {
e.printStackTrace();
}
String urlCode = (String) map.get("code_url");
if(urlCode==null){
return errorResult(ErrorCodeConstants.RUNTIME_ERROR, "調用接口失敗");
}
return successResult(urlCode);
}
訂單查尋
> /**
* 訂單查詢
* @param orderId
*/
InvokeResult queryOrderStatus(String orderId) ;
@Override
public InvokeResult queryOrderStatus(String orderId) {
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
packageParams.put("appid", SxlinkWecharConstants.SXLink_APP_ID);
packageParams.put("mch_id", SxlinkWecharConstants.MCH_ID);
packageParams.put("nonce_str", PayCommonUtil.generateNonceStr());
packageParams.put("out_trade_no",orderId); //商品訂單
String sign = PayCommonUtil.createSign("UTF-8", packageParams,SxlinkWecharConstants.API_KEY); //獲取簽名
packageParams.put("sign", sign);
String requestXML = PayCommonUtil.getRequestXml(packageParams);//將請求參數(shù)轉換成String類型
String resXml = HttpUtil.postData(SxlinkWecharConstants.ORDERQUERY_URL_SUFFIX, requestXML); //解析請求之后的xml參數(shù)并且轉換成String類型
Map map = null;
try {
map = XMLUtil.doXMLParse(resXml);
} catch (Exception e) {
e.printStackTrace();
}
String urlCode = (String) map.get("trade_state");
if(urlCode.equals("SUCCESS")){
return successResult("支付成功");
}
return errorResult(ErrorCodeConstants.RUNTIME_ERROR,"支付未成功");
}
app支付
/**
* app支付
* 注：商戶在請求參數(shù)中，自己附屬的一些額外參數(shù)，
* 不要和支付寶系統(tǒng)中約定的key（下表中 公共請求參數(shù)\請求參數(shù)）重名，否則將可能導致未知的異常。
* @param body 對一筆交易的具體描述信息。如果是多種商品，請將商品描述字符串累加傳給body。（微信必填）
* @param subject 商品的標題/交易標題/訂單標題/訂單關鍵字等。（支付寶必填）
* @param out_trade_no 商戶網(wǎng)站唯一訂單號（必填）
* @param timeout_express該筆訂單允許的最晚付款時間，逾期將關閉交易。取值范圍：1m～15d。m-分鐘，h-小時，d-天，
* 1c-當天（1c-當天的情況下，無論交易何時創(chuàng)建，都在0點關閉）。 該參數(shù)數(shù)值不接受小數(shù)點，
* 如 1.5h，可轉換為 90m。 注：若為空，則默認為 90m。
* @param total_amount 訂單總金額，單位為元，精確到小數(shù)點后兩位，取值范圍[0.01,100000000] （必填）
* @param product_code 銷售產(chǎn)品碼，商家和支付寶簽約的產(chǎn)品碼，為固定值QUICK_MSECURITY_PAY （支付寶必填）
* @return app支付訂單信息
*/
InvokeResult appPay(String body,String subject,String out_trade_no,String timeout_express,String total_amount,String product_code);
@Override
public InvokeResult appPay(String body, String subject, String outTradeNo,
String timeoutExpress, String totalAmount, String productCode) {
String cost =String.valueOf(Float.parseFloat(totalAmount)*100);
cost = cost.substring(0,cost.indexOf("."));
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
packageParams.put("appid", SxlinkWecharConstants.SXLinkOpenPlat_APP_ID);
packageParams.put("mch_id", SxlinkWecharConstants.MCH_ID);
packageParams.put("nonce_str", PayCommonUtil.generateNonceStr());
if(body==null){
body ="";
}
packageParams.put("body", body);//商品描述
packageParams.put("out_trade_no", outTradeNo); //商品訂單
packageParams.put("total_fee", cost); //費用 單位為分
packageParams.put("spbill_create_ip", PayCommonUtil.getHostIP()); //終端IP
packageParams.put("notify_url", SxlinkWecharConstants.NOTIFY_URL);
packageParams.put("trade_type", SxlinkWecharConstants.TRADE_TYPE_APP);
String sign = PayCommonUtil.createSign("UTF-8", packageParams,SxlinkWecharConstants.API_KEY); //獲取簽名
packageParams.put("sign", sign);
String requestXML = PayCommonUtil.getRequestXml(packageParams);//將請求參數(shù)轉換成String類型
String resXml = HttpUtil.postData(SxlinkWecharConstants.UNIFIEDORDER_URL_SUFFIX, requestXML); //解析請求之后的xml參數(shù)并且轉換成String類型
System.out.println(resXml);
try {
XMLUtil.doXMLParse(resXml);
} catch (Exception e) {
e.printStackTrace();
}
// 預支付交易會話ID
String prepay_id = "";
Map<String, String> m = new HashMap<String, String>();
if (resXml.indexOf("SUCCESS") != -1) {
try {
m = XMLUtil.doXMLParse(resXml);
} catch (Exception e) {
e.printStackTrace();
}
prepay_id = (String) m.get("prepay_id");
}
Map<String,String> signMap = new HashMap<String,String>() ;
//時間戳、隨機字符串
String timeStamp = String.valueOf(PayCommonUtil.getCurrentTimestamp());
String nonceStr = PayCommonUtil.generateNonceStr();
signMap.put("appId", SxlinkWecharConstants.SXLinkOpenPlat_APP_ID);
signMap.put("partnerid", SxlinkWecharConstants.MCH_ID);
signMap.put("prepayid", prepay_id);
signMap.put("package","Sign=WXPay");
signMap.put("nonceStr", nonceStr);
signMap.put("timeStamp",timeStamp);
String JSApisign = "";
try {
JSApisign = PayCommonUtil.generateSignature(signMap, SxlinkWecharConstants.API_KEY, SxlinkWecharConstants.SignType.MD5);
} catch (Exception e) {
e.printStackTrace();
}
JSONObject json = new JSONObject();
json.put("appid", SxlinkWecharConstants.SXLinkOpenPlat_APP_ID);
json.put("partnerid",SxlinkWecharConstants.MCH_ID);
json.put("prepayid",prepay_id);
json.put("package", "Sign=WXPay");
json.put("noncestr", nonceStr);
json.put("timestamp",timeStamp);
json.put("sign", JSApisign);
System.out.println(json.toString());
return successResult(json);
}
最終返回得code是二維碼得鏈接，前臺生成二維碼就可以了，這個二維碼有時間限制，用的時候注意。以下是用到得工具。
/**
* 獲取隨機字符串 Nonce Str
* @return String 隨機字符串
*/
public static String generateNonceStr() {
return UUID.randomUUID().toString().replaceAll("-", "").substring(0, 32);
}
/**
* 獲取本機的ip地址
* @return String
*/
public static String getHostIP(){
InetAddress addr;
String ip = "";
try {
addr = InetAddress.getLocalHost();
ip=addr.getHostAddress().toString(); //獲取本機ip
} catch (UnknownHostException e) {
e.printStackTrace();
}
return ip;
}
/**
* @Description：將請求參數(shù)map轉換為xml格式的string
* @param parameters 請求參數(shù)
* @return
*/
@SuppressWarnings("unchecked")
public static String getRequestXml(SortedMap<Object, 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 = (String) entry.getKey();
String v = (String) entry.getValue();
if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k) || "sign".equalsIgnoreCase(k)) {
sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");//注：參數(shù)值用XML轉義即可，CDATA標簽用于說明數(shù)據(jù)不被XML解析器解析。
} else {
sb.append("<" + k + ">" + v + "</" + k + ">");
}
}
sb.append("</xml>");
return sb.toString();
}
public static String postData(String urlStr, String data) {
return postData(urlStr, data, null);
}
/**
* post數(shù)據(jù)請求
* @param urlStr
* @param data
* @param contentType
* @return
*/
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;
}
/**
* XML格式字符串轉換為Map
*
* @param strXML XML字符串
* @return XML數(shù)據(jù)轉換后的Map
* @throws Exception
*/
public static Map<String, String> doXMLParse(String strXML) throws Exception {
Map<String, String> data = new HashMap<String, String>();
DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
InputStream stream = new ByteArrayInputStream(strXML.getBytes("UTF-8"));
org.w3c.dom.Document doc = documentBuilder.parse(stream);
doc.getDocumentElement().normalize();
NodeList nodeList = doc.getDocumentElement().getChildNodes();
for (int idx = 0; idx < nodeList.getLength(); ++idx) {
Node node = nodeList.item(idx);
if (node.getNodeType() == Node.ELEMENT_NODE) {
org.w3c.dom.Element element = (org.w3c.dom.Element) node;
data.put(element.getNodeName(), element.getTextContent());
}
}
try {
stream.close();
} catch (Exception ex) {
}
return data;
}
/**
* @Description：sign簽名
* @param characterEncoding 編碼格式
* @param parameters 請求參數(shù)
* @return
*/
@SuppressWarnings("unchecked")
public static String createSign(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 (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
sb.append(k + "=" + v + "&");
}
}
sb.append("key=" + API_KEY);
String sign = MD5Util.MD5Encode(sb.toString(), characterEncoding).toUpperCase();
return sign;
}
/**
* 獲取當前時間戳，單位秒
* @return
*/
public static long getCurrentTimestamp() {
return System.currentTimeMillis()/1000;
}
/**
* 生成簽名. 注意，若含有sign_type字段，必須和signType參數(shù)保持一致。
* @param data 待簽名數(shù)據(jù)
* @param key API密鑰
* @param signType 簽名方式
* @return 簽名
*/
public static String generateSignature(final Map<String, String> data, String key, SxlinkWecharConstants.SignType signType) throws Exception {
Set<String> keySet = data.keySet();
String[] keyArray = keySet.toArray(new String[keySet.size()]);
Arrays.sort(keyArray);
StringBuilder sb = new StringBuilder();
for (String k : keyArray) {
if (k.equals(SxlinkWecharConstants.FIELD_SIGN)) {
continue;
}
if (data.get(k).trim().length() > 0) // 參數(shù)值為空，則不參與簽名
sb.append(k).append("=").append(data.get(k).trim()).append("&");
}
sb.append("key=").append(key);
if (SxlinkWecharConstants.SignType.MD5.equals(signType)) {
return MD5(sb.toString()).toUpperCase();
}
else if (SxlinkWecharConstants.SignType.HMACSHA256.equals(signType)) {
return HMACSHA256(sb.toString(), key);
}
else {
throw new Exception(String.format("Invalid sign_type: %s", signType));
}
}
好了，微信支付到此結束，其中的商戶號，密鑰、網(wǎng)關之類，自己照著配置就好了,下面是異步回調的一個controller,處理了微信異步回調的解析，具體該實現(xiàn)自己的邏輯，在判斷支付成功里面設置。
/**
* 微信支付回調地址
* @param request
* @param response
*/
@RequestMapping(value = "/wxpaySucc",produces = MediaType.APPLICATION_JSON_VALUE)
public void wxpaySucc(HttpServletRequest request, HttpServletResponse response) throws IOException {
InputStream inputStream ;
StringBuffer sb = new StringBuffer();
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>();
try {
m = XMLUtil.doXMLParse(sb.toString());
} catch (Exception e1) {
e1.printStackTrace();
}
//過濾空 設置 TreeMap
SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();
Iterator<String> it = m.keySet().iterator();
while (it.hasNext()) {
String parameter = it.next();
String parameterValue = m.get(parameter);
String v = "";
if(null != parameterValue) {
v = parameterValue.trim();
}
packageParams.put(parameter, v);
}
//判斷簽名是否正確
String resXml = "";
boolean signVerified = false;
try {
signVerified = PayCommonUtil.isTenpaySign("UTF-8", packageParams,SxlinkWecharConstants.API_KEY);
} catch (Exception e) {
e.printStackTrace();
}
if(signVerified) {
String app_id = (String)packageParams.get("appid");
String mch_id = (String)packageParams.get("mch_id");
if(app_id.equals(SxlinkWecharConstants.SXLinkOpenPlat_APP_ID)&&mch_id.equals(SxlinkWecharConstants.MCH_ID)){
String out_trade_no = "";
String total_fee = "";
try{
//商戶訂單號
out_trade_no = (String)packageParams.get("out_trade_no");
//付款金額【以分為單位】
total_fee = (String) packageParams.get("total_fee");
}catch (Exception e) {
System.out.println(e);
}
if("SUCCESS".equals((String)packageParams.get("result_code"))){
//TODO 這里是支付成功 、執(zhí)行自己的業(yè)務邏輯開始
//通知微信.異步確認成功.必寫.不然會一直通知后臺.八次之后就認為交易失敗了.
resXml = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>"
+ "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";
}
}else{
resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
+ "<return_msg><![CDATA[微信商戶號或服務號有誤]]></return_msg>" + "</xml> ";
}
} else{
resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
+ "<return_msg><![CDATA[驗簽失敗]]></return_msg>" + "</xml> ";
}
//此處輸出resXml結果，告知微信異步通知結果時成功還是失敗
BufferedOutputStream out = new BufferedOutputStream(
response.getOutputStream());
out.write(resXml.getBytes());
out.flush();
out.close();
}
