| | |
|---|
| | | return DataRepository.getInstance(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 增加家大事记 |
|---|
| | | */ |
|---|
| | | // public void add() { |
|---|
| | | // if (uploadFileList.size() > 0) { |
|---|
| | | // List<Observable<String>> observables = new ArrayList<>(); |
|---|
| | | // for (String path : uploadFileList) { |
|---|
| | | // File file = new File(path); |
|---|
| | | // RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file); |
|---|
| | | // MultipartBody.Part body = MultipartBody.Part.createFormData("uploadFile", file.getName(), requestBody); |
|---|
| | | // Observable<String> uploadObservable = model.uploadFile(body) |
|---|
| | | // .flatMap(new Function<ResultData<UploadFileResponseBean>, ObservableSource<String>>() { |
|---|
| | | // @Override |
|---|
| | | // public ObservableSource<String> apply(ResultData<UploadFileResponseBean> resultData) throws Exception { |
|---|
| | | // if (resultData.getCode() == CODE_SUCCESS) { |
|---|
| | | // WebbackBean bean = getBeanLiveData().getValue(); |
|---|
| | | // if (bean != null) { |
|---|
| | | // String urls = bean.getUrl(); |
|---|
| | | // //替换图片地址 |
|---|
| | | // urls = urls.replace(path, resultData.getData().getUrl()); |
|---|
| | | // bean.setUrl(urls); |
|---|
| | | // getBeanLiveData().postValue(bean); |
|---|
| | | // } |
|---|
| | | // return Observable.just(path); |
|---|
| | | // } else { |
|---|
| | | // return Observable.error(new Exception(resultData.getMsg())); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // }); |
|---|
| | | // |
|---|
| | | // observables.add(uploadObservable); |
|---|
| | | // } |
|---|
| | | // Observable.zip(observables, result -> result) |
|---|
| | | // .flatMap(new Function<Object[], Observable<ResultData<String>>>() { |
|---|
| | | // @Override |
|---|
| | | // public Observable<ResultData<String>> apply(Object[] objects) throws Exception { |
|---|
| | | // //移除已经上传的文件 |
|---|
| | | // //把objects数组转换成list，然后移除 |
|---|
| | | // for (Object object : objects) { |
|---|
| | | // uploadFileList.remove((String) object); |
|---|
| | | // } |
|---|
| | | // return model.addWebback(beanLiveData.getValue()); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .doOnSubscribe(new Consumer<Disposable>() { |
|---|
| | | // @Override |
|---|
| | | // public void accept(Disposable disposable) throws Exception { |
|---|
| | | // changeStateView(StateViewEnum.DIALOG_LOADING); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .doFinally(new Action() { |
|---|
| | | // @Override |
|---|
| | | // public void run() throws Exception { |
|---|
| | | // changeStateView(StateViewEnum.DIALOG_DISMISS); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .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() { |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // }); |
|---|
| | | // }else { |
|---|
| | | // model.addMeeting(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() { |
|---|
| | | // model.deleteMeeting(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() { |
|---|
| | | // if (uploadFileList.size() > 0){ |
|---|
| | | // List<Observable<String>> observables = new ArrayList<>(); |
|---|
| | | // for (String path : uploadFileList) { |
|---|
| | | // File file = new File(path); |
|---|
| | | // RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file); |
|---|
| | | // MultipartBody.Part body = MultipartBody.Part.createFormData("uploadFile", file.getName(), requestBody); |
|---|
| | | // Observable<String> uploadObservable = model.uploadFile(body) |
|---|
| | | // .flatMap(new Function<ResultData<UploadFileResponseBean>, ObservableSource<String>>() { |
|---|
| | | // @Override |
|---|
| | | // public ObservableSource<String> apply(ResultData<UploadFileResponseBean> resultData) throws Exception { |
|---|
| | | // if (resultData.getCode() == CODE_SUCCESS){ |
|---|
| | | // MeetingBean bean = getBeanLiveData().getValue(); |
|---|
| | | // if (bean != null){ |
|---|
| | | // String urls = bean.getUrl(); |
|---|
| | | // //替换图片地址 |
|---|
| | | // urls = urls.replace(path,resultData.getData().getUrl()); |
|---|
| | | // bean.setUrl(urls); |
|---|
| | | // getBeanLiveData().postValue(bean); |
|---|
| | | // } |
|---|
| | | // return Observable.just(path); |
|---|
| | | // }else { |
|---|
| | | // return Observable.error(new Exception(resultData.getMsg())); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // }); |
|---|
| | | // |
|---|
| | | // observables.add(uploadObservable); |
|---|
| | | // } |
|---|
| | | // Observable.zip(observables,result -> result) |
|---|
| | | // .flatMap(new Function<Object[], Observable<ResultData<String>>>() { |
|---|
| | | // @Override |
|---|
| | | // public Observable<ResultData<String>> apply(Object[] objects) throws Exception { |
|---|
| | | // //移除已经上传的文件 |
|---|
| | | // //把objects数组转换成list，然后移除 |
|---|
| | | // for (Object object : objects) { |
|---|
| | | // uploadFileList.remove((String) object); |
|---|
| | | // } |
|---|
| | | // return model.updateMeeting(beanLiveData.getValue()); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .doOnSubscribe(new Consumer<Disposable>() { |
|---|
| | | // @Override |
|---|
| | | // public void accept(Disposable disposable) throws Exception { |
|---|
| | | // changeStateView(StateViewEnum.DIALOG_LOADING); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .doFinally(new Action() { |
|---|
| | | // @Override |
|---|
| | | // public void run() throws Exception { |
|---|
| | | // changeStateView(StateViewEnum.DIALOG_DISMISS); |
|---|
| | | // } |
|---|
| | | // }) |
|---|
| | | // .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() { |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // }); |
|---|
| | | // }else { |
|---|
| | | // model.updateMeeting(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 MutableLiveData<WebbackBean> getBeanLiveData() { |
|---|
| | | if (beanLiveData == null){ |
|---|
