密码验证加-

whyclxw

2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362

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

@@ -93,6 +93,8 @@

    private static PowerInfService pinfService;

    private static Qgn618NbstateService qgnService;

    private Session session;

    private HttpSession httpSession;
@@ -106,6 +108,12 @@
    public void setService(AcdcSecuityService acdcSecuityService) {
        RealTimeWebsocket.acdcSecuityService = acdcSecuityService;
    }

    @Autowired
    public void setQgn618NbstateService(Qgn618NbstateService qgnService) {
        RealTimeWebsocket.qgnService = qgnService;
    }


    @Autowired
    public void setService(BattRtstateService rtstateservice) {
@@ -315,6 +323,9 @@
                            case "nibian6184":
                                res = getNibian6184(realTimePar,lang);
                                break;
                            case "nibian6186":
                                res = getNibian6186(realTimePar,lang);
                                break;
                        }
                        //实时显示调整,增加电池数量,标称单体电压,铅酸还是锂电，放置于返回结果的data2
                        Battinf battinf = battInfService.getBattGroupInfoByBattGroupId(realTimePar.getBattGroupId());
@@ -381,7 +392,7 @@
                //查询电池组单体信息
                Response rtdataRes = rtdataservice.serchByCondition(binf.getBattGroupId());
                res.put("rtdata"+binf.getGroupIndexInFBSDevice(), rtdataRes);
                res.put("binf", binf);
                res.put("binf"+binf.getGroupIndexInFBSDevice(), binf);
            }
        }
        return new Response().set(1, res);
@@ -624,9 +635,11 @@
        if(realTimePar.getStationId()!=null){
            //根据机房id获取机房下电源信息
            PowerInf pinf=pinfService.getPwrDevIdByStationId(realTimePar.getStationId());
            //查询电源的ACDC信息
            Response pwrdevAcdcRes=pwrdevAcdcservice.getDataByDevId(pinf.getPowerDeviceId());
            res.put("pwrdevAcdc",pwrdevAcdcRes);
            if(pinf!=null){
                //查询电源的ACDC信息（重庆bts4810(61850)需要用tb_pwrdev_acdcdata的实时负载电流和三相交流电压）
                Response pwrdevAcdcRes=pwrdevAcdcservice.getDataByDevId(pinf.getPowerDeviceId());
                res.put("pwrdevAcdc",pwrdevAcdcRes);
            }
        }

        return new Response().set(1, res);
@@ -634,33 +647,46 @@

    //6184
    public Response getNibian6184(RealTimePar realTimePar, String lang) {
        Map<String, Response> res = new HashMap<>();
        Map<String, Object> res = new HashMap<>();
        //获取逆变的其他信息
        Response fbs9100sBuscoupleState = fbs9100sBuscoupleStateService.serchByDevId(realTimePar.getDevId());
        res.put("fbs9100sBuscoupleState", fbs9100sBuscoupleState);
        //查询fbs9100信息
        Response f9100stateRes = f9100service.serchContactorState(realTimePar.getDevId());
        res.put("f9100state", f9100stateRes);
        //查询电池组端信息
       //查询电池组端信息2组数据同时获取分开放
        List<Battinf> binfList=battInfService.getBattGroupInfoByFBSDeviceId(realTimePar.getDevId());
        if(binfList!=null){
            for (Battinf binf:binfList) {
                Response rtstateRes = rtstateservice.serchByCondition(binf.getBattGroupId());
                res.put("rtstate"+binf.getGroupIndexInFBSDevice(), rtstateRes);
                //查询电池组单体信息
                Response rtdataRes = rtdataservice.serchByCondition(binf.getBattGroupId());
                res.put("rtdata"+binf.getGroupIndexInFBSDevice(), rtdataRes);
                res.put("binf"+binf.getGroupIndexInFBSDevice(), binf);
            }
        }
        //获取615全功能逆变假负载开关以及逆变模块实时
        Response  qgnRes= qgnService.serchByDevId(realTimePar.getDevId());
        res.put("qgnRes", qgnRes);

        return new Response().set(1, res);
    }

    //6186
    public Response getNibian6186(RealTimePar realTimePar, String lang) {
        Map<String, Object> res = new HashMap<>();
        //查询fbs9100信息
        Response f9100stateRes = f9100service.serchContactorState(realTimePar.getDevId());
        res.put("f9100state", f9100stateRes);
        Response rtstateRes = rtstateservice.serchByCondition(realTimePar.getBattGroupId());
        res.put("rtstate", rtstateRes);

        //查询电池组单体信息
        Response rtdataRes = rtdataservice.serchByCondition(realTimePar.getBattGroupId());
        res.put("rtdata", rtdataRes);

        /*//电池告警
        Response rtalarmRes = rtalarmService.getInfo(realTimePar.getBattGroupId());
        res.put("rtalarm", rtalarmRes);
        //组端告警
        Response rsalarmRes = rsalarmService.getInfo(realTimePar.getBattGroupId());
        res.put("rsalarm", rsalarmRes);
*/
        //最后一次核容放电数据
        Response tinfRes = batttestDataInfService.searchBattLastHrDataById(realTimePar.getBattGroupId(), realTimePar.getDevId(), lang);
        Response tinfRes = batttestDataInfService.searchBattLastHrDataByIdDbs(realTimePar.getBattGroupId(), realTimePar.getDevId(), lang);
        res.put("tinfdata", tinfRes);


        return new Response().set(1, res);
    }