package?cn.com.webinfo.action.application;

import?java.io.IOException;
import?java.io.UnsupportedEncodingException;
import?java.util.Date;

import?cn.com.webinfo.action.applicationlayer.IApplayerHandler;
import?cn.com.webinfo.action.dataexchangelayer.ExchangeHandler;
import?cn.com.webinfo.action.dataexchangelayer.QueueData;
import?cn.com.webinfo.action.sntp.TimeSynchronization;
import?cn.com.webinfo.model.Cable;
import?cn.com.webinfo.model.Monitordata;
import?cn.com.webinfo.service.CableManager;
import?cn.com.webinfo.service.MonitordataManager;
import?cn.com.webinfo.util.Common;

/*?通信處理程序
?*?發出修改采樣間隔指令
?*?接受來自下位機的采集數據，并計算基頻，存入數據庫
?*/

public?class?ApplayerHandler?implements?IApplayerHandler?{

	private?ExchangeHandler?exchangeHandler;
	
	private?MonitordataManager?monitordataManager;	
	
	private?CableManager?cableManager;	
	
	private?byte[]?dataFromClient?=?new?byte[1024];

	public?ApplayerHandler（）?throws?InterruptedException?{
		exchangeHandler?=?ExchangeHandler.getInstance（）;
		exchangeHandler.setIAppHandler（this）;
		exchangeHandler.init（）;?//?數據交換層初始化
	}

	//發送修改下位機采樣時間間隔命令
	public?void?excuteSendDataCommand（String?dataToSend?String?targetIP）?throws?IOException?InterruptedException?{
		//?發送
		QueueData?qd?=?new?QueueData（）;
		qd.setNeedPrioritySort（true）;
		qd.setNeedZip（false）;
		qd.setPriority（4）;
		qd.setDestination（targetIP）;
		qd.setMonitorId（2）;
		qd.setQueueModel（1）;
		qd.setmyId（myId）;?//?I?am?1
		qd.setResendCount（0）;
		qd.setNeedReliable（true）;
		qd.setOutData（dataToSend.getBytes（））;
		qd.setLength（dataToSend.getBytes（）.length）;
		exchangeHandler.addToQueue（qd）;
		System.out.println（“Now:“?+?System.currentTimeMillis（））;
	}
	
	//發送下位機時間同步廣播指令
	public?void?excuteSendTimeSyncCommand（String?dataToSend?String?targetIP）?throws?IOException?InterruptedException{
		QueueData?qd?=?new?QueueData（）;
		qd.setNeedPrioritySort（true）;
		qd.setNeedZip（false）;
		qd.setPriority（7）;
		qd.setDestination（targetIP）;
		qd.setMonitorId（2）;
		qd.setQueueModel（1）;
		qd.setmyId（myId）;?//?I?am?1
		qd.setResendCount（0）;
		qd.setNeedReliable（true）;
		qd.setOutData（dataToSend.getBytes（））;
		qd.setLength（dataToSend.getBytes（）.length）;
		exchangeHandler.addToQueue（qd）;
		System.out.println（“Now:“?+?System.currentTimeMillis（））;		
	}

	//通信系統數據接受
	public?void?setDataFromExchange（byte[]?dataFromComm?int?priority）?{
		if?（dataFromComm?!=?null）?{
			System.out.println（“S:數據交換層上交給應用層的數據長度:“?+?dataFromComm.length?+?“優先級為:“?+?priority）;
			try?{
				Date?rectime?=?new?Date（）;
				System.out.print（“S:“?+?new?String（dataFromComm?“GBK“））;
				System.out.println（““）;
				dataFromClient?=?dataFromComm;
				String?stringFromClient?=?new?String（dataFromClient）;
				//?接受的采樣基頻數據分解
				//?###########################################
				//?#?????????#索號：時間@1，基頻；?????????????????#
				//?###########################################
				if?（stringFromClient.indexOf（“#“）?!=?-1）?{
					
			

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件???????2682??2009-09-07?10:21??upper-computer\.classpath

?????文件????????185??2009-09-07?10:21??upper-computer\.hibernateSynchronizer

?????文件????????589??2009-09-27?10:53??upper-computer\.hibernateSynchronizer3\config.properties

?????文件?????????66??2009-09-07?10:21??upper-computer\.myumldata

?????文件????????390??2009-09-07?10:21??upper-computer\.project

?????文件?????????86??2009-09-07?10:21??upper-computer\.settings\org.eclipse.core.resources.prefs

?????文件????????620??2009-09-07?10:21??upper-computer\.settings\org.eclipse.jdt.core.prefs

?????文件????????179??2009-09-07?10:21??upper-computer\.settings\org.eclipse.jdt.ui.prefs

?????文件????????272??2009-09-07?10:21??upper-computer\.springBeans

?????文件???????6630??2009-09-22?14:35??upper-computer\bin\cn\com\webinfo\action\application\ApplayerHandler.class

?????文件???????3132??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\application\MonitorServer.class

?????文件???????1052??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\application\Starter.class

?????文件???????1838??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\application\TestPOJO.class

?????文件????????676??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\applicationlayer\IApplayerHandler.class

?????文件????????324??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\ACKList.class

?????文件???????2317??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\ACKPacket.class

?????文件???????4318??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\Channel.class

?????文件??????17530??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\CommHandler.class

?????文件????????739??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\CsDetectTask.class

?????文件???????3353??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataDePacket.class

?????文件???????6942??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataPacket.class

?????文件???????3728??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataRePacket.class

?????文件???????2355??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\NACKPacket.class

?????文件???????1958??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\NetInterface.class

?????文件????????715??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDU.class

?????文件????????324??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDUPool.class

?????文件????????333??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDUWithSeq.class

?????文件???????4580??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\SendACKTask.class

?????文件???????3898??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\SendNACKTask.class

?????文件????????915??2009-09-07?10:21??upper-computer\bin\cn\com\webinfo\action\communicatelayer\SeqmanageTask.class

............此處省略215個文件信息