Finance/Schaad.Finance/Formats/AccountStatements/CAMT053.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Xml.Serialization;
using Schaad.Finance.Api;
using Schaad.Finance.Api.AccountStatements;
using Schaad.Finance.Formats.AccountStatements.Models;

namespace Schaad.Finance.Formats.AccountStatements
{
    /// <summary>
    /// Reads CAMT053 format
    /// https://www.six-interbank-clearing.com/dam/downloads/de/standardization/iso/swiss-recommendations/implementation-guidelines-camt.pdf
    /// </summary>
    public class CAMT053 : IAccountStatementParsingService
    {
        public List<AccountStatement> ReadFile(string filePath, Encoding encoding)
        {
            var accountStatements = new List<AccountStatement>();
            var serializer = new XmlSerializer(typeof(Document));
            using (var fileStream = new FileStream(filePath, FileMode.Open))
            {
                using (var reader = new StreamReader(fileStream, encoding))
                {
                    var document = (Document)serializer.Deserialize(reader);
                    foreach (var stmt in document.BkToCstmrStmt.Stmt)
                    {
                        var accountStatement = new AccountStatement();
                        accountStatements.Add(accountStatement);

                        accountStatement.AccountNumber = stmt.Acct.Id.Item.ToString();
                        accountStatement.Currency = stmt.Acct.Ccy;

                        foreach (var balance in stmt.Bal)
                        {
                            // var balanceAmount =  balance.Amt.Value;
                            // var balanceCurrency = balance.Amt.Ccy;
                            // var balanceDate = balance.Dt.Item;
                            // var creditDebit = balance.CdtDbtInd;

                            var balanceType = (BalanceType12Code)balance.Tp.CdOrPrtry.Item;
                            if (balanceType == BalanceType12Code.OPBD)
                            {
                                accountStatement.StartBalance = new Balance
                                {
                                    BookingDate = balance.Dt.Item,
                                    Value = (double)balance.Amt.Value,
                                };
                            }
                            else if (balanceType == BalanceType12Code.CLBD)
                            {
                                accountStatement.EndBalance = new Balance
                                {
                                    BookingDate = balance.Dt.Item,
                                    Value = (double)balance.Amt.Value,
                                };
                            }
                        }

                        if (stmt.TxsSummry != null)
                        {
                            if (stmt.TxsSummry.TtlCdtNtries != null)
                            {
                                accountStatement.CreditTransactionSummary = new TransactionSummary
                                {
                                    NumberOfTransaction = int.Parse(stmt.TxsSummry.TtlCdtNtries.NbOfNtries),
                                    Sum = stmt.TxsSummry.TtlCdtNtries.Sum
                                };
                            }
                            else
                            {
                                accountStatement.CreditTransactionSummary = new TransactionSummary();
                            }

                            if (stmt.TxsSummry.TtlDbtNtries != null)
                            {
                                accountStatement.DebitTransactionSummary = new TransactionSummary
                                {
                                    NumberOfTransaction = int.Parse(stmt.TxsSummry.TtlDbtNtries.NbOfNtries),
                                    Sum = stmt.TxsSummry.TtlDbtNtries.Sum
                                };
                            }
                            else
                            {
                                accountStatement.DebitTransactionSummary = new TransactionSummary();
                            }
                        }

                        accountStatement.Transactions = new List<Transaction>();
                        if (stmt.Ntry != null)
                        {
                            foreach (var entry in stmt.Ntry)
                            {
                                 (var text, var debtor, var creditor) = ParseEntry(entry);

                                var transaction = new Transaction();
                                transaction.Id = stmt.Id + entry.NtryRef;
                                transaction.BookingDate = entry.BookgDt.Item;
                                transaction.Text = text;
                                transaction.Debtor = debtor;
                                transaction.Creditor = creditor;
                                transaction.Value = (double)entry.Amt.Value;
                                transaction.ValueDate = entry.ValDt.Item;

                                if (entry.CdtDbtInd == CreditDebitCode.DBIT)
                                {
                                    transaction.Value *= -1;
                                }

                                accountStatement.Transactions.Add(transaction);
                            }
                        }
                    }
                }
            }

            return accountStatements;
        }

