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

a

Browse Source
This commit is contained in:
suyl
2021-07-30 17:37:39 +08:00
parent 6668ce23c7
commit 9f4786de45
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -94,8 +94,8 @@ func (t *TcpClient) handleConn(c net.Conn) {
//t.Clients[printNo] = printInfo //t.Clients[printNo] = printInfo
//t.Unlock() //t.Unlock()
t.addConn(c, printNo, status) t.addConn(c, printNo, status)
t.buildCallBackMap(printNo) //t.buildCallBackMap(printNo)
t.buildMsgMap(printNo) //t.buildMsgMap(printNo)
go t.doPrint2(printNo) go t.doPrint2(printNo)
changePrinterStatus(printNo, status) changePrinterStatus(printNo, status)
if status == printerStatusOnline { if status == printerStatusOnline {

8
business/jxstore/event/event_tcp_utils.go
View File

@@ -219,8 +219,8 @@ func (t *TcpClient) setPrintStatus(key string, status int) {
} }
func (t *TcpClient) addMsgChan(printMsg *model.PrintMsg) { func (t *TcpClient) addMsgChan(printMsg *model.PrintMsg) {
t.RLock() t.Lock()
defer t.RUnlock() defer t.Unlock()
if !t.isExistMsg(printMsg.PrintNo) { if !t.isExistMsg(printMsg.PrintNo) {
t.buildMsgMap(printMsg.PrintNo) t.buildMsgMap(printMsg.PrintNo)
} }
@@ -228,8 +228,8 @@ func (t *TcpClient) addMsgChan(printMsg *model.PrintMsg) {
} }
func (t *TcpClient) addCallbackChan(key, data string) { func (t *TcpClient) addCallbackChan(key, data string) {
t.RLock() t.Lock()
defer t.RUnlock() defer t.Unlock()
if !t.isExistCallback(key) { if !t.isExistCallback(key) {
t.buildCallBackMap(key) t.buildCallBackMap(key)
} }