zhangshi_app_android.git

			@@ -7,14 +7,29 @@
			import androidx.annotation.NonNull;
			import androidx.lifecycle.MutableLiveData;

			import com.android.app_base.base.StateViewEnum;
			import com.android.app_base.base.viewmodel.BaseViewModel;
			import com.android.app_base.http.ResultData;
			import com.android.app_base.manager.UserManager;
			import com.android.app_base.utils.RxUtils;
			import com.android.app_base.utils.rxbus.MessageEvent;
			import com.android.app_base.utils.rxbus.RxBus;
			import com.application.zhangshi_app_android.bean.BannerBean;
			import com.application.zhangshi_app_android.bean.GrowthExperienceInformationBean;
			import com.application.zhangshi_app_android.bean.UploadFileResponseBean;
			import com.application.zhangshi_app_android.data.DataRepository;

			import java.io.File;

			import io.reactivex.ObservableSource;
			import io.reactivex.Observer;
			import io.reactivex.disposables.Disposable;
			import io.reactivex.functions.Action;
			import io.reactivex.functions.Consumer;
			import io.reactivex.functions.Function;
			import okhttp3.MediaType;
			import okhttp3.MultipartBody;
			import okhttp3.RequestBody;

			/**
			* @author Ljj
			@@ -48,6 +63,12 @@
			public void onNext(ResultData<GrowthExperienceInformationBean> data) {
			if (data.getCode() == CODE_SUCCESS){
			getInfoLiveData().postValue(data.getData());
			GrowthExperienceInformationBean informationBean = data.getData();
			if(informationBean != null){
			UserManager.getInstance().setUserName(informationBean.getNickName());
			UserManager.getInstance().setUserAvatar(informationBean.getImg());
			RxBus.getInstance().post(new MessageEvent(MessageEvent.EVENT_UPDATE_USER_INFO,informationBean));
			}
			}else {
			messageLiveData.postValue(data.getMsg());
			}
			@@ -66,6 +87,72 @@
			});
			}

			/**
			* 修改个人信息（头像）
			*/
			public void updateInfo(String realPath) {
			File file = new File(realPath);
			RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file);
			MultipartBody.Part body = MultipartBody.Part.createFormData("uploadFile", file.getName(), requestBody);
			model.uploadFile(body)
			.flatMap(new Function<ResultData<UploadFileResponseBean>, ObservableSource<ResultData<String>>>() {
			@Override
			public ObservableSource<ResultData<String>> apply(ResultData<UploadFileResponseBean> resultData) throws Exception {
			GrowthExperienceInformationBean bean = getInfoLiveData().getValue();
			if (bean == null){
			bean = new GrowthExperienceInformationBean();
			}
			bean.setImg(resultData.getData().getUrl());
			infoLiveData.postValue(bean);
			return model.updateGrowthExperienceInformation(bean);
			}
			})
			.compose(RxUtils.schedulersTransformer())
			.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);
			}
			})
			.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("头像已上传");
			GrowthExperienceInformationBean informationBean = getInfoLiveData().getValue();
			if(informationBean != null){
			UserManager.getInstance().setUserName(informationBean.getNickName());
			UserManager.getInstance().setUserAvatar(informationBean.getUrl());
			RxBus.getInstance().post(new MessageEvent(MessageEvent.EVENT_UPDATE_USER_INFO,informationBean));
			}
			}else {
			messageLiveData.postValue(data.getMsg());
			}
			}

			@Override
			public void onError(Throwable e) {
			messageLiveData.postValue(e.getMessage());
			}

			@Override
			public void onComplete() {

			}
			});
			}


			public MutableLiveData<GrowthExperienceInformationBean> getInfoLiveData() {
			if (infoLiveData == null){