Vote Read Tool

[Swarlog]

Código [Seleccionar] Expandir

### Eclipse Workspace Patch 1.0
#P L2J_Server_BETA
Index: java/com/l2jserver/gameserver/voteEngine/VoteRead.java
===================================================================
--- java/com/l2jserver/gameserver/voteEngine/VoteRead.java (revision 0)
+++ java/com/l2jserver/gameserver/voteEngine/VoteRead.java (working copy)
@@ -0,0 +1,67 @@
+package com.l2jserver.gameserver.voteEngine;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.URL;
+import java.util.logging.Logger;
+
+/**
+ * @author Reunion Team
+ * @author www.l2reunion.eu
+ */
+public class VoteRead
+{
+ private static final Logger _log = Logger.getLogger(VoteRead.class.getName());
+ // Enter your http://l2network.eu/ server id
+ // Example:
+ // If your server link is http://l2network.eu/?a=details&u=Anius then your id is Anius
+ private static String L2NetworkServerId = "Anius";
+
+ public static long checkVotedIP(String IP)
+ {
+ long voteDate = 0;
+ if (checkIfVoted("Network", IP))
+ {
+ voteDate = System.currentTimeMillis() / 1000L;
+ }
+ return voteDate;
+ }
+
+ private static boolean checkIfVoted(String Topsite, String IP)
+ {
+ String WordToCheck = "";
+ boolean voted = false;
+ URL url = null;
+ InputStreamReader isr = null;
+ try
+ {
+ switch (Topsite)
+ {
+ case "Network":
+ url = new URL("http://l2network.eu/index.php?a=in&u=" + L2NetworkServerId + "&ipc=" + IP);
+ WordToCheck = "0"; // This is the word that API returns if you haven't voted for Network
+ break;
+ }
+
+ if (url != null)
+ {
+ isr = new InputStreamReader(url.openStream());
+ BufferedReader br = new BufferedReader(isr);
+ String strLine;
+ while ((strLine = br.readLine()) != null) // Read File Line By Line
+ {
+ if (!strLine.equals(WordToCheck))
+ {
+ voted = true;
+ }
+ }
+ isr.close(); // Close the input stream
+ }
+ }
+ catch (Exception e) // Catch exception if any
+ {
+ _log.warning("VoteRead: ERROR: " + e);
+ }
+ return voted;
+ }
+}
\ No newline at end of file
Index: java/com/l2jserver/gameserver/voteEngine/RewardVote.java
===================================================================
--- java/com/l2jserver/gameserver/voteEngine/RewardVote.java (revision 0)
+++ java/com/l2jserver/gameserver/voteEngine/RewardVote.java (working copy)
@@ -0,0 +1,274 @@
+package com.l2jserver.gameserver.voteEngine;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.logging.Logger;
+
+import com.l2jserver.L2DatabaseFactory;
+import com.l2jserver.gameserver.ThreadPoolManager;
+import com.l2jserver.gameserver.handler.IVoicedCommandHandler;
+import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
+
+/**
+ * @author Reunion Team
+ * @author www.l2reunion.eu
+ */
+public class RewardVote implements IVoicedCommandHandler
+{
+ private static enum ValueType
+ {
+ ACCOUNT_NAME,
+ IP_ADRESS,
+ HWID
+ }
+
+ private static final Logger _log = Logger.getLogger(RewardVote.class.getName());
+
+ private static final String[] COMMANDS_LIST = new String[]
+ {
+ "getreward"
+ };
+
+ private static int WAIT_TIME = 5;
+ private static int MIN_LEVEL_TO_ALLOW_VOTE = 40;
+ private static final long INTERVAL = WAIT_TIME * 60 * 1000; // in minutes.
+ private static int rewardId = 57;
+ private static int rewardAmount = 1000;
+
+ public List<L2PcInstance> _safePeople = new ArrayList<>();
+
+ @Override
+ public boolean useVoicedCommand(String command, L2PcInstance activeChar, String params)
+ {
+ if (command.equalsIgnoreCase("getreward"))
+ {
+ if (_safePeople.contains(activeChar))
+ {
+ activeChar.sendMessage("You can use this command only once at " + WAIT_TIME + " minutes.");
+ return false;
+ }
+
+ _safePeople.add(activeChar);
+ ThreadPoolManager.getInstance().scheduleGeneral(new PopSafePlayer(activeChar), INTERVAL);
+
+ // getting IP of client, here we will have to check for HWID when we have LAMEGUARD
+ String IPClient = activeChar.getClient().getConnectionAddress().getHostAddress();
+ // String IPIntern= activeChar.getClient().getConnectionAddress().get
+ // sending IP to client for debug purpose
+ // ??
+ // Return 0 if he didnt voted. Date when he voted on website
+ long dateHeVotedOnWebsite = VoteRead.checkVotedIP(IPClient);
+ if (dateHeVotedOnWebsite > 0)
+ {
+ if (activeChar.getLevel() < MIN_LEVEL_TO_ALLOW_VOTE)
+ {
+ activeChar.sendMessage("You need to be at least " + String.valueOf(MIN_LEVEL_TO_ALLOW_VOTE) + " level in order to use this command.");
+ return false;
+ }
+
+ String uniqueID = "";
+ // uniqueID = activeChar.getClient().getHWID();
+ // if (uniqueID == null)
+ // {
+ // uniqueID = "";
+ // }
+
+ // Calculate if he can take reward
+ if (canTakeReward(dateHeVotedOnWebsite, IPClient, activeChar, uniqueID))
+ {
+ _log.info(activeChar.getName() + " got rewarded");
+ insertInDataBase(dateHeVotedOnWebsite, IPClient, activeChar, uniqueID);
+
+ activeChar.getInventory().addItem("VoteReward", rewardId, rewardAmount, activeChar, true);
+ activeChar.sendMessage("Successfully rewarded.");
+ }
+ }
+ else
+ // He didnt voted.
+ {
+ activeChar.sendMessage("You didnt voted. Try again later!");
+ return false;
+ }
+ return true;
+ }
+ return false;
+ }
+
+ /**
+ * @param dateHeVotedOnWebsite
+ * @param IPClient
+ * @param activeChar
+ * @param HwID
+ **/
+ private static void insertInDataBase(long dateHeVotedOnWebsite, String IPClient, L2PcInstance activeChar, String HwID)
+ {
+ insertInDataBase(dateHeVotedOnWebsite, activeChar.getAccountName(), ValueType.ACCOUNT_NAME);
+ insertInDataBase(dateHeVotedOnWebsite, IPClient, ValueType.IP_ADRESS);
+ // insertInDataBase(dateHeVotedOnWebsite, HwID, ValueType.HWID);
+ }
+
+ private static void insertInDataBase(long dateHeVotedOnWebsite, String value, ValueType type)
+ {
+ Connection con = null;
+ PreparedStatement statement = null;
+ ResultSet rset = null;
+ try
+ {
+ con = L2DatabaseFactory.getInstance().getConnection();
+ statement = con.prepareStatement("SELECT * FROM votes WHERE value=? AND value_type=?");
+ statement.setString(1, value);
+ statement.setInt(2, type.ordinal());
+ rset = statement.executeQuery();
+
+ if (rset.next()) // He already exit in database because he voted before.
+ {
+ int count = rset.getInt("vote_count");
+ PreparedStatement statement2 = null;
+ try
+ {
+ statement2 = con.prepareStatement("UPDATE votes SET date_voted_website=?, date_take_reward_in_game=?, vote_count=? WHERE value=? AND value_type=?");
+ statement2.setLong(1, dateHeVotedOnWebsite);
+ statement2.setLong(2, (System.currentTimeMillis() / 1000L));
+ statement2.setInt(3, (count + 1));
+ statement2.setString(4, value);
+ statement2.setInt(5, type.ordinal());
+ statement2.executeUpdate();
+ }
+ catch (SQLException e)
+ {
+ _log.warning("RewardVote:insertInDataBase(long,String,ValueType): " + e);
+ }
+ finally
+ {
+ DbUtils.closeQuietly(statement2);
+ }
+ }
+ else
+ {
+ PreparedStatement statement2 = null;
+ try
+ {
+ statement2 = con.prepareStatement("INSERT INTO votes(value, value_type, date_voted_website, date_take_reward_in_game, vote_count) VALUES (?, ?, ?, ?, ?)");
+ statement2.setString(1, value);
+ statement2.setInt(2, type.ordinal());
+ statement2.setLong(3, dateHeVotedOnWebsite);
+ statement2.setLong(4, (System.currentTimeMillis() / 1000L));
+ statement2.setInt(5, 1);
+ statement2.execute();
+ }
+ catch (SQLException e)
+ {
+ _log.warning("RewardVote:insertInDataBase(long,String,ValueType): " + e);
+ }
+ finally
+ {
+ DbUtils.closeQuietly(statement2);
+ }
+ }
+ }
+ catch (SQLException e)
+ {
+ _log.warning("RewardVote:insertInDataBase(long,String,ValueType): " + e);
+ }
+ finally
+ {
+ DbUtils.closeQuietly(con, statement, rset);
+ }
+ }
+
+ private static boolean canTakeReward(long dateHeVotedOnWebsite, String IPClient, L2PcInstance activeChar, String HwID)
+ {
+ int whenCanVote = canTakeReward(dateHeVotedOnWebsite, activeChar.getAccountName(), ValueType.ACCOUNT_NAME);
+ int whenCanVoteIP = canTakeReward(dateHeVotedOnWebsite, IPClient, ValueType.IP_ADRESS);
+ int whenCanVoteHWID = canTakeReward(dateHeVotedOnWebsite, HwID, ValueType.HWID);
+
+ whenCanVote = Math.max(whenCanVote, Math.max(whenCanVoteIP, whenCanVoteHWID));
+
+ if (whenCanVote > 0)
+ {
+ if (whenCanVote > 60)
+ {
+ activeChar.sendMessage("You can vote only once at 12 hours and 5 minutes. You still have to wait " + (whenCanVote / 60) + " hours " + (whenCanVote % 60) + " minutes.");
+ }
+ else
+ {
+ activeChar.sendMessage("You can vote only once at 12 hours and 5 minutes. You still have to wait " + whenCanVote + " minutes.");
+ }
+ return false;
+ }
+ return true;
+ }
+
+ private static int canTakeReward(long dateHeVotedOnWebsite, String value, ValueType type)
+ {
+ int dateLastVote = 0; // Date When he last voted on server
+ int whenCanVote = 0; // The number of minutes when he can vote
+
+ Connection con = null;
+ PreparedStatement statement = null;
+ ResultSet rset = null;
+ try
+ {
+ con = L2DatabaseFactory.getInstance().getConnection();
+ statement = con.prepareStatement("SELECT date_take_reward_in_game FROM votes WHERE value=? AND value_type=?");
+ statement.setString(1, value);
+ statement.setInt(2, type.ordinal());
+ rset = statement.executeQuery();
+
+ if (rset.next())
+ {
+ dateLastVote = rset.getInt("date_take_reward_in_game");
+ }
+ }
+ catch (SQLException e)
+ {
+ _log.warning("RewardVote:canTakeReward(long,String,String): " + e);
+ }
+ finally
+ {
+ DbUtils.closeQuietly(con, statement, rset);
+ }
+
+ // The number of minutes when he can vote
+ if (dateLastVote == 0)
+ {
+ whenCanVote = (int) ((dateHeVotedOnWebsite - (System.currentTimeMillis() / 1000L)) / 60);
+ }
+ else
+ {
+ whenCanVote = (int) (((dateLastVote + (12 * 60 * 60) + 300) - (System.currentTimeMillis() / 1000L)) / 60);
+ }
+
+ return whenCanVote;
+ }
+
+ // this is the class to remove safe players to be reported again after the given time
+ private class PopSafePlayer implements Runnable
+ {
+ private final L2PcInstance _safeplayer;
+
+ public PopSafePlayer(L2PcInstance safeplayer)
+ {
+ _safeplayer = safeplayer;
+ }
+
+ @Override
+ public void run()
+ {
+ if (_safePeople.contains(_safeplayer))
+ {
+ _safePeople.remove(_safeplayer);
+ }
+ }
+ }
+
+ @Override
+ public String[] getVoicedCommandList()
+ {
+ return COMMANDS_LIST;
+ }
+}
\ No newline at end of file
Index: java/com/l2jserver/gameserver/handler/VoicedCommandHandler.java
===================================================================
--- java/com/l2jserver/gameserver/handler/VoicedCommandHandler.java (revision 6670)
+++ java/com/l2jserver/gameserver/handler/VoicedCommandHandler.java (working copy)
@@ -21,6 +21,8 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import com.l2jserver.gameserver.voteEngine.RewardVote;
+
 /**
  * @author UnAfraid
  */
