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

fixes more background jobs.

Browse Source
This commit is contained in:
Bryce
2023-05-23 21:10:52 -07:00
parent 9366347245
commit 8eb7d207e0
2 changed files with 24 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/clj/auto_ap/import/plaid.clj
View File

@@ -1,6 +1,6 @@
(ns auto-ap.import.plaid (ns auto-ap.import.plaid
(:require (:require
[auto-ap.datomic :refer [conn]] [auto-ap.datomic :refer [conn random-tempid]]
[auto-ap.import.common :refer [wrap-integration]] [auto-ap.import.common :refer [wrap-integration]]
[auto-ap.import.transactions :as t] [auto-ap.import.transactions :as t]
[auto-ap.plaid.core :as p] [auto-ap.plaid.core :as p]
@@ -27,6 +27,7 @@
(defn plaid->transaction [t] (defn plaid->transaction [t]
#:transaction {:description-original (:name t) #:transaction {:description-original (:name t)
:raw-id (:transaction_id t) :raw-id (:transaction_id t)
:db/id (random-tempid)
:id #_{:clj-kondo/ignore [:unresolved-var]} :id #_{:clj-kondo/ignore [:unresolved-var]}
(di/sha-256 (:transaction_id t)) (di/sha-256 (:transaction_id t))
:amount (if (= "credit" (:type (:account t))) :amount (if (= "credit" (:type (:account t)))

42
src/clj/auto_ap/jobs/vendor_usages.clj
View File

@@ -6,26 +6,28 @@
[datomic.api :as dc])) [datomic.api :as dc]))
(defn refresh-vendor-usages [] (defn refresh-vendor-usages []
@(dc/transact conn (->> (dc/q '[:find ?v ?c (count ?e) @(dc/transact-async
:in $ conn
:where (->> (dc/q '[:find ?v ?c (count ?e)
[?v :vendor/name] :in $
(or-join [?v ?c ?e] :where
(and [?v :vendor/name]
[?e :invoice/vendor ?v] (or-join [?v ?c ?e]
[?e :invoice/client ?c]) (and
(and [?e :invoice/vendor ?v]
[?e :transaction/vendor ?v] [?e :invoice/client ?c])
[?e :transaction/client ?c]) (and
(and [?e :transaction/vendor ?v]
[?e :journal-entry/vendor ?v] [?e :transaction/client ?c])
[?e :journal-entry/client ?c]))] (and
(dc/db conn)) [?e :journal-entry/vendor ?v]
(map (fn [[v c cnt]] [?e :journal-entry/client ?c]))]
#:vendor-usage {:vendor v (dc/db conn))
:client c (map (fn [[v c cnt]]
:key (str v "-" c) #:vendor-usage {:vendor v
:count cnt}))))) :client c
:key (str v "-" c)
:count cnt})))))
(defn -main [& _] (defn -main [& _]
(execute "vendor-usages" refresh-vendor-usages)) (execute "vendor-usages" refresh-vendor-usages))