package com.basic.security.fragment;

import android.content.Intent;
import android.os.SystemClock;
import android.view.View;
import android.widget.AbsListView;
import android.widget.ListPopupWindow;
import android.widget.PopupWindow;
import android.widget.Spinner;

import com.basic.security.R;
import com.basic.security.base.BaseApplication;
import com.basic.security.fragment.helper.HomeGridViewAdapter;
import com.basic.security.fragment.helper.HomePlayAlarmVideo;
import com.basic.security.manager.AlarmManager;
import com.basic.security.manager.SettingManager;
import com.basic.security.utils.MemoryUtil;
import com.basic.security.utils.RabbitMQConsumer;
import com.basic.security.utils.SocketClient;
import com.basic.security.utils.ThreadUtil;

import org.androidannotations.annotations.AfterInject;
import org.androidannotations.annotations.AfterViews;
import org.androidannotations.annotations.Background;
import org.androidannotations.annotations.Click;
import org.androidannotations.annotations.EFragment;
import org.androidannotations.annotations.UiThread;

import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


@EFragment(R.layout.fragment_home)
public class HomeFragment extends HomePlayAlarmVideo {

    public List<Map<String, String>> newSqliteAlarmList;

    @AfterInject
    void afterInject() {
        setRootUrl();
        homeRestClient.setRestErrorHandler(myErrorHandler);
    }

    public void setRootUrl() {
//        String ipStr = SettingManager.getIpStr();
//        if (localServer) {
//            homeRestClient.setRootUrl("http://"+ipStr+":8080/ManCarAnaly/alarm");
//        } else {
//            homeRestClient.setRootUrl("http://"+ipStr+":8000/data/api-v/realTime");
//        }
    }
    static List<SocketClient> socketClientList = new ArrayList<>();

    public static void startNewSocketClient() {
        System.out.println("启动新连接");
        SocketClient socketClient = new SocketClient(SettingManager.getIpStr(), SettingManager.getPort());
        socketClient.start();
        socketClientList.add(socketClient);
        SystemClock.sleep(10*1000);
    }

    @Background
    public void pullAlarmDataList() {
        SystemClock.sleep(1000);
        refreshGridView();
        while (true) {
            try{
                RabbitMQConsumer.init();
//                try {
//                    if (1!=1) {
//                        startNewSocketClient();
//                        break;
//                    } else {
//                        List<SocketClient> socketClientListToRemove = new ArrayList<>();
//                        for (SocketClient socketClient1 : socketClientList) {
//                            if (System.currentTimeMillis() - socketClient1.lastUpdateTime > 1000*60*2) {
////                                socketClient1.closeSocket();
//                                socketClient1.interrupt();
//                                socketClientListToRemove.add(socketClient1);
//                            }
//                        }
//                        socketClientList.removeAll(socketClientListToRemove);
//                        if (socketClientList.size() == 0) {
//                            startNewSocketClient();
//                        }
//                    }
//                } catch (Exception e) {
//                    System.out.println("pullAlarmDataList, " + e.getMessage());
//                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                SystemClock.sleep(3000);
            }
        }
    }

    @Override
    public void show() {
        for (AlarmListAdapter.ViewHolder viewHolder : viewHolderSet.keySet()) {
            if (AlarmManager.getAlarmPlaying(viewHolder.alarm)) {
                AlarmManager.putAlarmPlaying(viewHolder.alarm, false);
            }
        }
        refreshGridView();
    }

