<?php

/* Zend Framework
 * @category   Zend
 * @package    Zend_Controller_Action
 * @copyright  Copyright (c) 2008-2014 Zend Technologies USA Inc. (http://www.zend.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 * @version    1.0
 * @author     Ranvir singh <ranvir@catpl.co.in>
 * Create Date 06-09-2016
 * Update Date 06-09-2016
 * ************************************************************* */

class Gtxwebservices_Model_Webservices extends Zend_Db_Table_Abstract {

    private $postFields;
    private $url;

    function __construct() {
        $this->db = Zend_Db_Table::getDefaultAdapter();
    }

    public function __destruct() {
        $this->db->closeConnection();
    }

    public function getPackagesData($agencyId, $packageId) {
        $this->postFields = "";
        $this->postFields .= "&AgencySysId=$agencyId&packageId=$packageId";
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        $data = $this->sendInfo($this->postFields, $this->url);
        $getZsontoArray = Zend_Json::decode($data, true);
        $crud = new Admin_Model_CRUD();
        $errorlog = array();
        for ($i = 0; $i < count($getZsontoArray); $i++) {
            $resultset = $crud->rv_select_all('tb_tbb2c_packages_master', ['Keyword', 'Description', 'Metatag', 'Image', 'HotDeal', 'IsFeatured', 'DisplayIndex','metaTitle'], ['GTXPkgId' => $getZsontoArray[$i]["GTXPkgId"], 'IsMarkForDel' => 0], ['PkgSysId' => 'DESC'], 1);
            $LongJsonInfoDecode = Zend_Json::decode($getZsontoArray[$i]["LongJsonInfo"], true);
            $packageName = trim($LongJsonInfoDecode['package']['Name']);
            $packageNameUrl = trim(strtolower(str_replace([' ', ',', '&', '@'], '-', $packageName)));
            $packageNameUrlFinal = trim(str_replace(['----', '---', '--'], '-', $packageNameUrl));

            if (isset($resultset) && !empty($resultset)) {

                $updateData = array(
                    "GTXPkgSourceId" => $getZsontoArray[$i]["GTXPkgSourceId"],
                    "AgencySysId" => $getZsontoArray[$i]["AgencySysId"],
                  
                    "packageNameUrl" => $packageNameUrlFinal,
                    "PackageSearchString" => $getZsontoArray[$i]["PackageSearchString"] . ',',
                    "DisplayIndex" => $getZsontoArray[$i]["DisplayIndex"],
                    "ItemType" => $getZsontoArray[$i]["ItemType"],
                    "PackageType" => $getZsontoArray[$i]["PackageType"],
                    "PackageSubType" => $getZsontoArray[$i]["PackageSubType"],
                    "PackageCategory" => $getZsontoArray[$i]["ShortJsonInfo"],
                    "LongJsonInfo" => $getZsontoArray[$i]["LongJsonInfo"],
                    "Destinations" => $getZsontoArray[$i]["Destinations"],
                    "DestinationsId" => $getZsontoArray[$i]["DestinationsId"],
                    "MinPrice" => $getZsontoArray[$i]["MinPrice"],
                    "MaxPrice" => $getZsontoArray[$i]["MaxPrice"],
                    "Nights" => $getZsontoArray[$i]["Nights"],
                    "MinPax" => $getZsontoArray[$i]["MinPax"],
                    "PackTypeMask" => $getZsontoArray[$i]["PackTypeMask"],
                    "PackRangeType" => $getZsontoArray[$i]["PackRangeType"],
                    "PkgValidFrom" => $getZsontoArray[$i]["PkgValidFrom"],
                    "PkgValidUntil" => $getZsontoArray[$i]["PkgValidUntil"],
                    "BookingValidUntil" => $getZsontoArray[$i]["BookingValidUntil"],
                    "Countries" => $getZsontoArray[$i]["Countries"],
                    "CountryIds" => $getZsontoArray[$i]["CountryIds"],
                    "StarRating" => $getZsontoArray[$i]["StarRating"],
                    "UpdateDate" => date("Y-m-d H:i:s"),
                    "CreateDate" => $getZsontoArray[$i]["CreateDate"],
                    "CreatedBy" => $getZsontoArray[$i]["CreatedBy"],
                    "UpdatedBy" => $getZsontoArray[$i]["UpdatedBy"],
                    "IsPublish" => 1,
                    "IsActive" => 1,
                    "IsMarkForDel" => 0,
                    "Keyword" => $resultset[0]["Keyword"],
                    "Description" => $resultset[0]["Description"],
                    "Metatag" => $resultset[0]["Metatag"],
                    "metaTitle" => $resultset[0]["metaTitle"],
                    "Image" => $resultset[0]["Image"],
                    "HotDeal" => $resultset[0]["HotDeal"],
                    "IsFeatured" => $resultset[0]["IsFeatured"],
                    "DisplayIndex" => $resultset[0]["DisplayIndex"],
                    
                );
                try {

                    $where = array('GTXPkgId =?' => $getZsontoArray[$i]["GTXPkgId"]);
                    try {
                        $this->updateTable("tb_tbb2c_packages_master", $updateData, $where);
                    } catch (Zend_Exception $e) {
                        $errorlog["error"][] = "update" . $e->getMessage();
                    }


                    $tpid = $getZsontoArray[$i]["GTXPkgId"];
//                $tpid = $getZsontoArray[$i]["ItemType"];
                    $updateXMLUrl = Catabatic_Helper::getSiteUrl() . "api/sync/index?tpid=$tpid";
                    $this->updateXml($updateXMLUrl);
                    $errorlog["success"][] = $getZsontoArray[$i]["GTXPkgId"];
                } catch (Zend_Exception $e) {
                    $errorlog["error"][] = $e->getMessage();
                }
            } else {
                $insertData = array(
                    "GTXPkgId" => $getZsontoArray[$i]["GTXPkgId"],
                    "GTXPkgSourceId" => $getZsontoArray[$i]["GTXPkgSourceId"],
                    "AgencySysId" => $getZsontoArray[$i]["AgencySysId"],
                    "IsFeatured" => 0,
                    "packageNameUrl" => $packageNameUrlFinal,
                    "PackageSearchString" => $getZsontoArray[$i]["PackageSearchString"] . ',',
                    "DisplayIndex" => $getZsontoArray[$i]["DisplayIndex"],
                    "ItemType" => $getZsontoArray[$i]["ItemType"],
                    "PackageType" => $getZsontoArray[$i]["PackageType"],
                    "PackageSubType" => $getZsontoArray[$i]["PackageSubType"],
                    "PackageCategory" => $getZsontoArray[$i]["ShortJsonInfo"],
                    "LongJsonInfo" => $getZsontoArray[$i]["LongJsonInfo"],
                    "Destinations" => $getZsontoArray[$i]["Destinations"],
                    "DestinationsId" => $getZsontoArray[$i]["DestinationsId"],
                    "MinPrice" => $getZsontoArray[$i]["MinPrice"],
                    "MaxPrice" => $getZsontoArray[$i]["MaxPrice"],
                    "Nights" => $getZsontoArray[$i]["Nights"],
                    "MinPax" => $getZsontoArray[$i]["MinPax"],
                    "PackTypeMask" => $getZsontoArray[$i]["PackTypeMask"],
                    "PackRangeType" => $getZsontoArray[$i]["PackRangeType"],
                    "PkgValidFrom" => $getZsontoArray[$i]["PkgValidFrom"],
                    "PkgValidUntil" => $getZsontoArray[$i]["PkgValidUntil"],
                    "BookingValidUntil" => $getZsontoArray[$i]["BookingValidUntil"],
                    "Countries" => $getZsontoArray[$i]["Countries"],
                    "CountryIds" => $getZsontoArray[$i]["CountryIds"],
                    "StarRating" => $getZsontoArray[$i]["StarRating"],
                    "UpdateDate" => $getZsontoArray[$i]["UpdateDate"],
                    "CreateDate" => $getZsontoArray[$i]["CreateDate"],
                    "CreatedBy" => $getZsontoArray[$i]["CreatedBy"],
                    "UpdatedBy" => $getZsontoArray[$i]["UpdatedBy"],
                    "IsPublish" => 1,
                    "IsActive" => $getZsontoArray[$i]["IsActive"],
                    "IsMarkForDel" => $getZsontoArray[$i]["IsMarkForDel"]
                );
                try {
                    $this->insertTable("tb_tbb2c_packages_master", $insertData);

                    $tpid = $getZsontoArray[$i]["GTXPkgId"];
//                $tpid = $getZsontoArray[$i]["ItemType"];
                    $updateXMLUrl = Catabatic_Helper::getSiteUrl() . "api/sync/index?tpid=$tpid";
                    $this->updateXml($updateXMLUrl);
                    $errorlog["success"][] = $getZsontoArray[$i]["GTXPkgId"];
                } catch (Zend_Exception $e) {
                    $errorlog["error"][] = $e->getMessage();
                }
            }
        }
        return $errorlog;
    }

