package com.ld.igds.protocol.quantity.shuhan.server;

import com.ld.igds.io.notify.ServerNotifyInvoker;
import com.ld.igds.protocol.quantity.shuhan.ShuHanUtils;
import com.ld.igds.util.SpringUtil;
import com.ld.io.api.IoSession;
import com.ld.io.api.IoSessionListener;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class SessionListener implements IoSessionListener {

    public static final String BEAN_ID = "shly.sessionListener";


    @Override
    public void onCreate(IoSession session) {
        // 添加自定义业务ID
        session.setBusinessKey(ShuHanUtils.getServerKey(session.getAddress(), session.getPort()));
        log.info("++++蜀汉插件服务新建连接++++-IP={}，PORT={}", session.getAddress(), session.getPort());
    }

    @Override
    public void onDestroy(IoSession session) {
    	ServerNotifyInvoker serverNotifyInvoker = SpringUtil.getBean(ServerNotifyInvoker.class);
        serverNotifyInvoker.connectDestory(session.getBusinessKey(),
                session.getAddress(), session.getPort());
        log.info("---蜀汉插件服务连接断开，系统设置设备离线-----IP={}，PORT={}，SN={}", session.getAddress(), session.getPort(), session.getBusinessKey());
    }
}