From 17aecd365f444a3d766b0b4f4f9858cbea468e31 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Tue, 29 Jun 2021 09:10:21 +0800 Subject: [PATCH] aa --- business/jxstore/event/event_tcp.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 3773947bb..37875911b 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -69,7 +69,6 @@ func ListenTcp() { func handleConn(c net.Conn) { var ( printNo string //打印机编号 - db = dao.GetDB() ) if c == nil { globals.SugarLogger.Debugf("conn is nil") @@ -100,16 +99,17 @@ func handleConn(c net.Conn) { tcpClient.Clients[printNo] = c } else { //改变打印机状态 - changePrinterStatus(db, printNo, printerStatusOnline) + changePrinterStatus(printNo, printerStatusOnline) } } else if strings.Contains(data, printText) { - changePrintMsg(db, data) + changePrintMsg(data) } } } -func changePrintMsg(db *dao.DaoDB, data string) (err error) { +func changePrintMsg(data string) (err error) { var ( + db = dao.GetDB() printNo, comment string orderNo int64 status int @@ -148,6 +148,7 @@ func HandleTcpMessages() { c net.Conn data []byte ) + globals.SugarLogger.Debugf("HandleTcpMessages, start.....") for { //一直读? var err error @@ -160,7 +161,7 @@ func HandleTcpMessages() { c = tcpClient.Clients[printMsg.PrintNo] data, err = buildMsg(printMsg) } else { - changePrinterStatus(db, printMsg.PrintNo, printerStatusOffline) + changePrinterStatus(printMsg.PrintNo, printerStatusOffline) } } } else { @@ -182,9 +183,10 @@ func HandleTcpMessages() { } } -func changePrinterStatus(db *dao.DaoDB, printNo string, status int) (err error) { +func changePrinterStatus(printNo string, status int) (err error) { var ( printer = &model.Printer{} + db = dao.GetDB() ) sql := ` SELECT * FROM printer WHERE print_no = ?