/*
    * @(#)GameGlobalData.java Jul 10, 2004
    * 
    * Copyright (c) 2003-2005 Delft University of Technology, Jaffalaan 5, 2628 BX
    * Delft, the Netherlands. All rights reserved.
    * 
    * See for project information <a href="http://www.simulation.tudelft.nl/">
    * www.simulation.tudelft.nl </a>.
    * 
   * The source code and binary code of this software is proprietary information
   * of Delft University of Technology.
   */
  
  package org.gscg.game;
  
  import java.io.BufferedWriter;
  import java.io.FileWriter;
  import java.io.Serializable;
  import java.text.DateFormat;
  import java.util.Calendar;
  import java.util.Collection;
  import java.util.HashMap;
  import java.util.Iterator;
  import java.util.List;
  import java.util.Map;
  import java.util.TreeMap;
  
  import nl.tudelft.simulation.dsol.experiment.TimeUnit;
  import nl.tudelft.simulation.dsol.experiment.TimeUnitInterface;
  import nl.tudelft.simulation.dsol.simulators.DEVSSimulatorInterface;
  import nl.tudelft.simulation.dsol.simulators.SimulatorInterface;
  import nl.tudelft.simulation.language.swing.SwingWorker;
  import nl.tudelft.simulation.logger.Logger;
  import nl.tudelft.simulation.naming.InitialEventContext;
  import nl.tudelft.simulation.supplychain.actor.SupplyChainActor;
  import nl.tudelft.simulation.supplychain.content.Bill;
  import nl.tudelft.simulation.supplychain.product.Product;
  
  import org.gscg.common.GameActorInterface;
  import org.gscg.common.interactionlayer.location.YellowPage;
  import org.gscg.gameactors.GameDistributorInteractive;
  
  /***
   * The GameGlobalData contains all the data of the game, e.g. the products and
   * actors. Furthermore it takes care of providing game-wide statistics. <br>
   * Copyright (c) 2003-2005 Delft University of Technology, Jaffalaan 5, 2628 BX
   * Delft, the Netherlands. All rights reserved.
   * 
   * See for project information <a href="http://www.simulation.tudelft.nl/">
   * www.simulation.tudelft.nl </a>.
   * 
   * The source code and binary code of this software is proprietary information
   * of Delft University of Technology.
   * 
   * @author <a
   *         href="http://www.tbm.tudelft.nl/webstaf/alexandv/index.htm">Alexander
   *         Verbraeck </a>
   * @version $Revision: 1.1 $ $Date: 2005/08/03 08:52:49 $
   * @since 1.0.0 <br>
   */
  
  public class GameGlobalData implements Serializable
  {
  	/*** the serial version uid */
  	private static final long serialVersionUID = 11L;
  
  	/*** the name of this object in the context */
  	public static final String CONTEXT_NAME = "GAME_GLOBAL_DATA";
  
  	/*** the map of product names to product objects */
  	private Map products = new HashMap();
  
  	/*** the map of actor names to actor objects */
  	private Map actors = new HashMap();
  
  	/*** the locations and names of the actors */
  	private YellowPage yellowPage = new YellowPage();
  
  	/*** the simulator to use */
  	private SimulatorInterface simulator = null;
  
  	/***
  	 * constructs a new GlobalSupplyChainData
  	 * 
  	 * @param simulator the simulator to use
  	 */
  	public GameGlobalData(final SimulatorInterface simulator)
  	{
  		super();
  		// we bind ourselves into the context
  		try
  		{
  			new InitialEventContext().bind(GameGlobalData.CONTEXT_NAME, this);
  		} catch (Exception exception)
  		{
  			Logger.severe(this, "<init>", exception);
  		}
  
  		this.simulator = simulator;
 
 		// schedule the tally
 
 		/*
 		 * try { ((DEVSSimulatorInterface) this.simulator).scheduleEvent(1.1,
 		 * TimeUnitInterface.DAY, this, this, "printTally", new Object[]{}); }
 		 * catch (Exception exception) { Logger.severe(this, " <init>",
 		 * exception); }
 		 */
 		// schedule output of the balance sheet
 		try
 		{
 			((DEVSSimulatorInterface) this.simulator).scheduleEvent(1.1,
 					TimeUnitInterface.DAY, this, this, "printBalanceSheet",
 					new Object[]{});
 		} catch (Exception exception)
 		{
 			Logger.severe(this, " <init>", exception);
 		}
 
 	}
 
 	/***
 	 * @param product the product to add
 	 */
 	public void addProduct(final Product product)
 	{
 		this.products.put(product.getName(), product);
 	}
 
 	/***
 	 * @param name the name of the product to get
 	 * @return returns the Product
 	 */
 	public Product getProduct(final String name)
 	{
 		return (Product) this.products.get(name);
 	}
 
 	/***
 	 * @return returns a collection of Products
 	 */
 	public Collection getProducts()
 	{
 		return this.products.values();
 	}
 
 	/***
 	 * @param actor the actor to add
 	 * @param actorType the type of the actor
 	 * @param interactive indicates whether the actor is human controlled or not
 	 */
 	public void addSupplyChainActor(final SupplyChainActor actor,
 			final String actorType, final boolean interactive)
 	{
 		this.actors.put(actor.getName(), actor);
 		this.yellowPage.addActor((GameActorInterface) actor, actorType,
 				interactive);
 	}
 
 	/***
 	 * @param name the name of the actor to get
 	 * @return returns a SupplyChain actor
 	 */
 	public SupplyChainActor getSupplyChainActor(final String name)
 	{
 		return (SupplyChainActor) this.actors.get(name);
 	}
 
 	/***
 	 * @return returns a collection of SupplyChainActors
 	 */
 	public Collection getSupplyChainActors()
 	{
 		return this.actors.values();
 	}
 
 	/***
 	 * @return Returns the yellowPage.
 	 */
 	public YellowPage getYellowPage()
 	{
 		return this.yellowPage;
 	}
 
 	/***
 	 * Prints a balance sheet to the output stream
 	 */
 	protected void printBalanceSheet()
 	{
 		SwingWorker worker = new SwingWorker()
 		{
 			/***
 			 * @see nl.tudelft.simulation.language.swing.SwingWorker#construct()
 			 */
 			public Object construct()
 			{
 				GameGlobalData.this.balanceSheetWorker();
 				return null;
 			}
 		};
 		worker.start();
 
 		try
 		{
 			((DEVSSimulatorInterface) this.simulator).scheduleEvent(7.0,
 					TimeUnitInterface.DAY, this, this, "printBalanceSheet",
 					new Object[]{});
 		} catch (Exception exception)
 		{
 			Logger.severe(this, "printBalanceSheet", exception);
 		}
 	}
 
 	/***
 	 * Prints a tally to the output stream
 	 */
 	protected void printTally()
 	{
 		SwingWorker worker = new SwingWorker()
 		{
 			/***
 			 * @see nl.tudelft.simulation.language.swing.SwingWorker#construct()
 			 */
 			public Object construct()
 			{
 				GameGlobalData.this.tallyWorker();
 				return null;
 			}
 		};
 		worker.start();
 
 		try
 		{
 			((DEVSSimulatorInterface) this.simulator).scheduleEvent(30.1,
 					TimeUnitInterface.DAY, this, this, "printTally",
 					new Object[]{});
 		} catch (Exception exception)
 		{
 			Logger.severe(this, "printTally", exception);
 		}
 
 	}
 
 	/***
 	 * Executed in a swing thread.
 	 */
 	private void tallyWorker()
 	{
 		try
 		{
 			double time = Math.round(TimeUnit.convert(this.simulator
 					.getSimulatorTime(), this.simulator.getReplication()
 					.getRunControl().getTreatment().getTimeUnit(),
 					TimeUnitInterface.DAY));
 
 			Calendar calendar = Calendar.getInstance();
 			calendar.setTimeInMillis(System.currentTimeMillis());
 			String date = DateFormat.getDateTimeInstance().format(
 					calendar.getTime());
 
 			// replace any :
 			String[] dates = date.split(":");
 			date = dates[0] + "_" + dates[1] + "_" + dates[2];
 
 			// we pause for a brief moment
 			// this.simulator.stop();
 
 			// we write these objects first since they are used to create a
 			// context
 			BufferedWriter out = new BufferedWriter(new FileWriter("_TALLY"
 					+ " time in days " + time + " wallclock " + date + ".xls"));
 
 			// the headers
 			out.write("Name" + "\t");
 			out.write("Location" + "\t");
 			out.write("Bank Account" + "\t");
 			out.write("Product" + "\t");
 			out.write("Actual Amount" + "\t");
 			out.write("Value" + "\t");
 			out.write("Claimed Amount" + "\t");
 			out.write("Value" + "\t");
 			out.write("Ordered Amount" + "\t");
 			out.write("Value" + "\t");
 			out.write("" + "\n");
 
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				double finpos = 0.0;
 
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					out.write(interactive.getName() + "\t"
 							+ interactive.getLocationDescription() + "\t" + ""
 							+ interactive.getBankAccount().getBalance() + "\t");
 					finpos += interactive.getBankAccount().getBalance();
 					for (Iterator stockIterator = interactive.getStock()
 							.iterator(); stockIterator.hasNext();)
 					{
 						Product product = (Product) stockIterator.next();
 						out.write(product.getName() + "\t");
 						out.write(""
 								+ interactive.getStock().getActualAmount(
 										product) + "\t");
 						double actualValue = interactive.getStock()
 								.getActualAmount(product)
 								* product.getUnitMarketPrice();
 						finpos += actualValue;
 						out.write("" + actualValue + "\t");
 						out.write(""
 								+ interactive.getStock().getClaimedAmount(
 										product) + "\t");
 						double claimedValue = interactive.getStock()
 								.getClaimedAmount(product)
 								* product.getUnitMarketPrice();
 						// finpos += claimedValue;
 						out.write("" + claimedValue + "\t");
 						out.write(""
 								+ interactive.getStock().getOrderedAmount(
 										product) + "\t");
 						double orderedValue = interactive.getStock()
 								.getOrderedAmount(product)
 								* product.getUnitMarketPrice();
 						finpos -= orderedValue;
 						out.write("" + orderedValue + "\t");
 
 					}
 					// the financial position
 					out.write("" + finpos + "\n");
 				}
 			}
 
 			// close the stream
 			out.close();
 
 		} catch (Exception exception)
 		{
 			// TODO make logger dependent
 			exception.printStackTrace();
 		}
 
 		/*
 		 * try { this.simulator.start(); } catch (Exception exception) {
 		 * Logger.severe(this, "printTally", exception); }
 		 */
 		Logger.info(this, "printTally", "GlobalSupplyChainData: tally written");
 	}
 
 	/***
 	 * Executed in a swing thread.
 	 */
 	private void balanceSheetWorker()
 	{
 		try
 		{
 			// the intermediate results
 			Map assetsPerActor = new TreeMap();
 			Map liabilitiesPerActor = new TreeMap();
 			Map equityPerActor = new TreeMap();
 
 			double time = Math.round(TimeUnit.convert(this.simulator
 					.getSimulatorTime(), this.simulator.getReplication()
 					.getRunControl().getTreatment().getTimeUnit(),
 					TimeUnitInterface.DAY));
 
 			Calendar calendar = Calendar.getInstance();
 			calendar.setTimeInMillis(System.currentTimeMillis());
 			String date = DateFormat.getDateTimeInstance().format(
 					calendar.getTime());
 
 			// replace any :
 			String[] dates = date.split(":");
 			date = dates[0] + "_" + dates[1] + "_" + dates[2];
 
 			// we pause for a brief moment
 			// this.simulator.stop();
 
 			// we write these objects first since they are used to create a
 			// context
 			BufferedWriter out = new BufferedWriter(new FileWriter(
 					"_BALANCESHEET" + " time in days " + time + " wallclock "
 							+ date + ".xls"));
 
 			// the headers
 			out.write("Balance sheet " + " time in days " + time
 					+ " wallclock " + date + "\n");
 			out.write("\n");
 
 			// the names of the actors
 			out.write("Name\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					out.write(interactive.getName() + "\t");
 				}
 			}
 			out.write("\n");
 
 			// the locations of the actors
 			out.write("Location\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					out.write(interactive.getLocationDescription() + "\t");
 				}
 			}
 			out.write("\n");
 
 			// cash
 			out.write("\nASSETS\nCash & equivalents\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					out.write(Math.round(interactive.getBankAccount()
 							.getBalance())
 							+ "\t");
 					assetsPerActor.put(interactive.getName(), new Double(
 							interactive.getBankAccount().getBalance()));
 				}
 			}
 			out.write("\n");
 
 			// accounts receivable
 			out.write("Accounts receivable\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					double ar = 0.0;
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					for (Iterator stockIterator = interactive.getStock()
 							.iterator(); stockIterator.hasNext();)
 					{
 						Product product = (Product) stockIterator.next();
 						List billList = interactive.getGameContentStore()
 								.getAllProductContent(Bill.class, true,
 										product.getName());
 						for (Iterator billIterator = billList.iterator(); billIterator
 								.hasNext();)
 						{
 							Bill bill = (Bill) billIterator.next();
 							if (!bill.isPaid())
 							{
 								ar += bill.getPrice();
 							}
 						}
 					}
 					out.write(Math.round(ar) + "\t");
 					assetsPerActor.put(interactive.getName(),
 							new Double(((Double) assetsPerActor.get(interactive
 									.getName())).doubleValue()
 									+ ar));
 				}
 			}
 			out.write("\n");
 
 			// inventory after depreciation
 			out.write("Inventory\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					double inv = 0.0;
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					for (Iterator stockIterator = interactive.getStock()
 							.iterator(); stockIterator.hasNext();)
 					{
 						Product product = (Product) stockIterator.next();
 						inv += interactive.getStock().getActualAmount(product)
 								* interactive.getStock().getUnitPrice(product);
 					}
 					out.write(Math.round(inv) + "\t");
 					assetsPerActor.put(interactive.getName(),
 							new Double(((Double) assetsPerActor.get(interactive
 									.getName())).doubleValue()
 									+ inv));
 				}
 			}
 			out.write("\n");
 
 			// total assets
 			out.write("TOTAL ASSETS\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					double as = ((Double) assetsPerActor.get(interactive
 							.getName())).doubleValue();
 					out.write(Math.round(as) + "\t");
 				}
 			}
 			out.write("\n");
 
 			// accounts payable
 			out.write("\nLIABILITIES\nAccounts payable\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					double ap = 0.0;
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					for (Iterator stockIterator = interactive.getStock()
 							.iterator(); stockIterator.hasNext();)
 					{
 						Product product = (Product) stockIterator.next();
 						List billList = interactive.getGameContentStore()
 								.getAllProductContent(Bill.class, false,
 										product.getName());
 						for (Iterator billIterator = billList.iterator(); billIterator
 								.hasNext();)
 						{
 							Bill bill = (Bill) billIterator.next();
 							if (!bill.isPaid())
 							{
 								ap += bill.getPrice();
 							}
 						}
 					}
 					out.write(Math.round(ap) + "\t");
 					liabilitiesPerActor.put(interactive.getName(), new Double(
 							ap));
 				}
 			}
 			out.write("\n");
 
 			// total liabilities
 			out.write("TOTAL LIABILITIES\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					double li = ((Double) liabilitiesPerActor.get(interactive
 							.getName())).doubleValue();
 					out.write(Math.round(li) + "\t");
 				}
 			}
 			out.write("\n");
 
 			// equity
 			out.write("\nEQUITY\t");
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					double eq = ((Double) assetsPerActor.get(interactive
 							.getName())).doubleValue()
 							- ((Double) liabilitiesPerActor.get(interactive
 									.getName())).doubleValue();
 					equityPerActor.put(interactive.getName(), new Double(eq));
 					out.write(Math.round(eq) + "\t");
 				}
 			}
 			out.write("\n");
 
 			// close the stream
 			out.close();
 
 			//
 			// WRITE A TOTAL EQUITY FILE
 			//
 
 			BufferedWriter eqout = new BufferedWriter(new FileWriter(
 					"_EQUITYSHEET" + " time in days " + time + " wallclock "
 							+ date + ".xls"));
 
 			// the headers
 			eqout.write("Total balance sheet per player " + " time in days "
 					+ time + " wallclock " + date + "\n");
 			eqout.write("\n");
 
 			// sort on equity
 			Map sortedPlayersOnEquity = new TreeMap();
 			for (Iterator it = this.actors.keySet().iterator(); it.hasNext();)
 			{
 				Object actor = this.actors.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					double eq = ((Double) equityPerActor.get(interactive
 							.getName())).doubleValue();
 					String key = "" + Math.round(eq);
 					while (key.length() < 11)
 					{
 						key = "0" + key;
 					}
 					key = key + interactive.getName();
 					sortedPlayersOnEquity.put(key, interactive);
 				}
 			}
 
 			// the names of the actors
 			eqout.write("Name\tLocation\tAssets\tLiabilities\tEquity\n");
 			for (Iterator it = sortedPlayersOnEquity.keySet().iterator(); it
 					.hasNext();)
 			{
 				Object actor = sortedPlayersOnEquity.get(it.next());
 				if (actor instanceof GameDistributorInteractive)
 				{
 					GameDistributorInteractive interactive = (GameDistributorInteractive) actor;
 					eqout.write(interactive.getName()
 							+ "\t"
 							+ interactive.getLocationDescription()
 							+ "\t"
 							+ Math.round(((Double) assetsPerActor
 									.get(interactive.getName())).doubleValue())
 							+ "\t"
 							+ Math.round(((Double) liabilitiesPerActor
 									.get(interactive.getName())).doubleValue())
 							+ "\t"
 							+ Math.round(((Double) equityPerActor
 									.get(interactive.getName())).doubleValue())
 							+ "\n");
 				}
 			}
 
 			// close the stream
 			eqout.close();
 
 		} catch (Exception exception)
 		{
 			// TODO make logger dependent
 			exception.printStackTrace();
 		}
 
 		/*
 		 * try { this.simulator.start(); } catch (Exception exception) {
 		 * Logger.severe(this, "printTally", exception); }
 		 */
 		Logger.info(this, "printbalanceSheet",
 				"GlobalSupplyChainData: Balance Sheet written");
 	}
 }