monobank-firefly3-bot/app/import_transaction.go

179 lines
6.3 KiB
Go
Raw Normal View History

2024-04-12 13:00:28 +03:00
package app
import (
"bytes"
"context"
"encoding/json"
"errors"
"gitea.stuzer.link/stuzer05/go-firefly3/v2"
"gitea.stuzer.link/stuzer05/go-monobank"
"github.com/antihax/optional"
"math"
2024-04-29 12:34:20 +03:00
"os"
2024-04-12 13:00:28 +03:00
"slices"
"strconv"
"time"
)
func ImportTransaction(monobankTransaction monobank.WebHookResponse) error {
firefly3TransactionTypeWithdrawal := firefly3.WITHDRAWAL_TransactionTypeProperty
firefly3TransactionTypeDeposit := firefly3.DEPOSIT_TransactionTypeProperty
firefly3TransactionTypeTransfer := firefly3.TRANSFER_TransactionTypeProperty
2024-04-29 12:34:20 +03:00
timezoneHoursDiff, _ := strconv.Atoi(os.Getenv("TIMEZONE_HOURS_DIFF"))
2024-04-12 13:00:28 +03:00
// get body json string (for logging)
monobankTransactionJson, err := json.Marshal(monobankTransaction)
if err != nil {
return err
}
// find accounts
destAccount := App().Config.GetAccountByMonobankId(monobankTransaction.Data.Account)
2024-04-12 13:00:28 +03:00
// cancel if one of destAccount ids is empty
if len(destAccount.Firefly3Name) == 0 || len(destAccount.MonobankId) == 0 {
2024-04-12 13:00:28 +03:00
return errors.New("cannot find firefly3 or monobank ids (" + monobankTransaction.Data.Account + ")")
}
// create firefly3 transactions list
var firefly3Transactions []firefly3.TransactionSplitStore
// match transaction with config
for _, row := range App().Config.TransactionTypes {
// is refund
2024-05-12 12:35:18 +03:00
if slices.Contains(row.NamesRefund, monobankTransaction.Data.StatementItem.Description) {
2024-04-12 13:00:28 +03:00
opts := firefly3.TransactionsApiListTransactionOpts{
Limit: optional.NewInt32(999),
Type_: optional.NewInterface("withdrawal"),
Start: optional.NewString(time.Now().AddDate(0, 0, -7).Format("2006-01-02")), // one week before
}
oldTransactions, _, err := App().Firefly3Client.TransactionsApi.ListTransaction(context.Background(), &opts)
if err != nil {
return err
}
// find matching transaction to delete
isDeleted := false
for _, tRows := range oldTransactions.Data {
if isDeleted {
break
}
for _, tRow := range tRows.Attributes.Transactions {
// validate notes is json
notesBytes := bytes.NewBufferString(tRow.Notes).Bytes()
if !json.Valid(notesBytes) {
continue
}
// read monobank transaction
2024-06-30 14:31:43 +03:00
var monobankTransaction monobank.WebHookResponse
2024-04-12 13:00:28 +03:00
err = json.Unmarshal(notesBytes, &monobankTransaction)
if err != nil {
continue
}
// find transaction
2024-06-30 14:31:43 +03:00
sum := int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.Amount/100))) - int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.CommissionRate/100)))
2024-04-12 13:00:28 +03:00
sum2, _ := strconv.ParseFloat(tRow.Amount, 64)
2024-06-30 14:31:43 +03:00
if slices.Contains(row.Names, monobankTransaction.Data.StatementItem.Description) && sum == int(sum2) {
2024-04-12 13:00:28 +03:00
// delete transaction
opts := firefly3.TransactionsApiDeleteTransactionOpts{}
2024-06-30 14:31:43 +03:00
_, err := App().Firefly3Client.TransactionsApi.DeleteTransaction(context.Background(), tRows.Id, &opts)
if err != nil {
return err
}
2024-04-12 13:00:28 +03:00
isDeleted = true
}
}
}
break
} else {
// check name & mcc
2024-05-12 12:35:18 +03:00
if !(slices.Contains(row.Names, monobankTransaction.Data.StatementItem.Description) || slices.Contains(row.MccCodes, int(monobankTransaction.Data.StatementItem.Mcc))) {
2024-04-12 13:00:28 +03:00
continue
}
// create firefly3 transaction
firefly3Transaction := firefly3.TransactionSplitStore{
2024-05-12 12:35:18 +03:00
Date: time.Unix(int64(monobankTransaction.Data.StatementItem.Time), 0).Add(time.Hour * time.Duration(timezoneHoursDiff)),
2024-04-12 13:00:28 +03:00
Notes: string(monobankTransactionJson),
2024-05-12 12:35:18 +03:00
Amount: strconv.Itoa(int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.Amount/100))) - int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.CommissionRate/100)))),
SourceName: destAccount.Firefly3Name,
2024-04-12 13:00:28 +03:00
}
// check max sum
sum, _ := strconv.Atoi(firefly3Transaction.Amount)
if row.SumMax > 0 && sum > row.SumMax {
continue
}
// make transaction
switch row.Firefly3.Type {
case "withdrawal":
firefly3Transaction.Type_ = &firefly3TransactionTypeWithdrawal
break
case "deposit":
firefly3Transaction.Type_ = &firefly3TransactionTypeDeposit
break
case "transfer":
firefly3Transaction.Type_ = &firefly3TransactionTypeTransfer
break
default:
firefly3Transaction.Type_ = &firefly3TransactionTypeWithdrawal
}
firefly3Transaction.Description = row.Firefly3.Description
firefly3Transaction.DestinationName = row.Firefly3.Destination
firefly3Transaction.CategoryName = row.Firefly3.Category
// swap source and destination
if row.Firefly3.IsUseDestinationAsSource {
firefly3Transaction.SourceName, firefly3Transaction.DestinationName = firefly3Transaction.DestinationName, firefly3Transaction.SourceName
// when transfer between different currencies, convert
sourceAccount := App().Config.GetAccountByFirefly3Name(firefly3Transaction.SourceName)
if len(sourceAccount.Currency) > 0 && sourceAccount.Currency != destAccount.Currency {
// swap amounts
firefly3Transaction.ForeignAmount = firefly3Transaction.Amount
firefly3Transaction.Amount = strconv.Itoa(int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.OperationAmount / 100))))
firefly3Transaction.ForeignCurrencyCode = destAccount.Currency
}
2024-04-12 13:00:28 +03:00
}
firefly3Transactions = append(firefly3Transactions, firefly3Transaction)
break
}
}
2024-05-12 12:35:18 +03:00
if monobankTransaction.Data.StatementItem.CommissionRate > 0 {
2024-04-12 13:00:28 +03:00
firefly3Transactions = append(firefly3Transactions, firefly3.TransactionSplitStore{
Type_: &firefly3TransactionTypeWithdrawal,
2024-05-12 12:35:18 +03:00
Date: time.Unix(int64(monobankTransaction.Data.StatementItem.Time), 0).Add(time.Hour * time.Duration(timezoneHoursDiff)),
2024-04-12 13:00:28 +03:00
Notes: string(monobankTransactionJson),
Description: "Transfer fee",
2024-05-12 12:35:18 +03:00
Amount: strconv.Itoa(int(math.Abs(math.Round(monobankTransaction.Data.StatementItem.CommissionRate / 100)))),
SourceName: destAccount.Firefly3Name,
2024-04-12 13:00:28 +03:00
})
}
// log firefly3 transactions
if len(firefly3Transactions) > 0 {
transactionOpts := firefly3.TransactionsApiStoreTransactionOpts{}
for _, transaction := range firefly3Transactions {
_, _, err = App().Firefly3Client.TransactionsApi.StoreTransaction(context.Background(), firefly3.TransactionStore{
ApplyRules: true,
Transactions: []firefly3.TransactionSplitStore{transaction},
}, &transactionOpts)
if err != nil {
return err
}
}
}
return nil
}