审批页面修改

lxw

2023-08-15 160e150009b51a39fa95d9462c3798ba28d51a09

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

@@ -2,24 +2,20 @@

import com.whyc.dto.AlarmDaoFactory;
import com.whyc.dto.Response;
import com.whyc.mapper.BattalarmDataMapper;
import com.whyc.mapper.DevalarmDataMapper;
import com.whyc.pojo.*;
import com.whyc.util.ActionUtil;
import com.whyc.util.CommonUtil;
import com.whyc.util.MessageUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpSession;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.atomic.AtomicLong;
import java.util.stream.Collectors;

import static org.assertj.core.util.Maps.format;

/**
 * 告警:电池/设备/电源告警的统一接口
@@ -43,22 +39,26 @@
    @Lazy
    private MSTTSSpeechService service;

    @Autowired
    private AlarmVoiceSetService alarmVoiceSetService;


    public Map<String, Object> getAlarmLevel1ListMap() {
        Long userId = ActionUtil.getUser().getUId();
        List<BattalarmData> battAlarmList = battAlarmDataService.getList(userId,1);
        battAlarmList = battAlarmList.stream().filter(alarm->alarm.getAlmLevel().equals(1)).collect(Collectors.toList());
        String lang = ActionUtil.getLang();
        List<BattalarmData> battAlarmList = battAlarmDataService.getList(userId, 1);
        battAlarmList = battAlarmList.stream().filter(alarm -> alarm.getAlmLevel().equals(1)).collect(Collectors.toList());
        //相同设备id+告警类型的语音,只保留一条
        Map<String, List<BattalarmData>> battAlarmListMap = battAlarmList.stream().collect(Collectors.groupingBy(a -> a.getBattGroupId() + "_" + a.getAlmSignalId()));
        Set<String> keySet = battAlarmListMap.keySet();
        for (String key:keySet){
            battAlarmList.clear();
        battAlarmList.clear();
        for (String key : keySet) {
            battAlarmList.add(battAlarmListMap.get(key).get(0));
        }

        for (BattalarmData adata : battAlarmList) {
            adata.setAlmSignalIdName(AlarmDaoFactory.getAlarmName(adata.getAlmSignalId()));
            adata.setAlmLevelName(AlarmDaoFactory.getAlarmType(adata.getAlmLevel()));
            adata.setAlmSignalIdName(MessageUtils.getMessageSocket(AlarmDaoFactory.getAlarmName(adata.getAlmSignalId()), lang));
            adata.setAlmLevelName(MessageUtils.getMessageSocket(AlarmDaoFactory.getAlarmType(adata.getAlmLevel()), lang));
        }

        List<DevalarmData> devAlarmList = devAlarmDataService.getList(userId,1);
@@ -66,8 +66,8 @@
        //相同设备id+告警类型的语音,只保留一条
        Map<String, List<DevalarmData>> devAlarmListMap = devAlarmList.stream().collect(Collectors.groupingBy(a -> a.getDevId() + "_" + a.getAlmType()));
        Set<String> keySet2 = devAlarmListMap.keySet();
        devAlarmList.clear();
        for (String key:keySet2){
            devAlarmList.clear();
            devAlarmList.add(devAlarmListMap.get(key).get(0));
        }

@@ -76,8 +76,8 @@
        //相同设备id+告警类型的语音,只保留一条
        Map<String, List<PwrdevAlarm>> powerAlarmListMap = powerAlarmList.stream().collect(Collectors.groupingBy(a -> a.getPowerDeviceId() + "_" + a.getAlmType()));
        Set<String> keySet3 = powerAlarmListMap.keySet();
        powerAlarmList.clear();
        for (String key:keySet3){
            powerAlarmList.clear();
            powerAlarmList.add(powerAlarmListMap.get(key).get(0));
        }
        for (PwrdevAlarm p : powerAlarmList) {
@@ -299,52 +299,92 @@

        SimpleDateFormat format = new SimpleDateFormat(ActionUtil.time_yyyyMMddHHmmss);
        long currentTimeMillis = System.currentTimeMillis();
        //查询告警语音设置表的所有记录,并更新下次时间戳到到相关的语音文件中
        Long userId = ActionUtil.getUser().getUId();
        List<AlarmVoiceSet> setList = alarmVoiceSetService.getAllByUserId(userId);
        List<AlarmVoiceSet> setListBatt = setList.stream().filter(set->set.getBattGroupId()!=null).collect(Collectors.toList());
        List<AlarmVoiceSet> setListDevice = setList.stream().filter(set->set.getDeviceId()!=null).collect(Collectors.toList());
        List<AlarmVoiceSet> setListPowerDevice = setList.stream().filter(set->set.getPowerDeviceId()!=null).collect(Collectors.toList());

        File file = new File(dirPath);
        if(!file.exists()){
            file.mkdirs();
        }
        for (BattalarmData alarm : battAlarmList) {
            StringBuilder alarmMsgBuilder = new StringBuilder();
            String alarmName = AlarmDaoFactory.getAllAlarmName(alarm.getAlmSignalId());
            Integer almSignalId = alarm.getAlmSignalId();
            String alarmName = AlarmDaoFactory.getAllAlarmName(almSignalId);
            String alarmStartTime = format.format(alarm.getAlmStartTime());
            String stationName = alarm.getStationName();
            String district = stationName.split("-")[2];
            String stationNameUnion = stationName.substring(stationName.indexOf(district));
            String station = stationName.split("-")[3];
            String stationNameUnion = district+"-"+station;

            //查询是否存在 设备id+告警类型 相同的记录
            Integer battGroupId = alarm.getBattGroupId();
            AtomicLong nextTimestamp = new AtomicLong(currentTimeMillis);
            setListBatt.forEach(set->{
                if(set.getBattGroupId().equals(battGroupId) && set.getAlarmType().equals(almSignalId)){
                    nextTimestamp.set(set.getNextTimestamp());
                }
            });

            //alarmMsgBuilder.append(stationNameUnion).append(",电池组编号为").append(alarm.getBattgroupname()).append(",单体为").append(alarm.getMonNum()).append(",在").append(alarmStartTime).append("发生了").append(alarmName).append("告警;");
            alarmMsgBuilder.append(stationNameUnion).append("发生了").append(alarmName).append("告警;");
            //生成语音文件,命名规则 {alarmStartTime}_batt_{num}_{battGroupId}_{almSignalId}_{userId}_{nextTimeInterval}_{voiceTime} ->更改为
            //生成语音文件,命名规则 {alarmStartTime}_batt_{num}_{battGroupId}_{almSignalId}_{readableVoiceTime}
            service.saveToWav(alarmMsgBuilder.toString(), dirPath + File.separator
                + alarm.getAlmStartTime().getTime()+"_batt_"+alarm.getNum()+"_"+alarm.getBattGroupId()+"_"+ alarm.getAlmSignalId()+"_"+currentTimeMillis+".wav");
                + alarm.getAlmStartTime().getTime()+"_batt_"+alarm.getNum()+"_"+ battGroupId +"_"+ almSignalId +"_"+nextTimestamp.get()+".wav");

        }
        for (DevalarmData alarm : devAlarmList) {
            StringBuilder alarmMsgBuilder = new StringBuilder();
            String alarmName = AlarmDaoFactory.getAllAlarmName(alarm.getAlmType());
            Integer almType = alarm.getAlmType();
            String alarmName = AlarmDaoFactory.getAllAlarmName(almType);
            String alarmStartTime = format.format(alarm.getAlmStartTime());
            String stationName = alarm.getStationName();
            String district = stationName.split("-")[2];
            String stationNameUnion = stationName.substring(stationName.indexOf(district));
            String station = stationName.split("-")[3];
            String stationNameUnion = district+"-"+station;

            //查询是否存在 设备id+告警类型 相同的记录
            Integer devId = alarm.getDevId();
            AtomicLong nextTimestamp = new AtomicLong(currentTimeMillis);
            setListDevice.forEach(set->{
                if(set.getDeviceId().intValue() == devId && set.getAlarmType().equals(almType)){
                    nextTimestamp.set(set.getNextTimestamp());
                }
            });
            //alarmMsgBuilder.append(stationNameUnion).append(",设备编号为").append(alarm.getDevId()).append(",在").append(alarmStartTime).append("发生了").append(alarmName).append("告警;");
            alarmMsgBuilder.append(stationNameUnion).append("发生了").append(alarmName).append("告警;");
            //生成语音文件,命名规则 {alarmStartTime}_device_{num}_{deviceId}_{almType}_{readableVoiceTime}
            service.saveToWav(alarmMsgBuilder.toString(), dirPath + File.separator
                    + alarm.getAlmStartTime().getTime()+"_device_"+alarm.getNum()+"_"+alarm.getDevId()+"_"+ alarm.getAlmType()+"_"+currentTimeMillis+".wav");
                    + alarm.getAlmStartTime().getTime()+"_device_"+alarm.getNum()+"_"+alarm.getDevId()+"_"+ almType +"_"+nextTimestamp.get()+".wav");

        }
        for (PwrdevAlarm alarm : powerAlarmList) {
            StringBuilder alarmMsgBuilder = new StringBuilder();
            String alarmName = AlarmDaoFactory.getAllAlarmName(alarm.getAlmType());
            Integer almType = alarm.getAlmType();
            String alarmName = AlarmDaoFactory.getAllAlarmName(almType);
            String alarmStartTime = format.format(alarm.getAlmStartTime());
            String stationName = alarm.getStationName();
            String district = stationName.split("-")[2];
            String stationNameUnion = stationName.substring(stationName.indexOf(district));
            String station = stationName.split("-")[3];
            String stationNameUnion = district+"-"+station;

            //查询是否存在 设备id+告警类型 相同的记录
            Long powerDeviceId = alarm.getPowerDeviceId();
            AtomicLong nextTimestamp = new AtomicLong(currentTimeMillis);
            setListPowerDevice.forEach(set->{
                if(set.getPowerDeviceId().equals(powerDeviceId) && set.getAlarmType().equals(almType)){
                    nextTimestamp.set(set.getNextTimestamp());
                }
            });
            //alarmMsgBuilder.append(stationNameUnion).append(",电源编号为").append(alarm.getPowerDeviceId()).append(",在").append(alarmStartTime).append("发生了").append(alarmName).append("告警;");
            alarmMsgBuilder.append(stationNameUnion).append("发生了").append(alarmName).append("告警;");
            //生成语音文件,命名规则 {alarmStartTime}_device_{num}_{deviceId}_{almType}_{readableVoiceTime}
            service.saveToWav(alarmMsgBuilder.toString(), dirPath + File.separator
                    + alarm.getAlmStartTime().getTime()+"_power_"+alarm.getNum()+"_"+alarm.getPowerDeviceId()+"_"+ alarm.getAlmType()+"_"+currentTimeMillis+".wav");
                    + alarm.getAlmStartTime().getTime()+"_power_"+alarm.getNum()+"_"+alarm.getPowerDeviceId()+"_"+ almType +"_"+nextTimestamp.get()+".wav");

        }