电子病历发送通知优化

src/main/java/thyyxxk/webserver/controller/zhuyuanyizheng/EmrWebSocketController.java

@@ -27,8 +27,9 @@ public class EmrWebSocketController {
 
     @GetMapping("/sendAMessage")
     public ResultVo<String> sendAMessage(@RequestParam("sid") String sid,
+                                         @RequestParam("key") String key,
                                          @RequestParam("message") String message) {
-        return server.sendAMessage(sid, message);
+        return server.sendAMessage(sid, key, message);
     }
 
     @GetMapping("/getChatHistoryBySid")
@@ -46,4 +47,5 @@ public class EmrWebSocketController {
         return server.clearTheCurrentMedicalRecordUser(id);
     }
 
+
 }

src/main/java/thyyxxk/webserver/service/zhuyuanyisheng/EmrWebSocketServer.java

@@ -44,7 +44,7 @@ public class EmrWebSocketServer {
         return query.substring(query.indexOf("=") + 1);
     }
 
-    public ResultVo<String> sendAMessage(String sid, String message) {
+    public ResultVo<String> sendAMessage(String sid, String key, String message) {
         EmrSocketMessage esm = new EmrSocketMessage();
         UserInfo us = redisLikeService.getUserInfoByToken();
 
@@ -67,7 +67,7 @@ public class EmrWebSocketServer {
         lists.forEach(item -> {
             String code = sessionParseUserCode(item);
             if (!code.equals(us.getCode())) {
-                WebSocketServer.emrSendMessage(item, String.format("{\"message\" : \"%s\"}", message));
+                WebSocketServer.emrSendMessage(item, String.format("{\"%s\" : \"%s\"}", key, message));
             }
         });
         return ResultVoUtil.success();
@@ -96,4 +96,6 @@ public class EmrWebSocketServer {
         dao.deleteUserById(id, TokenUtil.getTokenUserId());
         return ResultVoUtil.success();
     }
+
+
 }