Code Voting Reward(Hopzone,topzone)

[StealthyS4m]

Hello,
I created this vote manager when I needed it for my server.Basically,you have to type /vote go get this html window:

Then by clicking on any of the buttons will give you 60seconds to vote for the server.

/*
 * This program is free software: you can redistribute it and/or modify it under
 * the terms of the GNU General Public License as published by the Free Software
 * Foundation, either version 3 of the License, or (at your option) any later
 * version.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
 * details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program. If not, see <http://www.gnu.org/licenses/>.
 */
package net.sf.l2j.gameserver.handler.usercommandhandlers;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.EnumMap;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

import net.sf.l2j.Config;
import net.sf.l2j.L2DatabaseFactory;
import net.sf.l2j.gameserver.ThreadPoolManager;
import net.sf.l2j.gameserver.handler.IUserCommandHandler;
import net.sf.l2j.gameserver.model.actor.instance.L2PcInstance;
import net.sf.l2j.gameserver.network.serverpackets.NpcHtmlMessage;

/**
 * @author Eimantas
 */
public class VotingReward implements IUserCommandHandler
{
    // Queries
    private static final String DELETE_QUERY = "DELETE FROM mods_voting_reward WHERE time < ?";
    private static final String SELECT_QUERY = "SELECT * FROM mods_voting_reward";
    private static final String INSERT_QUERY = "INSERT INTO mods_voting_reward (data, scope, time, top) VALUES (?, ?, ?, ?)";

    private static final Logger _log = Logger.getLogger(VotingReward.class.getName());

    private static final long VOTING_INTERVAL = TimeUnit.HOURS.toMillis(12);

    private static final Map<UserScope, ScopeContainer> VOTTERS_CACHE = new EnumMap<>(UserScope.class);

    public static long TimeToVote = TimeUnit.SECONDS.toMillis(60);
    static boolean isVotingHopzone = false;
    static boolean isVotingTopzone = false;
    public static String TopzoneURL = Config.TOPZONE_SERVER_LINK;
    public static String HopZoneURL = Config.HOPZONE_SERVER_LINK;
    
    static final int[] COMMANDS =
    {
        115
    };
    
    public VotingReward()
    {
        load();
    }
    
    @Override
    public boolean useUserCommand(int id, L2PcInstance activeChar)
    {
        if (id == COMMANDS[0])
        {
            showVoteHtml(activeChar);
        }
        return false;
    }
    
    @Override
    public int[] getUserCommandList()
    {
        return COMMANDS;
    }
    
    public static void showVoteHtml(L2PcInstance player)
    {
        NpcHtmlMessage html = new NpcHtmlMessage(0);
        html.setFile("data/html/managers/vote.htm");
        player.sendPacket(html);
    }
    
    public static void voteHopzone(L2PcInstance player)
    {
        final L2PcInstance player2 = player;
        showVoteHtml(player2);
        long time = getLastVotedTime(player, "hopzone");
        if (player2.isVoting())
        {
            player2.sendMessage("You are already voting!");
            return;
        }
        if (time > 0)
        {
            sendReEnterMessage(time, player);
            return;
        }
        if (isVotingHopzone)
        {
            player2.sendMessage("Someone is already voting.Please wait!");
            return;
        }
        final int currVotes = getHopzoneCurrentVotes();
        isVotingHopzone = true;

        player2.sendMessage("You have " + TimeToVote / 1000 + " seconds to vote for us on HopZone!");
        player2.setVoting(true);
        ThreadPoolManager.getInstance().scheduleGeneral(new Runnable()
        {
            @Override
            public void run()
            {
                if (getHopzoneCurrentVotes() > currVotes)
                {
                    player2.sendMessage("Thank You for voting!");
                    markAsVotted(player2, "hopzone");
                    giveReward(player2);
                }
                else
                {
                    player2.sendMessage("You did not vote for server!");
                }
                isVotingHopzone = false;
                player2.setVoting(false);
            }
        }, TimeToVote);

    }
    
