soapclient.php

См. документацию.

<?php
 
class CSOAPClient
{
    var $Server;
    var $Path;
    var $Port;
    var $Timeout = 0;
    var $Login;
    var $Password;
    
    var $SOAPRawRequest;
    var $SOAPRawResponse;
    
    public function __construct( $server, $path = '/', $port = 80 )
    {
        $this->Login = "";
        $this->Password = "";
        $this->Server = $server;
        $this->Path = $path;
        $this->Port = $port;
        if ( is_numeric( $port ) )
            $this->Port = $port;
        elseif(mb_strtolower($port) == 'ssl' )
            $this->Port = 443;
        else
            $this->Port = 80;
    }

    function send( $request )
    {
        $fullUrl = ($this->Port == 443 ? "https" : "http")."://".$this->Server.":".$this->Port.$this->Path;
 
        $uri = new \Bitrix\Main\Web\Uri($fullUrl);
        if($uri->getHost() == '')
        {
            $this->ErrorString = '<b>Error:</b> CSOAPClient::send() : Wrong server parameters.';
            return 0;
        }
        else
        {
            $this->Server = $uri->getHost();
            $this->Port = $uri->getPort();
            $this->Path = $uri->getPathQuery();
        }
 
        if ( $this->Timeout != 0 )
        {
            $fp = fsockopen( $this->Server,
                             $this->Port,
                             $this->errorNumber,
                             $this->errorString,
                             $this->Timeout );
        }
        else
        {
            $fp = fsockopen( $this->Server,
                             $this->Port,
                             $this->errorNumber,
                             $this->errorString );
        }
 
        if ( $fp == 0 )
        {
            $this->ErrorString = '<b>Error:</b> CSOAPClient::send() : Unable to open connection to ' . $this->Server . '.';
            return 0;
        }
 
        $payload = $request->payload();
 
        $authentification = "";
        if ( ( $this->login() != "" ) )
        {
            $authentification = "Authorization: Basic " . base64_encode( $this->login() . ":" . $this->password() ) . "\r\n" ;
        }
        
        $name = $request->name();
        $namespace = $request->get_namespace();
        if ($namespace[mb_strlen($namespace) - 1] != "/")
            $namespace .= "/";          
 
        $HTTPRequest = "POST " . $this->Path . " HTTP/1.0\r\n" .
            "User-Agent: BITRIX SOAP Client\r\n" .
            "Host: " . $this->Server . "\r\n" .
            $authentification .
            "Content-Type: text/xml; charset=utf-8\r\n" .
            "SOAPAction: \"" . $namespace . $request->name() . "\"\r\n" .
            "Content-Length: " . strlen($payload)  . "\r\n\r\n" .
            $payload;
        
        $this->SOAPRawRequest = $HTTPRequest;
        if ( !fwrite( $fp, $HTTPRequest /*, strlen( $HTTPRequest )*/ ) )
        {
            $this->ErrorString = "<b>Error:</b> could not send the SOAP request. Could not write to the socket.";
            $response = 0;
            return $response;
        }
 
        $rawResponse = "";
        // fetch the SOAP response
        while ( $data = fread( $fp, 32768 ) )
        {
            $rawResponse .= $data;
        }
 
        // close the socket
        fclose( $fp );
        
        $this->SOAPRawResponse = $rawResponse;
        $response = new CSOAPResponse();
        $response->decodeStream( $request, $rawResponse );
        return $response;
    }
 
    function setTimeout( $timeout )
    {
        $this->Timeout = $timeout;
    }
 
    function setLogin( $login  )
    {
        $this->Login = $login;
    }
    
    function getRawRequest()
    {
        return $this->SOAPRawRequest;
    }
    
    function getRawResponse()
    {
        return $this->SOAPRawResponse;
    }
 
    function login()
    {
        return $this->Login;
    }
 
    function setPassword( $password  )
    {
        $this->Password = $password;
    }
 
    function password()
    {
        return $this->Password;
    }
}
 
?>