增加超脑报警业务

‘liusuyi’

2023-12-06 e4043f3eea29b75ab7576f5489ed817985b71aa4

 ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java

@@ -22,6 +22,8 @@
import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarPumpMapper;
import com.ruoyi.alarm.steal.domain.ArdAlarmStealelec;
import com.ruoyi.alarm.steal.mapper.ArdAlarmStealelecMapper;
import com.ruoyi.alarm.superbrain.domain.ArdAlarmSuperBrain;
import com.ruoyi.alarm.superbrain.mapper.ArdAlarmSuperBrainMapper;
import com.ruoyi.alarm.tube.domain.ArdAlarmTube;
import com.ruoyi.alarm.tube.mapper.ArdAlarmTubeMapper;
import com.ruoyi.alarm.wall.domain.ArdAlarmWall;
@@ -74,6 +76,8 @@
@Slf4j(topic = "mqtt")
public class GlobalAlarmServiceImpl implements IGlobalAlarmService {
    //region 依赖注入
    @Resource
    private ArdAlarmSuperBrainMapper ardAlarmSuperBrainMapper;
    @Resource
    private ArdAlarmDigitization3Mapper ardAlarmDigitization3Mapper;
    @Resource
@@ -153,6 +157,8 @@
        countMap.put("1014", count1014);
        int count1012 = ardAlarmDigitization3Mapper.selectCountByAlarmTime(refreshTime);
        countMap.put("1012", count1012);
        int count1015 = ardAlarmSuperBrainMapper.selectCountByAlarmTime(refreshTime);
        countMap.put("1015", count1015);
        map.put("20000", countMap);
        return map;
    }
@@ -325,6 +331,22 @@
                                    .setAltitude(ardAlarmTube.getAltitude())
                                    .setCount(ardAlarmTube.getCount())
                                    .setTotal(ardAlarmTube.getTotal());
                            return globalAlarmData;
                        }).collect(Collectors.toList());
            case 1015:
                List<ArdAlarmSuperBrain> ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime);
                return ardAlarmSuperBrains.stream()
                        .map(ardAlarmSuperBrain -> {
                            GlobalAlarmData globalAlarmData = new GlobalAlarmData()
                                    .setId(ardAlarmSuperBrain.getId())
                                    .setName(ardAlarmSuperBrain.getAlarmType())
                                    .setAlarmType(ardAlarmSuperBrain.getAlarmType())
                                    .setAlarmTime(ardAlarmSuperBrain.getAlarmTime())
                                    .setLongitude(ardAlarmSuperBrain.getLongitude())
                                    .setLatitude(ardAlarmSuperBrain.getLatitude())
                                    .setAltitude(ardAlarmSuperBrain.getAltitude())
                                    .setCount(ardAlarmSuperBrain.getCount())
                                    .setTotal(ardAlarmSuperBrain.getTotal());
                            return globalAlarmData;
                        }).collect(Collectors.toList());
            default:
@@ -500,6 +522,22 @@
                                    .setAltitude(ardAlarmTube.getAltitude())
                                    .setCount(ardAlarmTube.getCount())
                                    .setTotal(ardAlarmTube.getTotal());
                            return globalAlarmData;
                        }).collect(Collectors.toList());
            case 1015:
                List<ArdAlarmSuperBrain> ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime);
                return ardAlarmSuperBrains.stream()
                        .map(ardAlarmSuperBrain -> {
                            GlobalAlarmData globalAlarmData = new GlobalAlarmData()
                                    .setId(ardAlarmSuperBrain.getId())
                                    .setName(ardAlarmSuperBrain.getAlarmType())
                                    .setAlarmType(ardAlarmSuperBrain.getAlarmType())
                                    .setAlarmTime(ardAlarmSuperBrain.getAlarmTime())
                                    .setLongitude(ardAlarmSuperBrain.getLongitude())
                                    .setLatitude(ardAlarmSuperBrain.getLatitude())
                                    .setAltitude(ardAlarmSuperBrain.getAltitude())
                                    .setCount(ardAlarmSuperBrain.getCount())
                                    .setTotal(ardAlarmSuperBrain.getTotal());
                            return globalAlarmData;
                        }).collect(Collectors.toList());
            default:
