From e91af284643d5e370b0d18c384fe8de65f59d9b3 Mon Sep 17 00:00:00 2001
From: JLChen <551775569@qq.com>
Date: 星期四, 24 九月 2020 12:01:10 +0800
Subject: [PATCH] 2020-09-24 1.修改MQTTSDK引用方式,修复闪退问题。

---
 Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLCommandText.java |  314 ++++++++++++++++++++++++++-------------------------
 1 files changed, 159 insertions(+), 155 deletions(-)

diff --git a/Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLCommandText.java b/Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLCommandText.java
index ab4e1fb..59422a0 100644
--- a/Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLCommandText.java
+++ b/Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLCommandText.java
@@ -1,6 +1,7 @@
 package com.hdl.sdk.hdl_core.HDLDeviceManger.Core;
 
 import android.util.Log;
+
 import com.google.gson.Gson;
 import com.hdl.sdk.hdl_core.Config.ZigbeeDeviceID;
 import com.hdl.sdk.hdl_core.HDLDeviceManger.Bean.ZigbeeBean.CommonErrorBean;
@@ -39,7 +40,7 @@
     private static boolean isFinished = false;//鏍囪鍥炶皟鍜屽満鏅澶囨暟鎹�
     public static Timer timer = null;//璁剧疆璁惧鍜屽満鏅洖璋�
     private static String ipAddr;//璁惧畾鎺у埗鏃剁殑ip鍦板潃
-    private static boolean is1 = false,is2 = false;//鏍囪鑾峰彇鐨勬俯搴﹀拰椋庢墖寮哄害
+    private static boolean is1 = false, is2 = false;//鏍囪鑾峰彇鐨勬俯搴﹀拰椋庢墖寮哄害
     private static int airTag = 0;//鏍囪浼犺繘鏉ユ帶鍒剁┖璋冪殑鏄粈涔堟柟寮忥紙寮�鍏炽�佹ā寮忋�侀閫熴�佽瀹氭俯搴︼級
     private static int airMode = 1;//鏍囨敞鏇存敼娓╁害鏃讹紝鎺у埗鐨勬ā寮�
     private static int scenesId = 0;//鍙戝満鏅椂浼犲叆锛屾柟渚挎敹鍦烘櫙
@@ -53,12 +54,12 @@
         this.ipAddr = ipAddr;
     }
 
