搜书大师 v23.2版本的 MD5 值为:5ee433f6456b6278bd6e80a5d44df55e

以下内容为反编译后的 MRManager.java 源代码,内容仅作参考


package com.flyersoft.baseapplication.http;

import android.content.Context;
import com.flyersoft.baseapplication.been.BoardBean;
import com.flyersoft.baseapplication.been.Book;
import com.flyersoft.baseapplication.been.BookAndDiscuss;
import com.flyersoft.baseapplication.been.BookContent;
import com.flyersoft.baseapplication.been.BookDetail;
import com.flyersoft.baseapplication.been.CatalogDetail;
import com.flyersoft.baseapplication.been.CommentAndDiscuss;
import com.flyersoft.baseapplication.been.Complaint;
import com.flyersoft.baseapplication.been.ConsumeRecord;
import com.flyersoft.baseapplication.been.DefaultCode;
import com.flyersoft.baseapplication.been.DefaultInfo;
import com.flyersoft.baseapplication.been.DetailCatalogDetail;
import com.flyersoft.baseapplication.been.DisRecord;
import com.flyersoft.baseapplication.been.DisRecordResult;
import com.flyersoft.baseapplication.been.Discuss;
import com.flyersoft.baseapplication.been.DiscussAndBookList;
import com.flyersoft.baseapplication.been.DiscussContent;
import com.flyersoft.baseapplication.been.Like;
import com.flyersoft.baseapplication.been.MovmentInfo;
import com.flyersoft.baseapplication.been.Order;
import com.flyersoft.baseapplication.been.VerifCode;
import com.flyersoft.baseapplication.been.account.AmountInfo;
import com.flyersoft.baseapplication.been.account.AttenKeepLikes;
import com.flyersoft.baseapplication.been.account.ChargeRecords;
import com.flyersoft.baseapplication.been.account.LevelData;
import com.flyersoft.baseapplication.been.account.Movement;
import com.flyersoft.baseapplication.been.account.PayConfig;
import com.flyersoft.baseapplication.been.account.SignInData;
import com.flyersoft.baseapplication.been.account.TencentYunConfig;
import com.flyersoft.baseapplication.been.account.UploadUserDateResult;
import com.flyersoft.baseapplication.been.account.UserInfo;
import com.flyersoft.baseapplication.been.account.UserMessage;
import com.flyersoft.baseapplication.been.account.WXAccessToken;
import com.flyersoft.baseapplication.been.account.WXLandingConfig;
import com.flyersoft.baseapplication.been.account.ZFBLandingConfig;
import com.flyersoft.baseapplication.been.discuss.DiscussConfig;
import com.flyersoft.baseapplication.been.seekbook.BookList;
import com.flyersoft.baseapplication.been.seekbook.BookListInfo;
import com.flyersoft.baseapplication.been.seekbook.BookThirdShuPing;
import com.flyersoft.baseapplication.been.seekbook.CommentReply;
import com.flyersoft.baseapplication.been.seekbook.CommentSubmiter;
import com.flyersoft.baseapplication.been.seekbook.Comments;
import com.flyersoft.baseapplication.been.seekbook.DiscussUpload;
import com.flyersoft.baseapplication.been.seekbook.Replys;
import com.flyersoft.baseapplication.been.seekbook.UserTask;
import com.flyersoft.baseapplication.config.HttpBaseConfig;
import com.flyersoft.baseapplication.http.biz.AccountBiz;
import com.flyersoft.baseapplication.http.biz.ActivityBookBiz;
import com.flyersoft.baseapplication.http.biz.BookListBiz;
import com.flyersoft.baseapplication.http.biz.CatalogBookBiz;
import com.flyersoft.baseapplication.http.biz.CommentBiz;
import com.flyersoft.baseapplication.http.biz.DetailCatalogBookBiz;
import com.flyersoft.baseapplication.http.biz.DiscussBiz;
import com.flyersoft.baseapplication.http.biz.IdentifyBiz;
import com.flyersoft.baseapplication.http.biz.ModuleBookBiz;
import com.flyersoft.baseapplication.http.biz.SearchBookBiz;
import com.flyersoft.baseapplication.http.biz.TTSBiz;
import com.flyersoft.baseapplication.http.biz.ThirdBiz;
import com.flyersoft.baseapplication.http.body.BaseRequest;
import com.flyersoft.baseapplication.http.body.LandingCodeBody;
import com.flyersoft.baseapplication.http.body.PayBody;
import com.flyersoft.baseapplication.http.body.SearchBookBody;
import com.flyersoft.baseapplication.http.body.WXAccessTokenBody;
import com.flyersoft.baseapplication.http.callback.RequestCallBack;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import java.util.List;

