src/Flexy/FrontBundle/Themes/Lasalle/Controller/Api/ApiController.php line 233

  1. <?php
  3. namespace App\Flexy\FrontBundle\Themes\Lasalle\Controller\Api;
  5. use App\Flexy\ProductBundle\Repository\ProductRepository;
  6. use App\Flexy\ShopBundle\Entity\Customer\Customer;
  7. use App\Flexy\ShopBundle\Entity\Customer\Visit;
  8. use App\Flexy\ShopBundle\Entity\Customer\VisitOutside;
  9. use App\Flexy\ShopBundle\Entity\Order\Order;
  10. use App\Flexy\ShopBundle\Repository\Order\OrderRepository;
  11. use App\Flexy\ShopBundle\Entity\Product\ProductShop;
  12. use App\Flexy\ShopBundle\Entity\Store\Store;
  13. use App\Flexy\ShopBundle\Repository\Customer\CustomerRepository;
  14. use App\Flexy\ShopBundle\Repository\Shipping\ShippingMethodRepository;
  15. use App\Service\FlexySettingsProvider;
  16. use Doctrine\Persistence\ManagerRegistry;
  17. use Exception;
  18. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\Routing\Annotation\Route;
  22. use Symfony\Component\HttpFoundation\JsonResponse;
  23. use Symfony\Component\Mercure\HubInterface;
  24. use Symfony\Component\Mercure\Update;
  27. #[Route('/api')]
  28. class ApiController extends AbstractController
  29. {
  30.     
  32.     #[Route('/check-customer-account', name: 'api_check_customer_account',methods: ['POST'])]
  33.     public function api_check_customer_account(Request $request ,ManagerRegistry $doctrine,   
  34.     CustomerRepository $customerRepository,HubInterface $hub,FlexySettingsProvider $flexySettingsProvider,
  35.     OrderRepository $orderRepository)
  36.     {
  38.         //dd($customer);
  41.         if ($request->getContentType() == 'json' and $request->getContent()) {
  42.             $contentJsonRequest = json_decode($request->getContent(),true, 512, JSON_THROW_ON_ERROR);
  43.             if($contentJsonRequest){
  44.                 $request->request->replace($contentJsonRequest);
  45.             }else{
  46.                 return $this->json([
  47.                     "status"=>"error","message"=>"Content is not well formated"
  48.                 ]);
  49.             }
  50.             
  51.         }
  53.         $reference =  $request->request->get("reference");
  56.         $em = $doctrine->getManager();
  58.         $currentDateTime = new \DateTime();
  60.         $query = $em->createQuery(
  61.             'SELECT customer
  62.             FROM App\Flexy\ShopBundle\Entity\Customer\Customer customer
  63.             
  64.             LEFT JOIN customer.productSubscriptions  productSubscriptions
  65.             WHERE customer.reference = :reference AND (customer.is_actif  IS NULL OR customer.is_actif = 0)
  66.             AND :currentDateTime BETWEEN productSubscriptions.startAt AND productSubscriptions.endAt
  67.             '
  68.         )
  70.         
  72.         ->setParameter('reference', $reference)
  73.         ->setParameter('currentDateTime', $currentDateTime);
  74.     
  75.         $customer = $query->getOneOrNullResult();
  76.         
  77.          // envoie vers la deuxieme salle //
  78.         // ðŸ“Œ Connexion Ã  la deuxième base avec DBAL (SQL brut)
  79.         /** @var Connection $connection */
  80.         $connection = $doctrine->getConnection('salle2');
  81.       
  83.          $sql = "SELECT c.*
  84.                     FROM customer c
  85.                     LEFT JOIN product_subscription ps 
  86.                         ON c.id = ps.customer_id
  87.                     WHERE c.reference = :reference
  88.                     AND (c.is_actif IS NULL OR c.is_actif = 0)
  89.                     AND :currentDateTime BETWEEN ps.start_at AND ps.end_at
  90.                 ";
  91.                 
  92.         $customer2 = $connection->fetchAssociative($sql, [
  93.                 'reference' => $reference,
  94.                 'currentDateTime' => (new \DateTime())->format('Y-m-d H:i:s')
  95.             ]);         
  96.                      
  97.         // dd($customer2);
  98.        
  99.         
  100.          $content = $request->getContent();
  101.         
  102.         
  103.          $url = $request->getUri();
  104.          
  105.           $other_salle = false;
  106.           
  107.           $status = (boolean)$customer;
  108.           $status_salle2 =(boolean)$customer2;
  109.           
  110.           if( $status == 1 or $status_salle2 ) {
  111.             $value  = "true";
  112.             
  113.            
  114.              
  115.            if($status){
  116.             $customer = $customerRepository->findOneBy(["reference"=> $reference]);
  117.             $customer_id = $customer->getId();
  118.            }else{
  119.            $customer_id = $customer2['id'];
  120.            $other_salle = true;
  121.            }
  122.            
  123.            
  124.             
  125.             $order = $orderRepository->findOneBy(["customer"=> $customer_id]);
  126.             
  127.             
  128.             // Vérifiez si l'ordre est "checked"
  129.             if ($order && $order->getIsChecked()) {
  130.                 // Récupérez l'heure actuelle
  131.                 $currentHour = (new \DateTime())->format('H:i');
  132.                  
  133.                 // Vérifiez si l'heure est entre 07:00 et 13:30
  134.                 if ($currentHour >= '07:00' && $currentHour <= '13:30') {
  135.                     $value = "true";
  136.                 
  137.                     
  138.                 } else {
  139.                     $value = "false";
  140.                      
  141.                 }
  142.             }
  143.            
  144.             //dd($value);
  145.             
  146.               // Créer l'entité Visit seulement si $value est "true"
  147.             if ($value === "true" and $status) {
  148.             $visit = new Visit();
  149.             $entityManager =  $doctrine->getManager();
  150.             $visit->setCustomer($customer);
  151.             $visit->setCreatedAt(\DateTime::createFromFormat('Y-m-d H:i:s',date('Y-m-d H:i:s')));
  152.             if($customer->getStore()){
  153.                $visit->setStore($customer->getStore()); 
  154.             }
  155.             
  156.             $visit->setCardReference($reference);
  157.             $entityManager->persist($visit);
  158.             $entityManager->flush();
  160.         }
  161.             // Publication Mercure selon la valeur de $value
  162.     if ($flexySettingsProvider->get()->isIsMercureEnabled()) {
  163.         $status = ($value === "true") ? "success" : "failed";
  164.         $update = new Update(
  165.             'https://hello.com/books/1',
  166.             json_encode([
  167.                 'status' => $status,
  168.                 'entity' => 'VisitCustomer',
  169.                 "customerId" => $customer_id,
  170.                 "otherSalle"=>$other_salle,
  171.                 'data' => $value === "true" ? $customer : null, // uniquement ajouter data si success
  172.                 
  173.             ])
  174.         );
  176.         $hub->publish($update);
  177.     }
  180.             /*if($flexySettingsProvider->get()->isIsMercureEnabled()){
  181.                 $update = new Update(
  182.                     'https://hello.com/books/1',
  183.                     json_encode(
  184.                         [
  185.                             'status' => 'success',
  186.                             'entity'=>'VisitCustomer',
  187.                             "customerId"=>$customer_id,
  188.                             'data'=>$customer,
  189.                         ]
  190.                         )
  191.                 );
  193.                 $hub->publish($update);
  194.                
  195.             }*/
  196.     
  197.           
  198.           }else{
  199.             if($flexySettingsProvider->get()->isIsMercureEnabled()){
  200.                 $update = new Update(
  201.                     'https://hello.com/books/1',
  202.                     json_encode(
  203.                         [
  204.                             'status' => 'failed',
  205.                             'entity'=>'VisitCustomer',
  206.                         ]
  207.                         )
  208.                 );
  210.                 $hub->publish($update);
  211.                
  212.             }
  213.              $value  = "false"; 
  214.           }
  215.         
  216.           //dd($customer[0]->getStore()->getName()); 
  218.          return new Response($value);
  220.      
  222.         
  224.         // Logic
  226.         /*return $this->json([
  227.             "status"=>(boolean)$customer
  228.         ]);*/
  229.         
  230.     }
  232.     #[Route('/visit-customer', name: 'visit-customer')]
  233.     public function visitCustomer(
  234.         CustomerRepository $customerRepository,
  235.         OrderRepository $orderRepository,
  236.         ManagerRegistry $doctrine, 
  237.         Request $request 
  238.         ): Response
  239.     {
  241.         
  242.         $timeStatus='';
  245.         // Vérifier si "other" est activé dans la requête
  246.     $useSalle2 = $request->query->get("other") === 'true';
  248.             if ($useSalle2) {
  249.                 // 📌 Connexion à la deuxième base (salle2)
  250.                 $connection = $doctrine->getConnection('salle2');
  251.         
  252.                 //$sql = "SELECT * FROM customer WHERE id = :reference";
  253.                 
  254.                $sql = "SELECT * FROM customer c
  255.                              LEFT JOIN product_subscription ps 
  256.                                   ON c.id = ps.customer_id
  257.                                   WHERE c.id =:reference";
  258.                     
  259.                 $customerSalle2 = $connection->fetchAssociative($sql, [
  260.                     'reference' => $request->query->get("customerId")
  261.                 ]);
  262.                 
  263.                //dd($customerSalle2);
  264.         
  265.                 if ($customerSalle2) {
  266.                     
  267.                 $visit = new VisitOutside();
  268.                 $entityManager =  $doctrine->getManager();
  269.                 $visit->setFistName($customerSalle2['first_name']);
  270.                 $visit->setLastName($customerSalle2['last_name']);
  271.                 $visit->setPhone($customerSalle2['phone']);
  272.                 $visit->setIdentity($customerSalle2['identity_number']);
  273.                 $visit->setPhoto($customerSalle2['image']);
  274.                 $visit->setCreateAt(\DateTimeImmutable::createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  276.                 $visit->setCardReference($customerSalle2['reference']);
  277.                 $entityManager->persist($visit);
  278.                 $entityManager->flush();
  279.             
  280.                     
  281.                     // Simulation de la récupération de la commande pour le client
  282.                     $sqlOrder = "SELECT * FROM `order` WHERE customer_id = :customerId LIMIT 1;";
  283.                     $orderSalle2 = $connection->fetchAssociative($sqlOrder, [
  284.                         'customerId' => $customerSalle2['id']
  285.                     ]);
  286.                     
  287.                     
  288.                     
  289.         
  290.                     $timeStatus = $orderSalle2 ? (bool) $orderSalle2['is_checked'] : false;
  291.                 } else {
  292.                     $timeStatus = false;
  293.                 }
  294.                 
  295.                 
  296.         
  297.                 return $this->render('@Flexy/FrontBundle/Themes/Lasalle/templates/front/customer/visit.html.twig', [
  298.                     'customer' => $customerSalle2,
  299.                     'salle2'=> true,
  300.                     'timeStatus' => $timeStatus,
  301.                 ]);
  302.             }else {
  305.         $customer = $customerRepository->find((int)$request->query->get("customerId"));
  306.         $order = $orderRepository->findOneBy(["customer"=> $customer]);
  307.     
  308.          if($order){
  310.             $timeStatus = $order->getisChecked();
  311.          }
  312.          else{
  313.             $timeStatus = false;
  314.         }
  315.           
  316.        // $customer = $doctrine->getManager()->getRepository(Customer::class)->findOneBy(["reference"=>7890222]);
  317.         //dd($customer[0]->getStore());
  319.         
  321.        
  322.         
  323.         return $this->render('@Flexy/FrontBundle/Themes/Lasalle/templates/front/customer/visit.html.twig', [
  324.             'customer' => $customer,
  325.             'salle2'=> false,
  326.             'timeStatus'=>$timeStatus,
  327.             
  328.         ]);
  329.     }
  330.     
  331.     }
  333. }