jidaikobo-shibata/a11yc

<?php
/**
 * A11yc\Controller\DataImport
 *
 * @package    part of A11yc
 * @author     Jidaikobo Inc.
 * @license    The MIT License (MIT)
 * @copyright  Jidaikobo Inc.
 * @link       http://www.jidaikobo.com
 */
namespace A11yc\Controller;

use A11yc\Model;

trait DataImport
{
    /**
     * all
     *
     * @return Void
     */
    public static function import()
    {
        if (Input::isPostExists())
        {
            $file = Input::file('import');

            if ( ! file_exists(Arr::get($file, 'tmp_name'))) Util::redirect(A11YC_URL);
            $results = json_decode(file_get_contents($file['tmp_name']), true);

            $is_add = self::addNewSite($results);
            if ($is_add) Model\Version::updateVersions($results['version']);

            foreach ($results['version_keys'] as $version)
            {
                Model\Version::setVersion($version);
                $vals = $results[$version];

                self::importSetting($vals);
                self::importPage($vals);
                self::importResult($vals);
                self::importChecklist($vals);
                self::importIssue($vals);
                self::importIcl($vals);
            }
            Session::add('messages', 'messages', A11YC_LANG_UPDATE_SUCCEED);
        }

        View::assign('title', A11YC_LANG_IMPORT);
        View::assign('body', View::fetchTpl('data/import.php'), FALSE);
    }

    /**
     * add new site
     *
     * @param Array $results
     * @return Bool
     */
    private static function addNewSite($results)
    {
        if ( ! isset($results['base_url'])) return false;

        // add new site
        $new_site = $results['base_url'];
        $sites = Model\Data::fetchSites();

        if (in_array($new_site, $sites))
        {
            Session::add('messages', 'errors', A11YC_LANG_CTRL_ALREADY_EXISTS);
            Util::redirect(A11YC_URL);
        }
        $sites[] = Util::urldec($new_site);
        Model\Data::update('sites', 'global', $sites);
        $group_id = max(array_keys($sites));
        Model\Data::update('group_id', 'global', $group_id, 0, 1);
        Model\Data::setGroupId($group_id);

        return true;
    }

    /**
     * setting
     *
     * @param Array $results
     * @return Void
     */
    private static function importSetting($results)
    {
        if ( ! isset($results['setting'])) return;
        $current = Model\Setting::fetchAll();
        Model\Setting::updateAll(array_merge($current, $results['setting']));
    }

    /**
     * page
     *
     * @param Array $results
     * @return Void
     */
    private static function importPage($results)
    {
        if ( ! isset($results['page'])) return;

        $this_pages = Model\Page::fetchAll();
        $this_pages = array_column($this_pages, 'url');
        foreach ($results['page'] as $vals)
        {
            if (in_array($vals['url'], $this_pages)) continue;
            Model\Page::insert($vals['url'], $vals);
        }

        foreach (Arr::get($results, 'html', array()) as $url => $val)
        {
            if ( ! isset($val)) continue;
            $val = htmlspecialchars_decode($val);
            Model\Html::insert($url, $val);
        }
    }

    /**
     * result
     *
     * @param Array $results
     * @return Void
     */
    private static function importResult($results)
    {
        if ( ! isset($results['result'])) return;

        foreach ($results['result'] as $url => $vals)
        {
            $ins = Model\Result::fetch($url);
            foreach ($vals as $criterion => $val)
            {
                if ( ! isset($ins[$criterion]) || empty($ins[$criterion]))
                {
                    $ins[$criterion] = $val;
                }
            }
            Model\Result::insert($url, $vals);
        }

        // evaluate
        foreach ($results['page'] as $vals)
        {
            $url = $vals['url'];
            Model\Page::updatePartial($url, 'level', Evaluate::getLevelByUrl($url));
        }
    }

    /**
     * checklist
     *
     * @param Array $results
     * @return Void
     */
    private static function importChecklist($results)
    {
        if ( ! isset($results['check'])) return;

        foreach ($results['check'] as $url => $vals)
        {
            $ins = Model\Checklist::fetch($url);
            foreach ($vals as $criterion => $val)
            {
                if (isset($ins[$criterion]))
                {
                    $ins[$criterion] = array_merge($ins[$criterion], $val);
                    continue;
                }
                $ins[$criterion] = $val;
            }
            Model\Checklist::update($url, $ins);
        }
    }

    /**
     * issue
     *
     * @param Array $results
     * @return Void
     */
    private static function importIssue($results)
    {
        if ( ! isset($results['issue'])) return;

        foreach ($results['issue'] as $url => $vals)
        {
            if (empty($vals)) continue;
            foreach ($vals as $val)
            {
                foreach ($val as $v)
                {
                    Model\Issue::insert($url, $v);
                }
            }
        }
    }

    /**
     * icl
     *
     * @param Array $results
     * @return Void
     */
    private static function importIcl($results)
    {
        if ( ! isset($results['icl'])) return;

        Model\Data::deleteByKey('icl');
        Model\Data::deleteByKey('iclsit');
        Model\Setting::update('icl', array());

        $chks = array();
        foreach ($results['icl'] as $v)
        {
            $chks[] = Model\Icl::insert($v, $v['is_sit']);
        }
        Model\Setting::update('icl', $chks);
    }
}