src/Centralstage/DeviceBundle/EventSubscriber/SensorRawPacketSubscriber.php line 21

Open in your IDE?
  1. <?php
  3. namespace App\Centralstage\DeviceBundle\EventSubscriber;
  5. use App\Centralstage\CoreBundle\Models\mongoDBDataModel;
  6. use App\Centralstage\CoreBundle\Utils\DateTimeHelper;
  7. use App\Centralstage\DeviceBundle\Event\SensorRawPacketEvent;
  8. use App\Centralstage\DeviceBundle\Models\DeviceDataModel;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Doctrine\ODM\MongoDB\DocumentManager;
  11. use MongoDB\BSON\UTCDateTime;
  13. class SensorRawPacketSubscriber implements EventSubscriberInterface
  14. {
  15.     private $documentManager;
  16.     public function __construct(DocumentManager $documentManager)
  17.     {
  18.         $this->documentManager = $documentManager;
  19.     }
  21.     public function onProcessRawData(SensorRawPacketEvent $RawObject) : void
  22.     {   
  23.         try {
  24.             $context = $RawObject->getData();
  25.             list($deviceChannelID, $data, $orgKey, $currentDate,$MachineType) = array_values($context);
  26.             $currentDT         = DateTimeHelper::parseDateTime($currentDate, 'Y-m-d', DateTimeHelper::ServerTimeZone);
  27.             $conDetails        = mongoDBDataModel::getDataBaseSensorCollection($orgKey,$deviceChannelID, $currentDT,$MachineType);
  28.             $dataBase          = $conDetails["database"];
  29.             $collectionName    = $conDetails["collection"];
  30.             $data              = json_decode($data, true);
  31.             $deviceTimestamp   = $data['timestamp'];
  32.             $timestamp         = new UTCDateTime($deviceTimestamp * 1000); // Convert to milliseconds
  33.             $data['timestamp'] = $timestamp;
  34.             $data['deviceChannelID'] = $deviceChannelID;
  35.           
  36.         
  37.             $database = $this->documentManager->getClient()->selectDatabase($dataBase);
  38.         
  39.             // Check if collection exists and create if not
  40.             $collections = $database->listCollections(['filter' => ['name' => $collectionName]]);
  41.             if (iterator_count($collections) === 0) {
  42.                 $database->command([
  43.                     'create' => $collectionName,
  44.                     'timeseries' => [
  45.                         'timeField' => 'timestamp',
  46.                     ],
  47.                 ]);
  48.                 // Create index on the timestamp field
  49.                 $database->selectCollection($collectionName)->createIndex(['timestamp' => 1]);
  50.             }
  51.         
  52.             // Insert data into the collection
  53.             $database->selectCollection($collectionName)->insertOne($data);
  54.         } catch (\Exception $exception) {
  55.             $error = $exception->getMessage();
  56.         }
  57.     }
  59.     public static function getSubscribedEvents(): array
  60.     {
  61.         return [
  62.             'device.raw' => 'onProcessRawData'
  63.         ];
  64.     }
  66.     public function __destruct(){}
  67. }