zsh_root
2024-01-02 7b595546af704983dbafcd0d385c8768ddacefc2
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
package BaoWen;
import java.io.File;
import java.util.Vector;
 
import Method.BaoWenShow;
import Method.GetNowTime;
import Method.SaveFIleInTxt;
import tbDataModel.Baowen;
import tbDataModel_Dell.Dell_tb_suanfa2;
 
/**
 * ´¦Àíԭʼ±¨ÎÄ
 * »ùÕ¾10ÃëÖÓ×Ô¶¯Æô¶¯Êý¾Ý
 * BBF9D5BE49443A2037313239202E0D0ABBF9D5BEC0E0D0CD3A2042202E0D0AB5A5B4CECDA8D1B6BBF9D5BECAFDC1BF3A203130B8F62E0D0A
 */
public class Dell_baowen_55AA0C implements Runnable{
    static int sleeptime = 1;
    static Thread t;
    static Vector<Baowen> baowenvec2 = new Vector<Baowen>();
    static int a = 0;
    static File file = SaveFIleInTxt.creatFilelog();
    static int AAaa0cnum=1;
 
    public static void intsert(String ip, String hex, String time, int port) {
        AAaa0cnum++;
        if(AAaa0cnum==5000000) {
            AAaa0cnum=1;
        }
        Baowen baowen = new Baowen();
        baowen.setHex(hex);
        baowen.setIp(ip);
        baowen.setAddtime(time);
        baowen.setTimestamp(GetNowTime.timestamp());
        baowen.setPort(port);
        baowenvec2.add(baowen);
    }
 
 
    public static Vector<Baowen> getBaowenvec2() {
        return baowenvec2;
    }
 
    /**
     * ´¦Àíԭʼ±¨ÎÄ
     */
    public void dellhex() {
        int size = baowenvec2.size();
        if (size == 0) {
            sleeptime =50;
            return;
        }
        //Èç¹ûÊý¾Ý´óÓÚ10ÍòÌõûÓд¦ÀíÔòÇå¿Õ
        if (size > 100000) {
            baowenvec2.removeAllElements();
        } else {
            sleeptime =1;//20230708yang
            Baowen baowen0 = baowenvec2.get(0);
            String ip = baowen0.getIp();
            int port = baowen0.getPort();
            String hex = baowen0.getHex();
            String time = baowen0.getAddtime();
            int timestamp = baowen0.getTimestamp();
            dell2(ip,port,hex,time,timestamp);//2023.07.08yang 
            baowenvec2.remove(baowen0);//2023.07.08yang      
        }
    }
 
    public static void dell2(String ip,int port,String hex,String time,int timestamp) {
        Have_Yuanshi_Do.Dell_yuanshi(ip, hex, time);
        if (hex.startsWith("55AA0C")) {
            BaoWenShow.ok("2", "55AA0C", hex, ip, "´¦Àíԭʼ±¨ÎÄ");
            Dell_55AA0C.dell(ip, time, hex, timestamp, port);
        }
        if(Dell_tb_suanfa2.isJnalog_open()){
            SaveFIleInTxt.save_jiexibaowen(hex, file);
        }
    }
  
 
   /**
     * Æô¶¯Ï̵߳ķ½·¨
     */
    public void startThread() {
        t = new Thread(this);
        t.start();
    }
 
    public void run() {
        while (true) {
            try {
                dellhex();
                synchronized (this){//·ÀÖ¹ÆäËûÏ̵߳÷ÓüÓÉÏͬ²½Ëø 2023.07.17 zsh
                    Thread.sleep(sleeptime);//ÐÝÃßʱ¼ä
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
 
 
    public static int getAAaa0cnum() {
        return AAaa0cnum;
    }
 
    //´òÓ¡ÈÕÖ¾
    public static File getFile() {
        return file;
    }
    
 
 
}