功率因数调整结果查询

 ansteel-biz/db/mysql.sql

@@ -908,4 +908,7 @@
    `pred_result` varchar(36) DEFAULT NULL COMMENT '预测结果',
    `sort`        int NULL DEFAULT NULL COMMENT '排序',
    PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='功率因数管控';
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='功率因数管控';

ALTER TABLE `t_power_factor_control` ADD COLUMN `data_type` varchar(20) NULL DEFAULT NULL COMMENT '数据类型' after `name`;
ALTER TABLE `t_power_factor_control` ADD COLUMN `cos_index` int NULL DEFAULT NULL COMMENT '功率因素结果角标' after `pred_result`;

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/PowerController.java

@@ -12,6 +12,7 @@
import com.iailab.module.ansteel.api.vo.PowerCapacitorHisPageReqVO;
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.enums.TransferTypeEnum;
import com.iailab.module.ansteel.common.utils.DecimalUtil;
import com.iailab.module.ansteel.common.utils.PowerUtil;
@@ -1320,8 +1321,9 @@
    }

    @PostMapping("/factor-control/list")
    @Operation(summary = "功率因数管控")
    @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 -> {
@@ -1350,66 +1352,88 @@
        dto.setScheduleCode("AnsteelOffPowerAC");
        Map<String, String> dynamicSettings = new HashMap<>();
        dynamicSettings.put("option_param", JSONArray.toJSONString(contentListNew.stream().toArray(Integer[]::new)));
        dynamicSettings.put("cos_param", JSONArray.toJSONString(powerFactorReqVO.getAdjustValueList().stream().toArray(String[]::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);
        // MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
        //log.info("调度方案执行完成，" + mdkScheduleRespDTO);

        String statusCode = mdkScheduleRespDTO.getStatusCode();
        /*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(","));//管控结果
        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);

        PowerFactorControlDTO powerFactorControlDTO = new PowerFactorControlDTO();
        List<PowerFactorControlDTO> result = new ArrayList<>();
        List<PowerFactorControlDTO> list = powerFactorControlService.list(powerFactorControlDTO);
        // 无功管控结果
        BigDecimal back_wugong_buchang = new BigDecimal(36.92);
        adjustCosList.add(back_wugong_buchang);

        Map<Integer, BigDecimal> adjustCosMap = new HashMap<>();
        for (int i = 1; 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++) {
            PowerFactorControlDTO controlDTO = list.get(i);
        for (int i = 1; i <= list.size(); i++) {
            PowerFactorControlEntity entity = list.get(i);
            PowerFactorControlDTO controlDTO = new PowerFactorControlDTO();
            controlDTO.setName(entity.getName());
            controlDTO.setSort(entity.getSort());
            try {
                PredictLastValueReqVO reqVO = new PredictLastValueReqVO();
                reqVO.setPredictTime(calendar.getTime());
                List<String[]> itemNos = new ArrayList<>();
                if (StringUtils.isNotBlank(controlDTO.getPredResult())) {
                    itemNos.add(controlDTO.getPredResult().split(","));
                // 预测结果
                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 (!CollectionUtils.isEmpty(itemNos)) {
                    reqVO.setItemNos(itemNos);
                    log.info("reqVO=" + JSONObject.toJSONString(reqVO));
                    Map<String, BigDecimal> preValues = mcsApi.getPredictValueByTime(reqVO);
                    if (!ObjectUtils.isEmpty(preValues.get(controlDTO.getPredResult()))) {
                        controlDTO.setPredResult(preValues.get(controlDTO.getPredResult()).toString());
                    }
                }
                controlDTO.setAdjustCos(adjustCosList.get(i));

                // 管控结果
                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);
        }

        List<String> points = new ArrayList<>();
        points.add(pointNo);
        Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);

        PowerFactorControlDTO controlDTO = new PowerFactorControlDTO();
        controlDTO.setName("望铁关口最大无功倒送量");
        controlDTO.setPredResult(pointsRealValue.get(pointNo).toString());
        controlDTO.setAdjustCos(data.get("back_wugong_buchang").toString());
        controlDTO.setSort(list.size() + 1);
        result.add(controlDTO);
        log.info("result===" + JSONObject.toJSONString(result));
        return success(result);
    }

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PowerFactorControlDTO.java

@@ -4,6 +4,7 @@
import lombok.Data;

import java.io.Serializable;
import java.math.BigDecimal;

/**
 * 功率因数管控
@@ -19,10 +20,10 @@
    private String name;

    @Schema(description = "预测结果")
    private String predResult;
    private BigDecimal predResult;

    @Schema(description = "管控结果")
    private String adjustCos;
    private BigDecimal adjustCos;

    @Schema(description = "排序")
    private Integer sort;

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PowerFactorReqVO.java

@@ -1,11 +1,10 @@
package com.iailab.module.ansteel.api.dto;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;
import java.math.BigDecimal;
import java.util.List;

/**
@@ -17,10 +16,16 @@
public class PowerFactorReqVO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "建议")
    @Schema(description = "投退建议内容集合")
    private List<String> contentList;

    @Schema(description = "调整值")
    private List<String> adjustValueList;
    @Schema(description = "Ccpp调整值")
    private BigDecimal adjustValueCcpp;

    @Schema(description = "135调整值")
    private BigDecimal adjustValue135;

    @Schema(description = "Trt调整值")
    private BigDecimal adjustValueTrt;

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/common/enums/ProcessConfDataTypeEnum.java

@@ -12,6 +12,7 @@
@AllArgsConstructor
public enum ProcessConfDataTypeEnum {
    DATAPOINT("DATAPOINT", "测点值"),
    PREDICTVALUE("PREDICTVALUE", "预测值"),
    IND("IND", "指标值(double)"),
    ARC("ARC", "归档数据"),
    MODEL("MODEL", "模型输出值"),

 ansteel-biz/src/main/java/com/iailab/module/ansteel/power/entity/PowerFactorControlEntity.java

@@ -27,7 +27,11 @@

    private String name;

    private String dataType;

    private String predResult;

    private Integer cosIndex;

    private Integer sort;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/PowerFactorControlService.java

@@ -1,6 +1,7 @@
package com.iailab.module.ansteel.power.service;

import com.iailab.module.ansteel.api.dto.PowerFactorControlDTO;
import com.iailab.module.ansteel.power.entity.PowerFactorControlEntity;

import java.util.List;

@@ -10,5 +11,5 @@
 */
public interface PowerFactorControlService {

    List<PowerFactorControlDTO> list(PowerFactorControlDTO powerFactorControlDTO);
    List<PowerFactorControlEntity> list();
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/impl/PowerFactorControlServiceImpl.java

@@ -24,7 +24,7 @@
    private PowerFactorControlDao powerFactorControlDao;

    @Override
    public List<PowerFactorControlDTO> list(PowerFactorControlDTO powerFactorControlDTO) {
        return ConvertUtils.sourceToTarget(powerFactorControlDao.selectList(new QueryWrapper<PowerFactorControlEntity>().orderByAsc("sort")), PowerFactorControlDTO.class);
    public List<PowerFactorControlEntity> list() {
        return powerFactorControlDao.selectList(new QueryWrapper<PowerFactorControlEntity>().orderByAsc("sort"));
    }
}

 doc/鞍钢数据接口文档_master.doc

Binary files differ

 doc/鞍钢鲅鱼圈钢铁分公司能源管控智能化提升项目使用说明书.docx

Binary files differ