new:分账查询、退款通知

This commit is contained in:
曾浩 2020-09-22 21:05:51 +08:00
parent 3b4bb74ce7
commit 58ac339beb
6 changed files with 548 additions and 1 deletions

View File

@ -0,0 +1,54 @@
package com.github.binarywang.wxpay.bean.ecommerce;
import com.google.gson.annotations.SerializedName;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@NoArgsConstructor
public class ProfitSharingQueryRequest implements Serializable {
/**
* <pre>
* 字段名二级商户号
* 变量名sub_mchid
* 是否必填
* 类型string32
* 描述
* 分账出资的电商平台二级商户填写微信支付分配的商户号
* 示例值1900000109
* </pre>
*/
@SerializedName(value = "sub_mchid")
private String subMchid;
/**
* <pre>
* 字段名微信订单号
* 变量名transaction_id
* 是否必填
* 类型string32
* 描述
* 微信支付订单号
* 示例值 4208450740201411110007820472
* </pre>
*/
@SerializedName(value = "transaction_id")
private String transactionId;
/**
* <pre>
* 字段名商户分账单号
* 变量名out_order_no
* 是否必填
* 类型string64
* 描述
* 商户系统内部的分账单号在商户系统内部唯一单次分账多次分账完结分账应使用不同的商户分账单号同一分账单号多次请求等同一次
* 示例值P20150806125346
* </pre>
*/
@SerializedName(value = "out_order_no")
private String outOrderNo;
}

View File

