package org.ruoyi.system.handler.wxcp; import lombok.RequiredArgsConstructor; import me.chanjar.weixin.common.api.WxConsts; import me.chanjar.weixin.common.session.WxSessionManager; import me.chanjar.weixin.cp.api.WxCpService; import me.chanjar.weixin.cp.bean.message.WxCpXmlMessage; import me.chanjar.weixin.cp.bean.message.WxCpXmlOutMessage; import org.ruoyi.system.builder.TextBuilder; import org.ruoyi.system.service.ISseService; import org.springframework.stereotype.Component; import java.util.Map; /** * @author Binary Wang */ @Component @RequiredArgsConstructor public class MsgHandler extends AbstractHandler { // private final ISseService sseService; @Override public WxCpXmlOutMessage handle(WxCpXmlMessage wxMessage, Map context, WxCpService cpService, WxSessionManager sessionManager) { final String msgType = wxMessage.getMsgType(); if (msgType == null) { // 如果msgType没有,就自己根据具体报文内容做处理 } if (!msgType.equals(WxConsts.XmlMsgType.EVENT)) { //TODO 可以选择将消息保存到本地 } //TODO 组装回复消息 String content = ""; //sseService.wxCpChat(wxMessage.getContent()); return new TextBuilder().build(content, wxMessage, cpService); } }