ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / centosnipponia / public_html / ticketing.nipponia.com / ticketing-old / include

<?php
/*********************************************************************
    class.import.php

Utilities for importing objects and data (usually via CSV)

Peter Rotich <peter@osticket.com>
    Jared Hancock <jared@osticket.com>
    Copyright (c)  2006-2015 osTicket
    http://www.osticket.com

Released under the GNU General Public License WITHOUT ANY WARRANTY.
    See LICENSE.TXT for details.

vim: expandtab sw=4 ts=4 sts=4:
**********************************************************************/

class ImportError extends Exception {}
class ImportDataError extends ImportError {}

class CsvImporter {
    // Bytes sequence of common BOM
    const BOMs = array(
                 'UTF8' => "\xEF\xBB\xBF",
                 'UTF16_BE' => "\xFE\xFF",
                 'UTF16_LE' => "\xFF\xFE",
                 'UTF32_BE' => "\x00\x00\xFE\xFF",
                 'UTF32_LE' => "\xFF\xFE\x00\x00");
    var $stream;

function __destruct() {
        fclose($this->stream);
    }

function importCsv($all_fields=array(), $defaults=array()) {
        $named_fields = array();
        $has_header = true;
        foreach ($all_fields as $f)
            if ($f->get('name'))
                $named_fields[$f->get('name')] = $f;

// Read the first row and see if it is a header or not
        if (!($data = fgetcsv($this->stream, 1000, ",", "\"", "")))
            throw new ImportError(__('Whoops. Perhaps you meant to send some CSV records'));

$headers = array();
        foreach (Format::htmlchars($data) as $h) {
            $h = trim($h);
            $found = false;
            foreach ($all_fields as $f) {
                if (in_array(mb_strtolower($h), array(
                        mb_strtolower($f->get('name')), mb_strtolower($f->get('label'))))) {
                    $found = true;
                    if (!$f->get('name'))
                        throw new ImportError(sprintf(__(
                            '%s: Field must have `variable` set to be imported'), Format::htmlchars($h)));
                    $headers[$f->get('name')] = $f->get('label');
                    break;
                }
            }
            if (!$found) {
                $has_header = false;
                if (count($data) == count($named_fields)) {
                    // Number of fields in the user form matches the number
                    // of fields in the data. Assume things line up
                    $headers = array();
                    foreach ($named_fields as $f)
                        $headers[$f->get('name')] = $f->get('label');
                    break;
                }
                else {
                    throw new ImportError(sprintf(
                                __('%s: Unable to map header to the object field'), Format::htmlchars($h)));
                }
            }
        }

if (!$has_header)
            fseek($this->stream, 0);

$objects = $fields = array();
        foreach ($headers as $h => $label) {
            if (!isset($named_fields[$h]))
                continue;

$f = $named_fields[$h];
            $name = $f->get('name');
            $fields[$name] = $f;
        }

// Add default fields (org_id, etc).
        foreach ($defaults as $key => $val) {
            // Don't apply defaults which are also being imported
            if (isset($header[$key]))
                unset($defaults[$key]);
        }

// Avoid reading the entire CSV before yielding the first record.
        // Use an iterator. This will also allow row-level errors to be
        // continuable such that the rows with errors can be handled and the
        // iterator can continue with the next row.
        return new CsvImportIterator($this->stream, $headers, $fields, $defaults);
    }

// Check if a string matches a BOM
    static function isBOM($str) {
        return in_array($str, self::BOMs);
    }
}

class CsvImportIterator
implements Iterator {
    var $stream;
    var $start = 0;
    var $headers;
    var $fields;
    var $defaults;

var $current = true;
    var $row = 0;

function __construct($stream, $headers, $fields, $defaults) {
        $this->stream = $stream;
        $this->start = ftell($stream);
        $this->headers = $headers;
        $this->fields = $fields;
        $this->defaults = $defaults;
    }

// Iterator interface -------------------------------------
    function rewind() {
        @fseek($this->stream, $this->start);
        if (ftell($this->stream) != $this->start)
            throw new RuntimeException('Stream cannot be rewound');
        $this->row = 0;
        $this->next();
    }
    function valid() {
        return $this->current;
    }
    function current() {
        return $this->current;
    }
    function key() {
        return $this->row;
    }

function next() {
        do {
            if (($csv = fgetcsv($this->stream, 4096, ",", "\"", "")) === false) {
                // Read error
                $this->current = false;
                break;
            }

if (count($csv) == 1 && $csv[0] == null)
                // Skip empty rows
                continue;
            elseif (count($csv) != count($this->headers))
                throw new ImportDataError(sprintf(__('Bad data. Expected: %s'),
                    implode(', ', $this->headers)));

// Validate according to field configuration
            $i = 0;
            $this->current = $this->defaults;
            foreach ($this->headers as $h => $label) {
                $f = $this->fields[$h];
                $f->_errors = array();
                $T = $f->parse(trim($csv[$i]));
                if ($f->validateEntry($T) && $f->errors())
                    throw new ImportDataError(sprintf(__(
                        /* 1 will be a field label, and 2 will be error messages */
                        '%1$s: Invalid data: %2$s'),
                        $label, implode(', ', $f->errors())));
                // Convert to database format
                $this->current[$h] = $f->to_database($T);
                $i++;
            }
        }
        // Use the do-loop only for the empty line skipping
        while (false);
        $this->row++;
    }
}