    public void refreshGridView() {
        try {
            mainActivity().runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    for (HomeGridViewAdapter.AlarmListAdapter.ViewHolder viewHolder : viewHolderSet.keySet()) {
                        viewHolder.matchPersonList.onDetachedFromWindow();
                    }
                }
            });
            SystemClock.sleep(100);
        } catch (Exception e) {
            e.printStackTrace();
        }
        try {
            refreshGridViewLocker.lock();
            newSqliteAlarmList = AlarmManager.findAlarmList();
            if (newSqliteAlarmList != null) {
                final Map<String, Map<String, String>> sqliteAlarmListMap = new HashMap<>();
                sqliteAlarmListLock.lock();
                for (Map<String, String> alarm : sqliteAlarmList) {
                    sqliteAlarmListMap.put(alarm.get("id"), alarm);
                }
                sqliteAlarmListLock.unlock();
                for (Map<String, String> alarm : newSqliteAlarmList) {
                    //AlarmManager.putAlarmPlaying(alarm, false);
                    Map<String, String> backupAlarm = sqliteAlarmListMap.get(alarm.get("id"));
                    if (backupAlarm != null) {
                        if ("true".equals(backupAlarm.get("videoPlayFinished"))) {
                            if (AlarmManager.getAlarmPlaying(alarm)) {
                                //alarm.put("videoPlaying", backupAlarm.get("videoPlaying"));
                            }
                        }
                    }
                }
                sqliteAlarmListLock.lock();
                sqliteAlarmList.clear();
                sqliteAlarmList.addAll(newSqliteAlarmList);
                sqliteAlarmListLock.unlock();
                updateAlarmDataListInUIThread();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            refreshGridViewLocker.unlock();
        }

    }

    @UiThread
    public void updateAlarmDataListInUIThread() {
        alarmListAdapter.notifyDataSetChanged();
    }

    /**
     * Hides a spinner's drop down.
     */
    public static void hideSpinnerDropDown(Spinner spinner) {
        try {
            Method method = Spinner.class.getDeclaredMethod("onDetachedFromWindow");
            method.setAccessible(true);
            method.invoke(spinner);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @AfterViews
    public void afterViews() {
        try {
            for (HomeGridViewAdapter.AlarmListAdapter.ViewHolder viewHolder : viewHolderSet.keySet()) {
                hideSpinnerDropDown(viewHolder.matchPersonList);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        alarmListAdapter = new AlarmListAdapter();
        alarmListGridView.setAdapter(alarmListAdapter);
        alarmListGridView.setOnScrollListener( new AbsListView.OnScrollListener() {
            public void onScrollStateChanged(AbsListView view, int scrollState) {
                sqliteAlarmListLock.lock();
                for (Map<String, String> sqliteAlarm :  sqliteAlarmList) {
                    AlarmManager.putAlarmPlaying(sqliteAlarm, false);
                }
                sqliteAlarmListLock.unlock();
                try{
                    for (HomeGridViewAdapter.AlarmListAdapter.ViewHolder viewHolder : viewHolderSet.keySet()) {
                        viewHolder.alarmVideoOverlay.setVisibility(View.GONE);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
                stopAllVideoPlays(null);
                int showGotoTop = View.INVISIBLE;
                if (alarmListGridView.getChildCount() > 0) {
                    if (alarmListGridView.getChildAt(0).getTop() != 0) {
                        showGotoTop = View.VISIBLE;
                    }
                }
                goto_top.setVisibility(showGotoTop);
            }
            public void onScroll(AbsListView view, int firstVisibleItem, int visibleItemCount, int totalItemCount) {}
        });
        saveVideoPlayerCurrentTime();
//        executorService.execute(new Runnable() {
//            @Override
//            public void run() {
//                while (true) {
//                    try {
//                        AlarmManager.updateVideoUrl();
//                        SystemClock.sleep(1 * 1000);
//                    } catch (Exception e) {
////                        e.printStackTrace();
//                        System.out.println("HomeFragment.run " + e.getMessage());
//                    }
//                }
//            }
//        });
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    try {
                        MemoryUtil.monitorMemory();
                        sendKeepLife();
                        ThreadUtil.threadCreateObserver();
                        SystemClock.sleep(3 * 1000);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
        });
    }
    public static void sendKeepLife() {
        try {
            if (System.currentTimeMillis() - lastSendKeepLife > 2 * 1000) {
                Intent intent = new Intent("keepLife");
                intent.putExtra("message", "This is my message!");
                BaseApplication.getApplication().activity.sendBroadcast(intent);
                lastSendKeepLife = System.currentTimeMillis();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
    static long lastSendKeepLife = 0;
    public ExecutorService executorService = Executors.newCachedThreadPool();
    @Click
    public void goto_top() {
        alarmListGridView.smoothScrollToPositionFromTop(0,0);
        goto_top.setVisibility(View.INVISIBLE);
    }

}