aa

business/jxstore/event/event_tcp.go

@@ -304,14 +304,19 @@ func doPrint(printMsgChanFail chan *model.PrintMsg) (err error) {
 							globals.SugarLogger.Debugf("handleTcpMessages success, data: %v", hex.EncodeToString(data))
 							printMsg.Status = printMsgAlreadySend
 							dao.UpdateEntity(db, printMsg, "Status", "Comment")
-
-							buffer := make([]byte, 1024)
-							n, _ := c.Read(buffer)
-							data := hex.EncodeToString(buffer[:n])
-							if strings.Contains(data, printText) {
-								globals.SugarLogger.Debugf("handleConn print callback: %v", data)
-								changePrintMsg(data)
+							for {
+								buffer := make([]byte, 1024)
+								n, _ := c.Read(buffer)
+								data := hex.EncodeToString(buffer[:n])
+								if strings.Contains(data, printText) {
+									globals.SugarLogger.Debugf("handleConn print callback: %v", data)
+									changePrintMsg(data)
+								}
+								if len(buffer) > 0 {
+									break
+								}
 							}
+
 						}
 					}
 				}