genimport_main.php

Go to the documentation of this file.

<?php

class GenImport_Main extends oxAdminDetails
{
    public $sClassDo   = "genImport_do";

    public $sClassMain = "genImport_main";

    protected $_sCsvFilePath = null;

    protected $_sStringTerminator = null;

    protected $_sStringEncloser = null;

    protected $_sDefaultStringTerminator = ";";

    protected $_sDefaultStringEncloser = '"';

    protected $_sThisTemplate = "genimport_main.tpl";

    public function render()
    {
        $oConfig = $this->getConfig();

        $oErpImport = new oxErpGenImport();
        $this->_sCsvFilePath = null;

        $sNavStep = $oConfig->getParameter( 'sNavStep' );

        if ( !$sNavStep ) {
            $sNavStep = 1;
        } else {
            $sNavStep++;
        }


        $sNavStep = $this->_checkErrors( $sNavStep );

        if ( $sNavStep == 1 ) {
            $this->_aViewData['sGiCsvFieldTerminator'] = htmlentities( $this->_getCsvFieldsTerminator() );
            $this->_aViewData['sGiCsvFieldEncloser']   = htmlentities( $this->_getCsvFieldsEncolser() );
        }

        if ( $sNavStep == 2 ) {
            //saving csv field terminator and encloser to config
            if ( $sTerminator = $oConfig->getParameter( 'sGiCsvFieldTerminator' ) ) {
                $this->_sStringTerminator = $sTerminator;
                $oConfig->saveShopConfVar( 'str', 'sGiCsvFieldTerminator', $sTerminator );
            }

            if ( $sEncloser = $oConfig->getParameter( 'sGiCsvFieldEncloser' ) ) {
                $this->_sStringEncloser = $sEncloser;
                $oConfig->saveShopConfVar( 'str', 'sGiCsvFieldEncloser', $sEncloser );
            }

            $sType = $oConfig->getParameter( 'sType' );
            $oType = $oErpImport->getImportObject( $sType );
            $this->_aViewData['sType'] = $sType;
            $this->_aViewData['sImportTable'] =  $oType->getBaseTableName();
            $this->_aViewData['aCsvFieldsList'] = $this->_getCsvFieldsNames();
            $this->_aViewData['aDbFieldsList'] = $oType->getFieldList();
        }

        if ( $sNavStep == 3 ) {
            $aCsvFields = $oConfig->getParameter( 'aCsvFields' );
            $sType = $oConfig->getParameter( 'sType' );

            $oErpImport = new oxErpGenImport();
            $oErpImport->setImportTypePrefix( $sType );
            $oErpImport->setCsvFileFieldsOrder( $aCsvFields );
            $oErpImport->setCsvContainsHeader( oxSession::getVar( 'blCsvContainsHeader' ) );

            $oErpImport->doImport( $this->_getUploadedCsvFilePath() );
            $this->_aViewData['iTotalRows'] = $oErpImport->getTotalImportedRowsNumber();

            //checking if errors occured during import
            $this->_checkImportErrors( $oErpImport );

            //deleting uploaded csv file from temp dir
            $this->_deleteCsvFile();

            //check if repeating import - then forsing first step
            if ( $oConfig->getParameter( 'iRepeatImport' ) ) {
                $this->_aViewData['iRepeatImport'] = 1;
                $sNavStep = 1;
            }
        }

        if ( $sNavStep == 1 ) {
            $this->_aViewData['aImportTables'] = $oErpImport->getImportObjectsList();
            asort( $this->_aViewData['aImportTables'] );
            $this->_resetUploadedCsvData();
        }

        $this->_aViewData['sNavStep'] = $sNavStep;

        return parent::render();
    }

    protected function _deleteCsvFile()
    {
        $sPath = $this->_getUploadedCsvFilePath();
        if ( is_file( $sPath ) ) {
           @unlink( $sPath );
        }
    }

    protected function _getCsvFieldsNames()
    {
        $blCsvContainsHeader = $this->getConfig()->getParameter( 'blContainsHeader' );
        oxSession::setVar( 'blCsvContainsHeader', $blCsvContainsHeader );
        $sCsvPath = $this->_getUploadedCsvFilePath();

        $aFirstRow = $this->_getCsvFirstRow();

        if ( !$blCsvContainsHeader ) {
            $iIndex = 1;
            foreach ( $aFirstRow as $sValue ) {
                $aCsvFields[$iIndex] = 'Column ' . $iIndex++;
            }
        } else {
            foreach ( $aFirstRow as $sKey => $sValue ) {
                $aFirstRow[$sKey] = htmlentities( $sValue );
            }

            $aCsvFields = $aFirstRow;
        }

        return $aCsvFields;
    }

