open-source/payment-spring-boot
1
0
Fork 0
mirror of https://github.com/dromara/payment-spring-boot.git synced 2026-03-14 05:43:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

重启批次接口 营销回调接口

Browse Source
This commit is contained in:
xiafang
2020-11-27 17:45:32 +08:00
parent 9f7e66445b
commit e98a1802fe
2 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/WechatPayCallback.java
View File

@@ -8,12 +8,18 @@ import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.PropertyNamingStrategy; import com.fasterxml.jackson.databind.PropertyNamingStrategy;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import java.util.HashMap;
import java.util.Map;
import java.util.function.Consumer;
/** /**
* @author Dax * @author Dax
* @since 10:21 * @since 10:21
*/ */
@Slf4j
public class WechatPayCallback { public class WechatPayCallback {
private static final ObjectMapper MAPPER = new ObjectMapper(); private static final ObjectMapper MAPPER = new ObjectMapper();
private final SignatureProvider signatureProvider; private final SignatureProvider signatureProvider;
@@ -29,7 +35,7 @@ public class WechatPayCallback {
@SneakyThrows @SneakyThrows
public CouponConsumeData wechatPayCouponCallback(ResponseSignVerifyParams params) { public Map<String, ?> wechatPayCouponCallback(ResponseSignVerifyParams params, Consumer<CouponConsumeData> couponConsumeDataConsumer) {
if (signatureProvider.responseSignVerify(params)) { if (signatureProvider.responseSignVerify(params)) {
CallbackParams callbackParams = MAPPER.readValue(params.getBody(), CallbackParams.class); CallbackParams callbackParams = MAPPER.readValue(params.getBody(), CallbackParams.class);
@@ -40,7 +46,12 @@ public class WechatPayCallback {
String ciphertext = resource.getCiphertext(); String ciphertext = resource.getCiphertext();
String data = signatureProvider.decryptResponseBody(associatedData, nonce, ciphertext); String data = signatureProvider.decryptResponseBody(associatedData, nonce, ciphertext);
Assert.hasText(data, "decryptData is required"); Assert.hasText(data, "decryptData is required");
return MAPPER.readValue(data, CouponConsumeData.class); CouponConsumeData couponConsumeData = MAPPER.readValue(data, CouponConsumeData.class);
couponConsumeDataConsumer.accept(couponConsumeData);
Map<String, Object> responseBody = new HashMap<>();
responseBody.put("code", 200);
responseBody.put("message", "核销成功");
return responseBody;
} }
throw new PayException("invalid wechat pay coupon callback"); throw new PayException("invalid wechat pay coupon callback");
} }

2
payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/model/ResponseSignVerifyParams.java
View File

@@ -6,7 +6,7 @@ import lombok.Data;
* 微信的响应签名校验参数 * 微信的响应签名校验参数
* *
* @author Dax * @author Dax
* @see com.enongm.dianji.payment.wechat.v3.SignatureProvider#responseSignVerify(String, String, String, String, String) * @see com.enongm.dianji.payment.wechat.v3.SignatureProvider#responseSignVerify(ResponseSignVerifyParams)
* @since 16:32 * @since 16:32
*/ */
@Data @Data