Browse Source

test websocket

HeWang 7 months ago
parent
commit
881f439d1f
1 changed files with 7 additions and 6 deletions
  1. 7 6
      tools/pji_api/main/main.go

+ 7 - 6
tools/pji_api/main/main.go

@@ -30,10 +30,10 @@ type Response struct {
 }
 
 type StatusMessage struct {
-	Type  string                 `json:"type"`
-	Topic string                 `json:"topic"`
-	Time  int64                  `json:"time"`
-	Data  map[string]interface{} `json:"data"`
+	Type  string      `json:"type"`
+	Topic string      `json:"topic"`
+	Time  int64       `json:"time"`
+	Data  interface{} `json:"data"`
 }
 
 // SendWebsocketRequest 发送WebSocket请求并返回sn字段的值
@@ -151,8 +151,9 @@ func receiveHandler(connection *websocket.Conn) {
 		}
 		fmt.Println("statusMessage:", statusMessage)
 		if statusMessage.Type == "push" && statusMessage.Topic == "robotStatus" {
-			fmt.Println("statusMessage.Data", statusMessage.Data)
-			fmt.Println("statusMessage.Data[\"taskStatus\"]", statusMessage.Data["taskStatus"])
+			data := statusMessage.Data.(map[string]interface{})
+			fmt.Println("statusMessage.Data", data)
+			fmt.Println("statusMessage.Data[\"taskStatus\"]", data["taskStatus"])
 		}
 	}
 }