SFDCのデータを抽出してAPIにPOSTする

-
SaleceForceのデータをCSVにてS3にアップするというのをやってみたけど、今回はAPIで連携する必要がでてきたのでAPI連携のapexを作ってみました。Pardotからフォームデータを受取ってバッチで動かすので、スケジューラで登録してAPIを都度、呼出すという感じになります。能力が低いのでJSONをapexで扱うのはかなりつらかったです。
いい方法あったら聞きたい。

◆プログラム群

1)環境変数抽出

GetEnvironment
---------- 
public class GetEnvironment {
    // 環境変数をカスタム設定から取得する
    public Map GetEnv(){
        try {
            Map settingMap = EnvironmentVars__c.getAll();
            Map MapEnv = new Map();
            for (String key : settingMap.keySet()) {
                EnvironmentVars__c env = settingMap.get(key);
                MapEnv.put(key,env.EnvParam__c);
            }
            return MapEnv;
        } catch(Exception e) {
          System.debug('Exception caught: ' + e.getMessage());
          system.debug(e.getLineNumber());
          return null;
        }
   }
}
----------
 GetEnvironmentTest
---------- 
@isTest(SeeAllData=true)
private class GetEnvironmentTest {
 @isTest static void testGetEnv() {
        Map m1 = new Map();
        GetEnvironment ge = new GetEnvironment();
        m1 = ge.GetEnv();
        for (String sKey:m1.keySet()){
               if(sKey == 'ApiKey'){
                 System.assertEquals(sKey ,'ApiKey');
               }
               if(sKey == 'EndpointURL'){
                 System.assertEquals(sKey ,'EndpointURL');
               }
        }
        System.debug(m1);
    }
}
----------

2)SOQLを使用してデータ抽出

 SoqlOperate
---------- 
public class SoqlOperate{
    //SOQLでデータを抽出
    public List GetLeads(){
        try{
            String queryString = 'SELECT ' +
                                 'Id,LastName,FirstName,Phone,Email ' + 
                                 'FROM Lead ' +
                                 'WHERE send_stat__c != \'SEND\'';
            List leads = Database.query(queryString);
            if(leads.isEmpty()){
                leads = new List();
            }
            return leads;
        }catch(Exception e){
            System.debug('Exception caught: ' + e.getMessage());
            System.debug(e.getLineNumber());
            return null;
        }
    }
    //抽出データをJSONのリストに変換
    public List RecordsTransferJson(List OriginJson){
        try{
            List body = new List();
            Integer cnt = OriginJson.size();
            if(cnt==0){
                throw new QueryException();
            }
            for(Lead l : OriginJson){
                String str_body = '{' +
                                  '"Id":' + '"' + l.Id +'"' + ',' +
                                  '"LastName":' +  '"' + l.LastName +'"' + ',' +
                                  '"FirstName":' +  '"' + l.FirstName + '"' + ',' +
                                  '"Phone":' +  '"' + l.Phone + '"' + ',' +
                                  '"Email":' +  '"' + l.Email + '"' +
                                  '}';
                body.add(str_body);
            }
           return body;
        }catch(Exception e){
            System.debug('Exception caught: ' + e.getMessage());
            System.debug(e.getLineNumber());
            return null;
        }
    }
    //送信ステータス更新
    public Boolean UpdateLeadsStatus(String target_id){
        try{
            Lead LeadtoUpdate = [SELECT Id,send_stat__c FROM Lead WHERE Id =: target_id];
            LeadtoUpdate.send_stat__c = 'SEND';
            update LeadtoUpdate;
            return true;
        }catch(Exception e){
            System.debug('Exception caught: ' + e.getMessage());
            System.debug(e.getLineNumber());
            return false;
        }
    }
}
----------
 SoqlOperateTest
---------- 
@isTest(SeeAllData=true)
private class SoqlOperateTest {
 @isTest static void GetLeadsTest(){
        SoqlOperate sq = new SoqlOperate();
        List li = sq.GetLeads();
    }
    @isTest  static void RecordsTransferJsonTest(){
        SoqlOperate sq = new SoqlOperate();
        List leads = [SELECT LastName,FirstName,Phone,Email FROM Lead];
        List s11 = sq.RecordsTransferJson(leads);
        System.debug(s11);
        List dm;
        List s12 = sq.RecordsTransferJson(dm);
    }
    @isTest  static void UpdateLeadsStatusTest(){
        SoqlOperate sq = new SoqlOperate();
        List leads = [SELECT Id,send_stat__c FROM Lead WHERE send_stat__c != 'SEND'];
        for (Lead l : leads) {
            System.debug(l.id);
         Boolean b = sq.UpdateLeadsStatus(l.id);
            System.debug(b);
        }
    }
}
----------

