Symfony Profiler

<?php
namespace App\Controller;
use DateTime;
use DateTimeZone;
use App\Entity\Order;
use App\Entity\Rewards;
use App\Entity\FoodItem;
use App\Entity\Toppings;
use App\Entity\UserInfo;
use Kreait\Firebase\Factory;
use App\Entity\RewardsHistory;
use Symfony\Component\Uid\Uuid;
use Symfony\Component\Mime\Email;
use Symfony\Component\Mime\Address;
use Symfony\Component\Mailer\Mailer;
use App\Repository\RewardsRepository;
use App\Repository\FoodItemRepository;
use Doctrine\ORM\EntityManagerInterface;
use App\Repository\ConfigurationRepository;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Component\Mailer\Transport\Smtp\EsmtpTransport;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
class OrderController extends AbstractController
{
private ConfigurationRepository $configurationRepository;
public function __construct(ConfigurationRepository $configurationRepository)
{
$this->configurationRepository = $configurationRepository;
}
#[Route('/order/prepare', name: 'api_prepare_order', methods: ['POST'])]
public function prepareOrder(Request $request, EntityManagerInterface $entityManager): Response
{
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $userUuid]);
if (!$userInfo) {
return $this->json(['status' => false, 'message' => 'User not found', 'data' => new \stdClass()]);
}
$requestData = json_decode($request->getContent(), true);
$restaurantId = $requestData['restaurantId'];
$foodItemsData = $requestData['foodItems'] ?? [];
$rewardsData = $requestData['rewards'] ?? [];
if ($restaurantId == 1) {
$checkForRestaurant = 1020;
} else if ($restaurantId == 3) {
$checkForRestaurant = 10202;
} else {
$checkForRestaurant = 1050;
}
$configuration = $this->configurationRepository->getConfigurationByRestaurantId($checkForRestaurant);
/* if (!$configuration) {
return $this->json([
'status' => false,
'message' => 'Configuration not found for restaurant ID: ' . $restaurantId,
'data' => new \stdClass()
]);
}*/
$bypassKey = 'force_prepare_order';
$bypassHeader = $request->headers->get('X-Bypass-Key');
/*
if (!$configuration->isOrderingEnabled() && $bypassHeader !== $bypassKey) {
return $this->json([
'status' => false,
'message' => 'Restaurant is currently not taking orders',
'data' => new \stdClass()
]);
}*/
$order = new Order();
$order->setUserUuid($userUuid);
$order->setRestaurantId($restaurantId);
$order->setOrderStatus('prepared');
$order->setIsSent(false);
$totalPrice = 0;
$itemDetails = [];
$orderItemsNames = [];
foreach ($foodItemsData as $itemData) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($itemData['itemId']);
if (!$foodItem) {
continue;
}
$itemTotal = $foodItem->getPrice() * $itemData['amount'];
$itemNames = [
'itemId' => $foodItem->getId(),
'name' => $foodItem->getName(),
'note' => $itemData['note'],
'quantity' => $itemData['amount'],
'image' => 'https://api.theswarm.io/uploads/images/' . $foodItem->getImage(),
'unitPrice' => $foodItem->getPrice(),
'totalPrice' => $itemTotal,
'toppings' => []
];
foreach ($itemData['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
$toppingTotal = $topping->getPrice() * $toppingData['amount'] * $itemData['amount'];
$itemTotal += $toppingTotal;
$itemNames['toppings'][] = [
'itemId' => $topping->getId(),
'name' => $topping->getName(),
'quantity' => $toppingData['amount'],
'unitPrice' => $topping->getPrice(),
'totalPrice' => $toppingTotal
];
}
}
$totalPrice += $itemTotal;
$itemNames['totalPrice'] = $itemTotal;
$itemDetails[] = $itemNames;
$orderItemsNames[] = $itemNames;
}
$order->setOriginalTotalPrice($totalPrice);
$rewardItemsList = [];
// Apply rewards and deduct reward points if applicable
$usedRewardPoints = 0;
foreach ($rewardsData as $rewardData) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardData['rewardId']);
if ($reward && $userInfo->getRewardPoints() >= $reward->getPrice()) {
$usedRewardPoints += $reward->getPrice();
$orderItemsNames[] = [
'name' => $reward->getName(),
'type' => 'reward',
'points' => $reward->getPrice()
];
$rewardItemsList[] = [
'rewardId' => $reward->getId(),
'name' => $reward->getName(),
'type' => 'reward',
'image' => 'https://api.theswarm.io/uploads/rewards_images/' . $reward->getImage(),
'points' => $reward->getPrice()
];
}
}
// Deduct wallet amount if applicable
// $gainingRewardPoints = round(($totalPrice / 100)*3);
// this block below activates 50% off
// if ($restaurantId == 3) {
// if ($totalPrice > 0) {
// $totalPrice = $totalPrice / 2;
// }
// }
$gainingRewardPoints = $totalPrice > 0 ? round(($totalPrice / 100) * 3) : 0;
/*$walletDeduction = min($userInfo->getWalletAmount(), $totalPrice);
if ($walletDeduction > $totalPrice) {
$walletDeduction = $totalPrice;
}
$totalPrice -= $walletDeduction;*/
/* $walletAmount = max(0, $userInfo->getWalletAmount());
$walletDeduction = min($walletAmount, $totalPrice);
$totalPrice -= $walletDeduction;*/
$walletAmount = max(0, $userInfo->getWalletAmount());
$walletDeduction = $totalPrice > 0 ? min($walletAmount, $totalPrice) : 0;
$totalPrice -= $walletDeduction;
$order->setTotalPrice($totalPrice); // convert to cents
$order->setOrderItemsJson(json_encode($foodItemsData));
$order->setOrderItemsNames(json_encode($orderItemsNames));
$order->setOrderRewardItems(json_encode($rewardsData));
$order->setUsedReward($usedRewardPoints);
$order->setGainedReward($gainingRewardPoints);
$order->setWalletDeduct($walletDeduction);
$entityManager->persist($order);
$entityManager->flush();
return $this->json([
'status' => true,
'message' => 'Order prepared successfully',
'data' => [
'order_id' => $order->getId(),
'total_price' => $totalPrice,
'used_reward_points' => $usedRewardPoints,
'wallet_deduction' => $walletDeduction,
'reward_points_gained' => $gainingRewardPoints,
'remaining_wallet_amount' => $userInfo->getWalletAmount() - $walletDeduction,
'items' => $itemDetails,
'rewards' => $rewardItemsList
]
]);
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Invalid token: ' . $e->getMessage(), 'data' => new \stdClass()]);
}
}
#[Route('/order/dispatch/{restaurantId}/{orderId}', name: 'api_dispatch_order', methods: ['POST'])]
public function dispatchOrder(Request $request, EntityManagerInterface $entityManager, int $restaurantId, int $orderId): JsonResponse
{
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Invalid token: ' . $e->getMessage(), 'data' => new \stdClass()]);
}
$order = $entityManager->getRepository(Order::class)->find($orderId);
if (!$order) {
return $this->json(['status' => false, 'message' => 'Order not found', 'data' => new \stdClass()]);
}
if ($order->getOrderStatus() === 'dispatched' || $order->getOrderStatus() === 'sent') {
return $this->json(['status' => false, 'message' => 'Order already dispatched or sent', 'data' => new \stdClass()]);
}
$remoteOrderId = Uuid::v4()->toRfc4122();
$order->setOrderStatus('dispatched');
$order->setRestaurantId($restaurantId);
$order->setRemoteOrderId($remoteOrderId);
$entityManager->persist($order);
$entityManager->flush();
$mockResponseData = [
'status' => true,
'message' => 'Order dispatched for approval',
'data' => [
'order_id' => $order->getId(),
'status' => 'acceptRequired',
'total_price' => $order->getTotalPrice(),
'used_reward_points' => $order->getUsedReward(),
'wallet_deduction' => $order->getWalletDeduct(),
'reward_points_gained' => $order->getGainedReward(),
'remaining_wallet_amount' => 0,
'items' => json_decode($order->getOrderItemsNames(), true),
'possibleStateChanges' => [
[
"state" => "receivedByProvider",
"timeChange" => true
],
[
"state" => "rejectedByPOS",
"timeChange" => false
]
],
'possibleActions' => [
'receivedByProvider'
],
'modifyHistory' => [
[
'status' => 'waitingForApproval',
'updatedAt' => (new \DateTime('now', new \DateTimeZone('UTC')))->format('Y-m-d\TH:i:s.v\Z')
]
],
],
'prepareTime' => 'Waiting for confirmation',
'stripePaymentId' => '',
'remoteOrderId' => $remoteOrderId
];
return $this->json($mockResponseData);
}
private function dispatchOrderMergeport(Order $order, int $restaurantId, int $pickupTime, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): void
{
if ($restaurantId == 1) {
$checkForRestaurant = 1020;
} else if ($restaurantId == 3) {
$checkForRestaurant = 10202;
} else {
$checkForRestaurant = 1050;
}
$configuration = $this->configurationRepository->getConfigurationByRestaurantId($checkForRestaurant);
/* if (!$configuration->isOrderingEnabled()) {
throw new \Exception('Restaurant is currently not taking orders');
}*/
$restaurantRemoteId = $this->getRestaurantRemoteId($restaurantId);
if (!$restaurantRemoteId) {
throw new \Exception('Restaurant ID Incorrect.');
}
$userUuid = $order->getUserUuid();
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $userUuid]);
if (!$userInfo) {
throw new \Exception('User not found');
}
$originalTotalPrice = 0;
$orderItems = json_decode($order->getOrderItemsJson(), true) ?? [];
$rewardsData = json_decode($order->getOrderRewardItems(), true) ?? [];
$products = [];
foreach ($orderItems as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
$itemTotal = $foodItem->getPrice() * $item['amount'];
if ($restaurantId == 1) {
$remoteCodeFoodItem = $foodItem->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeFoodItem = $foodItem->getPosId10202();
} else {
$remoteCodeFoodItem = $foodItem->getPosId1050();
}
$product = [
'id' => (string) $foodItem->getId(),
'remoteCode' => $remoteCodeFoodItem,
'name' => $foodItem->getName(),
'comment' => $item['note'] ?? '',
'unitPrice' => $foodItem->getPrice(),
'paidPrice' => $foodItem->getPrice() * $item['amount'],
'quantity' => isset($item['amount']) ? $item['amount'] : 1,
'selectedToppings' => []
];
foreach ($item['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
$itemTotal += $topping->getPrice() * $toppingData['amount'];
if ($topping) {
if ($restaurantId == 1) {
$remoteCodeTopping = $topping->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeTopping = $topping->getPosId10202();
} else {
$remoteCodeTopping = $topping->getPosId1050();
}
$product['selectedToppings'][] = [
'id' => (string) $topping->getId(),
'remoteCode' => $remoteCodeTopping,
'name' => $topping->getName(),
'price' => $topping->getPrice(),
'quantity' => isset($toppingData['amount']) ? $toppingData['amount'] : 1,
'children' => []
];
}
}
$originalTotalPrice += $itemTotal;
$products[] = $product;
}
}
if (!empty($rewardsData)) {
foreach ($rewardsData as $rewardData) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardData['rewardId']);
if ($reward) {
$product = [
'id' => 'reward_' . $reward->getId(),
'remoteCode' => '',
'name' => 'REWARD: ' . $reward->getName(),
'comment' => '',
'unitPrice' => 0,
'paidPrice' => 0,
'quantity' => 1,
'selectedToppings' => []
];
$products[] = $product;
}
}
}
$originalTotalPrice = $order->getOriginalTotalPrice();
$usedRewardPoints = $order->getUsedReward();
$gainedRewardPoints = $order->getGainedReward();
$walletDeduction = min($order->getWalletDeduct(), $originalTotalPrice);
$userFullName = $userInfo->getFullName();
$nameParts = explode(" ", $userFullName);
$userFName = $nameParts[0] ?? '';
$userLName = $nameParts[1] ?? '';
$expectedTime = (new \DateTime('now', new \DateTimeZone('UTC')))
->modify('+' . $pickupTime . ' minutes')
->format('Y-m-d\TH:i:s.v\Z');
/* $paymentAmount = $originalTotalPrice - $walletDeduction;
$paymentAmount = max(0, $paymentAmount);*/
$paymentAmount = max(0, $originalTotalPrice - $walletDeduction);
/*
$paymentType = $paymentAmount > 0 ? 'CARD' : 'WALLET';
$referenceId = $paymentAmount > 0 ? 'card' : 'wallet';*/
if ($paymentAmount > 0) {
$paymentType = 'CARD';
$referenceId = 'card';
} else {
$paymentType = 'WALLET';
$referenceId = 'wallet';
}
$paymentAmountForPayload = ($paymentType === 'WALLET') ? $walletDeduction : $paymentAmount;
$payload = [
'token' => uuid_create(),
'expiryDate' => (new \DateTime('+1 hour'))->format(\DateTimeInterface::ATOM),
'createdAt' => $order->getCreatedAt()->format(\DateTimeInterface::ATOM),
'code' => "ORDER#" . $order->getId(),
'shortCode' => "ORDER#" . $order->getId(),
'preOrder' => true,
'platformInfo' => [
'restaurantId' => $restaurantRemoteId,
'platform' => 'Randale',
'countryCode' => 'AT',
'currency' => 'EUR'
],
'customer' => [
'firstName' => $userFName,
'lastName' => $userLName,
'mobilePhone' => $userInfo->getPhoneNumber(),
],
'payment' => [
'type' => $paymentType,
'amount' => (int) $paymentAmountForPayload,
'payOnDelivery' => false,
'referenceId' => $referenceId
],
'expeditionType' => 'pickup',
'pickupInfo' => [
'expectedTime' => $expectedTime
],
'products' => $products,
'additionalCosts' => [],
'price' => [
'subTotal' => (int) $originalTotalPrice,
'grandTotal' => (int) $paymentAmount
]
];
if ($walletDeduction > 0) {
$payload['discounts'] = [['name' => 'Wallet', 'amount' => (int) $walletDeduction]];
}
try {
$userInfo->setRewardPoints($userInfo->getRewardPoints() - $usedRewardPoints + $gainedRewardPoints);
$userInfo->setWalletAmount($userInfo->getWalletAmount() - $walletDeduction);
$entityManager->persist($userInfo);
if ($order->getWalletDeduct() > $walletDeduction) {
$difference = $order->getWalletDeduct() - $walletDeduction;
$userInfo->setWalletAmount($userInfo->getWalletAmount() + $difference);
$order->setWalletDeduct($walletDeduction);
$entityManager->persist($userInfo);
$entityManager->persist($order);
}
// $entityManager->flush();
if ($usedRewardPoints > 0) {
$rewardsHistory = new RewardsHistory();
$rewardsHistory->setUserUuid($userUuid);
$rewardsHistory->setAmount($usedRewardPoints);
$rewardsHistory->setChangeType('deduct');
$rewardsHistory->setTransactionDate(new \DateTime());
$rewardsHistory->setDescription('Reward purchase');
$entityManager->persist($rewardsHistory);
}
if ($gainedRewardPoints > 0) {
$rewardsHistoryGain = new RewardsHistory();
$rewardsHistoryGain->setUserUuid($userUuid);
$rewardsHistoryGain->setAmount($gainedRewardPoints);
$rewardsHistoryGain->setChangeType('gain');
$rewardsHistoryGain->setTransactionDate(new \DateTime());
$rewardsHistoryGain->setDescription('Order');
$entityManager->persist($rewardsHistoryGain);
}
$entityManager->flush();
// dd($payload);
$response = $httpClient->request('POST', "https://ordering.mergeport.com/v4/hooks/main/e2e122e1-9481-65eb-8a0a-54079cb4211b/order/" . $restaurantRemoteId, [
'json' => $payload
]);
$responseData = $response->toArray();
$order->setRestaurantId($restaurantId);
$order->setOrderStatus('sent');
$order->setIsSent(true);
$order->setRemoteResponse($responseData);
// $order->setRemoteOrderId($responseData['remoteResponse']['remoteOrderId'] ?? '');
// $order->setStripeId($stripePaymentId);
$entityManager->persist($order);
$entityManager->flush();
// Send confirmation email to the user
$this->sendOrderSuccessEmail($order, $userInfo);
} catch (\Throwable $e) {
// Handle exceptions and rethrow for the calling method to catch
throw new \Exception('Failed to dispatch order: ' . $e->getMessage());
}
}
private function dispatchOrderMergeportNewBackup(Order $order, int $restaurantId, int $pickupTime, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): void
{
if ($restaurantId == 1) {
$checkForRestaurant = 1020;
} else if ($restaurantId == 3) {
$checkForRestaurant = 10202;
} else {
$checkForRestaurant = 1050;
}
$configuration = $this->configurationRepository->getConfigurationByRestaurantId($checkForRestaurant);
/* if (!$configuration->isOrderingEnabled()) {
throw new \Exception('Restaurant is currently not taking orders');
}*/
$restaurantRemoteId = $this->getRestaurantRemoteId($restaurantId);
if (!$restaurantRemoteId) {
throw new \Exception('Restaurant ID Incorrect.');
}
$userUuid = $order->getUserUuid();
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $userUuid]);
if (!$userInfo) {
throw new \Exception('User not found');
}
$orderItems = json_decode($order->getOrderItemsJson(), true);
$rewardsData = json_decode($order->getOrderRewardItems(), true);
$products = [];
foreach ($orderItems as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
if ($restaurantId == 1) {
$remoteCodeFoodItem = $foodItem->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeFoodItem = $foodItem->getPosId10202();
} else {
$remoteCodeFoodItem = $foodItem->getPosId1050();
}
$product = [
'id' => (string) $foodItem->getId(),
'remoteCode' => $remoteCodeFoodItem,
'name' => $foodItem->getName(),
'comment' => $item['note'] ?? '',
'unitPrice' => $foodItem->getPrice(),
'paidPrice' => $foodItem->getPrice() * $item['amount'],
'quantity' => $item['amount'],
'selectedToppings' => []
];
foreach ($item['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
if ($restaurantId == 1) {
$remoteCodeTopping = $topping->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeTopping = $topping->getPosId10202();
} else {
$remoteCodeTopping = $topping->getPosId1050();
}
$product['selectedToppings'][] = [
'id' => (string) $topping->getId(),
'remoteCode' => $remoteCodeTopping,
'name' => $topping->getName(),
'price' => $topping->getPrice(),
'quantity' => $toppingData['amount'],
'children' => []
];
}
}
$products[] = $product;
}
}
$usedRewardPoints = $order->getUsedReward();
$gainedRewardPoints = $order->getGainedReward();
$walletDeduction = $order->getWalletDeduct();
$userFullName = $userInfo->getFullName();
$nameParts = explode(" ", $userFullName);
$userFName = $nameParts[0] ?? '';
$userLName = $nameParts[1] ?? '';
$expectedTime = (new \DateTime('now', new \DateTimeZone('UTC')))
->modify('+' . $pickupTime . ' minutes')
->format('Y-m-d\TH:i:s.v\Z');
$payload = [
'token' => uuid_create(),
'expiryDate' => (new \DateTime('+1 hour'))->format(\DateTimeInterface::ATOM),
'createdAt' => $order->getCreatedAt()->format(\DateTimeInterface::ATOM),
'code' => "ORDER#" . $order->getId(),
'shortCode' => "ORDER#" . $order->getId(),
'preOrder' => true,
'platformInfo' => [
'restaurantId' => $restaurantRemoteId,
'platform' => 'Randale',
'countryCode' => 'AT',
'currency' => 'EUR'
],
'customer' => [
'firstName' => $userFName,
'lastName' => $userLName,
'mobilePhone' => $userInfo->getPhoneNumber(),
],
'payment' => [
'type' => 'CARD',
'amount' => $order->getTotalPrice(),
'payOnDelivery' => false,
'referenceId' => 'card'
],
'expeditionType' => 'pickup',
'pickupInfo' => [
'expectedTime' => $expectedTime
],
'products' => $products,
'additionalCosts' => [],
'price' => [
'subTotal' => $order->getTotalPrice(),
'grandTotal' => $order->getTotalPrice()
]
];
if ($walletDeduction > 0) {
$payload['discounts'] = [['name' => 'Wallet', 'amount' => $walletDeduction]];
}
try {
$userInfo->setRewardPoints($userInfo->getRewardPoints() - $usedRewardPoints + $gainedRewardPoints);
$userInfo->setWalletAmount($userInfo->getWalletAmount() - $walletDeduction);
$entityManager->persist($userInfo);
if ($usedRewardPoints > 0) {
$rewardsHistory = new RewardsHistory();
$rewardsHistory->setUserUuid($userUuid);
$rewardsHistory->setAmount($usedRewardPoints);
$rewardsHistory->setChangeType('deduct');
$rewardsHistory->setTransactionDate(new \DateTime());
$rewardsHistory->setDescription('Reward purchase');
$entityManager->persist($rewardsHistory);
}
if ($gainedRewardPoints > 0) {
$rewardsHistoryGain = new RewardsHistory();
$rewardsHistoryGain->setUserUuid($userUuid);
$rewardsHistoryGain->setAmount($gainedRewardPoints);
$rewardsHistoryGain->setChangeType('gain');
$rewardsHistoryGain->setTransactionDate(new \DateTime());
$rewardsHistoryGain->setDescription('Order');
$entityManager->persist($rewardsHistoryGain);
}
$entityManager->flush();
$response = $httpClient->request('POST', "https://ordering.mergeport.com/v4/hooks/main/e2e122e1-9481-65eb-8a0a-54079cb4211b/order/" . $restaurantRemoteId, [
'json' => $payload
]);
$responseData = $response->toArray();
$order->setRestaurantId($restaurantId);
$order->setOrderStatus('sent');
$order->setIsSent(true);
$order->setRemoteResponse($responseData);
$order->setRemoteOrderId($responseData['remoteResponse']['remoteOrderId'] ?? '');
// $order->setStripeId($stripePaymentId);
$entityManager->persist($order);
$entityManager->flush();
// Send confirmation email to the user
$this->sendOrderSuccessEmail($order, $userInfo);
} catch (\Throwable $e) {
// Handle exceptions and rethrow for the calling method to catch
throw new \Exception('Failed to dispatch order: ' . $e->getMessage());
}
}
#[Route('/order/dispatch-mergeport/{restaurantId}/{orderId}', name: 'api_dispatch_order_mergeport', methods: ['POST'])]
public function dispatchOrderMergeportBACKUP(Request $request, EntityManagerInterface $entityManager, HttpClientInterface $httpClient, $restaurantId, $orderId): Response
{
// $configuration = $this->configurationRepository->getCurrentConfiguration();
/* if (!$configuration || !$configuration->isOrderingEnabled()) {
return $this->json([
'status' => false,
'message' => 'Restaurant is currently not taking orders',
'data' => new \stdClass()
]);
}*/
if ($restaurantId == 1) {
$checkForRestaurant = 1020;
} else if ($restaurantId == 3) {
$checkForRestaurant = 10202;
} else {
$checkForRestaurant = 1050;
}
$configuration = $this->configurationRepository->getConfigurationByRestaurantId($checkForRestaurant);
/* if (!$configuration) {
return $this->json([
'status' => false,
'message' => 'Configuration not found for restaurant ID: ' . $restaurantId,
'data' => new \stdClass()
]);
}*/
$bypassKey = 'force_prepare_order';
$bypassHeader = $request->headers->get('X-Bypass-Key');
if (!$configuration->isOrderingEnabled() && $bypassHeader !== $bypassKey) {
return $this->json([
'status' => false,
'message' => 'Restaurant is currently not taking orders',
'data' => new \stdClass()
]);
}
$restaurantRemoteId = $this->getRestaurantRemoteId($restaurantId);
if (!$restaurantRemoteId) {
return $this->json(['status' => false, 'message' => 'Restaurant ID Incorrect.']);
}
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $userUuid]);
$order = $entityManager->getRepository(Order::class)->find($orderId);
if (!$order) {
return $this->json(['status' => false, 'message' => 'Order not found', 'data' => new \stdClass()]);
}
$requestData = json_decode($request->getContent(), true);
$stripePaymentId = $requestData['stripeTransactionId'] ?? [];
$orderItems = json_decode($order->getOrderItemsJson(), true);
$rewardsData = json_decode($order->getOrderRewardItems(), true);
$products = [];
foreach ($orderItems as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
if ($restaurantId == 1) {
$remoteCodeFoodItem = $foodItem->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeFoodItem = $foodItem->getPosId10202();
} else {
$remoteCodeFoodItem = $foodItem->getPosId1050();
}
$product = [
'id' => (string) $foodItem->getId(),
'remoteCode' => $remoteCodeFoodItem,
'name' => $foodItem->getName(),
'comment' => $item['note'],
'unitPrice' => $foodItem->getPrice(),
'paidPrice' => $foodItem->getPrice() * $item['amount'],
'quantity' => $item['amount'],
'selectedToppings' => []
];
foreach ($item['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
if ($restaurantId == 1) {
$remoteCodeTopping = $topping->getPosId();
} elseif ($restaurantId == 3) {
$remoteCodeTopping = $topping->getPosId10202();
} else {
$remoteCodeTopping = $topping->getPosId1050();
}
$product['selectedToppings'][] = [
'id' => (string) $topping->getId(),
'remoteCode' => $remoteCodeTopping,
'name' => $topping->getName(),
'price' => $topping->getPrice(),
'quantity' => $toppingData['amount'],
'children' => []
];
}
}
$products[] = $product;
}
}
$usedRewardPoints = 0;
foreach ($rewardsData as $rewardData) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardData['rewardId']);
if ($reward && $userInfo->getRewardPoints() >= $reward->getPrice()) {
$usedRewardPoints += $reward->getPrice();
$orderItemsNames[] = [
'name' => $reward->getName(),
'type' => 'reward',
'points' => $reward->getPrice()
];
$rewardItemsList[] = [
'name' => $reward->getName(),
'type' => 'reward',
'image' => 'https://api.theswarm.io/uploads/rewards_images/' . $reward->getImage(),
'points' => $reward->getPrice()
];
$product = [
'id' => (string) $reward->getId(),
'name' => $reward->getName(),
'comment' => '',
'unitPrice' => 0,
'paidPrice' => 0,
'quantity' => 1
];
$products[] = $product;
}
}
$userFullName = $userInfo->getFullName();
list($userFName, $userLName) = explode(" ", $userFullName);
$expectedTime = (new DateTime('now', new DateTimeZone('UTC')))
->modify('+20 minutes')
->format('Y-m-d\TH:i:s.v\Z');
$payload = [
'token' => uuid_create(),
'expiryDate' => (new \DateTime('+1 hour'))->format(\DateTimeInterface::ATOM),
'createdAt' => $order->getCreatedAt()->format(\DateTimeInterface::ATOM),
'code' => "ORDER#" . $order->getId(),
'shortCode' => "ORDER#" . $order->getId(),
'preOrder' => true,
'platformInfo' => [
'restaurantId' => $restaurantRemoteId,
'platform' => 'Randale',
'countryCode' => 'AT',
'currency' => 'EUR'
],
'customer' => [
'firstName' => $userFName,
'lastName' => $userLName,
'mobilePhone' => $userInfo->getPhoneNumber(),
],
'payment' => [
'type' => 'CARD',
'amount' => $order->getTotalPrice(),
'payOnDelivery' => false,
'referenceId' => 'card'
],
'expeditionType' => 'pickup',
'pickupInfo' => [
'expectedTime' => $expectedTime
],
'products' => $products,
'additionalCosts' => [],
'price' => [
'subTotal' => $order->getTotalPrice(),
'grandTotal' => $order->getTotalPrice()
]
];
try {
$totalPrice = 0;
$orderItems = json_decode($order->getOrderItemsJson(), true);
foreach ($orderItems as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
$itemTotal = $foodItem->getPrice() * $item['amount'];
foreach ($item['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
$itemTotal += $topping->getPrice() * $toppingData['amount'];
}
$totalPrice += $itemTotal;
}
//$gainingRewardPoints = round(($totalPrice / 100) * 3);
$gainingRewardPoints = $order->getGainedReward();
$walletDeduction = min($userInfo->getWalletAmount(), $totalPrice);
$userInfo->setRewardPoints($userInfo->getRewardPoints() - $usedRewardPoints + $gainingRewardPoints);
$userInfo->setWalletAmount($userInfo->getWalletAmount() - $walletDeduction);
if ($walletDeduction > 0) {
// add discount to payload
$payload['discounts'] = [['name' => 'Wallet', 'amount' => $walletDeduction]];
}
$entityManager->persist($userInfo);
if ($usedRewardPoints > 0) {
$rewardsHistory = new RewardsHistory();
$rewardsHistory->setUserUuid($userUuid);
$rewardsHistory->setAmount($usedRewardPoints);
$rewardsHistory->setChangeType('deduct');
$rewardsHistory->setTransactionDate(new \DateTime());
$rewardsHistory->setDescription('Reward purchase');
$entityManager->persist($rewardsHistory);
}
$rewardsHistoryGain = new RewardsHistory();
$rewardsHistoryGain->setUserUuid($userUuid);
$rewardsHistoryGain->setAmount($gainingRewardPoints);
$rewardsHistoryGain->setChangeType('gain');
$rewardsHistoryGain->setTransactionDate(new \DateTime());
$rewardsHistoryGain->setDescription('Order');
$entityManager->persist($rewardsHistoryGain);
$entityManager->flush();
$response = $httpClient->request('POST', "https://ordering.mergeport.com/v4/hooks/main/e2e122e1-9481-65eb-8a0a-54079cb4211b/order/".$restaurantRemoteId, [
'json' => $payload
]);
$responseData = $response->toArray();
$order->setRestaurantId($restaurantId);
$order->setOrderStatus('sent');
$order->setIsSent(true);
$order->setRemoteResponse($responseData);
$order->setRemoteOrderId($responseData['remoteResponse']['remoteOrderId'] ?? '');
$order->setStripeId($stripePaymentId);
$entityManager->persist($order);
$entityManager->flush();
$this->sendOrderSuccessEmail($order, $userInfo);
return $this->json([
'status' => true,
'message' => 'Order dispatched successfully',
'data' => $responseData,
'prepareTime' => 'Waiting for confirmation',
'usedRewardPoints' => $usedRewardPoints,
'gainedRewardPoints' => (int) $gainingRewardPoints,
'walletDeduction' => $walletDeduction,
'stripePaymentId' => $stripePaymentId,
'remoteOrderId' => $responseData['remoteResponse']['remoteOrderId'] ?? ''
]);
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Failed to dispatch order: ' . $e->getMessage(), 'data' => new \stdClass(), 'payload' => $payload]);
}
}
/*
#[Route('/order/history', name: 'order_history_list', methods: ['GET'])]
public function orderHistoryList(Request $request, EntityManagerInterface $entityManager): Response
{
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Invalid token: ' . $e->getMessage(), 'data' => new \stdClass()]);
}
$orders = $entityManager->getRepository(Order::class)->findBy(['user_uuid' => $userUuid, 'order_status' => 'sent']);
$orderList = array_map(function ($order) {
return [
'orderNumber' => $order->getId(),
'dateAndTime' => $order->getCreatedAt()->format('Y-m-d H:i:s'),
'totalPrice' => $order->getTotalPrice(),
'orderItems' => json_decode($order->getOrderItemsJson(), true)
];
}, $orders);
return $this->json([
'status' => true,
'data' => $orderList
]);
}*/
#[Route('/order/history', name: 'order_history_list', methods: ['GET'])]
public function orderHistoryList(Request $request, EntityManagerInterface $entityManager): Response
{
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Invalid token: ' . $e->getMessage(), 'data' => new \stdClass()]);
}
$orderStatuses = ['sent', 'refunded'];
$orders = $entityManager->getRepository(Order::class)->findBy(['user_uuid' => $userUuid, 'order_status' => $orderStatuses]);
$orderList = array_map(function ($order) use ($entityManager) {
$items = json_decode($order->getOrderItemsJson(), true);
$itemDetails = [];
$itemCount = 0;
foreach ($items as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
$itemDetail = [
'itemId' => $item['itemId'],
'name' => $foodItem->getName(),
'amount' => $item['amount'],
'unitPrice' => $foodItem->getPrice(),
'image' => 'https://api.theswarm.io/uploads/images/' . $foodItem->getImage(),
'toppings' => array_map(function ($toppingData) use ($entityManager) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
return [
'toppingId' => $toppingData['toppingId'],
'name' => $topping->getName(),
'amount' => $toppingData['amount'],
'unitPrice' => $topping->getPrice()
];
}
return null;
}, $item['toppings'])
];
$itemCount += $item['amount'];
$itemDetails[] = $itemDetail;
}
}
$rewardsData = json_decode($order->getOrderRewardItems(), true);
$rewards = [];
if (!empty($rewardsData)) {
foreach ($rewardsData as $rewardItem) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardItem['rewardId']);
if ($reward) {
$rewards[] = [
'rewardId' => $reward->getId(),
'image' => 'https://api.theswarm.io/uploads/rewards_images/' . $reward->getImage(),
'name' => $reward->getName(),
'type' => 'reward',
'points' => $reward->getPrice(),
];
}
}
}
$orderResponseJsonInfo = $order->getRemoteResponse();
$remote_order_id = "";
if ($orderResponseJsonInfo) {
$remote_order_id = $orderResponseJsonInfo['remoteResponse']['remoteOrderId'] ?? '';
}
return [
'orderStatus' => $order->getOrderStatus(),
'orderNumber' => $order->getId(),
'restaurant_id' => $order->getRestaurantId(),
'remote_order_id' => $remote_order_id,
'dateAndTime' => $order->getCreatedAt()->format('Y-m-d H:i:s'),
'total_price' => $order->getTotalPrice(),
'used_reward_points' => $order->getUsedReward(),
'reward_points_gained' => $order->getGainedReward(),
'wallet_deduction' => $order->getWalletDeduct(),
'orderItems' => $itemDetails,
'itemCount' => $itemCount,
'stripePaymentId' => $order->getStripeId(),
'rewards' => $rewards
];
}, $orders);
return $this->json([
'status' => true,
'data' => $orderList
]);
}
#[Route('/order/history/{orderId}', name: 'order_history_single', methods: ['GET'])]
public function orderHistorySingle(Request $request, EntityManagerInterface $entityManager, int $orderId): Response
{
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json(['status' => false, 'message' => 'Authorization token not found', 'data' => new \stdClass()]);
}
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$userUuid = $decodedToken->claims()->get('sub');
} catch (\Throwable $e) {
return $this->json(['status' => false, 'message' => 'Invalid token: ' . $e->getMessage(), 'data' => new \stdClass()]);
}
$orderStatuses = ['sent', 'refunded'];
$order = $entityManager->getRepository(Order::class)->findOneBy(['id' => $orderId, 'user_uuid' => $userUuid]);
if (!$order) {
return $this->json(['status' => false, 'message' => 'Order not found or not sent', 'data' => new \stdClass()]);
}
$items = json_decode($order->getOrderItemsJson(), true);
$itemDetails = [];
$itemCount = 0;
foreach ($items as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
$itemDetail = [
'itemId' => $item['itemId'],
'name' => $foodItem->getName(),
'unitPrice' => $foodItem->getPrice(),
'amount' => $item['amount'],
'image' => 'https://api.theswarm.io/uploads/images/' . $foodItem->getImage(),
'toppings' => array_map(function ($toppingData) use ($entityManager) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
return [
'toppingId' => $toppingData['toppingId'],
'name' => $topping->getName(),
'amount' => $toppingData['amount'],
'unitPrice' => $topping->getPrice()
];
}
return null;
}, $item['toppings'])
];
$itemCount += $item['amount'];
$itemDetails[] = $itemDetail;
}
}
$rewardsData = json_decode($order->getOrderRewardItems(), true);
$rewards = [];
if (!empty($rewardsData)) {
foreach ($rewardsData as $rewardItem) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardItem['rewardId']);
if ($reward) {
$rewards[] = [
'rewardId' => $reward->getId(),
'image' => 'https://api.theswarm.io/uploads/rewards_images/' . $reward->getImage(),
'name' => $reward->getName(),
'type' => 'reward',
'points' => $reward->getPrice(),
];
}
}
}
$orderResponseJsonInfo = $order->getRemoteResponse();
$remote_order_id = "";
if ($orderResponseJsonInfo) {
$remote_order_id = $orderResponseJsonInfo['remoteResponse']['remoteOrderId'] ?? '';
}
return $this->json([
'status' => true,
'data' => [
'orderStatus' => $order->getOrderStatus(),
'orderNumber' => $order->getId(),
'restaurant_id' => $order->getRestaurantId(),
'remote_order_id' => $remote_order_id,
'dateAndTime' => $order->getCreatedAt()->format('Y-m-d H:i:s'),
'total_price' => $order->getTotalPrice(),
'used_reward_points' => $order->getUsedReward(),
'reward_points_gained' => $order->getGainedReward(),
'wallet_deduction' => $order->getWalletDeduct(),
'items' => $itemDetails,
'itemCount' => $itemCount,
'stripePaymentId' => $order->getStripeId(),
'rewards' => $rewards
]
]);
}
#[Route('/api/ordering-status', name: 'api_ordering_status', methods: ['GET'])]
public function getOrderingStatus(): JsonResponse
{
$configurations = $this->configurationRepository->findAll();
if (!$configurations) {
return $this->json(['status' => false, 'message' => 'No configurations found', 'data' => new \stdClass()]);
}
$statusData = [];
foreach ($configurations as $configuration) {
$statusData[] = [
'restaurant' => $configuration->getDescription(),
'orderingEnabled' => $configuration->isOrderingEnabled(),
'message' => $configuration->isOrderingEnabled() ? '' : 'Restaurant is currently not taking orders'
];
}
return $this->json([
'status' => true,
'data' => $statusData
]);
}
#[Route('/api/order/status/{restaurantId}/{orderId}', name: 'api_order_status', methods: ['GET'])]
public function getOrderStatus(EntityManagerInterface $entityManager, string $restaurantId, string $orderId): JsonResponse
{
try {
// Fetch the order using remoteOrderId
$order = $entityManager->getRepository(Order::class)->findOneBy(['remote_order_id' => $orderId]);
if (!$order) {
return $this->json([
'status' => false,
'message' => 'Order not found',
'data' => new \stdClass()
]);
}
// Prepare common data
$orderData = [
'lastModifyDate' => $order->getUpdatedAt()->format('Y-m-d\TH:i:s.v\Z'),
'orderReference' => 'ORDER#' . $order->getId(),
'siteId' => '3447e2e9-57e6-47b8-aa54-4b8e8571e76d',
'additionalCosts' => [],
'orderId' => $order->getRemoteOrderId(),
'status' => '', // Will be set below
'creationDate' => $order->getCreatedAt()->format('Y-m-d\TH:i:s.v\Z'),
'paymentInfo' => [
[
'amount' => [
'amount' => $order->getTotalPrice(),
'currency' => 'EUR'
],
'multipleOrderPayment' => false,
'brand' => 'creditcard',
'referenceId' => 'card',
'paymentType' => 'CARD',
'payOnDelivery' => false
]
],
'pickupInfo' => [
'firstName' => '',
'lastName' => '',
'pickupTime' => '',
'phone' => '',
'middleName' => null,
'comment' => null,
'email' => null
],
'providerId' => 'e2e122e1-9481-65eb-8a0a-54079cb4211b',
'amountToPay' => [
'amount' => $order->getTotalPrice(),
'currency' => 'EUR'
],
'possibleActions' => [],
'modifyHistory' => [],
'notes' => 'ORDER#' . $order->getId(),
'providerName' => 'RANDALE APP',
'possibleStateChanges' => [],
'preOrder' => true,
'id' => Uuid::v4()->toRfc4122(),
'discounts' => [],
'customerId' => $order->getUserUuid(),
'items' => [],
];
// Fetch user info
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $order->getUserUuid()]);
if ($userInfo) {
$fullName = explode(' ', $userInfo->getFullName(), 2);
$orderData['pickupInfo']['firstName'] = $fullName[0] ?? '';
$orderData['pickupInfo']['lastName'] = $fullName[1] ?? '';
$orderData['pickupInfo']['phone'] = $userInfo->getPhoneNumber();
$orderData['pickupInfo']['email'] = $userInfo->getEmail();
}
// Set pickup time
if ($order->getPickupTime() > 0) {
$pickupMinutes = $order->getPickupTime() ?? 20;
} else {
$pickupMinutes = 20;
}
$pickupTime = (clone $order->getUpdatedAt())->modify('+' . $pickupMinutes . ' minutes');
$orderData['pickupInfo']['pickupTime'] = $pickupTime->format('Y-m-d\TH:i:s.v\Z');
// Build items
$orderItems = json_decode($order->getOrderItemsJson(), true) ?? [];
$rewardsData = json_decode($order->getOrderRewardItems(), true) ?? [];
$sortIndex = 1;
// Process order items
foreach ($orderItems as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if ($foodItem) {
$internalId = Uuid::v4()->toRfc4122();
$parentId = $internalId;
$orderData['items'][] = [
'quantity' => $item['amount'],
'orderItemId' => (string)$foodItem->getId(),
'providerId' => 'e2e122e1-9481-65eb-8a0a-54079cb4211b',
'orderItemName' => $foodItem->getName(),
'relativeRowTotal' => [
'amount' => $foodItem->getPrice() * $item['amount'],
'currency' => 'EUR'
],
'internalId' => $internalId,
'singlePrice' => [
'amount' => $foodItem->getPrice(),
'currency' => 'EUR'
],
'orderId' => $order->getRemoteOrderId(),
'relativeQuantity' => $item['amount'],
'rowTotal' => [
'amount' => $foodItem->getPrice() * $item['amount'],
'currency' => 'EUR'
],
'sortIndex' => $sortIndex++,
'posItemId' => $foodItem->getPosId()
];
// Toppings
foreach ($item['toppings'] as $toppingData) {
$topping = $entityManager->getRepository(Toppings::class)->find($toppingData['toppingId']);
if ($topping) {
$toppingInternalId = Uuid::v4()->toRfc4122();
$orderData['items'][] = [
'quantity' => $item['amount'], // Multiply by main item amount
'singlePrice' => [
'amount' => $topping->getPrice(),
'currency' => 'EUR'
],
'orderId' => $order->getRemoteOrderId(),
'sortIndex' => $sortIndex++,
'parentId' => $parentId,
'rowTotal' => [
'amount' => $topping->getPrice() * $item['amount'],
'currency' => 'EUR'
],
'posItemId' => $topping->getPosId(),
'orderItemId' => (string)$topping->getId(),
'providerId' => 'e2e122e1-9481-65eb-8a0a-54079cb4211b',
'orderItemName' => $topping->getName(),
'relativeRowTotal' => [
'amount' => $topping->getPrice() * $item['amount'],
'currency' => 'EUR'
],
'internalId' => $toppingInternalId,
'relativeQuantity' => $toppingData['amount']
];
}
}
// Notes
if (!empty($item['note'])) {
$noteInternalId = Uuid::v4()->toRfc4122();
$orderData['items'][] = [
'quantity' => $item['amount'],
'singlePrice' => [
'amount' => 0,
'currency' => 'EUR'
],
'orderId' => $order->getRemoteOrderId(),
'sortIndex' => $sortIndex++,
'parentId' => $parentId,
'rowTotal' => [
'amount' => 0,
'currency' => 'EUR'
],
'orderItemId' => Uuid::v4()->toRfc4122(),
'isNote' => true,
'providerId' => 'e2e122e1-9481-65eb-8a0a-54079cb4211b',
'orderItemName' => $item['note'],
'relativeRowTotal' => [
'amount' => 0,
'currency' => 'EUR'
],
'internalId' => $noteInternalId,
'relativeQuantity' => 1
];
}
}
}
// Process rewards as items
foreach ($rewardsData as $rewardData) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardData['rewardId']);
if ($reward) {
$internalId = Uuid::v4()->toRfc4122();
$orderData['items'][] = [
'quantity' => 1,
'orderItemId' => 'reward_' . $reward->getId(),
'providerId' => 'e2e122e1-9481-65eb-8a0a-54079cb4211b',
'orderItemName' => 'REWARD: ' . $reward->getName(),
'relativeRowTotal' => [
'amount' => 0,
'currency' => 'EUR'
],
'internalId' => $internalId,
'singlePrice' => [
'amount' => 0,
'currency' => 'EUR'
],
'orderId' => $order->getRemoteOrderId(),
'relativeQuantity' => 1,
'rowTotal' => [
'amount' => 0,
'currency' => 'EUR'
],
'sortIndex' => $sortIndex++,
'posItemId' => 'reward_' . $reward->getId()
];
}
}
// Handle order status
$orderStatus = $order->getOrderStatus();
if ($orderStatus === 'dispatched') {
$orderData['status'] = 'acceptRequired';
$orderData['possibleActions'] = ['accept', 'reject'];
$orderData['modifyHistory'] = [
[
'status' => 'acceptRequired',
'updatedAt' => $order->getCreatedAt()->format('Y-m-d\TH:i:s.v\Z')
]
];
$orderData['possibleStateChanges'] = [];
} elseif ($orderStatus === 'sent') {
$orderData['status'] = 'receivedByProvider';
$orderData['possibleActions'] = [
'rejectedByPOS',
'fetchedByPOS',
'acceptedByPOS',
'preparing',
'ready',
'pickedUp',
'inDelivery',
'delivered'
];
$orderData['modifyHistory'] = [
[
'status' => 'acceptRequired',
'updatedAt' => $order->getCreatedAt()->format('Y-m-d\TH:i:s.v\Z')
],
[
'status' => 'receivedByProvider',
'updatedAt' => $order->getUpdatedAt()->format('Y-m-d\TH:i:s.v\Z')
]
];
$orderData['possibleStateChanges'] = [
['state' => 'rejectedByPOS', 'timeChange' => false],
['state' => 'fetchedByPOS', 'timeChange' => false],
['state' => 'acceptedByPOS', 'timeChange' => true],
['state' => 'preparing', 'timeChange' => true],
['state' => 'ready', 'timeChange' => true],
['state' => 'pickedUp', 'timeChange' => true],
['state' => 'inDelivery', 'timeChange' => true],
['state' => 'delivered', 'timeChange' => true]
];
} elseif ($orderStatus === 'rejected') {
$orderData['status'] = 'rejectedByPOS';
$orderData['possibleActions'] = [];
$orderData['modifyHistory'] = [
[
'status' => 'acceptRequired',
'updatedAt' => $order->getCreatedAt()->format('Y-m-d\TH:i:s.v\Z')
],
[
'status' => 'rejectedByPOS',
'updatedAt' => $order->getUpdatedAt()->format('Y-m-d\TH:i:s.v\Z')
]
];
$orderData['possibleStateChanges'] = [];
} else {
$orderData['status'] = 'unknown';
$orderData['possibleActions'] = [];
$orderData['modifyHistory'] = [];
$orderData['possibleStateChanges'] = [];
}
// Set 'id' to match Mergeport's format (order's UUID)
$orderData['id'] = $order->getRemoteOrderId();
return $this->json([
'status' => true,
'message' => 'Order status retrieved successfully',
'data' => $orderData
]);
} catch (\Throwable $e) {
return $this->json([
'status' => false,
'message' => 'Failed to retrieve order status: ' . $e->getMessage(),
'data' => new \stdClass()
]);
}
}
#[Route('/api/order/status-backup/{restaurantId}/{orderId}', name: 'api_order_status_backup', methods: ['GET'])]
public function getOrderStatusBackup(HttpClientInterface $httpClient, string $restaurantId, string $orderId): JsonResponse
{
try {
$restaurantRemoteId = $this->getRestaurantRemoteId($restaurantId);
if (!$restaurantRemoteId) {
return $this->json(['status' => false, 'message' => 'Restaurant ID Incorrect.']);
}
// $restaurant_remote_id = "33b73f97-1d10-4f41-9b76-fd9f61396951";
$response = $httpClient->request('GET', "https://ordering.mergeport.com/v4/hooks/main/e2e122e1-9481-65eb-8a0a-54079cb4211b/{$restaurantRemoteId}/orders/{$orderId}");
if ($response->getStatusCode() !== 200) {
return $this->json([
'status' => false,
'message' => 'Failed to retrieve order status',
'data' => new \stdClass()
]);
}
$responseData = $response->toArray();
$datetimeFields = [
'lastModifyDate',
'creationDate',
'modifyHistory' => ['updatedAt']
];
foreach ($datetimeFields as $key => $field) {
if (is_array($field)) {
if (isset($responseData[$key])) {
foreach ($responseData[$key] as &$history) {
if (isset($history[$field[0]])) {
$originalDateTime = new \DateTime($history[$field[0]], new \DateTimeZone('UTC'));
$originalDateTime->setTimezone(new \DateTimeZone('Europe/Vienna'));
$history[$field[0]] = $originalDateTime->format('Y-m-d\TH:i:s.v\Z');
}
}
}
} else {
if (isset($responseData[$field])) {
$originalDateTime = new \DateTime($responseData[$field], new \DateTimeZone('UTC'));
$originalDateTime->setTimezone(new \DateTimeZone('Europe/Vienna'));
$responseData[$field] = $originalDateTime->format('Y-m-d\TH:i:s.v\Z');
}
}
}
if (isset($responseData['pickupInfo']['pickupTime'])) {
$originalDateTime = new \DateTime($responseData['pickupInfo']['pickupTime'], new \DateTimeZone('UTC'));
$originalDateTime->setTimezone(new \DateTimeZone('Europe/Vienna'));
$responseData['pickupInfo']['pickupTime'] = $originalDateTime->format('Y-m-d\TH:i:s.v\Z');
}
return $this->json([
'status' => true,
'message' => 'Order status retrieved successfully',
'data' => $responseData
]);
} catch (\Throwable $e) {
return $this->json([
'status' => false,
'message' => 'Failed to retrieve order status: ' . $e->getMessage(),
'data' => new \stdClass()
]);
}
}
public function getRestaurantRemoteId($restaurant) {
// this is a key for test mode. if you uncomment this line, it will make a test order.
// return "33b73f97-1d10-4f41-9b76-fd9f61396951";
// return "test-cashit-12dev34";
if ($restaurant == 1) {
// this is for 1020 restaurant
return "141e28eb-ee4b-4473-b693-84cdbedc9126";
}
if ($restaurant == 2) {
// this is for 1050 restaurant
return "a0a268e7-0291-475a-8324-f5836ef8bfee";
}
if ($restaurant == 3) {
// this is for 1020 Hillerstrasse
return "815705da-b49a-499b-a461-6f1fcd0f11c8";
}
return false;
}
#[Route('/order/refund/{orderId}', name: 'api_refund_order', methods: ['POST'])]
public function refundOrderEndpoint(int $orderId, Request $request, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): JsonResponse
{
$authHeader = $request->headers->get('Authorization');
$jwt = $authHeader ? str_replace('Bearer ', '', $authHeader) : null;
if (!$jwt) {
return $this->json([
'status' => false,
'message' => 'Authorization token not found',
'data' => new \stdClass()
]);
}
$projectDir = $this->getParameter('kernel.project_dir');
$serviceAccountPath = $projectDir . '/config/firebase_service_account.json';
$factory = (new Factory)->withServiceAccount($serviceAccountPath);
$firebaseAuth = $factory->createAuth();
try {
$decodedToken = $firebaseAuth->verifyIdToken($jwt);
$currentUserId = $decodedToken->claims()->get('sub');
} catch (\Throwable $e) {
return $this->json([
'status' => false,
'message' => 'Invalid token: ' . $e->getMessage(),
'data' => new \stdClass()
]);
}
// Fetch order
$order = $entityManager->getRepository(Order::class)->find($orderId);
if (!$order) {
return $this->json([
'status' => false,
'message' => 'Order not found',
'data' => new \stdClass()
]);
}
if ($order->getOrderStatus() != "rejected") {
return $this->json([
'status' => false,
'message' => 'Order not rejected',
'data' => new \stdClass()
]);
}
if ($order->getOrderStatus() === 'refunded') {
return $this->json([
'status' => false,
'message' => 'Order already refunded',
'data' => new \stdClass()
]);
}
// Check if the current user is the owner of the order
if ($order->getUserUuid() !== $currentUserId) {
return $this->json([
'status' => false,
'message' => 'Unauthorized action',
'data' => new \stdClass()
]);
}
// Check order status on Mergeport
$restaurantRemoteId = $this->getRestaurantRemoteId($order->getRestaurantId());
$remoteOrderId = $order->getRemoteOrderId();
/*$response = $httpClient->request('GET', "https://ordering.mergeport.com/v4/hooks/main/e2e122e1-9481-65eb-8a0a-54079cb4211b/{$restaurantRemoteId}/orders/{$remoteOrderId}");
if ($response->getStatusCode() !== 200) {
return $this->json([
'status' => false,
'message' => 'Failed to verify order status with Mergeport',
'data' => new \stdClass()
]);
}
$responseData = $response->toArray();
$orderStatus = $responseData['status'] ?? null;
if ($orderStatus !== 'rejectedByPOS') {
return $this->json([
'status' => false,
'message' => 'Order not rejected by POS',
'data' => new \stdClass()
]);
}*/
// Process refund
$requestData = json_decode($request->getContent(), true);
$stripeTransactionId = $requestData['stripeTransactionId'] ?? null;
/* if (!$stripeTransactionId) {
return $this->json([
'status' => false,
'message' => 'Stripe transaction ID not provided',
'data' => new \stdClass()
]);
} */
// Refund wallet amount if used
$userInfo = $entityManager->getRepository(UserInfo::class)->findOneBy(['firebaseId' => $order->getUserUuid()]);
if (!$userInfo) {
return $this->json([
'status' => false,
'message' => 'User not found',
'data' => new \stdClass()
]);
}
$walletDeduction = $order->getWalletDeduct();
$usedRewardPoints = $order->getUsedReward();
$gainedRewardPoints = $order->getGainedReward();
$orderRestaurantId = $order->getRestaurantId();
if ($orderRestaurantId == 1) {
// 1020
$stripeSecretKey = "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";
// $stripeSecretKey = "sk_test_51OkOVYC5nPVM0E9wnplSNZBJdSNFRsmrPCyV9wE8EMlUQdWIGW0UeibzMDY83krhkjkDEt4O1ribK2I1EYNHPJsD00E225VPBn";
} else if ($orderRestaurantId == 3) {
// 1020 Hillerstrasse
$stripeSecretKey = "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";
//$stripeSecretKey = "sk_test_51OkO9hJyT34EfWu7DPRY56ZLie8S4koWNLP2boiKZj0hc3ce4inIYHufkqLUJOMH5siwycQkT2zs6MkdSKFNiV0f009XcDtdh4";
} else {
// 1050
$stripeSecretKey = "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";
//$stripeSecretKey = "sk_test_51OkO9hJyT34EfWu7DPRY56ZLie8S4koWNLP2boiKZj0hc3ce4inIYHufkqLUJOMH5siwycQkT2zs6MkdSKFNiV0f009XcDtdh4";
}
if ($walletDeduction > 0) {
$userInfo->setWalletAmount($userInfo->getWalletAmount() + $walletDeduction);
}
if ($gainedRewardPoints > 0) {
$userInfo->setRewardPoints($userInfo->getRewardPoints() - $gainedRewardPoints);
}
if ($usedRewardPoints > 0) {
$userInfo->setRewardPoints($userInfo->getRewardPoints() + $usedRewardPoints);
}
// Refund Stripe payment if applicable
/* if ($stripeTransactionId) {
try {
$refundResponse = $httpClient->request('POST', "https://api.stripe.com/v1/refunds", [
'auth_bearer' => $stripeSecretKey,
'body' => [
'charge' => $stripeTransactionId,
'amount' => $order->getTotalPrice(),
],
]);
$refundData = $refundResponse->toArray();
if ($refundResponse->getStatusCode() !== 200) {
return $this->json([
'status' => false,
'message' => 'Failed to process Stripe refund: ' . ($refundData['error']['message'] ?? 'Unknown error'),
'data' => new \stdClass()
]);
}
} catch (\Throwable $e) {
return $this->json([
'status' => false,
'message' => 'Stripe refund error: ' . $e->getMessage(),
'data' => new \stdClass()
]);
}
}*/
if ($stripeTransactionId) {
try {
\Stripe\Stripe::setApiKey($stripeSecretKey);
$chargedAmount = $order->getTotalPrice() - $order->getWalletDeduct();
$refund = \Stripe\Refund::create([
'payment_intent' => $stripeTransactionId,
'amount' => $chargedAmount,
'reason' => 'requested_by_customer',
]);
if (!$refund || !$refund->status || $refund->status !== 'succeeded') {
return $this->json([
'status' => false,
'message' => 'Failed to process Stripe refund: ' . ($refund->failure_reason ?? 'Unknown error'),
'data' => new \stdClass()
]);
}
} catch (\Stripe\Exception\ApiErrorException $e) {
return $this->json([
'status' => false,
'message' => 'Stripe refund error: ' . $e->getMessage(),
'data' => new \stdClass()
]);
}
}
// Update the order status to reflect the refund
$order->setOrderStatus('refunded');
$entityManager->persist($order);
$entityManager->persist($userInfo);
// Log the reversal in RewardsHistory if applicable
if ($usedRewardPoints > 0) {
$rewardsHistory = new RewardsHistory();
$rewardsHistory->setUserUuid($order->getUserUuid());
$rewardsHistory->setAmount($usedRewardPoints);
$rewardsHistory->setChangeType('refund');
$rewardsHistory->setTransactionDate(new \DateTime());
$rewardsHistory->setDescription('Reward points refunded for order cancellation');
$entityManager->persist($rewardsHistory);
}
if ($gainedRewardPoints > 0) {
$rewardsHistory = new RewardsHistory();
$rewardsHistory->setUserUuid($order->getUserUuid());
$rewardsHistory->setAmount($gainedRewardPoints);
$rewardsHistory->setChangeType('reversal');
$rewardsHistory->setTransactionDate(new \DateTime());
$rewardsHistory->setDescription('Reward points reversal for order cancellation');
$entityManager->persist($rewardsHistory);
}
$entityManager->flush();
$this->sendRefundEmail($order, $userInfo);
return $this->json([
'status' => true,
'message' => 'Refund processed successfully',
'data' => new \stdClass()
]);
}
private function sendOrderSuccessEmail(Order $order, UserInfo $userInfo): void
{
$orderDetails = [
'orderNumber' => $order->getId(),
'restaurantId' => $order->getRestaurantId(),
'orderItems' => json_decode($order->getOrderItemsNames(), true),
'totalPrice' => $order->getTotalPrice(),
'usedRewardPoints' => $order->getUsedReward(),
'gainedRewardPoints' => $order->getGainedReward(),
'walletDeduction' => $order->getWalletDeduct(),
'orderDate' => $order->getCreatedAt()->format('Y-m-d H:i:s'),
];
// SMTP configuration
$transport = new EsmtpTransport('w0194057.kasserver.com', 587);
$transport->setUsername('[email protected]');
$transport->setPassword('A6KUDzkzwDgdmXPiJaak');
$mailer = new Mailer($transport);
$htmlContent = '
<html>
<body>
<h2>Your Order Has Been Placed Successfully</h2>
Thank you for your order! Here are the details:
<ul>
<li>Order Number: #' . $orderDetails['orderNumber'] . '</li>
<li>Total Price: ' . $orderDetails['totalPrice']/100 . ' EUR</li>
<li>Used Reward Points: ' . $orderDetails['usedRewardPoints'] . '</li>
<li>Gained Reward Points: ' . $orderDetails['gainedRewardPoints'] . '</li>
<li>Wallet Deduction: ' . $orderDetails['walletDeduction']/100 . ' EUR</li>
<li>Order Date: ' . date("d.m.Y H:i:s", @strtotime($orderDetails['orderDate'])) . '</li>
</ul>
Order Items:
<ul>';
foreach ($orderDetails['orderItems'] as $item) {
$itemQuantity = 1;
if (isset($item['quantity'])) {
$itemQuantity = $item['quantity'];
}
$itemTotalPrice = "";
if (isset($item['totalPrice'])) {
$itemTotalPrice = $item['totalPrice']/100;
}
$htmlContent .= '<li>' . $item['name'] . ' x ' . $itemQuantity . ' - ' . $itemTotalPrice . ' EUR</li>';
}
$htmlContent .= '
</ul>
We hope you enjoy your meal!
</body>
</html>';
// Send email
$email = (new Email())
->from(new Address('[email protected]', 'Randale'))
->to($userInfo->getEmail())
->subject('Pizza Randale: Your Order Has Been Placed Successfully')
->html($htmlContent);
$mailer->send($email);
}
private function sendRefundEmail(Order $order, UserInfo $userInfo): void
{
$refundDetails = [
'orderNumber' => $order->getId(),
'totalRefunded' => $order->getTotalPrice(),
'walletRefund' => $order->getWalletDeduct(),
'stripeRefund' => $order->getTotalPrice() - $order->getWalletDeduct(),
'refundDate' => (new \DateTime())->format('Y-m-d H:i:s'),
];
// SMTP configuration
$transport = new EsmtpTransport('w0194057.kasserver.com', 587);
$transport->setUsername('[email protected]');
$transport->setPassword('tsFN5ckDFKTNkZeNtp9C');
$mailer = new Mailer($transport);
$htmlContent = '
<html>
<body>
<h2>Your Order Has Been Refunded</h2>
Your order has been refunded successfully. Here are the details:
<ul>
<li>Order Number: ' . $refundDetails['orderNumber'] . '</li>
<li>Total Refunded: ' . $refundDetails['totalRefunded']/100 . ' EUR</li>
<li>Wallet Refund: ' . $refundDetails['walletRefund']/100 . ' EUR</li>
<li>Stripe Refund: ' . $refundDetails['stripeRefund']/100 . ' EUR</li>
<li>Refund Date: ' . date("d.m.Y H:i:s", @strtotime($refundDetails['refundDate'])) . '</li>
</ul>
If you have any questions, feel free to contact our support team.
</body>
</html>';
// Send email
$email = (new Email())
->from(new Address('[email protected]', 'Randale'))
->to($userInfo->getEmail())
->subject('Your Order Has Been Refunded')
->html($htmlContent);
$mailer->send($email);
}
#[Route('/api/orders/list/{restaurantId}', name: 'api_orders_list', methods: ['GET'])]
public function listOrders(EntityManagerInterface $entityManager, int $restaurantId): JsonResponse
{
$todayStart = (new \DateTime())->setTime(0, 0, 0);
$todayEnd = (new \DateTime())->setTime(23, 59, 59);
$dispatchedOrdersQuery = $entityManager->getRepository(Order::class)->createQueryBuilder('o')
->where('o.order_status = :status')
->andWhere('o.restaurant_id = :restaurantId')
->andWhere('o.created_at BETWEEN :todayStart AND :todayEnd')
->setParameter('status', 'dispatched')
->setParameter('restaurantId', $restaurantId)
->setParameter('todayStart', $todayStart)
->setParameter('todayEnd', $todayEnd)
->orderBy('o.id', 'DESC')
->getQuery();
$dispatchedOrders = $dispatchedOrdersQuery->getResult();
$orderHistoryQuery = $entityManager->getRepository(Order::class)->createQueryBuilder('o')
->where('o.order_status IN (:statuses)')
->andWhere('o.restaurant_id = :restaurantId')
->andWhere('o.created_at BETWEEN :todayStart AND :todayEnd')
->setParameter('statuses', ['sent', 'rejected'])
->setParameter('restaurantId', $restaurantId)
->setParameter('todayStart', $todayStart)
->setParameter('todayEnd', $todayEnd)
->orderBy('o.id', 'DESC')
->getQuery();
$orderHistory = $orderHistoryQuery->getResult();
$orders = array_map(function ($order) use ($entityManager) {
$items = json_decode($order->getOrderItemsJson(), true);
$orderItems = [];
foreach ($items as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if (!$foodItem) {
continue;
}
$toppings = array_map(function ($topping) use ($entityManager, $item) {
$toppingEntity = $entityManager->getRepository(Toppings::class)->find($topping['toppingId']);
if ($toppingEntity) {
return [
'name' => $toppingEntity->getName(),
'amount' => $topping['amount'],
'unitPrice' => $toppingEntity->getPrice() / 100,
'totalPrice' => ($toppingEntity->getPrice() * $topping['amount'] * $item['amount']) / 100
];
}
return null;
}, $item['toppings'] ?? []);
$toppings = array_filter($toppings);
$orderItems[] = [
'name' => $foodItem->getName(),
'amount' => $item['amount'],
'unitPrice' => $foodItem->getPrice() / 100,
'totalPrice' => ($foodItem->getPrice() * $item['amount']) / 100,
'toppings' => $toppings
];
}
$rewardItems = [];
$rewardData = json_decode($order->getOrderRewardItems(), true);
if (!empty($rewardData)) {
foreach ($rewardData as $rewardItem) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardItem['rewardId']);
if ($reward) {
$rewardItems[] = [
'name' => $reward->getName(),
'points' => $reward->getPrice(),
];
}
}
}
return [
'id' => $order->getId(),
'status' => $order->getOrderStatus(),
'restaurantId' => $order->getRestaurantId(),
'time' => $order->getCreatedAt()->format('Y-m-d\TH:i:s'),
'total_price' => $order->getTotalPrice() / 100,
'walletDeduction' => $order->getWalletDeduct() / 100,
'usedRewardPoints' => $order->getUsedReward(),
'gainedRewardPoints' => $order->getGainedReward(),
'orderItems' => $orderItems,
'rewards' => $rewardItems
];
}, $dispatchedOrders);
$history = array_map(function ($order) use ($entityManager) {
$items = json_decode($order->getOrderItemsJson(), true);
$orderItems = [];
foreach ($items as $item) {
$foodItem = $entityManager->getRepository(FoodItem::class)->find($item['itemId']);
if (!$foodItem) {
continue;
}
$toppings = array_map(function ($topping) use ($entityManager, $item) {
$toppingEntity = $entityManager->getRepository(Toppings::class)->find($topping['toppingId']);
if ($toppingEntity) {
return [
'name' => $toppingEntity->getName(),
'amount' => $topping['amount'],
'unitPrice' => $toppingEntity->getPrice() / 100,
'totalPrice' => ($toppingEntity->getPrice() * $topping['amount'] * $item['amount']) / 100
];
}
return null;
}, $item['toppings'] ?? []);
$toppings = array_filter($toppings);
$orderItems[] = [
'name' => $foodItem->getName(),
'amount' => $item['amount'],
'unitPrice' => $foodItem->getPrice() / 100,
'totalPrice' => ($foodItem->getPrice() * $item['amount']) / 100,
'toppings' => $toppings
];
}
$rewardItems = [];
$rewardData = json_decode($order->getOrderRewardItems(), true);
if (!empty($rewardData)) {
foreach ($rewardData as $rewardItem) {
$reward = $entityManager->getRepository(Rewards::class)->find($rewardItem['rewardId']);
if ($reward) {
$rewardItems[] = [
'name' => $reward->getName(),
'points' => $reward->getPrice(),
];
}
}
}
return [
'id' => $order->getId(),
'status' => $order->getOrderStatus(),
'restaurantId' => $order->getRestaurantId(),
'time' => $order->getCreatedAt()->format('Y-m-d\TH:i:s'),
'total_price' => $order->getTotalPrice() / 100,
'walletDeduction' => $order->getWalletDeduct() / 100,
'usedRewardPoints' => $order->getUsedReward(),
'gainedRewardPoints' => $order->getGainedReward(),
'orderItems' => $orderItems,
'rewards' => $rewardItems
];
}, $orderHistory);
return $this->json(['orders' => $orders, 'history' => $history]);
}
#[Route('/admin/approve-order/{orderId}/{restaurantId}', name: 'admin_approve_order', methods: ['POST'])]
public function approveOrder(int $orderId, int $restaurantId, Request $request, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): JsonResponse
{
$order = $entityManager->getRepository(Order::class)->find($orderId);
if (!$order || $order->getOrderStatus() !== 'dispatched') {
return $this->json(['status' => false, 'message' => 'Order not found or already processed']);
}
$data = json_decode($request->getContent(), true);
$pickupTime = $data['pickupTime'] ?? 20;
$order->setPickupTime($pickupTime);
$entityManager->persist($order);
$entityManager->flush();
try {
$this->dispatchOrderMergeport($order, $restaurantId, $pickupTime, $entityManager, $httpClient);
} catch (\Exception $e) {
return $this->json(['status' => false, 'message' => $e->getMessage()]);
}
return $this->json(['status' => true, 'message' => 'Order accepted and forwarded to Mergeport']);
}
#[Route('/admin/reject-order/{orderId}', name: 'admin_reject_order', methods: ['POST'])]
public function rejectOrder(int $orderId, EntityManagerInterface $entityManager): JsonResponse
{
$order = $entityManager->getRepository(Order::class)->find($orderId);
if (!$order || $order->getOrderStatus() !== 'dispatched') {
return $this->json(['status' => false, 'message' => 'Order not found or already processed']);
}
$order->setOrderStatus('rejected');
$order->setUpdatedAt(new \DateTime());
$entityManager->persist($order);
$entityManager->flush();
return $this->json(['status' => true, 'message' => 'Order rejected']);
}
#[Route('/reject-old-orders', name: 'reject_old_orders', methods: ['GET'])]
public function rejectOldOrders(EntityManagerInterface $entityManager): JsonResponse
{
return $this->json(['status' => false, 'message' => 'feature disabled']);
/*
$tenMinutesAgo = new \DateTime('-10 minutes');
$orders = $entityManager->getRepository(Order::class)
->createQueryBuilder('o')
->where('o.order_status = :status')
->andWhere('o.created_at <= :time')
->setParameter('status', 'dispatched')
->setParameter('time', $tenMinutesAgo)
->getQuery()
->getResult();
$rejectedCount = 0;
foreach ($orders as $order) {
$order->setOrderStatus('rejected');
$order->setUpdatedAt(new \DateTime());
$entityManager->persist($order);
$rejectedCount++;
}
$entityManager->flush();
return $this->json([
'status' => true,
'message' => "$rejectedCount orders automatically rejected"
]);*/
}
}

src/Controller/OrderController.php line 2079