package com.adroplat.fist_switch.jni;

import android.content.Context;
import android.content.Intent;
import android.os.AsyncTask;
import android.support.v4.content.LocalBroadcastManager;
import android.text.TextUtils;
import android.util.Log;
import com.adroplat.fist_switch.SwitchApplication;
import com.adroplat.fist_switch.config.GlobalVar;
import com.adroplat.fist_switch.utils.ToastUtils;
import com.adroplat.fist_switch.utils.WifiUtils;
import com.adroplat.fist_switch.utils.protocol.one.FistProtocol;
import com.google.gson.Gson;
import com.qnbar.switchcontrol.model.MessageEvent;
import io.realm.Realm;
import org.greenrobot.eventbus.EventBus;

import java.util.ArrayList;
import java.util.Arrays;

/**
 * Created by WLJ on 2016/1/14.
 */
public class FistJni {
    private static final String TAG = FistJni.class.getSimpleName();

    public static final int DEVICE_HUBS_ONLINE_NOTIFY = 0x7101;
    private static final String DEVICE_HUBS_ONLINE_NOTIFY_STR = "DEVICE_HUBS_ONLINE_NOTIFY_STR";
    public static final int DEVICE_SWITCH_ONLINE_NOTIFY = 0x7102;
    private static final String DEVICE_SWITCH_ONLINE_NOTIFY_STR = "DEVICE_SWITCH_ONLINE_NOTIFY_STR";

    static {
        System.loadLibrary("fist_ndk");
    }

    private static FistJni instance;

    private FistJni() {
    }

    public static FistJni getInstance() {
        if (null == instance) {
            instance = new FistJni();
        }
        return instance;
    }

    private static Intent intent;

    public static Intent getIntent() {
        intent = new Intent();
        return intent;
    }

    public static final String CONFIG_DONE = "CONFIG_DONE";
    public static final String SEARCH_RESPONSE = "SEARCH_RESPONSE";
    public static final String LINK_STATUS_RESPONSE = "LINK_STATUS_RESPONSE";
    public static final String LINK_RESPONSE = "LINK_RESPONSE";
    public static final String CTRL_PWD_RESPONSE = "CTRL_PWD_RESPONSE";
    public static final String START_ADD = "START_ADD";
    public static final String STOP_ADD = "STOP_ADD";
    public static final String ADD_DONE = "ADD_DONE";
    public static final String CONTROL_REQUEST_TIMEOUT = "CONTROL_REQUEST_TIMEOUT";
    public static final String CONTROL_RESPONSE = "CONTROL_RESPONSE";
    public static final String CONTROL_DONE = "CONTROL_DONE";
    public static final String CONTROL_OVER = "CONTROL_OVER";
    public static final String BYTE_ERROR_CODE = "BYTE_ERROR_CODE";
    public static final String JSON_DEVICE = "JSON_DEVICE";

    private static void configDone(Device device) {
        sendJsonDevice(CONFIG_DONE, device);
    }

    private static ArrayList<Device> hubs;

    public static ArrayList<Device> getHubs() {
        if (hubs == null) {
            hubs = new ArrayList<>();
        }
        return hubs;
    }

    private static ArrayList<SubDevice> subDevices;

    public static ArrayList<SubDevice> getSubDevices() {
        if (subDevices == null) {
            subDevices = new ArrayList<>();
        }
        return subDevices;
    }

    private static void online(Device device, String jsonDevice) {
//        boolean hasAdded = false;
        for (Device device1 : getHubs()) {
            if (Arrays.equals(device1.getDeviceIp(), device.getDeviceIp())) {
//                hasAdded = true;
                getHubs().remove(device1);
                break;
            }
        }
//        if (!hasAdded) {
        getHubs().add(device);
//        }
        sendMessage(DEVICE_HUBS_ONLINE_NOTIFY, DEVICE_HUBS_ONLINE_NOTIFY_STR);
    }

    private static void sendMessage(int type, String typeStr) {
        MessageEvent messageEvent = new MessageEvent();
        messageEvent.setEventId(type);
        messageEvent.setMessage(typeStr);
        EventBus.getDefault().post(messageEvent);
    }

    private static void saveRemote(Device device) {
        if (null == device) return;
        Realm realm = Realm.getDefaultInstance();
//        Hub host = realm.where(Hub.class)
//                .equalTo(Hub.Companion.getDEVICE_NUM(), device.getLongDeviceNum()).findFirst();
//        if (null != host) {//已存储，更新IP，查询子设备
//            realm.beginTransaction();
//            host.setMapIp(device.getIntMappedIp());
//            host.setMapPort(device.getMappedPort());
//            host.setPeerIp(device.getIntDeviceIp());
//            host.setPeerPort(device.getDevicePort());
//            host.setLAN(false);
//            host.setAlreadyHaveRemoteIP(true);
//            realm.commitTransaction();
//        }
        realm.close();
    }

