From bae84e1d6b81eb5d3423bcde0c1a68c0ff2435b2 Mon Sep 17 00:00:00 2001
From: heiheihei <36981492+biubiubiu3971@users.noreply.github.com>
Date: Fri, 24 Mar 2023 11:33:17 +0800
Subject: [PATCH] =?UTF-8?q?:art:=E3=80=90=E5=B0=8F=E7=A8=8B=E5=BA=8F?=
 =?UTF-8?q?=E3=80=91=E8=B7=AF=E7=94=B1=E8=A7=84=E5=88=99=E4=BD=BF=E7=94=A8?=
 =?UTF-8?q?=E5=BC=82=E6=AD=A5=E6=97=B6=EF=BC=8C=E5=BD=93=E5=89=8D=E7=9A=84?=
 =?UTF-8?q?appId=E6=B2=A1=E6=9C=89=E4=BC=A0=E5=85=A5=E5=88=B0=E5=AD=90?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B=EF=BC=8C=E5=AF=BC=E8=87=B4wxMaService?=
 =?UTF-8?q?=E5=9C=A8=E5=AD=90=E7=BA=BF=E7=A8=8B=E4=B8=AD=E6=97=A0=E6=B3=95?=
 =?UTF-8?q?=E5=8F=96=E5=88=B0=E7=88=B6=E7=BA=BF=E7=A8=8B=E7=9A=84appId?=
 =?UTF-8?q?=E3=80=82=20(#2961)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java
index 026babdd3..a4795c9b4 100644
--- a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java
+++ b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java
@@ -2,6 +2,7 @@ package cn.binarywang.wx.miniapp.message;
 
 import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.bean.WxMaMessage;
+import cn.binarywang.wx.miniapp.util.WxMaConfigHolder;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import lombok.Data;
 import me.chanjar.weixin.common.api.WxErrorExceptionHandler;
@@ -127,7 +128,7 @@ public class WxMaMessageRouter {
     if (matchRules.size() == 0) {
       return null;
     }
-
+    String miniAppId = WxMaConfigHolder.get();
     final List<Future<?>> futures = new ArrayList<>();
     WxMaXmlOutMessage result = null;
     for (final WxMaMessageRouterRule rule : matchRules) {
@@ -135,6 +136,7 @@ public class WxMaMessageRouter {
       if (rule.isAsync()) {
         futures.add(
           this.executorService.submit(() -> {
+            this.wxMaService.switchoverTo(miniAppId);
             rule.service(wxMessage, context, WxMaMessageRouter.this.wxMaService, WxMaMessageRouter.this.sessionManager, WxMaMessageRouter.this.exceptionHandler);
           })
         );