锂电池监测维护一体化平台
parent: 1dda096d | 补丁 | 提交 | ignore whitespace
whyclxw
2024-10-29 cdb8297d0f08ebff314ae726c5b21def9887ff75 
websocket默认101全改为从session获取
5个文件已修改
35 ■■■■■ 已修改文件
src/main/java/com/whyc/webSocket/DevAlmPopUp.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/DevInfSocket.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/DevLineSocket.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/DevStaticSocket.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/DevalarmSocket.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 src/main/java/com/whyc/webSocket/DevAlmPopUp.java


@@ -2,6 +2,7 @@




import com.whyc.config.WebSocketConfig;


import com.whyc.dto.Response;


import com.whyc.pojo.db_user.UserInf;


import com.whyc.service.DevInfService;


import com.whyc.service.DevalarmDataService;


import com.whyc.service.UserInfService;


@@ -37,9 +38,9 @@


    @OnOpen


    public void onOpen(Session session, EndpointConfig config){


        this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");


        //UserInf user = (UserInf) this.httpSession.getAttribute("user");


        //final int userId = user.getUid();


        final int userId = 101;


        UserInf user = (UserInf) this.httpSession.getAttribute("user");


        final int userId = user.getUid();


        //final int userId = 101;


        Thread thread = new Thread() {


            @Override


            public void run() {




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


@@ -3,6 +3,7 @@


import com.whyc.config.WebSocketConfig;


import com.whyc.dto.DevInfDto;


import com.whyc.dto.Response;


import com.whyc.pojo.db_user.UserInf;


import com.whyc.service.DevInfService;


import com.whyc.util.ActionUtil;


import org.springframework.beans.factory.annotation.Autowired;


@@ -48,9 +49,9 @@


    @OnMessage


    public void onMessage(Session session, String message) {


        DevInfDto devInfDto = ActionUtil.getGson("yyyy-MM-dd").fromJson(message, DevInfDto.class);


        //UserInf user = (UserInf) this.httpSession.getAttribute("user");


        //final int userId = user.getUid();


        final int userId = 101;


        UserInf user = (UserInf) this.httpSession.getAttribute("user");


        final int userId = user.getUid();


        //final int userId = 101;


        thread = new Thread("Thread_DinfSocket") {


            @Override


            public void run() {




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


@@ -2,6 +2,7 @@




import com.whyc.config.WebSocketConfig;


import com.whyc.dto.Response;


import com.whyc.pojo.db_user.UserInf;


import com.whyc.service.DevInfService;


import com.whyc.service.UserInfService;


import org.springframework.beans.factory.annotation.Autowired;


@@ -36,9 +37,9 @@


    @OnOpen


    public void onOpen(Session session, EndpointConfig config){


        this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");


        //UserInf user = (UserInf) this.httpSession.getAttribute("user");


        //final int userId = user.getUid();


        final int userId = 101;


        UserInf user = (UserInf) this.httpSession.getAttribute("user");


        final int userId = user.getUid();


        //final int userId = 101;


        Thread thread = new Thread() {


            @Override


            public void run() {




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


@@ -5,6 +5,7 @@


import com.whyc.dto.ResultA200Dto;


import com.whyc.factory.ThreadPoolExecutorFactory;


import com.whyc.pojo.db_lithium_ram_db.DevInf;


import com.whyc.pojo.db_user.UserInf;


import com.whyc.service.*;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


@@ -53,9 +54,9 @@


    @OnOpen


    public void onOpen(Session session, EndpointConfig config){


        this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");


        //UserInf user = (UserInf) this.httpSession.getAttribute("user");


        //final int userId = user.getUid();


        final int userId = 101;


        UserInf user = (UserInf) this.httpSession.getAttribute("user");


        final int userId = user.getUid();


        //final int userId = 101;


        Thread thread = new Thread() {


            @Override


            public void run() {




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


@@ -5,6 +5,7 @@


import com.whyc.dto.DevInfDto;


import com.whyc.dto.Response;


import com.whyc.pojo.db_alarm.DevalarmData;


import com.whyc.pojo.db_user.UserInf;


import com.whyc.service.DevInfService;


import com.whyc.service.DevalarmDataService;


import com.whyc.util.ActionUtil;


@@ -51,9 +52,9 @@


    @OnMessage


    public void onMessage(Session session, String message) {


        DalmDto dto = ActionUtil.getGson("yyyy-MM-dd HH:mm:ss").fromJson(message, DalmDto.class);


        //UserInf user = (UserInf) this.httpSession.getAttribute("user");


        //final int userId = user.getUid();


        final int userId = 101;


        UserInf user = (UserInf) this.httpSession.getAttribute("user");


        final int userId = user.getUid();


        //final int userId = 101;


        thread = new Thread("Thread_DevalarmSocket") {


            @Override


            public void run() {