src/Controller/EgdDeclarationController.php line 20

  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\EgdDeclaration;
  6. use App\Repository\EgdDeclarationRepository;
  7. use App\Service\Egd\EgdApiClient;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\Routing\Annotation\Route;
  15. #[Route('/egd-declaration')]
  16. class EgdDeclarationController extends AbstractController
  17. {
  19.     #[Route('/upload', name: 'app_egd_declaration_upload', methods: ['GET', 'POST'])]
  20.     public function uploadExcel(
  21.         Request $request, 
  22.         EntityManagerInterface $em, 
  23.         EgdApiClient $apiClient,
  24.         \App\Service\Egd\EgdXmlBuilder $xmlBuilder
  25.     ): Response {
  26.         if ($request->isMethod('POST')) {
  27.             $uploadedFile = $request->files->get('file');
  29.             if ($uploadedFile) {
  30.                 try {
  31.                     $fileDirectory = $this->getParameter('kernel.project_dir') . '/var/uploads';
  32.                     if (!is_dir($fileDirectory)) {
  33.                         mkdir($fileDirectory, 0777, true);
  34.                     }
  35.                     $originalExtension = pathinfo($uploadedFile->getClientOriginalName(), PATHINFO_EXTENSION);
  36.                     $newFilename = uniqid() . '.' . $originalExtension;
  37.                     
  38.                     $uploadedFile->move($fileDirectory, $newFilename);
  39.                     $filePath = $fileDirectory . '/' . $newFilename;
  41.                     if (!class_exists('\PhpOffice\PhpSpreadsheet\IOFactory')) {
  42.                         throw new \Exception('PhpSpreadsheet is not installed. Please run: composer require phpoffice/phpspreadsheet');
  43.                     }
  45.                     $spreadsheet = \PhpOffice\PhpSpreadsheet\IOFactory::load($filePath);
  46.                     $worksheet = $spreadsheet->getActiveSheet();
  47.                     
  48.                     $data = [];
  49.                     $columnHeaders = [];
  50.                     
  51.                     foreach ($worksheet->getRowIterator() as $row) {
  52.                         foreach ($row->getCellIterator() as $cell) {
  53.                             $columnHeaders[] = $cell->getValue();
  54.                         }
  55.                         break; 
  56.                     }
  58.                     foreach ($worksheet->getRowIterator() as $rowIndex => $row) {
  59.                         if ($rowIndex === 1) continue; // Skip headers
  60.                         
  61.                         $rowValues = [];
  62.                         $cellIterator = $row->getCellIterator();
  63.                         $cellIterator->setIterateOnlyExistingCells(false);
  65.                         foreach ($cellIterator as $cell) {
  66.                             $rowValues[] = $cell->getValue();
  67.                         }
  69.                         // Make sure we have the same number of keys and values
  70.                         if (count($columnHeaders) === count($rowValues)) {
  71.                             $data[] = array_combine($columnHeaders, $rowValues);
  72.                         }
  73.                     }
  75.                     // Build XML
  76.                     $masterWaybillId = $request->request->get('masterWaybillId', 'TD-000000001');
  77.                     $xmlData = $xmlBuilder->buildFromExcelData($data, $masterWaybillId);
  78.                     // Create Local Declaration
  79.                     $declaration = new EgdDeclaration();
  80.                     $courierDocId = $this->generateUuid();
  81.                     $messageId = $this->generateUuid();
  82.                     
  83.                     $declaration->setCourierDocId($courierDocId);
  84.                     $declaration->setMessageId($messageId);
  85.                     $declaration->setMasterWaybillId($masterWaybillId);
  86.                     $declaration->setOperation('Store');
  87.                     $declaration->setStatus('PENDING_SUBMIT');
  88.                     $declaration->setXmlData($xmlData);
  89.                     
  90.                     $em->persist($declaration);
  91.                     $em->flush();
  93.                     // Submit to EGD API
  94.                     $response = $apiClient->submitDeclaration($courierDocId, $messageId, 'Store', $xmlData);
  95.                     
  96.                     if ($response['success']) {
  97.                         $declaration->setStatus('SUBMITTED');
  98.                         $this->addFlash('success', 'Excel processed and declaration successfully submitted to EGD.');
  99.                     } else {
  100.                         $declaration->setStatus('FAILED');
  101.                         $declaration->setErrors($response['error'] ?? null);
  102.                         $this->addFlash('error', 'Failed to submit declaration to EGD.');
  103.                     }
  104.                     
  105.                     $em->flush();
  107.                     // Cleanup temp file
  108.                     @unlink($filePath);
  110.                     return $this->redirectToRoute('app_egd_declaration_show', ['id' => $declaration->getId()]);
  111.                     
  112.                 } catch (\Exception $e) {
  113.                     $this->addFlash('error', 'Error processing Excel: ' . $e->getMessage());
  114.                 }
  115.             } else {
  116.                 $this->addFlash('error', 'No file uploaded.');
  117.             }
  118.         }
  120.         return $this->render('egd_declaration/upload.html.twig');
  121.     }
  123.     #[Route('/new', name: 'app_egd_declaration_new', methods: ['GET', 'POST'])]
  124.     public function new(Request $request, EntityManagerInterface $em, EgdApiClient $apiClient): Response
  125.     {
  126.         if ($request->isMethod('POST')) {
  127.             $xmlData = $request->request->get('xmlData');
  128.             
  129.             if (empty($xmlData)) {
  130.                 $this->addFlash('error', 'XML Data cannot be empty.');
  131.                 return $this->redirectToRoute('app_egd_declaration_new');
  132.             }
  134.             $declaration = new EgdDeclaration();
  135.             $courierDocId = $this->generateUuid();
  136.             $messageId = $this->generateUuid();
  137.             
  138.             $declaration->setCourierDocId($courierDocId);
  139.             $declaration->setMessageId($messageId);
  140.             $declaration->setOperation('Store');
  141.             $declaration->setStatus('PENDING_SUBMIT');
  142.             $declaration->setXmlData($xmlData);
  143.             
  144.             $em->persist($declaration);
  145.             $em->flush();
  147.             // Submit to EGD
  148.             $response = $apiClient->submitDeclaration($courierDocId, $messageId, 'Store', $xmlData);
  149.             
  150.             if ($response['success']) {
  151.                 $declaration->setStatus('SUBMITTED');
  152.                 $this->addFlash('success', 'Declaration successfully submitted to EGD.');
  153.             } else {
  154.                 $declaration->setStatus('FAILED');
  155.                 $declaration->setErrors($response['error'] ?? null);
  156.                 $this->addFlash('error', 'Failed to submit declaration to EGD.');
  157.             }
  158.             
  159.             $em->flush();
  161.             return $this->redirectToRoute('app_egd_declaration_show', ['id' => $declaration->getId()]);
  162.         }
  164.         // We load the sample XML for convenience
  165.         $sampleXmlPath = $this->getParameter('kernel.project_dir') . '/sample-DGEC-declaration.xml';
  166.         $sampleXml = file_exists($sampleXmlPath) ? file_get_contents($sampleXmlPath) : '';
  168.         return $this->render('egd_declaration/new.html.twig', [
  169.             'sampleXml' => $sampleXml,
  170.         ]);
  171.     }
  173.     #[Route('/{id}', name: 'app_egd_declaration_show', methods: ['GET'])]
  174.     public function show(EgdDeclaration $declaration): Response
  175.     {
  176.         return $this->render('egd_declaration/show.html.twig', [
  177.             'declaration' => $declaration,
  178.         ]);
  179.     }
  181.     #[Route('/{id}/refresh', name: 'app_egd_declaration_refresh', methods: ['POST'])]
  182.     public function refresh(EgdDeclaration $declaration, EgdApiClient $apiClient, EntityManagerInterface $em): Response
  183.     {
  184.         $response = $apiClient->getSubmissionStatus($declaration->getMessageId());
  185.         
  186.         if ($response['status'] === 200) {
  187.             $data = $response['data'];
  188.             if (isset($data['status'])) {
  189.                 $declaration->setStatus($data['status']);
  190.                 $em->flush();
  191.                 $this->addFlash('success', 'Status refreshed from EGD.');
  192.             }
  193.         } else {
  194.             $this->addFlash('error', 'Could not refresh status. HTTP Code: ' . $response['status']);
  195.         }
  197.         return $this->redirectToRoute('app_egd_declaration_show', ['id' => $declaration->getId()]);
  198.     }
  200.     private function generateUuid(): string
  201.     {
  202.         $data = random_bytes(16);
  203.         $data[6] = chr(ord($data[6]) & 0x0f | 0x40); 
  204.         $data[8] = chr(ord($data[8]) & 0x3f | 0x80); 
  205.         return vsprintf('%s%s-%s-%s-%s-%s%s%s', str_split(bin2hex($data), 4));
  206.     }
  207. }