Guo_shaoshan
2023-04-09 ab9e0ae52d360fbe512bfbd3205206fcf4221be9
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
package com.application.zhangshi_app_android.data;
 
import androidx.annotation.NonNull;
 
import com.android.app_base.base.model.BaseModel;
import com.android.app_base.http.ResultData;
import com.application.zhangshi_app_android.bean.CaptchaImageBean;
import com.application.zhangshi_app_android.bean.FamilyAssetsResponseBean;
import com.application.zhangshi_app_android.bean.FamilyMemorabiliaBean;
import com.application.zhangshi_app_android.bean.FamilyMemorabiliaRequestBean;
import com.application.zhangshi_app_android.bean.FamilyMemorabiliaResponseBean;
import com.application.zhangshi_app_android.bean.GrowthExperienceBean;
import com.application.zhangshi_app_android.bean.GrowthExperienceResponseBean;
import com.application.zhangshi_app_android.bean.HomeDevicesResponseBean;
import com.application.zhangshi_app_android.bean.LoginRequestBean;
import com.application.zhangshi_app_android.bean.LoginResponseBean;
import com.application.zhangshi_app_android.bean.UploadFileResponseBean;
import com.application.zhangshi_app_android.data.source.HttpDataSource;
import com.application.zhangshi_app_android.data.source.LocalDataSource;
import com.application.zhangshi_app_android.data.source.http.HttpDataSourceImpl;
import com.application.zhangshi_app_android.data.source.local.LocalDataSourceImpl;
 
import java.io.File;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.DoubleUnaryOperator;
 
import io.reactivex.Completable;
import io.reactivex.Observable;
import io.reactivex.Observer;
import okhttp3.MultipartBody;
 
/**
 * @author Ljj
 * @date 2023.03.01. 20:58
 * @desc 数据仓库,包含网络数据和本地数据
 */
public class DataRepository extends BaseModel implements HttpDataSource, LocalDataSource {
 
    private volatile static DataRepository INSTANCE = null;
    private final HttpDataSource mHttpDataSource;
    private final LocalDataSource mLocalDataSource;
 
    private DataRepository(@NonNull HttpDataSource httpDataSource,
                           @NonNull LocalDataSource localDataSource) {
        this.mHttpDataSource = httpDataSource;
        this.mLocalDataSource = localDataSource;
    }
 
    public static DataRepository getInstance() {
        if (INSTANCE == null) {
            synchronized (DataRepository.class) {
                if (INSTANCE == null) {
                    INSTANCE = new DataRepository(HttpDataSourceImpl.getInstance(), LocalDataSourceImpl.getInstance());
                }
            }
        }
        return INSTANCE;
    }
 
 
    @Override
    public void onCleared() {
        HttpDataSourceImpl.destroyInstance();
        LocalDataSourceImpl.destroyInstance();
        INSTANCE = null;
    }
 
    /**
     * @see HttpDataSourceImpl
     */
    /**
     * 获取验证码图片
     */
    public Observable<ResultData<CaptchaImageBean>> getCaptchaImage(){
        return mHttpDataSource.getCaptchaImage();
    }
 
    /**
     * 登录
     */
    public Observable<ResultData<LoginResponseBean>> login(LoginRequestBean loginRequestBean){
        return mHttpDataSource.login(loginRequestBean);
    }
    /**
     * 注册
     */
    public Observable<ResultData<String>> register(LoginRequestBean loginRequestBean){
        return mHttpDataSource.register(loginRequestBean);
    }
    /**
     * 获取家大事记
     */
    @Override
    public Observable<ResultData<FamilyMemorabiliaResponseBean>> getFamilyMemorabilia(Map<String,Object> paramsMap) {
        return mHttpDataSource.getFamilyMemorabilia(paramsMap);
    }
    /**
     * 增加家大事记
     */
    @Override
    public Observable<ResultData<String>> addFamilyMemorabilia(FamilyMemorabiliaBean familyMemorabiliaBean) {
        return mHttpDataSource.addFamilyMemorabilia(familyMemorabiliaBean);
    }
    /**
     * 删除家大事记
     */
    @Override
    public Observable<ResultData<String>> deleteFamilyMemorabilia(String ids) {
        return mHttpDataSource.deleteFamilyMemorabilia(ids);
    }
    /**
     * 删除家大事记
     */
    @Override
    public Observable<ResultData<String>> updateFamilyMemorabilia(FamilyMemorabiliaBean familyMemorabiliaBean) {
        return mHttpDataSource.updateFamilyMemorabilia(familyMemorabiliaBean);
    }
 
    /**
     * 上传文件
     */
    public Observable<ResultData<UploadFileResponseBean>> uploadFile(MultipartBody.Part file) {
        return mHttpDataSource.uploadFile(file);
    }
 
    /**
     * 获取家庭资产
     */
    public Observable<ResultData<FamilyAssetsResponseBean>> getFamilyAssets(Map<String,Object> paramsMap) {
        return mHttpDataSource.getFamilyAssets(paramsMap);
    }
 
    /**
     * 获取家庭设备
     */
    public Observable<ResultData<HomeDevicesResponseBean>> getHomeDevices(Map<String, Object> paramsMap) {
        return mHttpDataSource.getHomeDevices(paramsMap);
    }
    /**
     * 获取成长经历
     */
       public Observable<ResultData<GrowthExperienceResponseBean>> getGrowthExperience(Map<String, Object> paramsMap) {
             return mHttpDataSource.getGrowthExperience(paramsMap);
          }
 
    /**
     * @see LocalDataSourceImpl
     */
}