aa
This commit is contained in:
@@ -3,7 +3,6 @@ package event
|
|||||||
import (
|
import (
|
||||||
"encoding/hex"
|
"encoding/hex"
|
||||||
"fmt"
|
"fmt"
|
||||||
"git.rosy.net.cn/baseapi/utils"
|
|
||||||
"git.rosy.net.cn/jx-callback/business/jxutils"
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
||||||
"git.rosy.net.cn/jx-callback/business/model"
|
"git.rosy.net.cn/jx-callback/business/model"
|
||||||
"git.rosy.net.cn/jx-callback/business/model/dao"
|
"git.rosy.net.cn/jx-callback/business/model/dao"
|
||||||
@@ -156,10 +155,10 @@ func HandleTcpMessages() {
|
|||||||
var err error
|
var err error
|
||||||
time.Sleep(time.Second / 2)
|
time.Sleep(time.Second / 2)
|
||||||
prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize)
|
prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize)
|
||||||
fmt.Println(utils.Format4Output(prints, false))
|
|
||||||
for _, printMsg := range prints {
|
for _, printMsg := range prints {
|
||||||
if printMsg != nil {
|
if printMsg != nil {
|
||||||
if err = checkPrintMsg(printMsg); err == nil {
|
if err = checkPrintMsg(printMsg); err == nil {
|
||||||
|
fmt.Println("11111111111111111111", tcpClient.Clients[printMsg.PrintNo])
|
||||||
if tcpClient.Clients[printMsg.PrintNo] != nil {
|
if tcpClient.Clients[printMsg.PrintNo] != nil {
|
||||||
c = tcpClient.Clients[printMsg.PrintNo]
|
c = tcpClient.Clients[printMsg.PrintNo]
|
||||||
data, err = buildMsg(printMsg)
|
data, err = buildMsg(printMsg)
|
||||||
|
|||||||
Reference in New Issue
Block a user