package com.iailab.module.ansteel.api.controller.admin;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.iailab.framework.common.exception.enums.GlobalErrorCodeConstants;
|
import com.iailab.framework.common.pojo.CommonResult;
|
import com.iailab.framework.common.pojo.PageResult;
|
import com.iailab.framework.common.util.date.DateUtils;
|
import com.iailab.framework.common.util.object.BeanUtils;
|
import com.iailab.framework.common.util.object.ConvertUtils;
|
import com.iailab.framework.excel.core.util.ExcelUtils;
|
import com.iailab.module.ansteel.api.dto.*;
|
import com.iailab.module.ansteel.api.vo.PowerCapacitorHisPageReqVO;
|
import com.iailab.module.ansteel.api.vo.PowerExportCosVO;
|
import com.iailab.module.ansteel.api.vo.PowerExportPqVO;
|
import com.iailab.module.ansteel.api.vo.PowerMaxDemandMainPageReqVO;
|
import com.iailab.module.ansteel.common.constant.CommonConstant;
|
import com.iailab.module.ansteel.common.enums.ProcessConfDataTypeEnum;
|
import com.iailab.module.ansteel.common.utils.CalendarUtil;
|
import com.iailab.module.ansteel.common.utils.DecimalUtil;
|
import com.iailab.module.ansteel.common.utils.PowerUtil;
|
import com.iailab.module.ansteel.power.entity.*;
|
import com.iailab.module.ansteel.power.service.*;
|
import com.iailab.module.data.api.point.DataPointApi;
|
import com.iailab.module.data.api.point.dto.ApiPointValueDTO;
|
import com.iailab.module.data.api.point.dto.ApiPointValueQueryDTO;
|
import com.iailab.module.data.api.point.dto.ApiPointsValueQueryDTO;
|
import com.iailab.module.model.api.mcs.McsApi;
|
import com.iailab.module.model.api.mcs.dto.ChartParamDTO;
|
import com.iailab.module.model.api.mcs.dto.PredictLastValueReqVO;
|
import com.iailab.module.model.api.mdk.MdkApi;
|
import com.iailab.module.model.api.mdk.dto.MdkScheduleReqDTO;
|
import io.swagger.v3.oas.annotations.Operation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import static com.iailab.framework.common.pojo.CommonResult.error;
|
import static com.iailab.framework.common.pojo.CommonResult.success;
|
|
/**
|
* 电力接口
|
*
|
* @author PanZhibao
|
* @Description
|
* @createTime 2025年04月11日
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/ansteel/api/power")
|
public class PowerController {
|
|
@Autowired
|
private PowerNetFactorService powerNetFactorService;
|
|
@Autowired
|
private PowerCapacitorStatusService powerCapacitorStatusService;
|
|
@Autowired
|
private PowerControlMainService powerControlMainService;
|
|
@Autowired
|
private PowerControlDetService powerControlDetService;
|
|
@Autowired
|
private PowerGenStatusDaoService powerGenStatusDaoService;
|
|
@Autowired
|
private PowerDemandService powerDemandService;
|
|
@Autowired
|
private PowerAdjustedFactorService powerAdjustedFactorService;
|
|
@Autowired
|
private DataPointApi dataPointApi;
|
|
@Autowired
|
private McsApi mcsApi;
|
|
@Autowired
|
private MdkApi mdkApi;
|
|
@Autowired
|
private PowerCapacitorHisService powerCapacitorHisService;
|
|
@Autowired
|
private PowerCapacitorDetService powerCapacitorDetService;
|
|
@Autowired
|
private PowerNetDropdownService powerNetDropdownService;
|
|
@Autowired
|
private PowerVoltageStatusService powerVoltageStatusService;
|
|
@Autowired
|
private PowerMaxdemandMainService powerMaxDemandMainService;
|
|
@Autowired
|
private PowerMaxdemandDetService powerMaxdemandDetService;
|
|
@Autowired
|
private PowerPriceMainService powerPriceMainService;
|
|
@Autowired
|
private PowerFactorControlService powerFactorControlService;
|
|
public static final String VALUE = "value";
|
|
public static final String TIME = "time";
|
|
//private String pointNo = "F0000201825";
|
|
@GetMapping("/net-factor/list")
|
@Operation(summary = "功率因数-电网拓扑列表")
|
public CommonResult<List<PowerNetFactorDTO>> getPowerNetFactorList(@RequestParam Map<String, Object> params) {
|
log.info("功率因数电网拓扑");
|
List<PowerNetFactorDTO> result = new ArrayList<>();
|
List<PowerNetFactorEntity> list = powerNetFactorService.list(params);
|
if (CollectionUtils.isEmpty(list)) {
|
log.info("list is empty");
|
return success(result);
|
}
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
|
for (PowerNetFactorEntity entity : list) {
|
PowerNetFactorDTO powerNetFactorDTO = new PowerNetFactorDTO();
|
powerNetFactorDTO.setId(entity.getId());
|
powerNetFactorDTO.setGroupName(entity.getGroupName());
|
powerNetFactorDTO.setNodeCode(entity.getNodeCode());
|
powerNetFactorDTO.setNodeName(entity.getNodeName());
|
boolean cosFlag = false;
|
try {
|
List<String> points = new ArrayList<>();
|
if (StringUtils.isNotBlank(entity.getCurA())) {
|
points.add(entity.getCurA());
|
}
|
if (StringUtils.isNotBlank(entity.getCurP())) {
|
points.add(entity.getCurP());
|
}
|
if (StringUtils.isNotBlank(entity.getCurQ())) {
|
points.add(entity.getCurQ());
|
}
|
if (StringUtils.isNotBlank(entity.getCurCos())) {
|
points.add(entity.getCurCos());
|
}
|
log.info("points=" + points);
|
if (!CollectionUtils.isEmpty(points)) {
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
log.info("pointsRealValue=" + pointsRealValue);
|
if (pointsRealValue.get(entity.getCurA()) != null) {
|
powerNetFactorDTO.setCurA(new BigDecimal(pointsRealValue.get(entity.getCurA()).toString()));
|
}
|
if (pointsRealValue.get(entity.getCurP()) != null) {
|
powerNetFactorDTO.setCurP(new BigDecimal(pointsRealValue.get(entity.getCurP()).toString()));
|
}
|
if (pointsRealValue.get(entity.getCurQ()) != null) {
|
powerNetFactorDTO.setCurQ(new BigDecimal(pointsRealValue.get(entity.getCurQ()).toString()));
|
}
|
if (pointsRealValue.get(entity.getCurCos()) != null) {
|
powerNetFactorDTO.setCurCos(new BigDecimal(pointsRealValue.get(entity.getCurCos()).toString()));
|
cosFlag = true;
|
}
|
}
|
} catch (Exception ex) {
|
log.info(entity.getNodeName() + "获取当前值异常" + ex.getMessage());
|
ex.printStackTrace();
|
}
|
|
try {
|
PredictLastValueReqVO reqVO = new PredictLastValueReqVO();
|
reqVO.setPredictTime(calendar.getTime());
|
List<String[]> itemNos = new ArrayList<>();
|
if (StringUtils.isNotBlank(entity.getPreP())) {
|
itemNos.add(entity.getPreP().split(","));
|
}
|
if (StringUtils.isNotBlank(entity.getPreQ())) {
|
itemNos.add(entity.getPreQ().split(","));
|
}
|
if (StringUtils.isNotBlank(entity.getPreCos())) {
|
itemNos.add(entity.getPreCos().split(","));
|
}
|
if (!CollectionUtils.isEmpty(itemNos)) {
|
reqVO.setItemNos(itemNos);
|
log.info("reqVO=" + JSONObject.toJSONString(reqVO));
|
Map<String, BigDecimal> preValues = mcsApi.getPredictValueByTime(reqVO);
|
if (StringUtils.isNotBlank(entity.getPreP()) && preValues.get(entity.getPreP()) != null) {
|
powerNetFactorDTO.setPreP(new BigDecimal(preValues.get(entity.getPreP()).toString()));
|
}
|
if (StringUtils.isNotBlank(entity.getPreQ()) && preValues.get(entity.getPreQ()) != null) {
|
powerNetFactorDTO.setPreQ(new BigDecimal(preValues.get(entity.getPreQ()).toString()));
|
}
|
if (StringUtils.isNotBlank(entity.getPreCos()) && preValues.get(entity.getPreCos()) != null) {
|
powerNetFactorDTO.setPreCos(new BigDecimal(preValues.get(entity.getPreCos()).toString()));
|
}
|
}
|
} catch (Exception ex) {
|
log.info(entity.getNodeName() + "获取预测值异常," + ex.getMessage());
|
ex.printStackTrace();
|
}
|
|
// 设置电流状态
|
powerNetFactorDTO.setStatus(0);
|
if (powerNetFactorDTO.getCurA() != null) {
|
BigDecimal curA = powerNetFactorDTO.getCurA();
|
if (entity.getLimitL() != null && curA.compareTo(entity.getLimitL()) < 0) {
|
powerNetFactorDTO.setStatus(1);
|
} else if (entity.getLimitH() != null && curA.compareTo(entity.getLimitH()) > 0) {
|
powerNetFactorDTO.setStatus(1);
|
}
|
}
|
|
// 设置功率因数状态
|
powerNetFactorDTO.setQstatus(0);
|
if (cosFlag && powerNetFactorDTO.getCurCos() != null) {
|
BigDecimal curCos = powerNetFactorDTO.getCurCos();
|
if (entity.getCosLimitL() != null && curCos.compareTo(entity.getCosLimitL()) < 0) {
|
powerNetFactorDTO.setQstatus(1);
|
} else if (entity.getCosLimitH() != null && curCos.compareTo(entity.getCosLimitH()) > 0) {
|
powerNetFactorDTO.setQstatus(1);
|
}
|
}
|
|
// 设置有功预警状态
|
powerNetFactorDTO.setPstatus(0);
|
if (powerNetFactorDTO.getCurP() != null) {
|
BigDecimal curP = powerNetFactorDTO.getCurP();
|
if (entity.getPLimitL() != null && curP.compareTo(entity.getPLimitL()) < 0) {
|
powerNetFactorDTO.setPstatus(1);
|
} else if (entity.getPLimitH() != null && curP.compareTo(entity.getPLimitH()) > 0) {
|
powerNetFactorDTO.setPstatus(1);
|
}
|
}
|
|
// 设置无功预警状态
|
powerNetFactorDTO.setQstatus(0);
|
if (powerNetFactorDTO.getCurQ() != null) {
|
BigDecimal curQ = powerNetFactorDTO.getCurQ();
|
if (entity.getQLimitL() != null && curQ.compareTo(entity.getQLimitL()) < 0) {
|
powerNetFactorDTO.setQstatus(1);
|
} else if (entity.getQLimitH() != null && curQ.compareTo(entity.getQLimitH()) > 0) {
|
powerNetFactorDTO.setQstatus(1);
|
}
|
}
|
|
// 日功率因数
|
if (StringUtils.isNotBlank(entity.getPDay()) && StringUtils.isNotBlank(entity.getQDay())) {
|
List<String> pointNos = new ArrayList<>();
|
pointNos.add(entity.getPDay());
|
pointNos.add(entity.getQDay());
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(pointNos);
|
if (!CollectionUtils.isEmpty(pointsRealValue)) {
|
double pValue = new BigDecimal(pointsRealValue.get(entity.getPDay()).toString()).doubleValue();
|
double qValue = new BigDecimal(pointsRealValue.get(entity.getQDay()).toString()).doubleValue();
|
powerNetFactorDTO.setDayCos(new BigDecimal(PowerUtil.calculateCos(pValue, qValue)).setScale(2, BigDecimal.ROUND_HALF_UP));
|
}
|
}
|
|
// 月功率因数
|
if (StringUtils.isNotBlank(entity.getPMon()) && StringUtils.isNotBlank(entity.getQMon())) {
|
List<String> pointNos = new ArrayList<>();
|
pointNos.add(entity.getPMon());
|
pointNos.add(entity.getQMon());
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(pointNos);
|
if (!CollectionUtils.isEmpty(pointsRealValue)) {
|
double pValue = new BigDecimal(pointsRealValue.get(entity.getPMon()).toString()).doubleValue();
|
double qValue = new BigDecimal(pointsRealValue.get(entity.getQMon()).toString()).doubleValue();
|
powerNetFactorDTO.setMonthCos(new BigDecimal(PowerUtil.calculateCos(pValue, qValue)).setScale(2, BigDecimal.ROUND_HALF_UP));
|
}
|
}
|
result.add(powerNetFactorDTO);
|
}
|
return success(result);
|
}
|
|
@GetMapping("/net-factor-dropdown/list")
|
@Operation(summary = "功率因数-电网拓扑下拉列表")
|
public CommonResult<List<PowerNetDropdownDTO>> getPowerNetFactorDropdownList(@RequestParam String nodeCode) {
|
log.info("nodeCode=" + nodeCode);
|
List<PowerNetDropdownDTO> result = new ArrayList<>();
|
PowerNetFactorEntity entity = powerNetFactorService.getByNodeCode(nodeCode);
|
if (entity == null) {
|
return success(result);
|
}
|
List<PowerNetDropdownEntity> list = new ArrayList<>();
|
Map<String, Object> params = new HashMap<>();
|
if ("望铁关口".equals(entity.getGroupName())) {
|
params.put("groupName", entity.getGroupName());
|
params.put("neNodeName", entity.getNodeName());
|
} else {
|
params.put("groupName", entity.getNodeName());
|
}
|
list = powerNetDropdownService.list(params);
|
|
// 追加公共 2025-06-18
|
Map<String, Object> paramsCom = new HashMap<>();
|
paramsCom.put("groupName", "COMMON1");
|
List<PowerNetDropdownEntity> comList = powerNetDropdownService.list(paramsCom);
|
list.addAll(comList);
|
|
List<String> points = list.stream().map(item -> {
|
return item.getCurCos();
|
}).collect(Collectors.toList());
|
Map<String, Object> pointsRealValue = new HashMap<>();
|
if (!CollectionUtils.isEmpty(points)) {
|
pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
}
|
for (PowerNetDropdownEntity netDropdown : list) {
|
PowerNetDropdownDTO dto = ConvertUtils.sourceToTarget(netDropdown, PowerNetDropdownDTO.class);
|
BigDecimal curCos = BigDecimal.ZERO;
|
if (pointsRealValue.get(netDropdown.getCurCos()) != null) {
|
curCos = new BigDecimal(pointsRealValue.get(netDropdown.getCurCos()).toString());
|
}
|
dto.setCurCos(curCos);
|
result.add(dto);
|
}
|
return success(result);
|
}
|
|
/**
|
* 判断 curCos 是否超上下限
|
* {nodeName}功率因数超上限/下限。
|
* <p>
|
* 判断 curQ
|
* {nodeName}发生无功返送
|
*/
|
@GetMapping("/net-factor/alarm")
|
@Operation(summary = "功率因数-电网拓扑预警信息")
|
public CommonResult<List<String>> getPowerNetFactorAlarm(@RequestParam Map<String, Object> params) {
|
List<String> result = new ArrayList<>();
|
List<PowerNetFactorEntity> list = powerNetFactorService.list(params);
|
List<PowerNetFactorDTO> dtoList = ConvertUtils.sourceToTarget(list, PowerNetFactorDTO.class);
|
if (CollectionUtils.isEmpty(dtoList)) {
|
return success(result);
|
}
|
for (PowerNetFactorEntity entity : list) {
|
List<String> points = new ArrayList<>();
|
String message = "";
|
if (StringUtils.isNotBlank(entity.getCurQ())) {
|
points.add(entity.getCurQ());
|
}
|
if (StringUtils.isNotBlank(entity.getCurCos())) {
|
points.add(entity.getCurCos());
|
}
|
if (CollectionUtils.isEmpty(points)) {
|
continue;
|
}
|
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
if (pointsRealValue.get(entity.getCurQ()) != null) {
|
BigDecimal curQ = new BigDecimal(pointsRealValue.get(entity.getCurQ()).toString());
|
if (entity.getCurFlag() != null && curQ.compareTo(BigDecimal.ZERO) == entity.getCurFlag()) {
|
message = entity.getNodeName() + "发生无功返送;";
|
}
|
}
|
if (pointsRealValue.get(entity.getCurCos()) != null) {
|
BigDecimal curCos = new BigDecimal(pointsRealValue.get(entity.getCurCos()).toString());
|
if (entity.getLimitH() != null && curCos.compareTo(entity.getLimitH()) > 0) {
|
message += entity.getNodeName() + "功率因数超上限";
|
} else if (entity.getLimitL() != null && curCos.compareTo(entity.getLimitL()) < 0) {
|
message += entity.getNodeName() + "功率因数超下限";
|
}
|
}
|
if (!message.isEmpty()) {
|
result.add(message);
|
}
|
}
|
return success(result);
|
}
|
|
@GetMapping("/gen-status/list")
|
@Operation(summary = "功率因数-发电机组实时状态")
|
public CommonResult<List<PowerGenStatusDTO>> getPowerGenStatusList(@RequestParam Map<String, Object> params) {
|
List<PowerGenStatusDTO> result = new ArrayList<>();
|
List<PowerGenStatusEntity> list = powerGenStatusDaoService.list(params);
|
if (CollectionUtils.isEmpty(list)) {
|
return success(result);
|
}
|
for (PowerGenStatusEntity entity : list) {
|
PowerGenStatusDTO dto = new PowerGenStatusDTO();
|
dto.setId(entity.getId());
|
dto.setName(entity.getName());
|
dto.setSort(entity.getSort());
|
|
List<String> points = new ArrayList<>();
|
if (StringUtils.isNotBlank(entity.getCurP())) {
|
points.add(entity.getCurP());
|
}
|
if (StringUtils.isNotBlank(entity.getCurQ())) {
|
points.add(entity.getCurQ());
|
}
|
if (StringUtils.isNotBlank(entity.getCurCos())) {
|
points.add(entity.getCurCos());
|
}
|
if (!CollectionUtils.isEmpty(points)) {
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
if (pointsRealValue.get(entity.getCurP()) != null) {
|
dto.setCurP(new BigDecimal(pointsRealValue.get(entity.getCurP()).toString()));
|
}
|
if (pointsRealValue.get(entity.getCurQ()) != null) {
|
dto.setCurQ(new BigDecimal(pointsRealValue.get(entity.getCurQ()).toString()));
|
}
|
if (pointsRealValue.get(entity.getCurCos()) != null) {
|
dto.setCurCos(new BigDecimal(pointsRealValue.get(entity.getCurCos()).toString()));
|
}
|
}
|
|
result.add(dto);
|
}
|
|
return success(result);
|
}
|
|
@PostMapping("/gen-status/history")
|
@Operation(summary = "功率因数-发电机组功率历史")
|
public CommonResult<PowerHistoryDTO> getPowerGenStatusHistory(@RequestBody PowerGenStatusHisReqDTO dto) {
|
log.info("请求参数: {}", JSONObject.toJSONString(dto));
|
|
// 参数校验
|
if (StringUtils.isBlank(dto.getId())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "id不能为空");
|
}
|
if (StringUtils.isBlank(dto.getQueryType())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "queryType不能为空");
|
}
|
log.info("id={}", dto.getId());
|
PowerGenStatusEntity powerGenStatus = powerGenStatusDaoService.getById(dto.getId());
|
if (powerGenStatus == null) {
|
log.info("未找到code对应的数据: {}", dto.getId());
|
return success(new PowerHistoryDTO());
|
}
|
|
String queryType = dto.getQueryType().toUpperCase();
|
log.info("queryType={}", queryType);
|
String pointNo;
|
switch (queryType.toUpperCase()) {
|
case "P":
|
pointNo = powerGenStatus.getCurP();
|
break;
|
case "Q":
|
pointNo = powerGenStatus.getCurQ();
|
break;
|
case "COS":
|
pointNo = powerGenStatus.getCurCos();
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的queryType: " + queryType);
|
}
|
log.info("开始查询，pointNo={}", pointNo);
|
|
// 默认查最近24小时
|
Date end = Optional.ofNullable(dto.getEndTime()).orElseGet(() -> {
|
Calendar cal = Calendar.getInstance();
|
cal.set(Calendar.MILLISECOND, 0);
|
cal.set(Calendar.SECOND, 0);
|
return cal.getTime();
|
});
|
|
Date start = Optional.ofNullable(dto.getStartTime()).orElseGet(() -> {
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(end);
|
cal.add(Calendar.MINUTE, -1440); // 24小时前
|
return cal.getTime();
|
});
|
|
// 查询历史数据
|
ApiPointValueQueryDTO query = new ApiPointValueQueryDTO();
|
query.setPointNo(pointNo);
|
query.setStart(start);
|
query.setEnd(end);
|
|
log.info("开始查询发电机组功率历史数据，测点: {}", pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(query);
|
|
// 构建返回结果
|
PowerHistoryDTO result = new PowerHistoryDTO();
|
result.setCategories(DateUtils.getTimeScale(start, end, 60));
|
result.setDataList(chartData.stream()
|
.map(pv -> new Object[]{
|
DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND),
|
pv.getV()
|
})
|
.collect(Collectors.toList()));
|
|
return success(result);
|
}
|
|
@GetMapping("/capacitor-status/list")
|
@Operation(summary = "功率因数-电容器投退状态")
|
public CommonResult<List<PowerCapacitorStatusDTO>> getPowerCapacitorStatusList(@RequestParam Map<String, Object> params) {
|
List<PowerCapacitorStatusDTO> result = new ArrayList<>();
|
List<PowerCapacitorStatusEntity> list = powerCapacitorStatusService.list(params);
|
for (PowerCapacitorStatusEntity entity : list) {
|
PowerCapacitorStatusDTO dto = new PowerCapacitorStatusDTO();
|
dto.setId(entity.getId());
|
dto.setName(entity.getName());
|
dto.setRemark(entity.getRemark());
|
dto.setMainCount(DecimalUtil.toBigDecimal(entity.getMainCount()).intValue());
|
dto.setChildCount(DecimalUtil.toBigDecimal(entity.getChildCount()).intValue());
|
int onCount = 0;
|
Map<String, Object> params1 = new HashMap<>();
|
params1.put("statusId", entity.getId());
|
List<PowerCapacitorDetEntity> detList = powerCapacitorDetService.list(params1);
|
if (CollectionUtils.isEmpty(detList)) {
|
dto.setOnCount(onCount);
|
continue;
|
}
|
List<String> points = new ArrayList<>();
|
Map<String, Object> pointsRealValue = new HashMap<>();
|
for (PowerCapacitorDetEntity det : detList) {
|
if (StringUtils.isNotBlank(det.getPointNo())) {
|
points.add(det.getPointNo());
|
}
|
}
|
if (!CollectionUtils.isEmpty(points)) {
|
pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
}
|
for (PowerCapacitorDetEntity det : detList) {
|
if (StringUtils.isBlank(det.getId())) {
|
continue;
|
}
|
Object obj = pointsRealValue.get(det.getPointNo());
|
if (obj == null) {
|
continue;
|
}
|
BigDecimal pv = new BigDecimal(obj.toString());
|
if (pv.compareTo(BigDecimal.ZERO) <= 0) {
|
continue;
|
}
|
onCount++;
|
}
|
dto.setOnCount(onCount);
|
String remark = String.format("共%d台，在投%d台", DecimalUtil.toBigDecimal(entity.getMainCount()).intValue(), onCount);
|
dto.setRemark(remark);
|
result.add(dto);
|
}
|
return success(result);
|
}
|
|
@GetMapping("/capacitor-det/list")
|
@Operation(summary = "功率因数-电容器投退指示灯")
|
public CommonResult<List<PowerCapacitorDetDTO>> getPowerCapacitorDetList(@RequestParam Map<String, Object> params) {
|
List<PowerCapacitorDetEntity> list = powerCapacitorDetService.list(params);
|
log.info("list.size=" + list.size());
|
List<String> points = new ArrayList<>();
|
Map<String, Object> pointsRealValue = new HashMap<>();
|
for (PowerCapacitorDetEntity det : list) {
|
if (StringUtils.isNotBlank(det.getPointNo())) {
|
points.add(det.getPointNo());
|
}
|
}
|
if (!CollectionUtils.isEmpty(points)) {
|
pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
}
|
|
List<PowerCapacitorDetDTO> result = new ArrayList<>();
|
for (PowerCapacitorDetEntity entity : list) {
|
PowerCapacitorDetDTO dto = ConvertUtils.sourceToTarget(entity, PowerCapacitorDetDTO.class);
|
result.add(dto);
|
dto.setStatus(0);
|
if (!pointsRealValue.containsKey(entity.getPointNo()) || pointsRealValue.get(entity.getPointNo()) == null) {
|
continue;
|
}
|
BigDecimal val = new BigDecimal(pointsRealValue.get(entity.getPointNo()).toString());
|
if (val.compareTo(BigDecimal.ZERO) >= 0.1) {
|
dto.setStatus(1);
|
}
|
}
|
return success(result);
|
}
|
|
@GetMapping("/capacitor-his/list")
|
@Operation(summary = "功率因数-电容器投退历史")
|
public CommonResult<List<PowerCapacitorHisDTO>> getPowerCapacitorHisList(@RequestParam Map<String, Object> params) {
|
String statusId = (String) params.get("statusId");
|
if (StringUtils.isBlank(statusId)) {
|
return success(new ArrayList<>());
|
}
|
|
List<PowerCapacitorDetEntity> detList = powerCapacitorDetService.list(statusId);
|
List<String> detIds = detList.stream().map(PowerCapacitorDetEntity::getId).collect(Collectors.toList());
|
List<PowerCapacitorHisEntity> list = powerCapacitorHisService.list(detIds);
|
return success(ConvertUtils.sourceToTarget(list, PowerCapacitorHisDTO.class));
|
}
|
|
@PostMapping("/capacitor-his/page")
|
@Operation(summary = "功率因数-电容器投退历史（分页）")
|
public CommonResult<PageResult<PowerCapacitorHisDTO>> getPowerCapacitorHisPage(@RequestBody PowerCapacitorHisPageReqVO reqVO) {
|
if (StringUtils.isBlank(reqVO.getStatusId())) {
|
return error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
|
List<PowerCapacitorDetEntity> detList = powerCapacitorDetService.list(reqVO.getStatusId());
|
List<String> detIds = detList.stream().map(PowerCapacitorDetEntity::getId).collect(Collectors.toList());
|
reqVO.setDetIdList(detIds);
|
|
PageResult<PowerCapacitorHisEntity> data = powerCapacitorHisService.page(reqVO);
|
return success(BeanUtils.toBean(data, PowerCapacitorHisDTO.class));
|
}
|
|
@GetMapping("/control-main/list")
|
@Operation(summary = "功率因数-管控变电站列表(已废弃)")
|
public CommonResult<List<PowerControlMainDTO>> getPowerControlMainList(@RequestParam Map<String, Object> params) {
|
List<PowerControlMainEntity> list = powerControlMainService.list(params);
|
return success(ConvertUtils.sourceToTarget(list, PowerControlMainDTO.class));
|
}
|
|
@PostMapping("/control-main/update")
|
@Operation(summary = "功率因数-管控变电站修改上下限(已废弃)")
|
public CommonResult<Boolean> updatePowerControlMain(@RequestBody PowerControlMainDTO dto) {
|
if (StringUtils.isBlank(dto.getId())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
PowerControlMainEntity entity = new PowerControlMainEntity();
|
entity.setId(dto.getId());
|
entity.setLimitH(dto.getLimitH());
|
entity.setLimitL(dto.getLimitL());
|
powerControlMainService.update(entity);
|
return success(true);
|
}
|
|
@GetMapping("/control-det/list")
|
@Operation(summary = "功率因数-管控功率因数详情(已废弃)")
|
public CommonResult<List<PowerControlDetDTO>> getPowerControlDetList(@RequestParam Map<String, Object> params) {
|
List<PowerControlDetDTO> result = new ArrayList<>();
|
String name = (String) params.get("name");
|
if (StringUtils.isBlank(name)) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
PowerControlMainEntity main = powerControlMainService.getByName(name);
|
if (main == null) {
|
return CommonResult.error(GlobalErrorCodeConstants.NOT_FOUND);
|
}
|
List<PowerControlDetEntity> list = powerControlDetService.list(main.getId());
|
result = ConvertUtils.sourceToTarget(list, PowerControlDetDTO.class);
|
|
result.forEach(item -> {
|
/*BigDecimal rv = new BigDecimal(randomNumber * 0.001).setScale(4, BigDecimal.ROUND_HALF_UP);
|
item.setValue(rv);
|
if (item.getLimitL() != null && rv.compareTo(item.getLimitL()) < 0) {
|
item.setStatus(1);
|
} else {
|
item.setStatus(0);
|
}*/
|
});
|
return success(result);
|
}
|
|
@GetMapping("/demand/list")
|
@Operation(summary = "负荷移植-月最大需量，实测需量，有功功率")
|
public CommonResult<List<PowerDemandDTO>> getPowerDemandList(@RequestParam Map<String, Object> params) {
|
log.info("负荷移植-月最大需量，实测需量，有功功率");
|
List<PowerDemandDTO> result = new ArrayList<>();
|
List<PowerDemandEntity> list = powerDemandService.list(params);
|
if (CollectionUtils.isEmpty(list)) {
|
log.info("list.size=" + list.size());
|
return success(result);
|
}
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.DAY_OF_MONTH, 1);
|
Date start = calendar.getTime();
|
Date end = new Date();
|
|
for (PowerDemandEntity entity : list) {
|
PowerDemandDTO demandDTO = new PowerDemandDTO();
|
demandDTO.setId(entity.getId());
|
demandDTO.setCode(entity.getCode());
|
demandDTO.setName(entity.getName());
|
|
List<String> points = new ArrayList<>();
|
if (StringUtils.isNotBlank(entity.getCurDemand())) {
|
points.add(entity.getCurDemand());
|
}
|
if (StringUtils.isNotBlank(entity.getActivePower())) {
|
points.add(entity.getActivePower());
|
}
|
if (!CollectionUtils.isEmpty(points)) {
|
Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
if (pointsRealValue.get(entity.getCurDemand()) != null) {
|
demandDTO.setCurDemand(new BigDecimal(pointsRealValue.get(entity.getCurDemand()).toString()));
|
}
|
if (pointsRealValue.get(entity.getActivePower()) != null) {
|
demandDTO.setActivePower(new BigDecimal(pointsRealValue.get(entity.getActivePower()).toString()));
|
}
|
}
|
|
if (!StringUtils.isEmpty(entity.getMaxDemand())) {
|
/*ApiPointValueQueryDTO apiPointValueQueryDTO = new ApiPointValueQueryDTO();
|
apiPointValueQueryDTO.setStart(start);
|
apiPointValueQueryDTO.setEnd(end);
|
apiPointValueQueryDTO.setPointNo(entity.getMaxDemand());
|
Map<String, Object> maxValue = dataPointApi.queryPointMaxTimeValue(apiPointValueQueryDTO);
|
if (maxValue != null) {
|
demandDTO.setMaxDemand(new BigDecimal(maxValue.get(VALUE).toString()));
|
demandDTO.setOccurTime(DateUtils.parse( maxValue.get(TIME).toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
|
}*/
|
PowerMaxdemandMainEntity maxdemandMainEntity = powerMaxDemandMainService.getMonthMax(entity.getCode(), start);
|
if (maxdemandMainEntity != null) {
|
demandDTO.setMaxDemand(maxdemandMainEntity.getMaxDemand());
|
demandDTO.setOccurTime(maxdemandMainEntity.getOccurTime());
|
} else {
|
demandDTO.setMaxDemand(BigDecimal.ZERO);
|
}
|
}
|
result.add(demandDTO);
|
}
|
return success(result);
|
}
|
|
@GetMapping("/demand-dropdown/list")
|
@Operation(summary = "负荷移植-功率因数下拉列表")
|
public CommonResult<List<PowerNetDropdownDTO>> getDemandDropdownList(@RequestParam String code) {
|
if (StringUtils.isBlank(code)) {
|
log.info("code isBlank");
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
log.info("code=" + code);
|
|
List<PowerNetDropdownDTO> result = new ArrayList<>();
|
PowerDemandEntity entity = powerDemandService.getByCode(code);
|
if (entity == null) {
|
log.info("PowerDemandEntity is null");
|
return success(result);
|
}
|
List<PowerNetDropdownEntity> list = new ArrayList<>();
|
Map<String, Object> params0 = new HashMap<>();
|
params0.put("groupName", entity.getName());
|
List<PowerNetDropdownEntity> list0 = powerNetDropdownService.list(params0);
|
if (!CollectionUtils.isEmpty(list0)) {
|
list.addAll(list0);
|
}
|
|
// 所有关口进线的二级界面（表格/曲线）均增加（CCPP/135/CDQ/TRT/余热）的选项。
|
Map<String, Object> params1 = new HashMap<>();
|
params1.put("groupName", "COMMON1");
|
List<PowerNetDropdownEntity> list1 = powerNetDropdownService.list(params1);
|
if (!CollectionUtils.isEmpty(list1)) {
|
list.addAll(list1);
|
}
|
|
Map<String, Object> params2 = new HashMap<>();
|
params2.put("groupName", "COMMON2");
|
List<PowerNetDropdownEntity> list2 = powerNetDropdownService.list(params2);
|
if (!CollectionUtils.isEmpty(list2)) {
|
list.addAll(list2);
|
}
|
|
List<String> points = list.stream().map(item -> {
|
return item.getCurCos();
|
}).collect(Collectors.toList());
|
Map<String, Object> pointsRealValue = new HashMap<>();
|
if (!CollectionUtils.isEmpty(points)) {
|
pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
}
|
for (PowerNetDropdownEntity netDropdown : list) {
|
PowerNetDropdownDTO dto = ConvertUtils.sourceToTarget(netDropdown, PowerNetDropdownDTO.class);
|
BigDecimal curCos = BigDecimal.ZERO;
|
if (pointsRealValue.get(netDropdown.getCurCos()) != null) {
|
curCos = new BigDecimal(pointsRealValue.get(netDropdown.getCurCos()).toString());
|
}
|
dto.setCurCos(curCos);
|
result.add(dto);
|
}
|
return success(result);
|
}
|
|
@PostMapping("/demand-query/list")
|
@Operation(summary = "负荷移植-需量值查询")
|
public CommonResult<List<PowerDemandQueryRespDTO>> getDemandQueryList(@RequestBody PowerDemandQueryDTO queryDto) {
|
List<PowerDemandQueryRespDTO> result = new ArrayList<>();
|
if (StringUtils.isBlank(queryDto.getCode())) {
|
log.info("code isBlank");
|
return success(result);
|
}
|
PowerDemandEntity entity = powerDemandService.getByCode(queryDto.getCode());
|
if (entity == null) {
|
log.info("PowerDemandEntity is null");
|
return success(result);
|
}
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.SECOND, 0);
|
Date startTime = queryDto.getStartTime();
|
Date endTime = queryDto.getEndTime();
|
if (endTime == null) {
|
endTime = calendar.getTime();
|
}
|
if (startTime == null) {
|
calendar.add(Calendar.DAY_OF_YEAR, -1);
|
startTime = calendar.getTime();
|
}
|
|
Map<String, Object> params0 = new HashMap<>();
|
params0.put("groupName", entity.getName());
|
List<PowerNetDropdownEntity> dropdownList = powerNetDropdownService.list(params0);
|
List<String> pointNos = new ArrayList<>();
|
Map<String, String> demandPointMap = new HashMap<>();
|
for (PowerNetDropdownEntity netDropdown : dropdownList) {
|
demandPointMap.put(netDropdown.getNodeCode(), netDropdown.getExt1());
|
if (StringUtils.isNotBlank(netDropdown.getExt1())) {
|
pointNos.add(netDropdown.getExt1());
|
}
|
}
|
for (PowerNetDropdownEntity netDropdown : dropdownList) {
|
PowerDemandQueryRespDTO dto = ConvertUtils.sourceToTarget(netDropdown, PowerDemandQueryRespDTO.class);
|
dto.setCurDemand(null);
|
result.add(dto);
|
}
|
if (queryDto.getCurDemand() == null) {
|
log.info("查询值为空，显示空白");
|
return success(result);
|
}
|
ApiPointValueQueryDTO queryCodeValue = new ApiPointValueQueryDTO();
|
queryCodeValue.setStart(startTime);
|
queryCodeValue.setEnd(endTime);
|
queryCodeValue.setPointNo(entity.getCurDemand());
|
List<ApiPointValueDTO> codeValueList = dataPointApi.queryPointHistoryValue(queryCodeValue);
|
if (CollectionUtils.isEmpty(codeValueList)) {
|
return success(result);
|
}
|
ApiPointValueDTO curValue = new ApiPointValueDTO();
|
for (ApiPointValueDTO valueDTO : codeValueList) {
|
if (Math.abs(queryDto.getCurDemand().doubleValue() - valueDTO.getV()) <= 0.0001) {
|
log.info("curValue is find");
|
curValue = valueDTO;
|
break;
|
}
|
}
|
log.info("curValue={}", curValue);
|
if (curValue.getT() == null) {
|
log.info("curValue is not find");
|
return success(result);
|
}
|
|
Calendar calendar1 = Calendar.getInstance();
|
calendar1.setTime(curValue.getT());
|
ApiPointsValueQueryDTO valueQueryDTO = new ApiPointsValueQueryDTO();
|
valueQueryDTO.setPointNos(pointNos);
|
valueQueryDTO.setEnd(calendar1.getTime());
|
calendar1.add(Calendar.MINUTE, -1);
|
valueQueryDTO.setStart(calendar1.getTime());
|
Map<String, List<Map<String, Object>>> pointsHisValues = dataPointApi.queryPointsHistoryValue(valueQueryDTO);
|
if (CollectionUtils.isEmpty(pointsHisValues)) {
|
log.info("pointsHisValues is null");
|
return success(result);
|
}
|
for (PowerDemandQueryRespDTO respDTO : result) {
|
if (StringUtils.isBlank(demandPointMap.get(respDTO.getNodeCode()))) {
|
continue;
|
}
|
List<Map<String, Object>> hisList = pointsHisValues.get(demandPointMap.get(respDTO.getNodeCode()));
|
if (CollectionUtils.isEmpty(hisList)) {
|
continue;
|
}
|
Map<String, Object> valueMap = hisList.get(hisList.size() - 1);
|
respDTO.setDataTime(DateUtils.parse(valueMap.get("time").toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
|
respDTO.setCurDemand(DecimalUtil.toBigDecimal(valueMap.get("value")));
|
}
|
return success(result);
|
}
|
|
/**
|
* 导出功率日累计
|
* 月报表导出：最大值、最小值、平均值、受电累计、返送累计
|
* 日功率因数二级界面：最大值、最小值、平均值、日功率因数
|
* 月功率因数二级界面：最大值、最小值、平均值、月功率因数
|
*
|
* @param response
|
* @param request
|
* @param dto
|
*/
|
@PostMapping("/net-factor/export-day")
|
@Operation(summary = "功率因数-电网拓扑功率导出(功率日累计)")
|
public void getPowerFactorExportDay(HttpServletResponse response, HttpServletRequest
|
request, @RequestBody PowerFactorExcelReqDTO dto) throws IOException {
|
|
List<PowerExportPqVO> exportPqList = new ArrayList<>();
|
List<PowerExportCosVO> exportCos = new ArrayList<>();
|
|
if (dto.getStartTime() == null) {
|
dto.setStartTime(new Date());
|
}
|
if (dto.getEndTime() == null) {
|
dto.setEndTime(new Date());
|
}
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(dto.getStartTime());
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
Date startTime = calendar.getTime();
|
calendar.setTime(dto.getEndTime());
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 59);
|
calendar.set(Calendar.HOUR_OF_DAY, 23);
|
Date endTime = calendar.getTime();
|
|
String pointNo = "=";
|
String[] pointNoArr = new String[2];
|
String queryType = dto.getQueryType();
|
PowerNetFactorEntity powerNetFactorEntity = powerNetFactorService.getByNodeCode(dto.getNodeCode());
|
Calendar curDay = Calendar.getInstance();
|
curDay.setTime(startTime);
|
do {
|
log.info("do excel");
|
PowerFactorExcelDTO excelDTO = new PowerFactorExcelDTO();
|
switch (queryType.toUpperCase()) {
|
case "P":
|
pointNo = powerNetFactorEntity.getCurP();
|
break;
|
case "Q":
|
pointNo = powerNetFactorEntity.getCurQ();
|
break;
|
case "DAYCOS":
|
pointNoArr[0] = powerNetFactorEntity.getPDay();
|
pointNoArr[1] = powerNetFactorEntity.getQDay();
|
break;
|
case "MONTHCOS":
|
pointNoArr[0] = powerNetFactorEntity.getPMon();
|
pointNoArr[1] = powerNetFactorEntity.getQMon();
|
break;
|
default:
|
return;
|
}
|
|
ApiPointValueQueryDTO apiPointValueQueryDTO = new ApiPointValueQueryDTO();
|
apiPointValueQueryDTO.setStart(curDay.getTime());
|
curDay.add(Calendar.DAY_OF_YEAR, 1);
|
apiPointValueQueryDTO.setEnd(curDay.getTime());
|
List<Double> valueList = new ArrayList<>();
|
Double lastValue = null;
|
if (StringUtils.isNotBlank(pointNo)) {
|
// 单点
|
apiPointValueQueryDTO.setPointNo(pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
for (ApiPointValueDTO pv : chartData) {
|
Object[] data = new Object[2];
|
data[0] = DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
|
data[1] = pv.getV();
|
valueList.add(pv.getV());
|
}
|
} else if (StringUtils.isNotBlank(pointNoArr[0]) && StringUtils.isNotBlank(pointNoArr[1])) {
|
List<String> categories = new ArrayList<>();
|
|
// P/Q
|
apiPointValueQueryDTO.setPointNo(pointNoArr[0]);
|
List<ApiPointValueDTO> chartDataP = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapP = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataP) {
|
categories.add(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
|
dataMapP.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
apiPointValueQueryDTO.setPointNo(pointNoArr[1]);
|
List<ApiPointValueDTO> chartDataQ = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapQ = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataQ) {
|
dataMapQ.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
for (String cate : categories) {
|
Double cos = PowerUtil.calculateCos(dataMapP.get(cate), dataMapQ.get(cate));
|
valueList.add(cos);
|
}
|
|
}
|
|
double max = 0;
|
double min = 0;
|
double avg = 0;
|
if (!CollectionUtils.isEmpty(valueList)) {
|
max = valueList.stream().mapToDouble(Double::doubleValue).max().getAsDouble();
|
min = valueList.stream().mapToDouble(Double::doubleValue).min().getAsDouble();
|
avg = valueList.stream().mapToDouble(Double::doubleValue).average().getAsDouble();
|
}
|
|
if ("P".equals(queryType.toUpperCase()) || "Q".equals(queryType.toUpperCase())) {
|
PowerExportPqVO evo = new PowerExportPqVO();
|
double sdl = 0;
|
double fsl = 0;
|
if (!CollectionUtils.isEmpty(valueList)) {
|
if (powerNetFactorEntity.getCurFlag() != null && powerNetFactorEntity.getCurFlag().intValue() != 0) {
|
for ( Double val : valueList) {
|
if (new BigDecimal(val).compareTo(BigDecimal.ZERO) != powerNetFactorEntity.getCurFlag()) {
|
// 未发生返送
|
sdl += val;
|
} else {
|
// 发生返送
|
fsl += val;
|
}
|
}
|
}
|
}
|
evo.setSdl(new BigDecimal(sdl).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setFsl(new BigDecimal(fsl).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setMax(new BigDecimal(max).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setMin(new BigDecimal(min).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setAvg(new BigDecimal(avg).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setDate(DateUtils.format(apiPointValueQueryDTO.getStart()));
|
exportPqList.add(evo);
|
} else if ("DAYCOS".equals(queryType.toUpperCase()) || "MONTHCOS".equals(queryType.toUpperCase())) {
|
double dayLast = 0;
|
if (!CollectionUtils.isEmpty(valueList)) {
|
dayLast = valueList.get(valueList.size() - 1);
|
}
|
PowerExportCosVO evo = new PowerExportCosVO();
|
evo.setCos(new BigDecimal(dayLast).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setMax(new BigDecimal(max).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setMin(new BigDecimal(min).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setAvg(new BigDecimal(avg).setScale(2, BigDecimal.ROUND_HALF_UP));
|
evo.setDate(DateUtils.format(apiPointValueQueryDTO.getStart()));
|
exportCos.add(evo);
|
}
|
|
} while (curDay.getTime().getTime() <= endTime.getTime());
|
|
if ("P".equals(queryType.toUpperCase()) || "Q".equals(queryType.toUpperCase())) {
|
String name = powerNetFactorEntity.getNodeName() +
|
queryType.toUpperCase().replace("P", "有功").replace("Q", "无功") +
|
"功率报表.xls";
|
ExcelUtils.write(response, name, "功率数据", PowerExportPqVO.class, exportPqList);
|
} else if ("DAYCOS".equals(queryType.toUpperCase()) || "MONTHCOS".equals(queryType.toUpperCase())) {
|
String name = powerNetFactorEntity.getNodeName() +
|
queryType.toUpperCase().replace("DAYCOS", "日").replace("MONTHCOS", "月") +
|
"功率因数报表.xls";
|
ExcelUtils.write(response, name, "功率数据", PowerExportPqVO.class, exportPqList);
|
}
|
}
|
|
@PostMapping("/net-factor/history")
|
@Operation(summary = "功率因数-电网拓扑功率历史")
|
public CommonResult<PowerHistoryDTO> getPowerHistoryData(@RequestBody PowerNetFactorHisReqDTO dto) {
|
log.info("PowerNetFactorHisReqDTO=" + JSONObject.toJSONString(dto));
|
PowerHistoryDTO result = new PowerHistoryDTO();
|
String nodeCode = dto.getNodeCode();
|
if (StringUtils.isBlank(nodeCode)) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
String queryType = dto.getQueryType();
|
if (StringUtils.isBlank(queryType)) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
PowerNetFactorQuery powerNetFactorQuery = null;
|
PowerNetFactorEntity powerNetFactorEntity = powerNetFactorService.getByNodeCode(nodeCode);
|
PowerNetDropdownEntity powerNetDropdownEntity = powerNetDropdownService.getByNodeCode(nodeCode);
|
if (powerNetFactorEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetFactorEntity, PowerNetFactorQuery.class);
|
} else if (powerNetDropdownEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetDropdownEntity, PowerNetFactorQuery.class);
|
}
|
if (powerNetFactorQuery == null) {
|
log.info("powerNetFactor is null");
|
return success(result);
|
}
|
log.info("开始查询，");
|
ApiPointValueQueryDTO apiPointValueQueryDTO = new ApiPointValueQueryDTO();
|
String pointNo = "";
|
String[] pointNoArr = new String[2];
|
switch (queryType.toUpperCase()) {
|
case "P":
|
pointNo = powerNetFactorQuery.getCurP();
|
break;
|
case "Q":
|
pointNo = powerNetFactorQuery.getCurQ();
|
break;
|
case "COS":
|
pointNo = powerNetFactorQuery.getCurCos();
|
break;
|
case "DAYCOS":
|
pointNoArr[0] = powerNetFactorEntity.getPDay();
|
pointNoArr[1] = powerNetFactorEntity.getQDay();
|
break;
|
case "MONTHCOS":
|
pointNoArr[0] = powerNetFactorEntity.getPMon();
|
pointNoArr[1] = powerNetFactorEntity.getQMon();
|
break;
|
default:
|
break;
|
}
|
|
|
//查询图表
|
List<Object[]> dataList = new ArrayList<>();
|
|
Calendar calendar0 = Calendar.getInstance();
|
calendar0.set(Calendar.MILLISECOND, 0);
|
calendar0.set(Calendar.SECOND, 0);
|
Date end = dto.getEndTime() == null ? calendar0.getTime() : dto.getEndTime();
|
calendar0.add(Calendar.MINUTE, -1440);
|
Date start = dto.getStartTime() == null ? calendar0.getTime() : dto.getStartTime();
|
apiPointValueQueryDTO.setEnd(end);
|
apiPointValueQueryDTO.setStart(start);
|
|
List<String> categories = DateUtils.getTimeScale(start, end, 60);
|
result.setCategories(categories);
|
if (StringUtils.isNotBlank(pointNo)) {
|
apiPointValueQueryDTO.setPointNo(pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
for (ApiPointValueDTO pv : chartData) {
|
Object[] data = new Object[2];
|
data[0] = DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
|
data[1] = pv.getV();
|
dataList.add(data);
|
}
|
|
} else if (StringUtils.isNotBlank(pointNoArr[0]) && StringUtils.isNotBlank(pointNoArr[1])) {
|
apiPointValueQueryDTO.setPointNo(pointNoArr[0]);
|
List<ApiPointValueDTO> chartDataP = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapP = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataP) {
|
dataMapP.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
apiPointValueQueryDTO.setPointNo(pointNoArr[1]);
|
List<ApiPointValueDTO> chartDataQ = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapQ = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataQ) {
|
dataMapQ.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
for (String cate : categories) {
|
Object[] data = new Object[2];
|
data[0] = cate;
|
data[1] = PowerUtil.calculateCos(dataMapP.get(cate), dataMapQ.get(cate));
|
dataList.add(data);
|
}
|
}
|
|
result.setDataList(dataList);
|
|
//查询月最大最小值
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.DAY_OF_MONTH, 1);
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MILLISECOND, 0);
|
start = calendar.getTime();
|
apiPointValueQueryDTO.setStart(start);
|
apiPointValueQueryDTO.setEnd(new Date());
|
Map<String, Object> maxV = dataPointApi.queryPointMaxValueRange(apiPointValueQueryDTO);
|
Map<String, Object> minV = dataPointApi.queryPointMaxValueRange(apiPointValueQueryDTO);
|
if (maxV != null && maxV.containsKey(pointNo)) {
|
result.setMax(new BigDecimal(maxV.get(pointNo).toString()));
|
}
|
if (minV != null && minV.containsKey(pointNo)) {
|
result.setMin(new BigDecimal(minV.get(pointNo).toString()));
|
}
|
return success(result);
|
}
|
|
@PostMapping("/net-factor/export-history")
|
@Operation(summary = "功率因数-电网拓扑功率历史导出(多code)")
|
public void exportPowerHistoryList(HttpServletResponse response, HttpServletRequest
|
request, @RequestBody PowerNetFactorHisReqDTO dto) throws IOException {
|
log.info("exportPowerHistoryList开始");
|
String firstCol = "时间";
|
List<String> column = new ArrayList<>();
|
column.add(firstCol);
|
List<List<Object>> exportData = new ArrayList<>();
|
|
List<String> nodeCodeList = dto.getNodeCodeList();
|
if (CollectionUtils.isEmpty(nodeCodeList)) {
|
return;
|
}
|
String queryType = dto.getQueryType();
|
if (StringUtils.isBlank(queryType)) {
|
return;
|
}
|
Calendar calendar0 = Calendar.getInstance();
|
calendar0.set(Calendar.MILLISECOND, 0);
|
calendar0.set(Calendar.SECOND, 0);
|
Date end0 = dto.getEndTime() == null ? calendar0.getTime() : dto.getEndTime();
|
calendar0.set(Calendar.MINUTE, 0);
|
calendar0.set(Calendar.HOUR_OF_DAY, 0);
|
Date start0 = dto.getStartTime() == null ? calendar0.getTime() : dto.getStartTime();
|
|
Map<String, Map<String, Object>> dataAll = new HashMap<>();
|
List<String> categories = DateUtils.getTimeScale(start0, end0, 60);
|
for (String nodeCode : nodeCodeList) {
|
PowerNetFactorQuery powerNetFactorQuery = null;
|
PowerNetFactorEntity powerNetFactorEntity = powerNetFactorService.getByNodeCode(nodeCode);
|
PowerNetDropdownEntity powerNetDropdownEntity = powerNetDropdownService.getByNodeCode(nodeCode);
|
if (powerNetFactorEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetFactorEntity, PowerNetFactorQuery.class);
|
} else if (powerNetDropdownEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetDropdownEntity, PowerNetFactorQuery.class);
|
}
|
if (powerNetFactorQuery == null) {
|
log.info("powerNetFactor is null");
|
continue;
|
}
|
column.add(powerNetFactorQuery.getNodeName());
|
|
log.info("开始查询，");
|
ApiPointValueQueryDTO apiPointValueQueryDTO = new ApiPointValueQueryDTO();
|
String pointNo = "";
|
String[] pointNoArr = new String[2];
|
switch (queryType.toUpperCase()) {
|
case "P":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurP())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurP();
|
break;
|
case "Q":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurQ())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurQ();
|
break;
|
case "COS":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurCos())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurCos();
|
break;
|
case "DAYCOS":
|
if (powerNetFactorEntity == null ||
|
StringUtils.isBlank(powerNetFactorEntity.getPDay()) || StringUtils.isBlank(powerNetFactorEntity.getQDay())) {
|
continue;
|
}
|
pointNoArr[0] = powerNetFactorEntity.getPDay();
|
pointNoArr[1] = powerNetFactorEntity.getQDay();
|
break;
|
case "MONTHCOS":
|
if (powerNetFactorEntity == null ||
|
StringUtils.isBlank(powerNetFactorEntity.getPMon()) || StringUtils.isBlank(powerNetFactorEntity.getQMon())) {
|
continue;
|
}
|
pointNoArr[0] = powerNetFactorEntity.getPMon();
|
pointNoArr[1] = powerNetFactorEntity.getQMon();
|
break;
|
default:
|
break;
|
}
|
|
//查询图表
|
apiPointValueQueryDTO.setEnd(end0);
|
apiPointValueQueryDTO.setStart(start0);
|
Map<String, Object> dataMap = new HashMap<>();
|
|
if (StringUtils.isNotBlank(pointNo)) {
|
log.info("查询功率");
|
apiPointValueQueryDTO.setPointNo(pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
for (ApiPointValueDTO pv : chartData) {
|
String key = DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
|
Object val = pv.getV();
|
dataMap.put(key, val);
|
}
|
} else if (StringUtils.isNotBlank(pointNoArr[0]) && StringUtils.isNotBlank(pointNoArr[1])) {
|
log.info("查询累计功率");
|
apiPointValueQueryDTO.setPointNo(pointNoArr[0]);
|
List<ApiPointValueDTO> chartDataP = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapP = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataP) {
|
dataMapP.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
apiPointValueQueryDTO.setPointNo(pointNoArr[1]);
|
List<ApiPointValueDTO> chartDataQ = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapQ = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataQ) {
|
dataMapQ.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
for (String cate : categories) {
|
Double cos = PowerUtil.calculateCos(dataMapP.get(cate), dataMapQ.get(cate));
|
Object val = cos == null ? 0 : new BigDecimal(cos).setScale(2, BigDecimal.ROUND_HALF_UP);
|
dataMap.put(cate, val);
|
}
|
|
}
|
dataAll.put(powerNetFactorQuery.getNodeName(), dataMap);
|
}
|
log.info("column=" + JSONArray.toJSONString(column));
|
for (String cate : categories) {
|
List<Object> row = new ArrayList<>();
|
for (String col : column) {
|
if (firstCol.equals(col)) {
|
row.add(cate);
|
} else if (dataAll.get(col) == null) {
|
log.info(col + " is null");
|
row.add("");
|
} else if (dataAll.get(col).get(cate) == null) {
|
log.info(col + cate + " is null");
|
row.add("");
|
} else {
|
row.add(dataAll.get(col).get(cate));
|
}
|
}
|
exportData.add(row);
|
}
|
log.info("exportData.size=" + exportData.size());
|
ExcelUtils.write(response, "历史.xlsx", "历史数据", column, exportData);
|
}
|
|
@PostMapping("/net-factor/history-list")
|
@Operation(summary = "功率因数-电网拓扑功率历史(多code)")
|
public CommonResult<LinkedHashMap<String, PowerHistoryDTO>> getPowerHistoryList(@RequestBody PowerNetFactorHisReqDTO dto) {
|
log.info("PowerNetFactorHisReqDTO=" + JSONObject.toJSONString(dto));
|
LinkedHashMap<String, PowerHistoryDTO> result = new LinkedHashMap<>();
|
List<String> nodeCodeList = dto.getNodeCodeList();
|
if (CollectionUtils.isEmpty(nodeCodeList)) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
String queryType = dto.getQueryType();
|
if (StringUtils.isBlank(queryType)) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
Calendar calendar0 = Calendar.getInstance();
|
calendar0.set(Calendar.MILLISECOND, 0);
|
calendar0.set(Calendar.SECOND, 0);
|
Date end0 = dto.getEndTime() == null ? calendar0.getTime() : dto.getEndTime();
|
calendar0.set(Calendar.MINUTE, 0);
|
calendar0.set(Calendar.HOUR_OF_DAY, 0);
|
Date start0 = dto.getStartTime() == null ? calendar0.getTime() : dto.getStartTime();
|
|
|
List<String> categories = DateUtils.getTimeScale(start0, end0, 60);
|
for (String nodeCode : nodeCodeList) {
|
PowerHistoryDTO powerHistoryDTO = new PowerHistoryDTO();
|
PowerNetFactorQuery powerNetFactorQuery = null;
|
PowerNetFactorEntity powerNetFactorEntity = powerNetFactorService.getByNodeCode(nodeCode);
|
PowerNetDropdownEntity powerNetDropdownEntity = powerNetDropdownService.getByNodeCode(nodeCode);
|
if (powerNetFactorEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetFactorEntity, PowerNetFactorQuery.class);
|
} else if (powerNetDropdownEntity != null) {
|
powerNetFactorQuery = ConvertUtils.sourceToTarget(powerNetDropdownEntity, PowerNetFactorQuery.class);
|
}
|
if (powerNetFactorQuery == null) {
|
log.info("powerNetFactor is null");
|
continue;
|
}
|
|
log.info("开始查询，");
|
ApiPointValueQueryDTO apiPointValueQueryDTO = new ApiPointValueQueryDTO();
|
String pointNo = "";
|
String[] pointNoArr = new String[2];
|
switch (queryType.toUpperCase()) {
|
case "P":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurP())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurP();
|
break;
|
case "Q":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurQ())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurQ();
|
break;
|
case "COS":
|
if (StringUtils.isBlank(powerNetFactorQuery.getCurCos())) {
|
continue;
|
}
|
pointNo = powerNetFactorQuery.getCurCos();
|
break;
|
case "DAYCOS":
|
if (powerNetFactorEntity == null ||
|
StringUtils.isBlank(powerNetFactorEntity.getPDay()) || StringUtils.isBlank(powerNetFactorEntity.getQDay())) {
|
continue;
|
}
|
pointNoArr[0] = powerNetFactorEntity.getPDay();
|
pointNoArr[1] = powerNetFactorEntity.getQDay();
|
break;
|
case "MONTHCOS":
|
if (powerNetFactorEntity == null ||
|
StringUtils.isBlank(powerNetFactorEntity.getPMon()) || StringUtils.isBlank(powerNetFactorEntity.getQMon())) {
|
continue;
|
}
|
pointNoArr[0] = powerNetFactorEntity.getPMon();
|
pointNoArr[1] = powerNetFactorEntity.getQMon();
|
break;
|
default:
|
break;
|
}
|
|
//查询图表
|
apiPointValueQueryDTO.setEnd(end0);
|
apiPointValueQueryDTO.setStart(start0);
|
List<Object[]> dataList = new ArrayList<>();
|
List<Double> valueList = new ArrayList<>();
|
double max = 0;
|
double min = 0;
|
double avg = 0;
|
String maxTime = "";
|
String minTime = "";
|
|
if (StringUtils.isNotBlank(pointNo)) {
|
apiPointValueQueryDTO.setPointNo(pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
for (ApiPointValueDTO pv : chartData) {
|
Object[] data = new Object[2];
|
data[0] = DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
|
data[1] = pv.getV();
|
dataList.add(data);
|
valueList.add(pv.getV());
|
}
|
|
// 返送累计
|
double fsl = 0;
|
if (!CollectionUtils.isEmpty(valueList)) {
|
if (powerNetFactorQuery.getCurFlag() != null && powerNetFactorQuery.getCurFlag().intValue() != 0) {
|
for ( Double val : valueList) {
|
if (new BigDecimal(val).compareTo(BigDecimal.ZERO) != powerNetFactorQuery.getCurFlag()) {
|
// 未发生返送
|
continue;
|
}
|
fsl += val;
|
}
|
}
|
}
|
powerHistoryDTO.setFsl(new BigDecimal(fsl).setScale(2, BigDecimal.ROUND_HALF_UP));
|
} else if (StringUtils.isNotBlank(pointNoArr[0]) && StringUtils.isNotBlank(pointNoArr[1])) {
|
apiPointValueQueryDTO.setPointNo(pointNoArr[0]);
|
List<ApiPointValueDTO> chartDataP = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapP = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataP) {
|
dataMapP.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
apiPointValueQueryDTO.setPointNo(pointNoArr[1]);
|
List<ApiPointValueDTO> chartDataQ = dataPointApi.queryPointHistoryValue(apiPointValueQueryDTO);
|
Map<String, Double> dataMapQ = new HashMap<>();
|
for (ApiPointValueDTO pv : chartDataQ) {
|
dataMapQ.put(DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND), pv.getV());
|
}
|
|
for (String cate : categories) {
|
Double cos = PowerUtil.calculateCos(dataMapP.get(cate), dataMapQ.get(cate));
|
if (cos == null) {
|
continue;
|
}
|
Object[] data = new Object[2];
|
data[0] = cate;
|
data[1] = cos;
|
dataList.add(data);
|
valueList.add(cos);
|
}
|
}
|
|
if (!CollectionUtils.isEmpty(valueList)) {
|
// max = valueList.stream().mapToDouble(Double::doubleValue).max().getAsDouble();
|
// min = valueList.stream().mapToDouble(Double::doubleValue).min().getAsDouble();
|
avg = valueList.stream().mapToDouble(Double::doubleValue).average().getAsDouble();
|
max = valueList.get(0).doubleValue();
|
min = valueList.get(0).doubleValue();
|
for (Object[] dataItem : dataList) {
|
String time = (String) dataItem[0];
|
double value = (double)dataItem[1];
|
if (value > max) {
|
max = value;
|
maxTime = time;
|
}
|
if (value < min) {
|
min = value;
|
minTime = time;
|
}
|
}
|
}
|
|
powerHistoryDTO.setMax(new BigDecimal(max).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setMin(new BigDecimal(min).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setAvg(new BigDecimal(avg).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setMaxTime(maxTime);
|
powerHistoryDTO.setMinTime(minTime);
|
powerHistoryDTO.setDataList(dataList);
|
result.put(nodeCode, powerHistoryDTO);
|
}
|
return success(result);
|
}
|
|
@GetMapping("/adjust-factor")
|
@Operation(summary = "功率因数-调整后的功率因数与无功倒送量")
|
public CommonResult<Map<String, Double>> getPowerAdjustFactor(@RequestParam Map<String, Object> params) {
|
List<PowerAdjustedFactorEntity> list = powerAdjustedFactorService.list(params);
|
List<PowerAdjustedFactorDTO> dtoList = ConvertUtils.sourceToTarget(list, PowerAdjustedFactorDTO.class);
|
Map<String, Double> result = new HashMap<>();
|
if (CollectionUtils.isEmpty(list)) {
|
log.info("PowerAdjustedFactor List is empty");
|
return success(result);
|
}
|
List<String> points = new ArrayList<>();
|
Map<String, Object> dataMap = new HashMap<>();
|
for (PowerAdjustedFactorDTO dto : dtoList) {
|
if (StringUtils.isNotBlank(dto.getPointNo())) {
|
points.add(dto.getPointNo());
|
}
|
}
|
if (!CollectionUtils.isEmpty(points)) {
|
dataMap = dataPointApi.queryPointsRealValue(points);
|
}
|
|
for (PowerAdjustedFactorDTO powerAdjustedFactorDTO : dtoList) {
|
Double value = dataMap.get(powerAdjustedFactorDTO.getPointNo()) == null ? 0 : Double.parseDouble(dataMap.get(powerAdjustedFactorDTO.getPointNo()).toString());
|
result.put(powerAdjustedFactorDTO.getName(), value);
|
}
|
return success(result);
|
}
|
|
@PostMapping("/demand/history")
|
@Operation(summary = "负荷移植-实测需量有功功率历史")
|
public CommonResult<PowerHistoryDTO> getPowerDemandHistory(@RequestBody PowerDemandHisReqDTO dto) {
|
log.info("请求参数: {}", JSONObject.toJSONString(dto));
|
|
// 参数校验
|
if (StringUtils.isBlank(dto.getCode())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "code不能为空");
|
}
|
if (StringUtils.isBlank(dto.getQueryType())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "queryType不能为空");
|
}
|
|
PowerDemandEntity powerDemand = powerDemandService.getByCode(dto.getCode());
|
if (powerDemand == null) {
|
log.info("未找到code对应的数据: {}", dto.getCode());
|
return success(new PowerHistoryDTO());
|
}
|
|
String queryType = dto.getQueryType().toUpperCase();
|
String pointNo;
|
switch (queryType.toUpperCase()) {
|
case "D":
|
pointNo = powerDemand.getCurDemand();
|
break;
|
case "P":
|
pointNo = powerDemand.getActivePower();
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的queryType: " + queryType);
|
}
|
|
// 默认查最近24小时
|
Date end = Optional.ofNullable(dto.getEndTime()).orElseGet(() -> {
|
Calendar cal = Calendar.getInstance();
|
cal.set(Calendar.MILLISECOND, 0);
|
cal.set(Calendar.SECOND, 0);
|
return cal.getTime();
|
});
|
|
Date start = Optional.ofNullable(dto.getStartTime()).orElseGet(() -> {
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(end);
|
cal.add(Calendar.MINUTE, -1440); // 24小时前
|
return cal.getTime();
|
});
|
|
// 查询历史数据
|
ApiPointValueQueryDTO query = new ApiPointValueQueryDTO();
|
query.setPointNo(pointNo);
|
query.setStart(start);
|
query.setEnd(end);
|
|
log.info("开始查询实测需量/有功功率历史数据，测点: {}", pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(query);
|
|
// 构建返回结果
|
PowerHistoryDTO result = new PowerHistoryDTO();
|
result.setCategories(DateUtils.getTimeScale(start, end, 60));
|
result.setDataList(chartData.stream()
|
.map(pv -> new Object[]{
|
DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND),
|
pv.getV()
|
})
|
.collect(Collectors.toList()));
|
|
return success(result);
|
}
|
|
@PostMapping("/demand/history-list")
|
@Operation(summary = "负荷移植-实测需量有功功率历史(多code)")
|
public CommonResult<LinkedHashMap<String, PowerHistoryDTO>> getPowerDemandHistoryList(@RequestBody PowerDemandHisReqDTO dto) {
|
log.info("请求参数: {}", JSONObject.toJSONString(dto));
|
LinkedHashMap<String, PowerHistoryDTO> result = new LinkedHashMap<>();
|
|
// 参数校验
|
if (CollectionUtils.isEmpty(dto.getCodeList())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "codeList不能为空");
|
}
|
if (StringUtils.isBlank(dto.getQueryType())) {
|
return CommonResult.error(GlobalErrorCodeConstants.BAD_REQUEST, "queryType不能为空");
|
}
|
Calendar cal = Calendar.getInstance();
|
cal.set(Calendar.MILLISECOND, 0);
|
cal.set(Calendar.SECOND, 0);
|
Date endTime = dto.getEndTime() == null ? cal.getTime() : dto.getEndTime();
|
Date startTime = dto.getStartTime();
|
if (dto.getStartTime() == null) {
|
cal.add(Calendar.DAY_OF_YEAR, -1);
|
startTime = cal.getTime();
|
}
|
|
Calendar calendar1 = Calendar.getInstance();
|
calendar1.set(Calendar.DAY_OF_MONTH, 1);
|
calendar1.set(Calendar.HOUR_OF_DAY, 0);
|
calendar1.set(Calendar.MINUTE, 0);
|
calendar1.set(Calendar.SECOND, 0);
|
calendar1.set(Calendar.MILLISECOND, 0);
|
Date start1 = calendar1.getTime();
|
|
for (String code : dto.getCodeList()) {
|
PowerHistoryDTO powerHistoryDTO = new PowerHistoryDTO();
|
PowerNetFactorQuery powerNetFactorQuery = new PowerNetFactorQuery();
|
PowerDemandEntity powerDemandEntity = powerDemandService.getByCode(code);
|
PowerNetDropdownEntity powerNetDropdownEntity = powerNetDropdownService.getByNodeCode(code);
|
if (powerDemandEntity != null) {
|
powerNetFactorQuery.setCurP(powerDemandEntity.getActivePower());
|
powerNetFactorQuery.setCurDem(powerDemandEntity.getCurDemand());
|
} else if (powerNetDropdownEntity != null) {
|
powerNetFactorQuery.setCurP(powerNetDropdownEntity.getCurP());
|
powerNetFactorQuery.setCurDem(powerNetDropdownEntity.getExt1());
|
} else {
|
log.info("未找到code对应的数据: {}", dto.getCode());
|
continue;
|
}
|
|
String queryType = dto.getQueryType().toUpperCase();
|
String pointNo;
|
switch (queryType.toUpperCase()) {
|
case "D":
|
pointNo = powerNetFactorQuery.getCurDem();
|
break;
|
case "P":
|
pointNo = powerNetFactorQuery.getCurP();
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的queryType: " + queryType);
|
}
|
|
|
// 查询历史数据
|
ApiPointValueQueryDTO query = new ApiPointValueQueryDTO();
|
query.setPointNo(pointNo);
|
query.setStart(startTime);
|
query.setEnd(endTime);
|
log.info("开始查询实测需量有功功率历史数据，测点: {}", pointNo);
|
List<ApiPointValueDTO> chartData = dataPointApi.queryPointHistoryValue(query);
|
List<Object[]> dataList = chartData.stream()
|
.map(pv -> new Object[]{
|
DateUtils.format(pv.getT(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND),
|
pv.getV()
|
})
|
.collect(Collectors.toList());
|
|
List<Double> valueList = chartData.stream().map(pv -> {
|
return pv.getV();
|
}).collect(Collectors.toList());
|
powerHistoryDTO.setDataList(dataList);
|
|
//查询月最大最小值
|
/*ApiPointValueQueryDTO apiPointValueQueryDTO1 = new ApiPointValueQueryDTO();
|
apiPointValueQueryDTO1.setStart(start1);
|
apiPointValueQueryDTO1.setEnd(new Date());
|
apiPointValueQueryDTO1.setPointNo(pointNo);
|
Map<String, Object> maxV = dataPointApi.queryPointMaxValueRange(apiPointValueQueryDTO1);
|
Map<String, Object> minV = dataPointApi.queryPointMinValueRange(apiPointValueQueryDTO1);
|
if (maxV != null && maxV.containsKey(pointNo)) {
|
powerHistoryDTO.setMax(new BigDecimal(maxV.get(pointNo).toString()));
|
}
|
if (minV != null && minV.containsKey(pointNo)) {
|
powerHistoryDTO.setMin(new BigDecimal(minV.get(pointNo).toString()));
|
}*/
|
|
|
double max = 0;
|
double min = 0;
|
double avg = 0;
|
String maxTime = "";
|
String minTime = "";
|
if (!CollectionUtils.isEmpty(valueList)) {
|
// max = valueList.stream().mapToDouble(Double::doubleValue).max().getAsDouble();
|
// min = valueList.stream().mapToDouble(Double::doubleValue).min().getAsDouble();
|
avg = valueList.stream().mapToDouble(Double::doubleValue).average().getAsDouble();
|
max = valueList.get(0).doubleValue();
|
min = valueList.get(0).doubleValue();
|
for (Object[] dataItem : dataList) {
|
String time = (String) dataItem[0];
|
double value = (double)dataItem[1];
|
if (value > max) {
|
max = value;
|
maxTime = time;
|
}
|
if (value < min) {
|
min = value;
|
minTime = time;
|
}
|
}
|
}
|
|
powerHistoryDTO.setMax(new BigDecimal(max).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setMin(new BigDecimal(min).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setAvg(new BigDecimal(avg).setScale(2, BigDecimal.ROUND_HALF_UP));
|
powerHistoryDTO.setMaxTime(maxTime);
|
powerHistoryDTO.setMinTime(minTime);
|
powerHistoryDTO.setDataList(dataList);
|
|
result.put(code, powerHistoryDTO);
|
}
|
|
return success(result);
|
}
|
|
|
@GetMapping("/voltage/status-list")
|
@Operation(summary = "功率因数-母线电压状态")
|
public CommonResult<List<PowerVoltageStatusDTO>> getPowerVoltageStatusList(@RequestParam Map<String, Object> params) {
|
List<PowerVoltageStatusDTO> result = new ArrayList<>();
|
List<PowerVoltageStatusEntity> list = powerVoltageStatusService.list(params);
|
if (CollectionUtils.isEmpty(list)) {
|
return success(result);
|
}
|
|
List<String> points = new ArrayList<>();
|
for (PowerVoltageStatusEntity entity : list) {
|
if (StringUtils.isBlank(entity.getPoint())) {
|
continue;
|
}
|
points.add(entity.getPoint());
|
}
|
Map<String, Object> pointsRealValue = new HashMap<>();
|
if (!CollectionUtils.isEmpty(points)) {
|
pointsRealValue = dataPointApi.queryPointsRealValue(points);
|
}
|
for (PowerVoltageStatusEntity entity : list) {
|
PowerVoltageStatusDTO dto = ConvertUtils.sourceToTarget(entity, PowerVoltageStatusDTO.class);
|
dto.setStatus(0);
|
BigDecimal value = new BigDecimal(pointsRealValue.get(entity.getPoint()).toString());
|
if (value.compareTo(entity.getLimitH()) > 0) {
|
dto.setStatus(1);
|
}
|
dto.setVoltage(value);
|
result.add(dto);
|
}
|
return success(result);
|
}
|
|
@PostMapping("/power-maxdemand/page")
|
@Operation(summary = "负荷移植-最大需量发生记录分页")
|
public CommonResult<PageResult<PowerMaxDemandMainDTO>> getPowerMaxDemandMainPage(@RequestBody PowerMaxDemandMainPageReqVO reqVO) {
|
if (StringUtils.isBlank(reqVO.getCode())) {
|
log.info("code is blank");
|
return error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
// 默认只展示当月
|
if(reqVO.getStartTime() == null) {
|
reqVO.setStartTime(CalendarUtil.getMonthFirstDay());
|
}
|
|
PageResult<PowerMaxdemandMainEntity> page = powerMaxDemandMainService.page(reqVO);
|
PageResult<PowerMaxDemandMainDTO> result = BeanUtils.toBean(page, PowerMaxDemandMainDTO.class);
|
result.getList().forEach(dto0 -> {
|
List<PowerMaxdemandDetEntity> detList0 = powerMaxdemandDetService.selectListByRelId(dto0.getId(), dto0.getOccurTime());
|
dto0.setChildren(ConvertUtils.sourceToTarget(detList0, PowerMaxdemandDetDTO.class));
|
if (!CollectionUtils.isEmpty(dto0.getChildren())) {
|
dto0.getChildren().forEach(dto1 -> {
|
List<PowerMaxdemandDetEntity> detList1 = powerMaxdemandDetService.selectListByRelId(dto1.getId(), dto1.getOccurTime());
|
dto1.setChildren(ConvertUtils.sourceToTarget(detList1, PowerMaxdemandDetDTO.class));
|
});
|
}
|
});
|
return success(result);
|
}
|
|
@PostMapping("/power-maxdemand/det-list")
|
@Operation(summary = "负荷移植-最大需量发生记录详情")
|
public CommonResult<List<PowerMaxdemandDetDTO>> getPowerMaxDemandDetList(@RequestBody Map<String, Object> params) {
|
String relId = (String) params.get("relId");
|
if (StringUtils.isBlank(relId)) {
|
return error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
List<PowerMaxdemandDetEntity> list = powerMaxdemandDetService.selectListByRelId(relId);
|
return success(ConvertUtils.sourceToTarget(list, PowerMaxdemandDetDTO.class));
|
}
|
|
@GetMapping("/power-price/list")
|
@Operation(summary = "获取峰谷平电价信息")
|
public CommonResult<List<PowerPriceMainDTO>> getPowerPriceList(@RequestParam Map<String, Object> params) {
|
List<PowerPriceMainDTO> result = powerPriceMainService.list(params);
|
return success(result);
|
}
|
|
@PostMapping("/power-price/save")
|
@Operation(summary = "保存峰谷平电价信息")
|
public CommonResult<Boolean> savePowerPriceList(@RequestBody PowerPriceMainDTO mainDTO) {
|
return success(powerPriceMainService.save(mainDTO));
|
}
|
|
@PostMapping("/power-price/update")
|
@Operation(summary = "修改峰谷平电价信息")
|
public CommonResult<Boolean> updatePowerPriceList(@RequestBody PowerPriceMainDTO mainDTO) {
|
if (StringUtils.isBlank(mainDTO.getId())) {
|
return error(GlobalErrorCodeConstants.BAD_REQUEST);
|
}
|
return success(powerPriceMainService.update(mainDTO));
|
}
|
|
@PostMapping("/factor-control/list")
|
@Operation(summary = "功率因数调整结果查询")
|
public CommonResult<List<PowerFactorControlDTO>> powerFactorControlList(@RequestBody PowerFactorReqVO powerFactorReqVO) {
|
List<PowerFactorControlDTO> result = new ArrayList<>();
|
Map<String, Object> chartMap = new HashMap<>();
|
List<ChartParamDTO> chartList = mcsApi.getChartParamList(CommonConstant.POWER_CODE);
|
chartList.forEach(item -> {
|
chartMap.put(item.getParamName(), item.getParamCode());
|
});
|
List<String> contentList = powerFactorReqVO.getContentList();
|
if (CollectionUtils.isEmpty(contentList)) {
|
log.info("contentList为空");
|
return new CommonResult<>();
|
}
|
List<Integer> contentListNew = new ArrayList<>();
|
contentList.forEach(item -> {
|
chartMap.forEach((key, value) -> {
|
if (item.contains(key)) {
|
contentListNew.add(Integer.parseInt(value.toString()));
|
}
|
});
|
});
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
|
MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
|
dto.setScheduleTime(calendar.getTime());
|
dto.setScheduleCode("AnsteelOffPowerAC");
|
Map<String, String> dynamicSettings = new HashMap<>();
|
dynamicSettings.put("option_param", JSONArray.toJSONString(contentListNew.stream().toArray(Integer[]::new)));
|
List<String> cosParam = new ArrayList<>();
|
cosParam.add(powerFactorReqVO.getAdjustValueCcpp().toString());
|
cosParam.add(powerFactorReqVO.getAdjustValue135().toString());
|
cosParam.add(powerFactorReqVO.getAdjustValueTrt().toString());
|
dynamicSettings.put("cos_param", JSONArray.toJSONString(cosParam));
|
dto.setDynamicSettings(dynamicSettings);
|
|
log.info("调度方案开始执行，" + JSONObject.toJSONString(dto));
|
// MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
|
//log.info("调度方案执行完成，" + mdkScheduleRespDTO);
|
|
/*String statusCode = mdkScheduleRespDTO.getStatusCode();
|
if (!CommonConstant.MDK_STATUS_100.equals(statusCode)) {
|
log.info("statusCode=" + statusCode);
|
return CommonResult.error(GlobalErrorCodeConstants.UNKNOWN.getCode(), "工序异常，无计算结果");
|
}
|
|
Map<String, Object> data = mdkScheduleRespDTO.getResult();*/
|
// 调整后的功率因数
|
// List<String> adjustCosList = Arrays.asList(data.get("adjust_cos").toString().split(","));
|
String fakeData = "[0.39,0.98,0.98,0 91,1.0,0.93,0.86,0.89,0.98,0.9,0.97,0.89,0.84,0.91]";
|
List<BigDecimal> adjustCosList = JSONArray.parseArray(fakeData, BigDecimal.class);
|
|
// 无功管控结果
|
BigDecimal back_wugong_buchang = new BigDecimal(36.92);
|
adjustCosList.add(back_wugong_buchang);
|
|
Map<Integer, BigDecimal> adjustCosMap = new HashMap<>();
|
for (int i = 0; i < adjustCosList.size(); i++) {
|
adjustCosMap.put(i, adjustCosList.get(i));
|
}
|
|
List<PowerFactorControlEntity> list = powerFactorControlService.list();
|
if (CollectionUtils.isEmpty(list)) {
|
log.info("list is empty");
|
return success(result);
|
}
|
|
for (int i = 0; i < list.size(); i++) {
|
PowerFactorControlEntity entity = list.get(i);
|
PowerFactorControlDTO controlDTO = new PowerFactorControlDTO();
|
controlDTO.setName(entity.getName());
|
controlDTO.setSort(entity.getSort());
|
try {
|
// 预测结果
|
switch (ProcessConfDataTypeEnum.getEumByCode(entity.getDataType())) {
|
case DATAPOINT:
|
List<String> params1 = new ArrayList<>();
|
params1.add(entity.getPredResult());
|
Map<String, Object> pointValues = dataPointApi.queryPointsRealValue(params1);
|
if (!CollectionUtils.isEmpty(pointValues)) {
|
controlDTO.setPredResult(DecimalUtil.toBigDecimal(pointValues.get(entity.getPredResult())));
|
}
|
break;
|
case PREDICTVALUE:
|
PredictLastValueReqVO reqVO = new PredictLastValueReqVO();
|
calendar.set(calendar.HOUR_OF_DAY, 0);
|
reqVO.setPredictTime(calendar.getTime());
|
List<String[]> itemNos = new ArrayList<>();
|
if (StringUtils.isNotBlank(entity.getPredResult())) {
|
itemNos.add(entity.getPredResult().split(","));
|
}
|
reqVO.setItemNos(itemNos);
|
Map<String, BigDecimal> preValues = mcsApi.getPredictValueByTime(reqVO);
|
if (preValues.get(entity.getPredResult()) != null) {
|
controlDTO.setPredResult(new BigDecimal(preValues.get(entity.getPredResult()).toString()));
|
}
|
break;
|
default:
|
break;
|
}
|
|
// 管控结果
|
if (adjustCosMap.containsKey(entity.getCosIndex())) {
|
controlDTO.setAdjustCos(adjustCosMap.get(entity.getCosIndex()));
|
}
|
} catch (Exception ex) {
|
log.info(controlDTO.getName() + "获取预测值异常," + ex.getMessage());
|
ex.printStackTrace();
|
}
|
result.add(controlDTO);
|
}
|
log.info("result===" + JSONObject.toJSONString(result));
|
return success(result);
|
}
|
}
|
