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

minor tweaks.

Browse Source
This commit is contained in:
Bryce Covert
2019-03-14 23:58:56 -07:00
parent e35bc97a7d
commit 55fb386376
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
View File

@@ -70,7 +70,7 @@
#_(bulk-load-invoice-ledger (d/connect auto-ap.datomic/uri)) #_(bulk-load-invoice-ledger (d/connect auto-ap.datomic/uri))
(def make-entity-not-unique (def make-entity-not-unique
[[[:db/retract :general-ledger/original-entity :db/unique]]]) [[[:db/retract :general-ledger/original-entity :db/unique :db.unique/identity]]])

5
src/clj/auto_ap/ledger.clj
View File

@@ -2,7 +2,6 @@
(:require [datomic.api :as d] (:require [datomic.api :as d]
[auto-ap.datomic :refer [uri remove-nils]])) [auto-ap.datomic :refer [uri remove-nils]]))
(defonce report-queue (d/tx-report-queue (d/connect uri) ) )
(defn datums->impacted-entity [db [e changes]] (defn datums->impacted-entity [db [e changes]]
(let [entity (d/pull db '[* {:invoice/_expense-accounts [*]}] e) (let [entity (d/pull db '[* {:invoice/_expense-accounts [*]}] e)
@@ -65,7 +64,7 @@
(into [[:replace-general-ledger (:general-ledger/original-entity (first entries))]] (into [[:replace-general-ledger (:general-ledger/original-entity (first entries))]]
entries)) entries))
(defn process-one [] (defn process-one [report-queue]
(let [transaction (.take report-queue) (let [transaction (.take report-queue)
db (:db-after transaction) db (:db-after transaction)
affected-entities (->> (:tx-data transaction) affected-entities (->> (:tx-data transaction)
@@ -90,7 +89,7 @@
(defn process-all [] (defn process-all []
(while (not (Thread/interrupted)) (while (not (Thread/interrupted))
(process-one))) (process-one (d/tx-report-queue (d/connect uri) ))))