监控层，运维层首页+跳转页

lxw

2023-03-07 5b98daea3ac8032b59ee2f2692ff45fa1bf84bbd

监控层，运维层首页+跳转页

 src/main/java/com/whyc/mapper/StationInfMapper.java

@@ -7,5 +7,5 @@
public interface StationInfMapper extends CustomMapper<StationInf> {

    //站点实时数据推送
    List<StationInf> getAll(int userId);
    List<StationInf> getSystemAll(int userId);
}

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

@@ -54,8 +54,8 @@
    }

    //站点实时数据推送
    public Response getAll(int userId) {
        List<StationInf> list = mapper.getAll(userId);
    public Response getSystemAll(int userId) {
        List<StationInf> list = mapper.getSystemAll(userId);
        for (StationInf inf : list) {
            String stationId = inf.getStationId();
            //查询机房下最大的单体电压和单体

 src/main/java/com/whyc/webSocket/DevOpSkipSocket.java

@@ -52,7 +52,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getAll(userId));
                                session.getBasicRemote().sendObject(service.getSystemAll(userId));
                            }
                            threadFlagMap.put(thread.getId(), false);
                        }

 src/main/java/com/whyc/webSocket/HomeDevOpSocket.java

@@ -52,7 +52,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getAll(userId));
                                session.getBasicRemote().sendObject(service.getSystemAll(userId));
                            }
                            threadFlagMap.put(thread.getId(), false);
                        }

 src/main/java/com/whyc/webSocket/HomeMonitorSocket.java

@@ -52,7 +52,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getAll(userId));
                                session.getBasicRemote().sendObject(service.getSystemAll(userId));
                            }
                            threadFlagMap.put(thread.getId(), false);
                        }

 src/main/java/com/whyc/webSocket/HomeSystemSocket.java

@@ -52,7 +52,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getAll(userId));
                                session.getBasicRemote().sendObject(service.getSystemAll(userId));
                            }
                            threadFlagMap.put(thread.getId(), false);
                        }

 src/main/java/com/whyc/webSocket/SystemSkipSocket.java

@@ -52,7 +52,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getAll(userId));
                                session.getBasicRemote().sendObject(service.getSystemAll(userId));
                            }
                            threadFlagMap.put(thread.getId(), false);
                        }

 src/main/resources/mapper/StationInfMapper.xml

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.StationInfMapper">
    <resultMap id="stationRt" type="com.whyc.pojo.StationInf">
    <resultMap id="SystemRt" type="com.whyc.pojo.StationInf">
        <id property="num" column="num"></id>
        <result property="stationId" column="stationId"></result>
        <result property="stationName" column="stationName"></result>
@@ -26,7 +26,7 @@
        </collection>
    </resultMap>

    <select id="getAll" resultMap="stationRt">
    <select id="getSystemAll" resultMap="SystemRt">
        select distinct *
        from db_battinf.tb_station_inf
        where StationId in (select distinct StationId