Merge branch 'dev/2024/0703/update-app-Y' of Harper/feifan-backend-zx-app into master

新增支付通道

feifan-module-pay/feifan-module-pay-biz/src/main/java/cn/newfeifan/mall/module/pay/fuiou/util/PostMethodCallback.java

@@ -0,0 +1,7 @@
+package cn.newfeifan.mall.module.pay.fuiou.util;
+
+import org.apache.commons.httpclient.methods.PostMethod;
+
+public interface PostMethodCallback {
+    public void doInPostMethod(PostMethod postMethod);
+}

feifan-module-pay/feifan-module-pay-biz/src/main/java/cn/newfeifan/mall/module/pay/fuiou/util/Test.java

@@ -46,20 +46,20 @@ public class Test {
 
 
 
-//    public String newPost(final String body) throws Exception {
-//        return post(new PostMethodCallback() {
-//
-//            @Override
-//            public void doInPostMethod(PostMethod postMethod) {
-//
-//                try {
-//                    postMethod.setRequestEntity(new StringRequestEntity(body,"application/json","UTF-8"));
-//                } catch (UnsupportedEncodingException e) {
-//                    e.printStackTrace();
-//                }
-//            }
-//        });
-//    }
+    public String newPost(final String body) throws Exception {
+        return post(new PostMethodCallback() {
+
+            @Override
+            public void doInPostMethod(PostMethod postMethod) {
+
+                try {
+                    postMethod.setRequestEntity(new StringRequestEntity(body,"application/json","UTF-8"));
+                } catch (UnsupportedEncodingException e) {
+                    e.printStackTrace();
+                }
+            }
+        });
+    }
 
 
 
@@ -74,69 +74,69 @@ public class Test {
      //	 * @throws LoanException
      //	 * @throws Exception
      */
-//    private String post(PostMethodCallback callback) throws Exception {
-//        PostMethod xmlpost = null;
-//        HttpClient httpclient = new HttpClient();
-//        try {
-//            // https设置
-//            if (url.indexOf("https://") != -1) {
-//                // 创建SSL连接
-//                @SuppressWarnings("deprecation")
-//                Protocol myhttps = new Protocol("https",
-//                        new MySSLSocketFactory(), 443);
-//                Protocol.registerProtocol("https", myhttps);
-//            }
-//            httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(60 * 1000);
-//            httpclient.getHttpConnectionManager().getParams().setSoTimeout(60 * 1000);
-//            xmlpost = new PostMethod(url);
-//            httpclient.getParams().setParameter(
-//                    HttpMethodParams.HTTP_CONTENT_CHARSET, charset);
-//            httpclient.getParams().setContentCharset(charset);
-//            // xmlpost.setRequestHeader("content-type", "text/xml; charset=" +
-//            // charset);
-//
-//            // 内部回调，发送数据，设置参数用
-//            callback.doInPostMethod(xmlpost);
-//            // 执行请求
-//            httpclient.executeMethod(xmlpost);
-//
-//            // 获取返回信息
-//            InputStream ips = xmlpost.getResponseBodyAsStream();
-//            List<Byte> byteList = new ArrayList<Byte>();
-//
-//            int is = 0;
-//            while ((is = ips.read()) != -1)
-//                byteList.add((byte) is);
-//
-//            byte[] allb = new byte[byteList.size()];
-//            for (int j = 0; j < byteList.size(); j++)
-//                allb[j] = byteList.get(j);
-//            String responseString = new String(allb, charset);
-//            // LogWriter.debug(this, "HTTP返回码=" + responseStatCode);
-//            System.out.println("应答数据=" + responseString);
-//
-//            if (url.indexOf("https://") != -1)
-//                Protocol.unregisterProtocol("https");
-//            return responseString;
-//        } catch (IOException ex2) {
-//            ex2.printStackTrace();
-//            System.out.println("报文发送到[" + url + "]失败:" + ex2.getMessage());
-//            throw new Exception("报文发送异常");
-//        } catch (Exception ex) {
-//            ex.printStackTrace();
-//            System.out.println("报文发送到[" + url + "]失败:" + ex.getMessage());
-//            throw new Exception("报文发送异常");
-//        } finally {
-//            try {
-//                if(xmlpost != null)
-//                    xmlpost.releaseConnection();
-//                if(httpclient != null)
-//                    httpclient.getHttpConnectionManager().closeIdleConnections(0);
-//            } catch (Exception e) {
-//                e.printStackTrace();
-//            }
-//        }
-//    }
+    private String post(PostMethodCallback callback) throws Exception {
+        PostMethod xmlpost = null;
+        HttpClient httpclient = new HttpClient();
+        try {
+            // https设置
+            if (url.indexOf("https://") != -1) {
+                // 创建SSL连接
+                @SuppressWarnings("deprecation")
+                Protocol myhttps = new Protocol("https",
+                        new MySSLSocketFactory(), 443);
+                Protocol.registerProtocol("https", myhttps);
+            }
+            httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(60 * 1000);
+            httpclient.getHttpConnectionManager().getParams().setSoTimeout(60 * 1000);
+            xmlpost = new PostMethod(url);
+            httpclient.getParams().setParameter(
+                    HttpMethodParams.HTTP_CONTENT_CHARSET, charset);
+            httpclient.getParams().setContentCharset(charset);
+            // xmlpost.setRequestHeader("content-type", "text/xml; charset=" +
+            // charset);
+
+            // 内部回调，发送数据，设置参数用
+            callback.doInPostMethod(xmlpost);
+            // 执行请求
+            httpclient.executeMethod(xmlpost);
+
+            // 获取返回信息
+            InputStream ips = xmlpost.getResponseBodyAsStream();
+            List<Byte> byteList = new ArrayList<Byte>();
+
+            int is = 0;
+            while ((is = ips.read()) != -1)
+                byteList.add((byte) is);
+
+            byte[] allb = new byte[byteList.size()];
+            for (int j = 0; j < byteList.size(); j++)
+                allb[j] = byteList.get(j);
+            String responseString = new String(allb, charset);
+            // LogWriter.debug(this, "HTTP返回码=" + responseStatCode);
+            System.out.println("应答数据=" + responseString);
+
+            if (url.indexOf("https://") != -1)
+                Protocol.unregisterProtocol("https");
+            return responseString;
+        } catch (IOException ex2) {
+            ex2.printStackTrace();
+            System.out.println("报文发送到[" + url + "]失败:" + ex2.getMessage());
+            throw new Exception("报文发送异常");
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            System.out.println("报文发送到[" + url + "]失败:" + ex.getMessage());
+            throw new Exception("报文发送异常");
+        } finally {
+            try {
+                if(xmlpost != null)
+                    xmlpost.releaseConnection();
+                if(httpclient != null)
+                    httpclient.getHttpConnectionManager().closeIdleConnections(0);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
 
     /**
      * PostMethod回调处理