aa

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 = ?