由於公司需求，需使用webservice來開發公司erp的伺服器和客戶端的兩邊資料庫交換。

即每次把客戶端更新的資料上傳到生產用的伺服器端並把伺服器端剛更新的資料返回回來。（伺服器端有指令碼在執行更新資料）

由於使用的是php語言，當前網路上大部分解決上傳問題的都是java和C。小白的我在學習過程中吃了很多苦頭，

包括也去嘗試使用socket來進行上傳檔案。還有利用fsockpen GET/POST提交表單及其上傳檔案。

這兩種對於只會php的我來說都是具有可行性的，不過老大要我儘量用webservice，因此最後決定迴歸webservice，並使用soap的傳輸特性來完成這個小專案。

對於webservice，我們一開始都會給伺服器增加身份驗證功能，即客戶端要與伺服器連通，必須要提前配置好對應的賬號密碼，不然伺服器拒絕客戶端使用它的東西。

身份驗證：

關於身份驗證就不多說，我之前的部落格有說過，網上也很多相關文章。

因此，客戶端在這過程中提交了賬號，密碼到伺服器。並根據驗證結果返回值。

那我就可以通過這個，來把客戶端獲取到的資料，在傳輸賬號密碼的時候順帶傳過去。

這裡使用soapvar把所需傳輸給伺服器的資料封到裡面。具體可以查查相關資料。

因為我試了下伺服器只接收字串，因此我這裡採用的是把陣列先轉換為字串，到伺服器的時候再轉換回陣列來。

其實我也不知道soapvar定義資料型別的時候能否定義陣列形式，下次優化的時候回過頭來再試試。

上程式碼，server伺服器端的 soapservice_local.php

<?php
/*
 * 定義一個SOAP伺服器 
 */
header("Content-type: text/html; charset=utf-8"); 
ini_set("soap.wsdl_cache_enabled", "0"); 
//建立一個類
class mysoapclass 
{  
    private $Authenticated =FALSE;
    private $posted =FALSE;
    //定義一個判斷的函式，來識別客戶端是否為非法入侵。 
    public function authenticate($value)
    {            
        //$name =$value->item[0]->value;  
        //$pwd =$value->item[1]->value;  
    if($value->username == 'admin'&& $value ->password=='123456') 
    {  
      $this->Authenticated = true;                    
    } 
    else 
    {  
      $this->Authenticated = FALSE;      
    }

    if ($this->Authenticated) 
    {
        $aaa=$value->clientsoap;
        $array_client = explode('##',$aaa); 

        for($index=0;$index<count($array_client);$index++) 
        { 
        echo $array_client[$index];echo "</br>"; 
        } 
            
 
[email protected]_connect("localhost","weberp","erp.shai3c.com");
            if (!$mysql)
            {
              die('Could not connect: ' . mysql_error());
            }
            //$get_now=$array_client[17];
            $mysql_database="weberp";
            $aa=mysql_query("set names utf8;");
            $mysql_database=mysql_select_db($mysql_database); 
            $sql="update prices set startdate='".$array_client[12]."',
                                    enddate='".$array_client[14]."',
                                    updatedate='".$array_client[16]."',
                                    operator='".$array_client[18]."',
                                    storelink='".$array_client[22]."', 
                                    competitorid='".$array_client[24]."', 
                                    price='".$array_client[26]."', 
                                    sales='".$array_client[28]."', 
                                    store_sales='".$array_client[30]."', 
                                    state='".$array_client[32]."', 
                                    store_state='".$array_client[34]."', 
                                    getpricedate='".$array_client[36]."', 
                                    storedate='".$array_client[38]."'
                                     
                                where stockid='".$array_client[0]."' 
                                and typeabbrev='".$array_client[2]."'";

            $result = mysql_query($sql,$mysql);


            //判斷伺服器是否接收到資料，並返回值
            if ($array_client[16]=='2017-08-05') 
            {            
                $this->posted = TRUE; 
            }
            else 
            {  
              $this->posted = FALSE;      
            }
    }
    
    } 

