WimaController.cc 57.8 KB
Newer Older
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1
#include "WimaController.h"
Valentin Platzgummer's avatar
Valentin Platzgummer committed
2
#include "utilities.h"
3
#include "ros_bridge/include/JsonMethodes.h"
4 5 6
#include "ros_bridge/rapidjson/include/rapidjson/document.h"
#include "ros_bridge/rapidjson/include/rapidjson/writer.h"
#include "ros_bridge/rapidjson/include/rapidjson/ostreamwrapper.h"
Valentin Platzgummer's avatar
Valentin Platzgummer committed
7

8
#include "QtROSJsonFactory.h"
9
#include "QtROSTypeFactory.h"
10
#include "NemoProgress.h"
11

Valentin Platzgummer's avatar
Valentin Platzgummer committed
12
#include "time.h"
13
#include "assert.h"
Valentin Platzgummer's avatar
Valentin Platzgummer committed
14

15
#include "QVector3D"
16
#include <QScopedPointer>
17

18

19 20 21 22 23 24 25 26 27 28
const char* WimaController::wimaFileExtension           = "wima";
const char* WimaController::areaItemsName               = "AreaItems";
const char* WimaController::missionItemsName            = "MissionItems";
const char* WimaController::settingsGroup               = "WimaController";
const char* WimaController::enableWimaControllerName    = "EnableWimaController";
const char* WimaController::overlapWaypointsName        = "OverlapWaypoints";
const char* WimaController::maxWaypointsPerPhaseName    = "MaxWaypointsPerPhase";
const char* WimaController::startWaypointIndexName      = "StartWaypointIndex";
const char* WimaController::showAllMissionItemsName     = "ShowAllMissionItems";
const char* WimaController::showCurrentMissionItemsName = "ShowCurrentMissionItems";
29
const char* WimaController::flightSpeedName             = "FlightSpeed";
30
const char* WimaController::arrivalReturnSpeedName      = "ArrivalReturnSpeed";
31
const char* WimaController::altitudeName                = "Altitude";
32
const char* WimaController::reverseName                 = "Reverse";
Valentin Platzgummer's avatar
Valentin Platzgummer committed
33 34
const char* WimaController::snakeTileWidthName          = "SnakeTileWidth";
const char* WimaController::snakeTileHeightName         = "SnakeTileHeight";
35
const char* WimaController::snakeMinTileAreaName        = "SnakeMinTileArea";
Valentin Platzgummer's avatar
Valentin Platzgummer committed
36 37 38 39 40
const char* WimaController::snakeLineDistanceName       = "SnakeLineDistance";
const char* WimaController::snakeMinTransectLengthName  = "SnakeMinTransectLength";

using namespace snake;
using namespace snake_geometry;
41

42
WimaController::WimaController(QObject *parent)
43 44 45 46 47 48 49 50 51 52 53
    : QObject                   (parent)
    , _container                (nullptr)
    , _joinedArea               (this)
    , _measurementArea          (this)
    , _serviceArea              (this)
    , _corridor                 (this)
    , _localPlanDataValid       (false)
    , _metaDataMap              (FactMetaData::createMapFromJsonFile(QStringLiteral(":/json/WimaController.SettingsGroup.json"), this))
    , _enableWimaController     (settingsGroup, _metaDataMap[enableWimaControllerName])
    , _overlapWaypoints         (settingsGroup, _metaDataMap[overlapWaypointsName])
    , _maxWaypointsPerPhase     (settingsGroup, _metaDataMap[maxWaypointsPerPhaseName])
54
    , _nextPhaseStartWaypointIndex       (settingsGroup, _metaDataMap[startWaypointIndexName])
55
    , _showAllMissionItems      (settingsGroup, _metaDataMap[showAllMissionItemsName])
56 57
    , _showCurrentMissionItems  (settingsGroup, _metaDataMap[showCurrentMissionItemsName])    
    , _flightSpeed              (settingsGroup, _metaDataMap[flightSpeedName])
58
    , _arrivalReturnSpeed       (settingsGroup, _metaDataMap[arrivalReturnSpeedName])
59
    , _altitude                 (settingsGroup, _metaDataMap[altitudeName])
60
    , _reverse                  (settingsGroup, _metaDataMap[reverseName])
Valentin Platzgummer's avatar
Valentin Platzgummer committed
61
    , _endWaypointIndex         (0)
62 63
    , _startWaypointIndex       (0)
    , _uploadOverrideRequired   (false)
64
    , _measurementPathLength    (-1)
65 66
    , _arrivalPathLength        (-1)
    , _returnPathLength         (-1)
67 68
    , _phaseDistance            (-1)
    , _phaseDuration            (-1)
69 70
    , _phaseDistanceBuffer      (-1)
    , _phaseDurationBuffer      (-1)
71 72 73
    , _vehicleHasLowBattery         (false)
    , _lowBatteryHandlingTriggered  (false)
    , _executingSmartRTL            (false)
Valentin Platzgummer's avatar
Valentin Platzgummer committed
74 75 76 77 78 79 80 81
    , _snakeConnectionStatus    (SnakeConnectionStatus::Connected) // TODO: implement automatic connection
    , _snakeCalcInProgress      (false)
    , _scenarioDefinedBool      (false)
    , _snakeTileWidth           (settingsGroup, _metaDataMap[snakeTileWidthName])
    , _snakeTileHeight          (settingsGroup, _metaDataMap[snakeTileHeightName])
    , _snakeMinTileArea         (settingsGroup, _metaDataMap[snakeMinTileAreaName])
    , _snakeLineDistance        (settingsGroup, _metaDataMap[snakeLineDistanceName])
    , _snakeMinTransectLength   (settingsGroup, _metaDataMap[snakeMinTransectLengthName])
Valentin Platzgummer's avatar
Valentin Platzgummer committed
82
    , _pRosBridge               (new ROSBridge::ROSBridge())
