mirror of
https://github.com/maybe-finance/maybe.git
synced 2025-08-02 20:15:22 +02:00
perf(imports): Bulk import CSV trades (#2040)
This commit is contained in:
parent
5cf758bd03
commit
0a17b84566
1 changed files with 13 additions and 12 deletions
|
@ -3,7 +3,7 @@ class TradeImport < Import
|
|||
transaction do
|
||||
mappings.each(&:create_mappable!)
|
||||
|
||||
rows.each do |row|
|
||||
trades = rows.map do |row|
|
||||
mapped_account = if account
|
||||
account
|
||||
else
|
||||
|
@ -16,21 +16,22 @@ class TradeImport < Import
|
|||
exchange_operating_mic: row.exchange_operating_mic
|
||||
)
|
||||
|
||||
entry = mapped_account.entries.build \
|
||||
date: row.date_iso,
|
||||
amount: row.signed_amount,
|
||||
name: row.name,
|
||||
Account::Trade.new(
|
||||
security: security,
|
||||
qty: row.qty,
|
||||
currency: row.currency.presence || mapped_account.currency,
|
||||
entryable: Account::Trade.new(
|
||||
security: security,
|
||||
qty: row.qty,
|
||||
price: row.price,
|
||||
entry: Account::Entry.new(
|
||||
account: mapped_account,
|
||||
date: row.date_iso,
|
||||
amount: row.signed_amount,
|
||||
name: row.name,
|
||||
currency: row.currency.presence || mapped_account.currency,
|
||||
price: row.price
|
||||
import: self
|
||||
),
|
||||
import: self
|
||||
|
||||
entry.save!
|
||||
)
|
||||
end
|
||||
Account::Trade.import!(trades, recursive: true)
|
||||
end
|
||||
end
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue