android - Activity 中的奇怪行为 ViewModel 观察者调用方法 - MVVM 架构

Question

对不起，如果我的英语不好

我是 mvvm 架构的新手。我使用 Room、Dagger 和 Reactive。在我的项目中，我创建了将“任务”插入数据库并从数据库中获取“任务”的示例。问题是当我保存“任务”时，观察者中从数据库获取“任务”的方法被触发，因此在 RecycleView 中将从数据库中添加相同的数据。但是在方法'constructSaveTask'中没有调用'getTask'

我使用两个 MutableLiveData，一个用于 getTask 和 saveTask

我不知道为什么。请帮我

任务道.kt

@Dao
abstract class TaskDao : BaseDao<TaskEntity>() {
    @Query("SELECT * FROM task")
    abstract fun getTasks() : Flowable<List<TaskEntity>>
}

任务存储库.kt

@Singleton
class TaskRepository {
    private var taskDao: TaskDao

    @Inject constructor(taskDao: TaskDao) {
        this.taskDao = taskDao
    }

    fun saveTask(taskEntity: TaskEntity) : Flowable<Long> {
        return Flowable.fromCallable { taskDao.save(taskEntity) }
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
    }

    fun getTasks() : Flowable<List<TaskEntity>> {
        return taskDao.getTasks()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
    }
}

基本响应.kt

open class BaseResponse<T> {
    var isLoading: Boolean = false
    var isSuccess: Boolean = false
    var isNeedBack: Boolean = false
    var failedMessage: String = ""
    var throwable: Throwable? = null
    var data: T? = null

    fun onLoading(isLoading: Boolean) : BaseResponse<T> {
        this.isLoading = isLoading
        return this
    }

    fun onSuccess(data: T?) : BaseResponse<T> {
        this.data = data
        this.isSuccess = true
        this.isLoading = false

        return this
    }

    fun onFailed(isNeedBack: Boolean, failedMessage: String) : BaseResponse<T> {
        this.isSuccess = false
        this.isNeedBack = isNeedBack
        this.failedMessage = failedMessage
        this.isLoading = false
        return this
    }

    fun onError(throwable: Throwable) : BaseResponse<T> {
        this.throwable = throwable
        this.isSuccess = false
        this.isLoading = false
        return this
    }
}

任务视图模型.kt

class TaskViewModel(private var taskRepository: TaskRepository) : BaseViewModel() {
    var getTasks: MutableLiveData<BaseResponse<List<TaskEntity>>> = MutableLiveData()
    var saveTask: MutableLiveData<BaseResponse<Long>> = MutableLiveData()

    fun getTasks() {
        addDisposable(taskRepository.getTasks()
                .doOnSubscribe {
                    getTasks.value = BaseResponse<List<TaskEntity>>().onLoading(true)
                }.doFinally {
                    getTasks.value = BaseResponse<List<TaskEntity>>().onLoading(false)
                }.subscribe{ data: List<TaskEntity>? ->
                    getTasks.value = BaseResponse<List<TaskEntity>>().onSuccess(data)
                })
    }

    fun saveTask(taskEntity: TaskEntity) {
        addDisposable(taskRepository.saveTask(taskEntity)
                .doOnSubscribe {
                    saveTask.value = BaseResponse<Long>().onLoading(true)
                }.doFinally {
                    saveTask.value = BaseResponse<Long>().onLoading(false)
                }.subscribe { data: Long? ->
                    saveTask.value = BaseResponse<Long>().onSuccess(data)
                })
    }
}

数据库活动.kt

class DatabaseActivity : BaseActivity() {
    var taskAdapter: TaskAdapter? = null
    var viewModeFactory: ViewModelFactory = ViewModelFactory()
    var taskViewModel: TaskViewModel? = null

    override fun getContentViewResource(): Int {
        return R.layout.activity_database
    }

    override fun onBaseCreated(savedInstanceState: Bundle?) {
        showNavigationBackButton()

        initAdapter()
        initView()

        button_save.setOnClickListener {
            val task = TaskEntity()
            task.description = field_description.text.toString()
            task.task = field_task.text.toString()
            task.finishedBy = field_finished_by.text.toString()

            field_description.text.clear()
            field_task.text.clear()
            field_finished_by.text.clear()

            taskViewModel?.saveTask(task)
        }

        taskViewModel?.getTasks()
    }

    fun initAdapter() {
        taskAdapter = TaskAdapter()
        list_task.adapter = taskAdapter
        list_task.layoutManager = AdapterHelper.verticalLayout(this, false)
        list_task.addItemDecoration(AdapterHelper.addDividerVertical(this))
    }

    fun initView() {
        taskViewModel = ViewModelProviders.of(this, viewModeFactory).get(TaskViewModel::class.java)
        taskViewModel?.saveTask?.observe(this, Observer { response -> constructSaveTask(response) })
        taskViewModel?.getTasks?.observe(this, Observer { response -> constructGetTask(response) })
    }

    private fun constructGetTask(response: BaseResponse<List<TaskEntity>>?) {
        if (response?.isLoading == true) {
            Toast.makeText(this, "Retrieving Task", Toast.LENGTH_LONG).show()
        } else {
            Toast.makeText(this, "Task Retrieved", Toast.LENGTH_LONG).show()
        }

        if (response?.isSuccess == true) {
            response.isSuccess = false
            if (response.data != null) {
                taskAdapter?.addAll(ArrayList(response.data!!))
            }
        }
    }

    private fun constructSaveTask(response: BaseResponse<Long>?) {
        if (response?.isLoading == true) {
            Toast.makeText(this, "Saving Task", Toast.LENGTH_LONG).show()
        } else {
            Toast.makeText(this, "Task Has Been Saved", Toast.LENGTH_LONG).show()
        }

        if (response?.isSuccess == true) {
            Toast.makeText(this, "Success Saved", Toast.LENGTH_LONG).show()
        }
    }
}

更新： 这里的适配器代码

任务适配器.kt

    class TaskAdapter : BaseAdapter<TaskEntity, TaskHolder>() {

    override fun onCreateViewHolder(viewGroup: ViewGroup, viewType: Int): TaskHolder {
        val view: View = LayoutInflater.from(viewGroup.context).inflate(R.layout.adapter_task, viewGroup, false)
        return TaskHolder(view)
    }

    override fun onBindViewHolder(holder: TaskHolder, position: Int) {
        val task: TaskEntity = contents[position]

        holder.descriptionText.text = task.description
        holder.taskText.text = task.task
        holder.finishedByText.text = task.finishedBy
    }
}

BaseAdapter.kt

abstract class BaseAdapter<ListContent, Holder : RecyclerView.ViewHolder> : RecyclerView.Adapter<Holder>() {
    var contents: ArrayList<ListContent> = ArrayList()

    override fun getItemCount(): Int {
        return contents.size
    }

    fun addAll(contents: ArrayList<ListContent>) {
        this.contents.addAll(contents)
        notifyDataSetChanged()
    }

    fun add(content: ListContent) {
        this.contents.add(content)
        notifyDataSetChanged()
    }

    fun put(position: Int, content: ListContent) {
        this.contents[position] = content
        notifyItemChanged(position)
    }

    fun remove(position: Int) {
        this.contents.removeAt(position)
        notifyItemChanged(position)
    }

    fun clear() {
        this.contents.clear()
        notifyDataSetChanged()
    }
}