Appstore SDK IAPの実装

private SampleIapManager sampleIapManager; // 購入レシートデータを格納します（任意）
protected void onCreate(final Bundle savedInstanceState) // onCreateにPurchasingListenerを実装します 
{
  super.onCreate(savedInstanceState);
  // setupApplicationSpecificOnCreate();
  
  // Appstore SDKにApplicationContextを登録し、LicensingListenerの実装（この場合はLicensingCallback）を使用して
  // DRMのライセンスを取得するリクエストを開始します
  LicensingService.verifyLicense(this.getApplicationContext(), new LicensingCallback());
  
  setupIAPOnCreate();
}

private void setupIAPOnCreate() {
  sampleIapManager = new SampleIapManager(this);

  final SamplePurchasingListener purchasingListener = new SamplePurchasingListener(sampleIapManager);
  Log.d(TAG, "onCreate: PurchasingListenerを登録します");

  PurchasingService.registerListener(this.getApplicationContext(), purchasingListener);
  PurchasingService.enablePendingPurchases(); // 購入保留を有効にします

  Log.d(TAG, "Appstore SDKモード：" + LicensingService.getAppstoreSDKMode()); // アプリがテストモードになっているかどうかを確認します
}

// ...
private String currentUserId = null;
private String currentMarketplace = null;
private String currentCountryCode = null;

// ...

public void onUserDataResponse(final UserDataResponse response) {

  final UserDataResponse.RequestStatus status = response.getRequestStatus();

  switch (status) {
    case SUCCESSFUL:
      currentUserId = response.getUserData().getUserId();
      currentMarketplace = response.getUserData().getMarketplace();
      currentCountryCode = response.getUserData().getCountryCode();
      break;

   case FAILED:
      // ユーザーがデバイスでAmazonにサインインしていないか、
      // アプリとAmazonアプリストアの接続に問題があります。
      // ユーザーと商品に関する詳細が正常に取得されるまで、
      // このデバイスのユーザーでIAPを一時的に無効にします。
      // getProductDataメソッドでProductDataが正常に取得されたら、
      // 再び購入が有効になります。
      iapManager.disableAllPurchases();
      break;
   case NOT_SUPPORTED:
      // デバイスがIAP機能をサポートしていません。
      // このデバイスのユーザーでIAPを無効にします。
      iapManager.disableAllPurchases();
      break;
  }
}

@Override
protected void onResume() // getPurchaseUpdatesはonResume内でのみ呼び出します
{
  super.onResume();

//...

  PurchasingService.getUserData();

//...

  PurchasingService.getPurchaseUpdates(false);
}

public class MyPurchasingListener implements PurchasingListener {
   boolean reset = false;
   //...

   public void onPurchaseUpdatesResponse(final PurchaseUpdatesResponse response) {
     //...
     // レシートを処理します
     switch (response.getRequestStatus()) {
       case SUCCESSFUL:
         for (final Receipt receipt : response.getReceipts()) {
           // レシートを処理します
         }
         if (response.hasMore()) {
           PurchasingService.getPurchaseUpdates(reset);
         }
         iapManager.refresh();
         break;
       case FAILED:
         // ユーザーデータが存在する場合、FAILEDはAmazonアプリストア側の問題であることを示します。
         // しばらくしてから再試行してください。
         // ユーザーと商品に関する詳細が正常に取得されるまで、
         // このデバイスでIAPを一時的に無効にします。
         // getProductDataメソッドでProductDataが正常に取得されたら、再び購入が有効になります。
         iapManager.disableAllPurchases();
         break;
       case NOT_SUPPORTED:
         // デバイスがIAP機能をサポートしていません。
         // このデバイスでIAPを無効にします。
         iapManager.disableAllPurchases();
     }
   }
   //...
}

public void onPurchaseUpdatesResponse(final PurchaseUpdatesResponse response) {
// ....
switch (status) {
case SUCCESSFUL:
	iapManager.setAmazonUserId(response.getUserData().getUserId(), response.getUserData().getMarketplace());
	for (final Receipt receipt : response.getReceipts()) {
		iapManager.handleReceipt(receipt, response.getUserData());
	}
	if (response.hasMore()) {
		PurchasingService.getPurchaseUpdates(false);
	}
	iapManager.refreshOranges();
	break;
}
// ...
}              

