合并第一个版本

hxb

2023-12-15 3b47201d878ba8ff973b84baf15942475688e964

 HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/core/utils/QueueUtils.java

@@ -114,13 +114,14 @@
                response.setByteData(bodyBytes);
            } else {
                LogUtils.e("解密失败\r\n" + linkPacket.getTopic() + "\r\n" + ByteUtils.encodeHexString(linkPacket.getBody()));
                response.setData(new String(linkPacket.getBody(), StandardCharsets.UTF_8));
                response.setByteData(linkPacket.getBody());
                response.setData(new String(linkPacket.getBody(), "utf-8"));
            }
        } else {
            response.setData(new String(linkPacket.getBody(), StandardCharsets.UTF_8));
            response.setByteData(linkPacket.getBody());
            response.setData(new String(linkPacket.getBody(), "utf-8"));
        }


        if (HDLConnectHelper.isLocal()) {
            if (HDLConnectHelper.isInverterTopic(response.getTopic())) {
@@ -128,6 +129,20 @@
            } else {
                LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData());
            }
//            if (!"/user/all/custom/gateway/broadcast".equals(response.getTopic())) {
//                LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData());
//            }
//            if(response.getTopic().contains("/custom/scene/list/get_reply")){
//                response.setData(response.getData()+"\":1}");
//            }
//            LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData()+ "\r\n" + response.getData().length());
        }
        if (response.getTopic().contains("/user/all/custom/gateway/")) {
//            LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData() + "\r\n" + response.getData().length());
        } else if (response.getTopic().contains("thing/property/up")) {
//            LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData() + "\r\n" + response.getData().length());
        } else {
            LogUtils.i("本地接收到数据:\r\n" + response.getTopic() + "\r\n" + response.getData() + "\r\n" + response.getData().length());
        }
        //解析完成,topic发送一次
        EventDispatcher.getInstance().post(response.getTopic(), response);