test: websocket

aarch64/pjibot_guide/common/config/c_websocket.go

@@ -59,7 +59,7 @@ func keepAlive() {
 	for {
 		select {
 		case <-ticker.C:
-			err := WsConn.WriteMessage(websocket.PingMessage, requestJSON)
+			err := WsConn.WriteMessage(websocket.TextMessage, requestJSON)
 			if err != nil {
 				c_log.GlobalLogger.Error("保持websocket连接活跃，发送心跳请求 - 失败。", err)
 				continue
@@ -77,7 +77,7 @@ func keepAlive() {
 				c_log.GlobalLogger.Error("保持websocket连接活跃，解析心跳响应为json - 失败。", err)
 				continue
 			}
-			c_log.GlobalLogger.Info("websocket responseMessage results:", responseMessage)
+			c_log.GlobalLogger.Info("websocket responseMessage:", responseMessage)
 			if responseMessage.Status != "" {
 				c_log.GlobalLogger.Info("websocket发送心跳请求解析状态为", responseMessage.Status)
 			}

aarch64/pjibot_guide/control/pkg/judge_local.go

@@ -32,6 +32,9 @@ func GetLocalStatus(localStatus *string, lastLocalStatus *string, turnLength int
 			log.Println("Error in receive:", err)
 			break
 		}
+		fmt.Println("websocket:", config.WsConn)
+		fmt.Println("statusMessage:", statusMessage)
+
 		if statusMessage.Type == "push" && statusMessage.Topic == "robotStatus" {
 			//fmt.Println("statusMessage:", statusMessage)
 			data := statusMessage.Data.(map[string]interface{})