modify logger
This commit is contained in:
+2
-2
@@ -19,7 +19,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"os/signal"
|
"os/signal"
|
||||||
"syscall"
|
"syscall"
|
||||||
|
"fmt"
|
||||||
"it2000.com.cn/tele-recv/utils"
|
"it2000.com.cn/tele-recv/utils"
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
@@ -92,7 +92,7 @@ func start() {
|
|||||||
buffer, count := utils.ReadPort()
|
buffer, count := utils.ReadPort()
|
||||||
if count > 0 {
|
if count > 0 {
|
||||||
if lograw {
|
if lograw {
|
||||||
l.Info(string(buffer))
|
fmt.Print(string(buffer))
|
||||||
}
|
}
|
||||||
utils.Append(buffer)
|
utils.Append(buffer)
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
@@ -45,7 +45,7 @@ func OpenPort(device string, baudrate int, bytesize byte, stopbits byte) error {
|
|||||||
|
|
||||||
//ReadPort read byte array from port
|
//ReadPort read byte array from port
|
||||||
func ReadPort() ([]byte, int) {
|
func ReadPort() ([]byte, int) {
|
||||||
buffer := make([]byte, 256)
|
buffer := make([]byte, 1)
|
||||||
if !ServerRunning {
|
if !ServerRunning {
|
||||||
return buffer, 0
|
return buffer, 0
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-2
@@ -82,9 +82,9 @@ func InsertTelegram(teleString string) {
|
|||||||
checkDbErr(err, "error in insert telegram ")
|
checkDbErr(err, "error in insert telegram ")
|
||||||
isWriting = false
|
isWriting = false
|
||||||
if insertSQL == InsertOld {
|
if insertSQL == InsertOld {
|
||||||
Log.Infof("telegram [%n] processed ", id)
|
Log.Infof("telegram [%s] processed ", id)
|
||||||
} else {
|
} else {
|
||||||
Log.Infof("telegram [%n] saved ", id)
|
Log.Infof("telegram [%s] saved ", id)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user