Method oneToManyReconciliation

reconciliation.go:681–714

oneToManyReconciliation performs a one-to-many reconciliation, where each external transaction can match multiple internal transactions grouped by specific criteria. Parameters are the same as `oneToOneReconciliation`, with additional support for grouping criteria and a flag to determine if the exte

(ctx context.Context, externalTxns []*model.Transaction, groupCriteria string, matchingRules []model.MatchingRule, isExternalGrouped bool)

// - []model.Match: A list of matched transactions.
// - []string: A list of unmatched transaction IDs.
func (s *LedgerForge) oneToManyReconciliation(ctx context.Context, externalTxns []*model.Transaction, groupCriteria string, matchingRules []model.MatchingRule, isExternalGrouped bool) ([]model.Match, []string) {
	conf, err := config.Fetch()
	if err != nil {
		logrus.Errorf("Error fetching configuration: %v", err)
	}

	var matches []model.Match
	var unmatched []string

	matchChan := make(chan model.Match, len(externalTxns))
	unmatchedChan := make(chan string, len(externalTxns))
	var wg sync.WaitGroup

	// Initiate the one-to-many reconciliation process.
	err = s.oneToMany(ctx, externalTxns, matchingRules, isExternalGrouped, &wg, groupCriteria, conf.Transaction.BatchSize, matchChan, unmatchedChan)
	if err != nil {
		logrus.Errorf("Error in one-to-many reconciliation: %v", err)
	}

	go func() {
		wg.Wait()
		close(matchChan)
		close(unmatchedChan)
	}()

	for match := range matchChan {
		matches = append(matches, match)
	}
	for unmatchedID := range unmatchedChan {
		unmatched = append(unmatched, unmatchedID)
	}

	return matches, unmatched
}

// manyToOneReconciliation performs a many-to-one reconciliation, where multiple internal transactions
// are grouped and matched against a single external transaction.