PHP Decode

if(!defined('sugarEntry'))define('sugarEntry', true);
/***********************************************
Code-Webhooks for Mailchimp.
***********************************************/
require_once('include/entryPoint.php');
require_once 'include/utils.php';
require_once('include/MVC/Controller/SugarController.php');

global $current_user,$db;
$current_user = new User();
$current_user->getSystemUser();
$tokenkey = $db->pquery("select tokenkey from smack_mailchimp_webhooks where id = '?'", array(1));
$token = $db->fetchByAssoc($tokenkey);

if ( !isset($_GET['key']) ){
    // no key
} elseif ($_GET['key'] != $token['tokenkey']) {
		$logInfo = array();
		$logInfo['service'] = 'Webhook';
		$logInfo['status'] = 'Failed';
		$logInfo['msg'] = "Invalid Webhook Token";
		addLog($logInfo);
} else {
    
    switch($_POST['type']){
        case 'subscribe'  : subscribe($_POST['data']);   break; 
        case 'unsubscribe': unsubscribe($_POST['data']); break; 
        case 'cleaned'    : cleaned($_POST['data']);     break; 
        case 'upemail'    : upemail($_POST['data']);     break; 
        case 'profile'    : profile($_POST['data']);     break; 
        case 'campaign'   : campaign($_POST['data']);    break;
        default:
        die();
    }
}
function campaign($data){
	
	global $db;
	$logInfo = array();	
	$campaign_id= $data['list_id'];
	$campaigns = $db->pquery("select * from smack_mailchimp_lists_crmids where chimpid = '?'", array($campaign_id));
	$campaigns_val = $db->fetchByAssoc($campaigns);	
	if ($campaigns_val) {	
		$logInfo['service'] = 'Webhook Campaign Sending Status';
		$logInfo['status'] = 'Success';
		$logInfo['msg'] = 'All mails of Campaign '.$data['list_id'].' Successfully Sent';
		addLog($logInfo);		
	}	
}

function subscribe($data)
{
	global $db;
	$logInfo = array();
	// write condition for email opt in
	$subscribes = $db->pquery("select subscribes from smack_mailchimp_webhooks where id = '?'", array(1));
	$subscribes_val = $db->fetchByAssoc($subscribes);
	if ($subscribes_val['subscribes']==1) {
		$list_id= $data['list_id'];		//list id from the mailchimp array
		$email_id=$data['email']; // email id is mandatory in mailchimp
		$call_func=check_record_exists($list_id,$email_id);
		if ($call_func) {
			$focus=$call_func[0];
			$focus->email_opt_out=0;	
			$focus->save();
			$logInfo['service'] = 'Webhook Subscribes';
			$logInfo['status'] = 'Success';
			$logInfo['msg'] = $email_id.' Successfully Opted In';
			addLog($logInfo);
		}
	}
}
function unsubscribe($data)
{
	global $db;
	$logInfo = array();
	// write condition for email optout
	$unsubscribes = $db->pquery("select unsubscribes from smack_mailchimp_webhooks where id = '?'", array(1));
	$unsubscribes_val = $db->fetchByAssoc($unsubscribes);
	if ($unsubscribes_val['unsubscribes']==1) {

		$list_id= $data['list_id'];		//list id from the mailchimp array
		$email_id=$data['email']; // email id is mandatory in mailchimp
		$call_func=check_record_exists($list_id,$email_id);
		if ($call_func) {
			$focus=$call_func[0];
			$focus->email_opt_out=1;	
			$focus->save();
			$logInfo['service'] = 'Webhook Unsubscribes';
			$logInfo['status'] = 'Success';
			$logInfo['msg'] = $email_id.' Successfully Opted Out';
			addLog($logInfo);
		}
		
	}
}
function cleaned($data)
{
	global $db;
	$logInfo = array();
	// write condition for email optout
	$cleaned_emails = $db->pquery("select cleaned_emails from smack_mailchimp_webhooks where id = '?'", array(1));
	$cleaned_emails_val = $db->fetchByAssoc($cleaned_emails);
	if ($cleaned_emails_val['cleaned_emails']==1) {

		$list_id= $data['list_id'];		//list id from the mailchimp array
		$email_id=$data['email']; // email id is mandatory in mailchimp
		$call_func=check_record_exists($list_id,$email_id);
		if ($call_func) {
			$focus=$call_func[0];
			$focus->email_opt_out=1;	
			$focus->save();
			$logInfo['service'] = 'Webhook Cleaned Emails';
			$logInfo['status'] = 'Success';
			$logInfo['msg'] = $email_id.' Successfully Opted Out';
			addLog($logInfo);
		}
		
	}
}
// updating primary email id
function upemail($data)
{
	$logInfo = array();
	$list_id= $data['list_id'];		//list id from the mailchimp array
	$old_email=$data['old_email']; // email id is mandatory in mailchimp
	$new_email=$data['new_email'];	
	$call_func=check_record_exists($list_id,$old_email);
	if ($call_func) {
		$focus=$call_func[0];
		$focus->email1=$new_email;	
		$focus->save();
		$logInfo['service'] = 'Webhook Email Address Changes';
		$logInfo['status'] = 'Success';
		$logInfo['msg'] = $new_email.' Address Changed';
		addLog($logInfo);
	}
}
// updating fname,lname,address,phone number.
function profile($data){

	global $db;
	$logInfo = array();
	$list_id= $data['list_id'];		//list id from the mailchimp array
	$email_id=$data['email']; // email id is mandatory in mailchimp	
	$getMap = $db->pquery("select mappinginfo from smack_mailchimp_lists_mapping where listid = '?'", array($list_id));
	$row = $db->fetchByAssoc($getMap);
	$mapping = unserialize(base64_decode($row['mappinginfo']));

	if (!empty($mapping)) {
	
		$call_func=check_record_exists($list_id,$email_id);
		if ($call_func) {

			$focus=$call_func[0];
			$module=$call_func[1];
			if($module == 'Accounts') {
				$focus->$mapping[$module.'_FNAME_1']=$data['merges']['FNAME'];
		    	$focus->$mapping[$module.'_LNAME_2']=$data['merges']['LNAME'];
		    	$focus->$mapping[$module.'_PHONE_3']=$data['merges']['PHONE'];
		    	$focus->$mapping[$module.'_ADDRESS_0']=$data['merges']['ADDRESS'];
		    }
		    else if($module == 'Contacts') {
		    	$focus->$mapping[$module.'_FNAME_1']=$data['merges']['FNAME'];
		    	$focus->$mapping[$module.'_LNAME_2']=$data['merges']['LNAME'];
		    	$focus->$mapping[$module.'_PHONE_3']=$data['merges']['PHONE'];
		    	$focus->$mapping[$module.'_ADDRESS_0']=$data['merges']['ADDRESS'];
		    }
		    else if($module == 'Leads') {
		    	$focus->$mapping[$module.'_FNAME_1']=$data['merges']['FNAME'];
		    	$focus->$mapping[$module.'_LNAME_2']=$data['merges']['LNAME'];
		    	$focus->$mapping[$module.'_PHONE_3']=$data['merges']['PHONE'];
		    	$focus->$mapping[$module.'_ADDRESS_0']=$data['merges']['ADDRESS'];
		     }
		    $focus->save();
		    $logInfo['service'] = 'Webhook Profile Updates';
			$logInfo['status'] = 'Success';
			$logInfo['msg'] = $email_id.' Successfully Updated';
			addLog($logInfo);
		}		
	}	 
}
	
