| | |
|---|
| | | } |
|---|
| | | byte []data = linkResponse.getByteData(); |
|---|
| | | ModbusResponse modbusResponse= new ModbusResponse(); |
|---|
| | | modbusResponse.setTopic("Modbus"+data[0]+data[1]); |
|---|
| | | String topic="Modbus"+data[0]+data[1]; |
|---|
| | | modbusResponse.setTopic(topic); |
|---|
| | | modbusResponse.setData(data); |
|---|
| | | String oid = null; |
|---|
| | | //是否是通过主网关透传主题 |
|---|
| | |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | EventDispatcher.getInstance().post(allTopic, modbusResponse); |
|---|
| | | EventDispatcher.getInstance().post(topic, modbusResponse); |
|---|
| | | //发布Zigbee原生主题及数据 |
|---|
| | | // EventDispatcher.getInstance().post(allTopic, zigbeeResponse); |
|---|
| | | // EventDispatcher.getInstance().post(allTopic, modbusResponse); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | LogUtils.e(TAG,"LinkResponse转ModbusResponse异常:"+ e.getMessage()); |
|---|
| | |
|---|
| | | String tempTopic = String.format(TopicConstant.NATIVE_MODBUS_DOWN, gatewayOidOrGatewayId); |
|---|
| | | LinkRequest request = new LinkRequest(tempTopic, payload, gatewayBean.getIsLocalEncrypt()); |
|---|
| | | |
|---|
| | | if ("true".equals(gatewayBean.getMaster())) { |
|---|
| | | // if ("true".equals(gatewayBean.getMaster())) { |
|---|
| | | request.setCloudTopic(String.format(TopicConstant.NATIVE_MODBUS_DOWN, HDLLinkConfig.getInstance().getGatewayId())); |
|---|
| | | } else { |
|---|
| | | request.setCloudTopic(String.format(TopicConstant.NATIVE_MODBUS_DOWN_SLAVE, HDLLinkConfig.getInstance().getGatewayId(), gatewayOidOrGatewayId)); |
|---|
| | | } |
|---|
| | | // } else { |
|---|
| | | // request.setCloudTopic(String.format(TopicConstant.NATIVE_MODBUS_DOWN_SLAVE, HDLLinkConfig.getInstance().getGatewayId(), gatewayOidOrGatewayId)); |
|---|
| | | // } |
|---|
| | | request.setReplyTopic("Modbus"+payload[0]+payload[1]); |
|---|
| | | long timeout = 2 * 1000; |
|---|
| | | |
|---|
