更新

src/main/java/com/zswl/dataservice/domain/iot/IotDeviceData.java

@@ -0,0 +1,37 @@
+package com.zswl.dataservice.domain.iot;
+
+import com.zswl.dataservice.domain.base.SuperEntity;
+import com.zswl.dataservice.model.iot.IotAttribute;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.data.mongodb.core.mapping.DBRef;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+/**
+ * @author TRX
+ * @date 2024/7/15
+ */
+@Data
+@Document
+@NoArgsConstructor
+@AllArgsConstructor
+public class IotDeviceData extends SuperEntity {
+
+    @Schema(description = "关联的属性、事件、方法")
+    @DBRef(lazy = true)
+    private IotMain iotMain;
+
+    @Schema(description = "关联的设备")
+    private String deviceId;
+
+    @Schema(description = "所属分支code")
+    private String projectCode;
+
+    @Schema(description = "关联字段")
+    private IotAttribute iotAttribute;
+
+    @Schema(description = "对应的值")
+    private Object data;
+}

src/main/java/com/zswl/dataservice/domain/mqtt/OperationMessageResult.java

@@ -0,0 +1,68 @@
+package com.zswl.dataservice.domain.mqtt;
+
+import com.zswl.dataservice.domain.base.SuperEntity;
+import com.zswl.dataservice.domain.iot.IotMain;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.data.mongodb.core.mapping.DBRef;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+/**
+ * @author TRX
+ * @date 2024/7/15
+ */
+@Data
+@Document
+@NoArgsConstructor
+@AllArgsConstructor
+public class OperationMessageResult extends SuperEntity {
+
+    @Schema(description = "消息消息")
+    @DBRef(lazy = true)
+    private OperationMessage operationMessage;
+
+    @Schema(description = "关联的事件")
+    private IotMain iotMain;
+
+    //-------------------业务处理结果 start----------------
+
+    @Schema(description = "是否处理成功")
+    private Boolean isHandleSuccess;
+
+    @Schema(description = "业务结果数据")
+    private Object resultData;
+
+    @Schema(description = "处理结果")
+    private String handleMsg;
+
+    @Schema(description = "业务处理的bean")
+    private String beanName;
+
+    @Schema(description = "业务处理的方法")
+    private String methodName;
+
+    @Schema(description = "处理时间")
+    private Long handlerTime;
+
+    //--------------------返回数据 start（就是把结果发送给响应网关）-------------
+    @Schema(description = "是否响应成功")
+    private Boolean isResult = Boolean.FALSE;
+
+    @Schema(description = "返回的topic")
+    private String reTopic;
+
+    @Schema(description = "返回-处理时间")
+    private Long reTime;
+
+    @Schema(description = "返回-处理时间可阅读")
+    private String reTimeStr;
+
+    @Schema(description = "响应结果")
+    private String reMsg;
+
+    @Schema(description = "是否响应成功")
+    private Boolean reIsSuccess;
+
+}