| | |
| | | |
| | | import com.whyc.config.WebSocketConfig; |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.pojo.UserInf; |
| | | import com.whyc.service.BattdischargePlanService; |
| | | import com.whyc.service.FaultUploadService; |
| | | import com.whyc.service.KPIService; |
| | |
| | | |
| | | @OnMessage |
| | | public void onMessage(Session session, String message) { |
| | | /*UserInf user = (UserInf) this.httpSession.getAttribute("user"); |
| | | final int userId = user.getUId().intValue();*/ |
| | | final int userId = 1041; |
| | | UserInf user = (UserInf) this.httpSession.getAttribute("user"); |
| | | final int userId = user.getUId().intValue(); |
| | | //final int userId = 1041; |
| | | Integer limitN = Integer.valueOf(message); |
| | | thread = new Thread("Thread_RealTime") { |
| | | @Override |