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

2026-03-13 21:33:41 +08:00 · 2020-11-30 08:58:21 +08:00
parent 9c0da19bc2
commit fb5493f823
4 changed files with 326 additions and 273 deletions
--- a/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/WechatPayConfiguration.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/WechatPayConfiguration.java
@@ -68,6 +68,18 @@ public class WechatPayConfiguration {
        return new WechatPayApi(wechatPayClient, wechatMetaBean);
    }

+    /**
+     * Wechat marketing api wechat marketing api.
+     *
+     * @param wechatPayClient the wechat pay client
+     * @param wechatMetaBean  the wechat meta bean
+     * @return the wechat marketing api
+     */
+    @Bean
+    public WechatMarketingApi wechatMarketingApi(WechatPayClient wechatPayClient, WechatMetaBean wechatMetaBean) {
+        return new WechatMarketingApi(wechatPayClient, wechatMetaBean);
+    }
+
    /**
     * Wechat pay callback.
     *
--- a/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/AbstractApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/AbstractApi.java
@@ -0,0 +1,51 @@
+package com.enongm.dianji.payment.wechat.v3;
+
+import com.enongm.dianji.payment.PayException;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.PropertyNamingStrategy;
+import org.springframework.http.RequestEntity;
+
+import java.net.URI;
+
+/**
+ * @author Dax
+ * @since 18:23
+ */
+public abstract class AbstractApi {
+    private final ObjectMapper mapper;
+    private final WechatPayClient wechatPayClient;
+    private final WechatMetaBean wechatMetaBean;
+
+
+    public AbstractApi(WechatPayClient wechatPayClient, WechatMetaBean wechatMetaBean) {
+        this.mapper = new ObjectMapper();
+        mapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE);
+        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+        this.wechatPayClient = wechatPayClient;
+        this.wechatMetaBean = wechatMetaBean;
+    }
+
+    public ObjectMapper getMapper() {
+        return mapper;
+    }
+
+    public WechatPayClient getWechatPayClient() {
+        return wechatPayClient;
+    }
+
+    public WechatMetaBean getWechatMetaBean() {
+        return wechatMetaBean;
+    }
+
+    protected RequestEntity<?> postRequestEntity(URI uri, Object params) {
+        try {
+            return RequestEntity.post(uri)
+                    .body(mapper.writeValueAsString(params));
+        } catch (JsonProcessingException e) {
+            e.printStackTrace();
+        }
+        throw new PayException("wechat app pay json failed");
+    }
+}
--- a/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/WechatMarketingApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/WechatMarketingApi.java
@@ -0,0 +1,259 @@
+package com.enongm.dianji.payment.wechat.v3;
+
+import com.enongm.dianji.payment.wechat.WechatPayProperties;
+import com.enongm.dianji.payment.wechat.enumeration.StockStatus;
+import com.enongm.dianji.payment.wechat.enumeration.WeChatServer;
+import com.enongm.dianji.payment.wechat.enumeration.WechatPayV3Type;
+import com.enongm.dianji.payment.wechat.v3.model.StocksCreateParams;
+import com.enongm.dianji.payment.wechat.v3.model.StocksQueryParams;
+import com.enongm.dianji.payment.wechat.v3.model.StocksSendParams;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.springframework.http.RequestEntity;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.util.StringUtils;
+import org.springframework.web.util.UriComponents;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.net.URI;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * @author Dax
+ * @since 18:22
+ */
+public class WechatMarketingApi extends AbstractApi {
+    public WechatMarketingApi(WechatPayClient wechatPayClient, WechatMetaBean wechatMetaBean) {
+        super(wechatPayClient, wechatMetaBean);
+    }
+
+    /**
+     * 创建代金券批次API.
+     *
+     * @param params the params
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> createStock(StocksCreateParams params) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_COUPON_STOCKS, params)
+                .function(this::createStocksFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+    private RequestEntity<?> createStocksFunction(WechatPayV3Type type, StocksCreateParams params) {
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+        String mchId = v3.getMchId();
+        String httpUrl = type.uri(WeChatServer.CHINA);
+        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().toUri();
+        params.setBelongMerchant(mchId);
+        return postRequestEntity(uri, params);
+    }
+
+    /**
+     * 激活代金券批次API
+     *
+     * @param stockId the stock id
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> startStock(String stockId) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_START, stockId)
+                .function(this::startAndRestartStockFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+    /**
+     * 重启代金券批次API.
+     *
+     * @param stockId the stock id
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> restartStock(String stockId) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_RESTART, stockId)
+                .function(this::startAndRestartStockFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+    private RequestEntity<?> startAndRestartStockFunction(WechatPayV3Type type, String stockId) {
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+        String mchId = v3.getMchId();
+        Map<String, String> body = new HashMap<>();
+        body.put("stock_creator_mchid", mchId);
+        String httpUrl = type.uri(WeChatServer.CHINA);
+        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().expand(stockId).toUri();
+        return postRequestEntity(uri, body);
+    }
+
+    /**
+     * 查询批次详情API.
+     *
+     * @param stockId the stock id
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> queryStockDetail(String stockId) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_DETAIL, stockId)
+                .function(this::stockDetailFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+
+    private RequestEntity<?> stockDetailFunction(WechatPayV3Type type, String stockId) {
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+
+        String httpUrl = type.uri(WeChatServer.CHINA);
+
+        MultiValueMap<String, String> queryParams = new LinkedMultiValueMap<>();
+        queryParams.add("stock_creator_mchid", v3.getMchId());
+        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).queryParams(queryParams).build().expand(stockId).toUri();
+        return RequestEntity.get(uri).build();
+
+    }
+
+
+    /**
+     * 查询该代金券可用的商户
+     *
+     * @param params the params
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> queryMerchantsByStockId(StocksQueryParams params) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_MERCHANTS, params)
+                .function(this::queryStocksFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+
+        return wechatResponseEntity;
+    }
+
+
+    /**
+     * 分页查询商户下的代金券批次.
+     *
+     * @param params the params
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> queryStocksByMch(StocksQueryParams params) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS, params)
+                .function(this::queryStocksFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+
+        return wechatResponseEntity;
+    }
+
+
+    private RequestEntity<?> queryStocksFunction(WechatPayV3Type type, StocksQueryParams params) {
+
+        MultiValueMap<String, String> queryParams = new LinkedMultiValueMap<>();
+        queryParams.add("offset", String.valueOf(params.getOffset()));
+        queryParams.add("limit", String.valueOf(params.getLimit()));
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+        queryParams.add("stock_creator_mchid", v3.getMchId());
+        LocalDateTime createStartTime = params.getCreateStartTime();
+        if (Objects.nonNull(createStartTime)) {
+            //rfc 3339   YYYY-MM-DDTHH:mm:ss.sss+TIMEZONE
+            queryParams.add("create_start_time", createStartTime.atOffset(ZoneOffset.ofHours(8))
+                    .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME));
+        }
+        LocalDateTime createEndTime = params.getCreateEndTime();
+        if (Objects.nonNull(createEndTime)) {
+            //rfc 3339   YYYY-MM-DDTHH:mm:ss.sss+TIMEZONE
+            queryParams.add("create_end_time", createEndTime.atOffset(ZoneOffset.ofHours(8))
+                    .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME));
+        }
+        StockStatus status = params.getStatus();
+        if (Objects.nonNull(status)) {
+            queryParams.add("status", status.value());
+        }
+
+        String stockId = params.getStockId();
+
+        UriComponents uriComponents = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+                .queryParams(queryParams)
+                .build();
+
+        if (StringUtils.hasText(stockId)) {
+            uriComponents = uriComponents.expand(stockId);
+        }
+
+        URI uri = uriComponents
+                .toUri();
+        return RequestEntity.get(uri).build();
+    }
+
+
+    /**
+     * 发放代金券API.
+     *
+     * @param params the params
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> sendStocks(StocksSendParams params) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_USERS_COUPONS, params)
+                .function(this::sendStocksFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+
+    private RequestEntity<?> sendStocksFunction(WechatPayV3Type type, StocksSendParams params) {
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+        // 服务号
+        params.setAppid(v3.getMp().getAppId());
+        params.setStockCreatorMchid(v3.getMchId());
+        String httpUrl = type.uri(WeChatServer.CHINA);
+        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().expand(params.getOpenid()).toUri();
+        params.setOpenid(null);
+        return postRequestEntity(uri, params);
+    }
+
+
+    /**
+     * 代金券核销回调通知.
+     *
+     * @param notifyUrl the notify url
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> marketingFavorCallback(String notifyUrl) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.getWechatPayClient().withType(WechatPayV3Type.MARKETING_FAVOR_CALLBACKS, notifyUrl)
+                .function(this::marketingFavorCallbackFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+    private RequestEntity<?> marketingFavorCallbackFunction(WechatPayV3Type type, String notifyUrl) {
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
+        Map<String, Object> body = new HashMap<>(3);
+        body.put("mchid", v3.getMchId());
+        body.put("notify_url", notifyUrl);
+        body.put("switch", true);
+        String httpUrl = type.uri(WeChatServer.CHINA);
+        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().toUri();
+        return postRequestEntity(uri, body);
+    }
+
+}
+
+
+
--- a/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/WechatPayApi.java
+++ b/payment-spring-boot-autoconfigure/src/main/java/com/enongm/dianji/payment/wechat/v3/WechatPayApi.java
@@ -1,33 +1,14 @@
 package com.enongm.dianji.payment.wechat.v3;

-import com.enongm.dianji.payment.PayException;
 import com.enongm.dianji.payment.wechat.WechatPayProperties;
-import com.enongm.dianji.payment.wechat.enumeration.StockStatus;
 import com.enongm.dianji.payment.wechat.enumeration.WeChatServer;
 import com.enongm.dianji.payment.wechat.enumeration.WechatPayV3Type;
 import com.enongm.dianji.payment.wechat.v3.model.AppPayParams;
-import com.enongm.dianji.payment.wechat.v3.model.StocksCreateParams;
-import com.enongm.dianji.payment.wechat.v3.model.StocksQueryParams;
-import com.enongm.dianji.payment.wechat.v3.model.StocksSendParams;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.PropertyNamingStrategy;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import org.springframework.http.RequestEntity;
-import org.springframework.util.LinkedMultiValueMap;
-import org.springframework.util.MultiValueMap;
-import org.springframework.util.StringUtils;
-import org.springframework.web.util.UriComponents;
 import org.springframework.web.util.UriComponentsBuilder;

 import java.net.URI;
-import java.time.LocalDateTime;
-import java.time.ZoneOffset;
-import java.time.format.DateTimeFormatter;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;

 /**
 * The type Wechat pay v 3 api.
@@ -35,248 +16,11 @@ import java.util.Objects;
 * @author Dax
 * @since 16 :15
 */
-public class WechatPayApi {
-    private static final ObjectMapper MAPPER = new ObjectMapper();
-    private final WechatPayClient wechatPayClient;
-    private final WechatMetaBean wechatMetaBean;
-
-    static {
-        MAPPER.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE);
-        MAPPER.setSerializationInclusion(JsonInclude.Include.NON_NULL);
-    }
+public class WechatPayApi extends AbstractApi {


-    /**
-     * Wechat Pay V3 Api.
-     *
-     * @param wechatPayClient the wechat pay v 3 client
-     * @param wechatMetaBean  the wechat meta bean
-     */
    public WechatPayApi(WechatPayClient wechatPayClient, WechatMetaBean wechatMetaBean) {
-        this.wechatPayClient = wechatPayClient;
-        this.wechatMetaBean = wechatMetaBean;
-    }
-
-
-    /**
-     * 创建代金券批次API.
-     *
-     * @param params the params
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> createStock(StocksCreateParams params) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_COUPON_STOCKS, params)
-                .function(this::createStocksFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-    private RequestEntity<?> createStocksFunction(WechatPayV3Type type, StocksCreateParams params) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-        String mchId = v3.getMchId();
-        String httpUrl = type.uri(WeChatServer.CHINA);
-        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().toUri();
-        params.setBelongMerchant(mchId);
-        return postRequestEntity(uri, params);
-    }
-
-    /**
-     * 激活代金券批次API
-     *
-     * @param stockId the stock id
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> startStock(String stockId) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_START, stockId)
-                .function(this::startAndRestartStockFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-    /**
-     * 重启代金券批次API.
-     *
-     * @param stockId the stock id
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> restartStock(String stockId) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_RESTART, stockId)
-                .function(this::startAndRestartStockFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-    private RequestEntity<?> startAndRestartStockFunction(WechatPayV3Type type, String stockId) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-        String mchId = v3.getMchId();
-        Map<String, String> body = new HashMap<>();
-        body.put("stock_creator_mchid", mchId);
-        String httpUrl = type.uri(WeChatServer.CHINA);
-        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().expand(stockId).toUri();
-        return postRequestEntity(uri, body);
-    }
-
-    /**
-     * 查询批次详情API.
-     *
-     * @param stockId the stock id
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> queryStockDetail(String stockId) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_DETAIL, stockId)
-                .function(this::stockDetailFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-
-    private RequestEntity<?> stockDetailFunction(WechatPayV3Type type, String stockId) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-
-        String httpUrl = type.uri(WeChatServer.CHINA);
-
-        MultiValueMap<String, String> queryParams = new LinkedMultiValueMap<>();
-        queryParams.add("stock_creator_mchid", v3.getMchId());
-        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).queryParams(queryParams).build().expand(stockId).toUri();
-        return RequestEntity.get(uri).build();
-
-    }
-
-
-    /**
-     * 查询该代金券可用的商户
-     *
-     * @param params the params
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> queryMerchantsByStockId(StocksQueryParams params) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS_MERCHANTS, params)
-                .function(this::queryStocksFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-
-        return wechatResponseEntity;
-    }
-
-
-    /**
-     * 分页查询商户下的代金券批次.
-     *
-     * @param params the params
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> queryStocksByMch(StocksQueryParams params) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_STOCKS, params)
-                .function(this::queryStocksFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-
-        return wechatResponseEntity;
-    }
-
-
-    private RequestEntity<?> queryStocksFunction(WechatPayV3Type type, StocksQueryParams params) {
-
-        MultiValueMap<String, String> queryParams = new LinkedMultiValueMap<>();
-        queryParams.add("offset", String.valueOf(params.getOffset()));
-        queryParams.add("limit", String.valueOf(params.getLimit()));
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-        queryParams.add("stock_creator_mchid", v3.getMchId());
-        LocalDateTime createStartTime = params.getCreateStartTime();
-        if (Objects.nonNull(createStartTime)) {
-            //rfc 3339   YYYY-MM-DDTHH:mm:ss.sss+TIMEZONE
-            queryParams.add("create_start_time", createStartTime.atOffset(ZoneOffset.ofHours(8))
-                    .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME));
-        }
-        LocalDateTime createEndTime = params.getCreateEndTime();
-        if (Objects.nonNull(createEndTime)) {
-            //rfc 3339   YYYY-MM-DDTHH:mm:ss.sss+TIMEZONE
-            queryParams.add("create_end_time", createEndTime.atOffset(ZoneOffset.ofHours(8))
-                    .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME));
-        }
-        StockStatus status = params.getStatus();
-        if (Objects.nonNull(status)) {
-            queryParams.add("status", status.value());
-        }
-
-        String stockId = params.getStockId();
-
-        UriComponents uriComponents = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
-                .queryParams(queryParams)
-                .build();
-
-        if (StringUtils.hasText(stockId)) {
-            uriComponents = uriComponents.expand(stockId);
-        }
-
-        URI uri = uriComponents
-                .toUri();
-        return RequestEntity.get(uri).build();
-    }
-
-
-    /**
-     * 发放代金券API.
-     *
-     * @param params the params
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> sendStocks(StocksSendParams params) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_USERS_COUPONS, params)
-                .function(this::sendStocksFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-
-    private RequestEntity<?> sendStocksFunction(WechatPayV3Type type, StocksSendParams params) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-        // 服务号
-        params.setAppid(v3.getMp().getAppId());
-        params.setStockCreatorMchid(v3.getMchId());
-        String httpUrl = type.uri(WeChatServer.CHINA);
-        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().expand(params.getOpenid()).toUri();
-        params.setOpenid(null);
-        return postRequestEntity(uri, params);
-    }
-
-
-    /**
-     * 代金券核销回调通知.
-     *
-     * @param notifyUrl the notify url
-     * @return the wechat response entity
-     */
-    public WechatResponseEntity<ObjectNode> marketingFavorCallback(String notifyUrl) {
-        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.MARKETING_FAVOR_CALLBACKS, notifyUrl)
-                .function(this::marketingFavorCallbackFunction)
-                .consumer(wechatResponseEntity::convert)
-                .request();
-        return wechatResponseEntity;
-    }
-
-    private RequestEntity<?> marketingFavorCallbackFunction(WechatPayV3Type type, String notifyUrl) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
-        Map<String, Object> body = new HashMap<>(3);
-        body.put("mchid", v3.getMchId());
-        body.put("notify_url", notifyUrl);
-        body.put("switch", true);
-        String httpUrl = type.uri(WeChatServer.CHINA);
-        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().toUri();
-        return postRequestEntity(uri, body);
+        super(wechatPayClient, wechatMetaBean);
    }

    /**
@@ -287,7 +31,7 @@ public class WechatPayApi {
     */
    public WechatResponseEntity<ObjectNode> appPay(AppPayParams payParams) {
        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
-        wechatPayClient.withType(WechatPayV3Type.APP, payParams)
+        this.getWechatPayClient().withType(WechatPayV3Type.APP, payParams)
                .function(this::appPayFunction)
                .consumer(wechatResponseEntity::convert)
                .request();
@@ -295,24 +39,11 @@ public class WechatPayApi {
    }

    private RequestEntity<?> appPayFunction(WechatPayV3Type type, AppPayParams payParams) {
-        WechatPayProperties.V3 v3 = wechatMetaBean.getWechatPayProperties().getV3();
+        WechatPayProperties.V3 v3 = this.getWechatMetaBean().getWechatPayProperties().getV3();
        payParams.setAppid(v3.getAppId());
        payParams.setMchid(v3.getMchId());
        String httpUrl = type.uri(WeChatServer.CHINA);
        URI uri = UriComponentsBuilder.fromHttpUrl(httpUrl).build().toUri();
        return postRequestEntity(uri, payParams);
    }
-
-
-    private static RequestEntity<?> postRequestEntity(URI uri, Object params) {
-        try {
-            return RequestEntity.post(uri)
-                    .body(MAPPER.writeValueAsString(params));
-        } catch (JsonProcessingException e) {
-            e.printStackTrace();
-        }
-        throw new PayException("wechat app pay json failed");
-    }
-
-
 }