Списывание ОС(Gp)

Код:

	@Override
	public void updateGloryPoints(final int playerId, final int gp) {
		Connection con = null;
		try {
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(UPDATE_GLORY_POINTS);
			stmt.setInt(1, gp);
			stmt.setInt(2, playerId);
			stmt.execute();
			stmt.close();
		}
		catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		finally {
			DatabaseFactory.close(con);
		}
	}

MySQL5AbyssRankDAO.java

Код:

	public void GpUpdateTask() {
		log.info("[GP SCHEDULED] Update gp start.");
		CronService.getInstance().schedule(new Runnable() {
			public void run() {
				AbyssRankUpdateService.this.loadGpRank();
			}
		}, RankingConfig.GP_UPDATE_TASK);
	}
 
	private void loadGpRank() {
		List<Integer> rankPlayers = DAOManager.getDAO(AbyssRankDAO.class).RankPlayers(9);
		reduceGP(rankPlayers);
	}
 
	private void reduceGP(List<Integer> rankPlayers) {
		log.info("[GP SCHEDULED] Task Scheduled delete GP.");
		for (int playerId : rankPlayers) {
			AbyssRank rank = DAOManager.getDAO(AbyssRankDAO.class).loadAbyssRank(playerId);
			Player player = World.getInstance().findPlayer(playerId);
			int lostGp = rank.getRank().getDailyReduceGp();
			if (rank.getRank().getId() < AbyssRankEnum.STAR1_OFFICER.getId())
				continue;
			if (player != null) {
				PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1402082, new Object[0]));
				PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1402209, player.getName(), rank.getRank().getDailyReduceGp()));
				AbyssPointsService.addGp(player, lostGp * -1);
			} else {
				int newGP = rank.getGp() - lostGp;
				if (newGP < 0)
					newGP = 0;
				DAOManager.getDAO(AbyssRankDAO.class).updateGloryPoints(playerId, newGP);
			}
		}
	}

AbyssRankUpdateService.java

Код:

	public abstract void updateGloryPoints(final int playerId, final int gp);
				   public abstract List<Integer> RankPlayers(final int rank);

AbyssRankDAO.java

психанул

 

Держи. Закинешь в сервис AbyssRankUpdateService

loadOrUpdateWeeklyReward метод настрой под себя

Код:

public void rewardWeeklyUpdate() {
		
		CronService.getInstance().schedule(new Runnable() {

			public void run() {
				List<Integer> rankPlayers = DAOManager.getDAO(AbyssRankDAO.class).loadWeeklyRewardPlayers(9);
				loadOrUpdateWeeklyReward(rankPlayers);
			}
		}, RankingConfig.WEEKLY_REWARDS);
	}

private void loadOrUpdateWeeklyReward(List<Integer> rankPlayers) {
		for (Integer playerId : rankPlayers) {
			AbyssRank rank = DAOManager.getDAO(AbyssRankDAO.class).loadAbyssRank(playerId);
			Player player = World.getInstance().findPlayer(playerId);
			int medalReward = rank.getRank().getMedalReward();
			int apReward = rank.getRank().getAbyssPointReward();
			String name = DAOManager.getDAO(PlayerDAO.class).getPlayerNameByObjId(playerId);	   
		   
			// Lost Glory point's
			int rankId = rank.getRank().getId();
			if ((rankId > 14) && (rank.getGp() > 0) && (rank.getWeeklyGP() < 12550)) {
				rank.setGP(rank.getGp() - 5210);
				DAOManager.getDAO(AbyssRankDAO.class).updateGp(playerId, rank);
				SystemMailService.getInstance().sendMail("Система", name, "Рейтинг бездны", "Требуемый еженедельный вклад не внесен. Списано 5210 очков славы.", 0, 0, 0, 0, LetterType.NORMAL);
			}
			else if ((rankId > 9 && rankId < 15) && (rank.getGp() > 0) && (rank.getWeeklyGP() < 1450)) {
				rank.setGP(0);
				DAOManager.getDAO(AbyssRankDAO.class).updateGp(playerId, rank);
				SystemMailService.getInstance().sendMail("Система", name, "Рейтинг бездны", "Требуемый еженедельный вклад не внесен. Очки славы обнулены.", 0, 0, 0, 0, LetterType.NORMAL);
			}
		}
	   
		AbyssRankUpdateService.this.performUpdate();
	   
		ThreadPoolManager.getInstance().schedule(new Runnable() {
		   
			@Override
			public void run() {
				rankPlayers.clear();
			}
		}, 2000);
	}

	public void scheduleUpdate() {
		ThreadPoolManager.getInstance().schedule(new Runnable() {
		   
			@Override
			public void run() {
				log.info("AbyssRankUpdateService: ranks update scheduled.");
				ServerVariablesDAO dao = DAOManager.getDAO(ServerVariablesDAO.class);
				int nextTime = dao.load("abyssRankUpdate");
				if (nextTime < System.currentTimeMillis() / 1000L)
					performUpdate();
			   
				CronService.getInstance().schedule(new Runnable() {

					public void run() {
						AbyssRankUpdateService.this.performUpdate();
					}
				}, RankingConfig.TOP_RANKING_UPDATE_RULE, true);
			}
		}, 1000);
	   
	}

	public void performUpdate() {
		long startTime = System.currentTimeMillis();
		updateLimitedRanks();
		AbyssRankingCache.getInstance().reloadRankings();
		Long.valueOf((System.currentTimeMillis() - startTime) / 1000L);
	}

DAO

Код:

	
	public abstract List<Integer> loadWeeklyRewardPlayers(int rank);
   
	public abstract void updateGp(int playerId, AbyssRank rank);

Sql5

Код:

public static final String SELECT_WEEKLY_REWARD = "SELECT player_id FROM abyss_rank WHERE rank > ?";
	public static final String UPDATE_WEEKLY_REWARD = "UPDATE abyss_rank SET gp = ? WHERE player_id = ?";

	@Override
	public List<Integer> loadWeeklyRewardPlayers(int rank) {
		List<Integer> players = new ArrayList<Integer>();
		Connection con = null;
		PreparedStatement stmt = null;
		try {
			con = DatabaseFactory.getConnection();
			stmt = con.prepareStatement(SELECT_WEEKLY_REWARD);
			stmt.setInt(1, rank);
			ResultSet resultSet = stmt.executeQuery();
			while (resultSet.next()) {
				int playerId = resultSet.getInt("player_id");
				if (!players.contains(playerId))
					players.add(playerId);
			}
		}
		catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		finally {
			DatabaseFactory.close(stmt, con);
		}
		return players;
	}
	
	@Override
	public void updateGp(int playerId, final AbyssRank rank) {
		Connection con = null;
		try {
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(UPDATE_WEEKLY_REWARD);
			stmt.setInt(1, rank.getGp());
			stmt.setInt(2, playerId); // Default
			stmt.execute();
			stmt.close();
		}
		catch (SQLException e) {
			log.error("updateGp", e);
		}
		finally {
			DatabaseFactory.close(con);
		}
	}

 

Добавь геттер и сеттер в AbyssRank

Код:

	public int getGp() {
		return this.currentGP;
	}
	
	public void setGP(int currentGP) {
		this.currentGP = currentGP;
	}