package com.basic.security.utils;
import android.os.SystemClock;
import android.text.TextUtils;

import com.basic.security.activity.MainActivity;
import com.basic.security.base.BaseApplication;
import com.basic.security.manager.AlarmManager;
import com.basic.security.utils.Constants;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParseException;
import com.google.gson.JsonParser;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

public class SocketAcceptedClient extends Thread {

    Socket mSocket;
    byte[] buff = new byte[1*1024*1024];
    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
    public static boolean needRestart = false;
    List<Map<String, String>> newRemoteAlarmList = null;

    private static final int MAX_BUFFER = 15;

    private static LinkedList<byte[]> mRgbCameraQueue = new LinkedList<byte[]>();

    public SocketAcceptedClient(Socket client) {
        mSocket = client;
    }

    public Comparator<Map<String, String>> mapComparator = new Comparator<Map<String, String>>() {
        public int compare(Map<String, String> m1, Map<String, String> m2) {
            try {
                double score1 = Double.parseDouble(m1.get("likePer"));
                double score2 = Double.parseDouble(m2.get("likePer"));
                return (int)(score1 - score2);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return 0;
        }
    };

    public void parseJson(String msg) {

        JsonParser parser = new JsonParser();
        boolean isJSON = true;
        JsonElement element = null;
        try {
            element = parser.parse(msg);
        } catch (JsonParseException e) {
            System.out.println("exception: "+ msg + " " + e);
            isJSON = false;
        }
        newRemoteAlarmList = new ArrayList<>();
        if (isJSON && element != null) {
            Object obj = element.getAsJsonObject();
            JsonArray dataList = (JsonArray) ((JsonObject) obj).get("datalist");
            for (int i = 0; i < dataList.size(); i++) {
                JsonObject je = (JsonObject)dataList.get(i);
                Map<String, String> newRemoteAlarm = new HashMap<>();
                for(Map.Entry<String, JsonElement> entry : je.entrySet()) {
                    Object value = entry.getValue();
                    String key = entry.getKey();
                    if (value != null) {
                        if ("baseInfo".equals(key)) {
                            List<Map<String, String>> matchPersonMapList = new ArrayList<>();
                            List<String> matchPersonStrList = new ArrayList<>();
                            String matchPersonListStr = "";
                            if (value instanceof JsonArray) {
                                JsonArray matchPersonList = (JsonArray)value;
                                for (int ii = 0; ii < matchPersonList.size(); ii++ ) {
                                    JsonObject matchPerson = (JsonObject)matchPersonList.get(ii);
                                    Map<String, String> matchPersonMap = new HashMap<>();

                                    for(Map.Entry<String, JsonElement> matchPersonEntry : matchPerson.entrySet()) {
                                        String matchPersonKey = matchPersonEntry.getKey();
                                        Object matchPersonValue = matchPersonEntry.getValue();
                                        if (matchPersonValue != null) {
                                            String matchPersonValueStr = matchPersonValue.toString();
                                            if (matchPersonValueStr.startsWith("\"")) {
                                                matchPersonValueStr = matchPersonValueStr.substring(1);
                                            }
                                            if (matchPersonValueStr.endsWith("\"")) {
                                                matchPersonValueStr = matchPersonValueStr.substring(0, matchPersonValueStr.length() - 1);
                                            }
                                            matchPersonMap.put(matchPersonKey, matchPersonValueStr);
                                        } else {
                                            matchPersonMap.put(matchPersonKey, "");
                                        }
                                    }
                                    matchPersonMap.put("mathPersonStr",  matchPersonMap.get("tableName")+ " " +  matchPersonMap.get("personName"));
                                    matchPersonMapList.add(matchPersonMap);
                                }
                                Collections.sort(matchPersonMapList, mapComparator);
                                for (Map<String, String> matchPersonMap : matchPersonMapList) {
                                    matchPersonStrList.add(matchPersonMap.get("mathPersonStr"));
                                }
                                matchPersonListStr = TextUtils.join("`", matchPersonStrList);
                            }
                            newRemoteAlarm.put("matchPersonListStr", matchPersonListStr);
                        } else {
                            newRemoteAlarm.put(entry.getKey(), value.toString());
                        }
                    }
                }
                newRemoteAlarmList.add(newRemoteAlarm);
            }
//
            if (newRemoteAlarmList != null && newRemoteAlarmList.size() > 0) {
//                                        System.out.println("receive");
//                                        if (1==1) {
//                                            return;
//                                        }
                AlarmManager.renameKeys(newRemoteAlarmList);
                if (AlarmManager.saveRemoteAlarmListToSqlite(newRemoteAlarmList) > 0) {
                    ((MainActivity) BaseApplication.getApplication().activity).fragment_home.refreshGridView();
                }
            } else {
                if (((MainActivity)BaseApplication.getApplication().activity).currentFragment ==
                        ((MainActivity)BaseApplication.getApplication().activity).fragment_home) {
                    ToastUtil.show("获取报警数据失败");
                }
            }
        }
    }

    @Override
    public void run() {
        try {
            BufferedOutputStream outputStream = new BufferedOutputStream(mSocket.getOutputStream());
            BufferedInputStream inputStream = new BufferedInputStream(mSocket.getInputStream());
            String msg = "";
            int len = 0;
            while ((len = inputStream.read(buff)) != -1) {
                for (int i1 = 0; i1 <len; i1++) {
                    if (buff[i1] == '\0') {
                        try {
                            byte[] msgBuf = byteArrayOutputStream.toByteArray();
                            byteArrayOutputStream.reset();
                            msg = new String(msgBuf, 0, msgBuf.length);
                            msg = msg.substring(0, msg.lastIndexOf("}") + 1);
                            System.out.println("msg="+msg);
                            if (msg.length() > 3) {
                                parseJson(msg);
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                        }

                    } else {
                        byteArrayOutputStream.write(buff[i1]);
                    }
                }
                if (needRestart) {
                    needRestart = false;
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


}