@ -5,6 +5,7 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.List;
/**
* 请求分账 结果响应
@ -72,4 +73,209 @@ public class ProfitSharingResult implements Serializable {
@SerializedName(value = "order_id")
private String orderId;
/**
* <pre>
* 字段名分账单状态
* 变量名status
* 是否必填
* 类型string (64)
* 描述
* 分账单状态枚举值
* ACCEPTED受理成功
* PROCESSING处理中
* FINISHED分账成功
* CLOSED处理失败已关单
* 示例值FINISHED
* </pre>
*/
@SerializedName(value = "status")
private String status;
/**
* <pre>
* 字段名分账接收方列表
* 变量名receivers
* 是否必填
* 类型array
* 描述
* 分账接收方列表当查询分账完结的执行结果时不返回该字段
* </pre>
*/
@SerializedName(value = "receivers")
private List<Receiver> receivers;
/**
* <pre>
* 字段名关单原因
* 变量名close_reason
* 是否必填
* 类型string (32)
* 描述
* 关单原因描述当分账单状态status为CLOSED处理失败已关单返回该字段
* 枚举值
* NO_AUTH分账授权已解除
* 示例值NO_AUTH
* </pre>
*/
@SerializedName(value = "close_reason")
private String closeReason;
/**
* <pre>
* 字段名分账完结金额
* 变量名finish_amount
* 是否必填
* 类型int
* 描述
* 分账完结的分账金额单位为分 仅当查询分账完结的执行结果时存在本字段
* 示例值100
* </pre>
*/
@SerializedName(value = "finish_amount")
private Integer finishAmount;
/**
* <pre>
* 字段名分账完结描述
* 变量名finish_description
* 是否必填
* 类型string (80)
* 描述
* 分账完结的原因描述仅当查询分账完结的执行结果时存在本字段
* 示例值分账完结
* </pre>
*/
@SerializedName(value = "finish_description")
private String finishDescription;
@Data
@NoArgsConstructor
public static class Receiver implements Serializable {
/**
* <pre>
* 字段名分账接收商户号
* 变量名receiver_mchid
* 是否必填
* 类型string (32)
* 描述
* 填写微信支付分配的商户号仅支持通过添加分账接收方接口添加的接收方电商平台商户已默认添加到分账接收方无需重复添加
* 示例值1900000109
* </pre>
*/
@SerializedName(value = "receiver_mchid")
private String receiverMchid;
/**
* <pre>
* 字段名分账金额
* 变量名amount
* 是否必填
* 类型int
* 描述
* 分账金额单位为分只能为整数不能超过原订单支付金额及最大分账比例金额
* 示例值 4208450740201411110007820472
* </pre>
*/
@SerializedName(value = "amount")
private Integer amount;
/**
* <pre>
* 字段名分账描述
* 变量名description
* 是否必填
* 类型string (80)
* 描述
* 分账的原因描述分账账单中需要体现
* 示例值分帐1900000110
* </pre>
*/
@SerializedName(value = "description")
private String description;
/**
* <pre>
* 字段名分账结果
* 变量名result
* 是否必填
* 类型string (32)
* 描述
* 分账结果枚举值
* PENDING待分账
* SUCCESS分账成功
* ADJUST分账失败待调账
* RETURNED已转回分账方
* CLOSED已关闭
* 示例值SUCCESS
* </pre>
*/
@SerializedName(value = "result")
private String result;
/**
* <pre>
* 字段名完成时间
* 变量名finish_time
* 是否必填
* 类型string (64)
* 描述
* 分账完成时间遵循rfc3339标准格式格式为YYYY-MM-DDTHH:mm:ss.sss+TIMEZONEYYYY-MM-DD表示年月日
* T出现在字符串中表示time元素的开头HH:mm:ss.sss表示时分秒毫秒TIMEZONE表示时区
* +08:00表示东八区时间领先UTC 8小时即北京时间例如2015-05-20T13:29:35.120+08:00表示北京时间2015年5月20日 13点29分35秒
* 示例值 2015-05-20T13:29:35.120+08:00
* </pre>
*/
@SerializedName(value = "finish_time")
private String finishTime;
/**
* <pre>
* 字段名分账失败原因
* 变量名fail_reason
* 是否必填
* 类型string (32)
* 描述
* 分账失败原因当分账结果result为RETURNED已转回分账方或CLOSED已关闭返回该字段
* 枚举值
* ACCOUNT_ABNORMAL分账接收账户异常
* NO_RELATION分账关系已解除
* RECEIVER_HIGH_RISK高风险接收方
* 示例值NO_RELATION
* </pre>
*/
@SerializedName(value = "fail_reason")
private String failReason;
/**
* <pre>
* 字段名分账接收方类型
* 变量名type
* 是否必填
* 类型string (32)
* 描述
* 分账接收方类型枚举值
* MERCHANT_ID商户
* PERSONAL_OPENID个人
* 示例值MERCHANT_ID
* </pre>
*/
@SerializedName(value = "type")
private String type;
/**
* <pre>
* 字段名分账接收方类型
* 变量名receiver_account
* 是否必填
* 类型string (64)
* 描述
* 分账接收方账号
* 类型是MERCHANT_ID时是商户ID
* 类型是PERSONAL_OPENID时是个人openid
* 示例值1900000109
* </pre>
*/
@SerializedName(value = "receiver_account")
private String receiverAccount;
}
}

View File

