src/Controller/OrderController.php line 716

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Customer;
  6. use App\Entity\Office;
  7. use App\Entity\Order;
  8. use App\Entity\OrderItem;
  9. use App\Entity\Product;
  10. use App\Entity\User;
  11. use App\Repository\Customer as CustomerRepository;
  12. use App\Repository\Order as OrderRepository;
  13. use App\Service\TempFileUploader;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  17. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
  22. use Symfony\Component\HttpKernel\KernelInterface;
  23. use Symfony\Component\Routing\Annotation\Route;
  24. use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
  25. use Symfony\Component\Serializer\SerializerInterface;
  26. use Symfony\Contracts\Translation\TranslatorInterface;
  28. class OrderController extends AbstractController
  29. {
  30.     #[
  31.         Route(
  32.             name: 'api_order_sums',
  33.             path: '/api/orders-sums',
  34.             methods: ['GET'],
  35.             defaults: [
  36.                 '_api_resource_class' => Order::class,
  37.                 '_api_collection_operation_name' => 'getSums',
  38.             ]
  39.         )
  40.     ]
  41.     public function sumsAction(?array $data): ?array
  42.     {
  43.         return $data;
  44.     }
  46.     #[
  47.         Route(
  48.             name: 'api_order_post',
  49.             path: '/api/orders',
  50.             methods: ['POST'],
  51.             defaults: [
  52.                 '_api_resource_class' => Order::class,
  53.                 '_api_collection_operation_name' => 'post',
  54.             ]
  55.         )
  56.     ]
  57.     public function postAction(Order $data, LoggerInterface $logger, TranslatorInterface $translator): Order
  58.     {
  59.         $logger->info($translator->trans('New order saved.', [], 'logger'), ['data' => $data]);
  61.         return $data;
  62.     }
  64.     #[
  65.         Route(
  66.             name: 'api_order_put',
  67.             path: '/api/orders/{id}',
  68.             requirements: ['id' => "\d+"],
  69.             methods: ['PUT'],
  70.             defaults: [
  71.                 '_api_resource_class' => Order::class,
  72.                 '_api_item_operation_name' => 'put',
  73.             ]
  74.         )
  75.     ]
  76.     public function putAction(Order $data, LoggerInterface $logger, TranslatorInterface $translator): Order
  77.     {
  78.         $logger->info($translator->trans('Order updated.', [], 'logger'), ['data' => $data]);
  80.         return $data;
  81.     }
  83.     #[
  84.         Route(
  85.             name: 'api_order_delete',
  86.             path: '/api/orders/{id}',
  87.             requirements: ['id' => "\d+"],
  88.             methods: ['DELETE'],
  89.             defaults: [
  90.                 '_api_resource_class' => Order::class,
  91.                 '_api_item_operation_name' => 'delete',
  92.             ]
  93.         )
  94.     ]
  95.     public function deleteAction(Order $data, LoggerInterface $logger, TranslatorInterface $translator): void
  96.     {
  97.         $logger->info($translator->trans('Order deleted', [], 'logger'), ['data' => $data]);
  98.     }
  100.     #[
  101.         Route(
  102.             name: 'order_import',
  103.             path: '/api-helper/orders/import',
  104.             methods: ['POST']
  105.         )
  106.     ]
  107.     public function importAction(
  108.         Request $request,
  109.         TempFileUploader $uploader
  110.     ): JsonResponse {
  111.         $file = $request->files->get('files');
  113.         $workFile = $uploader->getTargetDirectory().'/'.$uploader->upload($file);
  115.         file_put_contents($workFile, $this->convert(file_get_contents($workFile)));
  117.         $cols = [];
  118.         $rows = [];
  120.         if (false !== ($handle = fopen($workFile, 'r'))) {
  121.             $iter = 0;
  123.             while (false !== ($row = fgetcsv($handle, 1000, ';'))) {
  124.                 if (0 === $iter) {
  125.                     $cols = array_flip($row);
  126.                 } else {
  127.                     $rows[] = [
  128.                         'invoiceId' => preg_replace("/\s/i", '', $row[$cols['SZLASORSZ']]),
  129.                         'invoiceType' => $row[$cols['SZTNEV']],
  130.                         'customerName' => $row[$cols['PARTNEV']],
  131.                         'invoiceDate' => str_replace('.', '-', $row[$cols['SZLADATUM']]),
  132.                         'fulfillmentDeadline' => str_replace('.', '-', $row[$cols['TELJDATUM']]),
  133.                         'paymentDeadline' => str_replace('.', '-', $row[$cols['FIZHDATUM']]),
  134.                         'paymentMethodName' => $row[$cols['FMNEV']],
  135.                         'paymentMethodId' => intval($row[$cols['FMAZON']]),
  136.                         'net' => floatval($row[$cols['SUMNETTO']]),
  137.                         'tax' => floatval($row[$cols['SUMAFA']]),
  138.                         'gross' => floatval($row[$cols['SUMBRUTTO']]),
  139.                         'currency' => $row[$cols['DVZNEM']],
  140.                         'invoiceBookId' => intval($row[$cols['SZTAZON']]),
  141.                         'originalInvoiceId' => preg_replace("/\s/i", '', $row[$cols['ESZLASORSZ']]),
  142.                         'notice' => $row[$cols['MEGJEGYZES']],
  143.                         'cashInvoice' => 'IGAZ' === $row[$cols['KPSZAMLA']],
  144.                         'partazon' => intval($row[$cols['PARTAZON']]),
  145.                     ];
  146.                 }
  148.                 ++$iter;
  149.             }
  151.             file_put_contents($uploader->getTargetDirectory().'/order-rows-tmp.json', json_encode($rows));
  152.         }
  154.         $uploader->unlink();
  156.         return $this->json([
  157.             'success' => true,
  158.             'count' => count($rows),
  159.             'remaining' => count($rows),
  160.         ]);
  161.     }
  163.     #[
  164.         Route(
  165.             name: 'order_import_iteration',
  166.             path: '/api-helper/orders/import-iteration',
  167.             methods: ['GET']
  168.         )
  169.     ]
  170.     public function importIterationAction(
  171.         Request $request,
  172.         TempFileUploader $uploader,
  173.         EntityManagerInterface $em
  174.     ): JsonResponse {
  175.         $ordersTmpFile = $uploader->getTargetDirectory().'/order-rows-tmp.json';
  176.         $rows = json_decode(file_get_contents($ordersTmpFile), true);
  177.         $batch = 60;
  178.         $iter = 0;
  179.         $orderRepo = $em->getRepository(Order::class);
  180.         $customerRepo = $em->getRepository(Customer::class);
  181.         $userRepo = $em->getRepository(User::class);
  183.         $selectedOfficeid = $request->get('office');
  184.         $defaultOffice = $em
  185.             ->getRepository(Office::class)
  186.             ->find($selectedOfficeid);
  188.         /** @var User $authUser */
  189.         if (!$defaultOffice && ($authUser = $this->getUser())) {
  190.             $defaultOffice = $authUser->getOffice();
  191.         }
  193.         while ($batch > 0 && !empty($rows)) {
  194.             ++$iter;
  195.             --$batch;
  197.             $row = array_shift($rows);
  199.             $user = false;
  201.             $userMatches = [];
  202.             if (1 === preg_match('~^([0-9]+)([H|T|B|I])\s([\-0-9]+)~', $row['notice'], $userMatches)) {
  203.                 $user = $userRepo->find($userMatches[1]);
  204.             }
  206.             $office = $defaultOffice;
  208.             if ($user) {
  209.                 $office = $user->getOffice();
  210.             }
  212.             $finder = ['office' => $office->getId()];
  214.             $order = false;
  216.             if ($row['invoiceId']) {
  217.                 // we can find exact order
  218.                 $order = $orderRepo->findOneBy($finder + ['invoiceId' => $row['invoiceId']]);
  220.                 if ($order) {
  221.                     // order exists, skip
  222.                     continue;
  223.                 }
  224.             }
  226.             $order = new Order();
  228.             if ($user) {
  229.                 $order->setUser($user);
  230.             }
  232.             if (!empty($userMatches)) {
  233.                 $order->setSaleType($userMatches[2]);
  234.             }
  236.             /** @var Customer $customer */
  237.             $customer = false;
  239.             if ($row['partazon']) {
  240.                 // we have partazon, maybe we can find exact customer
  241.                 $customer = $customerRepo->findOneBy($finder + ['partazon' => $row['partazon']]);
  242.             }
  244.             if (!isset($customer) || !$customer) {
  245.                 // try to find by name
  246.                 $customer = $customerRepo->findOneBy($finder + ['name' => $row['customerName']]);
  247.             }
  249.             if ($customer) {
  250.                 $order->setCustomer($customer);
  252.                 if (isset($userMatches[3])) {
  253.                     $customer->setLoyaltyPoints($customer->getLoyaltyPoints() + intval($userMatches[3]));
  255.                     $em->persist($customer);
  256.                 }
  257.             }
  259.             if (!empty($row['originalInvoiceId'])) {
  260.                 $order->setOriginalInvoiceId($row['originalInvoiceId']); // ESZLASORSZ
  262.                 $qb = $em->createQueryBuilder();
  264.                 $query = $qb->select('o')
  265.                             ->from(Order::class, 'o')
  266.                             ->where(
  267.                                 $qb->expr()->andX(
  268.                                     $qb->expr()->eq('o.office', $office->getId()),
  269.                                     $qb->expr()->like('o.invoiceId', $qb->expr()->literal($row['originalInvoiceId']))
  270.                                 )
  271.                             )
  272.                             ->getQuery();
  274.                 $originalOrder = $query->getSingleResult();
  276.                 if ($originalOrder) {
  277.                     $order->setOriginalOrder($originalOrder);
  278.                 }
  279.             }
  281.             $order
  282.                 ->setOffice($office)
  283.                 ->setInvoiceId($row['invoiceId']) // SZLASORSZ
  284.                 ->setInvoiceType($row['invoiceType']) // SZTNEV
  285.                 ->setCustomerName($row['customerName']) // PARTNEV
  286.                 ->setInvoiceDate(new \DateTime($row['invoiceDate'])) // SZLADATUM
  287.                 ->setFulfillmentDeadline(new \DateTime($row['fulfillmentDeadline'])) // TELJDATUM
  288.                 ->setPaymentDeadline(new \DateTime($row['paymentDeadline'])) // FIZHDATUM
  289.                 ->setPaymentMethodName($row['paymentMethodName']) // FMNEV
  290.                 ->setPaymentMethodId($row['paymentMethodId']) // FMAZON
  291.                 ->setNet($row['net']) // SUMNETTO
  292.                 ->setTax($row['tax']) // SUMAFA
  293.                 ->setGross($row['gross']) // SUMBRUTTO
  294.                 ->setCurrency($row['currency']) // DVZNEM
  295.                 ->setInvoiceBookId($row['invoiceBookId']) // SZTAZON
  296.                 ->setNotice($row['notice']) // MEGJEGYZES
  297.                 ->setCashInvoice($row['cashInvoice']) // KPSZAMLA
  298.             ;
  300.             $em->persist($order);
  301.             $em->flush();
  302.         }
  304.         if (!empty($rows)) {
  305.             file_put_contents($ordersTmpFile, json_encode($rows));
  306.         } else {
  307.             unlink($ordersTmpFile);
  308.         }
  310.         return $this->json([
  311.             'success' => true,
  312.             'processed' => $iter,
  313.             'remaining' => count($rows),
  314.         ]);
  315.     }
  317.     #[
  318.         Route(
  319.             name: 'order_import_all',
  320.             path: '/api-helper/orders/import-all',
  321.             methods: ['POST']
  322.         )
  323.     ]
  324.     public function importAllAction(
  325.         Request $request,
  326.         TempFileUploader $uploader
  327.     ): JsonResponse {
  328.         $files = $request->files->get('files');
  330.         $workFileNames = $uploader->upload($files);
  332.         $ordersFile = '';
  333.         $itemsFile = '';
  335.         foreach ($workFileNames as $fileName) {
  336.             $workFile = $uploader->getTargetDirectory().'/'.$fileName;
  338.             file_put_contents($workFile, $this->convert(file_get_contents($workFile)));
  340.             if (false !== ($handle = fopen($workFile, 'r'))) {
  341.                 if (false !== ($row = fgetcsv($handle, 1000, ';'))) {
  342.                     $cols = array_flip($row);
  344.                     if (isset($cols['CIKKAZON'])) {
  345.                         $itemsFile = $workFile;
  346.                     } else {
  347.                         $ordersFile = $workFile;
  348.                     }
  349.                 }
  351.                 fclose($handle);
  352.             }
  353.         }
  355.         $cols = [];
  356.         $rows = [];
  358.         if (false !== ($handle = fopen($ordersFile, 'r'))) {
  359.             $iter = 0;
  361.             while (false !== ($row = fgetcsv($handle, 1000, ';'))) {
  362.                 if (0 === $iter) {
  363.                     $cols = array_flip($row);
  364.                 } else {
  365.                     $rows[preg_replace("/\s/i", '', $row[$cols['SZLASORSZ']])] = [
  366.                         'invoiceId' => preg_replace("/\s/i", '', $row[$cols['SZLASORSZ']]),
  367.                         'invoiceType' => $row[$cols['SZTNEV']],
  368.                         'customerName' => $row[$cols['PARTNEV']],
  369.                         'invoiceDate' => str_replace('.', '-', $row[$cols['SZLADATUM']]),
  370.                         'fulfillmentDeadline' => str_replace('.', '-', $row[$cols['TELJDATUM']]),
  371.                         'paymentDeadline' => str_replace('.', '-', $row[$cols['FIZHDATUM']]),
  372.                         'paymentMethodName' => $row[$cols['FMNEV']],
  373.                         'paymentMethodId' => intval($row[$cols['FMAZON']]),
  374.                         'net' => floatval($row[$cols['SUMNETTO']]),
  375.                         'tax' => floatval($row[$cols['SUMAFA']]),
  376.                         'gross' => floatval($row[$cols['SUMBRUTTO']]),
  377.                         'currency' => $row[$cols['DVZNEM']],
  378.                         'invoiceBookId' => intval($row[$cols['SZTAZON']]),
  379.                         'originalInvoiceId' => preg_replace("/\s/i", '', $row[$cols['ESZLASORSZ']]),
  380.                         'notice' => $row[$cols['MEGJEGYZES']],
  381.                         'cashInvoice' => 'IGAZ' === $row[$cols['KPSZAMLA']],
  382.                         'partazon' => intval($row[$cols['PARTAZON']]),
  383.                     ];
  384.                 }
  386.                 ++$iter;
  387.             }
  389.             fclose($handle);
  390.         }
  392.         if (!empty($rows) && false !== ($handle = fopen($itemsFile, 'r'))) {
  393.             $iter = 0;
  395.             while (false !== ($row = fgetcsv($handle, 1000, ';'))) {
  396.                 if (0 === $iter) {
  397.                     $cols = array_flip($row);
  398.                 } else {
  399.                     $invoiceId = preg_replace("/\s/i", '', $row[$cols['SZLASORSZ']]);
  401.                     if (isset($rows[$invoiceId])) {
  402.                         if (!isset($rows[$invoiceId]['items'])) {
  403.                             $rows[$invoiceId]['items'] = [];
  404.                         }
  406.                         $rows[$invoiceId]['items'][] = [
  407.                             'sku' => $row[$cols['SZTETCSZAM']],
  408.                             'cikkazon' => $row[$cols['CIKKAZON']],
  409.                             'name' => $row[$cols['SZTETNEV']],
  410.                             'quantity' => intval($row[$cols['MENNY']]),
  411.                             'unit' => $row[$cols['MEEGYSEG']],
  412.                             'unitPrice' => $row[$cols['EGYSEGAR']],
  413.                             'price' => intval($row[$cols['NEAR']]),
  414.                             'grossPrice' => intval($row[$cols['BRAR']]),
  415.                             'currency' => $row[$cols['DVZNEM']],
  416.                             'taxRate' => intval($row[$cols['AFASZLK']]),
  417.                             'orderItemId' => intval($row[$cols['SZTETAZON']]),
  418.                         ];
  419.                     }
  420.                 }
  422.                 ++$iter;
  423.             }
  424.         }
  426.         if (!empty($rows)) {
  427.             file_put_contents($uploader->getTargetDirectory().'/order-rows-tmp.json', json_encode($rows));
  428.         }
  430.         $uploader->unlink();
  432.         return $this->json([
  433.             'success' => true,
  434.             'count' => count($rows),
  435.             'remaining' => count($rows),
  436.         ]);
  437.     }
  439.     #[
  440.         Route(
  441.             name: 'order_import_all_iteration',
  442.             path: '/api-helper/orders/import-all-iteration',
  443.             methods: ['GET']
  444.         )
  445.     ]
  446.     public function importAllIterationAction(
  447.         Request $request,
  448.         TempFileUploader $uploader,
  449.         EntityManagerInterface $em
  450.     ): JsonResponse {
  451.         $ordersTmpFile = $uploader->getTargetDirectory().'/order-rows-tmp.json';
  452.         $rows = json_decode(file_get_contents($ordersTmpFile), true);
  453.         $batch = count($rows) < 20 ? count($rows) : 20;
  454.         $iter = 0;
  455.         $orderRepo = $em->getRepository(Order::class);
  456.         /** @var CustomerRepository $customerRepo */
  457.         $customerRepo = $em->getRepository(Customer::class);
  458.         $userRepo = $em->getRepository(User::class);
  459.         $orderItemRepo = $em->getRepository(OrderItem::class);
  460.         $productRepo = $em->getRepository(Product::class);
  462.         $selectedOfficeid = $request->get('office');
  463.         $defaultOffice = $em
  464.             ->getRepository(Office::class)
  465.             ->find($selectedOfficeid);
  467.         /** @var User $authUser */
  468.         if (!$defaultOffice && ($authUser = $this->getUser())) {
  469.             $defaultOffice = $authUser->getOffice();
  470.         }
  472.         $missingCustomers = [];
  474.         while ($batch > 0 && !empty($rows)) {
  475.             ++$iter;
  476.             --$batch;
  478.             $row = array_shift($rows);
  480.             $user = false;
  482.             $userMatches = [];
  483.             if (1 === preg_match('~([0-9]+)[\s]*([H|T|B|I])[\s]*([\-0-9]+)?~', $row['notice'], $userMatches)) {
  484.                 $user = $userRepo->find(intval($userMatches[1]));
  485.             }
  487.             $office = $defaultOffice;
  489.             if ($user) {
  490.                 $office = $user->getOffice() ?? $defaultOffice;
  491.             }
  493.             $finder = ['office' => $office->getId()];
  495.             $order = false;
  497.             if ($row['invoiceId']) {
  498.                 // we can find exact order
  499.                 $order = $orderRepo->findOneBy($finder + ['invoiceId' => $row['invoiceId']]);
  501.                 if ($order) {
  502.                     // order exists, skip
  503.                     continue;
  504.                 }
  505.             }
  507.             $order = new Order();
  509.             if ($user) {
  510.                 $order->setUser($user);
  511.             }
  513.             if (!empty($userMatches)) {
  514.                 $order->setSaleType($userMatches[2]);
  515.             }
  517.             $customer = false;
  519.             if ($row['partazon']) {
  520.                 // we have partazon, maybe we can find exact customer
  521.                 $customer = $customerRepo->findOneBy($finder + ['partazon' => $row['partazon']]);
  522.             }
  524.             if (!$customer && 1 !== $office->getId()) {
  525.                 // if not in office #1, look for customer in all office
  526.                 $customer = $customerRepo->findNotInFirstOffice($row['partazon']);
  527.             }
  529.             // if (!isset($customer) || !$customer) {
  530.             //     // try to find by name
  531.             //     $customer = $customerRepo->findOneBy($finder + ['name' => $row['customerName']]);
  532.             // }
  534.             // if (!$customer && $office->getId() > 2) {
  535.             //     // try to small offices' customers in office with id 2
  536.             //     $customer = $customerRepo->findOneBy(['office' => 2, 'partazon' => $row['partazon']]);
  538.             //     if (!$customer) {
  539.             //         // try to find by name
  540.             //         $customer = $customerRepo->findOneBy(['office' => 2, 'name' => $row['customerName']]);
  541.             //     }
  542.             // }
  544.             if (!$customer) {
  545.                 // if there's no customer, who is ordered? :)
  547.                 $missingCustomers[] = [
  548.                     'invoiceId' => $row['invoiceId'],
  549.                     'partazon' => $row['partazon'] ?? '',
  550.                     'name' => $row['customerName'],
  551.                 ];
  553.                 continue;
  554.             }
  556.             if (isset($userMatches[3])) {
  557.                 $customer->setLoyaltyPoints($customer->getLoyaltyPoints() + intval($userMatches[3]));
  558.                 $em->persist($customer);
  559.             }
  561.             if ($customer->getOffice()->getId() !== $office->getId()) {
  562.                 $customer->setOffice($office);
  563.                 $em->persist($customer);
  564.             }
  566.             if ($user && $customer) {
  567.                 $customer->setUser($user);
  568.                 $em->persist($customer);
  569.             }
  571.             if ($customer) {
  572.                 $order->setCustomer($customer);
  573.             }
  575.             if (!empty($row['originalInvoiceId'])) {
  576.                 $order->setOriginalInvoiceId($row['originalInvoiceId']); // ESZLASORSZ
  578.                 $qb = $em->createQueryBuilder();
  580.                 $query = $qb->select('o')
  581.                             ->from(Order::class, 'o')
  582.                             ->where(
  583.                                 $qb->expr()->andX(
  584.                                     $qb->expr()->eq('o.office', $office->getId()),
  585.                                     $qb->expr()->like('o.invoiceId', $qb->expr()->literal($row['originalInvoiceId']))
  586.                                 )
  587.                             )
  588.                             ->getQuery();
  590.                 $originalOrder = $query->getOneOrNullResult();
  592.                 if ($originalOrder) {
  593.                     $order->setOriginalOrder($originalOrder);
  594.                 }
  595.             }
  597.             $order
  598.                 ->setOffice($office)
  599.                 ->setInvoiceId($row['invoiceId']) // SZLASORSZ
  600.                 ->setInvoiceType($row['invoiceType']) // SZTNEV
  601.                 ->setCustomerName($row['customerName']) // PARTNEV
  602.                 ->setInvoiceDate(new \DateTime($row['invoiceDate'])) // SZLADATUM
  603.                 ->setFulfillmentDeadline(new \DateTime($row['fulfillmentDeadline'])) // TELJDATUM
  604.                 ->setPaymentDeadline(new \DateTime($row['paymentDeadline'])) // FIZHDATUM
  605.                 ->setPaymentMethodName($row['paymentMethodName']) // FMNEV
  606.                 ->setPaymentMethodId($row['paymentMethodId']) // FMAZON
  607.                 ->setNet($row['net']) // SUMNETTO
  608.                 ->setTax($row['tax']) // SUMAFA
  609.                 ->setGross($row['gross']) // SUMBRUTTO
  610.                 ->setCurrency($row['currency']) // DVZNEM
  611.                 ->setInvoiceBookId($row['invoiceBookId']) // SZTAZON
  612.                 ->setNotice($row['notice']) // MEGJEGYZES
  613.                 ->setCashInvoice($row['cashInvoice']) // KPSZAMLA
  614.             ;
  616.             $em->persist($order);
  618.             // ITEMS ITERATION
  620.             $loyaltyPoints = 0;
  622.             foreach ($row['items'] as $item) {
  623.                 $orderItem = $orderItemRepo->findOneBy([
  624.                     'orderItemId' => $item['orderItemId'],
  625.                     'order' => $order,
  626.                 ]);
  628.                 if ($orderItem) {
  629.                     // item already processed
  630.                     continue;
  631.                 }
  633.                 $orderItem = new OrderItem();
  635.                 $orderItem
  636.                     ->setOrder($order)
  637.                     ->setSku($item['sku'])
  638.                     ->setCikkazon($item['cikkazon'])
  639.                     ->setName($item['name'])
  640.                     ->setQuantity($item['quantity'])
  641.                     ->setUnit($item['unit'])
  642.                     ->setUnitPrice($item['unitPrice'])
  643.                     ->setPrice($item['price'])
  644.                     ->setGrossPrice($item['grossPrice'])
  645.                     ->setCurrency($item['currency'])
  646.                     ->setTaxRate($item['taxRate'])
  647.                     ->setOrderItemId($item['orderItemId'])
  648.                 ;
  650.                 $em->persist($orderItem);
  652.                 // calculate loyalty points
  653.                 $loyaltySkuExcludes = [
  654.                     // '123-284', // catalogue
  655.                     '002-1', // shipping
  656.                     '001-8', // shipping
  657.                     '123-20', // shipping
  658.                 ];
  659.                 if (!in_array($orderItem->getSku(), $loyaltySkuExcludes)) {
  660.                     $loyaltyPoints += 0.005 * $orderItem->getGrossPrice();
  661.                 }
  663.                 // have to substract quantity from product stock
  665.                 $product = $productRepo->findOneBy(['sku' => $item['sku']]);
  667.                 if ($product) {
  668.                     $product->setStock($product->getStock() - $item['quantity']);
  670.                     $em->persist($product);
  671.                 }
  672.             }
  674.             if (0 != $loyaltyPoints) {
  675.                 $sign = intval($loyaltyPoints / abs($loyaltyPoints));
  676.             } else {
  677.                 $sign = 1;
  678.             }
  679.             $loyaltyPoints = $sign * intval(ceil(abs($loyaltyPoints))) + $customer->getLoyaltyPoints();
  680.             $customer->setLoyaltyPoints($loyaltyPoints < 0 ? 0 : $loyaltyPoints);
  681.             $em->persist($customer);
  683.             if (0 === $iter % 10) {
  684.                 $em->flush();
  685.             }
  686.         }
  688.         $em->flush();
  690.         if (!empty($rows)) {
  691.             file_put_contents($ordersTmpFile, json_encode($rows));
  692.         } else {
  693.             unlink($ordersTmpFile);
  694.         }
  696.         return $this->json([
  697.             'success' => true,
  698.             'processed' => $iter,
  699.             'remaining' => count($rows),
  700.             'missingCustomers' => $missingCustomers,
  701.         ]);
  702.     }
  704.     protected function convert(array|string $str, string $to = 'UTF-8', string|array|null $from = 'ISO-8859-2'): array|string|false
  705.     {
  706.         return mb_convert_encoding($str, $to, $from);
  707.     }
  709.     #[
  710.         Route(
  711.             name: 'order_get_income',
  712.             path: '/api-helper/orders/get-income',
  713.             methods: ['GET']
  714.         )
  715.     ]
  716.     public function getIncome(
  717.         Request $request,
  718.         EntityManagerInterface $em,
  719.         AuthorizationCheckerInterface $authChecker
  720.     ): JsonResponse {
  721.         /** @var OrderRepository $orderRepo */
  722.         $orderRepo = $em->getRepository(Order::class);
  723.         /** @var User $user */
  724.         $user = $this->getUser();
  726.         if (!$authChecker->isGranted('ROLE_CLERK')) {
  727.             $userId = $user->getId();
  728.         } else {
  729.             $userId = $request->get('user_id', '');
  730.         }
  732.         $iDateParam = $request->get('invoiceDate', []);
  734.         return $this->json($orderRepo->findIncome(
  735.             $request->get('office_id', $user->getOffice()->getId()),
  736.             isset($iDateParam['after']) ? $iDateParam['after'] : '',
  737.             isset($iDateParam['before']) ? $iDateParam['before'] : '',
  738.             $userId,
  739.             $request->get('customer_id', ''),
  740.             $request->get('saleType', '')
  741.         ));
  742.     }
  744.     #[
  745.         Route(
  746.             name: 'order_get_income_by_users',
  747.             path: '/api-helper/orders/get-income-by-users',
  748.             methods: ['GET']
  749.         )
  750.     ]
  751.     public function getIncomeByUsers(
  752.         Request $request,
  753.         EntityManagerInterface $em,
  754.         AuthorizationCheckerInterface $authChecker
  755.     ): JsonResponse {
  756.         /** @var OrderRepository $orderRepo */
  757.         $orderRepo = $em->getRepository(Order::class);
  758.         /** @var User $user */
  759.         $user = $this->getUser();
  761.         if (!$authChecker->isGranted('ROLE_CLERK')) {
  762.             $userId = $user->getId();
  763.         } else {
  764.             $userId = $request->get('user_id', '');
  765.         }
  767.         $iDateParam = $request->get('invoiceDate', []);
  769.         return $this->json($orderRepo->findIncomeByUsers(
  770.             $request->get('office_id', $user->getOffice()->getId()),
  771.             isset($iDateParam['after']) ? $iDateParam['after'] : '',
  772.             isset($iDateParam['before']) ? $iDateParam['before'] : '',
  773.             $userId,
  774.             $request->get('customer_id', ''),
  775.             $request->get('saleType', '')
  776.         ));
  777.     }
  779.     #[
  780.         Route(
  781.             name: 'order_get_income_by_customers',
  782.             path: '/api-helper/orders/get-income-by-customers',
  783.             methods: ['GET']
  784.         )
  785.     ]
  786.     public function getIncomeByCustomers(
  787.         Request $request,
  788.         EntityManagerInterface $em,
  789.         AuthorizationCheckerInterface $authChecker,
  790.         SerializerInterface $serializer
  791.     ): JsonResponse {
  792.         /** @var OrderRepository $orderRepo */
  793.         $orderRepo = $em->getRepository(Order::class);
  794.         /** @var User $user */
  795.         $user = $this->getUser();
  797.         if (!$authChecker->isGranted('ROLE_CLERK')) {
  798.             $userId = $user->getId();
  799.         } else {
  800.             $userId = $request->get('user_id', '');
  801.         }
  803.         $iDateParam = $request->get('invoiceDate', []);
  804.         $page = $request->get('page', 1);
  805.         $itemsPerPage = $request->get('itemsPerPage', 40);
  806.         $ordering = $request->get('order', []);
  808.         $data = $serializer->serialize($orderRepo->findIncomeByCustomers(
  809.             $request->get('office_id', $user->getOffice()->getId()),
  810.             isset($iDateParam['after']) ? $iDateParam['after'] : '',
  811.             isset($iDateParam['before']) ? $iDateParam['before'] : '',
  812.             $userId,
  813.             $request->get('customer_id', ''),
  814.             $request->get('saleType', ''),
  815.             $page,
  816.             $itemsPerPage,
  817.             $ordering
  818.         ), 'json', ['groups' => ['order:getIncomeByCustomers']]);
  820.         return new JsonResponse($data, 200, [], true);
  821.     }
  823.     #[
  824.         Route(
  825.             name: 'order_income_by_customers_export_iterate',
  826.             path: '/api/orders/income-by-customers-export-iterate',
  827.             methods: ['GET']
  828.         )
  829.     ]
  830.     public function incomeByCustomersExportIterateAction(
  831.         Request $request,
  832.         KernelInterface $kernel,
  833.         EntityManagerInterface $em,
  834.         AuthorizationCheckerInterface $authChecker
  835.     ): JsonResponse {
  836.         ini_set('max_execution_time', 300); // 5 minutes
  838.         $tmpFileDir = $kernel->getProjectDir().'/var/tmp-files/';
  840.         if (!is_dir($tmpFileDir)) {
  841.             mkdir($tmpFileDir, 0777, true);
  842.         }
  844.         /** @var User $user */
  845.         $user = $this->getUser();
  847.         if (!$authChecker->isGranted('ROLE_CLERK')) {
  848.             $userId = $user->getId();
  849.         } else {
  850.             $userId = $request->get('user_id', '');
  851.         }
  853.         $iDateParam = $request->get('invoiceDate', []);
  854.         $ordering = $request->get('order', []);
  855.         $page = $request->get('page', 1);
  856.         $itemsPerPage = intval($request->get('itemsPerPage', 500));
  857.         $officeId = $request->get('office_id', $user->getOffice()->getId());
  859.         $fileName = $request->get('fileName', md5(uniqid().json_encode([
  860.             $officeId,
  861.             isset($iDateParam['after']) ? $iDateParam['after'] : '',
  862.             isset($iDateParam['before']) ? $iDateParam['before'] : '',
  863.             $userId,
  864.             $request->get('customer_id', ''),
  865.             $request->get('saleType', ''),
  866.             $page,
  867.             $itemsPerPage,
  868.             $ordering,
  869.         ])));
  871.         $tmpFile = "{$tmpFileDir}/{$fileName}.csv";
  873.         if (!file_exists($tmpFile)) {
  874.             file_put_contents(
  875.                 $tmpFile,
  876.                 $this->buildRow(['id', 'partazon', 'name', 'phone', 'isActive', 'zip', 'city', 'address', 'sellerId', 'sellerName', 'ordersCount', 'cartNetValue', 'giftNetValue', 'totalNetValue', 'cartGrossValue', 'giftGrossValue', 'totalGrossValue'])
  877.             );
  878.         }
  880.         /** @var OrderRepository $orderRepo */
  881.         $orderRepo = $em->getRepository(Order::class);
  883.         $data = $orderRepo->findIncomeByCustomers(
  884.             $officeId,
  885.             isset($iDateParam['after']) ? $iDateParam['after'] : '',
  886.             isset($iDateParam['before']) ? $iDateParam['before'] : '',
  887.             $userId,
  888.             $request->get('customer_id', ''),
  889.             $request->get('saleType', ''),
  890.             $page,
  891.             $itemsPerPage,
  892.             $ordering
  893.         );
  895.         /** @var Customer $item */
  896.         foreach ($data['items'] as $item) {
  897.             file_put_contents(
  898.                 $tmpFile,
  899.                 $this->buildRow([
  900.                     $item['id'],
  901.                     $item['customer']->getPartazon(),
  902.                     $item['customer']->getName(),
  903.                     $item['customer']->getPhone(),
  904.                     $item['customer']->getIsActive() ? '1' : '0',
  905.                     $item['customer']->getZip(),
  906.                     $item['customer']->getCity(),
  907.                     $item['customer']->getAddress(),
  908.                     $item['customer']->getUser() ? $item['customer']->getUser()->getId() : '',
  909.                     $item['customer']->getUser() ? $item['customer']->getUser()->getName() : '',
  910.                     $item['ordersCount'],
  911.                     $item['sumNet'] + ($item['giftNet'] ?? 0),
  912.                     ($item['giftNet'] ?? 0),
  913.                     $item['sumNet'],
  914.                     $item['sumGross'] + ($item['giftGross'] ?? 0),
  915.                     ($item['giftGross'] ?? 0),
  916.                     $item['sumGross'],
  917.                 ]),
  918.                 FILE_APPEND
  919.             );
  920.         }
  922.         return $this->json([
  923.             'page' => ($page + 1),
  924.             'itemsPerPage' => $itemsPerPage,
  925.             'fileName' => $fileName,
  926.             'remaining' => max($data['totalItems'] - $page * $itemsPerPage /*- count($data['items'])*/, 0),
  927.         ]);
  928.     }
  930.     #[
  931.         Route(
  932.             name: 'order_income_by_customers_export',
  933.             path: '/api/orders/income-by-customers-export',
  934.             methods: ['GET']
  935.         )
  936.     ]
  937.     public function incomeByCustomersExportAction(
  938.         Request $request,
  939.         KernelInterface $kernel
  940.     ): BinaryFileResponse {
  941.         $tmpFileDir = $kernel->getProjectDir().'/var/tmp-files/';
  942.         $fileName = $request->get('fileName');
  943.         $tmpFile = "{$tmpFileDir}/{$fileName}.csv";
  945.         $response = new BinaryFileResponse($tmpFile);
  946.         $response->headers->set('Content-Type', 'text/csv');
  947.         $response->setContentDisposition(ResponseHeaderBag::DISPOSITION_ATTACHMENT, 'orders-income-by-customers.csv')
  948.                  ->deleteFileAfterSend();
  950.         return $response;
  951.     }
  953.     protected function buildRow(array $row, string $delimiter = ',', string $enclosure = '"'): string|false
  954.     {
  955.         // output up to 5MB is kept in memory, if it becomes bigger
  956.         // it will automatically be written to a temporary file
  957.         $csv = fopen('php://temp/maxmemory:'.(5 * 1024 * 1024), 'r+');
  958.         fputcsv($csv, $row, $delimiter, $enclosure);
  959.         rewind($csv);
  961.         return stream_get_contents($csv);
  962.     }
  963. }