119 lines
3.3 KiB
C++
119 lines
3.3 KiB
C++
#include "qtradecore.h"
|
|
#include "qeventbus.h"
|
|
#include "qsubscriptionmanager.h"
|
|
#include "qbigordermanager.h"
|
|
#include "qlogmanager.h"
|
|
#include "qorderprocessor.h"
|
|
#include <QDebug>
|
|
#include <QCoreApplication>
|
|
QTradeCore* QTradeCore::instance()
|
|
{
|
|
static QTradeCore* instance = nullptr;
|
|
static QMutex mutex;
|
|
if (!instance) {
|
|
QMutexLocker locker(&mutex);
|
|
if (!instance) {
|
|
instance = new QTradeCore();
|
|
}
|
|
}
|
|
return instance;
|
|
}
|
|
QTradeCore::QTradeCore(QObject *parent) : QObject(parent)
|
|
{
|
|
}
|
|
QTradeCore::~QTradeCore()
|
|
{
|
|
shutdown();
|
|
}
|
|
void QTradeCore::initialize()
|
|
{
|
|
if (m_initialized) {
|
|
qWarning() << "QTradeCore: Already initialized";
|
|
return;
|
|
}
|
|
qDebug() << "QTradeCore: Initializing...";
|
|
try {
|
|
m_eventBus = QEventBus::instance();
|
|
m_subscriptionManager = QSubscriptionManager::instance();
|
|
m_bigOrderManager = QBigOrderManager::instance();
|
|
m_logManager = QLogManager::Instance();
|
|
m_orderProcessor = new QOrderProcessor(this);
|
|
m_initialized = true;
|
|
qDebug() << "QTradeCore: Initialization completed successfully";
|
|
emit systemInitialized();
|
|
} catch (const std::exception& e) {
|
|
qCritical() << "QTradeCore: Initialization failed:" << e.what();
|
|
emit errorOccurred(QString("Initialization failed: %1").arg(e.what()));
|
|
}
|
|
}
|
|
void QTradeCore::shutdown()
|
|
{
|
|
if (!m_initialized) {
|
|
return;
|
|
}
|
|
qDebug() << "QTradeCore: Shutting down...";
|
|
if (m_orderProcessor) {
|
|
delete m_orderProcessor;
|
|
m_orderProcessor = nullptr;
|
|
}
|
|
m_initialized = false;
|
|
qDebug() << "QTradeCore: Shutdown completed";
|
|
emit systemShutdown();
|
|
}
|
|
QSubscriptionManager* QTradeCore::subscriptionManager()
|
|
{
|
|
if (!m_initialized) {
|
|
qWarning() << "QTradeCore: Not initialized, cannot access subscription manager";
|
|
return nullptr;
|
|
}
|
|
return m_subscriptionManager;
|
|
}
|
|
QOrderProcessor* QTradeCore::orderProcessor()
|
|
{
|
|
if (!m_initialized) {
|
|
qWarning() << "QTradeCore: Not initialized, cannot access order processor";
|
|
return nullptr;
|
|
}
|
|
return m_orderProcessor;
|
|
}
|
|
QBigOrderManager* QTradeCore::bigOrderManager()
|
|
{
|
|
if (!m_initialized) {
|
|
qWarning() << "QTradeCore: Not initialized, cannot access big order manager";
|
|
return nullptr;
|
|
}
|
|
return m_bigOrderManager;
|
|
}
|
|
QLogManager* QTradeCore::logManager()
|
|
{
|
|
if (!m_initialized) {
|
|
qWarning() << "QTradeCore: Not initialized, cannot access log manager";
|
|
return nullptr;
|
|
}
|
|
return m_logManager;
|
|
}
|
|
QEventBus* QTradeCore::eventBus()
|
|
{
|
|
if (!m_initialized) {
|
|
qWarning() << "QTradeCore: Not initialized, cannot access event bus";
|
|
return nullptr;
|
|
}
|
|
return m_eventBus;
|
|
}
|
|
QString QTradeCore::getSystemStatus() const
|
|
{
|
|
QString status;
|
|
if (m_initialized) {
|
|
status = "System is running\n";
|
|
QStringList components;
|
|
if (m_subscriptionManager) components << "SubscriptionManager";
|
|
if (m_orderProcessor) components << "OrderProcessor";
|
|
if (m_bigOrderManager) components << "BigOrderManager";
|
|
if (m_logManager) components << "LogManager";
|
|
if (m_eventBus) components << "EventBus";
|
|
status += QString("Components: %1\n").arg(components.join(", "));
|
|
} else {
|
|
status = "System is not initialized";
|
|
}
|
|
return status;
|
|
} |