API tools faq
paste
Advertisement
l2TopgameserverNet

L2jMobius Interlude vote reward - l2.topgameserver.net

l2TopgameserverNet
May 12th, 2020 (edited)
2,193
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 91.58 KB | None | 0 0
raw download clone embed print report
  1. diff --git a/L2J_Mobius_C6_Interlude/dist/game/config/custom/votesystem.ini b/L2J_Mobius_C6_Interlude/dist/game/config/custom/votesystem.ini
  2. new file mode 100644
  3. index 0000000..3ea8d39
  4. --- /dev/null
  5. +++ b/L2J_Mobius_C6_Interlude/dist/game/config/custom/votesystem.ini
  6. @@ -0,0 +1,95 @@
  7. +EnableVoteSystem = True
  8. +
  9. +EnableGlobalVote = True
  10. +
  11. +EnableIndividualVote = True
  12. +
  13. +## Time to Update table totalVotes from DB
  14. +NextTimeToAutoUpdateTotalVote = 2
  15. +
  16. +## Time to update table individualVotes
  17. +NextTimeToAutoUpdateIndividualVotes = 2
  18. +
  19. +NextTimeToAutoCleanInnecesaryVotes = 30
  20. +
  21. +NextTimeToCheckAutoGlobalVotesReward = 1
  22. +
  23. +IntervalTimeToNextVote = 12
  24. +
  25. +GlobalVotesAmountToNextReward = 1
  26. +
  27. +EnableVotingCommand = True
  28. +
  29. +VotingCommand = getreward
  30. +
  31. +## l2.topgameserver.net
  32. +VoteLinkTgs = http://l2.topgameserver.net/lineage/VoteApi/
  33. +
  34. +TgsApiKey =
  35. +
  36. +## l2top.co
  37. +VoteLinkTopCo = https://l2top.co/reward/
  38. +
  39. +TopCoSrvId =
  40. +
  41. +## ITopz.com
  42. +VoteLinkItopz = https://itopz.com/check/
  43. +
  44. +ItopzZpiKey =
  45. +
  46. +ItopzSrvId =
  47. +
  48. +## l2votes.com
  49. +VoteLinkVts = https://l2votes.com/
  50. +
  51. +VtsApiKey =
  52. +
  53. +VtsSid =
  54. +
  55. +## Hopzone.net
  56. +VoteLinkHz = https://api.hopzone.net/lineage2/
  57. +
  58. +HzApiKey =
  59. +
  60. +## l2network.eu
  61. +VoteNetworkLink = https://l2network.eu/api.php
  62. +
  63. +VoteNetworkUserName =
  64. +
  65. +VoteNetworkApiKey =
  66. +
  67. +## L2TopServer.com
  68. +VoteLinkTss = https://l2topservers.com/votes?
  69. +
  70. +TssApiToken =
  71. +
  72. +TsSrvId = 453
  73. +
  74. +TsDomainName= l2catgang
  75. +
  76. +## top.l2jbrasil.com
  77. +BrasilVoteLink = https://top.l2jbrasil.com/votesystem/index.php?
  78. +
  79. +BrasilUserName = julioguzman
  80. +
  81. +## l2jtop.com
  82. +VoteLinkMmotop = https://l2jtop.com/api/
  83. +
  84. +MmotopApiKey =
  85. +
  86. +## L2TopZone.com
  87. +VoteLinkTz = https://api.l2topzone.com/v1/
  88. +
  89. +TzApiKey =
  90. +
  91. +## L2Servers.com
  92. +VoteLinkServers = https://www.l2servers.com/api/
  93. +
  94. +ServersHashCode =
  95. +
  96. +ServersSrvId =
  97. +
  98. +
  99. +## for local test
  100. +TestIp =
  101. +
  102. diff --git a/L2J_Mobius_C6_Interlude/dist/game/data/html/mods/votesystem/50009.html b/L2J_Mobius_C6_Interlude/dist/game/data/html/mods/votesystem/50009.html
  103. new file mode 100644
  104. index 0000000..b2a5624
  105. --- /dev/null
  106. +++ b/L2J_Mobius_C6_Interlude/dist/game/data/html/mods/votesystem/50009.html
  107. @@ -0,0 +1,19 @@
  108. +<html>
  109. +<title>Voting panel</title>
  110. +<body><center>
  111. +   <br><img src="L2UI_CH3.herotower_deco" width=256 height=32><br>
  112. +   <table cellpadding=2 width=280>
  113. +       <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>
  114. +   </table>
  115. +   <table width="290"><tr><td width="290" align="center">You can vote: </td></tr></table>
  116. +   <br><img src="l2ui.SquareWhite" width=290 height=1><br>
  117. +
  118. +   %enablevote%
  119. +
  120. +   <br>
  121. +   <img src="l2ui.SquareWhite" width=290 height=1><br>
  122. +
  123. +
  124. +
  125. +</center></body>
  126. +</html>
  127. \ No newline at end of file
  128. diff --git a/L2J_Mobius_C6_Interlude/dist/game/data/votesystem.json b/L2J_Mobius_C6_Interlude/dist/game/data/votesystem.json
  129. new file mode 100644
  130. index 0000000..dabcc63
  131. --- /dev/null
  132. +++ b/L2J_Mobius_C6_Interlude/dist/game/data/votesystem.json
  133. @@ -0,0 +1,14 @@
  134. +[
  135. +   {"votesite":{"ordinal":"0","name":"l2.topgameserver.net","timezone":"GMT+2", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  136. +   {"votesite":{"ordinal":"1","name":"Itopz.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  137. +   {"votesite":{"ordinal":"2","name":"L2Top.co","timezone":"GMT+2", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  138. +   {"votesite":{"ordinal":"3","name":"L2Votes.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  139. +   {"votesite":{"ordinal":"4","name":"Hopzone.net","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  140. +   {"votesite":{"ordinal":"5","name":"L2Network.eu","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  141. +   {"votesite":{"ordinal":"6","name":"L2Topservers.com","timezone":"Asia/Tokyo", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  142. +   {"votesite":{"ordinal":"7","name":"top.l2jbrasil.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  143. +   {"votesite":{"ordinal":"8","name":"l2jtop.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  144. +   {"votesite":{"ordinal":"9","name":"L2Topzone.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  145. +   {"votesite":{"ordinal":"10","name":"L2Servers.com","timezone":"GMT", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}},
  146. +   {"votesite":{"ordinal":"11","name":"globalVotes","timezone":"", "nextvotetime":"12","rewards":[{"item_id":"57","item_count":"100000"},{"item_id":"6673","item_count":"1"}]}}
  147. +]
  148. \ No newline at end of file
  149. diff --git a/L2J_Mobius_C6_Interlude/dist/libs/json-simple-1.1.1.jar b/L2J_Mobius_C6_Interlude/dist/libs/json-simple-1.1.1.jar
  150. new file mode 100644
  151. index 0000000..66347a6
  152. --- /dev/null
  153. +++ b/L2J_Mobius_C6_Interlude/dist/libs/json-simple-1.1.1.jar
  154. Binary files differ
  155. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/Config.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/Config.java
  156. index b126291..876bcaf 100644
  157. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/Config.java
  158. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/Config.java
  159. @@ -33,6 +33,7 @@
  160.  import java.util.List;
  161.  import java.util.Map;
  162.  import java.util.Properties;
  163. +import java.util.concurrent.TimeUnit;
  164.  import java.util.logging.Level;
  165.  import java.util.logging.Logger;
  166.  
  167. @@ -98,6 +99,7 @@
  168.     private static final String SCHEME_BUFFER_CONFIG_FILE = "./config/custom/SchemeBuffer.ini";
  169.     private static final String EVENT_REBIRTH_CONFIG_FILE = "./config/custom/Rebirth.ini";
  170.     private static final String EVENT_WEDDING_CONFIG_FILE = "./config/custom/Wedding.ini";
  171. +   private static final String VOTE_SYSTEM_FILE = "./config/custom/votesystem.ini";
  172.     // login
  173.     private static final String LOGIN_CONFIG_FILE = "./config/main/LoginServer.ini";
  174.     // others
  175. @@ -509,6 +511,50 @@
  176.     public static boolean GIVE_CUPID_BOW;
  177.     public static boolean ANNOUNCE_WEDDING;
  178.    
  179. +   // ---------------------------------------------------
  180. +   // VOTE SYSTEM
  181. +   // ---------------------------------------------------
  182. +   public static boolean ENABLE_VOTE_SYSTEM;
  183. +   public static boolean ENABLE_INDIVIDUAL_VOTE;
  184. +   public static boolean ENABLE_GLOBAL_VOTE;
  185. +   public static long NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE;
  186. +   public static long NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES;
  187. +   public static long NEXT_TIME_TO_AUTO_CLEAN_INECESARY_VOTES;
  188. +   public static long NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD;
  189. +   public static long INTERVAL_TO_NEXT_VOTE;
  190. +   public static int GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD;
  191. +   public static boolean ENABLE_VOTING_COMMAND;
  192. +   public static String VOTING_COMMAND;
  193. +   public static String VOTE_LINK_TGS;
  194. +   public static String TGS_API_KEY;
  195. +   public static String VOTE_LINK_TOP_CO;
  196. +   public static String TOP_CO_SRV_ID;
  197. +   public static String VOTE_LINK_ITOPZ;
  198. +   public static String ITOPZ_API_KEY;
  199. +   public static String ITOPZ_SRV_ID;
  200. +   public static String VOTE_LINK_VTS;
  201. +   public static String VTS_API_KEY;
  202. +   public static String VTS_SID;
  203. +   public static String VOTE_LINK_HZ;
  204. +   public static String HZ_API_KEY;
  205. +   public static String VOTE_NETWORK_LINK;
  206. +   public static String VOTE_NETWORK_USER_NAME;
  207. +   public static String VOTE_NETWORK_API_KEY;
  208. +   public static String VOTE_LINK_TSS;
  209. +   public static String TSS_API_TOKEN;
  210. +   public static String TS_SRV_ID;
  211. +   public static String TS_DOMAIN_NAME;
  212. +   public static String BRASIL_VOTE_LINK;
  213. +   public static String BRASIL_USER_NAME;
  214. +   public static String VOTE_LINK_MMOTOP;
  215. +   public static String MMOTOP_API_KEY;
  216. +   public static String VOTE_LINK_TZ;
  217. +   public static String TZ_API_KEY;
  218. +   public static String VOTE_LINK_SERVERS;
  219. +   public static String SERVERS_HASH_CODE;
  220. +   public static String SERVERS_SRV_ID;
  221. +   public static String TEST_IP;
  222. +  
  223.     public static String TVT_EVEN_TEAMS;
  224.     public static boolean TVT_ALLOW_INTERFERENCE;
  225.     public static boolean TVT_ALLOW_POTIONS;
  226. @@ -1758,6 +1804,53 @@
  227.         ANNOUNCE_WEDDING = weddingConfig.getBoolean("AnnounceWedding", true);
  228.     }
  229.    
  230. +   public static void loadVoteConfig()
  231. +   {
  232. +       // Load vote system settings
  233. +       final PropertiesParser votesystem = new PropertiesParser(VOTE_SYSTEM_FILE);
  234. +      
  235. +       ENABLE_VOTE_SYSTEM = votesystem.getBoolean("EnableVoteSystem", true);
  236. +       ENABLE_INDIVIDUAL_VOTE = votesystem.getBoolean("EnableIndividualVote", true);
  237. +       ENABLE_GLOBAL_VOTE = votesystem.getBoolean("EnableGlobalVote", true);
  238. +       NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE = TimeUnit.MINUTES.toMillis(votesystem.getInt("NextTimeToAutoUpdateTotalVote", 60));// -> minutes
  239. +       NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES = TimeUnit.MINUTES.toMillis(votesystem.getInt("NextTimeToAutoUpdateIndividualVotes", 60));// -> minutes
  240. +       NEXT_TIME_TO_AUTO_CLEAN_INECESARY_VOTES = TimeUnit.MINUTES.toMillis(votesystem.getInt("NextTimeToAutoCleanInnecesaryVotes", 30));// -> minutes
  241. +       NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD = TimeUnit.MINUTES.toMillis(votesystem.getInt("NextTimeToCheckAutoGlobalVotesReward", 5));// -> minutes
  242. +       INTERVAL_TO_NEXT_VOTE = TimeUnit.HOURS.toMillis(votesystem.getInt("IntervalTimeToNextVote", 12)); // -> hours
  243. +       GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD = votesystem.getInt("GlobalVotesAmountToNextReward", 50);
  244. +       ENABLE_VOTING_COMMAND = votesystem.getBoolean("EnableVotingCommand", true);
  245. +       VOTING_COMMAND = votesystem.getString("VotingCommand", "getreward");
  246. +       VOTE_LINK_TGS = votesystem.getString("VoteLinkTgs", "");
  247. +       TGS_API_KEY = votesystem.getString("TgsApiKey", "");
  248. +       VOTE_LINK_TOP_CO = votesystem.getString("VoteLinkTopCo", "");
  249. +       TOP_CO_SRV_ID = votesystem.getString("TopCoSrvId", "");
  250. +       VOTE_LINK_ITOPZ = votesystem.getString("VoteLinkItopz", "");
  251. +       ITOPZ_API_KEY = votesystem.getString("ItopzZpiKey", "");
  252. +       ITOPZ_SRV_ID = votesystem.getString("ItopzSrvId", "");
  253. +       VOTE_LINK_VTS = votesystem.getString("VoteLinkVts", "");
  254. +       VTS_API_KEY = votesystem.getString("VtsApiKey", "");
  255. +       VTS_SID = votesystem.getString("VtsSid", "");
  256. +       VOTE_LINK_HZ = votesystem.getString("VoteLinkHz", "");
  257. +       HZ_API_KEY = votesystem.getString("HzApiKey", "");
  258. +       VOTE_NETWORK_LINK = votesystem.getString("VoteNetworkLink", "");
  259. +       VOTE_NETWORK_USER_NAME = votesystem.getString("VoteNetworkUserName", "");
  260. +       VOTE_NETWORK_API_KEY = votesystem.getString("VoteNetworkApiKey", "");
  261. +       VOTE_LINK_TSS = votesystem.getString("VoteLinkTss", "");
  262. +       TSS_API_TOKEN = votesystem.getString("TssApiToken", "");
  263. +       TS_SRV_ID = votesystem.getString("TsSrvId", "");
  264. +       TS_DOMAIN_NAME = votesystem.getString("TsDomainName", "");
  265. +       BRASIL_VOTE_LINK = votesystem.getString("BrasilVoteLink", "");
  266. +       BRASIL_USER_NAME = votesystem.getString("BrasilUserName", "");
  267. +       VOTE_LINK_MMOTOP = votesystem.getString("VoteLinkMmotop", "");
  268. +       MMOTOP_API_KEY = votesystem.getString("MmotopApiKey", "");
  269. +       VOTE_LINK_TZ = votesystem.getString("VoteLinkTz", "");
  270. +       TZ_API_KEY = votesystem.getString("TzApiKey", "");
  271. +       VOTE_LINK_SERVERS = votesystem.getString("VoteLinkServers", "");
  272. +       SERVERS_HASH_CODE = votesystem.getString("ServersHashCode", "");
  273. +       SERVERS_SRV_ID = votesystem.getString("ServersSrvId", "");
  274. +       TEST_IP = votesystem.getString("TestIp", "");
  275. +   }
  276. +  
  277.     public static void loadTVTConfig()
  278.     {
  279.         final PropertiesParser tvtConfig = new PropertiesParser(EVENT_TVT_CONFIG_FILE);
  280. @@ -3190,6 +3283,7 @@
  281.             loadAutoPotionsConfig();
  282.             loadCustomMailManagerConfig();
  283.             loadMerchantZeroPriceConfig();
  284. +           loadVoteConfig();
  285.             loadWeddingConfig();
  286.             loadRebirthConfig();
  287.             loadBankingConfig();
  288. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/commons/util/StatsSet.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/commons/util/StatsSet.java
  289. new file mode 100644
  290. index 0000000..cb54758
  291. --- /dev/null
  292. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/commons/util/StatsSet.java
  293. @@ -0,0 +1,91 @@
  294. +/*
  295. + * This file is part of the L2J Mobius project.
  296. + *
  297. + * This program is free software: you can redistribute it and/or modify
  298. + * it under the terms of the GNU General Public License as published by
  299. + * the Free Software Foundation, either version 3 of the License, or
  300. + * (at your option) any later version.
  301. + *
  302. + * This program is distributed in the hope that it will be useful,
  303. + * but WITHOUT ANY WARRANTY; without even the implied warranty of
  304. + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  305. + * General Public License for more details.
  306. + *
  307. + * You should have received a copy of the GNU General Public License
  308. + * along with this program. If not, see <http://www.gnu.org/licenses/>.
  309. + */
  310. +package org.l2jmobius.commons.util;
  311. +
  312. +import java.util.HashMap;
  313. +
  314. +/**
  315. + * @author escor
  316. + */
  317. +public class StatsSet extends HashMap<String, Object>
  318. +{
  319. +  
  320. +   public StatsSet()
  321. +   {
  322. +       super();
  323. +   }
  324. +  
  325. +   public StatsSet(final StatsSet set)
  326. +   {
  327. +       super(set);
  328. +   }
  329. +  
  330. +   public void set(final String key, final Object value)
  331. +   {
  332. +       put(key, value);
  333. +   }
  334. +  
  335. +   public void set(final String key, final int value)
  336. +   {
  337. +       put(key, value);
  338. +   }
  339. +  
  340. +   public void set(final String key, final int[] value)
  341. +   {
  342. +       put(key, value);
  343. +   }
  344. +  
  345. +   public int getInteger(final String key)
  346. +   {
  347. +       final Object val = get(key);
  348. +      
  349. +       if (val instanceof Number)
  350. +       {
  351. +           return ((Number) val).intValue();
  352. +       }
  353. +       if (val instanceof String)
  354. +       {
  355. +           return Integer.parseInt((String) val);
  356. +       }
  357. +       if (val instanceof Boolean)
  358. +       {
  359. +           return (Boolean) val ? 1 : 0;
  360. +       }
  361. +      
  362. +       throw new IllegalArgumentException("StatsSet : Integer value required, but found: " + val + " for key: " + key + ".");
  363. +   }
  364. +  
  365. +   public int getInteger(final String key, final int defaultValue)
  366. +   {
  367. +       final Object val = get(key);
  368. +      
  369. +       if (val instanceof Number)
  370. +       {
  371. +           return ((Number) val).intValue();
  372. +       }
  373. +       if (val instanceof String)
  374. +       {
  375. +           return Integer.parseInt((String) val);
  376. +       }
  377. +       if (val instanceof Boolean)
  378. +       {
  379. +           return (Boolean) val ? 1 : 0;
  380. +       }
  381. +      
  382. +       return defaultValue;
  383. +   }
  384. +}
  385. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/GameServer.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/GameServer.java
  386. index 72f2e67..806f612 100644
  387. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/GameServer.java
  388. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/GameServer.java
  389. @@ -131,6 +131,8 @@
  390.  import org.l2jmobius.gameserver.scripting.ScriptEngineManager;
  391.  import org.l2jmobius.gameserver.taskmanager.TaskManager;
  392.  import org.l2jmobius.gameserver.ui.Gui;
  393. +import org.l2jmobius.gameserver.votesystem.Handler.voteManager;
  394. +import org.l2jmobius.gameserver.votesystem.VoteUtil.ReadJson;
  395.  import org.l2jmobius.telnet.TelnetStatusThread;
  396.  
  397.  public class GameServer
  398. @@ -331,6 +333,18 @@
  399.         FortSiegeManager.getInstance();
  400.         CrownManager.getInstance();
  401.        
  402. +       Util.printSection("Vote Reward System");
  403. +       if (Config.ENABLE_VOTE_SYSTEM)
  404. +       {
  405. +           voteManager.getInatance();
  406. +           LOGGER.info("======================Vote System Enabled=========================");
  407. +           ReadJson.getInstance();
  408. +       }
  409. +       else
  410. +       {
  411. +           LOGGER.info("======================Vote System Disabled=========================");
  412. +       }
  413. +      
  414.         Util.printSection("Boat");
  415.         BoatData.getInstance();
  416.        
  417. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/Shutdown.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/Shutdown.java
  418. index c040922..569a5d9 100644
  419. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/Shutdown.java
  420. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/Shutdown.java
  421. @@ -42,6 +42,7 @@
  422.  import org.l2jmobius.gameserver.network.gameserverpackets.ServerStatus;
  423.  import org.l2jmobius.gameserver.network.serverpackets.ServerClose;
  424.  import org.l2jmobius.gameserver.network.serverpackets.SystemMessage;
  425. +import org.l2jmobius.gameserver.votesystem.Handler.voteManager;
  426.  
  427.  /**
  428.   * This class provides the functions for shutting down and restarting the server.<br>
  429. @@ -453,6 +454,14 @@
  430.         FishingChampionshipManager.getInstance().shutdown();
  431.         LOGGER.info("Fishing Championship data have been saved!!");
  432.        
  433. +       // Save invidual votes data
  434. +      
  435. +       if (Config.ENABLE_VOTE_SYSTEM)
  436. +       {
  437. +           voteManager.getInatance().Shutdown();
  438. +           LOGGER.info("Vote data have been saved!!");
  439. +       }
  440. +      
  441.         // Schemes save.
  442.         SchemeBufferTable.getInstance().saveSchemes();
  443.         LOGGER.info("BufferTable data has been saved!!");
  444. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/VoicedCommandHandler.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/VoicedCommandHandler.java
  445. index 9236561..c5b807b 100644
  446. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/VoicedCommandHandler.java
  447. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/VoicedCommandHandler.java
  448. @@ -31,6 +31,7 @@
  449.  import org.l2jmobius.gameserver.handler.voicedcommandhandlers.Online;
  450.  import org.l2jmobius.gameserver.handler.voicedcommandhandlers.StatsCmd;
  451.  import org.l2jmobius.gameserver.handler.voicedcommandhandlers.TvTCmd;
  452. +import org.l2jmobius.gameserver.handler.voicedcommandhandlers.VoteReward;
  453.  import org.l2jmobius.gameserver.handler.voicedcommandhandlers.Wedding;
  454.  
  455.  public class VoicedCommandHandler
  456. @@ -97,6 +98,11 @@
  457.             registerVoicedCommandHandler(new AutoPotion());
  458.         }
  459.        
  460. +       if (Config.ENABLE_VOTE_SYSTEM && Config.ENABLE_INDIVIDUAL_VOTE && Config.ENABLE_VOTING_COMMAND)
  461. +       {
  462. +           registerVoicedCommandHandler(new VoteReward());
  463. +       }
  464. +      
  465.         LOGGER.info("VoicedCommandHandler: Loaded " + _datatable.size() + " handlers.");
  466.     }
  467.    
  468. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/voicedcommandhandlers/VoteReward.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/voicedcommandhandlers/VoteReward.java
  469. new file mode 100644
  470. index 0000000..ade580a
  471. --- /dev/null
  472. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/handler/voicedcommandhandlers/VoteReward.java
  473. @@ -0,0 +1,80 @@
  474. +/*
  475. + * This file is part of the L2J Mobius project.
  476. + *
  477. + * This program is free software: you can redistribute it and/or modify
  478. + * it under the terms of the GNU General Public License as published by
  479. + * the Free Software Foundation, either version 3 of the License, or
  480. + * (at your option) any later version.
  481. + *
  482. + * This program is distributed in the hope that it will be useful,
  483. + * but WITHOUT ANY WARRANTY; without even the implied warranty of
  484. + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  485. + * General Public License for more details.
  486. + *
  487. + * You should have received a copy of the GNU General Public License
  488. + * along with this program. If not, see <http://www.gnu.org/licenses/>.
  489. + */
  490. +package org.l2jmobius.gameserver.handler.voicedcommandhandlers;
  491. +
  492. +import org.l2jmobius.Config;
  493. +import org.l2jmobius.gameserver.handler.IVoicedCommandHandler;
  494. +import org.l2jmobius.gameserver.model.actor.instance.PlayerInstance;
  495. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  496. +import org.l2jmobius.gameserver.votesystem.Handler.voteManager;
  497. +
  498. +/**
  499. + * @author l2.topgameserver.net
  500. + */
  501. +public class VoteReward implements IVoicedCommandHandler
  502. +{
  503. +  
  504. +   @Override
  505. +   public boolean useVoicedCommand(String command, PlayerInstance player, String params)
  506. +   {
  507. +       if (command.equalsIgnoreCase(Config.VOTING_COMMAND))
  508. +       {
  509. +           if (player.isInJail())
  510. +           {
  511. +               player.sendMessage("You cannot use this function while you are jailed");
  512. +               return false;
  513. +           }
  514. +           if (!Config.ENABLE_VOTE_SYSTEM)
  515. +           {
  516. +               player.sendMessage("The rewards system has been disabled by your administrator");
  517. +               return false;
  518. +           }
  519. +           if (!Config.ENABLE_INDIVIDUAL_VOTE)
  520. +           {
  521. +               player.sendMessage("The individual reward system is disabled");
  522. +               return false;
  523. +           }
  524. +           if (!Config.ENABLE_VOTING_COMMAND)
  525. +           {
  526. +               player.sendMessage("Voting command reward is disabled");
  527. +               return false;
  528. +           }
  529. +          
  530. +           for (voteSite vs : voteSite.values())
  531. +           {
  532. +               new Thread(() ->
  533. +               {
  534. +                   voteManager.getInatance().getReward(player, vs.ordinal());
  535. +               }).start();
  536. +           }
  537. +          
  538. +           return true;
  539. +          
  540. +       }
  541. +       return false;
  542. +   }
  543. +  
  544. +   @Override
  545. +   public String[] getVoicedCommandList()
  546. +   {
  547. +       return new String[]
  548. +       {
  549. +           Config.VOTING_COMMAND,
  550. +       };
  551. +   }
  552. +  
  553. +}
  554. \ No newline at end of file
  555. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/NpcVoteRewardInstance.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/NpcVoteRewardInstance.java
  556. new file mode 100644
  557. index 0000000..42b55bd
  558. --- /dev/null
  559. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/NpcVoteRewardInstance.java
  560. @@ -0,0 +1,112 @@
  561. +/*
  562. + * This file is part of the L2J Mobius project.
  563. + *
  564. + * This program is free software: you can redistribute it and/or modify
  565. + * it under the terms of the GNU General Public License as published by
  566. + * the Free Software Foundation, either version 3 of the License, or
  567. + * (at your option) any later version.
  568. + *
  569. + * This program is distributed in the hope that it will be useful,
  570. + * but WITHOUT ANY WARRANTY; without even the implied warranty of
  571. + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  572. + * General Public License for more details.
  573. + *
  574. + * You should have received a copy of the GNU General Public License
  575. + * along with this program. If not, see <http://www.gnu.org/licenses/>.
  576. + */
  577. +package org.l2jmobius.gameserver.model.actor.instance;
  578. +
  579. +import org.l2jmobius.Config;
  580. +import org.l2jmobius.gameserver.datatables.ItemTable;
  581. +import org.l2jmobius.gameserver.model.actor.templates.NpcTemplate;
  582. +import org.l2jmobius.gameserver.network.serverpackets.NpcHtmlMessage;
  583. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  584. +import org.l2jmobius.gameserver.votesystem.Handler.voteManager;
  585. +import org.l2jmobius.gameserver.votesystem.Model.Reward;
  586. +import org.l2jmobius.gameserver.votesystem.VoteUtil.ReadJson;
  587. +
  588. +/**
  589. + * @author l2.topgameserver.net
  590. + */
  591. +public class NpcVoteRewardInstance extends NpcInstance
  592. +{
  593. +  
  594. +   /**
  595. +    * @param objectId
  596. +    * @param template
  597. +    */
  598. +   public NpcVoteRewardInstance(int objectId, NpcTemplate template)
  599. +   {
  600. +       super(objectId, template);
  601. +   }
  602. +  
  603. +   @Override
  604. +   public void onBypassFeedback(PlayerInstance player, String command)
  605. +   {
  606. +       if (command == null)
  607. +       {
  608. +           return;
  609. +       }
  610. +       int Ordinalsite = Integer.parseInt(command);
  611. +       voteManager.getInatance().getReward(player, Ordinalsite);
  612. +       showChatWindow(player, 0);
  613. +       super.onBypassFeedback(player, command);
  614. +   }
  615. +  
  616. +   @Override
  617. +   public void showChatWindow(PlayerInstance player, int val)
  618. +   {
  619. +       final NpcHtmlMessage html = new NpcHtmlMessage(0);
  620. +       StringBuilder sb = new StringBuilder();
  621. +       html.setFile(getHtmlPath(getNpcId(), 0));
  622. +       for (voteSite vs : voteSite.values())
  623. +       {
  624. +           sb.append("<table bgcolor=000000 width=280><tr>");
  625. +           sb.append("<td width=42><img src=\"icon.etc_treasure_box_i08\" width=32 height=32></td>");
  626. +           sb.append("<td width=220><table width=220>");
  627. +           sb.append("<tr><td><table width=220><tr><td width=145>On " + String.format("%s", ReadJson.getInstance().getRecordSite(vs.ordinal()).getSiteName()) + "</td>");
  628. +           if (voteManager.getInatance().checkIndividualAvailableVote(player, vs.ordinal()))
  629. +           {
  630. +               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>");
  631. +           }
  632. +           else
  633. +           {
  634. +               sb.append(String.format("<td width=75 align=center><font color=C68E00>%s</font></td>", voteManager.getInatance().getTimeRemainingWithSampleFormat(player, vs.ordinal())));
  635. +           }
  636. +           sb.append("</tr></table></td></tr>");
  637. +           sb.append("<tr><td><table width=220><tr>");
  638. +           int i = 0;
  639. +           for (Reward r : ReadJson.getInstance().getRewards(vs.ordinal()))
  640. +           {
  641. +               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()));
  642. +               i++;
  643. +               if ((i % 2) == 0)
  644. +               {
  645. +                   sb.append("</tr><tr>");
  646. +               }
  647. +           }
  648. +           sb.append("</tr></table></td></tr></table></td></tr></table><br>");
  649. +       }
  650. +       html.replace("%everyXtime%", Config.INTERVAL_TO_NEXT_VOTE / (3600 * 1000));
  651. +       html.replace("%enablevote%", sb.toString());
  652. +       html.replace("%accountName%", player.getName());
  653. +       player.sendPacket(html);
  654. +   }
  655. +  
  656. +   @Override
  657. +   public String getHtmlPath(int npcId, int val)
  658. +   {
  659. +       String filename = "";
  660. +       if (val == 0)
  661. +       {
  662. +           filename = "" + npcId;
  663. +       }
  664. +       else
  665. +       {
  666. +           filename = npcId + "-" + val;
  667. +       }
  668. +      
  669. +       return "data/html/mods/votesystem/" + filename + ".html";
  670. +   }
  671. +  
  672. +}
  673. \ No newline at end of file
  674. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/SchemeBufferInstance.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/SchemeBufferInstance.java
  675. index 93288b1..5cf052a 100644
  676. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/SchemeBufferInstance.java
  677. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/model/actor/instance/SchemeBufferInstance.java
  678. @@ -28,10 +28,11 @@
  679.  import org.l2jmobius.gameserver.model.actor.Creature;
  680.  import org.l2jmobius.gameserver.model.actor.Summon;
  681.  import org.l2jmobius.gameserver.model.actor.templates.NpcTemplate;
  682. +import org.l2jmobius.gameserver.network.serverpackets.MagicSkillUse;
  683.  import org.l2jmobius.gameserver.network.serverpackets.NpcHtmlMessage;
  684.  import org.l2jmobius.gameserver.util.Util;
  685.  
  686. -public class SchemeBufferInstance extends FolkInstance
  687. +public class SchemeBufferInstance extends NpcInstance
  688.  {
  689.     private static final int PAGE_LIMIT = 6;
  690.    
  691. @@ -40,6 +41,40 @@
  692.         super(objectId, template);
  693.     }
  694.    
  695. +   public String getSpecialSkills(String groupType)
  696. +   {
  697. +       List<Integer> skills = SchemeBufferTable.getInstance().getSkillsIdsByType(groupType);
  698. +      
  699. +       if (skills.isEmpty())
  700. +       {
  701. +           return "That group doesn't contain any skills.";
  702. +       }
  703. +      
  704. +       final StringBuilder sb = new StringBuilder(skills.size() * 150);
  705. +       int row = 0;
  706. +      
  707. +       for (int skillId : skills)
  708. +       {
  709. +           sb.append(((row % 2) == 0 ? "<table width=\"280\" bgcolor=\"000000\"><tr>" : "<table width=\"280\"><tr>"));
  710. +           if ((skillId > 0) && (skillId < 100))
  711. +           {
  712. +               StringUtil.append(sb, "<td height=40 width=40><img src=\"icon.skill00", skillId, "\" width=32 height=32></td><td width=190>", SkillTable.getInstance().getSkill(skillId, 1).getName(), "<br1><font color=\"B09878\">", SchemeBufferTable.getInstance().getAvailableBuff(skillId).getDescription(), "</font></td><td><button action=\"bypass npc_", getObjectId(), "_getSpecialBuff;", skillId, "\" width=32 height=32 back=\"L2UI_CH3.mapbutton_zoomin2\" fore=\"L2UI_CH3.mapbutton_zoomin1\"></td>");
  713. +           }
  714. +           else if ((skillId >= 100) && (skillId < 1000))
  715. +           {
  716. +               StringUtil.append(sb, "<td height=40 width=40><img src=\"icon.skill0", skillId, "\" width=32 height=32></td><td width=190>", SkillTable.getInstance().getSkill(skillId, 1).getName(), "<br1><font color=\"B09878\">", SchemeBufferTable.getInstance().getAvailableBuff(skillId).getDescription(), "</font></td><td><button action=\"bypass npc_", getObjectId(), "_getSpecialBuff;", skillId, "\" width=32 height=32 back=\"L2UI_CH3.mapbutton_zoomin2\" fore=\"L2UI_CH3.mapbutton_zoomin1\"></td>");
  717. +           }
  718. +           else if (skillId >= 1000)
  719. +           {
  720. +               StringUtil.append(sb, "<td height=40 width=40><img src=\"icon.skill", skillId, "\" width=32 height=32></td><td width=190>", SkillTable.getInstance().getSkill(skillId, 1).getName(), "<br1><font color=\"B09878\">", SchemeBufferTable.getInstance().getAvailableBuff(skillId).getDescription(), "</font></td><td><button action=\"bypass npc_", getObjectId(), "_getSpecialBuff;", skillId, "\" width=32 height=32 back=\"L2UI_CH3.mapbutton_zoomin2\" fore=\"L2UI_CH3.mapbutton_zoomin1\"></td>");
  721. +           }
  722. +           sb.append("</tr></table><img src=\"L2UI.SquareGray\" width=277 height=1>");
  723. +           row++;
  724. +       }
  725. +      
  726. +       return sb.toString();
  727. +   }
  728. +  
  729.     @Override
  730.     public void onBypassFeedback(PlayerInstance player, String commandValue)
  731.     {
  732. @@ -48,7 +83,68 @@
  733.        
  734.         final StringTokenizer st = new StringTokenizer(command, ";");
  735.         final String currentCommand = st.nextToken();
  736. -       if (currentCommand.startsWith("menu"))
  737. +      
  738. +       if (currentCommand.startsWith("specialbuff"))
  739. +       {
  740. +           final String ncommand = st.nextToken();
  741. +           final NpcHtmlMessage html = new NpcHtmlMessage(getObjectId());
  742. +           html.setFile(getHtmlPath(getNpcId(), 3));
  743. +           if (ncommand.startsWith("Resist"))
  744. +           {
  745. +               html.replace("%specialbuff%", getSpecialSkills("Resist"));
  746. +           }
  747. +           else if (ncommand.startsWith("Summon_buffs"))
  748. +           {
  749. +               html.replace("%specialbuff%", getSpecialSkills("Summon_buffs"));
  750. +           }
  751. +           else if (ncommand.startsWith("Malarias"))
  752. +           {
  753. +               html.replace("%specialbuff%", getSpecialSkills("Malarias"));
  754. +           }
  755. +           html.replace("%objectId%", getObjectId());
  756. +           player.sendPacket(html);
  757. +       }
  758. +      
  759. +       else if (currentCommand.startsWith("getSpecialBuff"))
  760. +       {
  761. +           final int skillid = Integer.parseInt(st.nextToken());
  762. +           final int price = SchemeBufferTable.getInstance().getAvailableBuff(skillid).getPrice();
  763. +           if (player.getInventory().getInventoryItemCount(7164, -1) >= 1)
  764. +           {
  765. +              
  766. +           }
  767. +           else if (player.getInventory().getInventoryItemCount(7569, -1) > price)
  768. +           {
  769. +               player.destroyItemByItemId("Buffer: ", 7569, price, player, true);
  770. +           }
  771. +           else
  772. +           {
  773. +               player.sendMessage("You don't have the necessary items to continue this action.");
  774. +               return;
  775. +           }
  776. +           Creature target = null;
  777. +           if (st.hasMoreTokens())
  778. +           {
  779. +               final String targetType = st.nextToken();
  780. +               if ((targetType != null) && targetType.equalsIgnoreCase("pet"))
  781. +               {
  782. +                   target = player.getPet();
  783. +               }
  784. +           }
  785. +           else
  786. +           {
  787. +               target = player;
  788. +           }
  789. +          
  790. +           if (target == null)
  791. +           {
  792. +               player.sendMessage("You don't have a pet.");
  793. +           }
  794. +           this.broadcastPacket(new MagicSkillUse(this, target, skillid, SchemeBufferTable.getInstance().getAvailableBuff(skillid).getLevel(), 0, 0));
  795. +           SkillTable.getInstance().getSkill(skillid, SchemeBufferTable.getInstance().getAvailableBuff(skillid).getLevel()).getEffects(this, target);
  796. +           player.sendMessage("You have acquired " + SkillTable.getInstance().getSkill(skillid, 1).getName());
  797. +       }
  798. +       else if (currentCommand.startsWith("menu"))
  799.         {
  800.             final NpcHtmlMessage html = new NpcHtmlMessage(getObjectId());
  801.             html.setFile(getHtmlPath(getNpcId(), 0));
  802. @@ -388,6 +484,10 @@
  803.         int count = 0;
  804.         for (String type : SchemeBufferTable.getInstance().getSkillTypes())
  805.         {
  806. +           if ((type.equalsIgnoreCase("Resist")) || (type.equalsIgnoreCase("Summon_buffs")) || (type.equalsIgnoreCase("Malarias")))
  807. +           {
  808. +               continue;
  809. +           }
  810.             if (count == 0)
  811.             {
  812.                 sb.append("<tr>");
  813. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/clientpackets/RequestBypassToServer.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/clientpackets/RequestBypassToServer.java
  814. index 528e895..84fc800 100644
  815. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/clientpackets/RequestBypassToServer.java
  816. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/clientpackets/RequestBypassToServer.java
  817. @@ -109,6 +109,30 @@
  818.                
  819.                 ach.useAdminCommand(_command, player);
  820.             }
  821. +           else if (_command.startsWith("vote_"))
  822. +           {
  823. +              
  824. +               int endOfId = _command.indexOf('_', 6);
  825. +               String id;
  826. +               if (endOfId > 0)
  827. +               {
  828. +                   id = _command.substring(5, endOfId);
  829. +               }
  830. +               else
  831. +               {
  832. +                   id = _command.substring(5);
  833. +               }
  834. +              
  835. +               if (_command.split(" ")[1].toString() != null)
  836. +               {
  837. +                   final WorldObject object = World.getInstance().findObject(Integer.parseInt(id));
  838. +                   if ((Config.ALLOW_CLASS_MASTERS && Config.ALLOW_REMOTE_CLASS_MASTERS && (object instanceof ClassMasterInstance)) //
  839. +                       || ((object instanceof NpcInstance) && (endOfId > 0) && player.isInsideRadius(object, NpcInstance.INTERACTION_DISTANCE, false, false)))
  840. +                   {
  841. +                       ((NpcInstance) object).onBypassFeedback(player, _command.split(" ")[1].toString());
  842. +                   }
  843. +               }
  844. +           }
  845.             else if (_command.equals("come_here") && player.isGM())
  846.             {
  847.                 final WorldObject obj = player.getTarget();
  848. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/serverpackets/CreatureSay.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/serverpackets/CreatureSay.java
  849. index 66c4ddd..0365268 100644
  850. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/serverpackets/CreatureSay.java
  851. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/network/serverpackets/CreatureSay.java
  852. @@ -25,7 +25,7 @@
  853.  public class CreatureSay extends GameServerPacket
  854.  {
  855.     private final int _objectId;
  856. -   private final ChatType _chatType;
  857. +   private final int _chatType;
  858.     private final String _charName;
  859.     private final String _text;
  860.    
  861. @@ -38,6 +38,14 @@
  862.     public CreatureSay(int objectId, ChatType chatType, String charName, String text)
  863.     {
  864.         _objectId = objectId;
  865. +       _chatType = chatType.getClientId();
  866. +       _charName = charName;
  867. +       _text = text;
  868. +   }
  869. +  
  870. +   public CreatureSay(int objectId, int chatType, String charName, String text)
  871. +   {
  872. +       _objectId = objectId;
  873.         _chatType = chatType;
  874.         _charName = charName;
  875.         _text = text;
  876. @@ -48,14 +56,14 @@
  877.     {
  878.         writeC(0x4a);
  879.         writeD(_objectId);
  880. -       writeD(_chatType.getClientId());
  881. +       writeD(_chatType);
  882.         writeS(_charName);
  883.         writeS(_text);
  884.        
  885.         final PlayerInstance player = getClient().getPlayer();
  886.         if (player != null)
  887.         {
  888. -           player.broadcastSnoop(_chatType, _charName, _text, this);
  889. +           player.broadcastSnoop(ChatType.values()[_chatType], _charName, _text, this);
  890.         }
  891.     }
  892.  }
  893. \ No newline at end of file
  894. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/util/Broadcast.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/util/Broadcast.java
  895. index 308ab18..ccf7ad6 100644
  896. --- a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/util/Broadcast.java
  897. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/util/Broadcast.java
  898. @@ -17,11 +17,13 @@
  899.  package org.l2jmobius.gameserver.util;
  900.  
  901.  import org.l2jmobius.gameserver.datatables.xml.ZoneData;
  902. +import org.l2jmobius.gameserver.enums.ChatType;
  903.  import org.l2jmobius.gameserver.model.World;
  904.  import org.l2jmobius.gameserver.model.actor.Creature;
  905.  import org.l2jmobius.gameserver.model.actor.instance.PlayerInstance;
  906.  import org.l2jmobius.gameserver.model.zone.ZoneType;
  907.  import org.l2jmobius.gameserver.network.serverpackets.CharInfo;
  908. +import org.l2jmobius.gameserver.network.serverpackets.CreatureSay;
  909.  import org.l2jmobius.gameserver.network.serverpackets.GameServerPacket;
  910.  import org.l2jmobius.gameserver.network.serverpackets.RelationChanged;
  911.  
  912. @@ -194,6 +196,11 @@
  913.         }
  914.     }
  915.    
  916. +   public static void toAllOnlinePlayers(String text, boolean isCritical)
  917. +   {
  918. +       toAllOnlinePlayers(new CreatureSay(0, isCritical ? ChatType.CRITICAL_ANNOUNCE.ordinal() : ChatType.ANNOUNCEMENT.ordinal(), "", text));
  919. +   }
  920. +  
  921.     /**
  922.      * Send a packet to all players in a specific zone type.
  923.      * @param <T> ZoneType.
  924. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/globalVoteDB.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/globalVoteDB.java
  925. new file mode 100644
  926. index 0000000..899b19c
  927. --- /dev/null
  928. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/globalVoteDB.java
  929. @@ -0,0 +1,123 @@
  930. +package org.l2jmobius.gameserver.votesystem.DB;
  931. +
  932. +import java.sql.Connection;
  933. +import java.sql.PreparedStatement;
  934. +import java.sql.ResultSet;
  935. +import java.sql.SQLException;
  936. +import java.sql.Statement;
  937. +import java.util.logging.Logger;
  938. +
  939. +import org.l2jmobius.commons.database.DatabaseFactory;
  940. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  941. +import org.l2jmobius.gameserver.votesystem.Model.globalVote;
  942. +
  943. +/**
  944. + * @author l2.topgameserver.net
  945. + */
  946. +public class globalVoteDB
  947. +{
  948. +   public static final Logger LOGGER = Logger.getLogger(globalVoteDB.class.getName());
  949. +   private Statement st;
  950. +   private Connection con;
  951. +   private final globalVote[] _globalVotes;
  952. +  
  953. +   private globalVoteDB()
  954. +   {
  955. +       _globalVotes = new globalVote[voteSite.values().length];
  956. +       loadGlobalVotes();
  957. +   }
  958. +  
  959. +   public void loadGlobalVotes()
  960. +   {
  961. +       con = DatabaseFactory.getConnection();
  962. +       try (PreparedStatement ps = con.prepareStatement("Select voteSite,lastRewardVotes from globalvotes");
  963. +           ResultSet rs = ps.executeQuery();)
  964. +       {
  965. +           if (rs.getRow() == 0)
  966. +           {
  967. +               for (voteSite vs : voteSite.values())
  968. +               {
  969. +                   globalVote gv = new globalVote();
  970. +                   gv.setVoteSite(vs.ordinal());
  971. +                   gv.setVotesLastReward(0);
  972. +                   _globalVotes[gv.getVoyeSite()] = gv;
  973. +               }
  974. +               return;
  975. +           }
  976. +           while (rs.next())
  977. +           {
  978. +               globalVote gv = new globalVote();
  979. +               gv.setVoteSite(rs.getInt("voteSite"));
  980. +               gv.setVotesLastReward(rs.getInt("lastRewardVotes"));
  981. +               _globalVotes[gv.getVoyeSite()] = gv;
  982. +           }
  983. +           ps.close();
  984. +           con.close();
  985. +          
  986. +       }
  987. +       catch (SQLException e)
  988. +       {
  989. +           e.printStackTrace();
  990. +       }
  991. +   }
  992. +  
  993. +   public void saveGlobalVote(globalVote gb)
  994. +   {
  995. +       try (Connection con = DatabaseFactory.getConnection();
  996. +           PreparedStatement ps = con.prepareStatement("INSERT INTO globalvotes(voteSite,lastRewardVotes) VALUES(?,?)" + "ON DUPLICATE KEY UPDATE voteSite = VALUES(voteSite), lastRewardVotes = VALUES(lastRewardVotes)"))
  997. +      
  998. +       {
  999. +           ps.setInt(1, gb.getVoyeSite());
  1000. +           ps.setInt(2, gb.getVotesLastReward());
  1001. +           ps.executeUpdate();
  1002. +          
  1003. +           ps.close();
  1004. +           con.close();
  1005. +          
  1006. +       }
  1007. +       catch (SQLException e)
  1008. +       {
  1009. +           e.printStackTrace();
  1010. +       }
  1011. +   }
  1012. +  
  1013. +   public void saveGlobalVotes(globalVote[] globalVotes)
  1014. +   {
  1015. +       try (Connection con = DatabaseFactory.getConnection();
  1016. +           PreparedStatement ps = con.prepareStatement("INSERT INTO globalvotes(voteSite,lastRewardVotes) VALUES(?,?)" + "ON DUPLICATE KEY UPDATE voteSite = VALUES(voteSite), lastRewardVotes = VALUES(lastRewardVotes)"))
  1017. +      
  1018. +       {
  1019. +           for (voteSite vs : voteSite.values())
  1020. +           {
  1021. +               globalVote gb = globalVotes[vs.ordinal()];
  1022. +               ps.setInt(1, gb.getVoyeSite());
  1023. +               ps.setInt(2, gb.getVotesLastReward());
  1024. +               ps.addBatch();
  1025. +           }
  1026. +           ps.executeBatch();
  1027. +          
  1028. +           ps.close();
  1029. +           con.close();
  1030. +          
  1031. +       }
  1032. +       catch (SQLException e)
  1033. +       {
  1034. +           e.printStackTrace();
  1035. +       }
  1036. +   }
  1037. +  
  1038. +   public globalVote[] getGlobalVotes()
  1039. +   {
  1040. +       return _globalVotes;
  1041. +   }
  1042. +  
  1043. +   public static final globalVoteDB getInstance()
  1044. +   {
  1045. +       return SingleHolder.INSTANCE;
  1046. +   }
  1047. +  
  1048. +   private static final class SingleHolder
  1049. +   {
  1050. +       protected static final globalVoteDB INSTANCE = new globalVoteDB();
  1051. +   }
  1052. +}
  1053. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/individualVoteDB.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/individualVoteDB.java
  1054. new file mode 100644
  1055. index 0000000..a3cfbbe
  1056. --- /dev/null
  1057. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/DB/individualVoteDB.java
  1058. @@ -0,0 +1,180 @@
  1059. +package org.l2jmobius.gameserver.votesystem.DB;
  1060. +
  1061. +import java.sql.Connection;
  1062. +import java.sql.PreparedStatement;
  1063. +import java.sql.ResultSet;
  1064. +import java.sql.SQLException;
  1065. +import java.sql.Statement;
  1066. +import java.util.HashMap;
  1067. +import java.util.HashSet;
  1068. +import java.util.Map;
  1069. +import java.util.logging.Logger;
  1070. +
  1071. +import org.l2jmobius.commons.database.DatabaseFactory;
  1072. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  1073. +import org.l2jmobius.gameserver.votesystem.Model.individualVote;
  1074. +
  1075. +/**
  1076. + * @author l2.topgameserver.net
  1077. + */
  1078. +public class individualVoteDB
  1079. +{
  1080. +   private static final Logger LOGGER = Logger.getLogger(individualVoteDB.class.getName());
  1081. +   private final Map<String, individualVote[]> _votes;
  1082. +   private Statement st;
  1083. +   private Connection con;
  1084. +  
  1085. +   private individualVoteDB()
  1086. +   {
  1087. +       _votes = new HashMap<>();
  1088. +       loadVotes();
  1089. +   }
  1090. +  
  1091. +   public void loadVotes()
  1092. +   {
  1093. +      
  1094. +       _votes.clear();
  1095. +       try (Connection con = DatabaseFactory.getConnection();
  1096. +           PreparedStatement ps = con.prepareStatement("SELECT voterIp,voteSite,diffTime,votingTimeSite,alreadyRewarded FROM individualvotes");
  1097. +           ResultSet rs = ps.executeQuery();)
  1098. +       {
  1099. +           individualVote[] ivs = new individualVote[voteSite.values().length];
  1100. +           while (rs.next())
  1101. +           {
  1102. +               individualVote iv = new individualVote();
  1103. +               iv.setVoterIp(rs.getString("voterIp"));
  1104. +               iv.setVoteSite(rs.getInt("voteSite"));
  1105. +               iv.setVotingTimeSite(rs.getLong("votingTimeSite"));
  1106. +               iv.setAlreadyRewarded(rs.getBoolean("alreadyRewarded"));
  1107. +              
  1108. +               if (_votes.containsKey(iv.getVoterIp()))
  1109. +               {
  1110. +                   if (_votes.get(iv.getVoterIp())[iv.getVoteSite()] == null)
  1111. +                   {
  1112. +                       ivs[iv.getVoteSite()] = iv;
  1113. +                       _votes.replace(iv.getVoterIp(), ivs);
  1114. +                   }
  1115. +               }
  1116. +               else
  1117. +               {
  1118. +                   ivs[iv.getVoteSite()] = iv;
  1119. +                   _votes.put(iv.getVoterIp(), ivs);
  1120. +                  
  1121. +               }
  1122. +           }
  1123. +          
  1124. +       }
  1125. +       catch (SQLException e)
  1126. +       {
  1127. +           e.printStackTrace();
  1128. +       }
  1129. +      
  1130. +   }
  1131. +  
  1132. +   public void SaveVotes(Map<String, individualVote[]> votes)
  1133. +   {
  1134. +      
  1135. +       if (votes == null)
  1136. +       {
  1137. +           return;
  1138. +       }
  1139. +       if (votes.size() == 0)
  1140. +       {
  1141. +           return;
  1142. +       }
  1143. +       try (Connection con = DatabaseFactory.getConnection();
  1144. +           PreparedStatement ps = con.prepareStatement("INSERT INTO individualvotes(voterIp,voteSite,votingTimeSite,alreadyRewarded) VALUES(?,?,?,?) ON DUPLICATE KEY UPDATE " + "voterIp = VALUES(voterIp), voteSite = VALUES(voteSite), votingTimeSite = VALUES(votingTimeSite),alreadyRewarded = VALUES(alreadyRewarded)");)
  1145. +       {
  1146. +          
  1147. +           for (Map.Entry<String, individualVote[]> ivm : votes.entrySet())
  1148. +           {
  1149. +               for (individualVote iv : ivm.getValue())
  1150. +               {
  1151. +                   if (iv == null)
  1152. +                   {
  1153. +                       continue;
  1154. +                   }
  1155. +                   ps.setString(1, iv.getVoterIp());
  1156. +                   ps.setInt(2, iv.getVoteSite());
  1157. +                   ps.setLong(4, iv.getVotingTimeSite());
  1158. +                   ps.setBoolean(5, iv.getAlreadyRewarded());
  1159. +                   ps.addBatch();
  1160. +               }
  1161. +           }
  1162. +           ps.executeBatch();
  1163. +       }
  1164. +       catch (SQLException e)
  1165. +       {
  1166. +           e.printStackTrace();
  1167. +       }
  1168. +   }
  1169. +  
  1170. +   public void SaveVote(individualVote vote)
  1171. +   {
  1172. +      
  1173. +       if (vote == null)
  1174. +       {
  1175. +           return;
  1176. +       }
  1177. +      
  1178. +       try (Connection con = DatabaseFactory.getConnection();
  1179. +           PreparedStatement ps = con.prepareStatement("INSERT INTO individualvotes(voterIp,voteSite,votingTimeSite,alreadyRewarded) VALUES(?,?,?,?) ON DUPLICATE KEY UPDATE" + "voterIp = VALUES(voterIp), voteSite = VALUES(voteSite), votingTimeSite = VALUES(votingTimeSite), alreadyRewarded = VALUES(alreadyRewarded)");)
  1180. +       {
  1181. +           ps.setString(1, vote.getVoterIp());
  1182. +           ps.setInt(2, vote.getVoteSite());
  1183. +           ps.setLong(4, vote.getVotingTimeSite());
  1184. +           ps.setBoolean(5, vote.getAlreadyRewarded());
  1185. +           ps.executeUpdate();
  1186. +       }
  1187. +       catch (SQLException e)
  1188. +       {
  1189. +           e.printStackTrace();
  1190. +       }
  1191. +   }
  1192. +  
  1193. +   public void DeleteVotes(HashSet<individualVote> deleteVotes)
  1194. +   {
  1195. +       if (deleteVotes == null)
  1196. +       {
  1197. +           return;
  1198. +       }
  1199. +       if (deleteVotes.size() == 0)
  1200. +       {
  1201. +           return;
  1202. +       }
  1203. +       try
  1204. +       {
  1205. +           con = DatabaseFactory.getConnection();
  1206. +           st = con.createStatement();
  1207. +           for (individualVote iv : deleteVotes)
  1208. +           {
  1209. +               String sql = String.format("Delete from individualvotes where voterIp = '%s' AND voteSite = %s", iv.getVoterIp(), iv.getVoteSite());
  1210. +               st.addBatch(sql);
  1211. +           }
  1212. +           int[] result = st.executeBatch();
  1213. +           st.close();
  1214. +           con.close();
  1215. +           LOGGER.info(result.length + " Innecesary votes has been deleted");
  1216. +          
  1217. +       }
  1218. +       catch (SQLException e)
  1219. +       {
  1220. +           e.printStackTrace();
  1221. +       }
  1222. +   }
  1223. +  
  1224. +   public Map<String, individualVote[]> getVotesDB()
  1225. +   {
  1226. +       return _votes;
  1227. +   }
  1228. +  
  1229. +   public static final individualVoteDB getInstance()
  1230. +   {
  1231. +       return SingleHolder.INSTANCE;
  1232. +   }
  1233. +  
  1234. +   private static final class SingleHolder
  1235. +   {
  1236. +       protected static final individualVoteDB INSTANCE = new individualVoteDB();
  1237. +   }
  1238. +}
  1239. \ No newline at end of file
  1240. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Enum/voteSite.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Enum/voteSite.java
  1241. new file mode 100644
  1242. index 0000000..9218452
  1243. --- /dev/null
  1244. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Enum/voteSite.java
  1245. @@ -0,0 +1,19 @@
  1246. +package org.l2jmobius.gameserver.votesystem.Enum;
  1247. +
  1248. +/**
  1249. + * @author l2.topgameserver.net
  1250. + */
  1251. +public enum voteSite
  1252. +{
  1253. +   L2TOPGAMESERVER, // 0
  1254. +   ITOPZ, // 1
  1255. +   L2TOPCO, // 2
  1256. +   L2VOTES, // 3
  1257. +   HOPZONE, // 4
  1258. +   L2NETWORK, // 5
  1259. +   L2TOPSERVERS, // 6
  1260. +   TOPL2JBRASIL, // 7
  1261. +   MMOTOP, // 8
  1262. +   TOPZONE, // 9
  1263. +   L2SERVERS,// 10
  1264. +}
  1265. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteHandler.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteHandler.java
  1266. new file mode 100644
  1267. index 0000000..d74419c
  1268. --- /dev/null
  1269. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteHandler.java
  1270. @@ -0,0 +1,500 @@
  1271. +package org.l2jmobius.gameserver.votesystem.Handler;
  1272. +
  1273. +import java.io.BufferedReader;
  1274. +import java.io.DataOutputStream;
  1275. +import java.io.InputStreamReader;
  1276. +import java.net.HttpURLConnection;
  1277. +import java.net.URL;
  1278. +import java.nio.charset.Charset;
  1279. +import java.text.ParseException;
  1280. +import java.text.SimpleDateFormat;
  1281. +import java.util.logging.Logger;
  1282. +
  1283. +import org.l2jmobius.Config;
  1284. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  1285. +import org.l2jmobius.gameserver.votesystem.Model.individualVoteResponse;
  1286. +import org.l2jmobius.gameserver.votesystem.VoteUtil.ReadJson;
  1287. +import org.l2jmobius.gameserver.votesystem.VoteUtil.VoteUtil;
  1288. +
  1289. +/**
  1290. + * @author l2.topgameserver.net
  1291. + */
  1292. +public class voteHandler
  1293. +{
  1294. +   public static final Logger LOGGER = Logger.getLogger(voteHandler.class.getName());
  1295. +  
  1296. +   protected static String getNetWorkResponse(String URL, int ordinal)
  1297. +   {
  1298. +       if ((ordinal == voteSite.L2NETWORK.ordinal()) && ("".equals(Config.VOTE_NETWORK_API_KEY) || "".equals(Config.VOTE_NETWORK_LINK) || "".equals(Config.VOTE_NETWORK_USER_NAME)))
  1299. +       {
  1300. +           return "";
  1301. +       }
  1302. +      
  1303. +       StringBuffer response = new StringBuffer();
  1304. +       try
  1305. +       {
  1306. +           String API_URL = Config.VOTE_NETWORK_LINK;
  1307. +           String detail = URL;
  1308. +           String postParameters = "";
  1309. +           postParameters += "apiKey=" + VoteUtil.between("apiKey=", detail, "&type=");
  1310. +           postParameters += "&type=" + VoteUtil.between("&type=", detail, "&player");
  1311. +           String beginIndexPlayer = "&player=";
  1312. +           String player = detail.substring(detail.indexOf(beginIndexPlayer) + beginIndexPlayer.length());
  1313. +          
  1314. +           if ((player != null) && !player.equals(""))
  1315. +           {
  1316. +               postParameters += "&player=" + player;
  1317. +           }
  1318. +          
  1319. +           byte[] postData = postParameters.getBytes(Charset.forName("UTF-8"));
  1320. +           URL url = new URL(API_URL);
  1321. +           HttpURLConnection con = (HttpURLConnection) url.openConnection();
  1322. +           con.setConnectTimeout(5000);
  1323. +           con.setRequestMethod("POST");
  1324. +           con.setRequestProperty("Content-Length", Integer.toString(postData.length));
  1325. +           con.setRequestProperty("User-Agent", "Mozilla/5.0");
  1326. +           con.setDoOutput(true);
  1327. +          
  1328. +           DataOutputStream os = new DataOutputStream(con.getOutputStream());
  1329. +           os.write(postData);
  1330. +           os.flush();
  1331. +           os.close();
  1332. +          
  1333. +           BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
  1334. +           String inputLine;
  1335. +          
  1336. +           while ((inputLine = in.readLine()) != null)
  1337. +           {
  1338. +               response.append(inputLine);
  1339. +           }
  1340. +           in.close();
  1341. +          
  1342. +           return response.toString();
  1343. +          
  1344. +       }
  1345. +       catch (Exception e)
  1346. +       {
  1347. +           LOGGER.warning(VoteUtil.Sites[ordinal] + " Say: An error ocurred " + e.getCause());
  1348. +           return "";
  1349. +       }
  1350. +   }
  1351. +  
  1352. +   protected static String getResponse(String Url, int ordinal)
  1353. +   {
  1354. +       if ((ordinal == voteSite.L2NETWORK.ordinal()) && ("".equals(Config.VOTE_NETWORK_API_KEY) || "".equals(Config.VOTE_NETWORK_LINK) || "".equals(Config.VOTE_NETWORK_USER_NAME)))
  1355. +       {
  1356. +           return "";
  1357. +       }
  1358. +      
  1359. +       try
  1360. +       {
  1361. +           int responseCode = 0;
  1362. +           URL objUrl = new URL(Url);
  1363. +           HttpURLConnection con = (HttpURLConnection) objUrl.openConnection();
  1364. +           con.setRequestMethod("GET");
  1365. +           con.setRequestProperty("User-Agent", "Mozilla/5.0");
  1366. +           con.setConnectTimeout(5000);
  1367. +           responseCode = con.getResponseCode();
  1368. +           if (responseCode == HttpURLConnection.HTTP_OK)
  1369. +           {
  1370. +               String inputLine;
  1371. +               StringBuffer response = new StringBuffer();
  1372. +               BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
  1373. +               while ((inputLine = in.readLine()) != null)
  1374. +               {
  1375. +                   response.append(inputLine);
  1376. +               }
  1377. +               in.close();
  1378. +               return response.toString();
  1379. +           }
  1380. +          
  1381. +       }
  1382. +       catch (Exception e)
  1383. +       {
  1384. +           LOGGER.warning(ReadJson.getInstance().getRecordSite(ordinal).getSiteName() + " Say: An error ocurred " + e.getCause());
  1385. +           return "";
  1386. +       }
  1387. +      
  1388. +       return "";
  1389. +   }
  1390. +  
  1391. +   public static individualVoteResponse getIndividualVoteResponse(int ordinal, String ip, String AccountName)
  1392. +   {
  1393. +       String response = "";
  1394. +       boolean isVoted = false;
  1395. +       long voteSiteTime = 0L, diffTime = 0L;
  1396. +       SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1397. +       individualVoteResponse ivr = new individualVoteResponse();
  1398. +      
  1399. +       switch (ordinal)
  1400. +       {
  1401. +           case 0:
  1402. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1403. +               isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"already_voted\":", response, ",\"vote_time\""));
  1404. +               if (isVoted)
  1405. +               {
  1406. +                   try
  1407. +                   {
  1408. +                       voteSiteTime = format.parse(VoteUtil.between("\"vote_time\":\"", response, "\",\"server_time\"")).getTime();
  1409. +                   }
  1410. +                   catch (ParseException e)
  1411. +                   {
  1412. +                       e.printStackTrace();
  1413. +                   }
  1414. +               }
  1415. +               break;
  1416. +          
  1417. +           case 1:
  1418. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1419. +               isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"isvoted\":", response.toString().toLowerCase().replaceAll("\n", "").replaceAll(" ", ""), ",\"votetime").replaceAll("\"", ""));
  1420. +               if (isVoted)
  1421. +               {
  1422. +                   try
  1423. +                   {
  1424. +                       voteSiteTime = (Long.parseLong(VoteUtil.between("\"votetime\":", response.toString().toLowerCase().replaceAll("\n", "").replaceAll(" ", ""), ",\"servertime"))) * 1000;
  1425. +                   }
  1426. +                   catch (Exception e)
  1427. +                   {
  1428. +                       e.printStackTrace();
  1429. +                   }
  1430. +               }
  1431. +               break;
  1432. +          
  1433. +           case 2:
  1434. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1435. +               isVoted = (response == "") ? false : Boolean.parseBoolean(response);
  1436. +               if (isVoted)
  1437. +               {
  1438. +                   voteSiteTime = System.currentTimeMillis() - (VoteUtil.getTimeZoneVotingSite(ordinal));
  1439. +               }
  1440. +               break;
  1441. +          
  1442. +           case 3:
  1443. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1444. +               isVoted = ((VoteUtil.between("\"status\":\"", response, "\",\"date\"") != "") && (Integer.parseInt(VoteUtil.between("\"status\":\"", response, "\",\"date\"")) == 1)) ? true : false;
  1445. +               if (isVoted)
  1446. +               {
  1447. +                   String dateString = VoteUtil.between("\"date\":\"", response, "\"}]");
  1448. +                   try
  1449. +                   {
  1450. +                       voteSiteTime = format.parse(String.format("%s-%s-%s %s:%s:%s", dateString.substring(0, 4), dateString.substring(4, 6), dateString.substring(6, 8), dateString.substring(8, 10), dateString.substring(10, 12), dateString.substring(12, 14))).getTime();
  1451. +                   }
  1452. +                   catch (ParseException e1)
  1453. +                   {
  1454. +                       e1.printStackTrace();
  1455. +                   }
  1456. +                  
  1457. +               }
  1458. +               break;
  1459. +          
  1460. +           case 4:
  1461. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1462. +               isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"voted\":", response, ",\"voteTime\""));
  1463. +               if (isVoted)
  1464. +               {
  1465. +                   try
  1466. +                   {
  1467. +                       voteSiteTime = format.parse(VoteUtil.between("\"voteTime\":\"", response, "\",\"hopzoneServerTime\"")).getTime();
  1468. +                   }
  1469. +                   catch (ParseException e)
  1470. +                   {
  1471. +                       e.printStackTrace();
  1472. +                   }
  1473. +               }
  1474. +               break;
  1475. +          
  1476. +           case 5:
  1477. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1478. +               isVoted = (!"".equals(response) && (Integer.parseInt(response) == 1)) ? true : false;
  1479. +               if (isVoted)
  1480. +               {
  1481. +                   voteSiteTime = System.currentTimeMillis() - (VoteUtil.getTimeZoneVotingSite(ordinal));
  1482. +               }
  1483. +               break;
  1484. +          
  1485. +           case 6:
  1486. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1487. +               isVoted = ("".equals(response)) ? false : Boolean.parseBoolean(VoteUtil.between("\"voted\":", response, ",\"voteTime\""));
  1488. +               if (isVoted)
  1489. +               {
  1490. +                   try
  1491. +                   {
  1492. +                       voteSiteTime = format.parse(VoteUtil.between("\"voteTime\":\"", response, "\",\"l2topserversServerTime\"")).getTime();
  1493. +                   }
  1494. +                   catch (Exception e)
  1495. +                   {
  1496. +                       e.printStackTrace();
  1497. +                   }
  1498. +                  
  1499. +               }
  1500. +               break;
  1501. +          
  1502. +           case 7:
  1503. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1504. +               isVoted = ((VoteUtil.between("\"status\":\"", response, "\",\"server_time\"") != "") && (Integer.parseInt(VoteUtil.between("\"status\":\"", response, "\",\"server_time\"")) == 1)) ? true : false;
  1505. +               if (isVoted)
  1506. +               {
  1507. +                   try
  1508. +                   {
  1509. +                       voteSiteTime = format.parse(VoteUtil.between("\"date\":\"", response, "\",\"status\"")).getTime();
  1510. +                   }
  1511. +                   catch (Exception e)
  1512. +                   {
  1513. +                       e.printStackTrace();
  1514. +                   }
  1515. +               }
  1516. +               break;
  1517. +          
  1518. +           case 8:
  1519. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1520. +               isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"is_voted\":", response, ",\"vote_time\""));
  1521. +               if (isVoted)
  1522. +               {
  1523. +                   try
  1524. +                   {
  1525. +                       voteSiteTime = (Long.parseLong(VoteUtil.between("\"vote_time\":", response, ",\"server_time\""))) * 1000;
  1526. +                   }
  1527. +                   catch (Exception e)
  1528. +                   {
  1529. +                       e.printStackTrace();
  1530. +                   }
  1531. +               }
  1532. +               break;
  1533. +          
  1534. +           case 9:
  1535. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1536. +               isVoted = (response == "") ? false : Boolean.parseBoolean(VoteUtil.between("\"isVoted\": ", response, ",\"voteTime\""));
  1537. +               if (isVoted)
  1538. +               {
  1539. +                   voteSiteTime = Long.parseLong(VoteUtil.between("\"voteTime\": \"", response, "\",\"serverTime\"")) * 1000;
  1540. +               }
  1541. +               break;
  1542. +          
  1543. +           case 10:
  1544. +               response = getResponse(getIndividualUrl(ordinal, ip, null), ordinal);
  1545. +               isVoted = (response == "") ? false : Boolean.parseBoolean(response);
  1546. +               if (isVoted)
  1547. +               {
  1548. +                   voteSiteTime = System.currentTimeMillis() - (VoteUtil.getTimeZoneVotingSite(ordinal));
  1549. +               }
  1550. +               break;
  1551. +          
  1552. +           default:
  1553. +               return null;
  1554. +       }
  1555. +       if (!response.equals("") && isVoted)
  1556. +       {
  1557. +           ivr.setIsVoted(isVoted);
  1558. +           ivr.setDiffTime(diffTime);
  1559. +           ivr.setVoteSiteTime(voteSiteTime);
  1560. +           return ivr;
  1561. +       }
  1562. +       return null;
  1563. +   }
  1564. +  
  1565. +   public int getGlobalVotesResponse(int ordinal)
  1566. +   {
  1567. +      
  1568. +       String response = "";
  1569. +       int totalVotes = 0;
  1570. +      
  1571. +       switch (ordinal)
  1572. +       {
  1573. +           case 0:
  1574. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1575. +               response = VoteUtil.between("\"getVotes\":", response, "}");
  1576. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1577. +               break;
  1578. +          
  1579. +           case 1:
  1580. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1581. +               response = VoteUtil.between("server_votes\":", response.replace(" ", ""), ",\"server_rank");
  1582. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1583. +               break;
  1584. +          
  1585. +           case 2:
  1586. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1587. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1588. +               break;
  1589. +          
  1590. +           case 3:
  1591. +               response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
  1592. +               response = VoteUtil.between("Votes:</th><th><a class='votes'>", response, "</a></th></tr><tr><th>Clicks:");
  1593. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1594. +               break;
  1595. +          
  1596. +           case 4:
  1597. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1598. +               response = VoteUtil.between("\"totalvotes\":", response, ",\"status_code\"");
  1599. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1600. +               break;
  1601. +          
  1602. +           case 5:
  1603. +               String responseNetwork = getNetWorkResponse(getGlobalUrl(ordinal), ordinal);
  1604. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1605. +               break;
  1606. +          
  1607. +           case 6:
  1608. +               response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
  1609. +               response = VoteUtil.between("VOTE <span>", response.toString().replaceAll("\n", ""), "</span>");
  1610. +              
  1611. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1612. +               break;
  1613. +          
  1614. +           case 7:
  1615. +               response = VoteUtil.getResponse(getGlobalUrl(ordinal), ordinal);
  1616. +               response = VoteUtil.between("nicas:</b> ", response, "<br /><br />");
  1617. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1618. +               break;
  1619. +          
  1620. +           case 8:
  1621. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1622. +               response = VoteUtil.between("\"monthly_votes\":", response, "}}");
  1623. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1624. +               break;
  1625. +          
  1626. +           case 9:
  1627. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1628. +               response = VoteUtil.between("\"totalVotes\":\"", response, "\",\"serverRank\"");
  1629. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1630. +               break;
  1631. +          
  1632. +           case 10:
  1633. +               response = getResponse(getGlobalUrl(ordinal), ordinal);
  1634. +               totalVotes = ((!"".equals(response)) ? (VoteUtil.isNumeric(response) ? Integer.parseInt(response) : -1) : -1);
  1635. +               break;
  1636. +       }
  1637. +      
  1638. +       return totalVotes;
  1639. +   }
  1640. +  
  1641. +   public static String getIndividualUrl(int ordinal, String ip, String AccountName)
  1642. +   {
  1643. +       String url = "";
  1644. +       ip = (Config.TEST_IP.equalsIgnoreCase("off") || Config.TEST_IP.equalsIgnoreCase("")) ? ip : Config.TEST_IP;
  1645. +       switch (ordinal)
  1646. +       {
  1647. +           case 0:
  1648. +               // l2.topgameserver.net
  1649. +               url = String.format("%sAPI_KEY=%s/getData/%s", Config.VOTE_LINK_TGS, Config.TGS_API_KEY, ip);
  1650. +               break;
  1651. +          
  1652. +           case 1:
  1653. +               // itopz.com
  1654. +               url = String.format("%s%s/%s/%s", Config.VOTE_LINK_ITOPZ, Config.ITOPZ_API_KEY, Config.ITOPZ_SRV_ID, ip);
  1655. +               break;
  1656. +          
  1657. +           case 2:
  1658. +               // l2top.co
  1659. +               url = String.format("%sVoteCheck.php?id=%s&ip=%s", Config.VOTE_LINK_TOP_CO, Config.TOP_CO_SRV_ID, ip);
  1660. +               break;
  1661. +          
  1662. +           case 3:
  1663. +               // l2votes.com
  1664. +               url = String.format("%sapi.php?apiKey=%s&ip=%s", Config.VOTE_LINK_VTS, Config.VTS_API_KEY, ip);
  1665. +               break;
  1666. +          
  1667. +           case 4:
  1668. +               // hopzone.net
  1669. +               url = String.format("%svote?token=%s&ip_address=%s", Config.VOTE_LINK_HZ, Config.HZ_API_KEY, ip);
  1670. +               break;
  1671. +          
  1672. +           case 5:
  1673. +               // l2network.eu
  1674. +               url = String.format("https://l2network.eu/index.php?a=in&u=%s&ipc=%s", Config.VOTE_NETWORK_USER_NAME, ip);
  1675. +               break;
  1676. +          
  1677. +           case 6:
  1678. +               // l2topservers.com
  1679. +               url = String.format("%stoken=%s&ip=%s", Config.VOTE_LINK_TSS, Config.TSS_API_TOKEN, ip);
  1680. +               break;
  1681. +          
  1682. +           case 7:
  1683. +               // top.l2jbrasil.com
  1684. +               url = String.format("%susername=%s&ip=%s&type=json", Config.BRASIL_VOTE_LINK, Config.BRASIL_USER_NAME, ip);
  1685. +               break;
  1686. +          
  1687. +           case 8:
  1688. +               // l2jtop
  1689. +               url = String.format("%s%s/ip/%s", Config.VOTE_LINK_MMOTOP, Config.MMOTOP_API_KEY, ip);
  1690. +               break;
  1691. +          
  1692. +           case 9:
  1693. +               // topzone.com
  1694. +               url = String.format("%svote?token=%s&ip=%s", Config.VOTE_LINK_TZ, Config.TZ_API_KEY, ip);
  1695. +               break;
  1696. +          
  1697. +           case 10:
  1698. +               // l2servers.com
  1699. +               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);
  1700. +               break;
  1701. +       }
  1702. +      
  1703. +       return url;
  1704. +   }
  1705. +  
  1706. +   public String getGlobalUrl(int ordinal)
  1707. +   {
  1708. +       String url = "";
  1709. +      
  1710. +       switch (ordinal)
  1711. +       {
  1712. +           case 0:
  1713. +               // l2.topgameserver.net
  1714. +               url = String.format("%sAPI_KEY=%s/getData", Config.VOTE_LINK_TGS, Config.TGS_API_KEY);
  1715. +               break;
  1716. +          
  1717. +           case 1:
  1718. +               // itopz.com
  1719. +               url = String.format("%s%s/%s", Config.VOTE_LINK_ITOPZ, Config.ITOPZ_API_KEY, Config.ITOPZ_SRV_ID);
  1720. +               break;
  1721. +          
  1722. +           case 2:
  1723. +               // l2top.co
  1724. +               url = String.format("%sVoteCheck_Total.php?id=%s", Config.VOTE_LINK_TOP_CO, Config.TOP_CO_SRV_ID);
  1725. +               break;
  1726. +          
  1727. +           case 3:
  1728. +               // l2votes.com
  1729. +               url = String.format("%sserverPage.php?sid=%s", Config.VOTE_LINK_VTS, Config.VTS_SID);
  1730. +               break;
  1731. +          
  1732. +           case 4:
  1733. +               // hopzone.net
  1734. +               url = String.format("%svotes?token=%s", Config.VOTE_LINK_HZ, Config.HZ_API_KEY);
  1735. +               break;
  1736. +          
  1737. +           case 5:
  1738. +               // l2network.eu
  1739. +               url = String.format("apiKey=%s&type=%s&player=", Config.VOTE_NETWORK_API_KEY, 1);
  1740. +               break;
  1741. +          
  1742. +           case 6:
  1743. +               // l2topservers
  1744. +               url = String.format("https://l2topservers.com/l2top/%s/%s", Config.TS_SRV_ID, Config.TS_DOMAIN_NAME);
  1745. +               break;
  1746. +          
  1747. +           case 7:
  1748. +               // top.l2jbrasil.com
  1749. +               url = String.format("https://top.l2jbrasil.com/index.php?a=stats&u=%s", Config.BRASIL_USER_NAME);
  1750. +               break;
  1751. +          
  1752. +           case 8:
  1753. +               // l2jtop.com
  1754. +               url = String.format("%s%s/info/", Config.VOTE_LINK_MMOTOP, Config.MMOTOP_API_KEY);
  1755. +               break;
  1756. +          
  1757. +           case 9:
  1758. +               // l2topzone.com
  1759. +               url = String.format("%sserver_%s/getServerData", Config.VOTE_LINK_TZ, Config.TZ_API_KEY);
  1760. +               break;
  1761. +          
  1762. +           case 10:
  1763. +               // l2servers.com
  1764. +               url = String.format("%syearlyvotes.php?server_id=%s", Config.VOTE_LINK_SERVERS, Config.SERVERS_SRV_ID);
  1765. +               break;
  1766. +       }
  1767. +      
  1768. +       return url;
  1769. +   }
  1770. +}
  1771. \ No newline at end of file
  1772. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteManager.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteManager.java
  1773. new file mode 100644
  1774. index 0000000..651ecde
  1775. --- /dev/null
  1776. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Handler/voteManager.java
  1777. @@ -0,0 +1,395 @@
  1778. +package org.l2jmobius.gameserver.votesystem.Handler;
  1779. +
  1780. +import java.util.HashSet;
  1781. +import java.util.Map;
  1782. +import java.util.concurrent.ConcurrentHashMap;
  1783. +import java.util.concurrent.ScheduledFuture;
  1784. +
  1785. +import org.l2jmobius.Config;
  1786. +import org.l2jmobius.commons.concurrent.ThreadPool;
  1787. +import org.l2jmobius.gameserver.model.World;
  1788. +import org.l2jmobius.gameserver.model.actor.instance.PlayerInstance;
  1789. +import org.l2jmobius.gameserver.network.GameClient;
  1790. +import org.l2jmobius.gameserver.network.SystemMessageId;
  1791. +import org.l2jmobius.gameserver.network.serverpackets.ItemList;
  1792. +import org.l2jmobius.gameserver.network.serverpackets.SystemMessage;
  1793. +import org.l2jmobius.gameserver.util.Broadcast;
  1794. +import org.l2jmobius.gameserver.votesystem.DB.globalVoteDB;
  1795. +import org.l2jmobius.gameserver.votesystem.DB.individualVoteDB;
  1796. +import org.l2jmobius.gameserver.votesystem.Enum.voteSite;
  1797. +import org.l2jmobius.gameserver.votesystem.Model.Reward;
  1798. +import org.l2jmobius.gameserver.votesystem.Model.globalVote;
  1799. +import org.l2jmobius.gameserver.votesystem.Model.individualVote;
  1800. +import org.l2jmobius.gameserver.votesystem.Model.individualVoteResponse;
  1801. +import org.l2jmobius.gameserver.votesystem.VoteUtil.ReadJson;
  1802. +import org.l2jmobius.gameserver.votesystem.VoteUtil.VoteUtil;
  1803. +
  1804. +/**
  1805. + * @author l2.topgameserver.net
  1806. + */
  1807. +public final class voteManager extends voteHandler
  1808. +{
  1809. +   private ScheduledFuture<?> _saveGlobalVotes;
  1810. +   private ScheduledFuture<?> _updateIndividualVotes;
  1811. +   private ScheduledFuture<?> _autoGlobalVotesReward;
  1812. +  
  1813. +   private HashSet<individualVote> _votes;
  1814. +   private Map<String, individualVote[]> _foundVoters;
  1815. +   private globalVote[] _globalVotes = new globalVote[voteSite.values().length];
  1816. +  
  1817. +   public voteManager()
  1818. +   {
  1819. +       _foundVoters = new ConcurrentHashMap<>();
  1820. +       loadVotes();
  1821. +       loadGlobalVotes();
  1822. +       checkAllResponseGlobalVotes();
  1823. +       stopAutoTasks();
  1824. +      
  1825. +       if (Config.ENABLE_INDIVIDUAL_VOTE && Config.ENABLE_VOTE_SYSTEM)
  1826. +       {
  1827. +           _updateIndividualVotes = ThreadPool.scheduleAtFixedRate(new AutoUpdateIndividualVotesTask(), 30000, Config.NEXT_TIME_TO_AUTO_UPDATE_INDIVIDUAL_VOTES);
  1828. +       }
  1829. +       if (Config.ENABLE_GLOBAL_VOTE && Config.ENABLE_VOTE_SYSTEM)
  1830. +       {
  1831. +           _autoGlobalVotesReward = ThreadPool.scheduleAtFixedRate(new AutoGlobalVoteRewardTask(), 10000, Config.NEXT_TIME_TO_CHECK_AUTO_GLOBAL_VOTES_REWARD);
  1832. +           _saveGlobalVotes = ThreadPool.scheduleAtFixedRate(new AutoSaveGlobalVotesTask(), 30000, Config.NEXT_TIME_TO_AUTO_UPDATE_TOTAL_VOTE);
  1833. +       }
  1834. +   }
  1835. +  
  1836. +   private void stopAutoTasks()
  1837. +   {
  1838. +       if (_saveGlobalVotes != null)
  1839. +       {
  1840. +           _saveGlobalVotes.cancel(true);
  1841. +           _saveGlobalVotes = null;
  1842. +       }
  1843. +       if (_updateIndividualVotes != null)
  1844. +       {
  1845. +           _updateIndividualVotes.cancel(true);
  1846. +           _updateIndividualVotes = null;
  1847. +       }
  1848. +       if (_autoGlobalVotesReward != null)
  1849. +       {
  1850. +           _autoGlobalVotesReward.cancel(true);
  1851. +           _autoGlobalVotesReward = null;
  1852. +       }
  1853. +   }
  1854. +  
  1855. +   public void getReward(PlayerInstance player, int ordinalSite)
  1856. +   {
  1857. +       String ip = existIp(player);
  1858. +       if (ip == null)
  1859. +       {
  1860. +           return;
  1861. +       }
  1862. +       individualVoteResponse ivr = getIndividualVoteResponse(ordinalSite, ip, player.getAccountName());
  1863. +       if (ivr == null)
  1864. +       {
  1865. +           player.sendMessage("We were unable to verify your vote with: " + ReadJson.getInstance().getRecordSite(ordinalSite).getSiteName() + ", please try again");
  1866. +           return;
  1867. +       }
  1868. +
  1869. +       if (getTimeRemaining(new individualVote(ip, ivr.getVoteSiteTime(), ordinalSite, false)) < 0)
  1870. +       {
  1871. +           player.sendMessage("We were unable to verify your vote with: " + ReadJson.getInstance().getRecordSite(ordinalSite).getSiteName() + ", please try again");
  1872. +           return;
  1873. +       }
  1874. +       if (!ivr.getIsVoted())
  1875. +       {
  1876. +           player.sendMessage(String.format("You haven't vote on %s yet!", ReadJson.getInstance().getRecordSite(ordinalSite).getSiteName()));
  1877. +           return;
  1878. +       }
  1879. +       if (!checkIndividualAvailableVote(player, ordinalSite))
  1880. +       {
  1881. +           player.sendMessage(String.format("You can get the reward again on %s at %s", ReadJson.getInstance().getRecordSite(ordinalSite).getSiteName(), getTimeRemainingWithSampleFormat(player, ordinalSite)));
  1882. +           return;
  1883. +       }
  1884. +       individualVote iv = new individualVote(ip, ivr.getVoteSiteTime(), ordinalSite, false);
  1885. +      
  1886. +       individualVote[] aiv;
  1887. +       if (!_foundVoters.containsKey(ip))
  1888. +       {
  1889. +           aiv = new individualVote[voteSite.values().length];
  1890. +           iv.setAlreadyRewarded(true);
  1891. +           aiv[ordinalSite] = iv;
  1892. +           _foundVoters.put(ip, aiv);
  1893. +       }
  1894. +       else
  1895. +       {
  1896. +           aiv = _foundVoters.get(ip);
  1897. +           iv.setAlreadyRewarded(true);
  1898. +           aiv[ordinalSite] = iv;
  1899. +           _foundVoters.replace(ip, aiv);
  1900. +          
  1901. +       }
  1902. +       for (Reward reward : ReadJson.getInstance().getRewards(ordinalSite))
  1903. +       {
  1904. +           player.getInventory().addItem("VoteSystem", reward.getItemId(), reward.getItemCount(), player, null);
  1905. +           player.sendPacket(new SystemMessage(SystemMessageId.YOU_HAVE_EARNED_S2_S1_S).addItemName(reward.getItemId()).addNumber(reward.getItemCount()));
  1906. +       }
  1907. +       player.sendMessage(String.format("%s: Thank you for voting for our server, your reward has been delivered.", ReadJson.getInstance().getRecordSite(ordinalSite).getSiteName()));
  1908. +       player.sendPacket(new ItemList(player, true));
  1909. +   }
  1910. +  
  1911. +   public boolean checkIndividualAvailableVote(PlayerInstance player, int ordinalSite)
  1912. +   {
  1913. +       String ip = existIp(player);
  1914. +       if (_foundVoters.containsKey(ip))
  1915. +       {
  1916. +           individualVote[] ivs = _foundVoters.get(ip);
  1917. +           if (ivs[ordinalSite] == null)
  1918. +           {
  1919. +               return true;
  1920. +           }
  1921. +           if (ivs[ordinalSite] != null)
  1922. +           {
  1923. +               individualVote iv = ivs[ordinalSite];
  1924. +               if (getTimeRemaining(iv) < 0)
  1925. +               {
  1926. +                   return true;
  1927. +               }
  1928. +           }
  1929. +       }
  1930. +       else
  1931. +       {
  1932. +           return true;
  1933. +       }
  1934. +      
  1935. +       return false;
  1936. +   }
  1937. +  
  1938. +   public long getTimeRemaining(individualVote iv)
  1939. +   {
  1940. +       long timeRemaining = 0L;
  1941. +       long diff = VoteUtil.getTimeZoneVotingSite(iv.getVoteSite());
  1942. +       long nexttime = ReadJson.getInstance().getRecordSite(iv.getVoteSite()).getNextVoteTime();
  1943. +       timeRemaining = (iv.getVotingTimeSite() + nexttime) - (System.currentTimeMillis() - diff);
  1944. +       return timeRemaining;
  1945. +   }
  1946. +  
  1947. +   public String getTimeRemainingWithSampleFormat(PlayerInstance player, int ordinalSite)
  1948. +   {
  1949. +       String ip = existIp(player);
  1950. +      
  1951. +       String timeRemainingWithSampleFormat = "";
  1952. +       if (_foundVoters.containsKey(ip))
  1953. +       {
  1954. +           individualVote[] ivs = _foundVoters.get(ip);
  1955. +           if (ivs[ordinalSite] != null)
  1956. +           {
  1957. +               individualVote iv = ivs[ordinalSite];
  1958. +               long timeRemaining = getTimeRemaining(iv);
  1959. +               if (timeRemaining > 0)
  1960. +               {
  1961. +                   timeRemainingWithSampleFormat = CalculateTimeRemainingWithSampleDateFormat(timeRemaining);
  1962. +                   return timeRemainingWithSampleFormat;
  1963. +               }
  1964. +           }
  1965. +       }
  1966. +       return timeRemainingWithSampleFormat;
  1967. +   }
  1968. +  
  1969. +   public String CalculateTimeRemainingWithSampleDateFormat(long timeRemaining)
  1970. +   {
  1971. +       long t = timeRemaining / 1000;
  1972. +       int hours = Math.round(((t / 3600) % 24));
  1973. +       int minutes = Math.round((t / 60) % 60);
  1974. +       int seconds = Math.round(t % 60);
  1975. +       return String.format("%sH:%sm:%ss", hours, minutes, seconds);
  1976. +   }
  1977. +  
  1978. +   public String existIp(PlayerInstance p)
  1979. +   {
  1980. +      
  1981. +       GameClient client = p.getClient();
  1982. +       if ((client.getConnection().getInetAddress() != null) && (client.getPlayer() != null) && !client.isDetached())
  1983. +       {
  1984. +           try
  1985. +           {
  1986. +               return client.getIpAddress();
  1987. +           }
  1988. +           catch (Exception e)
  1989. +           {
  1990. +               e.printStackTrace();
  1991. +           }
  1992. +       }
  1993. +       return null;
  1994. +      
  1995. +   }
  1996. +  
  1997. +   public final void loadVotes()
  1998. +   {
  1999. +       _foundVoters = individualVoteDB.getInstance().getVotesDB();
  2000. +   }
  2001. +  
  2002. +   protected void loadGlobalVotes()
  2003. +   {
  2004. +       _globalVotes = globalVoteDB.getInstance().getGlobalVotes();
  2005. +   }
  2006. +  
  2007. +   public void saveVotes()
  2008. +   {
  2009. +       individualVoteDB.getInstance().SaveVotes(_foundVoters);
  2010. +   }
  2011. +  
  2012. +   protected void AutoGlobalVoteReward()
  2013. +   {
  2014. +       HashSet<String> ipList = new HashSet<>();
  2015. +       for (voteSite vs : voteSite.values())
  2016. +       {
  2017. +           new Thread(() ->
  2018. +           {
  2019. +               checkNewUpdate(vs.ordinal());
  2020. +               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)))
  2021. +               {
  2022. +                   _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));
  2023. +                   for (PlayerInstance player : World.getInstance().getAllPlayers())
  2024. +                   {
  2025. +                       String ip = existIp(player);
  2026. +                       if (ip == null)
  2027. +                       {
  2028. +                           continue;
  2029. +                       }
  2030. +                       if (ipList.contains(ip))
  2031. +                       {
  2032. +                           continue;
  2033. +                       }
  2034. +                       for (Reward reward : ReadJson.getInstance().getRewards(11))
  2035. +                       {
  2036. +                           player.getInventory().addItem("VoteSystem: ", reward.getItemId(), reward.getItemCount(), player, null);
  2037. +                           player.sendPacket(new SystemMessage(SystemMessageId.YOU_HAVE_EARNED_S2_S1_S).addItemName(reward.getItemId()).addNumber(reward.getItemCount()));
  2038. +                       }
  2039. +                       ipList.add(ip);
  2040. +                       player.sendPacket(new ItemList(player, true));
  2041. +                   }
  2042. +                   Broadcast.toAllOnlinePlayers(VoteUtil.Sites[vs.ordinal()] + ": All players has been rewarded, please check your inventory", true);
  2043. +               }
  2044. +               else
  2045. +               {
  2046. +                   String encourage = "";
  2047. +                   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);
  2048. +                   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());
  2049. +                   Broadcast.toAllOnlinePlayers(encourage, true);
  2050. +               }
  2051. +           }).start();
  2052. +          
  2053. +       }
  2054. +   }
  2055. +  
  2056. +   protected void AutoSaveGlobalVotes()
  2057. +   {
  2058. +       globalVoteDB.getInstance().saveGlobalVotes(_globalVotes);
  2059. +   }
  2060. +  
  2061. +   protected synchronized void AutoUpdateIndividualVotes()
  2062. +   {
  2063. +       AutoCleanInnecesaryIndividualVotes();
  2064. +       individualVoteDB.getInstance().SaveVotes(_foundVoters);
  2065. +   }
  2066. +  
  2067. +   protected synchronized void AutoCleanInnecesaryIndividualVotes()
  2068. +   {
  2069. +       HashSet<individualVote> removeVotes = new HashSet<>();
  2070. +       for (Map.Entry<String, individualVote[]> ivs : _foundVoters.entrySet())
  2071. +       {
  2072. +           for (individualVote individualvote : ivs.getValue())
  2073. +           {
  2074. +               if (individualvote == null)
  2075. +               {
  2076. +                   continue;
  2077. +               }
  2078. +               if (getTimeRemaining(individualvote) < 0)
  2079. +               {
  2080. +                   removeVotes.add(individualvote);
  2081. +                   if (_foundVoters.containsKey(individualvote.getVoterIp()))
  2082. +                   {
  2083. +                       if (_foundVoters.get(individualvote.getVoterIp())[individualvote.getVoteSite()] != null)
  2084. +                       {
  2085. +                           _foundVoters.get(individualvote.getVoterIp())[individualvote.getVoteSite()] = null;
  2086. +                       }
  2087. +                   }
  2088. +               }
  2089. +           }
  2090. +       }
  2091. +       individualVoteDB.getInstance().DeleteVotes(removeVotes);
  2092. +   }
  2093. +  
  2094. +   public void checkAllResponseGlobalVotes()
  2095. +   {
  2096. +       for (voteSite vs : voteSite.values())
  2097. +       {
  2098. +           new Thread(() ->
  2099. +           {
  2100. +               checkNewUpdate(vs.ordinal());
  2101. +           });
  2102. +       }
  2103. +   }
  2104. +  
  2105. +   public void checkNewUpdate(int ordinalSite)
  2106. +   {
  2107. +       int globalVotesResponse = getGlobalVotesResponse(ordinalSite);
  2108. +       if (globalVotesResponse == -1)
  2109. +       {
  2110. +           return;
  2111. +       }
  2112. +       _globalVotes[ordinalSite].setCurrentVotes(globalVotesResponse);
  2113. +       int last = globalVotesResponse - (ordinalSite == voteSite.L2SERVERS.ordinal() ? 25 * Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD);
  2114. +       if (last < 0)
  2115. +       {
  2116. +           _globalVotes[ordinalSite].setVotesLastReward(0);
  2117. +           return;
  2118. +       }
  2119. +       if ((_globalVotes[ordinalSite].getVotesLastReward() + (ordinalSite == voteSite.L2SERVERS.ordinal() ? 25 * Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD : Config.GLOBAL_VOTES_AMOUNT_TO_NEXT_REWARD)) < globalVotesResponse)
  2120. +       {
  2121. +           _globalVotes[ordinalSite].setVotesLastReward(globalVotesResponse);
  2122. +           return;
  2123. +       }
  2124. +   }
  2125. +  
  2126. +   public void Shutdown()
  2127. +   {
  2128. +       AutoSaveGlobalVotes();
  2129. +       AutoCleanInnecesaryIndividualVotes();
  2130. +       AutoUpdateIndividualVotes();
  2131. +   }
  2132. +  
  2133. +   protected class AutoGlobalVoteRewardTask implements Runnable
  2134. +   {
  2135. +      
  2136. +       @Override
  2137. +       public void run()
  2138. +       {
  2139. +           AutoGlobalVoteReward();
  2140. +          
  2141. +       }
  2142. +      
  2143. +   }
  2144. +  
  2145. +   protected class AutoSaveGlobalVotesTask implements Runnable
  2146. +   {
  2147. +      
  2148. +       @Override
  2149. +       public void run()
  2150. +       {
  2151. +           AutoSaveGlobalVotes();
  2152. +          
  2153. +       }
  2154. +      
  2155. +   }
  2156. +  
  2157. +   protected class AutoUpdateIndividualVotesTask implements Runnable
  2158. +   {
  2159. +      
  2160. +       @Override
  2161. +       public void run()
  2162. +       {
  2163. +           AutoUpdateIndividualVotes();
  2164. +          
  2165. +       }
  2166. +      
  2167. +   }
  2168. +  
  2169. +   public static voteManager getInatance()
  2170. +   {
  2171. +       return SingleHolder.INSTANCE;
  2172. +   }
  2173. +  
  2174. +   private static class SingleHolder
  2175. +   {
  2176. +       protected static final voteManager INSTANCE = new voteManager();
  2177. +   }
  2178. +}
  2179. \ No newline at end of file
  2180. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/Reward.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/Reward.java
  2181. new file mode 100644
  2182. index 0000000..d0cda74
  2183. --- /dev/null
  2184. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/Reward.java
  2185. @@ -0,0 +1,36 @@
  2186. +package org.l2jmobius.gameserver.votesystem.Model;
  2187. +
  2188. +/**
  2189. + * @author l2.topgameserver.net
  2190. + */
  2191. +public class Reward
  2192. +{
  2193. +   private int _itemId;
  2194. +   private int _itemCount;
  2195. +  
  2196. +   public Reward(int itemId, int itemCount)
  2197. +   {
  2198. +       _itemId = itemId;
  2199. +       _itemCount = itemCount;
  2200. +   }
  2201. +  
  2202. +   public void setItemId(int itemId)
  2203. +   {
  2204. +       _itemId = itemId;
  2205. +   }
  2206. +  
  2207. +   public void setItemCount(int itemCount)
  2208. +   {
  2209. +       _itemCount = itemCount;
  2210. +   }
  2211. +  
  2212. +   public int getItemId()
  2213. +   {
  2214. +       return _itemId;
  2215. +   }
  2216. +  
  2217. +   public int getItemCount()
  2218. +   {
  2219. +       return _itemCount;
  2220. +   }
  2221. +}
  2222. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/VoteSite.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/VoteSite.java
  2223. new file mode 100644
  2224. index 0000000..b17237b
  2225. --- /dev/null
  2226. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/VoteSite.java
  2227. @@ -0,0 +1,76 @@
  2228. +package org.l2jmobius.gameserver.votesystem.Model;
  2229. +
  2230. +import java.util.ArrayList;
  2231. +import java.util.List;
  2232. +import java.util.concurrent.TimeUnit;
  2233. +
  2234. +/**
  2235. + * @author l2.topgameserver.net
  2236. + */
  2237. +public class VoteSite
  2238. +{
  2239. +   private int _siteOrdinal;
  2240. +   private String _siteName;
  2241. +   private String _timeZone;
  2242. +   private long _nextVoteTime;
  2243. +   private final List<Reward> _rewards = new ArrayList<>();
  2244. +  
  2245. +   public VoteSite()
  2246. +   {
  2247. +      
  2248. +   }
  2249. +  
  2250. +   public void setSiteOrdinal(int siteOrdinal)
  2251. +   {
  2252. +       _siteOrdinal = siteOrdinal;
  2253. +   }
  2254. +  
  2255. +   public void setTimeZone(String timeZone)
  2256. +   {
  2257. +       _timeZone = timeZone;
  2258. +   }
  2259. +  
  2260. +   public void setNextVoteTime(int nextVoteTime)
  2261. +   {
  2262. +       _nextVoteTime = nextVoteTime;
  2263. +   }
  2264. +  
  2265. +   public void setSiteName(String siteName)
  2266. +   {
  2267. +       _siteName = siteName;
  2268. +   }
  2269. +  
  2270. +   public void setRewardList(List<Reward> rewards)
  2271. +   {
  2272. +       for (Reward r : rewards)
  2273. +       {
  2274. +           _rewards.add(r);
  2275. +       }
  2276. +   }
  2277. +  
  2278. +   public String getTimeZone()
  2279. +   {
  2280. +       return _timeZone;
  2281. +   }
  2282. +  
  2283. +   public long getNextVoteTime()
  2284. +   {
  2285. +       return TimeUnit.HOURS.toMillis(_nextVoteTime);
  2286. +   }
  2287. +  
  2288. +   public int getSiteOrdinal()
  2289. +   {
  2290. +       return _siteOrdinal;
  2291. +   }
  2292. +  
  2293. +   public String getSiteName()
  2294. +   {
  2295. +       return _siteName;
  2296. +   }
  2297. +  
  2298. +   public List<Reward> getRewardList()
  2299. +   {
  2300. +       return _rewards;
  2301. +   }
  2302. +  
  2303. +}
  2304. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/globalVote.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/globalVote.java
  2305. new file mode 100644
  2306. index 0000000..6ed7b6b
  2307. --- /dev/null
  2308. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/globalVote.java
  2309. @@ -0,0 +1,53 @@
  2310. +package org.l2jmobius.gameserver.votesystem.Model;
  2311. +
  2312. +/**
  2313. + * @author l2.topgameserver.net
  2314. + */
  2315. +public class globalVote
  2316. +{
  2317. +   private int _voteSite;
  2318. +   private int _votesLastReward;
  2319. +   private int _currentVotes;
  2320. +  
  2321. +   public globalVote()
  2322. +   {
  2323. +      
  2324. +   }
  2325. +  
  2326. +   public globalVote(int voteSite, int votesLastReward)
  2327. +   {
  2328. +       _voteSite = voteSite;
  2329. +       _votesLastReward = votesLastReward;
  2330. +   }
  2331. +  
  2332. +   public void setVoteSite(int voteSite)
  2333. +   {
  2334. +       _voteSite = voteSite;
  2335. +   }
  2336. +  
  2337. +   public void setVotesLastReward(int votesLastReward)
  2338. +   {
  2339. +       _votesLastReward = votesLastReward;
  2340. +   }
  2341. +  
  2342. +   public void setCurrentVotes(int currentVotes)
  2343. +   {
  2344. +       _currentVotes = currentVotes;
  2345. +   }
  2346. +  
  2347. +   public int getVoyeSite()
  2348. +   {
  2349. +       return _voteSite;
  2350. +   }
  2351. +  
  2352. +   public int getVotesLastReward()
  2353. +   {
  2354. +       return _votesLastReward;
  2355. +   }
  2356. +  
  2357. +   public int getCurrentVotes()
  2358. +   {
  2359. +       return _currentVotes;
  2360. +   }
  2361. +  
  2362. +}
  2363. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVote.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVote.java
  2364. new file mode 100644
  2365. index 0000000..e0d227e
  2366. --- /dev/null
  2367. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVote.java
  2368. @@ -0,0 +1,66 @@
  2369. +package org.l2jmobius.gameserver.votesystem.Model;
  2370. +
  2371. +/**
  2372. + * @author l2.topgameserver.net
  2373. + */
  2374. +public class individualVote
  2375. +{
  2376. +   private String _voterIp;
  2377. +   private long _votingTimeSite;
  2378. +   private int _voteSite;
  2379. +   private boolean _alreadyRewarded;
  2380. +  
  2381. +   public individualVote(String voterIp, long votingTimeSite, int voteSite, boolean alreadyRewarded)
  2382. +   {
  2383. +       _voterIp = voterIp;
  2384. +       _votingTimeSite = votingTimeSite;
  2385. +       _voteSite = voteSite;
  2386. +       _alreadyRewarded = alreadyRewarded;
  2387. +   }
  2388. +  
  2389. +   public individualVote()
  2390. +   {
  2391. +      
  2392. +   }
  2393. +  
  2394. +   public void setVoterIp(String voterIp)
  2395. +   {
  2396. +       _voterIp = voterIp;
  2397. +   }
  2398. +  
  2399. +   public void setVotingTimeSite(long votingTimeSite)
  2400. +   {
  2401. +       _votingTimeSite = votingTimeSite;
  2402. +   }
  2403. +  
  2404. +   public void setVoteSite(int voteSite)
  2405. +   {
  2406. +       _voteSite = voteSite;
  2407. +   }
  2408. +  
  2409. +   public void setAlreadyRewarded(boolean alreadyRewarded)
  2410. +   {
  2411. +       _alreadyRewarded = alreadyRewarded;
  2412. +   }
  2413. +  
  2414. +   public String getVoterIp()
  2415. +   {
  2416. +       return _voterIp;
  2417. +   }
  2418. +  
  2419. +   public long getVotingTimeSite()
  2420. +   {
  2421. +       return _votingTimeSite;
  2422. +   }
  2423. +  
  2424. +   public int getVoteSite()
  2425. +   {
  2426. +       return _voteSite;
  2427. +   }
  2428. +  
  2429. +   public boolean getAlreadyRewarded()
  2430. +   {
  2431. +       return _alreadyRewarded;
  2432. +   }
  2433. +  
  2434. +}
  2435. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVoteResponse.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVoteResponse.java
  2436. new file mode 100644
  2437. index 0000000..6707e1b
  2438. --- /dev/null
  2439. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/Model/individualVoteResponse.java
  2440. @@ -0,0 +1,46 @@
  2441. +package org.l2jmobius.gameserver.votesystem.Model;
  2442. +
  2443. +/**
  2444. + * @author l2.topgameserver.net
  2445. + */
  2446. +public class individualVoteResponse
  2447. +{
  2448. +   private boolean _isVoted;
  2449. +   private long _diffTime;
  2450. +   private long _voteSiteTime;
  2451. +  
  2452. +   public individualVoteResponse()
  2453. +   {
  2454. +      
  2455. +   }
  2456. +  
  2457. +   public void setIsVoted(boolean isVoted)
  2458. +   {
  2459. +       _isVoted = isVoted;
  2460. +   }
  2461. +  
  2462. +   public void setDiffTime(long diffTime)
  2463. +   {
  2464. +       _diffTime = diffTime;
  2465. +   }
  2466. +  
  2467. +   public void setVoteSiteTime(long voteSiteTime)
  2468. +   {
  2469. +       _voteSiteTime = voteSiteTime;
  2470. +   }
  2471. +  
  2472. +   public boolean getIsVoted()
  2473. +   {
  2474. +       return _isVoted;
  2475. +   }
  2476. +  
  2477. +   public long getDiffTime()
  2478. +   {
  2479. +       return _diffTime;
  2480. +   }
  2481. +  
  2482. +   public long getVoteSiteTime()
  2483. +   {
  2484. +       return _voteSiteTime;
  2485. +   }
  2486. +}
  2487. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/ReadJson.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/ReadJson.java
  2488. new file mode 100644
  2489. index 0000000..0196c2a
  2490. --- /dev/null
  2491. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/ReadJson.java
  2492. @@ -0,0 +1,126 @@
  2493. +/*
  2494. + * This file is part of the L2J Mobius project.
  2495. + *
  2496. + * This program is free software: you can redistribute it and/or modify
  2497. + * it under the terms of the GNU General Public License as published by
  2498. + * the Free Software Foundation, either version 3 of the License, or
  2499. + * (at your option) any later version.
  2500. + *
  2501. + * This program is distributed in the hope that it will be useful,
  2502. + * but WITHOUT ANY WARRANTY; without even the implied warranty of
  2503. + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  2504. + * General Public License for more details.
  2505. + *
  2506. + * You should have received a copy of the GNU General Public License
  2507. + * along with this program. If not, see <http://www.gnu.org/licenses/>.
  2508. + */
  2509. +package org.l2jmobius.gameserver.votesystem.VoteUtil;
  2510. +
  2511. +import java.io.FileNotFoundException;
  2512. +import java.io.FileReader;
  2513. +import java.io.IOException;
  2514. +import java.util.Collection;
  2515. +import java.util.HashMap;
  2516. +import java.util.Map;
  2517. +import java.util.concurrent.TimeUnit;
  2518. +import java.util.logging.Logger;
  2519. +
  2520. +import org.json.simple.JSONArray;
  2521. +import org.json.simple.JSONObject;
  2522. +import org.json.simple.parser.JSONParser;
  2523. +
  2524. +import org.l2jmobius.Config;
  2525. +import org.l2jmobius.gameserver.votesystem.Model.Reward;
  2526. +import org.l2jmobius.gameserver.votesystem.Model.VoteSite;
  2527. +
  2528. +public class ReadJson
  2529. +{
  2530. +   Logger LOGGER = Logger.getLogger(ReadJson.class.getName());
  2531. +   private final static Map<Integer, VoteSite> _voteSites = new HashMap<>();
  2532. +  
  2533. +   public ReadJson()
  2534. +   {
  2535. +       load();
  2536. +   }
  2537. +  
  2538. +   @SuppressWarnings("unchecked")
  2539. +   public void load()
  2540. +   {
  2541. +       JSONParser jsonParser = new JSONParser();
  2542. +      
  2543. +       try (FileReader reader = new FileReader(parseDatapackFile("/data/votesystem.json")))
  2544. +       {
  2545. +           Object obj = jsonParser.parse(reader);
  2546. +          
  2547. +           JSONArray rewardSiteList = (JSONArray) obj;
  2548. +           rewardSiteList.forEach(emp -> parseRewardSites((JSONObject) emp));
  2549. +           LOGGER.info("Loaded " + _voteSites.size() + " reward sites");
  2550. +          
  2551. +       }
  2552. +       catch (FileNotFoundException e)
  2553. +       {
  2554. +           e.printStackTrace();
  2555. +       }
  2556. +       catch (IOException e)
  2557. +       {
  2558. +           e.printStackTrace();
  2559. +       }
  2560. +       catch (Exception e)
  2561. +       {
  2562. +           e.printStackTrace();
  2563. +       }
  2564. +   }
  2565. +  
  2566. +   private void parseRewardSites(JSONObject site)
  2567. +   {
  2568. +       VoteSite votesite = new VoteSite();
  2569. +       JSONObject rewardsite = (JSONObject) site.get("votesite");
  2570. +      
  2571. +       votesite.setSiteOrdinal(Integer.parseInt((String) rewardsite.get("ordinal")));
  2572. +       votesite.setSiteName((String) rewardsite.get("name"));
  2573. +       votesite.setNextVoteTime(Integer.parseInt((String) rewardsite.get("nextvotetime")));
  2574. +       votesite.setTimeZone((String) rewardsite.get("timezone"));
  2575. +      
  2576. +       JSONArray rewardList = (JSONArray) rewardsite.get("rewards");
  2577. +       for (int i = 0; i < rewardList.size(); i++)
  2578. +       {
  2579. +           JSONObject object = (JSONObject) rewardList.get(i);
  2580. +           votesite.getRewardList().add(new Reward(Integer.parseInt((String) object.get("item_id")), Integer.parseInt((String) object.get("item_count"))));
  2581. +          
  2582. +       }
  2583. +      
  2584. +       _voteSites.put(votesite.getSiteOrdinal(), votesite);
  2585. +   }
  2586. +  
  2587. +   private String parseDatapackFile(String path)
  2588. +   {
  2589. +       String p = Config.DATAPACK_ROOT + path;
  2590. +       return p;
  2591. +   }
  2592. +  
  2593. +   public VoteSite getRecordSite(int ordinal)
  2594. +   {
  2595. +       return _voteSites.get(ordinal);
  2596. +   }
  2597. +  
  2598. +   public long getNextVoteTime(int ordinal)
  2599. +   {
  2600. +       return TimeUnit.HOURS.toMillis(_voteSites.get(ordinal).getNextVoteTime());
  2601. +   }
  2602. +  
  2603. +   public Collection<Reward> getRewards(int ordinal)
  2604. +   {
  2605. +       return _voteSites.get(ordinal).getRewardList();
  2606. +   }
  2607. +  
  2608. +   public static final ReadJson getInstance()
  2609. +   {
  2610. +       return SingletonHolder.INSTANCE;
  2611. +   }
  2612. +  
  2613. +   private static final class SingletonHolder
  2614. +   {
  2615. +       protected static final ReadJson INSTANCE = new ReadJson();
  2616. +   }
  2617. +  
  2618. +}
  2619. diff --git a/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/VoteUtil.java b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/VoteUtil.java
  2620. new file mode 100644
  2621. index 0000000..8feba1f
  2622. --- /dev/null
  2623. +++ b/L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/votesystem/VoteUtil/VoteUtil.java
  2624. @@ -0,0 +1,130 @@
  2625. +package org.l2jmobius.gameserver.votesystem.VoteUtil;
  2626. +
  2627. +import java.io.BufferedReader;
  2628. +import java.io.InputStreamReader;
  2629. +import java.net.HttpURLConnection;
  2630. +import java.net.URL;
  2631. +import java.text.ParseException;
  2632. +import java.text.SimpleDateFormat;
  2633. +import java.time.ZoneId;
  2634. +import java.time.ZonedDateTime;
  2635. +import java.time.format.DateTimeFormatter;
  2636. +import java.util.Date;
  2637. +import java.util.TimeZone;
  2638. +import java.util.logging.Logger;
  2639. +
  2640. +/**
  2641. + * @author l2.topgameserver.net
  2642. + */
  2643. +public final class VoteUtil
  2644. +{
  2645. +   public static final Logger LOGGER = Logger.getLogger(VoteUtil.class.getName());
  2646. +  
  2647. +   public static final long getTimeZoneVotingSite(int ordinalSite)
  2648. +   {
  2649. +       try
  2650. +       {
  2651. +           String id = TimeZone.getDefault().getID();
  2652. +           String myDate = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(ZonedDateTime.now(ZoneId.of(ReadJson.getInstance().getRecordSite(ordinalSite).getTimeZone()))).toString();
  2653. +           SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  2654. +           Date date = sdf.parse(myDate);
  2655. +           String myDate2 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(ZonedDateTime.now(ZoneId.of(id))).toString();
  2656. +           SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  2657. +           Date date2 = sdf2.parse(myDate2);
  2658. +           return (date2.getTime() - date.getTime());
  2659. +          
  2660. +       }
  2661. +       catch (ParseException pe)
  2662. +       {
  2663. +           pe.printStackTrace();
  2664. +           return 0L;
  2665. +       }
  2666. +      
  2667. +   }
  2668. +  
  2669. +   public static final String Sites[] =
  2670. +   {
  2671. +       "L2.TopGameServer.net",
  2672. +       "ITopZ.com",
  2673. +       "L2Top.co",
  2674. +       "L2Votes.com",
  2675. +       "L2.Hopzone.net",
  2676. +       "L2Network.eu",
  2677. +       "L2TopServers.com",
  2678. +       "top.l2jbrasil.com",
  2679. +       "MMOTOP.eu",
  2680. +       "L2Topzone.com",
  2681. +       "L2Servers.com",
  2682. +       "GolbalVotes"
  2683. +   };
  2684. +  
  2685. +   public static final String getResponse(String Url, int ordinal)
  2686. +   {
  2687. +      
  2688. +       try
  2689. +       {
  2690. +           int responseCode = 0;
  2691. +           URL objUrl = new URL(Url);
  2692. +           HttpURLConnection con = (HttpURLConnection) objUrl.openConnection();
  2693. +           con.setRequestMethod("GET");
  2694. +           con.setRequestProperty("User-Agent", "Mozilla/5.0");
  2695. +           con.setConnectTimeout(5000);
  2696. +           responseCode = con.getResponseCode();
  2697. +           if (responseCode == HttpURLConnection.HTTP_OK)
  2698. +           {
  2699. +              
  2700. +               String inputLine;
  2701. +               StringBuffer response = new StringBuffer();
  2702. +               BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
  2703. +               while ((inputLine = in.readLine()) != null)
  2704. +               {
  2705. +                   if (ordinal == 3)
  2706. +                   {
  2707. +                       if (inputLine.contains("Votes:"))
  2708. +                       {
  2709. +                           response.append(inputLine);
  2710. +                           break;
  2711. +                       }
  2712. +                   }
  2713. +                   if (ordinal == 7)
  2714. +                   {
  2715. +                       if (inputLine.contains("<b>Entradas "))
  2716. +                       {
  2717. +                           response.append(inputLine);
  2718. +                           break;
  2719. +                       }
  2720. +                   }
  2721. +               }
  2722. +               in.close();
  2723. +               return response.toString();
  2724. +           }
  2725. +          
  2726. +       }
  2727. +       catch (Exception e)
  2728. +       {
  2729. +           LOGGER.warning(VoteUtil.Sites[ordinal] + " Say: An error ocurred " + e.getStackTrace());
  2730. +           return "";
  2731. +       }
  2732. +      
  2733. +       return "";
  2734. +   }
  2735. +  
  2736. +   public static final String between(String p1, String str, String p2)
  2737. +   {
  2738. +       String returnValue = "";
  2739. +       int i1 = str.indexOf(p1);
  2740. +       int i2 = str.indexOf(p2);
  2741. +       if ((i1 != -1) && (i2 != -1))
  2742. +       {
  2743. +           i1 = i1 + p1.length();
  2744. +           returnValue = str.substring(i1, i2);
  2745. +       }
  2746. +       return returnValue;
  2747. +   }
  2748. +  
  2749. +   public static final boolean isNumeric(String text)
  2750. +   {
  2751. +       return text.matches("[+-]?\\d*(\\.\\d+)?");
  2752. +   }
  2753. +  
  2754. +}
  2755.  
  2756. -- ----------------------------
  2757. -- Table structure for globalvotes
  2758. -- ----------------------------
  2759. DROP TABLE IF EXISTS `globalvotes`;
  2760. CREATE TABLE `globalvotes`  (
  2761.   `voteSite` tinyint(2) NOT NULL,
  2762.   `lastRewardVotes` int(11) NULL DEFAULT NULL,
  2763.   PRIMARY KEY (`voteSite`) USING BTREE
  2764. ) ENGINE = InnoDB CHARACTER SET = latin1 COLLATE = latin1_swedish_ci ROW_FORMAT = Dynamic;
  2765.  
  2766. -- ----------------------------
  2767. -- Records of globalvotes
  2768. -- ----------------------------
  2769. INSERT INTO `globalvotes` VALUES (0, 13);
  2770. INSERT INTO `globalvotes` VALUES (1, 68);
  2771. INSERT INTO `globalvotes` VALUES (2, 0);
  2772. INSERT INTO `globalvotes` VALUES (3, 3);
  2773. INSERT INTO `globalvotes` VALUES (4, 2);
  2774. INSERT INTO `globalvotes` VALUES (5, 0);
  2775. INSERT INTO `globalvotes` VALUES (6, 0);
  2776. INSERT INTO `globalvotes` VALUES (7, 2);
  2777. INSERT INTO `globalvotes` VALUES (8, 3);
  2778. INSERT INTO `globalvotes` VALUES (9, 0);
  2779. INSERT INTO `globalvotes` VALUES (10, 75);
  2780.  
  2781. -- ----------------------------
  2782. -- Table structure for individualvotes
  2783. -- ----------------------------
  2784. DROP TABLE IF EXISTS `individualvotes`;
  2785. CREATE TABLE `individualvotes`  (
  2786.   `voterIp` varchar(40) CHARACTER SET latin1 COLLATE latin1_swedish_ci NOT NULL,
  2787.   `voteSite` tinyint(3) NOT NULL,
  2788.   `votingTimeSite` bigint(20) NULL DEFAULT NULL,
  2789.   `alreadyRewarded` tinyint(3) NULL DEFAULT NULL,
  2790.   PRIMARY KEY (`voterIp`, `voteSite`) USING BTREE
  2791. ) ENGINE = InnoDB CHARACTER SET = latin1 COLLATE = latin1_swedish_ci ROW_FORMAT = Dynamic;
  2792.  
  2793. -- ----------------------------
  2794. -- Records of npc
  2795. -- ----------------------------
  2796. INSERT INTO `l2jmobiusc6`.`npc`(`id`, `idTemplate`, `name`, `serverSideName`, `title`, `serverSideTitle`, `class`, `collision_radius`, `collision_height`, `level`, `sex`, `type`, `attackrange`, `hp`, `mp`, `hpreg`, `mpreg`, `str`, `con`, `dex`, `int`, `wit`, `men`, `exp`, `sp`, `patk`, `pdef`, `matk`, `mdef`, `atkspd`, `aggro`, `matkspd`, `rhand`, `lhand`, `armor`, `walkspd`, `runspd`, `faction_id`, `faction_range`, `isUndead`, `absorb_level`, `absorb_type`) VALUES (75014, 35587, 'Kaaya', 1, 'Vote Reward System', 0, 'NPC.a_traderC_Fhuman', 8.00, 21.00, 70, 'female', 'NpcVoteReward', 40, 3862, 1493, 11.85, 2.78, 40, 43, 30, 21, 20, 10, 0, 0, 1314, 470, 780, 382, 278, 0, 333, 0, 0, 0, 88, 132, NULL, 0, 0, 0, 'LAST_HIT');
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!