1

src/main/java/cn/van/business/util/WxMessageConsumer.java

@@ -11,6 +11,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 
 import java.math.BigDecimal;
@@ -211,7 +212,7 @@ public class WxMessageConsumer {
         return finallyUrl;
     }
 
-    //@Async("threadPoolTaskExecutor")
+    @Async("threadPoolTaskExecutor")
     public void consume(WxMessage wxMessage) throws Exception {
         //logger.info("接收到消息 : {}", wxMessage);
         if (wxMessage.getEvent() == null) {
@@ -224,7 +225,7 @@ public class WxMessageConsumer {
          * 转账需要对接会员系统
          *
          * */
-        WxMessage.DataSection data = wxMessage.getData();
+        //WxMessage.DataSection data = wxMessage.getData();
         if (FromType.PRIVATE.getKey().equals(wxMessage.getEvent())) {
             handlePrivateMessage(wxMessage);
         } else if (FromType.GROUP.getKey().equals(wxMessage.getEvent())) {