protected void onResume() // 商品のSKUの検証はonResume内でのみ行います
{
   super.onResume();

   // ...

   final Set <string>productSkus =  new HashSet<string>();
   productSkus.add( "com.amazon.example.iap.consumable" );
   productSkus.add( "com.amazon.example.iap.entitlement" );
   productSkus.add( "com.amazon.example.iap.subscription" );
   PurchasingService.getProductData(productSkus); // PurchasingListener.onProductDataResponse()をトリガーします

   Log.v(TAG,  "SKUをAmazonで検証します" );
   }

public class MyPurchasingListener implements PurchasingListener {
   //  ...

   public void onProductDataResponse(final ProductDataResponse response) {
     switch (response.getRequestStatus()) {
       case SUCCESSFUL:
         for ( final String s : response.getUnavailableSkus()) {
           Log.v(TAG,  "アイテムデータを入手できないSKU：" + s);
         }
         // SKUをユーザーが購入することはできません。
         // 利用できないSKUの購入を無効にします。
         iapManager.disablePurchaseForSkus(response.getUnavailableSkus());
         // 利用可能なすべてのSKUの購入を有効にします。
         iapManager.enablePurchaseForSkus(response.getProductData());
         iapManager.refresh();

         final Map <string,>products = response.getProductData();
         for (final String key : products.keySet()) {
           Product product = products.get(key);
           Log.v(TAG, String.format( "商品：%s\n タイプ：%s\n SKU：%s\n 価格：%s\n 説明：%s\n" , product.getTitle(), product.getProductType(), product.getSku(), product.getPrice(), product.getDescription()));
         }
         break;

       case FAILED:
         Log.v(TAG,  "ProductDataRequestStatus: FAILED" );
         // ユーザーデータが存在する場合、FAILEDはAmazonアプリストア側の問題であることを示します。
         // しばらくしてから再試行してください。
         // ユーザーと商品に関する詳細が正常に取得されるまで、
         // このデバイスでIAPを一時的に無効にします。
         // getProductDataメソッドでProductDataが正常に取得されたら、再び購入が有効になります。
         iapManager.disableAllPurchases();
         break;
       case NOT_SUPPORTED:
         // デバイスがIAP機能をサポートしていません。
         // このデバイスでIAPを無効にします。
         iapManager.disableAllPurchases();
     }
   }

   //  ...
}

  public void onBuyOrangeClick(final View view) {
     final RequestId requestId = PurchasingService.purchase(MySku.ORANGE.getSku());
     Log.d(TAG, "onBuyOrangeClick: requestId (" + requestId + ")");
  }

public void onPurchaseResponse(final PurchaseResponse response) {
	switch (status) {
    // ...
    case SUCCESSFUL:
      final Receipt receipt = response.getReceipt();
      iapManager.setAmazonUserId(response.getUserData().getUserId(), response.getUserData().getMarketplace());
      Log.d(TAG, "onPurchaseResponse: receipt json:" + receipt.toJSON());
      iapManager.handlePurchase(receipt, response.getUserData());
      iapManager.refresh();
      break;
    case ALREADY_PURCHASED:
      // ユーザーは既にアイテムに対するアクティブな非消費型アイテムを持っています。
      // アプリとAmazonアプリストアが同期していません。Amazonアプリストアからすべての購入を再同期します。
      PurchasingService.getPurchaseUpdates(true);
      break;
    case INVALID_SKU:
      Log.d(TAG,
            "onPurchaseResponse：SKUが無効です。購入ボタンは、onProductDataResponseによって既に無効になっています。");
      final Set<String> unavailableSkus = new HashSet<String>();
      unavailableSkus.add(response.getReceipt().getSku());
      iapManager.disablePurchaseForSkus(unavailableSkus);
      break;
    case FAILED:
      // 購入手続きの完了前にユーザーが終了しました。
      Log.d(TAG, "onPurchaseResponse：失敗したため、ローカルストレージから購入リクエストを削除してください。");
      iapManager.showPurchaseFailedMessage(response.getReceipt().getSku());
      break;
    case NOT_SUPPORTED:
      Log.d(TAG, "onPurchaseResponse：失敗したため、ローカルストレージから購入リクエストを削除してください。");
      iapManager.showPurchaseFailedMessage(response.getReceipt().getSku());
      // デバイスがIAP機能をサポートしていません。
      // このデバイスでIAPを無効にします。
      iapManager.disableAllPurchases();
      break;
	}
}

