Method processGroupedTransactions

reconciliation.go:828–854

processGroupedTransactions handles the matching of transactions for both one-to-many and many-to-one reconciliations. It processes each transaction group in parallel, comparing them to the target transactions. Parameters: - singleTxns: The single transactions (either external or internal). - grouped

(singleTxns []*model.Transaction, groupedTxns map[string][]*model.Transaction, groupMap map[string]bool, matchingRules []model.MatchingRule, isExternalGrouped bool, wg *sync.WaitGroup, matchChan chan model.Match, unMatchChan chan string)

// Returns:
// - error: If any error occurs during processing.
func (s *LedgerForge) processGroupedTransactions(singleTxns []*model.Transaction, groupedTxns map[string][]*model.Transaction, groupMap map[string]bool, matchingRules []model.MatchingRule, isExternalGrouped bool, wg *sync.WaitGroup, matchChan chan model.Match, unMatchChan chan string) error {
	conf, err := config.Fetch()
	if err != nil {
		logrus.Errorf("Error fetching configuration: %v", err)
	}
	maxWorkers := 10 // Default
	if conf != nil {
		maxWorkers = conf.Transaction.MaxWorkers
	}
	sem := make(chan struct{}, maxWorkers) // Semaphore to limit concurrency

	for _, singleTxn := range singleTxns {
		wg.Add(1)
		go func(txn *model.Transaction) {
			defer wg.Done()
			sem <- struct{}{}        // Acquire token
			defer func() { <-sem }() // Release token

			matched := s.matchSingleTransaction(txn, groupedTxns, groupMap, matchingRules, isExternalGrouped, matchChan)
			if !matched {
				unMatchChan <- txn.TransactionID
			}
		}(singleTxn)
	}

	return nil
}

// matchSingleTransaction attempts to match a single transaction with a group of transactions based on matching rules.
// If a match is found, it sends the match to the match channel and marks the group as processed.