economyplugin/src/Economy.java

import java.util.Map;
import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;
import java.io.*;

public class Economy extends Plugin {
        @Override 
        public void enable() {}
        
        @Override
        public void disable() {}

        @Override 
        public void initialize() {
                PluginListener plugin = new EconomyPluginListener();
                PluginLoader loader = etc.getLoader();
                loader.addListener( PluginLoader.Hook.COMMAND, plugin, this, PluginListener.Priority.MEDIUM );
                loader.addListener( PluginLoader.Hook.SERVERCOMMAND, plugin, this, PluginListener.Priority.MEDIUM );
        }

        class ExchangeRate{
                public ExchangeRate() {}
                public ExchangeRate(int id, String name, int sell, int buy) {
                        this.id = id;
                        this.name = name;
                        this.sell = sell;
                        this.buy = buy;
                }

                int id; //blockid
                String name;
                int sell; //the amount the user receives when selling item
                int buy;
        }

        public class EconomyPluginListener extends PluginListener {
                final static String balanceFile = "economy-balance.txt";
                final static String ratesFile = "economy-rates.txt";

                private Map<String,Integer> itemMap = new HashMap<String,Integer>();
                private Map<String, Integer> balances = new ConcurrentHashMap<String,Integer>();
                private Map<Integer, ExchangeRate> rates = new HashMap<Integer,ExchangeRate>();

                public EconomyPluginListener() {
                        loadExchangeRates();
                        loadUserBalances();
                }

                private void loadExchangeRates() {
                        try {
                                File f = new File(ratesFile);
                                if (f.exists() ) {
                                        BufferedReader in = new BufferedReader(new InputStreamReader( new FileInputStream(f) ) );
                                        
                                        rates.clear();
                                        itemMap.clear();

                                        String line;    
                                        while ( (line = in.readLine()) != null) {
                                                line = line.trim();
                                                if (line.length() == 0 || line.startsWith("#")) {
                                                        continue;
                                                }

                                                String parts[] = line.split(":");
                                                ExchangeRate r = new ExchangeRate();
                                                r.id = Integer.parseInt(parts[0]);
                                                r.name = parts[1];
                                                r.sell = Integer.parseInt(parts[2]);
                                                r.buy = Integer.parseInt(parts[3]);

                                                rates.put(r.id, r);

                                                itemMap.put(r.name.toLowerCase(), r.id);

                                        }
                                } else {
                                        System.out.println("Could not find rates-file - creating new");
                                        BufferedWriter out = new BufferedWriter( new OutputStreamWriter(new FileOutputStream(f)) );

                                        out.write("#itemID:name:sellrate:buyrate\n");
                                        out.close();
                                }
                        } catch (Exception e) {
                                System.out.println("Error loading rates: " + e.getMessage() );
                        }
                }

                private void loadUserBalances() {
                        try {
                                File f = new File(balanceFile);
                                if (f.exists() ) {
                                        BufferedReader in = new BufferedReader(new InputStreamReader( new FileInputStream(f) ) );
                                
                                        String line;    
                                        while ( (line = in.readLine()) != null) {
                                                line = line.trim();
                                                if (line.length() == 0 || line.startsWith("#")) {
                                                        continue;
                                                }

                                                String parts[] = line.split(":");
                                                balances.put(parts[0], Integer.parseInt(parts[1]) );                                    
                                        }

                                        in.close();
                                }       
                        } catch (Exception e) {
                                System.out.println("Error loading balances: " + e.getMessage() );
                        }
                }

                private synchronized void saveUserBalance(String username) {
                        try {
                                FileOutputStream fos = new FileOutputStream(balanceFile);
                                BufferedWriter out = new BufferedWriter( new OutputStreamWriter(fos) ); 

                                for (String key : balances.keySet() ) {
                                        out.write( key + ":" + balances.get(key) );
                                        out.newLine();          
                                }
                                

                                out.close();
                                fos.close();
                        } catch (Exception e) {
                                System.out.println("Error saving user balance: " + e.getMessage() );
                        }
                
                }


