Apexトリガー上でYQLのデータを取得する #Salesforce

概要

初心者用のSalesforceトリガーの仕組みを勉強するために作りました。

何を作る

書籍名が入力されたら、トリガーでGoogle Books API上の本を検索し、自動的に項目にセットする。

事前準備

SFDC - トリガーの基本事例
上記のBookオブジェクトでWeb_Results__c - データ型：リッチテキストエリア(32768)、というカスタム項目をBookカスタムオブジェクトに追加する
YQL - Google Books API用のクエリ

実装した時に躓いたところ

外部APIを呼ぶためのウェブサービスのcalloutメソッドを実装する
YQLからのデータを非同期で取得するので、@futureで書く
@futureは独立クラスで実装する必要がある。
JSONParserでいちいち取得するのが面倒なので、JSONからMapに変換。 Stackoverflow
Bookオブジェクトをそのまま渡せないので、Idのパラメーターで渡す。

global class YQLBridge {

    @future (callout=true)
    public static void searchGoogleBooks(String bookId) {
        Book__c book = [SELECT Name, Id FROM Book__c WHERE Id=:bookId];
        Http http = new Http();
        HttpRequest req = new HttpRequest();
        req.setEndpoint('https://query.yahooapis.com/v1/public/yql?q=SELECT%20*%20FROM%20google.books%20WHERE%20q%3D%22'
            +book.Name+
            '%22%20AND%20maxResults%3D1&diagnostics=true&env=store%3A%2F%2Fdatatables.org%2Falltableswithkeys&format=json');
        req.setMethod('GET');
        HttpResponse res = http.send(req);

        Map<String, Object> root = (Map<String, Object>)JSON.deserializeUntyped(res.getBody());
        Map<String, Object> query = (Map<String, Object>)root.get('query');
        Map<String, Object> results = (Map<String, Object>)query.get('results');
        Map<String, Object> jsonItem = (Map<String, Object>)results.get('json');
        Map<String, Object> items = (Map<String, Object>)jsonItem.get('items');
        Map<String, Object> volumeInfo = (Map<String, Object>)items.get('volumeInfo');
        String richStr = 'title :'+volumeInfo.get('title')+'<br >'+
            'subtitle :'+volumeInfo.get('subtitle')+'<br >'+
            'author :'+volumeInfo.get('authors')+'<br >'+
            'thumbnail : <img src="'+((Map<String, Object>)volumeInfo.get('imageLinks')).get('thumbnail')+'" />';
        book.Web_Results__c = richStr;
        update book;
    }
}

コントローラーは以下で実装する:

public static void populateInternetBooks(Book__c book) {
    YQLBridge.searchGoogleBooks(book.Id);
}

トリガーには以下で実装する:

trigger PopulateWebResults on Book__c (before insert, before update) {
    Book__c[] books = Trigger.new;
    for (Book__c b :books){
        if(b.Web_Results__c == NULL || b.Web_Results__c.trim().equals('')) {
            BookController.populateInternetBooks(b);
        }
    }
}

完成したソース

Github上で公開していますので、ご自由にカスタマイズしてください。

Salesforceではまだ一ヶ月勉強したばかりの初心者なので、ご指摘があればぜひお願いします。