From 2f93f73c0e6d8695d351a523c63695e75d1842e4 Mon Sep 17 00:00:00 2001
From: Enrique Barcelli <kiko@barcelli.net>
Date: Sun, 11 Aug 2024 03:47:47 +0800
Subject: [PATCH] Add import orders

---
 .gitignore                               |   2 ++
 __init__.py                              |   0
 __pycache__/config.cpython-311.pyc       | Bin 0 -> 1078 bytes
 __pycache__/insert_order.cpython-311.pyc | Bin 0 -> 2425 bytes
 config.py                                |  20 +++++++++++++++
 connect.py                               |  17 +++++++++++++
 database.ini.sample                      |   5 ++++
 failed/__init__.py                       |   0
 history/__init__.py                      |   0
 import_data.py                           |  25 ++++++++++++++++++
 insert_order.py                          |  31 +++++++++++++++++++++++
 logs/__init__.py                         |   0
 upload/__init__.py                       |   0
 13 files changed, 100 insertions(+)
 create mode 100644 .gitignore
 create mode 100644 __init__.py
 create mode 100644 __pycache__/config.cpython-311.pyc
 create mode 100644 __pycache__/insert_order.cpython-311.pyc
 create mode 100644 config.py
 create mode 100644 connect.py
 create mode 100644 database.ini.sample
 create mode 100644 failed/__init__.py
 create mode 100644 history/__init__.py
 create mode 100644 import_data.py
 create mode 100644 insert_order.py
 create mode 100644 logs/__init__.py
 create mode 100644 upload/__init__.py

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..e9aa16e
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+database.ini
+*.csv
diff --git a/__init__.py b/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/__pycache__/config.cpython-311.pyc b/__pycache__/config.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..39a3537fb86ffd3cfd4338340a3f2364ee77799c
GIT binary patch
literal 1078
zcmZ8e&rcIU6rTOr7FwhNVOJX6ARtW))q{x#q6eiHQi8#Q7Gbk?r?8>jt+R_FY?Dez
zEC~l<OyIzQ6UOidc=hV7B~55HF){JPtqJkM$v0all(#!?-kbTpnQz|v7KwBquwSVk
z*-;juzcjfp?mRes3BeB1k<R2$o=Gzd(gQlb!K7Kt>B1855F-67!t4P=hcxvq&BL02
z`2z-4VKfcc;*3Ay!4tX^XT0z;%gh=J(;BfcIScEWqrKH^JZ6}N*HN%+XMte*T`uEa
zb$*TrGnIHM!O=U&X<dL&yNn|1vinzd&-pO9=(;om6*)j(y{83tnRYa}56FumwNNy;
zjx6#n{~XQr6a`n%8M%dZImp?|d>nSRdd<5|s0Befw=Y~~myyeWdeC{;(%P<WopHGt
z6z8W-=+g;Btq#xNjAK})vi6{;n3khttz}bJ3{!Cyv9k8CsAP>Cj*Eo8%Hs*vbgy$!
zvsJsv^8~}edD{z3tYmP3p5%#Hi{v#YE_y-AHMKnU0vB+x;5XD0Gk$wLnrpxpnltU7
z;@jC!V$sUu#FDXOB?yL&gMW{6%LTlWXp+YYAHB|;rRi!jC%wR?I_*7hCG<NYZ_aPc
zmy&h9<MZVD<aV&i%QarE@Nz>$UEQz|h#Uvxqkz17uNoMv1qK^P5N4Trw0|e|CAPaz
zjgHi!BW1DPH_$*#Xw-M*iTa(P{TF*H<>dCG-RRfH)o`p5jx{&{{1ed)sUkf+mXb$O
z^5=)j^sB1$x+cA@cBN}w=}IvDr!!hgoq|5(1ywb#8K$aE#aY6`3ZZR<x`mtXX_m^b
zy#F*xpw(1W(oOk7ff%Oq9g#lD?E!Zd9M4<&at=Qs1CY`-+i$>uHioIA;Y$18;3Le<
u25NV=5g#tE9&vJolj{+wJi9r!HAib0DovC}KBYENCI4#(h`$9G|MvfQ&HJ4I

literal 0
HcmV?d00001

diff --git a/__pycache__/insert_order.cpython-311.pyc b/__pycache__/insert_order.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..3d6f28e93afb862af3c32b92d422a5e7d219e5fe
GIT binary patch
literal 2425
zcmb7FO>7fK6rTOF*FS3~ptv!p=~7w=Lm(82R4J%5F=>?+g(`ungwpNe9VbrKyJmNt
zIOzsiDu*D^3Q#IIaER14r3wdbMHL4KNbPZpe27*;s??KvG6E!vQ{Sv{>?BxKXLsJb
z_wAcEZ$7^n|11bW1nrxpU(=6Rg#IQ*y$LUsr-vzot|0{}l!``cBQ;8aO{;X48D%J>
zFc;7$i#dgzq{%Gf0*x?>(S)xaOyS~n6|KX4EpUGeoNs{#THwJJc&G&)Zh;Fe@JIt+
z0xp+5KFL;r6>7xmiD;PsLkY?ask*F4DP2ov#!_pp@G%OVf&TQL8rjrbP@(5S7FhMR
z1j=&VKy%>$vdD~=ZNej-7z&#~cKAo?JL(Xc6Kr9z$*b;-(E4cL8L=aaPy(Bq9kh{6
z*|g2rtj*az+i&xBARSzS6_?jmr4X#dZJxbxC7^{S&&JtWXeW9Hnd~%OU{0ZFibAJ=
z!vE{79oUJia3c$AEkA@N{B=A{zlDtWT-0i>BM8~iCE$8_jc>9(`~uPQQH`&S)6_Jo
z<<>k;VK&ZF=n({2G{xTRQ;(G3W_OE&nu!fdltm3si@Kp;L(FKFE?VQbW}2cUpH;Cq
z`}^R~$iVOkad7Cw@t2==891jKRz@3>G`+h9*0gk5&1l%uQwEkTtVm~Py2W(HFfB>X
zVGS$YqAG)tQgxFU8nz@;R<YR)3l@m0CaaRATe8|M=H!_y)-1DTCxT*g`>gNS$$^nw
zZ^O+0?up(Z*Kg)iDQud*phUnR1?uuSb0($d#tyiCI3F5LS*|aYH%#4d{kVWrc?$!e
zXR{g04Ga`gIA>*a%@vNyK#pwU0mA@SE@uFDi8eRf%!|u=v;r4yP+#N44K{dj!_B<F
zIc@Ob2G)3S8Q{eYHSyv`*7M>r<~h|3OkqvY4Jo6Ll*wUtS+XgYfgQOVCaIcju<K?H
ziT+}D&$yn&J(HP9y@%|;1UZG(d=3|SGG3iX-d6VIX54TyV2BWoT({;AP{T!3@ll}<
zsA96>L+u^K!N)@9#WR=A6hEx6VJ`kS5-UZzoX9SC7h|=tf_#Cln@3l-#IEhRy64K?
zg}oKT30;c^|7zQMEp#<>J-OI@o4>RB-h?y!rSsLKlbv!3Usn)1PYu#Ad_tch!<(b@
z6NK7N)6YB!2<ToCB*+zELAWebLJ-)C?ujR4oo7Teuvcl-YV}ocg@MGq>^<>>?Bf{`
z4eV8#7j3gwwfa1QgxL3m(rbI2(7p<yxQ>Q+%nS4QV)#;czUhHT)d~ZCFh1u|ATpo%
zlkY6?olgC&e#@=Lz|+jbkG0U=--Uka=-<NpcBrqHyWbNA^?ongcO-EC2m|^GO@Y3`
zc)BkP-YZ+!{+NFy#t=PD5q+DdzfL80pp~vzQealzjV5{K0mA|Efad^tATUJV(VjfO
zxV$7~<%}jtWpdq>$sJiHXRu7}|1!D6%cPRZ<iafTL<EQ+|5ph=RQQZ(kWa>TBFIFq
z_()hy&SFV&S=ktyGDwW4(2?;5h!_0ftghr${JyatOtP{G)q#LHidsd%qW7$#XwiFC
zQJ1s+t@t{qcm=JA{fG_E&pu+}4ijHx+lt37Z(ZoTzGGqg_0)~=#d9|%Zyvn$-tE3y
zy?2<q{Jr+Op?f0_KmS91c-k30SsEU7PJdAvKI2GdOVXG#o+(Kaj;fbb%gIlb)M;nN
zh60|Y`bkYE>7%5aXQ=^VeMEmutdHp9#QKyTu300b?zt1h0100<N(QmpAXTFWHvKQs
Ca6$?I

literal 0
HcmV?d00001

diff --git a/config.py b/config.py
new file mode 100644
index 0000000..7c3fc46
--- /dev/null
+++ b/config.py
@@ -0,0 +1,20 @@
+from configparser import ConfigParser
+
+def load_config(filename='database.ini', section='postgresql'):
+    parser = ConfigParser()
+    parser.read(filename)
+
+    # get section, default to postgresql
+    config = {}
+    if parser.has_section(section):
+        params = parser.items(section)
+        for param in params:
+            config[param[0]] = param[1]
+    else:
+        raise Exception('Section {0} not found in the {1} file'.format(section, filename))
+
+    return config
+
+if __name__ == '__main__':
+    config = load_config()
+    print(config)
diff --git a/connect.py b/connect.py
new file mode 100644
index 0000000..ab449be
--- /dev/null
+++ b/connect.py
@@ -0,0 +1,17 @@
+import psycopg2
+from config import load_config
+
+def connect(config):
+    """ Connect to the PostgreSQL database server """
+    try:
+        # connecting to the PostgreSQL server
+        with psycopg2.connect(**config) as conn:
+            print('Connected to the PostgreSQL server.')
+            return conn
+    except (psycopg2.DatabaseError, Exception) as error:
+        print(error)
+
+
+if __name__ == '__main__':
+    config = load_config()
+    connect(config)
diff --git a/database.ini.sample b/database.ini.sample
new file mode 100644
index 0000000..00ded78
--- /dev/null
+++ b/database.ini.sample
@@ -0,0 +1,5 @@
+[postgresql]
+host=localhost
+database=dbname
+user=user
+password=password
diff --git a/failed/__init__.py b/failed/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/history/__init__.py b/history/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/import_data.py b/import_data.py
new file mode 100644
index 0000000..2016521
--- /dev/null
+++ b/import_data.py
@@ -0,0 +1,25 @@
+# Import necessary packages
+import glob
+import csv
+import shutil
+from insert_order import insert_order
+
+# Import Oder History
+path = "./upload/Order_History*.csv"
+for filename in glob.glob(path):
+    with open(filename) as file_obj:
+        # Skips the heading 
+        # Using next() method 
+        heading = next(file_obj)
+        
+        # Create reader object by passing the file 
+        # object to reader method 
+        reader_obj = csv.reader(file_obj)
+        
+        # Iterate over each row in the csv file 
+        # using reader object 
+        for row in reader_obj:
+	        print(row)
+	        insert_order (row[0], row[1], row[2], row[3], row[4], row[5], row[6], row[7], row[8], row[9])
+        shutil.move(filename, "history/")
+
diff --git a/insert_order.py b/insert_order.py
new file mode 100644
index 0000000..b7121f4
--- /dev/null
+++ b/insert_order.py
@@ -0,0 +1,31 @@
+import sys
+import psycopg2
+from config import load_config
+
+
+def insert_order(reporting_no, order_no, offline_no, created_by, first_opened, last_closed, net_sales, tax, final_total, payments_total):
+    """ Insert a new order into the orders table """
+
+    sql = """INSERT INTO orders(reporting_no, order_no, offline_no, created_by, first_opened, last_closed, net_sales, tax, final_total, payments_total)
+             VALUES(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s);"""
+    
+    vendor_id = None
+    config = load_config()
+
+    try:
+        with  psycopg2.connect(**config) as conn:
+            with  conn.cursor() as cur:
+                # execute the INSERT statement
+                cur.execute(sql, (reporting_no, order_no, offline_no, created_by, first_opened, last_closed, net_sales, tax, final_total, payments_total))
+
+                # commit the changes to the database
+                conn.commit()
+    except (Exception, psycopg2.DatabaseError) as error:
+        print(error)    
+    finally:
+        #return vendor_id
+        print('success')
+    
+
+if __name__ == '__main__':
+    insert_order(sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[4], sys.argv[5], sys.argv[6], sys.argv[7], sys.argv[8], sys.argv[9], sys.argv[10])
diff --git a/logs/__init__.py b/logs/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/upload/__init__.py b/upload/__init__.py
new file mode 100644
index 0000000..e69de29