zoukankan      html  css  js  c++  java
  • 微信机器人开发SDK使用教程--执行养号动作命令

    微信机器人开发SDK使用教程--执行养号动作命令

    case "WeChatMaintenanceTask": {// 执行养号动作命令
    log.debug("websocket:msgtype=WeChatMaintenanceTask。。。。。");
    weChatMaintenanceTaskWebsocketHandler.handleMsg(ctx, vo,contentJsonStr);
    break;
    }

    package com.jubotech.framework.netty.handler.websocket;

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.stereotype.Service;

    import com.google.protobuf.util.JsonFormat;
    import com.jubotech.framework.netty.common.Constant;
    import com.jubotech.framework.netty.utils.MessageUtil;
    import com.jubotech.framework.netty.utils.NettyConnectionUtil;

    import Jubo.JuLiao.IM.Wx.Proto.TransportMessageOuterClass.EnumErrorCode;
    import Jubo.JuLiao.IM.Wx.Proto.TransportMessageOuterClass.EnumMsgType;
    import Jubo.JuLiao.IM.Wx.Proto.TransportMessageOuterClass.TransportMessage;
    import Jubo.JuLiao.IM.Wx.Proto.WeChatMaintenanceTask.WeChatMaintenanceTaskMessage;
    import io.netty.channel.ChannelHandlerContext;
    @Service
    public class WeChatMaintenanceTaskWebsocketHandler{
    private final Logger log = LoggerFactory.getLogger(getClass());
    /**
    * 执行养号动作命令---pc端经过服务端转发给手机端
    * @author wechatno:tangjinjinwx
    * @param ctx
    * @param vo
    */
    public void handleMsg(ChannelHandlerContext ctx,TransportMessage vo, String contentJsonStr) {
    try {
    log.info(contentJsonStr);
    WeChatMaintenanceTaskMessage.Builder bd = WeChatMaintenanceTaskMessage.newBuilder();
    JsonFormat.parser().merge(contentJsonStr, bd);
    WeChatMaintenanceTaskMessage req = bd.build();
    //WeChatMaintenanceTaskMessage req = vo.getContent().unpack(WeChatMaintenanceTaskMessage.class);
    ChannelHandlerContext chx = NettyConnectionUtil.getClientChannelHandlerContextByUserId(req.getWeChatId());
    if(null != chx){
    //转发给手机端
    MessageUtil.sendMsg(chx, EnumMsgType.WeChatMaintenanceTask, vo.getAccessToken(), null, req);
    //告诉发送方 消息已经收到
    MessageUtil.sendJsonMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
    }else{
    //对方不在线
    MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.TargetNotOnline, Constant.ERROR_MSG_NOTONLINE);
    }

        } catch (Exception e) {
            e.printStackTrace();
            MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
        }
    }
    

    }

    项目地址:https://www.wuliaokankan.cn/url301/138.html
    接口参考:http://www.yunlauncher.com/Blog/articles/119.html

  • 相关阅读:
    CodeForces 347B Fixed Points (水题)
    CodeForces 347A Difference Row (水题)
    CodeForces 346A Alice and Bob (数学最大公约数)
    CodeForces 474C Captain Marmot (数学,旋转,暴力)
    CodeForces 474B Worms (水题,二分)
    CodeForces 474A Keyboard (水题)
    压力测试学习(一)
    算法学习(一)五个常用算法概念了解
    C#语言规范
    异常System.Threading.Thread.AbortInternal
  • 原文地址:https://www.cnblogs.com/wuliaokankan/p/10655923.html
Copyright © 2011-2022 走看看