格式化开放平台模块代码

Author: binarywang

weixin-java-open/src/main/java/me/chanjar/weixin/open/api/WxOpenComponentService.java

@@ -34,6 +34,7 @@ public interface WxOpenComponentService {
    * 刷新oauth2的access token
    */
   String OAUTH2_REFRESH_TOKEN_URL = "https://api.weixin.qq.com/sns/oauth2/refresh_token?appid=%s&grant_type=refresh_token&refresh_token=%s&component_appid==%s";
+
   WxMpService getWxMpServiceByAppid(String appid);
 
   WxOpenConfigStorage getWxOpenConfigStorage();

weixin-java-open/src/main/java/me/chanjar/weixin/open/api/WxOpenConfigStorage.java

@@ -9,29 +9,39 @@
  */
 public interface WxOpenConfigStorage {
 
+  String getComponentAppId();
+
   void setComponentAppId(String componentAppId);
 
+  String getComponentAppSecret();
+
   void setComponentAppSecret(String componentAppSecret);
 
+  String getComponentToken();
+
   void setComponentToken(String componentToken);
 
+  String getComponentAesKey();
+
   void setComponentAesKey(String componentAesKey);
 
-  String getComponentAppId();
-  String getComponentAppSecret();
-  String getComponentToken();
-  String getComponentAesKey();
   String getComponentVerifyTicket();
+
   void setComponentVerifyTicket(String componentVerifyTicket);
+
   String getComponentAccessToken();
+
   boolean isComponentAccessTokenExpired();
+
   void updateComponentAccessTokent(WxOpenComponentAccessToken componentAccessToken);
+
   WxMpConfigStorage getWxMpConfigStorage(String appId);
+
   /**
    * 应该是线程安全的
    *
-   * @param componentAccessToken      新的accessToken值
-   * @param expiresInSeconds 过期时间，以秒为单位
+   * @param componentAccessToken 新的accessToken值
+   * @param expiresInSeconds     过期时间，以秒为单位
    */
   void updateComponentAccessTokent(String componentAccessToken, int expiresInSeconds);
 
@@ -42,7 +52,9 @@ public interface WxOpenConfigStorage {
 
 
   String getAuthorizerRefreshToken(String appId);
+
   void setAuthorizerRefreshToken(String appId, String authorizerRefreshToken);
+
   String getAuthorizerAccessToken(String appId);
 
 
@@ -63,8 +75,8 @@ public interface WxOpenConfigStorage {
   /**
    * 应该是线程安全的
    *
-   * @param authorizerAccessToken      新的accessToken值
-   * @param expiresInSeconds 过期时间，以秒为单位
+   * @param authorizerAccessToken 新的accessToken值
+   * @param expiresInSeconds      过期时间，以秒为单位
    */
   void updateAuthorizerAccessToken(String appId, String authorizerAccessToken, int expiresInSeconds);
 

weixin-java-open/src/main/java/me/chanjar/weixin/open/api/WxOpenService.java

@@ -7,8 +7,11 @@
  */
 public interface WxOpenService {
   WxOpenComponentService getWxOpenComponentService();
+
   WxOpenConfigStorage getWxOpenConfigStorage();
+
   void setWxOpenConfigStorage(WxOpenConfigStorage wxOpenConfigStorage);
+
   /**
    * 当本Service没有实现某个API的时候，可以用这个，针对所有微信API中的GET请求
    */

weixin-java-open/src/main/java/me/chanjar/weixin/open/api/impl/WxOpenComponentServiceImpl.java

@@ -30,9 +30,9 @@
  * @author <a href="https://github.com/007gzs">007</a>
  */
 public class WxOpenComponentServiceImpl implements WxOpenComponentService {
+  private static final Map<String, WxMpService> wxOpenMpServiceMap = new Hashtable<>();
   protected final Logger log = LoggerFactory.getLogger(this.getClass());
   private WxOpenService wxOpenService;
-  private static final Map<String, WxMpService> wxOpenMpServiceMap = new Hashtable<>();
 
   public WxOpenComponentServiceImpl(WxOpenService wxOpenService) {
     this.wxOpenService = wxOpenService;
@@ -62,6 +62,7 @@ public WxOpenService getWxOpenService() {
   public WxOpenConfigStorage getWxOpenConfigStorage() {
     return wxOpenService.getWxOpenConfigStorage();
   }
+
   @Override
   public boolean checkSignature(String timestamp, String nonce, String signature) {
     try {
@@ -72,6 +73,7 @@ public boolean checkSignature(String timestamp, String nonce, String signature)
       return false;
     }
   }
+
   @Override
   public String getComponentAccessToken(boolean forceRefresh) throws WxErrorException {
 
@@ -137,6 +139,7 @@ public String route(final WxOpenXmlMessage wxMessage) throws WxErrorException {
     }
     return null;
   }
+
   @Override
   public WxOpenQueryAuthResult getQueryAuth(String authorizationCode) throws WxErrorException {
     JsonObject jsonObject = new JsonObject();
@@ -145,6 +148,7 @@ public WxOpenQueryAuthResult getQueryAuth(String authorizationCode) throws WxErr
     String responseContent = post(API_QUERY_AUTH_URL, jsonObject.toString());
     return WxOpenGsonBuilder.create().fromJson(responseContent, WxOpenQueryAuthResult.class);
   }
+
   @Override
   public WxOpenAuthorizerInfoResult getAuthorizerInfo(String authorizerAppid) throws WxErrorException {
     JsonObject jsonObject = new JsonObject();
@@ -163,6 +167,7 @@ public WxOpenAuthorizerOptionResult getAuthorizerOption(String authorizerAppid,
     String responseContent = post(API_GET_AUTHORIZER_OPTION_URL, jsonObject.toString());
     return WxOpenGsonBuilder.create().fromJson(responseContent, WxOpenAuthorizerOptionResult.class);
   }
+
   @Override
   public WxError setAuthorizerOption(String authorizerAppid, String optionName, String optionValue) throws WxErrorException {
     JsonObject jsonObject = new JsonObject();

weixin-java-open/src/main/java/me/chanjar/weixin/open/api/impl/WxOpenInMemoryConfigStorage.java

@@ -35,42 +35,45 @@ public class WxOpenInMemoryConfigStorage implements WxOpenConfigStorage {
   private Map<String, Token> cardApiTickets = new Hashtable<>();
 
   @Override
-  public void setComponentAppId(String componentAppId) {
-    this.componentAppId = componentAppId;
-  }
-  @Override
-  public void setComponentAppSecret(String componentAppSecret) {
-    this.componentAppSecret = componentAppSecret;
-  }
-  @Override
-  public void setComponentToken(String componentToken) {
-    this.componentToken = componentToken;
-  }
-  @Override
-  public void setComponentAesKey(String componentAesKey) {
-    this.componentAesKey = componentAesKey;
+  public String getComponentAppId() {
+    return componentAppId;
   }
 
   @Override
-  public String getComponentAppId() {
-    return componentAppId;
+  public void setComponentAppId(String componentAppId) {
+    this.componentAppId = componentAppId;
   }
 
   @Override
   public String getComponentAppSecret() {
     return componentAppSecret;
   }
 
+  @Override
+  public void setComponentAppSecret(String componentAppSecret) {
+    this.componentAppSecret = componentAppSecret;
+  }
+
   @Override
   public String getComponentToken() {
     return componentToken;
   }
 
+  @Override
+  public void setComponentToken(String componentToken) {
+    this.componentToken = componentToken;
+  }
+
   @Override
   public String getComponentAesKey() {
     return componentAesKey;
   }
 
+  @Override
+  public void setComponentAesKey(String componentAesKey) {
+    this.componentAesKey = componentAesKey;
+  }
+
   @Override
   public String getComponentVerifyTicket() {
     return componentVerifyTicket;
@@ -111,30 +114,34 @@ public void updateComponentAccessTokent(String componentAccessToken, int expires
   public boolean autoRefreshToken() {
     return true;
   }
-  private String getTokenString(Map<String, Token> map, String key){
+
+  private String getTokenString(Map<String, Token> map, String key) {
     Token token = map.get(key);
-    if(token == null || (token.expiresTime != null && System.currentTimeMillis() > token.expiresTime)){
+    if (token == null || (token.expiresTime != null && System.currentTimeMillis() > token.expiresTime)) {
       return null;
     }
     return token.token;
   }
-  private void expireToken(Map<String, Token> map, String key){
+
+  private void expireToken(Map<String, Token> map, String key) {
     Token token = map.get(key);
-    if(token != null){
+    if (token != null) {
       token.expiresTime = 0L;
     }
   }
-  private void updateToken(Map<String, Token> map, String key, String tokenString, Integer expiresInSeconds){
+
+  private void updateToken(Map<String, Token> map, String key, String tokenString, Integer expiresInSeconds) {
     Token token = map.get(key);
-    if(token == null){
+    if (token == null) {
       token = new Token();
       map.put(key, token);
     }
     token.token = tokenString;
-    if(expiresInSeconds != null) {
+    if (expiresInSeconds != null) {
       token.expiresTime = System.currentTimeMillis() + (expiresInSeconds - 200) * 1000L;
     }
   }
+
   @Override
   public String getAuthorizerRefreshToken(String appId) {
     return getTokenString(authorizerRefreshTokens, appId);
@@ -211,22 +218,21 @@ public void updateCardApiTicket(String appId, String cardApiTicket, int expiresI
     updateToken(cardApiTickets, appId, cardApiTicket, expiresInSeconds);
   }
 
-  private static class Token{
+  private static class Token {
     private String token;
     private Long expiresTime;
   }
-  private static class WxOpenMpConfigStorage implements WxMpConfigStorage{
+
+  private static class WxOpenMpConfigStorage implements WxMpConfigStorage {
     private WxOpenConfigStorage wxOpenConfigStorage;
     private String appId;
-    private WxOpenMpConfigStorage(WxOpenConfigStorage wxOpenConfigStorage, String appId){
-      this.wxOpenConfigStorage = wxOpenConfigStorage;
-      this.appId = appId;
-    }
-
     private Lock accessTokenLock = new ReentrantLock();
     private Lock jsapiTicketLock = new ReentrantLock();
     private Lock cardApiTicketLock = new ReentrantLock();
-
+    private WxOpenMpConfigStorage(WxOpenConfigStorage wxOpenConfigStorage, String appId) {
+      this.wxOpenConfigStorage = wxOpenConfigStorage;
+      this.appId = appId;
+    }
 
     @Override
     public String getAccessToken() {