switch basic files

+/build

+apply plugin: 'com.android.application'
+apply plugin: 'realm-android'
+
+android {
+    compileSdkVersion 25
+    buildToolsVersion "25.0.2"
+
+    defaultConfig {
+        applicationId "com.qnbar.switchcontrol"
+        minSdkVersion 18
+        targetSdkVersion 25
+        versionCode 1
+        versionName "1.0"
+
+        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
+
+    }
+
+    sourceSets {
+        main {
+            jniLibs.srcDirs = ['libs']
+        }
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
+        }
+    }
+}
+
+dependencies {
+    compile fileTree(dir: 'libs', include: ['*.jar'])
+    androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
+        exclude group: 'com.android.support', module: 'support-annotations'
+    })
+    compile 'com.android.support:appcompat-v7:25.2.0'
+    compile group: 'com.google.code.gson', name: 'gson', version: '2.4'
+    testCompile 'junit:junit:4.12'
+}

+# Add project specific ProGuard rules here.
+# By default, the flags in this file are appended to flags specified
+# in /Users/wugian/Documents/android-sdk-macosx/tools/proguard/proguard-android.txt
+# You can edit the include path and order by changing the proguardFiles
+# directive in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# Add any project specific keep options here:
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}

+package com.qnbar.switchcontrol;
+
+import android.content.Context;
+import android.support.test.InstrumentationRegistry;
+import android.support.test.runner.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumentation test, which will execute on an Android device.
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+    @Test
+    public void useAppContext() throws Exception {
+        // Context of the app under test.
+        Context appContext = InstrumentationRegistry.getTargetContext();
+
+        assertEquals("com.qnbar.switchcontrol", appContext.getPackageName());
+    }
+}

+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.qnbar.switchcontrol">
+
+    <uses-permission android:name="android.permission.INTERNET" />
+
+    <application android:allowBackup="true" android:icon="@mipmap/ic_launcher"
+        android:label="@string/app_name" android:supportsRtl="true" android:theme="@style/AppTheme">
+        <activity android:name=".MainActivity">
+            <intent-filter>
+                <action android:name="android.intent.action.MAIN" />
+
+                <category android:name="android.intent.category.LAUNCHER" />
+            </intent-filter>
+        </activity>
+    </application>
+
+</manifest>
\ No newline at end of file

+package com.adroplat.fist_switch;
+
+import android.app.Application;
+import android.content.Context;
+
+/**
+ * Created by wugian on 2017/3/8.
+ */
+
+public class SwitchApplication extends Application {
+    private static Context context;
+
+    public static Context getAppContext() {
+        return context;
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+        context = this.getApplicationContext();
+    }
+}

+package com.adroplat.fist_switch.config;
+
+import android.util.Log;
+
+/**
+ * Created by wugian on 2017/3/8.
+ */
+
+public class GlobalVar {
+    public static final String CHARSET_UTF8 = "utf-8";
+    public static final byte MAX_BYTE = (byte) 0xFF;
+    static GlobalVar globalVar;
+
+
+    public static GlobalVar getLogUtils() {
+        return globalVar;
+    }
+
+    public void i(String s) {
+        Log.d("GlobalVar", s);
+    }
+}

