package baowen;

import tools.GetNowTime;
import tools.Tools;

import java.io.IOException;
import java.net.*;

public class Dell_udpReceive implements Runnable{

    int port=7000;
    static DatagramSocket socket;
    static int bytlenth=1024;
    static DatagramPacket packet;
    static boolean startFlag=false;
    private static Thread receiveThread;

    public Dell_udpReceive(int port1){
        try {
            startFlag=true;
            port=port1;
            socket = new DatagramSocket(port);
            byte[] data = new byte[bytlenth]; // 创建byte数组
            packet= new DatagramPacket(data,bytlenth);
        } catch (SocketException e) {
            throw new RuntimeException(e);
        }
    }

    /**启动线程的方法*/
    public void startThread() {
        receiveThread = new Thread(this);
        receiveThread.start();
    }

    @Override
    public void run() {
        while(startFlag) {
            getdata();
        }
    }

    public  void getdata() {
        if (socket != null) {
            try {
                socket.receive(packet); // 接收数据包
                delludp_receive(packet);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    }

    public static void delludp_receive(DatagramPacket packet) {
        int lenth=packet.getLength();
        byte[] byt=subBytes(packet.getData(),0, lenth);
        String ip=packet.getAddress().getHostAddress();//获取发送端的IP地址对象
        int port=packet.getPort();
        String datas = Tools.Bytes2HexString(byt);//串口来的数据
        Dell_Baowen.intsert(ip, datas, GetNowTime.timestamp2(), port);
    }

    public static byte[] subBytes(byte[] src, int begin, int count) {
        byte[] bs = new byte[count];
        System.arraycopy(src, begin, bs, 0, count);
        return bs;
    }


    /**将数据发给基站*/
    public static void sendData(byte[] data,String ip2,int port2) {
        if(socket==null) {
            return;
        }
        String datas1=Tools.Bytes2HexString(data);
        DatagramPacket packet=null;
        InetAddress address=null;
        //如果数据类型相同
        try {
            address=InetAddress.getByName(ip2);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        packet=new DatagramPacket(data, data.length, address, port2);
        try {
            socket.send(packet);
            String datas=Tools.Bytes2HexString(data).substring(0, packet.getLength()*2);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }



    /** 停止线程并释放资源 */
    public static void stop() {

        if (receiveThread != null && receiveThread.isAlive()) {
            try {
                receiveThread.join();  // 等待线程结束
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }

    public static void stopThread() {
        startFlag = false;//停止数据接收
        if (socket != null && !socket.isClosed()) {
            socket.close();//关闭socket对象
        }
        stop();
    }
}