AudioHomePresenterImpl.kt

package com.ydl.audioim.presenter

import com.ydl.audioim.BuildConfig
import com.ydl.ydl_av.chat.config.YDLChatParam
import com.ydl.audioim.contract.IAudioHomeActivityContract
import com.ydl.audioim.http.command.*
import com.ydl.audioim.model.AudioHomeModelImpl
import com.ydl.ydlcommon.mvp.base.BasePresenter
import com.ydl.ydlcommon.router.YdlCommonRouterManager
import com.ydl.ydlcommon.utils.LogUtil
import com.ydl.ydlcommon.utils.remind.ToastHelper
import io.reactivex.android.schedulers.AndroidSchedulers
import io.reactivex.schedulers.Schedulers

/**
 * @author jiucheng
 * @描述:
 * @Copyright Copyright (c) 2018
 * @Company 壹点灵
 * @date 2018/10/30
 */
class AudioHomePresenterImpl : BasePresenter<IAudioHomeActivityContract.View, IAudioHomeActivityContract.Model>(), IAudioHomeActivityContract.Presenter {
//    override fun connectStart(param: ConnectStartCommand) {
//        mModel.connectStart(param)
//                .subscribeOn(Schedulers.io())
//                .observeOn(AndroidSchedulers.mainThread())
//                .doOnSubscribe {
//
//                }
//                .doAfterTerminate {
////                    view.dismissProgressView()
//                }
//                .subscribe({
////                    if (isSwitchAxb) {
////                        //切换axb：跳到拨号界面
////                        view.dialPhone()
////                    }
//                }, { e ->
//                    LogUtil.e(e.message)
//                })
//    }

//    override fun connectFinish(param: ConnectFinishCommand) {
//        mModel.connectFinish(param)
//                .subscribeOn(Schedulers.io())
//                .observeOn(AndroidSchedulers.mainThread())
//                .doOnSubscribe {
//                    //通知服务端专家已经接通时，此时用户已在界面通话中，不需要弹进度条
//                    mView.showProgressView()
//                }
//                .doAfterTerminate {
//                    mView.dismissProgressView()
//                }
//                .subscribe({
////                    if (isSwitchAxb) {
////                        //切换axb：跳到拨号界面
////                        view.dialPhone()
////                    }
//                    //挂断逻辑：不管接口调用成功与否，都关闭界面
//                    mView.finishActivity()
//                }, { e ->
//                    LogUtil.e(e.message)
//                    //挂断逻辑：不管接口调用成功与否，都关闭界面
//                    mView.finishActivity()
//                })
//    }

    override fun connectException(param: ConnectExceptionCommand) {
        mModel.connectException(param)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe {
                }
                .doAfterTerminate {
                }
                .subscribe({
                }, { e ->
                    LogUtil.e(e.message)
                })
    }

    /**
     * 登录声网
     */
    override fun loginChatNet(signalingToken: String) {
        mView.showProgressView()
        // appId:应用id
        // account：uid
        // token ：由 App ID 和 App Certificate 生成的 SignalingToken (如果不使用token可以设为字符串 _no_need_token)
        // uid：固定填 0
        // deviceID：暂时无用，设置为空
        // retry_time_in_s：登录重试时间，默认为 30 秒
        // retry_count：登录重试次数，默认为 3 次
        val ydlChtat = YDLChatParam()
        ydlChtat.appId = BuildConfig.AGORA_APPID
        ydlChtat.account = YdlCommonRouterManager.getYdlCommonRoute().getUid().toString()
        ydlChtat.token = signalingToken
        ydlChtat.uid = 0
        ydlChtat.deviceID = ""
        ydlChtat.retry_time_in_s = 30
        ydlChtat.retry_count = 3

//        YDLChartManager.instance!!.getChatApi().login(ydlChtat)
    }

    /**
     * 获取axb电话
     */
    override fun getAXBPhone(cmd: ConnectCommand) {
        mModel.getAXBPhone(cmd)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe { mView.showProgressView() }
                .doAfterTerminate { mView.dismissProgressView() }
                .subscribe({
                    if ("200".equals(it.code)){
                        if(0==it.data?.dialDetail?.dialStatus?:-1){
                            //连接成功
                            if(it.data?.dialDetail?.callConnectType?:-1==1){
                                //axb
                                mView.switchAXBResponse(it.data?.dialDetail?.phoneNu?:"")
                            }else{
                                ToastHelper.show(it.data?.dialDetail?.dialReason?:"连接失败")
                            }
                        }else{
                            ToastHelper.show(it.data?.dialDetail?.dialReason?:"连接失败")
                        }
                    }else{
                        ToastHelper.show(it.data?.dialDetail?.dialReason?:"连接失败")
                    }
                }, { e ->
                    LogUtil.d(e.message)
                })
    }

    /**
     * 通知服务端发送推送
     */
    override fun noticeServerPush(param: NoticePushCommand) {
        mModel.noticeServerPush(param)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    if (it.code == 200) {
//TODO
                    } else {
                        LogUtil.e(it.msg)
                    }
                }, { e ->
                    LogUtil.e(e.message)
                })
    }


    override fun createModel(): IAudioHomeActivityContract.Model {
        return AudioHomeModelImpl()
    }
}