| | |
| | | try { |
| | | if (msg instanceof LinkResponse) { |
| | | LinkResponse linkResponse = (LinkResponse) msg; |
| | | if (linkResponse.getTopic() == null || !linkResponse.getTopic().contains("custom/native/inverter/")) { |
| | | if (linkResponse.getTopic() == null || !linkResponse.getTopic().contains("custom/native/inverter/up")) { |
| | | return; |
| | | } |
| | | byte[] data = linkResponse.getByteData(); |
| | |
| | | break; |
| | | } |
| | | } |
| | | |
| | | EventDispatcher.getInstance().post(topic, modbusResponse); |
| | | //发布Zigbee原生主题及数据 |
| | | // EventDispatcher.getInstance().post(allTopic, modbusResponse); |
| | |
| | | // request.setCloudTopic(String.format(TopicConstant.NATIVE_MODBUS_DOWN_SLAVE, HDLLinkConfig.getInstance().getGatewayId(), gatewayOidOrGatewayId)); |
| | | // } |
| | | request.setReplyTopic("Modbus" + payload[0] + payload[1]); |
| | | long timeout = 2 * 1000; |
| | | long timeout = 5 * 1000; |
| | | |
| | | new HDLConnectHelper(timeout, 1, gatewayBean.getIp_address(), 8586, request, new HDLConnectHelper.HdlSocketListener() { |
| | | @Override |
| | | public void onSucceed(Object msg) { |
| | | if (msg instanceof byte[]) { |
| | | if (msg instanceof int[]) { |
| | | if (null != baseCallBack) { |
| | | baseCallBack.onSuccess((byte[]) msg); |
| | | baseCallBack.onSuccess((int[]) msg); |
| | | } |
| | | } else { |
| | | LogUtils.e("发送Modbus回调对象类型非数组类型,类型是" + msg.getClass()); |