<?php

class Travel_Model_FlightMaster
{

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

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

	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->where("IsApproved=?", 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 CheckPaymentSTatusHotel($tablename, $apiTraceId)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("TraceId=?", "$apiTraceId");

		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function CheckPaymentSTatus($tablename, $apiTraceId, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$TraceId = explode(',', $apiTraceId);
		//$select->where("apiTraceId=?", "$apiTraceId");
		$select->where('apiTraceId IN(?)', $TraceId);
		if ($journeyType) {
			$select->where("JourneyType=?", $journeyType);
		}
		//        $select->where("parent_id=?",0);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		$result = $this->db->fetchRow($select);
		return $result;
	}
	public function getbookingbyId($tablename, $id, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("id=?", "$id");
		
		$select->where("IsMarkForDel", 0);
		$select->order("id", '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 HotelBookingDataTripJack($tablename, $bookingId, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("TraceId=?", "$bookingId");

		//$select->where("parent_id=?",0);
		//$select->where("status", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		$result = $this->db->fetchRow($select);
		//echo"<pre>";print_r($result);exit;
		$passenger = [];
		if ($result) {
			$selectp = $this->db->select()->from("tbl_hotel_booking_guest", "*");
			$selectp->where("apiTraceId=?", "$bookingId");
			$selectp->where("IsMarkForDel", 0);
			$selectp->order("id", 'ASC');
			$passenger = $this->db->fetchAll($selectp);
		}
		//echo"<pre>";print_r($bookingId);exit;
		$data = array('data' => $result, '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("status", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		//echo $select;exit;
		$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);
		//echo"<pre>";print_r($data);exit;
		return $data;
	}

	public function FlightBookingDataNew($tablename, $bookingId, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("bookingId=?", "$bookingId");
		
		$select->where("status", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		//echo $select;exit;
		$result = $this->db->fetchAll($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 bookingstatus($tablename, $bookingId)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("bookingId=?", "$bookingId");
		
		$select->where("IsMarkForDel", 0);
		$select->order("id", 'ASC');
		//echo $select;exit;
		$result = $this->db->fetchAll($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 FlightBookingDataTripJackNew($tablename, $bookingId, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("apiTraceId=?", "$bookingId");
		if ($journeyType) {
			$select->where("JourneyType=?", $journeyType);
		}
		//        $select->where("parent_id=?",0);
		//$select->where("status", 1);
		$select->where('status IN(?)', [0, 1, 3, 4]);
		$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("apiTraceId=?", "$bookingId");
			$selectp->where("IsMarkForDel", 0);
			$selectp->order("id", 'ASC');
			$passenger = $this->db->fetchAll($selectp);
		}
		$data = array('data' => $result, 'passenger' => $passenger);
		//echo"<pre>";print_r($data);exit;
		return $data;
	}

	public function PeningFlightBookingDataTripJack($tablename, $bookingId, $journeyType = null)
	{
		//echo $bookingId;exit;
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("apiTraceId=?", $bookingId);
		//$select->where("status", 0);
		// $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("apiTraceId=?", "$bookingId");
			$selectp->where("IsMarkForDel", 0);
			$selectp->order("id", 'ASC');
			$passenger = $this->db->fetchAll($selectp);
		}
		$data = array('data' => $result, 'passenger' => $passenger);
		//echo"<pre>";print_r($data);exit;
		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)
	{
		// echo 
		$select = $this->db->select()->from("$tablename", "*");
		// die;
		// $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 GetCustomerDataCustomer($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", "*");

		//echo $cancel;exit;
		if ($CustomerSysId) {
			$select->where("CustomerSysId=?", $CustomerSysId);
		}
		if ($cancel) {
			$select->where("IsCancelled=?", $cancel);
		}

		$select->where("paymentStatus", 1);
		$select->where("IsMarkForDel", 0);
		$select->order("id DESC");
		$result = $this->db->fetchAll($select);

		//$data = array('BookingData'=>$result,'booking_room'=>$booking_room,'Guest'=>$passenger);

		//echo"<pre>"; print_r($result); exit;

		return $result;
	}
	public function getHotelsBookingListCustomer($tablename, array $CustomerSysId = null, $cancel = null)
	{
		$select = $this->db->select()->from("$tablename", "*");

		$select->where('CustomerSysId IN(?)', $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 getBusBookingListCustomer($tablename, array $CustomerSysId = null, $cancel = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		if($CustomerSysId){
			$select->where('CustomerSysId IN(?)', $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 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 sendSmsDetails($url, $strPostReq, $arrSMSStatistics = array(), $IsSMSApi = 1, $SearchParam = 0)
	{
		$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);
		$returnValArray = [];
		if (isset($response['status']) && $response['status'] == "OK") {
			$returnValArray['response'] = $response;
			$returnValArray['status'] = "OK";
			$returnValArray['Message'] = "success";
		} else {
			$returnValArray['response'] = $response;
			$returnValArray['status'] = "Fail";
			$returnValArray['Message'] = "check again";
		}
		return $returnValArray;
	}

	public function checkFlightOTP($apiTraceId)
	{
		$selectp = $this->db->select()->from("tbl_flight_booking", "generateOTP");
		$selectp->where("apiTraceId=?", "$apiTraceId");
		//$selectp->where('id IN(?)', $apiTraceId);
		$selectp->where("IsMarkForDel", 0);
		$selectp->order("id", 'ASC');
		$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 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 UpdateCashfeeData(array $addData, $where)
	{
		return $this->db->update('tbl_cashfee_detail', $addData, $where);
	}

	public function getCashFeeData($apiTraceId)
	{
		$select = $this->db->select();
		$select->from(array('TP' => "tbl_cashfee_detail"));
		$select->where("TP.orderId = ?", $apiTraceId);
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function CheckFlightToken($tablename, $AgencySysid = null)
	{
		$date1 = date('Y-m-d') . " 00:00:00";
		$date2 = date('Y-m-d') . " 23:59:00";
		$select = $this->db->select()->from("$tablename", "*");
		$select->where('AgencySysid =?', $AgencySysid);
		$select->where('created_at >= ?', $date1);
		$select->where('created_at <= ?', $date2);
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function DeleteToken($tablename)
	{
		$date1 = date('Y-m-d') . " 00:00:00";
		$date2 = date('Y-m-d') . " 23:59:00";
		$where = array('created_at >= ? ' => $date1);
		$result = $this->db->delete("$tablename", $where);
		return $result;
	}
	public function GetCoupon($tablename, $codeName)
	{
		$date = date('Y-m-d');
		$select = $this->db->select()->from("$tablename", "*");
		$select->where('codeName =?', $codeName);
		$select->where('status =?', '1');
		$select->where('isActive = ?', '1');
		$select->where('expiryDate >= ?', $date);
		//echo $select;die;
		$result = $this->db->fetchRow($select);
		return $result;
	}

	public function InsertHotelStaticData($tablename, array $addData)
    {
        $dbtable = new Zend_Db_Table($tablename);
        return $dbtable->insert($addData);
    }

	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 CheckHotelPaymentSTatus($tablename, $apiTraceId, $journeyType = null)
	{
		$select = $this->db->select()->from("$tablename", "*");
		$select->where("TraceId=?", "$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);
		return $result;
	}

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

	public function InsertChatgptEnqueryData(array $addData)
    {
        $this->db->insert('tbl_chatgpt_enquiry', $addData);
		return $this->db->lastInsertId('tbl_chatgpt_enquiry');
    }
	
	public function getLeadDeailsByLeadID($lastId)
    {
		$select = $this->db->select();
		$select->from(array('CE' => "tbl_chatgpt_enquiry"));
		$select->where("CE.lead_id  = ?", $lastId);
		$result = $this->db->fetchRow($select);
		return $result;
    }

	public function updateLeadResponse(array $updataData,$where)
    {
		return $this->db->update('tbl_chatgpt_enquiry',$updataData, $where);
    }
}