YUSHENG/yusheng-android
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

封版羽声，作为最后的基础版

Browse Source
This commit is contained in:
liangxiaojiang
2025-08-04 17:15:03 +08:00
parent 86b32f65d4
commit 5a6600a7e3
377 changed files with 384105 additions and 357697 deletions
Download Patch File Download Diff File Expand all files Collapse all files

226
moduleUtil/src/main/java/com/qxcm/moduleutil/http/RetrofitClient.java
View File

@@ -18,6 +18,7 @@ import com.google.gson.reflect.TypeToken;
import com.qxcm.moduleutil.base.CommonAppContext;
import com.qxcm.moduleutil.bean.AlbumBean;
import com.qxcm.moduleutil.bean.AppPay;
import com.qxcm.moduleutil.bean.AppUpdateModel;
import com.qxcm.moduleutil.bean.BannerModel;
import com.qxcm.moduleutil.bean.BindType;
import com.qxcm.moduleutil.bean.BlackUserBean;
@@ -25,11 +26,14 @@ import com.qxcm.moduleutil.bean.CharmRankingResp;
import com.qxcm.moduleutil.bean.CircleListBean;
import com.qxcm.moduleutil.bean.CommentBean;
import com.qxcm.moduleutil.bean.ExpandColumnBean;
import com.qxcm.moduleutil.bean.FirstChargeBean;
import com.qxcm.moduleutil.bean.FirstChargeGiftBean;
import com.qxcm.moduleutil.bean.GiftBoxBean;
import com.qxcm.moduleutil.bean.GiftBoxRecordBean;
import com.qxcm.moduleutil.bean.GiftLabelBean;
import com.qxcm.moduleutil.bean.GiftName;
import com.qxcm.moduleutil.bean.GiftPackBean;
import com.qxcm.moduleutil.bean.GiftUserWallBean;
import com.qxcm.moduleutil.bean.HeadlineBean;
import com.qxcm.moduleutil.bean.HeatedBean;
import com.qxcm.moduleutil.bean.HostBean;
@@ -39,10 +43,12 @@ import com.qxcm.moduleutil.bean.MyCpRoom;
import com.qxcm.moduleutil.bean.MyFootResp;
import com.qxcm.moduleutil.bean.MyRoomBean;
import com.qxcm.moduleutil.bean.NewsDataBean;
import com.qxcm.moduleutil.bean.NewsMessageList;
import com.qxcm.moduleutil.bean.PersonaltyBean;
import com.qxcm.moduleutil.bean.PlaceholderBean;
import com.qxcm.moduleutil.bean.RealNameBean;
import com.qxcm.moduleutil.bean.RechargeBean;
import com.qxcm.moduleutil.bean.RelationCardBean;
import com.qxcm.moduleutil.bean.RevenueBean;
import com.qxcm.moduleutil.bean.RewardUserBean;
import com.qxcm.moduleutil.bean.RoomBgBean;
@@ -60,6 +66,7 @@ import com.qxcm.moduleutil.bean.TopRoom;
import com.qxcm.moduleutil.bean.UserBean;
import com.qxcm.moduleutil.bean.UserFollowBean;
import com.qxcm.moduleutil.bean.UserInfo;
import com.qxcm.moduleutil.bean.UserOnlineStatusBean;
import com.qxcm.moduleutil.bean.UserTagBean;
import com.qxcm.moduleutil.bean.WalletBean;
import com.qxcm.moduleutil.bean.WalletConfig;
@@ -223,6 +230,9 @@ public class RetrofitClient {
// 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);
@@ -290,18 +300,60 @@ public class RetrofitClient {
});
}
public void withdrawal(String number, String type, String sms_code, BaseObserver<String> observer){
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){
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
if (baseModel.getCode()==1) {
if (baseModel.getCode() == 1) {
baseModel.setData(baseModel.getMsg());
observer.onNext(baseModel.getData());
}else {
} else {
baseModel.setData(baseModel.getMsg());
observer.onNext(baseModel.getData());
}
@@ -321,50 +373,56 @@ public class RetrofitClient {
});
}
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).compose(new DefaultTransformer<>()).subscribe(observer);
public void getMessagetitle(String type, String page, String page_limit, BaseObserver<List<NewsMessageList>> observer) {
sApiServer.getMessagetitle(type, page, page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void getRoomRank(String roomId, String type, String time_type, String page, String page_limit, BaseObserver<List<CharmRankingResp>> observer){
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).compose(new DefaultTransformer<>()).subscribe(observer);
}
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);
}
public void wealthRanking(String ranking_type, String type, BaseObserver<PlaceholderBean> observer){
if (ranking_type.equals("0")){
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")) {
} 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")) {
} else if (ranking_type.equals("3")) {
sApiServer.guildRanking().compose(new DefaultTransformer<>()).subscribe(observer);
}else if (ranking_type.equals("4")){
} else if (ranking_type.equals("4")) {
sApiServer.loveRanking(type).compose(new DefaultTransformer<>()).subscribe(observer);
}
}
public void dailyTasksBoxRecord(BaseObserver<List<GiftBoxRecordBean>> observer){
public void dailyTasksBoxRecord(BaseObserver<List<GiftBoxRecordBean>> observer) {
sApiServer.dailyTasksBoxRecord().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void packIncome(String page,String page_limit,BaseObserver<List<MyBagDataBean>> observer){
sApiServer.packIncome(page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void packOutcome(String page,String page_limit,BaseObserver<List<MyBagDataBean>> observer){
sApiServer.packOutcome(page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
public void packIncome(String page, String page_limit, BaseObserver<List<MyBagDataBean>> observer) {
sApiServer.packIncome(page, page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void giftPack(BaseObserver<List<GiftPackBean>> observer){
public void packOutcome(String page, String page_limit, BaseObserver<List<MyBagDataBean>> observer) {
sApiServer.packOutcome(page, page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void giftPack(BaseObserver<List<GiftPackBean>> observer) {
sApiServer.giftPack().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void tasksLihen(BaseObserver<GiftBoxBean> observer){
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){
if (response.code() == 200) {
String json = null;
try {
json = response.body().string();
Type type = new TypeToken<BaseModel<GiftBoxBean>>(){}.getType();
Type type = new TypeToken<BaseModel<GiftBoxBean>>() {
}.getType();
BaseModel<GiftBoxBean> baseModel = GsonUtils.fromJson(json, type);
observer.onNext(baseModel.getData());
} catch (IOException e) {
@@ -381,12 +439,12 @@ public class RetrofitClient {
});
}
public void dailyTasksOpenBox(String gift_box_id, BaseObserver<GiftName> observer){
public void dailyTasksOpenBox(String gift_box_id, BaseObserver<GiftName> observer) {
sApiServer.dailyTasksOpenBox(gift_box_id).compose(new DefaultTransformer<>()).subscribe(observer);
}
public void sendHeadine(String content, String money,String roomId, BaseObserver<String> observer) {
sApiServer.sendHeadine(content, money,roomId).enqueue(new Callback<BaseModel<String>>() {
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);
@@ -475,6 +533,7 @@ public class RetrofitClient {
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) {
@@ -553,7 +612,7 @@ public class RetrofitClient {
sApiServer.authorization().enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
if (response.code()==200){
if (response.code() == 200) {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
@@ -618,9 +677,9 @@ public class RetrofitClient {
sApiServer.getExpandColumn(type).compose(new DefaultTransformer<>()).subscribe(observer);
}
//获取官方公告数据或者系统消息，根据type区分 type=1是系统消息，type=2是官方公告
public void getOfficialNotice(String page, String page_limit, String type, BaseObserver<List<NewsDataBean>> observer) {
sApiServer.getOfficialNotice(page, page_limit, type).compose(new DefaultTransformer<>()).subscribe(observer);
//获取官方公告数据或者系统消息，
public void getOfficialNotice(BaseObserver<NewsDataBean> observer) {
sApiServer.getOfficialNotice().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void getAlbumList(String page, String page_limit, String userId, BaseObserver<List<AlbumBean>> observer) {
@@ -650,8 +709,8 @@ public class RetrofitClient {
});
}
public void getMyRoom(String type, BaseObserver<List<MyRoomBean>> observer) {
sApiServer.getMyRoom(type, "1", "20").enqueue(new Callback<BaseModel<List<MyRoomBean>>>() {
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) {
@@ -949,11 +1008,15 @@ public class RetrofitClient {
});
}
public void auctionEnd(String auctionId, BaseObserver<String> observer) {
sApiServer.auctionEnd(auctionId).enqueue(new Callback<BaseModel<String>>() {
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) {
onNextRetu(response, observer);
if (response.code() == 200) {
observer.onNext(null);
}
// onNextRetu(response, observer);
}
@Override
@@ -1160,6 +1223,10 @@ public class RetrofitClient {
});
}
public void firstChargeGift(BaseObserver<FirstChargeGiftBean> observer) {
sApiServer.firstChargeGift().compose(new DefaultTransformer<>()).subscribe(observer);
}
public void applyPit(String roomId, String pitNumber, BaseObserver<String> observer) {
sApiServer.applyPit(roomId, pitNumber).enqueue(new Callback<BaseModel<String>>() {
@Override
@@ -1316,6 +1383,59 @@ public class RetrofitClient {
});
}
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).compose(new DefaultTransformer<>()).subscribe(observer);
}
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) {
com.blankj.utilcode.util.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) {
com.blankj.utilcode.util.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<BaseModel<String>>() {
@Override
@@ -1338,9 +1458,9 @@ public class RetrofitClient {
try {
String json = response.body().string();
BaseModel<String> baseModel = GsonUtils.fromJson(json, BaseModel.class);
if (baseModel.getCode()==1) {
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else {
} else {
com.hjq.toast.ToastUtils.show(baseModel.getMsg());
}
} catch (IOException e) {
@@ -1594,6 +1714,39 @@ public class RetrofitClient {
});
}
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) {
com.blankj.utilcode.util.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 removeBlackList(String user_id, BaseObserver<String> observer) {
sApiServer.removeBlackList(user_id).enqueue(new Callback<BaseModel<String>>() {
@Override
@@ -1742,6 +1895,7 @@ public class RetrofitClient {
int code = string.getCode();
if (code == 1) {
observer.onNext(string.getMsg());
} else if (code == 301) {
try {
CommonAppContext.getInstance().clearLoginInfo();