package com.shlanbao.tzsc.data.runtime.netty;
import java.util.Map;
import java.util.Map.Entry;

import com.shlanbao.tzsc.base.interceptor.PMSXmlDataInterceptor;
import com.shlanbao.tzsc.data.webservice.client.SendMessageClient;
import org.jboss.netty.channel.ChannelHandler;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.handler.timeout.IdleStateAwareChannelHandler;

import net.sf.json.JSONObject;


public class ServerHandler extends IdleStateAwareChannelHandler implements ChannelHandler {

	/**
	* channel关闭的时候触发
	*/
	@Override
	public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
		System.out.println("channelClosed");
		super.channelClosed(ctx, e);
	}

	/**
	 * channelConnected：建立新连接，
	 * 我们通常可以用来检测IP是否是黑名单，比如有人恶意攻击服务器，我们在连接时可以监听发送来的请求，
	 * 如果请求过于频繁和流量太大就可以将这个IP加入黑名单
	 *
	 * */
	@Override
	public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
		System.out.println("channelConnected");
		NettyServer.getInstance().getMapChannel().put(ctx.getChannel(), ctx.getChannel());//有新的连接，添加Map
		super.channelConnected(ctx, e);
	}

	/**
	* 必须是链接已经建立，关闭通道的时候会触发
	* channelDisconnected：链接关闭，可以再用户断线的时候清除用户的缓存数据等。
	*/
	@Override
	public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
		System.out.println("channelDisconnected");
		closeMapChannels(ctx);//关闭管道，删除Map管道
		super.channelDisconnected(ctx, e);
	}

	/**
	 * 异常断开
	 *
	 * */
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
		System.out.println("异常断开。。。。");
		closeMapChannels(ctx);//关闭管道，删除Map管道
		super.exceptionCaught(ctx, e);
	}

	/**
	* 接收消息
	*/
	@Override
	@SuppressWarnings("unchecked")
	public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
		try {
			//1 得到字符串信息
			String str=(String) e.getMessage();
			System.out.println(str);
			//2 将字符串转换成map
			Map<String,String> map=(Map<String, String>)JSONObject.fromObject(str) ;
			//3 遍历map
			for(Entry<String, String>  m: map.entrySet()) {
				//4 判断key类型，进入相应的方法
				String key=m.getKey();
				if(key.equals("connection")) {//建立连接，回写客户端信息
					ctx.getChannel().write("服务端回写：重新获取连接成功");
				}/*else if(key.equals("workOrderSts")) {//工单状态反馈MES
					*//** 工单状态：运行，完成，反馈状态MES
					Map<Object, Object> mapBean= JSONUtil.jsonToMap(m.getValue());
					for( Entry<Object, Object> bean : mapBean.entrySet()) {
						System.out.println(bean.getKey().toString()+":"+bean.getValue());
					}*//*
				    System.out.println(m.getValue());
				    //通过webService接口反馈MES
				   SendMessageClient.SendMsgToOrderStsDetail(m.getValue());
				    PMSXmlDataInterceptor.getInstance().addLog(true,"工单状态反馈接口", 1, m.getValue());
				}*/
			}
		} catch (Exception e2) {
			e2.printStackTrace();
		}
		super.messageReceived(ctx, e);
	}

	/**
	 * 空闲连接下线处理
	 *
	 *
	@Override
    public void channelIdle(final ChannelHandlerContext ctx, IdleStateEvent e) throws Exception {
        if ( e.getState() == IdleState.ALL_IDLE) {
            ChannelFuture write = ctx.getChannel().write("time out,you will close");
            write.addListener(new ChannelFutureListener() {
                public void operationComplete(ChannelFuture channelFuture) throws Exception {
                    ctx.getChannel().close();
                }
            });
        }
    }
    */

	/**
	 *  异常，正常断开的管道关闭，删除
	 *
	 *
	 * */
	public void closeMapChannels(ChannelHandlerContext ctx) {
   	    try {
			NettyServer.getInstance().getMapChannel().remove(ctx.getChannel());
			ctx.getChannel().close();
		} catch (Exception e2) {
			System.out.println("关闭异常。。。。");
			e2.printStackTrace();
		}
    }

}