upgrade after testing

黄刚
1 parent 37d8d3a5
Showing 10 changed files with 173 additions and 32 deletions
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/client/WechatHttpClient.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/core/WechatDirectPipeline.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/core/WechatPartnerPipeline.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/core/WechatPipeline.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/service/impl/PaymentPipelineManagerImpl.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/service/impl/WechatPaymentServiceImpl.java
cashier-pipeline/src/main/java/com/diligrp/cashier/pipeline/type/ChannelType.java
cashier-shared/src/main/java/com/diligrp/cashier/shared/spi/domain/RefundResultBO.java
cashier-trade/src/main/java/com/diligrp/cashier/trade/service/impl/CashierPaymentServiceImpl.java
scripts/cashier-data.sql
@@ -67,7 +67,7 @@ public class WechatHttpClient extends ServiceEndpointSupport {
     /**
      * 查询微信预支付订单状态
      */
-    public OnlinePaymentResponse queryPrepayResponse(OnlinePrepayOrder order) throws Exception {
+    public OnlinePaymentResponse queryPrepayResponse(OnlinePrepayOrder request) throws Exception {
         throw new PaymentPipelineException(ErrorCode.OPERATION_NOT_ALLOWED, "支付通道不支持此操作");
     }
@@ -6,8 +6,11 @@ import com.diligrp.cashier.shared.util.AssertUtils;
 /**
  * 微信支付通道抽象模型-直联模式
+ *
+ * 直连模式upay_payment_pipeline.params只需配置notifyUrl
+ * upay_wechat_param需配置商户API接口所需配置信息
  */
-public class WechatDirectPipeline extends WechatPipeline {
+public class WechatDirectPipeline extends WechatPipeline<WechatDirectPipeline.DirectWechatParams> {
     private final ScanTimeStrategy strategy;
     // 直联模式下的微信客户端
@@ -30,6 +33,17 @@ public class WechatDirectPipeline extends WechatPipeline {
     }
     @Override
+    public Class<DirectWechatParams> paramClass() {
+        return DirectWechatParams.class;
+    }
+
+    public static class DirectWechatParams extends WechatParams {
+        public DirectWechatParams(String params) {
+            super(params);
+        }
+    }
+
+    @Override
     public WechatHttpClient getClient() {
         AssertUtils.notNull(client, "微信支付通道客户端未配置");
         return client;
 package com.diligrp.cashier.pipeline.core;
+import com.diligrp.cashier.pipeline.Constants;
 import com.diligrp.cashier.pipeline.client.WechatHttpClient;
 import com.diligrp.cashier.pipeline.client.WechatPartnerHttpClient;
+import com.diligrp.cashier.pipeline.domain.*;
 import com.diligrp.cashier.shared.util.AssertUtils;
 /**
  * 微信支付通道抽象模型-服务商模式
+ *
+ * 服务商模式需要额外配置subMchId和subAppId, subMchId可以由业务系统传递，否则使用通道配置的subMchId
+ * upay_payment_pipeline.params需配置subMchId, subAppId, appSecret和notifyUrl
+ * upay_wechat_param需配置服务商API接口所需配置信息
  */
-public class WechatPartnerPipeline extends WechatPipeline {
+public class WechatPartnerPipeline extends WechatPipeline<WechatPartnerPipeline.PartnerWechatParams> {
     private final ScanTimeStrategy strategy;
@@ -16,6 +22,10 @@ public class WechatPartnerPipeline extends WechatPipeline {
     public WechatPartnerPipeline(long mchId, long pipelineId, String name, String uri, String params) throws Exception {
         super(mchId, pipelineId, name, uri, params);
+        PartnerWechatParams config = params();
+        AssertUtils.notEmpty(config.getSubMchId(), "微信支付缺少参数配置: subMchId");
+        AssertUtils.notEmpty(config.getSubAppId(), "微信支付缺少参数配置: subAppId");
+        AssertUtils.notEmpty(config.getAppSecret(), "微信支付缺少参数配置: appSecret");
         this.strategy = new DefaultTimeStrategy();
     }
@@ -31,6 +41,111 @@ public class WechatPartnerPipeline extends WechatPipeline {
     }
     @Override
+    public NativePrepayResponse sendNativePrepayRequest(NativePrepayRequest request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.sendNativePrepayRequest(request);
+    }
+
+    @Override
+    public MiniProPrepayResponse sendMiniProPrepayRequest(MiniProPrepayRequest request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.sendMiniProPrepayRequest(request);
+    }
+
+    @Override
+    public OnlinePaymentResponse sendQrCodePaymentRequest(QrCodePaymentRequest request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.sendQrCodePaymentRequest(request);
+    }
+
+    @Override
+    public OnlinePaymentResponse queryPrepayResponse(OnlinePrepayOrder order) {
+        // 业务没有传递子商户则使用默认配置
+        if (order.getString(Constants.PARAM_MCH_ID) == null) {
+            order.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.queryPrepayResponse(order);
+    }
+
+    @Override
+    public void closePrepayOrder(OnlinePrepayOrder request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        super.closePrepayOrder(request);
+    }
+
+    @Override
+    public OnlineRefundResponse sendRefundRequest(OnlineRefundRequest request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.sendRefundRequest(request);
+    }
+
+    @Override
+    public OnlineRefundResponse queryRefundResponse(OnlineRefundOrder request) {
+        // 业务没有传递子商户则使用默认配置
+        if (request.getString(Constants.PARAM_MCH_ID) == null) {
+            request.put(Constants.PARAM_MCH_ID, params().getSubMchId());
+        }
+        return super.queryRefundResponse(request);
+    }
+
+    @Override
+    public Class<PartnerWechatParams> paramClass() {
+        return PartnerWechatParams.class;
+    }
+
+    public static class PartnerWechatParams extends WechatParams {
+        // 服务商模式下，子商户号
+        private String subMchId;
+        // 服务商模式下，subAppId
+        private String subAppId;
+        // subAppId对应的appSecret
+        private String appSecret;
+
+        public PartnerWechatParams(String params) {
+            super(params);
+        }
+
+        public String getSubMchId() {
+            return subMchId;
+        }
+
+        public void setSubMchId(String subMchId) {
+            this.subMchId = subMchId;
+        }
+
+        public String getSubAppId() {
+            return subAppId;
+        }
+
+        public void setSubAppId(String subAppId) {
+            this.subAppId = subAppId;
+        }
+
+        public String getAppSecret() {
+            return appSecret;
+        }
+
+        public void setAppSecret(String appSecret) {
+            this.appSecret = appSecret;
+        }
+    }
+
+    @Override
     public WechatHttpClient getClient() {
         AssertUtils.notNull(client, "微信支付通道客户端未配置");
         return client;
@@ -23,7 +23,7 @@ import java.security.PrivateKey;
 /**
  * 微信支付通道抽象模型
  */
-public abstract class WechatPipeline extends OnlinePipeline<WechatPipeline.WechatParams> {
+public abstract class WechatPipeline<T extends WechatPipeline.WechatParams> extends OnlinePipeline<T> {
     private static final Logger LOG = LoggerFactory.getLogger(WechatPipeline.class);
@@ -33,7 +33,7 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
     public WechatPipeline(long mchId, long pipelineId, String name, String uri, String params) throws Exception {
         super(mchId, pipelineId, name, uri, params);
         WechatParams config = params();
-        AssertUtils.notEmpty(config.notifyUri, String.format("微信支付缺少参数配置: notifyBaseUri"));
+        AssertUtils.notEmpty(config.getNotifyUrl(), "微信支付缺少参数配置: notifyUrl");
     }
     /**
@@ -86,7 +86,7 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
     @Override
     public NativePrepayResponse sendNativePrepayRequest(NativePrepayRequest request) {
         try {
-            String notifyUri = String.format(Constants.WECHAT_PAYMENT_NOTIFY_URI, params().notifyUri, request.getPaymentId());
+            String notifyUri = String.format(Constants.WECHAT_PAYMENT_NOTIFY_URI, params().getNotifyUrl(), request.getPaymentId());
             return getClient().sendNativePrepayRequest(request, notifyUri);
         } catch (PaymentPipelineException | IllegalArgumentException pse) {
             throw pse;
@@ -101,7 +101,7 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
      */
     public MiniProPrepayResponse sendMiniProPrepayRequest(MiniProPrepayRequest request) {
         try {
-            String notifyUri = String.format(Constants.WECHAT_PAYMENT_NOTIFY_URI, params().notifyUri, request.getPaymentId());
+            String notifyUri = String.format(Constants.WECHAT_PAYMENT_NOTIFY_URI, params().getNotifyUrl(), request.getPaymentId());
             String prepayId = getClient().sendMiniProPrepayRequest(request, notifyUri);
             String timeStamp = String.valueOf(System.currentTimeMillis() / 1000);
@@ -131,9 +131,9 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
     /**
      * 查询预支付订单状态
      */
-    public OnlinePaymentResponse queryPrepayResponse(OnlinePrepayOrder order) {
+    public OnlinePaymentResponse queryPrepayResponse(OnlinePrepayOrder request) {
         try {
-            return getClient().queryPrepayResponse(order);
+            return getClient().queryPrepayResponse(request);
         } catch (PaymentPipelineException | IllegalArgumentException pse) {
             throw pse;
         } catch (Exception ex) {
@@ -161,7 +161,7 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
      */
     public OnlineRefundResponse sendRefundRequest(OnlineRefundRequest request) {
         try {
-            String notifyUri = String.format(Constants.WECHAT_REFUND_NOTIFY_URI, params().notifyUri, request.getRefundId());
+            String notifyUri = String.format(Constants.WECHAT_REFUND_NOTIFY_URI, params().getNotifyUrl(), request.getRefundId());
             return getClient().sendRefundRequest(request, notifyUri);
         } catch (PaymentPipelineException | IllegalArgumentException pse) {
             throw pse;
@@ -192,25 +192,21 @@ public abstract class WechatPipeline extends OnlinePipeline&lt;WechatPipeline.Wecha
         return ChannelType.WXPAY;
     }
-    @Override
-    public Class<WechatParams> paramClass() {
-        return WechatParams.class;
-    }
+    public static abstract class WechatParams extends PipelineParams {
-    public static class WechatParams extends PipelineParams {
         // 微信支付通知base地址，如: https://gateway.diligrp.com/pay-service
-        private String notifyUri;
+        private String notifyUrl;
         public WechatParams(String params) {
             super(params);
         }
-        public String getNotifyUri() {
-            return notifyUri;
+        public String getNotifyUrl() {
+            return notifyUrl;
         }
-        public void setNotifyUri(String notifyUri) {
-            this.notifyUri = notifyUri;
+        public void setNotifyUrl(String notifyUrl) {
+            this.notifyUrl = notifyUrl;
         }
     }
 }
@@ -39,13 +39,13 @@ public class PaymentPipelineManagerImpl extends LifeCycle implements IPaymentPip
                 if (paramOpt.isPresent()) {
                     WechatParam param = paramOpt.get();
                     if (WechatPipelineType.DIRECT.equalTo(param.getType())) {
-                        WechatPipeline paymentPipeline = new WechatDirectPipeline(pipeline.getMchId(), pipeline.getPipelineId(),
+                        WechatPipeline<?> paymentPipeline = new WechatDirectPipeline(pipeline.getMchId(), pipeline.getPipelineId(),
                             pipeline.getName(), pipeline.getUri(), pipeline.getParam());
                         paymentPipeline.configure(param.getMchId(), param.getAppId(), param.getAppSecret(), param.getSerialNo(),
                             param.getPrivateKey(), param.getWechatSerialNo(), param.getWechatPublicKey(), param.getApiV3Key());
                         registerPaymentPipeline(paymentPipeline);
                     } else if (WechatPipelineType.PARTNER.equalTo(param.getType())) {
-                        WechatPipeline paymentPipeline = new WechatPartnerPipeline(pipeline.getMchId(), pipeline.getPipelineId(),
+                        WechatPipeline<?> paymentPipeline = new WechatPartnerPipeline(pipeline.getMchId(), pipeline.getPipelineId(),
                             pipeline.getName(), pipeline.getUri(), pipeline.getParam());
                         paymentPipeline.configure(param.getMchId(), param.getAppId(), param.getAppSecret(), param.getSerialNo(),
                             param.getPrivateKey(), param.getWechatSerialNo(), param.getWechatPublicKey(), param.getApiV3Key());
@@ -82,7 +82,7 @@ public class PaymentPipelineManagerImpl extends LifeCycle implements IPaymentPip
         if (allPipelines.size() > 1) {
             throw new PaymentPipelineException(ErrorCode.OBJECT_NOT_FOUND, "该商户未配置支付路由");
         }
-        return allPipelines.get(0);
+        return allPipelines.getFirst();
     }
     @Override
@@ -95,7 +95,7 @@ public class PaymentPipelineManagerImpl extends LifeCycle implements IPaymentPip
         if (allPipelines.size() > 1) {
             throw new PaymentPipelineException(ErrorCode.OBJECT_NOT_FOUND, "该商户未配置支付路由");
         }
-        return allPipelines.get(0);
+        return allPipelines.getFirst();
     }
     @Override
@@ -5,6 +5,7 @@ import com.diligrp.cashier.pipeline.core.WechatPartnerPipeline;
 import com.diligrp.cashier.pipeline.core.WechatPipeline;
 import com.diligrp.cashier.pipeline.domain.wechat.UploadShippingRequest;
 import com.diligrp.cashier.pipeline.domain.wechat.WechatAccessToken;
+import com.diligrp.cashier.pipeline.domain.wechat.WechatConfig;
 import com.diligrp.cashier.pipeline.service.IPaymentPipelineManager;
 import com.diligrp.cashier.pipeline.service.IWechatPaymentService;
 import jakarta.annotation.Resource;
@@ -21,8 +22,15 @@ public class WechatPaymentServiceImpl implements IWechatPaymentService {
      */
     @Override
     public String openIdByCode(Long pipelineId, String code) {
-        WechatPipeline pipeline = paymentPipelineManager.findPipelineById(pipelineId, WechatPipeline.class);
-        return pipeline.getClient().loginAuthorization(code);
+        WechatPipeline<?> pipeline = paymentPipelineManager.findPipelineById(pipelineId, WechatPipeline.class);
+        if (pipeline instanceof WechatPartnerPipeline partnerPipeline) {
+            // 服务商模式下subMchId和subAppId配置upay_payment_pipeline.params，对应的appSecret配置在upay_wechat_param.app_secret
+            WechatPartnerPipeline.PartnerWechatParams params = partnerPipeline.params();
+            WechatConfig config = pipeline.getClient().getWechatConfig();
+            return pipeline.getClient().loginAuthorization(params.getSubAppId(), config.getAppSecret(), code);
+        } else {
+            return pipeline.getClient().loginAuthorization(code);
+        }
     }
     /**
@@ -17,7 +17,7 @@ public enum ChannelType implements IEnumType {
     WXPAY("微信支付", 10),
-    ALIPAY("支付宝", 11),
+    ALIPAY("支付宝支付", 11),
     DILIPAY("园区卡支付", 19),
@@ -7,7 +7,7 @@ public class RefundResultBO {
     private final String refundId;
     // 原支付ID
     private final String tradeId;
-    // 支付状态
+    // 退款状态
     private final Integer state;
     // 发生时间
     private final LocalDateTime when;
@@ -278,7 +278,6 @@ public class CashierPaymentServiceImpl implements ICashierPaymentService {
     @Override
     public OnlinePaymentResult queryPaymentState(String paymentId, String mode) {
-        // TODO: 支付成功后返回支付成功的页面地址
         OnlinePayment payment = tradeAssistantService.findByPaymentId(paymentId);
         TradeOrder trade = tradeAssistantService.findByTradeId(payment.getTradeId());
@@ -422,7 +421,7 @@ public class CashierPaymentServiceImpl implements ICashierPaymentService {
         LOG.debug("Query online refund order[{}-{}] state...", refundId, refund.getState());
         // 微信支付通知较为及时和安全，非特殊情况可使用offline模式；一些本地状态与微信状态不一致的"异常订单"可使用online模式同步状态
         if (!PaymentState.isFinished(refund.getState()) && "online".equalsIgnoreCase(mode)) {
-            WechatPipeline pipeline = paymentPipelineManager.findPipelineById(refund.getPipelineId(), WechatPipeline.class);
+            WechatPipeline<?> pipeline = paymentPipelineManager.findPipelineById(refund.getPipelineId(), WechatPipeline.class);
             OnlineRefundOrder order = new OnlineRefundOrder(refundId, refund.getOutTradeNo());
             // 用于微信服务商模式下，微信子商户信息
             order.attach(com.diligrp.cashier.pipeline.Constants.PARAM_MCH_ID, refund.getOutMchId());
-INSERT INTO upay_merchant(mch_id, name, param, address, linkman, telephone, state, created_time, modified_time)
-VALUES (1001, '安徽省中瑞农副产品有限责任公司', '{"cashier":{"miniProUrl": "https://cashier.pay.gszdtop.com/merchant/mp"}}', '安徽省濉溪县南环路中瑞农产品批发市场', '赵静', '0561-6863420', 1, now(), now());
 \ No newline at end of file
+INSERT INTO dili_cashier.upay_merchant(mch_id, name, param, address, linkman, telephone, state, created_time, modified_time)
+VALUES (1001, '安徽省中瑞农副产品有限责任公司', '{"cashier":{"miniProUrl": "https://cashier.pay.gszdtop.com/merchant/mp"}}', '安徽省濉溪县南环路中瑞农产品批发市场', '赵静', '0561-6863420', 1, now(), now());
+
+-- 根据环境配置不同的回调地址
+INSERT INTO `dili_cashier`.upay_payment_pipeline(mch_id, pipeline_id, channel_id, type, name, uri, param, state, created_time, modified_time)
+VALUES (1001, 10011, 10, 10, '中瑞微信服务商支付通道', 'https://api.mch.weixin.qq.com', '{"subMchId":"1679224186", "subAppId":"wxad27b69b888b6dc9", "appSecret":"9c254c0ab932b3c30292a05679a688f7", "notifyUrl": "https://cashier.test.gszdtop.com"}', 1, now(), now());
+INSERT INTO `dili_cashier`.upay_wechat_param(pipeline_id, mch_id, app_id, app_secret, serial_no, private_key, wechat_serial_no, wechat_public_key, api_v3_key, type, created_time)
+VALUES(10011, '1679223106', 'wxca99d56a6ab15f29', '9c254c0ab932b3c30292a05679a688f7', '60C2877836D1D618D2E40186995BB00299D92F44','MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCx/XUbQ4mOr+zwuLn3e621YEgBc/dzbfGuc7mV2ojKN/wUwRRfrgfyln7xHurUeVf8jrPdJZwk/d6mqyZl28i/NS88Ud+jNOSe0bB2DwFEh5zhqbzfKYtBygkkNFzTam12ddSwCpng+59hcgaMdx47e7D6e+3C7Y422gJWMmBadP8gV25J2XP2u/zBl8PXUUsjhlWG474X6p5OGoahVTrfTFUIp6KfST8GvBa0uXjoiD3uS/d+u9VCKd6S2ohBDBEsybKGH8MHHopsF/NRuhlsUWKdR/eTcSItOs2fnE7MIGTeHZiBjA9lDi5qRsq5ryZEf85GU3uJCIlad0JbgsvjAgMBAAECggEBAINjcCDyGAcGgsen9U9lMvOi4USBUHca/78hmiuuqC9uaF0BsoJ2u1MuGQLxKbQy5up+hPOIod0EsmkiCjRCq8vJ/NZwMcAOeX1rmPFtXigyW3KRk+TAjBXCiED7jlJaS/eYP6q8CJ91309VltP10pFiW2BsPzUXm1WOVQ9AHLRoUIrywP+FZlymYBMo8HgMaIhBQdHS8+kxEUD/iJID9V/96sem6v0UOwZw8eVymZ+Yz9LVAxoI2zELyMKM2XrwLkJ1HTaV9VAjoFO09eTLJjZbiRFg0dqNBimSL0H3wDZrNpiOI5ptqs0RSCQ0o10n0DJIITI+ybpak9BtklFotjECgYEA627DKlWPTC4tWX6nt/Ty55+UxAmE5icT5i969eze3qTWcYnaF5R+Xe7ClM+H4cbZ957LwgKQhmmSy8joj9hhlN2opBmRZPuJTKa6hVYY4HUjmTdjiPxQebWK53hQuNLozCCC2Etpb4VBVGxF5d50zf2JD4FR1AspXR8hAag95bcCgYEAwYoLKKXYDqXUUzjmOiDOQFqmC5rfaT/A33Ud27uExHQEMBw7Pxijvdj+Ui7/ykeb7R2+g2eNlr00tohBrwvfiI+rZz2qcglgbZRQpacK1rkhUpW1Vxv5snR9NgvTganII2eRmyKUxQyvAsBUkWhvWXuy5fUma74nO9Y82UvHqzUCgYEAouKJCJsVf2FbYtWr+Cvyeqn/5PmpBwr2S4WCDu+I6oUlEHyNdU75dsefvBExM9W+LAGje2EG2NfmBjPEIvFT4gjRimdeHn2g6nVYCrQclf61WGXn6XiXvP0LU0X8o0LYaZH8tOTH165cGqqmWXllWrcUwrN4B7qJLbJBxcG+wVUCgYBOUGSZixo1OycCkfifNt0er0+XTJDwjsql4Uc2vddIg0WajiHvMzI2xRKMANaibH2M4kdP9twVTfSBk/s4MM6//Jq4CPzqbh7l2GkVztUU9A6m00twtzI/4uEzuG9afXAt21/Q7ZpTbgF3VIoj2KWOCP7oDF4CpQxNKzCuIPrnrQKBgQClomPIXuKw75YCtPN7eq7ul/NPa6GNfzkL0DNl+sxNV0NGjTxSmj7cVkTc7ebduQh1MwbAh1Tlhxt0rRkmzVmDToaH4Hb7ZpHeVNRQLQEBQoaHiiYztH7n6DNWVaICsi5SeeoDEYhcQG08xCgY6K4BKglezodEyPAJ1DJrRt6UHw==', '3C4D1F79159D86544E2B4E04BA3D5F8541818B3A', 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAtOrhRXuxkIcKYv4Aqg8OXT2HSUteoCfjnH8z3Ma6vQhgV5nriVR4dGUw/LOqHndKxN/n5RQcUBNQpsfGMATiEcVGkyiJNQZRBKBa6PxD24sCzGTde8wrYPCazibA+wA14Nj9fQIfc9loCJu9IrYrc6p7iJNOHqfYM20PtctrvGs5DgGt1Rav/xqin5f3wQXvungGfRJwbSpoA+ayXzRkFe5UThFEF/NP0PHOc6+pj7xuf5g9HactqdbRJyRIjhhyfAW5BOTAIFGPNVhE6juhyVFyx1uRBdKvZUKj0U76PzT/l8gW0FizeMpSal1oVszCSjo6FdD3II9C3CyJX1A01QIDAQAB', 'RSfFvEBBQiHz8GZyDcP2eSUlZJgKjdxk', 2, now());
+-- 根据环境配置不同的uri
+INSERT INTO `dili_cashier`.upay_payment_pipeline(mch_id, pipeline_id, channel_id, type, name, uri, param, state, created_time, modified_time)
+VALUES (1001, 10012, 19, 2, '中瑞园区卡支付通道', 'http://10.28.3.9:8081', null, 1, now(), now());