                private void adminCoins(Player player, String[] split) {
                        if(split.length != 4 || !(split[1].equals("give") || split[1].equals("take") )) {       
                                player.sendMessage( Colors.Green + "Usage: /admincoins (give|take) <player> <amount>");
                                return;
                        }

                        Player p2 = etc.getServer().getPlayer( split[2]);
                        if (p2 == null) {
                                player.sendMessage( Colors.Green + split[0] + ": could not find player " + split[2]);
                                return;
                        }

                        int amount;
                        try {
                                amount = Integer.parseInt(split[3]);
                        } catch (Exception e) {
                                player.sendMessage( Colors.Green + split[0] + ": amount must be a number");
                                return;
                        }

                        Integer balance = balances.get(p2.getName() );
                        if (balance == null) {
                                balance = 0;
                        }
                        
                        if (split[1].equals("give")) {
                                balance += amount;                              

                                player.sendMessage(Colors.Green + split[0] + ": coins given to " + p2.getName() );
                                p2.sendMessage(Colors.Green + "You have been given " + amount + " coins");
        
                        } else { //take
                                if (amount > balance) {
                                        player.sendMessage(Colors.Green + split[0] + ": " + p2.getName() + " doesnt have that many coins");
                                        return;
                                }
                                balance -= amount;

                                player.sendMessage(Colors.Green + split[0] + ": coins taken from " + p2.getName() );
                                p2.sendMessage(Colors.Green + amount + " coins have been taken from your account");

                        }       
                        
                        balances.put(p2.getName(), balance);
                        saveUserBalance(p2.getName() );

                }

                private void giveCoins(Player player, String[] split) {
                        if (split.length != 3) {
                                player.sendMessage( Colors.Green + "Usage: /givecoins <player> <amount> - gives coins to a user from your account");
                                return;
                        }
                        Player p2 = etc.getServer().getPlayer( split[1]);
                        if (p2 == null) {
                                player.sendMessage( Colors.Green + "Givecoins: could not find player " + split[1]);
                                return;
                        }
                        int amount;
                        try {
                                amount = Integer.parseInt(split[2]);
                        } catch (Exception e) {
                                player.sendMessage( Colors.Green + "Givecoins: amount must be a number");
                                return;
                        }

                        Integer source = balances.get(player.getName() );
                        if (source == null || source < amount) {
                                player.sendMessage(Colors.Green + "Givecoins: you don't have that much to give");
                                return;
                        }

                        Integer destination = balances.get(p2.getName());
                        if (destination == null) {
                                destination = 0;
                        }

                        balances.put(player.getName(), source - amount);
                        balances.put(p2.getName(), destination+amount);

                        saveUserBalance(player.getName() );
                        saveUserBalance(p2.getName() );

                        player.sendMessage(Colors.Green + "Givecoins, you have given " + amount + " coins to " + p2.getName() );
                        p2.sendMessage(Colors.Green + "Givecoins, you have received " + amount + " coins from " + player.getName() );
                        

                }

                private void balance(Player player) {
                        Integer balObj = balances.get( player.getName() );
        
                        int bal = (balObj != null ? balObj : 0);

                        player.sendMessage( Colors.Green + "Your balance is " + bal + " coins");                                                
                }

                private void rates(Player player) {

                        player.sendMessage( Colors.Green + "Current exchange rates");

                        for(ExchangeRate r : rates.values() ) {
                                player.sendMessage(Colors.Green + r.name + "(" + r.id + ") sell= " + r.sell + " buy=" + r.buy );
                        }
                }

                int getItemId(String str) {
                        int item = -1;
                        try {
                                item = Integer.parseInt( str );
                        } catch (Exception e) {                         
                                Integer itemId = itemMap.get( str.toLowerCase() );
                                if (itemId  != null) {
                                        item = itemId; 
                                } 
                        }
                        return item;
                }
                
