Compare commits
13 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d41b9da4e2 | |||
| 0bef16e82c | |||
| dc5da0a7b7 | |||
| 7454c5a75f | |||
| 93a38bc6fb | |||
| a8cd72ed17 | |||
| adf74e2427 | |||
| 603ed9c60e | |||
| 43c337d46a | |||
| 1ef6cd9479 | |||
| f8cb7453a7 | |||
| 6e9a9292de | |||
| ec1f4ea117 |
-1
@@ -157,7 +157,6 @@
|
|||||||
<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="datastores\DataStore.h" />
|
<ClInclude Include="datastores\DataStore.h" />
|
||||||
<ClInclude Include="datastores\DataStoreLockGuard.h" />
|
|
||||||
<ClInclude Include="datastores\sharedmemory\FileHeader.h" />
|
<ClInclude Include="datastores\sharedmemory\FileHeader.h" />
|
||||||
<ClInclude Include="datastores\sharedmemory\MappingInfo.h" />
|
<ClInclude Include="datastores\sharedmemory\MappingInfo.h" />
|
||||||
<ClInclude Include="datastores\sharedmemory\RecordState.h" />
|
<ClInclude Include="datastores\sharedmemory\RecordState.h" />
|
||||||
|
|||||||
+53
-27
@@ -588,37 +588,63 @@ void Controller::configureNotifications(bool paymentNotifications, bool serviceN
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: initialize
|
Function: loadSystemData
|
||||||
Description: Initializes the system and run system checks to ensure critical configurations, such as verifying admin existence.
|
Description: Loads all system data from persistent storage into memory.
|
||||||
Parameters:
|
Invokes the respective management services to load users, inventory items, services,
|
||||||
- None
|
combo packages, service bookings, job cards, invoices, and observers.
|
||||||
Returns:
|
|
||||||
- bool
|
|
||||||
*/
|
|
||||||
bool Controller::initialize()
|
|
||||||
{
|
|
||||||
auto& dataStore = DataStore::getInstance();
|
|
||||||
|
|
||||||
if (!dataStore.initialize())
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
m_userManagementService.ensureAdminExists();
|
|
||||||
m_inventoryManagementService.sendLowStockAlerts();
|
|
||||||
m_paymentManagementService.sendPaymentReminders();
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: shutdown
|
|
||||||
Description: Shutdown the system, and do necessary cleanups
|
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- void
|
- void
|
||||||
*/
|
*/
|
||||||
void Controller::shutdown()
|
void Controller::loadSystemData()
|
||||||
{
|
{
|
||||||
auto& dataStore = DataStore::getInstance();
|
m_userManagementService.loadUsers();
|
||||||
dataStore.shutdown();
|
m_inventoryManagementService.loadInventoryItems();
|
||||||
|
m_serviceManagementService.loadServices();
|
||||||
|
m_serviceManagementService.loadComboPackages();
|
||||||
|
m_serviceManagementService.loadServiceBookings();
|
||||||
|
m_serviceManagementService.loadJobCards();
|
||||||
|
m_paymentManagementService.loadInvoices();
|
||||||
|
m_serviceManagementService.loadObservers();
|
||||||
|
m_paymentManagementService.loadObservers();
|
||||||
|
m_inventoryManagementService.loadObservers();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: saveSystemData
|
||||||
|
Description: Saves all system data from memory back to persistent storage.
|
||||||
|
Invokes the respective management services to save users, inventory items, services,
|
||||||
|
combo packages, service bookings, job cards, invoices, and observers.
|
||||||
|
Parameters:
|
||||||
|
- None
|
||||||
|
Returns:
|
||||||
|
- void
|
||||||
|
*/
|
||||||
|
void Controller::saveSystemData()
|
||||||
|
{
|
||||||
|
m_userManagementService.saveUsers();
|
||||||
|
m_inventoryManagementService.saveInventoryItems();
|
||||||
|
m_serviceManagementService.saveServices();
|
||||||
|
m_serviceManagementService.saveComboPackages();
|
||||||
|
m_serviceManagementService.saveServiceBookings();
|
||||||
|
m_serviceManagementService.saveJobCards();
|
||||||
|
m_paymentManagementService.saveInvoices();
|
||||||
|
m_serviceManagementService.saveObservers();
|
||||||
|
m_paymentManagementService.saveObservers();
|
||||||
|
m_inventoryManagementService.saveObservers();
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: runSystemChecks
|
||||||
|
Description: Runs system checks to ensure critical configurations, such as verifying admin existence.
|
||||||
|
Parameter: None
|
||||||
|
Return type: void
|
||||||
|
*/
|
||||||
|
void Controller::runSystemChecks()
|
||||||
|
{
|
||||||
|
m_userManagementService.ensureAdminExists();
|
||||||
|
m_inventoryManagementService.sendLowStockAlerts();
|
||||||
|
m_paymentManagementService.sendPaymentReminders();
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -70,6 +70,7 @@ public:
|
|||||||
util::Vector<const Notification*> getNotifications();
|
util::Vector<const Notification*> getNotifications();
|
||||||
void deleteNotification(const std::string& notificationID);
|
void deleteNotification(const std::string& notificationID);
|
||||||
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
||||||
bool initialize();
|
void loadSystemData();
|
||||||
void shutdown();
|
void saveSystemData();
|
||||||
|
void runSystemChecks();
|
||||||
};
|
};
|
||||||
+72
-102
@@ -13,42 +13,9 @@ Date: 19-May-2026
|
|||||||
#include "SerializedRecords.h"
|
#include "SerializedRecords.h"
|
||||||
#include "FileHelper.h"
|
#include "FileHelper.h"
|
||||||
|
|
||||||
/*
|
|
||||||
Function: DataStore
|
|
||||||
Description: Constructs the DataStore singleton and initializes
|
|
||||||
internal handles to their default values.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- None
|
|
||||||
*/
|
|
||||||
DataStore::DataStore() :
|
DataStore::DataStore() :
|
||||||
m_globalMutex(NULL) {}
|
m_globalMutex(NULL) {}
|
||||||
|
|
||||||
/*
|
|
||||||
Function: ~DataStore
|
|
||||||
Description: Destroys the DataStore singleton and releases all
|
|
||||||
cached application objects owned by the datastore.
|
|
||||||
This includes users, notifications, services,
|
|
||||||
combo packages, inventory items, service bookings,
|
|
||||||
job cards, and invoices.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- None
|
|
||||||
*/
|
|
||||||
DataStore::~DataStore()
|
|
||||||
{
|
|
||||||
clearCache(m_userCache);
|
|
||||||
clearCache(m_notificationCache);
|
|
||||||
clearCache(m_serviceCache);
|
|
||||||
clearCache(m_comboPackageCache);
|
|
||||||
clearCache(m_inventoryItemCache);
|
|
||||||
clearCache(m_serviceBookingCache);
|
|
||||||
clearCache(m_jobCardCache);
|
|
||||||
clearCache(m_invoiceCache);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: initialize
|
Function: initialize
|
||||||
Description: Initializes the shared-memory datastore.
|
Description: Initializes the shared-memory datastore.
|
||||||
@@ -226,25 +193,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<User>>: Collection of user records
|
- util::Map<std::string, TrackedRecord<User>>: Collection of user records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<User>>& DataStore::getUsers()
|
util::Map<std::string, TrackedRecord<User>> DataStore::getUsers()
|
||||||
{
|
{
|
||||||
auto users = loadRecords<User, SerializedUser>(m_users);
|
return util::Map<std::string, TrackedRecord<User>>();
|
||||||
refreshCache(m_userCache, users);
|
|
||||||
auto& notifications = getNotifications();
|
|
||||||
int numberOfNotifications = m_notificationCache.getSize();
|
|
||||||
for (int index = 0; index < numberOfNotifications; index++)
|
|
||||||
{
|
|
||||||
Notification* notification = notifications.getValueAt(index).data;
|
|
||||||
const std::string& recipientUserId = notification->getRecipientUserId();
|
|
||||||
int userIndex = m_userCache.find(recipientUserId);
|
|
||||||
if (userIndex == -1)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid recipient user ID");
|
|
||||||
}
|
|
||||||
User* user = m_userCache.getValueAt(userIndex).data;
|
|
||||||
user->addNotification(notification);
|
|
||||||
}
|
|
||||||
return m_userCache;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -255,11 +206,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<Notification>>: Collection of notification records
|
- util::Map<std::string, TrackedRecord<Notification>>: Collection of notification records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<Notification>>& DataStore::getNotifications()
|
util::Map<std::string, TrackedRecord<Notification>> DataStore::getNotifications()
|
||||||
{
|
{
|
||||||
auto notifications = loadRecords<Notification, SerializedNotification>(m_notifications);
|
return util::Map<std::string, TrackedRecord<Notification>>();
|
||||||
refreshCache(m_notificationCache, notifications);
|
|
||||||
return m_notificationCache;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -270,9 +219,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<Service>>: Collection of service records
|
- util::Map<std::string, TrackedRecord<Service>>: Collection of service records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<Service>>& DataStore::getServices()
|
util::Map<std::string, TrackedRecord<Service>> DataStore::getServices()
|
||||||
{
|
{
|
||||||
return m_serviceCache;
|
return util::Map<std::string, TrackedRecord<Service>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -283,9 +232,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<ComboPackage>>: Collection of combo package records
|
- util::Map<std::string, TrackedRecord<ComboPackage>>: Collection of combo package records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<ComboPackage>>& DataStore::getComboPackages()
|
util::Map<std::string, TrackedRecord<ComboPackage>> DataStore::getComboPackages()
|
||||||
{
|
{
|
||||||
return m_comboPackageCache;
|
return util::Map<std::string, TrackedRecord<ComboPackage>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -296,9 +245,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<InventoryItem>>: Collection of inventory item records
|
- util::Map<std::string, TrackedRecord<InventoryItem>>: Collection of inventory item records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<InventoryItem>>& DataStore::getInventoryItems()
|
util::Map<std::string, TrackedRecord<InventoryItem>> DataStore::getInventoryItems()
|
||||||
{
|
{
|
||||||
return m_inventoryItemCache;
|
return util::Map<std::string, TrackedRecord<InventoryItem>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -309,9 +258,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<ServiceBooking>>: Collection of service booking records
|
- util::Map<std::string, TrackedRecord<ServiceBooking>>: Collection of service booking records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<ServiceBooking>>& DataStore::getServiceBookings()
|
util::Map<std::string, TrackedRecord<ServiceBooking>> DataStore::getServiceBookings()
|
||||||
{
|
{
|
||||||
return m_serviceBookingCache;
|
return util::Map<std::string, TrackedRecord<ServiceBooking>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -322,9 +271,9 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<JobCard>>: Collection of job card records
|
- util::Map<std::string, TrackedRecord<JobCard>>: Collection of job card records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<JobCard>>& DataStore::getJobCards()
|
util::Map<std::string, TrackedRecord<JobCard>> DataStore::getJobCards()
|
||||||
{
|
{
|
||||||
return m_jobCardCache;
|
return util::Map<std::string, TrackedRecord<JobCard>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -335,9 +284,22 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, TrackedRecord<Invoice>>: Collection of invoice records
|
- util::Map<std::string, TrackedRecord<Invoice>>: Collection of invoice records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, TrackedRecord<Invoice>>& DataStore::getInvoices()
|
util::Map<std::string, TrackedRecord<Invoice>> DataStore::getInvoices()
|
||||||
{
|
{
|
||||||
return m_invoiceCache;
|
return util::Map<std::string, TrackedRecord<Invoice>>();
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: getPayments
|
||||||
|
Description: Retrieves all payment records from the datastore.
|
||||||
|
Parameters:
|
||||||
|
- None
|
||||||
|
Returns:
|
||||||
|
- util::Map<std::string, TrackedRecord<Payment>>: Collection of payment records
|
||||||
|
*/
|
||||||
|
util::Map<std::string, TrackedRecord<Payment>> DataStore::getPayments()
|
||||||
|
{
|
||||||
|
return util::Map<std::string, TrackedRecord<Payment>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -346,11 +308,11 @@ Description: Retrieves all service management observer records from the datastor
|
|||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, User*>: Collection of observer records
|
- util::Map<std::string, TrackedRecord<std::string>>: Collection of observer records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, User*> DataStore::getServiceManagementObservers()
|
util::Map<std::string, TrackedRecord<std::string>> DataStore::getServiceManagementObservers()
|
||||||
{
|
{
|
||||||
return util::Map<std::string, User*>();
|
return util::Map<std::string, TrackedRecord<std::string>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -359,11 +321,11 @@ Description: Retrieves all payment management observer records from the datastor
|
|||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, User*>: Collection of observer records
|
- util::Map<std::string, TrackedRecord<std::string>>: Collection of observer records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, User*> DataStore::getPaymentManagementObservers()
|
util::Map<std::string, TrackedRecord<std::string>> DataStore::getPaymentManagementObservers()
|
||||||
{
|
{
|
||||||
return util::Map<std::string, User*>();
|
return util::Map<std::string, TrackedRecord<std::string>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -372,49 +334,46 @@ Description: Retrieves all inventory management observer records from the datast
|
|||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- util::Map<std::string, User*>: Collection of observer records
|
- util::Map<std::string, TrackedRecord<std::string>>: Collection of observer records
|
||||||
*/
|
*/
|
||||||
util::Map<std::string, User*> DataStore::getInventoryManagementObservers()
|
util::Map<std::string, TrackedRecord<std::string>> DataStore::getInventoryManagementObservers()
|
||||||
{
|
{
|
||||||
return util::Map<std::string, User*>();
|
return util::Map<std::string, TrackedRecord<std::string>>();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: saveUsers
|
Function: saveUsers
|
||||||
Description: Persists all user records to the datastore.
|
Description: Persists all user records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- users: util::Map<std::string, TrackedRecord<User>>&, collection of user records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveUsers()
|
void DataStore::saveUsers(util::Map<std::string, TrackedRecord<User>>& users)
|
||||||
{
|
{
|
||||||
saveRecords<User, SerializedUser>(m_users, m_userCache);
|
|
||||||
saveNotifications();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: saveNotifications
|
Function: saveNotifications
|
||||||
Description: Persists all notification records to the datastore.
|
Description: Persists all notification records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- notifications: util::Map<std::string, TrackedRecord<Notification>>&, collection of notification records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveNotifications()
|
void DataStore::saveNotifications(util::Map<std::string, TrackedRecord<Notification>>& notifications)
|
||||||
{
|
{
|
||||||
saveRecords<Notification, SerializedNotification>(m_notifications, m_notificationCache);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: saveServices
|
Function: saveServices
|
||||||
Description: Persists all service records to the datastore.
|
Description: Persists all service records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- services: util::Map<std::string, TrackedRecord<Service>>&, collection of service records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveServices()
|
void DataStore::saveServices(util::Map<std::string, TrackedRecord<Service>>& services)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -422,11 +381,11 @@ void DataStore::saveServices()
|
|||||||
Function: saveComboPackages
|
Function: saveComboPackages
|
||||||
Description: Persists all combo package records to the datastore.
|
Description: Persists all combo package records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- comboPackages: util::Map<std::string, TrackedRecord<ComboPackage>>&, collection of combo package records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveComboPackages()
|
void DataStore::saveComboPackages(util::Map<std::string, TrackedRecord<ComboPackage>>& comboPackages)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -434,11 +393,11 @@ void DataStore::saveComboPackages()
|
|||||||
Function: saveInventoryItems
|
Function: saveInventoryItems
|
||||||
Description: Persists all inventory item records to the datastore.
|
Description: Persists all inventory item records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- inventoryItems: util::Map<std::string, TrackedRecord<InventoryItem>>&, collection of inventory item records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveInventoryItems()
|
void DataStore::saveInventoryItems(util::Map<std::string, TrackedRecord<InventoryItem>>& inventoryItems)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -446,11 +405,11 @@ void DataStore::saveInventoryItems()
|
|||||||
Function: saveServiceBookings
|
Function: saveServiceBookings
|
||||||
Description: Persists all service booking records to the datastore.
|
Description: Persists all service booking records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- bookings: util::Map<std::string, TrackedRecord<ServiceBooking>>&, collection of service booking records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveServiceBookings()
|
void DataStore::saveServiceBookings(util::Map<std::string, TrackedRecord<ServiceBooking>>& bookings)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -458,11 +417,11 @@ void DataStore::saveServiceBookings()
|
|||||||
Function: saveJobCards
|
Function: saveJobCards
|
||||||
Description: Persists all job card records to the datastore.
|
Description: Persists all job card records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- jobCards: util::Map<std::string, TrackedRecord<JobCard>>&, collection of job card records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveJobCards()
|
void DataStore::saveJobCards(util::Map<std::string, TrackedRecord<JobCard>>& jobCards)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -470,11 +429,23 @@ void DataStore::saveJobCards()
|
|||||||
Function: saveInvoices
|
Function: saveInvoices
|
||||||
Description: Persists all invoice records to the datastore.
|
Description: Persists all invoice records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- invoices: util::Map<std::string, TrackedRecord<Invoice>>&, collection of invoice records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveInvoices()
|
void DataStore::saveInvoices(util::Map<std::string, TrackedRecord<Invoice>>& invoices)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: savePayments
|
||||||
|
Description: Persists all payment records to the datastore.
|
||||||
|
Parameters:
|
||||||
|
- payments: util::Map<std::string, TrackedRecord<Payment>>&, collection of payment records
|
||||||
|
Returns:
|
||||||
|
- None
|
||||||
|
*/
|
||||||
|
void DataStore::savePayments(util::Map<std::string, TrackedRecord<Payment>>& payments)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -486,7 +457,7 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveServiceManagementObservers(util::Map<std::string, User*>& observers)
|
void DataStore::saveServiceManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -494,11 +465,11 @@ void DataStore::saveServiceManagementObservers(util::Map<std::string, User*>& ob
|
|||||||
Function: savePaymentManagementObservers
|
Function: savePaymentManagementObservers
|
||||||
Description: Persists all payment management observer records to the datastore.
|
Description: Persists all payment management observer records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- observers: util::Map<std::string, User*>&, collection of observer records
|
- observers: util::Map<std::string, TrackedRecord<std::string>>&, collection of observer records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::savePaymentManagementObservers(util::Map<std::string, User*>& observers)
|
void DataStore::savePaymentManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -506,11 +477,11 @@ void DataStore::savePaymentManagementObservers(util::Map<std::string, User*>& ob
|
|||||||
Function: saveInventoryManagementObservers
|
Function: saveInventoryManagementObservers
|
||||||
Description: Persists all inventory management observer records to the datastore.
|
Description: Persists all inventory management observer records to the datastore.
|
||||||
Parameters:
|
Parameters:
|
||||||
- observers: util::Map<std::string, User*>&, collection of observer records
|
- observers: util::Map<std::string, TrackedRecord<std::string>>&, collection of observer records
|
||||||
Returns:
|
Returns:
|
||||||
- None
|
- None
|
||||||
*/
|
*/
|
||||||
void DataStore::saveInventoryManagementObservers(util::Map<std::string, User*>& observers)
|
void DataStore::saveInventoryManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -582,5 +553,4 @@ bool DataStore::unlockDataStore()
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return ReleaseMutex(m_globalMutex) != 0;
|
return ReleaseMutex(m_globalMutex) != 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -20,12 +20,12 @@ class InventoryItem;
|
|||||||
class ServiceBooking;
|
class ServiceBooking;
|
||||||
class JobCard;
|
class JobCard;
|
||||||
class Invoice;
|
class Invoice;
|
||||||
|
class Payment;
|
||||||
|
|
||||||
class DataStore
|
class DataStore
|
||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
DataStore();
|
DataStore();
|
||||||
~DataStore();
|
|
||||||
DataStore(const DataStore&) = delete;
|
DataStore(const DataStore&) = delete;
|
||||||
DataStore& operator=(const DataStore&) = delete;
|
DataStore& operator=(const DataStore&) = delete;
|
||||||
DataStore(DataStore&&) = delete;
|
DataStore(DataStore&&) = delete;
|
||||||
@@ -43,40 +43,34 @@ private:
|
|||||||
MappingInfo m_serviceManagementObservers;
|
MappingInfo m_serviceManagementObservers;
|
||||||
MappingInfo m_paymentManagementObservers;
|
MappingInfo m_paymentManagementObservers;
|
||||||
MappingInfo m_inventoryManagementObservers;
|
MappingInfo m_inventoryManagementObservers;
|
||||||
util::Map<std::string, TrackedRecord<User>> m_userCache;
|
|
||||||
util::Map<std::string, TrackedRecord<Notification>> m_notificationCache;
|
|
||||||
util::Map<std::string, TrackedRecord<Service>> m_serviceCache;
|
|
||||||
util::Map<std::string, TrackedRecord<ComboPackage>> m_comboPackageCache;
|
|
||||||
util::Map<std::string, TrackedRecord<InventoryItem>> m_inventoryItemCache;
|
|
||||||
util::Map<std::string, TrackedRecord<ServiceBooking>> m_serviceBookingCache;
|
|
||||||
util::Map<std::string, TrackedRecord<JobCard>> m_jobCardCache;
|
|
||||||
util::Map<std::string, TrackedRecord<Invoice>> m_invoiceCache;
|
|
||||||
public:
|
public:
|
||||||
static DataStore& getInstance();
|
static DataStore& getInstance();
|
||||||
bool initialize();
|
bool initialize();
|
||||||
void shutdown();
|
void shutdown();
|
||||||
util::Map<std::string, TrackedRecord<User>>& getUsers();
|
util::Map<std::string, TrackedRecord<User>> getUsers();
|
||||||
util::Map<std::string, TrackedRecord<Notification>>& getNotifications();
|
util::Map<std::string, TrackedRecord<Notification>> getNotifications();
|
||||||
util::Map<std::string, TrackedRecord<Service>>& getServices();
|
util::Map<std::string, TrackedRecord<Service>> getServices();
|
||||||
util::Map<std::string, TrackedRecord<ComboPackage>>& getComboPackages();
|
util::Map<std::string, TrackedRecord<ComboPackage>> getComboPackages();
|
||||||
util::Map<std::string, TrackedRecord<InventoryItem>>& getInventoryItems();
|
util::Map<std::string, TrackedRecord<InventoryItem>> getInventoryItems();
|
||||||
util::Map<std::string, TrackedRecord<ServiceBooking>>& getServiceBookings();
|
util::Map<std::string, TrackedRecord<ServiceBooking>> getServiceBookings();
|
||||||
util::Map<std::string, TrackedRecord<JobCard>>& getJobCards();
|
util::Map<std::string, TrackedRecord<JobCard>> getJobCards();
|
||||||
util::Map<std::string, TrackedRecord<Invoice>>& getInvoices();
|
util::Map<std::string, TrackedRecord<Invoice>> getInvoices();
|
||||||
util::Map<std::string, User*> getServiceManagementObservers();
|
util::Map<std::string, TrackedRecord<Payment>> getPayments();
|
||||||
util::Map<std::string, User*> getPaymentManagementObservers();
|
util::Map<std::string, TrackedRecord<std::string>> getServiceManagementObservers();
|
||||||
util::Map<std::string, User*> getInventoryManagementObservers();
|
util::Map<std::string, TrackedRecord<std::string>> getPaymentManagementObservers();
|
||||||
void saveUsers();
|
util::Map<std::string, TrackedRecord<std::string>> getInventoryManagementObservers();
|
||||||
void saveNotifications();
|
void saveUsers(util::Map<std::string, TrackedRecord<User>>& users);
|
||||||
void saveServices();
|
void saveNotifications(util::Map<std::string, TrackedRecord<Notification>>& notifications);
|
||||||
void saveComboPackages();
|
void saveServices(util::Map<std::string, TrackedRecord<Service>>& services);
|
||||||
void saveInventoryItems();
|
void saveComboPackages(util::Map<std::string, TrackedRecord<ComboPackage>>& comboPackages);
|
||||||
void saveServiceBookings();
|
void saveInventoryItems(util::Map<std::string, TrackedRecord<InventoryItem>>& inventoryItems);
|
||||||
void saveJobCards();
|
void saveServiceBookings(util::Map<std::string, TrackedRecord<ServiceBooking>>& bookings);
|
||||||
void saveInvoices();
|
void saveJobCards(util::Map<std::string, TrackedRecord<JobCard>>& jobCards);
|
||||||
void saveServiceManagementObservers(util::Map<std::string, User*>& observers);
|
void saveInvoices(util::Map<std::string, TrackedRecord<Invoice>>& invoices);
|
||||||
void savePaymentManagementObservers(util::Map<std::string, User*>& observers);
|
void savePayments(util::Map<std::string, TrackedRecord<Payment>>& payments);
|
||||||
void saveInventoryManagementObservers(util::Map<std::string, User*>& observers);
|
void saveServiceManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers);
|
||||||
|
void savePaymentManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers);
|
||||||
|
void saveInventoryManagementObservers(util::Map<std::string, TrackedRecord<std::string>>& observers);
|
||||||
bool lockDataStore();
|
bool lockDataStore();
|
||||||
bool unlockDataStore();
|
bool unlockDataStore();
|
||||||
private:
|
private:
|
||||||
@@ -84,8 +78,6 @@ private:
|
|||||||
util::Map<std::string, TrackedRecord<TObject>> loadRecords(MappingInfo& mapping);
|
util::Map<std::string, TrackedRecord<TObject>> loadRecords(MappingInfo& mapping);
|
||||||
template<typename TObject, typename TSerialized>
|
template<typename TObject, typename TSerialized>
|
||||||
void saveRecords(MappingInfo& mapping, util::Map<std::string, TrackedRecord<TObject>>& records);
|
void saveRecords(MappingInfo& mapping, util::Map<std::string, TrackedRecord<TObject>>& records);
|
||||||
template<typename TObject> void clearCache(util::Map<std::string, TrackedRecord<TObject>>&cache);
|
|
||||||
template<typename TObject> void refreshCache(util::Map<std::string, TrackedRecord<TObject>>&cache, util::Map<std::string, TrackedRecord<TObject>>&refreshedCache);
|
|
||||||
};
|
};
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -131,7 +123,9 @@ Description: Persists all modified and newly added records
|
|||||||
shared-memory mapping. Modified records overwrite
|
shared-memory mapping. Modified records overwrite
|
||||||
their existing slots, while new records are
|
their existing slots, while new records are
|
||||||
appended to the end of the mapping. Records marked
|
appended to the end of the mapping. Records marked
|
||||||
as CLEAN are ignored.
|
as CLEAN are ignored. After persistence, all
|
||||||
|
temporary objects owned by the tracked records are
|
||||||
|
destroyed to release memory.
|
||||||
Parameter:
|
Parameter:
|
||||||
- mapping: Reference to the mapping where records are
|
- mapping: Reference to the mapping where records are
|
||||||
stored.
|
stored.
|
||||||
@@ -164,74 +158,14 @@ template<typename TObject, typename TSerialized> void DataStore::saveRecords(Map
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
size_t recordCount = SharedMemory::getRecordCount(mapping);
|
size_t recordCount = SharedMemory::getRecordCount(mapping);
|
||||||
TSerialized* destination = static_cast<TSerialized*>(SharedMemory::getRecordAddress(mapping,recordCount));
|
TSerialized* destination = static_cast<TSerialized*>(SharedMemory::getRecordAddress(mapping, recordCount));
|
||||||
*destination = serialized;
|
*destination = serialized;
|
||||||
SharedMemory::setRecordCount(mapping, recordCount + 1);
|
SharedMemory::setRecordCount(mapping, recordCount + 1);
|
||||||
record.slotIndex = recordCount;
|
|
||||||
}
|
}
|
||||||
record.state = RecordState::CLEAN;
|
|
||||||
}
|
}
|
||||||
}
|
for (int index = 0; index < records.getSize(); ++index)
|
||||||
|
|
||||||
/*
|
|
||||||
Function: clearCache
|
|
||||||
Description: Releases all objects owned by the cache and
|
|
||||||
clears the cache contents.
|
|
||||||
Parameters:
|
|
||||||
- cache: Cache to be cleared.
|
|
||||||
Returns:
|
|
||||||
- None
|
|
||||||
*/
|
|
||||||
template<typename TObject>
|
|
||||||
void DataStore::clearCache(util::Map<std::string, TrackedRecord<TObject>>&cache)
|
|
||||||
{
|
|
||||||
for (int index = 0; index < cache.getSize(); ++index)
|
|
||||||
{
|
{
|
||||||
delete cache.getValueAt(index).data;
|
delete records.getValueAt(index).data;
|
||||||
cache.getValueAt(index).data = nullptr;
|
records.getValueAt(index).data = nullptr;
|
||||||
}
|
|
||||||
cache.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: refreshCache
|
|
||||||
Description: Refreshes the cache while preserving object addresses
|
|
||||||
for records that already exist. Existing objects are
|
|
||||||
updated in-place so that pointers held elsewhere remain
|
|
||||||
valid after the refresh.
|
|
||||||
Parameters:
|
|
||||||
- cache: Existing cache to refresh.
|
|
||||||
- refreshedCache: Newly loaded cache contents.
|
|
||||||
Returns:
|
|
||||||
- None
|
|
||||||
*/
|
|
||||||
template<typename TObject>
|
|
||||||
void DataStore::refreshCache(util::Map<std::string, TrackedRecord<TObject>>& cache, util::Map<std::string, TrackedRecord<TObject>>& refreshedCache)
|
|
||||||
{
|
|
||||||
util::Map<std::string, TrackedRecord<TObject>> oldCache = cache;
|
|
||||||
cache.clear();
|
|
||||||
for (int index = 0; index < refreshedCache.getSize(); ++index)
|
|
||||||
{
|
|
||||||
const std::string& id = refreshedCache.getKeyAt(index);
|
|
||||||
TrackedRecord<TObject>& refreshedRecord = refreshedCache.getValueAt(index);
|
|
||||||
int oldIndex = oldCache.find(id);
|
|
||||||
if (oldIndex != -1)
|
|
||||||
{
|
|
||||||
TrackedRecord<TObject>& oldRecord = oldCache.getValueAt(oldIndex);
|
|
||||||
*oldRecord.data = *refreshedRecord.data;
|
|
||||||
oldRecord.slotIndex = refreshedRecord.slotIndex;
|
|
||||||
oldRecord.state = refreshedRecord.state;
|
|
||||||
delete refreshedRecord.data;
|
|
||||||
refreshedRecord.data = oldRecord.data;
|
|
||||||
}
|
|
||||||
cache.insert(id, refreshedRecord);
|
|
||||||
}
|
|
||||||
for (int index = 0; index < oldCache.getSize(); ++index)
|
|
||||||
{
|
|
||||||
const std::string& id = oldCache.getKeyAt(index);
|
|
||||||
if (cache.find(id) == -1)
|
|
||||||
{
|
|
||||||
delete oldCache.getValueAt(index).data;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
-28
@@ -1,28 +0,0 @@
|
|||||||
/*
|
|
||||||
File: DataStoreLockGuard.h
|
|
||||||
Description: Defines the DataStoreLockGuard class used to manage DataStore
|
|
||||||
locking and unlocking automatically within a scope.
|
|
||||||
Author: Trenser
|
|
||||||
Date: 12-June-2026
|
|
||||||
*/
|
|
||||||
|
|
||||||
#pragma once
|
|
||||||
#include "DataStore.h"
|
|
||||||
|
|
||||||
class DataStoreLockGuard
|
|
||||||
{
|
|
||||||
public:
|
|
||||||
explicit DataStoreLockGuard(DataStore& dataStore)
|
|
||||||
: m_dataStore(dataStore)
|
|
||||||
{
|
|
||||||
m_dataStore.lockDataStore();
|
|
||||||
}
|
|
||||||
~DataStoreLockGuard()
|
|
||||||
{
|
|
||||||
m_dataStore.unlockDataStore();
|
|
||||||
}
|
|
||||||
DataStoreLockGuard(const DataStoreLockGuard&) = delete;
|
|
||||||
DataStoreLockGuard& operator=(const DataStoreLockGuard&) = delete;
|
|
||||||
private:
|
|
||||||
DataStore& m_dataStore;
|
|
||||||
};
|
|
||||||
-1
@@ -10,7 +10,6 @@ Created: 11-June-2026
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#include "SharedMemory.h"
|
#include "SharedMemory.h"
|
||||||
#include "Windows.h"
|
|
||||||
#include "Config.h"
|
#include "Config.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ Date: 19-May-2026
|
|||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "ComboPackage.h"
|
#include "ComboPackage.h"
|
||||||
#include "Service.h"
|
#include "Service.h"
|
||||||
#include "Factory.h"
|
#include "Factory.h"
|
||||||
@@ -270,72 +271,38 @@ static util::Vector<std::string> getServiceIDsAsVector(const std::string& servic
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the combo package into a CSV-formatted string.
|
Description: Serializes the ComboPackage object into a SerializedComboPackage record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized combo package record
|
- SerializedComboPackage: Serialized representation of the combo package
|
||||||
*/
|
*/
|
||||||
std::string ComboPackage::serialize() const
|
SerializedComboPackage ComboPackage::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedComboPackage;
|
SerializedComboPackage serialized = {};
|
||||||
serializedComboPackage << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< m_packageName << ','
|
strcpy_s(serialized.packageName, sizeof(serialized.packageName), m_packageName.c_str());
|
||||||
<< m_discountPercentage << ','
|
strcpy_s(serialized.serviceIDs, sizeof(serialized.serviceIDs), getServiceIDsAsString(m_serviceIDs).c_str());
|
||||||
<< getServiceIDsAsString(m_serviceIDs) << ','
|
serialized.discountPercentage = m_discountPercentage;
|
||||||
<< util::getStateString(m_status);
|
serialized.status = m_status;
|
||||||
return serializedComboPackage.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into a ComboPackage object.
|
Description: Deserializes a SerializedComboPackage record into a ComboPackage object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized combo package record
|
- serializedComboPackage: const SerializedComboPackage&, serialized combo package record
|
||||||
Returns:
|
Returns:
|
||||||
- ComboPackage*: Pointer to the deserialized ComboPackage object
|
- ComboPackage*: Pointer to the deserialized ComboPackage object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if data is invalid
|
|
||||||
*/
|
*/
|
||||||
ComboPackage* ComboPackage::deserialize(const std::string& record)
|
ComboPackage* ComboPackage::deserialize(const SerializedComboPackage& serializedComboPackage)
|
||||||
{
|
{
|
||||||
std::string id, packageName;
|
util::Vector<std::string> serviceIDs = getServiceIDsAsVector(serializedComboPackage.serviceIDs);
|
||||||
std::string discountPercentageString, serviceIDsString, statusString;
|
|
||||||
double discountPercentage;
|
|
||||||
std::istringstream serializedComboPackage(record);
|
|
||||||
getline(serializedComboPackage, id, ',');
|
|
||||||
getline(serializedComboPackage, packageName, ',');
|
|
||||||
getline(serializedComboPackage, discountPercentageString, ',');
|
|
||||||
getline(serializedComboPackage, serviceIDsString, ',');
|
|
||||||
getline(serializedComboPackage, statusString, ',');
|
|
||||||
try
|
|
||||||
{
|
|
||||||
discountPercentage = std::stod(discountPercentageString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid combo package data");
|
|
||||||
}
|
|
||||||
util::Vector<std::string> serviceIDs = getServiceIDsAsVector(serviceIDsString);
|
|
||||||
util::State status = util::getState(statusString);
|
|
||||||
return Factory::getObject<ComboPackage>(
|
return Factory::getObject<ComboPackage>(
|
||||||
id,
|
serializedComboPackage.id,
|
||||||
packageName,
|
serializedComboPackage.packageName,
|
||||||
discountPercentage,
|
serializedComboPackage.discountPercentage,
|
||||||
serviceIDs,
|
serviceIDs,
|
||||||
status
|
serializedComboPackage.status);
|
||||||
);
|
}
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for combo package serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,PackageName,DiscountPercentage,ServiceIDs,Status")
|
|
||||||
*/
|
|
||||||
std::string ComboPackage::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,PackageName,DiscountPercentage,ServiceIDs,Status";
|
|
||||||
}
|
|
||||||
@@ -12,6 +12,7 @@ Date: 19-May-2026
|
|||||||
#include "Enums.h"
|
#include "Enums.h"
|
||||||
|
|
||||||
class Service;
|
class Service;
|
||||||
|
class SerializedComboPackage;
|
||||||
|
|
||||||
class ComboPackage
|
class ComboPackage
|
||||||
{
|
{
|
||||||
@@ -38,7 +39,6 @@ public:
|
|||||||
void setDiscountPercentage(double discountPercentage);
|
void setDiscountPercentage(double discountPercentage);
|
||||||
void setServices(const util::Map<std::string, Service*>& services);
|
void setServices(const util::Map<std::string, Service*>& services);
|
||||||
void setState(util::State status);
|
void setState(util::State status);
|
||||||
std::string serialize() const;
|
SerializedComboPackage serialize() const;
|
||||||
static ComboPackage* deserialize(const std::string&);
|
static ComboPackage* deserialize(const SerializedComboPackage&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
+19
-54
@@ -8,6 +8,7 @@ Date: 19-May-2026
|
|||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "Factory.h"
|
#include "Factory.h"
|
||||||
#include "StringHelper.h"
|
#include "StringHelper.h"
|
||||||
#include "InventoryItem.h"
|
#include "InventoryItem.h"
|
||||||
@@ -206,73 +207,37 @@ void InventoryItem::setState(util::State status)
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the inventory item into a CSV-formatted string.
|
Description: Serializes the InventoryItem object into a SerializedInventoryItem record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized inventory item record
|
- SerializedInventoryItem: Serialized representation of the inventory item
|
||||||
*/
|
*/
|
||||||
std::string InventoryItem::serialize() const
|
SerializedInventoryItem InventoryItem::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedInventoryItem;
|
SerializedInventoryItem serialized = {};
|
||||||
serializedInventoryItem << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< m_partName << ','
|
strcpy_s(serialized.partName, sizeof(serialized.partName), m_partName.c_str());
|
||||||
<< m_quantity << ','
|
serialized.quantity = m_quantity;
|
||||||
<< m_price << ','
|
serialized.price = m_price;
|
||||||
<< util::getStateString(m_status);
|
serialized.status = m_status;
|
||||||
return serializedInventoryItem.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into an InventoryItem object.
|
Description: Deserializes a SerializedInventoryItem record into an InventoryItem object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized inventory item record
|
- serializedInventoryItem: const SerializedInventoryItem&, serialized inventory item record
|
||||||
Returns:
|
Returns:
|
||||||
- InventoryItem*: Pointer to the deserialized InventoryItem object
|
- InventoryItem*: Pointer to the deserialized InventoryItem object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if data is invalid
|
|
||||||
*/
|
*/
|
||||||
InventoryItem* InventoryItem::deserialize(const std::string& record)
|
InventoryItem* InventoryItem::deserialize(const SerializedInventoryItem& serializedInventoryItem)
|
||||||
{
|
{
|
||||||
std::string id, partName;
|
|
||||||
std::string quantityString, priceString, statusString;
|
|
||||||
int quantity;
|
|
||||||
double price;
|
|
||||||
std::istringstream serializedInventoryItem(record);
|
|
||||||
getline(serializedInventoryItem, id, ',');
|
|
||||||
getline(serializedInventoryItem, partName, ',');
|
|
||||||
getline(serializedInventoryItem, quantityString, ',');
|
|
||||||
getline(serializedInventoryItem, priceString, ',');
|
|
||||||
getline(serializedInventoryItem, statusString, ',');
|
|
||||||
try
|
|
||||||
{
|
|
||||||
quantity = std::stoi(quantityString);
|
|
||||||
price = std::stod(priceString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid inventory item data");
|
|
||||||
}
|
|
||||||
util::State status = util::getState(statusString);
|
|
||||||
return Factory::getObject<InventoryItem>(
|
return Factory::getObject<InventoryItem>(
|
||||||
id,
|
serializedInventoryItem.id,
|
||||||
partName,
|
serializedInventoryItem.partName,
|
||||||
quantity,
|
serializedInventoryItem.quantity,
|
||||||
price,
|
serializedInventoryItem.price,
|
||||||
status
|
serializedInventoryItem.status);
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for inventory item serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,PartName,Quantity,Price,Status")
|
|
||||||
*/
|
|
||||||
std::string InventoryItem::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,PartName,Quantity,Price,Status";
|
|
||||||
}
|
}
|
||||||
@@ -6,11 +6,12 @@ Author: Trenser
|
|||||||
Date: 19-May-2026
|
Date: 19-May-2026
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "Enums.h"
|
#include "Enums.h"
|
||||||
|
|
||||||
|
struct SerializedInventoryItem;
|
||||||
|
|
||||||
class InventoryItem
|
class InventoryItem
|
||||||
{
|
{
|
||||||
private:
|
private:
|
||||||
@@ -34,7 +35,6 @@ public:
|
|||||||
void setQuantity(int quantity);
|
void setQuantity(int quantity);
|
||||||
void setPrice(double price);
|
void setPrice(double price);
|
||||||
void setState(util::State status);
|
void setState(util::State status);
|
||||||
std::string serialize() const;
|
SerializedInventoryItem serialize() const;
|
||||||
static InventoryItem* deserialize(const std::string&);
|
static InventoryItem* deserialize(const SerializedInventoryItem&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
@@ -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"
|
||||||
@@ -473,100 +474,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";
|
|
||||||
}
|
}
|
||||||
@@ -16,6 +16,7 @@ Date: 19-May-2026
|
|||||||
|
|
||||||
class ServiceBooking;
|
class ServiceBooking;
|
||||||
class InventoryItem;
|
class InventoryItem;
|
||||||
|
struct SerializedInvoice;
|
||||||
|
|
||||||
class Invoice
|
class Invoice
|
||||||
{
|
{
|
||||||
@@ -87,7 +88,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();
|
|
||||||
};
|
};
|
||||||
@@ -9,6 +9,7 @@ Date:19-May-2026
|
|||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "JobCard.h"
|
#include "JobCard.h"
|
||||||
#include "Factory.h"
|
#include "Factory.h"
|
||||||
#include "StringHelper.h"
|
#include "StringHelper.h"
|
||||||
@@ -351,79 +352,41 @@ void JobCard::setCompletionDate(const util::Timestamp& completionDate)
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the job card into a CSV-formatted string.
|
Description: Serializes the JobCard object into a SerializedJobCard record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized job card record
|
- SerializedJobCard: Serialized representation of the job card
|
||||||
*/
|
*/
|
||||||
std::string JobCard::serialize() const
|
SerializedJobCard JobCard::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedJobCard;
|
SerializedJobCard serialized = {};
|
||||||
serializedJobCard << 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_serviceId << ','
|
strcpy_s(serialized.serviceId, sizeof(serialized.serviceId), m_serviceId.c_str());
|
||||||
<< m_technicianId << ','
|
strcpy_s(serialized.technicianId, sizeof(serialized.technicianId), m_technicianId.c_str());
|
||||||
<< m_assignedDate.toString() << ','
|
serialized.assignedDate = m_assignedDate;
|
||||||
<< util::getServiceJobStatusString(m_status) << ','
|
serialized.status = m_status;
|
||||||
<< m_completionDate.toString();
|
serialized.completionDate = m_completionDate;
|
||||||
return serializedJobCard.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into a JobCard object.
|
Description: Deserializes a SerializedJobCard record into a JobCard object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized job card record
|
- serializedJobCard: const SerializedJobCard&, serialized job card record
|
||||||
Returns:
|
Returns:
|
||||||
- JobCard*: Pointer to the deserialized JobCard object
|
- JobCard*: Pointer to the deserialized JobCard object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if timestamp parsing fails
|
|
||||||
*/
|
*/
|
||||||
JobCard* JobCard::deserialize(const std::string& record)
|
JobCard* JobCard::deserialize(const SerializedJobCard& serializedJobCard)
|
||||||
{
|
{
|
||||||
std::string id, bookingId, serviceId, technicianId;
|
|
||||||
std::string assignedDateString, statusString, completionDateString;
|
|
||||||
std::istringstream serializedJobCard(record);
|
|
||||||
getline(serializedJobCard, id, ',');
|
|
||||||
getline(serializedJobCard, bookingId, ',');
|
|
||||||
getline(serializedJobCard, serviceId, ',');
|
|
||||||
getline(serializedJobCard, technicianId, ',');
|
|
||||||
getline(serializedJobCard, assignedDateString, ',');
|
|
||||||
getline(serializedJobCard, statusString, ',');
|
|
||||||
getline(serializedJobCard, completionDateString, ',');
|
|
||||||
util::Timestamp assignedDate;
|
|
||||||
util::Timestamp completionDate;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
assignedDate = util::Timestamp::fromString(assignedDateString);
|
|
||||||
completionDate = util::Timestamp::fromString(completionDateString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid timestamp");
|
|
||||||
}
|
|
||||||
util::ServiceJobStatus status = util::getServiceJobStatus(statusString);
|
|
||||||
return Factory::getObject<JobCard>(
|
return Factory::getObject<JobCard>(
|
||||||
id,
|
serializedJobCard.id,
|
||||||
bookingId,
|
serializedJobCard.bookingId,
|
||||||
serviceId,
|
serializedJobCard.serviceId,
|
||||||
technicianId,
|
serializedJobCard.technicianId,
|
||||||
assignedDate,
|
serializedJobCard.assignedDate,
|
||||||
status,
|
serializedJobCard.status,
|
||||||
completionDate
|
serializedJobCard.completionDate);
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for job card serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,BookingID,ServiceID,TechnicianID,AssignedDate,Status,CompletionDate")
|
|
||||||
*/
|
|
||||||
std::string JobCard::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,BookingID,ServiceID,TechnicianID,AssignedDate,Status,CompletionDate";
|
|
||||||
}
|
}
|
||||||
@@ -15,6 +15,7 @@ Date:19-May-2026
|
|||||||
class ServiceBooking;
|
class ServiceBooking;
|
||||||
class Service;
|
class Service;
|
||||||
class User;
|
class User;
|
||||||
|
struct SerializedJobCard;
|
||||||
|
|
||||||
class JobCard
|
class JobCard
|
||||||
{
|
{
|
||||||
@@ -70,7 +71,6 @@ public:
|
|||||||
void setAssignedDate(const util::Timestamp& assignedDate);
|
void setAssignedDate(const util::Timestamp& assignedDate);
|
||||||
void setStatus(util::ServiceJobStatus status);
|
void setStatus(util::ServiceJobStatus status);
|
||||||
void setCompletionDate(const util::Timestamp& completionDate);
|
void setCompletionDate(const util::Timestamp& completionDate);
|
||||||
std::string serialize() const;
|
SerializedJobCard serialize() const;
|
||||||
static JobCard* deserialize(const std::string&);
|
static JobCard* deserialize(const SerializedJobCard&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
@@ -7,6 +7,7 @@ Date: 19-May-2026
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "Notification.h"
|
#include "Notification.h"
|
||||||
#include "StringHelper.h"
|
#include "StringHelper.h"
|
||||||
#include "Factory.h"
|
#include "Factory.h"
|
||||||
@@ -23,7 +24,7 @@ Returns:
|
|||||||
*/
|
*/
|
||||||
Notification::Notification()
|
Notification::Notification()
|
||||||
: m_id("NOT" + std::to_string(++m_uid)),
|
: m_id("NOT" + std::to_string(++m_uid)),
|
||||||
m_recipient(nullptr) {}
|
m_recipient(nullptr), m_state(util::State::ACTIVE) {}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: Notification
|
Function: Notification
|
||||||
@@ -43,7 +44,8 @@ Notification::Notification(const std::string& recipientUserId, User* recipient,
|
|||||||
m_recipient(recipient),
|
m_recipient(recipient),
|
||||||
m_title(title),
|
m_title(title),
|
||||||
m_message(message),
|
m_message(message),
|
||||||
m_createdAt(createdAt) {}
|
m_state(util::State::ACTIVE),
|
||||||
|
m_createdAt(createdAt){}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: Notification (parameterized constructor with ID)
|
Function: Notification (parameterized constructor with ID)
|
||||||
@@ -58,13 +60,14 @@ Parameters:
|
|||||||
Returns:
|
Returns:
|
||||||
- A new Notification object
|
- A new Notification object
|
||||||
*/
|
*/
|
||||||
Notification::Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt)
|
Notification::Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt, const util::State& state)
|
||||||
: m_id(id),
|
: m_id(id),
|
||||||
m_recipientUserId(recipientUserId),
|
m_recipientUserId(recipientUserId),
|
||||||
m_recipient(nullptr),
|
m_recipient(nullptr),
|
||||||
m_title(title),
|
m_title(title),
|
||||||
m_message(message),
|
m_message(message),
|
||||||
m_createdAt(createdAt)
|
m_createdAt(createdAt),
|
||||||
|
m_state(state)
|
||||||
{
|
{
|
||||||
int idNumber = util::extractNumber(m_id);
|
int idNumber = util::extractNumber(m_id);
|
||||||
if (idNumber > m_uid)
|
if (idNumber > m_uid)
|
||||||
@@ -219,69 +222,39 @@ void Notification::setCreatedAt(const util::Timestamp& createdAt)
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the notification into a CSV-formatted string.
|
Description: Serializes the Notification object into a SerializedNotification record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized notification record
|
- SerializedNotification: Serialized representation of the notification
|
||||||
*/
|
*/
|
||||||
std::string Notification::serialize() const
|
SerializedNotification Notification::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedNotification;
|
SerializedNotification serialized = {};
|
||||||
serializedNotification << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< m_recipientUserId << ','
|
strcpy_s(serialized.recipientUserId, sizeof(serialized.recipientUserId), m_recipientUserId.c_str());
|
||||||
<< m_title << ','
|
strcpy_s(serialized.title, sizeof(serialized.title), m_title.c_str());
|
||||||
<< m_message << ','
|
strcpy_s(serialized.message, sizeof(serialized.message), m_message.c_str());
|
||||||
<< m_createdAt.toString();
|
serialized.createdAt = m_createdAt;
|
||||||
return serializedNotification.str();
|
serialized.state = m_state;
|
||||||
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into a Notification object.
|
Description: Deserializes a SerializedNotification record into a Notification object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized notification record
|
- serializedNotification: const SerializedNotification&, serialized notification record
|
||||||
Returns:
|
Returns:
|
||||||
- Notification*: Pointer to the deserialized Notification object
|
- Notification*: Pointer to the deserialized Notification object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if timestamp parsing fails
|
|
||||||
*/
|
*/
|
||||||
Notification* Notification::deserialize(const std::string& record)
|
Notification* Notification::deserialize(const SerializedNotification& serializedNotification)
|
||||||
{
|
{
|
||||||
std::string id, recipientUserId, title, message, createdAtTimestampString;
|
|
||||||
std::istringstream serializedNotification(record);
|
|
||||||
getline(serializedNotification, id, ',');
|
|
||||||
getline(serializedNotification, recipientUserId, ',');
|
|
||||||
getline(serializedNotification, title, ',');
|
|
||||||
getline(serializedNotification, message, ',');
|
|
||||||
getline(serializedNotification, createdAtTimestampString, ',');
|
|
||||||
util::Timestamp createdAtTimestamp;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
createdAtTimestamp = util::Timestamp::fromString(createdAtTimestampString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid createdAt timestamp");
|
|
||||||
}
|
|
||||||
return Factory::getObject<Notification>(
|
return Factory::getObject<Notification>(
|
||||||
id,
|
serializedNotification.id,
|
||||||
recipientUserId,
|
serializedNotification.recipientUserId,
|
||||||
title,
|
serializedNotification.title,
|
||||||
message,
|
serializedNotification.message,
|
||||||
createdAtTimestamp
|
serializedNotification.createdAt,
|
||||||
);
|
serializedNotification.state);
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for notification serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,RecipientID,Title,Message,Timestamp")
|
|
||||||
*/
|
|
||||||
std::string Notification::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,RecipientID,Title,Message,Timestamp";
|
|
||||||
}
|
}
|
||||||
@@ -9,8 +9,10 @@ Date: 19-May-2026
|
|||||||
#pragma once
|
#pragma once
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "Timestamp.h"
|
#include "Timestamp.h"
|
||||||
|
#include "Enums.h"
|
||||||
|
|
||||||
class User;
|
class User;
|
||||||
|
struct SerializedNotification;
|
||||||
|
|
||||||
class Notification
|
class Notification
|
||||||
{
|
{
|
||||||
@@ -22,10 +24,11 @@ private:
|
|||||||
std::string m_title;
|
std::string m_title;
|
||||||
std::string m_message;
|
std::string m_message;
|
||||||
util::Timestamp m_createdAt;
|
util::Timestamp m_createdAt;
|
||||||
|
util::State m_state;
|
||||||
public:
|
public:
|
||||||
Notification();
|
Notification();
|
||||||
Notification(const std::string& recipientUserId, User* recipient, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
Notification(const std::string& recipientUserId, User* recipient, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
||||||
Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt, const util::State& state);
|
||||||
const std::string& getId() const;
|
const std::string& getId() const;
|
||||||
const std::string& getRecipientUserId() const;
|
const std::string& getRecipientUserId() const;
|
||||||
User* getRecipient() const;
|
User* getRecipient() const;
|
||||||
@@ -38,7 +41,8 @@ public:
|
|||||||
void setTitle(const std::string& title);
|
void setTitle(const std::string& title);
|
||||||
void setMessage(const std::string& message);
|
void setMessage(const std::string& message);
|
||||||
void setCreatedAt(const util::Timestamp& createdAt);
|
void setCreatedAt(const util::Timestamp& createdAt);
|
||||||
std::string serialize() const;
|
util::State getState();
|
||||||
static Notification* deserialize(const std::string&);
|
void setState(util::State state);
|
||||||
static std::string getHeaders();
|
SerializedNotification serialize() const;
|
||||||
|
static Notification* deserialize(const SerializedNotification&);
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ Date: 19-May-2026
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "Service.h"
|
#include "Service.h"
|
||||||
#include "InventoryItem.h"
|
#include "InventoryItem.h"
|
||||||
#include "StringHelper.h"
|
#include "StringHelper.h"
|
||||||
@@ -266,72 +267,38 @@ static util::Vector<std::string> getInventoryItemIDsAsVector(const std::string&
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the service into a CSV-formatted string.
|
Description: Serializes the Service object into a SerializedService record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized service record
|
- SerializedService: Serialized representation of the service
|
||||||
*/
|
*/
|
||||||
std::string Service::serialize() const
|
SerializedService Service::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedService;
|
SerializedService serialized = {};
|
||||||
serializedService << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< m_name << ','
|
strcpy_s(serialized.name, sizeof(serialized.name), m_name.c_str());
|
||||||
<< getInventoryItemIDsAsString(m_requiredInventoryItemIDs) << ','
|
strcpy_s(serialized.inventoryItemIDs, sizeof(serialized.inventoryItemIDs), getInventoryItemIDsAsString(m_requiredInventoryItemIDs).c_str());
|
||||||
<< m_laborCost << ','
|
serialized.laborCost = m_laborCost;
|
||||||
<< util::getStateString(m_status);
|
serialized.status = m_status;
|
||||||
return serializedService.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into a Service object.
|
Description: Deserializes a SerializedService record into a Service object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized service record
|
- serializedService: const SerializedService&, serialized service record
|
||||||
Returns:
|
Returns:
|
||||||
- Service*: Pointer to the deserialized Service object
|
- Service*: Pointer to the deserialized Service object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if labor cost parsing fails
|
|
||||||
*/
|
*/
|
||||||
Service* Service::deserialize(const std::string& record)
|
Service* Service::deserialize(const SerializedService& serializedService)
|
||||||
{
|
{
|
||||||
std::string id, name;
|
util::Vector<std::string> inventoryItemIDs = getInventoryItemIDsAsVector(serializedService.inventoryItemIDs);
|
||||||
std::string inventoryItemIDsString, laborCostString, statusString;
|
|
||||||
double laborCost;
|
|
||||||
std::istringstream serializedService(record);
|
|
||||||
getline(serializedService, id, ',');
|
|
||||||
getline(serializedService, name, ',');
|
|
||||||
getline(serializedService, inventoryItemIDsString, ',');
|
|
||||||
getline(serializedService, laborCostString, ',');
|
|
||||||
getline(serializedService, statusString, ',');
|
|
||||||
util::Vector<std::string> inventoryItemIDs = getInventoryItemIDsAsVector(inventoryItemIDsString);
|
|
||||||
try
|
|
||||||
{
|
|
||||||
laborCost = std::stod(laborCostString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid labor cost");
|
|
||||||
}
|
|
||||||
util::State status = util::getState(statusString);
|
|
||||||
return Factory::getObject<Service>(
|
return Factory::getObject<Service>(
|
||||||
id,
|
serializedService.id,
|
||||||
name,
|
serializedService.name,
|
||||||
inventoryItemIDs,
|
inventoryItemIDs,
|
||||||
laborCost,
|
serializedService.laborCost,
|
||||||
status
|
serializedService.status);
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for service serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,Name,InventoryIDs,LaborCost,Status")
|
|
||||||
*/
|
|
||||||
std::string Service::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,Name,InventoryIDs,LaborCost,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"
|
||||||
@@ -14,6 +13,7 @@ Date: 19-May-2026
|
|||||||
#include "Enums.h"
|
#include "Enums.h"
|
||||||
|
|
||||||
class InventoryItem;
|
class InventoryItem;
|
||||||
|
struct SerializedService;
|
||||||
|
|
||||||
class Service
|
class Service
|
||||||
{
|
{
|
||||||
@@ -40,7 +40,6 @@ public:
|
|||||||
void setRequiredInventoryItems(const util::Map<std::string, InventoryItem*>& requiredInventoryItems);
|
void setRequiredInventoryItems(const util::Map<std::string, InventoryItem*>& requiredInventoryItems);
|
||||||
void setLaborCost(double laborCost);
|
void setLaborCost(double laborCost);
|
||||||
void setState(util::State status);
|
void setState(util::State status);
|
||||||
std::string serialize() const;
|
SerializedService serialize() const;
|
||||||
static Service* deserialize(const std::string&);
|
static Service* deserialize(const SerializedService&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
+28
-64
@@ -6,8 +6,10 @@ Description: Implementation file containing the method definitions of the
|
|||||||
Author: Trenser
|
Author: Trenser
|
||||||
Date:19-May-2026
|
Date:19-May-2026
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
|
#include "SerializedRecords.h"
|
||||||
#include "ServiceBooking.h"
|
#include "ServiceBooking.h"
|
||||||
#include "Service.h"
|
#include "Service.h"
|
||||||
#include "Enums.h"
|
#include "Enums.h"
|
||||||
@@ -437,84 +439,46 @@ static util::Vector<std::string> getServiceIDsAsVector(const std::string& servic
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: serialize
|
Function: serialize
|
||||||
Description: Serializes the service booking into a CSV-formatted string.
|
Description: Serializes the ServiceBooking object into a SerializedServiceBooking record.
|
||||||
Parameters:
|
Parameters:
|
||||||
- None
|
- None
|
||||||
Returns:
|
Returns:
|
||||||
- std::string: Serialized booking record
|
- SerializedServiceBooking: Serialized representation of the service booking
|
||||||
*/
|
*/
|
||||||
std::string ServiceBooking::serialize() const
|
SerializedServiceBooking ServiceBooking::serialize() const
|
||||||
{
|
{
|
||||||
std::ostringstream serializedBooking;
|
SerializedServiceBooking serialized = {};
|
||||||
serializedBooking << m_id << ','
|
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||||
<< util::getServiceJobStatusString(m_status) << ','
|
strcpy_s(serialized.serviceIDs, sizeof(serialized.serviceIDs), getServiceIDsAsString(m_serviceIDs).c_str());
|
||||||
<< getServiceIDsAsString(m_serviceIDs) << ','
|
strcpy_s(serialized.customerId, sizeof(serialized.customerId), m_customerId.c_str());
|
||||||
<< m_customerId << ','
|
strcpy_s(serialized.vehicleNumber, sizeof(serialized.vehicleNumber), m_vehicleNumber.c_str());
|
||||||
<< m_vehicleNumber << ','
|
strcpy_s(serialized.vehicleBrand, sizeof(serialized.vehicleBrand), m_vehicleBrand.c_str());
|
||||||
<< m_vehicleBrand << ','
|
strcpy_s(serialized.vehicleModel, sizeof(serialized.vehicleModel), m_vehicleModel.c_str());
|
||||||
<< m_vehicleModel << ','
|
strcpy_s(serialized.assignedTechnicianId, sizeof(serialized.assignedTechnicianId), m_assignedTechnicianId.c_str());
|
||||||
<< m_assignedTechnicianId << ','
|
serialized.status = m_status;
|
||||||
<< m_discountPercentage << ',';
|
serialized.discountPercentage = m_discountPercentage;
|
||||||
return serializedBooking.str();
|
return serialized;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deserialize
|
Function: deserialize
|
||||||
Description: Deserializes a CSV-formatted string into a ServiceBooking object.
|
Description: Deserializes a SerializedServiceBooking record into a ServiceBooking object.
|
||||||
Parameters:
|
Parameters:
|
||||||
- record: const std::string&, serialized booking record
|
- serializedServiceBooking: const SerializedServiceBooking&, serialized service booking record
|
||||||
Returns:
|
Returns:
|
||||||
- ServiceBooking*: Pointer to the deserialized ServiceBooking object
|
- ServiceBooking*: Pointer to the deserialized ServiceBooking object
|
||||||
Throws:
|
|
||||||
- std::runtime_error if discount percentage parsing fails
|
|
||||||
*/
|
*/
|
||||||
ServiceBooking* ServiceBooking::deserialize(const std::string& record)
|
ServiceBooking* ServiceBooking::deserialize(const SerializedServiceBooking& serializedServiceBooking)
|
||||||
{
|
{
|
||||||
std::string id, customerId, vehicleNumber, vehicleBrand, vehicleModel, assignedTechnicianId;
|
util::Vector<std::string> serviceIDs = getServiceIDsAsVector(serializedServiceBooking.serviceIDs);
|
||||||
std::string serviceJobStatusString, serviceIDsString, discountPercentageString;
|
|
||||||
double discountPercentage;
|
|
||||||
std::istringstream serializedBooking(record);
|
|
||||||
getline(serializedBooking, id, ',');
|
|
||||||
getline(serializedBooking, serviceJobStatusString, ',');
|
|
||||||
getline(serializedBooking, serviceIDsString, ',');
|
|
||||||
getline(serializedBooking, customerId, ',');
|
|
||||||
getline(serializedBooking, vehicleNumber, ',');
|
|
||||||
getline(serializedBooking, vehicleBrand, ',');
|
|
||||||
getline(serializedBooking, vehicleModel, ',');
|
|
||||||
getline(serializedBooking, assignedTechnicianId, ',');
|
|
||||||
getline(serializedBooking, discountPercentageString, ',');
|
|
||||||
util::Vector<std::string> serviceIDs = getServiceIDsAsVector(serviceIDsString);
|
|
||||||
try
|
|
||||||
{
|
|
||||||
discountPercentage = std::stod(discountPercentageString);
|
|
||||||
}
|
|
||||||
catch (...)
|
|
||||||
{
|
|
||||||
throw std::runtime_error("Invalid discount percentage");
|
|
||||||
}
|
|
||||||
util::ServiceJobStatus status = util::getServiceJobStatus(serviceJobStatusString);
|
|
||||||
return Factory::getObject<ServiceBooking>(
|
return Factory::getObject<ServiceBooking>(
|
||||||
id,
|
serializedServiceBooking.id,
|
||||||
status,
|
serializedServiceBooking.status,
|
||||||
serviceIDs,
|
serviceIDs,
|
||||||
customerId,
|
serializedServiceBooking.customerId,
|
||||||
vehicleNumber,
|
serializedServiceBooking.vehicleNumber,
|
||||||
vehicleBrand,
|
serializedServiceBooking.vehicleBrand,
|
||||||
vehicleModel,
|
serializedServiceBooking.vehicleModel,
|
||||||
assignedTechnicianId,
|
serializedServiceBooking.assignedTechnicianId,
|
||||||
discountPercentage
|
serializedServiceBooking.discountPercentage);
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getHeaders
|
|
||||||
Description: Retrieves the CSV headers for service booking serialization.
|
|
||||||
Parameters:
|
|
||||||
- None
|
|
||||||
Returns:
|
|
||||||
- std::string: Header string ("ID,Status,ServiceIDs,CustomerID,VehicleNumber,VehicleBrand,VehicleModel,AssignedTechnicianID,DiscountPercentage")
|
|
||||||
*/
|
|
||||||
std::string ServiceBooking::getHeaders()
|
|
||||||
{
|
|
||||||
return "ID,Status,ServiceIDs,CustomerID,VehicleNumber,VehicleBrand,VehicleModel,AssignedTechnicianID,DiscountPercentage";
|
|
||||||
}
|
}
|
||||||
@@ -6,6 +6,7 @@ Description: Header file declaring the ServiceBooking class, which represents
|
|||||||
Author: Trenser
|
Author: Trenser
|
||||||
Date:19-May-2026
|
Date:19-May-2026
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "Map.h"
|
#include "Map.h"
|
||||||
@@ -14,6 +15,7 @@ Date:19-May-2026
|
|||||||
|
|
||||||
class Service;
|
class Service;
|
||||||
class User;
|
class User;
|
||||||
|
struct SerializedServiceBooking;
|
||||||
|
|
||||||
class ServiceBooking
|
class ServiceBooking
|
||||||
{
|
{
|
||||||
@@ -78,7 +80,6 @@ public:
|
|||||||
void setAssignedTechnicianId(const std::string& assignedTechnicianId);
|
void setAssignedTechnicianId(const std::string& assignedTechnicianId);
|
||||||
void setAssignedTechnician(User* assignedTechnician);
|
void setAssignedTechnician(User* assignedTechnician);
|
||||||
void setDiscountPercentage(double discountPercentage);
|
void setDiscountPercentage(double discountPercentage);
|
||||||
std::string serialize() const;
|
SerializedServiceBooking serialize() const;
|
||||||
static ServiceBooking* deserialize(const std::string&);
|
static ServiceBooking* deserialize(const SerializedServiceBooking&);
|
||||||
static std::string getHeaders();
|
|
||||||
};
|
};
|
||||||
@@ -29,8 +29,7 @@ Returns:
|
|||||||
User::User()
|
User::User()
|
||||||
: m_id("USR" + std::to_string(++m_uid)),
|
: m_id("USR" + std::to_string(++m_uid)),
|
||||||
m_type(util::UserType::CUSTOMER),
|
m_type(util::UserType::CUSTOMER),
|
||||||
m_status(util::State::ACTIVE) {
|
m_status(util::State::ACTIVE) {}
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: User
|
Function: User
|
||||||
@@ -53,8 +52,7 @@ User::User(const std::string& userName, const std::string& password, const std::
|
|||||||
m_phone(phone),
|
m_phone(phone),
|
||||||
m_email(email),
|
m_email(email),
|
||||||
m_type(role),
|
m_type(role),
|
||||||
m_status(util::State::ACTIVE) {
|
m_status(util::State::ACTIVE) {}
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: User (parameterized constructor with ID)
|
Function: User (parameterized constructor with ID)
|
||||||
|
|||||||
+96
-80
@@ -20,9 +20,6 @@ Date:19-May-2026
|
|||||||
#include "UserManagementService.h"
|
#include "UserManagementService.h"
|
||||||
#include "Vector.h"
|
#include "Vector.h"
|
||||||
#include "Validator.h"
|
#include "Validator.h"
|
||||||
#include "Utility.h"
|
|
||||||
#include "TrackedRecord.h"
|
|
||||||
#include "DataStoreLockGuard.h"
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Function: ensureAdminExists
|
Function: ensureAdminExists
|
||||||
@@ -34,13 +31,12 @@ Return type: void
|
|||||||
*/
|
*/
|
||||||
void UserManagementService::ensureAdminExists()
|
void UserManagementService::ensureAdminExists()
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
|
||||||
auto& usersMap = m_dataStore.getUsers();
|
auto& usersMap = m_dataStore.getUsers();
|
||||||
int usersMapSize = usersMap.getSize();
|
int usersMapSize = usersMap.getSize();
|
||||||
bool isAdminFound = false;
|
bool isAdminFound = false;
|
||||||
for (int index = 0; index < usersMapSize; index++)
|
for (int index = 0; index < usersMapSize; index++)
|
||||||
{
|
{
|
||||||
User* user = usersMap.getValueAt(index).data;
|
User* user = usersMap.getValueAt(index);
|
||||||
if (user && user->getUserType() == util::UserType::ADMIN)
|
if (user && user->getUserType() == util::UserType::ADMIN)
|
||||||
{
|
{
|
||||||
isAdminFound = true;
|
isAdminFound = true;
|
||||||
@@ -77,9 +73,7 @@ void UserManagementService::createUser(const std::string& username, const std::s
|
|||||||
InventoryManagementService inventoryManagementService;
|
InventoryManagementService inventoryManagementService;
|
||||||
PaymentManagementService paymentManagementService;
|
PaymentManagementService paymentManagementService;
|
||||||
ServiceManagementService serviceManagementService;
|
ServiceManagementService serviceManagementService;
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
auto& usersMap = m_dataStore.getUsers();
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
|
||||||
auto usersMap = util::getObjects(trackedUsersMap);
|
|
||||||
if (util::isUsernameDuplicate(username, usersMap))
|
if (util::isUsernameDuplicate(username, usersMap))
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Username already exists");
|
throw std::runtime_error("Username already exists");
|
||||||
@@ -93,14 +87,13 @@ void UserManagementService::createUser(const std::string& username, const std::s
|
|||||||
throw std::runtime_error("Phone already exists");
|
throw std::runtime_error("Phone already exists");
|
||||||
}
|
}
|
||||||
User* newUser = Factory::getObject<User>(username, password, name, phone, email, type);
|
User* newUser = Factory::getObject<User>(username, password, name, phone, email, type);
|
||||||
trackedUsersMap.insert(newUser->getId(), util::createNewRecord(newUser));
|
usersMap.insert(newUser->getId(), newUser);
|
||||||
paymentManagementService.attach(newUser);
|
paymentManagementService.attach(newUser);
|
||||||
serviceManagementService.attach(newUser);
|
serviceManagementService.attach(newUser);
|
||||||
if (newUser->getUserType() == util::UserType::ADMIN)
|
if (newUser->getUserType() == util::UserType::ADMIN)
|
||||||
{
|
{
|
||||||
inventoryManagementService.attach(newUser);
|
inventoryManagementService.attach(newUser);
|
||||||
}
|
}
|
||||||
m_dataStore.saveUsers();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -114,24 +107,19 @@ Return type: void
|
|||||||
*/
|
*/
|
||||||
void UserManagementService::updateUserDetails(const std::string& userID, const std::string& email, const std::string& phone)
|
void UserManagementService::updateUserDetails(const std::string& userID, const std::string& email, const std::string& phone)
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
auto& usersMap = m_dataStore.getUsers();
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
int index = usersMap.find(userID);
|
||||||
auto usersMap = util::getObjects(trackedUsersMap);
|
|
||||||
int index = trackedUsersMap.find(userID);
|
|
||||||
if (index == -1)
|
if (index == -1)
|
||||||
{
|
{
|
||||||
throw std::runtime_error("User does not exist!\n");
|
throw std::runtime_error("User does not exist!\n");
|
||||||
}
|
}
|
||||||
User* user = trackedUsersMap.getValueAt(index).data;
|
User* user = usersMap.getValueAt(index);
|
||||||
bool isModified = false;
|
|
||||||
if (email != user->getEmail())
|
if (email != user->getEmail())
|
||||||
{
|
{
|
||||||
if (util::isEmailDuplicate(email, usersMap))
|
if (util::isEmailDuplicate(email, usersMap))
|
||||||
{
|
{
|
||||||
throw std::runtime_error("Email already exists!\n");
|
throw std::runtime_error("Email already exists!\n");
|
||||||
}
|
}
|
||||||
user->setEmail(email);
|
|
||||||
isModified = true;
|
|
||||||
}
|
}
|
||||||
if (phone != user->getPhone())
|
if (phone != user->getPhone())
|
||||||
{
|
{
|
||||||
@@ -139,14 +127,9 @@ void UserManagementService::updateUserDetails(const std::string& userID, const s
|
|||||||
{
|
{
|
||||||
throw std::runtime_error("Phone number already exists!\n");
|
throw std::runtime_error("Phone number already exists!\n");
|
||||||
}
|
}
|
||||||
user->setPhone(phone);
|
|
||||||
isModified = true;
|
|
||||||
}
|
|
||||||
if (isModified)
|
|
||||||
{
|
|
||||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
|
||||||
m_dataStore.saveUsers();
|
|
||||||
}
|
}
|
||||||
|
user->setEmail(email);
|
||||||
|
user->setPhone(phone);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -161,13 +144,12 @@ Throws:
|
|||||||
*/
|
*/
|
||||||
util::Vector<Notification*> UserManagementService::getUserNotifications(const std::string& userID)
|
util::Vector<Notification*> UserManagementService::getUserNotifications(const std::string& userID)
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
auto& usersMap = m_dataStore.getUsers();
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
if (usersMap.find(userID) == -1)
|
||||||
if (trackedUsersMap.find(userID) == -1)
|
|
||||||
{
|
{
|
||||||
throw std::runtime_error("No user found with given UserID");
|
throw std::runtime_error("No user found with given UserID");
|
||||||
}
|
}
|
||||||
User* user = trackedUsersMap[userID].data;
|
User* user = usersMap[userID];
|
||||||
if (user)
|
if (user)
|
||||||
{
|
{
|
||||||
auto& notifications = user->getNotifications();
|
auto& notifications = user->getNotifications();
|
||||||
@@ -187,41 +169,97 @@ util::Vector<Notification*> UserManagementService::getUserNotifications(const st
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
Function: deleteNotification
|
Function: deleteNotification
|
||||||
Description: Marks a specific notification associated with a given user
|
Description: Deletes a specific notification associated with a given user ID.
|
||||||
as inactive.
|
|
||||||
Parameters:
|
Parameters:
|
||||||
- notificationID: The unique ID of the notification to be deleted.
|
- notificationID: The unique ID of the notification to be deleted.
|
||||||
- userID: The unique ID of the user whose notification is to be deleted.
|
- userID: The unique ID of the user whose notification is to be deleted.
|
||||||
Returns:
|
Returns:
|
||||||
- void
|
- void
|
||||||
Throws:
|
Throws:
|
||||||
- std::runtime_error if no user is found with the given UserID or
|
- std::runtime_error if no user is found with the given UserID or if no notification is found with the given NotificationID.
|
||||||
if no notification is found with the given NotificationID.
|
|
||||||
*/
|
*/
|
||||||
void UserManagementService::deleteNotification(const std::string& notificationID, const std::string& userID)
|
void UserManagementService::deleteNotification(const std::string& notificationID, const std::string& userID)
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
auto& usersMap = m_dataStore.getUsers();
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
if (usersMap.find(userID) == -1)
|
||||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
|
||||||
int userIndex = trackedUsersMap.find(userID);
|
|
||||||
if (userIndex == -1)
|
|
||||||
{
|
{
|
||||||
throw std::runtime_error("No user found with given UserID");
|
throw std::runtime_error("No user found with given UserID");
|
||||||
}
|
}
|
||||||
User* user = trackedUsersMap.getValueAt(userIndex).data;
|
User* user = usersMap[userID];
|
||||||
auto& notifications = user->getNotifications();
|
auto& notifications = user->getNotifications();
|
||||||
if (notifications.find(notificationID) == -1)
|
if (notifications.find(notificationID) == -1)
|
||||||
{
|
{
|
||||||
throw std::runtime_error("No notification found with given NotificationID");
|
throw std::runtime_error("No notification found with given NotificationID");
|
||||||
}
|
}
|
||||||
int notificationIndex = trackedNotificationsMap.find(notificationID);
|
notifications.remove(notificationID);
|
||||||
if (notificationIndex == -1)
|
}
|
||||||
{
|
|
||||||
throw std::runtime_error("No notification found with given NotificationID");
|
/*
|
||||||
}
|
Function: loadUsers
|
||||||
notifications[notificationID]->setState(util::State::INACTIVE);
|
Description: Loads users and notifications from persistent storage into the datastore.
|
||||||
trackedNotificationsMap.getValueAt(notificationIndex).state = RecordState::MODIFIED;
|
Validates that each notification’s recipient exists and attaches the
|
||||||
m_dataStore.saveNotifications();
|
notification to the corresponding user.
|
||||||
|
Parameters:
|
||||||
|
- None
|
||||||
|
Returns:
|
||||||
|
- void
|
||||||
|
Throws:
|
||||||
|
- std::runtime_error if a notification recipient user ID is invalid
|
||||||
|
*/
|
||||||
|
void UserManagementService::loadUsers()
|
||||||
|
{
|
||||||
|
util::FileManager<User> userFileManager(config::file::USER_FILE);
|
||||||
|
util::FileManager<Notification> notificationFileManager(config::file::NOTIFICATION_FILE);
|
||||||
|
auto& users = m_dataStore.getUsers();
|
||||||
|
auto usersMap = userFileManager.load();
|
||||||
|
auto notificationsMap = notificationFileManager.load();
|
||||||
|
int numberOfUsers = usersMap.getSize();
|
||||||
|
int numberOfNotifications = notificationsMap.getSize();
|
||||||
|
for (int index = 0; index < numberOfUsers; index++)
|
||||||
|
{
|
||||||
|
users[usersMap.getKeyAt(index)] = usersMap.getValueAt(index);
|
||||||
|
}
|
||||||
|
for (int index = 0; index < numberOfNotifications; index++)
|
||||||
|
{
|
||||||
|
Notification* notification = notificationsMap.getValueAt(index);
|
||||||
|
const std::string& recipientUserId = notification->getRecipientUserId();
|
||||||
|
int userIndex = users.find(recipientUserId);
|
||||||
|
if (userIndex == -1)
|
||||||
|
{
|
||||||
|
throw std::runtime_error("Invalid recipient user ID");
|
||||||
|
}
|
||||||
|
User* user = users.getValueAt(userIndex);
|
||||||
|
user->addNotification(notification);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Function: saveUsers
|
||||||
|
Description: Saves users and their notifications from the datastore to persistent storage.
|
||||||
|
Collects notifications from all users into a single map before saving.
|
||||||
|
Parameters:
|
||||||
|
- None
|
||||||
|
Returns:
|
||||||
|
- void
|
||||||
|
*/
|
||||||
|
void UserManagementService::saveUsers()
|
||||||
|
{
|
||||||
|
util::FileManager<User> userFileManager(config::file::USER_FILE);
|
||||||
|
util::FileManager<Notification> notificationFileManager(config::file::NOTIFICATION_FILE);
|
||||||
|
auto& users = m_dataStore.getUsers();
|
||||||
|
util::Map<std::string, Notification*> notifications;
|
||||||
|
for (int userIndex = 0; userIndex < users.getSize(); userIndex++)
|
||||||
|
{
|
||||||
|
User* user = users.getValueAt(userIndex);
|
||||||
|
auto& userNotifications = user->getNotifications();
|
||||||
|
for (int notificationIndex = 0; notificationIndex < userNotifications.getSize(); notificationIndex++)
|
||||||
|
{
|
||||||
|
notifications[userNotifications.getKeyAt(notificationIndex)] =
|
||||||
|
userNotifications.getValueAt(notificationIndex);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
userFileManager.save(users);
|
||||||
|
notificationFileManager.save(notifications);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -232,9 +270,7 @@ Return type: util::Map<std::string, User*>
|
|||||||
*/
|
*/
|
||||||
util::Map<std::string, User*> UserManagementService::getUsers()
|
util::Map<std::string, User*> UserManagementService::getUsers()
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
return m_dataStore.getUsers();
|
||||||
auto users = util::getObjects(m_dataStore.getUsers());
|
|
||||||
return users;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -245,12 +281,10 @@ Return type: User*
|
|||||||
*/
|
*/
|
||||||
User* UserManagementService::getUser(const std::string& userID)
|
User* UserManagementService::getUser(const std::string& userID)
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
int index = m_dataStore.getUsers().find(userID);
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
|
||||||
int index = trackedUsersMap.find(userID);
|
|
||||||
if (index != -1)
|
if (index != -1)
|
||||||
{
|
{
|
||||||
return trackedUsersMap.getValueAt(index).data;
|
return m_dataStore.getUsers().getValueAt(index);
|
||||||
}
|
}
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
@@ -266,53 +300,35 @@ void UserManagementService::removeUser(const std::string& userID)
|
|||||||
InventoryManagementService inventoryManagementService;
|
InventoryManagementService inventoryManagementService;
|
||||||
PaymentManagementService paymentManagementService;
|
PaymentManagementService paymentManagementService;
|
||||||
ServiceManagementService serviceManagementService;
|
ServiceManagementService serviceManagementService;
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
int index = m_dataStore.getUsers().find(userID);
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
|
||||||
int index = trackedUsersMap.find(userID);
|
|
||||||
if (index != -1)
|
if (index != -1)
|
||||||
{
|
{
|
||||||
User* user = trackedUsersMap.getValueAt(index).data;
|
User* user = m_dataStore.getUsers().getValueAt(index);
|
||||||
if (user != nullptr)
|
if (user != nullptr)
|
||||||
{
|
{
|
||||||
if (user->getUserType() == util::UserType::CUSTOMER)
|
if (user->getUserType() == util::UserType::CUSTOMER)
|
||||||
{
|
{
|
||||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||||
}
|
}
|
||||||
if (user->getUserType() == util::UserType::TECHNICIAN)
|
if (user->getUserType() == util::UserType::TECHNICIAN)
|
||||||
{
|
{
|
||||||
serviceManagementService.cancelTechnicianJobs(userID);
|
serviceManagementService.cancelTechnicianJobs(userID);
|
||||||
}
|
}
|
||||||
|
user->setState(util::State::INACTIVE);
|
||||||
inventoryManagementService.detach(user);
|
inventoryManagementService.detach(user);
|
||||||
paymentManagementService.detach(user);
|
paymentManagementService.detach(user);
|
||||||
serviceManagementService.detach(user);
|
serviceManagementService.detach(user);
|
||||||
user->setState(util::State::INACTIVE);
|
|
||||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
|
||||||
m_dataStore.saveUsers();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
util::Map<std::string, User*> UserManagementService::getUsers(util::UserType type)
|
||||||
Function: getUsers
|
|
||||||
Description: Retrieves all active users of the specified type from
|
|
||||||
the DataStore.
|
|
||||||
Parameters:
|
|
||||||
- type: The user type to filter by
|
|
||||||
(ADMIN, CUSTOMER, or TECHNICIAN).
|
|
||||||
Returns:
|
|
||||||
- util::Map<std::string, User*>:
|
|
||||||
Collection of active users matching the specified type,
|
|
||||||
keyed by user ID.
|
|
||||||
*/
|
|
||||||
util::Map<std::string, User*> UserManagementService::getUsers(util::UserType type)
|
|
||||||
{
|
{
|
||||||
DataStoreLockGuard lock(m_dataStore);
|
util::Map<std::string, User*>& currentUsers = m_dataStore.getUsers();
|
||||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
|
||||||
util::Map<std::string, User*> currentUsers = util::getObjects(trackedUsersMap);
|
|
||||||
util::Map<std::string, User*> filteredUsersMap;
|
util::Map<std::string, User*> filteredUsersMap;
|
||||||
for (int index = 0; index < currentUsers.getSize(); index++)
|
for (int iterator = 0; iterator < currentUsers.getSize(); iterator++)
|
||||||
{
|
{
|
||||||
User* currentUser = currentUsers.getValueAt(index);
|
User* currentUser = currentUsers.getValueAt(iterator);
|
||||||
if (currentUser && currentUser->getState() == util::State::ACTIVE && currentUser->getUserType() == type)
|
if (currentUser && currentUser->getState() == util::State::ACTIVE && currentUser->getUserType() == type)
|
||||||
{
|
{
|
||||||
filteredUsersMap.insert(currentUser->getId(), currentUser);
|
filteredUsersMap.insert(currentUser->getId(), currentUser);
|
||||||
|
|||||||
+2
@@ -31,4 +31,6 @@ public:
|
|||||||
util::Vector<Notification*> getUserNotifications(const std::string& userID);
|
util::Vector<Notification*> getUserNotifications(const std::string& userID);
|
||||||
void deleteNotification(const std::string& notificationID, const std::string& userID);
|
void deleteNotification(const std::string& notificationID, const std::string& userID);
|
||||||
void ensureAdminExists();
|
void ensureAdminExists();
|
||||||
|
void loadUsers();
|
||||||
|
void saveUsers();
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -99,80 +99,4 @@ namespace util
|
|||||||
auto observerIDs = service->getObserverIDs();
|
auto observerIDs = service->getObserverIDs();
|
||||||
util::saveRecords(filePath, observerIDs);
|
util::saveRecords(filePath, observerIDs);
|
||||||
}
|
}
|
||||||
|
|
||||||
template<typename TObject>
|
|
||||||
Map<std::string, TObject*> getObjects(const Map<std::string, TrackedRecord<TObject>>& trackedRecords);
|
|
||||||
|
|
||||||
template<typename TObject>
|
|
||||||
Map<std::string, const TObject*> getConstObjects(const Map<std::string, TrackedRecord<TObject>>& trackedRecords);
|
|
||||||
|
|
||||||
template<typename TObject>
|
|
||||||
TrackedRecord<TObject> createNewRecord(TObject* object);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getObjects
|
|
||||||
Description: Extracts the object pointers from a tracked-record
|
|
||||||
collection and returns them as a map keyed by the
|
|
||||||
same identifiers.
|
|
||||||
Parameters:
|
|
||||||
- trackedRecords: Collection of tracked records.
|
|
||||||
Returns:
|
|
||||||
- Map<std::string, TObject*>: Collection of object pointers.
|
|
||||||
*/
|
|
||||||
template<typename TObject>
|
|
||||||
util::Map<std::string, TObject*> util::getObjects(const util::Map<std::string, TrackedRecord<TObject>>& trackedRecords)
|
|
||||||
{
|
|
||||||
util::Map<std::string, TObject*> objects;
|
|
||||||
for (int index = 0; index < trackedRecords.getSize(); ++index)
|
|
||||||
{
|
|
||||||
const std::string& key = trackedRecords.getKeyAt(index);
|
|
||||||
TObject* object = trackedRecords.getValueAt(index).data;
|
|
||||||
objects.insert(key, object);
|
|
||||||
}
|
|
||||||
return objects;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: getConstObjects
|
|
||||||
Description: Extracts the object pointers from a tracked-record
|
|
||||||
collection and returns them as a read-only map
|
|
||||||
keyed by the same identifiers.
|
|
||||||
Parameters:
|
|
||||||
- trackedRecords: Collection of tracked records.
|
|
||||||
Returns:
|
|
||||||
- Map<std::string, const TObject*>:
|
|
||||||
Collection of read-only object pointers.
|
|
||||||
*/
|
|
||||||
template<typename TObject>
|
|
||||||
util::Map<std::string, const TObject*> util::getConstObjects(
|
|
||||||
const util::Map<std::string, TrackedRecord<TObject>>& trackedRecords)
|
|
||||||
{
|
|
||||||
util::Map<std::string, const TObject*> objects;
|
|
||||||
for (int index = 0; index < trackedRecords.getSize(); ++index)
|
|
||||||
{
|
|
||||||
const std::string& key = trackedRecords.getKeyAt(index);
|
|
||||||
const TObject* object = trackedRecords.getValueAt(index).data;
|
|
||||||
objects.insert(key, object);
|
|
||||||
}
|
|
||||||
return objects;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
Function: createNewRecord
|
|
||||||
Description: Creates a tracked record for a newly created
|
|
||||||
object. The record is initialized with
|
|
||||||
NEW_RECORD state.
|
|
||||||
Parameters:
|
|
||||||
- object: Pointer to the newly created object.
|
|
||||||
Returns:
|
|
||||||
- TrackedRecord<TObject>: Initialized tracked record.
|
|
||||||
*/
|
|
||||||
template<typename TObject>
|
|
||||||
TrackedRecord<TObject> util::createNewRecord(TObject* object)
|
|
||||||
{
|
|
||||||
TrackedRecord<TObject> record;
|
|
||||||
record.data = object;
|
|
||||||
record.state = RecordState::NEW_RECORD;
|
|
||||||
return record;
|
|
||||||
}
|
}
|
||||||
@@ -27,11 +27,8 @@ void UserInterface::run()
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (!m_controller.initialize())
|
m_controller.loadSystemData();
|
||||||
{
|
m_controller.runSystemChecks();
|
||||||
std::cout << "Error: Failed to initialize the system!";
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
bool isMenuActive = true;
|
bool isMenuActive = true;
|
||||||
while (isMenuActive)
|
while (isMenuActive)
|
||||||
{
|
{
|
||||||
@@ -52,7 +49,7 @@ void UserInterface::run()
|
|||||||
util::pressEnter();
|
util::pressEnter();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m_controller.shutdown();
|
m_controller.saveSystemData();
|
||||||
}
|
}
|
||||||
catch (const std::invalid_argument& exception)
|
catch (const std::invalid_argument& exception)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user