Kotlin初探(二)数据加载

移动开发 简书

内容

Part 1: Kotlin初探(一)基础构建

Part2: Kotlin初探(二)数据加载

UI界面就是一个简单的List数据列表,数据由网络获取

类图

TravelNotesPresenter

根据上面的图 TravelNotesPresenter 继承 PresenterDataWrapper 并指定数据和View的类型,实现

Contract.Presenter 接口指定数据类型,并且确定构造方法需要的View类型和初始化数据。

所以一般Presenter会至少持有两个引用,一个是View一个是Data,并且这里也把Model和Presenter的逻辑也是合并到了Presenter中暂时没有分离。

class TravelNotesPresenter(v: ContractTravelNotes.View) :
        PresenterDataWrapper<mutablelist, ContractTravelNotes.View>(v),
        ContractTravelNotes.Presenter<mutablelist>{

    var query = Query(AppConfig.INFO_QUERY_ADDRESS,1,10)

    init {
        mData = ArrayList()
    }
    /**
     * 这里主要是获取网络数据,其实应该是Model的业务逻辑,暂时先放到了Presenter中
     * 获取网络数据的方式是由Retrofit+Rxjava的方式,并且自定义了两个处理组件 RxSchedulersHelper 和 SchedulersDataHelper
     * RxSchedulersHelper 主要是合并了ob.subscribeOn(Schedulers.io()) 和 observeOn(AndroidSchedulers.mainThread()) 操作
     * SchedulersDataHelper 去处理数据是否获取成功或者服务器返回的非成功标识,成功则返回数据,错误则返回错误信息
     * Rxjava的生命周期由mView.getLifecycleDestroy()绑定到Activity上
     */
    override fun fetch() {
        ApiManager.travelNotesApi
                .getTravelNotesList(query.query,query.getPageQ(),query.getCountQ(),"")
                .compose(mView.getLifecycleDestroy())
                .compose(RxSchedulersHelper.io_main())
                .compose(SchedulersDataHelper.handleResult())
                .subscribe({processData(it.getBookses())},
                        {errorData(it.message.toString())},
                        {mView.onDialog(false)})
    }

    override fun processData(d: MutableList?) {
        if (d == null){
            mView.showToast(AppConfig.INFO_ERROR_NOT_DATA)
        } else {
            if (query.page == 1) {
                mData.clear()
            }
            mData.addAll(d)
            query.page=+query.count
            mView.updateUI()
        }
    }

    override fun errorData(error: Throwable) {
        mView.showToast(error.message.toString())
    }
  ...
}</mutablelist</mutablelist

TravelNotesActivity

TravelNotesActivity 继承 BasePActivity 并指定Contractl.Presenter以及数据类型,实现Contract.View接口。

class TravelNotesActivity :
        BasePActivity<contracttravelnotes.presenter<mutablelist>>(),
        ContractTravelNotes.View {
    private lateinit var adapter : TravelNotesAdapter

    /**
     * 初始化界面,使用Kotlin extensions 绑定控件
     */
    @SuppressLint("ResourceAsColor")
    override fun initUI() {
        setContentView(R.layout.activity_travel_notes)
        srlRefresh.setColorSchemeColors(R.color.colorPrimary,R.color.colorPrimaryDark)
        srlRefresh.setOnRefreshListener { mPresenter.refreshData() }
        rvBooks.layoutManager = LinearLayoutManager(this)
        //因为布局中有include标签,直接调用被include布局的id会出现问题,所以就给include指定了一个id=icTitle
        icTitle.tvTitle.text = "游记"
        icTitle.ivBack.visibility = View.INVISIBLE
    }

    /**
     * 初始化Presenter,类型已经通过泛型指定
     */
    override fun attachPresenter() {
        mPresenter = TravelNotesPresenter(this)
    }

    /**
     * activity中不会持有数据引用,一切交互都由接口确定
     */
    override fun initData() {
        adapter = TravelNotesAdapter(this, mPresenter.getData())
        rvBooks.adapter = adapter
        mPresenter.fetch()
    }

    /**
     * 刷新界面
     */
    override fun updateUI() {
        adapter.notifyDataSetChanged()
    }

    override fun onDestroy() {
        super.onDestroy()
        mPresenter.close()
    }

    override fun showToast(str: String) {
        ToastUtil.getInstance().makeShortToast(this,str)
    }

    override fun onDialog(show: Boolean) {
        srlRefresh.isRefreshing = show
    }

    override fun  getLifecycle2(): LifecycleTransformer {
        return bindToLifecycle()
    }

    override fun  getLifecycleDestroy(): LifecycleTransformer {
        return bindToLifecycleDestroy()
    }

}</contracttravelnotes.presenter<mutablelist

SchedulersDataHelper

class SchedulersDataHelper {
    companion object {
        /**
         * 错误信息
         */
        private var errorMsg = ""

        /**
         * 判断数据是否返回成功,成功则返回数据元,不成功则返回错误提示信息
         */
        fun  handleResult(): FlowableTransformer<responsejson, T> {
            return FlowableTransformer {
                it.flatMap(Function {
                    errorMsg = if (it != null) {
                        // 这里可以判断其他code状态类型并返回相应的错误信息
                        if(it.errcode !=0) {
                            AppConfig.INFO_ERROR_NOT_DATA
                        } else {
                            [email protected] createData(it.data)
                        }
                    } else {
                        AppConfig.INFO_ERROR_NETWORK
                    }
                    // 这里也可以直接继承Throwable返回其他的错误信息交由Presenter或者Model处理
                    [email protected] Flowable.error(Throwable(errorMsg))
                })
            }
        }

        /**
         * 请求成功后创建并返回数据
         */
        private fun  createData(data: T): Flowable {
            return Flowable.create({
                it.onNext(data)
                it.onComplete()
            },BackpressureStrategy.BUFFER)
        }
    }
}</responsejson

1.区别与以前Java的lambda中需要自定义一个值类似 data -> data.toString(),Kotlin中不需要自定义这个值默认为it

2.关于[email protected]的方式我不是特别的明白,直接看文档好了( http://kotlinlang.org/docs/reference/returns.html
)

对于请求网络数据的流程大致就是这样,后面会研究一下kapt生成文件的方式,并通过这种方式生成API接口管理、Presenter、View接口以及路由

至于kotlin的使用上感觉还是蛮不错的,有点类似于使用Python,和java也是配合的很好,后面还要对kotlin做一些更深层的了解。

简书稿源:简书 (源链) | 关于 | 阅读提示

本站遵循[CC BY-NC-SA 4.0]。如您有版权、意见投诉等问题,请通过eMail联系我们处理。
酷辣虫 » 移动开发 » Kotlin初探(二)数据加载

喜欢 (0)or分享给?

专业 x 专注 x 聚合 x 分享 CC BY-NC-SA 4.0

使用声明 | 英豪名录