    public static void voteTopzone(L2PcInstance player)
    {
        final L2PcInstance player2 = player;
        showVoteHtml(player2);
        long time = getLastVotedTime(player, "topzone");
        if (player2.isVoting())
        {
            player2.sendMessage("You are already voting!");
            return;
        }
        if (time > 0)
        {
            sendReEnterMessage(time, player);
            return;
        }
        if (isVotingTopzone)
        {
            player2.sendMessage("Someone is already voting.Please wait!");
            return;
        }
        final int currVotes = getTopzoneCurrentVotes();
        isVotingTopzone = true;
        player2.sendMessage("You have " + TimeToVote / 1000 + " seconds to vote for us on Topzone!");
        player2.setVoting(true);
        ThreadPoolManager.getInstance().scheduleGeneral(new Runnable()
        {
            @Override
            public void run()
            {
                if (getTopzoneCurrentVotes() > currVotes)
                {
                    player2.sendMessage("Thank You for voting!");
                    markAsVotted(player2, "topzone");
                    giveReward(player2);
                }
                else
                {
                    player2.sendMessage("You did not vote for server!");
                }
                isVotingTopzone = false;
                player2.setVoting(false);
            }
        }, TimeToVote);

    }
    
    public static int getHopzoneCurrentVotes()
    {
        InputStreamReader isr = null;
        BufferedReader br = null;
        
        try
        {
            if (!HopZoneURL.endsWith(".html"))
                HopZoneURL += ".html";
            
            URLConnection con = new URL(HopZoneURL).openConnection();
            
            con.addRequestProperty("User-L2Hopzone", "Mozilla/4.76");
            isr = new InputStreamReader(con.getInputStream());
            br = new BufferedReader(isr);
            
            String line;
            while ((line = br.readLine()) != null)
            {
                if (line.contains("no steal make love") || line.contains("no votes here") || line.contains("bang, you don't have votes") || line.contains("la vita e bella"))
                {
                    int votes = Integer.valueOf(line.split(">")[2].replace("</span", ""));
                    return votes;
                }
            }
            
            br.close();
            isr.close();
        }
        catch (Exception e)
        {
            System.out.println(e);
            System.out.println("Error while getting server vote count on HopZone.");
            _log.log(Level.WARNING, "Error while getting server vote count on HopZone!");
        }

        return -1;
    }
    
    public static int getTopzoneCurrentVotes()
    {
        InputStreamReader isr = null;
        BufferedReader br = null;

        try
        {
            URLConnection con = new URL(TopzoneURL).openConnection();
            con.addRequestProperty("User-Agent", "L2TopZone");
            isr = new InputStreamReader(con.getInputStream());
            br = new BufferedReader(isr);

            boolean got = false;

            String line;
            while ((line = br.readLine()) != null)
            {
                if (line.contains("<div class=\"rank\"><div class=\"votes2\">Votes:<br>") && !got)
                {
                    got = true;
                    int votes = Integer.valueOf(line.split("<div class=\"rank\"><div class=\"votes2\">Votes:<br>")[1].replace("</div></div>", ""));
                    return votes;
                }
            }

            br.close();
            isr.close();
        }
        catch (Exception e)
        {
            System.out.println(e);
            System.out.println("Error while getting server vote count on Topzone.");
            _log.log(Level.WARNING, "Error while getting server vote count on Topzone!");
        }

        return -1;
    }
    
    private static final long getLastVotedTime(L2PcInstance activeChar, String top)
    {
        for (Entry<UserScope, ScopeContainer> entry : VOTTERS_CACHE.entrySet())
        {
            final String data = entry.getKey().getData(activeChar);
            final long reuse = entry.getValue().getReuse(data, top);
            if (reuse > 0)
            {
                return reuse;
            }
        }
        return 0;
    }

