多公众号支持改造

Author: binarywang

README.md

@@ -5,9 +5,23 @@
 -----------------------
 
 ## 使用步骤：
-1. 配置：复制 `/src/main/resources/application.yml.template` 或修改其扩展名生成 `application.yml` 文件，根据自己需要填写相关配置（需要注意的是：yml文件内的属性冒号后面的文字之前需要加空格，可参考已有配置，否则属性会设置不成功）；	
-1. 运行Java程序：`WxMpDemoApplication`；
-1. 打开shell或cmd，进入ngrok目录，运行 `ngrok -config ngrok.cfg -subdomain my-domain 8080` 如果运行失败，请更换my-domain为其它字符串，直至连接成功；
-1. 配置微信公众号中的接口地址：http://my-domain.tunnel.qydev.com/wechat/portal （注意my-domain要跟上面的一致，需要符合微信官方的要求）；
-1. 根据自己需要修改各个handler的实现，加入自己的业务逻辑。
+1. 配置：复制 `/src/main/resources/application.yml.template` 或修改其扩展名生成 `application.yml` 文件，根据自己需要填写相关配置（需要注意的是：yml文件内的属性冒号后面的文字之前需要加空格，可参考已有配置，否则属性会设置不成功）；
+2. 主要配置说明如下：
+```
+wx:
+  mp:
+    configs:
+      - appId: 1111 （一个公众号的appid）
+        secret: 1111（公众号的appsecret）
+        token: 111 （接口配置里的Token值）
+        aesKey: 111 （接口配置里的EncodingAESKey值）
+      - appId: 2222 （另一个公众号的appid，以下同上）
+        secret: 1111
+        token: 111
+        aesKey: 111
+```
+3. 运行Java程序：`WxMpDemoApplication`；
+4. 打开shell或cmd，进入ngrok目录，运行 `ngrok -config ngrok.cfg -subdomain my-domain 8080` 如果运行失败，请更换my-domain为其它字符串，直至连接成功；
+5. 配置微信公众号中的接口地址：http://my-domain.tunnel.qydev.com/wx/portal/xxxxx （注意xxxxx为对应公众号的appid值，my-domain要跟上面的一致，需要符合微信官方的要求）；
+6. 根据自己需要修改各个handler的实现，加入自己的业务逻辑。
 

src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpConfiguration.java

@@ -1,19 +1,20 @@
 package com.github.binarywang.demo.wx.mp.config;
 
 import com.github.binarywang.demo.wx.mp.handler.*;
-import me.chanjar.weixin.mp.api.WxMpConfigStorage;
+import com.google.common.collect.Maps;
 import me.chanjar.weixin.mp.api.WxMpInMemoryConfigStorage;
 import me.chanjar.weixin.mp.api.WxMpMessageRouter;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
 import me.chanjar.weixin.mp.constant.WxMpEventConstants;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.Map;
+import java.util.stream.Collectors;
+
 import static me.chanjar.weixin.common.api.WxConsts.*;
 
 /**
@@ -22,55 +23,72 @@
  * @author Binary Wang(https://github.com/binarywang)
  */
 @Configuration
