| 提交 | 用户 | 时间 | ||
| a6de49 | 1 | package com.iailab.module.data.influxdb.common.utils; |
| H | 2 | |
| 3 | import com.iailab.module.data.common.enums.DataTypeEnum; | |
| 4 | import com.iailab.module.data.influxdb.common.enums.DataMeasurement; | |
| 5 | import com.influxdb.client.write.Point; | |
| 6 | ||
| 7 | /** | |
| 8 | * @author PanZhibao | |
| 9 | * @Description | |
| 10 | * @createTime 2023年05月08日 10:25:00 | |
| 11 | */ | |
| 12 | public class PointValueUtils { | |
| 13 | ||
| 14 | public static void addFileByPointType(Point point, String type, String value) { | |
| 15 | if (DataTypeEnum.FLOAT.getCode().equals(type)) { | |
| 16 | point.addField("value", Double.parseDouble(value)); | |
| 17 | } else if (DataTypeEnum.INT.getCode().equals(type)) { | |
| 18 | point.addField("value", Integer.parseInt(value)); | |
| 19 | } else if (DataTypeEnum.BOOLEAN.getCode().equals(type)) { | |
| 20 | point.addField("value", Boolean.parseBoolean(value)); | |
| 21 | } else { | |
| 22 | point.addField("value", value); | |
| 23 | } | |
| 24 | } | |
| 25 | ||
| 26 | public static String getMeasurement(String type) { | |
| 27 | if (DataTypeEnum.FLOAT.getCode().equals(type)) { | |
| 28 | return DataMeasurement.t_da_sim_value.name(); | |
| 29 | } else if (DataTypeEnum.INT.getCode().equals(type)) { | |
| 30 | return DataMeasurement.t_da_dig_value.name(); | |
| 31 | } else if (DataTypeEnum.BOOLEAN.getCode().equals(type)) { | |
| 32 | return DataMeasurement.t_da_bool_value.name(); | |
| 33 | } else { | |
| 34 | return DataMeasurement.t_da_str_value.name(); | |
| 35 | } | |
| 36 | } | |
| 37 | } | |
