fix

lmw

2023-03-14 128cbeac95dbc995fe1760bbd0f0a985fa5d23ba

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
package com.fuban.user.network
 
import cn.sinata.xldutils.activity.BaseActivity
import cn.sinata.xldutils.data.ResultData
import cn.sinata.xldutils.defaultScheduler
import cn.sinata.xldutils.fragment.BaseFragment
import cn.sinata.xldutils.rxutils.ResultDataSubscriber
import cn.sinata.xldutils.utils.SPUtils
import com.fuban.user.utils.Const
import io.reactivex.Flowable
 
/**
 * Created on 2018/4/12.
 */
 
inline fun <reified O, I : ResultData<O>> Flowable<I>.request(activity: BaseActivity, showToast: Boolean = true, crossinline success: (msg:String?, t: O?) -> Unit, crossinline error : (code: Int, msg: String) -> Unit) {
    this.defaultScheduler().subscribe(object : ResultDataSubscriber<O>(activity){
        override fun onSuccess(msg: String?, data: O?) {
            success(msg,data)
            activity.dismissDialog()
        }
        override fun isShowToast() = showToast
 
        override fun onError(code: Int, msg: String) {
            if (code == 600){//token无效
                super.onError(code, "您的身份已过期，请重新登录")
                SPUtils.instance().remove(Const.User.TOKEN).remove(Const.User.USER_ID).remove(Const.User.NO_PHONE).apply()
                activity.gotoLogin()
            }else{
                super.onError(code, msg)
                error(code,msg)
            }
            activity.dismissDialog()
        }
    })
}
inline fun <reified O, I : ResultData<O>> Flowable<I>.request(activity: BaseActivity, showToast: Boolean = true, crossinline success: (msg:String?, t: O?) -> Unit) {
    request(activity,showToast,success){_,_->}
}
 
inline fun <reified O, I : ResultData<O>> Flowable<I>.requestByF(fragment: BaseFragment, showToast: Boolean = true, crossinline success: (msg:String?, t: O?) -> Unit, crossinline error : (code: Int, msg: String) -> Unit) {
    this.defaultScheduler().subscribe(object : ResultDataSubscriber<O>(fragment){
        override fun onSuccess(msg: String?, data: O?) {
            fragment.dismissDialog()
            success(msg,data)
        }
        override fun isShowToast() = showToast
 
        override fun onError(code: Int, msg: String) {
            fragment.dismissDialog()
            if (code == 600){//token无效
//                super.onError(code, "您的身份已过期，请重新登录")
                SPUtils.instance().remove(Const.User.TOKEN).remove(Const.User.USER_ID).remove(Const.User.NO_PHONE).apply()
                fragment.gotoLogin()
            }else{
                super.onError(code, msg)
                error(code,msg)
            }
        }
    })
}
inline fun <reified O, I : ResultData<O>> Flowable<I>.requestByF(fragment: BaseFragment, showToast: Boolean = true, crossinline success: (msg:String?, t: O?) -> Unit) {
    requestByF(fragment,showToast,success){_,_->}
}