[+] ..
[-] .MANIFEST [edit]
[-] ajax.admin.php [edit]
[-] ajax.config.php [edit]
[-] ajax.content.php [edit]
[-] ajax.draft.php [edit]
[-] ajax.email.php [edit]
[-] ajax.export.php [edit]
[-] ajax.filter.php [edit]
[-] ajax.forms.php [edit]
[-] ajax.i18n.php [edit]
[-] ajax.kbase.php [edit]
[-] ajax.note.php [edit]
[-] ajax.orgs.php [edit]
[-] ajax.plugins.php [edit]
[-] ajax.schedule.php [edit]
[-] ajax.search.php [edit]
[-] ajax.sequence.php [edit]
[-] ajax.staff.php [edit]
[-] ajax.tasks.php [edit]
[-] ajax.thread.php [edit]
[-] ajax.tickets.php [edit]
[-] ajax.tips.php [edit]
[-] ajax.upgrader.php [edit]
[-] ajax.users.php [edit]
[-] api.cron.php [edit]
[-] api.tickets.php [edit]
[-] class.2fa.php [edit]
[-] class.ajax.php [edit]
[-] class.api.php [edit]
[-] class.app.php [edit]
[-] class.attachment.php [edit]
[-] class.auth.php [edit]
[-] class.avatar.php [edit]
[-] class.banlist.php [edit]
[-] class.base32.php [edit]
[-] class.businesshours.php [edit]
[-] class.canned.php [edit]
[-] class.captcha.php [edit]
[-] class.category.php [edit]
[-] class.charset.php [edit]
[-] class.cli.php [edit]
[-] class.client.php [edit]
[-] class.collaborator.php [edit]
[-] class.company.php [edit]
[-] class.config.php [edit]
[-] class.controller.php [edit]
[-] class.cron.php [edit]
[-] class.crypto.php [edit]
[-] class.csrf.php [edit]
[-] class.dept.php [edit]
[-] class.dispatcher.php [edit]
[-] class.draft.php [edit]
[-] class.dynamic_forms.php [edit]
[-] class.email.php [edit]
[-] class.error.php [edit]
[-] class.export.php [edit]
[-] class.faq.php [edit]
[-] class.file.php [edit]
[-] class.filter.php [edit]
[-] class.filter_action.php [edit]
[-] class.format.php [edit]
[-] class.forms.php [edit]
[-] class.http.php [edit]
[-] class.i18n.php [edit]
[-] class.import.php [edit]
[-] class.json.php [edit]
[-] class.knowledgebase.php [edit]
[-] class.list.php [edit]
[-] class.lock.php [edit]
[-] class.log.php [edit]
[-] class.mail.php [edit]
[-] class.mailer.php [edit]
[-] class.mailfetch.php [edit]
[-] class.mailparse.php [edit]
[-] class.message.php [edit]
[-] class.migrater.php [edit]
[-] class.mime.php [edit]
[-] class.misc.php [edit]
[-] class.model.php [edit]
[-] class.nav.php [edit]
[-] class.note.php [edit]
[-] class.oauth2.php [edit]
[-] class.organization.php [edit]
[-] class.orm.php [edit]
[-] class.osticket.php [edit]
[-] class.ostsession.php [edit]
[-] class.page.php [edit]
[-] class.pagenate.php [edit]
[-] class.passwd.php [edit]
[-] class.pdf.php [edit]
[-] class.plugin.php [edit]
[-] class.priority.php [edit]
[-] class.queue.php [edit]
[-] class.report.php [edit]
[-] class.role.php [edit]
[-] class.schedule.php [edit]
[-] class.search.php [edit]
[-] class.sequence.php [edit]
[-] class.session.php [edit]
[-] class.setup.php [edit]
[-] class.signal.php [edit]
[-] class.sla.php [edit]
[-] class.staff.php [edit]
[-] class.task.php [edit]
[-] class.team.php [edit]
[-] class.template.php [edit]
[-] class.thread.php [edit]
[-] class.thread_actions.php [edit]
[-] class.ticket.php [edit]
[-] class.timezone.php [edit]
[-] class.topic.php [edit]
[-] class.translation.php [edit]
[-] class.upgrader.php [edit]
[-] class.user.php [edit]
[-] class.usersession.php [edit]
[-] class.util.php [edit]
[-] class.validator.php [edit]
[-] class.variable.php [edit]
[-] class.xml.php [edit]
[-] class.yaml.php [edit]
[+] cli
[+] client
[+] config
[+] fpdf
[-] html2text.php [edit]
[-] htmLawed.php [edit]
[+] i18n
[-] index.php [edit]
[-] JSON.php [edit]
[+] laminas-mail
[+] mpdf
[-] mysqli.php [edit]
[-] ost-sampleconfig.php [edit]
[-] PasswordHash.php [edit]
[+] pear
[+] plugins
[-] Spyc.php [edit]
[+] staff
[-] tnef_decoder.php [edit]
[-] UniversalClassLoader.php [edit]
[+] upgrader
[-] ost-config.php [edit]
[-] .htaccess.disabled [edit]