| | |
| | | }; |
| | | //注册直接通讯的主题,包括直接和主网关通讯或者直接和从网关通讯 |
| | | registerListener(String.format(TopicConstant.NATIVE_MODBUS_UP, "+"), eventListener); |
| | | registerListener(String.format(TopicConstant.NATIVE_MODBUS_DOWN_REPLY, "+"), eventListener); |
| | | |
| | | // registerListener(String.format(TopicConstant.NATIVE_ZIGBEE_UP_SLAVE, "+", "+"), eventListener); |
| | | //registerListener(String.format(TopicConstant.NATIVE_MODBUS_DOWN_REPLY, "+"), eventListener); |
| | | //registerListener(String.format(TopicConstant.NATIVE_ZIGBEE_UP_SLAVE, "+", "+"), eventListener); |
| | | } |
| | | |
| | | /** |
| | |
| | | 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 byte[]) { |
| | | if (null != baseCallBack) { |
| | | baseCallBack.onSuccess((byte[])msg); |
| | | } |
| | |
| | | return; |
| | | } |
| | | ModBusBean modBusBean = com.alibaba.fastjson.JSONObject.parseObject(JSON.toJSONString(tempData), ModBusBean.class); |
| | | // ModBusBean modBusBean = new ModBusBean(); |
| | | // modBusBean.setOid("0101050219D44A00"); |
| | | // modBusBean.setData(new byte[]{00,01,00,00,00,0x09,00,00,00,01,03,00,00,00,01}); |
| | | if (modBusBean.getOid() == null || modBusBean.getData() == null) { |
| | | LogUtils.i("内容为空,oid=" + modBusBean.getOid() + " data=" + modBusBean.getData()); |
| | | return; |