修改退款

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/service/impl/DragonOrderRefundsServiceImpl.java

@@ -438,7 +438,12 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
             try {
                 HttpPost httpost = new HttpPost("https://api.mch.weixin.qq.com/secapi/pay/refund");
                 httpost.setEntity(new StringEntity(data, "UTF-8"));
-                CloseableHttpResponse response = PayWepayUtils.getInstance().getHttpClient().execute(httpost);
+                CloseableHttpResponse response=null;
+                if(code.contains("b")){
+                    response = PayWepayUtils.getInstance().getHttpClientB().execute(httpost);
+                }else{
+                     response = PayWepayUtils.getInstance().getHttpClient().execute(httpost);
+                }
                 try {
                     HttpEntity entity = response.getEntity();
                     entity.getContent();

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/PayWepayUtils.java

@@ -157,6 +157,45 @@ public class PayWepayUtils {
         }
         return httpClient;
     }
+    public CloseableHttpClient getHttpClientB() {
+        try {
+            if (httpClient == null) {
+
+                InputStream certStream = PayWepayUtils.class.getClassLoader().getResourceAsStream("payCert/wepayb/apiclient_cert.p12");
+                byte[] certData = IOUtils.toByteArray(certStream);
+                certStream.read(certData);
+                certStream.close();
+
+                KeyStore keyStore = KeyStore.getInstance("PKCS12");
+                ByteArrayInputStream inputStream = new ByteArrayInputStream(certData);
+                try {
+                    keyStore.load(inputStream, merchantId.toCharArray());
+                } finally {
+                    inputStream.close();
+                }
+                SSLContext sslcontext = SSLContexts.custom()
+                        .loadKeyMaterial(keyStore, merchantId.toCharArray())
+                        .build();
+                SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
+                        sslcontext,
+                        SSLConnectionSocketFactory.getDefaultHostnameVerifier());
+
+                // 配置同时支持 HTTP 和 HTPPS
+                Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create().register("http", PlainConnectionSocketFactory.getSocketFactory()).register("https", sslsf).build();
+                // 初始化连接管理器
+                poolConnManager =new PoolingHttpClientConnectionManager(socketFactoryRegistry);
+                poolConnManager.setMaxTotal(4000);// 同时最多连接数
+                // 设置最大路由
+                poolConnManager.setDefaultMaxPerRoute(2000);
+
+                // 初始化httpClient
+                httpClient = getConnection();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return httpClient;
+    }
 
     public static CloseableHttpClient getConnection() {
         RequestConfig config = RequestConfig.custom().setConnectTimeout(5000).setConnectionRequestTimeout(5000).setSocketTimeout(5000).build();