    protected function _getCsvFirstRow()
    {
        $sPath = $this->_getUploadedCsvFilePath();
        $iMaxLineLength = 8192;

        //getting first row
        if ( ( $rFile = @fopen( $sPath, "r" ) ) !== false ) {
            $aRow = fgetcsv( $rFile, $iMaxLineLength, $this->_getCsvFieldsTerminator(), $this->_getCsvFieldsEncolser() );
            fclose( $rFile );
        }

        return $aRow;
    }

    protected function _resetUploadedCsvData()
    {
        $this->_sCsvFilePath = null;
        oxSession::setVar( 'sCsvFilePath', null );
        oxSession::setVar( 'blCsvContainsHeader', null );
    }

    protected function _checkErrors( $iNavStep )
    {
        if ( $iNavStep == 2 ) {
            if ( !$this->_getUploadedCsvFilePath() ) {
                $oEx = new oxExceptionToDisplay();
                $oEx->setMessage( 'GENIMPORT_ERRORUPLOADINGFILE' );
                oxUtilsView::getInstance()->addErrorToDisplay( $oEx, false, true, 'genimport' );
                $iNavStep = 1;
            }
        }

        if ( $iNavStep == 3 ) {
            $blIsEmpty = true;
            $aCsvFields = $this->getConfig()->getParameter( 'aCsvFields' );
            foreach ( $aCsvFields as $sValue ) {
                if ( $sValue ) {
                   $blIsEmpty = false;
                   break;
                }
            }

            if ( $blIsEmpty ) {
                $oEx = new oxExceptionToDisplay();
                $oEx->setMessage( 'GENIMPORT_ERRORASSIGNINGFIELDS' );
                oxUtilsView::getInstance()->addErrorToDisplay( $oEx, false, true, 'genimport' );
                $iNavStep = 2;
            }
        }

        return $iNavStep;
    }

    protected function _getUploadedCsvFilePath()
    {
        //try to get uploaded csv file path
        if ( $this->_sCsvFilePath !== null ) {
            return $this->_sCsvFilePath;
        } elseif ( $this->_sCsvFilePath = oxSession::getVar( 'sCsvFilePath' ) ) {
            return $this->_sCsvFilePath;
        }

        $oConfig = $this->getConfig();
        $aFile = $oConfig->getUploadedFile( 'csvfile' );
        if ( isset( $aFile['name'] ) && $aFile['name'] ) {
            $this->_sCsvFilePath = $oConfig->getConfigParam( 'sCompileDir' ) . basename( $aFile['tmp_name'] );
            move_uploaded_file( $aFile['tmp_name'], $this->_sCsvFilePath );
            oxSession::setVar( 'sCsvFilePath', $this->_sCsvFilePath );
            return $this->_sCsvFilePath;
        }
    }

    protected function _checkImportErrors( $oErpImport )
    {
        foreach ( $oErpImport->getStatistics() as $aValue ) {
            if ( !$aValue ['r'] ) {
                $oEx = new oxExceptionToDisplay();
                $oEx->setMessage( $aValue ['m'] );
                oxUtilsView::getInstance()->addErrorToDisplay( $oEx, false, true, 'genimport' );
            }
        }

    }

    protected function _getCsvFieldsTerminator()
    {
        if ( $this->_sStringTerminator === null ) {
            $this->_sStringTerminator = $this->_sDefaultStringTerminator;
            if ( $sChar = $this->getConfig()->getConfigParam( 'sGiCsvFieldTerminator' ) ) {
                $this->_sStringTerminator = $sChar;
            }
        }
        return $this->_sStringTerminator;
    }

    protected function _getCsvFieldsEncolser()
    {
        if ( $this->_sStringEncloser === null ) {
            $this->_sStringEncloser = $this->_sDefaultStringEncloser;
            if ( $sChar = $this->getConfig()->getConfigParam( 'sGiCsvFieldEncloser' ) ) {
                $this->_sStringEncloser = $sChar;
            }
        }
        return $this->_sStringEncloser;
    }
}