Compare commits

...

2 Commits

Author SHA1 Message Date
zhczyx@163.com 3c030eda73 Merge branch 'ppt-20260120' into zhc 1 month ago
review512jwy@163.com d3dbe13ca0 redis取latestValueBO bug 1 month ago
  1. 11
      dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataBaStatusServiceImpl.java

11
dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataBaStatusServiceImpl.java

@ -196,11 +196,20 @@ public class DeviceDataBaStatusServiceImpl implements DeviceDataBaStatusService
List<Object> yCommon = new ArrayList<>(); List<Object> yCommon = new ArrayList<>();
//** 获取昨日最新数据 **// //** 获取昨日最新数据 **//
String redisKey = Constants.REDIS_BA_STATUS_LATEST_VALUE + DateUtil.getYesterdayInJapan(); String redisKey = Constants.REDIS_BA_STATUS_LATEST_VALUE + DateUtil.getYesterdayInJapan();
boolean cacheExist = redisUtil.existsKey(redisKey);
Object cacheLastValue = redisUtil.HGet(redisKey, lineDataSearchParams.getDeviceId().toLowerCase()); Object cacheLastValue = redisUtil.HGet(redisKey, lineDataSearchParams.getDeviceId().toLowerCase());
if (null != cacheLastValue) { if (null != cacheLastValue) {
try { try {
LatestValueBO latestValueBO = objectMapper.readValue(JSONObject.toJSONString(cacheLastValue), LatestValueBO.class); String value = cacheLastValue.toString();
// 如果是被双引号包住的 JSON(双层 JSON)
if (value.startsWith("\"")) {
value = objectMapper.readValue(value, String.class);
}
LatestValueBO latestValueBO = objectMapper.readValue(value, LatestValueBO.class);
String dateFormatted = Instant.ofEpochMilli(latestValueBO.getUpdateTs()) String dateFormatted = Instant.ofEpochMilli(latestValueBO.getUpdateTs())
.atZone(Constants.ZONE_TOKYO) .atZone(Constants.ZONE_TOKYO)
.format(Constants.FORMATTER_YMDHMS); .format(Constants.FORMATTER_YMDHMS);

Loading…
Cancel
Save