| | |
|---|
| | | logger.debug(json.toJSONString()); |
|---|
| | | } |
|---|
| | | String text = onlineElement.getText(); |
|---|
| | | if (Objects.equals(text.trim().toUpperCase(), "ONLINE")) { |
|---|
| | | if ("ONLINE".equalsIgnoreCase(text.trim())) { |
|---|
| | | deviceService.online(device); |
|---|
| | | }else { |
|---|
| | | deviceService.offline(device.getDeviceId()); |
|---|
| | | } |
|---|
| | | RequestMessage msg = new RequestMessage(); |
|---|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS + device.getDeviceId() + channelId); |
|---|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS + device.getDeviceId()); |
|---|
| | | msg.setData(json); |
|---|
| | | deferredResultHolder.invokeAllResult(msg); |
|---|
| | | } |
|---|
