145 lines
5.5 KiB
Clojure
145 lines
5.5 KiB
Clojure
(ns auto-ap.datomic.accounts
|
|
(:require
|
|
[auto-ap.datomic
|
|
:refer [add-sorter-fields apply-pagination apply-sort-3 conn merge-query uri]]
|
|
[clojure.string :as str]
|
|
[datomic.api :as d]
|
|
[clojure.tools.logging :as log]))
|
|
|
|
(defn <-datomic [a]
|
|
(-> a
|
|
(update :account/applicability :db/ident)
|
|
(update :account/invoice-allowance :db/ident)
|
|
(update :account/vendor-allowance :db/ident)))
|
|
|
|
(def default-read ['* {:account/type [:db/ident :db/id]
|
|
:account/applicability [:db/ident :db/id]
|
|
:account/invoice-allowance [:db/ident :db/id]
|
|
:account/vendor-allowance [:db/ident :db/id]
|
|
:account/client-overrides [:db/id
|
|
:account-client-override/name
|
|
{:account-client-override/client [:db/id :client/name]}]}])
|
|
|
|
(defn clientize [a client]
|
|
(if-let [override-name (->> a
|
|
:account/client-overrides
|
|
(filter #(= client
|
|
(:db/id (:account-client-override/client %))))
|
|
first
|
|
:account-client-override/name)]
|
|
(assoc a :account/name override-name)
|
|
a))
|
|
|
|
(defn get-accounts
|
|
([]
|
|
(get-accounts {}))
|
|
([args]
|
|
(let [query (cond-> {:query {:find [(list 'pull '?e default-read)]
|
|
:in ['$]
|
|
:where [['?e :account/name]]}
|
|
:args [(d/db (d/connect uri))]}
|
|
(:account-set args) (merge-query {:query {:in ['?account-set]
|
|
:where [['?e :account/account-set '?account-set]]}
|
|
:args [(:account-set args)]}))]
|
|
(->>
|
|
(d/query query)
|
|
(map first)
|
|
(map <-datomic)))))
|
|
|
|
(defn get-by-id [id]
|
|
(let [query {:query {:find [(list 'pull '?e default-read)]
|
|
:in ['$ '?e]}
|
|
:args [(d/db (d/connect uri) ) id]}]
|
|
(->>
|
|
(d/query query)
|
|
(map first)
|
|
(map <-datomic)
|
|
first)))
|
|
|
|
(defn get-for-vendor [vendor-id client-id]
|
|
(if client-id
|
|
(->>
|
|
(d/q [:find (list 'pull '?e default-read)
|
|
:in '$ '?v '?c
|
|
:where '(or-join [?v ?c ?e]
|
|
(and [?v :vendor/account-overrides ?ao]
|
|
[?ao :vendor-account-override/client ?c]
|
|
[?ao :vendor-account-override/account ?e])
|
|
(and [?v :vendor/account-overrides ?ao]
|
|
(not [?ao vendor-account-override/client ?c])
|
|
[?v :vendor/default-account ?e])
|
|
(and (not [?v :vendor/account-overrides])
|
|
[?v :vendor/default-account ?e]))]
|
|
|
|
(d/db conn )
|
|
vendor-id
|
|
client-id)
|
|
(map first)
|
|
(map <-datomic)
|
|
first)
|
|
(d/q [:find (list 'pull '?e default-read)
|
|
:in '$ '?v
|
|
:where '[?v :vendor/default-account ?e]]
|
|
|
|
(d/db conn )
|
|
vendor-id)))
|
|
|
|
(defn get-account-by-numeric-code-and-sets [numeric-code _]
|
|
(let [query (cond-> {:query {:find ['(pull ?e [* {:account/type [:db/ident :db/id]}])]
|
|
:in ['$ '?numeric-code]
|
|
:where ['[?e :account/numeric-code ?numeric-code]]}
|
|
:args [(d/db (d/connect uri)) numeric-code]})]
|
|
(->>
|
|
(d/query query)
|
|
(map first)
|
|
(map <-datomic)
|
|
(first))))
|
|
|
|
(defn raw-graphql-ids [db args]
|
|
(println args)
|
|
(let [query (cond-> {:query {:find []
|
|
:in ['$]
|
|
:where []}
|
|
:args [db]}
|
|
(:sort args) (add-sorter-fields {"name" ['[?e :account/name ?sort-name]]}
|
|
args)
|
|
|
|
(:numeric-code args)
|
|
(merge-query {:query {:in ['?numeric-code]
|
|
:where ['[?e :account/numeric-code ?numeric-code]]}
|
|
:args [(:numeric-code args)]})
|
|
|
|
(not (str/blank? (:name-like args)))
|
|
(merge-query {:query {:in ['?name-like]
|
|
:where ['[?e :account/name ?n]
|
|
'[(re-find ?name-like ?n)]]}
|
|
:args [(re-pattern (str "(?i)" (:name-like args)))]})
|
|
|
|
true
|
|
(merge-query {:query {:find ['?sort-default '?e ]
|
|
:where ['[?e :account/name]
|
|
'[?e :account/numeric-code ?sort-default]]}}))]
|
|
|
|
|
|
(cond->> query
|
|
true (d/query)
|
|
true (apply-sort-3 args)
|
|
true (apply-pagination args))))
|
|
|
|
|
|
(defn graphql-results [ids db _]
|
|
(let [results (->> (d/pull-many db default-read ids)
|
|
(group-by :db/id))
|
|
accounts (->> ids
|
|
(map results)
|
|
(map first)
|
|
(map <-datomic))]
|
|
accounts))
|
|
|
|
(defn get-graphql [args]
|
|
(log/info "ARGS" args)
|
|
(let [db (d/db conn)
|
|
{ids-to-retrieve :ids matching-count :count} (raw-graphql-ids db args)]
|
|
[(->> (graphql-results ids-to-retrieve db args))
|
|
matching-count]))
|