Method testRank

ZezeJava/ZezeJavaTest/src/UnitTest/Zeze/Game/TestRank.java:67–114

()

	}

	public void testRank() {
		if (disableTest)
			return;

		try {
			System.out.println("------ testRank begin");
			SimpleApp app = apps[0]; // 可以随便取一个, 不过都是对称的, 应该不用都测

			app.rank.setFuncConcurrentLevel(rankType -> CONC_LEVEL);
			int concLevel = app.rank.getConcurrentLevel(RANK_TYPE);
			var rankKey = Rank.newRankKey(RANK_TYPE, BConcurrentKey.TimeTypeTotal);
			LongUnaryOperator roleId2Value = roleId -> roleId * 10;

			for (int hash = 0; hash < concLevel; hash++) {
				int h = hash;
				long roleId = ROLE_ID_BEGIN + h;
				app.getZeze().newProcedure(() -> {
					app.rank.updateRank(h, rankKey, roleId, new BValueLong(roleId2Value.applyAsLong(roleId))).await().onSuccess(r -> {
						assertNotNull(r);
						assertEquals(Procedure.Success, r.longValue());
					}).onFail(e -> {
						e.printStackTrace();
						fail();
					});
					return Procedure.Success;
				}, "updateRank").call();
			}

			app.getZeze().newProcedure(() -> {
				// 直接从数据库读取并合并
				var result = app.rank.getRankDirect(rankKey);
//				System.out.format("--- getRankDirect: concurrent=%d, rankList=[%d]:%s%n",
//						concLevel, result.getRankList().size(), result);
				assertEquals(concLevel, result.getRankList().size());
				for (BRankValue rank : result.getRankList()) {
					assertTrue(rank.getRoleId() >= ROLE_ID_BEGIN && rank.getRoleId() < ROLE_ID_BEGIN + concLevel);
					assertEquals(roleId2Value.applyAsLong(rank.getRoleId()), ((BValueLong)rank.getDynamic().getBean()).getValue());
				}
				return Procedure.Success;
			}, "getRankDirect").call();
		} catch (Throwable e) {
			// print stacktrace.
			e.printStackTrace();
			throw e;
		} finally {
			System.out.println("------ testRank end");
		}
	}

	// 用于生成Redirect代码
	public static void main(String[] args) throws Exception {