package org.opentrafficsim.sim0mq.kpi;
   
   import java.io.Serializable;
   
   import org.djunits.unit.SpeedUnit;
   import org.djunits.value.vdouble.scalar.Speed;
   import org.djunits.value.vdouble.scalar.Time;
   import org.opentrafficsim.kpi.sampling.indicator.MeanSpeed;
   import org.opentrafficsim.kpi.sampling.indicator.MeanTravelTimePerKm;
  import org.opentrafficsim.kpi.sampling.indicator.MeanTripLength;
  import org.opentrafficsim.kpi.sampling.indicator.TotalDelay;
  import org.opentrafficsim.kpi.sampling.indicator.TotalNumberOfStops;
  import org.opentrafficsim.kpi.sampling.indicator.TotalTravelDistance;
  import org.opentrafficsim.kpi.sampling.indicator.TotalTravelTime;
  
  /**
   * OTS can publish messages about statistics or Key Performance Indicators (KPIs) of the relation between GTUs and a part of the
   * network. Examples are average speeds, travel times, trip durations, and number of stops. The statistics can be transmitted
   * via IMB at certain intervals. The statistics are based on the classes in the ots.road.sampling package. Most statistics
   * consider a time interval (can be unbound) and a region in space (a collection of lanes; can be the entire network), filtered
   * on metadata such as GTU type, origin, destination, or route.<br>
   * When a statistic is published for the first time, a NEW message is sent to IMB to identify the type of statistic, the time
   * interval and the lane(s) for which the statistic is calculated, and the metadata used to filter the GTUs. The CHANGE message
   * is posted whenever an updated statistic is available, or when the sample frequency time is reached. When a statistic is no
   * longer published, a DELETE event is posted. The Graph NEW messages are posted after the Network NEW, Node NEW, Link NEW, and
   * Lane NEW messages are posted, as it has to be able to identify Lanes.
   * <p>
   * <style>table,th,td {border:1px solid grey; border-style:solid; text-align:left; border-collapse: collapse;}</style>
   * <h2>NEW</h2>
   * <table summary="" style="width:800px;">
   * <thead>
   * <tr>
   * <th style="width:25%;">Variable</th>
   * <th style="width:15%;">Type</th>
   * <th style="width:60%;">Comments</th>
   * </tr>
   * </thead><tbody>
   * <tr>
   * <td>timestamp</td>
   * <td>double</td>
   * <td>time of the event, in simulation time seconds</td>
   * </tr>
   * <tr>
   * <td>statisticId</td>
   * <td>String</td>
   * <td>a unique id for the statistic, e.g. a UUID string</td>
   * </tr>
   * <tr>
   * <td>description</td>
   * <td>String</td>
   * <td>textual description of the statistic</td>
   * </tr>
   * <tr>
   * <td>networkId</td>
   * <td>String</td>
   * <td>id of the Network for which the statistic is made</td>
   * </tr>
   * <tr>
   * <td>numberMetadataEntries</td>
   * <td>int</td>
   * <td>number of metadata entries</td>
   * </tr>
   * <tr>
   * <td>metadataId_1</td>
   * <td>String</td>
   * <td>id of the first metadata entry</td>
   * </tr>
   * <tr>
   * <td>metadataType_1</td>
   * <td>String</td>
   * <td>type of metadata, one of GTUTYPE, ORIGIN, DESTINATION, ROUTE</td>
   * </tr>
   * <tr>
   * <td>metadataValue_1</td>
   * <td>String</td>
   * <td>value of the first metadata entry</td>
   * </tr>
   * <tr>
   * <td>...</td>
   * <td>&nbsp;</td>
   * <td>&nbsp;</td>
   * </tr>
   * <tr>
   * <td>metadataId_n</td>
   * <td>String</td> <tdid of the last metadata entry</td>
   * </tr>
   * <tr>
   * <td>metadataType_n</td>
   * <td>String</td>
   * <td>type of metadata, one of GTUTYPE, ORIGIN, DESTINATION, ROUTE</td>
   * </tr>
   * <tr>
   * <td>metadataValue_n</td>
   * <td>String</td>
   * <td>value of the last metadata entry</td>
   * </tr>
   * <td>numberSpaceTimeRegions</td>
   * <td>int</td>
   * <td>number of space-time regions for this statistic</td>
  * </tr>
  * <tr>
  * <td>startTime_1</td>
  * <td>double</td>
  * <td>start time for the first space time region, in seconds</td>
  * </tr>
  * <tr>
  * <td>endTime_1</td>
  * <td>double</td>
  * <td>end time for the first space time region, in seconds</td>
  * </tr>
  * <tr>
  * <td>linkId_1</td>
  * <td>String</td>
  * <td>id of the first Link for the space-time region</td>
  * </tr>
  * <tr>
  * <td>laneId_1</td>
  * <td>String</td>
  * <td>id of the first Lane in the link for the space-time region</td>
  * </tr>
  * <tr>
  * <td>...</td>
  * <td>&nbsp;</td>
  * <td>&nbsp;</td>
  * </tr>
  * <tr>
  * <td>startTime_n</td>
  * <td>double</td>
  * <td>start time for the last space time region, in seconds</td>
  * </tr>
  * <tr>
  * <td>endTime_n</td>
  * <td>double</td>
  * <td>end time for the last space time region, in seconds</td>
  * </tr>
  * <tr>
  * <td>linkId_n</td>
  * <td>String</td>
  * <td>id of the last Link for the space-time region</td>
  * </tr>
  * <tr>
  * <td>laneId_n</td>
  * <td>String</td>
  * <td>id of the last Lane in the link for the space-time region</td>
  * </tr>
  * <tr>
  * <td>connected</td>
  * <td>boolean</td>
  * <td>whether the lanes in the space-time regions are longitudinally connected or not</td>
  * </tr>
  * <tr>
  * <td>transmissionInterval</td>
  * <td>double</td>
  * <td>transmission interval of the statistic in seconds</td>
  * </tr>
  * </tbody>
  * </table>
  * </p>
  * <p>
  * <h2>CHANGE</h2>
  * <table summary="" style="width:800px;">
  * <thead>
  * <tr>
  * <th style="width:25%;">Variable</th>
  * <th style="width:15%;">Type</th>
  * <th style="width:60%;">Comments</th>
  * </tr>
  * </thead><tbody>
  * <tr>
  * <td>timestamp</td>
  * <td>double</td>
  * <td>time of the event, in simulation time seconds</td>
  * </tr>
  * <tr>
  * <td>statisticId</td>
  * <td>String</td>
  * <td>the unique id for the statistic, e.g. a UUID string</td>
  * </tr>
  * <tr>
  * <td>totalGtuDistance</td>
  * <td>double</td>
  * <td>total distance traveled by filtered GTUs in the given time and space, in meters</td>
  * </tr>
  * <tr>
  * <td>totalGtuTravelTime</td>
  * <td>double</td>
  * <td>total travel time by filtered GTUs in the given time and space, in seconds</td>
  * </tr>
  * <tr>
  * <td>averageGtuSpeed</td>
  * <td>double</td>
  * <td>average filtered GTU speed in the given time and space, in meter/second</td>
  * </tr>
  * <tr>
  * <td>averageGtuTravelTimePerKm</td>
  * <td>double</td>
  * <td>average filtered GTU travel time in the given time and space, in seconds per km</td>
  * </tr>
  * <tr>
  * <td>totalGtuTimeDelay</td>
  * <td>double</td>
  * <td>total time delay incurred by the filtered GTUs in the given time and space, in seconds</td>
  * </tr>
  * <tr>
  * <td>averageTripLength</td>
  * <td>double</td>
  * <td>average length of the trip of the filtered GTUs in the given time and space, in seconds</td>
  * </tr>
  * <tr>
  * <td>totalNumberStops</td>
  * <td>double</td>
  * <td>total number of stops that GTUs made in the given time and space, dimensionless</td>
  * </tr>
  * </tbody>
  * </table>
  * </p>
  * <p>
  * <h2>DELETE</h2>
  * <table summary="" style="width:800px;">
  * <thead>
  * <tr>
  * <th style="width:25%;">Variable</th>
  * <th style="width:15%;">Type</th>
  * <th style="width:60%;">Comments</th>
  * </tr>
  * </thead><tbody>
  * <tr>
  * <td>timestamp</td>
  * <td>double</td>
  * <td>time of the event, in simulation time seconds</td>
  * </tr>
  * <tr>
  * <td>statisticId</td>
  * <td>String</td>
  * <td>the unique id for the statistic that is removed</td>
  * </tr>
  * </tbody>
  * </table>
  * </p>
  * <p>
  * Copyright (c) 2013-2016 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved. <br>
  * BSD-style license. See <a href="http://opentrafficsim.org/docs/current/license.html">OpenTrafficSim License</a>.
  * <p>
  * @version $Revision$, $LastChangedDate$, by $Author$, initial version Sep 16, 2016 <br>
  * @author <a href="http://www.tbm.tudelft.nl/averbraeck">Alexander Verbraeck</a>
  * @author <a href="http://www.tudelft.nl/pknoppers">Peter Knoppers</a>
  */
 public class Sim0MQKpiTransceiver implements Serializable
 {
 
     /** */
     private static final long serialVersionUID = 20160923L;
 
     /** IMB connector. */
     // private final Connector connector;
 
     /** The query for the statistic. */
     // private final Query query;
 
     /** The Network id for which the graph is made. */
     // private final String networkId;
 
     /** The interval between generation of graphs. */
     // private final Duration transmissionInterval;
 
     private TotalTravelDistance totalTravelDistance = new TotalTravelDistance();
 
     private TotalTravelTime totalTravelTime = new TotalTravelTime();
 
     private MeanSpeed meanSpeed = new MeanSpeed(this.totalTravelDistance, this.totalTravelTime);
 
     private MeanTravelTimePerKm meanTravelTimePerKm = new MeanTravelTimePerKm(this.meanSpeed);
 
     private MeanTripLength meanTripLength = new MeanTripLength();
 
     private TotalDelay totalDelay = new TotalDelay(new Speed(130.0, SpeedUnit.KM_PER_HOUR));
 
     private TotalNumberOfStops totalNumberOfStops = new TotalNumberOfStops();
 
     private Time updateTime = Time.ZERO;
 
     // TODO implement DELETE message
 
 //    /**
 //     * Construct a new ImbKpiTransceiver.
 //     * @param connector Connector; the IMB connector
 //     * @param time Time; time of creation
 //     * @param networkId String; the network id
 //     * @param query Query; the statistics query
 //     * @param transmissionInterval Duration; the interval between generation of graphs
 //     * @throws IMBException when the post of the IMB message fails
 //     */
 //    public Sim0MQKpiTransceiver(final Connector connector, Time time, String networkId, final Query query,
 //            final Duration transmissionInterval) throws IMBException
 //    {
 //        this.connector = connector;
 //        this.query = query;
 //        this.networkId = networkId;
 //        this.transmissionInterval = transmissionInterval;
 //
 //        List<Object> newMessage = new ArrayList<>();
 //        newMessage.add(time.si);
 //        newMessage.add(query.getId());
 //        newMessage.add(query.toString());
 //        newMessage.add(this.networkId);
 //        newMessage.add((int) 0); // TODO numberMetadataEntries
 //        newMessage.add((int) 0); // TODO numberSpaceTimeRegions
 //        newMessage.add(false); // TODO "connected" not part of query anymore
 //        newMessage.add(true); // TODO totalTrajectory
 //        newMessage.add(transmissionInterval.si);
 //
 //        this.connector.postIMBMessage("StatisticsGTULane", IMBEventType.NEW, newMessage.toArray());
 //        sendStatisticsUpdate();
 //    }
 //
 //    /**
 //     * Notifies about time, such that statistics over some period (very recently ended) can be gathered and published.
 //     * @param time the time to be used in the notification (usually the current time)
 //     */
 //    public void notifyTime(Time time)
 //    {
 //        if (time.gt(this.updateTime))
 //        {
 //            try
 //            {
 //                sendStatisticsUpdate();
 //            }
 //            catch (IMBException exception)
 //            {
 //                throw new RuntimeException("Cannot send statistics update.", exception);
 //            }
 //        }
 //    }
 //
 //    /**
 //     * @throws IMBException when the transmission of the IMB message fails
 //     */
 //    public void sendStatisticsUpdate() throws IMBException
 //    {
 //        Length tdist = this.totalTravelDistance.getValue(this.query, this.updateTime);
 //        Duration ttt = this.totalTravelTime.getValue(this.query, this.updateTime);
 //        Speed ms = this.meanSpeed.getValue(this.query, this.updateTime);
 //        Duration mttpkm = this.meanTravelTimePerKm.getValue(this.query, this.updateTime);
 //        Length mtl = this.meanTripLength.getValue(this.query, this.updateTime);
 //        Duration tdel = this.totalDelay.getValue(this.query, this.updateTime);
 //        Dimensionless nos = this.totalNumberOfStops.getValue(this.query, this.updateTime);
 //        double time = this.updateTime.si;
 //        System.out.println("===== @time " + time + " s =====");
 //        System.out.println("Total distance " + tdist);
 //        System.out.println("Total travel time " + ttt);
 //        System.out.println("Mean speed " + ms);
 //        System.out.println("Mean travel time " + mttpkm + " (per km)");
 //        System.out.println("Mean trip length " + mtl);
 //        System.out.println("Total delay " + tdel);
 //        System.out.println("Number of stops " + nos);
 //        this.connector.postIMBMessage("StatisticsGTULane", IMBEventType.CHANGE,
 //                new Object[] { time, this.query.getId(), tdist.si, ttt.si, ms.si, mttpkm.si, tdel.si, mtl.si, nos.si });
 //        this.updateTime = this.updateTime.plus(this.transmissionInterval);
 //    }
 
 }