diff --git a/ftpReceiver/utils/__init__.py b/ftpReceiver/utils/__init__.py new file mode 100644 index 0000000..d325317 --- /dev/null +++ b/ftpReceiver/utils/__init__.py @@ -0,0 +1 @@ +"""Utilità""" diff --git a/ftpReceiver/utils/config/__init__.py b/ftpReceiver/utils/config/__init__.py new file mode 100644 index 0000000..09324b5 --- /dev/null +++ b/ftpReceiver/utils/config/__init__.py @@ -0,0 +1 @@ +"""Config ini setting""" diff --git a/ftpReceiver/utils/config/set_config.py b/ftpReceiver/utils/config/set_config.py new file mode 100644 index 0000000..c19175f --- /dev/null +++ b/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") diff --git a/ftpReceiver/utils/parsers/G801_parser.py b/ftpReceiver/utils/parsers/G801_parser.py new file mode 100644 index 0000000..18da667 --- /dev/null +++ b/ftpReceiver/utils/parsers/G801_parser.py @@ -0,0 +1 @@ +locals diff --git a/ftpReceiver/utils/parsers/__init__.py b/ftpReceiver/utils/parsers/__init__.py new file mode 100644 index 0000000..645f1c4 --- /dev/null +++ b/ftpReceiver/utils/parsers/__init__.py @@ -0,0 +1 @@ +"""Parser delle centraline""" diff --git a/ftpReceiver/utils/time/__init__.py b/ftpReceiver/utils/time/__init__.py new file mode 100644 index 0000000..71166cd --- /dev/null +++ b/ftpReceiver/utils/time/__init__.py @@ -0,0 +1 @@ +"""Utilità per i formati timestamp""" diff --git a/ftpReceiver/utils/time/date_refmt.py b/ftpReceiver/utils/time/date_refmt.py new file mode 100644 index 0000000..3bf409b --- /dev/null +++ b/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") diff --git a/ftpReceiver/utils/time/dt_convert.py b/ftpReceiver/utils/time/dt_convert.py new file mode 100644 index 0000000..13392e2 --- /dev/null +++ b/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") diff --git a/ftpReceiver/utils/time/timestamp_fmt.py b/ftpReceiver/utils/time/timestamp_fmt.py new file mode 100644 index 0000000..88b001a --- /dev/null +++ b/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])