commit iniziale

ftpReceiver/utils/__init__.py

@@ -0,0 +1 @@
+"""Utilità"""

ftpReceiver/utils/config/__init__.py

@@ -0,0 +1 @@
+"""Config ini setting"""

ftpReceiver/utils/config/set_config.py

@@ -0,0 +1,55 @@
+"""set configurations
+
+"""
+from configparser import ConfigParser
+
+
+class config:
+    def __init__(self):
+        c = ConfigParser()
+        c.read(["/etc/aseftp/ftpcsvreceiver.ini", "./ftpcsvreceiver.ini",
+               "./ase-receiver/ase-receiver/ftpcsvreceiver.ini"])
+        # FTP setting
+        self.firstport = c.getint("ftpserver", "firstPort")
+        self.logfilename = c.get("ftpserver", "logFilename")
+        self.proxyaddr = c.get("ftpserver", "proxyAddr")
+        self.portrangewidth = c.getint("ftpserver", "portRangeWidth")
+        self.virtusersdb = c.get("ftpserver", "virtusersdb")
+        self.virtpath = c.get("ftpserver", "virtpath")
+        self.adminuser = c.get("ftpserver", "adminuser").split("|")
+        self.servertype = c.get("ftpserver", "servertype")
+        self.certfile = c.get("ftpserver", "certfile")
+        self.fileext = c.get("ftpserver", "fileext").upper().split("|")
+
+        # MAIL setting
+        self.smtphost = c.get("mailserver", "hostname")
+        self.smtpport = c.getint("mailserver", "port")
+        self.sender = c.get("mailserver", "sender")
+        self.password = c.get("mailserver", "password")
+        self.receivers = c.get("mailserver", "receivers")
+        self.message = c.get("mailserver", "message")
+        self.subject = c.get("mailserver", "subject")
+        self.debuglevel = c.getint("mailserver", "debug")
+
+        # MQ setting
+        self.mqhost = c.get("mqserver", "hostname")
+        self.mqport = c.get("mqserver", "port")
+        self.mquser = c.get("mqserver", "user")
+        self.mqpass = c.get("mqserver", "password")
+        self.csv_queue = c.get("mqserver", "csvQueue")
+        self.elab_queue = c.get("mqserver", "elabQueue")
+
+        # CSV FILE setting
+        self.csvfs = c.get("csvfs", "path")
+
+        # LOADER setting
+        self.elablog = c.get("csvelab", "logFilename")
+
+        # DB setting
+        self.dbhost = c.get("db", "hostname")
+        self.dbuser = c.get("db", "user")
+        self.dbpass = c.get("db", "password")
+        self.dbname = c.get("db", "dbName")
+        self.table = c.get("db", "tableName")
+        self.valueNum = c.getint("db", "valueNum")
+        self.maxInsertRow = c.getint("db", "maxInsertRow")

ftpReceiver/utils/parsers/G801_parser.py

@@ -0,0 +1 @@
+locals

ftpReceiver/utils/parsers/__init__.py

@@ -0,0 +1 @@
+"""Parser delle centraline"""

ftpReceiver/utils/time/__init__.py

@@ -0,0 +1 @@
+"""Utilità per i formati timestamp"""

ftpReceiver/utils/time/date_refmt.py

@@ -0,0 +1,28 @@
+"""Funzioni per formato data
+
+"""
+
+from datetime import datetime
+from re import search
+
+
+def dateFmt(date):
+    t = date.replace("/", "-")
+    if search('^\d\d\d\d-\d\d-\d\d$', t):
+        d = datetime.strptime(t, "%Y-%m-%d")
+    elif search('^\d\d-\d\d-\d\d$', t):
+        d = datetime.strptime(t, "%y-%m-%d")
+    elif search('^\d\d-\d\d-\d\d\d\d$', t):
+        d = datetime.strptime(t, "%d-%m-%Y")
+    return datetime.strftime(d, "%Y-%m-%d")
+
+
+def dateTimeFmt(date):
+    t = date.replace("/", "-")
+    if search('^\d\d\d\d-\d\d-\d\d$', t):
+        d = datetime.strptime(t, "%Y-%m-%d %H:%M:%S")
+    elif search('^\d\d-\d\d-\d\d$', t):
+        d = datetime.strptime(t, "%y-%m-%d %H:%M:%S")
+    elif search('^\d\d-\d\d-\d\d\d\d$', t):
+        d = datetime.strptime(t, "%d-%m-%Y %H:%M:%S")
+    return datetime.strftime(d, "%Y-%m-%d")

ftpReceiver/utils/time/dt_convert.py

@@ -0,0 +1,25 @@
+"""Funzioni per convertire formato data
+
+"""
+
+import datetime
+
+
+def dateFmt(date):
+    t = date.replace("/", "-")
+    try:
+        datetime.datetime.strptime(t, "%Y-%m-%d")
+        return t
+    except ValueError:
+        d = datetime.datetime.strptime(t, "%d-%m-%Y")
+        return datetime.datetime.strftime(d, "%Y-%m-%d")
+
+
+def dateTimeFmt(date):
+    t = date.replace("/", "-")
+    try:
+        datetime.datetime.strptime(t, "%Y-%m-%d %H:%M:%S")
+        return t
+    except ValueError:
+        d = datetime.datetime.strptime(t, "%d-%m-%Y %H:%M:%S")
+        return datetime.datetime.strftime(d, "%Y-%m-%d %H:%M:%S")

ftpReceiver/utils/time/timestamp_fmt.py

@@ -0,0 +1,10 @@
+"""Funzioni per timestamp
+
+"""
+
+from datetime import datetime
+
+
+def timestamp(t):
+    fmt = {"log": "%Y-%m-%d %H:%M:%S", "tms": "%Y%m%d%H%M%S"}
+    return datetime.now().strftime(fmt[t])