微信云控开发SDK使用教程--手机端推送好友列表通知服务端

微信云控开发SDK使用教程--手机端推送好友列表通知服务端

case FriendPushNotice : {//手机端推送好友列表
log.debug("socket:msgtype=FriendPushNotice");
friendPushNoticeHandler.handleMsg(ctx, msgVo);
break;
}

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

import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import com.google.protobuf.util.JsonFormat;
import com.jubotech.business.web.domain.AccountInfo;
import com.jubotech.business.web.domain.WeChatAccountInfo;
import com.jubotech.business.web.domain.WeChatContactInfo;
import com.jubotech.business.web.service.AccountService;
import com.jubotech.business.web.service.WeChatAccountService;
import com.jubotech.business.web.service.WeChatContactService;
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.FriendAddNotice.FriendMessage;
import Jubo.JuLiao.IM.Wx.Proto.FriendPushNotice.FriendPushNoticeMessage;
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 FriendPushNoticeHandler{
private final Logger log = LoggerFactory.getLogger(getClass());
@Autowired
private WeChatAccountService weChatAccountService;
@Autowired
private AccountService accountService;
@Autowired
private WeChatContactService weChatContactService;

/**
 * 手机端主动推送好友列表消息
 * @author wechatno:tangjinjinwx
 * @param ctx
 * @param vo
 */
public  void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
    try {
    	FriendPushNoticeMessage req = vo.getContent().unpack(FriendPushNoticeMessage.class);
    	log.info(JsonFormat.printer().print(req));
		// 把消息转发给pc端
		// a、根据wechatId找到accountid
		// b、通过accountid找到account
		// c、通过account账号找到通道
		WeChatAccountInfo account = weChatAccountService.findWeChatAccountInfoByWeChatId(req.getWeChatId());
		if (null != account && null != account.getAccountid() && 1 != account.getIslogined()) {
			AccountInfo accInfo = accountService.findAccountInfoByid(account.getAccountid());
			if (null != accInfo) {
				// 转发给pc端
				ChannelHandlerContext chx = NettyConnectionUtil.getClientChannelHandlerContextByUserId(accInfo.getAccount());
				if (null != chx) {
					asyncSendMsg(chx, req);
				}
			}
			// 告诉客户端消息已收到
			MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
			
			
			//异步保存到数据库
			friendListSave(req, account);
		} else {
			// 对方不在线
			MessageUtil.sendErrMsg(ctx, EnumErrorCode.TargetNotOnline, Constant.ERROR_MSG_NOTONLINE);
		}
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
    }
}

@Async
private  void  asyncSendMsg(ChannelHandlerContext chx,FriendPushNoticeMessage req){
	MessageUtil.sendJsonMsg(chx, EnumMsgType.FriendPushNotice, NettyConnectionUtil.getNettyId(chx),null, req);
}

@Async
private void friendListSave(FriendPushNoticeMessage req,WeChatAccountInfo account) {
	List<FriendMessage>  friendList = req.getFriendsList();
	if(null != friendList && friendList.size()>0){
		String wechatId = req.getWeChatId();
		for(int i=0;i<friendList.size();i++){
			FriendMessage  friend = friendList.get(i);
			if(null != friend){
				WeChatContactInfo   contactinfo = weChatContactService.findContactinfoByfriendid(account.getCid(),wechatId,friend.getFriendId());
				try {
					if(null != contactinfo){
						setContActinfo(contactinfo, friend);
						weChatContactService.update(contactinfo);
					}else{
						contactinfo = new WeChatContactInfo();
						setContActinfo(contactinfo, friend);
						contactinfo.setCid(account.getCid());
						contactinfo.setWechatid(req.getWeChatId());
						contactinfo.setFriendid(friend.getFriendId());
						weChatContactService.insert(contactinfo);
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
}


private  static void  setContActinfo(WeChatContactInfo   contactinfo,FriendMessage  friend){
	contactinfo.setFriend_wechatno(friend.getFriendNo());
	contactinfo.setNickname(friend.getFriendNick());
	contactinfo.setGender(friend.getGenderValue());
	contactinfo.setAvatar(friend.getAvatar());
	contactinfo.setCountry(friend.getCountry());
	contactinfo.setProvince(friend.getProvince());
	contactinfo.setCity(friend.getCity());
	contactinfo.setState(0);
}

}

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