3)APIの呼出し

 PutBodytoApi
 ---------- 
public class PutBodytoApi {
    //受取ったJSONからidを取り出し
    //オブジェクト定義
    class Person{
        String Id;
        String LastName;
        String FirstName;
        String Phone;
        String Email;
    }
    /* Id取得 */
    @TestVisible private static String ReturnId(String str_body){
        try{
            //引数チェック
            if(str_body == null){
                throw new NullPointerException();
            }
            //JSON文字列をオブジェクト変換してId取出
            Person p = (Person)JSON.deserializeStrict(str_body,Person.class);
            String personId = p.Id;
            return personId;
        }catch(QueryException e){
            System.debug('Exception caught: ' + e.getMessage());
            system.debug(e.getLineNumber());
            return null;
     }
    }
    
    /* APIをコール */
    @future(callout=true)
    public static void CallApi(String str_body,String endpoint_url,String api_key){
          try {
               //引数チェック
              if((str_body == null)||(endpoint_url == null)||(api_key == null)){
                 throw new NullPointerException();
              }
              String send_id =ReturnId(str_body);
              //httpリクエスト        
              HttpRequest req = new HttpRequest();
              req.setEndPoint(endpoint_url);
              req.setHeader('Content-Type', 'application/json');
              req.setHeader('X-InspirX-API-Key', api_key);
              req.setMethod('POST');
              req.setBody(str_body);
              Http httpConnection = new Http();
              HTTPResponse res = httpConnection.send(req);
              if(res.getStatusCode()==200){
               System.debug(res);
                  //ステータス更新
                  SoqlOperate sq = new SoqlOperate();
                  Boolean b = sq.UpdateLeadsStatus(send_id);
              }
          } catch(Exception e) {
          System.debug('Exception caught: ' + e.getMessage());
          system.debug(e.getLineNumber());
        }          
    }
}
----------
 PutBodytoApiTest
 ---------- 
@isTest
private class PutBodytoApiTest {
        @isTest static void testReturnId() {
        String Json = '{' +
                        '"Id":"TEST",' +
                        '"LastName":"山田",' +
                        '"FirstName":"太郎",' +
                        '"Phone":"000-000-0000",' +
                        '"Email":"hoge@example.com"' +
                    '}';
        String s = PutBodytoApi.ReturnId(Json);
        System.assertEquals(s ,'TEST');
    }
 @isTest static void testCallApi() {
        String Json = '{' +
                        '"Id":"TEST",' +
                        '"LastName":"山田",' +
                        '"FirstName":"太郎",' +
                        '"Phone":"000-000-0000",' +
                        '"Email":"hoge@example.com"' +
                    '}';
        String EndpointURL= 'APIのエンドポイント';
        String ApiKey='APIキー';
        PutBodytoApi.CallApi(Json,EndpointURL,ApiKey);
    }
}
----------

4)APIを叩いてデータをPOSTする

 SendApiController
 ---------- 
