basicfamilyprocessor.java

MilyQQ是一个使用控制台的QQ客户端,基于LumaQQ的核心JQL包开发,只有一个可执行的jar包(MilyQQ.jar),携带方便,由于是Java程序,因此理论上应该可以运行于所有平台,不过基于

        QQEvent e = null;
        SystemNotificationPacket packet = (SystemNotificationPacket)in;
        // 判断类型
        switch(packet.type) {
        	case QQ.QQ_SYS_BEING_ADDED:
    	        e = new QQEvent(packet);
                e.type = QQEvent.QQ_ADDED_BY_OTHERS;
                break;
        	case QQ.QQ_SYS_ADD_FRIEND_REQUEST:
                e = new QQEvent(packet);
                e.type = QQEvent.QQ_REQUEST_ADD_ME;
                break;
        	case QQ.QQ_SYS_ADD_FRIEND_APPROVED:
                e = new QQEvent(packet);
                e.type = QQEvent.QQ_REQUEST_ADD_OTHER_APPROVED;
                break;
        	case QQ.QQ_SYS_ADD_FRIEND_REJECTED:
                e = new QQEvent(packet);
                e.type = QQEvent.QQ_REQUEST_ADD_OTHER_REJECTED;
                break;
        	case QQ.QQ_SYS_ADVERTISEMENT:
                e = new QQEvent(packet);
                e.type = QQEvent.QQ_RECEIVE_ADVERTISEMENT;
                break;
        	case QQ.QQ_SYS_BEING_ADDED_EX:
    	        e = new QQEvent(packet);
                e.type = QQEvent.QQ_ADDED_BY_OTHERS_EX;
                break;
        	case QQ.QQ_SYS_ADD_FRIEND_REQUEST_EX:
            	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_REQUEST_ADD_ME_EX;
            	break;
            default:
            	//log.debug("未知类型的系统通知，忽略");
            	break;
        }
        // 触发事件
        if(e != null)
            client.fireQQEvent(e);
    }

    /**
     * 处理未知命令，没有实际操作，简单打印内容
     *
     * @param in
     */
    private void processRequestKeyReply(BasicInPacket in) {
        RequestKeyReplyPacket packet = (RequestKeyReplyPacket)in;
        QQEvent e;
        if(packet.replyCode == QQ.QQ_REPLY_OK) {
	        e = new QQEvent(packet);
            e.type = QQEvent.QQ_REQUEST_KEY_SUCCESS;
	        client.fireQQEvent(e);
        } else {
	        e = new QQEvent(monitor.retrieveRequest(packet));
            e.type = QQEvent.QQ_REQUEST_KEY_FAIL;
	        client.fireQQEvent(e);
        }
    }

    /**
     * 处理收到的消息
     *
     * @param in
     */
    private void processReceiveIM(BasicInPacket in) {
        QQEvent e;
        if(!(in instanceof ReceiveIMPacket))
            return;

        ReceiveIMPacket packet = (ReceiveIMPacket)in;
        if(packet.isDuplicated()) {
            //log.debug("收到一条重复消息，发送确认");
            e = new QQEvent(packet);
            e.type = QQEvent.QQ_RECEIVE_DUPLICATED_IM;
            client.fireQQEvent(e);
            return;
        }

        // 开始处理
        switch(packet.header.type) {
        	case QQ.QQ_RECV_IM_FRIEND:
        	case QQ.QQ_RECV_IM_STRANGER:
                e = new QQEvent(packet);
            	switch(packet.normalHeader.type) {
            		case QQ.QQ_IM_TYPE_TEXT:
    		            e.type = QQEvent.QQ_RECEIVE_NORMAL_IM;
    		            break;
    		        case QQ.QQ_IM_TYPE_UDP_REQUEST:
    	        		//log.debug("对方请求传送文件，协议UDP" + " 传送文件端口：" + packet.fileArgs.majorPort);
    	        		e.type = QQEvent.QQ_REQUEST_SEND_FILE;
    	        		break;
    	        	case QQ.QQ_IM_TYPE_REJECT_UDP_REQUEST:
    	            	//log.debug("对方拒绝了传送文件的请求");
    	            	e.type = QQEvent.QQ_REJECT_SEND_FILE;
    	            	break;
    	            case QQ.QQ_IM_TYPE_ACCEPT_UDP_REQUEST:
    	            	//log.debug("对方接受了传送文件的请求");
    	            	e.type = QQEvent.QQ_ACCEPT_SEND_FILE;
    	            	break;
    	            case QQ.QQ_IM_TYPE_NOTIFY_IP:
    	            	/*/log.debug("对方告诉我文件发送的IP和端口，其外部IP为" + Util.getIpStringFromBytes(packet.fileArgs.internetIp) +
    	            			" 其外部端口为" + packet.fileArgs.internetPort + " 其主端口为" + packet.fileArgs.majorPort +
    							" 其真实IP为" + Util.getIpStringFromBytes(packet.fileArgs.localIp) +
    							" 其副端口为" + packet.fileArgs.minorPort);*/
    	            	e.type = QQEvent.QQ_NOTIFY_FILE_TRANSFER_ARGS;
    	            	break;
    	            case QQ.QQ_IM_TYPE_ARE_YOU_BEHIND_FIREWALL:
    	            	//log.debug("对方请求自己主动连接他");
    	            	e.type = QQEvent.QQ_REQUEST_ME_CONNECT;
    	            	break;
    	            case QQ.QQ_IM_TYPE_REQUEST_CANCELED:
    	            	//log.debug("对方取消了文件传送");
    	            	e.type = QQEvent.QQ_CANCEL_SEND_FILE;
    	            	break;
    	            default:
    	        		//log.debug("接受到一条非文本消息，目前无法处理，忽略该消息");
    	        		e.type = QQEvent.QQ_UNKNOWN_TYPE_IM;
    	        		break;
            	}
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_SYS_MESSAGE:
                //log.debug("接收到一条系统消息: " + packet.sysMessage);
                if(packet.systemMessageType == QQ.QQ_RECV_IM_KICK_OUT) {
                	e = new QQEvent(packet);
                	e.type = QQEvent.QQ_KICKED_OUT_BY_SYSTEM;
                	client.fireQQEvent(e);
                } else {
    	            e = new QQEvent(packet);
    	            e.type = QQEvent.QQ_RECEIVE_SYS_MESSAGE;
    	            client.fireQQEvent(e);
                }
                break;
        	case QQ.QQ_RECV_IM_CLUSTER:
            	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_RECEIVE_CLUSTER_IM;
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_TEMP_CLUSTER:
            	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_RECEIVE_TEMP_CLUSTER_IM;
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_UNKNOWN_CLUSTER:
               	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_RECEIVE_UNKNOWN_CLUSTER_IM;
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_BIND_USER:
        	case QQ.QQ_RECV_IM_MOBILE_QQ:
        	case QQ.QQ_RECV_IM_MOBILE_QQ_2:
        	case QQ.QQ_RECV_IM_MOBILE:
        		//log.debug("收到一条短信: " + packet.sms.message);
        		e = new QQEvent(packet);
        		e.type = QQEvent.QQ_RECEIVE_SMS;
        		client.fireQQEvent(e);
        		break;
        	case QQ.QQ_RECV_IM_TEMP_SESSION:
        		//log.debug("收到一条临时会话消息: " + packet.tempSessionIM.message);
        		e = new QQEvent(packet);
        		e.type = QQEvent.QQ_RECEIVE_TEMP_SESSION_IM;
        		client.fireQQEvent(e);
        		break;
        	case QQ.QQ_RECV_IM_CREATE_CLUSTER:
        	case QQ.QQ_RECV_IM_ADDED_TO_CLUSTER:
            	//log.debug("收到一条" + Util.getIMTypeString(packet.header.type) + "消息");
            	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_I_AM_ADDED_TO_CLUSTER;
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_DELETED_FROM_CLUSTER:
            	//log.debug("我被创建者从群中删除");
            	e = new QQEvent(packet);
            	e.type = QQEvent.QQ_I_AM_REMOVED_FROM_CLUSTER;
            	client.fireQQEvent(e);
            	break;
        	case QQ.QQ_RECV_IM_APPROVE_JOIN_CLUSTER:
    			//log.debug("对方同意我加入群，附加消息为：" + packet.message);
    			e = new QQEvent(packet);
    			e.type = QQEvent.QQ_REQUEST_JOIN_CLUSTER_APPROVED;
    			client.fireQQEvent(e);
    			break;
        	case QQ.QQ_RECV_IM_REJECT_JOIN_CLUSTER:
    			//log.debug("对方拒绝我加入群，附加消息为：" + packet.message);
    			e = new QQEvent(packet);
    			e.type = QQEvent.QQ_REQUEST_JOIN_CLUSTER_REJECTED;
    			client.fireQQEvent(e);
    			break;
        	case QQ.QQ_RECV_IM_REQUEST_JOIN_CLUSTER:
    			//log.debug("对方请求加入我的群，附加消息为：" + packet.message);
    			e = new QQEvent(packet);
    			e.type = QQEvent.QQ_REQUEST_JOIN_CLUSTER;
    			client.fireQQEvent(e);
    			break;
        	case QQ.QQ_RECV_IM_CLUSTER_NOTIFICATION:
        		switch(packet.opCode) {
        			case QQ.QQ_CLUSTER_OP_SET_ADMIN:
        				e = new QQEvent(packet);
        				e.type = QQEvent.QQ_ADMIN_ENTITLED;
        				client.fireQQEvent(e);
        				break;
        			case QQ.QQ_CLUSTER_OP_UNSET_ADMIN:
        				e = new QQEvent(packet);
        				e.type = QQEvent.QQ_ADMIN_WITHDRAWED;
        				client.fireQQEvent(e);
        				break;
        		}
        		break;
        	case QQ.QQ_RECV_IM_SIGNATURE:
        		//log.debug("好友" + packet.signatureOwner + "的个性签名改变了");
        		e = new QQEvent(packet);
        		e.type = QQEvent.QQ_FRIEND_SIGNATURE_CHANGED;
        		client.fireQQEvent(e);
        		break;
    		default:
                //log.debug("接收到一条" + Util.getIMTypeString(packet.header.type) + "消息，目前无法处理，忽略");
    			break;
        }
    }

    /**
     * 处理Keep Alive的回复事件
     *
     * @param in
     */
    private void processKeepAliveReply(BasicInPacket in) {
        QQEvent e;
        KeepAliveReplyPacket packet = (KeepAliveReplyPacket)in;
/*        if(log.isDebugEnabled()) {
            log.debug("Keep Alive: 在线数: " + packet.onlines + "我的IP: " + packet.ip);
        }*/

        // 触发事件
        e = new QQEvent(packet);
        e.type = QQEvent.QQ_KEEP_ALIVE_SUCCESS;
        client.fireQQEvent(e);
    }

    /**
     * 处理发送消息回复事件
     *
     * @param in
     */
    private void processSendIMReply(BasicInPacket in) {
        QQEvent e;
        SendIMReplyPacket packet = (SendIMReplyPacket)in;
        if(packet.replyCode == QQ.QQ_REPLY_OK) {
        	SendIMPacket srcPacket = (SendIMPacket)monitor.retrieveRequest(packet);
        	char messageType = srcPacket.getMessageType();
        	if(messageType == QQ.QQ_IM_TYPE_TEXT) {
	            //log.debug("消息发送成功");
	            e = new QQEvent(srcPacket);
	            e.type = QQEvent.QQ_SEND_IM_SUCCESS;
	            client.fireQQEvent(e);
        	} else if(messageType == QQ.QQ_IM_TYPE_UDP_REQUEST) {
        		//log.debug("传送文件请求已发送，等待对方接受");
        		e = new QQEvent(srcPacket);
        		e.type = QQEvent.QQ_SEND_FILE_REQUEST_SEND_SUCCESS;
        		client.fireQQEvent(e);
        	} else if(messageType == QQ.QQ_IM_TYPE_NOTIFY_IP) {
        	    //log.debug("IP信息已发送，等待对方返回确认");
        	}
        }
    }

    /**
     * 处理得到在线好友回复事件
     *
     * @param in
     */
    private void processGetFriendOnlineReply(BasicInPacket in) {
        QQEvent e;
        GetOnlineOpReplyPacket packet = (GetOnlineOpReplyPacket)in;

        /*if(log.isDebugEnabled()) {
            Iterator iter = packet.onlineFriends.iterator();
            while(iter.hasNext()) {
                FriendStatus fs = ((FriendOnlineEntry)iter.next()).status;
                log.debug("好友" + fs.qqNum + "在线状态" + Utils.getStatusString(fs.status));
            }
        }*/

        e = new QQEvent(packet);
        e.type = QQEvent.QQ_GET_FRIEND_ONLINE_SUCCESS;
        client.fireQQEvent(e);
    }

    /**
     * 处理得到好友列表回复事件
     *
     * @param in
     */
    private void processGetFriendListReply(BasicInPacket in) {
        QQEvent e;
        GetFriendListReplyPacket packet = (GetFriendListReplyPacket)in;
        /*if(log.isDebugEnabled()) {
            Iterator iter = packet.friends.iterator();
            while(iter.hasNext()) {
                QQFriend friend = (QQFriend)iter.next();
                log.debug("得到好友" + friend.qqNum + ", 昵称: " + friend.nick);
            }
        }*/

        // 触发事件
        e = new QQEvent(packet);
        e.type = QQEvent.QQ_GET_FRIEND_LIST_SUCCESS;
        client.fireQQEvent(e);
    }

    /**
     * 处理改变状态回复事件
     *
     * @param in
     */
    private void processChangeStatusReply(BasicInPacket in) {
        QQEvent e;
        ChangeStatusReplyPacket packet = (ChangeStatusReplyPacket)in;

        // 检查应答码
        if(packet.replyCode == QQ.QQ_REPLY_CHANGE_STATUS_OK) {
            //log.debug("改变状态成功");
            e = new QQEvent(packet);
            e.type = QQEvent.QQ_CHANGE_STATUS_SUCCESS;
            client.fireQQEvent(e);
        } else {
        	//log.debug("改变状态失败");
            e = new QQEvent(packet);
            e.type = QQEvent.QQ_CHANGE_STATUS_FAIL;
            client.fireQQEvent(e);
        }
    }

    /**
     * 处理得到用户信息回复事件
     *
     * @param in
     */
    private void processGetUserInfoReply(BasicInPacket in) {
        QQEvent e;
        GetUserInfoReplyPacket packet = (GetUserInfoReplyPacket)in;
        /*if(log.isDebugEnabled()) {
            for(int i = 0; i < QQ.QQ_CONTACT_FIELDS; i++)
                log.debug("用户信息字段" + i + ": " + packet.contactInfo.infos[i]);
        }*/
        // 触发成功事件
        e = new QQEvent(packet);
        e.type = QQEvent.QQ_GET_USER_INFO_SUCCESS;
        client.fireQQEvent(e);
    }

	/**
	 * 处理好友状态改变事件
	 *
	 * @param in
	 */
	private void processFriendChangeStatus(BasicInPacket in) {
		QQEvent e;
		FriendChangeStatusPacket packet = (FriendChangeStatusPacket)in;
		if(packet.myQQ == 0) {
			//log.warn("好友状态改变包中数据有误，忽略该包");
		} else {
			// 触发事件
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_FRIEND_CHANGE_STATUS;
			client.fireQQEvent(e);
		}
	}

    /* (non-Javadoc)
     * @see edu.tsinghua.lumaqq.qq.events.IPacketListener#accept(byte)
     */
    public boolean accept(byte header) {
        return header == QQ.QQ_HEADER_BASIC_FAMILY;
    }
}