Commit 1624c716 authored by 赵啸非's avatar 赵啸非

设备同步添加楼层和楼栋

parent 1b0e272c
......@@ -51,6 +51,10 @@ public class DeviceRestartTaskImpl implements ITaskExcuteService {
StrUtil.split(restartProduct, ",").stream().forEach(productCode -> {
List<DeviceEntity> deviceEntities = deviceService.find(new DeviceQuery().productCode(productCode));
for (DeviceEntity device : deviceEntities) {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
}
TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
header.put(MessageHeader.MESSAGETYPE, MESSAGETYPE_NOTIFY_RESTART_APP);
header.put(MessageHeader.DEVICECODE, device.getDeviceCode());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment