1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package tech.libeufin.sandbox
import org.jetbrains.exposed.sql.or
import org.jetbrains.exposed.sql.select
import org.jetbrains.exposed.sql.transactions.transaction
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import tech.libeufin.util.RawPayment
import tech.libeufin.util.importDateFromMillis
import tech.libeufin.util.toDashedDate
private val logger: Logger = LoggerFactory.getLogger("tech.libeufin.sandbox")
fun historyForAccount(iban: String): List<RawPayment> {
val history = mutableListOf<RawPayment>()
transaction {
logger.debug("Querying transactions involving: ${iban}")
BankAccountTransactionsTable.select {
BankAccountTransactionsTable.creditorIban eq iban or
(BankAccountTransactionsTable.debtorIban eq iban)
/**
FIXME: add the following condition too:
and (BankAccountTransactionsTable.date.between(start.millis, end.millis))
*/
/**
FIXME: add the following condition too:
and (BankAccountTransactionsTable.date.between(start.millis, end.millis))
*/
}.forEach {
history.add(
RawPayment(
subject = it[BankAccountTransactionsTable.subject],
creditorIban = it[BankAccountTransactionsTable.creditorIban],
creditorBic = it[BankAccountTransactionsTable.creditorBic],
creditorName = it[BankAccountTransactionsTable.creditorName],
debitorIban = it[BankAccountTransactionsTable.debtorIban],
debitorBic = it[BankAccountTransactionsTable.debtorBic],
debitorName = it[BankAccountTransactionsTable.debtorName],
date = importDateFromMillis(it[BankAccountTransactionsTable.date]).toDashedDate(),
amount = it[BankAccountTransactionsTable.amount],
currency = it[BankAccountTransactionsTable.currency],
// The line below produces a value too long (>35 chars),
// and it makes the document invalid!
// uid = "${it[pmtInfId]}-${it[msgId]}"
uid = it[BankAccountTransactionsTable.accountServicerReference],
direction = it[BankAccountTransactionsTable.direction],
pmtInfId = it[BankAccountTransactionsTable.pmtInfId]
)
)
}
}
return history
}
|
