package nl.tudelft.simulation.examples.dsol.terminal;

import java.util.Properties;

import nl.tudelft.simulation.dsol.DSOLModel;
import nl.tudelft.simulation.dsol.SimRuntimeException;
import nl.tudelft.simulation.dsol.simtime.SimTimeDouble;
import nl.tudelft.simulation.dsol.simulators.DEVSSimulatorInterface;
import nl.tudelft.simulation.dsol.simulators.SimulatorInterface;
import nl.tudelft.simulation.event.EventInterface;
import nl.tudelft.simulation.event.EventListenerInterface;
import nl.tudelft.simulation.event.EventProducer;
import nl.tudelft.simulation.event.EventType;
import nl.tudelft.simulation.jstats.distributions.DistExponential;
import nl.tudelft.simulation.jstats.distributions.DistTriangular;
import nl.tudelft.simulation.jstats.streams.StreamInterface;

/**
 * A simple model of a container terminal. <br>
 * (c) copyright 2018 <a href="https://simulation.tudelft.nl">Delft University of Technology </a>, the Netherlands.
 * <br>
 * See for project information <a href="https://simulation.tudelft.nl">www.simulation.tudelft.nl </a> <br>
 * License of use: <a href="http://www.gnu.org/copyleft/gpl.html">General Public License (GPL) </a>, no warranty <br>
 * @version 2.0 21.09.2003 <br>
 * @author <a href="http://www.tudelft.nl/averbraeck">Alexander Verbraeck</a>
 */
public class Terminal extends EventProducer implements DSOLModel.TimeDouble, EventListenerInterface
{
    /** The default serial version UID for serializable classes. */
    private static final long serialVersionUID = 1L;

    /** the ship-full event. */
    public static final EventType READY_EVENT = new EventType("READY_EVENT");

    /** the simulator. */
    private SimulatorInterface.TimeDouble simulator;

    /** QCs. */
    private int numQC = 5;

    /** AGVs. */
    private int numAGV = 25;

    /** replication nr. */
    private final int rep;

    /** debug info or not. */
    public static final boolean DEBUG = false;

    /** the ship for pub/sub when ready. */
    private Ship ship;

    /**
     * constructor for the Container Terminal.
     * @param rep the replication number
     */
    public Terminal(final int rep)
    {
        super();
        this.rep = rep;
    }

    /** {@inheritDoc} */
    @Override
    public final void constructModel(final SimulatorInterface<Double, Double, SimTimeDouble> pSimulator)
            throws SimRuntimeException
    {
        this.simulator = (DEVSSimulatorInterface.TimeDouble) pSimulator;
        DEVSSimulatorInterface.TimeDouble devsSimulator = (DEVSSimulatorInterface.TimeDouble) pSimulator;

        StreamInterface defaultStream = devsSimulator.getReplication().getStream("default");

        Properties properties = pSimulator.getReplication().getTreatment().getProperties();
        this.numQC = Integer.parseInt(properties.getProperty("numQC"));
        this.numAGV = Integer.parseInt(properties.getProperty("numAGV"));
        int numCont = 3000;

        QC qc = new QC(devsSimulator, "QC", this.numQC, new DistExponential(defaultStream, 60. / 30.));
        AGV agv = new AGV(devsSimulator, "AGV", this.numAGV, new DistTriangular(defaultStream, 7, 9, 14));
        this.ship = new Ship(numCont);

        this.ship.addListener(this, Ship.SHIP_FULL_EVENT);

        for (int c = 0; c < numCont; c++)
        {
            new Container(devsSimulator, c, qc, agv, this.ship);
        }
    }

    /** {@inheritDoc} */
    @Override
    public final SimulatorInterface<Double, Double, SimTimeDouble> getSimulator()
    {
        return this.simulator;
    }

    /**
     * @return the ship for pub/sub
     */
    public Ship getShip()
    {
        return this.ship;
    }

    /** {@inheritDoc} */
    @Override
    public void notify(final EventInterface event)
    {
        if (event.getType().equals(Ship.SHIP_FULL_EVENT))
        {
            try
            {
                this.simulator.stop();
                double ready = this.simulator.getSimulatorTime() / 60.0;
                double delayHours = Math.max(0.0, Math.ceil(ready) - 20.0);
                if (DEBUG)
                {
                    System.out.println("Delay = " + delayHours);
                }
                double costs = Math.max(20.0, Math.ceil(ready)) * (300.0 * this.numQC + 12.0 * this.numAGV)
                        + 2500.0 * delayHours;
                if (DEBUG)
                {
                    System.out.println("Costs = " + costs);
                }
                int nrCont = (Integer) event.getContent();
                fireEvent(Terminal.READY_EVENT,
                        new Output(this.numQC, this.numAGV, this.rep, delayHours, costs, ready, nrCont));
            }
            catch (SimRuntimeException exception)
            {
                exception.printStackTrace();
            }
        }
    }

    /** */
    public static class Output
    {
        /** QCs. */
        private final int numQC;

        /** AGVs. */
        private final int numAGV;

        /** replication nr. */
        private final int rep;

        /** delay. */
        private final double delayHours;

        /** costs. */
        private final double costs;

        /** time when ready in hrs. */
        private final double ready;

        /** nr containers handled. */
        private final int nrCont;

        /**
         * /**
         * @param numQC qc
         * @param numAGV agv
         * @param rep replication nr
         * @param delayHours delay in hours
         * @param costs costs in Euros
         * @param ready time when ready in hrs
         * @param nrCont nr containers handled
         */
        public Output(final int numQC, final int numAGV, final int rep, final double delayHours, final double costs,
                final double ready, final int nrCont)
        {
            super();
            this.numQC = numQC;
            this.numAGV = numAGV;
            this.rep = rep;
            this.delayHours = delayHours;
            this.costs = costs;
            this.ready = ready;
            this.nrCont = nrCont;
        }

        /**
         * @return numQC
         */
        public final int getNumQC()
        {
            return this.numQC;
        }

        /**
         * @return numAGV
         */
        public final int getNumAGV()
        {
            return this.numAGV;
        }

        /**
         * @return rep
         */
        public final int getRep()
        {
            return this.rep;
        }

        /**
         * @return delayHours
         */
        public final double getDelayHours()
        {
            return this.delayHours;
        }

        /**
         * @return costs
         */
        public final double getCosts()
        {
            return this.costs;
        }

        /**
         * @return ready
         */
        public final double getReady()
        {
            return this.ready;
        }

        /**
         * @return nrCont
         */
        public final int getNrCont()
        {
            return this.nrCont;
        }
    }
}