vendor/boldr/cloudprnt-receipt-printer/src/Controller/CloudPrntController.php line 33

Open in your IDE?
  1. <?php
  3. namespace Boldr\Shop\CloudPrntReceiptPrinterBundle\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\Routing\Annotation\Route;
  7. use Symfony\Component\HttpFoundation\{ Request, Response, BinaryFileResponse };
  8. use Boldr\Shop\ReceiptPrinterBundle\Printer\PrintJobManager;
  9. use Boldr\Shop\CloudPrntReceiptPrinterBundle\Entity\CloudPrntPrinterConfiguration;
  10. use Boldr\Shop\ReceiptPrinterBundle\Entity\{ Receipt };
  11. use mikehaertl\wkhtmlto\Image;
  12. use Boldr\Shop\CpUtilBinLocator\CpUtilBinLocator;
  13. use Imagick;
  14. use ImagickException;
  15. use Boldr\Shop\ShopBundle\Presenter\Order\OrderPresenter;
  16. use Symfony\Component\HttpKernel\Config\FileLocator;
  17. use Psr\Log\LoggerInterface;
  19. class CloudPrntController extends AbstractController
  20. {
  22.     public static function getSubscribedServices()
  23.     {
  24.         return array_merge(parent::getSubscribedServices(), [
  25.             'print_job_manager' => PrintJobManager::class,
  26.             'order_presenter' => OrderPresenter::class,
  27.             'file_locator' => FileLocator::class,
  28.             'logger' => LoggerInterface::class,
  29.         ]);
  30.     }
  32.     /** @Route("/boldr-api/cloudprnt/{secret}", name="cloudprnt_receipt_printer_print") */
  33.     public function cloudprnt(Request $request, string $secret)
  34.     {
  35.         $printerConfigurations = $this->getDoctrine()->getRepository(CloudPrntPrinterConfiguration::class)->findBySecret($secret);
  36.         if (count($printerConfigurations) === 0)
  37.             throw $this->createNotFoundException();
  39.         $printers = array_map(fn($printerConfiguration) => $printerConfiguration->getPrinter(), $printerConfigurations);
  41.         if ($request->getMethod() == 'POST')
  42.         {
  43.             return $this->poll($request, $printers);
  44.         }
  45.         elseif ($request->getMethod() == 'GET')
  46.         {
  47.             return $this->print($request, $printers);
  48.         }
  49.         elseif ($request->getMethod() == 'DELETE')
  50.         {
  51.             return $this->completed($request, $printers);
  52.         }
  53.     }
  55.     private function poll(Request $request, array $printers): Response
  56.     {
  57.         $printJobManager = $this->get('print_job_manager');
  59.         $printJobs = $printJobManager->getPrintJobs($printers, ['unknown', 'queued']);
  60.         $data = [];
  62.         // Ignore jobs if printingInProgress
  63.         if (!$request->request->get('printingInProgress', false))
  64.         {
  65.             if (count($printJobs) == 0)
  66.             {
  67.                 $data['jobReady'] = false;
  68.             }
  69.             else
  70.             {
  71.                 $receipt = $printJobs[0];
  72.                 $data = [
  73.                     'jobReady' => true,
  74.                     'jobToken' => (string) $receipt->getId(),
  75.                     'mediaTypes' => ['application/vnd.star.raster', 'application/vnd.star.line', 'application/vnd.star.starprnt', 'image/png', 'image/jpeg', 'application/vnd.star.starprntcore']
  76.                 ];
  77.             }
  78.         }
  80.         return $this->json($data);
  82.     }
  84.     private function getPrintJobByToken(array $printers, string $jobToken)
  85.     {
  86.         $printJobManager = $this->get('print_job_manager');
  87.         $receipt = $printJobManager->getPrintJob($printers, $jobToken);
  88.         if ($receipt === null)
  89.          // || $receipt->getState() == 'printed')
  90.             return null;
  92.         return $receipt;
  93.     }
  95.     private function print(Request $request, array $printers): Response
  96.     {
  97.         $token = $request->query->get('token');
  98.         if ($token === null)
  99.         {
  100.             return $this->json(['error' => 'missing_token_parameter']);
  101.         }
  103.         $printJob = $this->getPrintJobByToken($printers, $token);
  105.         if ($printJob === null)
  106.             throw $this->createNotFoundException();
  108.         $printer = $printJob->getPrinter();
  109.         $mediaType = $request->query->get('type');
  111.         $printJob->setState(Receipt::STATE_PRINTING);
  112.         $this->getDoctrine()->getManager()->flush();
  114.         $template = $printer->getConfiguration()->getTemplate();
  116.         $orders = $printJob->getOrders();
  118.         $customer = $orders[0]->getCustomer();
  119.         $state = $orders[0]->getState();
  120.         $currency = $orders[0]->getCurrency();
  122.         $megaOrder = clone $orders[0];
  123.         $invoiceItems = $megaOrder->getInvoiceItems();
  124.         $orderItems = $megaOrder->getItems();
  125.         foreach ($orders as $i => $order)
  126.         {
  127.             if ($i !== 0)
  128.             {
  129.                 foreach ($order->getItems() as $orderItem)
  130.                 {
  131.                     $orderItems->add($orderItem);
  133.                     $invoiceItem = $orderItem->getInvoiceItem();
  134.                     $invoiceItems->add($invoiceItem);
  135.                 }
  136.                 foreach ($order->getInvoiceItems() as $invoiceItem)
  137.                 {
  138.                     if (!$invoiceItems->contains($invoiceItem))
  139.                     {
  140.                         $invoiceItems->add($invoiceItem);
  141.                     }
  142.                 }
  143.             }
  144.         }
  146.         $orderView = $this->get('order_presenter')->createOrderView($megaOrder, $printer->getLocale());
  148.         // Separate items by category
  149.         $orderItemViewsByCategoryId = [];
  150.         if ($printer->getSeparateItemsByCategory())
  151.         {
  152.             $printerCategoryIds = array_map(fn($category) => $category->getId(), $printer->getCategories());
  153.             foreach ($orderView->getItems() as $orderItemView)
  154.             {
  155.                 $orderItemViewCategoryIds = array_map(fn($categoryView) => $categoryView->getId(), $orderItemView->getProduct()->getCategories());
  156.                 $inAny = false;
  157.                 foreach ($printerCategoryIds as $id)
  158.                 {
  159.                     if (in_array($id, $orderItemViewCategoryIds))
  160.                     {
  161.                         $orderItemViewsByCategoryId[$id][] = $orderItemView;
  162.                         $inAny = true;
  163.                         break;
  164.                     }
  165.                 }
  167.                 if (!$inAny && !$printer->getRestrictItemsByCategory())
  168.                 {
  169.                     $orderItemViewsByCategoryId[null][] = $orderItemView;
  170.                 }
  171.             }
  172.         }
  174.         // Generate receipt view
  175.         $templateData = $this->getParameter('boldr_cloudprnt_receipt_printer.receipt_templates')[$template];
  176.         $html = $this->renderView($templateData['template'], [
  177.             'order' => $orderView,
  178.             'logoUrl' => null,
  179.             'separateItemsByCategory' => $printer->getSeparateItemsByCategory(),
  180.             'categoryTranslations' => array_map(fn($category) => $category->getTranslations()->get($printer->getLocale()), $printer->getCategories()),
  181.             'orderItemsByCategoryId' => $orderItemViewsByCategoryId,
  182.         ]);
  184.         // Render to image
  185.         $stylesheet = substr($templateData['stylesheet'], 0, 1) == '@'
  186.             ? $this->get('file_locator')->locate($templateData['stylesheet'])
  187.             : $this->getParameter('kernel.project_dir') .'/'. $templateData['stylesheet'];
  189.         $wkhtmltoimage = new Image([
  190.             'user-style-sheet' => $stylesheet,
  191.             'width' => '518',
  192.             'encoding' => 'utf-8'
  193.         ]);
  194.         $wkhtmltoimage->setPage($html);
  196.         try
  197.         {
  198.             $imagick = new Imagick;
  199.             // $imagick->readImageBlob('');
  200.             $imagick->readImageBlob($wkhtmltoimage->toString());
  201.             $imagick->setImageType(Imagick::IMGTYPE_GRAYSCALE);
  202.             $imagick->setImageFormat('png8');
  203.             $imagick->stripImage();
  204.             $bytes = (string) $imagick;
  205.         }
  206.         catch (ImagickException $ex)
  207.         {
  208.             $this->container->get('logger')->critical('printing failed for receipt token '. $token .', requeued: '. $ex);
  209.             // If image generation failed for some reason, e.g. empty image string passed,
  210.             // re-queue the receipt to be printed another time.
  211.             $printJob->setState(Receipt::STATE_QUEUED);
  212.             $this->getDoctrine()->getManager()->flush();
  214.             return new Response('', 500);
  215.         }
  217.         if (!in_array($mediaType, $request->getAcceptableContentTypes()))
  218.         {
  219.             $response = new Response($bytes);
  220.             $response->headers->set('Content-Type', 'image/png');
  221.             return $response;
  222.         }
  224.         $tmpInput = tempnam(sys_get_temp_dir(), 'bcpi');
  225.         rename($tmpInput, $tmpInput.'.png');
  226.         $tmpInput .= '.png';
  227.         file_put_contents($tmpInput, $bytes);
  229.         // Capture cputil output
  230.         $tmpOutput = tempnam(sys_get_temp_dir(), 'bcpo');
  231.         $this->runCpUtilCommand('thermal3 dither buzzer-start 1 scale-to-fit decode '.$mediaType.' '.$tmpInput.' '.$tmpOutput);
  233.         $response = new BinaryFileResponse($tmpOutput);
  234.         $response->headers->set('Content-Type', $mediaType);
  235.         $response->headers->set('X-Star-Buzzerstartpattern', '1');
  237.         return $response;
  238.     }
  240.     private function runCpUtilCommand(string $command)
  241.     {
  242.         $cpUtilPath = CpUtilBinLocator::getCpUtilBin();
  243.         system($cpUtilPath .' '. $command);
  244.     }
  246.     private function completed(Request $request, array $printers): Response
  247.     {
  248.         $printJob = $this->getPrintJobByToken($printers, $request->query->get('token'));
  249.         if ($printJob === null)
  250.             return $this->createNotFoundException();
  252.         $code = $request->query->get('code');
  253.         if ($code)
  254.         {
  255.             if ($code >= 400 && $code < 600)
  256.             {
  257.                 $orderNumbers = $printJob->getOrders()->map(fn($order) => $order->getNumber() ?? ('ID#'. $order->getId()))->toArray();
  259.                 //$this->get('logger')->critical('Print job "'.$printJob->getId().'" (order(s) '. join(', ', $orderNumbers) .') return status '. $code .', retrying.');
  260.                 return $this->json([]);
  261.             }
  262.         }
  264.         $printJob->setState(Receipt::STATE_PRINTED);
  265.         $this->getDoctrine()->getManager()->flush();
  267.         return $this->json([]);
  268.     }
  270.     public function handleClientAction(Request $request)
  271.     {
  272.         $clientActions = $request->request->get('clientAction');
  273.         foreach ($clientActions as $clientAction)
  274.         {
  275.             switch ($clientAction['request'])
  276.             {
  278.             }
  279.         }
  280.     }
  282. }