                private boolean validateBuySell(Player player, String[] split) {
                        if (split.length != 3) {
                                player.sendMessage( Colors.Green + "Usage: " + split[0] + " <item> <amount>");
                                return false;
                        }

                        int item = getItemId(split[1]);
                        if (item == -1) {
                                player.sendMessage( Colors.Green + split[0] + ": <item> must be an integer or name of a traded item");
                                return false;
                        }
                        
                        int amount;
                        try {
                                amount = Integer.parseInt(split[2]);
                        } catch (Exception e) {
                                player.sendMessage( Colors.Green + split[0] + ": amount must be an integer");
                                return false;
                        }

                        if (amount < 0 || amount > 1024) {
                                player.sendMessage( Colors.Green + split[0] + ": amount must be between 0 and 1024");
                                return false;
                        }


                        ExchangeRate r = rates.get(item);
                        if (r == null) {
                                player.sendMessage( Colors.Green + split[0] + ": item with id " + item + " can not be traded");
                                return false;
                        }

                        return true;
                }

                
                private void buy(Player player, String[] split) {
                        int item = getItemId(split[1]);
                        int amount = Integer.parseInt(split[2]);
                        
                        ExchangeRate rate = rates.get(item);

                        int value = rate.buy * amount;

                        Integer balance = balances.get( player.getName() );

                        if (balance == null || balance < value) {
                                player.sendMessage( Colors.Green + split[0] + ": you don't have enough coins");
                                return;
                        }

                        player.giveItem(item,amount);
                        int newBalance = balance-value;
                        balances.put(player.getName(), newBalance);


                        player.sendMessage( Colors.Green + "You have bought " + amount + " x " + rate.name );
                        player.sendMessage( Colors.Green + "Your new balance is " + newBalance );
                                 

                        saveUserBalance(player.getName() );     
                }

                private boolean hasItem(Inventory inv, int itemID, int amount) {
                        int count = 0;
                        for (int i=0; i<36; i++) {
                                Item item = inv.getItemFromSlot(i);
                                if (item != null) {
                                        if (item.getItemId() == itemID) {
                                                count += item.getAmount();
                                        }
                                }
                        }
                        return (count >= amount);

                }

                private void sell(Player player, String[] split) {
                        int itemId = getItemId( split[1] );
                        int amount = Integer.parseInt(split[2]);


                        ExchangeRate rate = rates.get(itemId);

                        Inventory inv = player.getInventory();

/*                      if (! inv.hasItem(itemId, amount, 1024) ) {
                                player.sendMessage(Colors.Green + split[0] + ": you don't have that many pieces of " + rate.name );
                                return;
                        }
*/
                        if (! hasItem(inv, itemId, amount) ) {
                                player.sendMessage(Colors.Green + split[0] + ": you don't have that many pieces of " + rate.name );
                                return;
                        }
                        

                        Integer balance = balances.get( player.getName() );
                        if (balance == null) {
                                balance = 0;
                        }

                        Item item = new Item(itemId, amount);
                        inv.removeItem(item);
                        inv.updateInventory();

                        balance += (amount * rate.sell);
                        balances.put( player.getName(), balance);       

                        player.sendMessage( Colors.Green + "You have sold " + amount + " x " + rate.name );
                        player.sendMessage( Colors.Green + "Your new balance is " + balance );

                        saveUserBalance(player.getName() );     
                }

                
                @Override
                public boolean onCommand(Player player, java.lang.String[] split) {
                        if (split[0].equals("/balance") ) {
                                balance(player);
                                return true;
                        } 


                        if (split[0].equals("/admincoins") ) {
                                adminCoins(player,split);
                                return true;
                        }

                        if (split[0].equals("/givecoins") ) {
                                giveCoins(player,split);
                                return true;
                        }

                        if (split[0].equals("/rates") ) {
                                rates(player);
                                return true;
                        }

                        if (split[0].equals("/sell") ) {
                                if (validateBuySell(player,split)) {
                                        sell(player, split);
                                }
                                return true;
                        }

                        if (split[0].equals("/buy") ) {
                                if (validateBuySell(player,split)) {
                                        buy(player, split);
                                }
                                return true;
                        }

                        if (split[0].equals("/reload") ) {
                                loadExchangeRates();
                        }               


                        return false;
                
                }