-@ConditionalOnClass(WxMpService.class)
 @EnableConfigurationProperties(WxMpProperties.class)
 public class WxMpConfiguration {
-    @Autowired
-    protected LogHandler logHandler;
-    @Autowired
-    protected NullHandler nullHandler;
-    @Autowired
-    protected KfSessionHandler kfSessionHandler;
-    @Autowired
-    protected StoreCheckNotifyHandler storeCheckNotifyHandler;
-    @Autowired
-    private WxMpProperties properties;
-    @Autowired
+    private LogHandler logHandler;
+    private NullHandler nullHandler;
+    private KfSessionHandler kfSessionHandler;
+    private StoreCheckNotifyHandler storeCheckNotifyHandler;
     private LocationHandler locationHandler;
-    @Autowired
     private MenuHandler menuHandler;
-    @Autowired
     private MsgHandler msgHandler;
-    @Autowired
     private UnsubscribeHandler unsubscribeHandler;
-    @Autowired
     private SubscribeHandler subscribeHandler;
 
-    @Bean
-    @ConditionalOnMissingBean
-    public WxMpConfigStorage configStorage() {
-        WxMpInMemoryConfigStorage configStorage = new WxMpInMemoryConfigStorage();
-        configStorage.setAppId(this.properties.getAppId());
-        configStorage.setSecret(this.properties.getSecret());
-        configStorage.setToken(this.properties.getToken());
-        configStorage.setAesKey(this.properties.getAesKey());
-        return configStorage;
+    private WxMpProperties properties;
+
+    private static Map<String, WxMpMessageRouter> routers = Maps.newHashMap();
+    private static Map<String, WxMpService> mpServices = Maps.newHashMap();
+
+    @Autowired
+    public WxMpConfiguration(LogHandler logHandler, NullHandler nullHandler, KfSessionHandler kfSessionHandler,
+                             StoreCheckNotifyHandler storeCheckNotifyHandler, LocationHandler locationHandler,
+                             MenuHandler menuHandler, MsgHandler msgHandler, UnsubscribeHandler unsubscribeHandler,
+                             SubscribeHandler subscribeHandler, WxMpProperties properties) {
+        this.logHandler = logHandler;
+        this.nullHandler = nullHandler;
+        this.kfSessionHandler = kfSessionHandler;
+        this.storeCheckNotifyHandler = storeCheckNotifyHandler;
+        this.locationHandler = locationHandler;
+        this.menuHandler = menuHandler;
+        this.msgHandler = msgHandler;
+        this.unsubscribeHandler = unsubscribeHandler;
+        this.subscribeHandler = subscribeHandler;
+        this.properties = properties;
     }
 
-    @Bean
-    @ConditionalOnMissingBean
-    public WxMpService wxMpService(WxMpConfigStorage configStorage) {
-        // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceOkHttpImpl();
-        // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceJoddHttpImpl();
-        // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceHttpClientImpl();
-
-        WxMpService wxMpService = new WxMpServiceImpl();
-        wxMpService.setWxMpConfigStorage(configStorage);
-        return wxMpService;
+    public static Map<String, WxMpMessageRouter> getRouters() {
+        return routers;
+    }
+
+    public static Map<String, WxMpService> getMpServices() {
+        return mpServices;
     }
 
     @Bean
-    public WxMpMessageRouter router(WxMpService wxMpService) {
+    public Object services() {
+        mpServices = this.properties.getConfigs()
+            .stream()
+            .map(a -> {
+                WxMpInMemoryConfigStorage configStorage = new WxMpInMemoryConfigStorage();
+                configStorage.setAppId(a.getAppId());
+                configStorage.setSecret(a.getSecret());
+                configStorage.setToken(a.getToken());
+                configStorage.setAesKey(a.getAesKey());
+
+                // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceOkHttpImpl();
+                // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceJoddHttpImpl();
+                // WxMpService wxMpService = new me.chanjar.weixin.mp.api.impl.WxMpServiceHttpClientImpl();
+                WxMpService service = new WxMpServiceImpl();
+                service.setWxMpConfigStorage(configStorage);
+                routers.put(a.getAppId(), this.newRouter(service));
+                return service;
+            }).collect(Collectors.toMap(s -> s.getWxMpConfigStorage().getAppId(), a -> a));
+
+        return Boolean.TRUE;
+    }
+
+    private WxMpMessageRouter newRouter(WxMpService wxMpService) {
         final WxMpMessageRouter newRouter = new WxMpMessageRouter(wxMpService);
 
         // 记录所有事件的日志 （异步执行）

src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpProperties.java

@@ -1,67 +1,42 @@
 package com.github.binarywang.demo.wx.mp.config;
 
 import com.github.binarywang.demo.wx.mp.utils.JsonUtils;
-import org.apache.commons.lang3.builder.ToStringBuilder;
-import org.apache.commons.lang3.builder.ToStringStyle;
+import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.List;
+
 /**
  * wechat mp properties
  *
  * @author Binary Wang(https://github.com/binarywang)
  */
+@Data
 @ConfigurationProperties(prefix = "wx.mp")
 public class WxMpProperties {
-    /**
-     * 设置微信公众号的appid
-     */
-    private String appId;
-
-    /**
-     * 设置微信公众号的app secret
-     */
-    private String secret;
-
-    /**
-     * 设置微信公众号的token
-     */
-    private String token;
-
-    /**
-     * 设置微信公众号的EncodingAESKey
-     */
-    private String aesKey;
-
-    public String getAppId() {
-        return this.appId;
-    }
-
-    public void setAppId(String appId) {
-        this.appId = appId;
-    }
-
-    public String getSecret() {
-        return this.secret;
-    }
-
-    public void setSecret(String secret) {
-        this.secret = secret;
-    }
-
-    public String getToken() {
-        return this.token;
-    }
-
-    public void setToken(String token) {
-        this.token = token;
-    }
-
-    public String getAesKey() {
-        return this.aesKey;
-    }
-
-    public void setAesKey(String aesKey) {
-        this.aesKey = aesKey;
+    private List<MpConfig> configs;
+
+    @Data
+    public static class MpConfig {
+        /**
+         * 设置微信公众号的appid
+         */
+        private String appId;
+
+        /**
+         * 设置微信公众号的app secret
+         */
+        private String secret;
+
+        /**
+         * 设置微信公众号的token
+         */
+        private String token;
+
+        /**
+         * 设置微信公众号的EncodingAESKey
+         */
+        private String aesKey;
     }
 
     @Override

src/main/java/com/github/binarywang/demo/wx/mp/controller/WxMenuController.java

@@ -1,31 +1,21 @@
 package com.github.binarywang.demo.wx.mp.controller;
 
+import com.github.binarywang.demo.wx.mp.config.WxMpConfiguration;
 import me.chanjar.weixin.common.bean.menu.WxMenu;
 import me.chanjar.weixin.common.bean.menu.WxMenuButton;
 import me.chanjar.weixin.common.error.WxErrorException;
-import me.chanjar.weixin.mp.api.WxMpMenuService;
-import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.menu.WxMpGetSelfMenuInfoResult;
 import me.chanjar.weixin.mp.bean.menu.WxMpMenu;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import static me.chanjar.weixin.common.api.WxConsts.MenuButtonType;
 
 /**
- * <pre>
- *  注意：此contorller 实现WxMpMenuService接口，仅是为了演示如何调用所有菜单相关操作接口，
- *      实际项目中无需这样，根据自己需要添加对应接口即可
- * </pre>
- *
  * @author Binary Wang(https://github.com/binarywang)
  */
 @RestController
-@RequestMapping("/wechat/menu")
-public class WxMenuController implements WxMpMenuService {
-
-    @Autowired
-    private WxMpService wxService;
+@RequestMapping("/wx/menu/{appid}")
+public class WxMenuController {
 
     /**
      * <pre>
@@ -35,17 +25,15 @@ public class WxMenuController implements WxMpMenuService {
      * 详情请见：https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1455782296&token=&lang=zh_CN
      * </pre>
      *
-     * @param menu
      * @return 如果是个性化菜单，则返回menuid，否则返回null
      */
-    @Override
     @PostMapping("/create")
-    public String menuCreate(@RequestBody WxMenu menu) throws WxErrorException {
-        return this.wxService.getMenuService().menuCreate(menu);
+    public String menuCreate(@PathVariable String appid, @RequestBody WxMenu menu) throws WxErrorException {
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().menuCreate(menu);
     }
 
     @GetMapping("/create")
-    public String menuCreateSample() throws WxErrorException {
+    public String menuCreateSample(@PathVariable String appid) throws WxErrorException {
         WxMenu menu = new WxMenu();
         WxMenuButton button1 = new WxMenuButton();
         button1.setType(MenuButtonType.CLICK);
@@ -85,7 +73,7 @@ public String menuCreateSample() throws WxErrorException {
         button3.getSubButtons().add(button32);
         button3.getSubButtons().add(button33);
 
-        return this.wxService.getMenuService().menuCreate(menu);
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().menuCreate(menu);
     }
 
     /**
@@ -99,10 +87,9 @@ public String menuCreateSample() throws WxErrorException {
      * @param json
      * @return 如果是个性化菜单，则返回menuid，否则返回null
      */
-    @Override
     @GetMapping("/create/{json}")
-    public String menuCreate(@PathVariable String json) throws WxErrorException {
-        return this.wxService.getMenuService().menuCreate(json);
+    public String menuCreate(@PathVariable String appid, @PathVariable String json) throws WxErrorException {
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().menuCreate(json);
     }
 
     /**
@@ -111,10 +98,9 @@ public String menuCreate(@PathVariable String json) throws WxErrorException {
      * 详情请见: https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421141015&token=&lang=zh_CN
      * </pre>
      */
-    @Override
     @GetMapping("/delete")
-    public void menuDelete() throws WxErrorException {
-        this.wxService.getMenuService().menuDelete();
+    public void menuDelete(@PathVariable String appid) throws WxErrorException {
+        WxMpConfiguration.getMpServices().get(appid).getMenuService().menuDelete();
     }
 
     /**
@@ -125,10 +111,9 @@ public void menuDelete() throws WxErrorException {
      *
      * @param menuId 个性化菜单的menuid
      */
-    @Override
     @GetMapping("/delete/{menuId}")
-    public void menuDelete(@PathVariable String menuId) throws WxErrorException {
-        this.wxService.getMenuService().menuDelete(menuId);
+    public void menuDelete(@PathVariable String appid, @PathVariable String menuId) throws WxErrorException {
+        WxMpConfiguration.getMpServices().get(appid).getMenuService().menuDelete(menuId);
     }
 
     /**
@@ -137,10 +122,9 @@ public void menuDelete(@PathVariable String menuId) throws WxErrorException {
      * 详情请见： https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421141014&token=&lang=zh_CN
      * </pre>
      */
-    @Override
     @GetMapping("/get")
-    public WxMpMenu menuGet() throws WxErrorException {
-        return this.wxService.getMenuService().menuGet();
+    public WxMpMenu menuGet(@PathVariable String appid) throws WxErrorException {
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().menuGet();
     }
 
     /**
@@ -151,10 +135,9 @@ public WxMpMenu menuGet() throws WxErrorException {
      *
      * @param userid 可以是粉丝的OpenID，也可以是粉丝的微信号。
      */
-    @Override
     @GetMapping("/menuTryMatch/{userid}")
-    public WxMenu menuTryMatch(@PathVariable String userid) throws WxErrorException {
-        return this.wxService.getMenuService().menuTryMatch(userid);
+    public WxMenu menuTryMatch(@PathVariable String appid, @PathVariable String userid) throws WxErrorException {
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().menuTryMatch(userid);
     }
 
     /**
@@ -172,9 +155,8 @@ public WxMenu menuTryMatch(@PathVariable String userid) throws WxErrorException
      * https://api.weixin.qq.com/cgi-bin/get_current_selfmenu_info?access_token=ACCESS_TOKEN
      * </pre>
      */
-    @Override
     @GetMapping("/getSelfMenuInfo")
-    public WxMpGetSelfMenuInfoResult getSelfMenuInfo() throws WxErrorException {
-        return this.wxService.getMenuService().getSelfMenuInfo();
+    public WxMpGetSelfMenuInfoResult getSelfMenuInfo(@PathVariable String appid) throws WxErrorException {
+        return WxMpConfiguration.getMpServices().get(appid).getMenuService().getSelfMenuInfo();
     }
 }