Merge remote-tracking branch 'origin/dev_20211205' into dev_20211205

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/config/WechatMpConfigure.java

 package com.liquidnet.service.sweet.config;
 
-import com.liquidnet.service.sweet.handler.StrawberryPosterHandler;
-import com.liquidnet.service.sweet.handler.SubscribeHandler;
-import com.liquidnet.service.sweet.handler.TextMsgHandler;
-import com.liquidnet.service.sweet.handler.UnsubscribeHandler;
+import com.liquidnet.service.sweet.handler.*;
 import me.chanjar.weixin.common.api.WxConsts;
 import me.chanjar.weixin.common.api.WxMessageInMemoryDuplicateChecker;
 import me.chanjar.weixin.common.redis.RedisTemplateWxRedisOps;
@@ -70,6 +67,8 @@ public class WechatMpConfigure {
     private StrawberryPosterHandler posterHandler;
     @Autowired
     private TextMsgHandler textMsgHandler;
+    @Autowired
+    private TestMsgHandler testMsgHandler;
 
     @PostConstruct
     public void init() {
@@ -153,6 +152,12 @@ public class WechatMpConfigure {
                 .handler(textMsgHandler)
                 .end();
 
+        // 测试
+        router.rule().async(false).msgType(WxConsts.XmlMsgType.TEXT)
+                .content("112233")
+                .handler(testMsgHandler)
+                .end();
+
         return router;
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/TestMsgHandler.java

+package com.liquidnet.service.sweet.handler;
+
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpMessageHandler;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 文本消息测试
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-12-02
+ */
+@Component
+@Slf4j
+public class TestMsgHandler implements WxMpMessageHandler {
+
+    @Override
+    public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService,
+                                    WxSessionManager sessionManager) throws WxErrorException {
+        return WxMpXmlOutMessage.TEXT().content("这是个测试啦啦啦")
+                .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
+                .build();
+    }
+}