public void handlePurchase(final Receipt receipt, final UserData userData) {
    try {
        if (receipt.isCanceled()) {
            revokePurchase(receipt, userData);
        } else {
            // Amazonでは、レシートの検証はサーバー側で実行することを強く推奨します。
            if (!verifyReceiptFromYourService(receipt.getReceiptId(), userData)) {
                // 購入を検証できない場合は、
                // 適切なエラーメッセージをユーザーに表示します。
                mainActivity.showMessage("購入を検証できませんでした。後でもう一度お試しください。");
                return;
            }
            if (itemAlreadyPurcahsed(receipt, userData)) {
                    // アイテムがほかのストアから既に購入されている場合は、
                    // 購入をキャンセルし、適切なエラーメッセージをユーザーに表示します。
                    cancelPurchase(receipt, userData);
                    return;
            }
            if (receiptAlreadyFulfilled(receipt.getReceiptId(), userData)) {
                // レシートのアイテムが以前に付与されている場合は、付与済みであることを
                // Amazonアプリストアに改めて通知します。
                PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.FULFILLED);
                return;
            }
            grantPurchase(receipt, userData);
        }
        return;
    } catch (final Throwable e) {
        mainActivity.showMessage("購入を完了できませんでした。もう一度お試しください。");
    }
}

private void grantConsumablePurchase(final Receipt receipt, final UserData userData) {
    try {
        // このコードは基本的な実装を示しています。アプリでは、スレッドセーフで
        // トランザクション対応の安定したロジックを実装してください。

        // アプリやサーバーで購入情報を作成し、
        // 購入アイテムをユーザーに付与します。
        createPurchase(receipt.getReceiptId(), userData.getUserId());
        final MySku mySku = MySku.fromSku(receipt.getSku(), userIapData.getAmazonMarketplace());
        // SKUがまだ適用可能であることを確認します。
        if (mySku == null) {
            Log.w(TAG, "レシート内のSKU [" + receipt.getSku() + "] は無効になっています。");
            // SKUが適用不可の場合、ステータスUNAVAILABLEを指定して
            // PurchasingService.notifyFulfillmentを呼び出します。
            updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.UNAVAILABLE);
            PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.UNAVAILABLE);
            return;
        }

        if (updatePurchaseStatus(receipt.getReceiptId(), PurchaseStatus.PAID, PurchaseStatus.FULFILLED)) {
            // SQLiteデータベースの購入ステータスの更新に成功しました。
            userIapData.setRemainingOranges(userIapData.getRemainingOranges() + 1);
            saveUserIapData();
            Log.i(TAG, "購入ステータスをPAIDからFULFILLEDに正しく更新しました。レシートID：" + receipt.getReceiptId());
            // アイテム付与の結果をAmazonアプリストアに送信します。Amazonが
            // 購入されたアイテム付与の結果を受け取った後、Amazonアプリストアは
            // アプリへの購入レシートの送信を停止します。
            PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.FULFILLED);
        } else {
            // SQLiteデータベースの購入ステータスの更新に失敗しました。
            // ステータスは既に変更されています。
            // これは通常、同じレシートが別のonPurchaseResponseまたは
            // onPurchaseUpdatesResponseコールバックで更新されたことを意味します。
            // このコードではエラーの記録のみを行います。
            Log.w(TAG, "購入ステータスをPAIDからFULFILLEDに更新できませんでした。レシートID：" + receipt.getReceiptId()
                       + "。ステータスは既に変更されています。");
        }

    } catch (final Throwable e) {
        // 何らかの理由でアプリが購入アイテムを付与できない場合のために、
        // ここに独自のエラー処理コードを追加します。
        // 次回PurchasingService.getPurchaseUpdates APIを呼び出すと、
        // Amazonから消費型アイテムの購入レシートが再度送信されます。
        Log.e(TAG, "購入された消費型アイテムを付与できませんでした。エラー：" + e.getMessage());
    }
}

private void cancelPurchase(final Receipt receipt, final UserData userData) {
  // アプリやサーバーで購入情報を更新して、
  // ユーザーが重複購入を試みていないかどうかを特定します。
  // アイテムを付与できないことをAmazonに通知するには、
  // EXISTING_PURCHASE、NOT_ELIGIBLE、またはUNAVAILABLEのアイテム付与ステータスを使用します。
  // EXISTING_PURCHASEの場合
  //     updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.EXISTING_PURCHASE);
  //     PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.EXISTING_PURCHASE);
  // または、NOT_ELIGIBLEの場合
  //    updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.NOT_ELIGIBLE);
  //    PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.NOT_ELIGIBLE);
  // または、UNAVAILABLEの場合
  updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.UNAVAILABLE);
  PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.UNAVAILABLE);
  return;
}