Merge branch 'master' of http://dlindusit.com:53929/r/ansteel

 ansteel-biz/db/mysql.sql

@@ -229,53 +229,6 @@
CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, TRIGGER_GROUP);


DROP TABLE IF EXISTS `t_main_process_index_day`;
CREATE TABLE `t_main_process_index_day`  (
                                             `id` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'id',
                                             `index` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标',
                                             `his_avg` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
                                             `theory` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
                                             `actual` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
                                             `real_data` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
                                             PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of t_main_process_index_day
-- ----------------------------
INSERT INTO `t_main_process_index_day` VALUES ('1', 'COG消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_day` VALUES ('2', 'COG发生', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_day` VALUES ('3', 'BFG消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_day` VALUES ('4', '蒸汽消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_day` VALUES ('5', '蒸汽产生', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_day` VALUES ('6', '电力消耗', NULL, NULL, NULL, NULL);

SET FOREIGN_KEY_CHECKS = 1;


DROP TABLE IF EXISTS `t_main_process_index_team`;
CREATE TABLE `t_main_process_index_team`  (
                                              `id` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'id',
                                              `index` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标',
                                              `his_avg` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
                                              `theory` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
                                              `actual` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
                                              `real_data` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
                                              PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of t_main_process_index_team
-- ----------------------------
INSERT INTO `t_main_process_index_team` VALUES ('1', 'COG消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_team` VALUES ('2', 'COG发生', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_team` VALUES ('3', 'BFG消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_team` VALUES ('4', '蒸汽消耗', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_team` VALUES ('5', '蒸汽产生', NULL, NULL, NULL, NULL);
INSERT INTO `t_main_process_index_team` VALUES ('6', '电力消耗', NULL, NULL, NULL, NULL);

SET FOREIGN_KEY_CHECKS = 1;

-- ----------------------------
-- 电力功率因数-电网拓扑
-- ----------------------------
@@ -326,7 +279,7 @@
                                             `remark` varchar(50) NULL DEFAULT NULL COMMENT '备注',
                                             `sort` int NULL DEFAULT NULL COMMENT '排序',
                                             PRIMARY KEY (`id`) USING BTREE,
                                             UNIQUE INDEX `uk_name` varchar(50) NULL DEFAULT NULL COMMENT '名称'
                                             UNIQUE INDEX `uk_name` (`name`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '电力功率因数管控功率因数主表';

-- ----------------------------
@@ -342,4 +295,110 @@
                                        `status` int DEFAULT 0 COMMENT '是否超限(0:正常，1：超限)',
                                        `sort` int NULL DEFAULT NULL COMMENT '排序',
                                        PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '电力功率因数管控功率因数从表';
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '电力功率因数管控功率因数从表';


-- ----------------------------
-- 焦化工序-工序指标配置
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_process_conf`;
CREATE TABLE `t_coking_process_conf`  (
                                          `id` varchar(36) NOT NULL COMMENT 'id',
                                          `info_type` varchar(10) NULL DEFAULT NULL COMMENT '信息类型（0：生产情况，1：能源发生，2：能源消耗）',
                                          `ind_type` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标类型（prod_day,main,child）',
                                          `ind_code` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标编码',
                                          `ind_name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标名称',
                                          `ind_unit` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标单位',
                                          `remark` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '备注',
                                          `ext1` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '拓展字段1',
                                          `ext2` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '拓展字段2',
                                          `ext3` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '拓展字段3',
                                          `ext4` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '拓展字段4',
                                          `ext5` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '拓展字段5',
                                          `sort` int NULL DEFAULT NULL COMMENT '排序',
                                          PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序工序指标配置';

-- ----------------------------
-- 焦化工序-日生产信息
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_prod_day`;
CREATE TABLE `t_coking_prod_day` (
                                       `id` varchar(36) NOT NULL COMMENT 'id',
                                       `clock` varchar(20) NULL DEFAULT NULL COMMENT '查询时间',
                                       `info_type` varchar(10) NULL DEFAULT NULL COMMENT '信息类型（0：生产情况，1：能源发生，2：能源消耗）',
                                       `ind_name` varchar(50) NULL DEFAULT NULL COMMENT '数据名称',
                                       `ind_unit` varchar(50) NULL DEFAULT NULL COMMENT '数据单位',
                                       `ind_value` varchar(50) NULL DEFAULT NULL COMMENT '数据值',
                                       `sort` int NULL DEFAULT NULL COMMENT '排序',
                                       PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序日生产信息';

-- ----------------------------
-- 焦化工序-主工序指标历史
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_process_main`;
CREATE TABLE `t_coking_process_main`  (
                                             `id` varchar(36) NOT NULL COMMENT 'id',
                                             `category` varchar(20) NULL DEFAULT NULL COMMENT '类别（日：day,班：class）',
                                             `clock` varchar(20) NULL DEFAULT NULL COMMENT '查询时间',
                                             `info_type` varchar(10) NULL DEFAULT NULL COMMENT '信息类型（0：生产情况，1：能源发生，2：能源消耗）',
                                             `ind_name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标名称',
                                             `avg_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
                                             `theory_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
                                             `actual_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
                                             `stand_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '基准值',
                                             `real_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
                                             `sort` int NULL DEFAULT NULL COMMENT '排序',
                                             PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序主工序指标历史';


-- ----------------------------
-- 焦化工序-子工序指标
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_process_child`;
CREATE TABLE `t_coking_process_child`  (
                                          `id` varchar(36) NOT NULL COMMENT 'id',
                                          `category` varchar(20) NULL DEFAULT NULL COMMENT '类别（日：day,班：class）',
                                          `clock` varchar(20) NULL DEFAULT NULL COMMENT '查询时间',
                                          `info_type` varchar(10) NULL DEFAULT NULL COMMENT '信息类型（0：生产情况，1：能源发生，2：能源消耗）',
                                          `ind_type` varchar(20) NOT NULL COMMENT '类型',
                                          `ind_main` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '重点管控指标',
                                          `ind_name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标名称',
                                          `avg_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
                                          `theory_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
                                          `actual_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
                                          `stand_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '基准值',
                                          `real_value` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
                                          `sort` int NULL DEFAULT NULL COMMENT '排序',
                                          PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序主子工序指标';


-- ----------------------------
-- 焦化工序-趋势分析
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_analy_trend`;
CREATE TABLE `t_coking_analy_trend`  (
                                           `id` varchar(36) NOT NULL COMMENT 'id',
                                           `analy_type` varchar(20) NULL DEFAULT NULL COMMENT '分析类型',
                                           `analy_title` varchar(20) NULL DEFAULT NULL COMMENT '分析标题',
                                           `analy_date` varchar(20) NULL DEFAULT NULL COMMENT '分析日期',
                                           `analy_class` varchar(20) NULL DEFAULT NULL COMMENT '分析班次',
                                           `analy_content` varchar(20) NULL DEFAULT NULL COMMENT '内容',
                                           PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序趋势分析';

-- ----------------------------
-- 焦化工序-指标分析
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_analy_ind`;
CREATE TABLE `t_coking_analy_ind`  (
                                         `id` varchar(36) NOT NULL COMMENT 'id',
                                         `analy_type` varchar(20) NULL DEFAULT NULL COMMENT '分析类型',
                                         `analy_date` varchar(20) NULL DEFAULT NULL COMMENT '分析日期',
                                         `analy_class` varchar(20) NULL DEFAULT NULL COMMENT '分析班次',
                                         `analy_content` varchar(20) NULL DEFAULT NULL COMMENT '内容',
                                         PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序指标分析';

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

对比新文件
@@ -0,0 +1,82 @@
package com.iailab.module.ansteel.api.controller.admin;

import com.iailab.framework.common.pojo.CommonResult;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.module.ansteel.api.dto.*;
import com.iailab.module.ansteel.api.entity.*;
import com.iailab.module.ansteel.api.service.*;
import io.swagger.v3.oas.annotations.Operation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

import static com.iailab.framework.common.pojo.CommonResult.success;

/**
 * 焦化接口
 *
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@RestController
@RequestMapping("/ansteel/api/coking")
public class CokingController {

    @Autowired
    private CokingAnalyIndService cokingAnalyIndService;

    @Autowired
    private CokingAnalyTrendService cokingAnalyTrendService;

    @Autowired
    private CokingProcessChildService cokingProcessChildService;

    @Autowired
    private CokingProcessMainService cokingProcessMainService;

    @Autowired
    private CokingProdDayService cokingProdDayService;

    @GetMapping("/analy-ind/list")
    @Operation(summary = "焦化工序-指标分析")
    public CommonResult<List<CokingAnalyIndDTO>> getCokingAnalyIndList(@RequestParam Map<String, Object> params) {
        List<CokingAnalyIndEntity> list = cokingAnalyIndService.list(params);
        return success(ConvertUtils.sourceToTarget(list, CokingAnalyIndDTO.class));
    }

    @GetMapping("/analy-trend/list")
    @Operation(summary = "焦化工序-趋势分析")
    public CommonResult<List<CokingAnalyTrendDTO>> getCokingAnalyTrendList(@RequestParam Map<String, Object> params) {
        List<CokingAnalyTrendEntity> list = cokingAnalyTrendService.list(params);
        return success(ConvertUtils.sourceToTarget(list, CokingAnalyTrendDTO.class));
    }

    @GetMapping("/analy-trend/list")
    @Operation(summary = "焦化工序-子工序指标")
    public CommonResult<List<CokingProcessChildDTO>> getCokingProcessChildList(@RequestParam Map<String, Object> params) {
        List<CokingProcessChildEntity> list = cokingProcessChildService.list(params);
        return success(ConvertUtils.sourceToTarget(list, CokingProcessChildDTO.class));
    }

    @GetMapping("/analy-trend/list")
    @Operation(summary = "焦化工序-主工序指标")
    public CommonResult<List<CokingProcessMainDTO>> getCokingProcessMainList(@RequestParam Map<String, Object> params) {
        List<CokingProcessMainEntity> list = cokingProcessMainService.list(params);
        return success(ConvertUtils.sourceToTarget(list, CokingProcessMainDTO.class));
    }

    @GetMapping("/analy-trend/list")
    @Operation(summary = "焦化工序-日生产信息")
    public CommonResult<List<CokingProdDayDTO>> getCokingProdDayList(@RequestParam Map<String, Object> params) {
        List<CokingProdDayEntity> list = cokingProdDayService.list(params);
        return success(ConvertUtils.sourceToTarget(list, CokingProdDayDTO.class));
    }
}

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

@@ -48,23 +48,37 @@
        return CommonResult.success(tMap);
    }

    @GetMapping("/main-process-index/list")
    @Operation(summary = "主工序指标")
    public CommonResult<List<MainProcessIndexDTO>> getMainIndexList(@RequestParam Map<String, Object> params) {
        List<MainProcessIndexDTO> list = dataApi.getIndexList(params);
        return success(list);
    }

    @GetMapping("/child-process-index/list")
    @Operation(summary = "子工序指标")
    public CommonResult<List<ChildProcessIndexDTO>> getChildIndexList(@RequestParam Map<String, Object> params) {
        List<ChildProcessIndexDTO> list = new ArrayList<>();
        return success(list);
    }

    @PostMapping("/schedule-suggest/use-suggest")
    @Operation(summary = "采纳建议")
    public CommonResult<Boolean> useSuggest(@RequestBody StAlarmAndSuggestReqVO ReqVO) {
        return success(dataApi.useSuggest(ReqVO));
    }

    @GetMapping("/power-net-factor/list")
    @Operation(summary = "电力功率因数-电网拓扑")
    public CommonResult<List<PowerNetFactorDTO>> getPowerNetFactorList(@RequestParam Map<String, Object> params) {
        List<PowerNetFactorDTO> list = dataApi.getPowerNetFactorList();
        return success(list);
    }

    @GetMapping("/power-capacitor-status/list")
    @Operation(summary = "电力功率因数-电容器投运状态")
    public CommonResult<List<PowerCapacitorStatusDTO>> getPowerCapacitorStatusList(@RequestParam Map<String, Object> params) {
        List<PowerCapacitorStatusDTO> list = dataApi.getPowerCapacitorStatusList();
        return success(list);
    }

    @GetMapping("/power-control-main/list")
    @Operation(summary = "电力功率因数-管控功率因数主表")
    public CommonResult<List<PowerControlMainDTO>> getPowerControlMainList(@RequestParam Map<String, Object> params) {
        List<PowerControlMainDTO> list = dataApi.getPowerControlMainList();
        return success(list);
    }

    @GetMapping("/power-control-det/list")
    @Operation(summary = "电力功率因数-管控功率因数子表")
    public CommonResult<List<PowerControlDetDTO>> getPowerControlDetList(@RequestParam Map<String, Object> params) {
        List<PowerControlDetDTO> list = dataApi.getPowerControlDetList(params);
        return success(list);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/CokingAnalyIndDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.CokingAnalyIndEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@TenantDS
@Mapper
public interface CokingAnalyIndDao extends BaseDao<CokingAnalyIndEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/CokingAnalyTrendDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.CokingAnalyTrendEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@TenantDS
@Mapper
public interface CokingAnalyTrendDao extends BaseDao<CokingAnalyTrendEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/CokingProcessChildDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.CokingProcessChildEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@TenantDS
@Mapper
public interface CokingProcessChildDao extends BaseDao<CokingProcessChildEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/CokingProcessMainDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.CokingProcessMainEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@TenantDS
@Mapper
public interface CokingProcessMainDao extends BaseDao<CokingProcessMainEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/CokingProdDayDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.CokingProdDayEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@TenantDS
@Mapper
public interface CokingProdDayDao extends BaseDao<CokingProdDayEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/PowerCapacitorStatusDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.PowerCapacitorStatusEntity;
import org.apache.ibatis.annotations.Mapper;

@TenantDS
@Mapper
public interface PowerCapacitorStatusDao extends BaseDao<PowerCapacitorStatusEntity> {

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/PowerControlDetDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.PowerControlDetEntity;
import org.apache.ibatis.annotations.Mapper;

@TenantDS
@Mapper
public interface PowerControlDetDao extends BaseDao<PowerControlDetEntity> {

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/PowerControlMainDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.PowerControlMainEntity;
import org.apache.ibatis.annotations.Mapper;

@TenantDS
@Mapper
public interface PowerControlMainDao extends BaseDao<PowerControlMainEntity> {

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/PowerNetFactorDao.java

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

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
import com.iailab.module.ansteel.api.entity.PowerNetFactorEntity;
import org.apache.ibatis.annotations.Mapper;

@TenantDS
@Mapper
public interface PowerNetFactorDao extends BaseDao<PowerNetFactorEntity> {

}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Schema(description = "焦化工序-指标分析")
@Data
public class CokingAnalyIndDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "ID")
    private String id;

    @Schema(description = "分析类型")
    private String analyType;

    @Schema(description = "分析日期")
    private String analyDate;

    @Schema(description = "分析班次")
    private String analyClass;

    @Schema(description = "内容")
    private String analyContent;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Schema(description = "焦化工序-趋势分析")
@Data
public class CokingAnalyTrendDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "ID")
    private String id;

    @Schema(description = "分析类型")
    private String analyType;

    @Schema(description = "分析标题")
    private String analyTitle;

    @Schema(description = "分析日期")
    private String analyDate;

    @Schema(description = "分析班次")
    private String analyClass;

    @Schema(description = "内容")
    private String analyContent;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Schema(description = "焦化工序-子工序指标")
@Data
public class CokingProcessChildDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "ID")
    private String id;

    @Schema(description = "类别（日：day,班：class）")
    private String category;

    @Schema(description = "查询时间")
    private String clock;

    @Schema(description = "信息类型（0：生产情况，1：能源发生，2：能源消耗）")
    private String infoType;

    @Schema(description = "类型")
    private String indType;

    @Schema(description = "重点管控指标")
    private String indMain;

    @Schema(description = "指标名称")
    private String indName;

    @Schema(description = "历史平均")
    private String avgValue;

    @Schema(description = "理论值")
    private String theoryValue;

    @Schema(description = "实际值")
    private String actualValue;

    @Schema(description = "基准值")
    private String standValue;

    @Schema(description = "实时数据")
    private String realValue;

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

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Schema(description = "焦化工序-主工序指标")
@Data
public class CokingProcessMainDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "ID")
    private String id;

    @Schema(description = "类别（日：day,班：class）")
    private String category;

    @Schema(description = "查询时间")
    private String clock;

    @Schema(description = "信息类型（0：生产情况，1：能源发生，2：能源消耗）")
    private String infoType;

    @Schema(description = "指标名称")
    private String indName;

    @Schema(description = "历史平均")
    private String avgValue;

    @Schema(description = "理论值")
    private String theoryValue;

    @Schema(description = "实际值")
    private String actual_value;

    @Schema(description = "基准值")
    private String stand_value;

    @Schema(description = "实时数据")
    private String real_value;

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

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Schema(description = "焦化工序-日生产信息")
@Data
public class CokingProdDayDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "ID")
    private String id;

    @Schema(description = "查询时间")
    private String clock;

    @Schema(description = "信息类型（0：生产情况，1：能源发生，2：能源消耗）")
    private String infoType;

    @Schema(description = "数据名称")
    private String indName;

    @Schema(description = "数据单位")
    private String indUnit;

    @Schema(description = "数据值")
    private String indValue;

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

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

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

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

import java.io.Serializable;


/**
 * 电力功率因数电容器投运状态
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
public class PowerCapacitorStatusDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "id")
    private String id;

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

    @Schema(description = "主变数量")
    private String mainCount;

    @Schema(description = "主变测点编码")
    private String mainPoint;

    @Schema(description = "下属数量")
    private String childCount;

    @Schema(description = "下属测点编码")
    private String childPoint;

    @Schema(description = "投运数量")
    private String onCount;

    @Schema(description = "备注")
    private String remark;

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


}

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

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

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

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

/**
 * 电力功率因数管控功率因数从表
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
public class PowerControlDetDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "id")
    private String id;

    @Schema(description = "主表ID")
    private String controlId;

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

    @Schema(description = "测点")
    private String point;

    @Schema(description = "下限")
    private BigDecimal limitL;

    @Schema(description = "是否超限(0:正常，1：超限)")
    private Integer status;

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


}

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

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

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

import java.io.Serializable;


/**
 * 电力功率因数管控功率因数主表
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
public class PowerControlMainDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "id")
    private String id;

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

    @Schema(description = "备注")
    private String remark;

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

}

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

@@ -1,17 +1,65 @@
package com.iailab.module.ansteel.api.dto;

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

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

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月10日
 * 电力功率因数电网拓扑
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
public class PowerNetFactorDTO implements Serializable {
    private static final long serialVersionUID = 1L;

    @Schema(description = "id")
    private String id;

    @Schema(description = "分组名称")
    private String groupName;

    @Schema(description = "节点名称")
    private String nodeName;

    @Schema(description = "当前有功")
    private String curP;

    @Schema(description = "当前无功")
    private String curQ;

    @Schema(description = "当前功率因数")
    private String curCos;

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

    @Schema(description = "预测无功")
    private String preQ;

    @Schema(description = "预测功率因数")
    private String preCos;

    @Schema(description = "预测项ID")
    private String itemId;

    @Schema(description = "预测项输出ID")
    private String outId;

    @Schema(description = "上限")
    private BigDecimal limitH;

    @Schema(description = "下限")
    private BigDecimal limitL;

    @Schema(description = "是否超限(0:正常，1：超限)")
    private Integer status;

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


}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Data
@TableName("t_coking_analy_ind")
public class CokingAnalyIndEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    private String analyType;

    private String analyDate;

    private String analyClass;

    private String analyContent;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Data
@TableName("t_coking_analy_trend")
public class CokingAnalyTrendEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    private String analyType;

    private String analyTitle;

    private String analyDate;

    private String analyClass;

    private String analyContent;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Data
@TableName("t_coking_process_child")
public class CokingProcessChildEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    private String category;

    private String clock;

    private String infoType;

    private String indType;

    private String indMain;

    private String indName;

    private String avgValue;

    private String theoryValue;

    private String actualValue;

    private String standValue;

    private String realValue;

    private Integer sort;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Data
@TableName("t_coking_process_main")
public class CokingProcessMainEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    private String category;

    private String clock;

    private String infoType;

    private String indName;

    private String avgValue;

    private String theoryValue;

    private String actual_value;

    private String stand_value;

    private String real_value;

    private Integer sort;
}

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

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Data
@TableName("t_coking_prod_day")
public class CokingProdDayEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    private String clock;

    private String infoType;

    private String indName;

    private String indUnit;

    private String indValue;

    private Integer sort;

}

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

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

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

/**
 * 电力功率因数电容器投运状态
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
@TableName("t_power_capacitor_status")
public class PowerCapacitorStatusEntity {

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 电容器名称
     */
    private String name;
    /**
     * 主变数量
     */
    private String mainCount;
    /**
     * 主变测点编码
     */
    private String mainPoint;
    /**
     * 下属数量
     */
    private String childCount;
    /**
     * 下属测点编码
     */
    private String childPoint;
    /**
     * 投运数量
     */
    private String onCount;
    /**
     * 备注
     */
    private String remark;
    /**
     * 排序
     */
    private Integer sort;
}

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

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

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

import java.math.BigDecimal;

/**
 * 电力功率因数管控功率因数从表
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
@TableName("t_power_control_det")
public class PowerControlDetEntity {

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 主表ID
     */
    private String controlId;
    /**
     * 名称
     */
    private String name;
    /**
     * 测点
     */
    private String point;
    /**
     * 下限
     */
    private BigDecimal limitL;
    /**
     * 是否超限(0:正常，1：超限)
     */
    private Integer status;
    /**
     * 排序
     */
    private Integer sort;
}

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

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

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

/**
 * 电力功率因数管控功率因数主表
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
@TableName("t_power_control_main")
public class PowerControlMainEntity {

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 名称
     */
    private String name;
    /**
     * 备注
     */
    private String remark;
    /**
     * 排序
     */
    private Integer sort;
}

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

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

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

import java.math.BigDecimal;

/**
 * 电力功率因数电网拓扑
 *
 * @author Mark sunlightcs@gmail.com
 * @since 1.0.0 2025-04-11
 */
@Data
@TableName("t_power_net_factor")
public class PowerNetFactorEntity {

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 分组名称
     */
    private String groupName;
    /**
     * 节点名称
     */
    private String nodeName;
    /**
     * 当前有功
     */
    private String curP;
    /**
     * 当前无功
     */
    private String curQ;
    /**
     * 当前功率因数
     */
    private String curCos;
    /**
     * 预测有功
     */
    private String preP;
    /**
     * 预测无功
     */
    private String preQ;
    /**
     * 预测功率因数
     */
    private String preCos;
    /**
     * 预测项ID
     */
    private String itemId;
    /**
     * 预测项输出ID
     */
    private String outId;
    /**
     * 上限
     */
    private BigDecimal limitH;
    /**
     * 下限
     */
    private BigDecimal limitL;
    /**
     * 是否超限(0:正常，1：超限)
     */
    private Integer status;
    /**
     * 排序
     */
    private Integer sort;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/CokingAnalyIndService.java

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

import com.iailab.module.ansteel.api.entity.CokingAnalyIndEntity;

import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
public interface CokingAnalyIndService {

    List<CokingAnalyIndEntity> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/CokingAnalyTrendService.java

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

import com.iailab.module.ansteel.api.entity.CokingAnalyTrendEntity;

import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
public interface CokingAnalyTrendService {

    List<CokingAnalyTrendEntity> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/CokingProcessChildService.java

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

import com.iailab.module.ansteel.api.entity.CokingProcessChildEntity;

import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
public interface CokingProcessChildService {

    List<CokingProcessChildEntity> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/CokingProcessMainService.java

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

import com.iailab.module.ansteel.api.entity.CokingProcessMainEntity;

import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
public interface CokingProcessMainService {

    List<CokingProcessMainEntity> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/CokingProdDayService.java

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

import com.iailab.module.ansteel.api.entity.CokingProdDayEntity;

import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
public interface CokingProdDayService {

    List<CokingProdDayEntity> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java

@@ -24,4 +24,12 @@
    List<MainProcessIndexDTO> getIndexList(Map<String, Object> params);

    Boolean useSuggest(StAlarmAndSuggestReqVO ReqVO);

    List<PowerNetFactorDTO> getPowerNetFactorList();

    List<PowerCapacitorStatusDTO> getPowerCapacitorStatusList();

    List<PowerControlMainDTO> getPowerControlMainList();

    List<PowerControlDetDTO> getPowerControlDetList(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/CokingAnalyIndServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.api.dao.CokingAnalyIndDao;
import com.iailab.module.ansteel.api.entity.CokingAnalyIndEntity;
import com.iailab.module.ansteel.api.service.CokingAnalyIndService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@Service
public class CokingAnalyIndServiceImpl implements CokingAnalyIndService {

    @Resource
    private CokingAnalyIndDao cokingAnalyIndDao;

    @Override
    public List<CokingAnalyIndEntity> list(Map<String, Object> params) {
        QueryWrapper<CokingAnalyIndEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return cokingAnalyIndDao.selectList(queryWrapper);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/CokingAnalyTrendServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.api.dao.CokingAnalyTrendDao;
import com.iailab.module.ansteel.api.entity.CokingAnalyTrendEntity;
import com.iailab.module.ansteel.api.service.CokingAnalyTrendService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@Service
public class CokingAnalyTrendServiceImpl implements CokingAnalyTrendService {

    @Resource
    private CokingAnalyTrendDao cokingAnalyTrendDao;

    @Override
    public List<CokingAnalyTrendEntity> list(Map<String, Object> params) {
        QueryWrapper<CokingAnalyTrendEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return cokingAnalyTrendDao.selectList(queryWrapper);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/CokingProcessChildServiceImpl.java

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

import com.iailab.module.ansteel.api.entity.CokingProcessChildEntity;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.api.dao.CokingProcessChildDao;
import com.iailab.module.ansteel.api.service.CokingProcessChildService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@Service
public class CokingProcessChildServiceImpl implements CokingProcessChildService {

    @Resource
    private CokingProcessChildDao cokingProcessChildDao;

    @Override
    public List<CokingProcessChildEntity> list(Map<String, Object> params) {
        QueryWrapper<CokingProcessChildEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return cokingProcessChildDao.selectList(queryWrapper);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/CokingProcessMainServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.api.dao.CokingProcessMainDao;
import com.iailab.module.ansteel.api.entity.CokingProcessMainEntity;
import com.iailab.module.ansteel.api.service.CokingProcessMainService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@Service
public class CokingProcessMainServiceImpl implements CokingProcessMainService {

    @Resource
    private CokingProcessMainDao cokingProcessMainDao;

    @Override
    public List<CokingProcessMainEntity> list(Map<String, Object> params) {
        QueryWrapper<CokingProcessMainEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return cokingProcessMainDao.selectList(queryWrapper);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/CokingProdDayServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.api.dao.CokingProdDayDao;
import com.iailab.module.ansteel.api.entity.CokingProdDayEntity;
import com.iailab.module.ansteel.api.service.CokingProdDayService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月11日
 */
@Slf4j
@Service
public class CokingProdDayServiceImpl implements CokingProdDayService {

    @Resource
    private CokingProdDayDao cokingProdDayDao;

    @Override
    public List<CokingProdDayEntity> list(Map<String, Object> params) {
        QueryWrapper<CokingProdDayEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return cokingProdDayDao.selectList(queryWrapper);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java

@@ -3,10 +3,12 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.module.ansteel.api.dao.MainProcessIndexDayDao;
import com.iailab.module.ansteel.api.dao.MainProcessIndexTeamDao;
import com.iailab.module.ansteel.api.dao.PowerRunStateDao;
import com.iailab.module.ansteel.api.dao.*;
import com.iailab.module.ansteel.api.dto.*;
import com.iailab.module.ansteel.api.entity.PowerCapacitorStatusEntity;
import com.iailab.module.ansteel.api.entity.PowerControlDetEntity;
import com.iailab.module.ansteel.api.entity.PowerControlMainEntity;
import com.iailab.module.ansteel.api.entity.PowerNetFactorEntity;
import com.iailab.module.ansteel.api.service.DataApi;
import com.iailab.module.ansteel.common.constant.CommonConstant;
import com.iailab.module.data.api.plan.PlanItemApi;
@@ -48,6 +50,18 @@

    @Autowired
    private MainProcessIndexTeamDao mainProcessIndexTeamDao;

    @Autowired
    private PowerNetFactorDao powerNetFactorDao;

    @Autowired
    private PowerCapacitorStatusDao powerCapacitorStatusDao;

    @Autowired
    private PowerControlMainDao powerControlMainDao;

    @Autowired
    private PowerControlDetDao powerControlDetDao;

    @Override
    public List<PowerRunStateDTO> getPowerRunState() {
@@ -327,4 +341,27 @@
        }
        return endTime;
    }

    @Override
    public List<PowerNetFactorDTO> getPowerNetFactorList() {
        return ConvertUtils.sourceToTarget(powerNetFactorDao.selectList(new QueryWrapper<PowerNetFactorEntity>().orderByAsc("sort")), PowerNetFactorDTO.class);
    }

    @Override
    public List<PowerCapacitorStatusDTO> getPowerCapacitorStatusList() {
        return ConvertUtils.sourceToTarget(powerCapacitorStatusDao.selectList(new QueryWrapper<PowerCapacitorStatusEntity>().orderByAsc("sort")), PowerCapacitorStatusDTO.class);
    }

    @Override
    public List<PowerControlMainDTO> getPowerControlMainList() {
        return ConvertUtils.sourceToTarget(powerControlMainDao.selectList(new QueryWrapper<PowerControlMainEntity>().orderByAsc("sort")), PowerControlMainDTO.class);
    }

    @Override
    public List<PowerControlDetDTO> getPowerControlDetList(Map<String, Object> params) {
        QueryWrapper<PowerControlDetEntity> wrapper = new QueryWrapper<>();
        wrapper.eq("control_id", params.get("control_id"));
        wrapper.orderByAsc("sort");
        return ConvertUtils.sourceToTarget(powerControlDetDao.selectList(wrapper), PowerControlDetDTO.class);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/config/ScheduleConfig.java

@@ -22,7 +22,7 @@

        //quartz参数
        Properties prop = new Properties();
        prop.put("org.quartz.scheduler.instanceName", "IailabDataScheduler");
        prop.put("org.quartz.scheduler.instanceName", "IailabAnSteelScheduler");
        prop.put("org.quartz.scheduler.instanceId", "AUTO");
        //线程池配置
        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
@@ -44,7 +44,7 @@

        factory.setQuartzProperties(prop);

        factory.setSchedulerName("IailabDataScheduler");
        factory.setSchedulerName("IailabAnSteelScheduler");
        //延时启动
        factory.setStartupDelay(30);
        factory.setApplicationContextSchedulerContextKey("applicationContextKey");

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/utils/ScheduleJob.java

@@ -74,7 +74,7 @@
        }finally {
            //获取spring bean
            ScheduleJobLogService scheduleJobLogService = SpringContextUtils.getBean(ScheduleJobLogService.class);
            scheduleJobLogService.insert(log);
            // scheduleJobLogService.insert(log);
        }
    }
}

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

Binary files differ

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

Binary files differ