From 42f1491508c90c07299d729ebe72124b38c3c119 Mon Sep 17 00:00:00 2001 From: xiezw Date: Mon, 31 Mar 2025 16:59:46 +0800 Subject: [PATCH] qingyuan-20250331 --- .../board/controller/BoardNewController.java | 219 +++++ .../board/dto/BuildDetailRequestDTO.java | 14 + .../qingyuan/board/dto/BuildRequestDTO.java | 16 + .../dto/CarbonAndConsumptionDataDTO.java | 21 + .../board/dto/EnergyBuildDataDTO.java | 19 + .../board/dto/EnergyConsumptionDataDTO.java | 17 + .../dto/EnergyCostProportionDataDTO.java | 20 + .../board/dto/EnergyDataAnalyseDTO.java | 16 + .../board/dto/EnergyDataAnalyseDetailDTO.java | 16 + .../qingyuan/board/dto/EnergyDataDTO.java | 17 + .../qingyuan/board/dto/EnergyDayDataDTO.java | 21 + .../board/service/BoardNewService.java | 33 + .../service/impl/BoardNewServiceImpl.java | 853 ++++++++++++++++++ 13 files changed, 1282 insertions(+) create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/controller/BoardNewController.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildDetailRequestDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildRequestDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/CarbonAndConsumptionDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyBuildDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyConsumptionDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyCostProportionDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDetailDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDayDataDTO.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/BoardNewService.java create mode 100644 modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/impl/BoardNewServiceImpl.java diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/controller/BoardNewController.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/controller/BoardNewController.java new file mode 100644 index 0000000..e3facda --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/controller/BoardNewController.java @@ -0,0 +1,219 @@ +package com.thing.qingyuan.board.controller; + + +import com.thing.common.core.web.response.Result; +import com.thing.qingyuan.board.dto.*; +import com.thing.qingyuan.board.service.BoardNewService; +import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.Parameters; +import io.swagger.v3.oas.annotations.tags.Tag; +import lombok.RequiredArgsConstructor; +import org.apache.commons.lang3.StringUtils; +import org.springframework.web.bind.annotation.*; + +import java.time.LocalDate; +import java.time.format.DateTimeFormatter; +import java.util.List; +import java.util.Map; + +/** + * 看板 + * + * @author wzf 56583086@qq.com + * @since 1.0.0 2020-09-06 + */ + +@RestController +@RequestMapping("/board") +@Tag(name = "看板") +@RequiredArgsConstructor +public class BoardNewController { + + private final BoardNewService boardService; + + @GetMapping("eachEnergy") + @Operation(summary = "月用能统计") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result getEachEnergy(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + EnergyDayDataDTO result = boardService.getEachEnergy(day); + return new Result().ok(result); + } + + @GetMapping("eachEnergyYear") + @Operation(summary ="年用能统计") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result getYearEachEnergy(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + EnergyDayDataDTO result = boardService.getEachYearEnergy(day); + return new Result().ok(result); + } + + @GetMapping("energyConsumption") + @Operation(summary ="能耗统计") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result getEnergyConsumption(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + EnergyConsumptionDataDTO result = boardService.getEnergyConsumption(day); + return new Result().ok(result); + } + + @GetMapping("carbonAndConsumption") + @Operation(summary ="碳排和综合能耗数据") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result getCarbonAndConsumption(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + CarbonAndConsumptionDataDTO result = boardService.getCarbonAndConsumption(day); + return new Result().ok(result); + } + + @GetMapping("energyCost") + @Operation(summary ="能耗费用统计") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result> getEnergyCost(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + List result = boardService.getEnergyCost(day); + return new Result>().ok(result); + } + + @GetMapping("monthEnergy/ranking") + @Operation(summary ="月用能排行") + @Parameters({ + @Parameter(name = "month", description = "日期：例如2023-06", required = true), + @Parameter(name = "type", description = "类型：传参：电/水/蒸汽/压缩空气", required = true) + }) + public Result> getMonthEnergyRanking(@Parameter(hidden = true) @RequestParam Map params){ + String key = "A29mm"; + String type = params.get("type").toString(); + if ("电".equals(type)){ + key = "A29mm"; + }else if("水".equals(type)){ + key = "B2mm"; + }else if("蒸汽".equals(type)){ + key = "E3mm"; + }else if("压缩空气".equals(type)){ + key = "D2mm"; + } + String month; + if (params.get("month") != null){ + month = params.get("month").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM"); + month = currentDate.format(formatter); + } + List result = boardService.getMonthEnergyRanking(month,key,type); + return new Result>().ok(result); + } + + @GetMapping("monthEnergy/analyse") + @Operation(summary ="月用能趋势") + @Parameters({ + @Parameter(name = "month", description = "日期：例如2023-06", required = true), + @Parameter(name = "type", description = "类型：传参：电/水/蒸汽/压缩空气", required = true) + }) + public Result qcMonthEnergyAnalyse(@Parameter(hidden = true) @RequestParam Map params){ + String key = "A29dd"; + String type = params.get("type").toString(); + if ("电".equals(type)){ + key = "A29dd"; + }else if("水".equals(type)){ + key = "B2dd"; + }else if("蒸汽".equals(type)){ + key = "E3dd"; + }else if("压缩空气".equals(type)){ + key = "D2dd"; + } + String month; + if (params.get("month") != null){ + month = params.get("month").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM"); + month = currentDate.format(formatter); + } + EnergyDataAnalyseDTO result = boardService.qcMonthEnergyAnalyse(month,key,type); + return new Result().ok(result); + } + + @GetMapping("qcDayLoad/analyse") + @Operation(summary ="日用电负荷") + @Parameters({ + @Parameter(name = "day", description = "日期：例如2023-06-01", required = true) + }) + public Result qcDayLoadAnalyse(@Parameter(hidden = true) @RequestParam Map params){ + String day; + if (params.get("day") != null){ + day = params.get("day").toString(); + }else{ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + day = currentDate.format(formatter); + } + EnergyDataAnalyseDTO result = boardService.qcDayLoadAnalyse(day); + return new Result().ok(result); + } + + @PostMapping("build/data") + @Operation(summary ="建筑对应用能") + public Result getBuildEnergy(@RequestBody BuildRequestDTO dto){ + if (StringUtils.isBlank(dto.getMonth())){ + LocalDate currentDate = LocalDate.now(); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM"); + String month = currentDate.format(formatter); + dto.setMonth(month); + } + EnergyBuildDataDTO result = boardService.getBuildEnergy(dto); + return new Result().ok(result); + } + + + + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildDetailRequestDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildDetailRequestDTO.java new file mode 100644 index 0000000..b2ca357 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildDetailRequestDTO.java @@ -0,0 +1,14 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class BuildDetailRequestDTO { + + @Schema(description = "物编号") + private String code; + @Schema(description = "属性：电A29,水B2,蒸汽E3,压缩空气D2") + private String key; + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildRequestDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildRequestDTO.java new file mode 100644 index 0000000..a68fc62 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/BuildRequestDTO.java @@ -0,0 +1,16 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.util.List; + +@Data +public class BuildRequestDTO { + + @Schema(description = "月份") + private String month; + + @Schema(description = "物编号及属性") + private List datas; +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/CarbonAndConsumptionDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/CarbonAndConsumptionDataDTO.java new file mode 100644 index 0000000..7afb6db --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/CarbonAndConsumptionDataDTO.java @@ -0,0 +1,21 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class CarbonAndConsumptionDataDTO { + + @Schema(description = "日碳排") + private BigDecimal dayCarbon; + @Schema(description = "日能耗") + private BigDecimal dayConsumptionValue; + @Schema(description = "月能耗") + private BigDecimal monthConsumptionValue; + @Schema(description = "年碳排") + private BigDecimal yearCarbon; + @Schema(description = "年能耗") + private BigDecimal yearConsumptionValue; +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyBuildDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyBuildDataDTO.java new file mode 100644 index 0000000..672c3cd --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyBuildDataDTO.java @@ -0,0 +1,19 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyBuildDataDTO { + + @Schema(description = "用电量") + private BigDecimal electricValue; + @Schema(description = "用水量") + private BigDecimal waterValue; + @Schema(description = "蒸汽量") + private BigDecimal steamValue; + @Schema(description = "压缩空气量") + private BigDecimal airValue; +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyConsumptionDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyConsumptionDataDTO.java new file mode 100644 index 0000000..8fbc6a3 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyConsumptionDataDTO.java @@ -0,0 +1,17 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyConsumptionDataDTO { + + @Schema(description = "日能耗") + private BigDecimal dayValue; + @Schema(description = "月能耗") + private BigDecimal monthValue; + @Schema(description = "年能耗") + private BigDecimal yearValue; +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyCostProportionDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyCostProportionDataDTO.java new file mode 100644 index 0000000..6125e7d --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyCostProportionDataDTO.java @@ -0,0 +1,20 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyCostProportionDataDTO { + + @Schema(description = "能源名称") + private String name; + + @Schema(description = "值") + private BigDecimal value; + + @Schema(description = "占比") + private String proportion; + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDTO.java new file mode 100644 index 0000000..6e07459 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDTO.java @@ -0,0 +1,16 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.util.List; + +@Data +public class EnergyDataAnalyseDTO { + + @Schema(description = "当前月数据") + private List currentMonthData; +// @ApiModelProperty(value = "上月数据") +// private List lastMonthData; + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDetailDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDetailDTO.java new file mode 100644 index 0000000..e6351e2 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataAnalyseDetailDTO.java @@ -0,0 +1,16 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyDataAnalyseDetailDTO { + + @Schema(description = "日期") + private String date; + @Schema(description = "用量") + private BigDecimal value; + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataDTO.java new file mode 100644 index 0000000..f51f0eb --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDataDTO.java @@ -0,0 +1,17 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyDataDTO { + + @Schema(description = "物名称") + private String thingName; + + @Schema(description = "值") + private BigDecimal value; + +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDayDataDTO.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDayDataDTO.java new file mode 100644 index 0000000..e141128 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/dto/EnergyDayDataDTO.java @@ -0,0 +1,21 @@ +package com.thing.qingyuan.board.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class EnergyDayDataDTO { + + @Schema(description = "日用电量") + private BigDecimal electricDayValue; + @Schema(description = "日水电量") + private BigDecimal waterDayValue; + @Schema(description = "日蒸汽电量") + private BigDecimal steamDayValue; + @Schema(description = "日压缩空气量") + private BigDecimal airDayValue; + @Schema(description = "天然气量") + private BigDecimal gasValue; +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/BoardNewService.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/BoardNewService.java new file mode 100644 index 0000000..0d127a2 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/BoardNewService.java @@ -0,0 +1,33 @@ +package com.thing.qingyuan.board.service; + + +import com.thing.qingyuan.board.dto.*; + +import java.util.List; + +/** + * 看板 + * + * @author wzf 56583086@qq.com + * @since 1.0.0 2020-09-27 + */ +public interface BoardNewService { + + EnergyDayDataDTO getEachEnergy(String day); + + EnergyDataAnalyseDTO qcDayLoadAnalyse(String day); + + EnergyConsumptionDataDTO getEnergyConsumption(String day); + + CarbonAndConsumptionDataDTO getCarbonAndConsumption(String day); + + List getEnergyCost(String day); + + List getMonthEnergyRanking(String month, String key, String type); + + EnergyDataAnalyseDTO qcMonthEnergyAnalyse(String month, String key, String type); + + EnergyDayDataDTO getEachYearEnergy(String day); + + EnergyBuildDataDTO getBuildEnergy(BuildRequestDTO dto); +} diff --git a/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/impl/BoardNewServiceImpl.java b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/impl/BoardNewServiceImpl.java new file mode 100644 index 0000000..eb79a22 --- /dev/null +++ b/modules/qingyuan/src/main/java/com/thing/qingyuan/board/service/impl/BoardNewServiceImpl.java @@ -0,0 +1,853 @@ +package com.thing.qingyuan.board.service.impl; + +import cn.hutool.core.collection.CollectionUtil; +import com.alibaba.fastjson.JSONObject; +import com.thing.common.core.utils.DateTimeUtils; +import com.thing.qingyuan.board.dto.*; +import com.thing.qingyuan.board.service.BoardNewService; +import com.thing.sys.biz.service.SysDeptService; +import com.thing.sys.biz.service.SysParamsService; +import lombok.RequiredArgsConstructor; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.math.BigDecimal; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.YearMonth; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.stream.Collectors; + +/** + * 看板 + * + * @author WangJunLong 56583086@qq.com + * @since 1.0.0 2020-09-27 + */ +@Service +@RequiredArgsConstructor +public class BoardNewServiceImpl implements BoardNewService { +// @Autowired +// private ThingsDao thingsDao; + @Autowired + private SysParamsService sysParamsService; +// @Autowired +// private NewRestClientUtils newRestClientUtils; + @Autowired + private SysDeptService sysDeptService; +// @Autowired +// private PowerCoalRatioDao powerCoalRatioDao; +// +// @Autowired +// private ThingsService thingsService; +// +// @Autowired +// private EnergyPriceService energyPriceService; +// +// @Autowired +// private EnergyMonthDataService energyMonthDataService; + + @Override + public EnergyDataAnalyseDTO qcDayLoadAnalyse(String day) { + EnergyDataAnalyseDTO result = new EnergyDataAnalyseDTO(); + List currentMonthData = new ArrayList<>(); + //当日开始结束时间 + String dayStartTime = day + " 00:00:00"; + String dayEndTime = day + " 23:59:59"; + //将当月时间转换为时间戳 + Long dayStartTimeStamp = DateTimeUtils.dateToStamp(dayStartTime); + //当月结束时间 + Long dayEndTimeStamp = DateTimeUtils.dateToStamp(dayEndTime); + + /** + * 参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = JSONObject.parseObject(cqStr, Map.class); + List keys = new ArrayList<>(); + keys.add("A16"); + //注释说明：获取电表在所传时间内A16属性的数据，该接口传的是天的时间，A16表示电负荷， todo +// ThingsDTO thingsDTO = thingsService.getThingsByCode(codeMap.get("总用电")); +// if(thingsDTO==null && StringUtils.isBlank(thingsDTO.getEntityId())){ +// return result; +// } +// //当天 +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// List currentTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayStartTimeStamp-1000L,dayEndTimeStamp,true); +// if (CollectionUtil.isNotEmpty(currentTsKvEntries)) { +// for (TsKvEntry tsKvEntry:currentTsKvEntries){ +// EnergyDataAnalyseDetailDTO energyDataAnalyseDetailDTO = new EnergyDataAnalyseDetailDTO(); +// energyDataAnalyseDetailDTO.setDate(DateTimeUtils.timestampToDate(tsKvEntry.getTs(),DateTimeUtils.DATE_TIME_PATTERN_STR)); +// energyDataAnalyseDetailDTO.setValue(new BigDecimal(tsKvEntry.getValue().toString())); +// currentMonthData.add(energyDataAnalyseDetailDTO); +// } +// } + result.setCurrentMonthData(currentMonthData); + return result; + } + + + @Override + public EnergyConsumptionDataDTO getEnergyConsumption(String day) { + EnergyConsumptionDataDTO result = new EnergyConsumptionDataDTO(); + //日时间 + Long dayTime = DateTimeUtils.dateToStamp(day+" 00:00:00"); + //月时间 + Long monthTime = DateTimeUtils.dateToStamp(day.substring(0,7)+"-01 00:00:00"); + //年时间 + Long yearTime = DateTimeUtils.dateToStamp(day.substring(0,4)+"-01-01 00:00:00"); + BigDecimal totalDayValue = BigDecimal.ZERO; + BigDecimal totalMonthValue= BigDecimal.ZERO; + BigDecimal totalYearValue= BigDecimal.ZERO; + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = new HashMap<>(); + codeMap = JSONObject.parseObject(cqStr, Map.class); + +// SysDeptEntity dept = sysDeptService.getDeptVaildPermission((Long) null); + //获取折标煤系数，这边需要调整，物管理获取折标煤系数的地方 todo + Map coalRatio = new HashMap<>(); +// List powerCoalRatioList = getPowerCoalRatioList(dept.getTenantCode(), dept.getId()); +// if (CollectionUtils.isNotEmpty(powerCoalRatioList)){ +// for (PowerCoalRatioEntity powerCoalRatioEntity:powerCoalRatioList){ +// coalRatio.put(powerCoalRatioEntity.getPowerTypeCode(),powerCoalRatioEntity.getCoalRatio()); +// } +// } + + for(Map.Entry entry : codeMap.entrySet()){ + if (entry.getKey().equals("总用水")){ + continue; + } + BigDecimal coalRatioValue =null; + List keys = new ArrayList<>(); + List keys1 = new ArrayList<>(); + List keys2 = new ArrayList<>(); + if (entry.getKey().equals("总用电")){ + coalRatioValue = coalRatio.get("A"); + keys.add("A29dd"); + keys1.add("A29mm"); + keys2.add("A29yy"); + }else if (entry.getKey().equals("总蒸汽")){ + coalRatioValue = coalRatio.get("E"); + keys.add("E3dd"); + keys1.add("E3mm"); + keys2.add("E3yy"); + }else if(entry.getKey().equals("总压缩空气")){ + coalRatioValue = coalRatio.get("D"); + keys.add("D2dd"); + keys1.add("D2mm"); + keys2.add("D2yy"); + } + /** + * todo 获取各用能数据 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(entry.getValue()); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// TsKvEntry tsKvEntry = dayTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal dayConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalDayValue = totalDayValue.add(dayConsumptionValue); +// } +// } +// } +// //当月 +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,monthTime-5*60000L,monthTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal monthConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalMonthValue = totalMonthValue.add(monthConsumptionValue); +// } +// } +// } +// //当年 +// List yearTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys2,yearTime-5*60000L,yearTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(yearTsKvEntries)){ +// TsKvEntry tsKvEntry = yearTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal yearConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalYearValue = totalYearValue.add(yearConsumptionValue); +// } +// } +// } +// } + } + result.setDayValue(totalDayValue); + result.setMonthValue(totalMonthValue); + result.setYearValue(totalYearValue); + return result; + } + + @Override + public CarbonAndConsumptionDataDTO getCarbonAndConsumption(String day) { + CarbonAndConsumptionDataDTO result = new CarbonAndConsumptionDataDTO(); + //日时间 + Long dayTime = DateTimeUtils.dateToStamp(day+" 00:00:00"); + Long lastDayTime = dayTime-24*60*60*1000L; + //月时间 + Long monthTime = DateTimeUtils.dateToStamp(day.substring(0,7)+"-01 00:00:00"); + //年时间 + Long yearTime = DateTimeUtils.dateToStamp(day.substring(0,4)+"-01-01 00:00:00"); + BigDecimal totalDayCarbonValue = BigDecimal.ZERO; + BigDecimal totalDayConsumtionValue = BigDecimal.ZERO; + BigDecimal totalMonthConsumtionValue= BigDecimal.ZERO; + BigDecimal totalYearConsumtionValue = BigDecimal.ZERO; + BigDecimal totalYearCarbonValue= BigDecimal.ZERO; + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = new HashMap<>(); + codeMap = JSONObject.parseObject(cqStr, Map.class); + + Map coalRatio = new HashMap<>(); + /** + * 获取折标煤系数，这边需要调整，物管理获取折标煤系数的地方 todo + */ +// SysDeptEntity dept = sysDeptService.getDeptVaildPermission((Long) null); +// //获取折标煤系数 +// List powerCoalRatioList = getPowerCoalRatioList(dept.getTenantCode(), dept.getId()); +// if (CollectionUtils.isNotEmpty(powerCoalRatioList)){ +// for (PowerCoalRatioEntity powerCoalRatioEntity:powerCoalRatioList){ +// coalRatio.put(powerCoalRatioEntity.getPowerTypeCode(),powerCoalRatioEntity.getCoalRatio()); +// } +// } + + for(Map.Entry entry : codeMap.entrySet()){ + if (entry.getKey().equals("总用水")){ + continue; + } + BigDecimal coalRatioValue =null; + List keys = new ArrayList<>(); + List keys1 = new ArrayList<>(); + List keys2 = new ArrayList<>(); + if (entry.getKey().equals("总用电")){ + coalRatioValue = coalRatio.get("A"); + keys.add("A29dd"); + keys1.add("A29mm"); + keys2.add("A29yy"); + }else if (entry.getKey().equals("总蒸汽")){ + coalRatioValue = coalRatio.get("E"); + keys.add("E3dd"); + keys1.add("E3mm"); + keys2.add("E3yy"); + }else if(entry.getKey().equals("总压缩空气")){ + coalRatioValue = coalRatio.get("D"); + keys.add("D2dd"); + keys1.add("D2mm"); + keys2.add("D2yy"); + } + //获取各用能数据 +// ThingsDTO thingsDTO = thingsService.getThingsByCode(entry.getValue()); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,lastDayTime-5*60000L,lastDayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// TsKvEntry tsKvEntry = dayTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal dayConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalDayConsumtionValue = totalDayConsumtionValue.add(dayConsumptionValue); +// BigDecimal dayCarbonValue = dayConsumptionValue.multiply(new BigDecimal("2.493")); +// totalDayCarbonValue = totalDayCarbonValue.add(dayCarbonValue); +// } +// } +// } +// //当月 +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,monthTime-5*60000L,monthTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal monthConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalMonthConsumtionValue = totalMonthConsumtionValue.add(monthConsumptionValue); +// } +// } +// } +// List yearTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys2,yearTime-5*60000L,yearTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(yearTsKvEntries)){ +// TsKvEntry tsKvEntry = yearTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null && coalRatioValue!=null){ +// BigDecimal value = new BigDecimal(tsKvEntry.getValue().toString()); +// if (value!=null){ +// BigDecimal yearConsumptionValue = value.multiply(coalRatioValue).setScale(2,BigDecimal.ROUND_HALF_UP); +// totalYearConsumtionValue = totalYearConsumtionValue.add(yearConsumptionValue); +// BigDecimal yearCarbonValue = yearConsumptionValue.multiply(new BigDecimal("2.493")); +// totalYearCarbonValue = totalYearCarbonValue.add(yearCarbonValue); +// } +// } +// } +// } + } + result.setDayCarbon(totalDayCarbonValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + result.setDayConsumptionValue(totalDayConsumtionValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + result.setMonthConsumptionValue(totalMonthConsumtionValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + result.setYearCarbon(totalYearCarbonValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + result.setYearConsumptionValue(totalYearConsumtionValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + + return result; + } + + @Override + public List getEnergyCost(String day) { + List result = new ArrayList<>(); + + //月时间 + Long dayTime = DateTimeUtils.dateToStamp(day.substring(0,7)+"-01 00:00:00"); + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = new HashMap<>(); + codeMap = JSONObject.parseObject(cqStr, Map.class); + + List keyList = new ArrayList<>(); + keyList.add("A29_rush"); + keyList.add("A29_peak"); + keyList.add("A29_valley"); + keyList.add("A29_normal"); + keyList.add("A29"); + keyList.add("B2"); + keyList.add("D2"); + keyList.add("E3"); + /** + * todo ,获取各用能的价格 + */ + Map finalPriceMap= new HashMap<>(); +// SysDeptEntity sysDeptEntity = sysDeptService.getDeptVaildPermission(); +// Map> priceMap = new HashMap<>(); +// //获取价格配置 +// List energyPriceList = energyPriceService.getUnitPriceList(keyList, sysDeptEntity.getId()); +// if (CollectionUtil.isNotEmpty(energyPriceList)){ +// priceMap = energyPriceList.stream() +// // 按照 attributeKey 进行分组 +// .collect(Collectors.groupingBy(EnergyPriceDTO::getAttributeKey, +// // 分组后的每个列表根据 startTime 降序排序 +// Collectors.collectingAndThen( +// Collectors.toList(), +// list -> list.stream() +// .sorted(Comparator.comparing(EnergyPriceDTO::getStartTime).reversed()) +// .collect(Collectors.toList()) +// ) +// )); +// } +// +// if (priceMap!=null){ +// for (Map.Entry> entry:priceMap.entrySet()){ +// EnergyPriceDTO energyPriceDTO = entry.getValue().get(0); +// BigDecimal unitCost = BigDecimal.ZERO; +// if (energyPriceDTO.getPrice()!=null){ +// unitCost = new BigDecimal(energyPriceDTO.getPrice()); +// } +// finalPriceMap.put(entry.getKey(),unitCost); +// } +// } + BigDecimal totalAllValue = BigDecimal.ZERO; + for(Map.Entry entry : codeMap.entrySet()){ + if(entry.getKey().equals("总压缩空气")){ + continue; + } + EnergyCostProportionDataDTO costProportionDataDTO = new EnergyCostProportionDataDTO(); + List keys = new ArrayList<>(); + if (entry.getKey().equals("总用电")){ + costProportionDataDTO.setName("电"); + keys.add("A29_rushmm"); + keys.add("A29_peakmm"); + keys.add("A29_valleymm"); + keys.add("A29_normalmm"); + }else if (entry.getKey().equals("总用水")){ + costProportionDataDTO.setName("水"); + keys.add("B2mm"); + }else if (entry.getKey().equals("总蒸汽")){ + costProportionDataDTO.setName("蒸汽"); + keys.add("E3mm"); + } + BigDecimal totalValue = BigDecimal.ZERO; + /** + * todo 各用能费用 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(entry.getValue()); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// Map> tsKvMap = new HashMap<>(); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// tsKvMap = dayTsKvEntries.stream() +// .collect(Collectors.groupingBy(TsKvEntry::getKey)); +// } +// if (tsKvMap!=null){ +// for (Map.Entry> keyEntry:tsKvMap.entrySet()){ +// BigDecimal value1 = new BigDecimal(keyEntry.getValue().get(0).getValue().toString()); +// BigDecimal unitCost =BigDecimal.ZERO; +// if (keyEntry.getKey().equals("A29_rushmm")){ +// if (finalPriceMap.get("A29_rush")!=null){ +// unitCost =finalPriceMap.get("A29_rush"); +// } +// } +// if (keyEntry.getKey().equals("A29_peakmm")){ +// if (finalPriceMap.get("A29_peak")!=null){ +// unitCost =finalPriceMap.get("A29_peak"); +// } +// } +// if (entry.getKey().equals("A29_valleymm")){ +// if (finalPriceMap.get("A29_valley")!=null){ +// unitCost =finalPriceMap.get("A29_valley"); +// } +// } +// if (keyEntry.getKey().equals("A29_normalmm")){ +// if (finalPriceMap.get("A29_normal")!=null){ +// unitCost =finalPriceMap.get("A29_normal"); +// } +// } +// if (keyEntry.getKey().equals("B2mm")){ +// if (finalPriceMap.get("B2")!=null){ +// unitCost =finalPriceMap.get("B2"); +// } +// } +// if (keyEntry.getKey().equals("D2mm")){ +// if (finalPriceMap.get("D2")!=null){ +// unitCost =finalPriceMap.get("D2"); +// } +// } +// if (keyEntry.getKey().equals("E3mm")){ +// if (finalPriceMap.get("E3")!=null){ +// unitCost =finalPriceMap.get("E3"); +// } +// } +// if (value1!=null){ +// if (unitCost!=null){ +// totalValue = totalValue.add(value1.multiply(unitCost)); +// } +// } +// } +// } +// } +// } + costProportionDataDTO.setValue(totalValue.setScale(2,BigDecimal.ROUND_HALF_UP)); + result.add(costProportionDataDTO); + totalAllValue = totalAllValue.add(totalValue); + } + if (CollectionUtil.isNotEmpty(result)){ + for (EnergyCostProportionDataDTO cost:result){ + if (totalAllValue!=null && totalAllValue.compareTo(BigDecimal.ZERO)!=0){ + cost.setProportion(cost.getValue().divide(totalAllValue,2,BigDecimal.ROUND_HALF_UP)+"%"); + } + } + } + return result; + } + + @Override + public List getMonthEnergyRanking(String month, String key, String type) { + List result = new ArrayList<>(); + //月数据 + String dayStartTime = month + "-01 00:00:00"; + Long dayStartTimeStamp = DateTimeUtils.dateToStamp(dayStartTime); + Long dayEndTimeStamp = dayStartTimeStamp + 5*60*1000; + /** + * 排行表 ：参数格式：["D_V0000151_3","D_V0000151_4","D_V0000151_2","E_V0000151_7"] + */ + String codeStr = sysParamsService.getValue("BOARD_ENERGY_RANKING"); + List codeList = JSONObject.parseArray(codeStr, String.class); + List keys = new ArrayList<>(); + keys.add(key); + /** + * todo 获取各表的数据 + */ +// List things = thingsDao.getByCodes(codeList); +// if(CollectionUtil.isEmpty(things)){ +// return result; +// } +// for (ThingsDTO thingsDTO : things){ +// EnergyDataDTO energyDataDTO = new EnergyDataDTO(); +// energyDataDTO.setThingName(thingsDTO.getName()); +// List tsKvEntries = newRestClientUtils.getTimeseries(thingsDTO.getEntityId(),keys,dayStartTimeStamp-1000L,dayEndTimeStamp); +// if (CollectionUtil.isEmpty(tsKvEntries)) { +// continue; +// } +// BigDecimal value = new BigDecimal(tsKvEntries.get(0).getValue().toString()); +// if (value !=null){ +// energyDataDTO.setValue(value.setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// result.add(energyDataDTO); +// } + + result =result.stream() + .sorted(Comparator.comparing(EnergyDataDTO::getValue, Comparator.nullsLast(Comparator.reverseOrder()))) + .collect(Collectors.toList()); + return result; + } + + + public static String getLastDayOfMonth(String month) { + String fullDateString = month + "-01"; + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + LocalDate date = LocalDate.parse(fullDateString, formatter); + + // 获取该月的最后一天 + LocalDate lastDayOfMonth = date.withDayOfMonth(date.lengthOfMonth()); + + // 设置最后一天的时间为 23:59:59 + LocalDateTime lastMomentOfMonth = lastDayOfMonth.atTime(23, 59, 59); + + // 返回结果的字符串，格式为 "yyyy-MM-dd HH:mm:ss" + return lastMomentOfMonth.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + } + + @Override + public EnergyDataAnalyseDTO qcMonthEnergyAnalyse(String month, String key, String type) { + EnergyDataAnalyseDTO result = new EnergyDataAnalyseDTO(); + List currentMonthData = new ArrayList<>(); + //当日开始结束时间 + String dayStartTime = month + "-01 00:00:00"; + String dayEndTime = getLastDayOfMonth(month); + //将当月时间转换为时间戳 + Long dayStartTimeStamp = DateTimeUtils.dateToStamp(dayStartTime); + //当月结束时间 + Long dayEndTimeStamp = DateTimeUtils.dateToStamp(dayEndTime); + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + + Map codeMap = JSONObject.parseObject(cqStr, Map.class); + List keys = new ArrayList<>(); + keys.add(key); + String code =null; + if ("电".equals(type)){ + code = codeMap.get("总用电"); + }else if("水".equals(type)){ + code = codeMap.get("总用水"); + }else if("蒸汽".equals(type)){ + code = codeMap.get("总蒸汽"); + }else if("压缩空气".equals(type)){ + code = codeMap.get("总压缩空气"); + } + /** + * todo 获取各用能数据 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(code); +// if(thingsDTO==null && StringUtils.isBlank(thingsDTO.getEntityId())){ +// return result; +// } +// //当月 +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// List currentTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayStartTimeStamp-1000L,dayEndTimeStamp,true); +// if (CollectionUtil.isNotEmpty(currentTsKvEntries)) { +// for (TsKvEntry tsKvEntry:currentTsKvEntries){ +// EnergyDataAnalyseDetailDTO energyDataAnalyseDetailDTO = new EnergyDataAnalyseDetailDTO(); +// energyDataAnalyseDetailDTO.setDate(DateUtils.timeStamp2Date(String.valueOf(tsKvEntry.getTs()),DateUtils.DATE_TIME_PATTERN)); +// if (tsKvEntry.getValue()!=null){ +// energyDataAnalyseDetailDTO.setValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// currentMonthData.add(energyDataAnalyseDetailDTO); +// } +// } + result.setCurrentMonthData(currentMonthData); + return result; + } + + @Override + public EnergyDayDataDTO getEachYearEnergy(String day) { + EnergyDayDataDTO result = new EnergyDayDataDTO(); + String year = day.substring(0,4); + //年时间 + Long dayTime = DateTimeUtils.dateToStamp(year+"-01-01 00:00:00"); + + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = new HashMap<>(); + codeMap = JSONObject.parseObject(cqStr, Map.class); + + + /** + * todo 获取各用能数据 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(codeMap.get("总用电")); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// //当日 +// List keys = new ArrayList<>(); +// keys.add("A29yy"); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// TsKvEntry tsKvEntry = dayTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setElectricDayValue(new BigDecimal(tsKvEntry.getValue().toString()).divide(new BigDecimal(10000)).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //水 +// ThingsDTO thingsDTO1 = thingsService.getThingsByCode(codeMap.get("总用水")); +// if (thingsDTO1!=null && StringUtils.isNotBlank(thingsDTO1.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO1.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("B2yy"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setWaterDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //压缩空气 +// ThingsDTO thingsDTO2 = thingsService.getThingsByCode(codeMap.get("总压缩空气")); +// if (thingsDTO2!=null && StringUtils.isNotBlank(thingsDTO2.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO2.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("D2yy"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setAirDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //蒸汽 +// ThingsDTO thingsDTO3 = thingsService.getThingsByCode(codeMap.get("总蒸汽")); +// if (thingsDTO3!=null && StringUtils.isNotBlank(thingsDTO3.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO3.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("E3yy"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setSteamDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// +// //天然气 +// BigDecimal gasValue = energyMonthDataService.getYearDataByBaseInfoIdAndYear(100L,year); +// if (gasValue!=null){ +// result.setGasValue(gasValue.setScale(2,BigDecimal.ROUND_HALF_UP)); +// } + return result; + } + + @Override + public EnergyBuildDataDTO getBuildEnergy(BuildRequestDTO dto) { + EnergyBuildDataDTO result = new EnergyBuildDataDTO(); + String dayStartTime = dto.getMonth() + "-01 00:00:00"; + Long dayStartTimeStamp = DateTimeUtils.dateToStamp(dayStartTime); + Long dayEndTimeStamp = dayStartTimeStamp + 5*60*1000; + + if (CollectionUtil.isEmpty(dto.getDatas())){ + return result; + } + List datas = dto.getDatas(); + for (BuildDetailRequestDTO requestDTO:datas){ + /** + * todo ,获取各用能数据 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(requestDTO.getCode()); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// //当日 +// List keys = new ArrayList<>(); +// String key = requestDTO.getKey(); +// keys.add(key+"mm"); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayStartTimeStamp-5*60000L,dayEndTimeStamp,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// TsKvEntry tsKvEntry = dayTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// if ("A29".equals(key)){ +// result.setElectricValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// }else if("B2".equals(key)){ +// result.setWaterValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// }else if("E3".equals(key)){ +// result.setSteamValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// }else if("D2".equals(key)){ +// result.setAirValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// } + } + return result; + } + + + @Override + public EnergyDayDataDTO getEachEnergy(String day) { + EnergyDayDataDTO result = new EnergyDayDataDTO(); + String month = day.substring(0,7); + //月时间 + Long dayTime = DateTimeUtils.dateToStamp(month+"-01 00:00:00"); + + /** + * 总code ：参数格式：{"总用电": "G01","总用水": "G03","总蒸汽": "G02","总压缩空气": "D_V0000151_1"} + */ + String cqStr = sysParamsService.getValue("BOARD_TOTAL_ENERGY"); + Map codeMap = new HashMap<>(); + codeMap = JSONObject.parseObject(cqStr, Map.class); + + /** + * todo 获取各用能数据 + */ +// ThingsDTO thingsDTO = thingsService.getThingsByCode(codeMap.get("总用电")); +// if (thingsDTO!=null && StringUtils.isNotBlank(thingsDTO.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO.getEntityId())); +// //当日 +// List keys = new ArrayList<>(); +// keys.add("A29mm"); +// List dayTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(dayTsKvEntries)){ +// TsKvEntry tsKvEntry = dayTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setElectricDayValue(new BigDecimal(tsKvEntry.getValue().toString()).divide(new BigDecimal(10000)).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //水 +// ThingsDTO thingsDTO1 = thingsService.getThingsByCode(codeMap.get("总用水")); +// if (thingsDTO1!=null && StringUtils.isNotBlank(thingsDTO1.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO1.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("B2mm"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setWaterDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //压缩空气 +// ThingsDTO thingsDTO2 = thingsService.getThingsByCode(codeMap.get("总压缩空气")); +// if (thingsDTO2!=null && StringUtils.isNotBlank(thingsDTO2.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO2.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("D2mm"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setAirDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// //蒸汽 +// ThingsDTO thingsDTO3 = thingsService.getThingsByCode(codeMap.get("总蒸汽")); +// if (thingsDTO3!=null && StringUtils.isNotBlank(thingsDTO3.getEntityId())){ +// DeviceId deviceId = new DeviceId(UUID.fromString(thingsDTO3.getEntityId())); +// //当月 +// List keys1 = new ArrayList<>(); +// keys1.add("E3mm"); +// List monthTsKvEntries = newRestClientUtils.getTimeseries(deviceId,keys1,dayTime-5*60000L,dayTime+5*60000L,true); +// if (CollectionUtil.isNotEmpty(monthTsKvEntries)){ +// TsKvEntry tsKvEntry = monthTsKvEntries.get(0); +// if (tsKvEntry.getValue()!=null){ +// result.setSteamDayValue(new BigDecimal(tsKvEntry.getValue().toString()).setScale(2,BigDecimal.ROUND_HALF_UP)); +// } +// } +// } +// +// //天然气 +// BigDecimal gasValue = energyMonthDataService.getDataByBaseIdAndMonth(100L,month); +// if (gasValue!=null){ +// result.setGasValue(gasValue.setScale(2,BigDecimal.ROUND_HALF_UP)); +// } + return result; + } + + + public static List getDaysBetween(String startDate, String endDate) { + List daysList = new ArrayList<>(); + LocalDate start = LocalDate.parse(startDate); + LocalDate end = LocalDate.parse(endDate); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + + while (!start.isAfter(end)) { + String day = start.format(formatter); + daysList.add(day); + start = start.plusDays(1); + } + Collections.reverse(daysList); + return daysList; + } + + public static void main(String[] args) { + String month = "2024-12"; + String dayEndTime = getLastDayOfMonth(month); + System.out.println(dayEndTime); +// List daysList = getDaysBetween(month, LocalDate.now().toString()); +// Collections.reverse(daysList); +// System.out.println(daysList); +// +// String year = "2023"; +// List monthsList = getMonthsBetween(year + "-01", YearMonth.now().toString()); +// System.out.println(monthsList); + } + + + + public static List getMonthsBetween(String startMonth, String endMonth) { + List monthsList = new ArrayList<>(); + YearMonth start = YearMonth.parse(startMonth); + YearMonth end = YearMonth.parse(endMonth); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM"); + + while (!start.isAfter(end)) { + String month = start.format(formatter); + monthsList.add(month); + start = start.plusMonths(1); + } + Collections.reverse(monthsList); + return monthsList; + } + + + private static String getWeekdayName(int dayOfWeek) { + switch (dayOfWeek) { + case 1: + return "周一"; + case 2: + return "周二"; + case 3: + return "周三"; + case 4: + return "周四"; + case 5: + return "周五"; + case 6: + return "周六"; + case 7: + return "周日"; + default: + return ""; + } + } + +// private List getPowerCoalRatioList(Long tenantCode, Long deptId) { +// return powerCoalRatioDao.selectList(Wrappers.lambdaQuery() +// .eq(PowerCoalRatioEntity::getDeptId, deptId).eq(PowerCoalRatioEntity::getTenantCode, tenantCode)); +// } + + +}