设备超时告警

whyclxw

2021-12-13 5b0c33ff4ef4884e23482df5cd61ab97fa4fe998

设备超时告警

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

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

import com.whyc.dto.Response;
import com.whyc.service.PwrdevTimeOutAlarmService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "通讯电源超时告警")
@RestController
@RequestMapping("/PowerAlarmTimeoutAction")
public class PwrdevTimeOutAlarmController {
    @Autowired
    private PwrdevTimeOutAlarmService service;

    //设备超时告警
    @PutMapping("/getList")
    @ApiOperation("设备超时告警")
    public Response getList(){
        return service.getList();
    }

}

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

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

import com.whyc.pojo.PwrdevTimeOutAlarm;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface PwrdevTimeOutAlarmMapper extends CustomMapper<PwrdevTimeOutAlarm>{
    //设备超时告警
    List getList(int uId, @Param("alarmParamTableName") String alarmParamTableName);
}

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

@@ -4,9 +4,9 @@
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 io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.*;
import lombok.experimental.Accessors;

import java.io.Serializable;
@@ -21,9 +21,12 @@
 * @since 2021-12-10
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_pwrdev_time_out_alarm")
@TableName(schema ="db_pwrdev_alarm" ,value = "tb_pwrdev_time_out_alarm")
@ApiModel(value="PwrdevTimeOutAlarm对象", description="")
public class PwrdevTimeOutAlarm implements Serializable {

@@ -42,11 +45,20 @@

    private Integer timeoutTag;

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

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

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

    //多表查询
    @TableField("alarm_name")
    private String alarmName;

    private String stationName;


}

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

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

import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.PwrdevAlarmParamMapper;
import com.whyc.mapper.PwrdevTimeOutAlarmMapper;
import com.whyc.pojo.PwrdevTimeOutAlarm;
import com.whyc.pojo.UserInf;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;

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

@Service
public class PwrdevTimeOutAlarmService {
    @Resource
    private PwrdevTimeOutAlarmMapper mapper;
    @Resource
    private PwrdevAlarmParamMapper paramMapper;

    //设备超时告警
    public Response getList() {
        List<String> tablelist=paramMapper.getParamList();
        //取第一条记录,即param表
        String alarmParamTableName = tablelist.get(0);
        UserInf uinf= ActionUtil.getUser();
        List<PwrdevTimeOutAlarm> list=mapper.getList(uinf.getUId().intValue(),alarmParamTableName);
        for (PwrdevTimeOutAlarm p:list){
            int alarm_index = p.getAlarmIndex();
            String alarm_name = p.getAlarmName();
            if (alarm_index != 0) {
                String a = alarm_index + "";
                alarm_name = alarm_name.replace("N", a);
            }
            p.setAlarmName(alarm_name);
        }
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
}

 src/main/resources/mapper/PwrdevTimeOutAlarmMapper.xml

New file
@@ -0,0 +1,18 @@
<?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.PwrdevTimeOutAlarmMapper">
    <select id="getList" resultType="PwrdevTimeOutAlarm">
        SELECT t.num num, t.PowerDeviceId PowerDeviceId,alarm_typeId,alarm_index,timeout_tag,read_datetime,system_datetime,resume_datetime,alarm_name,StationName 
        FROM db_pwrdev_alarm.tb_pwrdev_time_out_alarm t ,db_pwrdev_alarm.${alarmParamTableName} p2,db_pwrdev_inf.tb_pwrdev_inf inf
        WHERE t.alarm_typeId = p2.alarm_id and t.PowerDeviceId= inf.PowerDeviceId
        AND t.PowerDeviceId in ( SELECT DISTINCT devInf.PowerDeviceId
        FROM db_pwrdev_inf.tb_pwrdev_inf devInf,
        db_user.tb_user_battgroup_baojigroup_battgroup group1,
        db_user.tb_user_battgroup_baojigroup_usr groupUser
        WHERE
        devInf.StationId = group1.StationId
        AND group1.baoji_group_id = groupUser.baoji_group_id
        AND groupUser.uId =#{uId})
    </select>

</mapper>