Ego_Search_Factory.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_Search_Factory
{
    static public function start($table = '', $param = [], $checkHealthy = false) {
        if (empty($table)) {
            $table = $GLOBALS['site'] ? $GLOBALS['site']->pageTable : '';
        }
        switch ($GLOBALS['egotec_conf']['search_engine']) {
            case 'mysql':
                require_once('base/Ego_Search_Mysql.php');
                return new Ego_Search_Mysql($table);
            case 'simple':
                require_once('base/Ego_Search_Simple.php');
                return new Ego_Search_Simple($table);
            case 'lucene':
                require_once('base/Ego_Search_Lucene.php');
                return new Ego_Search_Lucene($table, $param);
            case 'elastic':
                require_once('base/Ego_Search_Elastic.php');
                return new Ego_Search_Elastic($table, $param, $checkHealthy);
            case 'sql':
            default:
                require_once('base/Ego_Search_Sql.php');
                return new Ego_Search_Sql($table);
        }
    }
 
    public static function updateIndex($sites = [], $lang = '', $output = true) {
        $db = new_db_connection();
        if (empty($sites)) {
            $sites = Ego_System::getAllSites();
        }
        foreach ($sites as $site) {
            if ($lang) {
                $langs = [$lang];
            } else {
                $langs = $site->getLanguages();
            }
            foreach ($langs as $l) {
                $site->setLanguage($l);
                $site->clearCache();
                if ($output) {
                    Ego_System::flush("<br/>\nBearbeite Mandant '" . $site->name . "' mit Sprache '$l'");
                }
 
                $search_engine = self::start($site->pageTable);
                if (!$_REQUEST['start']) {
                    if ($output) {
                        Ego_System::flush("<br/>\nVolltextindex komplett löschen!\n\n");
                    }
                    $search_engine->reset();
                }
 
                $query = [];
                if ($_REQUEST['limit']) {
                    $query['limit'] = $_REQUEST['start'] . ',' . $_REQUEST['limit'];
                    $query['order'] = 'id ASC';
                }
                $pages = $site->getPages(
                    $query,
                    ['no_cache' => 1]
                );
                $next = false; // Ein weiteres Update nur durchführen,
                $bulk_pages = [];
 
                $search = Ego_Search_Factory::start($site->pageTable);
 
 
                foreach ($pages as $page) {
                    set_time_limit(0);
                    if ($output) {
                        Ego_System::flush("<br/>\n" . $page->field['id']);
                    }
 
                    if ($GLOBALS['egotec_conf']['search_engine'] == 'elastic') {
                        $bulk_pages[] = $page;
                        if (sizeof($bulk_pages) == 20) {
                            $search->updateBulk($bulk_pages, false);
                            $bulk_pages = [];
                        }
                    } else {
                        $page->updateIndex($search_engine, false, false);
                        $next = true; // wenn es noch Seiten für das Update gibt
                    }
                }
 
                if ($GLOBALS['egotec_conf']['search_engine'] == 'elastic' && sizeof($bulk_pages) > 0) {
                    $search->updateBulk($bulk_pages, false);
                }
 
                if (!in_array($GLOBALS['egotec_conf']['search_engine'], ['lucene', 'elastic'])) {
                    if ($output) {
                        Ego_System::flush("<br/>\nVolltexttabelle optimieren!\n\n");
                    }
                    $db->optimize($site->name . '_' . $l . '_fulltext');
                }
 
                if ($_REQUEST['auto'] && $next && !$_REQUEST['allsites']) {
                    $request_uri = str_replace('start=' . $_REQUEST['start'], 'start=' . ($_REQUEST['start'] + $_REQUEST['limit']), $_SERVER['REQUEST_URI']);
                    if ($output) {
                        Ego_System::flush("<script type=\"text/javascript\">document.location.href = \"" . $request_uri . "\";</script>");
                    }
                } elseif ($output) {
                    Ego_System::flush("\n\n<br>Fertig!<br/><hr/>\n");
                }
                $site->clearCache();
            }
        }
    }
}
 
?>