Banana-Coding.com - Java Knuddels Emulator

Quellcode

public class MessageHandler {

	public static void handle(String[] tokens, Client client) {

    	if (tokens[1].equals("msent")) {

        	String empfänger = tokens[3];
        	String sender = client.getName();
        	String betreff = tokens[4];
        	String message = tokens[5];


        	if (empfänger.equals(Server.get().getButler().getName())) {
            	client.send(Popup.create("Problem", "Problem", "An Issi können keine Nachrichten gesendet werden.", 400, 300));
            	return;
        	}
        	System.out.print(message.length());
        	if (message.length() >= 2000) {
            	client.send(Popup.create("Problem", "Deine Nachricht konnte nicht gesendet werden:", "Ihre Nachricht ist zu lang, sie darf h�chstens 2000 Zeichen lang sein.", 400, 300));
            	return;
        	}

        	message = KCodeParser.parse(message, client.isModerator(), 5, 10, 20);
        	message = Server.get().parseSmileys(message);


        	PoolConnection pcon = ConnectionPool.getConnection();
        	PreparedStatement ps = null;

        	try {
            	Connection con = pcon.connect();
            	ps = con.prepareStatement("INSERT INTO `message` (`sender`, `empfänger`, `zeit`, `betreff`, `message`, `read`) VALUES (?, ?, ?, ?, ?, 0)");
            	ps.setString(1, sender);
            	ps.setString(2, empfänger);
            	DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.FULL, DateFormat.MEDIUM, Locale.GERMANY);
            	ps.setString(3, dateFormat.format(new Date()));
            	ps.setString(4, betreff);
            	ps.setString(5, message);
            	ps.executeUpdate();
        	} catch (SQLException e) {
            	e.printStackTrace();
        	} finally {
            	if (ps != null) {
                	try {
                    	ps.close();
                	} catch (SQLException e) {
                	}
            	}

            	pcon.close();
        	}

        	client.sendButlerMessage(client.getChannel().getName(), String.format("Ich werde es nicht vergessen und _die Nachricht_ schnellstmöglich ausrichten.", empfänger));


        	String recipient = empfänger;
        	String[] recipients = recipient.split(",");
        	List<Client> targets = new ArrayList<Client>();
        	Client target;
        	for (String rcp : recipients) {
            	rcp = KCodeParser.escape(rcp);

            	if (rcp.isEmpty()) {
                	continue;
            	}

            	target = Server.get().getClient(rcp);

            	if (target == null) {
            	} else if (!targets.contains(target)) {
                	targets.add(target);
            	}
        	}

        	if (targets.isEmpty()) {
            	return;
        	}

        	Server.get().getButler().sendPrivateMessage(targets, String.format("_�>_h%s|/w "<r�_ hat dir gerade Post geschrieben. Du kannst sie mit _�BB>finger.b.gif<>/m|/m<r�_ abholen.", sender), Server.get().getClient(empfänger).getChannel(), false);

    	}

    	if (tokens[1].equals("m")) {

        	PoolConnection pcon = ConnectionPool.getConnection();
        	PreparedStatement ps = null;


        	try {
            	Connection con = pcon.connect();

            	ps = con.prepareStatement("SELECT * FROM `accounts` WHERE `name` = ?");
            	ps.setString(1, client.getName());
            	ResultSet rs = ps.executeQuery();

            	if (rs.next()) {
                	String wert = rs.getString("message");

                	if (wert.isEmpty()) {

                    	client.sendButlerMessage(client.getChannel().getName(), "Es liegen leider keine Nachrichten f�r dich vor.");

                	} else {

                    	String[] temp;
                    	temp = wert.split("|");
                    	String sender = temp[0];
                    	String message = temp[1];

                    	String popup = Popup.create("Dein Briefkasten", "Eine Nachricht wurde für dich hinterlegt:", "Alle Änderungen wurden _gespeichert_.", 400, 300);
                    	client.send(popup);

                	}
            	}
        	} catch (SQLException e) {
            	e.printStackTrace();
        	} finally {
            	if (ps != null) {
                	try {
                    	ps.close();
                	} catch (SQLException e) {
                	}
            	}

            	pcon.close();
        	}
    	}
	}
}