src/Centralstage/DeviceBundle/EventSubscriber/DevicepushSubscriber.php line 16

Open in your IDE?
  1. <?php
  3. namespace App\Centralstage\DeviceBundle\EventSubscriber;
  4. use App\Centralstage\DeviceBundle\Event\DevicepushEvent as Devicepush;
  5. use App\Centralstage\DeviceBundle\Models\DeviceDataModel;
  6. use App\Centralstage\CoreBundle\Utils\FileHelper;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. class DevicepushSubscriber implements EventSubscriberInterface
  11. {
  12.     CONST collectionFolder = "collection/";
  13.     private $fileSizeInBytes  = 5242880; // 5mb in bytes
  14.     //private $fileSizeInBytes  = 1000000; // 1mb in bytes
  16.     public function onDevicePush(Devicepush $devicepush): void
  17.     {   
  18.         try{
  19.             //DATA
  20.             $EventData       = $devicepush->getData();
  21.             $deviceDetails   = $EventData["deviceDetails"];
  22.             $rawData         = $EventData["rawData"];
  23.             $timestamp       = $EventData["devicetimestamp"];
  24.             $currentDT       = $EventData["currentDT"];
  25.             
  26.             unset($EventData); //free memory
  28.             if(is_string($rawData) && !empty($timestamp)){
  29.                 $NewFile_Bool = true;
  30.                 $dataArray    = json_decode($rawData, true);
  31.                 if(isset($dataArray["deviceStateTable"])){
  32.                     $deviceStateTable = $dataArray["deviceStateTable"];
  33.                     $folderPath       = DeviceDataModel::getFolderPath($deviceDetails, $currentDT);
  34.                     $collectionDir    = $folderPath.self::collectionFolder;
  35.                     if(!file_exists($collectionDir)){ //check dir existing 
  36.                         FileHelper::createDir($collectionDir);
  37.                     }else{
  38.                         /*** $lastDataFile    = isset($deviceDetails["deviceLastDataID"]) ? (file_exists($folderPath.$deviceDetails["deviceLastDataID"].".json") ? file_get_contents($folderPath.$deviceDetails["deviceLastDataID"].".json") : false)  : false;
  39.                         $currentFile     = is_string($lastDataFile) ? json_decode($lastDataFile, true) : false; ****/
  40.                         $currentFile     = !empty($deviceDetails["deviceLastDataID"]) ? $deviceDetails["deviceLastDataID"] : false;
  41.                         if(!empty($currentFile)){
  42.                             /** $currentFile    = isset($currentFile["timestamp"]) ? $currentFile["timestamp"] : 0; **/
  43.                             $selectedFile   = $collectionDir.$currentFile.".json";
  44.                             $fileSize       = FileHelper::getFileSize($selectedFile);
  45.                             if(!empty($fileSize) && ($fileSize < $this->fileSizeInBytes)){ // less than 5mb size in bytes 
  46.                                 $NewFileName  = $collectionDir.$timestamp.".json";
  47.                                 $data         = json_decode(file_get_contents($selectedFile, true), true);
  48.                                 if(!isset($data[$timestamp])){
  49.                                     $data[$timestamp] = [];
  50.                                 }
  51.                                 $data[$timestamp][] = $deviceStateTable;
  52.                                 $JsonData           = json_encode($data);
  53.                                 file_put_contents($selectedFile, $JsonData);
  54.                                 unset($data, $JsonData); //free Storage 
  55.                                 FileHelper::renameFile($selectedFile, $NewFileName);
  56.                                 $NewFile_Bool = false;
  57.                             }
  58.                         }
  59.                     }
  60.                     if($NewFile_Bool){
  61.                         $result      = [$timestamp => [$deviceStateTable]];
  62.                         $result      = json_encode($result);
  63.                         $outputfile  = "{$collectionDir}{$timestamp}.json";
  64.                         file_put_contents($outputfile, $result);
  65.                     }
  66.                 }
  67.             }
  68.         }catch (\Exception $exception) { $error = $exception->getMessage(); }
  69.     }
  71.     public static function getSubscribedEvents(): array
  72.     {
  73.         return [
  74.             'device.collection.push' => 'onDevicePush'
  75.         ];
  76.     }
  77. }