From b889adc00dff8883dce36086ff468cbd86e8e219 Mon Sep 17 00:00:00 2001
From: svk28 <banzaj28@yandex.ru>
Date: Tue, 1 Aug 2017 10:09:28 +0300
Subject: [PATCH] Added backup data files procedure

---
 data_reader.py | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/data_reader.py b/data_reader.py
index b39727f..682d908 100755
--- a/data_reader.py
+++ b/data_reader.py
@@ -12,13 +12,17 @@
 ####################################################################
 
 import pymysql
-import sys
+import sys, os
 import re
+import datetime
+
+
 
 # параметры соединения с СУБД
 db_host = 'host'
 db_user = 'dbuser'
 db_pass = 'dbpass'
+out_dir = '/var/log/ats'
 
 def insert(**kwargs):
     """Вставка данных в БД. В качестве параметров список полей и значений"""
@@ -47,6 +51,13 @@ def parce_string(line):
         return
     print(line)
 
+    # Создаём текстовые файлы на всякий случай, для дублирования информации
+    now = datetime.datetime.now()
+    out_log_name = os.path.join(out_dir, '{}_{}'.format(now.month, now.year))
+    out_log = open(out_log_name,"a+")
+    out_log.write(line + '\n')
+    out_log.close()
+
     # Разбор строки
     # Преобразуем дату к виду "ДД/ММ/ГГГГ"
     #call_date = "{}.{}.20{}".format(line[:2],line[3:5],line[6:8])
@@ -81,6 +92,7 @@ def parce_string(line):
            call_direct=call_direct)
 
 def port_data_read(port_name):
+    global out_dir
     """Чтение данных из последовательного порта, тестовая реализация"""
     import serial
     ser = serial.Serial(port_name)