添加测试mqtt消费者

device-api-service/src/main/java/com/xy/consumer/TestUpConsumer.java

@@ -22,7 +22,8 @@ public class TestUpConsumer implements MqttConsumer {
         log.info("测试数据：{}", payload);
         JSONObject jsonObject = JSONUtil.parseObj(payload);
         String deviceId = jsonObject.getStr("deviceId");
-        mqttProducer.sendToMqtt(payload, String.format("%s-test-down", deviceId));
+        jsonObject.set("time", System.currentTimeMillis());
+        mqttProducer.sendToMqtt(jsonObject.toString(), String.format("%s-test-down", deviceId));
         return true;
     }
 }