设备告警修改

whyclxw

2021-12-10 563091d892270b53ea5ef7e9c82c82ea3b39142a

设备告警修改

 src/main/java/com/whyc/controller/PwrdevAlarmController.java

New file
@@ -0,0 +1,28 @@
package com.whyc.controller;

import com.whyc.dto.Response;
import com.whyc.pojo.PwrdevAlarm;
import com.whyc.service.PwrdevAlarmService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "电源实时告警")
@RestController
@RequestMapping("/PowerAlarmAction")
public class PwrdevAlarmController {

    @Autowired
    private PwrdevAlarmService service;

    //电源实时告警查询
    @ApiOperation(value = "电源实时告警查询",notes="almTypes,almLevels,page,stationName1,stationName2,stationName3,stationName5,usrId,almSource")
    @PostMapping("/getAllPage")
    public Response getAllPage(@RequestBody PwrdevAlarm pwrdevAlarm){
        return service.getAllPage(pwrdevAlarm);
    }
}

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

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

import com.whyc.pojo.PwrdevAlarm;

import java.util.List;

public interface PwrdevAlarmMapper extends CustomMapper<PwrdevAlarm>{
    //电源实时告警
    List getAllPage(PwrdevAlarm pwrdevAlarm);
}

 src/main/java/com/whyc/pojo/PwrdevAlarm.java

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

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 com.fasterxml.jackson.annotation.JsonFormat;
import com.whyc.dto.Page;
import com.whyc.util.ActionUtil;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@TableName(schema = "db_pwrdev_inf",value = "tb_pwrdev_alarm")
@ApiModel(value="PwrdevAlarm对象", description="")
public class PwrdevAlarm implements Serializable {

    private static final long serialVersionUID = 1L;

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

    private Long recordId;

    @TableField("PowerDeviceId")
    private Long PowerDeviceId;

    private Integer almType;

    @TableField(exist = false)
    private List<Integer> almTypes;

    private Integer almLevel;

    @TableField(exist = false)
    private List<Integer> almLevels;

    @ApiModelProperty(value = "新增来源,1为设备自发,2为通过告警规则")
    private Integer almSource;

    private Integer almIndex;

    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date almStartTime;

    @TableField(exist = false)
    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date almStartTime1;

    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date almEndTime;

    private Float almValue;

    private Integer almIsConfirmed;

    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date almConfirmedTime;

    private Integer almClearedType;

    @TableField("usr_Id")
    private Integer usrId;

    @TableField(exist = false)
    @ApiModelProperty(value = "故障名称拼接")
    private String alarmName;

    @TableField(exist = false)
    @ApiModelProperty(value = "告警类型拼接")
    private String alarmLevels;

    @TableField(exist = false)
    @ApiModelProperty(value = "机房全名")
    private String stationName;

    @TableField(exist = false)
    @ApiModelProperty(value = "机房所在省")
    private String stationName1;

    @TableField(exist = false)
    @ApiModelProperty(value = "机房所在市")
    private String stationName2;

    @TableField(exist = false)
    @ApiModelProperty(value = "机房所在区县")
    private String stationName5;

    @TableField(exist = false)
    @ApiModelProperty(value = "机房名称")
    private String stationName3;
    
    @TableField(exist = false)
    private Page page;

}

 src/main/java/com/whyc/pojo/PwrdevAlarmConfig.java

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

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;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_alarm_config")
@ApiModel(value="PwrdevAlarmConfig对象", description="")
public class PwrdevAlarmConfig implements Serializable {

    private static final long serialVersionUID = 1L;

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

    @TableField("SMS_CommPort")
    private String smsCommport;

    @TableField("SMS_CommPort_ReInit")
    private Integer smsCommportReinit;

    @TableField("Beeper_CommPort")
    private String beeperCommport;

    @TableField("Beeper_CommPort_ReInit")
    private Integer beeperCommportReinit;

    @TableField("SMS_Alarm_Text")
    private String smsAlarmText;

    @TableField("SMS_Alarm_EN")
    private Integer smsAlarmEn;

    @TableField("Beeper_Alarm_EN")
    private Integer beeperAlarmEn;

    @TableField("Beeper_Sound_OFF")
    private Integer beeperSoundOff;

    @TableField("AlarmDevIP")
    private String AlarmDevIP;

    @TableField("SMS_Alarm_ipPort")
    private Integer smsAlarmIpport;

    @TableField("Beeper_Alarm_ipPort")
    private Integer beeperAlarmIpport;


}

 src/main/java/com/whyc/pojo/PwrdevAlarmHistory.java

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

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;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_alarm_history")
@ApiModel(value="PwrdevAlarmHistory对象", description="")
public class PwrdevAlarmHistory implements Serializable {

    private static final long serialVersionUID = 1L;

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

    private Long recordId;

