liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-06-29 10:49:46 +08:00
parent 92aba744ff
commit 8e7b4b56e1
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/event/event_tcp.go
View File

@@ -147,7 +147,6 @@ func HandleTcpMessages() {
var ( var (
db = dao.GetDB() db = dao.GetDB()
offset, pageSize = 0, 10 offset, pageSize = 0, 10
data []byte
) )
for { for {
//一直读？ //一直读？
@@ -155,7 +154,10 @@ func HandleTcpMessages() {
time.Sleep(time.Second / 2) time.Sleep(time.Second / 2)
prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize) prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize)
for _, printMsg := range prints { for _, printMsg := range prints {
var c net.Conn var (
data []byte
c net.Conn
)
if printMsg != nil { if printMsg != nil {
if err = checkPrintMsg(printMsg); err == nil { if err = checkPrintMsg(printMsg); err == nil {
if tcpClient.Clients[printMsg.PrintNo] != nil { if tcpClient.Clients[printMsg.PrintNo] != nil {