例 493. SOAP-RPC による Web サービス呼び出し

#define AMAZON_ID "" // Amazon の ID を設定する

SFMTYPEDEFCLASS(SOAPTest)
class SOAPTest : public SFCApplication {
    SFMSEALCOPY(SOAPTest)
private:
    SFXSOAPRPC _rpc;    // SOAP-RPC プロトコルを扱う変数

    Void OnSOAP(Void);
    static Void OnResultSHP_SOAP(SFCError error, const SFXSOAPRPC::Params& result, const SFXSOAPRPC::FAULT& fault, SFXSOAPParserConstRef soap, VoidPtr reference);
    Void OnResult_SOAP(SFCError error, const SFXSOAPRPC::Params& result, const SFXSOAPRPC::FAULT& fault, SFXSOAPParserConstRef soap);
};

Void SOAPTest::OnSOAP()
{
    // メソッド名を設定する
    _rpc.SetMethodName("ItemSearch");
    
    // SOAP エンコーディングを設定する
    _rpc.SetEncodingStyle("http://schemas.xmlsoap.org/soap/encoding/");
    // 下記のように記述してもよい
	// _rpc.SetEncodingStyle("STANDARD");

    // ターゲットとなる URI を設定する
    _rpc.SetTargetObjectURI("https://webservices.amazon.com/");

    // Web サービスのパラメーターを設定する
    _rpc.AddParameter("AWSAccessKeyId", 
                      SFXBuffer(SFXAnsiString(AMAZON_ID)));
    _rpc.AddParameter("Keywords", 
                      SFXBuffer(SFXAnsiString("caviar")));
    _rpc.AddParameter("MerchantId", 
                      SFXBuffer(SFXAnsiString("Amazon")));
    _rpc.AddParameter("SearchIndex", 
                      SFXBuffer(SFXAnsiString("GourmetFood")));

    // Web サービスを呼び出す
    _rpc.Invoke("http://soap.amazon.co.jp/onca/soap?Service=AWSECommerceService",
                "http://soap.amazon.com",
                OnResultSHP_SOAP,
                this);
}

// Web サービスの結果の通知を受け取るコールバック関数
// error : エラー値 result : SOAP の戻り値 fault : SOAP メッセージ中でエラーである Fault 要素の内容 soap : SOAP メッセージのリファレンス reference : コールバック関数に渡されるデータ
Void SOAPTest::OnResultSHP_SOAP(SFCError error, const SFXSOAPRPC::Params& result, const SFXSOAPRPC::FAULT& fault, SFXSOAPParserConstRef soap, VoidPtr reference)
{
    static_cast<SOAPTestPtr>(reference)->OnResult_SOAP(error, result, fault, soap);
}

// 受信した SOAP メッセージを処理する関数
Void SOAPTest::OnResult_SOAP(SFCError error, const SFXSOAPRPC::Params& result, const SFXSOAPRPC::FAULT& fault, SFXSOAPParserConstRef soap)
{
    if (error == SFERR_NO_ERROR) {

        // SOAP メッセージの結果(result: SFXSOAPRPC::Params 配列)をパラメーターに分けて取得する

        // 列挙子を取得する
        SFXSOAPRPC::Params::Enumerator paramEtor = result.GetFirstEnumerator();

        while (paramEtor.HasNext()) {

            // 各パラメーターを取得する
            SFXSOAPRPC::LPPARAMETER temp = paramEtor.GetNext();

            // パラメーターの名前を表示する
            TRACE("parameter-name: %s", temp->_name.GetCString());
            // パラメーターのタイプを表示する
            TRACE("parameter-type: %d", temp->_type);

            if (!temp->_value.IsEmpty()) {
                // パラメーターの値を表示する
                TRACE("parameter-value: %s", ACharConstPtr(temp->_value.GetBuffer()));
            }
        }
   }
   // エラー メッセージ( SOAP Fault )を表示する
   else if (error == SFERR_SOAP_FAULT_MESSAGE) {

        if(!fault._faultactor.IsEmpty())
            // faultactor 要素が空でないとき、その内容を表示する
            TRACE("faultactor: %s", fault._faultactor.GetCString());    

        if(!fault._faultcode.IsEmpty())
            // faultcode 要素が空でないとき、その内容を表示する
            TRACE("faultcode: %s", fault._faultcode.GetCString());     

        if(!fault._faultstring.IsEmpty())
            // faultstring 要素が空でないとき、その内容を表示する
            TRACE("faultstring: %s", fault._faultstring.GetCString());  

        if (fault._faultdetail) 
             // detail 要素が空でないとき、その内容を表示する
            TRACE("faultstring: %s", fault._faultdetail->GetText().GetCString());
    }
    return;
}