微信客服系统开发SDK- 拉取当前微信个人号列表请求（立即）

case “GetWeChatsReq”: {// 拉取当前微信个人号列表请求（立即）
log.debug(“websocket:msgtype=GetWeChatsReq。。。。。”);
getWeChatsReqWebsocketHandler.handleMsg(ctx, vo,contentJsonStr);
break;
}

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

import java.util.ArrayList;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
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.service.AccountService;
import com.jubotech.business.web.service.WeChatAccountService;
import com.jubotech.framework.netty.common.Constant;
import com.jubotech.framework.netty.utils.MessageUtil;

import Jubo.JuLiao.IM.Wx.Proto.GetWeChatsReq.GetWeChatsReqMessage;
import Jubo.JuLiao.IM.Wx.Proto.GetWeChatsRsp.GetWeChatsRspMessage;
import Jubo.JuLiao.IM.Wx.Proto.GetWeChatsRsp.WeChatRspMessage;
import Jubo.JuLiao.IM.Wx.Proto.TransportMessageOuterClass.EnumAccountType;
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 GetWeChatsReqWebsocketHandler{
Logger log = LoggerFactory.getLogger(getClass());
@Autowired
private WeChatAccountService weChatAccountService;
@Autowired
private AccountService accountService;
/**
* 拉取当前微信个人号列表响应
* @author wechatno:tangjinjinwx
* @param ctx
* @param vo
*/
public void handleMsg(ChannelHandlerContext ctx ,TransportMessage vo, String contentJsonStr) {
try {
log.info(contentJsonStr);
GetWeChatsReqMessage.Builder bd = GetWeChatsReqMessage.newBuilder();
JsonFormat.parser().merge(contentJsonStr, bd);
GetWeChatsReqMessage req = bd.build();
//1、校验用户信息
log.info(“账号：”+req.getUnionId());
if(null != req){
Integer id = (int) req.getUnionId();

    		AccountInfo  account = accountService.findAccountInfoByid(id);
    		if(null != account){
    			
    			List<WeChatAccountInfo> list =	weChatAccountService.findWeChatAccountInfo(account.getCid(), account.getId());

// if(null == list || list.isEmpty()){
// list = weChatAccountService.findWeChatAccountInfo(account.getCid(), null);
// }
List weChatrspList = getWechatList(list);

        		GetWeChatsRspMessage.Builder builder = GetWeChatsRspMessage.newBuilder();
        		builder.setUnionId(req.getUnionId());
        		builder.setAccountType(EnumAccountType.SubUser);
        		builder.setSupplierId(account.getCid());
        		if(null != weChatrspList && weChatrspList.size()>0){
        			builder.addAllWeChats(weChatrspList);
        		}
        		
        		GetWeChatsRspMessage resp = builder.build();
        		
        		//3、告诉PC客户端消息已收到
	    		MessageUtil.sendJsonMsg(ctx, EnumMsgType.GetWeChatsRsp, vo.getAccessToken(), vo.getId(), resp);
    		}else{
    			MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam,Constant.ERROR_MSG_PARAMERROR);
    		}
    	} 
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
    }
}

/**
 * 封装返回对象
 * @param list
 * @return
 */
private static List<WeChatRspMessage>  getWechatList(List<WeChatAccountInfo> list){
	List<WeChatRspMessage> weChatrspList = null;
    if(null != list && list.size()>0){
    	weChatrspList = new ArrayList<>();
		for(int i=0;i<list.size();i++){
			WeChatAccountInfo info = list.get(i);
			boolean online = false;
			if(null != info.getIsonline() && info.getIsonline()==0){
				online = true;
			}
			boolean logined = false;
			if(null != info.getIslogined() && info.getIslogined()==0){
				logined = true;
			}
			WeChatRspMessage.Builder builder = WeChatRspMessage.newBuilder();
	        if(null != info.getWechatid()){
	        	builder.setWeChatId(info.getWechatid());
	        }
	        if(null != info.getWechatno()){
	        	builder.setWeChatNo(info.getWechatno());
	        }
	        if(null !=info.getWechatnick()){
	        	builder.setWeChatNick(info.getWechatnick());
	        }
	        if(null != info.getAvatar()){
	        	builder.setAvatar(info.getAvatar());
	        }
	        if(null != info.getCountry()){
	        	builder.setCountry(info.getCountry());
	        }
	        if(null != info.getProvince()){
	        	builder.setProvince(info.getProvince());
	        }
	        if(null != info.getCity()){
	        	builder.setCity(info.getCity());
	        }
	        if(null != info.getGender()){
	        	builder.setGenderValue(info.getGender());
	        }
	        if(null != info.getLogin_time()){
	        	builder.setLoginTime(info.getLogin_time().getTime());
	        }
	        if(null != info.getModify_time()){
	        	builder.setModifyTime(info.getModify_time().getTime());
	        }
	        if(null != info.getDeviceid()){
	        	builder.setDeviceName(info.getDeviceid());
	        }
	        if(null != info.getAccountid()){
	        	builder.setLoginUnionId(info.getAccountid());
	        }
	        builder.setIsOnline(online);
	        builder.setIsLogined(logined);
	        builder.setIsDelete(false);
	        builder.setIsUpgrading(false);
					  
			weChatrspList.add(builder.build());
		}
    }
	
	return weChatrspList;
}

}

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