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