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