发电厂机组运行情况

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/controller/PowerRunStateController.java

对比新文件
@@ -0,0 +1,36 @@
package com.iailab.module.ansteel.mpk.controller;

import com.iailab.framework.common.pojo.CommonResult;
import com.iailab.module.ansteel.mpk.entity.PowerRunStateEntity;
import com.iailab.module.ansteel.mpk.service.PowerRunStateService;
import io.swagger.v3.oas.annotations.tags.Tag;
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: lirm
 * @date: 2025/03/17
 **/
@Tag(name = "发电厂机组运行情况")
@RestController
@RequestMapping("/mpk/power-run-state")
public class PowerRunStateController {

    @Autowired
    private PowerRunStateService powerRunStateService;

    @GetMapping("list")
    public CommonResult<List<PowerRunStateEntity>> list(@RequestParam Map<String, Object> params) {
        List<PowerRunStateEntity> list = powerRunStateService.list();
        return success(list);
    }

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/dao/PowerRunStateDao.java

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

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

@TenantDS
@Mapper
public interface PowerRunStateDao extends BaseDao<PowerRunStateEntity> {

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/dao/ProductProcessDao.java

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

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

@TenantDS
@Mapper
public interface ProductProcessDao extends BaseDao<ProductProcessEntity> {

}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/entity/PowerRunStateEntity.java

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

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

import java.io.Serializable;

/**
 * @description: 发电厂机组运行情况
 * @author: lirm
 * @date: 2025/03/13
 **/
@Data
@TableName("t_power_run_state")
public class PowerRunStateEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 机组名称
     */
    private String machineName;
    /**
     * 气耗率
     */
    private String qhRate;
    /**
     * 负荷率
     */
    private String fhRate;
    /**
     * 煤气总消耗
     */
    private String gasTotal;
    /**
     * 煤气可消纳量
     */
    private String gasCost;
    /**
     * 煤气剩余调节量
     */
    private String gasSurplus;
    /**
     * BFG
     */
    private String bfg;
    /**
     * COG
     */
    private String ldg;
    /**
     * LDG
     */
    private String cog;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/entity/ProductProcessEntity.java

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

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

import java.io.Serializable;

/**
 * @description: 工序
 * @author: lirm
 * @date: 2025/03/13
 **/
@Data
@TableName("t_product_process")
public class ProductProcessEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * id
     */
    @TableId
    private String id;
    /**
     * 工序名称
     */
    private String name;
    /**
     * BFG单耗
     */
    private String bfgCost;
    /**
     * BFG产率
     */
    private String bfgProdRate;
    /**
     * COG单耗
     */
    private String cogCost;
    /**
     * COG产率
     */
    private String cogProdRate;
    /**
     * LDG单耗
     */
    private String ldgCost;
    /**
     * LDG产率
     */
    private String ldgProdRate;
    /**
     * 混合煤气单耗
     */
    private String gasCost;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/service/PowerRunStateService.java

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


import com.iailab.module.ansteel.mpk.entity.PowerRunStateEntity;

import java.util.List;

public interface PowerRunStateService {

    List<PowerRunStateEntity> list();
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/service/ProductProcessService.java

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


import com.iailab.module.ansteel.mpk.entity.ProductProcessEntity;

import java.util.List;

public interface ProductProcessService {

    List<ProductProcessEntity> list();
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/service/impl/PowerRunStateServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.module.ansteel.mpk.dao.PowerRunStateDao;
import com.iailab.module.ansteel.mpk.entity.PowerRunStateEntity;
import com.iailab.module.ansteel.mpk.service.PowerRunStateService;
import com.iailab.module.data.api.point.DataPointApi;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;

import java.math.BigDecimal;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Slf4j
@Service
public class PowerRunStateServiceImpl extends BaseServiceImpl<PowerRunStateDao, PowerRunStateEntity> implements PowerRunStateService {

    @Autowired
    private DataPointApi dataPointApi;

    @Override
    public List<PowerRunStateEntity> list() {
        List<PowerRunStateEntity> list = baseDao.selectList(new QueryWrapper<>());
        if (!CollectionUtils.isEmpty(list)) {
            list.stream().map(item -> {
                StringBuffer sb = new StringBuffer();
                sb.append(item.getQhRate());
                sb.append(",");
                sb.append(item.getFhRate());
                sb.append(",");
                sb.append(item.getGasTotal());
                sb.append(",");
                sb.append(item.getGasCost());
                sb.append(",");
                sb.append(item.getGasSurplus());
                sb.append(",");
                sb.append(item.getBfg());
                sb.append(",");
                sb.append(item.getLdg());
                sb.append(",");
                sb.append(item.getCog());
                String[] arr = sb.toString().split(",");
                Map<String, Object> adjValue = dataPointApi.queryPointsRealValue(Arrays.asList(arr));
                item.setQhRate(ObjectUtils.isEmpty(adjValue.get(arr[0])) ? "0" : new BigDecimal(adjValue.get(arr[0]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setFhRate(ObjectUtils.isEmpty(adjValue.get(arr[1])) ? "0" : new BigDecimal(adjValue.get(arr[1]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setGasTotal(ObjectUtils.isEmpty(adjValue.get(arr[2])) ? "0" : new BigDecimal(adjValue.get(arr[2]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setGasCost(ObjectUtils.isEmpty(adjValue.get(arr[3])) ? "0" : new BigDecimal(adjValue.get(arr[3]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setGasSurplus(ObjectUtils.isEmpty(adjValue.get(arr[4])) ? "0" : new BigDecimal(adjValue.get(arr[4]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setBfg(ObjectUtils.isEmpty(adjValue.get(arr[5])) ? "0" : new BigDecimal(adjValue.get(arr[5]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setLdg(ObjectUtils.isEmpty(adjValue.get(arr[6])) ? "0" : new BigDecimal(adjValue.get(arr[6]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
                item.setCog(ObjectUtils.isEmpty(adjValue.get(arr[7])) ? "0" : new BigDecimal(adjValue.get(arr[7]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());

                return item;
            }).collect(Collectors.toList());
        }
        return list;
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/mpk/service/impl/ProductProcessServiceImpl.java

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.module.ansteel.mpk.dao.ProductProcessDao;
import com.iailab.module.ansteel.mpk.entity.ProductProcessEntity;
import com.iailab.module.ansteel.mpk.service.ProductProcessService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.List;

@Slf4j
@Service
public class ProductProcessServiceImpl extends BaseServiceImpl<ProductProcessDao, ProductProcessEntity> implements ProductProcessService {


    @Override
    public List<ProductProcessEntity> list() {
        return baseDao.selectList(new QueryWrapper<>());
    }
}