diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 43545cb5f..dad7c1827 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -73,7 +73,6 @@ func handleConn(c net.Conn, t *TcpClient) error { if c == nil { return errors.New("conn is nil") } - defer c.Close() for { buffer, n, err := ConnRead(c) if err != nil { @@ -482,7 +481,7 @@ func HandleCheckTcpHeart(t *TcpClient, key string) { statusTime := t.getPrintStatusTime(key) if !utils.IsTimeZero(statusTime) { //1分钟内没心跳判断打印机掉线了 - if time.Now().Sub(statusTime) > time.Second*70 { + if time.Now().Sub(statusTime) > time.Second*60 { globals.SugarLogger.Debugf("超过一分十秒没有心跳的打印机[%s]", key) changePrinterStatus(key, printerStatusOffline) delete(t.TimeoutMap, key) @@ -499,26 +498,4 @@ func HandleCheckTcpHeart(t *TcpClient, key string) { } } Poll.AddJob(fn) - //go func() { - // for { - // if t.TimeoutMap[key] == true { - // statusTime := t.getPrintStatusTime(key) - // if !utils.IsTimeZero(statusTime) { - // //1分钟内没心跳判断打印机掉线了 - // if time.Now().Sub(statusTime) > time.Second*70 { - // globals.SugarLogger.Debugf("超过一分十秒没有心跳的打印机[%s]", key) - // changePrinterStatus(key, printerStatusOffline) - // delete(t.TimeoutMap, key) - // globals.SugarLogger.Debugf("t := %s", utils.Format4Output(t.Clients[key].StatusTime, false)) - // } - // } - // } else { - // t.getClients(key).C.Close() - // close(t.MsgMap[key]) - // close(t.CallBackMap[key]) - // t.delConn(key) - // return - // } - // } - //}() }