功率因数管控接口

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

@@ -1,5 +1,6 @@
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;
@@ -10,6 +11,8 @@
import com.iailab.module.ansteel.api.dto.*;
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.TransferTypeEnum;
import com.iailab.module.ansteel.common.utils.DecimalUtil;
import com.iailab.module.ansteel.common.utils.PowerUtil;
import com.iailab.module.ansteel.power.entity.*;
@@ -19,16 +22,23 @@
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 com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
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.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;

import java.lang.reflect.Array;
import java.math.BigDecimal;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

import static com.iailab.framework.common.pojo.CommonResult.error;
@@ -74,6 +84,9 @@
    private McsApi mcsApi;

    @Autowired
    private MdkApi mdkApi;

    @Autowired
    private PowerCapacitorHisService powerCapacitorHisService;

    @Autowired
@@ -94,9 +107,14 @@
    @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 = "功率因数-电网拓扑")
@@ -1300,4 +1318,98 @@
        }
        return success(powerPriceMainService.update(mainDTO));
    }

    @PostMapping("/factor-control/list")
    @Operation(summary = "功率因数管控")
    public CommonResult<List<PowerFactorControlDTO>> powerFactorControlList(@RequestBody PowerFactorReqVO powerFactorReqVO) {
        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("AnSteelpowertransfer");
        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)));
        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(","));//管控结果

        PowerFactorControlDTO powerFactorControlDTO = new PowerFactorControlDTO();
        List<PowerFactorControlDTO> result = new ArrayList<>();
        List<PowerFactorControlDTO> list = powerFactorControlService.list(powerFactorControlDTO);
        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);
            try {
                PredictLastValueReqVO reqVO = new PredictLastValueReqVO();
                reqVO.setPredictTime(calendar.getTime());
                List<String[]> itemNos = new ArrayList<>();
                if (StringUtils.isNotBlank(controlDTO.getPredResult())) {
                    itemNos.add(controlDTO.getPredResult().split(","));
                }
                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));

            } 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);
        return success(result);
    }
}

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

对比新文件
@@ -0,0 +1,29 @@
package com.iailab.module.ansteel.api.dto;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

import java.io.Serializable;

/**
 * 功率因数管控
 *
 * @author lirm
 * @since 1.0.0 2025-06-04
 */
@Data
public class PowerFactorControlDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "名称")
    private String name;

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

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

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

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

对比新文件
@@ -0,0 +1,26 @@
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.util.List;

/**
 * @author lirm
 * @Description
 * @createTime 2025年06月09日
 */
@Data
public class PowerFactorReqVO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "建议")
    private List<String> contentList;

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

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/common/constant/CommonConstant.java

@@ -80,4 +80,7 @@
    String COKE_INDEX_CHARTCODE = "COKE_INDEX";
    String COAL_INDEX_CHARTCODE = "COAL_INDEX";
    String CHEMPROD_INDEX_CHARTCODE = "CHEMPROD_INDEX";

    //电容器编码
    String POWER_CODE = "POWER_CODE";
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOffPowerOptimTask.java

@@ -34,7 +34,7 @@

    @Override
    public void run(String params) {
        logger.info("runPredictModuleTask定时任务正在执行，参数为：{}", params);
        logger.info("runOffPowerOptimTask定时任务正在执行，参数为：{}", params);
        try {
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.SECOND, 0);
@@ -61,9 +61,9 @@
                logger.error("调度方案结果下发失败");
            }
        } catch (Exception ex) {
            logger.error("runPredictModuleTask运行异常", ex);
            logger.error("runOffPowerOptimTask运行异常", ex);
        }
        logger.info("runPredictModuleTask运行完成");
        logger.info("runOffPowerOptimTask运行完成");
    }

    private void saveScheduleSuggest(String title, Object content, String scheduleObj, Date scheduleTime) {

 ansteel-biz/src/main/java/com/iailab/module/ansteel/power/dao/PowerFactorControlDao.java

对比新文件
@@ -0,0 +1,10 @@
package com.iailab.module.ansteel.power.dao;

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.module.ansteel.power.entity.PowerFactorControlEntity;
import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface PowerFactorControlDao extends BaseDao<PowerFactorControlEntity> {

}

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

对比新文件
@@ -0,0 +1,33 @@
package com.iailab.module.ansteel.power.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.io.Serializable;

/**
 * @description: 功率因数管控
 * @author: lirm
 * @date: 2025/06/03
 **/
@Data
@TableName("t_power_factor_control")
public class PowerFactorControlEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * id
     */
    @TableId(type = IdType.ASSIGN_UUID)
    private String id;

    private String type;

    private String name;

    private String predResult;

    private Integer sort;
}

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

对比新文件
@@ -0,0 +1,14 @@
package com.iailab.module.ansteel.power.service;

import com.iailab.module.ansteel.api.dto.PowerFactorControlDTO;

import java.util.List;

/**
 * @author lirm
 * @since 1.0.0 2025/06/03
 */
public interface PowerFactorControlService {

    List<PowerFactorControlDTO> list(PowerFactorControlDTO powerFactorControlDTO);
}

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

对比新文件
@@ -0,0 +1,30 @@
package com.iailab.module.ansteel.power.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.module.ansteel.api.dto.PowerFactorControlDTO;
import com.iailab.module.ansteel.power.dao.PowerFactorControlDao;
import com.iailab.module.ansteel.power.entity.PowerFactorControlEntity;
import com.iailab.module.ansteel.power.service.PowerFactorControlService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author lirm
 * @since 1.0.0 2025/06/03
 */
@Slf4j
@Service
public class PowerFactorControlServiceImpl implements PowerFactorControlService {

    @Autowired
    private PowerFactorControlDao powerFactorControlDao;

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