<?php/** * OrangeHRM is a comprehensive Human Resource Management (HRM) System that captures * all the essential functionalities required for any enterprise. * Copyright (C) 2006 OrangeHRM Inc., http://www.orangehrm.com * * OrangeHRM is free software; you can redistribute it and/or modify it under the terms of * the GNU General Public License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * OrangeHRM is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along with this program; * if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, * Boston, MA  02110-1301, USA * */require_once ROOT_PATH.'/lib/dao/DMLFunctions.php';require_once ROOT_PATH.'/lib/dao/SQLQBuilder.php';require_once ROOT_PATH.'/lib/confs/sysConf.php';require_once ROOT_PATH.'/lib/common/CommonFunctions.php';require_once ROOT_PATH.'/lib/models/eimadmin/import/CSVImportPlugin.php';require_once ROOT_PATH.'/lib/models/eimadmin/import/CustomizableCSVImport.php';class CSVImport {	/* Import statuses */	const IMPORTED = "IMPORTED";	const IMPORT_ERROR = "IMPORT_ERROR";	const INCORRECT_COLUMN_NUMBER = "INCORRECT_COLUMN_NUMBER";	const SKIPPED_HEADER = "SKIPPED_HEADER";	const MISSING_WORKSTATION = "MISSING_WORKSTATION";	const COMPULSARY_FIELDS_MISSING_DATA = "COMPULSARY_FIELDS_MISSING_DATA";	const DD_DATA_INCOMPLETE = "DD_DATA_INCOMPLETE";	const INVALID_TYPE = "INVALID_TYPE";	const DUPLICATE_EMPLOYEE_ID = "DUPLICATE_EMPLOYEE_ID";	const DUPLICATE_EMPLOYEE_NAME = "DUPLICATE_EMPLOYEE_NAME";	const FIELD_TOO_LONG = "FIELD_TOO_LONG";	/**	 * Class Attributes	 */	private $fileName;	private $importType;	private $importPlugins;	private $pluginDir;	public function setFileName($fileName) {		$this->fileName = $fileName;	}	public function getFileName() {		return $this->fileName;	}	public function setImportType($importType) {		$this->importType = $importType;	}	public function getImportType() {		return $this->importType;	}	/**	 * Constructor	 *	 */	public function __construct() {		$this->pluginDir = ROOT_PATH . '/lib/models/eimadmin/import/plugins';		$this->importPlugins = $this->_getListOfAvailablePlugins();		/* Get user defined imports - defined via the UI.*/		$customImports = CustomImport::getCustomImportList();		foreach ($customImports as $import) {			/* We don't check for any conflicts in key since, plugins have the class name as key*/			$this->importPlugins[$import->getId()] = $import->getName();		}	}	/**	 * Get defined import types	 *	 */	public function getDefinedImportTypes() {		return $this->importPlugins;	}	/**	 * Do the data import	 *	 * @return array Array containing results of import	 */	 public function importData() {		set_time_limit(300); // For handling time out/*		$ir = array();		$ir[] = new ImportResult(self::IMPORT_ERROR, "A comment");		$ir[] = new ImportResult(self::INCORRECT_COLUMN_NUMBER, "Another comment");		$xx = new CSVImportStatus($ir, 3, 1, 1);		return $xx;*/		if (empty($this->importType) || empty($this->fileName)) {			throw new CSVImportException("Import data not received", CSVImportException::IMPORT_DATA_NOT_RECEIVED);		}		$importPlugin = $this->_getPlugin($this->importType);		// Open CSV file and read the data		$row = 0;		$rowsToSkip = $importPlugin->getNumHeaderRows();		$numColumns = $importPlugin->getNumColumns();		$rowsImported = 0;		$rowsWithErrors = 0;		$rowsSkipped = 0;		$importResults = array();		$handle = fopen($this->fileName, "r");		while (($data = fgetcsv($handle)) !== FALSE) {			if ($row >= $rowsToSkip) {				if (count($data) == $numColumns) {					array_walk($data, array('CSVImport', 'trimValue'));					try {						$importPlugin->importCSVData($data);						$importResults[$row] = new ImportResult(self::IMPORTED);						$rowsImported++;					} catch (CSVImportException $e) {						switch ($e->getCode()) {							case CSVImportException::MISSING_WORKSTATION:								$error = self::MISSING_WORKSTATION;								break;							case CSVImportException::DD_DATA_INCOMPLETE:								$error = self::DD_DATA_INCOMPLETE;								break;							case CSVImportException::INVALID_TYPE:								$error = self::INVALID_TYPE;								break;							case CSVImportException::DUPLICATE_EMPLOYEE_ID:								$error = self::DUPLICATE_EMPLOYEE_ID;								break;							case CSVImportException::DUPLICATE_EMPLOYEE_NAME:								$error = self::DUPLICATE_EMPLOYEE_NAME;								break;							case CSVImportException::FIELD_TOO_LONG:								$error = self::FIELD_TOO_LONG;								break;							default:								$error = self::IMPORT_ERROR;						}						$importResults[$row] = new ImportResult($error, $e->getMessage());						$rowsWithErrors++;					} catch (Exception $ee) {						$importResults[$row] = new ImportResult(self::IMPORT_ERROR, $ee->getMessage());						$rowsWithErrors++;					}				} else {					$importResults[$row] = new ImportResult(self::INCORRECT_COLUMN_NUMBER);					$rowsWithErrors++;				}			} else {				$importResults[$row] = new ImportResult(self::SKIPPED_HEADER);				$rowsSkipped++;			}			$row++;		}		fclose($handle);		$result = new CSVImportStatus($importResults, $rowsImported, $rowsWithErrors, $rowsSkipped);		return $result;	 }	 /**	  * Get list of available csv import plugins	  */	 protected function _getListOfAvailablePlugins() {		$plugins = array();		if (is_dir($this->pluginDir)) {			$handle = @opendir($this->pluginDir);			if ($handle) {				$oldDir = getcwd();				chdir($this->pluginDir);				while (false !== ($file = readdir($handle))) {					if (is_file($file)) {						$fileInfo = pathinfo($file);						$className = $fileInfo['basename'];						$extension = $fileInfo['extension'];						if (!empty($extension)) {							$className = str_replace("." . $extension, "", $className);						}						/* Skip any unit test classes (ending with Test) */						if (!(strrpos($className, "Test") === strlen($className) - 4)) {							require_once $this->pluginDir . "/" . $file;							$object = new $className;							if ($object instanceof CSVImportPlugin) {								$pluginName = $object->getName();								$plugins[$className] = $pluginName;							}						}					}    			}				closedir($handle);				chdir($oldDir);			}		}		return $plugins;	 }	/* Used to trim array */	public static function trimValue(& $value) {		$value = trim($value);	}	 private function _getPlugin($type) {		/* If the type is an ID, get the customizable CSV Import class */		if (CommonFunctions::isValidId($type)) {			$object = new CustomizableCSVImport($type);		} else {			require_once $this->pluginDir . "/" . $type . ".php";			$object = new $type;		}		return $object;	 }}class ImportResult {	private $status;	private $comments;	public function __construct($status, $comments = "") {		$this->status = $status;		$this->comments = $comments;	}	public function getStatus() {		return $this->status;	}	public function getComments() {		return $this->comments;	}}class CSVImportStatus {	private $importResults;	private $numImported;	private $numFailed;	private $numSkipped;	public function __construct($importResults, $numImported, $numFailed, $numSkipped) {		$this->importResults = $importResults;		$this->numImported = $numImported;		$this->numFailed = $numFailed;		$this->numSkipped = $numSkipped;	}	public function getImportResults() {		return $this->importResults;	}	public function getNumImported() {		return $this->numImported;	}	public function getNumFailed() {		return $this->numFailed;	}	public function getNumSkipped() {		return $this->numSkipped;	}}?>