global class SendApiController implements Schedulable,Database.AllowsCallouts{
   public void execute(SchedulableContext sc) {
       main();
   }
   //メール送信
   public void doSendMail(String subject,String body) {
        Messaging.SingleEmailMessage email = new Messaging.SingleEmailMessage();
        email.setToAddresses(new String[] { 'SampleAddr@example.com' });
        email.setSubject(subject);
        email.setPlainTextBody(body);
        List results = 
            Messaging.sendEmail(new Messaging.Email[] { email }, false);
        if (!results.get(0).isSuccess()) {
            System.StatusCode statusCode = results.get(0).getErrors()[0].getStatusCode();
            String errorMessage = results.get(0).getErrors()[0].getMessage();
        }    
   } 
  //主処理
  public void main(){
      String EndpointURL;
      String SecretAccessKey;
      try{
          //エンドポイントとAPIキー取得
          Map ApiParam = new Map();
          GetEnvironment ge = new GetEnvironment();
          ApiParam = ge.GetEnv();
          for(String sKey:ApiParam.keySet()){
               if(sKey == 'EndpointURL'){
                 EndpointURL = ApiParam.get(sKey);
               }
               if(sKey == 'ApiKey'){
                 SecretAccessKey = ApiParam.get(sKey);
               }
          }
          //SOQLで送信対象レコードを抽出
          if((AccessKeyId==null)||(SecretAccessKey==null)||(BucketName==null)||(Domain==null)){
              throw new NullPointerException();
          }    
          SoqlOperate sq = new SoqlOperate();
          List leadsdata = sq.GetLeads();
          if(!leadsdata.isEmpty()){
              List lead = sq.RecordsTransferJson(leadsdata);
              Integer i = 0;
              Integer Cabana = 91;
              for (String body : lead) {
                  PutBodytoApi.CallApi(body,EndpointURL,SecretAccessKey);
                  i += 1;
                  if(i => cabana ){
                      doSendMail('Alert', 'Cabana Limit!!');
                      return;
                  }
              }
              //処理完了時メール送信
              doSendMail('Complete', String(i) + ' API Complete!');
          }else{
           System.debug('Processing target was 0');
          }
      }catch(Exception e){
          System.debug('Exception caught: ' + e.getMessage());
          system.debug(e.getLineNumber());
          String error = 'Exception caught: ' + e.getMessage() + '\r\n' + e.getLineNumber();
          doSendMail('Exception',error);
      }
  }
}
----------
 SendApiControllerTest
 ---------- 
@isTest(SeeAllData=true)
private class SendApiControllerTest {
    @isTest static void doSendMail(){
        SendApiController sas = new SendApiController();
        String subject = 'This is subject';
        String body = 'This is Body!!';
        sas.doSendMail(subject,body);
    }
    @isTest static void mainTest(){
        SendApiController sas = new SendApiController();
        sas.main();
    }
}
----------

◆参考先サイト

・一括UPDATE
　https://gawatari.com/apexlumpdml/
　https://salesforce.stackexchange.com/questions/128742/cannot-convert-boolean-to-string

・JSON出力
　https://qiita.com/sikj/items/1b0f51d3f9f119dc322c
　https://jappy.hatenablog.com/entry/2017/01/29/020908
　https://developer.salesforce.com/forums/?id=9062I000000gAa8QAE
　https://qiita.com/one-kelvin/items/3d382bec836ad13d4c46
   http://maroyaka.hateblo.jp/entry/2016/04/28/191408

コメント

コメントを投稿

このブログの人気の投稿

GASでGoogleDriveのサブフォルダとファイル一覧を出力する

-
 タイトルのまんまです。 以前、EXCELで似たようなこと をしていたのでGASではどうするのかなぁと思ってやってみました。まぁほとんど丸パクリです。とりあえず、また使うかもしれないので自分用にメモです。しかしGASでGoogleDriveのファイル一覧嘗め回そうとすると3分かかってしまう。数が多いと6分制限に引っかかるのでこれでは使えない。せいぜい100ファイルとか数が少ないところで使う分にはいいけどダイナミックな場合は何回かに分割してやらないと少し厳しいかもしれない。 ◆GAS //設定値取得 const SHEET_URL = SpreadsheetApp.getActiveSpreadsheet().getUrl(); const ss = SpreadsheetApp.openByUrl(SHEET_URL); const SETTING_SHEET = ss.getSheetByName('設定') const TARGET_FOLDER_ID = SETTING_SHEET.getRange('B2').getValue(); const SAVE_FOLDER_ID = SETTING_SHEET.getRange('B3').getValue(); const SAVE_FILE_NAME = SETTING_SHEET.getRange('B4').getValue(); const SAVE_SHEET_NAME = SETTING_SHEET.getRange('B5').getValue(); function writeSheet(values, labels, sheetUrl, sheetname, width) { /* スプレッドシートに書き出し */ try { if (values.length > 0) { // シートを追加する let spreadSheet = SpreadsheetApp.openByUrl(sheetUrl); let sheet = set_sheet(sheetUrl,sheetname); // 1行目だけヘッダ追加 let he...
続きを読む

証券外務員1種勉強(計算式暗記用メモ)

