山西直流电源系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
whyclxw
6 天以前 2753ad7aee272a5a5a8a0124b1feea5a1e4cc83e 
 src/main/java/com/whyc/service/PwrdevAlarmService.java


@@ -8,26 +8,48 @@


import com.whyc.constant.DevAlarmEnum;


import com.whyc.constant.PowerAlarmEnum;


import com.whyc.dto.AlarmDto;


import com.whyc.dto.Param.AlmAnalyseDto;


import com.whyc.dto.Real.AlmDto;


import com.whyc.dto.Real.RealDateDTO;


import com.whyc.dto.Response;


import com.whyc.factory.ThreadPoolExecutorFactory;


import com.whyc.mapper.PwrdevAlarmMapper;


import com.whyc.pojo.db_alarm.DevalarmData;


import com.whyc.pojo.db_data_history.BattRealdataId;


import com.whyc.pojo.db_data_history.PwrdevHistorydataId;


import com.whyc.pojo.db_param.AlmAnalysisParam;


import com.whyc.pojo.db_param.AppParam;


import com.whyc.pojo.db_pwrdev_alarm.PwrdevAlarm;


import com.whyc.pojo.db_pwrdev_alarm.PwrdevAlarmParam;


import com.whyc.pojo.web_site.AlarmInspection;


import com.whyc.util.ActionUtil;


import com.whyc.util.DateUtil;


import com.whyc.util.ThreadLocalUtil;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.util.Date;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.concurrent.CountDownLatch;


import java.util.concurrent.ThreadPoolExecutor;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;




import static java.lang.Thread.sleep;




@Service


public class PwrdevAlarmService {


    @Autowired(required = false)


    private PwrdevAlarmMapper mapper;


    @Autowired


    private AppParamService appParamService;


    @Autowired


    private AlmAnalysisParamService almAnalysisParamService;


    @Autowired


    private SubTablePageInfoService subTablePageInfoService;


    @Autowired


    private BattInfService battInfService;


    //获取电源实时告警信息


    public Response getPwrAlmReal(AlmDto almDto) {


        PageHelper.startPage(almDto.getPageNum(),almDto.getPageSize());


@@ -84,4 +106,19 @@


    public List<AlarmDto> getListByUserId(Integer userId,Integer alarmLevel) {


        return mapper.getListByUserId(userId,alarmLevel);


    }




    //预警分析管理-电源告警


    public Response getPwrtAlmAnalyse(AlmAnalyseDto dto) {


        PageHelper .startPage(dto.getPageNum(),dto.getPageSize());


        List<PwrdevAlarm> list=mapper.getPwrtAlmAnalyse(dto);


        for (PwrdevAlarm pwrAlm:list) {


            pwrAlm.setAlmName(PowerAlarmEnum.getValue(pwrAlm.getAlmId()));


            //查询电源下所有的电池组id


            List<Integer> battgroupIdList = battInfService.getBattgroupIdList(pwrAlm.getPowerId());


            pwrAlm.setBattgroupIdList(battgroupIdList);


        }


        PageInfo pageInfo=new PageInfo(list);


        return new Response().setII(1,list!=null,pageInfo,"电源告警分析");


    }




}