src/EventSubscriber/NodeSubscriber.php line 30

Open in your IDE?
  1. <?php
  2. namespace App\EventSubscriber;
  4. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  5. use w3des\AdminBundle\Event\AdminSaveEvent;
  6. use w3des\AdminBundle\Service\Nodes;
  7. use Symfony\Component\HttpFoundation\File\UploadedFile;
  8. use PhpOffice\PhpSpreadsheet\IOFactory;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use w3des\AdminBundle\Entity\NodeVariable;
  12. class NodeSubscriber implements EventSubscriberInterface
  13. {
  14. private Nodes $nodes;
  15. private EntityManagerInterface $em;
  17. public function __construct(Nodes $nodes, EntityManagerInterface $em)
  18. {
  19. $this->nodes = $nodes;
  20. $this->em = $em;
  21. }
  23. public static function getSubscribedEvents(): array
  24. {
  25. return [
  26. AdminSaveEvent::class => 'preSave'
  27. ];
  28. }
  30. public function preSave(AdminSaveEvent $event): void
  31. {
  32. $model = $event->getModel();
  34. if (!method_exists($model, 'getType')) {
  35. return;
  36. }
  38. if ($model->getType() !== 'collection') {
  39. return;
  40. }
  41. $file = $event->getForm()->get('variables')->get('import')->get('xx')->getData();
  42. if (!($file instanceof UploadedFile)) {
  43. return;
  44. }
  45. $tmpName = \tempnam(\sys_get_temp_dir(), 'import') . '.' . $file->getClientOriginalExtension();
  46. $file->move(dirname($tmpName), basename($tmpName));
  47. try {
  48. $found = [];
  49. $workbook = IOFactory::createReaderForFile($tmpName)->load($tmpName);
  50. /** @var \PhpOffice\PhpSpreadsheet\Worksheet\Row $row */
  51. $sheet = $workbook->getActiveSheet();
  52. foreach ($sheet->getRowIterator() as $row) {
  53. $value = $sheet->getCell([1, $row->getRowIndex()])->getValue();
  54. if ($value) {
  55. $value = trim($value);
  56. }
  57. if (empty($value)) {
  58. continue;
  59. }
  61. $s = $this->nodes->getNodes('index', [
  62. 'where' => [
  63. 'index' => $value
  64. ]
  65. ]);
  66. foreach ($s['list'] as $obj) {
  67. $sub = $this->nodes->getNodes('product', [
  68. 'where' => [
  69. 'indexes' => $obj->model
  70. ]
  71. ]);
  72. foreach ($sub['list'] as $prod) {
  73. $found[$prod->id] = $prod->model;
  74. }
  76. }
  77. }
  78. if (count($found)) {
  79. /** @var \w3des\AdminBundle\Entity\Node $node */
  80. $node = $event->getModel();
  81. $vals = \array_values($found);
  82. $num = -1;
  83. foreach ($node->getVariables() as $v) {
  84. if ($v->getName() == 'indexes') {
  85. if ($v->getPos()+1 > count($vals)) {
  86. $node->getVariables()->remove($v);
  87. $this->em->remove($v);
  88. } else {
  89. $v->setNodeValue($vals[$v->getPos()]);
  90. $num = max($num, $v->getPos());
  91. }
  92. }
  93. }
  94. $num++;
  95. if (count($vals) > $num) {
  96. for ($i = $num; $i < count($vals); $i++) {
  97. $v = new NodeVariable();
  98. $v->setType('node');
  99. $v->setNode($node);
  100. $v->setName('indexes');
  101. $v->setLocale('xx');
  102. $v->setPos($num++);
  103. $v->setNodeValue($vals[$i]);
  104. $node->getVariables()->add($v);
  105. $this->em->persist($v);
  106. }
  107. }
  108. }
  109. } finally {
  110. unlink($tmpName);
  111. }
  113. //die('xd');
  114. }
  116. }