1

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"`

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
+}