告警参数控制和模块参数控制

whyclxw

2024-01-22 fea6cf80f99019b86e4738ffa6da04259c5c7b5d

告警参数控制和模块参数控制

 src/main/java/com/whyc/mapper/CkPowerDevParamLogMapper.java

New file
@@ -0,0 +1,9 @@
package com.whyc.mapper;

import com.whyc.pojo.db_ckpwrdev_data_rt.CkPowerDevParamLog;

public interface CkPowerDevParamLogMapper extends CustomMapper<CkPowerDevParamLog>{

    //查询最大的操作编号
    String getOpNum();
}

 src/main/java/com/whyc/pojo/db_ckpwrdev_data_rt/CKPowerDevAlmParam.java

@@ -9,6 +9,7 @@
import lombok.Data;

import java.io.Serializable;
import java.util.List;

/**
 *
@@ -71,4 +72,8 @@
    private Float acLowVolAlmVal;


    @TableField(exist = false)
    private List logList;


}

 src/main/java/com/whyc/pojo/db_ckpwrdev_data_rt/CKPowerDevModeparam.java

@@ -1,6 +1,7 @@
package com.whyc.pojo.db_ckpwrdev_data_rt;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
@@ -10,6 +11,7 @@
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.List;

/**
 * <p>
@@ -52,5 +54,8 @@
    @ApiModelProperty(value = "模块均充电压")
    private Float modeJunChrvol;

    @TableField(exist = false)
    private List logList;


}

 src/main/java/com/whyc/pojo/db_ckpwrdev_data_rt/CkPowerDevParamLog.java

New file
@@ -0,0 +1,52 @@
package com.whyc.pojo.db_ckpwrdev_data_rt;

import com.baomidou.mybatisplus.annotation.*;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;

/**
 * <p>
 * 参数阈值设置表
 * </p>
 *
 * @author lxw
 * @since 2024-01-22
 */
@Data
@TableName("tb_ckpowerdev_param_log")
@ApiModel(value="CkpowerdevParamLog对象", description="参数阈值设置表")
public class CkPowerDevParamLog implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableId(value = "id", type = IdType.AUTO)
    private Long id;

    @ApiModelProperty(value = "操作编号")
    private String opNum;

    @ApiModelProperty(value = "操作类型")
    private Integer cmdType;

    @ApiModelProperty(value = "被设置的参数")
    private String param;

    @ApiModelProperty(value = "被设置的参数中文名")
    private String paramCn;

    @ApiModelProperty(value = "值")
    private String value;

    @TableField(fill = FieldFill.INSERT)
    private Date createTime;

    private Date createDay;


}

 src/main/java/com/whyc/service/CKPowerDevAlmParamService.java

@@ -7,23 +7,49 @@
import com.whyc.constant.CMD_Constant;
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevAlmParamMapper;
import com.whyc.mapper.CKPowerDevBattSetLogMapper;
import com.whyc.mapper.CkPowerDevParamLogMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevAlmParam;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattSetLog;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSet;
import com.whyc.pojo.db_ckpwrdev_data_rt.CkPowerDevParamLog;
import com.whyc.util.OpCmdUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

@Service
public class CKPowerDevAlmParamService {
    @Autowired(required = false)
    private CKPowerDevAlmParamMapper mapper;

    @Resource
    private CkPowerDevParamLogMapper logMapper;

    @Resource
    private CkPowerDevParamLogService logService;

    //读取告警控制
    public Response getAlmParam() {
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevAlmParam> query = Wrappers.query();
        Response res=OpCmdUtil.readByUpdateOpCmd(mapper,query, CMD_Constant.CMD_GetAlarmParam,20,null);
        return res;
        Response opStatus=OpCmdUtil.readByUpdateOpCmd(mapper,query, CMD_Constant.CMD_GetAlarmParam,20,null);
        if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功
            //记录日志
            Date now = new Date();
            CkPowerDevParamLog log=new  CkPowerDevParamLog();
            //查询最大的操作编号
            String opNum=logMapper.getOpNum()!=null?logMapper.getOpNum():"0";
            log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1));
            log.setCreateTime(now);
            log.setCreateDay(now);
            log.setCmdType(CMD_Constant.CMD_GetAlarmParam);
            logService.add(log);
        }
        return opStatus;
    }

    //设置告警参数
