Commit dbd8c2d0 by 赵剑炜

修改redis方法

parent 1b85e999
...@@ -28,12 +28,12 @@ public interface JYZBConstant { ...@@ -28,12 +28,12 @@ public interface JYZBConstant {
/** /**
* 缓存前缀 * 缓存前缀
*/ */
String JYZB_CACHE_PREFIX = "jyzb:"; String JYZB_CACHE_PREFIX = "msg:";
/** /**
* 温度前缀 * 温度前缀
*/ */
String JYZB_TEMP_PREFIX = "temp"; String JYZB_TEMP_PREFIX = "temp:";
String JYZB_JWT_KEY = "JWT"; String JYZB_JWT_KEY = "JWT";
} }
...@@ -6,13 +6,15 @@ import com.junmp.v2.cache.AbstractRedisCache; ...@@ -6,13 +6,15 @@ import com.junmp.v2.cache.AbstractRedisCache;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
@Component //@Component
public class TemperatureRedisCache extends AbstractRedisCache<Object> { public class TemperatureRedisCache extends AbstractRedisCache<Object> {
public TemperatureRedisCache(RedisTemplate<String, Object> redisTemplate) { public TemperatureRedisCache(RedisTemplate<String, Object> redisTemplate) {
super(redisTemplate); super(redisTemplate);
// super(redisTemplate);
} }
@Override @Override
...@@ -21,21 +23,21 @@ public class TemperatureRedisCache extends AbstractRedisCache<Object> { ...@@ -21,21 +23,21 @@ public class TemperatureRedisCache extends AbstractRedisCache<Object> {
} }
public void addTemperatureHumidity(String warehouseId,String warehouseName,long timestamp, double humidity, double temperature) { public void addTemperatureHumidity(String warehouseId,String warehouseName,long timestamp, double humidity, double temperature) {
// HumidityAndtemperature data = new HumidityAndtemperature(); HumidityAndtemperature data = new HumidityAndtemperature();
// data.setHumidity(humidity); data.setHumidity(humidity);
// data.setTemperature(temperature); data.setTemperature(temperature);
// data.setCreateTime(timestamp); data.setCreateTime(timestamp);
// data.setWarehouseId(warehouseId); data.setWarehouseId(warehouseId);
// data.setWarehouseName(warehouseName); data.setWarehouseName(warehouseName);
// String key = warehouseId; String key = warehouseId;
// getRedisTemplate().opsForZSet().add(key, data, timestamp); getRedisTemplate().opsForZSet().add(key, data, timestamp);
//
// put(key, data); put(key, data);
}
public List<Object> getDataByTimestampRange(String warehouseId, long startTimestamp, long endTimestamp) {
String key = warehouseId;
Set<Object> dataInRange = getRedisTemplate().opsForZSet().rangeByScore(key, startTimestamp, endTimestamp);
return new ArrayList<>(dataInRange);
} }
// public List<HumidityAndtemperature> getDataByTimestampRange(String warehouseId, long startTimestamp, long endTimestamp) {
// String key = warehouseId;
//
// Set<HumidityAndtemperature> dataInRange = getRedisTemplate().opsForZSet().rangeByScore(key, startTimestamp, endTimestamp);
// return new ArrayList<>(dataInRange);
// }
} }
...@@ -2,12 +2,14 @@ package com.junmp.jyzb.entity.Temp; ...@@ -2,12 +2,14 @@ package com.junmp.jyzb.entity.Temp;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import org.springframework.context.annotation.Configuration;
import java.io.Serializable; import java.io.Serializable;
import java.sql.Time; import java.sql.Time;
import java.util.Date; import java.util.Date;
@Data @Data
@Configuration
@NoArgsConstructor @NoArgsConstructor
public class HumidityAndtemperature implements Serializable { public class HumidityAndtemperature implements Serializable {
//湿度 //湿度
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论