增加debug日志

Author: lianup

src/main/java/com/wechat/pay/contrib/apache/httpclient/SignatureExec.java

@@ -4,7 +4,9 @@
 import static org.apache.http.HttpStatus.SC_MULTIPLE_CHOICES;
 import static org.apache.http.HttpStatus.SC_OK;
 
+import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.util.Arrays;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpEntityEnclosingRequest;
 import org.apache.http.HttpException;
@@ -16,13 +18,16 @@
 import org.apache.http.conn.routing.HttpRoute;
 import org.apache.http.entity.BufferedHttpEntity;
 import org.apache.http.impl.execchain.ClientExecChain;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * @author xy-peng
  */
 public class SignatureExec implements ClientExecChain {
 
     private static final String WECHAT_PAY_HOST_NAME_SUFFIX = ".mch.weixin.qq.com";
+    private static final Logger log = LoggerFactory.getLogger(SignatureExec.class);
     private final ClientExecChain mainExec;
     private final Credentials credentials;
     private final Validator validator;
@@ -41,11 +46,9 @@ protected void convertToRepeatableResponseEntity(CloseableHttpResponse response)
     }
 
     protected void convertToRepeatableRequestEntity(HttpRequestWrapper request) throws IOException {
-        if (request instanceof HttpEntityEnclosingRequest) {
-            HttpEntity entity = ((HttpEntityEnclosingRequest) request).getEntity();
-            if (entity != null) {
-                ((HttpEntityEnclosingRequest) request).setEntity(new BufferedHttpEntity(entity));
-            }
+        HttpEntity entity = getRequestEntity(request);
+        if (entity != null) {
+            ((HttpEntityEnclosingRequest) request).setEntity(new BufferedHttpEntity(entity));
         }
     }
 
@@ -59,26 +62,45 @@ public CloseableHttpResponse execute(HttpRoute route, HttpRequestWrapper request
         }
     }
 
+    private HttpEntity getRequestEntity(HttpRequestWrapper request) {
+        HttpEntity entity = null;
+        if (request instanceof HttpEntityEnclosingRequest) {
+            entity = ((HttpEntityEnclosingRequest) request).getEntity();
+        }
+        return entity;
+    }
+
+    private boolean isUploadHttpPost(HttpRequestWrapper request) {
+        return request.getOriginal() instanceof WechatPayUploadHttpPost;
+    }
+
     private CloseableHttpResponse executeWithSignature(HttpRoute route, HttpRequestWrapper request,
             HttpClientContext context,
             HttpExecutionAware execAware) throws IOException, HttpException {
         // 上传类不需要消耗两次故不做转换
-        if (!(request.getOriginal() instanceof WechatPayUploadHttpPost)) {
+        if (!isUploadHttpPost(request)) {
             convertToRepeatableRequestEntity(request);
         }
         // 添加认证信息
         request.addHeader(AUTHORIZATION, credentials.getSchema() + " " + credentials.getToken(request));
-
         // 执行
         CloseableHttpResponse response = mainExec.execute(route, request, context, execAware);
-
         // 对成功应答验签
         StatusLine statusLine = response.getStatusLine();
         if (statusLine.getStatusCode() >= SC_OK && statusLine.getStatusCode() < SC_MULTIPLE_CHOICES) {
             convertToRepeatableResponseEntity(response);
             if (!validator.validate(response)) {
                 throw new HttpException("应答的微信支付签名验证失败");
             }
+        } else {
+            // 错误应答需要打日志
+            log.debug("request header[{}]", Arrays.toString(request.getAllHeaders()));
+            HttpEntity entity = getRequestEntity(request);
+            if (entity != null && !isUploadHttpPost(request)) {
+                ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+                entity.writeTo(outputStream);
+                log.debug("request body[{}]", outputStream.toString("UTF-8"));
+            }
         }
         return response;
     }

src/main/java/com/wechat/pay/contrib/apache/httpclient/WechatPayUploadHttpPost.java

@@ -6,17 +6,21 @@
 import java.io.InputStream;
 import java.net.URI;
 import java.net.URLConnection;
+import org.apache.http.HttpEntity;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.entity.ContentType;
 import org.apache.http.entity.mime.HttpMultipartMode;
 import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * @author xy-peng
  */
 public class WechatPayUploadHttpPost extends HttpPost {
 
     private final String meta;
+    private static final Logger log = LoggerFactory.getLogger(WechatPayUploadHttpPost.class);
 
     private WechatPayUploadHttpPost(URI uri, String meta) {
         super(uri);
@@ -80,10 +84,12 @@ public WechatPayUploadHttpPost build() {
             WechatPayUploadHttpPost request = new WechatPayUploadHttpPost(uri, meta);
             MultipartEntityBuilder entityBuilder = MultipartEntityBuilder.create();
             entityBuilder.setMode(HttpMultipartMode.RFC6532)
-                    .addBinaryBody("file", fileInputStream, fileContentType, fileName)
-                    .addTextBody("meta", meta, APPLICATION_JSON);
-            request.setEntity(entityBuilder.build());
+                    .addTextBody("meta", meta, APPLICATION_JSON)
+                    .addBinaryBody("file", fileInputStream, fileContentType, fileName);
+            HttpEntity entity = entityBuilder.build();
+            request.setEntity(entity);
             request.addHeader(ACCEPT, APPLICATION_JSON.toString());
+            log.debug("request[{}]", entity.getContentType());
             return request;
         }
     }

src/main/java/com/wechat/pay/contrib/apache/httpclient/auth/CertificatesVerifier.java

@@ -13,12 +13,15 @@
 import java.util.List;
 import java.util.Map;
 import java.util.NoSuchElementException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * @author xy-peng
  */
 public class CertificatesVerifier implements Verifier {
 
+    private static final Logger log = LoggerFactory.getLogger(CertificatesVerifier.class);
     protected final HashMap<BigInteger, X509Certificate> certificates = new HashMap<>();
 
     public CertificatesVerifier(List<X509Certificate> list) {
@@ -57,7 +60,11 @@ protected boolean verify(X509Certificate certificate, byte[] message, String sig
     public boolean verify(String serialNumber, byte[] message, String signature) {
         BigInteger val = new BigInteger(serialNumber, 16);
         X509Certificate cert = certificates.get(val);
-        return cert != null && verify(cert, message, signature);
+        if (cert == null) {
+            log.debug("Cert is null.serialNumber:{}", serialNumber);
+            return false;
+        }
+        return verify(cert, message, signature);
     }
 
     @Override