vendor/alnv/catalog-manager/library/alnv/ReviseRelatedTables.php line 42

Open in your IDE?
  1. <?php
  3. namespace CatalogManager;
  5. class ReviseRelatedTables extends \Controller {
  7.     private $arrErrorTables = [];
  9.     public function __construct() {
  11.         $this->import('Database');
  12.     }
  14.     public function reviseCatalogTables($strTable, $strPTable, $arrCTables) {
  16.         $objCatalogDb = $this->Database->prepare('SELECT id FROM tl_catalog WHERE tablename = ?')->execute($strTable);
  18.         if (!$objCatalogDb->count()) {
  19.             return false;
  20.         }
  22.         if ($strPTable && $this->Database->TableExists($strPTable)) {
  23.             if (isset($GLOBALS['TL_DCA'][ $strTable ]['config']['dynamicPtable']) && $GLOBALS['TL_DCA'][$strTable]['config']['dynamicPtable']) {
  24.                 $objStmt = $this->Database->prepare(sprintf(' SELECT * FROM %s WHERE ptable=? AND NOT EXISTS( SELECT * FROM %s WHERE %s.pid = %s.id )', $strTable, $strPTable, $strTable, $strPTable))->execute($strPTable);
  25.             } else {
  26.                 $objStmt = $this->Database->prepare(sprintf('SELECT * FROM %s WHERE NOT EXISTS( SELECT * FROM %s WHERE %s.pid = %s.id )', $strTable, $strPTable, $strTable, $strPTable))->execute();
  27.             }
  28.             if ($objStmt->count() > 0) {
  29.                 $this->arrErrorTables[] = $strPTable;
  30.                 return true;
  31.             }
  32.         }
  34.         if (!empty($arrCTables) && is_array($arrCTables)) {
  36.             foreach ($arrCTables as $v) {
  38.                 if ($v && $this->Database->TableExists($v)) {
  40.                     if (!isset($GLOBALS['TL_DCA'][$v])) {
  41.                         $objLoader = new \DcaLoader( $strTable );
  42.                         $objLoader->load(false);
  43.                     }
  45.                     if (!($GLOBALS['TL_DCA'][$v]??'')) {
  46.                         continue;
  47.                     }
  49.                     if (isset($GLOBALS['TL_DCA'][$v]['config']['dynamicPtable']) && $GLOBALS['TL_DCA'][$v]['config']['dynamicPtable']) {
  50.                         $objStmt = $this->Database->prepare(sprintf(' SELECT * FROM %s  WHERE ptable=? AND NOT EXISTS( SELECT * FROM %s WHERE %s.pid = %s.id)', $v, $strTable, $v, $strTable))->execute($v);
  51.                     } else {
  52.                         $objStmt = $this->Database->prepare(sprintf('SELECT * FROM %s WHERE NOT EXISTS( SELECT * FROM %s WHERE %s.pid = %s.id)', $v, $strTable, $v, $strTable))->execute();
  53.                     }
  55.                     if ($objStmt->count() > 0) {
  56.                         $this->arrErrorTables[] = $v;
  57.                         return true;
  58.                     }
  59.                 }
  60.             }
  61.         }
  63.         return false;
  64.     }
  66.     public function getErrorTables() {
  68.         return $this->arrErrorTables;
  69.     }
  70. }