package com.basic.security.manager.erlang;

import android.os.SystemClock;
import android.text.TextUtils;

import com.basic.security.base.BaseApplication;
import com.basic.security.utils.Constants;
import com.ericsson.otp.erlang.OtpConnection;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public class DeviceManager {

    public static List<Map<String, String>> getLocalDevice() {
        return getDeviceList(Constants.erlangLocalNode, "", Constants.erlangLocalNode);
    }

    public static List<Map<String, String>> getOtherDeviceList() {
        return getDeviceList(Constants.erlangLocalNode, Constants.erlangLocalNode, "");
    }

    public static String getInsertSql(Map<String, String> deviceInFatherNode) {

        String deviceInfoInFatherNodeInsertSql = "INSERT INTO `main`.`device_info` (\n" +
                "	`father_node`,\n" +
                "	`table`,\n" +
                "	`uuid`,\n" +
                "	`node_id`,\n" +
                "	`device_id`,\n" +
                "	`cluster_id`,\n" +
                "	`create_time`,\n" +
                "	`update_time`,\n" +
                "	`create_by`,\n" +
                "	`del_flag`\n" +
                ")\n" +
                "VALUES\n" +
                "	(\n" +
                "		'" + deviceInFatherNode.get("father_node") + "',\n" +
                "		'" + deviceInFatherNode.get("table") + "',\n" +
                "		'" + deviceInFatherNode.get("uuid") + "',\n" +
                "		'" + deviceInFatherNode.get("node_id") + "',\n" +
                "		'" + deviceInFatherNode.get("device_id") + "',\n" +
                "		'" + deviceInFatherNode.get("cluster_id") + "',\n" +
                "		'" + deviceInFatherNode.get("create_time") + "',\n" +
                "		'" + deviceInFatherNode.get("update_time") + "',\n" +
                "		'" + deviceInFatherNode.get("create_by") + "',\n" +
                "		'" + deviceInFatherNode.get("del_flag") + "'\n" +
                "	);";
        return deviceInfoInFatherNodeInsertSql;
    }

    public static List<Map<String, String>> getDeviceList(String nodeName, String notNodeId, String isNodeId) {
        String andNotNodeId = "";
        if (!TextUtils.isEmpty(notNodeId)) {
            andNotNodeId = " and a.node_id != '" + notNodeId + "' ";
        }
        String andIsNodeId = "";
        if (!TextUtils.isEmpty(isNodeId)) {
            andIsNodeId = " and a.node_id = '" + isNodeId + "' ";
        }
        List<Map<String, String>> deviceListInFatherNode = SqliteManager.queryFromSync(ErlangConnection.getRemoteConnection(nodeName), "SELECT\n" +
                "	a.father_node,\n" +
                "	a.\"table\",\n" +
                "	a.uuid,\n" +
                "	a.node_id,\n" +
                "	a.device_id,\n" +
                "	a.cluster_id,\n" +
                "	a.create_time,\n" +
                "	a.update_time,\n" +
                "	a.create_by,\n" +
                "	a.del_flag\n" +
                "FROM\n" +
                "	device_info a " +
                " where 1=1 " +
                andNotNodeId +
                andIsNodeId
        );
        return deviceListInFatherNode;
    }

    public static List<String> getInsertDeviceSqlList(String nodeName, String notNodeId) {
        return getInsertDeviceSqlList(nodeName, notNodeId, "");
    }

    public static List<String> getInsertDeviceSqlList(String nodeName, String notNodeId, String isNodeId) {
        List<String> nodeIdlList = new ArrayList<>();
        List<String> insertDeviceSqlList = new ArrayList<>();
        List<Map<String, String>> deviceListInFatherNode = getDeviceList(nodeName, notNodeId, isNodeId);
        for (Map<String, String> deviceInFatherNode : deviceListInFatherNode) {
            for (Map.Entry<String, String> entry : deviceInFatherNode.entrySet()) {
                String key = entry.getKey();
                String value = entry.getValue();
                if (value == null || "NULL".equalsIgnoreCase(value) || "undefined".equalsIgnoreCase(value)) {
                    deviceInFatherNode.put(key, "");
                }
            }
            // 添加了if判断是为了解决集群中有node_id为null以及有重复设备id的bug
            if (deviceInFatherNode.get("node_id") != null && !nodeIdlList.contains(deviceInFatherNode.get("node_id"))) {
                nodeIdlList.add(deviceInFatherNode.get("node_id"));
                insertDeviceSqlList.add(getInsertSql(deviceInFatherNode));
            }
        }
        return insertDeviceSqlList;
    }

    public static void sendLocalDeviceInfoToOtherDevices(List<Map<String, String>> localDeviceList) {
        String localDeviceInsertSql = getInsertSql(localDeviceList.get(0));
        List<Map<String, String>> otherDeviceList = getOtherDeviceList();
        for (Map<String, String> otherDevice : otherDeviceList) {
            String nodeId = otherDevice.get("node_id");
            SqliteManager.executeInSync(ErlangConnection.getRemoteConnection(nodeId), localDeviceInsertSql);
        }
    }

    public static void downloadDeviceInfoFromOtherDevices(String otherNodeName) {
        List<String> insertDeviceSqlList = DeviceManager.getInsertDeviceSqlList(otherNodeName, "");
        for (String inserDeviceSql : insertDeviceSqlList) {
            SqliteManager.executeInSync(ErlangConnection.getLocalConnection(), inserDeviceSql);
        }
    }

    public static void syncDeviceInfoAtAppStart() {
        BaseApplication.getApplication().executorService.execute(() -> {
            while (true) {
                try {
                    OtpConnection connection = ErlangConnection.getLocalConnection();
                    if (connection != null && connection.isConnected()) {
                        List<Map<String, String>> localDeviceList = getLocalDevice();
                        if (localDeviceList.size() > 0) {
                            for (Map<String, String> localDevice : localDeviceList) {
                                String fatherNode = localDevice.get("father_node");
                                if (fatherNode != null && fatherNode.length() > 5) {
                                    downloadDeviceInfoFromOtherDevices(fatherNode);
                                }
                            }
                            sendLocalDeviceInfoToOtherDevices(localDeviceList);
                            break;
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
                SystemClock.sleep(2 * 1000);
            }
        });
    }

}