workshift.php

国外的人才求职招聘最新版

<?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/common/CommonFunctions.php";
require_once ROOT_PATH."/lib/models/hrfunct/EmpInfo.php";

class Workshift {

	const WORKSHIFT_TABLE = "hs_hr_workshift";
	const EMPLOYEE_WORKSHIFT_TABLE = "hs_hr_employee_workshift";
	const DB_FIELD_WORKSHIFT_ID = "workshift_id";
	const DB_FIELD_NAME = "name";
	const DB_FIELD_HOURS = "hours_per_day";
	const DB_FIELD_EMP_NUMBER = "emp_number";


	private $workshiftId;
	private $name;
	private $hoursPerDay;

	/**
	 * Construct workshift object
	 */
	public function __constructor() {

	}

	/**
	 * Get workshift Id
	 */
	public function getWorkshiftId() {
		return $this->workshiftId;
	}

	/**
	 * Set workshift Id
	 * @param int $workshiftId work shift id
	 */
	public function setWorkshiftId($workshiftId) {
		$this->workshiftId = $workshiftId;
	}

	/**
	 * Get name
	 */
	public function getName() {
		return $this->name;
	}

	/**
	 * Sets worksheet name
	 * @param string $name work sheet name
	 */
	public function setName($name) {
		$this->name = $name;
	}

	/**
	 * Get hours per day
	 * @return hours per day
	 */
	public function getHoursPerDay() {
		return $this->hoursPerDay;
	}

	/**
	 * Set hours per day
	 * @param int $hoursPerDay hours per day
	 */
	public function setHoursPerDay($hoursPerDay) {
		$this->hoursPerDay = $hoursPerDay;
	}

	/**
	 * Save this workshift
	 * @return int number of rows changed (1 if update was done, 0 if not)
	 */
	public function save() {
		if (empty($this->hoursPerDay) || empty($this->name) || $this->hoursPerDay <= 0) {
			throw new WorkshiftException("Values not set", WorkshiftException::VALUES_EMPTY_OR_NOT_SET);
		}

		if (empty($this->workshiftId)) {
			return $this->_insert();
		} else {
			return $this->_update();
		}
	}

	private function _insert() {

		$fields[0] = self::DB_FIELD_WORKSHIFT_ID;
		$fields[1] = self::DB_FIELD_NAME;
		$fields[2] = self::DB_FIELD_HOURS;

		$this->workshiftId = UniqueIDGenerator::getInstance()->getNextID(self::WORKSHIFT_TABLE, self::DB_FIELD_WORKSHIFT_ID);
		$values[0] = $this->workshiftId;
		$values[1] = "'{$this->name}'";
		$values[2] = "'{$this->hoursPerDay}'";

		$sqlBuilder = new SQLQBuilder();
		$sqlBuilder->table_name = self::WORKSHIFT_TABLE;
		$sqlBuilder->flg_insert = 'true';
		$sqlBuilder->arr_insert = $values;
		$sqlBuilder->arr_insertfield = $fields;

		$sql = $sqlBuilder->addNewRecordFeature2();

		$dbConnection = new DMLFunctions();
		$result = $dbConnection->executeQuery($sql);
		if (!$result) {
			throw new WorkshiftException("Workshift not inserted", WorkshiftException::ERROR_IN_DB_QUERY);
		}

		if (mysql_affected_rows() != 1) {
			throw new WorkshiftException("Workshift not inserted", WorkshiftException::INVALID_ROW_COUNT);
		}

		return mysql_affected_rows();
	}

	private function _update() {

		$updateTable = self::WORKSHIFT_TABLE;

		$fields[0] = self::DB_FIELD_NAME;
		$fields[1] = self::DB_FIELD_HOURS;

		$updateValues[0] = "'" . $this->name . "'";
		$updateValues[1] = $this->hoursPerDay;

		$updateConditions[0] = self::DB_FIELD_WORKSHIFT_ID . " = " . $this->workshiftId;

		$sqlBuilder = new SQLQBuilder();
		$query = $sqlBuilder->simpleUpdate($updateTable, $fields, $updateValues, $updateConditions);
		$dbConnection = new DMLFunctions();

		$result = $dbConnection->executeQuery($query);
		if ($result === false) {
			throw new WorkshiftException("Error in update", WorkshiftException::ERROR_IN_DB_QUERY);
		}

		return mysql_affected_rows();
	}