@@ -692,6 +730,7 @@
        if (alarmData1012.size() > 0) {
            GlobalAlarmDataList.addAll(alarmData1012);
        }

        List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime);
        List<GlobalAlarmData> alarmData1014 = ardAlarmTubes.stream()
                .map(ardAlarmTube -> {
@@ -710,6 +749,26 @@
        if (alarmData1014.size() > 0) {
            GlobalAlarmDataList.addAll(alarmData1014);
        }

        List<ArdAlarmSuperBrain> ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime);
        List<GlobalAlarmData> alarmData1015 = ardAlarmSuperBrains.stream()
                .map(ardAlarmSuperBrain -> {
                    GlobalAlarmData globalAlarmData = new GlobalAlarmData()
                            .setId(ardAlarmSuperBrain.getId())
                            .setName(ardAlarmSuperBrain.getAlarmType())
                            .setAlarmTime(ardAlarmSuperBrain.getAlarmTime())
                            .setLongitude(ardAlarmSuperBrain.getLongitude())
                            .setLatitude(ardAlarmSuperBrain.getLatitude())
                            .setAltitude(ardAlarmSuperBrain.getAltitude())
                            .setCount(ardAlarmSuperBrain.getCount())
                            .setTotal(ardAlarmSuperBrain.getTotal())
                            .setAlarmType("1015");
                    return globalAlarmData;
                }).collect(Collectors.toList());
        if (alarmData1015.size() > 0) {
            GlobalAlarmDataList.addAll(alarmData1015);
        }

        return GlobalAlarmDataList;
    }

@@ -798,6 +857,12 @@
                aat.setPageNum(pageNum);
                aat.setPageSize(pageSize);
                return ardAlarmTubeMapper.selectArdAlarmTubeList(aat);
            case 1015:
                ArdAlarmSuperBrain aasb = new ArdAlarmSuperBrain();
                aasb.setParams(params);
                aasb.setPageNum(pageNum);
                aasb.setPageSize(pageSize);
                return ardAlarmSuperBrainMapper.selectArdAlarmSuperBrainList(aasb);
        }
        return null;
    }
@@ -903,6 +968,14 @@
                    String alarmTime = fmt.format(ardAlarmTube.getAlarmTime());
                    ardAlarmTubeMapper.updateViewTimeByTubeId(tubeId, alarmTime, DateUtils.getTime());
                    return ardAlarmTube;
                }
            case 1015:
                ArdAlarmSuperBrain ardAlarmSuperBrain = ardAlarmSuperBrainMapper.selectArdAlarmSuperBrainById(condition.getId());
                if (StringUtils.isNotNull(ardAlarmSuperBrain)) {
                    String alarmType = ardAlarmSuperBrain.getAlarmType();
                    String alarmTime = fmt.format(ardAlarmSuperBrain.getAlarmTime());
                    ardAlarmSuperBrainMapper.updateViewTimeByAlarmType(alarmType, alarmTime, DateUtils.getTime());
                    return ardAlarmSuperBrain;
                }
            default:
                return null;
@@ -1245,6 +1318,17 @@
                    }
                    //endregion
                    break;
                case "superBrain":
                    //region 超脑报警
                    ArdAlarmSuperBrain ardAlarmSuperBrain = JSONObject.parseObject(message, ArdAlarmSuperBrain.class);
                    ardAlarmSuperBrain.setId(IdUtils.simpleUUID());
                    ardAlarmSuperBrain.setCreateTime(new Date());
                    int sbRes = ardAlarmSuperBrainMapper.insertArdAlarmSuperBrain(ardAlarmSuperBrain);
                    if (sbRes > 0) {
                        log.debug("superBrain入库成功：" + ardAlarmSuperBrain);
                    }
                    //endregion
                    break;
            }
        } catch (Exception ex) {
            log.error("接收报警异常:" + ex.getMessage());