diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/constant/SchoolBaseConstants.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/constant/SchoolBaseConstants.java
index 15630795..62834153 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/constant/SchoolBaseConstants.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/constant/SchoolBaseConstants.java
@@ -74,4 +74,39 @@ public interface SchoolBaseConstants {
      * 驾校消息模板：分配教练通知
      */
     public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_ASSIGN_COACH= "已为您分配教练，科目一教练：%s，科目二教练：%s，科目三教练：%s，科目四教练：%s";
+
+    /**
+     * 驾校消息模板：课程终止
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_COURSE_END= "您的课程%s已终止";
+
+    /**
+     * 驾校消息模板：学员预约训练
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_RESERVE_TRAIN= "学员%s预约了%s %s %s%s的训练";
+
+    /**
+     * 驾校消息模板：教练审核预约结果
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_COACH_RESERVE_RESULT= "您预约的%s %s %s%s的训练教练已%s";
+
+    /**
+     * 驾校消息模板：学员到场打卡发送消息
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_ATTENDANCE= "您在%s已到达%s打卡%s%s的训练";
+
+    /**
+     * 驾校消息模板：学员结束打卡发送消息
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_END_ATTENDANCE= "您在%s已结束%s%s的训练，本次训练时长%s分钟，累计训练时长%s分钟";
+
+    /**
+     * 驾校消息模板：学员提交考试批次
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_EXAM_BATCH= "教练给您提交了%s%s的考试，考试时间为：%s - %s，考试地址为：%s";
+
+    /**
+     * 驾校消息模板：学员拿出驾驶证祝福语
+     */
+    public static final String SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_DRIVER_LICENSE= "恭喜您在%s已领取驾驶证，祝您驾得愉快";
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/DlDriveSchoolStudentService.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/DlDriveSchoolStudentService.java
index 79c1002d..7414b1f2 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/DlDriveSchoolStudentService.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/DlDriveSchoolStudentService.java
@@ -148,7 +148,8 @@ public interface DlDriveSchoolStudentService extends IService<DlDriveSchoolStude
      *
      * @param passTime 拿证日期
      * @param userId   学员id
+     * @param courseId 课程id
      * @param tenantId 租户id
      */
-    Boolean updateStudentPassAndGradTime(Date passTime, Long userId, Long tenantId);
+    Boolean updateStudentPassAndGradTime(Date passTime, Long userId, String courseId, Long tenantId);
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/SchoolNotifyMessageSendService.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/SchoolNotifyMessageSendService.java
index c3f16aa1..29bbbe0d 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/SchoolNotifyMessageSendService.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/SchoolNotifyMessageSendService.java
@@ -14,6 +14,7 @@ public interface SchoolNotifyMessageSendService {
      * @param userId  用户id
      * @param message 消息内容
      * @param type admin为管理员 member为会员
+     * @param tenantId 租户id
      */
-    void sendMessage(Long userId, String message, String type);
+    void sendMessage(Long userId, String message, String type, Long tenantId);
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/DlDriveSchoolStudentServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/DlDriveSchoolStudentServiceImpl.java
index ab6ac198..9d8c6a46 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/DlDriveSchoolStudentServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/DlDriveSchoolStudentServiceImpl.java
@@ -9,10 +9,13 @@ import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
 import cn.iocoder.yudao.module.base.entity.DlDriveSchoolStudent;
 import cn.iocoder.yudao.module.base.mapper.DlDriveSchoolStudentMapper;
 import cn.iocoder.yudao.module.base.service.DlDriveSchoolStudentService;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
 import cn.iocoder.yudao.module.base.vo.DlDriveSchoolStaffVO;
 import cn.iocoder.yudao.module.base.vo.DlDriveSchoolStudentVO;
 import cn.iocoder.yudao.module.base.vo.StudentCountVO;
+import cn.iocoder.yudao.module.course.entity.SchoolCourseOrder;
 import cn.iocoder.yudao.module.course.service.ProcessService;
+import cn.iocoder.yudao.module.course.service.SchoolCourseOrderService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -22,6 +25,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 
 import javax.annotation.Resource;
@@ -42,6 +46,12 @@ public class DlDriveSchoolStudentServiceImpl extends ServiceImpl<DlDriveSchoolSt
     @Resource
     private ProcessService processService;
 
+    @Resource
+    private SchoolCourseOrderService schoolCourseOrderService;
+
+    @Resource
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
+
     @Override
     public String createDlDriveSchoolStudent(DlDriveSchoolStudentVO createReqVO) {
         // 插入
@@ -240,21 +250,28 @@ public class DlDriveSchoolStudentServiceImpl extends ServiceImpl<DlDriveSchoolSt
      *
      * @param passTime 拿证日期
      * @param userId   学员id
+     * @param courseId 课程id
      * @param tenantId 租户id
      */
     @TenantIgnore
     @Override
-    public Boolean updateStudentPassAndGradTime(Date passTime, Long userId, Long tenantId) {
+    @Transactional
+    public Boolean updateStudentPassAndGradTime(Date passTime, Long userId,String courseId, Long tenantId) {
         if (ObjectUtils.isEmpty(passTime) || ObjectUtils.isEmpty(userId) || ObjectUtils.isEmpty(tenantId)) {
             return false;
         }
         // 更新学员拿证时间
-        update(Wrappers.lambdaUpdate(DlDriveSchoolStudent.class)
-                .eq(DlDriveSchoolStudent::getUserId, userId)
-                .eq(DlDriveSchoolStudent::getTenantId, tenantId)
-                .set(DlDriveSchoolStudent::getPassTime, passTime)
-                .eq(DlDriveSchoolStudent::getDeleted, SchoolBaseConstants.COMMON_NO)
-                .set(DlDriveSchoolStudent::getGradTime, new Date()));
+        schoolCourseOrderService.update(Wrappers.lambdaUpdate(SchoolCourseOrder.class)
+                .eq(SchoolCourseOrder::getUserId, userId)
+                .eq(SchoolCourseOrder::getCourseId, courseId)
+                .set(SchoolCourseOrder::getPassTime, passTime)
+                .set(SchoolCourseOrder::getGradTime, new Date()));
+
+        // 消息准备
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_DRIVER_LICENSE, DateUtil.format(passTime, "yyyy-MM-dd HH:mm:ss"));
+
+        // 发送消息
+        schoolNotifyMessageSendService.sendMessage(userId, message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, tenantId);
 
         return true;
     }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/SchoolNotifyMessageSendServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/SchoolNotifyMessageSendServiceImpl.java
index ce7804a4..1f0128d1 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/SchoolNotifyMessageSendServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/service/impl/SchoolNotifyMessageSendServiceImpl.java
@@ -34,7 +34,7 @@ public class SchoolNotifyMessageSendServiceImpl implements SchoolNotifyMessageSe
      * @param message 消息内容
      */
     @Override
-    public void sendMessage(Long userId, String message, String type) {
+    public void sendMessage(Long userId, String message, String type, Long tenantId) {
         NotifySendSingleToUserReqDTO dto = new NotifySendSingleToUserReqDTO();
         dto.setUserId(userId);
         dto.setSystemCode(SystemEnum.SCHOOL.getCode());
@@ -48,9 +48,9 @@ public class SchoolNotifyMessageSendServiceImpl implements SchoolNotifyMessageSe
 
         // 发送消息
         if (SCHOOL_NOTIFY_MESSAGE_TYPE_ADMIN.equals(type)) {
-            sendApi.sendSingleMessageToAdmin(dto);
+            sendApi.sendSingleMessageToAdmin(dto, tenantId);
         } else if (SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER.equals(type)) {
-            sendApi.sendSingleMessageToMember(dto);
+            sendApi.sendSingleMessageToMember(dto, tenantId);
         }
     }
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/utils/DriveSchoolBaseUtil.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/utils/DriveSchoolBaseUtil.java
new file mode 100644
index 00000000..a7742f00
--- /dev/null
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/base/utils/DriveSchoolBaseUtil.java
@@ -0,0 +1,31 @@
+package cn.iocoder.yudao.module.base.utils;
+
+/**
+ * @Description: 驾校基础工具类
+ * @Author: 86187
+ * @Date: 2025/04/09 10:30
+ * @Version: 1.0
+ */
+public class DriveSchoolBaseUtil {
+
+    /**
+     * 获取科目
+     *
+     * @param subject 科目数字
+     * @return 科目字符串
+     */
+    public static String getSubjectStr(Integer subject) {
+        switch (subject) {
+            case 1:
+                return "科目一";
+            case 2:
+                return "科目二";
+            case 3:
+                return "科目三";
+            case 4:
+                return "科目四";
+            default:
+                return "未知";
+        }
+    }
+}
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/entity/SchoolCourseOrder.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/entity/SchoolCourseOrder.java
index 87562f36..524faff3 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/entity/SchoolCourseOrder.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/entity/SchoolCourseOrder.java
@@ -8,6 +8,7 @@ import lombok.*;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
+import java.util.Date;
 
 /**
  * 驾照报名订单 DO
@@ -112,6 +113,14 @@ public class SchoolCourseOrder extends TenantBaseDO {
      * 旧订单id
      */
     private String oldOrderId;
+    /**
+     * 拿证时间
+     */
+    private Date passTime;
+    /**
+     * 毕业时间
+     */
+    private Date gradTime;
 
 
 }
\ No newline at end of file
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/ProcessServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/ProcessServiceImpl.java
index 780e4a0d..462b00c3 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/ProcessServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/ProcessServiceImpl.java
@@ -332,7 +332,7 @@ public class ProcessServiceImpl extends ServiceImpl<ProcessMapper, Process> impl
                 processes.get(3).getCoachName());
 
         // 发送消息给学员
-        schoolNotifyMessageSendService.sendMessage(userId, message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER);
+        schoolNotifyMessageSendService.sendMessage(userId, message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, null);
 
     }
 
@@ -363,7 +363,7 @@ public class ProcessServiceImpl extends ServiceImpl<ProcessMapper, Process> impl
                     .set(Process::getStatus, 2));
         }
 
-        if(process.getSubject() == 1 && process.getExamStatus().equals("1")){
+        if (process.getSubject() == 1 && process.getExamStatus().equals("1")) {
             update(Wrappers.lambdaUpdate(Process.class)
                     .eq(Process::getUserId, process.getUserId())
                     .eq(Process::getSubject, 2)
@@ -371,8 +371,8 @@ public class ProcessServiceImpl extends ServiceImpl<ProcessMapper, Process> impl
                     .eq(Process::getDeleted, SchoolBaseConstants.COMMON_NO)
                     .set(Process::getStatus, SchoolBaseConstants.PROCESS_STATUS_IN_PROGRESS));
         }
-        if(process.getSubject() == 4 && process.getExamStatus().equals("1")){
-            dlDriveSchoolStudentService.updateStudentPassAndGradTime(process.getExamTime(),process.getUserId(),process.getTenantId());
+        if (process.getSubject() == 4 && process.getExamStatus().equals("1")) {
+            dlDriveSchoolStudentService.updateStudentPassAndGradTime(process.getExamTime(), process.getUserId(), process.getCourseId(), process.getTenantId());
         }
 
     }
@@ -397,6 +397,7 @@ public class ProcessServiceImpl extends ServiceImpl<ProcessMapper, Process> impl
 
     /**
      * 根据userId查询考试列表
+     *
      * @param userId 用户id
      */
     @Override
@@ -416,6 +417,7 @@ public class ProcessServiceImpl extends ServiceImpl<ProcessMapper, Process> impl
 
     /**
      * 根据userId查询考试列表
+     *
      * @param userId 用户id
      */
     @Override
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolCourseOrderServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolCourseOrderServiceImpl.java
index 185ef80c..309fade2 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolCourseOrderServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolCourseOrderServiceImpl.java
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
 import cn.iocoder.yudao.module.course.entity.Process;
 import cn.iocoder.yudao.module.course.entity.SchoolCourseOrder;
 import cn.iocoder.yudao.module.course.mapper.SchoolCourseOrderMapper;
@@ -15,6 +16,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -39,6 +41,9 @@ public class SchoolCourseOrderServiceImpl extends ServiceImpl<SchoolCourseOrderM
     @Resource
     private ProcessService processService;
 
+    @Autowired
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
+
     @Override
     public String createSchoolCourseOrder(SchoolCourseOrderVO createReqVO) {
         // 插入
@@ -79,7 +84,7 @@ public class SchoolCourseOrderServiceImpl extends ServiceImpl<SchoolCourseOrderM
      **/
     @Override
     public IPage<SchoolCourseOrderVO> queryPage(Page<SchoolCommissionVO> page, SchoolCourseOrderVO pageReqVO) {
-        return schoolCourseOrderMapper.queryPage(pageReqVO,page);
+        return schoolCourseOrderMapper.queryPage(pageReqVO, page);
     }
     @Override
         public IPage<SchoolCourseOrderVO> queryPageNew(Page<SchoolCommissionVO> page, SchoolCourseOrderVO pageReqVO) {
@@ -110,11 +115,18 @@ public class SchoolCourseOrderServiceImpl extends ServiceImpl<SchoolCourseOrderM
         // 删除学员未开始和训练中的科目
         processService.remove(Wrappers.lambdaQuery(Process.class)
                 .eq(Process::getUserId, schoolCourseOrder.getUserId())
+                .eq(Process::getCourseId, schoolCourseOrder.getCourseId())
                 .and(q -> q.eq(Process::getStatus, SchoolBaseConstants.PROCESS_STATUS_NOT_START)
                         .or()
                         .eq(Process::getStatus, SchoolBaseConstants.PROCESS_STATUS_IN_PROGRESS))
         );
 
+        // 准备消息内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_COURSE_END, schoolCourseOrder.getCourseName());
+
+        // 发送消息给学员
+        schoolNotifyMessageSendService.sendMessage(Long.valueOf(schoolCourseOrder.getUserId()), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, null);
+
     }
 
     /**
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolFeedbackServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolFeedbackServiceImpl.java
index d047b478..43e05bb0 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolFeedbackServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/course/service/impl/SchoolFeedbackServiceImpl.java
@@ -28,6 +28,8 @@ import java.util.Map;
 import java.util.Optional;
 import java.util.stream.Collectors;
 
+import static cn.iocoder.yudao.module.base.utils.DriveSchoolBaseUtil.getSubjectStr;
+
 /**
  * 反馈Service业务层处理
  *
@@ -77,7 +79,8 @@ public class SchoolFeedbackServiceImpl extends ServiceImpl<SchoolFeedBackMapper,
     public IPage<SchoolFeedBackVO> queryPage(Page<SchoolFeedBack> page, SchoolFeedBackVO request) {
         // 1. 分页查询原始数据
         IPage<SchoolFeedBack> pageList = this.page(page, Wrappers.lambdaQuery(SchoolFeedBack.class)
-                .eq(ObjectUtil.isNotEmpty(request.getUserId()), SchoolFeedBack::getUserId, request.getUserId()));
+                .eq(ObjectUtil.isNotEmpty(request.getUserId()), SchoolFeedBack::getUserId, request.getUserId())
+                .orderByDesc(SchoolFeedBack::getCreateTime));
 
         // 2. 提取训练和考试的ID集合
         List<String> trainIds = pageList.getRecords().stream()
@@ -111,11 +114,15 @@ public class SchoolFeedbackServiceImpl extends ServiceImpl<SchoolFeedBackMapper,
         List<SchoolFeedBackVO> voList = pageList.getRecords().stream().map(item -> {
             SchoolFeedBackVO vo = BeanUtil.copyProperties(item, SchoolFeedBackVO.class);
             if (SchoolBaseConstants.EVALUATE_TYPE_TRAIN.equals(item.getEvaluateType())) {
+                // 设置标题
                 vo.setBusiName(getSubjectStr(trainMap.get(item.getBusiId()).getSubject()) + "训练");
+                // 设置课程类型和教练名
                 vo.setCourseType(trainMap.get(item.getBusiId()).getCourseType());
                 vo.setCoachName(trainMap.get(item.getBusiId()).getCoachName());
             } else if (SchoolBaseConstants.EVALUATE_TYPE_EXAM.equals(item.getEvaluateType())) {
+                // 设置标题
                 vo.setBusiName(getSubjectStr(examMap.get(item.getBusiId()).getSubject()) + "考试");
+                // 设置课程类型和教练名
                 vo.setCourseType(examMap.get(item.getBusiId()).getCourseType());
                 vo.setCoachName(examMap.get(item.getBusiId()).getCoachName());
             }
@@ -129,22 +136,4 @@ public class SchoolFeedbackServiceImpl extends ServiceImpl<SchoolFeedBackMapper,
 
         return resultPage;
     }
-
-    public String getSubjectStr(Integer subject) {
-        if (subject == null) {
-            return "";
-        }
-        switch (subject) {
-            case 1:
-                return "科目一";
-            case 2:
-                return "科目二";
-            case 3:
-                return "科目三";
-            case 4:
-                return "科目四";
-            default:
-                return "";
-        }
-    }
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/exam/service/impl/ExamBatchServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/exam/service/impl/ExamBatchServiceImpl.java
index 35bf1581..056e0600 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/exam/service/impl/ExamBatchServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/exam/service/impl/ExamBatchServiceImpl.java
@@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.exam.service.impl;
 
 import cn.hutool.core.date.DateUtil;
 import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
+import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
 import cn.iocoder.yudao.module.course.mapper.ProcessMapper;
 import cn.iocoder.yudao.module.exam.entity.ExamBatch;
 import cn.iocoder.yudao.module.exam.entity.ExamBatchItem;
@@ -18,11 +20,15 @@ import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
+import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 
+import static cn.iocoder.yudao.module.base.utils.DriveSchoolBaseUtil.getSubjectStr;
+
 
 /**
  * 考试批次主表 Service 实现类
@@ -38,6 +44,8 @@ public class ExamBatchServiceImpl extends ServiceImpl<ExamBatchMapper, ExamBatch
     @Autowired
     @Lazy
     private ExamBatchItemService examBatchItemService;
+    @Resource
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
 
     /**
      * 分页查询
@@ -88,6 +96,7 @@ public class ExamBatchServiceImpl extends ServiceImpl<ExamBatchMapper, ExamBatch
      * @date 23:11 2025/1/20
      **/
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void createObj(ExamBatchVO examBatchVO) {
         //生成批次编号
         String timestamp = DateUtil.format(DateUtil.date(), "yyyyMMddHHmmss");
@@ -106,6 +115,14 @@ public class ExamBatchServiceImpl extends ServiceImpl<ExamBatchMapper, ExamBatch
         //更新每个学生对应学习进度表考试的状态，设置为 已送考
         List<Long> userIdList = examBatchVO.getItemList().stream().map(ExamBatchItem::getUserId).collect(Collectors.toList());
         processMapper.updateProcessBatch(userIdList,examBatchVO.getCourseId(),examBatchVO.getSubject(),examBatchVO.getCoachId());
+
+        // 准备信息内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_EXAM_BATCH, examBatchVO.getCourseName(), getSubjectStr(examBatchVO.getSubject()), DateUtil.format(examBatchVO.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(examBatchVO.getEndTime(), "yyyy-MM-dd HH:mm:ss"), examBatchVO.getAddr());
+
+        itemList.forEach(item->{
+            // 发送消息
+            schoolNotifyMessageSendService.sendMessage(item.getUserId(), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, null);
+        });
     }
 
     /**
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/admin/ReservationCourseController.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/admin/ReservationCourseController.java
index 0572cd6f..fb753e36 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/admin/ReservationCourseController.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/admin/ReservationCourseController.java
@@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.train.controller.admin;
 
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
+import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
 import cn.iocoder.yudao.module.train.entity.ReservationCourse;
 import cn.iocoder.yudao.module.train.service.ReservationCourseService;
 import cn.iocoder.yudao.module.train.vo.ReservationCourseVO;
@@ -18,6 +20,7 @@ import javax.annotation.Resource;
 import javax.validation.Valid;
 
 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
+import static cn.iocoder.yudao.module.base.utils.DriveSchoolBaseUtil.getSubjectStr;
 
 @Tag(name = "管理后台 - 预约练车")
 @RestController
@@ -28,28 +31,40 @@ public class ReservationCourseController {
     @Resource
     private ReservationCourseService reservationCourseService;
 
+    @Resource
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
+
 
     @GetMapping("/page")
     @Operation(summary = "获得预约练车分页")
     public CommonResult<IPage<?>> getPage(ReservationCourseVO pageReqVO,
                                           @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
                                           @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
-        Page<ReservationCourseVO> page = new Page<>(pageNo,pageSize);
-        if("my".equals(pageReqVO.getSelectType())){
+        Page<ReservationCourseVO> page = new Page<>(pageNo, pageSize);
+        if ("my".equals(pageReqVO.getSelectType())) {
             //查自己的
             Long userId = SecurityFrameworkUtils.getLoginUserId();
             pageReqVO.setCoachId(userId);
         }
         //查未取消的
         pageReqVO.setIfCancel(false);
-        return success(reservationCourseService.queryListPage(pageReqVO,page));
+        return success(reservationCourseService.queryListPage(pageReqVO, page));
     }
 
 
     @PutMapping("/update")
     @Operation(summary = "审核预约练车")
-    public CommonResult<Boolean> updateReservationCourse(@Valid @RequestBody ReservationCourseVO updateReqVO) {
+    public CommonResult<Boolean> updateReservationCourse(@RequestBody ReservationCourseVO updateReqVO) {
         reservationCourseService.updateById(updateReqVO);
+
+        //通过id查询预约记录
+        ReservationCourse createObj = reservationCourseService.getById(updateReqVO.getId());
+
+        // 准备内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_COACH_RESERVE_RESULT, createObj.getReservDay(), createObj.getReservTime(), createObj.getCourseName(), getSubjectStr(createObj.getSubject()), reservatStatusStr(updateReqVO.getStatus()));
+
+        // 发送消息
+        schoolNotifyMessageSendService.sendMessage(createObj.getUserId(), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, createObj.getTenantId());
         return success(true);
     }
 
@@ -72,11 +87,12 @@ public class ReservationCourseController {
 
     /**
      * 根据学生userId查询学生信息及当天的预约记录
-     * @author vinjor-M
-     * @date 17:25 2025/1/16
+     *
      * @param userId 学生userId
      * @return cn.iocoder.yudao.framework.common.pojo.CommonResult<cn.iocoder.yudao.module.train.entity.ReservationCourse>
-    **/
+     * @author vinjor-M
+     * @date 17:25 2025/1/16
+     **/
     @GetMapping("/getUserInfoAndReservation")
     @Operation(summary = "根据学生userId查询学生信息及当天的预约记录")
     @Parameter(name = "id", description = "学生userId", required = true, example = "1024")
@@ -84,7 +100,15 @@ public class ReservationCourseController {
                                                 @RequestParam("courseId") String courseId,
                                                 @RequestParam("type") String type,
                                                 @RequestParam("subject") Integer subject) {
-        return success(reservationCourseService.getUserInfoAndReservation(userId,courseId,subject,type));
+        return success(reservationCourseService.getUserInfoAndReservation(userId, courseId, subject, type));
+    }
+
+    public String reservatStatusStr(Boolean status) {
+        if (!status) {
+            return "拒绝";
+        } else{
+            return "通过";
+        }
     }
 
 }
\ No newline at end of file
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/app/AppReservationCourseController.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/app/AppReservationCourseController.java
index fbd714cd..cae58bed 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/app/AppReservationCourseController.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/controller/app/AppReservationCourseController.java
@@ -2,6 +2,12 @@ package cn.iocoder.yudao.module.train.controller.app;
 
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
+import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
+import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
+import cn.iocoder.yudao.module.base.service.DlDriveSchoolCoachService;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
+import cn.iocoder.yudao.module.base.vo.DlDriveSchoolCoachRespVO;
+import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
 import cn.iocoder.yudao.module.train.entity.ReservationCourse;
 import cn.iocoder.yudao.module.train.service.ReservationCourseService;
 import cn.iocoder.yudao.module.train.vo.ReservationCourseVO;
@@ -10,12 +16,15 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 
 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
+import static cn.iocoder.yudao.module.base.utils.DriveSchoolBaseUtil.getSubjectStr;
 
 @Tag(name = "小程序 - 预约练车")
 @RestController
@@ -26,22 +35,34 @@ public class AppReservationCourseController {
     @Resource
     private ReservationCourseService reservationCourseService;
 
+    @Resource
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
+
 
     @GetMapping("/page")
     @Operation(summary = "获得预约练车分页")
+    @TenantIgnore
     public CommonResult<IPage<?>> getPage(ReservationCourseVO pageReqVO,
                                           @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
                                           @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
-        Page<ReservationCourseVO> page = new Page<>(pageNo,pageSize);
+        Page<ReservationCourseVO> page = new Page<>(pageNo, pageSize);
         Long userId = SecurityFrameworkUtils.getLoginUserId();
         pageReqVO.setUserId(userId);
-        return success(reservationCourseService.queryListPage(pageReqVO,page));
+        return success(reservationCourseService.queryListPage(pageReqVO, page));
     }
 
     @PutMapping("/create")
     @Operation(summary = "预约练车")
-    public CommonResult<Boolean> createReservationCourse( @RequestBody ReservationCourse createObj) {
+    @TenantIgnore
+    @Transactional
+    public CommonResult<Boolean> createReservationCourse(@RequestBody @Validated ReservationCourse createObj) {
         reservationCourseService.save(createObj);
+
+        // 准备消息内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_RESERVE_TRAIN, createObj.getUserName(), createObj.getReservDay(), createObj.getReservTime(), createObj.getCourseName(), getSubjectStr(createObj.getSubject()));
+
+        // 发送消息
+        schoolNotifyMessageSendService.sendMessage(createObj.getCoachId(), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_ADMIN, createObj.getTenantId());
         return success(true);
     }
 
@@ -70,5 +91,4 @@ public class AppReservationCourseController {
         return success(reservationCourseService.getById(id));
     }
 
-
 }
\ No newline at end of file
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/entity/ReservationCourse.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/entity/ReservationCourse.java
index 66a675a0..d02f81fa 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/entity/ReservationCourse.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/entity/ReservationCourse.java
@@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.*;
 
+import javax.validation.constraints.NotBlank;
+
 /**
  * 预约练车 DO
  *
@@ -51,10 +53,12 @@ public class ReservationCourse extends TenantBaseDO {
     /**
      * 预约日期 yyyy-MM-dd
      */
+    @NotBlank(message = "预约日期不能为空")
     private String reservDay;
     /**
      * 时间段（字典：school_reserv_time）09:00-10:00
      */
+    @NotBlank(message = "预约时间不能为空")
     private String reservTime;
     /**
      * 科目（1-科目一；2-科目二；3科目三；4科目四）
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/ReservationCourseService.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/ReservationCourseService.java
index 7e8022bd..d87b4553 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/ReservationCourseService.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/ReservationCourseService.java
@@ -17,21 +17,23 @@ public interface ReservationCourseService extends IService<ReservationCourse> {
 
     /**
      * 分页查询
+     *
+     * @param pageReqVO TODO
+     * @param page      TODO
+     * @return com.baomidou.mybatisplus.core.metadata.IPage<cn.iocoder.yudao.module.train.vo.ReservationCourseVO>
      * @author vinjor-M
      * @date 15:05 2025/1/14
-     * @param pageReqVO TODO
- * @param page TODO
-     * @return com.baomidou.mybatisplus.core.metadata.IPage<cn.iocoder.yudao.module.train.vo.ReservationCourseVO>
-    **/
+     **/
     IPage<ReservationCourseVO> queryListPage(ReservationCourseVO pageReqVO, Page<ReservationCourseVO> page);
 
     /**
      * 根据学生userId查询学生信息及当天的预约记录
+     *
+     * @param userId
+     * @return java.util.Map<java.lang.String, java.lang.Object>
      * @author vinjor-M
      * @date 17:27 2025/1/16
-     * @param userId
-     * @return java.util.Map<java.lang.String,java.lang.Object>
-    **/
-    Map<String,Object> getUserInfoAndReservation(Long userId,String courseId,Integer subject,String type);
+     **/
+    Map<String, Object> getUserInfoAndReservation(Long userId, String courseId, Integer subject, String type);
 
 }
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/impl/TrainServiceImpl.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/impl/TrainServiceImpl.java
index d2e8ac8f..b5bb0273 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/impl/TrainServiceImpl.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/service/impl/TrainServiceImpl.java
@@ -3,6 +3,8 @@ package cn.iocoder.yudao.module.train.service.impl;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import cn.iocoder.yudao.module.base.constant.SchoolBaseConstants;
+import cn.iocoder.yudao.module.base.service.SchoolNotifyMessageSendService;
 import cn.iocoder.yudao.module.course.entity.Process;
 import cn.iocoder.yudao.module.course.service.ProcessService;
 import cn.iocoder.yudao.module.train.entity.Train;
@@ -17,9 +19,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
 import java.util.Date;
 import java.util.List;
 
+import static cn.iocoder.yudao.module.base.utils.DriveSchoolBaseUtil.getSubjectStr;
+
 
 /**
  * 预约练车 Service 实现类
@@ -33,6 +38,8 @@ public class TrainServiceImpl extends ServiceImpl<TrainMapper, Train> implements
     @Autowired
     @Lazy
     private ProcessService processService;
+    @Resource
+    private SchoolNotifyMessageSendService schoolNotifyMessageSendService;
 
     /**
      * 分页查询
@@ -72,6 +79,11 @@ public class TrainServiceImpl extends ServiceImpl<TrainMapper, Train> implements
     public void createObj(TrainVO trainVO) {
         trainVO.setTrainDay(DateUtil.format(new Date(), "yyyy-MM-dd"));
         this.save(trainVO);
+
+        // 准备消息内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_ATTENDANCE, DateUtil.format(trainVO.getStartTime(), "yyyy-MM-dd HH:mm:ss"), trainVO.getAddr(), trainVO.getCourseName(), getSubjectStr(trainVO.getSubject()));
+
+        schoolNotifyMessageSendService.sendMessage(trainVO.getUserId(), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, null);
     }
 
     /**
@@ -92,6 +104,11 @@ public class TrainServiceImpl extends ServiceImpl<TrainMapper, Train> implements
         process.setId(trainVO.getProcessId());
         process.setTrainTime(allTrainTime);
         processService.updateById(process);
+
+        // 准备消息内容
+        String message = String.format(SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TEMPLATE_MEMBER_END_ATTENDANCE, DateUtil.format(trainVO.getEndTime(), "yyyy-MM-dd HH:mm:ss"), trainVO.getCourseName(), getSubjectStr(trainVO.getSubject()), trainVO.getTrainTime(), trainVO.getAllTrainTime());
+
+        schoolNotifyMessageSendService.sendMessage(trainVO.getUserId(), message, SchoolBaseConstants.SCHOOL_NOTIFY_MESSAGE_TYPE_MEMBER, null);
     }
 
     /**
diff --git a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/vo/ReservationCourseVO.java b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/vo/ReservationCourseVO.java
index c6032dda..7076965d 100644
--- a/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/vo/ReservationCourseVO.java
+++ b/dl-module-jx/src/main/java/cn/iocoder/yudao/module/train/vo/ReservationCourseVO.java
@@ -1,6 +1,7 @@
 package cn.iocoder.yudao.module.train.vo;
 
 import cn.iocoder.yudao.module.train.entity.ReservationCourse;
+import com.baomidou.mybatisplus.annotation.TableField;
 import lombok.Data;
 
 @Data
@@ -26,4 +27,16 @@ public class ReservationCourseVO extends ReservationCourse {
      * 用户性别-学员
      */
     private String userSex;
+    /**
+     * 状态字符串
+     */
+    private String statusStr;
+    /**
+     * 科目字符串
+     */
+    private String subjectStr;
+    /**
+     * 课程类型
+     */
+    private String courseType;
 }
