fix(message):Message服务消息转发遥信添加dataType字段

amos-boot-utils/amos-boot-utils-message/src/main/java/com/yeejoin/amos/message/kafka/KafkaConsumerService.java

@@ -58,6 +58,7 @@ public class KafkaConsumerService {
                 JSONObject data = messageObj.getJSONObject("body");
                 if (data.size() == 0){
                     data = messageObj;
+                    data.put("datatype","state");
                 }
                 log.info("接收到Roma消息对象: {}", data);
                 emqKeeper.getMqttClient().publish(topic, data.toString().getBytes(StandardCharsets.UTF_8), 0, false);