139 lines
5.1 KiB
C++
139 lines
5.1 KiB
C++
#ifndef BATTLEFIELD_CORE_EVENT_HPP
|
||
#define BATTLEFIELD_CORE_EVENT_HPP
|
||
|
||
#include <string>
|
||
#include <chrono>
|
||
#include <vector>
|
||
#include <cstdint>
|
||
#include <functional>
|
||
#include <regex>
|
||
#include <nlohmann/json.hpp>
|
||
|
||
namespace battlefield {
|
||
|
||
/// @brief 战场事件类型枚举（对应 SRS-F-01-001 分类）
|
||
enum class EventType : int32_t {
|
||
UNKNOWN = 0, ///< 未知类型
|
||
INTEL = 1, ///< 情报事件
|
||
THREAT = 2, ///< 威胁事件
|
||
MISSION = 3, ///< 任务事件
|
||
LOGISTIC = 4 ///< 后勤事件
|
||
};
|
||
|
||
/// @brief 事件状态枚举（对应 T_EVENT.STATUS）
|
||
enum class EventStatus : int32_t {
|
||
PENDING = 0, ///< 待处理
|
||
PROCESSING = 1, ///< 处理中
|
||
RESOLVED = 2, ///< 已解决
|
||
ARCHIVED = 3 ///< 已归档
|
||
};
|
||
|
||
/// @brief 战场事件数据结构，对应数据库表 T_EVENT
|
||
struct Event {
|
||
std::string id; ///< EVENT_ID
|
||
EventType type = EventType::UNKNOWN; ///< EVENT_TYPE
|
||
std::chrono::system_clock::time_point timestamp; ///< TIMESTAMP
|
||
std::string location; ///< LOCATION
|
||
int32_t priority{0}; ///< PRIORITY (1-10)
|
||
EventStatus status{EventStatus::PENDING}; ///< STATUS
|
||
std::string source; ///< 事件来源
|
||
std::string summary; ///< 事件摘要
|
||
};
|
||
|
||
/// @brief 将 EventType 转为字符串表示
|
||
inline const char* EventTypeToString(EventType t) {
|
||
switch (t) {
|
||
case EventType::INTEL: return "INTEL";
|
||
case EventType::THREAT: return "THREAT";
|
||
case EventType::MISSION: return "MISSION";
|
||
case EventType::LOGISTIC: return "LOGISTIC";
|
||
default: return "UNKNOWN";
|
||
}
|
||
}
|
||
|
||
/// @brief 将 EventStatus 转为字符串表示
|
||
inline const char* EventStatusToString(EventStatus s) {
|
||
switch (s) {
|
||
case EventStatus::PENDING: return "PENDING";
|
||
case EventStatus::PROCESSING: return "PROCESSING";
|
||
case EventStatus::RESOLVED: return "RESOLVED";
|
||
case EventStatus::ARCHIVED: return "ARCHIVED";
|
||
default: return "UNKNOWN";
|
||
}
|
||
}
|
||
|
||
/// @brief 事件接收与处理模块（SU-01，覆盖 SRS-F-01-001 ~ SRS-F-01-004）
|
||
class EventProcessor {
|
||
public:
|
||
/// @brief 接收外部事件数据包（对应接口 IF-01）
|
||
/// @param rawJson 原始 JSON 格式的事件数据
|
||
/// @param source 事件来源标识
|
||
/// @return 成功接收返回 true
|
||
bool ReceiveEvent(const std::string& rawJson, const std::string& source = "external");
|
||
|
||
/// @brief 从 ndjson 文件批量读取事件（支持大文件流式读取，对应异步IO模型）
|
||
/// @param filePath 文件路径
|
||
/// @param maxEvents 最大读取事件数（0表示不限制）
|
||
/// @return 成功读取的事件数
|
||
size_t LoadEventsFromFile(const std::string& filePath, size_t maxEvents = 0);
|
||
|
||
/// @brief 对事件数据进行过滤、转化和封装（SRS-F-01-002）
|
||
/// @param raw 原始字符串数据
|
||
/// @param source 事件来源标识
|
||
/// @return 标准化后的 Event 对象
|
||
Event TransformEvent(const std::string& raw, const std::string& source = "external");
|
||
|
||
/// @brief 校验事件数据格式（正则表达式校验，设计文档3.1.1要求）
|
||
/// @param jsonObj JSON对象
|
||
/// @return 校验通过返回 true
|
||
bool ValidateEventData(const nlohmann::json& jsonObj) const;
|
||
|
||
/// @brief 获取当前所有待处理事件列表（SRS-F-01-003）
|
||
/// @return 事件列表
|
||
std::vector<Event> GetPendingEvents() const;
|
||
|
||
/// @brief 获取指定状态的事件列表
|
||
std::vector<Event> GetEventsByStatus(EventStatus status) const;
|
||
|
||
/// @brief 按优先级排序事件列表（SRS-F-01-004）
|
||
/// @param ascending true 升序（低优先在前），false 降序
|
||
void SortEventsByPriority(bool ascending = true);
|
||
|
||
/// @brief 根据自定义比较函数排序
|
||
void SortEventsBy(std::function<bool(const Event&, const Event&)> comparator);
|
||
|
||
/// @brief 按事件类型筛选
|
||
std::vector<Event> FilterByType(EventType type) const;
|
||
|
||
/// @brief 按优先级范围筛选
|
||
std::vector<Event> FilterByPriority(int32_t minPriority, int32_t maxPriority) const;
|
||
|
||
/// @brief 按来源筛选
|
||
std::vector<Event> FilterBySource(const std::string& source) const;
|
||
|
||
/// @brief 标记事件为处理中
|
||
bool MarkProcessing(const std::string& eventId);
|
||
|
||
/// @brief 标记事件为已解决
|
||
bool MarkResolved(const std::string& eventId);
|
||
|
||
/// @brief 归档事件
|
||
bool MarkArchived(const std::string& eventId);
|
||
|
||
/// @brief 获取事件总数
|
||
size_t GetEventCount() const { return events_.size(); }
|
||
|
||
/// @brief 清空所有事件
|
||
void Clear() { events_.clear(); }
|
||
|
||
private:
|
||
std::vector<Event> events_; ///< 内部事件存储
|
||
|
||
/// @brief 将外部事件（如代码生成器事件）映射为战场事件类型
|
||
EventType MapExternalEventType(const std::string& eventType, const std::string& domain) const;
|
||
};
|
||
|
||
} // namespace battlefield
|
||
|
||
#endif // BATTLEFIELD_CORE_EVENT_HPP
|