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

1

Browse Source
This commit is contained in:
邹宗楠
2023-06-01 09:29:43 +08:00
parent 5f3f974d3e
commit 5f1bf89743
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -51,7 +51,6 @@ func ListenTcp() {
t := NewTcpClient() t := NewTcpClient()
if err := handleConn(c, t); err != nil { if err := handleConn(c, t); err != nil {
t = nil t = nil
//Poll.Stop()
return return
} }
} }
@@ -76,7 +75,6 @@ func ListenTcp() {
func handleConn(c net.Conn, t *TcpClient) error { func handleConn(c net.Conn, t *TcpClient) error {
if c == nil { if c == nil {
globals.SugarLogger.Debugf("conn is nil")
return errors.New("conn is nil") return errors.New("conn is nil")
} }
defer c.Close() defer c.Close()
@@ -131,7 +129,8 @@ func handleConn(c net.Conn, t *TcpClient) error {
//t.printFail() //t.printFail()
} }
changePrinterStatus(printNo, status) changePrinterStatus(printNo, status)
t.HandleCheckTcpHeart(printNo) // 暂时关闭心跳检测
//t.HandleCheckTcpHeart(printNo)
// todo 证明打印机已经被激活,将激活打印机存入数据库,保证用户不能无限制绑定打印机 // todo 证明打印机已经被激活,将激活打印机存入数据库,保证用户不能无限制绑定打印机
if err := dao.NotExistsCreate(printNo); err != nil { if err := dao.NotExistsCreate(printNo); err != nil {
globals.SugarLogger.Debugf("监听打印机心跳,不存在则创建 :[%v],printNo[%s]", err, printNo) globals.SugarLogger.Debugf("监听打印机心跳,不存在则创建 :[%v],printNo[%s]", err, printNo)
@@ -481,6 +480,7 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) {
if !utils.IsTimeZero(statusTime) { if !utils.IsTimeZero(statusTime) {
//1分钟内没心跳判断打印机掉线了 //1分钟内没心跳判断打印机掉线了
if time.Now().Sub(statusTime) > time.Minute+time.Second*10 { if time.Now().Sub(statusTime) > time.Minute+time.Second*10 {
globals.SugarLogger.Debugf("超过一分十秒没有心跳的打印机[%s]", key)
changePrinterStatus(key, printerStatusOffline) changePrinterStatus(key, printerStatusOffline)
delete(t.TimeoutMap, key) delete(t.TimeoutMap, key)
} }