diff --git a/dl-module-jx/src/main/resources/mapper/exam/ExamBatchItemMapper.xml b/dl-module-jx/src/main/resources/mapper/exam/ExamBatchItemMapper.xml
index 82dd763a..ad5c2409 100644
--- a/dl-module-jx/src/main/resources/mapper/exam/ExamBatchItemMapper.xml
+++ b/dl-module-jx/src/main/resources/mapper/exam/ExamBatchItemMapper.xml
@@ -143,10 +143,13 @@
         dseb.`subject`,
         dseb.addr,
         dseb.trans_way,
-        dseb.coach_id
+        dseb.coach_id,
+        dseb.coach_name,
+        dsc.type AS courseType
         FROM
         drive_school_exam_batch_item dsebi
         LEFT JOIN drive_school_exam_batch dseb ON dsebi.batch_id = dseb.id
+        LEFT JOIN drive_school_course dsc ON dseb.course_id = dsc.id
         WHERE
         dsebi.id IN
         <foreach collection="examIds" item="id" open="(" separator="," close=")">
diff --git a/dl-module-jx/src/main/resources/mapper/train/ReservationCourseMapper.xml b/dl-module-jx/src/main/resources/mapper/train/ReservationCourseMapper.xml
index f3eda1dc..aaa4156f 100644
--- a/dl-module-jx/src/main/resources/mapper/train/ReservationCourseMapper.xml
+++ b/dl-module-jx/src/main/resources/mapper/train/ReservationCourseMapper.xml
@@ -6,7 +6,19 @@
 
     <select id="queryListPage" resultType="cn.iocoder.yudao.module.train.vo.ReservationCourseVO">
         SELECT
