From 12342e2cd02eda1beee4969b728b92c4544d43b9 Mon Sep 17 00:00:00 2001 From: whyczh <hzjl@qq.com> Date: 星期四, 07 四月 2022 16:21:43 +0800 Subject: [PATCH] 更新RealTimeWebsocket接口 --- src/main/java/com/whyc/webSocket/RealTimeWebsocket.java | 10 ++++++++++ 1 files changed, 10 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/whyc/webSocket/RealTimeWebsocket.java b/src/main/java/com/whyc/webSocket/RealTimeWebsocket.java index 6188ece..7aacc33 100644 --- a/src/main/java/com/whyc/webSocket/RealTimeWebsocket.java +++ b/src/main/java/com/whyc/webSocket/RealTimeWebsocket.java @@ -58,6 +58,8 @@ private static Fbs9100ChargerstateService f9100Chargerstateservice;//Fbs9100Chargerstate + private static Fbs9100sBuscoupleStateService fbs9100sBuscoupleStateService; + private Session session; @Autowired @@ -131,6 +133,10 @@ @Autowired public void setService(Fbs9100ChargerstateService f9100Chargerstateservice) { RealTimeWebsocket.f9100Chargerstateservice = f9100Chargerstateservice; + } + @Autowired + public void setService(Fbs9100sBuscoupleStateService fbs9100sBuscoupleStateService) { + RealTimeWebsocket.fbs9100sBuscoupleStateService = fbs9100sBuscoupleStateService; } @OnOpen @@ -228,6 +234,10 @@ //ld-9鏁版嵁 Response ld9Res=ld9Service.searchByDevId(realTimePar.getDevId()); res.put("ld9",ld9Res); + }else if(realTimePar.getDevType()== DeviceTypeDTO.DEVICEBTS9120){ + //鑾峰彇閫嗗彉鐨勫叾浠栦俊鎭� + Response fbs9100sBuscoupleState=fbs9100sBuscoupleStateService.serchByDevId(realTimePar.getDevId()); + res.put("fbs9100sBuscoupleState",fbs9100sBuscoupleState); }else{ //鏌ヨfbs9100淇℃伅 Response f9100stateRes=f9100service.serchContactorState(realTimePar.getDevId()); -- Gitblit v1.9.1