diff --git a/pom.xml b/pom.xml
index 407524fe..7ce73d73 100644
--- a/pom.xml
+++ b/pom.xml
@@ -89,12 +89,12 @@
prod
prod
- 127.0.0.1:8848
+ 53.16.17.13:8848
DEFAULT_GROUP
DEFAULT_GROUP
nacos
nacos
- 127.0.0.1:4560
+ 53.16.17.13:4560
diff --git a/stwzhj-api/stwzhj-api-data2es/src/main/java/org/dromara/data2es/api/domain/RemoteGpsInfo.java b/stwzhj-api/stwzhj-api-data2es/src/main/java/org/dromara/data2es/api/domain/RemoteGpsInfo.java
index 598c0a2f..a1ed9279 100644
--- a/stwzhj-api/stwzhj-api-data2es/src/main/java/org/dromara/data2es/api/domain/RemoteGpsInfo.java
+++ b/stwzhj-api/stwzhj-api-data2es/src/main/java/org/dromara/data2es/api/domain/RemoteGpsInfo.java
@@ -22,8 +22,8 @@ public class RemoteGpsInfo implements Serializable {
* 类型
*/
private String deviceType;
- private String lat;
- private String lng;
+ private String latitude;
+ private String longitude;
//方向
private String orientation;
//高程
diff --git a/stwzhj-api/stwzhj-api-system/src/main/java/org/dromara/system/api/domain/bo/RemoteDeviceBo.java b/stwzhj-api/stwzhj-api-system/src/main/java/org/dromara/system/api/domain/bo/RemoteDeviceBo.java
index eead2ac0..2a49aa1e 100644
--- a/stwzhj-api/stwzhj-api-system/src/main/java/org/dromara/system/api/domain/bo/RemoteDeviceBo.java
+++ b/stwzhj-api/stwzhj-api-system/src/main/java/org/dromara/system/api/domain/bo/RemoteDeviceBo.java
@@ -83,6 +83,10 @@ public class RemoteDeviceBo implements Serializable {
*/
private String remark1;
+ private String createTime;
+
+ private String updateTime;
+
/**
* 备注字段2
*/
diff --git a/stwzhj-common/stwzhj-common-redis/src/main/java/org/dromara/common/redis/utils/RedisUtils.java b/stwzhj-common/stwzhj-common-redis/src/main/java/org/dromara/common/redis/utils/RedisUtils.java
index bff861b8..30d6b5c5 100644
--- a/stwzhj-common/stwzhj-common-redis/src/main/java/org/dromara/common/redis/utils/RedisUtils.java
+++ b/stwzhj-common/stwzhj-common-redis/src/main/java/org/dromara/common/redis/utils/RedisUtils.java
@@ -573,6 +573,73 @@ public class RedisUtils {
System.out.println("redis:"+list);
}
+ /**
+ * 批量插入数据，并为整个 RMap 设置过期时间
+ *
+ * @param data 需要批量插入的数据
+ * @param timeout 设置的过期时间
+ * @param timeUnit 过期时间的单位
+ */
+ public static void batchPutWithExpire(Map data, long timeout, TimeUnit timeUnit) {
+ // 创建 RBatch 实例
+ RBatch batch = CLIENT.createBatch();
+
+ // 获取 RMapAsync 对象
+ RMapAsync mapAsync = batch.getMap("myMap");
+
+ // 批量操作：将多个数据添加到 map 中
+ for (Map.Entry entry : data.entrySet()) {
+ mapAsync.putAsync(entry.getKey(), entry.getValue());
+ }
+
+ // 执行批量操作
+ batch.execute();
+
+ // 获取同步的 RMap 对象并设置过期时间
+ RMap mapSync = CLIENT.getMap("myMap");
+ mapSync.expire(timeout, timeUnit);
+ }
+
+ /**
+ * 批量插入数据
+ *
+ * @param data 需要批量插入的数据
+ */
+ public static void batchPut(Map data) {
+ // 创建 RBatch 实例
+ RBatch batch = CLIENT.createBatch();
+
+ // 获取 RMapAsync 对象
+ RMapAsync mapAsync = batch.getMap("myMap");
+
+ // 批量操作：将多个数据添加到 map 中
+ for (Map.Entry entry : data.entrySet()) {
+ mapAsync.putAsync(entry.getKey(), entry.getValue());
+ }
+
+ // 执行批量操作
+ batch.execute();
+
+ }
+
+ /**
+ * 根据 key 获取指定的值
+ *
+ * @param key 要查询的 key
+ * @return 查询到的值
+ */
+ public static JSONObject getData(String key) {
+ // 获取同步的 RMap 对象
+ RMap map = CLIENT.getMap("myMap");
+
+ // 根据 key 获取数据
+ Object value = map.get(key);
+ if (null == value){
+ return null;
+ }
+ return JSONUtil.parseObj(value.toString());
+ }
+
/*
* 模糊查询
* */
@@ -596,12 +663,41 @@ public class RedisUtils {
return list;
}
+ /**
+ * 根据模式（例如前缀）模糊匹配 Redis 中的 keys，并获取每个 key 的值
+ *
+ * @param pattern 模糊匹配的模式，例如 "user:*"
+ * @return 匹配到的 key 和 value 对
+ */
+ public Map getMatchingKeysAndValues(String pattern) {
+ RKeys rKeys = CLIENT.getKeys();
+ Iterable keysIterable = rKeys.getKeysByPattern(pattern); // 获取匹配的 key
+
+ // 获取匹配的键值对
+ RMap map = CLIENT.getMap("myMap");
+ Map result = new java.util.HashMap<>();
+
+ List list = new ArrayList<>();
+// RBatch batch = CLIENT.createBatch();
+ // 批量获取这些key的值
+ for (String key : keysIterable) {
+ String value = map.get(key); // 获取每个 key 对应的 value
+ JSONObject jsonObject = JSONUtil.parseObj(value);
+ list.add(jsonObject);
+ }
+
+ return result;
+ }
+
/*
* 根据key获取RBucket值
* */
public static JSONObject getBucket(String key){
RBucket