From dda8b5c209be5800ae714313b911caaabf9a9149 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Thu, 22 Jul 2021 15:06:08 +0800
Subject: [PATCH] aa

---
 business/jxstore/event/event_tcp.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index bf07c08c2..ada019e17 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -370,6 +370,7 @@ func HandleTcpMessages() {
 		//一直读？
 		prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
 		for _, printMsg := range prints {
+			printMsgChan <- printMsg
 			printMsg.Status = printMsgAlreadyLoad
 			dao.UpdateEntity(db, printMsg, "Status")
 		}
@@ -382,7 +383,7 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
 	)
 	for {
 		select {
-		case printMsg, _ := <-printMsgChan:
+		case printMsg := <-printMsgChan:
 			var (
 				data []byte
 				c    net.Conn