Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- diff --git a/aCis_gameserver/config/votesystem.properties b/aCis_gameserver/config/votesystem.properties
- new file mode 100644
- index 0000000..10f1f93
- --- /dev/null
- +++ b/aCis_gameserver/config/votesystem.properties
- @@ -0,0 +1,95 @@
- +EnableVoteSystem = True
- +
- +EnableGlobalVote = True
- +
- +EnableIndividualVote = True
- +
- +## Time to Update table totalVotes from DB
- +NextTimeToAutoUpdateTotalVote = 2
- +
- +## Time to update table individualVotes
- +NextTimeToAutoUpdateIndividualVotes = 2
- +
- +NextTimeToAutoCleanInnecesaryVotes = 30
- +
- +NextTimeToCheckAutoGlobalVotesReward = 1
- +
- +IntervalToNextVote = 12
- +
- +GlobalVotesAmountToNextReward = 1
- +
- +EnableVotingCommand = True
- +
- +VotingCommand = .getreward
- +
- +## l2.topgameserver.net
- +VoteLinkTgs = http://l2.topgameserver.net/lineage/VoteApi/
- +
- +TgsApiKey =
- +
- +## l2top.co
- +VoteLinkTopCo = https://l2top.co/reward/
- +
- +TopCoSrvId =
- +
- +## ITopz.com
- +VoteLinkItopz = https://itopz.com/check/
- +
- +ItopzZpiKey =
- +
- +ItopzSrvId =
- +
- +## l2votes.com
- +VoteLinkVts = https://l2votes.com/
- +
- +VtsApiKey =
- +
- +VtsSid =
- +
- +## Hopzone.net
- +VoteLinkHz = https://api.hopzone.net/lineage2/
- +
- +HzApiKey =
- +
- +## l2network.eu
- +VoteNetworkLink = https://l2network.eu/api.php
- +
- +VoteNetworkUserName =
- +
- +VoteNetworkApiKey =
- +
- +## L2TopServer.com
- +VoteLinkTss = https://l2topservers.com/votes?
- +
- +TssApiToken =
- +
- +TsSrvId = 453
- +
- +TsDomainName= l2catgang
- +
- +## top.l2jbrasil.com
- +BrasilVoteLink = https://top.l2jbrasil.com/votesystem/index.php?
- +
- +BrasilUserName = julioguzman
- +
- +## Mmotop.eu
- +VoteLinkMmotop = https://l2jtop.com/api/
- +
- +MmotopApiKey =
- +
- +## L2TopZone.com
- +VoteLinkTz = https://api.l2topzone.com/v1/
- +
- +TzApiKey =
- +
- +## L2Servers.com
- +VoteLinkServers = https://www.l2servers.com/api/
- +
- +ServersHashCode =
- +
- +ServersSrvId =
- +
- +
- +## for localhost test if your project is live, put the word off or leave it blank
- +TestIp =
- +
- diff --git a/aCis_gameserver/java/net/sf/l2j/Config.java b/aCis_gameserver/java/net/sf/l2j/Config.java
- index 4b7181f..800de1e 100644
- --- a/aCis_gameserver/java/net/sf/l2j/Config.java
- +++ b/aCis_gameserver/java/net/sf/l2j/Config.java
- import java.util.Properties;
- + import java.util.concurrent.TimeUnit;
- import java.util.logging.Level;
- @@ -35,6 +35,7 @@
- public static final String PLAYERS_FILE = "./config/players.properties";
- public static final String SERVER_FILE = "./config/server.properties";
- public static final String SIEGE_FILE = "./config/siege.properties";
- + public static final String VOTE_SYSTEM_FILE = "./config/votesystem.properties";
- // --------------------------------------------------
- // Clans settings
- @@ -461,6 +462,52 @@
- public static int MAX_DEFENDERS_NUMBER;
- public static int ATTACKERS_RESPAWN_DELAY;
- +
- + //---------------------------------------------------
- + // VOTE SYSTEM
- + //---------------------------------------------------
- + public static boolean ENABLE_VOTE_SYSTEM;
- + public static boolean ENABLE_INDIVIDUAL_VOTE;
- + public static boolean ENABLE_GLOBAL_VOTE;
- + public static long NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE;
- + public static long NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES;
- + public static long NEXT_TIME_TO_AUTO_CLEAN_INECESARY_VOTES;
- + public static long NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD;
- + public static long INTERVAL_TO_NEXT_VOTE;
- + public static int GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD;
- + public static boolean ENABLE_VOTING_COMMAND;
- + public static String VOTING_COMMAND;
- + public static String VOTE_LINK_TGS;
- + public static String TGS_API_KEY;
- + public static String VOTE_LINK_TOP_CO;
- + public static String TOP_CO_SRV_ID;
- + public static String VOTE_LINK_ITOPZ;
- + public static String ITOPZ_API_KEY;
- + public static String ITOPZ_SRV_ID;
- + public static String VOTE_LINK_VTS;
- + public static String VTS_API_KEY;
- + public static String VTS_SID;
- + public static String VOTE_LINK_HZ;
- + public static String HZ_API_KEY;
- + public static String VOTE_NETWORK_LINK;
- + public static String VOTE_NETWORK_USER_NAME;
- + public static String VOTE_NETWORK_API_KEY;
- + public static String VOTE_LINK_TSS;
- + public static String TSS_API_TOKEN;
- + public static String TS_SRV_ID;
- + public static String TS_DOMAIN_NAME;
- + public static String BRASIL_VOTE_LINK;
- + public static String BRASIL_USER_NAME;
- + public static String VOTE_LINK_MMOTOP;
- + public static String MMOTOP_API_KEY;
- + public static String VOTE_LINK_TZ;
- + public static String TZ_API_KEY;
- + public static String VOTE_LINK_SERVERS;
- + public static String SERVERS_HASH_CODE;
- + public static String SERVERS_SRV_ID;
- + public static String TEST_IP;
- +
- +
- // --------------------------------------------------
- // Server
- // --------------------------------------------------
- @@ -1102,6 +1149,52 @@
- ATTACKERS_RESPAWN_DELAY = sieges.getProperty("AttackerRespawn", 10000);
- }
- + private static final void loadVoteSystem()
- + {
- + final ExProperties votesystem = initProperties(Config.VOTE_SYSTEM_FILE);
- +
- + ENABLE_VOTE_SYSTEM = votesystem.getProperty("EnableVoteSystem", true);
- + ENABLE_INDIVIDUAL_VOTE = votesystem.getProperty("EnableIndividualVote", true);
- + ENABLE_GLOBAL_VOTE = votesystem.getProperty("EnableGlobalVote", true);
- + NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE = TimeUnit.MINUTES.toMillis(votesystem.getProperty("NextTimeToAutoUpdateTotalVote", 60));// -> minutes
- + NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES = TimeUnit.MINUTES.toMillis(votesystem.getProperty("NextTimeToAutoUpdateIndividualVotes", 60));// -> minutes
- + NEXT_TIME_TO_AUTO_CLEAN_INECESARY_VOTES = TimeUnit.MINUTES.toMillis(votesystem.getProperty("NextTimeToAutoCleanInnecesaryVotes", 30));// -> minutes
- + NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD = TimeUnit.MINUTES.toMillis(votesystem.getProperty("NextTimeToCheckAutoGlobalVotesReward", 5));// -> minutes
- + INTERVAL_TO_NEXT_VOTE = TimeUnit.HOURS.toMillis(votesystem.getProperty("IntervalTimeToNextVote", 12)); // -> hours
- + GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD = votesystem.getProperty("GlobalVotesAmountToNextReward",50);
- + ENABLE_VOTING_COMMAND = votesystem.getProperty("EnableVotingCommand",true);
- + VOTING_COMMAND = votesystem.getProperty("VotingCommand","getreward");
- + VOTE_LINK_TGS = votesystem.getProperty("VoteLinkTgs","");
- + TGS_API_KEY = votesystem.getProperty("TgsApiKey","");
- + VOTE_LINK_TOP_CO = votesystem.getProperty("VoteLinkTopCo","");
- + TOP_CO_SRV_ID = votesystem.getProperty("TopCoSrvId","");
- + VOTE_LINK_ITOPZ = votesystem.getProperty("VoteLinkItopz","");
- + ITOPZ_API_KEY = votesystem.getProperty("ItopzZpiKey","");
- + ITOPZ_SRV_ID = votesystem.getProperty("ItopzSrvId","");
- + VOTE_LINK_VTS = votesystem.getProperty("VoteLinkVts","");
- + VTS_API_KEY = votesystem.getProperty("VtsApiKey","");
- + VTS_SID = votesystem.getProperty("VtsSid","");
- + VOTE_LINK_HZ = votesystem.getProperty("VoteLinkHz","");
- + HZ_API_KEY = votesystem.getProperty("HzApiKey","");
- + VOTE_NETWORK_LINK = votesystem.getProperty("VoteNetworkLink","");
- + VOTE_NETWORK_USER_NAME = votesystem.getProperty("VoteNetworkUserName","");
- + VOTE_NETWORK_API_KEY = votesystem.getProperty("VoteNetworkApiKey","");
- + VOTE_LINK_TSS = votesystem.getProperty("VoteLinkTss","");
- + TSS_API_TOKEN = votesystem.getProperty("TssApiToken","");
- + TS_SRV_ID = votesystem.getProperty("TsSrvId","");
- + TS_DOMAIN_NAME = votesystem.getProperty("TsDomainName","");
- + BRASIL_VOTE_LINK = votesystem.getProperty("BrasilVoteLink","");
- + BRASIL_USER_NAME = votesystem.getProperty("BrasilUserName","");
- + VOTE_LINK_MMOTOP = votesystem.getProperty("VoteLinkMmotop","");
- + MMOTOP_API_KEY = votesystem.getProperty("MmotopApiKey","");
- + VOTE_LINK_TZ = votesystem.getProperty("VoteLinkTz","");
- + TZ_API_KEY = votesystem.getProperty("TzApiKey","");
- + VOTE_LINK_SERVERS = votesystem.getProperty("VoteLinkServers","");
- + SERVERS_HASH_CODE = votesystem.getProperty("ServersHashCode","");
- + SERVERS_SRV_ID = votesystem.getProperty("ServersSrvId","");
- + TEST_IP = votesystem.getProperty("TestIp","");
- + }
- +
- /**
- * Loads gameserver settings.<br>
- * IP addresses, database, rates, feature enabled/disabled, misc.
- @@ -1309,6 +1402,9 @@
- // server settings
- loadServer();
- +
- + //vote settings
- + loadVoteSystem();
- }
- public static final void loadLoginServer()
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/GameServer.java b/aCis_gameserver/java/net/sf/l2j/gameserver/GameServer.java
- index 41a9f92..da97fd2 100644
- --- a/aCis_gameserver/java/net/sf/l2j/gameserver/GameServer.java
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/GameServer.java
- @@ -99,6 +99,8 @@
- import net.sf.l2j.gameserver.taskmanager.RandomAnimationTaskManager;
- import net.sf.l2j.gameserver.taskmanager.ShadowItemTaskManager;
- import net.sf.l2j.gameserver.taskmanager.WaterTaskManager;
- +import net.sf.l2j.gameserver.votesystem.Handler.voteManager;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteSiteXml;
- import net.sf.l2j.util.DeadLockDetector;
- import net.sf.l2j.util.IPv4Filter;
- @@ -194,6 +196,15 @@
- CrestCache.getInstance();
- ClanTable.getInstance();
- + StringUtil.printSection("Vote System");
- + if(Config.ENABLE_VOTE_SYSTEM) {
- + voteManager.getInatance();
- + LOGGER.info("======================Vote System Enabled=========================");
- + VoteSiteXml.getInstance();
- + }else {
- + LOGGER.info("======================Vote System Disabled=========================");
- + }
- +
- StringUtil.printSection("Geodata & Pathfinding");
- GeoEngine.getInstance();
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/Shutdown.java b/aCis_gameserver/java/net/sf/l2j/gameserver/Shutdown.java
- index 88a3dc4..8443463 100644
- --- a/aCis_gameserver/java/net/sf/l2j/gameserver/Shutdown.java
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/Shutdown.java
- @@ -27,6 +27,7 @@
- import net.sf.l2j.gameserver.network.serverpackets.ServerClose;
- import net.sf.l2j.gameserver.network.serverpackets.SystemMessage;
- import net.sf.l2j.gameserver.taskmanager.ItemsOnGroundTaskManager;
- +import net.sf.l2j.gameserver.votesystem.Handler.voteManager;
- /**
- * This class provides functions for shutting down and restarting the server. It closes all client connections and saves data.
- @@ -146,6 +147,10 @@
- LOGGER.info("CoupleManager data has been saved.");
- }
- + //Save global and individual votes
- + voteManager.getInatance().Shutdown();
- + LOGGER.info("Vote data has been saved");
- +
- // Save server memos.
- ServerMemoTable.getInstance().storeMe();
- LOGGER.info("ServerMemo data has been saved.");
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/handler/CustomCommandsHandler.java b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/CustomCommandsHandler.java
- new file mode 100644
- index 0000000..aca915c
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/CustomCommandsHandler.java
- @@ -0,0 +1,42 @@
- +package net.sf.l2j.gameserver.handler;
- +
- +import java.util.Map;
- +
- +import net.sf.l2j.gameserver.handler.customcommandHandler.VoteCommandHandler;
- +
- +import java.util.HashMap;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class CustomCommandsHandler {
- + private final Map<Integer, ICustomCommandsHandler> _datatable = new HashMap<>();
- +
- +
- +
- + protected CustomCommandsHandler() {
- + registerCustomCommandHandler(new VoteCommandHandler());
- + }
- +
- + public void registerCustomCommandHandler(ICustomCommandsHandler handler) {
- + for (String id : handler.getCustomCommandList())
- + _datatable.put(id.hashCode(), handler);
- + }
- +
- + public ICustomCommandsHandler getCustomCommandHandler(String customCommand) {
- + return _datatable.get(customCommand.hashCode());
- + }
- +
- + public int size() {
- + return _datatable.size();
- + }
- +
- + public static CustomCommandsHandler getInstance() {
- + return SingletonHolder._instance;
- + }
- +
- + private static class SingletonHolder {
- + protected static final CustomCommandsHandler _instance = new CustomCommandsHandler();
- + }
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/handler/ICustomCommandsHandler.java b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/ICustomCommandsHandler.java
- new file mode 100644
- index 0000000..5b4fda9
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/ICustomCommandsHandler.java
- @@ -0,0 +1,13 @@
- +package net.sf.l2j.gameserver.handler;
- +
- +import net.sf.l2j.gameserver.model.actor.Player;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public interface ICustomCommandsHandler
- +{
- + void useCustomCommand(String command, Player activeChar);
- + public String[] getCustomCommandList();
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/handler/customcommandHandler/VoteCommandHandler.java b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/customcommandHandler/VoteCommandHandler.java
- new file mode 100644
- index 0000000..36d318c
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/handler/customcommandHandler/VoteCommandHandler.java
- @@ -0,0 +1,71 @@
- +package net.sf.l2j.gameserver.handler.customcommandHandler;
- +
- +import net.sf.l2j.Config;
- +import net.sf.l2j.gameserver.handler.ICustomCommandsHandler;
- +import net.sf.l2j.gameserver.model.actor.Player;
- +import net.sf.l2j.gameserver.votesystem.DB.individualVoteDB;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +import net.sf.l2j.gameserver.votesystem.Handler.voteManager;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class VoteCommandHandler implements ICustomCommandsHandler
- +{
- +
- + @Override
- + public void useCustomCommand(String command, Player player)
- + {
- +
- + if (command.equalsIgnoreCase(Config.VOTING_COMMAND))
- + {
- + if(player.isInJail()) {
- + player.sendMessage("You cannot use this function while you are jailed");
- + return;
- + }
- + if(!Config.ENABLE_VOTE_SYSTEM) {
- + player.sendMessage("The rewards system has been disabled by your administrator");
- + return;
- + }
- + if(!Config.ENABLE_INDIVIDUAL_VOTE) {
- + player.sendMessage("The individual reward system is disabled");
- + return;
- + }
- + if(!Config.ENABLE_VOTING_COMMAND) {
- + player.sendMessage("Voting command reward is disabled");
- + return;
- + }
- +
- + for(voteSite vs : voteSite.values()) {
- + new Thread(()->{
- + voteManager.getInatance().getReward(player, vs.ordinal());
- + }).start();
- + }
- +
- + }
- + if(player.isGM() && command.equalsIgnoreCase(".reloadinvotes")) {
- + individualVoteDB.getInstance().loadVotes();
- + player.sendMessage("All individual votes has been recharged");
- + }
- + }
- +
- +
- + @Override
- + public String[] getCustomCommandList()
- + {
- + return new String[]
- + {
- + Config.VOTING_COMMAND,
- + ".reloadinvotes",
- + };
- + }
- + public static VoteCommandHandler getInstance()
- + {
- + return SingletonHolder._instance;
- + }
- + private static class SingletonHolder
- + {
- + protected static final VoteCommandHandler _instance = new VoteCommandHandler();
- + }
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/model/actor/instance/NpcVote.java b/aCis_gameserver/java/net/sf/l2j/gameserver/model/actor/instance/NpcVote.java
- new file mode 100644
- index 0000000..d4bf57f
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/model/actor/instance/NpcVote.java
- @@ -0,0 +1,87 @@
- +package net.sf.l2j.gameserver.model.actor.instance;
- +
- +import net.sf.l2j.Config;
- +import net.sf.l2j.gameserver.data.ItemTable;
- +import net.sf.l2j.gameserver.model.actor.Player;
- +import net.sf.l2j.gameserver.model.actor.template.NpcTemplate;
- +import net.sf.l2j.gameserver.network.serverpackets.NpcHtmlMessage;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +import net.sf.l2j.gameserver.votesystem.Handler.voteManager;
- +import net.sf.l2j.gameserver.votesystem.Model.Reward;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteSiteXml;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class NpcVote extends Folk
- +{
- +
- + /**
- + * @param objectId
- + * @param template
- + */
- + public NpcVote(int objectId, NpcTemplate template)
- + {
- + super(objectId, template);
- + // TODO Auto-generated constructor stub
- + }
- +
- + @Override
- + public void onBypassFeedback(Player player, String command)
- + {
- + if(command == null) {
- + return;
- + }
- + int Ordinalsite = Integer.parseInt(command);
- + voteManager.getInatance().getReward(player, Ordinalsite);
- + showChatWindow(player,0);
- + super.onBypassFeedback(player, command);
- + }
- +
- + @Override
- + public void showChatWindow(Player player, int val) {
- + final NpcHtmlMessage html = new NpcHtmlMessage(0);
- + StringBuilder sb = new StringBuilder();
- + html.setFile(getHtmlPath(getNpcId(), 0));
- + for(voteSite vs : voteSite.values()) {
- + sb.append("<table bgcolor=000000 width=280><tr>");
- + sb.append("<td width=42><img src=\"icon.etc_treasure_box_i08\" width=32 height=32></td>");
- + sb.append("<td width=220><table width=220>");
- + sb.append("<tr><td><table width=220><tr><td width=145>On "+String.format("%s",VoteSiteXml.getInstance().getSiteName(vs.ordinal()))+"</td>");
- + if(voteManager.getInatance().checkIndividualAvailableVote(player, vs.ordinal())) {
- + sb.append("<td width=75>"+String.format("<button value=\"Get reward\" action=\"bypass -h vote_%s_site %s\" height=17 width=64 back=\"sek.cbui94\" fore=\"sek.cbui92\">",getObjectId(),vs.ordinal())+"</td>");
- + }else {
- + sb.append(String.format("<td width=75 align=center><font color=C68E00>%s</font></td>", voteManager.getInatance().getTimeRemainingWithSampleFormat(player, vs.ordinal())));
- + }
- + sb.append("</tr></table></td></tr>");
- + sb.append("<tr><td><table width=220><tr>");
- + int i=0;
- + for(Reward r : VoteSiteXml.getInstance().getRewards(vs.ordinal())) {
- + sb.append(String.format("<td width=110 height=32 align=center><font color=BFAF00>%s x%s</font></td>",ItemTable.getInstance().getTemplate(r.getItemId()).getName(), r.getItemCount()));
- + i++;
- + if(i%2==0) {
- + sb.append("</tr><tr>");
- + }
- + }
- + sb.append("</tr></table></td></tr></table></td></tr></table><br>");
- + }
- + html.replace("%everyXtime%",Config.INTERVAL_TO_NEXT_VOTE/(3600*1000));
- + html.replace("%enablevote%", sb.toString());
- + html.replace("%accountName%",player.getName());
- + player.sendPacket(html);
- + }
- +
- + @Override
- + public String getHtmlPath(int npcId, int val)
- + {
- + String filename = "";
- + if (val == 0)
- + filename = "" + npcId;
- + else
- + filename = npcId + "-" + val;
- +
- + return "data/html/mods/votesystem/" + filename + ".html";
- + }
- +
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/network/clientpackets/RequestBypassToServer.java b/aCis_gameserver/java/net/sf/l2j/gameserver/network/clientpackets/RequestBypassToServer.java
- index cfd76fa..773eee2 100644
- --- a/aCis_gameserver/java/net/sf/l2j/gameserver/network/clientpackets/RequestBypassToServer.java
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/network/clientpackets/RequestBypassToServer.java
- @@ -99,6 +99,23 @@
- html.disableValidation();
- player.sendPacket(html);
- }
- + else if(_command.startsWith("vote_")) {
- + if (!player.validateBypass(_command))
- + return;
- +
- + int endOfId = _command.indexOf('_', 6);
- + String id;
- + if (endOfId > 0)
- + id = _command.substring(5, endOfId);
- + else
- + id = _command.substring(5);
- +
- + if(_command.split(" ")[1].toString() != null) {
- + final WorldObject object = World.getInstance().getObject(Integer.parseInt(id));
- + if (object != null && object instanceof Npc && endOfId > 0 && ((Npc) object).canInteract(player))
- + ((Npc) object).onBypassFeedback(player, _command.split(" ")[1].toString());
- + }
- + }
- else if (_command.startsWith("npc_"))
- {
- if (!player.validateBypass(_command))
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/globalVoteDB.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/globalVoteDB.java
- new file mode 100644
- index 0000000..43865e9
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/globalVoteDB.java
- @@ -0,0 +1,104 @@
- +package net.sf.l2j.gameserver.votesystem.DB;
- +
- +import java.sql.Connection;
- +import java.sql.PreparedStatement;
- +import java.sql.ResultSet;
- +import java.sql.SQLException;
- +import java.sql.Statement;
- +
- +import net.sf.l2j.commons.logging.CLogger;
- +
- +import net.sf.l2j.L2DatabaseFactory;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +import net.sf.l2j.gameserver.votesystem.Model.globalVote;
- +
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class globalVoteDB
- +{
- + public static final CLogger LOGGER = new CLogger(globalVoteDB.class.getName());
- + private Statement st;
- + private Connection con;
- + private globalVote[] _globalVotes;
- + private globalVoteDB() {
- + _globalVotes = new globalVote[voteSite.values().length];
- + loadGlobalVotes();
- + }
- +
- + public void loadGlobalVotes() {
- + con = L2DatabaseFactory.getInstance().getConnection();
- + try(PreparedStatement ps = con.prepareStatement("Select voteSite,lastRewardVotes from globalvotes");
- + ResultSet rs = ps.executeQuery();){
- + if(rs.getRow() == 0){
- + for(voteSite vs : voteSite.values()){
- + globalVote gv = new globalVote();
- + gv.setVoteSite(vs.ordinal());
- + gv.setVotesLastReward(0);
- + _globalVotes[gv.getVoyeSite()] = gv;
- + }
- + return;
- + }
- + while(rs.next()) {
- + globalVote gv = new globalVote();
- + gv.setVoteSite(rs.getInt("voteSite"));
- + gv.setVotesLastReward(rs.getInt("lastRewardVotes"));
- + _globalVotes[gv.getVoyeSite()] = gv;
- + }
- + ps.close();
- + con.close();
- +
- + }catch(SQLException e) {
- + e.printStackTrace();
- + }
- + }
- + public void saveGlobalVote(globalVote gb) {
- + try(Connection con = L2DatabaseFactory.getInstance().getConnection();PreparedStatement ps = con.prepareStatement("INSERT INTO globalvotes(voteSite,lastRewardVotes) VALUES(?,?)"
- + + "ON DUPLICATE KEY UPDATE voteSite = VALUES(voteSite), lastRewardVotes = VALUES(lastRewardVotes)"))
- +
- + {
- + ps.setInt(1, gb.getVoyeSite());
- + ps.setInt(2, gb.getVotesLastReward());
- + ps.executeUpdate();
- +
- + ps.close();
- + con.close();
- +
- + }catch(SQLException e) {
- + e.printStackTrace();
- + }
- + }
- +
- + public void saveGlobalVotes(globalVote[] globalVotes) {
- + try(Connection con = L2DatabaseFactory.getInstance().getConnection();PreparedStatement ps = con.prepareStatement("INSERT INTO globalvotes(voteSite,lastRewardVotes) VALUES(?,?)"
- + + "ON DUPLICATE KEY UPDATE voteSite = VALUES(voteSite), lastRewardVotes = VALUES(lastRewardVotes)"))
- +
- + {
- + for(voteSite vs : voteSite.values()) {
- + globalVote gb = globalVotes[vs.ordinal()];
- + ps.setInt(1, gb.getVoyeSite());
- + ps.setInt(2, gb.getVotesLastReward());
- + ps.addBatch();
- + }
- + ps.executeBatch();
- +
- + ps.close();
- + con.close();
- +
- + }catch(SQLException e) {
- + e.printStackTrace();
- + }
- + }
- +
- + public globalVote[] getGlobalVotes() {
- + return _globalVotes;
- + }
- + public static final globalVoteDB getInstance() {
- + return SingleHolder.INSTANCE;
- + }
- + private static final class SingleHolder {
- + protected static final globalVoteDB INSTANCE = new globalVoteDB();
- + }
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/individualVoteDB.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/individualVoteDB.java
- new file mode 100644
- index 0000000..2cf9522
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/DB/individualVoteDB.java
- @@ -0,0 +1,160 @@
- +package net.sf.l2j.gameserver.votesystem.DB;
- +
- +
- +import java.sql.Connection;
- +import java.sql.PreparedStatement;
- +import java.sql.ResultSet;
- +import java.sql.SQLException;
- +import java.sql.Statement;
- +import java.util.HashMap;
- +import java.util.HashSet;
- +import java.util.Map;
- +import java.util.logging.Logger;
- +import net.sf.l2j.L2DatabaseFactory;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +
- +
- +import net.sf.l2j.gameserver.votesystem.Model.individualVote;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class individualVoteDB
- +{
- + private static final Logger LOGGER = Logger.getLogger(individualVoteDB.class.getName());
- + private Map<String,individualVote[]> _votes;
- + private Statement st;
- + private Connection con;
- +
- +
- + private individualVoteDB() {
- + _votes = new HashMap<>();
- + loadVotes();
- + }
- +
- + public void loadVotes() {
- +
- + _votes.clear();
- + try(Connection con = L2DatabaseFactory.getInstance().getConnection();PreparedStatement ps = con.prepareStatement("SELECT voterIp,voteSite,diffTime,votingTimeSite,alreadyRewarded FROM individualvotes");
- + ResultSet rs = ps.executeQuery();)
- + {
- + individualVote[] ivs = new individualVote[voteSite.values().length];
- + while(rs.next()) {
- + individualVote iv = new individualVote();
- + iv.setVoterIp(rs.getString("voterIp"));
- + iv.setVoteSite(rs.getInt("voteSite"));
- + iv.setDiffTime(rs.getLong("diffTime"));
- + iv.setVotingTimeSite(rs.getLong("votingTimeSite"));
- + iv.setAlreadyRewarded(rs.getBoolean("alreadyRewarded"));
- +
- + if(_votes.containsKey(iv.getVoterIp())) {
- + if(_votes.get(iv.getVoterIp())[iv.getVoteSite()] == null) {
- + ivs[iv.getVoteSite()] = iv;
- + _votes.replace(iv.getVoterIp(), ivs);
- + }
- + }else {
- + ivs[iv.getVoteSite()] = iv;
- + _votes.put(iv.getVoterIp(), ivs);
- +
- +
- + }
- + }
- +
- + }
- + catch (SQLException e)
- + {
- + e.printStackTrace();
- + }
- +
- + }
- +
- + public void SaveVotes(Map<String,individualVote[]> votes) {
- +
- + if(votes == null)
- + return;
- + if(votes.size() == 0) {
- + return;
- + }
- + try(Connection con = L2DatabaseFactory.getInstance().getConnection(); PreparedStatement ps = con.prepareStatement("INSERT INTO individualvotes(voterIp,voteSite,diffTime,votingTimeSite,alreadyRewarded) VALUES(?,?,?,?,?) ON DUPLICATE KEY UPDATE "
- + + "voterIp = VALUES(voterIp), voteSite = VALUES(voteSite), diffTime = VALUES(diffTime), votingTimeSite = VALUES(votingTimeSite),alreadyRewarded = VALUES(alreadyRewarded)");)
- + {
- +
- + for(Map.Entry<String, individualVote[]> ivm : votes.entrySet()) {
- + for(individualVote iv : ivm.getValue()) {
- + if(iv == null)
- + continue;
- + ps.setString(1, iv.getVoterIp());
- + ps.setInt(2, iv.getVoteSite());
- + ps.setLong(3, iv.getDiffTime());
- + ps.setLong(4, iv.getVotingTimeSite());
- + ps.setBoolean(5, iv.getAlreadyRewarded());
- + ps.addBatch();
- + }
- + }
- + ps.executeBatch();
- + }
- + catch (SQLException e)
- + {
- + e.printStackTrace();
- + }
- + }
- +
- + public void SaveVote(individualVote vote) {
- +
- + if(vote == null)
- + return;
- +
- + try(Connection con = L2DatabaseFactory.getInstance().getConnection(); PreparedStatement ps = con.prepareStatement("INSERT INTO individualvotes(voterIp,voteSite,diffTime,votingTimeSite,alreadyRewarded) VALUES(?,?,?,?,?) ON DUPLICATE KEY UPDATE"
- + + "voterIp = VALUES(voterIp), voteSite = VALUES(voteSite), diffTime = VALUES(diffTime), votingTimeSite = VALUES(votingTimeSite), alreadyRewarded = VALUES(alreadyRewarded)");)
- + {
- + ps.setString(1, vote.getVoterIp());
- + ps.setInt(2, vote.getVoteSite());
- + ps.setLong(3, vote.getDiffTime());
- + ps.setLong(4, vote.getVotingTimeSite());
- + ps.setBoolean(5, vote.getAlreadyRewarded());
- + ps.executeUpdate();
- + }
- + catch (SQLException e)
- + {
- + e.printStackTrace();
- + }
- + }
- +
- + public void DeleteVotes(HashSet<individualVote> deleteVotes) {
- + if(deleteVotes == null) {
- + return;
- + }
- + if(deleteVotes.size() == 0) {
- + return;
- + }
- + try {
- + con = L2DatabaseFactory.getInstance().getConnection();
- + st = con.createStatement();
- + for(individualVote iv : deleteVotes) {
- + String sql = String.format("Delete from individualvotes where voterIp = '%s' AND voteSite = %s", iv.getVoterIp(),iv.getVoteSite());
- + st.addBatch(sql);
- + }
- + int[] result = st.executeBatch();
- + st.close();
- + con.close();
- + LOGGER.info(result.length+" Innecesary votes has been deleted");
- +
- + }catch(SQLException e) {
- + e.printStackTrace();
- + }
- + }
- +
- + public Map<String,individualVote[]> getVotesDB(){
- + return _votes;
- + }
- +
- + public static final individualVoteDB getInstance()
- + {
- + return SingleHolder.INSTANCE;
- + }
- +
- + private static final class SingleHolder {
- + protected static final individualVoteDB INSTANCE = new individualVoteDB();
- + }
- +}
- \ No newline at end of file
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Enum/voteSite.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Enum/voteSite.java
- new file mode 100644
- index 0000000..4ce2a5d
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Enum/voteSite.java
- @@ -0,0 +1,20 @@
- +package net.sf.l2j.gameserver.votesystem.Enum;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public enum voteSite
- +{
- + L2TOPGAMESERVER,//0
- + ITOPZ,//1
- + L2TOPCO,//2
- + L2VOTES,//3
- + HOPZONE,//4
- + L2NETWORK,//5
- + L2TOPSERVERS,//6
- + TOPL2JBRASIL,//7
- + MMOTOP,//8
- + TOPZONE,//9
- + L2SERVERS,//10
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteHandler.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteHandler.java
- new file mode 100644
- index 0000000..8d0eb07
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteHandler.java
- @@ -0,0 +1,488 @@
- +package net.sf.l2j.gameserver.votesystem.Handler;
- +
- +import java.io.BufferedReader;
- +import java.io.DataOutputStream;
- +import java.io.InputStreamReader;
- +import java.net.HttpURLConnection;
- +import java.net.URL;
- +import java.nio.charset.Charset;
- +import java.text.ParseException;
- +import java.text.SimpleDateFormat;
- +import java.util.logging.Logger;
- +
- +import net.sf.l2j.Config;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +import net.sf.l2j.gameserver.votesystem.Model.individualVoteResponse;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteSiteXml;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteUtil;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class voteHandler {
- + public static final Logger LOGGER = Logger.getLogger(voteHandler.class.getName());
- +
- + protected static String getNetWorkResponse(String URL,int ordinal) {
- + if ((ordinal == voteSite.L2NETWORK.ordinal()) && ("".equals(Config.VOTE_NETWORK_API_KEY) || "".equals(Config.VOTE_NETWORK_LINK) || "".equals(Config.VOTE_NETWORK_USER_NAME)))
- + {
- + return "";
- + }
- +
- + StringBuffer response = new StringBuffer();
- + try {
- + String API_URL = Config.VOTE_NETWORK_LINK;
- + String detail = URL;
- + String postParameters = "";
- + postParameters +="apiKey="+VoteUtil.between("apiKey=", detail, "&type=");
- + postParameters += "&type="+VoteUtil.between("&type=", detail, "&player");
- + String beginIndexPlayer = "&player=";
- + String player = detail.substring(detail.indexOf(beginIndexPlayer)+beginIndexPlayer.length());
- +
- + if (player != null && !player.equals(""))
- + postParameters += "&player=" + player;
- +
- + byte[] postData = postParameters.getBytes(Charset.forName("UTF-8"));
- + URL url = new URL(API_URL);
- + HttpURLConnection con = (HttpURLConnection)url.openConnection();
- + con.setConnectTimeout(5000);
- + con.setRequestMethod("POST");
- + con.setRequestProperty("Content-Length", Integer.toString(postData.length));
- + con.setRequestProperty("User-Agent", "Mozilla/5.0");
- + con.setDoOutput(true);
- +
- + DataOutputStream os = new DataOutputStream(con.getOutputStream());
- + os.write(postData);
- + os.flush();
- + os.close();
- +
- + BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
- + String inputLine;
- +
- + while ((inputLine = in.readLine()) != null) {
- + response.append(inputLine);
- + }
- + in.close();
- +
- + return response.toString();
- +
- + } catch (Exception e) {
- + LOGGER.warning(VoteUtil.Sites[ordinal]+ " Say: An error ocurred "+ e.getCause());
- + return "";
- + }
- + }
- +
- + protected static String getResponse(String Url, int ordinal)
- + {
- + if ((ordinal == voteSite.L2NETWORK.ordinal()) && ("".equals(Config.VOTE_NETWORK_API_KEY) || "".equals(Config.VOTE_NETWORK_LINK) || "".equals(Config.VOTE_NETWORK_USER_NAME)))
- + {
- + return "";
- + }
- +
- + try
- + {
- + int responseCode = 0;
- + URL objUrl = new URL(Url);
- + HttpURLConnection con = (HttpURLConnection) objUrl.openConnection();
- + con.setRequestMethod("GET");
- + con.setRequestProperty("User-Agent", "Mozilla/5.0");
- + con.setConnectTimeout(5000);
- + responseCode = con.getResponseCode();
- + if (responseCode == HttpURLConnection.HTTP_OK) {
- + String inputLine;
- + StringBuffer response = new StringBuffer();
- + BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
- + while ((inputLine = in.readLine()) != null) {
- + response.append(inputLine);
- + }
- + in.close();
- + return response.toString();
- + }
- +
- + }
- + catch (Exception e)
- + {
- + LOGGER.warning(VoteSiteXml.getInstance().getSiteName(ordinal)+" Say: An error ocurred "+e.getCause());
- + return "";
- + }
- +
- + return "";
- + }
- +
- +
- + public static individualVoteResponse getIndividualVoteResponse(int ordinal,String ip, String AccountName)
- + {
- + String response = "";
- + boolean isVoted = false;
- + long voteSiteTime = 0L, diffTime = 0L;
- + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
- + individualVoteResponse ivr = new individualVoteResponse();
- +
- + switch(ordinal)
- + {
- + case 0:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"already_voted\":", response, ",\"vote_time\""));
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = format.parse(VoteUtil.between("\"vote_time\":\"", response, "\",\"server_time\"")).getTime();
- + diffTime = System.currentTimeMillis() - format.parse(VoteUtil.between("\"server_time\":\"", response, "\"}")).getTime();
- + }
- + catch (ParseException e)
- + {
- + e.printStackTrace();
- + }
- + }
- + break;
- +
- + case 1:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"isvoted\":", response.toString().toLowerCase().replaceAll("\n", "").replaceAll(" ", ""), ",\"votetime").replaceAll("\"", ""));
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = (Long.parseLong(VoteUtil.between("\"votetime\":", response.toString().toLowerCase().replaceAll("\n", "").replaceAll(" ", ""), ",\"servertime")))*1000;
- + diffTime = System.currentTimeMillis() - (Long.parseLong(VoteUtil.between("\"servertime\":", response.toLowerCase().replaceAll("\n", "").replaceAll(" ", ""), "}")))*1000;
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- + }
- + break;
- +
- + case 2:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false :Boolean.parseBoolean(response);
- + if(isVoted) {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + break;
- +
- + case 3:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (VoteUtil.between("\"status\":\"", response, "\",\"date\"") != "" && Integer.parseInt(VoteUtil.between("\"status\":\"", response, "\",\"date\"")) == 1) ? true : false;
- + if(isVoted) {
- + String dateString = VoteUtil.between("\"date\":\"", response, "\"}]");
- + try
- + {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- +
- + }
- + break;
- +
- + case 4:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"voted\":", response, ",\"voteTime\""));
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = format.parse(VoteUtil.between("\"voteTime\":\"", response, "\",\"hopzoneServerTime\"")).getTime();
- + diffTime = System.currentTimeMillis() - format.parse(VoteUtil.between("\"hopzoneServerTime\":\"", response, "\",\"status_code\":")).getTime();
- + }
- + catch (ParseException e)
- + {
- + e.printStackTrace();
- + }
- + }
- + break;
- +
- + case 5:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (!"".equals(response) && Integer.parseInt(response) == 1) ? true : false;
- + if(isVoted) {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + break;
- +
- + case 6:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = ("".equals(response)) ? false : Boolean.parseBoolean(VoteUtil.between("\"voted\":", response, ",\"voteTime\""));
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- +
- + }
- + break;
- +
- + case 7:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (VoteUtil.between("\"status\":\"", response, "\",\"server_time\"") != "" && Integer.parseInt(VoteUtil.between("\"status\":\"", response, "\",\"server_time\"")) == 1) ? true : false;
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- + }
- + break;
- +
- + case 8:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"is_voted\":", response, ",\"vote_time\""));
- + if(isVoted) {
- + try
- + {
- + voteSiteTime = (Long.parseLong(VoteUtil.between("\"vote_time\":", response, ",\"server_time\"")))*1000;
- + diffTime = System.currentTimeMillis() - Long.parseLong(VoteUtil.between("\"server_time\":",response,"}}"))*1000;
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- + }
- + break;
- +
- + case 9:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"isVoted\": ", response, ",\"voteTime\""));
- + if(isVoted) {
- + voteSiteTime = Long.parseLong(VoteUtil.between("\"voteTime\": \"", response, "\",\"serverTime\""))*1000;
- + diffTime = System.currentTimeMillis() - Long.parseLong(VoteUtil.between("\"serverTime\": ",response,"}}"))*1000;
- + }
- + break;
- +
- + case 10:
- + response = getResponse(getIndividualUrl(ordinal,ip,null),ordinal);
- + isVoted = (response == "") ? false : Boolean.parseBoolean(response);
- + if(isVoted) {
- + voteSiteTime = System.currentTimeMillis();
- + diffTime = 0;
- + }
- + break;
- +
- + }
- + if(!response.equals("")) {
- + ivr.setIsVoted(isVoted);
- + ivr.setDiffTime(diffTime);
- + ivr.setVoteSiteTime(voteSiteTime);
- + return ivr;
- + }
- + return null;
- + }
- +
- + public int getGlobalVotesResponse(int ordinal)
- + {
- +
- + String response = "";
- + int totalVotes = 0;
- +
- + switch(ordinal)
- + {
- + case 0:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("\"getVotes\":",response,"}");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 1:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("server_votes\":",response.replace(" ", ""),",\"server_rank");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 2:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 3:
- + response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("Votes:</th><th><a class='votes'>", response, "</a></th></tr><tr><th>Clicks:");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 4:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("\"totalvotes\":",response,",\"status_code\"");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 5:
- + String responseNetwork = getNetWorkResponse(getGlobalUrl(ordinal),ordinal);
- + totalVotes = (!"".equals(responseNetwork)) ? Integer.parseInt(responseNetwork) : -1;
- + break;
- +
- + case 6:
- + response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("VOTE <span>", response.toString().replaceAll("\n", ""), "</span>");
- +
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 7:
- + response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("nicas:</b> ", response, "<br /><br />");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 8:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("\"monthly_votes\":",response,"}}");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 9:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + response = VoteUtil.between("\"totalVotes\":\"", response, "\",\"serverRank\"");
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- +
- + case 10:
- + response = getResponse(getGlobalUrl(ordinal), ordinal);
- + totalVotes = (!"".equals(response)) ? Integer.parseInt(response) : -1;
- + break;
- + }
- +
- +
- + return totalVotes;
- + }
- +
- + public static String getIndividualUrl(int ordinal,String ip,String AccountName)
- + {
- + String url = "";
- + ip = (Config.TEST_IP.equalsIgnoreCase("off") || Config.TEST_IP.equalsIgnoreCase("") ) ? ip : Config.TEST_IP;
- + switch(ordinal) {
- + case 0:
- + //l2.topgameserver.net
- + url = String.format("%sAPI_KEY=%s/getData/%s", Config.VOTE_LINK_TGS, Config.TGS_API_KEY,ip);
- + break;
- +
- + case 1:
- + //itopz.com
- + url = String.format("%s%s/%s/%s", Config.VOTE_LINK_ITOPZ,Config.ITOPZ_API_KEY,Config.ITOPZ_SRV_ID,ip);
- + break;
- +
- + case 2:
- + //l2top.co
- + url = String.format("%sVoteCheck.php?id=%s&ip=%s", Config.VOTE_LINK_TOP_CO,Config.TOP_CO_SRV_ID,ip);
- + break;
- +
- + case 3:
- + //l2votes.com
- + url = String.format("%sapi.php?apiKey=%s&ip=%s", Config.VOTE_LINK_VTS,Config.VTS_API_KEY,ip);
- + break;
- +
- + case 4:
- + //hopzone.net
- + url = String.format("%svote?token=%s&ip_address=%s",Config.VOTE_LINK_HZ,Config.HZ_API_KEY,ip);
- + break;
- +
- + case 5:
- + //l2network.eu
- + url = String.format("https://l2network.eu/index.php?a=in&u=%s&ipc=%s", Config.VOTE_NETWORK_USER_NAME,ip);
- + break;
- +
- + case 6:
- + //l2topservers.com
- + url = String.format("%stoken=%s&ip=%s", Config.VOTE_LINK_TSS,Config.TSS_API_TOKEN,ip);
- + break;
- +
- + case 7:
- + //top.l2jbrasil.com
- + url = String.format("%susername=%s&ip=%s&type=json",Config.BRASIL_VOTE_LINK,Config.BRASIL_USER_NAME,ip);
- + break;
- +
- + case 8:
- + //mmotop
- + url = String.format("%s%s/ip/%s", Config.VOTE_LINK_MMOTOP, Config.MMOTOP_API_KEY, ip);
- + break;
- +
- + case 9:
- + //topzone.com
- + url = String.format("%svote?token=%s&ip=%s", Config.VOTE_LINK_TZ,Config.TZ_API_KEY,ip);
- + break;
- +
- + case 10:
- + //l2servers.com
- + url = String.format("%scheckip.php?hash=%s&server_id=%s&ip=%s", Config.VOTE_LINK_SERVERS,Config.SERVERS_HASH_CODE,Config.SERVERS_SRV_ID,ip);
- + break;
- + }
- +
- + return url;
- + }
- +
- + public String getGlobalUrl(int ordinal)
- + {
- + String url = "";
- +
- + switch(ordinal) {
- + case 0:
- + //l2.topgameserver.net
- + url = String.format("%sAPI_KEY=%s/getData", Config.VOTE_LINK_TGS, Config.TGS_API_KEY);
- + break;
- +
- + case 1:
- + //itopz.com
- + url = String.format("%s%s/%s", Config.VOTE_LINK_ITOPZ,Config.ITOPZ_API_KEY,Config.ITOPZ_SRV_ID);
- + break;
- +
- + case 2:
- + //l2top.co
- + url = String.format("%sVoteCheck_Total.php?id=%s", Config.VOTE_LINK_TOP_CO,Config.TOP_CO_SRV_ID);
- + break;
- +
- + case 3:
- + //l2votes.com
- + url = String.format("%sserverPage.php?sid=%s",Config.VOTE_LINK_VTS,Config.VTS_SID);
- + break;
- +
- + case 4:
- + //hopzone.net
- + url = String.format("%svotes?token=%s", Config.VOTE_LINK_HZ,Config.HZ_API_KEY);
- + break;
- +
- + case 5:
- + //l2network.eu
- + url = String.format("apiKey=%s&type=%s&player=",Config.VOTE_NETWORK_API_KEY,1);
- + break;
- +
- + case 6:
- + //l2topservers
- + url = String.format("https://l2topservers.com/l2top/%s/%s", Config.TS_SRV_ID,Config.TS_DOMAIN_NAME);
- + break;
- +
- + case 7:
- + //top.l2jbrasil.com
- + url = String.format("https://top.l2jbrasil.com/index.php?a=stats&u=%s",Config.BRASIL_USER_NAME);
- + break;
- +
- + case 8:
- + //mmotop.eu/l2/
- + url = String.format("%s%s/info/", Config.VOTE_LINK_MMOTOP,Config.MMOTOP_API_KEY);
- + break;
- +
- + case 9:
- + //l2topzone.com
- + url = String.format("%sserver_%s/getServerData", Config.VOTE_LINK_TZ,Config.TZ_API_KEY);
- + break;
- +
- + case 10:
- + //l2servers.com
- + url = String.format("%syearlyvotes.php?server_id=%s", Config.VOTE_LINK_SERVERS,Config.SERVERS_SRV_ID);
- + break;
- + }
- +
- + return url;
- + }
- +}
- \ No newline at end of file
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteManager.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteManager.java
- new file mode 100644
- index 0000000..aec398b
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Handler/voteManager.java
- @@ -0,0 +1,328 @@
- +package net.sf.l2j.gameserver.votesystem.Handler;
- +
- +import java.util.HashSet;
- +import java.util.Map;
- +import java.util.concurrent.ConcurrentHashMap;
- +import java.util.concurrent.ScheduledFuture;
- +
- +import net.sf.l2j.Config;
- +import net.sf.l2j.commons.concurrent.ThreadPool;
- +import net.sf.l2j.gameserver.model.World;
- +import net.sf.l2j.gameserver.model.actor.Player;
- +import net.sf.l2j.gameserver.network.GameClient;
- +import net.sf.l2j.gameserver.network.SystemMessageId;
- +import net.sf.l2j.gameserver.network.serverpackets.ItemList;
- +import net.sf.l2j.gameserver.network.serverpackets.SystemMessage;
- +import net.sf.l2j.gameserver.votesystem.DB.globalVoteDB;
- +import net.sf.l2j.gameserver.votesystem.DB.individualVoteDB;
- +import net.sf.l2j.gameserver.votesystem.Enum.voteSite;
- +import net.sf.l2j.gameserver.votesystem.Model.Reward;
- +import net.sf.l2j.gameserver.votesystem.Model.globalVote;
- +import net.sf.l2j.gameserver.votesystem.Model.individualVote;
- +import net.sf.l2j.gameserver.votesystem.Model.individualVoteResponse;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteSiteXml;
- +import net.sf.l2j.gameserver.votesystem.VoteUtil.VoteUtil;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public final class voteManager extends voteHandler{
- + private ScheduledFuture<?> _saveGlobalVotes;
- + private ScheduledFuture<?> _updateIndividualVotes;
- + private ScheduledFuture<?> _autoGlobalVotesReward;
- +
- + private HashSet<individualVote> _votes;
- + private Map<String,individualVote[]> _foundVoters;
- + private globalVote[] _globalVotes = new globalVote[voteSite.values().length];
- +
- + public voteManager() {
- + _foundVoters = new ConcurrentHashMap<>();
- + loadVotes();
- + loadGlobalVotes();
- + checkAllResponseGlobalVotes();
- + stopAutoTasks();
- +
- + if(Config.ENABLE_INDIVIDUAL_VOTE && Config.ENABLE_VOTE_SYSTEM) {
- + _updateIndividualVotes = ThreadPool.scheduleAtFixedRate(new AutoUpdateIndividualVotesTask(), 30000, Config.NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES);
- + }
- + if(Config.ENABLE_GLOBAL_VOTE && Config.ENABLE_VOTE_SYSTEM) {
- + _autoGlobalVotesReward = ThreadPool.scheduleAtFixedRate(new AutoGlobalVoteRewardTask(), 10000, Config.NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD);
- + _saveGlobalVotes = ThreadPool.scheduleAtFixedRate(new AutoSaveGlobalVotesTask(), 30000, Config.NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE);
- + }
- + }
- +
- + private void stopAutoTasks() {
- + if(_saveGlobalVotes != null) {
- + _saveGlobalVotes.cancel(true);
- + _saveGlobalVotes = null;
- + }
- + if(_updateIndividualVotes != null) {
- + _updateIndividualVotes.cancel(true);
- + _updateIndividualVotes = null;
- + }
- + if(_autoGlobalVotesReward != null) {
- + _autoGlobalVotesReward.cancel(true);
- + _autoGlobalVotesReward = null;
- + }
- + }
- +
- + public void getReward(Player player, int ordinalSite) {
- + String ip = existIp(player);
- + if(ip == null) {
- + return;
- + }
- + individualVoteResponse ivr = getIndividualVoteResponse(ordinalSite,ip,player.getAccountName());
- + if(ivr == null) {
- + player.sendMessage("We were unable to verify your vote with: "+VoteSiteXml.getInstance().getSiteName(ordinalSite)+", please try again");
- + return;
- + }
- +
- + if (getTimeRemaining(new individualVote(ip, ivr.getVoteSiteTime(), ordinalSite, false)) < 0)
- + {
- + player.sendMessage("We were unable to verify your vote with: " + VoteSiteXml.getInstance().getSiteName(ordinalSite) + ", please try again");
- + return;
- + }
- + if(!ivr.getIsVoted()) {
- + player.sendMessage(String.format("You haven't vote on %s yet!", VoteSiteXml.getInstance().getSiteName(ordinalSite)));
- + return;
- + }
- + if(!checkIndividualAvailableVote(player,ordinalSite)) {
- + player.sendMessage(String.format("You can get the reward again on %s at %s", VoteSiteXml.getInstance().getSiteName(ordinalSite),getTimeRemainingWithSampleFormat(player,ordinalSite)));
- + return;
- + }
- + individualVote iv = new individualVote(ip,ivr.getDiffTime(),ivr.getVoteSiteTime(),ordinalSite,false);
- +
- + individualVote[] aiv;
- + if(!_foundVoters.containsKey(ip)) {
- + aiv = new individualVote[voteSite.values().length];
- + iv.setAlreadyRewarded(true);
- + aiv[ordinalSite] = iv;
- + _foundVoters.put(ip, aiv);
- + for(Reward reward : VoteSiteXml.getInstance().getRewards(ordinalSite)) {
- + player.getInventory().addItem("VoteSystem", reward.getItemId(), reward.getItemCount(), player, null);
- + player.sendPacket(SystemMessage.getSystemMessage(SystemMessageId.EARNED_S2_S1_S).addItemName(reward.getItemId()).addNumber(reward.getItemCount()));
- + }
- + player.sendMessage(String.format("%s: Thank you for voting for our server, your reward has been delivered.", VoteSiteXml.getInstance().getSiteName(ordinalSite)));
- + player.sendPacket(new ItemList(player, true));
- + }else {
- + aiv = _foundVoters.get(ip);
- + iv.setAlreadyRewarded(true);
- + aiv[ordinalSite] = iv;
- + _foundVoters.replace(ip, aiv);
- + for(Reward reward : VoteSiteXml.getInstance().getRewards(ordinalSite)) {
- + player.getInventory().addItem("VoteSystem", reward.getItemId(), reward.getItemCount(), player, null);
- + player.sendPacket(SystemMessage.getSystemMessage(SystemMessageId.EARNED_S2_S1_S).addItemName(reward.getItemId()).addNumber(reward.getItemCount()));
- + }
- + player.sendMessage(String.format("%s: Thank you for voting for our server, your reward has been delivered.", VoteSiteXml.getInstance().getSiteName(ordinalSite)));
- + player.sendPacket(new ItemList(player, true));
- + }
- + }
- +
- + public boolean checkIndividualAvailableVote(Player player, int ordinalSite) {
- + String ip = existIp(player);
- + if(_foundVoters.containsKey(ip)) {
- + individualVote[] ivs=_foundVoters.get(ip);
- + if(ivs[ordinalSite] == null) {
- + return true;
- + }
- + if(ivs[ordinalSite] != null) {
- + individualVote iv = ivs[ordinalSite];
- + if(getTimeRemaining(iv)<0) {
- + return true;
- + }
- + }
- + }else {
- + return true;
- + }
- +
- + return false;
- + }
- +
- + public long getTimeRemaining(individualVote iv)
- + {
- + long timeRemaining = 0L;
- + timeRemaining = ((iv.getVotingTimeSite() + Config.INTERVAL_TO_NEXT_VOTE) - ((iv.getDiffTime() > 0) ? (System.currentTimeMillis() + iv.getDiffTime()) : (System.currentTimeMillis() - iv.getDiffTime())));
- + return timeRemaining;
- + }
- +
- + public String getTimeRemainingWithSampleFormat(Player player, int ordinalSite) {
- + String ip = existIp(player);
- + String timeRemainingWithSampleFormat ="";
- + if(_foundVoters.containsKey(ip)) {
- + individualVote[] ivs=_foundVoters.get(ip);
- + if(ivs[ordinalSite] != null) {
- + individualVote iv = ivs[ordinalSite];
- + long timeRemaining = getTimeRemaining(iv);
- + if(timeRemaining>0) {
- + timeRemainingWithSampleFormat = CalculateTimeRemainingWithSampleDateFormat(timeRemaining);
- + return timeRemainingWithSampleFormat;
- + }
- + }
- + }
- + return timeRemainingWithSampleFormat;
- + }
- +
- + public String CalculateTimeRemainingWithSampleDateFormat(long timeRemaining) {
- + long t = timeRemaining/1000;
- + int hours = Math.round((t/3600%24));
- + int minutes = Math.round((t/60)%60);
- + int seconds = Math.round(t%60);
- + return String.format("%sH:%sm:%ss", hours,minutes,seconds);
- + }
- +
- + public String existIp(Player p) {
- +
- + GameClient client = p.getClient();
- + if(client.getConnection() != null && client.getPlayer() != null && !client.isDetached()) {
- + try
- + {
- + return client.getConnection().getInetAddress().getHostAddress();
- + }
- + catch (Exception e)
- + {
- + e.printStackTrace();
- + }
- + }
- + return null;
- +
- + }
- +
- + public final void loadVotes() {
- + _foundVoters = individualVoteDB.getInstance().getVotesDB();
- + }
- + protected void loadGlobalVotes(){
- + _globalVotes = globalVoteDB.getInstance().getGlobalVotes();
- + }
- + public void saveVotes() {
- + individualVoteDB.getInstance().SaveVotes(_foundVoters);
- + }
- +
- + protected void AutoGlobalVoteReward() {
- + HashSet<String> ipList = new HashSet<>();
- + for(voteSite vs : voteSite.values()) {
- +
- + new Thread(() -> {
- + checkNewUpdate(vs.ordinal());
- + if(_globalVotes[vs.ordinal()].getCurrentVotes() >= _globalVotes[vs.ordinal()].getVotesLastReward() + (vs.ordinal() == voteSite.L2SERVERS.ordinal() ? 25*Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD)) {
- + _globalVotes[vs.ordinal()].setVotesLastReward(_globalVotes[vs.ordinal()].getVotesLastReward() + (vs.ordinal() == voteSite.L2SERVERS.ordinal() ? 25*Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD));
- + for(Player player : World.getInstance().getPlayers()) {
- + String ip = existIp(player);
- + if(ip == null) {
- + continue;
- + }
- + if(ipList.contains(ip)) {
- + continue;
- + }
- + for(Reward reward : VoteSiteXml.getInstance().getRewards(11)) {
- + player.getInventory().addItem("VoteSystem: ", reward.getItemId(), reward.getItemCount(), player, null);
- + player.sendPacket(SystemMessage.getSystemMessage(SystemMessageId.EARNED_S2_S1_S).addItemName(reward.getItemId()).addNumber(reward.getItemCount()));
- + }
- + ipList.add(ip);
- + player.sendPacket(new ItemList(player, true));
- + }
- + World.announceToOnlinePlayers(VoteUtil.Sites[vs.ordinal()]+": All players has been rewarded, please check your inventory", true);
- + }else {
- + String encourage ="";
- + int nextReward = _globalVotes[vs.ordinal()].getVotesLastReward() + (vs.ordinal() == voteSite.L2SERVERS.ordinal() ? 25*Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD);
- + encourage = String.format("Vote for %s current Votes: %s, next quantity of votes to reward : %s, need votes to next reward: %s", VoteUtil.Sites[vs.ordinal()], _globalVotes[vs.ordinal()].getCurrentVotes(),nextReward, nextReward-_globalVotes[vs.ordinal()].getCurrentVotes() );
- + World.announceToOnlinePlayers(encourage, true);
- + }
- + }).start();
- +
- + }
- + }
- +
- + protected void AutoSaveGlobalVotes() {
- + globalVoteDB.getInstance().saveGlobalVotes(_globalVotes);
- + }
- +
- + protected synchronized void AutoUpdateIndividualVotes() {
- + AutoCleanInnecesaryIndividualVotes();
- + individualVoteDB.getInstance().SaveVotes(_foundVoters);
- + }
- +
- + protected synchronized void AutoCleanInnecesaryIndividualVotes() {
- + HashSet<individualVote> removeVotes= new HashSet<>();
- + for(Map.Entry<String, individualVote[]> ivs : _foundVoters.entrySet()) {
- + for(individualVote individualvote : ivs.getValue()) {
- + if(individualvote == null)
- + continue;
- + if(getTimeRemaining(individualvote) < 0) {
- + removeVotes.add(individualvote);
- + if(_foundVoters.containsKey(individualvote.getVoterIp())) {
- + if(_foundVoters.get(individualvote.getVoterIp())[individualvote.getVoteSite()] != null) {
- + _foundVoters.get(individualvote.getVoterIp())[individualvote.getVoteSite()] = null;
- + }
- + }
- + }
- + }
- + }
- + individualVoteDB.getInstance().DeleteVotes(removeVotes);
- + }
- +
- + public void checkAllResponseGlobalVotes() {
- + for(voteSite vs : voteSite.values()) {
- + new Thread(()-> {
- + checkNewUpdate(vs.ordinal());
- + });
- + }
- + }
- +
- + public void checkNewUpdate(int ordinalSite) {
- + int globalVotesResponse = getGlobalVotesResponse(ordinalSite);
- + if(globalVotesResponse == -1) {
- + return;
- + }
- + _globalVotes[ordinalSite].setCurrentVotes(globalVotesResponse);
- + int last = globalVotesResponse - (ordinalSite == voteSite.L2SERVERS.ordinal() ? 25 * Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD);
- + if(last <0 ) {
- + _globalVotes[ordinalSite].setVotesLastReward(0);
- + return;
- + }
- + if((_globalVotes[ordinalSite].getVotesLastReward() + (ordinalSite == voteSite.L2SERVERS.ordinal() ? 25 * Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD)) < globalVotesResponse) {
- + _globalVotes[ordinalSite].setVotesLastReward(globalVotesResponse);
- + return;
- + }
- + }
- +
- + public void Shutdown() {
- + AutoSaveGlobalVotes();
- + AutoCleanInnecesaryIndividualVotes();
- + AutoUpdateIndividualVotes();
- + }
- +
- + protected class AutoGlobalVoteRewardTask implements Runnable {
- +
- + @Override
- + public void run()
- + {
- + AutoGlobalVoteReward();
- +
- + }
- +
- + }
- +
- + protected class AutoSaveGlobalVotesTask implements Runnable {
- +
- + @Override
- + public void run()
- + {
- + AutoSaveGlobalVotes();
- +
- + }
- +
- + }
- +
- + protected class AutoUpdateIndividualVotesTask implements Runnable {
- +
- + @Override
- + public void run()
- + {
- + AutoUpdateIndividualVotes();
- +
- + }
- +
- + }
- +
- + public static voteManager getInatance() {
- + return SingleHolder.INSTANCE;
- + }
- +
- + private static class SingleHolder {
- + protected static final voteManager INSTANCE = new voteManager();
- + }
- +}
- \ No newline at end of file
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/Reward.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/Reward.java
- new file mode 100644
- index 0000000..2ca11e8
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/Reward.java
- @@ -0,0 +1,33 @@
- +package net.sf.l2j.gameserver.votesystem.Model;
- +
- +
- +import net.sf.l2j.commons.util.StatsSet;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class Reward
- +{
- + private int _itemId;
- + private int _itemCount;
- +
- + public Reward(StatsSet set)
- + {
- + _itemId = set.getInteger("itemId");
- + _itemCount = set.getInteger("itemCount");
- + }
- +
- + public void setItemId(int itemId) {
- + _itemId = itemId;
- + }
- + public void setItemCount(int itemCount) {
- + _itemCount = itemCount;
- + }
- + public int getItemId() {
- + return _itemId;
- + }
- + public int getItemCount() {
- + return _itemCount;
- + }
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/VoteSite.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/VoteSite.java
- new file mode 100644
- index 0000000..e2c23ac
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/VoteSite.java
- @@ -0,0 +1,38 @@
- +package net.sf.l2j.gameserver.votesystem.Model;
- +
- +import java.util.ArrayList;
- +import java.util.List;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class VoteSite
- +{
- + private int _siteOrdinal;
- + private String _siteName;
- + private List<Reward> _rewards = new ArrayList<>();
- + public VoteSite() {
- +
- + }
- + public void setSiteOrdinal(int siteOrdinal) {
- + _siteOrdinal = siteOrdinal;
- + }
- + public void setSiteName(String siteName) {
- + _siteName = siteName;
- + }
- + public void setRewardList(List<Reward> rewards) {
- + for(Reward r : rewards)
- + _rewards.add(r);
- + }
- + public int getSiteOrdinal() {
- + return _siteOrdinal;
- + }
- + public String getSiteName() {
- + return _siteName;
- + }
- + public List<Reward> getRewardList(){
- + return _rewards;
- + }
- +
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/globalVote.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/globalVote.java
- new file mode 100644
- index 0000000..ca5d979
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/globalVote.java
- @@ -0,0 +1,45 @@
- +package net.sf.l2j.gameserver.votesystem.Model;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class globalVote
- +{
- + private int _voteSite;
- + private int _votesLastReward;
- + private int _currentVotes;
- + public globalVote() {
- +
- + }
- +
- + public globalVote(int voteSite, int votesLastReward) {
- + _voteSite = voteSite;
- + _votesLastReward = votesLastReward;
- + }
- +
- + public void setVoteSite(int voteSite) {
- + _voteSite = voteSite;
- + }
- +
- + public void setVotesLastReward(int votesLastReward) {
- + _votesLastReward = votesLastReward;
- + }
- +
- + public void setCurrentVotes(int currentVotes) {
- + _currentVotes = currentVotes;
- + }
- +
- + public int getVoyeSite() {
- + return _voteSite;
- + }
- +
- + public int getVotesLastReward() {
- + return _votesLastReward;
- + }
- +
- + public int getCurrentVotes() {
- + return _currentVotes;
- + }
- +
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVote.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVote.java
- new file mode 100644
- index 0000000..7d24d7f
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVote.java
- @@ -0,0 +1,69 @@
- +package net.sf.l2j.gameserver.votesystem.Model;
- +
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class individualVote
- +{
- + private String _voterIp;
- + private long _diffTime;
- + private long _votingTimeSite;
- + private int _voteSite;
- + private boolean _alreadyRewarded;
- +
- +
- + public individualVote(String voterIp, long diffTime, long votingTimeSite, int voteSite, boolean alreadyRewarded){
- + _voterIp = voterIp;
- + _diffTime = diffTime;
- + _votingTimeSite = votingTimeSite;
- + _voteSite = voteSite;
- + _alreadyRewarded = alreadyRewarded;
- + }
- +
- + public individualVote(){
- +
- + }
- +
- + public void setVoterIp(String voterIp) {
- + _voterIp = voterIp;
- + }
- +
- + public void setDiffTime(long diffTime) {
- + _diffTime = diffTime;
- + }
- +
- + public void setVotingTimeSite(long votingTimeSite) {
- + _votingTimeSite = votingTimeSite;
- + }
- +
- + public void setVoteSite(int voteSite) {
- + _voteSite = voteSite;
- + }
- +
- + public void setAlreadyRewarded(boolean alreadyRewarded) {
- + _alreadyRewarded = alreadyRewarded;
- + }
- +
- + public String getVoterIp() {
- + return _voterIp;
- + }
- +
- + public long getDiffTime() {
- + return _diffTime;
- + }
- +
- + public long getVotingTimeSite() {
- + return _votingTimeSite;
- + }
- +
- + public int getVoteSite() {
- + return _voteSite;
- + }
- +
- + public boolean getAlreadyRewarded() {
- + return _alreadyRewarded;
- + }
- +
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVoteResponse.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVoteResponse.java
- new file mode 100644
- index 0000000..14b7625
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/Model/individualVoteResponse.java
- @@ -0,0 +1,36 @@
- +package net.sf.l2j.gameserver.votesystem.Model;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class individualVoteResponse
- +{
- + private boolean _isVoted;
- + private long _diffTime;
- + private long _voteSiteTime;
- +
- + public individualVoteResponse() {
- +
- + }
- +
- + public void setIsVoted(boolean isVoted) {
- + _isVoted = isVoted;
- + }
- + public void setDiffTime(long diffTime) {
- + _diffTime = diffTime;
- + }
- + public void setVoteSiteTime(long voteSiteTime) {
- + _voteSiteTime = voteSiteTime;
- + }
- +
- + public boolean getIsVoted() {
- + return _isVoted;
- + }
- + public long getDiffTime() {
- + return _diffTime;
- + }
- + public long getVoteSiteTime() {
- + return _voteSiteTime;
- + }
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteSiteXml.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteSiteXml.java
- new file mode 100644
- index 0000000..d943fb8
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteSiteXml.java
- @@ -0,0 +1,69 @@
- +package net.sf.l2j.gameserver.votesystem.VoteUtil;
- +
- +import java.nio.file.Path;
- +import java.util.Collection;
- +import java.util.HashMap;
- +import java.util.Map;
- +
- +import net.sf.l2j.commons.data.xml.IXmlReader;
- +import net.sf.l2j.gameserver.votesystem.Model.Reward;
- +import net.sf.l2j.gameserver.votesystem.Model.VoteSite;
- +
- +import org.w3c.dom.Document;
- +import org.w3c.dom.NamedNodeMap;
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public class VoteSiteXml implements IXmlReader
- +{
- +
- + private final Map<Integer,VoteSite> _voteSites = new HashMap<>();
- +
- + protected VoteSiteXml() {
- + load();
- + }
- +
- + @Override
- + public void load()
- + {
- + parseFile("./data/xml/votesystem.xml");
- + LOGGER.info("Loaded {} reward sites", _voteSites.size());
- + }
- +
- +
- + @Override
- + public void parseDocument(Document doc, Path path)
- + {
- + forEach(doc, "list", listNode -> {
- + forEach(listNode, "votesite", votesiteNode -> {
- + final VoteSite votesite = new VoteSite();
- + final NamedNodeMap attrs = votesiteNode.getAttributes();
- + votesite.setSiteOrdinal(parseInteger(attrs,"ordinal"));
- + votesite.setSiteName(parseString(attrs,"name"));
- + forEach(votesiteNode,"items", itemsNode -> forEach(itemsNode,"item",itemNode -> votesite.getRewardList().add(new Reward(parseAttributes(itemNode)))));
- + _voteSites.put(votesite.getSiteOrdinal(),votesite);
- + });
- + });
- + }
- +
- + public String getSiteName(int ordinal) {
- + return _voteSites.get(ordinal).getSiteName();
- + }
- +
- + public Collection<Reward> getRewards(int ordinal){
- + return _voteSites.get(ordinal).getRewardList();
- + }
- +
- + public static final VoteSiteXml getInstance()
- + {
- + return SingletonHolder.INSTANCE;
- + }
- +
- + private static final class SingletonHolder
- + {
- + protected static final VoteSiteXml INSTANCE = new VoteSiteXml();
- + }
- +
- +}
- diff --git a/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteUtil.java b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteUtil.java
- new file mode 100644
- index 0000000..a555b85
- --- /dev/null
- +++ b/aCis_gameserver/java/net/sf/l2j/gameserver/votesystem/VoteUtil/VoteUtil.java
- @@ -0,0 +1,132 @@
- +package net.sf.l2j.gameserver.votesystem.VoteUtil;
- +
- +import java.io.BufferedReader;
- +import java.io.InputStreamReader;
- +import java.net.HttpURLConnection;
- +import java.net.URL;
- +import java.time.LocalDateTime;
- +import java.time.ZoneId;
- +import java.time.ZonedDateTime;
- +
- +import net.sf.l2j.commons.logging.CLogger;
- +
- +
- +/**
- + * @author l2.topgameserver.net
- + *
- + */
- +public final class VoteUtil
- +{
- + public static final CLogger LOGGER = new CLogger(VoteUtil.class.getName());
- +
- + private static String voteTimeZones[] = {
- + "topgameserver.net=Europe/Berlin",
- + "itopz.com=America/New_York",
- + "l2top.co=Europe/London",
- + "l2votes.com=GMT",
- + "hopzone.net=Europe/Athens",
- + "l2network.eu=America/Chicago",
- + "l2topservers.com=Europe/Athens",
- + "top.l2jbrasil.com=America/Sao_Paulo",
- + "mmotop.eu=America/Chicago",
- + "l2topzone.com=America/Chicago",
- + "l2servers.com=America/Chicago",
- + };
- +
- + public static final long getTimeVotingSite(int ordinalSite) {
- + LocalDateTime ldt = LocalDateTime.now(ZoneId.of(voteTimeZones[ordinalSite].split("=")[1]));
- + ZonedDateTime zdt = ldt.atZone(ZoneId.systemDefault());
- + long millis = zdt.toInstant().toEpochMilli();
- + return millis;
- + }
- +
- + public static final String Sites[] =
- + {
- + "L2.TopGameServer.net",
- + "ITopZ.com",
- + "L2Top.co",
- + "L2Votes.com",
- + "L2.Hopzone.net",
- + "L2Network.eu",
- + "L2TopServers.com",
- + "top.l2jbrasil.com",
- + "MMOTOP.eu",
- + "L2Topzone.com",
- + "L2Servers.com"
- + };
- +
- + public static final String getResponse(String Url, int ordinal)
- + {
- +
- + try
- + {
- + int responseCode = 0;
- + URL objUrl = new URL(Url);
- + HttpURLConnection con = (HttpURLConnection) objUrl.openConnection();
- + con.setRequestMethod("GET");
- + con.setRequestProperty("User-Agent", "Mozilla/5.0");
- + con.setConnectTimeout(5000);
- + responseCode = con.getResponseCode();
- + if (responseCode == HttpURLConnection.HTTP_OK) {
- +
- + String inputLine;
- + StringBuffer response = new StringBuffer();
- + BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
- + while ((inputLine = in.readLine()) != null) {
- + if(ordinal == 3) {
- + if(inputLine.contains("Votes:")) {
- + response.append(inputLine);
- + break;
- + }
- + }
- + if(ordinal == 7){
- + if(inputLine.contains("<b>Entradas ")) {
- + response.append(inputLine);
- + break;
- + }
- + }
- + }
- + in.close();
- + return response.toString();
- + }
- +
- + }
- + catch (Exception e)
- + {
- + LOGGER.error(VoteUtil.Sites[ordinal]+ " Say: An error ocurred ", e.getMessage());
- + return "";
- + }
- +
- + return "";
- + }
- +
- + public static final String between(String p1, String str, String p2){
- + String returnValue = "";
- + int i1 = str.indexOf(p1);
- + int i2 = str.indexOf(p2);
- + if(i1 != -1 && i2 != -1){
- + i1 = i1+p1.length();
- + returnValue = str.substring(i1,i2);
- + }
- + return returnValue;
- + }
- +
- + public static void goToVoteSite(String urlSiiteVotation) {
- + /*try
- + {
- + URL url = new URL(urlSiiteVotation);
- + try
- + {
- + Desktop.getDesktop().browse(url.toURI());
- + }
- + catch (IOException | URISyntaxException e)
- + {
- + e.printStackTrace();
- + }
- + }
- + catch (MalformedURLException e)
- + {
- + e.printStackTrace();
- + }*/
- + }
- +}
- ==============================================DATAPACK=======================================
- diff --git a/aCis_datapack/data/html/mods/votesystem/100005.html b/aCis_datapack/data/html/mods/votesystem/50009.html
- new file mode 100644
- index 0000000..d7d938a
- --- /dev/null
- +++ b/aCis_datapack/data/html/mods/votesystem/50009.html
- @@ -0,0 +1,19 @@
- +<html>
- +<title>Voting panel</title>
- +<body><center>
- + <br><img src="L2UI_CH3.herotower_deco" width=256 height=32><br>
- + <table cellpadding=2 width=280>
- + <tr><td width="280">Hello <font color="C6AF00">%accountName%</font>, welcome to the voting rewards dashboard, please help us by voting by server every <font color="C6AF00">%everyXtime% hours</font> in all voting sites.</td></tr>
- + </table>
- + <table width="290"><tr><td width="290" align="center">You can vote: </td></tr></table>
- + <br><img src="l2ui.SquareWhite" width=290 height=1><br>
- +
- + %enablevote%
- +
- + <br>
- + <img src="l2ui.SquareWhite" width=290 height=1><br>
- +
- +
- +
- +</center></body>
- +</html>
- \ No newline at end of file
- diff --git a/aCis_datapack/data/xml/npcs/50000-50999.xml b/aCis_datapack/data/xml/npcs/50000-50999.xml
- index 1a21b51..0e9b37f 100644
- --- a/aCis_datapack/data/xml/npcs/50000-50999.xml
- +++ b/aCis_datapack/data/xml/npcs/50000-50999.xml
- @@ -1,114 +1,153 @@
- </npc>
- + <npc id="50009" idTemplate="30519" name="Kaaya" title="Vote System">
- + <set name="usingServerSideName" val="true"/>
- + <set name="usingServerSideTitle" val="true"/>
- + <set name="level" val="70"/>
- + <set name="radius" val="7"/>
- + <set name="height" val="18"/>
- + <set name="rHand" val="0"/>
- + <set name="lHand" val="0"/>
- + <set name="type" val="NpcVote"/>
- + <set name="exp" val="0"/>
- + <set name="sp" val="0"/>
- + <set name="hp" val="2444.46819"/>
- + <set name="mp" val="1345.8"/>
- + <set name="hpRegen" val="7.5"/>
- + <set name="mpRegen" val="2.7"/>
- + <set name="pAtk" val="688.86373"/>
- + <set name="pDef" val="295.91597"/>
- + <set name="mAtk" val="470.40463"/>
- + <set name="mDef" val="216.53847"/>
- + <set name="crit" val="4"/>
- + <set name="atkSpd" val="253"/>
- + <set name="str" val="40"/>
- + <set name="int" val="21"/>
- + <set name="dex" val="30"/>
- + <set name="wit" val="20"/>
- + <set name="con" val="43"/>
- + <set name="men" val="20"/>
- + <set name="corpseTime" val="7"/>
- + <set name="walkSpd" val="50"/>
- + <set name="runSpd" val="120"/>
- + <set name="dropHerbGroup" val="0"/>
- + <ai type="DEFAULT" ssCount="0" ssRate="0" spsCount="0" spsRate="0" aggro="0" canMove="true" seedable="false"/>
- + <skills>
- + <skill id="4045" level="1"/>
- + <skill id="4416" level="18"/>
- + </skills>
- + </npc>
- +
- </list>
- \ No newline at end of file
- diff --git a/aCis_datapack/data/xml/votesystem.xml b/aCis_datapack/data/xml/votesystem.xml
- new file mode 100644
- index 0000000..f254f8c
- --- /dev/null
- +++ b/aCis_datapack/data/xml/votesystem.xml
- @@ -0,0 +1,75 @@
- +<?xml version="1.0" encoding="UTF-8"?>
- +<list>
- + <votesite name="l2.topgameserver.net" ordinal="0">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="ItopZ.com" ordinal="1">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Top.co" ordinal="2">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Votes.com" ordinal="3">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="Hopzone.net" ordinal="4">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Network.eu" ordinal="5">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Topservers.com" ordinal="6">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="top.l2jbrasil.com" ordinal="7">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="MMOTOP.eu" ordinal="8">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Topzone.com" ordinal="9">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="L2Servers.com" ordinal="10">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- + <votesite name="globalVotes" ordinal="11">
- + <items>
- + <item itemId="57" itemCount="10000000" />
- + <item itemId="6673" itemCount="1"/>
- + </items>
- + </votesite>
- +</list>
- \ No newline at end of file
- SET NAMES utf8mb4;
- SET FOREIGN_KEY_CHECKS = 0;
- -- ----------------------------
- -- Table structure for globalvotes
- -- ----------------------------
- DROP TABLE IF EXISTS `globalvotes`;
- CREATE TABLE `globalvotes` (
- `voteSite` tinyint(2) NOT NULL,
- `lastRewardVotes` int(11) NULL DEFAULT NULL,
- PRIMARY KEY (`voteSite`) USING BTREE
- ) ENGINE = InnoDB CHARACTER SET = latin1 COLLATE = latin1_swedish_ci ROW_FORMAT = Dynamic;
- -- ----------------------------
- -- Records of globalvotes
- -- ----------------------------
- INSERT INTO `globalvotes` VALUES (0, 13);
- INSERT INTO `globalvotes` VALUES (1, 68);
- INSERT INTO `globalvotes` VALUES (2, 0);
- INSERT INTO `globalvotes` VALUES (3, 3);
- INSERT INTO `globalvotes` VALUES (4, 2);
- INSERT INTO `globalvotes` VALUES (5, 0);
- INSERT INTO `globalvotes` VALUES (6, 0);
- INSERT INTO `globalvotes` VALUES (7, 2);
- INSERT INTO `globalvotes` VALUES (8, 3);
- INSERT INTO `globalvotes` VALUES (9, 0);
- INSERT INTO `globalvotes` VALUES (10, 75);
- -- ----------------------------
- -- Table structure for individualvotes
- -- ----------------------------
- DROP TABLE IF EXISTS `individualvotes`;
- CREATE TABLE `individualvotes` (
- `voterIp` varchar(40) CHARACTER SET latin1 COLLATE latin1_swedish_ci NOT NULL,
- `voteSite` tinyint(3) NOT NULL,
- `diffTime` bigint(20) NULL DEFAULT NULL,
- `votingTimeSite` bigint(20) NULL DEFAULT NULL,
- `alreadyRewarded` tinyint(3) NULL DEFAULT NULL,
- PRIMARY KEY (`voterIp`, `voteSite`) USING BTREE
- ) ENGINE = InnoDB CHARACTER SET = latin1 COLLATE = latin1_swedish_ci ROW_FORMAT = Dynamic;
- -- ----------------------------
- -- Records of individualvotes
- -- ----------------------------
- INSERT INTO `individualvotes` VALUES ('127.0.0.1', 0, 1588703279833, 1588702011000, 1);
- INSERT INTO `individualvotes` VALUES ('127.0.0.1', 3, 1588704503248, 1588703396000, 1);
- INSERT INTO `individualvotes` VALUES ('127.0.0.1', 5, 1588692835993, 1588692823000, 1);
- SET FOREIGN_KEY_CHECKS = 1;
Add Comment
Please, Sign In to add comment