From 82e57df230ecb744af6c8865f80870ba03c86d89 Mon Sep 17 00:00:00 2001 From: Linjiajia <319408893@qq.com> Date: 星期二, 25 七月 2023 22:18:27 +0800 Subject: [PATCH] 基本功能完成 --- app/src/main/java/com/application/zhangshi_app_android/ui/function/HomeDevicesDetailActivityViewModel.java | 364 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 359 insertions(+), 5 deletions(-) diff --git a/app/src/main/java/com/application/zhangshi_app_android/ui/function/HomeDevicesDetailActivityViewModel.java b/app/src/main/java/com/application/zhangshi_app_android/ui/function/HomeDevicesDetailActivityViewModel.java index d79aff7..0e41a12 100644 --- a/app/src/main/java/com/application/zhangshi_app_android/ui/function/HomeDevicesDetailActivityViewModel.java +++ b/app/src/main/java/com/application/zhangshi_app_android/ui/function/HomeDevicesDetailActivityViewModel.java @@ -1,14 +1,33 @@ package com.application.zhangshi_app_android.ui.function; +import static com.android.app_base.base.BaseConfig.CODE_SUCCESS; + import android.app.Application; import androidx.annotation.NonNull; import androidx.lifecycle.MutableLiveData; import com.android.app_base.base.viewmodel.BaseViewModel; -import com.application.zhangshi_app_android.bean.FamilyAssetsBean; +import com.android.app_base.http.ResultData; +import com.android.app_base.manager.AppManager; +import com.android.app_base.utils.RxUtils; +import com.android.app_base.utils.rxbus.RxBus; import com.application.zhangshi_app_android.bean.HomeDevicesBean; +import com.application.zhangshi_app_android.bean.MemoBean; +import com.application.zhangshi_app_android.bean.UploadFileResponseBean; import com.application.zhangshi_app_android.data.DataRepository; + +import java.io.File; +import java.util.ArrayList; +import java.util.List; + +import io.reactivex.ObservableSource; +import io.reactivex.Observer; +import io.reactivex.disposables.Disposable; +import io.reactivex.functions.Function; +import okhttp3.MediaType; +import okhttp3.MultipartBody; +import okhttp3.RequestBody; /** * @author Ljj @@ -18,6 +37,9 @@ public class HomeDevicesDetailActivityViewModel extends BaseViewModel<DataRepository> { private MutableLiveData<HomeDevicesBean> beanLiveData; + private MutableLiveData<List<MemoBean>> memoListLiveData; + + private MutableLiveData<Boolean> typeLiveData;//true 缂栬緫鐘舵�� false 灞曠ず鐘舵�� public HomeDevicesDetailActivityViewModel(@NonNull Application application) { super(application); @@ -28,14 +50,346 @@ return DataRepository.getInstance(); } - public MutableLiveData<HomeDevicesBean> getBeanLiveData() { - if (beanLiveData == null){ - beanLiveData = new MutableLiveData<>(); + + /** + * 澧炲姞瀹跺涵璁惧 + */ + public void add() { + model.addHomeDevices(beanLiveData.getValue()) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> stringResultData) { + if (stringResultData.getCode() == CODE_SUCCESS){ + AppManager.getAppManager().finishCurrentActivity(); + RxBus.getInstance().post(beanLiveData.getValue()); + messageLiveData.postValue("娣诲姞鎴愬姛"); + }else { + messageLiveData.postValue(stringResultData.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + /** + * 鍒犻櫎瀹跺涵璁惧 + */ + public void delete() { + if (beanLiveData.getValue() == null){ + return; } - return beanLiveData; + model.deleteHomeDevices(String.valueOf(beanLiveData.getValue().getId())) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> stringResultData) { + if (stringResultData.getCode() == CODE_SUCCESS){ + AppManager.getAppManager().finishCurrentActivity(); + RxBus.getInstance().post(beanLiveData.getValue()); + messageLiveData.postValue("鍒犻櫎鎴愬姛"); + }else { + messageLiveData.postValue(stringResultData.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + /** + * 淇敼瀹跺涵璁惧 + */ + public void update() { + model.updateHomeDevices(beanLiveData.getValue()) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> stringResultData) { + if (stringResultData.getCode() == CODE_SUCCESS){ + AppManager.getAppManager().finishCurrentActivity(); + RxBus.getInstance().post(beanLiveData.getValue()); + messageLiveData.postValue("淇敼鎴愬姛"); + }else { + messageLiveData.postValue(stringResultData.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + + /** + * 涓婁紶鐢靛瓙鏂囦欢 + */ + public void uploadFile(File file) { + RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file); + MultipartBody.Part body = MultipartBody.Part.createFormData("uploadFile", file.getName(), requestBody); + model.uploadFile(body) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<UploadFileResponseBean>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<UploadFileResponseBean> resultData) { + if (resultData.getCode() == CODE_SUCCESS){ + HomeDevicesBean bean = beanLiveData.getValue(); + String url; + if (bean != null){ + url = bean.getUrl(); + if (url == null){ + url = resultData.getData().getUrl(); + }else { + url = url + "," + resultData.getData().getUrl(); + } + bean.setUrl(url); + beanLiveData.postValue(bean); + } + }else { + messageLiveData.postValue(resultData.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + + /** + * 鑾峰彇澶囧繕褰� + */ + public void getMemos() { + if (beanLiveData.getValue() == null) { + return; + } + model.getMemos("2017", String.valueOf(beanLiveData.getValue().getId())) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<List<MemoBean>>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<List<MemoBean>> data) { + if (data.getCode() == CODE_SUCCESS){ + memoListLiveData.postValue(data.getData()); + }else { + messageLiveData.postValue(data.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + + /** + * 娣诲姞澶囧繕褰� + */ + public void addMemo(List<MemoBean> list) { + if (list == null || list.size() == 0) { + return; + } + for (MemoBean memoBean : list) { + model.addMemo(memoBean) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> data) { + if (data.getCode() == CODE_SUCCESS) { + messageLiveData.postValue("娣诲姞澶囧繕褰曟垚鍔�"); + } else { + messageLiveData.postValue(data.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + + } + + /** + * 鍒犻櫎澶囧繕褰� + */ + public void deleteMemo(List<MemoBean> list) { + if (list == null || list.size() == 0) { + return; + } + StringBuffer sb = new StringBuffer(); + list.forEach(HomeDevicesBean -> sb.append(HomeDevicesBean.getId()).append(",")); + sb.deleteCharAt(sb.length()-1); + model.deleteMemo(sb.toString()) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> stringResultData) { + if (stringResultData.getCode() == CODE_SUCCESS){ + messageLiveData.postValue("鍒犻櫎澶囧繕褰曟垚鍔�"); + }else { + messageLiveData.postValue(stringResultData.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + + /** + * 淇敼澶囧繕褰� + */ + public void updateMemo(List<MemoBean> list) { + if (list == null || list.size() == 0) { + return; + } + for (MemoBean memoBean : list) { + model.updateMemo(memoBean) + .compose(RxUtils.schedulersTransformer()) + .subscribe(new Observer<ResultData<String>>() { + @Override + public void onSubscribe(Disposable d) { + addSubscribe(d); + } + + @Override + public void onNext(ResultData<String> data) { + if (data.getCode() == CODE_SUCCESS) { + messageLiveData.postValue("淇敼澶囧繕褰曟垚鍔�"); + } else { + messageLiveData.postValue(data.getMsg()); + } + } + + @Override + public void onError(Throwable e) { + messageLiveData.postValue(e.getMessage()); + } + + @Override + public void onComplete() { + + } + }); + } + } + + + public MutableLiveData<Boolean> getTypeLiveData() { + if (typeLiveData == null){ + typeLiveData = new MutableLiveData<>(); + } + return typeLiveData; + } + + public void setTypeLiveData(MutableLiveData<Boolean> typeLiveData) { + this.typeLiveData = typeLiveData; } public void setBeanLiveData(MutableLiveData<HomeDevicesBean> beanLiveData) { this.beanLiveData = beanLiveData; } + + public MutableLiveData<HomeDevicesBean> getBeanLiveData() { + if (beanLiveData == null){ + beanLiveData = new MutableLiveData<>(); + } + if (beanLiveData.getValue() == null){ + beanLiveData.setValue(new HomeDevicesBean()); + } + return beanLiveData; + } + + public MutableLiveData<List<MemoBean>> getMemoListLiveData() { + if (memoListLiveData == null){ + memoListLiveData = new MutableLiveData<>(); + } + return memoListLiveData; + } + + public void setMemoListLiveData(MutableLiveData<List<MemoBean>> memoListLiveData) { + this.memoListLiveData = memoListLiveData; + } + } -- Gitblit v1.9.1