-    public static void initData(){
+    public static void initData() {
         zigbeeDeviceListBeans = new ArrayList<>();//鎼滅储鎴栨帶鍒舵椂鍊欓渶鍒濆鍖�
     }
 
-    public interface DataCallBack{
-        void onSuccess( List<ZigbeeDeviceListBean> zigbeeDeviceListBeans,ZigbeeSceneListBean zigbeeSceneListBeans);
+    public interface DataCallBack {
+        void onSuccess(List<ZigbeeDeviceListBean> zigbeeDeviceListBeans, ZigbeeSceneListBean zigbeeSceneListBeans);
     }
 
     //澶勭悊鎺ユ敹鐨勬暟鎹�
@@ -70,24 +71,24 @@
         //鎵�鏈変俊鎭幏鍙栧畬澶勭悊
         //閫夋嫨缃戝叧鐨勮瘽瑕佸湪鍒ゆ柇涓姞)
 
-        if (topic.contains("Scene/GetInfo_Respon")){
+        if (topic.contains("Scene/GetInfo_Respon")) {
             //澶勭悊鎼滅储鍒扮殑鍦烘櫙
             handleSceneList(message);
         }
 
-        if (topic.contains("DeviceInfoRespon")){
+        if (topic.contains("DeviceInfoRespon")) {
             //澶勭悊鑾峰彇鍒扮殑璁惧
             handleDeviceList(message);
         }
 
-        if (topic.contains("Scene/Open_Respon")){
+        if (topic.contains("Scene/Open_Respon")) {
             //杩斿洖鍦烘櫙琚墽琛�
             reportSceneStatus(message);
             return;
         }
 
-        if (topic.contains("DeviceInfoResponEnd")&&
-                zigbeeDeviceListBeans.get(0).getData().getGwId().equals(gatewayId)){
+        if (topic.contains("DeviceInfoResponEnd") &&
+                zigbeeDeviceListBeans.get(0).getData().getGwId().equals(gatewayId)) {
             Log.d("11113", "绋嬪簭鎺ュ彈瀹岃繘鏉ュ鐞�: ");
             isFinished = true;
         }
@@ -97,14 +98,14 @@
             return;
         }
 
-        ZigbeeReportBean zigbeeReportBean =JsonUtil.parseJsonWithGson(message, ZigbeeReportBean.class);
+        ZigbeeReportBean zigbeeReportBean = JsonUtil.parseJsonWithGson(message, ZigbeeReportBean.class);
         int cluterId = zigbeeReportBean.getData().getCluterID();
-        if (!(cluterId == 6 || cluterId==8 || cluterId == 258 || cluterId == 513 || cluterId == 514)) {
+        if (!(cluterId == 6 || cluterId == 8 || cluterId == 258 || cluterId == 513 || cluterId == 514)) {
             HDLLog.info("涓嶅鐞嗙殑cluterId:" + cluterId);
             return;
         }
         int deviceID = zigbeeReportBean.getDevice_ID();
-        switch (deviceID){
+        switch (deviceID) {
             case ZigbeeDeviceID.OnOffOutput:
                 //鐏厜璁惧
                 StatusReadBackBean lightReadBackBean = new StatusReadBackBean();
@@ -121,28 +122,28 @@
                 }
                 break;
             case ZigbeeDeviceID.WindowCoveringDevice:
-                 //绐楀笜璁惧
-                 StatusReadBackBean curtainReadBackBean = new StatusReadBackBean();
-                  for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData()
-                     .getAttriBute()){
-                     if (attriButeBean.getAttriButeId() == 8){
-                         curtainReadBackBean.setValue(attriButeBean.getAttriButeData());
-                     }
-                  }
-                  String curtainReadBackJson = JsonUtil.toJson(curtainReadBackBean);
-                  if (stateListener != null) {
-                      StateEvent event = new StateEvent(curtainReadBackJson);
-                      stateListener.onData(event);
-                  }
+                //绐楀笜璁惧
+                StatusReadBackBean curtainReadBackBean = new StatusReadBackBean();
+                for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData()
+                        .getAttriBute()) {
+                    if (attriButeBean.getAttriButeId() == 8) {
+                        curtainReadBackBean.setValue(attriButeBean.getAttriButeData());
+                    }
+                }
+                String curtainReadBackJson = JsonUtil.toJson(curtainReadBackBean);
+                if (stateListener != null) {
+                    StateEvent event = new StateEvent(curtainReadBackJson);
+                    stateListener.onData(event);
+                }
                 break;
             case ZigbeeDeviceID.DimmableLight:
                 //璋冨厜鍣ㄨ澶�
                 StatusReadBackBean dimmableLightReadBackBean = new StatusReadBackBean();
                 for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData()
                         .getAttriBute()) {
-                    if (attriButeBean.getAttriButeId() == 0 && cluterId==8 ) {
-                        Log.d("2222", "璋冨厜鍣ㄦ暟鎹�: "+attriButeBean.getAttriButeData());
-                        dimmableLightReadBackBean.setValue((int) (attriButeBean.getAttriButeData()/2.55));
+                    if (attriButeBean.getAttriButeId() == 0 && cluterId == 8) {
+                        Log.d("2222", "璋冨厜鍣ㄦ暟鎹�: " + attriButeBean.getAttriButeData());
+                        dimmableLightReadBackBean.setValue((int) (attriButeBean.getAttriButeData() / 2.55));
                     }
                 }
                 String dimmableLightReadBackJson = JsonUtil.toJson(dimmableLightReadBackBean);
@@ -153,42 +154,43 @@
                 break;
             case ZigbeeDeviceID.Thermostat:
                 //绌鸿皟璁惧
-                for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean:zigbeeReportBean.getData().getAttriBute()){
+                for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData().getAttriBute()) {
 
-                    if (attriButeBean.getAttriButeId() == 28 && attriButeBean.getAttriButeDataType() == 48){
+                    if (attriButeBean.getAttriButeId() == 28 && attriButeBean.getAttriButeDataType() == 48) {
                         //褰撳墠鐨勭┖璋冩ā寮�
                         int thermostatmode = attriButeBean.getAttriButeData();
                         thermostatReadBackBean.setThermostatmode(thermostatmode);
                         is1 = true;
                     }
 
-                    if (attriButeBean.getAttriButeId() == 0 && attriButeBean.getAttriButeDataType() == 0x30){
+                    if (attriButeBean.getAttriButeId() == 0 && attriButeBean.getAttriButeDataType() == 0x30) {
                         //褰撳墠鐨勬柊椋庢ā寮�
                         int fanmode = attriButeBean.getAttriButeData();
                         thermostatReadBackBean.setFanmode(fanmode);
                         is2 = true;
                     }
-                    if (attriButeBean.getAttriButeId() == 17 && attriButeBean.getAttriButeDataType() == 41){
+                    if (attriButeBean.getAttriButeId() == 17 && attriButeBean.getAttriButeDataType() == 41) {
                         //鍒跺喎娓╁害
-                        int coolingSetpoint = attriButeBean.getAttriButeData()/100;
+                        int coolingSetpoint = attriButeBean.getAttriButeData() / 100;
                         thermostatReadBackBean.setCoolingSetpoint(coolingSetpoint);
                         //Log.d("11113", "鍒跺喎娓╁害涓�: "+coolingSetpoint);
 
                     }
-                    if (attriButeBean.getAttriButeId() == 18 && attriButeBean.getAttriButeDataType() == 41){
+                    if (attriButeBean.getAttriButeId() == 18 && attriButeBean.getAttriButeDataType() == 41) {
                         //鍒剁儹娓╁害
-                        int heatingSetpoint = attriButeBean.getAttriButeData()/100;
+                        int heatingSetpoint = attriButeBean.getAttriButeData() / 100;
                         thermostatReadBackBean.setHeatingSetpoint(heatingSetpoint);
                         //Log.d("11113", "鍒剁儹娓╁害涓�: "+heatingSetpoint);
 
                     }
                 }
-                if (is1 && is2 ){ //浠h〃鑾峰彇鎭掓俯鍣ㄥ拰椋庢墖鐨勭姸鎬佸悗鐨勫洖璋�
-                    is1 = false;is2 = false;
+                if (is1 && is2) { //浠h〃鑾峰彇鎭掓俯鍣ㄥ拰椋庢墖鐨勭姸鎬佸悗鐨勫洖璋�
+                    is1 = false;
+                    is2 = false;
                     thermostatReadBackBean.setTag(airTag);
                     String thermostatReadJson = JsonUtil.toJson(thermostatReadBackBean);
                     //Log.d("11113", "鏁版嵁鏁版嵁鏁版嵁"+thermostatReadJson);
-                    if (stateListener != null ){
+                    if (stateListener != null) {
                         StateEvent event = new StateEvent(thermostatReadJson);
                         stateListener.onData(event);
                     }
@@ -197,8 +199,8 @@
             case ZigbeeDeviceID.AirPanel:
                 //鏂伴璁惧
                 StatusReadBackBean airPanelReadBackBean = new StatusReadBackBean();
-                for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData().getAttriBute()){
-                    if (attriButeBean.getAttriButeId() == 0 && attriButeBean.getAttriButeDataType() == 0x30){
+                for (ZigbeeReportBean.DataBean.AttriButeBean attriButeBean : zigbeeReportBean.getData().getAttriBute()) {
+                    if (attriButeBean.getAttriButeId() == 0 && attriButeBean.getAttriButeDataType() == 0x30) {
                         //褰撳墠鐨勬柊椋庢ā寮�
                         int fanmode = attriButeBean.getAttriButeData();
                         airPanelReadBackBean.setValue(fanmode);
@@ -213,10 +215,10 @@
         }
     }
 
-    public static void sendThirdPartyJson(final ZigbeeDeviceSaveBean zigbeeJson, String statusJson, int type){
+    public static void sendThirdPartyJson(final ZigbeeDeviceSaveBean zigbeeJson, String statusJson, int type) {
         HDLZigbeeMqtt.connect1(ipAddr);
         // 鍒ゆ柇鏄痺rite 杩樻槸 read锛屾帶鍒舵椂鍒ゆ柇浼犻�掑弬鏁�
-        switch (type){
+        switch (type) {
             case ZigbeeDeviceID.OnOffOutput:
                 //缁х數鍣�
                 GatewayCommondBean gatewayCommondBean = JsonUtil.parseJsonWithGson(statusJson, GatewayCommondBean.class);
@@ -224,10 +226,10 @@
                     reportError("cmd parameter error, please check it out");
                     return;
                 }
-                switch (gatewayCommondBean.getCmd()){
+                switch (gatewayCommondBean.getCmd()) {
                     case "write":
                         // 鐏厜鎺у埗锛�0鍏� 1寮�
-                        if (!(gatewayCommondBean.getValue()==1||gatewayCommondBean.getValue()==0)){
+                        if (!(gatewayCommondBean.getValue() == 1 || gatewayCommondBean.getValue() == 0)) {
                             reportError("Wrong lighting control parameters");
                             return;
                         }
@@ -241,7 +243,7 @@
                         new Thread(new Runnable() {
                             @Override
                             public void run() {
-                                HDLZigbeeMqtt.sendMqttData1( "DeviceControl", ctrlLightjson);
+                                HDLZigbeeMqtt.sendMqttData1("DeviceControl", ctrlLightjson);
                             }
                         }).start();
                         break;
@@ -272,14 +274,14 @@
                     return;
                 }
                 //绐楀笜鎺у埗
-                switch (gatewayCurtainBean.getCmd()){
+                switch (gatewayCurtainBean.getCmd()) {
                     case "write":
                         ZigbeeCtrlBean curtainCtrl = new ZigbeeCtrlBean();
                         curtainCtrl.setCluster_ID(258);
                         int curtainCmd;
-                        switch (gatewayCurtainBean.getTag()){
+                        switch (gatewayCurtainBean.getTag()) {
                             case 0:
-                                switch (gatewayCurtainBean.getValue()){
+                                switch (gatewayCurtainBean.getValue()) {
                                     case 0:
                                         curtainCmd = 0;
                                         break;
@@ -328,53 +330,53 @@
                         curtainBean.setAttriBute(curtainAttriButeBeanList);
                         curtainReadBean.setData(curtainBean);
                         String curtainReadJson = JsonUtil.toJson(curtainReadBean);
-                        HDLZigbeeMqtt.sendMqttData1("GetDeviceStatus",curtainReadJson);
+                        HDLZigbeeMqtt.sendMqttData1("GetDeviceStatus", curtainReadJson);
                         break;
                 }
                 break;
-                case ZigbeeDeviceID.DimmableLight:
-                    //璋冨厜鐏�
-                    GatewayCommondBean dimmableLightBean = JsonUtil.parseJsonWithGson(statusJson, GatewayCommondBean.class);
-                    if (dimmableLightBean.getCmd() == null) {
-                        reportError("cmd parameter error, please check it out");
-                        return;
-                    }
-                    switch (dimmableLightBean.getCmd()){
-                        case "write":
-                            // 璋冨厜鎺у埗
-                            ZigbeeDimmableCtrlBean light = new ZigbeeDimmableCtrlBean();
-                            ZigbeeDimmableCtrlBean.Data data = new ZigbeeDimmableCtrlBean.Data();
-                            light.setCluster_ID(8);
-                            light.setSendMode(2);
-                            light.setCommand(4);
-                            light.setDeviceAddr(zigbeeJson.getDeviceAddr());
-                            light.setEpoint(zigbeeJson.getEpoint());
-                            data.setLevel(dimmableLightBean.getValue());
-                            data.setTransitionTime(2);
-                            light.setData(data);
-                            String ctrlLightjson = JsonUtil.toJson(light);
-                            HDLZigbeeMqtt.sendMqttData1( "DeviceControl", ctrlLightjson);
-                            break;
-                        case "read":
-                            ZigbeeReadBean lightReadBean = new ZigbeeReadBean();
-                            lightReadBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
-                            lightReadBean.setEpoint(zigbeeJson.getEpoint());
-                            lightReadBean.setCluster_ID(8);
-                            lightReadBean.setCommand(108);
-                            lightReadBean.setSendMode(2);
+            case ZigbeeDeviceID.DimmableLight:
+                //璋冨厜鐏�
+                GatewayCommondBean dimmableLightBean = JsonUtil.parseJsonWithGson(statusJson, GatewayCommondBean.class);
+                if (dimmableLightBean.getCmd() == null) {
+                    reportError("cmd parameter error, please check it out");
+                    return;
+                }
+                switch (dimmableLightBean.getCmd()) {
+                    case "write":
+                        // 璋冨厜鎺у埗
+                        ZigbeeDimmableCtrlBean light = new ZigbeeDimmableCtrlBean();
+                        ZigbeeDimmableCtrlBean.Data data = new ZigbeeDimmableCtrlBean.Data();
+                        light.setCluster_ID(8);
+                        light.setSendMode(2);
+                        light.setCommand(4);
+                        light.setDeviceAddr(zigbeeJson.getDeviceAddr());
+                        light.setEpoint(zigbeeJson.getEpoint());
+                        data.setLevel(dimmableLightBean.getValue());
+                        data.setTransitionTime(2);
+                        light.setData(data);
+                        String ctrlLightjson = JsonUtil.toJson(light);
+                        HDLZigbeeMqtt.sendMqttData1("DeviceControl", ctrlLightjson);
+                        break;
+                    case "read":
+                        ZigbeeReadBean lightReadBean = new ZigbeeReadBean();
+                        lightReadBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
+                        lightReadBean.setEpoint(zigbeeJson.getEpoint());
+                        lightReadBean.setCluster_ID(8);
+                        lightReadBean.setCommand(108);
+                        lightReadBean.setSendMode(2);
 
-                            ZigbeeReadBean.DataBean lightBean = new ZigbeeReadBean.DataBean();
-                            List<ZigbeeReadBean.DataBean.AttriButeBean> lightAttriButeBeanList = new ArrayList<>();
-                            ZigbeeReadBean.DataBean.AttriButeBean lightAttriButeBean = new ZigbeeReadBean.DataBean.AttriButeBean();
-                            lightAttriButeBean.setAttriButeId(0);
-                            lightAttriButeBeanList.add(lightAttriButeBean);
-                            lightBean.setAttriBute(lightAttriButeBeanList);
-                            lightReadBean.setData(lightBean);
-                            String lightReadJson = JsonUtil.toJson(lightReadBean);
-                            HDLZigbeeMqtt.sendMqttData1("GetDeviceStatus", lightReadJson);
-                            break;
-                    }
-                    break;
+                        ZigbeeReadBean.DataBean lightBean = new ZigbeeReadBean.DataBean();
+                        List<ZigbeeReadBean.DataBean.AttriButeBean> lightAttriButeBeanList = new ArrayList<>();
+                        ZigbeeReadBean.DataBean.AttriButeBean lightAttriButeBean = new ZigbeeReadBean.DataBean.AttriButeBean();
+                        lightAttriButeBean.setAttriButeId(0);
+                        lightAttriButeBeanList.add(lightAttriButeBean);
+                        lightBean.setAttriBute(lightAttriButeBeanList);
+                        lightReadBean.setData(lightBean);
+                        String lightReadJson = JsonUtil.toJson(lightReadBean);
+                        HDLZigbeeMqtt.sendMqttData1("GetDeviceStatus", lightReadJson);
+                        break;
+                }
+                break;
             case ZigbeeDeviceID.Thermostat:
                 //绌鸿皟
                 final GatewayCommondBean thermostatBean = JsonUtil.parseJsonWithGson(statusJson, GatewayCommondBean.class);
@@ -382,17 +384,17 @@
                     reportError("cmd parameter error, please check it out");
                     return;
                 }
-                switch (thermostatBean.getCmd()){
-                    case  "write":
-                        switch (airTag){
+                switch (thermostatBean.getCmd()) {
+                    case "write":
+                        switch (airTag) {
                             case 0://寮�鍏�,寮�鍏充紶鍏ュ紑鍏�01
-                                switch (thermostatBean.getValue()){
+                                switch (thermostatBean.getValue()) {
                                     case 0://绌鸿皟鍏�
                                         new Thread(new Runnable() {
                                             @Override
                                             public void run() {
-                                                sendFan(zigbeeJson,0);//鍙戦�侀鎵囨帶鍒�
-                                                sendThermostat(zigbeeJson,0);//鍙戦�佹亽娓╁櫒
+                                                sendFan(zigbeeJson, 0);//鍙戦�侀鎵囨帶鍒�
+                                                sendThermostat(zigbeeJson, 0);//鍙戦�佹亽娓╁櫒
                                             }
                                         }).start();
                                         break;
@@ -400,8 +402,8 @@
                                         new Thread(new Runnable() {
                                             @Override
                                             public void run() {
-                                                sendThermostat(zigbeeJson,1);
-                                                sendFan(zigbeeJson,4);
+                                                sendThermostat(zigbeeJson, 1);
+                                                sendFan(zigbeeJson, 4);
                                             }
                                         }).start();
 
@@ -412,7 +414,7 @@
                                 new Thread(new Runnable() {
                                     @Override
                                     public void run() {
-                                        sendThermostat(zigbeeJson,thermostatBean.getValue());
+                                        sendThermostat(zigbeeJson, thermostatBean.getValue());
                                     }
                                 }).start();
                                 break;
@@ -420,17 +422,17 @@
                                 new Thread(new Runnable() {
                                     @Override
                                     public void run() {
-                                        sendFan(zigbeeJson,thermostatBean.getValue());
+                                        sendFan(zigbeeJson, thermostatBean.getValue());
                                     }
                                 }).start();
                                 break;
                             case 3://鎺у埗娓╁害
-                                switch (airMode){
+                                switch (airMode) {
                                     case 0://鍒剁儹
                                         new Thread(new Runnable() {
                                             @Override
                                             public void run() {
-                                                contrlThermostat(zigbeeJson,thermostatBean.getValue(),0);
+                                                contrlThermostat(zigbeeJson, thermostatBean.getValue(), 0);
                                             }
                                         }).start();
                                         break;
@@ -438,7 +440,7 @@
                                         new Thread(new Runnable() {
                                             @Override
                                             public void run() {
-                                                contrlThermostat(zigbeeJson,thermostatBean.getValue(),1);
+                                                contrlThermostat(zigbeeJson, thermostatBean.getValue(), 1);
                                             }
                                         }).start();
                                         break;
@@ -446,7 +448,7 @@
                                         new Thread(new Runnable() {
                                             @Override
                                             public void run() {
-                                                contrlThermostat(zigbeeJson,thermostatBean.getValue(),2);
+                                                contrlThermostat(zigbeeJson, thermostatBean.getValue(), 2);
                                             }
                                         }).start();
                                         break;
@@ -493,9 +495,9 @@
                     reportError("cmd parameter error, please check it out");
                     return;
                 }
-                switch (airpanelBean.getCmd()){
-                    case  "write":
-                        sendNewFan(zigbeeJson,airpanelBean.getValue());
+                switch (airpanelBean.getCmd()) {
+                    case "write":
+                        sendNewFan(zigbeeJson, airpanelBean.getValue());
                         break;
                     case "read":
                         readFan(zigbeeJson);
@@ -507,49 +509,50 @@
     }
 
     //鍒濆鍖栫姸鎬佷俊鎭�
-    public static void initStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type){
+    public static void initStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type) {
         initData();
         airTag = 0;
         new Thread(new Runnable() {
             @Override
             public void run() {
-                String sendStatus = HDLCommandText.setSendStatus("read",0);//璇讳笉闇�瑕佺煡閬撶姸鎬侊紝闅忎究濉竴涓�
-                HDLCommandText.sendThirdPartyJson(zigbeeDevice,sendStatus, type);
+                String sendStatus = HDLCommandText.setSendStatus("read", 0);//璇讳笉闇�瑕佺煡閬撶姸鎬侊紝闅忎究濉竴涓�
+                HDLCommandText.sendThirdPartyJson(zigbeeDevice, sendStatus, type);
             }
         }).start();
     }
 
     //鏇存柊绌鸿皟鐘舵��
-    public static void initAirStatus(final ZigbeeDeviceSaveBean zigbeeDevice,final int type ,int tag){
+    public static void initAirStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type, int tag) {
         airTag = tag;
-        String sendStatus = HDLCommandText.setSendStatus("read",0);//璇讳笉闇�瑕佺煡閬撶姸鎬侊紝闅忎究濉竴涓�
-        HDLCommandText.sendThirdPartyJson(zigbeeDevice,sendStatus, type);
+        String sendStatus = HDLCommandText.setSendStatus("read", 0);//璇讳笉闇�瑕佺煡閬撶姸鎬侊紝闅忎究濉竴涓�
+        HDLCommandText.sendThirdPartyJson(zigbeeDevice, sendStatus, type);
     }
 
 
     //鍙戦�佺┖璋冩帶鍒�
-    public static void sendAirStatus(final ZigbeeDeviceSaveBean zigbeeDevice,final int type ,final int value,
-                                     int tag,int mode){
-        airTag = tag;  airMode = mode;
-        String sendStatus = HDLCommandText.setSendStatus("write",value);
-        HDLCommandText.sendThirdPartyJson(zigbeeDevice,sendStatus,type);
+    public static void sendAirStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type, final int value,
+                                     int tag, int mode) {
+        airTag = tag;
+        airMode = mode;
+        String sendStatus = HDLCommandText.setSendStatus("write", value);
+        HDLCommandText.sendThirdPartyJson(zigbeeDevice, sendStatus, type);
     }
 
     //鍙戦�佸紑鍏虫帶鍒舵帶鍒�
-    public static void sendStatus(final ZigbeeDeviceSaveBean zigbeeDevice,final int type,final int value){
-        String sendStatus = HDLCommandText.setSendStatus("write",value);
-        HDLCommandText.sendThirdPartyJson(zigbeeDevice,sendStatus,type);
+    public static void sendStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type, final int value) {
+        String sendStatus = HDLCommandText.setSendStatus("write", value);
+        HDLCommandText.sendThirdPartyJson(zigbeeDevice, sendStatus, type);
     }
 
     //鍒濆鍖栫獥甯樻帶鍒�
-    public static void sendCurtainStatus(final ZigbeeDeviceSaveBean zigbeeDevice,final int type,
-                                         final int value,final int tag){
-        String sendStatus = HDLCommandText.setSendCurtainStatus("write",value,tag);
-        HDLCommandText.sendThirdPartyJson(zigbeeDevice,sendStatus,type);
+    public static void sendCurtainStatus(final ZigbeeDeviceSaveBean zigbeeDevice, final int type,
+                                         final int value, final int tag) {
+        String sendStatus = HDLCommandText.setSendCurtainStatus("write", value, tag);
+        HDLCommandText.sendThirdPartyJson(zigbeeDevice, sendStatus, type);
     }
 
     //璁剧疆缁х數鍣ㄧ殑鐘舵��
-    private static String setSendStatus(String status,int value){
+    private static String setSendStatus(String status, int value) {
         GatewayCommondBean gatewayCommondBean = new GatewayCommondBean();
         gatewayCommondBean.setCmd(status);
         gatewayCommondBean.setValue(value);
@@ -558,7 +561,7 @@
     }
 
     //璁剧疆绐楀笜鐨勭姸鎬�
-    private static String setSendCurtainStatus(String status,int value,int tag){
+    private static String setSendCurtainStatus(String status, int value, int tag) {
         GatewayCurtainBean gatewayCurtainBean = new GatewayCurtainBean();
         gatewayCurtainBean.setCmd(status);
         gatewayCurtainBean.setValue(value);
@@ -568,7 +571,7 @@
     }
 
     //鍙戦�佹亽娓╁櫒妯″紡
-    private static void sendThermostat(ZigbeeDeviceSaveBean zigbeeJson,int value){
+    private static void sendThermostat(ZigbeeDeviceSaveBean zigbeeJson, int value) {
         ZigbeeWriteCtrlBean zigbeeOffBean = new ZigbeeWriteCtrlBean();
         zigbeeOffBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
         zigbeeOffBean.setEpoint(zigbeeJson.getEpoint());
@@ -580,12 +583,12 @@
         zigbeeOffDataBean.setAttributeData(value);
         zigbeeOffBean.setData(zigbeeOffDataBean);
         String zigbeeoffJson = JsonUtil.toJson(zigbeeOffBean);
-        HDLZigbeeMqtt.sendMqttData1("SetWritableValue",zigbeeoffJson);
-        initAirStatus(zigbeeJson,ZigbeeDeviceID.Thermostat,airTag);
+        HDLZigbeeMqtt.sendMqttData1("SetWritableValue", zigbeeoffJson);
+        initAirStatus(zigbeeJson, ZigbeeDeviceID.Thermostat, airTag);
     }
 
     //鍙戦�侀妯″紡
-    private static void sendFan(final ZigbeeDeviceSaveBean zigbeeJson, int value){
+    private static void sendFan(final ZigbeeDeviceSaveBean zigbeeJson, int value) {
         ZigbeeWriteCtrlBean zigbeeOffBean = new ZigbeeWriteCtrlBean();
         zigbeeOffBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
         zigbeeOffBean.setEpoint(zigbeeJson.getEpoint());
@@ -597,12 +600,12 @@
         zigbeeOffDataBean.setAttributeData(value);
         zigbeeOffBean.setData(zigbeeOffDataBean);
         String zigbeeoffJson = JsonUtil.toJson(zigbeeOffBean);
-        HDLZigbeeMqtt.sendMqttData1("SetWritableValue",zigbeeoffJson);
-        initAirStatus(zigbeeJson,ZigbeeDeviceID.Thermostat,airTag);
+        HDLZigbeeMqtt.sendMqttData1("SetWritableValue", zigbeeoffJson);
+        initAirStatus(zigbeeJson, ZigbeeDeviceID.Thermostat, airTag);
     }
 
     //鏂伴鐘舵�佷笅鍙戦�佹柊椋庢ā寮�
-    private static void sendNewFan(final ZigbeeDeviceSaveBean zigbeeJson, int value){
+    private static void sendNewFan(final ZigbeeDeviceSaveBean zigbeeJson, int value) {
         ZigbeeWriteCtrlBean zigbeeOffBean = new ZigbeeWriteCtrlBean();
         zigbeeOffBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
         zigbeeOffBean.setEpoint(zigbeeJson.getEpoint());
@@ -614,12 +617,12 @@
         zigbeeOffDataBean.setAttributeData(value);
         zigbeeOffBean.setData(zigbeeOffDataBean);
         String zigbeeoffJson = JsonUtil.toJson(zigbeeOffBean);
-        HDLZigbeeMqtt.sendMqttData1("SetWritableValue",zigbeeoffJson);
-        initStatus(zigbeeJson,ZigbeeDeviceID.AirPanel);
+        HDLZigbeeMqtt.sendMqttData1("SetWritableValue", zigbeeoffJson);
+        initStatus(zigbeeJson, ZigbeeDeviceID.AirPanel);
     }
 
     //娓╁害鎺у埗
-    private static void contrlThermostat(ZigbeeDeviceSaveBean zigbeeJson,int value, int mode){
+    private static void contrlThermostat(ZigbeeDeviceSaveBean zigbeeJson, int value, int mode) {
         ZigbeeThermostatCtrlBean zigbeeThermostatCtrlBean = new ZigbeeThermostatCtrlBean();
         zigbeeThermostatCtrlBean.setDeviceAddr(zigbeeJson.getDeviceAddr());
         zigbeeThermostatCtrlBean.setEpoint(zigbeeJson.getEpoint());
@@ -631,12 +634,12 @@
         zigbeeData.setAmount(value);
         zigbeeThermostatCtrlBean.setData(zigbeeData);
         String zigbeeCtrlJson = JsonUtil.toJson(zigbeeThermostatCtrlBean);
-        HDLZigbeeMqtt.sendMqttData1("DeviceControl",zigbeeCtrlJson);
-        initAirStatus(zigbeeJson,ZigbeeDeviceID.Thermostat,airTag);
+        HDLZigbeeMqtt.sendMqttData1("DeviceControl", zigbeeCtrlJson);
+        initAirStatus(zigbeeJson, ZigbeeDeviceID.Thermostat, airTag);
     }
 
     //鏌ョ湅椋庨��
-    private static void readFan(ZigbeeDeviceSaveBean zigbeeJson){
+    private static void readFan(ZigbeeDeviceSaveBean zigbeeJson) {
 
         //鑾峰彇褰撳墠閫氶淇℃伅
         ZigbeeReadBean fanBean = new ZigbeeReadBean();
@@ -657,7 +660,7 @@
     }
 
     //鍙戦�佸満鏅暟鎹�
-    public static void sendSceneStatus(int ScenesId,int DelayTime){
+    public static void sendSceneStatus(int ScenesId, int DelayTime) {
         scenesId = ScenesId;
         ZigbeeSceneCtrlBean zigbeeSceneCtrlBean = new ZigbeeSceneCtrlBean();
         zigbeeSceneCtrlBean.setCluster_ID(0);
@@ -667,19 +670,19 @@
         dataBean.setDelayTime(DelayTime);
         zigbeeSceneCtrlBean.setData(dataBean);
         String json = JsonUtil.toJson(zigbeeSceneCtrlBean);
-        HDLZigbeeMqtt.sendMqttData1("Scene/Open",json);
+        HDLZigbeeMqtt.sendMqttData1("Scene/Open", json);
     }
 
     //澶勭悊璁惧淇℃伅
     private static void handleDeviceList(String message) {
-        ZigbeeDeviceListBean zigbeeDeviceListBean = JsonUtil.parseJsonWithGson(message,ZigbeeDeviceListBean.class);
+        ZigbeeDeviceListBean zigbeeDeviceListBean = JsonUtil.parseJsonWithGson(message, ZigbeeDeviceListBean.class);
         zigbeeDeviceListBeans.add(zigbeeDeviceListBean);
     }
 
     //澶勭悊鍦烘櫙淇℃伅
     private static void handleSceneList(String message) {
         Gson gson = new Gson();
-        zigbeeSceneListBean = gson.fromJson(message,ZigbeeSceneListBean.class);
+        zigbeeSceneListBean = gson.fromJson(message, ZigbeeSceneListBean.class);
     }
 
     //澶勭悊鍦烘櫙鐨勬暟鎹�
@@ -690,11 +693,11 @@
             return;
         }
         StatusReadBackBean statusReadBackBean = new StatusReadBackBean();
-        if (sceneCtrlBackBean.getData().getScenesId() == scenesId){
+        if (sceneCtrlBackBean.getData().getScenesId() == scenesId) {
             statusReadBackBean.setValue(sceneCtrlBackBean.getData().getResult());
         }
         String Json = JsonUtil.toJson(statusReadBackBean);
-        Log.d("11114", "澶勭悊鏁版嵁鍥炶皟: "+Json);
+        Log.d("11114", "澶勭悊鏁版嵁鍥炶皟: " + Json);
         if (stateListener != null) {
             StateEvent event = new StateEvent(Json);
             stateListener.onData(event);
@@ -702,25 +705,26 @@
     }
 
     //鍥炶皟鑾峰彇鍒扮殑璁惧淇℃伅
-    public static void handleDeviceData(final DataCallBack dataCallBack){
+    public static void handleDeviceData(final DataCallBack dataCallBack) {
         timer = new Timer();
         timer.schedule(new TimerTask() {
             @Override
             public void run() {
-                if (!isFinished){
+                if (!isFinished) {
                     Log.d("11112", "run: 绋嬪簭鎵ц涓�");
-                }else {
+                } else {
                     timer.cancel();
                     timer.purge();
                     timer = null;
                     isFinished = false;
-                    dataCallBack.onSuccess(zigbeeDeviceListBeans,zigbeeSceneListBean);
+                    dataCallBack.onSuccess(zigbeeDeviceListBeans, zigbeeSceneListBean);
                 }
             }
-        },1,500);
+        }, 1, 500);
     }
-    public static void reSearch(){
-        if (timer != null){
+
+    public static void reSearch() {
+        if (timer != null) {
             timer.cancel();
             timer.purge();
             timer = null;
@@ -734,7 +738,7 @@
             CommonErrorBean errorBean = new CommonErrorBean();
             errorBean.setCmd("error");
             errorBean.setReason(reason);
-            String errorJson =JsonUtil.toJson(errorBean);
+            String errorJson = JsonUtil.toJson(errorBean);
             StateEvent event = new StateEvent(errorJson);
             stateListener.onData(event);
         }

--
Gitblit v1.8.0