convoyTaskController.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2010 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/



#pragma once

#include "vrfmodel/vrfmodelDefines.h"
#include "vrfobjcore/convoyPSR.h"
#include "vrfobjcore/singleTaskControllerComponent.h"
#include "vrfobjparam/convoyDescriptor.h"
#include "vrftasks/setDataRequest.h"
#include "vrfutil/rwRailSegment.h"
#include <readerWriter/rwReal.h>
#include "vrfutil/rwTemplatedList.h"
#include "terrainCS/coordSystem.h"

#include <boost/shared_ptr.hpp>

#define CONVOY_CONTROLLER_MAKE_FIRST_SEGMENT 0


class DtAsyncJobMapEntry;
class DtVrfObjectMessage;
class DtBoolSetting;

class DT_DLL_vrfmodel DtConvoyTaskController : public DtSingleTaskControllerComponent
{
public:
   DtConvoyTaskController(const DtString& name, 
      DtVrfObject* owner,
      DtSimManager* simManager, 
      DtComponentDescriptor* desc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

   virtual ~DtConvoyTaskController();

   virtual bool init();

   virtual const char* type() const;

   virtual void clearTask();

   virtual void resetTask();
 
   virtual void registerTaskMsgCallbacks();

   static void convoyTaskCallback(DtSimMessage * msg, void * usr);

   static void taskCompleteReportCallback(const DtVrfObjectMessage* msg, void * usr);

   static void destinationChangedCallback(const DtVrfObject* obj, void* usr);

   static void objectAboutToBeRemovedCallback(const DtVrfObject* obj, void* usr);

   static DtSimComponent * creator(const DtString& name, 
      DtVrfObject* owner,
      DtSimManager* simManager, 
      DtComponentDescriptor* desc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

   virtual void preFirstTickInit();

   virtual void tick();

   virtual bool createPSR();

   static  void settingConsumerCallback(const DtSettingsObject* settingsObject,
      void* usr);

   virtual void updateTaskVisualizations();

protected:
   void onObjectAboutToBeRemoved(const DtVrfObject* obj);

   virtual void onModifyVrfObject(const DtVrfObject* obj);

   virtual void onConvoyTask(DtSimMessage * msg);

   virtual void onTaskComplete(const DtVrfObjectMessage* msg);

   virtual void sendTaskToSubordinate(const DtSimTask& task, 
      const DtUUID& subordinate);

   virtual void sendSetToSubordinate(DtSetDataRequest& request,
      const DtUUID& subordinate);

   virtual bool setupTask(const DtVrfObject* aggregate, const DtVrfObject* destination, 
      bool pathPlan);

   virtual DtVector findAssemblyPoint(const DtVrfObject* aggregate, const DtVector& destination, 
      bool haveRails, const Coordinate_System* coordSys);

#if CONVOY_CONTROLLER_MAKE_FIRST_SEGMENT
   virtual DtRwRailSegment* createEntrySegment(const DtVrfObject* entity, 
      const DtVector& assemblyPoint, const Coordinate_System* coordSys) const;
#endif

   virtual bool setupSubordinates(const DtVrfObject* aggregate, bool clearSubs, bool& leaderSet);

   virtual void setupLeadOnDistance(int numberOfEntities, float distanceBetween);

   virtual bool createDirectRailPath(const DtVrfObject* leadEntity, const DtVrfObject* destination);

   virtual bool areSeparationDistancesWithinRange(const DtConvoyPSR::DtRwSubordinateList& subordinates, 
      const float distance, const float tolerance, const Coordinate_System* coordSys);

   virtual void setLeaderSpeed(const float speed);

   virtual void resettingPhaseTick(bool retask = true);

   virtual void startingPhaseTick();

   virtual void assemblingPhaseTick();

   virtual void convoyingPhaseTick();

   virtual void finishingPhaseTick();

   virtual DtVector findIntersectionOfLineAndCircle(const DtVector& centerPoint, 
      const DtVector& endPoint, double radius, const Coordinate_System* coordSys) const;

   virtual bool taskEntityToMoveToAssemblyPt(const DtVrfObject* entity, const DtVector& assemblyPoint,
      const Coordinate_System* coordSys);

   virtual bool getEntityPathToEntry(const DtVrfObject* entity, const DtVector& assemblyPoint,
      const Coordinate_System* coordSys);

   virtual DtRailSegment* findClosestEntryRail(const DtVrfObject* aggregate, 
      const double& radius,
      DtRailSegmentList* rails,
      int& railNumber,
      const Coordinate_System* coordSys) const;

   virtual bool isPointWithinRadius(const DtVector& center, double radius, 
      const DtVector& point, const Coordinate_System* coordSys) const;

   virtual bool findPointOnRailOutsideSphere(const DtVector& center, const double& radius, 
      const DtRailSegment* segment, DtVector& resultPoint, const Coordinate_System* coordSys) const;

   virtual void registerDestinationChangedCallback();
   
   virtual void unregisterDestinationChangedCallback();

   virtual bool updateConvoySubordinates(const DtVrfObject* aggregate,
      std::vector<DtUUID>& tempList, 
      bool recursive = false);

   virtual bool isEntityPartOfConvoy(const DtUUID& entity) const;

   virtual bool isEntityIndependentlyTasked(const DtVrfObject* entity) const;

   virtual void setConvoyFollowing();

   virtual void destroyedPhaseTick();

   virtual void sendClearTask(const DtUUID& recipientName,
      const DtSimTaskMessageType& taskType);

   double maxSearchRadius(const DtPoint& start, const DtPoint& end);

   virtual bool startPathPlan(const DtVrfObject* leadEntity, 
      const DtVrfObject* destination);

   virtual bool pathPlanFinished();

   virtual DtVector groundClamp(const DtVector& point, DtGeodeticCoord& lastPoint) const;

   virtual void processSetting( const DtBoolSetting* setting);

protected:

   boost::shared_ptr<DtAsyncJobMapEntry> myPathJobEntry;

   const DtConvoyDescriptor* myDescriptor;
   DtConvoyPSR* myProcessState;
   bool myDestinationChangedCallbackRegistered;
   bool myDrivingOnLeft;

private:
   DtConvoyTaskController(const DtConvoyTaskController& orig);

   DtConvoyTaskController& operator=(const DtConvoyTaskController& orig);
};