midi-android/moduleUtil/src/main/java/com/xscm/moduleutil/presenter/RewardGiftPresenter.java

package com.xscm.moduleutil.presenter;

import android.content.Context;

import com.xscm.moduleutil.bean.GiftLabelBean;
import com.xscm.moduleutil.bean.GiftPackBean;
import com.xscm.moduleutil.bean.GiftPackListCount;
import com.xscm.moduleutil.bean.RewardUserBean;
import com.xscm.moduleutil.bean.RoonGiftModel;
import com.xscm.moduleutil.bean.WalletBean;
import com.xscm.moduleutil.bean.room.RoomAuction;
import com.xscm.moduleutil.http.BaseObserver;

import java.lang.ref.WeakReference;
import java.util.List;

import io.reactivex.disposables.Disposable;

public class RewardGiftPresenter extends BasePresenter<RewardGiftContacts.View> implements RewardGiftContacts.IIndexPre {
    RewardGiftContacts.View mView;

    public RewardGiftPresenter(RewardGiftContacts.View view, Context context) {
        super(view, context);
        mView = view;
    }

    @Override
    public void getRewardList(String id, int page, int page_limit) {
        api.getRewardList(id, page, page_limit, new BaseObserver<List<RewardUserBean>>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(List<RewardUserBean> rewardUserBeans) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().getRewardList(rewardUserBeans);
            }
        });

    }

    @Override
    public void getGiftLabel(String have_hot) {
        api.getGiftLabel(have_hot, new BaseObserver<List<GiftLabelBean>>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(List<GiftLabelBean> giftLabelBeans) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().getGiftLabel(giftLabelBeans);
            }
        });

    }

    @Override
    public void getGiftList(String id, int type, String roomId) {
        api.getGiftList(Integer.parseInt(id), roomId, new BaseObserver<List<RoonGiftModel>>() {

            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(List<RoonGiftModel> roonGiftModels) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().setGiftList(roonGiftModels, type);
            }
        });
    }

    @Override
    public void giveGift(String user_id, String gid, String num, String to_uid, String gift_type) {
        api.giveGift(user_id, gid, num, to_uid, gift_type, new BaseObserver<String>() {

            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(String s) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().giveGift();
            }
        });
    }

    @Override
    public void roomGift(String room_id, String gift_id, String gift_num, String to_uid, String type, String pit_number, String heart_id) {
        api.roomGift(room_id, gift_id, gift_num, to_uid, type, pit_number, heart_id, new BaseObserver<String>() {

            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(String s) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().giveGift();
            }
        });
    }

    @Override
    public void wallet() {
        api.wallet(new BaseObserver<WalletBean>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(WalletBean walletBean) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().wallet(walletBean);
            }
        });
    }

    @Override
    public void reward_zone(String id, String gift_id, String num, String is_pack) {
        api.reward_zone(id, gift_id, num, is_pack, new BaseObserver<String>() {

            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(String s) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().reward_zone();
            }
        });
    }

    @Override
    public void setRoomApply(String room_id, String gift_id, String gift_price) {
        api.setRoomApply(room_id, gift_id, gift_price, new BaseObserver<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(String s) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().reward_zone();
            }
        });
    }

    @Override
    public void roomAuctionJoin(String auction_id, String user_id, String gift_id, String num, String type) {
        api.roomAuctionJoin(auction_id, user_id, gift_id, num, type, new BaseObserver<RoomAuction.AuctionListBean>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(RoomAuction.AuctionListBean auctionListBean) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().roomAuctionJoin(auctionListBean);
            }
        });
    }

    @Override
    public void giftPack() {
        api.giftPack(new BaseObserver<List<GiftPackBean>>() {

            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(List<GiftPackBean> giftPackBeans) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().giftPack(giftPackBeans);
            }
        });
    }

    @Override
    public void getGiftPack(String roomId, String userId, String heart_id, String auction_id) {
        api.getGiftPack(roomId, userId, heart_id, auction_id, new BaseObserver<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(String s) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                if (s == null) {
                    MvpRef.get().getGiftPack(null);
                } else {
                    MvpRef.get().getGiftPack(s);
                }
            }
        });
    }

    @Override
    public void getGiftPackListCount() {
        api.getGiftPackListCount(new BaseObserver<GiftPackListCount>() {
            @Override
            public void onSubscribe(Disposable d) {
                addDisposable(d);
            }

            @Override
            public void onNext(GiftPackListCount giftPackListCount) {
                if (MvpRef == null) {
                    MvpRef = new WeakReference<>(mView);
                }
                MvpRef.get().getGiftPackListCount(giftPackListCount);
            }
        });
    }
}