Compare commits

...

2 Commits

Author SHA1 Message Date
zq
084201bb58 修改 2026-01-23 19:43:48 +08:00
zq
194429af2d 修改 2026-01-23 19:29:24 +08:00
3 changed files with 5 additions and 2 deletions

View File

@ -605,6 +605,9 @@ public class DeviceDataProcessServiceImpl extends AbstractBatteryDataProcessor i
*/ */
private void saveDeviceData(List<EmsPointMatch> pointMatchList, Map<String, Object> obj, private void saveDeviceData(List<EmsPointMatch> pointMatchList, Map<String, Object> obj,
Object entity, Map<String, List<EmsPointEnumMatch>> pointEnumMatchMap) { Object entity, Map<String, List<EmsPointEnumMatch>> pointEnumMatchMap) {
if (null == obj || obj.isEmpty()) {
return;
}
Map<String, String> pointMatchMap = pointMatchList.stream() Map<String, String> pointMatchMap = pointMatchList.stream()
.collect(Collectors.toMap( .collect(Collectors.toMap(
data -> StringUtils.toCamelCase(data.getMatchField()), // 源字段名转为驼峰 data -> StringUtils.toCamelCase(data.getMatchField()), // 源字段名转为驼峰

View File

@ -351,7 +351,7 @@ public class EmsStatsReportServiceImpl implements IEmsStatsReportService
resultList.forEach(ammeterRevenue -> { resultList.forEach(ammeterRevenue -> {
ammeterRevenue.setActiveTotalPrice(ammeterRevenue.getActivePeakPrice().add(ammeterRevenue.getActiveHighPrice()).add(ammeterRevenue.getActiveFlatPrice()).add(ammeterRevenue.getActiveValleyPrice())); ammeterRevenue.setActiveTotalPrice(ammeterRevenue.getActivePeakPrice().add(ammeterRevenue.getActiveHighPrice()).add(ammeterRevenue.getActiveFlatPrice()).add(ammeterRevenue.getActiveValleyPrice()));
ammeterRevenue.setReActiveTotalPrice(ammeterRevenue.getReActivePeakPrice().add(ammeterRevenue.getReActiveHighPrice()).add(ammeterRevenue.getReActiveFlatPrice()).add(ammeterRevenue.getReActiveValleyPrice())); ammeterRevenue.setReActiveTotalPrice(ammeterRevenue.getReActivePeakPrice().add(ammeterRevenue.getReActiveHighPrice()).add(ammeterRevenue.getReActiveFlatPrice()).add(ammeterRevenue.getReActiveValleyPrice()));
ammeterRevenue.setActualRevenue(ammeterRevenue.getReActiveFlatPrice().subtract(ammeterRevenue.getActiveTotalPrice())); ammeterRevenue.setActualRevenue(ammeterRevenue.getReActiveTotalPrice().subtract(ammeterRevenue.getActiveTotalPrice()));
}); });
return resultList; return resultList;

View File

@ -191,7 +191,7 @@
and t.device_category = #{deviceCategory} and t.device_category = #{deviceCategory}
</if> </if>
<if test="pointName != null and pointName != ''"> <if test="pointName != null and pointName != ''">
and t.point_name = #{pointName} and t.point_name like concat('%', #{pointName}, '%')
</if> </if>
</select> </select>