Compare commits
1 Commits
test_20260
...
main
| Author | SHA1 | Date |
|---|---|---|
lids
|
6bd7608e5c |
114
src/app.cpp
114
src/app.cpp
|
|
@ -9,6 +9,10 @@
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="核心引擎初始化", id="REQ-ENGINE-INIT-001")
|
||||
* 构造函数需初始化系统状态上下文，设置默认运行模式为空闲模式，
|
||||
* 并重置自增计数器，为后续业务操作提供初始状态。
|
||||
*
|
||||
* @brief 构造函数，初始化系统状态上下文与自增计数器
|
||||
*/
|
||||
CmsEngine::CmsEngine()
|
||||
|
|
@ -21,8 +25,11 @@ CmsEngine::CmsEngine()
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 生成自增唯一标识
|
||||
* @requirement(name="唯一标识生成", id="REQ-UTIL-IDGEN-001")
|
||||
* 系统需支持生成格式为 "ID-xxxxx" 的自增唯一标识，
|
||||
* 用于任务方案、事件等实体的 ID 分配。
|
||||
*
|
||||
* @brief 生成自增唯一标识
|
||||
* @return std::string 格式如 "ID-00001"
|
||||
*/
|
||||
std::string CmsEngine::generateNextId()
|
||||
|
|
@ -37,10 +44,11 @@ std::string CmsEngine::generateNextId()
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="战场事件接入", id="REQ-EVENT-INGEST-001")
|
||||
* 系统需支持从外部事件总线接入原始战场事件，执行基本合法性校验
|
||||
* （ID 不能为空、优先级范围检查），通过后存入事件库。
|
||||
*
|
||||
* @brief 接入原始战场事件
|
||||
*
|
||||
* 执行基本合法性校验（ID 不能为空、优先级范围检查），通过后存入事件库。
|
||||
*
|
||||
* @param event 战场事件
|
||||
* @return true 接入成功
|
||||
* @return false 接入失败
|
||||
|
|
@ -58,11 +66,11 @@ bool CmsEngine::ingestEvent(const EventRecord& event)
|
|||
}
|
||||
|
||||
/**
|
||||
* @requirement(name="待处理事件处理", id="REQ-EVENT-PROC-001")
|
||||
* 系统需遍历事件库中所有 Pending 状态的事件，自动将其状态标记为 Generated，
|
||||
* 并据此生成一个对应的 TaskPlan 草案，实现事件到方案的自动转化。
|
||||
*
|
||||
* @brief 处理待处理事件队列
|
||||
*
|
||||
* 遍历事件库中所有 Pending 状态的事件，自动将其状态标记为 Generated，
|
||||
* 并据此生成一个对应的 TaskPlan 草案。
|
||||
*
|
||||
* @return size_t 处理的事件数量
|
||||
*/
|
||||
size_t CmsEngine::processPendingEvents()
|
||||
|
|
@ -90,8 +98,11 @@ size_t CmsEngine::processPendingEvents()
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 根据事件 ID 查找事件
|
||||
* @requirement(name="事件查询", id="REQ-EVENT-QUERY-001")
|
||||
* 系统需支持根据事件 ID 在事件库中查找对应的事件记录，
|
||||
* 找到则返回事件指针，未找到返回 nullptr。
|
||||
*
|
||||
* @brief 根据事件 ID 查找事件
|
||||
* @param eventId 事件标识
|
||||
* @return const EventRecord* 事件指针，未找到返回 nullptr
|
||||
*/
|
||||
|
|
@ -110,10 +121,11 @@ const EventRecord* CmsEngine::findEventById(const std::string& eventId) const
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="任务方案创建", id="REQ-PLAN-CREATE-001")
|
||||
* 系统需校验方案名称非空后，为其分配系统 ID 并存入方案库，
|
||||
* 确保方案数据的完整性和可追溯性。
|
||||
*
|
||||
* @brief 创建任务方案
|
||||
*
|
||||
* 校验方案名称非空后，为其分配系统 ID 并存入方案库。
|
||||
*
|
||||
* @param plan 待创建方案（id 由系统填充）
|
||||
* @return true 创建成功
|
||||
* @return false 名称不合法
|
||||
|
|
@ -130,8 +142,10 @@ bool CmsEngine::createTaskPlan(TaskPlan& plan)
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 获取所有任务方案列表
|
||||
* @requirement(name="任务方案列表查询", id="REQ-PLAN-LIST-001")
|
||||
* 系统需返回全部任务方案列表的引用，以支撑方案全局视图展示。
|
||||
*
|
||||
* @brief 获取所有任务方案列表
|
||||
* @return const std::vector<TaskPlan>& 方案列表
|
||||
*/
|
||||
const std::vector<TaskPlan>& CmsEngine::getAllPlans() const
|
||||
|
|
@ -140,8 +154,11 @@ const std::vector<TaskPlan>& CmsEngine::getAllPlans() const
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 根据 ID 查找任务方案
|
||||
* @requirement(name="任务方案查找", id="REQ-PLAN-FIND-001")
|
||||
* 系统需支持根据任务 ID 在方案库中遍历查找对应方案，
|
||||
* 找到返回方案指针，未找到返回 nullptr。
|
||||
*
|
||||
* @brief 根据 ID 查找任务方案
|
||||
* @param planId 任务标识
|
||||
* @return const TaskPlan* 方案指针，未找到返回 nullptr
|
||||
*/
|
||||
|
|
@ -156,8 +173,11 @@ const TaskPlan* CmsEngine::findPlanById(const std::string& planId) const
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 更新任务方案状态
|
||||
* @requirement(name="任务方案状态更新", id="REQ-PLAN-UPDATE-001")
|
||||
* 系统需支持根据任务 ID 查找方案并更新其状态，返回是否更新成功，
|
||||
* 以驱动方案从草稿到完成的生命周期流转。
|
||||
*
|
||||
* @brief 更新任务方案状态
|
||||
* @param planId 任务标识
|
||||
* @param newStatus 新状态
|
||||
* @return true 更新成功
|
||||
|
|
@ -179,8 +199,10 @@ bool CmsEngine::updatePlanStatus(const std::string& planId, PlanStatus newStatus
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @brief 注册模板实例
|
||||
* @requirement(name="模板注册", id="REQ-TMPL-REG-001")
|
||||
* 系统需支持将模板实例添加到模板库中，为后续场景匹配提供候选模板。
|
||||
*
|
||||
* @brief 注册模板实例
|
||||
* @param tmpl 模板实例
|
||||
*/
|
||||
void CmsEngine::registerTemplate(const TemplateInstance& tmpl)
|
||||
|
|
@ -189,10 +211,11 @@ void CmsEngine::registerTemplate(const TemplateInstance& tmpl)
|
|||
}
|
||||
|
||||
/**
|
||||
* @requirement(name="模板匹配", id="REQ-TMPL-MATCH-001")
|
||||
* 系统需遍历模板库，返回置信度最高的模板（简单策略：置信度最大者），
|
||||
* 空库时返回 nullptr。
|
||||
*
|
||||
* @brief 根据场景匹配最佳模板
|
||||
*
|
||||
* 遍历模板库，返回置信度最高的模板（简单策略：置信度最大者）。
|
||||
*
|
||||
* @param scenario 场景描述（当前未用于精确匹配，仅做演示）
|
||||
* @return const TemplateInstance* 最佳模板，无匹配返回 nullptr
|
||||
*/
|
||||
|
|
@ -216,10 +239,11 @@ const TemplateInstance* CmsEngine::matchTemplate(const std::string& scenario) co
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="执行状态上报", id="REQ-MON-REPORT-001")
|
||||
* 系统需将节点遥测数据写入内部状态表，按 nodeId 覆盖更新，
|
||||
* 以维护各节点最新的执行状态。
|
||||
*
|
||||
* @brief 上报节点执行状态
|
||||
*
|
||||
* 将节点遥测数据写入内部状态表，按 nodeId 覆盖更新。
|
||||
*
|
||||
* @param status 执行状态
|
||||
*/
|
||||
void CmsEngine::reportExecutionStatus(const ExecutionStatus& status)
|
||||
|
|
@ -228,10 +252,11 @@ void CmsEngine::reportExecutionStatus(const ExecutionStatus& status)
|
|||
}
|
||||
|
||||
/**
|
||||
* @requirement(name="节点健康检查", id="REQ-MON-HEALTH-001")
|
||||
* 系统需遍历所有节点状态，依据健康指数 < 0.5、异常码 != 0 或
|
||||
* 距最后上报超过 30 秒的判据筛选异常节点，返回异常节点状态列表。
|
||||
*
|
||||
* @brief 检查所有节点健康状态
|
||||
*
|
||||
* 异常判据：健康指数 < 0.5 或异常码 != 0 或心跳超时（距最后上报 > 30秒）。
|
||||
*
|
||||
* @return std::vector<ExecutionStatus> 异常节点列表
|
||||
*/
|
||||
std::vector<ExecutionStatus> CmsEngine::checkHealth() const
|
||||
|
|
@ -268,10 +293,10 @@ std::vector<ExecutionStatus> CmsEngine::checkHealth() const
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="用户会话创建", id="REQ-SESS-CREATE-001")
|
||||
* 系统需校验 userId 非空且不重复后存入会话表，确保用户会话的唯一性。
|
||||
*
|
||||
* @brief 创建用户会话
|
||||
*
|
||||
* 校验 userId 非空且不重复后存入会话表。
|
||||
*
|
||||
* @param session 用户会话
|
||||
* @return true 创建成功
|
||||
* @return false 用户已存在或 ID 为空
|
||||
|
|
@ -289,10 +314,11 @@ bool CmsEngine::createSession(const UserSession& session)
|
|||
}
|
||||
|
||||
/**
|
||||
* @requirement(name="权限校验", id="REQ-SESS-PERM-001")
|
||||
* 系统需检查用户会话的权限位图是否包含所需的权限掩码，
|
||||
* 通过按位与运算进行判定，以保障系统操作安全。
|
||||
*
|
||||
* @brief 校验用户权限
|
||||
*
|
||||
* 检查用户会话的权限位图是否包含所需的权限掩码。
|
||||
*
|
||||
* @param userId 用户 ID
|
||||
* @param permissionMask 所需权限位掩码
|
||||
* @return true 有权限
|
||||
|
|
@ -313,8 +339,10 @@ bool CmsEngine::checkPermission(const std::string& userId,
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @brief 推送通知消息
|
||||
* @requirement(name="通知推送", id="REQ-NOTIF-PUSH-001")
|
||||
* 系统需支持将通知消息添加到消息队列尾部，以支撑系统内实时信息传达。
|
||||
*
|
||||
* @brief 推送通知消息
|
||||
* @param msg 通知消息
|
||||
*/
|
||||
void CmsEngine::pushNotification(const NotificationMessage& msg)
|
||||
|
|
@ -323,8 +351,11 @@ void CmsEngine::pushNotification(const NotificationMessage& msg)
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 获取所有未读通知
|
||||
* @requirement(name="未读通知查询", id="REQ-NOTIF-UNREAD-001")
|
||||
* 系统需遍历通知队列，筛选出所有未读通知并返回列表，
|
||||
* 以支撑用户快速查看待处理信息。
|
||||
*
|
||||
* @brief 获取所有未读通知
|
||||
* @return std::vector<NotificationMessage> 未读通知列表
|
||||
*/
|
||||
std::vector<NotificationMessage> CmsEngine::getUnreadNotifications() const
|
||||
|
|
@ -343,10 +374,11 @@ std::vector<NotificationMessage> CmsEngine::getUnreadNotifications() const
|
|||
// ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
/**
|
||||
* @requirement(name="运行模式切换", id="REQ-MODE-SWITCH-001")
|
||||
* 系统需支持运行模式切换，降级模式下不允许切换到其他模式（模拟故障隔离策略），
|
||||
* 切换成功后更新时间戳和一致性标记。
|
||||
*
|
||||
* @brief 切换系统运行模式
|
||||
*
|
||||
* 降级模式下不允许切换到其他模式（模拟故障隔离策略），其余模式可自由切换。
|
||||
*
|
||||
* @param newMode 目标模式
|
||||
* @return true 切换成功
|
||||
* @return false 切换被拒绝
|
||||
|
|
@ -364,8 +396,11 @@ bool CmsEngine::switchMode(RunMode newMode)
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 获取当前系统状态上下文
|
||||
* @requirement(name="系统状态查询", id="REQ-MODE-QUERY-001")
|
||||
* 系统需返回当前系统状态上下文的常量引用，包括运行模式、上下文快照、
|
||||
* 一致性标记和切换时间，以支撑状态监控与审计。
|
||||
*
|
||||
* @brief 获取当前系统状态上下文
|
||||
* @return const SystemStateContext& 状态上下文
|
||||
*/
|
||||
const SystemStateContext& CmsEngine::getSystemContext() const
|
||||
|
|
@ -374,8 +409,11 @@ const SystemStateContext& CmsEngine::getSystemContext() const
|
|||
}
|
||||
|
||||
/**
|
||||
* @brief 获取引擎摘要信息
|
||||
* @requirement(name="引擎摘要生成", id="REQ-SUMM-GEN-001")
|
||||
* 系统需汇总事件数、方案数、模板数、监控节点数、活跃会话数、
|
||||
* 未读通知数和当前运行模式，生成格式化的引擎运行摘要字符串。
|
||||
*
|
||||
* @brief 获取引擎摘要信息
|
||||
* @return std::string 包含事件数、方案数、节点数、未读通知数等
|
||||
*/
|
||||
std::string CmsEngine::getSummary() const
|
||||
|
|
|
|||
|
|
@ -1,25 +0,0 @@
|
|||
cmake_minimum_required(VERSION 3.10.0)
|
||||
project(test_plan_execute_t1)
|
||||
include(FetchContent)
|
||||
if (MSVC)
|
||||
add_compile_options(/utf-8)
|
||||
endif()
|
||||
FetchContent_Declare(
|
||||
googletest
|
||||
URL https://github.com/google/googletest/archive/03597a01ee50ed33e9dfd640b249b4be3799d395.zip
|
||||
)
|
||||
# For Windows: Prevent overriding the parent project's compiler/linker settings
|
||||
set(gtest_force_shared_crt ON CACHE BOOL "" FORCE)
|
||||
FetchContent_MakeAvailable(googletest)
|
||||
set(CMAKE_CXX_STANDARD 17)
|
||||
set(CMAKE_CXX_STANDARD_REQUIRED ON)
|
||||
include_directories(${CMAKE_CURRENT_SOURCE_DIR}/../include)
|
||||
|
||||
include(CTest)
|
||||
enable_testing()
|
||||
|
||||
add_executable(test_plan_execute_t1 test_app.cpp ../src/app.cpp)
|
||||
|
||||
target_link_libraries(test_plan_execute_t1 gtest gmock gtest_main)
|
||||
include(GoogleTest)
|
||||
gtest_discover_tests(test_plan_execute_t1)
|
||||
|
|
@ -1,429 +0,0 @@
|
|||
#include <gtest/gtest.h>
|
||||
#include <gmock/gmock.h>
|
||||
#include "app.hpp"
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <chrono>
|
||||
|
||||
using namespace testing;
|
||||
|
||||
// ============================================================================
|
||||
// 测试套件：CmsEngine::processPendingEvents
|
||||
// ============================================================================
|
||||
|
||||
/**
|
||||
* @brief 测试 processPendingEvents 处理多个Pending事件
|
||||
*/
|
||||
TEST(CmsEngineProcessPendingEventsTest, ProcessMultiplePendingEvents) {
|
||||
CmsEngine engine;
|
||||
for (size_t i = 0; i < 3; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-" + std::to_string(i);
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
size_t processed = engine.processPendingEvents();
|
||||
|
||||
EXPECT_EQ(processed, 3);
|
||||
|
||||
// 验证所有事件状态已更新为Generated
|
||||
for (size_t i = 0; i < 3; ++i) {
|
||||
std::string eventId = "EVT-" + std::to_string(i);
|
||||
const EventRecord* evt = engine.findEventById(eventId);
|
||||
ASSERT_NE(evt, nullptr);
|
||||
EXPECT_EQ(evt->status, EventStatus::Generated);
|
||||
}
|
||||
|
||||
// 验证生成了对应的TaskPlan
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_EQ(plans.size(), 3);
|
||||
for (size_t i = 0; i < 3; ++i) {
|
||||
EXPECT_EQ(plans[i].relatedEventId, "EVT-" + std::to_string(i));
|
||||
EXPECT_EQ(plans[i].status, PlanStatus::Drafting);
|
||||
EXPECT_EQ(plans[i].type, PlanType::Centralized);
|
||||
EXPECT_FALSE(plans[i].name.empty());
|
||||
EXPECT_FALSE(plans[i].id.empty());
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 processPendingEvents 处理0个Pending事件（所有事件已处理）
|
||||
*/
|
||||
TEST(CmsEngineProcessPendingEventsTest, ProcessZeroPendingEvents) {
|
||||
CmsEngine engine;
|
||||
for (size_t i = 0; i < 3; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-" + std::to_string(i);
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Generated;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
size_t processed = engine.processPendingEvents();
|
||||
|
||||
EXPECT_EQ(processed, 0);
|
||||
|
||||
// 验证没有生成新的TaskPlan
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_TRUE(plans.empty());
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 processPendingEvents 处理空事件库
|
||||
*/
|
||||
TEST(CmsEngineProcessPendingEventsTest, ProcessEmptyEventList) {
|
||||
CmsEngine engine;
|
||||
|
||||
size_t processed = engine.processPendingEvents();
|
||||
|
||||
EXPECT_EQ(processed, 0);
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_TRUE(plans.empty());
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 processPendingEvents 处理混合状态事件
|
||||
*/
|
||||
TEST(CmsEngineProcessPendingEventsTest, ProcessMixedStatusEvents) {
|
||||
CmsEngine engine;
|
||||
|
||||
// 添加2个Pending事件
|
||||
for (size_t i = 0; i < 2; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "PENDING-" + std::to_string(i);
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
// 添加2个Generated事件
|
||||
for (size_t i = 0; i < 2; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "GENERATED-" + std::to_string(i);
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Generated;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
size_t processed = engine.processPendingEvents();
|
||||
|
||||
EXPECT_EQ(processed, 2);
|
||||
|
||||
// 验证只有Pending事件被处理
|
||||
const EventRecord* pendingEvt0 = engine.findEventById("PENDING-0");
|
||||
ASSERT_NE(pendingEvt0, nullptr);
|
||||
EXPECT_EQ(pendingEvt0->status, EventStatus::Generated);
|
||||
|
||||
const EventRecord* generatedEvt0 = engine.findEventById("GENERATED-0");
|
||||
ASSERT_NE(generatedEvt0, nullptr);
|
||||
EXPECT_EQ(generatedEvt0->status, EventStatus::Generated);
|
||||
|
||||
// 验证生成了2个TaskPlan
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_EQ(plans.size(), 2);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 processPendingEvents 处理大量Pending事件
|
||||
*/
|
||||
TEST(CmsEngineProcessPendingEventsTest, ProcessLargeNumberOfPendingEvents) {
|
||||
const size_t largeCount = 1000;
|
||||
CmsEngine engine;
|
||||
for (size_t i = 0; i < largeCount; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-" + std::to_string(i);
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
size_t processed = engine.processPendingEvents();
|
||||
|
||||
EXPECT_EQ(processed, largeCount);
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_EQ(plans.size(), largeCount);
|
||||
|
||||
// 验证ID生成正确（递增）
|
||||
for (size_t i = 0; i < largeCount; ++i) {
|
||||
std::string expectedId = "ID-" + std::string(5 - std::to_string(i + 1).length(), '0') + std::to_string(i + 1);
|
||||
EXPECT_EQ(plans[i].id, expectedId);
|
||||
}
|
||||
}
|
||||
|
||||
// ============================================================================
|
||||
// 测试套件：CmsEngine::findEventById
|
||||
// ============================================================================
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 查找存在的普通事件
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindExistingEvent) {
|
||||
CmsEngine engine;
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-001";
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
|
||||
const EventRecord* found = engine.findEventById("EVT-001");
|
||||
|
||||
ASSERT_NE(found, nullptr);
|
||||
EXPECT_EQ(found->id, "EVT-001");
|
||||
EXPECT_EQ(found->priority, 100);
|
||||
EXPECT_EQ(found->status, EventStatus::Pending);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 查找不存在的ID
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindNonExistentEvent) {
|
||||
CmsEngine engine;
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-001";
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
|
||||
const EventRecord* found = engine.findEventById("NONEXISTENT");
|
||||
|
||||
EXPECT_EQ(found, nullptr);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 查找空字符串ID
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindEventWithEmptyId) {
|
||||
CmsEngine engine;
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-001";
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
|
||||
const EventRecord* found = engine.findEventById("");
|
||||
|
||||
EXPECT_EQ(found, nullptr);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 在空事件库中查找
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindEventInEmptyEngine) {
|
||||
const CmsEngine engine;
|
||||
|
||||
const EventRecord* found = engine.findEventById("ANY-ID");
|
||||
|
||||
EXPECT_EQ(found, nullptr);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 查找多个事件中的特定事件
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindSpecificEventAmongMany) {
|
||||
CmsEngine engine;
|
||||
|
||||
// 添加多个事件
|
||||
for (int i = 0; i < 10; ++i) {
|
||||
EventRecord evt;
|
||||
evt.id = "EVT-" + std::to_string(i);
|
||||
evt.priority = 50 + i * 10;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
}
|
||||
|
||||
const EventRecord* found = engine.findEventById("EVT-5");
|
||||
|
||||
ASSERT_NE(found, nullptr);
|
||||
EXPECT_EQ(found->id, "EVT-5");
|
||||
EXPECT_EQ(found->priority, 100);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 findEventById 查找大小写敏感的ID
|
||||
*/
|
||||
TEST(CmsEngineFindEventByIdTest, FindEventCaseSensitive) {
|
||||
CmsEngine engine;
|
||||
EventRecord evt;
|
||||
evt.id = "Event-001";
|
||||
evt.priority = 100;
|
||||
evt.status = EventStatus::Pending;
|
||||
engine.ingestEvent(evt);
|
||||
|
||||
const EventRecord* found = engine.findEventById("event-001");
|
||||
|
||||
EXPECT_EQ(found, nullptr);
|
||||
|
||||
found = engine.findEventById("Event-001");
|
||||
ASSERT_NE(found, nullptr);
|
||||
EXPECT_EQ(found->id, "Event-001");
|
||||
}
|
||||
|
||||
// ============================================================================
|
||||
// 测试套件：CmsEngine::createTaskPlan
|
||||
// ============================================================================
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建有效的任务方案
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateValidTaskPlan) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
plan.name = "TestPlan";
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
plan.resourceQuota = 0.8;
|
||||
plan.constraints = "测试约束";
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
|
||||
EXPECT_TRUE(result);
|
||||
EXPECT_FALSE(plan.id.empty());
|
||||
EXPECT_EQ(plan.name, "TestPlan");
|
||||
EXPECT_EQ(plan.type, PlanType::Centralized);
|
||||
EXPECT_EQ(plan.status, PlanStatus::Drafting);
|
||||
EXPECT_EQ(plan.resourceQuota, 0.8);
|
||||
EXPECT_EQ(plan.constraints, "测试约束");
|
||||
|
||||
// 验证方案已存入引擎
|
||||
const auto& plans = engine.getAllPlans();
|
||||
ASSERT_EQ(plans.size(), 1);
|
||||
EXPECT_EQ(plans[0].id, plan.id);
|
||||
EXPECT_EQ(plans[0].name, "TestPlan");
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建名称为空的方案
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateTaskPlanWithEmptyName) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
plan.name = "";
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
|
||||
EXPECT_FALSE(result);
|
||||
EXPECT_TRUE(plan.id.empty());
|
||||
|
||||
// 验证没有方案被添加
|
||||
const auto& plans = engine.getAllPlans();
|
||||
EXPECT_TRUE(plans.empty());
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建名称为空格的方案
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateTaskPlanWithWhitespaceName) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
plan.name = " ";
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
|
||||
EXPECT_TRUE(result);
|
||||
EXPECT_FALSE(plan.id.empty());
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
ASSERT_EQ(plans.size(), 1);
|
||||
EXPECT_EQ(plans[0].name, " ");
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建多个方案并验证ID递增
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateMultipleTaskPlans) {
|
||||
CmsEngine engine;
|
||||
|
||||
TaskPlan plan1;
|
||||
plan1.name = "Plan1";
|
||||
bool result1 = engine.createTaskPlan(plan1);
|
||||
EXPECT_TRUE(result1);
|
||||
EXPECT_EQ(plan1.id, "ID-00001");
|
||||
|
||||
TaskPlan plan2;
|
||||
plan2.name = "Plan2";
|
||||
bool result2 = engine.createTaskPlan(plan2);
|
||||
EXPECT_TRUE(result2);
|
||||
EXPECT_EQ(plan2.id, "ID-00002");
|
||||
|
||||
TaskPlan plan3;
|
||||
plan3.name = "Plan3";
|
||||
bool result3 = engine.createTaskPlan(plan3);
|
||||
EXPECT_TRUE(result3);
|
||||
EXPECT_EQ(plan3.id, "ID-00003");
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
ASSERT_EQ(plans.size(), 3);
|
||||
EXPECT_EQ(plans[0].id, "ID-00001");
|
||||
EXPECT_EQ(plans[1].id, "ID-00002");
|
||||
EXPECT_EQ(plans[2].id, "ID-00003");
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建包含特殊字符名称的方案
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateTaskPlanWithSpecialCharacters) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
plan.name = "Plan_With_Special_Chars!@#$%^&*()";
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
|
||||
EXPECT_TRUE(result);
|
||||
EXPECT_FALSE(plan.id.empty());
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
ASSERT_EQ(plans.size(), 1);
|
||||
EXPECT_EQ(plans[0].name, "Plan_With_Special_Chars!@#$%^&*()");
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建包含超长名称的方案
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateTaskPlanWithLongName) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
std::string longName(1000, 'A');
|
||||
plan.name = longName;
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
|
||||
EXPECT_TRUE(result);
|
||||
EXPECT_FALSE(plan.id.empty());
|
||||
|
||||
const auto& plans = engine.getAllPlans();
|
||||
ASSERT_EQ(plans.size(), 1);
|
||||
EXPECT_EQ(plans[0].name, longName);
|
||||
}
|
||||
|
||||
/**
|
||||
* @brief 测试 createTaskPlan 创建方案后通过findPlanById验证
|
||||
*/
|
||||
TEST(CmsEngineCreateTaskPlanTest, CreateAndFindTaskPlan) {
|
||||
CmsEngine engine;
|
||||
TaskPlan plan;
|
||||
plan.name = "TestPlan";
|
||||
plan.type = PlanType::Centralized;
|
||||
plan.status = PlanStatus::Drafting;
|
||||
|
||||
bool result = engine.createTaskPlan(plan);
|
||||
EXPECT_TRUE(result);
|
||||
|
||||
const TaskPlan* found = engine.findPlanById(plan.id);
|
||||
ASSERT_NE(found, nullptr);
|
||||
EXPECT_EQ(found->name, "TestPlan");
|
||||
EXPECT_EQ(found->id, plan.id);
|
||||
EXPECT_EQ(found->type, PlanType::Centralized);
|
||||
EXPECT_EQ(found->status, PlanStatus::Drafting);
|
||||
}
|
||||
Loading…
Reference in New Issue