Merge remote-tracking branch 'origin/master'

 ansteel-biz/db/mysql.sql

@@ -570,4 +570,47 @@
    `power_c` decimal(10, 4) NULL DEFAULT NULL COMMENT '电力消耗',
    PRIMARY KEY (`id`) USING BTREE,
    key       idx_rel_id (rel_id)
) 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_trace_energy`;
CREATE TABLE `t_coking_trace_energy`
(
    `id`      varchar(36) NOT NULL COMMENT 'id',
    `rel_id`  varchar(36) NULL DEFAULT NULL COMMENT '关联ID',
    `type`    varchar(20) NULL DEFAULT NULL COMMENT '类型',
    `clock`   varchar(20) NULL DEFAULT NULL COMMENT '查询时间',
    `steam_p` decimal(10, 4) NULL DEFAULT NULL COMMENT '蒸汽发生',
    `steam_c` decimal(10, 4) NULL DEFAULT NULL COMMENT '蒸汽消耗',
    `gas_p`   decimal(10, 4) NULL DEFAULT NULL COMMENT '煤气发生',
    `gas_c`   decimal(10, 4) NULL DEFAULT NULL COMMENT '煤气消耗',
    `power_c` decimal(10, 4) NULL DEFAULT NULL COMMENT '电力消耗',
    PRIMARY KEY (`id`) USING BTREE,
    key       idx_rel_id (rel_id)
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC COMMENT '焦化工序能耗整体情况';

-- ----------------------------
-- 焦化工序-指标值溯源
-- ----------------------------
DROP TABLE IF EXISTS `t_coking_trace_ind`;
CREATE TABLE `t_coking_trace_ind`
(
    `id`        varchar(36) NOT NULL COMMENT 'id',
    `rel_id`    varchar(36) NULL DEFAULT NULL COMMENT '关联ID',
    `title`      varchar(20) NULL DEFAULT NULL COMMENT '标题',
    `clock`     varchar(20) NULL DEFAULT NULL COMMENT '查询时间',
    `ind_name`  varchar(20) NULL DEFAULT NULL COMMENT '名称',
    `ind_value` varchar(20) NULL DEFAULT NULL COMMENT '值',
    `ind_unit`  varchar(20) 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,
    key         idx_rel_id (rel_id)
) 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

@@ -3,6 +3,7 @@
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.coking.dto.CokingTraceEnergyDTO;
import com.iailab.module.ansteel.coking.entity.*;
import com.iailab.module.ansteel.coking.service.*;
import io.swagger.v3.oas.annotations.Operation;
@@ -45,6 +46,9 @@
    @Autowired
    private CokingProdDayService cokingProdDayService;

    @Autowired
    private CokingTraceEnergyService cokingTraceEnergyService;

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


    @GetMapping("/trace-energy/list")
    @Operation(summary = "焦化工序-能耗整体情况")
    public CommonResult<Map<String,List<CokingTraceEnergyDTO>>> getEnergyConsumptionList(@RequestParam Map<String, Object> params) {
        Map<String,List<CokingTraceEnergyDTO>> result = cokingTraceEnergyService.list(params);
        return success(result);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/dao/CokingTraceIndDao.java

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

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

/**
 * 焦化工序指标值溯源
 *
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月17日
 */
@Mapper
public interface CokingTraceIndDao extends BaseDao<CokingTraceIndEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/dto/CokingTraceIndDTO.java

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

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

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月17日
 */
@Data
@Schema(description = "焦化工序能耗整体情况")
public class CokingTraceIndDTO implements Serializable {
    private static final long serialVersionUID = 1L;

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

    @Schema(description = "关联ID")
    private String relId;

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

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

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

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

    @Schema(description = "拓展字段1")
    private String ext1;

    @Schema(description = "拓展字段2")
    private String ext2;

    @Schema(description = "拓展字段3")
    private String ext3;

    @Schema(description = "拓展字段4")
    private String ext4;

    @Schema(description = "拓展字段5")
    private String ext5;

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

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/entity/CokingTraceIndEntity.java

对比新文件
@@ -0,0 +1,83 @@
package com.iailab.module.ansteel.coking.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月17日
 */
@Data
@TableName("t_coking_trace_ind")
public class CokingTraceIndEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    @TableId
    private String id;

    /**
     * 关联ID
     */
    private String relId;

    /**
     * 标题
     */
    private String title;

    /**
     * 查询时间
     */
    private String clock;

    /**
     * 名称
     */
    private String indName;

    /**
     * 值
     */
    private String indValue;

    /**
     * 单位
     */
    private String indUnit;

    /**
     * 拓展字段1
     */
    private String ext1;

    /**
     * 拓展字段2
     */
    private String ext2;

    /**
     * 拓展字段3
     */
    private String ext3;

    /**
     * 拓展字段4
     */
    private String ext4;

    /**
     * 拓展字段5
     */
    private String ext5;

    /**
     * 排序
     */
    private String sort;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceEnergyService.java

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


import com.iailab.module.ansteel.coking.dto.CokingTraceEnergyDTO;
import com.iailab.module.ansteel.coking.entity.CokingTraceEnergyEntity;

import java.util.List;
@@ -13,5 +14,5 @@
 * @since 1.0.0 2025-04-16
 */
public interface CokingTraceEnergyService {
    List<CokingTraceEnergyEntity> list(Map<String, Object> params);
    Map<String,List<CokingTraceEnergyDTO>> list(Map<String, Object> params);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java

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

import com.iailab.module.ansteel.coking.entity.CokingTraceIndEntity;

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

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月17日
 */
public interface CokingTraceIndService {

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

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceEnergyServiceImpl.java

@@ -1,14 +1,20 @@
package com.iailab.module.ansteel.coking.service.impl;

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.coking.dao.CokingTraceEnergyDao;
import com.iailab.module.ansteel.coking.dto.CokingTraceEnergyDTO;
import com.iailab.module.ansteel.coking.entity.CokingProdDayEntity;
import com.iailab.module.ansteel.coking.entity.CokingTraceEnergyEntity;
import com.iailab.module.ansteel.coking.service.CokingTraceEnergyService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

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

/**
 * 焦化工序能耗整体情况
@@ -23,7 +29,37 @@
    private CokingTraceEnergyDao cokingTraceEnergyDao;

    @Override
    public List<CokingTraceEnergyEntity> list(Map<String, Object> params) {
        return cokingTraceEnergyDao.selectList(new QueryWrapper<>());
    public Map<String,List<CokingTraceEnergyDTO>> list(Map<String, Object> params) {
        Map<String,List<CokingTraceEnergyDTO>> result = new HashMap<>(2);

        String clock = (String) params.get("clock");
        String month;
        if (StringUtils.isBlank(clock)) {
            Calendar calendar = Calendar.getInstance();
            calendar.add(Calendar.DAY_OF_YEAR, -1);
            clock = DateUtils.format(calendar.getTime(), "yyyy-MM-dd");
            month = DateUtils.format(calendar.getTime(), "yyyy-MM");
        }else {
            Date parse = DateUtils.parse(clock, "yyyy-MM-dd");
            month = DateUtils.format(parse, "yyyy-MM");
        }

        // 天数据
        QueryWrapper<CokingTraceEnergyEntity> queryWrapperDay = new QueryWrapper<>();
        queryWrapperDay.eq("clock", clock);
        List<CokingTraceEnergyEntity> dayList = cokingTraceEnergyDao.selectList(queryWrapperDay);
        result.put("day",ConvertUtils.sourceToTarget(dayList,CokingTraceEnergyDTO.class));

        // 月数据
        QueryWrapper<CokingTraceEnergyEntity> queryWrapperMonth = new QueryWrapper<>();
        queryWrapperMonth.like("clock", month);
        queryWrapperMonth.select("type","SUM(steam_p) as steam_p","SUM(steam_c) as steam_c","SUM(gas_p) as gas_p","SUM(gas_c) as gas_c","SUM(power_c) as power_c")
                .groupBy("type");

        List<CokingTraceEnergyEntity> monthList = cokingTraceEnergyDao.selectList(queryWrapperMonth);
        monthList.forEach(e -> e.setClock(month));
        result.put("month",ConvertUtils.sourceToTarget(monthList,CokingTraceEnergyDTO.class));

        return result;
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.coking.dao.CokingTraceIndDao;
import com.iailab.module.ansteel.coking.entity.CokingTraceIndEntity;
import com.iailab.module.ansteel.coking.service.CokingTraceIndService;
import org.springframework.stereotype.Service;

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

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年04月17日
 */
@Service
public class CokingTraceIndServiceImpl implements CokingTraceIndService {

    @Resource
    private CokingTraceIndDao cokingTraceIndDao;

    @Override
    public List<CokingTraceIndEntity> list(Map<String, Object> params) {
        String relId = (String) params.get("relId");
        QueryWrapper<CokingTraceIndEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("rel_id", relId);
        queryWrapper.orderByDesc("sort");
        return cokingTraceIndDao.selectList(queryWrapper);
    }
}

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

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

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * @description: 工序
 * @author: dzd
 * @date: 2025/4/17 15:58
 **/
@Getter
@AllArgsConstructor
public enum ProcessTypeEnum {
    GL("GL", "鼓冷"),
    LA("LA", "硫铵"),
    CB("CB", "粗苯"),
    TL("TL", "脱硫"),
    GXJ_1("GXJ_1", "1#干熄焦"),
    GXJ_2("GXJ_2", "2#干熄焦"),
    GXJ_3("GXJ_3", "3#干熄焦"),
    ALL("ALL", "总体");
    private String code;
    private String desc;

    public static ProcessTypeEnum getEumByCode(Integer code) {
        if (code == null) {
            return null;
        }

        for (ProcessTypeEnum statusEnum : ProcessTypeEnum.values()) {
            if (statusEnum.getCode().equals(code)) {
                return statusEnum;
            }
        }
        return null;
    }

}

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

Binary files differ