TradeCycle.java

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package nrftw_trade;
import java.util.List;  
import java.util.ArrayList;
import java.util.Iterator;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;
import java.util.HashMap;
import java.util.Collections;

/**
 *
 * @author sandy
 */


public class TradeCycle {
    
    TradeCycle(){
        
    }
    
    public void run(ArrayList theMarkets, ArrayList theCommodities, ArrayList theTags){
        //The trade cycle
        //for each market. 
        for(Iterator<Market> aMarketItterator = theMarkets.iterator(); aMarketItterator.hasNext();){
            Market aMarket = aMarketItterator.next();
            //for each commodity
            System.out.println(aMarket.theName);
            for(Iterator<Commodity> aCommodityItterator = theCommodities.iterator(); aCommodityItterator.hasNext();){
                Commodity aCommodity = aCommodityItterator.next();
                System.out.println(aCommodity.theName);
                String getPRateQuery = "select p_rate, stock from trade_matrix where market_name = '"+aMarket.theName+"' and commodity_name = '"+aCommodity.theName+"'";
                ResultSet pRateResults = NRFTW_Trade.dBQuery(getPRateQuery);
                int productionRate = 0;
                int stockPile = 0;
                try{
                    while(pRateResults.next()){
                        productionRate = pRateResults.getInt(1);
                        stockPile = pRateResults.getInt(2);
                }
                }catch(SQLException ex){
                    System.out.println(ex);
                } 
                //@todo - amalgamate prices into trade matrix db table
                String getPriceQuery = "select price from prices where market = '"+aMarket.theName+"' and commodity = '"+aCommodity.theName+"'";
                ResultSet priceResults = NRFTW_Trade.dBQuery(getPriceQuery);
                int price = 0;
                
                try{
                    while(pRateResults.next()){
                        price = priceResults.getInt(1);
                        
                }
                }catch(SQLException ex){
                    System.out.println(ex);
                } 
                //for each point of produciton rate
                System.out.println("Producing");
                for(int i=1;i<=productionRate;i++)
                {                
                    //add a unit to the stock pile
                    stockPile++;
                    //alter the price downwards price
                    if(price > 0){
                        price = (price - ((price/stockPile)/2));
                    }
                }
                //  write new stock and price to DB
                String stockInsertion = "update trade_matrix set stock = "+stockPile+" where market_name = '"+aMarket.theName+"' and commodity_name = '"+aCommodity.theName+"'";
                NRFTW_Trade.dBUpdate(stockInsertion);
                String newPrice = "update prices set price = "+price+"  where market = '"+aMarket.theName+"' and commodity = '"+aCommodity.theName+"'";
                NRFTW_Trade.dBUpdate(newPrice);
            //close comodity loop
            }
            //for each tag
            for(Iterator<Tag> aTagItterator = theTags.iterator(); aTagItterator.hasNext();){
                Tag aTag = aTagItterator.next();
                //get consumption rate
                String getPRateQuery = "select c_rate from trade_matrix where market_name = '"+aMarket.theName+"' and tag_name = '"+aTag.theName+"' and tag_grade = '"+aTag.theGrade+"'";
                ResultSet pRateResults = NRFTW_Trade.dBQuery(getPRateQuery);
                System.out.println("consuming: "+aTag.theName+" :1");
                int consumptionRate = 0;
                System.out.println("consuming: "+aTag.theName+" :2");
                try{
                    while(pRateResults.next()){
                        System.out.println("consuming: "+aTag.theName+" :3");
                        consumptionRate = pRateResults.getInt(1);            
                        System.out.println("consuming: "+aTag.theName+" :4");
                    }
                }catch(SQLException ex){
                    System.out.println(ex);
                } 		
                System.out.println("consuming: "+aTag.theName+" :5");
		//get each comodity
                    //include any of a higher tag
                String commodityQuery = "select trade_matrix.commodity_name, trade_matrix.stock, prices.price from trade_matrix inner join prices on trade_matrix.commodity_name = prices.commodity and trade_matrix.market_name = prices.market where trade_matrix.commodity_name in (select commodity from commodities_tags where tag = '"+aTag.theName+"' and grade >= "+aTag.theGrade+") and trade_matrix.market_name = '"+aMarket.theName+"' order by price asc";
                System.out.println("consuming: "+aTag.theName+" :6");
                System.out.println(commodityQuery);
                ResultSet commodityResults = NRFTW_Trade.dBQuery(commodityQuery);
                System.out.println("consuming: "+aTag.theName+" :7");
                ArrayList theConsumedCommodities = new ArrayList();
                System.out.println("consuming: "+aTag.theName+" :8");
                try{                   
                    while(commodityResults.next()){
                        System.out.println("consuming: "+aTag.theName+" :9");
                        String thisCommodityName = commodityResults.getString(1);
                        System.out.println("consuming: "+aTag.theName+" :10");
                        int thisCommodityStock = commodityResults.getInt(2);
                        System.out.println("consuming: "+aTag.theName+" :11");
                        int thisCommodityPrice = commodityResults.getInt(3);
                        System.out.println("consuming: "+aTag.theName+" :12");
                        Commodity thisCommodity = new Commodity(thisCommodityName,thisCommodityStock,thisCommodityPrice);
                        System.out.println("consuming: "+aTag.theName+" :13");
                        theConsumedCommodities.add(thisCommodity);
                        System.out.println("consuming: "+aTag.theName+" :14");
                        Collections.sort(theConsumedCommodities);
                        System.out.println("consuming: "+aTag.theName+" :15");
        		//rank by local price
                    }                                                                  
                }catch(SQLException ex){
                    System.out.println(ex);
                } 
                //loop until consumption rate is satisfied
                int fulfilledConsumption = 0;
                System.out.println("consuming: "+aTag.theName+" :16");
                while(fulfilledConsumption < consumptionRate){  
                    System.out.println("consuming: "+aTag.theName+" :17");                    
                    //get cheapest commodity
                    if(theConsumedCommodities.size() > 0){
                        System.out.println("consuming: "+aTag.theName+" :18");
                        Commodity forConsumption = (Commodity) theConsumedCommodities.get(0);
                        System.out.println("consuming: "+aTag.theName+" :19");
                            //if commodity has stockpile
                            if(forConsumption.theStockLevel > 0){
                                //..consume unit of that commodity
                                if(forConsumption.thePrice == 0){
                                    System.out.println("consuming: "+aTag.theName+" :20");
                                    forConsumption.thePrice ++;
                                }
                                forConsumption.thePrice = (forConsumption.thePrice + ((forConsumption.thePrice/forConsumption.theStockLevel)/2));
                                //adjust price of commodity
                                forConsumption.theStockLevel --;
                                System.out.println("consuming: "+aTag.theName+" :21");
                            }else{
                                //adjust price of commodity by more
                                forConsumption.thePrice = (forConsumption.thePrice + (forConsumption.thePrice/2));
                                System.out.println("consuming: "+aTag.theName+" :22");
                            }
                        //add one to consumption rate satisfaction
                        fulfilledConsumption ++;
                        // resort commodities\
                        System.out.println("consuming: "+aTag.theName+" :23");
                    }else{
                        System.out.println("cannot resolve consumed commodities for '"+aTag.theName+"' in '"+aMarket.theName+"' The database is incomplete. Terminating.");
                        System.exit(0);
                    }
                }
            //close tag loop
            }
        //close market loop 
        }
        System.out.println("Trading");
        //for each market
        for(Iterator<Market> aMarketItterator = theMarkets.iterator(); aMarketItterator.hasNext();){
            Market aMarket = aMarketItterator.next();
            //for each comodity
            System.out.println(aMarket.theName);
            for(Iterator<Commodity> aCommodityItterator = theCommodities.iterator(); aCommodityItterator.hasNext();){
                Commodity theTradingCommodity = aCommodityItterator.next();
                System.out.println(theTradingCommodity.theName);
                //trade loop (loop until no trade is made)
                boolean tradeHappens = true; 
                while(tradeHappens = true){
                    tradeHappens= false;
                    //if stockpile <=0
                    String stockpileQuery = "select stock from trade_matrix where market_name = '"+aMarket.theName+"'and commodity_name ='"+theTradingCommodity.theName+"'";
                    ResultSet stockpileResults = NRFTW_Trade.dBQuery(stockpileQuery);
                    int stockpile = 0;
                    boolean commodityShortage = false;
                    try{
                        while(stockpileResults.next()){
                            stockpile = stockpileResults.getInt(1);                        
                        }
                    }catch(SQLException ex){
                        System.out.println(ex);
                    }        
                    if(stockpile <= 0){    
                        //mark commodity shortage
                        commodityShortage = true;
                    }
                    //find cheapest linked market
                    //get all linked markets
                    Integer bestPrice = null;
                    String bestMarket = "";
                    Integer bestRouteID = null;
                    ArrayList linkedRoutes = NRFTW_Trade.getTradeRoutesByStart(aMarket.theName);
                    HashMap<String, Integer> totalSold = new HashMap<String, Integer>();                    
                    for(Iterator<TradeRoute> linkedRoutesIterator = linkedRoutes.iterator(); linkedRoutesIterator.hasNext();){ 
                        //store cheapest price market;
                        TradeRoute thisTR = linkedRoutesIterator.next();
                        String linkedMarket = "";
                        if(!thisTR.startPoint.equals(aMarket.theName)){
                            linkedMarket = thisTR.startPoint;
                        }else
                            if(!thisTR.endPoint.equals(aMarket.theName)){
                                linkedMarket = thisTR.endPoint;
                        }
                        totalSold.put(linkedMarket,0);
                        Integer thisPrice = null;
                        String priceQuery = "select price from prices where commodity = '"+theTradingCommodity.theName+"' and market = '"+linkedMarket+"'";
                        ResultSet priceResult = NRFTW_Trade.dBQuery(priceQuery);
                        try{
                            while(priceResult.next()){
                                thisPrice = priceResult.getInt(1);
                            }
                        }catch(SQLException ex){
                            System.out.println(ex);
                        }
                        if(bestPrice == null){
                            bestPrice = thisPrice;
                            bestMarket = linkedMarket;
                            bestRouteID = thisTR.id;
                            
                        }else
                        if(thisPrice < bestPrice){
                            bestPrice = thisPrice;
                            bestMarket = linkedMarket;
                            bestRouteID = thisTR.id;
                        }
                    }
                    if(bestRouteID != null){
                        int stock = 0;
                        Integer transferRate = null;
                        int localPrice = 0;
                        String transferRateQuery = "select rate from route_capacity where commodity = '"+theTradingCommodity.theName+"' and route = '"+bestRouteID+"'";
                        ResultSet tRateResult = NRFTW_Trade.dBQuery(transferRateQuery);
                        try{
                            while(tRateResult.next()){
                                transferRate = tRateResult.getInt(1);
                            }   
                        }catch(SQLException ex){
                             System.out.println(ex);
                        }
                        String stockQuery = "select stock from trade_matrix where commodity_name = '"+theTradingCommodity.theName+"'and market_name ='"+bestMarket+"'";
                        ResultSet stockResult = NRFTW_Trade.dBQuery(stockQuery);
                        try{
                            while(stockResult.next()){
                                stock =stockResult.getInt(1);
                            }
                        }catch(SQLException ex){
                            System.out.println(ex);
                        }
                        int thisTotalSold = totalSold.get(bestMarket);
                        //if market has stock & transfer total < tranfer rate & linked price < local price
                        if(stock > 0 && transferRate >= thisTotalSold && bestPrice < localPrice){
                            int localStock = 0;
                            String localStockQuery = "select stock from trade_matrix where commodity_name = '"+theTradingCommodity.theName+"'and market_name ='"+aMarket.theName+"'";
                            ResultSet localStockResult = NRFTW_Trade.dBQuery(localStockQuery);
                            try{
                                while(localStockResult.next()){
                                    localStock =stockResult.getInt(1);
                                }
                            }catch(SQLException ex){
                                System.out.println(ex);
                            }                          
                            totalSold.put(bestMarket,thisTotalSold+1);
                            tradeHappens = true;
                            //subtract 1 unit from linked market stockpile
                            String linkedStockDownQuery = "update trade_matrix set stock = "+(stock - 1)+" commodity_name = '"+theTradingCommodity.theName+"'and market_name ='"+bestMarket+"'";
                            NRFTW_Trade.dBUpdate(linkedStockDownQuery);
                            //adjust linked marked price up
                            int newLinkedPrice = bestPrice + ((bestPrice/stock)/2);
                            String linkedPriceUpQuery = "update prices set price = "+newLinkedPrice+" where market = '"+bestMarket+"' and commodity = '"+theTradingCommodity.theName+"'";
                            NRFTW_Trade.dBUpdate(linkedPriceUpQuery);
                            //add  1 unit to local stock pile
                            String localStockUpQuery = "update trade_matrix set stock = "+(localStock+1)+" commodity_name = '"+theTradingCommodity.theName+"'and market_name ='"+aMarket.theName+"'";
                            NRFTW_Trade.dBUpdate(linkedStockDownQuery);
                            int newLocalPrice = 0;
                            if(localStock >= 0){
                                newLocalPrice = (localPrice - (localPrice/2));
                            }else{
                                newLocalPrice = (localPrice - ((localPrice/localStock)/2));
                            }
                            //adjust local price down
                            String localPriceDownQuery = "update prices set price = "+newLocalPrice+" where market = '"+aMarket.theName+"' and commodity = '"+theTradingCommodity.theName+"'";;
                            NRFTW_Trade.dBUpdate(localPriceDownQuery);
                            //forConsumption.thePrice + ((forConsumption.thePrice/forConsumption.theStockLevel)/2
                        }
                    }
		//Close trade loop
                }
            //close comodity loop
            }
        //close market loop
        }
    }
}