package ng.devices;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

import builder.S7control;
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import ng.db.DBHelper;
import ng.db.DBSession;
import ng.db.DBSession.StdCallResult;


public abstract class ModbusService implements Runnable  {


	//modbus客户端
	protected ModbusClient client;
	//自动读数据地址(字节为单位,目前是0)
	protected int readOffset;
	//自动读取数据长度(字节为单位，可超长，目前用50，最大250)
	protected int readSize;
	//设备ID
	protected int machineID;
	//连接类型
	protected byte functionType;
	//线程运行状态
	protected boolean running;

	//设备IP
	protected  String ip;
	//设备端口
	protected int port;
	protected String remarks;
	//线程
	java.lang.Thread thread;
	//缓冲区（服务允许发送超过协议要求的数据，所以缓冲区更大）
	byte[] buff=new byte[10000];

    
  
    public String LastReturn;
    
    //关闭线程
    public void close(){
    	this.running=false;
    }

    //运行
    public void Run(int MachineID,String ip,int port,byte state,int ReadOffset,int ReadSize,int timeout,byte FunctionType,String remarks){
    	//设置参数
    	this.machineID=MachineID;
    	this.ip=ip;
    	this.port=port;
    	this.readOffset=ReadOffset;
    	this.readSize=ReadSize;
		this.functionType= FunctionType;
		this.remarks= remarks;

    	//启动线程
		if(this.port==102){
			thread=new java.lang.Thread(this);
			thread.start();
		}else{
			this.client=new ModbusClient();
			this.client.setConnectionParam(MachineID,ip,port,(byte)state,timeout);
			thread=new java.lang.Thread(this);
			thread.start();
		}


    }
    
    
    //一次读取行为
    String once(){
    	//按照配置读数据
    	String msg= client.read(this.readOffset,this.readSize,buff,0,this.functionType);
    	this.LastReturn=msg;
    	if(msg=="ok"){
    		try {
    			//请求打包
        		ModbusDataPackage pack=new ModbusDataPackage();
        		pack.ByteSize=this.readSize;
        		pack.Address=this.readOffset;
        		pack.Content=buff;
        		ModbusDataPackage rsp=new ModbusDataPackage();
        		//调用服务
        		if(this.Service(pack,rsp)){
        			//服务要求会数据，则会
        			if(rsp.Content!=null){
        			  return client.write(rsp.Address,rsp.ByteSize,rsp.Content,0);
        			}
        		}
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();			    
			}
    		finally{
    		}
    		
    		
    	}
    	return msg;
    }
	//一次s7读取行为
	String onceS7(){
		try {
			DBSession sn=null;
			String result=null;
			String flag=null;
			String messsage="000000000000000000";
			EPlcType ePlcType=null;
			if(this.machineID==4){
				ePlcType=EPlcType.S1500;
			}else if(this.machineID==6){
				ePlcType=EPlcType.S200_SMART;
			}else{
				ePlcType=EPlcType.S1200;
			}
			S7control s7=new S7control(ePlcType, ip, port, 0, 0);
			//List<Integer> word=s7.readWord("DB34.122",  1);
			List<Integer> listWord=s7.readWord(this.remarks,(this.readSize/2));
			if(listWord==null){
				System.out.println("notread");
				return "";
			}
            for(int i=0;i<listWord.size();i++){
				//System.out.println("i  "+listWord.size()+"   "+messsage);
				messsage+=HexUtil.intTo2ByteHex(listWord.get(i));
			}

			//System.out.println(messsage);
			//System.out.println(ip+"  "+s7.readWord("DB34.122",  1));
			//数据库
			DBHelper db=DBHelper.getDBHelper("mes");
			try{
				//创建连接
				sn=db.createSession(false);
				Connection con= sn.getConnection();
				//调用那个存储过程
				CallableStatement sql=con.prepareCall("{call Total_method(?,?,?,?)}");
				sql.registerOutParameter(3, java.sql.Types.VARCHAR);
				sql.registerOutParameter(4, java.sql.Types.VARCHAR);
				sql.setString(1, messsage);
				sql.setLong(2, machineID);
				sql.execute();
				//读取返回参数
				result= sql.getString(3);
				flag= sql.getString(4);
				if (result!=null&&result.length()>0){
					String []results=result.split(",");
					//得到存储过程返回的值，数组第一个为地址，第二个为值
					int resultsLength=results.length;
					int resultsSize=resultsLength/2;

					for(int i=1;i<resultsSize+1;i++){
						int addressIndex=(i-1)*2;
						int valueIndex=i*2-1;
						s7.writeWord(results[addressIndex],Integer.valueOf(results[valueIndex]));//参数组写入
					}
//					if(results.length==2){
//						s7.writeWord(results[0],Integer.valueOf(results[1]) );
//					}
//					if(results.length==4){
//						s7.writeWord(results[0],Integer.valueOf(results[1]));//配方
//						s7.writeWord(results[2],Integer.valueOf(results[3]));//速度
//					}
					List<Integer> listWord2=s7.readWord(this.remarks,(this.readSize/2));
					System.out.println(listWord2.size());

				}


			}
			catch(Exception e){
				e.printStackTrace();
			}
			finally{
				sn.close();

			}

		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally{

		}

		return "";
	}

	public void SendPLC(int Address, int count, byte[] buffer, int offset) {
		this.client.write(Address, count, buffer, offset);
	}
    public boolean isRunning(){
    	return this.running;
    }
	
    public boolean isOnLine(){
        ModbusClient c=this.client;
        if(this.client!=null)
    	return this.client.IsEnable();
        return false;
    }
    
    protected int UpadateInterval=200;
	
    //线程运行函数
	void proc(){
		running=true;
		while(running){
			if(this.port==102||client.IsEnable()){
				try {
					java.lang.Thread.sleep(UpadateInterval);
					if(this.port==102){
						String back=onceS7();
					}else{
						String back=once();
					}

				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
				}
			}
			else{
				client.connect();
				if(client.IsEnable()==false){
					try {
						java.lang.Thread.sleep(4000);
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
					}
				}
//				else{
//					System.out.print("IO链接成功");
//				}
			}
		}
		this.running=false;
		client.close();
		
	}

   //线程入口
	@Override
	public void run() {
		// TODO Auto-generated method stub

		proc();
	}
	public class ModbusDataPackage{
		public int Address;
		public int ByteSize;
		public byte[] Content;
	}
	protected  abstract boolean Service(ModbusDataPackage request,ModbusDataPackage response);	 
   

}