    private static Gson gson;

    public static Gson getGson() {
        if (null == gson) {
            gson = new Gson();
        }
        return gson;
    }

    /**
     * 发送广播
     *
     * @param action
     * @param device
     */
    private static void sendJsonDevice(String action, Device device) {
        if (null == action || action.isEmpty() || null == device) return;
        Context context = SwitchApplication.getAppContext();
        if (null == context) return;
        Intent intent = getIntent();
        intent.setAction(action);
        intent.putExtra(JSON_DEVICE, device);
        LocalBroadcastManager.getInstance(context).sendBroadcast(intent);
    }

    static String deviceJsonAA;

    public static void fistListener(String jsonDevice) {
        if (null == jsonDevice || jsonDevice.isEmpty()) return;
//        GlobalVar.getLogUtils().i("fistListener jsonDevice =" + jsonDevice);
        Log.d(TAG, jsonDevice);
        Gson gson = getGson();
        Device device = gson.fromJson(jsonDevice, Device.class);
        char cmdTpye = (char) device.getCmdType();
        if (TextUtils.isEmpty(deviceJsonAA)) {
            deviceJsonAA = jsonDevice;
        }
        if (FistProtocol.CommondType.CMD_TYPE_SEARCH_RESPONSE == cmdTpye) {//查询响应
            removeId(device);
            online(device, jsonDevice);
            sendJsonDevice(SEARCH_RESPONSE, device);

        } else if (FistProtocol.CommondType.CMD_TYPE_CONFIG_DONE == cmdTpye) {//配置完成处理
            configDone(device);

        } else if (FistProtocol.CommondType.CMD_TYPE_ONLINE == cmdTpye) {//上线通知
            removeId(device);
            online(device, jsonDevice);
            configDone(device);

        } else if (FistProtocol.CommondType.CMD_TYPE_QUERY_RESPONSE == cmdTpye) {
            sendJsonDevice(ADD_DONE, device);
            ArrayList<SubDevice> subDevices = device.getSubDevices();
            if (!subDevices.isEmpty()) {//查询结果不为空
                subDeviceOnline(subDevices);
//                getSubDevices().addAll(subDevices);
//                sendMessage(DEVICE_SWITCH_ONLINE_NOTIFY, DEVICE_SWITCH_ONLINE_NOTIFY_STR);
            }
//            sendJsonDevice(LightingGroupAdapter.REFRESH, device);

        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_RESPONSE == cmdTpye) {
            sendJsonDevice(START_ADD, device);
//            FistJni.stopAddSubDevice(jsonDevice);
            device.setCmdType(49);
            getInstance().query(gson.toJson(device));
//            getInstance().query(gson.toJson(device));
            FistJni.stopAddSubDevice(jsonDevice);
        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_OVER == cmdTpye) {//子设备结束入网
            if (0 == device.getIntDeviceIp()) return;
            device.setCmdType(49);
//            getInstance().query(gson.toJson(device));
            getInstance().query(gson.toJson(device));
            FistJni.stopAddSubDevice(jsonDevice);
//            getInstance().query(jsonDevice);
        } else if (FistProtocol.CommondType.CMD_TYPE_CONTROL == cmdTpye) {//控制超时
            sendJsonDevice(CONTROL_REQUEST_TIMEOUT, device);

        } else if (FistProtocol.CommondType.CMD_TYPE_CONTROL_RESPONSE == cmdTpye) {//控制应答
            sendJsonDevice(CONTROL_RESPONSE, device);

        } else if (FistProtocol.CommondType.CMD_TYPE_CONTROL_DONE_RESPONSE == cmdTpye) {//单个控制结果
            sendJsonDevice(CONTROL_DONE, device);
            getInstance().query(getGson().toJson(getHubs().get(0)));
//            ArrayList<SubDevice> subDevices = device.getSubDevices();
//            if (!subDevices.isEmpty()) {//查询结果不为空
//                subDeviceOnline(subDevices);
////                getSubDevices().addAll(subDevices);
////                sendMessage(DEVICE_SWITCH_ONLINE_NOTIFY, DEVICE_SWITCH_ONLINE_NOTIFY_STR);
//            }
        } else if (FistProtocol.CommondType.CMD_TYPE_CONTROL_OVER == cmdTpye) {
            sendJsonDevice(CONTROL_OVER, device);
            GlobalVar.getLogUtils().i("CONTROL_OVER");
        } else if (FistProtocol.CommondType.CMD_NET_LINK_STATUS_RESPONSE == cmdTpye) {
            sendJsonDevice(LINK_STATUS_RESPONSE, device);

        } else if (FistProtocol.CommondType.CMD_LINK_RESPONSE == cmdTpye) {
            sendJsonDevice(LINK_RESPONSE, device);

        } else if (FistProtocol.CommondType.CMD_MODIFY_CTRL_PWD_RESPONSE == cmdTpye) {
            GlobalVar.getLogUtils().i("FistProtocol.CommondType.CMD_MODIFY_CTRL_PWD_RESPONSE");
            sendJsonDevice(CTRL_PWD_RESPONSE, device);

        } /*else if (RemoteProtocol.MsgType.SET_SUCCESS == cmdTpye) {//密码设置成功
            GlobalVar.getLogUtils().i("SET_SUCCESS jsonDevice =" + jsonDevice);
            long deviceNum = device.getLongDeviceNum();
            Realm realm = Realm.getDefaultInstance();
            Hub host = realm.where(Hub.class).equalTo(Hub.Companion.getDEVICE_NUM(), deviceNum).findFirst();
            if (null != host) {
                realm.beginTransaction();
                host.setWanState(WanState.ON);
                realm.commitTransaction();
            }
            realm.close();
        } else if (RemoteProtocol.MsgType.SET_FAILED == cmdTpye) {//密码设置失败
            GlobalVar.getLogUtils().i("SET_FAILED jsonDevice =" + jsonDevice);

        } else if (RemoteProtocol.MsgType.QUERY_SUCCESS == cmdTpye) {//查询对端成功
            final long deviceNum = device.getLongDeviceNum();
            ArrayList<Long> ids = HeService.getLocIds();
            for (long id : ids) {
                if (deviceNum == id) {
                    saveRemote(device);
                    device.setWan(true);
                    jsonDevice = gson.toJson(device);
                    querySubDevice(jsonDevice);
                    break;
                }
            }
            removeId(device);

        } else if (RemoteProtocol.MsgType.QUERY_FAILED == cmdTpye) {//查询对端失败

        }*/
    }

