bundles/ZweiPunkt/ShopwareBundle/Controller/DefaultController.php line 22

Open in your IDE?
  1. <?php
  3. namespace ZweiPunkt\ShopwareBundle\Controller;
  5. use DateInterval;
  6. use DateTime;
  7. use Doctrine\DBAL\Connection;
  8. use Pimcore\Controller\FrontendController;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\RedirectResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\Routing\Annotation\Route;
  14. use ZweiPunkt\ShopwareBundle\Command\SyncCommand;
  16. class DefaultController extends FrontendController
  17. {
  18.     private Connection $connection;
  19.     /**
  20.      * @Route("/sync")
  21.      */
  22.     public function indexAction(Request $request, Connection $connection)
  23.     {
  24.         $this->connection = $connection;
  25.         if (file_exists(SyncCommand::SYNC_FILE)) {
  26.             unlink(SyncCommand::SYNC_FILE);
  27.         }
  28.         $action = $request->query->get('action', 'none');
  29.         if ('full' == $action) {
  30.             $query = '
  31.                 UPDATE object_1
  32.                 SET shopwareSync = 0
  33.                 WHERE shopwareSync IS NOT NULL;
  34.             ';
  35.             $connection->executeStatement($query);
  36.             return new RedirectResponse('/sync');
  37.         }
  38.         return new Response($this->getContent(), Response::HTTP_OK);
  39.     }
  41.     private function getContent(): string
  42.     {
  43.         $links = [
  44.             'Update starten' => '/sync',
  45.             'Vollsynchronisation' => '/sync?action=full',
  46.             'Liste' => '/list'
  47.         ];
  48.         $content = '';
  50.         $entitiesToSync = $this
  51.             ->connection
  52.             ->executeQuery('
  53.                 SELECT COUNT(*) AS `count`
  54.                  FROM `object_1`
  55.                 WHERE o_modificationDate > shopwareSync
  56.                    OR shopwareSync IS NULL;
  57.             ')
  58.             ->fetchAllAssociative()
  59.         ;
  60.         $count = $entitiesToSync[0]['count'] ?? 0;
  62.         if ($count > 0) {
  63.             $content .= '<p>' . sprintf('Zu Synchronisieren: %d', $count) . '</p>';
  64.         }
  66.         $content .= '<div style="margin: 25px">';
  68.         foreach ($links as $name => $link) {
  69.             $content .= sprintf(
  70.                 '<a style="margin: 10px; padding: 5px 10px; background: #EFEFEF; text-decoration: none;" href="%s">%s</a>',
  71.                 $link,
  72.                 $name
  73.             );
  74.         }
  75.         $content .= '</div><p>Synchronisation wird in den nächsten 5 Minuten gestartet.</p>';
  76.         return $content;
  77.     }
  79.     /**
  80.      * @Route("/list")
  81.      */
  82.     public function listAction(Request $request, Connection $connection)
  83.     {
  84.         $entitiesToSync = $connection
  85.             ->executeQuery('
  86.                 SELECT oo_id AS id,
  87.                        customfield_asf_model AS model,
  88.                        customfield_asf_material AS material,
  89.                        customfield_asf_alloy AS alloy,
  90.                        customfield_asf_default_stone AS stone
  91.                  FROM `object_1`
  92.                 WHERE o_modificationDate > shopwareSync
  93.                    OR shopwareSync IS NULL;
  94.             ')
  95.             ->fetchAllAssociative()
  96.         ;
  97.         $content = '<style>body { font-family: "Courier New"; } td,th { text-align: left; padding: 5px 10px; font-family: "Courier New"; }</style>';
  98.         $content .= '<h1>Zu aktualisierende Produkte: ' . count($entitiesToSync) . '</h1>';
  99.         $content .= '<h4>Technische Daten direkt aus DB (nicht für Import / Export geeignet).</h4>';
  100.         $content .= '<table>';
  101.         $content .= '
  102.             <thead>
  103.                 <th>ID</th>
  104.                 <th>Modell</th>
  105.                 <th>Material</th>
  106.                 <th>Legierung</th>
  107.                 <th>Stein</th>
  108.                 <th>Einzelprodukt</th>
  109.                 <th>Modell</th>
  110.             </thead>
  111.         ';
  112.         foreach ($entitiesToSync as $entry) {
  113.             $content .= '<tr>';
  114.             $content .= sprintf('
  115.                         <td>%d</td>
  116.                         <td>%s</td>
  117.                         <td>%s</td>
  118.                         <td>%s</td>
  119.                         <td>%s</td>
  120.                         <td><pre style="color: gray;">bin/console shopware:sync --ring=%d</pre></td>
  121.                         <td><pre style="color: gray;">bin/console shopware:sync --model=%s</pre></td>
  122.                     ',
  123.                     $entry['id'],
  124.                     $entry['model'],
  125.                     $entry['material'],
  126.                     $entry['alloy'],
  127.                     $entry['stone'],
  128.                     $entry['id'],
  129.                     $entry['model']
  130.                 );
  131.             $content .= '</tr>';
  132.         }
  133.         $content .= '</table>';
  135.         return new Response($content, Response::HTTP_OK);
  136.     }
  137. }