Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ae37b83cbc | |||
| 8aaa4eeec0 | |||
| f3e42a8b17 | |||
| d8ef54ddd0 | |||
| 5fb92fba0e | |||
| d2a7420db5 | |||
| 7047e96b3c | |||
| f545d57f79 |
+13
-9
@@ -102,7 +102,7 @@
|
|||||||
<SDLCheck>true</SDLCheck>
|
<SDLCheck>true</SDLCheck>
|
||||||
<PreprocessorDefinitions>_DEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
<PreprocessorDefinitions>_DEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
||||||
<ConformanceMode>true</ConformanceMode>
|
<ConformanceMode>true</ConformanceMode>
|
||||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)datastores\sharedmemory;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)core\sharedmemory;$(ProjectDir)core\events;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
<Link>
|
<Link>
|
||||||
<SubSystem>Console</SubSystem>
|
<SubSystem>Console</SubSystem>
|
||||||
@@ -117,7 +117,7 @@
|
|||||||
<SDLCheck>true</SDLCheck>
|
<SDLCheck>true</SDLCheck>
|
||||||
<PreprocessorDefinitions>NDEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
<PreprocessorDefinitions>NDEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
||||||
<ConformanceMode>true</ConformanceMode>
|
<ConformanceMode>true</ConformanceMode>
|
||||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)datastores\sharedmemory;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)core\sharedmemory;$(ProjectDir)core\events;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
<Link>
|
<Link>
|
||||||
<SubSystem>Console</SubSystem>
|
<SubSystem>Console</SubSystem>
|
||||||
@@ -126,10 +126,11 @@
|
|||||||
</ItemDefinitionGroup>
|
</ItemDefinitionGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ClCompile Include="controllers\Controller.cpp" />
|
<ClCompile Include="controllers\Controller.cpp" />
|
||||||
|
<ClCompile Include="core\events\EventManager.cpp" />
|
||||||
<ClCompile Include="core\patterns\Observer.cpp" />
|
<ClCompile Include="core\patterns\Observer.cpp" />
|
||||||
<ClCompile Include="core\patterns\Subject.cpp" />
|
<ClCompile Include="core\patterns\Subject.cpp" />
|
||||||
|
<ClCompile Include="core\sharedmemory\SharedMemory.cpp" />
|
||||||
<ClCompile Include="datastores\DataStore.cpp" />
|
<ClCompile Include="datastores\DataStore.cpp" />
|
||||||
<ClCompile Include="datastores\sharedmemory\SharedMemory.cpp" />
|
|
||||||
<ClCompile Include="models\ComboPackage.cpp" />
|
<ClCompile Include="models\ComboPackage.cpp" />
|
||||||
<ClCompile Include="models\InventoryItem.cpp" />
|
<ClCompile Include="models\InventoryItem.cpp" />
|
||||||
<ClCompile Include="models\Invoice.cpp" />
|
<ClCompile Include="models\Invoice.cpp" />
|
||||||
@@ -148,21 +149,23 @@
|
|||||||
<ClCompile Include="utilities\Validator.cpp" />
|
<ClCompile Include="utilities\Validator.cpp" />
|
||||||
<ClCompile Include="views\AdminMenu.cpp" />
|
<ClCompile Include="views\AdminMenu.cpp" />
|
||||||
<ClCompile Include="views\CustomerMenu.cpp" />
|
<ClCompile Include="views\CustomerMenu.cpp" />
|
||||||
|
<ClCompile Include="views\Menu.cpp" />
|
||||||
<ClCompile Include="views\TechnicianMenu.cpp" />
|
<ClCompile Include="views\TechnicianMenu.cpp" />
|
||||||
<ClCompile Include="views\UserInterface.cpp" />
|
<ClCompile Include="views\UserInterface.cpp" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ClInclude Include="controllers\Controller.h" />
|
<ClInclude Include="controllers\Controller.h" />
|
||||||
|
<ClInclude Include="core\events\EventManager.h" />
|
||||||
<ClInclude Include="core\patterns\Observer.h" />
|
<ClInclude Include="core\patterns\Observer.h" />
|
||||||
<ClInclude Include="core\patterns\Subject.h" />
|
<ClInclude Include="core\patterns\Subject.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\FileHeader.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\MappingInfo.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\RecordState.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\SerializedRecords.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\SharedMemory.h" />
|
||||||
|
<ClInclude Include="core\sharedmemory\TrackedRecord.h" />
|
||||||
<ClInclude Include="datastores\DataStore.h" />
|
<ClInclude Include="datastores\DataStore.h" />
|
||||||
<ClInclude Include="datastores\DataStoreLockGuard.h" />
|
<ClInclude Include="datastores\DataStoreLockGuard.h" />
|
||||||
<ClInclude Include="datastores\sharedmemory\FileHeader.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\MappingInfo.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\RecordState.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\SerializedRecords.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\SharedMemory.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\TrackedRecord.h" />
|
|
||||||
<ClInclude Include="factories\Factory.h" />
|
<ClInclude Include="factories\Factory.h" />
|
||||||
<ClInclude Include="models\ComboPackage.h" />
|
<ClInclude Include="models\ComboPackage.h" />
|
||||||
<ClInclude Include="models\InventoryItem.h" />
|
<ClInclude Include="models\InventoryItem.h" />
|
||||||
@@ -191,6 +194,7 @@
|
|||||||
<ClInclude Include="utilities\Vector.h" />
|
<ClInclude Include="utilities\Vector.h" />
|
||||||
<ClInclude Include="views\AdminMenu.h" />
|
<ClInclude Include="views\AdminMenu.h" />
|
||||||
<ClInclude Include="views\CustomerMenu.h" />
|
<ClInclude Include="views\CustomerMenu.h" />
|
||||||
|
<ClInclude Include="views\Menu.h" />
|
||||||
<ClInclude Include="views\MenuHelper.h" />
|
<ClInclude Include="views\MenuHelper.h" />
|
||||||
<ClInclude Include="views\TechnicianMenu.h" />
|
<ClInclude Include="views\TechnicianMenu.h" />
|
||||||
<ClInclude Include="views\UserInterface.h" />
|
<ClInclude Include="views\UserInterface.h" />
|
||||||
|
|||||||
+42
-24
@@ -64,11 +64,17 @@
|
|||||||
<Filter Include="Source Files\Core\Patterns">
|
<Filter Include="Source Files\Core\Patterns">
|
||||||
<UniqueIdentifier>{8057b93d-51a9-42df-b06e-01ce395f6308}</UniqueIdentifier>
|
<UniqueIdentifier>{8057b93d-51a9-42df-b06e-01ce395f6308}</UniqueIdentifier>
|
||||||
</Filter>
|
</Filter>
|
||||||
<Filter Include="Header Files\DataStores\SharedMemory">
|
<Filter Include="Header Files\Core\SharedMemory">
|
||||||
<UniqueIdentifier>{ec639004-44c6-4bd6-9963-077adde82b5f}</UniqueIdentifier>
|
<UniqueIdentifier>{d9da9793-fe6f-4914-bee3-99d5934da228}</UniqueIdentifier>
|
||||||
</Filter>
|
</Filter>
|
||||||
<Filter Include="Source Files\DataStores\SharedMemory">
|
<Filter Include="Source Files\Core\SharedMemory">
|
||||||
<UniqueIdentifier>{7aa8722e-adfa-466e-8211-de63f3b7892b}</UniqueIdentifier>
|
<UniqueIdentifier>{0769afb6-f57d-4ae3-a1cf-ceca6e606af0}</UniqueIdentifier>
|
||||||
|
</Filter>
|
||||||
|
<Filter Include="Header Files\Core\Events">
|
||||||
|
<UniqueIdentifier>{85029bdb-6941-41dc-a3a7-9e5841671d8c}</UniqueIdentifier>
|
||||||
|
</Filter>
|
||||||
|
<Filter Include="Source Files\Core\Events">
|
||||||
|
<UniqueIdentifier>{1050aca7-6f2c-4ccb-a446-db9c898c3599}</UniqueIdentifier>
|
||||||
</Filter>
|
</Filter>
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
@@ -144,8 +150,14 @@
|
|||||||
<ClCompile Include="models\ComboPackage.cpp">
|
<ClCompile Include="models\ComboPackage.cpp">
|
||||||
<Filter>Source Files\Models</Filter>
|
<Filter>Source Files\Models</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
<ClCompile Include="datastores\sharedmemory\SharedMemory.cpp">
|
<ClCompile Include="core\sharedmemory\SharedMemory.cpp">
|
||||||
<Filter>Source Files\DataStores\SharedMemory</Filter>
|
<Filter>Source Files\Core\SharedMemory</Filter>
|
||||||
|
</ClCompile>
|
||||||
|
<ClCompile Include="core\events\EventManager.cpp">
|
||||||
|
<Filter>Source Files\Core\Events</Filter>
|
||||||
|
</ClCompile>
|
||||||
|
<ClCompile Include="views\Menu.cpp">
|
||||||
|
<Filter>Source Files\Views</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
@@ -254,26 +266,32 @@
|
|||||||
<ClInclude Include="views\MenuHelper.h">
|
<ClInclude Include="views\MenuHelper.h">
|
||||||
<Filter>Header Files\Views</Filter>
|
<Filter>Header Files\Views</Filter>
|
||||||
</ClInclude>
|
</ClInclude>
|
||||||
<ClInclude Include="datastores\sharedmemory\FileHeader.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\sharedmemory\MappingInfo.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\sharedmemory\RecordState.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\sharedmemory\TrackedRecord.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\sharedmemory\SerializedRecords.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\sharedmemory\SharedMemory.h">
|
|
||||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
|
||||||
</ClInclude>
|
|
||||||
<ClInclude Include="datastores\DataStoreLockGuard.h">
|
<ClInclude Include="datastores\DataStoreLockGuard.h">
|
||||||
<Filter>Header Files\DataStores</Filter>
|
<Filter>Header Files\DataStores</Filter>
|
||||||
</ClInclude>
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\FileHeader.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\MappingInfo.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\RecordState.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\SerializedRecords.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\SharedMemory.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\sharedmemory\TrackedRecord.h">
|
||||||
|
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="core\events\EventManager.h">
|
||||||
|
<Filter>Header Files\Core\Events</Filter>
|
||||||
|
</ClInclude>
|
||||||
|
<ClInclude Include="views\Menu.h">
|
||||||
|
<Filter>Header Files\Views</Filter>
|
||||||
|
</ClInclude>
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
</Project>
|
</Project>
|
||||||
@@ -622,3 +622,16 @@ void Controller::shutdown()
|
|||||||
auto& dataStore = DataStore::getInstance();
|
auto& dataStore = DataStore::getInstance();
|
||||||
dataStore.shutdown();
|
dataStore.shutdown();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: registerEvents
|
||||||
|
Description: Registers menu event handles with the authentication
|
||||||
|
service.
|
||||||
|
Parameter: HANDLE accountDisabledEvent - account disabled event handle
|
||||||
|
HANDLE notificationAvailableEvent - notification event handle
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Controller::registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent)
|
||||||
|
{
|
||||||
|
m_authenticationManagementService.registerEvents(accountDisabledEvent, notificationAvailableEvent);
|
||||||
|
}
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ Date:19-May-2026
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
#include <windows.h>
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "AuthenticationManagementService.h"
|
#include "AuthenticationManagementService.h"
|
||||||
#include "Enums.h"
|
#include "Enums.h"
|
||||||
@@ -72,4 +73,5 @@ public:
|
|||||||
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
||||||
bool initialize();
|
bool initialize();
|
||||||
void shutdown();
|
void shutdown();
|
||||||
|
void registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent);
|
||||||
};
|
};
|
||||||
+225
@@ -0,0 +1,225 @@
|
|||||||
|
/*
|
||||||
|
File: EventManager.cpp
|
||||||
|
Description: Implementation file containing the method definitions of the
|
||||||
|
EventManager class, including listener management and
|
||||||
|
interprocess event publishing.
|
||||||
|
Author: Trenser
|
||||||
|
Date:15-Jun-2026
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <iostream>
|
||||||
|
#include <stdexcept>
|
||||||
|
#include "EventManager.h"
|
||||||
|
|
||||||
|
namespace
|
||||||
|
{
|
||||||
|
const std::string USER_DISABLED_EVENT = "userDisabled_";
|
||||||
|
|
||||||
|
const std::string NOTIFICATION_AVAILABLE_EVENT = "notificationAvailable_";
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: EventManager
|
||||||
|
Description: Constructs an EventManager instance with default values.
|
||||||
|
Parameter: None
|
||||||
|
Return type: None
|
||||||
|
*/
|
||||||
|
EventManager::EventManager()
|
||||||
|
:
|
||||||
|
m_userDisabledEvent(NULL),
|
||||||
|
m_notificationAvailableEvent(NULL),
|
||||||
|
m_shutdownEvent(NULL),
|
||||||
|
m_running(false) {}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: ~EventManager
|
||||||
|
Description: Destroys the EventManager and performs final cleanup.
|
||||||
|
Parameter: None
|
||||||
|
Return type: None
|
||||||
|
*/
|
||||||
|
EventManager::~EventManager()
|
||||||
|
{
|
||||||
|
shutdown();
|
||||||
|
if (m_listenerThread.joinable())
|
||||||
|
{
|
||||||
|
m_listenerThread.join();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: initialize
|
||||||
|
Description: Creates the user-specific events and starts the listener
|
||||||
|
thread.
|
||||||
|
Parameter: const std::string& userId - unique identifier of the user
|
||||||
|
std::function<void()> userDisabledCallback - callback for
|
||||||
|
user disable events
|
||||||
|
std::function<void()> notificationCallback - callback for
|
||||||
|
notification events
|
||||||
|
Return type: bool - true if initialization succeeds, false otherwise
|
||||||
|
*/
|
||||||
|
bool EventManager::initialize(const std::string& userId, std::function<void()> userDisabledCallback, std::function<void()> notificationCallback)
|
||||||
|
{
|
||||||
|
if (m_running.load())
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
m_userDisabledCallback = userDisabledCallback;
|
||||||
|
m_notificationCallback = notificationCallback;
|
||||||
|
m_userDisabledEvent = CreateEventA(NULL, FALSE, FALSE, (USER_DISABLED_EVENT + userId).c_str());
|
||||||
|
if (!m_userDisabledEvent)
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (GetLastError() == ERROR_ALREADY_EXISTS)
|
||||||
|
{
|
||||||
|
CloseHandle(m_userDisabledEvent);
|
||||||
|
m_userDisabledEvent = NULL;
|
||||||
|
throw std::runtime_error("Only one session allowed per user.");
|
||||||
|
}
|
||||||
|
m_notificationAvailableEvent = CreateEventA(NULL, FALSE, FALSE, (NOTIFICATION_AVAILABLE_EVENT + userId).c_str());
|
||||||
|
if (!m_notificationAvailableEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_userDisabledEvent);
|
||||||
|
m_userDisabledEvent = NULL;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
m_shutdownEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||||
|
if (!m_shutdownEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_userDisabledEvent);
|
||||||
|
CloseHandle(m_notificationAvailableEvent);
|
||||||
|
m_userDisabledEvent = NULL;
|
||||||
|
m_notificationAvailableEvent = NULL;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
m_running.store(true);
|
||||||
|
m_listenerThread = std::thread(&EventManager::run, this);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: shutdown
|
||||||
|
Description: Stops the listener thread and releases event resources.
|
||||||
|
Parameter: None
|
||||||
|
Return type: None
|
||||||
|
*/
|
||||||
|
void EventManager::shutdown()
|
||||||
|
{
|
||||||
|
if (!m_running.load())
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
m_running.store(false);
|
||||||
|
if (m_shutdownEvent)
|
||||||
|
{
|
||||||
|
SetEvent(m_shutdownEvent);
|
||||||
|
}
|
||||||
|
if (m_listenerThread.joinable())
|
||||||
|
{
|
||||||
|
if (std::this_thread::get_id() != m_listenerThread.get_id())
|
||||||
|
{
|
||||||
|
m_listenerThread.join();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (m_userDisabledEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_userDisabledEvent);
|
||||||
|
m_userDisabledEvent = NULL;
|
||||||
|
}
|
||||||
|
if (m_notificationAvailableEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_notificationAvailableEvent);
|
||||||
|
m_notificationAvailableEvent = NULL;
|
||||||
|
}
|
||||||
|
if (m_shutdownEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_shutdownEvent);
|
||||||
|
m_shutdownEvent = NULL;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: run
|
||||||
|
Description: Waits for and dispatches user-related events.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void EventManager::run()
|
||||||
|
{
|
||||||
|
HANDLE handles[3];
|
||||||
|
handles[0] = m_userDisabledEvent;
|
||||||
|
handles[1] = m_notificationAvailableEvent;
|
||||||
|
handles[2] = m_shutdownEvent;
|
||||||
|
while (m_running.load())
|
||||||
|
{
|
||||||
|
DWORD result = WaitForMultipleObjects(3, handles, FALSE, INFINITE);
|
||||||
|
switch (result)
|
||||||
|
{
|
||||||
|
case WAIT_OBJECT_0:
|
||||||
|
try
|
||||||
|
{
|
||||||
|
if (m_userDisabledCallback)
|
||||||
|
{
|
||||||
|
m_userDisabledCallback();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (const std::exception& exception)
|
||||||
|
{
|
||||||
|
std::cout << exception.what() << std::endl;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case WAIT_OBJECT_0 + 1:
|
||||||
|
try
|
||||||
|
{
|
||||||
|
if (m_notificationCallback)
|
||||||
|
{
|
||||||
|
m_notificationCallback();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (const std::exception& exception)
|
||||||
|
{
|
||||||
|
std::cout << exception.what() << std::endl;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case WAIT_OBJECT_0 + 2:
|
||||||
|
return;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: sendUserDisabledEvent
|
||||||
|
Description: Publishes a user disabled event for a specific user.
|
||||||
|
Parameter: const std::string& userId - target user identifier
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void EventManager::sendUserDisabledEvent(const std::string& userId)
|
||||||
|
{
|
||||||
|
HANDLE eventHandle = CreateEventA(NULL, FALSE, FALSE, (USER_DISABLED_EVENT + userId).c_str());
|
||||||
|
if (!eventHandle)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
SetEvent(eventHandle);
|
||||||
|
CloseHandle(eventHandle);
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: sendNotificationAvailableEvent
|
||||||
|
Description: Publishes a notification available event for a specific
|
||||||
|
user.
|
||||||
|
Parameter: const std::string& userId - target user identifier
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void EventManager::sendNotificationAvailableEvent(const std::string& userId)
|
||||||
|
{
|
||||||
|
HANDLE eventHandle = CreateEventA(NULL, FALSE, FALSE, (NOTIFICATION_AVAILABLE_EVENT + userId).c_str());
|
||||||
|
if (!eventHandle)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
SetEvent(eventHandle);
|
||||||
|
CloseHandle(eventHandle);
|
||||||
|
}
|
||||||
@@ -0,0 +1,37 @@
|
|||||||
|
/*
|
||||||
|
File: EventManager.h
|
||||||
|
Description: Header file declaring the EventManager class, which manages
|
||||||
|
user-specific interprocess events for user disable and
|
||||||
|
notification availability updates.
|
||||||
|
Author: Trenser
|
||||||
|
Date:15-Jun-2026
|
||||||
|
*/
|
||||||
|
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <windows.h>
|
||||||
|
#include <atomic>
|
||||||
|
#include <functional>
|
||||||
|
#include <string>
|
||||||
|
#include <thread>
|
||||||
|
|
||||||
|
class EventManager
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
HANDLE m_userDisabledEvent;
|
||||||
|
HANDLE m_notificationAvailableEvent;
|
||||||
|
HANDLE m_shutdownEvent;
|
||||||
|
std::atomic<bool> m_running;
|
||||||
|
std::thread m_listenerThread;
|
||||||
|
std::function<void()> m_userDisabledCallback;
|
||||||
|
std::function<void()> m_notificationCallback;
|
||||||
|
void run();
|
||||||
|
|
||||||
|
public:
|
||||||
|
EventManager();
|
||||||
|
~EventManager();
|
||||||
|
bool initialize(const std::string& userId, std::function<void()> userDisabledCallback, std::function<void()> notificationCallback);
|
||||||
|
void shutdown();
|
||||||
|
static void sendUserDisabledEvent(const std::string& userId);
|
||||||
|
static void sendNotificationAvailableEvent(const std::string& userId);
|
||||||
|
};
|
||||||
@@ -14,6 +14,7 @@ Date: 19-May-2026
|
|||||||
#include "FileHelper.h"
|
#include "FileHelper.h"
|
||||||
#include "ServiceBooking.h"
|
#include "ServiceBooking.h"
|
||||||
#include "JobCard.h"
|
#include "JobCard.h"
|
||||||
|
#include "Invoice.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: DataStore
|
Function: DataStore
|
||||||
@@ -450,6 +451,45 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<Invoice>>& DataStore::getInvoices()
|
util::Map<std::string, TrackedRecord<Invoice>>& DataStore::getInvoices()
|
||||||
{
|
{
|
||||||
|
auto& serviceBookings = getServiceBookings();
|
||||||
|
auto& inventoryItems = getInventoryItems();
|
||||||
|
util::Map<std::string, TrackedRecord<Invoice>> invoices = loadRecords<Invoice, SerializedInvoice>(m_invoices);
|
||||||
|
refreshCache(m_invoiceCache, invoices);
|
||||||
|
for (int iterator = 0; iterator < m_invoiceCache.getSize(); iterator++)
|
||||||
|
{
|
||||||
|
auto& trackedInvoice = m_invoiceCache.getValueAt(iterator);
|
||||||
|
Invoice* invoice = trackedInvoice.data;
|
||||||
|
if (!invoice)
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
const std::string& currentBookingId = invoice->getBookingId();
|
||||||
|
int currentBookingIndex = serviceBookings.find(currentBookingId);
|
||||||
|
if (currentBookingIndex == -1)
|
||||||
|
{
|
||||||
|
throw std::runtime_error("Invalid Service Booking Index.");
|
||||||
|
}
|
||||||
|
ServiceBooking* currentBooking = serviceBookings.getValueAt(currentBookingIndex).data;
|
||||||
|
auto& currentInventoryItemIds = invoice->getPartIDs();
|
||||||
|
util::Map<std::string, InventoryItem*> currentInventoryItems;
|
||||||
|
for (int iterator = 0; iterator < currentInventoryItemIds.getSize(); iterator++)
|
||||||
|
{
|
||||||
|
const std::string& currentItemId = currentInventoryItemIds[iterator];
|
||||||
|
int currentItemIndex = inventoryItems.find(currentItemId);
|
||||||
|
if (currentItemIndex == -1)
|
||||||
|
{
|
||||||
|
throw std::runtime_error("Invalid Inventory item id.");
|
||||||
|
}
|
||||||
|
InventoryItem* currentItem = inventoryItems.getValueAt(currentItemIndex).data;
|
||||||
|
if (!currentItem)
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
currentInventoryItems[currentItemId] = currentItem;
|
||||||
|
}
|
||||||
|
invoice->setBooking(currentBooking);
|
||||||
|
invoice->setParts(currentInventoryItems);
|
||||||
|
}
|
||||||
return m_invoiceCache;
|
return m_invoiceCache;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -624,6 +664,7 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
void DataStore::saveInvoices()
|
void DataStore::saveInvoices()
|
||||||
{
|
{
|
||||||
|
saveRecords<Invoice, SerializedInvoice>(m_invoices, m_invoiceCache);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -739,5 +780,4 @@ bool DataStore::unlockDataStore()
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return ReleaseMutex(m_globalMutex) != 0;
|
return ReleaseMutex(m_globalMutex) != 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -9,6 +9,7 @@ Date: 19-May-2026
|
|||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "Invoice.h"
|
#include "Invoice.h"
|
||||||
#include "Factory.h"
|
#include "Factory.h"
|
||||||
#include "InventoryItem.h"
|
#include "InventoryItem.h"
|
||||||
@@ -34,7 +35,8 @@ Invoice::Invoice()
|
|||||||
m_discountPercentage(0.0),
|
m_discountPercentage(0.0),
|
||||||
m_totalAmount(0.0),
|
m_totalAmount(0.0),
|
||||||
m_paymentMethod(util::PaymentMode()),
|
m_paymentMethod(util::PaymentMode()),
|
||||||
m_status(util::PaymentStatus()) {}
|
m_status(util::PaymentStatus()) {
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: Invoice
|
Function: Invoice
|
||||||
@@ -57,16 +59,16 @@ Returns:
|
|||||||
Invoice::Invoice(
|
Invoice::Invoice(
|
||||||
const std::string& bookingId,
|
const std::string& bookingId,
|
||||||
ServiceBooking* booking,
|
ServiceBooking* booking,
|
||||||
const util::Timestamp& invoiceDate,
|
const util::Timestamp& invoiceDate,
|
||||||
double laborCost,
|
double laborCost,
|
||||||
const util::Map<std::string, InventoryItem*>& parts,
|
const util::Map<std::string, InventoryItem*>& parts,
|
||||||
double partsCost,
|
double partsCost,
|
||||||
double discountPercentage,
|
double discountPercentage,
|
||||||
double totalAmount,
|
double totalAmount,
|
||||||
const util::Timestamp& paymentDate,
|
const util::Timestamp& paymentDate,
|
||||||
util::PaymentMode paymentMethod,
|
util::PaymentMode paymentMethod,
|
||||||
util::PaymentStatus status
|
util::PaymentStatus status
|
||||||
)
|
)
|
||||||
: m_id("INV" + std::to_string(++m_uid)),
|
: m_id("INV" + std::to_string(++m_uid)),
|
||||||
m_bookingId(bookingId),
|
m_bookingId(bookingId),
|
||||||
m_booking(booking),
|
m_booking(booking),
|
||||||
@@ -78,7 +80,7 @@ Invoice::Invoice(
|
|||||||
m_totalAmount(totalAmount),
|
m_totalAmount(totalAmount),
|
||||||
m_paymentDate(paymentDate),
|
m_paymentDate(paymentDate),
|
||||||
m_paymentMethod(paymentMethod),
|
m_paymentMethod(paymentMethod),
|
||||||
m_status(status)
|
m_status(status)
|
||||||
{
|
{
|
||||||
int numberOfParts = m_parts.getSize();
|
int numberOfParts = m_parts.getSize();
|
||||||
auto partPointers = m_parts.getValues();
|
auto partPointers = m_parts.getValues();
|
||||||
@@ -473,100 +475,50 @@ static util::Vector<std::string> getPartIDsAsVector(const std::string& partIDsSt
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the invoice into a CSV-formatted string.
|
Description: Serializes the Invoice object into a SerializedInvoice record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized invoice record
|
- SerializedInvoice: Serialized representation of the invoice
|
||||||
*/
|
*/
|
||||||
std::string Invoice::serialize() const
|
SerializedInvoice Invoice::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedInvoice;
|
SerializedInvoice serialized = {};
|
||||||
serializedInvoice << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< m_bookingId << ','
|
strcpy_s(serialized.bookingId, sizeof(serialized.bookingId), m_bookingId.c_str());
|
||||||
<< m_invoiceDate.toString() << ','
|
strcpy_s(serialized.partIDs, sizeof(serialized.partIDs), getPartIDsAsString(m_partIDs).c_str());
|
||||||
<< m_laborCost << ','
|
serialized.invoiceDate = m_invoiceDate;
|
||||||
<< getPartIDsAsString(m_partIDs) << ','
|
serialized.laborCost = m_laborCost;
|
||||||
<< m_partsCost << ','
|
serialized.partsCost = m_partsCost;
|
||||||
<< m_discountPercentage << ','
|
serialized.discountPercentage = m_discountPercentage;
|
||||||
<< m_totalAmount << ','
|
serialized.totalAmount = m_totalAmount;
|
||||||
<< m_paymentDate.toString() << ','
|
serialized.paymentDate = m_paymentDate;
|
||||||
<< util::getPaymentModeString(m_paymentMethod) << ','
|
serialized.paymentMethod = m_paymentMethod;
|
||||||
<< util::getPaymentStatusString(m_status);
|
serialized.status = m_status;
|
||||||
return serializedInvoice.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into an Invoice object.
|
Description: Deserializes a SerializedInvoice record into an Invoice object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized invoice record
|
- serializedInvoice: const SerializedInvoice&, serialized invoice record
|
||||||
Returns:
|
Returns:
|
||||||
- Invoice*: Pointer to the deserialized Invoice object
|
- Invoice*: Pointer to the deserialized Invoice object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if data is invalid
|
|
||||||
*/
|
*/
|
||||||
Invoice* Invoice::deserialize(const std::string& record)
|
Invoice* Invoice::deserialize(const SerializedInvoice& serializedInvoice)
|
||||||
{
|
{
|
||||||
std::string id, bookingId;
|
util::Vector<std::string> partIDs = getPartIDsAsVector(serializedInvoice.partIDs);
|
||||||
std::string invoiceDateString, laborCostString, partIDsString;
|
|
||||||
std::string partsCostString, discountPercentageString, totalAmountString;
|
|
||||||
std::string paymentDateString, paymentMethodString, statusString;
|
|
||||||
double laborCost, partsCost, discountPercentage, totalAmount;
|
|
||||||
std::istringstream serializedInvoice(record);
|
|
||||||
getline(serializedInvoice, id, ',');
|
|
||||||
getline(serializedInvoice, bookingId, ',');
|
|
||||||
getline(serializedInvoice, invoiceDateString, ',');
|
|
||||||
getline(serializedInvoice, laborCostString, ',');
|
|
||||||
getline(serializedInvoice, partIDsString, ',');
|
|
||||||
getline(serializedInvoice, partsCostString, ',');
|
|
||||||
getline(serializedInvoice, discountPercentageString, ',');
|
|
||||||
getline(serializedInvoice, totalAmountString, ',');
|
|
||||||
getline(serializedInvoice, paymentDateString, ',');
|
|
||||||
getline(serializedInvoice, paymentMethodString, ',');
|
|
||||||
getline(serializedInvoice, statusString, ',');
|
|
||||||
util::Timestamp invoiceDate;
|
|
||||||
util::Timestamp paymentDate;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
invoiceDate = util::Timestamp::fromString(invoiceDateString);
|
|
||||||
paymentDate = util::Timestamp::fromString(paymentDateString);
|
|
||||||
laborCost = std::stod(laborCostString);
|
|
||||||
partsCost = std::stod(partsCostString);
|
|
||||||
discountPercentage = std::stod(discountPercentageString);
|
|
||||||
totalAmount = std::stod(totalAmountString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid invoice data");
|
|
||||||
}
|
|
||||||
util::Vector<std::string> partIDs = getPartIDsAsVector(partIDsString);
|
|
||||||
util::PaymentMode paymentMethod = util::getPaymentMode(paymentMethodString);
|
|
||||||
util::PaymentStatus status = util::getPaymentStatus(statusString);
|
|
||||||
return Factory::getObject<Invoice>(
|
return Factory::getObject<Invoice>(
|
||||||
id,
|
serializedInvoice.id,
|
||||||
bookingId,
|
serializedInvoice.bookingId,
|
||||||
invoiceDate,
|
serializedInvoice.invoiceDate,
|
||||||
partIDs,
|
partIDs,
|
||||||
laborCost,
|
serializedInvoice.laborCost,
|
||||||
partsCost,
|
serializedInvoice.partsCost,
|
||||||
discountPercentage,
|
serializedInvoice.discountPercentage,
|
||||||
totalAmount,
|
serializedInvoice.totalAmount,
|
||||||
paymentDate,
|
serializedInvoice.paymentDate,
|
||||||
paymentMethod,
|
serializedInvoice.paymentMethod,
|
||||||
status
|
serializedInvoice.status);
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for invoice serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,BookingID,InvoiceDate,LaborCost,PartIDs,PartsCost,DiscountPercentage,TotalAmount,PaymentDate,PaymentMethod,Status")
|
|
||||||
*/
|
|
||||||
std::string Invoice::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,BookingID,InvoiceDate,LaborCost,PartIDs,PartsCost,DiscountPercentage,TotalAmount,PaymentDate,PaymentMethod,Status";
|
|
||||||
}
|
}
|
||||||
@@ -6,7 +6,6 @@ Author: Trenser
|
|||||||
Date: 19-May-2026
|
Date: 19-May-2026
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "Map.h"
|
#include "Map.h"
|
||||||
@@ -16,6 +15,7 @@ Date: 19-May-2026
|
|||||||
|
|
||||||
class ServiceBooking;
|
class ServiceBooking;
|
||||||
class InventoryItem;
|
class InventoryItem;
|
||||||
|
struct SerializedInvoice;
|
||||||
|
|
||||||
class Invoice
|
class Invoice
|
||||||
{
|
{
|
||||||
@@ -39,14 +39,14 @@ public:
|
|||||||
Invoice(
|
Invoice(
|
||||||
const std::string& bookingId,
|
const std::string& bookingId,
|
||||||
ServiceBooking* booking,
|
ServiceBooking* booking,
|
||||||
const util::Timestamp& invoiceDate,
|
const util::Timestamp& invoiceDate,
|
||||||
double laborCost,
|
double laborCost,
|
||||||
const util::Map<std::string,InventoryItem*>& parts,
|
const util::Map<std::string, InventoryItem*>& parts,
|
||||||
double partsCost,
|
double partsCost,
|
||||||
double discountPercentage,
|
double discountPercentage,
|
||||||
double totalAmount,
|
double totalAmount,
|
||||||
const util::Timestamp& paymentDate,
|
const util::Timestamp& paymentDate,
|
||||||
util::PaymentMode paymentMethod,
|
util::PaymentMode paymentMethod,
|
||||||
util::PaymentStatus status
|
util::PaymentStatus status
|
||||||
);
|
);
|
||||||
Invoice(
|
Invoice(
|
||||||
@@ -87,7 +87,6 @@ public:
|
|||||||
void setPaymentDate(const util::Timestamp& paymentDate);
|
void setPaymentDate(const util::Timestamp& paymentDate);
|
||||||
void setPaymentMethod(util::PaymentMode paymentMethod);
|
void setPaymentMethod(util::PaymentMode paymentMethod);
|
||||||
void setStatus(util::PaymentStatus status);
|
void setStatus(util::PaymentStatus status);
|
||||||
std::string serialize() const;
|
SerializedInvoice serialize() const;
|
||||||
static Invoice* deserialize(const std::string&);
|
static Invoice* deserialize(const SerializedInvoice&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
+36
@@ -14,6 +14,9 @@ Date:19-May-2026
|
|||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
|
|
||||||
User* AuthenticationManagementService::m_authenticatedUser = nullptr;
|
User* AuthenticationManagementService::m_authenticatedUser = nullptr;
|
||||||
|
EventManager AuthenticationManagementService::m_eventManager;
|
||||||
|
HANDLE AuthenticationManagementService::m_accountDisabledEvent = NULL;
|
||||||
|
HANDLE AuthenticationManagementService::m_notificationsAvailableEvent = NULL;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: login
|
Function: login
|
||||||
@@ -37,6 +40,22 @@ bool AuthenticationManagementService::login(const std::string& username, const s
|
|||||||
if (password == user->getPassword())
|
if (password == user->getPassword())
|
||||||
{
|
{
|
||||||
m_authenticatedUser = user;
|
m_authenticatedUser = user;
|
||||||
|
m_eventManager.initialize(
|
||||||
|
user->getId(),
|
||||||
|
[]()
|
||||||
|
{
|
||||||
|
if (m_accountDisabledEvent)
|
||||||
|
{
|
||||||
|
SetEvent(m_accountDisabledEvent);
|
||||||
|
}
|
||||||
|
},
|
||||||
|
[]()
|
||||||
|
{
|
||||||
|
if (m_notificationsAvailableEvent)
|
||||||
|
{
|
||||||
|
SetEvent(m_notificationsAvailableEvent);
|
||||||
|
}
|
||||||
|
});
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
@@ -65,7 +84,10 @@ Return type: void
|
|||||||
*/
|
*/
|
||||||
void AuthenticationManagementService::logout()
|
void AuthenticationManagementService::logout()
|
||||||
{
|
{
|
||||||
|
m_eventManager.shutdown();
|
||||||
m_authenticatedUser = nullptr;
|
m_authenticatedUser = nullptr;
|
||||||
|
m_accountDisabledEvent = NULL;
|
||||||
|
m_notificationsAvailableEvent = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -92,3 +114,17 @@ void AuthenticationManagementService::changePassword(const std::string& newPassw
|
|||||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||||
m_dataStore.saveUsers();
|
m_dataStore.saveUsers();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: registerEvents
|
||||||
|
Description: Registers menu event handles used to notify the active
|
||||||
|
menu of account disable and notification events.
|
||||||
|
Parameter: HANDLE accountDisabledEvent - account disabled event handle
|
||||||
|
HANDLE notificationAvailableEvent - notification event handle
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void AuthenticationManagementService::registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent)
|
||||||
|
{
|
||||||
|
m_accountDisabledEvent = accountDisabledEvent;
|
||||||
|
m_notificationsAvailableEvent = notificationAvailableEvent;
|
||||||
|
}
|
||||||
|
|||||||
+6
@@ -9,6 +9,8 @@ Date:19-May-2026
|
|||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include <string>
|
#include <string>
|
||||||
|
#include <windows.h>
|
||||||
|
#include "EventManager.h"
|
||||||
#include "DataStore.h"
|
#include "DataStore.h"
|
||||||
|
|
||||||
class User;
|
class User;
|
||||||
@@ -17,6 +19,9 @@ class AuthenticationManagementService
|
|||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
static User* m_authenticatedUser;
|
static User* m_authenticatedUser;
|
||||||
|
static EventManager m_eventManager;
|
||||||
|
static HANDLE m_accountDisabledEvent;
|
||||||
|
static HANDLE m_notificationsAvailableEvent;
|
||||||
DataStore& m_dataStore;
|
DataStore& m_dataStore;
|
||||||
public:
|
public:
|
||||||
AuthenticationManagementService() : m_dataStore(DataStore::getInstance()) {}
|
AuthenticationManagementService() : m_dataStore(DataStore::getInstance()) {}
|
||||||
@@ -24,4 +29,5 @@ public:
|
|||||||
void logout();
|
void logout();
|
||||||
void changePassword(const std::string& newPassword);
|
void changePassword(const std::string& newPassword);
|
||||||
User* getAuthenticatedUser();
|
User* getAuthenticatedUser();
|
||||||
|
void registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent);
|
||||||
};
|
};
|
||||||
|
|||||||
+2
@@ -19,6 +19,7 @@ Date: 22-May-2026
|
|||||||
#include "Utility.h"
|
#include "Utility.h"
|
||||||
#include "Vector.h"
|
#include "Vector.h"
|
||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
|
#include "EventManager.h"
|
||||||
|
|
||||||
util::Map<std::string, User*> InventoryManagementService::m_observers{};
|
util::Map<std::string, User*> InventoryManagementService::m_observers{};
|
||||||
|
|
||||||
@@ -281,5 +282,6 @@ void InventoryManagementService::sendNotification(User* user, const std::string&
|
|||||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||||
m_dataStore.saveNotifications();
|
m_dataStore.saveNotifications();
|
||||||
|
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+38
-20
@@ -15,12 +15,14 @@ Date: 20-May-2026
|
|||||||
#include "Invoice.h"
|
#include "Invoice.h"
|
||||||
#include "JobCard.h"
|
#include "JobCard.h"
|
||||||
#include "PaymentManagementService.h"
|
#include "PaymentManagementService.h"
|
||||||
|
#include "DataStoreLockGuard.h"
|
||||||
#include "Service.h"
|
#include "Service.h"
|
||||||
#include "ServiceBooking.h"
|
#include "ServiceBooking.h"
|
||||||
#include "Timestamp.h"
|
#include "Timestamp.h"
|
||||||
#include "User.h"
|
#include "User.h"
|
||||||
#include "Utility.h"
|
#include "Utility.h"
|
||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
|
#include "EventManager.h"
|
||||||
|
|
||||||
util::Map<std::string, User*> PaymentManagementService::m_observers{};
|
util::Map<std::string, User*> PaymentManagementService::m_observers{};
|
||||||
|
|
||||||
@@ -108,6 +110,7 @@ void PaymentManagementService::sendNotification(User* user, const std::string& t
|
|||||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||||
m_dataStore.saveNotifications();
|
m_dataStore.saveNotifications();
|
||||||
|
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -121,11 +124,12 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
void PaymentManagementService::sendPaymentReminders()
|
void PaymentManagementService::sendPaymentReminders()
|
||||||
{
|
{
|
||||||
auto& invoicesMap = m_dataStore.getInvoices();
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
int invoicesMapSize = invoicesMap.getSize();
|
auto& trackedInvoicesMap = m_dataStore.getInvoices();
|
||||||
|
int invoicesMapSize = trackedInvoicesMap.getSize();
|
||||||
for (int index = 0; index < invoicesMapSize; index++)
|
for (int index = 0; index < invoicesMapSize; index++)
|
||||||
{
|
{
|
||||||
const Invoice* invoice = invoicesMap.getValueAt(index);
|
const Invoice* invoice = trackedInvoicesMap.getValueAt(index).data;
|
||||||
if (invoice && invoice->getStatus() == util::PaymentStatus::PENDING)
|
if (invoice && invoice->getStatus() == util::PaymentStatus::PENDING)
|
||||||
{
|
{
|
||||||
util::Timestamp invoiceCreationTimestamp = invoice->getInvoiceDate();
|
util::Timestamp invoiceCreationTimestamp = invoice->getInvoiceDate();
|
||||||
@@ -181,6 +185,7 @@ Throws:
|
|||||||
*/
|
*/
|
||||||
void PaymentManagementService::generateInvoice(ServiceBooking* booking)
|
void PaymentManagementService::generateInvoice(ServiceBooking* booking)
|
||||||
{
|
{
|
||||||
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
if (!booking)
|
if (!booking)
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Invoice generation failed: booking is null.");
|
throw std::runtime_error("Invoice generation failed: booking is null.");
|
||||||
@@ -190,10 +195,10 @@ void PaymentManagementService::generateInvoice(ServiceBooking* booking)
|
|||||||
std::string bookingID = booking->getId();
|
std::string bookingID = booking->getId();
|
||||||
util::Map<std::string, Service*> servicesInTheBookedService = booking->getServices();
|
util::Map<std::string, Service*> servicesInTheBookedService = booking->getServices();
|
||||||
util::Map<std::string, InventoryItem*> completeInventoryItemMapOfBooking;
|
util::Map<std::string, InventoryItem*> completeInventoryItemMapOfBooking;
|
||||||
util::Map<std::string, JobCard*> currentJobCards = m_dataStore.getJobCards();
|
auto& currentTrackedJobCards = m_dataStore.getJobCards();
|
||||||
for (int iterator = 0; iterator < currentJobCards.getSize(); iterator++)
|
for (int iterator = 0; iterator < currentTrackedJobCards.getSize(); iterator++)
|
||||||
{
|
{
|
||||||
JobCard* currentJobCard = currentJobCards.getValueAt(iterator);
|
JobCard* currentJobCard = currentTrackedJobCards.getValueAt(iterator).data;
|
||||||
util::ServiceJobStatus currentJobCardStatus = currentJobCard->getStatus();
|
util::ServiceJobStatus currentJobCardStatus = currentJobCard->getStatus();
|
||||||
if (currentJobCard->getBookingId() == bookingID && currentJobCardStatus != util::ServiceJobStatus::CANCELLED && currentJobCardStatus != util::ServiceJobStatus::COMPLETED)
|
if (currentJobCard->getBookingId() == bookingID && currentJobCardStatus != util::ServiceJobStatus::CANCELLED && currentJobCardStatus != util::ServiceJobStatus::COMPLETED)
|
||||||
{
|
{
|
||||||
@@ -213,8 +218,9 @@ void PaymentManagementService::generateInvoice(ServiceBooking* booking)
|
|||||||
totalServiceCost = totalLaborCost + totalPartsCost;
|
totalServiceCost = totalLaborCost + totalPartsCost;
|
||||||
totalServiceCost -= (totalServiceCost * (discountPercentage / 100));
|
totalServiceCost -= (totalServiceCost * (discountPercentage / 100));
|
||||||
Invoice* invoice = Factory::getObject<Invoice>(bookingID, booking, util::Timestamp(), totalLaborCost, completeInventoryItemMapOfBooking, totalPartsCost, discountPercentage, totalServiceCost, util::Timestamp(), util::PaymentMode::NOTSET, util::PaymentStatus::PENDING);
|
Invoice* invoice = Factory::getObject<Invoice>(bookingID, booking, util::Timestamp(), totalLaborCost, completeInventoryItemMapOfBooking, totalPartsCost, discountPercentage, totalServiceCost, util::Timestamp(), util::PaymentMode::NOTSET, util::PaymentStatus::PENDING);
|
||||||
util::Map<std::string, Invoice*>& currentInvoices = m_dataStore.getInvoices();
|
auto& currentTrackedInvoices = m_dataStore.getInvoices();
|
||||||
currentInvoices.insert(invoice->getId(), invoice);
|
currentTrackedInvoices.insert(invoice->getId(), util::createNewRecord(invoice));
|
||||||
|
m_dataStore.saveInvoices();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -227,11 +233,12 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
util::Map<std::string, Invoice*> PaymentManagementService::getInvoices(const std::string& customerID)
|
util::Map<std::string, Invoice*> PaymentManagementService::getInvoices(const std::string& customerID)
|
||||||
{
|
{
|
||||||
util::Map<std::string, Invoice*>& currentInvoices = m_dataStore.getInvoices();
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
|
auto& currentTrackedInvoices = m_dataStore.getInvoices();
|
||||||
util::Map<std::string, Invoice*> currentUserInvoices;
|
util::Map<std::string, Invoice*> currentUserInvoices;
|
||||||
for (int iterator = 0; iterator < currentInvoices.getSize(); iterator++)
|
for (int iterator = 0; iterator < currentTrackedInvoices.getSize(); iterator++)
|
||||||
{
|
{
|
||||||
Invoice* currentInvoice = currentInvoices.getValueAt(iterator);
|
Invoice* currentInvoice = currentTrackedInvoices.getValueAt(iterator).data;
|
||||||
if (currentInvoice->getBooking()->getCustomerId() == customerID)
|
if (currentInvoice->getBooking()->getCustomerId() == customerID)
|
||||||
{
|
{
|
||||||
currentUserInvoices.insert(currentInvoice->getId(), currentInvoice);
|
currentUserInvoices.insert(currentInvoice->getId(), currentInvoice);
|
||||||
@@ -254,11 +261,13 @@ Throws:
|
|||||||
*/
|
*/
|
||||||
void PaymentManagementService::completePayment(const std::string& invoiceID, util::PaymentMode paymentMode)
|
void PaymentManagementService::completePayment(const std::string& invoiceID, util::PaymentMode paymentMode)
|
||||||
{
|
{
|
||||||
auto& currentInvoices = m_dataStore.getInvoices();
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
int invoiceIndex = currentInvoices.find(invoiceID);
|
auto& currentTrackedInvoices = m_dataStore.getInvoices();
|
||||||
|
int invoiceIndex = currentTrackedInvoices.find(invoiceID);
|
||||||
if (invoiceIndex != -1)
|
if (invoiceIndex != -1)
|
||||||
{
|
{
|
||||||
Invoice* invoice = currentInvoices.getValueAt(invoiceIndex);
|
auto& trackedInvoice = currentTrackedInvoices.getValueAt(invoiceIndex);
|
||||||
|
Invoice* invoice = trackedInvoice.data;
|
||||||
if (invoice && invoice->getStatus() != util::PaymentStatus::PAID)
|
if (invoice && invoice->getStatus() != util::PaymentStatus::PAID)
|
||||||
{
|
{
|
||||||
User* currentUser = invoice->getBooking()->getCustomer();
|
User* currentUser = invoice->getBooking()->getCustomer();
|
||||||
@@ -269,12 +278,14 @@ void PaymentManagementService::completePayment(const std::string& invoiceID, uti
|
|||||||
title = "Payment successful";
|
title = "Payment successful";
|
||||||
message = "Payment successful for Invoice ID " + invoiceID;
|
message = "Payment successful for Invoice ID " + invoiceID;
|
||||||
sendNotification(currentUser, title, message);
|
sendNotification(currentUser, title, message);
|
||||||
|
trackedInvoice.state = RecordState::MODIFIED;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Payment failed: invalid invoice ID.");
|
throw std::runtime_error("Payment failed: invalid invoice ID.");
|
||||||
}
|
}
|
||||||
|
m_dataStore.saveInvoices();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -283,11 +294,14 @@ Description: Provides access to all invoices stored in the data store.
|
|||||||
Parameters:
|
Parameters:
|
||||||
- none
|
- none
|
||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, Invoice*>&: Map of invoice IDs to invoice objects
|
- util::Map<std::string, Invoice*>: Map of invoice IDs to invoice objects
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, Invoice*>& PaymentManagementService::getAllInvoices()
|
util::Map<std::string, Invoice*> PaymentManagementService::getAllInvoices()
|
||||||
{
|
{
|
||||||
return m_dataStore.getInvoices();
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
|
util::Map<std::string, Invoice*> invoices;
|
||||||
|
invoices = util::getObjects(m_dataStore.getInvoices());
|
||||||
|
return invoices;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -303,20 +317,24 @@ Throws:
|
|||||||
*/
|
*/
|
||||||
void PaymentManagementService::confirmPayment(const std::string& invoiceID)
|
void PaymentManagementService::confirmPayment(const std::string& invoiceID)
|
||||||
{
|
{
|
||||||
auto& currentInvoices = m_dataStore.getInvoices();
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
int invoiceIndex = currentInvoices.find(invoiceID);
|
auto& currentTrackedInvoices = m_dataStore.getInvoices();
|
||||||
|
int invoiceIndex = currentTrackedInvoices.find(invoiceID);
|
||||||
if (invoiceIndex == -1)
|
if (invoiceIndex == -1)
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Payment confirmation failed: invalid invoice ID.");
|
throw std::runtime_error("Payment confirmation failed: invalid invoice ID.");
|
||||||
}
|
}
|
||||||
Invoice* invoice = currentInvoices.getValueAt(invoiceIndex);
|
auto& trackedInvoice = currentTrackedInvoices.getValueAt(invoiceIndex);
|
||||||
|
Invoice* invoice = trackedInvoice.data;
|
||||||
if (!invoice || invoice->getStatus() != util::PaymentStatus::PAID)
|
if (!invoice || invoice->getStatus() != util::PaymentStatus::PAID)
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Payment confirmation failed: invoice is not awaiting confirmation.");
|
throw std::runtime_error("Payment confirmation failed: invoice is not awaiting confirmation.");
|
||||||
}
|
}
|
||||||
User* currentUser = invoice->getBooking()->getCustomer();
|
User* currentUser = invoice->getBooking()->getCustomer();
|
||||||
invoice->setStatus(util::PaymentStatus::COMPLETED);
|
invoice->setStatus(util::PaymentStatus::COMPLETED);
|
||||||
|
trackedInvoice.state = RecordState::MODIFIED;
|
||||||
std::string title = "Payment Confirmed";
|
std::string title = "Payment Confirmed";
|
||||||
std::string message = "Payment Confirmed for Invoice ID " + invoiceID;
|
std::string message = "Payment Confirmed for Invoice ID " + invoiceID;
|
||||||
sendNotification(currentUser, title, message);
|
sendNotification(currentUser, title, message);
|
||||||
|
m_dataStore.saveInvoices();
|
||||||
}
|
}
|
||||||
+1
-1
@@ -27,7 +27,7 @@ public:
|
|||||||
void generateInvoice(ServiceBooking* booking);
|
void generateInvoice(ServiceBooking* booking);
|
||||||
util::Map<std::string, Invoice*> getInvoices(const std::string& customerID);
|
util::Map<std::string, Invoice*> getInvoices(const std::string& customerID);
|
||||||
void completePayment(const std::string& invoiceID, util::PaymentMode paymentMode);
|
void completePayment(const std::string& invoiceID, util::PaymentMode paymentMode);
|
||||||
util::Map<std::string, Invoice*>& getAllInvoices();
|
util::Map<std::string, Invoice*> getAllInvoices();
|
||||||
void confirmPayment(const std::string& invoiceID);
|
void confirmPayment(const std::string& invoiceID);
|
||||||
void sendPaymentReminders();
|
void sendPaymentReminders();
|
||||||
void sendNotification(User* user, const std::string& title, const std::string& message) override;
|
void sendNotification(User* user, const std::string& title, const std::string& message) override;
|
||||||
|
|||||||
+2
@@ -27,6 +27,7 @@ Date:19-May-2026
|
|||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
#include "Utility.h"
|
#include "Utility.h"
|
||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
|
#include "EventManager.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: purchaseService
|
Function: purchaseService
|
||||||
@@ -199,6 +200,7 @@ void ServiceManagementService::sendNotification(User* user, const std::string& t
|
|||||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||||
m_dataStore.saveNotifications();
|
m_dataStore.saveNotifications();
|
||||||
|
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|||||||
+27
-18
@@ -22,6 +22,7 @@ Date:19-May-2026
|
|||||||
#include "Utility.h"
|
#include "Utility.h"
|
||||||
#include "TrackedRecord.h"
|
#include "TrackedRecord.h"
|
||||||
#include "DataStoreLockGuard.h"
|
#include "DataStoreLockGuard.h"
|
||||||
|
#include "EventManager.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: ensureAdminExists
|
Function: ensureAdminExists
|
||||||
@@ -267,30 +268,38 @@ void UserManagementService::removeUser(const std::string& userID)
|
|||||||
InventoryManagementService inventoryManagementService;
|
InventoryManagementService inventoryManagementService;
|
||||||
PaymentManagementService paymentManagementService;
|
PaymentManagementService paymentManagementService;
|
||||||
ServiceManagementService serviceManagementService;
|
ServiceManagementService serviceManagementService;
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
std::string removedUserID;
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
|
||||||
int index = trackedUsersMap.find(userID);
|
|
||||||
if (index != -1)
|
|
||||||
{
|
{
|
||||||
User* user = trackedUsersMap.getValueAt(index).data;
|
DataStoreLockGuard lock(m_dataStore);
|
||||||
if (user != nullptr)
|
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||||
|
int index = trackedUsersMap.find(userID);
|
||||||
|
if (index != -1)
|
||||||
{
|
{
|
||||||
if (user->getUserType() == util::UserType::CUSTOMER)
|
User* user = trackedUsersMap.getValueAt(index).data;
|
||||||
|
if (user != nullptr)
|
||||||
{
|
{
|
||||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
if (user->getUserType() == util::UserType::CUSTOMER)
|
||||||
|
{
|
||||||
|
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||||
|
}
|
||||||
|
if (user->getUserType() == util::UserType::TECHNICIAN)
|
||||||
|
{
|
||||||
|
serviceManagementService.cancelTechnicianJobs(userID);
|
||||||
|
}
|
||||||
|
inventoryManagementService.detach(user);
|
||||||
|
paymentManagementService.detach(user);
|
||||||
|
serviceManagementService.detach(user);
|
||||||
|
user->setState(util::State::INACTIVE);
|
||||||
|
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||||
|
removedUserID = user->getId();
|
||||||
|
m_dataStore.saveUsers();
|
||||||
}
|
}
|
||||||
if (user->getUserType() == util::UserType::TECHNICIAN)
|
|
||||||
{
|
|
||||||
serviceManagementService.cancelTechnicianJobs(userID);
|
|
||||||
}
|
|
||||||
inventoryManagementService.detach(user);
|
|
||||||
paymentManagementService.detach(user);
|
|
||||||
serviceManagementService.detach(user);
|
|
||||||
user->setState(util::State::INACTIVE);
|
|
||||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
|
||||||
m_dataStore.saveUsers();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (!removedUserID.empty())
|
||||||
|
{
|
||||||
|
EventManager::sendUserDisabledEvent(removedUserID);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|||||||
@@ -30,10 +30,16 @@ Return type: void
|
|||||||
*/
|
*/
|
||||||
void AdminMenu::showMenu()
|
void AdminMenu::showMenu()
|
||||||
{
|
{
|
||||||
|
startEventListener();
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
break;
|
||||||
|
}
|
||||||
int choice;
|
int choice;
|
||||||
util::clear();
|
util::clear();
|
||||||
std::cout << "Admin Menu"
|
std::cout << "Admin Menu"
|
||||||
@@ -68,6 +74,7 @@ void AdminMenu::showMenu()
|
|||||||
util::pressEnter();
|
util::pressEnter();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
stopEventListener();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -78,6 +85,11 @@ Return type: bool - true if menu continues, false if logout
|
|||||||
*/
|
*/
|
||||||
bool AdminMenu::handleOperation(int choice)
|
bool AdminMenu::handleOperation(int choice)
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
switch (choice)
|
switch (choice)
|
||||||
{
|
{
|
||||||
case 1:
|
case 1:
|
||||||
@@ -141,6 +153,19 @@ bool AdminMenu::handleOperation(int choice)
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: handleNotificationEvent
|
||||||
|
Description: Retrieves and displays the latest notification for the
|
||||||
|
currently logged in admin.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void AdminMenu::handleNotificationEvent()
|
||||||
|
{
|
||||||
|
auto notifications = m_controller.getNotifications();
|
||||||
|
displayNewNotification(notifications);
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: logout
|
Function: logout
|
||||||
Description: Logs out the currently authenticated admin user.
|
Description: Logs out the currently authenticated admin user.
|
||||||
|
|||||||
@@ -9,12 +9,13 @@ Date:19-May-2026
|
|||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include "Controller.h"
|
#include "Controller.h"
|
||||||
|
#include "Menu.h"
|
||||||
|
|
||||||
class AdminMenu
|
class AdminMenu : public Menu
|
||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
Controller m_controller;
|
|
||||||
bool handleOperation(int choice);
|
bool handleOperation(int choice);
|
||||||
|
void handleNotificationEvent() override;
|
||||||
public:
|
public:
|
||||||
void showMenu();
|
void showMenu();
|
||||||
void logout();
|
void logout();
|
||||||
|
|||||||
@@ -32,10 +32,17 @@ Return type: void
|
|||||||
*/
|
*/
|
||||||
void CustomerMenu::showMenu()
|
void CustomerMenu::showMenu()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
startEventListener();
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
break;
|
||||||
|
}
|
||||||
int choice;
|
int choice;
|
||||||
util::clear();
|
util::clear();
|
||||||
std::cout << "Customer Menu"
|
std::cout << "Customer Menu"
|
||||||
@@ -62,6 +69,7 @@ void CustomerMenu::showMenu()
|
|||||||
util::pressEnter();
|
util::pressEnter();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
stopEventListener();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -72,6 +80,11 @@ Return type: bool - true if menu continues, false if logout
|
|||||||
*/
|
*/
|
||||||
bool CustomerMenu::handleOperation(int choice)
|
bool CustomerMenu::handleOperation(int choice)
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
switch (choice)
|
switch (choice)
|
||||||
{
|
{
|
||||||
case 1:
|
case 1:
|
||||||
@@ -111,6 +124,19 @@ bool CustomerMenu::handleOperation(int choice)
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: handleNotificationEvent
|
||||||
|
Description: Retrieves and displays the latest notification for the
|
||||||
|
currently logged in admin.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void CustomerMenu::handleNotificationEvent()
|
||||||
|
{
|
||||||
|
auto notifications = m_controller.getNotifications();
|
||||||
|
displayNewNotification(notifications);
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: logout
|
Function: logout
|
||||||
Description: Logs out the currently authenticated customer user.
|
Description: Logs out the currently authenticated customer user.
|
||||||
|
|||||||
@@ -9,13 +9,14 @@ Date:19-May-2026
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
#include "Menu.h"
|
||||||
#include "Controller.h"
|
#include "Controller.h"
|
||||||
|
|
||||||
class CustomerMenu
|
class CustomerMenu : public Menu
|
||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
Controller m_controller;
|
|
||||||
bool handleOperation(int choice);
|
bool handleOperation(int choice);
|
||||||
|
void handleNotificationEvent();
|
||||||
public:
|
public:
|
||||||
void showMenu();
|
void showMenu();
|
||||||
void logout();
|
void logout();
|
||||||
|
|||||||
@@ -0,0 +1,144 @@
|
|||||||
|
/*
|
||||||
|
File: Menu.cpp
|
||||||
|
Description: Implementation file containing common menu event listener
|
||||||
|
functionality, account disable handling, and notification
|
||||||
|
event dispatching for all menu types.
|
||||||
|
Author: Trenser
|
||||||
|
Date:16-Jun-2026
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "Menu.h"
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: Menu
|
||||||
|
Description: Constructs a Menu object and initializes event handles
|
||||||
|
and menu state.
|
||||||
|
Parameter: None
|
||||||
|
Return type: None
|
||||||
|
*/
|
||||||
|
Menu::Menu()
|
||||||
|
:
|
||||||
|
m_isMenuActive(false),
|
||||||
|
m_accountDisabledEvent(NULL),
|
||||||
|
m_notificationAvailableEvent(NULL),
|
||||||
|
m_shutdownEvent(NULL) {}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: ~Menu
|
||||||
|
Description: Destroys the Menu object and performs event listener
|
||||||
|
cleanup.
|
||||||
|
Parameter: None
|
||||||
|
Return type: None
|
||||||
|
*/
|
||||||
|
Menu::~Menu()
|
||||||
|
{
|
||||||
|
stopEventListener();
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: startEventListener
|
||||||
|
Description: Creates menu event handles, registers them with the
|
||||||
|
authentication service, and starts the event listener
|
||||||
|
thread.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Menu::startEventListener()
|
||||||
|
{
|
||||||
|
if (m_isMenuActive.load())
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
m_isMenuActive.store(true);
|
||||||
|
m_accountDisabledEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||||
|
m_notificationAvailableEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||||
|
m_shutdownEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||||
|
m_controller.registerEvents(m_accountDisabledEvent, m_notificationAvailableEvent);
|
||||||
|
m_eventListenerThread = std::thread(&Menu::eventListenerLoop, this);
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: eventListenerLoop
|
||||||
|
Description: Waits for account disabled, notification available,
|
||||||
|
and shutdown events and dispatches them to the
|
||||||
|
appropriate handlers.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Menu::eventListenerLoop()
|
||||||
|
{
|
||||||
|
HANDLE handles[3];
|
||||||
|
handles[0] = m_accountDisabledEvent;
|
||||||
|
handles[1] = m_notificationAvailableEvent;
|
||||||
|
handles[2] = m_shutdownEvent;
|
||||||
|
while (m_isMenuActive.load())
|
||||||
|
{
|
||||||
|
DWORD result = WaitForMultipleObjects(3, handles, FALSE, INFINITE);
|
||||||
|
switch (result)
|
||||||
|
{
|
||||||
|
case WAIT_OBJECT_0:
|
||||||
|
handleAccountDisabledEvent();
|
||||||
|
break;
|
||||||
|
case WAIT_OBJECT_0 + 1:
|
||||||
|
handleNotificationEvent();
|
||||||
|
break;
|
||||||
|
case WAIT_OBJECT_0 + 2:
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: stopEventListener
|
||||||
|
Description: Stops the event listener thread and releases all
|
||||||
|
associated event handles.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Menu::stopEventListener()
|
||||||
|
{
|
||||||
|
m_isMenuActive.store(false);
|
||||||
|
if (m_shutdownEvent)
|
||||||
|
{
|
||||||
|
SetEvent(m_shutdownEvent);
|
||||||
|
}
|
||||||
|
if (m_eventListenerThread.joinable())
|
||||||
|
{
|
||||||
|
m_eventListenerThread.join();
|
||||||
|
}
|
||||||
|
if (m_accountDisabledEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_accountDisabledEvent);
|
||||||
|
}
|
||||||
|
if (m_notificationAvailableEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_notificationAvailableEvent);
|
||||||
|
}
|
||||||
|
if (m_shutdownEvent)
|
||||||
|
{
|
||||||
|
CloseHandle(m_shutdownEvent);
|
||||||
|
}
|
||||||
|
m_accountDisabledEvent = NULL;
|
||||||
|
m_notificationAvailableEvent = NULL;
|
||||||
|
m_shutdownEvent = NULL;
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: handleAccountDisabledEvent
|
||||||
|
Description: Handles an account disabled event by marking the menu
|
||||||
|
inactive and notifying the user.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Menu::handleAccountDisabledEvent()
|
||||||
|
{
|
||||||
|
m_isMenuActive.store(false);
|
||||||
|
MessageBoxA(
|
||||||
|
GetConsoleWindow(),
|
||||||
|
"Your account has been disabled.",
|
||||||
|
"Account Disabled",
|
||||||
|
MB_OK |
|
||||||
|
MB_ICONWARNING |
|
||||||
|
MB_SETFOREGROUND |
|
||||||
|
MB_TOPMOST);
|
||||||
|
}
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
/*
|
||||||
|
File: Menu.h
|
||||||
|
Description: Base class providing common event listener functionality
|
||||||
|
for all menu implementations.
|
||||||
|
Author: Trenser
|
||||||
|
Date:16-Jun-2026
|
||||||
|
*/
|
||||||
|
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <windows.h>
|
||||||
|
#include <atomic>
|
||||||
|
#include <thread>
|
||||||
|
#include "Controller.h"
|
||||||
|
|
||||||
|
class Menu
|
||||||
|
{
|
||||||
|
protected:
|
||||||
|
Controller m_controller;
|
||||||
|
std::atomic<bool> m_isMenuActive;
|
||||||
|
HANDLE m_accountDisabledEvent;
|
||||||
|
HANDLE m_notificationAvailableEvent;
|
||||||
|
HANDLE m_shutdownEvent;
|
||||||
|
std::thread m_eventListenerThread;
|
||||||
|
void startEventListener();
|
||||||
|
void stopEventListener();
|
||||||
|
void eventListenerLoop();
|
||||||
|
void handleAccountDisabledEvent();
|
||||||
|
virtual void handleNotificationEvent() = 0;
|
||||||
|
public:
|
||||||
|
Menu();
|
||||||
|
virtual ~Menu();
|
||||||
|
};
|
||||||
@@ -1407,4 +1407,38 @@ inline std::string selectComboPackage(util::Map<std::string, const ComboPackage*
|
|||||||
std::cout << "Enter a valid choice.\n";
|
std::cout << "Enter a valid choice.\n";
|
||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: displayNewNotification
|
||||||
|
Description: Displays the most recent notification from the supplied
|
||||||
|
notification collection.
|
||||||
|
Parameter: util::Vector<const Notification*> notifications -
|
||||||
|
collection of notifications
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
inline void displayNewNotification(util::Vector<const Notification*> notifications)
|
||||||
|
{
|
||||||
|
const Notification* notification = nullptr;
|
||||||
|
size_t numberOfNotifications = notifications.getSize();
|
||||||
|
for (int index = 0; index < numberOfNotifications; index++)
|
||||||
|
{
|
||||||
|
if (!notification)
|
||||||
|
{
|
||||||
|
notification = notifications[index];
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
if (notification->getId() < notifications[index]->getId())
|
||||||
|
{
|
||||||
|
notification = notifications[index];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
MessageBoxA(
|
||||||
|
GetConsoleWindow(),
|
||||||
|
notification->getMessage().c_str(),
|
||||||
|
notification->getTitle().c_str(),
|
||||||
|
MB_OK |
|
||||||
|
MB_ICONINFORMATION);
|
||||||
}
|
}
|
||||||
@@ -27,10 +27,16 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
void TechnicianMenu::showMenu()
|
void TechnicianMenu::showMenu()
|
||||||
{
|
{
|
||||||
|
startEventListener();
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
break;
|
||||||
|
}
|
||||||
int choice;
|
int choice;
|
||||||
util::clear();
|
util::clear();
|
||||||
std::cout << "Technician Menu"
|
std::cout << "Technician Menu"
|
||||||
@@ -52,6 +58,7 @@ void TechnicianMenu::showMenu()
|
|||||||
util::pressEnter();
|
util::pressEnter();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
stopEventListener();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -62,6 +69,11 @@ Return type: bool - true if menu continues, false if logout
|
|||||||
*/
|
*/
|
||||||
bool TechnicianMenu::handleOperation(int choice)
|
bool TechnicianMenu::handleOperation(int choice)
|
||||||
{
|
{
|
||||||
|
if (!m_isMenuActive)
|
||||||
|
{
|
||||||
|
logout();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
switch (choice)
|
switch (choice)
|
||||||
{
|
{
|
||||||
case 1:
|
case 1:
|
||||||
@@ -86,6 +98,19 @@ bool TechnicianMenu::handleOperation(int choice)
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: handleNotificationEvent
|
||||||
|
Description: Retrieves and displays the latest notification for the
|
||||||
|
currently logged in admin.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void TechnicianMenu::handleNotificationEvent()
|
||||||
|
{
|
||||||
|
auto notifications = m_controller.getNotifications();
|
||||||
|
displayNewNotification(notifications);
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: displayJobs
|
Function: displayJobs
|
||||||
Description: Displays all Jobs assigned to a Technician
|
Description: Displays all Jobs assigned to a Technician
|
||||||
|
|||||||
@@ -9,12 +9,13 @@ Date:19-May-2026
|
|||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include "Controller.h"
|
#include "Controller.h"
|
||||||
|
#include "Menu.h"
|
||||||
|
|
||||||
class TechnicianMenu
|
class TechnicianMenu : public Menu
|
||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
Controller m_controller;
|
|
||||||
bool handleOperation(int choice);
|
bool handleOperation(int choice);
|
||||||
|
void handleNotificationEvent();
|
||||||
public:
|
public:
|
||||||
void showMenu();
|
void showMenu();
|
||||||
void displayJobs();
|
void displayJobs();
|
||||||
|
|||||||
Reference in New Issue
Block a user