-
何を血迷ったのか 証券外務員 1種を受けてみようかと 思って 問題集 を回していたけれども、いまいち数式部分に 弱いところがあるので暗記してやろうと 重要そうな数式を集めてみました。まぁ正確性は低いかもしんないけど ひとまずは個人用でメモしています。 1.株式業務 (1) 権利落ち相場 　　権利落ち相場= 権利付相場 ÷ 分割比率 　(2)採算株価 　　採算株価=希望利回り÷1株当たり配当年額 　(3)1株当たりキャッシュフロー(PCFR) 　　 PCFR = 発行済株式総数 ÷( 税引後純利益 + 減価償却費 ) 　(4) イールドスプレッド 　　イールドスプレッド=長期債利回りー 株式益回り 　(5) EVITDA (金利・税金・償却前利益) 　　EVITDA=税引前利益+支払利息+減価償却費 　(6) EV (企業価値) 　　EV= 時価総額 + 有利子負債 ー 現金預金 ー 短期有価証券 　(7) EV/EVITDA倍率 (倍) 　　EV/EVITDA倍率=EV÷EVITDA 　◆株価成立参照 　　 https://www.rakuten-sec.co.jp/web/domestic/stock/rule/agreed.html 　　 http://money-magazine.org/%E6%A0%AA%E4%BE%A1%E3%81%AE%E6%B1%BA%E3%81%BE%E3%82%8A%E6%96%B9%E3%81%AE%E5%9F%BA%E7%A4%8E%E7%9F%A5%E8%AD%98/ 　　 https://kabusyo.com/keiken/q_baibai.html 　　 https://ja.wikipedia.org/wiki/%E6%A0%AA%E4%BE%A1 　　 http://kabukiso.com/basics/buy/ita.html 2.債券業務 (1) パリティ価格 (転換社債株式価値) 　　パリティ価格=(株価÷ 転換価格 )×100 　(2) 乖離率 (%) 　　乖離率={(転換社債の時価ーパリティ価格)÷パリティ価格}×100 　(3) 最終利回り (%) 　　最終利回り={利率+(償還価格ー購入価格)÷ 残存期間 ＜年＞)}÷購入価格×...
続きを読む

マクロ経済学(IS-LM分析)

-
イメージ
危うく3日坊主になりそうでした。とりあえず今日は 「IS-LM分析」 です。 テキストでは 簡便4象限法 とかいうのの説明が多いです。なのでさっぱり わけわからん状態ですが、それなりに頑張ってみます。 1: IS曲線 の導出 財市場の均衡を表す。Iは投資を表し、Sは貯蓄を表す。 ・IS曲線導出の材料 I→利子率の関数、S→所得の関数で「I=S」で財市場を表す。 ・ 投資関数 利子率の減少関数、I (投資関数)=I(r)　※rは利子率 ・政府活動の導入 裁量的な拡張的な財政政策はIS曲線をシフトさせる。 IS曲線の右シフト=政府支出の増大や減税等の有効需要を増加させる要因による 2: LM曲線 の導出 利子率の低下が国民所得の増大につながる因果関係を明らかにする目的 ・LM曲線導出の材料 貨幣需要(MD)=L、L=取引的動機+予備的動機(L1)+投機的動機(L2) MD=L1+L2 貨幣供給(Ms)=名目貨幣供給/物価(P) ・LM曲線のシフト 金融緩和策・物価下落：実質貨幣供給(MS)が増大→右(下)へシフト 金融引締策・物価上昇：実質貨幣供給(MS)が減少→左(上)へシフト 独立投資拡大→IS曲線が右にシフト 利子率がr1→r2に下落する。 IS曲線、LM曲線の均衡点がE→Fに移動する。 国民所得がY1→Yfとなって増大する。 3:特殊なLM曲線 ・ 流動性の罠 のLM曲線 金融政策は無効→LM曲線をシフトさせても均衡点Eは変わらない IS曲線を右にシフトさせる拡張的な財政政策を実施すると均衡点が E→E´となり国民所得がY1→Y2に増加するので財政政策は有効となる。　　　 ・ 投資の利子率に対する弾力性ゼロ 金融政策は無効→LM曲線を右にシフトさせても国民所得が増えない。 流動性の罠と同じくIS曲線を右にシフトさせる拡張的な財政政策を実施すると 均衡点がE→E´となり国民所得がY1→Y2に増加するので財政政策は有効となる。　　　　　　 4: クラウディング・アウト 政府が市場に介入して公共投資を行うと民間の投資が締出しを受ける ・古典派による財政政策の無効論 政府支出を拡大すると利子率が上昇してしまい。投資が減少する。 政府の支出がクラウディングアウトを引き起こして支...
続きを読む