<?php

/**
 * Class Package Master
 * Description 	This model contains the basic activity functions needed for packages.
 * @name	Package Master
 * @author	Ravi Khare
 * @version 	1.0
 * @copyright 	Catabatic Automation Pvt. Ltd.
 * Handle 	Packate Related function
 *
 */
class Travel_Model_TblFacebook extends Zend_Db_Table_Abstract {
    #declare class vairables

    public $intId = NULL;
    private $db = NULL;

    /**
     * Class Constructors
     */
    public function __construct() {

        #initialize db adapter
        $this->db = Zend_Db_Table::getDefaultAdapter();
    }

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

    public function getActiveFacebookLeadForm() {
        $select = $this->db->select()->from(array("T1" => "TB_Agency_Marketing_Facebook_FormsFieldMapping"), array('DISTINCT(FormSysId) as FormSysId', 'T1.AgencySysId'))
                ->joinLeft(array('T2' => "TB_Agency_Marketing_Facebook_Forms"), "T1.FormSysId = T2.FormID", array(""))
                ->joinLeft(array('T3' => "TB_Agency"), "T1.AgencySysId = T3.AgencySysId", array(""))
                //->where("T2.AgencySysId = 54784")
                ->where("T2.FormStatus =?", "ACTIVE")
                ->where("T3.IsActive =?", 1)
                ->where("T3.IsApproved =?", 1);
        $result = $this->db->fetchAll($select);
        //echo "<pre>";print_r($result); exit;
        return $result;
    }

    public function getActiveFacebookLeadFormDCB() {
        $select = $this->db->select()
                ->from("TB_Agency_Marketing_Facebook_FormsFieldMapping", array('DISTINCT(FormSysId) as FormSysId', 'AgencySysId'));
        $select->where("AgencySysId = 4191");
        //echo $select;die;
        $result = $this->db->fetchAll($select);
        return $result;
    }

    public function insertLeadDatainCRM($formId) {
        $select = $this->db->select()->from(array("t1" => "TB_Agency_Marketing_Facebook_Forms"), array(""))
                ->joinLeft(array('t2' => "TB_Agency_Marketing_Facebook_Pages"), "t1.PageSysId = t2.PageID", array(""))
                ->joinLeft(array('t3' => "TB_Agency_Marketing_Facebook_AccessToken"), "t2.AccessTokenSysId = t3.FBAccessTokenSysId", "AccessToken")
                ->where("FormID =?", $formId);
        $result = $this->db->fetchRow($select);
        //echo "<pre>";print_r($result); exit;
        return $result;
    }

    public function fbExchangeToken($accessToken) {
        $fbExchangeTokenUrl = "https://graph.facebook.com/v15.0/oauth/access_token?grant_type=fb_exchange_token&redirect_uri=https://globaltravelexchange.com/facebook-lead/get-access-key&client_id=2032473587063611&client_secret=e51d914b4effdf595ef2228d25729b0e&fb_exchange_token=$accessToken";
        $fbExchangeTokenArray = $this->sendRequest($fbExchangeTokenUrl);
        return $fbExchangeTokenArray;
    }

    public function WAExchangeToken($accessToken) {
        $fbExchangeTokenUrl = "https://graph.facebook.com/v15.0/oauth/access_token?grant_type=fb_exchange_token&client_id=857744605657973&client_secret=ad9bcb105ebab0d634cd9c90e6f304d6&fb_exchange_token=$accessToken";
        $fbExchangeTokenArray = $this->sendRequest($fbExchangeTokenUrl);
        return $fbExchangeTokenArray;
    }

    public function sendRequestFromGetContents($graph_url) {
        $result = file_get_contents($graph_url);
        parse_str($result, $output);
        //echo "<pre>";print_r($output);exit;
        $resultSet = array_keys($output);
        $returnVal = '';
        if (is_array($resultSet)) {
            $returnVal = isset($resultSet[0]) ? $resultSet[0] : '';
        }
        return $returnVal;
    }

    public function sendRequestFromGetContents1($graph_url) {
        $result = file_get_contents($graph_url);
        parse_str($result, $output);
        echo "<pre>";
        print_r($output);
        exit;
        $resultSet = array();
        foreach ($output as $val) {
            $resultSet = $val;
        }
        $resultSet = array_keys($resultSet);
        $returnVal = '';
        if (is_array($resultSet)) {
            $returnVal = isset($resultSet[0]) ? $resultSet[0] : '';
        }
        return $returnVal;
    }

    public function sendRequest($url) {
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
        curl_setopt($ch, CURLOPT_TIMEOUT, 3);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Accept: application/json'));
        $result = curl_exec($ch);
        return $result;
    }

    public function getActiveFacebookLeadFormFileds($formId) {
        $select = $this->db->select()
                ->from("TB_Agency_Marketing_Facebook_FormsFieldMapping")
                ->where("FormSysId =?", $formId)
                ->where("IsMarkForDel = '0'");
        $result = $this->db->fetchAll($select);
        return $result;
    }

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

