南瑞版本新增iedscout调试工具功能

DELL

2024-03-07 8295ec1295eb6b0db77d5079ab6f324513ade80d

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
package com.iedscout; 
 
import java.util.Date; 
 
import org.apache.logging.log4j.LogManager; 
import org.apache.logging.log4j.Logger; 
 
import com.base.Com; 
import com.dec.fbs9100.MysqlConnPool; 
 
 
/** 
 *     数据库更新线程 
 * @author DELL 
 * 
 */ 
public class UpdateDataToMySQL_Task implements Runnable { 
    private BTS_ScoutData_Array scoutData_Array; 
    private MysqlConnPool pool; 
     
    private boolean m_app_UpdateAlive = true; 
    private Logger logger = null; 
     
    private boolean m_initTask = false; 
 
    public UpdateDataToMySQL_Task(BTS_ScoutData_Array scoutData_Array,MysqlConnPool pool) { 
        this.pool = pool; 
        this.scoutData_Array = scoutData_Array;     
         
        this.logger = LogManager.getLogger(this); 
         
    } 
     
    @Override 
    public void run() { 
        logger.info("UpdateDataToMySQL_Task Start at " + Com.get_DTF(new Date(), Com.DTF_YMDhms)); 
        m_app_UpdateAlive = true; 
        BTS61850_IEDScout_Task_Thread_SQL.clearIed_NodeState_Table(pool); 
 
                 
        while(m_app_UpdateAlive) { 
            try { 
//                if(m_app_UpdateAlive) { 
//                    //清空数据库表 
//                     
//                    BTS61850_IEDScout_Task_Thread_SQL.inseartIed_NodeState_Table(pool, scoutData_Array); 
//                     
//                    m_app_UpdateAlive = false; 
//                } 
                 
                //System.err.println("UpdateDataToMySQL_Task : scoutData_Array.Count():" + scoutData_Array.getDataCount()); 
                //BTS61850_IEDScout_Task_Thread_SQL.updateIed_NodeState_Table(pool, scoutData_Array); 
                BTS61850_IEDScout_Task_Thread_SQL.inseartIed_NodeState_Table(pool, scoutData_Array); 
                Thread.sleep(2000); 
                 
            } catch (Exception e) { 
                logger.error("UpdateDataToMySQL_Task" + e.toString(), e); 
            }         
        }         
        logger.info("UpdateDataToMySQL_Task Stop at " + Com.get_DTF(new Date(), Com.DTF_YMDhms)); 
    } 
     
     
    public void setApp_UpdateAlive(boolean flag) { 
        this.m_app_UpdateAlive = flag; 
    } 
 
    public boolean isM_initTask() { 
        return m_initTask; 
    } 
 
    public void setM_initTask(boolean m_initTask) { 
        this.m_initTask = m_initTask; 
    } 
     
     
     
}