custom/plugins/MagmodulesWebshopnl/src/Api/Controller/OrderController.php line 63

  1. <?php
  2. declare(strict_types=1);
  4. namespace MagmodulesWebshopnl\Api\Controller;
  6. use Shopware\Core\Framework\Context;
  7. use Shopware\Core\System\SystemConfig\SystemConfigService;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\Routing\Annotation\Route;
  13. class OrderController extends AbstractController
  14. {
  15.     public function __construct(
  16.         private SystemConfigService $systemConfigService,
  17.         private OrderProcess $orderProcess
  18.     ) {
  19.     }
  21.     /**
  22.      * @Route("/api/webshopnl/order/{salesChannelId}",
  23.      *     name="api.webshopnl.order",  methods={"POST"},
  24.      *     defaults={"auth_required"=false, "_routeScope"={"administration"}})
  25.      */
  26.     public function createOrder(Context $context, Request $request): JsonResponse
  27.     {
  28.         $bearerToken = (string) $request->headers->get('Authorization', '');
  29.         $bearerToken = str_replace("Bearer ", "", $bearerToken);
  30.         $integrationToken = $this->systemConfigService->get('MagmodulesWebshopnl.settings.integrationToken');
  31.         if ($bearerToken !== $integrationToken) {
  32.             return new JsonResponse([
  33.                 'status' => 401,
  34.                 'title' => 'The resource owner or authorization server denied the request',
  35.                 "detail" => 'Access token could not be verified',
  36.             ]);
  37.         }
  39.         $order = json_decode($request->getContent(), true);
  40.         $salesChannelId = $request->attributes->get('salesChannelId');
  41.         $response = $this->orderProcess->processOrder($order, $salesChannelId, $context);
  43.         if (!$response || ($response['status'] ?? null) === 'Rejected') {
  44.             return new JsonResponse($response);
  45.         }
  47.         return new JsonResponse([
  48.             [
  49.                 'order_id' => $order['order_id'],
  50.                 'remote_order_id' => $response['id'] ?? $response['order_id'] ?? null,
  51.                 'merchant_id' => $order['merchant_id'],
  52.                 'status' => "CONFIRMED",
  53.                 'message' => 'Order was imported',
  54.             ],
  55.         ]);
  56.     }
  58.     /**
  59.      * @Route("/api/webshopnl/status/{orderId}",
  60.      *     name="api.webshopnl.status",  methods={"GET"},
  61.      *     defaults={"auth_required"=false, "_routeScope"={"administration"}})
  62.      */
  63.     public function getOrderStatus(Context $context, Request $request): JsonResponse
  64.     {
  65.         $bearerToken = $request->headers->get('Authorization');
  66.         if ($bearerToken) {
  67.             $bearerToken = str_replace("Bearer ", "", $bearerToken);
  68.             $integrationToken = $this->systemConfigService->get('MagmodulesWebshopnl.settings.integrationToken');
  69.             if ($bearerToken === $integrationToken) {
  70.                 $orderId = $request->attributes->get('orderId');
  72.                 return $this->orderProcess->getOrderStatus($orderId, $context);
  73.             }
  75.             return new JsonResponse([
  76.                 'status' => 401,
  77.                 'title' => 'The resource owner or authorization server denied the request',
  78.                 "detail" => 'Access token could not be verified',
  79.             ]);
  80.         }
  82.         return new JsonResponse([
  83.             "status" => 401,
  84.             "title" => 'The resource owner or authorization server denied the request.',
  85.             "detail" => 'Missing Authorization header',
  86.         ]);
  87.     }
  88. }