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:
骆召亮
2025-11-22 18:38:49 +08:00
parent 5eac6d302c
commit 2a6d2e4709
45 changed files with 972 additions and 251 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
BaseModule/src/main/java/com/xscm/moduleutil/http/ApiServer.java
View File

@@ -856,4 +856,7 @@ public interface ApiServer {
@POST(Constants.ROOM_USER_RECONNECT)
Call<BaseModel<String>> roomUserReconnect(@Field("room_id") String room_id);
@GET(Constants.GET_CP_ZONE)
Call<BaseModel<HeartCpBean>> getCpRoom(@Query("user_id") String userId);
}

92
BaseModule/src/main/java/com/xscm/moduleutil/http/RetrofitClient.java
View File

@@ -141,7 +141,9 @@ public class RetrofitClient {
mRetrofit = provideRetrofit(provideOkHttpClient());
sApiServer = mRetrofit.create(ApiServer.class);
}
private CPListener cpListener;
public void CpListener(CPListener cpListenter) {
this.cpListener = cpListenter;
}
@@ -604,7 +606,7 @@ public class RetrofitClient {
});
}
public void singerSongCut(String id,BaseObserver<String> observer) {
public void singerSongCut(String id, BaseObserver<String> observer) {
sApiServer.singerSongCut(id).enqueue(new Callback<BaseModel<String>>() {
@Override
@@ -632,7 +634,7 @@ public class RetrofitClient {
});
}
public void singerSongTop(String id,BaseObserver<String> observer){
public void singerSongTop(String id, BaseObserver<String> observer) {
sApiServer.singerSongTop(id).enqueue(new Callback<BaseModel<String>>() {
@Override
@@ -662,8 +664,8 @@ public class RetrofitClient {
});
}
public void singerSongCount(String roomId,BaseObserver<SingerSongCount> observer){
sApiServer.singerSongCount(roomId).enqueue(new Callback<BaseModel<SingerSongCount>>(){
public void singerSongCount(String roomId, BaseObserver<SingerSongCount> observer) {
sApiServer.singerSongCount(roomId).enqueue(new Callback<BaseModel<SingerSongCount>>() {
@Override
public void onResponse(Call<BaseModel<SingerSongCount>> call, Response<BaseModel<SingerSongCount>> response) {
@@ -678,7 +680,7 @@ public class RetrofitClient {
} catch (ClassNotFoundException e) {
}
}else {
} else {
ToastUtils.showShort(baseModel.getMsg());
}
}
@@ -3094,19 +3096,19 @@ public class RetrofitClient {
sApiServer.roomGift(room_id, gift_id, gift_num, to_uid, type, pit_number, heart_id).enqueue(new Callback<BaseModel<RoomGiftData>>() {
@Override
public void onResponse(Call<BaseModel<RoomGiftData>> call, Response<BaseModel<RoomGiftData>> response) {
if (response.code()==200){
if (response.code() == 200) {
BaseModel<RoomGiftData> data = response.body();
if (data.getCode()==1) {
if (data.getData().getCp_type()!=null){
if (cpListener !=null){
if (data.getCode() == 1) {
if (data.getData().getCp_type() != null) {
if (cpListener != null) {
cpListener.onSendCpMsg(data.getData());
}
}
observer.onNext(data.getData());
}else if (data.getCode()==0){
} else if (data.getCode() == 0) {
ToastUtils.showShort(data.getMsg());
}else if (data.getCode()==301) {
} else if (data.getCode() == 301) {
try {
ToastUtils.showShort(data.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
@@ -3124,24 +3126,24 @@ public class RetrofitClient {
});
}
public void cpGiveGift(String user_id, String gift_id,String room_id,BaseObserver<RoomGiftData> observer) {
sApiServer.cpGiveGift(user_id, gift_id,room_id).enqueue(new Callback<BaseModel<RoomGiftData>>() {
public void cpGiveGift(String user_id, String gift_id, String room_id, BaseObserver<RoomGiftData> observer) {
sApiServer.cpGiveGift(user_id, gift_id, room_id).enqueue(new Callback<BaseModel<RoomGiftData>>() {
@Override
public void onResponse(Call<BaseModel<RoomGiftData>> call, Response<BaseModel<RoomGiftData>> response) {
if (response.code()==200){
if (response.code() == 200) {
BaseModel<RoomGiftData> data = response.body();
if (data.getCode()==1) {
if (data.getData().getCp_type()!=null){
if (cpListener !=null){
if (data.getCode() == 1) {
if (data.getData().getCp_type() != null) {
if (cpListener != null) {
cpListener.onSendCpMsg(data.getData());
}
}
observer.onNext(data.getData());
}else if (data.getCode()==0){
} else if (data.getCode() == 0) {
ToastUtils.showShort(data.getMsg());
}else if (data.getCode()==301) {
} else if (data.getCode() == 301) {
try {
ToastUtils.showShort(data.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
@@ -3154,7 +3156,7 @@ public class RetrofitClient {
@Override
public void onFailure(Call<BaseModel<RoomGiftData>> call, Throwable t) {
LogUtils.e("cpGiveGift",t.fillInStackTrace());
LogUtils.e("cpGiveGift", t.fillInStackTrace());
}
});
}
@@ -3403,7 +3405,6 @@ public class RetrofitClient {
}
public void agreeSong(String room_id, String type, BaseObserver<String> observer) {
sApiServer.agreeSong(room_id, type).enqueue(new Callback<BaseModel<String>>() {
@Override
@@ -3623,23 +3624,23 @@ public class RetrofitClient {
});
}
public void getFriendListMore(String user_id,String relation_id,BaseObserver<List<RelationshipBean>> observer){
sApiServer.getFriendListMore(user_id,relation_id).enqueue(new Callback<BaseModel<List<RelationshipBean>>>() {
public void getFriendListMore(String user_id, String relation_id, BaseObserver<List<RelationshipBean>> observer) {
sApiServer.getFriendListMore(user_id, relation_id).enqueue(new Callback<BaseModel<List<RelationshipBean>>>() {
@Override
public void onResponse(Call<BaseModel<List<RelationshipBean>>> call, Response<BaseModel<List<RelationshipBean>>> response) {
if (response.code()==200){
if (response.code() == 200) {
BaseModel<List<RelationshipBean>> baseModel = response.body();
if (baseModel.getCode()==1) {
if (baseModel.getCode() == 1) {
observer.onNext(baseModel.getData());
}else if (baseModel.getCode()==301){
} else if (baseModel.getCode() == 301) {
try {
ToastUtils.showShort(baseModel.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}else {
} else {
ToastUtils.showShort(baseModel.getMsg());
}
}
@@ -3647,7 +3648,7 @@ public class RetrofitClient {
@Override
public void onFailure(Call<BaseModel<List<RelationshipBean>>> call, Throwable t) {
LogUtils.e("getFriendListMore",t.toString());
LogUtils.e("getFriendListMore", t.toString());
}
});
}
@@ -3783,22 +3784,22 @@ public class RetrofitClient {
});
}
public void getFriendList(String userId,String page,String page_limit,BaseObserver<RelationBean> observer) {
public void getFriendList(String userId, String page, String page_limit, BaseObserver<RelationBean> observer) {
sApiServer.getFriendList(userId, page, page_limit).enqueue(new Callback<BaseModel<RelationBean>>() {
@Override
public void onResponse(Call<BaseModel<RelationBean>> call, Response<BaseModel<RelationBean>> response) {
if (response.code()==200){
if (response.code() == 200) {
BaseModel<RelationBean> body = response.body();
if (body.getCode()==1){
if (body.getCode() == 1) {
observer.onNext(body.getData());
}else if (body.getCode()==301){
} else if (body.getCode() == 301) {
try {
ToastUtils.showShort(body.getMsg());
CommonAppContext.getInstance().clearLoginInfo();
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}else {
} else {
ToastUtils.showShort(body.getMsg());
}
}
@@ -3806,7 +3807,7 @@ public class RetrofitClient {
@Override
public void onFailure(Call<BaseModel<RelationBean>> call, Throwable t) {
LogUtils.e("getFriendList",t.fillInStackTrace());
LogUtils.e("getFriendList", t.fillInStackTrace());
}
});
}
@@ -4555,4 +4556,27 @@ public class RetrofitClient {
});
}
public void getCpRoom(String userId,BaseObserver<HeartCpBean> observer) {
sApiServer.getCpRoom(userId).enqueue(new Callback<BaseModel<HeartCpBean>>() {
@Override
public void onResponse(Call<BaseModel<HeartCpBean>> call, Response<BaseModel<HeartCpBean>> response) {
if (response.code() == 200) {
BaseModel<HeartCpBean> 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<HeartCpBean>> call, Throwable t) {
t.printStackTrace();
}
});
}
}