    private static void sendReEnterMessage(long time, L2PcInstance player)
    {
        if (time > System.currentTimeMillis())
        {
            final long remainingTime = (time - System.currentTimeMillis()) / 1000;
            final int hours = (int) (remainingTime / 3600);
            final int minutes = (int) ((remainingTime % 3600) / 60);
            final int seconds = (int) ((remainingTime % 3600) % 60);

            String msg = "You have received your reward already try again in: " + hours + " hours";
            if (minutes > 0)
            {
                msg += " " + minutes + " minutes";
            }
            if (seconds > 0)
            {
                msg += " " + seconds + " seconds";
            }
            player.sendMessage(msg);
        }
    }

    private static final void load()
    {
        // Initialize the cache
        for (UserScope scope : UserScope.values())
        {
            VOTTERS_CACHE.put(scope, new ScopeContainer());
        }

        // Cleanup old entries and load the data for votters
        try (Connection con = L2DatabaseFactory.getInstance().getConnection(); PreparedStatement ps = con.prepareStatement(DELETE_QUERY); Statement st = con.createStatement())
            {
            ps.setLong(1, System.currentTimeMillis());
            ps.execute();

            // Load the data
            try (ResultSet rset = st.executeQuery(SELECT_QUERY))
            {
                while (rset.next())
                {
                    final String data = rset.getString("data");
                    final UserScope scope = UserScope.findByName(rset.getString("scope"));
                    final Long time = rset.getLong("time");
                    final String top = rset.getString("top");
                    if (scope != null)
                    {
                        VOTTERS_CACHE.get(scope).registerVotter(data, time, top);
                    }
                }
            }
            }
        catch (SQLException e)
        {
            _log.log(Level.WARNING, VotingReward.class.getSimpleName() + ": " + e.getMessage(), e);
        }
    }

    private enum UserScope
    {
        ACCOUNT
        {
            @Override
            public String getData(L2PcInstance player)
            {
                return player.getAccountName();
            }
        },
        IP
        {
            @Override
            public String getData(L2PcInstance player)
            {
                return player.getClient().getConnection().getInetAddress().getHostAddress();
            }
        },
        //@formatter:off
        /*HWID
        {
            @Override
            public String getData(L2PcInstance player)
            {
                return player.getHWID();
            }
        }*/
        //@formatter:on
        ;

        public abstract String getData(L2PcInstance player);

        public static UserScope findByName(String name)
        {
            for (UserScope scope : values())
            {
                if (scope.name().equals(name))
                {
                    return scope;
                }
            }
            return null;
        }
    }

    private static class ScopeContainer
    {
        private final Map<String, Long> _HopzoneVotters = new ConcurrentHashMap<>();
        private final Map<String, Long> _TopzoneVotters = new ConcurrentHashMap<>();

        public ScopeContainer()
        {
        }

        public void registerVotter(String data, long reuse, String top)
        {
            if (top.equalsIgnoreCase("hopzone"))
            {
                _HopzoneVotters.put(data, reuse);
            }
            if (top.equalsIgnoreCase("topzone"))
            {
                _TopzoneVotters.put(data, reuse);
            }
        }

        public long getReuse(String data, String top)
        {
            if (top.equalsIgnoreCase("hopzone"))
            {
                if (_HopzoneVotters.containsKey(data))
                {
                    long time = _HopzoneVotters.get(data);
                    if (time > System.currentTimeMillis())
                    {
                        return time;
                    }
                }
            }
            if (top.equalsIgnoreCase("topzone"))
            {
                if (_TopzoneVotters.containsKey(data))
                {
                    long time = _TopzoneVotters.get(data);
                    if (time > System.currentTimeMillis())
                    {
                        return time;
                    }
                }
            }
            return 0;
        }
    }

