package?com.iweb.socket;

import?java.util.HashMap;
import?java.util.Map;

import?javax.websocket.OnClose;
import?javax.websocket.OnMessage;
import?javax.websocket.OnOpen;
import?javax.websocket.Session;
import?javax.websocket.server.ServerEndpoint;

@ServerEndpoint（“/websocket/light“）
public?class?LightServer?{
	
	private?static?Map?sessionMap?=?new?HashMap（）;
	
	private?static?int?preDi;
	
	@OnOpen
	public?void?onOpen（）{
		//System.out.println（“WEBopen“）;
	}
	
	@OnClose
	public?void?onClose（）{
		//System.out.println（“WEBCLOSE“）;
	}
	
	@OnMessage
	public?void?onMessage（Session?session?String?msg）{
		//System.out.println（“received?message:?“?+?msg?+?“?session?id:?“?+?session.getId（）?+?“?this:?“?+?this）;
		System.out.println（“received?message?on?light:?“?+?msg）;
		int?di?=?Integer.parseInt（msg）;	//0~255:亮度調節?-1:嵌入式端發來請求	
		if（di?==?preDi）{
			return;
		}
		if（session.isOpen（））{
			Session?waitCommandSession?=?sessionMap.get（“waitCommand“）;
			try?{
				if（di?>=?0）{//控制頁面發來的				
					try{
						if（waitCommandSession?==?null）{
							session.getBasicRemote（）.sendText（“目的地找不到!“）;		
						}else{
							if（waitCommandSession.isOpen（））{
								waitCommandSession.getBasicRemote（）.sendText（di+““）;	
								preDi?=?di;
							}
						}
					}catch（Exception?e）{
						e.printStackTrace（）;
					}			
				}else{//-1
					if（waitCommandSession?!=?null?&&?waitCommandSession.isOpen（））{
						waitCommandSession.close（）;
					}
					sessionMap.put（“waitCommand“?session）;					
				}
			}?catch?（Exception?e）?{
				e.printStackTrace（）;
			}
		}
	}
	
	
}