diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java index d190306..d0135aa 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java @@ -345,16 +345,16 @@ public class EmsStatsReportServiceImpl implements IEmsStatsReportService public List getAmmeterRevenueDataResult(StatisAmmeterDateRequest requestVo) { String siteId = requestVo.getSiteId(); List resultList = new ArrayList<>(); - //查询电价配置 - List priceConfigList = emsEnergyPriceConfigMapper.getConfigListByTimeFrame(siteId, requestVo.getStartTime(), requestVo.getEndTime()); - if (CollectionUtils.isEmpty(priceConfigList)){ - return Collections.emptyList(); - } //查询电表数据 List dataList = this.getAmmeterDataResult(requestVo); if (CollectionUtils.isEmpty(dataList)) { return Collections.emptyList(); } + //查询电价配置 + List priceConfigList = emsEnergyPriceConfigMapper.getConfigListByTimeFrame(siteId, requestVo.getStartTime(), requestVo.getEndTime()); + if (CollectionUtils.isEmpty(priceConfigList)){ + return Collections.emptyList(); + } Map> priceConfigMap = priceConfigList.stream().collect(Collectors.groupingBy(EnergyPriceConfigVo::getYearMonth)); dataList.forEach(ammeter -> { List priceConfigs = priceConfigMap.get(ammeter.getDataTime().substring(0, 7)); diff --git a/ems-system/src/main/java/com/xzzn/ems/utils/DevicePointMatchDataProcessor.java b/ems-system/src/main/java/com/xzzn/ems/utils/DevicePointMatchDataProcessor.java index 5fabd12..64aa1d2 100644 --- a/ems-system/src/main/java/com/xzzn/ems/utils/DevicePointMatchDataProcessor.java +++ b/ems-system/src/main/java/com/xzzn/ems/utils/DevicePointMatchDataProcessor.java @@ -1,14 +1,10 @@ package com.xzzn.ems.utils; -import com.alibaba.fastjson2.JSON; -import com.alibaba.fastjson2.JSONObject; import com.xzzn.common.annotation.Excel; import com.xzzn.common.constant.RedisKeyConstants; import com.xzzn.common.core.redis.RedisCache; - import com.xzzn.common.enums.PointType; -import com.xzzn.common.utils.DataUtils; import com.xzzn.common.utils.StringUtils; import com.xzzn.ems.domain.EmsPointEnumMatch; import com.xzzn.ems.domain.EmsPointMatch; @@ -27,13 +23,10 @@ import java.util.Map; import java.util.Objects; import java.util.stream.Collectors; -import javax.annotation.PostConstruct; - import org.apache.commons.collections4.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.core.io.ClassPathResource; import org.springframework.stereotype.Service; @Service @@ -56,18 +49,18 @@ public class DevicePointMatchDataProcessor { /** * 初始化加载设备匹配点位配置数据 */ - @PostConstruct - public void init() - { - try { - ClassPathResource classPathResource = new ClassPathResource("biz/configData/DevicePointMatch.json"); - String configJson = DataUtils.getJSONFromFile(classPathResource.getInputStream()); - devicePointMatchInfo = JSONObject.parseObject(configJson, DevicePointMatchInfo.class); - log.info("初始化设备匹配点位配置数据成功。"+ JSON.toJSONString(devicePointMatchInfo)); - } catch (Exception ex) { - log.error("OcrMedicalStdHandler 设置mapping数据异常。", ex); - } - } +// @PostConstruct +// public void init() +// { +// try { +// ClassPathResource classPathResource = new ClassPathResource("biz/configData/DevicePointMatch.json"); +// String configJson = DataUtils.getJSONFromFile(classPathResource.getInputStream()); +// devicePointMatchInfo = JSONObject.parseObject(configJson, DevicePointMatchInfo.class); +// log.info("初始化设备匹配点位配置数据成功。"+ JSON.toJSONString(devicePointMatchInfo)); +// } catch (Exception ex) { +// log.error("OcrMedicalStdHandler 设置mapping数据异常。", ex); +// } +// } /** * 获取字段注解信息