lywsvip/pay-java-parent
1
0
Fork 0
mirror of https://gitee.com/egzosn/pay-java-parent.git synced 2026-06-01 05:19:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

微信新转账逻辑

Browse Source
This commit is contained in:
egzosn
2026-05-08 15:44:17 +08:00
parent 0791bbd9b7
commit 9b184d93df
5 changed files with 21 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pay-java-wx/src/main/java/com/egzosn/pay/wx/v3/api/WxPayService.java
View File

@@ -212,11 +212,15 @@ public class WxPayService extends BasePayService<WxPayConfigStorage> implements
String body = noticeParams.getBodyStr();
//签名信息
String signText = StringUtils.joining("\n", timestamp, nonce, body);
LOG.debug("微信验签：{}", signText);
if (StringUtils.isNotEmpty(payConfigStorage.getKeyPublic())) {
return RSA2.verify(signText, signature, payConfigStorage.getKeyPublic(), payConfigStorage.getInputCharset());
}
Certificate certificate = getAssistService().getCertificate(serial);
return RSA2.verify(signText, signature, certificate, payConfigStorage.getInputCharset());
boolean verify = RSA2.verify(signText, signature, certificate, payConfigStorage.getInputCharset());
LOG.debug("微信验签：{}, verify:{}", signText, verify);
return verify;
}
@@ -364,7 +368,8 @@ public class WxPayService extends BasePayService<WxPayConfigStorage> implements
public NoticeParams getNoticeParams(NoticeRequest request) {
WxNoticeParams noticeParams = null;
try (InputStream is = request.getInputStream()) {
String body = IOUtils.toString(is);
String body = IOUtils.toString(is, payConfigStorage.getInputCharset());
LOG.debug("微信回调解析：{}", body);
noticeParams = JSON.parseObject(body, WxNoticeParams.class);
noticeParams.setAttr(new MapGen<String, Object>(WxConst.RESP_BODY, body).getAttr());
noticeParams.setBodyStr(body);
@@ -374,8 +379,9 @@ public class WxPayService extends BasePayService<WxPayConfigStorage> implements
String ciphertext = resource.getCiphertext();
String data = AntCertificationUtil.decryptToString(associatedData, nonce, ciphertext, payConfigStorage.getV3ApiKey(), payConfigStorage.getInputCharset());
noticeParams.setBody(JSON.parseObject(data));
}
catch (IOException e) {
LOG.debug("微信回调解析noticeParams：{}", JSON.toJSONString(noticeParams));
} catch (IOException | RuntimeException e) {
LOG.error("获取回调参数异常：{}", e.getMessage(), e);
throw new PayErrorException(new WxPayError(FAILURE, "获取回调参数异常"), e);
}
Map<String, List<String>> headers = new HashMap<>();
@@ -659,7 +665,8 @@ public class WxPayService extends BasePayService<WxPayConfigStorage> implements
}
parameters.put(WxConst.TRANSFER_AMOUNT, Util.conversionCentAmount(transferOrder.getAmount()));
parameters.put(WxConst.TRANSFER_REMARK, transferOrder.getRemark());
parameters.put(WxConst.TOTAL_NUM, transferOrder.getAttr(WxConst.TOTAL_NUM));
parameters.put(WxConst.NOTIFY_URL, payConfigStorage.getNotifyUrl());
OrderParaStructure.loadParameters(parameters, WxConst.TOTAL_NUM, transferOrder);
OrderParaStructure.loadParameters(parameters, WxConst.TRANSFER_SCENE_ID, transferOrder);
OrderParaStructure.loadParameters(parameters, WxConst.NOTIFY_URL, transferOrder);
OrderParaStructure.loadParameters(parameters, WxConst.USER_RECV_PERCEPTION, transferOrder);

6
pay-java-wx/src/main/java/com/egzosn/pay/wx/v3/bean/WxTransferType.java
View File

@@ -18,6 +18,8 @@ public enum WxTransferType implements TransferType {
* 转账到零钱
*/
TRANSFER_BATCHES("/v3/transfer/batches", MethodType.POST),
TRANSFER_BILLS("/v3/fund-app/mch-transfer/transfer-bills", MethodType.POST),
/**
* 查询转账到零钱的记录,通过微信批次单号查询批次单
*/
@@ -51,6 +53,8 @@ public enum WxTransferType implements TransferType {
*/
QUERY_TRANSFER_DETAIL_ELECTRONIC_RECEIPTS("/v3/transfer-detail/electronic-receipts"),
;
private String type;
private MethodType method;
WxTransferType(String type, MethodType method) {
this.type = type;
@@ -61,8 +65,6 @@ public enum WxTransferType implements TransferType {
this(type, MethodType.GET);
}
private String type;
private MethodType method;
@Override