RxMakePromptMessageTimer.java

package live.nodiyphoneshell.cend.rxbus;
import android.content.Context;
import android.text.TextUtils;
import android.view.View;
import android.widget.ImageView;
import android.widget.LinearLayout;
import android.widget.TextView;
import androidx.annotation.NonNull;
import com.squareup.picasso.Picasso;
import java.util.List;
import java.util.concurrent.TimeUnit;
import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import live.nodiyphoneshell.cend.config.Config;
import live.nodiyphoneshell.cend.modules.OrderNoticeBean;
import live.nodiyphoneshell.cend.utils.DateUtils;
import live.nodiyphoneshell.cend.utils.ScreenUtils;
/**
 * @author MaYnaghua
 * @version 1.0.0
 * @date 2021/3/4 10:21
 */
public class RxMakePromptMessageTimer {

    private Disposable mDisposable;
    private static volatile RxMakePromptMessageTimer instance;
    private Context context;
    private LinearLayout linearLayout;
    private TextView textView;
    private ImageView imageView;
    private Disposable mDisposableCountDown;
    private int period = 6;
    private int postion = 0;//轮播位置
    public  List<OrderNoticeBean> orderNoticeBeanList;      //之前消息集合
    private boolean hasComeIn = false; //是否首次进入
    private int getWidth;

    public static RxMakePromptMessageTimer getInstance(Context context) {
        if (instance == null) {
            synchronized (RxMakePromptMessageTimer.class) {
                if (instance == null) {
                    instance = new RxMakePromptMessageTimer(context);
                }
            }
        }
        return instance;
    }

    public RxMakePromptMessageTimer(Context context) {
        getWidth=ScreenUtils.dip2px(context, 15);
        this.context = context;
    }


    /*有几个关键：
     1、队列管理，存储数量控制，清空队列；
     2、队列循环，为避免指定时间推送，所以按随机时间段（5、10、15）取个时间间隔
     3、显示规则，每次只显示1S，间隔5秒显示下一条，合计50S内显示完最新队列，接着按2的规则进入下一次循环；*/
    //初始化数据
    public void initData(LinearLayout linearLayout, ImageView imageView, TextView textView) {
        this.linearLayout = linearLayout;
        this.textView = textView;
        this.imageView = imageView;
    }


    //更新集合数据
    public void setUpDataList(List<OrderNoticeBean> orderNoticeBeanList) {
        this.orderNoticeBeanList = orderNoticeBeanList;
        this.postion = 0;
        if (textView != null && linearLayout != null && orderNoticeBeanList != null && orderNoticeBeanList.size() > 0) {
            interval();
        } else {
            cancel();
        }
    }

    /**
     * milliseconds毫秒后执行指定动作
     */
    public synchronized void timer(long SECONDS) {
        Observable.timer(SECONDS, TimeUnit.SECONDS)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(@NonNull Disposable disposable) {
                        mDisposableCountDown = disposable;
                    }

                    @Override
                    public void onNext(@NonNull Long number) {
                        if (linearLayout != null) {
                            linearLayout.setVisibility(View.GONE);
                        }
                    }

                    @Override
                    public void onError(@NonNull Throwable e) {

                    }

                    @Override
                    public void onComplete() {

                    }
                });
    }


    /**
     * 每隔milliseconds秒后执行指定动作
     */
    public void interval() {
        if (mDisposable == null && !hasComeIn) {
            if (linearLayout != null) {
                linearLayout.setVisibility(View.GONE);
            }
            hasComeIn = true;
            Observable.interval(period, TimeUnit.SECONDS)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Observer<Long>() {
                        @Override
                        public void onSubscribe(@NonNull Disposable disposable) {
                            mDisposable = disposable;
                        }

                        @Override
                        public void onNext(@NonNull Long number) {
                            try {
                                if (orderNoticeBeanList != null && orderNoticeBeanList.size() > 0) {
                                    if (linearLayout != null) {
                                        linearLayout.setVisibility(View.VISIBLE);
                                    }
                                    if (postion < orderNoticeBeanList.size() && textView != null) {
                                        OrderNoticeBean orderNoticeBean = orderNoticeBeanList.get(postion);
                                        if (orderNoticeBean != null) {
                                            long getNumber = System.currentTimeMillis() / 1000 - orderNoticeBean.getCreate_time();
                                            textView.setText(DateUtils.getDate(getNumber) + " 前定制了 " + orderNoticeBean.getGoods_name());
                                            String imageUrl = orderNoticeBean.getWorks_image();
                                            if (!TextUtils.isEmpty(imageUrl)) {
                                                imageUrl = imageUrl + Config.IMAGE_OSS_URL +getWidth;
                                                if (context != null && imageView != null) {
                                                    Picasso.get().load(imageUrl).into(imageView);
                                                    /*Picasso.with(context)
                                                            .load(imageUrl).skipMemoryCache()
                                                            .into(imageView);*/
                                                }
                                            }
                                            postion++;
                                        }
                                    }
                                    if (postion > (orderNoticeBeanList.size() - 1)) {//判断位置是否大于条数
                                        postion = 0;
                                    }
                                }
                                timer(3);
                            } catch (Exception e) {

                            }
                        }

                        //16:54:35
                        //17:02:39
                        @Override
                        public void onError(@NonNull Throwable e) {

                        }

                        @Override
                        public void onComplete() {

                        }
                    });
        }
    }

    /**
     * 取消订阅
     */
    public void cancel() {
        postion = 0;
        hasComeIn = false;
        if (mDisposable != null) {
            mDisposable.dispose();
            mDisposable = null;
        }
        if (mDisposableCountDown != null) {
            mDisposableCountDown.dispose();
            mDisposableCountDown = null;
        }
    }

}