<?php
@ini_set ("soap.wsdl_cache_enabled", "0" );
@ini_set("default_socket_timeout" , "300");
@ini_set("memory_limit","256M");
 
class MSSoapClient extends SoapClient {
    public $name_space;
 
    function __doRequest($request, $location, $action, $version) {
        $request = preg_replace ( '/<ns1:(\w+)/', '<$1 xmlns="' . $this->name_space . '"', $request, 1 );
 
        $s = array ('SOAP-ENV', 'xsd:', 'ns1:' );
        $r = array ('soap', '', '' );
 
        $request = str_ireplace ( $s, $r, $request );
 
        $request = str_replace ( 'xsi:type="ms_soap_comp"', 'xmlns="http://tempuri.org/"', $request );
        $request = str_replace ( '<WebCustomer>', '', $request );
        $request = str_replace ( '</WebCustomer>', '', $request );
        $request = str_replace ('<SOAP-ENC:Struct xsi:type="WebCustomer">', '<WebCustomer>', $request );        
        $request = str_replace ('</SOAP-ENC:Struct>', '</WebCustomer>', $request );     
 
 
        return parent::__doRequest ( $request, $location, $action, $version );
    }
}
 
class Active_Trail {      
    public $login_success;        
    private $session_id;
    private $user;
    private $pass;
    public $client;    
    private $wsdl_uri_ = "https://webapi.mymarketing.co.il/Messaging/MessagingService.asmx?WSDL";
    private $wsdl_uri_report = "https://webapi.mymarketing.co.il/reports/reportservice.asmx?WSDL";
    private $wsdl_uri_userservice = "https://webapi.mymarketing.co.il/users/userservice.asmx?WSDL";
    private $wsdl_uri_customer = "https://webapi.mymarketing.co.il/customers/customerService.asmx?WSDL";
 
    private $name_space = "http://tempuri.org/";
 
    function __construct($u, $p, $location = "") {
        if (isset ( $u ) && isset ( $p )) {
            $this->user = $u;
            $this->pass = $p;
            $this->_Login($location);
    
        }
    }
 
    private function _Connect( $location = "") {
        $wsdl_options = array ('features'=>SOAP_SINGLE_ELEMENT_ARRAYS, 'trace' => true, "exceptions" => 0, "user_agent"=> "some_string", 'connection_timeout' => '3600', 'classmap' => array ('webMessage' => "webMessage", 'GetPerformanceReport' => "GetPerformanceReport" ,'GetOverviewReport' => "GetOverviewReport", 'webCampaign' => "webMessage",'ArrayOfBodyPart' => 'ArrayOfBodyPart' ) );
 
        unset ( $this->client );
 
        $uri = "wsdl_uri_$location";
        
        //Init the client
        $this->client = new MSSoapClient ( $this->$uri, $wsdl_options );
        $this->client->name_space = $this->name_space;
 
    }
 
    private function _Login($location = "") {
        $this->_Connect ($location);
        $this->_Auth_Header ();
        $response = $this->client->Login ();
        
        $this->session_id = $response->LoginResult;
        
        if ( $response->LoginResult == "" ) {
             //log_data("ERREUR : Erreur connection ou mauvais login");
            $success = array(__('Login <b>failed</b>. It seems that your username/password combination is not correct. Please try again.', 'atl'), 'error');
            //die( "ERREUR : Erreur connection ou mauvais login\n");
            //exit;
        }else{
            $this->login_success = TRUE;
        }
    }
    
    private function _Auth_Header() {
        $auth_header = new SoapHeader ( $this->name_space, 'AuthHeader', new AuthHeader ( $this->user, $this->pass, $this->session_id ) );
        $this->client->__setSoapHeaders ( array ($auth_header ) );
    }
    
