diff --git a/src/main/java/org/b3log/symphony/util/NodeUtil.java b/src/main/java/org/b3log/symphony/util/NodeUtil.java index ee9a1170d..b894a44a8 100644 --- a/src/main/java/org/b3log/symphony/util/NodeUtil.java +++ b/src/main/java/org/b3log/symphony/util/NodeUtil.java @@ -38,7 +38,6 @@ import java.net.URI; import java.net.http.HttpClient; import java.net.http.WebSocket; -import java.nio.ByteBuffer; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.HashMap; @@ -158,12 +157,12 @@ public static void sendClear() { if (response.equals("{}")) { ChatRoomBot.sendBotMsg(nickName + ":报告!没有超过6小时未活跃的成员,一切都很和谐~"); } else { - HashMap result = parseStringToHashMap(response); + Map result = new JSONObject(response).toMap(); StringBuilder stringBuilder = new StringBuilder(); stringBuilder.append(nickName + ":报告!成功扫描超过6小时未活跃的成员,并已将他们断开连接:
"); stringBuilder.append("
不活跃用户列表"); for (String j : result.keySet()) { - long time = result.get(j); + long time = Long.parseLong(result.get(j).toString()); stringBuilder.append(j + " AFK " + time + "小时
"); } stringBuilder.append("
"); @@ -361,6 +360,7 @@ public void onOpen(WebSocket webSocket) { } private final StringBuilder messageBuffer = new StringBuilder(); + @Override public CompletionStage onText(WebSocket webSocket, CharSequence data, boolean last) { messageBuffer.append(data);