2kw添加实时和历史故障检测和存储

whyclj

2020-09-23 aa8c04269a191e7c4b157b6442b7beb0e064a5b5

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
package com.electrical.TwoKW; 
 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.List; 
import com.base.Com; 
import com.sql.MysqlConnPool; 
 
public class DeviceAlarm_Thread implements Runnable{ 
    public MysqlConnPool pool; 
    public List<Electric_inf_2kw> einfs; 
    public List<Electric_2MW_alarm> last_alarms;            //ÉÏÒ»´ÎµÄ¸æ¾¯¶ÔÏó 
         
    public DeviceAlarm_Thread(MysqlConnPool pool,List<Electric_inf_2kw> einfs) { 
        this.pool = pool; 
        this.einfs = einfs; 
        last_alarms = new ArrayList<>(); 
        init(); 
    } 
     
    public void init() { 
        for(int i = 0;i<einfs.size();i++) { 
            Electric_2MW_alarm  alarm = new Electric_2MW_alarm(einfs.get(i).electric2KW_id); 
            //¼ÓÔØ֮ǰµÄ¸æ¾¯¼Ç¼ 
            Electrical_2KWTask_SQL.searchLastDeviceAlarm(pool, alarm);     
            last_alarms.add(alarm); 
        } 
    } 
     
    @Override 
    public void run() { 
        System.out.println("DeviceAlarm_Thread Start at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); 
        List<DeviceAlarm> addalarm = new ArrayList<DeviceAlarm>();            //гöÏֵĸ澯 
        List<DeviceAlarm> delalarm = new ArrayList<DeviceAlarm>();            //ÏûʧµÄ¸æ¾¯ 
         
        while(true) { 
            try { 
                for(int i = 0;i < einfs.size();i ++) { 
                    //¶ÁÈ¡¹ýµ±Ç°É豸µÄ¸æ¾¯²Å¼ì²â¸æ¾¯ 
                    if(einfs.get(i).alarm.isReadOk) { 
                        einfs.get(i).alarm.checkAlarm(last_alarms.get(i),addalarm,delalarm); 
                        last_alarms.set(i, einfs.get(i).alarm.clone()); 
                    } 
                } 
                 
                if(addalarm.size() > 0) { 
                    //гöÏֵĸ澯¼Ç¼ 
                    DeviceAlarm_Thread_SQL.insertNewAlarm(pool,addalarm); 
                    addalarm.clear(); 
                } 
                 
                if(delalarm.size() > 0) { 
                    //È¡ÏûµÄ¸æ¾¯¼Ç¼ 
                    for(int k = 0;k<delalarm.size();k++) {                         
                        DeviceAlarm_Thread_SQL.makeRealToHistory(pool,delalarm.get(k)); 
                    } 
                    delalarm.clear(); 
                } 
                Thread.sleep(1000); 
            } catch (Exception e) { 
                try { 
                    Thread.sleep(5000); 
                } catch (InterruptedException e1) { 
                    e1.printStackTrace(); 
                } 
                e.printStackTrace(); 
            } 
        } 
         
    } 
}