resupplySupplierController.h

Go to the documentation of this file.

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



#pragma once

#include <vrfMsgTransport/events.h>

#include "vrfobjcore/singleTaskControllerComponent.h"

#include "vrfmodel/resupplySupplierStateData.h"
#include "vrfmodel/vrfmodelDefines.h"

class DtResupplySupplierControllerDescriptor;


class DT_DLL_vrfmodel DtResupplySupplierController : public DtSingleTaskControllerComponent
{
public:

   DtResupplySupplierController(const DtString& name, 
      DtVrfObject* owner,
      DtSimManager* simManager, 
      DtComponentDescriptor* compDesc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

   virtual ~DtResupplySupplierController();

   virtual const char* type() const;

   virtual bool postAddComponentsInit();

   virtual bool init();

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

   virtual void processSetSupplying(DtSimMessage * msg);

   virtual void addSetDataCallbacks();

   void removeSetDataCallbacks();

   virtual void tick();

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

protected:

   DtResupplySupplierController();

   DtResupplySupplierController(const DtResupplySupplierController &
      orig);

   const DtResupplySupplierController & operator=(const
      DtResupplySupplierController & orig);

   virtual const DtResupplySupplierControllerDescriptor* getDescriptor();


   virtual void serviceRequestEvent(const DtEvent&);
   virtual void processServiceRequest(const DtServiceRequestInteraction& serviceRequest);
   virtual void resupplyReceivedEvent(const DtEvent&);
   virtual void processResupplyReceived(const DtResupplyRecInteraction& resupplyReceived);
   virtual void resupplyCancelEvent(const DtEvent&);
   virtual void processResupplyCancel(const DtResupplyCancelInteraction& resupplyCancel);


   virtual std::shared_ptr<DtResupplyOfferInteraction> createResupplyOfferInteraction(const DtGlobalObjectDesignator& receiver);
   virtual void sendResupplyOfferInteraction(DtResupplyOfferInteraction& resupplyOffer);
   virtual std::shared_ptr<DtResupplyCancelInteraction> createResupplyCancelInteraction(const DtGlobalObjectDesignator& receiver);
   virtual void sendResupplyCancelInteraction(DtResupplyCancelInteraction& resupplyCancel);

protected:
   virtual void transferSupplies();
   virtual void processReadyState(const DtGlobalObjectDesignator& receiver);
   virtual void processOfferingState(const DtGlobalObjectDesignator& receiver);

   virtual void updateRequestedSupplies(const DtServiceRequestInteraction& serviceRequest);
   virtual void updateOfferedSupplies(const DtGlobalObjectDesignator& receiver);
   virtual void updateSentSupplies(const DtResupplyRecInteraction& resupplyReceived);
   virtual void removeSentSupplies(const DtGlobalObjectDesignator& receiver);
   virtual bool checkSuppliesRequested(const DtGlobalObjectDesignator& receiver);
   virtual bool checkResourcesAvailable(const DtGlobalObjectDesignator& receiver);
   virtual bool checkResourceAvailable(DtEntityType type);
   virtual bool checkResourceAvailable(DtString supplyName);
   virtual double resourceAvailable(DtEntityType type);
   virtual double resourceAvailable(DtString supplyName);
   virtual void updateResource(DtEntityType type, double quantity);
   virtual void updateResource(DtString supplyName, double quantity);

   virtual const DtString lookUpSupplyType(const DtEntityType& type) const;

   virtual DtTime currentSimTime();

protected:
   const DtResupplySupplierControllerDescriptor* myResupplySupplierDesc;

   std::map<DtGlobalObjectDesignator, DtResupplySupplierStateData> mySupplierStateData;

protected:
   const DtTime theOfferingStateDefaultTimeout = 120.0;     
};