Added TCL version

data_reader.py

@@ -80,16 +80,16 @@ def parce_string(line):
         dial_number = dial_number[3:]
     else: call_direct = "Исходящий"
 
-    insert(call_date=call_date,
-           call_time=call_time,
-           int_number=int_number,
-           ext_co_line=ext_co_line,
-           dial_number=dial_number,
-           ring=ring,
-           call_duration=call_duration,
-           acc_code=acc_code,
-           call_code=call_code,
-           call_direct=call_direct)
+        insert(call_date=call_date,
+               call_time=call_time,
+               int_number=int_number,
+               ext_co_line=ext_co_line,
+               dial_number=dial_number,
+               ring=ring,
+               call_duration=call_duration,
+               acc_code=acc_code,
+               call_code=call_code,
+               call_direct=call_direct)
 
 def port_data_read(port_name):
     global out_dir
@@ -127,3 +127,4 @@ if __name__ == "__main__":
         \n- для чтения данных напрямую с com-порта АТС\
         \n # python data_reader.py -port /dev/ttyUSB0\n")
         sys.exit(1)
+c

logger.tcl

@@ -0,0 +1,109 @@
+#!/usr/bin/tclsh
+######################################################
+#        Panasonic TDA200 call data collector
+#        Distributed under GNU Public License
+# Author: Sergey Kalinin banzaj28@gmail.com
+# Home page: 
+######################################################
+package require mysqltcl
+
+# параметры соединения с СУБД
+set db(host) "host"
+set db(user) "user"
+set db(pass) "password"
+set db(dbname) "ats_test"
+set out_dir "~/tmp/ats"
+
+proc InsertData {} {
+    global arrVariables db
+    puts [array size arrVariables]
+    set qwery "INSERT INTO `cdr` ("
+    foreach key [array names arrVariables] {
+        set qwery "$qwery `$key`, "
+    }
+    set qwery "[string trimright  $qwery ", "]\) VALUES\("
+    foreach key [array names arrVariables] {
+        set qwery "$qwery \"[string trim $arrVariables($key)]\","
+    }
+    set qwery "[string trimright $qwery ", "]\);"
+    puts $qwery
+    set conn [mysql::connect -host $db(host) -db $db(dbname) -user $db(user) -password $db(pass) -encoding utf-8]
+    mysql::exec $conn $qwery
+    mysql::commit $conn
+    mysql::close $conn
+}
+
+proc ParceString {line} {
+    global out_dir arrVariables
+    # Получает на вход строку и раскидывает её в нужном виде и пишет в файл
+    if {[string range $line 0 2] == "---" || $line == "" || [string range $line 3 6] == "Date"} {
+        # puts $line
+        return
+    }
+    # Создаём текстовые файлы на всякий случай, для дублирования информации
+    set fName [clock format [clock scan "now" -base [clock seconds]] -format %m_%Y]
+    set out_log_name [file join $out_dir $fName]
+    set out_log [open $out_log_name "a+"]
+    puts $out_log "$line"
+    close $out_log
+    # Разбор строки
+    # Преобразуем дату к виду "ДД/ММ/ГГГГ"
+    set arrVariables(call_date) "20[string range $line 6 7]\/[string range $line 3 4]\/[string range $line 0 1]"
+    set arrVariables(call_time) [string range $line 9 13]
+    set arrVariables(int_number) [string range $line 19 21]
+    set arrVariables(ext_co_line) [string range $line 23 24]
+    set arrVariables(dial_number) [string range $line 26 50]
+    set arrVariables(ring) [string range $line 52 55]
+    set arrVariables(call_duration) [string range $line 57 66]
+    set arrVariables(acc_code) [string range $line 66 76]
+    set arrVariables(call_code) [string range $line 77 81]
+    # Проверяем признак входящщего звонка
+    if {$arrVariables(dial_number) == "<I>"} {
+        set arrVariables(call_direct) "In"
+        set arrVariables(dial_number) ""
+    } elseif {[string range $arrVariables(dial_number) 0 3] == "EXT"} {
+        set arrVariables(call_direct) "Ext"
+        set arrVariables(dial_number) [string range $arrVariables(dial_number) 3 end]
+    } else {
+        set arrVariables(call_direct) "Out"
+    }
+    InsertData
+}
+
+proc PortDataRead {portName} {
+    global out_dir
+    set fh [open $portName RD]
+    fconfigure $fh -blocking 0 -buffering none -mode 9600,n,8,1 -translation binary -eofchar {}
+    while [gets line $fh] {
+        set line = [string trim $line]
+        ParceString $line
+    }
+}
+
+# Обработка ключей командной сроки
+if {[llength $argv] >= 2} {
+    if {[lindex $argv 0] == "-port"} {
+        set port_name [lindex $argv 2]
+        PortDataRead $port_name
+    }
+    if {[lindex $argv 0] == "-file"} {
+        set log_file_name [lindex $argv 1]
+        set log [open $log_file_name "r"]
+        # проверям наличие каталога и если его нет то создаём
+        if {[file isdirectory $out_dir] == 0} {
+            file mkdir $out_dir
+        }
+        # читаем файл построчно
+        while {[gets $log line] >= 0} {
+            ParceString $line
+        }
+        close $log
+    }
+} else {
+    puts "\nФормат вызова:\n- для обработки файла\
+    \n # python data_reader.py -file TDA20013082015_12052016.lg\
+    \n- для чтения данных напрямую с com-порта АТС\
+    \n # python data_reader.py -port /dev/ttyUSB0\n"
+    exit
+}
+