提交 96e5a417 authored 作者: yangli's avatar yangli

.

上级 d068f934
...@@ -357,7 +357,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -357,7 +357,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
private void onRpcCommand(String message) { private void onRpcCommand(String message) {
JsonNode payload = fromString(message); JsonNode payload = fromString(message);
MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder().requestId(payload.get("id").asInt()) MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder()
.method(payload.get("method").asText()).params(payload.get("params").asText()).build(); .method(payload.get("method").asText()).params(payload.get("params").asText()).build();
...@@ -365,11 +365,12 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -365,11 +365,12 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
try { try {
if ("remote_control".equals(mqttRpcDataMessage.getMethod())) {// 远程控制请求 if ("remote_control".equals(mqttRpcDataMessage.getMethod())) {// 远程控制请求
log.debug("收到远程控制请求!!!"); log.info("收到远程控制请求!!!");
SysConfigUtil.saveProperty("control.request", "1"); SysConfigUtil.saveProperty("control.request", "1");
return; return;
} }
if ("remote_control_accept".equals(mqttRpcDataMessage.getMethod())) { if ("remote_control_accept".equals(mqttRpcDataMessage.getMethod())) {
log.info("远程控制请求接受!!! params: {}", mqttRpcDataMessage.getParams());
Long minutes = Convert.toLong(mqttRpcDataMessage.getParams()); Long minutes = Convert.toLong(mqttRpcDataMessage.getParams());
remoteControlController.startVncServer(minutes); remoteControlController.startVncServer(minutes);
return; return;
...@@ -377,7 +378,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -377,7 +378,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
persistentFileService.flushRpcDataToFile(mqttRpcDataMessage); persistentFileService.flushRpcDataToFile(mqttRpcDataMessage);
} catch (Exception e) { } catch (Exception e) {
log.error("Failed to process rpc command persistent : {}", message); log.error("Failed to process rpc command persistent : {}", message, e);
} }
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论