问诊socket流程提交

virtual-patient-model/src/main/java/com/supervision/model/ConfigPhysicalTool.java

@@ -12,6 +12,7 @@ import java.util.List;
 
 /**
  * 体格检查工具配置表
+ *
  * @TableName vp_config_physical_tool
  */
 @TableName(value = "vp_config_physical_tool", autoResultMap = true)

virtual-patient-model/src/main/java/com/supervision/model/Patient.java

@@ -1,22 +1,22 @@
 package com.supervision.model;
 
-import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.supervision.handler.StringListTypeHandler;
+import lombok.Data;
+
 import java.io.Serializable;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.List;
 
-import com.supervision.handler.StringListTypeHandler;
-import lombok.Data;
-
 /**
  * 病人表
+ *
  * @TableName vp_patient
  */
-@TableName(value ="vp_patient")
+@TableName(value = "vp_patient", autoResultMap = true)
 @Data
 public class Patient implements Serializable {
     /**

virtual-patient-model/src/main/resources/mapper/ConfigPhysicalToolMapper.xml

@@ -10,7 +10,8 @@
         <result property="code" column="code" jdbcType="VARCHAR"/>
         <result property="toolName" column="tool_name" jdbcType="VARCHAR"/>
         <result property="requireLocation" column="require_location" jdbcType="INTEGER"/>
-            <result column="call_out_question" jdbcType="ARRAY" property="callOutQuestion" typeHandler="com.supervision.handler.StringListTypeHandler" />
+        <result column="call_out_question" jdbcType="ARRAY" property="callOutQuestion"
+                typeHandler="com.supervision.handler.StringListTypeHandler"/>
         <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
         <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
         <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
@@ -18,7 +19,8 @@
     </resultMap>
 
     <sql id="Base_Column_List">
-        id,tool_class,code,
+        id
+        ,tool_class,code,
         tool_name,require_location,create_user_id,
         create_time,update_user_id,update_time
     </sql>

virtual-patient-model/src/main/resources/mapper/PatientMapper.xml

@@ -12,7 +12,8 @@
         <result property="symptoms" column="symptoms" jdbcType="VARCHAR"/>
         <result property="height" column="height" jdbcType="DECIMAL"/>
         <result property="weight" column="weight" jdbcType="DECIMAL"/>
-            <result property="diseaseList" column="disease_list" jdbcType="VARCHAR"/>
+        <result property="diseaseList"  jdbcType="ARRAY" column="disease_list"
+                typeHandler="com.supervision.handler.StringListTypeHandler"/>
         <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
         <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
         <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
@@ -20,7 +21,8 @@
     </resultMap>
 
     <sql id="Base_Column_List">
-        id,name,gender,
+        id
+        ,name,gender,
         age,symptoms,height,
         weight,disease_list,create_user_id,
         create_time,update_user_id,update_time

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

@@ -13,6 +13,7 @@ import com.supervision.websocket.cache.WebSocketUserCache;
 import com.supervision.websocket.dto.ActionDTO;
 import com.supervision.websocket.dto.SocketMessageDTO;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.socket.TextMessage;
@@ -21,6 +22,7 @@ import org.springframework.web.socket.WebSocketSession;
 import java.io.IOException;
 import java.util.List;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class AskServiceImpl implements AskService {
@@ -42,6 +44,7 @@ public class AskServiceImpl implements AskService {
         }
         // 进行rasa对话
         List<String> rasaResultList = RasaUtil.talkRasa(text, socketMessageDTO.getSocketId());
+        log.info("问题:{},rasa回复:{}", text, JSONUtil.toJsonStr(rasaResultList));
         WebSocketSession session = WebSocketUserCache.getSession(socketMessageDTO.getSocketId());
         for (String rasaResult : rasaResultList) {
             if (StrUtil.isNotBlank(rasaResult)) {
@@ -87,6 +90,7 @@ public class AskServiceImpl implements AskService {
         res.setTextMessage("医生,我们有听懂您说的什么");
         res.setType(1);
         session.sendMessage(new TextMessage(JSONUtil.toJsonStr(res)));
+        log.info("兜底话术,需要检查上面是不是出什么问题了");
     }
 
     @Override