微信api接口调用-触发推送微信群聊列表
/*** 触发推送微信群聊列表* @author wechatno:tangjinjinwx* @blog */@Asyncpublic void handleMsg(ChannelHandlerContext ctx, TransportMessage vo, String contentJsonStr) {try {log.debug(contentJsonStr);TriggerChatRoomPushTaskMessage.Builder bd = TriggerChatRoomPushTaskMessage.newBuilder();JsonFormat.parser().merge(contentJsonStr, bd);TriggerChatRoomPushTaskMessage req = bd.build();// 将消息转发送给手机客户端asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.TriggerChatroomPushTask, vo, req);} catch (Exception e) {e.printStackTrace();MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);}}/*** 推送微信群聊列表* @author wechatno:tangjinjinwx* @blog */@Asyncpublic void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {try {ChatRoomPushNoticeMessage req = vo.getContent().unpack(ChatRoomPushNoticeMessage.class);log.debug(JsonFormat.printer().print(req));asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.ChatroomPushNotice, req);asyncTaskService.qunListSave(req);// 告诉客户端消息已收到MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);} catch (Exception e) {e.printStackTrace();MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam,vo.getId(), Constant.ERROR_MSG_DECODFAIL);}}
