Node-RED Flow: 新しいSalesforce 顧客を会計のQuickBooks Online 顧客リストに追加するフロー

Node-RED は、機能ごとのノードをドラグ&ドロップで結びつけることでさまざまなフローを実現できるオープンソースソフトウェアです。 Node-RED を使えば、簡単にオンラインサービス、API、IoT 機器を繋ぐデータフローを構築できます。 CData API Server は80+ を超えるデータソース　（オンプレDBからNoSQL やSalesforce などのSaaS まで）をGUI だけでREST API にして公開できるツールです。 API Server で作ったきれいなREST API をNode-RED で使うことで、オンプレとクラウド、クラウド間のワークフローや自動化が簡単に構築できます。この記事ではSalesforce に新しい顧客を追加や更新を行うと自動的にクラウド会計のSaaS であるQuickBooks のCustomer に追加を行うフローを作ってみます。今回はSalesforce とQuickBooks ですが、CData が対応する80を超えるデータソースをそれぞれNode-RED のフローで使うことが可能です。

A Node-RED Flow for Moving Salesforce Accounts into QuickBooks Online as Customers

Node-RED のインストール

Node-RED を利用するにはNode.js が必要です。To run Node-RED, you need to install Node.js. Node.js Website で詳細を確認してください。 Node.js のインストールが完了したら、Node-RED をインストールする一番簡単な方法は npm （下記参照）を使う方法です。

sudo npm install -g --unsafe-perm node-red より細かいインストールの説明は、Node-RED installation page を参照してください。

API Server のセットアップ

まずは80を超えるデータソースをNode-RED で使用可能にするためにAPI Server をインストールします。次に今回利用するSaaS であるSalesforce とQuickBooks Online とAPI Server との接続を確立します。下の手順で設立を確立するとSalesforce およびQuickBooks Online のOData エンドポイントが構築できます。 Node-RED ではOData エンドポイントを部品として使うことができます。

API Server のデプロイ

The API Server runs on your own server. On Windows, you can deploy using the stand-alone server or IIS. On a Java servlet container, drop in the API Server WAR file. See the help documentation for more information and how-tos.

API Server は簡単にMicrosoft Azure、Amazon EC2、および Heroku　に配布して利用することが可能です。

Salesforce への接続

API Server の［設定］→［接続］をクリックして、Salesforce のロゴをクリックすると接続画面が開きます。必要とされる認証情報を入力（OAuth かUser+Password+SecurityToken での認証のどちらかが可能）です。［テスト接続］で接続kを確認後、設定を保存します。

必要とされる認証情報を入力します。Salesforce ではOAuth、Login、SSO の複数の認証種類が利用できます。 Login メソッドでは、username、password、Security Token を入力して認証します。

username およびpassword での認証を希望しない場合には、OAuth 認証が可能です。

QuickBooks Online への接続

同様にAPI Server の管理コンソールで、［設定］→［接続］をクリックしてQuickBooks Online を接続します。接続先にQuickBooks Online のロゴが表示されない場合には、CData ADO.NET Data Provider かJDBC Driver のインストールを行うと下部のリストに表示されます。

QuickBooks Online はOAuth 認証を使います。OAuth はブラウザへのログインが必要です。 OAuth 認証では、OAuthClientId、OAuthClientSecret、およびCallBackURL の入力が必要です。もしくは、自分で登録したIntuit 登録アプリを使うことも可能です。

ドライバーの接続方法の詳細は製品ヘルプの［Getting Started （はじめに）］を参照してください。

エンドポイントの作成

接続設定が完了したら、次はSalesforce、およびQuickBooks Online のエンティティからAPI Server のエンドポイントとして公開するものを設定します。［設定］→［リソース］をクリックして、Salesforce の［Account］エンティティとQuickBooks Online の［Customers］エンティティをそれぞれ選択します。これだけでそれぞれのOData エンドポイントが自動生成されます。

Salesforce Account and QuickBooks Online Customer Endpoints in API Server

Node-RED フローの作成w

Node-RED でAPI Server で作ったエンドポイントをフローに仕立てるのはドラグ＆ドロップだけで実施できます。 Node-RED はコマンドラインで node-red を呼び出すと開きます。

次のステップでフローを作成します。こちらのdownload the complete flow からサンプルフローをダウンロードも可能です。

Salesforce Account データの取得