-        dsrc.*,dsp.train_time,dss.name AS userName,dss.phone AS userMobile,dss.sex AS userSex
+        dsrc.*,dsp.train_time,dss.name AS userName,dss.phone AS userMobile,dss.sex AS userSex,dsc.type as courseType,
+        CASE dsrc.status
+        WHEN 0 THEN '已拒绝'
+        WHEN 1 THEN '已审核'
+        ELSE '待审核'
+        END AS statusStr,
+        CASE dsrc.subject
+        WHEN 1 THEN '科目一'
+        WHEN 2 THEN '科目二'
+        WHEN 3 THEN '科目三'
+        WHEN 4 THEN '科目四'
+        ELSE '未知'
+        END AS subjectStr
         FROM
         drive_school_reservation_course dsrc
         LEFT JOIN drive_school_process dsp ON dsrc.user_id = dsp.user_id
@@ -15,6 +27,7 @@
         AND dsrc.`subject` = dsp.`subject`
         AND dsp.`status`='1'
         LEFT JOIN drive_school_student dss ON dsrc.user_id = dss.user_id
+        LEFT JOIN drive_school_course dsc ON dsrc.course_id = dsc.id
         where
             dsrc.deleted = 0
             <if test="entity.userId != null and entity.userId != ''">
diff --git a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApi.java b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApi.java
index facedfad..2d02c198 100644
--- a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApi.java
+++ b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApi.java
@@ -27,4 +27,20 @@ public interface NotifyMessageSendApi {
      */
     Long sendSingleMessageToMember(@Valid NotifySendSingleToUserReqDTO reqDTO);
 
+    /**
+     * 发送单条站内信给 Admin 用户
+     *
+     * @param reqDTO 发送请求
+     * @return 发送消息 ID
+     */
+    Long sendSingleMessageToAdmin(@Valid NotifySendSingleToUserReqDTO reqDTO, Long tenantId);
+
+    /**
+     * 发送单条站内信给 Member 用户
+     *
+     * @param reqDTO 发送请求
+     * @return 发送消息 ID
+     */
+    Long sendSingleMessageToMember(@Valid NotifySendSingleToUserReqDTO reqDTO, Long tenantId);
+
 }
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApiImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApiImpl.java
index 18e5c009..b5887a55 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApiImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/notify/NotifyMessageSendApiImpl.java
@@ -1,5 +1,6 @@
 package cn.iocoder.yudao.module.system.api.notify;
 
