秀嘎

whyclj

2020-09-10 2993af45f257be3a1e76545f886bbe6a3b0bc9af

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
package com.electrical.TwoKW;
 
import java.util.List;
 
import com.modbus.data.MyModbusMaster;
import com.modbus.data.MyModbusUtils;
import com.serotonin.modbus4j.BatchRead;
import com.serotonin.modbus4j.BatchResults;
import com.sql.MysqlConnPool;
 
public class Electrical_2KW_SocketClient_Thread implements Runnable{
 
    public MysqlConnPool conn_pool;
    public Electric_inf_2kw einf;
    public Electric_Rt_2kw ert;
    public Electric_Control_Single_2kw econ;
    public MyModbusMaster master;
    
    public Electrical_2KW_SocketClient_Thread(Electric_inf_2kw winf,MysqlConnPool conn_pool) {
        this.conn_pool = conn_pool;
        this.einf = winf;
        
        ert = new Electric_Rt_2kw(einf.electric2KW_id);
        econ = new Electric_Control_Single_2kw(einf.electric2KW_id);
        master = new MyModbusMaster(einf.getElectric2KW_ip(), MyModbusMaster.SLAVEID_DEFAULT);
    }
        
 
    @Override
    public void run() {
        int runCount = 0;
        while(true) {
            try {
                
                if(runCount %2 == 0) {
                    //*************************** ¸üÐÂ2MWϵͳʵʱÐÅÏ¢******************************//*
                    readMutilElectric_Rt_2kw(master, ert);
                    Electrical_2KWTask_SQL.update_Electric_Rt_2KW(conn_pool, ert);
                    
                    
                    
                    
                    
                    //**************************** ¸üÐÂ2MWϵͳ¿ØÖÆÐÅÏ¢ *****************************//*
                    readMutilElectric_Control_Single_2kw(master, econ);
                    Electrical_2KWTask_SQL.update_Electric_Control_2KW(conn_pool, econ);
                    
                }
                
                /*if(runCount %4 == 0) {
                    //*************************** ¶ÁÈ¡2MWÐÅÏ¢¹ÊÕÏ ******************************//*
                    //readWaterAlarmData(master,walarm);
                    readMutilWaterAlarmData(master, walarm);
                    Water_Task_SQL.insertOrUpdateWater_alarmTable(conn_pool, listAlarm);
                }*/
                
                if(runCount%10 == 0) {
                    //¸üе±Ç°É豸ip
                    master.setTarget_ip(einf.electric2KW_ip);
                }
                if(runCount > 999900) {
                    runCount = 0;
                }
                runCount ++;                
                Thread.sleep(200);                
            } catch (Exception e) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e1) {
                    //e1.printStackTrace();
                }
                e.printStackTrace();
            }
        }
    }
    /**
     * ¸üÐÂ2MWµçԴϵͳʵʱ״̬ÐÅÏ¢
     * @param master
     * @param ert
     */
    public void readMutilElectric_Rt_2kw(MyModbusMaster master, Electric_Rt_2kw ert) {
        BatchRead<Integer> batch = ert.createBatchRead(master);        
        BatchResults<Integer> res = MyModbusUtils.readMutilRegisters(batch, master);
        ert.putBatchResult(res);
    }
    /**
     * ¸üÐÂ2MWµçÔ´¿ØÖÆÐÅÏ¢
     * @param master
     * @param econ
     */
    public void readMutilElectric_Control_Single_2kw(MyModbusMaster master, Electric_Control_Single_2kw econ) {
        BatchRead<Integer> batch = econ.createBatchRead(master);        
        BatchResults<Integer> res = MyModbusUtils.readMutilRegisters(batch, master);
        econ.putBatchResult(res);
    }
    
    
    /**
     * ¸üÐÂ2MWµçÔ´¿ØÖÆÐÅÏ¢
     * @param master
     * @param econ
     */
    public void readMutilElectric_State_2kw(MyModbusMaster master, Electric_State_2kw state) {
        BatchRead<Integer> batch = state.createBatchRead(master);        
        BatchResults<Integer> res = MyModbusUtils.readMutilRegisters(batch, master);
        state.putBatchResult(res);
    }
}