lxw
2022-12-23 cd62acd86f3d4b283f473e002aa6e32498cdd66d
实时告警分级数
4个文件已修改
19 ■■■■ 已修改文件
src/main/java/com/whyc/mapper/BattalarmDataMapper.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/BattalarmDataService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/BattAlarmDataSocket.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/BattalarmDataMapper.xml 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/mapper/BattalarmDataMapper.java
@@ -58,5 +58,5 @@
    List<BattalarmData> getList(@Param("uId") Long userId);
    //查询分级告警的个数
    int serchByLevel(int alarmLevel);
    int serchByLevel(@Param("alarmLevel") int alarmLevel, @Param("uId") int uId);
}
src/main/java/com/whyc/service/BattalarmDataService.java
@@ -371,11 +371,11 @@
    }
    //查询分级告警的个数
    public Response serchByLevel() {
    public Response serchByLevel(int uId) {
        List list = new ArrayList();
        //分四级查询个数
        for (int i = 1; i <= 4; i++) {
            int countLevel = mapper.serchByLevel(i);
            int countLevel = mapper.serchByLevel(i, uId);
            list.add(countLevel);
        }
        return new Response().setII(1, list.size() > 0, list, "分级告警数");
src/main/java/com/whyc/webSocket/BattAlarmDataSocket.java
@@ -56,7 +56,7 @@
                        Response unconfirmedAlarms = service.serchByConditionOfWebSocket(alarmPar);
                        res.put("unconfirmedAlarms", unconfirmedAlarms);
                        //查询分级告警的个数
                        Response levelRes = service.serchByLevel();
                        Response levelRes = service.serchByLevel(alarmPar.getUId());
                        res.put("levelRes", levelRes);
                        if (session.isOpen()) {
                            //推送信息
src/main/resources/mapper/BattalarmDataMapper.xml
@@ -339,5 +339,16 @@
        from db_alarm.tb_battalarm_data,
             db_battinf.tb_battinf
        where alm_level = #{alarmLevel}
          and db_alarm.tb_battalarm_data.BattGroupId
            in (select distinct db_battinf.tb_battinf.battgroupid
                from db_battinf.tb_battinf,
                     db_user.tb_user_battgroup_baojigroup_battgroup,
                     db_user.tb_user_battgroup_baojigroup_usr,
                     db_user.tb_user_inf
                where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId = db_battinf.tb_battinf.BattGroupId
                  and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
                      db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
                  and db_user.tb_user_inf.uid = db_user.tb_user_battgroup_baojigroup_usr.uid
                  and db_user.tb_user_inf.uid = #{uId})
    </select>
</mapper>