xzzn/emsback
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

0918电价-站点的实时总收入和实时当日收入

Browse Source
This commit is contained in:
mashili
2025-10-13 11:37:03 +08:00
parent 6ebeb48b62
commit eed6f839f6
3 changed files with 24 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
ems-common/src/main/java/com/xzzn/common/utils/DateUtils.java
View File

@ -393,4 +393,19 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils
// 3. 转换为Date // 3. 转换为Date
return new Date(updateTime); return new Date(updateTime);
} }
/**
* 获取昨天的日期，格式为yyyy-MM-dd
* @return 昨天的日期字符串
*/
public static String getYesterdayDayString() {
// 获取今天的日期
LocalDate today = LocalDate.now();
// 减去一天得到昨天
LocalDate yesterday = today.minusDays(1);
// 定义日期格式化器
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(YYYYMMDD);
// 格式化并返回
return yesterday.format(formatter);
}
} }

11
ems-system/src/main/java/com/xzzn/ems/service/impl/DDSDataProcessServiceImpl.java
View File

@ -954,13 +954,13 @@ public class DDSDataProcessServiceImpl extends AbstractBatteryDataProcessor impl
String yestDate = DateUtils.getYesterdayDate(); String yestDate = DateUtils.getYesterdayDate();
String yestDateRedisKey = RedisKeyConstants.AMMETER + SITE_ID + "_" + deviceId + "_" + yestDate; String yestDateRedisKey = RedisKeyConstants.AMMETER + SITE_ID + "_" + deviceId + "_" + yestDate;
EmsAmmeterData yestData = redisCache.getCacheObject(yestDateRedisKey); EmsAmmeterData yestData = redisCache.getCacheObject(yestDateRedisKey);
if (yestDate == null) { if (yestData == null) {
// redis没有这查电表总数据表取截止到昨日最新第一条数据 // redis没有这查电表总数据表取截止到昨日最新第一条数据
yestData = emsAmmeterDataMapper.getYestLatestDate(SITE_ID,deviceId,yestDate); yestData = emsAmmeterDataMapper.getYestLatestDate(SITE_ID,deviceId,yestDate);
// 数据存redis-有效期1天 // 数据存redis-有效期1天
redisCache.setCacheObject(yestDateRedisKey, yestDate , Constants.DATE_VALID_TIME, TimeUnit.DAYS); redisCache.setCacheObject(yestDateRedisKey, yestData , Constants.DATE_VALID_TIME, TimeUnit.DAYS);
} }
if (yestDate != null) { if (yestData != null) {
// 今日总数据-昨日总数据=今日充放电 // 今日总数据-昨日总数据=今日充放电
BigDecimal yestTotalDisChargeDate = yestData.getCurrentReverseActiveTotal(); BigDecimal yestTotalDisChargeDate = yestData.getCurrentReverseActiveTotal();
BigDecimal yestTotalChargeDate = yestData.getCurrentForwardActiveTotal(); BigDecimal yestTotalChargeDate = yestData.getCurrentForwardActiveTotal();
@ -1046,14 +1046,15 @@ public class DDSDataProcessServiceImpl extends AbstractBatteryDataProcessor impl
private BigDecimal getYestLastData(String siteId) { private BigDecimal getYestLastData(String siteId) {
// dds存的是累计到昨日总收益 // dds存的是累计到昨日总收益
String redisKey = RedisKeyConstants.DDS_TOTAL_REVENUE + siteId; String yestDate = DateUtils.getYesterdayDayString();
String redisKey = RedisKeyConstants.DDS_TOTAL_REVENUE + siteId + "_" + yestDate;
BigDecimal yestLastTotalRevenue = redisCache.getCacheObject(redisKey); BigDecimal yestLastTotalRevenue = redisCache.getCacheObject(redisKey);
if (yestLastTotalRevenue == null) { if (yestLastTotalRevenue == null) {
yestLastTotalRevenue = emsDailyEnergyDataMapper.getLastTotalRevenue(siteId); yestLastTotalRevenue = emsDailyEnergyDataMapper.getLastTotalRevenue(siteId);
if (yestLastTotalRevenue == null) { if (yestLastTotalRevenue == null) {
yestLastTotalRevenue = BigDecimal.ZERO; yestLastTotalRevenue = BigDecimal.ZERO;
} }
redisCache.setCacheObject(redisKey, yestLastTotalRevenue); redisCache.setCacheObject(redisKey, yestLastTotalRevenue, 1 , TimeUnit.DAYS);
} }
return yestLastTotalRevenue; return yestLastTotalRevenue;
} }

5
ems-system/src/main/java/com/xzzn/ems/service/impl/FXXDataProcessServiceImpl.java
View File

@ -910,7 +910,8 @@ public class FXXDataProcessServiceImpl extends AbstractBatteryDataProcessor impl
private Map<String, BigDecimal> getLastData(String siteId) { private Map<String, BigDecimal> getLastData(String siteId) {
// dds存的是累计到昨日总收益 // dds存的是累计到昨日总收益
String redisKey = RedisKeyConstants.FXX_REALTIME_REVENUE + siteId; String yestDate = DateUtils.getYesterdayDayString();
String redisKey = RedisKeyConstants.FXX_REALTIME_REVENUE + siteId + "_" + yestDate;
Map<String, BigDecimal> realTimeRevenue = redisCache.getCacheObject(redisKey); Map<String, BigDecimal> realTimeRevenue = redisCache.getCacheObject(redisKey);
if (realTimeRevenue == null) { if (realTimeRevenue == null) {
realTimeRevenue = emsDailyEnergyDataMapper.getRealTimeRevenue(siteId); realTimeRevenue = emsDailyEnergyDataMapper.getRealTimeRevenue(siteId);
@ -919,7 +920,7 @@ public class FXXDataProcessServiceImpl extends AbstractBatteryDataProcessor impl
realTimeRevenue.put("totalRevenue", BigDecimal.ZERO); realTimeRevenue.put("totalRevenue", BigDecimal.ZERO);
realTimeRevenue.put("dayRevenue", BigDecimal.ZERO); realTimeRevenue.put("dayRevenue", BigDecimal.ZERO);
} }
redisCache.setCacheObject(redisKey, realTimeRevenue); redisCache.setCacheObject(redisKey, realTimeRevenue, 1, TimeUnit.DAYS);
} }
return realTimeRevenue; return realTimeRevenue;
} }