| | |
| | | package com.whyc.webSocket; |
| | | |
| | | import com.whyc.dto.InterfacePageParam; |
| | | import com.whyc.dto.InterfaceParam; |
| | | import com.whyc.service.InterfaceService; |
| | | import com.whyc.util.ActionUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | @OnMessage |
| | | public void onMessage(Session session, String message){ |
| | | InterfacePageParam param = ActionUtil.getGson().fromJson(message, InterfacePageParam.class); |
| | | InterfaceParam param = ActionUtil.getGson().fromJson(message, InterfaceParam.class); |
| | | thread = new Thread("Thread_interfacePowerAlarm") { |
| | | @Override |
| | | public void run() { |
| | | while (runFlag && !isInterrupted()) { |
| | | Thread thread = currentThread(); |
| | |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |
| | | session.getBasicRemote().sendObject(service.getPwrdevAlarm(param.getPageNum(),param.getPageSize())); |
| | | session.getBasicRemote().sendObject(service.getPwrdevAlarm(param.getPowerDeviceIds(), param.getInterfaceNumber())); |
| | | } |
| | | threadFlagMap.put(thread.getId(),false); |
| | | } |