87 lines
2.9 KiB
Clojure
87 lines
2.9 KiB
Clojure
(ns auto-ap.db.invoices
|
|
(:require [auto-ap.db.utils :refer [clj->db db->clj get-conn query] :as utils]
|
|
[auto-ap.parse :as parse]
|
|
[auto-ap.db.companies :as companies]
|
|
[auto-ap.db.vendors :as vendors]
|
|
[auto-ap.entities.companies :as company]
|
|
[auto-ap.entities.vendors :as vendor]
|
|
[clojure.java.jdbc :as j]
|
|
[clojure.string :as str]
|
|
[honeysql.core :as sql]
|
|
[honeysql.helpers :as helpers]))
|
|
|
|
(def all-keys #{:company-id :vendor-id :imported :potential-duplicate :total :invoice-number :date})
|
|
|
|
(defn insert-multi! [rows]
|
|
(j/insert-multi! (get-conn)
|
|
:invoices
|
|
(map clj->db rows)))
|
|
|
|
(def base-query (sql/build :select :invoices.*
|
|
:from :invoices))
|
|
|
|
|
|
(defn get-all []
|
|
(query base-query))
|
|
|
|
(defn approve []
|
|
(j/update! (get-conn) :invoices {:imported true} [] ))
|
|
|
|
(defn reject []
|
|
(j/delete! (get-conn) :invoices ["imported = false"]))
|
|
|
|
(defn get-unpaid [company]
|
|
(query
|
|
(if company
|
|
(-> base-query
|
|
(helpers/merge-where [:= :imported true])
|
|
(helpers/merge-where [:= :company-id company]))
|
|
(-> base-query
|
|
(helpers/merge-where [:= :imported true])))))
|
|
|
|
(defn get-pending [company]
|
|
(query
|
|
(if company
|
|
(-> base-query
|
|
(helpers/merge-where [:= :imported false])
|
|
(helpers/merge-where [:= :company-id company]))
|
|
(-> base-query
|
|
(helpers/merge-where [:= :imported false])))))
|
|
|
|
(defn add-sort-by [q sort-by asc]
|
|
(let [sort-by-key (keyword sort-by)]
|
|
(cond (all-keys sort-by-key)
|
|
(helpers/merge-order-by q [sort-by-key (when-not asc :desc)])
|
|
|
|
(= :vendor sort-by-key)
|
|
(-> q
|
|
(helpers/merge-left-join [:vendors :v] [:= :v.id :invoices.vendor-id] )
|
|
(helpers/merge-order-by [:v.name (when-not asc :desc)]))
|
|
|
|
(= :company sort-by-key)
|
|
(-> q
|
|
(helpers/merge-left-join [:companies :c] [:= :c.id :invoices.company-id] )
|
|
(helpers/merge-order-by [:c.name (when-not asc :desc)]))
|
|
|
|
:else
|
|
q)))
|
|
|
|
|
|
(defn get-graphql [{:keys [imported company-id sort-by asc]}]
|
|
(query
|
|
(cond-> base-query
|
|
(not (nil? imported)) (helpers/merge-where [:= :imported imported])
|
|
(not (nil? company-id)) (helpers/merge-where [:= :company-id company-id])
|
|
(not (nil? sort-by) ) (add-sort-by sort-by asc))))
|
|
|
|
(defn import [parsed-invoices companies vendors]
|
|
(insert-multi!
|
|
(for [{:keys [total date invoice-number customer-identifier vendor-code] :as row} parsed-invoices]
|
|
(do
|
|
(dissoc (assoc row
|
|
:company-id (:id (parse/best-match companies customer-identifier))
|
|
:vendor-id (:id (first (filter #(= (:code %) vendor-code) vendors)))
|
|
:imported false
|
|
:potential-duplicate false)
|
|
:vendor-code)))))
|