09.03.2011, 20:15
|
#27
|
|
Герой
Регистрация: 03.05.2010
Возраст: 36
Сообщений: 44
Отблагодарили 11 раз(а)
Рейтинг мнений:
|
Re: [Core]Community Board
Цитата:
Сообщение от APKO
мнебы код из com/l2jserver/gameserver/taskmanager/L2TopRuManager.java
|
Вот лови))
Свернуть ↑
Код:
/*
* 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 com.l2jserver.gameserver.taskmanager;
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.Statement;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import javolution.util.FastComparator;
import javolution.util.FastMap;
import javolution.util.FastTable;
import com.l2jserver.ExternalConfig;
import com.l2jserver.L2DatabaseFactory;
import com.l2jserver.gameserver.ThreadPoolManager;
import com.l2jserver.gameserver.datatables.ItemTable;
import com.l2jserver.gameserver.idfactory.IdFactory;
import com.l2jserver.gameserver.model.L2ItemInstance;
import com.l2jserver.gameserver.model.L2World;
import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
import com.l2jserver.gameserver.network.SystemMessageId;
import com.l2jserver.gameserver.network.serverpackets.InventoryUpdate;
import com.l2jserver.gameserver.network.serverpackets.SystemMessage;
public class L2TopRuManager
{
protected static final Logger _log = Logger.getLogger(L2TopRuManager.class.getName());
private Pattern _webPattern;
private Pattern _smsPattern;
private static final DateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
private static L2TopRuManager _instance = null;
private static FastMap<Integer, Long> _voteDateCache = new FastMap<Integer, Long>().shared(); // Кеш: charObjId=>lastVoteDate
private static String USERAGENT = "Mozilla/5.0 (%Platform%; %Version%; %Architecture%; U) %JVM%/%JVMVer%"
.replace("%Platform%", System.getProperty("os.name")).replace("%Version%", System.getProperty("os.version")).replace("%Architecture%", System.getProperty("os.arch"))
.replace("%JVM%", System.getProperty("java.vm.name")).replace("%JVMVer%", System.getProperty("java.vm.version"));
public static L2TopRuManager getInstance()
{
if (_instance == null)
_instance = new L2TopRuManager();
return _instance;
}
private L2TopRuManager()
{
if (ExternalConfig.L2TOPRU_DELAY < 1)
return;
_log.info("L2TopRuManager: Initializing.");
_webPattern = Pattern.compile("^([\\d-]+\\s[\\d:]+)\\s+(?:"+ExternalConfig.L2TOPRU_PREFIX+"-)*([a-zA-Z0-9-]+)$", Pattern.MULTILINE);
_smsPattern = Pattern.compile("^([\\d-]+\\s[\\d:]+)\\s+(?:"+ExternalConfig.L2TOPRU_PREFIX+"-)*([a-zA-Z0-9-]+)\\s+x(\\d{1,2})$", Pattern.MULTILINE);
ThreadPoolManager.getInstance().scheduleGeneralAtFixedRate(new L2TopRuTask(), ExternalConfig.L2TOPRU_DELAY, ExternalConfig.L2TOPRU_DELAY);
}
private class L2TopRuTask implements Runnable
{
@Override
public void run()
{
L2TopRuManager.getInstance().tick();
}
}
private FastTable<L2TopRuVote> filterVotes(FastTable<L2TopRuVote> votes)
{
FastTable<L2TopRuVote> result = new FastTable<L2TopRuVote>();
FastMap<String, Integer> chars = new FastMap<String, Integer>(); // Все персонажи сервера.
Connection con = null;
Statement stmt = null;
ResultSet rset = null;
try
{
con = L2DatabaseFactory.getInstance().getConnection();
stmt = con.createStatement();
rset = stmt.executeQuery("SELECT `charId`,`char_name` FROM `characters`");
while(rset.next())
chars.put(rset.getString("char_name").toLowerCase(), rset.getInt("charId"));
stmt.close();
rset.close();
}
catch (Exception ex)
{
ex.printStackTrace();
}
finally
{
L2DatabaseFactory.close(con);
}
int charObjId = 0;
for (L2TopRuVote vote : votes)
{
if(chars.containsKey(vote.charname)) // Существует ли персонаж?
{
charObjId = chars.get(vote.charname); // Да, берем его objId
if(isRewardReq(charObjId, vote.datetime)) // Нужно-ли награда за этот голос?
{
vote.char_obj_id = charObjId;
result.add(vote);
}
}
}
return result;
}
private boolean isRewardReq(int charObjId, long date)
{
long lastDate = 0;
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rset = null;
if(_voteDateCache.containsKey(charObjId)) // Закеширована ли дата голоса?
{
lastDate = _voteDateCache.get(charObjId); // Да, последяя дата голосования в кеше
if(date > lastDate) // текущая позже даты в кеше?
{
_voteDateCache.put(charObjId, date); // Да, обновим дату в кеше,
try
{
con = L2DatabaseFactory.getInstance().getConnection();
pstmt = con.prepareStatement("REPLACE DELAYED INTO `l2topru_votes`(`obj_Id`,`last_vote`) VALUES (?,?)"); // и , заодно, в бд,
pstmt.setInt(1, charObjId);
pstmt.setLong(2, date);
pstmt.executeUpdate();
pstmt.close();
L2DatabaseFactory.close(con);
}
catch (Exception ex)
{
ex.printStackTrace();
}
return true; // и выдадим награду.
}
}
else // промах, ишем в БД
{
try
{
con = L2DatabaseFactory.getInstance().getConnection();
pstmt = con.prepareStatement("SELECT `obj_Id`,`last_vote` FROM `l2topru_votes` WHERE `obj_Id` = ?");// в бд есть запись об этом чаре?
pstmt.setInt(1, charObjId);
rset = pstmt.executeQuery();
if(rset.next()) // да, есть
{
lastDate = rset.getLong("last_vote");
pstmt.close();
rset.close();
if (date > lastDate) // текущая позже даты в бд?
{
_voteDateCache.put(charObjId, date); // Да, поместим в кеш самую новую дату (текущую)
try
{
pstmt = con.prepareStatement("REPLACE DELAYED INTO `l2topru_votes`(`obj_Id`,`last_vote`) VALUES (?,?)"); // и обновим в бд
pstmt.setInt(1, charObjId);
pstmt.setLong(2, date);
pstmt.executeUpdate();
pstmt.close();
L2DatabaseFactory.close(con);
}
catch (Exception ex)
{
ex.printStackTrace();
}
return true; // бд обновили, даем награду.
}
else // нет
_voteDateCache.put(charObjId, lastDate); // поместим в кеш самую новую дату (из бд)
}
else // хм, записи нет, голосуем 1й раз,
{
pstmt.close();
rset.close();
_voteDateCache.put(charObjId, date); // добавим в кеш,
try
{
pstmt = con.prepareStatement("REPLACE DELAYED INTO `l2topru_votes`(`obj_Id`,`last_vote`) VALUES (?,?)"); // сохраним
pstmt.setInt(1, charObjId);
pstmt.setLong(2, date);
pstmt.executeUpdate();
pstmt.close();
L2DatabaseFactory.close(con);
}
catch (Exception ex)
{
ex.printStackTrace();
}
return true; // и разрешим давать награду.
}
}
catch (Exception ex)
{
ex.printStackTrace();
}
finally
{
L2DatabaseFactory.close(con);
}
}
return false;
}
private void rewardVotes(FastTable<L2TopRuVote> votes)
{
for (L2TopRuVote vote : votes)
{
switch (vote.type)
{
case WEB:
_log.info("L2TopRuManager: Rewarding "+vote.toString());
giveItem(vote.char_obj_id, ExternalConfig.L2TOPRU_WEB_REWARD_ITEMID, ExternalConfig.L2TOPRU_WEB_REWARD_ITEMCOUNT);
break;
case SMS:
_log.info("L2TopRuManager: Rewarding "+vote.toString());
giveItem(vote.char_obj_id, ExternalConfig.L2TOPRU_SMS_REWARD_ITEMID,
(ExternalConfig.L2TOPRU_SMS_REWARD_VOTE_MULTI ? ExternalConfig.L2TOPRU_SMS_REWARD_ITEMCOUNT * vote.count : ExternalConfig.L2TOPRU_SMS_REWARD_ITEMCOUNT));
break;
}
}
}
private void giveItem(int charObjId, int itemId, int itemCount)
{
if (charObjId < 1)
return;
L2PcInstance player = (L2PcInstance)L2World.getInstance().findObject(charObjId);
if (player != null)
{
L2ItemInstance item = player.getInventory().addItem("L2TopVoting", itemId, itemCount, null, null);
InventoryUpdate iu = new InventoryUpdate();
iu.addItem(item);
player.sendPacket(iu);
//final SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.YOU_PICKED_UP_S1_S2);
SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.YOU_PICKED_UP_S1_S2);
sm.addItemName(item);
sm.addNumber(itemCount);
player.sendPacket(sm);
}
else
{
L2ItemInstance newItem = new L2ItemInstance(IdFactory.getInstance().getNextId(), ItemTable.getInstance().getTemplate(itemId));
newItem.setCount(itemCount);
newItem.setOwnerId(charObjId);
newItem.setLocation(L2ItemInstance.ItemLocation.INVENTORY);
newItem.updateDatabase(true);
}
}
private FastTable<L2TopRuVote> getAllVotes()
{
FastTable<L2TopRuVote> result = new FastTable<L2TopRuVote>();
try
{
L2TopRuVote vote;
Matcher m = _webPattern.matcher(getPage(ExternalConfig.L2TOPRU_WEB_VOTE_URL));
while(m.find())
{
vote = new L2TopRuVote(m.group(1), m.group(2));
result.add(vote);
}
m = _smsPattern.matcher(getPage(ExternalConfig.L2TOPRU_SMS_VOTE_URL));
while(m.find())
{
vote = new L2TopRuVote(m.group(1), m.group(2), m.group(3));
result.add(vote);
}
result.setValueComparator(new L2TopRuVoteComparator());
}
catch (Exception ex)
{
ex.printStackTrace();
}
return result.sort();
}
private void tick()
{
_log.info("L2TopRuManager: Rewarding votes.");
rewardVotes(filterVotes(getAllVotes()));
}
private String getPage(String uri) throws Exception
{
URL url = new URL(uri);
URLConnection conn = url.openConnection();
conn.addRequestProperty("Host", url.getHost());
conn.addRequestProperty("Accept", "*/*");
conn.addRequestProperty("Connection", "close");
conn.addRequestProperty("User-Agent", USERAGENT);
conn.setConnectTimeout(30000);
BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "cp1251")); // cp1251 (((
StringBuilder builder = new StringBuilder();
String line = null;
while((line = in.readLine()) != null)
{
builder.append(line).append("\n");
}
return builder.toString();
}
private enum L2TopRuVoteType
{
WEB,
SMS
}
private class L2TopRuVote
{
public long datetime;
public String charname;
public int count;
public int char_obj_id = -1;
public L2TopRuVoteType type;
public L2TopRuVote(String date, String charName, String itemCount) throws Exception
{
datetime = DATE_FORMAT.parse(date).getTime() / 1000;
count = Byte.parseByte(itemCount);
charname = charName.toLowerCase();
type = L2TopRuVoteType.SMS;
}
public L2TopRuVote(String date, String charName) throws Exception
{
datetime = DATE_FORMAT.parse(date).getTime() / 1000;
charname = charName.toLowerCase();
count = 1;
type = L2TopRuVoteType.WEB;
}
@Override
public String toString()
{
return charname + "-" + count + "[" + char_obj_id + "(" + datetime + "|" + type.name() + ")]";
}
}
private final class L2TopRuVoteComparator<T> extends FastComparator<L2TopRuVote>
{
@Override
public int hashCodeOf(L2TopRuVote o)
{
return o.hashCode();
}
@Override
public boolean areEqual(L2TopRuVote o, L2TopRuVote o1)
{
return o.char_obj_id == o1.char_obj_id && o.datetime == o1.datetime;
}
@Override
public int compare(L2TopRuVote o, L2TopRuVote o1)
{
if (o.datetime == o1.datetime)
return 0;
if (o.datetime < o1.datetime)
return Integer.MIN_VALUE;
if (o.datetime > o1.datetime)
return Integer.MAX_VALUE;
return -1;
}
}
}
Свернуть ↑Развернуть ↓
|
|
|
Buffer Teleport Shop
Похожие темы