@ -0,0 +1,233 @@
package com.github.binarywang.wxpay.bean.ecommerce;
import com.google.gson.annotations.SerializedName;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* 退款结果 查询结果
* <pre>
* 文档地址https://pay.weixin.qq.com/wiki/doc/apiv3/wxpay/ecommerce/refunds/chapter3_3.shtml
* </pre>
*/
@Data
@NoArgsConstructor
public class RefundNotifyResult implements Serializable {
/**
* 源数据
*/
private NotifyResponse rawData;
/**
* <pre>
* 字段名电商平台商户号
* 变量名sp_mchid
* 是否必填
* 类型string32
* 描述
* 微信支付分配给电商平台的商户号
* 示例值1900000100
* </pre>
*/
@SerializedName(value = "sp_mchid")
private String spMchid;
/**
* <pre>
* 字段名二级商户号
* 变量名sub_mchid
* 是否必填
* 类型string32
* 描述
* 分账出资的电商平台二级商户填写微信支付分配的商户号
* 示例值1900000109
* </pre>
*/
@SerializedName(value = "sub_mchid")
private String subMchid;
/**
* <pre>
* 字段名商户订单号
* 变量名out_trade_no
* 是否必填
* 类型string32
* 描述
* 返回的商户订单号
* 示例值 1217752501201407033233368018
* </pre>
*/
@SerializedName(value = "out_trade_no")
private String outTradeNo;
/**
* <pre>
* 字段名微信订单号
* 变量名transaction_id
* 是否必填
* 类型string32
* 描述
* 微信支付订单号
* 示例值 1217752501201407033233368018
* </pre>
*/
@SerializedName(value = "transaction_id")
private String transactionId;
/**
* <pre>
* 字段名商户退款单号
* 变量名out_refund_no
* 是否必填
* 类型string32
* 描述
* 商户退款单号
* 示例值 1217752501201407033233368018
* </pre>
*/
@SerializedName(value = "out_refund_no")
private String outRefundNo;
/**
* <pre>
* 字段名微信退款单号
* 变量名refund_id
* 是否必填
* 类型string32
* 描述
* 微信退款单号
* 示例值 1217752501201407033233368018
* </pre>
*/
@SerializedName(value = "refund_id")
private String refundId;
/**
* <pre>
* 字段名退款状态
* 变量名refund_status
* 是否必填
* 类型string16
* 描述
* 退款状态枚举值
* SUCCESS退款成功
* CLOSE退款关闭
* ABNORMAL退款异常退款到银行发现用户的卡作废或者冻结了导致原路退款银行卡失败可前往服务商平台>交易中心手动处理此笔退款
* 示例值SUCCESS
* </pre>
*/
@SerializedName(value = "refund_status")
private String refundStatus;
/**
* <pre>
* 字段名退款成功时间
* 变量名success_time
* 是否必填
* 类型string64
* 描述
* 1退款成功时间遵循rfc3339标准格式格式为YYYY-MM-DDTHH:mm:ss+TIMEZONEYYYY-MM-DD表示年月日T出现在字符串中
* 表示time元素的开头HH:mm:ss表示时分秒TIMEZONE表示时区+08:00表示东八区时间领先UTC 8小时即北京时间
* 例如2015-05-20T13:29:35+08:00表示北京时间2015年5月20日13点29分35秒
* 2当退款状态为退款成功时返回此参数
* 示例值2018-06-08T10:34:56+08:00
* </pre>
*/
@SerializedName(value = "success_time")
private String successTime;
/**
* <pre>
* 字段名退款入账账户
* 变量名user_received_account
* 是否必填
* 类型string64
* 描述
* 取当前退款单的退款入账方
* 退回银行卡{银行名称}{卡类型}{卡尾号}
* 退回支付用户零钱: 支付用户零钱
* 退还商户: 商户基本账户商户结算银行账户
* 退回支付用户零钱通支付用户零钱通
* 示例值招商银行信用卡0403
* </pre>
*/
@SerializedName(value = "user_received_account")
private String userReceivedAccount;
/**
* <pre>
* 字段名金额信息
* 变量名amount
* 是否必填
* 类型object
* 描述
* 金额信息
* </pre>
*/
@SerializedName(value = "amount")
private Amount amount;
@Data
@NoArgsConstructor
public static class Amount implements Serializable {
/**
* <pre>
* 字段名订单金额
* 变量名total
* 是否必填
* 类型int
* 描述
* 订单总金额单位为分只能为整数详见支付金额
* 示例值999
* </pre>
*/
@SerializedName(value = "total")
private Integer total;
/**
* <pre>
* 字段名退款金额
* 变量名refund
* 是否必填
* 类型int
* 描述
* 退款金额币种的最小单位只能为整数不能超过原订单支付金额如果有使用券后台会按比例退
* 示例值999
* </pre>
*/
@SerializedName(value = "refund")
private String refund;
/**
* <pre>
* 字段名用户支付金额
* 变量名payer_total
* 是否必填
* 类型int
* 描述
* 用户支付金额单位为分
* 示例值100
* </pre>
*/
@SerializedName(value = "payer_total")
private Integer payerTotal;
/**
* <pre>
* 字段名用户退款金额
* 变量名payer_currency
* 是否必填
* 类型int
* 描述
* 退款给用户的金额不包含所有优惠券金额
* 示例值999
* </pre>
*/
@SerializedName(value = "payer_refund")
private String payerRefund;
}
}

