package com.aionemu.gameserver.dao;

import java.sql.*;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.aionemu.commons.database.DB;
import com.aionemu.commons.database.DatabaseFactory;
import com.aionemu.commons.database.IUStH;
import com.aionemu.commons.database.ParamReadStH;
import com.aionemu.gameserver.model.gameobjects.Item;
import com.aionemu.gameserver.model.gameobjects.Letter;
import com.aionemu.gameserver.model.gameobjects.LetterType;
import com.aionemu.gameserver.model.gameobjects.Persistable.PersistentState;
import com.aionemu.gameserver.model.gameobjects.player.Mailbox;
import com.aionemu.gameserver.model.gameobjects.player.Player;
import com.aionemu.gameserver.model.gameobjects.player.PlayerCommonData;
import com.aionemu.gameserver.model.items.storage.StorageType;

/**
 * @author kosyachok
 */
public class MailDAO {

	private static final Logger log = LoggerFactory.getLogger(MailDAO.class);

	public static Mailbox loadPlayerMailbox(Player player) {
		Mailbox mailbox = new Mailbox(player);
		Map<Letter, Integer> letters = new HashMap<>();
		List<Item> mailboxItems = null;

		DB.select("SELECT * FROM mail WHERE mail_recipient_id = ?", new ParamReadStH() {

			@Override
			public void setParams(PreparedStatement stmt) throws SQLException {
				stmt.setInt(1, player.getObjectId());
			}

			@Override
			public void handleRead(ResultSet rset) throws SQLException {
				while (rset.next()) {
					int mailUniqueId = rset.getInt("mail_unique_id");
					int recipientId = rset.getInt("mail_recipient_id");
					String senderName = rset.getString("sender_name");
					String mailTitle = rset.getString("mail_title");
					String mailMessage = rset.getString("mail_message");
					boolean unread = rset.getInt("unread") == 1;
					int attachedItemObjId = rset.getInt("attached_item_id");
					long attachedKinahCount = rset.getLong("attached_kinah_count");
					LetterType letterType = LetterType.getLetterTypeById(rset.getInt("express"));
					Timestamp receivedTime = rset.getTimestamp("recieved_time");
					letters.put(
						new Letter(mailUniqueId, recipientId, null, attachedKinahCount, mailTitle, mailMessage, senderName, receivedTime, unread, letterType),
						attachedItemObjId);
				}
			}
		});

		for (Entry<Letter, Integer> e : letters.entrySet()) {
			Letter letter = e.getKey();
			int attachedItemObjId = e.getValue();

			if (attachedItemObjId > 0) {
				if (mailboxItems == null) { // lazy initialization to minimize DB io
					mailboxItems = InventoryDAO.loadItems(player.getObjectId(), StorageType.MAILBOX);
					ItemStoneListDAO.load(mailboxItems);
				}
				for (Item item : mailboxItems)
					if (item.getObjectId() == attachedItemObjId)
						letter.setAttachedItem(item);
			}
			letter.setPersistentState(PersistentState.UPDATED);
			mailbox.putLetterToMailbox(letter);
		}

		return mailbox;
	}

	public static boolean haveUnread(int playerId) {
		try (Connection con = DatabaseFactory.getConnection();
				 PreparedStatement stmt = con.prepareStatement("SELECT * FROM mail WHERE mail_recipient_id = ? ORDER BY recieved_time")) {

			stmt.setInt(1, playerId);
			ResultSet rset = stmt.executeQuery();
			while (rset.next()) {
				int unread = rset.getInt("unread");
				if (unread == 1) {
					return true;
				}
			}
			rset.close();
		} catch (Exception e) {
			log.error("Could not read mail for player: " + playerId + " from DB: " + e.getMessage(), e);
		}
		return false;
	}

	public static void storeMailbox(Player player) {
		Mailbox mailbox = player.getMailbox();
		if (mailbox == null)
			return;
		Collection<Letter> letters = mailbox.getLetters();
		for (Letter letter : letters) {
			storeLetter(letter);
		}
	}

	public static boolean storeLetter(Letter letter) {
		boolean result = false;
		switch (letter.getPersistentState()) {
			case NEW:
				result = saveLetter(letter);
				break;
			case UPDATE_REQUIRED:
				result = updateLetter(letter);
				break;
		}
		letter.setPersistentState(PersistentState.UPDATED);

		return result;
	}

