提交

whyclj

2020-09-09 491df299f66993c836743774e365dd90f64d84e2

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
package com.dev.base.data;
 
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import com.base.Com;
import com.data.PowerArk_Task_SQL;
import com.sql.MysqlConnPool;
 
public class Dynamicload_ServerSocket_Thread implements Runnable{
    public List<Dynamicload_inf> dinfs;
    public MysqlConnPool conn_pool;
    public Map<Integer, Dynamicload_SocketClient_Thread> dinfthreads;
    
    public Dynamicload_ServerSocket_Thread(MysqlConnPool conn_pool,List<Dynamicload_inf> dinfs) {
        this.dinfs = dinfs;
        this.conn_pool = conn_pool;
        this.dinfthreads = new HashMap<Integer,Dynamicload_SocketClient_Thread>();
    }
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println(" Dynamicload_ServerSocket_Thread Start at " +Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
        for(int i = 0;i<dinfs.size();i++) {
            //²åÈë»ò¸üиºÔØ°´Å¥ÐÅÏ¢±í
            PowerArk_Task_SQL.insertOrUpdateDynamicload_ButtonTable(conn_pool, new Dynamicload_button(dinfs.get(i).getDev_id()),dinfs.get(i).getFZ_button_num());
            //²åÈë»ò¸üиºÔØ״̬ÐÅÏ¢±í
            PowerArk_Task_SQL.insertOrUpdateDynamicload_StateTable(conn_pool, new Dynamicload_state(dinfs.get(i).getDev_id(),dinfs.get(i).getFZ_button_num()));
            
            
            Dynamicload_SocketClient_Thread thread = new Dynamicload_SocketClient_Thread(dinfs.get(i),conn_pool);
            dinfthreads.put(dinfs.get(i).dev_id, thread);
            new Thread(thread).start();
        }
        
    }
 
}