genimport_main.php

Go to the documentation of this file.

<?php

class GenImport_Main extends oxAdminDetails
{
    public $sClass_do   = "genImport_do";
    public $sClass_main = "genImport_main";

    protected $_sCsvFilePath;

    protected $_sStringTerminator = null;

    protected $_sStringEncloser = null;

    protected $_sDefaultStringTerminator = ";";

    protected $_sDefaultStringEncloser = '"';

    protected $_sThisTemplate = "genimport_main.tpl";

    public function render()
    {

        $oConfig = $this->getConfig();
        $oSession = $this->getSession();

        $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( $oSession->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' );
        $this->getSession()->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
        $file = fopen($sPath, "r");
        if (isset($file) && $file) {
            $aRow = fgetcsv( $file, $iMaxLineLength, $this->_getCsvFieldsTerminator(), $this->_getCsvFieldsEncolser());
            fclose( $file );
        }

        return $aRow;
    }

    protected function _resetUploadedCsvData()
    {
        $this->_sCsvFilePath = null;
        $oSession = $this->getSession();
        $oSession->setVar( 'sCsvFilePath', null );
        $oSession->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()
    {
        $oConfig = $this->getConfig();
        $oSession = $this->getSession();

        //try to get uploaded csv file path
        if ( !empty( $this->_sCsvFilePath ) ) {
            return $this->_sCsvFilePath;
        } elseif ( $this->_sCsvFilePath = $oSession->getVar( 'sCsvFilePath' ) ) {
            return $this->_sCsvFilePath;
        }

        $aFile = $oConfig->getUploadedFile('csvfile');
        if ( isset( $aFile['name'] ) && !empty($aFile['name']) ) {
            $this->_sCsvFilePath = $oConfig->getConfigParam( 'sCompileDir' ) . "/" . basename( $aFile['tmp_name'] );
            move_uploaded_file( $aFile['tmp_name'], $this->_sCsvFilePath );
            $oSession->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 ) {
            return $this->_sStringTerminator;
        }

        if ( $sChar = $this->getConfig()->getConfigParam( 'sGiCsvFieldTerminator' ) ) {
            return $this->_sStringTerminator = $sChar;
        } else {
            return $this->_sDefaultStringTerminator;
        }
    }

    protected function _getCsvFieldsEncolser()
    {
        if ( $this->_sStringEncloser ) {
            return $this->_sStringEncloser;
        }

        if ( $sChar = $this->getConfig()->getConfigParam( 'sGiCsvFieldEncloser' ) ){
            return $this->_sStringEncloser = $sChar;
        } else {
            return $this->_sDefaultStringEncloser;
        }
    }
}

---