| 提交 | 用户 | 时间 | ||
| a6de49 | 1 | package com.iailab.module.data.point.collection.utils; |
| H | 2 | |
| 3 | import com.iailab.module.data.common.enums.DataTypeEnum; | |
| 4 | import com.iailab.module.data.point.dto.DaPointDTO; | |
| 5 | import com.iailab.module.data.influxdb.pojo.*; | |
| 6 | ||
| 7 | /** | |
| 8 | * @author PanZhibao | |
| 9 | * @Description | |
| 10 | * @createTime 2023年05月08日 13:34:00 | |
| 11 | */ | |
| 12 | public class GenInfluxPointValueUtils { | |
| 13 | ||
| 14 | public static InfluxPointValuePOJO getByPoint(DaPointDTO dto){ | |
| 15 | if (DataTypeEnum.FLOAT.getCode().equals(dto.getDataType())) { | |
| 16 | InfluxPointValuePOJO pojo = new InfluxPointValueSimPOJO(); | |
| 17 | pojo.setPoint(dto.getPointNo()); | |
| 18 | if (dto.getDefaultValue() != null) { | |
| 19 | ((InfluxPointValueSimPOJO) pojo).setValue(dto.getDefaultValue().doubleValue()); | |
| 20 | } | |
| 21 | return pojo; | |
| 22 | } else if (DataTypeEnum.INT.getCode().equals(dto.getDataType())) { | |
| 23 | InfluxPointValuePOJO pojo = new InfluxPointValueDigPOJO(); | |
| 24 | pojo.setPoint(dto.getPointNo()); | |
| 25 | if (dto.getDefaultValue() != null) { | |
| 26 | ((InfluxPointValueDigPOJO) pojo).setValue(dto.getDefaultValue().intValue()); | |
| 27 | } | |
| 28 | return pojo; | |
| 29 | } else if (DataTypeEnum.BOOLEAN.getCode().equals(dto.getDataType())) { | |
| 30 | return new InfluxPointValueDigPOJO(); | |
| 31 | } else { | |
| 32 | return new InfluxPointValueStrPOJO(); | |
| 33 | } | |
| 34 | } | |
| 35 | ||
| 36 | public static InfluxPointValuePOJO getByPoint(DaPointDTO dto, Object value){ | |
| 37 | if (DataTypeEnum.FLOAT.getCode().equals(dto.getDataType())) { | |
| 38 | InfluxPointValuePOJO pojo = new InfluxPointValueSimPOJO(); | |
| 39 | pojo.setPoint(dto.getPointNo()); | |
| 40 | if (dto.getDefaultValue() != null) { | |
| 41 | ((InfluxPointValueSimPOJO) pojo).setValue(dto.getDefaultValue().doubleValue()); | |
| 42 | } | |
| 43 | if (value != null) { | |
| 44 | ((InfluxPointValueSimPOJO) pojo).setValue(Double.parseDouble(value.toString())); | |
| 45 | } | |
| 46 | return pojo; | |
| 47 | } else if (DataTypeEnum.INT.getCode().equals(dto.getDataType())) { | |
| 48 | InfluxPointValuePOJO pojo = new InfluxPointValueDigPOJO(); | |
| 49 | pojo.setPoint(dto.getPointNo()); | |
| 50 | if (dto.getDefaultValue() != null) { | |
| 51 | ((InfluxPointValueDigPOJO) pojo).setValue(dto.getDefaultValue().intValue()); | |
| 52 | } | |
| 53 | if (value != null) { | |
| 54 | ((InfluxPointValueDigPOJO) pojo).setValue(Integer.parseInt(value.toString())); | |
| 55 | } | |
| 56 | return pojo; | |
| 57 | } else if (DataTypeEnum.BOOLEAN.getCode().equals(dto.getDataType().trim())) { | |
| 58 | InfluxPointValuePOJO pojo = new InfluxPointValueBoolPOJO(); | |
| 59 | pojo.setPoint(dto.getPointNo()); | |
| 60 | if (value != null) { | |
| 61 | ((InfluxPointValueBoolPOJO) pojo).setValue(Boolean.parseBoolean(value.toString())); | |
| 62 | } | |
| 63 | return pojo; | |
| 64 | } else { | |
| 65 | InfluxPointValuePOJO pojo = new InfluxPointValueStrPOJO(); | |
| 66 | if (value != null) { | |
| 67 | ((InfluxPointValueStrPOJO) pojo).setValue(value.toString()); | |
| 68 | } | |
| 69 | return new InfluxPointValueStrPOJO(); | |
| 70 | } | |
| 71 | } | |
| 72 | } | |
