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;

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) {

                Runnable messagehandler = new Runnable() {
                        @Override
                        public void run() {
                                Player player = event.getPlayer();
                                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);
                                        server.save(msg);
                                }
                        }                       
                };
                
                BukkitScheduler sched = plugin.getServer().getScheduler();              
                sched.scheduleSyncDelayedTask(plugin, messagehandler, 20*4);
                
        }
        
        public void sendMessage(OfflinePlayer player, String message) {
                if (player.isOnline()) {
                        Player online = (Player) player;
                        online.sendMessage(message);
                } else {
                        queueMessage(player.getName(), message);
                }
        }
        
        protected void queueMessage(String player, String message) {
                
                MessageBean msg = new MessageBean();
                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	torben	1768	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			public class MessageWrapper implements Listener {
19
20			EbeanServer server;
21			Plugin plugin;
22
23
24			public MessageWrapper(Plugin plugin, Runnable installer) {
25			this.plugin = plugin;
26			server = plugin.getDatabase();
27
28			try {
29			server.find(MessageBean.class).findRowCount(); //probe
30			} catch (Exception e) {
31
32			installer.run();
33			}
34
35			}
36
37			@EventHandler
38			public void onPlayerLogin(final PlayerLoginEvent event) {
39
40			Runnable messagehandler = new Runnable() {
41			@Override
42			public void run() {
43			Player player = event.getPlayer();
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			server.save(msg);
54			}
55			}
56			};
57
58			BukkitScheduler sched = plugin.getServer().getScheduler();
59			sched.scheduleSyncDelayedTask(plugin, messagehandler, 20*4);
60
61			}
62
63			public void sendMessage(OfflinePlayer player, String message) {
64			if (player.isOnline()) {
65			Player online = (Player) player;
66			online.sendMessage(message);
67			} else {
68			queueMessage(player.getName(), message);
69			}
70			}
71
72			protected void queueMessage(String player, String message) {
73
74			MessageBean msg = new MessageBean();
75			msg.setPlayer(player);
76			msg.setMessage(message);
77			msg.setCreatetimeNow();
78			try {
79			server.save(msg);
80			} catch (PersistenceException e) {
81			plugin.getLogger().log(Level.SEVERE, "MessageWrapper.queueMessage() failed:" + e.getMessage() );
82			}
83
84
85			}
86
87			}