From 82581bd9f30b38cd5b402bfd15486fe7d37e3178 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 17 Jan 2024 14:38:52 +0800
Subject: [PATCH] fapiao

---
 src/main/java/cc/mrbird/febs/pay/service/impl/WxFaPiaoServiceImpl.java |   24 ++++++++++++++++++++++--
 1 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/pay/service/impl/WxFaPiaoServiceImpl.java b/src/main/java/cc/mrbird/febs/pay/service/impl/WxFaPiaoServiceImpl.java
index db77555..ec935be 100644
--- a/src/main/java/cc/mrbird/febs/pay/service/impl/WxFaPiaoServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/pay/service/impl/WxFaPiaoServiceImpl.java
@@ -162,6 +162,7 @@
         String result = "";
         CloseableHttpClient httpClient = HttpClients.createDefault();
         HttpPatch httpPatch = new HttpPatch(url);
+        CloseableHttpResponse response = null;
         httpPatch.setHeader("Content-type", "application/json");
         httpPatch.setHeader("Charset", "utf-8");
         httpPatch.setHeader("Accept", "application/json");
@@ -170,11 +171,20 @@
         try {
             StringEntity data = new StringEntity(params, "utf-8");
             httpPatch.setEntity(data);
-            HttpResponse response = httpClient.execute(httpPatch);
+            response = httpClient.execute(httpPatch);
             HttpEntity entity = response.getEntity();
             result = EntityUtils.toString(entity);
         } catch (Exception e) {
             result = "{\"status\":\"1\",\"error\":\"" + e.getMessage() + "\"}";
+        }finally {
+            try {
+                httpClient.close();
+                if (response != null) {
+                    response.close();
+                }
+            } catch (IOException var22) {
+                var22.printStackTrace();
+            }
         }
         return result;
     }
@@ -186,6 +196,7 @@
         while (true) {
             CloseableHttpClient client = HttpClients.createDefault();
             HttpPost httpPost = new HttpPost(url);
+            CloseableHttpResponse response = null;
             try {
                 httpPost.addHeader("Content-type", "application/json");
                 httpPost.addHeader("Charset", "utf-8");
@@ -195,7 +206,7 @@
 
                 StringEntity data = new StringEntity(params, "utf-8");
                 httpPost.setEntity(data);
-                HttpResponse response = client.execute(httpPost);
+                response = client.execute(httpPost);
                 HttpEntity resEntity = response.getEntity();
                 result = EntityUtils.toString(resEntity);
                 return result;
@@ -209,6 +220,15 @@
                 } catch (InterruptedException e1) {
                     result = "{\"status\":\"1\",\"errors\":\"" + e1.getMessage() + "\"}";
                 }
+            }finally {
+                try {
+                    client.close();
+                    if (response != null) {
+                        response.close();
+                    }
+                } catch (IOException var22) {
+                    var22.printStackTrace();
+                }
             }
         }
         return result;

--
Gitblit v1.9.1