	/**
	 * Delete this workshift
	 */
	public function delete() {

		if (!CommonFunctions::isValidId($this->workshiftId)) {
			throw new WorkshiftException("Invalid id", WorkshiftException::INVALID_ID);
		}

		$arrList = array($this->workshiftId);
		$count = self::_deleteWorkshifts($arrList);

		if (mysql_affected_rows() !== 1) {
			throw new WorkshiftException("Error in Delete", WorkshiftException::INVALID_ROW_COUNT);
		}

	}

	private static function _deleteWorkshifts($ids) {

		$tableName = self::WORKSHIFT_TABLE;
		$arrFieldList[0] = self::DB_FIELD_WORKSHIFT_ID;

		$sqlBuilder = new SQLQBuilder();

		$sqlBuilder->table_name = $tableName;
		$sqlBuilder->flg_delete = 'true';
		$sqlBuilder->arr_delete = $arrFieldList;

		$arrList[] = $ids;
		$sqlQString = $sqlBuilder->deleteRecord($arrList);

		$dbConnection = new DMLFunctions();
		$result = $dbConnection->executeQuery($sqlQString);

		if ($result) {
			return mysql_affected_rows();
		} else {
			throw new WorkshiftException("Error in SQL Query", WorkshiftException::ERROR_IN_DB_QUERY);
		}
	}

	/**
	 * Assign employees to this workshift
	 * @param array $employeeIds Array of employee ids to assign
	 */
	public function assignEmployees($empNumbers) {

		if (!CommonFunctions::isValidId($this->workshiftId)) {
			throw new WorkshiftException("Invalid workshift id: ". $this->workshiftId, WorkshiftException::INVALID_ID);
		}

		// Filter out non-valid employee numbers
		$empNumbers = array_filter($empNumbers, array("CommonFunctions", "isValidId"));

		if (count($empNumbers) == 0) {
			return 0;
		}

		$empNumberList = implode(",", $empNumbers);

		$sql = "INSERT IGNORE INTO " . self::EMPLOYEE_WORKSHIFT_TABLE . "(" . self::DB_FIELD_WORKSHIFT_ID . ", " . self::DB_FIELD_EMP_NUMBER .") " .
		       "SELECT b." . self::DB_FIELD_WORKSHIFT_ID . ", a." . EmpInfo::EMPLOYEE_FIELD_EMP_NUMBER . " " .
		       "FROM " . EmpInfo::EMPLOYEE_TABLE_NAME . " a, " . self::WORKSHIFT_TABLE . " b " .
		       "WHERE a." . EmpInfo::EMPLOYEE_FIELD_EMP_NUMBER . " IN (" . $empNumberList . ") AND " .
		       " b." . self::DB_FIELD_WORKSHIFT_ID . " = " . $this->workshiftId;

		$conn = new DMLFunctions();
		$results = $conn->executeQuery($sql);

		if ($results === false) {
			throw new WorkshiftException("Error in db query:" . $sql . ": " . mysql_error(), WorkshiftException::ERROR_IN_DB_QUERY);
		}

		return mysql_affected_rows();
	}

	/**
	 * Get workshift for given employee
	 *
	 * @param int $empNumber The employee number
	 * @return Workshift Workshift for employee or null if no workshift assigned
	 */
	public static function getWorkshiftForEmployee($empNumber) {

		if (!CommonFunctions::isValidId($empNumber)) {
			throw new WorkshiftException("Invalid emp number: $empNumber", WorkshiftException::INVALID_ID);
		}

		$fields[0] = "a.`" . self::DB_FIELD_WORKSHIFT_ID . "`";
		$fields[1] = "a.`" . self::DB_FIELD_NAME . "`";
		$fields[2] = "a.`" . self::DB_FIELD_HOURS . "`";

		$tables[0] = "`" . self::WORKSHIFT_TABLE . "` a ";
		$tables[1] = "`" . self::EMPLOYEE_WORKSHIFT_TABLE . "` b ";

		$joinConditions[1] = "a." . self::DB_FIELD_WORKSHIFT_ID .
							 " = b." . self::DB_FIELD_WORKSHIFT_ID;

		$selectConditions[0] = " b." . self::DB_FIELD_EMP_NUMBER . " = " . $empNumber;

		$sqlBuilder = new SQLQBuilder();
		$sql = $sqlBuilder->selectFromMultipleTable($fields, $tables, $joinConditions, $selectConditions);

		$conn = new DMLFunctions();
		$results = $conn->executeQuery($sql);

		if ($results === false) {
			throw new WorkshiftException("Error in db query:" . $sql, WorkshiftException::ERROR_IN_DB_QUERY);
		}