    public function getActiveFormDetail($formId) {
        $select = $this->db->select()
                ->from("TB_Agency_Marketing_Facebook_Forms")
                ->where("FormID =?", $formId);
        $result = $this->db->fetchAll($select);
        return $result;
    }

    public function getMarketingMail($AgencySysId, $TemplateSysId) {
        $marketingMdl = new Marketing_Model_Marketing();
        $getAllTemplateData = $marketingMdl->getAllTemplatreDataById($AgencySysId, $TemplateSysId);
        $TemplateHTML['TemplateHTML'] = isset($getAllTemplateData[0]['TemplateHTML']) ? $getAllTemplateData[0]['TemplateHTML'] : '';
        $TemplateHTML['TemplateSubject'] = isset($getAllTemplateData[0]['TemplateSubject']) ? $getAllTemplateData[0]['TemplateSubject'] : '';
        return $TemplateHTML;
    }

    public function isWhatsAppActivatedInAgency($SecurityKey) {
        $select = $this->db->select()->from(array("t1" => "TB_Agency"), array("AgencySysId"))
                ->joinLeft(array('t2' => "TB_Agency_Mapping"), "t1.AgencySysId = t2.AgencySysId", array("IsWhatsApp", "WhatsAppNumberId", "WhatsAppApiType", "WhatsAppStaticAccessToken", "FacebookBusinessId", "FacebookAppId"))
                ->joinLeft(array('t3' => "TB_Agency_Marketing_WhatsApp_AccessToken"), "t1.AgencySysId = t3.AgencySysId", array("AccessToken"))
                ->where("t1.SecurityKey =?", $SecurityKey);
        $result = $this->db->fetchRow($select);
        return $result;
    }

    public function checkTemplate($AgencySysId, $TemplateName) {
        $select = $this->db->select()->from(array("t1" => "TB_Agency_WhatsAppEmail_Template"), array("IsActive"))
                ->where("t1.AgencySysId =?", $AgencySysId)
                ->where("t1.IsMarkForDel =?", 0)
                ->where("t1.TemplateName =?", $TemplateName);
        $result = $this->db->fetchRow($select);
        return $result;
    }

    public function createSessionAction($data) {
        $fbexchangeToken = isset($data['access_token']) ? trim($data['access_token']) : '';
        $AppId = isset($data['AppId']) ? trim($data['AppId']) : '';
        $apiUrl = "https://graph.facebook.com/v18.0/" . $AppId . "/uploads";
        $setWhatsAppTemplate = array(
            "file_length" => $data['file_length'],
            "file_type" => $data['file_type'], //"image/png"
            "file_name" => $data['file_name']
        );
        $curl = curl_init();
        curl_setopt_array($curl, array(
            CURLOPT_URL => $apiUrl,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_ENCODING => '',
            CURLOPT_MAXREDIRS => 10,
            CURLOPT_TIMEOUT => 0,
            CURLOPT_FOLLOWLOCATION => true,
            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
            CURLOPT_CUSTOMREQUEST => "POST",
            CURLOPT_POSTFIELDS => json_encode($setWhatsAppTemplate),
            CURLOPT_HTTPHEADER => array(
                "Authorization: Bearer $fbexchangeToken",
                'Content-Type: application/json'
            ),
        ));
        $returnResponse = curl_exec($curl);
        curl_close($curl);
        return json_decode($returnResponse, 1);
    }

    public function createImgAction($data) {
        $fbexchangeToken = isset($data['access_token']) ? trim($data['access_token']) : '';
        $AgencySysId = isset($data['AgencySysId']) ? trim($data['AgencySysId']) : '';
        $apiUrl = "https://graph.facebook.com/v18.0/" . $data['id'];
        $Path = $_SERVER["DOCUMENT_ROOT"] . '/public/upload/media/agency/' . ($AgencySysId) . '/whatsapp' . '/' . $data['file_name'];
        $cfile = new CURLFile($Path, $data['file_type'], $data['file_name']);
        $curl = curl_init();
        curl_setopt_array($curl, array(
            CURLOPT_URL => $apiUrl,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_ENCODING => '',
            CURLOPT_MAXREDIRS => 10,
            CURLOPT_TIMEOUT => 0,
            CURLOPT_FOLLOWLOCATION => true,
            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
            CURLOPT_CUSTOMREQUEST => "POST",
            CURLOPT_POSTFIELDS => ['data-binary' => $cfile],
            CURLOPT_HTTPHEADER => array(
                "Authorization: OAuth $fbexchangeToken",
                'file_length:' . $data['file_length'],
                'Content-Type:' . $data['file_type'],
                'file_offset:0'
            ),
        ));
        try {
            $returnResponse = curl_exec($curl);
        } catch (Zend_Exception $e) {
            echo $e->getMessage();
            exit;
        }
        curl_close($curl);
        return json_decode($returnResponse, 1);
    }
}