diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/controller/consultationInfo/ConsultationInfoController.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/controller/consultationInfo/ConsultationInfoController.java
new file mode 100644
index 0000000..c491a27
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/controller/consultationInfo/ConsultationInfoController.java
@@ -0,0 +1,110 @@
+package com.xinelu.manage.controller.consultationInfo;
+
+import com.xinelu.common.annotation.Log;
+import com.xinelu.common.core.controller.BaseController;
+import com.xinelu.common.core.domain.AjaxResult;
+import com.xinelu.common.core.page.TableDataInfo;
+import com.xinelu.common.enums.BusinessType;
+import com.xinelu.common.socket.WebSocketUtils;
+import com.xinelu.manage.domain.chatRecord.ChatRecord;
+import com.xinelu.manage.domain.consultationInfo.ConsultationInfo;
+import com.xinelu.manage.service.chatRecord.IChatRecordService;
+import com.xinelu.manage.service.consultationInfo.IConsultationInfoService;
+import com.xinelu.manage.vo.consultationInfo.ConsultationInfoVO;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 在线问诊-问诊信息Controller
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@RestController
+@RequestMapping("/system/consultationInfo")
+public class ConsultationInfoController extends BaseController {
+    @Autowired
+    private IConsultationInfoService consultationInfoService;
+
+    @Autowired
+    private IChatRecordService chatRecordService;
+
+    /**
+     * 查询在线问诊-问诊信息列表
+     */
+    //@PreAuthorize("@ss.hasPermi('system:info:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(ConsultationInfo consultationInfo) {
+        startPage();
+        List<ConsultationInfoVO> list = consultationInfoService.selectConsultationInfoList(consultationInfo);
+        return getDataTable(list);
+    }
+
+
+    /**
+     * 获取在线问诊-问诊信息详细信息
+     */
+    //@PreAuthorize("@ss.hasPermi('system:info:query')")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id) {
+        return AjaxResult.success(consultationInfoService.selectConsultationInfoById(id));
+    }
+
+    /**
+     * 新增在线问诊-问诊信息
+     */
+    // @PreAuthorize("@ss.hasPermi('system:info:add')")
+    @Log(title = "在线问诊-问诊信息", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody ConsultationInfo consultationInfo) {
+        return toAjax(consultationInfoService.insertConsultationInfo(consultationInfo));
+    }
+
+    /**
+     * 修改在线问诊-问诊信息(修改问诊状态)
+     */
+    // @PreAuthorize("@ss.hasPermi('system:info:edit')")
+    @Log(title = "在线问诊-问诊信息", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody ConsultationInfo consultationInfo) {
+        return toAjax(consultationInfoService.updateConsultationInfo(consultationInfo));
+    }
+
+    /**
+     * 查询聊天记录
+     */
+    @GetMapping("/getChatRecord")
+    public AjaxResult getChatRecord(ChatRecord chatRecord) {
+        return AjaxResult.success(chatRecordService.selectChatRecordList(chatRecord));
+    }
+
+    /**
+     * 修改已读状态
+     */
+    @Log(title = "图文咨询-聊天记录", businessType = BusinessType.UPDATE)
+    @PutMapping(value = "updateReadStatus")
+    public AjaxResult updateReadStatus(@RequestBody ChatRecord chatRecord) {
+        return toAjax(chatRecordService.updateChatRecord(chatRecord));
+    }
+
+    @ApiOperation(value = "发送即时消息", notes = "向接收方发送即时消息")
+    @PostMapping("/sendMessage")
+    @Transactional
+    public AjaxResult sendMessage(@RequestBody ChatRecord chatRecord) {
+        if (chatRecordService.insertChatRecord(chatRecord) > 0) {
+            // 判断接收人是否在线
+            if (WebSocketUtils.clients.get(chatRecord.getRecipientId().toString()) == null) {
+                return AjaxResult.success();
+            } else {
+                return chatRecordService.sendMessage(chatRecord) ? AjaxResult.success() : AjaxResult.error();
+            }
+        } else {
+            return AjaxResult.success();
+        }
+    }
+
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/chatRecord/ChatRecord.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/chatRecord/ChatRecord.java
new file mode 100644
index 0000000..3a98ce3
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/chatRecord/ChatRecord.java
@@ -0,0 +1,149 @@
+package com.xinelu.manage.domain.chatRecord;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xinelu.common.annotation.Excel;
+import com.xinelu.common.core.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * 图文咨询-聊天记录对象 chat_record
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "图文咨询-聊天记录对象", description = "chat_record")
+public class ChatRecord extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 自增主键
+     */
+    private Long id;
+
+    /**
+     * 聊天记录业务主键(问诊表id)
+     */
+    private Long consultationId;
+
+    /**
+     * 发送人
+     */
+    @ApiModelProperty(value = "发送人")
+    @Excel(name = "发送人")
+    private Long senderId;
+
+    /**
+     * 发送人姓名
+     */
+    @ApiModelProperty(value = "发送人姓名")
+    @Excel(name = "发送人姓名")
+    private String senderName;
+
+    /**
+     * 发送时间，时间格式：yyyy-MM-dd HH:mm:ss
+     */
+    @ApiModelProperty(value = "发送时间，时间格式：yyyy-MM-dd HH:mm:ss")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "发送时间，时间格式：yyyy-MM-dd HH:mm:ss", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date sendTime;
+
+    /**
+     * 接收人
+     */
+    @ApiModelProperty(value = "接收人")
+    @Excel(name = "接收人")
+    private Long recipientId;
+
+    /**
+     * 接收人姓名
+     */
+    @ApiModelProperty(value = "接收人姓名")
+    @Excel(name = "接收人姓名")
+    private String recipientName;
+
+    /**
+     * 消息类型(0：其他 1：文字，2：图片 3：表情 4：视频 5：文件  6：链接)
+     */
+    @ApiModelProperty(value = "消息类型(0：其他 1：文字，2：图片 3：表情 4：视频 5：文件  6：链接)")
+    @Excel(name = "消息类型(0：其他 1：文字，2：图片 3：表情 4：视频 5：文件  6：链接)")
+    private String messageType;
+
+    /**
+     * 标题
+     */
+    @ApiModelProperty(value = "标题")
+    @Excel(name = "标题")
+    private String title;
+
+    /**
+     * 消息内容，图片内容时内容为：图片路径
+     */
+    @ApiModelProperty(value = "消息内容，图片内容时内容为：图片路径")
+    @Excel(name = "消息内容，图片内容时内容为：图片路径")
+    private String content;
+
+    /**
+     * 消息内容业务主键，用于点击跳转
+     */
+    @ApiModelProperty(value = "消息内容业务主键，用于点击跳转")
+    @Excel(name = "消息内容业务主键，用于点击跳转")
+    private String contentId;
+
+    /**
+     * 已读状态，0：未读，1：已读
+     */
+    @ApiModelProperty(value = "已读状态，0：未读，1：已读")
+    @Excel(name = "已读状态，0：未读，1：已读")
+    private String readStatus;
+
+    /**
+     * 阅读时间，时间格式：yyyy-MM-dd HH:mm:ss
+     */
+    @ApiModelProperty(value = "阅读时间，时间格式：yyyy-MM-dd HH:mm:ss")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "阅读时间，时间格式：yyyy-MM-dd HH:mm:ss", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date readTime;
+
+    /**
+     * 删除状态，0：未删除，1：已删除
+     */
+    private Integer delFlag;
+
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("consultationId", getConsultationId())
+                .append("senderId", getSenderId())
+                .append("senderName", getSenderName())
+                .append("sendTime", getSendTime())
+                .append("recipientId", getRecipientId())
+                .append("recipientName", getRecipientName())
+                .append("messageType", getMessageType())
+                .append("title", getTitle())
+                .append("content", getContent())
+                .append("contentId", getContentId())
+                .append("readStatus", getReadStatus())
+                .append("readTime", getReadTime())
+                .append("delFlag", getDelFlag())
+                .append("createBy", getCreateBy())
+                .append("createTime", getCreateTime())
+                .append("updateBy", getUpdateBy())
+                .append("updateTime", getUpdateTime())
+                .toString();
+    }
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/consultationInfo/ConsultationInfo.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/consultationInfo/ConsultationInfo.java
new file mode 100644
index 0000000..54b72b4
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/domain/consultationInfo/ConsultationInfo.java
@@ -0,0 +1,192 @@
+package com.xinelu.manage.domain.consultationInfo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xinelu.common.annotation.Excel;
+import com.xinelu.common.core.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * 在线问诊-问诊信息（图文和视频问诊基本信息）对象 consultation_info
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "在线问诊-问诊信息（图文和视频问诊基本信息）对象", description = "consultation_info")
+public class ConsultationInfo extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 患者id
+     */
+    @ApiModelProperty(value = "患者id")
+    @Excel(name = "患者id")
+    private Long patientId;
+
+    /**
+     * 患者名称
+     */
+    @ApiModelProperty(value = "患者名称")
+    @Excel(name = "患者名称")
+    private String patientName;
+
+    /**
+     * 患者身份证号
+     */
+    @ApiModelProperty(value = "患者身份证号")
+    @Excel(name = "患者身份证号")
+    private String cardNo;
+
+    /**
+     * 患者联系方式
+     */
+    @ApiModelProperty(value = "患者联系方式")
+    @Excel(name = "患者联系方式")
+    private String phone;
+
+    /**
+     * 现住址所在地区
+     */
+    @ApiModelProperty(value = "现住址所在地区")
+    @Excel(name = "现住址所在地区")
+    private String address;
+
+    /**
+     * 医生id(签约医生/专家)
+     */
+    @ApiModelProperty(value = "医生id(签约医生/专家)")
+    @Excel(name = "医生id(签约医生/专家)")
+    private String doctorId;
+
+    /**
+     * 医生名称
+     */
+    @ApiModelProperty(value = "医生名称")
+    @Excel(name = "医生名称")
+    private String doctorName;
+
+    /**
+     * 问诊类型，图文问诊：IMAGE_TEXT_CONSULTATION，视频问诊：VIDEO_CONSULTATION
+     */
+    @ApiModelProperty(value = "问诊类型，图文问诊：IMAGE_TEXT_CONSULTATION，视频问诊：VIDEO_CONSULTATION")
+    @Excel(name = "问诊类型，图文问诊：IMAGE_TEXT_CONSULTATION，视频问诊：VIDEO_CONSULTATION")
+    private String consultationType;
+
+    /**
+     * 状态(1 未完成 ,2 已完成)
+     */
+    @ApiModelProperty(value = "状态(1 未完成 ,2 已完成)")
+    @Excel(name = "状态(1 未完成 ,2 已完成)")
+    private Integer status;
+
+    /**
+     * 预约日期(视频问诊预约)，时间格式：yyyy-MM-dd
+     */
+    @ApiModelProperty(value = "预约日期(视频问诊预约)，时间格式：yyyy-MM-dd")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "预约日期(视频问诊预约)，时间格式：yyyy-MM-dd", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date appointmentDate;
+
+    /**
+     * 预约开始时间点(视频问诊预约)，时间格式：HH:mm
+     */
+    @ApiModelProperty(value = "预约开始时间点(视频问诊预约)，时间格式：HH:mm")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "预约开始时间点(视频问诊预约)，时间格式：HH:mm", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date appointmentStartTime;
+
+    /**
+     * 预约结束时间点(视频问诊预约)，时间格式：HH:mm
+     */
+    @ApiModelProperty(value = "预约结束时间点(视频问诊预约)，时间格式：HH:mm")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "预约结束时间点(视频问诊预约)，时间格式：HH:mm", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date appointmentEndTime;
+
+    /**
+     * 视频问诊地址
+     */
+    @ApiModelProperty(value = "视频问诊地址")
+    @Excel(name = "视频问诊地址")
+    private String videoUrl;
+
+    /**
+     * 问题简述
+     */
+    @ApiModelProperty(value = "问题简述")
+    @Excel(name = "问题简述")
+    private String problemDescription;
+
+    /**
+     * 患者个体情况说明
+     */
+    @ApiModelProperty(value = "患者个体情况说明")
+    @Excel(name = "患者个体情况说明")
+    private String situationDescription;
+
+    /**
+     * 问题描述
+     */
+    @ApiModelProperty(value = "问题描述")
+    @Excel(name = "问题描述")
+    private String problemStatement;
+
+    /**
+     * 病历
+     */
+    @ApiModelProperty(value = "病历")
+    @Excel(name = "病历")
+    private String medicalRecord;
+
+    /**
+     * 是否删除标识，0：否，1：是
+     */
+    private Integer delFlag;
+
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("patientId", getPatientId())
+                .append("patientName", getPatientName())
+                .append("cardNo", getCardNo())
+                .append("phone", getPhone())
+                .append("address", getAddress())
+                .append("doctorId", getDoctorId())
+                .append("doctorName", getDoctorName())
+                .append("consultationType", getConsultationType())
+                .append("status", getStatus())
+                .append("appointmentDate", getAppointmentDate())
+                .append("appointmentStartTime", getAppointmentStartTime())
+                .append("appointmentEndTime", getAppointmentEndTime())
+                .append("videoUrl", getVideoUrl())
+                .append("problemDescription", getProblemDescription())
+                .append("situationDescription", getSituationDescription())
+                .append("problemStatement", getProblemStatement())
+                .append("medicalRecord", getMedicalRecord())
+                .append("delFlag", getDelFlag())
+                .append("createBy", getCreateBy())
+                .append("createTime", getCreateTime())
+                .append("updateBy", getUpdateBy())
+                .append("updateTime", getUpdateTime())
+                .toString();
+    }
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/chatRecord/ChatRecordMapper.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/chatRecord/ChatRecordMapper.java
new file mode 100644
index 0000000..7623c6a
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/chatRecord/ChatRecordMapper.java
@@ -0,0 +1,62 @@
+package com.xinelu.manage.mapper.chatRecord;
+
+import com.xinelu.manage.domain.chatRecord.ChatRecord;
+
+import java.util.List;
+
+
+/**
+ * 图文咨询-聊天记录Mapper接口
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+public interface ChatRecordMapper {
+    /**
+     * 查询图文咨询-聊天记录
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 图文咨询-聊天记录
+     */
+    public ChatRecord selectChatRecordById(Long id);
+
+    /**
+     * 查询图文咨询-聊天记录列表
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 图文咨询-聊天记录集合
+     */
+    public List<ChatRecord> selectChatRecordList(ChatRecord chatRecord);
+
+    /**
+     * 新增图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    public int insertChatRecord(ChatRecord chatRecord);
+
+    /**
+     * 修改图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    public int updateChatRecord(ChatRecord chatRecord);
+
+    /**
+     * 删除图文咨询-聊天记录
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 结果
+     */
+    public int deleteChatRecordById(Long id);
+
+    /**
+     * 批量删除图文咨询-聊天记录
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteChatRecordByIds(Long[] ids);
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/consultationInfo/ConsultationInfoMapper.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/consultationInfo/ConsultationInfoMapper.java
new file mode 100644
index 0000000..5176451
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/mapper/consultationInfo/ConsultationInfoMapper.java
@@ -0,0 +1,63 @@
+package com.xinelu.manage.mapper.consultationInfo;
+
+import com.xinelu.manage.domain.consultationInfo.ConsultationInfo;
+import com.xinelu.manage.vo.consultationInfo.ConsultationInfoVO;
+
+import java.util.List;
+
+
+/**
+ * 在线问诊-问诊信息（图文和视频问诊基本信息）Mapper接口
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+public interface ConsultationInfoMapper {
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）
+     */
+    public ConsultationInfo selectConsultationInfoById(Long id);
+
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）列表
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）集合
+     */
+    public List<ConsultationInfoVO> selectConsultationInfoList(ConsultationInfo consultationInfo);
+
+    /**
+     * 新增在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    public int insertConsultationInfo(ConsultationInfo consultationInfo);
+
+    /**
+     * 修改在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    public int updateConsultationInfo(ConsultationInfo consultationInfo);
+
+    /**
+     * 删除在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 结果
+     */
+    public int deleteConsultationInfoById(Long id);
+
+    /**
+     * 批量删除在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteConsultationInfoByIds(Long[] ids);
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/IChatRecordService.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/IChatRecordService.java
new file mode 100644
index 0000000..f810486
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/IChatRecordService.java
@@ -0,0 +1,64 @@
+package com.xinelu.manage.service.chatRecord;
+
+import com.xinelu.manage.domain.chatRecord.ChatRecord;
+
+import java.util.List;
+
+
+/**
+ * 图文咨询-聊天记录Service接口
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+public interface IChatRecordService {
+    /**
+     * 查询图文咨询-聊天记录
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 图文咨询-聊天记录
+     */
+    public ChatRecord selectChatRecordById(Long id);
+
+    /**
+     * 查询图文咨询-聊天记录列表
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 图文咨询-聊天记录集合
+     */
+    public List<ChatRecord> selectChatRecordList(ChatRecord chatRecord);
+
+    /**
+     * 新增图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    public int insertChatRecord(ChatRecord chatRecord);
+
+    Boolean sendMessage(ChatRecord chatRecord);
+
+    /**
+     * 修改图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    public int updateChatRecord(ChatRecord chatRecord);
+
+    /**
+     * 批量删除图文咨询-聊天记录
+     *
+     * @param ids 需要删除的图文咨询-聊天记录主键集合
+     * @return 结果
+     */
+    public int deleteChatRecordByIds(Long[] ids);
+
+    /**
+     * 删除图文咨询-聊天记录信息
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 结果
+     */
+    public int deleteChatRecordById(Long id);
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/impl/ChatRecordServiceImpl.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/impl/ChatRecordServiceImpl.java
new file mode 100644
index 0000000..f1c2f1a
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/chatRecord/impl/ChatRecordServiceImpl.java
@@ -0,0 +1,108 @@
+package com.xinelu.manage.service.chatRecord.impl;
+
+import com.xinelu.common.core.dto.MessageTemplate;
+import com.xinelu.common.enums.MessageContentType;
+import com.xinelu.common.socket.WebSocketUtils;
+import com.xinelu.common.utils.DateUtils;
+import com.xinelu.manage.domain.chatRecord.ChatRecord;
+import com.xinelu.manage.mapper.chatRecord.ChatRecordMapper;
+import com.xinelu.manage.service.chatRecord.IChatRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * 图文咨询-聊天记录Service业务层处理
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@Service
+public class ChatRecordServiceImpl implements IChatRecordService {
+    @Resource
+    private ChatRecordMapper chatRecordMapper;
+
+    /**
+     * 查询图文咨询-聊天记录
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 图文咨询-聊天记录
+     */
+    @Override
+    public ChatRecord selectChatRecordById(Long id) {
+        return chatRecordMapper.selectChatRecordById(id);
+    }
+
+    /**
+     * 查询图文咨询-聊天记录列表
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 图文咨询-聊天记录
+     */
+    @Override
+    public List<ChatRecord> selectChatRecordList(ChatRecord chatRecord) {
+        return chatRecordMapper.selectChatRecordList(chatRecord);
+    }
+
+    /**
+     * 新增图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    @Override
+    public int insertChatRecord(ChatRecord chatRecord) {
+        chatRecord.setCreateTime(DateUtils.getNowDate());
+        return chatRecordMapper.insertChatRecord(chatRecord);
+    }
+
+    @Override
+    public Boolean sendMessage(ChatRecord chatRecord) {
+        // 构建消息结构
+        MessageTemplate msg = new MessageTemplate();
+        msg.setMessage(chatRecord.getContent());
+        msg.setFromKey(chatRecord.getSenderId().toString());
+        msg.setToKey(chatRecord.getRecipientId().toString());
+        msg.setMsgType(MessageContentType.CHAT.name());
+        msg.setSendTime(chatRecord.getSendTime());
+        return WebSocketUtils.sendMessage(chatRecord.getRecipientId().toString(), msg);
+    }
+
+    /**
+     * 修改图文咨询-聊天记录
+     *
+     * @param chatRecord 图文咨询-聊天记录
+     * @return 结果
+     */
+    @Override
+    public int updateChatRecord(ChatRecord chatRecord) {
+        //更新已读时间
+        chatRecord.setReadTime(DateUtils.getNowDate());
+        chatRecord.setReadStatus("1");
+        return chatRecordMapper.updateChatRecord(chatRecord);
+    }
+
+    /**
+     * 批量删除图文咨询-聊天记录
+     *
+     * @param ids 需要删除的图文咨询-聊天记录主键
+     * @return 结果
+     */
+    @Override
+    public int deleteChatRecordByIds(Long[] ids) {
+        return chatRecordMapper.deleteChatRecordByIds(ids);
+    }
+
+    /**
+     * 删除图文咨询-聊天记录信息
+     *
+     * @param id 图文咨询-聊天记录主键
+     * @return 结果
+     */
+    @Override
+    public int deleteChatRecordById(Long id) {
+        return chatRecordMapper.deleteChatRecordById(id);
+    }
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/IConsultationInfoService.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/IConsultationInfoService.java
new file mode 100644
index 0000000..d40c823
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/IConsultationInfoService.java
@@ -0,0 +1,63 @@
+package com.xinelu.manage.service.consultationInfo;
+
+import com.xinelu.manage.domain.consultationInfo.ConsultationInfo;
+import com.xinelu.manage.vo.consultationInfo.ConsultationInfoVO;
+
+import java.util.List;
+
+
+/**
+ * 在线问诊-问诊信息（图文和视频问诊基本信息）Service接口
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+public interface IConsultationInfoService {
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）
+     */
+    public ConsultationInfo selectConsultationInfoById(Long id);
+
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）列表
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）集合
+     */
+    public List<ConsultationInfoVO> selectConsultationInfoList(ConsultationInfo consultationInfo);
+
+    /**
+     * 新增在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    public int insertConsultationInfo(ConsultationInfo consultationInfo);
+
+    /**
+     * 修改在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    public int updateConsultationInfo(ConsultationInfo consultationInfo);
+
+    /**
+     * 批量删除在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param ids 需要删除的在线问诊-问诊信息（图文和视频问诊基本信息）主键集合
+     * @return 结果
+     */
+    public int deleteConsultationInfoByIds(Long[] ids);
+
+    /**
+     * 删除在线问诊-问诊信息（图文和视频问诊基本信息）信息
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 结果
+     */
+    public int deleteConsultationInfoById(Long id);
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/impl/ConsultationInfoServiceImpl.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/impl/ConsultationInfoServiceImpl.java
new file mode 100644
index 0000000..49d07fb
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/service/consultationInfo/impl/ConsultationInfoServiceImpl.java
@@ -0,0 +1,92 @@
+package com.xinelu.manage.service.consultationInfo.impl;
+
+import com.xinelu.common.utils.DateUtils;
+import com.xinelu.manage.domain.consultationInfo.ConsultationInfo;
+import com.xinelu.manage.mapper.consultationInfo.ConsultationInfoMapper;
+import com.xinelu.manage.service.consultationInfo.IConsultationInfoService;
+import com.xinelu.manage.vo.consultationInfo.ConsultationInfoVO;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+
+/**
+ * 在线问诊-问诊信息（图文和视频问诊基本信息）Service业务层处理
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@Service
+public class ConsultationInfoServiceImpl implements IConsultationInfoService {
+    @Resource
+    private ConsultationInfoMapper consultationInfoMapper;
+
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）
+     */
+    @Override
+    public ConsultationInfo selectConsultationInfoById(Long id) {
+        return consultationInfoMapper.selectConsultationInfoById(id);
+    }
+
+    /**
+     * 查询在线问诊-问诊信息（图文和视频问诊基本信息）列表
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 在线问诊-问诊信息（图文和视频问诊基本信息）
+     */
+    @Override
+    public List<ConsultationInfoVO> selectConsultationInfoList(ConsultationInfo consultationInfo) {
+        return consultationInfoMapper.selectConsultationInfoList(consultationInfo);
+    }
+
+    /**
+     * 新增在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    @Override
+    public int insertConsultationInfo(ConsultationInfo consultationInfo) {
+        consultationInfo.setCreateTime(DateUtils.getNowDate());
+        return consultationInfoMapper.insertConsultationInfo(consultationInfo);
+    }
+
+    /**
+     * 修改在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param consultationInfo 在线问诊-问诊信息（图文和视频问诊基本信息）
+     * @return 结果
+     */
+    @Override
+    public int updateConsultationInfo(ConsultationInfo consultationInfo) {
+        consultationInfo.setUpdateTime(DateUtils.getNowDate());
+        return consultationInfoMapper.updateConsultationInfo(consultationInfo);
+    }
+
+    /**
+     * 批量删除在线问诊-问诊信息（图文和视频问诊基本信息）
+     *
+     * @param ids 需要删除的在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 结果
+     */
+    @Override
+    public int deleteConsultationInfoByIds(Long[] ids) {
+        return consultationInfoMapper.deleteConsultationInfoByIds(ids);
+    }
+
+    /**
+     * 删除在线问诊-问诊信息（图文和视频问诊基本信息）信息
+     *
+     * @param id 在线问诊-问诊信息（图文和视频问诊基本信息）主键
+     * @return 结果
+     */
+    @Override
+    public int deleteConsultationInfoById(Long id) {
+        return consultationInfoMapper.deleteConsultationInfoById(id);
+    }
+}
diff --git a/xinelu-nurse-manage/src/main/java/com/xinelu/manage/vo/consultationInfo/ConsultationInfoVO.java b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/vo/consultationInfo/ConsultationInfoVO.java
new file mode 100644
index 0000000..2ec4853
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/java/com/xinelu/manage/vo/consultationInfo/ConsultationInfoVO.java
@@ -0,0 +1,157 @@
+package com.xinelu.manage.vo.consultationInfo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xinelu.common.annotation.Excel;
+import com.xinelu.common.core.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 在线问诊-问诊信息对象 consultation_info
+ *
+ * @author xinelu
+ * @date 2023-09-25
+ */
+@Data
+public class ConsultationInfoVO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 患者id
+     */
+    private Long patientId;
+
+    /**
+     * 患者名称
+     */
+    private String patientName;
+
+    /**
+     * 患者身份证号
+     */
+    private String cardNo;
+
+    /**
+     * 患者联系方式
+     */
+    private String phone;
+
+    /**
+     * 现住址所在地区
+     */
+    private String address;
+
+    /**
+     * 医生id(签约医生/专家)
+     */
+    private String doctorId;
+
+    /**
+     * 医生名称
+     */
+    private String doctorName;
+
+    /**
+     * 问诊类型，图文问诊：IMAGE_TEXT_CONSULTATION，视频问诊：VIDEO_CONSULTATION
+     */
+    private String consultationType;
+
+    /**
+     * 状态(1 未完成 ,2 已完成)
+     */
+    private Integer status;
+
+    /**
+     * 预约日期(视频问诊预约)，时间格式：yyyy-MM-dd
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date appointmentDate;
+
+    /**
+     * 预约开始时间点(视频问诊预约)，时间格式：HH:mm
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date appointmentStartTime;
+
+    /**
+     * 预约结束时间点(视频问诊预约)，时间格式：HH:mm
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date appointmentEndTime;
+
+    /**
+     * 视频问诊地址
+     */
+    private String videoUrl;
+
+    /**
+     * 问题简述
+     */
+    private String problemDescription;
+
+    /**
+     * 患者个体情况说明
+     */
+    private String situationDescription;
+
+    /**
+     * 问题描述
+     */
+    private String problemStatement;
+
+    /**
+     * 病历
+     */
+    private String medicalRecord;
+
+    /**
+     * 是否删除标识，0：否，1：是
+     */
+    private Integer delFlag;
+
+    /**
+     * 消息数量
+     */
+    private Integer messageCount;
+
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("patientId", getPatientId())
+                .append("patientName", getPatientName())
+                .append("cardNo", getCardNo())
+                .append("phone", getPhone())
+                .append("address", getAddress())
+                .append("doctorId", getDoctorId())
+                .append("doctorName", getDoctorName())
+                .append("consultationType", getConsultationType())
+                .append("status", getStatus())
+                .append("appointmentDate", getAppointmentDate())
+                .append("appointmentStartTime", getAppointmentStartTime())
+                .append("appointmentEndTime", getAppointmentEndTime())
+                .append("videoUrl", getVideoUrl())
+                .append("problemDescription", getProblemDescription())
+                .append("situationDescription", getSituationDescription())
+                .append("problemStatement", getProblemStatement())
+                .append("medicalRecord", getMedicalRecord())
+                .append("delFlag", getDelFlag())
+                .append("messageCount", getMessageCount())
+                .toString();
+    }
+}
diff --git a/xinelu-nurse-manage/src/main/resources/mapper/manage/chatRecord/ChatRecordMapper.xml b/xinelu-nurse-manage/src/main/resources/mapper/manage/chatRecord/ChatRecordMapper.xml
new file mode 100644
index 0000000..b2e1679
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/resources/mapper/manage/chatRecord/ChatRecordMapper.xml
@@ -0,0 +1,233 @@
+<?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.xinelu.manage.mapper.chatRecord.ChatRecordMapper">
+
+    <resultMap type="ChatRecord" id="ChatRecordResult">
+        <result property="id" column="id"/>
+        <result property="consultationId" column="consultation_id"/>
+        <result property="senderId" column="sender_id"/>
+        <result property="senderName" column="sender_name"/>
+        <result property="sendTime" column="send_time"/>
+        <result property="recipientId" column="recipient_id"/>
+        <result property="recipientName" column="recipient_name"/>
+        <result property="messageType" column="message_type"/>
+        <result property="title" column="title"/>
+        <result property="content" column="content"/>
+        <result property="contentId" column="content_id"/>
+        <result property="readStatus" column="read_status"/>
+        <result property="readTime" column="read_time"/>
+        <result property="delFlag" column="del_flag"/>
+        <result property="createBy" column="create_by"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateBy" column="update_by"/>
+        <result property="updateTime" column="update_time"/>
+    </resultMap>
+
+    <sql id="selectChatRecordVo">
+        select id,
+               consultation_id,
+               sender_id,
+               sender_name,
+               send_time,
+               recipient_id,
+               recipient_name,
+               message_type,
+               title,
+               content,
+               content_id,
+               read_status,
+               read_time,
+               del_flag,
+               create_by,
+               create_time,
+               update_by,
+               update_time
+        from chat_record
+    </sql>
+
+    <select id="selectChatRecordList" parameterType="ChatRecord" resultMap="ChatRecordResult">
+        <include refid="selectChatRecordVo"/>
+        where del_flag = '0'
+        and consultation_id = #{consultationId}
+        and (
+        (sender_id = #{senderId} and recipient_id = #{recipientId})
+        or
+        (sender_id = #{recipientId} and recipient_id = #{senderId})
+        )
+        <if test="readStatus != null">
+            and read_status = #{readStatus}
+        </if>
+        order by send_time
+    </select>
+
+    <select id="selectChatRecordById" parameterType="Long"
+            resultMap="ChatRecordResult">
+        <include refid="selectChatRecordVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertChatRecord" parameterType="ChatRecord" useGeneratedKeys="true"
+            keyProperty="id">
+        insert into chat_record
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="consultationId != null">consultation_id,
+            </if>
+            <if test="senderId != null">sender_id,
+            </if>
+            <if test="senderName != null and senderName != ''">sender_name,
+            </if>
+            <if test="sendTime != null">send_time,
+            </if>
+            <if test="recipientId != null">recipient_id,
+            </if>
+            <if test="recipientName != null and recipientName != ''">recipient_name,
+            </if>
+            <if test="messageType != null">message_type,
+            </if>
+            <if test="title != null">title,
+            </if>
+            <if test="content != null">content,
+            </if>
+            <if test="contentId != null">content_id,
+            </if>
+            <if test="readStatus != null">read_status,
+            </if>
+            <if test="readTime != null">read_time,
+            </if>
+            <if test="delFlag != null">del_flag,
+            </if>
+            <if test="createBy != null">create_by,
+            </if>
+            <if test="createTime != null">create_time,
+            </if>
+            <if test="updateBy != null">update_by,
+            </if>
+            <if test="updateTime != null">update_time,
+            </if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="consultationId != null">#{consultationId},
+            </if>
+            <if test="senderId != null">#{senderId},
+            </if>
+            <if test="senderName != null and senderName != ''">#{senderName},
+            </if>
+            <if test="sendTime != null">#{sendTime},
+            </if>
+            <if test="recipientId != null">#{recipientId},
+            </if>
+            <if test="recipientName != null and recipientName != ''">#{recipientName},
+            </if>
+            <if test="messageType != null">#{messageType},
+            </if>
+            <if test="title != null">#{title},
+            </if>
+            <if test="content != null">#{content},
+            </if>
+            <if test="contentId != null">#{contentId},
+            </if>
+            <if test="readStatus != null">#{readStatus},
+            </if>
+            <if test="readTime != null">#{readTime},
+            </if>
+            <if test="delFlag != null">#{delFlag},
+            </if>
+            <if test="createBy != null">#{createBy},
+            </if>
+            <if test="createTime != null">#{createTime},
+            </if>
+            <if test="updateBy != null">#{updateBy},
+            </if>
+            <if test="updateTime != null">#{updateTime},
+            </if>
+        </trim>
+    </insert>
+
+    <update id="updateChatRecord" parameterType="ChatRecord">
+        update chat_record
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="consultationId != null">consultation_id =
+                #{consultationId},
+            </if>
+            <if test="senderId != null">sender_id =
+                #{senderId},
+            </if>
+            <if test="senderName != null and senderName != ''">sender_name =
+                #{senderName},
+            </if>
+            <if test="sendTime != null">send_time =
+                #{sendTime},
+            </if>
+            <if test="recipientId != null">recipient_id =
+                #{recipientId},
+            </if>
+            <if test="recipientName != null and recipientName != ''">recipient_name =
+                #{recipientName},
+            </if>
+            <if test="messageType != null">message_type =
+                #{messageType},
+            </if>
+            <if test="title != null">title =
+                #{title},
+            </if>
+            <if test="content != null">content =
+                #{content},
+            </if>
+            <if test="contentId != null">content_id =
+                #{contentId},
+            </if>
+            <if test="readStatus != null">read_status =
+                #{readStatus},
+            </if>
+            <if test="readTime != null">read_time =
+                #{readTime},
+            </if>
+            <if test="delFlag != null">del_flag =
+                #{delFlag},
+            </if>
+            <if test="createBy != null">create_by =
+                #{createBy},
+            </if>
+            <if test="createTime != null">create_time =
+                #{createTime},
+            </if>
+            <if test="updateBy != null">update_by =
+                #{updateBy},
+            </if>
+            <if test="updateTime != null">update_time =
+                #{updateTime},
+            </if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <update id="updateReadStatus" parameterType="ChatRecord">
+        update chat_record
+
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="readStatus != null and readStatus != ''">
+                read_status = =#{readStatus},
+            </if>
+            <if test="readTime != null">
+                read_time = #{readTime},
+            </if>
+        </trim>
+
+        where del_flag = '0' and read_status = '0' and recipient_id = #{recipientId}
+    </update>
+
+    <delete id="deleteChatRecordById" parameterType="Long">
+        delete
+        from chat_record
+        where id = #{id}
+    </delete>
+
+    <delete id="deleteChatRecordByIds" parameterType="String">
+        delete from chat_record where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
diff --git a/xinelu-nurse-manage/src/main/resources/mapper/manage/consultationInfo/ConsultationInfoMapper.xml b/xinelu-nurse-manage/src/main/resources/mapper/manage/consultationInfo/ConsultationInfoMapper.xml
new file mode 100644
index 0000000..2bc96e2
--- /dev/null
+++ b/xinelu-nurse-manage/src/main/resources/mapper/manage/consultationInfo/ConsultationInfoMapper.xml
@@ -0,0 +1,305 @@
+<?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.xinelu.manage.mapper.consultationInfo.ConsultationInfoMapper">
+
+    <resultMap type="ConsultationInfo" id="ConsultationInfoResult">
+        <result property="id" column="id"/>
+        <result property="patientId" column="patient_id"/>
+        <result property="patientName" column="patient_name"/>
+        <result property="cardNo" column="card_no"/>
+        <result property="phone" column="phone"/>
+        <result property="address" column="address"/>
+        <result property="doctorId" column="doctor_id"/>
+        <result property="doctorName" column="doctor_name"/>
+        <result property="consultationType" column="consultation_type"/>
+        <result property="status" column="status"/>
+        <result property="appointmentDate" column="appointment_date"/>
+        <result property="appointmentStartTime" column="appointment_start_time"/>
+        <result property="appointmentEndTime" column="appointment_end_time"/>
+        <result property="videoUrl" column="video_url"/>
+        <result property="problemDescription" column="problem_description"/>
+        <result property="situationDescription" column="situation_description"/>
+        <result property="problemStatement" column="problem_statement"/>
+        <result property="medicalRecord" column="medical_record"/>
+        <result property="delFlag" column="del_flag"/>
+        <result property="createBy" column="create_by"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateBy" column="update_by"/>
+        <result property="updateTime" column="update_time"/>
+    </resultMap>
+
+    <sql id="selectConsultationInfoVo">
+        select id,
+               patient_id,
+               patient_name,
+               card_no,
+               phone,
+               address,
+               doctor_id,
+               doctor_name,
+               consultation_type,
+               status,
+               appointment_date,
+               appointment_start_time,
+               appointment_end_time,
+               video_url,
+               problem_description,
+               situation_description,
+               problem_statement,
+               medical_record,
+               del_flag,
+               create_by,
+               create_time,
+               update_by,
+               update_time
+        from consultation_info
+    </sql>
+
+    <select id="selectConsultationInfoList" parameterType="ConsultationInfo" resultType="com.xinelu.manage.vo.consultationInfo.ConsultationInfoVO">
+        SELECT
+        ci.id,
+        ci.patient_id,
+        ci.patient_name,
+        ci.card_no,
+        ci.phone,
+        ci.address,
+        ci.doctor_id,
+        ci.doctor_name,
+        ci.problem_description,
+        COUNT(cr.id) as messageCount
+        FROM
+        consultation_info ci
+        LEFT JOIN  chat_record cr ON cr.consultation_id=ci.id AND read_status='0'
+        <if test="patientId != null ">
+            and sender_id= ci.doctor_id
+        </if>
+        <if test="doctorId != null ">
+            and sender_id= ci.patient_id
+        </if>
+
+        <where>
+            <if test="patientId != null ">
+                and ci.patient_id = #{patientId}
+            </if>
+            <if test="patientName != null  and patientName != ''">
+                and ci.patient_name like concat('%', #{patientName}, '%')
+            </if>
+            <if test="doctorId != null  and doctorId != ''">
+                and ci.doctor_id = #{doctorId}
+            </if>
+            <if test="doctorName != null  and doctorName != ''">
+                and ci.doctor_name like concat('%', #{doctorName}, '%')
+            </if>
+            <if test="consultationType != null  and consultationType != ''">
+                and ci.consultation_type = #{consultationType}
+            </if>
+            <if test="status != null ">
+                and ci.status = #{status}
+            </if>
+            <if test="appointmentDate != null ">
+                and ci.appointment_date = #{appointmentDate}
+            </if>
+            <if test="appointmentStartTime != null ">
+                and ci.appointment_start_time = #{appointmentStartTime}
+            </if>
+            <if test="appointmentEndTime != null ">
+                and ci.appointment_end_time = #{appointmentEndTime}
+            </if>
+        </where>
+        ORDER BY ci.create_time DESC
+    </select>
+
+    <select id="selectConsultationInfoById" parameterType="Long"
+            resultMap="ConsultationInfoResult">
+        <include refid="selectConsultationInfoVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertConsultationInfo" parameterType="ConsultationInfo">
+        insert into consultation_info
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="id != null">id,
+            </if>
+            <if test="patientId != null">patient_id,
+            </if>
+            <if test="patientName != null">patient_name,
+            </if>
+            <if test="cardNo != null">card_no,
+            </if>
+            <if test="phone != null">phone,
+            </if>
+            <if test="address != null">address,
+            </if>
+            <if test="doctorId != null">doctor_id,
+            </if>
+            <if test="doctorName != null">doctor_name,
+            </if>
+            <if test="consultationType != null">consultation_type,
+            </if>
+            <if test="status != null">status,
+            </if>
+            <if test="appointmentDate != null">appointment_date,
+            </if>
+            <if test="appointmentStartTime != null">appointment_start_time,
+            </if>
+            <if test="appointmentEndTime != null">appointment_end_time,
+            </if>
+            <if test="videoUrl != null">video_url,
+            </if>
+            <if test="problemDescription != null">problem_description,
+            </if>
+            <if test="situationDescription != null">situation_description,
+            </if>
+            <if test="problemStatement != null">problem_statement,
+            </if>
+            <if test="medicalRecord != null">medical_record,
+            </if>
+            <if test="delFlag != null">del_flag,
+            </if>
+            <if test="createBy != null">create_by,
+            </if>
+            <if test="createTime != null">create_time,
+            </if>
+            <if test="updateBy != null">update_by,
+            </if>
+            <if test="updateTime != null">update_time,
+            </if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="id != null">#{id},
+            </if>
+            <if test="patientId != null">#{patientId},
+            </if>
+            <if test="patientName != null">#{patientName},
+            </if>
+            <if test="cardNo != null">#{cardNo},
+            </if>
+            <if test="phone != null">#{phone},
+            </if>
+            <if test="address != null">#{address},
+            </if>
+            <if test="doctorId != null">#{doctorId},
+            </if>
+            <if test="doctorName != null">#{doctorName},
+            </if>
+            <if test="consultationType != null">#{consultationType},
+            </if>
+            <if test="status != null">#{status},
+            </if>
+            <if test="appointmentDate != null">#{appointmentDate},
+            </if>
+            <if test="appointmentStartTime != null">#{appointmentStartTime},
+            </if>
+            <if test="appointmentEndTime != null">#{appointmentEndTime},
+            </if>
+            <if test="videoUrl != null">#{videoUrl},
+            </if>
+            <if test="problemDescription != null">#{problemDescription},
+            </if>
+            <if test="situationDescription != null">#{situationDescription},
+            </if>
+            <if test="problemStatement != null">#{problemStatement},
+            </if>
+            <if test="medicalRecord != null">#{medicalRecord},
+            </if>
+            <if test="delFlag != null">#{delFlag},
+            </if>
+            <if test="createBy != null">#{createBy},
+            </if>
+            <if test="createTime != null">#{createTime},
+            </if>
+            <if test="updateBy != null">#{updateBy},
+            </if>
+            <if test="updateTime != null">#{updateTime},
+            </if>
+        </trim>
+    </insert>
+
+    <update id="updateConsultationInfo" parameterType="ConsultationInfo">
+        update consultation_info
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="patientId != null">patient_id =
+                #{patientId},
+            </if>
+            <if test="patientName != null">patient_name =
+                #{patientName},
+            </if>
+            <if test="cardNo != null">card_no =
+                #{cardNo},
+            </if>
+            <if test="phone != null">phone =
+                #{phone},
+            </if>
+            <if test="address != null">address =
+                #{address},
+            </if>
+            <if test="doctorId != null">doctor_id =
+                #{doctorId},
+            </if>
+            <if test="doctorName != null">doctor_name =
+                #{doctorName},
+            </if>
+            <if test="consultationType != null">consultation_type =
+                #{consultationType},
+            </if>
+            <if test="status != null">status =
+                #{status},
+            </if>
+            <if test="appointmentDate != null">appointment_date =
+                #{appointmentDate},
+            </if>
+            <if test="appointmentStartTime != null">appointment_start_time =
+                #{appointmentStartTime},
+            </if>
+            <if test="appointmentEndTime != null">appointment_end_time =
+                #{appointmentEndTime},
+            </if>
+            <if test="videoUrl != null">video_url =
+                #{videoUrl},
+            </if>
+            <if test="problemDescription != null">problem_description =
+                #{problemDescription},
+            </if>
+            <if test="situationDescription != null">situation_description =
+                #{situationDescription},
+            </if>
+            <if test="problemStatement != null">problem_statement =
+                #{problemStatement},
+            </if>
+            <if test="medicalRecord != null">medical_record =
+                #{medicalRecord},
+            </if>
+            <if test="delFlag != null">del_flag =
+                #{delFlag},
+            </if>
+            <if test="createBy != null">create_by =
+                #{createBy},
+            </if>
+            <if test="createTime != null">create_time =
+                #{createTime},
+            </if>
+            <if test="updateBy != null">update_by =
+                #{updateBy},
+            </if>
+            <if test="updateTime != null">update_time =
+                #{updateTime},
+            </if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteConsultationInfoById" parameterType="Long">
+        delete
+        from consultation_info
+        where id = #{id}
+    </delete>
+
+    <delete id="deleteConsultationInfoByIds" parameterType="String">
+        delete from consultation_info where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>