        private (string text, string debtor, string creditor) ParseEntry(ReportEntry4 entry)
        {
            var transactionTexts = new HashSet<string>();
            var transactionReferences = new HashSet<string>();
            var debtors = new HashSet<string>();
            var creditors = new HashSet<string>();

            if (!string.IsNullOrEmpty(entry.AddtlNtryInf))
            {
                foreach (var addtlNtryInf in SplitForNewline(entry.AddtlNtryInf).Where(a => !string.IsNullOrEmpty(a)))
                {
                    transactionTexts.Add(addtlNtryInf);
                }
            }

            foreach (var ntryDtl in entry.NtryDtls)
            {
                foreach (var txDtl in ntryDtl.TxDtls)
                {
                    if (txDtl.RmtInf?.Ustrd != null)
                    {
                        foreach (var ustrd in txDtl.RmtInf.Ustrd)
                        {
                            foreach (var info in SplitForNewline(ustrd).Where(a => !string.IsNullOrEmpty(a)))
                            {
                                transactionTexts.Add(info.Trim());
                            }
                        }
                    }

                    if (txDtl.RltdPties?.Cdtr != null)
                    {
                        creditors.Add(ParseRelatedParty(txDtl.RltdPties.Cdtr));
                    }

                    if (txDtl.RltdPties?.Dbtr != null)
                    {
                        debtors.Add(ParseRelatedParty(txDtl.RltdPties.Dbtr));
                    }

                    if (txDtl.Refs != null)
                    {
                        transactionReferences.Add(ParseTransactionReference(txDtl.Refs));
                    }
                }
            }

            var debtorsText = GetText(debtors);
            var creditorsText = GetText(creditors);
            var transactionTexts1 = transactionTexts.Count > 0 ? GetText(transactionTexts) : GetText(transactionReferences);

            return (transactionTexts1, debtorsText, creditorsText);
        }

        private string ParseRelatedParty(PartyIdentification43 entry)
        {
            var texts = new HashSet<string>();
            AddIfNotEmpty(texts, entry.Nm);
            if (entry.PstlAdr != null)
            {
                AddIfNotEmpty(texts, entry.PstlAdr.StrtNm);
                AddIfNotEmpty(texts, entry.PstlAdr.PstCd);
                AddIfNotEmpty(texts, entry.PstlAdr.TwnNm);

                if (entry.PstlAdr.AdrLine != null)
                {
                    foreach (var line in entry.PstlAdr.AdrLine)
                    {
                        AddIfNotEmpty(texts, line);
                    }
                }
            }

            return GetAddress(texts);
        }

        private string ParseTransactionReference(TransactionReferences3 entry)
        {
            return entry.InstrId;
        }

        private IReadOnlyList<string> SplitForNewline(string text)
        {
            return text.Split('\n');
        }

        private string GetText(HashSet<string> lines)
        {
            return string.Join(" / ", lines);
        }

        private string GetAddress(HashSet<string> lines)
        {
            return string.Join(" ", lines);
        }

        private void AddIfNotEmpty(HashSet<string> lines, string value)
        {
            if (!string.IsNullOrWhiteSpace(value))
            {
                lines.Add(value);
            }
        }

        public string ValidateAccountStatement(AccountStatement accountStatement)
        {
            if (accountStatement.StartBalance.Currency != accountStatement.EndBalance.Currency)
            {
                return $"Startbalance currency ({accountStatement.StartBalance.Currency}) does not match endbalance currency ({accountStatement.EndBalance.Currency})";
            }

            if (accountStatement.CreditTransactionSummary != null && accountStatement.DebitTransactionSummary != null)
            {
                var transactionSum = Math.Round(accountStatement.Transactions.Sum(t => (decimal)t.Value), 2);
                var totalNumber = accountStatement.Transactions.Count;

                var transactionSumValidation = accountStatement.CreditTransactionSummary.Sum - accountStatement.DebitTransactionSummary.Sum;
                var totalNumberValidation = accountStatement.CreditTransactionSummary.NumberOfTransaction + accountStatement.DebitTransactionSummary.NumberOfTransaction;

                if (transactionSum != transactionSumValidation)
                {
                    return $"Transaction sum ({transactionSum}) does not match validation sum ({transactionSumValidation})";
                }

                if (totalNumber != totalNumberValidation)
                {
                    return $"Transaction count ({totalNumber}) does not match validation count ({totalNumberValidation})";
                }
            }
            else if (accountStatement.StartBalance != null && accountStatement.EndBalance != null)
            {
                var transactionSum = Math.Round(accountStatement.Transactions.Sum(t => t.Value), 2);
                var end = accountStatement.StartBalance.Value + transactionSum;
                if (end != accountStatement.EndBalance.Value)
                {
                    return $"Enbalance ({accountStatement.EndBalance.Value}) does not match startbalance ({accountStatement.StartBalance.Value}) + transactions ({transactionSum})";
                }
            }

            return string.Empty;
        }
    }
}