保存到数据库中

virtual-patient-model/src/main/java/com/supervision/mapper/DiagnosisAiRecordMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.supervision.model.DiagnosisAiRecord;
+
+/**
+ * @author flevance
+ * @description 针对表【vp_diagnosis_ai_record】的数据库操作Mapper
+ * @createDate 2024-06-03 09:16:51
+ * @Entity com.supervision.model.DiagnosisAiRecord
+ */
+public interface DiagnosisAiRecordMapper extends BaseMapper<DiagnosisAiRecord> {
+
+}
+
+
+
+

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

@@ -0,0 +1,52 @@
+package com.supervision.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * @TableName vp_diagnosis_ai_record
+ */
+@TableName(value = "vp_diagnosis_ai_record")
+@Data
+public class DiagnosisAiRecord implements Serializable {
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+    /**
+     * 诊断进程ID
+     */
+    private String processId;
+    /**
+     * 问题内容
+     */
+    private String question;
+    /**
+     * 回答ID
+     */
+    private String answer;
+    /**
+     * 创建人ID
+     */
+    private String createUserId;
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+    /**
+     * 更新人ID
+     */
+    private String updateUserId;
+    /**
+     * 更新人时间
+     */
+    private LocalDateTime updateTime;
+}

virtual-patient-model/src/main/java/com/supervision/service/DiagnosisAiRecordService.java

@@ -0,0 +1,13 @@
+package com.supervision.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.supervision.model.DiagnosisAiRecord;
+
+/**
+ * @author flevance
+ * @description 针对表【vp_diagnosis_ai_record】的数据库操作Service
+ * @createDate 2024-06-03 09:16:51
+ */
+public interface DiagnosisAiRecordService extends IService<DiagnosisAiRecord> {
+
+}

virtual-patient-model/src/main/java/com/supervision/service/impl/DiagnosisAiRecordServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.mapper.DiagnosisAiRecordMapper;
+import com.supervision.model.DiagnosisAiRecord;
+import com.supervision.service.DiagnosisAiRecordService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author flevance
+ * @description 针对表【vp_diagnosis_ai_record】的数据库操作Service实现
+ * @createDate 2024-06-03 09:16:51
+ */
+@Service
+public class DiagnosisAiRecordServiceImpl extends ServiceImpl<DiagnosisAiRecordMapper, DiagnosisAiRecord>
+        implements DiagnosisAiRecordService {
+
+}
+
+
+
+

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

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.mapper.DiagnosisAiRecordMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.model.DiagnosisAiRecord">
+        <id property="id" column="id" jdbcType="VARCHAR"/>
+        <result property="processId" column="process_id" jdbcType="VARCHAR"/>
+        <result property="question" column="question" jdbcType="VARCHAR"/>
+        <result property="answer" column="answer" jdbcType="VARCHAR"/>
+        <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"/>
+        <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id
+        ,process_id,question,
+        answer,create_user_id,create_time,
+        update_user_id,update_time
+    </sql>
+</mapper>

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

@@ -62,6 +62,8 @@ public class AskServiceImpl implements AskService {
 
     private final MedicalRecService medicalRecService;
 
+    private final DiagnosisAiRecordService diagnosisAiRecordService;
+
     @Override
     public String receiveVoiceFile(MultipartFile file) {
         if (file.getSize() <= 0) {
@@ -331,11 +333,24 @@ public class AskServiceImpl implements AskService {
                         log.info("{}:病历配置,从AskPatientAnswer中未找到回答结果,走大模型", qaSimilarityQuestionAnswer.getMatchQuestionCode());
                         String talk = aiService.talk(talkReqVO.getText(), medicalRec.getMedicalRecordAi());
                         talkVideoTtsResultResVO.setAnswerMessage(talk);
+
                     }
                 }
             }
         }
         talkVideoTtsResultResVO.setVoiceBase64(TtsUtil.ttsTransform(talkVideoTtsResultResVO.getAnswerMessage()));
+        saveAiRecord(process.getId(), talkReqVO.getText(), talkVideoTtsResultResVO.getAnswerMessage());
         return talkVideoTtsResultResVO;
     }
+
+    private void saveAiRecord(String processId, String question, String answer) {
+        DiagnosisAiRecord diagnosisAiRecord = new DiagnosisAiRecord();
+        diagnosisAiRecord.setProcessId(processId);
+        diagnosisAiRecord.setQuestion(question);
+        diagnosisAiRecord.setAnswer(answer);
+        diagnosisAiRecord.setCreateUserId(UserUtil.getUser().getId());
+        diagnosisAiRecord.setUpdateUserId(UserUtil.getUser().getId());
+        diagnosisAiRecordService.save(diagnosisAiRecord);
+
+    }
 }