wip arbitrage

[jarrg-ian.git] / src / com / tedpearson / ypp / market / MarketUploader.java

diff --git a/src/com/tedpearson/ypp/market/MarketUploader.java b/src/com/tedpearson/ypp/market/MarketUploader.java
index 7632c01f1221bd8ac3b27fd0c1242bcaeca3fbe6..9aa8f046301e1480e90aaf7ef2c56f61f4958aa5 100644 (file)
--- a/src/com/tedpearson/ypp/market/MarketUploader.java
+++ b/src/com/tedpearson/ypp/market/MarketUploader.java
@@ -78,6 +78,14 @@ public class MarketUploader implements TopLevelWindowListener, GUIInitializedLis
                        }
                }
            };
+
+        private int parseQty(String str) {
+               if (str.equals(">1000")) {
+                       return 1001;
+               } else {
+                       return Integer.parseInt(str);
+               }
+       }
        
        /**
        *       An abstract market offer, entailing a commodity being bought or sold by
@@ -108,11 +116,7 @@ public class MarketUploader implements TopLevelWindowListener, GUIInitializedLis
                        commodity = commodId.intValue();
                        price = Integer.parseInt(record.get(priceIndex));
                        String qty = record.get(priceIndex+1);
-                       if(qty.equals(">1000")) {
-                               quantity = 1001;
-                       } else {
-                               quantity = Integer.parseInt(record.get(priceIndex+1));
-                       }
+                       quantity = parseQty(qty);
                        shoppe = stallMap.get(record.get(1)).intValue();
                }
                
@@ -378,12 +382,12 @@ public class MarketUploader implements TopLevelWindowListener, GUIInitializedLis
                        yarrgts = getYarrgTimestamp();
                }
 
-               AccessibleTable t = findMarketTable();
-               if(t == null) {
+               AccessibleTable accesstable = findMarketTable();
+               if(accesstable == null) {
                        error("Market table not found! Please open the Buy/Sell Commodities interface.");
                        return;
                }
-               if(t.getAccessibleRowCount() == 0) {
+               if(accesstable.getAccessibleRowCount() == 0) {
                        error("No data found, please wait for the table to have data first!");
                        return;
                }
@@ -399,7 +403,33 @@ public class MarketUploader implements TopLevelWindowListener, GUIInitializedLis
                    latch.await(2, java.util.concurrent.TimeUnit.SECONDS);
                }
 
-               ArrayList<ArrayList<String>> data = getData(t);
+               String headings_expected[] = new String[]
+                   { "Commodity", "Trading outlet", "Buy price", "Will buy", "Sell price", "Will sell" };
+               ArrayList<ArrayList<String>> headers = getData(accesstable.getAccessibleColumnHeader());
+               if (headers.size() != 1) {
+                   error("Table headings not one row! " + headers.toString());
+                   return;
+               }
+               if (headers.get(0).size() != 6) {
+                   error("Table headings not six columns! " + headers.toString());
+                   return;
+               }
+               for (int col=0; col<headings_expected.length; col++) {
+                   String expd = headings_expected[col];
+                   String got = headers.get(0).get(col);
+                   if (expd.compareTo(got) != 0) {
+                       error("Table heading for column "+col
+                             +" is not \""+expd+"\" but \""+got+"\".\n\n"
+                             +"Please do not reorder the table when using this tool.");
+                       return;
+                   }
+               }
+
+               ArrayList<ArrayList<String>> data = getData(accesstable);
+
+               if (false) {
+                       calculateArbitrage(data);
+               }
 
                if (uploadToYarrg && yarrgts != null) {
                        pm.setNote("Yarrg: Preparing data");
@@ -953,5 +983,71 @@ public class MarketUploader implements TopLevelWindowListener, GUIInitializedLis
        }
        return true;
     }
+
+    private int calculateArbitrageCommodity(ArrayList<SortedSet<int[]>> arb_bs) {
+       System.out.println("ARBITRAGE?");
+       int profit = 0;
+       SortedSet<int[]> buys = arb_bs.get(0);
+       SortedSet<int[]> sells = arb_bs.get(1);
+       while (true) {
+           int[] buy, sell;
+           try {
+               buy = buys.first();
+               sell = sells.last();
+           } catch (NoSuchElementException e) {
+               break;
+           }
+           int count = buy[1] < sell[1] ? buy[1] : sell[1];
+           System.out.println(" buy @"+buy[0]+" x"+buy[1]+" sell @"+sell[0]+" x"+sell[1]+" => x"+count);
+           profit += count * (buy[0] - sell[0]);
+           buy[1] -= count;
+           sell[1] -= count;
+           if (buy[1]==0) buys.remove(buy);
+           if (sell[1]==0) buys.remove(sell);
+       }
+       return profit;
+    }
+
+    private class arbitrageOfferComparator implements Comparator {
+       public int compare(Object o1, Object o2) {
+           int p1 = ((int[])o1)[0];
+           int p2 = ((int[])o2)[0];
+           return p2 - p1;
+       }
+    }
+
+    private @SuppressWarnings("unchecked") void calculateArbitrage(ArrayList<ArrayList<String>> data)
+           {
+       int arbitrage = 0;
+       ArrayList<SortedSet<int[]>> arb_bs = null;
+       String lastcommod = null;
+       Comparator compar = new arbitrageOfferComparator();
+
+       for (ArrayList<String> row : data) {
+           String thiscommod = row.get(0);
+           System.out.println("ROW "+row.toString());
+           if (lastcommod == null || !thiscommod.equals(lastcommod)) {
+               if (lastcommod != null)
+                   arbitrage += calculateArbitrageCommodity(arb_bs);
+               //System.out.println("ROW rdy");
+               arb_bs = new ArrayList<SortedSet<int[]>>(2);
+               arb_bs.add(0, new TreeSet<int[]>(compar));
+               arb_bs.add(1, new TreeSet<int[]>(compar));
+               System.out.println("ROW init");
+               lastcommod = thiscommod;
+           }
+           for (int bs = 0; bs < 2; bs++) {
+               String pricestr = row.get(bs*2 + 2);
+               if (pricestr == null)
+                   continue;
+               int[] entry = new int[2];
+               //System.out.println("ROW BS "+bs);
+               entry[0] = parseQty(pricestr);
+               entry[1] = parseQty(row.get(bs*2 + 3));
+               arb_bs.get(bs).add(entry);
+           }
+       }
+       arbitrage += calculateArbitrageCommodity(arb_bs);
+    }
     
 }