package ru.catssoftware.gameserver.model.olympiad;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.logging.Logger;
import javolution.text.TextBuilder;
import javolution.util.FastMap;
import javolution.util.FastMap.Entry;
import javolution.util.FastTable;
import ru.catssoftware.L2DatabaseFactory;
import ru.catssoftware.gameserver.datatables.Close;
import ru.catssoftware.gameserver.datatables.CustomServerData;
import ru.catssoftware.gameserver.model.actor.instance.L2PcInstance;
import ru.catssoftware.gameserver.model.entity.Hero;
import ru.catssoftware.gameserver.network.serverpackets.NpcHtmlMessage;
public class OlympiadDiary
{
private static Logger _log = Logger.getLogger(OlympiadDiary.class.getName());
private static FastMap<Integer, ClassInfo> _diaries = new FastMap();
private static SimpleDateFormat datef = new SimpleDateFormat("'Год:' yyyy 'Месяц:' M 'День:' d 'Время:' H:m");
public static void open()
{
_diaries.clear();
}
public static void clear()
{
FastMap.Entry e = _diaries.head(); for (FastMap.Entry end = _diaries.tail(); (e = e.getNext()) != end; )
{
Integer key = (Integer)e.getKey();
ClassInfo value = (ClassInfo)e.getValue();
if ((key != null) && (value != null))
{
value = null;
}
}
}
public static void close() {
_log.info("Hero System: Loaded " + _diaries.size() + " Diaries.");
}
public static void write(int charId)
{
String charName = CustomServerData.getInstance().getCharName(charId);
if (charName.equalsIgnoreCase("n?f")) {
return;
}
ClassInfo info = new ClassInfo(charId, charName);
Connection con = null;
PreparedStatement st = null;
ResultSet rs = null;
try
{
int classId = -1;
con = L2DatabaseFactory.getInstance().getConnection();
con.setTransactionIsolation(1);
st = con.prepareStatement("SELECT class_id, char_id, page, records FROM olympiad_diaries WHERE char_id = ?");
st.setInt(1, charId);
rs = st.executeQuery();
rs.setFetchSize(50);
FastTable recs = new FastTable();
FastMap recPages = new FastMap();
while (rs.next())
{
recs.clear();
recPages.clear();
classId = rs.getInt("class_id");
int page = rs.getInt("page");
String records = rs.getString("records");
String[] frecs = records.split(";");
for (String rec : frecs)
{
if (!rec.equals(""))
{
String[] recrd = rec.split(",");
String date = recrd[0];
String action = recrd[1];
if ((date != null) && (action != null))
{
recs.add(new Record(date, action));
}
}
}
recPages.put(Integer.valueOf(page), recs);
info.putRecords(recPages);
}
if (classId != -1)
_diaries.put(Integer.valueOf(classId), info);
}
catch (SQLException e)
{
_log.warning("OlympiadDiary: Could not load olympiad_diaries table.");
e.getMessage();
}
finally
{
Close.CSR(con, st, rs);
}
}
public static void addRecord(L2PcInstance player, String rec)
{
if (!Hero.getInstance().isHero(player.getObjectId())) {
return;
}
ClassInfo info = (ClassInfo)_diaries.get(Integer.valueOf(player.getClassId().getId()));
if (info != null)
{
int freePage = 0;
int leader = info.leader;
if (player.getObjectId() != leader) {
return;
}
if (!info.name.equalsIgnoreCase(player.getName())) {
info.name = player.getName();
}
FastTable records = null;
FastMap pages = info.pages;
if (pages.size() > 1)
{
freePage = pages.size() - 1;
records = (FastTable)pages.get(Integer.valueOf(freePage));
}
else {
records = (FastTable)pages.get(Integer.valueOf(0));
}
if (records.size() > 15)
{
freePage++;
records = new FastTable();
}
records.add(new Record(datef.format(new Date()).toString(), rec));
info.updateRecords(freePage, records);
TextBuilder tb = new TextBuilder();
int i = 0; for (int n = records.size(); i < n; i++)
{
Record rc = (Record)records.get(i);
tb.append(rc.date + "," + rc.action + ";");
}
rec = tb.toString();
updateDatabase(player.getClassId().getId(), leader, freePage, rec);
tb.clear();
tb = null;
}
else {
putNewHero(rec, player, 0);
}
}
private static void putNewHero(String rec, L2PcInstance player, int page) {
FastTable nRecs = new FastTable();
FastMap nRecPages = new FastMap();
Date date = new Date();
Record rc = new Record(datef.format(date).toString(), rec);
rec = rc.date + "," + rc.action + ";";
nRecs.add(rc);
nRecPages.put(Integer.valueOf(page), nRecs);
ClassInfo info = new ClassInfo(player.getObjectId(), player.getName());
info.putRecords(nRecPages);
_diaries.put(Integer.valueOf(player.getClassId().getId()), info);
updateDatabase(player.getClassId().getId(), player.getObjectId(), 0, rec);
}
private static void updateDatabase(int classId, int charId, int page, String record)
{
System.out.println("UPDATE DATABSE DIARES");
Connection con = null;
PreparedStatement st = null;
try
{
con = L2DatabaseFactory.getInstance().getConnection();
st = con.prepareStatement("REPLACE INTO `olympiad_diaries` (`class_id`, `char_id`, `page`, `records`) VALUES (?,?,?,?)");
st.setInt(1, classId);
st.setInt(2, charId);
st.setInt(3, page);
st.setString(4, record);
st.execute();
}
catch (SQLException e)
{
_log.warning("OlyDiary: updateDatabase() error: " + e);
}
finally
{
Close.CS(con, st);
}
}
public static void show(L2PcInstance player, String query)
{
int classId = 0;
int page = 0;
try
{
System.out.println("SHOW!!!!!!!!!!!!!!");
String[] cmd = query.split("&");
classId = Integer.parseInt(cmd[0]);
page = Integer.parseInt(cmd[1].substring(5));
page--;
}
catch (Exception e)
{
return;
}
ClassInfo info = (ClassInfo)_diaries.get(Integer.valueOf(player.getClassId().getId()));
if (info != null)
{
System.out.println("NPCHTMLMESSAGE SHOW!!!");
NpcHtmlMessage reply = new NpcHtmlMessage(1);
player.sendMessage("Дневник");
TextBuilder replyMSG = new TextBuilder("<html><body>");
FastTable records = info.getPage(page);
if ((records == null) || (records.isEmpty())) {
return;
}
if (!info.name.equalsIgnoreCase(player.getName())) {
info.name = player.getName();
}
System.out.println("SHOW!!!!!!!!!!!!!!2222");
replyMSG.append("<table width=280><tr><td>Дневник героя " + info.name + "<br></td></tr>");
replyMSG.append("</table><br>");
if (info.getPages() > 1)
{
int p = 0; for (int k = info.getPages(); p < k; p++)
{
if (p == page)
replyMSG.append(" " + p + " ");
else
replyMSG.append(" <a action=\"bypass -h _diary?class=" + classId + "&page= " + p + "\">").append(p).append("</a> ");
}
}
replyMSG.append("</body></html>");
reply.setHtml(replyMSG.toString());
player.sendPacket(reply);
_log.warning("warning show");
}
}
private static class Record
{
public String date;
public String action;
public Record(String date, String action)
{
this.date = date;
this.action = action;
}
}
private static class ClassInfo
{
public int leader;
public String name;
FastMap<Integer, FastTable<OlympiadDiary.Record>> pages = new FastMap();
public ClassInfo(int leader, String name)
{
this.leader = leader;
this.name = name;
}
public void putRecords(FastMap<Integer, FastTable<OlympiadDiary.Record>> pages)
{
if ((pages == null) || (pages.isEmpty())) {
return;
}
this.pages.putAll(pages);
}
public void updateRecords(int page, FastTable<OlympiadDiary.Record> records)
{
if (records.isEmpty()) {
return;
}
this.pages.put(Integer.valueOf(page), records);
}
public FastTable<OlympiadDiary.Record> getPage(int page)
{
return (FastTable)this.pages.get(Integer.valueOf(page));
}
public int getPages()
{
return this.pages.size();
}
}
}
