From 614ddceebcdd940420540aa430900b31a891c27f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=85=BE?= <3467447354@qq.com> Date: Wed, 2 Oct 2024 09:43:00 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=BA=86IoTDB=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E7=9A=84=E5=AE=9E=E4=BD=93=E7=B1=BB=E3=80=81=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E5=92=8C=E6=B3=A8=E8=A7=A3=E3=80=82=E8=BF=99=E4=BA=9B?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=8F=AF=E8=83=BD=E5=B7=B2=E7=BB=8F=E7=A7=BB?= =?UTF-8?q?=E5=8A=A8=E5=88=B0=E5=8F=A6=E4=B8=80=E4=B8=AA=E4=BD=8D=E7=BD=AE?= =?UTF-8?q?=E6=88=96=E8=80=85=E4=B8=8D=E5=86=8D=E9=9C=80=E8=A6=81=E8=BF=99?= =?UTF-8?q?=E4=BA=9B=E7=BB=93=E6=9E=84=E3=80=82=E5=8F=97=E5=BD=B1=E5=93=8D?= =?UTF-8?q?=E7=9A=84=E4=BB=A3=E7=A0=81=E5=8C=85=E6=8B=AC=EF=BC=9A=20-=20?= =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=BA=86`com.muyu.carData.domain.IoTDBRecord?= =?UTF-8?q?`=E5=AE=9E=E4=BD=93=E7=B1=BB=EF=BC=8C=E5=AE=83=E7=94=A8?= =?UTF-8?q?=E4=BA=8E=E5=AE=9A=E4=B9=89IoT=E6=95=B0=E6=8D=AE=E5=BA=93?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E3=80=82=20-=20=E5=88=A0=E9=99=A4=E4=BA=86`c?= =?UTF-8?q?om.muyu.carData.interfaces.IoTDBRecordable`=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=EF=BC=8C=E5=AE=83=E5=AE=9A=E4=B9=89=E4=BA=86=E5=A6=82=E4=BD=95?= =?UTF-8?q?=E5=B0=86=E5=AF=B9=E8=B1=A1=E8=BD=AC=E6=8D=A2=E4=B8=BAIoTDBReco?= =?UTF-8?q?rd=E3=80=82=20-=20=E5=88=A0=E9=99=A4=E4=BA=86`com.muyu.carData.?= =?UTF-8?q?annotation.IoTTableName`=E6=B3=A8=E8=A7=A3=EF=BC=8C=E5=AE=83?= =?UTF-8?q?=E7=94=A8=E4=BA=8E=E6=A0=87=E8=AE=B0=E7=B1=BB=E5=AF=B9=E5=BA=94?= =?UTF-8?q?IoT=E6=95=B0=E6=8D=AE=E5=BA=93=E8=A1=A8=E7=9A=84=E5=90=8D?= =?UTF-8?q?=E7=A7=B0=E3=80=82=20-=20=E5=88=A0=E9=99=A4=E4=BA=86`com.muyu.c?= =?UTF-8?q?arData.constract.IoTDBTableParam`=E7=B1=BB=EF=BC=8C=E5=AE=83?= =?UTF-8?q?=E5=8C=85=E5=90=ABIoT=E6=95=B0=E6=8D=AE=E5=BA=93=E8=A1=A8?= =?UTF-8?q?=E5=8F=82=E6=95=B0=E7=9A=84=E5=B8=B8=E9=87=8F=E5=AE=9A=E4=B9=89?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu/carData/annotation/IoTTableName.java | 18 ------- .../carData/constract/IoTDBTableParam.java | 13 ----- .../com/muyu/carData/domain/IoTDBRecord.java | 47 ---------------- .../carData/interfaces/IoTDBRecordable.java | 53 ------------------- 4 files changed, 131 deletions(-) delete mode 100644 cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/annotation/IoTTableName.java delete mode 100644 cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/constract/IoTDBTableParam.java delete mode 100644 cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/domain/IoTDBRecord.java delete mode 100644 cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/interfaces/IoTDBRecordable.java diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/annotation/IoTTableName.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/annotation/IoTTableName.java deleted file mode 100644 index 64b4a1f..0000000 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/annotation/IoTTableName.java +++ /dev/null @@ -1,18 +0,0 @@ -package com.muyu.carData.annotation; - -import java.lang.annotation.*; - -/** - * @Author：张腾 - * @Package：com.muyu.carData.annotation - * @Project：cloud-server-8 - * @name：IoTTableName - * @Date：2024/9/27 19:29 - */ -@Documented -@Retention(RetentionPolicy.RUNTIME) -@Target({ElementType.TYPE, ElementType.ANNOTATION_TYPE}) -public @interface IoTTableName { - - String value() default ""; -} diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/constract/IoTDBTableParam.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/constract/IoTDBTableParam.java deleted file mode 100644 index e03e8ed..0000000 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/constract/IoTDBTableParam.java +++ /dev/null @@ -1,13 +0,0 @@ -package com.muyu.carData.constract; - -/** - * @Author：张腾 - * @Package：com.muyu.carData.constract - * @Project：cloud-server-8 - * @name：IoTDBTableParam - * @Date：2024/9/27 20:02 - */ -public class IoTDBTableParam { - - public static final String SYSLOG_IOT_TABLE = "student"; -} diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/domain/IoTDBRecord.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/domain/IoTDBRecord.java deleted file mode 100644 index 00af674..0000000 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/domain/IoTDBRecord.java +++ /dev/null @@ -1,47 +0,0 @@ -package com.muyu.carData.domain; - -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; - -import java.util.List; - -/** - * @Author：张腾 - * @Package：com.muyu.carData.domain - * @Project：cloud-server-8 - * @name：IoTDBRecord - * @Date：2024/9/27 19:25 - */ -@Data -@Builder -@AllArgsConstructor -@NoArgsConstructor -public class IoTDBRecord { - - /** - * 节点路径 - */ - private String deviceId; - - /** - * 时间戳 - */ - private long time = System.currentTimeMillis(); - - /** - * 属性 - */ - private List measurementList; - - /** - * 属性值 - */ - private List valueList; - - /** - * 数据类型 - */ - private List typeList; -} diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/interfaces/IoTDBRecordable.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/interfaces/IoTDBRecordable.java deleted file mode 100644 index 1a1500c..0000000 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/interfaces/IoTDBRecordable.java +++ /dev/null @@ -1,53 +0,0 @@ -package com.muyu.carData.interfaces; - -import com.muyu.carData.annotation.IoTTableName; -import com.muyu.carData.domain.IoTDBRecord; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.lang.reflect.Field; -import java.lang.reflect.Method; -import java.util.ArrayList; - -/** - * @Author：张腾 - * @Package：com.muyu.carData.interfaces - * @Project：cloud-server-8 - * @name：IoTDBRecordable - * @Date：2024/9/27 19:22 - * iot基类 - */ -public interface IoTDBRecordable { - - Logger logger = LoggerFactory.getLogger(IoTDBRecordable.class); - - /** - * 数据载入方法 - * @return Record - */ - default IoTDBRecord toRecord() throws Exception { - IoTDBRecord ioTDBRecord = new IoTDBRecord(); - Object getIoTDBTime = this.getClass().getMethod("getIoTDBTime").invoke(this); - if (null != getIoTDBTime){ - ioTDBRecord.setTime((Long) getIoTDBTime); - } - Class aClass = this.getClass(); - IoTTableName name = this.getClass().getAnnotation(IoTTableName.class); - ioTDBRecord.setDeviceId(name.value()); - Field[] declaredFields = aClass.getDeclaredFields(); - ArrayList measurements = new ArrayList<>(); - ArrayList records = new ArrayList<>(); - ArrayList types = new ArrayList<>(); - for (Field declaredField : declaredFields) { - measurements.add(declaredField.getName()); - String methodNamePro = declaredField.getName().substring(0, 1).toUpperCase() + declaredField.getName().substring(1); - Method methodName = this.getClass().getMethod("get" + methodNamePro); - records.add(methodName.invoke(this)); - types.add(methodName.getReturnType().getName()); - } - ioTDBRecord.setMeasurementList(measurements); - ioTDBRecord.setValueList(records); - ioTDBRecord.setTypeList(types); - return ioTDBRecord; - } -}