public class MRManager {
    private static MRManager mRManager;
    private AccountBiz accountBiz;
    private ActivityBookBiz activityBookBiz;
    private BookListBiz bookListBiz;
    private CatalogBookBiz catalogBookBiz;
    private CommentBiz commentBiz;
    private Context context;
    private DetailCatalogBookBiz detailCatalogBookBiz;
    private DiscussBiz discussBiz;
    private IdentifyBiz identifyBiz;
    private ModuleBookBiz moduleBookBiz;
    private SearchBookBiz searchBookBiz;

    private MRManager(Context context) {
        this.context = context;
    }

    public static synchronized MRManager getInstance(Context context) {
        MRManager mRManager2;
        synchronized (MRManager.class) {
            if (mRManager == null) {
                mRManager = new MRManager(context);
            }
            mRManager2 = mRManager;
        }
        return mRManager2;
    }

    public Observable<BaseRequest> addBookList(BookList bookList) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.addBookList(bookList.toMap()).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> addDiscuss(DiscussUpload discuss) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.addDiscuss(discuss).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> addHeatDegreeByBook(String bookName, String bookAuthor) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.addHeatDegreeByBook(bookName, bookAuthor).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> addHeatDegreeByBookId(String bookId) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.addHeatDegreeByBookId(bookId).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public void addToSelf(String bookId, RequestCallBack<BookDetail> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.addToSelf(bookId, callback);
    }

    public Observable<BaseRequest> bookListInfoAdd(BookListInfo bookList) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.bookListInfoAdd(bookList.toMap()).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public void buyBook(String bookId, String chapterNums, boolean autoDebits, RequestCallBack<Boolean> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.buyBook(bookId, chapterNums, autoDebits, callback);
    }

