Commit 8492c3d3 by 赵剑炜

先恢复至可用

parent 6ffc99ae
......@@ -17,7 +17,10 @@
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>io.swagger</groupId>
<artifactId>swagger-annotations</artifactId>
......
package com.junmp.jyzb.cache;
import com.junmp.jyzb.api.constant.JYZBConstant;
import com.junmp.v2.cache.AbstractRedisCache;
import org.springframework.data.redis.core.RedisTemplate;
......
......@@ -6,16 +6,13 @@ import com.junmp.v2.cache.AbstractRedisCache;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Component
public class TemperatureRedisCache extends AbstractRedisCache<HumidityAndtemperature> {
public TemperatureRedisCache(RedisTemplate<String, HumidityAndtemperature> redisTemplate) {
public class TemperatureRedisCache extends AbstractRedisCache<Object> {
public TemperatureRedisCache(RedisTemplate<String, Object> redisTemplate) {
super(redisTemplate);
// super(redisTemplate);
}
@Override
......@@ -24,21 +21,21 @@ public class TemperatureRedisCache extends AbstractRedisCache<HumidityAndtempera
}
public void addTemperatureHumidity(String warehouseId,String warehouseName,long timestamp, double humidity, double temperature) {
HumidityAndtemperature data = new HumidityAndtemperature();
data.setHumidity(humidity);
data.setTemperature(temperature);
data.setCreateTime(timestamp);
data.setWarehouseId(warehouseId);
data.setWarehouseName(warehouseName);
String key = warehouseId;
getRedisTemplate().opsForZSet().add(key, data, timestamp);
put(key, data);
}
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);
// HumidityAndtemperature data = new HumidityAndtemperature();
// data.setHumidity(humidity);
// data.setTemperature(temperature);
// data.setCreateTime(timestamp);
// data.setWarehouseId(warehouseId);
// data.setWarehouseName(warehouseName);
// String key = warehouseId;
// getRedisTemplate().opsForZSet().add(key, data, timestamp);
//
// put(key, data);
}
// 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);
// }
}
package com.junmp.jyzb.entity.Temp;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.sql.Time;
import java.util.Date;
@Data
public class HumidityAndtemperature {
@NoArgsConstructor
public class HumidityAndtemperature implements Serializable {
//湿度
private Double humidity;
//温度
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论