Merge pull request binarywang#3 from wechat-group/develop

合并代码

Author: aimilin6688

README.md

@@ -1,56 +1,57 @@
 # Weixin Java Tools 微信公众号/企业号开发Java SDK
-## [![Open Source Love](https://badges.frapsoft.com/os/v1/open-source.svg?v=103)](https://github.com/ellerbrock/open-source-badge/)     ![Maven Central](https://img.shields.io/maven-central/v/com.github.binarywang/weixin-java-parent.svg)  [![Build Status](https://travis-ci.org/binarywang/weixin-java-tools.svg?branch=develop)](https://travis-ci.org/binarywang/weixin-java-tools)
+## [![Open Source Love](https://badges.frapsoft.com/os/v1/open-source.svg?v=103)](https://github.com/ellerbrock/open-source-badge/)     ![Maven Central](https://img.shields.io/maven-central/v/com.github.binarywang/weixin-java-parent.svg)  [![Build Status](https://travis-ci.org/wechat-group/weixin-java-tools.svg?branch=develop)](https://travis-ci.org/wechat-group/weixin-java-tools)
 
 
-### 声明：本项目Fork自chanjarster/weixin-java-tools，但由于原项目已停止维护，故单独维护和发布，且发布到maven上的groupId也会不同，详细信息见下文。
+### 注意：
+1. ***本项目Fork自chanjarster/weixin-java-tools，但由于原项目已停止维护，故单独维护和发布，且发布到maven上的groupId也会不同，详细信息见下文。***
+1. ***自2.0.0版本以来，主要是公众号的接口调整比较大，主要是为了解决主接口类过于庞大不方便管理的问题，将接口实现代码按模块进行拆分。***
+1. 最新更新：2016-08-31 发布2.1.0正式版！
 
-### 最新更新：2.1.0版发布！！！ on 2016-08-31
+===========
 
