在Java代码中初始化并调用Kotlin ViewModel（含Hilt集成）

@HiltViewModel
class PermProdsTestViewModel @Inject constructor(
    private val prodsUseCase: ProductUseCase // 假设 ProductUseCase 是一个依赖
) : ViewModel() {

    private val _prods = MutableStateFlow(ProdsState())
    val prods: StateFlow<ProdsState> = _prods

    /**
     * 获取允许的产品列表
     */
    fun getPermittedProducts(
        serviceName: String?,
        productTypes: List<String>?,
        permission: String?,
        subServiceName: String?,
        filter: Boolean?
    ) = viewModelScope.launch(Dispatchers.IO) {
        // 假设 permittedProdsUseCase 是通过 prodsUseCase 提供的
        // 实际应用中，这里可能是 prodsUseCase.invoke(...)
        // 为演示目的，我们简化此处的调用
        prodsUseCase.invoke(serviceName, productTypes, permission, subServiceName, filter).collect {
            when (it) {
                is DataResult.Success -> {
                    _prods.value = ProdsState(products = it.data)
                    // Timber.d("Api request success, getting results")
                }
                is DataResult.Error -> {
                    _prods.value = ProdsState(error = it.cause.localizedMessage ?: "Unexpected Error")
                    // Timber.d("Error getting permitted products")
                }
            }
        }
    }
}

// 示例数据类和状态类，实际项目中根据需要定义
data class ProdsState(
    val products: List<Any> = emptyList(), // 假设产品列表为 Any 类型
    val error: String? = null
)

sealed class DataResult<out T> {
    data class Success<out T>(val data: T) : DataResult<T>()
    data class Error(val cause: Throwable) : DataResult<Nothing>()
}

// 假设 ProductUseCase 存在
class ProductUseCase @Inject constructor() {
    fun invoke(
        serviceName: String?,
        productTypes: List<String>?,
        permission: String?,
        subServiceName: String?,
        filter: Boolean?
    ): kotlinx.coroutines.flow.Flow<DataResult<List<Any>>> {
        // 模拟异步操作
        return kotlinx.coroutines.flow.flow {
            kotlinx.coroutines.delay(100) // 模拟网络延迟
            emit(DataResult.Success(listOf("Product A", "Product B")))
        }
    }
}

import android.os.Bundle;
import androidx.annotation.Nullable;
import androidx.appcompat.app.AppCompatActivity;
import androidx.lifecycle.ViewModelProvider;
import dagger.hilt.android.AndroidEntryPoint;

// 确保您的 Activity 带有 @AndroidEntryPoint 注解
@AndroidEntryPoint
public class TestActivity extends AppCompatActivity {

    private PermProdsTestViewModel vm;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_test); // 假设您有一个 activity_test.xml 布局文件

        // 使用 ViewModelProvider 初始化 ViewModel
        // 注意：这里需要传入 ViewModel 的 .class 对象
        vm = new ViewModelProvider(this).get(PermProdsTestViewModel.class);

        // 调用 ViewModel 中的方法
        // 示例：调用 getPermittedProducts 方法，传入 null 或实际参数
        vm.getPermittedProducts(null, null, null, null, null);

        // 如果需要观察 StateFlow 的数据，可以通过 Kotlin 的 Flow API 在 Java 中进行收集
        // 但这通常涉及到 Kotlin 协程和 Flow 的互操作性，可能需要额外的适配
        // 例如：
        // vm.getProds().onEach(prodsState -> {
        //     // 处理 prodsState
        //     Log.d("TestActivity", "Products: " + prodsState.getProducts());
        // }).launchIn(lifecycleScope); // 需要 Kotlin 扩展函数，Java 中直接调用会复杂
        // 在 Java 中更常见的是通过 LiveData 暴露数据，或者手动收集 Flow
    }
}