app微信支付宝支付后台的插件模式+回调通过spring广播处理后续业务（已亲测可用）

2023-11-28 08:53:58

写在前面的话：每当我们做一个项目，基本上都会涉及到支付的业务，最常用的莫过于微信和支付宝的支付了，项目有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");
        AlipayClient alipayClient = new DefaultAlipayClient(service_url, partner_app, private_key, "json", "utf-8",
                pubilc_key, "RSA2");
        // 实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
        AlipayTradeAppPayRequest request = new AlipayTradeAppPayRequest();
        // SDK已经封装掉了公共参数，这里只需要传入业务参数。以下方法为sdk的model入参方式(model和biz_content同时存在的情况下取biz_content)。
        AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
        /* model.setBody(body); */// 产品详情
        model.setBody(URLEncoder.encode(body.toString()));
        model.setSubject(URLEncoder.encode(subject.toString()));
        model.setOutTradeNo(out_trade_no); // 商户单号
        model.setTimeoutExpress("30m"); // 请求时长(报错时间)
        model.setTotalAmount(total_fee); // 支付金额
        model.setProductCode("QUICK_MSECURITY_PAY"); // 支付类型
        request.setBizModel(model);
        request.setNotifyUrl(notify_url);
        String zhifubaoBody = null; // 返回请求数据
        try {
            // 这里和普通的接口调用不同，使用的是sdkExecute
            AlipayTradeAppPayResponse response = alipayClient.sdkExecute(request);
            zhifubaoBody = response.getBody();
        } catch (AlipayApiException e) {
            e.printStackTrace();
            logger.error(e.getMessage());
        }
        return zhifubaoBody;
    }

    /**
     * 支付宝单笔转账(提现)
     * 
     * @parameter indentNum 订单号
     * @parameter payeeAccount 支付宝账户（收款账号）
     * @parameter price 转账金额
     * @Description: TODO(用一句话描述该文件做什么)
     * @author XXX
     * @date 创建时间：2017年7月11日 上午11:01:34
     */
    @Override
    public String alipayTransfer(String indentNum, String payeeAccount, String price) throws AlipayApiException {

        Map<String, Object> config = getConfigManager().loadConfig();
        String pubilc_key = (String) config.get("pubilc_key");
        String private_key = (String) config.get("private_key");
        String partner_app = (String) config.get("partner_app");
        String remark = (String) config.get("remark");

        AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", partner_app,
                private_key, "json", "utf-8", pubilc_key, "RSA2");
        AlipayFundTransToaccountTransferRequest request = new AlipayFundTransToaccountTransferRequest();
        request.setBizContent("{" + "\"out_biz_no\":\"" + indentNum + "\"," + "\"payee_type\":\"ALIPAY_LOGONID\","
                + "\"payee_account\":\"" + payeeAccount + "\"," + "\"amount\":\"" + price + "\"," + "\"remark\":\""
                + remark + "\"" + "  }");
        AlipayFundTransToaccountTransferResponse response = alipayClient.execute(request);
        logger.info("------sub_msg:" + response.getSubMsg() + "-----SubCode:" + response.getSubCode());
        if (response.isSuccess()) {
            return "SUCCESS";
        } else {
            System.out.println("调用失败");
            return "FALSE";
        }
    }

    /**
     * 支付宝退款
     * 
     * @parameter indentNum 商户订单号
     * @parameter send_back 支付宝号
     * @parameter price 退款金额
     * @Description: TODO(用一句话描述该文件做什么)
     * @author XXX
     * @throws AlipayApiException
     * @date 创建时间：2017年7月8日 下午6:00:50
     */
    @Override
    public ApiResult alipayRefund(String indentNum, BigDecimal price) throws AlipayApiException {
        price = new BigDecimal("0.01");// 测试退款
        ApiResult result = new ApiResult();

        Map<String, Object> config = getConfigManager().loadConfig();
        String pubilc_key = (String) config.get("pubilc_key");
        String private_key = (String) config.get("private_key");
        String partner_app = (String) config.get("partner_app");

        AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", partner_app,
                private_key, "json", "utf-8", pubilc_key, "RSA2");
        AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
        request.setBizContent("{" + "\"trade_no\":\"" + indentNum + "\"," + "\"refund_amount\":" + price + ","
                + "\"refund_reason\":\"正常退款\"" + "  }");
        System.out.println(request.getBizContent().toString());
        AlipayTradeRefundResponse response = alipayClient.execute(request);
        System.out.println(response.getCode());
        if (response.isSuccess()) {
            result.setCode(0);
            result.setMessage("退款成功");
            return result;
        } else {
            result.setMessage(response.getSubMsg());
            return result;
        }
    }

    /**
     * @return configManager
     */
    public IConfigManager getConfigManager() {
        if (configManager == null)
            configManager = new AliPayDefaultConfigManager();
        return configManager;
    }

    /**
     * @param configManager
     *            the configManager to set
     */
    public void setConfigManager(IConfigManager configManager) {
        this.configManager = configManager;
    }

}

看到这里有的人又问了，提交的参数怎么一个都没有？其实我是将它们都配置在了数据库中，大家可以根据业务在loadConfig()方法中将参数以key value的形式放入一个map中return。

接下来再看这两个方法继承的类和接口，