    static void markAsVotted(L2PcInstance player, String top)
    {
        final long reuse = System.currentTimeMillis() + VOTING_INTERVAL;
        try (Connection con = L2DatabaseFactory.getInstance().getConnection(); PreparedStatement ps = con.prepareStatement(INSERT_QUERY))
            {
            for (UserScope scope : UserScope.values())
            {
                final String data = scope.getData(player);
                final ScopeContainer container = VOTTERS_CACHE.get(scope);
                container.registerVotter(data, reuse, top);

                ps.setString(1, data);
                ps.setString(2, scope.name());
                ps.setLong(3, reuse);
                ps.setString(4, top);
                ps.addBatch();
            }
            ps.executeBatch();
            }
        catch (SQLException e)
        {
            _log.log(Level.WARNING, VotingReward.class.getSimpleName() + ": " + e.getMessage(), e);
        }
    }
    
    static void giveReward(L2PcInstance player)
    {
        player.addItem("Reward", 6673, 1, player, true);
    }
    
}

Add those to net.sf.l2j.Config:

public static String TOPZONE_SERVER_LINK;
public static String HOPZONE_SERVER_LINK;
HOPZONE_SERVER_LINK = votemanager.getProperty("HopzoneServerLink", "http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/");
TOPZONE_SERVER_LINK = votemanager.getProperty("TopzoneServerLink", "http://l2topzone.com/lineage2/server-info/11321/L2Cyrex.html/");

and to net.sf.l2j.gameserver.handler.UserCommandHandler this:

registerUserCommandHandler(new VotingReward());

SQL:
 

DROP TABLE IF EXISTS `mods_voting_reward`;
CREATE TABLE `mods_voting_reward` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `data` varchar(255) NOT NULL,
  `scope` varchar(255) NOT NULL,
  `time` bigint(20) unsigned NOT NULL,
  `top` varchar(255) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=55 DEFAULT CHARSET=utf8;

Changing reward(Last lines of VotingReward):

    static void giveReward(L2PcInstance player)
    {
        player.addItem("Reward", ITEM ID , ITEM COUNT , player, true);
    }

Config(votemanager.properties):
 

HopzoneServerLink = http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/
TopzoneServerLink = http://l2topzone.com/lineage2/server-info/11321/L2Cyrex.html/

This is probably poorly coded,just wanted to share,some pieces are taken from An4rchy vote manager.
Also Client side(commandname-e.dat):

116	115	vote

EDIT:Vote.html
 

<html>
<body>
       <center>
	   <p>Vote Manager:</p>
	   <br><br><br><br><br><br><br><br><br><br><br><br>
	   <button value="Vote for us on HopZone" action="bypass -h vote-hopzone" width=180 height=20 back="YourTexture" fore="YourTexture"/>
	   <img src=L2UI_CH3.herotower_deco width=256 height=32>
	   <button value="Vote for us on Topzone" action="bypass -h vote-topzone" width=180 height=20 back="YourTexture" fore="YourTexture"/>
	   </center>
</body>
</html>

Ofc,you have to change YourTexture to....

L2PcInstance.java
 

        boolean isVoting = false;	
        public boolean isVoting()
	{
		return isVoting;
	}
	
	public void setVoting(boolean voting)
	{
		isVoting = voting;
	}

Good luck!
 

Edited April 5, 2015 by StealthyS4m

['Baggos']

There is many people searching for something like this..

Good job mate..

[StealthyS4m]

Yeah,that's why I shared it.
Also I've took so many things from MxC,wanted to give something. :)
I hope it will be some use. ^_^
 

[te0x]

is it tested that the hopzone link works?

i passed the part that reads the hopzone vote in my individual and still doesn't work..

[StealthyS4m]

Well,I use this code in my server now and it works just fine.
I think it's necessary to add / at the end of the link:
 

http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/

Like there is "/" after l2-cyrex

Edited March 20, 2015 by StealthyS4m

[te0x]

Well,I use this code in my server now and it works just fine.

I think it's necessary to add / at the end of the link:

 

http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/

Like there is "/" after l2-cyrex

if is this the problem i will cry. i will really cry

. still doesnt work xD

Edited March 20, 2015 by te0x

