stuzer05/monobank-firefly3-bot
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Activity

Add transaction adjustment on cancellation (when amount differs)
Some checks failed
build docker image / docker-build (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Illya Marchenko
2025-06-06 16:54:13 +03:00
parent f947606131
commit ebb213a3cc
1 changed files with 44 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
app/import_transaction.go
View File

@ -8,6 +8,7 @@ import (
"gitea.stuzer.link/stuzer05/go-firefly3/v2" "gitea.stuzer.link/stuzer05/go-firefly3/v2"
"gitea.stuzer.link/stuzer05/go-monobank" "gitea.stuzer.link/stuzer05/go-monobank"
"github.com/antihax/optional" "github.com/antihax/optional"
"log"
"math" "math"
"os" "os"
"slices" "slices"
@ -55,7 +56,7 @@ func ImportTransaction(monobankTransaction monobank.WebHookResponse) error {
return err return err
} }
// find matching transaction to delete // find matching transaction to adjust/delete
isDeleted := false isDeleted := false
for _, tRows := range oldTransactions.Data { for _, tRows := range oldTransactions.Data {
if isDeleted { if isDeleted {
@ -70,24 +71,55 @@ func ImportTransaction(monobankTransaction monobank.WebHookResponse) error {
} }
// read monobank transaction // read monobank transaction
var monobankTransaction monobank.WebHookResponse var monobankTransactionOld monobank.WebHookResponse
err = json.Unmarshal(notesBytes, &monobankTransaction) err = json.Unmarshal(notesBytes, &monobankTransactionOld)
if err != nil { if err != nil {
continue continue
} }
// Parse amounts
sumNew := int64(math.Abs(math.Round(monobankTransaction.Data.StatementItem.Amount/100))) - int64(math.Abs(math.Round(monobankTransaction.Data.StatementItem.CommissionRate/100)))
sumOldFloat, _ := strconv.ParseFloat(tRow.Amount, 64)
sumOld := int64(sumOldFloat)
// find transaction // find transaction
sum := int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.Amount/100))) - int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.CommissionRate/100))) if slices.Contains(row.Names, monobankTransactionOld.Data.StatementItem.Description) {
sum2, _ := strconv.ParseFloat(tRow.Amount, 64) if sumNew == sumOld {
if slices.Contains(row.Names, monobankTransaction.Data.StatementItem.Description) && sum == int(sum2) {
// delete transaction // delete transaction
opts := firefly3.TransactionsApiDeleteTransactionOpts{} opts := firefly3.TransactionsApiDeleteTransactionOpts{}
_, err := App().Firefly3Client.TransactionsApi.DeleteTransaction(context.Background(), tRows.Id, &opts) _, err := App().Firefly3Client.TransactionsApi.DeleteTransaction(context.Background(), tRows.Id, &opts)
if err != nil { if err != nil {
return err return err
} }
} else {
// adjust transaction
opts := firefly3.TransactionsApiUpdateTransactionOpts{}
body := firefly3.TransactionUpdate{
Transactions: []firefly3.TransactionSplitUpdate{
{
Description: tRow.Description,
CategoryId: tRow.CategoryId,
DestinationId: tRow.DestinationId,
SourceId: tRow.SourceId,
CurrencyId: tRow.CurrencyId,
ExternalUrl: tRow.ExternalUrl,
Date: tRow.Date,
DueDate: tRow.DueDate,
Tags: tRow.Tags,
Notes: tRow.Notes,
// Notes: string(monobankTransactionJson),
Amount: strconv.FormatInt(sumOld-sumNew, 10),
},
},
}
_, _, err := App().Firefly3Client.TransactionsApi.UpdateTransaction(context.Background(), body, tRows.Id, &opts)
if err != nil {
log.Println(err)
return err
}
}
isDeleted = true isDeleted = true // break 2
} }
} }
} }