@@ -31,6 +33,8 @@
  protected VoicedCommandHandler()
  {
  _datatable = new HashMap<>();
+
+ registerHandler(new RewardVote());
  }
 
  @Override
Index: java/com/l2jserver/gameserver/voteEngine/DbUtils.java
===================================================================
--- java/com/l2jserver/gameserver/voteEngine/DbUtils.java (revision 0)
+++ java/com/l2jserver/gameserver/voteEngine/DbUtils.java (working copy)
@@ -0,0 +1,172 @@
+package com.l2jserver.gameserver.voteEngine;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+/**
+ * @author Reunion Team
+ * @author www.l2reunion.eu
+ */
+public class DbUtils
+{
+ /**
+ * Close a <code>Connection</code>, avoid closing if null.
+ * @param conn Connection to close.
+ * @throws SQLException if a database access error occurs
+ */
+ public static void close(Connection conn) throws SQLException
+ {
+ if (conn != null)
+ {
+ conn.close();
+ }
+ }
+
+ /**
+ * Close a <code>ResultSet</code>, avoid closing if null.
+ * @param rs ResultSet to close.
+ * @throws SQLException if a database access error occurs
+ */
+ public static void close(ResultSet rs) throws SQLException
+ {
+ if (rs != null)
+ {
+ rs.close();
+ }
+ }
+
+ /**
+ * Close a <code>Statement</code>, avoid closing if null.
+ * @param stmt Statement to close.
+ * @throws SQLException if a database access error occurs
+ */
+ public static void close(Statement stmt) throws SQLException
+ {
+ if (stmt != null)
+ {
+ stmt.close();
+ }
+ }
+
+ /**
+ * Close a <code>Statement</code> and <code>ResultSet</code>, avoid closing if null.
+ * @param stmt Statement to close.
+ * @param rs ResultSet to close.
+ * @throws SQLException if a database access error occurs
+ */
+ public static void close(Statement stmt, ResultSet rs) throws SQLException
+ {
+ close(stmt);
+ close(rs);
+ }
+
+ /**
+ * Close a <code>Connection</code>, avoid closing if null and hide any SQLExceptions that occur.
+ * @param conn Connection to close.
+ */
+ public static void closeQuietly(Connection conn)
+ {
+ try
+ {
+ close(conn);
+ }
+ catch (SQLException e)
+ {
+ // quiet
+ }
+ }
+
+ /**
+ * Close a <code>Connection</code> and <code>Statement</code>. Avoid closing if null and hide any SQLExceptions that occur.
+ * @param conn Connection to close.
+ * @param stmt Statement to close.
+ */
+ public static void closeQuietly(Connection conn, Statement stmt)
+ {
+ try
+ {
+ closeQuietly(stmt);
+ }
+ finally
+ {
+ closeQuietly(conn);
+ }
+ }
+
+ /**
+ * Close a <code>Statement</code> and <code>ResultSet</code>. Avoid closing if null and hide any SQLExceptions that occur.
+ * @param stmt Statement to close.
+ * @param rs ResultSet to close.
+ */
+ public static void closeQuietly(Statement stmt, ResultSet rs)
+ {
+ try
+ {
+ closeQuietly(stmt);
+ }
+ finally
+ {
+ closeQuietly(rs);
+ }
+ }
+
+ /**
+ * Close a <code>Connection</code>, <code>Statement</code> and <code>ResultSet</code>. Avoid closing if null and hide any SQLExceptions that occur.
+ * @param conn Connection to close.
+ * @param stmt Statement to close.
+ * @param rs ResultSet to close.
+ */
+ public static void closeQuietly(Connection conn, Statement stmt, ResultSet rs)
+ {
+
+ try
+ {
+ closeQuietly(rs);
+ }
+ finally
+ {
+ try
+ {
+ closeQuietly(stmt);
+ }
+ finally
+ {
+ closeQuietly(conn);
+ }
+ }
+ }
+
+ /**
+ * Close a <code>ResultSet</code>, avoid closing if null and hide any SQLExceptions that occur.
+ * @param rs ResultSet to close.
+ */
+ public static void closeQuietly(ResultSet rs)
+ {
+ try
+ {
+ close(rs);
+ }
+ catch (SQLException e)
+ {
+ // quiet
+ }
+ }
+
+ /**
+ * Close a <code>Statement</code>, avoid closing if null and hide any SQLExceptions that occur.
+ * @param stmt Statement to close.
+ */
+ public static void closeQuietly(Statement stmt)
+ {
+ try
+ {
+ close(stmt);
+ }
+ catch (SQLException e)
+ {
+ // quiet 35214
+ }
+ }
+}