Real-time financial sweeps management system and method

A system, comprising:

• a file database configured to store a plurality of files, wherein the plurality of files includes client information;
• a transaction database configured to store a plurality of financial transactions of a transaction system;
• and
• a financial sweeps management system operatively connected to the file database and the transaction database, comprising:
• a hardware-based system processor;
• a system memory configured to store instructions and configured to provide the instructions to the hardware-based system processor;
• and
• a set of modules configured to implement the instructions provided to the hardware-based system processor, the set of modules including:
• a sweeps processing module including a policy-implementing pipeline and a calendar module, the sweeps processing module being responsive to the detecting of an erroneous transaction among the plurality of financial transactions stored in the transaction database of the transaction system, to generate a rollback request to the sweeps processing module, the sweeps processing module configured to filter the detected erroneous transaction based on a set of predetermined rules and to restore the transaction database of the transaction system to a healthy state in case of the erroneous transaction detected during processing of financial transactions by the transaction system, and the calendar module is responsible for generating an epoch identification (epochID) associated with each financial transaction corresponding to an epoch during a business day, with the epochID being an incrementing identification value which is used to rollback the financial transactions and restore the transaction database of the transaction system back to the healthy state;
• a sweeps allocation module;
• a file processing module configured to process the plurality of files from the file database, and to load the processed files into the sweeps processing module;
• and
• a transaction pre-processing module configured to process the plurality of financial transactions streaming in real-time from the transaction database, to format the financial transactions, and to load the formatted financial transactions into the sweeps processing module,
• wherein the sweeps processing module is configured to apply the processed files and the formatted financial transactions to the policy-implementing pipeline to generate sweeps allocation data in real-time,
• wherein the sweeps allocation module, responsive to the sweeps allocation data, is configured to perform an allocation of financial values to implement a financial sweep based on different levels of complexity, and
• wherein the sweeps processing module, responsive to the rollback request, rolls back the financial transactions by reprocessing at least one million financial transactions within twenty minutes before the end of an intraday period and having a selected epochID for a corresponding epoch including the detected erroneous transaction, thereby filtering the erroneous transaction by skipping the detected erroneous transaction based on the selected epochID and selectively restoring the transaction database to the healthy state.

A computer-based method, comprising:

• loading a plurality of files into a sweeps processing module including a policy-implementing pipeline and a calendar module, wherein each file is associated with client information;
• receiving a plurality of financial transactions in a transaction database of a transaction system;
• processing the received plurality of financial transactions streaming in real-time;
• formatting the plurality of financial transactions;
• loading the formatted financial transactions into the sweeps processing module;
• processing the formatted financial transactions using a set of predetermined rules;
• detecting an erroneous transaction among the formatted financial transactions;
• responsive to the detecting of the erroneous transaction, generating a rollback request;
• processing the loaded files and the loaded formatted financial transactions by the policy-implementing pipeline;
• generating sweeps allocation data in real-time from the loaded files and the loaded formatted financial transactions using the policy-implementing pipeline;
• responsive to the sweeps allocation data, performing an allocation of financial values to implement a financial sweep based on different levels of complexity using the sweeps allocation module,
• generating an epoch identification (epochID) associated with each financial transaction and corresponding to an epoch during a business day using the calendar module with the epochID being an incrementing identification value which is used to rollback the financial transactions,
• receiving the rollback request, and
• responsive to the rollback request, rolling back the financial transactions by reprocessing at least one million financial transactions within twenty minutes before the end of an intraday period and having a selected epochID for a corresponding epoch including the detected erroneous transaction, thereby filtering the erroneous transaction based on a set of predetermined rules by skipping the detected erroneous transaction based on the selected epochID and restoring the transaction database of the transaction system to a healthy state in case of the erroneous transaction detected during processing of financial transactions by the transaction system and selectively restoring the transaction database to the healthy state.