certStrategyFunc = v1.isClasspathUsed()?this::loadFile:s -> s;
+
+ propertyMapper.from(v1::getAppCertPublicKeyPath)
+ .as(certStrategyFunc)
+ .to(certAlipayRequest::setCertContent);
+ propertyMapper.from(v1::getAlipayPublicCertPath)
+ .as(certStrategyFunc)
+ .to(certAlipayRequest::setAlipayPublicCertContent);
+ propertyMapper.from(v1::getAlipayRootCertPath)
+ .as(certStrategyFunc)
+ .to(certAlipayRequest::setRootCertContent);
return new DefaultAlipayClient(certAlipayRequest);
}
- private String getContentFromClassPath(String classPath) {
- ClassPathResource resource = new ClassPathResource(classPath);
- try (InputStreamReader in = new InputStreamReader(resource.getInputStream())) {
- return IOUtils.toString(in);
- } catch (IOException e) {
- log.error("ali pay root cert is invalid ,{}", e.getMessage());
- throw new PayException("ali pay root cert path is invalid");
- }
- }
-
-
- private String appRSAPrivateKey(String classPath) {
+ private String loadFile(String classPath) {
ClassPathResource resource = new ClassPathResource(classPath);
try (InputStreamReader inputStreamReader = new InputStreamReader(resource.getInputStream())) {
- try (BufferedReader bufferedReader = new BufferedReader(inputStreamReader)) {
- return bufferedReader.readLine();
- }
+ return IOUtils.toString(inputStreamReader);
} catch (IOException e) {
log.error("ali pay app private key is required ,{}", e.getMessage());
throw new PayException("ali pay app private key is required");
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/alipay/AliPayProperties.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/alipay/AliPayProperties.java
index f19b5de..4c2b4e2 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/alipay/AliPayProperties.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/alipay/AliPayProperties.java
@@ -70,6 +70,10 @@ public class AliPayProperties {
* charset default utf-8
*/
private String charset = "utf-8";
+ /**
+ * use classpath or not ,default true
+ */
+ private boolean classpathUsed = true;
/**
* alipay public cert path
*/
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/ReceiverType.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/ReceiverType.java
new file mode 100644
index 0000000..6c1c8be
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/ReceiverType.java
@@ -0,0 +1,23 @@
+package cn.felord.payment.wechat.enumeration;
+
+
+/**
+ * 分账接收方类型
+ *
+ * @author n1
+ * @since 2021/5/31 17:47
+ */
+public enum ReceiverType {
+ /**
+ * 商户号
+ */
+ MERCHANT_ID,
+ /**
+ * 个人openid（由父商户APPID转换得到）
+ */
+ PERSONAL_OPENID,
+ /**
+ * 个人sub_openid（由子商户APPID转换得到），服务商模式
+ */
+ PERSONAL_SUB_OPENID
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/TransferAcceptType.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/TransferAcceptType.java
new file mode 100644
index 0000000..2020bb9
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/TransferAcceptType.java
@@ -0,0 +1,22 @@
+package cn.felord.payment.wechat.enumeration;
+
+/**
+ * 批量转账到零钱 - 电子回单受理类型
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+public enum TransferAcceptType {
+ /**
+ * 批量转账明细电子回单
+ */
+ BATCH_TRANSFER,
+ /**
+ * 企业付款至零钱电子回单
+ */
+ TRANSFER_TO_POCKET,
+ /**
+ * 企业付款至银行卡电子回单
+ */
+ TRANSFER_TO_BANK
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/WechatPayV3Type.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/WechatPayV3Type.java
index 3bcbca3..654ef68 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/WechatPayV3Type.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/WechatPayV3Type.java
@@ -47,13 +47,13 @@ public enum WechatPayV3Type {
*
* @since 1.0.3.RELEASE
*/
- TRADEBILL(HttpMethod.GET, "%s/v3/bill/tradebill"),
+ TRADE_BILL(HttpMethod.GET, "%s/v3/bill/tradebill"),
/**
* 申请资金账单API.
*
* @since 1.0.3.RELEASE
*/
- FUNDFLOWBILL(HttpMethod.GET, "%s/v3/bill/fundflowbill"),
+ FUND_FLOW_BILL(HttpMethod.GET, "%s/v3/bill/fundflowbill"),
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
@@ -487,6 +487,37 @@ public enum WechatPayV3Type {
* @since 1.0.6.RELEASES
*/
BATCH_TRANSFER_DOWNLOAD_BILL(HttpMethod.GET, "%s/v3/transfer/bill-receipt/{out_batch_no}"),
+ /**
+ * 转账明细电子回单受理API.
+ *
+ * @since 1.0.11.RELEASES
+ */
+ BATCH_TRANSFER_ELECTRONIC(HttpMethod.POST, "%s/v3/transfer-detail/electronic-receipts"),
+ /**
+ * 查询转账明细电子回单受理结果API.
+ * 请求方式同{@link WechatPayV3Type#BATCH_TRANSFER_ELECTRONIC}不同
+ *
+ * @since 1.0.11.RELEASES
+ */
+ BATCH_TRANSFER_ELECTRONIC_DETAIL(HttpMethod.GET, "%s/v3/transfer-detail/electronic-receipts"),
+ /**
+ * 查询账户实时余额API
+ *
+ * @since 1.0.11.RELEASES
+ */
+ BATCH_TRANSFER_FUND_BALANCE(HttpMethod.GET, "%s/v3/merchant/fund/balance/{account_type}"),
+ /**
+ * 查询账户日终余额API
+ *
+ * @since 1.0.11.RELEASES
+ */
+ BATCH_TRANSFER_FUND_DAY_BALANCE(HttpMethod.GET, "%s/v3/merchant/fund/dayendbalance/{account_type}"),
+ /**
+ * 商户银行来账查询API
+ *
+ * @since 1.0.11.RELEASES
+ */
+ BATCH_TRANSFER_FUND_INCOME_RECORDS(HttpMethod.GET, "%s/v3/merchantfund/merchant/income-records"),
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
@@ -536,7 +567,62 @@ public enum WechatPayV3Type {
* @since 1.0.0.RELEASE
*/
TRANSACTION_OUT_TRADE_NO_PARTNER(HttpMethod.GET, "%s/v3/pay/partner/transactions/out-trade-no/{out_trade_no}"),
- ;
+
+ //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+ /**
+ * 请求分账API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_ORDERS(HttpMethod.POST, "%s/v3/profitsharing/orders"),
+ /**
+ * 查询分账结果API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_ORDERS_RESULT(HttpMethod.GET, "%s/v3/profitsharing/orders/{out_order_no}"),
+ /**
+ * 请求分账回退API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_RETURN_ORDERS(HttpMethod.POST, "%s/v3/profitsharing/return-orders"),
+ /**
+ * 查询分账回退结果API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_RETURN_ORDERS_RESULT(HttpMethod.GET, "%s/v3/profitsharing/return-orders"),
+ /**
+ * 解冻剩余资金API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_ORDERS_UNFREEZE(HttpMethod.POST, "%s/v3/profitsharing/orders/unfreeze"),
+ /**
+ * 查询剩余待分金额API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_AMOUNTS(HttpMethod.GET, "%s/v3/profitsharing/transactions/{transaction_id}/amounts"),
+ /**
+ * 服务商专用-查询最大分账比例API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_MCH_CONFIG(HttpMethod.GET, "%s/v3/profitsharing/merchant-configs/{sub_mchid}"),
+ /**
+ * 添加分账接收方API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_RECEIVERS_ADD(HttpMethod.POST, "%s/v3/profitsharing/receivers/add"),
+ /**
+ * 删除分账接收方API.
+ *
+ * @since 1.0.11.RELEASE
+ */
+ PROFITSHARING_RECEIVERS_DELETE(HttpMethod.POST, "%s/v3/profitsharing/receivers/add");
/**
* The Pattern.
*
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v2/WechatAllocationApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v2/WechatAllocationApi.java
index 6c815ca..e7c050b 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v2/WechatAllocationApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v2/WechatAllocationApi.java
@@ -36,6 +36,7 @@ import java.util.List;
* 微信支付分账
*
*
+ * @author felord.cn
* @since 1.0.10.RELEASE
*/
@Slf4j
@@ -72,20 +73,20 @@ public class WechatAllocationApi {
*/
@SneakyThrows
public JsonNode profitSharing(ProfitSharingModel profitSharingModel) {
- ProfitSharingSModel profitSharingSModel = new ProfitSharingSModel();
+ ProfitSharingSModel model = new ProfitSharingSModel();
List receivers = profitSharingModel.getReceivers();
- profitSharingSModel.setReceivers(MAPPER.writeValueAsString(receivers));
+ model.setReceivers(MAPPER.writeValueAsString(receivers));
WechatPayProperties.V3 v3 = wechatV2Client.getWechatMetaBean().getV3();
- profitSharingSModel.setAppid(v3.getAppId());
- profitSharingSModel.setMchId(v3.getMchId());
+ model.setAppid(v3.getAppId());
+ model.setMchId(v3.getMchId());
- profitSharingSModel.setTransactionId(profitSharingModel.getTransactionId());
- profitSharingSModel.setOutOrderNo(profitSharingModel.getOutOrderNo());
+ model.setTransactionId(profitSharingModel.getTransactionId());
+ model.setOutOrderNo(profitSharingModel.getOutOrderNo());
- profitSharingSModel.certPath(v3.getCertPath());
- profitSharingSModel.signType(BaseModel.HMAC_SHA256);
- return wechatV2Client.wechatPayRequest(profitSharingSModel,
+ model.certPath(v3.getCertPath());
+ model.signType(BaseModel.HMAC_SHA256);
+ return wechatV2Client.wechatPayRequest(model,
HttpMethod.POST,
"https://api.mch.weixin.qq.com/secapi/pay/profitsharing");
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/AbstractApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/AbstractApi.java
index 50615ec..693da19 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/AbstractApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/AbstractApi.java
@@ -27,8 +27,10 @@ import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.PropertyNamingStrategy;
+import com.fasterxml.jackson.databind.node.ObjectNode;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import org.springframework.core.io.Resource;
+import org.springframework.http.ContentDisposition;
import org.springframework.http.HttpHeaders;
import org.springframework.http.RequestEntity;
import org.springframework.http.ResponseEntity;
@@ -89,7 +91,7 @@ public abstract class AbstractApi {
*/
private void applyObjectMapper(ObjectMapper mapper) {
mapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE)
- .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES,false)
+ .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
// empty string error
.configure(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT, true)
.setSerializationInclusion(JsonInclude.Include.NON_NULL)
@@ -217,13 +219,15 @@ public abstract class AbstractApi {
throw new PayException("wechat app pay json failed");
}
}
+
/**
- * 对账单内容下载，非流文件。
+ * 对账单CSV内容下载，非流文件。
*
* @param link the link
* @return 对账单内容 ，有可能为空字符 “”
+ * @see AbstractApi#billResource(String) AbstractApi#billResource(String)AbstractApi#billResource(String)AbstractApi#billResource(String)
*/
- protected String billDownload(String link) {
+ protected String billCsvDownload(String link) {
return this.client().withType(WechatPayV3Type.FILE_DOWNLOAD, link)
.function((type, downloadUrl) -> {
URI uri = UriComponentsBuilder.fromHttpUrl(downloadUrl)
@@ -234,26 +238,12 @@ public abstract class AbstractApi {
.download();
}
- /**
- * 对账单下载，流文件。
- *
- * @param link the link
- * @return response entity
- */
- protected ResponseEntity billResource(String link) {
- return this.client().withType(WechatPayV3Type.FILE_DOWNLOAD, link)
- .function((type, downloadUrl) -> {
- URI uri = UriComponentsBuilder.fromHttpUrl(downloadUrl)
- .build()
- .toUri();
- return Get(uri);
- })
- .resource();
- }
/**
* 申请交易账单API
*
+ * 返回值直接返回前端，会下载tradebill-前缀加上日期的txt文件（默认）或者gzip文件。
+ *
* 微信支付按天提供交易账单文件，商户可以通过该接口获取账单文件的下载地址。文件内包含交易相关的金额、时间、营销等信息，供商户核对订单、退款、银行到账等情况。
*
* 注意：
@@ -265,10 +255,13 @@ public abstract class AbstractApi {
*
*
* @param tradeBillParams tradeBillParams
+ * @return the response entity
* @since 1.0.3.RELEASE
*/
- public final void downloadTradeBill(TradeBillParams tradeBillParams) {
- this.client().withType(WechatPayV3Type.TRADEBILL, tradeBillParams)
+ public ResponseEntity downloadTradeBill(TradeBillParams tradeBillParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+
+ this.client().withType(WechatPayV3Type.TRADE_BILL, tradeBillParams)
.function((wechatPayV3Type, params) -> {
MultiValueMap queryParams = new LinkedMultiValueMap<>();
LocalDate billDate = params.getBillDate();
@@ -291,8 +284,15 @@ public abstract class AbstractApi {
.build().toUri();
return Get(uri);
})
- .consumer(response -> this.billDownload(Objects.requireNonNull(response.getBody()).get("download_url").asText()))
+ .consumer(wechatResponseEntity::convert)
.request();
+ String downloadUrl = Objects.requireNonNull(wechatResponseEntity.getBody())
+ .get("download_url")
+ .asText();
+
+ String ext = Objects.equals(TarType.GZIP, tradeBillParams.getTarType()) ? ".gzip" : ".txt";
+ String filename = "tradebill-" + tradeBillParams.getBillDate().toString() + ext;
+ return downloadBillResponse(downloadUrl, filename);
}
/**
@@ -307,10 +307,12 @@ public abstract class AbstractApi {
*
*
* @param fundFlowBillParams fundFlowBillParams
+ * @return the response entity
* @since 1.0.3.RELEASE
*/
- public final void downloadFundFlowBill(FundFlowBillParams fundFlowBillParams) {
- this.client().withType(WechatPayV3Type.FUNDFLOWBILL, fundFlowBillParams)
+ public ResponseEntity downloadFundFlowBill(FundFlowBillParams fundFlowBillParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.FUND_FLOW_BILL, fundFlowBillParams)
.function((wechatPayV3Type, params) -> {
MultiValueMap queryParams = new LinkedMultiValueMap<>();
LocalDate billDate = params.getBillDate();
@@ -328,7 +330,46 @@ public abstract class AbstractApi {
.build().toUri();
return Get(uri);
})
- .consumer(response -> this.billDownload(Objects.requireNonNull(response.getBody()).get("download_url").asText()))
+ .consumer(wechatResponseEntity::convert)
.request();
+ String downloadUrl = Objects.requireNonNull(wechatResponseEntity.getBody())
+ .get("download_url")
+ .asText();
+
+ String ext = Objects.equals(TarType.GZIP, fundFlowBillParams.getTarType()) ? ".gzip" : ".txt";
+ String filename = "fundflowbill-" + fundFlowBillParams.getBillDate().toString() + ext;
+ return this.downloadBillResponse(downloadUrl, filename);
+ }
+
+ /**
+ * 调用{@code /v3/billdownload/file}直接下载为文件.
+ *
+ * @param downloadUrl 格式为 {@code https://api.mch.weixin.qq.com/v3/billdownload/file?token=xxx}
+ * @param filename 文件名称包含扩展名
+ * @return the response entity
+ */
+ public ResponseEntity downloadBillResponse(String downloadUrl, String filename) {
+ ResponseEntity responseEntity = this.billResource(downloadUrl);
+ HttpHeaders httpHeaders = new HttpHeaders();
+ // utf is not support
+ httpHeaders.setContentDisposition(ContentDisposition.attachment().filename(filename).build());
+ return ResponseEntity.ok().headers(httpHeaders).body(responseEntity.getBody());
+ }
+
+ /**
+ * 调用{@code /v3/billdownload/file}下载返回的原始文件流
+ *
+ * @param link the link
+ * @return response entity
+ */
+ protected ResponseEntity billResource(String link) {
+ return this.client().withType(WechatPayV3Type.FILE_DOWNLOAD, link)
+ .function((type, downloadUrl) -> {
+ URI uri = UriComponentsBuilder.fromHttpUrl(downloadUrl)
+ .build()
+ .toUri();
+ return Get(uri);
+ })
+ .resource();
}
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/SignatureProvider.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/SignatureProvider.java
index 1d37b4d..f3af733 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/SignatureProvider.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/SignatureProvider.java
@@ -30,9 +30,7 @@ import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.bouncycastle.jce.provider.BouncyCastleProvider;
import org.springframework.http.*;
-import org.springframework.util.AlternativeJdkIdGenerator;
-import org.springframework.util.Base64Utils;
-import org.springframework.util.IdGenerator;
+import org.springframework.util.*;
import org.springframework.web.client.RestOperations;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponents;
@@ -120,7 +118,6 @@ public class SignatureProvider {
/**
* 我方请求前用 SHA256withRSA 加签，使用API证书.
*
- * @param newLine the new line
* @param tenantId the properties key
* @param method the method
* @param canonicalUrl the canonical url
@@ -128,7 +125,7 @@ public class SignatureProvider {
* @return the string
*/
@SneakyThrows
- public String requestSign(boolean newLine,String tenantId, String method, String canonicalUrl, String body) {
+ public String requestSign(String tenantId, String method, String canonicalUrl, String body) {
long timestamp = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8"));
String nonceStr = nonceStrGenerator.generateId()
@@ -136,7 +133,7 @@ public class SignatureProvider {
.replaceAll("-", "");
WechatMetaBean wechatMetaBean = wechatMetaContainer.getWechatMeta(tenantId);
PrivateKey privateKey = wechatMetaBean.getKeyPair().getPrivate();
- String encode = this.doRequestSign(newLine,privateKey, method, canonicalUrl, String.valueOf(timestamp), nonceStr, body);
+ String encode = this.doRequestSign(privateKey, method, canonicalUrl, String.valueOf(timestamp), nonceStr, body);
// 序列号
String serialNo = wechatMetaBean.getSerialNumber();
// 生成token
@@ -150,17 +147,16 @@ public class SignatureProvider {
/**
* Do request sign.
*
- * @param newLine the has suffix
* @param privateKey the private key
* @param orderedComponents the orderedComponents
* @return the string
* @since 1.0.4.RELEASE
*/
@SneakyThrows
- public String doRequestSign(boolean newLine,PrivateKey privateKey, String... orderedComponents) {
+ public String doRequestSign(PrivateKey privateKey, String... orderedComponents) {
Signature signer = Signature.getInstance("SHA256withRSA", BC_PROVIDER);
signer.initSign(privateKey);
- final String signatureStr = createSign(newLine,orderedComponents);
+ final String signatureStr = createSign(true, orderedComponents);
signer.update(signatureStr.getBytes(StandardCharsets.UTF_8));
return Base64Utils.encodeToString(signer.sign());
}
@@ -180,7 +176,7 @@ public class SignatureProvider {
}
Certificate certificate = CERTIFICATE_MAP.get(wechatpaySerial);
- final String signatureStr = createSign(true,params.getWechatpayTimestamp(), params.getWechatpayNonce(), params.getBody());
+ final String signatureStr = createSign(true, params.getWechatpayTimestamp(), params.getWechatpayNonce(), params.getBody());
Signature signer = Signature.getInstance("SHA256withRSA");
signer.initVerify(certificate);
signer.update(signatureStr.getBytes(StandardCharsets.UTF_8));
@@ -208,7 +204,7 @@ public class SignatureProvider {
}
// 签名
HttpMethod httpMethod = WechatPayV3Type.CERT.method();
- String authorization = requestSign(true,tenantId, httpMethod.name(), canonicalUrl, "");
+ String authorization = requestSign(tenantId, httpMethod.name(), canonicalUrl, "");
HttpHeaders headers = new HttpHeaders();
headers.setAccept(Collections.singletonList(MediaType.APPLICATION_JSON));
@@ -224,8 +220,8 @@ public class SignatureProvider {
}
ArrayNode certificates = bodyObjectNode.withArray("data");
if (certificates.isArray() && certificates.size() > 0) {
- CERTIFICATE_MAP.clear();
- final CertificateFactory certificateFactory = CertificateFactory.getInstance("X509",BC_PROVIDER);
+ CERTIFICATE_MAP.remove(tenantId);
+ final CertificateFactory certificateFactory = CertificateFactory.getInstance("X509", BC_PROVIDER);
certificates.forEach(objectNode -> {
JsonNode encryptCertificate = objectNode.get("encrypt_certificate");
String associatedData = encryptCertificate.get("associated_data").asText();
@@ -256,6 +252,15 @@ public class SignatureProvider {
* @return the string
*/
public String decryptResponseBody(String tenantId, String associatedData, String nonce, String ciphertext) {
+
+ try {
+ Assert.hasText(associatedData, "associatedData is invalid");
+ Assert.hasText(nonce, "nonce is invalid");
+ Assert.hasText(ciphertext, "ciphertext is invalid");
+ } catch (Exception e) {
+ throw new PayException(e.getMessage());
+ }
+
try {
Cipher cipher = Cipher.getInstance("AES/GCM/NoPadding", BC_PROVIDER);
String apiV3Key = wechatMetaContainer.getWechatMeta(tenantId).getV3().getAppV3Secret();
@@ -285,14 +290,14 @@ public class SignatureProvider {
* @return encrypt message
* @since 1.0.6.RELEASE
*/
- public String encryptRequestMessage(String message,Certificate certificate) {
+ public String encryptRequestMessage(String message, Certificate certificate) {
try {
Cipher cipher = Cipher.getInstance("RSA/ECB/OAEPWithSHA-1AndMGF1Padding", BC_PROVIDER);
cipher.init(Cipher.ENCRYPT_MODE, certificate.getPublicKey());
byte[] data = message.getBytes(StandardCharsets.UTF_8);
byte[] cipherData = cipher.doFinal(data);
- return Base64Utils.encodeToString(cipherData);
+ return Base64Utils.encodeToString(cipherData);
} catch (Exception e) {
throw new PayException(e);
@@ -304,14 +309,14 @@ public class SignatureProvider {
*
* @return the x 509 wechat certificate info
*/
- public X509WechatCertificateInfo getCertificate(){
+ public X509WechatCertificateInfo getCertificate() {
for (String serial : CERTIFICATE_MAP.keySet()) {
X509Certificate x509Cert = (X509Certificate) CERTIFICATE_MAP.get(serial);
try {
x509Cert.checkValidity();
X509WechatCertificateInfo x509WechatCertificateInfo = new X509WechatCertificateInfo();
- x509WechatCertificateInfo.setWechatPaySerial(serial);
- x509WechatCertificateInfo.setX509Certificate(x509Cert);
+ x509WechatCertificateInfo.setWechatPaySerial(serial);
+ x509WechatCertificateInfo.setX509Certificate(x509Cert);
return x509WechatCertificateInfo;
} catch (Exception e) {
log.warn("the wechat certificate is invalid , {}", e.getMessage());
@@ -348,9 +353,9 @@ public class SignatureProvider {
* @param components the components
* @return string string
*/
- private static String createSign(boolean newLine,String... components) {
+ private static String createSign(boolean newLine, String... components) {
- String suffix = newLine? "\n":"";
+ String suffix = newLine ? "\n" : "";
return Arrays.stream(components)
.collect(Collectors.joining("\n", "", suffix));
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatApiProvider.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatApiProvider.java
index b7c9778..cb9e442 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatApiProvider.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatApiProvider.java
@@ -123,7 +123,7 @@ public class WechatApiProvider {
}
/**
- * 批量转账到零钱.
+ * 批量转账到零钱.
*
* 批量转账到零钱提供商户同时向多个用户微信零钱转账的能力。商户可以使用批量转账到零钱用于费用报销、员工福利发放、合作伙伴货款或服务款项支付等场景，提高转账效率。
*
@@ -193,4 +193,23 @@ public class WechatApiProvider {
return new WechatAllocationApi(wechatV2Client);
}
+ /**
+ * 直连商户微信支付分账，基于V3
+ *
+ * @param tenantId the tenant id
+ * @return the wechat profitsharing api
+ */
+ public WechatProfitsharingApi profitsharingApi(String tenantId) {
+ return new WechatProfitsharingApi(wechatPayClient, tenantId);
+ }
+
+ /**
+ * 服务商微信支付分账，基于V3
+ *
+ * @param tenantId the tenant id
+ * @return the wechat partner profitsharing api
+ */
+ public WechatPartnerProfitsharingApi partnerProfitsharingApi(String tenantId) {
+ return new WechatPartnerProfitsharingApi(wechatPayClient, tenantId);
+ }
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatBatchTransferApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatBatchTransferApi.java
index 3abe668..32da85d 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatBatchTransferApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatBatchTransferApi.java
@@ -17,11 +17,10 @@
package cn.felord.payment.wechat.v3;
+import cn.felord.payment.wechat.enumeration.FundFlowAccountType;
import cn.felord.payment.wechat.enumeration.WeChatServer;
import cn.felord.payment.wechat.enumeration.WechatPayV3Type;
-import cn.felord.payment.wechat.v3.model.batchtransfer.CreateBatchTransferParams;
-import cn.felord.payment.wechat.v3.model.batchtransfer.QueryBatchTransferDetailParams;
-import cn.felord.payment.wechat.v3.model.batchtransfer.QueryBatchTransferParams;
+import cn.felord.payment.wechat.v3.model.batchtransfer.*;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.springframework.core.io.Resource;
import org.springframework.http.HttpHeaders;
@@ -38,6 +37,7 @@ import java.security.cert.X509Certificate;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.Optional;
import java.util.stream.Collectors;
/**
@@ -77,11 +77,11 @@ public class WechatBatchTransferApi extends AbstractApi {
List transferDetailList = createBatchTransferParams.getTransferDetailList();
SignatureProvider signatureProvider = this.client().signatureProvider();
- final X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ final X509Certificate x509Certificate = certificate.getX509Certificate();
List encrypted = transferDetailList.stream()
.peek(transferDetailListItem -> {
String userName = transferDetailListItem.getUserName();
- X509Certificate x509Certificate = certificate.getX509Certificate();
String encryptedUserName = signatureProvider.encryptRequestMessage(userName, x509Certificate);
transferDetailListItem.setUserName(encryptedUserName);
String userIdCard = transferDetailListItem.getUserIdCard();
@@ -140,13 +140,13 @@ public class WechatBatchTransferApi extends AbstractApi {
WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
this.client().withType(WechatPayV3Type.BATCH_TRANSFER_DETAIL_WECHAT, queryBatchTransferDetailParams)
.function((type, params) -> {
- Map queryParams = new HashMap<>();
- queryParams.put("batch_id", params.getBatchIdOrOutBatchNo());
- queryParams.put("detail_id", params.getDetailIdOrOutDetailNo());
+ Map pathParams = new HashMap<>(2);
+ pathParams.put("batch_id", params.getBatchIdOrOutBatchNo());
+ pathParams.put("detail_id", params.getDetailIdOrOutDetailNo());
URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
.build()
- .expand(queryParams)
+ .expand(pathParams)
.toUri();
return Get(uri);
})
@@ -195,13 +195,13 @@ public class WechatBatchTransferApi extends AbstractApi {
WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
this.client().withType(WechatPayV3Type.BATCH_TRANSFER_DETAIL_MCH, queryBatchTransferDetailParams)
.function((type, params) -> {
- Map queryParams = new HashMap<>();
- queryParams.put("batch_id", params.getBatchIdOrOutBatchNo());
- queryParams.put("detail_id", params.getDetailIdOrOutDetailNo());
+ Map pathParams = new HashMap<>(2);
+ pathParams.put("batch_id", params.getBatchIdOrOutBatchNo());
+ pathParams.put("detail_id", params.getDetailIdOrOutDetailNo());
URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
.build()
- .expand(queryParams)
+ .expand(pathParams)
.toUri();
return Get(uri);
})
@@ -256,4 +256,150 @@ public class WechatBatchTransferApi extends AbstractApi {
Assert.hasText(downloadUrl, "download url has no text");
return this.billResource(downloadUrl);
}
+
+ /**
+ * 转账明细电子回单受理API
+ *
+ * 受理转账明细电子回单接口，商户通过该接口可以申请受理转账明细单电子回单服务。
+ *
+ * 返回的下载链接可调用{@link #downloadBillResponse(String, String)}下载文件
+ *
+ * @param params the params
+ * @return the wechat response entity
+ * @since 1.0.11.RELEASE
+ */
+ public WechatResponseEntity transferElectronic(TransferDetailElectronicParams params) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.BATCH_TRANSFER_ELECTRONIC, params)
+ .function((type, transferDetailElectronic) -> {
+ URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, transferDetailElectronic);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询转账明细电子回单受理结果API
+ *
+ * 查询转账明细电子回单受理结果接口，商户通过该接口可以查询电子回单受理进度信息，
+ * 包括电子回单据信息，电子回单文件的hash值，电子回单文件的下载地址等。
+ *
+ * 返回的下载链接可调用{@link this#downloadBillResponse(String, String)}下载文件
+ *
+ * @param params the params
+ * @return the wechat response entity
+ * @since 1.0.11.RELEASE
+ */
+ public WechatResponseEntity queryTransferElectronicResult(TransferDetailElectronicParams params) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.BATCH_TRANSFER_ELECTRONIC_DETAIL, params)
+ .function((type, transferDetailElectronic) -> {
+ MultiValueMap queryParams = new LinkedMultiValueMap<>();
+ queryParams.add("accept_type", transferDetailElectronic.getAcceptType().name());
+ queryParams.add("out_batch_no", transferDetailElectronic.getOutBatchNo());
+ queryParams.add("out_detail_no", transferDetailElectronic.getOutDetailNo());
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+ .queryParams(queryParams)
+ .build()
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询账户实时余额API
+ *
+ * 商户通过此接口可以查询本商户号的账号余额情况。
+ *
+ * @param accountType the account type
+ * @return the wechat response entity
+ * @since 1.0.11.RELEASE
+ */
+ public WechatResponseEntity queryFundBalance(FundFlowAccountType accountType) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.BATCH_TRANSFER_FUND_BALANCE, accountType)
+ .function((type, flowAccountType) -> {
+ URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+ .build()
+ .expand(flowAccountType.name())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询账户日终余额API
+ *
+ * 通过此接口可以查询本商户号指定日期当天24点的账户余额。
+ *
+ * @param queryDayBalanceParams the transfer day balance params
+ * @return the wechat response entity
+ * @since 1.0.11.RELEASE
+ */
+ public WechatResponseEntity queryDayFundBalance(QueryDayBalanceParams queryDayBalanceParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.BATCH_TRANSFER_FUND_DAY_BALANCE, queryDayBalanceParams)
+ .function((type, params) -> {
+ URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+ .queryParam("date", params.getDate().toString())
+ .build()
+ .expand(params.getAccountType().name())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 商户银行来账查询API
+ *
+ * 商户通过本接口查询指定日期内本商户银行来账记录列表。
+ * 列表内包含本商户银行来账相关的业务单号、金额、完成时间等信息，用于查询和核对。
+ *
+ * 注意：
+ *
+ * - 如需检索，请在前端缓存所有银行来账记录数据并自行完成检索功能；
+ * - 调用该接口前，商户需提前开通“来账识别”产品权限；
+ * - 本接口对可查询的商户范围有所规定，仅支持对本商户进行查询；
+ * - 本接口仅提供近90天内的银行来账记录查询，且一次只能查询一天，商户需确保查询记录日期在此范围内；
+ * - 本接口返回的记录字段后续可能会有所扩充，商户需做好接口兼容准备；
+ * - 单商户单接口最大请求频率不超过50TPS。
+ *
+ *
+ * @param queryIncomeRecordParams the transfer day balance params
+ * @return the wechat response entity
+ * @since 1.0.11.RELEASE
+ */
+ public WechatResponseEntity queryIncomeRecords(QueryIncomeRecordParams queryIncomeRecordParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.BATCH_TRANSFER_FUND_INCOME_RECORDS, queryIncomeRecordParams)
+ .function((type, params) -> {
+ MultiValueMap queryParams = new LinkedMultiValueMap<>();
+ queryParams.add("account_type", params.getAccountType().name());
+ queryParams.add("date", params.getDate().toString());
+ queryParams.add("offset", Optional.ofNullable(params.getOffset()).orElse(0).toString());
+ queryParams.add("limit", params.getLimit().toString());
+ URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+ .queryParams(queryParams)
+ .build()
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatDirectPayApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatDirectPayApi.java
index 7467dfe..f3ba6a7 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatDirectPayApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatDirectPayApi.java
@@ -87,7 +87,7 @@ public class WechatDirectPayApi extends AbstractApi {
.toString()
.replaceAll("-", "");
String prepayId = body.get("prepay_id").asText();
- String paySign = signatureProvider.doRequestSign(true,privateKey, appId, timestamp, nonceStr, prepayId);
+ String paySign = signatureProvider.doRequestSign(privateKey, appId, timestamp, nonceStr, prepayId);
String mchId = wechatMetaBean.getV3().getMchId();
body.put("appid", appId);
@@ -136,7 +136,7 @@ public class WechatDirectPayApi extends AbstractApi {
.toString()
.replaceAll("-", "");
String packageStr = "prepay_id=" + body.get("prepay_id").asText();
- String paySign = signatureProvider.doRequestSign(true,privateKey, appId, timestamp, nonceStr, packageStr);
+ String paySign = signatureProvider.doRequestSign(privateKey, appId, timestamp, nonceStr, packageStr);
body.put("appId", appId);
body.put("timeStamp", timestamp);
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatMarketingFavorApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatMarketingFavorApi.java
index 87d63fe..8bba96f 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatMarketingFavorApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatMarketingFavorApi.java
@@ -353,9 +353,9 @@ public class WechatMarketingFavorApi extends AbstractApi {
MultiValueMap queryParams = new LinkedMultiValueMap<>();
queryParams.add("appid", v3.getAppId());
- MultiValueMap pathParams = new LinkedMultiValueMap<>();
- pathParams.add("openid", params.getOpenId());
- pathParams.add("coupon_id", params.getCouponId());
+ Map pathParams = new HashMap<>(2);
+ pathParams.put("openid", params.getOpenId());
+ pathParams.put("coupon_id", params.getCouponId());
URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
.queryParams(queryParams)
.build()
@@ -493,7 +493,7 @@ public class WechatMarketingFavorApi extends AbstractApi {
*
* @param stockId the stock id
* @return the wechat response entity
- * @see AbstractApi#billDownload(String) AbstractApi#billDownload(String)对账单下载api
+ * @see AbstractApi#billCsvDownload(String) AbstractApi#billDownload(String)对账单下载api
*/
public WechatResponseEntity downloadStockUseFlow(String stockId) {
WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
@@ -501,7 +501,7 @@ public class WechatMarketingFavorApi extends AbstractApi {
.function(this::downloadFlowFunction)
.consumer(wechatResponseEntity::convert)
.request();
- String csv = this.billDownload(wechatResponseEntity.getBody().get("url").asText());
+ String csv = this.billCsvDownload(wechatResponseEntity.getBody().get("url").asText());
wechatResponseEntity.getBody().put("csv", csv);
return wechatResponseEntity;
}
@@ -515,7 +515,7 @@ public class WechatMarketingFavorApi extends AbstractApi {
*
* @param stockId the stock id
* @return the wechat response entity
- * @see AbstractApi#billDownload(String) AbstractApi#billDownload(String)对账单下载api
+ * @see AbstractApi#billCsvDownload(String) AbstractApi#billDownload(String)对账单下载api
*/
public WechatResponseEntity downloadStockRefundFlow(String stockId) {
WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
@@ -523,7 +523,7 @@ public class WechatMarketingFavorApi extends AbstractApi {
.function(this::downloadFlowFunction)
.consumer(wechatResponseEntity::convert)
.request();
- String csv = this.billDownload(wechatResponseEntity.getBody().get("url").asText());
+ String csv = this.billCsvDownload(wechatResponseEntity.getBody().get("url").asText());
wechatResponseEntity.getBody().put("csv", csv);
return wechatResponseEntity;
}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerPayApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerPayApi.java
index 908c15b..a25cda6 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerPayApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerPayApi.java
@@ -87,7 +87,7 @@ public class WechatPartnerPayApi extends AbstractApi {
.toString()
.replaceAll("-", "");
String prepayId = body.get("prepay_id").asText();
- String paySign = signatureProvider.doRequestSign(true, privateKey, subAppid, timestamp, nonceStr, prepayId);
+ String paySign = signatureProvider.doRequestSign(privateKey, subAppid, timestamp, nonceStr, prepayId);
body.put("appid", subAppid);
body.put("partnerid", partnerPayParams.getSubMchid());
@@ -136,7 +136,7 @@ public class WechatPartnerPayApi extends AbstractApi {
.toString()
.replaceAll("-", "");
String packageStr = "prepay_id=" + body.get("prepay_id").asText();
- String paySign = signatureProvider.doRequestSign(true, privateKey, subAppid, timestamp, nonceStr, packageStr);
+ String paySign = signatureProvider.doRequestSign(privateKey, subAppid, timestamp, nonceStr, packageStr);
body.put("appId", subAppid);
body.put("timeStamp", timestamp);
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerProfitsharingApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerProfitsharingApi.java
new file mode 100644
index 0000000..3504cf5
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPartnerProfitsharingApi.java
@@ -0,0 +1,318 @@
+package cn.felord.payment.wechat.v3;
+
+import cn.felord.payment.wechat.WechatPayProperties;
+import cn.felord.payment.wechat.enumeration.WeChatServer;
+import cn.felord.payment.wechat.enumeration.WechatPayV3Type;
+import cn.felord.payment.wechat.v3.model.profitsharing.*;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.springframework.http.HttpHeaders;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.util.StringUtils;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.net.URI;
+import java.security.cert.X509Certificate;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+/**
+ * 微信V3服务商分账
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+public class WechatPartnerProfitsharingApi extends AbstractApi {
+
+ /**
+ * Instantiates a new Abstract api.
+ *
+ * @param wechatPayClient the wechat pay client
+ * @param tenantId the tenant id
+ */
+ public WechatPartnerProfitsharingApi(WechatPayClient wechatPayClient, String tenantId) {
+ super(wechatPayClient, tenantId);
+ }
+
+ /**
+ * 请求分账API
+ *
+ * 微信订单支付成功后，商户发起分账请求，将结算后的资金分到分账接收方
+ *
+ * 注意：
+ *
+ * - 对同一笔订单最多能发起20次分账请求，每次请求最多分给50个接收方
+ * - 此接口采用异步处理模式，即在接收到商户请求后，优先受理请求再异步处理，最终的分账结果可以通过查询分账接口获取
+ *
+ *
+ * @param profitSharingOrder the profit sharing order
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity profitsharingOrders(PartnerProfitSharingOrder profitSharingOrder) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS, profitSharingOrder)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ SignatureProvider signatureProvider = this.client().signatureProvider();
+ X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ final X509Certificate x509Certificate = certificate.getX509Certificate();
+ params.setAppid(v3.getAppId());
+ List receivers = params.getReceivers();
+ if (!CollectionUtils.isEmpty(receivers)) {
+ List encrypted = receivers.stream()
+ .peek(receiversItem -> {
+ String name = receiversItem.getName();
+ if (StringUtils.hasText(name)) {
+ String encryptedName = signatureProvider.encryptRequestMessage(name, x509Certificate);
+ receiversItem.setName(encryptedName);
+ }
+ }).collect(Collectors.toList());
+ params.setReceivers(encrypted);
+ }
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ HttpHeaders httpHeaders = new HttpHeaders();
+ httpHeaders.add("Wechatpay-Serial", certificate.getWechatPaySerial());
+ return Post(uri, params, httpHeaders);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询分账结果API
+ *
+ * 发起分账请求后，可调用此接口查询分账结果
+ *
+ * 注意：
+ *
+ * - 发起解冻剩余资金请求后，可调用此接口查询解冻剩余资金的结果
+ *
+ *
+ * @param queryOrderParams the query order params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryProfitsharingOrder(PartnerQueryOrderParams queryOrderParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS_RESULT, queryOrderParams)
+ .function((wechatPayV3Type, params) -> {
+ MultiValueMap queryParams = new LinkedMultiValueMap<>();
+ queryParams.add("transaction_id", params.getTransactionId());
+ Optional.ofNullable(params.getSubMchid())
+ .ifPresent(mchId -> queryParams.add("sub_mchid", params.getSubMchid()));
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .queryParams(queryParams)
+ .build()
+ .expand(params.getOutOrderNo())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 请求分账回退API
+ *
+ * 如果订单已经分账，在退款时，可以先调此接口，将已分账的资金从分账接收方的账户回退给分账方，再发起退款
+ *
+ * 注意：
+ *
+ * - 分账回退以原分账单为依据，支持多次回退，申请回退总金额不能超过原分账单分给该接收方的金额
+ * - 此接口采用同步处理模式，即在接收到商户请求后，会实时返回处理结果
+ * - 对同一笔分账单最多能发起20次分账回退请求
+ * - 退款和分账回退没有耦合，分账回退可以先于退款请求，也可以后于退款请求
+ * - 此功能需要接收方在商户平台-交易中心-分账-分账接收设置下，开启同意分账回退后，才能使用
+ *
+ *
+ * @param returnOrdersParams the return orders params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity returnOrders(PartnerReturnOrdersParams returnOrdersParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RETURN_ORDERS, returnOrdersParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询分账回退结果API
+ *
+ * 商户需要核实回退结果，可调用此接口查询回退结果
+ *
+ * 注意：
+ *
+ * - 如果分账回退接口返回状态为处理中，可调用此接口查询回退结果
+ *
+ *
+ * @param queryReturnOrderParams the query return order params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryReturnOrders(PartnerQueryReturnOrderParams queryReturnOrderParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RETURN_ORDERS_RESULT, queryReturnOrderParams)
+ .function((wechatPayV3Type, params) -> {
+ MultiValueMap queryParams = new LinkedMultiValueMap<>();
+ queryParams.add("out_order_no", params.getOutOrderNo());
+ Optional.ofNullable(params.getSubMchid())
+ .ifPresent(mchId -> queryParams.add("sub_mchid", params.getSubMchid()));
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .queryParams(queryParams)
+ .build()
+ .expand(params.getOutReturnNo())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 解冻剩余资金API
+ *
+ * 不需要进行分账的订单，可直接调用本接口将订单的金额全部解冻给特约商户
+ *
+ * 注意：
+ *
+ * - 调用分账接口后，需要解冻剩余资金时，调用本接口将剩余的分账金额全部解冻给特约商户
+ * - 此接口采用异步处理模式，即在接收到商户请求后，优先受理请求再异步处理，最终的分账结果可以通过查询分账接口获取
+ *
+ *
+ * @param unfreezeParams the unfreeze params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity unfreeze(PartnerUnfreezeParams unfreezeParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS_UNFREEZE, unfreezeParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询剩余待分金额API
+ *
+ * 可调用此接口查询订单剩余待分金额
+ *
+ * @param transactionId the transaction id
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryAmounts(String transactionId) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_AMOUNTS, transactionId)
+ .function((wechatPayV3Type, id) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .expand(id)
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * （服务商）查询剩余待分金额API
+ *
+ * 可调用此接口查询订单剩余待分金额
+ *
+ * @param subMchid the sub mchid
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryMchConfigs(String subMchid) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_MCH_CONFIG, subMchid)
+ .function((wechatPayV3Type, id) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .expand(id)
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 添加分账接收方API
+ *
+ * 商户发起添加分账接收方请求，建立分账接收方列表。后续可通过发起分账请求，将分账方商户结算后的资金，分到该分账接收方
+ *
+ * @param addReceiversParams the add receivers params
+ * @return wechat response entity
+ */
+ public WechatResponseEntity addReceivers(PartnerAddReceiversParams addReceiversParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RECEIVERS_ADD, addReceiversParams)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ SignatureProvider signatureProvider = this.client().signatureProvider();
+ X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ final X509Certificate x509Certificate = certificate.getX509Certificate();
+ params.setAppid(v3.getAppId());
+ String name = params.getName();
+ if (StringUtils.hasText(name)) {
+ String encryptedName = signatureProvider.encryptRequestMessage(name, x509Certificate);
+ params.setName(encryptedName);
+ }
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ HttpHeaders httpHeaders = new HttpHeaders();
+ httpHeaders.add("Wechatpay-Serial", certificate.getWechatPaySerial());
+ return Post(uri, params, httpHeaders);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 删除分账接收方API
+ *
+ * 商户发起删除分账接收方请求。删除后，不支持将分账方商户结算后的资金，分到该分账接收方
+ *
+ * @param delReceiversParams the del receivers params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity deleteReceivers(PartnerDelReceiversParams delReceiversParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RECEIVERS_DELETE, delReceiversParams)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ params.setAppid(v3.getAppId());
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayCallback.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayCallback.java
index f6789a8..604abed 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayCallback.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayCallback.java
@@ -29,6 +29,7 @@ import cn.felord.payment.wechat.v3.model.payscore.PayScoreConsumer;
import cn.felord.payment.wechat.v3.model.payscore.PayScoreUserConfirmConsumeData;
import cn.felord.payment.wechat.v3.model.payscore.PayScoreUserPaidConsumeData;
import cn.felord.payment.wechat.v3.model.payscore.PayScoreUserPermissionConsumeData;
+import cn.felord.payment.wechat.v3.model.profitsharing.ProfitsharingConsumeData;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature;
@@ -39,7 +40,6 @@ import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.Assert;
-import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
@@ -73,8 +73,8 @@ public class WechatPayCallback {
static {
MAPPER.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE)
.setSerializationInclusion(JsonInclude.Include.NON_NULL)
- .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES,false)
- .configure(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT,true)
+ .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
+ .configure(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT, true)
.registerModule(new JavaTimeModule());
}
@@ -92,7 +92,7 @@ public class WechatPayCallback {
/**
- * 微信支付分账回调.
+ * 微信支付分账V2回调.
*
* @param params the params
* @param consumeDataConsumer the consume data consumer
@@ -100,14 +100,11 @@ public class WechatPayCallback {
* @since 1.0.10.RELEASE
*/
@SneakyThrows
- public Map profitSharingCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map profitSharingCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
String data = this.callback(params, EventType.TRANSACTION);
ProfitSharingConsumeData consumeData = MAPPER.readValue(data, ProfitSharingConsumeData.class);
consumeDataConsumer.accept(consumeData);
- Map responseBody = new HashMap<>(2);
- responseBody.put("code", 200);
- responseBody.put("message", "SUCCESS");
- return responseBody;
+ return response();
}
@@ -121,14 +118,11 @@ public class WechatPayCallback {
* @since 1.0.0.RELEASE
*/
@SneakyThrows
- public Map couponCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map couponCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
String data = this.callback(params, EventType.COUPON_USE);
CouponConsumeData consumeData = MAPPER.readValue(data, CouponConsumeData.class);
consumeDataConsumer.accept(consumeData);
- Map responseBody = new HashMap<>(2);
- responseBody.put("code", 200);
- responseBody.put("message", "SUCCESS");
- return responseBody;
+ return response();
}
@@ -143,12 +137,11 @@ public class WechatPayCallback {
* @since 1.0.0.RELEASE
*/
@SneakyThrows
- public Map transactionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map transactionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
String data = this.callback(params, EventType.TRANSACTION);
TransactionConsumeData consumeData = MAPPER.readValue(data, TransactionConsumeData.class);
consumeDataConsumer.accept(consumeData);
- return Collections.singletonMap("code", "SUCCESS");
-
+ return response();
}
/**
@@ -162,12 +155,11 @@ public class WechatPayCallback {
* @since 1.0.0.RELEASE
*/
@SneakyThrows
- public Map combineTransactionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map combineTransactionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
String data = this.callback(params, EventType.TRANSACTION);
CombineTransactionConsumeData consumeData = MAPPER.readValue(data, CombineTransactionConsumeData.class);
consumeDataConsumer.accept(consumeData);
- return Collections.singletonMap("code", "SUCCESS");
-
+ return response();
}
/**
@@ -181,7 +173,7 @@ public class WechatPayCallback {
* @since 1.0.2.RELEASE
*/
@SneakyThrows
- public Map payscoreUserOrderCallback(ResponseSignVerifyParams params, PayScoreConsumer payScoreConsumer) {
+ public Map payscoreUserOrderCallback(ResponseSignVerifyParams params, PayScoreConsumer payScoreConsumer) {
CallbackParams callbackParams = resolve(params);
String eventType = callbackParams.getEventType();
@@ -197,8 +189,7 @@ public class WechatPayCallback {
log.error("wechat pay event type is not matched, callbackParams {}", callbackParams);
throw new PayException(" wechat pay event type is not matched");
}
-
- return Collections.singletonMap("code", "SUCCESS");
+ return response();
}
/**
@@ -213,7 +204,7 @@ public class WechatPayCallback {
* @return the map
*/
@SneakyThrows
- public Map permissionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map permissionCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
CallbackParams callbackParams = resolve(params);
String eventType = callbackParams.getEventType();
boolean closed;
@@ -229,7 +220,7 @@ public class WechatPayCallback {
PayScoreUserPermissionConsumeData consumeData = MAPPER.readValue(data, PayScoreUserPermissionConsumeData.class);
consumeData.setClosed(closed);
consumeDataConsumer.accept(consumeData);
- return Collections.singletonMap("code", "SUCCESS");
+ return response();
}
/**
@@ -265,7 +256,7 @@ public class WechatPayCallback {
log.error("wechat pay event type is not matched, callbackParams {}", callbackParams);
throw new PayException(" wechat pay event type is not matched");
}
- return Collections.singletonMap("code", "SUCCESS");
+ return response();
}
/**
@@ -280,7 +271,7 @@ public class WechatPayCallback {
* @return the map
*/
@SneakyThrows
- public Map busiFavorReceiveCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map busiFavorReceiveCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
CallbackParams callbackParams = resolve(params);
String eventType = callbackParams.getEventType();
@@ -292,7 +283,7 @@ public class WechatPayCallback {
BusiFavorReceiveConsumeData consumeData = MAPPER.readValue(data, BusiFavorReceiveConsumeData.class);
consumeDataConsumer.accept(consumeData);
- return Collections.singletonMap("code", "SUCCESS");
+ return response();
}
/**
@@ -302,10 +293,10 @@ public class WechatPayCallback {
*
* @param params the params
* @param consumeDataConsumer the consume data consumer
- * @return map
+ * @return map map
*/
@SneakyThrows
- public Map refundCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
+ public Map refundCallback(ResponseSignVerifyParams params, Consumer consumeDataConsumer) {
CallbackParams callbackParams = resolve(params);
String eventType = callbackParams.getEventType();
@@ -319,9 +310,23 @@ public class WechatPayCallback {
RefundConsumeData consumeData = MAPPER.readValue(data, RefundConsumeData.class);
consumeDataConsumer.accept(consumeData);
- return Collections.singletonMap("code", "SUCCESS");
+ return response();
}
+ /**
+ * 微信支付分账V3动账通知
+ *
+ * @param params the params
+ * @param profitsharingConsumeDataConsumer the profitsharing consume data consumer
+ * @return map map
+ */
+ @SneakyThrows
+ public Map profitsharingCallback(ResponseSignVerifyParams params, Consumer profitsharingConsumeDataConsumer) {
+ String callback = this.callback(params, EventType.TRANSACTION);
+ ProfitsharingConsumeData consumeData = MAPPER.readValue(callback, ProfitsharingConsumeData.class);
+ profitsharingConsumeDataConsumer.accept(consumeData);
+ return response();
+ }
/**
* Callback.
@@ -373,6 +378,18 @@ public class WechatPayCallback {
return data;
}
+ /**
+ * 回调应答
+ *
+ * @return response
+ */
+ private Map response() {
+ Map responseBody = new HashMap<>(2);
+ responseBody.put("code", "SUCCESS");
+ responseBody.put("message", "SUCCESS");
+ return responseBody;
+ }
+
/**
* 事件类型用于处理回调.
@@ -450,7 +467,7 @@ public class WechatPayCallback {
COUPON_SEND("COUPON.SEND"),
/**
- * 支付成功事件.
+ * 支付成功、分账、分账回退事件.
*
* @since 1.0.0.RELEASE
*/
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayClient.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayClient.java
index b1b9957..fb69c71 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayClient.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayClient.java
@@ -164,7 +164,7 @@ public class WechatPayClient {
public void request() {
RequestEntity requestEntity = this.requestEntityBiFunction.apply(this.wechatPayV3Type, this.model);
WechatRequestEntity wechatRequestEntity = WechatRequestEntity.of(requestEntity, this.responseBodyConsumer);
- this.doExecute(this.header(true,wechatRequestEntity));
+ this.doExecute(this.header(wechatRequestEntity));
}
@@ -176,7 +176,7 @@ public class WechatPayClient {
public String download() {
RequestEntity requestEntity = this.requestEntityBiFunction.apply(this.wechatPayV3Type, this.model);
WechatRequestEntity wechatRequestEntity = WechatRequestEntity.of(requestEntity, this.responseBodyConsumer);
- return this.doDownload(this.header(true,wechatRequestEntity));
+ return this.doDownload(this.header(wechatRequestEntity));
}
/**
@@ -185,10 +185,10 @@ public class WechatPayClient {
* @return the string
* @since 1.0.6.RELEASE
*/
- public ResponseEntity resource() {
+ protected ResponseEntity resource() {
RequestEntity requestEntity = this.requestEntityBiFunction.apply(this.wechatPayV3Type, this.model);
WechatRequestEntity wechatRequestEntity = WechatRequestEntity.of(requestEntity, this.responseBodyConsumer);
- return this.doResource(this.header(false,wechatRequestEntity));
+ return this.doResource(this.header(wechatRequestEntity));
}
@@ -199,7 +199,7 @@ public class WechatPayClient {
* @param requestEntity the request entity
* @return the wechat request entity
*/
- private WechatRequestEntity header(boolean newLine,WechatRequestEntity requestEntity) {
+ private WechatRequestEntity header(WechatRequestEntity requestEntity) {
UriComponents uri = UriComponentsBuilder.fromUri(requestEntity.getUrl()).build();
String canonicalUrl = uri.getPath();
@@ -220,7 +220,7 @@ public class WechatPayClient {
}
String tenantId = Objects.requireNonNull(headers.get("Pay-TenantId")).get(0);
- String authorization = signatureProvider.requestSign(newLine,tenantId, httpMethod.name(), canonicalUrl, body);
+ String authorization = signatureProvider.requestSign(tenantId, httpMethod.name(), canonicalUrl, body);
HttpHeaders httpHeaders = new HttpHeaders();
httpHeaders.addAll(headers);
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayScoreApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayScoreApi.java
index 86068ae..8113088 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayScoreApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayScoreApi.java
@@ -29,6 +29,8 @@ import org.springframework.util.StringUtils;
import org.springframework.web.util.UriComponentsBuilder;
import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
/**
* 微信支付分API.
@@ -63,14 +65,14 @@ public class WechatPayScoreApi extends AbstractApi {
.function((wechatPayV3Type, userServiceStateParams) -> {
WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
- MultiValueMap expandParams = new LinkedMultiValueMap<>();
- expandParams.add("appid", v3.getAppId());
- expandParams.add("service_id", params.getServiceId());
- expandParams.add("openid", params.getOpenId());
+ Map pathParams = new HashMap<>(3);
+ pathParams.put("appid", v3.getAppId());
+ pathParams.put("service_id", params.getServiceId());
+ pathParams.put("openid", params.getOpenId());
URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
.build()
- .expand(expandParams)
+ .expand(pathParams)
.toUri();
return Get(uri);
})
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatProfitsharingApi.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatProfitsharingApi.java
new file mode 100644
index 0000000..3158ae6
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatProfitsharingApi.java
@@ -0,0 +1,285 @@
+package cn.felord.payment.wechat.v3;
+
+import cn.felord.payment.wechat.WechatPayProperties;
+import cn.felord.payment.wechat.enumeration.WeChatServer;
+import cn.felord.payment.wechat.enumeration.WechatPayV3Type;
+import cn.felord.payment.wechat.v3.model.profitsharing.*;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.springframework.http.HttpHeaders;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.net.URI;
+import java.security.cert.X509Certificate;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 微信V3直联商户分账
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+public class WechatProfitsharingApi extends AbstractApi {
+
+ /**
+ * Instantiates a new Abstract api.
+ *
+ * @param wechatPayClient the wechat pay client
+ * @param tenantId the tenant id
+ */
+ public WechatProfitsharingApi(WechatPayClient wechatPayClient, String tenantId) {
+ super(wechatPayClient, tenantId);
+ }
+
+ /**
+ * 请求分账API
+ *
+ * 微信订单支付成功后，商户发起分账请求，将结算后的资金分到分账接收方
+ *
+ * 注意：
+ *
+ * - 对同一笔订单最多能发起20次分账请求，每次请求最多分给50个接收方
+ * - 此接口采用异步处理模式，即在接收到商户请求后，优先受理请求再异步处理，最终的分账结果可以通过查询分账接口获取
+ *
+ *
+ * @param profitSharingOrder the profit sharing order
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity profitsharingOrders(ProfitSharingOrder profitSharingOrder) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS, profitSharingOrder)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ SignatureProvider signatureProvider = this.client().signatureProvider();
+ X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ final X509Certificate x509Certificate = certificate.getX509Certificate();
+ params.setAppid(v3.getAppId());
+ List receivers = params.getReceivers();
+ if (!CollectionUtils.isEmpty(receivers)) {
+ List encrypted = receivers.stream()
+ .peek(receiversItem -> {
+ String name = receiversItem.getName();
+ if (StringUtils.hasText(name)) {
+ String encryptedName = signatureProvider.encryptRequestMessage(name, x509Certificate);
+ receiversItem.setName(encryptedName);
+ }
+ }).collect(Collectors.toList());
+ params.setReceivers(encrypted);
+ }
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ HttpHeaders httpHeaders = new HttpHeaders();
+ httpHeaders.add("Wechatpay-Serial", certificate.getWechatPaySerial());
+ return Post(uri, params, httpHeaders);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询分账结果API
+ *
+ * 发起分账请求后，可调用此接口查询分账结果
+ *
+ * 注意：
+ *
+ * - 发起解冻剩余资金请求后，可调用此接口查询解冻剩余资金的结果
+ *
+ *
+ * @param queryOrderParams the query order params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryProfitsharingOrder(QueryOrderParams queryOrderParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS_RESULT, queryOrderParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .queryParam("transaction_id", params.getTransactionId())
+ .build()
+ .expand(params.getOutOrderNo())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 请求分账回退API
+ *
+ * 如果订单已经分账，在退款时，可以先调此接口，将已分账的资金从分账接收方的账户回退给分账方，再发起退款
+ *
+ * 注意：
+ *
+ * - 分账回退以原分账单为依据，支持多次回退，申请回退总金额不能超过原分账单分给该接收方的金额
+ * - 此接口采用同步处理模式，即在接收到商户请求后，会实时返回处理结果
+ * - 对同一笔分账单最多能发起20次分账回退请求
+ * - 退款和分账回退没有耦合，分账回退可以先于退款请求，也可以后于退款请求
+ * - 此功能需要接收方在商户平台-交易中心-分账-分账接收设置下，开启同意分账回退后，才能使用
+ *
+ *
+ * @param returnOrdersParams the return orders params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity returnOrders(ReturnOrdersParams returnOrdersParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RETURN_ORDERS, returnOrdersParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询分账回退结果API
+ *
+ * 商户需要核实回退结果，可调用此接口查询回退结果
+ *
+ * 注意：
+ *
+ * - 如果分账回退接口返回状态为处理中，可调用此接口查询回退结果
+ *
+ *
+ * @param queryReturnOrderParams the query return order params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryReturnOrders(QueryReturnOrderParams queryReturnOrderParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RETURN_ORDERS_RESULT, queryReturnOrderParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .queryParam("out_order_no", params.getOutOrderNo())
+ .build()
+ .expand(params.getOutReturnNo())
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 解冻剩余资金API
+ *
+ * 不需要进行分账的订单，可直接调用本接口将订单的金额全部解冻给特约商户
+ *
+ * 注意：
+ *
+ * - 调用分账接口后，需要解冻剩余资金时，调用本接口将剩余的分账金额全部解冻给特约商户
+ * - 此接口采用异步处理模式，即在接收到商户请求后，优先受理请求再异步处理，最终的分账结果可以通过查询分账接口获取
+ *
+ *
+ * @param unfreezeParams the unfreeze params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity unfreeze(UnfreezeParams unfreezeParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_ORDERS_UNFREEZE, unfreezeParams)
+ .function((wechatPayV3Type, params) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 查询剩余待分金额API
+ *
+ * 可调用此接口查询订单剩余待分金额
+ *
+ * @param transactionId the transaction id
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity queryAmounts(String transactionId) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_AMOUNTS, transactionId)
+ .function((wechatPayV3Type, id) -> {
+
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .expand(id)
+ .toUri();
+ return Get(uri);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 添加分账接收方API
+ *
+ * 商户发起添加分账接收方请求，建立分账接收方列表。后续可通过发起分账请求，将分账方商户结算后的资金，分到该分账接收方
+ *
+ * @param addReceiversParams the add receivers params
+ * @return wechat response entity
+ */
+ public WechatResponseEntity addReceivers(AddReceiversParams addReceiversParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RECEIVERS_ADD, addReceiversParams)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ SignatureProvider signatureProvider = this.client().signatureProvider();
+ X509WechatCertificateInfo certificate = signatureProvider.getCertificate();
+ final X509Certificate x509Certificate = certificate.getX509Certificate();
+ params.setAppid(v3.getAppId());
+ String name = params.getName();
+ if (StringUtils.hasText(name)) {
+ String encryptedName = signatureProvider.encryptRequestMessage(name, x509Certificate);
+ params.setName(encryptedName);
+ }
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ HttpHeaders httpHeaders = new HttpHeaders();
+ httpHeaders.add("Wechatpay-Serial", certificate.getWechatPaySerial());
+ return Post(uri, params, httpHeaders);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+
+ /**
+ * 删除分账接收方API
+ *
+ * 商户发起删除分账接收方请求。删除后，不支持将分账方商户结算后的资金，分到该分账接收方
+ *
+ * @param delReceiversParams the del receivers params
+ * @return the wechat response entity
+ */
+ public WechatResponseEntity deleteReceivers(DelReceiversParams delReceiversParams) {
+ WechatResponseEntity wechatResponseEntity = new WechatResponseEntity<>();
+ this.client().withType(WechatPayV3Type.PROFITSHARING_RECEIVERS_DELETE, delReceiversParams)
+ .function((wechatPayV3Type, params) -> {
+ WechatPayProperties.V3 v3 = this.wechatMetaBean().getV3();
+ params.setAppid(v3.getAppId());
+ URI uri = UriComponentsBuilder.fromHttpUrl(wechatPayV3Type.uri(WeChatServer.CHINA))
+ .build()
+ .toUri();
+ return Post(uri, params);
+ })
+ .consumer(wechatResponseEntity::convert)
+ .request();
+ return wechatResponseEntity;
+ }
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/RefundParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/RefundParams.java
index 5adb83d..25e31d1 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/RefundParams.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/RefundParams.java
@@ -75,6 +75,12 @@ public class RefundParams {
*/
@Data
public static class RefundAmount {
+ /**
+ * 退款出资账户及金额
+ *
+ * @since 1.0.11.RELEASE
+ */
+ private List form;
/**
* 原订单金额，币种的最小单位，只能为整数，不能超过原订单支付金额。
*/
@@ -89,4 +95,43 @@ public class RefundParams {
private Integer refund;
}
+ /**
+ * 退款出资账户及金额
+ *
+ * 退款需要从指定账户出资时，传递此参数指定出资金额（币种的最小单位，只能为整数）。
+ *
+ * 同时指定多个账户出资退款的使用场景需要满足以下条件：
+ *
+ *
+ * - 未开通退款支出分离产品功能；
+ * - 订单属于分账订单，且分账处于待分账或分账中状态。
+ *
+ *
+ * 参数传递需要满足条件：
+ *
+ *
+ * - 基本账户可用余额出资金额与基本账户不可用余额出资金额之和等于退款金额；
+ * - 账户类型不能重复。
+ *
+ *
+ * 上述任一条件不满足将返回错误
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+ @Data
+ public static class RefundForm {
+ /**
+ * 出资账户类型
+ *
+ * {@code AVAILABLE} 可用余额
+ * {@code UNAVAILABLE} 不可用余额
+ */
+ private String account;
+ /**
+ * 对应账户出资金额
+ */
+ private String amount;
+
+ }
}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryDayBalanceParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryDayBalanceParams.java
new file mode 100644
index 0000000..c816806
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryDayBalanceParams.java
@@ -0,0 +1,25 @@
+package cn.felord.payment.wechat.v3.model.batchtransfer;
+
+import cn.felord.payment.wechat.enumeration.FundFlowAccountType;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * 查询账户日终余额API 请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class QueryDayBalanceParams {
+ /**
+ * 账户类型，必填
+ * @see FundFlowAccountType
+ */
+ private FundFlowAccountType accountType;
+ /**
+ * 日期，必填
+ */
+ private LocalDate date;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryIncomeRecordParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryIncomeRecordParams.java
new file mode 100644
index 0000000..1ffad1e
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/QueryIncomeRecordParams.java
@@ -0,0 +1,37 @@
+package cn.felord.payment.wechat.v3.model.batchtransfer;
+
+import cn.felord.payment.wechat.enumeration.FundFlowAccountType;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * 商户银行来账查询API 请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class QueryIncomeRecordParams {
+ /**
+ * 账户类型，必填
+ * @see FundFlowAccountType
+ */
+ private FundFlowAccountType accountType;
+ /**
+ * 日期，必填
+ */
+ private LocalDate date;
+ /**
+ * 本次查询偏移量，选填
+ *
+ * 表示该次请求资源的起始位置，从0开始计数。调用方选填，默认为0。offset为20，limit为100时，查询第20-119条数据
+ */
+ private Integer offset;
+ /**
+ * 本次请求最大查询条数，必填
+ *
+ * 非0非负的整数，该次请求可返回的最大资源条数，最大支持100条。
+ */
+ private Integer limit;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/TransferDetailElectronicParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/TransferDetailElectronicParams.java
new file mode 100644
index 0000000..79e1da6
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/batchtransfer/TransferDetailElectronicParams.java
@@ -0,0 +1,36 @@
+package cn.felord.payment.wechat.v3.model.batchtransfer;
+
+import cn.felord.payment.wechat.enumeration.TransferAcceptType;
+import lombok.Data;
+
+/**
+ * 转账明细电子回单受理API请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class TransferDetailElectronicParams {
+ /**
+ * 电子回单受理类型，必填。
+ *
+ * @see TransferAcceptType
+ */
+ private TransferAcceptType acceptType;
+ /**
+ * 商家转账批次单号，选填。
+ *
+ * 需要电子回单的批量转账明细单所在的转账批次单号，该单号为商户申请转账时生成的商户单号。
+ * 受理类型为{@code BATCH_TRANSFER}时该单号必填，否则该单号留空。
+ */
+ private String outBatchNo;
+ /**
+ * 商家转账明细单号，必填。
+ *
+ *
+ * - 受理类型为{@code BATCH_TRANSFER}时填写商家批量转账明细单号。
+ * - 受理类型为{@code TRANSFER_TO_POCKET}或{@code TRANSFER_TO_BANK}时填写商家转账单号。
+ *
+ */
+ private String outDetailNo;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/combine/CombineTransactionConsumeData.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/combine/CombineTransactionConsumeData.java
index 38682ce..279c2f5 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/combine/CombineTransactionConsumeData.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/combine/CombineTransactionConsumeData.java
@@ -19,6 +19,7 @@ package cn.felord.payment.wechat.v3.model.combine;
import cn.felord.payment.wechat.enumeration.TradeState;
import cn.felord.payment.wechat.enumeration.TradeType;
+import cn.felord.payment.wechat.v3.model.PromotionDetail;
import cn.felord.payment.wechat.v3.model.SceneInfo;
import lombok.Data;
@@ -125,6 +126,13 @@ public class CombineTransactionConsumeData {
*/
private String transactionId;
+ /**
+ * 优惠功能，子单有核销优惠券时有返回
+ *
+ * @since 1.0.11.RELEASE
+ */
+ private List promotionDetail;
+
}
/**
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/payscore/CompleteServiceOrderParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/payscore/CompleteServiceOrderParams.java
index b37d697..876bfc3 100644
--- a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/payscore/CompleteServiceOrderParams.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/payscore/CompleteServiceOrderParams.java
@@ -78,7 +78,7 @@ public class CompleteServiceOrderParams {
* false：不分账，默认：false
* true：分账。
*/
- private Boolean profitSharing = Boolean.TRUE;
+ private Boolean profitSharing = Boolean.FALSE;
/**
* 订单优惠标记，选填
*
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/AddReceiversParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/AddReceiversParams.java
new file mode 100644
index 0000000..14f3a67
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/AddReceiversParams.java
@@ -0,0 +1,92 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.enumeration.ReceiverType;
+import lombok.Data;
+
+/**
+ * 直连商户-添加分账接收方API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class AddReceiversParams {
+ /**
+ * 应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 分账接收方类型，必填
+ */
+ private ReceiverType type;
+ /**
+ * 分账接收方帐号，必填
+ */
+ private String account;
+ /**
+ * 分账个人接收方姓名，选填
+ *
+ * 分账接收方类型是{@code MERCHANT_ID}时，是商户全称（必传），当商户是小微商户或个体户时，是开户人姓名 分账接收方类型是{@code PERSONAL_OPENID}时，是个人姓名（选传，传则校验）
+ *
+ * - 分账接收方类型是{@code PERSONAL_OPENID}，是个人姓名的密文（选传，传则校验） 此字段的加密方法详见：敏感信息加密说明
+ * - 使用微信支付平台证书中的公钥
+ * - 使用RSAES-OAEP算法进行加密
+ * - 将请求中HTTP头部的Wechatpay-Serial设置为证书序列号
+ *
+ */
+ private String name;
+ /**
+ * 与分账方的关系类型，必填
+ */
+ private RelationType relationType;
+ /**
+ * 自定义的分账关系，选填
+ */
+ private String customRelation;
+
+ /**
+ * 子商户与接收方的关系
+ */
+ public enum RelationType {
+ /**
+ * 门店.
+ */
+ STORE,
+ /**
+ * 员工.
+ */
+ STAFF,
+ /**
+ * 店主.
+ */
+ STORE_OWNER,
+ /**
+ * 合作伙伴.
+ */
+ PARTNER,
+ /**
+ * 总部.
+ */
+ HEADQUARTER,
+ /**
+ * 品牌方.
+ */
+ BRAND,
+ /**
+ * 分销商.
+ */
+ DISTRIBUTOR,
+ /**
+ * 用户.
+ */
+ USER,
+ /**
+ * 供应商.
+ */
+ SUPPLIER,
+ /**
+ * 自定义.
+ */
+ CUSTOM
+ }
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/DelReceiversParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/DelReceiversParams.java
new file mode 100644
index 0000000..a08cc45
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/DelReceiversParams.java
@@ -0,0 +1,26 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.enumeration.ReceiverType;
+import lombok.Data;
+
+/**
+ * 直连商户-删除分账接收方API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class DelReceiversParams {
+ /**
+ * 应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 分账接收方类型，必填
+ */
+ private ReceiverType type;
+ /**
+ * 分账接收方帐号，必填
+ */
+ private String account;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerAddReceiversParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerAddReceiversParams.java
new file mode 100644
index 0000000..25e04d4
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerAddReceiversParams.java
@@ -0,0 +1,102 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.enumeration.ReceiverType;
+import lombok.Data;
+
+/**
+ * 服务商-添加分账接收方API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerAddReceiversParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 子商户应用ID，选填
+ *
+ * 分账接收方类型包含{@code PERSONAL_SUB_OPENID}时必填
+ */
+ private String subAppid;
+ /**
+ * 分账接收方类型，必填
+ */
+ private ReceiverType type;
+ /**
+ * 分账接收方帐号，必填
+ */
+ private String account;
+ /**
+ * 分账个人接收方姓名，选填
+ *
+ * 分账接收方类型是{@code MERCHANT_ID}时，是商户全称（必传），当商户是小微商户或个体户时，是开户人姓名 分账接收方类型是{@code PERSONAL_OPENID}时，是个人姓名（选传，传则校验）
+ *
+ * - 分账接收方类型是{@code PERSONAL_OPENID}，是个人姓名的密文（选传，传则校验） 此字段的加密方法详见：敏感信息加密说明
+ * - 使用微信支付平台证书中的公钥
+ * - 使用RSAES-OAEP算法进行加密
+ * - 将请求中HTTP头部的Wechatpay-Serial设置为证书序列号
+ *
+ */
+ private String name;
+ /**
+ * 与分账方的关系类型，必填
+ */
+ private RelationType relationType;
+ /**
+ * 自定义的分账关系，选填
+ */
+ private String customRelation;
+
+ /**
+ * 子商户与接收方的关系
+ */
+ public enum RelationType {
+ /**
+ * 门店.
+ */
+ STORE,
+ /**
+ * 员工.
+ */
+ STAFF,
+ /**
+ * 店主.
+ */
+ STORE_OWNER,
+ /**
+ * 合作伙伴.
+ */
+ PARTNER,
+ /**
+ * 总部.
+ */
+ HEADQUARTER,
+ /**
+ * 品牌方.
+ */
+ BRAND,
+ /**
+ * 分销商.
+ */
+ DISTRIBUTOR,
+ /**
+ * 用户.
+ */
+ USER,
+ /**
+ * 供应商.
+ */
+ SUPPLIER,
+ /**
+ * 自定义.
+ */
+ CUSTOM
+ }
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerDelReceiversParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerDelReceiversParams.java
new file mode 100644
index 0000000..cd66d4b
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerDelReceiversParams.java
@@ -0,0 +1,36 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.enumeration.ReceiverType;
+import lombok.Data;
+
+/**
+ * 服务商-删除分账接收方API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerDelReceiversParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 子商户应用ID，选填
+ *
+ * 分账接收方类型包含{@code PERSONAL_SUB_OPENID}时必填
+ */
+ private String subAppid;
+ /**
+ * 分账接收方类型，必填
+ */
+ private ReceiverType type;
+ /**
+ * 分账接收方帐号，必填
+ */
+ private String account;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitSharingOrder.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitSharingOrder.java
new file mode 100644
index 0000000..7407529
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitSharingOrder.java
@@ -0,0 +1,55 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 服务商请求分账API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerProfitSharingOrder {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 服务商应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 子商户应用ID，选填
+ *
+ * 分账接收方类型包含{@code PERSONAL_SUB_OPENID}时必填
+ */
+ private String subAppid;
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+ /**
+ * 商户分账单号，必填
+ *
+ * 商户系统内部的分账单号，在商户系统内部唯一，同一分账单号多次请求等同一次。
+ * 只能是数字、大小写字母_-|*@
+ */
+ private String outOrderNo;
+ /**
+ * 分账接收方列表，选填
+ *
+ * 可以设置出资商户作为分账接受方，最多可有50个分账接收方
+ */
+ private List receivers;
+ /**
+ * 是否解冻剩余未分资金，必填
+ *
+ *
+ * - 如果为{@code true}，该笔订单剩余未分账的金额会解冻回分账方商户；
+ * - 如果为{@code false}，该笔订单剩余未分账的金额不会解冻回分账方商户，可以对该笔订单再次进行分账。
+ *
+ */
+ private Boolean unfreezeUnsplit;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitsharingConsumeData.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitsharingConsumeData.java
new file mode 100644
index 0000000..6c4b67d
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerProfitsharingConsumeData.java
@@ -0,0 +1,84 @@
+/*
+ *
+ * Copyright 2019-2020 felord.cn
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ * Website:
+ * https://felord.cn
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.v2.model.allocation.Receiver;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 服务商-微信支付分账动账通知参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerProfitsharingConsumeData {
+
+ /**
+ * 服务商商户号.
+ *
+ * 服务商模式分账发起商户
+ */
+ private String mchid;
+ /**
+ * 子商户号
+ *
+ * 服务商模式分账出资商户
+ */
+ private String subMchid;
+
+ /**
+ * 微信订单号.
+ *
+ * 微信支付订单号
+ */
+ private String transactionId;
+
+ /**
+ * 微信分账/回退单号.
+ */
+ private String orderId;
+
+ /**
+ * 商户分账/回退单号.
+ *
+ * 分账方系统内部的分账/回退单号
+ */
+ private String outOrderNo;
+
+ /**
+ * 分账接收方.
+ *
+ * 分账接收方对象
+ */
+ private List receivers;
+
+ /**
+ * 成功时间.
+ *
+ * Rfc3339标准
+ */
+ @JsonFormat(pattern = "yyyy-MM-dd'T'HH:mm:ssXXX", timezone = "GMT+8")
+ private LocalDateTime successTime;
+
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryOrderParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryOrderParams.java
new file mode 100644
index 0000000..fa12dc9
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryOrderParams.java
@@ -0,0 +1,25 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 服务商-查询分账结果API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerQueryOrderParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryReturnOrderParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryReturnOrderParams.java
new file mode 100644
index 0000000..3f6ce01
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerQueryReturnOrderParams.java
@@ -0,0 +1,25 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 服务商-查询分账回退结果API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerQueryReturnOrderParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 商户回退单号，必填
+ */
+ private String outReturnNo;
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerReturnOrdersParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerReturnOrdersParams.java
new file mode 100644
index 0000000..65cf588
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerReturnOrdersParams.java
@@ -0,0 +1,45 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 服务商-请求分账回退API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerReturnOrdersParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 微信分账单号，同{@link #outOrderNo} 二选一
+ */
+ private String orderId;
+ /**
+ * 商户分账单号，同{@link #orderId} 二选一
+ */
+ private String outOrderNo;
+ /**
+ * 商户回退单号，必填
+ */
+ private String outReturnNo;
+ /**
+ * 回退商户号，必填
+ *
+ * 分账回退的出资商户，只能对原分账请求中成功分给商户接收方进行回退
+ */
+ private String returnMchid;
+ /**
+ * 回退金额，必填
+ *
+ * 需要从分账接收方回退的金额，单位为分，只能为整数，不能超过原始分账单分出给该接收方的金额
+ */
+ private Integer amount;
+ /**
+ * 回退描述，必填
+ */
+ private String description;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerUnfreezeParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerUnfreezeParams.java
new file mode 100644
index 0000000..0b3f192
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/PartnerUnfreezeParams.java
@@ -0,0 +1,29 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 服务商-解冻剩余资金API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class PartnerUnfreezeParams {
+ /**
+ * 子商户号，选填
+ */
+ private String subMchid;
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+ /**
+ * 分账描述，必填
+ */
+ private String description;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitSharingOrder.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitSharingOrder.java
new file mode 100644
index 0000000..b58174a
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitSharingOrder.java
@@ -0,0 +1,45 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 直连商户-请求分账API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class ProfitSharingOrder {
+ /**
+ * 应用ID，自动注入
+ */
+ private String appid;
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+ /**
+ * 商户分账单号，必填
+ *
+ * 商户系统内部的分账单号，在商户系统内部唯一，同一分账单号多次请求等同一次。
+ * 只能是数字、大小写字母_-|*@
+ */
+ private String outOrderNo;
+ /**
+ * 分账接收方列表，选填
+ *
+ * 可以设置出资商户作为分账接受方，最多可有50个分账接收方
+ */
+ private List receivers;
+ /**
+ * 是否解冻剩余未分资金，必填
+ *
+ *
+ * - 如果为{@code true}，该笔订单剩余未分账的金额会解冻回分账方商户；
+ * - 如果为{@code false}，该笔订单剩余未分账的金额不会解冻回分账方商户，可以对该笔订单再次进行分账。
+ *
+ */
+ private Boolean unfreezeUnsplit;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitsharingConsumeData.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitsharingConsumeData.java
new file mode 100644
index 0000000..f02951c
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ProfitsharingConsumeData.java
@@ -0,0 +1,78 @@
+/*
+ *
+ * Copyright 2019-2020 felord.cn
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ * Website:
+ * https://felord.cn
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.v2.model.allocation.Receiver;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 直连商户-微信支付分账动账通知参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class ProfitsharingConsumeData {
+
+ /**
+ * 直连商户号.
+ *
+ * 直连模式分账发起和出资商户
+ */
+ private String mchid;
+
+ /**
+ * 微信订单号.
+ *
+ * 微信支付订单号
+ */
+ private String transactionId;
+
+ /**
+ * 微信分账/回退单号.
+ */
+ private String orderId;
+
+ /**
+ * 商户分账/回退单号.
+ *
+ * 分账方系统内部的分账/回退单号
+ */
+ private String outOrderNo;
+
+ /**
+ * 分账接收方.
+ *
+ * 分账接收方对象
+ */
+ private List receivers;
+
+ /**
+ * 成功时间.
+ *
+ * Rfc3339标准
+ */
+ @JsonFormat(pattern = "yyyy-MM-dd'T'HH:mm:ssXXX", timezone = "GMT+8")
+ private LocalDateTime successTime;
+
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryOrderParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryOrderParams.java
new file mode 100644
index 0000000..9778454
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryOrderParams.java
@@ -0,0 +1,21 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 直连商户-查询分账结果API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class QueryOrderParams {
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryReturnOrderParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryReturnOrderParams.java
new file mode 100644
index 0000000..fd5420c
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/QueryReturnOrderParams.java
@@ -0,0 +1,21 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 直连商户-查询分账回退结果API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class QueryReturnOrderParams {
+ /**
+ * 商户回退单号，必填
+ */
+ private String outReturnNo;
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/Receiver.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/Receiver.java
new file mode 100644
index 0000000..3e9432b
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/Receiver.java
@@ -0,0 +1,44 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import cn.felord.payment.wechat.enumeration.ReceiverType;
+import lombok.Data;
+
+/**
+ * 分账接收方信息
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class Receiver {
+ /**
+ * 分账接收方类型，必填
+ */
+ private ReceiverType type;
+ /**
+ * 分账接收方帐号，必填
+ */
+ private String account;
+ /**
+ * 分账个人接收方姓名，选填
+ *
+ * 在接收方类型为个人的时可选填，若有值，会检查与 name 是否实名匹配，不匹配会拒绝分账请求
+ *
+ * - 分账接收方类型是{@code PERSONAL_OPENID}，是个人姓名的密文（选传，传则校验） 此字段的加密方法详见：敏感信息加密说明
+ * - 使用微信支付平台证书中的公钥
+ * - 使用RSAES-OAEP算法进行加密
+ * - 将请求中HTTP头部的Wechatpay-Serial设置为证书序列号
+ *
+ */
+ private String name;
+ /**
+ * 分账金额，必填
+ *
+ * 单位为分，只能为整数，不能超过原订单支付金额及最大分账比例金额
+ */
+ private Integer amount;
+ /**
+ * 分账的原因描述，必填。分账账单中需要体现
+ */
+ private String description;
+}
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ReturnOrdersParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ReturnOrdersParams.java
new file mode 100644
index 0000000..23e375b
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/ReturnOrdersParams.java
@@ -0,0 +1,41 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 直连商户-请求分账回退API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class ReturnOrdersParams {
+ /**
+ * 微信分账单号，同{@link #outOrderNo} 二选一
+ */
+ private String orderId;
+ /**
+ * 商户分账单号，同{@link #orderId} 二选一
+ */
+ private String outOrderNo;
+ /**
+ * 商户回退单号，必填
+ */
+ private String outReturnNo;
+ /**
+ * 回退商户号，必填
+ *
+ * 分账回退的出资商户，只能对原分账请求中成功分给商户接收方进行回退
+ */
+ private String returnMchid;
+ /**
+ * 回退金额，必填
+ *
+ * 需要从分账接收方回退的金额，单位为分，只能为整数，不能超过原始分账单分出给该接收方的金额
+ */
+ private Integer amount;
+ /**
+ * 回退描述，必填
+ */
+ private String description;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/UnfreezeParams.java b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/UnfreezeParams.java
new file mode 100644
index 0000000..a2d3ed2
--- /dev/null
+++ b/payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/model/profitsharing/UnfreezeParams.java
@@ -0,0 +1,25 @@
+package cn.felord.payment.wechat.v3.model.profitsharing;
+
+import lombok.Data;
+
+/**
+ * 直连商户-解冻剩余资金API-请求参数
+ *
+ * @author felord.cn
+ * @since 1.0.11.RELEASE
+ */
+@Data
+public class UnfreezeParams {
+ /**
+ * 微信订单号，必填
+ */
+ private String transactionId;
+ /**
+ * 商户分账单号，必填
+ */
+ private String outOrderNo;
+ /**
+ * 分账描述，必填
+ */
+ private String description;
+}
\ No newline at end of file
diff --git a/payment-spring-boot-starter/pom.xml b/payment-spring-boot-starter/pom.xml
index dd4975d..6e742a5 100644
--- a/payment-spring-boot-starter/pom.xml
+++ b/payment-spring-boot-starter/pom.xml
@@ -5,11 +5,11 @@
cn.felord
payment-spring-boot
- 1.0.10.RELEASE
+ 1.0.11.RELEASE
payment-spring-boot-starter
- 1.0.10.RELEASE
+ 1.0.11.RELEASE
jar
4.0.0
diff --git a/pom.xml b/pom.xml
index ffc78bd..f827c72 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
cn.felord
payment-spring-boot
- 1.0.10.RELEASE
+ 1.0.11.RELEASE
pom
4.0.0