<?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 getFlightBookingListCustomer($tablename, $CustomerSysId = null, $currentDate = null)
	{
		if ($CustomerSysId) {
			$select = $this->db->select()->from("$tablename", "*");

			$select->where('CustomerSysId IN(?)', $CustomerSysId);

			if ($currentDate) {
				$select->where("TravelDate < " . new Zend_Db_Expr('NOW()'));
				//$select->where('TravelDate <', $currentDate);
			}

			//$select->where("parent_id",0);
			$select->where("status", 1);
			$select->where("IsMarkForDel", 0);
			$select->order("id DESC");
			//$select->group("BookingId");
			$result = $this->db->fetchAll($select);

			//$data = array('BookingData'=>$result,'booking_room'=>$booking_room,'Guest'=>$passenger);
			return $result;
		} else {
			return [];
		}
	}

	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 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");
		}

		$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 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";
	}
	
	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 sendSmsDetails($url, $strPostReq, $arrSMSStatistics = array(), $IsSMSApi = 1,$SearchParam)
    {
        $strBuffer = array();
        parse_str($strPostReq, $get_array);
        $prepareJson = array(
            'sender' => $get_array['sender'],
            'message' => $get_array['message'],
            'unicode' => 0,
            'sms' => array(
                array(
                    'to' => $get_array['to']
                )
            )
        );
        // echo '<pre>';
        // print_r($prepareJson);
        $jsonData = json_encode($prepareJson);
        $api_url = $url . '?method=sms.json&api_key=' . $get_array['api_key'] . '&format=xml&json=' . urlencode($jsonData);
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $api_url);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        $strBuffer = curl_exec($ch);
        curl_close($ch);
        $response = json_decode($strBuffer, true);
        
        $strFilePath = "flight/SearchParam/" . $SearchParam . '/OTPuse/' . date('Y-m-d-H-i-s') . "_request.json";
        Zend_Controller_Action_HelperBroker::getStaticHelper("General")->createApiCallLogs($strFilePath, $jsonData);
        
        $strFilePath = "flight/SearchParam/" . $SearchParam . '/OTPuse/' . date('Y-m-d-H-i-s'). "_response.json";
        Zend_Controller_Action_HelperBroker::getStaticHelper("General")->createApiCallLogs($strFilePath, $strBuffer);
        
        if (isset($response['status']) && $response['status'] == "OK") {
            $returnValArray['status'] = "OK";
            $returnValArray['Message'] = "success";
        } else {
            $returnValArray['status'] = "Fail";
            $returnValArray['Message'] = "check again";
        }
    }

	public function getflightAirportData($AirportCode)
	{

		$select = $this->db->select()->from("tbl_flight_airport_code");
		$select->where("AirportCode=?", $AirportCode);
		$select->order("AirId", 'DESC');
		$result = $this->db->fetchAll($select);
		return $result;
	}

	public function CheckPaymentSTatus($tablename, $apiTraceId,$journeyType=null) {
        $select = $this->db->select()->from("$tablename", "*");
        $select->where("apiTraceId=?", "$apiTraceId");
        if($journeyType){
            $select->where("JourneyType=?",$journeyType);
        }
        $select->where("IsMarkForDel",0);
        $select->order("id", 'ASC');
        $result = $this->db->fetchRow($select);
        return $result;
    }
	public function checkFlightOTP($apiTraceId)
    {
        $selectp = $this->db->select()->from("tbl_flight_booking", "generateOTP");
        $selectp->where("apiTraceId=?", "$apiTraceId");
        $selectp->where("IsMarkForDel", 0);
       $selectp->order("id", 'ASC');
        //echo $selectp;die;
        $passenger = $this->db->fetchRow($selectp);
        return $passenger;
    }
    public function checkBookingPrice($apiTraceId)
    {
        $selectp = $this->db->select()->from("tbl_flight_booking", ["generateOTP","PublishedFare","BagPrice","MealPrice","SeatPrice"]);
        $selectp->where("apiTraceId=?", "$apiTraceId");
        $selectp->where("IsMarkForDel", 0);
        $selectp->order("id", 'ASC');
        $passenger = $this->db->fetchAll($selectp);
        return $passenger;
    }

	public function insertFlightTempData($data)
    {
        $this->db->insert('tbl_temp_data', $data);
        return $this->db->lastInsertId('tbl_temp_data');
    }
    public function GetFlightTempData($traceId)
    {
        $arr = array('json_data', 'created_at');
        $select = $this->db->select();
        $select->from(array('TP' => "tbl_temp_data"), $arr);
        $select->where("TP.TraceId = ?", $traceId);
        $result = $this->db->fetchRow($select);
        return $result;
    }
	public function deleteFlightTempData($TraceId)
    {
        $where = array('TraceId = ? ' => $TraceId);
        $this->db->delete('tbl_temp_data', $where);
    }

	public function DBConnect() {
		return $this->db;
	}

}