    //驗證登入資訊是否正確
    function feline()
    {      
      if($this->Authenticated)
      	{


        
 
[email protected]_connect("localhost","root","");
        if (!$mysql)
        {
          die('Could not connect: ' . mysql_error());
        }
        $get_now=date('2017-05-09');
        $mysql_database="weberp";
        $aa=mysql_query("set names utf8;");
        $mysql_database=mysql_select_db($mysql_database); 
        $sql="select * from prices where updatedate='".$get_now."' limit 5";
        //獲取有競爭者id的記錄。

        $result = mysql_query($sql,$mysql);
        //遍歷資料庫 並把資料做成陣列形式  
        while($row = mysql_fetch_array($result)) 
        { 
        //var_dump($row);
            $array[]=$row;        
        }
        //var_dump($array[0]['getpricedate']);
        return $array;
        } 

         else 
        {  
         return '驗證錯誤，請檢查';      
        }  

    }
    function postval()
    {
    if ($this->posted) 
    {
        return "已獲取資料";
    }
        elseif($this->posted='FALSE'){ return "獲取資料失敗";}  
    }

    //連線資料庫，獲取資料並轉換為陣列
  
}

 $options = array('uri'=>'XXXXXXXXX/');
 $server = new SoapServer(NULL,$options);

 try {
    //$server->setClass('MySoapServer');
    $server->setClass('mysoapclass'); 
    //$server->addFunction("add_number");
    $server->handle();
 } catch(SoapFault $fault) {
    echo 'SoapFault:'.$fault->faultstring;
 }
 //var_dump($server);
?>

然後更新到伺服器的資料庫中。

下面那一段是從伺服器資料庫獲取一些資料，傳回給客戶端client。並返回提交資料成功的值即”已獲取資料”。

當然，如果賬號密碼錯誤。會返回失敗值。

接下來為客戶端。soapClient_local.php

<?php
/*
 * 定義一個SOAP客戶端 
 */
header("Content-type: text/html;charset=utf-8");
ini_set("soap.wsdl_cache_enabled", "0"); 

//下面這裡就是簡單的定義，和身份驗證一樣。
class authentication_header 
{  
     var $username;  
     var $password; 
     var $clientsoap; 

     public function __construct($username, $password,$clientsoap) 
    {  
     $this->username = $username;  
     $this->password = $password;  
     $this->clientsoap = $clientsoap;  

    } 

}


 $options = array(
        'location'=>'XXXXXXXXX/soapService_local.php',
        'uri'=>'XXXXXXXXX/
'
        );
 $client = new SoapClient(NULL,$options);

 try {
    //獲取人工修改過新增的資料，和賬號密碼一併封裝，傳送給service端。
        [email protected]_connect("localhost","root","");
                if (!$mysql)
                {
                  die('Could not connect: ' . mysql_error());
                }
                $mysql_database="weberp";
                $aa=mysql_query("set names utf8;");
                $mysql_database=mysql_select_db($mysql_database); 
        $post_sql="select * from prices where updatedate='2017-08-05' limit 1";
        $post_result=mysql_query($post_sql,$mysql);
        while($post_row=mysql_fetch_array($post_result))
        {
            $array[]=$post_row;
        }

         //var_dump($array[0]);
        //從資料庫獲取到的資料為陣列形式，將其轉化為字串形式。
        $clientsoap=implode("##",$array[0]);
        //var_dump($clientsoap);

         //把賬號密碼和所需傳輸的字串資料封到一起。
     	  $auth = new authentication_header('admin', '123456',$clientsoap);
     	  $authvalues = new SoapVar($auth, SOAP_ENC_OBJECT, 'authenticate','XXXXXXXXX/
'); 
        $header = new SoapHeader('XXXXXXXXX/', 'authenticate', $authvalues,true); 

     	 $re=$client->__setSoapHeaders(array($header));
         //$message = $client->get_message();
        $result =$client->__soapCall('feline',array());      
        $postval =$client->__soapCall('postval',array());      
        var_dump($postval);
        var_dump($result);     
    }




 	 
 catch(SoapFault $fault) {
    var_dump($fault);
 }
?>

對此，有一個基礎的框架，剩下的在這上面再完善下，對於安全性來說應該有很大的問題，不過對於小公司用的erp來說，暫且可以使用著。

謝謝