[关闭]
@kangwg 2017-04-09T14:38:31.000000Z 字数 7452 阅读 1053

layout: post
title: "微信支付"
subtitle: "微信app支付，微信公众号支付，微信扫码支付"
date: 2017-04-09 12:00:00
author: "kangwg"
header-img: "img/post-bg-2015.jpg"
catalog: true

- 微信

先导入微信的第三方依赖

    <dependency>
        <groupId>me.hao0</groupId>
        <artifactId>wepay-core</artifactId>
        <version>1.1.2</version>
    </dependency>

先建微信支付的基类，然后各种支付类型的实现继承它

  1. import java.math.BigDecimal;
  2. import java.text.SimpleDateFormat;
  3. import java.util.Map;
  5. import org.slf4j.*;
  7. import com.google.common.base.Strings;
  9. import cn.swao.baselib.util.*;
  10. import me.hao0.wepay.core.*;
  11. import me.hao0.wepay.exception.WepayException;
  12. import me.hao0.wepay.model.order.WePayOrder;
  13. import me.hao0.wepay.model.refund.*;
  15. public class WxPayService {
  17.     private static Logger log = LoggerFactory.getLogger(WxPayService.class);
  19.     public Wepay wepay = null;
  21.     public final static SimpleDateFormat wxTimeFormat = new SimpleDateFormat("yyyyMMddHHmmss");
  23.     public String merchant = null;
  25.     public void setMerchant(String merchant) {
  26.         this.merchant = merchant;
  27.     }
  29.     public Wepay initWepay(String certPath, String appId, String payKey, String payMerchant, String certPasswd) {
  30.         if (Strings.isNullOrEmpty(certPath)) {
  31.             log.info("WxPay : no init.");
  32.         } else {
  33.             log.info("WxPay : init. " + certPath);
  34.             byte[] data = FsUtils.readBinaryFile(certPath);//读取证书
  35.             if (data == null)
  36.                 log.error("WxPay : read cert error. " + certPath);
  37.             else
  38.                 this.wepay = WepayBuilder.newBuilder(appId, payKey, payMerchant).certPasswd(certPasswd).certs(data).build();
  39.         }
  40.         return this.wepay;
  41.     }
  43.     public Notifies getNotifies() {
  44.         return this.wepay.notifies();
  45.     }
  47.     // 异步通知检验
  48.     public boolean notifyVerify(Map<String, ?> map) {
  49.         return getNotifies().verifySign(map);
  50.     }
  52.     // 订单查询
  53.     public WePayOrder getOrder(String outTradeNo) {
  54.         try {
  55.             return this.wepay.order().queryByOutTradeNo(outTradeNo);
  56.         } catch (WepayException e) {
  57.             log.error("WxPay getOrder", e);
  58.             return null;
  59.         }
  60.     }
  62.     // 退款
  63.     public RefundApplyResponse refund(String outTradeNo, BigDecimal fee) {
  64.         try {
  65.             log.info(LogUtils.gen("WxPay refund", "out_trade_no", outTradeNo));
  66.             Integer totalFee = fee.multiply(new BigDecimal(100)).intValue();
  67.             RefundApplyRequest req = new RefundApplyRequest();
  68.             req.setOutTradeNo(outTradeNo);
  69.             req.setOutRefundNo(outTradeNo);
  70.             req.setTotalFee(totalFee);
  71.             req.setRefundFee(totalFee);
  72.             req.setOpUserId(this.merchant);
  74.             RefundApplyResponse result = this.wepay.refund().apply(req);
  75.             log.info(LogUtils.gen("WxPay sucess", "RefundApplyResponse", result.toString()));
  76.             return result;
  77.         } catch (WepayException e) {
  78.             log.error("WxPay refund", e);
  79.             return null;
  80.         }
  81.     }
  83.     // 退款查询
  84.     public RefundQueryResponse getRefund(String outTradeNo) {
  85.         try {
  86.             return wepay.refund().queryByOutTradeNo(outTradeNo);
  87.         } catch (WepayException e) {
  88.             log.error("WxPay getRefund", e);
  89.             return null;
  90.         }
  91.     }
  93. }

initWepay是对微信支付client对象初始化，其中还有通用的退款、查询、异步通知校验的方法。