[StealthyS4m]

Are you using my whole code or only some parts of it?

[Klay]

public static void voteHopzone(L2PcInstance player)
    {
        final L2PcInstance player2 = player;
        showVoteHtml(player2);
.
.
.

why not

public static void voteHopzone(final L2PcInstance player)
    {
        showVoteHtml(player);
.
.
.

Edited March 20, 2015 by Klay

[te0x]

Are you using my whole code or only some parts of it?

told ya only the part tha reads the hopzone votes.

but i can't get it why it works as a voice command or in the auto reward with this code and not in the npc!

anyways nice share ;d

[StealthyS4m]

Klay,
Yeah it would work perfectly,just I needed to create final variable,because when calling from inside of ThreadPoolManager you have to call variable of type final.
te0x,
This code is easy to redo for NPC:

        if (actualCommand.startsWith("command"))
        VotingReward.showVoteHtml(activeChar);

This would be a bit of waste if you don't want  /vote command at all,but I think it should work.

Edited March 20, 2015 by StealthyS4m

[.Thug]

te0x i can't belive this, you can't fix hopzone problem on individual manager?

use this , for me working fine :) w/o any problem.

 

protected static int getVotes()
{
InputStreamReader isr = null;
BufferedReader br = null;

try
{
if(!hopzoneUrl.endsWith(".html"))
hopzoneUrl+=".html";

URLConnection con = new URL(hopzoneUrl).openConnection();


con.addRequestProperty("User-L2Hopzone", "Mozilla/4.76");
isr = new InputStreamReader(con.getInputStream());
br = new BufferedReader(isr);

String line;
while ((line = br.readLine()) != null)
{
if (line.contains("no steal make love")||line.contains("no votes here")||line.contains("bang, you don't have votes")|| line.contains("la vita e bella"))
{
int votes = Integer.valueOf(line.split(">")[2].replace("</span", ""));

return votes;
}
}

br.close();
isr.close();
}
catch (Exception e)
{
System.out.println("[VoteRewardManager]: Problem occured while getting Hopzone votes. Error Trace: " + e.getMessage());
}
return -1;
}

[te0x]

 

te0x i can't belive this, you can't fix hopzone problem on individual manager?

use this , for me working fine :) w/o any problem.

protected static int getVotes()
{
InputStreamReader isr = null;
BufferedReader br = null;

try
{
if(!hopzoneUrl.endsWith(".html"))
hopzoneUrl+=".html";

URLConnection con = new URL(hopzoneUrl).openConnection();


con.addRequestProperty("User-L2Hopzone", "Mozilla/4.76");
isr = new InputStreamReader(con.getInputStream());
br = new BufferedReader(isr);

String line;
while ((line = br.readLine()) != null)
{
if (line.contains("no steal make love")||line.contains("no votes here")||line.contains("bang, you don't have votes")|| line.contains("la vita e bella"))
{
int votes = Integer.valueOf(line.split(">")[2].replace("</span", ""));

return votes;
}
}

br.close();
isr.close();
}
catch (Exception e)
{
System.out.println("[VoteRewardManager]: Problem occured while getting Hopzone votes. Error Trace: " + e.getMessage());
}
return -1;
}

i am trying every day this fcking part and it doesnt work for me in the individual vote manager its impossible.

[.Thug]

im using individual vote manager, w/o any problem :P send me  a msg if you want

[Nightw0lf]

its 3 stupid lines

if(!hopzoneUrl.endsWith(".html"))
hopzoneUrl+=".html";

 

and

 

con.addRequestProperty("User-L2Hopzone", "Mozilla/4.76");

 

and how to catch the votes is

if (line.contains("no steal make love")||line.contains("no votes here")||line.contains("bang, you don't have votes")|| line.contains("la vita e bella"))

[StealthyS4m]

Try the difference between:
1) http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/.html
2) http://l2.hopzone.net/lineage2/details/98632/L2-cyrex/