微信 支付非同步回撥 獲取引數值
阿新 • • 發佈：2019-01-24
import java.io.StringReader; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import java.util.SortedMap; import java.util.TreeMap; import javax.servlet.http.HttpServletRequest; import org.apache.commons.lang.StringUtils; import org.apache.log4j.Logger; import org.jdom2.Document; import org.jdom2.Element; import org.jdom2.input.SAXBuilder; import org.xml.sax.InputSource; import com.jfinal.aop.Before; import com.jfinal.ext.interceptor.POST; import com.jfinal.plugin.activerecord.NestedTransactionHelpException; import com.jfinal.plugin.activerecord.tx.Tx; import com.utils.MD5Util; import comwechat.config.WeChatConfig; public class WeChatPayController extends BaseController { private Logger logger = Logger.getLogger(getClass()); /** * 微信同步回撥 * <p> * 返回結果.code=0：正常結束<br> * 返回結果.code=1：傳參錯誤<br> * 返回結果.code=2：該賬戶已在其它裝置上登入<br> * 返回結果.code=3：已被封號<br> * 返回結果.code=99：系統異常 * * @param deviceId * 裝置ID * @param params * 加密過的引數({deviceId 裝置ID, userId 使用者ID, historyId 充值履歷ID, state * 充值狀態}) * @return 返回加密過的結果(null) */ @Before({ POST.class, Tx.class, DecryptParamsInterceptor.class }) public void synchronous_notify() { String userId = decryptParams.get("userId"); String deviceId = decryptParams.get("deviceId"); String transaction_id = decryptParams.get("transaction_id"); String state = decryptParams.get("state"); if (StringUtils.isEmpty(userId) || StringUtils.isEmpty(deviceId) || StringUtils.isEmpty(transaction_id) || StringUtils.isEmpty(state)) { throw new ServiceException(1, "傳參錯誤"); } if (!PayState.SUCC.equals(state) && !PayState.FAIL.equals(state)) { throw new ServiceException(1, "傳參錯誤"); } int int_userId = Integer.parseInt(userId); checkUser(int_userId, deviceId); Transaction transaction = common_Transaction(transaction_id, state); if (RechargeState.SUCC.equals(state)) { common_notify(transaction); } } /** * @Description: 微信非同步回撥 * @param @throws UnsupportedEncodingException * @return void * @throws * @author ChenFeng * @date 2016/06/30 */ @Before(Tx.class) public void asynchronousWeChat_notify() { try { Transaction transaction = weChat_notify(); common_notify(transaction); renderText("success"); } catch (ServiceException ex) { logger.error(ex.getMessage()); if (ex.getCode() == 33) { renderText("success"); } else { renderText("fail"); } throw new NestedTransactionHelpException(ex.getMessage()); } } private void common_notify(Transaction transaction) { RechargeHistory rh = RechargeHistory.dao.lockById(transaction.getLong("recharge_id")); if (rh == null) { throw new ServiceException(35, "沒有發現對應充值履歷（recharge_id=" + transaction.getInt("recharge_id") + "）"); } if (!RechargeType.WEIXIN.equals(rh.getStr("type"))) { throw new ServiceException(37, "非微信支付"); } rh.set("state", RechargeState.SUCC); rh.set("updater", "WeChatPay"); if (!rh.update()) { throw new ServiceException(36, "充值履歷狀態更新失敗"); } RechargePackage rp = RechargePackage.dao.findById(rh.getInt("package_id")); if (rp == null) { throw new ServiceException(38, "充值套餐已不存在"); } User user = User.dao.lockById(rh.getInt("user_id")); if (user == null) { throw new ServiceException(38, "支付使用者已不存在"); } int recharge_rmb = user.getInt("recharge_rmb") + rh.getInt("amount"); UserLevel nul = UserLevel.dao.getNext(user.getInt("level_id")); if (nul != null && recharge_rmb >= nul.getInt("min_rmb")) { UpLevel ul = new UpLevel(); ul.set("user_id", user.get("id")); ul.set("up_time", getNowTime()); ul.set("level_id", nul.get("id")); if (!ul.save()) { throw new ServiceException(39, "升級失敗"); } user.set("level_id", nul.get("id")); } user.set("recharge_rmb", recharge_rmb); user.set("accum_diam", user.getInt("accum_diam") + rp.getInt("num")); user.set("resid_diam", user.getInt("resid_diam") + rp.getInt("num")); if (!user.update()) { throw new ServiceException(39, "充值失敗"); } SysInfo si = SysInfo.dao.findById(SysInfoKey.INFORM_RECHARGE); if (si != null && StringUtils.isNotEmpty(si.getStr("value"))) { SysMsgService.getToken(); SysMsgService.publishTxtMsg(Integer.toString(user.getInt("id")), si.getStr("value")); } } @SuppressWarnings("rawtypes") private Transaction weChat_notify() { // 獲取微信POST過來反饋資訊 System.out.print("微信支付回撥獲取資料開始"); logger.debug("微信支付回撥獲取資料開始"); HttpServletRequest request = getRequest(); String inputLine; String notityXml = ""; try { while ((inputLine = request.getReader().readLine()) != null) { notityXml += inputLine; } request.getReader().close(); } catch (Exception e) { logger.debug("xml獲取失敗：" + e); throw new ServiceException(39, "xml獲取失敗！"); } System.out.println("接收到的報文：" + notityXml); logger.debug("收到微信非同步回撥："); logger.debug(notityXml); if(StringUtils.isEmpty(notityXml)){ logger.debug("xml為空："); throw new ServiceException(39, "xml為空！"); } Map m = parseXmlToList2(notityXml); String appid = m.get("appid").toString(); String bank_type = m.get("bank_type").toString(); String cash_fee = m.get("cash_fee").toString(); String fee_type = m.get("fee_type").toString(); String is_subscribe = m.get("is_subscribe").toString(); String mch_id = m.get("mch_id").toString(); String nonce_str = m.get("nonce_str").toString(); String openid = m.get("openid").toString(); String out_trade_no = m.get("out_trade_no").toString(); String result_code = m.get("result_code").toString(); String return_code = m.get("return_code").toString(); String sign = m.get("sign").toString(); String time_end = m.get("time_end").toString(); String total_fee = m.get("total_fee").toString(); String trade_type = m.get("trade_type").toString(); String transaction_id = m.get("transaction_id").toString(); SortedMap<Object, Object> parameters = new TreeMap<Object, Object>(); parameters.put("appid", appid); parameters.put("bank_type", bank_type); parameters.put("cash_fee", cash_fee); parameters.put("fee_type", fee_type); parameters.put("is_subscribe", is_subscribe); parameters.put("mch_id", mch_id); parameters.put("nonce_str", nonce_str); parameters.put("openid", openid); parameters.put("out_trade_no", out_trade_no); parameters.put("result_code", result_code); parameters.put("return_code", return_code); parameters.put("time_end", time_end); parameters.put("total_fee", total_fee); parameters.put("trade_type", trade_type); parameters.put("transaction_id", transaction_id); String characterEncoding = "UTF-8"; String mySign = createSign(characterEncoding, parameters); System.out.println("我 的簽名是：" + mySign); logger.debug("我 的簽名是：" + mySign); logger.debug("WeChat 的簽名是：" + sign); if (sign.equals(mySign)) { System.out.println("簽名一致"); logger.debug("簽名一致"); } else { System.out.println("簽名不一致"); logger.debug("簽名不一致"); throw new ServiceException(39, "簽名不一致！"); } if (!"SUCCESS".equals(result_code)) { throw new ServiceException(31, "微信返回的交易狀態不正確（result_code=" + result_code + "）"); } return common_Transaction(out_trade_no, RechargeState.SUCC); } @SuppressWarnings({ "rawtypes", "unchecked" }) private static Map parseXmlToList2(String xml) { Map retMap = new HashMap(); try { StringReader read = new StringReader(xml); // 建立新的輸入源SAX 解析器將使用 InputSource 物件來確定如何讀取 XML 輸入 InputSource source = new InputSource(read); // 建立一個新的SAXBuilder SAXBuilder sb = new SAXBuilder(); // 通過輸入源構造一個Document Document doc = (Document) sb.build(source); Element root = doc.getRootElement();// 指向根節點 List<Element> es = root.getChildren(); if (es != null && es.size() != 0) { for (Element element : es) { retMap.put(element.getName(), element.getValue()); } } } catch (Exception e) { e.printStackTrace(); } return retMap; } private Transaction common_Transaction(String transaction_id, String state) { Transaction transaction = Transaction.dao.findById(transaction_id); if (transaction == null) { throw new ServiceException(32, "沒有發現對應的交易流水賬號（transaction_id=" + transaction_id + "）"); } if (RechargeState.SUCC.equals(transaction.getStr("state"))) { throw new ServiceException(33, "該交易流水狀態已變更"); } transaction.set("state", state); transaction.set("updater", "WeChatPay"); if (!transaction.update()) { throw new ServiceException(34, "交易流水狀態更新失敗"); } return transaction; } /** * 微信支付簽名演算法sign * * @param characterEncoding * @param parameters * @return */ @SuppressWarnings("rawtypes") public static String createSign(String characterEncoding, SortedMap<Object, Object> parameters) { StringBuffer sb = new StringBuffer(); Set es = parameters.entrySet();// 所有參與傳參的引數按照accsii排序（升序） Iterator it = es.iterator(); while (it.hasNext()) { Map.Entry entry = (Map.Entry) it.next(); String k = (String) entry.getKey(); Object v = entry.getValue(); if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) { sb.append(k + "=" + v + "&"); } } String key = WeChatConfig.key; sb.append("key=" + key); String sign = MD5Util.MD5Encode(sb.toString(), characterEncoding).toUpperCase(); return sign; } }