Files
midi-android/moduleUtil/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java
2025-10-13 09:22:04 +08:00

3733 lines
151 KiB
Java
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

package com.xscm.moduleutil.http;
//import com.blankj.utilcode.util.LogUtils;
import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.util.Log;
import com.blankj.utilcode.util.GsonUtils;
import com.blankj.utilcode.util.LogUtils;
import com.blankj.utilcode.util.ToastUtils;
import com.franmontiel.persistentcookiejar.ClearableCookieJar;
import com.franmontiel.persistentcookiejar.PersistentCookieJar;
import com.franmontiel.persistentcookiejar.cache.SetCookieCache;
import com.franmontiel.persistentcookiejar.persistence.SharedPrefsCookiePersistor;
import com.google.gson.reflect.TypeToken;
import com.xscm.moduleutil.base.CommonAppContext;
import com.xscm.moduleutil.bean.*;
import com.xscm.moduleutil.bean.blindboxwheel.BlindBoxBean;
import com.xscm.moduleutil.bean.blindboxwheel.BlindReslutBean;
import com.xscm.moduleutil.bean.blindboxwheel.XlhDrawBean;
import com.xscm.moduleutil.bean.room.*;
import com.xscm.moduleutil.bean.zhuangb.ZhuangBanShangChengBean;
import com.xscm.moduleutil.listener.MessageListenerSingleton;
import com.xscm.moduleutil.utils.SpUtil;
import com.xscm.moduleutil.utils.SystemUtils;
import com.xscm.moduleutil.utils.logger.DataLogger;
import com.xscm.moduleutil.utils.logger.DataLoggingInterceptor;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.Type;
import java.net.Proxy;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
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;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import io.reactivex.disposables.Disposable;
import okhttp3.Cache;
import okhttp3.OkHttpClient;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
public class RetrofitClient {
private static RetrofitClient INSTANCE;
private static ApiServer sApiServer;
public static final int DEFAULT_TIME_OUT = 60;
private static OkHttpClient client;
private final Retrofit mRetrofit;
public OkHttpClient getHttpClient() {
return client;
}
File cacheFile = new File(CommonAppContext.getInstance().getCacheDir(), "cache");
Cache cache = new Cache(cacheFile, 1024 * 1024 * 100); // 100MB 的缓存空间
boolean isNetworkAvailable = checkNetworkConnection(); // 实现这个方法来检查网络状态
String cacheControl = isNetworkAvailable ? "max-age=0" : "only-if-cached, max-stale=86400";
private boolean checkNetworkConnection() {
ConnectivityManager connectivityManager = (ConnectivityManager) CommonAppContext.getInstance().getSystemService(Context.CONNECTIVITY_SERVICE);
NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
return activeNetworkInfo != null && activeNetworkInfo.isConnected();
}
private OkHttpClient provideOkHttpClient() {
Map<String, String> headers = Collections.emptyMap();
if (SpUtil.isAgreePolicy()) {
headers = SystemUtils.getSystemParams();
}
SetCookieCache cookieCache = new SetCookieCache();
ClearableCookieJar cookieJar =
new PersistentCookieJar(cookieCache, new SharedPrefsCookiePersistor(CommonAppContext.getInstance()));
try {
X509TrustManager trustAllCert = new X509TrustManager() {
@Override
public void checkClientTrusted(X509Certificate[] chain, String authType) {
}
@Override
public void checkServerTrusted(X509Certificate[] chain, String authType) {
}
@Override
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[]{};
}
};
SSLContext sslContext = null;
sslContext = SSLContext.getInstance("SSL");
sslContext.init(null, new TrustManager[]{trustAllCert}, new SecureRandom());
final OkHttpClient client = new OkHttpClient.Builder()
// .addInterceptor(new LogInterceptor())
.addInterceptor(new DataLoggingInterceptor(new DataLogger()))
.addInterceptor(new AccessTokenInterceptor(headers))
.proxy(Proxy.NO_PROXY)
.sslSocketFactory(sslContext.getSocketFactory(), trustAllCert)
.hostnameVerifier((hostname, session) -> true)
.cookieJar(cookieJar)
.connectTimeout(DEFAULT_TIME_OUT, TimeUnit.SECONDS)
.readTimeout(DEFAULT_TIME_OUT, TimeUnit.SECONDS)
.writeTimeout(DEFAULT_TIME_OUT, TimeUnit.SECONDS)
.build();
RetrofitClient.client = client;
} catch (KeyManagementException | NoSuchAlgorithmException e) {
throw new RuntimeException(e);
}
return client;
}
private Retrofit provideRetrofit(OkHttpClient client) {
return new Retrofit.Builder()
.addConverterFactory(MyConverterFactory.create())/**/
// .addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
// .baseUrl("http://chat.qxmier.com/")
.baseUrl(CommonAppContext.getInstance().getCurrentEnvironment().getServerUrl())
.client(client)
.build();
}
// private static Retrofit mRainRetrofit;
//
// public static Retrofit getRainRetrofit() {
// if (mRainRetrofit == null) {
// synchronized (RetrofitClient.class) {
// mRainRetrofit = new Retrofit.Builder()
// .addConverterFactory(RainConverterFactory.create())
// .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
// .baseUrl(BuildConfig.RAIN_GAME_BASE_URL)
// .client(client)
// .build();
// }
// }
// return mRainRetrofit;
// }
private RetrofitClient() {
mRetrofit = provideRetrofit(provideOkHttpClient());
sApiServer = mRetrofit.create(ApiServer.class);
}
public static RetrofitClient getInstance() {
if (INSTANCE == null) {
synchronized (RetrofitClient.class) {
if (INSTANCE == null) {
INSTANCE = new RetrofitClient();
}
}
}
return INSTANCE;
}
/**
* 检查网络连接状态
* @return true表示网络可用false表示网络不可用
*/
private boolean isNetworkAvailable() {
ConnectivityManager connectivityManager = (ConnectivityManager) CommonAppContext.getInstance()
.getSystemService(Context.CONNECTIVITY_SERVICE);
if (connectivityManager != null) {
NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
return activeNetworkInfo != null && activeNetworkInfo.isConnected();
}
return false;
}
/**
* 网络不可用时的统一处理方法
* @param observer BaseObserver对象
* @param <T> 泛型类型
*/
private <T> void handleNetworkUnavailable(BaseObserver<T> observer) {
ToastUtils.showShort("网络不可用,请检查网络设置");
observer.onError(new Throwable("网络不可用,请检查网络设置"));
}
public <T> T createApiClient(Class<T> apiClientClass) {
return mRetrofit.create(apiClientClass);
}
public void login() {
// login("18473492252", "123456");
// login("18229732986", "123456");
}
public void appUpdate(BaseObserver<AppUpdateModel> observer) {
sApiServer.appUpdate().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void sendCode(String mobile, String event, BaseObserver<Object> observer) {
sApiServer.sendCode(mobile, event).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void mobileView(String mobile, String new_mobile, String sms_code, BaseObserver<String> observer) {
sApiServer.mobileView(mobile, new_mobile, sms_code).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> body = response.body();
observer.onNext(body.getMsg());
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void userRoomBack(String room_id,String type){//用户退出前后台保留数据操作 type:1:切后台 2切前台
sApiServer.userRoomBack(room_id,type).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
}
});
}
public void mobileView2(String new_mobile, String sms_code, BaseObserver<String> observer) {
sApiServer.mobileView2(new_mobile, sms_code).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> body = response.body();
observer.onNext(body.getMsg());
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void login(String mobile, String password, BaseObserver<List<UserBean>> observer) {
sApiServer.login(mobile, password).enqueue(new Callback<BaseModel<List<UserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserBean>>> call, Response<BaseModel<List<UserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<UserBean>> listBaseModel = response.body();
if (listBaseModel != null) {
int code = listBaseModel.getCode();
if (code == 1) {
observer.onNext(listBaseModel.getData());
} else if (code == 301) {
ToastUtils.showShort(listBaseModel.getMsg());
} else {
ToastUtils.showShort(listBaseModel.getMsg());
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<UserBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getRoomHourRanking(String page, String page_limit, BaseObserver<RoomHourBean> observer){
sApiServer.getRoomHourRanking(page, page_limit).enqueue(new Callback<BaseModel<RoomHourBean>>() {
@Override
public void onResponse(Call<BaseModel<RoomHourBean>> call, Response<BaseModel<RoomHourBean>> response) {
if (response.code() == 200) {
BaseModel<RoomHourBean> listBaseModel = response.body();
if (listBaseModel != null) {
if (listBaseModel.getCode()==1) {
observer.onNext(listBaseModel.getData());
}else {
ToastUtils.showShort(listBaseModel.getMsg());
}
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomHourBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void userLogin(String mobile, String password, BaseObserver<List<UserBean>> observer) {
sApiServer.userLogin(mobile, password).enqueue(new Callback<BaseModel<List<UserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserBean>>> call, Response<BaseModel<List<UserBean>>> response) {
// if (response.code()==200){
// BaseModel<List<UserBean>> 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<List<UserBean>> string = response.body();
if (string != null) {
LogUtils.e("@@@", response);
int code = string.getCode();
if (code == 1) {
observer.onNext(string.getData());
} 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());
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<UserBean>>> call, Throwable t) {
LogUtils.e("@@@", t);
}
});
}
public void exchangeCoin(String earnings_num, BaseObserver<String> observer) {
sApiServer.exchangeCoin(earnings_num).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void delfoot(BaseObserver<String> observer) {
sApiServer.delfoot().enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void firstCharge(String uid, BaseObserver<FirstChargeBean> observer) {
sApiServer.firstCharge(uid).enqueue(new Callback<BaseModel<FirstChargeBean>>() {
@Override
public void onResponse(Call<BaseModel<FirstChargeBean>> call, Response<BaseModel<FirstChargeBean>> response) {
if (response.code() == 200) {
BaseModel<FirstChargeBean> baseModel = response.body();
if (baseModel != null) {
observer.onNext(baseModel.getData());
} else {
ToastUtils.showShort("获取数据失败");
}
}
}
@Override
public void onFailure(Call<BaseModel<FirstChargeBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void giftWall(String userId, BaseObserver<GiftUserWallBean> observer) {
sApiServer.giftWall(userId).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void withdrawal(String number, String type, String sms_code, BaseObserver<String> observer) {
sApiServer.withdrawal(number, type, sms_code).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
if (baseModel.getCode() == 1) {
baseModel.setData(baseModel.getMsg());
observer.onNext(baseModel.getData());
} else {
baseModel.setData(baseModel.getMsg());
observer.onNext(baseModel.getData());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("提现失败", t);
}
});
}
public void getMessagetitle(String type, String page, String page_limit, BaseObserver<List<NewsMessageList>> observer) {
sApiServer.getMessagetitle(type, page, page_limit).enqueue(new Callback<BaseModel<List<NewsMessageList>>>() {
@Override
public void onResponse(Call<BaseModel<List<NewsMessageList>>> call, Response<BaseModel<List<NewsMessageList>>> response) {
if (response.code() == 200){
BaseModel<List<NewsMessageList>> baseModel = response.body();
if (baseModel.getCode()==1){
observer.onNext(baseModel.getData());
}else {
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<NewsMessageList>>> call, Throwable t) {
}
});
}
public void withdrawalList(String page, String page_limit, String search_stime, String search_etime, BaseObserver<List<WithdrawalBean>> observer) {
sApiServer.withdrawalList(page,page_limit,search_stime,search_etime).enqueue(new Callback<BaseModel<List<WithdrawalBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<WithdrawalBean>>> call, Response<BaseModel<List<WithdrawalBean>>> response) {
if (response.code() == 200){
BaseModel<List<WithdrawalBean>> baseModel=response.body();
if (baseModel.getCode()==1){
Log.d("withdrawalList---", "onResponse: "+response.body().toString());
observer.onNext(baseModel.getData());
}else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<WithdrawalBean>>> call, Throwable t) {
}
});
// sApiServer.withdrawalList(page, page_limit, search_stime, search_etime).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void bindDetai(String userId, String type,BaseObserver<BindDetail> observer){
sApiServer.bindDetai(userId, type).enqueue(new Callback<BaseModel<BindDetail>>() {
@Override
public void onResponse(Call<BaseModel<BindDetail>> call, Response<BaseModel<BindDetail>> response) {
if (response.code() == 200){
BaseModel<BindDetail> baseModel = response.body();
if (baseModel.getCode()==1){
observer.onNext(baseModel.getData());
}else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<BindDetail>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getRoomRank(String roomId, String type, String time_type, String page, String page_limit, BaseObserver<List<CharmRankingResp>> observer) {
// sApiServer.getRoomRank(roomId, type, time_type, page, page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.getRoomRank(roomId, type, time_type, page, page_limit).enqueue(new Callback<BaseModel<List<CharmRankingResp>>>() {
@Override
public void onResponse(Call<BaseModel<List<CharmRankingResp>>> call, Response<BaseModel<List<CharmRankingResp>>> response) {
if (response.code() == 200) {
BaseModel<List<CharmRankingResp>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<CharmRankingResp>>> call, Throwable t) {
}
});
}
public void wealthRanking(String ranking_type, String type, BaseObserver<PlaceholderBean> observer) {
if (ranking_type.equals("0")) {
sApiServer.roomRanking(type).compose(new DefaultTransformer<>()).subscribe(observer);
} else if (ranking_type.equals("1") || ranking_type.equals("2")) {
sApiServer.wealthRanking(ranking_type, type).compose(new DefaultTransformer<>()).subscribe(observer);
} else if (ranking_type.equals("3")) {
sApiServer.guildRanking().compose(new DefaultTransformer<>()).subscribe(observer);
} else if (ranking_type.equals("4")) {
sApiServer.loveRanking(type).compose(new DefaultTransformer<>()).subscribe(observer);
}
}
public void dailyTasksBoxRecord(BaseObserver<List<GiftBoxRecordBean>> observer) {
sApiServer.dailyTasksBoxRecord().enqueue(new Callback<BaseModel<List<GiftBoxRecordBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBoxRecordBean>>> call, Response<BaseModel<List<GiftBoxRecordBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBoxRecordBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBoxRecordBean>>> call, Throwable t) {
}
});
}
public void packIncome(String page, String page_limit, BaseObserver<List<MyBagDataBean>> observer) {
sApiServer.packIncome(page, page_limit).enqueue(new Callback<BaseModel<List<MyBagDataBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<MyBagDataBean>>> call, Response<BaseModel<List<MyBagDataBean>>> response) {
if (response.code() == 200) {
BaseModel<List<MyBagDataBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MyBagDataBean>>> call, Throwable t) {
}
});
}
public void packOutcome(String page, String page_limit, BaseObserver<List<MyBagDataBean>> observer) {
sApiServer.packOutcome(page, page_limit).enqueue(new Callback<BaseModel<List<MyBagDataBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<MyBagDataBean>>> call, Response<BaseModel<List<MyBagDataBean>>> response) {
if (response.code() == 200) {
BaseModel<List<MyBagDataBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MyBagDataBean>>> call, Throwable t) {
}
});
}
public void giftPack(BaseObserver<List<GiftPackBean>> observer) {
sApiServer.giftPack().enqueue(new Callback<BaseModel<List<GiftPackBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftPackBean>>> call, Response<BaseModel<List<GiftPackBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftPackBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftPackBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getGiftPack(String roomId, String userId, String heart_id, String auction_id, BaseObserver<String> observer) {
sApiServer.getGiftPack(roomId, userId, heart_id, auction_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getMsg());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getGiftPackListCount(BaseObserver<GiftPackListCount> observer) {
sApiServer.getGiftPackListCount().enqueue(new Callback<BaseModel<GiftPackListCount>>() {
@Override
public void onResponse(Call<BaseModel<GiftPackListCount>> call, Response<BaseModel<GiftPackListCount>> response) {
if (response.code() == 200) {
BaseModel<GiftPackListCount> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<GiftPackListCount>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void roomUserReconnect(String roomId) {
sApiServer.roomUserReconnect(roomId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200){
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
}
});
}
public void tasksLihen(BaseObserver<GiftBoxBean> observer) {
sApiServer.tasksLihen().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
String json = null;
try {
json = response.body().string();
Type type = new TypeToken<BaseModel<GiftBoxBean>>() {
}.getType();
BaseModel<GiftBoxBean> baseModel = GsonUtils.fromJson(json, type);
observer.onNext(baseModel.getData());
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void dailyTasksOpenBox(String gift_box_id, BaseObserver<GiftName> observer) {
sApiServer.dailyTasksOpenBox(gift_box_id).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void dailyTasksReceive(String task_id, BaseObserver<String> observer) {
sApiServer.dailyTasksReceive(task_id).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
observer.onNext("任务完成");
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void dailyTasksComplete(String task_id, BaseObserver<RoomSingleton> observer) {
sApiServer.dailyTasksComplete(task_id).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
String json = null;
try {
json = response.body().string();
Type type = new TypeToken<BaseModel<RoomSingleton>>() {
}.getType();
BaseModel<RoomSingleton> baseModel = GsonUtils.fromJson(json, type);
observer.onNext(baseModel.getData());
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void sendHeadine(String content, String money, String roomId, BaseObserver<String> observer) {
sApiServer.sendHeadine(content, money, roomId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void currentHeadline(BaseObserver<HeadlineBean> observer) {
sApiServer.currentHeadline().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void upUserNickname(BaseObserver<String> observer) {
sApiServer.upUserNickname().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData().toString());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getRevenueData(String page, String page_limit, String in_out_type, String start_time, String end_time, String gift_type, BaseObserver<List<RevenueBean>> observer) {
sApiServer.getRevenueData(page, page_limit, in_out_type, start_time, end_time, gift_type).enqueue(new Callback<BaseModel<List<RevenueBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RevenueBean>>> call, Response<BaseModel<List<RevenueBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RevenueBean>> baseModel = response.body();
if (baseModel != null) {
if (baseModel.getData() != null && baseModel.getData().size() > 0) {
observer.onNext(baseModel.getData());
} else {
observer.onNext(new ArrayList<>());
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RevenueBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void realNameInfo(BaseObserver<RealNameBean> observer) {
// sApiServer.realNameInfo().compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.realNameInfo().enqueue(new Callback<BaseModel<RealNameBean>>() {
@Override
public void onResponse(Call<BaseModel<RealNameBean>> call, Response<BaseModel<RealNameBean>> response) {
if (response.code() == 200) {
BaseModel<RealNameBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RealNameBean>> call, Throwable t) {
}
});
}
public void addBlackList(String userId, BaseObserver<String> observer) {
sApiServer.addBlackList(userId).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void upUserPic(String sex, BaseObserver<String> observer) {
sApiServer.upUserPic(sex).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
// .enqueue(new Callback<BaseModel<String>>() {
// @Override
// public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
// if (response.code() == 200){
// BaseModel<String> baseModel = response.body();
// if (baseModel.getCode()==1){
// onNextRetu(response, observer);
// }
// }
// }
//
// @Override
// public void onFailure(Call<BaseModel<String>> call, Throwable t) {
// LogUtils.e("@@@", t);
// }
// });
}
public void sendPk(String roomIda, String createUserId, String roomIdb, BaseObserver<Object> observer) {
sApiServer.sendPk(roomIda, createUserId, roomIdb).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
ToastUtils.showShort(baseModel.getMsg());
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("发起pk失败", t);
}
});
}
public void refusePk(String roomId, String is_pk, BaseObserver<String> observer) {
sApiServer.refusePk(is_pk, roomId).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("不再接受 PK", t);
}
});
}
public void recharge(BaseObserver<List<RechargeBean>> observer) {
// sApiServer.recharge().compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.recharge().enqueue(new Callback<BaseModel<List<RechargeBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RechargeBean>>> call, Response<BaseModel<List<RechargeBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RechargeBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RechargeBean>>> call, Throwable t) {
}
});
}
public void endPk(String pk_id, String type, String user_id, BaseObserver<String> observer) {
sApiServer.endPk(pk_id, type, user_id).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("结束 PK", t);
}
});
}
public void switchAccounts(String loginId, BaseObserver<List<UserBean>> observer) {
// sApiServer.switchAccounts(loginId).compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.switchAccounts(loginId).enqueue(new Callback<BaseModel<List<UserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserBean>>> call, Response<BaseModel<List<UserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<UserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<UserBean>>> call, Throwable t) {
}
});
}
public void searchPkRoom(String roomId, String page, String limit, BaseObserver<List<RoomBean>> observer) {
// sApiServer.searchPkRoom(roomId, page, limit).compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.searchPkRoom(roomId, page, limit).enqueue(new Callback<BaseModel<List<RoomBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomBean>>> call, Response<BaseModel<List<RoomBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomBean>>> call, Throwable t) {
}
});
}
public void userUpdate(String nickname, String birthday, String sex, String avatar, String init_code, String user_id, BaseObserver<UserBean> observer) {
// sApiServer.userUpdate(nickname, birthday, sex, avatar, init_code, user_id).compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.userUpdate(nickname, birthday, sex, avatar, init_code, user_id).enqueue(new Callback<BaseModel<UserBean>>() {
@Override
public void onResponse(Call<BaseModel<UserBean>> call, Response<BaseModel<UserBean>> response) {
if (response.code() == 200) {
BaseModel<UserBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<UserBean>> call, Throwable t) {
}
});
}
public void authorization(BaseObserver<String> observer) {
sApiServer.authorization().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void oauthLogin(String netease_token, BaseObserver<List<UserBean>> observer) {
sApiServer.oauthLogin(netease_token).enqueue(new Callback<BaseModel<List<UserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserBean>>> call, Response<BaseModel<List<UserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<UserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else if (baseModel.getCode() == 301) {
ToastUtils.showShort(baseModel.getMsg());
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<UserBean>>> call, Throwable t) {
LogUtils.e("授权登录失败", t);
}
});
}
public void getThemeData(BaseObserver<ThemeBean> observer) {
sApiServer.getThemeData().enqueue(new Callback<BaseModel<ThemeBean>>() {
@Override
public void onResponse(Call<BaseModel<ThemeBean>> call, Response<BaseModel<ThemeBean>> response) {
if (response.code() == 200) {
BaseModel<ThemeBean> baseModel = response.body();
if (baseModel.getData() != null) {
observer.onNext(baseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<ThemeBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void authCode(String netease_token, int type, BaseObserver<List<UserBean>> observer) {
if (type == 1) {
sApiServer.authCode1(netease_token).compose(new DefaultTransformer<>()).subscribe(observer);
} else {
sApiServer.authCode(netease_token).compose(new DefaultTransformer<>()).subscribe(observer);
}
}
public void getUserFollowList(String page, String page_limit, BaseObserver<List<BlackUserBean>> observer) {
sApiServer.getUserFollowList(page, page_limit).enqueue(new Callback<BaseModel<List<BlackUserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<BlackUserBean>>> call, Response<BaseModel<List<BlackUserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<BlackUserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else {
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<BlackUserBean>>> call, Throwable t) {
}
});
}
public void getUserFansList(String page, String page_limit, BaseObserver<List<BlackUserBean>> observer) {
sApiServer.getUserFansList(page, page_limit).enqueue(new Callback<BaseModel<List<BlackUserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<BlackUserBean>>> call, Response<BaseModel<List<BlackUserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<BlackUserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else {
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<BlackUserBean>>> call, Throwable t) {
}
});
}
public void getBlacklist(String page, String page_limit, BaseObserver<List<BlackUserBean>> observer) {
sApiServer.getBlacklist(page, page_limit).enqueue(new Callback<BaseModel<List<BlackUserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<BlackUserBean>>> call, Response<BaseModel<List<BlackUserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<BlackUserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else {
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<BlackUserBean>>> call, Throwable t) {
}
});
}
public void getLockMiniList(String page, String page_limit, BaseObserver<List<BlackUserBean>> observer) {
sApiServer.getLockMiniList(page, page_limit).enqueue(new Callback<BaseModel<List<BlackUserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<BlackUserBean>>> call, Response<BaseModel<List<BlackUserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<BlackUserBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else {
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<BlackUserBean>>> call, Throwable t) {
}
});
}
public void realName(String real_name, String card_number, BaseObserver<RealNameBean> observer) {
sApiServer.realName(real_name, card_number).enqueue(new Callback<BaseModel<RealNameBean>>() {
@Override
public void onResponse(Call<BaseModel<RealNameBean>> call, Response<BaseModel<RealNameBean>> response) {
if (response.code() == 200) {
BaseModel<RealNameBean> 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){
try {
CommonAppContext.getInstance().clearLoginInfo();
ToastUtils.showShort(baseModel.getMsg());
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
}
}
@Override
public void onFailure(Call<BaseModel<RealNameBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
//获取扩列数据
public void getExpandColumn(String type, String page, String page_limit, BaseObserver<List<ExpandColumnBean>> observer) {
sApiServer.getExpandColumn(type, page, page_limit).enqueue(new Callback<BaseModel<List<ExpandColumnBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<ExpandColumnBean>>> call, Response<BaseModel<List<ExpandColumnBean>>> response) {
if (response.code() == 200) {
BaseModel<List<ExpandColumnBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<ExpandColumnBean>>> call, Throwable t) {
}
});
}
//获取官方公告数据或者系统消息,
public void getOfficialNotice(BaseObserver<NewsDataBean> observer) {
sApiServer.getOfficialNotice().enqueue(new Callback<BaseModel<NewsDataBean>>() {
@Override
public void onResponse(Call<BaseModel<NewsDataBean>> call, Response<BaseModel<NewsDataBean>> response) {
if (response.code() == 200) {
BaseModel<NewsDataBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<NewsDataBean>> call, Throwable t) {
}
});
}
public void getAlbumList(String page, String page_limit, String userId, BaseObserver<List<AlbumBean>> observer) {
// sApiServer.getAlbumList(page, page_limit, userId).compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.getAlbumList(page, page_limit, userId).enqueue(new Callback<BaseModel<List<AlbumBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<AlbumBean>>> call, Response<BaseModel<List<AlbumBean>>> response) {
if (response.code() == 200) {
BaseModel<List<AlbumBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<AlbumBean>>> call, Throwable t) {
}
});
}
public void sjRoomName(BaseObserver<String> observer) {
sApiServer.sjRoomName().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("获取房间名称失败", t);
}
});
}
public void getMyRoom(String type, String page, String page_limit, BaseObserver<List<MyRoomBean>> observer) {
sApiServer.getMyRoom(type, page, page_limit).enqueue(new Callback<BaseModel<List<MyRoomBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<MyRoomBean>>> call, Response<BaseModel<List<MyRoomBean>>> response) {
if (response.code() == 200) {
BaseModel<List<MyRoomBean>> listBaseModel = response.body();
if (listBaseModel != null) {
observer.onNext(listBaseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MyRoomBean>>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void getBanners(BaseObserver<List<BannerModel>> observer) {
sApiServer.getBanners("3").enqueue(new Callback<BaseModel<List<BannerModel>>>() {
@Override
public void onResponse(Call<BaseModel<List<BannerModel>>> call, Response<BaseModel<List<BannerModel>>> response) {
if (response.code() == 200) {
BaseModel<List<BannerModel>> listBaseModel = response.body();
if (listBaseModel.getCode()==1) {
if (listBaseModel != null) {
observer.onNext(listBaseModel.getData());
} else {
observer.onNext(null);
}
}else if (listBaseModel.getCode()==0){
observer.onNext(null);
}else if (listBaseModel.getCode()==301){
try {
ToastUtils.showShort(listBaseModel.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<BannerModel>>> call, Throwable t) {
LogUtils.e("获取轮播图失败", t);
}
});
}
public void getTopRooms(String page, String page_limit, String is_top, String label_id, BaseObserver<List<TopRoom>> observer) {
sApiServer.getTopRooms(page, page_limit, is_top, label_id).enqueue(new Callback<BaseModel<List<TopRoom>>>() {
@Override
public void onResponse(Call<BaseModel<List<TopRoom>>> call, Response<BaseModel<List<TopRoom>>> response) {
if (response.code() == 200) {
BaseModel<List<TopRoom>> listBaseModel = response.body();
if (listBaseModel.getCode()==1) {
if (listBaseModel != null) {
observer.onNext(listBaseModel.getData());
} else {
observer.onNext(null);
}
}else if (listBaseModel.getCode()==0){
observer.onNext(null);
}else if (listBaseModel.getCode()==301){
try {
ToastUtils.showShort(listBaseModel.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<TopRoom>>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void getRoomCategories(BaseObserver<List<RoomTypeModel>> observer) {
sApiServer.getRoomCategories().enqueue(new Callback<BaseModel<List<RoomTypeModel>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomTypeModel>>> call, Response<BaseModel<List<RoomTypeModel>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomTypeModel>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}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);
}
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomTypeModel>>> call, Throwable t) {
}
});
}
public void getRewardList(String id, int page, int page_limit, BaseObserver<List<RewardUserBean>> observer) {
// sApiServer.getRewardList(id, page + "", page_limit + "").compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.getRewardList(id, page + "", page_limit + "").enqueue(new Callback<BaseModel<List<RewardUserBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RewardUserBean>>> call, Response<BaseModel<List<RewardUserBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RewardUserBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RewardUserBean>>> call, Throwable t) {
}
});
}
public void getGiftLabel(String have_hot, BaseObserver<List<GiftLabelBean>> observer) {
sApiServer.getGiftLabel(have_hot).enqueue(new Callback<BaseModel<List<GiftLabelBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftLabelBean>>> call, Response<BaseModel<List<GiftLabelBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftLabelBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftLabelBean>>> call, Throwable t) {
}
});
}
public void getGiftList(int type, String roomId, BaseObserver<List<RoonGiftModel>> observer) {
sApiServer.getGiftList(type, roomId).enqueue(new Callback<BaseModel<List<RoonGiftModel>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoonGiftModel>>> call, Response<BaseModel<List<RoonGiftModel>>> response) {
if (response.code() == 200) {
BaseModel<List<RoonGiftModel>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoonGiftModel>>> call, Throwable t) {
}
});
}
public void topicList(String page, String page_limit, BaseObserver<List<HeatedBean>> observer) {
sApiServer.topicList(page, page_limit).enqueue(new Callback<BaseModel<List<HeatedBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<HeatedBean>>> call, Response<BaseModel<List<HeatedBean>>> response) {
if (response.code() == 200) {
BaseModel<List<HeatedBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<HeatedBean>>> call, Throwable t) {
}
});
}
public void getCategories(BaseObserver<List<HeatedBean>> observer) {//动态顶部热门话题
sApiServer.getCategories().enqueue(new Callback<BaseModel<List<HeatedBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<HeatedBean>>> call, Response<BaseModel<List<HeatedBean>>> response) {
if (response.code() == 200) {
BaseModel<List<HeatedBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<HeatedBean>>> call, Throwable t) {
}
});
}
public void getCircleList(String page, String page_limit, BaseObserver<List<CircleListBean>> observer) {//动态列表
sApiServer.getCircleList(page, page_limit).enqueue(new Callback<BaseModel<List<CircleListBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<CircleListBean>>> call, Response<BaseModel<List<CircleListBean>>> response) {
if (response.code() == 200) {
BaseModel<List<CircleListBean>> listBaseModel = response.body();
if (listBaseModel != null) {
observer.onNext(listBaseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<CircleListBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getCircleUserList(String user_id, String page, String page_limit, BaseObserver<List<CircleListBean>> observer) {//用户主页动态列表
sApiServer.getCircleUserList(user_id, page, page_limit).enqueue(new Callback<BaseModel<List<CircleListBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<CircleListBean>>> call, Response<BaseModel<List<CircleListBean>>> response) {
if (response.code() == 200) {
BaseModel<List<CircleListBean>> listBaseModel = response.body();
if (listBaseModel != null) {
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<CircleListBean>>> call, Throwable t) {
}
});
}
public void topicId(String topic_id, BaseObserver<List<CircleListBean>> observer) {//动态列表
sApiServer.topicId(topic_id).enqueue(new Callback<BaseModel<List<CircleListBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<CircleListBean>>> call, Response<BaseModel<List<CircleListBean>>> response) {
if (response.code() == 200) {
BaseModel<List<CircleListBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<CircleListBean>>> call, Throwable t) {
}
});
}
public void zoneDetail(String topic_id, BaseObserver<CircleListBean> observer) {//动态列表
sApiServer.zoneDetail(topic_id).enqueue(new Callback<BaseModel<CircleListBean>>() {
@Override
public void onResponse(Call<BaseModel<CircleListBean>> call, Response<BaseModel<CircleListBean>> response) {
if (response.code() == 200) {
BaseModel<CircleListBean> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<CircleListBean>> call, Throwable t) {
}
});
}
public void getUserHome(String user_id, BaseObserver<UserInfo> observer) {
sApiServer.getUserHome(user_id).enqueue(new Callback<BaseModel<UserInfo>>() {
@Override
public void onResponse(Call<BaseModel<UserInfo>> call, Response<BaseModel<UserInfo>> response) {
if (response.code() == 200) {
BaseModel<UserInfo> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<UserInfo>> call, Throwable t) {
}
});
}
public void getCommentList(String id, String page, String page_limit, BaseObserver<CommentBean> observer) {
sApiServer.getCommentList(id, page, page_limit).enqueue(new Callback<BaseModel<CommentBean>>() {
@Override
public void onResponse(Call<BaseModel<CommentBean>> call, Response<BaseModel<CommentBean>> response) {
if (response.code() == 200) {
BaseModel<CommentBean> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<CommentBean>> call, Throwable t) {
}
});
}
public void song(String roomId, String user_id, String song_code, String song_name, String singer, String poster, String duration, BaseObserver<List<SongMusicBean>> observer) {
sApiServer.song(roomId, user_id, song_code, song_name, singer, poster, duration).enqueue(new Callback<BaseModel<List<SongMusicBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<SongMusicBean>>> call, Response<BaseModel<List<SongMusicBean>>> response) {
if (response.code() == 200) {
BaseModel<List<SongMusicBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<SongMusicBean>>> call, Throwable t) {
}
});
}
public void getMyInfo(BaseObserver<UserInfo> observer) {//点击我的获取数据
sApiServer.getMyInfo().enqueue(new Callback<BaseModel<UserInfo>>() {
@Override
public void onResponse(Call<BaseModel<UserInfo>> call, Response<BaseModel<UserInfo>> response) {
if (response.code() == 200) {
BaseModel<UserInfo> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<UserInfo>> call, Throwable t) {
}
});
}
public void getUserTagList(BaseObserver<List<UserTagBean>> observer) {
sApiServer.getUserTagList().enqueue(new Callback<BaseModel<List<UserTagBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserTagBean>>> call, Response<BaseModel<List<UserTagBean>>> response) {
if (response.code() == 200) {
BaseModel<List<UserTagBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<UserTagBean>>> call, Throwable t) {
}
});
}
public void getLikeList(String id, BaseObserver<List<CircleListBean.LikeList>> observer) {
sApiServer.getLikeList(id).enqueue(new Callback<BaseModel<List<CircleListBean.LikeList>>>() {
@Override
public void onResponse(Call<BaseModel<List<CircleListBean.LikeList>>> call, Response<BaseModel<List<CircleListBean.LikeList>>> response) {
if (response.code() == 200) {
BaseModel<List<CircleListBean.LikeList>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<CircleListBean.LikeList>>> call, Throwable t) {
}
});
}
public void getAlbumDetail(String albumId, String pwd, String page, String page_limit, BaseObserver<AlbumBean> observer) {
sApiServer.getAlbumDetail(albumId, pwd, page, page_limit).enqueue(new Callback<BaseModel<AlbumBean>>() {
@Override
public void onResponse(Call<BaseModel<AlbumBean>> call, Response<BaseModel<AlbumBean>> response) {
if (response.code() == 200) {
BaseModel<AlbumBean> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<AlbumBean>> call, Throwable t) {
}
});
}
public void getSubsidy(String roomId, BaseObserver<RoomSubsidy> observer) {
sApiServer.getSubsidy(roomId).enqueue(new Callback<BaseModel<RoomSubsidy>>() {
@Override
public void onResponse(Call<BaseModel<RoomSubsidy>> call, Response<BaseModel<RoomSubsidy>> response) {
if (response.code() == 200) {
BaseModel<RoomSubsidy> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomSubsidy>> call, Throwable t) {
}
});
}
public void getSubsidyDetail(String roomId, BaseObserver<RoomSubsidyDetails> observer) {
// sApiServer.getSubsidyDetail(roomId).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void getPersonaltyList(BaseObserver<List<PersonaltyBean>> observer) {
sApiServer.getPersonaltyList().enqueue(new Callback<BaseModel<List<PersonaltyBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<PersonaltyBean>>> call, Response<BaseModel<List<PersonaltyBean>>> response) {
if (response.code() == 200) {
BaseModel<List<PersonaltyBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<PersonaltyBean>>> call, Throwable t) {
}
});
}
public void getDecorateList(String type, BaseObserver<List<ZhuangBanShangChengBean>> observer) {
sApiServer.getDecorateList(type).enqueue(new Callback<BaseModel<List<ZhuangBanShangChengBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<ZhuangBanShangChengBean>>> call, Response<BaseModel<List<ZhuangBanShangChengBean>>> response) {
if (response.code() == 200) {
BaseModel<List<ZhuangBanShangChengBean>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<ZhuangBanShangChengBean>>> call, Throwable t) {
}
});
}
public void roomGetIn(String roomId, String password, BaseObserver<RoomInfoResp> observer) {
if (!isNetworkAvailable()) {
handleNetworkUnavailable(observer);
CommonAppContext.getInstance().isRoomJoininj=false;
return;
}
sApiServer.roomGetIn(roomId, password).enqueue(new Callback<BaseModel<RoomInfoResp>>() {
@Override
public void onResponse(Call<BaseModel<RoomInfoResp>> call, Response<BaseModel<RoomInfoResp>> response) {
CommonAppContext.getInstance().isRoomJoininj=false;
if (response.code() == 200) {
BaseModel<RoomInfoResp> roomInfoRespBaseModel = response.body();
if (roomInfoRespBaseModel.getCode() == 1) {
observer.onNext(roomInfoRespBaseModel.getData());
} else {
MessageListenerSingleton.getInstance().quitGroup(roomId);
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomInfoResp>> call, Throwable t) {
MessageListenerSingleton.getInstance().quitGroup(roomId);
CommonAppContext.getInstance().isRoomJoininj=false;
}
});
}
public void updatePassword(String roomId, String password, BaseObserver<String> observer) {
sApiServer.updatePassword(roomId, password).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> stringBaseModel = response.body();
if (stringBaseModel.getCode() == 1) {
observer.onNext(stringBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
}
});
}
public void getMyFoot(String page, BaseObserver<List<MyFootResp>> observer) {
sApiServer.getMyFoot(page, "10").enqueue(new Callback<BaseModel<List<MyFootResp>>>() {
@Override
public void onResponse(Call<BaseModel<List<MyFootResp>>> call, Response<BaseModel<List<MyFootResp>>> response) {
if (response.code() == 200) {
BaseModel<List<MyFootResp>> listBaseModel = response.body();
if (listBaseModel.getCode() == 1) {
observer.onNext(listBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MyFootResp>>> call, Throwable t) {
}
});
}
public void myCpRoom(BaseObserver<List<MyCpRoom>> observer) {
sApiServer.myCpRoom().enqueue(new Callback<BaseModel<List<MyCpRoom>>>() {
@Override
public void onResponse(Call<BaseModel<List<MyCpRoom>>> call, Response<BaseModel<List<MyCpRoom>>> response) {
if (response.code() == 200) {
BaseModel<List<MyCpRoom>> listBaseModel = response.body();
if (listBaseModel != null) {
observer.onNext(listBaseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MyCpRoom>>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void startPk(String pk_id, String pk_times, BaseObserver<String> observer) {
sApiServer.startPk(pk_id, pk_times).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
observer.onNext(baseModel.getData());
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
LogUtils.e("开始pk", t);
}
});
}
public void getRoomOnline(String roomId, String page, String page_limit, BaseObserver<RoomOnline> observer) {
sApiServer.getRoomOnline(roomId, page, page_limit).enqueue(new Callback<BaseModel<RoomOnline>>() {
@Override
public void onResponse(Call<BaseModel<RoomOnline>> call, Response<BaseModel<RoomOnline>> response) {
if (response.code() == 200) {
BaseModel<RoomOnline> roomOnlineBaseModel = response.body();
if (roomOnlineBaseModel.getCode() == 1) {
observer.onNext(roomOnlineBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomOnline>> call, Throwable t) {
}
});
}
public void activitiesPermission(BaseObserver<ActivitiesPermission> observer){
sApiServer.activitiesPermission().enqueue(new Callback<BaseModel<ActivitiesPermission>>() {
@Override
public void onResponse(Call<BaseModel<ActivitiesPermission>> call, Response<BaseModel<ActivitiesPermission>> response) {
if (response.code() == 200) {
BaseModel<ActivitiesPermission> activitiesPermissionBaseModel = response.body();
if (activitiesPermissionBaseModel.getCode() == 1) {
observer.onNext(activitiesPermissionBaseModel.getData());
}else if (activitiesPermissionBaseModel.getCode()==0){
ToastUtils.showShort(activitiesPermissionBaseModel.getMsg());
}else if (activitiesPermissionBaseModel.getCode()==301){
try {
CommonAppContext.getInstance().clearLoginInfo();
ToastUtils.showShort(activitiesPermissionBaseModel.getMsg());
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
}
}
@Override
public void onFailure(Call<BaseModel<ActivitiesPermission>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void wallet(BaseObserver<WalletBean> observer) {
sApiServer.wallet().enqueue(new Callback<BaseModel<WalletBean>>() {
@Override
public void onResponse(Call<BaseModel<WalletBean>> call, Response<BaseModel<WalletBean>> response) {
if (response.code() == 200) {
BaseModel<WalletBean> walletBeanBaseModel = response.body();
if (walletBeanBaseModel.getCode() == 1) {
observer.onNext(walletBeanBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<WalletBean>> call, Throwable t) {
}
});
}
public void appPay(String user_id, String money, String coin, String type, BaseObserver<AppPay> observer) {
sApiServer.appPay(user_id, money, coin, type).enqueue(new Callback<BaseModel<AppPay>>() {
@Override
public void onResponse(Call<BaseModel<AppPay>> call, Response<BaseModel<AppPay>> response) {
if (response.code() == 200) {
BaseModel<AppPay> appPayBaseModel = response.body();
if (appPayBaseModel.getCode() == 1) {
observer.onNext(appPayBaseModel.getData());
}else {
ToastUtils.showShort(appPayBaseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<AppPay>> call, Throwable t) {
}
});
}
public void bindType(String userId, BaseObserver<BindType> observer) {
sApiServer.bindType(userId).enqueue(new Callback<BaseModel<BindType>>() {
@Override
public void onResponse(Call<BaseModel<BindType>> call, Response<BaseModel<BindType>> response) {
if (response.code() == 200) {
BaseModel<BindType> bindTypeBaseModel = response.body();
if (bindTypeBaseModel.getCode() == 1) {
observer.onNext(bindTypeBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<BindType>> call, Throwable t) {
}
});
}
public void getWalletConfig(BaseObserver<WalletConfig> observer) {
sApiServer.getWalletConfig().enqueue(new Callback<BaseModel<WalletConfig>>() {
@Override
public void onResponse(Call<BaseModel<WalletConfig>> call, Response<BaseModel<WalletConfig>> response) {
if (response.code() == 200) {
BaseModel<WalletConfig> walletConfigBaseModel = response.body();
if (walletConfigBaseModel.getCode() == 1) {
observer.onNext(walletConfigBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<WalletConfig>> call, Throwable t) {
}
});
}
public void bind(String userId, String type, String alipayAccount, String bank_card_number, String bank_card, String open_bank, BaseObserver<String> observer) {
sApiServer.bind(userId, type, alipayAccount, bank_card_number, bank_card, open_bank).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void roomApplyListBean(String roomId, BaseObserver<RoomApplyListBean> observer) {
sApiServer.roomApplyListBean(roomId).enqueue(new Callback<BaseModel<RoomApplyListBean>>() {
@Override
public void onResponse(Call<BaseModel<RoomApplyListBean>> call, Response<BaseModel<RoomApplyListBean>> response) {
if (response.code() == 200) {
BaseModel<RoomApplyListBean> roomApplyListBeanBaseModel = response.body();
if (roomApplyListBeanBaseModel.getCode() == 1) {
observer.onNext(roomApplyListBeanBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomApplyListBean>> call, Throwable t) {
}
});
}
public void getRoomUserInfo(String room_id, String
user_id, BaseObserver<UserInfo> observer) {
sApiServer.getRoomUserInfo(room_id, user_id).enqueue(new Callback<BaseModel<UserInfo>>() {
@Override
public void onResponse(Call<BaseModel<UserInfo>> call, Response<BaseModel<UserInfo>> response) {
if (response.code() == 200) {
BaseModel<UserInfo> userInfoBaseModel = response.body();
if (userInfoBaseModel.getCode() == 1) {
observer.onNext(userInfoBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<UserInfo>> call, Throwable t) {
}
});
}
public void songList(String room_id, BaseObserver<List<MusicSongBean>> observer) {
sApiServer.songList(room_id).enqueue(new Callback<BaseModel<List<MusicSongBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<MusicSongBean>>> call, Response<BaseModel<List<MusicSongBean>>> response) {
if (response.code() == 200) {
BaseModel<List<MusicSongBean>> musicSongBaseModel = response.body();
if (musicSongBaseModel.getCode() == 1) {
observer.onNext(musicSongBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<MusicSongBean>>> call, Throwable t) {
}
});
}
// TODO: 2025/3/15 获取主持人列表
public void getHostList(String roomId, String
type, BaseObserver<List<HostBean>> observer) {
sApiServer.getHostList(roomId, type).enqueue(new Callback<BaseModel<List<HostBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<HostBean>>> call, Response<BaseModel<List<HostBean>>> response) {
if (response.code() == 200) {
BaseModel<List<HostBean>> hostBeanBaseModel = response.body();
if (hostBeanBaseModel.getCode() == 1) {
observer.onNext(hostBeanBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<HostBean>>> call, Throwable t) {
}
});
}
public void getSearch(String keyWord, String type, BaseObserver<List<RoomSearchResp>> observer) {
sApiServer.getSearch(keyWord, type).enqueue(new Callback<BaseModel<List<RoomSearchResp>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomSearchResp>>> call, Response<BaseModel<List<RoomSearchResp>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomSearchResp>> roomSearchRespBaseModel = response.body();
if (roomSearchRespBaseModel.getCode() == 1) {
observer.onNext(roomSearchRespBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomSearchResp>>> call, Throwable t) {
}
});
}
public void getSearchAll(String keyWord, BaseObserver<SearchAll> observer) {
sApiServer.getSearchAll(keyWord).enqueue(new Callback<BaseModel<SearchAll>>() {
@Override
public void onResponse(Call<BaseModel<SearchAll>> call, Response<BaseModel<SearchAll>> response) {
if (response.code() == 200){
BaseModel<SearchAll> searchAllBaseModel = response.body();
if (searchAllBaseModel.getCode()==1){
if (searchAllBaseModel.getData()!=null){
observer.onNext(searchAllBaseModel.getData());
}
}
}
}
@Override
public void onFailure(Call<BaseModel<SearchAll>> call, Throwable t) {
}
});
}
public void getBackgroundList(BaseObserver<RoomBgBean> observer) {
sApiServer.getBackgroundList().enqueue(new Callback<BaseModel<RoomBgBean>>() {
@Override
public void onResponse(Call<BaseModel<RoomBgBean>> call, Response<BaseModel<RoomBgBean>> response) {
if (response.code() == 200) {
BaseModel<RoomBgBean> roomBgBeanBaseModel = response.body();
if (roomBgBeanBaseModel.getCode() == 1) {
observer.onNext(roomBgBeanBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomBgBean>> call, Throwable t) {
}
});
}
public void getCharmList(String roomId, String stime, String etime, String
p, BaseObserver<RoomDetails> observer) {
sApiServer.getCharmList(roomId, stime, etime, p).enqueue(new Callback<BaseModel<RoomDetails>>() {
@Override
public void onResponse(Call<BaseModel<RoomDetails>> call, Response<BaseModel<RoomDetails>> response) {
if (response.code() == 200) {
BaseModel<RoomDetails> roomDetailsBaseModel = response.body();
if (roomDetailsBaseModel.getCode() == 1) {
observer.onNext(roomDetailsBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomDetails>> call, Throwable t) {
}
});
}
// TODO: 2025/6/28 房间竞拍开始
public void roomAuction(String roomId, String userId, String giftId, String
relation_id, String auction_type, String time_day, BaseObserver<AuctionBean> observer) {
sApiServer.roomAuction(roomId, userId, giftId, relation_id, auction_type, time_day).enqueue(new Callback<BaseModel<AuctionBean>>() {
@Override
public void onResponse(Call<BaseModel<AuctionBean>> call, Response<BaseModel<AuctionBean>> response) {
if (response.code() == 200) {
BaseModel<AuctionBean> auctionBeanBaseModel = response.body();
if (auctionBeanBaseModel.getCode() == 1) {
observer.onNext(auctionBeanBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<AuctionBean>> call, Throwable t) {
}
});
}
public void roomAuctionTime(String gift_id, BaseObserver<RoomTime> observer) {
sApiServer.roomAuctionTime(gift_id).enqueue(new Callback<BaseModel<RoomTime>>() {
@Override
public void onResponse(Call<BaseModel<RoomTime>> call, Response<BaseModel<RoomTime>> response) {
if (response.code() == 200) {
BaseModel<RoomTime> roomTimeBaseModel = response.body();
if (roomTimeBaseModel.getCode() == 1) {
observer.onNext(roomTimeBaseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomTime>> call, Throwable t) {
}
});
}
public void roomAuctionJoin(String auctionId, String userId, String giftId, String num, String type, BaseObserver<RoomAuction.AuctionListBean> observer) {
sApiServer.roomAuctionJoin(auctionId, userId, giftId, num, type).enqueue(new ApiResponseCallback<RoomAuction.AuctionListBean>(CommonAppContext.getInstance()) {
@Override
public void onSuccess(RoomAuction.AuctionListBean data) {
if (data != null) {
observer.onNext(data);
}else {
observer.onNext(new RoomAuction.AuctionListBean());
}
}
@Override
public void onFailure(Throwable t) {
t.printStackTrace();
}
});
// .enqueue(new Callback<BaseModel<RoomAuction.AuctionListBean>>() {
//
// @Override
// public void onResponse(Call<BaseModel<RoomAuction.AuctionListBean>> call, Response<BaseModel<RoomAuction.AuctionListBean>> response) {
// if (response.code() == 200) {
// BaseModel<RoomAuction.AuctionListBean> baseModel = response.body();
//
// if (baseModel.getCode() == 1) {
// observer.onNext( null);
// } else {
// ToastUtils.showShort(baseModel.getMsg());
// }
// }
// }
//
// @Override
// public void onFailure(Call<BaseModel<RoomAuction.AuctionListBean>> call, Throwable t) {
// t.printStackTrace();
// }
// });
}
public void auctionDelay(String auctionId, BaseObserver<String> observer) {
sApiServer.auctionDelay(auctionId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void auctionEnd(String auctionId, String roomId, BaseObserver<String> observer) {
sApiServer.auctionEnd(auctionId, roomId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
observer.onNext(null);
}
// onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void auctionMode(String roomId, String labelId, BaseObserver<String> observer) {
sApiServer.auctionMode(roomId, labelId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void uploadBgImage(String id, String image_url, BaseObserver<String> observer) {
sApiServer.setUploadBgImg(id, image_url).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void editRoom(String room_id, String room_name, String room_cover, String
room_intro, String room_background, BaseObserver<String> observer) {
sApiServer.editRoom(room_id, room_name, room_cover, room_intro, room_background).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void setPresidedRatio(String room_id, String user_id, String
ratio, BaseObserver<String> observer) {
sApiServer.setPresidedRatio(room_id, user_id, ratio).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void postHostAdd(String roomId, String userId, String type, String
is_add, BaseObserver<String> observer) {
sApiServer.getPresidedRatio(roomId, userId, type, is_add).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void reward_zone(String id, String gift_id, String num, String
is_pack, BaseObserver<String> observer) {
sApiServer.reward_zone(id, gift_id, num, is_pack).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void upSong(String did, String type, BaseObserver<String> observer) {
sApiServer.upSong(did, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void clearApply(String room_id, BaseObserver<String> observer) {
sApiServer.clearApply(room_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void agreePit(String room_id, String user_id, BaseObserver<String> observer) {
sApiServer.agreePit(room_id, user_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
}
});
}
public void refusePit(String room_id, String user_id, BaseObserver<String> observer) {
sApiServer.refusePit(room_id, user_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
}
});
}
public void helpApply(String room_id, String user_id, BaseObserver<String> observer) {
sApiServer.helpApply(room_id, user_id)
.enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void setRoomApply(String room_id, String gift_id, String
gift_price, BaseObserver<String> observer) {
sApiServer.setRoomApply(room_id, gift_id, gift_price).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void giveGift(String user_id, String gid, String num, String to_uid, String
gift_type, BaseObserver<String> observer) {
sApiServer.giveGift(user_id, gid, num, to_uid, gift_type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void roomGift(String room_id, String gift_id, String gift_num, String to_uid, String
type, String pit_number, String heart_id, BaseObserver<String> observer) {
sApiServer.roomGift(room_id, gift_id, gift_num, to_uid, type, pit_number, heart_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void getDayDropGift(BaseObserver<HeavenGiftBean> observer){
sApiServer.getDayDropGift().enqueue(new Callback<BaseModel<HeavenGiftBean>>() {
@Override
public void onResponse(Call<BaseModel<HeavenGiftBean>> call, Response<BaseModel<HeavenGiftBean>> response) {
if (response.code()==200){
BaseModel<HeavenGiftBean> data = response.body();
if (data.getCode()==1){
observer.onNext(data.getData());
}else if (data.getCode()==0){
ToastUtils.showShort(data.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<HeavenGiftBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void firstChargeGift(BaseObserver<FirstChargeGiftBean> observer) {
// sApiServer.firstChargeGift().compose(new DefaultTransformer<>()).subscribe(observer);
sApiServer.firstChargeGift().enqueue(new Callback<BaseModel<FirstChargeGiftBean>>() {
@Override
public void onResponse(Call<BaseModel<FirstChargeGiftBean>> call, Response<BaseModel<FirstChargeGiftBean>> response) {
if (response.code() == 200) {
BaseModel<FirstChargeGiftBean> data = response.body();
if (data.getCode() == 1) {
observer.onNext(data.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<FirstChargeGiftBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getNewChargeGift(BaseObserver<FirstChargeGiftBean> observer) {
sApiServer.getNewChargeGift().enqueue(new Callback<BaseModel<FirstChargeGiftBean>>() {
@Override
public void onResponse(Call<BaseModel<FirstChargeGiftBean>> call, Response<BaseModel<FirstChargeGiftBean>> response) {
if (response.code() == 200) {
BaseModel<FirstChargeGiftBean> data = response.body();
if (data.getCode() == 1) {
observer.onNext(data.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<FirstChargeGiftBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void applyPit(String roomId, String pitNumber, BaseObserver<String> observer) {
sApiServer.applyPit(roomId, pitNumber).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void startFriend(String roomId, BaseObserver<String> observer) {
sApiServer.startFriend(roomId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> baseModel = response.body();
if (baseModel.getCode() != 1) {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void delay(String friend_id, String room_id, String
delay_times, BaseObserver<String> observer) {
sApiServer.delay(friend_id, room_id, delay_times).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> baseModel = response.body();
if (baseModel.getCode() != 1) {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void endFriend(String friend_id, String
room_id, BaseObserver<FriendUserBean> observer) {
sApiServer.endFriend(friend_id, room_id).enqueue(new Callback<BaseModel<FriendUserBean>>() {
@Override
public void onResponse(Call<BaseModel<FriendUserBean>> call, Response<BaseModel<FriendUserBean>> response) {
if (response.code() == 200) {
BaseModel<FriendUserBean> baseModel = response.body();
if (baseModel.getCode() != 1) {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
}
observer.onNext(baseModel.getData());
}
}
@Override
public void onFailure(Call<BaseModel<FriendUserBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void createRelation(String room_id, String friend_id, String user1_id, String
user2_id, String relation_id, BaseObserver<String> observer) {
sApiServer.createRelation(room_id, friend_id, user1_id, user2_id, relation_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> baseModel = response.body();
if (baseModel.getCode() != 1) {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
} else {
observer.onNext("");
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void keepXintiao(){
sApiServer.keepXintiao().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
}
});
}
public void setMutePit(String roomId, String user_id, String
isMute, BaseObserver<String> observer) {
sApiServer.setMutePit(roomId, user_id, isMute).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void setLockPit(String roomId, String pitNumber, String
isLock, BaseObserver<String> observer) {
sApiServer.setLockPit(roomId, pitNumber, isLock).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void downPit(String roomId, String pitNumber, BaseObserver<String> observer) {
sApiServer.downPit(roomId, pitNumber).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void kickOutRoom(String room_id, String user_id, BaseObserver<String> observer) {
sApiServer.kickOutRoom(room_id, user_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void applySong(String room_id, BaseObserver<String> observer) {
sApiServer.applySong(room_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void agreeSong(String room_id, String type, BaseObserver<String> observer) {
sApiServer.agreeSong(room_id, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void endSong(String room_id, BaseObserver<String> observer) {
sApiServer.endSong(room_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void postRoomInfo(String roomId, BaseObserver<RoomInfoResp> observer) {
sApiServer.postRoomInfo(roomId).enqueue(new Callback<BaseModel<RoomInfoResp>>() {
@Override
public void onResponse(Call<BaseModel<RoomInfoResp>> call, Response<BaseModel<RoomInfoResp>> response) {
if (response.code() == 200) {
BaseModel<RoomInfoResp> baseModel = response.body();
if (baseModel.getCode() != 1) {
observer.onNext(null);
} else {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RoomInfoResp>> call, Throwable t) {
}
});
}
public void getCharmRank(String roomId, BaseObserver<List<RoomCharmRankBean>> observer) {
sApiServer.getCharmRank(roomId).enqueue(new Callback<BaseModel<List<RoomCharmRankBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomCharmRankBean>>> call, Response<BaseModel<List<RoomCharmRankBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomCharmRankBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomCharmRankBean>>> call, Throwable t) {
}
});
}
public void roomRelationList(String
type, BaseObserver<List<RoomRelationBean>> observer) {
sApiServer.roomRelationList(type).enqueue(new Callback<BaseModel<List<RoomRelationBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomRelationBean>>> call, Response<BaseModel<List<RoomRelationBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomRelationBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomRelationBean>>> call, Throwable t) {
}
});
}
public void roomAuctionList(String
auction_id, BaseObserver<List<RoomAuction.AuctionListBean>> observer) {
sApiServer.roomAuctionList(auction_id).enqueue(new Callback<BaseModel<List<RoomAuction.AuctionListBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomAuction.AuctionListBean>>> call, Response<BaseModel<List<RoomAuction.AuctionListBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomAuction.AuctionListBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomAuction.AuctionListBean>>> call, Throwable t) {
}
});
}
public void changeSong(String room_id, String now_did, BaseObserver<String> observer) {
sApiServer.changeSong(room_id, now_did).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void hostUserPit(String room_id, String pit_number, String user_id, String
type, BaseObserver<String> observer) {
sApiServer.hostUserPit(room_id, pit_number, user_id, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void giveCoin(String user_id, String coin, BaseObserver<String> observer) {
sApiServer.giveCoin(user_id, coin).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
BaseModel<String> baseModel = response.body();
if (baseModel.getCode() == 1) {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void relationCard(String user_id, BaseObserver<RelationCardBean> observer) {
sApiServer.relationCard(user_id).enqueue(new Callback<BaseModel<RelationCardBean>>() {
@Override
public void onResponse(Call<BaseModel<RelationCardBean>> call, Response<BaseModel<RelationCardBean>> response) {
if (response.code() == 200){
BaseModel<RelationCardBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<RelationCardBean>> call, Throwable t) {
}
});
}
public void topRelationCard(String id, BaseObserver<String> observer) {
sApiServer.topRelationCard(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void deleteRelationCard(String id, BaseObserver<String> observer) {
sApiServer.deleteRelationCard(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void quitRoom(String room_id, String user_id, BaseObserver<String> observer) {
sApiServer.quitRoom(room_id, user_id).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
observer.onNext(null);
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void checkTxt(String room_name, String room_cover, String
room_intro, BaseObserver<String> observer) {
sApiServer.checkTxt(room_name, room_cover, room_intro).enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
t.printStackTrace();
}
});
}
public void setUserDecorate(String decorateId, BaseObserver<String> observer) {
sApiServer.setUserDecorate(decorateId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void cancelUserDecorate(String type, BaseObserver<String> observer) {
sApiServer.cancelUserDecorate(type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
if (response.code() == 200) {
observer.onNext("取消成功");
}
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void publishZone(String images, String content, String topic_id, String
room_id, String ip, BaseObserver<String> observer) {
sApiServer.publishZone(images, content, topic_id, room_id, ip).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void likeZone(String zone_id, BaseObserver<String> observer) {
sApiServer.likeZone(zone_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void deleteComment(String id, BaseObserver<String> observer) {
sApiServer.deleteComment(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void deleteZone(String id, BaseObserver<String> observer) {
sApiServer.deleteZone(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void commentZone(String id, String content, String pid, String
reply_to, BaseObserver<String> observer) {
sApiServer.commentZone(id, content, pid, reply_to).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void clearLoginInfo(BaseObserver<String> observer) {
sApiServer.clearLoginInfo(SpUtil.getToken()).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void cancel(BaseObserver<String> observer) {
sApiServer.cancel(SpUtil.getToken()).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void getPostData(String new_password, String mobile, String code, String userId, BaseObserver<String> observer) {
sApiServer.getPostData(new_password, mobile, code, userId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
// ToastUtils.showShort("提示当前账号已在别的地方登陆,如果不是本人操作请修改密码");
if (t.toString().contains("登录失效")) {
try {
CommonAppContext.getInstance().clearLoginInfo();
ToastUtils.showShort(t.toString());
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
ToastUtils.showShort(t.toString());
}
});
}
public void forgotPassword(String new_password, String mobile, String
sms_code, BaseObserver<String> observer) {
sApiServer.forgotPassword(new_password, mobile, sms_code).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void createAlbum(String name, String pwd, String
image, BaseObserver<String> observer) {
sApiServer.createAlbum(name, pwd, image).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void editAlbum(String album_id, String name, String pwd, String
image, BaseObserver<String> observer) {
sApiServer.editAlbum(album_id, name, pwd, image).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void editUserInfo(int type, String nickname, String birthday, String sex, String
avatar, String images, String profile, String tag_id, BaseObserver<String> observer) {
if (type == 1) {
sApiServer.editUserInfo(nickname, birthday, sex, avatar, images, profile, tag_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
} else {
sApiServer.editUserBg(images).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
}
public void userGuanz(String user_id, String type, BaseObserver<String> observer) {
sApiServer.userGuanz(user_id, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void acceptPk(String pk_id, String type, BaseObserver<String> observer) {
sApiServer.acceptPk(pk_id, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void clearUserCharm(String roomId, String userId, BaseObserver<String> observer) {
sApiServer.clearUserCharm(roomId, userId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
t.printStackTrace();
}
});
}
public void userOnlineStatus(String user_id, String roomId, BaseObserver<List<UserOnlineStatusBean>> observer) {
sApiServer.userOnlineStatus(user_id, roomId).enqueue(new Callback<BaseModel<List<UserOnlineStatusBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<UserOnlineStatusBean>>> call, Response<BaseModel<List<UserOnlineStatusBean>>> response) {
if (response.code() == 200) {
BaseModel<List<UserOnlineStatusBean>> baseModel = response.body();
observer.onNext(baseModel.getData());
}
}
@Override
public void onFailure(Call<BaseModel<List<UserOnlineStatusBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void postRoomSwToken(String roomId, BaseObserver<PkSwTokenBean> observer) {
sApiServer.postRoomSwToken(roomId).enqueue(new Callback<BaseModel<PkSwTokenBean>>() {
@Override
public void onResponse(Call<BaseModel<PkSwTokenBean>> call, Response<BaseModel<PkSwTokenBean>> response) {
if (response.code() == 200) {
BaseModel<PkSwTokenBean> baseModel = response.body();
observer.onNext(baseModel.getData());
}
}
@Override
public void onFailure(Call<BaseModel<PkSwTokenBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void removeBlackList(String user_id, BaseObserver<String> observer) {
sApiServer.removeBlackList(user_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void upAddAlbum(String album_id, String images, String
content, BaseObserver<String> observer) {
sApiServer.upAddAlbum(album_id, images, content).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void moveAlbum(String id, String new_album_id, BaseObserver<String> observer) {
sApiServer.moveAlbum(id, new_album_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void address_ip(String address_ip, BaseObserver<String> observer) {
sApiServer.address_ip(address_ip).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
// onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
// com.blankj.utilcode.util.ToastUtils.showShort(t.toString());
}
});
}
public void deleteAlbum(String id, int type, BaseObserver<String> observer) {
if (type == 1) {
sApiServer.deleteAlbumImage(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
} else {
sApiServer.deleteAlbum(id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
}
public void likeAlbum(String albumId, BaseObserver<String> observer) {
sApiServer.likeAlbum(albumId).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void getRealNameResult(String orderNo, BaseObserver<String> observer) {
sApiServer.getRealNameResult(orderNo).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void changeRoom(String roomId, String userId, BaseObserver<String> observer) {
sApiServer.changeRoom(roomId, "-99").enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void changeRoomType(String roomId, String type, BaseObserver<String> observer) {
sApiServer.changeRoomType(roomId, type).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
ToastUtils.showShort(t.toString());
}
});
}
public void onNextRetu
(Response<BaseModel<String>> response, BaseObserver<String> observer) {
if (response.code() == 200) {
BaseModel<String> string = response.body();
if (string != null) {
int code = string.getCode();
if (code == 1) {
observer.onNext(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);
}
ToastUtils.showShort(string.getMsg());
} else {
ToastUtils.showShort(string.getMsg());
}
}
}
}
/// 获取活动礼物列表
public void getBoxGiftList(String giftBagId, String
roomId, BaseObserver<BlindBoxBean> observer) {
sApiServer.getBoxGiftList(giftBagId, roomId).enqueue(new Callback<BaseModel<BlindBoxBean>>() {
@Override
public void onResponse(Call<BaseModel<BlindBoxBean>> call, Response<BaseModel<BlindBoxBean>> response) {
if (response.code() == 200) {
BaseModel<BlindBoxBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<BlindBoxBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
/// 巡乐会
public void getBoxGiftListXLH(String roomId, BaseObserver<BlindBoxBean> observer) {
sApiServer.getBoxGiftListXLH(roomId).enqueue(new Callback<BaseModel<BlindBoxBean>>() {
@Override
public void onResponse(Call<BaseModel<BlindBoxBean>> call, Response<BaseModel<BlindBoxBean>> response) {
if (response.code() == 200) {
BaseModel<BlindBoxBean> baseModel = response.body();
observer.onNext(baseModel.getData());
}
}
@Override
public void onFailure(Call<BaseModel<BlindBoxBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
/// 巡乐会抽奖
public void xlhChou(String roomId, String
num, BaseObserver<List<XlhDrawBean>> observer) {
sApiServer.xlhChou(roomId, num).enqueue(new Callback<BaseModel<List<XlhDrawBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<XlhDrawBean>>> call, Response<BaseModel<List<XlhDrawBean>>> response) {
if (response.code() == 200) {
BaseModel<List<XlhDrawBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
if (baseModel != null && baseModel.getData() != null) {
observer.onNext(baseModel.getData());
}
} else {
observer.onNext(null);
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<XlhDrawBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
/// 盲盒转盘抽奖
public void drawGiftList(String giftBagId, String gift_user_ids, String roomId, String num, String heart_id,String auction_id, BaseObserver<BlindReslutBean> observer) {
sApiServer.drawGiftList(giftBagId, gift_user_ids, roomId, num, heart_id, auction_id).enqueue(new Callback<BaseModel<BlindReslutBean>>() {
@Override
public void onResponse(Call<BaseModel<BlindReslutBean>> call, Response<BaseModel<BlindReslutBean>> response) {
if (response.code() == 200) {
BaseModel<BlindReslutBean> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else {
observer.onNext(null);
ToastUtils.showShort(baseModel.getMsg());
}
}
}
@Override
public void onFailure(Call<BaseModel<BlindReslutBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getMyRecord(String giftBagId, String page, String
pageSize, BaseObserver<List<GiftBean>> observer) {
sApiServer.getMyRecord(giftBagId, page, pageSize).enqueue(new Callback<BaseModel<List<GiftBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBean>>> call, Response<BaseModel<List<GiftBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void xlhAllRecord(String roomId, String page, String
pageSize,int type, BaseObserver<List<GiftBean>> observer) {
if (type==1) {
sApiServer.xlhAllRecord(roomId, page, pageSize).enqueue(new Callback<BaseModel<List<GiftBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBean>>> call, Response<BaseModel<List<GiftBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}else {
sApiServer.xlXH_RANking(roomId,page,pageSize).enqueue(new Callback<BaseModel<List<GiftBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBean>>> call, Response<BaseModel<List<GiftBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
LogUtils.e("xlXH_RANking", response.body().toString());
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
}
public void xlhMyRecord(String roomId, String page, String
pageSize, BaseObserver<List<GiftBean>> observer) {
sApiServer.xlhMyRecord(roomId, page, pageSize).enqueue(new Callback<BaseModel<List<GiftBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBean>>> call, Response<BaseModel<List<GiftBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void getAllRecord(String giftBagId, String page, String
pageSize, BaseObserver<List<GiftBean>> observer) {
sApiServer.getAllRecord(giftBagId, page, pageSize).enqueue(new Callback<BaseModel<List<GiftBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<GiftBean>>> call, Response<BaseModel<List<GiftBean>>> response) {
if (response.code() == 200) {
BaseModel<List<GiftBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}
}
}
@Override
public void onFailure(Call<BaseModel<List<GiftBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void giftSend(String send_id, BaseObserver<String> observer) {
sApiServer.giftSend(send_id).enqueue(new Callback<BaseModel<String>>() {
@Override
public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
onNextRetu(response, observer);
}
@Override
public void onFailure(Call<BaseModel<String>> call, Throwable t) {
t.printStackTrace();
}
});
}
public void roomUserCharmList(String room_id, String
user_id, BaseObserver<List<RoomUserCharmListBean>> observer) {
sApiServer.roomUserCharmList(room_id, user_id).enqueue(new Callback<BaseModel<List<RoomUserCharmListBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RoomUserCharmListBean>>> call, Response<BaseModel<List<RoomUserCharmListBean>>> response) {
if (response.code() == 200) {
BaseModel<List<RoomUserCharmListBean>> baseModel = response.body();
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
} else if (baseModel.getCode() == 0) {
observer.onNext(null);
}
}
}
@Override
public void onFailure(Call<BaseModel<List<RoomUserCharmListBean>>> call, Throwable t) {
t.printStackTrace();
}
});
}
}