src/Controller/Api/MetakockaReceiverController.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api;
  5. use PhpAmqpLib\Channel\AbstractChannel;
  6. use PhpAmqpLib\Channel\AMQPChannel;
  7. use PhpAmqpLib\Connection\AMQPStreamConnection;
  8. use PhpAmqpLib\Message\AMQPMessage;
  9. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\Routing\Annotation\Route;
  14. /**
  15.  * @Route("/api/receiver", name="api_receiver_")
  16.  */
  17. class MetakockaReceiverController extends AbstractController
  18. {
  19.     const LOGFILE = 'webhook_receiver';
  20.     /**
  21.      * @var AMQPStreamConnection
  22.      */
  23.     protected $connection;
  24.     /**
  25.      * @var AbstractChannel|AMQPChannel
  26.      */
  27.     protected $channel;
  29.     /**
  30.      * @var array
  31.      */
  32.     private $connectionParams = [
  33.         'host' => '212.44.120.180',
  34.         'port' => '5672',
  35.         'user' => 'malizakladi',
  36.         'password' => 'h4pCEJEZZW3PxbZaw9otkfJM',
  37.         'vhost' => 'prod'
  38.     ];
  40.     private $queueName = 'erp.product.queue';
  42.     /**
  43.      * @Route("/submit", name="submit", methods={"POST"})
  44.      */
  45.     public function submit(Request $request): JsonResponse
  46.     {
  47.         // Decode the JSON request payload
  48.         $data = json_decode($request->getContent(), true);
  50.         if (!$data) {
  51.             return new JsonResponse(['error' => 'Invalid request data'], 400);
  52.         }
  54.         try {
  55.             $this->connection = new AMQPStreamConnection(
  56.                 $this->connectionParams['host'],
  57.                 $this->connectionParams['port'],
  58.                 $this->connectionParams['user'],
  59.                 $this->connectionParams['password'],
  60.                 $this->connectionParams['vhost']
  61.             );
  62.             $this->channel = $this->connection->channel();
  63.             $this->channel->queue_declare($this->queueName, false, true, false, false);
  64.             $message = [];
  66.             if (isset($data['stock_list'])) {
  67.                 foreach ($data['stock_list'] as $stock) {
  68.                     $message[] = $stock['code'];
  69.         }
  71.         \Pimcore\Log\Simple::log(self::LOGFILE, json_encode($message));
  72.                 $msg = new AMQPMessage(json_encode($message), ['message_id' => time()]);
  73.                 $this->channel->basic_publish($msg, '', $this->queueName);
  74.         } else {
  75.             \Pimcore\Log\Simple::log(self::LOGFILE, json_encode($data));
  76.         }
  77.         } catch (\Exception $e) {
  78.             \Pimcore\Log\Simple::log(self::LOGFILE, $e->getMessage());
  79.     }
  81.         return new JsonResponse(["status"=>"ok"]);
  82.     }
  83. }