From a441c28bf599cae71f03714283e10be5fd31e9e1 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Mon, 2 Aug 2021 16:03:39 +0800 Subject: [PATCH] aa --- business/jxstore/event/event_tcp.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index cb73e90a6..e5b81c72c 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -156,8 +156,9 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize) for _, printMsg := range prints { printMsg.Status = printMsgAlreadyLoad - dao.UpdateEntity(db, printMsg, "Status") - t.addMsgChan(printMsg) + if _, err := dao.UpdateEntity(db, printMsg, "Status"); err == nil { + t.addMsgChan(printMsg) + } } } }()