src/Controller/CronJobController.php line 65

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Vehicle;
  6. use App\Entity\VehiclePositions;
  7. use App\Service\ElasticService;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Psr\Log\LoggerInterface;
  10. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  14. class CronJobController extends AbstractController
  15. {
  16.     public function postPositions(EntityManagerInterface $em, Request $request, LoggerInterface $logger)
  17.     {
  18.         try {
  19.             $data1 = $request->request->get('data');
  20.             $data = json_decode($data1, true);
  21.             $vehicle = $em->getRepository(Vehicle::class)->findOneBy(['trackerId' => $data['imei']]);
  22.             $positions = new VehiclePositions();
  23.             $positions->setVehicle($vehicle)
  24.                 ->setLongitude($data['lng'])
  25.                 ->setLatitude($data['lat'])
  26.                 ->setPositionTime(new \DateTime())
  27.                 ->setVehicleSpeed($data['speed'])
  28.                 ->setDistanceCovered(0.0);
  29.             $em->persist($positions);
  30.             $em->flush();
  31.             $logger->error(__METHOD__ . ' -> {message}', ['message' => $data]);
  32.             return new Response('Ok', 200);
  33.         } catch (\Exception $e) {
  34.             $logger->error(__METHOD__ . ' -> {message}', ['message' => $e->getMessage()]);
  35.         }
  36.     }
  38.     public function postPositionsLocal(EntityManagerInterface $em, Request $request, LoggerInterface $logger)
  39.     {
  40.         $data1='{"op":"loc","imei":"358480080044318","dt_tracker":"2019-12-17 17:12:37","lat":38.007147,"lng":23.845655,"altitude":229,"angle":60,"speed":0,"loc_valid":1,"params":{"gpslev":7,"batc":0,"gsmlev":3,"gnss":1,"ext_volt":12.78,"speed":0,"batv":4.071},"event":null}';
  43. //        dump(json_decode($data,true));
  46. //        $data1=$request->request->get('data');
  47.         $data=json_decode($data1,true);
  49.         $vehicle=$em->getRepository(Vehicle::class)->findOneBy(['trackerId' => $data['imei']]);
  51.         $positions=new VehiclePositions();
  53.         $positions->setVehicle($vehicle);
  54.         $positions->setLongitude($data['lng']);
  55.         $positions->setLatitude($data['lat']);
  56.         $positions->setPositionTime(new \DateTime());
  57.         $positions->setVehicleSpeed($data['speed']);
  58.         $positions->setDistanceCovered(0.0);
  59.         $em->persist($positions);
  60.         $em->flush();
  62.         return new Response('Ok',200);
  63.     }
  65.     public function purgeVehiclePositions(ElasticService $elasticService, LoggerInterface $logger): Response
  66.     {
  67.         $size = 10000;
  69.         try {
  70.             $date = new \DateTime();
  71.             $date->sub(new \DateInterval('P90D'));
  73.             $response = $elasticService->deleteOldValues($date, $size);
  75.             if ($response) {
  76.                 return new Response('Ok',200);
  77.             }
  79.             return new Response('Internal Server Error',500);
  80.         } catch (\Exception $e) {
  81.             $logger->error(__METHOD__ . ' -> {message}', ['message' => $e->getMessage()]);
  83.             return new Response('Internal Server Error',500);
  84.         }
  85.     }
  86. }