aa

business/jxstore/event/event_tcp.go

@@ -75,7 +75,6 @@ func handleConn(c net.Conn) {
 		globals.SugarLogger.Debugf("conn is nil")
 		return
 	}
-	globals.SugarLogger.Debugf("handleConn map: [%v]", utils.Format4Output(tcpClient.Clients, false))
 	defer c.Close()
 	buffer := make([]byte, 1024)
 	for {
@@ -88,6 +87,7 @@ func handleConn(c net.Conn) {
 			}
 			return
 		}
+		globals.SugarLogger.Debugf("handleConn map: [%v]", utils.Format4Output(tcpClient.Clients, false))
 		//看是心跳还是打印返回
 		data := hex.EncodeToString(buffer[:n])
 		globals.SugarLogger.Debugf("handleConn heart : [%v]", data)
@@ -95,6 +95,7 @@ func handleConn(c net.Conn) {
 		if strings.Contains(data, heartText) {
 			printNoData, _ := hex.DecodeString(data[len(heartText) : len(data)-8])
 			printNo = string(printNoData)
+			globals.SugarLogger.Debugf("handleConn printno :[%v]", printNo)
 			if tcpClient.Clients[printNo] == nil {
 				tcpClient.Clients[printNo] = c
 			} else {
@@ -151,6 +152,7 @@ func HandleTcpMessages() {
 		//一直读？
 		var err error
 		prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize)
+		globals.SugarLogger.Debugf("HandleTcpMessages, len prints: [%v]", len(prints))
 		for _, printMsg := range prints {
 			if printMsg != nil {
 				if err = checkPrintMsg(printMsg); err == nil {