From 15c7bf201ca77efe0e130c6a6c89db90196d93a0 Mon Sep 17 00:00:00 2001 From: whycxzp <glperry@163.com> Date: 星期二, 05 十二月 2023 11:36:15 +0800 Subject: [PATCH] 核容单体信息 --- src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java | 12 +++++++++++- 1 files changed, 11 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java b/src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java index 78bd507..494f437 100644 --- a/src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java +++ b/src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java @@ -2,9 +2,11 @@ import com.whyc.config.WebSocketConfig; import com.whyc.dto.Response; +import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtData; import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtState; import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt; import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignal; +import com.whyc.service.CKPowerDevBattRtDataService; import com.whyc.service.CKPowerDevBattRtStateService; import com.whyc.service.CKPowerDevRtService; import com.whyc.service.CKPowerDevSignalService; @@ -33,6 +35,8 @@ private static CKPowerDevBattRtStateService ckPowerDevBattRtStateService; + private static CKPowerDevBattRtDataService ckPowerDevBattRtDataService; + @Autowired public void setCkPowerDevRtService(CKPowerDevRtService ckPowerDevRtService) { CKRtAndSignalAndHrSocket.ckPowerDevRtService = ckPowerDevRtService; @@ -48,6 +52,11 @@ CKRtAndSignalAndHrSocket.ckPowerDevBattRtStateService = ckPowerDevBattRtStateService; } + @Autowired + public void setCkPowerDevBattRtDataService(CKPowerDevBattRtDataService ckPowerDevBattRtDataService) { + CKRtAndSignalAndHrSocket.ckPowerDevBattRtDataService = ckPowerDevBattRtDataService; + } + @OnOpen public void onOpen(Session session, EndpointConfig config){ this.session = session; @@ -60,7 +69,8 @@ CKPowerDevRt ckPowerDevRt = ckPowerDevRtService.get(); CKPowerDevSignal ckPowerDevSignal = ckPowerDevSignalService.get(); CKPowerDevBattRtState ckPowerDevBattRtState = ckPowerDevBattRtStateService.get(); - session.getBasicRemote().sendObject(new Response<>().setIII(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,"鏌ヨ瀹屾垚")); + CKPowerDevBattRtData ckPowerDevBattRtData = ckPowerDevBattRtDataService.get(); + session.getBasicRemote().sendObject(new Response<>().setIV(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,ckPowerDevBattRtData,"鏌ヨ瀹屾垚")); sleep(4000); } } catch (Exception e) { -- Gitblit v1.9.1