package com.driver.igotrip.netUtls;
|
|
import android.content.Context;
|
import android.content.Intent;
|
import android.graphics.Bitmap;
|
import android.util.Log;
|
|
import com.driver.igotrip.base.BaseEvent;
|
import com.driver.igotrip.base.MyApplication;
|
import com.driver.igotrip.service.LocationForegroundService;
|
import com.driver.igotrip.ui.pub.LoginActivity;
|
import com.driver.igotrip.utils.Cache.CacheUtil;
|
import com.driver.igotrip.utils.LogUtils;
|
import com.google.gson.Gson;
|
import com.google.gson.JsonSyntaxException;
|
|
import org.greenrobot.eventbus.EventBus;
|
|
import java.io.IOException;
|
import java.lang.ref.WeakReference;
|
import java.net.ConnectException;
|
import java.net.SocketTimeoutException;
|
|
import cn.sinata.rxnetty.NettyClient;
|
import cn.sinata.xldutils.activitys.BaseActivity;
|
import cn.sinata.xldutils.fragment.BaseFragment;
|
import cn.sinata.xldutils.net.utils.Error;
|
import cn.sinata.xldutils.net.utils.ResultException;
|
import cn.sinata.xldutils.utils.StringUtils;
|
import cn.sinata.xldutils.utils.Toast;
|
import cn.sinata.xldutils.utils.Utils;
|
import cn.sinata.xldutils.xldUtils;
|
import io.reactivex.Observer;
|
import io.reactivex.annotations.NonNull;
|
import io.reactivex.disposables.Disposable;
|
import okhttp3.ResponseBody;
|
import retrofit2.HttpException;
|
|
/**
|
* 自定义Observer类处理网络数据
|
* Created by Administrator on 2018/1/25.
|
*/
|
|
public abstract class MyNoMsgObserver implements Observer<ResponseBody>, Disposable {
|
|
WeakReference<BaseActivity> activities;
|
WeakReference<BaseFragment> fragments;
|
Context context;
|
|
public MyNoMsgObserver(BaseActivity activity) {
|
activities = new WeakReference<>(activity);
|
if (activity != null) {
|
this.context = activity;
|
activity.compositeSubscription.add(this);
|
}
|
}
|
|
public MyNoMsgObserver(BaseFragment fragment) {
|
fragments = new WeakReference<BaseFragment>(fragment);
|
if (fragment != null && !fragment.isDetached()) {
|
this.context = fragment.getContext();
|
fragment.addDisposable(this);
|
}
|
}
|
|
public MyNoMsgObserver(Context context) {
|
this.context = context;
|
}
|
|
@Override
|
public void onSubscribe(@NonNull Disposable d) {
|
|
}
|
|
@Override
|
public void onNext(@NonNull ResponseBody responseBody) {
|
dismissDialog();
|
try {
|
String responseString = responseBody.string();
|
if (StringUtils.isEmpty(responseString)) { //判空
|
int code = -1;
|
String msg = getShowErrorMsg(Error.PARSER_ERROR);
|
onError(code, msg, responseString);
|
return;
|
}
|
// success(responseString);
|
BaseBean baseBean = new Gson().fromJson(responseString, BaseBean.class);
|
if (baseBean.getCode() == Api.SUCCESS) {
|
success(responseString);
|
} else {
|
if (baseBean.getCode() == 600) {
|
MyApplication.setCouldShowFloatingWindow(false);
|
LocationForegroundService.stop();
|
CacheUtil.get().clear();
|
NettyClient.getInstance().stopService();
|
Intent intent = new Intent();
|
intent.setClass(MyApplication.Companion.getAppContext(), LoginActivity.class);
|
EventBus.getDefault().post(new BaseEvent(BaseEvent.OFF_LINE));
|
|
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
MyApplication.Companion.getAppContext().startActivity(intent);
|
}
|
onError(baseBean.getCode(), baseBean.getMsg(), responseString);
|
// success(responseString);
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void onError(@NonNull Throwable e) {
|
dismissDialog();
|
if (xldUtils.DEBUG) {
|
e.printStackTrace();
|
}
|
int code = -1;
|
String msg = getShowErrorMsg(Error.REQUEST_ERROR);
|
if (e instanceof JsonSyntaxException ||
|
e instanceof NumberFormatException ||
|
e instanceof IllegalStateException) {
|
msg = getShowErrorMsg(Error.PARSER_ERROR);
|
} else if (e instanceof HttpException) {
|
msg = getShowErrorMsg(Error.SERVER_ERROR);
|
} else if (e instanceof ConnectException) {
|
msg = getShowErrorMsg(Error.NET_ERROR);
|
} else if (e instanceof SocketTimeoutException) {
|
msg = getShowErrorMsg(Error.NET_TIMEOUT);
|
} else if (e instanceof ResultException) {
|
code = ((ResultException) e).getCode();
|
msg = e.getMessage();
|
}
|
try {
|
onError(code, msg, "");
|
} catch (Exception es) {
|
es.printStackTrace();
|
}
|
|
}
|
|
protected void onError(int code, String msg, String resposeString) {
|
if (shouldShowErrorToast()) {
|
Log.e("onError: ", "长连接请求报错" + msg);
|
// showToast(msg);
|
}
|
}
|
|
protected boolean shouldShowErrorToast() {
|
return true;
|
}
|
|
@Override
|
public void onComplete() {
|
|
}
|
|
/**
|
* 显示toast
|
*
|
* @param s 提示文字
|
*/
|
protected void showToast(String s) {
|
Toast.create(context).show(s);
|
}
|
|
/**
|
* 访问成功回调抽象方法
|
*
|
* @param responseString 返回的数据
|
*/
|
public abstract void success(String responseString);
|
|
/**
|
* 访问成功回调方法
|
*
|
* @param bitmap 获取的Bitmap
|
*/
|
public void success(Bitmap bitmap) {
|
}
|
|
private void dismissDialog() {
|
if (activities != null) {
|
BaseActivity activity = activities.get();
|
if (activity != null) {
|
activity.dismissDialog();
|
|
}
|
}
|
if (fragments != null) {
|
BaseFragment fragment = fragments.get();
|
if (fragment != null) {
|
fragment.dismissDialog();
|
|
}
|
}
|
}
|
|
@Override
|
public boolean isDisposed() {
|
return false;
|
}
|
|
@Override
|
public void dispose() {
|
|
}
|
|
/**
|
* 获取异常显示信息
|
*/
|
public String getShowErrorMsg(Error error) {
|
int typeByLanguage = HttpManager.getTypeByLanguage();
|
return switch (typeByLanguage) {
|
case 3 -> error.getErrorFr();
|
case 1 -> error.getErrorCh();
|
default -> error.getErrorEn();
|
};
|
}
|
}
|
