java - Google 应用内购买返回错误代码 6

Question

onPurchasesUpdated 无法消费Async 和 billingResult 结果错误代码 6。

我尝试将 ConsumerAsync 移动到 queryPurchases 和 queryPurchaseHistoryAsync，并且购买只会在 queryPurchaseHistoryAsync 而不是 queryPurchases 中消耗

billingClient = BillingClient.newBuilder(this).setListener(new PurchasesUpdatedListener() {
            @Override
            public void onPurchasesUpdated(BillingResult billingResult, @Nullable List<Purchase> purchases) {
                if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK
                        && purchases != null) {
                    for (Purchase purchase : purchases) {
                        handlePurchase(purchase);
                        //The following consumeAsync not working, return error code 6
                        ConsumeParams consumeParams = ConsumeParams.newBuilder()
                                .setPurchaseToken(purchase.getPurchaseToken())
                                .setDeveloperPayload(purchase.getDeveloperPayload())
                                .build();
                        billingClient.consumeAsync(consumeParams, new ConsumeResponseListener() {
                            @Override
                            public void onConsumeResponse(BillingResult billingResult, String purchaseToken) {
//billingResult return code 6 here. 
                                Log.i("TAG", String.valueOf(billingResult.getResponseCode()));
                            }
                        });
                    }
                } else if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.USER_CANCELED) {
                    // Handle an error caused by a user cancelling the purchase flow.
                } else {
                    // Handle any other error codes.
                }
            }
        }).enablePendingPurchases().build();

consumeAsync 在 queryPurchases() 下不起作用:

Purchase.PurchasesResult purchasesResult = billingClient.queryPurchases(BillingClient.SkuType.INAPP);
                    for(Purchase purchase : purchasesResult.getPurchasesList()) {
                        handlePurchase(purchase);
                        ConsumeParams consumeParams = ConsumeParams.newBuilder()
                                .setPurchaseToken(purchase.getPurchaseToken())
                                .setDeveloperPayload(purchase.getDeveloperPayload())
                                .build();
                        billingClient.consumeAsync(consumeParams, new ConsumeResponseListener() {
                            @Override
                            public void onConsumeResponse(BillingResult billingResult, String purchaseToken) { 
                                Log.i("TAG", String.valueOf(billingResult.getResponseCode()));
                            }
                        });
                    }

consumeAsync仅在以下代码下工作(我知道该方法是错误的，该项目将被一遍又一遍地消耗并返回代码8，但这是该项目被消耗的唯一方式):

     billingClient.queryPurchaseHistoryAsync(BillingClient.SkuType.INAPP, new PurchaseHistoryResponseListener() {
                        @Override
                        public void onPurchaseHistoryResponse(BillingResult billingResult, List<PurchaseHistoryRecord> purchaseHistoryRecordList) {
                            if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK
                                    && purchaseHistoryRecordList != null) {
                                for (PurchaseHistoryRecord purchase : purchaseHistoryRecordList) {
                                    handlePurchaseHistoryRecord(purchase);
                                    ConsumeParams consumeParams = ConsumeParams.newBuilder()
                                            .setPurchaseToken(purchase.getPurchaseToken())
                                            .setDeveloperPayload(purchase.getDeveloperPayload())
                                            .build();
                                    billingClient.consumeAsync(consumeParams, new ConsumeResponseListener() {
                                        @Override
                                        public void onConsumeResponse(BillingResult billingResult, String purchaseToken) { 
                                            Log.i("TAG", "item consumed");
                                        }
                                    });
                                }
                            }
                        }
                    });

Answer 1

您的代码将在每次购买后立即使用。一般来说，如果您希望买家能够再次重新购买该产品，您只想使用该产品。如果您的元素预计是消耗品，例如游戏中的额外硬币，则可能会出现这种情况。一旦金币用完，您将消耗购买的金额，然后买家可以购买更多金币。

您可能消费购买的另一个场景是用于测试，您可能希望多次购买产品。您可以设置一个临时按钮或其他方法来消费购买的商品，以便您可以在解决代码中的任何错误的同时继续重新购买。

第三种情况可能是在您向买家退款后。退款后，您可能需要消费购买的商品，以便买家可以选择再次购买该产品。

这是我能想到的仅有的三种您想要使用托管产品的场景。

编辑

对于 YKW 的评论: YKW 提出了一个很好的观点，即购买额外的硬币，这最初并没有发生在我身上……但无论哪种方式，你都不能再次消费该产品，直到你从第一次购买消费中获得有效的消费响应，然后再消费该产品。再次购买产品。在这种情况下，您至少应该首先检查以确保购买不是PurchaseState.Pending。然后消费该产品，在收到 onConsume 响应之前不允许再次购买该产品。您还需要在每次应用和/或 Activity 启动时进行检查，并消耗任何购买的产品，因为 Google 确认偶尔消耗会失败。

结束编辑

更新

接收响应代码 6 的另一种可能性是开发人员负载字符串为空。您可以删除 .setDeveloperPayload(purchase.getDeveloperPayload()) 行，因为指定开发人员有效负载对于 ConsumeParams 是可选的。

如果您想发送开发人员有效负载，请确保purchase.getDeveloperPayload() 不会返回空字符串。

结束更新

有一个很好的示例，说明了在简单的驱动器应用程序中消费购买的方法。

Trivial Drive V2 BillingManager

这是我用来调试的一种方法，基于在简单的 Drive V2 应用程序中找到的方法。

void consumeAsync(final ConsumeParams consumeParams) {
    // If we've already scheduled to consume this token - no action is needed (this could happen
    // if you received the token when querying purchases inside onReceive() and later from
    // onActivityResult()
    if (paramsSetToConsume == null) {
        paramsSetToConsume = new HashSet<>();
    } else if (paramsSetToConsume.contains(consumeParams)) {
        Log.i(TAG, "Params was already scheduled to be consumed - skipping...");
        return;
    }
    paramsSetToConsume.add(consumeParams);

    // Generating Consume Response listener
    final ConsumeResponseListener onConsumeListener = new ConsumeResponseListener() {
        @Override
        public void onConsumeResponse(BillingResult billingResult, String purchaseToken) {
            // If billing service was disconnected, we try to reconnect 1 time
            // (feel free to introduce your retry policy here).
            Log.d(TAG, "ConsumeResponseListener fired.  sending to onConsumedFinished listener");
            mBillingUpdatesListener.onConsumeFinished(consumeParams.getPurchaseToken(), billingResult.getResponseCode());
        }
    };
// Creating a runnable from the request to use it inside our connection retry policy below
    Runnable consumeRequest = new Runnable() {
        @Override
        public void run() {
            // Consume the purchase async
            Log.d(TAG, "consumeParams being sent to billingClient to consume");
            billingClient.consumeAsync(consumeParams, onConsumeListener);
        }
    };

    executeServiceRequest(consumeRequest);
}

然后，我设置一个临时按钮，创建 ConsumeParams 并在 onClick 监听器中调用此方法。

paramsSetToConsume 是一个成员变量

private Set<ConsumeParams> paramsSetToConsume;