1.app支付

  1. import java.math.BigDecimal;
  2. import java.net.*;
  3. import java.util.Map;
  5. import javax.annotation.PostConstruct;
  7. import org.slf4j.*;
  8. import org.springframework.beans.factory.annotation.Value;
  9. import org.springframework.stereotype.Service;
  11. import com.google.common.base.Strings;
  12. import com.google.common.collect.Maps;
  13. import com.google.gson.JsonObject;
  15. import cn.swao.baselib.util.*;
  16. import me.hao0.wepay.model.pay.*;
  18. @Service
  19. public class WxAppService extends WxPayService {
  21.     private static Logger log = LoggerFactory.getLogger(WeixinMpService.class);
  23.     @Value("${open.appId:}")
  24.     private String appId = null;
  25.     @Value("${open.appSecret:}")
  26.     private String appSecret = null;
  27.     @Value("${open.pay.Merchant:}")
  28.     private String payMerchant = null;
  29.     @Value("${open.pay.Key:}")
  30.     private String payKey = null;
  31.     @Value("${open.pay.CertPasswd:}")
  32.     private String certPasswd = null;
  33.     @Value("${open.pay.CertPath:}")
  34.     private String certPath = null;
  35.     @Value("${open.pay.notifyUrl:}")
  36.     private String payNotifyUrl = null;
  38.     @PostConstruct
  39.     private void init() {
  40.         initWepay(certPath, appId, payKey, payMerchant, certPasswd);
  41.         setMerchant(this.payMerchant);
  42.     }
  44.     // app支付
  45.     public AppPayResponse getAppPay(String outTradeNo, BigDecimal fee, String body, String ip) {
  46.         log.info(LogUtils.gen("wxapp下单", "out_trade_no", outTradeNo, "body", body, "ip", ip));
  47.         PayRequest app = new PayRequest();
  48.         int totalFee = FinanceUtils.toFen(fee);
  49.         app.setBody(body);
  50.         app.setNotifyUrl(this.payNotifyUrl);
  51.         app.setOutTradeNo(outTradeNo);
  52.         app.setTotalFee(totalFee);
  53.         if (Strings.isNullOrEmpty(ip)) {
  54.             try {
  55.                 ip = InetAddress.getLocalHost().getHostAddress();//如果ip为空，那么拿本机ip(防止拿不到ip导致的异常)
  56.             } catch (UnknownHostException e) {
  57.             }
  58.         }
  59.         app.setClientId(ip);
  60.         app.setTimeStart(DateUtils.nowString(wxTimeFormat));
  61.         Map<String, Object> attachMap = Maps.newHashMap();
  62.         attachMap.put("out_trade_no", outTradeNo);
  63.         attachMap.put("wxPayWay", "JSAPI");
  64.         app.setAttach(JSONUtils.toJson(attachMap));
  66.         try {
  67.             log.info(LogUtils.gen("app", app.toString()));
  68.             AppPayResponse appPay = super.wepay.pay().appPay(app);
  69.             log.info(LogUtils.gen("wxapp下单成功", "appPay", appPay.toString()));
  70.             return appPay;
  71.         } catch (Exception e) {
  72.             log.error("WxAppService getAppPay", e);
  73.             return null;
  74.         }
  75.     }
  77. }

