add project.

Hunter0x7c7

2023-08-11 198dd6e1b210758867eed417bf6e00ba733d47c0

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package com.github.hunter0x7c7.sync.model.data.result.consumer;
/*
 * @Auther: Hunter
 * @Date: 2022/12/02/18:03
 * @Description:
 */
import com.github.hunter0x7c7.sync.model.data.result.ResultEntity;
import com.github.hunter0x7c7.sync.model.interfaces.KvCallback;
import io.reactivex.functions.Consumer;
 
public abstract class BaseConsumer<T> implements Consumer<ResultEntity<T>> {
    private ResultEntity<T> mResultEntity;
 
    public BaseConsumer() {
    }
 
    public void accept(ResultEntity<T> t) {
        this.setResultEntity(t);
        this.onAccept(t);
    }
 
    public abstract void onAccept(ResultEntity<T> var1);
 
    public abstract void onSuccess(String var1, T var2);
 
    public abstract void onResult(int var1, String var2);
 
    protected void onReLogin(int code, String msg) {
//        ToastUtil.showPrompt(string.login_disable_relogin);
        this.onResult(-1, msg);
    }
 
    protected void onTimeout(int code, String msg) {
//        ToastUtil.showPrompt(string.request_timeout);
        this.onResult(-1, msg);
    }
 
    protected void onSystemError(int code, String msg) {
//        ToastUtil.showPrompt(string.request_system_error);
        this.onResult(-1, msg);
    }
 
    protected void onDeviceOffline(int code, String msg) {
//        ToastUtil.showPrompt(string.device_offline);
        this.onResult(-1, msg);
    }
 
    public void getDataResult(ResultEntity<T> result) {
//        LogUtil.d("getDataResult... result:" + JsonUtil.toJson(result));
        if (result != null) {
            switch (result.getCode()) {
                case 0:
                    if ("ok".equals(result.getMsg())) {
                        this.onSuccess(result.getMsg(), result.getData());
                    }
                    break;
                case 200:
                    this.onSuccess(result.getMsg(), result.getData());
                    break;
                default:
                    this.onResult(result.getCode(), result.getMsg());
            }
        } else {
            this.onResult(-2, (String) null);
        }
 
    }
 
    public void getDataResultMsg(ResultEntity<T> result) {
        if (result != null) {
            switch (result.getCode()) {
                case 200:
                    this.onSuccess(result.getMsg(), result.getData());
                    break;
                default:
                    this.onResult(result.getCode(), result.getMsg());
            }
        } else {
            this.onResult(-2, (String) null);
        }
 
    }
 
    public static <K> void getDataResultMsg(ResultEntity<K> result, KvCallback<K, String> callback) {
        if (result != null) {
            switch (result.getCode()) {
                case 200:
                    if (callback != null) {
                        callback.onSuccess(result.getData());
                    }
                    break;
                default:
                    if (callback != null) {
                        callback.onResult(result.getCode(), result.getMsg());
                    }
            }
        } else if (callback != null) {
            callback.onResult(-1, null);
        }
 
    }
 
    public static boolean getDataResultEnable(ResultEntity data) {
        return data != null && data.getCode() == 200;
    }
 
    public ResultEntity<T> getResultEntity() {
        return this.mResultEntity;
    }
 
    public void setResultEntity(ResultEntity<T> t) {
        this.mResultEntity = t;
    }
}