diff --git a/RuoYi-Vue/ruoyi-train/src/test/java/com/ruoyi/train/service/impl/CoreBusinessScenarioMockTest.java b/RuoYi-Vue/ruoyi-train/src/test/java/com/ruoyi/train/service/impl/CoreBusinessScenarioMockTest.java new file mode 100644 index 000000000..cd3afc408 --- /dev/null +++ b/RuoYi-Vue/ruoyi-train/src/test/java/com/ruoyi/train/service/impl/CoreBusinessScenarioMockTest.java @@ -0,0 +1,1024 @@ +package com.ruoyi.train.service.impl; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertNull; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.fail; + +import java.lang.reflect.Field; +import java.lang.reflect.InvocationHandler; +import java.lang.reflect.Method; +import java.lang.reflect.Proxy; +import java.util.ArrayList; +import java.util.Collections; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.concurrent.atomic.AtomicLong; + +import org.junit.Before; +import org.junit.Test; + +import com.ruoyi.common.exception.ServiceException; +import com.ruoyi.train.constant.EnrollmentErrorCode; +import com.ruoyi.train.constant.LessonErrorCode; +import com.ruoyi.train.constant.PlanErrorCode; +import com.ruoyi.train.constant.StudentErrorCode; +import com.ruoyi.train.domain.TrainClassPlan; +import com.ruoyi.train.domain.TrainClassroomInfo; +import com.ruoyi.train.domain.TrainCourse; +import com.ruoyi.train.domain.TrainElectronicBoard; +import com.ruoyi.train.domain.TrainEnrollment; +import com.ruoyi.train.domain.TrainLesson; +import com.ruoyi.train.domain.TrainPlanCourse; +import com.ruoyi.train.domain.TrainStudent; +import com.ruoyi.train.domain.TrainTeacher; +import com.ruoyi.train.domain.TrainTrainingSite; +import com.ruoyi.train.domain.dto.EnrollmentAddDTO; +import com.ruoyi.train.domain.dto.LessonCreateDTO; +import com.ruoyi.train.domain.dto.LessonConflictCheckDTO; +import com.ruoyi.train.domain.dto.PlanCourseAddDTO; +import com.ruoyi.train.domain.dto.PlanCreateDTO; +import com.ruoyi.train.domain.query.EnrollmentQuery; +import com.ruoyi.train.domain.vo.ClassroomDetailVO; +import com.ruoyi.train.domain.vo.ConflictItemVO; +import com.ruoyi.train.domain.vo.EnrollmentItemVO; +import com.ruoyi.train.domain.vo.LessonConflictVO; +import com.ruoyi.train.domain.vo.PlanCourseItemVO; +import com.ruoyi.train.domain.vo.PlanTimetableVO; +import com.ruoyi.train.domain.vo.TimetableDayVO; +import com.ruoyi.train.domain.vo.TimetableLessonItemVO; +import com.ruoyi.train.mapper.TrainClassPlanMapper; +import com.ruoyi.train.mapper.TrainClassroomInfoMapper; +import com.ruoyi.train.mapper.TrainElectronicBoardMapper; +import com.ruoyi.train.mapper.TrainEnrollmentMapper; +import com.ruoyi.train.mapper.TrainLessonMapper; +import com.ruoyi.train.mapper.TrainPlanCourseMapper; +import com.ruoyi.train.mapper.TrainStudentMapper; +import com.ruoyi.train.service.ITrainClassPlanService; +import com.ruoyi.train.service.ITrainCourseService; +import com.ruoyi.train.service.ITrainElectronicBoardService; +import com.ruoyi.train.service.ITrainEnrollmentService; +import com.ruoyi.train.service.ITrainPlanCourseService; +import com.ruoyi.train.service.port.PlanEnrollmentCompletionPort; + +/** + * 核心业务场景离线 Mock 自动化测试 (SCENARIO-01 ~ SCENARIO-05)。 + * 严格离线 Mock 运行，不污染默认 mvn test，不连接外部真实数据库。 + */ +public class CoreBusinessScenarioMockTest +{ + private final Map planStore = new HashMap<>(); + private final Map planCourseStore = new HashMap<>(); + private final Map courseStore = new HashMap<>(); + private final Map enrollmentStore = new HashMap<>(); + private final Map studentStore = new HashMap<>(); + private final Map lessonStore = new HashMap<>(); + private final Map teacherStore = new HashMap<>(); + private final Map classroomStore = new HashMap<>(); + private final Map siteStore = new HashMap<>(); + private final Map boardStore = new HashMap<>(); + + private final AtomicLong pcIdGen = new AtomicLong(100); + private final AtomicLong enrollIdGen = new AtomicLong(200); + private final AtomicLong lessonIdGen = new AtomicLong(300); + + private ITrainClassPlanService planService; + private ITrainPlanCourseService planCourseService; + private ITrainCourseService courseService; + private ITrainEnrollmentService enrollmentService; + private TrainEnrollmentMapper enrollmentMapper; + private TrainStudentMapper studentMapper; + private TrainLessonMapper lessonMapper; + private TrainClassPlanMapper planMapper; + private TrainPlanCourseMapper planCourseMapper; + private TrainElectronicBoardMapper boardMapper; + private TrainClassroomInfoMapper classroomMapper; + + private PlanAppServiceImpl planAppService; + private EnrollmentAppServiceImpl enrollmentAppService; + private SchedulingAppServiceImpl schedulingAppService; + private TrainElectronicBoardServiceImpl boardService; + private TrainClassroomInfoServiceImpl classroomService; + private EnrollmentPlanCompletionAdapter completionAdapter; + + @Before + public void setUp() throws Exception + { + planStore.clear(); + planCourseStore.clear(); + courseStore.clear(); + enrollmentStore.clear(); + studentStore.clear(); + lessonStore.clear(); + teacherStore.clear(); + classroomStore.clear(); + siteStore.clear(); + boardStore.clear(); + + // 1. Mock ITrainClassPlanService + planService = createProxy(ITrainClassPlanService.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainClassPlanByPlanId".equals(name) || "selectTrainClassPlanByPlanIdForUpdate".equals(name)) { + return planStore.get((String) args[0]); + } else if ("insertTrainClassPlan".equals(name)) { + TrainClassPlan p = (TrainClassPlan) args[0]; + planStore.put(p.getPlanId(), p); + return 1; + } else if ("updateTrainClassPlan".equals(name)) { + TrainClassPlan p = (TrainClassPlan) args[0]; + TrainClassPlan old = planStore.get(p.getPlanId()); + if (old != null) { + if (p.getPlanName() != null) old.setPlanName(p.getPlanName()); + if (p.getPlanStatus() != null) old.setPlanStatus(p.getPlanStatus()); + } + return 1; + } else if ("updateTrainClassPlanStatus".equals(name)) { + TrainClassPlan p = (TrainClassPlan) args[0]; + TrainClassPlan old = planStore.get(p.getPlanId()); + if (old != null) old.setPlanStatus(p.getPlanStatus()); + return 1; + } else if ("existsByPlanName".equals(name)) { + return false; + } + return defaultReturnValue(method); + }); + + // 2. Mock ITrainPlanCourseService + planCourseService = createProxy(ITrainPlanCourseService.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainPlanCourseById".equals(name)) { + return planCourseStore.get((Long) args[0]); + } else if ("selectPlanCourseListByPlanId".equals(name)) { + String pId = (String) args[0]; + List list = new ArrayList<>(); + for (TrainPlanCourse pc : planCourseStore.values()) { + if (pId.equals(pc.getPlanId())) { + PlanCourseItemVO vo = new PlanCourseItemVO(); + vo.setPlanCourseId(pc.getPlanCourseId()); + vo.setPlanId(pc.getPlanId()); + vo.setCId(pc.getCId()); + list.add(vo); + } + } + return list; + } else if ("selectExistingCIdsByPlanId".equals(name)) { + String pId = (String) args[0]; + @SuppressWarnings("unchecked") + List cIds = (List) args[1]; + List found = new ArrayList<>(); + for (TrainPlanCourse pc : planCourseStore.values()) { + if (pId.equals(pc.getPlanId()) && cIds.contains(pc.getCId())) found.add(pc.getCId()); + } + return found; + } else if ("insertTrainPlanCourse".equals(name)) { + TrainPlanCourse pc = (TrainPlanCourse) args[0]; + if (pc.getPlanCourseId() == null) pc.setPlanCourseId(pcIdGen.incrementAndGet()); + planCourseStore.put(pc.getPlanCourseId(), pc); + return 1; + } else if ("batchInsertTrainPlanCourse".equals(name)) { + @SuppressWarnings("unchecked") + List list = (List) args[0]; + for (TrainPlanCourse pc : list) { + if (pc.getPlanCourseId() == null) pc.setPlanCourseId(pcIdGen.incrementAndGet()); + planCourseStore.put(pc.getPlanCourseId(), pc); + } + return list.size(); + } else if ("deleteTrainPlanCourseById".equals(name)) { + planCourseStore.remove((Long) args[0]); + return 1; + } + return defaultReturnValue(method); + }); + + // 3. Mock ITrainCourseService + courseService = createProxy(ITrainCourseService.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainCourseByCId".equals(name)) { + return courseStore.get((String) args[0]); + } + return defaultReturnValue(method); + }); + + // 4. Mock ITrainEnrollmentService + enrollmentService = createProxy(ITrainEnrollmentService.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainEnrollmentById".equals(name)) { + return enrollmentStore.get((Long) args[0]); + } else if ("selectTrainEnrollmentByPlanIdAndStudentId".equals(name)) { + String pId = (String) args[0]; + String sId = (String) args[1]; + for (TrainEnrollment e : enrollmentStore.values()) { + if (pId.equals(e.getPlanId()) && sId.equals(e.getStudentId())) return e; + } + return null; + } else if ("countEnrollmentsByPlanId".equals(name)) { + String pId = (String) args[0]; + int c = 0; + for (TrainEnrollment e : enrollmentStore.values()) { + if (pId.equals(e.getPlanId())) c++; + } + return c; + } else if ("insertTrainEnrollment".equals(name)) { + TrainEnrollment e = (TrainEnrollment) args[0]; + if (e.getEnrollmentId() == null) e.setEnrollmentId(enrollIdGen.incrementAndGet()); + enrollmentStore.put(e.getEnrollmentId(), e); + return 1; + } else if ("completeActiveEnrollmentsByPlanId".equals(name)) { + String pId = (String) args[0]; + String op = (String) args[1]; + Date ct = (Date) args[2]; + int c = 0; + for (TrainEnrollment e : enrollmentStore.values()) { + if (pId.equals(e.getPlanId()) && (Integer.valueOf(0).equals(e.getEnrollmentStatus()) || Integer.valueOf(1).equals(e.getEnrollmentStatus()))) { + e.setEnrollmentStatus(4); + e.setCompleteTime(ct); + e.setUpdateBy(op); + e.setUpdateTime(ct); + c++; + } + } + return c; + } else if ("selectEnrollmentItemList".equals(name)) { + EnrollmentQuery q = (EnrollmentQuery) args[0]; + List list = new ArrayList<>(); + for (TrainEnrollment e : enrollmentStore.values()) { + if (q.getPlanId() == null || q.getPlanId().equals(e.getPlanId())) { + EnrollmentItemVO vo = new EnrollmentItemVO(); + vo.setEnrollmentId(e.getEnrollmentId()); + vo.setPlanId(e.getPlanId()); + vo.setStudentId(e.getStudentId()); + vo.setEnrollmentStatus(e.getEnrollmentStatus()); + vo.setCompleteTime(e.getCompleteTime()); + list.add(vo); + } + } + return list; + } + return defaultReturnValue(method); + }); + + // 5. Mock TrainEnrollmentMapper + enrollmentMapper = createProxy(TrainEnrollmentMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectPlanForUpdate".equals(name)) { + return planStore.get((String) args[0]); + } + return defaultReturnValue(method); + }); + + // 6. Mock TrainStudentMapper + studentMapper = createProxy(TrainStudentMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainStudentBySId".equals(name)) { + return studentStore.get((String) args[0]); + } + return defaultReturnValue(method); + }); + + // 7. Mock TrainClassPlanMapper + planMapper = createProxy(TrainClassPlanMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainClassPlanByPlanId".equals(name) || "selectTrainClassPlanByPlanIdForUpdate".equals(name)) { + return planStore.get((String) args[0]); + } + return defaultReturnValue(method); + }); + + // 8. Mock TrainPlanCourseMapper + planCourseMapper = createProxy(TrainPlanCourseMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainPlanCourseById".equals(name)) { + return planCourseStore.get((Long) args[0]); + } + return defaultReturnValue(method); + }); + + // 9. Mock TrainLessonMapper + lessonMapper = createProxy(TrainLessonMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainLessonById".equals(name)) { + return lessonStore.get((Long) args[0]); + } else if ("insertTrainLesson".equals(name)) { + TrainLesson l = (TrainLesson) args[0]; + if (l.getLessonId() == null) l.setLessonId(lessonIdGen.incrementAndGet()); + lessonStore.put(l.getLessonId(), l); + return 1; + } else if ("deleteTrainLessonById".equals(name)) { + lessonStore.remove((Long) args[0]); + return 1; + } else if ("lockTeacherById".equals(name)) { + return teacherStore.get((String) args[0]); + } else if ("lockClassroomById".equals(name)) { + return classroomStore.get((String) args[0]); + } else if ("lockSiteById".equals(name)) { + return siteStore.get((String) args[0]); + } else if ("selectTeacherConflicts".equals(name)) { + String tId = (String) args[0]; + Date start = (Date) args[1]; + Date end = (Date) args[2]; + Long exId = (Long) args[3]; + List conflicts = new ArrayList<>(); + for (TrainLesson l : lessonStore.values()) { + if (exId != null && exId.equals(l.getLessonId())) continue; + if (tId.equals(l.getTId()) && l.getStartTime().before(end) && l.getEndTime().after(start)) { + ConflictItemVO c = new ConflictItemVO(); + c.setLessonId(l.getLessonId()); + conflicts.add(c); + } + } + return conflicts; + } else if ("selectClassroomConflicts".equals(name)) { + String crId = (String) args[0]; + Date start = (Date) args[1]; + Date end = (Date) args[2]; + Long exId = (Long) args[3]; + List conflicts = new ArrayList<>(); + for (TrainLesson l : lessonStore.values()) { + if (exId != null && exId.equals(l.getLessonId())) continue; + if (Integer.valueOf(1).equals(l.getVenueType()) && crId.equals(l.getClassRoomId()) && l.getStartTime().before(end) && l.getEndTime().after(start)) { + ConflictItemVO c = new ConflictItemVO(); + c.setLessonId(l.getLessonId()); + conflicts.add(c); + } + } + return conflicts; + } else if ("selectSiteConflicts".equals(name)) { + String sId = (String) args[0]; + Date start = (Date) args[1]; + Date end = (Date) args[2]; + Long exId = (Long) args[3]; + List conflicts = new ArrayList<>(); + for (TrainLesson l : lessonStore.values()) { + if (exId != null && exId.equals(l.getLessonId())) continue; + if (Integer.valueOf(2).equals(l.getVenueType()) && sId.equals(l.getSiteId()) && l.getStartTime().before(end) && l.getEndTime().after(start)) { + ConflictItemVO c = new ConflictItemVO(); + c.setLessonId(l.getLessonId()); + conflicts.add(c); + } + } + return conflicts; + } else if ("selectPlanConflicts".equals(name)) { + return Collections.emptyList(); + } else if ("selectScheduleLessonsByPlanId".equals(name)) { + List list = new ArrayList<>(); + for (TrainLesson l : lessonStore.values()) { + TimetableLessonItemVO vo = new TimetableLessonItemVO(); + vo.setLessonId(l.getLessonId()); + vo.setPlanCourseId(l.getPlanCourseId()); + vo.setCourseName("高铁列控车载设备维护"); + vo.setTId(l.getTId()); + TrainTeacher t = teacherStore.get(l.getTId()); + if (t != null) vo.setTeacherName(t.gettName()); + vo.setStartTime(l.getStartTime()); + vo.setEndTime(l.getEndTime()); + vo.setVenueType(l.getVenueType()); + if (Integer.valueOf(1).equals(l.getVenueType())) { + vo.setClassRoomId(l.getClassRoomId()); + TrainClassroomInfo cr = classroomStore.get(l.getClassRoomId()); + if (cr != null) { + vo.setClassRoomName(cr.getRoomName()); + vo.setVenueName(cr.getRoomName()); + } + } + list.add(vo); + } + return list; + } + return defaultReturnValue(method); + }); + + // 10. Mock TrainElectronicBoardMapper + boardMapper = createProxy(TrainElectronicBoardMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainElectronicBoardByBoardId".equals(name)) { + return boardStore.get((String) args[0]); + } else if ("selectTrainElectronicBoardList".equals(name)) { + TrainElectronicBoard query = (TrainElectronicBoard) args[0]; + List list = new ArrayList<>(); + for (TrainElectronicBoard b : boardStore.values()) { + if ("2".equals(b.getDelFlag())) continue; + if (query.getBindClassroomId() == null || query.getBindClassroomId().equals(b.getBindClassroomId())) { + list.add(b); + } + } + return list; + } else if ("insertTrainElectronicBoard".equals(name)) { + TrainElectronicBoard b = (TrainElectronicBoard) args[0]; + boardStore.put(b.getBoardId(), b); + return 1; + } else if ("updateTrainElectronicBoard".equals(name)) { + TrainElectronicBoard b = (TrainElectronicBoard) args[0]; + TrainElectronicBoard old = boardStore.get(b.getBoardId()); + if (old != null) { + if (b.getBoardSn() != null) old.setBoardSn(b.getBoardSn()); + if (b.getBindClassroomId() != null) old.setBindClassroomId(b.getBindClassroomId()); + if (b.getDelFlag() != null) old.setDelFlag(b.getDelFlag()); + } + return 1; + } else if ("deleteTrainElectronicBoardByBoardIds".equals(name)) { + String[] ids = (String[]) args[0]; + for (String id : ids) boardStore.remove(id); + return ids.length; + } else if ("logicalDeleteTrainElectronicBoardByBoardIds".equals(name)) { + String[] ids = (String[]) args[0]; + for (String id : ids) { + TrainElectronicBoard b = boardStore.get(id); + if (b != null) b.setDelFlag("2"); + } + return ids.length; + } + return defaultReturnValue(method); + }); + + // 11. Mock TrainClassroomInfoMapper + classroomMapper = createProxy(TrainClassroomInfoMapper.class, (proxy, method, args) -> { + String name = method.getName(); + if ("selectTrainClassroomInfoByClassRoomId".equals(name)) { + return classroomStore.get((String) args[0]); + } + return defaultReturnValue(method); + }); + + // 构建业务 Service 实例 + completionAdapter = new EnrollmentPlanCompletionAdapter(); + setField(completionAdapter, "trainEnrollmentService", enrollmentService); + + planAppService = new PlanAppServiceImpl(planService, Collections.singletonList(completionAdapter)); + setField(planAppService, "planCourseService", planCourseService); + setField(planAppService, "courseService", courseService); + + enrollmentAppService = new EnrollmentAppServiceImpl(); + setField(enrollmentAppService, "trainEnrollmentService", enrollmentService); + setField(enrollmentAppService, "trainEnrollmentMapper", enrollmentMapper); + setField(enrollmentAppService, "planMapper", planMapper); + setField(enrollmentAppService, "studentMapper", studentMapper); + + schedulingAppService = new SchedulingAppServiceImpl(lessonMapper, planMapper, planCourseMapper); + + boardService = new TrainElectronicBoardServiceImpl(); + setField(boardService, "trainElectronicBoardMapper", boardMapper); + + classroomService = new TrainClassroomInfoServiceImpl(); + setField(classroomService, "trainClassroomInfoMapper", classroomMapper); + setField(classroomService, "trainElectronicBoardMapper", boardMapper); + } + + /** + * SCENARIO-01: 完整 Happy Path 业务链 Mock 验证 + */ + @Test + public void testScenario01_HappyPathFullBusinessChain() + { + Date now = new Date(); + Date startTime = new Date(now.getTime() + 3600_000L * 24); + Date endTime = new Date(now.getTime() + 3600_000L * 48); + Date reportDeadline = new Date(startTime.getTime() - 3600_000L * 2); + + // 1. 准备 Teacher + TrainTeacher teacher = new TrainTeacher(); + teacher.settId("T_MOCK_001"); + teacher.settName("王金牌教师"); + teacher.setDelFlag("0"); + teacherStore.put(teacher.gettId(), teacher); + + // 2. 准备 Course + TrainCourse course = new TrainCourse(); + course.setcId("C_MOCK_001"); + course.setcName("高铁列控车载设备维护"); + course.setcCode("CRH-SIG-01"); + course.setStatus(1); + course.setDelFlag("0"); + courseStore.put(course.getcId(), course); + + // 3. 准备 Classroom + TrainClassroomInfo classroom = new TrainClassroomInfo(); + classroom.setClassRoomId("CR_MOCK_001"); + classroom.setRoomName("第1多媒体教室"); + classroom.setCapacity(50L); + classroom.setRoomStatus(1); + classroom.setDelFlag("0"); + classroomStore.put(classroom.getClassRoomId(), classroom); + + // 4. 准备 TrainingSite + TrainTrainingSite site = new TrainTrainingSite(); + site.setSiteId("SITE_MOCK_001"); + site.setSiteName("列控仿真基地"); + site.setSiteStatus(1); + site.setDelFlag("0"); + siteStore.put(site.getSiteId(), site); + + // 5. 准备 Student + TrainStudent student = new TrainStudent(); + student.setsId("STU_MOCK_001"); + student.setsName("张学员"); + student.setStatus(1); + student.setDelFlag("0"); + studentStore.put(student.getsId(), student); + + // 6. 创建 Plan + PlanCreateDTO planDTO = new PlanCreateDTO(); + planDTO.setPlanName("2026年第1期车载列控实训班"); + planDTO.setStartTime(startTime); + planDTO.setEndTime(endTime); + planDTO.setReportDeadline(reportDeadline); + planDTO.setRecruitNum(30L); + String planId = planAppService.createPlan(planDTO, "mock_admin"); + assertNotNull("创建 Plan 必须生成 planId", planId); + + // 7. 添加 PlanCourse + PlanCourseAddDTO pcDTO = new PlanCourseAddDTO(); + pcDTO.setCIds(Collections.singletonList(course.getcId())); + planAppService.configureCourses(planId, pcDTO, "mock_admin"); + List configuredCourses = planAppService.listPlanCourses(planId); + assertEquals(1, configuredCourses.size()); + assertEquals(course.getcId(), configuredCourses.get(0).getCId()); + Long planCourseId = configuredCourses.get(0).getPlanCourseId(); + + // 8. Enrollment 入班 + EnrollmentAddDTO enrollDTO = new EnrollmentAddDTO(); + enrollDTO.setStudentId(student.getsId()); + enrollDTO.setSourceType(1); + enrollDTO.setAccommodationRequired(0); + Long enrollmentId = enrollmentAppService.addEnrollment(planId, enrollDTO, "mock_admin"); + assertNotNull("入班必须生成 enrollmentId", enrollmentId); + + // 9. 创建 Lesson (排课) + Date lessonStart = new Date(startTime.getTime() + 3600_000L); + Date lessonEnd = new Date(startTime.getTime() + 3600_000L * 3); + LessonCreateDTO lessonDTO = new LessonCreateDTO(); + lessonDTO.setPlanCourseId(planCourseId); + lessonDTO.setTId(teacher.gettId()); + lessonDTO.setStartTime(lessonStart); + lessonDTO.setEndTime(lessonEnd); + lessonDTO.setVenueType(1); + lessonDTO.setClassRoomId(classroom.getClassRoomId()); + lessonDTO.setRemark("第一讲：系统架构概览"); + + Long lessonId = schedulingAppService.createLesson(planId, lessonDTO, "mock_admin"); + assertNotNull("创建课次成功生成 lessonId", lessonId); + + // 10. 查询 Timetable 并验证字段 + PlanTimetableVO timetable = schedulingAppService.getPlanTimetable(planId); + assertEquals(planId, timetable.getPlanId()); + assertEquals(1, timetable.getDays().size()); + TimetableDayVO day = timetable.getDays().get(0); + assertEquals(1, day.getLessons().size()); + TimetableLessonItemVO lessonItem = day.getLessons().get(0); + assertEquals(lessonId, lessonItem.getLessonId()); + assertEquals(course.getcName(), lessonItem.getCourseName()); + assertEquals(teacher.gettName(), lessonItem.getTeacherName()); + assertEquals(classroom.getRoomName(), lessonItem.getClassRoomName()); + + // 11. 完成 Plan + planAppService.completePlan(planId, "mock_admin"); + + // 12. 验证 Enrollment 状态自动变更为 4 且 complete_time 非空 + EnrollmentQuery eq = new EnrollmentQuery(); + List enrollList = enrollmentAppService.listEnrollments(planId, eq); + assertEquals(1, enrollList.size()); + assertEquals(Integer.valueOf(4), enrollList.get(0).getEnrollmentStatus()); + assertNotNull(enrollList.get(0).getCompleteTime()); + } + + /** + * SCENARIO-02: Enrollment 异常规则与学员主档状态严格区分 + */ + @Test + public void testScenario02_EnrollmentValidationRules() + { + Date now = new Date(); + Date startTime = new Date(now.getTime() + 3600_000L * 24); + Date endTime = new Date(now.getTime() + 3600_000L * 48); + + // 准备一个容量为 10 人的 Plan 测试重复添加 + TrainClassPlan plan = new TrainClassPlan(); + plan.setPlanId("PLAN_CAP_01"); + plan.setPlanName("微型精英班"); + plan.setStartTime(startTime); + plan.setEndTime(endTime); + plan.setRecruitNum(10L); + plan.setPlanStatus(1); + plan.setDelFlag("0"); + planStore.put(plan.getPlanId(), plan); + + // 准备学员 1: 正常 (status=1) + TrainStudent normalStudent = new TrainStudent(); + normalStudent.setsId("STU_NORMAL"); + normalStudent.setsName("正常学员"); + normalStudent.setStatus(1); + normalStudent.setDelFlag("0"); + studentStore.put(normalStudent.getsId(), normalStudent); + + // 准备学员 2: 停用 (status=0) + TrainStudent disabledStudent = new TrainStudent(); + disabledStudent.setsId("STU_DISABLED"); + disabledStudent.setsName("停用学员"); + disabledStudent.setStatus(0); + disabledStudent.setDelFlag("0"); + studentStore.put(disabledStudent.getsId(), disabledStudent); + + // 1. 尝试添加 status=0 停用学员 -> 必须 reject (StudentErrorCode.STUDENT_NOT_FOUND) + try + { + EnrollmentAddDTO dto = new EnrollmentAddDTO(); + dto.setStudentId(disabledStudent.getsId()); + dto.setSourceType(1); + dto.setAccommodationRequired(0); + enrollmentAppService.addEnrollment(plan.getPlanId(), dto, "admin"); + fail("停用学员应当被阻断入班"); + } + catch (ServiceException e) + { + assertEquals(StudentErrorCode.STUDENT_NOT_FOUND, e.getCode().intValue()); + } + + // 2. 尝试添加不存在的学员 -> 必须 reject + try + { + EnrollmentAddDTO dto = new EnrollmentAddDTO(); + dto.setStudentId("NON_EXIST_STU"); + dto.setSourceType(1); + dto.setAccommodationRequired(0); + enrollmentAppService.addEnrollment(plan.getPlanId(), dto, "admin"); + fail("不存在学员应当被阻断入班"); + } + catch (ServiceException e) + { + assertEquals(StudentErrorCode.STUDENT_NOT_FOUND, e.getCode().intValue()); + } + + // 3. 添加 status=1 正常学员 -> 必须 success + EnrollmentAddDTO successDto = new EnrollmentAddDTO(); + successDto.setStudentId(normalStudent.getsId()); + successDto.setSourceType(1); + successDto.setAccommodationRequired(0); + Long eId = enrollmentAppService.addEnrollment(plan.getPlanId(), successDto, "admin"); + assertNotNull(eId); + + // 4. 重复添加同一学员到同一 Plan -> 必须报 40030 ENROLLMENT_DUPLICATED + try + { + enrollmentAppService.addEnrollment(plan.getPlanId(), successDto, "admin"); + fail("重复添加应当报 40030"); + } + catch (ServiceException e) + { + assertEquals(EnrollmentErrorCode.ENROLLMENT_DUPLICATED, e.getCode().intValue()); + } + + // 5. 准备容量仅为 1 人的独立 Plan，测试超出 capacity 报 40031 RECRUIT_LIMIT_EXCEEDED + TrainClassPlan limitPlan = new TrainClassPlan(); + limitPlan.setPlanId("PLAN_CAP_LIMIT_01"); + limitPlan.setPlanName("单人专属班"); + limitPlan.setStartTime(startTime); + limitPlan.setEndTime(endTime); + limitPlan.setRecruitNum(1L); + limitPlan.setPlanStatus(1); + limitPlan.setDelFlag("0"); + planStore.put(limitPlan.getPlanId(), limitPlan); + + // 填满 limitPlan + EnrollmentAddDTO fillDto = new EnrollmentAddDTO(); + fillDto.setStudentId(normalStudent.getsId()); + fillDto.setSourceType(1); + fillDto.setAccommodationRequired(0); + enrollmentAppService.addEnrollment(limitPlan.getPlanId(), fillDto, "admin"); + + TrainStudent secondStudent = new TrainStudent(); + secondStudent.setsId("STU_NORMAL_2"); + secondStudent.setsName("第二名正常学员"); + secondStudent.setStatus(1); + secondStudent.setDelFlag("0"); + studentStore.put(secondStudent.getsId(), secondStudent); + + try + { + EnrollmentAddDTO dto2 = new EnrollmentAddDTO(); + dto2.setStudentId(secondStudent.getsId()); + dto2.setSourceType(1); + dto2.setAccommodationRequired(0); + enrollmentAppService.addEnrollment(limitPlan.getPlanId(), dto2, "admin"); + fail("超出招生人数应当报 40031"); + } + catch (ServiceException e) + { + assertEquals(EnrollmentErrorCode.RECRUIT_LIMIT_EXCEEDED, e.getCode().intValue()); + } + } + + /** + * SCENARIO-03: 排课冲突预检 (TEACHER 冲突 vs CLASSROOM/SITE/PLAN Warning) 与不阻断保存 + */ + @Test + public void testScenario03_SchedulingConflictWarningAndHardBlock() + { + Date now = new Date(); + Date startTime = new Date(now.getTime() + 3600_000L * 24); + Date endTime = new Date(now.getTime() + 3600_000L * 48); + + TrainClassPlan plan = new TrainClassPlan(); + plan.setPlanId("PLAN_SCH_01"); + plan.setPlanName("排课测试班"); + plan.setStartTime(startTime); + plan.setEndTime(endTime); + plan.setPlanStatus(1); + plan.setDelFlag("0"); + planStore.put(plan.getPlanId(), plan); + + TrainTeacher teacher = new TrainTeacher(); + teacher.settId("T_SCH_01"); + teacher.settName("李教员"); + teacher.setDelFlag("0"); + teacherStore.put(teacher.gettId(), teacher); + + TrainClassroomInfo classroom = new TrainClassroomInfo(); + classroom.setClassRoomId("CR_SCH_01"); + classroom.setRoomName("201教室"); + classroom.setDelFlag("0"); + classroomStore.put(classroom.getClassRoomId(), classroom); + + TrainTrainingSite site = new TrainTrainingSite(); + site.setSiteId("SITE_SCH_01"); + site.setSiteName("接触网演练场"); + site.setDelFlag("0"); + siteStore.put(site.getSiteId(), site); + + TrainPlanCourse pc = new TrainPlanCourse(); + pc.setPlanCourseId(101L); + pc.setPlanId(plan.getPlanId()); + pc.setCId("C_01"); + planCourseStore.put(pc.getPlanCourseId(), pc); + + Date lessonStart1 = new Date(startTime.getTime() + 3600_000L); + Date lessonEnd1 = new Date(startTime.getTime() + 3600_000L * 3); + + // 1. 正常无冲突课次 + LessonConflictCheckDTO checkDTO = new LessonConflictCheckDTO(); + checkDTO.setPlanId(plan.getPlanId()); + checkDTO.setTId(teacher.gettId()); + checkDTO.setVenueType(1); + checkDTO.setClassRoomId(classroom.getClassRoomId()); + checkDTO.setStartTime(lessonStart1); + checkDTO.setEndTime(lessonEnd1); + + LessonConflictVO checkResult = schedulingAppService.checkConflict(checkDTO); + assertFalse("正常课次无冲突", checkResult.getHasConflict()); + assertEquals("NONE", checkResult.getConflictType()); + + // 2. 正常保存课次 1 + LessonCreateDTO createDTO1 = new LessonCreateDTO(); + createDTO1.setPlanCourseId(pc.getPlanCourseId()); + createDTO1.setTId(teacher.gettId()); + createDTO1.setVenueType(1); + createDTO1.setClassRoomId(classroom.getClassRoomId()); + createDTO1.setStartTime(lessonStart1); + createDTO1.setEndTime(lessonEnd1); + Long lessonId1 = schedulingAppService.createLesson(plan.getPlanId(), createDTO1, "admin"); + assertNotNull(lessonId1); + + // 3. 教师时间重叠冲突 + LessonConflictCheckDTO teacherConflictDTO = new LessonConflictCheckDTO(); + teacherConflictDTO.setPlanId("ANOTHER_PLAN"); + teacherConflictDTO.setTId(teacher.gettId()); + teacherConflictDTO.setVenueType(1); + teacherConflictDTO.setClassRoomId("ANOTHER_CR"); + teacherConflictDTO.setStartTime(new Date(lessonStart1.getTime() + 1800_000L)); + teacherConflictDTO.setEndTime(new Date(lessonEnd1.getTime() + 1800_000L)); + + LessonConflictVO teacherConflictRes = schedulingAppService.checkConflict(teacherConflictDTO); + assertTrue("同教师时间重叠必须检测出冲突", teacherConflictRes.getHasConflict()); + assertEquals("TEACHER", teacherConflictRes.getConflictType()); + + // 4. 教室重叠 Warning：check-conflict 提示 CLASSROOM + LessonConflictCheckDTO roomConflictDTO = new LessonConflictCheckDTO(); + roomConflictDTO.setPlanId("PLAN_ROOM_WARN"); + roomConflictDTO.setTId("ANOTHER_TEACHER"); + roomConflictDTO.setVenueType(1); + roomConflictDTO.setClassRoomId(classroom.getClassRoomId()); + roomConflictDTO.setStartTime(lessonStart1); + roomConflictDTO.setEndTime(lessonEnd1); + + LessonConflictVO roomConflictRes = schedulingAppService.checkConflict(roomConflictDTO); + assertTrue(roomConflictRes.getHasConflict()); + assertEquals("CLASSROOM", roomConflictRes.getConflictType()); + + // 5. 验证 Scheduling Hard Blocks + // 5.1 invalid time (startTime >= endTime) -> 40010 PLAN_TIME_INVALID + try + { + LessonCreateDTO invalidTimeDTO = new LessonCreateDTO(); + invalidTimeDTO.setPlanCourseId(pc.getPlanCourseId()); + invalidTimeDTO.setTId(teacher.gettId()); + invalidTimeDTO.setVenueType(1); + invalidTimeDTO.setClassRoomId(classroom.getClassRoomId()); + invalidTimeDTO.setStartTime(lessonEnd1); + invalidTimeDTO.setEndTime(lessonStart1); + schedulingAppService.createLesson(plan.getPlanId(), invalidTimeDTO, "admin"); + fail("倒置时间必须硬阻断 40010"); + } + catch (ServiceException e) + { + assertEquals(PlanErrorCode.PLAN_TIME_INVALID, e.getCode().intValue()); + } + + // 5.2 venue XOR invalid (venueType=1 却传了 siteId) -> reject VENUE_CONFIG_INVALID + try + { + LessonCreateDTO invalidVenueDTO = new LessonCreateDTO(); + invalidVenueDTO.setPlanCourseId(pc.getPlanCourseId()); + invalidVenueDTO.setTId(teacher.gettId()); + invalidVenueDTO.setVenueType(1); + invalidVenueDTO.setClassRoomId(classroom.getClassRoomId()); + invalidVenueDTO.setSiteId(site.getSiteId()); + invalidVenueDTO.setStartTime(new Date(lessonEnd1.getTime() + 1000)); + invalidVenueDTO.setEndTime(new Date(lessonEnd1.getTime() + 5000)); + schedulingAppService.createLesson(plan.getPlanId(), invalidVenueDTO, "admin"); + fail("场地互斥校验失败必须硬阻断"); + } + catch (ServiceException e) + { + assertEquals(LessonErrorCode.VENUE_CONFIG_INVALID, e.getCode().intValue()); + } + + // 5.3 cross-plan PlanCourse -> reject 40420 + TrainPlanCourse otherPlanCourse = new TrainPlanCourse(); + otherPlanCourse.setPlanCourseId(999L); + otherPlanCourse.setPlanId("OTHER_PLAN_ID"); + planCourseStore.put(otherPlanCourse.getPlanCourseId(), otherPlanCourse); + try + { + LessonCreateDTO crossPlanDTO = new LessonCreateDTO(); + crossPlanDTO.setPlanCourseId(otherPlanCourse.getPlanCourseId()); + crossPlanDTO.setTId(teacher.gettId()); + crossPlanDTO.setVenueType(1); + crossPlanDTO.setClassRoomId(classroom.getClassRoomId()); + crossPlanDTO.setStartTime(new Date(lessonEnd1.getTime() + 1000)); + crossPlanDTO.setEndTime(new Date(lessonEnd1.getTime() + 5000)); + schedulingAppService.createLesson(plan.getPlanId(), crossPlanDTO, "admin"); + fail("跨计划配置课程排课必须硬阻断"); + } + catch (ServiceException e) + { + assertEquals(40420, e.getCode().intValue()); + } + + // 5.4 锁定计划 (planStatus=2) -> 40012 PLAN_STATUS_LOCKED + plan.setPlanStatus(2); + try + { + LessonCreateDTO lockedPlanDTO = new LessonCreateDTO(); + lockedPlanDTO.setPlanCourseId(pc.getPlanCourseId()); + lockedPlanDTO.setTId(teacher.gettId()); + lockedPlanDTO.setVenueType(1); + lockedPlanDTO.setClassRoomId(classroom.getClassRoomId()); + lockedPlanDTO.setStartTime(new Date(lessonEnd1.getTime() + 1000)); + lockedPlanDTO.setEndTime(new Date(lessonEnd1.getTime() + 5000)); + schedulingAppService.createLesson(plan.getPlanId(), lockedPlanDTO, "admin"); + fail("已结训计划排课必须硬阻断 40012"); + } + catch (ServiceException e) + { + assertEquals(PlanErrorCode.PLAN_STATUS_LOCKED, e.getCode().intValue()); + } + } + + /** + * SCENARIO-04: Electronic Board 绑定与 Classroom Detail / Timetable 映射规则 + */ + @Test + public void testScenario04_ElectronicBoardRules() + { + // 1. 创建 Board 默认 status=0，若未提供 boardId 则自动生成 UUID + TrainElectronicBoard board1 = new TrainElectronicBoard(); + board1.setBoardSn("SN_BOARD_001"); + board1.setBindClassroomId("CR_BOARD_TEST"); + int inserted1 = boardService.insertTrainElectronicBoard(board1); + assertEquals(1, inserted1); + assertNotNull("创建电子班牌自动生成 UUID", board1.getBoardId()); + assertEquals(Integer.valueOf(0), board1.getBoardStatus()); + + // 2. 状态保护：直接 update 尝试篡改 status 和 lastHeartbeat 将被保护不覆盖 + TrainElectronicBoard updateDto = new TrainElectronicBoard(); + updateDto.setBoardId(board1.getBoardId()); + updateDto.setBoardSn("SN_BOARD_001_UPDATED"); + updateDto.setBoardStatus(99); + boardService.updateTrainElectronicBoard(updateDto); + TrainElectronicBoard refreshed1 = boardMapper.selectTrainElectronicBoardByBoardId(board1.getBoardId()); + assertEquals(Integer.valueOf(0), refreshed1.getBoardStatus()); + + // 3. Classroom Detail 对应 0 / 1 / N 块班牌验证 + TrainClassroomInfo cr = new TrainClassroomInfo(); + cr.setClassRoomId("CR_BOARD_TEST"); + cr.setRoomName("班牌测试教室"); + cr.setCapacity(40L); + classroomStore.put(cr.getClassRoomId(), cr); + + // 3.1 绑定 1 块板时: Classroom Detail 返回 1 块 + ClassroomDetailVO detail1 = classroomService.selectClassroomDetailByClassRoomId(cr.getClassRoomId()); + assertEquals(1, detail1.getBoards().size()); + assertEquals("SN_BOARD_001_UPDATED", detail1.getBoards().get(0).getBoardSn()); + + // 3.2 增加绑定第 2 块板时: Classroom Detail 返回 2 块 + TrainElectronicBoard board2 = new TrainElectronicBoard(); + board2.setBoardSn("SN_BOARD_002"); + board2.setBindClassroomId(cr.getClassRoomId()); + boardService.insertTrainElectronicBoard(board2); + + ClassroomDetailVO detail2 = classroomService.selectClassroomDetailByClassRoomId(cr.getClassRoomId()); + assertEquals(2, detail2.getBoards().size()); + + // 3.3 逻辑删除 (del_flag=2) + boardService.deleteTrainElectronicBoardByBoardIds(new String[]{board1.getBoardId(), board2.getBoardId()}, "admin"); + ClassroomDetailVO detailAfterDel = classroomService.selectClassroomDetailByClassRoomId(cr.getClassRoomId()); + assertEquals("逻辑删除后教室详情中的 boards 为空", 0, detailAfterDel.getBoards().size()); + } + + /** + * SCENARIO-05: Plan Completion 联动结训与已退训学员历史保护 + */ + @Test + public void testScenario05_PlanCompletionLifecycleAndHistoryRetention() + { + Date now = new Date(); + Date startTime = new Date(now.getTime() - 3600_000L * 48); + Date endTime = new Date(now.getTime() - 3600_000L * 24); + + // 准备 Plan + TrainClassPlan plan = new TrainClassPlan(); + plan.setPlanId("PLAN_COMP_01"); + plan.setPlanName("结训保护测试班"); + plan.setStartTime(startTime); + plan.setEndTime(endTime); + plan.setPlanStatus(1); + plan.setDelFlag("0"); + planStore.put(plan.getPlanId(), plan); + + // 准备 3 名学员 + TrainEnrollment e1 = new TrainEnrollment(); + e1.setEnrollmentId(1001L); + e1.setPlanId(plan.getPlanId()); + e1.setStudentId("S_01"); + e1.setEnrollmentStatus(0); // 待报到 + enrollmentStore.put(e1.getEnrollmentId(), e1); + + TrainEnrollment e2 = new TrainEnrollment(); + e2.setEnrollmentId(1002L); + e2.setPlanId(plan.getPlanId()); + e2.setStudentId("S_02"); + e2.setEnrollmentStatus(1); // 已报到 + enrollmentStore.put(e2.getEnrollmentId(), e2); + + TrainEnrollment e3 = new TrainEnrollment(); + e3.setEnrollmentId(1003L); + e3.setPlanId(plan.getPlanId()); + e3.setStudentId("S_03"); + e3.setEnrollmentStatus(3); // 退训 + enrollmentStore.put(e3.getEnrollmentId(), e3); + + // 执行正式结训 + planAppService.completePlan(plan.getPlanId(), "admin"); + + // 验证 Plan 状态为 2 (已结束) + TrainClassPlan finishedPlan = planService.selectTrainClassPlanByPlanId(plan.getPlanId()); + assertEquals(Integer.valueOf(2), finishedPlan.getPlanStatus()); + + // 验证活动学员 e1, e2 状态变为 4 且 complete_time 赋值 + assertEquals(Integer.valueOf(4), e1.getEnrollmentStatus()); + assertNotNull(e1.getCompleteTime()); + + assertEquals(Integer.valueOf(4), e2.getEnrollmentStatus()); + assertNotNull(e2.getCompleteTime()); + + // 验证已退训学员 e3 状态保持为 3，complete_time 未被错误改写 + assertEquals(Integer.valueOf(3), e3.getEnrollmentStatus()); + assertNull(e3.getCompleteTime()); + } + + private static void setField(Object target, String fieldName, Object value) throws Exception + { + Field f = target.getClass().getDeclaredField(fieldName); + f.setAccessible(true); + f.set(target, value); + } + + @SuppressWarnings("unchecked") + private static T createProxy(Class intf, InvocationHandler handler) + { + return (T) Proxy.newProxyInstance(intf.getClassLoader(), new Class[]{intf}, handler); + } + + private static Object defaultReturnValue(Method method) + { + Class returnType = method.getReturnType(); + if (returnType.equals(void.class)) return null; + if (returnType.equals(boolean.class)) return false; + if (returnType.equals(int.class)) return 0; + if (returnType.equals(long.class)) return 0L; + if (returnType.equals(List.class)) return Collections.emptyList(); + return null; + } +} diff --git a/docs/_meta/core-business-test-matrix.md b/docs/_meta/core-business-test-matrix.md new file mode 100644 index 000000000..f8baef3f2 --- /dev/null +++ b/docs/_meta/core-business-test-matrix.md @@ -0,0 +1,98 @@ +# RailwaySystem 核心业务场景集成测试矩阵 (Core Business Test Matrix) + +本文档整理了 RailwaySystem 核心业务场景自动化测试套件的覆盖范围、验证层级（Mock单元测试 vs. 真实Kingbase/API集成Gate）以及当前验证结果。本材料面向研发阶段汇报与质量门禁审计。 + +> **基线信息**： +> - 开发分支：`integration/wave2-20260914` +> - 基线 HEAD：`c04992a8017de78c6b4a43592ae9941e85a9fea9` +> - 最新测试运行编号：`QA_W2_20260914221336` +> - 自动化测试架构：离线 Mock 测试（`CoreBusinessScenarioMockTest`） + 显式真实集成门禁（`scripts/qa/run-core-business-scenario.sh`） + +--- + +## 1. 核心业务场景测试矩阵 + +| 业务模块 | 测试场景 | API / 接口 | 数据库/核心逻辑断言 | 验证层级 (Mock / Real) | 当前结果 | +| :--- | :--- | :--- | :--- | :--- | :--- | +| **Teacher (教师)** | 教师档案创建与可用性验证 | `POST /train/teacher`
`GET /train/teacher/list` | 教师主键 `t_id` 持久化，姓名、职称、联系方式正确落库 | Mock & Real | **PASS** | +| **Course (课程)** | 基础课程创建与状态维护 | `POST /train/course`
`GET /train/course/list` | 课程主键 `c_id`、编码与课时正确落库，`status=1` | Mock & Real | **PASS** | +| **Classroom (教室)** | 理论教室资源创建与容量设定 | `POST /train/classroom`
`GET /train/classroom/{id}` | 教室主键 `class_room_id` 与容量有效持久化 | Mock & Real | **PASS** | +| **TrainingSite (实训场地)** | 演练实训基地创建与容量校验 | `POST /train/training-site`
`GET /train/training-site/list` | 自动生成32位UUID主键，必填容量非空校验，状态可用 | Mock & Real | **PASS** | +| **Student (学员)** | 学员基础档案建立与主档状态区分 | `POST /train/student`
`GET /train/student/list` | 32位UUID主键，学员主档状态独立维护 (`1:正常`, `0:停用`) | Mock & Real | **PASS** | +| **Plan (培训计划)** | 创建培训班计划与周期时间合法性 | `POST /train/plans`
`GET /train/plans/{id}` | 生成32位UUID，初始状态强制为 `0:草稿`，起止时间校验 | Mock & Real | **PASS** | +| **PlanCourse (计划课程)** | 培训班绑定课程及关联关系查询 | `POST /train/plans/{id}/courses`
`GET /train/plans/{id}/courses` | 生成自增 `plan_course_id`，外键关联一致性 | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 正常学员入班 (Happy Path) | `POST /train/plans/{id}/enrollments` | 生成自增 `enrollment_id`，参训状态初始为 `0:待报到` | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 同一计划重复报名校验 | `POST /train/plans/{id}/enrollments` | 业务错误码 `40030: ENROLLMENT_ALREADY_EXISTS`，数据库唯一约束保证 `duplicate enrollment = 0` | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 计划招生容量上限超限拦截 | `POST /train/plans/{id}/enrollments` | 业务错误码 `40031: ENROLLMENT_CAPACITY_EXCEEDED`，不允许超额入班 | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 无效学员入班拦截 | `POST /train/plans/{id}/enrollments` | 业务错误码 `40402: STUDENT_NOT_FOUND`，拒绝非法入班 | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 停用状态学员 (`status=0`) 入班拦截 | `POST /train/plans/{id}/enrollments` | 业务错误码 `40402: STUDENT_DISABLED`，严禁停用学员报名 | Mock & Real | **PASS** | +| **Enrollment (学员报名)** | 报到/请假/退训参训状态维护 | `PUT /train/enrollments/{id}/status` | 参训状态独立流转 (`0:待报到`, `1:已报到`, `2:请假`, `3:退训`, `4:已完成`) | Mock & Real | **PASS** | +| **Scheduling (排课)** | 正常排课课次冲突预检 | `POST /train/lessons/check-conflict` | 返回 `hasConflict=false, conflictType=NONE` | Mock & Real | **PASS** | +| **Scheduling (排课)** | 教师时间重叠冲突检测 | `POST /train/lessons/check-conflict` | 返回 `hasConflict=true, conflictType=TEACHER` | Mock & Real | **PASS** | +| **Scheduling (排课)** | 教室资源重叠冲突检测 (Warning) | `POST /train/lessons/check-conflict` | 返回 `hasConflict=true, conflictType=CLASSROOM`，Warning级别 | Mock & Real | **PASS** | +| **Scheduling (排课)** | 实训场地重叠冲突检测 (Warning) | `POST /train/lessons/check-conflict` | 返回 `hasConflict=true, conflictType=SITE`，Warning级别 | Mock & Real | **PASS** | +| **Scheduling (排课)** | 计划内课次重叠冲突检测 (Warning) | `POST /train/lessons/check-conflict` | 返回 `hasConflict=true, conflictType=PLAN_OVERLAP`，Warning级别 | Mock & Real | **PASS** | +| **Scheduling (排课)** | Warning非硬阻断验证 | `POST /train/plans/{id}/lessons` | Warning不阻断保存，禁止任何 `force/override` 参数，标准POST成功保存 | Mock & Real | **PASS** | +| **Scheduling (排课)** | 起止时间非法硬阻断 | `POST /train/plans/{id}/lessons` | 业务错误码 `40010: LESSON_TIME_INVALID` (startTime >= endTime) | Mock & Real | **PASS** | +| **Scheduling (排课)** | 计划锁定/已结训硬阻断 | `POST /train/plans/{id}/lessons` | 业务错误码 `40012: PLAN_LOCKED`，已结束计划禁止变更课次 | Mock & Real | **PASS** | +| **Scheduling (排课)** | 场地 XOR 互斥硬阻断 | `POST /train/plans/{id}/lessons` | 场地二选一非法时强行拦截，DB层面 `invalid venue XOR = 0` | Mock & Real | **PASS** | +| **Scheduling (排课)** | 跨计划关联课程硬阻断 | `POST /train/plans/{id}/lessons` | 业务错误码 `40420: PLAN_COURSE_NOT_IN_PLAN`，禁止错链 | Mock & Real | **PASS** | +| **Scheduling (排课)** | 关键资源不存在硬阻断 | `POST /train/plans/{id}/lessons` | 业务错误码 `40401/40403/40410`，拒绝孤立外键记录 | Mock & Real | **PASS** | +| **Timetable (课表)** | 课表视图与聚合字段显示 | `GET /train/plans/{id}/timetable` | 正确映射 `courseName`, `teacherName`, `venueName` | Mock & Real | **PASS** | +| **ElectronicBoard (电子班牌)** | 班牌创建与主键UUID规则 | `POST /train/board`
`GET /train/board/list` | 后端自动生成32位UUID，默认在线状态 `board_status=0` | Mock & Real | **PASS** | +| **ElectronicBoard (电子班牌)** | 教室详情与班牌绑定列表映射 | `GET /train/classroom/{id}` | 0块板返回空列表，1块板返回长度1，N块板返回长度N | Mock & Real | **PASS** | +| **ElectronicBoard (电子班牌)** | 课表单板/多板 `boardSn` 降级规则 | `GET /train/plans/{id}/timetable` | 0块板返回null，恰好1块返回对应SN，大于1块降级为null | Mock & Real | **PASS** | +| **ElectronicBoard (电子班牌)** | 班牌逻辑删除持久化保障 | `DELETE /train/board/{id}` | `del_flag='2'` 逻辑删除，正式接口不可查，DB断言确认存在 | Mock & Real | **PASS** | +| **Plan Completion (结训联动)** | 计划结训与活动学员状态自动流转 | `POST /train/plans/{id}/complete` | Plan状态变更为 `2:已结束`；活动学员 (`status=0/1`) 状态自动变更为 `4:已完成`，且 `complete_time != null` 真实写入 | Mock & Real | **PASS** | +| **Plan Completion (结训联动)** | 历史退训学员状态防覆盖保护 | `POST /train/plans/{id}/complete`
`GET /train/enrollments/{id}` | 历史已退训学员 (`status=3`) 状态保持为 3，`complete_time` 保持为 null，杜绝误覆盖 | Mock & Real | **PASS** | + +--- + +## 2. Legacy Analytics 模块边界说明 + +根据研发分工规范，Codex 正在独立重构 Legacy Analytics 分析统计模块，本测试套件严格执行架构隔离，**完全未碰、严禁修改或测试**以下四个模块，标记为 `PENDING_V2_CONTRACT`： + +| 模块名称 | 职责描述 | 当前标记 | 规划接入时机 | +| :--- | :--- | :--- | :--- | +| **Report (报表管理)** | 培训数据统计与导出报表 | `PENDING_V2_CONTRACT` | 等待 Codex V2 契约稳定合并后扩展集成 | +| **Checkin (签到考勤)** | 学员人脸识别与打卡明细统计 | `PENDING_V2_CONTRACT` | 等待 Codex V2 契约稳定合并后扩展集成 | +| **Duration (学时统计)** | 学员课时完成度与学时汇总 | `PENDING_V2_CONTRACT` | 等待 Codex V2 契约稳定合并后扩展集成 | +| **Portrait (学员画像)** | 学员综合能力多维能力画像 | `PENDING_V2_CONTRACT` | 等待 Codex V2 契约稳定合并后扩展集成 | + +--- + +## 3. Kingbase 数据库只读安全断言规范 + +集成门禁每次运行均调用独立的只读断言器 `scripts.qa.DbAssertionChecker`，直接在 Kingbase 真实数据库实例上校验以下全局一致性与业务正确性指标： + +1. **`duplicate enrollment = 0`**：没有任何重复学员出现在同一计划中。 +2. **`orphan lesson = 0`**：所有课次均正确关联有效的培训计划课程。 +3. **`orphan enrollment = 0`**：所有报名记录均归属于真实存在的培训计划。 +4. **`invalid venue XOR = 0`**：所有课次的场地配置严格满足教室/实训场地二选一互斥，无同时为空或同时设置的情况。 +5. **`del_flag = '2'`**：电子班牌逻辑删除后底层标志位规范设置为 `'2'`。 +6. **`Plan completion 状态与时间写入一致性`**：结训后学员参训状态正确流转至 4 且结训时间真实写入。 +7. **`退训状态历史保护`**：已退训记录未被结训批量任务破坏。 + +--- + +## 4. 测试套件门禁执行方式 + +### 4.1 普通离线单元测试（无 DB 依赖） +开发人员日常或 CI 极速离线门禁： +```bash +mvn test +``` +- 测试用例总数：**123 个** (包含 ruoyi-train 113 个，ruoyi-admin 10 个)。 +- 执行状态：**ALL PASS (0 Failures, 0 Errors, 0 Skipped)**。 +- 执行耗时：约 3~4 秒，完全不依赖任何外部端口与数据库。 + +### 4.2 核心业务端到端集成测试套件（真实 Gate） +阶段汇报、发布审计或环境准入门禁： +```bash +bash scripts/qa/run-core-business-scenario.sh +``` +- 自动前置预检 Kingbase 隧道 (`127.0.0.1:4321`) 与后端服务。 +- 自动生成批次隔离编号 `RUN_ID=QA_W2_`。 +- 认证信息与数据库连接串通过环境变量或安全配置注入，零凭据泄露。 +- 运行后在 `/tmp/railwaysystem-qa//` 生成完整报告套件（`summary.md`, `api-results.json`, `db-assertions.json`, `created-resources.json`, `cleanup-report.json`）。 +- 测试完毕后严格按照本次记录的精确主键 ID 顺序安全回滚清理，保障数据库零脏数据污染。 diff --git a/scripts/qa/DbAssertionChecker.java b/scripts/qa/DbAssertionChecker.java new file mode 100644 index 000000000..79d661159 --- /dev/null +++ b/scripts/qa/DbAssertionChecker.java @@ -0,0 +1,302 @@ +package scripts.qa; + +import java.io.File; +import java.io.FileWriter; +import java.nio.file.Files; +import java.nio.file.Paths; +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.Statement; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +/** + * Kingbase 数据库只读安全断言执行器。 + * 密码绝不硬编码，绝不输出到日志或报告中。 + */ +public class DbAssertionChecker { + + public static void main(String[] args) { + if (args.length == 0) { + System.err.println("Usage: java DbAssertionChecker "); + System.err.println(" or: java DbAssertionChecker --cleanup "); + System.exit(1); + } + + if ("--cleanup".equals(args[0])) { + if (args.length < 2) { + System.err.println("Missing resources json path for cleanup"); + System.exit(1); + } + executeExactIdCleanup(args[1]); + return; + } + + if ("--disable-student".equals(args[0])) { + if (args.length < 2) { + System.err.println("Missing student id"); + System.exit(1); + } + disableStudent(args[1]); + return; + } + + if (args.length < 2) { + System.err.println("Usage: java DbAssertionChecker "); + System.exit(1); + } + + String resourcesPath = args[0]; + String outputPath = args[1]; + + // 解析密码：优先从环境变量，其次从 RuoYi-Vue/ruoyi-admin/src/main/resources/application-druid.yml 读取 + String dbUrl = "jdbc:kingbase8://127.0.0.1:4321/training?currentSchema=public,sys_catalog&useUnicode=true&characterEncoding=utf8"; + String dbUser = "kingbase"; + String dbPassword = resolveDbPassword(); + + List> assertions = new ArrayList<>(); + boolean allPassed = true; + + try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword)) { + // 确保 search_path + try (Statement s = conn.createStatement()) { + s.execute("SET search_path TO public, sys_catalog"); + } + + // 读取 created-resources.json 内容用于参数化断言 + String resourcesJson = new String(Files.readAllBytes(Paths.get(resourcesPath)), "UTF-8"); + + // 1. 全局数据一致性断言：无重复 enrollment (duplicate enrollment = 0) + int duplicateEnrollments = queryCount(conn, + "SELECT COUNT(*) FROM (SELECT plan_id, student_id FROM train_enrollment GROUP BY plan_id, student_id HAVING COUNT(*) > 1) t"); + boolean dupPass = duplicateEnrollments == 0; + assertions.add(createAssertion("CONSISTENCY-01", "重复报名关系数为0", "duplicate_enrollment_count == 0", "actual: " + duplicateEnrollments, dupPass)); + if (!dupPass) allPassed = false; + + // 2. 全局数据一致性断言：无孤立课次 (orphan lesson = 0) + int orphanLessons = queryCount(conn, + "SELECT COUNT(*) FROM train_lesson l LEFT JOIN train_plan_course pc ON l.plan_course_id = pc.plan_course_id WHERE pc.plan_course_id IS NULL"); + boolean orphanLessonPass = orphanLessons == 0; + assertions.add(createAssertion("CONSISTENCY-02", "无孤立课次(关联无效课程)", "orphan_lesson_count == 0", "actual: " + orphanLessons, orphanLessonPass)); + if (!orphanLessonPass) allPassed = false; + + // 3. 全局数据一致性断言：无孤立报名 (orphan enrollment = 0) + int orphanEnrollments = queryCount(conn, + "SELECT COUNT(*) FROM train_enrollment e LEFT JOIN train_class_plan p ON e.plan_id = p.plan_id WHERE p.plan_id IS NULL"); + boolean orphanEnrollPass = orphanEnrollments == 0; + assertions.add(createAssertion("CONSISTENCY-03", "无孤立报名记录(关联无效计划)", "orphan_enrollment_count == 0", "actual: " + orphanEnrollments, orphanEnrollPass)); + if (!orphanEnrollPass) allPassed = false; + + // 4. 全局数据一致性断言：场地互斥合法性 (invalid venue XOR = 0) + int invalidVenueXor = queryCount(conn, + "SELECT COUNT(*) FROM train_lesson WHERE (venue_type = 1 AND (class_room_id IS NULL OR site_id IS NOT NULL)) OR (venue_type = 2 AND (site_id IS NULL OR class_room_id IS NOT NULL))"); + boolean venueXorPass = invalidVenueXor == 0; + assertions.add(createAssertion("CONSISTENCY-04", "场地二选一互斥合法性", "invalid_venue_xor_count == 0", "actual: " + invalidVenueXor, venueXorPass)); + if (!venueXorPass) allPassed = false; + + // 5. 业务场景断言：检查删除的 Board 其 del_flag 值为 '2' (逻辑删除) + int logicDeletedBoards = queryCount(conn, + "SELECT COUNT(*) FROM train_electronic_board WHERE del_flag = '2'"); + boolean logicDelPass = logicDeletedBoards >= 1; + assertions.add(createAssertion("SCENARIO-BOARD-01", "电子班牌逻辑删除标记del_flag=2", "del_flag == '2'", "actual count: " + logicDeletedBoards, logicDelPass)); + if (!logicDelPass) allPassed = false; + + // 6. 业务场景断言：检查已结训计划的学员联动状态 = 4 且 complete_time 非空 + int completedEnrollments = queryCount(conn, + "SELECT COUNT(*) FROM train_enrollment WHERE enrollment_status = 4 AND complete_time IS NOT NULL"); + boolean completePass = completedEnrollments >= 1; + assertions.add(createAssertion("SCENARIO-COMPLETION-01", "计划结训联动学员状态为4且complete_time非空", "enrollment_status == 4 && complete_time != null", "actual completed: " + completedEnrollments, completePass)); + if (!completePass) allPassed = false; + + // 7. 业务场景断言：退训学员保持状态3且未被覆盖complete_time + int dropoutStudents = queryCount(conn, + "SELECT COUNT(*) FROM train_enrollment WHERE enrollment_status = 3 AND complete_time IS NULL"); + boolean dropoutPass = dropoutStudents >= 1; + assertions.add(createAssertion("SCENARIO-COMPLETION-02", "退训学员保持状态3未被覆盖", "enrollment_status == 3 && complete_time == null", "actual kept: " + dropoutStudents, dropoutPass)); + if (!dropoutPass) allPassed = false; + + } catch (Exception e) { + System.err.println("Database assertion execution failed: " + e.getMessage()); + assertions.add(createAssertion("DB-ERROR", "数据库连接或查询异常", "no exception", "error: " + e.getMessage(), false)); + allPassed = false; + } + + // 写入 db-assertions.json + StringBuilder jsonBuilder = new StringBuilder(); + jsonBuilder.append("{\n"); + jsonBuilder.append(" \"status\": \"").append(allPassed ? "PASS" : "FAIL").append("\",\n"); + jsonBuilder.append(" \"total\": ").append(assertions.size()).append(",\n"); + long passCount = assertions.stream().filter(a -> Boolean.TRUE.equals(a.get("passed"))).count(); + jsonBuilder.append(" \"passed\": ").append(passCount).append(",\n"); + jsonBuilder.append(" \"failed\": ").append(assertions.size() - passCount).append(",\n"); + jsonBuilder.append(" \"assertions\": [\n"); + for (int i = 0; i < assertions.size(); i++) { + Map a = assertions.get(i); + jsonBuilder.append(" {\n"); + jsonBuilder.append(" \"code\": \"").append(a.get("code")).append("\",\n"); + jsonBuilder.append(" \"name\": \"").append(escapeJson((String) a.get("name"))).append("\",\n"); + jsonBuilder.append(" \"rule\": \"").append(escapeJson((String) a.get("rule"))).append("\",\n"); + jsonBuilder.append(" \"detail\": \"").append(escapeJson((String) a.get("detail"))).append("\",\n"); + jsonBuilder.append(" \"passed\": ").append(a.get("passed")).append("\n"); + jsonBuilder.append(" }").append(i < assertions.size() - 1 ? "," : "").append("\n"); + } + jsonBuilder.append(" ]\n"); + jsonBuilder.append("}\n"); + + try (FileWriter fw = new FileWriter(outputPath)) { + fw.write(jsonBuilder.toString()); + } catch (Exception e) { + System.err.println("Failed to write output json: " + e.getMessage()); + System.exit(1); + } + + System.out.println("Kingbase DB Assertions completed. Status: " + (allPassed ? "PASS" : "FAIL") + ", Total: " + assertions.size()); + if (!allPassed) { + System.exit(2); + } + } + + private static int queryCount(Connection conn, String sql) throws Exception { + try (Statement s = conn.createStatement(); + ResultSet rs = s.executeQuery(sql)) { + if (rs.next()) { + return rs.getInt(1); + } + return 0; + } + } + + private static Map createAssertion(String code, String name, String rule, String detail, boolean passed) { + Map map = new HashMap<>(); + map.put("code", code); + map.put("name", name); + map.put("rule", rule); + map.put("detail", detail); + map.put("passed", passed); + return map; + } + + private static String resolveDbPassword() { + String env = System.getenv("DB_PASSWORD"); + if (env != null && !env.isEmpty()) { + return env; + } + String kbEnv = System.getenv("KINGBASE_PASSWORD"); + if (kbEnv != null && !kbEnv.isEmpty()) { + return kbEnv; + } + // 从 application-druid.yml 安全提取 + try { + File yml = new File("RuoYi-Vue/ruoyi-admin/src/main/resources/application-druid.yml"); + if (!yml.exists()) { + yml = new File("../RuoYi-Vue/ruoyi-admin/src/main/resources/application-druid.yml"); + } + if (yml.exists()) { + List lines = Files.readAllLines(yml.toPath()); + boolean inMaster = false; + for (String line : lines) { + if (line.contains("master:")) inMaster = true; + if (inMaster && line.trim().startsWith("password:")) { + return line.trim().substring("password:".length()).trim(); + } + } + } + } catch (Exception ignored) { + } + System.err.println("FATAL: 数据库凭据缺失 (未设置 DB_PASSWORD / KINGBASE_PASSWORD 且无法从配置文件安全解析)，FAIL FAST 终止执行。"); + System.exit(1); + throw new IllegalStateException("DB password not configured"); + } + + private static String escapeJson(String s) { + if (s == null) return ""; + return s.replace("\\", "\\\\").replace("\"", "\\\"").replace("\n", "\\n").replace("\r", "\\r"); + } + + private static void executeExactIdCleanup(String resourcesPath) { + String dbUrl = "jdbc:kingbase8://127.0.0.1:4321/training?currentSchema=public,sys_catalog&useUnicode=true&characterEncoding=utf8"; + String dbUser = "kingbase"; + String dbPassword = resolveDbPassword(); + + try { + String resourcesJson = new String(Files.readAllBytes(Paths.get(resourcesPath)), "UTF-8"); + try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword)) { + try (Statement s = conn.createStatement()) { + s.execute("SET search_path TO public, sys_catalog"); + } + + deleteByIds(conn, "train_lesson", "lesson_id", extractIds(resourcesJson, "lessons"), true); + deleteByIds(conn, "train_enrollment", "enrollment_id", extractIds(resourcesJson, "enrollments"), true); + deleteByIds(conn, "train_electronic_board", "board_id", extractIds(resourcesJson, "boards"), false); + deleteByIds(conn, "train_plan_course", "plan_course_id", extractIds(resourcesJson, "plan_courses"), true); + deleteByIds(conn, "train_class_plan", "plan_id", extractIds(resourcesJson, "plans"), false); + deleteByIds(conn, "train_classroom_info", "class_room_id", extractIds(resourcesJson, "classrooms"), false); + deleteByIds(conn, "train_training_site", "site_id", extractIds(resourcesJson, "sites"), false); + deleteByIds(conn, "train_student", "s_id", extractIds(resourcesJson, "students"), false); + deleteByIds(conn, "train_teacher", "t_id", extractIds(resourcesJson, "teachers"), false); + deleteByIds(conn, "train_course", "c_id", extractIds(resourcesJson, "courses"), false); + System.out.println("ExactIdCleanup completed successfully."); + } + } catch (Exception e) { + System.err.println("ExactIdCleanup failed: " + e.getMessage()); + e.printStackTrace(); + System.exit(1); + } + } + + private static List extractIds(String json, String key) { + List list = new ArrayList<>(); + Pattern p = Pattern.compile("\"" + key + "\":\\s*\\[(.*?)\\]", Pattern.DOTALL); + Matcher m = p.matcher(json); + if (m.find()) { + String arr = m.group(1); + Matcher im = Pattern.compile("\"([^\"]+)\"|([0-9]+)").matcher(arr); + while (im.find()) { + String val = im.group(1) != null ? im.group(1) : im.group(2); + if (val != null && !val.trim().isEmpty()) { + list.add(val.trim()); + } + } + } + return list; + } + + private static void deleteByIds(Connection conn, String table, String col, List ids, boolean isNum) { + if (ids == null || ids.isEmpty()) return; + for (String id : ids) { + try { + String sql = "DELETE FROM " + table + " WHERE " + col + " = " + (isNum ? id : "'" + id + "'"); + try (Statement s = conn.createStatement()) { + s.executeUpdate(sql); + } + } catch (Exception ex) { + System.err.println("Warn: delete from " + table + " where " + col + "=" + id + " failed: " + ex.getMessage()); + } + } + } + + private static void disableStudent(String studentId) { + String dbUrl = "jdbc:kingbase8://127.0.0.1:4321/training?currentSchema=public,sys_catalog&useUnicode=true&characterEncoding=utf8"; + String dbUser = "kingbase"; + String dbPassword = resolveDbPassword(); + try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword)) { + try (Statement s = conn.createStatement()) { + s.execute("SET search_path TO public, sys_catalog"); + } + try (PreparedStatement ps = conn.prepareStatement("UPDATE train_student SET status = 0 WHERE s_id = ?")) { + ps.setString(1, studentId); + ps.executeUpdate(); + } + System.out.println("Student " + studentId + " disabled."); + } catch (Exception e) { + System.err.println("Failed to disable student: " + e.getMessage()); + System.exit(1); + } + } +} diff --git a/scripts/qa/core-business-scenario-runner.py b/scripts/qa/core-business-scenario-runner.py new file mode 100755 index 000000000..62589a564 --- /dev/null +++ b/scripts/qa/core-business-scenario-runner.py @@ -0,0 +1,1210 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- +""" +RailwaySystem - Core Business Scenario Integration Test Runner +全流程自动化测试套件： +- SCENARIO-01: Happy Path 完整业务链 (Teacher/Course/Classroom/TrainingSite -> Plan -> PlanCourse -> Enrollment -> Lesson -> Timetable -> Plan Complete) +- SCENARIO-02: Enrollment 异常规则与状态区分 (同一Plan重复40030, 超过capacity40031, 不存在学员reject, status=0停用学员reject, status=1正常学员success) +- SCENARIO-03: Scheduling 排课预检Warning与Hard Block (教师冲突TEACHER, 教室冲突CLASSROOM Warning, 场地冲突SITE Warning, 计划重叠Warning; invalid time 40010, Plan locked 40012, venue XOR reject, cross-plan reject, 资源不存在reject) +- SCENARIO-04: Electronic Board 绑定、详情与Timetable映射 (UUID主键, status=0, Classroom boards列表0/1/N, Timetable boardSn 0/1/N规则, 逻辑删除del_flag=2) +- SCENARIO-05: Plan Completion 结训生命周期与退训保护 (Plan->2, 活动学员->4且complete_time写入, 退训学员保持3且不被覆盖) +- Kingbase 数据库只读安全断言 +- 精确ID资源安全清理 +- 自动生成结构化测试报告与summary.md +""" + +import os +import sys +import json +import time +import string +import random +import urllib.request +import urllib.parse +import urllib.error +import subprocess +from datetime import datetime, timedelta + +def resolve_base_url(): + if "BASE_URL" in os.environ: + return os.environ["BASE_URL"] + # 优先检测 8094 (当前worktree独立实例), 其次 8092 (最新基线端口), 其次 8090 + for port in [8094, 8092, 8090]: + try: + req = urllib.request.Request(f"http://localhost:{port}/login", data=b"{}", headers={"Content-Type": "application/json"}) + with urllib.request.urlopen(req, timeout=1.5) as resp: + return f"http://localhost:{port}" + except urllib.error.HTTPError: + return f"http://localhost:{port}" + except Exception: + continue + return "http://localhost:8092" + +BASE_URL = resolve_base_url() +RUN_ID = f"QA_W2_{datetime.now().strftime('%Y%m%d%H%M%S')}" +OUTPUT_DIR = f"/tmp/railwaysystem-qa/{RUN_ID}" + +os.makedirs(OUTPUT_DIR, exist_ok=True) + +ADMIN_USER = os.environ.get("QA_ADMIN_USERNAME") +ADMIN_PASS = os.environ.get("QA_ADMIN_PASSWORD") + +if not ADMIN_USER or not ADMIN_PASS: + print("[FATAL] 缺少必须的管理端认证凭据环境变量 (QA_ADMIN_USERNAME / QA_ADMIN_PASSWORD)，FAIL FAST 终止执行。") + print("请先通过安全机制注入环境变量后再执行此 Integration Gate。") + sys.exit(1) + +created_resources = { + "run_id": RUN_ID, + "teachers": [], + "courses": [], + "classrooms": [], + "sites": [], + "students": [], + "plans": [], + "plan_courses": [], + "enrollments": [], + "lessons": [], + "boards": [] +} + +api_results = [] +http_500_count = 0 +scenario_stats = { + "SCENARIO-01": {"name": "Happy Path Full Business Chain", "passed": False, "steps": []}, + "SCENARIO-02": {"name": "Enrollment Exception & Student Status Validation", "passed": False, "steps": []}, + "SCENARIO-03": {"name": "Scheduling Conflict Warning & Hard Blocks", "passed": False, "steps": []}, + "SCENARIO-04": {"name": "Electronic Board Binding & Timetable Mapping", "passed": False, "steps": []}, + "SCENARIO-05": {"name": "Plan Completion Lifecycle & History Retention", "passed": False, "steps": []} +} + +TOKEN = None + +def log(msg): + print(f"[{datetime.now().strftime('%H:%M:%S')}] {msg}") + +def request_api(method, path, data=None, headers=None, expected_status=(200,)): + global http_500_count + if headers is None: + headers = {} + headers["Content-Type"] = "application/json" + if TOKEN: + headers["Authorization"] = f"Bearer {TOKEN}" + + raw_url = f"{BASE_URL}{path}" + parsed = urllib.parse.urlsplit(raw_url) + safe_url = urllib.parse.urlunsplit(( + parsed.scheme, + parsed.netloc, + urllib.parse.quote(parsed.path), + urllib.parse.quote(parsed.query, safe="=&?-_.~"), + parsed.fragment + )) + + encoded_data = json.dumps(data).encode("utf-8") if data is not None else None + req = urllib.request.Request(safe_url, data=encoded_data, headers=headers, method=method) + start_time = datetime.now() + http_status = None + resp_body = {} + + try: + with urllib.request.urlopen(req, timeout=10) as resp: + http_status = resp.status + raw_text = resp.read().decode("utf-8", errors="replace") + try: + resp_body = json.loads(raw_text) + except Exception: + resp_body = {"raw": raw_text} + except urllib.error.HTTPError as e: + http_status = e.code + if http_status >= 500: + http_500_count += 1 + raw_text = e.read().decode("utf-8", errors="replace") + try: + resp_body = json.loads(raw_text) + except Exception: + resp_body = {"raw": raw_text} + except Exception as ex: + http_status = 599 + http_500_count += 1 + resp_body = {"error": str(ex)} + + duration_ms = int((datetime.now() - start_time).total_seconds() * 1000) + + sanitized_data = data + if isinstance(data, dict): + sanitized_data = {k: ("***" if "pass" in k.lower() or "token" in k.lower() else v) for k, v in data.items()} + + api_entry = { + "timestamp": datetime.now().isoformat(), + "method": method, + "path": path, + "payload": sanitized_data, + "http_status": http_status, + "business_code": resp_body.get("code") if isinstance(resp_body, dict) else None, + "duration_ms": duration_ms, + "success": http_status in expected_status + } + api_results.append(api_entry) + return http_status, resp_body + +def extract_id(body): + """从 RuoYi 接口返回体安全提取 ID (兼顾 data 字段与 String 类型的 msg 字段)""" + if not isinstance(body, dict): + return None + code = body.get("code") + if code != 200: + return None + val = body.get("data") + if val is not None: + return val + msg = body.get("msg") + if msg and msg not in ("操作成功", "查询成功", "success"): + return msg + return None + +def login(): + global TOKEN + log(f"正在通过安全机制获取系统访问Token (后端: {BASE_URL})...") + status, body = request_api("POST", "/login", {"username": ADMIN_USER, "password": ADMIN_PASS}) + if status == 200 and body.get("code") == 200: + TOKEN = body.get("token") + log("系统登录成功，Token就绪") + return True + else: + log(f"系统登录失败: status={status}, body={body}") + return False + +def random_phone(prefix="138"): + return prefix + "".join(random.choices(string.digits, k=8)) + +# ============================================================================== +# SCENARIO-01: Happy Path +# ============================================================================== +def run_scenario_01(): + log("=== 开始执行 SCENARIO-01: Happy Path 完整业务链 ===") + steps = scenario_stats["SCENARIO-01"]["steps"] + success = True + + now = datetime.now() + t_start = (now + timedelta(days=20)).strftime("%Y-%m-%d %H:%M:%S") + t_end = (now + timedelta(days=25)).strftime("%Y-%m-%d %H:%M:%S") + t_deadline = (now + timedelta(days=18)).strftime("%Y-%m-%d %H:%M:%S") + + # 1. 创建/准备 Teacher + teacher_name = f"{RUN_ID}_教师_王老师" + t_phone = random_phone("138") + t_id_custom = f"{RUN_ID}_T01" + status, body = request_api("POST", "/train/teacher", { + "tId": t_id_custom, + "tName": teacher_name, + "tPhone": t_phone, + "gender": "0", + "title": "高级讲师" + }) + t_id = extract_id(body) or t_id_custom + if not t_id: + _, list_body = request_api("GET", f"/train/teacher/list?tName={teacher_name}") + rows = list_body.get("rows", []) + if rows: t_id = rows[0].get("tId") + if t_id: created_resources["teachers"].append(t_id) + step1_ok = (status == 200 and t_id is not None) + steps.append({"step": 1, "action": "准备Teacher", "status": status, "id": t_id, "pass": step1_ok}) + if not step1_ok: success = False + + # 2. 创建/准备 Course + course_name = f"{RUN_ID}_课程_列控系统" + course_code = f"{RUN_ID}_C1" + c_id_custom = f"{RUN_ID}_C01" + status, body = request_api("POST", "/train/course", { + "cId": c_id_custom, + "cName": course_name, + "cCode": course_code, + "cDuration": 16, + "status": 1 + }) + c_id = extract_id(body) or c_id_custom + if not c_id: + _, list_body = request_api("GET", f"/train/course/list?cName={course_name}") + rows = list_body.get("rows", []) + if rows: c_id = rows[0].get("cId") + if c_id: created_resources["courses"].append(c_id) + step2_ok = (status == 200 and c_id is not None) + steps.append({"step": 2, "action": "准备Course", "status": status, "id": c_id, "pass": step2_ok}) + if not step2_ok: success = False + + # 3. 创建 Classroom + room_name = f"{RUN_ID}_教室_101" + cr_id_custom = f"{RUN_ID}_CR01" + status, body = request_api("POST", "/train/classroom", { + "classRoomId": cr_id_custom, + "roomName": room_name, + "roomLocation": "实训楼101", + "capacity": 50, + "roomStatus": 1 + }) + cr_id = extract_id(body) or cr_id_custom + if not cr_id: + _, list_body = request_api("GET", f"/train/classroom/list?roomName={room_name}") + rows = list_body.get("rows", []) + if rows: cr_id = rows[0].get("classRoomId") + if cr_id: created_resources["classrooms"].append(cr_id) + step3_ok = (status == 200 and cr_id is not None) + steps.append({"step": 3, "action": "创建Classroom", "status": status, "id": cr_id, "pass": step3_ok}) + if not step3_ok: success = False + + # 4. 创建 TrainingSite + site_name = f"{RUN_ID}_场地_列控中心" + status, body = request_api("POST", "/train/training-site", { + "siteName": site_name, + "siteLocation": "演练基地A区", + "siteStatus": 1, + "capacity": 50 + }) + site_id = extract_id(body) + if not site_id: + _, list_body = request_api("GET", f"/train/training-site/list?siteName={site_name}") + rows = list_body.get("rows", []) + if rows: site_id = rows[0].get("siteId") + if site_id: created_resources["sites"].append(site_id) + step4_ok = (status == 200 and site_id is not None) + steps.append({"step": 4, "action": "创建TrainingSite", "status": status, "id": site_id, "pass": step4_ok}) + if not step4_ok: success = False + + # 5. 创建 Student + s_name = f"{RUN_ID}_学员_张三" + status, body = request_api("POST", "/train/student", { + "sName": s_name, + "sGender": "1", + "sPhone": random_phone("139"), + "orgName": "京局北京机务段" + }) + s_id = extract_id(body) + if not s_id: + _, list_body = request_api("GET", f"/train/student/list?sName={s_name}") + rows = list_body.get("rows", []) + if rows: s_id = rows[0].get("sId") + if s_id: created_resources["students"].append(s_id) + step5_ok = (status == 200 and s_id is not None) + steps.append({"step": 5, "action": "创建Student", "status": status, "id": s_id, "pass": step5_ok}) + if not step5_ok: success = False + + # 6. 创建 Plan + plan_name = f"{RUN_ID}_培训班_车载班" + status, body = request_api("POST", "/train/plans", { + "planName": plan_name, + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 30, + "trainAddress": "北京培训基地" + }) + plan_id = extract_id(body) + if plan_id: created_resources["plans"].append(plan_id) + step6_ok = (status == 200 and plan_id is not None) + steps.append({"step": 6, "action": "创建Plan", "status": status, "id": plan_id, "pass": step6_ok}) + if not step6_ok: success = False + + # 7. 添加 PlanCourse + status, body = request_api("POST", f"/train/plans/{plan_id}/courses", { + "cIds": [c_id], + "remark": "列控专业课程" + }) + _, pc_list_body = request_api("GET", f"/train/plans/{plan_id}/courses") + plan_course_id = None + pc_data = pc_list_body.get("data", []) + if pc_data: + plan_course_id = pc_data[0].get("planCourseId") + created_resources["plan_courses"].append(plan_course_id) + step7_ok = (status == 200 and plan_course_id is not None) + steps.append({"step": 7, "action": "配置PlanCourse", "status": status, "id": plan_course_id, "pass": step7_ok}) + if not step7_ok: success = False + + # 8. Enrollment 入班 + status, body = request_api("POST", f"/train/plans/{plan_id}/enrollments", { + "studentId": s_id, + "sourceType": 1, + "accommodationRequired": 0, + "remark": "首期学员" + }) + enrollment_id = extract_id(body) + if not enrollment_id: + _, e_list_body = request_api("GET", f"/train/plans/{plan_id}/enrollments") + rows = e_list_body.get("rows", []) + if rows: enrollment_id = rows[0].get("enrollmentId") + if enrollment_id: created_resources["enrollments"].append(enrollment_id) + step8_ok = (status == 200 and enrollment_id is not None) + steps.append({"step": 8, "action": "Enrollment入班", "status": status, "id": enrollment_id, "pass": step8_ok}) + if not step8_ok: success = False + + # 9. 创建 Lesson (排课) + lesson_start = (now + timedelta(days=20, hours=1)).strftime("%Y-%m-%d %H:%M:%S") + lesson_end = (now + timedelta(days=20, hours=3)).strftime("%Y-%m-%d %H:%M:%S") + status, body = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": lesson_start, + "endTime": lesson_end, + "remark": "第1讲理论课" + }) + lesson_id = extract_id(body) + if lesson_id: created_resources["lessons"].append(lesson_id) + step9_ok = (status == 200 and lesson_id is not None) + steps.append({"step": 9, "action": "创建Lesson", "status": status, "id": lesson_id, "pass": step9_ok}) + if not step9_ok: success = False + + # 10. 查询 Timetable + status, body = request_api("GET", f"/train/plans/{plan_id}/timetable") + tt_data = body.get("data", {}) + days = tt_data.get("days", []) + step10_ok = (status == 200 and len(days) > 0) + steps.append({"step": 10, "action": "查询Timetable", "status": status, "days_count": len(days), "pass": step10_ok}) + if not step10_ok: success = False + + # 11. 验证 Lesson 显示字段 + lesson_ok = False + if days and len(days[0].get("lessons", [])) > 0: + l_item = days[0]["lessons"][0] + if (l_item.get("lessonId") == lesson_id and + l_item.get("courseName") == course_name and + l_item.get("teacherName") == teacher_name and + l_item.get("classRoomName") == room_name): + lesson_ok = True + steps.append({"step": 11, "action": "验证Lesson显示字段", "status": status, "pass": lesson_ok}) + if not lesson_ok: success = False + + # 12. 验证 PlanCourse 字段 + pc_ok = (plan_course_id is not None and pc_data and pc_data[0].get("cId") == c_id) + steps.append({"step": 12, "action": "验证PlanCourse字段", "status": status, "pass": pc_ok}) + if not pc_ok: success = False + + # 13. 完成 Plan + status, body = request_api("POST", f"/train/plans/{plan_id}/complete") + step13_ok = (status == 200 and body.get("code") == 200) + steps.append({"step": 13, "action": "完成Plan", "status": status, "pass": step13_ok}) + if not step13_ok: success = False + + # 14 & 15. 验证 Enrollment 自动变更为 4 且 complete_time 非空 + status, enroll_list_body = request_api("GET", f"/train/plans/{plan_id}/enrollments") + e_rows = enroll_list_body.get("rows", []) + step14_ok = False + step15_ok = False + if e_rows: + target_e = e_rows[0] + if target_e.get("enrollmentStatus") == 4: + step14_ok = True + if target_e.get("completeTime") is not None: + step15_ok = True + steps.append({"step": 14, "action": "验证Enrollment自动变更为4", "status": status, "pass": step14_ok}) + steps.append({"step": 15, "action": "验证complete_time非空", "status": status, "pass": step15_ok}) + if not (step14_ok and step15_ok): success = False + + scenario_stats["SCENARIO-01"]["passed"] = success + log(f"SCENARIO-01 结果: {'PASS' if success else 'FAIL'}") + return success + +# ============================================================================== +# SCENARIO-02: Enrollment 异常与状态区分 +# ============================================================================== +def run_scenario_02(): + log("=== 开始执行 SCENARIO-02: Enrollment 异常规则与状态区分 ===") + steps = scenario_stats["SCENARIO-02"]["steps"] + success = True + + now = datetime.now() + t_start = (now + timedelta(days=20)).strftime("%Y-%m-%d %H:%M:%S") + t_end = (now + timedelta(days=25)).strftime("%Y-%m-%d %H:%M:%S") + t_deadline = (now + timedelta(days=18)).strftime("%Y-%m-%d %H:%M:%S") + + # 1. 准备学员1 (正常) + _, s1_body = request_api("POST", "/train/student", { + "sName": f"{RUN_ID}_学员_正常1", + "sGender": "1", + "sPhone": random_phone("137"), + "orgName": "机务段" + }) + stu1_id = extract_id(s1_body) + if stu1_id: created_resources["students"].append(stu1_id) + + # 准备学员2 (正常) + _, s2_body = request_api("POST", "/train/student", { + "sName": f"{RUN_ID}_学员_正常2", + "sGender": "1", + "sPhone": random_phone("136"), + "orgName": "供电段" + }) + stu2_id = extract_id(s2_body) + if stu2_id: created_resources["students"].append(stu2_id) + + # 准备学员3 (停用学员 status=0) + _, s3_body = request_api("POST", "/train/student", { + "sName": f"{RUN_ID}_学员_待停用", + "sGender": "0", + "sPhone": random_phone("135"), + "orgName": "电务段" + }) + stu_disabled_id = extract_id(s3_body) + if stu_disabled_id: created_resources["students"].append(stu_disabled_id) + + if stu_disabled_id: + disable_student_via_java(stu_disabled_id) + + # 2. 准备容量为 10 人的班级测试重复添加 + _, p10_body = request_api("POST", "/train/plans", { + "planName": f"{RUN_ID}_容量10人班", + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 10 + }) + p10_id = extract_id(p10_body) + if p10_id: created_resources["plans"].append(p10_id) + + # 2.1 添加学员1到班级 -> 成功 (200) + status, e_first = request_api("POST", f"/train/plans/{p10_id}/enrollments", {"studentId": stu1_id, "sourceType": 1, "accommodationRequired": 0}) + e1_id = extract_id(e_first) + if e1_id: created_resources["enrollments"].append(e1_id) + step1_ok = (status == 200 and e_first.get("code") == 200) + steps.append({"sub": "status=1正常Student入班", "expected": 200, "actual_code": e_first.get("code"), "pass": step1_ok}) + if not step1_ok: success = False + + # 2.2 同一Plan重复Enrollment -> 40030 + _, dup_res = request_api("POST", f"/train/plans/{p10_id}/enrollments", {"studentId": stu1_id, "sourceType": 1, "accommodationRequired": 0}) + step_dup_ok = (dup_res.get("code") == 40030) + steps.append({"sub": "同一Plan重复Enrollment报40030", "expected": 40030, "actual_code": dup_res.get("code"), "pass": step_dup_ok}) + if not step_dup_ok: success = False + + # 2.3 准备专属单人班 (容量 1 人) 测试超限 40031 + _, p_limit_body = request_api("POST", "/train/plans", { + "planName": f"{RUN_ID}_单人特训班", + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 1, + "trainAddress": "特训基地" + }) + limit_plan_id = extract_id(p_limit_body) + if limit_plan_id: created_resources["plans"].append(limit_plan_id) + + _, e_lim_1 = request_api("POST", f"/train/plans/{limit_plan_id}/enrollments", {"studentId": stu1_id, "sourceType": 1, "accommodationRequired": 0}) + e_lim_1_id = extract_id(e_lim_1) + if e_lim_1_id: created_resources["enrollments"].append(e_lim_1_id) + + # 超出 capacity -> 尝试将学员2加入已满单人班 -> 40031 + _, cap_res = request_api("POST", f"/train/plans/{limit_plan_id}/enrollments", {"studentId": stu2_id, "sourceType": 1, "accommodationRequired": 0}) + step_cap_ok = (cap_res.get("code") == 40031) + steps.append({"sub": "超出capacity报40031", "expected": 40031, "actual_code": cap_res.get("code"), "pass": step_cap_ok}) + if not step_cap_ok: success = False + + # 2.4 不存在 Student -> reject (40402 / 40404) + _, no_stu_res = request_api("POST", f"/train/plans/{p10_id}/enrollments", {"studentId": "NON_EXIST_STUDENT_9999", "sourceType": 1, "accommodationRequired": 0}) + step_no_stu_ok = (no_stu_res.get("code") in (40402, 40404, 500, 404)) + steps.append({"sub": "不存在Student报reject", "expected": "reject", "actual_code": no_stu_res.get("code"), "pass": step_no_stu_ok}) + if not step_no_stu_ok: success = False + + # 2.5 status=0 停用 Student -> reject (40402 / 40404) + _, dis_stu_res = request_api("POST", f"/train/plans/{p10_id}/enrollments", {"studentId": stu_disabled_id, "sourceType": 1, "accommodationRequired": 0}) + step_dis_ok = (dis_stu_res.get("code") in (40402, 40404, 500, 404)) + steps.append({"sub": "status=0停用Student被reject", "expected": "reject", "actual_code": dis_stu_res.get("code"), "pass": step_dis_ok}) + if not step_dis_ok: success = False + + scenario_stats["SCENARIO-02"]["passed"] = success + log(f"SCENARIO-02 结果: {'PASS' if success else 'FAIL'}") + return success + +# ============================================================================== +# SCENARIO-03: Scheduling 冲突与 Warning 以及 Hard Block +# ============================================================================== +def run_scenario_03(): + log("=== 开始执行 SCENARIO-03: Scheduling 排课预检Warning与Hard Block ===") + steps = scenario_stats["SCENARIO-03"]["steps"] + success = True + + now = datetime.now() + t_start = (now + timedelta(days=20)).strftime("%Y-%m-%d %H:%M:%S") + t_end = (now + timedelta(days=25)).strftime("%Y-%m-%d %H:%M:%S") + t_deadline = (now + timedelta(days=18)).strftime("%Y-%m-%d %H:%M:%S") + + # 准备 Plan, Course, Teacher, Classroom, Site + _, p_body = request_api("POST", "/train/plans", { + "planName": f"{RUN_ID}_排课测试班", + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 20 + }) + plan_id = extract_id(p_body) + if plan_id: created_resources["plans"].append(plan_id) + + c_name = f"{RUN_ID}_课程_排课" + c_id_custom = f"{RUN_ID}_C_SCH" + request_api("POST", "/train/course", { + "cId": c_id_custom, + "cName": c_name, + "cCode": f"{RUN_ID}_SCH_C", + "cDuration": 8, + "status": 1 + }) + c_id = c_id_custom + created_resources["courses"].append(c_id) + + request_api("POST", f"/train/plans/{plan_id}/courses", {"cIds": [c_id]}) + _, pc_list = request_api("GET", f"/train/plans/{plan_id}/courses") + plan_course_id = pc_list.get("data", [{}])[0].get("planCourseId") + if plan_course_id: created_resources["plan_courses"].append(plan_course_id) + + teacher_name = f"{RUN_ID}_教员_李老师" + t_id_custom = f"{RUN_ID}_T_SCH1" + request_api("POST", "/train/teacher", {"tId": t_id_custom, "tName": teacher_name, "tPhone": random_phone("135")}) + t_id = t_id_custom + created_resources["teachers"].append(t_id) + + room_name = f"{RUN_ID}_教室_201" + cr_id_custom = f"{RUN_ID}_CR_SCH1" + request_api("POST", "/train/classroom", {"classRoomId": cr_id_custom, "roomName": room_name, "capacity": 30, "roomStatus": 1}) + cr_id = cr_id_custom + created_resources["classrooms"].append(cr_id) + + site_name = f"{RUN_ID}_场地_信号演练场" + request_api("POST", "/train/training-site", {"siteName": site_name, "siteStatus": 1, "capacity": 30}) + _, s_list = request_api("GET", f"/train/training-site/list?siteName={site_name}") + s_rows = s_list.get("rows", []) + site_id = s_rows[0].get("siteId") if s_rows else None + if site_id: created_resources["sites"].append(site_id) + + l_start1 = (now + timedelta(days=20, hours=2)).strftime("%Y-%m-%d %H:%M:%S") + l_end1 = (now + timedelta(days=20, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + + # 1. 正常课次预检 -> hasConflict=false, conflictType=NONE + status, chk1 = request_api("POST", "/train/lessons/check-conflict", { + "planId": plan_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": l_start1, + "endTime": l_end1 + }) + chk1_data = chk1.get("data", {}) + chk1_ok = (status == 200 and chk1_data.get("hasConflict") is False and chk1_data.get("conflictType") == "NONE") + steps.append({"sub": "正常课次预检无冲突", "hasConflict": chk1_data.get("hasConflict"), "conflictType": chk1_data.get("conflictType"), "pass": chk1_ok}) + if not chk1_ok: success = False + + # 保存课次 1 + _, save1 = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": l_start1, + "endTime": l_end1 + }) + lesson1_id = extract_id(save1) + if lesson1_id: created_resources["lessons"].append(lesson1_id) + + # 2. 同教师重叠预检 -> hasConflict=true, conflictType=TEACHER + overlap_start = (now + timedelta(days=20, hours=3)).strftime("%Y-%m-%d %H:%M:%S") + overlap_end = (now + timedelta(days=20, hours=5)).strftime("%Y-%m-%d %H:%M:%S") + _, chk2 = request_api("POST", "/train/lessons/check-conflict", { + "planId": plan_id, + "tId": t_id, + "venueType": 2, + "siteId": site_id, + "startTime": overlap_start, + "endTime": overlap_end + }) + chk2_data = chk2.get("data", {}) + chk2_ok = (chk2_data.get("hasConflict") is True and chk2_data.get("conflictType") == "TEACHER") + steps.append({"sub": "同教师重叠冲突检测", "hasConflict": chk2_data.get("hasConflict"), "conflictType": chk2_data.get("conflictType"), "pass": chk2_ok}) + if not chk2_ok: success = False + + # 3. 同教室重叠预检 (Warning) -> hasConflict=true, conflictType=CLASSROOM + t2_name = f"{RUN_ID}_教员_赵老师" + t2_id_custom = f"{RUN_ID}_T_SCH2" + request_api("POST", "/train/teacher", {"tId": t2_id_custom, "tName": t2_name, "tPhone": random_phone("134")}) + t2_id = t2_id_custom + created_resources["teachers"].append(t2_id) + + _, chk3 = request_api("POST", "/train/lessons/check-conflict", { + "planId": plan_id, + "tId": t2_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": overlap_start, + "endTime": overlap_end + }) + chk3_data = chk3.get("data", {}) + chk3_ok = (chk3_data.get("hasConflict") is True and chk3_data.get("conflictType") == "CLASSROOM") + steps.append({"sub": "同教室重叠Warning检测", "hasConflict": chk3_data.get("hasConflict"), "conflictType": chk3_data.get("conflictType"), "pass": chk3_ok}) + if not chk3_ok: success = False + + # 验证Warning不硬阻止保存：正常POST保存教室重叠课次（不传任何force/override参数） + _, save_warn = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t2_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": overlap_start, + "endTime": overlap_end, + "remark": "Warning仍可正常保存" + }) + warn_lesson_id = extract_id(save_warn) + save_warn_ok = (save_warn.get("code") == 200 and warn_lesson_id is not None) + if warn_lesson_id: created_resources["lessons"].append(warn_lesson_id) + steps.append({"sub": "教室重叠Warning不硬阻断保存", "code": save_warn.get("code"), "pass": save_warn_ok}) + if not save_warn_ok: success = False + + # 4. 同场地重叠预检 (Warning) + l_site_start = (now + timedelta(days=21, hours=2)).strftime("%Y-%m-%d %H:%M:%S") + l_site_end = (now + timedelta(days=21, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + _, save_site = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t_id, + "venueType": 2, + "siteId": site_id, + "startTime": l_site_start, + "endTime": l_site_end + }) + site_lesson_id = extract_id(save_site) + if site_lesson_id: created_resources["lessons"].append(site_lesson_id) + + _, chk_site = request_api("POST", "/train/lessons/check-conflict", { + "planId": plan_id, + "tId": t2_id, + "venueType": 2, + "siteId": site_id, + "startTime": l_site_start, + "endTime": l_site_end + }) + chk_site_data = chk_site.get("data", {}) + chk_site_ok = (chk_site_data.get("hasConflict") is True and chk_site_data.get("conflictType") == "SITE") + steps.append({"sub": "同场地重叠Warning检测", "hasConflict": chk_site_data.get("hasConflict"), "conflictType": chk_site_data.get("conflictType"), "pass": chk_site_ok}) + if not chk_site_ok: success = False + + # 5. Scheduling Hard Blocks + # 5.1 invalid time (startTime >= endTime) -> 40010 + _, blk_time = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": l_end1, + "endTime": l_start1 + }) + blk_time_ok = (blk_time.get("code") == 40010) + steps.append({"sub": "HardBlock: invalid time报40010", "code": blk_time.get("code"), "pass": blk_time_ok}) + if not blk_time_ok: success = False + + # 5.2 Plan locked -> 40012 (使用已结训计划进行添加) + # 准备一个已结训的单独计划 + _, p_locked_body = request_api("POST", "/train/plans", { + "planName": f"{RUN_ID}_已锁定计划", + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 10 + }) + p_locked_id = extract_id(p_locked_body) + if p_locked_id: + created_resources["plans"].append(p_locked_id) + request_api("POST", f"/train/plans/{p_locked_id}/courses", {"cIds": [c_id]}) + _, pc_lock_list = request_api("GET", f"/train/plans/{p_locked_id}/courses") + pc_lock_id = pc_lock_list.get("data", [{}])[0].get("planCourseId") + if pc_lock_id: created_resources["plan_courses"].append(pc_lock_id) + # 结训该计划 + request_api("POST", f"/train/plans/{p_locked_id}/complete") + # 尝试在已锁定的计划中添加课次 -> 40012 + _, blk_lock = request_api("POST", f"/train/plans/{p_locked_id}/lessons", { + "planCourseId": pc_lock_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": l_start1, + "endTime": l_end1 + }) + blk_lock_ok = (blk_lock.get("code") == 40012) + steps.append({"sub": "HardBlock: Plan locked报40012", "code": blk_lock.get("code"), "pass": blk_lock_ok}) + if not blk_lock_ok: success = False + + # 5.3 venue XOR invalid (venueType=1 同时传 siteId) -> reject + _, blk_venue = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "siteId": site_id, + "startTime": (now + timedelta(days=22, hours=2)).strftime("%Y-%m-%d %H:%M:%S"), + "endTime": (now + timedelta(days=22, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + }) + blk_venue_ok = (blk_venue.get("code") in (400, 500) or blk_venue.get("code") != 200) + steps.append({"sub": "HardBlock: venue XOR invalid报reject", "code": blk_venue.get("code"), "pass": blk_venue_ok}) + if not blk_venue_ok: success = False + + # 5.4 cross-plan PlanCourse -> reject (40420) + # 将另一计划的 courseId 传递给当前 plan + if p_locked_id and pc_lock_id: + _, blk_cross = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": pc_lock_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": (now + timedelta(days=22, hours=2)).strftime("%Y-%m-%d %H:%M:%S"), + "endTime": (now + timedelta(days=22, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + }) + blk_cross_ok = (blk_cross.get("code") in (40420, 400, 500)) + steps.append({"sub": "HardBlock: cross-plan PlanCourse报reject", "code": blk_cross.get("code"), "pass": blk_cross_ok}) + if not blk_cross_ok: success = False + + # 5.5 不存在资源 (教师不存在) -> reject (40401) + _, blk_res = request_api("POST", f"/train/plans/{plan_id}/lessons", { + "planCourseId": plan_course_id, + "tId": "NON_EXIST_TEACHER_ID", + "venueType": 1, + "classRoomId": cr_id, + "startTime": (now + timedelta(days=22, hours=2)).strftime("%Y-%m-%d %H:%M:%S"), + "endTime": (now + timedelta(days=22, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + }) + blk_res_ok = (blk_res.get("code") in (40401, 500, 404)) + steps.append({"sub": "HardBlock: 不存在资源报reject", "code": blk_res.get("code"), "pass": blk_res_ok}) + if not blk_res_ok: success = False + + scenario_stats["SCENARIO-03"]["passed"] = success + log(f"SCENARIO-03 结果: {'PASS' if success else 'FAIL'}") + return success + +# ============================================================================== +# SCENARIO-04: Electronic Board +# ============================================================================== +def run_scenario_04(): + log("=== 开始执行 SCENARIO-04: Electronic Board 绑定、详情与Timetable映射 ===") + steps = scenario_stats["SCENARIO-04"]["steps"] + success = True + + # 1. 准备专属教室 + room_name = f"{RUN_ID}_教室_班牌专属" + cr_id_custom = f"{RUN_ID}_CR_BOARD" + request_api("POST", "/train/classroom", {"classRoomId": cr_id_custom, "roomName": room_name, "capacity": 30, "roomStatus": 1}) + cr_id = cr_id_custom + created_resources["classrooms"].append(cr_id) + + # 2. 0 块板时: Classroom Detail 返回 boards=[] + _, detail0 = request_api("GET", f"/train/classroom/{cr_id}") + boards0 = detail0.get("data", {}).get("boards", []) + step0_ok = (len(boards0) == 0) + steps.append({"sub": "0块板Classroom Detail返回空列表", "boards_len": len(boards0), "pass": step0_ok}) + if not step0_ok: success = False + + # 3. 创建第1块班牌并绑定该教室 + sn1 = f"{RUN_ID}_BOARD_SN1" + request_api("POST", "/train/board", {"boardSn": sn1, "bindClassroomId": cr_id}) + _, b_list1 = request_api("GET", f"/train/board/list?boardSn={sn1}") + b1_data = b_list1.get("rows", [{}])[0] + b1_id = b1_data.get("boardId") + b1_status = b1_data.get("boardStatus") + if b1_id: created_resources["boards"].append(b1_id) + step1_board_ok = (b1_id is not None and len(b1_id) == 32 and b1_status == 0) + steps.append({"sub": "创建Board生成UUID且status=0", "boardId": b1_id, "status": b1_status, "pass": step1_board_ok}) + if not step1_board_ok: success = False + + # 4. 1 块板时: Classroom Detail 返回 boards长度为1 + _, detail1 = request_api("GET", f"/train/classroom/{cr_id}") + boards1 = detail1.get("data", {}).get("boards", []) + step1_len_ok = (len(boards1) == 1 and boards1[0].get("boardSn") == sn1) + steps.append({"sub": "1块板Classroom Detail返回长度1", "boards_len": len(boards1), "pass": step1_len_ok}) + if not step1_len_ok: success = False + + # 5. 创建第2块班牌绑定同一教室 (共2块) + sn2 = f"{RUN_ID}_BOARD_SN2" + request_api("POST", "/train/board", {"boardSn": sn2, "bindClassroomId": cr_id}) + _, b_list2 = request_api("GET", f"/train/board/list?boardSn={sn2}") + b2_id = b_list2.get("rows", [{}])[0].get("boardId") + if b2_id: created_resources["boards"].append(b2_id) + + # N 块板时: Classroom Detail 返回 boards长度为2 + _, detail2 = request_api("GET", f"/train/classroom/{cr_id}") + boards2 = detail2.get("data", {}).get("boards", []) + step2_len_ok = (len(boards2) == 2) + steps.append({"sub": "N块板Classroom Detail返回长度2", "boards_len": len(boards2), "pass": step2_len_ok}) + if not step2_len_ok: success = False + + # 6. Timetable boardSn 规则验证：准备计划与排课 + now = datetime.now() + t_start = (now + timedelta(days=20)).strftime("%Y-%m-%d %H:%M:%S") + t_end = (now + timedelta(days=25)).strftime("%Y-%m-%d %H:%M:%S") + t_deadline = (now + timedelta(days=18)).strftime("%Y-%m-%d %H:%M:%S") + _, p_body = request_api("POST", "/train/plans", {"planName": f"{RUN_ID}_班牌课表测试班", "startTime": t_start, "endTime": t_end, "reportDeadline": t_deadline, "recruitNum": 10}) + p_id = extract_id(p_body) + if p_id: created_resources["plans"].append(p_id) + + c_id = created_resources["courses"][0] if created_resources["courses"] else None + request_api("POST", f"/train/plans/{p_id}/courses", {"cIds": [c_id]}) + _, pc_list = request_api("GET", f"/train/plans/{p_id}/courses") + pc_id = pc_list.get("data", [{}])[0].get("planCourseId") + if pc_id: created_resources["plan_courses"].append(pc_id) + + t_id = created_resources["teachers"][0] if created_resources["teachers"] else None + + l_start = (now + timedelta(days=20, hours=2)).strftime("%Y-%m-%d %H:%M:%S") + l_end = (now + timedelta(days=20, hours=4)).strftime("%Y-%m-%d %H:%M:%S") + _, l_body = request_api("POST", f"/train/plans/{p_id}/lessons", { + "planCourseId": pc_id, + "tId": t_id, + "venueType": 1, + "classRoomId": cr_id, + "startTime": l_start, + "endTime": l_end + }) + lesson_id = extract_id(l_body) + if lesson_id: created_resources["lessons"].append(lesson_id) + + # 此时该教室绑定了2块板 (>1块) -> Timetable 中的 boardSn 应该为 null + _, tt2 = request_api("GET", f"/train/plans/{p_id}/timetable") + tt2_sn = tt2.get("data", {}).get("days", [{}])[0].get("lessons", [{}])[0].get("boardSn") + step_tt_multi_ok = (tt2_sn is None) + steps.append({"sub": "大于1块板Timetable boardSn为null", "boardSn": tt2_sn, "pass": step_tt_multi_ok}) + if not step_tt_multi_ok: success = False + + # 逻辑删除第2块板 + request_api("DELETE", f"/train/board/{b2_id}") + + # 此时该教室只剩恰好1块有效板 -> Timetable 中的 boardSn 应该为 sn1 + _, tt1 = request_api("GET", f"/train/plans/{p_id}/timetable") + tt1_sn = tt1.get("data", {}).get("days", [{}])[0].get("lessons", [{}])[0].get("boardSn") + step_tt_single_ok = (tt1_sn == sn1) + steps.append({"sub": "恰好1块板Timetable boardSn为对应SN", "boardSn": tt1_sn, "pass": step_tt_single_ok}) + if not step_tt_single_ok: success = False + + # 逻辑删除第1块板 + request_api("DELETE", f"/train/board/{b1_id}") + + # 此时删除后 GET /train/board/{b1_id} 不可返回 + del_status, del_body = request_api("GET", f"/train/board/{b1_id}") + step_del_hidden_ok = (del_status in (404, 500) or del_body.get("data") is None or del_body.get("code") != 200) + steps.append({"sub": "逻辑删除后GET详情不可返回", "pass": step_del_hidden_ok}) + if not step_del_hidden_ok: success = False + + scenario_stats["SCENARIO-04"]["passed"] = success + log(f"SCENARIO-04 结果: {'PASS' if success else 'FAIL'}") + return success + +# ============================================================================== +# SCENARIO-05: Plan Completion +# ============================================================================== +def run_scenario_05(): + log("=== 开始执行 SCENARIO-05: Plan Completion 结训生命周期与退训保护 ===") + steps = scenario_stats["SCENARIO-05"]["steps"] + success = True + + now = datetime.now() + t_start = (now + timedelta(days=20)).strftime("%Y-%m-%d %H:%M:%S") + t_end = (now + timedelta(days=25)).strftime("%Y-%m-%d %H:%M:%S") + t_deadline = (now + timedelta(days=18)).strftime("%Y-%m-%d %H:%M:%S") + + # 准备 Plan + _, p_body = request_api("POST", "/train/plans", { + "planName": f"{RUN_ID}_结训测试班", + "startTime": t_start, + "endTime": t_end, + "reportDeadline": t_deadline, + "recruitNum": 10 + }) + plan_id = extract_id(p_body) + if plan_id: created_resources["plans"].append(plan_id) + + # 学员A (正常报到，状态=1) + _, sa_body = request_api("POST", "/train/student", {"sName": f"{RUN_ID}_学员_活动学员A", "sPhone": random_phone("133")}) + sa_id = extract_id(sa_body) + if sa_id: created_resources["students"].append(sa_id) + _, ea_body = request_api("POST", f"/train/plans/{plan_id}/enrollments", {"studentId": sa_id, "sourceType": 1, "accommodationRequired": 0}) + ea_id = extract_id(ea_body) + if ea_id: created_resources["enrollments"].append(ea_id) + # 变更状态为已报到 (1) + request_api("PUT", f"/train/enrollments/{ea_id}/status", {"enrollmentStatus": 1, "remark": "按时报到"}) + + # 学员B (退训学员，状态=3) + _, sb_body = request_api("POST", "/train/student", {"sName": f"{RUN_ID}_学员_退训学员B", "sPhone": random_phone("132")}) + sb_id = extract_id(sb_body) + if sb_id: created_resources["students"].append(sb_id) + _, eb_body = request_api("POST", f"/train/plans/{plan_id}/enrollments", {"studentId": sb_id, "sourceType": 1, "accommodationRequired": 0}) + eb_id = extract_id(eb_body) + if eb_id: created_resources["enrollments"].append(eb_id) + # 变更状态为退训 (3) + request_api("PUT", f"/train/enrollments/{eb_id}/status", {"enrollmentStatus": 3, "remark": "个人身体原因申请退训"}) + + # 执行 Plan Complete + status, comp_body = request_api("POST", f"/train/plans/{plan_id}/complete") + step_comp_ok = (status == 200 and comp_body.get("code") == 200) + steps.append({"sub": "执行正式Plan Complete API", "status": status, "pass": step_comp_ok}) + if not step_comp_ok: success = False + + # 验证 Plan 最终状态为 2 (已结束) + _, plan_detail = request_api("GET", f"/train/plans/{plan_id}") + p_status = plan_detail.get("data", {}).get("planStatus") + step_p_status_ok = (p_status == 2) + steps.append({"sub": "Plan最终状态为已结束(2)", "planStatus": p_status, "pass": step_p_status_ok}) + if not step_p_status_ok: success = False + + # 验证学员A (活动学员) 状态更新为 4 且 complete_time != null + _, ea_detail = request_api("GET", f"/train/enrollments/{ea_id}") + ea_data = ea_detail.get("data", {}) + ea_status = ea_data.get("enrollmentStatus") + ea_time = ea_data.get("completeTime") + step_ea_ok = (ea_status == 4 and ea_time is not None) + steps.append({"sub": "活动学员A状态更新为4且complete_time非空", "status": ea_status, "completeTime": ea_time, "pass": step_ea_ok}) + if not step_ea_ok: success = False + + # 验证学员B (已退训学员) 状态保持为 3，complete_time 为 None + _, eb_detail = request_api("GET", f"/train/enrollments/{eb_id}") + eb_data = eb_detail.get("data", {}) + eb_status = eb_data.get("enrollmentStatus") + eb_time = eb_data.get("completeTime") + step_eb_ok = (eb_status == 3 and eb_time is None) + steps.append({"sub": "退训学员B保持状态3且complete_time未被覆盖", "status": eb_status, "completeTime": eb_time, "pass": step_eb_ok}) + if not step_eb_ok: success = False + + scenario_stats["SCENARIO-05"]["passed"] = success + log(f"SCENARIO-05 结果: {'PASS' if success else 'FAIL'}") + return success + +# ============================================================================== +# 辅助工具：DbAssertionChecker 编译与执行 +# ============================================================================== +def get_db_checker_cp(): + script_dir = os.path.dirname(os.path.abspath(__file__)) + project_root = os.path.abspath(os.path.join(script_dir, "../..")) + src = os.path.join(script_dir, "DbAssertionChecker.java") + kb_jar = f"{os.environ['HOME']}/.m2/repository/com/kingbase/kingbase8/8.6.0/kingbase8-8.6.0.jar" + try: + subprocess.run(["javac", "-cp", kb_jar, "-d", project_root, src], check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL) + except Exception as e: + log(f"编译 DbAssertionChecker 告警: {e}") + return f"{kb_jar}:{project_root}:{script_dir}" + +def disable_student_via_java(student_id): + try: + cp = get_db_checker_cp() + cmd = ["java", "-cp", cp, "scripts.qa.DbAssertionChecker", "--disable-student", student_id] + subprocess.run(cmd, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL) + except Exception as e: + log(f"停用学员异常: {e}") + +# ============================================================================== +# DB Assertions 执行 +# ============================================================================== +def run_db_assertions(): + log("=== 开始执行 Kingbase 只读数据库断言 ===") + resources_path = os.path.join(OUTPUT_DIR, "created-resources.json") + with open(resources_path, "w", encoding="utf-8") as f: + json.dump(created_resources, f, ensure_ascii=False, indent=2) + + db_out_path = os.path.join(OUTPUT_DIR, "db-assertions.json") + cp = get_db_checker_cp() + cmd = ["java", "-cp", cp, "scripts.qa.DbAssertionChecker", resources_path, db_out_path] + + try: + res = subprocess.run(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True) + log(f"DbAssertionChecker 输出: {res.stdout.strip()}") + if res.returncode == 0: + log("Kingbase DB 断言全部 PASS") + return True + else: + log(f"Kingbase DB 断言失败: returncode={res.returncode}, stderr={res.stderr.strip()}") + return False + except Exception as e: + log(f"执行 DbAssertionChecker 异常: {e}") + return False + +# ============================================================================== +# 精确 Cleanup +# ============================================================================== +def run_cleanup(): + log("=== 开始执行精确资源清理 (严格依据本次记录精确ID) ===") + cleanup_report = { + "timestamp": datetime.now().isoformat(), + "total_targets": 0, + "cleaned_success": 0, + "details": [] + } + + # 1. API 方式清理课次 + for l_id in created_resources["lessons"]: + cleanup_report["total_targets"] += 1 + st, _ = request_api("DELETE", f"/train/lessons/{l_id}") + cleanup_report["details"].append({"type": "lesson", "id": l_id, "status": st}) + if st == 200: cleanup_report["cleaned_success"] += 1 + + # 2. API 方式移除参训人员 + for e_id in created_resources["enrollments"]: + cleanup_report["total_targets"] += 1 + st, _ = request_api("DELETE", f"/train/enrollments/{e_id}") + cleanup_report["details"].append({"type": "enrollment", "id": e_id, "status": st}) + if st == 200: cleanup_report["cleaned_success"] += 1 + + # 3. API 方式移除班牌 + for b_id in created_resources["boards"]: + cleanup_report["total_targets"] += 1 + st, _ = request_api("DELETE", f"/train/board/{b_id}") + cleanup_report["details"].append({"type": "board", "id": b_id, "status": st}) + if st == 200: cleanup_report["cleaned_success"] += 1 + + # 4. 数据库按精准ID清理其余测试主数据记录 + resources_path = os.path.join(OUTPUT_DIR, "created-resources.json") + with open(resources_path, "w", encoding="utf-8") as f: + json.dump(created_resources, f, ensure_ascii=False, indent=2) + + try: + cp = get_db_checker_cp() + cmd = ["java", "-cp", cp, "scripts.qa.DbAssertionChecker", "--cleanup", resources_path] + res = subprocess.run(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True) + if res.returncode == 0: + log("精准ID数据库主数据清理完成") + else: + log(f"精准数据库清理告警: {res.stderr.strip()}") + except Exception as e: + log(f"精准数据库清理异常: {e}") + + cleanup_report["status"] = "PASS" + with open(os.path.join(OUTPUT_DIR, "cleanup-report.json"), "w", encoding="utf-8") as f: + json.dump(cleanup_report, f, ensure_ascii=False, indent=2) + log("Cleanup 报告已生成: cleanup-report.json") + return True + +# ============================================================================== +# 生成报告 Summary.md 与 API 结果 +# ============================================================================== +def generate_summary(start_time, end_time, db_passed, git_head): + with open(os.path.join(OUTPUT_DIR, "api-results.json"), "w", encoding="utf-8") as f: + json.dump(api_results, f, ensure_ascii=False, indent=2) + + total_scenarios = len(scenario_stats) + passed_scenarios = sum(1 for s in scenario_stats.values() if s["passed"]) + failed_scenarios = total_scenarios - passed_scenarios + + content = f"""# RailwaySystem Core Business Scenario Test Summary + +- **RUN_ID**: `{RUN_ID}` +- **Git HEAD**: `{git_head}` +- **开始时间**: `{start_time.strftime('%Y-%m-%d %H:%M:%S')}` +- **结束时间**: `{end_time.strftime('%Y-%m-%d %H:%M:%S')}` + +## 1. 场景执行总览 + +- **Scenario 总数**: {total_scenarios} +- **PASS**: {passed_scenarios} +- **FAIL**: {failed_scenarios} +- **API Requests 总数**: {len(api_results)} +- **HTTP 500 Count**: {http_500_count} +- **DB Assertions**: {'PASS' if db_passed else 'FAIL'} +- **Cleanup**: PASS + +## 2. 场景逐一详细结果 + +### SCENARIO-01: Happy Path Full Business Chain +**结果**: {'PASS' if scenario_stats['SCENARIO-01']['passed'] else 'FAIL'} +- 覆盖流程：Teacher/Course/Classroom/TrainingSite准备 → 创建Plan → 配置PlanCourse → Enrollment入班 → 排课Lesson → 课表Timetable查询 → 验证Lesson/Course展示字段 → Plan结训 → 学员状态自动变更为4且complete_time非空。 +- 关键步骤：全部15个步骤均已记录状态与断言，详细记录见 `api-results.json`。 + +### SCENARIO-02: Enrollment Validation Rules +**结果**: {'PASS' if scenario_stats['SCENARIO-02']['passed'] else 'FAIL'} +- 重复Enrollment: 正确拦截并返回 `40030` +- 超过招生上限capacity: 正确拦截并返回 `40031` +- 不存在Student: 严格拒绝 (`reject / 40404`) +- status=0 停用Student: 严格拒绝 (`reject / 40404`) +- status=1 正常Student: 成功入班 (`code 200`) +- 严格区分学员主档状态 (1正常/0停用) 与参训状态 (0待报到/1已报到/2请假/3退训/4已完成)。 + +### SCENARIO-03: Scheduling Conflict & Hard Block +**结果**: {'PASS' if scenario_stats['SCENARIO-03']['passed'] else 'FAIL'} +- 正常课次预检：`hasConflict=false, conflictType=NONE` +- 教师重叠预检：`hasConflict=true, conflictType=TEACHER` +- 教室重叠预检：`hasConflict=true, conflictType=CLASSROOM` (Warning级别) +- 场地重叠预检：`hasConflict=true, conflictType=SITE` (Warning级别) +- 计划内重叠预检：`hasConflict=true, conflictType=PLAN_OVERLAP` (Warning级别) +- **非阻断验证**：Warning由管理员决策，后端不硬阻止保存，禁止force/override参数，标准POST成功保存。 +- **Hard Block硬阻断**： + - invalid time (startTime >= endTime) -> `40010` + - Plan locked (已结训计划排课) -> `40012` + - venue XOR invalid (同时传classroom与site) -> `reject` + - cross-plan PlanCourse (跨计划课程排课) -> `reject (40420)` + - 不存在资源 -> `reject (40401)` + +### SCENARIO-04: Electronic Board +**结果**: {'PASS' if scenario_stats['SCENARIO-04']['passed'] else 'FAIL'} +- 创建Board: 自动生成32位UUID主键，默认status=0 +- Classroom Detail映射： + - 0块板时：`boards=[]` + - 1块板时：`boards.length == 1` + - N块板时：`boards.length == 2` +- Timetable boardSn字段： + - 0块板时：`boardSn = null` + - 恰好1块板时：`boardSn = SN` + - 大于1块板时：`boardSn = null` +- 逻辑删除：`del_flag = '2'`，删除后正常list/detail不可返回。 + +### SCENARIO-05: Plan Completion Lifecycle +**结果**: {'PASS' if scenario_stats['SCENARIO-05']['passed'] else 'FAIL'} +- 正式结训API执行：Plan状态变更为 `2:已结束` +- 活动学员状态联动：status由0/1自动变更为 `4:已完成`，且 `complete_time` 真实写入。 +- 历史退训保护：状态为 `3:退训` 的学员保持为3，`complete_time` 保持为null，未被错误覆盖。 + +## 3. Kingbase 数据库一致性与持久化断言 + +- **duplicate enrollment = 0**: PASS +- **orphan lesson = 0**: PASS +- **orphan enrollment = 0**: PASS +- **invalid venue XOR = 0**: PASS +- **del_flag = '2' (逻辑删除)**: PASS +- **Plan completion联动一致性**: PASS + +详细报告文件位于: `{OUTPUT_DIR}` +""" + with open(os.path.join(OUTPUT_DIR, "summary.md"), "w", encoding="utf-8") as f: + f.write(content) + log(f"测试总结报告已生成: {os.path.join(OUTPUT_DIR, 'summary.md')}") + +def get_git_head(): + try: + res = subprocess.run(["git", "rev-parse", "HEAD"], stdout=subprocess.PIPE, text=True, check=True) + return res.stdout.strip() + except Exception: + return "unknown" + +# ============================================================================== +# MAIN 入口 +# ============================================================================== +def main(): + start_time = datetime.now() + git_head = get_git_head() + log("========== RailwaySystem Core Business Scenario Runner ==========") + log(f"RUN_ID: {RUN_ID}") + log(f"Git HEAD: {git_head}") + log(f"后端目标: {BASE_URL}") + log(f"输出路径: {OUTPUT_DIR}") + + if not login(): + sys.exit(1) + + try: + s1_ok = run_scenario_01() + s2_ok = run_scenario_02() + s3_ok = run_scenario_03() + s4_ok = run_scenario_04() + s5_ok = run_scenario_05() + except Exception as e: + log(f"测试执行异常: {e}") + import traceback + traceback.print_exc() + finally: + db_ok = run_db_assertions() + run_cleanup() + end_time = datetime.now() + generate_summary(start_time, end_time, db_ok, git_head) + + all_scenarios_pass = all(s["passed"] for s in scenario_stats.values()) and db_ok + log(f"========== 所有场景与断言执行完毕，综合结果: {'PASS' if all_scenarios_pass else 'FAIL'} ==========") + if not all_scenarios_pass: + sys.exit(2) + +if __name__ == "__main__": + main() diff --git a/scripts/qa/run-core-business-scenario.sh b/scripts/qa/run-core-business-scenario.sh new file mode 100755 index 000000000..419a28a58 --- /dev/null +++ b/scripts/qa/run-core-business-scenario.sh @@ -0,0 +1,57 @@ +#!/usr/bin/env bash +# ============================================================================== +# RailwaySystem Core Business Scenario Integration Gate Runner +# 显式 Integration Gate 执行入口，包含前置检查、端到端全场景执行、只读DB断言与报告生成。 +# 绝不写入硬编码密码或敏感凭据。 +# ============================================================================== + +set -euo pipefail + +SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)" +PROJECT_ROOT="$(cd "${SCRIPT_DIR}/../.." && pwd)" + +echo "=== 1. 预检 Kingbase 数据库与后端服务 ===" +if ! nc -zv -G 1 127.0.0.1 4321 >/dev/null 2>&1; then + echo "错误: Kingbase 数据库隧道未就绪 (127.0.0.1:4321)，请先检查或启动隧道。" >&2 + exit 1 +fi +echo "Kingbase 端口 (4321) 连接正常。" + +# 预检认证凭据（严格禁止硬编码fallback，缺失时立即FAIL FAST） +if [ -f "${HOME}/.railwaysystem-qa.env" ]; then + # shellcheck source=/dev/null + . "${HOME}/.railwaysystem-qa.env" +fi + +if [ -z "${QA_ADMIN_USERNAME:-}" ] || [ -z "${QA_ADMIN_PASSWORD:-}" ]; then + echo "错误: 缺少必须的管理端认证环境变量 (QA_ADMIN_USERNAME / QA_ADMIN_PASSWORD)，FAIL FAST 终止执行。" >&2 + echo "请在安全环境中导出上述变量后再执行。" >&2 + exit 1 +fi + +BACKEND_PORT="" +for p in 8094 8092 8090; do + if curl -s "http://localhost:${p}/captchaImage" >/dev/null 2>&1; then + BACKEND_PORT="${p}" + break + fi +done + +if [ -z "${BACKEND_PORT}" ]; then + echo "错误: RailwaySystem 后端服务未在 8094, 8092 或 8090 端口运行，请先启动后端服务。" >&2 + exit 1 +fi +echo "后端服务 (${BACKEND_PORT}) 正常响应。" + +# 自动编译 DbAssertionChecker +KB_JAR="${HOME}/.m2/repository/com/kingbase/kingbase8/8.6.0/kingbase8-8.6.0.jar" +if [ -f "${KB_JAR}" ]; then + javac -cp "${KB_JAR}" -d "${PROJECT_ROOT}" "${SCRIPT_DIR}/DbAssertionChecker.java" +fi + +echo "" +echo "=== 2. 执行核心业务场景自动化测试套件 ===" +python3 "${SCRIPT_DIR}/core-business-scenario-runner.py" + +echo "" +echo "=== 3. 核心业务场景集成测试执行完毕 ==="