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 io.ebean.Ebean;
import io.ebean.EbeanServer;

import java.sql.Timestamp;

public class MessageWrapper implements Listener {

        EbeanServer server;
        Plugin plugin;
        
        
        public MessageWrapper(Plugin plugin) {
                this.plugin = plugin;
                server = Ebean.getDefaultServer();
                

                server.find(MessageBean.class).findCount(); //probe 
        }

        @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
17
18	import io.ebean.Ebean;
19	import io.ebean.EbeanServer;
20
21	import java.sql.Timestamp;
22
23	public class MessageWrapper implements Listener {
24
25	EbeanServer server;
26	Plugin plugin;
27
28
29	public MessageWrapper(Plugin plugin) {
30	this.plugin = plugin;
31	server = Ebean.getDefaultServer();
32
33
34	server.find(MessageBean.class).findCount(); //probe
35	}
36
37	@EventHandler
38	public void onPlayerLogin(final PlayerLoginEvent event) {
39	final Player player = event.getPlayer();
40
41	Runnable messagehandler = new Runnable() {
42	@Override
43	public void run() {
44	List<MessageBean> beans = server.find( MessageBean.class)
45	.where()
46	.eq("player", player.getName() )
47	.eq("isread", 0)
48	.findList();
49
50	for(MessageBean msg : beans) {
51	player.sendMessage( msg.getMessage() );
52	msg.setIsread(true);
53	msg.setReadtime( new Timestamp(System.currentTimeMillis()) );
54	server.save(msg);
55	}
56	}
57	};
58
59	BukkitScheduler sched = plugin.getServer().getScheduler();
60	sched.scheduleSyncDelayedTask(plugin, messagehandler, 20*4);
61
62	}
63
64	public void sendMessage(String from, OfflinePlayer player, String message) {
65	if (player.isOnline()) {
66	Player online = (Player) player;
67	online.sendMessage(message);
68	} else {
69	queueMessage(from, player.getName(), message);
70	}
71	}
72
73	protected void queueMessage(String from, String player, String message) {
74
75	MessageBean msg = new MessageBean();
76	msg.setFromplayer(from);
77	msg.setPlayer(player);
78	msg.setMessage(message);
79	msg.setCreatetimeNow();;
80	try {
81	server.save(msg);
82	} catch (PersistenceException e) {
83	plugin.getLogger().log(Level.SEVERE, "MessageWrapper.queueMessage() failed:" + e.getMessage() );
84	}
85
86
87	}
88
89	}