密码验证加-

whyclxw

2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362

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

@@ -8,14 +8,18 @@
import com.whyc.dto.Response;
import com.whyc.mapper.PwrdevAlarmHistoryMapper;
import com.whyc.mapper.PwrdevAlarmParamMapper;
import com.whyc.pojo.PwrDevAlarmVerify;
import com.whyc.pojo.PwrdevAlarmHistory;
import com.whyc.pojo.PwrdevAlarmParam;
import com.whyc.pojo.UserLog;
import com.whyc.util.ActionUtil;
import com.whyc.util.SubTablePageInfoUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
@@ -30,6 +34,12 @@
    @Resource
    private PwrdevAlarmParamMapper paramMapper;

    @Resource
    private SubTablePageInfoUtils subTablePageInfoUtils;

    @Autowired
    private SubTablePageInfoService subService;

    //查询所有的电源历史告警信息
    public Response getHistoryAllPage(PwrdevAlarmHistory pwrH) {
        PageHelper.startPage(pwrH.getPage().getPageCurr(), pwrH.getPage().getPageSize());
@@ -41,6 +51,64 @@
        PageInfo pageInfo = new PageInfo(list);
        List levelList = serchByLevel(ActionUtil.getUser().getUId().intValue(), pwrH.getAlmTypes());
        return new Response<>().setII(1, pageInfo, levelList, "返回结果");
    }

    public Response getPageInfo(PwrdevAlarmHistory param) throws ParseException {
        Integer pageNum = param.getPage().getPageCurr();
        Integer pageSize = param.getPage().getPageSize();
        Date almStartTime = param.getAlmStartTime();
        Date almEndTime = param.getAlmStartTime1();
        //recordId = 1 普通电源
        param.setRecordId(1L);
        int uId = ActionUtil.getUser().getUId().intValue();
        param.setUsrId(uId);
        PageInfo<Object> pageInfo = subTablePageInfoUtils.getPageInfo(pageNum, pageSize, almStartTime, almEndTime,
                "db_pwrdev_alarm", "tb_pwrdev_alarm_history", param);
        List<Object> list = pageInfo.getList();
        for (Object temp : list) {
            PwrdevAlarmHistory p = (PwrdevAlarmHistory) temp;
            p.setAlarmName(AlarmDaoFactory.getAllAlarmName(p.getAlmType()));
        }
        return new Response<>().setII(1, pageInfo, null, "返回结果");
    }

    public Response getPageInfoForTX(PwrdevAlarmHistory param) throws ParseException {
        Integer pageNum = param.getPage().getPageCurr();
        Integer pageSize = param.getPage().getPageSize();
        Date almStartTime = param.getAlmStartTime();
        Date almEndTime = param.getAlmStartTime1();
        //2代表通讯电源
        param.setRecordId(2L);
        param.setUsrId(ActionUtil.getUser().getUId().intValue());
        PageInfo<Object> pageInfo = subTablePageInfoUtils.getPageInfo(pageNum, pageSize, almStartTime, almEndTime,
                "db_pwrdev_alarm", "tb_pwrdev_alarm_history", param);
        List<Object> list = pageInfo.getList();
        List<String> tableList = paramMapper.getParamList();
        //取第一条记录,即param表
        String alarmParamTableName = tableList.get(0);
        //List<PwrdevAlarmParam>  paramList=paramMapper.searchAll(alarmParamTableName);
        List<PwrdevAlarmParam>  paramList=subService.searchAll(alarmParamTableName);
        for (Object obj:list) {
            PwrdevAlarmHistory p = (PwrdevAlarmHistory) obj;
            int almType = p.getAlmType();
            AtomicBoolean matchFlag = new AtomicBoolean(false);
            paramList.stream().forEach(temp->{
                if(temp.getAlarmId()  == almType ){
                    if (p.getAlmIndex() != 0) {
                        p.setAlarmName(temp.getAlarmName().replace("N", p.getAlmIndex() + ""));
                    }else{
                        p.setAlarmName(temp.getAlarmName());
                    }
                    matchFlag.set(true);
                    return;
                }
            });
            if(!matchFlag.get()){
                p.setAlarmName("未知告警类型");
            }

        }
        return  new Response<>().set(1,pageInfo);
    }

    //查询分级告警的个数
@@ -77,7 +145,8 @@
        List<String> tableList = paramMapper.getParamList();
        //取第一条记录,即param表
        String alarmParamTableName = tableList.get(0);
        List<PwrdevAlarmParam>  paramList=paramMapper.searchAll(alarmParamTableName);
        //List<PwrdevAlarmParam>  paramList=paramMapper.searchAll(alarmParamTableName);
        List<PwrdevAlarmParam>  paramList=subService.searchAll(alarmParamTableName);
        for (PwrdevAlarmHistory p:list) {
            int almType = p.getAlmType();
            AtomicBoolean matchFlag = new AtomicBoolean(false);
@@ -107,4 +176,37 @@
        update.lt("alm_start_time",retentionTime);
        mapper.delete(update);
    }

    public void add(PwrDevAlarmVerify data) {
        PwrdevAlarmHistory dataHistory = new PwrdevAlarmHistory();
        dataHistory.setAlmClearedType(data.getAlmClearedType());
        dataHistory.setAlmConfirmedTime(data.getAlmConfirmedTime());
        dataHistory.setAlmEndTime(data.getAlmEndTime());
        dataHistory.setAlmIndex(data.getAlmIndex());
        dataHistory.setAlmIsConfirmed(data.getAlmIsConfirmed());
        dataHistory.setAlmLevel(data.getAlmLevel());
        dataHistory.setAlmSeverity(data.getAlmSeverity());
        dataHistory.setAlmSource(data.getAlmSource());
        dataHistory.setAlmStartTime(data.getAlmStartTime());
        dataHistory.setAlmType(data.getAlmType());
        dataHistory.setAlmValue(data.getAlmValue());
        dataHistory.setPowerDeviceId(data.getPowerDeviceId());
        dataHistory.setRecordId(data.getRecordId());
        dataHistory.setUsrId(data.getUsrId());
        dataHistory.setAlmTrigger(data.getAlmTrigger());

        mapper.insert(dataHistory);
    }

    public List<PwrdevAlarmHistory> getListByStationId(Date startTime, Date endTime, String stationId,String tableName) {
        //List list=mapper.getListByStationId(startTime,endTime,stationId,tableName);
        List list=subService.getListByStationId_pwr(startTime,endTime,stationId,tableName);
        return list;
    }

    public Response getLevelList(List<Integer> almTypes) {
        int uId = ActionUtil.getUser().getUId().intValue();
        List<Integer> levelList = subTablePageInfoUtils.getLevelList(uId,"db_pwrdev_alarm", "tb_pwrdev_alarm_history", "tb_pwrdev_alarm_history_?[0-9]*",almTypes);
        return new Response().set(1,levelList);
    }
}