    private static void subDeviceOnline(ArrayList<SubDevice> subDevices) {
        for (SubDevice subDevice : subDevices) {
//            boolean hasAdd = false;
            for (SubDevice subDevice1 : getSubDevices()) {
                if (subDevice.getSubDeviceNum() == subDevice1.getSubDeviceNum()) {
//                    hasAdd = true;
                    getSubDevices().remove(subDevice1);
                    break;
                }
            }
//            if (!hasAdd) {
            getSubDevices().add(subDevice);
            sendMessage(DEVICE_SWITCH_ONLINE_NOTIFY, DEVICE_SWITCH_ONLINE_NOTIFY_STR);
//            }
        }
    }

    /**
     * 开始
     */
    public static native void start();

    /**
     * 启动SKD
     */
    public void startSdk() {
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                start();
                Log.d(TAG, "start sdk");
                return null;
            }
        }.execute();
    }

    /**
     * 移除查询到的主机ID
     *
     * @param device
     */
    private static void removeId(Device device) {
//        ArrayList<Long> ids = HeService.getLocIds();
//        final long deviceNum = device.getLongDeviceNum();
//        for (long id : ids) {
//            if (deviceNum == id) {
//                ids.remove(id);
//                break;
//            }
//        }
    }

    /**
     * 搜索设备
     */
    public static native void searchDevice();

    /**
     * 查询子设备
     */
    public static native void querySubDevice(String jsonDevice);

    public void query(final String jsonDevice) {
//        if (!HeService.isConn()) {
//            return;
//        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                querySubDevice(jsonDevice);
                return null;
            }
        }.execute();
    }

    public void query() {
//        if (!HeService.isConn()) {
//            return;
//        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                querySubDevice(deviceJsonAA);
                return null;
            }
        }.execute();
    }

    /**
     * 开始添加子设备
     */
    public static native void startAddSubDevice(String jsonDevice);

    public void startAdd(final String jsonDevice) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                startAddSubDevice(jsonDevice);
                return null;
            }
        }.execute();
    }

    /**
     * 停止添加子设备
     */
    public static native void stopAddSubDevice(String jsonDevice);

    public void stopAdd(final String jsonDevice) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                stopAddSubDevice(jsonDevice);
                return null;
            }
        }.execute();
    }

    /**
     * 删除子设备
     */
    public static native void deleteSubDevices(String jsonDevice);

    public void delSub(final String jsonDevice) {
//        if (!HeService.isConn()) {
//            ToastUtils.toastShort("网络未连接");
//            return;
//        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                deleteSubDevices(jsonDevice);
                return null;
            }
        }.execute();
    }

    /**
     * 查询软件版本
     */
    public static native void querySoftwareVer(String jsonDevice);

    /**
     * 查询工作模式
     */
    public static native void queryModel(String jsonDevice);

    public void sceneC(final String jsonDevice) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                GlobalVar.getLogUtils().i("sceneC jsonDevice =" + jsonDevice);
                sceneControl(jsonDevice);
                return null;
            }
        }.execute();
    }

    /**
     * 情景控制
     */
    public static native void sceneControl(String jsonDevice);

    public void normalC(final String jsonDevice) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                GlobalVar.getLogUtils().i("normalC jsonDevice =" + jsonDevice);
                normalControl(jsonDevice);
                return null;
            }
        }.execute();
    }

    /**
     * 普通控制
     */
    private static native void normalControl(String jsonDevice);


    /**
     * 设置远程密码
     *
     * @param jsonDevice
     * @param pwd
     */
    private static native void setRemotePwd(String jsonDevice, String pwd);

    public void setPwd(final String jsonDevice, final String pwd) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                setRemotePwd(jsonDevice, pwd);
                return null;
            }
        }.execute();
    }

    private static native void getRemoteCtrlIp(String jsonDevice, String random, String pwd);

    public void searchRecordDevice() {
//        final ArrayList<Long> ids = HeService.getLocIds();
//        if (ids.isEmpty()) return;
//        new AsyncTask<Void, Void, Void>() {
//
//            @Override
//            protected Void doInBackground(Void... params) {
//                searchDevice();
//                Realm realm = Realm.getDefaultInstance();
//                for (long id : ids) {
//                    Hub host = realm.where(Hub.class).equalTo(Hub.Companion.getDEVICE_NUM(), id).findFirst();
//                    if (null != host) {
//                        if (WanState.ON == host.getWanState()) {
//                            realm.beginTransaction();
//                            host.setAlreadyHaveRemoteIP(false);
//                            realm.commitTransaction();
//                            Device device = Device.getInstance();
//                            device.setDeviceNum(ByteUtils.longToMacArray(id));
//                            device.setDeviceKey(host.getWanPwd().getBytes());
//                            Gson gson = getGson();
//                            String jsonDevice = gson.toJson(device);
//                            GlobalVar.getLogUtils().i("searchRecordDevice = " + jsonDevice);
//                            String strRandom = RandomUtil.getRandomStr();
//                            String strPwd = host.getWanPwd();
//                            getRemoteCtrlIp(jsonDevice, strRandom, strPwd);
//                        }
//                    }
//                }
//                realm.close();
//                return null;
//            }
//        }.execute();
    }

    public void searchLocalDevice() {
        new AsyncTask<Void, Void, Void>() {

            @Override
            protected Void doInBackground(Void... params) {
                searchDevice();
                Log.d(TAG, "search local device");
                return null;
            }
        }.execute();
    }

    /**
     * 链接路由
     *
     * @param jsonDevice
     * @param ssid
     * @param pwd
     */
    public static native void linkRouter(String jsonDevice, String ssid, String pwd);

    public void getlinkRouter(final String jsonDevice, final String ssid, final String pwd) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                GlobalVar.getLogUtils().i("getlinkRouter jsonDevice =" + jsonDevice);
                linkRouter(jsonDevice, ssid, pwd);
                return null;
            }
        }.execute();
    }

    /**
     * 修改密码或SSID
     *
     * @param jsonDevice
     * @param ssid
     * @param pwd
     */
    public static native void modifyAp(String jsonDevice, String ssid, String pwd);

    /**
     * 链接状态
     *
     * @param jsonDevice
     */
    public static native void linkStatus(String jsonDevice);

    public void getLinkStatus(final String jsonDevice) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                GlobalVar.getLogUtils().i("getLinkStatus jsonDevice =" + jsonDevice);
                linkStatus(jsonDevice);
                return null;
            }
        }.execute();
    }


    /**
     * 修改控制密码
     *
     * @param jsonDevice
     * @param pwd
     */
    public static native void modifyCtrlPWd(String jsonDevice, String pwd);

    public void modifyPwd(final String jsonDevice, final String pwd) {
        if (!(WifiUtils.isWifiConnected())) {
            ToastUtils.toastShort("网络未连接");
            return;
        }
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... params) {
                GlobalVar.getLogUtils().i("modifyPwd jsonDevice =" + jsonDevice);
                modifyCtrlPWd(jsonDevice, pwd);
                return null;
            }
        }.execute();
    }
}