101 lines
4.2 KiB
Clojure
101 lines
4.2 KiB
Clojure
(ns auto-ap.datomic.vendors
|
|
(:require [datomic.api :as d]
|
|
[auto-ap.graphql.utils :refer [limited-clients ]]
|
|
|
|
[auto-ap.datomic :refer [uri conn merge-query]]))
|
|
(defn cleanse [id vendor]
|
|
(let [clients (if-let [clients (limited-clients id)]
|
|
(set (map :db/id clients))
|
|
nil)]
|
|
(if clients
|
|
(-> vendor
|
|
(update :vendor/account-overrides (fn [ao] (filter #(clients (:db/id (:vendor-account-override/client %))) ao)))
|
|
(update :vendor/terms-overrides (fn [to] (filter #(clients (:db/id (:vendor-terms-override/client %))) to)))
|
|
(update :vendor/schedule-payment-dom (fn [to] (filter #(clients (:db/id (:vendor-schedule-payment-dom/client %))) to))))
|
|
vendor)))
|
|
|
|
(def default-read
|
|
'[* {:vendor/account-overrides [* {:vendor-account-override/client [:client/name :db/id]
|
|
:vendor-account-override/account [:account/name :account/numeric-code :db/id]}]
|
|
:vendor/terms-overrides [* {:vendor-terms-override/client [:client/name :client/code :db/id]}]
|
|
:vendor/schedule-payment-dom [* {:vendor-schedule-payment-dom/client [:client/name :client/code :db/id]}]
|
|
:vendor/automatically-paid-when-due [:db/id :client/name]}])
|
|
|
|
(defn get-usages [args]
|
|
(->> (cond-> {:query {:find ['?v '?c '(count ?e)]
|
|
:in ['$]
|
|
:where ['[?v :vendor/name]
|
|
'(or-join [?v ?c ?e]
|
|
(and
|
|
[?e :invoice/vendor ?v]
|
|
[?e :invoice/client ?c])
|
|
(and
|
|
[?e :transaction/vendor ?v]
|
|
[?e :transaction/client ?c])
|
|
(and
|
|
[?e :journal-entry/vendor ?v]
|
|
[?e :journal-entry/client ?c]))]}
|
|
:args [(d/db conn)]}
|
|
|
|
(limited-clients (:id args))
|
|
(merge-query {:query {:in ['?xx]
|
|
:where [['(get ?xx ?c)]]}
|
|
:args [(set (map :db/id (limited-clients (:id args))))]}))
|
|
(d/query)
|
|
(reduce
|
|
(fn [usages [v c cnt]]
|
|
(update usages v (fnil conj []) {:client-id c :count cnt}))
|
|
{})))
|
|
|
|
(defn get-graphql [args]
|
|
(let [usages (time (get-usages args))]
|
|
(->> (cond-> {:query {:find [(list 'pull '?e default-read)]
|
|
:in ['$]
|
|
:where ['[?e :vendor/name]]}
|
|
:args [(d/db (d/connect uri))]})
|
|
(d/query)
|
|
(map first)
|
|
(map #(cleanse (:id args) %))
|
|
(map #(assoc % :usage (get usages (:db/id %)))))))
|
|
|
|
(defn get-by-id [id]
|
|
|
|
(->> (d/q '[:find (pull ?e [*
|
|
{:default-account [:account/name :db/id :account/location]
|
|
:vendor/account-overrides [* {:vendor-account-override/client [:client/name :db/id]
|
|
:vendor-account-override/account [:account/name :account/numeric-code :db/id]}]
|
|
:vendor/terms-overrides [* {:vendor-terms-override/client [:client/name :db/id]}]
|
|
:vendor/schedule-payment-dom [* {:vendor-schedule-payment-dom/client [:client/name :db/id]}]
|
|
:vendor/automatically-paid-when-due [:db/id :client/name]}])
|
|
:in $ ?e
|
|
:where [?e]]
|
|
(d/db (d/connect uri))
|
|
id)
|
|
(map first)
|
|
(first)))
|
|
|
|
|
|
(defn terms-for-client-id [vendor client-id]
|
|
(or
|
|
(->>
|
|
(filter
|
|
(fn [to]
|
|
(= (:db/id (:vendor-terms-override/client to))
|
|
client-id))
|
|
(:vendor/terms-overrides vendor))
|
|
first
|
|
:vendor-terms-override/terms)
|
|
(:vendor/terms vendor)))
|
|
|
|
(defn account-for-client-id [vendor client-id]
|
|
(or
|
|
(->>
|
|
(filter
|
|
(fn [to]
|
|
(= (:db/id (:vendor-account-override/client to))
|
|
client-id))
|
|
(:vendor/account-overrides vendor))
|
|
first
|
|
:vendor-account-override/account)
|
|
(:vendor/default-account vendor)))
|