更新大屏socket

whycxzp

2023-03-27 cf749931d6a26160a3e0fbfe36eaea956679fb3a

更新大屏socket

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

@@ -72,4 +72,7 @@

    //电池告警机房
    int getQualityAnalysisStation(int userId);

    int getCapAlarmNum(int userId);

}

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

@@ -578,4 +578,8 @@
    public List<Integer> getStationList(int userId) {
        return mapper.getStationList(userId);
    }

    public int getCapAlarmNum(int userId) {
        return mapper.getCapAlarmNum(userId);
    }
}

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

@@ -64,11 +64,11 @@

    @OnOpen
    public void onOpen(Session session, EndpointConfig config){
        this.session = session;
        /*this.session = session;
        HttpSession httpSession = (HttpSession) config.getUserProperties().get("httpSession");
        UserInf user = (UserInf) httpSession.getAttribute("user");
        final int userId = user.getUId().intValue();
        //final int userId = 1001;
        final int userId = user.getUId().intValue();*/
        final int userId = 1001;
        Thread thread = new Thread() {
            @Override
            public void run() {
@@ -153,13 +153,21 @@
                            latch.countDown();
                        });
                        poolExecutor.execute(()->{
                            //续航检测:按照电池组为单位进行检测,告警判定:实际容量/标称容量<=某个百分比 TODO 续航表中读取需要询问李军确认
                            //弃用
                            /*//续航检测:按照电池组为单位进行检测,告警判定:实际容量/标称容量<=某个百分比 TODO 续航表中读取需要询问李军确认
                            Response res_capAlarmNum = new Response();
                            try {
                                int capAlarmNum = battInfService.getCapAlarmNum(userId);
                                res_capAlarmNum.setII(1,true,capAlarmNum,null);
                            }catch (Exception e){
                                res_capAlarmNum.set(1,false,"发生异常:"+e.getCause());
                            }*/
                            Response res_capAlarmNum = new Response();
                            try {
                                int capAlarmNum = battAlarmDataService.getCapAlarmNum(userId);
                                res_capAlarmNum.setII(1,true,capAlarmNum,null);
                            }catch (Exception e){
                                res_capAlarmNum.set(1,false,"发生异常:"+e.getCause());
                            }
                            res.put("capAlarmNum", res_capAlarmNum);
                            latch.countDown();

 src/main/resources/mapper/BattalarmDataMapper.xml

@@ -433,4 +433,19 @@
                              and db_user.tb_user_inf.uid = db_user.tb_user_battgroup_baojigroup_usr.uid
                              and db_user.tb_user_inf.uid = #{userId})
    </select>
    <select id="getCapAlarmNum" resultType="java.lang.Integer">
        select count(*)
        from db_battinf.tb_battinf,
        db_alarm.tb_battalarm_data
        where tb_battinf.battgroupId = db_alarm.tb_battalarm_data.battgroupid
        and db_alarm.tb_battalarm_data.alm_id in (119010,119011)
        and StationId in (select distinct stationId
        from 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_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 = #{userId})
    </select>
</mapper>