app微信支付宝支付后台的插件模式+回调通过spring广播处理后续业务（已亲测可用）
Posted 陈扬天
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了app微信支付宝支付后台的插件模式+回调通过spring广播处理后续业务（已亲测可用）相关的知识，希望对你有一定的参考价值。
写在前面的话：每当我们做一个项目，基本上都会涉及到支付的业务，最常用的莫过于微信和支付宝的支付了，项目有bug，有问题，都不叫问题，可一旦钱出了问题，那就是大问题了，所以在支付业务上我们必须慎之又慎！
但是我们做开发的，并不是在一个项目中完成支付模块就万事大吉了，在下一个项目中，我们是不是又要将支付模块的代码复制粘贴一遍，然后再重改支付模块？这样的坏处是频繁修改支付模块难免出现一些我们自己都意识不到的问题，一旦暴露在一些不怀好心的又懂技术的人面前，那我们哭都不知道去找谁。
所以，我试着通过利用spring的一些特性，将支付模块配置成了类似插件的样子，然后回调中的业务提取出来，通过spring广播播报出去，谁爱处理谁处理，跟我支付毛线关系都没有。
废话不多说（已经说了一大堆废话），我们就来看一下到底是怎么实现这种效果的。
一：首先创建一个spring-site.xml 就是一个新的xml,在spirng-mvc.xml中引用它（目的就是结构清楚，直接写在spring-mvc.xml中也没有任何的问题），下面看代码：
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.1.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.1.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd" default-lazy-init="true"> <description>Spring Site Configuration</description> <!-- 配置短信发送器 --> <bean id="configManager" class="com.sm.vendors.sms.lingkai.LingkaiDefaultConfigManager"> </bean> <bean id="iSmsSender" class="com.sm.vendors.sms.lingkai.LingkaiSmsSender"> <property name="configManager" ref="configManager" /> </bean> <!-- 配置极光推送器 --> <bean id="JPushconfigManager" class="com.sm.vendors.push.jpush.JpushDefaultConfigManager"> </bean> <bean id="JpushMessage" class="com.sm.vendors.push.jpush.JPushUtil"> <property name="configManager" ref="JPushconfigManager" /> </bean> <!-- 配置微信支付 --> <bean id="WeixinManager" class="com.sm.vendors.pay.wxpay.WeixinPayConfigManager"> </bean> <bean id="WeixinUtil" class="com.sm.vendors.pay.wxpay.WeixinService"> <property name="configManager" ref="WeixinManager" /> </bean> <!-- 配置支付宝支付 --> <bean id="AliPayManager" class="com.sm.vendors.pay.alipay.AliPayConfigManager"> </bean> <bean id="AlipayUtil" class="com.sm.vendors.pay.alipay.AlipayService"> <property name="configManager" ref="AliPayManager" /> </bean> <!-- 验证码生成器 --> <bean id="verificationGenerator" class="com.sm.common.Generator.VerificationGenerator" /> </beans>
可以看到我把推送和发送短信等也配置了进来，我们只需要关心支付模块就好。
微信支付宝的配置模式是一样的，都是两个bean，一个插件管理器，一个支付工具类，下面是两个类的代码（首先是微信）：
package com.sm.vendors.pay.wxpay; import java.util.HashMap; import java.util.List; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import com.sm.common.sms.IConfigManager; import com.sm.modules.glo.entity.settings.GloSetting; import com.sm.modules.glo.service.settings.GloSettingService; /** * @declare 微信支付管理器 * @author XXX * @date 2017年8月28日 */ public class WeixinPayConfigManager implements IConfigManager { @Autowired private GloSettingService gloSettingService; public WeixinPayConfigManager() { // TODO Auto-generated constructor stub } @Override public void saveConfig(Map<String, Object> map) { // TODO Auto-generated method stub } @Override public Map<String, Object> loadConfig() { GloSetting gloSetting = new GloSetting(); gloSetting.setType("wx.pay"); List<GloSetting> list = gloSettingService.findList(gloSetting); Map<String, Object> map = new HashMap<String, Object>(); for (GloSetting gloSetting2 : list) { map.put(gloSetting2.getName(), gloSetting2.getValue()); } return map; } }
package com.sm.vendors.pay.wxpay; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.math.BigDecimal; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.HashMap; import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Random; import org.apache.http.NameValuePair; import org.apache.http.message.BasicNameValuePair; import org.apache.log4j.Logger; import org.jdom.JDOMException; import org.springframework.beans.factory.annotation.Autowired; import com.sm.common.api.ApiResult; import com.sm.common.sms.IConfigManager; import com.sm.vendors.pay.alipay.AlipayService; import com.sm.vendors.pay.wxpay.bean.WeixinBean; import com.sm.vendors.pay.wxpay.util.htmlUtil; import com.sm.vendors.pay.wxpay.util.HttpUtil; import com.sm.vendors.pay.wxpay.util.MD5Util; import com.sm.vendors.pay.wxpay.util.Sha1Util; import com.sm.vendors.pay.wxpay.util.XMLUtil; public class WeixinService { /** * 信息 */ private final Logger logger = Logger.getLogger(AlipayService.class); @Autowired private IConfigManager configManager; /** * 微信APP支付 * * @param request * @param response * @param indentNum * 订单号 * @param money * 订单金额 * @param body * 商品简单描述 格式: 腾讯充值中心-QQ会员充值,必填 * @param notify_url * 回调地址 * @return * @throws UnsupportedEncodingException */ public ApiResult wechatPayAPP(String indentNum, BigDecimal money, String body) throws UnsupportedEncodingException { ApiResult result = new ApiResult(); // 金额 (已分为单位) String totalCount = money.toString(); System.out.println(totalCount); Map<String, Object> config = getConfigManager().loadConfig(); String appid = (String) config.get("appid");// 微信appid String mch_id = (String) config.get("mch_id"); String key = (String) config.get("key");// 微信key String notify_url = (String) config.get("notify_url");// 回调地址 // 存入实体 WeixinBean weixinBean = new WeixinBean(appid, mch_id, key, "APP", null, null, body, indentNum, totalCount, notify_url); Map<String, String> xml = doInBackground(weixinBean); if (xml.get("return_code").equals("SUCCESS")) { // 生成微信预支付订单返回成功 String nonceStr = genNonceStr(); // 随机字符串 String date = Sha1Util.getTimeStamp(); // 时间截 // 将返回的参数进行第二次签名然后返回给客户端 List<NameValuePair> packageParams = new LinkedList<NameValuePair>(); packageParams.add(new BasicNameValuePair("appid", appid)); packageParams.add(new BasicNameValuePair("noncestr", nonceStr)); packageParams.add(new BasicNameValuePair("package", "Sign=WXPay")); packageParams.add(new BasicNameValuePair("partnerid", mch_id)); // 商户id packageParams.add(new BasicNameValuePair("prepayid", xml.get("prepay_id"))); // 微信返回预支付订单id packageParams.add(new BasicNameValuePair("timestamp", date)); // 第二次签名 String sign = genPackageSign(packageParams, key); Map<String, Object> map = new HashMap<String, Object>(); map.put("sign", sign); map.put("nonceStr", nonceStr); map.put("timestamp", date); map.put("packages", "Sign=WXPay"); map.put("prepayid", xml.get("prepay_id")); map.put("partnerid", mch_id); map.put("appid", appid); map.put("body", body); System.out.println(xml.get("prepay_id")); // 同步微信订单号到本地数据库 result.setCode(0); result.setData(map); result.setMessage("订单生成成功！"); } else { result.setCode(-1); result.setMessage("订单生成失败！"); } return result; } /** * 发送生成预支付订单请求 * * @param money * 支付金额 * @param indentNum * 订单号 * @param openid * 支付者唯一标识 * @param request * @return */ @SuppressWarnings("unchecked") protected Map<String, String> doInBackground(WeixinBean weixinBean) { String entity = getproduct(weixinBean); // String buf = HttpUtil.sendPostUrl(WeixinConfig.service_url,entity); Map<String, Object> config = getConfigManager().loadConfig(); String service_url = (String) config.get("service_url");// 微信支付地址 String buf = HtmlUtil.postData(service_url, entity); Map<String, String> xml = null; try { String content = new String(buf.getBytes(), "UTF-8"); xml = XMLUtil.doXMLParse(content); } catch (UnsupportedEncodingException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } catch (JDOMException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return xml; } /** * 封装产品信息 * * @param weixinBean * 微信支付参数实体 * @return 返回支付参数封装类(map类型) */ public String getproduct(WeixinBean weixinBean) { List<NameValuePair> packageParams = new LinkedList<NameValuePair>(); // APP_ID 应用从官方网站申请到的合法appId packageParams.add(new BasicNameValuePair("appid", weixinBean.getAppid())); // packageParams.add(new BasicNameValuePair("attach",inputMoney)); // body为汉字是要转成UTF-8 packageParams.add(new BasicNameValuePair("body", weixinBean.getBody())); // 商户号 packageParams.add(new BasicNameValuePair("mch_id", weixinBean.getMch_id())); // 验证参数 packageParams.add(new BasicNameValuePair("nonce_str", genNonceStr())); // 回调地址 packageParams.add(new BasicNameValuePair("notify_url", weixinBean.getNotify_url())); // 支付者唯一标示 if (weixinBean.getTrade_type() == "JSAPI") { // JSAPI支付使用 packageParams.add(new BasicNameValuePair("openid", weixinBean.getOpenid())); } // 订单号码 packageParams.add(new BasicNameValuePair("out_trade_no", weixinBean.getOut_trade_no())); // 服务器地址 packageParams.add(new BasicNameValuePair("spbill_create_ip", getLocalIP())); // 支付金额 packageParams.add(new BasicNameValuePair("total_fee", weixinBean.getTotal_fee())); // 支付类型 jsapi packageParams.add(new BasicNameValuePair("trade_type", weixinBean.getTrade_type())); // 签名 String sign = genPackageSign(packageParams, weixinBean.getKey()); packageParams.add(new BasicNameValuePair("sign", sign)); String xmlstring = toXml(packageParams); // 将请求参数转换为xml格式 return xmlstring; } // 获得服务器ip地址 public static String getLocalIP() { InetAddress addr = null; try { addr = InetAddress.getLocalHost(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } byte[] ipAddr = addr.getAddress(); String ipAddrStr = ""; for (int i = 0; i < ipAddr.length; i++) { if (i > 0) { ipAddrStr += "."; } ipAddrStr += ipAddr[i] & 0xFF; } // System.out.println(ipAddrStr); return ipAddrStr; } /** * 随机字符串 * * @return */ private String genNonceStr() { Random random = new Random(); return MD5Util.getMessageDigest(String.valueOf(random.nextInt(10000)).getBytes()); } /** * 获得签名 * * @param params * 参数 * @return 签名以后的字符串 */ private String genPackageSign(List<NameValuePair> params, String key) { StringBuilder sb = new StringBuilder(); for (int i = 0; i < params.size(); i++) { sb.append(params.get(i).getName()); sb.append(\'=\'); sb.append(params.get(i).getValue()); sb.append(\'&\'); } sb.append("key="); sb.append(key); String packageSign = MD5Util.MD5Encode(sb.toString(), "utf-8").toUpperCase(); // System.out.println("包签名：="+packageSign); return packageSign; } /** * 将请求参数转换为xml格式 * * @param params * 参数list * @return xml字符串 */ public String toXml(List<NameValuePair> params) { StringBuilder sb = new StringBuilder(); sb.append("<xml>"); for (int i = 0; i < params.size(); i++) { sb.append("<" + params.get(i).getName() + ">"); sb.append(params.get(i).getValue()); sb.append("</" + params.get(i).getName() + ">"); } sb.append("</xml>"); return sb.toString(); } /** * 查询订单支付信息 * * @authour xilongfei * @2017年1月7日 上午9:44:48 * @param transaction_id * //微信交易单号 * @param type * 支付类型 APP,JSAPI,NATIVE * @return */ public Map<String, String> getSelectOrder(String transaction_id, String type) { String WX_APP_ID = null; // appid String WX_PARTNER_ID = null; // 商户id String key = null; // 秘钥 Map<String, Object> config = getConfigManager().loadConfig(); String appid = (String) config.get("appid");// 微信appid String mch_id = (String) config.get("mch_id"); // 合作者身份ID String html_appid = (String) config.get("html_appid"); // htmlappid String partner_id = (String) config.get("partner_id"); String html_key = (String) config.get("html_key"); if (type.equals("APP")) { // 判断支付方式 WX_APP_ID = appid; WX_PARTNER_ID = mch_id; key = (String) config.get("key"); ; } else { // 公众号 JSAPI支付,NATIVE(二维码支付) WX_APP_ID = html_appid; WX_PARTNER_ID = partner_id; key = html_key; } List<NameValuePair> packageParams = new LinkedList<NameValuePair>(); packageParams.add(new BasicNameValuePair("appid", WX_APP_ID)); packageParams.add(new BasicNameValuePair("mch_id", WX_PARTNER_ID)); packageParams.add(new BasicNameValuePair("nonce_str", genNonceStr())); packageParams.add(new BasicNameValuePair("transaction_id", transaction_id)); String sign = genPackageSign(packageParams, key); packageParams.add(new BasicNameValuePair("sign", sign)); String xmlstring = toXml(packageParams); try { xmlstring = new String(xmlstring.toString().getBytes(), "ISO8859-1"); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } String url = String.format("https://api.mch.weixin.qq.com/pay/orderquery"); String buf = HttpUtil.sendPostUrl(url, xmlstring); String content = new String(buf); Map<String, String> xml = null; try { xml = XMLUtil.doXMLParse(content); } catch (JDOMException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return xml; } /** * @return configManager */ public IConfigManager getConfigManager() { if (configManager == null) configManager = new WeixinPayDefaultConfigManager(); return configManager; } /** * @param configManager * the configManager to set */ public void setConfigManager(IConfigManager configManager) { this.configManager = configManager; } }
接下来是支付宝的：
package com.sm.vendors.pay.alipay; import java.util.HashMap; import java.util.List; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import com.sm.common.sms.IConfigManager; import com.sm.modules.glo.entity.settings.GloSetting; import com.sm.modules.glo.service.settings.GloSettingService; /** * @declare 支付宝支付管理器 * @author XXXX * @date 2017年8月28日 */ public class AliPayConfigManager implements IConfigManager { @Autowired private GloSettingService gloSettingService; public AliPayConfigManager() { // TODO Auto-generated constructor stub } @Override public void saveConfig(Map<String, Object> map) { // TODO Auto-generated method stub } @Override public Map<String, Object> loadConfig() { GloSetting gloSetting = new GloSetting(); gloSetting.setType("ali.pay"); List<GloSetting> list = gloSettingService.findList(gloSetting); Map<String, Object> map = new HashMap<String, Object>(); for (GloSetting gloSetting2 : list) { map.put(gloSetting2.getName(), gloSetting2.getValue()); } return map; } }
package com.sm.vendors.pay.alipay; import java.math.BigDecimal; import java.net.URLEncoder; import java.util.HashMap; import java.util.Map; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import com.alipay.api.AlipayApiException; import com.alipay.api.AlipayClient; import com.alipay.api.DefaultAlipayClient; import com.alipay.api.domain.AlipayTradeAppPayModel; import com.alipay.api.request.AlipayFundTransToaccountTransferRequest; import com.alipay.api.request.AlipayTradeAppPayRequest; import com.alipay.api.request.AlipayTradeRefundRequest; import com.alipay.api.response.AlipayFundTransToaccountTransferResponse; import com.alipay.api.response.AlipayTradeAppPayResponse; import com.alipay.api.response.AlipayTradeRefundResponse; import com.sm.common.api.ApiResult; import com.sm.common.pay.IAliPay; import com.sm.common.sms.IConfigManager; import com.sm.vendors.pay.alipay.util.AlipaySubmit; public class AlipayService implements IAliPay { private final Logger logger = Logger.getLogger(AlipayService.class); @Autowired private IConfigManager configManager; /** * pc-支付宝-发送请求 * * @2017年6月6日 * @上午9:18:08 * @param out_trade_no * 订单号(商户单号) * @param subject * 产品信息 * @param total_fee * 支付金额 * @param body * 支付信息 * @param notifyUrl * 回调地址（处理事务） * @param returnUrl * 回调页面（成功返回页面） * @return */ @Override public String pay(String out_trade_no, String subject, String total_fee, String body, String notifyUrl, String returnUrl) { ////////////////////////////////////////////////////////////////////////////////// // 把请求参数打包成数组 Map<String, String> sParaTemp = new HashMap<String, String>(); Map<String, Object> config = getConfigManager().loadConfig(); String service = (String) config.get("service");// 支付宝接口名称 String partner = (String) config.get("partner"); // 合作者身份ID String seller_id = (String) config.get("seller_id");// 支付宝商户收款账号 String _input_charset = (String) config.get("_input_charset");// 参数编码字符集 String payment_type = (String) config.get("payment_type");// 支付类型 sParaTemp.put("service", service); // 支付宝接口名称 sParaTemp.put("partner", partner); // 合作者身份ID sParaTemp.put("seller_id", seller_id); // 支付宝商户收款账号 sParaTemp.put("_input_charset", _input_charset); // 参数编码字符集 sParaTemp.put("payment_type", payment_type); // 支付类型 sParaTemp.put("notify_url", notifyUrl); // 支付宝异步通知地址 sParaTemp.put("return_url", returnUrl); sParaTemp.put("anti_phishing_key", ""); sParaTemp.put("exter_invoke_ip", ""); sParaTemp.put("out_trade_no", out_trade_no); // 订单号 sParaTemp.put("subject", subject); // sParaTemp.put("total_fee", total_fee); // 支付金额 sParaTemp.put("body", body); // 产品详情 // 其他业务参数根据在线开发文档，添加参数.文档地址:https://doc.open.alipay.com/doc2/detail.htm?spm=a219a.7629140.0.0.O9yorI&treeId=62&articleId=103740&docType=1 // 如sParaTemp.put("参数名","参数值"); // 建立请求 String sHtmlText = AlipaySubmit.buildRequest(sParaTemp, "get", "确认"); return sHtmlText; } /** * 支付宝打包成类型-APP支付 * * @2016年11月5日 上午11:41:53 * @param out_trade_no * 订单号 * @param subject * 商品名称 * @param total_fee * 支付金额 * @param body * 商品明细 * @param notifyUrl * 支付宝异步通知地址(修改数据库) * @return 支付宝请求数据 * */ @SuppressWarnings("deprecation") @Override public String payAPP(String out_trade_no, String subject, String total_fee, String body) { Map<String, Object> config = getConfigManager().loadConfig(); String pubilc_key = (String) config.get("pubilc_key"); String notify_url = (String) config.get("notify_url"); String private_key = (String) config.get("private_key"); String partner_app = (String) config.get("partner_app"); String service_url = (String) config.get("service_url"H5App打包支付方式