package com.dy.rtuMw.server.forTcp;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.mina.core.session.IoSession;

import com.dy.common.mw.channel.tcp.TcpIoSessionAttrIdIsRtuAddr;
import com.dy.common.mw.channel.tcp.TcpIoSessionEventCallback;
import com.dy.common.mw.core.CoreUnit;
import com.dy.rtuMw.server.tasks.RtuUpTask;

public class TcpIoSessionCallback implements TcpIoSessionEventCallback{

	private static Logger log = LogManager.getLogger(TcpIoSessionCallback.class.getName());

    /**
     * 网络连接打开
     */
	public void sessionOpened(IoSession session) throws Exception {
    	log.info("网络连接建立，终端网址是：" + session.getRemoteAddress().toString()) ;
	}

	/**
	 * 网络连接关闭
	 */
	@Override
	public void sessionClosed(IoSession session) throws Exception {
		if(session != null){
	     	String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ;

	     	if(rtuAddr != null){
	     		//记录状态
	     		RtuStatusDealer.offLine(rtuAddr);
	     	}

	    	log.info("网络连接关闭，"
	    			+ (rtuAddr==null?"":("终端地址是：" + rtuAddr))) ;
	    			//+ (session==null?"":(session.getRemoteAddress() == null?"":(session.getRemoteAddress().toString()==null?"":("，终端网址是：" + session.getRemoteAddress().toString()))))) ;
		}
 	}
	/**
     * 发生异常
     */
    public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
    	if(session != null && cause != null){
    		String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ;
    		log.error("网络会话发生异常，"
    				+ (rtuAddr==null?"":("终端地址是：" + rtuAddr))
    				+ (session==null?"":(session.getRemoteAddress() != null?("，终端网址是：" + session.getRemoteAddress().toString()):""))
    				+ "\n异常消息：" + cause.getMessage(), cause);
    	}
    }
	
    /**
     * TCP通道发送完数据后，回调的方法，进行后续数据处理
     */
    public void messageSended(IoSession session, Object message) throws Exception  {
      	String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey) ;
    	log.info("网络发送了数据，"
    			+ (rtuAddr==null?"":("终端地址是：" + rtuAddr))
    			+ (session==null?"":(session.getRemoteAddress() != null?("，终端网址是：" + session.getRemoteAddress().toString()):"")) );
    }

    /**
     * TCP通道接收到数据，回调的方法，进行数据处理
     * 此方法调用后，上行数据脱离了NIO线程，进入了核心线程
     */
	@Override
	public void messageReceived(IoSession session, Object message)throws Exception {
		if(session != null && message != null){
			RtuUpTask task = new RtuUpTask() ;
			task.data = new Object[]{session, (byte[])message} ;
			try{
				CoreUnit.getInstance().pushCoreTask(task);
			}catch(Exception e){
				log.error(e.getMessage(), e);
			}
		}
	}

}