<?php

class Travel_Model_FlightMaster {

	protected $db = NULL;
	public $intId = NULL;

	/*     * ************************************ */

	public function __construct() {
		$request = Zend_Controller_Front::getInstance()->getRequest();
		$this->baseUrl = $request->getScheme() . '://' . $request->getHttpHost();
		$this->db = Zend_Db_Table::getDefaultAdapter();

	}

	public function __destruct() {
		$this->db->closeConnection();
	}
	/* Added By Pardeep Panchal Ends */

	public function InsertFlightData($tablename, array $addData) {
		$dbtable = new Zend_Db_Table($tablename);
		return $dbtable->insert($addData);
	}
	public function UpdateFlightData($tablename, array $addData, $where) {
		return $this->db->update($tablename, $addData, $where);
//        return $dbtable->insert($addData);
	}
	/*public function SearchFlightCustomer($tablename, array $param) {
		        $leadMobile = $param['leadMobile'];
		        $term = $param['term'];
		        $select = $this->db->select()->from("$tablename", "*");
		        $select->where("Contacts=?", "$leadMobile");
		        $select->where('EmailId LIKE ?', "%$term%");
		        $select->where("IsMarkForDel",0);
		        $select->where("IsActive", 1);
		        $result = $this->db->fetchAll($select);
		        return $result;
	*/
	public function SearchFlightCustomer($tablename, array $param) {
		$leadMobile = $param['leadMobile'];
		$leadEmail = $param['leadEmail'];
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("Contacts=?", "$leadMobile");
		$select->where('EmailId=?', $leadEmail);
		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$result = $this->db->fetchAll($select);
		return $result;
	}
        public function SearchFlightCustomerMember($tablename, array $param) {
		$FirstName = $param['FirstName'];
		$Relation = $param['Relation'];
		$CustomerSysId = $param['CustomerSysId'];
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("FirstName=?", "$FirstName");
		$select->where('Relation=?', $Relation);
		$select->where('CustomerSysId=?', $CustomerSysId);
		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$result = $this->db->fetchAll($select);
		return $result;
	}
	public function GetFlightCustomerMember($tablename, array $param) {
		$CustomerSysId = $param['CustomerSysId'];
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("CustomerSysId=?", "$CustomerSysId");
		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$select->order("paxType", 'ASC');
		$result = $this->db->fetchAll($select);
		return $result;
	}
	public function CheckCustomer($tablename, array $param) {
		$select = $this->db->select()->from("$tablename", "*");
		if (isset($param['CustomerSysId']) && !empty($param['CustomerSysId'])) {
			$CustomerSysId = $param['CustomerSysId'];
			$select->where("CustomerSysId=?", "$CustomerSysId");
		}
		if (isset($param['Contacts']) && !empty($param['Contacts'])) {
			$Contacts = $param['Contacts'];
			$select->where("Contacts=?", "$Contacts");
		}
		if (isset($param['EmailId']) && !empty($param['EmailId'])) {
			$EmailId = $param['EmailId'];
			$select->where("EmailId=?", "$EmailId");
		}
		if (isset($param['apiTraceId']) && !empty($param['apiTraceId'])) {
			$apiTraceId = $param['apiTraceId'];
			$select->where("apiTraceId=?", "$apiTraceId");
		}

		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$select->order("paxType", 'ASC');
		$result = $this->db->fetchRow($select);
		return $result;
	}
	public function CheckMember($tablename, array $param) {
		$CustomerSysId = $param['CustomerMemberSysId'];
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("CustomerMemberSysId=?", "$CustomerSysId");
		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$select->order("paxType", 'ASC');
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function GetFlightBookingData($tablename, array $param) {
		$CustomerSysId = $param['CustomerSysId'];
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("CustomerSysId=?", "$CustomerSysId");
		$select->where("parent_id=?", 0);
		$select->where("status=?", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'DESC');
		$result = $this->db->fetchAll($select);
		return $result;
	}
	public function FlightBookingData($tablename, $apiTraceId, $journeyType = null) {
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("apiTraceId=?", "$apiTraceId");
		if ($journeyType) {
			$select->where("JourneyType=?", $journeyType);
		}
//        $select->where("parent_id=?",0);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		$result = $this->db->fetchRow($select);
		$resultReturn = [];
		$passenger = [];
		if ($result) {
			if (empty($journeyType)) {
				$parent_id = $result['id'];
				$selectr = $this->db->select()->from("$tablename", "*");
				$selectr->where("apiTraceId=?", "$apiTraceId");
				$selectr->where("parent_id=?", "$parent_id");
				$selectr->where("IsMarkForDel", 0);
				$selectr->order("id", 'ASC');
				$resultReturn = $this->db->fetchRow($selectr);
			}

			$selectp = $this->db->select()->from("tbl_flight_booking_customer", "*");
			$selectp->where("apiTraceId=?", "$apiTraceId");
			$selectp->where("IsMarkForDel", 0);
			$selectp->order("id", 'ASC');
			$passenger = $this->db->fetchAll($selectp);
		}
		$data = array('onward' => $result, 'return' => $resultReturn, 'passenger' => $passenger);
		return $data;
	}

	public function FlightBookingDataTripJack($tablename, $bookingId, $journeyType = null) {
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("bookingId=?", "$bookingId");
		if ($journeyType) {
			$select->where("JourneyType=?", $journeyType);
		}
//        $select->where("parent_id=?",0);
		$select->where("status", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		$result = $this->db->fetchRow($select);
		$passenger = [];
		if ($result) {
			$selectp = $this->db->select()->from("tbl_flight_booking_customer", "*");
			$selectp->where("bookingId=?", "$bookingId");
			$selectp->where("IsMarkForDel", 0);
			$selectp->order("id", 'ASC');
			$passenger = $this->db->fetchAll($selectp);
		}
		$data = array('data' => $result, 'passenger' => $passenger);
		return $data;
	}

    public function FlightCancelDataTripJack($tablename, $bookingId, $ChangeRequestId = null)
    {
        $select = $this->db->select()->from("$tablename", "*");
        $select->where("bookingId=?", "$bookingId");
        if ($ChangeRequestId) {
            $select->where("ChangeRequestId=?", $ChangeRequestId);
        }

        //$select->where("parent_id=?",0);
        //$select->where("status", 1);
        $select->where("IsMarkForDel", 0);
        $select->order("id", 'ASC');
        $result = $this->db->fetchRow($select);
        $passenger = [];
        if ($result) {
            $selectp = $this->db->select()->from("tbl_flight_booking_customer", "*");
            $selectp->where("bookingId=?", "$bookingId");
            if ($ChangeRequestId) {
                $selectp->where("ChangeRequestId=?", $ChangeRequestId);
            }
            $selectp->where("IsMarkForDel", 0);
            $selectp->order("id", 'ASC');
            $passenger = $this->db->fetchAll($selectp);
        }
        $data = array('data' => $result, 'passenger' => $passenger);
        return $data;
    }

	public function GetCustomerData($tablename, $CustomerSysId = null, $mobile = null, $email = null, $gtxagencysysid = null) {
		$select = $this->db->select()->from("$tablename", "*");
       // $select->where("CustomerSysId=?", "$CustomerSysId");
		if (!empty($CustomerSysId)) {
			$select->where("CustomerSysId=?", "$CustomerSysId");
		}
		if (!empty($mobile)) {
			$select->where("Contacts=?", "$mobile");
		}
		if (!empty($email)) {
			$select->where("EmailId=?", "$email");
		}
		if (!empty($gtxagencysysid)) {
			$select->where("AgencySysId=?", "$gtxagencysysid");
		}
		$select->where("IsMarkForDel", 0);
		$select->where("IsActive", 1);
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function getHotelsBookingList($tablename, $CustomerSysId=null,$cancel=null) {
        $select = $this->db->select()->from("$tablename", "*");
        if($CustomerSysId){
            $select->where("CustomerSysId=?",$CustomerSysId);
        }
        if($cancel){
            $select->where("IsCancelled=?",$cancel);
        }
        
        $select->where("status",1);
        $select->where("IsMarkForDel",0);
        $select->order("id DESC");
        $result = $this->db->fetchAll($select);
        
        //$data = array('BookingData'=>$result,'booking_room'=>$booking_room,'Guest'=>$passenger);
        return $result;
	}
	
	public function getFlightBookingList($tablename, $CustomerSysId=null,$currentDate=null) {
        //print_r($currentDate);die;
        $select = $this->db->select()->from("$tablename", "*");
        if($CustomerSysId){
            $select->where('CustomerSysId IN(?)', $CustomerSysId);
        }
        if($currentDate){
            $select->where("TravelDate < ".new Zend_Db_Expr('NOW()'));
            //$select->where('TravelDate <', $currentDate);
        }
        
        $select->where("status",1);
        $select->where("IsMarkForDel",0);
        $select->order("id DESC");
        $result = $this->db->fetchAll($select);
        
        //$data = array('BookingData'=>$result,'booking_room'=>$booking_room,'Guest'=>$passenger);
        return $result;
    }

	public function DBConnect() {
		return $this->db;
	}
	public function getInvoice($table){
		$select = $this->db->select()->from("$table", "*");
		$select->order("id DESC");
		$select->limit(1);
		$result = $this->db->fetchRow($select);
		return $result;
		//$query ="SELECT * FROM Table ORDER BY ID DESC LIMIT 1";
	}

}