Android应用内购：在Java中实现用户订阅状态的准确检查

import android.util.Log;
import com.android.billingclient.api.AcknowledgePurchaseParams;
import com.android.billingclient.api.BillingClient;
import com.android.billingclient.api.BillingResult;
import com.android.billingclient.api.Purchase;
import com.android.billingclient.api.QueryPurchasesParams;
import java.util.List;

public class SubscriptionManager {

    private BillingClient billingClient;
    private static final String TAG = "SubscriptionManager";

    // 构造函数或初始化方法中传入 BillingClient 实例
    public SubscriptionManager(BillingClient client) {
        this.billingClient = client;
    }

    /**
     * 检查用户当前的订阅状态。
     * 此方法应在 BillingClient 连接成功后调用。
     */
    public void checkSubscriptionStatus() {
        if (billingClient != null && billingClient.isReady()) {
            // 查询订阅类型商品
            billingClient.queryPurchasesAsync(
                QueryPurchasesParams.newBuilder().setProductType(BillingClient.ProductType.SUBS).build(),
                (billingResult, purchases) -> {
                    if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
                        boolean hasActiveSubscription = false;
                        if (purchases != null && !purchases.isEmpty()) {
                            for (Purchase purchase : purchases) {
                                // 验证购买状态和商品ID
                                // 请替换 "your_subscription_product_id" 为您实际的订阅商品ID
                                if (purchase.getProducts().contains("your_subscription_product_id") &&
                                    purchase.getPurchaseState() == Purchase.PurchaseState.PURCHASED) {

                                    // 如果购买未被确认，则需要确认
                                    if (!purchase.isAcknowledged()) {
                                        acknowledgePurchase(purchase);
                                    }

                                    // 购买已确认且状态为已购买，则视为有效订阅
                                    if (purchase.isAcknowledged()) {
                                        hasActiveSubscription = true;
                                        Log.d(TAG, "用户拥有有效订阅: OrderId = " + purchase.getOrderId());
                                        // TODO: 根据您的应用逻辑更新UI或应用状态
                                        // 例如: Constant.subscription = true;
                                        break; // 找到一个有效订阅即可
                                    }
                                }
                            }
                        }

                        if (!hasActiveSubscription) {
                            Log.d(TAG, "用户没有有效的订阅。");
                            // TODO: 根据您的应用逻辑更新UI或应用状态
                            // 例如: Constant.subscription = false;
                        }
                    } else {
                        Log.e(TAG, "查询订阅失败: " + billingResult.getDebugMessage());
                    }
                }
            );
        } else {
            Log.e(TAG, "BillingClient 未准备好或为空，无法查询订阅。");
        }
    }

    /**
     * 辅助方法：确认购买。
     * Google Play 要求所有购买（包括订阅）必须在3天内确认。
     * 未确认的购买会在3天后自动退款。
     */
    private void acknowledgePurchase(Purchase purchase) {
        AcknowledgePurchaseParams acknowledgePurchaseParams =
                AcknowledgePurchaseParams.newBuilder()
                        .setPurchaseToken(purchase.getPurchaseToken())
                        .build();

        billingClient.acknowledgePurchase(acknowledgePurchaseParams, billingResult -> {
            if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
                Log.d(TAG, "购买已成功确认: OrderId = " + purchase.getOrderId());
                // 确认成功后，可以再次触发订阅状态检查或直接更新UI
                // checkSubscriptionStatus(); // 重新检查以更新状态
            } else {
                Log.e(TAG, "购买确认失败: " + billingResult.getDebugMessage());
            }
        });
    }

    // 您可能还需要一个方法来处理可消耗商品的消耗逻辑，如果您的应用有此类商品。
    // 订阅商品不需要消耗。
    /*
    void handleConsumablePurchase(Purchase purchase) {
        ConsumeParams consumeParams = ConsumeParams.newBuilder()
                .setPurchaseToken(purchase.getPurchaseToken())
                .build();

        billingClient.consumeAsync(consumeParams, (billingResult, purchaseToken) -> {
            if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
                Log.d(TAG, "可消耗商品已成功消耗。");
                // TODO: 授予用户商品
            } else {
                Log.e(TAG, "可消耗商品消耗失败: " + billingResult.getDebugMessage());
            }
        });
    }
    */
}

import android.util.Log;
import com.android.billingclient.api.BillingClient;
import com.android.billingclient.api.BillingResult;
import com.android.billingclient.api.Purchase;
import com.android.billingclient.api.PurchasesUpdatedListener;
import java.util.List;

public class MyBillingClientLifecycleManager implements PurchasesUpdatedListener {

    private SubscriptionManager subscriptionManager; // 假设您有SubscriptionManager实例

    public MyBillingClientLifecycleManager(SubscriptionManager manager) {
        this.subscriptionManager = manager;
    }

    @Override
    public void onPurchasesUpdated(BillingResult billingResult, List<Purchase> purchases) {
        if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK && purchases != null) {
            for (Purchase purchase : purchases) {
                // 对于新购买的订阅，需要进行确认
                if (purchase.getProducts().contains("your_subscription_product_id")) {
                    // 确认操作应在 SubscriptionManager 中处理
                    if (!purchase.isAcknowledged()) {
                        subscriptionManager.acknowledgePurchase(purchase);
                    }
                    Log.d("BillingFlow", "新订阅购买成功并处理: OrderId = " + purchase.getOrderId());
                    // TODO: 更新应用状态，例如 Constant.subscription = true;
                }
                // 如果是可消耗商品，则需要消耗
                // else if (purchase.getProducts().contains("your_consumable_product_id")) {
                //    subscriptionManager.handleConsumablePurchase(purchase);
                // }
            }
            // 无论新购买成功与否，都建议重新查询一次以同步最新状态
            subscriptionManager.checkSubscriptionStatus();

        } else if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.USER_CANCELED){
            Log.d("BillingFlow", "用户取消了购买流程。");
            // TODO: 更新应用状态，例如 Constant.subscription = false;
        } else {
            Log.e("BillingFlow", "购买流程出现错误: " + billingResult.getDebugMessage());
        }
    }
}