package com.ruoyi.netty.communication;


import com.ruoyi.common.utils.netty.ApplicationContextRegister;
import com.ruoyi.common.utils.netty.ConcurrentHashMapBean;
import com.ruoyi.common.utils.netty.ConvertCode;
import com.ruoyi.common.utils.netty.NettyTool;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.AttributeKey;
import io.netty.util.concurrent.GlobalEventExecutor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;

/**
 * @author 86175
 */
@Slf4j
public class OptometerServerHandler extends SimpleChannelInboundHandler<byte[]> {


    ApplicationContext act = ApplicationContextRegister.getApplicationContext();

    //用于保存所有Channel对象
    public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    //表示连接建立
    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        //chanel可以理解成Connection
        Channel channel = ctx.channel();
        //广播消息给所有的客户端
        channelGroup.add(channel);
    }


    // 数据发送和接受
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, byte[] bytes) throws Exception {
        String receiveStr = ConvertCode.bytes2Str(bytes);
        log.info("info 得到的数据：" + receiveStr);
        // 添加 CRC16校验 添加了 高位 和低位

        //建立通讯通道
        Channel channel = channelHandlerContext.channel();

        //报文原始码
//        String  mangedata=receiveStr.substring(26,receiveStr.length()-6);
//        //序列号
//        String number=receiveStr.substring(8,12);
        channelGroup.forEach(ch -> {
            //表示当前连接 就是当前硬件客户端与服务器进行的连接
            if (channel == ch) {
                if ( !receiveStr.startsWith("aa") && receiveStr.substring(46,48).equals("85")){
                    //获取识别符
                    String Identifier = receiveStr.substring(46, 48);
                    // 获取设备编号
                    String stcd = receiveStr.substring(40, 46);
                    log.info("连接的Id为：" + channel.id().asLongText());
                    online(ch, stcd);
                    ConcurrentHashMapBean.channelMap.put(stcd, channel);
                    log.info("设备: " + stcd + "与channel已经注册成功");
                    log.info("map的字节数" + ConcurrentHashMapBean.channelMap.size());
                }

                // ConnectTOClient.write2Client("7e7e01020304050607", channel, "心跳");

                DecisionIdentifier.ScreenIdentifier(receiveStr,act);
            }
        });
        channel.flush();
    }


    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        /*ctx.close();*/
        log.warn("exceptionCaught发生异常：");
        cause.printStackTrace();
    }

    //连接处于活动状态
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        Channel channel = ctx.channel();
        log.info(channel.remoteAddress() + " 上线了");
    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        try {
            Channel channel = ctx.channel();
            //根据 channel 找到 map的 key 然后删掉 做到数据同步
            String stcd = NettyTool.getKeyByLoop(ConcurrentHashMapBean.channelMap, channel);
            log.info(" channelInactive---通道的设备号： " + NettyTool.getKeyByLoop(ConcurrentHashMapBean.channelMap, channel) + "下线");
            ConcurrentHashMapBean.channelMap.remove(stcd);
            log.info(channel.remoteAddress() + " 下线了");

        } catch (Exception e) {
        }
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        try {
            Channel channel = ctx.channel();
            log.info(" 【硬件设备】 -" + channel.remoteAddress() + " 离开\n");

            //验证一下每次客户端断开连接，连接自动地从channelGroup中删除调。
            // System.out.println(channelGroup.size());
            //当客户端和服务端断开连接的时候，下面的那段代码netty会自动调用，所以不需要人为的去调用它
            channelGroup.remove(channel);
            //下线的设备编号
            String stcd = NettyTool.getKeyByLoop(ConcurrentHashMapBean.channelMap, channel);
            log.info("通道的设备号： " + NettyTool.getKeyByLoop(ConcurrentHashMapBean.channelMap, channel) + "下线");
            //根据stcd  删除 连接通道
            ConcurrentHashMapBean.channelMap.remove(stcd);
        } catch (Exception e) {
        }
    }


    /**
     * 上线一个用户
     *
     * @param channel
     * @param userId
     */
    public void online(Channel channel, String userId) {
        //先判断用户是否在web系统中登录?
        //这部分代码个人实现,参考上面redis中的验证
        ConcurrentHashMapBean.channelMap.put(userId, channel);
        AttributeKey<String> key = AttributeKey.valueOf("user");
        channel.attr(key).set(userId);
    }


}