    public Observable<BaseRequest<Integer>> checkBookListName(String listName) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.checkBookListName(listName).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<Boolean>> checkCodeForMobileTask(String smsCode, String mobile) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.checkCodeForMobileTask(smsCode, mobile);
    }

    public Observable<BaseRequest<Boolean>> checkSmsCode(String smsCode, String mobile) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.checkSmsCode(smsCode, mobile);
    }

    public Observable<BaseRequest<List<UserMessage>>> checkUserMsg(int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.checkUserMsg(from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> complaintData(Complaint complaint) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.complaintData(complaint).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<AmountInfo> consume(long money, String remark) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.consume(money, remark);
    }

    public Observable<BaseRequest> delBookListInfo(String listId, String infoIds) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.delBookListInfo(listId, infoIds).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> delCommByDisUser(Comments comments) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.delCommByDisUser(comments).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<DisRecordResult>> disRecord(DisRecord disRecord) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.disRecord(disRecord).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<DiscussConfig>> discontrol() {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.discontrol().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> editBookListIntro(String listId, String listIntro) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.editBookListIntro(listId, listIntro).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> editDisCont(Discuss discuss) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.editDisCont(discuss).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> editIcnAdnDataFile(String filePath, String fileName, int type) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.editIcnAdnDataFile(filePath, fileName, type);
    }

    public Observable<BaseRequest> editMsg(int doType, String idList) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.editMsg(doType, idList).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<UserInfo>> editPetName(String pName) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.editPetName(pName);
    }

    public Observable<BaseRequest> editUserBlackList(int type, String authorId) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.editUserBlackList(type, authorId).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<UserInfo>> editUserInfo(int editType, String editCont) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.editUserInfo(editType, editCont);
    }

    public Observable<BaseRequest<List<ConsumeRecord>>> findConsumeRecord() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.findConsumeRecord();
    }

    public Observable<BaseRequest<List<Discuss>>> findData(String softType, int from, int maxCount, String userName, String type) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.findData(softType, from, maxCount, userName, type);
    }

    public Observable<BaseRequest<DiscussContent>> findDisCont(String discussId, String blUid) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.findDisCont(discussId, blUid).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<UploadUserDateResult>>> findPathByUid() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.findPathByUid();
    }

    public Observable<BaseRequest<List<Order>>> findPayRecord() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.findPayRecord();
    }

    @Deprecated
    public Observable<WXAccessToken> getAccessToken(WXAccessTokenBody wXAccessTokenBody) {
        return new ThirdBiz("https://api.weixin.qq.com").getAccessToken(wXAccessTokenBody);
    }

    public void getActivityBooks(RequestCallBack<List<Book>> callback) {
        if (this.activityBookBiz == null) {
            this.activityBookBiz = new ActivityBookBiz(this.context);
        }
        this.activityBookBiz.getActivityBooks(callback);
    }

    public void getAmount(RequestCallBack<AmountInfo> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.getAmount(callback);
    }

    public Observable<BaseRequest<List<BoardBean>>> getBoards() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getBoards().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<CommentAndDiscuss>> getBookInfo(String bookName, String bookAuthor, String userName, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.getBookInfo(bookName, bookAuthor, userName, from, maxCount);
    }

    public void getBuyBookRecords(int from, int limitfinal, RequestCallBack<List<BookDetail>> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.getBuyBookRecords(from, limitfinal, callback);
    }

    public void getCategoryBooks(RequestCallBack<List<CatalogDetail>> callback) {
        if (this.catalogBookBiz == null) {
            this.catalogBookBiz = new CatalogBookBiz(this.context);
        }
        this.catalogBookBiz.getCatalogBooks(callback);
    }

    public void getChargeRecords(int from, int limitfinal, RequestCallBack<List<ChargeRecords>> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.getChargeRecords(from, limitfinal, callback);
    }

    public Observable<BaseRequest<List<Comments>>> getComments(String discussId, String blUid, int from, int maxCount, String userName) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.getComments(discussId, blUid, from, maxCount, userName);
    }

    public void getContent(String bookId, int chapterNo, String direction, RequestCallBack<BaseRequest<BookContent>> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.getContent(bookId, chapterNo, direction, callback);
    }

    public void getDetailCategoryBooks(String bookId, int from, int maxCountfinal, RequestCallBack<List<DetailCatalogDetail>> callback) {
        if (this.detailCatalogBookBiz == null) {
            this.detailCatalogBookBiz = new DetailCatalogBookBiz(this.context);
        }
        this.detailCatalogBookBiz.getCatalogBooks(bookId, from, maxCountfinal, callback);
    }

    public Observable<BaseRequest<List<Discuss>>> getDiscuss(int type, int from, int maxCount, String userName, int sortType) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.getDiscuss(type, from, maxCount, userName, sortType).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public void getModuleBooks(String moduleId, int from, int limit, RequestCallBack<List<BookDetail>> callback) {
        if (this.moduleBookBiz == null) {
            this.moduleBookBiz = new ModuleBookBiz(this.context);
        }
        this.moduleBookBiz.getModuleBooks(moduleId, from, limit, callback);
    }

    public void getSearchBooks(String keyWord, String categoryId, int from, int to, RequestCallBack<List<BookDetail>> callback) {
        if (this.searchBookBiz == null) {
            this.searchBookBiz = new SearchBookBiz(this.context);
        }
        this.searchBookBiz.getSearchBooks(new SearchBookBody("", keyWord, categoryId, "", from, to), callback);
    }

    public Observable<byte[]> getTTS(String tex, int spd) {
        return new TTSBiz(HttpBaseConfig.TTS_BAIDU).getTTS(tex, spd);
    }

    public Observable<BaseRequest<TencentYunConfig>> getTencentYunConfig(int type) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getTencentYunConfig(type);
    }

    public Observable<BaseRequest<UserInfo>> getUserInfo() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getUserInfo();
    }

    public Observable<BaseRequest<WXLandingConfig>> getWXLandingConfig(String auth_code) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getWXLandingConfig(auth_code);
    }

    public Observable<BaseRequest<PayConfig>> getWXPayInfo(PayBody payBody) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getWXPayInfo(payBody);
    }

    public Observable<ZFBLandingConfig> getZFBLandingConfig() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getZFBLandingConfig();
    }

    public Observable<DefaultInfo> getZFBPayInfo(PayBody payBody) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.getZFBPayInfo(payBody);
    }

    public Observable<BaseRequest> identify(String url) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.identify(url);
    }

    public void ifInSelf(String bookId, RequestCallBack<DefaultCode> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.ifInSelf(bookId, callback);
    }

    public Observable<BaseRequest<AttenKeepLikes>> keepAndAttenStr() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.keepAndAttenStr().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> likeData(Like disRecord) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.likeData(disRecord).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public void logOut(RequestCallBack<Boolean> callback) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        this.accountBiz.logOut(callback);
    }

    public Observable<BaseRequest> movementAdd(Movement movement) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.movementAdd(movement).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest> postEvent(String data) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.postEvent(data).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(Schedulers.io());
    }

    public Observable<BaseRequest<List<Discuss>>> queryActionData(String userName, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryActionData(userName, from, maxCount);
    }

    public Observable<BaseRequest<List<UserInfo>>> queryAttenByUser() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryAttenByUser().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<BookAndDiscuss>> queryBookByBookId(String bookId) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryBookByBookId(bookId).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookListInfo>>> queryBookList(String listId, String blUid, int skip, int maxCount) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.queryBookList(listId, blUid, skip, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookList>>> queryBookListByBookName(String bookName, int skip, int maxCount) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.queryBookListByBookName(bookName, skip, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookList>>> queryBookLists(int skip, int maxCount, int sortType) {
        if (this.bookListBiz == null) {
            this.bookListBiz = new BookListBiz(this.context);
        }
        return this.bookListBiz.queryBookLists(skip, maxCount, sortType).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookList>>> queryBookListsOfUser(String userId, int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryBookListsOfUser(userId, from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookAndDiscuss>>> queryBooksByTags(String tag, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryBooksByTags(tag, from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<Integer>> queryCommCountByBook(String bookName, String bookAuthor) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryCommCountByBook(bookName, bookAuthor).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Comments>>> queryCommListByUser(String userId, int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryCommListByUser(userId, from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Comments>>> queryCommsByBook(String bookName, String bookAuthor, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryCommsByBook(bookName, bookAuthor, from, maxCount);
    }

    public Observable<BaseRequest<MovmentInfo>> queryDataOfUser(String userName, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryDataOfUser(userName, from, maxCount);
    }

    public Observable<BaseRequest<DiscussAndBookList>> queryDisInfo(String dataId, String blUid, int dataType, int dataCate) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryDisInfo(dataId, blUid, dataType, dataCate).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Discuss>>> queryDisListByUser(String userId, int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryDisListByUser(userId, from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Discuss>>> queryDiscussByBook(String bookName, String bookAuthor, int from, int maxCount) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryDiscussByBook(bookName, bookAuthor, from, maxCount);
    }

    public Observable<BaseRequest<List<LevelData>>> queryGradeList() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryGradeList();
    }

    public Observable<BaseRequest<List<Movement>>> queryKeepByUser(int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryKeepByUser(from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<Integer>> queryMsgCount() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryMsgCount().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookThirdShuPing>>> queryPostUrls(String bookId, String bookName, String bookAuthor) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryPostUrls(bookId, bookName, bookAuthor);
    }

    public Observable<BaseRequest<List<Replys>>> queryReplyComms(String commId, String parentId, String blUid, int commType, int from, int maxCount) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.queryReplyComms(commId, parentId, blUid, commType, from, maxCount);
    }

    public Observable<BaseRequest<List<Replys>>> queryReplyListByUser(String userId, int from, int maxCount) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryReplyListByUser(userId, from, maxCount).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<BookAndDiscuss>>> querySBook(String userName, String bookName, String bookAuthor, String type) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.querySBook(userName, bookName, bookAuthor, type).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Discuss>>> queryShortComms(int from, int maxCount, String userName, int sortType) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.queryShortComms(from, maxCount, userName, sortType).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<SignInData>>> querySignInTaskList(int days) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.querySignInTaskList(days);
    }

    public Observable<BaseRequest<List<UserTask>>> queryTaskList() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.queryTaskList();
    }

    public Observable<BaseRequest<Object>> rechargePay(int count, String outNo) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.rechargePay(count, outNo);
    }

    public Observable<BaseRequest<Boolean>> rechargePayNotify(String outNo, String appNo) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.rechargePayNotify(outNo, appNo);
    }

    public Observable<BaseRequest> replyAdd(CommentReply submiter) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.replyAdd(submiter).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<UserInfo>> saveAdClickTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveAdClickTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveAttenUserTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveAttenUserTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveKeepDisTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveKeepDisTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveReaderTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveReaderTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveSearchBookTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveSearchBookTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveShareTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveShareTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveTelNumTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveTelNumTask(taskNum, taskType);
    }

    public Observable<BaseRequest<UserInfo>> saveUserInfoTask(int taskNum, int taskType) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.saveUserInfoTask(taskNum, taskType);
    }

    public Observable<BaseRequest<List<BookList>>> searchBookList(String searchKey) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.searchBookList(searchKey).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<List<Discuss>>> searchDiscuss(String searchKey, int days) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.searchDiscuss(searchKey, days).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<Boolean>> sendCodeForMobileTask(String mobile, String vcode, String cpid) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.sendCodeForMobileTask(mobile, vcode, cpid);
    }

    public Observable<BaseRequest<Boolean>> sendMobile(String mobile, String vcode, String cpid) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.sendMobile(mobile, vcode, cpid);
    }

    public Observable<BaseRequest> submitComment(CommentSubmiter submiter) {
        if (this.commentBiz == null) {
            this.commentBiz = new CommentBiz(this.context);
        }
        return this.commentBiz.submitComment(submiter).subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    @Deprecated
    public Observable<RequestCallBack> synYueWenPay(String url) {
        return new ThirdBiz(url).synYueWenPay();
    }

    public Observable<BaseRequest<UserInfo>> updateNoAdTime(long noAdTime) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.uodateNoAdTime(noAdTime);
    }

    public Observable<BaseRequest<BookAndDiscuss>> uploadBookData(String data) {
        if (this.discussBiz == null) {
            this.discussBiz = new DiscussBiz(this.context);
        }
        return this.discussBiz.uploadBookData(data);
    }

    public Observable<BaseRequest<UserInfo>> uploadCode(LandingCodeBody landingCodeBody) {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.uploadCode(landingCodeBody);
    }

    public Observable<BaseRequest> userOut() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.userOut().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<BaseRequest<UserInfo>> userSignIn() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.userSignIn();
    }

    public Observable<BaseRequest<VerifCode>> verifCode() {
        if (this.accountBiz == null) {
            this.accountBiz = new AccountBiz(this.context);
        }
        return this.accountBiz.verifCode().subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }

    public void getModuleBooks(String moduleId, RequestCallBack<List<BookDetail>> callback) {
        if (this.moduleBookBiz == null) {
            this.moduleBookBiz = new ModuleBookBiz(this.context);
        }
        getModuleBooks(moduleId, 0, 3, callback);
    }
}