package cn.lili.modules.payment.kit.plugin.unionpay;
|
|
import cn.hutool.core.net.URLEncoder;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.json.JSONUtil;
|
import cn.lili.common.enums.ResultCode;
|
import cn.lili.common.exception.ServiceException;
|
import cn.lili.common.utils.SnowFlake;
|
import cn.lili.common.vo.ResultMessage;
|
import cn.lili.modules.payment.kit.CashierSupport;
|
import cn.lili.modules.payment.kit.Payment;
|
import cn.lili.modules.payment.kit.core.enums.SignType;
|
import cn.lili.modules.payment.kit.core.kit.HttpKit;
|
import cn.lili.modules.payment.kit.core.kit.IpKit;
|
import cn.lili.modules.payment.kit.core.kit.WxPayKit;
|
import cn.lili.modules.payment.kit.dto.PayParam;
|
import cn.lili.modules.payment.kit.params.dto.CashierParam;
|
import cn.lili.modules.payment.kit.plugin.unionpay.enums.ServiceEnum;
|
import cn.lili.modules.payment.kit.plugin.unionpay.model.UnifiedOrderModel;
|
import cn.lili.modules.payment.service.PaymentService;
|
import cn.lili.modules.system.entity.dos.Setting;
|
import cn.lili.modules.system.entity.dto.payment.UnionPaymentSetting;
|
import cn.lili.modules.system.entity.enums.SettingEnum;
|
import cn.lili.modules.system.service.SettingService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.nio.charset.StandardCharsets;
|
import java.util.Map;
|
|
/**
|
* 银联云闪付 支付
|
*
|
* @author Bulbasaur
|
* @since 2023/02/14 17:44
|
*/
|
@Slf4j
|
@Component
|
public class UnionPayPlugin implements Payment {
|
|
|
/**
|
* 收银台
|
*/
|
@Autowired
|
private CashierSupport cashierSupport;
|
/**
|
* 支付日志
|
*/
|
@Autowired
|
private PaymentService paymentService;
|
/**
|
* 配置
|
*/
|
@Autowired
|
private SettingService settingService;
|
|
@Override
|
public ResultMessage<Object> nativePay(HttpServletRequest request, PayParam payParam) {
|
try {
|
CashierParam cashierParam = cashierSupport.cashierParam(payParam);
|
UnionPaymentSetting unionPaymentSetting = this.unionPaymentSetting();
|
String notifyUrl = unionPaymentSetting.getUnionPayDomain().concat("/unionPay/payNotify");
|
//用户ip
|
String ip = IpKit.getRealIp(request);
|
//第三方付款订单
|
String outOrderNo = SnowFlake.getIdStr();
|
String attach = URLEncoder.createDefault().encode(JSONUtil.toJsonStr(payParam), StandardCharsets.UTF_8);
|
Map<String, String> params = UnifiedOrderModel.builder()
|
.service(ServiceEnum.NATIVE.toString())
|
.mch_id(unionPaymentSetting.getUnionPayMachId())
|
.out_trade_no(outOrderNo)
|
.body(cashierParam.getDetail())
|
.attach(attach)
|
.total_fee("0")
|
.mch_create_ip(ip)
|
.notify_url(notifyUrl)
|
.nonce_str(WxPayKit.generateStr())
|
.build().createSign(unionPaymentSetting.getUnionPayKey(), SignType.MD5);
|
|
String xmlResult = UnionPayApi.execution(unionPaymentSetting.getUnionPayServerUrl(), params);
|
log.info("xmlResult:" + xmlResult);
|
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
|
log.info(result.toString());
|
return null;
|
} catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
|
@Override
|
public ResultMessage<Object> appPay(HttpServletRequest request, PayParam payParam) {
|
try {
|
|
CashierParam cashierParam = cashierSupport.cashierParam(payParam);
|
UnionPaymentSetting unionPaymentSetting = this.unionPaymentSetting();
|
String notifyUrl = unionPaymentSetting.getUnionPayDomain().concat("/unionPay/payNotify");
|
String attach = URLEncoder.createDefault().encode(JSONUtil.toJsonStr(payParam), StandardCharsets.UTF_8);
|
|
//用户ip
|
String ip = IpKit.getRealIp(request);
|
Map<String, String> params = UnifiedOrderModel.builder()
|
.service(ServiceEnum.WEI_XIN_APP_PAY.toString())
|
.mch_id(unionPaymentSetting.getUnionPayMachId())
|
.appid(unionPaymentSetting.getUnionPayAppId())
|
.out_trade_no(WxPayKit.generateStr())
|
.body(cashierParam.getDetail())
|
.attach(attach)
|
.total_fee("0")
|
.mch_create_ip(ip)
|
.notify_url(notifyUrl)
|
.nonce_str(WxPayKit.generateStr())
|
.build()
|
.createSign(unionPaymentSetting.getUnionPayKey(), SignType.MD5);
|
|
System.out.println(params);
|
|
String xmlResult = UnionPayApi.execution(unionPaymentSetting.getUnionPayServerUrl(), params);
|
log.info("xmlResult:" + xmlResult);
|
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
|
if (!WxPayKit.verifyNotify(result, unionPaymentSetting.getUnionPayKey(), SignType.MD5)) {
|
log.error("签名异常");
|
}
|
String status = result.get("status");
|
String resultCode = result.get("result_code");
|
if (!"0".equals(status) && !"0".equals(resultCode)) {
|
log.error(result.get("err_msg"));
|
return null;
|
}
|
log.error(result.get("pay_info"));
|
return null;
|
} catch (Exception e) {
|
log.error(e.getMessage());
|
e.printStackTrace();
|
|
return null;
|
|
}
|
}
|
|
@Override
|
public ResultMessage<Object> jsApiPay(HttpServletRequest request, PayParam payParam) {
|
String buyerLogonId="";
|
String buyerId="";
|
CashierParam cashierParam = cashierSupport.cashierParam(payParam);
|
UnionPaymentSetting unionPaymentSetting = this.unionPaymentSetting();
|
String attach = URLEncoder.createDefault().encode(JSONUtil.toJsonStr(payParam), StandardCharsets.UTF_8);
|
//用户ip
|
String ip = IpKit.getRealIp(request);
|
try {
|
if (StrUtil.isEmpty(buyerLogonId) && StrUtil.isEmpty(buyerId)) {
|
log.error("buyer_logon_id buyer_id 不能同时为空");
|
return null;
|
}
|
|
String notifyUrl = unionPaymentSetting.getUnionPayDomain().concat("/unionPay/payNotify");
|
|
|
Map<String, String> params = UnifiedOrderModel.builder()
|
.service(ServiceEnum.ALI_PAY_JS_PAY.toString())
|
.mch_id(unionPaymentSetting.getUnionPayMachId())
|
.out_trade_no(WxPayKit.generateStr())
|
.body(cashierParam.getDetail())
|
.attach(attach)
|
.total_fee("0")
|
.mch_create_ip(ip)
|
.notify_url(notifyUrl)
|
.nonce_str(WxPayKit.generateStr())
|
.buyer_id(buyerId)
|
.buyer_logon_id(buyerLogonId)
|
.build()
|
.createSign(unionPaymentSetting.getUnionPayKey(), SignType.MD5);
|
|
System.out.println(params);
|
|
String xmlResult = UnionPayApi.execution(unionPaymentSetting.getUnionPayServerUrl(), params);
|
log.info("xmlResult:" + xmlResult);
|
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
|
log.info(result.toString());
|
return null;
|
} catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
|
|
@Override
|
public void callBack(HttpServletRequest request) {
|
try {
|
verifyNotify(request);
|
} catch (Exception e) {
|
log.error("支付异常", e);
|
}
|
}
|
|
@Override
|
public void notify(HttpServletRequest request) {
|
try {
|
verifyNotify(request);
|
} catch (Exception e) {
|
log.error("支付异常", e);
|
}
|
}
|
|
private void verifyNotify(HttpServletRequest request) throws Exception {
|
String xmlMsg = HttpKit.readData(request);
|
log.info("支付通知=" + xmlMsg);
|
Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);
|
|
String status = params.get("status");
|
String returnCode = params.get("result_code");
|
|
log.info(status + " " + returnCode);
|
|
if ("0".equals(status) && "0".equals(returnCode)) {
|
UnionPaymentSetting unionPaymentSetting = this.unionPaymentSetting();
|
// 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
|
// 注意此处签名方式需与统一下单的签名类型一致
|
if (WxPayKit.verifyNotify(params, unionPaymentSetting.getUnionPayKey(), SignType.MD5)) {
|
log.info("支付成功....");
|
// 更新订单信息
|
// 发送通知等
|
|
}
|
}
|
|
}
|
/**
|
* 获取微信支付配置
|
*
|
* @return
|
*/
|
private UnionPaymentSetting unionPaymentSetting() {
|
try {
|
Setting systemSetting = settingService.get(SettingEnum.UNIONPAY_PAYMENT.name());
|
UnionPaymentSetting unionPaymentSetting = JSONUtil.toBean(systemSetting.getSettingValue(), UnionPaymentSetting.class);
|
return unionPaymentSetting;
|
} catch (Exception e) {
|
log.error("微信支付暂不支持", e);
|
throw new ServiceException(ResultCode.PAY_NOT_SUPPORT);
|
}
|
}
|
}
|
