diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
index c86f230..7b902dd 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
@@ -93,13 +93,8 @@
}
@Override
- public BusConfig findLatestConfigSendToDevice(Long deviceId) {
- List configList = baseMapper.findConfigListSendToDevice(deviceId);
- if (ObjectUtil.isNotNull(configList) && !configList.isEmpty()) {
- return configList.get(0);
- }
-
- return null;
+ public List findLatestConfigSendToDevice(Long deviceId) {
+ return baseMapper.findConfigListSendToDevice(deviceId);
}
/**
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
index c86f230..7b902dd 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
@@ -93,13 +93,8 @@
}
@Override
- public BusConfig findLatestConfigSendToDevice(Long deviceId) {
- List configList = baseMapper.findConfigListSendToDevice(deviceId);
- if (ObjectUtil.isNotNull(configList) && !configList.isEmpty()) {
- return configList.get(0);
- }
-
- return null;
+ public List findLatestConfigSendToDevice(Long deviceId) {
+ return baseMapper.findConfigListSendToDevice(deviceId);
}
/**
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
new file mode 100644
index 0000000..845f39d
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
@@ -0,0 +1,35 @@
+package com.casic.missiles.service.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.casic.missiles.mapper.DeviceConfigMapper;
+import com.casic.missiles.model.DeviceConfig;
+import com.casic.missiles.service.IDeviceConfigService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务实现类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+@Service
+@RequiredArgsConstructor
+public class DeviceConfigServiceImpl extends ServiceImpl implements IDeviceConfigService {
+
+ @Override
+ public void saveOrUpdateByDeviceId(DeviceConfig deviceConfig) {
+ QueryWrapper wrapper = new QueryWrapper<>();
+ wrapper.eq("device_id", deviceConfig.getDeviceId());
+
+ // 先执行update 如果返回为0 则再执行insert
+ int count = baseMapper.update(deviceConfig, wrapper);
+ if (count == 0) {
+ baseMapper.insert(deviceConfig);
+ }
+ }
+}
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
index c86f230..7b902dd 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
@@ -93,13 +93,8 @@
}
@Override
- public BusConfig findLatestConfigSendToDevice(Long deviceId) {
- List configList = baseMapper.findConfigListSendToDevice(deviceId);
- if (ObjectUtil.isNotNull(configList) && !configList.isEmpty()) {
- return configList.get(0);
- }
-
- return null;
+ public List findLatestConfigSendToDevice(Long deviceId) {
+ return baseMapper.findConfigListSendToDevice(deviceId);
}
/**
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
new file mode 100644
index 0000000..845f39d
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
@@ -0,0 +1,35 @@
+package com.casic.missiles.service.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.casic.missiles.mapper.DeviceConfigMapper;
+import com.casic.missiles.model.DeviceConfig;
+import com.casic.missiles.service.IDeviceConfigService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务实现类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+@Service
+@RequiredArgsConstructor
+public class DeviceConfigServiceImpl extends ServiceImpl implements IDeviceConfigService {
+
+ @Override
+ public void saveOrUpdateByDeviceId(DeviceConfig deviceConfig) {
+ QueryWrapper wrapper = new QueryWrapper<>();
+ wrapper.eq("device_id", deviceConfig.getDeviceId());
+
+ // 先执行update 如果返回为0 则再执行insert
+ int count = baseMapper.update(deviceConfig, wrapper);
+ if (count == 0) {
+ baseMapper.insert(deviceConfig);
+ }
+ }
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
index 1a5c8bf..bd5e566 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
@@ -121,6 +121,15 @@
}
@Override
+ public void updateDeviceStatus(String deviceCode, Integer status) {
+ Device device = getDeviceByDeviceCode(deviceCode);
+ if (ObjectUtil.isNotNull(device)) {
+ device.setStatus(status);
+ baseMapper.updateById(device);
+ }
+ }
+
+ @Override
public ReturnDTO deleteDevice(List ids) {
if (this.baseMapper.deleteBatchIds(ids) > 0) {
return ReturnUtil.success();
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
index c86f230..7b902dd 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
@@ -93,13 +93,8 @@
}
@Override
- public BusConfig findLatestConfigSendToDevice(Long deviceId) {
- List configList = baseMapper.findConfigListSendToDevice(deviceId);
- if (ObjectUtil.isNotNull(configList) && !configList.isEmpty()) {
- return configList.get(0);
- }
-
- return null;
+ public List findLatestConfigSendToDevice(Long deviceId) {
+ return baseMapper.findConfigListSendToDevice(deviceId);
}
/**
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
new file mode 100644
index 0000000..845f39d
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
@@ -0,0 +1,35 @@
+package com.casic.missiles.service.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.casic.missiles.mapper.DeviceConfigMapper;
+import com.casic.missiles.model.DeviceConfig;
+import com.casic.missiles.service.IDeviceConfigService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务实现类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+@Service
+@RequiredArgsConstructor
+public class DeviceConfigServiceImpl extends ServiceImpl implements IDeviceConfigService {
+
+ @Override
+ public void saveOrUpdateByDeviceId(DeviceConfig deviceConfig) {
+ QueryWrapper wrapper = new QueryWrapper<>();
+ wrapper.eq("device_id", deviceConfig.getDeviceId());
+
+ // 先执行update 如果返回为0 则再执行insert
+ int count = baseMapper.update(deviceConfig, wrapper);
+ if (count == 0) {
+ baseMapper.insert(deviceConfig);
+ }
+ }
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
index 1a5c8bf..bd5e566 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
@@ -121,6 +121,15 @@
}
@Override
+ public void updateDeviceStatus(String deviceCode, Integer status) {
+ Device device = getDeviceByDeviceCode(deviceCode);
+ if (ObjectUtil.isNotNull(device)) {
+ device.setStatus(status);
+ baseMapper.updateById(device);
+ }
+ }
+
+ @Override
public ReturnDTO deleteDevice(List ids) {
if (this.baseMapper.deleteBatchIds(ids) > 0) {
return ReturnUtil.success();
diff --git a/casic-iot-web/src/main/resources/config/application-dev.yml b/casic-iot-web/src/main/resources/config/application-dev.yml
index ec165dc..5199412 100644
--- a/casic-iot-web/src/main/resources/config/application-dev.yml
+++ b/casic-iot-web/src/main/resources/config/application-dev.yml
@@ -6,16 +6,16 @@
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://111.198.10.15:11336/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
username: root
- password: Casic203
+ password: 123456
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master
strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
datasource:
master:
driver-class-name: com.mysql.cj.jdbc.Driver
- url: jdbc:mysql://111.198.10.15:11336/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
+ url: jdbc:mysql://127.0.0.1:3306/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
username: root
- password: Casic203
+ password: 123456
# use-ping-method: false
sensorhub: #实现动态的双库操作,暂时不想合并
driver-class-name: com.mysql.cj.jdbc.Driver
diff --git a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
index 8ed6f2f..098f9f7 100644
--- a/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
+++ b/casic-iot-common/src/main/java/com/casic/missiles/util/WebSocket.java
@@ -47,7 +47,7 @@
@OnMessage
public void onMessage(String message) {
- log.info("【websocket消息】收到客户端消息:" + message);
+ log.debug("【websocket消息】收到客户端消息:" + message);
// System.out.println("【websocket消息】收到客户端消息:" + message);
}
diff --git a/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
new file mode 100644
index 0000000..17a1764
--- /dev/null
+++ b/casic-iot-dao/src/main/java/com/casic/missiles/mapper/DeviceConfigMapper.java
@@ -0,0 +1,16 @@
+package com.casic.missiles.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 Mapper 接口
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface DeviceConfigMapper extends BaseMapper {
+
+}
diff --git a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
index deb5d9e..b3534c2 100644
--- a/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/BusConfigMapper.xml
@@ -81,11 +81,11 @@
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
index 7f0a356..4f11813 100644
--- a/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceBizDataMapper.xml
@@ -5,7 +5,7 @@
-
+
diff --git a/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
new file mode 100644
index 0000000..13f3913
--- /dev/null
+++ b/casic-iot-dao/src/main/resources/mapper/DeviceConfigMapper.xml
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${paramStr}
+
+
+
+ TO_TIMESTAMP(${paramStr},'yyyy-MM-dd hh24:mi:ss')::timestamp without time zone
+
+
+
+ TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi')
+
+
+
+
+ device_id, devCode, config_json, logtime, frame_log_id
+
+
+
diff --git a/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
new file mode 100644
index 0000000..b508cef
--- /dev/null
+++ b/casic-iot-model/src/main/java/com/casic/missiles/model/DeviceConfig.java
@@ -0,0 +1,66 @@
+package com.casic.missiles.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.casic.missiles.annotation.DictCodeField;
+import com.casic.missiles.enums.DictCodeEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表
+ *
+ *
+ * @author cz
+ * @since 2023-11-22
+ */
+@Data
+@TableName("device_config")
+public class DeviceConfig implements Serializable, DictCodeEnum {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 设备编号
+ */
+ @TableField("device_id")
+ @NotNull
+ @ApiModelProperty(value = "设备id", dataType = "Long")
+ private Long deviceId;
+
+ /**
+ * 设备编号
+ */
+ @TableField("devCode")
+ @NotNull
+ @ApiModelProperty(value = "设备编号", dataType = "String")
+ private String devCode;
+
+ /**
+ * 下发配置内容
+ */
+ @TableField("config_json")
+ @ApiModelProperty(value = "{\"repeat\":\"重传次数\",\"lowerThreshold\":\"低报\",\"upperThreshold\":\"高报\",\"collectTime\":\"采集时间\",\"period\":\"上传周期\",\"ip\":\"\",\"port\":\"\"}", dataType = "String")
+ private String configJson;
+
+
+ @TableField("logtime")
+ @ApiModelProperty(value = "上传时间", dataType = "LocalDateTime")
+ private LocalDateTime logtime;
+
+ /**
+ * 编号
+ */
+ @TableField("frame_log_id")
+ private Long frameLogId;
+
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
index 06d131c..7fae695 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IBusConfigService.java
@@ -28,6 +28,6 @@
ReturnDTO deleteBusConfig(List ids);
BusConfig findLatestConfigToBeSend(Long deviceId);
- BusConfig findLatestConfigSendToDevice(Long deviceId);
+ List findLatestConfigSendToDevice(Long deviceId);
}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
new file mode 100644
index 0000000..8e8194f
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceConfigService.java
@@ -0,0 +1,17 @@
+package com.casic.missiles.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.casic.missiles.model.DeviceConfig;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+public interface IDeviceConfigService extends IService {
+
+ void saveOrUpdateByDeviceId(DeviceConfig deviceConfig);
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
index 619725a..04e38ee 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/IDeviceService.java
@@ -32,6 +32,7 @@
ReturnDTO updateDevice(Device deviceGroup);
void updateDeviceImei(String deviceCode, String imei, String iccid);
+ void updateDeviceStatus(String deviceCode, Integer status);
ReturnDTO deleteDevice(List ids);
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
index c86f230..7b902dd 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/BusConfigServiceImpl.java
@@ -93,13 +93,8 @@
}
@Override
- public BusConfig findLatestConfigSendToDevice(Long deviceId) {
- List configList = baseMapper.findConfigListSendToDevice(deviceId);
- if (ObjectUtil.isNotNull(configList) && !configList.isEmpty()) {
- return configList.get(0);
- }
-
- return null;
+ public List findLatestConfigSendToDevice(Long deviceId) {
+ return baseMapper.findConfigListSendToDevice(deviceId);
}
/**
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
new file mode 100644
index 0000000..845f39d
--- /dev/null
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceConfigServiceImpl.java
@@ -0,0 +1,35 @@
+package com.casic.missiles.service.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.casic.missiles.mapper.DeviceConfigMapper;
+import com.casic.missiles.model.DeviceConfig;
+import com.casic.missiles.service.IDeviceConfigService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 设备配置 设备下发配置所用表 服务实现类
+ *
+ *
+ * @author cz
+ * @since 2023-11-20
+ */
+@Service
+@RequiredArgsConstructor
+public class DeviceConfigServiceImpl extends ServiceImpl implements IDeviceConfigService {
+
+ @Override
+ public void saveOrUpdateByDeviceId(DeviceConfig deviceConfig) {
+ QueryWrapper wrapper = new QueryWrapper<>();
+ wrapper.eq("device_id", deviceConfig.getDeviceId());
+
+ // 先执行update 如果返回为0 则再执行insert
+ int count = baseMapper.update(deviceConfig, wrapper);
+ if (count == 0) {
+ baseMapper.insert(deviceConfig);
+ }
+ }
+}
diff --git a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
index 1a5c8bf..bd5e566 100644
--- a/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
+++ b/casic-iot-service/src/main/java/com/casic/missiles/service/impl/DeviceServiceImpl.java
@@ -121,6 +121,15 @@
}
@Override
+ public void updateDeviceStatus(String deviceCode, Integer status) {
+ Device device = getDeviceByDeviceCode(deviceCode);
+ if (ObjectUtil.isNotNull(device)) {
+ device.setStatus(status);
+ baseMapper.updateById(device);
+ }
+ }
+
+ @Override
public ReturnDTO deleteDevice(List ids) {
if (this.baseMapper.deleteBatchIds(ids) > 0) {
return ReturnUtil.success();
diff --git a/casic-iot-web/src/main/resources/config/application-dev.yml b/casic-iot-web/src/main/resources/config/application-dev.yml
index ec165dc..5199412 100644
--- a/casic-iot-web/src/main/resources/config/application-dev.yml
+++ b/casic-iot-web/src/main/resources/config/application-dev.yml
@@ -6,16 +6,16 @@
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://111.198.10.15:11336/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
username: root
- password: Casic203
+ password: 123456
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master
strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
datasource:
master:
driver-class-name: com.mysql.cj.jdbc.Driver
- url: jdbc:mysql://111.198.10.15:11336/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
+ url: jdbc:mysql://127.0.0.1:3306/casic_iot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&&allowMultiQueries=true
username: root
- password: Casic203
+ password: 123456
# use-ping-method: false
sensorhub: #实现动态的双库操作,暂时不想合并
driver-class-name: com.mysql.cj.jdbc.Driver
diff --git a/sensorhub-core/src/main/java/com/casic/missiles/service/impl/GeneralServiceImpl.java b/sensorhub-core/src/main/java/com/casic/missiles/service/impl/GeneralServiceImpl.java
index 29a6594..0839e26 100644
--- a/sensorhub-core/src/main/java/com/casic/missiles/service/impl/GeneralServiceImpl.java
+++ b/sensorhub-core/src/main/java/com/casic/missiles/service/impl/GeneralServiceImpl.java
@@ -3,11 +3,16 @@
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import com.casic.missiles.enums.BirmmDeviceTypeEnums;
import com.casic.missiles.enums.BirmmFrameAttributeEnums;
import com.casic.missiles.enums.BirmmOperationTypeEnums;
-import com.casic.missiles.frame.base.BirmmBaseFrame;
import com.casic.missiles.frame.BirmmFrameBuilderFactory;
+import com.casic.missiles.frame.base.BirmmBaseFrame;
+import com.casic.missiles.frame.base.BirmmBaseTag;
+import com.casic.missiles.frame.base.BirmmSetResponseFrame;
+import com.casic.missiles.frame.base.BirmmStartupRequestFrame;
import com.casic.missiles.frame.tag.biz.SensorStartupTag;
import com.casic.missiles.model.*;
import com.casic.missiles.parser.BirmmProtocolParser;
@@ -17,7 +22,6 @@
import com.casic.missiles.service.*;
import com.casic.missiles.util.SnowflakeUtil;
import com.casic.missiles.util.SpringContextUtil;
-import com.casic.missiles.frame.base.BirmmBaseTag;
import lombok.extern.slf4j.Slf4j;
import org.apache.tomcat.util.buf.HexUtils;
import org.springframework.stereotype.Service;
@@ -47,6 +51,9 @@
IBusConfigService configService;
@Resource
+ IDeviceConfigService devConfigService;
+
+ @Resource
IDeviceImeiIccidService imeiService;
@Resource
@@ -148,6 +155,10 @@
@Override
public void bizDataAfterAction(BirmmBaseFrame baseFrame, Long frameLogId) {
+ // 更新设备状态
+ deviceService.updateDeviceStatus(baseFrame.getDevCode(), 1);
+
+ // 根据操作类型 执行业务后处理
BirmmOperationTypeEnums operationType = BirmmOperationTypeEnums.toType(baseFrame.getOperationType());
switch (operationType) {
case UP_TRAP_REQUEST:
@@ -157,7 +168,7 @@
case UP_STARTUP_REQUEST:
// 上报三码数据后处理 保存三码记录 更新device表的对应字段
- saveSensorDevCodeAndImei(baseFrame, frameLogId);
+ saveSensorDevCodeAndImei((BirmmStartupRequestFrame) baseFrame, frameLogId);
break;
case UP_ONLINE_REQUEST:
@@ -170,7 +181,7 @@
case UP_SET_RESPONSE:
// 设置响应消息后处理 更新config表对应状态
- updateConfigStatus(baseFrame);
+ updateConfigStatus((BirmmSetResponseFrame) baseFrame, frameLogId);
break;
default:
@@ -178,55 +189,87 @@
}
}
- private void saveBizData(BirmmBaseFrame baseFrame, Long frameLogId) {
- List bizDataList = baseFrame.convertToBizDataList();
+ private void saveBizData(BirmmBaseFrame trapRequest, Long frameLogId) {
+ List bizDataList = trapRequest.convertToBizDataList();
for (DeviceBizData bizData : bizDataList) {
// 设置其他的属性
bizData.setId(new SnowflakeUtil().nextId());
bizData.setFrameLogId(frameLogId); // 关联日志记录id
- bizData.setDevcode(baseFrame.getDevCode());
- bizData.setDeviceType(Integer.valueOf(baseFrame.getDeviceType()));
- bizData.setLogtime(baseFrame.getLogTime());
+ bizData.setDevcode(trapRequest.getDevCode());
+ bizData.setDeviceType(Integer.valueOf(trapRequest.getDeviceType()));
+ bizData.setLogtime(trapRequest.getLogTime());
}
// 批量保存
bizDataService.saveBatch(bizDataList);
}
- private void saveSensorDevCodeAndImei(BirmmBaseFrame baseFrame, Long frameLogId) {
- List imeiTags = baseFrame.getTagList().get(SensorStartupTag.class.getSimpleName());
+ private void saveSensorDevCodeAndImei(BirmmStartupRequestFrame startupRequest, Long frameLogId) {
+ List imeiTags = startupRequest.getTagList().get(SensorStartupTag.class.getSimpleName());
if (ObjectUtil.isNotNull(imeiTags) && !imeiTags.isEmpty()) {
SensorStartupTag imeiTag = (SensorStartupTag) imeiTags.get(0);
- deviceService.updateDeviceImei(baseFrame.getDevCode(), imeiTag.getImei(), imeiTag.getIccid());
+ deviceService.updateDeviceImei(startupRequest.getDevCode(), imeiTag.getImei(), imeiTag.getIccid());
DeviceImeiIccid imeiIccid = new DeviceImeiIccid();
- imeiIccid.setDevcode(baseFrame.getDevCode());
+ imeiIccid.setDevcode(startupRequest.getDevCode());
imeiIccid.setImei(imeiTag.getImei());
imeiIccid.setIccid(imeiTag.getIccid());
- imeiIccid.setLogtime(baseFrame.getLogTime());
+ imeiIccid.setLogtime(startupRequest.getLogTime());
imeiIccid.setFrameLogId(frameLogId);
imeiService.save(imeiIccid);
}
}
- private void updateConfigStatus(BirmmBaseFrame birmmBaseFrame) {
+ private void updateConfigStatus(BirmmSetResponseFrame setResponse, Long frameLogId) {
// 查询数据库找到待下发的内容
- Device device = deviceService.getDeviceByDeviceCode(birmmBaseFrame.getDevCode());
+ Device device = deviceService.getDeviceByDeviceCode(setResponse.getDevCode());
if (ObjectUtil.isNotNull(device)) {
- BusConfig latestConfig = configService.findLatestConfigSendToDevice(device.getId());
- if (ObjectUtil.isNotNull(latestConfig)) {
- // TODO-LIST
- // 需要检查返回的配置项是否与下发的值一致
+ // 更新设备当前配置项表的项目
+ DeviceConfig newDevConfig = new DeviceConfig();
+ newDevConfig.setDeviceId(device.getId());
+ newDevConfig.setDevCode(device.getDevcode());
+ newDevConfig.setFrameLogId(frameLogId);
+ newDevConfig.setLogtime(setResponse.getLogTime());
+ newDevConfig.setConfigJson(setResponse.getConfigJSON().toJSONString());
+ devConfigService.saveOrUpdateByDeviceId(newDevConfig);
+ // 更新下发表的状态
+ // 查询所有已下发等待响应的下发配置记录
+ List latestConfigList = configService.findLatestConfigSendToDevice(device.getId());
+ for (BusConfig config : latestConfigList) {
+ // 转换成Map来进行匹配
+ List