hoeruputils/message/MessageWrapper.java

package dk.thoerup.bukkit.hoeruputils.message;

import java.util.List;
import java.util.logging.Level;

import javax.persistence.PersistenceException;

import org.bukkit.OfflinePlayer;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerLoginEvent;
import org.bukkit.plugin.Plugin;
import org.bukkit.scheduler.BukkitScheduler;

import com.avaje.ebean.EbeanServer;

import java.sql.Timestamp;

public class MessageWrapper implements Listener {

        EbeanServer server;
        Plugin plugin;
        
        
        public MessageWrapper(Plugin plugin, Runnable installer) {
                this.plugin = plugin;
                server = plugin.getDatabase();
                
                try {
                        server.find(MessageBean.class).findRowCount(); //probe 
                } catch (Exception e) {
                        
                        installer.run();
                }
                
        }

        @EventHandler
        public void onPlayerLogin(final PlayerLoginEvent event) {
                final Player player = event.getPlayer();

                Runnable messagehandler = new Runnable() {
                        @Override
                        public void run() {                             
                                List<MessageBean> beans = server.find( MessageBean.class)
                                        .where()
                                        .eq("player", player.getName() )
                                        .eq("isread", 0)
                                        .findList();
                                
                                for(MessageBean msg : beans) {
                                        player.sendMessage( msg.getMessage() );
                                        msg.setIsread(true);
                                        msg.setReadtime( new Timestamp(System.currentTimeMillis()) );
                                        server.save(msg);
                                }
                        }                       
                };
                
                BukkitScheduler sched = plugin.getServer().getScheduler();              
                sched.scheduleSyncDelayedTask(plugin, messagehandler, 20*4);
                
        }
        
        public void sendMessage(String from, OfflinePlayer player, String message) {
                if (player.isOnline()) {
                        Player online = (Player) player;
                        online.sendMessage(message);
                } else {
                        queueMessage(from, player.getName(), message);
                }
        }
        
        protected void queueMessage(String from, String player, String message) {
                
                MessageBean msg = new MessageBean();
                msg.setFromplayer(from);
                msg.setPlayer(player);
                msg.setMessage(message);
                msg.setCreatetimeNow();;
                try {
                        server.save(msg);                       
                } catch (PersistenceException e) {                      
                        plugin.getLogger().log(Level.SEVERE, "MessageWrapper.queueMessage() failed:" + e.getMessage() );
                }
                
                
        }
        
}
1	package dk.thoerup.bukkit.hoeruputils.message;
2
3	import java.util.List;
4	import java.util.logging.Level;
5
6	import javax.persistence.PersistenceException;
7
8	import org.bukkit.OfflinePlayer;
9	import org.bukkit.entity.Player;
10	import org.bukkit.event.EventHandler;
11	import org.bukkit.event.Listener;
12	import org.bukkit.event.player.PlayerLoginEvent;
13	import org.bukkit.plugin.Plugin;
14	import org.bukkit.scheduler.BukkitScheduler;
15
16	import com.avaje.ebean.EbeanServer;
17
18	import java.sql.Timestamp;
19
20	public class MessageWrapper implements Listener {
21
22	EbeanServer server;
23	Plugin plugin;
24
25
26	public MessageWrapper(Plugin plugin, Runnable installer) {
27	this.plugin = plugin;
28	server = plugin.getDatabase();
29
30	try {
31	server.find(MessageBean.class).findRowCount(); //probe
32	} catch (Exception e) {
33
34	installer.run();
35	}
36
37	}
38
39	@EventHandler
40	public void onPlayerLogin(final PlayerLoginEvent event) {
41	final Player player = event.getPlayer();
42
43	Runnable messagehandler = new Runnable() {
44	@Override
45	public void run() {
46	List<MessageBean> beans = server.find( MessageBean.class)
47	.where()
48	.eq("player", player.getName() )
49	.eq("isread", 0)
50	.findList();
51
52	for(MessageBean msg : beans) {
53	player.sendMessage( msg.getMessage() );
54	msg.setIsread(true);
55	msg.setReadtime( new Timestamp(System.currentTimeMillis()) );
56	server.save(msg);
57	}
58	}
59	};
60
61	BukkitScheduler sched = plugin.getServer().getScheduler();
62	sched.scheduleSyncDelayedTask(plugin, messagehandler, 20*4);
63
64	}
65
66	public void sendMessage(String from, OfflinePlayer player, String message) {
67	if (player.isOnline()) {
68	Player online = (Player) player;
69	online.sendMessage(message);
70	} else {
71	queueMessage(from, player.getName(), message);
72	}
73	}
74
75	protected void queueMessage(String from, String player, String message) {
76
77	MessageBean msg = new MessageBean();
78	msg.setFromplayer(from);
79	msg.setPlayer(player);
80	msg.setMessage(message);
81	msg.setCreatetimeNow();;
82	try {
83	server.save(msg);
84	} catch (PersistenceException e) {
85	plugin.getLogger().log(Level.SEVERE, "MessageWrapper.queueMessage() failed:" + e.getMessage() );
86	}
87
88
89	}
90
91	}