zoukankan      html  css  js  c++  java
  • 微信机器人开发SDK使用教程--清粉任务

    微信机器人开发SDK使用教程--清粉任务

    case "PostFriendDetectTask": {// 清粉任务
    log.debug("websocket:msgtype=PostFriendDetectTask。。。。。");
    postFriendDetectTaskWebsocketHandler.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.PostFriendDetectTask.PostFriendDetectTaskMessage;
    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 io.netty.channel.ChannelHandlerContext;

    @Service
    public class PostFriendDetectTaskWebsocketHandler{
    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);
    PostFriendDetectTaskMessage.Builder bd = PostFriendDetectTaskMessage.newBuilder();
    JsonFormat.parser().merge(contentJsonStr, bd);
    PostFriendDetectTaskMessage req = bd.build();
    //将消息转发送给手机客户端
    ChannelHandlerContext cx= NettyConnectionUtil.getClientChannelHandlerContextByUserId(req.getWeChatId());
    if(null != cx){
    MessageUtil.sendMsg(cx, EnumMsgType.PostFriendDetectTask, NettyConnectionUtil.getNettyId(ctx), null, req);

        		//告诉pc端消息已收到
        		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

  • 相关阅读:
    linux /usr/bin/ld: cannot find -lxxx
    chm手册显示已取消到该网页的导航
    安装 composer SSL operation failed with code 1
    protoc-gen-php --php_out: protoc-gen-php: Plugin output is unparseable.
    Lamp 安装(CentOS6.6, php-5.4.39, httpd-2.4.12, mysql-5.6.24)
    SUSE Linux Enterprise Server 11 软件源
    vmware 下linux 共享文件夹消失
    thrift 安装历程
    隐藏apache服务器信息
    固定总金额、还款天数、还款次数,计算每日每次的还款金额
  • 原文地址:https://www.cnblogs.com/wuliaokankan/p/10655945.html
Copyright © 2011-2022 走看看