Commit 10fb8b44 authored by 刘林's avatar 刘林

fix(equip):修改入库influxdb tagsMap字段

parent 5d9fc573
...@@ -96,13 +96,13 @@ public class KafkaConsumerService { ...@@ -96,13 +96,13 @@ public class KafkaConsumerService {
String valueLabel = valueTranslate(value, equipmentSpeIndex.getValueEnum()); String valueLabel = valueTranslate(value, equipmentSpeIndex.getValueEnum());
fieldsMap.put("traceId", traceId); fieldsMap.put("traceId", traceId);
fieldsMap.put("address", indexAddress); tagsMap.put("address", indexAddress);
fieldsMap.put("value", value); fieldsMap.put("value", value);
fieldsMap.put("valueLabel", valueLabel.equals("") ? value : valueLabel); fieldsMap.put("valueLabel", valueLabel.equals("") ? value : valueLabel);
fieldsMap.put("gatewayId", gatewayId); tagsMap.put("gatewayId", gatewayId);
fieldsMap.put("dataType", dataType); tagsMap.put("dataType", dataType);
fieldsMap.put("isAlarm", equipmentSpeIndex.getIsAlarm()); tagsMap.put("isAlarm", String.valueOf(equipmentSpeIndex.getIsAlarm()));
fieldsMap.put("equipmentSpecificName", equipmentSpeIndex.getEquipmentSpecificName()); tagsMap.put("equipmentSpecificName", equipmentSpeIndex.getEquipmentSpecificName());
fieldsMap.put("equipmentIndexName", equipmentSpeIndex.getEquipmentIndexName()); fieldsMap.put("equipmentIndexName", equipmentSpeIndex.getEquipmentIndexName());
fieldsMap.put("unit", equipmentSpeIndex.getUnitName()); fieldsMap.put("unit", equipmentSpeIndex.getUnitName());
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment