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

working on support gl.

Browse Source
This commit is contained in:
Bryce Covert
2019-12-31 18:00:58 -08:00
parent 4b2821e6fb
commit 475985c137
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -6,11 +6,11 @@
[auto-ap.ledger :as ledger])) [auto-ap.ledger :as ledger]))
(defn test-run [txs-set] (defn test-run [txs-set]
(println "processing " (count txs-set)) #_(println "processing " (count txs-set))
(doseq [[i tx] (map vector (range) txs-set)] (doseq [[i tx] (map vector (range) txs-set)]
@(d/transact (d/connect auto-ap.datomic/uri) @(d/transact (d/connect auto-ap.datomic/uri)
tx) tx)
(when (= 0 (mod i 1000)) (when (= 0 (mod i 100))
(println "processed " i)))) (println "processed " i))))
@@ -218,7 +218,6 @@
:in '[$] :in '[$]
:where ['[?e :transaction/id]]} :where ['[?e :transaction/id]]}
:args [(d/db conn)]})) :args [(d/db conn)]}))
_ (println (count transaction-ids))
z (->> transaction-ids z (->> transaction-ids
(map #(ledger/entity-change->ledger (d/db conn) [:transaction %])) (map #(ledger/entity-change->ledger (d/db conn) [:transaction %]))
(filter identity) (filter identity)
@@ -438,7 +437,7 @@
:in '[$] :in '[$]
:where ['[?e :journal-entry/original-entity ]]} :where ['[?e :journal-entry/original-entity ]]}
:args [(d/db conn)]}) :args [(d/db conn)]})
(mapv (fn [[id]] (map (fn [[id]]
[:db/retractEntity id])) [:db/retractEntity id]))
(partition-all 100))] (partition-all 100))]
results)) results))

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

@@ -141,8 +141,11 @@
#_(println "updating general-ledger " d-tx) #_(println "updating general-ledger " d-tx)
@(d/transact (d/connect uri) [d-tx])))) @(d/transact (d/connect uri) [d-tx]))))
(def break (atom false))
(defn process-all [] (defn process-all []
(while (not (Thread/interrupted)) (while (and (not @break)
(not (Thread/interrupted)))
(process-one (d/tx-report-queue (d/connect uri) )))) (process-one (d/tx-report-queue (d/connect uri) ))))