-
Notifications
You must be signed in to change notification settings - Fork 2
/
core.clj
168 lines (146 loc) · 5.81 KB
/
core.clj
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
(ns cnab-parser.core
(:require [clojure.java.io :as io]
[clojure.string :as s]
[clojure.edn :as edn]
[clojure.tools.logging :as log]
[clojure.test :refer [is]]
))
(defn make-cnab-parser
"Cria um parser de cnab a partirda sua espeficicação em edn
Precisa seguir o formato estabelecido em https://github.com/lsevero/cnab-layouts
path: caminho para o edn de especificação do cnab
retorno: um mapa contendo a espeficicação do contendo tanto o retorno e a remessa
"
[content]
(edn/read-string content))
(defn split-cnab
"Divide o cnab em lote de n bytes"
[^String cnab ^long n]
(map (partial apply str) (partition n (s/replace cnab #"\r|\n" ""))))
(defn parse-cnab-field
"Parseia um campo do cnab.
Levanta uma exceção caso o intervalo definido em :pos não tenha o mesmo tamanho que o definido em picture.
"
[^String cnab-part {picture :picture [begin end :as pos] :pos :as spec}]
{:pre [(is (and (contains? spec :picture)
(contains? spec :pos)))
(is (= (- end (dec begin))
(apply + (map #(Long/parseLong (% 1)) (re-seq #"\((\d+)\)" picture)))))]}
(try
(let [field (subs cnab-part (dec begin) end)]
(cond
(s/starts-with? picture "9")
(if (s/includes? picture "V")
(let [[[_ size1] [_ _]] (re-seq #"\((\d+)\)" picture)]
(Double/parseDouble (str (subs field 0 (Long/parseLong size1))
"."
(subs field (Long/parseLong size1)))))
(Long/parseLong field))
(s/starts-with? picture "X") field
:else (throw (ex-info "Picture não está definido nem como número (9) nem como string (X)"
{:msg "Erro em picture"
:pos pos
:picture picture}))))
(catch Exception e (do
(log/debug "parse-cnab-field fail! cnab-part: " cnab-part " spec: " spec " exception: " e)
(throw e)))))
(defn- dispatch
[cnab padrao cnab-type]
[padrao cnab-type])
(defmulti parse-cnab dispatch)
(defmulti parse-cnab-header-arquivo dispatch)
(defmulti parse-cnab-header-lote dispatch)
(defmulti parse-cnab-detalhes dispatch)
(defmulti parse-cnab-trailer-lote dispatch)
(defmulti parse-cnab-trailer-arquivo dispatch)
(defmethod parse-cnab :default
[cnab padrao cnab-type]
(let [error-msg
(str "Não existe implementações de parse-cnab para o padrão "
padrao " tipo " cnab-type)]
(throw (ex-info error-msg
{:cnab cnab
:padrao padrao
:cnab-type cnab-type}))))
(defmethod parse-cnab-header-arquivo :default
[cnab padrao cnab-type]
(let [error-msg
(str "Não existe implementações de parse-cnab-header-arquivo para o padrão "
padrao " tipo " cnab-type)]
(throw (ex-info error-msg
{:cnab cnab
:padrao padrao
:cnab-type cnab-type}))))
(defmethod parse-cnab-header-lote :default
[cnab padrao cnab-type]
nil)
(defmethod parse-cnab-detalhes :default
[cnab padrao cnab-type]
(let [error-msg (str "Não existe implementações de parse-cnab-detalhes para o padrão "
padrao " tipo " cnab-type)]
(throw (ex-info error-msg
{:cnab cnab
:padrao padrao
:cnab-type cnab-type}))))
(defmethod parse-cnab-trailer-lote :default
[cnab padrao cnab-type]
nil)
(defmethod parse-cnab-trailer-arquivo :default
[cnab padrao cnab-type]
(let [error-msg
(str "Não existe implementações de parse-cnab-trailer-arquivo para o padrão "
padrao " tipo " cnab-type)]
(throw (ex-info error-msg
{:cnab cnab
:padrao padrao
:cnab-type cnab-type}))))
(defn try-fns
"Receives a list of functions and a list of args and iterate applying each functions to args,
if the function throws an Exception, try the next one. Returns nil if all functions raises a exception."
([fns args ^long n]
(let [[head & tail] fns
random-sym (gensym)
ans (try (apply head args)
(catch Exception e random-sym))]
(if (= ans random-sym)
(when-not (empty? tail)
(recur tail args (inc n)))
{:res ans
:fn head
:fn-pos n
:args args})))
([fns args]
(try-fns fns args 0)))
(defn try-args
"Receives a function and a list of list of args and iterate applying the function to each args,
if the function throws an Exception, try the next one. Returns nil if all functions raises a exception."
([f args ^long n]
(let [[head & tail] args
random-sym (gensym)
ans (try (apply f head)
(catch Exception e random-sym))]
(if (= ans random-sym)
(when-not (empty? tail)
(recur f tail (inc n)))
{:res ans
:fn f
:args-pos n
:args head})))
([f args]
(try-args f args 0)))
(comment
(type (gensym))
(do
(def itau (spit (io/file "/tmp/itau400.edn") (yaml/from-file "/home/severo/Documentos/cnab-layouts/config/itau/cnab400/cobranca.yml") ))
(apply merge (:remessa itau)))
(def detalhes (get-in itau [:remessa :detalhes]))
(def header (get-in itau [:remessa :header_arquivo]))
(def spec {:header header
:detalhes (apply merge (map (fn [[ k v]] v) detalhes))})
(make-cnab-parser "/home/severo/Documentos/cnab-layouts/c")
(type (make-cnab-parser (-> "itau400.edn" io/resource io/file)))
(->> (partition 400 (s/replace (slurp "/home/severo/Documentos/cnab-exemplo/CN14020A.RET") #"\r|\n" ""))
(map (partial apply str))
)
(parse-cnab-field "00012345" {:pos [1 8] :picture "9(6)V9(2)"})
)