@@ -31,6 +57,21 @@
        mapper.update(almParam,null);
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevAlmParam> query = Wrappers.query();
        return OpCmdUtil.getOpStatus(mapper,query, CMD_Constant.CMD_SetAlarmParam,20,null);
        Response opStatus=OpCmdUtil.getOpStatus(mapper,query, CMD_Constant.CMD_SetAlarmParam,20,null);
        if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功
            //记录日志
            Date now = new Date();
            List<CkPowerDevParamLog> logList = almParam.getLogList();
            //查询最大的操作编号
            String opNum=logMapper.getOpNum()!=null?logMapper.getOpNum():"0";
            logList.forEach(log->{
                log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1));
                log.setCmdType(CMD_Constant.CMD_SetAlarmParam);
                log.setCreateTime(now);
                log.setCreateDay(now);
            });
            logService.addBatch(logList);
        }
        return opStatus;
    }
}

 src/main/java/com/whyc/service/CKPowerDevModeparamService.java

@@ -5,29 +5,68 @@
import com.whyc.constant.CMD_Constant;
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevModeparamMapper;
import com.whyc.mapper.CkPowerDevParamLogMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevAlmParam;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevModeparam;
import com.whyc.pojo.db_ckpwrdev_data_rt.CkPowerDevParamLog;
import com.whyc.util.OpCmdUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

@Service
public class CKPowerDevModeparamService {
    @Autowired(required = false)
    private CKPowerDevModeparamMapper mapper;

    @Resource
    private CkPowerDevParamLogMapper logMapper;

    @Resource
    private CkPowerDevParamLogService logService;

    //读取模块参数
    public Response getModeParam() {
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevModeparam> query = Wrappers.query();
        Response res= OpCmdUtil.readByUpdateOpCmd(mapper,query, CMD_Constant.CMD_GetModelParam,20,null);
        return res;
        Response opStatus= OpCmdUtil.readByUpdateOpCmd(mapper,query, CMD_Constant.CMD_GetModelParam,20,null);
        if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功
            //记录日志
            Date now = new Date();
            CkPowerDevParamLog log=new  CkPowerDevParamLog();
            //查询最大的操作编号
            String opNum=logMapper.getOpNum()!=null?logMapper.getOpNum():"0";
            log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1));
            log.setCreateTime(now);
            log.setCreateDay(now);
            log.setCmdType(CMD_Constant.CMD_GetModelParam);
            logService.add(log);
        }
        return opStatus;
    }
    //设置模块参数
    public Response setModeParam(CKPowerDevModeparam modeParam) {
        mapper.update(modeParam,null);
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevModeparam> query = Wrappers.query();
        return OpCmdUtil.getOpStatus(mapper,query, CMD_Constant.CMD_SetModelParam,20,null);
        Response opStatus=OpCmdUtil.getOpStatus(mapper,query, CMD_Constant.CMD_SetModelParam,20,null);
        if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功
            //记录日志
            Date now = new Date();
            List<CkPowerDevParamLog> logList = modeParam.getLogList();
            //查询最大的操作编号
            String opNum=logMapper.getOpNum()!=null?logMapper.getOpNum():"0";
            logList.forEach(log->{
                log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1));
                log.setCmdType(CMD_Constant.CMD_SetModelParam);
                log.setCreateTime(now);
                log.setCreateDay(now);
            });
            logService.addBatch(logList);
        }
        return opStatus;
    }
}

 src/main/java/com/whyc/service/CkPowerDevParamLogService.java

New file
@@ -0,0 +1,24 @@
package com.whyc.service;

import com.whyc.mapper.CkPowerDevParamLogMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattSetLog;
import com.whyc.pojo.db_ckpwrdev_data_rt.CkPowerDevParamLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class CkPowerDevParamLogService {
    @Autowired(required = false)
    private CkPowerDevParamLogMapper mapper;

    //添加记录
    public void addBatch(List<CkPowerDevParamLog> logList) {
        mapper.insertBatchSomeColumn(logList);
    }
    //添加记录单条
    public void add(CkPowerDevParamLog log) {
        mapper.insert(log);
    }
}

 src/main/resources/mapper/CkPowerDevParamLogMapper.xml

New file
@@ -0,0 +1,10 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.CkPowerDevParamLogMapper" >


    <select id="getOpNum" resultType="java.lang.String">
        select op_num from db_ckpwrdev_data_rt.tb_ckpowerdev_param_log
        order by id desc limit 1
    </select>
</mapper>