MSTransportableDevice_FCDReplay.cpp

Go to the documentation of this file.

/****************************************************************************/
// Eclipse SUMO, Simulation of Urban MObility; see https://eclipse.dev/sumo
// Copyright (C) 2013-2025 German Aerospace Center (DLR) and others.
// This program and the accompanying materials are made available under the
// terms of the Eclipse Public License 2.0 which is available at
// https://www.eclipse.org/legal/epl-2.0/
// This Source Code may also be made available under the following Secondary
// Licenses when the conditions for such availability set forth in the Eclipse
// Public License 2.0 are satisfied: GNU General Public License, version 2
// or later which is available at
// https://www.gnu.org/licenses/old-licenses/gpl-2.0-standalone.html
// SPDX-License-Identifier: EPL-2.0 OR GPL-2.0-or-later
/****************************************************************************/
// A device which replays recorded floating car data
/****************************************************************************/
#include <config.h>
 
#include <utils/options/OptionsCont.h>
#include <libsumo/Person.h>
#include <microsim/MSEdge.h>
#include <microsim/MSEventControl.h>
#include <microsim/MSLane.h>
#include <microsim/MSNet.h>
#include <microsim/devices/MSDevice_Transportable.h>
#include <microsim/transportables/MSPerson.h>
#include <microsim/transportables/MSStageWalking.h>
#include <microsim/transportables/MSTransportable.h>
#include <microsim/transportables/MSTransportableControl.h>
#include "MSTransportableDevice_FCDReplay.h"
 
 
// ===========================================================================
// static member initializations
// ===========================================================================
bool MSTransportableDevice_FCDReplay::myAmActive = false;
 
 
// ===========================================================================
// method definitions
// ===========================================================================
// ---------------------------------------------------------------------------
// static initialisation methods
// ---------------------------------------------------------------------------
void
MSTransportableDevice_FCDReplay::insertOptions(OptionsCont& oc) {
    insertDefaultAssignmentOptions("fcd-replay", "FCD Replay Device", oc, true);
}
 
 
void
MSTransportableDevice_FCDReplay::buildDevices(MSTransportable& t, std::vector<MSTransportableDevice*>& into) {
    OptionsCont& oc = OptionsCont::getOptions();
    if (equippedByDefaultAssignmentOptions(oc, "fcd-replay", t, oc.isSet("device.fcd-replay.file"), true)) {
        MSTransportableDevice_FCDReplay* device = new MSTransportableDevice_FCDReplay(t, "fcdReplay_" + t.getID());
        into.push_back(device);
        if (!myAmActive) {
            MSNet::getInstance()->getBeginOfTimestepEvents()->addEvent(new MovePedestrians(), SIMSTEP + DELTA_T);
            myAmActive = true;
        }
    }
}
 
 
// ---------------------------------------------------------------------------
// MSTransportableDevice_FCDReplay-methods
// ---------------------------------------------------------------------------
MSTransportableDevice_FCDReplay::MSTransportableDevice_FCDReplay(MSTransportable& holder, const std::string& id) :
    MSTransportableDevice(holder, id) {
}
 
 
MSTransportableDevice_FCDReplay::~MSTransportableDevice_FCDReplay() {
}
 
 
bool
MSTransportableDevice_FCDReplay::move(SUMOTime currentTime) {
    if (!myHolder.hasDeparted()) { // need to check this first for trajectories of size 1
        return false;
    }
    if (myTrajectory == nullptr || myTrajectoryIndex == (int)myTrajectory->size()) {
        // removing person
        return true;
    }
    MSPerson* person = dynamic_cast<MSPerson*>(&myHolder);
    const auto& te = myTrajectory->at(myTrajectoryIndex);
    if (person == nullptr || te.time > currentTime) {
        return false;
    }
    if (person->getCurrentStageType() == MSStageType::DRIVING) {
        if (person->getVehicle() == nullptr) {  // entering the vehicle
            const MSEdge* const edge = person->getEdge();
            for (const SUMOVehicle* v : edge->getVehicles()) {
                if (v->getSpeed() == 0. && fabs(v->getPositionOnLane() - te.lanePos) < POSITION_EPS) {
                    v->getLane()->getVehiclesSecure();  // lock the lane
                    SUMOTime dummy = -1; // boarding- and loading-time are not considered
                    MSNet::getInstance()->getPersonControl().loadAnyWaiting(edge, const_cast<SUMOVehicle*>(v), dummy, dummy, person);
                    v->getLane()->releaseVehicles();  // unlock the lane
                }
            }
        } else {
            SUMOVehicle* v = person->getVehicle();
            if (te.speed == 0. && fabs(v->getPositionOnLane() - te.lanePos) >= POSITION_EPS) {  // leaving the vehicle
                v->getLane()->getVehiclesSecure();  // lock the lane
                MSDevice_Transportable* transDev = static_cast<MSDevice_Transportable*>(v->getDevice(typeid(MSDevice_Transportable)));
                transDev->removeTransportable(person);
                person->proceed(MSNet::getInstance(), currentTime);
                v->getLane()->releaseVehicles();  // unlock the lane
            }
        }
    }
    if (person->getCurrentStageType() == MSStageType::WALKING) {
        try {
            libsumo::Person::moveToXY(person->getID(), te.edgeOrLane, te.pos.x(), te.pos.y(), te.angle, 7, 0.1);
        } catch (const libsumo::TraCIException& e) {
            WRITE_WARNING(e.what());
        }
        MSStageWalking* walk = static_cast<MSStageWalking*>(person->getCurrentStage());
        if (myTrajectoryIndex > 0 && myTrajectory->at(myTrajectoryIndex - 1).edgeOrLane != te.edgeOrLane) {
            walk->moveToNextEdge(person, currentTime, 1, nullptr, true);
        }
    }
    // person->setPreviousSpeed(std::get<3>(p), std::numeric_limits<double>::min());
    myTrajectoryIndex++;
    return false;
}
 
 
MSTransportableDevice_FCDReplay::MovePedestrians::MovePedestrians() {
    // higher than default command priority of 0
    priority = 1;
}
 
 
SUMOTime
MSTransportableDevice_FCDReplay::MovePedestrians::execute(SUMOTime currentTime) {
    MSTransportableControl& c = MSNet::getInstance()->getPersonControl();
    std::vector<MSTransportableDevice_FCDReplay*> devices;
    for (MSTransportableControl::constVehIt i = c.loadedBegin(); i != c.loadedEnd(); ++i) {
        MSTransportableDevice_FCDReplay* device = static_cast<MSTransportableDevice_FCDReplay*>(i->second->getDevice(typeid(MSTransportableDevice_FCDReplay)));
        if (device != nullptr) {
            devices.push_back(device);
        }
    }
    for (MSTransportableDevice_FCDReplay* d : devices) {
        if (d->move(currentTime)) {
            d->getHolder().removeStage(0, false);
        }
    }
    return DELTA_T;
}
 
 
/****************************************************************************/