package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.AlarmDaoFactory;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.PwrdevAlarmHistoryMapper;
|
import com.whyc.mapper.PwrdevAlarmParamMapper;
|
import com.whyc.pojo.PwrdevAlarmHistory;
|
import com.whyc.pojo.PwrdevAlarmParam;
|
import com.whyc.pojo.UserLog;
|
import com.whyc.util.ActionUtil;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
@Service
|
public class PwrdevAlarmHistoryService {
|
@Resource
|
private PwrdevAlarmHistoryMapper mapper;
|
|
@Resource
|
private PwrdevAlarmParamMapper paramMapper;
|
|
//查询所有的电源历史告警信息
|
public Response getHistoryAllPage(PwrdevAlarmHistory pwrH) {
|
PageHelper.startPage(pwrH.getPage().getPageCurr(), pwrH.getPage().getPageSize());
|
pwrH.setUsrId(ActionUtil.getUser().getUId().intValue());
|
List<PwrdevAlarmHistory> list = mapper.getHistoryAllPage(pwrH);
|
for (PwrdevAlarmHistory p : list) {
|
p.setAlarmName(AlarmDaoFactory.getAllAlarmName(p.getAlmType()));
|
}
|
PageInfo pageInfo = new PageInfo(list);
|
List levelList = serchByLevel(ActionUtil.getUser().getUId().intValue(), pwrH.getAlmTypes());
|
return new Response<>().setII(1, pageInfo, levelList, "返回结果");
|
}
|
|
//查询分级告警的个数
|
public List serchByLevel(int uId, List<Integer> almTypes) {
|
List list = new ArrayList();
|
//分四级查询个数
|
for (int i = 1; i <= 4; i++) {
|
int countLevel = mapper.serchByLevel(i, uId, almTypes);
|
list.add(countLevel);
|
}
|
return list;
|
}
|
|
//电源历史告警删除
|
public Response delete(int num) {
|
int flag = mapper.deleteById(num);
|
return new Response().set(flag);
|
}
|
|
//电源历史告警删除批量
|
@Transactional
|
public Response deletepro(List<Integer> list) {
|
int flag = 0;
|
for (Integer num : list) {
|
flag = mapper.deleteById(num);
|
}
|
return new Response().set(flag);
|
}
|
//查询所有的通讯电源历史告警信息
|
public Response getHistoryAllPage2(PwrdevAlarmHistory pwrH) {
|
PageHelper.startPage(pwrH.getPage().getPageCurr(),pwrH.getPage().getPageSize());
|
pwrH.setUsrId(ActionUtil.getUser().getUId().intValue());
|
List<PwrdevAlarmHistory> list= mapper.getHistoryAllPage2(pwrH);
|
List<String> tableList = paramMapper.getParamList();
|
//取第一条记录,即param表
|
String alarmParamTableName = tableList.get(0);
|
List<PwrdevAlarmParam> paramList=paramMapper.searchAll(alarmParamTableName);
|
for (PwrdevAlarmHistory p:list) {
|
int almType = p.getAlmType();
|
AtomicBoolean matchFlag = new AtomicBoolean(false);
|
paramList.stream().forEach(param->{
|
if(param.getAlarmId() == almType ){
|
p.setAlarmName(param.getAlarmName());
|
matchFlag.set(true);
|
return;
|
}
|
});
|
if(!matchFlag.get()){
|
p.setAlarmName("未知告警类型");
|
}
|
|
}
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response<>().set(1,pageInfo);
|
}
|
|
public List<PwrdevAlarmHistory> getDataBeforeRetentionMonth(Date retentionTime) {
|
return mapper.getDataBeforeRetentionMonth(retentionTime);
|
}
|
|
public void deleteBeforeRetentionMonth(Date retentionTime) {
|
UpdateWrapper<PwrdevAlarmHistory> update = Wrappers.update();
|
|
update.lt("alm_start_time",retentionTime);
|
mapper.delete(update);
|
}
|
}
|
