电网拓扑预警信息

 ansteel-biz/db/mysql.sql

@@ -252,6 +252,8 @@
                                             PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '电力功率因数电网拓扑';

ALTER TABLE `t_power_net_factor` ADD COLUMN `cur_flag` int DEFAULT 0 COMMENT '无功返送(1:大于0是，-1：小于0是)';

-- ----------------------------
-- 电力功率因数-发电机组实时状态
-- ----------------------------

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

@@ -80,15 +80,13 @@
        return success(result);
    }

    /*
    /**
     * 判断 curCos 是否超上下限
     * {nodeName}功率因数超上限/下限。
     *
     * <p>
     * 判断 curQ
     * {nodeName}发生无功返送
     *
     * */

     */
    @GetMapping("/net-factor/alarm")
    @Operation(summary = "功率因数-电网拓扑预警信息")
    public CommonResult<List<String>> getPowerNetFactorAlarm(@RequestParam Map<String, Object> params) {
@@ -99,39 +97,37 @@
            return success(result);
        }
        for (PowerNetFactorDTO dto : dtoList) {
            String message = "";
            List<String> points = new ArrayList<>();
            String message = "";
            if (StringUtils.isNotBlank(dto.getCurQ())) {
                points.add(dto.getCurQ());
            }
            if (StringUtils.isNotBlank(dto.getCurCos())) {
                points.add(dto.getCurCos());
            }
            if (CollectionUtils.isEmpty(points)) {
                return success(result);
                continue;
            }

            Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
            if (pointsRealValue.get(dto.getCurQ()) == null) {
                return success(result);
            }
            BigDecimal curQ = new BigDecimal(pointsRealValue.get(dto.getCurQ()).toString());
            if (dto.getCurFlag().compareTo(BigDecimal.ZERO) > 0) {
                if (curQ.compareTo(BigDecimal.ZERO) > 0) {
                    message = dto.getNodeName() + "发生无功返送;";
                }
            } else {
                if (curQ.compareTo(BigDecimal.ZERO) < 0) {
            if (pointsRealValue.get(dto.getCurQ()) != null) {
                BigDecimal curQ = new BigDecimal(pointsRealValue.get(dto.getCurQ()).toString());
                if (curQ.compareTo(BigDecimal.ZERO) == dto.getCurFlag()) {
                    message = dto.getNodeName() + "发生无功返送;";
                }
            }
            BigDecimal curCos = new BigDecimal(dto.getCurCos());
            if (curCos.compareTo(dto.getLimitH()) > 0) {
                message += dto.getNodeName() + "功率因数超上限";
            }else if (curCos.compareTo(dto.getLimitL()) < 0) {
                message += dto.getNodeName() + "功率因数超下限";
            if (pointsRealValue.get(dto.getCurCos()) != null) {
                BigDecimal curCos = new BigDecimal(pointsRealValue.get(dto.getCurCos()).toString());
                if (curCos.compareTo(dto.getLimitH()) > 0) {
                    message += dto.getNodeName() + "功率因数超上限";
                } else if (curCos.compareTo(dto.getLimitL()) < 0) {
                    message += dto.getNodeName() + "功率因数超下限";
                }
            }
            if(!"".equals(message)) {
            if (!message.isEmpty()) {
                result.add(message);
            }
        }

        return success(result);
    }


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

@@ -34,8 +34,8 @@
    @Schema(description = "当前功率因数")
    private String curCos;

    @Schema(description = "无功返送判断条件（1判断cur_q>0,-1判断cur_q<0）")
    private BigDecimal curFlag;
    @Schema(description = "无功返送(1:大于0是，-1：小于0是)")
    private Integer curFlag;

    @Schema(description = "预测有功")
    private String preP;

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/PowerNetFactorEntity.java

@@ -46,7 +46,7 @@
    /**
     * 无功返送判断条件
     */
    private BigDecimal curFlag;
    private Integer curFlag;
    /**
     * 预测有功
     */