JAVA版免费开源的微信管家平台。支持微信公众号、小程序、第三方平台等

package com.jeecg.p3.weixin.service.impl; import com.jeecg.p3.baseApi.util.EmojiFilter; import com.jeecg.p3.commonweixin.entity.MyJwWebJwid; import com.jeecg.p3.commonweixin.util.DateUtils; import com.jeecg.p3.message.entity.WeixinGroupMessageSendDetail; import com.jeecg.p3.message.service.WeixinGroupMessageSendDetailService; import com.jeecg.p3.qrcode.entity.WeixinQrcode; import com.jeecg.p3.qrcode.entity.WeixinQrcodeScanRecord; import com.jeecg.p3.qrcode.service.WeixinQrcodeScanRecordService; import com.jeecg.p3.qrcode.service.WeixinQrcodeService; import com.jeecg.p3.system.service.MyJwWebJwidService; import com.jeecg.p3.weixin.entity.*; import com.jeecg.p3.weixin.service.*; import com.jeecg.p3.weixin.util.MessageUtil; import com.jeecg.p3.weixin.util.WeiXinConstants; import com.jeecg.p3.weixin.util.WeixinUtil; import com.jeecg.p3.weixin.vo.WeixinMessageDTO; import com.jeecg.p3.weixin.vo.resp.Article; import com.jeecg.p3.weixin.vo.resp.NewsMessageResp; import com.jeecg.p3.weixin.vo.resp.TextMessageResp; import net.sf.json.JSONObject; import org.apache.commons.lang.StringUtil; import org.jeecgframework.p3.core.util.oConvertUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.servlet.http.HttpServletRequest; import java.text.SimpleDateFormat; import java.util.*; import java.util.regex.Pattern; /** * 微信消息处理 * @author LeeShaoQing * @since 20180723 */ @Service("wechatService") public class WechatServiceImpl implements WechatService { public final static Logger log = LoggerFactory.getLogger(WechatServiceImpl.class); @Autowired private WeixinAutoresponseService weixinAutoresponseService; @Autowired private WeixinTexttemplateService weixinTexttemplateService; @Autowired private WeixinNewstemplateService weixinNewstemplateService; @Autowired private WeixinNewsitemService weixinNewsitemService; @Autowired private MyJwWebJwidService myJwWebJwidService; @Autowired private WeixinAutoresponseDefaultService weixinAutoresponseDefaultService; @Autowired private WeixinMenuService weixinMenuService; @Autowired private WeixinSubscribeService weixinSubscribeService; @Autowired private WeixinReceivetextService weixinReceivetextService; @Autowired private WeixinGzuserService weixinGzuserService; @Autowired private WeixinQrcodeService weixinQrcodeService; @Autowired private WeixinQrcodeScanRecordService weixinQrcodeScanRecordService; @Autowired private WeixinGroupMessageSendDetailService weixinGroupMessageSendDetailService; @Override public String coreService(HttpServletRequest request) { log.info(" ------------接受微信客户端消息，进入逻辑处理开始------------"); String respMessage = ""; try { // xml请求解析 Map<String, String> requestMap = MessageUtil.parseXml(request); log.info(" ---------解析微信客户端消息完成-----MessageUtil.parseXml-------"); //消息存储-非事件消息 if(!MessageUtil.REQ_MESSAGE_TYPE_EVENT.equals(requestMap.get("MsgType"))) { log.info(" ---------保存微信客户端消息进数据库-------"); saveReceiveMessage(requestMap); } log.info(" -----微信客户端消息------： {}", requestMap.toString()); //写入通用DTO类中方便传递参数 WeixinMessageDTO weixinMessageDTO = new WeixinMessageDTO(); // 发送方帐号(OpenId) weixinMessageDTO.setFromUserName(requestMap.get("FromUserName")); // 公众帐号(JWID) weixinMessageDTO.setToUserName(requestMap.get("ToUserName")); // 消息类型 weixinMessageDTO.setMsgType(requestMap.get("MsgType")); //消息ID weixinMessageDTO.setMsgId(requestMap.get("MsgId")); //消息内容 weixinMessageDTO.setContent(requestMap.get("Content")); //多媒体ID weixinMessageDTO.setMediaId(requestMap.get("MediaId")); //菜单key weixinMessageDTO.setKey(requestMap.get("EventKey")); //Event(事件) weixinMessageDTO.setEvent(requestMap.get("Event")); //【微信触发类型】文本消息 if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) { respMessage = doTextResponse(weixinMessageDTO, request); } //【微信触发类型】图片消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) { respMessage = doImageResponse(weixinMessageDTO, request); } //【微信触发类型】地理位置消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) { respMessage = doLocationeResponse(weixinMessageDTO, request); } //【微信触发类型】链接消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) { respMessage = doLinkResponse(weixinMessageDTO, request); } //【微信触发类型】音频消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) { respMessage = doVoiceResponse(weixinMessageDTO, request); } //【微信触发类型】视频消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.RESP_MESSAGE_TYPE_VIDEO)) { respMessage = doVideoResponse(weixinMessageDTO, request); } //【微信触发类型】小视频消息 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_SHORTVIDEO)) { respMessage = doShortVideoResponse(weixinMessageDTO, request); } //【微信触发类型】事件推送 else if (weixinMessageDTO.getMsgType().equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) { // 事件类型 String eventType = weixinMessageDTO.getEvent(); // 订阅 if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) { try { respMessage = doSubscribeEventResponse(weixinMessageDTO, request); } catch (Exception e) { e.printStackTrace(); log.error("-----处理订阅事件异常：--------------"+e.toString()); } //扫描二维码 }else if(eventType.equals(MessageUtil.EVENT_TYPE_SCAN)){ try { //update-begin--Author:sunkai Date:20180904 for：扫码关注事件-------------------- String sceneId = weixinMessageDTO.getKey(); respMessage = doScanEventResponse(weixinMessageDTO,sceneId, request); //update-end--Author:sunkai Date:20180904 for：扫码关注事件-------------------- } catch (Exception e) { e.printStackTrace(); log.error("-----处理扫描二维码事件异常：--------------"+e.toString()); } } // 取消订阅 else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) { try { respMessage = doUnsubscribeEventResponse(weixinMessageDTO, request); } catch (Exception e) { e.printStackTrace(); log.error("-----处理取消订阅事件异常：--------------"+e.toString()); } } //上报地理位置事件 else if(eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)){ try { respMessage = doLocationEventResponse(weixinMessageDTO, request); } catch (Exception e) { e.printStackTrace(); log.error("-----处理上报地理位置事件异常：--------------"+e.toString()); } } // 自定义菜单点击事件(Click) else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) { try { respMessage = doMyMenuEventResponse(weixinMessageDTO, request); } catch (Exception e) { e.printStackTrace(); log.error("-----处理微信请求[Click]事件异常：--------------"+e.toString()); } } // 自定义菜单点击事件（VIEW） else if (eventType.equals(MessageUtil.EVENT_TYPE_VIEW)) { try { respMessage = doMyMenuViewEventResponse(weixinMessageDTO, request); } catch (Exception e) { e.printStackTrace(); log.error("-----处理微信请求[View]事件异常：--------------"+e.toString()); } } // 其他事件 else { try { respMessage