为什么要这么写我相信多数人都会明白其中的意义所在。

package com.sm.common.pay;

import java.math.BigDecimal;

import com.alipay.api.AlipayApiException;
import com.sm.common.api.ApiResult;

public interface IAliPay {

    /**
     * pc-支付宝-发送请求
     *@2017年6月6日
     *@上午9:18:08
     *@param out_trade_no    订单号(商户单号)
     *@param subject           产品信息
     *@param total_fee           支付金额
     *@param body               支付信息
     *@param notifyUrl         回调地址（处理事务）
     *@param returnUrl        回调页面（成功返回页面）
     *@author fwz
     *@return
     */
    public String pay(String out_trade_no, String subject ,String total_fee, String body,String notifyUrl,String returnUrl);
    
    
    /**
     * 支付宝打包成类型-APP支付
     * @2016年11月5日
     * 上午11:41:53
     * @param out_trade_no    订单号
     * @param subject         商品名称
     * @param total_fee       支付金额
     * @param body            商品明细
     * @param notifyUrl       支付宝异步通知地址(修改数据库)
     * @return 支付宝请求数据
     * @author fwz
     */
    public String payAPP(String out_trade_no, String subject ,String total_fee, String body);
    
    
    
    /**
       * 支付宝单笔转账(提现)
       * @parameter  indentNum  订单号
       * @parameter  payeeAccount 支付宝账户（收款账号）
       * @parameter  price  转账金额
       * @Description: TODO(用一句话描述该文件做什么)
       * @author fwz
       * @date 创建时间：2017年7月11日 上午11:01:34
       */
      public String alipayTransfer(String indentNum,String payeeAccount,String price) throws AlipayApiException;
      
      
      /**
       * 支付宝退款
       * @parameter  indentNum 商户订单号 
       * @parameter  send_back 支付宝号 
       * @parameter  price 退款金额
       * @Description: TODO(用一句话描述该文件做什么)
       * @author fwz
       * @throws AlipayApiException 
       * @date 创建时间：2017年7月8日 下午6:00:50
       */
      public ApiResult alipayRefund(String indentNum,BigDecimal price) throws AlipayApiException;
}

/**
* <p>Title: IConfigManager.java</p>
* <p>Description: </p>
* <p>Copyright: Copyright (c) 2007</p>
* <p>Company: LTGames</p>
* @author linxy.cn
* @date 2017年8月25日
* @version 1.0
*/
package com.sm.common.sms;

import java.util.Map;

/**
* <p>Title: 各类配置管理器</p>
* <p>Description: </p>
* <p>Company: LTGames</p> 
* @author linxy.cn
* @date 2017年8月25日
*/
public interface IConfigManager {

    /**
     * 
    * <p>Title: 保存配置定义</p>
    * <p>Description: </p>
    * @param map
    * @author linxy.cn
    * @date 2017年8月25日
     */
    void saveConfig(Map<String , Object> map);
    
    /**
     * 
    * <p>Title: 加载配置定义</p>
    * <p>Description: </p>
    * @return
    * @author linxy.cn
    * @date 2017年8月25日
     */
    Map<String , Object> loadConfig();
}

最后是两个不和任何业务挂钩的回调函数，在这里就不列出来了，在我文章最后分享的代码中全部都有，大家只需要放到自己的项目中，照着上面的方法稍作修改即可。

然后说一下spring的广播，spring的广播机制是非常好玩的一个东东，就像十字路口的红绿灯，我只管显示红或者绿，行人们是走是停跟我就没有任何的关系了。

使用方法也非常简单，只需要在spring中配置一个广播bean和一个监听bean，代码如下：

<bean id="AliPayResultListener" class="com.sm.common.event.AliPayResultListener"></bean>
    <bean id="OrderEvent" class="com.sm.common.event.OrderEvent"></bean>

package com.sm.common.event;

import org.springframework.context.ApplicationListener;

public class AliPayResultListener implements ApplicationListener<OrderEvent> {

    @Override
    public void onApplicationEvent(OrderEvent event) {
        // TODO Auto-generated method stub
        System.out.println("支付宝支付回调函数监听：" + event.getOrderNo());
    }

}

package com.sm.common.event;

import org.springframework.context.ApplicationEvent;

public class OrderEvent extends ApplicationEvent {

    /** serialVersionUID*/
    private static final long serialVersionUID = -9098775622920305229L;
    private String orderNo;
    
    public OrderEvent(Object source) {
        // TODO Auto-generated constructor stub
        super(source);
    }

    /**
    * @return orderNo
    */
    public String getOrderNo() {
        return orderNo;
    }

    /**
     * @param orderNo the orderNo to set
     */
    public void setOrderNo(String orderNo) {
        this.orderNo = orderNo;
    }
}

然后在回调函数里面将事件广播出去：

OrderEvent event = new OrderEvent(this);
event.setOrderNo("44444444FFFFF");
SpringContextHolder.getApplicationContext().publishEvent(event);

然后在 onApplicationEvent(OrderEvent event)这个方法中处理自己的业务即可。

微信支付宝回调函数中还夹杂着我之前项目中的一些业务没有及时删除，大家直接删掉就行了。

app微信支付宝支付后台的插件模式+回调通过spring广播处理后续业务（已亲测可用）

码农公寓

相关文章