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();
		}
		
	}

}