+import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
 import cn.iocoder.yudao.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;
 import cn.iocoder.yudao.module.system.service.notify.NotifySendService;
 import org.springframework.stereotype.Service;
@@ -20,13 +21,25 @@ public class NotifyMessageSendApiImpl implements NotifyMessageSendApi {
     @Override
     public Long sendSingleMessageToAdmin(NotifySendSingleToUserReqDTO reqDTO) {
         return notifySendService.sendSingleNotifyToAdmin(reqDTO.getUserId(),
-                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(),reqDTO.getSystemCode());
+                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(), reqDTO.getSystemCode());
     }
 
     @Override
     public Long sendSingleMessageToMember(NotifySendSingleToUserReqDTO reqDTO) {
         return notifySendService.sendSingleNotifyToMember(reqDTO.getUserId(),
-                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(),reqDTO.getSystemCode());
+                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(), reqDTO.getSystemCode());
+    }
+
+    @Override
+    public Long sendSingleMessageToAdmin(NotifySendSingleToUserReqDTO reqDTO, Long tenantId) {
+        return notifySendService.sendSingleNotify(reqDTO.getUserId(), UserTypeEnum.ADMIN.getValue(),
+                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(), reqDTO.getSystemCode(), tenantId);
+    }
+
+    @Override
+    public Long sendSingleMessageToMember(NotifySendSingleToUserReqDTO reqDTO, Long tenantId) {
+        return notifySendService.sendSingleNotify(reqDTO.getUserId(), UserTypeEnum.MEMBER.getValue(),
+                reqDTO.getTemplateCode(), reqDTO.getTemplateParams(), reqDTO.getSystemCode(), tenantId);
     }
 
 }
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/notify/NotifyMessageDO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/notify/NotifyMessageDO.java
index 64611fba..8831907f 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/notify/NotifyMessageDO.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/notify/NotifyMessageDO.java
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.system.dal.dataobject.notify;
 
 import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import cn.iocoder.yudao.framework.tenant.core.db.TenantBaseDO;
 import com.baomidou.mybatisplus.annotation.KeySequence;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
