问诊socket流程提交

virtual-patient-web/src/main/java/com/supervision/controller/TestController.java

@@ -1,5 +1,9 @@
 package com.supervision.controller;
 
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.io.file.FileReader;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
 import com.supervision.model.ConfigPhysicalTool;
 import com.supervision.service.ConfigPhysicalToolService;
 import lombok.RequiredArgsConstructor;
@@ -7,6 +11,7 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.io.File;
 import java.util.List;
 
 @RestController
@@ -25,4 +30,12 @@ public class TestController {
     public List<ConfigPhysicalTool> testQueryJSON(){
         return configPhysicalToolService.list();
     }
+
+
+    public static void main(String[] args) {
+        File file = FileUtil.newFile("/Users/flevance/Desktop/template.txt");
+        List<String> strings = FileReader.create(file).readLines();
+        System.out.println(JSONUtil.toJsonStr(strings));
+
+    }
 }

virtual-patient-web/src/main/java/com/supervision/paddlespeech/TtsUtil.java

@@ -29,7 +29,7 @@ public class TtsUtil {
             }
             return response.getResult().getAudio();
         } catch (Exception e) {
-            throw new BusinessException("语音转换文字失败");
+            throw new BusinessException("语音转换文字失败", e);
         }
 
     }

virtual-patient-web/src/main/java/com/supervision/paddlespeech/dto/res/PaddleSpeechResDTO.java

@@ -9,7 +9,7 @@ public class PaddleSpeechResDTO<T> {
 
     private Integer code;
 
-    private String message;
+    private Object message;
 
     private T result;
 }

virtual-patient-web/src/main/java/com/supervision/service/impl/AskServiceImpl.java

@@ -87,7 +87,7 @@ public class AskServiceImpl implements AskService {
         SocketMessageDTO res = new SocketMessageDTO();
         res.setSocketId(socketMessageDTO.getSocketId());
         res.setUserId(UserUtil.getUser().getId());
-        res.setTextMessage("医生,我们有听懂您说的什么");
+        res.setTextMessage("医生,我没有听懂您说的什么意思");
         res.setType(1);
         session.sendMessage(new TextMessage(JSONUtil.toJsonStr(res)));
         log.info("兜底话术,需要检查上面是不是出什么问题了");

virtual-patient-web/src/main/java/com/supervision/websocket/handler/AskWebSocketHandler.java

@@ -3,6 +3,7 @@ package com.supervision.websocket.handler;
 import cn.hutool.json.JSONUtil;
 import com.supervision.service.AskService;
 import com.supervision.util.SpringBeanUtil;
+import com.supervision.util.UserUtil;
 import com.supervision.websocket.cache.WebSocketUserCache;
 import com.supervision.websocket.dto.SocketMessageDTO;
 import lombok.extern.slf4j.Slf4j;
@@ -33,10 +34,21 @@ public class AskWebSocketHandler extends TextWebSocketHandler {
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws IOException {
         // 处理接收到的消息
         log.info("收到消息:{}", message.toString());
-        // 这里反序列化消息,将消息形成固定的格式
-        SocketMessageDTO socketMessageDTO = JSONUtil.toBean(message.getPayload(), SocketMessageDTO.class);
-        AskService askService = SpringBeanUtil.getBean(AskService.class);
-        askService.handlerMessageBySocket(socketMessageDTO);
+        try {
+            // 这里反序列化消息,将消息形成固定的格式
+            SocketMessageDTO socketMessageDTO = JSONUtil.toBean(message.getPayload(), SocketMessageDTO.class);
+            AskService askService = SpringBeanUtil.getBean(AskService.class);
+            askService.handlerMessageBySocket(socketMessageDTO);
+        } catch (Exception e) {
+            log.error("对话出现异常", e);
+            SocketMessageDTO res = new SocketMessageDTO();
+            res.setSocketId(session.getId());
+            res.setUserId(UserUtil.getUser().getId());
+            res.setTextMessage("出错了");
+            res.setType(1);
+            session.sendMessage(new TextMessage(JSONUtil.toJsonStr(res)));
+        }
+
     }
 
     @Override