+package com.adroplat.fist_switch.jni;
+
+
+import com.adroplat.fist_switch.config.GlobalVar;
+import com.adroplat.fist_switch.utils.ByteUtils;
+
+import java.io.Serializable;
+import java.io.UnsupportedEncodingException;
+import java.util.ArrayList;
+
+/**
+ * Created by WLJ on 16-3-8.
+ */
+public class Device implements Serializable, Cloneable {
+    private static final long serialVersionUID = -1055014034866886590L;
+
+    private static Device instance;
+
+    private Device() {
+    }
+
+    public static Device getInstance() {
+        if (null == instance) {
+            instance = new Device();
+        }
+        Device hub;
+        try {
+            hub = (Device) instance.clone();
+        } catch (CloneNotSupportedException e) {
+            hub = new Device();
+        }
+        return hub;
+    }
+
+    /**
+     * 控制ID
+     */
+    private long ControllerId;
+    /**
+     * 命令类型
+     */
+    private int CmdType;
+    /**
+     * 错误码
+     */
+    private byte ErrorCode;
+    /**
+     * 设备IP
+     */
+    private byte[] DeviceIp;
+    /**
+     * 设备端口
+     */
+    private int DevicePort;
+    /**
+     * 设备公网IP
+     */
+    private byte[] MappedIp;
+    /**
+     * 设备公网端口
+     */
+    private int MappedPort;
+    /**
+     * 设备号
+     */
+    private byte[] DeviceNum;
+    /**
+     * 设备口令
+     */
+    private byte[] DeviceKey;
+    /**
+     * 是否是广域网控制
+     */
+    private boolean IsWan;
+    /**
+     * 子设备
+     */
+    private ArrayList<SubDevice> SubDevices;
+
+    public long getControllerId() {
+        return ControllerId;
+    }
+
+    public void setControllerId(long controllerId) {
+        ControllerId = controllerId;
+    }
+
+    public int getCmdType() {
+        return CmdType;
+    }
+
+    public void setCmdType(int cmdType) {
+        CmdType = cmdType;
+    }
+
+    public byte getErrorCode() {
+        return ErrorCode;
+    }
+
+    public void setErrorCode(byte errorCode) {
+        ErrorCode = errorCode;
+    }
+
+    public byte[] getDeviceIp() {
+        return DeviceIp;
+    }
+
+    public String getStringDeviceIp() {
+        String strIp = "null";
+        if (null != DeviceIp) {
+            char point = '.';
+            StringBuilder builder = new StringBuilder();
+            for (byte b : DeviceIp) {
+                builder.append(b & GlobalVar.MAX_BYTE).append(point);
+            }
+            builder.deleteCharAt(builder.length() - 1);
+            strIp = builder.toString();
+        }
+        return strIp;
+    }
+
+    public void setDeviceIp(byte[] deviceIp) {
+        DeviceIp = deviceIp;
+    }
+
+    public int getDevicePort() {
+        return DevicePort;
+    }
+
+    public void setDevicePort(int devicePort) {
+        DevicePort = devicePort;
+    }
+
+    public byte[] getMappedIp() {
+        return MappedIp;
+    }
+
+    public void setMappedIp(byte[] mappedIp) {
+        MappedIp = mappedIp;
+    }
+
+    public int getMappedPort() {
+        return MappedPort;
+    }
+
+    public void setMappedPort(int mappedPort) {
+        MappedPort = mappedPort;
+    }
+
+    public byte[] getDeviceNum() {
+        return DeviceNum;
+    }
+
+    public void setDeviceNum(byte[] deviceNum) {
+        DeviceNum = deviceNum;
+    }
+
+    public byte[] getDeviceKey() {
+        return DeviceKey;
+    }
+
+    public String getDeviceStrKey() {
+        String strKey = "";
+        try {
+            strKey = new String(DeviceKey, GlobalVar.CHARSET_UTF8);
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return strKey;
+    }
+
+    public void setDeviceKey(byte[] deviceKey) {
+        DeviceKey = deviceKey;
+    }
+
+    public boolean isWan() {
+        return IsWan;
+    }
+
+    public void setWan(boolean wan) {
+        IsWan = wan;
+    }
+
+    public ArrayList<SubDevice> getSubDevices() {
+        return SubDevices;
+    }
+
+    public void setSubDevices(ArrayList<SubDevice> subDevices) {
+        this.SubDevices = subDevices;
+    }
+
+    /**
+     * DeviceNum转换成long
+     *
+     * @return
+     */
+    public long getLongDeviceNum() {
+        return ByteUtils.macArrayToLong(DeviceNum);
+    }
+
+    /**
+     * DeviceKey转换成long
+     *
+     * @return
+     */
+    public long getLongDeviceKey() {
+        return ByteUtils.macArrayToLong(DeviceKey);
+    }
+
+    /**
+     * MappedIp转换成int
+     *
+     * @return
+     */
+    public int getIntMappedIp() {
+        return ByteUtils.byteArrayToInt(MappedIp);
+    }
+
+    /**
+     * DeviceIp转换成int
+     *
+     * @return
+     */
+    public int getIntDeviceIp() {
+        return ByteUtils.byteArrayToInt(DeviceIp);
+    }
+}

+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 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 java.util.ArrayList;
+
+import io.realm.Realm;
+
+/**
+ * Created by WLJ on 2016/1/14.
+ */
+public class FistJni {
+    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 void online(Device device, String jsonDevice) {
+        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.setIp(device.getIntDeviceIp());
+//            host.setLAN(true);
+//            realm.commitTransaction();
+//            FistJni.getInstance().query(jsonDevice);
+//        }
+        realm.close();
+    }
+
+    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);
+    }
+
+    public static void fistListener(String jsonDevice) {
+        if (null == jsonDevice || jsonDevice.isEmpty()) return;
+        GlobalVar.getLogUtils().i("fistListener jsonDevice =" + jsonDevice);
+        Gson gson = getGson();
+        Device device = gson.fromJson(jsonDevice, Device.class);
+        char cmdTpye = (char) device.getCmdType();
+
+        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()) {//查询结果不为空
+                Realm realm = Realm.getDefaultInstance();
+//                long hostNum = device.getLongDeviceNum();
+//                RealmResults<Hub> hubs = realm.where(Hub.class)
+//                        .equalTo(Hub.Companion.getDEVICE_NUM(), hostNum)
+//                        .notEqualTo(Transform.Companion.getSYNC_CODE(), SyncState.DELETE.ordinal()).findAll();
+//                if (!hubs.isEmpty()) {
+//                    int subSize = subDevices.size();
+//                    for (int i = 0; i < subSize; i++) {
+//                        SubDevice subDevice = subDevices.get(i);
+//                        long subDeviceNum = subDevice.getSubDeviceNum();
+//                        RealmResults<SwSubDev> swSubDevs = realm.where(SwSubDev.class)
+//                                .equalTo(SwSubDev.Companion.getHOST_NUM(), hostNum)
+//                                .equalTo(SwSubDev.Companion.getPARENT_NUM(), subDeviceNum)
+//                                .findAll();
+//                        if (!swSubDevs.isEmpty()) {//数据库已存储
+//                            int lightingSize = swSubDevs.size();
+//                            byte lingtingState = (byte) subDevice.getSubDeviceStatus();
+//                            for (int j = 0; j < lightingSize; j++) {//更新开关状态
+//                                SwSubDev lighting = swSubDevs.get(j);
+//                                realm.beginTransaction();
+//                                byte currentState = (byte) (lingtingState >> lighting.getDeviceNum() & 1);
+//                                if (0 == currentState) {
+//                                    lighting.setOn(false);
+//                                } else {
+//                                    lighting.setOn(true);
+//                                }
+//                                realm.commitTransaction();
+//                            }
+//                        }
+//                    }
+//                }
+
+                realm.close();
+            }
+//            sendJsonDevice(LightingGroupAdapter.REFRESH, device);
+
+        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_RESPONSE == cmdTpye) {
+            sendJsonDevice(START_ADD, device);
+
+        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_OVER == cmdTpye) {//子设备结束入网
+//            if (0 == device.getIntDeviceIp()) return;
+//            FistJni.stopAddSubDevice(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);
+
+        } 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) {//查询对端失败
+
+        }*/
+    }
+
+    /**
+     * 开始
+     */
+    public static native void start();
+
+    /**
+     * 启动SKD
+     */
+    public void startSdk() {
+        new AsyncTask<Void, Void, Void>() {
+            @Override
+            protected Void doInBackground(Void... params) {
+                start();
+                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 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();
+                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();
+    }
+}
\ No newline at end of file

+//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 com.adroplat.fist_switch.adapter.LightingGroupAdapter;
+//import com.adroplat.fist_switch.config.GlobalVar;
+//import com.adroplat.fist_switch.service.HeService;
+//import com.adroplat.fist_switch.sqlite.Hub;
+//import com.adroplat.fist_switch.sqlite.SwSubDev;
+//import com.adroplat.fist_switch.sqlite.SyncState;
+//import com.adroplat.fist_switch.sqlite.Transform;
+//import com.adroplat.fist_switch.sqlite.WanState;
+//import com.adroplat.fist_switch.ui.SwitchApp;
+//import com.adroplat.fist_switch.utils.ByteUtils;
+//import com.adroplat.fist_switch.utils.RandomUtil;
+//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.adroplat.fist_switch.utils.protocol.remote.RemoteProtocol;
+//import com.google.gson.Gson;
+//
+//import java.util.ArrayList;
+//
+//import io.realm.Realm;
+//import io.realm.RealmResults;
+//
+///**
+// * Created by WLJ on 2016/1/14.
+// */
+//public class FistJni_back {
+//    static {
+//        System.loadLibrary("fist_ndk");
+//    }
+//
+//    private static FistJni_back instance;
+//
+//    private FistJni_back() {
+//    }
+//
+//    public static FistJni_back getInstance() {
+//        if (null == instance) {
+//            instance = new FistJni_back();
+//        }
+//        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 void online(Device device, String jsonDevice) {
+//        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.setIp(device.getIntDeviceIp());
+//            host.setLAN(true);
+//            realm.commitTransaction();
+//            FistJni_back.getInstance().query(jsonDevice);
+//        }
+//        realm.close();
+//    }
+//
+//    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 = SwitchApp.getAppContext();
+//        if (null == context) return;
+//        Intent intent = getIntent();
+//        intent.setAction(action);
+//        intent.putExtra(JSON_DEVICE, device);
+//        LocalBroadcastManager.getInstance(context).sendBroadcast(intent);
+//    }
+//
+//    public static void fistListener(String jsonDevice) {
+//        if (null == jsonDevice || jsonDevice.isEmpty()) return;
+//        GlobalVar.getLogUtils().i("fistListener jsonDevice =" + jsonDevice);
+//        Gson gson = getGson();
+//        Device device = gson.fromJson(jsonDevice, Device.class);
+//        char cmdTpye = (char) device.getCmdType();
+//
+//        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()) {//查询结果不为空
+//                Realm realm = Realm.getDefaultInstance();
+//                long hostNum = device.getLongDeviceNum();
+//                RealmResults<Hub> hubs = realm.where(Hub.class)
+//                        .equalTo(Hub.Companion.getDEVICE_NUM(), hostNum)
+//                        .notEqualTo(Transform.Companion.getSYNC_CODE(), SyncState.DELETE.ordinal()).findAll();
+//                if (!hubs.isEmpty()) {
+//                    int subSize = subDevices.size();
+//                    for (int i = 0; i < subSize; i++) {
+//                        SubDevice subDevice = subDevices.get(i);
+//                        long subDeviceNum = subDevice.getSubDeviceNum();
+//                        RealmResults<SwSubDev> swSubDevs = realm.where(SwSubDev.class)
+//                                .equalTo(SwSubDev.Companion.getHOST_NUM(), hostNum)
+//                                .equalTo(SwSubDev.Companion.getPARENT_NUM(), subDeviceNum)
+//                                .findAll();
+//                        if (!swSubDevs.isEmpty()) {//数据库已存储
+//                            int lightingSize = swSubDevs.size();
+//                            byte lingtingState = (byte) subDevice.getSubDeviceStatus();
+//                            for (int j = 0; j < lightingSize; j++) {//更新开关状态
+//                                SwSubDev lighting = swSubDevs.get(j);
+//                                realm.beginTransaction();
+//                                byte currentState = (byte) (lingtingState >> lighting.getDeviceNum() & 1);
+//                                if (0 == currentState) {
+//                                    lighting.setOn(false);
+//                                } else {
+//                                    lighting.setOn(true);
+//                                }
+//                                realm.commitTransaction();
+//                            }
+//                        }
+//                    }
+//                }
+//
+//                realm.close();
+//            }
+//            sendJsonDevice(LightingGroupAdapter.REFRESH, device);
+//
+//        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_RESPONSE == cmdTpye) {
+//            sendJsonDevice(START_ADD, device);
+//
+//        } else if (FistProtocol.CommondType.CMD_TYPE_ADD_OVER == cmdTpye) {//子设备结束入网
+////            if (0 == device.getIntDeviceIp()) return;
+////            FistJni.stopAddSubDevice(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);
+//
+//        } 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) {//查询对端失败
+//
+//        }
+//    }
+//
+//    /**
+//     * 开始
+//     */
+//    public static native void start();
+//
+//    /**
+//     * 启动SKD
+//     */
+//    public void startSdk() {
+//        new AsyncTask<Void, Void, Void>() {
+//            @Override
+//            protected Void doInBackground(Void... params) {
+//                start();
+//                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 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();
+//                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();
+//    }
+//}
\ No newline at end of file

+package com.adroplat.fist_switch.jni;
+
+/**
+ * Created by yikuyiliao on 16-3-8.
+ */
+public class SubDevice implements Cloneable {
+
+    private static SubDevice instance;
+
+    private SubDevice() {
+    }
+
+    public static SubDevice getInstance() {
+        if (null == instance) {
+            instance = new SubDevice();
+        }
+        SubDevice subDevice = null;
+        try {
+            subDevice = (SubDevice) instance.clone();
+        } catch (CloneNotSupportedException e) {
+            e.printStackTrace();
+        }
+        if (null == subDevice) {
+            subDevice = new SubDevice();
+        }
+        return subDevice;
+    }
+
+    private long SubDeviceNum;
+    private int SubDeviceType;
+    private int SubDeviceStatus;
+    private int SubDeviceOnlineStatus;
+    private int SubDeviceBit;
+
+
+    public long getSubDeviceNum() {
+
+        return SubDeviceNum;
+    }
+
+    public void setSubDeviceNum(long subDeviceNum) {
+
+        SubDeviceNum = subDeviceNum;
+    }
+
+    public int getSubDeviceType() {
+        return SubDeviceType;
+    }
+
+    public void setSubDeviceType(int subDeviceType) {
+
+        SubDeviceType = subDeviceType;
+    }
+
+    public int getSubDeviceStatus() {
+        return SubDeviceStatus;
+    }
+
+    public void setSubDeviceStatus(int subDeviceStatus) {
+
+        SubDeviceStatus = subDeviceStatus;
+    }
+
+    public int getSubDeviceOnlineStatus() {
+        return SubDeviceOnlineStatus;
+    }
+
+    public void setSubDeviceOnlineStatus(int subDeviceOnlineStatus) {
+        SubDeviceOnlineStatus = subDeviceOnlineStatus;
+    }
+
+    public int getSubDeviceBit() {
+        return SubDeviceBit;
+    }
+
+    public void setSubDeviceBit(int subDeviceBit) {
+        SubDeviceBit = subDeviceBit;
+    }
+}

+package com.adroplat.fist_switch.utils;
+
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+
+//import com.adroplat.fist_switch.utils.protocol.remote.RemoteHead;
+
+/**
+ * byte转换工具类
+ * Created by WLJ on 2015/10/10.
+ */
+public class ByteUtils {
+
+
+    /**
+     * byte数组转int
+     *
+     * @param byteArray
+     * @return
+     */
+    public static int byteArrayToInt(byte[] byteArray) {
+        int value = 0;
+        if (null == byteArray || 4 != byteArray.length) {
+
+        } else {
+            int len = byteArray.length;
+            for (int i = 0; i < len; i++) {
+                value += (byteArray[i] & 0xff) << (8 * (3 - i));
+            }
+        }
+        return value;
+    }
+
+    /**
+     * int转byte数组
+     *
+     * @param value
+     * @return
+     */
+    public static byte[] intToByteArrays(int value) {
+        byte[] byteArray = new byte[4];
+        int len = byteArray.length;
+        for (int i = 0; i < len; i++) {
+            byteArray[i] = (byte) ((value >> (8 * (3 - i))) & 0xff);
+        }
+        return byteArray;
+    }
+
+    public static String intToIp(int ipInt) {
+        StringBuilder builder = new StringBuilder();
+        builder.delete(0, builder.length());
+        char c = '.';
+        return builder.append(((ipInt >> 24) & 0xff)).append(c)
+                .append((ipInt >> 16) & 0xff).append(c)
+                .append((ipInt >> 8) & 0xff).append(c)
+                .append((ipInt & 0xff))
+                .toString();
+    }
+
+    public static byte[] intToLend(int value) {
+        byte[] byteArray = new byte[4];
+        int len = byteArray.length;
+        for (int i = 0; i < len; i++) {
+            byteArray[i] = (byte) ((value >> (8 * i)) & 0xff);
+        }
+        return byteArray;
+    }
+
+    /**
+     * byte数组转long
+     *
+     * @param macArray
+     * @return
+     */
+    public static long macArrayToLong(byte[] macArray) {
+        long value = 0;
+        if (null == macArray || 8 < macArray.length) {
+
+        } else {
+            int len = macArray.length;
+            for (int i = 0; i < len; i++) {
+                value |= (long) (macArray[i] & 0xff) << (8 * (len - i - 1));
+            }
+        }
+        return value;
+    }
+
+    /**
+     * long转byte数组
+     *
+     * @param value
+     * @return
+     */
+    public static byte[] longToMacArray(long value) {
+        byte[] lAray = longToBytes(value);
+        return Arrays.copyOfRange(lAray, 2, lAray.length);
+    }
+
+
+    /**
+     * long转16进制String
+     *
+     * @param value
+     * @return
+     */
+    public static String longToHexString(long value) {
+        byte[] array = longToMacArray(value);
+        int offset = 0;
+        int len = array.length;
+        for (int i = 0; i < len; i++) {
+            if (0 != array[i]) {
+                offset = i;
+                break;
+            }
+        }
+        array = Arrays.copyOfRange(array, offset, len);
+        return byteArayToHexString(array).trim();
+    }
+
+    /**
+     * 16进制String转long
+     *
+     * @param hex
+     * @return
+     */
+    public static long hexStringToLong(String hex) {
+        byte[] array = hexStringToByteAray(hex);
+        return macArrayToLong(array);
+    }
+
+    /**
+     * byte数组转16进制String
+     *
+     * @param array
+     * @return
+     */
+    public static String byteArayToHexString(byte[] array) {
+        String strHex = null;
+        if (null == array || 0 == array.length) {
+        } else {
+            StringBuilder builder = new StringBuilder();
+            for (byte b : array) {
+                String str = Integer.toHexString(b & 0xff);
+                if (1 == str.length()) {
+                    str = '0' + str;
+                }
+                builder.append(str);
+            }
+            strHex = builder.toString();
+        }
+        return strHex;
+    }
+
+    /**
+     * byte数组转16进制MAC
+     *
+     * @param array
+     * @return
+     */
+    public static String byteArayToMacStr(byte[] array) {
+        String strHex = null;
+        if (null == array || 0 == array.length) {
+        } else {
+            StringBuilder builder = new StringBuilder();
+            for (byte b : array) {
+                String str = Integer.toHexString(b & 0xff);
+                if (1 == str.length()) {
+                    str = '0' + str;
+                }
+                builder.append(str + ":");
+            }
+            strHex = builder.deleteCharAt(builder.length() - 1).toString().toUpperCase();
+        }
+        return strHex;
+    }
+
+    /**
+     * 16进制String转byte数组
+     *
+     * @param hex
+     * @return
+     */
+    public static byte[] hexStringToByteAray(String hex) {
+        if (hex == null || hex.equals("")) {
+            return null;
+        }
+        hex = hex.toUpperCase();
+        char[] hexChars = hex.toCharArray();
+        int len = hexChars.length / 2;
+        byte[] d = new byte[len];
+        for (int i = 0; i < len; i++) {
+            int pos = i * 2;
+            d[i] = (byte) (charToByte(hexChars[pos]) << 4 | charToByte(hexChars[pos + 1]));
+        }
+        return d;
+    }
+
+    /**
+     * Convert char to byte
+     *
+     * @param c char
+     * @return byte
+     */
+    private static byte charToByte(char c) {
+        return (byte) "0123456789ABCDEF".indexOf(c);
+    }
+
+    /**
+     * int转char
+     *
+     * @param value
+     * @return
+     */
+    public static char intToChar(int value) {
+        byte[] byteArray = intToByteArrays(value);
+//        return (char) ((byteArray[2] & 0xff) << 8 | byteArray[3] & 0xff);
+        return bytesToChar(byteArray);
+    }
+
+
+    /**
+     * char转byte[]
+     */
+    public static byte[] charToBytes(char c) {
+        byte[] bytes = new byte[2];
+//        final char DIGIT = RemoteHead.DIGIT;
+//        bytes[0] = (byte) ((c >> 8) & DIGIT);
+//        bytes[1] = (byte) (c & DIGIT);
+        return bytes;
+    }
+
+    /**
+     * byte[]转char
+     */
+    public static char bytesToChar(byte[] bytes) {
+        char c = 0;
+        if (null != bytes) {
+            int size = bytes.length;
+            if (size >= 2) {
+                c = (char) ((bytes[size - 2] & 0xff) << 8 | bytes[size - 1] & 0xff);
+            } else if (1 == size) {
+                c = (char) (bytes[0]);
+            }
+        }
+        return c;
+    }
+
+    /**
+     * 转化CRON需要的星期
+     *
+     * @param weekCode
+     * @return
+     */
+    public static String byteToDayWeek(byte weekCode, String weekDay[]) {
+        StringBuilder sb = new StringBuilder();
+        if (null != weekDay) {
+            final int size = weekDay.length;
+            for (int i = 0; i < size; i++) {
+                if (0 != (weekCode >> i) % 2) {
+                    sb.append(weekDay[i]).append(",");
+                }
+            }
+            int len = sb.length();
+            if (len > 0) {
+                sb.deleteCharAt(len - 1);
+            }
+        }
+        return sb.toString();
+    }
+
+    public static byte[] longToBytes(long value) {
+        ByteBuffer buffer = ByteBuffer.allocate(8);
+        buffer.putLong(0, value);
+        return buffer.array();
+    }
+
+    public static long bytesToLong(byte[] value) {
+        long result = 0;
+        if (null != value) {
+            for (int i = 0; i < value.length; i++) {
+                value[i] &= 0xff;
+            }
+            ByteBuffer buffer = ByteBuffer.allocate(8);
+            buffer.put(value, 0, value.length);
+            buffer.flip();//need flip
+            result = buffer.getLong();
+        }
+        return result;
+    }
+
+}

+package com.adroplat.fist_switch.utils;
+
+import android.util.Log;
+
+/**
+ * Created by wugian on 2017/3/8.
+ */
+
+public class ToastUtils {
+    public static void toastShort(String s){
+        Log.d("ToastUtils", s);
+    }
+}

+package com.adroplat.fist_switch.utils;
+
+/**
+ * Created by wugian on 2017/3/8.
+ */
+
+public class WifiUtils {
+    public static boolean isWifiConnected() {
+        return true;
+    }
+}

+package com.qnbar.switchcontrol;
+
+import android.os.Bundle;
+import android.os.Handler;
+import android.os.Message;
+import android.support.v7.app.AppCompatActivity;
+import android.util.Log;
+import android.view.View;
+
+import com.adroplat.fist_switch.jni.FistJni;
+
+public class MainActivity extends AppCompatActivity {
+
+    @Override
+    protected void onCreate(Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+        setContentView(R.layout.activity_main);
+
+        Handler handler = new Handler() {
+            @Override
+            public void dispatchMessage(Message msg) {
+                super.dispatchMessage(msg);
+                switch (msg.what) {
+                    case UdpPostSender.MSG_What:
+                        Log.d("lovely_switch", "msg what:" + msg.toString());
+                        break;
+                    default:
+                        Log.d("lovely_switch", msg.toString());
+                }
+            }
+        };
+//        new UdpPostSender("", 9000, 9000, handler).start();
+        new Thread(){
+            @Override
+            public void run() {
+                super.run();
+                new UdpHelper().StartListen();
+            }
+        }.start();
+//        new UdpHelper().run();
+//        new UdpHelper().run();
+    }
+
+    public void startSdk(View view) {
+        FistJni fistJni = FistJni.getInstance();
+        fistJni.startSdk();
+    }
+
+    public void searchLocalDevice(View view){
+        FistJni fistJni = FistJni.getInstance();
+        fistJni.searchLocalDevice();
+    }
+}

+package com.qnbar.switchcontrol;
+
+import android.util.Log;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+import java.net.SocketException;
+/**
+ * UdpHelper帮助类
+ * 
+ */
+public class UdpHelper{
+    public    Boolean IsThreadDisable = false;//指示监听线程是否终止
+    InetAddress mInetAddress;
+
+    public void StartListen()  {
+        // UDP服务器监听的端口
+        Integer port = 9000;
+        // 接收的字节大小，客户端发送的数据不能超过这个大小
+        byte[] message = new byte[4096];
+        try {
+            // 建立Socket连接
+            DatagramSocket datagramSocket = new DatagramSocket(port);
+            datagramSocket.setBroadcast(true);
+            try {
+                while (!IsThreadDisable) {
+                    // 准备接收数据
+                    Log.d("UDP_Demo", "准备接受");
+
+                    DatagramPacket datagramPacket = new DatagramPacket(message,
+                            message.length);
+                    datagramSocket.receive(datagramPacket);
+                    String strMsg=new String(datagramPacket.getData()).trim();
+                    Log.d("UDP_Demo", datagramPacket.getAddress()
+                            .getHostAddress().toString()
+                            + ":" +strMsg );
+                }
+            } catch (IOException e) {//IOException
+                e.printStackTrace();
+            }
+        } catch (SocketException e) {
+            e.printStackTrace();
+        }
+    }
+   /* public static void send(String message) {
+        message = (message == null ? “Hello IdeasAndroid!” : message);
+        int server_port = 8904;
+        Log.d(“UDP Demo”, “UDP发送数据:”+message);
+        DatagramSocket s = null;
+        try {
+            s = new DatagramSocket();
+        } catch (SocketException e) {
+            e.printStackTrace();
+        }
+        InetAddress local = null;
+        try {
+            local = InetAddress.getByName(“255.255.255.255”);
+        } catch (UnknownHostException e) {
+            e.printStackTrace();
+        }
+        int msg_length = message.length();
+        byte[] messageByte = message.getBytes();
+        DatagramPacket p = new DatagramPacket(messageByte, msg_length, local,
+                server_port);
+        try {
+            s.send(p);
+            s.close();
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }*/
+}
\ No newline at end of file

+package com.qnbar.switchcontrol;
+
+import android.os.Handler;
+import android.os.Message;
+import android.text.TextUtils;
+import android.util.Log;
+
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.UnknownHostException;
+
+/**
+ * UDP通信接口类，采用单例模式，用ip和通信端口初始化
+ */
+public class UdpPostSender extends Thread {
+
+    public static final int MSG_What = 0x100;
+    protected static final int MSG_PARSE_DATA = 0x100;
+    private static final String TAG = "UdpPostSender";
+
+    private boolean isThreadDisable = false;// 指示监听线程是否终止
+    private Handler mHandler;
+    private DatagramSocket udpSocket = null;
+    private DatagramPacket dataPacket = null;
+    private InetAddress broadcastAddr = null;
+    private int defaultPort;
+    private int remotePort;
+    private String ip;
+    private String remoteIp;
+
+    public UdpPostSender(String iP, int defaultPort, int remotePort,
+                         Handler handler) {
+        this.ip = iP;
+        this.defaultPort = defaultPort;
+        this.remotePort = remotePort;
+        this.mHandler = handler;
+
+        initData();
+
+        if (handler != null) {// 不需要接收恢复信息的udp
+            this.start();
+        }
+    }
+
+    public String getRemoteIp() {
+        return remoteIp;
+    }
+
+    @Override
+    public void run() {
+        startListen();
+    }
+
+    private void initData() {
+        try {
+            if (udpSocket == null) {
+                udpSocket = new DatagramSocket(null);
+                udpSocket.setReuseAddress(true);
+                // udpSocket.setSoTimeout(5000);
+                udpSocket.bind(new InetSocketAddress(defaultPort));
+            }
+            Log.i("info", "ip----" + ip);
+            broadcastAddr = InetAddress.getByName(ip);
+
+        } catch (Exception e) {
+            Log.i("info", e.getMessage());
+        }
+    }
+
+    public void sendUDPmsg(final String command) {
+        byte out[] = command.getBytes();
+        dataPacket = new DatagramPacket(out, out.length);
+        dataPacket.setPort(remotePort);
+        try {
+            dataPacket.setAddress(InetAddress.getByName(remoteIp));
+        } catch (UnknownHostException e) {
+            Log.i("info", e.getMessage());
+            e.printStackTrace();
+        }
+        Log.e(TAG, "cmd" + command + broadcastAddr.toString());
+        new Thread() {
+            public void run() {
+                try {
+                    udpSocket.send(dataPacket);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        }.start();
+    }
+
+    public void startListen() {
+        while (!isThreadDisable) {
+            try {
+                // 准备接收数据
+                byte[] buf = new byte[4 * 1024];
+                DatagramPacket packet = new DatagramPacket(buf, buf.length);
+                initData();
+//                udpSocket.setSoTimeout(2 * 1000);
+                udpSocket.receive(packet);
+                Log.d("lovely_switch", "success");
+//                String ip = packet.getAddress().getHostAddress();
+                String cmd = new String(packet.getData(), 0, packet.getLength());
+                if (!TextUtils.isEmpty(cmd)) {
+                    remoteIp = packet.getAddress().toString().replace("/", "");
+                }
+                Message m = Message.obtain();
+                m.what = MSG_PARSE_DATA;
+                m.obj = cmd;
+                mHandler.sendMessage(m);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    public void stopListen() {
+        isThreadDisable = true;
+    }
+}
\ No newline at end of file

+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools" android:id="@+id/activity_main"
+    android:layout_width="match_parent" android:layout_height="match_parent"
+    android:paddingBottom="@dimen/activity_vertical_margin"
+    android:paddingLeft="@dimen/activity_horizontal_margin"
+    android:paddingRight="@dimen/activity_horizontal_margin"
+    android:paddingTop="@dimen/activity_vertical_margin"
+    android:orientation="vertical"
+    tools:context="com.qnbar.switchcontrol.MainActivity">
+
+    <TextView android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:text="Hello World!" />
+
+    <Button
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:onClick="startSdk"
+        android:text="startSdk"/>
+
+    <Button
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:onClick="searchLocalDevice"
+        android:text="searchLocalDevice"/>
+
+</LinearLayout>

+<resources>
+    <!-- Example customization of dimensions originally defined in res/values/dimens.xml
+         (such as screen margins) for screens with more than 820dp of available width. This
+         would include 7" and 10" devices in landscape (~960dp and ~1280dp respectively). -->
+    <dimen name="activity_horizontal_margin">64dp</dimen>
+</resources>

+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <color name="colorPrimary">#3F51B5</color>
+    <color name="colorPrimaryDark">#303F9F</color>
+    <color name="colorAccent">#FF4081</color>
+</resources>

+<resources>
+    <!-- Default screen margins, per the Android Design guidelines. -->
+    <dimen name="activity_horizontal_margin">16dp</dimen>
+    <dimen name="activity_vertical_margin">16dp</dimen>
+</resources>

+<resources>
+    <string name="app_name">SwitchControl</string>
+</resources>

+<resources>
+
+    <!-- Base application theme. -->
+    <style name="AppTheme" parent="Theme.AppCompat.Light.DarkActionBar">
+        <!-- Customize your theme here. -->
+        <item name="colorPrimary">@color/colorPrimary</item>
+        <item name="colorPrimaryDark">@color/colorPrimaryDark</item>
+        <item name="colorAccent">@color/colorAccent</item>
+    </style>
+
+</resources>

+package com.qnbar.switchcontrol;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+public class ExampleUnitTest {
+    @Test
+    public void addition_isCorrect() throws Exception {
+        assertEquals(4, 2 + 2);
+    }
+}
\ No newline at end of file