                public boolean onConsoleCommand(String[] split)  {
                        if (split[0].equals("reload") ) {
                                loadExchangeRates();
                        }
                        return false;
                }       
        }               
}
1	torben	1166	import java.util.Map;
2			import java.util.HashMap;
3			import java.util.concurrent.ConcurrentHashMap;
4			import java.io.*;
5
6			public class Economy extends Plugin {
7			@Override
8			public void enable() {}
9
10			@Override
11			public void disable() {}
12
13			@Override
14			public void initialize() {
15			PluginListener plugin = new EconomyPluginListener();
16			PluginLoader loader = etc.getLoader();
17			loader.addListener( PluginLoader.Hook.COMMAND, plugin, this, PluginListener.Priority.MEDIUM );
18			loader.addListener( PluginLoader.Hook.SERVERCOMMAND, plugin, this, PluginListener.Priority.MEDIUM );
19			}
20
21			class ExchangeRate{
22			public ExchangeRate() {}
23			public ExchangeRate(int id, String name, int sell, int buy) {
24			this.id = id;
25			this.name = name;
26			this.sell = sell;
27			this.buy = buy;
28			}
29
30			int id; //blockid
31			String name;
32			int sell; //the amount the user receives when selling item
33			int buy;
34			}
35
36			public class EconomyPluginListener extends PluginListener {
37			final static String balanceFile = "economy-balance.txt";
38			final static String ratesFile = "economy-rates.txt";
39
40			private Map<String,Integer> itemMap = new HashMap<String,Integer>();
41			private Map<String, Integer> balances = new ConcurrentHashMap<String,Integer>();
42			private Map<Integer, ExchangeRate> rates = new HashMap<Integer,ExchangeRate>();
43
44			public EconomyPluginListener() {
45			loadExchangeRates();
46			loadUserBalances();
47			}
48
49			private void loadExchangeRates() {
50			try {
51			File f = new File(ratesFile);
52			if (f.exists() ) {
53			BufferedReader in = new BufferedReader(new InputStreamReader( new FileInputStream(f) ) );
54
55			rates.clear();
56			itemMap.clear();
57
58			String line;
59			while ( (line = in.readLine()) != null) {
60			line = line.trim();
61			if (line.length() == 0 \|\| line.startsWith("#")) {
62			continue;
63			}
64
65			String parts[] = line.split(":");
66			ExchangeRate r = new ExchangeRate();
67			r.id = Integer.parseInt(parts[0]);
68			r.name = parts[1];
69			r.sell = Integer.parseInt(parts[2]);
70			r.buy = Integer.parseInt(parts[3]);
71
72			rates.put(r.id, r);
73
74			itemMap.put(r.name.toLowerCase(), r.id);
75
76			}
77			} else {
78			System.out.println("Could not find rates-file - creating new");
79			BufferedWriter out = new BufferedWriter( new OutputStreamWriter(new FileOutputStream(f)) );
80
81			out.write("#itemID:name:sellrate:buyrate\n");
82			out.close();
83			}
84			} catch (Exception e) {
85			System.out.println("Error loading rates: " + e.getMessage() );
86			}
87			}
88
89			private void loadUserBalances() {
90			try {
91			File f = new File(balanceFile);
92			if (f.exists() ) {
93			BufferedReader in = new BufferedReader(new InputStreamReader( new FileInputStream(f) ) );
94
95			String line;
96			while ( (line = in.readLine()) != null) {
97			line = line.trim();
98			if (line.length() == 0 \|\| line.startsWith("#")) {
99			continue;
100			}
101
102			String parts[] = line.split(":");
103			balances.put(parts[0], Integer.parseInt(parts[1]) );
104			}
105
106			in.close();
107			}
108			} catch (Exception e) {
109			System.out.println("Error loading balances: " + e.getMessage() );
110			}
111			}
112
113			private synchronized void saveUserBalance(String username) {
114			try {
115			FileOutputStream fos = new FileOutputStream(balanceFile);
116			BufferedWriter out = new BufferedWriter( new OutputStreamWriter(fos) );
117
118			for (String key : balances.keySet() ) {
119			out.write( key + ":" + balances.get(key) );
120			out.newLine();
121			}
122
123
124			out.close();
125			fos.close();
126			} catch (Exception e) {
127			System.out.println("Error saving user balance: " + e.getMessage() );
128			}
129
130			}
131
132
133			private void adminCoins(Player player, String[] split) {
134			if(split.length != 4 \|\| !(split[1].equals("give") \|\| split[1].equals("take") )) {
135			player.sendMessage( Colors.Green + "Usage: /admincoins (give\|take) <player> <amount>");
136			return;
137			}
138
139			Player p2 = etc.getServer().getPlayer( split[2]);
140			if (p2 == null) {
141			player.sendMessage( Colors.Green + split[0] + ": could not find player " + split[2]);
142			return;
143			}
144
145			int amount;
146			try {
147			amount = Integer.parseInt(split[3]);
148			} catch (Exception e) {
149			player.sendMessage( Colors.Green + split[0] + ": amount must be a number");
150			return;
151			}
152
153			Integer balance = balances.get(p2.getName() );
154			if (balance == null) {
155			balance = 0;
156			}
157
158			if (split[1].equals("give")) {
159			balance += amount;
160
161			player.sendMessage(Colors.Green + split[0] + ": coins given to " + p2.getName() );
162			p2.sendMessage(Colors.Green + "You have been given " + amount + " coins");
163
164			} else { //take
165			if (amount > balance) {
166			player.sendMessage(Colors.Green + split[0] + ": " + p2.getName() + " doesnt have that many coins");
167			return;
168			}
169			balance -= amount;
170
171			player.sendMessage(Colors.Green + split[0] + ": coins taken from " + p2.getName() );
172			p2.sendMessage(Colors.Green + amount + " coins have been taken from your account");
173
174			}
175
176			balances.put(p2.getName(), balance);
177			saveUserBalance(p2.getName() );
178
179			}
180
181			private void giveCoins(Player player, String[] split) {
182			if (split.length != 3) {
183			player.sendMessage( Colors.Green + "Usage: /givecoins <player> <amount> - gives coins to a user from your account");
184			return;
185			}
186			Player p2 = etc.getServer().getPlayer( split[1]);
187			if (p2 == null) {
188			player.sendMessage( Colors.Green + "Givecoins: could not find player " + split[1]);
189			return;
190			}
191			int amount;
192			try {
193			amount = Integer.parseInt(split[2]);
194			} catch (Exception e) {
195			player.sendMessage( Colors.Green + "Givecoins: amount must be a number");
196			return;
197			}
198
199			Integer source = balances.get(player.getName() );
200			if (source == null \|\| source < amount) {
201			player.sendMessage(Colors.Green + "Givecoins: you don't have that much to give");
202			return;
203			}
204
205			Integer destination = balances.get(p2.getName());
206			if (destination == null) {
207			destination = 0;
208			}
209
210			balances.put(player.getName(), source - amount);
211			balances.put(p2.getName(), destination+amount);
212
213			saveUserBalance(player.getName() );
214			saveUserBalance(p2.getName() );
215
216			player.sendMessage(Colors.Green + "Givecoins, you have given " + amount + " coins to " + p2.getName() );
217			p2.sendMessage(Colors.Green + "Givecoins, you have received " + amount + " coins from " + player.getName() );
218
219
220
221			}
222
223			private void balance(Player player) {
224			Integer balObj = balances.get( player.getName() );
225
226			int bal = (balObj != null ? balObj : 0);
227
228			player.sendMessage( Colors.Green + "Your balance is " + bal + " coins");
229			}
230
231			private void rates(Player player) {
232
233			player.sendMessage( Colors.Green + "Current exchange rates");
234
235			for(ExchangeRate r : rates.values() ) {
236			player.sendMessage(Colors.Green + r.name + "(" + r.id + ") sell= " + r.sell + " buy=" + r.buy );
237			}
238			}
239
240			int getItemId(String str) {
241			int item = -1;
242			try {
243			item = Integer.parseInt( str );
244			} catch (Exception e) {
245			Integer itemId = itemMap.get( str.toLowerCase() );
246			if (itemId != null) {
247			item = itemId;
248			}
249			}
250			return item;
251			}
252
253			private boolean validateBuySell(Player player, String[] split) {
254			if (split.length != 3) {
255			player.sendMessage( Colors.Green + "Usage: " + split[0] + " <item> <amount>");
256			return false;
257			}
258
259			int item = getItemId(split[1]);
260			if (item == -1) {
261			player.sendMessage( Colors.Green + split[0] + ": <item> must be an integer or name of a traded item");
262			return false;
263			}
264
265			int amount;
266			try {
267			amount = Integer.parseInt(split[2]);
268			} catch (Exception e) {
269			player.sendMessage( Colors.Green + split[0] + ": amount must be an integer");
270			return false;
271			}
272
273			if (amount < 0 \|\| amount > 1024) {
274			player.sendMessage( Colors.Green + split[0] + ": amount must be between 0 and 1024");
275			return false;
276			}
277
278
279			ExchangeRate r = rates.get(item);
280			if (r == null) {
281			player.sendMessage( Colors.Green + split[0] + ": item with id " + item + " can not be traded");
282			return false;
283			}
284
285			return true;
286			}
287
288
289
290			private void buy(Player player, String[] split) {
291			int item = getItemId(split[1]);
292			int amount = Integer.parseInt(split[2]);
293
294			ExchangeRate rate = rates.get(item);
295
296			int value = rate.buy * amount;
297
298			Integer balance = balances.get( player.getName() );
299
300			if (balance == null \|\| balance < value) {
301			player.sendMessage( Colors.Green + split[0] + ": you don't have enough coins");
302			return;
303			}
304
305			player.giveItem(item,amount);
306			int newBalance = balance-value;
307			balances.put(player.getName(), newBalance);
308
309
310			player.sendMessage( Colors.Green + "You have bought " + amount + " x " + rate.name );
311			player.sendMessage( Colors.Green + "Your new balance is " + newBalance );
312
313
314			saveUserBalance(player.getName() );
315			}
316
317			private boolean hasItem(Inventory inv, int itemID, int amount) {
318			int count = 0;
319			for (int i=0; i<36; i++) {
320			Item item = inv.getItemFromSlot(i);
321			if (item != null) {
322			if (item.getItemId() == itemID) {
323			count += item.getAmount();
324			}
325			}
326			}
327			return (count >= amount);
328
329			}
330
331			private void sell(Player player, String[] split) {
332			int itemId = getItemId( split[1] );
333			int amount = Integer.parseInt(split[2]);
334
335
336			ExchangeRate rate = rates.get(itemId);
337
338			Inventory inv = player.getInventory();
339
340			/* if (! inv.hasItem(itemId, amount, 1024) ) {
341			player.sendMessage(Colors.Green + split[0] + ": you don't have that many pieces of " + rate.name );
342			return;
343			}
344			*/
345			if (! hasItem(inv, itemId, amount) ) {
346			player.sendMessage(Colors.Green + split[0] + ": you don't have that many pieces of " + rate.name );
347			return;
348			}
349
350
351			Integer balance = balances.get( player.getName() );
352			if (balance == null) {
353			balance = 0;
354			}
355
356			Item item = new Item(itemId, amount);
357			inv.removeItem(item);
358			inv.updateInventory();
359
360			balance += (amount * rate.sell);
361			balances.put( player.getName(), balance);
362
363			player.sendMessage( Colors.Green + "You have sold " + amount + " x " + rate.name );
364			player.sendMessage( Colors.Green + "Your new balance is " + balance );
365
366			saveUserBalance(player.getName() );
367			}
368
369
370
371			@Override
372			public boolean onCommand(Player player, java.lang.String[] split) {
373			if (split[0].equals("/balance") ) {
374			balance(player);
375			return true;
376			}
377
378
379			if (split[0].equals("/admincoins") ) {
380			adminCoins(player,split);
381			return true;
382			}
383
384			if (split[0].equals("/givecoins") ) {
385			giveCoins(player,split);
386			return true;
387			}
388
389			if (split[0].equals("/rates") ) {
390			rates(player);
391			return true;
392			}
393
394			if (split[0].equals("/sell") ) {
395			if (validateBuySell(player,split)) {
396			sell(player, split);
397			}
398			return true;
399			}
400
401			if (split[0].equals("/buy") ) {
402			if (validateBuySell(player,split)) {
403			buy(player, split);
404			}
405			return true;
406			}
407
408			if (split[0].equals("/reload") ) {
409			loadExchangeRates();
410			}
411
412
413			return false;
414
415			}
416
417			public boolean onConsoleCommand(String[] split) {
418			if (split[0].equals("reload") ) {
419			loadExchangeRates();
420			}
421			return false;
422			}
423			}
424			}