package org.springblade.modules.netty.handle;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.DatagramPacket;
import io.netty.util.CharsetUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.modules.netty.business.entity.DeviceMobilePositionPoliceCamera;
import org.springblade.modules.netty.business.service.DeviceChannelPoliceCameraService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import static org.springblade.modules.netty.config.MyDecoder.hexToByte;
import static org.springblade.modules.netty.config.MyDecoder.hexTohort;
import static org.springblade.modules.netty.util.Hex.getDouble;
import static org.springblade.modules.netty.util.Hex.hexStr2Str;

/**
 * updHandler udp 服务端数据接收处理
 * @author zhongrj
 * @date 2023-02-21
 */
@Component
public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {
	private Logger logger = LoggerFactory.getLogger(this.getClass());

	private static UdpServerHandler udpServerHandler;

	@Autowired
	private DeviceChannelPoliceCameraService deviceChannelPoliceCameraService;

	@PostConstruct
	public void init() {
		udpServerHandler = this;
		udpServerHandler.deviceChannelPoliceCameraService = this.deviceChannelPoliceCameraService;
	}

	@Override
	protected void channelRead0(ChannelHandlerContext channelHandlerContext, DatagramPacket datagramPacket) throws Exception {
		// 读取收到的数据
		ByteBuf buf = (ByteBuf) datagramPacket.copy().content();
		byte[] req = new byte[buf.readableBytes()];
		buf.readBytes(req);
		String body = new String(req, CharsetUtil.UTF_8);
		// 字节转16进制字符串
		String s = bytesToHexString(req);
		//获取字符串的长度
		int length = s.length();
//		System.out.println("数据长度>>>>>> = " + length);
		//数据解析
		dataHandler(s);
	}

	/**
	 * 数据解析
	 * @param s 16位字符串
	 */
	private void dataHandler(String s) {
		System.out.println("s = " + s);
		s = "AAAACCCC220000000033373933343732393100000000000000000000000052D50451F77D5D406C04E275FD723C400000015F0000000507E70306103B0A";
		System.out.println("s = " + s);
		//创建设备对象
		DeviceMobilePositionPoliceCamera backEquipment = new DeviceMobilePositionPoliceCamera();
//		if (s.substring(4,8).equals("CCCC")) {
//			backEquipment.setStatus(1);
//		}
//		//断开连接
//		if (s.substring(4,8).equals("FFFF")) {
//			backEquipment.setStatus(0);
//		}
		//截取字符串,并去除后面多余的空格（如果有）
		backEquipment.setChannelId(hexStr2Str(s.substring(20, 60)).trim());
		//设置经纬度
		backEquipment.setLongitude(getDouble(s.substring(60, 76)));
		backEquipment.setLatitude(getDouble(s.substring(76, 92)));
		// 设置速度、方向等
		backEquipment.setSpeed(hexTohort(s.substring(92, 96)));
		backEquipment.setDirection(hexTohort(s.substring(96, 100)));
		backEquipment.setAltitude(hexTohort(s.substring(100, 104)));
		backEquipment.setReportSource(Short.toString(hexTohort(s.substring(104, 108))));
		//时间拼接
		String year = Short.toString(hexTohort(s.substring(108, 112)));
		String month = Short.toString(hexToByte(s.substring(112, 114)));
		if (Integer.parseInt(month)<10){
			month = "0" + month;
		}
		String day = Short.toString(hexToByte(s.substring(114, 116)));
		if (Integer.parseInt(day)<10){
			day = "0" + day;
		}
		String hour = Short.toString(hexToByte(s.substring(116, 118)));
		if (Integer.parseInt(hour)<10){
			hour = "0" + hour;
		}
		String minute = Short.toString(hexToByte(s.substring(118, 120)));
		if (Integer.parseInt(minute)<10){
			minute = "0" + minute;
		}
		String second = Short.toString(hexToByte(s.substring(120, 122)));
		if (Integer.parseInt(second)<10){
			second = "0" + second;
		}
		String time = year + "-" + month + "-" + day +" " + hour + ":" + minute + ":" + second;
		backEquipment.setTime(time);
		// 该处设置成和通道一样
		backEquipment.setDeviceId(backEquipment.getChannelId());
		// 新增
		udpServerHandler.deviceChannelPoliceCameraService.save(backEquipment);
	}

	/**
	 * 转换
	 * @param bArray
	 * @return
	 */
	public String bytesToHexString(byte[] bArray) {
		StringBuffer sb = new StringBuffer(bArray.length);
		String sTemp;
		for (int i = 0; i < bArray.length; i++) {
			sTemp = Integer.toHexString(0xFF & bArray[i]);
			if (sTemp.length() < 2)
				sb.append(0);
			sb.append(sTemp.toUpperCase());
		}
		return sb.toString();
	}


	/**
	 * 捕获异常
	 * @param ctx
	 * @param cause
	 * @throws Exception
	 */
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)throws Exception {
		logger.error("UdpServerHandler exceptionCaught"+cause.getMessage());
		System.out.println("UdpServerHandler exceptionCaught"+cause.getMessage());
		cause.printStackTrace();
		ctx.close();
	}

	/**
	 * 消息没有结束的时候触发
	 * @param ctx
	 * @throws Exception
	 */
	@Override
	public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
		ctx.flush();
	}
}