package com.sp_comm;

import com.dev.Rectifier_power.Rectifier_power;
import com.intelligt.modbus.MyJlibModbus;
import com.modbus.data.MyModbusMaster;

public class Rectifier_Power_Thread implements Runnable{
	public MyModbusMaster master;
	public MyJlibModbus mymodbus;
	public boolean read_data = false;						//¶ÁÈ¡Êý¾Ý
	public boolean auto_update_data = false;				//×Ô¶¯Ëæ»úÊý¾Ý
	public boolean write_data = false;						//дÈëÊý¾Ý
	
	public boolean running_en = true;						//ÊÇ·ñÔËÐÐ
	
	public Rectifier_power rPower;
	
	public Rectifier_Power_Thread(String serverip,int slave_id){
		//master = new MyModbusMaster(serverip,slave_id);
		mymodbus = new MyJlibModbus(serverip, slave_id, 16, 16, 16, 16);
		rPower=new Rectifier_power();
	}

	@Override
	public void run() {
		new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e1) {
					e1.printStackTrace();
				}
				while(running_en) {
					//System.out.println(this.getClass().getName());
					try {
						/********* ¶ÁÈ¡Êý¾Ý ****************************************************/
						if(read_data) {				
							rPower.readMutliData( mymodbus);
						}
					
						/********* ×Ô¶¯Ëæ»úÊý¾Ý ****************************************************/
						if(auto_update_data) {
							rPower.randomData(); 					//Éú³ÉËæËæ»úÊý¾Ý
							rPower.writeMutliData(mymodbus);		
							//System.err.println(data);
						}		
						
						/********* дÈëÊý¾Ý *****************************************************************/
						if(write_data) {
							rPower.writeMutliData(mymodbus);	
							write_data = false;
						}
						Thread.sleep(500);
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
		
		
		System.out.println("¿ªÊ¼Ï̡߳£¡£¡£");
		mymodbus.init();		
		System.out.println("¼´½«ÔËÐС£¡£¡£");
		
	}
}