package com.dobbinsoft.fw.pay.service.pay; import com.alipay.easysdk.kernel.Config; import com.alipay.easysdk.payment.app.models.AlipayTradeAppPayResponse; import com.alipay.easysdk.payment.common.models.*; import com.alipay.easysdk.payment.facetoface.models.AlipayTradePayResponse; import com.alipay.easysdk.payment.page.models.AlipayTradePagePayResponse; import com.alipay.easysdk.payment.wap.models.AlipayTradeWapPayResponse; import com.dobbinsoft.fw.pay.client.AliClient; import com.dobbinsoft.fw.pay.config.PayProperties; import com.dobbinsoft.fw.pay.enums.PayChannelType; import com.dobbinsoft.fw.pay.enums.PayPlatformType; import com.dobbinsoft.fw.pay.exception.MatrixPayException; import com.dobbinsoft.fw.pay.model.coupon.*; import com.dobbinsoft.fw.pay.model.notify.MatrixPayOrderNotifyResult; import com.dobbinsoft.fw.pay.model.notify.MatrixPayRefundNotifyResult; import com.dobbinsoft.fw.pay.model.request.*; import com.dobbinsoft.fw.pay.model.result.*; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; /** * ClassName: AliPayServiceImpl * Description: 支付宝支付实现 * * @author: e-weichaozheng * @date: 2021-04-22 */ public class AliPayServiceImpl implements MatrixPayService { private static final Logger logger = LoggerFactory.getLogger(AliPayServiceImpl.class); private Map configMap = new ConcurrentHashMap<>(); private PayProperties payProperties; public AliPayServiceImpl(PayProperties payProperties) { this.payProperties = payProperties; } @Override public Object createOrder(MatrixPayUnifiedOrderRequest entity) throws MatrixPayException { AliClient aliClient = getClient(entity.getAppid()); try { List> detailMaps = null; if (!CollectionUtils.isEmpty(entity.getDetail())) { detailMaps = coverToAliGoodsDetail(entity.getDetail()); } if (entity.getPayPlatform() == PayPlatformType.APP) { AlipayTradeAppPayResponse appPayResponse = aliClient.payment.App() .optional("body", entity.getAttach()) .optional("time_expire", transToAliTime(entity.getTimeExpire())) .optional("goods_detail", detailMaps) .optional("terminal_id", entity.getDeviceInfo()) .pay(entity.getBody(), entity.getOutTradeNo(), this.fenToYuan(entity.getTotalFee())); return appPayResponse.body; } else if (entity.getPayPlatform() == PayPlatformType.WEB) { AlipayTradePagePayResponse pagePayResponse = aliClient.payment.Page() .optional("body", entity.getAttach()) .optional("time_expire", transToAliTime(entity.getTimeExpire())) .optional("goods_detail", detailMaps) .optional("terminal_id", entity.getDeviceInfo()) .pay(entity.getBody(), entity.getOutTradeNo(), this.fenToYuan(entity.getTotalFee()), entity.getReturnUrl()); return pagePayResponse.body; } else if (entity.getPayPlatform() == PayPlatformType.WAP) { AlipayTradeWapPayResponse wapPayResponse = aliClient.payment.Wap() .optional("body", entity.getAttach()) .optional("time_expire", transToAliTime(entity.getTimeExpire())) .optional("goods_detail", detailMaps) .optional("terminal_id", entity.getDeviceInfo()) .pay(entity.getBody(), entity.getOutTradeNo(), this.fenToYuan(entity.getTotalFee()), entity.getReturnUrl(), entity.getReturnUrl()); return wapPayResponse.body; } else { AlipayTradeCreateResponse alipayTradeCreateResponse = aliClient.payment.Common() .optional("body", entity.getAttach()) .optional("time_expire", transToAliTime(entity.getTimeExpire())) .optional("goods_detail", detailMaps) .optional("terminal_id", entity.getDeviceInfo()) .create(entity.getBody(), entity.getOutTradeNo(), this.fenToYuan(entity.getTotalFee()), entity.getOpenid()); return alipayTradeCreateResponse; } } catch (Exception e) { logger.info("[支付宝] 创建统一支付订单 异常 outTradeNo=" + entity.getOutTradeNo(), e); throw new MatrixPayException(e.getMessage()); } } private List> coverToAliGoodsDetail(List detail) { return detail.stream().map(item -> { Map map = new HashMap<>(); map.put("goods_id", item.getGoodsId()); map.put("goods_name", item.getGoodsName()); map.put("quantity", item.getGoodsNum()); map.put("price", fenToYuan(item.getPrice())); map.put("goods_category", item.getGoodsCategory()); return map; }).collect(Collectors.toList()); } /** * 将微信的时间，转化为ali的时间 * * @param time * @return */ private String transToAliTime(String time) throws ParseException { if (time == null) { return null; } SimpleDateFormat wxSdf = new SimpleDateFormat("yyyyMMddHHmmss"); Date parse = wxSdf.parse(time); SimpleDateFormat aliSdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); return aliSdf.format(parse); } private String transToWxTime(String time) throws ParseException { if (time == null) { return null; } SimpleDateFormat aliSdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date parse = aliSdf.parse(time); SimpleDateFormat wxSdf = new SimpleDateFormat("yyyyMMddHHmmss"); return wxSdf.format(parse); } @Override public void configWarmUp(List list) { if (!CollectionUtils.isEmpty(list)) { for (PayProperties properties : list) { if (StringUtils.isNotBlank(properties.getAliAppId())) { AliClient aliClient = new AliClient(this.buildNewConfig(properties)); this.configMap.put(properties.getAliAppId(), aliClient); } } } } @Override public MatrixEntPayService getEntPayService() { return null; } @Override public void setEntPayService(MatrixEntPayService entPayService) { } @Override public MatrixPayOrderQueryResult queryOrder(MatrixPayOrderQueryRequest request) throws MatrixPayException { if (StringUtils.isBlank(request.getOutTradeNo()) && StringUtils.isBlank(request.getTransactionId())) { throw new MatrixPayException("支付宝仅支持outTradeNo查询"); } AliClient aliClient = this.getClient(request.getAppid()); try { AlipayTradeQueryResponse response = aliClient.payment.Common() .optional("trade_no", request.getTransactionId()) .query(StringUtils.isBlank(request.getOutTradeNo()) ? "" : request.getOutTradeNo()); if (response != null) { MatrixPayOrderQueryResult matrixPayOrderQueryResult = new MatrixPayOrderQueryResult(); matrixPayOrderQueryResult.setPayChannel(PayChannelType.ALI); matrixPayOrderQueryResult.setAppid(request.getAppid()); matrixPayOrderQueryResult.setOutTradeNo(response.getOutTradeNo()); matrixPayOrderQueryResult.setTransactionId(response.getTradeNo()); matrixPayOrderQueryResult.setOpenid(response.getBuyerUserId()); matrixPayOrderQueryResult.setTotalFee(yuanToFen(response.getTotalAmount())); matrixPayOrderQueryResult.setFeeType(response.getTransCurrency()); String tradeStatus = response.getTradeStatus(); matrixPayOrderQueryResult.setTradeState(toMatrixStatus(tradeStatus)); matrixPayOrderQueryResult.setAttach(response.getBody()); matrixPayOrderQueryResult.setDeviceInfo(response.getTerminalId()); matrixPayOrderQueryResult.setTimeEnd(transToWxTime(response.getSendPayDate())); return matrixPayOrderQueryResult; } } catch (Exception e) { logger.error("[支付宝] 支付订单查询 异常 outTradeNo=" + request.getOutTradeNo() + " ;transactionId=" + request.getTransactionId(), e); throw new MatrixPayException(e.getMessage()); } return null; } @Override public MatrixPayOrderCloseResult closeOrder(MatrixPayOrderCloseRequest request) throws MatrixPayException { try { AliClient aliClient = getClient(request.getAppid()); AlipayTradeCloseResponse response = aliClient.payment.Common().close(request.getOutTradeNo()); if (response != null) { MatrixPayOrderCloseResult matrixPayOrderCloseResult = new MatrixPayOrderCloseResult(); matrixPayOrderCloseResult.setAppid(request.getAppid()); return matrixPayOrderCloseResult; } } catch (Exception e) { logger.info("[支付宝] 关闭订单 异常 outTradeNo=" + request.getOutTradeNo(), e); throw new MatrixPayException(e.getMessage()); } return null; } @Override public MatrixPayRefundResult refund(MatrixPayRefundRequest entity) throws MatrixPayException { AliClient aliClient = getClient(entity.getAppid()); try { AlipayTradeRefundResponse response = aliClient.payment.Common() .optional("trade_no", entity.getTransactionId()) .optional("out_request_no", entity.getOutRefundNo()) .optional("refund_reason", entity.getRefundDesc()) .refund(entity.getOutTradeNo() == null ? "" : entity.getOutTradeNo(), fenToYuan(entity.getRefundFee())); MatrixPayRefundResult result = new MatrixPayRefundResult(); String code = response.getCode(); // 是否成功判斷 if (StringUtils.equals(code, "10000")) { result.setReturnCode("SUCCESS"); result.setResultCode("SUCCESS"); } else { result.setReturnCode("ERROR"); result.setResultCode("ERROR"); } result.setAppid(entity.getAppid()); result.setPayChannel(entity.getPayChannel()); result.setRefundFee(yuanToFen(response.refundFee)); result.setTransactionId(response.tradeNo); result.setOutTradeNo(response.outTradeNo); result.setFeeType(response.refundCurrency); result.setRefundId(response.refundSettlementId); return result; } catch (Exception e) { logger.error("[支付宝] 创建退款单 异常 orderNo=" + entity.getOutTradeNo(), e); throw new MatrixPayException(e.getMessage()); } } @Override public MatrixPayRefundQueryResult refundQuery(MatrixPayRefundQueryRequest request) throws MatrixPayException { try { AliClient aliClient = getClient(request.getAppid()); AlipayTradeFastpayRefundQueryResponse response = aliClient.payment.Common() .optional("out_request_no", request.getOutRefundNo()) .queryRefund(request.getOutTradeNo() == null ? "" : request.getOutTradeNo(), request.getOutRefundNo() == null ? "" : request.getOutRefundNo()); if (response != null) { MatrixPayRefundQueryResult result = new MatrixPayRefundQueryResult(); result.setPayChannel(PayChannelType.ALI); result.setAppid(request.getAppid()); result.setTransactionId(response.getTradeNo()); result.setOutTradeNo(response.getOutTradeNo()); result.setCashFee(yuanToFen(response.getTotalAmount())); // TODO return result; } } catch (Exception e) { logger.error("[支付宝] 退款单查询 异常 orderNo=" + request.getOutTradeNo(), e); throw new MatrixPayException(e.getMessage()); } return null; } @Override public void report(MatrixPayReportRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public String downloadRawBill(MatrixPayDownloadBillRequest request) throws MatrixPayException { try { AliClient client = this.getClient(request.getAppid()); AlipayDataDataserviceBillDownloadurlQueryResponse response = client.payment.Common().downloadBill(request.getBillType(), transToAliTime(request.getBillDate())); return response.billDownloadUrl; } catch (Exception e) { logger.error("[支付宝] 退款单查询 异常 orderNo=" + request.getBillDate(), e); throw new MatrixPayException(e.getMessage()); } } @Override public MatrixPayBillResult downloadBill(MatrixPayDownloadBillRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayFundFlowResult downloadFundFlow(MatrixPayDownloadFundFlowRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayMicropayResult micropay(MatrixPayMicropayRequest request) throws MatrixPayException { AliClient aliClient = getClient(request.getAppid()); try { List> detailMaps = null; if (!CollectionUtils.isEmpty(request.getDetail())) { detailMaps = coverToAliGoodsDetail(request.getDetail()); } AlipayTradePayResponse response = aliClient.payment.FaceToFace() .optional("time_expire", transToAliTime(request.getTimeExpire())) .optional("body", request.getAttach()) .optional("detail", detailMaps) .pay(request.getBody(), request.getOutTradeNo(), fenToYuan(request.getTotalFee()), request.getAuthCode()); MatrixPayMicropayResult result = new MatrixPayMicropayResult(); result.setAppid(request.getAppid()); result.setTransactionId(response.getTradeNo()); result.setOutTradeNo(response.getOutTradeNo()); if (response.getCode().equals("10000")) { return result; } else if (response.getCode().equals("10003")) { MatrixPayException matrixPayException = new MatrixPayException(response.getMsg()); matrixPayException.setErrCode("USERPAYING"); matrixPayException.setErrCodeDes("用户正在付款"); throw matrixPayException; } throw new MatrixPayException(response.getMsg()); // result.setFeeType(response.getCur); } catch (MatrixPayException e) { throw e; } catch (Exception e) { logger.error("[支付宝] 提交当面支付 异常 outTradeNo=" + request.getOutTradeNo(), e); throw new MatrixPayException(e.getMessage()); } } @Override public MatrixPayOrderReverseResult reverseOrder(MatrixPayOrderReverseRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public String shorturl(MatrixPayShorturlRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public String authcode2Openid(MatrixPayAuthcode2OpenidRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public String getSandboxSignKey() throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayCouponSendResult sendCoupon(MatrixPayCouponSendRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayCouponStockQueryResult queryCouponStock(MatrixPayCouponStockQueryRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayCouponInfoQueryResult queryCouponInfo(MatrixPayCouponInfoQueryRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public String queryComment(MatrixPayQueryCommentRequest request) throws MatrixPayException { throw new MatrixPayException("支付宝暂时支持"); } @Override public MatrixPayOrderNotifyResult checkParsePayResult(Object request) throws MatrixPayException { try { Map map = (Map) request; AliClient aliClient = getClient(map.get("app_id")); aliClient.payment.Common().verifyNotify(map); MatrixPayOrderNotifyResult result = new MatrixPayOrderNotifyResult(); result.setOpenid(map.get("buyer_id")); result.setTotalFee(yuanToFen(map.get("invoice_amount"))); result.setOutTradeNo(map.get("out_trade_no")); result.setAppid(map.get("app_id")); result.setTransactionId(map.get("trade_no")); result.setVersion(map.get("version")); result.setAttach(map.get("body")); return result; } catch (Exception e) { logger.error("[解析支付宝 付款通知] 异常", e); throw new MatrixPayException(e.getMessage()); } } @Override public MatrixPayRefundNotifyResult checkParseRefundNotifyResult(Object request) throws MatrixPayException { try { Map map = (Map) request; AliClient aliClient = getClient(map.get("app_id")); aliClient.payment.Common().verifyNotify(map); MatrixPayRefundNotifyResult result = new MatrixPayRefundNotifyResult(); MatrixPayRefundNotifyResult.ReqInfo reqInfo = new MatrixPayRefundNotifyResult.ReqInfo(); reqInfo.setOutRefundNo(map.get("out_request_no")); reqInfo.setTransactionId(map.get("trade_no")); reqInfo.setRefundStatus(map.get("dback_status").equals("S") ? "SUCCESS" : "CHANGE"); reqInfo.setRefundFee(yuanToFen(map.get("dback_amount"))); reqInfo.setSuccessTime(transToWxTime(map.get("bank_ack_time"))); return result; } catch (Exception e) { logger.error("[解析支付宝 付款通知] 异常", e); throw new MatrixPayException(e.getMessage()); } } private String fenToYuan(Integer fen) { return "" + (fen / 100.0); } private String toMatrixStatus(String aliOrderStatus) { if ("WAIT_BUYER_PAY".equals(aliOrderStatus)) { return "NOTPAY"; } else if ("TRADE_CLOSED".equals(aliOrderStatus)) { return "CLOSED"; } else if ("TRADE_SUCCESS".equals(aliOrderStatus) || "TRADE_FINISHED".equals(aliOrderStatus)) { return "SUCCESS"; } return null; } public static Integer yuanToFen(String yuan) { return (new BigDecimal(yuan)).setScale(2, 4).multiply(new BigDecimal(100)).intValue(); } private AliClient getClient(String appId) { if (StringUtils.isEmpty(appId)) { appId = this.payProperties.getAliAppId(); } AliClient aliClient = this.configMap.get(appId); if (aliClient == null) { String aliAppId = this.payProperties.getAliAppId(); if (StringUtils.equals(appId, aliAppId)) { aliClient = new AliClient(this.buildNewConfig(this.payProperties)); this.configMap.put(payProperties.getAliAppId(), aliClient); } else { throw new MatrixPayException("加载APPID失败，请再PayProperties接口中返回对应的APPID"); } } else { // 动态判断APPID是否被更新 Config config = aliClient.getConfig(); if (payProperties.getAliDynamic() && (config.appId.hashCode() != payProperties.getAliAppId().hashCode() || config.gatewayHost.hashCode() != payProperties.getAliGateway().hashCode() || config.merchantPrivateKey.hashCode() != payProperties.getAliMchPrivateKey().hashCode() || config.alipayPublicKey.hashCode() != payProperties.getAliAliPublicKey().hashCode() || config.notifyUrl.hashCode() != payProperties.getAliNotifyUrl().hashCode() || config.alipayPublicKey.hashCode() != payProperties.getAliAliPublicKey().hashCode())) { aliClient = new AliClient(this.buildNewConfig(this.payProperties)); this.configMap.put(payProperties.getAliAppId(), aliClient); } } return aliClient; } private Config buildNewConfig(PayProperties properties) { Config config = new Config(); config.protocol = "https"; config.appId = properties.getAliAppId(); config.gatewayHost = properties.getAliGateway(); config.signType = "RSA2"; config.merchantPrivateKey = properties.getAliMchPrivateKey(); config.alipayPublicKey = properties.getAliAliPublicKey(); config.notifyUrl = properties.getAliNotifyUrl(); return config; } }