    @TableField("PowerDeviceId")
    private Long PowerDeviceId;

    private Integer almType;

    private Integer almLevel;

    private Integer almSource;

    private Integer almIndex;

    private Date almStartTime;

    private Date almEndTime;

    private Float almValue;

    private Integer almIsConfirmed;

    private Date almConfirmedTime;

    private Integer almClearedType;

    @TableField("usr_Id")
    private Integer usrId;


}

 src/main/java/com/whyc/pojo/PwrdevAlarmParam.java

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

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;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_alarm_param")
@ApiModel(value="PwrdevAlarmParam对象", description="")
public class PwrdevAlarmParam implements Serializable {

    private static final long serialVersionUID = 1L;

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

    private Long alarmId;

    @TableField("alarm_limitH")
    private Float alarmLimith;

    @TableField("alarm_limitL")
    private Float alarmLimitl;

    @ApiModelProperty(value = "是否可以设置上下限")
    @TableField("alarm_limitEn")
    private Integer alarmLimiten;

    @ApiModelProperty(value = "告警规则是否启动")
    @TableField("UserAlarm_EN")
    private Integer useralarmEn;

    private Integer alarmLevel;

    private Integer alarmDevtype;

    private String alarmName;


}

 src/main/java/com/whyc/pojo/PwrdevTimeAdjAlarm.java

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

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;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_time_adj_alarm")
@ApiModel(value="PwrdevTimeAdjAlarm对象", description="")
public class PwrdevTimeAdjAlarm implements Serializable {

    private static final long serialVersionUID = 1L;

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

    @TableField("PowerDeviceId")
    private Long PowerDeviceId;

    @TableField("alarm_typeId")
    private Integer alarmTypeid;

    private Date detectDatetime;

    private Date recordDatetime;


}

 src/main/java/com/whyc/pojo/PwrdevTimeOutAlarm.java

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

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;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2021-12-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_time_out_alarm")
@ApiModel(value="PwrdevTimeOutAlarm对象", description="")
public class PwrdevTimeOutAlarm implements Serializable {

    private static final long serialVersionUID = 1L;

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

    @TableField("PowerDeviceId")
    private Long PowerDeviceId;

    @TableField("alarm_typeId")
    private Integer alarmTypeid;

    private Integer alarmIndex;

    private Integer timeoutTag;

    private Date readDatetime;

    private Date systemDatetime;

    private Date resumeDatetime;


}

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

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

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.PwrdevAlarmMapper;
import com.whyc.pojo.PwrdevAlarm;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;

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

@Service
public class PwrdevAlarmService {

    @Resource
    private PwrdevAlarmMapper mapper;

    //电源实时告警查询
    public Response getAllPage(PwrdevAlarm pwrdevAlarm){
        //分页信息
        PageHelper.startPage(pwrdevAlarm.getPage().getPageCurr(), pwrdevAlarm.getPage().getPageSize());
        pwrdevAlarm.setUsrId(ActionUtil.getUser().getUId().intValue());
        List list=mapper.getAllPage(pwrdevAlarm);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
}

 src/main/resources/mapper/PwrdevAlarmMapper.xml

New file
@@ -0,0 +1,48 @@
<?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.PwrdevAlarmMapper" >

    <select id="getAllPage" resultType="PwrdevAlarm">
        select  alarm.*,inf.StationName from db_pwrdev_alarm.tb_pwrdev_alarm alarm,db_pwrdev_inf.tb_pwrdev_inf inf
        <where>
            alarm.PowerDeviceId = inf.PowerDeviceId
            <if test="stationName1!=null ">
                and stationName1 like '%${stationName1}%'
            </if>
            <if test="stationName2!=null ">
                and stationName2 like '%${stationName2}%'
            </if>
            <if test="stationName5!=null ">
                and stationName5 like '%${stationName5}%'
            </if>
            <if test="stationName3!=null ">
                and stationName3 like '%${stationName3}%'
            </if>
            <if test="almSource!=null">
                and alm_source=#{almSource}
            </if>
            <if test="almTypes!=null and almTypes.size>0">
                <foreach collection="almTypes" item="almType" open="and alm_type in (" close=")" separator=",">
                   #{almType}
                </foreach>
            </if>
            <if test="almLevels!=null and almLevels.size>0">
                <foreach collection="almLevels" item="almLevel" open="and alm_level in (" close=")" separator=",">
                    #{almLevel}
                </foreach>
            </if>
            and StationId in ( select distinct inf.StationId from
            (select StationId from db_battinf.tb_battinf union select StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf,
            db_user.tb_user_battgroup_baojigroup_battgroup,
            db_user.tb_user_battgroup_baojigroup_usr,
            db_user.tb_user_inf
            where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId
            and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
            and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid
            and db_user.tb_user_inf.uid=#{usrId} )
        </where>
    </select>



</mapper>