    public function ImportCustomers($webCustomers,$groupId,$mailinglistName)
    {
        $this->_Connect('customer');
        $this->_Auth_Header();
        $param=new stdClass(); 
        
        
        $param->ImportCustomers->webCustomers=$webCustomers;
        $param->ImportCustomers->groupId=$groupId;
        $param->ImportCustomers->mailinglistName=$mailinglistName;
 
        $ImportCustomers=new SoapVar($param->ImportCustomers, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        
        
        $response=$this->client->ImportCustomers(new SoapParam($ImportCustomers,"ImportCustomers"));
                
        return $response;
    }
 
    /* Function Create Campaign
     * Set $campaign_name and $campaign_data (array)
     * Get the campaign Id
    */
    public function CreateCampaign($campaign_name, $campaign_data)
    {
        $this->_Connect ();
        $this->_Auth_Header ();
 
        $param = new stdClass ();
        $param->webCampaign = new webMessage ();
        $param->webCampaign->Subject = $campaign_data ['subject'];
        $param->webCampaign->From->FromName = $campaign_data ['from_name'];
        $param->webCampaign->From->FromEmail = $campaign_data ['from_email'];
        $param->webCampaign->Name = "$campaign_name";
 
        $ArrayOfBodyPart = new ArrayOfBodyPart ( );
        $ArrayOfBodyPart->BodyPart [] = new BodyPart ( 'utf-8', 'HTML', $campaign_data ['body_part'] );
        $param->webCampaign->BodyParts = $ArrayOfBodyPart;
 
        $CreateCampaign = new SoapVar ( $param, SOAP_ENC_OBJECT, 'ms_soap_comp' );
 
        $response = $this->client->CreateCampaign ( new SoapParam ( $CreateCampaign, "CreateCampaign" ) );
 
        if ($response->CreateCampaignResult > 0 && $campaign_data['language_id'] > 0){
            $response->LanguageID = $campaign_data['language_id'];
        }
 
        return $response;
    }
 
    // Imports an email address to the account
    // https://webapi.mymarketing.co.il/customers/customerservice.asmx?op=ImportEmail
    public function ImportEmail ($Groups, $Mailinglists, $Email){
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
 
        $param->ImportEmail->email = "$Email";
        $param->ImportEmail->groups = $Groups;
        $param->ImportEmail->mailinglists = $Mailinglists;
 
        $ImportEmail = new SoapVar ( $param->ImportEmail, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->ImportEmail ( new SoapParam ( $ImportEmail, "ImportEmail") );
 
        return $response;
    }
      
    /* Function Import Customers Email
     * Set $GroupId and $Email (array)
     * Get the response success
    */
    public function ImportCustomersEmail($GroupID, $Emails)
    {
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
 
        $param->ImportCustomersEmail->emails = $Emails;
        $param->ImportCustomersEmail->groupId = $GroupID;
        $param->ImportCustomersEmail->groupId = $GroupID;
 
        $ImportCustomersEmail = new SoapVar ( $param->ImportCustomersEmail, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->ImportCustomersEmail ( new SoapParam ( $ImportCustomersEmail, "ImportCustomersEmail") );
 
        return $response;
    }
 
    public function SendMessageToEmails ($from, $from_name, $to, $replyto, $subject, $content_html, $content_txt="") {
 
        log_data("Send message from activetrail: from ".$from." to : ".$to." subject : ".$subject);
 
        $this->_Connect ();
        $this->_Auth_Header ();
 
        $param = new stdClass ( );
        $param->webMessage = new webMessage ( );
 
        $param->webMessage->Subject = $subject;
        $param->webMessage->From->FromName = $from_name;
        $param->webMessage->From->FromEmail = $from;
        $param->webMessage->ExternalMessageId = "15";
        $param->webMessage->LanguageId=35;
        $param->webMessage->UserPlaceholders= false;
        $param->webMessage->AddStatistics = false;
        $param->webMessage->AddAdvertisement = false;
        $param->webMessage->SignMessage = false;
        $param->webMessage->AddUnsubscribeLink = false;
        $param->webMessage->Note = '';
        $param->webMessage->AddPrintButton = false;
        $param->webMessage->Name = "Campagne depuis OVH";
        $param->webMessage->Priority = '2';
 
        $ArrayOfBodyPart = new ArrayOfBodyPart ( );
        $ArrayOfBodyPart->BodyPart [] = new BodyPart ( '', 'HTML', $content_html );
        if (! empty ( $content_txt ))
            $ArrayOfBodyPart->BodyPart [] = new BodyPart ( '', 'Text', $content_txt );
 
        $param->webMessage->BodyParts = $ArrayOfBodyPart;
 
        $ArrayEmail=new ListEmails($to);
        $param->emails=$ArrayEmail;
 
        $SendMessageToEmails = new SoapVar ( $param, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->SendMessageToEmails ( new SoapParam ( $SendMessageToEmails, "SendMessageToEmails" ) );
 
        return $response;
    }
 
 public function SendCampaignById($campaign_id, $group_id){
        $this->_Connect ();
        $this->_Auth_Header ();
 
        $param = new stdClass ( );
        $param->SendCampaignById->campaignId = $campaign_id;
        $param->SendCampaignById->groups = $group_id;
 
        $SendCampaignById = new SoapVar ( $param->SendCampaignById, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->SendCampaignById ( new SoapParam ( $SendCampaignById, "SendCampaignById") );
 
        return $response;
    }
 
    public function GetCampaignByName($campaign_name){
        $this->_Connect ();
        $this->_Auth_Header ();
 
        $param->GetCampaignByName->campaignName = "$campaign_name";
 
        $GetCampaignByName = new SoapVar ( $param->GetCampaignByName, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->GetCampaignByName ( new SoapParam ( $GetCampaignByName, "GetCampaignByName") );
 
        return $response;
    }
 
    public function CreateGroup($GroupName){
        $this->_Connect ( 'userservice' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->CreateGroup->name = "$GroupName";
 
        $CreateGroup = new SoapVar ( $param->CreateGroup, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->CreateGroup ( new SoapParam ( $CreateGroup, "CreateGroup") );
 
        return $response->CreateGroupResult;
    }
    
    public function GetUserProfiles()
    {
        $this->_Connect ( 'userservice' );
        $this->_Auth_Header ();
        $response = $this->client->GetUserProfiles();
        return $response;
    }
 
    public function GetCustomers()
    {
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        
        // set the default timezone to use. Available since PHP 5.1
        date_default_timezone_set('UTC');
        // get the date
        $startDate = date("Y-m-d") . 'T' . date("H:i:s");
        $endDate = date("Y-m-d", $t = time() - 86400 * 50) . 'T' . date("H:i:s", $t);
     
        $param = new stdClass ( );
        $param->GetCustomers->customerState = "ACTIVE";
        $param->GetCustomers->fromDate = $endDate;
        $param->GetCustomers->toDate = $startDate;
  
        $GetCustomers = new SoapVar ( $param->GetCustomers, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->GetCustomers ( new SoapParam ( $GetCustomers, "GetCustomers") );
 
        return $response;
        
    }
     
    public function GetCustomersRecordSet()
    {
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        
        // set the default timezone to use. Available since PHP 5.1
        date_default_timezone_set('UTC');
        // get the date
        $startDate = date("Y-m-d") . 'T' . date("H:i:s");
        $endDate = date("Y-m-d", $t = time() - 86400 * 50) . 'T' . date("H:i:s", $t);
     
        $param = new stdClass ( );
       
        $param->GetCustomersRecordSet->fromDate = $endDate;
        $param->GetCustomersRecordSet->toDate = $startDate;
        $param->GetCustomersRecordSet->stateType  = 'None';
        $param->GetCustomersRecordSet->pageNumber  = 50;
        $param->GetCustomersRecordSet->inactiveType  = 'None';
        $param->GetCustomersRecordSet->groupsIds  = -1;
        $param->GetCustomersRecordSet->mailingListsIds = -1;
        $param->GetCustomersRecordSet->confirmStatus = 'NONE';
        
        $GetCustomers = new SoapVar ( $param->GetCustomersRecordSet, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->GetCustomersRecordSet ( new SoapParam ( $GetCustomers, "GetCustomersRecordSet") );
 
        return $response;
        
    }
 
    public function ImportEmailAsConfirmed($data){
        
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        $response = $this->client->ImportEmailAsConfirmed( new SoapParam ( new SoapVar ($data, SOAP_ENC_OBJECT, 'ms_soap_comp' ), "ImportEmailAsConfirmed") );
        return $response;
    }
     
    /**
     * Generic function for calling requests
     */
    public function RunCommand($data, $command, $connect, $auth = true)
    {
        $this->_Connect($connect);
        
        if ($auth)
        {
            $this->_Auth_Header();
        }
        
        $param = new SoapVar ($data , SOAP_ENC_OBJECT, 'ms_soap_comp' );        
        return call_user_func_array(array($this->client, $command),
                 array(new SoapParam($param, $command)));
                 
    }
    
    public function __ImportCustomerAsConfirmed ($Groups, $Mailinglists, $Email){
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
 
        $param->ImportCustomerAsConfirmed->webcustomer->Email = "$Email";
        $param->ImportCustomerAsConfirmed->webcustomer->FirstName = "Test";
        $param->ImportCustomerAsConfirmed->webcustomer->LastName = "Test";
        
        $param->ImportCustomerAsConfirmed->groups = $Groups;
        $param->ImportCustomerAsConfirmed->mailinglists = $Mailinglists;
 
        $ImportEmail = new SoapVar ( $param->ImportCustomerAsConfirmed, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->ImportCustomerAsConfirmed( new SoapParam ( $ImportEmail, "ImportCustomerAsConfirmed") );
 
        return $response;
    }
     
    public function GetCustomerByEmail($data)
    {
        return $this->RunCommand($data, 'GetCustomerByEmail', 'customer');
    }
  
    public function ImportCustomerAsConfirmed($data){
        return $this->RunCommand($data, 'ImportCustomerAsConfirmed', 'customer');
    }
    
    public function ImportCustomer($data){
        return $this->RunCommand($data, 'ImportCustomer', 'customer');
    }
         
    public function GetMailingLists()
    {
         $this->_Connect ( 'userservice' );
         $this->_Auth_Header ();
         $response = $this->client->GetMailingLists();
         return $response;
    }
    
    public function GetGroups()
    {       
         $this->_Connect ( 'userservice' );
         $this->_Auth_Header ();
         $response = $this->client->GetGroups();
         return $response;
    }
 
    public function SetCampaignCategory($CampaignID, $CategoryID){
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->SetCampaignCategory->campaignId = "$CampaignID";
        $param->SetCampaignCategory->contentCategoryId = "$CategoryID";
 
        $SetCampaignCategory = new SoapVar ( $param->SetCampaignCategory, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->SetCampaignCategory ( new SoapParam ( $SetCampaignCategory, "SetCampaignCategory") );
 
        return $response;
    }
 
    public function SetCampaignHeadersLanguage($CampaignID, $LanguageID){
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->SetCampaignHeadersLanguage->campaignId = "$CampaignID";
        $param->SetCampaignHeadersLanguage->cultureId = "$LanguageID";
        echo "Setting for: $CampaignID, $LanguageID \n";
        $SetCampaignHeadersLanguage = new SoapVar ( $param->SetCampaignHeadersLanguage, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->SetCampaignHeadersLanguage ( new SoapParam ( $SetCampaignHeadersLanguage, "SetCampaignHeadersLanguage") );
 
        return $response;
    }
 
    public function ClearGroup($GroupID){
        $this->_Connect ( 'userservice' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->ClearGroup->id = "$ClearGroup";
 
        $ClearGroup = new SoapVar ( $param->ClearGroup, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->ClearGroup ( new SoapParam ( $ClearGroup, "ClearGroup") );
 
        return $response;
    }
 
    public function AddToGroups($GroupID, $Emails, $Gname){
        $this->_Connect ( 'customer' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
 
        $param->AddToGroups->emails = $Emails;
        #$param->AddToGroups->groupNames = $Gname;
        $param->AddToGroups->groupIds = $GroupID;
 
 
        $AddToGroups = new SoapVar ( $param->AddToGroups, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        $response = $this->client->AddToGroups ( new SoapParam ( $AddToGroups, "AddToGroups") );
 
        return $response;
    }
 
    // Function Checked
    // public function ImportCustomersEmail($GroupID, $Emails)
    // {
        // $this->_Connect ( 'customer' );
        // $this->_Auth_Header ();
        // $param = new stdClass ( );
 
        // $param->ImportCustomersEmail->emails = $Emails;
        // $param->ImportCustomersEmail->groupId = $GroupID;
 
        // $ImportCustomersEmail = new SoapVar ( $param->ImportCustomersEmail, SOAP_ENC_OBJECT, 'ms_soap_comp' );
        // $response = $this->client->ImportCustomersEmail ( new SoapParam ( $ImportCustomersEmail, "ImportCustomersEmail") );
 
        // return $response;
    // }
 
    
 
 
    /* Reporting Functions */
    public function GetOverviewReport($campaign, $dateStart, $dateEnd){
        $this->_Connect ( 'report' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->GetOverviewReport = new GetOverviewReport ( );
        $param->GetOverviewReport->objectId = $campaign;
        $param->GetOverviewReport->fromDate = "$dateStart";
        $param->GetOverviewReport->toDate = "$dateEnd";
 
        $GetOverviewReport = new SoapVar ( $param->GetOverviewReport, SOAP_ENC_OBJECT, 'ms_soap_comp' );
 
        $response = $this->client->GetOverviewReport ( new SoapParam ( $GetOverviewReport, "GetOverviewReport") );
        return $response;
    }
 
    public function GetPerformanceReport($campaign){
        $this->_Connect ( 'report' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->GetPerformanceReport = new GetPerformanceReport ( );
        $param->GetPerformanceReport->objectId = $campaign;
 
        $GetOverviewReport = new SoapVar ( $param->GetPerformanceReport, SOAP_ENC_OBJECT, 'ms_soap_comp' );
 
        $response = $this->client->GetPerformanceReport ( new SoapParam ( $GetPerformanceReport, "GetPerformanceReport") );
        return $response;
    }
 
    public function GetBouncesReport($dateStart, $dateEnd){
        $this->_Connect ( 'report' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->GetBouncesReport = new GetBouncesReport ( );
        $param->GetBouncesReport->objectId = -1;
        $param->GetBouncesReport->fromDate = "$dateStart";
        $param->GetBouncesReport->toDate = "$dateEnd";
 
        $GetBouncesReport = new SoapVar ( $param->GetBouncesReport, SOAP_ENC_OBJECT, 'ms_soap_comp' );
 
        $response = $this->client->GetBouncesReport ( new SoapParam ( $GetBouncesReport, "GetBouncesReport") );
        return $response;
    }
    
    public function GetUnsubscribeReport($dateStart, $dateEnd){
        $this->_Connect ( 'report' );
        $this->_Auth_Header ();
        $param = new stdClass ( );
        $param->GetUnsubscribeReport = new GetUnsubscribeReport ( );
        $param->GetUnsubscribeReport->objectId = -1;
        $param->GetUnsubscribeReport->fromDate = "$dateStart";
        $param->GetUnsubscribeReport->toDate = "$dateEnd";
 
        $GetUnsubscribeReport = new SoapVar ( $param->GetUnsubscribeReport, SOAP_ENC_OBJECT, 'ms_soap_comp' );
 
        $response = $this->client->GetUnsubscribeReport ( new SoapParam ( $GetUnsubscribeReport, "GetUnsubscribeReport") );
        return $response;
    }  
}
 
class CampaignByName {
 public $campaignName;
}
 
// Login credentials to be supplied as a SOAP header
class AuthHeader {
    /** @var string Login */
    public $Username;
    /** @var string Password */
    public $Password;
    /** @var string Token */
    public $Token;
 
    public function __construct($u, $p, $t) {
        $this->Username = $u;
        $this->Password = $p;
        $this->Token = $t;        
    }
}
 
// Mail details
class WebMessage {
    /** @var string Subject */
    public $Subject;
    public $From;
    public $ExternalMessageId;
    public $BodyParts;
    public $UserPlaceholders = false;
    public $AddStatistics = true;
    public $AddAdvertisement = false;
    public $SignMessage = false;
    public $AddUnsubscribeLink = true;
    public $LanguageId = 119;
    public $AddPrintButton = true;
    #    public $Note;
    public $Name = "Test Campaign";
    #    public $Classification;
    #    public $Identifier;
    public $Priority = '2';
}
 
class webCustomers  {
    public $WebCustomer = array();
}
 
class WebCustomer {
 public  $City;
 public  $Email;
 public  $Fax;
 public  $FirstName;
 public  $LastName;
 public  $Phone1;
 public  $Phone2;
 public  $Street;
 public  $ZipCode;
 public  $Birthday;
 public  $Anniversary;
 public  $Ext1;
 public  $Ext2;
 public  $Ext3;
 public  $Ext4;
 public  $Ext5;
 public  $Ext6;
 public  $EncryptedExt1;
 public  $EncryptedExt2;
 public  $EncryptedExt3;
 public  $EncryptedExt4;
}
 
class GetOverviewReport {
    public $reportType = "OVERVIEW";
    public $objectType = "CAMPAIGN";
    public $objectId = "";
    public $classification = "-1";
    public $fromDate = "2008-12-01";
    public $toDate = "2009-01-30";
}
 
class GetBouncesReport {
    public $reportType = "BOUNCES";
    public $objectType = "MESSAGE";
    public $objectId = "-1";
    public $classification = "-1";
    public $bounceType = "-1";
    public $fromDate = "2008-12-01";
    public $toDate = "2009-01-30";
}
 
class GetUnsubscribeReport {
    public $reportType = "UNSUBSCRIBE";
    public $objectType = "MESSAGE";
    public $objectId = "-1";
    public $classification = "-1";
    public $bounceType = "-1";
    public $fromDate = "2008-12-01";
    public $toDate = "2009-01-30";
}
 
class GetPerformanceReport {
    public $reportType = "OVERVIEW";
    public $objectType = "CAMPAIGN";
    public $objectId = "";
    public $classification = "-1";
    public $fromDate = "2008-12-01";
    public $toDate = "2009-01-30";
}
 
class ListEmails {
    public $string;
    public function __construct($email) {
        $this->string = $email;
    }
 
}
 
class ArrayOfBodyPart {
    public $BodyPart = array ();
}
 
class BodyPart {
    public $BodyPartEncoding;
    public $BodyPartFormat;
    public $Body;
 
    public function __construct($bpe, $bpf, $b) {
        $this->BodyPartEncoding = $bpe;
        $this->BodyPartFormat = $bpf;
        $this->Body = $b;
    }
}
 
?>