-#### ***自2.0.0版本以来，接口调整比较大，主要是公众号的调整，企业号无过多调整，主要是为了解决主接口类过于庞大不方便管理的问题，将接口实现代码按模块进行拆分。所以如果习惯于1.X.X版本的同学不想做过多更改的话，请慎重考虑升级到2.X.X版本.***
----
+## 开发交流方式：
+1. ***入群须知：为保证入群成员质量，请申请入群前，先Star本项目，然后在申请入群时，输入您的Github帐号ID，以便管理员核对，ID即你的github主页地址https://github.com/XXXX 中最后的部分XXXX的内容，或者在github网页右上角点击头像后查看Signed in as后方内容。***
+1. QQ群：343954419 [![Join QQ Group](http://pub.idqqimg.com/wpa/images/group.png)](http://shang.qq.com/wpa/qunwpa?idkey=078f7a153d243853e24cf2b542e7a6ccbf2a592bc138080f84d11297f736ec46)
+1. 微信群： 因二维码有时间限制，如有想加入微信群的，请入QQ群后咨询获取最新入群二维码；
+1. 有功能需求或由于微信官方接口调整导致的代码问题，可以直接提出issue，便于讨论追踪问题；
+1. 详细开发文档请看 [Wiki](https://github.com/wechat-group/weixin-java-tools/wiki)。
 
-### 详细开发文档请看 [wiki](https://github.com/chanjarster/weixin-java-tools/wiki)。
-===========
-## 开发交流工具：
-* 微信群： 因二维码有时间限制，如有想加入微信群的，请入QQ群后咨询获取最新入群二维码。
-* QQ群：343954419 [![Join QQ Group](http://pub.idqqimg.com/wpa/images/group.png)](http://shang.qq.com/wpa/qunwpa?idkey=078f7a153d243853e24cf2b542e7a6ccbf2a592bc138080f84d11297f736ec46)
-* ***注意：为保证入群成员质量，请申请入群前，先Star本项目，然后在申请入群时，输入您的Github帐号ID，以便管理员核对，ID即你的github主页地址https://github.com/XXXX 中最后的部分XXXX的内容，或者在github网页右上角点击头像查看，如下图Signed in as下方黄色标识内容即是：***
-* ![github_id](https://raw.githubusercontent.com/wechat-group/weixin-java-tools/develop/res/github_id.png)
- 
 ===========
 
 ## 版本说明
-* 本项目定为每月发布一次正式版，版本号格式为X.X.0（如2.0.0，2.1.0等），月初或月底发布新版本，遇到重大问题需修复会及时提交新版本，欢迎大家随时提交Pull Request。
-* BUG修复和新特性一般会先发布成小版本作为临时版本（如2.0.1，2.0.2等，即尾号不为0，以区别于正式版）。
-* 目前最新版本号为 ![Maven Central](https://img.shields.io/maven-central/v/com.github.binarywang/weixin-java-parent.svg) ，也可以通过访问如下地址查看所有最新的版本：
-- [【公众号】](http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22com.github.binarywang%22%20AND%20a%3A%22weixin-java-mp%22)
-- [【企业号】](http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22com.github.binarywang%22%20AND%20a%3A%22weixin-java-cp%22)
-
+* 本项目定为每月发布一次正式版，版本号格式为X.X.0（如2.0.0，2.1.0等），月初或月底发布新版本，遇到重大问题需修复会及时提交新版本，欢迎大家随时提交Pull Request；
+* BUG修复和新特性一般会先发布成小版本作为临时版本（如2.0.1，2.0.2等，即尾号不为0，以区别于正式版）；
+* 目前最新版本号为 ![Maven Central](https://img.shields.io/maven-central/v/com.github.binarywang/weixin-java-parent.svg) ，也可以通过访问链接[【公众号】](http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22com.github.binarywang%22%20AND%20a%3A%22weixin-java-mp%22) 、[【企业号】](http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22com.github.binarywang%22%20AND%20a%3A%22weixin-java-cp%22)
+分别查看所有最新的版本。 
 
 ## Maven & Gradle
 
 * 公众号（订阅号、服务号）：
+
+maven：
 ```xml
 <dependency>
   <groupId>com.github.binarywang</groupId>
   <artifactId>weixin-java-mp</artifactId>
   <version>2.1.0</version>
 </dependency>
 ```
-
+gradle：
 ```groovy
 compile 'com.github.binarywang:weixin-java-mp:2.1.0'
 ```
 
 * 企业号：
+
+maven：
 ```xml
 <dependency>
   <groupId>com.github.binarywang</groupId>
   <artifactId>weixin-java-cp</artifactId>
   <version>2.1.0</version>
 </dependency>
 ```
-
+gradle：
 ```groovy
 compile 'com.github.binarywang:weixin-java-cp:2.1.0'
 ```
@@ -63,16 +64,14 @@ compile 'com.github.binarywang:weixin-java-cp:2.1.0'
 * https://git.coding.net/binarywang/weixin-java-tools.git
 
 
-## 目前可参考的Demo项目:
-* https://github.com/wechat-group/weixin-java-tools-springmvc
-* https://github.com/wechat-group/weixin-mp-demo
-* ===========以下为备份仓库，会保持跟主仓库同步
-* http://git.oschina.net/binary/weixin-mp-demo
-* https://bitbucket.org/binarywang/weixin-mp-demo
+## 目前可参考的Demo项目有两个:
+1. https://github.com/wechat-group/weixin-mp-demo
+1. https://github.com/wechat-group/weixin-java-tools-springmvc
 
 ## 关于代码贡献
+* 非常欢迎和感谢对本项目发起Pull Request的同学，本项目代码风格为使用2个空格代表一个Tab，因此在提交代码时请注意一下，否则很容易在IDE格式化代码后与原代码产生大量diff，这样会给其他人阅读代码带来极大的困扰。
+* 为了便于设置，本项目引入editorconfig插件，请使用eclipse的同学在贡献代码前安装相关插件，IntelliJ IDEA则自带支持，无需额外安装插件。
+* 本项目可以采用两种方式接受代码贡献：
 
-* 非常欢迎和感谢对本项目发起Pull Request的同学，本项目可以采用两种方式接受代码贡献：
-* 第一种就是基于[Git Flow](https://www.atlassian.com/git/tutorials/comparing-workflows/gitflow-workflow)开发流程，因此在发起Pull Request的时候请选择develop分支。
-* 另外一种贡献代码的方式就是加入SDK Developers开发组，如果对自己的代码足够自信，可以随时提交代码，注意要随时进行单元测试，保证提交代码没有明显问题，具体加入方式，请咨询管理员。
-* 本项目代码风格为使用2个空格代表一个Tab，因此在提交代码时请注意一下，否则很容易在IDE格式化代码后与原代码产生大量diff，这样会给其他人阅读代码带来极大的困扰。
+1. 第一种就是基于[Git Flow](https://www.atlassian.com/git/tutorials/comparing-workflows/gitflow-workflow)开发流程，因此在发起Pull Request的时候请选择develop分支。
+1. 另外一种贡献代码的方式就是加入SDK Developers开发组，如果对自己的代码足够自信，可以随时提交代码，注意要随时进行单元测试，保证提交代码没有明显问题，具体加入方式，请咨询管理员。

build.gradle

@@ -13,8 +13,8 @@ subprojects {
 
   repositories {
     mavenLocal()
-
-    maven { url "http://maven.aliyun.com/nexus/content/groups/public" }
+    maven { url "http://central.maven.org/maven2" }
+    //maven { url "http://maven.aliyun.com/nexus/content/groups/public" }
   }
 
 
@@ -24,6 +24,8 @@ subprojects {
     compile group: 'org.apache.httpcomponents', name: 'httpmime', version:'4.5'
     compile group: 'org.jodd', name: 'jodd-http', version:'3.6.7'
     compile group: 'com.google.code.gson', name: 'gson', version:'2.7'
+    compile group: 'com.google.guava', name: 'guava', version:'19.0'
+    compile group: 'org.jooq', name: 'joor', version:'0.9.6'
     compile group: 'commons-codec', name: 'commons-codec', version:'1.10'
     compile group: 'commons-io', name: 'commons-io', version:'2.5'
     compile group: 'org.apache.commons', name: 'commons-lang3', version:'3.4'

pom.xml

@@ -51,6 +51,8 @@
     <jodd-http.version>3.6.7</jodd-http.version>
     <jedis.version>2.9.0</jedis.version>
     <gson.version>2.7</gson.version>
+    <guava.version>19.0</guava.version>
+    <joor.version>0.9.6</joor.version>
     <commons-lang3.version>3.4</commons-lang3.version>
     <commons-io.version>2.5</commons-io.version>
     <commons-codec.version>1.10</commons-codec.version>
@@ -111,6 +113,14 @@
       <version>${jedis.version}</version>
       <scope>provided</scope>
     </dependency>
+    <dependency>
+      <groupId>com.google.guava</groupId>
+      <artifactId>guava</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.jooq</groupId>
+      <artifactId>joor</artifactId>
+    </dependency>
   </dependencies>
 
   <dependencyManagement>
@@ -151,6 +161,16 @@
         <version>${jetty.version}</version>
         <scope>test</scope>
       </dependency>
+      <dependency>
+        <groupId>com.google.guava</groupId>
+        <artifactId>guava</artifactId>
+        <version>${guava.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.jooq</groupId>
+        <artifactId>joor</artifactId>
+        <version>${joor.version}</version>
+      </dependency>
     </dependencies>
   </dependencyManagement>
 

res/github_id.png

@@ -0,0 +1,19 @@
+package me.chanjar.weixin.common.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * 标识某个字段是否是必填的
+ * 
+ * Created by Binary Wang on 2016/9/25.
+ * @author binarywang (https://github.com/binarywang)
+ *
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.FIELD)
+public @interface Required {
+
+}

weixin-java-common/src/main/java/me/chanjar/weixin/common/annotation/Required.java

@@ -30,6 +30,7 @@ public class WxConsts {
   public static final String CUSTOM_MSG_MUSIC = "music";
   public static final String CUSTOM_MSG_NEWS = "news";
   public static final String CUSTOM_MSG_FILE = "file";
+  public static final String CUSTOM_MSG_WXCARD = "wxcard";
   public static final String CUSTOM_MSG_TRANSFER_CUSTOMER_SERVICE = "transfer_customer_service";
   public static final String CUSTOM_MSG_SAFE_NO = "0";
   public static final String CUSTOM_MSG_SAFE_YES = "1";

weixin-java-common/src/main/java/me/chanjar/weixin/common/api/WxConsts.java

@@ -19,14 +19,8 @@
 
 import java.io.StringReader;
 import java.nio.charset.Charset;
-import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
 import java.util.Random;
-import java.util.SortedMap;
-import java.util.TreeMap;
 
 import javax.crypto.Cipher;
 import javax.crypto.spec.IvParameterSpec;
@@ -36,7 +30,6 @@
 import javax.xml.parsers.ParserConfigurationException;
 
 import org.apache.commons.codec.binary.Base64;
-import org.apache.commons.codec.digest.DigestUtils;
 import org.w3c.dom.Document;
 import org.w3c.dom.Element;
 import org.xml.sax.InputSource;
@@ -79,33 +72,6 @@ public WxCryptUtil(String token, String encodingAesKey,
     this.aesKey = Base64.decodeBase64(encodingAesKey + "=");
   }
 
-  /**
-   * 微信公众号支付签名算法(详见:http://pay.weixin.qq.com/wiki/doc/api/index.php?chapter=4_3)
-   * @param packageParams 原始参数
-   * @param signKey 加密Key(即 商户Key)
-   * @return 签名字符串
-   */
-  public static String createSign(Map<String, String> packageParams,
-                                  String signKey) {
-    SortedMap<String, String> sortedMap = new TreeMap<>();
-    sortedMap.putAll(packageParams);
-
-    List<String> keys = new ArrayList<>(packageParams.keySet());
-    Collections.sort(keys);
-
-    StringBuffer toSign = new StringBuffer();
-    for (String key : keys) {
-      String value = packageParams.get(key);
-      if (null != value && !"".equals(value) && !"sign".equals(key)
-              && !"key".equals(key)) {
-        toSign.append(key + "=" + value + "&");
-      }
-    }
-    toSign.append("key=" + signKey);
-    String sign = DigestUtils.md5Hex(toSign.toString()).toUpperCase();
-    return sign;
-  }
-
   static String extractEncryptPart(String xml) {
     try {
       DocumentBuilder db = builderLocal.get();

weixin-java-common/src/main/java/me/chanjar/weixin/common/util/crypto/WxCryptUtil.java

@@ -1,11 +1,9 @@
 package me.chanjar.weixin.common.util.http;
 
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
+import me.chanjar.weixin.common.bean.result.WxError;
+import me.chanjar.weixin.common.exception.WxErrorException;
+import me.chanjar.weixin.common.util.StringUtils;
+import me.chanjar.weixin.common.util.fs.FileUtils;
 import org.apache.http.Header;
 import org.apache.http.HttpHost;
 import org.apache.http.client.config.RequestConfig;
@@ -14,30 +12,28 @@
 import org.apache.http.entity.ContentType;
 import org.apache.http.impl.client.CloseableHttpClient;
 
-import me.chanjar.weixin.common.bean.result.WxError;
-import me.chanjar.weixin.common.exception.WxErrorException;
-import me.chanjar.weixin.common.util.StringUtils;
-import me.chanjar.weixin.common.util.fs.FileUtils;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 /**
  * 下载媒体文件请求执行器，请求的参数是String, 返回的结果是File
- *
+ * 视频文件不支持下载
  * @author Daniel Qian
  */
 public class MediaDownloadRequestExecutor implements RequestExecutor<File, String> {
 
   private File tmpDirFile;
 
   public MediaDownloadRequestExecutor() {
-    super();
   }
 
   public MediaDownloadRequestExecutor(File tmpDirFile) {
-    super();
     this.tmpDirFile = tmpDirFile;
   }
 
-
   @Override
   public File execute(CloseableHttpClient httpclient, HttpHost httpProxy, String uri, String queryParam) throws WxErrorException, IOException {
     if (queryParam != null) {
@@ -59,34 +55,39 @@ public File execute(CloseableHttpClient httpclient, HttpHost httpProxy, String u
 
       Header[] contentTypeHeader = response.getHeaders("Content-Type");
       if (contentTypeHeader != null && contentTypeHeader.length > 0) {
-        // 下载媒体文件出错
-        if (ContentType.TEXT_PLAIN.getMimeType().equals(contentTypeHeader[0].getValue())) {
+        if (contentTypeHeader[0].getValue().startsWith(ContentType.APPLICATION_JSON.getMimeType())) {
+          // application/json; encoding=utf-8 下载媒体文件出错
           String responseContent = Utf8ResponseHandler.INSTANCE.handleResponse(response);
           throw new WxErrorException(WxError.fromJson(responseContent));
         }
       }
-      // 视频文件不支持下载
+
       String fileName = getFileName(response);
       if (StringUtils.isBlank(fileName)) {
         return null;
       }
-      String[] name_ext = fileName.split("\\.");
-      File localFile = FileUtils.createTmpFile(inputStream, name_ext[0], name_ext[1], this.tmpDirFile);
-      return localFile;
+
+      String[] nameAndExt = fileName.split("\\.");
+      return FileUtils.createTmpFile(inputStream, nameAndExt[0], nameAndExt[1], this.tmpDirFile);
 
     } finally {
       httpGet.releaseConnection();
     }
 
   }
 
-  protected String getFileName(CloseableHttpResponse response) {
+  private String getFileName(CloseableHttpResponse response) throws WxErrorException {
     Header[] contentDispositionHeader = response.getHeaders("Content-disposition");
+    if(contentDispositionHeader == null || contentDispositionHeader.length == 0){
+      throw new WxErrorException(WxError.newBuilder().setErrorMsg("无法获取到文件名").build());
+    }
+
     Pattern p = Pattern.compile(".*filename=\"(.*)\"");
     Matcher m = p.matcher(contentDispositionHeader[0].getValue());
-    m.matches();
-    String fileName = m.group(1);
-    return fileName;
+    if(m.matches()){
+      return m.group(1);
+    }
+    throw new WxErrorException(WxError.newBuilder().setErrorMsg("无法获取到文件名").build());
   }
 
 }

weixin-java-common/src/main/java/me/chanjar/weixin/common/util/http/MediaDownloadRequestExecutor.java

@@ -2,7 +2,6 @@
 
 import me.chanjar.weixin.common.exception.WxErrorException;
 import org.apache.http.HttpHost;
-import org.apache.http.client.ClientProtocolException;
 import org.apache.http.impl.client.CloseableHttpClient;
 
 import java.io.IOException;
@@ -21,7 +20,6 @@ public interface RequestExecutor<T, E> {
    * @param uri        uri
    * @param data       数据
    * @throws WxErrorException
-   * @throws ClientProtocolException
    * @throws IOException
    */
   T execute(CloseableHttpClient httpclient, HttpHost httpProxy, String uri, E data) throws WxErrorException, IOException;