diff --git a/BaseModule/src/main/java/com/xscm/moduleutil/http/NetworkCheckInterceptor.java b/BaseModule/src/main/java/com/xscm/moduleutil/http/NetworkCheckInterceptor.java new file mode 100644 index 00000000..ceb35b9f --- /dev/null +++ b/BaseModule/src/main/java/com/xscm/moduleutil/http/NetworkCheckInterceptor.java @@ -0,0 +1,61 @@ +package com.xscm.moduleutil.http; + +import android.content.Context; +import android.net.ConnectivityManager; +import android.net.NetworkInfo; +import android.net.http.NetworkException; + +import com.blankj.utilcode.util.ToastUtils; + +import java.io.IOException; + +import okhttp3.Interceptor; +import okhttp3.Response; + +/** + * 项目名称：羽声语音 + * 时间：2025/12/23 16:58 + * 用途：网络状态检查拦截器,会在每次请求前检查网络状态。 + */ +public class NetworkCheckInterceptor implements Interceptor { + + private final Context context; + + public NetworkCheckInterceptor(Context context) { + this.context = context.getApplicationContext(); // 使用 Application Context 避免内存泄漏 + } + + @Override + public Response intercept(Chain chain) throws IOException { + // 检查网络连接状态 + if (!isNetworkAvailable()) { + // 如果没有网络，抛出我们自定义的异常 + ToastUtils.showLong("网络连接不可用，请检查您的网络设置"); + } + + // 如果有网络，继续执行请求 + return chain.proceed(chain.request()); + } + + /** + * 检查网络是否可用 + * @return true if network is available, false otherwise. + */ + private boolean isNetworkAvailable() { + ConnectivityManager connectivityManager = + (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE); + + if (connectivityManager != null) { + // 获取所有网络信息 + NetworkInfo[] networkInfos = connectivityManager.getAllNetworkInfo(); + if (networkInfos != null) { + for (NetworkInfo info : networkInfos) { + if (info.getState() == NetworkInfo.State.CONNECTED) { + return true; + } + } + } + } + return false; + } +} diff --git a/BaseModule/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java b/BaseModule/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java index 282ac193..bc7b7f34 100644 --- a/BaseModule/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java +++ b/BaseModule/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java @@ -41,6 +41,7 @@ import java.security.SecureRandom; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.Collections; +import java.util.EventListener; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -121,6 +122,7 @@ public class RetrofitClient { final OkHttpClient client = new OkHttpClient.Builder() .addInterceptor(new DataLoggingInterceptor(new DataLogger())) .addInterceptor(new AccessTokenInterceptor(headers)) + .addInterceptor(new NetworkCheckInterceptor(CommonAppContext.getInstance())) .proxy(Proxy.NO_PROXY) .sslSocketFactory(sslContext.getSocketFactory(), trustAllCert) .hostnameVerifier((hostname, session) -> true) @@ -233,7 +235,12 @@ public class RetrofitClient { observer.onNext(body.getMsg()); } else if (body.getCode() == 0) { ToastUtils.showLong(body.getMsg()); + } else if (body.getCode() == 301) { + setCode301(body.getMsg()); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("sendCode", response.message()); } } @@ -250,14 +257,22 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel body = response.body(); - observer.onNext(body.getMsg()); - + if (body.getCode() == 1) { + observer.onNext(body.getMsg()); + } else if (body.getCode() == 0) { + ToastUtils.showLong(body.getMsg()); + } else if (body.getCode() == 301) { + setCode301(body.getMsg()); + } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("mobileView", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("mobileView", t.getMessage()); } }); } @@ -273,19 +288,17 @@ public class RetrofitClient { } else if (body.getCode() == 0) { observer.onError(new Throwable(body.getMsg())); } else if (body.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(body.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(body.getMsg()); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("upEmotion", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("upEmotion", t.getMessage()); } }); @@ -306,18 +319,17 @@ public class RetrofitClient { } else if (body.getCode() == 0) { observer.onError(new Throwable(body.getMsg())); } else if (body.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(body.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(body.getMsg()); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("getEmotionDeatils", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { + LogUtils.e("getEmotionDeatils", t.getMessage()); } }); @@ -343,13 +355,22 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel body = response.body(); - observer.onNext(body.getMsg()); + if (body.getCode() == 1) { + observer.onNext(body.getMsg()); + } else if (body.getCode() == 0) { + ToastUtils.showLong(body.getMsg()); + } else if (body.getCode() == 301) { + setCode301(body.getMsg()); + } + } else { + ToastUtils.showLong("手机绑定请求错误", response.code()); + LogUtils.e("mobileView2", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("mobileView2", t.getMessage()); } }); } @@ -371,12 +392,16 @@ public class RetrofitClient { ToastUtils.showShort(listBaseModel.getMsg()); } } + } else { + ToastUtils.showLong("登录请求错误", response.code()); + LogUtils.e("mobileView2", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("mobileView2", t.getMessage()); + } }); } @@ -390,17 +415,22 @@ public class RetrofitClient { if (listBaseModel != null) { if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); - } else { + } else if (listBaseModel.getCode() == 0) { ToastUtils.showShort(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); } } + } else { + ToastUtils.showLong("小时榜请求错误", response.code()); + LogUtils.e("getRoomHourRanking", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getRoomHourRanking", t.getMessage()); } }); } @@ -409,19 +439,6 @@ public class RetrofitClient { sApiServer.userLogin(mobile, password).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { -// if (response.code()==200){ -// BaseModel> listBaseModel=response.body(); -// if (listBaseModel!=null){ -// int code=listBaseModel.getCode(); -// if (code==1){ -// observer.onNext(listBaseModel.getData()); -// } -// else { -// LogUtils.e("@@@",response); -// } -// } -// } - if (response.code() == 200) { LogUtils.e("Raw JSON", response.body()); // 打印原始响应内容 BaseModel> string = response.body(); @@ -433,23 +450,22 @@ public class RetrofitClient { } else if (code == 301) { // try { ToastUtils.showShort(string.getMsg()); -// ToastUtils.showShort("提示当前账号已在别的地方登陆，如果不是本人操作请修改密码"); -// CommonAppContext.getInstance().clearLoginInfo(); -// } catch (ClassNotFoundException e) { -// throw new RuntimeException(e); -// } } else { - ToastUtils.showShort(string.getMsg()); } + } else { + ToastUtils.showLong("登录请求返回数据错误"); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("userLogin", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - LogUtils.e("@@@", t); + LogUtils.e("userLogin", t); } }); } @@ -463,7 +479,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("exchangeCoin", t.getMessage()); } }); } @@ -479,7 +495,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("delfoot", t.getMessage()); } }); } @@ -492,16 +508,23 @@ public class RetrofitClient { if (response.code() == 200) { BaseModel baseModel = response.body(); if (baseModel != null) { - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } } else { ToastUtils.showShort("获取数据失败"); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("firstCharge", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("firstCharge", t.getMessage()); } }); } @@ -529,6 +552,9 @@ public class RetrofitClient { } catch (IOException e) { e.printStackTrace(); } + } else { + ToastUtils.showLong("提现失败", response.code()); + LogUtils.e("withdrawal", response.message()); } } @@ -536,8 +562,6 @@ public class RetrofitClient { public void onFailure(Call call, Throwable t) { LogUtils.e("提现失败", t); } - - }); } @@ -549,15 +573,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("getMessagetitle", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getMessagetitle", t); } }); } @@ -572,14 +601,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) observer.onNext(baseModel.getMsg()); else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("postInvite", response.message()); } } @@ -600,14 +628,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) observer.onNext(baseModel.getMsg()); else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { - observer.onNext(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("认证失败", response.code()); + LogUtils.e("singerAuth", response.message()); } } @@ -628,15 +655,14 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); - observer.onNext(baseModel.getData()); + observer.onNext(new SongPlaylist()); } + } else { + ToastUtils.showLong("获取歌曲失败", response.code()); + LogUtils.e("getSong", response.message()); } } @@ -658,19 +684,19 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("切歌失败", response.code()); + LogUtils.e("singerSongCut", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { + LogUtils.e("切歌失败", t.fillInStackTrace()); } }); @@ -687,15 +713,14 @@ public class RetrofitClient { ToastUtils.showShort(baseModel.getMsg()); observer.onNext(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { observer.onNext(baseModel.getMsg()); ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("置顶失败", response.code()); + LogUtils.e("singerSongTop", response.message()); } } @@ -716,15 +741,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取歌曲数量失败", response.code()); + LogUtils.e("singerSongCount", response.message()); } } @@ -745,14 +768,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("点歌失败", response.code()); + LogUtils.e("singerSong", response.message()); } } @@ -772,15 +794,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取歌曲列表失败", response.code()); + LogUtils.e("singerSongList", response.message()); } } @@ -800,15 +820,14 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); observer.onNext(baseModel.getData()); } + } else { + ToastUtils.showLong("删除歌曲失败", response.code()); + LogUtils.e("deleteSong", response.message()); } } @@ -829,23 +848,21 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); observer.onNext(new TempKeyBean()); } else if (baseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(baseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("getTempKey", response.message()); } } @Override public void onFailure(Call> call, Throwable throwable) { - + LogUtils.e("getTempKey", throwable.fillInStackTrace()); } - }); } @@ -857,17 +874,21 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { Log.d("withdrawalList---", "onResponse: " + response.body().toString()); - observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { - observer.onNext(null); + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("withdrawalList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("withdrawalList", t.fillInStackTrace()); } }); // sApiServer.withdrawalList(page, page_limit, search_stime, search_etime).compose(new DefaultTransformer<>()).subscribe(observer); @@ -881,15 +902,21 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { - observer.onNext(null); + ToastUtils.showLong("获取失败", response.code()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("bindDetai", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("bindDetai", t.fillInStackTrace()); + } }); } @@ -904,7 +931,14 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("getRoomRank", response.message()); } } @@ -935,12 +969,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("dailyTasksBoxRecord", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { + LogUtils.e("dailyTasksBoxRecord", t.fillInStackTrace()); } }); @@ -956,13 +998,18 @@ public class RetrofitClient { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { observer.onNext(new ArrayList<>()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("packIncome", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("packIncome", t.fillInStackTrace()); } }); } @@ -977,13 +1024,18 @@ public class RetrofitClient { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { observer.onNext(new ArrayList<>()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取失败", response.code()); + LogUtils.e("packOutcome", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("packOutcome", t.fillInStackTrace()); } }); } @@ -997,15 +1049,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); - } else { -// observer.onNext(null); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("背包礼物获取失败", response.code()); + LogUtils.e("giftPack", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("giftPack", t.fillInStackTrace()); } }); } @@ -1018,15 +1075,20 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getMsg()); - } else { -// observer.onNext(null); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("背包礼物获取失败", response.code()); + LogUtils.e("getGiftPack", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getGiftPack", t.fillInStackTrace()); } }); } @@ -1039,13 +1101,21 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("背包礼物总价值", response.code()); + LogUtils.e("getGiftPackListCount", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getGiftPackListCount", t.fillInStackTrace()); + } }); } @@ -1076,17 +1146,26 @@ public class RetrofitClient { Type type = new TypeToken>() { }.getType(); BaseModel baseModel = GsonUtils.fromJson(json, type); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } } catch (IOException e) { throw new RuntimeException(e); } - + } else { + ToastUtils.showLong("每日任务列表获取失败", response.code()); + LogUtils.e("tasksLihen", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("tasksLihen", t.fillInStackTrace()); + } }); } @@ -1107,19 +1186,23 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { baseModel.setData(baseModel.getMsg()); observer.onNext(baseModel.getData()); - } else { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } - } catch (IOException e) { e.printStackTrace(); } + } else { + ToastUtils.showLong("领取每日任务奖励失败", response.code()); + LogUtils.e("dailyTasksReceive", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("dailyTasksReceive", t.fillInStackTrace()); } }); } @@ -1135,16 +1218,25 @@ public class RetrofitClient { Type type = new TypeToken>() { }.getType(); BaseModel baseModel = GsonUtils.fromJson(json, type); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } } catch (IOException e) { throw new RuntimeException(e); } + } else { + ToastUtils.showLong("领取每日任务奖励失败", response.code()); + LogUtils.e("dailyTasksComplete", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("dailyTasksComplete", t.fillInStackTrace()); } }); } @@ -1158,7 +1250,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("sendHeadine", t.fillInStackTrace()); } }); } @@ -1171,19 +1263,30 @@ public class RetrofitClient { sApiServer.upUserNickname().enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { - try { - String json = response.body().string(); - BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); - observer.onNext(baseModel.getData().toString()); + if (response.code() == 200) { + try { + String json = response.body().string(); + BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } - } catch (IOException e) { - e.printStackTrace(); + } catch (IOException e) { + e.printStackTrace(); + } + } else { + ToastUtils.showLong("更新用户昵称失败", response.code()); + LogUtils.e("upUserNickname", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("upUserNickname", t.fillInStackTrace()); } }); @@ -1195,19 +1298,28 @@ public class RetrofitClient { public void onResponse(Call>> call, Response>> response) { if (response.code() == 200) { BaseModel> baseModel = response.body(); - if (baseModel != null) { - if (baseModel.getData() != null && baseModel.getData().size() > 0) { - observer.onNext(baseModel.getData()); - } else { - observer.onNext(new ArrayList<>()); + if (baseModel.getCode() == 1) { + if (baseModel != null) { + if (baseModel.getData() != null && baseModel.getData().size() > 0) { + observer.onNext(baseModel.getData()); + } else { + observer.onNext(new ArrayList<>()); + } } + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取收益明细失败", response.code()); + LogUtils.e("getRevenueData", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getRevenueData", t.fillInStackTrace()); } }); } @@ -1221,13 +1333,20 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("获取实名认证信息失败", response.code()); + LogUtils.e("realNameInfo", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("realNameInfo", t.fillInStackTrace()); } }); } @@ -1236,19 +1355,29 @@ public class RetrofitClient { sApiServer.addBlackList(userId).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { - try { - String json = response.body().string(); - BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); - observer.onNext(baseModel.getData()); - - } catch (IOException e) { - e.printStackTrace(); + if (response.code() == 200) { + try { + String json = response.body().string(); + BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } + } catch (IOException e) { + e.printStackTrace(); + } + } else { + ToastUtils.showLong("添加黑名单失败", response.code()); + LogUtils.e("addBlackList", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("addBlackList", t.fillInStackTrace()); } }); } @@ -1257,19 +1386,29 @@ public class RetrofitClient { sApiServer.upUserPic(sex).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { - try { - String json = response.body().string(); - BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); - observer.onNext(baseModel.getData()); - - } catch (IOException e) { - e.printStackTrace(); + if (response.code() == 200) { + try { + String json = response.body().string(); + BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } + } catch (IOException e) { + e.printStackTrace(); + } + } else { + ToastUtils.showLong("上传头像失败", response.code()); + LogUtils.e("upUserPic", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("upUserPic", t.toString()); } }); @@ -1291,7 +1430,8 @@ public class RetrofitClient { // }); } - public void sendPk(String roomIda, String createUserId, String roomIdb, BaseObserver observer) { + public void sendPk(String roomIda, String createUserId, String + roomIdb, BaseObserver observer) { sApiServer.sendPk(roomIda, createUserId, roomIdb).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { @@ -1343,18 +1483,25 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + LogUtils.e("充值", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("充值", t); } }); } - public void endPk(String pk_id, String type, String user_id, BaseObserver observer) { + public void endPk(String pk_id, String type, String + user_id, BaseObserver observer) { sApiServer.endPk(pk_id, type, user_id).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { @@ -1386,13 +1533,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("切换账号", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("切换账号", t); } }); } @@ -1406,13 +1559,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("搜索房间", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("搜索房间", t); } }); } @@ -1426,13 +1585,19 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("用户信息修改", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("用户信息修改", t); } }); } @@ -1450,12 +1615,14 @@ public class RetrofitClient { } catch (IOException e) { e.printStackTrace(); } + } else { + LogUtils.e("授权失败", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("授权失败", t); } }); } @@ -1471,10 +1638,12 @@ public class RetrofitClient { } else if (baseModel.getCode() == 301) { ToastUtils.showShort(baseModel.getMsg()); observer.onNext(new ArrayList<>()); - }else if (baseModel.getCode() == 0) { + } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); observer.onNext(new ArrayList<>()); } + } else { + LogUtils.e("授权登录失败", response.message()); } } @@ -1501,12 +1670,14 @@ public class RetrofitClient { observer.onNext(null); } } + } else { + LogUtils.e("获取主题数据失败", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("获取主题数据失败", t); } }); } @@ -1527,15 +1698,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + LogUtils.e("获取关注列表失败", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("获取关注列表失败", t); } }); } @@ -1548,20 +1723,25 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); - } else { + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } + } else { + LogUtils.e("获取粉丝列表失败", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("获取粉丝列表失败", t); } }); } - public void getBlacklist(String page, String page_limit, BaseObserver> observer) { + public void getBlacklist(String page, String + page_limit, BaseObserver> observer) { sApiServer.getBlacklist(page, page_limit).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -1569,20 +1749,25 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); - } else { + } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("黑名单", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("黑名单", t.toString()); } }); } - public void getLockMiniList(String page, String page_limit, BaseObserver> observer) { + public void getLockMiniList(String page, String + page_limit, BaseObserver> observer) { sApiServer.getLockMiniList(page, page_limit).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -1590,15 +1775,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); - } else { + } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("访客失败", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("访客失败", t.toString()); } }); } @@ -1614,25 +1803,23 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(baseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("实名认证失败", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("实名认证失败", t.toString()); } }); } //获取扩列数据 - public void getExpandColumn(String type, String page, String page_limit, BaseObserver> observer) { + public void getExpandColumn(String type, String page, String + page_limit, BaseObserver> observer) { sApiServer.getExpandColumn(type, page, page_limit).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -1640,13 +1827,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("获取扩列数据失败", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("获取扩列数据失败", t.toString()); } }); } @@ -1662,17 +1855,20 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } + } else { + LogUtils.e("获取官方公告数据失败", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("获取官方公告数据失败", t.toString()); } }); } - public void getAlbumList(String page, String page_limit, String userId, BaseObserver> observer) { + public void getAlbumList(String page, String page_limit, String + userId, BaseObserver> observer) { // sApiServer.getAlbumList(page, page_limit, userId).compose(new DefaultTransformer<>()).subscribe(observer); sApiServer.getAlbumList(page, page_limit, userId).enqueue(new Callback>>() { @Override @@ -1681,13 +1877,19 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + LogUtils.e("获取相册列表失败", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("获取相册列表失败", t.toString()); } }); } @@ -1700,10 +1902,18 @@ public class RetrofitClient { try { String json = response.body().string(); BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } } catch (IOException e) { e.printStackTrace(); } + } else { + LogUtils.e("获取房间名称失败", response.message()); } } @@ -1715,23 +1925,32 @@ public class RetrofitClient { }); } - public void getMyRoom(String type, String page, String page_limit, BaseObserver> observer) { + public void getMyRoom(String type, String page, String + page_limit, BaseObserver> observer) { sApiServer.getMyRoom(type, page, page_limit).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { if (response.code() == 200) { BaseModel> listBaseModel = response.body(); if (listBaseModel != null) { - observer.onNext(listBaseModel.getData()); + if (listBaseModel.getCode() == 1) { + observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showLong(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } + } else { + LogUtils.e("getMyRoom", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("获取我的房间失败", t); } }); } @@ -1746,18 +1965,15 @@ public class RetrofitClient { if (listBaseModel != null) { observer.onNext(listBaseModel.getData()); } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } } else if (listBaseModel.getCode() == 0) { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } else if (listBaseModel.getCode() == 301) { - try { - ToastUtils.showShort(listBaseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(listBaseModel.getMsg()); } + } else { + LogUtils.e("getBanners", response.message()); } } @@ -1779,25 +1995,23 @@ public class RetrofitClient { if (listBaseModel != null) { observer.onNext(listBaseModel.getData()); } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } } else if (listBaseModel.getCode() == 0) { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } else if (listBaseModel.getCode() == 301) { - try { - ToastUtils.showShort(listBaseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } - + setCode301(listBaseModel.getMsg()); } + } else { + observer.onError(new Throwable(response.message())); + ToastUtils.showLong("首页房间列表异常",response.code()); + LogUtils.e("getTopRooms", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("获取置顶房间失败", t.toString()); } }); } @@ -1813,20 +2027,16 @@ public class RetrofitClient { } else if (listBaseModel.getCode() == 0) { observer.onNext(null); } else if (listBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(listBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } - + setCode301(listBaseModel.getMsg()); } + } else { + LogUtils.e("getRoomCategories", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getRoomCategories", t.toString()); } }); } @@ -1841,13 +2051,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showLong(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); } + } else { + LogUtils.e("getRewardList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getRewardUserList", t.fillInStackTrace()); } }); } @@ -1860,13 +2076,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showLong(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); } + } else { + LogUtils.e("getGiftLabel", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getGiftLabel", t.fillInStackTrace()); } }); } @@ -1879,13 +2101,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showLong(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); } + } else { + LogUtils.e("getGiftList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.fillInStackTrace(); + LogUtils.e("getGiftList", t.fillInStackTrace()); } }); } @@ -1902,22 +2130,17 @@ public class RetrofitClient { observer.onNext(listBaseModel.getData()); } else if (listBaseModel.getCode() == 0) { ToastUtils.showLong(listBaseModel.getMsg()); - observer.onNext(null); } else if (listBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(listBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(listBaseModel.getMsg()); } - + } else { + LogUtils.e("singerUpdateSong", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("singerUpdateSong", t.fillInStackTrace()); } }); } @@ -1934,28 +2157,24 @@ public class RetrofitClient { observer.onNext(listBaseModel.getData()); } else if (listBaseModel.getCode() == 0) { ToastUtils.showLong(listBaseModel.getMsg()); - observer.onNext(null); } else if (listBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(listBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(listBaseModel.getMsg()); } - + } else { + LogUtils.e("singerAddSong", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("singerAddSong", t.fillInStackTrace()); } }); } - public void topicList(String page, String page_limit, BaseObserver> observer) { + public void topicList(String page, String + page_limit, BaseObserver> observer) { sApiServer.topicList(page, page_limit).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -1963,13 +2182,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("topicList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("topicList", t.fillInStackTrace()); } }); } @@ -1983,13 +2208,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getCategories", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getCategories", t.fillInStackTrace()); } }); } @@ -2002,16 +2233,24 @@ public class RetrofitClient { if (response.code() == 200) { BaseModel> listBaseModel = response.body(); if (listBaseModel != null) { - observer.onNext(listBaseModel.getData()); + if (listBaseModel.getCode() == 1) { + observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); + } } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } + } else { + LogUtils.e("getCircleList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getCircleList", t.fillInStackTrace()); } }); } @@ -2026,16 +2265,22 @@ public class RetrofitClient { if (listBaseModel != null) { if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); } + } else { + LogUtils.e("getCircleUserList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getCircleUserList", t.fillInStackTrace()); } }); } @@ -2048,13 +2293,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("topicId", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("topicId", t.toString()); } }); } @@ -2067,13 +2318,19 @@ public class RetrofitClient { BaseModel listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("zoneDetail", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("zoneDetail", t.fillInStackTrace()); } }); } @@ -2091,13 +2348,18 @@ public class RetrofitClient { if (ActivityUtils.getTopActivity().getComponentName().getClassName().contains("UserHomepageActivity")) { ActivityUtils.getTopActivity().finish(); } + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); } + } else { + ToastUtils.showLong("进入用户主页错误",response.code()); + LogUtils.e("getUserHome", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getUserHome", t.fillInStackTrace()); } }); } @@ -2110,18 +2372,25 @@ public class RetrofitClient { BaseModel listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getCommentList", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getCommentList", t.fillInStackTrace()); } }); } - public void song(String roomId, String user_id, String song_code, String song_name, String singer, String poster, String duration, BaseObserver> observer) { + public void song(String roomId, String user_id, String song_code, String song_name, + String singer, String poster, String duration, BaseObserver> observer) { sApiServer.song(roomId, user_id, song_code, song_name, singer, poster, duration).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -2129,13 +2398,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("song", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("song", t.getMessage()); } }); } @@ -2148,13 +2423,20 @@ public class RetrofitClient { BaseModel listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + ToastUtils.showLong("获取用户数据错误",response.code()); + LogUtils.e("getMyInfo", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getMyInfo", t.getMessage()); } }); } @@ -2167,13 +2449,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getUserTagList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getUserTagList", t.getMessage()); } }); } @@ -2186,13 +2474,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getLikeList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getLikeList", t.getMessage()); } }); } @@ -2205,13 +2499,19 @@ public class RetrofitClient { BaseModel listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getAlbumDetail", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getAlbumDetail", t.getMessage()); } }); } @@ -2224,14 +2524,19 @@ public class RetrofitClient { BaseModel listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); - + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getSubsidy", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getSubsidy", t.getMessage()); } }); } @@ -2248,13 +2553,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getPersonaltyList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getPersonaltyList", t.getMessage()); } }); } @@ -2267,13 +2578,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showShort(listBaseModel.getMsg()); } + } else { + LogUtils.e("getDecorateList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getDecorateList", t.getMessage()); } }); } @@ -2294,12 +2611,7 @@ public class RetrofitClient { if (roomInfoRespBaseModel.getCode() == 1) { observer.onNext(roomInfoRespBaseModel.getData()); } else if (roomInfoRespBaseModel.getCode() == 301) { - ToastUtils.showShort(roomInfoRespBaseModel.getMsg()); - try { - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(roomInfoRespBaseModel.getMsg()); } else if (roomInfoRespBaseModel.getCode() == 0) { ToastUtils.showShort(roomInfoRespBaseModel.getMsg()); if (joinRoomLoadListener != null) { @@ -2310,6 +2622,12 @@ public class RetrofitClient { } else { MessageListenerSingleton.getInstance().quitGroup(roomId); } + }else { + ToastUtils.showLong("进入房间错误",response.code()); + if (joinRoomLoadListener != null) { + joinRoomLoadListener.onJoinRoomLoad("网络异常"); + } + LogUtils.e("roomGetIn", response.message()); } } @@ -2335,10 +2653,10 @@ public class RetrofitClient { BaseModel beforeJoinRoomCheckBeanBaseModel = response.body(); if (beforeJoinRoomCheckBeanBaseModel.getCode() == 202) { observer.onNext(beforeJoinRoomCheckBeanBaseModel.getData()); - }else { + } else { observer.onNext(new BeforeJoinRoomCheckBean()); } - }else { + } else { if (joinRoomLoadListener != null) { ToastUtils.showLong("网络异常"); joinRoomLoadListener.onJoinRoomLoad("网络异常"); @@ -2352,6 +2670,7 @@ public class RetrofitClient { ToastUtils.showLong("网络异常"); joinRoomLoadListener.onJoinRoomLoad("网络异常"); } + LogUtils.e("beforeJoinRoomCheck", t.toString()); } }); } @@ -2366,13 +2685,19 @@ public class RetrofitClient { BaseModel stringBaseModel = response.body(); if (stringBaseModel.getCode() == 1) { observer.onNext(stringBaseModel.getData()); + } else if (stringBaseModel.getCode() == 301) { + setCode301(stringBaseModel.getMsg()); + } else if (stringBaseModel.getCode() == 0) { + ToastUtils.showLong(stringBaseModel.getMsg()); } + } else { + LogUtils.e("taskJumpRoomId", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("taskJumpRoomId", t.toString()); } }); } @@ -2386,13 +2711,19 @@ public class RetrofitClient { BaseModel stringBaseModel = response.body(); if (stringBaseModel.getCode() == 1) { observer.onNext(stringBaseModel.getData()); + } else if (stringBaseModel.getCode() == 301) { + setCode301(stringBaseModel.getMsg()); + } else if (stringBaseModel.getCode() == 0) { + ToastUtils.showLong(stringBaseModel.getMsg()); } + } else { + LogUtils.e("updatePassword", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("updatePassword", t.toString()); } }); } @@ -2405,13 +2736,19 @@ public class RetrofitClient { BaseModel> listBaseModel = response.body(); if (listBaseModel.getCode() == 1) { observer.onNext(listBaseModel.getData()); + } else if (listBaseModel.getCode() == 301) { + setCode301(listBaseModel.getMsg()); + } else if (listBaseModel.getCode() == 0) { + ToastUtils.showLong(listBaseModel.getMsg()); } + } else { + LogUtils.e("getMyFoot", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getMyFoot", t.toString()); } }); } @@ -2433,7 +2770,7 @@ public class RetrofitClient { @Override public void onFailure(Call>> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("myCpRoom", t.toString()); } }); } @@ -2447,14 +2784,9 @@ public class RetrofitClient { if (stringBaseModel.getCode() == 1) { observer.onNext(""); } else if (stringBaseModel.getCode() == 0) { - com.hjq.toast.ToastUtils.show(stringBaseModel.getMsg()); + ToastUtils.showLong(stringBaseModel.getMsg()); } else if (stringBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(stringBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(stringBaseModel.getMsg()); } } else { LogUtils.e("check_create_room", response.message()); @@ -2504,13 +2836,18 @@ public class RetrofitClient { observer.onNext(roomOnlineBaseModel.getData()); } else if (roomOnlineBaseModel.getCode() == 0) { ToastUtils.showLong(roomOnlineBaseModel.getMsg()); + } else if (roomOnlineBaseModel.getCode() == 301) { + setCode301(roomOnlineBaseModel.getMsg()); } + } else { + ToastUtils.showLong("房间在线异常", response.code()); + LogUtils.e("房间在线人数", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getRoomOnline", t.toString()); } }); } @@ -2527,19 +2864,17 @@ public class RetrofitClient { observer.onNext(new ActivitiesPermission()); ToastUtils.showShort(activitiesPermissionBaseModel.getMsg()); } else if (activitiesPermissionBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(activitiesPermissionBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(activitiesPermissionBaseModel.getMsg()); } + } else { + ToastUtils.showLong("活动权限异常", response.code()); + LogUtils.e("活动权限", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("activitiesPermission", t.toString()); } }); } @@ -2560,13 +2895,11 @@ public class RetrofitClient { } else if (indexRecommendRoomBaseModel.getCode() == 0) { ToastUtils.showShort(indexRecommendRoomBaseModel.getMsg()); } else if (indexRecommendRoomBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(indexRecommendRoomBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(indexRecommendRoomBaseModel.getMsg()); } + } else { + ToastUtils.showLong("首页房间推荐异常", response.code()); + LogUtils.e("首页房间推荐", response.message()); } } @@ -2586,13 +2919,20 @@ public class RetrofitClient { BaseModel walletBeanBaseModel = response.body(); if (walletBeanBaseModel.getCode() == 1) { observer.onNext(walletBeanBaseModel.getData()); + } else if (walletBeanBaseModel.getCode() == 0) { + observer.onNext(new WalletBean()); + } else if (walletBeanBaseModel.getCode() == 301) { + setCode301(walletBeanBaseModel.getMsg()); } + } else { + ToastUtils.showLong("钱包异常", response.code()); + LogUtils.e("钱包", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("钱包", t.fillInStackTrace()); } }); } @@ -2607,13 +2947,10 @@ public class RetrofitClient { observer.onNext(tasksMessage.getData()); } else if (tasksMessage.getCode() == 0) { } else if (tasksMessage.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(tasksMessage.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(tasksMessage.getMsg()); } + } else { + LogUtils.e("任务个数", response.message()); } } @@ -2624,9 +2961,9 @@ public class RetrofitClient { }); } - public void redPacketCreate(int type, String password, int coin_type, String - total_amount, String total_count, String conditions, String countdown, String - room_id, String remark, BaseObserver observer) { + public void redPacketCreate(int type, String password, int coin_type, + String total_amount, String total_count, String conditions, + String countdown, String room_id, String remark, BaseObserver observer) { sApiServer.redPacketCreate(type, password, coin_type, total_amount, total_count, conditions, countdown, room_id, remark).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { @@ -2639,22 +2976,20 @@ public class RetrofitClient { } else if (redPacketBeanBaseModel.getCode() == 0) { ToastUtils.showShort(redPacketBeanBaseModel.getMsg()); } else if (redPacketBeanBaseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(redPacketBeanBaseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(redPacketBeanBaseModel.getMsg()); } } catch (IOException e) { e.printStackTrace(); } + } else { + ToastUtils.showShort("创建红包失败", response.code()); + LogUtils.e("创建红包", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("创建红包", t.fillInStackTrace()); } }); @@ -2687,8 +3022,7 @@ public class RetrofitClient { // }); } - public void appPay(String user_id, String money, String coin, String type, String - type_params, String type_id, String nobility_id, BaseObserver observer) { + public void appPay(String user_id, String money, String coin, String type, String type_params, String type_id, String nobility_id, BaseObserver observer) { sApiServer.appPay(user_id, money, coin, type, type_params, type_id, nobility_id).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -2696,15 +3030,20 @@ public class RetrofitClient { BaseModel appPayBaseModel = response.body(); if (appPayBaseModel.getCode() == 1) { observer.onNext(appPayBaseModel.getData()); - } else { + } else if (appPayBaseModel.getCode() == 301) { + setCode301(appPayBaseModel.getMsg()); + } else if (appPayBaseModel.getCode() == 0) { ToastUtils.showShort(appPayBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取appPay异常", response.code()); + LogUtils.e("appPay", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("appPay", t.getMessage()); } }); } @@ -2717,13 +3056,20 @@ public class RetrofitClient { BaseModel bindTypeBaseModel = response.body(); if (bindTypeBaseModel.getCode() == 1) { observer.onNext(bindTypeBaseModel.getData()); + } else if (bindTypeBaseModel.getCode() == 301) { + setCode301(bindTypeBaseModel.getMsg()); + } else if (bindTypeBaseModel.getCode() == 0) { + ToastUtils.showShort(bindTypeBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取绑定方式异常", response.code()); + LogUtils.e("bindType", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("bindType", t.getMessage()); } }); } @@ -2736,19 +3082,25 @@ public class RetrofitClient { BaseModel walletConfigBaseModel = response.body(); if (walletConfigBaseModel.getCode() == 1) { observer.onNext(walletConfigBaseModel.getData()); + } else if (walletConfigBaseModel.getCode() == 301) { + setCode301(walletConfigBaseModel.getMsg()); + } else if (walletConfigBaseModel.getCode() == 0) { + ToastUtils.showShort(walletConfigBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取钱包配置异常", response.code()); + LogUtils.e("getWalletConfig", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getWalletConfig", t.getMessage()); } }); } - public void bind(String userId, String type, String alipayAccount, String - bank_card_number, String bank_card, String open_bank, BaseObserver observer) { + public void bind(String userId, String type, String alipayAccount, String bank_card_number, String bank_card, String open_bank, BaseObserver observer) { sApiServer.bind(userId, type, alipayAccount, bank_card_number, bank_card, open_bank).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -2757,7 +3109,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("bind", t.getMessage()); } }); } @@ -2770,19 +3122,25 @@ public class RetrofitClient { BaseModel roomApplyListBeanBaseModel = response.body(); if (roomApplyListBeanBaseModel.getCode() == 1) { observer.onNext(roomApplyListBeanBaseModel.getData()); + } else if (roomApplyListBeanBaseModel.getCode() == 301) { + setCode301(roomApplyListBeanBaseModel.getMsg()); + } else if (roomApplyListBeanBaseModel.getCode() == 0) { + ToastUtils.showShort(roomApplyListBeanBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取房间申请列表异常", response.code()); + LogUtils.e("roomApplyListBean", response.code()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("roomApplyListBean", t.getMessage()); } }); } - public void getRoomUserInfo(String room_id, String - user_id, BaseObserver observer) { + public void getRoomUserInfo(String room_id, String user_id, BaseObserver observer) { sApiServer.getRoomUserInfo(room_id, user_id).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -2790,19 +3148,25 @@ public class RetrofitClient { BaseModel userInfoBaseModel = response.body(); if (userInfoBaseModel.getCode() == 1) { observer.onNext(userInfoBaseModel.getData()); + } else if (userInfoBaseModel.getCode() == 301) { + setCode301(userInfoBaseModel.getMsg()); + } else if (userInfoBaseModel.getCode() == 0) { + ToastUtils.showShort(userInfoBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取用户信息异常", response.code()); + LogUtils.e("getRoomUserInfo", response.code()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getRoomUserInfo", t.getMessage()); } }); } - public void songList(String room_id, String - page, BaseObserver> observer) { + public void songList(String room_id, String page, BaseObserver> observer) { sApiServer.songList(room_id, page).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -2810,20 +3174,26 @@ public class RetrofitClient { BaseModel> musicSongBaseModel = response.body(); if (musicSongBaseModel.getCode() == 1) { observer.onNext(musicSongBaseModel.getData()); + } else if (musicSongBaseModel.getCode() == 301) { + setCode301(musicSongBaseModel.getMsg()); + } else if (musicSongBaseModel.getCode() == 0) { + ToastUtils.showShort(musicSongBaseModel.getMsg()); } + } else { + ToastUtils.showShort("获取歌曲列表异常", response.code()); + LogUtils.e("songList", response.code()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("songList", t.getMessage()); } }); } // TODO: 2025/3/15 获取主持人列表 - public void getHostList(String roomId, String - type, BaseObserver> observer) { + public void getHostList(String roomId, String type, BaseObserver> observer) { sApiServer.getHostList(roomId, type).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -2831,20 +3201,27 @@ public class RetrofitClient { BaseModel> hostBeanBaseModel = response.body(); if (hostBeanBaseModel.getCode() == 1) { observer.onNext(hostBeanBaseModel.getData()); + } else if (hostBeanBaseModel.getCode() == 301) { + setCode301(hostBeanBaseModel.getMsg()); + } else if (hostBeanBaseModel.getCode() == 0) { + ToastUtils.showShort(hostBeanBaseModel.getMsg()); + } + } else { + ToastUtils.showShort("获取主持人列表异常", response.code()); + LogUtils.e("getHostList", response.code()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getHostList", t.getMessage()); } }); } - public void getSearch(String keyWord, String - type, BaseObserver> observer) { + public void getSearch(String keyWord, String type, BaseObserver> observer) { sApiServer.getSearch(keyWord, type).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -2852,13 +3229,20 @@ public class RetrofitClient { BaseModel> roomSearchRespBaseModel = response.body(); if (roomSearchRespBaseModel.getCode() == 1) { observer.onNext(roomSearchRespBaseModel.getData()); + } else if (roomSearchRespBaseModel.getCode() == 301) { + setCode301(roomSearchRespBaseModel.getMsg()); + } else if (roomSearchRespBaseModel.getCode() == 0) { + ToastUtils.showShort(roomSearchRespBaseModel.getMsg()); } + } else { + ToastUtils.showShort("搜索结果异常", response.code()); + LogUtils.e("getSearch", response.code()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getSearch", t.getMessage()); } }); } @@ -2873,14 +3257,23 @@ public class RetrofitClient { if (searchAllBaseModel.getCode() == 1) { if (searchAllBaseModel.getData() != null) { observer.onNext(searchAllBaseModel.getData()); + } else { + ToastUtils.showShort("搜索结果为空"); } + } else if (searchAllBaseModel.getCode() == 0) { + ToastUtils.showShort(searchAllBaseModel.getMsg()); + } else if (searchAllBaseModel.getCode() == 301) { + setCode301(searchAllBaseModel.getMsg()); } + } else { + ToastUtils.showShort("搜索结果异常", response.code()); + LogUtils.e("getSearchAll", response.code()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getSearchAll", t.getMessage()); } }); } @@ -2893,20 +3286,25 @@ public class RetrofitClient { BaseModel roomBgBeanBaseModel = response.body(); if (roomBgBeanBaseModel.getCode() == 1) { observer.onNext(roomBgBeanBaseModel.getData()); + } else if (roomBgBeanBaseModel.getCode() == 0) { + ToastUtils.showShort(roomBgBeanBaseModel.getMsg()); + } else if (roomBgBeanBaseModel.getCode() == 301) { + setCode301(roomBgBeanBaseModel.getMsg()); } - + } else { + ToastUtils.showShort("房间背景异常", response.code()); + LogUtils.e("getBackgroundList", response.code()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getBackgroundList", t.getMessage()); } }); } - public void getCharmList(String roomId, String stime, String etime, String - p, BaseObserver observer) { + public void getCharmList(String roomId, String stime, String etime, String p, BaseObserver observer) { sApiServer.getCharmList(roomId, stime, etime, p).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -2914,13 +3312,20 @@ public class RetrofitClient { BaseModel roomDetailsBaseModel = response.body(); if (roomDetailsBaseModel.getCode() == 1) { observer.onNext(roomDetailsBaseModel.getData()); + } else if (roomDetailsBaseModel.getCode() == 0) { + ToastUtils.showShort(roomDetailsBaseModel.getMsg()); + } else if (roomDetailsBaseModel.getCode() == 301) { + setCode301(roomDetailsBaseModel.getMsg()); } + } else { + ToastUtils.showShort("房间流水异常", response.code()); + LogUtils.e("getCharmList", response.code()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("getCharmList", t.getMessage()); } }); } @@ -2987,31 +3392,31 @@ public class RetrofitClient { // }); .enqueue(new Callback>() { - @Override - public void onResponse(Call> call, Response> response) { - if (response.code() == 200) { - BaseModel baseModel = response.body(); + @Override + public void onResponse(Call> call, Response> response) { + if (response.code() == 200) { + BaseModel baseModel = response.body(); - if (baseModel.getCode() == 1) { - observer.onNext( new RoomAuction.AuctionListBean()); - }else if (baseModel.getCode() == 0) { - ToastUtils.showShort(baseModel.getMsg()); - }else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); + if (baseModel.getCode() == 1) { + observer.onNext(new RoomAuction.AuctionListBean()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + try { + ToastUtils.showShort(baseModel.getMsg()); + CommonAppContext.getInstance().clearLoginInfo(); + } catch (ClassNotFoundException e) { + throw new RuntimeException(e); + } + } } } - } - } - @Override - public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); - } - }); + @Override + public void onFailure(Call> call, Throwable t) { + t.printStackTrace(); + } + }); } public void auctionDelay(String auctionId, BaseObserver observer) { @@ -3037,21 +3442,19 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { - + ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showShort("红包列表失败", response.code()); + LogUtils.e("roomRedPackets", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("roomRedPackets", t.toString()); } }); } @@ -3067,19 +3470,17 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showShort("红包详情失败", response.code()); + LogUtils.e("redPacketDetail", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("redPacketDetail", t.toString()); } }); } @@ -3100,18 +3501,17 @@ public class RetrofitClient { observer.onNext(baseModel.getData()); } } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showShort("抢红包失败", response.code()); + LogUtils.e("grab", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("grab", t.fillInStackTrace()); } }); } @@ -3129,7 +3529,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("onFailure", t.fillInStackTrace()); } }); } @@ -3143,7 +3543,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("onFailure", t.fillInStackTrace()); } }); } @@ -3157,14 +3557,13 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("uploadBgImage", t.fillInStackTrace()); } }); } - public void editRoom(String room_id, String room_name, String room_cover, String - room_intro, String room_background, BaseObserver observer) { + public void editRoom(String room_id, String room_name, String room_cover, String room_intro, String room_background, BaseObserver observer) { sApiServer.editRoom(room_id, room_name, room_cover, room_intro, room_background).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3173,13 +3572,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("editRoom", t.fillInStackTrace()); } }); } - public void setPresidedRatio(String room_id, String user_id, String - ratio, BaseObserver observer) { + public void setPresidedRatio(String room_id, String user_id, String ratio, BaseObserver observer) { sApiServer.setPresidedRatio(room_id, user_id, ratio).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3188,14 +3586,13 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("setPresidedRatio", t.fillInStackTrace()); } }); } - public void postHostAdd(String roomId, String userId, String type, String - is_add, BaseObserver observer) { + public void postHostAdd(String roomId, String userId, String type, String is_add, BaseObserver observer) { sApiServer.getPresidedRatio(roomId, userId, type, is_add).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3204,13 +3601,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("postHostAdd", t.fillInStackTrace()); } }); } - public void reward_zone(String id, String gift_id, String num, String - is_pack, BaseObserver observer) { + public void reward_zone(String id, String gift_id, String num, String is_pack, BaseObserver observer) { sApiServer.reward_zone(id, gift_id, num, is_pack).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3219,7 +3615,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("reward_zone", t.fillInStackTrace()); } }); } @@ -3233,7 +3629,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("upSong", t.fillInStackTrace()); } }); } @@ -3247,7 +3643,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("clearApply", t.fillInStackTrace()); } }); } @@ -3261,6 +3657,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { + LogUtils.e("agreePit", t.fillInStackTrace()); } }); } @@ -3274,6 +3671,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { + LogUtils.e("refusePit", t.fillInStackTrace()); } }); } @@ -3288,13 +3686,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("helpApply", t.fillInStackTrace()); } }); } - public void setRoomApply(String room_id, String gift_id, String - gift_price, BaseObserver observer) { + public void setRoomApply(String room_id, String gift_id, String gift_price, BaseObserver observer) { sApiServer.setRoomApply(room_id, gift_id, gift_price).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3303,13 +3700,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("setRoomApply", t.fillInStackTrace()); } }); } - public void giveGift(String user_id, String gid, String num, String to_uid, String - gift_type, BaseObserver observer) { + public void giveGift(String user_id, String gid, String num, String to_uid, String gift_type, BaseObserver observer) { sApiServer.giveGift(user_id, gid, num, to_uid, gift_type).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3318,13 +3714,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("giveGift", t.fillInStackTrace()); } }); } - public void roomGift(String room_id, String gift_id, String gift_num, String to_uid, String - type, String pit_number, String heart_id, BaseObserver observer) { + public void roomGift(String room_id, String gift_id, String gift_num, String to_uid, String type, String pit_number, String heart_id, BaseObserver observer) { sApiServer.roomGift(room_id, gift_id, gift_num, to_uid, type, pit_number, heart_id).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3345,25 +3740,22 @@ public class RetrofitClient { } else if (data.getCode() == 0) { ToastUtils.showShort(data.getMsg()); } else if (data.getCode() == 301) { - try { - ToastUtils.showShort(data.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(data.getMsg()); } + } else { + ToastUtils.showLong("网络异常", response.code()); + LogUtils.e("roomGift: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("roomGift", t.fillInStackTrace()); } }); } - public void cpGiveGift(String user_id, String gift_id, String - room_id, BaseObserver observer) { + public void cpGiveGift(String user_id, String gift_id, String room_id, BaseObserver observer) { sApiServer.cpGiveGift(user_id, gift_id, room_id).enqueue(new Callback>() { @Override @@ -3381,13 +3773,11 @@ public class RetrofitClient { } else if (data.getCode() == 0) { ToastUtils.showShort(data.getMsg()); } else if (data.getCode() == 301) { - try { - ToastUtils.showShort(data.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(data.getMsg()); } + } else { + ToastUtils.showLong("网络异常", response.code()); + LogUtils.e("cpGiveGift: " + response.message()); } } @@ -3408,13 +3798,18 @@ public class RetrofitClient { observer.onNext(data.getData()); } else if (data.getCode() == 0) { ToastUtils.showShort(data.getMsg()); + } else { + setCode301(data.getMsg()); } + } else { + ToastUtils.showLong("网络异常", response.code()); + LogUtils.e("getDayDropGift: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getDayDropGift", t.fillInStackTrace()); } }); } @@ -3427,13 +3822,20 @@ public class RetrofitClient { BaseModel data = response.body(); if (data.getCode() == 1) { observer.onNext(data.getData()); + } else if (data.getCode() == 0) { + ToastUtils.showShort(data.getMsg()); + } else if (data.getCode() == 301) { + setCode301(data.getMsg()); } + } else { + ToastUtils.showLong("网络异常", response.code()); + LogUtils.e("firstChargeGift: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("firstChargeGift", t.fillInStackTrace()); } }); } @@ -3446,13 +3848,20 @@ public class RetrofitClient { BaseModel data = response.body(); if (data.getCode() == 1) { observer.onNext(data.getData()); + } else if (data.getCode() == 0) { + ToastUtils.showShort(data.getMsg()); + } else if (data.getCode() == 301) { + setCode301(data.getMsg()); } + } else { + ToastUtils.showLong("网络异常", response.code()); + LogUtils.e("getNewChargeGift: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getNewChargeGift", t.fillInStackTrace()); } }); } @@ -3466,7 +3875,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("applyPit", t.fillInStackTrace()); } }); } @@ -3478,20 +3887,25 @@ public class RetrofitClient { if (response.code() == 200) { BaseModel baseModel = response.body(); if (baseModel.getCode() != 1) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); + if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } } + } else { + ToastUtils.showLong("网络异常"); + LogUtils.e("startFriend: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("startFriend", t.toString()); } }); } - public void delay(String friend_id, String room_id, String - delay_times, BaseObserver observer) { + public void delay(String friend_id, String room_id, String delay_times, BaseObserver observer) { sApiServer.delay(friend_id, room_id, delay_times).enqueue(new Callback>() { @Override @@ -3499,64 +3913,79 @@ public class RetrofitClient { if (response.code() == 200) { BaseModel baseModel = response.body(); if (baseModel.getCode() != 1) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); + if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } } + } else { + ToastUtils.showLong("网络异常"); + LogUtils.e("delay: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("delay", t.toString()); } }); } - public void endFriend(String friend_id, String - room_id, BaseObserver observer) { + public void endFriend(String friend_id, String room_id, BaseObserver observer) { sApiServer.endFriend(friend_id, room_id).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel baseModel = response.body(); - if (baseModel.getCode() != 1) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); } - observer.onNext(baseModel.getData()); + } else { + ToastUtils.showLong("网络异常"); + LogUtils.e("endFriend: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("endFriend", t.toString()); } }); } - public void createRelation(String room_id, String friend_id, String user1_id, String - user2_id, String relation_id, BaseObserver observer) { + public void createRelation(String room_id, String friend_id, String user1_id, String user2_id, String relation_id, BaseObserver observer) { sApiServer.createRelation(room_id, friend_id, user1_id, user2_id, relation_id).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel baseModel = response.body(); - if (baseModel.getCode() != 1) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { observer.onNext(""); } + } else { + ToastUtils.showLong("网络异常"); + LogUtils.e("createRelation: " + response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("createRelation", t.toString()); } }); } - public void keepXintiao(String roomId) { + public void keepXintiao(String roomId) {//这是心跳，如果服务端返回的是失败，code=0，不进行toast sApiServer.keepXintiao(roomId).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3569,13 +3998,11 @@ public class RetrofitClient { } } else if (tasksMessage.getCode() == 0) { } else if (tasksMessage.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(tasksMessage.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(tasksMessage.getMsg()); } + } else { + ToastUtils.showLong("网络异常"); + LogUtils.e("心跳: " + response.message()); } } @@ -3595,7 +4022,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("setMutePit", t.toString()); } }); } @@ -3609,7 +4036,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("setLockPit", t.toString()); } }); } @@ -3623,7 +4050,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("downPit", t.toString()); } }); } @@ -3637,7 +4064,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("kickOutRoom", t.toString()); } }); } @@ -3651,7 +4078,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("applySong", t.toString()); } }); } @@ -3667,7 +4094,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("agreeSong", t.toString()); } }); } @@ -3682,15 +4109,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showShort("盲盒转盘失败，", response.code()); + LogUtils.e("盲盒转盘", response.message()); } } @@ -3710,7 +4135,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("endSong", t.toString()); } }); } @@ -3721,17 +4146,22 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel baseModel = response.body(); - if (baseModel.getCode() != 1) { - observer.onNext(null); - } else { + if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("房间信息失败，", response.code()); + LogUtils.e("postRoomInfo", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("postRoomInfo", t.toString()); } }); } @@ -3744,19 +4174,25 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("魅力榜失败，", response.code()); + LogUtils.e("getCharmRank", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("getCharmRank", t.toString()); } }); } - public void roomRelationList(String - type, BaseObserver> observer) { + public void roomRelationList(String type, BaseObserver> observer) { sApiServer.roomRelationList(type).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -3764,19 +4200,25 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("房间关系列表失败，", response.code()); + LogUtils.e("roomRelationList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("roomRelationList", t.toString()); } }); } - public void roomAuctionList(String - auction_id, BaseObserver> observer) { + public void roomAuctionList(String auction_id, BaseObserver> observer) { sApiServer.roomAuctionList(auction_id).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -3784,13 +4226,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("竞拍列表失败，", response.code()); + LogUtils.e("roomAuctionList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("roomAuctionList", t.toString()); } }); } @@ -3804,13 +4253,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("changeSong", t.toString()); } }); } - public void hostUserPit(String room_id, String pit_number, String user_id, String - type, BaseObserver observer) { + public void hostUserPit(String room_id, String pit_number, String user_id, String type, BaseObserver observer) { sApiServer.hostUserPit(room_id, pit_number, user_id, type).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -3819,7 +4267,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("hostUserPit", t.toString()); } }); } @@ -3831,15 +4279,22 @@ public class RetrofitClient { if (response.code() == 200) { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("转币错误", response.code()); + LogUtils.e("giveCoin", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("giveCoin", t.toString()); } }); } @@ -3852,13 +4307,20 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("关系列表错误", response.code()); + LogUtils.e("relationCard", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("relationCard", t.toString()); } }); } @@ -3872,7 +4334,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("topRelationCard", t.toString()); } }); } @@ -3886,7 +4348,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("deleteRelationCard", t.toString()); } }); } @@ -3898,18 +4360,22 @@ public class RetrofitClient { sApiServer.quitRoom(room_id, user_id).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { - observer.onNext(null); + if (response.code() == 200) { + observer.onNext(null); + } else { + ToastUtils.showShort("请求错误：" + response.code()); + LogUtils.e("quitRoom", response.message()); + } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("quitRoom", t.toString()); } }); } - public void getFriendListMore(String user_id, String - relation_id, BaseObserver> observer) { + public void getFriendListMore(String user_id, String relation_id, BaseObserver> observer) { sApiServer.getFriendListMore(user_id, relation_id).enqueue(new Callback>>() { @Override @@ -3919,15 +4385,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showShort("请求错误：" + response.code()); + LogUtils.e("getFriendListMore", response.message()); } } @@ -3938,8 +4402,7 @@ public class RetrofitClient { }); } - public void checkTxt(String room_name, String room_cover, String - room_intro, BaseObserver observer) { + public void checkTxt(String room_name, String room_cover, String room_intro, BaseObserver observer) { sApiServer.checkTxt(room_name, room_cover, room_intro).enqueue(new Callback() { @Override public void onResponse(Call call, Response response) { @@ -3949,18 +4412,23 @@ public class RetrofitClient { BaseModel baseModel = GsonUtils.fromJson(json, BaseModel.class); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); } } catch (IOException e) { e.printStackTrace(); } + } else { + ToastUtils.showShort("请求错误：" + response.code()); + LogUtils.e("checkTxt", response.message()); } } @Override public void onFailure(Call call, Throwable t) { - t.printStackTrace(); + LogUtils.e("checkTxt", t.toString()); } }); } @@ -3974,7 +4442,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("setUserDecorate", t.toString()); } }); } @@ -3985,19 +4453,20 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { observer.onNext("取消成功"); + } else { + ToastUtils.showShort("取消失败"); + LogUtils.e("cancelUserDecorate", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("cancelUserDecorate", t.toString()); } }); } - public void publishZone(String images, String content, String topic_id, String - room_id, String ip, BaseObserver observer) { - + public void publishZone(String images, String content, String topic_id, String room_id, String ip, BaseObserver observer) { sApiServer.publishZone(images, content, topic_id, room_id, ip).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4006,7 +4475,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("publishZone", t.toString()); } }); } @@ -4020,7 +4489,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("likeZone", t.toString()); } }); } @@ -4034,7 +4503,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("deleteComment", t.toString()); } }); @@ -4050,13 +4519,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("deleteZone", t.toString()); } }); } - public void commentZone(String id, String content, String pid, String - reply_to, BaseObserver observer) { + public void commentZone(String id, String content, String pid, String reply_to, BaseObserver observer) { sApiServer.commentZone(id, content, pid, reply_to).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4065,7 +4533,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("commentZone", t.toString()); } }); } @@ -4080,15 +4548,13 @@ public class RetrofitClient { if (body.getCode() == 1) { observer.onNext(body.getData()); } else if (body.getCode() == 301) { - try { - ToastUtils.showShort(body.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(body.getMsg()); } else { ToastUtils.showShort(body.getMsg()); } + } else { + ToastUtils.showShort("网络异常", response.code()); + LogUtils.e("getFriendList", response.message()); } } @@ -4109,7 +4575,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("clearLoginInfo", t.toString()); } }); } @@ -4124,7 +4590,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("cancel", t.toString()); } }); } @@ -4138,13 +4604,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getModifyHideStatus", t.toString()); } }); } - public void getPostData(String new_password, String mobile, String code, String - userId, BaseObserver observer) { + public void getPostData(String new_password, String mobile, String code, String userId, BaseObserver observer) { sApiServer.getPostData(new_password, mobile, code, userId).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4162,13 +4627,12 @@ public class RetrofitClient { throw new RuntimeException(e); } } - ToastUtils.showShort(t.toString()); + LogUtils.e("getPostData", t.toString()); } }); } - public void forgotPassword(String new_password, String mobile, String - sms_code, BaseObserver observer) { + public void forgotPassword(String new_password, String mobile, String sms_code, BaseObserver observer) { sApiServer.forgotPassword(new_password, mobile, sms_code).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4177,13 +4641,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("forgotPassword", t.toString()); } }); } - public void createAlbum(String name, String pwd, String - image, BaseObserver observer) { + public void createAlbum(String name, String pwd, String image, BaseObserver observer) { sApiServer.createAlbum(name, pwd, image).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4192,13 +4655,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("createAlbum", t.toString()); } }); } - public void editAlbum(String album_id, String name, String pwd, String - image, BaseObserver observer) { + public void editAlbum(String album_id, String name, String pwd, String image, BaseObserver observer) { sApiServer.editAlbum(album_id, name, pwd, image).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4207,13 +4669,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("editAlbum", t.toString()); } }); } - public void editUserInfo(int type, String nickname, String birthday, String sex, String - avatar, String images, String profile, String tag_id, BaseObserver observer) { + public void editUserInfo(int type, String nickname, String birthday, String sex, String avatar, String images, String profile, String tag_id, BaseObserver observer) { if (type == 1) { sApiServer.editUserInfo(nickname, birthday, sex, avatar, images, profile, tag_id).enqueue(new Callback>() { @@ -4224,7 +4685,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("editUserInfo", t.toString()); } }); } else { @@ -4237,7 +4698,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("editUserInfo", t.toString()); } }); } @@ -4252,7 +4713,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("userGuanz", t.toString()); } }); } @@ -4266,7 +4727,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("followRoom", t.toString()); } }); } @@ -4280,7 +4741,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("acceptPk", t.toString()); } }); } @@ -4295,26 +4756,34 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); - t.printStackTrace(); + LogUtils.e("clearUserCharm", t.toString()); } }); } - public void userOnlineStatus(String user_id, String - roomId, BaseObserver> observer) { + public void userOnlineStatus(String user_id, String roomId, BaseObserver> observer) { sApiServer.userOnlineStatus(user_id, roomId).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { if (response.code() == 200) { BaseModel> baseModel = response.body(); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + observer.onNext(new ArrayList<>()); + } + } else { + ToastUtils.showLong("网络异常，请稍后重试", response.code()); + LogUtils.e("userOnlineStatus", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("userOnlineStatus", t.toString()); } }); } @@ -4326,13 +4795,22 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel baseModel = response.body(); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); + } + } else { + ToastUtils.showLong("网络异常，请稍后重试", response.code()); + LogUtils.e("postRoomSwToken", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("postRoomSwToken", t.toString()); } }); } @@ -4346,13 +4824,12 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("removeBlackList", t.toString()); } }); } - public void upAddAlbum(String album_id, String images, String - content, BaseObserver observer) { + public void upAddAlbum(String album_id, String images, String content, BaseObserver observer) { sApiServer.upAddAlbum(album_id, images, content).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4361,7 +4838,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("upAddAlbum", t.toString()); } }); } @@ -4375,7 +4852,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("moveAlbum", t.toString()); } }); } @@ -4404,7 +4881,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("deleteAlbum", t.toString()); } }); } else { @@ -4416,7 +4893,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("deleteAlbum", t.toString()); } }); } @@ -4432,7 +4909,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("likeAlbum", t.toString()); } }); } @@ -4446,7 +4923,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("getRealNameResult", t.toString()); } }); } @@ -4460,7 +4937,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("changeRoom", t.toString()); } }); } @@ -4474,39 +4951,34 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - ToastUtils.showShort(t.toString()); + LogUtils.e("changeRoomType", t.toString()); } }); } - public void onNextRetu - (Response> response, BaseObserver observer) { + public void onNextRetu(Response> response, BaseObserver observer) { if (response.code() == 200) { BaseModel string = response.body(); if (string != null) { int code = string.getCode(); if (code == 1) { observer.onNext(string.getMsg() != null ? string.getMsg() : ""); - } else if (code == 301) { - try { -// com.blankj.utilcode.util.ToastUtils.showShort("提示当前账号已在别的地方登陆，如果不是本人操作请修改密码"); - ToastUtils.showShort(string.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(string.getMsg()); } else { ToastUtils.showShort(string.getMsg()); } + } else { + ToastUtils.showLong("数据错误"); } - + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("请求错误", response.message()); } } /// 获取活动礼物列表 - public void getBoxGiftList(String giftBagId, String - roomId, BaseObserver observer) { + public void getBoxGiftList(String giftBagId, String roomId, BaseObserver observer) { sApiServer.getBoxGiftList(giftBagId, roomId).enqueue(new Callback>() { @Override public void onResponse(Call> call, Response> response) { @@ -4514,15 +4986,22 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); - } else { - observer.onNext(null); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("请求错误", response.message()); } + } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getBoxGiftList", t.fillInStackTrace()); } }); } @@ -4534,13 +5013,22 @@ public class RetrofitClient { public void onResponse(Call> call, Response> response) { if (response.code() == 200) { BaseModel baseModel = response.body(); - observer.onNext(baseModel.getData()); + if (baseModel.getCode() == 1) { + observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showLong(baseModel.getMsg()); + } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("请求错误", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getBoxGiftListXLH", t.fillInStackTrace()); } }); } @@ -4555,21 +5043,19 @@ public class RetrofitClient { if (code == 1) { observer.onNext("成功"); } else if (code == 301) { - try { - ToastUtils.showShort(response.body().getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - LogUtils.e(e.toString()); - } - } else { + setCode301(response.body().getMsg()); + } else if (code == 0) { observer.onNext("失败"); } + } else { + ToastUtils.showLong("请求错误", response.code()); + LogUtils.e("请求错误", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - observer.onNext("失败"); + LogUtils.e("postSendAppLog", t.fillInStackTrace()); } }); } @@ -4586,17 +5072,22 @@ public class RetrofitClient { if (baseModel != null && baseModel.getData() != null) { observer.onNext(baseModel.getData()); } + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { - observer.onNext(null); + observer.onNext(new ArrayList<>()); ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("巡乐会抽奖错误", response.code()); + LogUtils.e("巡乐会抽奖错误", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("xlhChou", t.fillInStackTrace()); } }); @@ -4612,22 +5103,26 @@ public class RetrofitClient { BaseModel baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } else { - observer.onNext(null); + observer.onNext(new BlindReslutBean()); ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("抽奖错误", response.code()); + LogUtils.e("drawGiftList", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("drawGiftList", t.fillInStackTrace()); } }); } - public void getMyRecord(String giftBagId, String page, String - pageSize, BaseObserver> observer) { + public void getMyRecord(String giftBagId, String page, String pageSize, BaseObserver> observer) { sApiServer.getMyRecord(giftBagId, page, pageSize).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -4635,13 +5130,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("我的抽奖记录错误", response.code()); + LogUtils.e("getMyRecord", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getMyRecord", t.fillInStackTrace()); } }); } @@ -4658,13 +5160,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("巡乐会记录错误", response.code()); + LogUtils.e("xlhAllRecord", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("xlhAllRecord", t.fillInStackTrace()); } }); } else { @@ -4676,13 +5185,20 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { LogUtils.e("xlXH_RANking", response.body().toString()); observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("巡乐会记录错误", response.code()); + LogUtils.e("xlXH_RANking", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("xlXH_RANking", t.fillInStackTrace()); } }); } @@ -4697,13 +5213,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("巡乐会记录错误", response.code()); + LogUtils.e("xlhMyRecord", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("xlhMyRecord", t.fillInStackTrace()); } }); } @@ -4717,13 +5240,20 @@ public class RetrofitClient { BaseModel> baseModel = response.body(); if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { + ToastUtils.showShort(baseModel.getMsg()); } + } else { + ToastUtils.showLong("礼物列表错误", response.code()); + LogUtils.e("getAllRecord", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getAllRecord", t.fillInStackTrace()); } }); } @@ -4739,18 +5269,17 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("爵位详情错误", response.code()); + LogUtils.e("getNobilityDetail", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getNobilityDetail", t.fillInStackTrace()); } }); @@ -4767,18 +5296,17 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("爵位列表错误", response.code()); + LogUtils.e("getNobilityList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getNobilityList", t.fillInStackTrace()); } }); } @@ -4794,18 +5322,17 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showShort(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("爵位价格错误", response.code()); + LogUtils.e("getNobilityPrice", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getNobilityPrice", t.fillInStackTrace()); } }); } @@ -4824,8 +5351,7 @@ public class RetrofitClient { }); } - public void roomUserCharmList(String room_id, String - user_id, BaseObserver> observer) { + public void roomUserCharmList(String room_id, String user_id, BaseObserver> observer) { sApiServer.roomUserCharmList(room_id, user_id).enqueue(new Callback>>() { @Override public void onResponse(Call>> call, Response>> response) { @@ -4834,14 +5360,20 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { - observer.onNext(null); + observer.onNext(new ArrayList<>()); + ToastUtils.showLong(baseModel.getMsg()); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("魅力列表错误", response.code()); + LogUtils.e("roomUserCharmList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("roomUserCharmList", t.fillInStackTrace()); } }); } @@ -4856,21 +5388,19 @@ public class RetrofitClient { if (baseModel.getCode() == 1) observer.onNext(baseModel.getData() != null ? baseModel.getData() : new ArrayList()); else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } - - } else { + setCode301(baseModel.getMsg()); + } else if (baseModel.getCode() == 0) { ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("价格列表错误", response.code()); + LogUtils.e("signCoinList", response.message()); } } @Override public void onFailure(Call>> call, Throwable t) { - + LogUtils.e("signCoinList", t.fillInStackTrace()); } }); } @@ -4885,7 +5415,7 @@ public class RetrofitClient { @Override public void onFailure(Call> call, Throwable t) { - + LogUtils.e("signCoin", t.fillInStackTrace()); } }); } @@ -4902,13 +5432,18 @@ public class RetrofitClient { } else if (baseModel.getCode() == 0) { ToastUtils.showLong(baseModel.getMsg()); // observer.onNext(null); + } else if (baseModel.getCode() == 301) { + setCode301(baseModel.getMsg()); } + } else { + ToastUtils.showLong("心动空间错误", response.code()); + LogUtils.e("getCpRoom", response.message()); } } @Override public void onFailure(Call> call, Throwable t) { - t.printStackTrace(); + LogUtils.e("getCpRoom", t.fillInStackTrace()); } }); } @@ -4924,14 +5459,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData() != null ? baseModel.getData() : new MyFamilyBean()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("家族错误", response.code()); + LogUtils.e("myFamily", response.message()); } } @@ -4950,15 +5484,14 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData() != null ? baseModel.getData() : new MyFamilyBean()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { observer.onNext(new MyFamilyBean()); ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("家族错误", response.code()); + LogUtils.e("myJoinFamily", response.message()); } } @@ -4980,14 +5513,13 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData() != null ? baseModel.getData() : new ArrayList()); } else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("家族收益错误", response.code()); + LogUtils.e("familyEarnings", response.message()); } } @@ -5008,15 +5540,14 @@ public class RetrofitClient { if (baseModel.getCode() == 1) observer.onNext(baseModel.getData() != null ? baseModel.getData() : new ArrayList()); else if (baseModel.getCode() == 301) { - try { - ToastUtils.showShort(baseModel.getMsg()); - CommonAppContext.getInstance().clearLoginInfo(); - } catch (ClassNotFoundException e) { - } + setCode301(baseModel.getMsg()); } else { ToastUtils.showLong(baseModel.getMsg()); } + } else { + ToastUtils.showLong("才艺列表错误", response.code()); + LogUtils.e("skillList", response.message()); } } @@ -5126,14 +5657,9 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData() != null ? baseModel.getData() : new ArrayList()); } else if (baseModel.getCode() == 0) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { - try { - CommonAppContext.getInstance().clearLoginInfo(); - ToastUtils.showShort(baseModel.getMsg()); - } catch (ClassNotFoundException e) { - throw new RuntimeException(e); - } + setCode301(baseModel.getMsg()); } } else { LogUtils.e("signIn", response.errorBody()); @@ -5174,7 +5700,7 @@ public class RetrofitClient { if (baseModel.getCode() == 1) { observer.onNext(baseModel.getData()); } else if (baseModel.getCode() == 0) { - com.hjq.toast.ToastUtils.show(baseModel.getMsg()); + ToastUtils.showLong(baseModel.getMsg()); } else if (baseModel.getCode() == 301) { try { CommonAppContext.getInstance().clearLoginInfo(); @@ -5196,5 +5722,13 @@ public class RetrofitClient { } + private void setCode301(String msg) { + try { + CommonAppContext.getInstance().clearLoginInfo(); + ToastUtils.showShort(msg); + } catch (ClassNotFoundException e) { + LogUtils.e("setCode301", e.fillInStackTrace()); + } + } } diff --git a/BaseModule/src/main/java/com/xscm/moduleutil/presenter/RewardGiftPresenter.java b/BaseModule/src/main/java/com/xscm/moduleutil/presenter/RewardGiftPresenter.java index 60962692..4e34aa90 100644 --- a/BaseModule/src/main/java/com/xscm/moduleutil/presenter/RewardGiftPresenter.java +++ b/BaseModule/src/main/java/com/xscm/moduleutil/presenter/RewardGiftPresenter.java @@ -208,9 +208,6 @@ public class RewardGiftPresenter extends BasePresenter if (MvpRef == null) { MvpRef = new WeakReference<>(mView); } - if (giftPackBeans == null) { - return; - } MvpRef.get().giftPack(giftPackBeans); } }); diff --git a/MainModule/src/main/java/com/xscm/modulemain/activity/room/activity/RoomActivity.kt b/MainModule/src/main/java/com/xscm/modulemain/activity/room/activity/RoomActivity.kt index 75996150..a0858f19 100644 --- a/MainModule/src/main/java/com/xscm/modulemain/activity/room/activity/RoomActivity.kt +++ b/MainModule/src/main/java/com/xscm/modulemain/activity/room/activity/RoomActivity.kt @@ -1815,6 +1815,7 @@ class RoomActivity : BaseMvpActivity(), } } } + LogUtils.e("handleMsgType1004", "mRoomInfoResp = $mRoomInfoResp") roomFragment!!.upRoomInfoData(mRoomInfoResp) roomFragment?.handleRoomMessage(messageEvent) roomBtnShowIsHide(fromUserInfo.user_id) diff --git a/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/FriendshipRoomFragment.java b/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/FriendshipRoomFragment.java index 6f4f57ed..cffccae2 100644 --- a/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/FriendshipRoomFragment.java +++ b/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/FriendshipRoomFragment.java @@ -100,14 +100,14 @@ public class FriendshipRoomFragment extends BaseRoomFragment implem view.finishRefreshLoadMore(); } } + @Override + public void onError(Throwable e) { + if (MvpRef==null){ + MvpRef=new WeakReference<>(mView); + } + MvpRef.get().finishRefreshLoadMore(); + } }); } diff --git a/MainModule/src/main/java/com/xscm/modulemain/activity/user/fragment/VocalRangeFragment.java b/MainModule/src/main/java/com/xscm/modulemain/activity/user/fragment/VocalRangeFragment.java index f3f32481..8d3f5ef5 100644 --- a/MainModule/src/main/java/com/xscm/modulemain/activity/user/fragment/VocalRangeFragment.java +++ b/MainModule/src/main/java/com/xscm/modulemain/activity/user/fragment/VocalRangeFragment.java @@ -185,6 +185,10 @@ public class VocalRangeFragment extends BaseMvpFragment { + // 点击跳过按钮时，停止视频并跳转到登录页 + if (videoView != null) { + videoView.stopPlayback(); + } + setEnter(); + }); + + // 设置文本跳过按钮点击事件 + mBinding.btnSkipVideo.setOnClickListener(v -> { + // 点击跳过按钮时，停止视频并跳转到登录页 + if (videoView != null) { + videoView.stopPlayback(); + } + setEnter(); + }); + } + + // 用于更新进度条的方法 + private void startProgressUpdate(MediaPlayer mediaPlayer, int duration) { + // 使用MediaPlayer实例的引用，避免在回调中直接使用可能导致异常的MediaPlayer对象 + final MediaPlayer mp = mediaPlayer; + handler = new Handler(); + handler.postDelayed(new Runnable() { + @Override + public void run() { + try { + // 检查videoView是否还在播放状态，而不是直接检查mediaPlayer + if (videoView != null && videoView.isPlaying()) { + // 使用videoView获取当前播放位置，而不是mediaPlayer + int currentPosition = videoView.getCurrentPosition(); + mBinding.progress.setCurProgress(currentPosition); + + // 继续更新进度 + handler.postDelayed(this, 100); // 每100毫秒更新一次 + } + } catch (Exception e) { + // 捕获任何可能的异常，防止应用崩溃 + LogUtils.e("LaunchPageActivity", "更新进度时出错: " + e.getMessage()); + } + } + }, 100); // 延迟100毫秒开始更新 } private void initLogin() { diff --git a/app/src/main/res/layout/activity_launch_page.xml b/app/src/main/res/layout/activity_launch_page.xml index 76372c38..f9a74373 100644 --- a/app/src/main/res/layout/activity_launch_page.xml +++ b/app/src/main/res/layout/activity_launch_page.xml @@ -27,7 +27,7 @@ android:layout_marginTop="37dp" android:layout_marginRight="15dp" android:background="@drawable/bg_launcher_skip" - android:visibility="invisible"> + android:visibility="visible"> - + + + + + + + + \ No newline at end of file diff --git a/app/src/main/res/raw/app_start.mp4 b/app/src/main/res/raw/app_start.mp4 index da905f49..e408c408 100644 Binary files a/app/src/main/res/raw/app_start.mp4 and b/app/src/main/res/raw/app_start.mp4 differ