function check_record_exists($list_id,$email_id){
	global $db;
	$get_list_id = $db->pquery("select * from smack_mailchimp_lists_crmids where chimpid = '?'", array($list_id));
	$row = $get_list_id->fetch_assoc();

	$get_email_id = "select id from email_addresses where email_address = '$email_id'";
	$email_details = $db->query($get_email_id); 
	$MailCount = $db->getRowCount($email_details); 
	if($MailCount){ 
		$idmail = $db->getOne($get_email_id); 
		$id_query = "select bean_id from email_addr_bean_rel where email_address_id='$idmail' "; 
		$suite_crm_id= $db->getOne($id_query); // contact or account or lead crmid
	}
	$crmId=$row['crmid'];
	$list=getRelatedRecords($suite_crm_id);
	if (!empty($list)) {
		$key=array_keys($list);

		if ($list[$key[0]]==$crmId) {
			$mode = 'edit';
		    
		    if($key[0] == 'Accounts') {
		       	require_once("modules/Accounts/Account.php");
				$focus = new Account();		        
		    }
		    else if($key[0] == 'Contacts') {
		       	require_once("modules/Contacts/Contact.php");
				$focus = new Contact();		       
		    }
		    else if($key[0] == 'Leads') {
		       	require_once("modules/Leads/Lead.php");
				$focus = new Lead();		        
		    }
		    $focus->id = $suite_crm_id;
			$focus->mode = $mode; 
			$focus->retrieve($suite_crm_id);
			return array($focus, $key[0]);			
		}

	}

}
// function to check record available.
function getRelatedRecords($suite_crm_id)
{	
	global $db;
    $getRelatedRecords= array();
    $get_con_id = $db->pquery("select smack_mailchimp_lists_contactssmack_mailchimp_lists_ida from smack_mailchimp_lists_contacts_c where smack_mailchimp_lists_contactscontacts_idb='?' and deleted=0", array($suite_crm_id));
    while($row = $db->fetchByAssoc($get_con_id)) {
        $getRelatedRecords['Contacts'] = $row['smack_mailchimp_lists_contactssmack_mailchimp_lists_ida'];
    }
    $get_lead_id = $db->pquery("select smack_mailchimp_lists_leadssmack_mailchimp_lists_ida from smack_mailchimp_lists_leads_c where smack_mailchimp_lists_leadsleads_idb = '?' and deleted=0",array($suite_crm_id));  
    while($row = $db->fetchByAssoc($get_lead_id)) {
        $getRelatedRecords['Leads'] = $row['smack_mailchimp_lists_leadssmack_mailchimp_lists_ida'];
    }
    $get_acc_id = $db->pquery("select smack_mailchimp_lists_accountssmack_mailchimp_lists_ida from smack_mailchimp_lists_accounts_c where smack_mailchimp_lists_accountsaccounts_idb = '?' and deleted=0",array($suite_crm_id));
    while($row = $db->fetchByAssoc($get_acc_id)) {
        $getRelatedRecords['Accounts'] = $row['smack_mailchimp_lists_accountssmack_mailchimp_lists_ida'];
    }
    return $getRelatedRecords;
}

function addLog($logInfo)	{
        global $db;
        $date = date('Y-m-d H:i:s');
        $db->pquery("insert into smack_mailchimp_lists_logs (name, message, status, createdtime) values ('?','?','?','?')", array($logInfo['service'], $logInfo['msg'], $logInfo['status'], $date));
	}