package baowen;

import tools.GetNowTime;

import java.util.Vector;

public class Dell_Baowen implements Runnable {

    static Thread t;

    static Vector<Baowen> baowenvec = new Vector<Baowen>();
    static int sleeptime = 1;

    public void startThread() {
        t = new Thread(this);
        t.start();
    }

    public static void intsert(String ip, String hex, String time, int port) {
        Baowen baowen = new Baowen();
        baowen.setHex(hex);
        baowen.setIp(ip);
        baowen.setAddtime(time);
        baowen.setTimestamp(GetNowTime.timestamp());
        baowen.setPort(port);
        baowenvec.add(baowen);
    }


    public void run() {
        while (true) {
            try {
                dellhex();
                Thread.sleep(sleeptime);//休眠时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void dellhex() {
        int size = baowenvec.size();
        if (size == 0) {
            sleeptime = 10;
            return;
        }
        if (size > 100000) {//如果数据大于10万条没有处理则清空
            baowenvec.removeAllElements();
        } else {
            sleeptime = 0;
            Baowen baowen0 = baowenvec.get(0);
            String ip = baowen0.getIp();
            int port = baowen0.getPort();
            String hex = baowen0.getHex();
            String time = baowen0.getAddtime();
            int timestamp = baowen0.getTimestamp();
            int lenth = hex.length();
            try {
                dellhex2(ip, port, hex, time, timestamp, lenth);//处理原始数据
            } catch (Exception e) {
                e.printStackTrace();
            }
            baowenvec.remove(baowen0);//删除处理过的报文
        }
    }
    public static void dellhex2(String ip, int port, String hex, String time, int timestamp, int lenth) {
        if (hex.startsWith("55AA39")) {
            Dell_55AA39.dell(ip, hex,port);
        }else if (hex.startsWith("55AA40")){
            Dell_55AA40.dellrgs(ip, hex,port);
        }else if (hex.startsWith("55AA03")){
            Dell_55AA03.dell(ip, hex,port);
        }else if (hex.startsWith("55AA34")){
            Dell_55AA34.dellrgs(ip, hex,port);
        }else {
            Dell_uanshi_byt.intsert(ip, hex, time, timestamp, port);
        }
    }
}