package com.hdl.sdk.common.event;

import androidx.annotation.NonNull;
import androidx.collection.ArrayMap;


import com.hdl.sdk.common.utils.LogUtils;
import com.hdl.sdk.common.utils.ThreadToolUtils;

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.ExecutorService;


/**
 * Created by Tong on 2021/9/22.
 * 事件分发
 */
public class EventDispatcher {

    private static final List<EventListener> ALL_TOPICS_EVENT = new ArrayList<>();//所有主题消息

    private static final ArrayMap<Object, List<EventListener>> EVENT = new ArrayMap<>();

    private static final ArrayMap<EventListener, Integer> TYPE = new ArrayMap<>();

    private static final int MAIN_TYPE = 0;
    private static final int IO_TYPE = 1;

    private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(3);


    private EventDispatcher() {
    }

    //    private static class SingletonInstance {
    private static final EventDispatcher instance = new EventDispatcher();
//    }

    public static EventDispatcher getInstance() {
        return instance;
    }

    public void register(Object tag, EventListener listener) {
        synchronized (this) {
            try {
                LogUtils.i("注册主题：" + tag);
                if (tag == null) return;
                if (!EVENT.containsKey(tag)) {
                    EVENT.put(tag, new ArrayList<>());
                }
                if (listener == null) {
                    LogUtils.i("监听事件为空");
                    return;
                }
                Objects.requireNonNull(EVENT.get(tag)).add(listener);
                TYPE.put(listener, MAIN_TYPE);
            } catch (Exception e) {
                LogUtils.e("register：" + e.getMessage());
            }
        }
    }

    public  void registerIo(Object tag, EventListener listener) {
        synchronized (this) {
            LogUtils.i("注册主题：" + tag);
            if (tag == null) return;
            if (!EVENT.containsKey(tag)) {
                EVENT.put(tag, new ArrayList<>());
            }
            try {
                if (listener == null) {
                    LogUtils.i("监听事件为空");
                    return;
                }
                Objects.requireNonNull(EVENT.get(tag)).add(listener);
                TYPE.put(listener, IO_TYPE);
            } catch (Exception e) {
                LogUtils.e("registerIo：" + e.getMessage());
            }
        }
    }

    public  void remove(Object tag) {
        synchronized (this) {
            if (tag == null) {
                return;
            }
            try {
                if (EVENT.containsKey(tag)) {
                    LogUtils.i("移除key：" + tag);
                    List<EventListener> list = EVENT.get(tag);
                    for (EventListener eventListener : list) {
                        if (eventListener == null) {
                            continue;
                        }
                        TYPE.remove(eventListener);
                    }
                    EVENT.remove(tag);
                }
            } catch (Exception ignored) {
                LogUtils.e("移除event异常1：" + ignored.getMessage());
            }
        }
    }

    public  void remove(Object tag, EventListener listener) {
        synchronized (this) {
            try {
                if (tag == null || listener == null) {
                    return;
                }
                if (EVENT.containsKey(tag)) {
                    LogUtils.i("移除key：" + tag);
                    List<EventListener> ev = EVENT.get(tag);
                    if (ev != null && !ev.isEmpty()) {
                        TYPE.remove(listener);
                        ev.remove(listener);
                    }
                }
            } catch (Exception ignored) {
                LogUtils.e("移除event异常1：" + ignored.getMessage());
            }
        }
    }

    public synchronized void post(Object tag, @NonNull Object o) {
        if (tag == null) {
            LogUtils.i("post tag为空");
            return;
        }
        try {
            if (EVENT.containsKey(tag)) {
                LogUtils.i("post：" + tag);
                List<EventListener> list = EVENT.get(tag);
                if (list != null && !list.isEmpty()) {
                    for (EventListener listener : list) {
                        if (listener == null) {
                            continue;
                        }
                        ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
                            @Override
                            public void run() {
                                try {
                                    if (listener != null) {
                                        listener.onMessage(o);
                                    }
                                } catch (Exception e) {
                                    LogUtils.e("post异常1：" + e.getMessage());
                                }
                            }
                        });
                    }
                }
            }
            //所有主题的Listener通知
            if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {
                for (EventListener listener : ALL_TOPICS_EVENT) {
                    if (listener == null) {
                        continue;
                    }
                    ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                if (listener != null) {
                                    listener.onMessage(o);
                                }
                            } catch (Exception e) {
                            }
                        }
                    });
                }
            }
        }catch (Exception e){
            LogUtils.e("post异常2：" + e.getMessage());
        }
    }

    /**
     * 注册所有主题消息的监听
     * @param listener
     */
    public synchronized void registerAllTopicsListener(EventListener listener) {
        if(listener==null){
            return;
        }
        try {
            if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.contains(listener)) {
                ALL_TOPICS_EVENT.add(listener);
            }
            TYPE.put(listener, MAIN_TYPE);
        }catch (Exception e){
            LogUtils.e("registerAllTopicsListener：" + e.getMessage());
        }
    }

    /**
     * 取消所有主题消息的监听
     * @param listener
     */
    public synchronized void removeAllTopicsListener(EventListener listener) {
        try {
            ioThread.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        if(listener==null){
                            return;
                        }
                        if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {
                            TYPE.remove(listener);
                            ALL_TOPICS_EVENT.remove(listener);
                        }
                    } catch (Exception ignored) {
                        LogUtils.e("移除event异常1：" + ignored.getMessage());
                    }

                }
            });
        } catch (Exception e) {
            LogUtils.e("移除event异常2：" + e.getMessage());
        }
    }

    public synchronized void clear() {
        ALL_TOPICS_EVENT.clear();
        EVENT.clear();
        TYPE.clear();
    }

    public synchronized void release() {
        clear();
        ioThread.shutdownNow();
    }
}