test topic

pkg/protocol/topic.go

@@ -112,7 +112,7 @@ func parseLast(topics []string) (topicInfo *TopicInfo, err error) {
 
 func GetCommandTopic(deviceCode, productKey string) string {
 	topic := strings.Join([]string{TopicHeadThing, "down", "command", productKey, deviceCode}, "/")
-	fmt.Printf("topic:%s", topic)
+	fmt.Printf("topic:%s\r\n", topic)
 	return topic
 }
 

services/emqx-agent/agent.go

@@ -236,7 +236,7 @@ func (a *Agent) SendCommand(args rpcs.ArgsSendCommand, reply *rpcs.ReplySendComm
 	if err != nil {
 		return err
 	}
-	return a.client.PublishToMsgToDev(protocol.GetCommandTopic(args.DeviceId, product.RecordId), msg)
+	return a.client.PublishToMsgToDev(protocol.GetCommandTopic(args.DeviceId, product.ProductKey), msg)
 }
 
 // GetStatus rpc 获取设备状态