From b4bac4ea1720b53abbe11897bf41a76a64c3f03f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Thu, 16 Mar 2023 14:34:18 +0800 Subject: [PATCH] 1 --- business/jxstore/event/event_tcp.go | 1 + business/jxstore/event/print_test.go | 34 ++++++++++++++++++++++++++++ 2 files changed, 35 insertions(+) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index eb84d071d..9f38519d5 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -63,6 +63,7 @@ func (t *TcpClient) handleConn(c net.Conn) error { //看是心跳还是打印回调 data := hex.EncodeToString(buffer[:n]) + globals.SugarLogger.Debugf("========shuju:=%s", data) if strings.Contains(string(buffer[0:n]), "print_no_clear") { // 清理缓存 param := struct { PrintNoClear json.Number `json:"print_no_clear"` diff --git a/business/jxstore/event/print_test.go b/business/jxstore/event/print_test.go index 542f93afb..2f86e47e1 100644 --- a/business/jxstore/event/print_test.go +++ b/business/jxstore/event/print_test.go @@ -5,6 +5,7 @@ import ( "fmt" "git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/model" + "net" "strconv" "strings" "testing" @@ -82,3 +83,36 @@ func TestTen216(t *testing.T) { fmt.Println(gg) fmt.Println(kk) } + +func TestBuildTest(s *testing.T) { + l, err := net.Listen("tcp", ":8000") + if err != nil { + fmt.Println("listen error:", err) + return + } + for { + c, err := l.Accept() + if err != nil { + fmt.Println("accept error:", err) + break + } + go func() { + t := NewTcpClient() + if err := t.HandleConnTest(c); err != nil { + t = nil + return + } + }() + } + +} +func (t *TcpClient) HandleConnTest(c net.Conn) error { + c.Write([]byte("")) + t.addConn(c, "1111111", 1) + t.buildAllMap("1111111") + t.HandleTcpMessages("1111111") + t.doPrint("1111111") + changePrinterStatus("1111111", 1) + t.HandleCheckTcpHeart("1111111") + return nil +}