	private static boolean saveLetter(Letter letter) {
		int attachedItemId = 0;
		if (letter.getAttachedItem() != null)
			attachedItemId = letter.getAttachedItem().getObjectId();

		int fAttachedItemId = attachedItemId;

		return DB.insertUpdate(
			"INSERT INTO `mail` (`mail_unique_id`, `mail_recipient_id`, `sender_name`, `mail_title`, `mail_message`, `unread`, `attached_item_id`, `attached_kinah_count`, `express`, `recieved_time`) VALUES(?,?,?,?,?,?,?,?,?,?)",
			new IUStH() {

				@Override
				public void handleInsertUpdate(PreparedStatement stmt) throws SQLException {
					stmt.setInt(1, letter.getObjectId());
					stmt.setInt(2, letter.getRecipientId());
					stmt.setString(3, letter.getSenderName());
					stmt.setString(4, letter.getTitle());
					stmt.setString(5, letter.getMessage());
					stmt.setBoolean(6, letter.isUnread());
					stmt.setInt(7, fAttachedItemId);
					stmt.setLong(8, letter.getAttachedKinah());
					stmt.setInt(9, letter.getLetterType().getId());
					stmt.setTimestamp(10, letter.getTimeStamp());
					stmt.execute();
				}
			});
	}

	private static boolean updateLetter(Letter letter) {
		int attachedItemId = 0;
		if (letter.getAttachedItem() != null)
			attachedItemId = letter.getAttachedItem().getObjectId();

		int fAttachedItemId = attachedItemId;

		return DB.insertUpdate(
			"UPDATE mail SET  unread=?, attached_item_id=?, attached_kinah_count=?, `express`=?, recieved_time=? WHERE mail_unique_id=?", new IUStH() {

				@Override
				public void handleInsertUpdate(PreparedStatement stmt) throws SQLException {
					stmt.setBoolean(1, letter.isUnread());
					stmt.setInt(2, fAttachedItemId);
					stmt.setLong(3, letter.getAttachedKinah());
					stmt.setInt(4, letter.getLetterType().getId());
					stmt.setTimestamp(5, letter.getTimeStamp());
					stmt.setInt(6, letter.getObjectId());
					stmt.execute();
				}
			});
	}

	public static boolean deleteLetter(int letterId) {
		return DB.insertUpdate("DELETE FROM mail WHERE mail_unique_id=?", new IUStH() {

			@Override
			public void handleInsertUpdate(PreparedStatement stmt) throws SQLException {
				stmt.setInt(1, letterId);
				stmt.execute();
			}
		});
	}

	public static void updateOfflineMailCounter(PlayerCommonData recipientCommonData) {
		DB.insertUpdate("UPDATE players SET mailbox_letters=? WHERE name=?", new IUStH() {

			@Override
			public void handleInsertUpdate(PreparedStatement stmt) throws SQLException {
				stmt.setInt(1, recipientCommonData.getMailboxLetters());
				stmt.setString(2, recipientCommonData.getName());
				stmt.execute();
			}
		});
	}

	public static int[] getUsedIDs() {
		try (Connection con = DatabaseFactory.getConnection();
				 PreparedStatement stmt = con.prepareStatement("SELECT mail_unique_id FROM mail", ResultSet.TYPE_SCROLL_INSENSITIVE,
					 ResultSet.CONCUR_READ_ONLY)) {
			ResultSet rs = stmt.executeQuery();
			rs.last();
			int count = rs.getRow();
			rs.beforeFirst();
			int[] ids = new int[count];
			for (int i = 0; rs.next(); i++)
				ids[i] = rs.getInt("mail_unique_id");
			return ids;
		} catch (SQLException e) {
			log.error("Can't get list of IDs from mail table", e);
			return null;
		}
	}

	public static boolean cleanMail(String recipient) {
		return DB.insertUpdate(
			"DELETE FROM mail WHERE mail_recipient_id=(SELECT id FROM players WHERE name=?) AND attached_item_id=0 AND attached_kinah_count=0",
			new IUStH() {

				@Override
				public void handleInsertUpdate(PreparedStatement stmt) throws SQLException {
					stmt.setString(1, recipient);
					stmt.execute();
				}
			});
	}

}