83 84 85
{
    _showAllMissionItems.setRawValue(true);
    _showCurrentMissionItems.setRawValue(true);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
86 87 88 89 90 91 92
    connect(&_overlapWaypoints,             &Fact::rawValueChanged, this, &WimaController::_updateNextWaypoint);
    connect(&_maxWaypointsPerPhase,         &Fact::rawValueChanged, this, &WimaController::_recalcCurrentPhase);
    connect(&_nextPhaseStartWaypointIndex,  &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
    connect(&_flightSpeed,                  &Fact::rawValueChanged, this, &WimaController::_updateflightSpeed);
    connect(&_arrivalReturnSpeed,           &Fact::rawValueChanged, this, &WimaController::_updateArrivalReturnSpeed);
    connect(&_altitude,                     &Fact::rawValueChanged, this, &WimaController::_updateAltitude);
    connect(&_reverse,                      &Fact::rawValueChanged, this, &WimaController::_reverseChangedHandler);
93

94
    // setup low battery handling
Valentin Platzgummer's avatar
Valentin Platzgummer committed
95 96
    connect(&_eventTimer, &QTimer::timeout, this, &WimaController::_eventTimerHandler);
    _eventTimer.setInterval(EVENT_TIMER_INTERVAL);
97

98
    Fact *enableLowBatteryHandling = qgcApp()->toolbox()->settingsManager()->wimaSettings()->enableLowBatteryHandling();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
99 100 101 102
    connect(enableLowBatteryHandling, &Fact::rawValueChanged, this, &WimaController::_enableDisableLowBatteryHandling);
    _enableDisableLowBatteryHandling(enableLowBatteryHandling->rawValue());

    // Snake Worker Thread.
103
    connect(&_snakeWorker, &SnakeWorker::resultReady, this, &WimaController::_snakeStoreWorkerResults);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
104 105 106 107

    // Start, stop RosBridge.
    connect(&_enableSnake, &Fact::rawValueChanged, this, &WimaController::_startStopRosBridge);
    _startStopRosBridge();
108 109
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
110 111 112 113
QStringList WimaController::loadNameFilters() const
{
    QStringList filters;

114
    filters << tr("Supported types (*.%1 *.%2)").arg(wimaFileExtension).arg(AppSettings::planFileExtension) <<
Valentin Platzgummer's avatar
Valentin Platzgummer committed
115 116
               tr("All Files (*.*)");
    return filters;
117 118 119 120 121
}

QStringList WimaController::saveNameFilters() const
{
    QStringList filters;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
122

123 124
    filters << tr("Supported types (*.%1 *.%2)").arg(wimaFileExtension).arg(AppSettings::planFileExtension);
    return filters;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
125 126
}

127 128 129 130 131
bool WimaController::uploadOverrideRequired() const
{
    return _uploadOverrideRequired;
}

132 133 134 135 136 137 138 139 140 141
double WimaController::phaseDistance() const
{
    return _phaseDistance;
}

double WimaController::phaseDuration() const
{
    return _phaseDuration;
}

142 143 144 145 146
bool WimaController::vehicleHasLowBattery() const
{
    return _vehicleHasLowBattery;
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
147 148 149 150 151 152 153 154 155 156
long WimaController::snakeConnectionStatus() const
{
    return _snakeConnectionStatus;
}

bool WimaController::snakeCalcInProgress() const
{
    return _snakeCalcInProgress;
}

157 158 159 160 161 162 163 164 165 166 167 168
void WimaController::setMasterController(PlanMasterController *masterC)
{
    _masterController = masterC;
    emit masterControllerChanged();
}

void WimaController::setMissionController(MissionController *missionC)
{
    _missionController = missionC;
    emit missionControllerChanged();
}

169 170 171 172 173 174
/*!
 * \fn void WimaController::setDataContainer(WimaDataContainer *container)
 * Sets the pointer to the \c WimaDataContainer, which is meant to exchange data between the \c WimaController and the \c WimaPlaner.
 *
 * \sa WimaPlaner, WimaDataContainer, WimaPlanData
 */
175 176
void WimaController::setDataContainer(WimaDataContainer *container)
{
177 178
    if (container != nullptr) {
        if (_container != nullptr) {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
179
           disconnect(_container, &WimaDataContainer::newDataAvailable, this, &WimaController::_fetchContainerData);
180 181
        }

182
        _container = container;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
183
        connect(_container, &WimaDataContainer::newDataAvailable, this, &WimaController::_fetchContainerData);
184 185 186 187 188

        emit dataContainerChanged();
    }
}

189 190 191 192 193 194 195 196 197
void WimaController::setUploadOverrideRequired(bool overrideRequired)
{
    if (_uploadOverrideRequired != overrideRequired) {
        _uploadOverrideRequired = overrideRequired;

        emit uploadOverrideRequiredChanged();
    }
}

198 199
void WimaController::nextPhase()
{
Valentin Platzgummer's avatar
Valentin Platzgummer committed
200
    _calcNextPhase();
201 202
}

203
void WimaController::previousPhase()
Valentin Platzgummer's avatar
Valentin Platzgummer committed
204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220
{    
    bool reverseBool = _reverse.rawValue().toBool();
    if (!reverseBool){
        int startIndex = _nextPhaseStartWaypointIndex.rawValue().toInt();
        if (startIndex > 0) {
            _nextPhaseStartWaypointIndex.setRawValue(1+std::max(_startWaypointIndex
                                                              - _maxWaypointsPerPhase.rawValue().toInt()
                                                              + _overlapWaypoints.rawValue().toInt(), 0));
        }
    }
    else {
        int startIndex = _nextPhaseStartWaypointIndex.rawValue().toInt();
        if (startIndex <= _missionItems.count()) {
            _nextPhaseStartWaypointIndex.setRawValue(1+std::min(_startWaypointIndex
                                                              + _maxWaypointsPerPhase.rawValue().toInt()
                                                              - _overlapWaypoints.rawValue().toInt(), _missionItems.count()-1));
        }
221
    }
222 223 224 225
}

void WimaController::resetPhase()
{
Valentin Platzgummer's avatar
Valentin Platzgummer committed
226 227 228 229 230 231 232
    bool reverseBool = _reverse.rawValue().toBool();
    if (!reverseBool) {
        _nextPhaseStartWaypointIndex.setRawValue(int(1));
    }
    else {
        _nextPhaseStartWaypointIndex.setRawValue(_missionItems.count());
    }
233 234
}

235
bool WimaController::uploadToVehicle()
236
{
237 238
    if (   !_serviceArea.containsCoordinate(_masterController->managerVehicle()->coordinate())
        && _currentMissionItems.count() > 0) {
239 240 241 242 243 244 245 246 247 248
        setUploadOverrideRequired(true);
        return false;
    }

    return forceUploadToVehicle();
}

bool WimaController::forceUploadToVehicle()
{
    setUploadOverrideRequired(false);
249
    if (_currentMissionItems.count() < 1)
250
        return false;
251 252 253 254 255 256 257

    _missionController->removeAll();
    // set homeposition of settingsItem
    QmlObjectListModel* visuals = _missionController->visualItems();
    MissionSettingsItem* settingsItem = visuals->value<MissionSettingsItem *>(0);
    if (settingsItem == nullptr) {
        qWarning("WimaController::updateCurrentMissionItems(): nullptr");
258
        return false;
259 260 261 262 263 264 265
    }
    settingsItem->setCoordinate(_takeoffLandPostion);

    // copy mission items from _currentMissionItems to _missionController
    for (int i = 0; i < _currentMissionItems.count(); i++){
        SimpleMissionItem *item = _currentMissionItems.value<SimpleMissionItem *>(i);
        _missionController->insertSimpleMissionItem(*item, visuals->count());
266 267 268 269 270 271 272 273 274 275 276 277 278 279 280
        if (item->command() == MAV_CMD_DO_CHANGE_SPEED) {
        }
    }

    for (int i = 0; i < _missionController->visualItems()->count(); i++){
        SimpleMissionItem *item =  _missionController->visualItems()->value<SimpleMissionItem*>(i);
        if (item == nullptr)
            continue;
        if (item->command() == MAV_CMD_DO_CHANGE_SPEED) {
        }
    }
    for (int i = 0; i < _missionController->visualItems()->count(); i++){
        SimpleMissionItem *item =  _missionController->visualItems()->value<SimpleMissionItem*>(i);
        if (item == nullptr)
            continue;
281 282
    }

283
    _masterController->sendToVehicle();
284 285

    return true;
286
}
287

288 289 290
void WimaController::removeFromVehicle()
{
    _masterController->removeAllFromVehicle();
291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313
    _missionController->removeAll();
}

bool WimaController::checkSmartRTLPreCondition()
{
    QString errorString;
    bool retValue = _checkSmartRTLPreCondition(errorString);
    if (retValue == false) {
        qgcApp()->showMessage(errorString);
        return false;
    }
    return true;
}

bool WimaController::calcReturnPath()
{
    QString errorString;
    bool retValue = _calcReturnPath(errorString);
    if (retValue == false) {
        qgcApp()->showMessage(errorString);
        return false;
    }
    return true;
314 315
}

316
void WimaController::executeSmartRTL()
317
{
318
    _executeSmartRTL();
319 320
}

321
void WimaController::initSmartRTL()
322
{
323 324
    _srtlReason = UserRequest;
    _initSmartRTL();
325 326
}

327 328 329 330 331 332
void WimaController::removeVehicleTrajectoryHistory()
{
    Vehicle *managerVehicle = masterController()->managerVehicle();
    managerVehicle->trajectoryPoints()->clear();
}

333
void WimaController::saveToCurrent()
334
{
335

336 337
}

338 339
void WimaController::saveToFile(const QString& filename)
{
340
    QString file = filename;
341 342
}

343
bool WimaController::loadFromCurrent()
344
{
345
    return true;
346 347 348 349
}

bool WimaController::loadFromFile(const QString &filename)
{
350
    QString file = filename;
351
    return true;
352 353 354
}


355

356
QJsonDocument WimaController::saveToJson(FileType fileType)
357
{
358 359 360 361
    if(fileType)
    {

    }
362
    return QJsonDocument();
363 364
}

365
bool WimaController::calcShortestPath(const QGeoCoordinate &start, const QGeoCoordinate &destination, QVector<QGeoCoordinate> &path)
366 367 368
{
    using namespace GeoUtilities;
    using namespace PolygonCalculus;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
369
    QVector<QPointF> path2D;
370 371 372 373 374 375 376 377 378 379
    bool retVal = PolygonCalculus::shortestPath(
                                   toQPolygonF(toCartesian2D(_joinedArea.coordinateList(), /*origin*/ start)),
                                   /*start point*/ QPointF(0,0),
                                   /*destination*/ toCartesian2D(destination, start),
                                   /*shortest path*/ path2D);
    path.append(toGeo(path2D, /*origin*/ start));

    return  retVal;
}

380
bool WimaController::extractCoordinateList(QmlObjectListModel &missionItems, QVector<QGeoCoordinate> &coordinateList)
381 382 383 384
{
    return extractCoordinateList(missionItems, coordinateList, 0, missionItems.count()-1);
}

385
bool WimaController::extractCoordinateList(QmlObjectListModel &missionItems, QVector<QGeoCoordinate> &coordinateList, int startIndex, int endIndex)
386 387 388 389 390 391 392 393 394 395 396 397
{
    if (   startIndex >= 0
        && startIndex < missionItems.count()
        && endIndex >= 0
        && endIndex < missionItems.count()) {
        if (startIndex > endIndex) {
            if (!extractCoordinateList(missionItems, coordinateList, startIndex, missionItems.count()-1))
                return false;
            if (!extractCoordinateList(missionItems, coordinateList, 0, endIndex))
                return false;
        } else {
            for (int i = startIndex; i <= endIndex; i++) {
398
                SimpleMissionItem *mItem = missionItems.value<SimpleMissionItem *>(i);
399 400 401 402 403 404 405 406 407 408 409 410 411 412

                if (mItem == nullptr) {
                    coordinateList.clear();
                    return false;
                }
                coordinateList.append(mItem->coordinate());
            }
        }
    } else
        return false;

    return true;
}

413
bool WimaController::extractCoordinateList(QmlObjectListModel &missionItems, QVariantList &coordinateList)
414 415 416 417
{
    return extractCoordinateList(missionItems, coordinateList, 0 , missionItems.count()-1);
}

418
bool WimaController::extractCoordinateList(QmlObjectListModel &missionItems, QVariantList &coordinateList, int startIndex, int endIndex)
419
{
420
    QVector<QGeoCoordinate> geoCoordintateList;
421 422 423

    bool retValue = extractCoordinateList(missionItems, geoCoordintateList, startIndex, endIndex);

424 425 426
    if (!retValue)
        return false;

427 428
    for (int i = 0; i < geoCoordintateList.size(); i++) {
        QGeoCoordinate vertex = geoCoordintateList[i];
Valentin Platzgummer's avatar
Valentin Platzgummer committed
429 430
        if (   (qFuzzyIsNull(vertex.latitude()) && qFuzzyIsNull(vertex.longitude()))
            || !vertex.isValid())
431 432 433
            geoCoordintateList.removeAt(i);
    }

434 435 436 437 438 439
    for (auto coordinate : geoCoordintateList)
        coordinateList.append(QVariant::fromValue(coordinate));

    return true;
}

440 441 442 443 444 445 446
/*!
 * \fn void WimaController::containerDataValidChanged(bool valid)
 * Pulls plan data generated by \c WimaPlaner from the \c _container if the data is valid (\a valid equals true).
 * Is connected to the dataValidChanged() signal of the \c WimaDataContainer.
 *
 * \sa WimaDataContainer, WimaPlaner, WimaPlanData
 */
Valentin Platzgummer's avatar
Valentin Platzgummer committed
447
bool WimaController::_fetchContainerData()
448
{
449
    // fetch only if valid, return true on success
450

451 452
    // reset visual items
    _visualItems.clear();
453 454
    _missionItems.clearAndDeleteContents();
    _currentMissionItems.clearAndDeleteContents();
455 456
    _waypointPath.clear();
    _currentWaypointPath.clear();
457 458
    _snakeTiles.polygons().clear();
    _snakeTilesLocal.polygons().clear();
459
    _snakeTileCenterPoints.clear();
460

461 462 463 464
    emit visualItemsChanged();
    emit missionItemsChanged();
    emit currentMissionItemsChanged();
    emit currentWaypointPathChanged();
465
    emit snakeTilesChanged();
466
    emit snakeTileCenterPointsChanged();
467

468
    _localPlanDataValid = false;
469

470 471 472 473
    if (_container == nullptr) {
        qWarning("WimaController::fetchContainerData(): No container assigned!");
        return false;
    }
474

475
    WimaPlanData planData = _container->pull();
476

477 478
    // extract list with WimaAreas
    QList<const WimaAreaData*> areaList = planData.areaList();
479

480 481 482 483
    int areaCounter = 0;
    int numAreas = 4; // extract only numAreas Areas, if there are more they are invalid and ignored
    for (int i = 0; i < areaList.size(); i++) {
        const WimaAreaData *areaData = areaList[i];
484

485 486 487 488
        if (areaData->type() == WimaServiceAreaData::typeString) { // is it a service area?
            _serviceArea = *qobject_cast<const WimaServiceAreaData*>(areaData);
            areaCounter++;
            _visualItems.append(&_serviceArea);
489

490 491
            continue;
        }
492

493 494 495 496
        if (areaData->type() == WimaMeasurementAreaData::typeString) { // is it a measurement area?
            _measurementArea =  *qobject_cast<const WimaMeasurementAreaData*>(areaData);
            areaCounter++;
            _visualItems.append(&_measurementArea);
497

498
            continue;
499
        }
500

501 502 503 504
        if (areaData->type() == WimaCorridorData::typeString) { // is it a corridor?
            _corridor =  *qobject_cast<const WimaCorridorData*>(areaData);
            areaCounter++;
            //_visualItems.append(&_corridor); // not needed
505

506 507
            continue;
        }
508

509 510 511 512
        if (areaData->type() == WimaJoinedAreaData::typeString) { // is it a corridor?
            _joinedArea =  *qobject_cast<const WimaJoinedAreaData*>(areaData);
            areaCounter++;
            _visualItems.append(&_joinedArea);
513

514 515
            continue;
        }
516

517 518 519
        if (areaCounter >= numAreas)
            break;
    }
520

521
    // extract mission items
522
    QList<MissionItem> tempMissionItems = planData.missionItems();
523 524
    if (tempMissionItems.size() < 1)
        return false;
525

526 527 528
    // create mission items
    _missionController->removeAll();
    QmlObjectListModel* missionControllerVisualItems = _missionController->visualItems();
529

530 531
    // create SimpleMissionItem by using _missionController
    for ( int i = 0; i < tempMissionItems.size(); i++) {
532
        _missionController->insertSimpleMissionItem(tempMissionItems[i], missionControllerVisualItems->count());
533 534 535 536 537 538 539
    }
    // copy mission items from _missionController to _missionItems
    for ( int i = 1; i < missionControllerVisualItems->count(); i++) {
        SimpleMissionItem *visualItem     = qobject_cast<SimpleMissionItem *>((*missionControllerVisualItems)[i]);
        if (visualItem == nullptr) {
            qWarning("WimaController::fetchContainerData(): Nullptr at SimpleMissionItem!");
            return false;
540
        }
541 542 543 544 545
        SimpleMissionItem *visualItemCopy = new SimpleMissionItem(*visualItem, true, this);
        _missionItems.append(visualItemCopy);
    }
    if (areaCounter != numAreas)
        return false;
546

Valentin Platzgummer's avatar
Valentin Platzgummer committed
547
    if (!_setTakeoffLandPosition())
548
        return false;
549

Valentin Platzgummer's avatar
Valentin Platzgummer committed
550
    _updateWaypointPath();
551

552
    // set _nextPhaseStartWaypointIndex to 1
Valentin Platzgummer's avatar
Valentin Platzgummer committed
553
    disconnect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
554 555
    bool reverse = _reverse.rawValue().toBool();
    _nextPhaseStartWaypointIndex.setRawValue(reverse? _missionItems.count() : int(1));
Valentin Platzgummer's avatar
Valentin Platzgummer committed
556
    connect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
557

Valentin Platzgummer's avatar
Valentin Platzgummer committed
558
    if(!_calcNextPhase())
559
        return false;
560

Valentin Platzgummer's avatar
Valentin Platzgummer committed
561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581
    // Initialize _scenario.
    Area mArea;
    for (auto variant : _measurementArea.path()){
        QGeoCoordinate c{variant.value<QGeoCoordinate>()};
        mArea.geoPolygon.push_back(GeoPoint2D{c.latitude(), c.longitude()});
    }
    mArea.type = AreaType::MeasurementArea;

    Area sArea;
    for (auto variant : _serviceArea.path()){
        QGeoCoordinate c{variant.value<QGeoCoordinate>()};
        sArea.geoPolygon.push_back(GeoPoint2D{c.latitude(), c.longitude()});
    }
    sArea.type = AreaType::ServiceArea;

    Area corridor;
    for (auto variant : _corridor.path()){
        QGeoCoordinate c{variant.value<QGeoCoordinate>()};
        corridor.geoPolygon.push_back(GeoPoint2D{c.latitude(), c.longitude()});
    }
    corridor.type = AreaType::Corridor;
582

Valentin Platzgummer's avatar
Valentin Platzgummer committed
583 584 585 586
    _scenario.addArea(mArea);
    _scenario.addArea(sArea);
    _scenario.addArea(corridor);

587 588 589 590
    // Check if scenario is defined.
    if ( !_verifyScenarioDefinedWithErrorMessage() )
        return false;

591 592 593 594
    {
        // Get tiles.
        const auto &tiles = _scenario.getTiles();
        const auto &cps = _scenario.getTileCenterPoints();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
595
        for ( unsigned int i=0; i < tiles.size(); ++i ) {
596 597 598 599 600 601 602 603 604 605 606
            const auto &tile = tiles[i];
            SnakeTile Tile;
            for ( const auto &vertex : tile) {
                QGeoCoordinate QVertex(vertex[0], vertex[1], vertex[2]);
                Tile.append(QVertex);
            }
            const auto &centerPoint = cps[i];
            QGeoCoordinate QCenterPoint(centerPoint[0], centerPoint[1], centerPoint[2]);
            Tile.setCenter(QCenterPoint);
            _snakeTiles.polygons().append(Tile);
            _snakeTileCenterPoints.append(QVariant::fromValue(QCenterPoint));
607
        }
608 609 610 611 612
    }

    {
        // Get local tiles.
        const auto &tiles = _scenario.getTilesENU();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
613
        for ( unsigned int i=0; i < tiles.size(); ++i ) {
614 615 616 617
            const auto &tile = tiles[i];
            Polygon2D Tile;
            for ( const auto &vertex : tile.outer()) {
                QPointF QVertex(vertex.get<0>(), vertex.get<1>());
618
                Tile.path().append(QVertex);
619 620 621 622
            }
            _snakeTilesLocal.polygons().append(Tile);
        }

623 624
        QtROSJsonFactory JsonFactory;
        QScopedPointer<rapidjson::Document> doc(JsonFactory.create(_snakeTilesLocal));
625 626 627

        auto &temp = _scenario.getOrigin();
        ::GeoPoint3D origin(temp[0], temp[1], temp[2]);
628
        QScopedPointer<rapidjson::Document> doc2(JsonFactory.create(origin));
629

630
        cout.precision(10);
631 632 633 634 635 636 637 638
        cout << "Origin" << endl;
        rapidjson::OStreamWrapper out(std::cout);
        rapidjson::Writer<rapidjson::OStreamWrapper> writer(out);
        doc2->Accept(writer);
        std::cout << std::endl << std::endl;

        cout << "Snake Tiles" << endl;
        rapidjson::Writer<rapidjson::OStreamWrapper> writer2(out);
639
        //doc->Accept(writer2);
640 641
        std::cout << std::endl << std::endl;

642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657
        QtROSTypeFactory TypeFactory;
      ::GeoPoint3D origin_same;
        TypeFactory.create(*doc2.data(), origin_same);

        cout << "Origin2" << endl;
        std::cout << origin_same << std::endl;

        std::cout << "TypeFactory test true: ";
        bool isSame = origin_same == origin;
        std::cout << isSame << endl;


        ::SnakeTilesLocal tiles_same;
          TypeFactory.create(*doc.data(), tiles_same);


658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678
          Polygon2D tile1;
          tile1.path().push_back(QPointF(1,0));
          tile1.path().push_back(QPointF(1,1));
          tile1.path().push_back(QPointF(1,2));
          Polygon2D tile2;
          tile2.path().push_back(QPointF(2,0));
          tile2.path().push_back(QPointF(2,1));
          tile2.path().push_back(QPointF(2,2));
          Polygon2D tile3;
          tile3.path().push_back(QPointF(3,0));
          tile3.path().push_back(QPointF(3,1));
          tile3.path().push_back(QPointF(3,2));
          SnakeTilesLocal tilesSmall;
          tilesSmall.polygons().push_back(tile1);
          tilesSmall.polygons().push_back(tile2);
          tilesSmall.polygons().push_back(tile3);


          QScopedPointer<rapidjson::Document> jsonTileSmall(JsonFactory.create(tilesSmall));

          SnakeTilesLocal tilesSmallSame;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
679
          TypeFactory.create(*jsonTileSmall.data(), tilesSmallSame);
680 681 682 683 684 685 686 687 688 689 690 691 692 693

          QScopedPointer<rapidjson::Document> jsonTileSmallSame(JsonFactory.create(tilesSmallSame));

          cout << "Snake Tiles small" << endl;
          rapidjson::Writer<rapidjson::OStreamWrapper> writer4(out);
          jsonTileSmall->Accept(writer4);
          std::cout << std::endl << std::endl;

          cout << "Snake Tiles small same" << endl;
          rapidjson::Writer<rapidjson::OStreamWrapper> writer5(out);
          jsonTileSmallSame->Accept(writer5);
          std::cout << std::endl << std::endl;

          // progress
Valentin Platzgummer's avatar
Valentin Platzgummer committed
694
          QNemoProgress progress;
695 696 697 698 699 700 701 702 703
          progress.progress().push_back(1);
          progress.progress().push_back(2);
          progress.progress().push_back(3);
          progress.progress().push_back(4);
          progress.progress().push_back(13);
          progress.progress().push_back(600);


          QScopedPointer<rapidjson::Document> jsonProgress(JsonFactory.create(progress));
Valentin Platzgummer's avatar
Valentin Platzgummer committed
704
          cout << "Progress" << endl;
705 706 707
          rapidjson::Writer<rapidjson::OStreamWrapper> writer6(out);
          jsonProgress->Accept(writer6);
          std::cout << std::endl << std::endl;
708

Valentin Platzgummer's avatar
Valentin Platzgummer committed
709 710 711 712 713 714 715
          QNemoProgress progressSame;
          TypeFactory.create(*jsonProgress.data(), progressSame);
          cout << "Progress Type created." << endl;

          QScopedPointer<rapidjson::Document> jsonProgressSame(JsonFactory.create(progressSame));

          cout << "Progress same" << endl;
716 717 718
          rapidjson::Writer<rapidjson::OStreamWrapper> writer7(out);
          jsonProgressSame->Accept(writer7);
          std::cout << std::endl << std::endl;
719 720
    }

Valentin Platzgummer's avatar
Valentin Platzgummer committed
721

722
    emit visualItemsChanged();
723
    emit missionItemsChanged();
724 725
    emit snakeTilesChanged();
    emit snakeTileCenterPointsChanged();
726

727 728
    _localPlanDataValid = true;
    return true;
729 730
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
731
bool WimaController::_calcNextPhase()
732
{
Valentin Platzgummer's avatar
Valentin Platzgummer committed
733 734 735
    if (_missionItems.count() < 1) {
        _startWaypointIndex = 0;
        _endWaypointIndex = 0;
736
        return false;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
737
    }
738

739
    _currentMissionItems.clearAndDeleteContents();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
740

Valentin Platzgummer's avatar
Valentin Platzgummer committed
741 742 743 744
    bool reverse = _reverse.rawValue().toBool(); // Reverses the phase direction. Phases go from high to low waypoint numbers, if true.
    int startIndex = _nextPhaseStartWaypointIndex.rawValue().toInt()-1;
    if (!reverse) {
        if (startIndex > _missionItems.count()-1)
745 746 747
            return false;
    }
    else {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
748
        if (startIndex < 0)
749
            return false;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
750 751
    }    
    _startWaypointIndex = startIndex;
752

Valentin Platzgummer's avatar
Valentin Platzgummer committed
753
    int maxWaypointsPerPhase = _maxWaypointsPerPhase.rawValue().toInt();
754
    // determine end waypoint index
Valentin Platzgummer's avatar
Valentin Platzgummer committed
755 756 757
    bool lastMissionPhaseReached = false;
    if (!reverse) {
        _endWaypointIndex = std::min(_startWaypointIndex + maxWaypointsPerPhase - 1, _missionItems.count()-1);
758
        if (_endWaypointIndex == _missionItems.count() - 1)
Valentin Platzgummer's avatar
Valentin Platzgummer committed
759
            lastMissionPhaseReached = true;
760 761
    }
    else {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
762
        _endWaypointIndex = std::max(_startWaypointIndex - maxWaypointsPerPhase + 1, 0);
763
        if (_endWaypointIndex == 0)
Valentin Platzgummer's avatar
Valentin Platzgummer committed
764
            lastMissionPhaseReached = true;
765 766
    }

767

768
    // extract waypoints
769
    QVector<QGeoCoordinate> CSWpList; // list with potential waypoints (from _missionItems), for _currentMissionItems
770

Valentin Platzgummer's avatar
Valentin Platzgummer committed
771
    if (!reverse) {
772
        if (!extractCoordinateList(_missionItems, CSWpList, _startWaypointIndex, _endWaypointIndex)) {
773 774 775 776
            qWarning("WimaController::calcNextPhase(): error on waypoint extraction.");
            return false;
        }
    } else {
777
        if (!extractCoordinateList(_missionItems, CSWpList, _endWaypointIndex, _startWaypointIndex)) {
778 779 780 781 782
            qWarning("WimaController::calcNextPhase(): error on waypoint extraction.");
            return false;
        }

        // reverse path
783 784
        QVector<QGeoCoordinate> reversePath;
        for (QGeoCoordinate c : CSWpList)
785
            reversePath.prepend(c);
786 787
        CSWpList.clear();
        CSWpList.append(reversePath);
788
    }
789

790

791 792 793 794 795 796
    // calculate phase length
    _measurementPathLength = 0;
    for (int i = 0; i < CSWpList.size()-1; ++i)
        _measurementPathLength += CSWpList[i].distanceTo(CSWpList[i+1]);


797
    // set start waypoint index for next phase
Valentin Platzgummer's avatar
Valentin Platzgummer committed
798
    if (!lastMissionPhaseReached) {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
799
        disconnect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
800
        if (!reverse) {
801 802 803 804 805 806 807 808 809
            int untruncated = std::max(_endWaypointIndex + 1 - _overlapWaypoints.rawValue().toInt(), 0);
            int truncated   = std::min(untruncated , _missionItems.count()-1);
            _nextPhaseStartWaypointIndex.setRawValue(truncated  + 1);
        }
        else {
            int untruncated = std::min(_endWaypointIndex - 1 + _overlapWaypoints.rawValue().toInt(), _missionItems.count()-1);
            int truncated   = std::max(untruncated , 0);
            _nextPhaseStartWaypointIndex.setRawValue(truncated  + 1);
        }
Valentin Platzgummer's avatar
Valentin Platzgummer committed
810
        connect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
811
    }
812 813

    // calculate path from home to first waypoint
814
    QVector<QGeoCoordinate> arrivalPath;
815 816 817 818
    if (!_takeoffLandPostion.isValid()){
        qWarning("WimaController::calcNextPhase(): _takeoffLandPostion not valid.");
        return false;
    }
819
    if ( !calcShortestPath(_takeoffLandPostion, CSWpList.first(), arrivalPath) ) {
820 821
        qWarning("WimaController::calcNextPhase(): Not able to calc path from home to first waypoint.");
        return false;
822
    }
823 824 825 826 827 828

    // calculate arrival path length
    _arrivalPathLength = 0;
    for (int i = 0; i < arrivalPath.size()-1; ++i)
        _arrivalPathLength += arrivalPath[i].distanceTo(arrivalPath[i+1]);

829
    arrivalPath.removeFirst();
830 831

    // calculate path from last waypoint to home
832 833
    QVector<QGeoCoordinate> returnPath;
    if ( !calcShortestPath(CSWpList.last(), _takeoffLandPostion, returnPath) ) {
834
        qWarning("WimaController::calcNextPhase(): Not able to calc path from home to last waypoint.");
835
        return false;
836 837 838 839 840 841 842
    }

    // calculate arrival path length
    _returnPathLength = 0;
    for (int i = 0; i < returnPath.size()-1; ++i)
        _returnPathLength += returnPath[i].distanceTo(returnPath[i+1]);

843 844
    returnPath.removeFirst();
    returnPath.removeLast();
845

846

847

848 849 850
    // create Mission Items
    _missionController->removeAll();
    QmlObjectListModel* missionControllerVisuals = _missionController->visualItems();
851 852 853 854

    // set homeposition of settingsItem
    MissionSettingsItem* settingsItem = missionControllerVisuals->value<MissionSettingsItem *>(0);
    if (settingsItem == nullptr) {
855 856
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
857 858 859
    }
    settingsItem->setCoordinate(_takeoffLandPostion);

860
    // set takeoff position for first mission item (bug)
861
    missionController()->insertSimpleMissionItem(_takeoffLandPostion, 1);
862 863 864 865
    SimpleMissionItem *takeoffItem = missionControllerVisuals->value<SimpleMissionItem*>(1);
    if (takeoffItem == nullptr) {
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
866
    }
867
    takeoffItem->setCoordinate(_takeoffLandPostion);
868

869
    // create change speed item, after take off
870 871 872 873 874 875
    _missionController->insertSimpleMissionItem(_takeoffLandPostion, 2);
    SimpleMissionItem *speedItem = missionControllerVisuals->value<SimpleMissionItem*>(2);
    if (speedItem == nullptr) {
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
    }
Valentin Platzgummer's avatar
Valentin Platzgummer committed
876
    speedItem->setCommand(MAV_CMD_DO_CHANGE_SPEED);// set coordinate must be after setCommand (setCommand sets coordinate to zero)
877
    speedItem->setCoordinate(_takeoffLandPostion);
878 879 880 881 882 883 884 885 886 887 888 889 890 891
    speedItem->missionItem().setParam2(_arrivalReturnSpeed.rawValue().toDouble());

    // insert arrival path
    for (auto coordinate : arrivalPath)
        _missionController->insertSimpleMissionItem(coordinate, missionControllerVisuals->count());

    // create change speed item, after arrival path
    int index = missionControllerVisuals->count();
    _missionController->insertSimpleMissionItem(CSWpList.first(), index);
    speedItem = missionControllerVisuals->value<SimpleMissionItem*>(index);
    if (speedItem == nullptr) {
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
    }
Valentin Platzgummer's avatar
Valentin Platzgummer committed
892
    speedItem->setCommand(MAV_CMD_DO_CHANGE_SPEED); // set coordinate must be after setCommand (setCommand sets coordinate to zero)
893
    speedItem->setCoordinate(CSWpList.first());
894 895
    speedItem->missionItem().setParam2(_flightSpeed.rawValue().toDouble());

896 897 898 899 900 901 902 903 904 905 906 907
    // insert Circular Survey coordinates
    for (auto coordinate : CSWpList)
        _missionController->insertSimpleMissionItem(coordinate, missionControllerVisuals->count());

    // create change speed item, after circular survey
    index = missionControllerVisuals->count();
    _missionController->insertSimpleMissionItem(CSWpList.last(), index);
    speedItem = missionControllerVisuals->value<SimpleMissionItem*>(index);
    if (speedItem == nullptr) {
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
    }
Valentin Platzgummer's avatar
Valentin Platzgummer committed
908 909
    speedItem->setCommand(MAV_CMD_DO_CHANGE_SPEED); // set coordinate must be after setCommand (setCommand sets coordinate to zero)
    speedItem->setCoordinate(CSWpList.last());
910 911 912 913 914
    speedItem->missionItem().setParam2(_arrivalReturnSpeed.rawValue().toDouble());

    // insert return path coordinates
    for (auto coordinate : returnPath)
        _missionController->insertSimpleMissionItem(coordinate, missionControllerVisuals->count());
915 916

    // set land command for last mission item
917 918 919
    index = missionControllerVisuals->count();
    _missionController->insertSimpleMissionItem(_takeoffLandPostion, index);
    SimpleMissionItem *landItem = missionControllerVisuals->value<SimpleMissionItem*>(index);
920
    if (landItem == nullptr) {
921 922
        qWarning("WimaController::calcNextPhase(): nullptr");
        return false;
923
    }
924
    _missionController->setLandCommand(*landItem);
925

926
    // copy to _currentMissionItems
927 928 929
    for ( int i = 1; i < missionControllerVisuals->count(); i++) {
        SimpleMissionItem *visualItem     = missionControllerVisuals->value<SimpleMissionItem*>(i);
        if (visualItem == nullptr) {
930
            qWarning("WimaController::calcNextPhase(): Nullptr at SimpleMissionItem!");
931
            _currentMissionItems.clear();
932
            return false;
933
        }
934

935
        SimpleMissionItem *visualItemCopy = new SimpleMissionItem(*visualItem, true, this);
936 937
        _currentMissionItems.append(visualItemCopy);
    }
938

939 940 941 942 943 944
    double dist = 0;
    double time = 0;
    if (!_missionController->distanceTimeToMissionEnd(dist, time, 1, false))
        qWarning("WimaController::calcNextPhase: distanceTimeToMissionEnd returned false!");
    _setPhaseDistance(dist);
    _setPhaseDuration(time);
945
    _missionController->removeAll(); // remove items from _missionController, will be added on upload
Valentin Platzgummer's avatar
Valentin Platzgummer committed
946
    _updateAltitude();
947

Valentin Platzgummer's avatar
Valentin Platzgummer committed
948
    _updateCurrentPath();
949
    emit currentMissionItemsChanged();
950 951

    return true;
952
}
953

Valentin Platzgummer's avatar
Valentin Platzgummer committed
954
void WimaController::_updateWaypointPath()
955 956
{
    _waypointPath.clear();
957
    extractCoordinateList(_missionItems, _waypointPath, 0, _missionItems.count()-1);
958

959 960
    emit waypointPathChanged();
}
Valentin Platzgummer's avatar
Valentin Platzgummer committed
961
void WimaController::_updateCurrentPath()
962 963
{
    _currentWaypointPath.clear();
964
    extractCoordinateList(_currentMissionItems, _currentWaypointPath, 0, _currentMissionItems.count()-1);
965

966 967
    emit currentWaypointPathChanged();
}
968

Valentin Platzgummer's avatar
Valentin Platzgummer committed
969
void WimaController::_updateNextWaypoint()
970 971
{
    if (_endWaypointIndex < _missionItems.count()-2) {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
972
        disconnect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
973
        _nextPhaseStartWaypointIndex.setRawValue(1 + std::max(_endWaypointIndex + 1 - _overlapWaypoints.rawValue().toInt(), 0));
Valentin Platzgummer's avatar
Valentin Platzgummer committed
974
        connect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
975 976 977
    }
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
978
void WimaController::_recalcCurrentPhase()
979
{
Valentin Platzgummer's avatar
Valentin Platzgummer committed
980
    disconnect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
981
    _nextPhaseStartWaypointIndex.setRawValue(_startWaypointIndex + 1);    
Valentin Platzgummer's avatar
Valentin Platzgummer committed
982 983
    connect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
    _calcNextPhase();
984 985
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
986
bool WimaController::_setTakeoffLandPosition()
987 988 989 990 991 992
{
    _takeoffLandPostion.setAltitude(0);
    _takeoffLandPostion.setLongitude(_serviceArea.center().longitude());
    _takeoffLandPostion.setLatitude(_serviceArea.center().latitude());

    return true;
993 994
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
995
void WimaController::_updateflightSpeed()
996
{
997 998 999 1000 1001 1002 1003 1004 1005
    int speedItemCounter = 0;
    for (int i = 0; i < _currentMissionItems.count(); i++) {
        SimpleMissionItem *item = _currentMissionItems.value<SimpleMissionItem *>(i);
        if (item != nullptr && item->command() == MAV_CMD_DO_CHANGE_SPEED) {
            speedItemCounter++;
            if (speedItemCounter == 2) {
                item->missionItem().setParam2(_flightSpeed.rawValue().toDouble());
            }
        }
1006
    }
1007

1008 1009 1010 1011
    _setPhaseDuration(_phaseDistance/_flightSpeed.rawValue().toDouble()
                      + (_arrivalPathLength + _returnPathLength)
                      / _arrivalReturnSpeed.rawValue().toDouble());

1012 1013 1014 1015
    if (speedItemCounter != 3)
        qWarning("WimaController::updateflightSpeed(): internal error.");
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1016
void WimaController::_updateArrivalReturnSpeed()
1017 1018 1019 1020 1021 1022 1023 1024 1025 1026
{
    int speedItemCounter = 0;
    for (int i = 0; i < _currentMissionItems.count(); i++) {
        SimpleMissionItem *item = _currentMissionItems.value<SimpleMissionItem *>(i);
        if (item != nullptr && item->command() == MAV_CMD_DO_CHANGE_SPEED) {
            speedItemCounter++;
            if (speedItemCounter != 2) {
                item->missionItem().setParam2(_arrivalReturnSpeed.rawValue().toDouble());
            }
        }
1027
    }
1028

1029 1030 1031 1032
    _setPhaseDuration(_phaseDistance/_flightSpeed.rawValue().toDouble()
                      + (_arrivalPathLength + _returnPathLength)
                      / _arrivalReturnSpeed.rawValue().toDouble());

1033 1034 1035
    if (speedItemCounter != 3)
        qWarning("WimaController::updateArrivalReturnSpeed(): internal error.");

1036 1037
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1038
void WimaController::_updateAltitude()
1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049
{
    for (int i = 0; i < _currentMissionItems.count(); i++) {
        SimpleMissionItem *item = _currentMissionItems.value<SimpleMissionItem *>(i);
        if (item == nullptr) {
            qWarning("WimaController::updateAltitude(): nullptr");
            return;
        }
        item->altitude()->setRawValue(_altitude.rawValue().toDouble());
    }
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1050
void WimaController::_checkBatteryLevel()
1051
{
1052 1053 1054 1055 1056
    Vehicle *managerVehicle     = masterController()->managerVehicle();
    WimaSettings* wimaSettings  = qgcApp()->toolbox()->settingsManager()->wimaSettings();
    int batteryThreshold        = wimaSettings->lowBatteryThreshold()->rawValue().toInt();
    bool enabled                = _enableWimaController.rawValue().toBool();
    unsigned int minTime        = wimaSettings->minimalRemainingMissionTime()->rawValue().toUInt();
1057

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1058
    if (managerVehicle != nullptr && enabled == true) {
1059 1060 1061 1062 1063 1064 1065 1066
        Fact *battery1percentRemaining = managerVehicle->battery1FactGroup()->getFact(VehicleBatteryFactGroup::_percentRemainingFactName);
        Fact *battery2percentRemaining = managerVehicle->battery2FactGroup()->getFact(VehicleBatteryFactGroup::_percentRemainingFactName);


        if (battery1percentRemaining->rawValue().toDouble() < batteryThreshold
                && battery2percentRemaining->rawValue().toDouble() < batteryThreshold) {
            _setVehicleHasLowBattery(true);
            if (!_lowBatteryHandlingTriggered) {
1067 1068 1069 1070 1071

                if (_missionController->remainingTime() <= minTime) {
                    _lowBatteryHandlingTriggered = true;
                }
                else {
1072 1073 1074
                    _lowBatteryHandlingTriggered = true;
                    _srtlReason = BatteryLow;
                    _initSmartRTL();
1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085
                }
            }
        }
        else {
            _setVehicleHasLowBattery(false);
            _lowBatteryHandlingTriggered = false;
        }

    }
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1086 1087 1088 1089
void WimaController::_eventTimerHandler()
{
    static EventTicker batteryLevelTicker(EVENT_TIMER_INTERVAL, CHECK_BATTERY_INTERVAL);
    static EventTicker snakeEventLoopTicker(EVENT_TIMER_INTERVAL, SNAKE_EVENT_LOOP_INTERVAL);
1090
    static EventTicker rosBridgeTicker(EVENT_TIMER_INTERVAL, 1000);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1091 1092 1093 1094 1095 1096 1097 1098 1099

    // Battery level check necessary?
    if ( batteryLevelTicker.ready() )
        _checkBatteryLevel();

    // Snake flight plan update necessary?
    if ( snakeEventLoopTicker.ready() ) {
        if ( _enableSnake.rawValue().toBool() && _localPlanDataValid && !_snakeCalcInProgress && _scenarioDefinedBool) {

1100
            _snakeProgress.clear();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1101
            long n = _scenario.getTilesENU().size();
1102
            _snakeProgress.reserve(n);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1103 1104
            std::srand(time(NULL));
            for (long i=0; i<n; ++i){
1105
                int r{rand()%200};
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1106 1107
                if ( r > 100 )
                    r = 100;
1108
                _snakeProgress.append(r);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1109 1110 1111
            }

            _snakeWorker.setScenario(_scenario);
1112
            _snakeWorker.setProgress(_snakeProgress);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1113 1114
            _snakeWorker.setLineDistance(_snakeLineDistance.rawValue().toDouble());
            _snakeWorker.setMinTransectLength(_snakeMinTransectLength.rawValue().toDouble());
1115
            _setSnakeCalcInProgress(true);
1116
            _snakeWorker.start();
1117 1118

            emit snakeProgressChanged();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1119 1120
        }
    }
1121

1122
    if (rosBridgeTicker.ready()) {
1123 1124
//        using namespace ros_bridge;

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1125
        _pRosBridge->publish(_snakeTilesLocal, "/snake/snake_tiles");
1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228
//        // Time
//        class Time time(1, 2);
//        rapidjson::Document doc(rapidjson::kObjectType);
//        // Write to stdout
//        cout << "Time" << endl;
//        cout << "Return value : " << time.toJson(doc, doc.GetAllocator()) << std::endl;
//        rapidjson::OStreamWrapper out(std::cout);
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer(out);
//        doc.Accept(writer);
//        std::cout << std::endl << std::endl;


//        // Header
//        Header header(1, &time, "/map");
//        // Write to stdout
//        cout << "Header" << endl;
//        rapidjson::Document doc2(rapidjson::kObjectType);
//        cout << "Return value : " << header.toJson(doc2, doc2.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer2(out);
//        doc2.Accept(writer2);
//        std::cout << std::endl << std::endl;


//        // Point 3D
//        QVector3D p1(1, 2, 3);
//        typedef Point32<QVector3D> PointWrapper;
//        PointWrapper pw1(&p1);
//        // Write to stdout
//        cout << "Point 3D" << endl;
//        rapidjson::Document doc3(rapidjson::kObjectType);
//        cout << "Return value : " << pw1.toJson(doc3, doc3.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer3(out);
//        doc3.Accept(writer3);
//        std::cout << std::endl << std::endl;


//        // Point 2D
//        QPoint p2D(1, 2);
//        p2D.x();
//        Point32<QPoint> pw2D(&p2D);
//        // Write to stdout
//        cout << "Point 2D" << endl;
//        rapidjson::Document docI(rapidjson::kObjectType);
//        cout << "Return value : " << pw2D.toJson(docI, docI.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writerI(out);
//        docI.Accept(writerI);
//        std::cout << std::endl << std::endl;


//        // Polygon
//        QVector3D p2(4, 5, 6);
//        QVector3D p3(7, 8, 9);
//        PointWrapper pw2(&p2);
//        PointWrapper pw3(&p3);
//        QVector<PointWrapper> pointList;
//        pointList.append(pw1);
//        pointList.append(pw2);
//        pointList.append(pw3);
//        typedef Polygon<PointWrapper, QVector> Poly;
//        Poly polyW(&pointList);
//        // Write to stdout
//        cout << "Polygon" << endl;
//        rapidjson::Document doc4(rapidjson::kObjectType);
//        cout << "Return value : " << polyW.toJson(doc4, doc4.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer4(out);
//        doc4.Accept(writer4);
//        std::cout << std::endl << std::endl;


//        // PolygonStamped
//        typedef PolygonStamped<PointWrapper, Poly> PolyWrapper;
//        PolyWrapper polyStamped(&header, &polyW);
//        // Write to stdout
//        cout << "PolygonStamped" << endl;
//        rapidjson::Document doc5(rapidjson::kObjectType);
//        cout << "Return value : " << polyStamped.toJson(doc5, doc5.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer5(out);
//        doc5.Accept(writer5);
//        std::cout << std::endl << std::endl;


//        // PolygonArray
//        // Define second Polygon
//        QVector3D p4(10, 11, 12);
//        QVector3D p5(13, 14, 15);
//        QVector3D p6(16, 17, 18);
//        PointWrapper pw4(&p4);
//        PointWrapper pw5(&p5);
//        PointWrapper pw6(&p6);
//        QVector<PointWrapper> pointList2{pw4, pw5, pw6};
//        Poly polyW2(&pointList2);
//        typedef PolygonArray<PointWrapper, Poly, QVector> PolyArray;
//        QVector<Poly*> polygons{&polyW, &polyW2};
//        PolyArray polyArray{};
//        polyArray.setHeader(&header);
//        polyArray.setPolygons(&polygons);
//        // Write to stdout
//        cout << "PolygonStamped" << endl;
//        rapidjson::Document doc6(rapidjson::kObjectType);
//        cout << "Return value : " << polyArray.toJson(doc6, doc6.GetAllocator()) << std::endl;
//        rapidjson::Writer<rapidjson::OStreamWrapper> writer6(out);
//        doc6.Accept(writer6);
//        std::cout << std::endl << std::endl;
1229
    }
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1230 1231 1232
}

void WimaController::_smartRTLCleanUp(bool flying)
1233 1234 1235 1236 1237 1238
{

    if ( !flying) { // vehicle has landed
        if (_executingSmartRTL) {
            _executingSmartRTL = false;
            _loadCurrentMissionItemsFromBuffer();
1239 1240
            _setPhaseDistance(_phaseDistanceBuffer);
            _setPhaseDuration(_phaseDurationBuffer);
1241
            _showAllMissionItems.setRawValue(true);
1242 1243
            _missionController->removeAllFromVehicle();
            _missionController->removeAll();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1244
            disconnect(masterController()->managerVehicle(), &Vehicle::flyingChanged, this, &WimaController::_smartRTLCleanUp);
1245 1246 1247 1248
        }
    }
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1249
void WimaController::_enableDisableLowBatteryHandling(QVariant enable)
1250 1251
{
    if (enable.toBool()) {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1252
        _eventTimer.start();
1253
    } else {
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1254
        _eventTimer.stop();
1255 1256 1257
    }
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1258
void WimaController::_reverseChangedHandler()
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1259
{
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1260
    disconnect(&_nextPhaseStartWaypointIndex,  &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1261
    _nextPhaseStartWaypointIndex.setRawValue(_endWaypointIndex+1);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1262
    connect(&_nextPhaseStartWaypointIndex,  &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1263

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1264
    _calcNextPhase();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1265 1266
}

1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284
void WimaController::_setPhaseDistance(double distance)
{
    if (!qFuzzyCompare(distance, _phaseDistance)) {
        _phaseDistance = distance;

        emit phaseDistanceChanged();
    }
}

void WimaController::_setPhaseDuration(double duration)
{
    if (!qFuzzyCompare(duration, _phaseDuration)) {
        _phaseDuration = duration;

        emit phaseDurationChanged();
    }
}

1285 1286 1287 1288 1289 1290 1291
bool WimaController::_checkSmartRTLPreCondition(QString &errorString)
{
    if (!_localPlanDataValid) {
        errorString.append(tr("No WiMA data available. Please define at least a measurement and a service area."));
        return false;
    }
    Vehicle *managerVehicle = masterController()->managerVehicle();
1292 1293 1294 1295 1296 1297 1298 1299 1300
    if (!managerVehicle->flying()) {
         errorString.append(tr("Vehicle is not flying. Smart RTL not available."));
         return false;
    }

    if (!_joinedArea.containsCoordinate(managerVehicle->coordinate())) {
         errorString.append(tr("Vehicle not inside save area. Smart RTL not available."));
         return false;
    }
1301 1302

   return true;
1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319
}

bool WimaController::_calcReturnPath(QString &errorSring)
{
    // it is assumed that checkSmartRTLPreCondition() was called first and true was returned


    Vehicle *managerVehicle = masterController()->managerVehicle();

    QGeoCoordinate currentVehiclePosition = managerVehicle->coordinate();
    // check if vehicle inside _joinedArea, this statement is not inside checkSmartRTLPreCondition() because during checkSmartRTLPreCondition() vehicle is not paused yet
    if (!_joinedArea.containsCoordinate(currentVehiclePosition)) {
        errorSring.append(tr("Vehicle not inside joined area. Action not supported."));
        return false;
    }

    // calculate return path
1320
    QVector<QGeoCoordinate> returnPath;
1321 1322 1323 1324 1325 1326 1327 1328
    calcShortestPath(currentVehiclePosition, _takeoffLandPostion, returnPath);
    // successful?
    if (returnPath.isEmpty()) {
        errorSring.append(tr("Not able to calculate return path."));
        return false;
    }
    // qWarning() << "returnPath.size()" << returnPath.size();

1329
    _saveCurrentMissionItemsToBuffer();
1330 1331 1332
    _phaseDistanceBuffer = _phaseDistance;
    _phaseDurationBuffer = _phaseDuration;

1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361

    // create Mission Items
    removeFromVehicle();
    QmlObjectListModel* missionControllerVisuals = _missionController->visualItems();

    // set homeposition of settingsItem
    MissionSettingsItem* settingsItem = missionControllerVisuals->value<MissionSettingsItem *>(0);
    if (settingsItem == nullptr) {
        qWarning("WimaController: nullptr");
        return false;
    }
    settingsItem->setCoordinate(_takeoffLandPostion);

    // copy from returnPath to _missionController
    QGeoCoordinate speedItemCoordinate = returnPath.first();
    for (auto coordinate : returnPath) {
        _missionController->insertSimpleMissionItem(coordinate, missionControllerVisuals->count());
    }
    //qWarning() << "missionControllerVisuals->count()" << missionControllerVisuals->count();

    // create speed item
    int speedItemIndex = 1;
    _missionController->insertSimpleMissionItem(speedItemCoordinate, speedItemIndex);
    SimpleMissionItem *speedItem = missionControllerVisuals->value<SimpleMissionItem*>(speedItemIndex);
    if (speedItem == nullptr) {
        qWarning("WimaController: nullptr");
        return false;
    }
    speedItem->setCommand(MAV_CMD_DO_CHANGE_SPEED);
1362 1363
    speedItem->setCoordinate(speedItemCoordinate);
    speedItem->missionItem().setParam2(_arrivalReturnSpeed.rawValue().toDouble());
1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397

    // set second item command to ordinary waypoint (is takeoff)
    SimpleMissionItem *secondItem = missionControllerVisuals->value<SimpleMissionItem*>(2);
    if (secondItem == nullptr) {
        qWarning("WimaController: nullptr");
        return false;
    }
    secondItem->setCoordinate(speedItemCoordinate);
    secondItem->setCommand(MAV_CMD_NAV_WAYPOINT);


    // set land command for last mission item
    SimpleMissionItem *landItem = missionControllerVisuals->value<SimpleMissionItem*>(missionControllerVisuals->count()-1);
    if (landItem == nullptr) {
        qWarning("WimaController: nullptr");
        return false;
    }
    _missionController->setLandCommand(*landItem);

    // copy to _currentMissionItems
    //qWarning() << "_currentMissionItems.count()" << _currentMissionItems.count();
    for ( int i = 1; i < missionControllerVisuals->count(); i++) {
        SimpleMissionItem *visualItem     = missionControllerVisuals->value<SimpleMissionItem*>(i);
        if (visualItem == nullptr) {
            qWarning("WimaController: Nullptr at SimpleMissionItem!");
            _currentMissionItems.clear();
            return false;
        }

        SimpleMissionItem *visualItemCopy = new SimpleMissionItem(*visualItem, true, this);
        _currentMissionItems.append(visualItemCopy);
    }
    //qWarning() << "_currentMissionItems.count()" << _currentMissionItems.count();

1398 1399 1400 1401 1402 1403
    double dist = 0;
    double time = 0;
    if (!_missionController->distanceTimeToMissionEnd(dist, time, 1, false))
        qWarning("WimaController::calcNextPhase: distanceTimeToMissionEnd returned false!");
    _setPhaseDistance(dist);
    _setPhaseDuration(time);
1404
    _missionController->removeAll(); // remove items from _missionController, will be added on upload
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1405
    _updateAltitude();
1406

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1407
    _updateCurrentPath();
1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426
    emit currentMissionItemsChanged();


    //qWarning() << "_currentMissionItems.count()" << _currentMissionItems.count();
    _showAllMissionItems.setRawValue(false);
    managerVehicle->trajectoryPoints()->clear();

    return true;
}

void WimaController::_setVehicleHasLowBattery(bool batteryLow)
{
    if (_vehicleHasLowBattery != batteryLow) {
        _vehicleHasLowBattery = batteryLow;

        emit vehicleHasLowBatteryChanged();
    }
}

1427 1428 1429 1430 1431 1432 1433 1434
void WimaController::_initSmartRTL()
{
    QString errorString;
    static int attemptCounter = 0;
    attemptCounter++;

    if (_checkSmartRTLPreCondition(errorString) == true) {
        _masterController->managerVehicle()->pauseVehicle();
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1435
        connect(masterController()->managerVehicle(), &Vehicle::flyingChanged, this, &WimaController::_smartRTLCleanUp);
1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461
        if (_calcReturnPath(errorString)) {
            _executingSmartRTL = true;
            attemptCounter = 0;

            switch(_srtlReason) {
                case BatteryLow:
                    emit returnBatteryLowConfirmRequired();
                break;
                case UserRequest:
                    emit returnUserRequestConfirmRequired();
                break;
            }

            return;
        }
    }
    if (attemptCounter > SMART_RTL_MAX_ATTEMPTS) { // try 3 times, somtimes vehicle is outside joined area
        errorString.append(tr("Smart RTL: No success after maximum number of attempts."));
        qgcApp()->showMessage(errorString);
        attemptCounter = 0;
    } else {
        _smartRTLAttemptTimer.singleShot(SMART_RTL_ATTEMPT_INTERVAL, this, &WimaController::_initSmartRTL);
    }
}

void WimaController::_executeSmartRTL()
1462 1463 1464 1465 1466
{
    forceUploadToVehicle();
    masterController()->managerVehicle()->startMission();
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497
void WimaController::_setSnakeConnectionStatus(WimaController::SnakeConnectionStatus status)
{
    if (_snakeConnectionStatus != status) {
        _snakeConnectionStatus = status;
        emit snakeConnectionStatusChanged();
    }
}

void WimaController::_setSnakeCalcInProgress(bool inProgress)
{
    if (_snakeCalcInProgress != inProgress){
        _snakeCalcInProgress = inProgress;
        emit snakeCalcInProgressChanged();
    }
}

bool WimaController::_verifyScenarioDefined()
{
    _scenarioDefinedBool = _scenario.defined(_snakeTileWidth.rawValue().toDouble(), _snakeTileHeight.rawValue().toDouble(), _snakeMinTileArea.rawValue().toDouble());
    return _scenarioDefinedBool;
}

bool WimaController::_verifyScenarioDefinedWithErrorMessage()
{
    bool value = _verifyScenarioDefined();
    if (!value){
        QString errorString;
        for (auto c : _scenario.errorString)
            errorString.push_back(c);
        qgcApp()->showMessage(errorString);
    }
1498
    return value;
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1499 1500
}

1501 1502
void WimaController::_snakeStoreWorkerResults()
{
1503
    auto start = std::chrono::high_resolution_clock::now();
1504 1505
    _missionItems.clearAndDeleteContents();
    const WorkerResult_t &r = _snakeWorker.getResult();
1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517
    _setSnakeCalcInProgress(false);
    if (!r.success) {
        qgcApp()->showMessage(r.errorMessage);
        return;
    }

    // create Mission items from r.waypoints
    long n = r.waypoints.size() - r.returnPathIdx.size() - r.arrivalPathIdx.size() + 2;
    assert(n >= 1);
    QVector<MissionItem> missionItems;
    missionItems.reserve(int(n));

1518 1519 1520 1521 1522 1523
    // Remove all items from mission controller.
    _missionController->removeAll();
    QmlObjectListModel* missionControllerVisualItems = _missionController->visualItems();

    // Create QVector<QGeoCoordinate> containing all waypoints;
    unsigned long startIdx = r.arrivalPathIdx.last();
1524
    unsigned  long endIdx = r.returnPathIdx.first();
1525
    QVector<QGeoCoordinate> waypoints;
1526 1527
    for (unsigned long i = startIdx; i <= endIdx; ++i) {
        QGeoCoordinate wp{r.waypoints[int(i)].value<QGeoCoordinate>()};
1528
        waypoints.append(wp);
1529 1530 1531
    }

    // create SimpleMissionItem by using _missionController
1532 1533 1534 1535 1536 1537 1538
    long insertIdx = missionControllerVisualItems->count();
    for (auto wp : waypoints)
        _missionController->insertSimpleMissionItem(wp, insertIdx++);
    SimpleMissionItem *takeOffItem = missionControllerVisualItems->value<SimpleMissionItem*>(1);
    if (takeOffItem == nullptr) {
        qWarning("WimaController::_snakeStoreWorkerResults(): Nullptr at SimpleMissionItem!");
        return;
1539
    }
1540 1541 1542
    takeOffItem->setCommand(MAV_CMD_NAV_WAYPOINT);
    takeOffItem->setCoordinate(waypoints[0]);

1543 1544 1545 1546
    // copy mission items from _missionController to _missionItems
    for ( int i = 1; i < missionControllerVisualItems->count(); i++) {
        SimpleMissionItem *visualItem     = qobject_cast<SimpleMissionItem *>((*missionControllerVisualItems)[i]);
        if (visualItem == nullptr) {
1547
            qWarning("WimaController::_snakeStoreWorkerResults(): Nullptr at SimpleMissionItem!");
1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561
            return;
        }
        SimpleMissionItem *visualItemCopy = new SimpleMissionItem(*visualItem, true, this);
        _missionItems.append(visualItemCopy);
    }

    _updateWaypointPath();

    // set _nextPhaseStartWaypointIndex to 1
    disconnect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);
    bool reverse = _reverse.rawValue().toBool();
    _nextPhaseStartWaypointIndex.setRawValue(reverse? _missionItems.count() : int(1));
    connect(&_nextPhaseStartWaypointIndex,   &Fact::rawValueChanged, this, &WimaController::_calcNextPhase);

1562 1563
    _calcNextPhase();
    emit missionItemsChanged();
1564 1565 1566 1567 1568


    auto end = std::chrono::high_resolution_clock::now();
    double duration = std::chrono::duration_cast<std::chrono::milliseconds>(end-start).count();
    qWarning() << "WimaController::_snakeStoreWorkerResults execution time: " << duration << " ms.";
Valentin Platzgummer's avatar
Valentin Platzgummer committed
1569 1570
}

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1571 1572 1573 1574 1575 1576 1577 1578 1579
void WimaController::_startStopRosBridge()
{
    if (_enableSnake.rawValue().toBool()) {
        _pRosBridge->start();
    } else {
        _pRosBridge->stop();
    }
}

1580 1581 1582 1583 1584 1585
void WimaController::_loadCurrentMissionItemsFromBuffer()
{
    _currentMissionItems.clear();
    int numItems = _missionItemsBuffer.count();
    for (int i = 0; i < numItems; i++)
        _currentMissionItems.append(_missionItemsBuffer.removeAt(0));
1586

Valentin Platzgummer's avatar
Valentin Platzgummer committed
1587
    _updateCurrentPath();
1588 1589 1590 1591 1592 1593
}


void WimaController::_saveCurrentMissionItemsToBuffer()
{
    _missionItemsBuffer.clear();
1594 1595
    int numCurrentMissionItems = _currentMissionItems.count();
    for (int i = 0; i < numCurrentMissionItems; i++)
1596 1597 1598
        _missionItemsBuffer.append(_currentMissionItems.removeAt(0));
}

1599 1600