clustercommandreplypacket.java

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

			case QQ.QQ_CLUSTER_CMD_SEND_TEMP_IM:
			    parseSendTempClusterIMReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_CREATE_CLUSTER:
				parseCreateReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_CREATE_TEMP:
			    parseCreateTempCluster(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_ACTIVATE_CLUSTER:
				parseActivateReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_MODIFY_MEMBER:
				parseModifyMemberReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_CLUSTER_INFO:
				parseGetInfoReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_EXIT_CLUSTER:
				parseExitReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_MEMBER_INFO:
				parseGetMemberInfoReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_ONLINE_MEMBER:
				parseGetOnlineMemberReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_JOIN_CLUSTER:
				parseJoinReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_JOIN_CLUSTER_AUTH:
				parseJoinAuthReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_MODIFY_CLUSTER_INFO:
				parseModifyInfoReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_SEARCH_CLUSTER:
				parseSearchReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_TEMP_INFO:
			    parseGetTempClusterInfoReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_EXIT_TEMP:
			    parseExitTempClusterReply(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_ACTIVATE_TEMP:
			    parseActivateTempCluster(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_SUB_CLUSTER_OP:
				parseSubClusterOp(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_UPDATE_ORGANIZATION:
				parseUpdateOrganization(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_COMMIT_ORGANIZATION:
				parseCommitOrganization(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_COMMIT_MEMBER_ORGANIZATION:
				parseCommitMemberOrganization(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_MODIFY_TEMP_INFO:
				parseModifyTempClusterInfo(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_MODIFY_CARD:
				parseModifyCard(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_CARD_BATCH:
				parseGetCardBatch(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_GET_CARD:
				parseGetCard(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_SET_ROLE:
				parseSetRole(buf);
				break;
			case QQ.QQ_CLUSTER_CMD_TRANSFER_ROLE:
				parseTransferRole(buf);
				break;
		}

		// 如果操作失败
		if(replyCode != QQ.QQ_REPLY_OK) {
			switch(subCommand) {
				case QQ.QQ_CLUSTER_CMD_TRANSFER_ROLE:
					clusterId = buf.getInt();
					memberQQ = buf.getInt();
					errorMessage = Util.getString(buf);
					break;
				case QQ.QQ_CLUSTER_CMD_SET_ROLE:
					clusterId = buf.getInt();
					errorMessage = Util.getString(buf);
					break;
				default:
					/* 操作失败 */
					errorMessage = Util.getString(buf);
					break;
			}
		}
    }

    /**
     * 处理转让角色的回复包
     *
     * @param buf
     */
    private void parseTransferRole(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			memberQQ = buf.getInt();
			versionId = buf.getInt();
		}
	}

	/**
     * 处理设置群成员角色的回复包
     *
     * @param buf
     */
    private void parseSetRole(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			versionId = buf.getInt();
			memberQQ = buf.getInt();
			role = buf.get();
		}
	}

	/**
     * 处理得到单个成员群名片回复包
     *
     * @param buf
     */
    private void parseGetCard(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			memberQQ = buf.getInt();
			card = new Card();
			card.readBean(buf);
		}
	}

	/**
     * 处理批量得到群名片真实姓名回复包
     *
     * @param buf
     */
    private void parseGetCardBatch(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			cardVersionId = buf.getInt();
			cardStubs = new ArrayList<CardStub>();
			nextStart = buf.getInt();
			while(buf.hasRemaining()) {
				CardStub stub = new CardStub();
				stub.readBean(buf);
				cardStubs.add(stub);
			}
		}
	}

	/**
     * 解析修改群名片回复包
     *
     * @param buf
     */
    private void parseModifyCard(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
		}
	}

	/**
     * 处理修改临时群信息回复包
     *
     * @param buf
     */
    private void parseModifyTempClusterInfo(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			type = buf.get();
			parentClusterId = buf.getInt();
			clusterId = buf.getInt();
		}
	}

	/**
     * 处理提交成员分组情况的回复包
     *
     * @param buf
     */
    private void parseCommitMemberOrganization(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			memberOrganziationVersionId = buf.getInt();
		}
	}

	/**
     * 处理提交组织架构的回复包
     *
     * @param buf
     */
    private void parseCommitOrganization(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			organizationVersionId = buf.getInt();
			organizationCount = buf.getChar();
		}
	}

	/**
     * 解析更新组织架构回复包
     *
     * @param buf
     * 		ByteBuffer
     */
    private void parseUpdateOrganization(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			organizations = new ArrayList<QQOrganization>();
			clusterId = buf.getInt();
			buf.get();
			organizationVersionId = buf.getInt();
			if(organizationVersionId != 0) {
				organizationCount = buf.get() & 0xFF;
				while(buf.hasRemaining()) {
					QQOrganization org = new QQOrganization();
					org.readBean(buf);
					organizations.add(org);
				}
			}
		}
	}

	/**
     * 解析子群操作回复包
     *
     * @param buf
     */
    private void parseSubClusterOp(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			subClusterOpByte = buf.get();
			clusterId = buf.getInt();
			externalId = buf.getInt();
			subClusters = new ArrayList<SimpleClusterInfo>();
			while(buf.hasRemaining()) {
				SimpleClusterInfo s = new SimpleClusterInfo();
				s.readBean(buf);
				subClusters.add(s);
			}
		}
	}

	/**
     * @param buf
     */
    private void parseCreateTempCluster(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
		    type = buf.get();
			parentClusterId = buf.getInt();
			clusterId = buf.getInt();
		}
    }

    /**
     * @param buf
     */
    private void parseExitTempClusterReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
		    type = buf.get();
			parentClusterId = buf.getInt();
			clusterId = buf.getInt();
		}
    }

    /**
     * 处理发送临时群信息的回复包
     *
     * @param buf
     */
    private void parseSendTempClusterIMReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
		    type = buf.get();
			parentClusterId = buf.getInt();
			clusterId = buf.getInt();
		}
    }

    /**
	 * 处理修改群成员的回复包
	 *
	 * @param buf
	 */
	private void parseModifyMemberReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK)
			clusterId = buf.getInt();
	}

	/**
	 * 处理发送消息的回复包
	 *
	 * @param buf
	 */
	private void parseSendIMReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
		}
	}

	/**
	 * 处理搜索群的回复包
	 *
	 * @param buf
	 */
	private void parseSearchReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			searchType = buf.get();
			clusters = new ArrayList<ClusterInfo>();
			while(buf.hasRemaining()) {
				ClusterInfo ci = new ClusterInfo();
				ci.readClusterInfoFromSearchReply(buf);
				clusters.add(ci);
			}
		}
	}

	/**
	 * 处理修改群信息的回复包
	 *
	 * @param buf
	 */
	private void parseModifyInfoReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
		}
	}

	/**
	 * 处理认证信息的回复包，这个回复包只是个简单的回复，没什么用
	 *
	 * @param buf
	 */
	private void parseJoinAuthReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
		}
	}

	/**
	 * 处理加入群的回复包
	 *
	 * @param buf
	 */
	private void parseJoinReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			joinReply = buf.get();
		}
	}

	/**
	 * 处理得到在线成员的回复包
	 *
	 * @param buf
	 */
	private void parseGetOnlineMemberReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			// 内部ID
			clusterId = buf.getInt();
			// 未知字节，0x3C
			buf.get();
			// 成员信息
			onlineMembers = new ArrayList<Integer>();
			while(buf.hasRemaining())
				onlineMembers.add(buf.getInt());
		}
	}

    /**
     * @param buf
     */
    private void parseActivateTempCluster(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
		    // 临时群类型
		    type = buf.get();
			// 父群内部ID
			parentClusterId = buf.getInt();
			// 临时群内部ID
			clusterId = buf.getInt();
			// 成员信息
			members = new ArrayList<Member>();
			while(buf.hasRemaining()) {
				Member member = new Member();
				member.qq = buf.getInt();
			    members.add(member);
			}
		}
    }

	/**
	 * 处理得到群成员信息的回复包
	 *
	 * @param buf
	 */
	private void parseGetMemberInfoReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			// 成员信息
			memberInfos = new ArrayList<QQFriend>();
			while(buf.hasRemaining()) {
				QQFriend friend = new QQFriend();
				friend.readBean(buf);
				memberInfos.add(friend);
			}
		}
	}

	/**
	 * 处理退出群的回复包
	 *
	 * @param buf
	 */
	private void parseExitReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK)
			clusterId = buf.getInt();
	}

	/**
	 * 处理得到群信息的回复包
	 *
	 * @param buf
	 */
	private void parseGetInfoReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			// 群信息
			info = new ClusterInfo();
			info.readClusterInfo(buf);
			clusterId = info.clusterId;
			externalId = info.externalId;
			// 读取成员列表
			members = new ArrayList<Member>();
			while(buf.hasRemaining()) {
				Member member = new Member();
				member.readBean(buf);
			    members.add(member);
			}
		}
	}

	/**
	 * 处理得到临时群信息的回复包
	 *
     * @param buf
     */
    private void parseGetTempClusterInfoReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			// 群信息
			info = new ClusterInfo();
			info.readTempClusterInfo(buf);
			type = info.type;
			clusterId = info.clusterId;
			parentClusterId = info.externalId;
			// 读取成员列表
			members = new ArrayList<Member>();
			while(buf.hasRemaining()) {
				Member member = new Member();
				member.readTempBean(buf);
			    members.add(member);
			}
		}
    }

	/**
	 * 处理激活群的回复包
	 *
	 * @param buf
	 */
	private void parseActivateReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK)
			clusterId = buf.getInt();
	}

	/**
	 * 解析创建群的回复包
	 *
	 * @param buf
	 */
	private void parseCreateReply(ByteBuffer buf) {
		if(replyCode == QQ.QQ_REPLY_OK) {
			clusterId = buf.getInt();
			externalId = buf.getInt();
		}
	}
}