package org.springblade.system.nettyServer;

import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ConcurrentHashMap;

@Component
public class ServerHandler extends ChannelInboundHandlerAdapter {

	private String reg_LA = "LA[d]{8}[d|A-F]{12}[d|A-F]{8}[d|A-Z]{2}[d|A-F]{4}[x2A][d|A-F]{6}[#@]";
	private String reg_LB = "LB[\\d|A-F]{12}[\\x2A].*[#@]";
	private String reg_LB2 = "LB[\\d|A-F]{6}[\\x2A].*[#@]";
	private String reg_LD = "LD[d]{8}[d|A-F]{12}:[A-Z]{4}[\\x2A].*[#@]";


	private ConcurrentHashMap<String, Channel> sessionChannelMap = new ConcurrentHashMap<String, Channel>();

	private static ServerHandler serverHandler;

	@PostConstruct
	public void init() {
		serverHandler = this;
	}

	/**
	 * 客户端与服务端创建连接的时候调用
	 */
	@Override
	public void channelActive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("CTX:" + ctx.channel());
		System.out.println("客户端与服务端连接开始...");
//		ChannelId id = ctx.channel().id();
//		String s = id.toString();
		//NettyConfig.group.add(ctx.channel());
	}

	/**
	 * 客户端与服务端断开连接时调用
	 */
	@Override
	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("客户端与服务端连接关闭...");
	}

	/**
	 * 服务端接收客户端发送过来的数据结束之后调用
	 */
	@Override
	public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
		ctx.flush();
		System.out.println("信息接收完毕...");
	}

	/**
	 * 工程出现异常的时候调用
	 */
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		cause.printStackTrace();
		ctx.close();
	}

	/**
	 * 服务端处理客户端websocket请求的核心方法，这里接收了客户端发来的信息
	 */
	@Override
	public void channelRead(ChannelHandlerContext channelHandlerContext, Object info) throws Exception {
		long startTime1 = System.currentTimeMillis();
		Date day = new Date();
		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("接收到了：" + info);
		ByteBuf buf = (ByteBuf) info;
		byte[] req = new byte[buf.readableBytes()];
		buf.readBytes(req);
		String body = new String(req, "UTF-8");
		String content = body;
		System.out.println("【TCP】>>>>>> 接收客户端数据:" + body);
		String state="系统故障"; //设备故障状态
		String reason=null; //故障原因
		//获取字符串的长度
		int length = content.length();
		//当字符串长度大于200时，采集体温数据，小于则采集报警数据
		System.out.println("tcp报文长度 = " + length);

//		channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer("LEOK#@!", CharsetUtil.UTF_8));
		//服务端使用这个就能向 每个连接上来的客户端群发消息
		//NettyConfig.group.writeAndFlush(info);
//		Iterator<Channel> iterator = NettyConfig.group.iterator();
//		System.out.println("iterator:"+iterator);
//        while(iterator.hasNext()){
//          //打印出所有客户端的远程地址
//           System.out.println((iterator.next()).remoteAddress());
//
//		}
	}


}