package cn.iocoder.yudao.module.pay.framework.pay.core.client.impl.weixin; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.codec.Base64; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.date.TemporalAccessorUtil; import cn.hutool.core.util.StrUtil; import cn.iocoder.yudao.framework.common.util.io.FileUtils; import cn.iocoder.yudao.framework.common.util.json.JsonUtils; import cn.iocoder.yudao.framework.common.util.object.ObjectUtils; import cn.iocoder.yudao.module.pay.enums.order.PayOrderStatusEnum; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.order.PayOrderRespDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.order.PayOrderUnifiedReqDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.refund.PayRefundRespDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.refund.PayRefundUnifiedReqDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.transfer.PayTransferRespDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.dto.transfer.PayTransferUnifiedReqDTO; import cn.iocoder.yudao.module.pay.framework.pay.core.client.impl.AbstractPayClient; import com.github.binarywang.wxpay.bean.notify.*; import com.github.binarywang.wxpay.bean.request.*; import com.github.binarywang.wxpay.bean.result.*; import com.github.binarywang.wxpay.bean.transfer.TransferBillsGetResult; import com.github.binarywang.wxpay.bean.transfer.TransferBillsNotifyResult; import com.github.binarywang.wxpay.bean.transfer.TransferBillsRequest; import com.github.binarywang.wxpay.bean.transfer.TransferBillsResult; import com.github.binarywang.wxpay.config.WxPayConfig; import com.github.binarywang.wxpay.exception.WxPayException; import com.github.binarywang.wxpay.service.WxPayService; import com.github.binarywang.wxpay.service.impl.WxPayServiceImpl; import lombok.extern.slf4j.Slf4j; import java.time.LocalDateTime; import java.time.ZoneId; import java.util.Map; import java.util.Objects; import static cn.hutool.core.date.DatePattern.*; import static cn.iocoder.yudao.module.pay.framework.pay.core.client.impl.weixin.WxPayClientConfig.API_VERSION_V2; import static cn.iocoder.yudao.module.pay.framework.pay.core.client.impl.weixin.WxPayClientConfig.API_VERSION_V3; /** * 微信支付抽象类，实现微信统一的接口、以及部分实现（退款） * * @author 芋道源码 */ @Slf4j public abstract class AbstractWxPayClient extends AbstractPayClient { protected WxPayService client; public AbstractWxPayClient(Long channelId, String channelCode, WxPayClientConfig config) { super(channelId, channelCode, config); } /** * 初始化 client 客户端 * * @param tradeType 交易类型 */ protected void doInit(String tradeType) { // 创建 config 配置 WxPayConfig payConfig = new WxPayConfig(); BeanUtil.copyProperties(config, payConfig, "keyContent", "privateKeyContent", "publicKeyContent"); payConfig.setTradeType(tradeType); // weixin-pay-java 无法设置内容，只允许读取文件，所以这里要创建临时文件来解决 if (Objects.equals(config.getApiVersion(), API_VERSION_V2)) { payConfig.setKeyPath(FileUtils.createTempFile(Base64.decode(config.getKeyContent())).getPath()); } else if (Objects.equals(config.getApiVersion(), API_VERSION_V3)) { payConfig.setPrivateKeyPath(FileUtils.createTempFile(config.getPrivateKeyContent()).getPath()); // 参考 https://gitee.com/yudaocode/yudao-ui-admin-vue3/issues/ICUE53 和 https://t.zsxq.com/ODR5V if (StrUtil.isNotBlank(config.getPublicKeyContent())) { payConfig.setPublicKeyPath(FileUtils.createTempFile(config.getPublicKeyContent()).getPath()); } // 特殊：强制使用微信公钥模式，避免灰度期间的问题！！！ payConfig.setStrictlyNeedWechatPaySerial(true); } // 创建 client 客户端 client = new WxPayServiceImpl(); client.setConfig(payConfig); } // ============ 支付相关 ========== @Override protected PayOrderRespDTO doUnifiedOrder(PayOrderUnifiedReqDTO reqDTO) throws Exception { try { switch (config.getApiVersion()) { case API_VERSION_V2: return doUnifiedOrderV2(reqDTO); case API_VERSION_V3: // TODO @芋艿：【可能是 wxjava 的 bug】参考 https://github.com/binarywang/WxJava/issues/1557 client.getConfig().setApiV3HttpClient(null); return doUnifiedOrderV3(reqDTO); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } catch (WxPayException e) { log.error("[doUnifiedOrder][支付({}) 发起微信支付异常", reqDTO, e); String errorCode = getErrorCode(e); String errorMessage = getErrorMessage(e); return PayOrderRespDTO.closedOf(errorCode, errorMessage, reqDTO.getOutTradeNo(), e.getXmlString()); } } /** * 【V2】调用支付渠道，统一下单 * * @param reqDTO 下单信息 * @return 各支付渠道的返回结果 */ protected abstract PayOrderRespDTO doUnifiedOrderV2(PayOrderUnifiedReqDTO reqDTO) throws Exception; /** * 【V3】调用支付渠道，统一下单 * * @param reqDTO 下单信息 * @return 各支付渠道的返回结果 */ protected abstract PayOrderRespDTO doUnifiedOrderV3(PayOrderUnifiedReqDTO reqDTO) throws WxPayException; /** * 【V2】创建微信下单请求 * * @param reqDTO 下信息 * @return 下单请求 */ protected WxPayUnifiedOrderRequest buildPayUnifiedOrderRequestV2(PayOrderUnifiedReqDTO reqDTO) { return WxPayUnifiedOrderRequest.newBuilder() .outTradeNo(reqDTO.getOutTradeNo()) .body(reqDTO.getSubject()) .detail(reqDTO.getBody()) .totalFee(reqDTO.getPrice()) // 单位分 .timeExpire(formatDateV2(reqDTO.getExpireTime())) .spbillCreateIp(reqDTO.getUserIp()) .notifyUrl(reqDTO.getNotifyUrl()) .build(); } /** * 【V3】创建微信下单请求 * * @param reqDTO 下信息 * @return 下单请求 */ protected WxPayUnifiedOrderV3Request buildPayUnifiedOrderRequestV3(PayOrderUnifiedReqDTO reqDTO) { WxPayUnifiedOrderV3Request request = new WxPayUnifiedOrderV3Request(); request.setOutTradeNo(reqDTO.getOutTradeNo()); request.setDescription(reqDTO.getSubject()); request.setAmount(new WxPayUnifiedOrderV3Request.Amount().setTotal(reqDTO.getPrice())); // 单位分 request.setTimeExpire(formatDateV3(reqDTO.getExpireTime())); request.setSceneInfo(new WxPayUnifiedOrderV3Request.SceneInfo().setPayerClientIp(reqDTO.getUserIp())); request.setNotifyUrl(reqDTO.getNotifyUrl()); return request; } @Override public PayOrderRespDTO doParseOrderNotify(Map params, String body, Map headers) throws WxPayException { switch (config.getApiVersion()) { case API_VERSION_V2: return doParseOrderNotifyV2(body); case API_VERSION_V3: return doParseOrderNotifyV3(body, headers); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } private PayOrderRespDTO doParseOrderNotifyV2(String body) throws WxPayException { // 1. 解析回调 WxPayOrderNotifyResult response = client.parseOrderNotifyResult(body); // 2. 构建结果 // V2 微信支付的回调，只有 SUCCESS 支付成功、CLOSED 支付失败两种情况，无需像支付宝一样解析的比较复杂 Integer status = Objects.equals(response.getResultCode(), "SUCCESS") ? PayOrderStatusEnum.SUCCESS.getStatus() : PayOrderStatusEnum.CLOSED.getStatus(); return PayOrderRespDTO.of(status, response.getTransactionId(), response.getOpenid(), parseDateV2(response.getTimeEnd()), response.getOutTradeNo(), body); } private PayOrderRespDTO doParseOrderNotifyV3(String body, Map headers) throws WxPayException { // 1. 解析回调 SignatureHeader signatureHeader = getRequestHeader(headers); WxPayNotifyV3Result response = client.parseOrderNotifyV3Result(body, signatureHeader); WxPayNotifyV3Result.DecryptNotifyResult result = response.getResult(); // 2. 构建结果 Integer status = parseStatus(result.getTradeState()); String openid = result.getPayer() != null ? result.getPayer().getOpenid() : null; return PayOrderRespDTO.of(status, result.getTransactionId(), openid, parseDateV3(result.getSuccessTime()), result.getOutTradeNo(), body); } @Override protected PayOrderRespDTO doGetOrder(String outTradeNo) throws Throwable { try { switch (config.getApiVersion()) { case API_VERSION_V2: return doGetOrderV2(outTradeNo); case API_VERSION_V3: return doGetOrderV3(outTradeNo); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } catch (WxPayException e) { if (ObjectUtils.equalsAny(e.getErrCode(), "ORDERNOTEXIST", "ORDER_NOT_EXIST")) { String errorCode = getErrorCode(e); String errorMessage = getErrorMessage(e); return PayOrderRespDTO.closedOf(errorCode, errorMessage, outTradeNo, e.getXmlString()); } throw e; } } private PayOrderRespDTO doGetOrderV2(String outTradeNo) throws WxPayException { // 构建 WxPayUnifiedOrderRequest 对象 WxPayOrderQueryRequest request = WxPayOrderQueryRequest.newBuilder() .outTradeNo(outTradeNo).build(); // 执行请求 WxPayOrderQueryResult response = client.queryOrder(request); // 转换结果 Integer status = parseStatus(response.getTradeState()); return PayOrderRespDTO.of(status, response.getTransactionId(), response.getOpenid(), parseDateV2(response.getTimeEnd()), outTradeNo, response); } private PayOrderRespDTO doGetOrderV3(String outTradeNo) throws WxPayException { // 构建 WxPayUnifiedOrderRequest 对象 WxPayOrderQueryV3Request request = new WxPayOrderQueryV3Request() .setOutTradeNo(outTradeNo); // 执行请求 WxPayOrderQueryV3Result response = client.queryOrderV3(request); // 转换结果 Integer status = parseStatus(response.getTradeState()); String openid = response.getPayer() != null ? response.getPayer().getOpenid() : null; return PayOrderRespDTO.of(status, response.getTransactionId(), openid, parseDateV3(response.getSuccessTime()), outTradeNo, response); } private static Integer parseStatus(String tradeState) { switch (tradeState) { case "NOTPAY": case "USERPAYING": // 支付中，等待用户输入密码（条码支付独有） return PayOrderStatusEnum.WAITING.getStatus(); case "SUCCESS": return PayOrderStatusEnum.SUCCESS.getStatus(); case "REFUND": return PayOrderStatusEnum.REFUND.getStatus(); case "CLOSED": case "REVOKED": // 已撤销（刷卡支付独有） case "PAYERROR": // 支付失败（其它原因，如银行返回失败） return PayOrderStatusEnum.CLOSED.getStatus(); default: throw new IllegalArgumentException(StrUtil.format("未知的支付状态({})", tradeState)); } } // ============ 退款相关 ========== @Override protected PayRefundRespDTO doUnifiedRefund(PayRefundUnifiedReqDTO reqDTO) throws Throwable { try { switch (config.getApiVersion()) { case API_VERSION_V2: return doUnifiedRefundV2(reqDTO); case API_VERSION_V3: return doUnifiedRefundV3(reqDTO); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } catch (WxPayException e) { String errorCode = getErrorCode(e); String errorMessage = getErrorMessage(e); return PayRefundRespDTO.failureOf(errorCode, errorMessage, reqDTO.getOutRefundNo(), e.getXmlString()); } } private PayRefundRespDTO doUnifiedRefundV2(PayRefundUnifiedReqDTO reqDTO) throws Throwable { // 1. 构建 WxPayRefundRequest 请求 WxPayRefundRequest request = new WxPayRefundRequest() .setOutTradeNo(reqDTO.getOutTradeNo()) .setOutRefundNo(reqDTO.getOutRefundNo()) .setRefundFee(reqDTO.getRefundPrice()) .setRefundDesc(reqDTO.getReason()) .setTotalFee(reqDTO.getPayPrice()) .setNotifyUrl(reqDTO.getNotifyUrl()); // 2.1 执行请求 WxPayRefundResult response = client.refundV2(request); // 2.2 创建返回结果 if (Objects.equals("SUCCESS", response.getResultCode())) { // V2 情况下，不直接返回退款成功，而是等待异步通知 return PayRefundRespDTO.waitingOf(response.getRefundId(), reqDTO.getOutRefundNo(), response); } return PayRefundRespDTO.failureOf(reqDTO.getOutRefundNo(), response); } private PayRefundRespDTO doUnifiedRefundV3(PayRefundUnifiedReqDTO reqDTO) throws Throwable { // 1. 构建 WxPayRefundRequest 请求 WxPayRefundV3Request request = new WxPayRefundV3Request() .setOutTradeNo(reqDTO.getOutTradeNo()) .setOutRefundNo(reqDTO.getOutRefundNo()) .setAmount(new WxPayRefundV3Request.Amount().setRefund(reqDTO.getRefundPrice()) .setTotal(reqDTO.getPayPrice()).setCurrency("CNY")) .setReason(reqDTO.getReason()) .setNotifyUrl(reqDTO.getNotifyUrl()); // 2.1 执行请求 WxPayRefundV3Result response = client.refundV3(request); // 2.2 创建返回结果 if (Objects.equals("SUCCESS", response.getStatus())) { return PayRefundRespDTO.successOf(response.getRefundId(), parseDateV3(response.getSuccessTime()), reqDTO.getOutRefundNo(), response); } if (Objects.equals("PROCESSING", response.getStatus())) { return PayRefundRespDTO.waitingOf(response.getRefundId(), reqDTO.getOutRefundNo(), response); } return PayRefundRespDTO.failureOf(reqDTO.getOutRefundNo(), response); } @Override public PayRefundRespDTO doParseRefundNotify(Map params, String body, Map headers) throws WxPayException { switch (config.getApiVersion()) { case API_VERSION_V2: return doParseRefundNotifyV2(body); case API_VERSION_V3: return parseRefundNotifyV3(body, headers); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } private PayRefundRespDTO doParseRefundNotifyV2(String body) throws WxPayException { // 1. 解析回调 WxPayRefundNotifyResult response = client.parseRefundNotifyResult(body); WxPayRefundNotifyResult.ReqInfo result = response.getReqInfo(); // 2. 构建结果 if (Objects.equals("SUCCESS", result.getRefundStatus())) { return PayRefundRespDTO.successOf(result.getRefundId(), parseDateV2B(result.getSuccessTime()), result.getOutRefundNo(), response); } return PayRefundRespDTO.failureOf(result.getOutRefundNo(), response); } private PayRefundRespDTO parseRefundNotifyV3(String body, Map headers) throws WxPayException { // 1. 解析回调 SignatureHeader signatureHeader = getRequestHeader(headers); WxPayRefundNotifyV3Result response = client.parseRefundNotifyV3Result(body, signatureHeader); WxPayRefundNotifyV3Result.DecryptNotifyResult result = response.getResult(); // 2. 构建结果 if (Objects.equals("SUCCESS", result.getRefundStatus())) { return PayRefundRespDTO.successOf(result.getRefundId(), parseDateV3(result.getSuccessTime()), result.getOutRefundNo(), response); } return PayRefundRespDTO.failureOf(result.getOutRefundNo(), response); } @Override protected PayRefundRespDTO doGetRefund(String outTradeNo, String outRefundNo) throws WxPayException { try { switch (config.getApiVersion()) { case API_VERSION_V2: return doGetRefundV2(outTradeNo, outRefundNo); case API_VERSION_V3: return doGetRefundV3(outTradeNo, outRefundNo); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } catch (WxPayException e) { if (ObjectUtils.equalsAny(e.getErrCode(), "REFUNDNOTEXIST", "RESOURCE_NOT_EXISTS")) { String errorCode = getErrorCode(e); String errorMessage = getErrorMessage(e); return PayRefundRespDTO.failureOf(errorCode, errorMessage, outRefundNo, e.getXmlString()); } throw e; } } private PayRefundRespDTO doGetRefundV2(String outTradeNo, String outRefundNo) throws WxPayException { // 1. 构建 WxPayRefundRequest 请求 WxPayRefundQueryRequest request = WxPayRefundQueryRequest.newBuilder() .outTradeNo(outTradeNo) .outRefundNo(outRefundNo) .build(); // 2.1 执行请求 WxPayRefundQueryResult response = client.refundQuery(request); // 2.2 创建返回结果 if (!Objects.equals("SUCCESS", response.getResultCode())) { return PayRefundRespDTO.waitingOf(null, outRefundNo, response); } WxPayRefundQueryResult.RefundRecord refund = CollUtil.findOne(response.getRefundRecords(), record -> record.getOutRefundNo().equals(outRefundNo)); if (refund == null) { return PayRefundRespDTO.failureOf(outRefundNo, response); } switch (refund.getRefundStatus()) { case "SUCCESS": return PayRefundRespDTO.successOf(refund.getRefundId(), parseDateV2B(refund.getRefundSuccessTime()), outRefundNo, response); case "PROCESSING": return PayRefundRespDTO.waitingOf(refund.getRefundId(), outRefundNo, response); case "CHANGE": // 退款到银行发现用户的卡作废或者冻结了，导致原路退款银行卡失败，资金回流到商户的现金帐号，需要商户人工干预，通过线下或者财付通转账的方式进行退款 case "FAIL": return PayRefundRespDTO.failureOf(outRefundNo, response); default: throw new IllegalArgumentException(String.format("未知的退款状态(%s)", refund.getRefundStatus())); } } private PayRefundRespDTO doGetRefundV3(String outTradeNo, String outRefundNo) throws WxPayException { // 1. 构建 WxPayRefundRequest 请求 WxPayRefundQueryV3Request request = new WxPayRefundQueryV3Request(); request.setOutRefundNo(outRefundNo); // 2.1 执行请求 WxPayRefundQueryV3Result response = client.refundQueryV3(request); // 2.2 创建返回结果 switch (response.getStatus()) { case "SUCCESS": return PayRefundRespDTO.successOf(response.getRefundId(), parseDateV3(response.getSuccessTime()), outRefundNo, response); case "PROCESSING": return PayRefundRespDTO.waitingOf(response.getRefundId(), outRefundNo, response); case "ABNORMAL": // 退款异常 case "CLOSED": return PayRefundRespDTO.failureOf(outRefundNo, response); default: throw new IllegalArgumentException(String.format("未知的退款状态(%s)", response.getStatus())); } } @Override protected PayTransferRespDTO doUnifiedTransfer(PayTransferUnifiedReqDTO reqDTO) throws WxPayException { // 1. 构建 TransferBillsRequest 请求 TransferBillsRequest request = TransferBillsRequest.newBuilder() .appid(this.config.getAppId()) .outBillNo(reqDTO.getOutTransferNo()) .transferAmount(reqDTO.getPrice()) .transferRemark(reqDTO.getSubject()) .transferSceneId(reqDTO.getChannelExtras().get("sceneId")) .openid(reqDTO.getUserAccount()) .userName(reqDTO.getUserName()) .transferSceneReportInfos(JsonUtils.parseArray(reqDTO.getChannelExtras().get("sceneReportInfos"), TransferBillsRequest.TransferSceneReportInfo.class)) .notifyUrl(reqDTO.getNotifyUrl()) .build(); // 特殊：微信转账，必须 0.3 元起，才允许传入姓名 if (reqDTO.getPrice() < 30) { request.setUserName(null); } // 2.1 执行请求 try { TransferBillsResult response = client.getTransferService().transferBills(request); // 2.2 创建返回结果 String state = response.getState(); if (ObjectUtils.equalsAny(state, "ACCEPTED", "PROCESSING", "WAIT_USER_CONFIRM", "TRANSFERING")) { return PayTransferRespDTO.processingOf(response.getTransferBillNo(), response.getOutBillNo(), response) .setChannelPackageInfo(response.getPackageInfo()); // 一般情况下，只有 WAIT_USER_CONFIRM 会有！ } if (Objects.equals("SUCCESS", state)) { return PayTransferRespDTO.successOf(response.getTransferBillNo(), parseDateV3(response.getCreateTime()), response.getOutBillNo(), response); } return PayTransferRespDTO.closedOf(state, response.getFailReason(), response.getOutBillNo(), response); } catch (WxPayException e) { log.error("[doUnifiedTransfer][转账({}) 发起微信支付异常", reqDTO, e); String errorCode = getErrorCode(e); String errorMessage = getErrorMessage(e); return PayTransferRespDTO.closedOf(errorCode, errorMessage, reqDTO.getOutTransferNo(), e.getXmlString()); } } @Override protected PayTransferRespDTO doGetTransfer(String outTradeNo) throws WxPayException { // 1. 执行请求 TransferBillsGetResult response = client.getTransferService().getBillsByOutBillNo(outTradeNo); // 2. 创建返回结果 String state = response.getState(); if (ObjectUtils.equalsAny(state, "ACCEPTED", "PROCESSING", "WAIT_USER_CONFIRM", "TRANSFERING")) { return PayTransferRespDTO.processingOf(response.getTransferBillNo(), response.getOutBillNo(), response); } if (Objects.equals("SUCCESS", state)) { return PayTransferRespDTO.successOf(response.getTransferBillNo(), parseDateV3(response.getUpdateTime()), response.getOutBillNo(), response); } return PayTransferRespDTO.closedOf(state, response.getFailReason(), response.getOutBillNo(), response); } @Override public PayTransferRespDTO doParseTransferNotify(Map params, String body, Map headers) throws WxPayException { switch (config.getApiVersion()) { case API_VERSION_V3: return parseTransferNotifyV3(body, headers); case API_VERSION_V2: throw new UnsupportedOperationException("V2 版本暂不支持，建议使用 V3 版本"); default: throw new IllegalArgumentException(String.format("未知的 API 版本(%s)", config.getApiVersion())); } } private PayTransferRespDTO parseTransferNotifyV3(String body, Map headers) throws WxPayException { // 1. 解析回调 SignatureHeader signatureHeader = getRequestHeader(headers); TransferBillsNotifyResult response = client.getTransferService().parseTransferBillsNotifyResult(body, signatureHeader); TransferBillsNotifyResult.DecryptNotifyResult result = response.getResult(); // 2. 创建返回结果 String state = result.getState(); if (ObjectUtils.equalsAny(state, "ACCEPTED", "PROCESSING", "WAIT_USER_CONFIRM", "TRANSFERING")) { return PayTransferRespDTO.processingOf(result.getTransferBillNo(), result.getOutBillNo(), response); } if (Objects.equals("SUCCESS", state)) { return PayTransferRespDTO.successOf(result.getTransferBillNo(), parseDateV3(result.getUpdateTime()), result.getOutBillNo(), response); } return PayTransferRespDTO.closedOf(state, result.getFailReason(), result.getOutBillNo(), response); } // ========== 各种工具方法 ========== /** * 组装请求头重的签名信息 * * @see 官方示例 */ private SignatureHeader getRequestHeader(Map headers) { // 参见 https://gitee.com/zhijiantianya/yudao-cloud/issues/ICSFL6 return SignatureHeader.builder() .signature(getHeaderValue(headers, "Wechatpay-Signature", "wechatpay-signature")) .nonce(getHeaderValue(headers, "Wechatpay-Nonce", "wechatpay-nonce")) .serial(getHeaderValue(headers, "Wechatpay-Serial", "wechatpay-serial")) .timeStamp(getHeaderValue(headers, "Wechatpay-Timestamp", "wechatpay-timestamp")) .build(); } private String getHeaderValue(Map headers, String capitalizedKey, String lowercaseKey) { String value = headers.get(capitalizedKey); if (value != null) { return value; } return headers.get(lowercaseKey); } static String formatDateV2(LocalDateTime time) { return TemporalAccessorUtil.format(time.atZone(ZoneId.systemDefault()), PURE_DATETIME_PATTERN); } static LocalDateTime parseDateV2(String time) { return LocalDateTimeUtil.parse(time, PURE_DATETIME_PATTERN); } static LocalDateTime parseDateV2B(String time) { return LocalDateTimeUtil.parse(time, NORM_DATETIME_PATTERN); } static String formatDateV3(LocalDateTime time) { return TemporalAccessorUtil.format(time.atZone(ZoneId.systemDefault()), UTC_WITH_XXX_OFFSET_PATTERN); } static LocalDateTime parseDateV3(String time) { return LocalDateTimeUtil.parse(time, UTC_WITH_XXX_OFFSET_PATTERN); } static String getErrorCode(WxPayException e) { if (StrUtil.isNotEmpty(e.getErrCode())) { return e.getErrCode(); } if (StrUtil.isNotEmpty(e.getCustomErrorMsg())) { return "CUSTOM_ERROR"; } return e.getReturnCode(); } static String getErrorMessage(WxPayException e) { if (StrUtil.isNotEmpty(e.getErrCode())) { return e.getErrCodeDes(); } if (StrUtil.isNotEmpty(e.getCustomErrorMsg())) { return e.getCustomErrorMsg(); } return e.getReturnMsg(); } }