内容

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<TravelNoteBook.Books>, ContractTravelNotes.View>(v),
        ContractTravelNotes.Presenter<MutableList<TravelNoteBook.Books>>{

    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<TravelNoteBook.Books>?) {
        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())
    }
  ...
}

TravelNotesActivity

---

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

class TravelNotesActivity :
        BasePActivity<ContractTravelNotes.Presenter<MutableList<TravelNoteBook.Books>>>(),
        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 <R> getLifecycle2(): LifecycleTransformer<R> {
        return bindToLifecycle()
    }

    override fun <R> getLifecycleDestroy(): LifecycleTransformer<R> {
        return bindToLifecycleDestroy()
    }

}

SchedulersDataHelper

---

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

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

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

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

2.关于return@label的方式我不是特别的明白，直接看文档好了(http://kotlinlang.org/docs/reference/returns.html)

对于请求网络数据的流程大致就是这样，后面会研究一下kapt生成文件的方式，并通过这种方式生成API接口管理、Presenter、View接口以及路由
至于kotlin的使用上感觉还是蛮不错的，有点类似于使用Python，和java也是配合的很好，后面还要对kotlin做一些更深层的了解。