语圈基本完成

2、个人主页完成

moduleUtil/src/main/java/com/qxcm/moduleutil/http/RetrofitClient.java

@@ -23,6 +23,9 @@ import com.qxcm.moduleutil.bean.RealNameBean;
 import com.qxcm.moduleutil.bean.RewardUserBean;
 import com.qxcm.moduleutil.bean.RoonGiftModel;
 import com.qxcm.moduleutil.bean.UserBean;
+import com.qxcm.moduleutil.bean.UserInfo;
+import com.qxcm.moduleutil.bean.UserTagBean;
+import com.qxcm.moduleutil.utils.SpUtil;
 import com.qxcm.moduleutil.utils.SystemUtils;
 import com.qxcm.moduleutil.utils.logger.DataLogger;
 import com.qxcm.moduleutil.utils.logger.DataLoggingInterceptor;
@@ -190,6 +193,8 @@ public class RetrofitClient {
         sApiServer.switchAccounts(loginId).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
+
+
     public void userUpdate(Map<String, String> map, BaseObserver<UserBean> observer) {
         sApiServer.userUpdate(map).compose(new DefaultTransformer<>()).subscribe(observer);
     }
@@ -221,39 +226,11 @@ public class RetrofitClient {
         sApiServer.getOfficialNotice(page,page_limit,type).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
-    public void getAlbumList(String page,String page_limit,BaseObserver<List<AlbumBean>> observer){
-        sApiServer.getAlbumList(page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
+    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);
     }
 
-    public void createAlbum(String name,String image,BaseObserver<String> observer) {
-        sApiServer.createAlbum(name,image).enqueue(new Callback<BaseModel<String>>() {
-            @Override
-            public void onResponse(Call<BaseModel<String>> call, Response<BaseModel<String>> response) {
-                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 {
-                                CommonAppContext.getInstance().clearLoginInfo();
-                            } catch (ClassNotFoundException e) {
-                                throw new RuntimeException(e);
-                            }
-                            com.blankj.utilcode.util.ToastUtils.showShort(string.getMsg());
-                        }
-                    }
 
-                }
-            }
-
-            @Override
-            public void onFailure(Call<BaseModel<String>> call, Throwable t) {
-                com.blankj.utilcode.util.ToastUtils.showShort(t.toString());
-            }
-        });
-    }
 
     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);
@@ -272,36 +249,6 @@ public class RetrofitClient {
         sApiServer.topicList(page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
-    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) {
-                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 {
-                                CommonAppContext.getInstance().clearLoginInfo();
-                            } catch (ClassNotFoundException e) {
-                                throw new RuntimeException(e);
-                            }
-                            com.blankj.utilcode.util.ToastUtils.showShort(string.getMsg());
-                        }
-                    }
-
-                }
-            }
-
-            @Override
-            public void onFailure(Call<BaseModel<String>> call, Throwable t) {
-                com.blankj.utilcode.util.ToastUtils.showShort(t.toString());
-            }
-        });
-    }
 
     public void getCategories(BaseObserver<List<HeatedBean>> observer){//动态顶部热门话题
         sApiServer.getCategories().compose(new DefaultTransformer<>()).subscribe(observer);
@@ -311,63 +258,46 @@ public class RetrofitClient {
         sApiServer.getCircleList(page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
-    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) {
-                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 {
-                                CommonAppContext.getInstance().clearLoginInfo();
-                            } catch (ClassNotFoundException e) {
-                                throw new RuntimeException(e);
-                            }
-                            com.blankj.utilcode.util.ToastUtils.showShort(string.getMsg());
-                        }
-                    }
+    public void getCircleUserList(String user_id,String page,String page_limit,BaseObserver<List<CircleListBean>> observer){//用户主页动态列表
+        sApiServer.getCircleUserList(user_id,page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+    public void topicId(String topic_id,BaseObserver<List<CircleListBean>> observer){//动态列表
+        sApiServer.topicId(topic_id).compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+    public void zoneDetail(String topic_id,BaseObserver<CircleListBean> observer){//动态列表
+        sApiServer.zoneDetail(topic_id).compose(new DefaultTransformer<>()).subscribe(observer);
+    }
 
-                }
-            }
-
-            @Override
-            public void onFailure(Call<BaseModel<String>> call, Throwable t) {
-                com.blankj.utilcode.util.ToastUtils.showShort(t.toString());
-            }
-        });
+    public void getUserHome(String user_id,BaseObserver<UserInfo> observer){
+        sApiServer.getUserHome(user_id).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
     public void getCommentList(String id, String page, String page_limit, BaseObserver<CommentBean> observer){
         sApiServer.getCommentList(id,page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
     }
 
-    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>>() {
+    public void getMyInfo(BaseObserver<UserInfo> observer){//点击我的获取数据
+        sApiServer.getMyInfo().compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+
+    public void getUserTagList(BaseObserver<List<UserTagBean>> observer){
+        sApiServer.getUserTagList().compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+
+    public void getLikeList(String id,BaseObserver<List<CircleListBean.LikeList>> observer){
+        sApiServer.getLikeList(id).compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+
+    public void getAlbumDetail(String albumId, String pwd,String page,String page_limit,BaseObserver<AlbumBean> observer){
+        sApiServer.getAlbumDetail(albumId,pwd,page,page_limit).compose(new DefaultTransformer<>()).subscribe(observer);
+    }
+
+    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) {
-                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 {
-                                CommonAppContext.getInstance().clearLoginInfo();
-                            } catch (ClassNotFoundException e) {
-                                throw new RuntimeException(e);
-                            }
-                            com.blankj.utilcode.util.ToastUtils.showShort(string.getMsg());
-                        }
-                    }
-
-                }else {
-                    ToastUtils.showShort("评论失败");
-                }
+                onNextRetu(response,observer);
             }
 
             @Override
@@ -377,4 +307,288 @@ public class RetrofitClient {
         });
     }
 
+
+    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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.ToastUtils.showShort(t.toString());
+                if (t.toString().contains("登录失效")){
+                    try {
+                        CommonAppContext.getInstance().clearLoginInfo();
+                    } catch (ClassNotFoundException e) {
+                        throw new RuntimeException(e);
+                    }
+                }
+            }
+        });
+    }
+
+    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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                   com.blankj.utilcode.util.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) {
+                    com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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) {
+                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) {
+                    com.blankj.utilcode.util.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) {
+                    com.blankj.utilcode.util.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) {
+                com.blankj.utilcode.util.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 {
+                        CommonAppContext.getInstance().clearLoginInfo();
+                    } catch (ClassNotFoundException e) {
+                        throw new RuntimeException(e);
+                    }
+                    com.blankj.utilcode.util.ToastUtils.showShort(string.getMsg());
+                }
+            }
+
+        }
+    }
+
 }