|
|
@@ -68,8 +68,8 @@ public class FireDeviceStatusTask {
|
|
|
byte[] activeCodeByte =ReUtil.hexStringToByteArray(activeCode);
|
|
|
mqttSend.send(MqttConstants.TOPIC_FIRE_DEVICE + vo.getDeviceCode(), activeCodeByte);
|
|
|
//兼容指令无反应问题
|
|
|
- Thread.sleep(500);
|
|
|
- mqttSend.send(MqttConstants.TOPIC_FIRE_DEVICE + vo.getDeviceCode(), activeCodeByte);
|
|
|
+ /*Thread.sleep(500);
|
|
|
+ mqttSend.send(MqttConstants.TOPIC_FIRE_DEVICE + vo.getDeviceCode(), activeCodeByte);*/
|
|
|
logger.info("集合数量:" + list.size() + ",mqtt消息推送, 灭火装置状态请求,实验室id:" + vo.getSubjectId() + ",采集器编号:" + vo.getDeviceCode()+",继电器编号"+vo.getRelayCode());
|
|
|
|
|
|
|