src/Controller/DevicesController.php line 854

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Device;
  6. use App\Form\DeviceType;
  7. use App\Entity\DataUplinks;
  8. use App\Repository\BoutonRepository;
  9. use App\Repository\DataUplinksRepository;
  10. use App\Repository\DeviceRepository;
  11. use App\Repository\ModeleRepository;
  12. use App\Repository\ScenarioRepository;
  13. use DateTime;
  14. use DateTimeZone;
  15. use Doctrine\DBAL\Schema\View;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Component\HttpClient\HttpClient;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Symfony\Component\Routing\Annotation\Route;
  20. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  21. use Symfony\Component\HttpFoundation\JsonResponse;
  22. use Symfony\Component\VarDumper\VarDumper;
  24. class DevicesController extends AbstractController
  25. {
  26.     /**
  27.      * @Route("/affecter_devices", name="affecter_devices")
  28.      */
  29.     public function affecterDevices(ScenarioRepository $scenarioRepository, ModeleRepository $modeleRepository, Request $request, DeviceRepository $deviceRepository)
  30.     {
  31.         $this->denyAccessUnlessGranted('ROLE_EDIT'); // restreindre l'accès à l'action affecterDevices si l'utilisateur n'a pas le role Edit.
  33.         $manager = $this->getDoctrine()->getManager();
  34.         $form = $this->createForm(DeviceType::class);
  36.         $form->handleRequest($request);
  37.         if ($form->isSubmitted() && $form->isValid()) {
  38.             $idClient = $_POST['device']['idClient'];
  39.             //Appel API GHOST
  40.             $httpClient = new HttpClient();
  41.             $httpClient = $httpClient->create();
  42.             $response = $httpClient->request('POST', 'https://ghost.camileia.com/api/societe', [
  43.                 'query' => [
  44.                     'pass1' => 'CBrEPEdovEmhrmyJTY5twbRB',
  45.                     'pass2' => 'wnuhGwNru3Q4VLilAi1OXW0G',
  46.                     'id' => $idClient
  47.                 ]
  48.             ]);
  49.             $client = $response->toArray();
  51.             $libelleClient = $client['societe']['libelle'];
  52.             $allCreatedDevicesTab = []; // contiendra tous les devices créés, servira pour mettre a jour le PAc des devices via API de Sigfox
  53.             //Pour chaque modèle créé
  54.             foreach ($_POST['modeles'] as $modele) {
  55.                 $tabSigFox = [];
  56.                 $tabSigFox['deviceTypeId'] = $modeleRepository->find($modele['idModele'])->getTypeDevice()->getIdTypeSigfox(); //ID du type de device enregistré par Sigfox
  57.                 $tabSigFox['productCertificate']['key'] = $modeleRepository->find($modele['idModele'])->getTypeDevice()->getProductKey(); //Clé produit du type de device enregistré par Sigfox
  58.                 //Pour chaque device d'un modèle
  59.                 foreach ($modele['devices'] as $devices) {
  60.                     //hydratation d'un nouveau device
  61.                     $device = new Device();
  62.                     $device->setIdClient($idClient)
  63.                         ->setLibelleClient($libelleClient)
  64.                         ->setModele($modeleRepository->find($modele['idModele']))
  65.                         ->setNumeroSerie($devices['idDevice'])
  66.                         ->setPac($devices['pac'])
  67.                         ->setVille($client['societe']['ville'])
  68.                         ->setScenario($scenarioRepository->find($devices['idScenario']))
  69.                         ->setLibelle($devices['libelle'])
  70.                         ->setDateActivation(new \DateTime());
  71.                     $manager->persist($device);
  72.                     $tabData = [];
  73.                     $tabData['id'] = $devices['idDevice'];
  74.                     $tabData['pac'] = $devices['pac'];
  75.                     $tabData['name'] = $devices['libelle'];
  76.                     $tabSigFox['data'][] = $tabData;
  77.                     $allCreatedDevicesTab[] = $tabSigFox; 
  78.                 }
  79.                 //Enregistrement des devices via l'API de Sigfox
  80.                 $this->ajouterDeviceAPISigfox($tabSigFox);
  81.             }
  82.             $manager->flush();
  83.             //MAJ du PAC des devices enregistrées
  84.             $devicesSigfox = $this->getInfosDeviceAPISigfox(); //Appel de l'api Sigfox afin de recevoir les informations pour tous les devices enregistrés
  85.             //pour chaque device créé
  86.             foreach ($allCreatedDevicesTab as $createdDevice) {
  87.                 //Pour chaque device enregistré chez Sigfox
  88.                 foreach ($devicesSigfox as $key => $value) {
  89.                     //Si les id correspondent, on met à jour le PAC du device correspondant
  90.                     if ($createdDevice['data'][0]['id'] == $key) {
  91.                         $deviceAModifier = $deviceRepository->find($key);
  92.                         $deviceAModifier->setPac($value);
  93.                         $manager->persist($deviceAModifier);
  94.                     }
  95.                 }
  96.             }
  97.             $manager->flush();
  98.             //redirection à la liste des clients
  99.             return $this->redirectToRoute('clients');
  100.         }
  102.         return $this->render('devices/affecter_device.html.twig', [
  103.             'form' => $form->createView(),
  104.         ]);
  105.     }
  107.     /**
  108.      * @Route("/devices/details_device/{idDevice}", name="details_device")
  109.      */
  110.     public function detailsDevice(int $idDevice, DeviceRepository $deviceRepository, DataUplinksRepository $dataUplinksRepository, BoutonRepository $boutonRepository)
  111.     {
  112.         $device = $deviceRepository->find($idDevice);
  113.         $dataUplinksDevice = $dataUplinksRepository->findDataUplinksByDevice($device->getId());
  114.         $boutonsDevice = $boutonRepository->findBoutonByScenario($device->getScenario()->getId());
  115.         return $this->render('devices/details_device.html.twig', [
  116.             'device' => $device,
  117.             'dataUplinksDevice' => $dataUplinksDevice,
  118.             'boutonsDevice' => $boutonsDevice,
  119.         ]);
  120.     }
  123.     /**
  124.      * Intercepte les données émises par les devices SimpleLeak
  125.      * @Route("/devices/sigfox/simpleleak", name="sigfox_callback_simpleleak")
  126.      */
  127.     public function getCallbackSigfoxSimpleLeak(Request $request, DeviceRepository $deviceRepository)
  128.     {
  129.         $manager = $this->getDoctrine()->getManager();
  130.         //Si un message est envoyé depuis un device SimpleLeak
  131.         if ($content = $request->getContent()) {
  132.             $dataUplinks = new DataUplinks(); //Nouvelle data pour l'historique
  133.             $data = json_decode($content, true);
  134.             $device = $deviceRepository->findDeviceByNumSerie($data['device']);
  135.             $horodating = new \DateTime();
  136.             //Si le code d'alerte émis n'est pas compris dans le tableau, on retourne une erreur
  137.             if (!in_array($data['alert'], ["00", "64", "65", "66", "67"])) {
  138.                 return $this->json(['status' => 'Unknown alert'], 500);
  139.             //Si le mode émis n'est pas compris dans le tableau, on retourne une erreur
  140.             } else if ($data['mode'] != "10") {
  141.                 return $this->json(['status' => 'Mode non pris en compte'], 501);
  142.             }
  143.             //Pour chaque code d'alerte, une action différente
  144.             switch ($data['alert']) {
  145.                 case '64':
  146.                     $dataUplinks->setMessageAlerte('Une fuite d\'eau a été détectée')
  147.                         ->setDevice($device)
  148.                         ->setMode($data['mode'])
  149.                         ->setCodeAlerte($data['alert'])
  150.                         ->setHorodating($horodating);
  151.                         $device->setIsBonEtat(1); //Le device communique
  152.                     break;
  153.                 case '65':
  154.                     $dataUplinks->setMessageAlerte('Fin de la fuite d\'eau')
  155.                         ->setDevice($device)
  156.                         ->setMode($data['mode'])
  157.                         ->setCodeAlerte($data['alert'])
  158.                         ->setHorodating($horodating);
  159.                         $device->setIsBonEtat(1); //Le device communique
  160.                     break;
  161.                 case '66':
  162.                     $dataUplinks->setMessageAlerte('Mauvaise orientation du boitier')
  163.                         ->setDevice($device)
  164.                         ->setMode($data['mode'])
  165.                         ->setCodeAlerte($data['alert'])
  166.                         ->setHorodating($horodating);
  167.                         $device->setIsBonEtat(1); //Le device communique
  168.                     break;
  169.                 case '67':
  170.                     $dataUplinks->setMessageAlerte('Le boitier est remis d\'aplomb')
  171.                         ->setDevice($device)
  172.                         ->setMode($data['mode'])
  173.                         ->setCodeAlerte($data['alert'])
  174.                         ->setHorodating($horodating);
  175.                         $device->setIsBonEtat(1); //Le device communique
  176.                     break;
  177.                 //Message "keep-alive" afin de savoir si le device émet toujours
  178.                 case "00":
  179.                     $dataUplinks->setDevice($device)
  180.                         ->setMessageAlerte('Je suis en vie')
  181.                         ->setHorodating($horodating);
  182.                     $device->setIsBonEtat(2); //Le device est en veille
  183.                     break;
  184.                 default:
  185.                     break;
  186.             }
  187.             $manager->persist($dataUplinks);
  188.             $device->setDateDerniereCommunication($horodating);
  190.             $manager->persist($device);
  191.             $manager->flush();
  193.             $idClients = explode(',',$device->getIdClient());
  194.             $sousDomaines = $this->getSousDomaineClientById($idClients);
  195.             //Si le code d'alerte correspond à une alerte
  196.             if (in_array($dataUplinks->getCodeAlerte(), ['64', '66'])) {
  197.             //On créé une Demande d'Intervention via l'API de SEJI
  198.                 foreach ($sousDomaines as $sousDomaine) {
  199.                     $this->sendDISeji($sousDomaine, $device, $dataUplinks->getMessageAlerte());
  200.                 }
  201.             }
  203.             return $this->json(['status' => 'OK'], 200);
  204.         } else {
  205.             return $this->json(['status' => 'A problem occured'], 500);
  206.         }
  207.     }
  209.     /**
  210.      * Intercepte les données émises par les devices clicMe
  211.      * @Route("/devices/sigfox/clicme", name="sigfox_callback_clicme")
  212.      */
  213.     public function getCallbackSigfoxClicme(Request $request, BoutonRepository $boutonRepository, DeviceRepository $deviceRepository)
  214.     {
  215.         $manager = $this->getDoctrine()->getManager();
  216.         //Si un message est envoyé depuis un device ClicMe
  217.         if ($content = $request->getContent()) {
  218.             $dataUplinks = new DataUplinks(); //Nouvelle data pour l'historique
  219.             $data = json_decode($content, true);
  220.             $horodating = new \DateTime();
  221.             $device = $deviceRepository->findDeviceByNumSerie($data['device']);
  223.             $dataUplinks->setDevice($deviceRepository->findDeviceByNumSerie($data['device']))
  224.                 ->setSourceButton($data['boutonSource'])
  225.                 ->setTypeTrigger($data['typeTrigger'])
  226.                 ->setMessageAlerte($boutonRepository->findBoutonByScenarioAndPosition($device->getScenario()->getId(), $data['boutonSource'])[0]->getActionBouton()) //Correspond au libelle du bouton appuyé
  227.                 ->setHorodating($horodating);
  229.             $manager->persist($dataUplinks);
  230.             $device->setPourcentageBatterie($data['battery'])
  231.                 ->setDateDerniereCommunication($horodating)
  232.                 ->setIsBonEtat(1); //Le device communique
  233.             $manager->persist($device);
  234.             $manager->flush();
  236.             $idClients = explode(',',$device->getIdClient());
  237.             $sousDomaines = $this->getSousDomaineClientById($idClients);
  238.             //Créé une Demande d'Intervention via l'API SEJI
  239.             foreach ($sousDomaines as $sousDomaine) {
  240.                 $this->sendDISeji($sousDomaine, $device, $dataUplinks->getMessageAlerte());
  241.             }
  243.             return $this->json(['status' => 'OK'], 200);
  244.         } else {
  245.             return $this->json(['status' => 'A problem occured'], 500);
  246.         }
  247.     }
  249.     /**
  250.      * Intercepte les données émises par les devices Enless Temperature
  251.      * @Route("/devices/sigfox/enlessTemperature", name="sigfox_callback_enless_temperature")
  252.      */
  253.     public function getCallbackSigfoxEnlessTemperature(Request $request, DeviceRepository $deviceRepository)
  254.     {
  255.         $manager = $this->getDoctrine()->getManager();
  256.         //Si un device EnlessTemperature a émis une donnée
  257.         if ($content = $request->getContent()) {
  258.             $dataUplinks = new DataUplinks(); //Nouvelle data pour l'historique
  259.             $data = json_decode($content, true);
  260.             $device = $deviceRepository->findDeviceByNumSerie($data['device']);
  261.             $horodating = new \DateTime();
  262.             $dataUplinks->setDevice($device)
  263.                 ->setTemperature($data['temp'] / 10) //Divise la température par 10 pour l'avoir au bon format (en °C)
  264.                 ->setHorodating($horodating);
  265.             $device->setDateDerniereCommunication($horodating)
  266.                 ->setIsBonEtat(1); //Le device communique
  268.             $manager->persist($device);
  269.             $manager->persist($dataUplinks);
  270.             $manager->flush();
  272.             $idClients = explode(',',$device->getIdClient());
  273.             $sousDomaines = $this->getSousDomaineClientById($idClients);
  274.             //Envoi de la température à SEJI via l'API
  275.             foreach ($sousDomaines as $sousDomaine) {
  276.                 $this->sendTempHumiSeji($sousDomaine, $device, $dataUplinks->getTemperature());
  277.             }
  279.             return $this->json(['status' => 'OK'], 200);
  280.         } else {
  281.             return $this->json(['status' => 'A problem occured'], 500);
  282.         }
  283.     }
  285.     /**
  286.      * Intercepte les données émises par les devices Enless Ambiance
  287.      * @Route("/devices/sigfox/enlessAmbiance", name="sigfox_callback_enless_ambiance")
  288.      */
  289.     public function getCallbackSigfoxEnlessAmbiance(Request $request, DeviceRepository $deviceRepository)
  290.     {
  291.         $manager = $this->getDoctrine()->getManager();
  292.         //Si un device Enless Ambiance a émis une donnée
  293.         if ($content = $request->getContent()) {
  294.             $dataUplinks = new DataUplinks(); //Nouvelle data pour l'historique
  295.             $data = json_decode($content, true);
  296.             $device = $deviceRepository->findDeviceByNumSerie($data['device']);
  297.             $horodating = new DateTime();
  298.             $dataUplinks->setDevice($device)
  299.                 ->setTemperature($data['temp'] / 10) //Divise la température par 10 pour l'avoir au bon format (en °C)
  300.                 ->setHumidity($data['humidity'] / 10) //Divise l'humidité par 10 pour l'avoir au bon format (en pourcentage)
  301.                 ->setHorodating($horodating);
  302.             $device->setDateDerniereCommunication($horodating)
  303.                 ->setIsBonEtat(1); //Le device communique
  305.             $manager->persist($device);
  306.             $manager->persist($dataUplinks);
  307.             $manager->flush();
  309.             $idClients = explode(',',$device->getIdClient());
  310.             $sousDomaines = $this->getSousDomaineClientById($idClients);
  311.             //Envoie la température et l'humidité à SEJI via l'API
  312.             foreach ($sousDomaines as $sousDomaine) {
  313.                 $this->sendTempHumiSeji($sousDomaine, $device, $dataUplinks->getTemperature(), $dataUplinks->getHumidity());
  314.             }
  316.             return $this->json(['status' => 'OK'], 200);
  317.         } else {
  318.             return $this->json(['status' => 'A problem occured'], 500);
  319.         }
  320.     }
  321.     /**
  322.      * Intercepte les messages de statut "keep-alive" envoyés par Sigfox
  323.      * @Route("/devices/sigfox/status")
  324.      */
  325.     public function status(Request $request, DeviceRepository $deviceRepository)
  326.     {
  327.         $manager = $this->getDoctrine()->getManager();
  328.         //Si Sigfox a émis une donnée
  329.         if ($content = $request->getContent()) {
  330.             $data = json_decode($content, true);
  331.             $dataUplinks = new DataUplinks(); //Nouvelle donnée pour l'historique
  332.             $dataUplinks->setDevice($deviceRepository->findDeviceByNumSerie($data['device']));
  333.             $device = $deviceRepository->findDeviceByNumSerie($data['device']);
  334.             //Si la qualité du réseau est envoyée
  335.             if (isset($data['LinkQuality']))
  336.                 $device->setLinkQuality($data['LinkQuality']);
  337.             //Si la batterie est envoyée
  338.             if (isset($data['battery']))
  339.                 $device->setPourcentageBatterie($data['battery']);
  340.             //Si la gravité de l'erreur (pas de réponse du device au keep-alive de sigfox) est envoyée
  341.             if (isset($data['Severity'])) {
  342.                 $dataUplinks->setSeverity($data['Severity'])
  343.                     ->setErrorMessage($data['info'])
  344.                     ->setHorodating(new \DateTime());
  345.                 $device->setIsBonEtat(2); //Le device est en veille
  346.                 $manager->persist($dataUplinks);
  347.             } else {
  348.                 $device->setIsBonEtat(1); //Le device communique
  349.             }
  350.             $manager->persist($device);
  351.             $manager->flush();
  353.             return $this->json(['status' => 'OK'], 200);
  354.         } else {
  355.             return $this->json(['status' => 'A problem occured'], 500);
  356.         }
  357.     }
  358.     /**
  359.      * Retourne le sous-domaine d'un client via son ID passé en paramètre
  360.      */
  361.     public function getSousDomaineClientById($idClients)
  362.     {
  363.         $sousdomaines = [];
  364.         foreach ($idClients as $idclient) {
  365.             //Appel API GHOST
  366.             $httpClient = new HttpClient();
  367.             $httpClient = $httpClient->create();
  368.             $response = $httpClient->request('POST', 'https://ghost.camileia.com/api/societe', [
  369.                 'query' => [
  370.                     'pass1' => 'CBrEPEdovEmhrmyJTY5twbRB',
  371.                     'pass2' => 'wnuhGwNru3Q4VLilAi1OXW0G',
  372.                     'id' => $idclient
  373.                 ]
  374.             ]);
  375.             $client = $response->toArray();
  377.             $sousdomaines[] = $client['societe']['sousdomaine'];
  378.         }
  380.         return $sousdomaines;
  381.     }
  382.     /**
  383.      * Envoie une Demande d'Intervention à SEJI via son API
  384.      */
  385.     public function sendDISeji($sousDomaine, Device $device, ?String $messageAlerte)
  386.     {
  387.         //Appel de l'API SEJI
  388.         $httpClient = new HttpClient();
  389.         $httpClient = $httpClient->create();
  390.         $response = $httpClient->request('POST', 'https://' . $sousDomaine . '.camileia.com/lara/data/add', [
  391.             'json' => [
  392.                 "device_id" => $device->getNumeroSerie(),
  393.                 "pass" => "41cb4c447902b0bc922257d08018c736",
  394.                 "message_alerte" => $messageAlerte
  395.             ]
  396.         ]);
  397.         return $response->toArray()['etat'];
  398.     }
  399.     /**
  400.      * Envoie la température et l'humidité à SEJI via son API
  401.      */
  402.     public function sendTempHumiSeji($sousDomaine, Device $device, $temperature, $humidity = null) {
  403.         //Appel de l'API SEJI
  404.         $tab = ['json' => [
  405.             'device_id' => $device->getNumeroSerie(),
  406.             'pass' => '41cb4c447902b0bc922257d08018c736',
  407.             'temperature' => strval($temperature)
  408.         ]];
  410.         if (isset($humidity)) {
  411.             $tab['json']['humidity'] = strval($humidity);
  412.         }
  414.         $httpClient = new HttpClient();
  415.         $httpClient = $httpClient->create();
  416.         $response = $httpClient->request('POST', 'https://' . $sousDomaine . '.camileia.com/lara/data/add', $tab);
  417.         return $response->toArray()['etat'];
  418.     }
  420.     /* Envoie les datas des iots à la solution Camileia via son API */
  421.     public function sendDatasToCamileia(
  422.         $sousDomaine, Device $device, $temperature = null, $humidity = null, $activityLevel = null,
  423.         $co2ppm = null, $devEUI = null, $illumination = null, $infrared = null, 
  424.         $infraredAndVisible = null, $pressure = null, $tvoc = null, $horodating = null, $dba = null, $dbaeq = null, $dbamax= null
  425.     )
  426.     {
  427.         //Appel de l'API SEJI
  428.         $tab = ['json' => [
  429.             'device_id' => $device->getNumeroSerie(),
  430.             'pass' => '41cb4c447902b0bc922257d08018c736',
  431.         ]];
  433.         $optionalFields = [
  434.             'temperature', 'humidity', 'activityLevel', 'co2ppm', 'devEUI', 
  435.             'illumination', 'infrared', 'infraredAndVisible', 'pressure', 'tvoc', 'horodating',
  436.             'dba'  , 'dbaeq'  , 'dbamax'
  437.         ];
  439.         foreach ($optionalFields as $field) {
  440.             if (isset($$field)) {
  441.                 $tab['json'][$field] = $$field;
  442.             }
  443.         }
  445.         $httpClient = new HttpClient();
  446.         $httpClient = $httpClient->create();
  447.         $response = $httpClient->request('POST', 'https://' . $sousDomaine . '.camileia.com/lara/data/add', $tab);
  448.         return $response->toArray()['etat'];
  449.     }
  451.     /**
  452.      * Retourne les informations de toutes les devices enregistrées chez Sigfox via leur API
  453.      * @Route("/devices/sigfox/infos/", name="infos_devices_api_sigfox")
  454.      */
  455.     public function getInfosDeviceAPISigfox()
  456.     {
  457.         $httpClient = new HttpClient();
  458.         $httpClient = $httpClient->create([
  459.             'auth_basic' => ['5f02da07e833d97984534175', 'd5d72bed6a690735ee5aa22770b7dbde'] //authentification basicAuth obligatoire pour communiquer avec l'API
  460.         ]);
  461.         $response = $httpClient->request('GET', 'https://api.sigfox.com/v2/devices/');
  462.         if ($response->getStatusCode() == 200) {
  463.             $arrayResponse = array_column($response->toArray()['data'], "pac", "id");
  464.             return $arrayResponse;
  465.         } else {
  466.             return new JsonResponse($response->toArray(), $response->getStatusCode());
  467.         }
  468.     }
  469.     /**
  470.      * Permet d'enregistrer des devices chez sigfox. Les devices sont contenues dans un tableau passé en paramètres
  471.      */
  472.     public function ajouterDeviceAPISigfox($tabSigFox)
  473.     {
  474.         $httpClient = new HttpClient();
  475.         $httpClient = $httpClient->create([
  476.             'auth_basic' => ['5f02da07e833d97984534175', 'd5d72bed6a690735ee5aa22770b7dbde'] //authentification basicAuth obligatoire pour communiquer avec l'API
  477.         ]);
  479.         $response = $httpClient->request('POST', 'https://api.sigfox.com/v2/devices/bulk', [
  480.             "json" => $tabSigFox
  481.         ]);
  482.         if ($response->getStatusCode() == 200) {
  483.             return new JsonResponse(['status' => 'OK'], 200);
  484.         } else {
  485.             return new JsonResponse(['status' => 'A problem occured'], $response->getStatusCode());
  486.         }
  487.     }
  489.     /**
  490.      * Intercepte les données émises par les devices Milesight Temperature
  491.      * @Route("/devices/lora/milesight", name="lora_milesight_device")
  492.      */
  493.     public function getMilesightDevice(Request $request, DeviceRepository $deviceRepository,BoutonRepository $boutonRepository, EntityManagerInterface $em)
  494.     {
  495.         if($request->headers->get('MilesightPassword') === "25EA4DF565368B8BC7C3F5D164D08A1B")
  496.         {
  497.             // $em = $this->getDoctrine()->getManager();
  498.             if($request->headers->get('DeviceModel') === "AM107" || $request->headers->get('DeviceModel') === "AM103"){
  499.                 
  500.                 if ($content = $request->getContent()) {
  501.                     $data = json_decode($content, true);
  503.                     if (isset($data['devEUI'])) {
  504.                         $device = $deviceRepository->findDeviceByDevEUI($data['devEUI']); // on recup le device par son devEUI
  505.                         $horodating = date_create_from_format("Y-m-d\TH:i:s.u\Z", $data['time'], new DateTimeZone('UTC')); // on horodate la data
  506.                         $horodating->setTimezone(new DateTimeZone('Europe/Paris'));
  507.                         
  508.                         $dataUplinks = new DataUplinks(); // Nouvelle data pour l'historique
  509.                         $dataUplinks->setDevice($device); // on lie la trame au device concerné
  510.                         $dataUplinks->setHorodating($horodating);
  511.                         
  512.                         if (isset($data['temperature'])) { // si la trame contient la temperature 
  513.                             $dataUplinks
  514.                             ->setTemperature($data['temperature']);
  515.                         }
  516.                         
  517.                         if (isset($data['humidity'])) { // si la trame contient la temperature 
  518.                             $dataUplinks->setHumidity($data['humidity']);
  519.                         }
  521.                         if (isset($data['activity'])) { // si la trame contient le niveau d'activité 
  522.                             $dataUplinks->setActivityLevel($data['activity']);
  523.                         }
  525.                         if (isset($data['co2'])) { // si la trame contient le le taux de pollution dans l'air (partie par million)
  526.                             $dataUplinks->setCo2ppm($data['co2']);
  527.                         }
  529.                         if (isset($data['devEUI'])) { // si la trame contient le DevEUI
  530.                             $dataUplinks->setDevEUI($data['devEUI']);
  531.                         }
  533.                         if (isset($data['illumination'])) { // si la trame contient la luminosity
  534.                             $dataUplinks->setIllumination($data['illumination']);
  535.                         }
  537.                         if (isset($data['infrared'])) { // si la trame contient l'infrarouge
  538.                             $dataUplinks->setInfrared($data['infrared']);
  539.                         }
  541.                         if (isset($data['infrared_and_visible'])) {
  542.                             $dataUplinks->setInfraredAndVisible($data['infrared_and_visible']);
  543.                         }
  545.                         if (isset($data['pressure'])) {
  546.                             $dataUplinks->setPressure($data['pressure']);
  547.                         }
  549.                         if (isset($data['tvoc'])) {
  550.                             $dataUplinks->setTvoc($data['tvoc']);
  551.                         }
  552.                         
  553.                         $em->persist($dataUplinks);
  554.                         $idClients = explode(',',$device->getIdClient());
  555.                         $sousDomaines = $this->getSousDomaineClientById($idClients);
  556.                         
  557.                         // //Envoi de la température à SEJI via l'API
  558.                         foreach ($sousDomaines as $sousDomaine) {
  559.                             $this->sendDatasToCamileia($sousDomaine, $device, $dataUplinks->getTemperature(), $dataUplinks->getHumidity(),
  560.                                 $dataUplinks->getActivityLevel(), $dataUplinks->getCo2ppm(), $dataUplinks->getDevEUI(),
  561.                                 $dataUplinks->getIllumination(), $dataUplinks->getInfrared(), $dataUplinks->getInfraredAndVisible(),
  562.                                 $dataUplinks->getPressure(), $dataUplinks->getTvoc(), $dataUplinks->getHorodating(),
  563.                                 $dataUplinks->getDba(), $dataUplinks->getDbaeq(), $dataUplinks->getDbamax()
  564.                             );
  565.                         }
  567.                         // }
  569.                         if(isset($data['battery'])) { // si la batterie est présente dans la trame (en pourcentage géré par le decoder)
  570.                             
  571.                             $device->setPourcentageBatterie($data['battery']);
  572.                         }
  574.                         $linkQuality = 0;
  575.                         if(isset($data['rxInfo'][0]['loRaSNR'])) {
  576.                             if($data['rxInfo'][0]['loRaSNR'] > 0 )
  577.                             {
  578.                                 $linkQuality = 1;
  579.                             }
  580.                             if($data['rxInfo'][0]['loRaSNR'] > 5 )
  581.                             {
  582.                                 $linkQuality = 2;
  583.                             }
  584.                             if($data['rxInfo'][0]['loRaSNR'] > 10)
  585.                             {
  586.                                 $linkQuality = 3;
  587.                             }
  588.                         }
  589.             
  590.                         $device->setDateDerniereCommunication($horodating)
  591.                             ->setIsBonEtat(1)
  592.                             ->setLinkQuality($linkQuality);
  593.             
  594.                         $em->persist($device);
  595.                         $em->flush();
  597.                         return $this->json([
  598.                             // 'json' => $data,
  599.                             'status' => 'ok',
  600.                             'typeDevice' => 'AM107',
  601.                             'path' => 'src/Controller/DevicesController.php',
  602.                             200
  603.                         ]);
  604.                     } else {
  606.                         return $this->json(['status' => 'Error' , 'message' => 'No DevEUI provided'], 500);
  607.                     }
  610.                 } else {
  611.                     return $this->json(['status' => 'Error', 'message' => 'Impossible to get the content of the body request'], 500);
  612.                 }
  614.             }
  616.             if($request->headers->get('DeviceModel') === "WS302"){
  618.                 if ($content = $request->getContent()) {
  619.                     $data = json_decode($content, true);
  621.                     if (isset($data['devEUI'])) {
  622.                         $device = $deviceRepository->findDeviceByDevEUI($data['devEUI']); // on recup le device par son devEUI
  623.                         $horodating = date_create_from_format("Y-m-d\TH:i:s.u\Z", $data['time'], new DateTimeZone('UTC')); // on horodate la data
  624.                         $horodating->setTimezone(new DateTimeZone('Europe/Paris'));
  626.                         $dataUplinks = new DataUplinks(); // Nouvelle data pour l'historique
  627.                         $dataUplinks->setDevice($device); // on lie la trame au device concerné
  628.                         $dataUplinks->setHorodating($horodating);
  630.                         if (isset($data['la'])) {
  631.                             $dataUplinks->setDba($data['la']);
  632.                         }
  634.                         if (isset($data['laeq'])) {
  635.                             $dataUplinks->setDbaeq($data['laeq']);
  636.                         }
  638.                         if (isset($data['devEUI'])) {
  639.                             $dataUplinks->setDevEUI($data['devEUI']);
  640.                         }
  642.                         if (isset($data['lafmax'])) {
  643.                             $dataUplinks->setDbamax($data['lafmax']);
  644.                         }
  646.                         $em->persist($dataUplinks);
  647.                         $idClients = explode(',',$device->getIdClient());
  648.                         $sousDomaines = $this->getSousDomaineClientById($idClients);
  650.                         // //Envoi de la température à SEJI via l'API
  651.                         foreach ($sousDomaines as $sousDomaine) {
  652.                             $this->sendDatasToCamileia($sousDomaine, $device, $dataUplinks->getTemperature(), $dataUplinks->getHumidity(),
  653.                                 $dataUplinks->getActivityLevel(), $dataUplinks->getCo2ppm(), $dataUplinks->getDevEUI(),
  654.                                 $dataUplinks->getIllumination(), $dataUplinks->getInfrared(), $dataUplinks->getInfraredAndVisible(),
  655.                                 $dataUplinks->getPressure(), $dataUplinks->getTvoc(), $dataUplinks->getHorodating(),
  656.                                 $dataUplinks->getDba(), $dataUplinks->getDbaeq(), $dataUplinks->getDbamax()
  657.                             );
  658.                         }
  660.                         // }
  662.                         if(isset($data['battery'])) { // si la batterie est présente dans la trame (en pourcentage géré par le decoder)
  664.                             $device->setPourcentageBatterie($data['battery']);
  665.                         }
  667.                         $linkQuality = 0;
  668.                         if(isset($data['rxInfo'][0]['loRaSNR'])) {
  669.                             if($data['rxInfo'][0]['loRaSNR'] > 0 )
  670.                             {
  671.                                 $linkQuality = 1;
  672.                             }
  673.                             if($data['rxInfo'][0]['loRaSNR'] > 5 )
  674.                             {
  675.                                 $linkQuality = 2;
  676.                             }
  677.                             if($data['rxInfo'][0]['loRaSNR'] > 10)
  678.                             {
  679.                                 $linkQuality = 3;
  680.                             }
  681.                         }
  683.                         $device->setDateDerniereCommunication($horodating)
  684.                             ->setIsBonEtat(1)
  685.                             ->setLinkQuality($linkQuality);
  687.                         $em->persist($device);
  688.                         $em->flush();
  690.                         return $this->json([
  691.                             // 'json' => $data,
  692.                             'status' => 'ok',
  693.                             'typeDevice' => 'AM107',
  694.                             'path' => 'src/Controller/DevicesController.php',
  695.                             200
  696.                         ]);
  697.                     } else {
  699.                         return $this->json(['status' => 'Error' , 'message' => 'No DevEUI provided'], 500);
  700.                     }
  703.                 } else {
  704.                     return $this->json(['status' => 'Error', 'message' => 'Impossible to get the content of the body request'], 500);
  705.                 }
  707.             }
  709.             if($request->headers->get('DeviceModel') === "DS3604"){
  711.                 if ($content = $request->getContent()) {
  712.                     $data = json_decode($content, true);
  714.                     if (isset($data['devEUI'])) {
  715.                         $device = $deviceRepository->findDeviceByDevEUI($data['devEUI']); // on recup le device par son devEUI
  716.                         $horodating = date_create_from_format("Y-m-d\TH:i:s.u\Z", $data['time'], new DateTimeZone('UTC')); // on horodate la data
  717.                         $horodating->setTimezone(new DateTimeZone('Europe/Paris'));
  719.                         if(isset($data['battery'])) { // si la batterie est présente dans la trame (en pourcentage géré par le decoder)
  720.                             $device->setPourcentageBatterie($data['battery']);
  721.                         }
  723.                         $linkQuality = 0;
  724.                         if(isset($data['rxInfo'][0]['loRaSNR'])) {
  725.                             if($data['rxInfo'][0]['loRaSNR'] > 0 )
  726.                             {
  727.                                 $linkQuality = 1;
  728.                             }
  729.                             if($data['rxInfo'][0]['loRaSNR'] > 5 )
  730.                             {
  731.                                 $linkQuality = 2;
  732.                             }
  733.                             if($data['rxInfo'][0]['loRaSNR'] > 10)
  734.                             {
  735.                                 $linkQuality = 3;
  736.                             }
  737.                         }
  739.                         $device->setDateDerniereCommunication($horodating)
  740.                             ->setIsBonEtat(1)
  741.                             ->setLinkQuality($linkQuality);
  743.                         $em->persist($device);
  744.                         $em->flush();
  746.                         return $this->json([
  747.                             // 'json' => $data,
  748.                             'status' => 'ok',
  749.                             'typeDevice' => 'AM107',
  750.                             'path' => 'src/Controller/DevicesController.php',
  751.                             200
  752.                         ]);
  753.                     } else {
  755.                         return $this->json(['status' => 'Error' , 'message' => 'No DevEUI provided'], 500);
  756.                     }
  759.                 } else {
  760.                     return $this->json(['status' => 'Error', 'message' => 'Impossible to get the content of the body request'], 500);
  761.                 }
  763.             }
  765.             if($request->headers->get('DeviceModel') === "WS101"){
  767.                 if ($content = $request->getContent()) {
  768.                     $data = json_decode($content, true);
  770.                     if (isset($data['devEUI'])) {
  771.                         $device = $deviceRepository->findDeviceByDevEUI($data['devEUI']); // on recup le device par son devEUI
  772.                         $horodating = date_create_from_format("Y-m-d\TH:i:s.u\Z", $data['time'], new DateTimeZone('UTC')); // on horodate la data
  773.                         $horodating->setTimezone(new DateTimeZone('Europe/Paris'));
  775.                         if(isset($data['button'])) {
  776.                             $dataUplinks = new DataUplinks(); // Nouvelle data pour l'historique
  777.                             $dataUplinks->setDevice($device); // on lie la trame au device concerné
  778.                             $dataUplinks->setHorodating($horodating);
  779.                             $dataUplinks->setSourceButton(1);
  780.                             $dataUplinks->setMessageAlerte($boutonRepository->findBoutonByScenarioAndPosition($device->getScenario()->getId(), 1)[0]->getActionBouton());
  781.                             $em->persist($dataUplinks);
  782.                             $em->flush();
  784.                             $idClients = explode(',',$device->getIdClient());
  785.                             $sousDomaines = $this->getSousDomaineClientById($idClients);
  787.                             //Envoi de la température à SEJI via l'API
  788.                             foreach ($sousDomaines as $sousDomaine) {
  789.                                 $this->sendDISeji($sousDomaine, $device, $dataUplinks->getMessageAlerte());
  790.                             }
  791.                         }
  793.                         // }
  795.                         if(isset($data['battery'])) { // si la batterie est présente dans la trame (en pourcentage géré par le decoder)
  797.                             $device->setPourcentageBatterie($data['battery']);
  798.                         }
  800.                         $linkQuality = 0;
  801.                         if(isset($data['rxInfo'][0]['loRaSNR'])) {
  802.                             if($data['rxInfo'][0]['loRaSNR'] > 0 )
  803.                             {
  804.                                 $linkQuality = 1;
  805.                             }
  806.                             if($data['rxInfo'][0]['loRaSNR'] > 5 )
  807.                             {
  808.                                 $linkQuality = 2;
  809.                             }
  810.                             if($data['rxInfo'][0]['loRaSNR'] > 10)
  811.                             {
  812.                                 $linkQuality = 3;
  813.                             }
  814.                         }
  816.                         $device->setDateDerniereCommunication($horodating)
  817.                             ->setIsBonEtat(1)
  818.                             ->setLinkQuality($linkQuality);
  820.                         $em->persist($device);
  821.                         $em->flush();
  823.                         return $this->json([
  824.                             'status' => 'ok',
  825.                             'typeDevice' => 'WS101',
  826.                             'path' => 'src/Controller/DevicesController.php',
  827.                             200
  828.                         ]);
  829.                     } else {
  831.                         return $this->json(['status' => 'Error' , 'message' => 'No DevEUI provided'], 500);
  832.                     }
  835.                 } else {
  836.                     return $this->json(['status' => 'Error', 'message' => 'Impossible to get the content of the body request'], 500);
  837.                 }
  839.             }
  841.         } else {
  842.             return $this->json(['status' => 'Error', 'message' => 'Incorrect password'], 500);
  843.         }
  844.     }
  846.     /**
  847.      * Intercepte les données émises par les devices Watteco Temperature
  848.      * @Route("/devices/lora/wattecoTemperature", name="lora_callback_watteco_temperature")
  849.      */
  850.     public function getCallbackLoraWattecoTemperature(Request $request, DeviceRepository $deviceRepository)
  851.     {
  852.         if($request->headers->get('WattecoPassword') === "3zkKqe8w7S37vsRBb35nrdZJJSVr")
  853.         {
  854.             $manager = $this->getDoctrine()->getManager();
  855.             //Si un device WattecoTemperature a émis une donnée
  856.             if ($content = $request->getContent()) {
  857.     
  858.                 $data = json_decode($content, true);
  859.     
  860.                 if(isset($data['data']['temperature']) || isset($data['data']['disposable_battery_voltage'])) {
  861.     
  862.                     $device = $deviceRepository->findDeviceByNumSerie($data['object']['devEUI']);
  863.                 
  864.                     $horodating = date_create_from_format("Y-m-d\TH:i:s.v\Z",$data['lora']['date'],new DateTimeZone('UTC'));
  865.                     $horodating->setTimezone(new DateTimeZone('Europe/Paris'));
  866.     
  867.                     if(isset($data['data']['temperature'])) {
  868.                         $dataUplinks = new DataUplinks(); //Nouvelle data pour l'historique
  869.                         $dataUplinks->setDevice($device)
  870.                         ->setTemperature($data['data']['temperature'])
  871.                         ->setHorodating($horodating);
  872.     
  873.                         $manager->persist($dataUplinks);
  875.                         $idClients = explode(',',$device->getIdClient());
  876.                         $sousDomaines = $this->getSousDomaineClientById($idClients);
  877.                         //Envoi de la température à SEJI via l'API
  878.                         foreach ($sousDomaines as $sousDomaine) {
  879.                             $this->sendTempHumiSeji($sousDomaine, $device, $dataUplinks->getTemperature());
  880.                         }
  881.                     }
  882.                     
  883.                     if(isset($data['data']['disposable_battery_voltage'])) {
  884.     
  885.                         if($data['data']['disposable_battery_voltage'] > 3.6) {
  886.                             $pourcentage = 100;
  887.     
  888.                         } else {
  889.                             $pourcentage = (($data['data']['disposable_battery_voltage'] - 3)/0.6) * 100;
  890.                         }
  891.     
  892.                         $device->setPourcentageBatterie($pourcentage);
  893.                     }
  894.     
  895.                     $linkQuality = 0;
  896.     
  897.                     if(isset($data['object']['rxInfo'][0]['loRaSNR'])) {
  898.                         if($data['object']['rxInfo'][0]['loRaSNR'] > 0 )
  899.                         {
  900.                             $linkQuality = 1;
  901.                         }
  902.                         if($data['object']['rxInfo'][0]['loRaSNR'] > 5 )
  903.                         {
  904.                             $linkQuality = 2;
  905.                         }
  906.                         if($data['object']['rxInfo'][0]['loRaSNR'] > 10)
  907.                         {
  908.                             $linkQuality = 3;
  909.                         }
  910.                     }
  911.         
  912.                     $device->setDateDerniereCommunication($horodating)
  913.                         ->setIsBonEtat(1)
  914.                         ->setLinkQuality($linkQuality);
  915.         
  916.                     $manager->persist($device);
  917.                     $manager->flush();
  918.                 }
  919.                 
  920.                 return $this->json(['status' => 'OK'], 200);
  921.             } else {
  922.                 return $this->json(['status' => 'A problem occured'], 500);
  923.             }
  924.         }
  925.         else
  926.         {
  927.             return $this->json(['status' => 'A problem occured'], 500);
  928.         }
  929.     }
  930. }