优雅使用Retrofit，在协程时代遨游安卓网络请求（三）下

/**
 * 带壳的相应bean
 * @param T data实体类
 * @property data T 报文中对应data的部分
 * @property errorCode Int 报文中对应errorCode的部分
 * @property errorMsg String 报文中对应errorMsg的部分
 * @constructor
 */
data class WanBeanWrapper<T>(
    val data: T,
    val errorCode: Int = -1,
    val errorMsg: String = ""
) {
    companion object {
        const val SUCCESS_CODE = 0
        const val LOGIN_ERROR_CODE = -1001
    }
    /**
     * 请求是否成功
     * @return Boolean true:成功
     */
    fun isSuccessful(): Boolean {
        return errorCode == SUCCESS_CODE
    }
    /**
     * 登陆失败
     * @return Boolean true:登陆失败
     */
    fun isLoginError(): Boolean {
        return errorCode == LOGIN_ERROR_CODE
    }
}

class WanGlobalNetworkResultInterceptor @Inject constructor() : GlobalNetworkResultInterceptor {
    override fun <T> onIntercept(networkResult: NetworkResult<T>): NetworkResult<T> {
        return if (
            //只有成功才转换
            networkResult is Success &&
            //只转换这种类型的Bean
            networkResult.responseBody is WanBeanWrapper<*>
        ) {
            //类型强转
            val wanBeanWrapper = (networkResult.responseBody as WanBeanWrapper<*>)
            //如果不成功
            if (!wanBeanWrapper.isSuccessful()) {
                return MsgException(wanBeanWrapper.errorMsg).toExceptionResult()
            }
            networkResult
        } else {
            networkResult
        }
    }
}

//扩展方法新增一个参数
fun <T> Response<T>.toNetworkResult(interceptor: GlobalNetworkResultInterceptor): NetworkResult<T> =
    interceptor.onIntercept(
        try {
            if (isSuccessful) {
                toSuccessResult()
            } else {
                toServerErrorResult()
            }
        } catch (t: Throwable) {
            t.toExceptionResult()
        }
    )
//代理类
internal class ApexResponseCallDelegate<T>(
    private val proxyCall: Call<T>,
    //新增参数，传入全局拦截器
    private val interceptor: GlobalNetworkResultInterceptor
) :
    Call<NetworkResult<T>> {
    override fun enqueue(callback: Callback<NetworkResult<T>>) =
        proxyCall.enqueue(object : Callback<T> {
            override fun onResponse(call: Call<T>, response: Response<T>) {
                callback.onResponse(
                    this@ApexResponseCallDelegate,
                    Response.success(
                        //将参数传入到这里使用
                        response.toNetworkResult(interceptor)
                    )
                )
            }
            //省略部分代码
        })