@@ -25,7 +26,7 @@ import java.util.Map;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class NotifyMessageDO extends BaseDO {
+public class NotifyMessageDO extends TenantBaseDO {
 
     /**
      * 站内信编号，自增
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageService.java
index b40d9a99..99c70738 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageService.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageService.java
@@ -30,6 +30,20 @@ public interface NotifyMessageService {
     Long createNotifyMessage(Long userId, Integer userType,
                              NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams,String systemCode);
 
+    /**
+     * 创建站内信
+     *
+     * @param userId 用户编号
+     * @param userType 用户类型
+     * @param template 模版信息
+     * @param templateContent 模版内容
+     * @param templateParams 模版参数
+     * @param tenantId 租户id
+     * @return 站内信编号
+     */
+    Long createNotifyMessage(Long userId, Integer userType,
+                             NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams,String systemCode, Long tenantId);
+
     /**
      * 获得站内信分页
      *
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageServiceImpl.java
index 88f347b6..c716dc4f 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageServiceImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifyMessageServiceImpl.java
@@ -29,7 +29,7 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
 
     @Override
     public Long createNotifyMessage(Long userId, Integer userType,
-                                    NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams,String systemCode) {
+                                    NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams, String systemCode) {
         NotifyMessageDO message = new NotifyMessageDO().setUserId(userId).setUserType(userType)
                 .setTemplateId(template.getId()).setTemplateCode(template.getCode())
                 .setSystemCode(systemCode)
@@ -39,6 +39,30 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
         return message.getId();
     }
 
+    /**
+     * 创建站内信
+     *
+     * @param userId          用户编号
+     * @param userType        用户类型
+     * @param template        模版信息
+     * @param templateContent 模版内容
+     * @param templateParams  模版参数
+     * @param systemCode      系统编码
+     * @param tenantId        租户id
+     * @return 站内信编号
+     */
+    @Override
+    public Long createNotifyMessage(Long userId, Integer userType, NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams, String systemCode, Long tenantId) {
+        NotifyMessageDO message = new NotifyMessageDO().setUserId(userId).setUserType(userType)
+                .setTemplateId(template.getId()).setTemplateCode(template.getCode())
+                .setSystemCode(systemCode)
+                .setTemplateType(template.getType()).setTemplateNickname(template.getNickname())
+                .setTemplateContent(templateContent).setTemplateParams(templateParams).setReadStatus(false);
+        message.setTenantId(tenantId);
+        notifyMessageMapper.insert(message);
+        return message.getId();
+    }
+
     @Override
     public PageResult<NotifyMessageDO> getNotifyMessagePage(NotifyMessagePageReqVO pageReqVO) {
         return notifyMessageMapper.selectPage(pageReqVO);
@@ -48,6 +72,7 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
     public PageResult<NotifyMessageDO> getMyMyNotifyMessagePage(NotifyMessageMyPageReqVO pageReqVO, Long userId, Integer userType) {
         return notifyMessageMapper.selectPage(pageReqVO, userId, userType);
     }
+
     @Override
     @TenantIgnore
     public PageResult<NotifyMessageDO> getWxMyNotifyMessagePage(NotifyMessageMyPageReqVO pageReqVO, Long userId) {
@@ -65,12 +90,13 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
     }
 
     @Override
-    public Long getUnreadNotifyMessageCount(Long userId, Integer userType,String systemCode) {
-        return notifyMessageMapper.selectUnreadCountByUserIdAndUserType(userId, userType,systemCode);
+    public Long getUnreadNotifyMessageCount(Long userId, Integer userType, String systemCode) {
+        return notifyMessageMapper.selectUnreadCountByUserIdAndUserType(userId, userType, systemCode);
     }
+
     @Override
     @TenantIgnore
-    public Long getWXUnreadNotifyMessageCount(Long userId,String systemCode) {
+    public Long getWXUnreadNotifyMessageCount(Long userId, String systemCode) {
         return notifyMessageMapper.selectUnreadCountByUserIdAndUserType(userId, 1, systemCode);
     }
 
@@ -78,6 +104,7 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
     public int updateNotifyMessageRead(Collection<Long> ids, Long userId, Integer userType) {
         return notifyMessageMapper.updateListRead(ids, userId, userType);
     }
+
     @Override
     @TenantIgnore
     public int updateWXNotifyMessageRead(Collection<Long> ids, Long userId) {
@@ -88,6 +115,7 @@ public class NotifyMessageServiceImpl implements NotifyMessageService {
     public int updateAllNotifyMessageRead(Long userId, Integer userType) {
         return notifyMessageMapper.updateListRead(userId, userType);
     }
+
     @Override
     @TenantIgnore
     public int updateWXAllNotifyMessageRead(Long userId) {
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendService.java
index 7bebc2a0..b71e3ebb 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendService.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendService.java
@@ -47,6 +47,19 @@ public interface NotifySendService {
     Long sendSingleNotify( Long userId, Integer userType,
                            String templateCode, Map<String, Object> templateParams,String systemCode);
 
+    /**
+     * 发送单条站内信给用户
+     *
+     * @param userId 用户编号
+     * @param userType 用户类型
+     * @param templateCode 站内信模板编号
+     * @param templateParams 站内信模板参数
+     * @param tenantId 租户id
+     * @return 发送日志编号
+     */
+    Long sendSingleNotify( Long userId, Integer userType,
+                           String templateCode, Map<String, Object> templateParams,String systemCode, Long tenantId);
+
     default void sendBatchNotify(List<String> mobiles, List<Long> userIds, Integer userType,
                                  String templateCode, Map<String, Object> templateParams) {
         throw new UnsupportedOperationException("暂时不支持该操作，感兴趣可以实现该功能哟！");
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendServiceImpl.java
index 8c14b65e..558d355a 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendServiceImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/notify/NotifySendServiceImpl.java
@@ -58,6 +58,33 @@ public class NotifySendServiceImpl implements NotifySendService {
         return notifyMessageService.createNotifyMessage(userId, userType, template, content, templateParams,systemCode);
     }
 
+    /**
+     * 发送单条站内信给用户
+     *
+     * @param userId         用户编号
+     * @param userType       用户类型
+     * @param templateCode   站内信模板编号
+     * @param templateParams 站内信模板参数
+     * @param systemCode
+     * @param tenantId       租户id
+     * @return 发送日志编号
+     */
+    @Override
+    public Long sendSingleNotify(Long userId, Integer userType, String templateCode, Map<String, Object> templateParams, String systemCode, Long tenantId) {
+        // 校验模版
+        NotifyTemplateDO template = validateNotifyTemplate(templateCode);
+        if (Objects.equals(template.getStatus(), CommonStatusEnum.DISABLE.getStatus())) {
+            log.info("[sendSingleNotify][模版({})已经关闭，无法给用户({}/{})发送]", templateCode, userId, userType);
+            return null;
+        }
+        // 校验参数
+        validateTemplateParams(template, templateParams);
+
+        // 发送站内信
+        String content = notifyTemplateService.formatNotifyTemplateContent(template.getContent(), templateParams);
+        return notifyMessageService.createNotifyMessage(userId, userType, template, content, templateParams,systemCode, tenantId);
+    }
+
     @VisibleForTesting
     public NotifyTemplateDO validateNotifyTemplate(String templateCode) {
         // 获得站内信模板。考虑到效率，从缓存中获取