basicfamilyprocessor.java

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

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

	/**
     * 处理批量得到群名片回复包
     *
     * @param packet
     */
    private void processGetCardBatchReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_GET_CARD_BATCH_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_GET_CARD_BATCH_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理修改临时群信息回复包
     *
     * @param packet
     */
    private void processModifyTempClusterInfoReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_MODIFY_TEMP_CLUSTER_INFO_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_MODIFY_TEMP_CLUSTER_INFO_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理提交成员分组情况回复包
     *
     * @param packet
     */
    private void processCommitMemberOrganizationReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_COMMIT_MEMBER_ORGANIZATION_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_COMMIT_MEMBER_ORGANIZATION_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理提交组织架构回复包
     *
     * @param packet
     */
    private void processCommitOrganizationReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_COMMIT_ORGANIZATION_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_COMMIT_ORGANIZATION_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理更新组织架构回复包
     *
     * @param packet
     */
    private void processUpdateOrganizationReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_UPDATE_ORGANIZATION_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_UPDATE_ORGANIZATION_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理讨论组操作回复包
     *
     * @param packet
     */
    private void processClusterSubClusterOpReply(ClusterCommandReplyPacket packet) {
    	QQEvent e;
    	if(packet.replyCode == QQ.QQ_REPLY_OK) {
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_SUB_CLUSTER_OP_SUCCESS;
    		client.fireQQEvent(e);
    	} else {
    		ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
    		packet.clusterId = ccp.getClusterId();
    		e = new QQEvent(packet);
    		e.type = QQEvent.QQ_SUB_CLUSTER_OP_FAIL;
    		client.fireQQEvent(e);
    	}
	}

	/**
     * 处理修改临时群成员的回复包
     *
     * @param packet
     */
    private void processClusterModifyTempClusterMemberReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
		packet.clusterId = ccp.getClusterId();
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
		    //log.debug("临时群成员修改成功，群ID：" + packet.clusterId + " 父ID：" + packet.parentClusterId);
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_TEMP_CLUSTER_MEMBER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("临时群成员修改失败");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_TEMP_CLUSTER_MEMBER_FAIL;
			client.fireQQEvent(e);
		}
    }

    /**
     * 处理创建临时群的回复包
     *
     * @param packet
     */
    private void processClusterCreateTempClusterReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("临时群创建成功，群ID：" + packet.clusterId + " 父ID：" + packet.parentClusterId);
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_CREATE_TEMP_CLUSTER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("临时群创建失败");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_CREATE_TEMP_CLUSTER_FAIL;
			client.fireQQEvent(e);
		}
    }

    /**
	 * 处理修改群成员的回复包
	 *
	 * @param packet
	 * 		ClusterCommandReplyPacket
	 */
	private void processClusterModifyMember(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("群成员修改成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_CLUSTER_MEMBER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("群成员修改失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_CLUSTER_MEMBER_FAIL;
			client.fireQQEvent(e);
		}
	}

    /**
     * @param packet
     */
    private void processClusterSendTempClusterIMReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
		packet.clusterId = ccp.getClusterId();
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("临时群消息发送成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEND_TEMP_CLUSTER_IM_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("临时群消息发送失败");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEND_TEMP_CLUSTER_IM_FAIL;
			client.fireQQEvent(e);
		}
    }

    /**
     * 处理扩展群消息回复包
     *
     * @param packet
     */
    private void processClusterSendIMExReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("群消息发送成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEND_CLUSTER_IM_EX_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("群消息发送失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEND_CLUSTER_IM_EX_FAIL;
			client.fireQQEvent(e);
		}
    }

	/**
	 * 处理搜索群的回复包
	 *
	 * @param packet
	 */
	private void processClusterSearchReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("群搜索成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEARCH_CLUSTER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("搜索群失败");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_SEARCH_CLUSTER_FAIL;
			client.fireQQEvent(e);
		}
	}

	// 处理修改群信息的回复包
	private void processClusterModifyInfoReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("群信息修改成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_CLUSTER_INFO_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("群信息修改失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_MODIFY_CLUSTER_INFO_FAIL;
			client.fireQQEvent(e);
		}
	}

	// 处理认证信息发送的回复包
	private void processClusterJoinAuthReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("认证信息发送成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_JOIN_CLUSTER_AUTH_SEND_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("认证信息发送失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_JOIN_CLUSTER_AUTH_SEND_FAIL;
			client.fireQQEvent(e);
		}
	}

	// 处理加入群的回复包
	private void processClusterJoinReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
		    switch(packet.joinReply) {
		        case QQ.QQ_CLUSTER_JOIN_OK:
					//log.debug("加入群成功");
					e = new QQEvent(packet);
					e.type = QQEvent.QQ_JOIN_CLUSTER_SUCCESS;
					client.fireQQEvent(e);
					break;
				case QQ.QQ_CLUSTER_JOIN_NEED_AUTH:
					//log.debug("对方需要认证");
					e = new QQEvent(packet);
					e.type = QQEvent.QQ_JOIN_CLUSTER_NEED_AUTH;
					client.fireQQEvent(e);
					break;
				case QQ.QQ_CLUSTER_JOIN_DENIED:
				    //log.debug("对方禁止加入成员");
					e = new QQEvent(packet);
					e.type = QQEvent.QQ_JOIN_CLUSTER_DENIED;
					client.fireQQEvent(e);
					break;
				default:
				    //log.debug("收到加入群的回复，但是回复码未知，抛弃该包");
					break;
		    }
		} else {
			//log.debug("加入群失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_JOIN_CLUSTER_FAIL;
			client.fireQQEvent(e);
		}
	}

    /**
     * @param packet
     */
    private void processClusterExitTempClusterReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
		packet.clusterId = ccp.getClusterId();
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("退出群成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_EXIT_TEMP_CLUSTER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("退出群失败");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_EXIT_TEMP_CLUSTER_FAIL;
			client.fireQQEvent(e);
		}
    }

	/**
	 * 处理退出群的回复包
	 *
	 * @param packet
	 */
	private void processClusterExitReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("退出群成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_EXIT_CLUSTER_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("退出群失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);
			packet.clusterId = ccp.getClusterId();
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_EXIT_CLUSTER_FAIL;
			client.fireQQEvent(e);
		}
	}

	// 处理得到群成员信息的回复包
	private void processClusterGetMemberInfoReply(ClusterCommandReplyPacket packet) {
		QQEvent e;
		if(packet.replyCode == QQ.QQ_REPLY_OK) {
			//log.debug("得到群成员信息成功");
			e = new QQEvent(packet);
			e.type = QQEvent.QQ_GET_MEMBER_INFO_SUCCESS;
			client.fireQQEvent(e);
		} else {
			//log.debug("得到群成员信息失败");
			ClusterCommandPacket ccp = (ClusterCommandPacket)monitor.retrieveRequest(packet);