package com.genersoft.iot.vmp.netty.handle;

import com.genersoft.iot.vmp.netty.business.entity.TalkBackEquipment;
import com.genersoft.iot.vmp.netty.business.service.TalkBackEquipmentService;
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.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.util.Date;

/**
 * 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 TalkBackEquipmentService talkBackEquipmentService;


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

	@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);

		System.out.println("【UDP】>>>>>> 收到客户端的数据："+body);
		//获取字符串的长度
		int length = body.length();
		System.out.println("数据长度>>>>>> = " + length);
		//保存数据
//		saveTalkBackEquipmentInfo(body);

	}

	/**
	 * 保存设备数据
	 * @param body
	 */
	@Async
	public void saveTalkBackEquipmentInfo(String body) {
		TalkBackEquipment equipmentRecord = new TalkBackEquipment();
		equipmentRecord.setName("ces");
		equipmentRecord.setCode("cs123456");
		equipmentRecord.setStatus(1);
		equipmentRecord.setUnitName("CSDW");
		equipmentRecord.setUnitCode("CSDW123456");
		equipmentRecord.setPoliceName("JINGYUAN");
		equipmentRecord.setPoliceCode("JINGYUAN123456");
		equipmentRecord.setTerminalNumber("788888888888");
		equipmentRecord.setLongitude("128.124124412");
		equipmentRecord.setLatitude("27.1224521421");
		equipmentRecord.setSpeed("10");
		equipmentRecord.setDirection("10");
		equipmentRecord.setElevation("10");
		equipmentRecord.setPrecisions("10");
		equipmentRecord.setReceiveTime(new Date());
		equipmentRecord.setCreateTime(new Date());
		equipmentRecord.setUpdateTime(new Date());
		//保存数据
		udpServerHandler.talkBackEquipmentService.save(equipmentRecord);
	}

	/**
	 * 捕获异常
	 * @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();
	}
}