修复bug

whyclj

2020-12-14 dbbdd1006f15da8579d709598ce11116e8f70bfe

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
package com.data.Comm; 
 
import java.util.Date; 
import java.util.List; 
 
import org.apache.logging.log4j.LogManager; 
import org.apache.logging.log4j.Logger; 
 
import com.base.Com; 
import com.data.Motor_inf; 
import com.sql.MysqlConnPool; 
 
public class Central_Data_SocketServer_Thread extends Thread{ 
    public static int Dev_Type_LineScreen = 10004;            //½ø³öÏßÆÁ 
    public static int Dev_Type_DcDistribute = 10005;        //Ö±Á÷Ö÷Åä 
     
     
    private MysqlConnPool pool; 
    private List<Motor_inf> motors; 
    private Logger logger = null; 
     
     
    public Central_Data_SocketServer_Thread(MysqlConnPool pool,List<Motor_inf> motors) { 
        this.pool = pool; 
        this.motors = motors; 
        logger = LogManager.getFormatterLogger(this.getClass()); 
    } 
     
    @Override 
    public void run() { 
        logger.trace(" Central_Data_SocketServer_Thread Start at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); 
        for(int i = 0;i<motors.size();i++) { 
            Motor_inf motor = motors.get(i); 
            Central_Data_SocketClient_Thread socket = new Central_Data_SocketClient_Thread(pool,motor); 
            new Thread(socket).start(); 
        } 
    } 
}