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

works to fill gaps.

Browse Source
This commit is contained in:
Bryce Covert
2022-05-30 14:23:18 -07:00
parent d24f7a81a2
commit abd79c4b41
2 changed files with 25 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,7 +18,6 @@
(map :a)
(map namespace)
set)]
(println namespaces changes)
(cond (namespaces "invoice" ) [[:invoice e]]
(namespaces "invoice-expense-account" ) [[:invoice (:db/id (:invoice/_expense-accounts entity))]]
(namespaces "transaction-account" ) [[:transaction (:db/id (:transaction/_accounts entity))]]

49
src/clj/auto_ap/square/core.clj
View File

@@ -77,21 +77,22 @@
(log/warn "couldn't look up" i)
"Uncategorized"))))
(defn pc [d] {"query" {"filter" {"date_time_filter"
{
"created_at" {
"start_at" (f/unparse (f/formatter "YYYY-MM-dd'T'HH:mm:ssZZ") (time/to-time-zone (coerce/to-date-time d) (time/time-zone-for-id "America/Los_Angeles")))
"end_at" (f/unparse (f/formatter "YYYY-MM-dd'T'HH:mm:ssZZ") (time/to-time-zone (time/plus (coerce/to-date-time d) (time/days 1)) (time/time-zone-for-id "America/Los_Angeles")))
}
(defn pc [start end]
{"query" {"filter" {"date_time_filter"
{
"created_at" {
"start_at" (f/unparse (f/formatter "YYYY-MM-dd'T'HH:mm:ssZZ") start)
"end_at" (f/unparse (f/formatter "YYYY-MM-dd'T'HH:mm:ssZZ") end)
}
}}
}}
"sort" {
"sort_field" "CREATED_AT"
"sort_order" "DESC"
}}})
"sort" {
"sort_field" "CREATED_AT"
"sort_order" "DESC"
}}})
(defn get-order
([client location order-id]
@@ -103,33 +104,33 @@
)]
result)))
(defn continue-search [client location d cursor]
(defn continue-search [client location start end cursor]
(log/info "Continuing search for" cursor)
(let [result (->> (client/post "https://connect.squareup.com/v2/orders/search"
{:headers (client-base-headers client)
:body (json/write-str (cond-> {"location_ids" [(:square-location/square-id location)]
"limit" 10000
"cursor" cursor}
d (merge (pc d))))
start (merge (pc start end))))
:as :json})
:body)]
(log/info "found " (count (:orders result)))
(if (not-empty (:cursor result))
(concat (:orders result) (continue-search client location d (:cursor result)))
(concat (:orders result) (continue-search client location start end (:cursor result)))
(:orders result))))
(defn search
([client location d]
([client location start end]
(log/info "Searching for" (:square-location/client-location location))
(let [result (->> (client/post "https://connect.squareup.com/v2/orders/search"
{:headers (client-base-headers client)
:body (json/write-str (cond-> {"location_ids" [(:square-location/square-id location)] "limit" 10000}
d (merge (pc d))))
start (merge (pc start end))))
:as :json})
:body)]
(log/info "found " (count (:orders result)))
(if (not-empty (:cursor result))
(concat (:orders result) (continue-search client location d (:cursor result)))
(concat (:orders result) (continue-search client location start end (:cursor result)))
(:orders result)))))
@@ -205,9 +206,9 @@
(defn daily-results
([client location]
(daily-results client location nil))
([client location d]
(let [search-results (search client location d)
(daily-results client location (time/plus (time/now) (time/days -3)) (time/now)))
([client location start end]
(let [search-results (search client location start end)
koala-production-ids (->> search-results
(filter #(= "koala-production" (:name (:source %))))
(map :id)
@@ -372,8 +373,8 @@
([client ]
(doseq [square-location (:client/square-locations client)
:when (:square-location/client-location square-location)]
(upsert client square-location (atime/unparse-local (time/now) atime/iso-date))))
([client location d]
(upsert client square-location (time/plus (time/now) (time/days -3)) (time/now))))
([client location start end]
(lc/with-context {:source "Square loading"}
(try
(let [existing (->> (d/query {:query {:find ['?external-id]
@@ -385,7 +386,7 @@
set)
_ (log/info (count existing) "Sales orders already exist")
to-create (filter #(not (existing (:sales-order/external-id %)))
(daily-results client location d))]
(daily-results client location start end))]
(doseq [x (partition-all 20 to-create)]
(log/info "Loading " (count x))
@(d/transact conn x)))