notid/integreat
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

it's okay to upsert without checking existing.

Browse Source
This commit is contained in:
Bryce Covert
2022-06-25 08:14:19 -07:00
parent a26469ce2b
commit f710f97a8c
1 changed files with 6 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/clj/auto_ap/square/core.clj
View File

@@ -408,19 +408,9 @@
([client location] ([client location]
(lc/with-context {:source "Square settlements loading"} (lc/with-context {:source "Square settlements loading"}
(try (try
(let [existing (->> (d/query {:query {:find ['?external-id] (doseq [x (partition-all 20 (daily-settlements client location))]
:in ['$ '?client] (log/info "Loading expected deposit" (count x))
:where ['[?d :expected-deposit/client ?client] @(d/transact conn x))
'[?d :expected-deposit/external-id ?external-id]]}
:args [(d/db conn) (:db/id client)]})
(map first)
set)
_ (log/info (count existing) "settlements already exist")
to-create (filter #(not (existing (:expected-deposit/external-id %)))
(daily-settlements client location))]
(doseq [x (partition-all 20 to-create)]
(log/info "Loading expected deposit" (count x))
@(d/transact conn x)))
(catch Exception e (catch Exception e
(log/error e))) (log/error e)))
(log/info "Done loading settlements")))) (log/info "Done loading settlements"))))
@@ -435,19 +425,9 @@
:client (:client/code client) :client (:client/code client)
:location (:square-location/client-location client)} :location (:square-location/client-location client)}
(try (try
(let [existing (->> (d/query {:query {:find ['?external-id] (doseq [x (partition-all 20 (refunds client location))]
:in ['$ '?client] (log/info "Loading refund" (count x))
:where ['[?r :sales-refund/client ?client] @(d/transact conn x))
'[?r :sales-refund/external-id ?external-id]]}
:args [(d/db conn) (:db/id client)]})
(map first)
set)
_ (log/info (count existing) "refunds already exist")
to-create (filter #(not (existing (:sales-refund/external-id %)))
(refunds client location))]
(doseq [x (partition-all 20 to-create)]
(log/info "Loading refund" (count x))
@(d/transact conn x)))
(catch Exception e (catch Exception e
(log/error e))) (log/error e)))
(log/info "Done loading refunds")))) (log/info "Done loading refunds"))))