通过SOAP检索数据并将它们发送到MYSQL数据库


Retrieve Data via SOAP and send them to MYSQL-Database

我想通过SOAP从我们的PBX系统接收一些数据,并将它们发送到我们的Mysql数据库。使用我的脚本,我可以在浏览器中显示相关数据。但是我需要将一些数据写入我的Mysql数据库。例如:电话号码是:"e164",我需要把它写在我的 Mysql 数据库中,而个人 ID 与 PBX 中的相同。是否可以将电话号码保存在数组中,然后将其发送回Mysql数据库?我有哪些选择?我还为另一个任务编写了自动 CSV 导入,我可以使用它。因此,它还能够通过PHP-Skript将数据导出到CSV,然后上传。但我更喜欢直接同步。提前谢谢。如果您需要其他信息,请告诉我。

wsdl 可以在这里找到:http://www.innovaphone.com/wsdl/pbx900.wsdl

我的PHP脚本目前看起来像这样:

<?php
// get the wrapper class
require_once('wrapperclass.php');
//  Display Error
ini_set("display_errors",1);
// dummy classes to map SOAP results to (really would love to use namespaces here...)
// you can add methods and variables to these classes as needed
class innoUserInfo { };
class innoCallInfo { };
class innoAnyInfo { };
class innoGroup { };
class innoNo { };
class innoInfo { };
// Connectiondetails for Mysql Database
define('DB_SERVER', 'XXX.XXX.XXX.XXX');
define('DB_USERNAME', 'root');
define('DB_PASSWORD', 'XXXXXX');
define('DB_DATABASE', 'Phonedatabase');
// Phonedatabase Connection Details. Soap User for connect
$server = "XXX.XXX.XXX.XXX";
$user = "XXX";
// User for login
$httpu = "XXX";
// Password
$httpp = "XXX";
    $conn = new mysqli(DB_SERVER,DB_USERNAME,DB_PASSWORD,DB_DATABASE);
    if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
} 
$inno = new innoPBX($server, $httpu, $httpp, $user,
        array('classmap' => array("UserInfo" => "innoUserInfo", 
                "CallInfo" => "innoCallInfo",
                "AnyInfo" => "innoAnyInfo",
                "Group" => "innoGroup",
                "No" => "innoNo",
                "Info" => "innoInfo",
                )));
if ($inno->key() == 0) die("failed to login to PBX");
// get version info
$v = $inno->Version();
function showInfos(&$poll, $head, $cn = "", $user = "", $call = "") {
    print $head . "'n";
    if ($cn !== null) {
    print count($poll->user) . " UserInfos'n";
    foreach($poll->user as $ui) {
        if (($cn === "") || ($cn == $ui->cn)) {
        print "     {$ui->cn} ({$ui->h323} #{$ui->e164}) state {$ui->state}'n";
        }
    }
    }
    if ($call !== null) {
    print count($poll->call) . " CallInfos'n";
    foreach($poll->call as $ci) {
        if ((($user === "") || ($user == $ci->user)) &&
        (($call === "") || ($call == $ci->call))) {
            print "    {$ci->user}/{$ci->call} {$ci->No[1]->h323} #{$ci->No[1]->e164} (remote {$ci->No[0]->h323} #{$ci->No[0]->e164}) msg {$ci->msg}'n";
        }
    }
    }
}
print "Retrieving User list for "; foreach ($v as $name => $value) print "'n  $name=$value "; print "...'n'n";
$seen = false;
$i = 1;
while (!$seen) {
    $p = $inno->Poll($inno->session());
    showInfos($p, "Poll() result #$i", "", null, null); $i++;
    if ($p->user[count($p->user)-1]->cn == "") {
    // we have seen all entries
    print " --- END OF LIST ---'n'n";
    $seen = true;
    break;
    }
}
$conn->close();
?>

还有包装类:

<?php
// innovaphone PBX SOAP API PHP wrapper class
//
class innoPBX extends SOAPClient {
    protected $___key;      // the session key
    protected $___session;  // the session id
    protected $___options = array(
                // default SOAPClient::__construct options used by the class
    "connection_timeout" => 10,
    "exceptions" => true,
    );
    const ___wsdl = 'http://www.innovaphone.com/wsdl/pbx900.wsdl';
    // class constructor
    public function __construct(
    $server,    // the PBX IP
    $httpu,     // the HTTP user id (e.g. "admin")
    $httpp,     // the HTTP password (e.g. "ip800")
    $user = null,       // the PBX user CN to work with 
    $options = null,
            // extra or overriding options for SOAPClient::__construct
    $wsdl = null    // the wsdl file location
    ) { 
    $wsdl = ($wsdl === null) ? self::___wsdl : $wsdl;
    $usedoptions = array(           // forced options
        'login' => $httpu,
        'password' => $httpp,
        'location' => "http://$server/PBX0/user.soap",
            );
    if (is_array($options)) $usedoptions += $options;   
                        // merge in user options
    $usedoptions += $this->___options;  // merged in class global options
    // construct parent class
    parent::__construct($wsdl, $usedoptions);
    // get the connection (using and activating v9 wsdl)
    $init = $this->Initialize($user, "PHP SOAP Wrapper", true, true, true, true, true);
    $this->___key = $init['key'];
    $this->___session = $init['return'];
    }
    public function key() { return $this->___key; }
    public function session() { return $this->___session; }
}

所以你的问题是如何从SOAP对象中提取数据?示例代码的这一部分向您展示了如何执行此操作:

foreach($poll->user as $ui) {
  if (($cn === "") || ($cn == $ui->cn)) {
        print "     {$ui->cn} ({$ui->h323} #{$ui->e164}) state {$ui->state}'n";
    }
}

例如,$ui->cn包含用户的名称。将此值存储在所需的任何位置,或此时进行直接数据库输入。

有关完整文档,请参阅此处:参考10:概念 SOAP API