    public function insertTable($table, $data) {
        $dbtable = new Zend_Db_Table("$table");
        return $dbtable->insert($data);
    }

    public function updateTable($table, $editData, $where) {
        $dbtable = new Zend_Db_Table("$table");
        $dbtable->update($editData, $where);
    }

    public function writeLog($data) {
        $fileName = date("Y-m-d") . ".txt";
        $fp = fopen("data/" . $fileName, 'a+');
        $data = date("Y-m-d H:i:s") . " - " . $_SERVER["REMOTE_ADDR"] . " - " . $data;
        fwrite($fp, $data);
        fclose($fp);
    }

    public function sendInfo($data, $url) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        $output = curl_exec($ch);
        //echo "<pre>";print_r($output);exit;
        $this->writeLog($output . "\n");
        curl_close($ch);
        return $output;
    }

    public function sendQuery($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/query');
    }

    public function sendLead($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/lead');
    }

    public function getleadcustomerdetail($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/hotel');
    }
        public function sendQueryB2B($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/b2b-readymade-query');
    }
    
    public function sendQueryProposal($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/query-proposal');
    }
    public function customerPayment($data, $url) {
        return $this->sendInfo($data, $url);
    }

    public function updateXml($url) {
        $data = "";
//        $this->sendInfo($data, $url);
    }

    public function genrateFlightQuery($data) {
        $this->url = Catabatic_Helper::gtxBtoBsite() . "gtxwebservices";
        return $this->sendInfo($data, $this->url . '/flight');
    }

}