src/Controller/WebhookController.php line 61

  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Carrier;
  6. use App\Entity\CarrierStatus;
  7. use App\Entity\Order;
  8. use App\Entity\TrackingInformation;
  9. use App\Manager\OrderTrackingManager;
  10. use App\Repository\OrderRepository;
  11. use App\Repository\TrackingInformationRepository;
  12. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\Routing\Annotation\Route;
  17. class WebhookController extends AbstractController
  18. {
  21.     #[Route('/webhooks/delhivery/sync', name: 'webhooks_delhivery_sync', methods: ['POST'])]
  22.     public function createShipment(Request $request, OrderRepository $orderRepository, TrackingInformationRepository $trackingInformationRepository, OrderTrackingManager $orderTrackingManager): JsonResponse
  23.     {
  24.         // Check for Authorization header
  25.         $authHeader = $request->headers->get('Authorization');
  26.         if (!$authHeader || !str_starts_with($authHeader, 'Bearer ')) {
  27.             return new JsonResponse(['error' => 'Authorization header is missing or invalid'], 401);
  28.         }
  30.         // Extract and validate token
  31.         $token = substr($authHeader, 7); // Remove 'Bearer ' prefix
  32.         if ($token !== $this->getParameter('shipflick.webhook.delhivery.token')) {
  33.             return new JsonResponse(['error' => 'Invalid API token'], 403);
  34.         }
  36.         // Decode JSON payload
  37.         $payload = json_decode($request->getContent(), true);
  38.         if (json_last_error() !== JSON_ERROR_NONE) {
  39.             return new JsonResponse(['error' => 'Invalid JSON'], 400);
  40.         }
  42.         // Validate payload fields
  43.         $requiredFields = [
  44.             'shipment_remark', 'location', 'count', 'lrnum', 'mwn',
  45.             'cl_uuid', 'name', 'package_type', 'expected_delivery_date',
  46.             'promised_delivery_date', 'timestamp', 'status',
  47.         ];
  48.         foreach ($requiredFields as $field) {
  49.             if (!isset($payload[$field])) {
  50.                 return new JsonResponse(['error' => "Missing required field: $field"], 400);
  51.             }
  52.         }
  54.         $order = $orderRepository->findOneBy(['LRNo' => $payload['lrnum']]);
  56.         if($order instanceof Order) {
  58.             $statusDateTime = \DateTimeImmutable::createFromFormat("Y-m-d\TH:i:s.u", $payload['timestamp']);
  60.             $mappedStatus = $orderTrackingManager->translateCarrierStatus($order->getCarrier(), $payload['status']);
  61.             $trackingDuplication = $trackingInformationRepository->findBy(['shippingOrder' => $order, 'carrierUpdatedAt' => $statusDateTime, 'status' => $mappedStatus]) ?: false;
  63.             if (!$trackingDuplication) {
  64.                 $trackingInfo = new TrackingInformation();
  65.                 $trackingInfo->setShippingOrder($order);
  66.                 $trackingInfo->setStatus($mappedStatus);
  67.                 $trackingInfo->setLocation($payload['location']);
  68.                 $trackingInfo->setRemarks("scan_remark: " . $payload['shipment_remark']);
  69.                 $trackingInfo->setCarrierUpdatedAt($statusDateTime);
  70.                 $trackingInfo->setStatus($mappedStatus);
  71.                 $orderRepository->save($order);
  72.             }
  74.         }
  78.         return new JsonResponse(['message' => 'Shipment status updated successfully'], 201);
  79.     }
  82. }