Method manyToOne

reconciliation.go:772–799

manyToOne handles the core logic of many-to-one reconciliation. It groups external transactions and processes them in batches, comparing them to internal transactions. Parameters: - ctx: The context controlling the operation. - internalTxns: The internal transactions to match against. - matchingRule

(ctx context.Context, internalTxns []*model.Transaction, uploadID string, matchingRules []model.MatchingRule, isExternalGrouped bool, wg *sync.WaitGroup, groupingCriteria string, batchSize int, matchChan chan model.Match, unMatchChan chan string)

// Returns:
// - error: If any error occurs during processing.
func (s *LedgerForge) manyToOne(ctx context.Context, internalTxns []*model.Transaction, uploadID string, matchingRules []model.MatchingRule, isExternalGrouped bool, wg *sync.WaitGroup, groupingCriteria string, batchSize int, matchChan chan model.Match, unMatchChan chan string) error {
	offset := int64(0)
	ctx, span := otel.Tracer("ledgerforge.reconciliation").Start(ctx, "ProcessManyToOne")
	defer span.End()

	// Loop to process transactions in batches.
	for {
		groupedExternalTxns, err := s.groupExternalTransactions(ctx, uploadID, groupingCriteria, batchSize, offset)
		if err != nil {
			logrus.Errorf("Error grouping external transactions: %v", err)
			break
		}
		if len(groupedExternalTxns) == 0 {
			span.AddEvent("No more grouped transactions to process")
			break
		}
		groupMap := s.buildGroupMap(groupedExternalTxns)
		err = s.processGroupedTransactions(internalTxns, groupedExternalTxns, groupMap, matchingRules, isExternalGrouped, wg, matchChan, unMatchChan)
		if err != nil {
			logrus.Errorf("Error processing grouped transactions: %v", err)
		}
		if len(groupMap) == 0 {
			break
		}
		offset += int64(batchSize)
	}
	return nil
}

// groupExternalTransactions retrieves and groups external transactions based on the specified criteria.
// This is used in many-to-one reconciliation.