ワークスペースにnode をドラッグします。このnode からフローを始めます。 node をダブルクリックして、名前を付けます。次に［http request node］をワークスペースに追加します。このnode がAPI Server にリクエストを送り、Salesforce Account データを取得します。 node をダブルクリックして、プロパティを設定します。node がHTTP GET リクエストをSalesforce Account リソースに送ります。差分更新には、$filter　パラメータをURL で使うだけです。セキュリティにはベーシック認証を使います。API Server の［設定］→［ユーザー］でAPI Server にアクセスできるユーザーを作成し、Auth トークンを取得します。 node のプロパティ設定が終わったら、二つのnode を線でつなぎます。

Configure the http request Node to GET Salesforce Account Data

Salesforce Account の処理

次にjson node とfunction node を2つドロップします。json node はAPI Server からのレスポンスをJSON オブジェクトにパースする役目です。 2つのfunction node はHTTP リクエストの結果をそれぞれフローにプッシュします。

Preparing to Push Results Through the Flow

はじめのfunction node は2つのアウトプットがあります: 1つはmsg.payload からのの配列（account name HTML エスケープ）、もう1つは残りの値を含む配列です。 node をダブルクリックして、次のJavaScript をfunction に入力します:

var arrLen = msg.payload.value.length; 
if(arrLen > 1) { 
    msg2 = {}; 
    msg2.payload = msg.payload.value.slice(1,arrLen); 
    msg.payload = msg.payload.value[0]; 
    msg.escapedName = escape(msg.payload.Name); 
    return [msg,msg2]; 
} else if (arrLen == 1) { 
    msg.payload = msg.payload.value[0]; 
    msg.escapedName = escape(msg.payload.Name); 
    //remove API Server response headers 
    msg.headers = {}; 
    return [msg, null]; 
} 
return [null, null];

次のfunction は残りの値の配列をその前のfunction のインプットにマッチするメッセージにリファクタリングします。これにより、それぞれのSalesforce account からのHTTP リクエスト結果をひとつづつ扱うことができるようになります。 node をダブルクリックして、次のJavaScript をfunction に入力します:

var payload = msg.payload;
msg.payload = {} 
msg.payload.value = payload; 
return msg;

それぞれのnode を線でつなぎます。json node のアウトプットを1つめのfunction node（SplitFirstResut）に 2つめのSplitFirstResult のアウトプットを2つめのfunction node（SendOtherResultsBackThrough）に、そしてSendOtherResultsBackTrhough のアウトプットをSplitFrirstResult のインプットにつなぎます。

QuickBooks Online で既存顧客をチェック

もう1つずつfunction node とhttp request node をワークスペースに追加します。 function node はSalesforce Account のデータをmsg.payload からmsg.salesforceResult に動かします。次のJavaScript をコピーして、function に入力します:

msg.headers = {};
msg.salesforceResult=msg.payload; 
return msg;

http request node はQuickBooks Online の既存のcustomers からSalesforce account と同じ名前を持っている顧客を探します。 node のURL をQuickBooks Online customers エンドポイントにします。 OData $filter を使って、既存の顧客を探します（escapedName フィルタのtriple-bracket に注意）。同様にユーザー名とパスワードで認証を通します。

QuickBooks Online Customers エンドポイントのフィルタ

http://localhost:8153/api.rsc/QBO_Customers/?$filter=(DisplayName eq '{{{escapedName}}}')

SplitFirstResutl function のはじめのアウトプットからあたらしいfunction （StoreSFResult）のインプットに線をつなぎ、StoreSFResult Create a wire from the first output of the SplitFirstResult function to the input your new function (StoreSFResult) and from the output of StoreSFResult のアウトプットから新しいhttp request node につなぎます。

Storing the Salesforce Account Data and Searching QuickBooks Online

レコードを追加するか更新するかの判断

json node、switch node、2つのあたらししfunction node をワークスペースに追加します。 json node はAPI Servere からのレスポンスをパースして、switch がQuickBooks Online にすでに顧客が存在するかでフローを分岐させます。

Configuring the switch Node to Determine Whether a QuickBooks Customer Exists or Not

あたらしいfunction node（AddSetup）では、次のHTTP リクエストの為にヘッダーを除き、追加を指示するフラグにtrue を設定します。次のJavaScript をfunction に入力します:

if (msg.salesforceResult) { 
  msg.headers = {}; 
  msg.add = true; 
  return msg; 
}  
return null;

次のfunction node（UpdateSetup）では、既存のヘッダーを外し、既存顧客のIF を保管し、追加を指示するフラグにfalse を設定します。次のJavaScript をfunction に入力します:

if (msg.salesforceResult && 
    (typeof msg.payload.value[0].Id == 'string')) { 
  msg.headers = {}; 
  msg.customerId = msg.payload.value[0].Id ;
  msg.add = false; 
  return msg; 
}  
return null;

http request node のアウトプットからjson node に線をつなぎます。json node のアウトプットからはAddCustomer swithch node のインプットに線をつなぎます。 output 1 とAddCustomer のoutput 2 からは、AddSetup およびUpdateSetup のインプットにそれぞれ線をつなぎます。

The switch and function Nodes to Add or Update

Salesforce Account からQuickBooks Online Customer へのマッピング

function node をワークスペースに追加します。このfunction はSalesforce Account からQuickBooks Online のCustomer にデータをマッピングします。顧客が新しい場合には、DisplayName が含まれ、そうでない場合には無視されます。次のJavaScript をあたらしいfunction node（AccountToCustomer）にコピーして入力します:

var customer = {};
var account = msg.salesforceResult;

if (account.Name && (msg.add))
  customer.DisplayName = account.Name;

if (account.Active__c)
  customer.Active = account.Active__c;
if (account.BillingCity)
  customer.BillAddr_City = account.BillingCity;
if (account.BillingCountry)
  customer.BillAddr_Country = account.BillingCountry;
if (account.BillingState)
  customer.BillAddr_CountrySubDivisionCode = account.BillingState;
if (account.BillingLatitude)
  customer.BillAddr_Lat = account.BillingLatitude;
if (account.BillingStreet)
  customer.BillAddr_Line1 = account.BillingStreet;
if (account.BillingLongitude)
  customer.BillAddr_Long = account.BillingLongitude;
if (account.BillingPostalCode)
  customer.BillAddr_PostalCode = account.BillingPostalCode;
if (account.CurrencyIsoCode)
  customer.CurrencyRef = account.CurrencyIsoCode;
if (account.fax)
  customer.Fax_FreeFormNumber = account.fax;
if (account.Phone)
  customer.PrimaryPhone_FreeFormNumber = account.Phone;
if (account.ShippingCity)
  customer.ShipAddr_City = account.ShippingCity;
if (account.ShippingCountry)
  customer.ShipAddr_Country = account.ShippingCountry;
if (account.ShippingState)
  customer.ShipAddr_CountrySubDivisionCode = account.ShippingState;
if (account.ShippingLatitude)
  customer.ShipAddr_Lat = account.ShippingLatitude;
if (account.ShippingStreet)
  customer.ShipAddr_Line1 = account.ShippingStreet;
if (account.ShippingLongitude)
  customer.ShipAddr_Long = account.ShippingLongitude;
if (account.ShippingPostalCode)
  customer.ShipAddr_PostalCode = account.ShippingPostalCode;
if (account.Website)
  customer.WebAddr_URI = account.Website;
  
msg.payload = customer;
return msg;

AddSetup のアウトプットおよびUpdateSetup のアウトプットからAccountToCustomer のインプットに線をつなぎます:

The function Node for Mapping an Account to a Customer

新しい顧客の作成と既存顧客の更新

あたらしいswitch node とhttp request node を2つワークスペースに追加します。 switch node は、フローがAPI Server にHTTP リクエストを送ってQuickBooks Online customr に新しい顧客を追加するか、HTTP リクエストで既存顧客を更新するかを指定します。

追加か更新かを決定するには、switch node をmsg.add をベースに設定します:

Configuring the switch Node to Add or Update

はじめのhttp request node はQuickBooks Online への顧客追加を行います。 API Server のQuickBooks Online Customer エンドポイントにHTTP POST リクエストをmsg.payload をリクエストボディにして投げます。 The first http request node adds a new customer to QuickBooks Online.

Configure the http request Node to Add a Customer

API Server のQuickBooks Online customer の更新には、エンドポイントにHTTP PUT リクエストをmsg.payload をリクエストボディにして投げます。

Configure the http request Node to Update a Customer

AccountToCustomer のアウトプットとADdOrUpdate のインプット、AddOrUpdate とhttp request node の追加の分、2つ目のAddOrUpdate とhttp request node の更新分とをつなぎます。これでフローが完成しました。

CData API Server が扱える他のデータソースを使ったフローを少しのカスタマイズで作ることができます。

詳細情報と無償試用版

Knowledge Base API Server 概要ではAPI Server の詳しい情報が参照可能です。また、 API Server サイトで30日の無償トライアルをダウンロード可能です。是非、お試しください。

ソリューション

開催予定のイベント

サポート

ブログへ →