Method finalizeReconciliation

reconciliation.go:586–611

finalizeReconciliation finalizes the reconciliation process by updating its status and recording the final match/unmatch counts. Parameters: - ctx: The context controlling the request. - reconciliation: The reconciliation object representing the current process. - matchCount: The number of matched t

(ctx context.Context, reconciliation model.Reconciliation, matchCount, unmatchedCount int)

// Returns:
// - error: If any error occurs during finalization.
func (s *LedgerForge) finalizeReconciliation(ctx context.Context, reconciliation model.Reconciliation, matchCount, unmatchedCount int) error {
	// Update the reconciliation status to "completed".
	reconciliation.Status = StatusCompleted
	reconciliation.UnmatchedTransactions = unmatchedCount
	reconciliation.MatchedTransactions = matchCount
	reconciliation.CompletedAt = ptr.Time(time.Now())

	logrus.Infof("Finalizing reconciliation. Matches: %d, Unmatched: %d", matchCount, unmatchedCount)

	if !reconciliation.IsDryRun {
		s.postReconciliationActions(ctx, reconciliation)
	} else {
		logrus.Infof("Dry run completed. Matches: %d, Unmatched: %d", matchCount, unmatchedCount)
	}

	// Update the final reconciliation status and counts in the data source.
	err := s.datasource.UpdateReconciliationStatus(ctx, reconciliation.ReconciliationID, StatusCompleted, matchCount, unmatchedCount)
	if err != nil {
		logrus.Errorf("Error updating reconciliation status: %v", err)
		return err
	}

	logrus.Infof("Reconciliation %s completed. Total matches: %d, Total unmatched: %d", reconciliation.ReconciliationID, matchCount, unmatchedCount)

	return nil
}

// oneToOneReconciliation performs a one-to-one reconciliation, where each external transaction is matched against
// a single internal transaction. The process is parallelized using goroutines.