アプリ内課金（IAP）APIを組み込む方法

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 ;

// ...

public void onUserDataResponse( final UserDataResponse response) {

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

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

   case FAILED:
   case NOT_SUPPORTED:
	 // 失敗時の処理を適切に行います。
	 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);
         }
         break ;
       case FAILED:
         break ;
     }
   }
   //...
}

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);
         }

         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" );
         break ;
     }
   }

   //  ...
}

  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.handleReceipt(receipt, response.getUserData());
			iapManager.refreshOranges();
			break;
	}
}

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

                grantConsumablePurchase(receipt, userData);
            }
            return;
        } catch (final Throwable e) {
            mainActivity.showMessage("購入を完了できませんでした。もう一度お試しください。");
        }
    }

private void grantConsumablePurchase(final Receipt receipt, final UserData userData) {
    try {
        // 以下のサンプルコードは簡易な実装です。独自の付与ロジックを
        // 実装するときは、スレッドセーフ、トランザクション性、堅牢性に
        // 注意してください。

        // アプリ／サーバーで購入情報を作成し、購入アイテムを
        // ユーザーに付与します。この例では、ユーザーにオレンジを1つ
        // 付与します。
        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はその購入レシートをアプリに送信しなく
            // なります。
            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());
    }
}