package com.hdl.sdk.link.common.event;

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


import com.hdl.sdk.link.common.utils.LockArrayMap;
import com.hdl.sdk.link.common.utils.LockList;
import com.hdl.sdk.link.common.utils.LogUtils;
import com.hdl.sdk.link.common.utils.ThreadToolUtils;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;


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

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

    //    private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
    private static final LockArrayMap<String, List<EventListener>> EVENT = new LockArrayMap<String, List<EventListener>>();
    //需异步回调的接口
    private static final LockList<EventListener> ASYNC_EVENT = new LockList<>();

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

    private EventDispatcher() {
    }

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

    public static EventDispatcher getInstance() {
        return SingletonInstance.INSTANCE;
    }

    public synchronized void register(String tag, EventListener listener) {
        try {
            if (!EVENT.containsKey(tag)) {
                EVENT.put(tag, new ArrayList<>());
            }
            List<EventListener> events = EVENT.get(tag);
            if (events != null && !events.contains(listener)) {
                events.add(listener);
                LogUtils.i(String.format("增加订阅主题:%s,当前回调数量:%s", tag, events.size()));
            }
        } catch (Exception e) {
            LogUtils.e(e.getMessage());
        }
    }

//    public synchronized void registerIo(String tag, EventListener listener) {
//        try {
//            if (!EVENT.containsKey(tag)) {
//                EVENT.put(tag, new ArrayList<>());
//            }
//            List<EventListener> events = EVENT.get(tag);
//            if (events != null && !events.contains(listener)) {
//                events.add(listener);
//            }
//        } catch (Exception e) {
//            LogUtils.e(e.getMessage());
//        }
//    }

    /**
     * 需要异步回调的接口
     * @param tag
     * @param listener
     */
    public synchronized void asyncRegister(String tag, EventListener listener) {
        register(tag, listener);
        if (!ASYNC_EVENT.contains(listener)) {
            ASYNC_EVENT.add(listener);
        }
    }

    public synchronized void remove(String tag) {
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    if (EVENT.containsKey(tag)) {
//                        List<EventListener> list = EVENT.get(tag);
//                        for (EventListener eventListener : list) {
//                            TYPE.remove(eventListener);
//                        }
                        EVENT.remove(tag);
                    }
                } catch (Exception e) {
                    LogUtils.e(e.getMessage());
                }

            }
        });

    }

    public synchronized void remove(Object tag, EventListener listener) {
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    if (EVENT.containsKey(tag)) {
                        List<EventListener> ev = EVENT.get(tag);
                        if (ev != null && !ev.isEmpty()) {
//                            TYPE.remove(listener);
                            ev.remove(listener);
                            ASYNC_EVENT.remove(listener);
                            LogUtils.i(String.format("移除订阅主题:%s,当前回调数量:%s",tag,ev.size()));
                        }
                    }
                } catch (Exception e) {
                    LogUtils.e(e.getMessage());
                }

            }
        });
    }

    /**
     * 两个主题是否匹配
     * @param desString 字典中的主题
     * @param sourceString 接收到的主题
     * @return
     */
    boolean isMatch(String desString,String sourceString) {
        String[] des = desString.split("/");
        String[] source = sourceString.split("/");
        if (des.length != source.length) {
            return false;
        }
        for (int i = 0; i < des.length; i++) {
            if (!(des[i].equals(source[i]) || des[i].equals("+"))) {
                if (i != 2) {
                    //网关id不判断，可能是Oid,也可能是mac
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * 事件分发器，分发所有在接口列表中的事件
     * @param topicTag
     * @param o
     */
    public synchronized void post(String topicTag, @NonNull Object o) {
        try {
//            LogUtils.e("EventDispatcher", "===15");
            for (String key : EVENT.keySet()) {
                if (!isMatch(key, topicTag)) {
                    continue;
                }
//                LogUtils.e("EventDispatcher", "===16");
                List<EventListener> list = EVENT.get(key);
                if (list != null && !list.isEmpty()) {
                    for (EventListener listener : list) {
                        if(listener==null){
                            continue;
                        }
//                        LogUtils.e("EventDispatcher", "===17");
                        //需要异步回调的
                        if(ASYNC_EVENT.contains(listener)) {
//                            LogUtils.e("EventDispatcher", "===18");
                            runOnSubThread(listener,o);
                        }
                        else {
//                            LogUtils.e("EventDispatcher", "===19");
                            runOnUIThread(listener,o);
                        }
                    }
                }
            }
            //所有主题的Listener通知
            if (ALL_TOPICS_EVENT == null || ALL_TOPICS_EVENT.isEmpty()) {
                return;
            }
//            LogUtils.e("EventDispatcher", "===20");
            //开发分发事件
            for (EventListener listener : ALL_TOPICS_EVENT) {
                runOnUIThread(listener, o);
            }
//            LogUtils.e("EventDispatcher", "===21");
        }catch (Exception e){
            LogUtils.e(e.getMessage());
        }

    }

    /**
     * 运行在子线程
     * @param eventListener
     * @param o
     */
    private void runOnSubThread(EventListener eventListener,Object o) {
        if (eventListener == null) {
            return;
        }
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
                try {
//                    LogUtils.e("EventDispatcher", "===22");
                    eventListener.onMessage(o);
                } catch (Exception e) {
                    LogUtils.e("runOnSubThread数据异常", o + " " + e.getMessage());
                }
            }
        });
    }

    /**
     * 运行到主线程
     * @param eventListener
     * @param o
     */
    private void runOnUIThread(EventListener eventListener,Object o) {
        if (eventListener == null) {
            return;
        }
        ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
            @Override
            public void run() {
                try {
//                    LogUtils.e("EventDispatcher", "===23");
                    eventListener.onMessage(o);
                } catch (Exception e) {
                    LogUtils.e("runOnUIThread数据异常", o + " " + e.getMessage());
                }
            }
        });
    }

    /**
     * 文件发送通知 wxr 2022-03-08 15:38:59
     */
    public synchronized void filePost() {
        //TODO
    }
    /**
     * 注册所有主题消息的监听
     * @param listener
     */
    public synchronized void registerAllTopicsListener(EventListener listener) {
        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(e.getMessage());
        }
    }

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

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

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


}