其中的方法是app统一支付下单的方法，其他的查询和异步验签只需要用父类的方法。@Value中的参数写在配置文件中，这些参数是app支付必要的一些参数 ,@PostConstruct项目启动后调用，获取微信支付的对象。
2.微信公众号支付和扫码支付

  1. import cn.swao.baselib.model.NotifyTemplates;
  2. import cn.swao.baselib.util.*;
  3. import com.google.common.base.Strings;
  4. import com.google.common.collect.Maps;
  5. import com.google.gson.JsonObject;
  6. import me.hao0.wepay.exception.WepayException;
  7. import me.hao0.wepay.model.pay.JsPayRequest;
  8. import me.hao0.wepay.model.pay.JsPayResponse;
  9. import me.hao0.wepay.model.pay.QrPayRequest;
  10. import org.slf4j.Logger;
  11. import org.slf4j.LoggerFactory;
  12. import org.springframework.beans.factory.annotation.Value;
  13. import org.springframework.stereotype.Service;
  15. import javax.annotation.PostConstruct;
  16. import java.math.BigDecimal;
  17. import java.util.*;
  19. @Service
  20. public class WeixinMpService extends WxPayService {
  21.     private static Logger log = LoggerFactory.getLogger(WeixinMpService.class);
  23.     @Value("${mp.appId:}")
  24.     private String appId = null;
  25.     @Value("${mp.appSecret:}")
  26.     private String appSecret = null;
  27.     @Value("${mp.pay.Merchant:}")
  28.     private String payMerchant = null;
  29.     @Value("${mp.pay.Key:}")
  30.     private String payKey = null;
  31.     @Value("${mp.pay.CertPasswd:}")
  32.     private String certPasswd = null;
  33.     @Value("${mp.pay.CertPath:}")
  34.     private String certPath = null;
  35.     @Value("${mp.pay.notifyUrl:}")
  36.     private String payNotifyUrl = null;
  38.     @PostConstruct
  39.     private void init() {
  40.         initWepay(this.certPath, this.appId, this.payKey, this.payMerchant, this.certPasswd);
  41.         setMerchant(this.payMerchant);
  42.     }
  45.     // 微信公众号支付
  46.     public JsPayResponse getJsPay(String outTradeNo, BigDecimal fee, String body, String ip, String openid) {
  47.         log.info(LogUtils.gen("开始统一下单", "out_trade_no", outTradeNo, "body", body, "ip", ip, "openid", openid));
  48.         int totalFee = FinanceUtils.toFen(fee);
  49.         JsPayRequest jpr = new JsPayRequest();
  50.         jpr.setBody(body);
  51.         jpr.setNotifyUrl(this.payNotifyUrl);
  52.         jpr.setOutTradeNo(outTradeNo);
  53.         jpr.setTotalFee(totalFee);
  54.         if (Strings.isNullOrEmpty(ip))
  55.             ip = SysUtils.getIp();
  56.         jpr.setClientId(ip);
  57.         jpr.setOpenId(openid);
  58.         jpr.setTimeStart(DateUtils.nowString(wxTimeFormat));
  59.         Map<String, Object> attachMap = Maps.newHashMap();
  60.         attachMap.put("out_trade_no", outTradeNo);
  61.         attachMap.put("wxPayWay", "JSAPI");
  62.         jpr.setAttach(JSONUtils.toJson(attachMap));
  64.         try {
  65.             log.info(LogUtils.gen("jpr", jpr.toString()));
  66.             JsPayResponse jsPay = this.wepay.pay().jsPay(jpr);
  67.             log.info(LogUtils.gen("统一下单成功", "JsPayResponse", jsPay.toString()));
  68.             return jsPay;
  69.         } catch (WepayException e) {
  70.             log.error("WeixinService getJsPay", e);
  71.             return null;
  72.         }
  73.     }
  75.     //扫码支付
  76.     public String getQrPay(String outTradeNo, BigDecimal fee, String body, String ip, String productId) {
  77.         log.info(LogUtils.gen("开始统一下单", "out_trade_no", outTradeNo, "body", body, "ip", ip, "productId", productId));
  78.         QrPayRequest qr = new QrPayRequest();
  79.         int totalFee = FinanceUtils.toFen(fee);
  81.         qr.setBody(body);
  82.         qr.setNotifyUrl(this.payNotifyUrl);
  83.         qr.setOutTradeNo(outTradeNo);
  84.         qr.setTotalFee(totalFee);
  85.         if (Strings.isNullOrEmpty(ip))
  86.             ip = SysUtils.getIp();//获取本机地址ip
  87.         qr.setClientId(ip);
  88.         qr.setTimeStart(DateUtils.nowString(wxTimeFormat));
  89.         qr.setProductId(productId);
  90.         String codeUrl = null;
  91.         try {
  92.             codeUrl = this.wepay.pay().qrPay(qr);
  93.             log.info("扫码支付 codeUrl:{}", codeUrl);
  94.         } catch (Exception e) {
  95.             log.error("扫码支付下单失败", e);
  96.         }
  97.         return codeUrl;
  98.     }
  99. }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注