View File

@ -72,7 +72,7 @@ public class ReturnOrdersResult implements Serializable {
* </pre>
*/
@SerializedName(value = "out_return_no")
private String R20190516001;
private String outReturnNo;
/**
* <pre>

View File

@ -225,6 +225,18 @@ public interface EcommerceService {
*/
ProfitSharingResult profitSharing(ProfitSharingRequest request) throws WxPayException;
/**
* <pre>
* 查询分账结果API
* 文档地址: https://pay.weixin.qq.com/wiki/doc/apiv3/wxpay/ecommerce/profitsharing/chapter3_2.shtml
* </pre>
*
* @param request 查询分账请求
* @return 返回数据 profit sharing result
* @throws WxPayException the wx pay exception
*/
ProfitSharingResult queryProfitSharing(ProfitSharingQueryRequest request) throws WxPayException;
/**
* <pre>
* 请求分账回退API
@ -261,6 +273,19 @@ public interface EcommerceService {
*/
RefundsResult refunds(RefundsRequest request) throws WxPayException;
/**
* <pre>
* 退款通知回调数据处理
* 文档地址: https://pay.weixin.qq.com/wiki/doc/apiv3/wxpay/ecommerce/refunds/chapter3_3.shtml
* </pre>
*
* @param notifyData 通知数据
* @param header 通知头部数据不传则表示不校验头
* @return 解密后通知数据 partner refund notify result
* @throws WxPayException the wx pay exception
*/
RefundNotifyResult parseRefundNotifyResult(String notifyData, SignatureHeader header) throws WxPayException;
/**
* <pre>
* 二级商户账户余额提现API

View File

@ -181,6 +181,14 @@ public class EcommerceServiceImpl implements EcommerceService {
return GSON.fromJson(response, ProfitSharingResult.class);
}
@Override
public ProfitSharingResult queryProfitSharing(ProfitSharingQueryRequest request) throws WxPayException {
String url = String.format("%s/v3/ecommerce/profitsharing/orders?sub_mchid=%s&transaction_id=%s&out_order_no=%s",
this.payService.getPayBaseUrl(), request.getSubMchid(), request.getTransactionId(), request.getOutOrderNo());
String response = this.payService.getV3(URI.create(url));
return GSON.fromJson(response, ProfitSharingResult.class);
}
@Override
public ReturnOrdersResult returnOrders(ReturnOrdersRequest request) throws WxPayException {
String url = String.format("%s/v3/ecommerce/profitsharing/returnorders", this.payService.getPayBaseUrl());
@ -202,6 +210,27 @@ public class EcommerceServiceImpl implements EcommerceService {
return GSON.fromJson(response, RefundsResult.class);
}
@Override
public RefundNotifyResult parseRefundNotifyResult(String notifyData, SignatureHeader header) throws WxPayException {
if(Objects.nonNull(header) && !this.verifyNotifySign(header, notifyData)){
throw new WxPayException("非法请求,头部信息验证失败");
}
NotifyResponse response = GSON.fromJson(notifyData, NotifyResponse.class);
NotifyResponse.Resource resource = response.getResource();
String cipherText = resource.getCiphertext();
String associatedData = resource.getAssociatedData();
String nonce = resource.getNonce();
String apiV3Key = this.payService.getConfig().getApiV3Key();
try {
String result = AesUtils.decryptToString(associatedData, nonce,cipherText, apiV3Key);
RefundNotifyResult notifyResult = GSON.fromJson(result, RefundNotifyResult.class);
notifyResult.setRawData(response);
return notifyResult;
} catch (GeneralSecurityException | IOException e) {
throw new WxPayException("解析报文异常!", e);
}
}
@Override
public SubWithdrawResult subWithdraw(SubWithdrawRequest request) throws WxPayException {
String url = String.format("%s/v3/ecommerce/fund/withdraw", this.payService.getPayBaseUrl());