package com.sp_comm;

import com.dev.central.Central_ST_Data;
import com.intelligt.modbus.MyJlibModbus;
import com.modbus.data.MyModbusMaster;

public class Central_Monitor_Thread implements Runnable{
	public static final int DEV_TYPE_DEFAULT = 0;
	public static final int DEV_TYPE_GENERAL = 1;
	public static final int DEV_TYPE_DCDIS   = 2;	
	/***********************************************/
	public MyModbusMaster master;
	public MyJlibModbus mymodbus;
	
	
	public static int dev_type = DEV_TYPE_DEFAULT;			//É豸ÀàÐÍ
	
	public boolean read_data = false;						//¶ÁÈ¡Êý¾Ý
	public boolean auto_update_data = false;				//×Ô¶¯Ëæ»úÊý¾Ý
	public boolean write_data = false;						//дÈëÊý¾Ý
	
	public Central_ST_Data data;
	
	
	public Central_Monitor_Thread(String serverip,int slave_id){
		//master = new MyModbusMaster(serverip,slave_id);
		mymodbus = new MyJlibModbus(serverip, slave_id, 16, 16, 16, 16);
		data = new Central_ST_Data();
	}
	
	@Override
	public void run() {
		new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e1) {
					e1.printStackTrace();
				}
				while(true) {
					try {
						/********* ¶ÁÈ¡Êý¾Ý ****************************************************/
						if(read_data) {				
							data.readMutliData(dev_type, mymodbus);
						}
					
						/********* ×Ô¶¯Ëæ»úÊý¾Ý ****************************************************/
						if(auto_update_data) {
							data.randomData(); 					//Éú³ÉËæËæ»úÊý¾Ý
							data.writeMutliData(dev_type,mymodbus);		
							//System.err.println(data);
						}		
						
						/********* дÈëÊý¾Ý *****************************************************************/
						if(write_data) {
							data.writeMutliData(dev_type,mymodbus);	
							write_data = false;
						}
						Thread.sleep(500);
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
		
		
		System.out.println("¿ªÊ¼Ï̡߳£¡£¡£");
		mymodbus.init();		
		System.out.println("¼´½«ÔËÐС£¡£¡£");
		
	}
	
}