資訊專欄INFORMATION COLUMN
摘要：本文是淺析微信支付系列文章的第六篇，主要講解支付成功后，微信回調(diào)商戶支付結(jié)果通知的處理。微信支付支付回調(diào)接口該鏈接是通過統(tǒng)一下單中提交的參數(shù)設(shè)置，如果鏈接無法訪問，商戶將無法接收到微信通知。
本文是【淺析微信支付】系列文章的第六篇，主要講解支付成功后，微信回調(diào)商戶支付結(jié)果通知的處理。
淺析微信支付系列已經(jīng)更新五篇了喲～，沒有看過的朋友們可以看一下哦。
淺析微信支付：統(tǒng)一下單接口
淺析微信支付：微信公眾號網(wǎng)頁授權(quán)
淺析微信支付：開發(fā)前的準備
前面一章已經(jīng)講了如何調(diào)用統(tǒng)一下單接口和調(diào)起微信支付窗口，在調(diào)用下單接口時，我們會傳入 異步接收微信支付結(jié)果通知的回調(diào)地址，顧名思義這個地址作用就是用來接收支付結(jié)果通知，當(dāng)用戶在前端支付成功后，微信服務(wù)器會自動調(diào)用此地址，然后商戶再進行處理。
1、支付結(jié)果通知以下為接口官方解釋：
支付完成后，微信會把相關(guān)支付結(jié)果和用戶信息發(fā)送給商戶，商戶需要接收處理，并返回應(yīng)答。 對后臺通知交互時，如果微信收到商戶的應(yīng)答不是成功或超時，微信認為通知失敗，微信會通過一定的策略定期重新發(fā)起通知，盡可能提高通知的成功率，但微信不保證通知最終能成功。 （通知頻率為15/15/30/180/1800/1800/1800/1800/3600，單位：秒） 注意：同樣的通知可能會多次發(fā)送給商戶系統(tǒng)。商戶系統(tǒng)必須能夠正確處理重復(fù)的通知。 推薦的做法是，當(dāng)收到通知進行處理時，首先檢查對應(yīng)業(yè)務(wù)數(shù)據(jù)的狀態(tài)，判斷該通知是否已經(jīng)處理過，如果沒有處理過再進行處理，如果處理過直接返回結(jié)果成功。在對業(yè)務(wù)數(shù)據(jù)進行狀態(tài)檢查和處理之前，要采用數(shù)據(jù)鎖進行并發(fā)控制，以避免函數(shù)重入造成的數(shù)據(jù)混亂。 特別提醒：商戶系統(tǒng)對于支付結(jié)果通知的內(nèi)容一定要做簽名驗證,并校驗返回的訂單金額是否與商戶側(cè)的訂單金額一致，防止數(shù)據(jù)泄漏導(dǎo)致出現(xiàn)“假通知”，造成資金損失。 技術(shù)人員可登進微信商戶后臺掃描加入接口報警群。
支付結(jié)果通知接口文檔地址：
https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=9_7&index=8
需要注意的事項有以下幾點：
1. 該鏈接是通過【統(tǒng)一下單API】中提交的參數(shù)notify_url設(shè)置，如果鏈接無法訪問，商戶將無法接收到微信通知。 2. 通知url必須為直接可訪問的url，不能攜帶參數(shù)，也就是必須使用外網(wǎng)接口地址，不能使用本地調(diào)試地址 3. 商戶需要接收處理，并返回應(yīng)答。如果微信收到商戶的應(yīng)答不是成功或超時，微信認為通知失敗，微信會通過一定的策略定期重新發(fā)起通知，盡可能提高通知的成功率，但微信不保證通知最終能成功。 4. 通知頻率為15/15/30/180/1800/1800/1800/1800/3600，單位：秒 5. 同樣的通知可能會多次發(fā)送給商戶系統(tǒng)。商戶系統(tǒng)必須能夠正確處理重復(fù)的通知。 6. 特別提醒：商戶系統(tǒng)對于支付結(jié)果通知的內(nèi)容一定要做簽名驗證,并校驗返回的訂單金額是否與商戶側(cè)的訂單金額一致，防止數(shù)據(jù)泄漏導(dǎo)致出現(xiàn)“假通知”，造成資金損失。
PS：推薦的做法是，當(dāng)收到通知進行處理時，首先檢查對應(yīng)業(yè)務(wù)數(shù)據(jù)的狀態(tài)，判斷該通知是否已經(jīng)處理過，如果沒有處理過再進行處理，如果處理過直接返回結(jié)果成功。在對業(yè)務(wù)數(shù)據(jù)進行狀態(tài)檢查和處理之前，要采用數(shù)據(jù)鎖進行并發(fā)控制，以避免函數(shù)重入造成的數(shù)據(jù)混亂。
關(guān)于具體的簽名和接收通知代碼如下：
package imall.controller.wx;
package ...
/**
* 微信支付Controller
*
* @author yclimb
* @date 2018/6/15
*/
@Api
@RestController
@RequestMapping("/weixin/pay")
public class WXPayController extends BaseController {
// 需要注入的一些service
/**
* 返回成功xml
*/
private String resSuccessXml = "
* 支付完成后，微信會把相關(guān)支付結(jié)果和用戶信息發(fā)送給商戶，商戶需要接收處理，并返回應(yīng)答。
* 對后臺通知交互時，如果微信收到商戶的應(yīng)答不是成功或超時，微信認為通知失敗，微信會通過一定的策略定期重新發(fā)起通知，盡可能提高通知的成功率，但微信不保證通知最終能成功。
* （通知頻率為15/15/30/180/1800/1800/1800/1800/3600，單位：秒）
* 注意：同樣的通知可能會多次發(fā)送給商戶系統(tǒng)。商戶系統(tǒng)必須能夠正確處理重復(fù)的通知。
* 推薦的做法是，當(dāng)收到通知進行處理時，首先檢查對應(yīng)業(yè)務(wù)數(shù)據(jù)的狀態(tài)，判斷該通知是否已經(jīng)處理過，如果沒有處理過再進行處理，如果處理過直接返回結(jié)果成功。在對業(yè)務(wù)數(shù)據(jù)進行狀態(tài)檢查和處理之前，要采用數(shù)據(jù)鎖進行并發(fā)控制，以避免函數(shù)重入造成的數(shù)據(jù)混亂。
* 特別提醒：商戶系統(tǒng)對于支付結(jié)果通知的內(nèi)容一定要做簽名驗證，防止數(shù)據(jù)泄漏導(dǎo)致出現(xiàn)“假通知”，造成資金損失。
*
* @author yclimb
* @date 2018/6/15
*/
@ApiOperation(value = "微信支付|支付回調(diào)接口", httpMethod = "POST", notes = "該鏈接是通過【統(tǒng)一下單API】中提交的參數(shù)notify_url設(shè)置，如果鏈接無法訪問，商戶將無法接收到微信通知。")
@RequestMapping("/wxnotify")
public void wxnotify(HttpServletRequest request, HttpServletResponse response) {
String resXml = "";
InputStream inStream;
try {
inStream = request.getInputStream();
ByteArrayOutputStream outSteam = new ByteArrayOutputStream();
byte[] buffer = new byte[1024];
int len = 0;
while ((len = inStream.read(buffer)) != -1) {
outSteam.write(buffer, 0, len);
}
WXPayUtil.getLogger().info("wxnotify:微信支付----start----");
// 獲取微信調(diào)用我們notify_url的返回信息
String result = new String(outSteam.toByteArray(), "utf-8");
WXPayUtil.getLogger().info("wxnotify:微信支付----result----=" + result);
// 關(guān)閉流
outSteam.close();
inStream.close();
// xml轉(zhuǎn)換為map
Map resultMap = WXPayUtil.xmlToMap(result);
boolean isSuccess = false;
if (WXPayConstants.SUCCESS.equalsIgnoreCase(resultMap.get(WXPayConstants.RESULT_CODE))) {
WXPayUtil.getLogger().info("wxnotify:微信支付----返回成功");
if (WXPayUtil.isSignatureValid(resultMap, WXPayConstants.API_KEY)) {
// 訂單處理 操作 orderconroller 的回寫操作?
WXPayUtil.getLogger().info("wxnotify:微信支付----驗證簽名成功");
// 通知微信.異步確認成功.必寫.不然會一直通知后臺.八次之后就認為交易失敗了.
resXml = resSuccessXml;
isSuccess = true;
} else {
WXPayUtil.getLogger().error("wxnotify:微信支付----判斷簽名錯誤");
}
} else {
WXPayUtil.getLogger().error("wxnotify:支付失敗,錯誤信息：" + resultMap.get(WXPayConstants.ERR_CODE_DES));
resXml = resFailXml;
}
// 付款記錄修改 & 記錄付款日志
// 回調(diào)方法，處理業(yè)務(wù) - 修改訂單狀態(tài)
WXPayUtil.getLogger().info("wxnotify:微信支付回調(diào)：修改的訂單===>" + resultMap.get("out_trade_no"));
int updateResult = ...;
if (updateResult > 0) {
WXPayUtil.getLogger().info("wxnotify:微信支付回調(diào)：修改訂單支付狀態(tài)成功");
} else {
WXPayUtil.getLogger().error("wxnotify:微信支付回調(diào)：修改訂單支付狀態(tài)失敗");
}
} catch (Exception e) {
WXPayUtil.getLogger().error("wxnotify:支付回調(diào)發(fā)布異常：", e);
} finally {
try {
// 處理業(yè)務(wù)完畢
BufferedOutputStream out = new BufferedOutputStream(response.getOutputStream());
out.write(resXml.getBytes());
out.flush();
out.close();
} catch (IOException e) {
WXPayUtil.getLogger().error("wxnotify:支付回調(diào)發(fā)布異常:out：", e);
}
}
}
}
驗證是否本商戶返回的正確通知：
