rang
This commit is contained in:
@@ -298,16 +298,20 @@ func (t *TcpClient) doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
|
|||||||
func (t *TcpClient) HandleCheckTcpHeart() {
|
func (t *TcpClient) HandleCheckTcpHeart() {
|
||||||
for {
|
for {
|
||||||
keys := []string{}
|
keys := []string{}
|
||||||
|
t.RLock()
|
||||||
for k, v := range t.Clients {
|
for k, v := range t.Clients {
|
||||||
if time.Now().Sub(v.StatusTime) > time.Minute+time.Second {
|
if time.Now().Sub(v.StatusTime) > time.Minute+time.Second {
|
||||||
v.Status = printerStatusOffline
|
v.Status = printerStatusOffline
|
||||||
keys = append(keys, k)
|
keys = append(keys, k)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
t.RUnlock()
|
||||||
for _, v := range keys {
|
for _, v := range keys {
|
||||||
changePrinterStatus(v, printerStatusOffline)
|
changePrinterStatus(v, printerStatusOffline)
|
||||||
if t.Clients[v] != nil {
|
if t.isExist(v) {
|
||||||
|
t.Lock()
|
||||||
delete(t.Clients, v)
|
delete(t.Clients, v)
|
||||||
|
t.Unlock()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -86,7 +86,6 @@ const (
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
//t = &TcpClient{}
|
//t = &TcpClient{}
|
||||||
|
|
||||||
printErrMap = map[string]string{
|
printErrMap = map[string]string{
|
||||||
printErrWithoutPaper: "打印机缺纸!",
|
printErrWithoutPaper: "打印机缺纸!",
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user